yonyou
/
taikai2312
2
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

生产订单审批后推送高压MES修改 优化

This commit is contained in:
houyi 2025-10-10 15:09:08 +08:00
parent 5150a55404
commit d40571cfb7
4 changed files with 56 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
mmpac/src/private/nc/bs/mmpac/pickm/bp/rule/AfterApproveRuleHighpressureMes.java
View File

@ -130,7 +130,16 @@ public class AfterApproveRuleHighpressureMes implements IRule<AggPickmVO> {
Map<String, Object> material = (Map<String, Object>) baseDAO.executeQuery(mrlsql, new MapProcessor());
itemObj.put("materialCode", material.get("code")); // 物料编码
itemObj.put("materialName", material.get("name")); // 物料名称
itemObj.put("drawingNumber", "计划信息组织"); // 图号
// itemObj.put("drawingNumber", "计划信息组织"); // 图号
String plansql = "select def1 from bd_materialplan where pk_org = '0001A11000000059XIB0' " + "and pk_material = '" + item.getCbmaterialid() + "' " + "and dr=0";//计划信息查询
Map<String, Object> plan = (Map<String, Object>) baseDAO.executeQuery(plansql, new MapProcessor());
if (plan != null && !plan.isEmpty()) {
itemObj.put("drawingNumber", plan.get("def1")); // 图号编码(计划信息查询高压生产中心)
} else {
itemObj.put("drawingNumber", "");
}
Object unit = hybo.findColValue("bd_measdoc", "code", " pk_measdoc = '" + material.get("pk_measdoc") + "' ");
itemObj.put("unit", unit); // 规格单位
// 生产信息
@ -198,7 +207,16 @@ public class AfterApproveRuleHighpressureMes implements IRule<AggPickmVO> {
Map<String, Object> material = (Map<String, Object>) baseDAO.executeQuery(mrlsql, new MapProcessor());
itemObj.put("materialCode", material.get("code")); // 物料编码
itemObj.put("materialName", material.get("name")); // 物料名称
itemObj.put("drawingNumber", "计划信息组织"); // 图号
// itemObj.put("drawingNumber", "计划信息组织"); // 图号
String plansql = "select def1 from bd_materialplan where pk_org = '0001A11000000059XIB0' " + "and pk_material = '" + item.getCbmaterialid() + "' " + "and dr=0";//计划信息查询
Map<String, Object> plan = (Map<String, Object>) baseDAO.executeQuery(plansql, new MapProcessor());
if (plan != null && !plan.isEmpty()) {
itemObj.put("drawingNumber", plan.get("def1")); // 图号编码(计划信息查询高压生产中心)
} else {
itemObj.put("drawingNumber", "");
}
Object unit = hybo.findColValue("bd_measdoc", "code", " pk_measdoc = '" + material.get("pk_measdoc") + "' ");
itemObj.put("unit", unit); // 规格单位
// 生产信息

24
mmpac/src/private/nc/bs/mmpac/pmo/pac0002/bp/rule/AfterApproveSyncHighpressureMesRule.java
View File

@ -124,10 +124,16 @@ 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", "计划信息组织"); // 图号编码 graphid
// itemObj.put("drawingNumber", "1234");
Object unit = hybo.findColValue("bd_measdoc", "code", " pk_measdoc = '" + mrl.get("pk_measdoc") + "' ");
String plansql = "select def1 from bd_materialplan where pk_org = '0001A11000000059XIB0' " + "and pk_material = '" + item.getCmaterialvid() + "' " + "and dr=0";//计划信息查询
Map<String, Object> plan = (Map<String, Object>) baseDAO.executeQuery(plansql, new MapProcessor());
if (plan != null && !plan.isEmpty()) {
itemObj.put("drawingNumber", plan.get("def1")); // 图号编码(计划信息查询高压生产中心)
} else {
itemObj.put("drawingNumber", "");
}
Object unit = hybo.findColValue("bd_measdoc", "code", " pk_measdoc = '" + mrl.get("pk_measdoc") + "' ");
itemObj.put("unit", unit); // 单位 pk_measdoc
// 生产信息
@ -184,10 +190,16 @@ 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", "计划信息组织");
Object unit = hybo.findColValue("bd_measdoc", "code", " pk_measdoc = '" + mrl.get("pk_measdoc") + "' ");
String plansql = "select def1 from bd_materialplan where pk_org = '0001A11000000059XIB0' " + "and pk_material = '" + item.getCmaterialvid() + "' " + "and dr=0";//计划信息查询
Map<String, Object> plan = (Map<String, Object>) baseDAO.executeQuery(plansql, new MapProcessor());
if (plan != null && !plan.isEmpty()) {
itemObj.put("drawingNumber", plan.get("def1")); // 图号编码(计划信息查询高压生产中心)
} else {
itemObj.put("drawingNumber", "");
}
Object unit = hybo.findColValue("bd_measdoc", "code", " pk_measdoc = '" + mrl.get("pk_measdoc") + "' ");
itemObj.put("unit", unit); // 单位 pk_measdoc
// 生产信息

9
uapbd/src/private/nc/impl/bd/material/baseinfo/MaterialToGyMesListener.java
View File

@ -109,8 +109,15 @@ public class MaterialToGyMesListener implements IBusinessListener {
singleObj.put("primaryUnit", unitMap.get("measrate").toString().split("/")[0]);
// 主单位
singleObj.put("materialUnit", unitMap.get("measrate").toString().split("/")[1]); // 单位
// singleObj.put("drawingNumber", vo.getGraphid()); // 图号编码
singleObj.put("drawingNumber", "计划信息组织"); // 图号编码("计划信息组织"是高压的图号)
String plansql = "select def1 from bd_materialplan where pk_org = '0001A11000000059XIB0' " + "and pk_material = '" + pkMaterial + "' " + "and dr=0";//计划信息查询
Map<String, Object> plan = (Map<String, Object>) baseDAO.executeQuery(plansql, new MapProcessor());
if (plan != null && !plan.isEmpty()) {
singleObj.put("drawingNumber", plan.get("def1")); // 图号编码(计划信息查询高压生产中心)
} else {
singleObj.put("drawingNumber", "");
}
singleObj.put("enableStatus", enablestate - 1); // 启用状态 0 未启动 1 已启动 2 已停用
singleObj.put("materialType", stockMap.get("martype")); // 物料类型编码
singleObj.put("batchManagement", stockMap.get("wholemanaflag")); // 批次管理

11
uapbd/src/private/nccloud/api/uapbd/material/listener/MaterialToGyMesListener.java
View File

@ -42,6 +42,7 @@ public class MaterialToGyMesListener implements IBusinessListener {
private static final String addUrl = "/bip/order/materialAdd";
private static final String updateUrl = "/bip/order/materialUpdate";
private Map<String, String> configParams;
private BaseDAO baseDAO = new BaseDAO();
@Override
public void doAction(IBusinessEvent event) throws BusinessException {
@ -141,8 +142,16 @@ public class MaterialToGyMesListener implements IBusinessListener {
singleObj.put("primaryUnit", unitMap.get("measrate").toString().split("/")[0]);
// 主单位
singleObj.put("materialUnit", unitMap.get("measrate").toString().split("/")[1]); // 单位
// singleObj.put("drawingNumber", vo.getGraphid()); // 图号编码
singleObj.put("drawingNumber", "计划信息组织"); // 图号编码("计划信息组织"是高压的图号)
String plansql = "select def1 from bd_materialplan where pk_org = '0001A11000000059XIB0' " + "and pk_material = '" + pkMaterial + "' " + "and dr=0";//计划信息查询
Map<String, Object> plan = (Map<String, Object>) baseDAO.executeQuery(plansql, new MapProcessor());
if (plan != null && !plan.isEmpty()) {
singleObj.put("drawingNumber", plan.get("def1")); // 图号编码(计划信息查询高压生产中心)
} else {
singleObj.put("drawingNumber", "");
}
singleObj.put("enableStatus", enablestate - 1); // 启用状态 0 未启动 1 已启动 2 已停用
singleObj.put("materialType", stockMap.get("martype")); // 物料类型编码
singleObj.put("batchManagement", stockMap.get("wholemanaflag")); // 批次管理