From ba785762c9b70d3afc66d1c4498030016f342fdf Mon Sep 17 00:00:00 2001 From: sez Date: Wed, 10 Dec 2025 11:41:04 +0800 Subject: [PATCH] =?UTF-8?q?=E5=8C=97=E4=B8=8A=E5=B9=BF=E6=B3=A8=E5=86=8C?= =?UTF-8?q?=E8=AF=81=EF=BC=8C=E7=94=9F=E4=BA=A7=E5=95=86=E6=A0=B9=E6=8D=AE?= =?UTF-8?q?=E6=A0=87=E8=AE=B0=E6=8E=A8=E9=80=81=EF=BC=8C=E9=9D=9E=E9=87=87?= =?UTF-8?q?=E8=B4=AD=E4=BE=9B=E5=BA=94=E5=95=86=E5=88=9B=E5=BB=BA=E4=BA=BA?= =?UTF-8?q?=E6=A0=B9=E6=8D=AE=E6=B3=9B=E5=BE=AEid=E6=9F=A5=E8=AF=A2?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../app/api/controller/SupplierControl.java | 4 +- .../app/plugin/operate/sys/BGScsOpPlugin.java | 48 +++++++++++-------- .../app/plugin/operate/sys/BGZczOpPlugin.java | 48 +++++++++++-------- .../operate/sys/WmsScsSyncOpPlugin.java | 25 ++++++---- .../operate/sys/WmsZczSyncOpPlugin.java | 25 ++++++---- 5 files changed, 90 insertions(+), 60 deletions(-) diff --git a/lc123/cloud/app/api/controller/SupplierControl.java b/lc123/cloud/app/api/controller/SupplierControl.java index 3a759ec..cb04e57 100644 --- a/lc123/cloud/app/api/controller/SupplierControl.java +++ b/lc123/cloud/app/api/controller/SupplierControl.java @@ -61,9 +61,9 @@ public class SupplierControl implements Serializable { billStatus = false; } else { creator = BusinessDataServiceHelper.loadSingle("bos_user", - new QFilter[]{new QFilter("number", QCP.equals, creator_number)}); + new QFilter[]{new QFilter("entryentity.tqq9_fwuserid", QCP.equals, creator_number)}); if (null == creator) { - rowMsg.add("根据创建人工号【" + creator_number + "】在金蝶系统中没有查询到对应的人员信息"); + rowMsg.add("根据泛微人员id【" + creator_number + "】在金蝶系统中没有查询到对应的人员信息"); billStatus = false; } } diff --git a/lc123/cloud/app/plugin/operate/sys/BGScsOpPlugin.java b/lc123/cloud/app/plugin/operate/sys/BGScsOpPlugin.java index 6e2da13..f5de4e9 100644 --- a/lc123/cloud/app/plugin/operate/sys/BGScsOpPlugin.java +++ b/lc123/cloud/app/plugin/operate/sys/BGScsOpPlugin.java @@ -61,36 +61,44 @@ public class BGScsOpPlugin extends AbstractOperationServicePlugIn { HashMap headMap = new HashMap<>(); logger.info("北广生产商同步body：" + jsonBody); try { - String result = HttpRequestUtils.postJson(BJ_URL + "/api/BA/Manufacturer", jsonBody, headMap); - if (StringUtils.isNotEmpty(result)) { - ObjectMapper objectMapper = new ObjectMapper(); - JsonNode rootNode = objectMapper.readTree(result); - if (null != rootNode) { - String code = String.valueOf(rootNode.get("code")); - LCLogServiceImpl lcLogService = new LCLogServiceImpl(); - lcLogService.savelog("北京生产商同步", BJ_URL+ "/api/BA/Manufacturer", true, code.equals("0"), jsonBody, result); - lcLogService.isSuccess("tqq9_proxyandfactory", number, "number", "tqq9_pushw", code.equals("0")); + boolean tqq9_pushbj = dataEntity.getBoolean("tqq9_pushbj"); + if (!tqq9_pushbj) { + String result = HttpRequestUtils.postJson(BJ_URL + "/api/BA/Manufacturer", jsonBody, headMap); + if (StringUtils.isNotEmpty(result)) { + ObjectMapper objectMapper = new ObjectMapper(); + JsonNode rootNode = objectMapper.readTree(result); + if (null != rootNode) { + String code = String.valueOf(rootNode.get("code")); + LCLogServiceImpl lcLogService = new LCLogServiceImpl(); + lcLogService.savelog("北京生产商同步", BJ_URL + "/api/BA/Manufacturer", true, code.equals("0"), jsonBody, result); + lcLogService.isSuccess("tqq9_proxyandfactory", number, "number", "tqq9_pushbj", code.equals("0")); + } + logger.info("北京生产商同步结果：" + result); } - logger.info("北京生产商同步结果：" + result); } + } catch (IOException ex) { throw new RuntimeException(ex); } //广州 try { - String result = HttpRequestUtils.postJson(GZ_URL + "/api/BA/Manufacturer", jsonBody, headMap); - if (StringUtils.isNotEmpty(result)) { - ObjectMapper objectMapper = new ObjectMapper(); - JsonNode rootNode = objectMapper.readTree(result); - if (null != rootNode) { - String code = String.valueOf(rootNode.get("code")); - LCLogServiceImpl lcLogService = new LCLogServiceImpl(); - lcLogService.savelog("广州生产商同步", GZ_URL+ "/api/BA/Manufacturer", true, code.equals("0"), jsonBody, result); - lcLogService.isSuccess("tqq9_proxyandfactory", number, "number", "tqq9_pushw", code.equals("0")); + boolean tqq9_pushgz = dataEntity.getBoolean("tqq9_pushgz"); + if (!tqq9_pushgz) { + String result = HttpRequestUtils.postJson(GZ_URL + "/api/BA/Manufacturer", jsonBody, headMap); + if (StringUtils.isNotEmpty(result)) { + ObjectMapper objectMapper = new ObjectMapper(); + JsonNode rootNode = objectMapper.readTree(result); + if (null != rootNode) { + String code = String.valueOf(rootNode.get("code")); + LCLogServiceImpl lcLogService = new LCLogServiceImpl(); + lcLogService.savelog("广州生产商同步", GZ_URL + "/api/BA/Manufacturer", true, code.equals("0"), jsonBody, result); + lcLogService.isSuccess("tqq9_proxyandfactory", number, "number", "tqq9_pushgz", code.equals("0")); + } + logger.info("广州生产商同步结果：" + result); } - logger.info("广州生产商同步结果：" + result); } + } catch (IOException ex) { throw new RuntimeException(ex); } diff --git a/lc123/cloud/app/plugin/operate/sys/BGZczOpPlugin.java b/lc123/cloud/app/plugin/operate/sys/BGZczOpPlugin.java index d96cfa6..d202d40 100644 --- a/lc123/cloud/app/plugin/operate/sys/BGZczOpPlugin.java +++ b/lc123/cloud/app/plugin/operate/sys/BGZczOpPlugin.java @@ -140,35 +140,43 @@ public class BGZczOpPlugin extends AbstractOperationServicePlugIn { logger.info("广州注册证body：" + gzjsonBody); //北京 try { - String result = HttpRequestUtils.postJson(BJ_URL + "/api/BA/Registration", bjjsonBody, null); - if (StringUtils.isNotEmpty(result)) { - ObjectMapper objectMapper = new ObjectMapper(); - JsonNode rootNode = objectMapper.readTree(result); - if (null != rootNode) { - String code = String.valueOf(rootNode.get("code")); - LCLogServiceImpl lcLogService = new LCLogServiceImpl(); - lcLogService.savelog("北京注册证同步", BJ_URL+ "/api/BA/Registration", true, code.equals("0"), bjjsonBody, result); - lcLogService.isSuccess("tqq9_registration", number, "number", "tqq9_pushw", code.equals("0")); + boolean tqq9_pushbj = dataEntity.getBoolean("tqq9_pushbj"); + if (!tqq9_pushbj) { + String result = HttpRequestUtils.postJson(BJ_URL + "/api/BA/Registration", bjjsonBody, null); + if (StringUtils.isNotEmpty(result)) { + ObjectMapper objectMapper = new ObjectMapper(); + JsonNode rootNode = objectMapper.readTree(result); + if (null != rootNode) { + String code = String.valueOf(rootNode.get("code")); + LCLogServiceImpl lcLogService = new LCLogServiceImpl(); + lcLogService.savelog("北京注册证同步", BJ_URL + "/api/BA/Registration", true, code.equals("0"), bjjsonBody, result); + lcLogService.isSuccess("tqq9_registration", number, "number", "tqq9_pushbj", code.equals("0")); + } + logger.info("北京注册证同步结果：" + result); } - logger.info("北京注册证同步结果：" + result); } + } catch (IOException ex) { throw new RuntimeException(ex); } //广州 try { - String result = HttpRequestUtils.postJson(GZ_URL + "/api/BA/Registration", gzjsonBody, null); - if (StringUtils.isNotEmpty(result)) { - ObjectMapper objectMapper = new ObjectMapper(); - JsonNode rootNode = objectMapper.readTree(result); - if (null != rootNode) { - String code = String.valueOf(rootNode.get("code")); - LCLogServiceImpl lcLogService = new LCLogServiceImpl(); - lcLogService.savelog("广州注册证同步", GZ_URL+ "/api/BA/Registration", true, code.equals("0"), bjjsonBody, result); - lcLogService.isSuccess("tqq9_registration", number, "number", "tqq9_pushw", code.equals("0")); + boolean tqq9_pushgz = dataEntity.getBoolean("tqq9_pushgz"); + if (!tqq9_pushgz) { + String result = HttpRequestUtils.postJson(GZ_URL + "/api/BA/Registration", gzjsonBody, null); + if (StringUtils.isNotEmpty(result)) { + ObjectMapper objectMapper = new ObjectMapper(); + JsonNode rootNode = objectMapper.readTree(result); + if (null != rootNode) { + String code = String.valueOf(rootNode.get("code")); + LCLogServiceImpl lcLogService = new LCLogServiceImpl(); + lcLogService.savelog("广州注册证同步", GZ_URL + "/api/BA/Registration", true, code.equals("0"), bjjsonBody, result); + lcLogService.isSuccess("tqq9_registration", number, "number", "tqq9_pushgz", code.equals("0")); + } + logger.info("广州注册证同步结果：" + result); } - logger.info("广州注册证同步结果：" + result); } + } catch (IOException ex) { throw new RuntimeException(ex); } diff --git a/lc123/cloud/app/plugin/operate/sys/WmsScsSyncOpPlugin.java b/lc123/cloud/app/plugin/operate/sys/WmsScsSyncOpPlugin.java index c2de408..e03ecff 100644 --- a/lc123/cloud/app/plugin/operate/sys/WmsScsSyncOpPlugin.java +++ b/lc123/cloud/app/plugin/operate/sys/WmsScsSyncOpPlugin.java @@ -43,6 +43,9 @@ public class WmsScsSyncOpPlugin extends AbstractOperationServicePlugIn { e.getFieldKeys().add("name"); e.getFieldKeys().add("tqq9_address"); e.getFieldKeys().add("tqq9_proaddress"); + e.getFieldKeys().add("tqq9_pushw"); + e.getFieldKeys().add("tqq9_pushgz"); + e.getFieldKeys().add("tqq9_pushbj"); } @Override @@ -117,18 +120,22 @@ public class WmsScsSyncOpPlugin extends AbstractOperationServicePlugIn { String ttx_mainUrl = ConfigUtils.getThirdConfigByNumber("Ttx_MainURL"); ttx_mainUrl = ttx_mainUrl + "?method=manufacturer.create&v=2.0&format=xml&customerId=" + ttx_customerId; try { - String result = HttpRequestUtils.postXml(ttx_mainUrl, xmlBuilder.toString(), headMap); - if (StringUtils.isNotEmpty(result)) { - JSONObject jsonObject = HttpRequestUtils.xmlToJson(result); - JSONObject response = jsonObject.getJSONObject("response"); - String code = response.getString("code"); + boolean tqq9_pushw = dataEntity.getBoolean("tqq9_pushw"); + if (!tqq9_pushw) { + String result = HttpRequestUtils.postXml(ttx_mainUrl, xmlBuilder.toString(), headMap); + if (StringUtils.isNotEmpty(result)) { + JSONObject jsonObject = HttpRequestUtils.xmlToJson(result); + JSONObject response = jsonObject.getJSONObject("response"); + String code = response.getString("code"); - LCLogServiceImpl lcLogService = new LCLogServiceImpl(); - lcLogService.savelog("wms生产商同步", ttx_mainUrl, true, code.equals("200"), xmlBuilder.toString(), result); - lcLogService.isSuccess("tqq9_proxyandfactory", number1, "number", "tqq9_pushw", code.equals("200")); + LCLogServiceImpl lcLogService = new LCLogServiceImpl(); + lcLogService.savelog("wms生产商同步", ttx_mainUrl, true, code.equals("200"), xmlBuilder.toString(), result); + lcLogService.isSuccess("tqq9_proxyandfactory", number1, "number", "tqq9_pushw", code.equals("200")); - logger.info("wms生产商同步接口结果：" + result); + logger.info("wms生产商同步接口结果：" + result); + } } + } catch (IOException ex) { throw new RuntimeException(ex); } diff --git a/lc123/cloud/app/plugin/operate/sys/WmsZczSyncOpPlugin.java b/lc123/cloud/app/plugin/operate/sys/WmsZczSyncOpPlugin.java index 298e06d..c0fea1e 100644 --- a/lc123/cloud/app/plugin/operate/sys/WmsZczSyncOpPlugin.java +++ b/lc123/cloud/app/plugin/operate/sys/WmsZczSyncOpPlugin.java @@ -50,6 +50,9 @@ public class WmsZczSyncOpPlugin extends AbstractOperationServicePlugIn { e.getFieldKeys().add("tqq9_proxyno"); e.getFieldKeys().add("tqq9_entry.tqq9_e_supno"); e.getFieldKeys().add("enable"); + e.getFieldKeys().add("tqq9_pushw"); + e.getFieldKeys().add("tqq9_pushgz"); + e.getFieldKeys().add("tqq9_pushbj"); } @Override @@ -169,17 +172,21 @@ public class WmsZczSyncOpPlugin extends AbstractOperationServicePlugIn { String ttx_mainUrl = ConfigUtils.getThirdConfigByNumber("Ttx_MainURL"); ttx_mainUrl = ttx_mainUrl + "?method=registrationcertificate.create&v=2.0&format=xml&customerId=" + ttx_customerId; try { - String result = HttpRequestUtils.postXml(ttx_mainUrl, xmlBuilder.toString(), headMap); - if (StringUtils.isNotEmpty(result)) { - JSONObject jsonObject = HttpRequestUtils.xmlToJson(result); - JSONObject response = jsonObject.getJSONObject("response"); - String code = response.getString("code"); - LCLogServiceImpl lcLogService = new LCLogServiceImpl(); - lcLogService.savelog("wms注册证同步", ttx_mainUrl, true, code.equals("200"), xmlBuilder.toString(), result); - lcLogService.isSuccess("tqq9_registration", number, "number", "tqq9_pushw", code.equals("200")); + boolean tqq9_pushw = dataEntity.getBoolean("tqq9_pushw"); + if (!tqq9_pushw) { + String result = HttpRequestUtils.postXml(ttx_mainUrl, xmlBuilder.toString(), headMap); + if (StringUtils.isNotEmpty(result)) { + JSONObject jsonObject = HttpRequestUtils.xmlToJson(result); + JSONObject response = jsonObject.getJSONObject("response"); + String code = response.getString("code"); + LCLogServiceImpl lcLogService = new LCLogServiceImpl(); + lcLogService.savelog("wms注册证同步", ttx_mainUrl, true, code.equals("200"), xmlBuilder.toString(), result); + lcLogService.isSuccess("tqq9_registration", number, "number", "tqq9_pushw", code.equals("200")); - logger.info("wms注册证接口结果：" + result); + logger.info("wms注册证接口结果：" + result); + } } + } catch (IOException ex) { throw new RuntimeException(ex); }