|
@@ -211,19 +211,18 @@ public class SyncOrderInfoLogic {
|
|
|
Map<String, String> heard = new HashMap<>();
|
|
|
heard.put("authorization", "Bearer " + accessToken);
|
|
|
|
|
|
- log.info(greeUrl + Constant.gree.GET_UPDATE_ORDERS + "/" + itfGreeSynRule.getSalesWebsitNumber() + "/" + time+",参数"+params.toString()+",token"+heard);
|
|
|
String body = HttpUtils.requestGet(greeUrl + Constant.gree.GET_UPDATE_ORDERS + "/" + itfGreeSynRule.getSalesWebsitNumber() + "/" + time, params, heard);
|
|
|
|
|
|
- log.info(itfGreeSynRule.getSalesWebsitNumber()+"时间为:"+time+"【工单同步数据内容】:" + body);
|
|
|
Map<String, Object> bodyMap = JSON.parseObject(body);
|
|
|
|
|
|
+ log.info(itfGreeSynRule.getSalesWebsitNumber() + "时间为:" + time + "【工单同步数据内容】:" + bodyMap.toString());
|
|
|
+
|
|
|
String s = bodyMap.get("data").toString();
|
|
|
|
|
|
|
|
|
JSONArray jsonArray = JSONUtil.parseArray(s);
|
|
|
|
|
|
|
|
|
-
|
|
|
itfGreeSynRule.setLastSynUpdTime(new Date());
|
|
|
|
|
|
itfGreeSynRule.updateById();
|
|
@@ -258,8 +257,8 @@ public class SyncOrderInfoLogic {
|
|
|
itfGreeSynDownloadRecService.lambdaUpdate().in(ItfGreeSynDownloadRec::getWorkOrderId,
|
|
|
itfGreeSynDownloadRecs.stream().map(ItfGreeSynDownloadRec::getWorkOrderId)
|
|
|
.collect(Collectors.toList()))
|
|
|
- .eq(ItfGreeSynDownloadRec::getGreeStatSynStatus,0)
|
|
|
- .set(ItfGreeSynDownloadRec::getGreeStatSynStatus,9)
|
|
|
+ .eq(ItfGreeSynDownloadRec::getGreeStatSynStatus, 0)
|
|
|
+ .set(ItfGreeSynDownloadRec::getGreeStatSynStatus, 9)
|
|
|
.update();
|
|
|
|
|
|
itfGreeSynDownloadRecService.saveBatch(itfGreeSynDownloadRecs);
|
|
@@ -306,235 +305,301 @@ public class SyncOrderInfoLogic {
|
|
|
}
|
|
|
|
|
|
|
|
|
- @Transactional(rollbackFor = Exception.class)
|
|
|
- public void syncDetail() {
|
|
|
+ public synchronized 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());
|
|
|
|
|
|
- tblOldProductOrderDetailList.addAll(itfGreeSynDownloadRecBean.getTblOldProductOrderDetailList());
|
|
|
+ tblWorkOrderAddComplainList.addAll(itfGreeSynDownloadRecBean.getTblWorkOrderAddComplainList());
|
|
|
|
|
|
- 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());
|
|
|
|
|
|
- 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()) {
|
|
|
|
|
|
- for (ItfTblWorkOrderCollection0Bean itfTblWorkOrderCollectionBean : itfGreeSynDownloadRecBean.getWorkOrderCollectionList()) {
|
|
|
+ ItfTblWorkOrderCollection itfTblWorkOrderCollection = BeanUtil.toBean(itfTblWorkOrderCollectionBean, ItfTblWorkOrderCollection.class);
|
|
|
+ workOrderCollectionList.add(itfTblWorkOrderCollectionBean);
|
|
|
|
|
|
- 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());
|
|
|
+
|
|
|
+ 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(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(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);
|
|
|
+ }
|
|
|
|
|
|
- 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();
|
|
|
+ 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());
|
|
|
|
|
|
+ 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();
|
|
|
+
|
|
|
+
|
|
|
+ }
|
|
|
}
|
|
|
|
|
|
}
|
|
@@ -557,19 +622,19 @@ public class SyncOrderInfoLogic {
|
|
|
workerOrderSyncBean.setInDownloadBatchNo(itfTblWorkOrder.getDownloadBatchNo());
|
|
|
WorkerOrderSyncBean workerOrderSyncBean1 = syncMapper.orderExecute(workerOrderSyncBean);
|
|
|
|
|
|
- if (!workerOrderSyncBean1.getOutSynStatus()){
|
|
|
+ if (!workerOrderSyncBean1.getOutSynStatus()) {
|
|
|
|
|
|
- log.info("工单同步返回内容:"+workerOrderSyncBean1.toString());
|
|
|
- itfTblWorkOrder.setSynTimes(itfTblWorkOrder.getSynTimes()+1);
|
|
|
+ log.info("工单同步返回内容:" + workerOrderSyncBean1.toString());
|
|
|
+ itfTblWorkOrder.setSynTimes(itfTblWorkOrder.getSynTimes() + 1);
|
|
|
itfTblWorkOrder.setSynErrMsg(workerOrderSyncBean1.getOutSynErrMsg());
|
|
|
itfTblWorkOrder.updateById();
|
|
|
}
|
|
|
- }catch (Exception e){
|
|
|
- itfTblWorkOrder.setSynTimes(itfTblWorkOrder.getSynTimes()+1);
|
|
|
+ } catch (Exception e) {
|
|
|
+ itfTblWorkOrder.setSynTimes(itfTblWorkOrder.getSynTimes() + 1);
|
|
|
itfTblWorkOrder.setSynErrMsg(e.getMessage());
|
|
|
itfTblWorkOrder.updateById();
|
|
|
|
|
|
- log.info("工单同步返回日志错误内容:"+itfTblWorkOrder.getDownloadBatchNo()+e);
|
|
|
+ log.info("工单同步返回日志错误内容:" + itfTblWorkOrder.getDownloadBatchNo() + e);
|
|
|
}
|
|
|
|
|
|
|