导入流程生产订单-序列号-保存序列号档案id

This commit is contained in:
mzr 2025-09-26 21:10:10 +08:00
parent 2f5997b069
commit 5077b4b7bc
1 changed files with 23 additions and 9 deletions

View File

@ -13,6 +13,7 @@ import nc.bs.trade.business.HYPubBO;
import nc.impl.pubapp.pattern.data.bill.BillQuery;
import nc.jdbc.framework.processor.MapProcessor;
import nc.pubitf.sn.doc.ISnService;
import nc.pubitf.sn.doc.param.ISnDocParam;
import nc.pubitf.sn.doc.param.SnDocParam;
import nc.vo.ml.NCLangRes4VoTransl;
import nc.vo.mmpac.pmo.pac0002.entity.PMOAggVO;
@ -121,16 +122,29 @@ public class PmoSerialNoImportProcess extends AbstractImportProceeWithContext {
// 之前序列号全部设置为删除状态
// int num = dao.executeUpdate("update mm_pmo_serialno set dr = 1 where cmoid = '" + itemvo.getCmoid() + "'");
// NCCForUAPLogger.debug("PmoSerialNoImportProcess-num = " + num);
String insert = hy.insert(vo);
NCCForUAPLogger.debug("PmoSerialNoImportProcess-insert = " + insert);
if (insert != null && !insert.isEmpty()) {
PMOSerialNoVO pmoSerialNoVO = (PMOSerialNoVO) hy.queryByPrimaryKey(PMOSerialNoVO.class, insert);
// 新增序列号档案
List<SnDocParam> saveParams = new ArrayList<>();
this.construcParams(saveParams, headvo, itemvo, pmoSerialNoVO, null);
this.construcParams(saveParams, headvo, itemvo, vo, null);
ISnService service = NCLocator.getInstance().lookup(ISnService.class);
service.saveSerialnos(saveParams.toArray(new SnDocParam[0]));
ISnDocParam[] iSnDocParams = service.saveSerialnos(saveParams.toArray(new SnDocParam[0]));
if (iSnDocParams != null && iSnDocParams.length > 0) {
ISnDocParam iSnDocParam = iSnDocParams[0];
vo.setCserialnoid(iSnDocParam.getPk_serialno());// 埼죗뵀도갭id
String insert = hy.insert(vo);
NCCForUAPLogger.debug("PmoSerialNoImportProcess-insert = " + insert);
/*if (insert != null && !insert.isEmpty()) {
String cmoid = itemvo.getCmoid();// <EFBFBD>끓땐데츠玖id
String sql = "cmoid = '" + cmoid + "'";
PMOSerialNoVO[] objects = (PMOSerialNoVO[]) hy.queryByCondition(PMOSerialNoVO.class, sql);
for (PMOSerialNoVO serialNoVO : objects) {
String vsndef3 = serialNoVO.getVsndef3();
if (!"Y".equals(vsndef3)) {
}
}
}*/
}
// NCLocator.getInstance().lookup(IPMOMaintainService.class).insert(resvo);
} catch (BusinessException e) {
ExceptionUtils.wrappException(e);