单据批量下载

src/main/java/com/glxp/api/service/collect/down/YPCF002Download.java

@@ -8,6 +8,7 @@ import com.glxp.api.req.basic.GetSickPrescribeRequest;
 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.springframework.stereotype.Service;
 
 import javax.annotation.Resource;
@@ -22,19 +23,29 @@ public class YPCF002Download implements IDownload{
 
     @Override
     public BaseResponse downloadOrder(CollectOrderRequest collectOrderRequest) {
+        int page = 1;
+        int limit = 100;
         GetSickPrescribeRequest getSickPrescribeRequest = new GetSickPrescribeRequest();
-        getSickPrescribeRequest.setPage(1);
-        getSickPrescribeRequest.setLimit(100);
+        getSickPrescribeRequest.setLimit(limit);
         getSickPrescribeRequest.setCode(collectOrderRequest.getBillNo());
         getSickPrescribeRequest.setThirdSys("thirdId");
         getSickPrescribeRequest.setWorkPlaceCode(collectOrderRequest.getWorkPlaceCode());
         getSickPrescribeRequest.setFromType(collectOrderRequest.getFromType());
-        BaseResponse<PageSimpleResponse<IoCollectOrder>> baseResponse = erpBasicClient.getPrescribeV2(getSickPrescribeRequest);
-        if (baseResponse.getCode() == 20000) {
-            List<IoCollectOrder> list = baseResponse.getData().getList();
-            collectOrderService.importPrescribe(list,collectOrderRequest.getBusType());
-            return ResultVOUtils.success("下载成功");
+        while (true){
+            getSickPrescribeRequest.setPage(page);
+            BaseResponse<PageSimpleResponse<IoCollectOrder>> baseResponse = erpBasicClient.getPrescribeV2(getSickPrescribeRequest);
+            if (baseResponse.getCode() == 20000) {
+                List<IoCollectOrder> list = baseResponse.getData().getList();
+                collectOrderService.importPrescribe(list,collectOrderRequest.getBusType());
+                if ((list.size() >= limit && !baseResponse.getData().getTotal().equals(-666)) || IntUtil.value(baseResponse.getData().getTotal()) == -555) {
+                    page++;
+                } else {
+                    break;
+                }
+            }else {
+                return ResultVOUtils.error(500, "下载第三方系统产品信息异常");
+            }
         }
-        return ResultVOUtils.error("下载失败");
+        return ResultVOUtils.success("下载成功");
     }
 }