yaozhixue 1 年之前
父节点
当前提交
4c96ac359a

+ 14 - 0
src/main/java/com/zfire/jiasm/syncdata/service/impl/AddInstallBusinessImpl.java

@@ -86,6 +86,9 @@ public class AddInstallBusinessImpl implements AddInstallBusiness {
     SysVariableConfigService sysVariableConfigService;
     @Autowired
     ItfMessagehuifangentityService itfMessagehuifangentityService;
+    @Resource
+    SyncCreateOrderService syncCreateOrderService;
+
 
 
 
@@ -278,9 +281,20 @@ public class AddInstallBusinessImpl implements AddInstallBusiness {
         ResponseHelper respone = jiasmApi.orderAdd(createOrder);
         log.info("创建安装工单接口 respone:{}", JSONObject.toJSONString(respone));
         if (respone.getCode()==200){
+            if (flag){
+                SyncCreateOrder sco = new SyncCreateOrder();
+                sco.setId(publicService.getUUID());
+                sco.setOrderBaseId(createOrder.getGreeId());
+                sco.setPgidOrPgguid(item.getPgguid());
+                sco.setOrderJson(JSONObject.toJSONString(createOrder));
+                sco.setCreateTime(new Date());
+                syncCreateOrderService.save(sco);
+            }
+
             // 安装工单数据落本地表
             addOrderDataApi(item.getSynReqId(), synReqIds, synReqFkMxIds, synReqYfYyIds, fyqd, getpjSynReqId,
                     faGreeSms, orderAppeal, its, odfs, oiolList, oids, oa);
+
             return Boolean.TRUE;
         } else {
             String msg = publicService.getErrormessage(respone);

+ 11 - 0
src/main/java/com/zfire/jiasm/syncdata/service/impl/AddRepairBusinessServiceImpl.java

@@ -96,6 +96,8 @@ public class AddRepairBusinessServiceImpl implements AddRepairBusinessService {
     TestService testService;
     @Resource
     ItfGreeToFaDownloadTaskListService itfGreeToFaDownloadTaskListService;
+    @Resource
+    SyncCreateOrderService syncCreateOrderService;
 
 
 
@@ -423,6 +425,15 @@ public class AddRepairBusinessServiceImpl implements AddRepairBusinessService {
         ResponseHelper respone = jiasmApi.orderAdd(orderApi);
         log.info("创建维修工单 respone:{}", JSONObject.toJSONString(respone));
         if (respone.getCode()==200){
+            if (flag){
+                SyncCreateOrder sco = new SyncCreateOrder();
+                sco.setId(publicService.getUUID());
+                sco.setOrderBaseId(orderApi.getGreeId());
+                sco.setPgidOrPgguid(String.valueOf(item.getPgid()));
+                sco.setOrderJson(JSONObject.toJSONString(orderApi));
+                sco.setCreateTime(new Date());
+                syncCreateOrderService.save(sco);
+            }
             // 同步更新状态
             synStatus(item, ups, pjups, orderAppeal, oanew, faGreeSms, oilist, ydups, fkmxups, orols, us, order,its);
             return Boolean.TRUE;