From 63880a6a10d94eedfada21a4dcebb074a971c25e Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E5=BC=A0=E6=98=8E?=
 <125556714+Topfunplus@users.noreply.github.com>
Date: Wed, 21 May 2025 16:30:41 +0800
Subject: [PATCH] =?UTF-8?q?=E9=87=8D=E6=9E=84=E9=87=87=E8=B4=AD=E5=85=A5?=
 =?UTF-8?q?=E5=BA=93=E5=90=8C=E6=AD=A5=20MES=20=E6=8E=A5=E5=8F=A3=E9=80=BB?=
 =?UTF-8?q?=E8=BE=91?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../rule/AfterSigningSynchronizeRuleMES.java  | 34 ++++---------------
 1 file changed, 7 insertions(+), 27 deletions(-)

diff --git a/ic/src/private/nc/bs/ic/m45/sign/rule/AfterSigningSynchronizeRuleMES.java b/ic/src/private/nc/bs/ic/m45/sign/rule/AfterSigningSynchronizeRuleMES.java
index 974922f..b712240 100644
--- a/ic/src/private/nc/bs/ic/m45/sign/rule/AfterSigningSynchronizeRuleMES.java
+++ b/ic/src/private/nc/bs/ic/m45/sign/rule/AfterSigningSynchronizeRuleMES.java
@@ -1,6 +1,5 @@
 package nc.bs.ic.m45.sign.rule;
 
-import com.alibaba.fastjson.JSONArray;
 import com.alibaba.fastjson.JSONObject;
 import nc.bs.dao.BaseDAO;
 import nc.bs.framework.common.NCLocator;
@@ -50,27 +49,13 @@ public class AfterSigningSynchronizeRuleMES implements IRule<PurchaseInVO> {
 
             // 初始化HTTP请求工具类
             IHttpPostOtherSys httpPostOtherSys = NCLocator.getInstance().lookup(IHttpPostOtherSys.class);
-
             for (PurchaseInVO purchaseInVO : purchaseInVOs) {
-                // 判断是否需要同步到MES
-                if (!isSyncToMES(purchaseInVO)) {
-                    continue;
-                }
-
                 PurchaseInHeadVO hvo = (PurchaseInHeadVO) purchaseInVO.getParentVO();
                 PurchaseInBodyVO[] bvos = (PurchaseInBodyVO[]) purchaseInVO.getChildrenVO();
                 // 构建请求参数
-                JSONObject requestParam = buildSyncData(hvo, bvos);
-
-                if (requestParam != null) {
-                    // 获取操作类型
-                    String operationType = (String) requestParam.get("operation_type");
-                    // 根据操作类型选择URL
-                    String url = "I".equals(operationType) ? ADD_URL : DELETE_URL;
-                    obmlog.debug("采购入库同步MES-开始处理单据: " + hvo.getVbillcode());
-                    obmlog.debug("采购入库同步MES-请求参数: " + requestParam.toJSONString());
-                    // 调用MES接口
-                    httpPostOtherSys.sendToExternalSystem(url, requestParam);
+                JSONObject syncData = buildSyncData(hvo, bvos);
+                if (syncData != null) {
+                    httpPostOtherSys.sendToExternalSystem(ADD_URL, syncData);
                 }
             }
         } catch (Exception e) {
@@ -79,20 +64,15 @@ public class AfterSigningSynchronizeRuleMES implements IRule<PurchaseInVO> {
         }
     }
 
-    /**
-     * 判断是否需要同步到MES
-     */
-    private boolean isSyncToMES(PurchaseInVO purchaseInVO) {
-        // 此处根据业务规则判断是否需要同步
-        return true;
-    }
-
     /**
      * 构建符合MES系统接口规范的请求数据
      */
     private JSONObject buildSyncData(PurchaseInHeadVO hvo, PurchaseInBodyVO[] bvos) throws BusinessException {
         obmlog.debug("采购入库同步MES-开始构建数据: " + hvo.getVbillcode());
-
+//        if (!hvo.getPk_org().equals("0001A110000000000677")) {
+//            obmlog.debug("AfterSigningSynchronizeRule-跳过处理销售出库单,因为此单据组织非电缆: " + hvo.getVbillcode());
+//            return null;
+//        }
         JSONObject requestData = new JSONObject();
         // 设置操作类型
         requestData.put("operation_type", "I");  // 签字为新增操作