diff --git a/src_core/com/tenwa/comm/message/controller/FileMailingMessage.java b/src_core/com/tenwa/comm/message/controller/FileMailingMessage.java index b10dc423e..774e594d3 100644 --- a/src_core/com/tenwa/comm/message/controller/FileMailingMessage.java +++ b/src_core/com/tenwa/comm/message/controller/FileMailingMessage.java @@ -25,7 +25,7 @@ public class FileMailingMessage extends BaseBussinessMessage { messageManager.createQuery(" delete from O where message_content='邮寄档案归档' ").executeUpdate(); String sql = "SELECT COUNT(O.PROJECT_MANAGE) number,O.PROJECT_MANAGE PROJECT_MANAGE FROM LB_CONTRACT_INFO O LEFT JOIN LB_FILE_MAILARCHIVING_INFO lfi ON lfi.contract_id = O.id LEFT JOIN ORG_INFO oi ON oi.orgid = O.PROJECT_DEPT LEFT JOIN LC_CALC_CONDITION lcc ON lcc.contract_id = O.id WHERE (lfi.ALLHANDOVERSTATUS IS NULL OR lfi.ALLHANDOVERSTATUS = 'part' OR lfi.ALLHANDOVERSTATUS = 'none') AND NOT EXISTS (SELECT 1 FROM LB_FILE_MAILARCHIVING_INFO_TEMP lfmit WHERE lfmit.contract_id = O.id AND lfmit.is_flowing = '0') AND EXISTS (SELECT 1 FROM LB_FILE_ARCHIVING_INFO lfai WHERE lfai.contract_id = O.id) GROUP BY O.PROJECT_MANAGE"; - List> lciList=DataOperatorUtil.getDataBySql(sql, null); + List> lciList=DataOperatorUtil.getDataBySql(sql); for(Map lci : lciList){ Mapmessage=new HashMap(); diff --git a/src_core/com/tenwa/comm/util/jboutil/DataOperatorUtil.java b/src_core/com/tenwa/comm/util/jboutil/DataOperatorUtil.java index 91bef246a..b8fb2312f 100644 --- a/src_core/com/tenwa/comm/util/jboutil/DataOperatorUtil.java +++ b/src_core/com/tenwa/comm/util/jboutil/DataOperatorUtil.java @@ -563,7 +563,16 @@ public class DataOperatorUtil { public static List> getDataBySql( String sql, Map params ) throws Exception { return getDataBySql( null, sql, params ); } - + /** + * 重构一个简便调用 + * @param sql + * @param tx + * @return + * @throws Exception + */ + public static List> getDataBySql(String sql , JBOTransaction tx) throws Exception { + return getDataBySql( tx, sql, null ); + } /** * 再重构一个更简便调用 * @param sql diff --git a/src_core/com/tenwa/doc/action/DocListInitAction.java b/src_core/com/tenwa/doc/action/DocListInitAction.java index 7790924bd..29985a290 100644 --- a/src_core/com/tenwa/doc/action/DocListInitAction.java +++ b/src_core/com/tenwa/doc/action/DocListInitAction.java @@ -461,7 +461,7 @@ public class DocListInitAction { } String sql = "SELECT FLOWNO FROM flow_catalog WHERE flowname='" + flowName + "'"; - List> ds = DataOperatorUtil.getDataBySql( sql, null); + List> ds = DataOperatorUtil.getDataBySql( sql); String flowno = GetValueByKey("docpreview.properties", ds.get(0).get("FLOWNO")); // 根据要求拖车申请是 @@ -584,7 +584,7 @@ public class DocListInitAction { public static List nextImageForMailDoc(String contract_id) throws Exception{ List list = new ArrayList(); String sql = "select lda.id attrid from lb_docrelative ldr left join lb_doclibrary ldl on ldl.RELATIVE_ID = ldr.id left join lb_docattribute lda on lda.LIBRARY_ID = ldl.ID where ldr.OBJECTTYPE = 'MortgageFileMailFlow' and contract_id = '"+contract_id+"' and lda.id is not null"; - List> ds = DataOperatorUtil.getDataBySql( sql, null ); + List> ds = DataOperatorUtil.getDataBySql( sql ); for(Map map:ds){ list.add(map.get("attrid")); } @@ -593,7 +593,7 @@ public class DocListInitAction { public static List nextImageForMailHisDoc(String contract_id) throws Exception{ List list = new ArrayList(); String sql = "select lda.id attrid from lb_docrelative ldr left join lb_doclibrary ldl on ldl.RELATIVE_ID = ldr.id left join lb_docattribute lda on lda.LIBRARY_ID = ldl.ID where ldr.OBJECTTYPE IN ('BusinessApplyFlow','FundPaymentCarFlow','MortgageFileFlow') and proj_id = '"+contract_id+"' and lda.id is not null"; - List> ds = DataOperatorUtil.getDataBySql( sql, null ); + List> ds = DataOperatorUtil.getDataBySql( sql ); for(Map map:ds){ list.add(map.get("attrid")); } diff --git a/src_tenwa/com/tenwa/lease/app/quartzmession/CorpusSourceRentPlanCopy.java b/src_tenwa/com/tenwa/lease/app/quartzmession/CorpusSourceRentPlanCopy.java index 866ea24f5..ea2085575 100644 --- a/src_tenwa/com/tenwa/lease/app/quartzmession/CorpusSourceRentPlanCopy.java +++ b/src_tenwa/com/tenwa/lease/app/quartzmession/CorpusSourceRentPlanCopy.java @@ -2,29 +2,23 @@ package com.tenwa.lease.app.quartzmession; import com.amarsoft.are.jbo.*; import com.amarsoft.are.util.StringFunction; -import com.amarsoft.awe.util.ASResultSet; -import com.amarsoft.awe.util.SqlObject; 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.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.sql.SQLException; - import java.text.ParseException; import java.text.SimpleDateFormat; - -import java.util.Date; -import java.util.HashSet; -import java.util.List; -import java.util.Set; +import java.util.*; import static java.math.BigDecimal.ROUND_HALF_UP; @@ -33,25 +27,7 @@ import static java.math.BigDecimal.ROUND_HALF_UP; */ public class CorpusSourceRentPlanCopy implements Job { - Set contractSet = null; - JBOTransaction tx = null; - Transaction Sqlca = null; - { - try { - tx = JBOFactory.createJBOTransaction(); - Sqlca = Transaction.createTransaction(tx); - } catch (JBOException e) { - e.printStackTrace(); - try { - if (Sqlca != null) { - Sqlca.rollback(); - } - } catch (JBOException e1) { - e1.printStackTrace(); - } - } - } - + private String contractId; @Override public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException { @@ -62,7 +38,13 @@ public class CorpusSourceRentPlanCopy implements Job { 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 添加渠道商的选择，哪些需要拷表哪些不需要 @@ -72,11 +54,17 @@ public class CorpusSourceRentPlanCopy implements Job { //1.更新租金计划租金信息，并获取每个文件的contract_id String sql = "select fr.CONTRACT_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); - contractSet = this.updateRentPlan(fyfrpBoList); - //2.更新租金计划剩余本金 - updateAllRemainCorpus(); - //3.更新租金计划分润信息 - updateSplitSP(); + + Set contractSet = this.updateRentPlan(fyfrpBoList,tx); + for(String contractId : contractSet){ + 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); @@ -105,10 +93,10 @@ public class CorpusSourceRentPlanCopy implements Job { * @throws JBOException * @throws ParseException */ - public Set updateRentPlan(List fyfrpBoList) throws JBOException, ParseException { + public Set updateRentPlan(List fyfrpBoList,JBOTransaction tx) throws JBOException, ParseException { BizObjectManager lrpBom = null; lrpBom = JBOFactory.getBizObjectManager(LC_RENT_PLAN.CLASS_NAME,tx); - contractSet = new HashSet<>(); + Set contractSet = new HashSet<>(); //更新租金计划表 for(BizObject bo : fyfrpBoList){ //获取参数 @@ -141,73 +129,142 @@ public class CorpusSourceRentPlanCopy implements Job { * 更新剩余本金信息 * @throws JBOException */ - public void updateAllRemainCorpus() 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); - //根据contractId遍历循环来更新租金计划表中剩余本金字段 - for(String contractId : contractSet){ - 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); - } + 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() throws Exception { + public void updateSplitSP(Map param,Transaction Sqlca) throws Exception { - for(String contractId : contractSet) { - String sql = "select lci.product_id,lci.distributor_id,lcc.payment_number from lb_contract_info lci left join lc_calc_condition lcc on lci.id=lcc.contract_id where lci.id='" + contractId + "'"; - SqlObject sqlBo = null; - String productId = null; - String distributorId = null; - String paymentNumber = null; - ASResultSet rs = null; + 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 { - sqlBo = new SqlObject(sql); - rs = Sqlca.getASResultSet(sqlBo); - if ( rs.next() ) { - productId = rs.getString( "product_id" ); - distributorId = rs.getString( "distributor_id" ); - paymentNumber = rs.getString( "payment_number" ); - String splitType = Sqlca.getString("select attribute5 from business_type where typeno = '" + productId + "'"); - String splittingRatio = Sqlca.getString("select splitting_ratio from lb_splitting_ratio where distributor_id='" + distributorId + "' and product_id='" + productId + "'"); - if (!"".equals(splittingRatio) && splittingRatio != null) { - CreateTransactionExecutor cre = new CreateTransactionExecutor(); - cre.setPlannumber(paymentNumber); - cre.insertRentPlan_SP(splittingRatio, Sqlca, splitType); - } + if (Sqlca != null) { + Sqlca.rollback(); } - - } catch (SQLException throwables) { - throwables.printStackTrace(); - }finally { - rs.close(); + } catch (JBOException e1) { + e1.printStackTrace(); } - } } - - public Set getContractSet() { - return contractSet; + /** + * 获取每个合同的参数 + * @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); } - public void setContractSet(Set contractSet) { - this.contractSet = contractSet; + /** + * 获取每个合同的参数 + * @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"); + 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 corpusSourceRate = param.get("corpusSourceRate"); + 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("profit",profit); + lppBo.setAttributeValue("inputtime",StringFunction.getTodayNow()); + lppBom.saveObject(lppBo); + } + + } + + /** + * 插入分润计划 + * @param tx + * @throws JBOException + */ + public void insertProfitPlan(JBOTransaction tx) throws Exception { + Map param = this.getParamByContractId(contractId,tx); + this.insertProfitPlan(param,tx); + } + + public String getContractId() { + return contractId; + } + + public void setContractId(String contractId) { + this.contractId = contractId; } }