From 40fa68080b3aa466df0a7c6284edc2224b85662a Mon Sep 17 00:00:00 2001
From: chenhc <2369838784@qq.com>
Date: Fri, 6 Dec 2024 17:39:26 +0800
Subject: [PATCH] =?UTF-8?q?fix:=20=E4=B8=8B=E8=BD=BD=E8=AE=BE=E5=A4=87?=
 =?UTF-8?q?=E7=9A=84=E6=94=B6=E7=9B=8A=E6=98=8E=E7=BB=86=E5=8A=9F=E8=83=BD?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../thrsys/DeviceBusinessProjectService.java   | 18 +++++++-----------
 1 file changed, 7 insertions(+), 11 deletions(-)

diff --git a/src/main/java/com/glxp/api/service/thrsys/DeviceBusinessProjectService.java b/src/main/java/com/glxp/api/service/thrsys/DeviceBusinessProjectService.java
index 969687060..7410a53a8 100644
--- a/src/main/java/com/glxp/api/service/thrsys/DeviceBusinessProjectService.java
+++ b/src/main/java/com/glxp/api/service/thrsys/DeviceBusinessProjectService.java
@@ -120,6 +120,7 @@ public class DeviceBusinessProjectService extends ServiceImpl<DeviceBusinessProj
         while (true) {
             query.setPage(page);
             BaseResponse<PageSimpleResponse<DeviceBusinessProject>> baseResponse = erpBasicClient.getDeviceBusinessProject(query);
+            log.error(String.valueOf(baseResponse));
             if (baseResponse.getCode() == 20000) {
                 List<DeviceBusinessProject> list = baseResponse.getData().getList();
                 if (CollUtil.isNotEmpty(list)) {
@@ -128,11 +129,15 @@ public class DeviceBusinessProjectService extends ServiceImpl<DeviceBusinessProj
                         item.setCreateTime(new Date());
                         item.setUpdateTime(new Date());
                         // TODO: 2024/12/6 物资系统的部门编码转化 自身系统的编码和名称
-
-
                         addList.add(item);
                     });
+
+                    if (CollUtil.isNotEmpty(addList)){
+                        this.saveBatch(addList);
+                        addList.clear();
+                    }
                 }
+
                 if (list.size() >= limit && !baseResponse.getData().getTotal().equals(-666)) {
                     page++;
                 } else {
@@ -141,15 +146,6 @@ public class DeviceBusinessProjectService extends ServiceImpl<DeviceBusinessProj
             } else {
                 throw new JsonException("下载异常中断");
             }
-
-            if (addList.size() >= 500){
-                this.saveBatch(addList);
-            }
         }
-
-        if (CollUtil.isNotEmpty(addList)){
-            this.saveBatch(addList);
-        }
-
     }
 }