From d4f06b57295cbedbf686cc0af3e48fe973aa4e3d Mon Sep 17 00:00:00 2001 From: ap007 Date: Mon, 2 Aug 2021 17:22:24 +0800 Subject: [PATCH] =?UTF-8?q?=E8=B5=84=E6=96=B9=E7=A7=9F=E9=87=91=E8=AE=A1?= =?UTF-8?q?=E5=88=92=E6=8B=B7=E8=B4=9D=E5=AE=9A=E6=97=B6=E4=BB=BB=E5=8A=A1?= =?UTF-8?q?=E5=8F=8A=E5=8A=9F=E8=83=BD=E4=BC=98=E5=8C=96?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../quartzmession/CorpusSourceFileCopy.java | 352 ++++++++++++++++++ .../CorpusSourceRentPlanCopy.java | 295 +++------------ 2 files changed, 400 insertions(+), 247 deletions(-) create mode 100644 src_tenwa/com/tenwa/lease/app/quartzmession/CorpusSourceFileCopy.java diff --git a/src_tenwa/com/tenwa/lease/app/quartzmession/CorpusSourceFileCopy.java b/src_tenwa/com/tenwa/lease/app/quartzmession/CorpusSourceFileCopy.java new file mode 100644 index 000000000..691cb7e35 --- /dev/null +++ b/src_tenwa/com/tenwa/lease/app/quartzmession/CorpusSourceFileCopy.java @@ -0,0 +1,352 @@ +package com.tenwa.lease.app.quartzmession; + +import com.amarsoft.are.ARE; +import com.amarsoft.are.jbo.*; +import com.amarsoft.are.util.StringFunction; +import com.amarsoft.awe.util.Transaction; +import com.base.util.QuartzUtil; +import com.tenwa.comm.util.jboutil.DataOperatorUtil; +import com.tenwa.reckon.executor.CreateTransactionExecutor; +import jbo.app.tenwa.calc.LC_CALC_CONDITION; +import jbo.app.tenwa.calc.LC_RENT_PLAN; +import jbo.app.tenwa.calc.LC_RENT_PLAN_HIS; +import jbo.oti.FC_FILE_PUSH; +import jbo.oti.FC_YC_FILE_REPAY_PLAN; +import jbo.oti.LC_PROFIT_PLAN; +import org.quartz.Job; +import org.quartz.JobExecutionContext; +import org.quartz.JobExecutionException; + +import java.math.BigDecimal; +import java.text.ParseException; +import java.text.SimpleDateFormat; +import java.util.Date; +import java.util.HashMap; +import java.util.List; +import java.util.Map; + +import static java.math.BigDecimal.ROUND_HALF_UP; + +/** + * 资方租金计划拷贝 + */ +public class CorpusSourceFileCopy { + + private String contractId; + private String fileType; + + public void doCopy(JBOTransaction tx) throws JobExecutionException { + BizObjectManager ffpBom = null; + Transaction Sqlca = null; + try { + Sqlca = Transaction.createTransaction(tx); + ffpBom = JBOFactory.getBizObjectManager(FC_FILE_PUSH.CLASS_NAME,tx); + //todo 添加渠道商的选择，哪些需要拷表哪些不需要 + String fileSql = "select ID,FILE_STS from O where FILE_TYPE='"+fileType+"' and FILE_STS='2'"; + List ffpBoList = ffpBom.createQuery(fileSql).getResultList(true); + if(ffpBoList.size()==0){ + ARE.getLog().info("暂时没有需要拷表的资方文件"); + return; + } + //遍历解析每个文件 + for(BizObject ffpBo : ffpBoList){ + analyticalFile(ffpBo,tx); + ffpBo.setAttributeValue("FILE_STS","3"); + ffpBo.setAttributeValue("FILE_STS_DESC","拷贝成功"); + ffpBom.saveObject(ffpBo); + } + Sqlca.commit(); + } catch (Exception e) { + e.printStackTrace(); + try { + if (Sqlca != null) { + Sqlca.rollback(); + } + } catch (JBOException e1) { + e1.printStackTrace(); + } + throw new JobExecutionException(e); + } + } + + /** + * 解析文件 + * @param ffpBo + * @param tx + * @throws Exception + */ + public void analyticalFile(BizObject ffpBo,JBOTransaction tx) throws Exception { + String fcFileId = ffpBo.getAttribute("ID").toString(); + List fyfrpBoList = getFileInfoByFileId(fcFileId); + + respectiveDo(fyfrpBoList,tx); + + } + + /** + * 执行自己类所需的操作 + * @param fyfrpBoList + * @param tx + * @throws Exception + */ + public void respectiveDo(List fyfrpBoList , JBOTransaction tx) throws Exception { + //获取对应的合同 + Map contractMap = this.getContractIdMap(fyfrpBoList); + if(contractMap.size()==0){ + String fcFileId = fyfrpBoList.get(0).getAttribute("FC_REQUEST_ID").toString(); + ARE.getLog().error("未找到FC_REQUEST_ID: "+fcFileId+" 对应的合同ID"); + throw new Exception("未找到FC_REQUEST_ID: "+fcFileId+" 对应的合同ID"); + } + Transaction Sqlca = Transaction.createTransaction(tx); + //===顺序不能错=== + //0.将租金计划拷贝到历史表 + copyRentPlanFormatToHis(contractMap,tx); + //1.更新租金计划表（直接文件每条信息更新，不需要遍历） + updateRentPlan(fyfrpBoList,tx); + for(Map.Entry entry : contractMap.entrySet()){ + String contractId = entry.getKey(); + Map param = getParamByContractId(contractId,tx); + //2.更新剩余本金 + updateAllRemainCorpus(contractId,Sqlca); + //3.更新SP分润计划 + updateSplitSP(param,Sqlca); + //4.插入分润计划 + insertProfitPlan(param,tx); + } + + } + + /** + * 获取每个文件的文件信息 + * @param fcFileId + * @return + * @throws Exception + */ + public List getFileInfoByFileId(String fcFileId) throws Exception { + String sql = "select fr.CONTRACT_ID,O.FC_REQUEST_ID,O.LEND_TERM,O.ANS_REPAYMENT_DATE,O.ANS_PRINCIPAL,O.ANS_INTEREST,ANS_REPAYMENT_MONEY from O left join jbo.oti.FC_REQUEST fr on O.FC_REQUEST_ID=fr.ID where fr.DEL_FLAG='0' and O.FC_FILE_ID=:fcFileId"; + BizObjectManager fyfrpBom = JBOFactory.getBizObjectManager(FC_YC_FILE_REPAY_PLAN.CLASS_NAME); + List fyfrpBoList = fyfrpBom.createQuery(sql).setParameter("fcFileId",fcFileId).getResultList(false); + if(fyfrpBoList.size()==0){ + ARE.getLog().error("未找到FC_REQUEST_ID: "+fcFileId+" 对应的资方还款计划"); + throw new Exception("未找到FC_REQUEST_ID: "+fcFileId+" 对应的资方还款计划"); + } + return fyfrpBoList; + } + + /** + * copy租金计划到历史表 + * @param contractMap + * @param tx + * @throws Exception + */ + public void copyRentPlanFormatToHis(Map contractMap ,JBOTransaction tx) throws Exception { + for(Map.Entry entry: contractMap.entrySet()){ + Map fromCondtion=new HashMap(); + fromCondtion.put("CONTRACT_ID",entry.getKey()); + + Map otherProperty=new HashMap(); + otherProperty.put("MEMO", "安鹏原正式租金计划"); + otherProperty.put("FLOWUNID", entry.getValue()); + + DataOperatorUtil.copyJBOSet(LC_RENT_PLAN.CLASS_NAME, fromCondtion, LC_RENT_PLAN_HIS.CLASS_NAME,null, otherProperty, null, tx); + } + } + /** + * 获取对应的合同ID + * @param fyfrpBoList + * @return + * @throws JBOException + */ + public Map getContractIdMap(List fyfrpBoList) throws JBOException { + Map contractMap = new HashMap<>(); + for(BizObject bo : fyfrpBoList){ + String contractId = bo.getAttribute("CONTRACT_ID").toString(); + String fcRequestId = bo.getAttribute("FC_REQUEST_ID").toString(); + contractMap.put(contractId,fcRequestId); + } + return contractMap; + } + /** + * 租金计划拷贝 + * @param fyfrpBoList 每个回执文件包含的租金计划信息 + * @return 每个回执文件包含的contract_id + * @throws JBOException + * @throws ParseException + */ + public void updateRentPlan(List fyfrpBoList,JBOTransaction tx) throws JBOException, ParseException { + BizObjectManager lrpBom = null; + lrpBom = JBOFactory.getBizObjectManager(LC_RENT_PLAN.CLASS_NAME,tx); + //更新租金计划表 + for(BizObject bo : fyfrpBoList){ + //获取参数 + String contractId = bo.getAttribute("CONTRACT_ID").toString(); + String lendTerm = bo.getAttribute("LEND_TERM").toString(); + String principal = bo.getAttribute("ANS_PRINCIPAL").toString(); + String interest = bo.getAttribute("ANS_INTEREST").toString(); + String rent = new BigDecimal(principal).add(new BigDecimal(interest)).toString(); + String repaymentMoney = bo.getAttribute("ANS_REPAYMENT_MONEY").toString(); + String repaymentDate = bo.getAttribute("ANS_REPAYMENT_DATE").toString(); + //转换日期格式 + Date date = new SimpleDateFormat("yyyyMMdd").parse(repaymentDate); + repaymentDate = new SimpleDateFormat("yyyy/MM/dd").format(date); + //更新租金计划表 + BizObject lrpBo = lrpBom.createQuery("CONTRACT_ID=:contractId and PLAN_LIST=:lendTerm").setParameter("contractId",contractId).setParameter("lendTerm",lendTerm).getSingleResult(true); + lrpBo.setAttributeValue("RENT",rent); + lrpBo.setAttributeValue("CORPUS",principal); + lrpBo.setAttributeValue("INTEREST",interest); + lrpBo.setAttributeValue("CORPUS_BUSINESS",principal); + lrpBo.setAttributeValue("INTEREST_BUSINESS",interest); + lrpBo.setAttributeValue("PLAN_DATE",repaymentDate); + lrpBo.setAttributeValue("RENT",repaymentMoney); + lrpBom.saveObject(lrpBo); + } + } + + /** + * 更新剩余本金信息 + * @throws JBOException + */ + public void updateAllRemainCorpus(String contractId,JBOTransaction tx) throws JBOException { + BizObjectManager lrpBom = null; + lrpBom = JBOFactory.getBizObjectManager(LC_RENT_PLAN.CLASS_NAME,tx); + BizObjectManager lccBom = null; + lccBom = JBOFactory.getBizObjectManager(LC_CALC_CONDITION.CLASS_NAME,tx); + + BizObject lccBo = lccBom.createQuery("select CLEAN_LEASE_MONEY from O where contract_id=:contractId").setParameter("contractId",contractId).getSingleResult(false); + String clean_lease_money = lccBo.getAttribute("CLEAN_LEASE_MONEY").toString(); + BigDecimal cleanLeaseMoneyBd = new BigDecimal(clean_lease_money); + List lrpBos= lrpBom.createQuery("contract_id=:contractId order by plan_list").setParameter("contractId",contractId).getResultList(true); + for(BizObject bo :lrpBos){ + String corpus = bo.getAttribute("corpus").toString(); + BigDecimal corpusBd = new BigDecimal(corpus); + cleanLeaseMoneyBd = cleanLeaseMoneyBd.subtract(corpusBd).setScale(2,ROUND_HALF_UP); + bo.setAttributeValue("ALL_REMAIN_CORPUS",cleanLeaseMoneyBd.toString()); + lrpBom.saveObject(bo); + } + } + + /** + * 更新剩余本金信息 + * @throws JBOException + */ + public void updateAllRemainCorpus(JBOTransaction tx) throws JBOException { + updateAllRemainCorpus(contractId,tx); + } + + /** + * 更新分润信息 + * @throws Exception + */ + public void updateSplitSP(Map param,Transaction Sqlca) throws Exception { + + String splittingRatio = param.get("splittingRatio"); + //必须的判断条件（配置了灵活分润的产品可能没有配置分润） + // 判断顺序，是否分润--》是否灵活分润 + //是否灵活分润在insertRentPlan_SP（）方法中判断 + if (!"".equals(splittingRatio) && splittingRatio != null) { + String paymentNumber = param.get("paymentNumber"); + String splitType = param.get("splitType"); + CreateTransactionExecutor cre = new CreateTransactionExecutor(); + cre.setPlannumber(paymentNumber); + cre.insertRentPlan_SP(splittingRatio, Sqlca, splitType); + } + + } + + /** + * 更新分润信息 + * @throws Exception + */ + public void updateSplitSP(JBOTransaction tx) { + Transaction Sqlca = null; + try { + Sqlca = Transaction.createTransaction(tx); + Map param = getParamByContractId(contractId,tx); + updateSplitSP(param,Sqlca); + } catch (JBOException e) { + e.printStackTrace(); + } catch (Exception e) { + e.printStackTrace(); + }finally { + try { + if (Sqlca != null) { + Sqlca.rollback(); + } + } catch (JBOException e1) { + e1.printStackTrace(); + } + } + } + + /** + * 获取每个合同的参数 + * @return + * @throws Exception + */ + public Map getParamByContractId(String contractId,JBOTransaction tx) throws Exception { + String sql = "select * from vi_corpus_source_param where contractId='" + contractId + "'"; + List> data = DataOperatorUtil.getDataBySql(sql,tx); + return data.get(0); + } + + /** + * 获取每个合同的参数 + * @return + * @throws Exception + */ + public Map getParamByContractId(JBOTransaction tx) throws Exception { + return getParamByContractId(contractId,tx); + } + + /** + * 插入分润计划 + * @param param + * @throws JBOException + */ + public void insertProfitPlan(Map param,JBOTransaction tx) throws JBOException { + BizObjectManager lppBom = null; + lppBom = JBOFactory.getBizObjectManager(LC_PROFIT_PLAN.CLASS_NAME,tx); + BizObjectManager lrpBom = null; + lrpBom = JBOFactory.getBizObjectManager(LC_RENT_PLAN.CLASS_NAME,tx); + BizObject lppBo = null; + String paymentNumber = param.get("paymentNumber"); + String corpusSourceRate = param.get("corpusSourceRate"); + List lrpBos = lrpBom.createQuery("PAYMENT_NUMBER=:paymentNumber order by plan_list").setParameter("paymentNumber",paymentNumber).getResultList(false); + for(BizObject bo :lrpBos){ + String rentPlanId = bo.getAttribute("ID").toString(); + String interest = bo.getAttribute("INTEREST").toString(); + String yearRate = bo.getAttribute("YEAR_RATE").toString(); + String profit = new BigDecimal(yearRate).subtract(new BigDecimal(corpusSourceRate)).divide(new BigDecimal(yearRate),6,BigDecimal.ROUND_HALF_UP).multiply(new BigDecimal(interest)).setScale(2,BigDecimal.ROUND_HALF_UP).toString(); + lppBo = lppBom.newObject(); + lppBo.setAttributeValue("rent_plan_id",rentPlanId); + lppBo.setAttributeValue("CORPUS_RATE",corpusSourceRate); + lppBo.setAttributeValue("profit",profit); + lppBo.setAttributeValue("inputtime",StringFunction.getTodayNow()); + lppBom.saveObject(lppBo); + } + + } + + /** + * 插入分润计划 + * @param tx + * @throws JBOException + */ + public void insertProfitPlan(JBOTransaction tx) throws Exception { + Map param = getParamByContractId(contractId,tx); + insertProfitPlan(param,tx); + } + + public String getContractId() { + return contractId; + } + + public void setContractId(String contractId) { + this.contractId = contractId; + } + + public String getFileType() { return fileType; } + + public void setFileType(String fileType) { this.fileType = fileType; } + +} diff --git a/src_tenwa/com/tenwa/lease/app/quartzmession/CorpusSourceRentPlanCopy.java b/src_tenwa/com/tenwa/lease/app/quartzmession/CorpusSourceRentPlanCopy.java index ad229dfe5..831f46ba0 100644 --- a/src_tenwa/com/tenwa/lease/app/quartzmession/CorpusSourceRentPlanCopy.java +++ b/src_tenwa/com/tenwa/lease/app/quartzmession/CorpusSourceRentPlanCopy.java @@ -27,86 +27,29 @@ import static java.math.BigDecimal.ROUND_HALF_UP; /** * 资方租金计划拷贝 */ -public class CorpusSourceRentPlanCopy implements Job { +public class CorpusSourceRentPlanCopy extends CorpusSourceFileCopy implements Job { private String contractId; @Override public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException { - String startime = StringFunction.getTodayNow(); Object userId = jobExecutionContext.getTrigger().getJobDataMap().get("CurUserId"); String curUserId = userId == null? "system" : userId.toString(); - BizObjectManager ffpBom = null; - BizObjectManager fyfrpBom = null; - JBOTransaction tx = null; - Transaction Sqlca = null; - try { tx = JBOFactory.createJBOTransaction(); - Sqlca = Transaction.createTransaction(tx); - ffpBom = JBOFactory.getBizObjectManager(FC_FILE_PUSH.CLASS_NAME,tx); - fyfrpBom = JBOFactory.getBizObjectManager(FC_YC_FILE_REPAY_PLAN.CLASS_NAME,tx); - //todo 添加渠道商的选择，哪些需要拷表哪些不需要 - List ffpBoList = ffpBom.createQuery("select ID,FILE_STS from O where FILE_STS='2'").getResultList(true); - if(ffpBoList.size()==0){ - ARE.getLog().info("暂时没有需要拷表的资方文件"); - return; - } - //遍历每个文件 - for(BizObject ffpBo : ffpBoList){ - String fcFileId = ffpBo.getAttribute("ID").toString(); - String sql = "select fr.CONTRACT_ID,O.FC_REQUEST_ID,O.LEND_TERM,O.ANS_REPAYMENT_DATE,O.ANS_PRINCIPAL,O.ANS_INTEREST,ANS_REPAYMENT_MONEY from O left join jbo.oti.FC_REQUEST fr on O.FC_REQUEST_ID=fr.ID where fr.DEL_FLAG='0' and O.FC_FILE_ID=:fcFileId"; - List fyfrpBoList = fyfrpBom.createQuery(sql).setParameter("fcFileId",fcFileId).getResultList(false); - if(fyfrpBoList.size()==0){ - ARE.getLog().error("未找到FC_REQUEST_ID: "+fcFileId+" 对应的资方还款计划"); - throw new Exception("未找到FC_REQUEST_ID: "+fcFileId+" 对应的资方还款计划"); - } - //获取对应的合同 - Map contractMap = this.getContractIdMap(fyfrpBoList); - if(contractMap.size()==0){ - ARE.getLog().error("未找到FC_REQUEST_ID: "+fcFileId+" 对应的合同ID"); - throw new Exception("未找到FC_REQUEST_ID: "+fcFileId+" 对应的合同ID"); - } - //0.租金计划正式表考入历史表 - for(Map.Entry entry: contractMap.entrySet()){ - Map fromCondtion=new HashMap(); - fromCondtion.put("CONTRACT_ID",entry.getKey()); - - Map otherProperty=new HashMap(); - otherProperty.put("MEMO", "安鹏原正式租金计划"); - otherProperty.put("FLOWUNID", entry.getValue()); - - DataOperatorUtil.copyJBOSet(LC_RENT_PLAN.CLASS_NAME, fromCondtion, LC_RENT_PLAN_HIS.CLASS_NAME,null, otherProperty, null, Sqlca); - } - //1.更新租金计划（直接文件每条信息更新，不需要遍历） - this.updateRentPlan(fyfrpBoList,tx); - - for(Map.Entry entry: contractMap.entrySet()){ - String contractId = entry.getKey(); - Map param= this.getParamByContractId(contractId,tx); - //2.更新租金计划剩余本金 - this.updateAllRemainCorpus(contractId,tx); - //3.更新租金计划分润信息 - this.updateSplitSP(param,Sqlca); - //4.插入分润计划 - this.insertProfitPlan(param,tx); - } - ffpBo.setAttributeValue("FILE_STS","3"); - ffpBo.setAttributeValue("FILE_STS_DESC","拷贝成功"); - ffpBom.saveObject(ffpBo); - } - - Sqlca.commit(); + setFileType("RepayPlan"); + doCopy(tx); + tx.commit(); QuartzUtil.insertLog(startime,"com.tenwa.lease.app.quartzmession.CorpusSourceRentPlanCopy", "success", "成功", curUserId); } catch (Exception e) { e.printStackTrace(); QuartzUtil.insertLog(startime,"com.tenwa.lease.app.quartzmession.CorpusSourceRentPlanCopy", "error", "失败", curUserId); try { - if (Sqlca != null) { - Sqlca.rollback(); + if (tx != null) { + tx.rollback(); } } catch (JBOException e1) { e1.printStackTrace(); @@ -116,196 +59,54 @@ public class CorpusSourceRentPlanCopy implements Job { } /** - * 获取对应的合同ID + * 执行自己类所需的操作 * @param fyfrpBoList - * @return - * @throws JBOException - */ - public Map getContractIdMap(List fyfrpBoList) throws JBOException { - Map contractMap = new HashMap<>(); - for(BizObject bo : fyfrpBoList){ - String contractId = bo.getAttribute("CONTRACT_ID").toString(); - String fcRequestId = bo.getAttribute("FC_REQUEST_ID").toString(); - contractMap.put(contractId,fcRequestId); - } - return contractMap; - } - /** - * 租金计划拷贝 - * @param fyfrpBoList 每个回执文件包含的租金计划信息 - * @return 每个回执文件包含的contract_id - * @throws JBOException - * @throws ParseException - */ - public void updateRentPlan(List fyfrpBoList,JBOTransaction tx) throws JBOException, ParseException { - BizObjectManager lrpBom = null; - lrpBom = JBOFactory.getBizObjectManager(LC_RENT_PLAN.CLASS_NAME,tx); - //更新租金计划表 - for(BizObject bo : fyfrpBoList){ - //获取参数 - String contractId = bo.getAttribute("CONTRACT_ID").toString(); - String lendTerm = bo.getAttribute("LEND_TERM").toString(); - String principal = bo.getAttribute("ANS_PRINCIPAL").toString(); - String interest = bo.getAttribute("ANS_INTEREST").toString(); - String repaymentMoney = bo.getAttribute("ANS_REPAYMENT_MONEY").toString(); - String repaymentDate = bo.getAttribute("ANS_REPAYMENT_DATE").toString(); - //转换日期格式 - Date date = new SimpleDateFormat("yyyyMMdd").parse(repaymentDate); - repaymentDate = new SimpleDateFormat("yyyy/MM/dd").format(date); - //更新租金计划表 - BizObject lrpBo = lrpBom.createQuery("CONTRACT_ID=:contractId and PLAN_LIST=:lendTerm").setParameter("contractId",contractId).setParameter("lendTerm",lendTerm).getSingleResult(true); - lrpBo.setAttributeValue("RENT",repaymentMoney); - lrpBo.setAttributeValue("CORPUS",principal); - lrpBo.setAttributeValue("INTEREST",interest); - lrpBo.setAttributeValue("CORPUS_BUSINESS",principal); - lrpBo.setAttributeValue("INTEREST_BUSINESS",interest); - lrpBo.setAttributeValue("PLAN_DATE",repaymentDate); - lrpBo.setAttributeValue("RENT",repaymentMoney); - lrpBom.saveObject(lrpBo); - } - } - - /** - * 更新剩余本金信息 - * @throws JBOException - */ - public void updateAllRemainCorpus(String contractId,JBOTransaction tx) throws JBOException { - BizObjectManager lrpBom = null; - lrpBom = JBOFactory.getBizObjectManager(LC_RENT_PLAN.CLASS_NAME,tx); - BizObjectManager lccBom = null; - lccBom = JBOFactory.getBizObjectManager(LC_CALC_CONDITION.CLASS_NAME,tx); - - BizObject lccBo = lccBom.createQuery("select CLEAN_LEASE_MONEY from O where contract_id=:contractId").setParameter("contractId",contractId).getSingleResult(false); - String clean_lease_money = lccBo.getAttribute("CLEAN_LEASE_MONEY").toString(); - BigDecimal cleanLeaseMoneyBd = new BigDecimal(clean_lease_money); - List lrpBos= lrpBom.createQuery("contract_id=:contractId order by plan_list").setParameter("contractId",contractId).getResultList(true); - for(BizObject bo :lrpBos){ - String corpus = bo.getAttribute("corpus").toString(); - BigDecimal corpusBd = new BigDecimal(corpus); - cleanLeaseMoneyBd = cleanLeaseMoneyBd.subtract(corpusBd).setScale(2,ROUND_HALF_UP); - bo.setAttributeValue("ALL_REMAIN_CORPUS",cleanLeaseMoneyBd.toString()); - lrpBom.saveObject(bo); - } - } - - /** - * 更新剩余本金信息 - * @throws JBOException - */ - public void updateAllRemainCorpus(JBOTransaction tx) throws JBOException { - this.updateAllRemainCorpus(contractId,tx); - } - - /** - * 更新分润信息 - * @throws Exception - */ - public void updateSplitSP(Map param,Transaction Sqlca) throws Exception { - - String splittingRatio = param.get("splittingRatio"); - //必须的判断条件（配置了灵活分润的产品可能没有配置分润） - // 判断顺序，是否分润--》是否灵活分润 - //是否灵活分润在insertRentPlan_SP（）方法中判断 - if (!"".equals(splittingRatio) && splittingRatio != null) { - String paymentNumber = param.get("paymentNumber"); - String splitType = param.get("splitType"); - CreateTransactionExecutor cre = new CreateTransactionExecutor(); - cre.setPlannumber(paymentNumber); - cre.insertRentPlan_SP(splittingRatio, Sqlca, splitType); - } - - } - - /** - * 更新分润信息 - * @throws Exception - */ - public void updateSplitSP(JBOTransaction tx) { - Transaction Sqlca = null; - try { - Sqlca = Transaction.createTransaction(tx); - Map param = this.getParamByContractId(contractId,tx); - this.updateSplitSP(param,Sqlca); - } catch (JBOException e) { - e.printStackTrace(); - } catch (Exception e) { - e.printStackTrace(); - }finally { - try { - if (Sqlca != null) { - Sqlca.rollback(); - } - } catch (JBOException e1) { - e1.printStackTrace(); - } - } - } - - /** - * 获取每个合同的参数 - * @return - * @throws Exception - */ - public Map getParamByContractId(String contractId,JBOTransaction tx) throws Exception { - String sql = "select * from vi_corpus_source_param where contractId='" + contractId + "'"; - List> data = DataOperatorUtil.getDataBySql(sql,tx); - return data.get(0); - } - - /** - * 获取每个合同的参数 - * @return - * @throws Exception - */ - public Map getParamByContractId(JBOTransaction tx) throws Exception { - return this.getParamByContractId(contractId,tx); - } - - /** - * 插入分润计划 - * @param param - * @throws JBOException - */ - public void insertProfitPlan(Map param,JBOTransaction tx) throws JBOException { - BizObjectManager lppBom = null; - lppBom = JBOFactory.getBizObjectManager(LC_PROFIT_PLAN.CLASS_NAME,tx); - BizObjectManager lrpBom = null; - lrpBom = JBOFactory.getBizObjectManager(LC_RENT_PLAN.CLASS_NAME,tx); - BizObject lppBo = null; - String paymentNumber = param.get("paymentNumber"); - String corpusSourceRate = param.get("corpusSourceRate"); - List lrpBos = lrpBom.createQuery("PAYMENT_NUMBER=:paymentNumber order by plan_list").setParameter("paymentNumber",paymentNumber).getResultList(false); - for(BizObject bo :lrpBos){ - String rentPlanId = bo.getAttribute("ID").toString(); - String interest = bo.getAttribute("INTEREST").toString(); - String yearRate = bo.getAttribute("YEAR_RATE").toString(); - String profit = new BigDecimal(yearRate).subtract(new BigDecimal(corpusSourceRate)).divide(new BigDecimal(yearRate),6,BigDecimal.ROUND_HALF_UP).multiply(new BigDecimal(interest)).setScale(2,BigDecimal.ROUND_HALF_UP).toString(); - lppBo = lppBom.newObject(); - lppBo.setAttributeValue("rent_plan_id",rentPlanId); - lppBo.setAttributeValue("CORPUS_RATE",corpusSourceRate); - lppBo.setAttributeValue("profit",profit); - lppBo.setAttributeValue("inputtime",StringFunction.getTodayNow()); - lppBom.saveObject(lppBo); - } - - } - - /** - * 插入分润计划 * @param tx - * @throws JBOException + * @throws Exception */ - public void insertProfitPlan(JBOTransaction tx) throws Exception { - Map param = this.getParamByContractId(contractId,tx); - this.insertProfitPlan(param,tx); + public void respectiveDo(List fyfrpBoList , JBOTransaction tx) throws Exception { + //获取对应的合同 + Map contractMap = getContractIdMap(fyfrpBoList); + if(contractMap.size()==0){ + String fcFileId = fyfrpBoList.get(0).getAttribute("FC_REQUEST_ID").toString(); + ARE.getLog().error("未找到FC_REQUEST_ID: "+fcFileId+" 对应的合同ID"); + throw new Exception("未找到FC_REQUEST_ID: "+fcFileId+" 对应的合同ID"); + } + Transaction Sqlca = Transaction.createTransaction(tx); + //===顺序不能错=== + //0.将租金计划拷贝到历史表 + copyRentPlanFormatToHis(contractMap,tx); + //1.更新租金计划表（直接文件每条信息更新，不需要遍历） + updateRentPlan(fyfrpBoList,tx); + for(Map.Entry entry : contractMap.entrySet()){ + String contractId = entry.getKey(); + Map param = getParamByContractId(contractId,tx); + //2.更新剩余本金 + updateAllRemainCorpus(contractId,Sqlca); + //3.更新SP分润计划 + updateSplitSP(param,Sqlca); + //4.插入分润计划 + insertProfitPlan(param,tx); + } + } - public String getContractId() { - return contractId; + /** + * 根据文件ID获取《租金计划》信息 + * @param fcFileId + * @return + * @throws Exception + */ + public List getFileInfoByFileId(String fcFileId) throws Exception { + String sql = "select fr.CONTRACT_ID,O.FC_REQUEST_ID,O.LEND_TERM,O.ANS_REPAYMENT_DATE,O.ANS_PRINCIPAL,O.ANS_INTEREST,ANS_REPAYMENT_MONEY from O left join jbo.oti.FC_REQUEST fr on O.FC_REQUEST_ID=fr.ID where fr.DEL_FLAG='0' and O.FC_FILE_ID=:fcFileId"; + BizObjectManager fyfrpBom = JBOFactory.getBizObjectManager(FC_YC_FILE_REPAY_PLAN.CLASS_NAME); + List fyfrpBoList = fyfrpBom.createQuery(sql).setParameter("fcFileId",fcFileId).getResultList(false); + if(fyfrpBoList.size()==0){ + ARE.getLog().error("未找到FC_REQUEST_ID: "+fcFileId+" 对应的资方还款计划"); + throw new Exception("未找到FC_REQUEST_ID: "+fcFileId+" 对应的资方还款计划"); + } + return fyfrpBoList; } - public void setContractId(String contractId) { - this.contractId = contractId; - } }