物料推送高压ims优化字段

This commit is contained in:
lihao 2025-11-05 08:50:37 +08:00
parent d1431ad379
commit 4def8af5ec
1 changed files with 27 additions and 9 deletions

View File

@ -53,14 +53,16 @@ public class MaterialToGyImsListener implements IBusinessListener {
if ((num <= 0)) {
continue;
}else {
String materialid = ((MaterialStockVO) objs[0]).getPk_material();
MaterialVO[] useVOs = (MaterialVO[]) BDCacheQueryUtil.queryVOsByIDs(
MaterialVO.class,
MaterialVO.PK_MATERIAL,
new String[]{materialid},
new String[]{MaterialVO.PK_MEASDOC});
// for (MaterialStockVO stockVO:(MaterialStockVO[])objs ){
String materialid = materialStockVO.getPk_material();
MaterialVO[] useVOs = (MaterialVO[]) BDCacheQueryUtil.queryVOsByIDs(
MaterialVO.class,
MaterialVO.PK_MATERIAL,
new String[]{materialid},
new String[]{MaterialVO.PK_MEASDOC});
pushIms(useVOs);
// }
pushIms(useVOs);
}
}
// String materialid = ((MaterialStockVO) objs[0]).getPk_material();
@ -170,7 +172,7 @@ public class MaterialToGyImsListener implements IBusinessListener {
String[] fields = {
"pk_material", "code", "name", "materialspec", "materialtype",
"materialshortname", "pk_measdoc", "pk_marbasclass", "memo",
"enablestate", "itemtype", "itemattribute", "itemmodel", "status", "createdate"
"enablestate", "itemtype", "itemattribute", "itemmodel", "status", "createdate","itemCode"
};
// 构建字段部分
@ -201,6 +203,16 @@ public class MaterialToGyImsListener implements IBusinessListener {
String unitsql="SELECT code from bd_measdoc where pk_measdoc='" +data.get("pk_measdoc")+ "'";
String unit = (String) new BaseDAO().executeQuery(unitsql,new ColumnProcessor());
data.put("pk_marbasclass",unit);
data.put("createdate",data.get("creationtime"));
// 쉥셕뺍女푯暠뵀렴흙
String def1sql="SELECT p.def1 from bd_materialplan p LEFT JOIN org_stockorg b ON p.pk_org = b.pk_stockorg where p.pk_material='" +data.get("pk_material")+ "' and b.code = '"+configParams.get("imsOrg").toString()+"'";
String def1 = (String) new BaseDAO().executeQuery(def1sql,new ColumnProcessor());
data.put("itemCode",def1);
// 쉥셕좆데貫긍쯤렴흙
String pk_measdocsql="SELECT p.code from bd_measdoc p where p.pk_measdoc='" +data.get("pk_measdoc")+ "' ";
String pk_measdoc = (String) new BaseDAO().executeQuery(pk_measdocsql,new ColumnProcessor());
data.put("pk_measdoc",pk_measdoc);
values.append("(");
@ -274,7 +286,7 @@ public class MaterialToGyImsListener implements IBusinessListener {
String[] fields = {
"pk_material", "code", "name", "materialspec", "materialtype",
"materialshortname", "pk_measdoc", "pk_marbasclass", "memo",
"enablestate", "itemtype", "itemattribute", "itemmodel", "status", "createdate"
"enablestate", "itemtype", "itemattribute", "itemmodel", "status", "createdate","itemCode"
};
for (Map<String, Object> data : remain) {
@ -284,6 +296,7 @@ public class MaterialToGyImsListener implements IBusinessListener {
if (pkMaterial == null) {
continue; // 主键为空时跳过更新
}
data.put("createdate",data.get("creationtime"));
String matBasClassSql="SELECT code from bd_marbasclass where pk_marbasclass='" +data.get("pk_marbasclass")+ "'";
String matbascode = (String) new BaseDAO().executeQuery(matBasClassSql,new ColumnProcessor());
data.put("pk_marbasclass",matbascode);
@ -291,6 +304,11 @@ public class MaterialToGyImsListener implements IBusinessListener {
String unitsql="SELECT code from bd_measdoc where pk_measdoc='" +data.get("pk_measdoc")+ "'";
String unit = (String) new BaseDAO().executeQuery(unitsql,new ColumnProcessor());
data.put("pk_marbasclass",unit);
// 쉥셕뺍女푯暠뵀렴흙
String def1sql="SELECT p.def1 from bd_materialplan p LEFT JOIN org_stockorg b ON p.pk_org = b.pk_stockorg where p.pk_material='" +data.get("pk_material")+ "' and b.code = '"+configParams.get("imsOrg").toString()+"'";
String def1 = (String) new BaseDAO().executeQuery(def1sql,new ColumnProcessor());
data.put("itemCode",def1);
// 构建SET部分
List<String> setParts = new ArrayList<>();
for (String field : fields) {