修改为增量添加

epmet-module/open-data-worker/open-data-worker-server/src/main/java/com/epmet/opendata/dao/CaKettleBaseDisputeProcessDao.java

@@ -47,4 +47,14 @@ public interface CaKettleBaseDisputeProcessDao extends BaseDao<CaKettleBaseDispu
      * @date 2022/7/6 17:47
      */
     CaKettleDetailsResultDTO getCaKettleDetails(@Param("form") CaKettleDetailsById form);
+
+    /**
+     * 查询最后一个baseKeyId
+     *
+     * @param
+     * @return java.lang.String
+     * @author LZN
+     * @date 2022/7/7 16:47
+     */
+    String selectBaseKeyId();
 }

epmet-module/open-data-worker/open-data-worker-server/src/main/java/com/epmet/opendata/service/impl/CaKettleBaseDisputeProcessServiceImpl.java

@@ -108,31 +108,30 @@ public class CaKettleBaseDisputeProcessServiceImpl extends BaseServiceImpl<CaKet
      */
     @Override
     public void getPreserKettleVation(PreserVationFormDTO dto) {
-        int i = baseDao.deleteAll();
-        if (i >= 0) {
-            dto.setPageNo(NumConstant.ONE);
-            dto.setPageSize(CaWghDataConstant.PAGE_LIMIT);
-            dto.setTableSchema(CaWghDataConstant.TABLESCHEMA_UNICOM);
-            dto.setTableName(CaWghDataConstant.UNICOM_KETTLE);
-
-            dto.setWhereCase("1=1");
-            dto.setOrderBy("timelimit,create_time,update_time,import_time,eventdate desc");
-
-            int pageNo = 1;
-
-            int total = 0;
-
-            do {
-                try {
-                    total = listKettle(dto);
-                    pageNo++;
-                    dto.setPageNo(pageNo);
-                } catch (Exception e) {
-                    e.printStackTrace();
-                }
-            } while (total > (pageNo * NumConstant.FIFTY));
-        }
 
+        dto.setPageNo(NumConstant.ONE);
+        dto.setPageSize(CaWghDataConstant.PAGE_LIMIT);
+        dto.setTableSchema(CaWghDataConstant.TABLESCHEMA_UNICOM);
+        dto.setTableName(CaWghDataConstant.UNICOM_KETTLE);
+        dto.setOrderBy("timelimit,create_time,update_time,import_time,eventdate desc");
+
+        int pageNo = 1;
+
+        int total = 0;
+
+        String id = baseDao.selectBaseKeyId();
+
+        dto.setWhereCase("base_key_id >" + id);
+
+        do {
+            try {
+                total = listKettle(dto);
+                pageNo++;
+                dto.setPageNo(pageNo);
+            } catch (Exception e) {
+                e.printStackTrace();
+            }
+        } while (total > (pageNo * NumConstant.FIFTY));
     }
 
     /**

epmet-module/open-data-worker/open-data-worker-server/src/main/resources/mapper/CaKettleBaseDisputeProcessDao.xml

@@ -48,5 +48,14 @@
         where
             base_key_id = #{form.baseKeyId}
     </select>
+    <select id="selectBaseKeyId" resultType="java.lang.String">
+        SELECT
+            base_key_id
+        FROM
+            ca_kettle_base_dispute_process
+        ORDER BY
+            base_key_id DESC
+            LIMIT 1
+    </select>
 
 </mapper>