优化

ParamInsertDb/src/main/java/com/nm/gsgl/common/utils/UnzipUtil.java

@@ -27,7 +27,7 @@ import java.util.zip.ZipInputStream;
  * @date: 2022年11月09日 10:03
  * @description: 解压缩文件工具类
  */
-@Slf4j
+//@Slf4j
 public class UnzipUtil {
     private static final int BUFFER = 1024;
     private static final String CODING_GBK = "GBK";
@@ -43,11 +43,11 @@ public class UnzipUtil {
      * @return java.util.List<java.lang.String>
      */
     public static List<String> UnzipFile(String uuid, String fileAllPath, String destDir) {
-        log.info("[uuid:{}]解析zip文件插入数据库开始，{}", uuid, fileAllPath);
+        //log.info("[uuid:{}]解析zip文件插入数据库开始，{}", uuid, fileAllPath);
         //解压之前先清空解压目标目录
-        log.info("[uuid:{}]清空解压目标目录，{}", uuid, destDir);
+        //log.info("[uuid:{}]清空解压目标目录，{}", uuid, destDir);
         FileUtil.removeFiles(new File(destDir));
-        log.info("[uuid:{}]解析zip文件{}生成json转对象开始", uuid, fileAllPath);
+        //log.info("[uuid:{}]解析zip文件{}生成json转对象开始", uuid, fileAllPath);
         //解压缩文件
         UnzipUtil.dealUnZip(fileAllPath, destDir);
         return FileUtil.getJsonPaths(destDir);
@@ -65,7 +65,7 @@ public class UnzipUtil {
             //解压缩执行方法
             decompressFile(new File(zipPath), new File(unzipPath), srcList);
         } catch (Exception e) {
-            log.error("解压缩失败:{}", e.getMessage(), e);
+            //log.error("解压缩失败:{}", e.getMessage(), e);
             throw new PPException(MessageEnum.系统异常.getCode(), MessageEnum.系统异常.getMessage());
         }
         return srcList;

ParamInsertDb/src/main/java/com/nm/gsgl/service/impl/InsertParamDbServiceImpl.java

@@ -67,6 +67,9 @@ public class InsertParamDbServiceImpl implements InsertParamDbService {
             for (FileInfo fileInfo : fileInfos) {
                 String fileName = fileInfo.getFileName();
                 String filePath = fileInfo.getFilePath();
+                log.info("[uuid:{}]解析zip文件插入数据库开始，{}", uuid, filePath);
+                //解压之前先清空解压目标目录
+                log.info("[uuid:{}]清空解压目标目录，{}", uuid, destDir);
                 List<String> jsonPathList = UnzipUtil.UnzipFile(uuid, filePath, destDir);
                 //黑名单全量或增量
                 if (fileName.contains("CARDBLACKLISTDOWN") || fileName.contains("CARDBLACKLISTINCREDOWN")) {

ParamInsertDb/src/main/java/com/nm/gsgl/service/impl/MinFeeIntoDataBaseServiceImpl.java

@@ -82,6 +82,8 @@ public class MinFeeIntoDataBaseServiceImpl implements MinFeeIntoDataBaseService
                         log.info("[uuid:{}]开始将读取的SQB文件:{},插入数据库ALLROADMINFEE_TABLE_1表", uuid, fileName);
                         DatabaseUtil.insertMinFeeDb(TollBankDriverName, TollBankConnectionStringOracle, TollBankOracleName, TollBankOraclePass, allRoadMinFees, Constant.INSERT_MIN_FEE_1);
                         log.info("[uuid:{}]插入数据库ALLROADMINFEE_TABLE_1表中数据条数为:{}", uuid, listSize);
+                    }else {
+                        log.info("[uuid:{}]暂停入库{}数据库ALLROADMINFEE_TABLE_1表", uuid,TollBankConnectionStringOracle);
                     }
                     if(Constant.STR_ONE.equals(isInJTJT)){
                         //先删除原来的数据
@@ -91,10 +93,12 @@ public class MinFeeIntoDataBaseServiceImpl implements MinFeeIntoDataBaseService
                         log.info("[uuid:{}]开始将读取的SQB文件:{},插入数据库ALLROADMINFEE_TABLE表", uuid, fileName);
                         DatabaseUtil.insertMinFeeDb(TollBankDriverName, JTJTConnectionStringOracle, JTJTOracleName, JTJTOraclePass, allRoadMinFees, Constant.INSERT_MIN_FEE);
                         log.info("[uuid:{}]插入数据库ALLROADMINFEE_TABLE表中数据条数为:{}", uuid, listSize);
+                    }else {
+                        log.info("[uuid:{}]暂停入库{}数据库ALLROADMINFEE_TABLE表", uuid,JTJTConnectionStringOracle);
                     }
-                    //删除下载的zip文件
+                    //删除文件
                     FileUtil.fileDelete(filePath);
-                    log.info("[uuid:{}]删除已入库的文件:{}", uuid, filePath);
+                    log.info("[uuid:{}]删除已入库或者暂停入库的文件:{}", uuid, filePath);
                 }
             }
         }