Merge remote-tracking branch 'origin/dev_fifo_z' into dev_fifo_z

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;
+            int page = 1;
-        GetSickPrescribeRequest getSickPrescribeRequest = new GetSickPrescribeRequest();
+            int limit = 100;
-        getSickPrescribeRequest.setLimit(limit);
+            GetSickPrescribeRequest getSickPrescribeRequest = new GetSickPrescribeRequest();
-        getSickPrescribeRequest.setCode(collectOrderRequest.getBillNo());
+            getSickPrescribeRequest.setLimit(limit);
-        getSickPrescribeRequest.setThirdSys("thirdId");
+            getSickPrescribeRequest.setCode(collectOrderRequest.getBillNo());
-        getSickPrescribeRequest.setWorkPlaceCode(collectOrderRequest.getWorkPlaceCode());
+            getSickPrescribeRequest.setThirdSys("thirdId");
-        getSickPrescribeRequest.setFromType(collectOrderRequest.getFromType());
+            getSickPrescribeRequest.setWorkPlaceCode(collectOrderRequest.getWorkPlaceCode());
-        getSickPrescribeRequest.setStartTime(collectOrderRequest.getStartTime());
+            getSickPrescribeRequest.setFromType(collectOrderRequest.getFromType());
-        getSickPrescribeRequest.setEndTime(collectOrderRequest.getEndTime());
+            getSickPrescribeRequest.setStartTime(collectOrderRequest.getStartTime());
-        getSickPrescribeRequest.setKey(collectOrderRequest.getKeyWords());
+            getSickPrescribeRequest.setEndTime(collectOrderRequest.getEndTime());
-        getSickPrescribeRequest.setBusType(collectOrderRequest.getBusType());
+            getSickPrescribeRequest.setKey(collectOrderRequest.getKeyWords());
-        while (true) {
+            getSickPrescribeRequest.setBusType(collectOrderRequest.getBusType());
-            getSickPrescribeRequest.setPage(page);
+            while (true) {
-            BaseResponse<PageSimpleResponse<IoCollectOrder>> baseResponse = erpBasicClient.getPrescribeV2(getSickPrescribeRequest);
+                List<IoCollectOrder> list;
-
+                try {
-            // TODO: 2024/9/11 添加一张中间表（io_collect_order_origin）原始表做为转换
+                getSickPrescribeRequest.setPage(page);
-
+                BaseResponse<PageSimpleResponse<IoCollectOrder>> baseResponse = erpBasicClient.getPrescribeV2(getSickPrescribeRequest);
-            if (baseResponse.getCode() == 20000) {
+
-                List<IoCollectOrder> list = baseResponse.getData().getList();
+                // TODO: 2024/9/11 添加一张中间表（io_collect_order_origin）原始表做为转换
-                if (list == null) {
+
-                    return ResultVOUtils.error(500, "未查到此业务单据");
+                if (baseResponse.getCode() == 20000) {
-                }
+                    list = baseResponse.getData().getList();
-                thrOrderDownload.importThrOrder(list, collectOrderRequest);
+                    if (list == null) {
-                if ((list.size() >= limit && !baseResponse.getData().getTotal().equals(-666)) || IntUtil.value(baseResponse.getData().getTotal()) == -555) {
+                        return ResultVOUtils.error(500, "未查到此业务单据");
-                    page++;
+                    }
+                    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("下载成功");
     }
 }