From 38438e77428a0c9b52d3789ee6d5e9ddf8951533 Mon Sep 17 00:00:00 2001 From: houyi <1398559711@qq.com> Date: Wed, 24 Sep 2025 15:04:32 +0800 Subject: [PATCH] =?UTF-8?q?=E9=AB=98=E5=8E=8B-=E5=A4=87=E6=96=99=E8=AE=A1?= =?UTF-8?q?=E5=88=92=E5=AE=A1=E6=89=B9=E5=90=8E=E6=8E=A8=E9=80=81=E9=AB=98?= =?UTF-8?q?=E5=8E=8BMES?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../nc/bs/mmpac/pickm/bp/PickmApproveBP.java | 5 + .../rule/AfterApproveRuleHighpressureMes.java | 173 ++++++++++++++++++ 2 files changed, 178 insertions(+) create mode 100644 mmpac/src/private/nc/bs/mmpac/pickm/bp/rule/AfterApproveRuleHighpressureMes.java diff --git a/mmpac/src/private/nc/bs/mmpac/pickm/bp/PickmApproveBP.java b/mmpac/src/private/nc/bs/mmpac/pickm/bp/PickmApproveBP.java index 1641bbf0..ae4dd414 100644 --- a/mmpac/src/private/nc/bs/mmpac/pickm/bp/PickmApproveBP.java +++ b/mmpac/src/private/nc/bs/mmpac/pickm/bp/PickmApproveBP.java @@ -1,12 +1,14 @@ package nc.bs.mmpac.pickm.bp; +import nc.bs.mmpac.pickm.bp.rule.AfterApproveRuleHighpressureMes; import nc.bs.mmpac.pickm.bp.rule.AfterApproveRuleSyncRZWMS; import nc.bs.mmpac.pickm.plugin.PickmPluginPoint; import nc.bs.mmpac.pickm.rule.PickmApproveCheckStatusRule; import nc.bs.mmpac.pickm.rule.PickmCheckAuditRule; import nc.bs.mmpac.pickm.rule.PickmFbackflustimeCheckRule; import nc.bs.mmpac.pickm.rule.PickmSetStatusRule; +import nc.bs.mmpac.pmo.pac0002.bp.rule.AfterApproveSyncHighpressureMesRule; import nc.bs.mmpub.rule.MMATOMaterialCheckRule; import nc.bs.mmpub.rule.MMVOSagaFrozenValidateRule; import nc.impl.pubapp.pattern.data.bill.template.UpdateBPTemplate; @@ -24,6 +26,9 @@ public class PickmApproveBP { //备料计划审批推送锐制 IRule pickmstatusFilterRule = new AfterApproveRuleSyncRZWMS(); processer.addAfterRule(pickmstatusFilterRule); + //备料计划审批后推送高压MES + IRule pickmHighpressureMesRules = new AfterApproveRuleHighpressureMes(); + processer.addAfterRule(pickmHighpressureMesRules); } private void addBeforeRule(CompareAroundProcesser processer) { diff --git a/mmpac/src/private/nc/bs/mmpac/pickm/bp/rule/AfterApproveRuleHighpressureMes.java b/mmpac/src/private/nc/bs/mmpac/pickm/bp/rule/AfterApproveRuleHighpressureMes.java new file mode 100644 index 00000000..68172c85 --- /dev/null +++ b/mmpac/src/private/nc/bs/mmpac/pickm/bp/rule/AfterApproveRuleHighpressureMes.java @@ -0,0 +1,173 @@ +package nc.bs.mmpac.pickm.bp.rule; + + +import com.alibaba.fastjson.JSON; +import com.alibaba.fastjson.JSONArray; +import com.alibaba.fastjson.JSONObject; +import com.alibaba.fastjson.serializer.SerializerFeature; +import nc.bs.dao.BaseDAO; +import nc.bs.logging.Log; +import nc.bs.trade.business.HYPubBO; +import nc.bs.uapbd.util.MyHelper; +import nc.bs.uapbd.util.ThirdPartyPostRequestUtil; +import nc.impl.pubapp.pattern.rule.IRule; +import nc.jdbc.framework.processor.ColumnProcessor; +import nc.jdbc.framework.processor.MapProcessor; +import nc.vo.mmpac.pickm.entity.AggPickmVO; +import nc.vo.mmpac.pickm.entity.PickmHeadVO; +import nc.vo.mmpac.pickm.entity.PickmItemVO; +import nc.vo.org.OrgVO; +import nc.vo.pub.BusinessException; +import nc.vo.pubapp.pattern.exception.ExceptionUtils; +import nc.vo.scmpub.util.ArrayUtil; + +import java.util.Map; + +/** + * 备料审批后推送高压MES + * + * @author houyi + * @date 2025/9/23 + */ +public class AfterApproveRuleHighpressureMes implements IRule { + + private static final String LOG_INFO_NAME = "gymeslog"; + private static final Log logger = Log.getInstance(LOG_INFO_NAME); + private Map configParams; + + @Override + public void process(AggPickmVO[] aggPickmVOS) { + if (ArrayUtil.isEmpty(aggPickmVOS)) { + return; + } + configParams = MyHelper.getConfigParams("gy-config", null); + try { + buildSyncData(aggPickmVOS); + } catch (Exception e) { + logger.error("同步备料计划到高压MES系统失败: " + e.getMessage(), e); + ExceptionUtils.wrappException(e); + } + } + + /** + * 构建同步数据 + */ + private void buildSyncData(AggPickmVO[] useVOs) throws BusinessException { + BaseDAO baseDAO = new BaseDAO(); + + HYPubBO hybo = new HYPubBO(); + JSONObject list = new JSONObject(); + JSONArray jsonArray = new JSONArray(); + for (AggPickmVO vo : useVOs) { + PickmHeadVO pickmHeadVO = vo.getParentVO(); + PickmItemVO[] itemVOS = (PickmItemVO[]) vo.getChildrenVO(); + // 判断物料的业务单元是否是箱变公司，不是则跳过 + String pkOrg = pickmHeadVO.getPk_org(); + String orgCode = MyHelper.transferField(OrgVO.getDefaultTableName(), OrgVO.CODE, OrgVO.PK_ORG, pkOrg); + if (checkIfOrg(orgCode, configParams)) { + continue; + } + JSONObject singleObj = new JSONObject(); + singleObj.put("materialPreparationPlanNumber", pickmHeadVO.getVbillcode());// 备料计划单号 + singleObj.put("bipId", pickmHeadVO.getCpickmid());// 主键ID + // 生产部门 + String deptsql = " select name from org_dept where pk_dept='" + pickmHeadVO.getCdeptid() + "' and dr=0 "; + Map dept = (Map) baseDAO.executeQuery(deptsql, new MapProcessor()); + singleObj.put("bipDeptName", dept.get("name")); // 生产部门 + singleObj.put("bipDeptId", pickmHeadVO.getCdeptid()); // 生产部门Id + + singleObj.put("bipProcessProductionOrderId", pickmHeadVO.getVsourcemocode()); // 流程生产订单号 + singleObj.put("bipProcessProductionOrderRowNum", pickmHeadVO.getVsourcemorowcode()); // 来源单据号行号 + singleObj.put("bipParentProcessProductionOrderId", pickmHeadVO.getVsourcebillcode()); // 上级来源单据号 + singleObj.put("bipParentProcessProductionOrderRowNum", pickmHeadVO.getVsourcebillrowno()); // 上级来源单据行号 + singleObj.put("bipOriginProcessProductionOrderId", pickmHeadVO.getVfirstbillcode()); // 顶级来源单据号 + singleObj.put("bipOriginProcessProductionOrderRowNum", pickmHeadVO.getVfirstbillrowno()); // 顶级来源单据行号 + singleObj.put("orderQuantity", pickmHeadVO.getNastnum()); // 订单数量（计划数量） + singleObj.put("bomVersion", pickmHeadVO.getVbomversionnumber()); // bom版本 + // 物料信息 + String cpsql = "select code,name,graphid,pk_measdoc,materialspec from bd_material where pk_material = '" + pickmHeadVO.getCmaterialvid() + "' "; + Map mrl = (Map) baseDAO.executeQuery(cpsql, new MapProcessor()); + singleObj.put("productCode", mrl.get("code")); // 产品编码 + singleObj.put("productName", mrl.get("name")); // 产品名称 + + singleObj.put("intervalModel", mrl.get("materialspec")); // (物料的自定义字段) + singleObj.put("requiredDate", pickmHeadVO.getDmakedate()); // 需用日期 + String sql1 = " select user_name from sm_user where cuserid = '" + pickmHeadVO.getCreator() + "' "; + String bipCreateBy = (String) baseDAO.executeQuery(sql1, new ColumnProcessor()); + + singleObj.put("bipCreateBy", bipCreateBy); // 创建人ID + + // 创建子项数组 + JSONArray contentArray = new JSONArray(); + for (PickmItemVO item : itemVOS) { + JSONObject itemObj = new JSONObject(); + + itemObj.put("bipChildId", item.getCpickm_bid()); // 子项主键ID + itemObj.put("bchkitemforwr", item.getBchkitemforwr()); // 完工齐套检查 + itemObj.put("lineNumber", item.getVrowno()); // 行号 + itemObj.put("quantityPerSet", item.getNunituseastnum()); // 单套数量（单位用量） + itemObj.put("reservedQuantity", item.getNatpastnum()); // 预留数量 + itemObj.put("cumulativePendingQuantity", item.getNshouldastnum()); // 累计待发数量 + itemObj.put("cumulativeIssuedQuantity", item.getNaccoutastnum()); // 累计出库数量 + + // 物料信息 + String mrlsql = "select code,name,graphid,pk_measdoc,materialspec from bd_material where pk_material = '" + item.getCbmaterialid() + "' "; + Map material = (Map) baseDAO.executeQuery(mrlsql, new MapProcessor()); + itemObj.put("materialCode", material.get("code")); // 物料编码 + itemObj.put("materialName", material.get("name")); // 物料名称 + itemObj.put("drawingNumber", material.get("graphid")); // 图号 + Object unit = hybo.findColValue("bd_measdoc", "code", " pk_measdoc = '" + material.get("pk_measdoc") + "' "); + itemObj.put("unit", unit); // 规格单位 + // 生产信息 + itemObj.put("intervalModel", material.get("materialspec")); // 产品类型 + itemObj.put("lineNumber", String.valueOf(item.getVrowno())); // 行号 + + contentArray.add(itemObj); // 将子项添加到数组 + } + + singleObj.put("itemList", contentArray); // 将子项数组添加到主对象 + jsonArray.add(singleObj); + list.put("list", jsonArray); + } + pushData(list); + } + + /** + * 推送同步数据 + */ + private void pushData(JSONObject param) throws BusinessException { + // 转json字符串的时候保留null值 + String jsonStr = JSON.toJSONString(param, + SerializerFeature.WriteMapNullValue, + SerializerFeature.WriteNullStringAsEmpty + ); + logger.error("gyMes-Agg-param = " + jsonStr); + String baseUrl = configParams.get("mesBaseUrl"); + String requestUrl = baseUrl + configParams.get("productionOrderAdd"); + logger.error("gyMes-Agg-url = " + requestUrl); + String result = ThirdPartyPostRequestUtil.sendPostRequest(requestUrl, jsonStr); + JSONObject resultObj = JSONObject.parseObject(result); + logger.error("gyMes-Agg-res = " + result); + + if (!"200".equals(resultObj.getString("code"))) { + logger.error("gyMes-Agg-error,result[" + resultObj.toJSONString() + "]"); + throw new BusinessException("备料计划推送高压MES错误:" + resultObj.getString("msg")); + } + } + + private boolean checkIfOrg(String code, Map configParams) throws BusinessException { + String targetCode = configParams.get("gyOrg"); + if (targetCode == null || nc.vo.am.common.util.StringUtils.isEmpty(targetCode)) { + throw new BusinessException("未配置组织参数"); + } + String[] orgItem = targetCode.split(","); + for (String orgCode : orgItem) { + if (!orgCode.isEmpty() && orgCode.equals(code)) { + return false; + } + } + return true; + } + + +}