优化了要货计划和销售合同台账

src/main/java/com/management/controller/GoodsPlanController.java

@@ -972,9 +972,9 @@ public class GoodsPlanController {
         }
 
         trackingNumMap.put("f9w5_deviceid", trackingNumData.getString("device_id_third__c") != null ? trackingNumData.getString("device_id_third__c") : "");//设备ID（第三方编号）
-        trackingNumMap.put("f9w5_apn", trackingNumData.getString("apn_parameters__c") != null ? trackingNumData.getString("apn_parameters__c") : "");//APN参数
+        trackingNumMap.put("f9w5_apn", trackingNumData.getString("apn_parameters__c") != null ? trackingNumData.getString("apn_parameters__c") : "无");//APN参数
-        trackingNumMap.put("f9w5_ip", trackingNumData.getString("ip_address__c") != null ? trackingNumData.getString("ip_address__c") : "");//ip
+        trackingNumMap.put("f9w5_ip", trackingNumData.getString("ip_address__c") != null ? trackingNumData.getString("ip_address__c") : "无");//ip
-        trackingNumMap.put("f9w5_port", trackingNumData.getString("port__c") != null ? trackingNumData.getString("port__c") : "");//端口
+        trackingNumMap.put("f9w5_port", trackingNumData.getString("port__c") != null ? trackingNumData.getString("port__c") : "无");//端口
 
         //是否插卡
         String isCard = trackingNumData.getString("is_card_inserted__c") != null ? trackingNumData.getString("is_card_inserted__c") : "";
@@ -1051,7 +1051,7 @@ public class GoodsPlanController {
 
         trackingNumMap.put("f9w5_auxiliarytype", auxiliarychanneltype);
         //维护时间段
-        trackingNumMap.put("f9w5_maintenancetime", trackingNumData.getString("maintenance_time_period__c") != null ? trackingNumData.getString("maintenance_time_period__c") : "");
+        trackingNumMap.put("f9w5_maintenancetime", trackingNumData.getString("maintenance_time_period__c") != null ? trackingNumData.getString("maintenance_time_period__c") : "无");
         //出厂内外卡选择
         trackingNumMap.put("f9w5_inoutcard", trackingNumData.getString("factory_external_card_choi__c__r") != null ? trackingNumData.getString("factory_external_card_choi__c__r") : "");
         //出厂平台选择

src/main/java/com/management/tzcontroller/TZXSHTController.java

@@ -14,6 +14,8 @@ import org.springframework.web.bind.annotation.RestController;
 import org.springframework.web.client.RestClientException;
 import org.springframework.web.client.RestTemplate;
 
+import java.time.LocalDateTime;
+import java.time.ZoneId;
 import java.util.Arrays;
 import java.util.HashMap;
 import java.util.Map;
@@ -43,7 +45,7 @@ public class TZXSHTController {
         String[] syncStatus = {"option_pending_sync__c", "option_resync__c"};
 
         JSONObject salesOrderReq = crmRequestUtil.getCRMList(Arrays.asList(
-                new Filter("GT", "last_modified_time", Arrays.asList("1748923200000")),
+                new Filter("GT", "create_time", Arrays.asList("1748923200000")),
                 new Filter("EQ", "life_status", Arrays.asList("normal")),
                 new Filter("N", "is_initial__c", Arrays.asList("true")),
                 new Filter("ISN", "zhy_contract_number__c", Arrays.asList("")),
@@ -78,7 +80,7 @@ public class TZXSHTController {
                 continue;
             }
 
-            String modifyTime = salesOrderData.getString("last_modified_time");
+            String modifyTime = salesOrderData.getString("create_time");
 
             //开始查询数据库是否已经存在该数据
             JSONObject salesOrderIsExist = new JSONObject();
@@ -239,4 +241,217 @@ public class TZXSHTController {
         }
     }
 
+    /**
+     * 更新销售合同
+     *
+     * @return void
+     * @Author weiloong_zhang
+     */
+    @PostMapping
+    public void updateSalesOrder() {
+        CrmRequestUtil crmRequestUtil = new CrmRequestUtil();
+
+        long twoDaysAgo = LocalDateTime.now()
+                .minusDays(3)
+                .atZone(ZoneId.systemDefault())
+                .toInstant()
+                .toEpochMilli();
+
+        JSONObject salesOrderReq = crmRequestUtil.getCRMList(Arrays.asList(
+                new Filter("GT", "last_modified_time", Arrays.asList(String.valueOf(twoDaysAgo))),
+                new Filter("EQ", "life_status", Arrays.asList("normal")),
+                new Filter("N", "is_initial__c", Arrays.asList("true")),
+                new Filter("ISN", "zhy_contract_number__c", Arrays.asList("")),
+                //new Filter("EQ", "name", Arrays.asList("ZHY2505260018")),
+                new Filter("EQ", "ledger_sync_status__c", Arrays.asList("option_sync_success__c"))
+        ), "SaleContractObj");
+
+        JSONObject salesOrderRes = new JSONObject();
+
+        try {
+            salesOrderRes = restTemplate.postForObject(URLConstant.GET_CRM_LIST_URL, salesOrderReq, JSONObject.class);
+        } catch (RestClientException e) {
+            e.printStackTrace();
+        }
+
+        if (!"success".equals(salesOrderRes.getString("errorDescription")) || salesOrderRes.getJSONObject("data").getJSONArray("dataList").isEmpty()) {
+            log.info("销售合同为空或者请求失败，将不再向下执行");
+            return;
+        }
+
+        for (Object salesOrderObj : salesOrderRes.getJSONObject("data").getJSONArray("dataList")) {
+            JSONObject salesOrderData = JSON.parseObject(JSON.toJSONString(salesOrderObj));
+
+            System.out.println("当前正在处理的数据为：" + salesOrderData);
+
+            //开始截取关键数据
+            String salesOrderId = salesOrderData.getString("_id");//唯一id
+            String salesOrderName = salesOrderData.getString("zhy_contract_number__c") != null ? salesOrderData.getString("zhy_contract_number__c") : "";
+
+            if ("".equals(salesOrderName)) {
+                log.info("合同名称不存在，将不再向下执行");
+                continue;
+            }
+
+            String modifyTime = salesOrderData.getString("last_modified_time");
+
+            //开始查询数据库是否已经存在该数据
+            JSONObject salesOrderIsExist = new JSONObject();
+
+            try {
+                salesOrderIsExist = restTemplate.getForObject("http://localhost:18085/Log/query/log_data?table=send_log_tzht&log_type=TZXSHTUP&dataId=" + salesOrderId + "&mark=" + modifyTime, JSONObject.class);
+            } catch (RestClientException e) {
+                e.printStackTrace();
+            }
+
+            if (!salesOrderIsExist.getJSONArray("data").isEmpty()) {
+                log.info("数据已经存在，将不再继续向下执行");
+                continue;
+            }
+
+            log.info("数据不存在，将开始向下执行");
+
+            Map salesOrderReqMap = new HashMap<>();
+            salesOrderReqMap.put("crmId", salesOrderId);
+            salesOrderReqMap.put("contract", salesOrderName);//合同号
+            salesOrderReqMap.put("contractName", salesOrderData.getString("project_name__c") != null ? salesOrderData.getString("project_name__c") : "");//合同名称
+            salesOrderReqMap.put("signingUnit", salesOrderData.getString("account_id__r") != null ? salesOrderData.getString("account_id__r") : "");//签订单位
+            salesOrderReqMap.put("customerId", salesOrderData.getString("account_id") != null ? salesOrderData.getString("account_id") : "");//签订单位唯一性ID
+
+            //开始获取地区
+            //省
+            String province = salesOrderData.getString("field_9IuQE__c__r") != null ? salesOrderData.getString("field_9IuQE__c__r") : "";
+            //市
+            String city = salesOrderData.getString("field_cuMW9__c__r") != null ? salesOrderData.getString("field_cuMW9__c__r") : "";
+            //区
+            String district = salesOrderData.getString("field_e9XrV__c__r") != null ? salesOrderData.getString("field_e9XrV__c__r") : "";
+            //详细地址
+            String address = salesOrderData.getString("field_tfkq9__c") != null ? salesOrderData.getString("field_tfkq9__c") : "";
+            //地址
+            String region = province + city + district + address;
+
+            salesOrderReqMap.put("region", region);//地区
+
+            //是否竣工
+            String isComplete = salesOrderData.getString("is_completed__c") != null ? salesOrderData.getString("is_completed__c") : "";
+
+            Integer isCompletion = 0;
+
+            switch (isComplete) {
+                case "yes":
+                    isCompletion = 1;
+                    break;
+                case "no":
+                    isCompletion = 0;
+                    break;
+                default:
+                    isCompletion = 0;
+            }
+
+            salesOrderReqMap.put("isCompletion", isCompletion);//是否竣工
+
+            //开始获取oken
+            String token = new LedgerTokenController().getToken();
+
+            if (token == null || "".equals(token)) {
+                log.info("台账token获取失败，将不再向下执行");
+                continue;
+            }
+
+            HttpHeaders headers = new HttpHeaders();
+            headers.set("Content-Type", "application/json");
+            headers.set("accessToken", token);
+
+            HttpEntity reqEntity = new HttpEntity(Arrays.asList(salesOrderReqMap), headers);
+
+            System.out.println(JSON.parseObject(JSON.toJSONString(reqEntity)));
+
+            String url = "http://192.168.9.4:9011/crm/initContract";
+
+            JSONObject salesOrderResult = new JSONObject();
+
+            try {
+                salesOrderResult = restTemplate.postForObject(url, reqEntity, JSONObject.class);
+            } catch (RestClientException e) {
+                e.printStackTrace();
+            }
+
+            System.out.println(JSON.parseObject(JSON.toJSONString(salesOrderResult)));
+
+            //开始封装回写程序
+            Map backReqMap = new HashMap();
+            backReqMap.put("_id", salesOrderId);
+            backReqMap.put("dataObjectApiName", "SaleContractObj");
+
+            //开始封装日志
+            Map logMap = new HashMap<>();
+            logMap.put("log_id", UUID.randomUUID().toString().replace("-", ""));
+            logMap.put("log_type", "TZXSHTUP");
+            logMap.put("syn_type", "0");
+            logMap.put("data_name", salesOrderName);
+            logMap.put("data_id", salesOrderId);
+            logMap.put("mark", modifyTime);
+            logMap.put("send_body", JSON.toJSONString(reqEntity));
+            logMap.put("send_res", JSON.toJSONString(salesOrderResult));
+            logMap.put("tableName", "send_log_tzht");
+
+            //判断是否执行成功
+            if (salesOrderResult.getInteger("code") == 0) {
+                //同步成功
+                logMap.put("log_status", "0");
+                logMap.put("res_body", "同步成功");
+                backReqMap.put("ledger_sync_status__c", "option_sync_success__c");
+                backReqMap.put("ledger_response_status__c", salesOrderResult.getString("msg"));
+            } else {
+                //同步失败
+                logMap.put("log_status", "1");
+                logMap.put("res_body", "同步失败：" + salesOrderResult.getString("msg"));
+                backReqMap.put("ledger_sync_status__c", "option_sync_failure__c");
+                backReqMap.put("ledger_response_status__c", salesOrderResult.getString("msg"));
+            }
+
+            //开始回写
+            JSONObject unlockReq = crmRequestUtil.unlockCRM(salesOrderId, "SaleContractObj");
+            //解锁
+            if ("1".equals(salesOrderData.getString("lock_status"))) {
+                log.info("解锁");
+
+                JSONObject unlockRes = new JSONObject();
+
+                try {
+                    unlockRes = restTemplate.postForObject(URLConstant.UNLOCK_CRM_URL, unlockReq, JSONObject.class);
+                } catch (RestClientException e) {
+                    e.printStackTrace();
+                }
+                System.out.println("解锁" + unlockRes);
+            }
+
+            JSONObject backReq = crmRequestUtil.updateCRM(backReqMap);
+
+            JSONObject backRes = new JSONObject();
+
+            try {
+                backRes = restTemplate.postForObject(URLConstant.UPDATE_CRM_MAIN, backReq, JSONObject.class);
+            } catch (RestClientException e) {
+                e.printStackTrace();
+            }
+
+            System.out.println("回写结果为：" + backRes);
+
+            logMap.put("send_memo", JSON.toJSONString(backRes));
+
+            //开始记录日志
+            JSONObject logRes = new JSONObject();
+
+            try {
+                logRes = restTemplate.postForObject("http://localhost:18085/Log/insert/log_data", logMap, JSONObject.class);
+            } catch (RestClientException e) {
+                e.printStackTrace();
+            }
+
+            System.out.println("日志插入结果为：" + logRes);
+
+        }
+    }
+
 }