部中心统计入库表INVENTORY_STATISTICS_JAVA

ParamDownload/src/main/java/com/nm/gsgl/common/Constant.java

@@ -208,13 +208,15 @@ public class Constant {
     public static final String UPDATE_APP_ALIVE_STATUS_ALIVEID_1 = "UPDATE APP_ALIVE_STATUS SET ALIVEID = 1 WHERE APPID=1";
     public static final String UPDATE_APP_ALIVE_STATUS_ALIVEID_2 = "UPDATE APP_ALIVE_STATUS SET ALIVEID = 2 WHERE APPID=1";
     public static final String DEL_BUSINESS_OVERDUE = "DELETE FROM business_tasks_info WHERE downloadTime BETWEEN  '2023-01-01 00:00:00'  AND  datetime('now','localtime','-AAAAA day');";
-    public static final String SELECT_BUSINESS_HANDLER_HR_MIN_FEE = "SELECT id,fileName,size,recordCount,downStatus,protocolType,downloadTime,consumTime,version,newVersion,proStatus,middleDatabase,handleStatus,handleTime,publishStatus,publishTime FROM business_tasks_info WHERE protocolType=250 AND middleDatabase = 1 AND handleStatus = 0 OR handleStatus = 2";
+    public static final String SELECT_BUSINESS_HANDLER_HR_MIN_FEE = "SELECT id,fileName,size,recordCount,downStatus,protocolType,downloadTime,consumTime,version,newVersion,proStatus,middleDatabase,handleStatus,handleTime,publishStatus,publishTime,createTime FROM business_tasks_info WHERE protocolType=250 AND middleDatabase = 1 AND handleStatus = 0 OR handleStatus = 2";
-    public static final String SELECT_BUSINESS_HANDLER_HR = "SELECT id,fileName,size,recordCount,downStatus,protocolType,downloadTime,consumTime,version,newVersion,proStatus,middleDatabase,handleStatus,handleTime,publishStatus,publishTime FROM business_tasks_info WHERE  protocolType not in (250,241,242,244) AND middleDatabase = 1 AND handleStatus = 0 OR handleStatus = 2";
+    //public static final String SELECT_BUSINESS_HANDLER_HR = "SELECT id,fileName,size,recordCount,downStatus,protocolType,downloadTime,consumTime,version,newVersion,proStatus,middleDatabase,handleStatus,handleTime,publishStatus,publishTime FROM business_tasks_info WHERE  protocolType not in (250,241,242,244) AND middleDatabase = 1 AND handleStatus = 0 OR handleStatus = 2";
-    public static final String SELECT_BUSINESS_HANDLER_HR_241 = "SELECT id,fileName,size,recordCount,downStatus,protocolType,downloadTime,consumTime,version,newVersion,proStatus,middleDatabase,handleStatus,handleTime,publishStatus,publishTime FROM business_tasks_info WHERE  protocolType  in (241) AND middleDatabase = 1 AND handleStatus = 0 OR handleStatus = 2";
+    public static final String SELECT_BUSINESS_HANDLER_HR_SQB = "SELECT id,fileName,size,recordCount,downStatus,protocolType,downloadTime,consumTime,version,newVersion,proStatus,middleDatabase,handleStatus,handleTime,publishStatus,publishTime,createTime FROM business_tasks_info WHERE  protocolType  in (101,102,103,104,105,106,107,108,111,801,802,808,809,919,920) AND middleDatabase = 1 AND handleStatus = 0 OR handleStatus = 2";
-    public static final String SELECT_BUSINESS_HANDLER_HR_242 = "SELECT id,fileName,size,recordCount,downStatus,protocolType,downloadTime,consumTime,version,newVersion,proStatus,middleDatabase,handleStatus,handleTime,publishStatus,publishTime FROM business_tasks_info WHERE  protocolType  in (242) AND middleDatabase = 1 AND handleStatus = 0 OR handleStatus = 2";
+    public static final String SELECT_BUSINESS_HANDLER_HR_INSERT = "SELECT id,fileName,size,recordCount,downStatus,protocolType,downloadTime,consumTime,version,newVersion,proStatus,middleDatabase,handleStatus,handleTime,publishStatus,publishTime,createTime FROM business_tasks_info WHERE  protocolType  in (237,240,243,245,246,302,304,306,501,502,503,604,605,804,803,901,902,903,904,905,917,918,922,923,924,925) AND middleDatabase = 1 AND handleStatus = 0 OR handleStatus = 2";
-    public static final String SELECT_BUSINESS_HANDLER_HR_244 = "SELECT id,fileName,size,recordCount,downStatus,protocolType,downloadTime,consumTime,version,newVersion,proStatus,middleDatabase,handleStatus,handleTime,publishStatus,publishTime FROM business_tasks_info WHERE  protocolType  in (244) AND middleDatabase = 1 AND handleStatus = 0 OR handleStatus = 2";
+    public static final String SELECT_BUSINESS_HANDLER_HR_241 = "SELECT id,fileName,size,recordCount,downStatus,protocolType,downloadTime,consumTime,version,newVersion,proStatus,middleDatabase,handleStatus,handleTime,publishStatus,publishTime,createTime FROM business_tasks_info WHERE  protocolType = 241 AND middleDatabase = 1 AND handleStatus = 0 OR handleStatus = 2";
-    public static final String SELECT_BUSINESS_HANDLER_MD = "SELECT id,fileName,size,recordCount,downStatus,protocolType,downloadTime,consumTime,version,newVersion,proStatus,middleDatabase,handleStatus,handleTime,publishStatus,publishTime FROM business_tasks_info WHERE middleDatabase = 2 AND handleStatus = 0 OR handleStatus = 2";
+    public static final String SELECT_BUSINESS_HANDLER_HR_242 = "SELECT id,fileName,size,recordCount,downStatus,protocolType,downloadTime,consumTime,version,newVersion,proStatus,middleDatabase,handleStatus,handleTime,publishStatus,publishTime,createTime FROM business_tasks_info WHERE  protocolType = 242 AND middleDatabase = 1 AND handleStatus = 0 OR handleStatus = 2";
-    public static final String SELECT_BUSINESS_BY_ID = "SELECT id,fileName,size,recordCount,downStatus,protocolType,downloadTime,consumTime,version,newVersion,proStatus,middleDatabase,handleStatus,handleTime,publishStatus,publishTime FROM business_tasks_info WHERE id =";
+    public static final String SELECT_BUSINESS_HANDLER_HR_244 = "SELECT id,fileName,size,recordCount,downStatus,protocolType,downloadTime,consumTime,version,newVersion,proStatus,middleDatabase,handleStatus,handleTime,publishStatus,publishTime,createTime FROM business_tasks_info WHERE  protocolType = 244 AND middleDatabase = 1 AND handleStatus = 0 OR handleStatus = 2";
+    public static final String SELECT_BUSINESS_HANDLER_MD = "SELECT id,fileName,size,recordCount,downStatus,protocolType,downloadTime,consumTime,version,newVersion,proStatus,middleDatabase,handleStatus,handleTime,publishStatus,publishTime,createTime FROM business_tasks_info WHERE middleDatabase = 2 AND handleStatus = 0 OR handleStatus = 2";
+    public static final String SELECT_BUSINESS_BY_ID = "SELECT id,fileName,size,recordCount,downStatus,protocolType,downloadTime,consumTime,version,newVersion,proStatus,middleDatabase,handleStatus,handleTime,publishStatus,publishTime,createTime FROM business_tasks_info WHERE id =";
     public static final String SELECT_BUSINESS_COUNT = "SELECT COUNT(*) FROM business_tasks_info WHERE protocolType in(102,104,802,36)";
     public static final String UPDATE_BUSINESS = "UPDATE business_tasks_info ";
     public static final String UPDATE_BUSINESS_HANDLER = "UPDATE business_tasks_info SET handleStatus = 1 ,publishStatus = 1, handleTime ='";

ParamDownload/src/main/java/com/nm/gsgl/common/utils/DatabaseUtil.java

@@ -1,7 +1,5 @@
 package com.nm.gsgl.common.utils;
 
-import com.nm.gsgl.common.enumeration.MessageEnum;
-import com.nm.gsgl.common.exception.PPException;
 import com.nm.gsgl.entity.intermediary.AppAliveStatus;
 import com.nm.gsgl.entity.intermediary.DownloadNotify;
 import com.nm.gsgl.entity.intermediary.ParamNotify;
@@ -72,15 +70,16 @@ public class DatabaseUtil {
                     bt.setHandleTime(rs.getString("handleTime"));
                     bt.setPublishStatus(rs.getInt("publishStatus"));
                     bt.setPublishTime(rs.getString("publishTime"));
+                    bt.setCreateTime(rs.getString("createTime"));
                     list.add(bt);
                 }
             }
             return list;
         } catch (ClassNotFoundException e) {
-            LogUtil.WriteLog_Error("数据库连接异常" + e.getMessage()+e, "DatabaseUtil");
+            LogUtil.WriteLog_Error("数据库连接异常" + e.getMessage()+e, "DatabaseUtil-selectBusines");
             //throw new PPException(MessageEnum.数据库连接异常.getCode(), MessageEnum.数据库连接异常.getMessage());
         } catch (SQLException e) {
-            LogUtil.WriteLog_Error("sql语句执行失败" + e.getMessage()+e, "DatabaseUtil");
+            LogUtil.WriteLog_Error("sql语句执行失败" + e.getMessage()+e, "DatabaseUtil-selectBusines");
             //throw new PPException(MessageEnum.数据库执行sql失败.getCode(), MessageEnum.数据库执行sql失败.getMessage());
         } finally {
             try {
@@ -133,10 +132,10 @@ public class DatabaseUtil {
             }
             return count;
         } catch (ClassNotFoundException e) {
-             LogUtil.WriteLog_Error("数据库连接异常" + e.getMessage()+e, "DatabaseUtil");
+             LogUtil.WriteLog_Error("数据库连接异常" + e.getMessage()+e, "DatabaseUtil-insertSqlite");
             //throw new PPException(MessageEnum.数据库连接异常.getCode(), MessageEnum.数据库连接异常.getMessage());
         } catch (SQLException e) {
-            LogUtil.WriteLog_Error("sql语句执行失败" + e.getMessage()+e, "DatabaseUtil");
+            LogUtil.WriteLog_Error("sql语句执行失败" + e.getMessage()+e, "DatabaseUtil-insertSqlite");
 
             //throw new PPException(MessageEnum.数据库执行sql失败.getCode(), MessageEnum.数据库执行sql失败.getMessage());
         } finally {
@@ -192,10 +191,10 @@ public class DatabaseUtil {
             //log.info("执行sql语句完成");
             return count;
         } catch (ClassNotFoundException e) {
-             LogUtil.WriteLog_Error("数据库连接异常" + e.getMessage()+e, "DatabaseUtil");
+             LogUtil.WriteLog_Error("数据库连接异常" + e.getMessage()+e, "DatabaseUtil-selectCountSqlite");
             //throw new PPException(MessageEnum.数据库连接异常.getCode(), MessageEnum.数据库连接异常.getMessage());
         } catch (SQLException e) {
-            LogUtil.WriteLog_Error("sql语句执行失败" + e.getMessage()+e, "DatabaseUtil");
+            LogUtil.WriteLog_Error("sql语句执行失败" + e.getMessage()+e, "DatabaseUtil-selectCountSqlite");
 
             //throw new PPException(MessageEnum.数据库执行sql失败.getCode(), MessageEnum.数据库执行sql失败.getMessage());
         } finally {
@@ -319,10 +318,10 @@ public class DatabaseUtil {
             }
             return count;
         } catch (ClassNotFoundException e) {
-             LogUtil.WriteLog_Error("数据库连接异常" + e.getMessage()+e, "DatabaseUtil");
+             LogUtil.WriteLog_Error("数据库连接异常" + e.getMessage()+e, "DatabaseUtil-updateSql");
             //throw new PPException(MessageEnum.数据库连接异常.getCode(), MessageEnum.数据库连接异常.getMessage());
         } catch (SQLException e) {
-            LogUtil.WriteLog_Error("sql语句执行失败" + e.getMessage()+e, "DatabaseUtil");
+            LogUtil.WriteLog_Error("sql语句执行失败" + e.getMessage()+e, "DatabaseUtil-updateSql");
             //throw new PPException(MessageEnum.数据库执行sql失败.getCode(), MessageEnum.数据库执行sql失败.getMessage());
         } finally {
             try {
@@ -371,10 +370,10 @@ public class DatabaseUtil {
             }
             //log.info("执行sql语句完成");
         } catch (ClassNotFoundException e) {
-             LogUtil.WriteLog_Error("数据库连接异常" + e.getMessage()+e, "DatabaseUtil");
+             LogUtil.WriteLog_Error("数据库连接异常" + e.getMessage()+e, "DatabaseUtil-upOrInsertSql");
             //throw new PPException(MessageEnum.数据库连接异常.getCode(), MessageEnum.数据库连接异常.getMessage());
         } catch (SQLException e) {
-            LogUtil.WriteLog_Error("sql语句执行失败" + e.getMessage()+e, "DatabaseUtil");
+            LogUtil.WriteLog_Error("sql语句执行失败" + e.getMessage()+e, "DatabaseUtil-upOrInsertSql");
 
             //throw new PPException(MessageEnum.数据库执行sql失败.getCode(), MessageEnum.数据库执行sql失败.getMessage());
         } finally {
@@ -510,10 +509,10 @@ public class DatabaseUtil {
             }
             return list;
         } catch (ClassNotFoundException e) {
-             LogUtil.WriteLog_Error("数据库连接异常" + e.getMessage()+e, "DatabaseUtil");
+             LogUtil.WriteLog_Error("数据库连接异常" + e.getMessage()+e, "DatabaseUtil-selectDownloadNotify");
             //throw new PPException(MessageEnum.数据库连接异常.getCode(), MessageEnum.数据库连接异常.getMessage());
         } catch (SQLException e) {
-            LogUtil.WriteLog_Error("sql语句执行失败" + e.getMessage()+e, "DatabaseUtil");
+            LogUtil.WriteLog_Error("sql语句执行失败" + e.getMessage()+e, "DatabaseUtil-selectDownloadNotify");
             //throw new PPException(MessageEnum.数据库执行sql失败.getCode(), MessageEnum.数据库执行sql失败.getMessage());
         } finally {
             try {
@@ -581,10 +580,10 @@ public class DatabaseUtil {
             }
             return list;
         } catch (ClassNotFoundException e) {
-             LogUtil.WriteLog_Error("数据库连接异常" + e.getMessage()+e, "DatabaseUtil");
+             LogUtil.WriteLog_Error("数据库连接异常" + e.getMessage()+e, "DatabaseUtil-selectParamNotify");
             //throw new PPException(MessageEnum.数据库连接异常.getCode(), MessageEnum.数据库连接异常.getMessage());
         } catch (SQLException e) {
-            LogUtil.WriteLog_Error("sql语句执行失败" + e.getMessage()+e, "DatabaseUtil");
+            LogUtil.WriteLog_Error("sql语句执行失败" + e.getMessage()+e, "DatabaseUtil-selectParamNotify");
             //throw new PPException(MessageEnum.数据库执行sql失败.getCode(), MessageEnum.数据库执行sql失败.getMessage());
         } finally {
             try {

ParamDownload/src/main/java/com/nm/gsgl/common/utils/DateTimeUtil.java

@@ -192,7 +192,22 @@ public class DateTimeUtil {
         }
         return count;
     }
-
+    /**
+     * 只保留日期部分
+     */
+    public static Date getDateByDay(Date date) {
+        Calendar calendar = Calendar.getInstance();
+        calendar.setTime(date);
+        // 时
+        calendar.set(Calendar.HOUR_OF_DAY, 0);
+        // 分
+        calendar.set(Calendar.MINUTE, 0);
+        // 秒
+        calendar.set(Calendar.SECOND, 0);
+        // 毫秒
+        calendar.set(Calendar.MILLISECOND, 0);
+        return calendar.getTime();
+    }
     public static void main(String[] args) throws ParseException {
         String d1 = "2023-07-27 08:54:00";
         Date formatDate = getFormatDate(d1, Constant.YYYY_MM_DD_HH_MM_SS);

ParamDownload/src/main/java/com/nm/gsgl/common/utils/StringUtil.java

@@ -95,7 +95,7 @@ public class StringUtil {
      */
     public static String sqliteInsert(BusinessTasks bt) {
         StringBuilder sb = new StringBuilder();
-        sb.append("INSERT INTO business_tasks_info (id,fileName,size,recordCount,downStatus,protocolType,downloadTime,consumTime,version,newVersion,proStatus,middleDatabase,handleStatus) VALUES(")
+        sb.append("INSERT INTO business_tasks_info (id,fileName,size,recordCount,downStatus,protocolType,downloadTime,consumTime,version,newVersion,proStatus,middleDatabase,handleStatus,createTime) VALUES(")
                 .append(bt.getId()).append(",")
                 .append("'").append(bt.getFileName()).append("'").append(",")
                 .append("'").append(bt.getSize()).append("'").append(",")
@@ -108,7 +108,8 @@ public class StringUtil {
                 .append("'").append(bt.getNewVersion()).append("'").append(",")
                 .append(bt.getProStatus()).append(",")
                 .append(bt.getMiddleDatabase()).append(",")
-                .append(bt.getHandleStatus()).append(")");
+                .append(bt.getHandleStatus()).append(",")
+                .append("'").append(bt.getCreateTime()).append("'").append(")");
         return sb.toString();
     }
 

ParamDownload/src/main/java/com/nm/gsgl/controller/VueTestController.java

@@ -67,10 +67,10 @@ public class VueTestController {
         List<BusinessTasks> businessTasks;
 
         if (StringUtils.isNotBlank(pageInfo.getDownloadTime())) {
-            businessTasks = DatabaseUtil.selectBusines(sqliteDriverName, sqliteUrl, "SELECT id,fileName,size,recordCount,downStatus,protocolType,downloadTime,consumTime,version,newVersion,proStatus,middleDatabase,handleStatus,handleTime,publishStatus,publishTime FROM business_tasks_info WHERE downloadTime LIKE '%" +
+            businessTasks = DatabaseUtil.selectBusines(sqliteDriverName, sqliteUrl, "SELECT id,fileName,size,recordCount,downStatus,protocolType,downloadTime,consumTime,version,newVersion,proStatus,middleDatabase,handleStatus,handleTime,publishStatus,publishTime,createTime FROM business_tasks_info WHERE downloadTime LIKE '%" +
                     pageInfo.getDownloadTime() + "%'");
         } else {
-            businessTasks = DatabaseUtil.selectBusines(sqliteDriverName, sqliteUrl, "SELECT id,fileName,size,recordCount,downStatus,protocolType,downloadTime,consumTime,version,newVersion,proStatus,middleDatabase,handleStatus,handleTime,publishStatus,publishTime FROM business_tasks_info");
+            businessTasks = DatabaseUtil.selectBusines(sqliteDriverName, sqliteUrl, "SELECT id,fileName,size,recordCount,downStatus,protocolType,downloadTime,consumTime,version,newVersion,proStatus,middleDatabase,handleStatus,handleTime,publishStatus,publishTime,createTime FROM business_tasks_info");
         }
         businessTasks.sort(Comparator.comparing(BusinessTasks::getDownloadTime).reversed());
         //log.info("[uuid:{}]-查询Sqlite业务状态表完成，条数为{}", uuid, businessTasks.size());

ParamDownload/src/main/java/com/nm/gsgl/entity/sqlite/BusinessTasks.java

@@ -73,6 +73,10 @@ public class BusinessTasks {
      * 发布时间  yyyy-MM-dd HH:mm:ss
      */
     private String publishTime;
+    /**
+     * 部中心文件创建时间  yyyy-MM-dd HH:mm:ss
+     */
+    private String createTime;;
 
 
 

ParamDownload/src/main/java/com/nm/gsgl/entity/statistics/InventoryStatistics.java

@@ -0,0 +1,68 @@
+package com.nm.gsgl.entity.statistics;
+
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableName;
+import lombok.Data;
+
+import java.util.Date;
+
+/**
+ * @author: shuguang
+ * @date: 2024年07月19日 16:43
+ * @description: 部中心统计入库表
+ */
+@Data
+@TableName("INVENTORY_STATISTICS_JAVA")
+public class InventoryStatistics {
+
+    /**
+     * 下载协议类型
+     */
+    @TableField("PROTOCOLTYPE")
+    private String protocolType;
+    /**
+     *zip文件名称
+     */
+    @TableField("BASICFILENAME")
+    private String basicFilename;
+    /**
+     * 部中心zip文件条数
+     */
+    @TableField("RECORDCOUNT")
+    private Integer recordCount;
+    /**
+     * 部中心zip处理时间  yyyy-MM-dd HH:mm:ss
+     */
+    @TableField("CREATETIME")
+    private Date createTime;
+    /**
+     * 部中心zip处理日期  yyyy-MM-dd
+     */
+    @TableField("CREATEDATE")
+    private Date createDate;
+    /**
+     * 部中心zip文件json解析条数
+     */
+    @TableField("JSONCOUNT")
+    private Integer jsonCount;
+    /**
+     * 入库nmgmpayadmin表名
+     */
+    @TableField("DBTABLENAME")
+    private String dbTableName;
+    /**
+     * 入库nmgmpayadmin条数
+     */
+    @TableField("INSERTCOUNT")
+    private Integer insertCount;
+    /**
+     * 入库nmgmpayadmin表判重条数
+     */
+    @TableField("REPEATCOUNT")
+    private Integer repeatCount;
+    /**
+     * 入库时间  yyyy-MM-dd HH:mm:ss
+     */
+    @TableField("STORAGETIME")
+    private Date storageTime;
+}

ParamDownload/src/main/java/com/nm/gsgl/mapper/statistics/InventoryStatisticsMapper.java

@@ -0,0 +1,14 @@
+package com.nm.gsgl.mapper.statistics;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.nm.gsgl.entity.statistics.InventoryStatistics;
+import org.apache.ibatis.annotations.Mapper;
+
+/**
+ * @author: shuguang
+ * @date: 2024年07月22日 8:17
+ * @description:
+ */
+@Mapper
+public interface InventoryStatisticsMapper extends BaseMapper<InventoryStatistics> {
+}

ParamDownload/src/main/java/com/nm/gsgl/service/impl/EctServiceImpl.java

@@ -96,7 +96,7 @@ public class EctServiceImpl implements EctService {
             //开始下载扫描迈道，华软下载任务
             ftpDownloadService.getHrMdTask(uuid);
             //开始查询sqlite任务表中华软未处理数据任务
-            List<BusinessTasks> businessTasks = DatabaseUtil.selectBusines(sqliteDriverName, sqliteUrl, Constant.SELECT_BUSINESS_HANDLER_HR);
+            List<BusinessTasks> businessTasks = DatabaseUtil.selectBusines(sqliteDriverName, sqliteUrl, Constant.SELECT_BUSINESS_HANDLER_HR_SQB);
             //按照文件类型排序
             businessTasks.sort(Comparator.comparing(BusinessTasks::getProtocolType));
 

ParamDownload/src/main/java/com/nm/gsgl/service/impl/FtpDownloadServiceImpl.java

@@ -178,7 +178,8 @@ public class FtpDownloadServiceImpl implements FtpDownloadService {
                             bt.setMiddleDatabase(1);
                             //办理状态 0-未处理 1-已处理 2-再次轮询处理
                             bt.setHandleStatus(0);
-
+                            //增加部中心zip处理时间  yyyy-MM-dd HH:mm:ss
+                            bt.setCreateTime(downloadNotify.getCREATETIME());
                             String sqliteInsert = StringUtil.sqliteInsert(bt);
                             if (businessTasks.size() == 0) {
                                 DatabaseUtil.insertSqlite(sqliteDriverName, sqliteUrl, sqliteInsert);
@@ -292,6 +293,8 @@ public class FtpDownloadServiceImpl implements FtpDownloadService {
                             bt.setMiddleDatabase(2);
                             //办理状态 0-未处理 1-已处理
                             bt.setHandleStatus(0);
+                            //增加部中心zip处理时间  yyyy-MM-dd HH:mm:ss
+                            bt.setCreateTime(paramNotify.getCREATE_TIME());
                             String sqliteInsert = StringUtil.sqliteInsert(bt);
 
                             if (businessTasks.size() == 0) {
@@ -411,7 +414,8 @@ public class FtpDownloadServiceImpl implements FtpDownloadService {
                             bt.setMiddleDatabase(1);
                             //办理状态 0-未处理 1-已处理 2-再次轮询处理
                             bt.setHandleStatus(0);
-
+                            //增加部中心zip处理时间  yyyy-MM-dd HH:mm:ss
+                            bt.setCreateTime(downloadNotify.getCREATETIME());
                             String sqliteInsert = StringUtil.sqliteInsert(bt);
                             if (businessTasks.size() == 0) {
                                 DatabaseUtil.insertSqlite(sqliteDriverName, sqliteUrl, sqliteInsert);
@@ -533,7 +537,8 @@ public class FtpDownloadServiceImpl implements FtpDownloadService {
                             bt.setMiddleDatabase(1);
                             //办理状态 0-未处理 1-已处理 2-再次轮询处理
                             bt.setHandleStatus(0);
-
+                            //增加部中心zip处理时间  yyyy-MM-dd HH:mm:ss
+                            bt.setCreateTime(downloadNotify.getCREATETIME());
                             String sqliteInsert = StringUtil.sqliteInsert(bt);
                             if (businessTasks.size() == 0) {
                                 DatabaseUtil.insertSqlite(sqliteDriverName, sqliteUrl, sqliteInsert);
@@ -646,7 +651,8 @@ public class FtpDownloadServiceImpl implements FtpDownloadService {
                             bt.setMiddleDatabase(1);
                             //办理状态 0-未处理 1-已处理 2-再次轮询处理
                             bt.setHandleStatus(0);
-
+                            //增加部中心zip处理时间  yyyy-MM-dd HH:mm:ss
+                            bt.setCreateTime(downloadNotify.getCREATETIME());
                             String sqliteInsert = StringUtil.sqliteInsert(bt);
                             if (businessTasks.size() == 0) {
                                 DatabaseUtil.insertSqlite(sqliteDriverName, sqliteUrl, sqliteInsert);
@@ -759,7 +765,8 @@ public class FtpDownloadServiceImpl implements FtpDownloadService {
                             bt.setMiddleDatabase(1);
                             //办理状态 0-未处理 1-已处理 2-再次轮询处理
                             bt.setHandleStatus(0);
-
+                            //增加部中心zip处理时间  yyyy-MM-dd HH:mm:ss
+                            bt.setCreateTime(downloadNotify.getCREATETIME());
                             String sqliteInsert = StringUtil.sqliteInsert(bt);
                             if (businessTasks.size() == 0) {
                                 DatabaseUtil.insertSqlite(sqliteDriverName, sqliteUrl, sqliteInsert);

ParamDownload/src/main/java/com/nm/gsgl/service/impl/IntoDatabaseServiceImpl.java

@@ -77,7 +77,7 @@ public class IntoDatabaseServiceImpl implements IntoDatabaseService {
             //开始下载扫描迈道，华软下载任务
             ftpDownloadService.getHrInsertDBTask(uuid);
             //开始查询sqlite任务表中华软未处理数据任务
-            List<BusinessTasks> businessTasks = DatabaseUtil.selectBusines(sqliteDriverName, sqliteUrl, Constant.SELECT_BUSINESS_HANDLER_HR);
+            List<BusinessTasks> businessTasks = DatabaseUtil.selectBusines(sqliteDriverName, sqliteUrl, Constant.SELECT_BUSINESS_HANDLER_HR_INSERT);
             //按照文件类型排序
             businessTasks.sort(Comparator.comparing(BusinessTasks::getProtocolType));
             if (businessTasks.size() > 0) {

ParamDownload/src/main/java/com/nm/gsgl/service/impl/MinFtpDownloadServiceImpl.java

@@ -155,7 +155,8 @@ public class MinFtpDownloadServiceImpl implements MinFtpDownloadService {
                             bt.setMiddleDatabase(1);
                             //办理状态 0-未处理 1-已处理 2-再次轮询处理
                             bt.setHandleStatus(0);
-
+                            //增加部中心zip处理时间  yyyy-MM-dd HH:mm:ss
+                            bt.setCreateTime(downloadNotify.getCREATETIME());
                             String sqliteInsert = StringUtil.sqliteInsert(bt);
                             if (businessTasks.size() == 0) {
                                 DatabaseUtil.insertSqlite(sqliteDriverName, sqliteUrl, sqliteInsert);