diff --git a/arap/src/private/nc/bs/arap/actions/GatheringbillEditSaveBatchBSAction.java b/arap/src/private/nc/bs/arap/actions/GatheringbillEditSaveBatchBSAction.java new file mode 100644 index 00000000..a49745cf --- /dev/null +++ b/arap/src/private/nc/bs/arap/actions/GatheringbillEditSaveBatchBSAction.java @@ -0,0 +1,109 @@ +// +// Source code recreated from a .class file by IntelliJ IDEA +// (powered by FernFlower decompiler) +// + +package nc.bs.arap.actions; + +import nc.bs.arap.bill.ArapBillPubUtil; +import nc.bs.arap.util.ArapBillVOUtils; +import nc.bs.arap.util.BillAccountCalendarUtils; +import nc.bs.arap.util.BillDateUtils; +import nc.bs.arap.validator.CrossRuleCheckValidator; +import nc.bs.dao.BaseDAO; +import nc.jdbc.framework.processor.MapProcessor; +import nc.vo.arap.basebill.BaseBillVO; +import nc.vo.arap.utils.StringUtil; +import nc.vo.pub.AggregatedValueObject; +import nc.vo.pub.BusinessException; +import nc.vo.pub.CircularlyAccessibleValueObject; +import nc.vo.pub.lang.UFDouble; + +import java.util.Map; + +public class GatheringbillEditSaveBatchBSAction extends BillUpdateBatchBSAction { + public GatheringbillEditSaveBatchBSAction() { + this.validatorCode.add(5); + this.validatorCode.add(34); + this.validatorCode.add(57); + this.validatorCode.add(59); + this.validatorCode.add(62); + this.validatorCode.add(93); + this.validatorCode.add(94); + this.validatorCode.add(100); + } + + protected void doBeforeUpdate(AggregatedValueObject[] bills, AggregatedValueObject[] orginBills) throws BusinessException { + ArapBillPubUtil.fillTradeTypeInfo(bills); + + for(AggregatedValueObject bill : bills) { + ArapBillPubUtil.processMoneyOnlySum(bill); + } + + /** + * 收款单保存校验关联的销售订单实际收款金额是否超过价税合计 + */ + int i = 0; + + for(AggregatedValueObject bill : bills) { + AggregatedValueObject oriBill = orginBills[i++]; + BaseBillVO billVO = (BaseBillVO) bill.getParentVO(); //修改的收款单 + BaseBillVO billOriVO = (BaseBillVO) oriBill.getParentVO(); //之前的收款单 + UFDouble money = billVO.getMoney(); //修改后的金额 + UFDouble oriMoney = billOriVO.getMoney(); //修改前的金额 + String pk_tradetype = billVO.getPk_tradetype(); + if(!"F2-Cxx-02".equals(pk_tradetype)){ + continue; + } + String def3 = billVO.getDef3(); //收款单对应的销售订单id + if(StringUtil.isEmpty(def3) || "N".equals(def3) || "~".equals(def3)){ + //无绑定的销售订单则下一次循环 + continue; + } + //计算收款单金额差值 + UFDouble changeMoney = money.sub(oriMoney); + //根据销售订单id去查询销售订单 + BaseDAO dao = new BaseDAO(); + String sql = "select nreceivedmny,ntotalorigmny from so_saleorder where dr = 0 and csaleorderid = '" +def3+"'"; + Map saleMap = (Map)dao.executeQuery(sql, new MapProcessor()); + //销售订单价税合计 + UFDouble ntotalorigmny = UFDouble.ZERO_DBL; + //销售订单实际收款金额 + UFDouble nreceivedmny = UFDouble.ZERO_DBL; + if(saleMap != null) { + nreceivedmny = new UFDouble(saleMap.get("nreceivedmny") == null ? "0" : saleMap.get("nreceivedmny").toString()); + ntotalorigmny = new UFDouble(saleMap.get("ntotalorigmny") == null ? "0" : saleMap.get("ntotalorigmny").toString()); + } + UFDouble moreMoney = nreceivedmny.add(changeMoney).sub(ntotalorigmny); + if(nreceivedmny.add(changeMoney).compareTo(ntotalorigmny) > 0){ + throw new BusinessException("【该笔收款已超销售订单"+ moreMoney +"元，无法传输！请检查订单累计收款金额！】"); + } + } + + ArapBillVOUtils.prepareDefaultInfo(bills, true); + BillDateUtils.setBillDateByNow(bills); + int updateType = this.getUpdateType(bills, orginBills); + + for(AggregatedValueObject bill : bills) { + bill.getParentVO().setStatus(1); + } + + if (updateType == TEMP_2_SAVE || updateType == SAVE_2_SAVE) { + for(AggregatedValueObject bill : bills) { + for(CircularlyAccessibleValueObject item : bill.getChildrenVO()) { + if (item.getStatus() != 2 && item.getStatus() != 3) { + item.setStatus(1); + } + } + } + } + + if (updateType == TEMP_2_SAVE || updateType == SAVE_2_SAVE) { + BillAccountCalendarUtils.setAccperiodYearMonth(bills); + } + + this.checkIsCorrdBillMoneyControl(bills, orginBills); + this.checkOtherSystemBill(bills, orginBills); + (new CrossRuleCheckValidator()).validate(bills); + } +} diff --git a/arap/src/private/nc/bs/arap/actions/GatheringbillSaveBatchBSAction.java b/arap/src/private/nc/bs/arap/actions/GatheringbillSaveBatchBSAction.java new file mode 100644 index 00000000..00be7a28 --- /dev/null +++ b/arap/src/private/nc/bs/arap/actions/GatheringbillSaveBatchBSAction.java @@ -0,0 +1,96 @@ +// +// Source code recreated from a .class file by IntelliJ IDEA +// (powered by FernFlower decompiler) +// + +package nc.bs.arap.actions; + +import nc.bs.arap.bill.ArapBillPubUtil; +import nc.bs.arap.util.ArapBillVOUtils; +import nc.bs.arap.util.BillAccountCalendarUtils; +import nc.bs.arap.util.BillDateUtils; +import nc.bs.arap.util.BillMoneyVUtils; +import nc.bs.arap.validator.CrossRuleCheckValidator; +import nc.bs.dao.BaseDAO; +import nc.jdbc.framework.processor.MapProcessor; +import nc.vo.arap.basebill.BaseBillVO; +import nc.vo.arap.utils.StringUtil; +import nc.vo.pub.AggregatedValueObject; +import nc.vo.pub.BusinessException; +import nc.vo.pub.lang.UFDouble; + +import java.util.Map; + +public class GatheringbillSaveBatchBSAction extends BillInsertBatchBSAction { + public GatheringbillSaveBatchBSAction() { + this.validatorCode.add(5); + this.validatorCode.add(15); + this.validatorCode.add(29); + this.validatorCode.add(19); + this.validatorCode.add(8); + this.validatorCode.add(24); + this.validatorCode.add(28); + this.validatorCode.add(44); + this.validatorCode.add(46); + this.validatorCode.add(31); + this.validatorCode.add(36); + this.validatorCode.add(23); + this.validatorCode.add(49); + this.validatorCode.add(57); + this.validatorCode.add(59); + this.validatorCode.add(62); + this.validatorCode.add(93); + this.validatorCode.add(94); + this.validatorCode.add(100); + } + + protected void doBeforeInsert(AggregatedValueObject[] bills) throws BusinessException { + ArapBillPubUtil.fillTradeTypeInfo(bills); + BillDateUtils.setBillDateByNow(bills); + ArapBillPubUtil.resetBasedocVid(bills); + BillAccountCalendarUtils.setAccperiodYearMonth(bills); + ArapBillVOUtils.prepareDefaultInfo(bills); + BillMoneyVUtils.sumAllVoBodyToHead(bills); + (new CrossRuleCheckValidator()).validate(bills); + ArapBillPubUtil.resetDestVODoc(bills); + ArapBillVOUtils.setMaterialInfo(bills); + ArapBillVOUtils.setDefaultSagaFrozen(bills); + ArapBillVOUtils.setDefaultFeeundertaker(bills); + ArapBillVOUtils.setDefaultSettleFlag(bills); + + /** + * 收款单保存校验关联的销售订单实际收款金额是否超过价税合计 + */ + + for(AggregatedValueObject bill : bills) { + BaseBillVO billVO = (BaseBillVO) bill.getParentVO(); //修改的收款单 + UFDouble money = billVO.getMoney(); //金额 + String pk_tradetype = billVO.getPk_tradetype(); + if(!"F2-Cxx-02".equals(pk_tradetype)){ + continue; + } + String def3 = billVO.getDef3(); //收款单对应的销售订单id + if(StringUtil.isEmpty(def3) || "N".equals(def3) || "~".equals(def3)){ + //无绑定的销售订单则下一次循环 + continue; + } + + //根据销售订单id去查询销售订单 + BaseDAO dao = new BaseDAO(); + String sql = "select nreceivedmny,ntotalorigmny from so_saleorder where dr = 0 and csaleorderid = '" +def3+"'"; + Map saleMap = (Map)dao.executeQuery(sql, new MapProcessor()); + //销售订单价税合计 + UFDouble ntotalorigmny = UFDouble.ZERO_DBL; + //销售订单实际收款金额 + UFDouble nreceivedmny = UFDouble.ZERO_DBL; + if(saleMap != null) { + nreceivedmny = new UFDouble(saleMap.get("nreceivedmny") == null ? "0" : saleMap.get("nreceivedmny").toString()); + ntotalorigmny = new UFDouble(saleMap.get("ntotalorigmny") == null ? "0" : saleMap.get("ntotalorigmny").toString()); + } + UFDouble moreMoney = nreceivedmny.add(money).sub(ntotalorigmny); + if(nreceivedmny.add(money).compareTo(ntotalorigmny) > 0){ + throw new BusinessException("【该笔收款已超销售订单"+ moreMoney +"元，无法传输！请检查订单累计收款金额！】"); + } + } + } +} diff --git a/mmpac/src/private/nc/bs/mmpac/pmo/pac0002/bp/PMOFinishBP.java b/mmpac/src/private/nc/bs/mmpac/pmo/pac0002/bp/PMOFinishBP.java new file mode 100644 index 00000000..fb11fc9c --- /dev/null +++ b/mmpac/src/private/nc/bs/mmpac/pmo/pac0002/bp/PMOFinishBP.java @@ -0,0 +1,68 @@ +// +// Source code recreated from a .class file by IntelliJ IDEA +// (powered by FernFlower decompiler) +// + +package nc.bs.mmpac.pmo.pac0002.bp; + +import nc.bs.mmpac.pmo.pac0002.pluginpoint.PMOPluginPoint; +import nc.bs.mmpac.pmo.pac0002.rule.PMOFilterBillStatusRule; +import nc.bs.mmpac.pmo.pac0002.rule.PMOFinishAutoFinishPutPlanRule; +import nc.bs.mmpac.pmo.pac0002.rule.PMOToFinishPickMRule; +import nc.bs.mmpac.pmo.pac0002.rule.fill.PMOFillFinishValueRule; +import nc.bs.mmpub.rule.MMVOSagaFrozenValidateRule; +import nc.impl.pubapp.pattern.rule.IFilterRule; +import nc.impl.pubapp.pattern.rule.IRule; +import nc.impl.pubapp.pattern.rule.processer.CompareAroundProcesser; +import nc.util.mmf.framework.gc.GCUpdateBPTemplate; +import nc.vo.mmpac.pmo.pac0002.constant.PMOConstLang; +import nc.vo.mmpac.pmo.pac0002.entity.PMOAggVO; +import nc.vo.mmpac.pmo.pac0002.enumeration.PMOFBillstatusEnum; + +public class PMOFinishBP { + public PMOFinishBP() { + } + + public PMOAggVO[] finish(PMOAggVO[] fullBills, PMOAggVO[] originBills) { + GCUpdateBPTemplate bp = new GCUpdateBPTemplate(PMOPluginPoint.FINISH); + this.addFinishBeforeRule(bp.getAroundProcesser()); + this.addFinishAfterRule(bp.getAroundProcesser()); + PMOAggVO[] retBills = (PMOAggVO[])bp.update(fullBills, originBills); + return retBills; + } + + private void addFinishBeforeRule(CompareAroundProcesser processer) { + IRule checkFrozenRule = new MMVOSagaFrozenValidateRule(true); + processer.addBeforeRule(checkFrozenRule); + IFilterRule filterStatusRule = new PMOFilterBillStatusRule(PMOConstLang.getMSG_ACTION_NO_AUDIT(), PMOFBillstatusEnum.AUDIT); + processer.addBeforeRule(filterStatusRule); + IRule fillFinishRule = new PMOFillFinishValueRule(false); + processer.addBeforeRule(fillFinishRule); + } + + private void addFinishAfterRule(CompareAroundProcesser processer) { + IRule finishPutPlanRule = new PMOFinishAutoFinishPutPlanRule(); + processer.addAfterRule(finishPutPlanRule); + /** 同步修改备料计划完成(生产订单强制完工时) */ + IRule pMOToFinishPickMRule = new PMOToFinishPickMRule(); + processer.addAfterRule(pMOToFinishPickMRule); + } + + public PMOAggVO[] finishCancel(PMOAggVO[] fullBills, PMOAggVO[] originBills) { + GCUpdateBPTemplate bp = new GCUpdateBPTemplate(PMOPluginPoint.UNFINISH); + this.addFinishCancelBeforeRule(bp.getAroundProcesser()); + this.addFinishCancelAfterRule(bp.getAroundProcesser()); + PMOAggVO[] retBills = (PMOAggVO[])bp.update(fullBills, originBills); + return retBills; + } + + private void addFinishCancelBeforeRule(CompareAroundProcesser processer) { + IFilterRule filterStatusRule = new PMOFilterBillStatusRule(PMOConstLang.getMSG_ACTION_NO_AUDIT(), PMOFBillstatusEnum.AUDIT); + processer.addBeforeRule(filterStatusRule); + IRule fillFinishRule = new PMOFillFinishValueRule(true); + processer.addBeforeRule(fillFinishRule); + } + + private void addFinishCancelAfterRule(CompareAroundProcesser processer) { + } +} diff --git a/mmpac/src/private/nc/bs/mmpac/pmo/pac0002/bp/PMORowFinishBP.java b/mmpac/src/private/nc/bs/mmpac/pmo/pac0002/bp/PMORowFinishBP.java new file mode 100644 index 00000000..76403771 --- /dev/null +++ b/mmpac/src/private/nc/bs/mmpac/pmo/pac0002/bp/PMORowFinishBP.java @@ -0,0 +1,115 @@ +// +// Source code recreated from a .class file by IntelliJ IDEA +// (powered by FernFlower decompiler) +// + +package nc.bs.mmpac.pmo.pac0002.bp; + +import nc.bs.mmpac.pmo.pac0002.bp.service.PMOBPService; +import nc.bs.mmpac.pmo.pac0002.bp.util.PMOBPUtil; +import nc.bs.mmpac.pmo.pac0002.pluginpoint.PMOPluginPoint; +import nc.bs.mmpac.pmo.pac0002.rule.PMOFilterBillStatusRule; +import nc.bs.mmpac.pmo.pac0002.rule.PMOFilterRowStatusRule; +import nc.bs.mmpac.pmo.pac0002.rule.PMOFinishAutoFinishPutPlanRule; +import nc.bs.mmpac.pmo.pac0002.rule.PMOToFinishPickMRule; +import nc.bs.mmpac.pmo.pac0002.rule.fill.PMOFillFinishValueRule; +import nc.bs.mmpub.rule.MMVOSagaFrozenValidateRule; +import nc.impl.pubapp.pattern.rule.IRule; +import nc.impl.pubapp.pattern.rule.processer.CompareAroundProcesser; +import nc.util.mmf.framework.gc.GCBillTransferTool; +import nc.util.mmf.framework.gc.GCBillUpdate; +import nc.util.mmf.framework.gc.GCUpdateBPTemplate; +import nc.vo.mmpac.pmo.pac0002.constant.PMOConstLang; +import nc.vo.mmpac.pmo.pac0002.entity.PMOAggVO; +import nc.vo.mmpac.pmo.pac0002.entity.PMOItemVO; +import nc.vo.mmpac.pmo.pac0002.enumeration.PMOFBillstatusEnum; +import nc.vo.mmpac.pmo.pac0002.enumeration.PMOFItemStatusEnum; +import nc.vo.pub.BusinessException; +import nc.vo.pub.CircularlyAccessibleValueObject; +import nc.vo.pubapp.pattern.exception.ExceptionUtils; + +import java.util.ArrayList; +import java.util.HashMap; +import java.util.List; +import java.util.Map; + +public class PMORowFinishBP { + public PMORowFinishBP() { + } + + public PMOAggVO[] rowfinish(PMOAggVO[] vos) { + GCUpdateBPTemplate bp = new GCUpdateBPTemplate(PMOPluginPoint.ROWFINISH); + CompareAroundProcesser processer = bp.getAroundProcesser(); + this.addRowFinishBeforeRule(processer); + this.addRowFinishAfterRule(processer); + PMOAggVO[] returnvos = (PMOAggVO[])processer.before(vos, vos); + List upditemList = new ArrayList(); + Map upditemMap = new HashMap(); + + for(PMOAggVO aggvo : returnvos) { + PMOItemVO[] items = aggvo.getChildrenVO(); + + for(PMOItemVO item : items) { + upditemList.add(item); + upditemMap.put(item.getCmoid(), item); + } + } + + try { + PMOAggVO aggvo = PMOBPService.getIPMOQueryService().queryByPk(vos[0].getParentVO().getCpmohid()); + PMOItemVO[] olditems = aggvo.getChildrenVO(); + List tempitems = new ArrayList(); + + for(PMOItemVO item : olditems) { + if (!upditemMap.containsKey(item.getCmoid())) { + tempitems.add(item); + } else { + ((PMOItemVO)upditemMap.get(item.getCmoid())).setStatus(1); + PMOBPUtil.setGrandVOStatusUpdate((PMOItemVO)upditemMap.get(item.getCmoid())); + tempitems.add((PMOItemVO)upditemMap.get(item.getCmoid())); + } + } + + aggvo.setChildrenVO((CircularlyAccessibleValueObject[])tempitems.toArray(new PMOItemVO[tempitems.size()])); + PMOAggVO[] aggvos = new PMOAggVO[]{aggvo}; + GCBillTransferTool transferTool = new GCBillTransferTool(aggvos); + PMOAggVO[] originBills = (PMOAggVO[])transferTool.getOriginBills(); + GCBillUpdate billupdate = new GCBillUpdate(); + PMOAggVO[] newaggvos = (PMOAggVO[])billupdate.update(aggvos, originBills); + PMOItemVO[] totalitems = newaggvos[0].getChildrenVO(); + Map newitemMap = new HashMap(); + + for(PMOItemVO item : totalitems) { + if (upditemMap.containsKey(item.getCmoid())) { + newitemMap.put(item.getCmoid(), item); + } + } + + returnvos[0].setChildrenVO((CircularlyAccessibleValueObject[])newitemMap.values().toArray(new PMOItemVO[0])); + processer.after(returnvos, returnvos); + + /** 同步修改备料计划完成(生产订单强制完工时) */ + IRule pMOToFinishPickMRule = new PMOToFinishPickMRule(); + pMOToFinishPickMRule.process(newaggvos); + /** ******************** */ + + PMOAggVO newaggvo = PMOBPService.getIPMOQueryService().queryByPk(vos[0].getParentVO().getCpmohid()); + return new PMOAggVO[]{newaggvo}; + } catch (BusinessException e) { + ExceptionUtils.wrappException(e); + return returnvos; + } + } + + private void addRowFinishBeforeRule(CompareAroundProcesser processer) { + IRule checkFrozenRule = new MMVOSagaFrozenValidateRule(true); + processer.addBeforeRule(checkFrozenRule); + processer.addBeforeRule(new PMOFilterBillStatusRule(PMOConstLang.getMSG_ACTION_NO_AUDIT(), PMOFBillstatusEnum.AUDIT)); + processer.addBeforeRule(new PMOFilterRowStatusRule(PMOConstLang.getMSG_RULE_NO_ROWDATA(), PMOFItemStatusEnum.PUT)); + processer.addBeforeRule(new PMOFillFinishValueRule(false)); + } + + private void addRowFinishAfterRule(CompareAroundProcesser processer) { + processer.addAfterRule(new PMOFinishAutoFinishPutPlanRule()); + } +} diff --git a/mmpac/src/private/nc/bs/mmpac/pmo/pac0002/rule/PMOToFinishPickMRule.java b/mmpac/src/private/nc/bs/mmpac/pmo/pac0002/rule/PMOToFinishPickMRule.java new file mode 100644 index 00000000..bf89dfc1 --- /dev/null +++ b/mmpac/src/private/nc/bs/mmpac/pmo/pac0002/rule/PMOToFinishPickMRule.java @@ -0,0 +1,78 @@ +package nc.bs.mmpac.pmo.pac0002.rule; + +import nc.bs.framework.common.NCLocator; +import nc.impl.pubapp.pattern.rule.IRule; +import nc.itf.mmpac.pickm.IPickmMaintainService; +import nc.md.persist.framework.IMDPersistenceQueryService; +import nc.util.mmf.framework.base.MMValueCheck; +import nc.vo.mmpac.pickm.entity.AggPickmVO; +import nc.vo.mmpac.pickm.entity.PickmHeadVO; +import nc.vo.mmpac.pmo.pac0002.entity.PMOAggVO; +import nc.vo.mmpac.pmo.pac0002.entity.PMOItemVO; +import nc.vo.pub.BusinessException; + +import java.util.ArrayList; + +public class PMOToFinishPickMRule + extends Object + implements IRule{ + public void process(PMOAggVO[] vos) { + if (MMValueCheck.isEmpty(vos)) { + return; + } + /** + * 业务逻辑： + * 1.循环生产订单明细表 + * 2.查看生产订单明细行的状态是否为完工（2） + * 3.若为完工状态，则根据生产订单明细表中生产订单行查询备料计划 + * 4.修改备料计划为完成状态（3） + */ + for(int i = 0; i < vos.length; i++) { + PMOAggVO vo = vos[i]; + PMOItemVO[] items = vo.getChildrenVO(); + //循环生产订单明细 + for(int j = 0; j < items.length; j++) { + PMOItemVO item = items[j]; + //查看生产订单行状态是否为完工（2） + int fitemStatus = item.getFitemstatus(); + if(fitemStatus != 2) { + continue; + } + //根据生产订单行查询备料计划 + String cmoid = item.getCmoid(); + String whereSql = "nvl(mm_pickm.dr,0) = 0 and mm_pickm.vsourcemorowid = '" + cmoid + "'"; + IMDPersistenceQueryService aggvoQueryService = NCLocator.getInstance().lookup(IMDPersistenceQueryService.class); + // 根据主键查询得到aggvo + try { + @SuppressWarnings("unchecked") + ArrayList aggVOs = (ArrayList)aggvoQueryService.queryBillOfVOByCond(AggPickmVO.class, whereSql, true, false); + if(aggVOs.size() <= 0) { + continue; + } + //数组转换 + AggPickmVO[] aggVOsArr = new AggPickmVO[aggVOs.size()]; + boolean flag = false; + for(int z=0; z bp = new GCInsertBPTemplate(WrPluginPoint.INSERT); + AroundProcesser processor = bp.getAroundProcesser(); + Map vbatchsMap = new HashMap(); + this.addBeforeRule(processor, vos, vbatchsMap); + this.addAfterRule(processor, vbatchsMap); + return (AggWrVO[])bp.insert(vos); + } + + private void addBeforeRule(AroundProcesser processer, AggWrVO[] vos, Map vbatchsMap) { + IRule wrNullRule = new WrNullRule(); + processer.addBeforeRule(wrNullRule); + IRule mmatoMaterialCheckRule = new MMATOMaterialCheckRule((String)null, "cbmaterialvid", "cbffileid"); + processer.addBeforeRule(mmatoMaterialCheckRule); + IRule orgRule = new OrgDisabledCheckRule("pk_org", "FACTORYTYPE000000000"); + processer.addBeforeRule(orgRule); + IRule checkDefRule = new UserDefSaveRule(new String[]{"vdef", "vbdef", "vgdef", "vpdef"}, new Class[]{WrVO.class, WrItemVO.class, WrQualityVO.class, WrPickVO.class}); + processer.addBeforeRule(checkDefRule); + MarAssistantSaveRule marRule = new MarAssistantSaveRule(); + processer.addBeforeRule(marRule); + IRule fillInsertDataRule = new WrFillInsertDataRule(); + processer.addBeforeRule(fillInsertDataRule); + IRule autoMaterialAssignRule = new MMAutoMaterialAssignRule((String)null, "cbmaterialvid", new String[]{"pk_org"}, (String[])null); + processer.addBeforeFinalRule(autoMaterialAssignRule); + IRule orgPermissionRule = new WrCheckMaterialPermissionRule(); + processer.addBeforeRule(orgPermissionRule); + IRule moCloseRule = new WrCheckMoIsCloseRule(); + processer.addBeforeRule(moCloseRule); + processer.addBeforeRule(new MMCheckMaterialVirtualRule(WrItemVO.class)); + IRule wrSetDefaultValueWhenInsertRule = new WrSetDefaultValueWhenInsertRule(); + processer.addBeforeRule(wrSetDefaultValueWhenInsertRule); + IRule wrSetItemDefaultValueRule = new WrSetItemDefaultValueRule(); + processer.addBeforeRule(wrSetItemDefaultValueRule); + IRule billcodeRule = new MMCreateBillcodeAndTrantypecodeRule("55A4", "vbillcode", "pk_group", "pk_org", "vtrantypecode"); + processer.addBeforeRule(billcodeRule); + IRule wrHeadNotNullRule = new WrHeadNotNullRule(); + processer.addBeforeRule(wrHeadNotNullRule); + IRule wrBatchCodeRule = new WrCreateBatchCodeRule(); + processer.addBeforeRule(wrBatchCodeRule); + IRule wrClearNullProductBodyRule = new WrClearNullBodyRule(); + processer.addBeforeRule(wrClearNullProductBodyRule); + processer.addBeforeRule(new WrRowNoRule()); + IRule wrQualityFilterRule = new WrQualityFilterRule(); + processer.addBeforeRule(wrQualityFilterRule); + IRule wrPickFilterRule = new WrPickFilterRule(); + processer.addBeforeRule(wrPickFilterRule); + IRule wrOutputNotNullRule = new WrOutputNotNullRule(); + processer.addBeforeRule(wrOutputNotNullRule); + IRule wrNoneMainProductBomCheckRule = new WrNoneMainProductBomCheckRule(); + processer.addBeforeRule(wrNoneMainProductBomCheckRule); + IRule wrConsumeNotNullRule = new WrPickNotNullRule(); + processer.addBeforeRule(wrConsumeNotNullRule); + IRule lengthCheckRule = new FieldLengthCheckRule(); + processer.addBeforeRule(lengthCheckRule); + IRule wrInsertAndDelInStockBatchCodeBeforeRule = new WrInsertAndDelInStockBatchCodeBeforeRule(vbatchsMap); + processer.addBeforeRule(wrInsertAndDelInStockBatchCodeBeforeRule); + WrSetQualityVODefaultValueRule wrSetQualityVODefaultValueRule = new WrSetQualityVODefaultValueRule(); + processer.addBeforeRule(wrSetQualityVODefaultValueRule); + processer.addBeforeRule(new WrSerialNoCheckCodeRepeat()); + WrSerialNoAutoCreateBeforeRule wrAutoCreateSnBeforeRule = new WrSerialNoAutoCreateBeforeRule(); + processer.addBeforeRule(wrAutoCreateSnBeforeRule); + WrSerialNoCheckRule wrSnCheckRule = new WrSerialNoCheckRule(); + processer.addBeforeRule(wrSnCheckRule); + WrSnSynToQualtiyRule synToQRule = new WrSnSynToQualtiyRule(); + processer.addBeforeRule(synToQRule); + WrMoSerialNoMarkIRule mosnMarkRule = new WrMoSerialNoMarkIRule(); + processer.addBeforeRule(mosnMarkRule); + IRule wrCreateBatProdRule = new WrCreateBatProdRule(); + processer.addBeforeRule(wrCreateBatProdRule); + processer.addBeforeRule(new WrCheckTranstypeCodeRule()); + } + + private void addAfterRule(AroundProcesser processor, Map vbatchsMap) { + IRule rule = new MMBillCodeCheckAndTrantypeRule("55A4", "vbillcode", "pk_group", "pk_org", "vtrantypecode"); + processor.addAfterRule(rule); + IRule wrCreateInStockBatchCodeAfterRule = new WrInsertInStockBatchCodeAfterRule(vbatchsMap); + processor.addAfterRule(wrCreateInStockBatchCodeAfterRule); + processor.addAfterRule(new WrInsertRewriteWrNumForPutPlanRule()); + IRule wrMORewriteRule = new WrMORewriteRule(2); + processor.addAfterRule(wrMORewriteRule); + IRule moDiscadNumRewriteRule = new MoDiscadNumRewriteRule(2); + processor.addAfterRule(moDiscadNumRewriteRule); + IRule snSaveRule = new WrSerialNoSaveRule(); + processor.addAfterRule(snSaveRule); + /** 同步修改备料计划完成 */ + IRule pickMFinishRule = new PickMFinishRule(); + processor.addAfterRule(pickMFinishRule); + /** ******************** */ + + if (!this.isOnlyInsert) { + processor.addAfterRule(new WrIsSaveAndApproveRule()); + } + + processor.addAfterRule(new WrAuditAndApplyCheckRule()); + processor.addAfterRule(new WrAuditAndProdInRule()); + } + + /** @deprecated */ + @Deprecated + protected IRule getMoRewriteRule() { + return null; + } + + /** @deprecated */ + @Deprecated + protected IRule getMoDiscadNumRewriteRule() { + return null; + } + + /** @deprecated */ + @Deprecated + protected IRule getAuditRule() { + return null; + } + + public boolean isOnlyInsert() { + return this.isOnlyInsert; + } + + public void setOnlyInsert(boolean isOnlyInsert) { + this.isOnlyInsert = isOnlyInsert; + } +} diff --git a/mmpac/src/private/nc/bs/mmpac/wr/rule/serialno/PickMFinishRule.java b/mmpac/src/private/nc/bs/mmpac/wr/rule/serialno/PickMFinishRule.java new file mode 100644 index 00000000..037ab8be --- /dev/null +++ b/mmpac/src/private/nc/bs/mmpac/wr/rule/serialno/PickMFinishRule.java @@ -0,0 +1,106 @@ +package nc.bs.mmpac.wr.rule.serialno; + +import nc.bs.framework.common.NCLocator; +import nc.bs.mmpac.pmo.pac0002.bp.query.PMOItemVOQueryBP; +import nc.bs.mmpac.wr.rule.serialno.doc.WrSerialNoDocInsertControl; +import nc.impl.pubapp.pattern.rule.IRule; +import nc.itf.mmpac.pickm.IPickmMaintainService; +import nc.md.persist.framework.IMDPersistenceQueryService; +import nc.util.mmf.framework.base.MMValueCheck; +import nc.util.mmpac.wr.vochange.WrBusiVOToChangeVO; +import nc.vo.mmpac.pickm.entity.AggPickmVO; +import nc.vo.mmpac.pickm.entity.PickmHeadVO; +import nc.vo.mmpac.pmo.pac0002.entity.PMOItemVO; +import nc.vo.mmpac.wr.entity.AggWrChangeVO; +import nc.vo.mmpac.wr.entity.AggWrVO; +import nc.vo.mmpac.wr.entity.WrItemVO; +import nc.vo.pub.BusinessException; + +import java.util.ArrayList; + + + + + + + +public class PickMFinishRule + extends Object + implements IRule +{ + public void process(AggWrVO[] vos) { + if (MMValueCheck.isEmpty(vos)) { + return; + } + /** + * 业务逻辑： + * 1.根据生产报告子表中生产订单行查看生产订单明细表 + * 2.查看生产订单明细行的状态是否为完工（2） + * 3.若为完工状态，则根据生成报告子表中生产订单行查询备料计划 + * 4.修改备料计划为完成状态（3） + */ + for(int i = 0; i < vos.length; i++) { + AggWrVO vo = vos[i]; + WrItemVO[] items = vo.getChildrenVO(); + //循环生产报告子表 + for(int j = 0; j < items.length; j++) { + WrItemVO item = items[j]; + String cbmobid = item.getCbmobid(); + String[] keys = {cbmobid}; + //生产订单行查询 + PMOItemVO[] pmoItemvos = (new PMOItemVOQueryBP()).getPMOItemVOsByids(keys); + //查看生产订单行状态是否为完工（2） + if(pmoItemvos.length > 0) { + PMOItemVO pmoItem = pmoItemvos[0]; + int fitemStatus = pmoItem.getFitemstatus(); + if(fitemStatus != 2) { + continue; + } + //根据生产订单行查询备料计划 +// BillQuery query = new BillQuery(AggPickmVO.class); +// AggPickmVO[] aggVOs = (AggPickmVO[])query.query(keys); + + String whereSql = "nvl(mm_pickm.dr,0) = 0 and mm_pickm.vsourcemorowid = '" + cbmobid + "'"; + IMDPersistenceQueryService aggvoQueryService = NCLocator.getInstance().lookup(IMDPersistenceQueryService.class); + // 根据主键查询得到aggvo + try { + @SuppressWarnings("unchecked") + ArrayList aggVOs = (ArrayList)aggvoQueryService.queryBillOfVOByCond(AggPickmVO.class, whereSql, true, false); + if(aggVOs.size() <= 0) { + continue; + } + //数组转换 + AggPickmVO[] aggVOsArr = new AggPickmVO[aggVOs.size()]; + boolean flag = false; + for(int z=0; z processer = new AroundProcesser(BP30PlugInPoint.InsertBP); + TimeLog.logStart(); + this.addBeforeRule(processer); + processer.before(bills); + TimeLog.info(NCLangRes4VoTransl.getNCLangRes().getStrByID("4006011_0", "04006011-0066")); + TimeLog.logStart(); + BillInsert bo = new BillInsert(); + SaleOrderVO[] vos = (SaleOrderVO[])bo.insert(bills); + TimeLog.info(NCLangRes4VoTransl.getNCLangRes().getStrByID("4006011_0", "04006011-0067")); + TimeLog.logStart(); + this.addAfterRule(processer); + processer.after(vos); + TimeLog.info(NCLangRes4VoTransl.getNCLangRes().getStrByID("4006011_0", "04006011-0068")); + return vos; + } + + private void addAfterRule(AroundProcesser processer) { + IRule rule = null; + IRule var4 = new InsertSoBalanceWhenAddNewRule(); + processer.addAfterRule(var4); + IRule var5 = new RenovateARByHidsEndRule(M30EngrossAction.M30Insert); + processer.addAfterRule(var5); + IRule var6 = new ThisGatheringRule(); + processer.addAfterRule(var6); + IRule var7 = new CheckUniqueBillCodeRule(); + processer.addAfterRule(var7); + IRule var8 = new RewriteBillInsertRule(); + processer.addAfterRule(var8); + IRule var9 = new SaveTransferMsgRule(); + processer.addAfterRule(var9); + IRule var10 = new RewritePriceFormRule(); + processer.addAfterRule(var10); + IRule var11 = new SourceToSaleOrderMsgRule(); + processer.addAfterRule(var11); + boolean icEnable = SysInitGroupQuery.isICEnabled(); + if (icEnable) { + IRule var12 = new SaleOrderVOATPAfterRule(); + processer.addAfterRule(var12); + IRule var13 = new AutoReserveRule(); + processer.addAfterRule(var13); + } + + if (SysInitGroupQuery.isPRICEEnabled()) { + IRule var14 = new RewritePromotePriceInsertRule(); + processer.addAfterRule(var14); + } + /** + * 销售订单新增回写参考物料售价规则 + */ + IRule var15 = new WritebackMaterialPriceRule(); + processer.addAfterRule(var15); + + processer.addAfterRule(new MobAfterSaveMessageRule()); + } + + private void addBeforeRule(AroundProcesser processer) { + IRule rule = new SaleOrgEnableCheckRule(); + processer.addBeforeRule(rule); + IRule var4 = new FillupRedundanceDataRule(); + processer.addBeforeRule(var4); + IRule var5 = new FillupFretexchangeRule(); + processer.addBeforeRule(var5); + IRule var6 = new AddNewBillCodeRule(); + processer.addBeforeRule(var6); + IRule var7 = new CheckNumPriceMnyRule(); + processer.addBeforeRule(var7); + IRule var8 = new SaleOrderCheckNumAndMnyRule(); + processer.addBeforeRule(var8); + IRule var9 = new CheckMaterilaOVidRule(); + processer.addBeforeRule(var9); + IRule var10 = new CheckSettleOrgRepeat(); + processer.addBeforeRule(var10); + IRule var11 = new CheckDateRule(); + processer.addBeforeRule(var11); + processer.addBeforeRule(new AutoMaterialAssignRule("cmaterialid", new String[]{"pk_org"}, new String[]{"pk_org", "csendstockorgid", "csettleorgid", "carorgid", "cprofitcenterid", "csprofitcenterid"})); + IRule var12 = new CfgMatchSaveRule(); + processer.addBeforeRule(var12); + IRule var13 = new CfgMatchCheckRule(); + processer.addBeforeRule(var13); + IRule var14 = new CheckSaveBillRule(); + processer.addBeforeRule(var14); + IRule var15 = new FillBillTailInfoRuleForIns(); + processer.addBeforeRule(var15); + IRule var16 = new SetAddAuditInfoRule(); + processer.addBeforeRule(var16); + IRule var17 = new RenovateARByHidsBeginRule(M30EngrossAction.M30Insert); + processer.addBeforeRule(var17); + boolean icEnable = SysInitGroupQuery.isICEnabled(); + if (icEnable) { + IRule var18 = new SaleOrderVOATPBeforeRule(); + processer.addBeforeRule(var18); + } + + IRule var19 = new LrgCashMarCheckRule(); + processer.addBeforeRule(var19); + IRule var20 = new ArsubOffsetBeforeSaveRule(); + processer.addBeforeRule(var20); + IRule var21 = new CheckLrgTotalMoney(); + processer.addBeforeRule(var21); + IRule var22 = new UserDefSaveRule(new Class[]{SaleOrderHVO.class, SaleOrderBVO.class}); + processer.addBeforeRule(var22); + IRule var23 = new CrossRuleValidateRule(); + processer.addBeforeRule(var23); + IRule var24 = new CheckProjectValueRule(); + processer.addBeforeRule(var24); + IRule var25 = new CheckBusiForPMRule(); + processer.addBeforeRule(var25); + IRule var26 = new CheckValueWhenIsdeliveryRule(); + processer.addBeforeRule(var26); + IRule var27 = new CheckProjectMFGRule(); + processer.addBeforeRule(var27); + } +} diff --git a/so/src/private/nc/bs/so/m30/maintain/UpdateSaleOrderBP.java b/so/src/private/nc/bs/so/m30/maintain/UpdateSaleOrderBP.java new file mode 100644 index 00000000..66a02715 --- /dev/null +++ b/so/src/private/nc/bs/so/m30/maintain/UpdateSaleOrderBP.java @@ -0,0 +1,171 @@ +// +// Source code recreated from a .class file by IntelliJ IDEA +// (powered by FernFlower decompiler) +// + +package nc.bs.so.m30.maintain; + +import nc.bs.scmpub.rule.CrossRuleValidateRule; +import nc.bs.scmpub.rule.VOSagaFrozenValidateRule; +import nc.bs.so.m30.maintain.rule.insert.WritebackMaterialPriceRule; +import nc.bs.so.m30.maintain.rule.update.RewriteBillUpdateRule; +import nc.bs.so.m30.maintain.rule.update.RewritePromotePriceUpdateRule; +import nc.bs.so.m30.plugin.BP30PlugInPoint; +import nc.bs.so.m30.rule.atp.SaleOrderVOATPAfterRule; +import nc.bs.so.m30.rule.atp.SaleOrderVOATPBeforeRule; +import nc.bs.so.m30.rule.billcode.CheckUniqueBillCodeRule; +import nc.bs.so.m30.rule.billcode.UpdateBillCodeRule; +import nc.bs.so.m30.rule.businessinfo.SaveTransferMsgRule; +import nc.bs.so.m30.rule.credit.RenovateARByHidsBeginRule; +import nc.bs.so.m30.rule.credit.RenovateARByHidsEndRule; +import nc.bs.so.m30.rule.feature.CfgMatchCheckRule; +import nc.bs.so.m30.rule.feature.CfgMatchSaveRule; +import nc.bs.so.m30.rule.m35.ArsubOffsetBeforeSaveRule; +import nc.bs.so.m30.rule.m35.LrgCashMarCheckRule; +import nc.bs.so.m30.rule.maintaincheck.*; +import nc.bs.so.m30.rule.maintainprocess.*; +import nc.bs.so.m30.rule.pm.CheckBusiForPMRule; +import nc.bs.so.m30.rule.pm.CheckProjectMFGRule; +import nc.bs.so.m30.rule.pm.CheckProjectValueRule; +import nc.bs.so.m30.rule.reserve.AutoReserveRule; +import nc.bs.so.m30.rule.reserve.ReserveUpdateRule; +import nc.bs.so.m30.rule.rewrite.price.RewritePriceFormRule; +import nc.bs.so.pub.rule.CheckApproverRule; +import nc.impl.pubapp.bd.userdef.UserDefSaveRule; +import nc.impl.pubapp.pattern.data.bill.BillUpdate; +import nc.impl.pubapp.pattern.rule.ICompareRule; +import nc.impl.pubapp.pattern.rule.IRule; +import nc.impl.pubapp.pattern.rule.processer.CompareAroundProcesser; +import nc.itf.scmpub.reference.uap.group.SysInitGroupQuery; +import nc.vo.credit.engrossmaintain.pub.action.M30EngrossAction; +import nc.vo.ml.NCLangRes4VoTransl; +import nc.vo.pubapp.pattern.log.TimeLog; +import nc.vo.pubapp.util.SetUpdateAuditInfoRule; +import nc.vo.scmpub.rule.AutoMaterialAssignRule; +import nc.vo.so.m30.entity.SaleOrderBVO; +import nc.vo.so.m30.entity.SaleOrderHVO; +import nc.vo.so.m30.entity.SaleOrderVO; + +public class UpdateSaleOrderBP { + public UpdateSaleOrderBP() { + } + + public SaleOrderVO[] update(SaleOrderVO[] bills, SaleOrderVO[] originBills) { + CompareAroundProcesser processer = new CompareAroundProcesser(BP30PlugInPoint.UpdateBP); + TimeLog.logStart(); + this.addBeforeRule(processer); + processer.before(bills, originBills); + TimeLog.info(NCLangRes4VoTransl.getNCLangRes().getStrByID("4006011_0", "04006011-0069")); + TimeLog.logStart(); + BillUpdate bo = new BillUpdate(); + SaleOrderVO[] vos = (SaleOrderVO[])bo.update(bills, originBills); + TimeLog.info(NCLangRes4VoTransl.getNCLangRes().getStrByID("4006011_0", "04006011-0070")); + TimeLog.logStart(); + this.addAfterRule(processer); + processer.after(vos, originBills); + TimeLog.info(NCLangRes4VoTransl.getNCLangRes().getStrByID("4006011_0", "04006011-0071")); + return vos; + } + + private void addAfterRule(CompareAroundProcesser processer) { + IRule rule = null; + IRule var5 = new UpdateSoBalanceWhenUpdateRule(); + processer.addAfterRule(var5); + IRule var6 = new RenovateARByHidsEndRule(M30EngrossAction.M30Edit); + processer.addAfterRule(var6); + IRule var7 = new ThisGatheringRule(); + processer.addAfterRule(var7); + IRule var8 = new CheckUniqueBillCodeRule(); + processer.addAfterRule(var8); + ICompareRule compareRule = new RewriteBillUpdateRule(); + processer.addAfterRule(compareRule); + IRule var9 = new SaveTransferMsgRule(); + processer.addAfterRule(var9); + IRule var10 = new RewritePriceFormRule(); + processer.addAfterRule(var10); + IRule var11 = new UpdateSoBalanceWhenUpdateM30HeadRule(); + processer.addAfterRule(var11); + boolean icEnable = SysInitGroupQuery.isICEnabled(); + if (icEnable) { + IRule var12 = new SaleOrderVOATPAfterRule(); + processer.addAfterRule(var12); + IRule var13 = new ReserveUpdateRule(); + processer.addAfterRule(var13); + IRule var14 = new AutoReserveRule(); + processer.addAfterRule(var14); + } + + if (SysInitGroupQuery.isPRICEEnabled()) { + ICompareRule var15 = new RewritePromotePriceUpdateRule(); + processer.addAfterRule(var15); + } + + /** + * 销售订单新增回写参考物料售价规则 + */ + IRule var16 = new WritebackMaterialPriceRule(); + processer.addAfterRule(var16); + + } + + private void addBeforeRule(CompareAroundProcesser processer) { + IRule rule = null; + IRule var5 = new VOSagaFrozenValidateRule(); + processer.addBeforeRule(var5); + IRule var6 = new CheckCanUpdateWhenAuditing(); + processer.addBeforeRule(var6); + IRule var7 = new CheckApproverRule(); + processer.addBeforeRule(var7); + IRule var8 = new CfgMatchSaveRule(); + processer.addBeforeRule(var8); + IRule var9 = new CfgMatchCheckRule(); + processer.addBeforeRule(var9); + IRule var10 = new FillupRedundanceDataRule(); + processer.addBeforeRule(var10); + IRule var11 = new FillupFretexchangeRule(); + processer.addBeforeRule(var11); + IRule var12 = new SetUpdateAuditInfoRule(); + processer.addBeforeRule(var12); + ICompareRule compareRule = new UpdateBillCodeRule(); + processer.addBeforeRule(compareRule); + IRule var13 = new CheckMaterilaOVidRule(); + processer.addBeforeRule(var13); + IRule var14 = new CheckNumPriceMnyRule(); + processer.addBeforeRule(var14); + IRule var15 = new SaleOrderCheckNumAndMnyRule(); + processer.addBeforeRule(var15); + IRule var16 = new CheckSettleOrgRepeat(); + processer.addBeforeRule(var16); + IRule var17 = new CheckDateRule(); + processer.addBeforeRule(var17); + processer.addBeforeRule(new AutoMaterialAssignRule("cmaterialid", new String[]{"pk_org"}, new String[]{"pk_org", "csendstockorgid", "csettleorgid", "carorgid", "cprofitcenterid", "csprofitcenterid"})); + IRule var18 = new CheckSaveBillRule(); + processer.addBeforeRule(var18); + IRule var19 = new RenovateARByHidsBeginRule(M30EngrossAction.M30Edit); + processer.addBeforeRule(var19); + boolean icEnable = SysInitGroupQuery.isICEnabled(); + if (icEnable) { + IRule var20 = new SaleOrderVOATPBeforeRule(); + processer.addBeforeRule(var20); + } + + IRule var21 = new LrgCashMarCheckRule(); + processer.addBeforeRule(var21); + IRule var22 = new ArsubOffsetBeforeSaveRule(); + processer.addBeforeRule(var22); + IRule var23 = new CheckLrgTotalMoney(); + processer.addBeforeRule(var23); + IRule var24 = new CrossRuleValidateRule(); + processer.addBeforeRule(var24); + IRule var25 = new UserDefSaveRule(new Class[]{SaleOrderHVO.class, SaleOrderBVO.class}); + processer.addBeforeRule(var25); + IRule var26 = new CheckProjectValueRule(); + processer.addBeforeRule(var26); + IRule var27 = new CheckBusiForPMRule(); + processer.addBeforeRule(var27); + IRule var28 = new CheckValueWhenIsdeliveryRule(); + processer.addBeforeRule(var28); + IRule var29 = new CheckProjectMFGRule(); + processer.addBeforeRule(var29); + } +} diff --git a/so/src/private/nc/bs/so/m30/maintain/rule/insert/WritebackMaterialPriceRule.java b/so/src/private/nc/bs/so/m30/maintain/rule/insert/WritebackMaterialPriceRule.java new file mode 100644 index 00000000..031d3c9f --- /dev/null +++ b/so/src/private/nc/bs/so/m30/maintain/rule/insert/WritebackMaterialPriceRule.java @@ -0,0 +1,55 @@ +package nc.bs.so.m30.maintain.rule.insert; + +import nc.bs.framework.common.NCLocator; +import nc.impl.pubapp.pattern.rule.IRule; +import nc.itf.bd.material.sale.IMaterialSaleService; +import nc.md.persist.framework.IMDPersistenceQueryService; +import nc.vo.bd.material.sale.MaterialSaleVO; +import nc.vo.pub.BusinessException; +import nc.vo.pub.lang.UFDouble; +import nc.vo.so.m30.entity.SaleOrderBVO; +import nc.vo.so.m30.entity.SaleOrderVO; + +import java.util.ArrayList; + +public class WritebackMaterialPriceRule implements IRule{ + + + @Override + public void process(SaleOrderVO[] vos) { + // TODO Auto-generated method stub + for (SaleOrderVO vo : vos) { + //根据销售订单子表的物料编码和销售组织查询物料主表 + SaleOrderBVO[] saleOrderitems = vo.getChildrenVO(); + //循环销售订单子表 + for(int i = 0; i < saleOrderitems.length; i++) { + SaleOrderBVO item = saleOrderitems[i]; + //取销售订单子表的物料编码和销售组织 + String cmaterialvid = item.getCmaterialvid(); //物料主键 + String pk_org = item.getPk_org(); //销售组织 + UFDouble nqtorigprice = item.getNqtorigprice(); //无税单价 + IMDPersistenceQueryService aggvoQueryService = NCLocator.getInstance().lookup(IMDPersistenceQueryService.class); + // 条件查询得到物料MaterialSaleVO + try { + String whereSql = "nvl(bd_materialsale.dr,0) = 0 and bd_materialsale.pk_material = '" + cmaterialvid + "' and bd_materialsale.pk_org = '" + pk_org + "'"; + @SuppressWarnings("unchecked") + ArrayList materialSaleVOs = (ArrayList)aggvoQueryService.queryBillOfVOByCond(MaterialSaleVO.class, whereSql, true, false); + if(materialSaleVOs.size() <= 0) { + continue; + } + for(MaterialSaleVO materialSaleVO : materialSaleVOs) { + materialSaleVO.setResaleprice(nqtorigprice); + //实体更新物料销售表 +// IMaterialSaleService iMaterialSaleService = ServiceLocator.find(IMaterialSaleService.class); + IMaterialSaleService iMaterialSaleService = NCLocator.getInstance().lookup(IMaterialSaleService.class); + iMaterialSaleService.updateMaterialSaleVO(materialSaleVO); + } + }catch(BusinessException e) { + // TODO Auto-generated catch block + e.printStackTrace(); + } + } + } + } + +} diff --git a/sscivm/src/private/nccloud/itf/sscivm/ivsale/impl/IVApplicationServiceImpl.java b/sscivm/src/private/nccloud/itf/sscivm/ivsale/impl/IVApplicationServiceImpl.java new file mode 100644 index 00000000..6c9fa632 --- /dev/null +++ b/sscivm/src/private/nccloud/itf/sscivm/ivsale/impl/IVApplicationServiceImpl.java @@ -0,0 +1,938 @@ +// +// Source code recreated from a .class file by IntelliJ IDEA +// (powered by FernFlower decompiler) +// + +package nccloud.itf.sscivm.ivsale.impl; + +import com.alibaba.fastjson.JSON; +import com.alibaba.fastjson.JSONObject; +import com.google.gson.Gson; +import com.google.gson.internal.LinkedTreeMap; +import java.util.ArrayList; +import java.util.HashMap; +import java.util.HashSet; +import java.util.List; +import java.util.Map; +import java.util.Set; +import nc.bs.businessevent.EventDispatcher; +import nc.bs.dao.BaseDAO; +import nc.bs.framework.common.InvocationInfoProxy; +import nc.bs.framework.common.NCLocator; +import nc.bs.framework.common.RuntimeEnv; +import nc.bs.pub.pf.PfUtilTools; +import nc.bs.sscivm.ivsale.bp.IVApplicationDeleteBP; +import nc.bs.sscivm.ivsale.bp.IVApplicationInsertBP; +import nc.bs.sscivm.ivsale.bp.IVApplicationQueryBP; +import nc.bs.sscivm.ivsale.bp.IVApplicationUpdateBP; +import nc.bs.sscivm.ivsale.splitmerge.util.TransSpiltMergePksUtil; +import nc.bs.sscivm.ivsale.util.ApplicationBusinessEvent; +import nc.bs.sscivm.ivsale.util.IVApplicationBillDefValue; +import nc.bs.sscivm.ivsale.util.IVApplicationSlsmUtil; +import nc.bs.sscivm.ivsale.util.IVSaleUtil; +import nc.bs.sscivm.logger.SSCIVMLogger; +import nc.bs.sscivm.util.IVMSagaValidationUtils; +import nc.impl.pubapp.pattern.data.bill.tool.BillTransferTool; +import nc.itf.bd.material.baseinfo.IMaterialBaseInfoQueryService; +import nc.itf.uap.pf.IWorkflowDefine; +import nc.itf.uap.pf.IWorkflowMachine; +import nc.itf.uap.pf.metadata.IFlowBizItf; +import nc.jdbc.framework.processor.ColumnProcessor; +import nc.pubitf.bbd.CurrtypeQuery; +import nc.pubitf.para.SysInitQuery; +import nc.pubitf.uapbd.CurrencyRateUtilHelper; +import nc.pubitf.uapbd.ICustomerPubService; +import nc.pubitf.uapbd.IMaterialPubService; +import nc.uap.pf.metadata.PfMetadataTools; +import nc.vo.bd.currtype.CurrtypeVO; +import nc.vo.bd.material.MaterialVO; +import nc.vo.bd.material.MaterialVersionVO; +import nc.vo.ic.pub.util.StringUtil; +import nc.vo.ml.NCLangRes4VoTransl; +import nc.vo.org.OrgQueryUtil; +import nc.vo.org.OrgVO; +import nc.vo.pf.pub.util.SQLUtil; +import nc.vo.pub.AggregatedValueObject; +import nc.vo.pub.BusinessException; +import nc.vo.pub.CircularlyAccessibleValueObject; +import nc.vo.pub.lang.UFBoolean; +import nc.vo.pub.lang.UFDate; +import nc.vo.pub.lang.UFDateTime; +import nc.vo.pub.lang.UFDouble; +import nc.vo.pub.workflownote.WorkflownoteVO; +import nc.vo.pubapp.pattern.exception.ExceptionUtils; +import nc.vo.sscivm.ivmpub.IVAplocationFPXZ; +import nc.vo.sscivm.ivmpub.IVAplocationKPFS; +import nc.vo.sscivm.ivsale.IVApplicationAggVO; +import nc.vo.sscivm.ivsale.IVApplicationBodyVO; +import nc.vo.sscivm.ivsale.IVApplicationHeadVO; +import nc.vo.sscivm.ivsale.IVApplogVO; +import nc.vo.sscivm.ivsale.IVBilltypeVO; +import nc.vo.sscivm.ivsale.IVTspzsBodyVO; +import nc.vo.sscivm.ivsale.MessageVO; +import nc.vo.uap.pf.PFBusinessException; +import nc.vo.uap.pf.PfProcessBatchRetObject; +import nc.vo.wfengine.definition.WorkflowTypeEnum; +import nccloud.commons.lang.StringUtils; +import nccloud.itf.sscivm.ivsale.service.ApplicationLogService; +import nccloud.itf.sscivm.ivsale.service.IVABilltypeExtService; +import nccloud.itf.sscivm.ivsale.service.IVApplicationInvoiceService; +import nccloud.itf.sscivm.ivsale.service.IVApplicationQueryService; +import nccloud.itf.sscivm.ivsale.service.IVApplicationService; +import nccloud.pubitf.riart.pflow.CloudPFlowContext; +import nccloud.pubitf.riart.pflow.ICloudScriptPFlowService; +import nccloud.putitf.riart.billtype.IBilltypeService; + +public class IVApplicationServiceImpl implements IVApplicationService { + public IVApplicationServiceImpl() { + } + + public IVApplicationAggVO save(IVApplicationAggVO ivApplicationVO) throws BusinessException { + IVApplicationAggVO[] ivApplicationVOs = null; + + try { + ivApplicationVOs = this.saveBatch(new IVApplicationAggVO[]{ivApplicationVO}); + } catch (Exception e) { + SSCIVMLogger.error(e.getMessage(), e); + ExceptionUtils.marsh(e); + } + + return ivApplicationVOs != null && ivApplicationVOs.length != 0 ? ivApplicationVOs[0] : null; + } + + public IVApplicationAggVO[] saveBatch(IVApplicationAggVO[] clientFullVOs) throws BusinessException { + IVApplicationAggVO[] retvos = null; + HashSet retVOLits = new HashSet(); + + try { + IVApplicationInsertBP action = new IVApplicationInsertBP(); + retvos = action.insert(clientFullVOs); + HashSet tradetypeids = new HashSet(); + + for(IVApplicationAggVO applicationAggVO : retvos) { + tradetypeids.add(applicationAggVO.getParentVO().getTranstypecode()); + } + + IVABilltypeExtService var10000 = (IVABilltypeExtService)NCLocator.getInstance().lookup(IVABilltypeExtService.class); + String var10001 = InvocationInfoProxy.getInstance().getGroupId(); + IVBilltypeVO[] billtypeVOS = var10000.getBilltypeVOsByWhere(" pk_group ='" + var10001 + "' and " + SQLUtil.buildSqlForIn("billtypecode", (String[])tradetypeids.toArray(new String[tradetypeids.size()]))); + if (billtypeVOS != null && billtypeVOS.length > 0) { + HashSet atuoVOs = new HashSet(); + HashSet noatuoVOs = new HashSet(); + + for(IVApplicationAggVO retvo : retvos) { + boolean Isatuo_submit = UFBoolean.FALSE.booleanValue(); + + for(IVBilltypeVO billtypeVO : billtypeVOS) { + if (retvo.getParentVO().getTranstypecode() != null && retvo.getParentVO().getTranstypecode().equals(billtypeVO.getBilltypecode()) && billtypeVO.getIsatuo_submit() == UFBoolean.TRUE) { + Isatuo_submit = UFBoolean.TRUE.booleanValue(); + } + } + + if (Isatuo_submit) { + atuoVOs.add(retvo); + } else { + noatuoVOs.add(retvo); + } + } + + if (atuoVOs != null && atuoVOs.size() > 0) { + Object submitObj = this.submit((IVApplicationAggVO[])atuoVOs.toArray(new IVApplicationAggVO[atuoVOs.size()]), (IVApplicationAggVO[])null, (Object)null); + if (submitObj instanceof Map) { + throw new BusinessException(NCLangRes4VoTransl.getNCLangRes().getStrByID("1058sal_0", "01058sal-0053")); + } + + retvos = (IVApplicationAggVO[])submitObj; + if (retvos != null && retvos.length > 0) { + for(IVApplicationAggVO retvo : retvos) { + retVOLits.add(retvo); + } + + if (noatuoVOs != null && noatuoVOs.size() > 0) { + retVOLits.addAll(noatuoVOs); + } + } + + retvos = (IVApplicationAggVO[])retVOLits.toArray(new IVApplicationAggVO[retVOLits.size()]); + } else if (noatuoVOs != null && noatuoVOs.size() > 0) { + retVOLits.addAll(noatuoVOs); + retvos = (IVApplicationAggVO[])retVOLits.toArray(new IVApplicationAggVO[retVOLits.size()]); + } + } + } catch (Exception e) { + SSCIVMLogger.error(e.getMessage(), e); + ExceptionUtils.marsh(e); + } + + return retvos; + } + + public void deleteById(String pk) throws BusinessException { + this.deleteByIds(new String[]{pk}); + } + + public void deleteByIds(String[] pks) throws BusinessException { + IVApplicationAggVO[] retvos = (new IVApplicationQueryBP()).queryAggIVApplicationVOByCondition(SQLUtil.buildSqlForIn("pk_ivapplication", pks)); + (new IVApplicationDeleteBP()).delete(retvos); + } + + public void delete(IVApplicationAggVO vo) throws BusinessException { + try { + (new IVApplicationDeleteBP()).delete(new IVApplicationAggVO[]{vo}); + } catch (Exception e) { + SSCIVMLogger.error(e.getMessage(), e); + ExceptionUtils.marsh(e); + } + + } + + public void deleteBatch(IVApplicationAggVO[] vos) throws BusinessException { + try { + (new IVApplicationDeleteBP()).delete(vos); + } catch (Exception e) { + SSCIVMLogger.error(e.getMessage(), e); + ExceptionUtils.marsh(e); + } + + } + + public void deleteBatchdUnCheckApproveStaus(IVApplicationAggVO[] vos) throws BusinessException { + try { + (new IVApplicationDeleteBP()).deleteUnCheckApproveStaus(vos); + } catch (Exception e) { + SSCIVMLogger.error(e.getMessage(), e); + ExceptionUtils.marsh(e); + } + + } + + public IVApplicationAggVO update(IVApplicationAggVO ivApplicationVO) throws BusinessException { + IVApplicationAggVO[] retvos = null; + + try { + if (ivApplicationVO == null || ivApplicationVO.getParentVO() == null) { + return null; + } + + Integer approveStatus = ivApplicationVO.getParentVO().getBillstatus(); + if (approveStatus == 1) { + throw new BusinessException(NCLangRes4VoTransl.getNCLangRes().getStrByID("1058sal_0", "01058sal-0024")); + } + + if (approveStatus == 3 || approveStatus == 2) { + String billId = ivApplicationVO.getParentVO().getPk_ivapplication(); + String billType = ivApplicationVO.getParentVO().getTranstypecode(); + String userId = InvocationInfoProxy.getInstance().getUserId(); + if (!this.isFlowCheckman(billId, billType, userId)) { + throw new BusinessException(NCLangRes4VoTransl.getNCLangRes().getStrByID("1058sal_0", "01058sal-0050")); + } + } + + retvos = this.updateBatch(new IVApplicationAggVO[]{ivApplicationVO}, (IVApplicationAggVO[])null); + if (retvos != null && retvos.length > 0) { + CircularlyAccessibleValueObject[] bodys = retvos[0].getChildrenVO(); + if (bodys != null && bodys.length > 0) { + for(int m = 0; m < bodys.length; ++m) { + CircularlyAccessibleValueObject body = bodys[m]; + body.setAttributeValue("rowid", ivApplicationVO.getChildrenVO()[m].getAttributeValue("rowid")); + } + } + } + } catch (Exception e) { + SSCIVMLogger.error(e.getMessage(), e); + ExceptionUtils.marsh(e); + } + + return retvos != null && retvos.length != 0 ? retvos[0] : null; + } + + public IVApplicationAggVO[] updateBatch(IVApplicationAggVO[] clientFullVOs, IVApplicationAggVO[] originBills) throws BusinessException { + IVApplicationAggVO[] retvos = null; + + try { + BillTransferTool transferTool = new BillTransferTool(clientFullVOs); + IVApplicationUpdateBP action = new IVApplicationUpdateBP(); + originBills = (IVApplicationAggVO[])transferTool.getOriginBills(); + retvos = action.update(clientFullVOs, originBills); + } catch (Exception e) { + SSCIVMLogger.error(e.getMessage(), e); + ExceptionUtils.marsh(e); + } + + return retvos; + } + + public IVApplicationAggVO updateForUI(IVApplicationAggVO ivApplicationVO) throws BusinessException { + IVApplicationAggVO[] retvos = null; + + try { + if (ivApplicationVO == null || ivApplicationVO.getParentVO() == null) { + return null; + } + + Integer approveStatus = ivApplicationVO.getParentVO().getBillstatus(); + if (approveStatus == 1) { + throw new BusinessException(NCLangRes4VoTransl.getNCLangRes().getStrByID("1058sal_0", "01058sal-0024")); + } + + if (approveStatus == 3 || approveStatus == 2) { + String billId = ivApplicationVO.getParentVO().getPk_ivapplication(); + String billType = ivApplicationVO.getParentVO().getTranstypecode(); + String userId = InvocationInfoProxy.getInstance().getUserId(); + if (!this.isFlowCheckman(billId, billType, userId)) { + throw new BusinessException(NCLangRes4VoTransl.getNCLangRes().getStrByID("1058sal_0", "01058sal-0050")); + } + } + + //如果来源单据为销售发票,根据来源单据编号src_billno和来源单据类型（billtype = 32）查询销售发票价税合计（ntotalorigmny）与开票申请中价税合计（jshj）比较，须满足 jshj 0){ + throw new BusinessException("价税合计不能超过销售发票中价税合计"); + } + } + + retvos = this.updateBatchForUI(new IVApplicationAggVO[]{ivApplicationVO}, (IVApplicationAggVO[])null); + if (retvos != null && retvos.length > 0) { + CircularlyAccessibleValueObject[] bodys = retvos[0].getChildrenVO(); + if (bodys != null && bodys.length > 0) { + for(int m = 0; m < bodys.length; ++m) { + CircularlyAccessibleValueObject body = bodys[m]; + body.setAttributeValue("rowid", ivApplicationVO.getChildrenVO()[m].getAttributeValue("rowid")); + } + } + } + } catch (Exception e) { + SSCIVMLogger.error(e.getMessage(), e); + ExceptionUtils.marsh(e); + } + + return retvos != null && retvos.length != 0 ? retvos[0] : null; + } + + private IVApplicationAggVO[] updateBatchForUI(IVApplicationAggVO[] clientFullVOs, IVApplicationAggVO[] originBills) throws BusinessException { + IVApplicationAggVO[] retvos = null; + + try { + BillTransferTool transferTool = new BillTransferTool(clientFullVOs); + IVApplicationUpdateBP action = new IVApplicationUpdateBP(); + originBills = (IVApplicationAggVO[])transferTool.getOriginBills(); + retvos = action.update(clientFullVOs, originBills); + Map pkAndOldVOMap = new HashMap(); + + for(IVApplicationAggVO aggVO : originBills) { + pkAndOldVOMap.put(aggVO.getPrimaryKey(), aggVO); + } + + HashSet tradetypeids = new HashSet(); + + for(IVApplicationAggVO applicationAggVO : retvos) { + IVApplicationAggVO oldApplicationAggVO = (IVApplicationAggVO)pkAndOldVOMap.get(applicationAggVO.getPrimaryKey()); + if (applicationAggVO.getParentVO().getBillstatus() == -1 && oldApplicationAggVO.getParentVO().getBillstatus() == -1) { + tradetypeids.add(applicationAggVO.getParentVO().getTranstypecode()); + } + } + + if (tradetypeids.size() == 0) { + return retvos; + } + + IVABilltypeExtService var10000 = (IVABilltypeExtService)NCLocator.getInstance().lookup(IVABilltypeExtService.class); + String var10001 = InvocationInfoProxy.getInstance().getGroupId(); + IVBilltypeVO[] billtypeVOS = var10000.getBilltypeVOsByWhere(" pk_group ='" + var10001 + "' and " + SQLUtil.buildSqlForIn("billtypecode", (String[])tradetypeids.toArray(new String[tradetypeids.size()]))); + if (billtypeVOS != null && billtypeVOS.length > 0) { + HashSet atuoVOs = new HashSet(); + HashSet noatuoVOs = new HashSet(); + + for(IVApplicationAggVO retvo : retvos) { + boolean Isatuo_submit = UFBoolean.FALSE.booleanValue(); + + for(IVBilltypeVO billtypeVO : billtypeVOS) { + if (retvo.getParentVO().getTranstypecode() != null && retvo.getParentVO().getTranstypecode().equals(billtypeVO.getBilltypecode()) && billtypeVO.getIsatuo_submit() == UFBoolean.TRUE) { + Isatuo_submit = UFBoolean.TRUE.booleanValue(); + } + } + + if (Isatuo_submit) { + atuoVOs.add(retvo); + } else { + noatuoVOs.add(retvo); + } + } + + List retVOLits = new ArrayList(); + if (atuoVOs != null && atuoVOs.size() > 0) { + Object submitObj = this.submit((IVApplicationAggVO[])atuoVOs.toArray(new IVApplicationAggVO[atuoVOs.size()]), (IVApplicationAggVO[])null, (Object)null); + if (submitObj instanceof Map) { + throw new BusinessException(NCLangRes4VoTransl.getNCLangRes().getStrByID("1058sal_0", "01058sal-0053")); + } + + retvos = (IVApplicationAggVO[])submitObj; + if (retvos != null && retvos.length > 0) { + for(IVApplicationAggVO retvo : retvos) { + retVOLits.add(retvo); + } + + if (noatuoVOs != null && noatuoVOs.size() > 0) { + retVOLits.addAll(noatuoVOs); + } + } + + retvos = (IVApplicationAggVO[])retVOLits.toArray(new IVApplicationAggVO[retVOLits.size()]); + } else if (noatuoVOs != null && noatuoVOs.size() > 0) { + retVOLits.addAll(noatuoVOs); + retvos = (IVApplicationAggVO[])retVOLits.toArray(new IVApplicationAggVO[retVOLits.size()]); + } + } + } catch (Exception e) { + SSCIVMLogger.error(e.getMessage(), e); + ExceptionUtils.marsh(e); + } + + return retvos; + } + + public Object submit(IVApplicationAggVO[] clientBills, IVApplicationAggVO[] originBills, Object assingUsers) throws BusinessException { + if (clientBills != null && clientBills.length > 0) { + String[] pks = new String[clientBills.length]; + + for(int i = 0; i < clientBills.length; ++i) { + pks[i] = clientBills[i].getParentVO().getPk_ivapplication(); + } + + IVMSagaValidationUtils.checkSagaStatus(pks, IVApplicationHeadVO.getDefaultTableName(), "pk_ivapplication"); + } + + List retvos = new ArrayList(); + + try { + for(int i = 0; i < clientBills.length; ++i) { + AggregatedValueObject billVO = clientBills[i]; + if (clientBills[i].getParentVO().getBillstatus() != -1) { + String var10002 = NCLangRes4VoTransl.getNCLangRes().getStrByID("1058sal_0", "01058sal-0025"); + throw new BusinessException(var10002 + (i + 1) + NCLangRes4VoTransl.getNCLangRes().getStrByID("1058sal_0", "01058sal-0026")); + } + + Object retObj = this.doNccCommit(billVO, assingUsers); + if (retObj instanceof Map) { + return retObj; + } + + if (retObj != null) { + retvos.add((IVApplicationAggVO)((MessageVO)retObj).getSuccessVO()); + } + } + } catch (Exception e) { + SSCIVMLogger.error(e.getMessage(), e); + ExceptionUtils.marsh(e); + } + + return retvos.toArray(new IVApplicationAggVO[retvos.size()]); + } + + private Object doNccCommit(AggregatedValueObject aggVos, Object assingUsers) throws Exception { + MessageVO result = null; + IVApplicationQueryService ivApplicationQueryService = (IVApplicationQueryService)NCLocator.getInstance().lookup(IVApplicationQueryService.class); + AggregatedValueObject billVO = aggVos; + String djlxbm = null; + + try { + if (billVO.getParentVO() instanceof IVApplicationHeadVO) { + IVApplicationAggVO[] submitVos = ivApplicationQueryService.queryAggVOsByPks(new String[]{((IVApplicationHeadVO)billVO.getParentVO()).getPrimaryKey()}); + if (submitVos != null && submitVos.length > 0 && (null == ((IVApplicationHeadVO)billVO.getParentVO()).getTs() || ((IVApplicationHeadVO)billVO.getParentVO()).getTs().compareTo(submitVos[0].getParentVO().getTs()) != 0)) { + throw new Exception(NCLangRes4VoTransl.getNCLangRes().getStrByID("1058sal_0", "01058sal-0057")); + } + + String tradetypePk = ((IVApplicationHeadVO)billVO.getParentVO()).getPk_tradetype(); + djlxbm = ((IBilltypeService)NCLocator.getInstance().lookup(IBilltypeService.class)).getBilltypeCode(tradetypePk); + } + + Object retObj = null; + HashMap paramMap = new HashMap(); + paramMap.put("silently", "silently"); + String cuserid = InvocationInfoProxy.getInstance().getUserId(); + UFDateTime currTime = new UFDateTime(InvocationInfoProxy.getInstance().getBizDateTime()); + WorkflownoteVO noteVO = null; + + try { + noteVO = ((IWorkflowMachine)NCLocator.getInstance().lookup(IWorkflowMachine.class)).checkWorkFlow("SAVE", djlxbm, billVO, (HashMap)null); + } catch (BusinessException e) { + SSCIVMLogger.error(e.getMessage(), e); + } + + boolean hasWorkfFlow = false; + if (noteVO == null) { + try { + IFlowBizItf fbi = (IFlowBizItf)PfMetadataTools.getBizItfImpl(billVO, IFlowBizItf.class); + IWorkflowDefine wfDefine = (IWorkflowDefine)NCLocator.getInstance().lookup(IWorkflowDefine.class); + hasWorkfFlow = wfDefine.hasValidProcessDef(((IVApplicationHeadVO)billVO.getParentVO()).getPk_org(), ((IVApplicationHeadVO)billVO.getParentVO()).getTranstypecode(), fbi.getPkorg(), fbi.getBillMaker(), fbi.getEmendEnum(), WorkflowTypeEnum.Workflow.getIntValue()); + if (!hasWorkfFlow) { + hasWorkfFlow = wfDefine.hasValidProcessDef(InvocationInfoProxy.getInstance().getGroupId(), ((IVApplicationHeadVO)billVO.getParentVO()).getTranstypecode(), fbi.getPkorg(), fbi.getBillMaker(), fbi.getEmendEnum(), WorkflowTypeEnum.Workflow.getIntValue()); + } + } catch (PFBusinessException var16) { + String err = NCLangRes4VoTransl.getNCLangRes().getStrByID("pfworkflow", "UPPpfworkflow-000058"); + if (var16.getMessage() == null || !var16.getMessage().contains(err)) { + throw new PFBusinessException(var16); + } + } + + if (!hasWorkfFlow) { + ((IVApplicationHeadVO)billVO.getParentVO()).setApprover(cuserid); + ((IVApplicationHeadVO)billVO.getParentVO()).setApprovedate(currTime); + ((IVApplicationHeadVO)billVO.getParentVO()).setBillstatus(1); + UFDate preDate = ((IVApplicationHeadVO)billVO.getParentVO()).getPreparedate(); + if (preDate.toStdString().substring(0, 10).compareTo(currTime.toStdString().substring(0, 10)) > 0) { + throw new BusinessException(NCLangRes4VoTransl.getNCLangRes().getStrByID("1058sal_0", "01058sal-0150")); + } + + retObj = this.approveVOs(new IVApplicationAggVO[]{(IVApplicationAggVO)billVO}); + } else { + retObj = this.commitScriptPFlow("START", djlxbm, billVO, assingUsers); + } + } else { + retObj = this.commitScriptPFlow("SAVE", djlxbm, billVO, assingUsers); + } + + if (retObj == null) { + result = new MessageVO(billVO, 8); + result.setSuccess(false); + result.setErrorMessage(NCLangRes4VoTransl.getNCLangRes().getStrByID("2011", "UPP2011-000339")); + } else { + if (retObj instanceof Map) { + return retObj; + } + + if (retObj instanceof AggregatedValueObject) { + result = new MessageVO((AggregatedValueObject)retObj, 8); + } else if (retObj instanceof MessageVO[]) { + MessageVO[] messages = (MessageVO[])retObj; + result = messages[0]; + } else if (retObj instanceof MessageVO) { + result = (MessageVO)retObj; + } else if (retObj instanceof PfProcessBatchRetObject) { + if ((PfProcessBatchRetObject)retObj != null && ((PfProcessBatchRetObject)retObj).getRetObj() != null) { + result = (MessageVO)((PfProcessBatchRetObject)retObj).getRetObj()[0]; + } else { + result = new MessageVO((AggregatedValueObject)null, 8); + } + } + } + } catch (Exception e) { + SSCIVMLogger.error(e.getMessage(), e); + ExceptionUtils.marsh(e); + } + + return result; + } + + private Object commitScriptPFlow(String actionName, String djlxbm, AggregatedValueObject aggVo, Object assingUsers) throws BusinessException { + new JSONObject(); + HashMap eParam = new HashMap(); + if (assingUsers instanceof LinkedTreeMap) { + JSONObject assignContent = JSON.parseObject((new Gson()).toJson(assingUsers)); + eParam.put("content", assignContent); + } + + eParam.put("silently", "silently"); + if ("START".equals(actionName)) { + String checkman = ""; + BaseDAO dao = new BaseDAO(); + String sql = " SELECT a.checkman FROM PUB_WORKFLOWNOTE a INNER JOIN PUB_WF_TASK b ON a.PK_WF_TASK = b.PK_WF_TASK WHERE a.billid ='" + aggVo.getParentVO().getPrimaryKey() + "' and a.actiontype='MAKEBILL' and b.REJECTTACHEACTIVITYID is not null and a.ischeck='N' "; + Object obj = dao.executeQuery(sql, new ColumnProcessor()); + if (obj != null) { + checkman = (String)obj; + actionName = "SIGNAL" + checkman; + } + } + + CloudPFlowContext context = new CloudPFlowContext(); + context.setActionName(actionName); + context.setBillType(djlxbm); + context.setBillVos(new AggregatedValueObject[]{aggVo}); + context.seteParam(eParam); + Object[] ss = null; + if ("START".equals(actionName)) { + WorkflownoteVO noteVO = null; + + try { + noteVO = ((IWorkflowMachine)NCLocator.getInstance().lookup(IWorkflowMachine.class)).checkWorkFlow("START", djlxbm, aggVo, (HashMap)null); + } catch (BusinessException e) { + SSCIVMLogger.error(e.getMessage(), e); + } + + WorkflowTypeEnum flowtype = PfUtilTools.runningFlowStatus(StringUtils.isNotEmpty(context.getTrantype()) ? context.getTrantype() : context.getBillType(), aggVo.getParentVO().getPrimaryKey()); + if (flowtype == null && (noteVO == null || noteVO.getTaskInfo().getAssignableInfos().size() == 0)) { + ss = ((ICloudScriptPFlowService)NCLocator.getInstance().lookup(ICloudScriptPFlowService.class)).exeScriptPFlow_CommitNoFlowBatch(context); + } + } + + if (ss == null) { + ss = ((ICloudScriptPFlowService)NCLocator.getInstance().lookup(ICloudScriptPFlowService.class)).exeScriptPFlow(context); + } + + Object obj = ss[0]; + if (obj instanceof Map map && ((Map)obj).get("workflow") != null && ("approveflow".equals(String.valueOf(((Map)obj).get("workflow"))) || "workflow".equals(String.valueOf(((Map)obj).get("workflow"))))) { + if (map.get("workflow") != null) { + return map; + } + } + + return obj; + } + + public IVApplicationAggVO[] recall(IVApplicationAggVO[] clientBills, IVApplicationAggVO[] originBills) throws BusinessException { + if (clientBills != null && clientBills.length > 0) { + String[] pks = new String[clientBills.length]; + + for(int i = 0; i < clientBills.length; ++i) { + pks[i] = clientBills[i].getParentVO().getPk_ivapplication(); + } + + IVMSagaValidationUtils.checkSagaStatus(pks, IVApplicationHeadVO.getDefaultTableName(), "pk_ivapplication"); + } + + List retvos = new ArrayList(); + + try { + for(int i = 0; i < clientBills.length; ++i) { + AggregatedValueObject billVO = clientBills[i]; + if (clientBills[i].getParentVO().getBillstatus() != 3 && clientBills[i].getParentVO().getBillstatus() != 1) { + String var11 = NCLangRes4VoTransl.getNCLangRes().getStrByID("1058sal_0", "01058sal-0025"); + throw new BusinessException(var11 + (i + 1) + NCLangRes4VoTransl.getNCLangRes().getStrByID("1058sal_0", "01058sal-0028")); + } + + List applogVOList = ((ApplicationLogService)NCLocator.getInstance().lookup(ApplicationLogService.class)).queryApplicationLogByLyid(TransSpiltMergePksUtil.transIvapplicationToLyid(new String[]{clientBills[i].getParentVO().getPk_ivapplication()})); + if (applogVOList != null && applogVOList.size() > 0) { + String var10002 = NCLangRes4VoTransl.getNCLangRes().getStrByID("1058sal_0", "01058sal-0029"); + throw new BusinessException(var10002 + clientBills[i].getParentVO().getBillno() + NCLangRes4VoTransl.getNCLangRes().getStrByID("1058sal_0", "01058sal-0030")); + } + + Object retObj = this.doNccRecall(billVO); + retvos.add((IVApplicationAggVO)((MessageVO)retObj).getSuccessVO()); + } + } catch (Exception e) { + SSCIVMLogger.error(e.getMessage(), e); + ExceptionUtils.marsh(e); + } + + return (IVApplicationAggVO[])retvos.toArray(new IVApplicationAggVO[retvos.size()]); + } + + private Object doNccRecall(AggregatedValueObject billVO) throws Exception { + MessageVO result = null; + IVApplicationQueryService ivApplicationQueryService = (IVApplicationQueryService)NCLocator.getInstance().lookup(IVApplicationQueryService.class); + String djlxbm = null; + + try { + if (billVO.getParentVO() instanceof IVApplicationHeadVO) { + IVApplicationAggVO[] submitVos = ivApplicationQueryService.queryAggVOsByPks(new String[]{((IVApplicationHeadVO)billVO.getParentVO()).getPrimaryKey()}); + if (submitVos != null && submitVos.length > 0 && (null == ((IVApplicationHeadVO)billVO.getParentVO()).getTs() || ((IVApplicationHeadVO)billVO.getParentVO()).getTs().compareTo(submitVos[0].getParentVO().getTs()) != 0)) { + throw new Exception(NCLangRes4VoTransl.getNCLangRes().getStrByID("1058sal_0", "01058sal-0057")); + } + + String tradetypePk = ((IVApplicationHeadVO)billVO.getParentVO()).getPk_tradetype(); + djlxbm = ((IBilltypeService)NCLocator.getInstance().lookup(IBilltypeService.class)).getBilltypeCode(tradetypePk); + } + + String actionName = "RECALL"; + boolean isApproveflowFlag = IVSaleUtil.isApproveFlowStartup(billVO.getParentVO().getPrimaryKey(), djlxbm); + if (isApproveflowFlag) { + actionName = "UNSAVE"; + } + + Object[] exeScriptPFlow = null; + CloudPFlowContext context = new CloudPFlowContext(); + context.setActionName(actionName); + context.setBillType(djlxbm); + context.setBillVos(new AggregatedValueObject[]{billVO}); + context.seteParam(new HashMap()); + WorkflowTypeEnum flowtype = PfUtilTools.runningFlowStatus(StringUtils.isNotEmpty(context.getTrantype()) ? context.getTrantype() : context.getBillType(), billVO.getParentVO().getPrimaryKey()); + ICloudScriptPFlowService service = (ICloudScriptPFlowService)NCLocator.getInstance().lookup(ICloudScriptPFlowService.class); + if (flowtype == null) { + exeScriptPFlow = service.exeScriptPFlow_UnSaveNoFlowBatch(context); + } else { + exeScriptPFlow = service.exeScriptPFlow(context); + } + + if (exeScriptPFlow[0] instanceof PfProcessBatchRetObject) { + if ((PfProcessBatchRetObject)exeScriptPFlow[0] != null && ((PfProcessBatchRetObject)exeScriptPFlow[0]).getRetObj() != null) { + result = new MessageVO((AggregatedValueObject)((PfProcessBatchRetObject)exeScriptPFlow[0]).getRetObj()[0], 9); + } else { + result = new MessageVO((AggregatedValueObject)null, 9); + } + } else if (exeScriptPFlow[0] instanceof AggregatedValueObject) { + result = new MessageVO((AggregatedValueObject)exeScriptPFlow[0], 9); + } + + return result; + } catch (Exception e) { + SSCIVMLogger.error(e.getMessage(), e); + throw e; + } + } + + public IVApplicationAggVO dealDefValue(String uistate, String pk_group, String pk_user, String pk_tradetype, String appcode) throws Exception { + IVApplicationAggVO retvos = new IVApplicationAggVO(); + IVApplicationBillDefValue billDefValue = new IVApplicationBillDefValue(); + if (!"onInit".equals(uistate) && !"add".equals(uistate)) { + if (!"onChange".equals(uistate) && "edit".equals(uistate)) { + } + } else { + retvos = billDefValue.getNewVO(pk_group, pk_user, pk_tradetype, appcode); + } + + return retvos; + } + + public String getOrgLocalCurrPK(String pk_org) throws BusinessException { + String orgLocalCurrPK = CurrencyRateUtilHelper.getInstance().getLocalCurrtypeByOrgID(pk_org); + return orgLocalCurrPK; + } + + public Integer getCurrDigit(String pk_currtype) throws BusinessException { + if (StringUtils.isEmpty(pk_currtype)) { + return 0; + } else { + CurrtypeVO currtypeVO = null; + if (RuntimeEnv.getInstance().isRunningInServer()) { + currtypeVO = CurrtypeQuery.getInstance().getCurrtypeVO(pk_currtype); + } + + return currtypeVO == null ? 0 : currtypeVO.getCurrdigit(); + } + } + + public String getOrgVersion(String voclassname, String name, String pk_org) throws Exception { + OrgVO[] vos = OrgQueryUtil.queryOrgVOByPks(new String[]{pk_org}); + return vos[0].getPk_vid(); + } + + public MessageVO[] approveVOs(IVApplicationAggVO[] applicationAggVOs) throws Exception { + if (applicationAggVOs != null && applicationAggVOs.length != 0) { + for(int i = 0; i < applicationAggVOs.length; ++i) { + applicationAggVOs[i].getParentVO().setStatus(1); + } + + IVApplicationAggVO[] aggVOs = this.updateBatch(applicationAggVOs, (IVApplicationAggVO[])null); + MessageVO[] msgs = new MessageVO[aggVOs.length]; + + for(int i = 0; i < aggVOs.length; ++i) { + msgs[i] = new MessageVO(aggVOs[i], 1); + } + + EventDispatcher.fireEvent(new ApplicationBusinessEvent("f4555e3d-c6a1-42bf-8354-57be38eb5dd6", "1020", aggVOs)); + IVApplicationInvoiceService applicationInvoiceService = (IVApplicationInvoiceService)NCLocator.getInstance().lookup(IVApplicationInvoiceService.class); + + for(int i = 0; i < aggVOs.length; ++i) { + String billTypePk = aggVOs[i].getParentVO().getPk_tradetype(); + String billtypeCode = ((IBilltypeService)NCLocator.getInstance().lookup(IBilltypeService.class)).getBilltypeCode(billTypePk); + IVBilltypeVO billtypeVO = ((IVABilltypeExtService)NCLocator.getInstance().lookup(IVABilltypeExtService.class)).getBilltypeVOByCode(billtypeCode, InvocationInfoProxy.getInstance().getGroupId()); + if (null != billtypeVO && IVApplicationSlsmUtil.slsmCheck(aggVOs[i]) && billtypeVO.getIsatuo_invoice() == UFBoolean.TRUE) { + JSONObject jsonObj = new JSONObject(); + IVApplicationAggVO[] voAfterMakeInvoice = applicationInvoiceService.makeInvoice(new IVApplicationAggVO[]{aggVOs[i]}, jsonObj, (Map)null, false); + msgs[i] = new MessageVO(voAfterMakeInvoice[0], 1); + } + } + + return msgs; + } else { + return null; + } + } + + public Object unApproveVOs(IVApplicationAggVO[] applicationAggVOs) throws BusinessException { + if (applicationAggVOs != null && applicationAggVOs.length != 0) { + for(int i = 0; i < applicationAggVOs.length; ++i) { + List applogVOList = ((ApplicationLogService)NCLocator.getInstance().lookup(ApplicationLogService.class)).queryApplicationLogByLyid(TransSpiltMergePksUtil.transIvapplicationToLyid(new String[]{applicationAggVOs[i].getParentVO().getPk_ivapplication()})); + if (applogVOList != null && applogVOList.size() > 0) { + String var10002 = NCLangRes4VoTransl.getNCLangRes().getStrByID("1058sal_0", "01058sal-0029"); + throw new BusinessException(var10002 + applicationAggVOs[i].getParentVO().getBillno() + NCLangRes4VoTransl.getNCLangRes().getStrByID("1058sal_0", "01058sal-0030")); + } + + applicationAggVOs[i].getParentVO().setStatus(1); + } + + IVApplicationAggVO[] aggVOs = this.updateBatch(applicationAggVOs, (IVApplicationAggVO[])null); + MessageVO[] msgs = new MessageVO[aggVOs.length]; + + for(int i = 0; i < aggVOs.length; ++i) { + msgs[i] = new MessageVO(aggVOs[i], 2); + } + + EventDispatcher.fireEvent(new ApplicationBusinessEvent("f4555e3d-c6a1-42bf-8354-57be38eb5dd6", "1022", aggVOs)); + return msgs; + } else { + return null; + } + } + + public IVApplicationAggVO copyApplication(String pk) throws Exception { + IVApplicationAggVO aggVO = ((IVApplicationQueryService)NCLocator.getInstance().lookup(IVApplicationQueryService.class)).queryByPK(pk); + if (aggVO == null) { + throw new BusinessException(NCLangRes4VoTransl.getNCLangRes().getStrByID("1058sal_0", "01058sal-0057")); + } else if (aggVO.getParentVO().getHzfp() != UFBoolean.TRUE && aggVO.getParentVO().getZffp() != UFBoolean.TRUE) { + if (aggVO.getParentVO().getSrc_pkbusibill() != null) { + throw new BusinessException(NCLangRes4VoTransl.getNCLangRes().getStrByID("1058sal_0", "01058sal-0032")); + } else { + IVApplicationAggVO copyVo = aggVO.clone(); + IVApplicationHeadVO headvo = copyVo.getParentVO(); + String[] headFieldNotCopy = new String[]{"pk_ivapplication", "approvedate", "approver", "billno", "billstatus", "creationtime", "creator", "kpr", "kpzt", "lyid", "modifiedtime", "modifier", "preparedate", "src_billno", "src_pkbusibill", "src_tradetype", "saga_frozen", "saga_gtxid", "saga_btxid", "saga_status", "invoiced_hjje", "invoiced_hjse", "invoiced_jshj", "invoiceing_hjje", "invoiceing_hjse", "invoiceing_jshj", "caninvoice_hjje", "caninvoice_hjse", "caninvoice_jshj", "hzxxsqb", "email", "slsm"}; + + for(int i = 0; i < headFieldNotCopy.length; ++i) { + headvo.setAttributeValue(headFieldNotCopy[i], (Object)null); + } + + Set meterialPKs = new HashSet(); + + for(int i = 0; i < copyVo.getChildrenVO().length; ++i) { + IVApplicationBodyVO bodyVO = (IVApplicationBodyVO)copyVo.getChildrenVO()[i]; + bodyVO.setPk_ivappdetail((String)null); + bodyVO.setPk_ivapplication((String)null); + bodyVO.setCaninvoice_se(UFDouble.ZERO_DBL); + bodyVO.setCaninvoice_xmje(UFDouble.ZERO_DBL); + bodyVO.setCaninvoice_xmjshj(UFDouble.ZERO_DBL); + bodyVO.setCaninvoice_xmsl(UFDouble.ZERO_DBL); + bodyVO.setInvoiced_se(UFDouble.ZERO_DBL); + bodyVO.setInvoiced_xmje(UFDouble.ZERO_DBL); + bodyVO.setInvoiced_xmjshj(UFDouble.ZERO_DBL); + bodyVO.setInvoiced_xmsl(UFDouble.ZERO_DBL); + bodyVO.setInvoiceing_se(UFDouble.ZERO_DBL); + bodyVO.setInvoiceing_xmje(UFDouble.ZERO_DBL); + bodyVO.setInvoiceing_xmjshj(UFDouble.ZERO_DBL); + bodyVO.setInvoiceing_xmsl(UFDouble.ZERO_DBL); + if (bodyVO.getPk_materiel() != null) { + meterialPKs.add(bodyVO.getPk_materiel()); + } + + if (IVAplocationFPXZ.FPXZ_ZCH.toIntValue() == bodyVO.getFphxz()) { + bodyVO.setHh((String)null); + bodyVO.setZkhhh((String)null); + } + } + + if (copyVo.getIvTspzsBodyVO() != null) { + for(int i = 0; i < copyVo.getIvTspzsBodyVO().length; ++i) { + IVTspzsBodyVO ivTspzsBodyVO = copyVo.getIvTspzsBodyVO()[i]; + ivTspzsBodyVO.setPk_ivtspzsdetail((String)null); + ivTspzsBodyVO.setPk_ivapplication((String)null); + ivTspzsBodyVO.setPk_ivappdetail((String)null); + } + } + + if (meterialPKs.size() > 0) { + Map meterialMap = new HashMap(); + MaterialVO[] materialVOS = ((IMaterialBaseInfoQueryService)NCLocator.getInstance().lookup(IMaterialBaseInfoQueryService.class)).queryDataByPks((String[])meterialPKs.toArray(new String[0])); + meterialPKs.clear(); + + for(MaterialVO materialVO : materialVOS) { + meterialPKs.add(materialVO.getPk_source()); + meterialMap.put(materialVO.getPk_material(), materialVO.getPk_source()); + } + + Map map = ((IMaterialPubService)NCLocator.getInstance().lookup(IMaterialPubService.class)).queryMaterialBaseInfoByOidPks((String[])meterialPKs.toArray(new String[0]), new String[]{"pk_material"}); + + for(int i = 0; i < copyVo.getChildrenVO().length; ++i) { + IVApplicationBodyVO bodyVO = (IVApplicationBodyVO)copyVo.getChildrenVO()[i]; + if (bodyVO.getPk_materiel() != null) { + bodyVO.setPk_materiel(((MaterialVersionVO)map.get(meterialMap.get(bodyVO.getPk_materiel()))).getPk_material()); + } + } + } + + String cuserid = InvocationInfoProxy.getInstance().getUserId(); + UFDateTime currTime = new UFDateTime(InvocationInfoProxy.getInstance().getBizDateTime()); + UFDate currDate = currTime.getDate(); + headvo.setBillstatus(-1); + headvo.setPreparedate(currDate); + headvo.setCreator(cuserid); + headvo.setCreationtime(currTime); + headvo.setModifier(cuserid); + headvo.setModifiedtime(currTime); + headvo.setHzfp(UFBoolean.FALSE); + headvo.setCkfp(UFBoolean.FALSE); + headvo.setZffp(UFBoolean.FALSE); + headvo.setFpdm(""); + headvo.setFphm(""); + Integer paramValue = SysInitQuery.getParaInt(headvo.getPk_org(), "SSCIVA01"); + headvo.setKpfs(paramValue == null ? IVAplocationKPFS.ZLKP.toIntValue() : paramValue); + Map map = new HashMap(); + map.put(headvo.getPk_customer(), headvo.getPreparedate()); + Map idMap = ((ICustomerPubService)NCLocator.getInstance().lookup(ICustomerPubService.class)).getCustomerLastVIDByOidAndDate(map); + headvo.setPk_customer_v((String)idMap.get(headvo.getPk_customer())); + + for(int i = 0; i < copyVo.getChildrenVO().length; ++i) { + IVApplicationBodyVO bodyvo = (IVApplicationBodyVO)copyVo.getChildrenVO()[i]; + bodyvo.setStatus(2); + } + + return copyVo; + } + } else { + throw new BusinessException(NCLangRes4VoTransl.getNCLangRes().getStrByID("1058sal_0", "01058sal-0031")); + } + } + + public boolean isFlowCheckman(String billId, String billType, String userId) throws BusinessException { + return IVSaleUtil.isCheckman(billId, billType, userId); + } + + public IVApplicationAggVO calHeadJe(IVApplicationAggVO vo) throws BusinessException { + UFDouble hjje = UFDouble.ZERO_DBL; + UFDouble hjse = UFDouble.ZERO_DBL; + UFDouble jshj = UFDouble.ZERO_DBL; + UFDouble can_hjje = UFDouble.ZERO_DBL; + UFDouble can_hjse = UFDouble.ZERO_DBL; + UFDouble can_jshj = UFDouble.ZERO_DBL; + + for(IVApplicationBodyVO bvo : vo.getBodyVOs()) { + if (bvo.getStatus() != 3) { + UFDouble xmje = bvo.getXmje() == null ? UFDouble.ZERO_DBL : bvo.getXmje(); + UFDouble se = bvo.getSe() == null ? UFDouble.ZERO_DBL : bvo.getSe(); + UFDouble xmjshj = bvo.getXmjshj() == null ? UFDouble.ZERO_DBL : bvo.getXmjshj(); + UFDouble can_xmje = bvo.getCaninvoice_xmje() == null ? UFDouble.ZERO_DBL : bvo.getCaninvoice_xmje(); + UFDouble can_se = bvo.getCaninvoice_se() == null ? UFDouble.ZERO_DBL : bvo.getCaninvoice_se(); + UFDouble can_xmjshj = bvo.getCaninvoice_xmjshj() == null ? UFDouble.ZERO_DBL : bvo.getCaninvoice_xmjshj(); + hjje = hjje.add(xmje); + hjse = hjse.add(se); + jshj = jshj.add(xmjshj); + can_hjje = can_hjje.add(can_xmje); + can_hjse = can_hjse.add(can_se); + can_jshj = can_jshj.add(can_xmjshj); + } + } + + IVApplicationHeadVO headvo = vo.getHeadVO(); + headvo.setHjje(hjje); + headvo.setHjse(hjse); + headvo.setJshj(jshj); + headvo.setCaninvoice_hjje(can_hjje); + headvo.setCaninvoice_hjse(can_hjse); + headvo.setCaninvoice_jshj(can_jshj); + return vo; + } +} diff --git a/uapbd/src/client/nccloud/web/uapbd/ref/pub/MaterialGridRef.java b/uapbd/src/client/nccloud/web/uapbd/ref/pub/MaterialGridRef.java new file mode 100644 index 00000000..f76a73bd --- /dev/null +++ b/uapbd/src/client/nccloud/web/uapbd/ref/pub/MaterialGridRef.java @@ -0,0 +1,70 @@ +// +// Source code recreated from a .class file by IntelliJ IDEA +// (powered by FernFlower decompiler) +// + +package nccloud.web.uapbd.ref.pub; + +import nc.uap.utils.SQLHelper; +import nc.vo.bd.material.MaterialVO; +import nc.vo.bd.material.MaterialVersionVO; +import nc.vo.bd.material.marbasclass.MarBasClassVO; +import nc.vo.ml.MultiLangUtil; +import nccloud.framework.web.processor.IRefSqlBuilder; +import nccloud.framework.web.processor.refgrid.RefQueryInfo; +import nccloud.framework.web.ui.meta.RefMeta; +import nccloud.framework.web.ui.meta.TreeRefMeta; +import nccloud.web.refer.action.DefaultTreeGridRefAction; +import nccloud.web.refer.sqlbuilder.StrongDefaultTreeGridRefSqlBuilder; + +public class MaterialGridRef extends DefaultTreeGridRefAction { + public MaterialGridRef() { + this.setClassPkFieldName("pk_marbasclass"); + this.setClassTableName((new MarBasClassVO()).getTableName()); + this.setClassIsShowDisableData(false); + this.setClassMdClassId("c099f7d7-52a9-4b98-bee7-2e3a6c3ea263"); + this.setClassResourceCode("materialbasclass"); + this.setShowDisabledData(false); + this.setUnitPkKey("pk_org"); + this.setMdClassId("c7dc0ccd-8872-4eee-8882-160e8f49dfad"); + this.setResourceCode("material_v"); + this.setUsualDataPkFieldName("pk_material"); + this.setUsualDataTableName(MaterialVO.getDefaultTableName()); + } + + public String getOrderSql(RefQueryInfo paramRefQueryInfo, RefMeta paramRefMeta) { + return " order by code"; + } + + public RefMeta getRefMeta(RefQueryInfo refQueryInfo) { + TreeRefMeta meta = new TreeRefMeta(); + meta.setCodeField("code"); + meta.setNameField("name"); + meta.setFullTxtNameField("name" + MultiLangUtil.getCurrentLangSeqSuffix()); + meta.setPkField("pk_source"); + meta.setPidField("pk_marbasclass"); + meta.setMutilLangNameRef(true); + meta.setExtraFields(new String[]{"pk_org", "materialspec", "materialtype", "materialshortname", + "materialmnecode", "graphid", "pk_measdoc", "measdoc_name", "org_name", "materialmgt", "pk_material", "memo"}); + String var10001 = SQLHelper.getMultiLangNameColumn("bd_material_v.name"); + meta.setTableName("(select bd_material_v.pk_material as pk_material, bd_material_v.pk_marbasclass as pk_marbasclass," + + " bd_material_v.pk_org as pk_org,bd_material_v.dr as dr,bd_material_v.setpartsflag as setpartsflag,bd_material_v.code as code," + + var10001 + " as name,bd_material_v.version as version,bd_material_v.enablestate as enablestate," + + "bd_material_v.discountflag as discountflag,bd_material_v.fee as fee,bd_material_v.pk_group as pk_group," + + "bd_material_v.materialspec as materialspec,bd_material_v.materialtype as materialtype,bd_material_v.materialshortname as materialshortname," + + "bd_material_v.materialmgt as materialmgt,bd_material_v.materialmnecode as materialmnecode,bd_material_v.graphid as graphid," + + "bd_material_v.pk_measdoc as pk_measdoc,bd_material_v.pk_source as pk_source,bd_material_v.memo as memo,bd_material_v.retail as retail, " + + "bd_material_v.electronicsale as electronicsale, bd_material_v.isfeature as isfeature,bd_material_v.matchmode as matchmode, " + + SQLHelper.getMultiLangNameColumn("org_orgs.name") + " as org_name," + SQLHelper.getMultiLangNameColumn("bd_measdoc.name") + + " as measdoc_name,bd_material_v.name2 as name2,bd_material_v.name3 as name3,bd_material_v.name4 as name4,bd_material_v.name5 as name5," + + "bd_material_v.name6 as name6 from bd_material_v left join org_orgs on bd_material_v.pk_org=org_orgs.pk_org " + + "left join bd_measdoc on bd_material_v.pk_measdoc = bd_measdoc.pk_measdoc ) aa"); + meta.setDefaultTableName(MaterialVersionVO.getDefaultTableName()); + meta.setFullTxtTabName(MaterialVersionVO.getDefaultTableName()); + return meta; + } + + protected IRefSqlBuilder getRefSqlBuilder(RefQueryInfo refQueryInfo) { + return new StrongDefaultTreeGridRefSqlBuilder(this, this, refQueryInfo); + } +} diff --git a/uapbd/src/private/nc/bs/uapbd/task/InvoiceTaskPlugin.java b/uapbd/src/private/nc/bs/uapbd/task/InvoiceTaskPlugin.java new file mode 100644 index 00000000..96e1c5b0 --- /dev/null +++ b/uapbd/src/private/nc/bs/uapbd/task/InvoiceTaskPlugin.java @@ -0,0 +1,122 @@ +package nc.bs.uapbd.task; + +import nc.bs.dao.BaseDAO; +import nc.bs.logging.Logger; +import nc.bs.pub.pa.PreAlertObject; +import nc.bs.pub.taskcenter.BgWorkingContext; +import nc.bs.pub.taskcenter.IBackgroundWorkPlugin; +import nc.bs.trade.business.HYSuperDMO; +import nc.jdbc.framework.processor.MapListProcessor; +import nc.vo.pub.BusinessException; +import nc.vo.sscivm.ivsale.IVApplicationHeadVO; +import nc.vo.sscivm.ivsale.IVApplogVO; +import uap.mw.trans.TransactionFactory; + +import java.util.ArrayList; +import java.util.HashMap; + +public class InvoiceTaskPlugin implements IBackgroundWorkPlugin{ + + @Override + public PreAlertObject executeTask(BgWorkingContext arg0) throws BusinessException { + // TODO Auto-generated method stub + Logger.error("---start----任务开始运行--"); + try { + BaseDAO dao = new BaseDAO(); + String sql = " SELECT sscivm_invoice.pk_invoice,so_saleinvoice.csaleinvoiceid,so_saleinvoice.vbillcode billcode, sscivm_invoice.fphm, " + + "sscivm_invoice.Gmfmc, sscivm_invoice.Jshj, sscivm_invoice.viewurl, sscivm_invoice.billno " + + " FROM sscivm_invoice " + + " left join sscivm_invoice_relation on sscivm_invoice_relation.PK_INVOICE = sscivm_invoice.pk_invoice " + + " left join so_saleinvoice on so_saleinvoice.csaleinvoiceid = sscivm_invoice_relation.billid " + + " left join sscivm_ivapplog on sscivm_ivapplog.fphm = sscivm_invoice.fphm " + + " where " + + " sscivm_invoice_relation.billtype = '32' " + + " and so_saleinvoice.vdef20 <> 'Y' " + + " and sscivm_invoice.dr = 0 " + + " and sscivm_ivapplog.kpzt = 2 "; +// + " so_saleinvoice.vbillcode = 'SI2024070400000738' "; + ArrayList> al = (ArrayList>)dao.executeQuery(sql, new MapListProcessor()); + Logger.error("---alData------"+al); + if(al.size() > 0) { + for(HashMap sscivm_invoice : al) { + Object pk_invoice = sscivm_invoice.get("pk_invoice"); //bip发票主键 + Object csaleinvoiceid = sscivm_invoice.get("csaleinvoiceid"); //销售发票id + Object billcode = sscivm_invoice.get("billcode"); //销售发票编码 + Object billno = sscivm_invoice.get("billno"); //bip单据编码编码 + Object fphm = sscivm_invoice.get("fphm"); + Object Gmfmc = sscivm_invoice.get("Gmfmc"); + Object Jshj = sscivm_invoice.get("Jshj"); + Object viewurl = sscivm_invoice.get("viewurl"); + String ctcode=""; + HYSuperDMO dmo = new HYSuperDMO(); + IVApplogVO[] ivApplogVO=(IVApplogVO[]) dmo.queryByWhereClause(IVApplogVO.class, "fphm='"+fphm+"' and dr=0 "); + Logger.error("---ivApplogVO------"+ivApplogVO); + if(ivApplogVO!=null&&ivApplogVO.length>0) { + ivApplogVO[0].getLyid();//开票申请单主键 + IVApplicationHeadVO ivApplicationHeadVO =(IVApplicationHeadVO) dmo.queryByPrimaryKey(IVApplicationHeadVO.class, ivApplogVO[0].getLyid()); + ctcode=ivApplicationHeadVO.getDef2();//合同号 + } + Object url = ctcode+"_"+Gmfmc+"_"+fphm+"_"+Jshj + ".pdf"; + /** + * 回写逻辑： + * 1.修改发票关联关系单据编码 + * 2.ERP销售发票回传，根据销售发票id，回写发票号和单据编号 + * 3.根据销售发票id 回写下游应收单表头表体发票号 + * 4.查询销售发票下游单据，如果有将下游单据表体字段【来源单据号】更新成新的发票号 + */ + //手动开启事务 + TransactionFactory.getTMProxy().begin(3,0); + //修改发票信息单据号 + String sscivmSql = "UPDATE sscivm_invoice set billno = '" + fphm +"' where pk_invoice = '"+ pk_invoice +"'"; + dao.executeUpdate(sscivmSql); + Logger.error("---sscivmSqlExecute------"+sscivmSql); + //修改发票关联关系单据编码 + String sirSql = "UPDATE sscivm_invoice_relation set billno = '" + fphm +"' where pk_invoice = '"+ pk_invoice +"' and billid = '"+ csaleinvoiceid +"'"; + dao.executeUpdate(sirSql); + Logger.error("---sirSqlExecute------"+sirSql); + //ERP销售发票回传，根据销售发票id，回写发票号和单据编号 + String sSaleSql = "UPDATE so_saleinvoice set vdef20 = 'Y' , vdef13 = '" + fphm + "', vbillcode = '" + fphm +"' where csaleinvoiceid = '" + csaleinvoiceid + "'"; + dao.executeUpdate(sSaleSql); + Logger.error("---sSaleSqlExecute------"+sSaleSql); + //根据销售发票id 回写下游应收单表头发票号 + String recBillSql = "MERGE INTO ar_recbill a USING (select DISTINCT pk_recbill,top_billid,top_billtype from ar_recitem) b ON ( a.pk_recbill = b.pk_recbill AND b.top_billid = '" + csaleinvoiceid + "' AND b.top_billtype = '32' ) \n" + + "WHEN MATCHED THEN\n" + + "UPDATE \n" + + "SET a.invoiceno = '" + fphm + "'"; + dao.executeUpdate(recBillSql); + Logger.error("---recBillSqlExecute------"+recBillSql); + //根据销售发票id 回写下游应收单表体发票号 + String recItemSql = "UPDATE ar_recitem \n" + + "SET invoiceno = '" + fphm + "' \n" + + "WHERE\n" + + "top_billid = '" + csaleinvoiceid + "' \n" + + "AND top_billtype = '32'"; + dao.executeUpdate(recItemSql); + Logger.error("---recItemSqlExecute------"+recItemSql); + //查询销售发票下游单据，如果有将下游单据表体字段【来源单据号】更新成新的发票号 + String saleOutSql = "UPDATE ic_saleout_b \n" + + "SET vsourcebillcode = '"+ fphm +"' \n" + + "WHERE\n" + + "csourcetype = '32' \n" + + "AND csourcebillhid = '" + csaleinvoiceid +"'"; + dao.executeUpdate(saleOutSql); + Logger.error("---saleOutSqlExecute------"+saleOutSql); + //正常结束 + TransactionFactory.getTMProxy().end(null); + } + + + } + } catch(Exception e) { + e.printStackTrace(); + //异常回滚 + TransactionFactory.getTMProxy().end(e); + Logger.error("writeBack Error: ",e); + } + return null; + } + + + + +}