From 64f3440afdf6168aa8e5968eb74fec24caabd9f1 Mon Sep 17 00:00:00 2001
From: qiuyt <zane0312@foxmail.com>
Date: Thu, 26 Dec 2024 17:52:37 +0800
Subject: [PATCH] =?UTF-8?q?=E4=B8=8B=E8=BD=BD=E4=B8=89=E6=96=B9=E9=94=99?=
 =?UTF-8?q?=E8=AF=AF?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../service/collect/down/YPCF002Download.java | 70 +++++++++++--------
 1 file changed, 40 insertions(+), 30 deletions(-)

diff --git a/src/main/java/com/glxp/api/service/collect/down/YPCF002Download.java b/src/main/java/com/glxp/api/service/collect/down/YPCF002Download.java
index 1a7ffdc32..87c98465f 100644
--- a/src/main/java/com/glxp/api/service/collect/down/YPCF002Download.java
+++ b/src/main/java/com/glxp/api/service/collect/down/YPCF002Download.java
@@ -9,6 +9,7 @@ import com.glxp.api.req.collect.CollectOrderRequest;
 import com.glxp.api.res.PageSimpleResponse;
 import com.glxp.api.service.collect.IoCollectOrderService;
 import com.glxp.api.util.IntUtil;
+import org.jfree.util.Log;
 import org.springframework.stereotype.Service;
 
 import javax.annotation.Resource;
@@ -25,39 +26,48 @@ public class YPCF002Download implements IDownload {
 
     @Override
     public BaseResponse downloadOrder(CollectOrderRequest collectOrderRequest) {
-        int page = 1;
-        int limit = 100;
-        GetSickPrescribeRequest getSickPrescribeRequest = new GetSickPrescribeRequest();
-        getSickPrescribeRequest.setLimit(limit);
-        getSickPrescribeRequest.setCode(collectOrderRequest.getBillNo());
-        getSickPrescribeRequest.setThirdSys("thirdId");
-        getSickPrescribeRequest.setWorkPlaceCode(collectOrderRequest.getWorkPlaceCode());
-        getSickPrescribeRequest.setFromType(collectOrderRequest.getFromType());
-        getSickPrescribeRequest.setStartTime(collectOrderRequest.getStartTime());
-        getSickPrescribeRequest.setEndTime(collectOrderRequest.getEndTime());
-        getSickPrescribeRequest.setKey(collectOrderRequest.getKeyWords());
-        getSickPrescribeRequest.setBusType(collectOrderRequest.getBusType());
-        while (true) {
-            getSickPrescribeRequest.setPage(page);
-            BaseResponse<PageSimpleResponse<IoCollectOrder>> baseResponse = erpBasicClient.getPrescribeV2(getSickPrescribeRequest);
-
-            // TODO: 2024/9/11 添加一张中间表（io_collect_order_origin）原始表做为转换
-
-            if (baseResponse.getCode() == 20000) {
-                List<IoCollectOrder> list = baseResponse.getData().getList();
-                if (list == null) {
-                    return ResultVOUtils.error(500, "未查到此业务单据");
-                }
-                thrOrderDownload.importThrOrder(list, collectOrderRequest);
-                if ((list.size() >= limit && !baseResponse.getData().getTotal().equals(-666)) || IntUtil.value(baseResponse.getData().getTotal()) == -555) {
-                    page++;
+
+            int page = 1;
+            int limit = 100;
+            GetSickPrescribeRequest getSickPrescribeRequest = new GetSickPrescribeRequest();
+            getSickPrescribeRequest.setLimit(limit);
+            getSickPrescribeRequest.setCode(collectOrderRequest.getBillNo());
+            getSickPrescribeRequest.setThirdSys("thirdId");
+            getSickPrescribeRequest.setWorkPlaceCode(collectOrderRequest.getWorkPlaceCode());
+            getSickPrescribeRequest.setFromType(collectOrderRequest.getFromType());
+            getSickPrescribeRequest.setStartTime(collectOrderRequest.getStartTime());
+            getSickPrescribeRequest.setEndTime(collectOrderRequest.getEndTime());
+            getSickPrescribeRequest.setKey(collectOrderRequest.getKeyWords());
+            getSickPrescribeRequest.setBusType(collectOrderRequest.getBusType());
+            while (true) {
+                List<IoCollectOrder> list;
+                try {
+                getSickPrescribeRequest.setPage(page);
+                BaseResponse<PageSimpleResponse<IoCollectOrder>> baseResponse = erpBasicClient.getPrescribeV2(getSickPrescribeRequest);
+
+                // TODO: 2024/9/11 添加一张中间表（io_collect_order_origin）原始表做为转换
+
+                if (baseResponse.getCode() == 20000) {
+                    list = baseResponse.getData().getList();
+                    if (list == null) {
+                        return ResultVOUtils.error(500, "未查到此业务单据");
+                    }
+                    thrOrderDownload.importThrOrder(list, collectOrderRequest);
+                    if ((list.size() >= limit && !baseResponse.getData().getTotal().equals(-666)) || IntUtil.value(baseResponse.getData().getTotal()) == -555) {
+                        page++;
+                    } else {
+                        break;
+                    }
                 } else {
-                    break;
+                    return ResultVOUtils.error(500, "下载第三方系统产品信息异常");
+                }
+                }catch (Exception e){
+                    System.out.println("下载三方错误==="+e.getMessage()+"==="+collectOrderRequest);
+                    e.printStackTrace();
                 }
-            } else {
-                return ResultVOUtils.error(500, "下载第三方系统产品信息异常");
             }
-        }
+
+
         return ResultVOUtils.success("下载成功");
     }
 }