高压MES推物料
This commit is contained in:
mzr
parent
28713967b3
commit
ba87df5020
|
|
@ -0,0 +1,254 @@
|
||||||
|
package nccloud.api.uapbd.material.listener;
|
||||||
|
|
||||||
|
import com.alibaba.fastjson.JSON;
|
||||||
|
import com.alibaba.fastjson.JSONArray;
|
||||||
|
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.businessevent.IBusinessEvent;
|
||||||
|
import nc.bs.businessevent.IBusinessListener;
|
||||||
|
import nc.bs.businessevent.bd.BDCommonEvent;
|
||||||
|
import nc.bs.dao.BaseDAO;
|
||||||
|
import nc.bs.framework.common.NCLocator;
|
||||||
|
import nc.bs.logging.Log;
|
||||||
|
import nc.bs.trade.business.HYPubBO;
|
||||||
|
import nc.bs.uapbd.util.MyHelper;
|
||||||
|
import nc.bs.uapbd.util.ThirdPartyPostRequestUtil;
|
||||||
|
import nc.jdbc.framework.processor.MapProcessor;
|
||||||
|
import nc.pubitf.uapbd.IMaterialPubService;
|
||||||
|
import nc.util.mmf.framework.base.MMValueCheck;
|
||||||
|
import nc.vo.am.common.util.StringUtils;
|
||||||
|
import nc.vo.bd.material.MaterialVO;
|
||||||
|
import nc.vo.bd.material.marbasclass.MarBasClassVO;
|
||||||
|
import nc.vo.bd.material.plan.MaterialPlanVO;
|
||||||
|
import nc.vo.org.OrgVO;
|
||||||
|
import nc.vo.pub.BusinessException;
|
||||||
|
import nc.vo.pub.lang.UFBoolean;
|
||||||
|
import nc.vo.sm.UserVO;
|
||||||
|
|
||||||
|
import java.util.*;
|
||||||
|
import java.util.stream.Stream;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 高压MES-物料新增修改后同步
|
||||||
|
*
|
||||||
|
* @author mzr
|
||||||
|
* @date 2025/09/11
|
||||||
|
*/
|
||||||
|
public class MaterialToGyMesListener implements IBusinessListener {
|
||||||
|
private static final String LOG_INFO_NAME = "gyMesLog";
|
||||||
|
private static final Log logger = Log.getInstance(LOG_INFO_NAME);
|
||||||
|
private static final String addUrl = "/bip/order/materialAdd";
|
||||||
|
private static final String updateUrl = "/bip/order/materialUpdate";
|
||||||
|
private Map<String, String> configParams;
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public void doAction(IBusinessEvent event) throws BusinessException {
|
||||||
|
BDCommonEvent e = (BDCommonEvent) event;
|
||||||
|
String eventType = event.getEventType();
|
||||||
|
Object[] objs = e.getObjs();
|
||||||
|
|
||||||
|
// EventType是事件编码 1002-新增后 1004-修改后 1071-状态由停用变为启用后 1069-状态由启用变为停用后
|
||||||
|
if ("1004".equals(eventType)) {
|
||||||
|
MaterialVO[] useVOs = ArrayClassConvertUtil.convert(objs, MaterialVO.class);
|
||||||
|
configParams = MyHelper.getConfigParams("jm-config", null);
|
||||||
|
if (configParams.isEmpty()) {
|
||||||
|
throw new BusinessException("高压的gymes接口缺少配置");
|
||||||
|
}
|
||||||
|
buildSyncData(useVOs, eventType);
|
||||||
|
} else if ("1071".equals(eventType) || "1069".equals(eventType)) {
|
||||||
|
MaterialVO[] useVOs = ArrayClassConvertUtil.convert(objs, MaterialVO.class);
|
||||||
|
configParams = MyHelper.getConfigParams("jm-config", null);
|
||||||
|
if (configParams.isEmpty()) {
|
||||||
|
throw new BusinessException("高压的gymes接口缺少配置");
|
||||||
|
}
|
||||||
|
buildSyncData(useVOs, eventType);
|
||||||
|
} else if ("1009".equals(eventType)) {
|
||||||
|
// 物料可见性范围-分配后 1009
|
||||||
|
configParams = MyHelper.getConfigParams("jm-config", null);
|
||||||
|
if (configParams.isEmpty()) {
|
||||||
|
throw new BusinessException("高压的gymes接口缺少配置");
|
||||||
|
}
|
||||||
|
HYPubBO hyPub = new HYPubBO();
|
||||||
|
List<MaterialVO> voList = new ArrayList<>();
|
||||||
|
for (Object obj : objs) {
|
||||||
|
MultiOrgAssignVO vo = (MultiOrgAssignVO) obj;
|
||||||
|
String pkMaterial = vo.getPk_doc();
|
||||||
|
String pkOrg = vo.getPk_org();
|
||||||
|
String orgCode = (String) hyPub.findColValue(OrgVO.getDefaultTableName(), OrgVO.CODE, "dr =0 and pk_org = '" + pkOrg + "' ");
|
||||||
|
// 检查当前组织是否为高压
|
||||||
|
if (checkIfOrg(orgCode, configParams)) {
|
||||||
|
continue;
|
||||||
|
}
|
||||||
|
MaterialVO materialVO = (MaterialVO) hyPub.queryByPrimaryKey(MaterialVO.class, pkMaterial);
|
||||||
|
voList.add(materialVO);
|
||||||
|
}
|
||||||
|
if (!voList.isEmpty()) {
|
||||||
|
MaterialVO[] useVOs = voList.toArray(new MaterialVO[0]);
|
||||||
|
buildSyncData(useVOs, eventType);
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 构建同步数据
|
||||||
|
*/
|
||||||
|
private void buildSyncData(MaterialVO[] useVOs, String eventType) throws BusinessException {
|
||||||
|
String orgId = MyHelper.transferField(OrgVO.getDefaultTableName(), OrgVO.PK_ORG, OrgVO.CODE, "C003");
|
||||||
|
JSONArray dataArr = new JSONArray();
|
||||||
|
for (MaterialVO vo : useVOs) {
|
||||||
|
String pkMaterial = vo.getPk_material();
|
||||||
|
// 判断物料的业务单元是否是高压公司，不是则跳过
|
||||||
|
// String pkOrg = vo.getPk_org();
|
||||||
|
Integer num = MyHelper.checkIfOrg(configParams, pkMaterial, "gyOrg");
|
||||||
|
if (!"1009".equals(eventType) && (num <= 0)) {
|
||||||
|
continue;
|
||||||
|
}
|
||||||
|
// 字段值翻译
|
||||||
|
String pk_marbasclass = vo.getPk_marbasclass();
|
||||||
|
String mrlTypeName = MyHelper.getStrValByCondition(MarBasClassVO.getDefaultTableName(), MarBasClassVO.NAME,
|
||||||
|
"pk_marbasclass = '" + pk_marbasclass + "'");
|
||||||
|
// 计量单位
|
||||||
|
Map unitMap = getGoodsInfo(pkMaterial);
|
||||||
|
Map<String, MaterialPlanVO> planMap = queryMaterialPlanInfoByPks(new String[]{pkMaterial}, orgId,
|
||||||
|
new String[]{MaterialPlanVO.ISVIRTUAL});
|
||||||
|
UFBoolean isvirtual = new UFBoolean(false);
|
||||||
|
if (MMValueCheck.isNotEmpty(planMap) &&
|
||||||
|
MMValueCheck.isNotEmpty(planMap.get(pkMaterial))) {
|
||||||
|
isvirtual = planMap.get(pkMaterial).getIsvirtual();
|
||||||
|
}
|
||||||
|
// creator 创建人
|
||||||
|
String creator = vo.getCreator();
|
||||||
|
String creatorName = MyHelper.getStrValByCondition("sm_user", UserVO.USER_NAME,
|
||||||
|
UserVO.CUSERID + " = '" + creator + "'");
|
||||||
|
// 1=未启用;2=已启用;3=已停用;
|
||||||
|
Integer enablestate = vo.getEnablestate();
|
||||||
|
// 组装数据
|
||||||
|
JSONObject singleObj = new JSONObject();
|
||||||
|
singleObj.put("materialCode", vo.getCode()); // 物料编码
|
||||||
|
singleObj.put("bipMaterialId", pkMaterial); // 物料主键
|
||||||
|
singleObj.put("materialName", vo.getName()); // 物料名称
|
||||||
|
singleObj.put("materialCategory", ""); // 物料分类
|
||||||
|
singleObj.put("specification", vo.getMaterialspec()); // 规格
|
||||||
|
singleObj.put("intervalModel", ""); // 产品类型 例如35-KV-断路器（物料自定义字段）
|
||||||
|
singleObj.put("primaryUnit", unitMap.get("unitname")); // 主单位
|
||||||
|
singleObj.put("materialUnit", unitMap.get("deputy_unitname")); // 单位
|
||||||
|
singleObj.put("drawingNumber", vo.getGraphid()); // 图号编码
|
||||||
|
singleObj.put("enableStatus", enablestate - 1); // 启用状态 0 未启动 1 已启动 2 已停用
|
||||||
|
singleObj.put("materialType", ""); // 物料类型编码
|
||||||
|
singleObj.put("batchManagement", ""); // 批次管理
|
||||||
|
singleObj.put("outboundPriority", ""); // 出库优先级
|
||||||
|
singleObj.put("mainWarehouse", ""); // 主仓库
|
||||||
|
singleObj.put("reservation", ""); // 预留
|
||||||
|
singleObj.put("virtualItem", isvirtual.toString()); // 虚项
|
||||||
|
singleObj.put("productionDepartment", ""); // 生产部门编码
|
||||||
|
singleObj.put("matchingComponents", ""); // 配套子件
|
||||||
|
singleObj.put("issuance", ""); // 发料
|
||||||
|
singleObj.put("backflushMethod", ""); // 倒冲方式
|
||||||
|
singleObj.put("postCompletionProcessing", ""); // 完工后续处理
|
||||||
|
singleObj.put("bipCreateBy", creatorName); // 创建人
|
||||||
|
dataArr.add(singleObj);
|
||||||
|
/**
|
||||||
|
* {
|
||||||
|
* "list": [
|
||||||
|
* {
|
||||||
|
* "materialCode": "物料编码",
|
||||||
|
* "bipMaterialId": "物料主键",
|
||||||
|
* "materialName": "物料名称",
|
||||||
|
* "materialCategory": "物料分类",
|
||||||
|
* "specification": "规格例如 台 件",
|
||||||
|
* "intervalModel": "产品类型 例如35-KV-断路器（物料自定义字段）",
|
||||||
|
* "primaryUnit": "主单位例如 1 ",
|
||||||
|
* "materialUnit": "单位例如 1 ",
|
||||||
|
* "drawingNumber": "图号编码 如 X56434 高压",
|
||||||
|
* "enableStatus": "启用状态 0 未启动 1 已启动 2 已停用",
|
||||||
|
* "materialType": "物料类型编码",
|
||||||
|
* "batchManagement": "批次管理",
|
||||||
|
* "outboundPriority": "出库优先级 按BIP类型",
|
||||||
|
* "mainWarehouse": "主仓库 按BIP类型",
|
||||||
|
* "reservation": "预留 按BIP类型",
|
||||||
|
* "virtualItem": "虚项 按BIP类型",
|
||||||
|
* "productionDepartment": "生产部门编码 按BIP类型",
|
||||||
|
* "matchingComponents": "配套子件 按BIP类型",
|
||||||
|
* "issuance": "发料 按BIP类型",
|
||||||
|
* "backflushMethod": "倒冲方式 按BIP类型",
|
||||||
|
* "postCompletionProcessing": "完工后续处理 按BIP类型",
|
||||||
|
* "bipCreateBy": "创建人"
|
||||||
|
* }
|
||||||
|
* ]
|
||||||
|
* }
|
||||||
|
*/
|
||||||
|
}
|
||||||
|
if (!dataArr.isEmpty()) {
|
||||||
|
pushData(dataArr);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 推送同步数据
|
||||||
|
*/
|
||||||
|
private void pushData(JSONArray param) throws BusinessException {
|
||||||
|
// String jsonString = param.toJSONString();
|
||||||
|
// 转json字符串的时候保留null值
|
||||||
|
String jsonStr = JSON.toJSONString(param,
|
||||||
|
SerializerFeature.WriteMapNullValue,
|
||||||
|
SerializerFeature.WriteNullStringAsEmpty
|
||||||
|
);
|
||||||
|
logger.error("gymes-Material-param = " + jsonStr);
|
||||||
|
// NCCForUAPLogger.debug("gymes-Material-param = " + jsonStr);
|
||||||
|
String baseUrl = configParams.get("gymesBaseUrl");
|
||||||
|
String requestUrl = baseUrl + addUrl;
|
||||||
|
logger.error("gymes-Material-url = " + requestUrl);
|
||||||
|
String result = ThirdPartyPostRequestUtil.sendPostRequest(requestUrl, jsonStr);
|
||||||
|
JSONObject resultObj = JSONObject.parseObject(result);
|
||||||
|
logger.error("gymes-Material-res = " + result);
|
||||||
|
|
||||||
|
if (!"200".equals(resultObj.getString("code"))) {
|
||||||
|
// throw new BusinessException("gymes-Material-error:" + resultObj.getString("msg"));
|
||||||
|
logger.error("gymes-Material-error,result[" + resultObj.toJSONString() + "]");
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
private Map getGoodsInfo(String pkMaterial) throws BusinessException {
|
||||||
|
String sql = " select a.pk_measdoc, c.name unitname, b.pk_measdoc deputyUnit, d.name deputy_unitname, nvl(b.measrate, '1/1') measrate " +
|
||||||
|
"from bd_material a " +
|
||||||
|
"left join bd_materialconvert b on a.pk_material = b.pk_material " +
|
||||||
|
"left join bd_measdoc c on a.pk_measdoc = c.pk_measdoc " +
|
||||||
|
"left join bd_measdoc d on b.pk_measdoc = d.pk_measdoc " +
|
||||||
|
"where a.pk_material = '" + pkMaterial + "' ";
|
||||||
|
Map map = (Map) new BaseDAO().executeQuery(sql, new MapProcessor());
|
||||||
|
// map.put("convertRate", MyHelper.transferSpecialField(map.get("measrate") + ""));
|
||||||
|
return map;
|
||||||
|
}
|
||||||
|
|
||||||
|
private boolean checkIfOrg(String code, Map<String, String> configParams) throws BusinessException {
|
||||||
|
String targetCode = configParams.get("jmOrg");
|
||||||
|
if (targetCode == null || StringUtils.isEmpty(targetCode)) {
|
||||||
|
throw new BusinessException("未配置组织参数");
|
||||||
|
}
|
||||||
|
String[] orgItem = targetCode.split(",");
|
||||||
|
for (String orgCode : orgItem) {
|
||||||
|
if (!orgCode.isEmpty() && orgCode.equals(code)) {
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
return true;
|
||||||
|
}
|
||||||
|
|
||||||
|
public static Map<String, MaterialPlanVO> queryMaterialPlanInfoByPks(String[] pks, String pk_stockorg,
|
||||||
|
String[] fields) throws BusinessException {
|
||||||
|
Map<String, MaterialPlanVO> map = null;
|
||||||
|
List<String> vids = Stream.of(pks).filter(Objects::nonNull).distinct().toList();
|
||||||
|
if (vids.isEmpty()) {
|
||||||
|
map = new HashMap<>();
|
||||||
|
} else {
|
||||||
|
map = NCLocator.getInstance().lookup(IMaterialPubService.class)
|
||||||
|
.queryMaterialPlanInfoByPks(vids.toArray(new String[0]), pk_stockorg, fields);
|
||||||
|
}
|
||||||
|
|
||||||
|
return map;
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
Loading…
Reference in New Issue