物料新增修改mes接口 字段优化

This commit is contained in:
houyi 2025-10-21 15:53:50 +08:00
parent 7e7300cb26
commit 9cd6448cae
2 changed files with 14 additions and 2 deletions

View File

@ -80,6 +80,7 @@ public class MaterialToGyMesListener implements IBusinessListener {
* 构建同步数据
*/
private void buildSyncData(MaterialVO[] useVOs, String eventType) throws BusinessException {
BaseDAO baseDAO = new BaseDAO();
JSONArray dataArr = new JSONArray();
for (MaterialVO vo : useVOs) {
String pkMaterial = vo.getPk_material();
@ -137,6 +138,11 @@ public class MaterialToGyMesListener implements IBusinessListener {
singleObj.put("backflushMethod", prodMap.get("conversemethod")); // 倒冲方式
singleObj.put("postCompletionProcessing", prodMap.get("wghxcl")); // 完工后续处理
}
// ¿â´æ¹©»õ×éÖ¯±àÂë»ñÈ¡
String mrlsql = "select code from org_stockorg where pk_stockorg = '" + stockMap.get("pk_suplystockorg") + "' ";
Map<String, Object> stockorg = (Map<String, Object>) baseDAO.executeQuery(mrlsql, new MapProcessor());
singleObj.put("supplyInventoryOrg", stockorg.get("code"));// ¿â´æ¹©»õ×éÖ¯
singleObj.put("bipCreateBy", creatorName); // 创建人
dataArr.add(singleObj);
/**
@ -215,7 +221,7 @@ public class MaterialToGyMesListener implements IBusinessListener {
}
private Map getStockInfo(String pkMaterial) throws BusinessException {
String sql = " select martype, wholemanaflag, outpriority, remain,bd_stordoc.code as pk_stordoc" +
String sql = " select pk_suplystockorg, martype, wholemanaflag, outpriority, remain,bd_stordoc.code as pk_stordoc" +
" from bd_materialstock left join bd_stordoc on bd_stordoc.pk_stordoc = bd_materialstock.pk_stordoc " +
" where pk_material = '" + pkMaterial + "' " + " and bd_materialstock.pk_org = '" + orgId + "' ";
Map map = (Map) new BaseDAO().executeQuery(sql, new MapProcessor());

View File

@ -116,6 +116,7 @@ public class MaterialToGyMesListener implements IBusinessListener {
* 构建同步数据
*/
private void buildSyncData(MaterialVO[] useVOs, String eventType) throws BusinessException {
BaseDAO baseDAO = new BaseDAO();
JSONArray dataArr = new JSONArray();
for (MaterialVO vo : useVOs) {
String pkMaterial = vo.getPk_material();
@ -172,6 +173,11 @@ public class MaterialToGyMesListener implements IBusinessListener {
singleObj.put("backflushMethod", prodMap.get("conversemethod")); // 倒冲方式
singleObj.put("postCompletionProcessing", prodMap.get("wghxcl")); // 完工后续处理
}
// ¿â´æ¹©»õ×éÖ¯±àÂë»ñÈ¡
String mrlsql = "select code from org_stockorg where pk_stockorg = '" + stockMap.get("pk_suplystockorg") + "' ";
Map<String, Object> stockorg = (Map<String, Object>) baseDAO.executeQuery(mrlsql, new MapProcessor());
singleObj.put("supplyInventoryOrg", stockorg.get("code"));// ¿â´æ¹©»õ×éÖ¯
singleObj.put("bipCreateBy", creatorName); // 创建人
dataArr.add(singleObj);
/**
@ -298,7 +304,7 @@ public class MaterialToGyMesListener implements IBusinessListener {
}
private Map getStockInfo(String pkMaterial) throws BusinessException {
String sql = " select martype, wholemanaflag, outpriority, remain,bd_stordoc.code as pk_stordoc" +
String sql = " select pk_suplystockorg, martype, wholemanaflag, outpriority, remain,bd_stordoc.code as pk_stordoc" +
" from bd_materialstock left join bd_stordoc on bd_stordoc.pk_stordoc = bd_materialstock.pk_stordoc " +
" where pk_material = '" + pkMaterial + "' " + " and bd_materialstock.pk_org = '" + orgId + "' ";
Map map = (Map) new BaseDAO().executeQuery(sql, new MapProcessor());