高压物料推送注释调整

This commit is contained in:
mzr 2025-12-02 15:16:24 +08:00
parent 22004d24aa
commit 7654d019e9
4 changed files with 78 additions and 79 deletions

View File

@ -36,6 +36,11 @@ import java.text.SimpleDateFormat;
import java.util.*; import java.util.*;
import java.util.stream.Stream; import java.util.stream.Stream;
/**
* 描述:物料同步到高压mes-已弃用
*
* @author lihao
*/
public class MaterialToGyMesTaskPlugin implements IBackgroundWorkPlugin { public class MaterialToGyMesTaskPlugin implements IBackgroundWorkPlugin {
private HYSuperDMO superDMO = null; private HYSuperDMO superDMO = null;
private static final String LOG_INFO_NAME = "gymeslog"; private static final String LOG_INFO_NAME = "gymeslog";
@ -44,6 +49,7 @@ public class MaterialToGyMesTaskPlugin implements IBackgroundWorkPlugin {
private static final String updateUrl = "/bip/order/materialUpdate"; private static final String updateUrl = "/bip/order/materialUpdate";
private Map<String, String> configParams; private Map<String, String> configParams;
private String orgId = ""; private String orgId = "";
public HYSuperDMO getSuperDMO() { public HYSuperDMO getSuperDMO() {
if (superDMO == null) { if (superDMO == null) {
@ -52,6 +58,7 @@ public class MaterialToGyMesTaskPlugin implements IBackgroundWorkPlugin {
return superDMO; return superDMO;
} }
@Override @Override
public PreAlertObject executeTask(BgWorkingContext arg0) throws BusinessException { public PreAlertObject executeTask(BgWorkingContext arg0) throws BusinessException {
Logger.error("---start----ÈÎÎñ¿ªÊ¼ÔËÐÐ--"); Logger.error("---start----ÈÎÎñ¿ªÊ¼ÔËÐÐ--");

View File

@ -30,7 +30,7 @@ import java.util.*;
import java.util.stream.Stream; import java.util.stream.Stream;
/** /**
* 高压MES-物料新增后同步 * 高压MES-物料新增后同步-已弃用
* *
* @author lihao * @author lihao
* @date 2025/09/11 * @date 2025/09/11

View File

@ -1,32 +1,27 @@
package nccloud.api.uapbd.material.listener; package nccloud.api.uapbd.material.listener;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.alibaba.fastjson.serializer.SerializerFeature;
import nc.bs.bd.assignservice.multiorg.MultiOrgAssignVO;
import nc.bs.bd.baseservice.ArrayClassConvertUtil; import nc.bs.bd.baseservice.ArrayClassConvertUtil;
import nc.bs.businessevent.IBusinessEvent; import nc.bs.businessevent.IBusinessEvent;
import nc.bs.businessevent.IBusinessListener; import nc.bs.businessevent.IBusinessListener;
import nc.bs.businessevent.bd.BDCommonEvent; import nc.bs.businessevent.bd.BDCommonEvent;
import nc.bs.dao.BaseDAO; import nc.bs.dao.BaseDAO;
import nc.bs.dao.DAOException;
import nc.bs.logging.Log; import nc.bs.logging.Log;
import nc.bs.trade.business.HYPubBO;
import nc.bs.uapbd.util.MyHelper; import nc.bs.uapbd.util.MyHelper;
import nc.bs.uapbd.util.ThirdPartyPostRequestUtil;
import nc.jdbc.framework.processor.ColumnProcessor; import nc.jdbc.framework.processor.ColumnProcessor;
import nc.jdbc.framework.processor.MapListProcessor; import nc.jdbc.framework.processor.MapListProcessor;
import nc.jdbc.framework.processor.MapProcessor;
import nc.vo.bd.material.MaterialVO; import nc.vo.bd.material.MaterialVO;
import nc.vo.bd.material.marbasclass.MarBasClassVO;
import nc.vo.bd.material.stock.MaterialStockVO; import nc.vo.bd.material.stock.MaterialStockVO;
import nc.vo.bd.pub.BDCacheQueryUtil; import nc.vo.bd.pub.BDCacheQueryUtil;
import nc.vo.fi.pub.SqlUtils;
import nc.vo.org.OrgVO; import nc.vo.org.OrgVO;
import nc.vo.pub.BusinessException; import nc.vo.pub.BusinessException;
import java.util.*; import java.util.*;
/**
* 描述:物料同步到高压IMS-已弃用
*
* @author lihao
*/
public class MaterialToGyImsListener implements IBusinessListener { public class MaterialToGyImsListener implements IBusinessListener {
private static final String LOG_INFO_NAME = "dldzlog"; private static final String LOG_INFO_NAME = "dldzlog";
private static final Log logDl = Log.getInstance(LOG_INFO_NAME); private static final Log logDl = Log.getInstance(LOG_INFO_NAME);
@ -80,7 +75,6 @@ public class MaterialToGyImsListener implements IBusinessListener {
updateEnableStatus(useVOs); updateEnableStatus(useVOs);
} else if ("1012".equals(eventType)) { } else if ("1012".equals(eventType)) {
configParams = MyHelper.getConfigParams("gy-config", null); configParams = MyHelper.getConfigParams("gy-config", null);
if (configParams.isEmpty()) { if (configParams.isEmpty()) {
@ -109,9 +103,9 @@ public class MaterialToGyImsListener implements IBusinessListener {
updateIms(useVOs); updateIms(useVOs);
}
}
}
}
public static boolean contains(String[] orgItem, String target) { public static boolean contains(String[] orgItem, String target) {
// 数组为null时直接返回false // 数组为null时直接返回false
if (orgItem == null) { if (orgItem == null) {
@ -252,7 +246,6 @@ public class MaterialToGyImsListener implements IBusinessListener {
String updateSql = "INSERT INTO BIPItemTab (" + fieldNames.toString() + ") VALUES " + values.toString(); String updateSql = "INSERT INTO BIPItemTab (" + fieldNames.toString() + ") VALUES " + values.toString();
try { try {
int rowsAffected = gyimsDao.executeUpdate(updateSql); int rowsAffected = gyimsDao.executeUpdate(updateSql);
@ -261,6 +254,7 @@ public class MaterialToGyImsListener implements IBusinessListener {
throw new RuntimeException("插入失败:" + e.getMessage(), e); throw new RuntimeException("插入失败:" + e.getMessage(), e);
} }
} }
private void updateStatus(String pk, String type) throws BusinessException { private void updateStatus(String pk, String type) throws BusinessException {
BaseDAO gyimsDao = new BaseDAO("gyims"); BaseDAO gyimsDao = new BaseDAO("gyims");
gyimsDao.setAddTimeStamp(false); gyimsDao.setAddTimeStamp(false);
@ -353,6 +347,4 @@ public class MaterialToGyImsListener implements IBusinessListener {
} }
} }

View File

@ -33,7 +33,7 @@ import java.util.*;
import java.util.stream.Stream; import java.util.stream.Stream;
/** /**
* 高压MES-物料修改后同步 * 高压MES-物料修改后同步-已弃用
* *
* @author mzr * @author mzr
* @date 2025/09/11 * @date 2025/09/11