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

高压mes-物料-推送调整

This commit is contained in:
mzr 2025-10-09 18:37:43 +08:00
parent 721fdb22c2
commit da276076bf
2 changed files with 9 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -4,7 +4,6 @@ import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONArray; import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject; import com.alibaba.fastjson.JSONObject;
import com.alibaba.fastjson.serializer.SerializerFeature; import com.alibaba.fastjson.serializer.SerializerFeature;
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;
@ -13,7 +12,6 @@ import nc.bs.framework.common.NCLocator;
import nc.bs.logging.Log; import nc.bs.logging.Log;
import nc.bs.uapbd.util.MyHelper; import nc.bs.uapbd.util.MyHelper;
import nc.bs.uapbd.util.ThirdPartyPostRequestUtil; import nc.bs.uapbd.util.ThirdPartyPostRequestUtil;
import nc.itf.scmpub.reference.uap.bd.material.MaterialPubService;
import nc.jdbc.framework.processor.MapProcessor; import nc.jdbc.framework.processor.MapProcessor;
import nc.pubitf.uapbd.IMaterialPubService; import nc.pubitf.uapbd.IMaterialPubService;
import nc.util.mmf.framework.base.MMValueCheck; import nc.util.mmf.framework.base.MMValueCheck;
@ -33,7 +31,12 @@ import java.util.List;
import java.util.Map; import java.util.Map;
import java.util.Objects; import java.util.Objects;
import java.util.stream.Stream; import java.util.stream.Stream;
/**
* 高压MES-物料新增后同步
*
* @author lihao
* @date 2025/09/11
*/
public class MaterialToGyMesListener implements IBusinessListener { public class MaterialToGyMesListener implements IBusinessListener {
private static final String LOG_INFO_NAME = "gyMesLog"; private static final String LOG_INFO_NAME = "gyMesLog";
private static final Log logger = Log.getInstance(LOG_INFO_NAME); private static final Log logger = Log.getInstance(LOG_INFO_NAME);
@ -61,7 +64,7 @@ public class MaterialToGyMesListener implements IBusinessListener {
* ¹¹½¨Í¬²½Êý¾Ý * ¹¹½¨Í¬²½Êý¾Ý
*/ */
private void buildSyncData(MaterialVO[] useVOs, String eventType) throws BusinessException { private void buildSyncData(MaterialVO[] useVOs, String eventType) throws BusinessException {
String orgId = MyHelper.transferField(OrgVO.getDefaultTableName(), OrgVO.PK_ORG, OrgVO.CODE, "C003"); String orgId = MyHelper.transferField(OrgVO.getDefaultTableName(), OrgVO.PK_ORG, OrgVO.CODE, "C046");
JSONArray dataArr = new JSONArray(); JSONArray dataArr = new JSONArray();
for (MaterialVO vo : useVOs) { for (MaterialVO vo : useVOs) {
String pkMaterial = vo.getPk_material(); String pkMaterial = vo.getPk_material();

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

@ -31,7 +31,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
@ -96,7 +96,7 @@ public class MaterialToGyMesListener implements IBusinessListener {
* 构建同步数据 * 构建同步数据
*/ */
private void buildSyncData(MaterialVO[] useVOs, String eventType) throws BusinessException { private void buildSyncData(MaterialVO[] useVOs, String eventType) throws BusinessException {
String orgId = MyHelper.transferField(OrgVO.getDefaultTableName(), OrgVO.PK_ORG, OrgVO.CODE, "C003"); String orgId = MyHelper.transferField(OrgVO.getDefaultTableName(), OrgVO.PK_ORG, OrgVO.CODE, "C046");
JSONArray dataArr = new JSONArray(); JSONArray dataArr = new JSONArray();
for (MaterialVO vo : useVOs) { for (MaterialVO vo : useVOs) {
String pkMaterial = vo.getPk_material(); String pkMaterial = vo.getPk_material();