diff --git a/ic/src/private/nc/bs/ic/m4c/sign/rule/AfterSigningSynchronizeRule.java b/ic/src/private/nc/bs/ic/m4c/sign/rule/AfterSigningSynchronizeRule.java index bdfd9ba..9909ce7 100644 --- a/ic/src/private/nc/bs/ic/m4c/sign/rule/AfterSigningSynchronizeRule.java +++ b/ic/src/private/nc/bs/ic/m4c/sign/rule/AfterSigningSynchronizeRule.java @@ -40,11 +40,13 @@ public class AfterSigningSynchronizeRule implements IRule { SaleOutBodyVO[] bvos = (SaleOutBodyVO[]) saleOutVO.getChildrenVO(); // 构建要发送的数据 JSONObject syncData = buildSyncData(hvo, bvos); - // 发送数据到金思维系统(使用HttpPostOtherSysImpl处理网络请求) - String mesResponse = httpPostOtherSys.callMes(SALE_OUT_URL, syncData); - obmlog.debug("AfterSigningSynchronizeRule-金思维系统响应: " + mesResponse); - // 解析响应,处理结果 - processResponse(hvo.getVbillcode(), mesResponse); + if (syncData != null) { + // 发送数据到金思维系统(使用HttpPostOtherSysImpl处理网络请求) + String mesResponse = httpPostOtherSys.callMes(SALE_OUT_URL, syncData); + obmlog.debug("AfterSigningSynchronizeRule-金思维系统响应: " + mesResponse); + // 解析响应,处理结果 + processResponse(hvo.getVbillcode(), mesResponse); + } } } catch (Exception e) { obmlog.error("AfterSigningSynchronizeRule-处理异常:" + e.getMessage(), e); @@ -56,6 +58,11 @@ public class AfterSigningSynchronizeRule implements IRule { * 按照NCC/YonBIP字段映射到金思维系统字段 */ private JSONObject buildSyncData(SaleOutHeadVO hvo, SaleOutBodyVO[] bvos) { + obmlog.debug("AfterSigningSynchronizeRule-开始处理销售出库单: " + hvo.getVbillcode()); + if (!hvo.getPk_org().equals("0001A1100000000026O5") || !hvo.getPk_org().equals("1001A11000000KFE18FO")) { + obmlog.debug("AfterSigningSynchronizeRule-跳过处理销售出库单,因为此单据组织非电缆: " + hvo.getVbillcode()); + return null; + } JSONObject requestData = new JSONObject(); requestData.put("operation_type", "I"); diff --git a/ic/src/private/nc/bs/ic/m4r/approve/rule/AfterApprovingSynchronizeRule.java b/ic/src/private/nc/bs/ic/m4r/approve/rule/AfterApprovingSynchronizeRule.java index 44a1525..e4f7a5e 100644 --- a/ic/src/private/nc/bs/ic/m4r/approve/rule/AfterApprovingSynchronizeRule.java +++ b/ic/src/private/nc/bs/ic/m4r/approve/rule/AfterApprovingSynchronizeRule.java @@ -45,12 +45,14 @@ public class AfterApprovingSynchronizeRule implements IRule { // 构建要发送的数据 JSONObject syncData = buildSyncData(hvo, bvos); - // 发送数据到金思维系统(使用HttpPostOtherSysImpl处理网络请求) - String mesResponse = httpPostOtherSys.callMes(INV_COUNT_URL, syncData); - obmlog.debug("AfterApprovingSynchronizeRule-金思维系统响应: " + mesResponse); + if (syncData != null) { + // 发送数据到金思维系统(使用HttpPostOtherSysImpl处理网络请求) + String mesResponse = httpPostOtherSys.callMes(INV_COUNT_URL, syncData); + obmlog.debug("AfterApprovingSynchronizeRule-金思维系统响应: " + mesResponse); - // 解析响应,处理结果 - processResponse(hvo.getVbillcode(), mesResponse); + // 解析响应,处理结果 + processResponse(hvo.getVbillcode(), mesResponse); + } } } catch (Exception e) { obmlog.error("AfterApprovingSynchronizeRule-处理异常:" + e.getMessage(), e); @@ -62,6 +64,11 @@ public class AfterApprovingSynchronizeRule implements IRule { * 按照接口文档要求构建JSON结构 */ private JSONObject buildSyncData(InvCountHeaderVO hvo, InvCountBodyVO[] bvos) throws BusinessException { + obmlog.debug("AfterApprovingSynchronizeRule-开始处理盘点单: " + hvo.getVbillcode()); + if (!hvo.getPk_org().equals("0001A1100000000026O5") || !hvo.getPk_org().equals("1001A11000000KFE18FO")) { + obmlog.debug("AfterApprovingSynchronizeRule-跳过处理销售出库单,因为此单据组织非电缆: " + hvo.getVbillcode()); + return null; + } JSONObject requestData = new JSONObject(); // 操作类型为新增 requestData.put("operation_type", "I");