流程生产订单删除后同步艾普MES-V1

mmpac/src/private/nc/bs/mmpac/pmo/pac0002/bp/rule/AfterDelSyncEpicMesRule.java

@@ -0,0 +1,104 @@
+package nc.bs.mmpac.pmo.pac0002.bp.rule;
+
+
+import com.alibaba.fastjson.JSONArray;
+import nc.bs.dao.BaseDAO;
+import nc.bs.logging.Log;
+import nc.bs.uapbd.util.MyHelper;
+import nc.impl.pubapp.pattern.rule.ICompareRule;
+import nc.util.mmf.framework.base.MMArrayUtil;
+import nc.vo.mmpac.pmo.pac0002.entity.PMOAggVO;
+import nc.vo.mmpac.pmo.pac0002.entity.PMOItemVO;
+import nc.vo.org.DeptVO;
+import nc.vo.org.OrgVO;
+import nc.vo.pub.BusinessException;
+import nc.vo.pubapp.pattern.exception.ExceptionUtils;
+
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Map;
+
+/**
+ * 流程生产订单删除后同步艾普MES
+ *
+ * @author mzr
+ * @date 2025/9/16
+ */
+public class AfterDelSyncEpicMesRule implements ICompareRule<PMOAggVO> {
+
+    private static final String LOG_INFO_NAME = "dldzlog";
+
+    private static final Log logDl = Log.getInstance(LOG_INFO_NAME);
+    private static final String pmoUrl = "/prj-v5-web/ext/api/workOrder";
+    private Map<String, String> configParams;
+    private Map<String, String> deptParams;
+
+    private static final BaseDAO dao = new BaseDAO();
+
+    @Override
+    public void process(PMOAggVO[] pmoAggVOS, PMOAggVO[] originVOs) {
+        if (MMArrayUtil.isEmpty(pmoAggVOS)) {
+            return;
+        }
+        try {
+            configParams = MyHelper.getConfigParams("Dldz-config", null);
+            if (configParams.isEmpty()) {
+                // throw new BusinessException("电力电子的艾普MES接口缺少配置");
+                logDl.error("电力电子的艾普MES接口缺少配置");
+                return;
+            }
+            deptParams = MyHelper.getConfigParams("Dldz-dept", null);
+            if (deptParams.isEmpty()) {
+                // throw new BusinessException("电力电子的艾普MES接口缺少部门编码映射配置");
+                logDl.error("电力电子的艾普MES接口缺少部门编码映射配置");
+                return;
+            }
+            String deptRange = String.join(",", deptParams.keySet());
+            configParams.put("deptRange", deptRange);
+            List<PMOAggVO> filteredOrders = checkAndFilterBillSrcOrg(pmoAggVOS);
+            if (filteredOrders.isEmpty()) {
+                logDl.error("没有符合条件的生产订单需要同步到艾普MES系统。");
+                return;
+            }
+            logDl.info("开始同步生产订单到艾普MES系统，符合条件的订单数量: " + filteredOrders.size());
+            JSONArray jsonArray = new JSONArray();
+            // 推送到艾普MES系统
+            for (PMOAggVO aggVO : filteredOrders) {
+
+            }
+        } catch (Exception e) {
+            logDl.error("删除同步生产订单到艾普MES系统失败: " + e.getMessage(), e);
+            ExceptionUtils.wrappException(e);
+        }
+    }
+
+
+    /**
+     * 检查并筛选需要同步的单据
+     */
+    private List<PMOAggVO> checkAndFilterBillSrcOrg(PMOAggVO[] pmoAggVOS) throws BusinessException {
+        List<PMOAggVO> aggvoList = new ArrayList<>();
+        for (PMOAggVO aggVo : pmoAggVOS) {
+            String pkOrg = aggVo.getParentVO().getPk_org();
+            String orgCode = MyHelper.transferField(OrgVO.getDefaultTableName(), OrgVO.CODE, OrgVO.PK_ORG, pkOrg);
+            // 检查当前组织是否为电力电子
+            if (MyHelper.checkIfDldzOrg(orgCode, configParams)) {
+                continue;
+            }
+            // 按照部门筛选生产订单，只传消弧车间、电容车间、成套车间（部门是配置项）
+            PMOItemVO childrenVO = aggVo.getChildrenVO()[0];
+            String cdeptid = childrenVO.getCdeptid();
+            String deptCode = MyHelper.transferField(DeptVO.getDefaultTableName(), DeptVO.CODE, DeptVO.PK_DEPT, cdeptid);
+            // 如果部门不在范围内则跳过本次循环
+            String deptRange = configParams.get("deptRange");
+            if (deptCode == null || !deptRange.contains(deptCode)) {
+                continue;
+            }
+            aggvoList.add(aggVo);
+        }
+
+        return aggvoList;
+    }
+
+
+}