From e56e462009c695510b5c95b9293bc8d8a5fe24c6 Mon Sep 17 00:00:00 2001 From: itzhang <2019326567@qq.com> Date: Fri, 1 Aug 2025 09:33:57 +0800 Subject: [PATCH] =?UTF-8?q?=E9=94=80=E5=94=AE=E5=90=88=E5=90=8C=E7=AB=A3?= =?UTF-8?q?=E5=B7=A5=E7=8A=B6=E6=80=81=E7=AD=9B=E9=80=89=E6=9D=A1=E4=BB=B6?= =?UTF-8?q?=E4=BC=98=E5=8C=96=EF=BC=8C=E4=BE=9B=E5=BA=94=E5=95=86=E6=96=B0?= =?UTF-8?q?=E9=9C=80=E6=B1=82=E6=9B=B4=E6=96=B0?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../controller/VendorController.java | 196 ++++++++++++++++++ .../management/controller/XSHTController.java | 3 +- 2 files changed, 198 insertions(+), 1 deletion(-) diff --git a/src/main/java/com/management/controller/VendorController.java b/src/main/java/com/management/controller/VendorController.java index 5848467..144f576 100644 --- a/src/main/java/com/management/controller/VendorController.java +++ b/src/main/java/com/management/controller/VendorController.java @@ -2,6 +2,7 @@ package com.management.controller; import com.alibaba.fastjson.JSON; import com.alibaba.fastjson.JSONObject; +import com.management.constant.CertificateConstant; import com.management.constant.ERPURLConstant; import com.management.constant.URLConstant; import com.management.entity.Filter; @@ -74,6 +75,83 @@ public class VendorController { String vendorName = vendorData.getString("name"); String createTime = vendorData.getString("last_modified_time"); + //根据供应商名称查询是否已存在重名数据 + JSONObject getRepeatedVendor = crmRequestUtil.getCRMList(Arrays.asList( + new Filter("EQ", "name", Arrays.asList(vendorName)), + new Filter("N", "record_type", Arrays.asList("record_ev1gl__c")), + new Filter("EQ", "life_status", Arrays.asList("normal")) + ), "SupplierObj"); + + JSONObject repeatedVendorRes = new JSONObject(); + + try { + repeatedVendorRes = restTemplate.postForObject(URLConstant.GET_CUSTOMIZE_LIST_URL, getRepeatedVendor, JSONObject.class); + } catch (RestClientException e) { + e.printStackTrace(); + } + + if ("success".equals(repeatedVendorRes.getString("errorDescription")) && !repeatedVendorRes.getJSONObject("data").getJSONArray("dataList").isEmpty()) { + log.info("存在重名的数据"); + + //开始获取关键数据 + JSONObject repeatedVendorData = repeatedVendorRes.getJSONObject("data").getJSONArray("dataList").getJSONObject(0); + + System.out.println("当前正在处理的数据为：" + repeatedVendorData); + + //开始获取该数据的ERP信息 + String erpId = repeatedVendorData.getString("erp_number__c") != null ? repeatedVendorData.getString("erp_number__c") : ""; + + String updateRes = updateVendorType(repeatedVendorData); + + String isSuccess = ""; + + if ("同步更新状态成功".equals(updateRes)) { + isSuccess = "option_sync_success__c"; + } else { + isSuccess = "option_sync_failure__c"; + } + + //将当前单据的单位编号改成重名供应商的erp单据编号 + Map valueMap = new HashMap<>(); + valueMap.put("_id", vendorId); + valueMap.put("erpCode", erpId); + valueMap.put("isSuccess", isSuccess); + valueMap.put("status", updateRes); + + Map parameters = new HashMap<>(); + parameters.put("value", valueMap); + parameters.put("name", "syncArg"); + parameters.put("type", "Map"); + + Map dataMap = new HashMap<>(); + dataMap.put("api_name", "CstmCtrl_ZdkhQ__c"); + dataMap.put("postId", UUID.randomUUID().toString().replace("-", "")); + dataMap.put("parameters", Arrays.asList(parameters)); + + Map erpVendorReq = new HashMap<>(); + erpVendorReq.put("corpAccessToken", crmRequestUtil.getCRMToken()); + erpVendorReq.put("currentOpenUserId", CertificateConstant.CURRENT_OPEN_USERID); + erpVendorReq.put("corpId", CertificateConstant.CORP_ID); + erpVendorReq.put("data", dataMap); + + JSONObject erpVendorRes = new JSONObject(); + + try { + erpVendorRes = restTemplate.postForObject("https://open.fxiaoke.com/cgi/crm/v2/special/function", erpVendorReq, JSONObject.class); + } catch (RestClientException e) { + e.printStackTrace(); + } + + System.out.println("供应商回写结果为：" + erpVendorRes); + + if (!erpVendorRes.getString("errorCode").equals("0")) { + log.info("供应商回写失败"); + continue; + } + + continue; + } + //开始查询日子是否存在当前单据 JSONObject isLog = new JSONObject(); @@ -449,4 +527,122 @@ public class VendorController { } } + /** + * 修改erp中的供应商类型 + * + * @param vendorData + * @return void + * @param: + * @Author weiloong_zhang + */ + public String updateVendorType(JSONObject vendorData) { + if (vendorData == null) { + return "同步失败，vendorData为null"; + } + + System.out.println("当前正在处理的供应商数据为：" + vendorData); + + //开始截取关键数据 + String vendorId = vendorData.getString("_id"); + String vendorName = vendorData.getString("name"); + String createTime = vendorData.getString("last_modified_time"); + String erpId = vendorData.getString("erp_id__c") != null ? vendorData.getString("erp_id__c") : ""; + + if ("".equals(erpId)){ + log.info("当前单据erp_id__c为空，不再向下执行"); + return "当前单据erp_id__c为空，不再向下执行"; + } + + Map vendorMap = new HashMap<>(); + vendorMap.put("id", erpId); + vendorMap.put("createorg_number", "zyierp"); + vendorMap.put("f9w5_isconstruction", true); + + //供应商最终请求 + Map vendorReq = new HashMap<>(); + vendorReq.put("data", Arrays.asList(vendorMap)); + + //开始获取token + String accessToken = new KDTokenController().getKDAccessTokenTest(); + + if (accessToken == null || accessToken.equals("")) { + log.info("金蝶token为空或不存在"); + return "失败，金蝶token为空"; + } + 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 vendorReqEntity = new HttpEntity(vendorReq, headers); + + System.out.println(JSON.parseObject(JSON.toJSONString(vendorReqEntity))); + + //String vendorUrl = ERPURLConstant.ERP_URL + "/ierp/kapi/v2/f9w5/basedata/bd_supplier/bdSupplierSave"; + String vendorUrl = "https://lxr2.zhydsp.cn:40448/ierp/kapi/v2/f9w5/basedata/bd_supplier/bdSupplierUpdate"; + + JSONObject vendorERPRes = new JSONObject(); + + try { + vendorERPRes = restTemplate.postForObject(vendorUrl, vendorReqEntity, JSONObject.class); + } catch (RestClientException e) { + e.printStackTrace(); + } + + + System.out.println(vendorERPRes); + + //开始封装回写程序 + Map backReqMap = new HashMap(); + backReqMap.put("_id", vendorId); + backReqMap.put("dataObjectApiName", "SupplierObj"); + + //开始封装日志 + Map logMap = new HashMap<>(); + logMap.put("log_id", UUID.randomUUID().toString().replace("-", "")); + logMap.put("log_type", "供应商更新状态"); + logMap.put("syn_type", "1"); + logMap.put("data_name", vendorName); + logMap.put("data_id", vendorId); + logMap.put("mark", createTime); + logMap.put("send_body", JSON.toJSONString(vendorReqEntity)); + logMap.put("send_res", JSON.toJSONString(vendorERPRes)); + logMap.put("tableName", "send_log_vendor"); + + + String result = ""; + //判断是否执行成功 + if ("0".equals(vendorERPRes.getString("errorCode"))) { + //同步成功 + logMap.put("log_status", "0"); + logMap.put("res_body", "同步成功"); + backReqMap.put("erp_id__c", vendorERPRes.getJSONObject("data").getJSONArray("result").getJSONObject(0).getString("id")); + backReqMap.put("sync_status__c", "option_sync_success__c"); + backReqMap.put("response_status__c", "更新操作同步成功"); + result = "同步更新状态成功"; + } else { + //同步失败 + logMap.put("log_status", "1"); + logMap.put("res_body", "同步失败：" + vendorERPRes.getString("message")); + backReqMap.put("sync_status__c", "option_sync_failure__c"); + backReqMap.put("response_status__c", "更新失败：" + vendorERPRes.getString("message")); + result = "同步更新状态失败：" + vendorERPRes.getString("message"); + } + + //开始记录日志 + 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); + + return result; + } + } diff --git a/src/main/java/com/management/controller/XSHTController.java b/src/main/java/com/management/controller/XSHTController.java index b4d176c..c303412 100644 --- a/src/main/java/com/management/controller/XSHTController.java +++ b/src/main/java/com/management/controller/XSHTController.java @@ -1005,7 +1005,8 @@ public class XSHTController { JSONObject contractReq = crmRequestUtil.getCRMList(Arrays.asList( //new Filter("EQ", "name", Arrays.asList("ZHY2505180013")), new Filter("GT", "create_time", Arrays.asList("1748923200000")), - new Filter("N", "is_initial__c", Arrays.asList("true")), + //new Filter("N", "is_initial__c", Arrays.asList("true")), + new Filter("EQ", "completion_sync_status__c", Arrays.asList("option_pending_sync__c")), new Filter("EQ", "is_completed__c", Arrays.asList("yes")) ), "SaleContractObj");