|
|
@@ -1,17 +1,13 @@
|
|
|
package com.abi.qms.platform.infrastructure.mq;
|
|
|
|
|
|
-import cn.hutool.core.io.FileUtil;
|
|
|
import cn.hutool.core.io.file.FileWriter;
|
|
|
-import com.abi.base.foundation.util.JsonUtil;
|
|
|
import com.abi.base.foundation.util.RedisClient;
|
|
|
import com.abi.qms.platform.dao.entity.*;
|
|
|
import com.abi.qms.platform.dao.enums.InvalidEnum;
|
|
|
-import com.abi.qms.platform.dao.enums.QrFormatUrlEnum;
|
|
|
import com.abi.qms.platform.dao.enums.QrPackageGenerateStatusEnum;
|
|
|
import com.abi.qms.platform.dao.enums.QrRepertoryTypeEnum;
|
|
|
import com.abi.qms.platform.dao.mapper.*;
|
|
|
import com.abi.qms.platform.dao.tablestore.entity.QrCode;
|
|
|
-import com.abi.qms.platform.dao.vo.result.QrPackageVO;
|
|
|
import com.abi.qms.platform.dao.vo.result.QrRepertoryColumnVO;
|
|
|
import com.abi.qms.platform.dao.vo.result.QrRepertoryVO;
|
|
|
import com.abi.qms.platform.feign.BasicServiceClient;
|
|
|
@@ -24,11 +20,13 @@ import com.abi.task.common.tablestore.TableStorePlusUtils;
|
|
|
import com.abi.task.common.tablestore.common.TableStoreEntity;
|
|
|
import com.abi.task.common.utils.PojoConverterUtils;
|
|
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
|
|
-import com.baomidou.mybatisplus.core.toolkit.IdWorker;
|
|
|
import com.rabbitmq.client.Channel;
|
|
|
-import com.sun.xml.internal.bind.v2.TODO;
|
|
|
import lombok.SneakyThrows;
|
|
|
import lombok.extern.slf4j.Slf4j;
|
|
|
+import net.lingala.zip4j.core.ZipFile;
|
|
|
+import net.lingala.zip4j.exception.ZipException;
|
|
|
+import net.lingala.zip4j.model.ZipParameters;
|
|
|
+import net.lingala.zip4j.util.Zip4jConstants;
|
|
|
import org.apache.commons.fileupload.FileItem;
|
|
|
import org.apache.commons.fileupload.FileItemFactory;
|
|
|
import org.apache.commons.fileupload.disk.DiskFileItemFactory;
|
|
|
@@ -40,13 +38,8 @@ import org.springframework.amqp.rabbit.annotation.RabbitHandler;
|
|
|
import org.springframework.amqp.rabbit.annotation.RabbitListener;
|
|
|
import org.springframework.amqp.support.AmqpHeaders;
|
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
|
-import org.springframework.beans.factory.annotation.Value;
|
|
|
import org.springframework.messaging.Message;
|
|
|
import org.springframework.stereotype.Component;
|
|
|
-import net.lingala.zip4j.core.ZipFile;
|
|
|
-import net.lingala.zip4j.exception.ZipException;
|
|
|
-import net.lingala.zip4j.model.ZipParameters;
|
|
|
-import net.lingala.zip4j.util.Zip4jConstants;
|
|
|
import org.springframework.util.DigestUtils;
|
|
|
import org.springframework.web.multipart.MultipartFile;
|
|
|
import org.springframework.web.multipart.commons.CommonsMultipartFile;
|
|
|
@@ -56,9 +49,7 @@ import java.io.FileInputStream;
|
|
|
import java.io.IOException;
|
|
|
import java.io.OutputStream;
|
|
|
import java.nio.charset.StandardCharsets;
|
|
|
-import java.text.SimpleDateFormat;
|
|
|
import java.time.LocalDateTime;
|
|
|
-import java.time.format.DateTimeFormatter;
|
|
|
import java.util.*;
|
|
|
import java.util.stream.Collectors;
|
|
|
|
tanzhongran