add

src/main/java/com/zfire/jiasm/syncdata/api/OrderAddBeanDTO.java

@@ -16,8 +16,6 @@ public class OrderAddBeanDTO {
     private String id;
     //操作标记 1=临时保存,2=下派工单   不能为空
     private Integer operatorFlag;
-    // 操作标记: 0=临时保存 1=下派服务单，2=下派网点，3=下派师傅)
-    private Integer flag;
     //客户名称  不能为空
     private String userName;
     //联系人  不能为空
@@ -74,10 +72,17 @@ public class OrderAddBeanDTO {
     private String demandSmallTypeId;
     // 需求小类名称
     private String demandSmallTypeName;
-    // 结算主体id   不能为空
-    private String brandId;
+    // 当前工单状态
+    private String orderStatus;
     // 产品品牌id
     private String productBrandId;
+
+
+
+
+    // 结算主体id   不能为空
+    private String brandId;
+
     // 产品大类id   不能为空
     private String mainId;
     // 商户网点id 不能为空
@@ -154,8 +159,7 @@ public class OrderAddBeanDTO {
     private String shopFlag;
     // 产品信息/故障信息
     private List<OrderProduct> orderProductList = new ArrayList<>();
-    // 当前工单状态
-    private String orderStatus;
+
 
     // 工程单号-销售类型为工程机必填
     private String enginNo;
@@ -202,8 +206,14 @@ public class OrderAddBeanDTO {
     // 格力工单号
     private String greeId;
 
+    // 是否为跨区单
+    private IsEnum isSpanned;
+
     // 安装、维修总数量
     private Integer totalNum;
     // 未完成数量
     private Integer undoneNum;
+
+    // 操作标记：0=临时保存 1=下派服务单，2=下派网点，3=下派师傅，4=智能派工
+    private Integer flag;
 }

src/main/java/com/zfire/jiasm/syncdata/service/impl/GLPPGFWebsitServiceImpl.java

@@ -900,7 +900,7 @@ public class GLPPGFWebsitServiceImpl implements GLPPGFWebsitService {
         addWebsitRec.add(v);
     }
 
-    private void extractedFSXSWDAddOrUpdate(List<ItfTblXinWangdianDownload> addRec, List<ItfTblXinWangdianDownload> updateRec, JSONArray jsonArray, String synTaskNo) {
+    private void extractedFSXSWDAddOrUpdateBak(List<ItfTblXinWangdianDownload> addRec, List<ItfTblXinWangdianDownload> updateRec, JSONArray jsonArray, String synTaskNo) {
         Boolean flag = Boolean.FALSE;
         List<ItfTblXinWangdianDownload> oldRec =  new ArrayList<>();
         List<String> oldRecpkGuid = new ArrayList<>();
@@ -1343,4 +1343,60 @@ public class GLPPGFWebsitServiceImpl implements GLPPGFWebsitService {
             log.info("网点基础资料信息同步更新修改了{}条数据", updateRec.size());
         }
     }
+
+
+    private void extractedFSXSWDAddOrUpdate(List<ItfTblXinWangdianDownload> addRec, List<ItfTblXinWangdianDownload> updateRec, JSONArray jsonArray, String synTaskNo) {
+        List<ItfTblXinWangdianDownload> oldRec =  new ArrayList<>();
+        List<String> oldRecpkGuid = new ArrayList<>();
+        Map<String, List<ItfTblXinWangdianDownload>> oldRecMap = new HashMap<>();
+
+        // 提取现有的数据信息
+        oldRec =  itfTblXinWangdianDownloadService.lambdaQuery().list();
+        if (CollectionUtils.isNotEmpty(oldRec)){
+            oldRecpkGuid = oldRec.stream().map(ItfTblXinWangdianDownload::getPkGuid).collect(Collectors.toList());
+            oldRecMap = oldRec.stream().collect(Collectors.groupingBy(ItfTblXinWangdianDownload::getPkGuid));
+        }
+
+        for (int i = 0; i < jsonArray.size(); i++) {
+            JSONObject aData = jsonArray.getJSONObject(i);
+            ItfTblXinWangdianDownload item = JSON.toJavaObject(aData,ItfTblXinWangdianDownload.class);
+            // 修改
+            if (oldRecpkGuid.contains(item.getPkGuid())){
+                ItfTblXinWangdianDownload old = oldRecMap.get(item.getPkGuid()).get(0);
+                item.setSynReqId(old.getSynReqId());
+
+                item.setLastModifiedBy("system");
+                item.setLastModifiedDate(new Date());
+                // 操作人
+                if (!StringUtils.isEmpty(item.getLastModifiedBy())){
+                    item.setLastModifiedBy(item.getLastModifiedBy());
+                }
+                // 修改时间
+                if (!StringUtils.isEmpty(item.getLastModifiedDate())){
+                    item.setLastModifiedDate(item.getLastModifiedDate());
+                }
+                updateRec.add(item);
+            } else {
+                // 新增
+                item.setSynTaskNo(synTaskNo);
+                item.setSynReqTime(new Date());
+                item.setSynStatus(1);
+                item.setSynTime(new Date());
+                item.setSynTimes(0);
+                addRec.add(item);
+            }
+        }
+
+        // 新增的插入到表
+        if (addRec.size()>0){
+            itfTblXinWangdianDownloadService.saveBatch(addRec);
+            log.info("网点基础资料信息同步新增插入了{}条数据", addRec.size());
+        }
+
+        // 更新
+        if (updateRec.size()>0){
+            itfTblXinWangdianDownloadService.updateBatchById(updateRec);
+            log.info("网点基础资料信息同步更新修改了{}条数据", updateRec.size());
+        }
+    }
 }