收款单新增/修改校验关联销售订单实际收款金额 + 开票申请保存校验
This commit is contained in:
parent
1f48069759
commit
d1350c0392
|
|
@ -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);
|
||||
}
|
||||
}
|
||||
|
|
@ -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 +"元，无法传输！请检查订单累计收款金额！】");
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
|
|
@ -0,0 +1,931 @@
|
|||
//
|
||||
// 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<IVApplicationAggVO> retVOLits = new HashSet();
|
||||
|
||||
try {
|
||||
IVApplicationInsertBP action = new IVApplicationInsertBP();
|
||||
retvos = action.insert(clientFullVOs);
|
||||
HashSet<String> 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<IVApplicationAggVO> atuoVOs = new HashSet();
|
||||
HashSet<IVApplicationAggVO> 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<IVApplicationAggVO> 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<ntotalorigmny
|
||||
String src_billtype = ivApplicationVO.getParentVO().getSrc_billtype(); //来源单据类型
|
||||
String src_billno = ivApplicationVO.getParentVO().getSrc_billno(); //来源单据号
|
||||
String def23 = ivApplicationVO.getParentVO().getDef23(); //bip开票类型 （3：出口发票）
|
||||
/**
|
||||
* 2025-03-12新增：
|
||||
* 开票申请自定义项 23（bip开票类型） 不等于 3，即def23 ！= 3
|
||||
* 再做金额校验
|
||||
*/
|
||||
if("32".equals(src_billtype) && !StringUtil.isNullStringOrNull(src_billno) && !"3".equals(def23)){
|
||||
BaseDAO dao = new BaseDAO();
|
||||
String sql = "select ntotalorigmny from so_saleinvoice where dr = 0 and vbillcode = '" +src_billno+"'";
|
||||
Object obj = dao.executeQuery(sql, new ColumnProcessor());
|
||||
//销售发票价税合计
|
||||
UFDouble ntotalorigmny = UFDouble.ZERO_DBL;
|
||||
if(obj != null) {
|
||||
ntotalorigmny = new UFDouble(obj.toString());
|
||||
}
|
||||
//开票申请价税合计
|
||||
UFDouble jshj = ivApplicationVO.getParentVO().getJshj();
|
||||
//如果开票申请价税合计 大于 销售发票价税合计则返回报错
|
||||
if(jshj != null && ntotalorigmny != null && jshj.compareTo(ntotalorigmny) > 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<IVApplicationAggVO> transferTool = new BillTransferTool(clientFullVOs);
|
||||
IVApplicationUpdateBP action = new IVApplicationUpdateBP();
|
||||
originBills = (IVApplicationAggVO[])transferTool.getOriginBills();
|
||||
retvos = action.update(clientFullVOs, originBills);
|
||||
Map<String, IVApplicationAggVO> pkAndOldVOMap = new HashMap();
|
||||
|
||||
for(IVApplicationAggVO aggVO : originBills) {
|
||||
pkAndOldVOMap.put(aggVO.getPrimaryKey(), aggVO);
|
||||
}
|
||||
|
||||
HashSet<String> 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<IVApplicationAggVO> atuoVOs = new HashSet();
|
||||
HashSet<IVApplicationAggVO> 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<IVApplicationAggVO> 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<IVApplicationAggVO> 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<String, String> 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<Object, Object> 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<IVApplicationAggVO> 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<IVApplogVO> 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<IVApplogVO> 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<String> 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<String, String> 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<String, MaterialVersionVO> 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<String, UFDate> map = new HashMap();
|
||||
map.put(headvo.getPk_customer(), headvo.getPreparedate());
|
||||
Map<String, String> 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;
|
||||
}
|
||||
}
|
||||
Loading…
Reference in New Issue