From a135aa1d853ef78c6635547ee266ea6689805075 Mon Sep 17 00:00:00 2001
From: HAHA <HAHA@etoak.com>
Date: Thu, 7 Jul 2022 18:00:03 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E4=B8=BA=E5=A2=9E=E9=87=8F?=
 =?UTF-8?q?=E6=B7=BB=E5=8A=A0?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../dao/CaKettleBaseDisputeProcessDao.java    | 10 ++++
 ...CaKettleBaseDisputeProcessServiceImpl.java | 47 +++++++++----------
 .../mapper/CaKettleBaseDisputeProcessDao.xml  |  9 ++++
 3 files changed, 42 insertions(+), 24 deletions(-)

diff --git a/epmet-module/open-data-worker/open-data-worker-server/src/main/java/com/epmet/opendata/dao/CaKettleBaseDisputeProcessDao.java b/epmet-module/open-data-worker/open-data-worker-server/src/main/java/com/epmet/opendata/dao/CaKettleBaseDisputeProcessDao.java
index b5de69ed29..499338ca6d 100644
--- a/epmet-module/open-data-worker/open-data-worker-server/src/main/java/com/epmet/opendata/dao/CaKettleBaseDisputeProcessDao.java
+++ b/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();
 }
diff --git a/epmet-module/open-data-worker/open-data-worker-server/src/main/java/com/epmet/opendata/service/impl/CaKettleBaseDisputeProcessServiceImpl.java b/epmet-module/open-data-worker/open-data-worker-server/src/main/java/com/epmet/opendata/service/impl/CaKettleBaseDisputeProcessServiceImpl.java
index 700a264a06..76de183169 100644
--- a/epmet-module/open-data-worker/open-data-worker-server/src/main/java/com/epmet/opendata/service/impl/CaKettleBaseDisputeProcessServiceImpl.java
+++ b/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));
     }
 
     /**
diff --git a/epmet-module/open-data-worker/open-data-worker-server/src/main/resources/mapper/CaKettleBaseDisputeProcessDao.xml b/epmet-module/open-data-worker/open-data-worker-server/src/main/resources/mapper/CaKettleBaseDisputeProcessDao.xml
index c2919cd375..805b335e1a 100644
--- a/epmet-module/open-data-worker/open-data-worker-server/src/main/resources/mapper/CaKettleBaseDisputeProcessDao.xml
+++ b/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>