diff --git a/uapbd/src/private/nc/impl/bd/material/baseinfo/MaterialToGyMesListener.java b/uapbd/src/private/nc/impl/bd/material/baseinfo/MaterialToGyMesListener.java index 941e82db..460922c9 100644 --- a/uapbd/src/private/nc/impl/bd/material/baseinfo/MaterialToGyMesListener.java +++ b/uapbd/src/private/nc/impl/bd/material/baseinfo/MaterialToGyMesListener.java @@ -42,6 +42,7 @@ public class MaterialToGyMesListener implements IBusinessListener { private static final String updateUrl = "/bip/order/materialUpdate"; private Map configParams; private BaseDAO baseDAO = new BaseDAO(); + private String orgId = ""; public void doAction(IBusinessEvent event) throws BusinessException { BDCommonEvent e = (BDCommonEvent) event; @@ -52,7 +53,7 @@ public class MaterialToGyMesListener implements IBusinessListener { if (configParams.isEmpty()) { throw new BusinessException("高压的gymes接口缺少配置"); } - + orgId = MyHelper.getStrValByCondition(OrgVO.getDefaultTableName(), OrgVO.PK_ORG, OrgVO.CODE + " = 'C046' and ISBUSINESSUNIT = 'Y'"); HYPubBO hyPub = new HYPubBO(); List voList = new ArrayList<>(); for (Object obj : objs) { @@ -217,7 +218,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" + " from bd_materialstock left join bd_stordoc on bd_stordoc.pk_stordoc = bd_materialstock.pk_stordoc " + - " where pk_material = '" + pkMaterial + "' "; + " where pk_material = '" + pkMaterial + "' " + " and bd_materialstock.pk_org = '" + orgId + "' "; Map map = (Map) new BaseDAO().executeQuery(sql, new MapProcessor()); return map; } @@ -228,7 +229,7 @@ public class MaterialToGyMesListener implements IBusinessListener { "FROM " + " bd_materialprod a" + " left join org_dept b on a.pk_prodeptdoc = b.pk_dept " + - " where a.pk_material = '" + pkMaterial + "' "; + " where a.pk_material = '" + pkMaterial + "' " + " and a.pk_org = '" + orgId + "' "; Map map = (Map) new BaseDAO().executeQuery(sql, new MapProcessor()); return map; } diff --git a/uapbd/src/private/nccloud/api/uapbd/material/listener/MaterialToGyMesListener.java b/uapbd/src/private/nccloud/api/uapbd/material/listener/MaterialToGyMesListener.java index 0246ab3b..cb81fabe 100644 --- a/uapbd/src/private/nccloud/api/uapbd/material/listener/MaterialToGyMesListener.java +++ b/uapbd/src/private/nccloud/api/uapbd/material/listener/MaterialToGyMesListener.java @@ -300,7 +300,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" + " from bd_materialstock left join bd_stordoc on bd_stordoc.pk_stordoc = bd_materialstock.pk_stordoc " + - " where pk_material = '" + pkMaterial + "' "; + " where pk_material = '" + pkMaterial + "' " + " and bd_materialstock.pk_org = '" + orgId + "' "; Map map = (Map) new BaseDAO().executeQuery(sql, new MapProcessor()); return map; } @@ -311,7 +311,7 @@ public class MaterialToGyMesListener implements IBusinessListener { "FROM " + " bd_materialprod a" + " left join org_dept b on a.pk_prodeptdoc = b.pk_dept " + - " where a.pk_material = '" + pkMaterial + "' "; + " where a.pk_material = '" + pkMaterial + "' " + " and a.pk_org = '" + orgId + "' "; Map map = (Map) new BaseDAO().executeQuery(sql, new MapProcessor()); return map; }