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

Compare commits

base: yonyou:0fafc2b8c40b8482c494115bc519ee5bf9af5578
Branches Tags
yonyou:master
...
compare: yonyou:f6270650fc8060fcc470b27419b54b15431d4093
Branches Tags
yonyou:master

6 Commits
0fafc2b8c4 ... f6270650fc

Author SHA1 Message Date
lj f6270650fc 物料参照源码 2025-03-05 15:16:28 +08:00
lj 669eb4618b Merge remote-tracking branch 'origin/master' 2025-03-05 15:15:27 +08:00
lj 4b7ca00e4c Merge remote-tracking branch 'origin/master' 2025-03-05 13:22:39 +08:00
mzr f76fc42505 收款单修改 2025-02-28 14:28:58 +08:00
lj ad8c2fa6d6 销售订单保存时回写售价 + 开票云回写销售发票级下游单据逻辑 + 开票申请保存时校验 2025-02-25 17:23:13 +08:00
lj fed80fd269 销售订单保存时回写售价 + 开票云回写销售发票级下游单据逻辑 2025-02-20 09:13:03 +08:00
6 changed files with 1819 additions and 0 deletions
Show Stats Expand all files Collapse all files

223
so/src/private/nc/bs/so/m30/maintain/InsertSaleOrderBP.java Normal file
View File

@ -0,0 +1,223 @@
/* */ package nc.bs.so.m30.maintain;
/* */
/* */ import nc.bs.scmpub.rule.CrossRuleValidateRule;
import nc.bs.so.m30.maintain.rule.insert.JudgeMaterialPriceInsertRule;
/* */ import nc.bs.so.m30.maintain.rule.insert.RewriteBillInsertRule;
/* */ import nc.bs.so.m30.maintain.rule.insert.RewritePromotePriceInsertRule;
/* */ import nc.bs.so.m30.maintain.rule.insert.WritebackMaterialPriceRule;
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.AddNewBillCodeRule;
/* */ import nc.bs.so.m30.rule.billcode.CheckUniqueBillCodeRule;
/* */ 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.FeatureSelectSaveRule;
/* */ import nc.bs.so.m30.rule.m35.ArsubOffsetBeforeSaveRule;
/* */ import nc.bs.so.m30.rule.m35.LrgCashMarCheckRule;
/* */ import nc.bs.so.m30.rule.maintaincheck.CheckDateRule;
/* */ import nc.bs.so.m30.rule.maintaincheck.CheckLrgTotalMoney;
/* */ import nc.bs.so.m30.rule.maintaincheck.CheckNumPriceMnyRule;
/* */ import nc.bs.so.m30.rule.maintaincheck.CheckSaveBillRule;
/* */ import nc.bs.so.m30.rule.maintaincheck.CheckSettleOrgRepeat;
/* */ import nc.bs.so.m30.rule.maintainprocess.FillupFretexchangeRule;
/* */ import nc.bs.so.m30.rule.maintainprocess.FillupRedundanceDataRule;
/* */ import nc.bs.so.m30.rule.maintainprocess.InsertSoBalanceWhenAddNewRule;
/* */ import nc.bs.so.m30.rule.maintainprocess.SourceToSaleOrderMsgRule;
/* */ import nc.bs.so.m30.rule.maintainprocess.ThisGatheringRule;
/* */ import nc.bs.so.m30.rule.reserve.AutoReserveRule;
/* */ import nc.bs.so.m30.rule.rewrite.price.RewritePriceFormRule;
/* */ import nc.bs.so.pub.rule.FillBillTailInfoRuleForIns;
/* */ import nc.impl.pubapp.bd.userdef.UserDefSaveRule;
/* */ import nc.impl.pubapp.pattern.data.bill.BillInsert;
/* */ import nc.impl.pubapp.pattern.rule.IRule;
/* */ import nc.impl.pubapp.pattern.rule.processer.AroundProcesser;
/* */ import nc.itf.scmpub.reference.uap.group.SysInitGroupQuery;
/* */ import nc.vo.credit.engrossmaintain.pub.action.M30EngrossAction;
/* */ import nc.vo.pubapp.pattern.log.TimeLog;
/* */ import nc.vo.pubapp.util.SetAddAuditInfoRule;
/* */ import nc.vo.scmpub.rule.SaleOrgEnableCheckRule;
/* */ import nc.vo.so.m30.entity.SaleOrderBVO;
/* */ import nc.vo.so.m30.entity.SaleOrderHVO;
/* */ import nc.vo.so.m30.entity.SaleOrderVO;
/* */ import nccloud.bs.so.mobile.saleorder.operation.rule.MobAfterSaveMessageRule;
/* */
/* */
/* */
/* */
/* */
/* */
/* */
/* */
/* */
/* */
/* */
/* */ public class InsertSaleOrderBP {
/* */ public SaleOrderVO[] insert(SaleOrderVO[] bills) {
/* 56 */ AroundProcesser<SaleOrderVO> processer = new AroundProcesser(BP30PlugInPoint.InsertBP);
/* */
/* */
/* */
/* 60 */ TimeLog.logStart();
/* 61 */ this.addBeforeRule(processer);
/* 62 */ processer.before(bills);
/* 63 */ TimeLog.info("调用新增保存前BP插入点");
/* */
/* 65 */ TimeLog.logStart();
/* 66 */ BillInsert<SaleOrderVO> bo = new BillInsert();
/* 67 */ SaleOrderVO[] vos = (SaleOrderVO[])bo.insert(bills);
/* 68 */ TimeLog.info("保存单据到数据库");
/* */
/* */
/* 71 */ TimeLog.logStart();
/* 72 */ this.addAfterRule(processer);
/* 73 */ processer.after(vos);
/* 74 */ TimeLog.info("调用新增保存后BP插入点");
/* */
/* 76 */ return vos;
/* */ }
/* */
/* */ private void addAfterRule(AroundProcesser<SaleOrderVO> processer) {
/* 80 */ IRule<SaleOrderVO> rule = null;
/* */
/* */
/* 83 */ rule = new InsertSoBalanceWhenAddNewRule();
/* 84 */ processer.addAfterRule(rule);
/* */
/* */
/* 87 */ rule = new RenovateARByHidsEndRule(M30EngrossAction.M30Insert);
/* 88 */ processer.addAfterRule(rule);
/* */
/* */
/* 91 */ rule = new ThisGatheringRule();
/* 92 */ processer.addAfterRule(rule);
/* */
/* */
/* 95 */ rule = new CheckUniqueBillCodeRule();
/* 96 */ processer.addAfterRule(rule);
/* */
/* */
/* */
/* */
/* */
/* 102 */ rule = new RewriteBillInsertRule();
/* 103 */ processer.addAfterRule(rule);
/* */
/* */
/* 106 */ rule = new SaveTransferMsgRule();
/* 107 */ processer.addAfterRule(rule);
/* */
/* */
/* 110 */ rule = new RewritePriceFormRule();
/* 111 */ processer.addAfterRule(rule);
/* */
/* */
/* 114 */ rule = new SourceToSaleOrderMsgRule();
/* 115 */ processer.addAfterRule(rule);
rule = new WritebackMaterialPriceRule();
processer.addAfterRule(rule);
/* */
/* 117 */ boolean icEnable = SysInitGroupQuery.isICEnabled();
/* 118 */ if (icEnable) {
/* */
/* 120 */ rule = new SaleOrderVOATPAfterRule();
/* 121 */ processer.addAfterRule(rule);
/* */
/* 123 */ rule = new AutoReserveRule();
/* 124 */ processer.addAfterRule(rule);
/* */
/* */
/* */ }
/* */
/* 129 */ if (SysInitGroupQuery.isPRICEEnabled()) {
/* 130 */ rule = new RewritePromotePriceInsertRule();
/* 131 */ processer.addAfterRule(rule);
/* */
/* */
/* */ }
/* */
/* 136 */ processer.addAfterRule(new MobAfterSaveMessageRule());
/* 137 */ }
/* */
/* */
/* */
/* */ private void addBeforeRule(AroundProcesser<SaleOrderVO> processer) {
/* 142 */ IRule<SaleOrderVO> rule = new SaleOrgEnableCheckRule();
/* 143 */ processer.addBeforeRule(rule);
/* */
/* */
/* 146 */ rule = new FillupRedundanceDataRule();
/* 147 */ processer.addBeforeRule(rule);
/* */
/* */
/* 150 */ rule = new FillupFretexchangeRule();
/* 151 */ processer.addBeforeRule(rule);
/* */
/* */
/* 154 */ rule = new AddNewBillCodeRule();
/* 155 */ processer.addBeforeRule(rule);
/* */
/* */
/* 158 */ rule = new CheckNumPriceMnyRule();
/* 159 */ processer.addBeforeRule(rule);
/* */
/* 161 */ rule = new CheckSettleOrgRepeat();
/* 162 */ processer.addBeforeRule(rule);
/* */
/* 164 */ rule = new CheckDateRule();
/* 165 */ processer.addBeforeRule(rule);
/* */
/* 167 */ rule = new CheckSaveBillRule();
/* 168 */ processer.addBeforeRule(rule);
/* */
/* */
/* 171 */ rule = new FillBillTailInfoRuleForIns();
/* 172 */ processer.addBeforeRule(rule);
/* */
/* */
/* 175 */ rule = new SetAddAuditInfoRule();
/* 176 */ processer.addBeforeRule(rule);
/* */
/* */
/* 179 */ rule = new RenovateARByHidsBeginRule(M30EngrossAction.M30Insert);
/* 180 */ processer.addBeforeRule(rule);
/* */
/* 182 */ boolean icEnable = SysInitGroupQuery.isICEnabled();
/* 183 */ if (icEnable) {
/* */
/* 185 */ rule = new SaleOrderVOATPBeforeRule();
/* 186 */ processer.addBeforeRule(rule);
/* */
/* */ }
/* */
/* 190 */ rule = new LrgCashMarCheckRule();
/* 191 */ processer.addBeforeRule(rule);
/* */
/* */
/* 194 */ rule = new ArsubOffsetBeforeSaveRule();
/* 195 */ processer.addBeforeRule(rule);
/* */
/* */
/* 198 */ rule = new CheckLrgTotalMoney();
/* 199 */ processer.addBeforeRule(rule);
/* */
/* */
/* 202 */ rule = new FeatureSelectSaveRule();
/* 203 */ processer.addBeforeRule(rule);
/* */
/* */
/* 206 */ rule = new UserDefSaveRule(new Class[]{SaleOrderHVO.class, SaleOrderBVO.class});
/* */
/* */
/* 209 */ processer.addBeforeRule(rule);
/* */
/* */
/* 212 */ rule = new CrossRuleValidateRule();
/* 213 */ processer.addBeforeRule(rule);
rule = new JudgeMaterialPriceInsertRule();
processer.addBeforeRule(rule);
/* 214 */ }
/* */ }

229
so/src/private/nc/bs/so/m30/maintain/UpdateSaleOrderBP.java Normal file
View File

@ -0,0 +1,229 @@
/* */ 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.JudgeMaterialPriceInsertRule;
/* */ 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.ClearMffileSRCRule;
/* */ import nc.bs.so.m30.rule.feature.FeatureSelectSaveRule;
/* */ import nc.bs.so.m30.rule.feature.RestMffileSRCRule;
/* */ import nc.bs.so.m30.rule.m35.ArsubOffsetBeforeSaveRule;
/* */ import nc.bs.so.m30.rule.m35.LrgCashMarCheckRule;
/* */ import nc.bs.so.m30.rule.maintaincheck.CheckCanUpdateWhenAuditing;
/* */ import nc.bs.so.m30.rule.maintaincheck.CheckDateRule;
/* */ import nc.bs.so.m30.rule.maintaincheck.CheckLrgTotalMoney;
/* */ import nc.bs.so.m30.rule.maintaincheck.CheckNumPriceMnyRule;
/* */ import nc.bs.so.m30.rule.maintaincheck.CheckSaveBillRule;
/* */ import nc.bs.so.m30.rule.maintaincheck.CheckSettleOrgRepeat;
/* */ import nc.bs.so.m30.rule.maintainprocess.FillupFretexchangeRule;
/* */ import nc.bs.so.m30.rule.maintainprocess.FillupRedundanceDataRule;
/* */ import nc.bs.so.m30.rule.maintainprocess.ThisGatheringRule;
/* */ import nc.bs.so.m30.rule.maintainprocess.UpdateSoBalanceWhenUpdateM30HeadRule;
/* */ import nc.bs.so.m30.rule.maintainprocess.UpdateSoBalanceWhenUpdateRule;
/* */ 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.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.pubapp.pattern.log.TimeLog;
/* */ import nc.vo.pubapp.util.SetUpdateAuditInfoRule;
/* */ import nc.vo.so.m30.entity.SaleOrderVO;
/* */
/* */
/* */
/* */
/* */
/* */
/* */
/* */ public class UpdateSaleOrderBP {
/* */ public SaleOrderVO[] update(SaleOrderVO[] bills, SaleOrderVO[] originBills) {
/* 53 */ CompareAroundProcesser<SaleOrderVO> processer = new CompareAroundProcesser(BP30PlugInPoint.UpdateBP);
/* */
/* */
/* */
/* 57 */ TimeLog.logStart();
/* 58 */ this.addBeforeRule(processer);
/* 59 */ processer.before(bills, originBills);
/* */
/* 61 */ TimeLog.info("???????????BP?????");
/* */
/* 63 */ TimeLog.logStart();
/* 64 */ BillUpdate<SaleOrderVO> bo = new BillUpdate();
/* 65 */ SaleOrderVO[] vos = (SaleOrderVO[])bo.update(bills, originBills);
/* */
/* 67 */ TimeLog.info("????????????????");
/* */
/* */
/* 70 */ TimeLog.logStart();
/* 71 */ this.addAfterRule(processer);
/* 72 */ processer.after(vos, originBills);
/* */
/* 74 */ TimeLog.info("???????????BP?????");
/* */
/* 76 */ return vos;
/* */ }
/* */
/* */ private void addAfterRule(CompareAroundProcesser<SaleOrderVO> processer) {
/* 80 */ IRule<SaleOrderVO> rule = null;
/* */
/* */
/* 83 */ rule = new UpdateSoBalanceWhenUpdateRule();
/* 84 */ processer.addAfterRule(rule);
/* */
/* */
/* 87 */ rule = new RenovateARByHidsEndRule(M30EngrossAction.M30Edit);
/* 88 */ processer.addAfterRule(rule);
/* */
/* */
/* 91 */ rule = new ThisGatheringRule();
/* 92 */ processer.addAfterRule(rule);
/* */
/* */
/* 95 */ rule = new CheckUniqueBillCodeRule();
/* 96 */ processer.addAfterRule(rule);
/* */
/* */
/* 99 */ ICompareRule<SaleOrderVO> compareRule = new RewriteBillUpdateRule();
/* 100 */ processer.addAfterRule(compareRule);
/* */
/* */
/* 103 */ rule = new SaveTransferMsgRule();
/* 104 */ processer.addAfterRule(rule);
/* */
/* */
/* 107 */ rule = new RewritePriceFormRule();
/* 108 */ processer.addAfterRule(rule);
/* */
/* */
/* 111 */ rule = new UpdateSoBalanceWhenUpdateM30HeadRule();
/* 112 */ processer.addAfterRule(rule);
rule = new WritebackMaterialPriceRule();
processer.addAfterRule(rule);
/* */
/* 114 */ boolean icEnable = SysInitGroupQuery.isICEnabled();
/* 115 */ if (icEnable) {
/* */
/* 117 */ rule = new SaleOrderVOATPAfterRule();
/* 118 */ processer.addAfterRule(rule);
/* */
/* 120 */ rule = new ReserveUpdateRule();
/* 121 */ processer.addAfterRule(rule);
/* */
/* 123 */ rule = new AutoReserveRule();
/* 124 */ processer.addAfterRule(rule);
/* */
/* */ }
/* */
/* 128 */ if (SysInitGroupQuery.isPRICEEnabled()) {
/* 129 */ compareRule = new RewritePromotePriceUpdateRule();
/* 130 */ processer.addAfterRule(compareRule);
/* */
/* */ }
/* */
/* 134 */ compareRule = new RestMffileSRCRule();
/* 135 */ processer.addAfterRule(compareRule);
/* 136 */ }
/* */
/* */ private void addBeforeRule(CompareAroundProcesser<SaleOrderVO> processer) {
/* 139 */ IRule<SaleOrderVO> rule = null;
/* */
/* */
/* 142 */ rule = new VOSagaFrozenValidateRule();
/* 143 */ processer.addBeforeRule(rule);
/* */
/* */
/* 146 */ rule = new CheckCanUpdateWhenAuditing();
/* 147 */ processer.addBeforeRule(rule);
/* */
/* */
/* */
/* 151 */ rule = new CheckApproverRule();
/* 152 */ processer.addBeforeRule(rule);
/* */
/* */
/* */
/* */
/* 157 */ rule = new FillupRedundanceDataRule();
/* 158 */ processer.addBeforeRule(rule);
/* */
/* */
/* 161 */ rule = new FillupFretexchangeRule();
/* 162 */ processer.addBeforeRule(rule);
/* */
/* */
/* 165 */ rule = new SetUpdateAuditInfoRule();
/* 166 */ processer.addBeforeRule(rule);
/* */
/* */
/* 169 */ ICompareRule<SaleOrderVO> compareRule = new UpdateBillCodeRule();
/* 170 */ processer.addBeforeRule(compareRule);
/* */
/* */
/* 173 */ rule = new CheckNumPriceMnyRule();
/* 174 */ processer.addBeforeRule(rule);
/* */
/* 176 */ rule = new CheckSettleOrgRepeat();
/* 177 */ processer.addBeforeRule(rule);
/* */
/* 179 */ rule = new CheckDateRule();
/* 180 */ processer.addBeforeRule(rule);
/* */
/* */
/* 183 */ rule = new CheckSaveBillRule();
/* 184 */ processer.addBeforeRule(rule);
/* */
/* */
/* 187 */ rule = new RenovateARByHidsBeginRule(M30EngrossAction.M30Edit);
/* 188 */ processer.addBeforeRule(rule);
/* */
/* 190 */ boolean icEnable = SysInitGroupQuery.isICEnabled();
/* 191 */ if (icEnable) {
/* */
/* 193 */ rule = new SaleOrderVOATPBeforeRule();
/* 194 */ processer.addBeforeRule(rule);
/* */
/* */ }
/* */
/* 198 */ rule = new LrgCashMarCheckRule();
/* 199 */ processer.addBeforeRule(rule);
/* */
/* */
/* 202 */ rule = new ArsubOffsetBeforeSaveRule();
/* 203 */ processer.addBeforeRule(rule);
/* */
/* */
/* 206 */ rule = new CheckLrgTotalMoney();
/* 207 */ processer.addBeforeRule(rule);
/* */
/* */
/* 210 */ rule = new FeatureSelectSaveRule();
/* 211 */ processer.addBeforeRule(rule);
/* */
/* */
/* 214 */ rule = new CrossRuleValidateRule();
/* 215 */ processer.addBeforeRule(rule);
/* */
/* */
/* 218 */ compareRule = new ClearMffileSRCRule();
/* 219 */ processer.addBeforeRule(compareRule);
/* */
rule = new JudgeMaterialPriceInsertRule();
processer.addBeforeRule(rule);
/* 221 */ }
/* */ }

59
so/src/private/nc/bs/so/m30/maintain/rule/insert/WritebackMaterialPriceRule.java Normal file
View File

@ -0,0 +1,59 @@
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;
import java.util.List;
public class WritebackMaterialPriceRule implements IRule<SaleOrderVO>{
@Override
public void process(SaleOrderVO[] vos) {
// TODO Auto-generated method stub
List<SaleOrderBVO> list = new ArrayList<SaleOrderBVO>();
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(); //无税单价
String whereSql = "nvl(bd_material.dr,0) = 0 and bd_material.code = '" + cmaterialvid + "' and bd_material.pk_org = '" + pk_org + "'";
// IMDPersistenceQueryService aggvoQueryService = ServiceLocator.find(IMDPersistenceQueryService.class);
IMDPersistenceQueryService aggvoQueryService = NCLocator.getInstance().lookup(IMDPersistenceQueryService.class);
// 条件查询得到物料MaterialSaleVO
try {
whereSql = "nvl(bd_materialsale.dr,0) = 0 and bd_materialsale.pk_material = '" + cmaterialvid + "' and bd_materialsale.pk_org = '" + pk_org + "'";
@SuppressWarnings("unchecked")
ArrayList<MaterialSaleVO> materialSaleVOs = (ArrayList<MaterialSaleVO>)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();
}
}
}
}
}

796
sscivm/src/private/nccloud/itf/sscivm/ivsale/impl/IVApplicationServiceImpl.java Normal file
View File

@ -0,0 +1,796 @@
package nccloud.itf.sscivm.ivsale.impl;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.HashSet;
import java.util.List;
import java.util.Map;
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.framework.core.service.TimeService;
import nc.bs.logging.Logger;
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.ivaconst.IVAWebConst;
import nc.bs.sscivm.ivsale.util.ActionUtils;
import nc.bs.sscivm.ivsale.util.IVApplicationBillDefValue;
import nc.bs.sscivm.ivsale.util.IVApplicationEventType;
import nc.bs.sscivm.ivsale.util.IVApplicationSlsmUtil;
import nc.bs.sscivm.ivsale.util.IVSaleUtil;
import nc.bs.sscivm.util.IVMSagaValidationUtils;
import nc.impl.pubapp.pattern.data.bill.tool.BillTransferTool;
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.jdbc.framework.processor.MapListProcessor;
import nc.pubitf.bbd.CurrtypeQuery;
import nc.pubitf.para.SysInitQuery;
import nc.pubitf.uapbd.CurrencyRateUtilHelper;
import nc.uap.pf.metadata.PfMetadataTools;
import nc.vo.bd.currtype.CurrtypeVO;
import nc.vo.ic.pub.util.StringUtil;
import nc.vo.ml.NCLangRes4VoTransl;
import nc.vo.pf.change.PfUtilBaseTools;
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.VOStatus;
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.pf.workflow.IPFActionName;
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.trade.pub.IBillStatus;
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;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.google.gson.Gson;
import com.google.gson.internal.LinkedTreeMap;
public class IVApplicationServiceImpl implements IVApplicationService {
@Override
public IVApplicationAggVO save(IVApplicationAggVO ivApplicationVO) throws BusinessException {
IVApplicationAggVO[] ivApplicationVOs = null;
try {
ivApplicationVOs = saveBatch(new IVApplicationAggVO[] { ivApplicationVO });
} catch (Exception e) {
ExceptionUtils.marsh(e);
}
return ivApplicationVOs == null || ivApplicationVOs.length == 0 ? null : ivApplicationVOs[0];
}
@Override
public IVApplicationAggVO[] saveBatch(IVApplicationAggVO[] clientFullVOs) throws BusinessException {
IVApplicationAggVO[] retvos = null;
HashSet<IVApplicationAggVO> retVOLits = new HashSet<IVApplicationAggVO>();
try {
//BillTransferTool<IVApplicationAggVO> transferTool = new BillTransferTool<IVApplicationAggVO>(clientFullVOs);
IVApplicationInsertBP action = new IVApplicationInsertBP();
retvos = action.insert(clientFullVOs);
//retvos = (IVApplicationAggVO[]) transferTool.getBillForToClient(retvos);
//处理自动提交
HashSet<String> tradetypeids = new HashSet<String>();
for (IVApplicationAggVO applicationAggVO : retvos) {
tradetypeids.add(applicationAggVO.getParentVO().getTranstypecode());
}
IVBilltypeVO[] billtypeVOS =
NCLocator
.getInstance()
.lookup(IVABilltypeExtService.class)
.getBilltypeVOsByWhere(
" "
+ IVBilltypeVO.PK_GROUP
+ " ='"
+ InvocationInfoProxy.getInstance().getGroupId()
+ "' and "
+ SQLUtil.buildSqlForIn(IVBilltypeVO.BILLTYPECODE,
tradetypeids.toArray(new String[tradetypeids.size()])));
//提交时处理自动审批功能
if (billtypeVOS != null && billtypeVOS.length > 0) {
// 3、自动提交勾选时
HashSet<IVApplicationAggVO> atuoVOs = new HashSet<IVApplicationAggVO>();
HashSet<IVApplicationAggVO> noatuoVOs = new HashSet<IVApplicationAggVO>();
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())) {
if (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(atuoVOs.toArray(new IVApplicationAggVO[atuoVOs.size()]), null, null);
if (submitObj instanceof Map) {
throw new BusinessException(nc.vo.ml.NCLangRes4VoTransl.getNCLangRes().getStrByID("1058sal_0","01058sal-0053")/*@res "开票申请单保存提交失败，下游环节含有指派信息"*/);
}
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 = retVOLits.toArray(new IVApplicationAggVO[retVOLits
.size()]);
} else {
if (noatuoVOs != null && noatuoVOs.size() > 0) {
retVOLits.addAll(noatuoVOs);
retvos = retVOLits
.toArray(new IVApplicationAggVO[retVOLits
.size()]);
}
}
}
} catch (Exception e) {
ExceptionUtils.marsh(e);
}
return retvos;
}
@Override
public void deleteById(String pk) throws BusinessException {
deleteByIds(new String[] { pk });
}
@Override
public void deleteByIds(String[] pks) throws BusinessException {
IVApplicationAggVO[] retvos = new IVApplicationQueryBP().queryAggIVApplicationVOByCondition(SQLUtil.buildSqlForIn(
IVApplicationHeadVO.PK_IVAPPLICATION, pks));
new IVApplicationDeleteBP().delete(retvos);
}
@Override
public void delete(IVApplicationAggVO vo) throws BusinessException {
try {
new IVApplicationDeleteBP().delete(new IVApplicationAggVO[] { vo });
} catch (Exception e) {
ExceptionUtils.marsh(e);
}
}
@Override
public void deleteBatch(IVApplicationAggVO[] vos) throws BusinessException {
try {
new IVApplicationDeleteBP().delete(vos);
} catch (Exception e) {
ExceptionUtils.marsh(e);
}
}
@Override
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.intValue() == IBillStatus.CHECKPASS) {
throw new BusinessException(nc.vo.ml.NCLangRes4VoTransl
.getNCLangRes()
.getStrByID("1058sal_0", "01058sal-0024")/*
* @res
* "审批通过的单据不允许修改"
*/);
}
// 审批进行中的单据只允许当前审批人修改
if (approveStatus.intValue() == IBillStatus.COMMIT
|| approveStatus.intValue() == IBillStatus.CHECKGOING) {
String billId = ivApplicationVO.getParentVO()
.getPk_ivapplication();
String billType = ivApplicationVO.getParentVO()
.getTranstypecode();
String userId = InvocationInfoProxy.getInstance().getUserId();
if (!isFlowCheckman(billId, billType, userId)) {
throw new BusinessException(nc.vo.ml.NCLangRes4VoTransl
.getNCLangRes().getStrByID("1058sal_0",
"01058sal-0050")/*
* @res
* "审批流程中的单据，只有当前审批人可以修改!"
*/);
}
}
//如果来源单据为销售发票,根据来源单据编号src_billno和来源单据类型（billtype = 32）查询销售发票价税合计（ntotalorigmny）与开票申请中价税合计（jshj）比较，须满足 jshj<ntotalorigmny
String src_billtype = ivApplicationVO.getParentVO().getSrc_billtype(); //来源单据类型
String src_billno = ivApplicationVO.getParentVO().getSrc_billno(); //来源单据号
if("32".equals(src_billtype) && !StringUtil.isNullStringOrNull(src_billno)){
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 = updateBatch(new IVApplicationAggVO[] { ivApplicationVO }, 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) {
ExceptionUtils.marsh(e);
}
return retvos == null || retvos.length == 0 ? null : retvos[0];
}
@Override
public IVApplicationAggVO[] updateBatch(IVApplicationAggVO[] clientFullVOs, IVApplicationAggVO[] originBills) throws BusinessException {
IVApplicationAggVO[] retvos = null;
try {
BillTransferTool<IVApplicationAggVO> transferTool = new BillTransferTool<IVApplicationAggVO>(clientFullVOs);
IVApplicationUpdateBP action = new IVApplicationUpdateBP();
originBills = transferTool.getOriginBills();
retvos = action.update(clientFullVOs, originBills);
//retvos = (IVApplicationAggVO[]) transferTool.getBillForToClient(retvos);
} catch (Exception e) {
ExceptionUtils.marsh(e);
}
return retvos;
}
@Override
public Object submit(IVApplicationAggVO[] clientBills, IVApplicationAggVO[] originBills, Object assingUsers) throws BusinessException {
//判断saga状态
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(), IVApplicationHeadVO.PK_IVAPPLICATION);
}
List<IVApplicationAggVO> retvos = new ArrayList<IVApplicationAggVO>();
try {
for (int i = 0; i < clientBills.length; i++) {
AggregatedValueObject billVO = clientBills[i];
if (clientBills[i].getParentVO().getBillstatus() != IBillStatus.FREE) {
// 存在非自由态的单据
throw new BusinessException(nc.vo.ml.NCLangRes4VoTransl.getNCLangRes().getStrByID("1058sal_0","01058sal-0025")/*@res "第:"*/ + (i + 1) + nc.vo.ml.NCLangRes4VoTransl.getNCLangRes().getStrByID("1058sal_0","01058sal-0026")/*@res "行，非自由态的单据不允许提交!"*/);
}
Object retObj = doNccCommit(billVO, assingUsers);
if(retObj instanceof Map){
return retObj;
}
if (retObj != null) {
retvos.add((IVApplicationAggVO)((MessageVO)retObj).getSuccessVO());
}
}
} catch (Exception 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 =
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) {
if (null == ((IVApplicationHeadVO)billVO.getParentVO()).getTs()
|| ((IVApplicationHeadVO)billVO.getParentVO()).getTs().compareTo(
submitVos[0].getParentVO().getTs()) != 0) {
throw new Exception(nc.vo.ml.NCLangRes4VoTransl.getNCLangRes().getStrByID("1058sal_0", "01058sal-0057")/*@res "单据已经被他人修改,请刷新页面!"*/);
}
}
String tradetypePk = ((IVApplicationHeadVO)billVO.getParentVO()).getPk_tradetype();
djlxbm = NCLocator.getInstance().lookup(IBilltypeService.class).getBilltypeCode(tradetypePk);
}
Object retObj = null;
HashMap<String, String> paramMap = new HashMap<String, String>();
paramMap.put(PfUtilBaseTools.PARAM_SILENTLY, PfUtilBaseTools.PARAM_SILENTLY);
// String actionCode = IVSaleUtil.getActionCode((String)
// billVO.getParentVO().getAttributeValue(IVApplicationHeadVO.PK_ORG));
String cuserid = InvocationInfoProxy.getInstance().getUserId();
UFDateTime currTime = TimeService.getInstance().getUFDateTime();
WorkflownoteVO noteVO = null;
try {
noteVO =
((IWorkflowMachine)NCLocator.getInstance().lookup(IWorkflowMachine.class)).checkWorkFlow(
IPFActionName.SAVE, djlxbm, billVO, null);
} catch (BusinessException e) {
}
boolean hasWorkfFlow = false;
if (noteVO == null) {
try{
IFlowBizItf fbi = PfMetadataTools.getBizItfImpl(billVO, IFlowBizItf.class);
IWorkflowDefine wfDefine = 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 e){
String err = NCLangRes4VoTransl.getNCLangRes().getStrByID("pfworkflow", "UPPpfworkflow-000058");/** 找不到工作流定义 无法启动工作流*/
if (e.getMessage()!=null && e.getMessage().contains(err)) {
//throw new BusinessException(nc.vo.ml.NCLangRes4VoTransl.getNCLangRes().getStrByID("1058sal_0","01058sal-0027")/*@res "找不到流程定义，无法启动流程!"*/);
}else{
throw new PFBusinessException(e);
}
}
if (!hasWorkfFlow) {
((IVApplicationHeadVO)billVO.getParentVO()).setApprover(cuserid);
((IVApplicationHeadVO)billVO.getParentVO()).setApprovedate(currTime);
((IVApplicationHeadVO)billVO.getParentVO()).setBillstatus(IBillStatus.CHECKPASS);
// ((IVApplicationHeadVO)billVO.getParentVO()).setStatus(VOStatus.UPDATED);
// retObj = this.updateBatch(new IVApplicationAggVO[] { (IVApplicationAggVO) billVO }, null)[0];
retObj = approveVOs(new IVApplicationAggVO[] { (IVApplicationAggVO) billVO });
} else {
retObj = commitScriptPFlow(IPFActionName.START, djlxbm, billVO, assingUsers);
}
} else {
// 有审批流走审批流
retObj = commitScriptPFlow(IPFActionName.SAVE, djlxbm, billVO, assingUsers);
}
if (retObj == null) {
result = new MessageVO(billVO, ActionUtils.COMMIT);
result.setSuccess(false);
result
.setErrorMessage(nc.vo.ml.NCLangRes4VoTransl.getNCLangRes().getStrByID("2011", "UPP2011-000339")/*
* @
* res
* "用户取消操作"*/);
} else {
if(retObj instanceof Map){
return retObj;
}
if (retObj instanceof AggregatedValueObject) {// 仅提交
result = new MessageVO((AggregatedValueObject)retObj, ActionUtils.COMMIT);
} 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(null, ActionUtils.COMMIT);
}
}
}
} catch (Exception e) {
ExceptionUtils.marsh(e);
}
return result;
}
private Object commitScriptPFlow(String actionName, String djlxbm, AggregatedValueObject aggVo, Object assingUsers) throws BusinessException {
JSONObject assignContent = new JSONObject();
HashMap<Object, Object> eParam = new HashMap<Object, Object>();
if ((assingUsers instanceof LinkedTreeMap)) {
assignContent = JSON.parseObject(new Gson().toJson(assingUsers));
eParam.put("content", assignContent);
}
// 调用平台接口
eParam.put(PfUtilBaseTools.PARAM_SILENTLY, PfUtilBaseTools.PARAM_SILENTLY);
// eParam.put("isSkipAssign", true);
CloudPFlowContext context = new CloudPFlowContext();
context.setActionName(actionName);
context.setBillType(djlxbm);
context.setBillVos(new AggregatedValueObject[] { aggVo });
context.seteParam(eParam);
Object[] ss = null;
if(IPFActionName.START.equals(actionName)){
WorkflowTypeEnum flowtype = nc.bs.pub.pf.PfUtilTools.runningFlowStatus(nccloud.commons.lang.StringUtils.isNotEmpty(context.getTrantype()) ? context.getTrantype() : context.getBillType(), aggVo.getParentVO().getPrimaryKey());
if(flowtype==null){
ss =NCLocator.getInstance().lookup(ICloudScriptPFlowService.class).exeScriptPFlow_CommitNoFlowBatch(context);
}
}
if(ss==null){
ss =NCLocator.getInstance().lookup(ICloudScriptPFlowService.class).exeScriptPFlow(context);
}
Object obj = ss[0];
if (((obj instanceof Map))
&& (((Map<?, ?>)obj).get("workflow") != null)
&& (("approveflow".equals(String.valueOf(((Map<?, ?>)obj).get("workflow")))) || ("workflow".equals(String
.valueOf(((Map<?, ?>)obj).get("workflow")))))) {
@SuppressWarnings("unchecked")
Map<String, Object> map = (Map<String, Object>)obj;
if (map.get("workflow") != null) {
return map;
}
}
return obj;
}
@Override
public IVApplicationAggVO[] recall(IVApplicationAggVO[] clientBills, IVApplicationAggVO[] originBills) throws BusinessException {
//判断saga状态
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(), IVApplicationHeadVO.PK_IVAPPLICATION);
}
List<IVApplicationAggVO> retvos = new ArrayList<IVApplicationAggVO>();
try {
for (int i = 0; i < clientBills.length; i++) {
AggregatedValueObject billVO = clientBills[i];
if(clientBills[i].getParentVO().getBillstatus()!=IBillStatus.COMMIT && clientBills[i].getParentVO().getBillstatus()!=IBillStatus.CHECKPASS){
//存在非自由态的单据
throw new BusinessException(nc.vo.ml.NCLangRes4VoTransl.getNCLangRes().getStrByID("1058sal_0","01058sal-0025")/*@res "第:"*/+(i+1)+nc.vo.ml.NCLangRes4VoTransl.getNCLangRes().getStrByID("1058sal_0","01058sal-0028")/*@res "行，非提交态的单据不允许收回!"*/);
}
List<IVApplogVO> applogVOList =
NCLocator.getInstance().lookup(ApplicationLogService.class)
.queryApplicationLogByLyid(new String[] {clientBills[i].getParentVO().getPk_ivapplication()});
if(applogVOList != null && applogVOList.size() > 0){
throw new nc.vo.pub.BusinessException(nc.vo.ml.NCLangRes4VoTransl.getNCLangRes().getStrByID("1058sal_0","01058sal-0029")/*@res "单据"*/ + clientBills[i].getParentVO().getBillno()
+ nc.vo.ml.NCLangRes4VoTransl.getNCLangRes().getStrByID("1058sal_0","01058sal-0030")/*@res "已经开票，不允许取消审批!"*/);
}
Object retObj = doNccRecall(billVO);
retvos.add( (IVApplicationAggVO) ((MessageVO) retObj).getSuccessVO());
}
} catch (Exception e) {
ExceptionUtils.marsh(e);
}
return retvos.toArray(new IVApplicationAggVO[retvos.size()]);
}
private Object doNccRecall(AggregatedValueObject billVO) throws Exception {
MessageVO result = null;
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) {
if (null == ((IVApplicationHeadVO) billVO.getParentVO()).getTs()
|| ((IVApplicationHeadVO) billVO.getParentVO()).getTs().compareTo(submitVos[0].getParentVO().getTs()) != 0) {
throw new Exception(nc.vo.ml.NCLangRes4VoTransl.getNCLangRes().getStrByID("1058sal_0", "01058sal-0057")/*@res "单据已经被他人修改,请刷新页面!"*/);
}
}
String tradetypePk = ((IVApplicationHeadVO) billVO.getParentVO()).getPk_tradetype();
djlxbm = NCLocator.getInstance().lookup(IBilltypeService.class).getBilltypeCode(tradetypePk);
}
String actionName = IPFActionName.RECALL;
boolean isApproveflowFlag = IVSaleUtil.isApproveFlowStartup(billVO.getParentVO().getPrimaryKey(), djlxbm);
if (isApproveflowFlag) {
actionName = IPFActionName.UNSAVE;
}
// 收回流程信息
Object[] exeScriptPFlow = null;
CloudPFlowContext context = new CloudPFlowContext();
context.setActionName(actionName);
context.setBillType(djlxbm);// 开票申请单
context.setBillVos(new AggregatedValueObject[] { billVO });
context.seteParam(new HashMap<Object, Object>());
WorkflowTypeEnum flowtype = nc.bs.pub.pf.PfUtilTools.runningFlowStatus(nccloud.commons.lang.StringUtils.isNotEmpty(context.getTrantype()) ? context.getTrantype() : context.getBillType(), billVO.getParentVO().getPrimaryKey());
ICloudScriptPFlowService service = 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], ActionUtils.RECALL);
} else {
result = new MessageVO(null, ActionUtils.RECALL);
}
} else if (exeScriptPFlow[0] instanceof AggregatedValueObject) {
result = new MessageVO((AggregatedValueObject) (exeScriptPFlow[0]), ActionUtils.RECALL);
}
} catch (Exception e) {
Logger.error(e.getMessage(), e);
throw e;
}
return result;
}
/**
* 开票申请-初始化默认数据
* @param ivapplicationaggvo
* @return
* @throws BusinessException
*/
public IVApplicationAggVO dealDefValue(String uistate, String pk_group, String pk_user, String pk_tradetype) throws Exception {
IVApplicationAggVO retvos = new IVApplicationAggVO();
IVApplicationBillDefValue billDefValue = new IVApplicationBillDefValue();
// 自定义默认值
if (IVAWebConst.INIT_LOADDEF.equals(uistate) || IVAWebConst.UISTATUS_ADD.equals(uistate)) {
retvos = billDefValue.getNewVO(pk_group, pk_user, pk_tradetype);
} else if (IVAWebConst.CHANGE_LOADDEF.equals(uistate) || IVAWebConst.UISTATUS_EDIT.equals(uistate)) {
//retvos = billDefValue.getDefaultVO(pk_org);
}
return retvos;
}
/**
* 开票申请-查询组织本币对应币种
* @param String
* @return
* @throws BusinessException
*/
public String getOrgLocalCurrPK(String pk_org) throws BusinessException {
String orgLocalCurrPK = CurrencyRateUtilHelper.getInstance().getLocalCurrtypeByOrgID(pk_org);
return orgLocalCurrPK;
}
/**
* 开票申请-币种对应精度
* @param String
* @return
* @throws BusinessException
*/
public Integer getCurrDigit(String pk_currtype) throws BusinessException {
if (StringUtils.isEmpty(pk_currtype)) {
return 0;
}
CurrtypeVO currtypeVO = null;
if (RuntimeEnv.getInstance().isRunningInServer()) {
currtypeVO = CurrtypeQuery.getInstance().getCurrtypeVO(pk_currtype);
}
return currtypeVO == null ? 0 : currtypeVO.getCurrdigit();
}
/**
* 开票申请-获取组织对应版本
* @param String
* @return
* @throws BusinessException
*/
public String getOrgVersion(String voclassname, String name, String pk_org) throws Exception {
String className = new IVApplicationBillDefValue().getClassname(voclassname);
String pk_org_v = (String) new IVApplicationBillDefValue().getRelationItemValue(className, name, "pk_org", pk_org);
return pk_org_v;
}
@Override
public MessageVO[] approveVOs(IVApplicationAggVO[] applicationAggVOs) throws Exception {
if (applicationAggVOs == null || applicationAggVOs.length == 0) {
return null;
}
// 1、更新单据
for (int i = 0; i < applicationAggVOs.length; i++) {
applicationAggVOs[i].getParentVO().setStatus(VOStatus.UPDATED);
}
IVApplicationAggVO[] aggVOs = updateBatch(applicationAggVOs, null);
MessageVO[] msgs = new MessageVO[aggVOs.length];
for (int i = 0; i < aggVOs.length; i++) {
msgs[i] = new MessageVO(aggVOs[i], ActionUtils.AUDIT);
}
// 2、审批通过时自动开票
IVApplicationInvoiceService applicationInvoiceService = NCLocator.getInstance().lookup(IVApplicationInvoiceService.class);
for (int i = 0; i < aggVOs.length; i++) {
String billTypePk = aggVOs[i].getParentVO().getPk_tradetype();
String billtypeCode = NCLocator.getInstance().lookup(IBilltypeService.class).getBilltypeCode(billTypePk);
IVBilltypeVO billtypeVO = NCLocator.getInstance().lookup(IVABilltypeExtService.class).getBilltypeVOByCode(billtypeCode,
InvocationInfoProxy.getInstance().getGroupId());
if(null != billtypeVO){
if(billtypeVO.getIsatuo_invoice() == UFBoolean.TRUE && IVApplicationSlsmUtil.slsmCheck(aggVOs[i])){//@全电发票@@特殊票种电子凭证@
JSONObject jsonObj = new JSONObject();
IVApplicationAggVO[] voAfterMakeInvoice = applicationInvoiceService.makeInvoice(new IVApplicationAggVO[] {aggVOs[i]}, jsonObj, null, false);
msgs[i] = new MessageVO(voAfterMakeInvoice[0], ActionUtils.AUDIT);
}
}
}
return msgs;
}
@Override
public Object unApproveVOs(IVApplicationAggVO[] applicationAggVOs) throws BusinessException {
if (applicationAggVOs == null || applicationAggVOs.length == 0) {
return null;
}
// 1、判断开票申请单是否已经开票，如果已经开票，则不允许取消审批
for (int i = 0; i < applicationAggVOs.length; i++) {
List<IVApplogVO> applogVOList =
NCLocator.getInstance().lookup(ApplicationLogService.class)
.queryApplicationLogByLyid(new String[] {applicationAggVOs[i].getParentVO().getPk_ivapplication()});
if(applogVOList != null && applogVOList.size() > 0){
throw new nc.vo.pub.BusinessException(nc.vo.ml.NCLangRes4VoTransl.getNCLangRes().getStrByID("1058sal_0","01058sal-0029")/*@res "单据"*/ + applicationAggVOs[i].getParentVO().getBillno()
+ nc.vo.ml.NCLangRes4VoTransl.getNCLangRes().getStrByID("1058sal_0","01058sal-0030")/*@res "已经开票，不允许取消审批!"*/);
}
applicationAggVOs[i].getParentVO().setStatus(VOStatus.UPDATED);
}
// 2、更新单据状态
IVApplicationAggVO[] aggVOs = updateBatch(applicationAggVOs, null);
MessageVO[] msgs = new MessageVO[aggVOs.length];
for (int i = 0; i < aggVOs.length; i++) {
msgs[i] = new MessageVO(aggVOs[i], ActionUtils.UNAUDIT);
}
return msgs;
}
@Override
public IVApplicationAggVO copyApplication(String pk) throws Exception {
// 1、校验单据是否存在
IVApplicationAggVO aggVO = NCLocator.getInstance().lookup(IVApplicationQueryService.class).queryByPK(pk);
if (aggVO == null) {
throw new nc.vo.pub.BusinessException(nc.vo.ml.NCLangRes4VoTransl.getNCLangRes().getStrByID("1058sal_0", "01058sal-0057")/*@res "单据已经被他人修改,请刷新页面!"*/);
}
if(aggVO.getParentVO().getHzfp() == UFBoolean.TRUE || aggVO.getParentVO().getZffp() == UFBoolean.TRUE){
throw new nc.vo.pub.BusinessException(nc.vo.ml.NCLangRes4VoTransl.getNCLangRes().getStrByID("1058sal_0","01058sal-0031")/*@res "单据关联的发票是红字发票或作废发票，不允许复制单据!"*/);
}
if(aggVO.getParentVO().getSrc_pkbusibill() != null){
throw new nc.vo.pub.BusinessException(nc.vo.ml.NCLangRes4VoTransl.getNCLangRes().getStrByID("1058sal_0","01058sal-0032")/*@res "单据已关联上游单据，不允许复制单据!"*/);
}
// 2、复制单据
IVApplicationAggVO copyVo = aggVO.clone();
IVApplicationHeadVO headvo = copyVo.getParentVO();
// 3、清除表头不该复制的字段
//清除saga相关的三个字段，否则复制时出现主键被加锁的情况
String[] headFieldNotCopy =
{IVApplicationHeadVO.PK_IVAPPLICATION, IVApplicationHeadVO.APPROVEDATE, IVApplicationHeadVO.APPROVER,
IVApplicationHeadVO.BILLNO, IVApplicationHeadVO.BILLSTATUS, IVApplicationHeadVO.CREATIONTIME,
IVApplicationHeadVO.CREATOR, IVApplicationHeadVO.KPR, IVApplicationHeadVO.KPZT,
IVApplicationHeadVO.LYID, IVApplicationHeadVO.MODIFIEDTIME, IVApplicationHeadVO.MODIFIER,
IVApplicationHeadVO.PREPAREDATE, IVApplicationHeadVO.SRC_BILLNO, IVApplicationHeadVO.SRC_BILLTYPE,
IVApplicationHeadVO.SRC_PKBUSIBILL, IVApplicationHeadVO.SRC_TRADETYPE,IVApplicationHeadVO.SAGA_FROZEN,
IVApplicationHeadVO.SAGA_GTXID,IVApplicationHeadVO.SAGA_BTXID,IVApplicationHeadVO.SAGA_STATUS};
for (int i = 0; i < headFieldNotCopy.length; i++) {
headvo.setAttributeValue(headFieldNotCopy[i], null);
}
// 4、清除表体字段
for (int i = 0; i < copyVo.getChildrenVO().length; i++) {
IVApplicationBodyVO bodyVO = (IVApplicationBodyVO) copyVo.getChildrenVO()[i];
bodyVO.setPk_ivappdetail(null);
bodyVO.setPk_ivapplication(null);
}
//@特殊票种电子凭证@begin
// 5、清除特殊票种相关字段
if (copyVo.getIvTspzsBodyVO() != null) {
for (int i = 0; i < copyVo.getIvTspzsBodyVO().length; i++) {
IVTspzsBodyVO ivTspzsBodyVO = copyVo.getIvTspzsBodyVO()[i];
ivTspzsBodyVO.setPk_ivtspzsdetail(null);
ivTspzsBodyVO.setPk_ivapplication(null);
ivTspzsBodyVO.setPk_ivappdetail(null);
}
}
//@特殊票种电子凭证@end
// 5、重新制单人、修改人、时间等信息
String cuserid = InvocationInfoProxy.getInstance().getUserId();
UFDateTime currTime = TimeService.getInstance().getUFDateTime();
UFDate currDate = currTime.getDate();
headvo.setBillstatus(IBillStatus.FREE);
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("");
//表头设置开票方式默认值，默认为1 直联开票
Integer paramValue = SysInitQuery.getParaInt(headvo.getPk_org(), IVAWebConst.IVA_KP_SSCIVA01);
headvo.setKpfs(paramValue == null ? IVAplocationKPFS.ZLKP.toIntValue() : paramValue);
for (int i = 0; i < copyVo.getChildrenVO().length; i++) {
IVApplicationBodyVO bodyvo = (IVApplicationBodyVO) copyVo.getChildrenVO()[i];
bodyvo.setStatus(VOStatus.NEW);
}
return copyVo;
}
@Override
public boolean isFlowCheckman(String billId, String billType, String userId)
throws BusinessException {
return IVSaleUtil.isCheckman(billId, billType, userId);
}
}

255
uapbd/src/private/nc/bs/uapbd/task/InvoiceTaskPlugin.java Normal file
View File

@ -0,0 +1,255 @@
package nc.bs.uapbd.task;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.net.URL;
import java.net.URLEncoder;
import java.nio.charset.StandardCharsets;
import java.util.ArrayList;
import java.util.Base64;
import java.util.HashMap;
import java.util.Map;
import java.util.TreeMap;
import javax.crypto.Mac;
import javax.crypto.spec.SecretKeySpec;
import javax.net.ssl.HttpsURLConnection;
import javax.net.ssl.SSLContext;
import javax.net.ssl.TrustManager;
import org.apache.http.client.config.CookieSpecs;
import org.apache.http.client.config.RequestConfig;
import org.apache.http.client.methods.HttpGet;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.entity.StringEntity;
import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.impl.client.HttpClients;
import org.apache.http.impl.conn.PoolingHttpClientConnectionManager;
import org.apache.http.util.EntityUtils;
import com.alibaba.fastjson.JSONObject;
import com.google.gson.Gson;
import com.yonyou.cloud.utils.StringUtils;
import nc.bs.dao.BaseDAO;
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.bs.uapbd.util.IgnoreSslUtil;
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.iweb.log.Logger;
import uap.mw.trans.TransactionFactory;
import javax.net.ssl.HttpsURLConnection;
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<HashMap<String, Object>> al = (ArrayList<HashMap<String, Object>>)dao.executeQuery(sql, new MapListProcessor());
Logger.error("---alData------"+al);
if(al.size() > 0) {
for(HashMap<String, Object> 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 sirSql = "UPDATE sscivm_invoice_relation set billno = '" + billno +"' 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 = '" + billno +"' 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 = '"+ billno +"' \n" +
"WHERE\n" +
"csourcetype = '32' \n" +
"AND csourcebillhid = '" + csaleinvoiceid +"'";
dao.executeUpdate(saleOutSql);
Logger.error("---saleOutSqlExecute------"+saleOutSql);
//正常结束
TransactionFactory.getTMProxy().end(null);
// String updateRecbillAndItemSql = "BEGIN\n" +
// "UPDATE sscivm_invoice_relation set billno = '" + billno +"' where pk_invoice = '"+ pk_invoice +"' and billid = '"+ csaleinvoiceid +"';\n" +
// "UPDATE so_saleinvoice set vdef20 = 'Y' , vdef13 = '" + fphm + "', vbillcode = '" + billno +"' where csaleinvoiceid = '" + csaleinvoiceid + "';\n" +
// "MERGE INTO ar_recbill a USING 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 + "';\n" +
// "UPDATE ar_recitem \n" +
// "SET invoiceno = '" + fphm + "' \n" +
// "WHERE\n" +
// "top_billid = '" + csaleinvoiceid + "' \n" +
// "AND top_billtype = '32';\n" +
// "UPDATE ic_saleout_b \n" +
// "SET vsourcebillcode = '"+ billno +"' \n" +
// "WHERE\n" +
// "csourcetype = '32' \n" +
// "AND csourcebillhid = '" + csaleinvoiceid +"';\n" +
// "COMMIT;\n" +
// "EXCEPTION \n" +
// "WHEN OTHERS THEN\n" +
// "ROLLBACK;\n" +
// "RAISE;\n" +
// "END;";
// dao.executeUpdate(updateRecbillAndItemSql);
}
}
} catch(Exception e) {
e.printStackTrace();
//异常回滚
TransactionFactory.getTMProxy().end(e);
Logger.error("writeBack Error: ",e);
}
return null;
}
private String doPost(String requestUrl, JSONObject json) throws IOException {
URL u = new URL(requestUrl);
try {
if("https".equalsIgnoreCase(u.getProtocol())){//判定网址是否信任，不信任则调用忽略信任工具类SslUtil
IgnoreSslUtil.ignoreSsl();
}
HttpsURLConnection connection = (HttpsURLConnection)u.openConnection();
// 设置请求方法
connection.setRequestMethod("POST");
// 设置请求属性
connection.setRequestProperty("Content-Type", "application/json; charset=UTF-8");
// 发送POST请求必须设置如下两行
connection.setDoOutput(true);
connection.setDoInput(true);
byte[] outputInBytes = json.toJSONString().getBytes(StandardCharsets.UTF_8);
// 写入数据到请求体
OutputStream os = connection.getOutputStream();
os.write(outputInBytes);
// 获取响应码
int responseCode = connection.getResponseCode();
System.out.println("Response Code: " + responseCode);
// 读取响应
try(BufferedReader br = new BufferedReader(new InputStreamReader(connection.getInputStream()))) {
String response = br.readLine();
System.out.println("Response: " + response);
}
// 关闭连接
connection.disconnect();
} catch(Exception e) {
e.printStackTrace();
}
return null;
}
private String doGet(String requestUrl, Map<String, String> paramMap) throws IOException {
StringBuilder param = new StringBuilder("?");
if (paramMap != null) {
for (Map.Entry<String, String> entry : paramMap.entrySet()) {
param.append(entry.getKey());
param.append("=");
param.append(entry.getValue());
param.append("&");
}
param.deleteCharAt(param.length() - 1);
}
String url = requestUrl + param;
URL u = new URL(url);
try {
if("https".equalsIgnoreCase(u.getProtocol())){//判定网址是否信任，不信任则调用忽略信任工具类SslUtil
IgnoreSslUtil.ignoreSsl();
}
HttpsURLConnection connection = (HttpsURLConnection)u.openConnection();
connection.setRequestMethod("GET");
connection.setConnectTimeout(5000);
connection.setReadTimeout(5000);
connection.connect();
StringBuilder response =new StringBuilder();
int responsecode = connection.getResponseCode();
if(responsecode == HttpsURLConnection.HTTP_OK) {
InputStream inputstream =connection.getInputStream();
BufferedReader reader = new BufferedReader(new InputStreamReader(inputstream));
String line;
while((line =reader.readLine()) != null) {
response.append(line);
}
reader.close();
}
connection.disconnect();
return response.toString();
} catch(Exception e) {
e.printStackTrace();
}
return null;
}
}

257
uapbd/src/public/nc/ui/bd/ref/model/MaterialDefaultRefModel.java Normal file
View File

@ -0,0 +1,257 @@
//
// Source code recreated from a .class file by IntelliJ IDEA
// (powered by FernFlower decompiler)
//
package nc.ui.bd.ref.model;
import java.util.HashMap;
import java.util.LinkedHashMap;
import java.util.Map;
import java.util.Vector;
import nc.bs.framework.common.NCLocator;
import nc.bs.logging.Logger;
import nc.bs.sec.esapi.NCESAPI;
import nc.itf.bd.material.assign.IMaterialAssignService;
import nc.itf.uap.bd.ref.IAssignDataShowRefModel;
import nc.ui.bd.ref.AbstractRefGridTreeBigDataModel;
import nc.ui.bd.ref.IRefDocEdit;
import nc.ui.bd.ref.IRefMaintenanceHandler;
import nc.ui.bd.ref.RefSearchFieldSetting;
import nc.ui.pub.beans.ValueChangedEvent;
import nc.vo.bd.material.MaterialVersionVO;
import nc.vo.bd.material.marbasclass.MarBasClassSysParaUtil;
import nc.vo.bd.material.marbasclass.MarBasClassVO;
import nc.vo.bd.material.measdoc.MeasdocVO;
import nc.vo.ml.NCLangRes4VoTransl;
import nc.vo.org.OrgVO;
import nc.vo.pfxx.util.ArrayUtils;
import nc.vo.pub.BusinessException;
import nc.vo.util.BDVisibleUtil;
import nc.vo.util.SqlWhereUtil;
import nc.vo.util.VisibleUtil;
public class MaterialDefaultRefModel extends AbstractRefGridTreeBigDataModel implements IAssignDataShowRefModel {
private boolean isShowAssginDataChk = false;
private boolean isShowDisableData = false;
private boolean isAssginShowData = false;
private IMaterialAssignService assignService = null;
private Map<String, String> assginSqlMap = new HashMap();
private UserDefRefShow userDefRefShow = UserDefRefShowUtil.getInstance().getUserDefRefShow("c7dc0ccd-8872-4eee-8882-160e8f49dfad");
public MaterialDefaultRefModel() {
this.reset();
}
public void filterValueChanged(ValueChangedEvent changedValue) {
super.filterValueChanged(changedValue);
String[] pk_orgs = (String[])changedValue.getNewValue();
if (ArrayUtils.isNotEmpty(pk_orgs)) {
this.setPk_org(pk_orgs[0]);
}
}
public String getClassWherePart() {
SqlWhereUtil sw = new SqlWhereUtil(super.getClassWherePart());
try {
sw.and(VisibleUtil.getRefVisibleCondition(this.getPk_group(), this.getPk_org(), "c099f7d7-52a9-4b98-bee7-2e3a6c3ea263"));
if (this.isDisabledDataShow()) {
sw.and("enablestate in (2,3) ");
} else {
sw.and("enablestate = 2");
}
return sw.getSQLWhere();
} catch (BusinessException e) {
Logger.error(e.getMessage());
return " 1=2 ";
}
}
public String getCodingRule() {
String codeRule = null;
try {
codeRule = MarBasClassSysParaUtil.getCodeRuleSysPara(this.getPk_group(), this.getPk_org());
} catch (BusinessException e) {
Logger.error(e.getMessage(), e);
}
return codeRule;
}
public void reset() {
this.setRefNodeName("物料");
this.setRootName(NCLangRes4VoTransl.getNCLangRes().getStrByID("10140mclg", "110140mclg0002"));
this.setClassFieldCode(new String[]{"code", "name", "pk_marbasclass", "pk_org"});
this.setClassJoinField("pk_marbasclass");
this.setClassTableName(MarBasClassVO.getDefaultTableName());
this.setClassDefaultFieldCount(2);
this.setClassDataPower(true);
this.setClassWherePart("1 = 1");
this.setFieldCode(new String[]{"pk_org", "code", "name", "materialspec", "materialtype", "materialshortname", "materialmnecode", "graphid", "pk_measdoc"});
String[] fieldNames = new String[]{NCLangRes4VoTransl.getNCLangRes().getStrByID("common", "2UC000-000360"), NCLangRes4VoTransl.getNCLangRes().getStrByID("common", "UC000-0002911"), NCLangRes4VoTransl.getNCLangRes().getStrByID("common", "UC000-0002908"), NCLangRes4VoTransl.getNCLangRes().getStrByID("common", "UC000-0003448"), NCLangRes4VoTransl.getNCLangRes().getStrByID("common", "UC000-0001240"), NCLangRes4VoTransl.getNCLangRes().getStrByID("10140mag", "2materia-000017"), NCLangRes4VoTransl.getNCLangRes().getStrByID("common", "UC000-0000703"), NCLangRes4VoTransl.getNCLangRes().getStrByID("common", "UC000-0001223"), NCLangRes4VoTransl.getNCLangRes().getStrByID("common", "2UC000-000031")};
this.setFieldName(fieldNames);
String orgFomula = "getMLCValue(\"" + OrgVO.getDefaultTableName() + "\",\"" + "name" + "\",\"" + "pk_org" + "\"," + "pk_org" + ")";
String mesFomula = "getMLCValue(\"" + MeasdocVO.getDefaultTableName() + "\",\"" + "name" + "\",\"" + "pk_measdoc" + "\"," + "pk_measdoc" + ")";
this.setFormulas(new String[][]{{"pk_org", orgFomula}, {"pk_measdoc", mesFomula}});
this.setDefaultFieldCount(7);
this.setHiddenFieldCode(new String[]{"pk_material", "pk_source", "pk_marbasclass"});
this.setTableName(MaterialVersionVO.getDefaultTableName());
this.setPkFieldCode("pk_source");
this.setDocJoinField("pk_marbasclass");
this.setRefCodeField("code");
this.setRefNameField("name");
this.setMnecode(new String[]{"materialmnecode"});
this.setAddEnableStateWherePart(true);
this.setOrderPart("code");
this.setResourceID("material_v");
this.setClassResouceID("materialbasclass");
this.setRefMaintenanceHandler(new IRefMaintenanceHandler() {
public String[] getFucCodes() {
return new String[]{"10140MAG", "10140MAO"};
}
public IRefDocEdit getRefDocEdit() {
return null;
}
});
this.setCommonDataTableName(MaterialVersionVO.getDefaultTableName());
this.setFilterRefNodeName(new String[]{"业务单元"});
this.userDefRefShow.addUserDefItemFields(this);
this.resetFieldName();
this.assginSqlMap.clear();
Map<String, String> allFields = new LinkedHashMap();
allFields.put("pk_org", fieldNames[0]);
allFields.put("code", fieldNames[1]);
allFields.put("name", fieldNames[2]);
allFields.put("materialspec", fieldNames[3]);
allFields.put("materialtype", fieldNames[4]);
allFields.put("materialshortname", fieldNames[5]);
allFields.put("materialmnecode", fieldNames[6]);
allFields.put("graphid", fieldNames[7]);
String[] defaultSearchFields = new String[]{"code", "name"};
RefSearchFieldSetting setting = new RefSearchFieldSetting(this.getRefNodeName(), allFields, defaultSearchFields);
this.setSearchFieldSetting(setting);
}
// public void reset() {
// this.setRefNodeName("物料");
// this.setRootName(NCLangRes4VoTransl.getNCLangRes().getStrByID("10140mclg", "110140mclg0002"));
// this.setClassFieldCode(new String[]{"code", "name", "pk_marbasclass", "pk_org"});
// this.setClassJoinField("pk_marbasclass");
// this.setClassTableName(MarBasClassVO.getDefaultTableName());
// this.setClassDefaultFieldCount(2);
// this.setClassDataPower(true);
// this.setClassWherePart("1 = 1");
// this.setFieldCode(new String[]{"pk_org", "code", "name", "materialspec", "materialtype", "materialshortname", "materialmnecode", "graphid", "pk_measdoc"
//// , "memo"
// });
// String[] fieldNames = new String[]{NCLangRes4VoTransl.getNCLangRes().getStrByID("common", "2UC000-000360"),
// NCLangRes4VoTransl.getNCLangRes().getStrByID("common", "UC000-0002911"),
// NCLangRes4VoTransl.getNCLangRes().getStrByID("common", "UC000-0002908"),
// NCLangRes4VoTransl.getNCLangRes().getStrByID("common", "UC000-0003448"),
// NCLangRes4VoTransl.getNCLangRes().getStrByID("common", "UC000-0001240"),
// NCLangRes4VoTransl.getNCLangRes().getStrByID("10140mag", "2materia-000017"),
// NCLangRes4VoTransl.getNCLangRes().getStrByID("common", "UC000-0000703"),
// NCLangRes4VoTransl.getNCLangRes().getStrByID("common", "UC000-0001223"),
// NCLangRes4VoTransl.getNCLangRes().getStrByID("common", "2UC000-000031")
//// ,NCLangRes4VoTransl.getNCLangRes().getStrByID("common", "2UC000-000258")
// };
// this.setFieldName(fieldNames);
// String orgFomula = "getMLCValue(\"" + OrgVO.getDefaultTableName() + "\",\"" + "name" + "\",\"" + "pk_org" + "\"," + "pk_org" + ")";
// String mesFomula = "getMLCValue(\"" + MeasdocVO.getDefaultTableName() + "\",\"" + "name" + "\",\"" + "pk_measdoc" + "\"," + "pk_measdoc" + ")";
// this.setFormulas(new String[][]{{"pk_org", orgFomula}, {"pk_measdoc", mesFomula}});
// this.setDefaultFieldCount(7);
// this.setHiddenFieldCode(new String[]{"pk_material", "pk_source", "pk_marbasclass"});
// this.setTableName(MaterialVersionVO.getDefaultTableName());
// this.setPkFieldCode("pk_source");
// this.setDocJoinField("pk_marbasclass");
// this.setRefCodeField("code");
// this.setRefNameField("name");
// this.setMnecode(new String[]{"materialmnecode"});
// this.setAddEnableStateWherePart(true);
// this.setOrderPart("code");
// this.setResourceID("material_v");
// this.setClassResouceID("materialbasclass");
// this.setRefMaintenanceHandler(new IRefMaintenanceHandler() {
// public String[] getFucCodes() {
// return new String[]{"10140MAG", "10140MAO"};
// }
//
// public IRefDocEdit getRefDocEdit() {
// return null;
// }
// });
// this.setCommonDataTableName(MaterialVersionVO.getDefaultTableName());
// this.setFilterRefNodeName(new String[]{"业务单元"});
// this.userDefRefShow.addUserDefItemFields(this);
// this.resetFieldName();
// this.assginSqlMap.clear();
// Map<String, String> allFields = new LinkedHashMap();
// allFields.put("pk_org", fieldNames[0]);
// allFields.put("code", fieldNames[1]);
// allFields.put("name", fieldNames[2]);
// allFields.put("materialspec", fieldNames[3]);
// allFields.put("materialtype", fieldNames[4]);
// allFields.put("materialshortname", fieldNames[5]);
// allFields.put("materialmnecode", fieldNames[6]);
// allFields.put("graphid", fieldNames[7]);
//// allFields.put("memo", fieldNames[8]);
// String[] defaultSearchFields = new String[]{"code", "name"};
// RefSearchFieldSetting setting = new RefSearchFieldSetting(this.getRefNodeName(), allFields, defaultSearchFields);
// this.setSearchFieldSetting(setting);
// }
public Vector getData() {
Vector<Vector> v = super.getData();
this.userDefRefShow.proessorData(v);
return v;
}
protected String getEnvWherePart() {
SqlWhereUtil sw = new SqlWhereUtil();
try {
sw.and(BDVisibleUtil.getRefVisibleCondition(NCESAPI.clientSqlEncode(this.getPk_group()), NCESAPI.clientSqlEncode(this.getPk_org()), "c7dc0ccd-8872-4eee-8882-160e8f49dfad", this.isShowDisableData()));
} catch (BusinessException e) {
Logger.error(e.getMessage());
}
return sw.getSQLWhere();
}
public boolean isAssginShowData() {
return this.isAssginShowData;
}
public void setAssginShowData(boolean isAssginShowData) {
this.isAssginShowData = isAssginShowData;
}
private IMaterialAssignService getAssignService() {
if (this.assignService == null) {
this.assignService = (IMaterialAssignService)NCLocator.getInstance().lookup(IMaterialAssignService.class);
}
return this.assignService;
}
public boolean isShowAssginDataChk() {
return this.isShowAssginDataChk;
}
public void setShowAssginDataChk(boolean isShowAssginDataChk) {
this.isShowAssginDataChk = isShowAssginDataChk;
}
public void setShowDisableData(boolean isShowDisableData) {
this.isShowDisableData = isShowDisableData;
}
public boolean isShowDisableData() {
return this.isShowDisableData;
}
}