diff --git a/mmpac/src/private/nc/bs/mmpac/pmo/pac0002/pluginpoint/PmoSerialNoImportProcess.java b/mmpac/src/private/nc/bs/mmpac/pmo/pac0002/pluginpoint/PmoSerialNoImportProcess.java index 6501c5b0..6c3b2199 100644 --- a/mmpac/src/private/nc/bs/mmpac/pmo/pac0002/pluginpoint/PmoSerialNoImportProcess.java +++ b/mmpac/src/private/nc/bs/mmpac/pmo/pac0002/pluginpoint/PmoSerialNoImportProcess.java @@ -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 saveParams = new ArrayList<>(); - this.construcParams(saveParams, headvo, itemvo, pmoSerialNoVO, null); - ISnService service = NCLocator.getInstance().lookup(ISnService.class); - service.saveSerialnos(saveParams.toArray(new SnDocParam[0])); + // 新增序列号档案 + List saveParams = new ArrayList<>(); + this.construcParams(saveParams, headvo, itemvo, vo, null); + ISnService service = NCLocator.getInstance().lookup(ISnService.class); + 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();// 生产订单明细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);