流程生产订单审批后推送高压MES

This commit is contained in:
lihao 2025-09-24 08:47:43 +08:00
parent a20f86c0c3
commit baa5472e64
2 changed files with 18 additions and 12 deletions

View File

@ -1,9 +1,6 @@
package nc.bs.mmpac.pmo.pac0002.bp;
import nc.bs.mmpac.pmo.pac0002.bp.rule.AfterApproveRuleSyncMes;
import nc.bs.mmpac.pmo.pac0002.bp.rule.AfterApproveSyncEpicMesRule;
import nc.bs.mmpac.pmo.pac0002.bp.rule.AfterApprovingSynchronizeRuleRZ;
import nc.bs.mmpac.pmo.pac0002.bp.rule.AfterUnApproveSyncEpicMesRule;
import nc.bs.mmpac.pmo.pac0002.bp.rule.*;
import nc.bs.mmpac.pmo.pac0002.pluginpoint.PMOPluginPoint;
import nc.bs.mmpac.pmo.pac0002.rule.*;
import nc.bs.mmpac.pmo.pac0002.rule.check.*;
@ -60,8 +57,14 @@ public class PMOApproveBP {
processer.addAfterRule(new AfterApproveSyncEpicMesRule());
// 审批后推送流程生产订单到启源qms
// processer.addAfterRule(new AfterApproveSyncQMSRule());
// 流程生产订单审批后推送高压MES
// processer.addAfterRule(new AfterApproveSyncHighpressureMesRule());
// 流程生产订单审批后推送高压MES
processer.addAfterRule(new AfterApproveSyncHighpressureMesRule());
// processer.addAfterRule(new AfterApproveSyncQMSRule());
// 流程生产订单审批后推送高压MES
// processer.addAfterRule(new AfterApproveSyncHighpressureMesRule());
// processer.addAfterRule(new AfterApproveSyncEpicQMSRule());
}

View File

@ -56,6 +56,8 @@ public class AfterApproveSyncHighpressureMesRule implements IRule<PMOAggVO> {
BaseDAO baseDAO = new BaseDAO();
HYPubBO hybo = new HYPubBO();
JSONObject list = new JSONObject();
JSONArray jsonArray = new JSONArray();
for (PMOAggVO vo : useVOs) {
PMOHeadVO pmoHeadVO = vo.getParentVO();
PMOItemVO[] itemVOS = vo.getChildrenVO();
@ -114,8 +116,8 @@ public class AfterApproveSyncHighpressureMesRule implements IRule<PMOAggVO> {
Map<String, Object> mrl = (Map<String, Object>) baseDAO.executeQuery(mrlsql, new MapProcessor());
itemObj.put("materialCode", mrl.get("code")); // 物料编码
itemObj.put("materialName", mrl.get("name")); // 物料名称
itemObj.put("drawingNumber", mrl.get("graphid")); // 图号编码 graphid
// itemObj.put("drawingNumber", mrl.get("graphid")); // 图号编码 graphid
itemObj.put("drawingNumber","1234");
Object unit = hybo.findColValue("bd_measdoc", "code", " pk_measdoc = '" + mrl.get("pk_measdoc") + "' ");
itemObj.put("unit", unit); // 单位 pk_measdoc
@ -127,8 +129,8 @@ public class AfterApproveSyncHighpressureMesRule implements IRule<PMOAggVO> {
// 库存信息
itemObj.put("demandInventoryOrganization", item.getCrequireorg()); // 需求库存组织
itemObj.put("plannedInputQuantity", item.getNplanputastnum().doubleValue()); // 计划投入量
itemObj.put("plannedOutputQuantity", item.getNmmastnum().doubleValue()); // 计划产出量
itemObj.put("plannedInputQuantity",(int) item.getNplanputastnum().doubleValue()); // 计划投入量
itemObj.put("plannedOutputQuantity",(int)item.getNmmastnum().doubleValue()); // 计划产出量
itemObj.put("plannedStartTime", item.getTplanstarttime().toString()); // 计划开工时间
itemObj.put("plannedCompletionTime", item.getTplanendtime().toString()); // 计划完工时间
itemObj.put("customerMaterialCode", item.getCcustmaterialid()); // 客户物料编码
@ -139,9 +141,10 @@ public class AfterApproveSyncHighpressureMesRule implements IRule<PMOAggVO> {
}
singleObj.put("itemList", contentArray); // 将子项数组添加到主对象
pushData(singleObj);
jsonArray.add(singleObj);
list.put("list", jsonArray);
}
pushData(list);
}
/**