diff --git a/src_core/com/tenwa/voucher/serviceImp/OverdueRepurchaseVoucherPSBC.java b/src_core/com/tenwa/voucher/serviceImp/OverdueRepurchaseVoucherPSBC.java new file mode 100644 index 000000000..d733df03d --- /dev/null +++ b/src_core/com/tenwa/voucher/serviceImp/OverdueRepurchaseVoucherPSBC.java @@ -0,0 +1,503 @@ +package com.tenwa.voucher.serviceImp; + +import com.alibaba.fastjson.JSONObject; +import com.amarsoft.are.ARE; +import com.amarsoft.are.jbo.*; +import com.amarsoft.awe.util.SqlObject; +import com.amarsoft.awe.util.Transaction; +import com.amarsoft.dict.als.cache.CacheLoaderFactory; +import com.amarsoft.dict.als.manage.NameManager; +import com.google.common.collect.Lists; +import com.tenwa.app.manage.qiyuesuo.v2.ContractSignVtwoUtils; +import com.tenwa.comm.util.jboutil.DataOperatorUtil; +import com.tenwa.flow.util.FlowUtil; +import com.tenwa.reckon.util.DateUtil; +import com.tenwa.reckon.util.UUIDUtil; +import com.tenwa.voucher.service.VoucherInfoService; +import jbo.app.VOUCHER_V8; +import jbo.app.tenwa.customer.CUSTOMER_LIST; +import jbo.com.tenwa.entity.comm.own.OWN_INFO; +import jbo.com.tenwa.lease.comm.LB_CONTRACT_INFO; +import org.apache.commons.lang3.StringUtils; +import org.apache.commons.lang3.time.DateFormatUtils; +import org.apache.commons.lang3.time.DateUtils; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; +import org.springframework.util.CollectionUtils; + +import java.math.BigDecimal; +import java.text.SimpleDateFormat; +import java.util.Date; +import java.util.HashMap; +import java.util.List; +import java.util.Map; + +/** + * 代偿-资方邮储逾期回购-助贷-购置融资租赁资产 + */ +public class OverdueRepurchaseVoucherPSBC implements VoucherInfoService { + + private static final Logger logger = LoggerFactory.getLogger(OverdueRepurchaseVoucherPSBC.class); + + private static final String VOUCHER_CONFIG_NO_1 = "PZ2021081700000026";//代偿-资方邮储逾期回购-助贷-购置融资租赁资产凭证编号 + private static final String VOUCHER_CONFIG_NO_2 = "PZ2021081800000029";//代偿-资方邮储逾期回购-助贷-合同起租凭证编号 + private static final String CORPUS_CHANNEL_NO = "PSBC";//邮储银行编号 + + @Override + public void run() { + Transaction Sqlca =null; + try { + Sqlca = Transaction.createTransaction(CacheLoaderFactory.getDataSource()); + generateVoucher(Sqlca); + } catch (JBOException e) { + e.printStackTrace(); + } catch (Exception e) { + e.printStackTrace(); + }finally { + try { + if(Sqlca!=null){ + Sqlca.disConnect(); + Sqlca = null; + } + } catch (JBOException e) { + e.printStackTrace(); + try { + Sqlca.rollback(); + } catch (JBOException jboException) { + jboException.printStackTrace(); + } + } + } + } + + /** + * 生成所有凭证 + * @param Sqlca + * @throws Exception + */ + public void generateVoucher(Transaction Sqlca) throws Exception { + Sqlca.getConnection(); + JBOTransaction tx = Sqlca.getTransaction(); + //获取所有需要生成凭证的合同 + List> loanInfoList = findHasLoanContract(CORPUS_CHANNEL_NO); + if(CollectionUtils.isEmpty(loanInfoList)){ + logger.warn("OverdueRepurchaseVoucherPSBC20210818 获取所有需要生成凭证的合同 记录为空 -- 定时任务执行结束"); + return; + } + logger.info("OverdueRepurchaseVoucherPSBC20210818 获取所有需要生成凭证的合同 记录条数：" + loanInfoList.size()); + //遍历所有需要生成凭证的合同 + for(Map loanInfo : loanInfoList){ + //金额计算 + String contractId = loanInfo.get("contractId");//合同id + String actualPaymentBackAmount = loanInfo.get("buyback_money");//实际偿还总额 + String outstandingPrincipal = findOutstandingPrincipal(contractId, Sqlca);//未还本金 + String outstandingInterest = findOutstandingInterest(contractId, Sqlca);//未还利息 + String overdueInterest = findOverdueInterest(actualPaymentBackAmount, outstandingPrincipal);//未还罚息利息 + String customerNo = findCustomerNoByContractId(contractId, Sqlca); + logger.info("OverdueRepurchaseVoucherPSBC20210818 查找客户编号信息：customerNo=" + customerNo); + loanInfo.put("customerNo", customerNo); + for(String voucherConfigNo : Lists.newArrayList(VOUCHER_CONFIG_NO_1, VOUCHER_CONFIG_NO_2)){ + String voucherNo ="k" + FlowUtil.getVoucher_Number(tx); + logger.info("OverdueRepurchaseVoucherPSBC20210818 voucherNo=" + voucherNo); + loanInfo.put("voucherNo", voucherNo); + logger.info("OverdueRepurchaseVoucherPSBC20210818 开始收集参数：initFinalParam"); + //获取最终参数 + List> paramList = initFinalParam(loanInfo, voucherConfigNo, + actualPaymentBackAmount, outstandingPrincipal, outstandingInterest, overdueInterest); + logger.info("OverdueRepurchaseVoucherPSBC20210818 收集参数完毕：initFinalParam， paramList=" + JSONObject.toJSONString(paramList)); + //生成凭证 + logger.info("OverdueRepurchaseVoucherPSBC20210818 开始生成凭证：createVoucher， voucherNo=" + voucherNo); + createVoucher(paramList,tx); + logger.info("OverdueRepurchaseVoucherPSBC20210818 生成凭证结束：createVoucher， voucherNo=" + voucherNo); + } + //更新凭证信息状态 + logger.info("OverdueRepurchaseVoucherPSBC20210818 开始更新凭证信息状态：updateVoucherStatus， contractId=" + contractId); + updateVoucherStatus(loanInfo.get("overdue_back_id"), Sqlca); + //逾期信息添加 + addOverdueRepayPlan(loanInfo, Sqlca); + logger.info("OverdueRepurchaseVoucherPSBC20210818 更新凭证信息状态结束：updateVoucherStatus， overdue_back_id=" + loanInfo.get("overdue_back_id")); + logger.info("定时任务 ============="+CORPUS_CHANNEL_NO+":合同编号为"+loanInfo.get("contractNo")+"的放款凭证生成完毕============"); + } + } + + /** + * 未还本金 + * @return + */ + private String findOutstandingPrincipal(String contractId, Transaction Sqlca) throws Exception { + String sqlPrincipal = "SELECT SUM(CORPUS) from lc_rent_plan WHERE CONTRACT_ID='"+contractId+"'";//总本金 + String sqlRepaymentPrincipal = "SELECT SUM(CORPUS) from lc_rent_income WHERE CONTRACT_ID='"+contractId+"'";//已还本金 + String amountPrincipal = Sqlca.getString(sqlPrincipal); + String amountRepaymentPrincipal = Sqlca.getString(sqlRepaymentPrincipal); + if(StringUtils.isEmpty(amountPrincipal) || StringUtils.isEmpty(amountRepaymentPrincipal)){ + logger.warn("contractId="+ contractId + "生成凭证，查询本金信息失败。"); + throw new Exception("contractId="+ contractId + "生成凭证，查询本金信息失败。"); + } + BigDecimal amount = new BigDecimal(amountPrincipal).subtract(new BigDecimal(amountRepaymentPrincipal)); + return amount.toString(); + } + + /** + * 逾期罚息利息 + * @param actualPaymentBackAmount 回购金额 + * @param outstandingPrincipal 未还本金 + * @return + * @throws Exception + */ + private String findOverdueInterest(String actualPaymentBackAmount, String outstandingPrincipal) throws Exception { + if(StringUtils.isEmpty(actualPaymentBackAmount) || StringUtils.isEmpty(outstandingPrincipal)){ + logger.warn("生成凭证，查询逾期罚息利息信息失败。"); + throw new Exception("生成凭证，查询逾期罚息利息信息失败。"); + } + BigDecimal amount = new BigDecimal(actualPaymentBackAmount).subtract(new BigDecimal(outstandingPrincipal)); + return amount.toString(); + } + + /** + * 未到期利息总额 + * @return + */ + private String findOutstandingInterest(String contractId, Transaction Sqlca) throws Exception { + String sqlInterest = "SELECT SUM(INTEREST) from lc_rent_plan WHERE CONTRACT_ID='"+contractId+"'";//总利息 + String sqlRepaymentInterest = "SELECT SUM(INTEREST) from lc_rent_income WHERE CONTRACT_ID='"+contractId+"'";//已还利息 + String amountInterest = Sqlca.getString(sqlInterest); + String amountRepaymentInterest = Sqlca.getString(sqlRepaymentInterest); + if(StringUtils.isEmpty(amountInterest) || StringUtils.isEmpty(amountRepaymentInterest)){ + logger.warn("contractId="+ contractId + "生成凭证，查询未到期利息总额信息失败。"); + throw new Exception("contractId="+ contractId + "生成凭证，查询未到期利息总额信息失败。"); + } + BigDecimal amount = new BigDecimal(amountInterest).subtract(new BigDecimal(amountRepaymentInterest)); + return amount.toString(); + } + + /** + * 获取需要生成凭证的合同以及对应信息 + * @return + * @throws Exception + */ + private List> findHasLoanContract(String channelNo) throws Exception { + // : 2021/8/19 buyback_money 实际支付回购金额 + String sql = "select frc.id as overdue_back_id, fr.customer_name as customerName,frc.inputtime as createTime, " + + " fr.CONTRACT_ID as contractId,fr.CONTRACT_NO as contractNo,fr.ID as fc_request_id,frc.buyback_money " + + "from fc_buyback_info frc " + + "left join fc_yc_file_repay_result ffr on frc.fc_request_id = ffr.FC_REQUEST_ID " + + "left join fc_request fr on frc.fc_request_id = fr.ID " + + "where frc.voucher_status='0' and fr.DEL_FLAG='0' and fr.CHANNEL_NO='"+channelNo+"' and ffr.REPAYMENT_FLAG='3' and ffr.REPAYMENT_SOURCE='1' and ffr.ID is not null "; + return DataOperatorUtil.getDataBySql(sql); + } + + /** + * 根据合同id查询客户编号 + * @param contractId + * @param Sqlca + * @return + * @throws Exception + */ + private String findCustomerNoByContractId(String contractId,Transaction Sqlca) throws Exception { + String sql = "select ci.customer_num from customer_info ci left join lb_union_lessee lul on lul.CUSTOMER_ID=ci.customerid and lul.IS_MAIN='Y' where lul.CONTRACT_ID='"+contractId+"'"; + String customerNo = Sqlca.getString(sql); + return customerNo; + } + + /** + * 获取最终的参数 + * @param loanInfo + * @param voucherConfigNo + * @param actualPaymentBackAmount 实际偿还总额 + * @param outstandingPrincipal 未还本金 + * @param outstandingInterest 未还利息 + * @param overdueInterest 未还罚息利息 + * @return + * @throws Exception + */ + private List> initFinalParam(Map loanInfo, String voucherConfigNo,String actualPaymentBackAmount, + String outstandingPrincipal, String outstandingInterest, String overdueInterest) throws Exception { + List> paramList = findParamOfVoucher(voucherConfigNo); + for(Map param : paramList){ + //将公共参数放到凭证配置参数里 + param.putAll(initCommonParam(loanInfo)); + //将差别参数放进去 + addRespectiveParam(param, voucherConfigNo, actualPaymentBackAmount, outstandingPrincipal, outstandingInterest, overdueInterest); + //转译的凭证信息 + param.putAll(initConvertParam(param)); + } + return paramList; + } + //助贷-购置融资租赁资产 + private static final String FINANCIAL_LEASING_ASSETS = "14610201";//借--【融资租赁资产】-【承租人未还本金】-【客商+合同号码】 + private static final String LONG_TERM_LEASEBACK_OVERDUE_INTEREST = "1531020102";//借--【长期应收-回租-汽车-利息】-【逾期利息+罚息等】-【客商+合同号码】 + private static final String BANK_DEPOSIT = "100219";//贷--【银行存款-邮储银行】-【代偿总额】-【现金流，集团外客商，用11213】 + //助贷-合同起租 + private static final String LONG_TERM_RECEIVABLES_LEASEBACK_PRINCIPAL = "1531020101";//借--【长期应收-回租-汽车-本金】-【承租人未还本金】-【客商+合同号码】 +// private static final String LONG_TERM_LEASEBACK_INTEREST = "1531020102";//借--【长期应收-回租-汽车-利息】-【未到期利息总额】-【客商+合同号码】 +// private static final String FINANCIAL_LEASING_ASSETS = "14610201";//贷--【融资租赁资产】-【承租人未还本金】-【客商+合同号码】 + private static final String UNREALIZED_INCOME_LEASEBACK_AUTOMOBILE = "15320201";//贷--【未实现融资收益-回租-汽车】-【未到期利息总额】-【客商+合同号码】 + + /** + * 每条凭证各自差异数据放到参数List + * @param param + * @param actualPaymentBackAmount 实际偿还总额 + * @param outstandingPrincipal 未还本金 + * @param outstandingInterest 未还利息 + * @param overdueInterest 未还罚息利息 + * @throws Exception + */ + public void addRespectiveParam(Map param, String voucherConfigNo, String actualPaymentBackAmount, + String outstandingPrincipal, String outstandingInterest, String overdueInterest) throws Exception { + String money = ""; + String subjectsCode = param.get("subjectsCode"); + //银行存款-邮储银行【100219】 + if(BANK_DEPOSIT.equals(subjectsCode)){ + money=actualPaymentBackAmount;//实际回购支付总额 + param.put("contractNo",""); + param.put("customerNo",""); + param.put("customerName",""); + //应财务要求邮储放款填固定值 + param.put("cashFlow","11213"); + } + //【长期应收-回租-汽车-利息】-【逾期利息+罚息等】-【客商+合同号码】 + //【长期应收-回租-汽车-利息】-【未到期利息总额】-【客商+合同号码】 + else if(LONG_TERM_LEASEBACK_OVERDUE_INTEREST.equals(subjectsCode)){ + money=overdueInterest;//未还罚息利息 + if(VOUCHER_CONFIG_NO_2.equals(voucherConfigNo)){//合同起租，取未还利息 + money=outstandingInterest;//未还利息 + } + } + //【未实现融资收益-回租-汽车】-【未到期利息总额】-【客商+合同号码】 + else if(UNREALIZED_INCOME_LEASEBACK_AUTOMOBILE.equals(subjectsCode)){ + money=outstandingInterest;//未还利息 + } + //【融资租赁资产】-【承租人未还本金】-【客商+合同号码】 + //【长期应收-回租-汽车-本金】-【承租人未还本金】-【客商+合同号码】 + else if(FINANCIAL_LEASING_ASSETS.equals(subjectsCode)||LONG_TERM_RECEIVABLES_LEASEBACK_PRINCIPAL.equals(subjectsCode)){ + money=outstandingPrincipal;// + }else { + logger.warn("生成凭证，当前凭证类型匹配失败。subjectsCode=" + subjectsCode); + throw new Exception("生成凭证，当前凭证类型匹配失败。subjectsCode=" + subjectsCode); + } + if(StringUtils.isEmpty(money)){ + logger.warn("生成凭证，查询凭证相关金额信息失败。"); + throw new Exception("生成凭证，查询凭证相关金额信息失败。"); + } + //debit:借；credit:贷 + if("1".equals(param.get("entrydc"))) { + param.put("debitMoney",money); + param.put("creditMoney","0.00"); + }else{ + param.put("debitMoney","0.00"); + param.put("creditMoney",money); + } + } + + + /** + * 根据凭证配置编号获取对应的每条凭证参数 + * @return + * @throws Exception + */ + public List> findParamOfVoucher(String voucherConfigNo) throws Exception { + String sql = "select lvl.SORT_NUMBER as sortNumber,lvl.LOAN_SUBJECT as loanSubject, " + + " CASE WHEN lvl.loan_direction = '1' THEN '1' ELSE '-1' END as entrydc, " + + " lvl.VALUE_ABSTRACT as valueAbstract,lsc.SUBJECTS_CODE as subjectsCode, " + + " lsc.SUBJECTS_NAME as subjectsName,lvc.MODULAR_NUMBER as modularName " + + " from lv_voucher_loan lvl " + + " left join LV_STACTS_CONFIG lsc on lvl.LOAN_SUBJECT=lsc.id " + + " left join lv_voucher_config lvc on lvl.VOUCHER_ID=lvc.id " + + " where lvc.VOUCHER_NO='"+voucherConfigNo+"'"; + List> paramList = DataOperatorUtil.getDataBySql(sql); + if(paramList.size()==0){ + logger.warn(voucherConfigNo + "通过凭证配置编号未找到对应配置信息"); + throw new Exception(voucherConfigNo + "通过凭证配置编号未找到对应配置信息"); + } + return paramList; + } + + /** + * 获取生成凭证所需的公共参数(每个合同为单位) + * 在传来值的基础上增添 + * @param loanInfo + * @return + * @throws Exception + */ + private Map initCommonParam(Map loanInfo) throws Exception { + + //固定值部分 + String evidenceMessage = "凭证输出";//查看凭证表，发现只有这一个值，目前先设置为固定值 + String easFlag = "0";//导入财务系统状态 默认0 (同上，只有这一个值) + String userId = "administrator";//操作人 + String userName = NameManager.getUserName(userId); + loanInfo.put("evidenceMessage",evidenceMessage); + loanInfo.put("easFlag",easFlag); + loanInfo.put("userId",userId); + loanInfo.put("userName",userName); + + //日期：【 2021/08/11 17:48:17】 + String createTime = loanInfo.get("createTime").substring(0,10); + String periodYear = createTime.substring(0,4); + String periodMonth = createTime.substring(5,7); + loanInfo.put("periodYear",periodYear); + loanInfo.put("periodMonth",periodMonth); + loanInfo.put("accountingDate",createTime); + loanInfo.put("generateDate", DateUtil.getSystemDateDetailTime()); + + //主体信息 + String contractId = loanInfo.get("contractId"); + loanInfo.putAll(this.getSubjectInfoByContractId(contractId)); + return loanInfo; + } + + /** + * 创建凭证 + * @param paramList + * @param tx + * @throws Exception + */ + private void createVoucher(List> paramList, JBOTransaction tx) throws Exception { + BizObjectManager bomV8 = JBOFactory.getBizObjectManager(VOUCHER_V8.CLASS_NAME,tx); + for(Map param :paramList){ + logger.info("创建凭证 createVoucher VoucherNo=" + param.get("f3") + "；configNo=" + param.get("f2")); + BizObject boV8 = bomV8.newObject(); + boV8.setAttributesValue(param); + bomV8.saveObject(boV8); + } + } + + /** + * 根据contractId获取主体信息 + * @param contractId + * @return + * @throws JBOException + */ + public Map getSubjectInfoByContractId(String contractId) throws JBOException { + Map subject = new HashMap<>(); + BizObjectManager bomLCI = JBOFactory.getBizObjectManager(LB_CONTRACT_INFO.CLASS_NAME); + BizObject boLCI = bomLCI.createQuery("id=:id").setParameter("id",contractId).getSingleResult(false); + String subjectId = boLCI.getAttribute("SUBJECTID").toString(); + String subjectName = boLCI.getAttribute("SUBJECTNAME").toString(); + BizObjectManager bomOI = JBOFactory.getBizObjectManager(OWN_INFO.CLASS_NAME); + BizObject boOI = bomOI.createQuery("OWN_NAME=:subjectName").setParameter("subjectName",subjectName).getSingleResult(false); + String ownNumber = boOI.getAttribute("OWN_NUMBER").toString(); + subject.put("subjectId",subjectId); + subject.put("subjectName",subjectName); + subject.put("ownNumber",ownNumber); + return subject; + } + + /** + * 将最终获取的参数转换为凭证表voucher_v8对应的字段 + * 注意：新增时注意param中字段不可修改 + * @param param + * @return + */ + private Map initConvertParam(Map param){ + Map finalParam = new HashMap<>(); + finalParam.put("evidence_message",param.get("evidenceMessage"));//固定值：凭证输出 + finalParam.put("periodyear",param.get("periodYear")); //年 + finalParam.put("f1",param.get("accountingDate"));//会计日期 + finalParam.put("f2",param.get("subjectsCode"));//科目编码 + finalParam.put("f3",param.get("voucherNo"));//凭证编号 + finalParam.put("f5",param.get("valueAbstract"));//摘要 + finalParam.put("f6",param.get("loanSubject"));//科目表id + finalParam.put("f7",param.get("debitMoney"));//借方金额 + finalParam.put("f8",param.get("creditMoney"));//贷方金额 + finalParam.put("f12",param.get("userName"));//操作人 + finalParam.put("f15",param.get("accountingDate"));//日期(与会计日期相同) + finalParam.put("f47",param.get("contractNo"));//业务合同编号 + finalParam.put("f48",param.get("ownNumber"));//本方信息No + finalParam.put("f49",param.get("subjectId"));//所属公司ID（注意：实际此字段存的是code_library表中codeno='ManySubject' 的 itemno 字段） + finalParam.put("f50",param.get("subjectName"));//所属公司名称 + finalParam.put("f51",param.get("periodYear"));//会计期间-年（与上面 ‘年’ 相同） + finalParam.put("f52",param.get("periodMonth"));//会计期间-月 + finalParam.put("f59",param.get("sortNumber"));//凭证配置中排序号 + finalParam.put("f60",param.get("contractNo"));//业务合同号，与f47相同（尚不明为何重复） + finalParam.put("f61",param.get("customerName"));//客户名称 + finalParam.put("f62",param.get("loanSubject"));//科目表id，与f6相同（尚不明为何重复） + finalParam.put("f65",param.get("customerNo"));//客商编号（取值customer_info表中customer_num字段） + finalParam.put("f74",param.get("cashFlow"));// 现金流项目 + finalParam.put("v8_status","已完整");//凭证状态 ： 已完整；未完整 + finalParam.put("generate_date",param.get("generateDate"));//创建时间 + finalParam.put("v8_flag",param.get("easFlag"));//导入财务系统状态 默认0（尚不知有何逻辑，目前整个表中全部为0） + finalParam.put("module_name",param.get("modularName"));//凭证模型名称 + finalParam.put("entrydc",param.get("entrydc"));//借贷：1，借；-1，贷 + finalParam.put("inputuserid",param.get("userId"));//操作人id + return finalParam; + } + private void updateVoucherStatus(String id ,Transaction Sqlca) throws Exception { + String sql = "update fc_buyback_info set voucher_status = '1' where id = '"+id+"'"; + SqlObject sqlObject = new SqlObject(sql); + Sqlca.executeSQL(sqlObject); + } + + //fc_yc_overdue_repay_plan + + /** + * 逾期回购时，新增逾期回购中逾期的进行备注 + * @param loanInfo + * @param Sqlca + * @throws Exception + */ + private void addOverdueRepayPlan(Map loanInfo ,Transaction Sqlca) throws Exception { + String sqlQuery = "SELECT plan_list from report_rent_plan WHERE contract_number='"+loanInfo.get("contractNo") +"' and batch_status='未完成' and over_days > 0"; + List> paramList = DataOperatorUtil.getDataBySql(sqlQuery); + if(paramList.size()==0 || paramList.size()>2 ){ + logger.warn(loanInfo.get("contractNo") + "逾期回购生成凭证之后，查询是否有逾期数据，或逾期数据大于2。"); + return; + } + String sqlQuery2 = "SELECT * from fc_buyback_info WHERE fc_request_id='"+loanInfo.get("fc_request_id") +"'"; + List> paramList2 = DataOperatorUtil.getDataBySql(sqlQuery2); + if(paramList2.size()==0 || paramList2.size()>1){ + logger.warn(loanInfo.get("contractNo") + "逾期回购生成凭证之后，查询是否有逾期数据2，或逾期数据大于1。"); + return; + } + Map overduePlan = paramList2.get(0); + String firstOverduePenalty = overduePlan.get("first_overdue_penalty"); + String secondOverduePenalty = overduePlan.get("second_overdue_penalty"); + if(paramList.size()==1){ + paramList.get(0).put("overduePenalty", firstOverduePenalty); + }else if(paramList.size() == 2){ + int firstTerm = Integer.parseInt(paramList.get(0).get("plan_list")); + int secondTerm = Integer.parseInt(paramList.get(1).get("plan_list")); + if(firstTerm < secondTerm){ + paramList.get(0).put("overduePenalty", firstOverduePenalty); + paramList.get(1).put("overduePenalty", secondOverduePenalty); + }else { + paramList.get(0).put("overduePenalty", secondOverduePenalty); + paramList.get(1).put("overduePenalty", firstOverduePenalty); + } + } + for(Map planList : paramList){ + String term = planList.get("plan_list"); + String overduePenalty = planList.get("overduePenalty"); + String sqlRentPlan = "SELECT ID from lc_rent_plan WHERE CONTRACT_ID='"+loanInfo.get("contractId") + +"' and PLAN_LIST='"+term+"'";//租金计划id + String rentPlanId = Sqlca.getString(sqlRentPlan); + String sql = "insert into fc_yc_overdue_repay_plan (" + + "id," + + "fc_request_id," + + "contract_id," + + "contract_no," + + "lend_term," + + "rent_plan_id," + + "yc_overdue_amount," + + "yc_overdue_repay_amount," + + "create_time," + + "update_time" + + ") values" + + " (" + + "'"+ UUIDUtil.getUUID() +"',"+ + "'"+ loanInfo.get("fc_request_id") +"',"+ + "'"+ loanInfo.get("contractId") +"',"+ + "'"+ loanInfo.get("contractNo") +"',"+ + ""+ term +","+ + "'"+ rentPlanId +"',"+ + "'"+ overduePenalty +"',"+ + "'0',"+ + "'"+ DateUtil.getSystemTimeByFormat("yyyyMMddHHmmss") +"',"+ + "'"+ DateUtil.getSystemTimeByFormat("yyyyMMddHHmmss") +"'"+ + ")" ; + SqlObject sqlObject = new SqlObject(sql); + Sqlca.executeSQL(sqlObject); + } + } + +} diff --git a/src_tenwa/com/tenwa/lease/app/quartzmession/CorpusSourceOverdueRepurchaseCreateVoucherJob.java b/src_tenwa/com/tenwa/lease/app/quartzmession/CorpusSourceOverdueRepurchaseCreateVoucherJob.java new file mode 100644 index 000000000..aa265bedd --- /dev/null +++ b/src_tenwa/com/tenwa/lease/app/quartzmession/CorpusSourceOverdueRepurchaseCreateVoucherJob.java @@ -0,0 +1,31 @@ +package com.tenwa.lease.app.quartzmession; +import com.amarsoft.are.util.StringFunction; +import com.base.util.QuartzUtil; +import com.tenwa.voucher.service.VoucherInfoService; +import com.tenwa.voucher.serviceImp.FundIncomeVoucherPSBC; +import com.tenwa.voucher.serviceImp.OverdueRepurchaseVoucherPSBC; +import org.quartz.Job; +import org.quartz.JobExecutionContext; +import org.quartz.JobExecutionException; + +/** + * 逾期回购生成凭证-定时任务 + * @author zl + */ +public class CorpusSourceOverdueRepurchaseCreateVoucherJob implements Job { + + @Override + public void execute(JobExecutionContext arg0) throws JobExecutionException { + String startime = StringFunction.getTodayNow(); + Object userId = arg0.getTrigger().getJobDataMap().get("CurUserId"); + String curUserId = userId == null? "system" : userId.toString(); + try{ + VoucherInfoService voucher = new OverdueRepurchaseVoucherPSBC(); + voucher.run(); + QuartzUtil.insertLog(startime,"com.tenwa.lease.app.quartzmession.CorpusSourceOverdueRepurchaseCreateVoucherJob", "success", "成功", curUserId); + } catch (Exception e) { + QuartzUtil.insertLog(startime,"com.tenwa.lease.app.quartzmession.CorpusSourceOverdueRepurchaseCreateVoucherJob", "error", "失败", curUserId); + } + } + +}