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

箱变公司MRP计划订单推送生产订单时生成相同的生产批次号

This commit is contained in:
lihao 2025-09-11 10:59:42 +08:00
parent 51d55b9d18
commit 543f9965ef
1 changed files with 88 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

96
mmpac/src/private/nc/bs/mmpac/pmo/pac0002/rule/fill/PMOFillBatchCodeRule.java
View File

@ -12,13 +12,12 @@ import java.util.Map;
import java.util.Set;
import nc.bs.framework.common.NCLocator;
import nc.bs.mmpac.pmo.pac0002.bp.service.PMOBPService;
import nc.bs.trade.business.HYPubBO;
import nc.impl.pubapp.pattern.rule.IRule;
import nc.pub.billcode.itf.IBillcodeManage;
import nc.uif.pub.exception.UifException;
import nc.util.mmf.busi.service.MaterialPubService;
import nc.util.mmf.framework.base.MMArrayUtil;
import nc.util.mmf.framework.base.MMCollectionUtil;
import nc.util.mmf.framework.base.MMMapUtil;
import nc.util.mmf.framework.base.MMValueCheck;
import nc.util.mmf.framework.base.*;
import nc.vo.bd.material.prod.MaterialProdVO;
import nc.vo.mmpac.pickm.param.PickmTransParamForMO;
import nc.vo.mmpac.pmo.pac0002.constant.PMOConstLang;
@ -27,6 +26,7 @@ import nc.vo.mmpac.pmo.pac0002.entity.PMOHeadVO;
import nc.vo.mmpac.pmo.pac0002.entity.PMOItemVO;
import nc.vo.mmpac.pmo.pac0002.enumeration.PMOFItemStatusEnum;
import nc.vo.mmpac.pmo.pac0002.util.PMOTransferUtil;
import nc.vo.org.OrgVO;
import nc.vo.pd.pd0332.entity.PbEventParamVO;
import nc.vo.pd.pd0332.entity.PbParamVO;
import nc.vo.pub.BusinessException;
@ -38,10 +38,14 @@ public class PMOFillBatchCodeRule implements IRule<PMOAggVO> {
}
public void process(PMOAggVO[] aggvos) {
this.fillBatchCode(aggvos);
try {
this.fillBatchCode(aggvos);
} catch (UifException e) {
throw new RuntimeException(e);
}
}
private void fillBatchCode(PMOAggVO[] aggvos) {
private void fillBatchCode(PMOAggVO[] aggvos) throws UifException {
PMOItemVO[] filteritems = this.getItemByBatchCode(aggvos);
if (!MMArrayUtil.isEmpty(filteritems)) {
Map<String, PMOHeadVO> headMap = new HashMap();
@ -81,6 +85,8 @@ public class PMOFillBatchCodeRule implements IRule<PMOAggVO> {
needbatcodeList.add(itemVO);
} else if (PMOFItemStatusEnum.PLAN.equalsValue(itemVO.getFitemstatus()) && provo.getPchscscd() == 3) {
needbatcodeList.add(itemVO);
} else if (PMOFItemStatusEnum.PLAN.equalsValue(itemVO.getFitemstatus()) && provo.getPchscscd() == 0) {
needbatcodeList.add(itemVO);
}
}
}
@ -116,14 +122,24 @@ public class PMOFillBatchCodeRule implements IRule<PMOAggVO> {
}
}
private void genBatchCode(PMOItemVO[] paravos, Map<String, PMOHeadVO> headMap) {
private void genBatchCode(PMOItemVO[] paravos, Map<String, PMOHeadVO> headMap) throws UifException {
if (!MMArrayUtil.isEmpty(paravos)) {
List<PMOItemVO> itemList = new ArrayList();
List<PMOItemVO> xbitemList = new ArrayList();
HYPubBO hybo = new HYPubBO();
String org = hybo.findColValue("org_adminorg", "pk_adminorg", " code = 'C030' ") + "";
for(PMOItemVO vo : paravos) {
itemList.add(vo);
if(vo.getPk_org().equals(org)) {
xbitemList.add(vo);
}else{
itemList.add(vo);
}
}
if (itemList.size() > 0) {
PMOItemVO[] vos = (PMOItemVO[])itemList.toArray(new PMOItemVO[itemList.size()]);
IBillcodeManage billcodeManage = (IBillcodeManage)NCLocator.getInstance().lookup(IBillcodeManage.class);
@ -188,6 +204,70 @@ public class PMOFillBatchCodeRule implements IRule<PMOAggVO> {
}
}
if (xbitemList.size() > 0) {
PMOItemVO[] vos = (PMOItemVO[])xbitemList.toArray(new PMOItemVO[itemList.size()]);
IBillcodeManage billcodeManage = (IBillcodeManage)NCLocator.getInstance().lookup(IBillcodeManage.class);
String[] billcodes = null;
try {
billcodes = billcodeManage.getBatchBillCodes_RequiresNew("55A2-2", vos[0].getPk_group(), vos[0].getPk_org(), vos[0],1);
} catch (BusinessException ex) {
ExceptionUtils.wrappException(ex);
}
if (MMStringUtil.isEmpty(billcodes[0])) {
ExceptionUtils.wrappBusinessException(PMOConstLang.getMSG_RULE_PUT_BATCHCODECREATE_CHECK());
}
int i = 0;
List<PbEventParamVO> eparaList = new ArrayList();
for(PMOItemVO vo : vos) {
vo.setVbatchcode(billcodes[0]);
if (!MMValueCheck.isEmpty(vo.getVbatchcode())) {
PbParamVO paravo = PMOTransferUtil.getBatchParamVO((PMOHeadVO)headMap.get(vo.getCpmohid()), vo, false);
PbEventParamVO eparavo = new PbEventParamVO(paravo, (PbParamVO)null, (PbParamVO)null, (PbParamVO)null);
eparaList.add(eparavo);
}
}
Map<String, PbParamVO> ResultParamVOMap = PMOBPService.getIPbMaintainServiceForPac().batchSavePdParamVO((PbEventParamVO[])eparaList.toArray(new PbEventParamVO[eparaList.size()]));
if (MMMapUtil.isEmpty(ResultParamVOMap)) {
return;
}
for(PMOItemVO item : vos) {
PMOHeadVO headvo = (PMOHeadVO)headMap.get(item.getCpmohid());
if (!MMValueCheck.isEmpty(item.getVbatchcode())) {
String var10001 = headvo.getPk_org();
PbParamVO paravo = (PbParamVO)ResultParamVOMap.get(var10001 + headvo.getVbillcode() + item.getVrowno());
if (!MMValueCheck.isEmpty(paravo)) {
item.setVbatchcode(paravo.getVprodbatchcode());
item.setCbatchid(paravo.getPk_batchcode());
}
}
}
try {
List<PickmTransParamForMO> paramList = new ArrayList();
for(PMOItemVO vo : vos) {
PickmTransParamForMO param = new PickmTransParamForMO();
param.setSourceBillID(vo.getCpmohid());
param.setSourceBillRowID(vo.getCmoid());
param.setBatchCode(vo.getVbatchcode());
param.setBatchid(vo.getCbatchid());
paramList.add(param);
}
if (paramList.size() > 0) {
PMOBPService.getIPpickmBusinessServiceForPmo().updatePickmBatchCode((PickmTransParamForMO[])paramList.toArray(new PickmTransParamForMO[0]));
}
} catch (Exception e) {
ExceptionUtils.wrappException(e);
}
}
}
}
}