真空MES-流程生产订单-增加单据类型判断

This commit is contained in:
mzr 2025-12-02 16:52:15 +08:00
parent 1aac295eb6
commit bf5c6aeb5a
1 changed files with 25 additions and 2 deletions

View File

@ -28,6 +28,7 @@ import java.net.URL;
import java.nio.charset.StandardCharsets; import java.nio.charset.StandardCharsets;
import java.util.HashMap; import java.util.HashMap;
import java.util.Map; import java.util.Map;
import java.util.Set;
import java.util.zip.GZIPInputStream; import java.util.zip.GZIPInputStream;
/** /**
@ -122,13 +123,17 @@ public class AfterPmoSyncZkMesRule implements IRule<PMOAggVO> {
private void buildSyncDelData(PMOAggVO[] useVOs) throws BusinessException { private void buildSyncDelData(PMOAggVO[] useVOs) throws BusinessException {
for (PMOAggVO vo : useVOs) { for (PMOAggVO vo : useVOs) {
PMOHeadVO headVO = vo.getParentVO();
PMOItemVO[] itemVOS = vo.getChildrenVO();
// 判断是否是真空公司不是则跳过 // 判断是否是真空公司不是则跳过
String pkOrg = vo.getParentVO().getPk_org(); String pkOrg = headVO.getPk_org();
String orgCode = MyHelper.transferField(OrgVO.getDefaultTableName(), OrgVO.CODE, OrgVO.PK_ORG, pkOrg); String orgCode = MyHelper.transferField(OrgVO.getDefaultTableName(), OrgVO.CODE, OrgVO.PK_ORG, pkOrg);
if (checkIfOrg(orgCode, configParams)) { if (checkIfOrg(orgCode, configParams)) {
continue; continue;
} }
PMOItemVO[] itemVOS = vo.getChildrenVO(); // 判断单据类型部分类型的生产订单推送
String vtrantypecode = headVO.getVtrantypecode();
if (!checkBillType(vtrantypecode)) continue;
// 组装数据 // 组装数据
JSONArray contentArray = new JSONArray(); JSONArray contentArray = new JSONArray();
@ -186,6 +191,24 @@ public class AfterPmoSyncZkMesRule implements IRule<PMOAggVO> {
return true; return true;
} }
/**
* 判断单据类型
*
* @param vtrantypecode 单据类型编码
*/
private boolean checkBillType(String vtrantypecode) {
String typeCodeStr = configParams.get("pmoBillType");
if (MMValueCheck.isNotEmpty(typeCodeStr)) {
if (typeCodeStr.contains(",")) {
Set<String> codeSet = Set.of(typeCodeStr.split(",", -1));
return codeSet.contains(vtrantypecode);
} else {
return typeCodeStr.equals(vtrantypecode);
}
}
return false;
}
/** /**
* 业务请求方法 * 业务请求方法
*/ */