From 67efd8a4041cf8bbf7ace0893efc4370184ffbb5 Mon Sep 17 00:00:00 2001 From: itzhang <2019326567@qq.com> Date: Tue, 13 May 2025 17:29:30 +0800 Subject: [PATCH] =?UTF-8?q?=E9=94=80=E5=94=AE=E5=90=88=E5=90=8C=E7=9A=84?= =?UTF-8?q?=E9=83=A8=E5=88=86=E4=BF=AE=E6=94=B9=EF=BC=8C=E6=96=B0=E5=A2=9E?= =?UTF-8?q?=E8=AE=BE=E8=AE=A1=E6=96=87=E4=BB=B6=E9=9B=86=E6=88=90=E4=BB=A3?= =?UTF-8?q?=E7=A0=81=E3=80=81=E8=A6=81=E8=B4=A7=E8=AE=A1=E5=88=92=E9=9B=86?= =?UTF-8?q?=E6=88=90=E4=BB=A3=E7=A0=81?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../controller/DesignController.java | 575 ++++++++++++++++ .../controller/GoodsPlanController.java | 642 ++++++++++++++++++ .../magicboot/controller/XSHTController.java | 1 + 3 files changed, 1218 insertions(+) create mode 100644 magic-boot/src/main/java/org/ssssssss/magicboot/controller/DesignController.java create mode 100644 magic-boot/src/main/java/org/ssssssss/magicboot/controller/GoodsPlanController.java diff --git a/magic-boot/src/main/java/org/ssssssss/magicboot/controller/DesignController.java b/magic-boot/src/main/java/org/ssssssss/magicboot/controller/DesignController.java new file mode 100644 index 0000000..c914264 --- /dev/null +++ b/magic-boot/src/main/java/org/ssssssss/magicboot/controller/DesignController.java @@ -0,0 +1,575 @@ +package org.ssssssss.magicboot.controller; + +import com.alibaba.fastjson.JSON; +import com.alibaba.fastjson.JSONObject; +import lombok.extern.slf4j.Slf4j; +import org.springframework.http.HttpEntity; +import org.springframework.http.HttpHeaders; +import org.springframework.http.MediaType; +import org.springframework.web.bind.annotation.PostMapping; +import org.springframework.web.bind.annotation.RequestMapping; +import org.springframework.web.bind.annotation.RestController; +import org.springframework.web.client.RestClientException; +import org.springframework.web.client.RestTemplate; +import org.ssssssss.magicboot.constant.URLConstant; +import org.ssssssss.magicboot.entity.Filter; +import org.ssssssss.magicboot.utils.CrmRequestUtil; + +import java.util.*; + +/** + * 设计文件 + * + * @param + * @return null + * @Author weiloong_zhang + */ +@RestController +@RequestMapping("/api/design") +@Slf4j +public class DesignController { + + private RestTemplate restTemplate = new RestTemplate(); + + public static void main(String[] args) { + new DesignController().syncDesign(); + } + + /** + * 设计文件同步 + * + * @return void + * @Author weiloong_zhang + */ + @PostMapping("/sync/designDoc") + public void syncDesign() { + CrmRequestUtil crmRequestUtil = new CrmRequestUtil(); + log.info("开始同步设计文件"); + + JSONObject getDesignDoc = crmRequestUtil.getCRMList(Arrays.asList( + new Filter("EQ", "name", Arrays.asList("SJWJ250509-0003")) + ), "design_file__c"); + + JSONObject designDocRes = new JSONObject(); + + try { + designDocRes = restTemplate.postForObject(URLConstant.GET_CUSTOMIZE_LIST_URL, getDesignDoc, JSONObject.class); + } catch (RestClientException e) { + e.printStackTrace(); + } + + if (!"success".equals(designDocRes.getString("errorDescription")) || designDocRes.getJSONObject("data").getJSONArray("dataList").isEmpty()) { + log.info("查询失败或者不存在符合条件的数据"); + return; + } + + log.info("查询成功，继续向下执行"); + + for (Object designDocObj : designDocRes.getJSONObject("data").getJSONArray("dataList")) { + JSONObject designDocData = JSON.parseObject(JSON.toJSONString(designDocObj)); + + System.out.println("当前正在处理的设计文件数据为：" + designDocData); + + //当前设计文件的唯一id + String designDocId = designDocData.getString("_id"); + + //当前单据的编号 + String designDocName = designDocData.getString("name"); + + //当前单据的创建时间 + String createTime = designDocData.getString("create_time"); + + //开始查询该单据是否已经集成过 + JSONObject isLog = new JSONObject(); + + try { + isLog = restTemplate.getForObject("http://localhost:18088/Log/query/log_data?table=send_log_sjwj&log_type=DF&dataId=" + designDocId + "&mark=" + createTime, JSONObject.class); + } catch (RestClientException e) { + e.printStackTrace(); + } + + //判断是否已经执行过 + if (!isLog.getJSONArray("data").isEmpty()) { + log.info("当前单据已经集成过了，将不再向下执行"); + continue; + } + + log.info("当前单据没有集成过，将开始向下执行"); + + //开始封装传输至ERP中的请求 + Map erpDesignMap = new HashMap<>(); + erpDesignMap.put("billno", designDocName);//设计文件编号 + erpDesignMap.put("org_number", "zyierp");//组织编码 + erpDesignMap.put("billtype_number", "pm_requirapplybill_STD_BT_S");//单据类型 + erpDesignMap.put("biztype_name", "物料类采购");//业务类型 + + //开始获取单据日期 + long bizTime = designDocData.getLong("document_date__c"); + Date date = new Date(bizTime); + + erpDesignMap.put("biztime", date);//单据日期 + + //部门编码 + String deptCode = ""; + + List deptIdList = designDocData.getJSONArray("data_own_department"); + + //开始查询部门编码 + JSONObject deptReq = crmRequestUtil.getCRMList(Arrays.asList( + new Filter("EQ", "_id", deptIdList) + ), "DepartmentObj"); + + JSONObject deptRes = new JSONObject(); + + try { + deptRes = restTemplate.postForObject(URLConstant.GET_CRM_LIST_URL, deptReq, JSONObject.class); + } catch (RestClientException e) { + e.printStackTrace(); + } + + if ("success".equals(deptRes.getString("errorDescription")) && !deptRes.getJSONObject("data").getJSONArray("dataList").isEmpty()) { + JSONObject deptData = deptRes.getJSONObject("data").getJSONArray("dataList").getJSONObject(0); + deptCode = deptData.getString("field_Vj6sf__c") != null ? deptData.getString("field_Vj6sf__c") : ""; + } + + erpDesignMap.put("dept_number", "zyierp");//部门编码 + + //获取负责人编码 + String ownerCode = ""; + + List ownerIdList = designDocData.getJSONArray("owner"); + + JSONObject ownerReq = crmRequestUtil.getCRMList(Arrays.asList( + new Filter("EQ", "_id", ownerIdList) + ), "PersonnelObj"); + + JSONObject ownerRes = new JSONObject(); + + try { + ownerRes = restTemplate.postForObject(URLConstant.GET_CRM_LIST_URL, ownerReq, JSONObject.class); + } catch (RestClientException e) { + e.printStackTrace(); + } + + if ("success".equals(ownerRes.getString("errorDescription")) && !ownerRes.getJSONObject("data").getJSONArray("dataList").isEmpty()) { + JSONObject ownerData = ownerRes.getJSONObject("data").getJSONArray("dataList").getJSONObject(0); + ownerCode = ownerData.getString("field_T1xid__c") != null ? ownerData.getString("field_T1xid__c") : ""; + } + + erpDesignMap.put("bizuser_number", "ID-000011");//人员编码 + erpDesignMap.put("bizorg_number", "zyierp");//采购组织 + erpDesignMap.put("project_number", designDocData.getString("project_id__c"));//todo 项目号（商机） + erpDesignMap.put("contractno", designDocData.getString("sales_contract_number__c__r"));//合同号 + erpDesignMap.put("crmid", designDocId);//crm唯一id + erpDesignMap.put("comment", designDocData.getString("remark__c") != null ? designDocData.getString("remark__c") : "");//备注 + + + //开始获取设计文件明细 + JSONObject getDesignDocDetail = crmRequestUtil.getCRMList(Arrays.asList( + new Filter("EQ", "design_file__c", Arrays.asList(designDocId)) + ), "design_file_details__c"); + + JSONObject designDocDetailRes = new JSONObject(); + + try { + designDocDetailRes = restTemplate.postForObject(URLConstant.GET_CUSTOMIZE_LIST_URL, getDesignDocDetail, JSONObject.class); + } catch (RestClientException e) { + e.printStackTrace(); + } + + if (!"success".equals(designDocDetailRes.getString("errorDescription")) || designDocDetailRes.getJSONObject("data").getJSONArray("dataList").isEmpty()) { + log.info("查询失败或不存在当前设计文件明细"); + continue; + } + + List designDocList = new ArrayList<>(); + + for (Object designDocDetailObj : designDocDetailRes.getJSONObject("data").getJSONArray("dataList")) { + JSONObject designDocDetailData = JSON.parseObject(JSON.toJSONString(designDocDetailObj)); + + System.out.println("当前正在处理的设计文件明细数据为：" + designDocDetailData); + + //开始封装设计文件明细 + Map designDocDetailMap = new HashMap<>(); + designDocDetailMap.put("materialmasterid_number", designDocDetailData.getString("material_id__c__r"));//设计文件明细 + designDocDetailMap.put("qty", designDocDetailData.getBigDecimal("quantity__c") != null ? designDocDetailData.getBigDecimal("quantity__c") : 0);//数量 + designDocDetailMap.put("materialtype", designDocDetailData.getString("customer_material_type__c"));//客指供应类型 + designDocDetailMap.put("crmentryid", designDocDetailData.getString("_id"));//crm明细行id + designDocDetailMap.put("entrycomment", designDocDetailData.getString("remark__c") != null ? designDocDetailData.getString("remark__c") : "");//备注 + designDocDetailMap.put("supplier_number", "G08000001");//todo 建议供应商 + + designDocList.add(designDocDetailMap); + + } + + erpDesignMap.put("billentry", designDocList); + + Map erpContractData = new HashMap<>(); + erpContractData.put("data", Arrays.asList(erpDesignMap));//请求体 + + System.out.println("erp请求为：" + JSON.parseObject(JSON.toJSONString(erpContractData))); + + String accessToken = new KDTokenController().getKDAccessTokenTest(); + + if (accessToken == null || accessToken.equals("")) { + log.info("金蝶token为空或不存在"); + return; + } + String uuid = UUID.randomUUID().toString().replace("-", ""); + //开始封装请求头 + HttpHeaders headers = new HttpHeaders(); + headers.setContentType(MediaType.APPLICATION_JSON); + headers.set("accessToken", accessToken); + headers.set("Idempotency-Key", uuid); + + HttpEntity designDocReqEntity = new HttpEntity(erpContractData, headers); + + System.out.println("请求为：" + JSON.parseObject(JSON.toJSONString(designDocReqEntity))); + + //开始向金蝶发起请求 + String designPlanUrl = "http://192.168.31.233:8022/ierp/kapi/v2/f9w5/pssc/pm_requirapplybill/requirapplybillSave"; + + JSONObject erpDesignDocRes = new JSONObject(); + + try { + erpDesignDocRes = restTemplate.postForObject(designPlanUrl, designDocReqEntity, JSONObject.class); + } catch (RestClientException e) { + e.printStackTrace(); + } + + System.out.println("设计文件结果为：" + JSON.parseObject(JSON.toJSONString(erpDesignDocRes))); + + //开始封装回写程序 + Map backReqMap = new HashMap(); + backReqMap.put("_id", designDocId); + backReqMap.put("dataObjectApiName", "design_file__c"); + + //开始封装日志 + Map logMap = new HashMap<>(); + logMap.put("log_id", UUID.randomUUID().toString().replace("-", "")); + logMap.put("log_type", "DF"); + logMap.put("syn_type", "0"); + logMap.put("data_name", designDocName); + logMap.put("data_id", designDocId); + logMap.put("mark", createTime); + logMap.put("send_body", JSON.toJSONString(designDocReqEntity)); + logMap.put("send_res", JSON.toJSONString(erpDesignDocRes)); + logMap.put("tableName", "send_log_sjwj"); + + //判断是否执行成功 + if ("0".equals(erpDesignDocRes.getString("errorCode"))) { + //同步成功 + logMap.put("log_status", "0"); + logMap.put("res_body", "同步成功"); + backReqMap.put("erp_id__c", erpDesignDocRes.getJSONObject("data").getJSONArray("result").getJSONObject(0).getString("id")); + backReqMap.put("sync_status__c", "option_sync_success__c"); + backReqMap.put("response_info__c", "同步成功"); + } else { + //同步失败 + logMap.put("log_status", "1"); + logMap.put("res_body", "同步失败：" + erpDesignDocRes.getString("message")); + backReqMap.put("sync_status__c", "option_sync_failure__c"); + backReqMap.put("response_info__c", erpDesignDocRes.getString("message")); + } + + //开始回写 + JSONObject backReq = crmRequestUtil.updateCRM(backReqMap); + + System.out.println("回写请求为：" + JSON.parseObject(JSON.toJSONString(backReq))); + + JSONObject backRes = new JSONObject(); + + try { + backRes = restTemplate.postForObject(URLConstant.UPDATE_CRM_CUSTOMIZE, backReq, JSONObject.class); + } catch (RestClientException e) { + e.printStackTrace(); + } + + System.out.println("回写结果为：" + backRes); + + //开始记录日志 + JSONObject logResMap = new JSONObject(); + try { + logResMap = restTemplate.postForObject("http://localhost:18088/Log/insert/log_data", logMap, JSONObject.class); + } catch (RestClientException e) { + e.printStackTrace(); + } + + System.out.println("日志插入结果为：" + logResMap); + + } + } + + + /** + * 设计文件更新接口 + * @return void + * @Author weiloong_zhang + */ + @PostMapping("/syncUp/designDoc") + public void upDesignDoc() { + CrmRequestUtil crmRequestUtil = new CrmRequestUtil(); + log.info("开始同步设计文件"); + + JSONObject getDesignDoc = crmRequestUtil.getCRMList(Arrays.asList( + new Filter("EQ", "name", Arrays.asList("SJWJ250509-0003")) + ), "design_file__c"); + + JSONObject designDocRes = new JSONObject(); + + try { + designDocRes = restTemplate.postForObject(URLConstant.GET_CUSTOMIZE_LIST_URL, getDesignDoc, JSONObject.class); + } catch (RestClientException e) { + e.printStackTrace(); + } + + if (!"success".equals(designDocRes.getString("errorDescription")) || designDocRes.getJSONObject("data").getJSONArray("dataList").isEmpty()) { + log.info("查询失败或者不存在符合条件的数据"); + return; + } + + log.info("查询成功，继续向下执行"); + + for (Object designDocObj : designDocRes.getJSONObject("data").getJSONArray("dataList")) { + JSONObject designDocData = JSON.parseObject(JSON.toJSONString(designDocObj)); + + System.out.println("当前正在处理的设计文件数据为：" + designDocData); + + //当前设计文件的唯一id + String designDocId = designDocData.getString("_id"); + + //当前单据的编号 + String designDocName = designDocData.getString("name"); + + //当前单据的创建时间 + String createTime = designDocData.getString("create_time"); + + //开始查询该单据是否已经集成过 + JSONObject isLog = new JSONObject(); + + try { + isLog = restTemplate.getForObject("http://localhost:18088/Log/query/log_data?table=send_log_sjwj&log_type=DFUP&dataId=" + designDocId + "&mark=" + createTime, JSONObject.class); + } catch (RestClientException e) { + e.printStackTrace(); + } + + //判断是否已经执行过 + if (!isLog.getJSONArray("data").isEmpty()) { + log.info("当前单据已经集成过了，将不再向下执行"); + continue; + } + + log.info("当前单据没有集成过，将开始向下执行"); + + //开始封装传输至ERP中的请求 + String erpId = designDocData.getString("erp_id__c") != null ? designDocData.getString("erp_id__c") : ""; + + if ("".equals(erpId)) { + log.info("当前单据erp_id__c为空，不再向下执行"); + continue; + } + + Map erpDesignMap = new HashMap<>(); + erpDesignMap.put("id", erpId);//erpId + erpDesignMap.put("billno", designDocName);//设计文件编号 + erpDesignMap.put("org_number", "zyierp");//组织编码 + erpDesignMap.put("billtype_number", "pm_requirapplybill_STD_BT_S");//单据类型 + erpDesignMap.put("biztype_name", "物料类采购");//业务类型 + + //开始获取单据日期 + long bizTime = designDocData.getLong("document_date__c"); + Date date = new Date(bizTime); + + erpDesignMap.put("biztime", date);//单据日期 + + //部门编码 + String deptCode = ""; + + List deptIdList = designDocData.getJSONArray("data_own_department"); + + //开始查询部门编码 + JSONObject deptReq = crmRequestUtil.getCRMList(Arrays.asList( + new Filter("EQ", "_id", deptIdList) + ), "DepartmentObj"); + + JSONObject deptRes = new JSONObject(); + + try { + deptRes = restTemplate.postForObject(URLConstant.GET_CRM_LIST_URL, deptReq, JSONObject.class); + } catch (RestClientException e) { + e.printStackTrace(); + } + + if ("success".equals(deptRes.getString("errorDescription")) && !deptRes.getJSONObject("data").getJSONArray("dataList").isEmpty()) { + JSONObject deptData = deptRes.getJSONObject("data").getJSONArray("dataList").getJSONObject(0); + deptCode = deptData.getString("field_Vj6sf__c") != null ? deptData.getString("field_Vj6sf__c") : ""; + } + + erpDesignMap.put("dept_number", "zyierp");//部门编码 + + //获取负责人编码 + String ownerCode = ""; + + List ownerIdList = designDocData.getJSONArray("owner"); + + JSONObject ownerReq = crmRequestUtil.getCRMList(Arrays.asList( + new Filter("EQ", "_id", ownerIdList) + ), "PersonnelObj"); + + JSONObject ownerRes = new JSONObject(); + + try { + ownerRes = restTemplate.postForObject(URLConstant.GET_CRM_LIST_URL, ownerReq, JSONObject.class); + } catch (RestClientException e) { + e.printStackTrace(); + } + + if ("success".equals(ownerRes.getString("errorDescription")) && !ownerRes.getJSONObject("data").getJSONArray("dataList").isEmpty()) { + JSONObject ownerData = ownerRes.getJSONObject("data").getJSONArray("dataList").getJSONObject(0); + ownerCode = ownerData.getString("field_T1xid__c") != null ? ownerData.getString("field_T1xid__c") : ""; + } + + erpDesignMap.put("bizuser_number", "ID-000011");//人员编码 + erpDesignMap.put("bizorg_number", "zyierp");//采购组织 + erpDesignMap.put("project_number", designDocData.getString("project_id__c"));//todo 项目号（商机） + erpDesignMap.put("contractno", designDocData.getString("sales_contract_number__c__r"));//合同号 + erpDesignMap.put("crmid", designDocId);//crm唯一id + erpDesignMap.put("comment", designDocData.getString("remark__c") != null ? designDocData.getString("remark__c") : "");//备注 + + + //开始获取设计文件明细 + JSONObject getDesignDocDetail = crmRequestUtil.getCRMList(Arrays.asList( + new Filter("EQ", "design_file__c", Arrays.asList(designDocId)) + ), "design_file_details__c"); + + JSONObject designDocDetailRes = new JSONObject(); + + try { + designDocDetailRes = restTemplate.postForObject(URLConstant.GET_CUSTOMIZE_LIST_URL, getDesignDocDetail, JSONObject.class); + } catch (RestClientException e) { + e.printStackTrace(); + } + + if (!"success".equals(designDocDetailRes.getString("errorDescription")) || designDocDetailRes.getJSONObject("data").getJSONArray("dataList").isEmpty()) { + log.info("查询失败或不存在当前设计文件明细"); + continue; + } + + List designDocList = new ArrayList<>(); + + for (Object designDocDetailObj : designDocDetailRes.getJSONObject("data").getJSONArray("dataList")) { + JSONObject designDocDetailData = JSON.parseObject(JSON.toJSONString(designDocDetailObj)); + + System.out.println("当前正在处理的设计文件明细数据为：" + designDocDetailData); + + //开始封装设计文件明细 + Map designDocDetailMap = new HashMap<>(); + designDocDetailMap.put("materialmasterid_number", designDocDetailData.getString("material_id__c__r"));//设计文件明细 + designDocDetailMap.put("qty", designDocDetailData.getBigDecimal("quantity__c") != null ? designDocDetailData.getBigDecimal("quantity__c") : 0);//数量 + designDocDetailMap.put("materialtype", designDocDetailData.getString("customer_material_type__c"));//客指供应类型 + designDocDetailMap.put("crmentryid", designDocDetailData.getString("_id"));//crm明细行id + designDocDetailMap.put("entrycomment", designDocDetailData.getString("remark__c") != null ? designDocDetailData.getString("remark__c") : "");//备注 + designDocDetailMap.put("supplier_number", "G08000001");//todo 建议供应商 + + designDocList.add(designDocDetailMap); + + } + + erpDesignMap.put("billentry", designDocList); + + Map erpContractData = new HashMap<>(); + erpContractData.put("data", Arrays.asList(erpDesignMap));//请求体 + + System.out.println("erp请求为：" + JSON.parseObject(JSON.toJSONString(erpContractData))); + + String accessToken = new KDTokenController().getKDAccessTokenTest(); + + if (accessToken == null || accessToken.equals("")) { + log.info("金蝶token为空或不存在"); + return; + } + String uuid = UUID.randomUUID().toString().replace("-", ""); + //开始封装请求头 + HttpHeaders headers = new HttpHeaders(); + headers.setContentType(MediaType.APPLICATION_JSON); + headers.set("accessToken", accessToken); + headers.set("Idempotency-Key", uuid); + + HttpEntity designDocReqEntity = new HttpEntity(erpContractData, headers); + + System.out.println("请求为：" + JSON.parseObject(JSON.toJSONString(designDocReqEntity))); + + //开始向金蝶发起请求 + String designPlanUrl = "http://192.168.31.233:8022/ierp/kapi/v2/f9w5/pssc/pm_requirapplybill/requirapplybillSave"; + + JSONObject erpDesignDocRes = new JSONObject(); + + try { + erpDesignDocRes = restTemplate.postForObject(designPlanUrl, designDocReqEntity, JSONObject.class); + } catch (RestClientException e) { + e.printStackTrace(); + } + + System.out.println("设计文件结果为：" + JSON.parseObject(JSON.toJSONString(erpDesignDocRes))); + + //开始封装回写程序 + Map backReqMap = new HashMap(); + backReqMap.put("_id", designDocId); + backReqMap.put("dataObjectApiName", "design_file__c"); + + //开始封装日志 + Map logMap = new HashMap<>(); + logMap.put("log_id", UUID.randomUUID().toString().replace("-", "")); + logMap.put("log_type", "DFUP"); + logMap.put("syn_type", "0"); + logMap.put("data_name", designDocName); + logMap.put("data_id", designDocId); + logMap.put("mark", createTime); + logMap.put("send_body", JSON.toJSONString(designDocReqEntity)); + logMap.put("send_res", JSON.toJSONString(erpDesignDocRes)); + logMap.put("tableName", "send_log_sjwj"); + + //判断是否执行成功 + if ("0".equals(erpDesignDocRes.getString("errorCode"))) { + //同步成功 + logMap.put("log_status", "0"); + logMap.put("res_body", "同步成功"); + backReqMap.put("erp_id__c", erpDesignDocRes.getJSONObject("data").getJSONArray("result").getJSONObject(0).getString("id")); + backReqMap.put("sync_status__c", "option_sync_success__c"); + backReqMap.put("response_info__c", "同步成功"); + } else { + //同步失败 + logMap.put("log_status", "1"); + logMap.put("res_body", "同步失败：" + erpDesignDocRes.getString("message")); + backReqMap.put("sync_status__c", "option_sync_failure__c"); + backReqMap.put("response_info__c", erpDesignDocRes.getString("message")); + } + + //开始回写 + JSONObject backReq = crmRequestUtil.updateCRM(backReqMap); + + System.out.println("回写请求为：" + JSON.parseObject(JSON.toJSONString(backReq))); + + JSONObject backRes = new JSONObject(); + + try { + backRes = restTemplate.postForObject(URLConstant.UPDATE_CRM_CUSTOMIZE, backReq, JSONObject.class); + } catch (RestClientException e) { + e.printStackTrace(); + } + + System.out.println("回写结果为：" + backRes); + + //开始记录日志 + JSONObject logResMap = new JSONObject(); + try { + logResMap = restTemplate.postForObject("http://localhost:18088/Log/insert/log_data", logMap, JSONObject.class); + } catch (RestClientException e) { + e.printStackTrace(); + } + + System.out.println("日志插入结果为：" + logResMap); + + } + } +} diff --git a/magic-boot/src/main/java/org/ssssssss/magicboot/controller/GoodsPlanController.java b/magic-boot/src/main/java/org/ssssssss/magicboot/controller/GoodsPlanController.java new file mode 100644 index 0000000..a2fb2c3 --- /dev/null +++ b/magic-boot/src/main/java/org/ssssssss/magicboot/controller/GoodsPlanController.java @@ -0,0 +1,642 @@ +package org.ssssssss.magicboot.controller; + +import com.alibaba.fastjson.JSON; +import com.alibaba.fastjson.JSONObject; +import lombok.extern.slf4j.Slf4j; +import org.springframework.http.HttpEntity; +import org.springframework.http.HttpHeaders; +import org.springframework.http.MediaType; +import org.springframework.web.bind.annotation.PostMapping; +import org.springframework.web.bind.annotation.RequestMapping; +import org.springframework.web.bind.annotation.RestController; +import org.springframework.web.client.RestClientException; +import org.springframework.web.client.RestTemplate; +import org.ssssssss.magicboot.constant.URLConstant; +import org.ssssssss.magicboot.entity.Filter; +import org.ssssssss.magicboot.utils.CrmRequestUtil; + +import java.util.*; + +/** + * 要货计划 + * + * @param + * @return null + * @Author weiloong_zhang + */ +@RestController +@RequestMapping("/api/goods_plan") +@Slf4j +public class GoodsPlanController { + + private RestTemplate restTemplate = new RestTemplate(); + + public static void main(String[] args) { + //new GoodsPlanController().syncGoodsPlan(); + new GoodsPlanController().updateGoodsPlan(); + } + + /** + * 同步新增要货计划 + * + * @return void + * @Author weiloong_zhang + */ + @PostMapping("/sync/goodsPlan") + public void syncGoodsPlan() { + CrmRequestUtil crmRequestUtil = new CrmRequestUtil(); + log.info("开始同步要货计划"); + + //要货计划请求 + JSONObject getGoodsPlan = crmRequestUtil.getCRMList(Arrays.asList( + new Filter("EQ", "name", Arrays.asList("YHJH20250508-0002")), + new Filter("EQ", "life_status", Arrays.asList("normal")) + ), "purchase_plan__c"); + + JSONObject goodsPlanRes = new JSONObject(); + + //开始发起请求 + try { + goodsPlanRes = restTemplate.postForObject(URLConstant.GET_CUSTOMIZE_LIST_URL, getGoodsPlan, JSONObject.class); + } catch (RestClientException e) { + e.printStackTrace(); + } + + //判断是否请求成功 + if (!"success".equals(goodsPlanRes.getString("errorDescription")) || goodsPlanRes.getJSONObject("data").getJSONArray("dataList").isEmpty()) { + log.info("请求失败或数据不存在"); + return; + } + + //请求成功 + for (Object goodsPlanObj : goodsPlanRes.getJSONObject("data").getJSONArray("dataList")) { + //将Obj转为JSONObject + JSONObject goodsPlanData = JSON.parseObject(JSON.toJSONString(goodsPlanObj)); + + System.out.println("当前正在处理的要货计划数据为：" + goodsPlanData); + + //获取当前单据的唯一id + String goodsPlanId = goodsPlanData.getString("_id"); + + //获取当前单据名称 + String goodsPlanName = goodsPlanData.getString("name"); + + //获取当前单据的创建时间 + String createTime = goodsPlanData.getString("create_time"); + + //开始查询该单据是否已经集成过 + JSONObject logRes = new JSONObject(); + + try { + logRes = restTemplate.getForObject("http://localhost:18088/Log/query/log_data?table=send_log_goodsplan&log_type=GP&dataId=" + goodsPlanId + "&mark=" + createTime, JSONObject.class); + } catch (RestClientException e) { + e.printStackTrace(); + } + + if (!logRes.getJSONArray("data").isEmpty()) { + log.info("当前单据已经集成过了"); + continue; + } + + log.info("当前单据没有集成过"); + + //开始封装传输至ERP的请求 + log.info("开始封装请求"); + + Map erpGoodsPlanReq = new HashMap<>(); + erpGoodsPlanReq.put("f9w5_crmid", goodsPlanId); + erpGoodsPlanReq.put("billno", goodsPlanName);//单据编号 + erpGoodsPlanReq.put("billtype_number", "f9w5_sm_purchaseplan_BT");//单据类型 + erpGoodsPlanReq.put("org_number", "zyierp");//组织编码 + + //开始获取需求日期 + long biztime = goodsPlanData.getLong("requirement_date__c"); + + Date date = new Date(biztime); + erpGoodsPlanReq.put("biztime", date);//需求日期 + + //部门编码 + String deptCode = ""; + + List deptIdList = goodsPlanData.getJSONArray("data_own_department"); + + //开始查询部门编码 + JSONObject deptReq = crmRequestUtil.getCRMList(Arrays.asList( + new Filter("EQ", "_id", deptIdList) + ), "DepartmentObj"); + + JSONObject deptRes = new JSONObject(); + + try { + deptRes = restTemplate.postForObject(URLConstant.GET_CRM_LIST_URL, deptReq, JSONObject.class); + } catch (RestClientException e) { + e.printStackTrace(); + } + + if ("success".equals(deptRes.getString("errorDescription")) && !deptRes.getJSONObject("data").getJSONArray("dataList").isEmpty()) { + JSONObject deptData = deptRes.getJSONObject("data").getJSONArray("dataList").getJSONObject(0); + deptCode = deptData.getString("field_Vj6sf__c") != null ? deptData.getString("field_Vj6sf__c") : ""; + } + + erpGoodsPlanReq.put("dept", "zyierp");//todo 归属部门 + + //获取负责人编码 + String ownerCode = ""; + + List ownerIdList = goodsPlanData.getJSONArray("owner"); + + JSONObject ownerReq = crmRequestUtil.getCRMList(Arrays.asList( + new Filter("EQ", "_id", ownerIdList) + ), "PersonnelObj"); + + JSONObject ownerRes = new JSONObject(); + + try { + ownerRes = restTemplate.postForObject(URLConstant.GET_CRM_LIST_URL, ownerReq, JSONObject.class); + } catch (RestClientException e) { + e.printStackTrace(); + } + + if ("success".equals(ownerRes.getString("errorDescription")) && !ownerRes.getJSONObject("data").getJSONArray("dataList").isEmpty()) { + JSONObject ownerData = ownerRes.getJSONObject("data").getJSONArray("dataList").getJSONObject(0); + ownerCode = ownerData.getString("field_T1xid__c") != null ? ownerData.getString("field_T1xid__c") : ""; + } + + erpGoodsPlanReq.put("operator", "ID-000011");//todo 负责人 + + //根据要货计划查询要货计划明细 + JSONObject getGoodsPlanDetail = crmRequestUtil.getCRMList(Arrays.asList( + new Filter("EQ", "purchase_plan__c", Arrays.asList(goodsPlanId)) + ), "purchase_plan_details__c"); + + JSONObject goodsPlanDetailRes = new JSONObject(); + + try { + goodsPlanDetailRes = restTemplate.postForObject(URLConstant.GET_CUSTOMIZE_LIST_URL, getGoodsPlanDetail, JSONObject.class); + } catch (RestClientException e) { + e.printStackTrace(); + } + + System.out.println("要货计划明细查询结果为：" + goodsPlanDetailRes); + + if (!"success".equals(goodsPlanDetailRes.getString("errorDescription")) || goodsPlanDetailRes.getJSONObject("data").getJSONArray("dataList").isEmpty()) { + log.info("要货计划明细查询失败不存在当前要货计划明细"); + continue; + } + + log.info("要货计划明细存在，继续向下执行"); + + //明细列表 + List goodsPlanDetailList = new ArrayList<>(); + + for (Object goodsPlanDetailObj : goodsPlanDetailRes.getJSONObject("data").getJSONArray("dataList")) { + JSONObject goodsPlanDetailData = JSON.parseObject(JSON.toJSONString(goodsPlanDetailObj)); + + System.out.println("当前正在处理的要货计划明细数据为：" + goodsPlanDetailData); + + //开始封装要货计划明细数据 + Map erpGoodsPlanDetailReq = new HashMap<>(); + erpGoodsPlanDetailReq.put("f9w5_crmentryid", goodsPlanDetailData.getString("_id"));//crm明细id + erpGoodsPlanDetailReq.put("material_number", goodsPlanDetailData.getString("material_id__c__r"));//物料编号 + erpGoodsPlanDetailReq.put("entryorg_number", "zyierp");//组织编码 + erpGoodsPlanDetailReq.put("qty", goodsPlanDetailData.getBigDecimal("quantity__c") != null ? goodsPlanDetailData.getBigDecimal("quantity__c") : 0);//数量 + //erpGoodsPlanDetailReq.put("lot_number", goodsPlanDetailData.getString("batch_number__c") != null ? goodsPlanDetailData.getString("batch_number__c") : "");//批号 + erpGoodsPlanDetailReq.put("entrycomment", goodsPlanDetailData.getString("remark__c") != null ? goodsPlanDetailData.getString("remark__c") : "");//备注 + erpGoodsPlanDetailReq.put("f9w5_contractno", goodsPlanDetailData.getString("sales_contract_number__c__r") != null ? goodsPlanDetailData.getString("sales_contract_number__c__r") : "");//销售合同编号 + + //开始查询项目号 + String projectId = goodsPlanDetailData.getString("project_name__c") != null ? goodsPlanDetailData.getString("project_name__c") : ""; + + //开始查询项目号 + JSONObject getProjectReq = crmRequestUtil.getCRMList(Arrays.asList( + new Filter("EQ", "_id", Arrays.asList(projectId)) + ), "NewOpportunityObj"); + + JSONObject projectRes = new JSONObject(); + + try { + projectRes = restTemplate.postForObject(URLConstant.GET_CUSTOMIZE_LIST_URL, getProjectReq, JSONObject.class); + } catch (RestClientException e) { + e.printStackTrace(); + } + + String projectCode = ""; + + if ("success".equals(projectRes.getString("errorDescription")) && !projectRes.getJSONObject("data").getJSONArray("dataList").isEmpty()) { + JSONObject projectData = projectRes.getJSONObject("data").getJSONArray("dataList").getJSONObject(0); + projectCode = projectData.getString("opportunity_id__c") != null ? projectData.getString("opportunity_id__c") : ""; + } + + erpGoodsPlanDetailReq.put("f9w5_project_number", projectCode);//项目号 + + goodsPlanDetailList.add(erpGoodsPlanDetailReq); + + } + + erpGoodsPlanReq.put("billentry", goodsPlanDetailList); + + //开始封装要货计划请求 + System.out.println("erp请求为：" + JSON.parseObject(JSON.toJSONString(erpGoodsPlanReq))); + + Map erpContractData = new HashMap<>(); + erpContractData.put("data", Arrays.asList(erpGoodsPlanReq));//请求体 + + String accessToken = new KDTokenController().getKDAccessTokenTest(); + + if (accessToken == null || accessToken.equals("")) { + log.info("金蝶token为空或不存在"); + return; + } + String uuid = UUID.randomUUID().toString().replace("-", ""); + //开始封装请求头 + HttpHeaders headers = new HttpHeaders(); + headers.setContentType(MediaType.APPLICATION_JSON); + headers.set("accessToken", accessToken); + headers.set("Idempotency-Key", uuid); + + HttpEntity goodsPlanReqEntity = new HttpEntity(erpContractData, headers); + + System.out.println(JSON.parseObject(JSON.toJSONString(goodsPlanReqEntity))); + + //开始向金蝶发起请求 + String goodsPlanUrl = "http://192.168.31.233:8022/ierp/kapi/v2/f9w5/sm/f9w5_sm_purchaseplan/purchaseplanSave"; + + JSONObject erpGoodsPlanRes = new JSONObject(); + + try { + erpGoodsPlanRes = restTemplate.postForObject(goodsPlanUrl, goodsPlanReqEntity, JSONObject.class); + } catch (RestClientException e) { + e.printStackTrace(); + } + + System.out.println("要货计划结果为：" + JSON.parseObject(JSON.toJSONString(erpGoodsPlanRes))); + + //开始封装回写程序 + Map backReqMap = new HashMap(); + backReqMap.put("_id", goodsPlanId); + backReqMap.put("dataObjectApiName", "purchase_plan__c"); + + //开始封装日志 + Map logMap = new HashMap<>(); + logMap.put("log_id", UUID.randomUUID().toString().replace("-", "")); + logMap.put("log_type", "GP"); + logMap.put("syn_type", "0"); + logMap.put("data_name", goodsPlanName); + logMap.put("data_id", goodsPlanId); + logMap.put("mark", createTime); + logMap.put("send_body", JSON.toJSONString(goodsPlanReqEntity)); + logMap.put("send_res", JSON.toJSONString(erpGoodsPlanRes)); + logMap.put("tableName", "send_log_goodsplan"); + + //判断是否执行成功 + if ("0".equals(erpGoodsPlanRes.getString("errorCode"))) { + //同步成功 + logMap.put("log_status", "0"); + logMap.put("res_body", "同步成功"); + backReqMap.put("erp_id__c", erpGoodsPlanRes.getJSONObject("data").getJSONArray("result").getJSONObject(0).getString("id")); + backReqMap.put("sync_status__c", "option_sync_success__c"); + backReqMap.put("response_info__c", "同步成功"); + } else { + //同步失败 + logMap.put("log_status", "1"); + logMap.put("res_body", "同步失败：" + erpGoodsPlanRes.getString("message")); + backReqMap.put("sync_status__c", "option_sync_failure__c"); + backReqMap.put("response_info__c", erpGoodsPlanRes.getString("message")); + } + + //开始回写 + JSONObject backReq = crmRequestUtil.updateCRM(backReqMap); + + System.out.println("回写请求为：" + JSON.parseObject(JSON.toJSONString(backReq))); + + JSONObject backRes = new JSONObject(); + + try { + backRes = restTemplate.postForObject(URLConstant.UPDATE_CRM_CUSTOMIZE, backReq, JSONObject.class); + } catch (RestClientException e) { + e.printStackTrace(); + } + + System.out.println("回写结果为：" + backRes); + + //开始记录日志 + JSONObject logResMap = new JSONObject(); + try { + logResMap = restTemplate.postForObject("http://localhost:18088/Log/insert/log_data", logMap, JSONObject.class); + } catch (RestClientException e) { + e.printStackTrace(); + } + + System.out.println("日志插入结果为：" + logResMap); + + + } + + } + + /** + * 要货计划更新接口 + * + * @return void + * @Author weiloong_zhang + */ + @PostMapping("/update/goodsPlan") + public void updateGoodsPlan() { + CrmRequestUtil crmRequestUtil = new CrmRequestUtil(); + log.info("开始同步更新要货计划"); + + //要货计划请求 + JSONObject getGoodsPlan = crmRequestUtil.getCRMList(Arrays.asList( + new Filter("EQ", "name", Arrays.asList("YHJH20250508-0002")), + new Filter("EQ", "life_status", Arrays.asList("normal")) + ), "purchase_plan__c"); + + JSONObject goodsPlanRes = new JSONObject(); + + //开始发起请求 + try { + goodsPlanRes = restTemplate.postForObject(URLConstant.GET_CUSTOMIZE_LIST_URL, getGoodsPlan, JSONObject.class); + } catch (RestClientException e) { + e.printStackTrace(); + } + + //判断是否请求成功 + if (!"success".equals(goodsPlanRes.getString("errorDescription")) || goodsPlanRes.getJSONObject("data").getJSONArray("dataList").isEmpty()) { + log.info("请求失败或数据不存在"); + return; + } + + //请求成功 + for (Object goodsPlanObj : goodsPlanRes.getJSONObject("data").getJSONArray("dataList")) { + //将Obj转为JSONObject + JSONObject goodsPlanData = JSON.parseObject(JSON.toJSONString(goodsPlanObj)); + + System.out.println("当前正在处理的要货计划数据为：" + goodsPlanData); + + //获取当前单据的唯一id + String goodsPlanId = goodsPlanData.getString("_id"); + + //获取当前单据名称 + String goodsPlanName = goodsPlanData.getString("name"); + + //获取当前单据的最后修改时间 + String lastModifyTime = goodsPlanData.getString("last_modified_time"); + + //开始查询该单据是否已经集成过 + JSONObject logRes = new JSONObject(); + + try { + logRes = restTemplate.getForObject("http://localhost:18088/Log/query/log_data?table=send_log_goodsplan&log_type=GPUP&dataId=" + goodsPlanId + "&mark=" + lastModifyTime, JSONObject.class); + } catch (RestClientException e) { + e.printStackTrace(); + } + + if (!logRes.getJSONArray("data").isEmpty()) { + log.info("当前单据已经更新过了"); + continue; + } + + log.info("当前单据没有集成过"); + + //开始封装传输至ERP的请求 + log.info("开始封装请求"); + + //获取ERPID + String erpId = goodsPlanData.getString("erp_id__c") != null ? goodsPlanData.getString("erp_id__c") : ""; + + if ("".equals(erpId)) { + log.info("当前单据erp_id__c为空，不再向下执行"); + continue; + } + + log.info("存在ERPID，继续向下执行！"); + + Map erpGoodsPlanReq = new HashMap<>(); + erpGoodsPlanReq.put("id", erpId); + erpGoodsPlanReq.put("f9w5_crmid", goodsPlanId); + erpGoodsPlanReq.put("billno", goodsPlanName);//单据编号 + erpGoodsPlanReq.put("billtype_number", "f9w5_sm_purchaseplan_BT");//单据类型 + erpGoodsPlanReq.put("org_number", "zyierp");//组织编码 + + //开始获取需求日期 + long biztime = goodsPlanData.getLong("requirement_date__c"); + + Date date = new Date(biztime); + erpGoodsPlanReq.put("biztime", date);//需求日期 + + //部门编码 + String deptCode = ""; + + List deptIdList = goodsPlanData.getJSONArray("data_own_department"); + + //开始查询部门编码 + JSONObject deptReq = crmRequestUtil.getCRMList(Arrays.asList( + new Filter("EQ", "_id", deptIdList) + ), "DepartmentObj"); + + JSONObject deptRes = new JSONObject(); + + try { + deptRes = restTemplate.postForObject(URLConstant.GET_CRM_LIST_URL, deptReq, JSONObject.class); + } catch (RestClientException e) { + e.printStackTrace(); + } + + if ("success".equals(deptRes.getString("errorDescription")) && !deptRes.getJSONObject("data").getJSONArray("dataList").isEmpty()) { + JSONObject deptData = deptRes.getJSONObject("data").getJSONArray("dataList").getJSONObject(0); + deptCode = deptData.getString("field_Vj6sf__c") != null ? deptData.getString("field_Vj6sf__c") : ""; + } + + erpGoodsPlanReq.put("dept", "zyierp");//todo 归属部门 + + //获取负责人编码 + String ownerCode = ""; + + List ownerIdList = goodsPlanData.getJSONArray("owner"); + + JSONObject ownerReq = crmRequestUtil.getCRMList(Arrays.asList( + new Filter("EQ", "_id", ownerIdList) + ), "PersonnelObj"); + + JSONObject ownerRes = new JSONObject(); + + try { + ownerRes = restTemplate.postForObject(URLConstant.GET_CRM_LIST_URL, ownerReq, JSONObject.class); + } catch (RestClientException e) { + e.printStackTrace(); + } + + if ("success".equals(ownerRes.getString("errorDescription")) && !ownerRes.getJSONObject("data").getJSONArray("dataList").isEmpty()) { + JSONObject ownerData = ownerRes.getJSONObject("data").getJSONArray("dataList").getJSONObject(0); + ownerCode = ownerData.getString("field_T1xid__c") != null ? ownerData.getString("field_T1xid__c") : ""; + } + + erpGoodsPlanReq.put("operator", "ID-000011");//todo 负责人 + + //根据要货计划查询要货计划明细 + JSONObject getGoodsPlanDetail = crmRequestUtil.getCRMList(Arrays.asList( + new Filter("EQ", "purchase_plan__c", Arrays.asList(goodsPlanId)) + ), "purchase_plan_details__c"); + + JSONObject goodsPlanDetailRes = new JSONObject(); + + try { + goodsPlanDetailRes = restTemplate.postForObject(URLConstant.GET_CUSTOMIZE_LIST_URL, getGoodsPlanDetail, JSONObject.class); + } catch (RestClientException e) { + e.printStackTrace(); + } + + System.out.println("要货计划明细查询结果为：" + goodsPlanDetailRes); + + if (!"success".equals(goodsPlanDetailRes.getString("errorDescription")) || goodsPlanDetailRes.getJSONObject("data").getJSONArray("dataList").isEmpty()) { + log.info("要货计划明细查询失败不存在当前要货计划明细"); + continue; + } + + log.info("要货计划明细存在，继续向下执行"); + + //明细列表 + List goodsPlanDetailList = new ArrayList<>(); + + for (Object goodsPlanDetailObj : goodsPlanDetailRes.getJSONObject("data").getJSONArray("dataList")) { + JSONObject goodsPlanDetailData = JSON.parseObject(JSON.toJSONString(goodsPlanDetailObj)); + + System.out.println("当前正在处理的要货计划明细数据为：" + goodsPlanDetailData); + + //开始封装要货计划明细数据 + Map erpGoodsPlanDetailReq = new HashMap<>(); + erpGoodsPlanDetailReq.put("f9w5_crmentryid", goodsPlanDetailData.getString("_id"));//crm明细id + erpGoodsPlanDetailReq.put("material_number", goodsPlanDetailData.getString("material_id__c__r"));//物料编号 + erpGoodsPlanDetailReq.put("entryorg_number", "zyierp");//组织编码 + erpGoodsPlanDetailReq.put("qty", goodsPlanDetailData.getBigDecimal("quantity__c") != null ? goodsPlanDetailData.getBigDecimal("quantity__c") : 0);//数量 + //erpGoodsPlanDetailReq.put("lot_number", goodsPlanDetailData.getString("batch_number__c") != null ? goodsPlanDetailData.getString("batch_number__c") : "");//批号 + erpGoodsPlanDetailReq.put("entrycomment", goodsPlanDetailData.getString("remark__c") != null ? goodsPlanDetailData.getString("remark__c") : "");//备注 + erpGoodsPlanDetailReq.put("f9w5_contractno", goodsPlanDetailData.getString("sales_contract_number__c__r") != null ? goodsPlanDetailData.getString("sales_contract_number__c__r") : "");//销售合同编号 + + //开始查询项目号 + String projectId = goodsPlanDetailData.getString("project_name__c") != null ? goodsPlanDetailData.getString("project_name__c") : ""; + + //开始查询项目号 + JSONObject getProjectReq = crmRequestUtil.getCRMList(Arrays.asList( + new Filter("EQ", "_id", Arrays.asList(projectId)) + ), "NewOpportunityObj"); + + JSONObject projectRes = new JSONObject(); + + try { + projectRes = restTemplate.postForObject(URLConstant.GET_CUSTOMIZE_LIST_URL, getProjectReq, JSONObject.class); + } catch (RestClientException e) { + e.printStackTrace(); + } + + String projectCode = ""; + + if ("success".equals(projectRes.getString("errorDescription")) && !projectRes.getJSONObject("data").getJSONArray("dataList").isEmpty()) { + JSONObject projectData = projectRes.getJSONObject("data").getJSONArray("dataList").getJSONObject(0); + projectCode = projectData.getString("opportunity_id__c") != null ? projectData.getString("opportunity_id__c") : ""; + } + + erpGoodsPlanDetailReq.put("f9w5_project_number", projectCode);//项目号 + + goodsPlanDetailList.add(erpGoodsPlanDetailReq); + + } + + erpGoodsPlanReq.put("billentry", goodsPlanDetailList); + + //开始封装要货计划请求 + System.out.println("erp请求为：" + JSON.parseObject(JSON.toJSONString(erpGoodsPlanReq))); + + Map erpContractData = new HashMap<>(); + erpContractData.put("data", Arrays.asList(erpGoodsPlanReq));//请求体 + + String accessToken = new KDTokenController().getKDAccessTokenTest(); + + if (accessToken == null || accessToken.equals("")) { + log.info("金蝶token为空或不存在"); + return; + } + String uuid = UUID.randomUUID().toString().replace("-", ""); + //开始封装请求头 + HttpHeaders headers = new HttpHeaders(); + headers.setContentType(MediaType.APPLICATION_JSON); + headers.set("accessToken", accessToken); + headers.set("Idempotency-Key", uuid); + + HttpEntity goodsPlanReqEntity = new HttpEntity(erpContractData, headers); + + System.out.println(JSON.parseObject(JSON.toJSONString(goodsPlanReqEntity))); + + //开始向金蝶发起请求 + String goodsPlanUrl = "http://192.168.31.233:8022/ierp/kapi/v2/f9w5/sm/f9w5_sm_purchaseplan/purchaseplanSave"; + + JSONObject erpGoodsPlanRes = new JSONObject(); + + try { + erpGoodsPlanRes = restTemplate.postForObject(goodsPlanUrl, goodsPlanReqEntity, JSONObject.class); + } catch (RestClientException e) { + e.printStackTrace(); + } + + System.out.println("要货计划结果为：" + JSON.parseObject(JSON.toJSONString(erpGoodsPlanRes))); + + //开始封装回写程序 + Map backReqMap = new HashMap(); + backReqMap.put("_id", goodsPlanId); + backReqMap.put("dataObjectApiName", "purchase_plan__c"); + + //开始封装日志 + Map logMap = new HashMap<>(); + logMap.put("log_id", UUID.randomUUID().toString().replace("-", "")); + logMap.put("log_type", "GPUP"); + logMap.put("syn_type", "1"); + logMap.put("data_name", goodsPlanName); + logMap.put("data_id", goodsPlanId); + logMap.put("mark", lastModifyTime); + logMap.put("send_body", JSON.toJSONString(goodsPlanReqEntity)); + logMap.put("send_res", JSON.toJSONString(erpGoodsPlanRes)); + logMap.put("tableName", "send_log_goodsplan"); + + //判断是否执行成功 + if ("0".equals(erpGoodsPlanRes.getString("errorCode"))) { + //同步成功 + logMap.put("log_status", "0"); + logMap.put("res_body", "同步成功"); + backReqMap.put("erp_id__c", erpGoodsPlanRes.getJSONObject("data").getJSONArray("result").getJSONObject(0).getString("id")); + backReqMap.put("sync_status__c", "option_sync_success__c"); + backReqMap.put("response_info__c", "同步成功"); + } else { + //同步失败 + logMap.put("log_status", "1"); + logMap.put("res_body", "同步失败：" + erpGoodsPlanRes.getString("message")); + backReqMap.put("sync_status__c", "option_sync_failure__c"); + backReqMap.put("response_info__c", erpGoodsPlanRes.getString("message")); + } + + //开始回写 + JSONObject backReq = crmRequestUtil.updateCRM(backReqMap); + + System.out.println("回写请求为：" + JSON.parseObject(JSON.toJSONString(backReq))); + + JSONObject backRes = new JSONObject(); + + try { + backRes = restTemplate.postForObject(URLConstant.UPDATE_CRM_CUSTOMIZE, backReq, JSONObject.class); + } catch (RestClientException e) { + e.printStackTrace(); + } + + System.out.println("回写结果为：" + backRes); + + //开始记录日志 + JSONObject logResMap = new JSONObject(); + try { + logResMap = restTemplate.postForObject("http://localhost:18088/Log/insert/log_data", logMap, JSONObject.class); + } catch (RestClientException e) { + e.printStackTrace(); + } + + System.out.println("日志插入结果为：" + logResMap); + } + } +} diff --git a/magic-boot/src/main/java/org/ssssssss/magicboot/controller/XSHTController.java b/magic-boot/src/main/java/org/ssssssss/magicboot/controller/XSHTController.java index 6b8c490..177a62b 100644 --- a/magic-boot/src/main/java/org/ssssssss/magicboot/controller/XSHTController.java +++ b/magic-boot/src/main/java/org/ssssssss/magicboot/controller/XSHTController.java @@ -307,6 +307,7 @@ public class XSHTController { contractDetailMap.put("baseunit", contractDetailData.getString("unit__c__r") != null ? contractDetailData.getString("unit__c__r") : "");//单位 //contractDetailMap.put("baseunit", "TEST0001");//todo 单位 contractDetailMap.put("unit_number", "pcs");//单位编码 + contractDetailMap.put("f9w5_unit1_number", "pcs");//单位编码 contractDetailMap.put("baseqty", contractDetailData.getBigDecimal("quantity") != null ? contractDetailData.getBigDecimal("quantity") : 0);//数量 contractDetailMap.put("qty", contractDetailData.getBigDecimal("quantity") != null ? contractDetailData.getBigDecimal("quantity") : 0);//数量 contractDetailMap.put("priceandtax", contractDetailData.getBigDecimal("quantity") != null ? contractDetailData.getBigDecimal("quantity") : 0);//含税单价