需求

mall-server-api/src/main/java/com/gree/mall/manager/logic/SyncOrderInfoLogic.java

@@ -309,232 +309,234 @@ public class SyncOrderInfoLogic {
     @Transactional(rollbackFor = Exception.class)
     public void syncDetail() {
 
+        while (true) {
 
-        List<ItfGreeSynDownloadRec> itfGreeSynDownloadRecs = itfGreeSynDownloadRecService.lambdaQuery()
-                .in(ItfGreeSynDownloadRec::getGreeStatSynStatus, 0,99)
-                .last("limit 50")
-                .orderByAsc(ItfGreeSynDownloadRec::getGreeStatSynStatus)
-                .list();
-        if (CollectionUtils.isEmpty(itfGreeSynDownloadRecs))
-            return;
 
+            List<ItfGreeSynDownloadRec> itfGreeSynDownloadRecs = itfGreeSynDownloadRecService.lambdaQuery()
+                    .in(ItfGreeSynDownloadRec::getGreeStatSynStatus, 0, 99)
+                    .last("limit 20")
+                    .orderByAsc(ItfGreeSynDownloadRec::getGreeStatSynStatus)
+                    .list();
+            if (CollectionUtils.isEmpty(itfGreeSynDownloadRecs))
+                return;
 
-        try {
 
-            String batch = IdWorker.getIdStr();
+            try {
 
-            String accessToken = this.getAccessTokenV3();
+                String batch = IdWorker.getIdStr();
 
+                String accessToken = this.getAccessTokenV3();
 
-            Map<String, String> params = new HashMap<>();
 
-            Map<String, String> heard = new HashMap<>();
-            heard.put("authorization", "Bearer " + accessToken);
+                Map<String, String> params = new HashMap<>();
 
-            WorkOrderSearchReq workOrderSearchReq = new WorkOrderSearchReq();
+                Map<String, String> heard = new HashMap<>();
+                heard.put("authorization", "Bearer " + accessToken);
 
-            List<String> collect = itfGreeSynDownloadRecs.stream().map(ItfGreeSynDownloadRec::getWorkOrderId).collect(Collectors.toList());
-            List<Long> syncIds = itfGreeSynDownloadRecs.stream().map(ItfGreeSynDownloadRec::getSynReqId).collect(Collectors.toList());
+                WorkOrderSearchReq workOrderSearchReq = new WorkOrderSearchReq();
 
-            itfGreeSynDownloadRecService.lambdaUpdate()
-                    .in(ItfGreeSynDownloadRec::getSynReqId, syncIds)
-                    .set(ItfGreeSynDownloadRec::getGreeStatSynStatus, 1)
-                    .set(ItfGreeSynDownloadRec::getDownloadBatchNo, batch)
-                    .set(ItfGreeSynDownloadRec::getGreeStatSynTime, new Date())
-                    .update();
+                List<String> collect = itfGreeSynDownloadRecs.stream().map(ItfGreeSynDownloadRec::getWorkOrderId).collect(Collectors.toList());
+                List<Long> syncIds = itfGreeSynDownloadRecs.stream().map(ItfGreeSynDownloadRec::getSynReqId).collect(Collectors.toList());
 
-            workOrderSearchReq.setWorkOrderIds(collect);
+                itfGreeSynDownloadRecService.lambdaUpdate()
+                        .in(ItfGreeSynDownloadRec::getSynReqId, syncIds)
+                        .set(ItfGreeSynDownloadRec::getGreeStatSynStatus, 1)
+                        .set(ItfGreeSynDownloadRec::getDownloadBatchNo, batch)
+                        .set(ItfGreeSynDownloadRec::getGreeStatSynTime, new Date())
+                        .update();
 
-            String json = JSONUtil.toJsonStr(workOrderSearchReq);
+                workOrderSearchReq.setWorkOrderIds(collect);
 
+                String json = JSONUtil.toJsonStr(workOrderSearchReq);
 
 
-            String body = HttpUtils.requestPostBody(greeUrl + Constant.gree.POST_WORKER_ORDER_DETAIL, json, heard);
+                String body = HttpUtils.requestPostBody(greeUrl + Constant.gree.POST_WORKER_ORDER_DETAIL, json, heard);
 
-            Map<String, Object> bodyMap = JSON.parseObject(body);
-            String s = bodyMap.get("data").toString();
+                Map<String, Object> bodyMap = JSON.parseObject(body);
+                String s = bodyMap.get("data").toString();
 
 
-            log.info("工单同步详情返回："+s);
+                log.info("工单同步详情返回：" + s);
 
 
-            JSONArray jsonArray = JSONUtil.parseArray(s);
+                JSONArray jsonArray = JSONUtil.parseArray(s);
 
-            List<WorkOrderRelationBean> itfGreeSynDownloadRecBeans = JSONUtil.toList(jsonArray, WorkOrderRelationBean.class);
+                List<WorkOrderRelationBean> itfGreeSynDownloadRecBeans = JSONUtil.toList(jsonArray, WorkOrderRelationBean.class);
 
 
-            List<ItfTblWorkOrderFeedback> feedbackRespList = new ArrayList<>();
-            List<ItfTblCollectionCharge> collectionChargeList = new ArrayList<>();
-            List<ItfTblCollectionChargeDetail> collectionChargeDetails = new ArrayList<>();
-            List<ItfTblOldProductOrderDetail> tblOldProductOrderDetailList = new ArrayList<>();
-            List<ItfTblWorkOrderAddComplain> tblWorkOrderAddComplainList = new ArrayList<>();
-            List<ItfTblWorkOrderAppoint> tblWorkOrderAppointList = new ArrayList<>();
-            List<ItfTblWorkOrderCancel> tblWorkOrderCancelList = new ArrayList<>();
-            List<ItfTblWorkOrderComplainFeedback> tblWorkOrderComplainFeedbackList = new ArrayList<>();
-            List<ItfTblWorkOrderComplain> tblWorkOrderComplainList = new ArrayList<>();
-            List<ItfTblWorkOrderCompleteInfo> tblWorkOrderCompleteInfoList = new ArrayList<>();
-            List<ItfTblWorkOrderConsult> tblWorkOrderConsultList = new ArrayList<>();
-            List<ItfTblWorkOrderDetailBarcode> tblWorkOrderDetailBarcodeList = new ArrayList<>();
-            List<ItfTblWorkOrderDetailRelocation> tblWorkOrderDetailRelocationList = new ArrayList<>();
-            List<ItfTblWorkOrderDispatchOutlets> tblWorkOrderDispatchOutletsList = new ArrayList<>();
-            List<ItfTblWorkOrderEngineer> tblWorkOrderEngineerList = new ArrayList<>();
-            List<ItfTblWorkOrderEvaluation> tblWorkOrderEvaluationList = new ArrayList<>();
-            List<ItfTblWorkOrderExt> tblWorkOrderExtList = new ArrayList<>();
-            List<ItfTblWorkOrderIndicators> tblWorkOrderIndicatorsList = new ArrayList<>();
-            List<ItfTblWorkOrderSign> tblWorkOrderSignList = new ArrayList<>();
-            List<ItfTblWorkOrderTag> tblWorkOrderTagList = new ArrayList<>();
-            List<ItfTblWorkOrderCharge> workOrderChargeList = new ArrayList<>();
-            List<ItfTblWorkOrderCollectionComplain> workOrderCollectionComplainList = new ArrayList<>();
+                List<ItfTblWorkOrderFeedback> feedbackRespList = new ArrayList<>();
+                List<ItfTblCollectionCharge> collectionChargeList = new ArrayList<>();
+                List<ItfTblCollectionChargeDetail> collectionChargeDetails = new ArrayList<>();
+                List<ItfTblOldProductOrderDetail> tblOldProductOrderDetailList = new ArrayList<>();
+                List<ItfTblWorkOrderAddComplain> tblWorkOrderAddComplainList = new ArrayList<>();
+                List<ItfTblWorkOrderAppoint> tblWorkOrderAppointList = new ArrayList<>();
+                List<ItfTblWorkOrderCancel> tblWorkOrderCancelList = new ArrayList<>();
+                List<ItfTblWorkOrderComplainFeedback> tblWorkOrderComplainFeedbackList = new ArrayList<>();
+                List<ItfTblWorkOrderComplain> tblWorkOrderComplainList = new ArrayList<>();
+                List<ItfTblWorkOrderCompleteInfo> tblWorkOrderCompleteInfoList = new ArrayList<>();
+                List<ItfTblWorkOrderConsult> tblWorkOrderConsultList = new ArrayList<>();
+                List<ItfTblWorkOrderDetailBarcode> tblWorkOrderDetailBarcodeList = new ArrayList<>();
+                List<ItfTblWorkOrderDetailRelocation> tblWorkOrderDetailRelocationList = new ArrayList<>();
+                List<ItfTblWorkOrderDispatchOutlets> tblWorkOrderDispatchOutletsList = new ArrayList<>();
+                List<ItfTblWorkOrderEngineer> tblWorkOrderEngineerList = new ArrayList<>();
+                List<ItfTblWorkOrderEvaluation> tblWorkOrderEvaluationList = new ArrayList<>();
+                List<ItfTblWorkOrderExt> tblWorkOrderExtList = new ArrayList<>();
+                List<ItfTblWorkOrderIndicators> tblWorkOrderIndicatorsList = new ArrayList<>();
+                List<ItfTblWorkOrderSign> tblWorkOrderSignList = new ArrayList<>();
+                List<ItfTblWorkOrderTag> tblWorkOrderTagList = new ArrayList<>();
+                List<ItfTblWorkOrderCharge> workOrderChargeList = new ArrayList<>();
+                List<ItfTblWorkOrderCollectionComplain> workOrderCollectionComplainList = new ArrayList<>();
 
-            List<ItfTblWorkOrderDispatchEngineer> tblWorkOrderDispatchEngineerList = new ArrayList<>();
-            List<ItfTblWorkOrderStatus> tblWorkOrderStatusList = new ArrayList<>();
+                List<ItfTblWorkOrderDispatchEngineer> tblWorkOrderDispatchEngineerList = new ArrayList<>();
+                List<ItfTblWorkOrderStatus> tblWorkOrderStatusList = new ArrayList<>();
 
-            List<ItfTblWorkOrderCollection> workOrderCollectionList = new ArrayList<>();
-            List<ItfTblCollectionRepair> collectionRepairList = new ArrayList<>();
-            List<ItfTblCollectionRepairPart> collectionRepairPartList = new ArrayList<>();
-            List<ItfTblCollectionRepairProject> collectionRepairProjectList = new ArrayList<>();
-            List<ItfTblCollectionRepairSymptomReason> collectionRepairSymptomReasonList = new ArrayList<>();
-            List<ItfTblWorkOrderDetail> tblWorkOrderDetailList = new ArrayList<>();
+                List<ItfTblWorkOrderCollection> workOrderCollectionList = new ArrayList<>();
+                List<ItfTblCollectionRepair> collectionRepairList = new ArrayList<>();
+                List<ItfTblCollectionRepairPart> collectionRepairPartList = new ArrayList<>();
+                List<ItfTblCollectionRepairProject> collectionRepairProjectList = new ArrayList<>();
+                List<ItfTblCollectionRepairSymptomReason> collectionRepairSymptomReasonList = new ArrayList<>();
+                List<ItfTblWorkOrderDetail> tblWorkOrderDetailList = new ArrayList<>();
 
-            List<ItfTblWorkOrder> itfTblWorkOrders = new ArrayList<>();
+                List<ItfTblWorkOrder> itfTblWorkOrders = new ArrayList<>();
 
 
-            for (WorkOrderRelationBean itfGreeSynDownloadRecBean : itfGreeSynDownloadRecBeans) {
+                for (WorkOrderRelationBean itfGreeSynDownloadRecBean : itfGreeSynDownloadRecBeans) {
 
-                List<ItfGreeSynDownloadRec> itfGreeSynDownloadRecList = itfGreeSynDownloadRecs.stream()
-                        .filter(item -> item.getWorkOrderId().equals(itfGreeSynDownloadRecBean.getId())).collect(Collectors.toList());
+                    List<ItfGreeSynDownloadRec> itfGreeSynDownloadRecList = itfGreeSynDownloadRecs.stream()
+                            .filter(item -> item.getWorkOrderId().equals(itfGreeSynDownloadRecBean.getId())).collect(Collectors.toList());
 
-                itfGreeSynDownloadRecBean.setDownloadBatchNo(batch);
+                    itfGreeSynDownloadRecBean.setDownloadBatchNo(batch);
 
-                tblWorkOrderDetailList.addAll(itfGreeSynDownloadRecBean.getTblWorkOrderDetailList());
+                    tblWorkOrderDetailList.addAll(itfGreeSynDownloadRecBean.getTblWorkOrderDetailList());
 
 
-                feedbackRespList.addAll(itfGreeSynDownloadRecBean.getFeedbackRespList());
+                    feedbackRespList.addAll(itfGreeSynDownloadRecBean.getFeedbackRespList());
 
-                for (ItfTblCollectionChargeBean itfTblCollectionChargeBean : itfGreeSynDownloadRecBean.getCollectionChargeList()) {
-                    ItfTblCollectionCharge itfTblCollectionCharge = BeanUtil.toBean(itfTblCollectionChargeBean, ItfTblCollectionCharge.class);
-                    collectionChargeList.add(itfTblCollectionCharge);
-                    collectionChargeDetails.addAll(itfTblCollectionChargeBean.getCollectionChargeDetails());
-                }
+                    for (ItfTblCollectionChargeBean itfTblCollectionChargeBean : itfGreeSynDownloadRecBean.getCollectionChargeList()) {
+                        ItfTblCollectionCharge itfTblCollectionCharge = BeanUtil.toBean(itfTblCollectionChargeBean, ItfTblCollectionCharge.class);
+                        collectionChargeList.add(itfTblCollectionCharge);
+                        collectionChargeDetails.addAll(itfTblCollectionChargeBean.getCollectionChargeDetails());
+                    }
 
-                tblOldProductOrderDetailList.addAll(itfGreeSynDownloadRecBean.getTblOldProductOrderDetailList());
-
-                tblWorkOrderAddComplainList.addAll(itfGreeSynDownloadRecBean.getTblWorkOrderAddComplainList());
-
-                tblWorkOrderAppointList.addAll(itfGreeSynDownloadRecBean.getTblWorkOrderAppointList());
-                tblWorkOrderCancelList.addAll(itfGreeSynDownloadRecBean.getTblWorkOrderCancelList());
-                tblWorkOrderComplainFeedbackList.addAll(itfGreeSynDownloadRecBean.getTblWorkOrderComplainFeedbackList());
-                tblWorkOrderComplainList.addAll(itfGreeSynDownloadRecBean.getTblWorkOrderComplainList());
-                tblWorkOrderCompleteInfoList.addAll(itfGreeSynDownloadRecBean.getTblWorkOrderCompleteInfoList());
-                tblWorkOrderConsultList.addAll(itfGreeSynDownloadRecBean.getTblWorkOrderConsultList());
-                tblWorkOrderDetailBarcodeList.addAll(itfGreeSynDownloadRecBean.getTblWorkOrderDetailBarcodeList());
-                tblWorkOrderDetailRelocationList.addAll(itfGreeSynDownloadRecBean.getTblWorkOrderDetailRelocationList());
-                tblWorkOrderDispatchOutletsList.addAll(itfGreeSynDownloadRecBean.getTblWorkOrderDispatchOutletsList());
-                tblWorkOrderEngineerList.addAll(itfGreeSynDownloadRecBean.getTblWorkOrderEngineerList());
-                tblWorkOrderEvaluationList.addAll(itfGreeSynDownloadRecBean.getTblWorkOrderEvaluationList());
-                tblWorkOrderExtList.addAll(itfGreeSynDownloadRecBean.getTblWorkOrderExtList());
-                tblWorkOrderIndicatorsList.addAll(itfGreeSynDownloadRecBean.getTblWorkOrderIndicatorsList());
-                tblWorkOrderSignList.addAll(itfGreeSynDownloadRecBean.getTblWorkOrderSignList());
-                tblWorkOrderTagList.addAll(itfGreeSynDownloadRecBean.getTblWorkOrderTagList());
-                workOrderCollectionComplainList.addAll(itfGreeSynDownloadRecBean.getWorkOrderCollectionComplainList());
-                workOrderChargeList.addAll(itfGreeSynDownloadRecBean.getWorkOrderChargeList());
-
-
-                for (ItfTblWorkOrderCollection0Bean itfTblWorkOrderCollectionBean : itfGreeSynDownloadRecBean.getWorkOrderCollectionList()) {
-
-                    ItfTblWorkOrderCollection itfTblWorkOrderCollection = BeanUtil.toBean(itfTblWorkOrderCollectionBean, ItfTblWorkOrderCollection.class);
-                    workOrderCollectionList.add(itfTblWorkOrderCollectionBean);
-
-                    collectionRepairList.addAll(itfTblWorkOrderCollectionBean.getCollectionRepairList());
-                    collectionRepairPartList.addAll(itfTblWorkOrderCollectionBean.getCollectionRepairPartList());
-                    collectionRepairProjectList.addAll(itfTblWorkOrderCollectionBean.getCollectionRepairProjectList());
-                    collectionRepairSymptomReasonList.addAll(itfTblWorkOrderCollectionBean.getCollectionRepairSymptomReasonList());
-                }
-                tblWorkOrderDispatchEngineerList.addAll(itfGreeSynDownloadRecBean.getTblWorkOrderDispatchEngineerList());
-                tblWorkOrderStatusList.addAll(itfGreeSynDownloadRecBean.getTblWorkOrderStatusList());
+                    tblOldProductOrderDetailList.addAll(itfGreeSynDownloadRecBean.getTblOldProductOrderDetailList());
 
-                ItfTblWorkOrder itfTblWorkOrder = BeanUtil.toBean(itfGreeSynDownloadRecBean, ItfTblWorkOrder.class);
-                itfTblWorkOrders.add(itfTblWorkOrder);
+                    tblWorkOrderAddComplainList.addAll(itfGreeSynDownloadRecBean.getTblWorkOrderAddComplainList());
 
-            }
+                    tblWorkOrderAppointList.addAll(itfGreeSynDownloadRecBean.getTblWorkOrderAppointList());
+                    tblWorkOrderCancelList.addAll(itfGreeSynDownloadRecBean.getTblWorkOrderCancelList());
+                    tblWorkOrderComplainFeedbackList.addAll(itfGreeSynDownloadRecBean.getTblWorkOrderComplainFeedbackList());
+                    tblWorkOrderComplainList.addAll(itfGreeSynDownloadRecBean.getTblWorkOrderComplainList());
+                    tblWorkOrderCompleteInfoList.addAll(itfGreeSynDownloadRecBean.getTblWorkOrderCompleteInfoList());
+                    tblWorkOrderConsultList.addAll(itfGreeSynDownloadRecBean.getTblWorkOrderConsultList());
+                    tblWorkOrderDetailBarcodeList.addAll(itfGreeSynDownloadRecBean.getTblWorkOrderDetailBarcodeList());
+                    tblWorkOrderDetailRelocationList.addAll(itfGreeSynDownloadRecBean.getTblWorkOrderDetailRelocationList());
+                    tblWorkOrderDispatchOutletsList.addAll(itfGreeSynDownloadRecBean.getTblWorkOrderDispatchOutletsList());
+                    tblWorkOrderEngineerList.addAll(itfGreeSynDownloadRecBean.getTblWorkOrderEngineerList());
+                    tblWorkOrderEvaluationList.addAll(itfGreeSynDownloadRecBean.getTblWorkOrderEvaluationList());
+                    tblWorkOrderExtList.addAll(itfGreeSynDownloadRecBean.getTblWorkOrderExtList());
+                    tblWorkOrderIndicatorsList.addAll(itfGreeSynDownloadRecBean.getTblWorkOrderIndicatorsList());
+                    tblWorkOrderSignList.addAll(itfGreeSynDownloadRecBean.getTblWorkOrderSignList());
+                    tblWorkOrderTagList.addAll(itfGreeSynDownloadRecBean.getTblWorkOrderTagList());
+                    workOrderCollectionComplainList.addAll(itfGreeSynDownloadRecBean.getWorkOrderCollectionComplainList());
+                    workOrderChargeList.addAll(itfGreeSynDownloadRecBean.getWorkOrderChargeList());
+
+
+                    for (ItfTblWorkOrderCollection0Bean itfTblWorkOrderCollectionBean : itfGreeSynDownloadRecBean.getWorkOrderCollectionList()) {
+
+                        ItfTblWorkOrderCollection itfTblWorkOrderCollection = BeanUtil.toBean(itfTblWorkOrderCollectionBean, ItfTblWorkOrderCollection.class);
+                        workOrderCollectionList.add(itfTblWorkOrderCollectionBean);
 
-            feedbackRespList.stream().forEach(item -> item.setDownloadBatchNo(batch));
-            itfTblWorkOrderFeedbackService.saveBatch(feedbackRespList);
-
-            tblWorkOrderDetailList.stream().forEach(item -> item.setDownloadBatchNo(batch));
-            itfTblWorkOrderDetailService.saveBatch(tblWorkOrderDetailList);
-
-            collectionChargeList.stream().forEach(item -> item.setDownloadBatchNo(batch));
-            itfTblCollectionChargeService.saveBatch(collectionChargeList);
-            collectionChargeDetails.stream().forEach(item -> item.setDownloadBatchNo(batch));
-            itfTblCollectionChargeDetailService.saveBatch(collectionChargeDetails);
-            tblOldProductOrderDetailList.stream().forEach(item -> item.setDownloadBatchNo(batch));
-            itfTblOldProductOrderDetailService.saveBatch(tblOldProductOrderDetailList);
-            tblWorkOrderAddComplainList.stream().forEach(item -> item.setDownloadBatchNo(batch));
-            itfTblWorkOrderAddComplainService.saveBatch(tblWorkOrderAddComplainList);
-            tblWorkOrderAppointList.stream().forEach(item -> item.setDownloadBatchNo(batch));
-            itfTblWorkOrderAppointService.saveBatch(tblWorkOrderAppointList);
-            tblWorkOrderCancelList.stream().forEach(item -> item.setDownloadBatchNo(batch));
-            itfTblWorkOrderCancelService.saveBatch(tblWorkOrderCancelList);
-            tblWorkOrderComplainList.stream().forEach(item -> item.setDownloadBatchNo(batch));
-            itfTblWorkOrderComplainService.saveBatch(tblWorkOrderComplainList);
-            tblWorkOrderComplainFeedbackList.stream().forEach(item -> item.setDownloadBatchNo(batch));
-            itfTblWorkOrderComplainFeedbackService.saveBatch(tblWorkOrderComplainFeedbackList);
-            tblWorkOrderCompleteInfoList.stream().forEach(item -> item.setDownloadBatchNo(batch));
-            itfTblWorkOrderCompleteInfoService.saveBatch(tblWorkOrderCompleteInfoList);
-            tblWorkOrderConsultList.stream().forEach(item -> item.setDownloadBatchNo(batch));
-            itfTblWorkOrderConsultService.saveBatch(tblWorkOrderConsultList);
-            tblWorkOrderDetailBarcodeList.stream().forEach(item -> item.setDownloadBatchNo(batch));
-            itfTblWorkOrderDetailBarcodeService.saveBatch(tblWorkOrderDetailBarcodeList);
-            tblWorkOrderDetailRelocationList.stream().forEach(item -> item.setDownloadBatchNo(batch));
-            itfTblWorkOrderDetailRelocationService.saveBatch(tblWorkOrderDetailRelocationList);
-            tblWorkOrderDispatchOutletsList.stream().forEach(item -> item.setDownloadBatchNo(batch));
-            itfTblWorkOrderDispatchOutletsService.saveBatch(tblWorkOrderDispatchOutletsList);
-            tblWorkOrderEngineerList.stream().forEach(item -> item.setDownloadBatchNo(batch));
-            itfTblWorkOrderEngineerService.saveBatch(tblWorkOrderEngineerList);
-            tblWorkOrderEvaluationList.stream().forEach(item -> item.setDownloadBatchNo(batch));
-            itfTblWorkOrderEvaluationService.saveBatch(tblWorkOrderEvaluationList);
-            tblWorkOrderExtList.stream().forEach(item -> item.setDownloadBatchNo(batch));
-            itfTblWorkOrderExtService.saveBatch(tblWorkOrderExtList);
-            tblWorkOrderIndicatorsList.stream().forEach(item -> item.setDownloadBatchNo(batch));
-            itfTblWorkOrderIndicatorsService.saveBatch(tblWorkOrderIndicatorsList);
-            tblWorkOrderSignList.stream().forEach(item -> item.setDownloadBatchNo(batch));
-            itfTblWorkOrderSignService.saveBatch(tblWorkOrderSignList);
-            tblWorkOrderTagList.stream().forEach(item -> item.setDownloadBatchNo(batch));
-            itfTblWorkOrderTagService.saveBatch(tblWorkOrderTagList);
-            workOrderChargeList.stream().forEach(item -> item.setDownloadBatchNo(batch));
-            itfTblWorkOrderChargeService.saveBatch(workOrderChargeList);
-            workOrderCollectionComplainList.stream().forEach(item -> item.setDownloadBatchNo(batch));
-            itfTblWorkOrderCollectionComplainService.saveBatch(workOrderCollectionComplainList);
-            tblWorkOrderDispatchEngineerList.stream().forEach(item -> item.setDownloadBatchNo(batch));
-            itfTblWorkOrderDispatchEngineerService.saveBatch(tblWorkOrderDispatchEngineerList);
-            tblWorkOrderStatusList.stream().forEach(item -> item.setDownloadBatchNo(batch));
-            itfTblWorkOrderStatusService.saveBatch(tblWorkOrderStatusList);
-            workOrderCollectionList.stream().forEach(item -> item.setDownloadBatchNo(batch));
-            itfTblWorkOrderCollectionService.saveBatch(workOrderCollectionList);
-            collectionRepairList.stream().forEach(item -> item.setDownloadBatchNo(batch));
-            itfTblCollectionRepairService.saveBatch(collectionRepairList);
-            collectionRepairPartList.stream().forEach(item -> item.setDownloadBatchNo(batch));
-            itfTblCollectionRepairPartService.saveBatch(collectionRepairPartList);
-            collectionRepairProjectList.stream().forEach(item -> item.setDownloadBatchNo(batch));
-            itfTblCollectionRepairProjectService.saveBatch(collectionRepairProjectList);
-            collectionRepairSymptomReasonList.stream().forEach(item -> item.setDownloadBatchNo(batch));
-            itfTblCollectionRepairSymptomReasonService.saveBatch(collectionRepairSymptomReasonList);
-
-
-            itfTblWorkOrderService.saveBatch(itfTblWorkOrders);
-
-
-        } catch (Exception e) {
-            List<Long> syncIds = itfGreeSynDownloadRecs.stream().map(ItfGreeSynDownloadRec::getSynReqId).collect(Collectors.toList());
-
-            itfGreeSynDownloadRecService.lambdaUpdate()
-                    .in(ItfGreeSynDownloadRec::getSynReqId, syncIds)
-                    .set(ItfGreeSynDownloadRec::getGreeStatSynErrMsg, e.getMessage())
-                    .set(ItfGreeSynDownloadRec::getGreeStatSynTime, new Date())
-                    .set(ItfGreeSynDownloadRec::getGreeStatSynStatus, 99).update();
+                        collectionRepairList.addAll(itfTblWorkOrderCollectionBean.getCollectionRepairList());
+                        collectionRepairPartList.addAll(itfTblWorkOrderCollectionBean.getCollectionRepairPartList());
+                        collectionRepairProjectList.addAll(itfTblWorkOrderCollectionBean.getCollectionRepairProjectList());
+                        collectionRepairSymptomReasonList.addAll(itfTblWorkOrderCollectionBean.getCollectionRepairSymptomReasonList());
+                    }
+                    tblWorkOrderDispatchEngineerList.addAll(itfGreeSynDownloadRecBean.getTblWorkOrderDispatchEngineerList());
+                    tblWorkOrderStatusList.addAll(itfGreeSynDownloadRecBean.getTblWorkOrderStatusList());
 
+                    ItfTblWorkOrder itfTblWorkOrder = BeanUtil.toBean(itfGreeSynDownloadRecBean, ItfTblWorkOrder.class);
+                    itfTblWorkOrders.add(itfTblWorkOrder);
 
+                }
+
+                feedbackRespList.stream().forEach(item -> item.setDownloadBatchNo(batch));
+                itfTblWorkOrderFeedbackService.saveBatch(feedbackRespList);
+
+                tblWorkOrderDetailList.stream().forEach(item -> item.setDownloadBatchNo(batch));
+                itfTblWorkOrderDetailService.saveBatch(tblWorkOrderDetailList);
+
+                collectionChargeList.stream().forEach(item -> item.setDownloadBatchNo(batch));
+                itfTblCollectionChargeService.saveBatch(collectionChargeList);
+                collectionChargeDetails.stream().forEach(item -> item.setDownloadBatchNo(batch));
+                itfTblCollectionChargeDetailService.saveBatch(collectionChargeDetails);
+                tblOldProductOrderDetailList.stream().forEach(item -> item.setDownloadBatchNo(batch));
+                itfTblOldProductOrderDetailService.saveBatch(tblOldProductOrderDetailList);
+                tblWorkOrderAddComplainList.stream().forEach(item -> item.setDownloadBatchNo(batch));
+                itfTblWorkOrderAddComplainService.saveBatch(tblWorkOrderAddComplainList);
+                tblWorkOrderAppointList.stream().forEach(item -> item.setDownloadBatchNo(batch));
+                itfTblWorkOrderAppointService.saveBatch(tblWorkOrderAppointList);
+                tblWorkOrderCancelList.stream().forEach(item -> item.setDownloadBatchNo(batch));
+                itfTblWorkOrderCancelService.saveBatch(tblWorkOrderCancelList);
+                tblWorkOrderComplainList.stream().forEach(item -> item.setDownloadBatchNo(batch));
+                itfTblWorkOrderComplainService.saveBatch(tblWorkOrderComplainList);
+                tblWorkOrderComplainFeedbackList.stream().forEach(item -> item.setDownloadBatchNo(batch));
+                itfTblWorkOrderComplainFeedbackService.saveBatch(tblWorkOrderComplainFeedbackList);
+                tblWorkOrderCompleteInfoList.stream().forEach(item -> item.setDownloadBatchNo(batch));
+                itfTblWorkOrderCompleteInfoService.saveBatch(tblWorkOrderCompleteInfoList);
+                tblWorkOrderConsultList.stream().forEach(item -> item.setDownloadBatchNo(batch));
+                itfTblWorkOrderConsultService.saveBatch(tblWorkOrderConsultList);
+                tblWorkOrderDetailBarcodeList.stream().forEach(item -> item.setDownloadBatchNo(batch));
+                itfTblWorkOrderDetailBarcodeService.saveBatch(tblWorkOrderDetailBarcodeList);
+                tblWorkOrderDetailRelocationList.stream().forEach(item -> item.setDownloadBatchNo(batch));
+                itfTblWorkOrderDetailRelocationService.saveBatch(tblWorkOrderDetailRelocationList);
+                tblWorkOrderDispatchOutletsList.stream().forEach(item -> item.setDownloadBatchNo(batch));
+                itfTblWorkOrderDispatchOutletsService.saveBatch(tblWorkOrderDispatchOutletsList);
+                tblWorkOrderEngineerList.stream().forEach(item -> item.setDownloadBatchNo(batch));
+                itfTblWorkOrderEngineerService.saveBatch(tblWorkOrderEngineerList);
+                tblWorkOrderEvaluationList.stream().forEach(item -> item.setDownloadBatchNo(batch));
+                itfTblWorkOrderEvaluationService.saveBatch(tblWorkOrderEvaluationList);
+                tblWorkOrderExtList.stream().forEach(item -> item.setDownloadBatchNo(batch));
+                itfTblWorkOrderExtService.saveBatch(tblWorkOrderExtList);
+                tblWorkOrderIndicatorsList.stream().forEach(item -> item.setDownloadBatchNo(batch));
+                itfTblWorkOrderIndicatorsService.saveBatch(tblWorkOrderIndicatorsList);
+                tblWorkOrderSignList.stream().forEach(item -> item.setDownloadBatchNo(batch));
+                itfTblWorkOrderSignService.saveBatch(tblWorkOrderSignList);
+                tblWorkOrderTagList.stream().forEach(item -> item.setDownloadBatchNo(batch));
+                itfTblWorkOrderTagService.saveBatch(tblWorkOrderTagList);
+                workOrderChargeList.stream().forEach(item -> item.setDownloadBatchNo(batch));
+                itfTblWorkOrderChargeService.saveBatch(workOrderChargeList);
+                workOrderCollectionComplainList.stream().forEach(item -> item.setDownloadBatchNo(batch));
+                itfTblWorkOrderCollectionComplainService.saveBatch(workOrderCollectionComplainList);
+                tblWorkOrderDispatchEngineerList.stream().forEach(item -> item.setDownloadBatchNo(batch));
+                itfTblWorkOrderDispatchEngineerService.saveBatch(tblWorkOrderDispatchEngineerList);
+                tblWorkOrderStatusList.stream().forEach(item -> item.setDownloadBatchNo(batch));
+                itfTblWorkOrderStatusService.saveBatch(tblWorkOrderStatusList);
+                workOrderCollectionList.stream().forEach(item -> item.setDownloadBatchNo(batch));
+                itfTblWorkOrderCollectionService.saveBatch(workOrderCollectionList);
+                collectionRepairList.stream().forEach(item -> item.setDownloadBatchNo(batch));
+                itfTblCollectionRepairService.saveBatch(collectionRepairList);
+                collectionRepairPartList.stream().forEach(item -> item.setDownloadBatchNo(batch));
+                itfTblCollectionRepairPartService.saveBatch(collectionRepairPartList);
+                collectionRepairProjectList.stream().forEach(item -> item.setDownloadBatchNo(batch));
+                itfTblCollectionRepairProjectService.saveBatch(collectionRepairProjectList);
+                collectionRepairSymptomReasonList.stream().forEach(item -> item.setDownloadBatchNo(batch));
+                itfTblCollectionRepairSymptomReasonService.saveBatch(collectionRepairSymptomReasonList);
+
+
+                itfTblWorkOrderService.saveBatch(itfTblWorkOrders);
+
+
+            } catch (Exception e) {
+                List<Long> syncIds = itfGreeSynDownloadRecs.stream().map(ItfGreeSynDownloadRec::getSynReqId).collect(Collectors.toList());
+
+                itfGreeSynDownloadRecService.lambdaUpdate()
+                        .in(ItfGreeSynDownloadRec::getSynReqId, syncIds)
+                        .set(ItfGreeSynDownloadRec::getGreeStatSynErrMsg, e.getMessage())
+                        .set(ItfGreeSynDownloadRec::getGreeStatSynTime, new Date())
+                        .set(ItfGreeSynDownloadRec::getGreeStatSynStatus, 99).update();
+
+
+            }
         }
 
     }

mall-server-sync-api/src/main/java/com/gree/mall/manager/logic/SyncOrderInfoLogic.java

@@ -307,296 +307,299 @@ public class SyncOrderInfoLogic {
 
     public synchronized void syncDetail() {
 
+        while (true) {
 
-        List<ItfGreeSynDownloadRec> itfGreeSynDownloadRecs = itfGreeSynDownloadRecService.lambdaQuery()
-                .in(ItfGreeSynDownloadRec::getGreeStatSynStatus, 0, 99)
-                .last("limit 10")
-                .orderByAsc(ItfGreeSynDownloadRec::getGreeStatSynStatus)
-                .list();
-        if (CollectionUtils.isEmpty(itfGreeSynDownloadRecs))
-            return;
 
+            List<ItfGreeSynDownloadRec> itfGreeSynDownloadRecs = itfGreeSynDownloadRecService.lambdaQuery()
+                    .in(ItfGreeSynDownloadRec::getGreeStatSynStatus, 0, 99)
+                    .last("limit 20")
+                    .orderByAsc(ItfGreeSynDownloadRec::getGreeStatSynStatus)
+                    .list();
+            if (CollectionUtils.isEmpty(itfGreeSynDownloadRecs))
+                return;
 
-        try {
 
-            String batch = IdWorker.getIdStr();
+            try {
 
-            String accessToken = this.getAccessTokenV3();
+                String batch = IdWorker.getIdStr();
 
+                String accessToken = this.getAccessTokenV3();
 
-            Map<String, String> params = new HashMap<>();
 
-            Map<String, String> heard = new HashMap<>();
-            heard.put("authorization", "Bearer " + accessToken);
+                Map<String, String> params = new HashMap<>();
 
-            WorkOrderSearchReq workOrderSearchReq = new WorkOrderSearchReq();
+                Map<String, String> heard = new HashMap<>();
+                heard.put("authorization", "Bearer " + accessToken);
 
-            List<String> collect = itfGreeSynDownloadRecs.stream().map(ItfGreeSynDownloadRec::getWorkOrderId).collect(Collectors.toList());
-            List<Long> syncIds = itfGreeSynDownloadRecs.stream().map(ItfGreeSynDownloadRec::getSynReqId).collect(Collectors.toList());
+                WorkOrderSearchReq workOrderSearchReq = new WorkOrderSearchReq();
 
-            itfGreeSynDownloadRecService.lambdaUpdate()
-                    .in(ItfGreeSynDownloadRec::getSynReqId, syncIds)
-                    .set(ItfGreeSynDownloadRec::getGreeStatSynStatus, 1)
-                    .set(ItfGreeSynDownloadRec::getDownloadBatchNo, batch)
-                    .set(ItfGreeSynDownloadRec::getGreeStatSynTime, new Date())
-                    .update();
+                List<String> collect = itfGreeSynDownloadRecs.stream().map(ItfGreeSynDownloadRec::getWorkOrderId).collect(Collectors.toList());
+                List<Long> syncIds = itfGreeSynDownloadRecs.stream().map(ItfGreeSynDownloadRec::getSynReqId).collect(Collectors.toList());
 
-            workOrderSearchReq.setWorkOrderIds(collect);
+                itfGreeSynDownloadRecService.lambdaUpdate()
+                        .in(ItfGreeSynDownloadRec::getSynReqId, syncIds)
+                        .set(ItfGreeSynDownloadRec::getGreeStatSynStatus, 1)
+                        .set(ItfGreeSynDownloadRec::getDownloadBatchNo, batch)
+                        .set(ItfGreeSynDownloadRec::getGreeStatSynTime, new Date())
+                        .update();
 
-            String json = JSONUtil.toJsonStr(workOrderSearchReq);
+                workOrderSearchReq.setWorkOrderIds(collect);
 
+                String json = JSONUtil.toJsonStr(workOrderSearchReq);
 
-            String body = HttpUtils.requestPostBody(greeUrl + Constant.gree.POST_WORKER_ORDER_DETAIL, json, heard);
 
-            Map<String, Object> bodyMap = JSON.parseObject(body);
-            String s = bodyMap.get("data").toString();
+                String body = HttpUtils.requestPostBody(greeUrl + Constant.gree.POST_WORKER_ORDER_DETAIL, json, heard);
 
+                Map<String, Object> bodyMap = JSON.parseObject(body);
+                String s = bodyMap.get("data").toString();
 
-            log.info("工单同步详情返回：" + s);
 
+                log.info("工单同步详情返回：" + s);
 
-            JSONArray jsonArray = JSONUtil.parseArray(s);
 
-            List<WorkOrderRelationBean> itfGreeSynDownloadRecBeans = JSONUtil.toList(jsonArray, WorkOrderRelationBean.class);
+                JSONArray jsonArray = JSONUtil.parseArray(s);
 
+                List<WorkOrderRelationBean> itfGreeSynDownloadRecBeans = JSONUtil.toList(jsonArray, WorkOrderRelationBean.class);
 
-            List<ItfTblWorkOrderFeedback> feedbackRespList = new ArrayList<>();
-            List<ItfTblCollectionCharge> collectionChargeList = new ArrayList<>();
-            List<ItfTblCollectionChargeDetail> collectionChargeDetails = new ArrayList<>();
-            List<ItfTblOldProductOrderDetail> tblOldProductOrderDetailList = new ArrayList<>();
-            List<ItfTblWorkOrderAddComplain> tblWorkOrderAddComplainList = new ArrayList<>();
-            List<ItfTblWorkOrderAppoint> tblWorkOrderAppointList = new ArrayList<>();
-            List<ItfTblWorkOrderCancel> tblWorkOrderCancelList = new ArrayList<>();
-            List<ItfTblWorkOrderComplainFeedback> tblWorkOrderComplainFeedbackList = new ArrayList<>();
-            List<ItfTblWorkOrderComplain> tblWorkOrderComplainList = new ArrayList<>();
-            List<ItfTblWorkOrderCompleteInfo> tblWorkOrderCompleteInfoList = new ArrayList<>();
-            List<ItfTblWorkOrderConsult> tblWorkOrderConsultList = new ArrayList<>();
-            List<ItfTblWorkOrderDetailBarcode> tblWorkOrderDetailBarcodeList = new ArrayList<>();
-            List<ItfTblWorkOrderDetailRelocation> tblWorkOrderDetailRelocationList = new ArrayList<>();
-            List<ItfTblWorkOrderDispatchOutlets> tblWorkOrderDispatchOutletsList = new ArrayList<>();
-            List<ItfTblWorkOrderEngineer> tblWorkOrderEngineerList = new ArrayList<>();
-            List<ItfTblWorkOrderEvaluation> tblWorkOrderEvaluationList = new ArrayList<>();
-            List<ItfTblWorkOrderExt> tblWorkOrderExtList = new ArrayList<>();
-            List<ItfTblWorkOrderIndicators> tblWorkOrderIndicatorsList = new ArrayList<>();
-            List<ItfTblWorkOrderSign> tblWorkOrderSignList = new ArrayList<>();
-            List<ItfTblWorkOrderTag> tblWorkOrderTagList = new ArrayList<>();
-            List<ItfTblWorkOrderCharge> workOrderChargeList = new ArrayList<>();
-            List<ItfTblWorkOrderCollectionComplain> workOrderCollectionComplainList = new ArrayList<>();
 
-            List<ItfTblWorkOrderDispatchEngineer> tblWorkOrderDispatchEngineerList = new ArrayList<>();
-            List<ItfTblWorkOrderStatus> tblWorkOrderStatusList = new ArrayList<>();
+                List<ItfTblWorkOrderFeedback> feedbackRespList = new ArrayList<>();
+                List<ItfTblCollectionCharge> collectionChargeList = new ArrayList<>();
+                List<ItfTblCollectionChargeDetail> collectionChargeDetails = new ArrayList<>();
+                List<ItfTblOldProductOrderDetail> tblOldProductOrderDetailList = new ArrayList<>();
+                List<ItfTblWorkOrderAddComplain> tblWorkOrderAddComplainList = new ArrayList<>();
+                List<ItfTblWorkOrderAppoint> tblWorkOrderAppointList = new ArrayList<>();
+                List<ItfTblWorkOrderCancel> tblWorkOrderCancelList = new ArrayList<>();
+                List<ItfTblWorkOrderComplainFeedback> tblWorkOrderComplainFeedbackList = new ArrayList<>();
+                List<ItfTblWorkOrderComplain> tblWorkOrderComplainList = new ArrayList<>();
+                List<ItfTblWorkOrderCompleteInfo> tblWorkOrderCompleteInfoList = new ArrayList<>();
+                List<ItfTblWorkOrderConsult> tblWorkOrderConsultList = new ArrayList<>();
+                List<ItfTblWorkOrderDetailBarcode> tblWorkOrderDetailBarcodeList = new ArrayList<>();
+                List<ItfTblWorkOrderDetailRelocation> tblWorkOrderDetailRelocationList = new ArrayList<>();
+                List<ItfTblWorkOrderDispatchOutlets> tblWorkOrderDispatchOutletsList = new ArrayList<>();
+                List<ItfTblWorkOrderEngineer> tblWorkOrderEngineerList = new ArrayList<>();
+                List<ItfTblWorkOrderEvaluation> tblWorkOrderEvaluationList = new ArrayList<>();
+                List<ItfTblWorkOrderExt> tblWorkOrderExtList = new ArrayList<>();
+                List<ItfTblWorkOrderIndicators> tblWorkOrderIndicatorsList = new ArrayList<>();
+                List<ItfTblWorkOrderSign> tblWorkOrderSignList = new ArrayList<>();
+                List<ItfTblWorkOrderTag> tblWorkOrderTagList = new ArrayList<>();
+                List<ItfTblWorkOrderCharge> workOrderChargeList = new ArrayList<>();
+                List<ItfTblWorkOrderCollectionComplain> workOrderCollectionComplainList = new ArrayList<>();
 
-            List<ItfTblWorkOrderCollection> workOrderCollectionList = new ArrayList<>();
-            List<ItfTblCollectionRepair> collectionRepairList = new ArrayList<>();
-            List<ItfTblCollectionRepairPart> collectionRepairPartList = new ArrayList<>();
-            List<ItfTblCollectionRepairProject> collectionRepairProjectList = new ArrayList<>();
-            List<ItfTblCollectionRepairSymptomReason> collectionRepairSymptomReasonList = new ArrayList<>();
-            List<ItfTblWorkOrderDetail> tblWorkOrderDetailList = new ArrayList<>();
+                List<ItfTblWorkOrderDispatchEngineer> tblWorkOrderDispatchEngineerList = new ArrayList<>();
+                List<ItfTblWorkOrderStatus> tblWorkOrderStatusList = new ArrayList<>();
 
-            List<ItfTblWorkOrder> itfTblWorkOrders = new ArrayList<>();
+                List<ItfTblWorkOrderCollection> workOrderCollectionList = new ArrayList<>();
+                List<ItfTblCollectionRepair> collectionRepairList = new ArrayList<>();
+                List<ItfTblCollectionRepairPart> collectionRepairPartList = new ArrayList<>();
+                List<ItfTblCollectionRepairProject> collectionRepairProjectList = new ArrayList<>();
+                List<ItfTblCollectionRepairSymptomReason> collectionRepairSymptomReasonList = new ArrayList<>();
+                List<ItfTblWorkOrderDetail> tblWorkOrderDetailList = new ArrayList<>();
 
+                List<ItfTblWorkOrder> itfTblWorkOrders = new ArrayList<>();
 
-            for (WorkOrderRelationBean itfGreeSynDownloadRecBean : itfGreeSynDownloadRecBeans) {
 
-                List<ItfGreeSynDownloadRec> itfGreeSynDownloadRecList = itfGreeSynDownloadRecs.stream()
-                        .filter(item -> item.getWorkOrderId().equals(itfGreeSynDownloadRecBean.getId())).collect(Collectors.toList());
+                for (WorkOrderRelationBean itfGreeSynDownloadRecBean : itfGreeSynDownloadRecBeans) {
 
-                itfGreeSynDownloadRecBean.setDownloadBatchNo(batch);
+                    List<ItfGreeSynDownloadRec> itfGreeSynDownloadRecList = itfGreeSynDownloadRecs.stream()
+                            .filter(item -> item.getWorkOrderId().equals(itfGreeSynDownloadRecBean.getId())).collect(Collectors.toList());
 
-                tblWorkOrderDetailList.addAll(itfGreeSynDownloadRecBean.getTblWorkOrderDetailList());
+                    itfGreeSynDownloadRecBean.setDownloadBatchNo(batch);
 
+                    tblWorkOrderDetailList.addAll(itfGreeSynDownloadRecBean.getTblWorkOrderDetailList());
 
-                feedbackRespList.addAll(itfGreeSynDownloadRecBean.getFeedbackRespList());
 
-                for (ItfTblCollectionChargeBean itfTblCollectionChargeBean : itfGreeSynDownloadRecBean.getCollectionChargeList()) {
-                    ItfTblCollectionCharge itfTblCollectionCharge = BeanUtil.toBean(itfTblCollectionChargeBean, ItfTblCollectionCharge.class);
-                    collectionChargeList.add(itfTblCollectionCharge);
-                    collectionChargeDetails.addAll(itfTblCollectionChargeBean.getCollectionChargeDetails());
-                }
+                    feedbackRespList.addAll(itfGreeSynDownloadRecBean.getFeedbackRespList());
 
-                tblOldProductOrderDetailList.addAll(itfGreeSynDownloadRecBean.getTblOldProductOrderDetailList());
+                    for (ItfTblCollectionChargeBean itfTblCollectionChargeBean : itfGreeSynDownloadRecBean.getCollectionChargeList()) {
+                        ItfTblCollectionCharge itfTblCollectionCharge = BeanUtil.toBean(itfTblCollectionChargeBean, ItfTblCollectionCharge.class);
+                        collectionChargeList.add(itfTblCollectionCharge);
+                        collectionChargeDetails.addAll(itfTblCollectionChargeBean.getCollectionChargeDetails());
+                    }
 
-                tblWorkOrderAddComplainList.addAll(itfGreeSynDownloadRecBean.getTblWorkOrderAddComplainList());
+                    tblOldProductOrderDetailList.addAll(itfGreeSynDownloadRecBean.getTblOldProductOrderDetailList());
 
-                tblWorkOrderAppointList.addAll(itfGreeSynDownloadRecBean.getTblWorkOrderAppointList());
-                tblWorkOrderCancelList.addAll(itfGreeSynDownloadRecBean.getTblWorkOrderCancelList());
-                tblWorkOrderComplainFeedbackList.addAll(itfGreeSynDownloadRecBean.getTblWorkOrderComplainFeedbackList());
-                tblWorkOrderComplainList.addAll(itfGreeSynDownloadRecBean.getTblWorkOrderComplainList());
-                tblWorkOrderCompleteInfoList.addAll(itfGreeSynDownloadRecBean.getTblWorkOrderCompleteInfoList());
-                tblWorkOrderConsultList.addAll(itfGreeSynDownloadRecBean.getTblWorkOrderConsultList());
-                tblWorkOrderDetailBarcodeList.addAll(itfGreeSynDownloadRecBean.getTblWorkOrderDetailBarcodeList());
-                tblWorkOrderDetailRelocationList.addAll(itfGreeSynDownloadRecBean.getTblWorkOrderDetailRelocationList());
-                tblWorkOrderDispatchOutletsList.addAll(itfGreeSynDownloadRecBean.getTblWorkOrderDispatchOutletsList());
-                tblWorkOrderEngineerList.addAll(itfGreeSynDownloadRecBean.getTblWorkOrderEngineerList());
-                tblWorkOrderEvaluationList.addAll(itfGreeSynDownloadRecBean.getTblWorkOrderEvaluationList());
-                tblWorkOrderExtList.addAll(itfGreeSynDownloadRecBean.getTblWorkOrderExtList());
-                tblWorkOrderIndicatorsList.addAll(itfGreeSynDownloadRecBean.getTblWorkOrderIndicatorsList());
-                tblWorkOrderSignList.addAll(itfGreeSynDownloadRecBean.getTblWorkOrderSignList());
-                tblWorkOrderTagList.addAll(itfGreeSynDownloadRecBean.getTblWorkOrderTagList());
-                workOrderCollectionComplainList.addAll(itfGreeSynDownloadRecBean.getWorkOrderCollectionComplainList());
-                workOrderChargeList.addAll(itfGreeSynDownloadRecBean.getWorkOrderChargeList());
+                    tblWorkOrderAddComplainList.addAll(itfGreeSynDownloadRecBean.getTblWorkOrderAddComplainList());
 
+                    tblWorkOrderAppointList.addAll(itfGreeSynDownloadRecBean.getTblWorkOrderAppointList());
+                    tblWorkOrderCancelList.addAll(itfGreeSynDownloadRecBean.getTblWorkOrderCancelList());
+                    tblWorkOrderComplainFeedbackList.addAll(itfGreeSynDownloadRecBean.getTblWorkOrderComplainFeedbackList());
+                    tblWorkOrderComplainList.addAll(itfGreeSynDownloadRecBean.getTblWorkOrderComplainList());
+                    tblWorkOrderCompleteInfoList.addAll(itfGreeSynDownloadRecBean.getTblWorkOrderCompleteInfoList());
+                    tblWorkOrderConsultList.addAll(itfGreeSynDownloadRecBean.getTblWorkOrderConsultList());
+                    tblWorkOrderDetailBarcodeList.addAll(itfGreeSynDownloadRecBean.getTblWorkOrderDetailBarcodeList());
+                    tblWorkOrderDetailRelocationList.addAll(itfGreeSynDownloadRecBean.getTblWorkOrderDetailRelocationList());
+                    tblWorkOrderDispatchOutletsList.addAll(itfGreeSynDownloadRecBean.getTblWorkOrderDispatchOutletsList());
+                    tblWorkOrderEngineerList.addAll(itfGreeSynDownloadRecBean.getTblWorkOrderEngineerList());
+                    tblWorkOrderEvaluationList.addAll(itfGreeSynDownloadRecBean.getTblWorkOrderEvaluationList());
+                    tblWorkOrderExtList.addAll(itfGreeSynDownloadRecBean.getTblWorkOrderExtList());
+                    tblWorkOrderIndicatorsList.addAll(itfGreeSynDownloadRecBean.getTblWorkOrderIndicatorsList());
+                    tblWorkOrderSignList.addAll(itfGreeSynDownloadRecBean.getTblWorkOrderSignList());
+                    tblWorkOrderTagList.addAll(itfGreeSynDownloadRecBean.getTblWorkOrderTagList());
+                    workOrderCollectionComplainList.addAll(itfGreeSynDownloadRecBean.getWorkOrderCollectionComplainList());
+                    workOrderChargeList.addAll(itfGreeSynDownloadRecBean.getWorkOrderChargeList());
 
-                for (ItfTblWorkOrderCollection0Bean itfTblWorkOrderCollectionBean : itfGreeSynDownloadRecBean.getWorkOrderCollectionList()) {
 
-                    ItfTblWorkOrderCollection itfTblWorkOrderCollection = BeanUtil.toBean(itfTblWorkOrderCollectionBean, ItfTblWorkOrderCollection.class);
-                    workOrderCollectionList.add(itfTblWorkOrderCollectionBean);
+                    for (ItfTblWorkOrderCollection0Bean itfTblWorkOrderCollectionBean : itfGreeSynDownloadRecBean.getWorkOrderCollectionList()) {
 
-                    collectionRepairList.addAll(itfTblWorkOrderCollectionBean.getCollectionRepairList());
-                    collectionRepairPartList.addAll(itfTblWorkOrderCollectionBean.getCollectionRepairPartList());
-                    collectionRepairProjectList.addAll(itfTblWorkOrderCollectionBean.getCollectionRepairProjectList());
-                    collectionRepairSymptomReasonList.addAll(itfTblWorkOrderCollectionBean.getCollectionRepairSymptomReasonList());
-                }
-                tblWorkOrderDispatchEngineerList.addAll(itfGreeSynDownloadRecBean.getTblWorkOrderDispatchEngineerList());
-                tblWorkOrderStatusList.addAll(itfGreeSynDownloadRecBean.getTblWorkOrderStatusList());
+                        ItfTblWorkOrderCollection itfTblWorkOrderCollection = BeanUtil.toBean(itfTblWorkOrderCollectionBean, ItfTblWorkOrderCollection.class);
+                        workOrderCollectionList.add(itfTblWorkOrderCollectionBean);
 
-                ItfTblWorkOrder itfTblWorkOrder = BeanUtil.toBean(itfGreeSynDownloadRecBean, ItfTblWorkOrder.class);
-                itfTblWorkOrders.add(itfTblWorkOrder);
+                        collectionRepairList.addAll(itfTblWorkOrderCollectionBean.getCollectionRepairList());
+                        collectionRepairPartList.addAll(itfTblWorkOrderCollectionBean.getCollectionRepairPartList());
+                        collectionRepairProjectList.addAll(itfTblWorkOrderCollectionBean.getCollectionRepairProjectList());
+                        collectionRepairSymptomReasonList.addAll(itfTblWorkOrderCollectionBean.getCollectionRepairSymptomReasonList());
+                    }
+                    tblWorkOrderDispatchEngineerList.addAll(itfGreeSynDownloadRecBean.getTblWorkOrderDispatchEngineerList());
+                    tblWorkOrderStatusList.addAll(itfGreeSynDownloadRecBean.getTblWorkOrderStatusList());
 
-            }
+                    ItfTblWorkOrder itfTblWorkOrder = BeanUtil.toBean(itfGreeSynDownloadRecBean, ItfTblWorkOrder.class);
+                    itfTblWorkOrders.add(itfTblWorkOrder);
 
-            if (!CollectionUtils.isEmpty(feedbackRespList)) {
-                feedbackRespList.stream().forEach(item -> item.setDownloadBatchNo(batch));
-                itfTblWorkOrderFeedbackService.saveBatch(feedbackRespList);
-            }
+                }
 
-            if (!CollectionUtils.isEmpty(tblWorkOrderDetailList)) {
-                tblWorkOrderDetailList.stream().forEach(item -> item.setDownloadBatchNo(batch));
-                itfTblWorkOrderDetailService.saveBatch(tblWorkOrderDetailList);
-            }
+                if (!CollectionUtils.isEmpty(feedbackRespList)) {
+                    feedbackRespList.stream().forEach(item -> item.setDownloadBatchNo(batch));
+                    itfTblWorkOrderFeedbackService.saveBatch(feedbackRespList);
+                }
 
-            if (!CollectionUtils.isEmpty(collectionChargeList)) {
-                collectionChargeList.stream().forEach(item -> item.setDownloadBatchNo(batch));
-                itfTblCollectionChargeService.saveBatch(collectionChargeList);
-            }
-            if (!CollectionUtils.isEmpty(collectionChargeDetails)) {
-                collectionChargeDetails.stream().forEach(item -> item.setDownloadBatchNo(batch));
-                itfTblCollectionChargeDetailService.saveBatch(collectionChargeDetails);
-            }
+                if (!CollectionUtils.isEmpty(tblWorkOrderDetailList)) {
+                    tblWorkOrderDetailList.stream().forEach(item -> item.setDownloadBatchNo(batch));
+                    itfTblWorkOrderDetailService.saveBatch(tblWorkOrderDetailList);
+                }
 
-            if (!CollectionUtils.isEmpty(tblOldProductOrderDetailList)) {
-                tblOldProductOrderDetailList.stream().forEach(item -> item.setDownloadBatchNo(batch));
-                itfTblOldProductOrderDetailService.saveBatch(tblOldProductOrderDetailList);
-            }
-            if (!CollectionUtils.isEmpty(tblWorkOrderAddComplainList)) {
-                tblWorkOrderAddComplainList.stream().forEach(item -> item.setDownloadBatchNo(batch));
-                itfTblWorkOrderAddComplainService.saveBatch(tblWorkOrderAddComplainList);
-            }
-            if (!CollectionUtils.isEmpty(tblWorkOrderAppointList)) {
-                tblWorkOrderAppointList.stream().forEach(item -> item.setDownloadBatchNo(batch));
-                itfTblWorkOrderAppointService.saveBatch(tblWorkOrderAppointList);
-            }
-            if (!CollectionUtils.isEmpty(tblWorkOrderCancelList)) {
-                tblWorkOrderCancelList.stream().forEach(item -> item.setDownloadBatchNo(batch));
-                itfTblWorkOrderCancelService.saveBatch(tblWorkOrderCancelList);
-            }
-            if (!CollectionUtils.isEmpty(tblWorkOrderComplainList)) {
-                tblWorkOrderComplainList.stream().forEach(item -> item.setDownloadBatchNo(batch));
-                itfTblWorkOrderComplainService.saveBatch(tblWorkOrderComplainList);
-            }
-            if (!CollectionUtils.isEmpty(tblWorkOrderComplainFeedbackList)) {
-                tblWorkOrderComplainFeedbackList.stream().forEach(item -> item.setDownloadBatchNo(batch));
-                itfTblWorkOrderComplainFeedbackService.saveBatch(tblWorkOrderComplainFeedbackList);
-            }
-            if (!CollectionUtils.isEmpty(tblWorkOrderCompleteInfoList)) {
-                tblWorkOrderCompleteInfoList.stream().forEach(item -> item.setDownloadBatchNo(batch));
-                itfTblWorkOrderCompleteInfoService.saveBatch(tblWorkOrderCompleteInfoList);
-            }
-            if (!CollectionUtils.isEmpty(tblWorkOrderConsultList)) {
-                tblWorkOrderConsultList.stream().forEach(item -> item.setDownloadBatchNo(batch));
-                itfTblWorkOrderConsultService.saveBatch(tblWorkOrderConsultList);
-            }
-            if (!CollectionUtils.isEmpty(tblWorkOrderDetailBarcodeList)) {
-                tblWorkOrderDetailBarcodeList.stream().forEach(item -> item.setDownloadBatchNo(batch));
-                itfTblWorkOrderDetailBarcodeService.saveBatch(tblWorkOrderDetailBarcodeList);
-            }
-            if (!CollectionUtils.isEmpty(tblWorkOrderDetailRelocationList)) {
-                tblWorkOrderDetailRelocationList.stream().forEach(item -> item.setDownloadBatchNo(batch));
-                itfTblWorkOrderDetailRelocationService.saveBatch(tblWorkOrderDetailRelocationList);
-            }
-            if (!CollectionUtils.isEmpty(tblWorkOrderDispatchOutletsList)) {
-                tblWorkOrderDispatchOutletsList.stream().forEach(item -> item.setDownloadBatchNo(batch));
-                itfTblWorkOrderDispatchOutletsService.saveBatch(tblWorkOrderDispatchOutletsList);
-            }
-            if (!CollectionUtils.isEmpty(tblWorkOrderEngineerList)) {
-                tblWorkOrderEngineerList.stream().forEach(item -> item.setDownloadBatchNo(batch));
-                itfTblWorkOrderEngineerService.saveBatch(tblWorkOrderEngineerList);
-            }
-            if (!CollectionUtils.isEmpty(tblWorkOrderEvaluationList)) {
-                tblWorkOrderEvaluationList.stream().forEach(item -> item.setDownloadBatchNo(batch));
-                itfTblWorkOrderEvaluationService.saveBatch(tblWorkOrderEvaluationList);
-            }
-            if (!CollectionUtils.isEmpty(tblWorkOrderExtList)) {
-                tblWorkOrderExtList.stream().forEach(item -> item.setDownloadBatchNo(batch));
-                itfTblWorkOrderExtService.saveBatch(tblWorkOrderExtList);
-            }
-            if (!CollectionUtils.isEmpty(tblWorkOrderIndicatorsList)) {
-                tblWorkOrderIndicatorsList.stream().forEach(item -> item.setDownloadBatchNo(batch));
-                itfTblWorkOrderIndicatorsService.saveBatch(tblWorkOrderIndicatorsList);
-            }
-            if (!CollectionUtils.isEmpty(tblWorkOrderSignList)) {
-                tblWorkOrderSignList.stream().forEach(item -> item.setDownloadBatchNo(batch));
-                itfTblWorkOrderSignService.saveBatch(tblWorkOrderSignList);
-            }
-            if (!CollectionUtils.isEmpty(tblWorkOrderTagList)) {
-                tblWorkOrderTagList.stream().forEach(item -> item.setDownloadBatchNo(batch));
-                itfTblWorkOrderTagService.saveBatch(tblWorkOrderTagList);
-            }
-            if (!CollectionUtils.isEmpty(workOrderChargeList)) {
-                workOrderChargeList.stream().forEach(item -> item.setDownloadBatchNo(batch));
-                itfTblWorkOrderChargeService.saveBatch(workOrderChargeList);
-            }
-            if (!CollectionUtils.isEmpty(workOrderCollectionComplainList)) {
-                workOrderCollectionComplainList.stream().forEach(item -> item.setDownloadBatchNo(batch));
-                itfTblWorkOrderCollectionComplainService.saveBatch(workOrderCollectionComplainList);
-            }
-            if (!CollectionUtils.isEmpty(tblWorkOrderDispatchEngineerList)) {
-                tblWorkOrderDispatchEngineerList.stream().forEach(item -> item.setDownloadBatchNo(batch));
-                itfTblWorkOrderDispatchEngineerService.saveBatch(tblWorkOrderDispatchEngineerList);
-            }
-            if (!CollectionUtils.isEmpty(tblWorkOrderStatusList)) {
-                tblWorkOrderStatusList.stream().forEach(item -> item.setDownloadBatchNo(batch));
-                itfTblWorkOrderStatusService.saveBatch(tblWorkOrderStatusList);
-            }
-            if (!CollectionUtils.isEmpty(workOrderCollectionList)) {
-                workOrderCollectionList.stream().forEach(item -> item.setDownloadBatchNo(batch));
-                itfTblWorkOrderCollectionService.saveBatch(workOrderCollectionList);
-            }
-            if (!CollectionUtils.isEmpty(collectionRepairList)) {
-                collectionRepairList.stream().forEach(item -> item.setDownloadBatchNo(batch));
-                itfTblCollectionRepairService.saveBatch(collectionRepairList);
-            }
-            if (!CollectionUtils.isEmpty(collectionRepairPartList)) {
-                collectionRepairPartList.stream().forEach(item -> item.setDownloadBatchNo(batch));
-                itfTblCollectionRepairPartService.saveBatch(collectionRepairPartList);
-            }
-            if (!CollectionUtils.isEmpty(collectionRepairProjectList)) {
-                collectionRepairProjectList.stream().forEach(item -> item.setDownloadBatchNo(batch));
-                itfTblCollectionRepairProjectService.saveBatch(collectionRepairProjectList);
-            }
-            if (!CollectionUtils.isEmpty(collectionRepairSymptomReasonList)) {
-                collectionRepairSymptomReasonList.stream().forEach(item -> item.setDownloadBatchNo(batch));
-                itfTblCollectionRepairSymptomReasonService.saveBatch(collectionRepairSymptomReasonList);
-            }
+                if (!CollectionUtils.isEmpty(collectionChargeList)) {
+                    collectionChargeList.stream().forEach(item -> item.setDownloadBatchNo(batch));
+                    itfTblCollectionChargeService.saveBatch(collectionChargeList);
+                }
+                if (!CollectionUtils.isEmpty(collectionChargeDetails)) {
+                    collectionChargeDetails.stream().forEach(item -> item.setDownloadBatchNo(batch));
+                    itfTblCollectionChargeDetailService.saveBatch(collectionChargeDetails);
+                }
 
-            if (!CollectionUtils.isEmpty(itfTblWorkOrders)) {
-                itfTblWorkOrders.stream().forEach(item -> item.setDownloadBatchNo(batch));
-                itfTblWorkOrderService.saveBatch(itfTblWorkOrders);
-            }
+                if (!CollectionUtils.isEmpty(tblOldProductOrderDetailList)) {
+                    tblOldProductOrderDetailList.stream().forEach(item -> item.setDownloadBatchNo(batch));
+                    itfTblOldProductOrderDetailService.saveBatch(tblOldProductOrderDetailList);
+                }
+                if (!CollectionUtils.isEmpty(tblWorkOrderAddComplainList)) {
+                    tblWorkOrderAddComplainList.stream().forEach(item -> item.setDownloadBatchNo(batch));
+                    itfTblWorkOrderAddComplainService.saveBatch(tblWorkOrderAddComplainList);
+                }
+                if (!CollectionUtils.isEmpty(tblWorkOrderAppointList)) {
+                    tblWorkOrderAppointList.stream().forEach(item -> item.setDownloadBatchNo(batch));
+                    itfTblWorkOrderAppointService.saveBatch(tblWorkOrderAppointList);
+                }
+                if (!CollectionUtils.isEmpty(tblWorkOrderCancelList)) {
+                    tblWorkOrderCancelList.stream().forEach(item -> item.setDownloadBatchNo(batch));
+                    itfTblWorkOrderCancelService.saveBatch(tblWorkOrderCancelList);
+                }
+                if (!CollectionUtils.isEmpty(tblWorkOrderComplainList)) {
+                    tblWorkOrderComplainList.stream().forEach(item -> item.setDownloadBatchNo(batch));
+                    itfTblWorkOrderComplainService.saveBatch(tblWorkOrderComplainList);
+                }
+                if (!CollectionUtils.isEmpty(tblWorkOrderComplainFeedbackList)) {
+                    tblWorkOrderComplainFeedbackList.stream().forEach(item -> item.setDownloadBatchNo(batch));
+                    itfTblWorkOrderComplainFeedbackService.saveBatch(tblWorkOrderComplainFeedbackList);
+                }
+                if (!CollectionUtils.isEmpty(tblWorkOrderCompleteInfoList)) {
+                    tblWorkOrderCompleteInfoList.stream().forEach(item -> item.setDownloadBatchNo(batch));
+                    itfTblWorkOrderCompleteInfoService.saveBatch(tblWorkOrderCompleteInfoList);
+                }
+                if (!CollectionUtils.isEmpty(tblWorkOrderConsultList)) {
+                    tblWorkOrderConsultList.stream().forEach(item -> item.setDownloadBatchNo(batch));
+                    itfTblWorkOrderConsultService.saveBatch(tblWorkOrderConsultList);
+                }
+                if (!CollectionUtils.isEmpty(tblWorkOrderDetailBarcodeList)) {
+                    tblWorkOrderDetailBarcodeList.stream().forEach(item -> item.setDownloadBatchNo(batch));
+                    itfTblWorkOrderDetailBarcodeService.saveBatch(tblWorkOrderDetailBarcodeList);
+                }
+                if (!CollectionUtils.isEmpty(tblWorkOrderDetailRelocationList)) {
+                    tblWorkOrderDetailRelocationList.stream().forEach(item -> item.setDownloadBatchNo(batch));
+                    itfTblWorkOrderDetailRelocationService.saveBatch(tblWorkOrderDetailRelocationList);
+                }
+                if (!CollectionUtils.isEmpty(tblWorkOrderDispatchOutletsList)) {
+                    tblWorkOrderDispatchOutletsList.stream().forEach(item -> item.setDownloadBatchNo(batch));
+                    itfTblWorkOrderDispatchOutletsService.saveBatch(tblWorkOrderDispatchOutletsList);
+                }
+                if (!CollectionUtils.isEmpty(tblWorkOrderEngineerList)) {
+                    tblWorkOrderEngineerList.stream().forEach(item -> item.setDownloadBatchNo(batch));
+                    itfTblWorkOrderEngineerService.saveBatch(tblWorkOrderEngineerList);
+                }
+                if (!CollectionUtils.isEmpty(tblWorkOrderEvaluationList)) {
+                    tblWorkOrderEvaluationList.stream().forEach(item -> item.setDownloadBatchNo(batch));
+                    itfTblWorkOrderEvaluationService.saveBatch(tblWorkOrderEvaluationList);
+                }
+                if (!CollectionUtils.isEmpty(tblWorkOrderExtList)) {
+                    tblWorkOrderExtList.stream().forEach(item -> item.setDownloadBatchNo(batch));
+                    itfTblWorkOrderExtService.saveBatch(tblWorkOrderExtList);
+                }
+                if (!CollectionUtils.isEmpty(tblWorkOrderIndicatorsList)) {
+                    tblWorkOrderIndicatorsList.stream().forEach(item -> item.setDownloadBatchNo(batch));
+                    itfTblWorkOrderIndicatorsService.saveBatch(tblWorkOrderIndicatorsList);
+                }
+                if (!CollectionUtils.isEmpty(tblWorkOrderSignList)) {
+                    tblWorkOrderSignList.stream().forEach(item -> item.setDownloadBatchNo(batch));
+                    itfTblWorkOrderSignService.saveBatch(tblWorkOrderSignList);
+                }
+                if (!CollectionUtils.isEmpty(tblWorkOrderTagList)) {
+                    tblWorkOrderTagList.stream().forEach(item -> item.setDownloadBatchNo(batch));
+                    itfTblWorkOrderTagService.saveBatch(tblWorkOrderTagList);
+                }
+                if (!CollectionUtils.isEmpty(workOrderChargeList)) {
+                    workOrderChargeList.stream().forEach(item -> item.setDownloadBatchNo(batch));
+                    itfTblWorkOrderChargeService.saveBatch(workOrderChargeList);
+                }
+                if (!CollectionUtils.isEmpty(workOrderCollectionComplainList)) {
+                    workOrderCollectionComplainList.stream().forEach(item -> item.setDownloadBatchNo(batch));
+                    itfTblWorkOrderCollectionComplainService.saveBatch(workOrderCollectionComplainList);
+                }
+                if (!CollectionUtils.isEmpty(tblWorkOrderDispatchEngineerList)) {
+                    tblWorkOrderDispatchEngineerList.stream().forEach(item -> item.setDownloadBatchNo(batch));
+                    itfTblWorkOrderDispatchEngineerService.saveBatch(tblWorkOrderDispatchEngineerList);
+                }
+                if (!CollectionUtils.isEmpty(tblWorkOrderStatusList)) {
+                    tblWorkOrderStatusList.stream().forEach(item -> item.setDownloadBatchNo(batch));
+                    itfTblWorkOrderStatusService.saveBatch(tblWorkOrderStatusList);
+                }
+                if (!CollectionUtils.isEmpty(workOrderCollectionList)) {
+                    workOrderCollectionList.stream().forEach(item -> item.setDownloadBatchNo(batch));
+                    itfTblWorkOrderCollectionService.saveBatch(workOrderCollectionList);
+                }
+                if (!CollectionUtils.isEmpty(collectionRepairList)) {
+                    collectionRepairList.stream().forEach(item -> item.setDownloadBatchNo(batch));
+                    itfTblCollectionRepairService.saveBatch(collectionRepairList);
+                }
+                if (!CollectionUtils.isEmpty(collectionRepairPartList)) {
+                    collectionRepairPartList.stream().forEach(item -> item.setDownloadBatchNo(batch));
+                    itfTblCollectionRepairPartService.saveBatch(collectionRepairPartList);
+                }
+                if (!CollectionUtils.isEmpty(collectionRepairProjectList)) {
+                    collectionRepairProjectList.stream().forEach(item -> item.setDownloadBatchNo(batch));
+                    itfTblCollectionRepairProjectService.saveBatch(collectionRepairProjectList);
+                }
+                if (!CollectionUtils.isEmpty(collectionRepairSymptomReasonList)) {
+                    collectionRepairSymptomReasonList.stream().forEach(item -> item.setDownloadBatchNo(batch));
+                    itfTblCollectionRepairSymptomReasonService.saveBatch(collectionRepairSymptomReasonList);
+                }
+
+                if (!CollectionUtils.isEmpty(itfTblWorkOrders)) {
+                    itfTblWorkOrders.stream().forEach(item -> item.setDownloadBatchNo(batch));
+                    itfTblWorkOrderService.saveBatch(itfTblWorkOrders);
+                }
 
 
-        } catch (Exception e) {
-            List<Long> syncIds = itfGreeSynDownloadRecs.stream().map(ItfGreeSynDownloadRec::getSynReqId).collect(Collectors.toList());
+            } catch (Exception e) {
+                List<Long> syncIds = itfGreeSynDownloadRecs.stream().map(ItfGreeSynDownloadRec::getSynReqId).collect(Collectors.toList());
 
-            log.error("工单同步错误" + e.getMessage());
+                log.error("工单同步错误" + e.getMessage());
 
-            itfGreeSynDownloadRecService.lambdaUpdate()
-                    .in(ItfGreeSynDownloadRec::getSynReqId, syncIds)
-                    .set(ItfGreeSynDownloadRec::getGreeStatSynErrMsg, e.getMessage())
-                    .set(ItfGreeSynDownloadRec::getGreeStatSynTime, new Date())
-                    .set(ItfGreeSynDownloadRec::getGreeStatSynStatus, 99).update();
+                itfGreeSynDownloadRecService.lambdaUpdate()
+                        .in(ItfGreeSynDownloadRec::getSynReqId, syncIds)
+                        .set(ItfGreeSynDownloadRec::getGreeStatSynErrMsg, e.getMessage())
+                        .set(ItfGreeSynDownloadRec::getGreeStatSynTime, new Date())
+                        .set(ItfGreeSynDownloadRec::getGreeStatSynStatus, 99).update();
 
 
+            }
         }
 
     }