|
|
|
@ -20,6 +20,8 @@ import com.yxt.anrui.buscenter.api.bussalesorderreturnvehapply.BusSalesOrderRetu |
|
|
|
import com.yxt.anrui.buscenter.api.bussalesordervehicle.BusSalesOrderVehicle; |
|
|
|
import com.yxt.anrui.buscenter.api.bussalesordervehicle.BusSalesOrderVehicleFeign; |
|
|
|
import com.yxt.anrui.fin.api.finmanufacturerbank.FinManufacturerBank; |
|
|
|
import com.yxt.anrui.fin.api.finpaymentrecord.FinPaymentrecordDto; |
|
|
|
import com.yxt.anrui.fin.api.finpaymentrecord.FinPaymentrecordFeign; |
|
|
|
import com.yxt.anrui.fin.api.finpaymentrecord.FinPaymentrecordSourceLCVo; |
|
|
|
import com.yxt.anrui.fin.api.kingdee.FinKingDeeFeign; |
|
|
|
import com.yxt.anrui.fin.api.kingdee.bdcustomer.BdCustomer; |
|
|
|
@ -46,6 +48,7 @@ import com.yxt.anrui.portal.api.sysuser.SysUserVo; |
|
|
|
import com.yxt.anrui.riskcenter.api.loanfile.LoanFile; |
|
|
|
import com.yxt.anrui.riskcenter.api.loanfile.LoanFileEnum; |
|
|
|
import com.yxt.anrui.riskcenter.api.loanoverduefin.UrlQuery; |
|
|
|
import com.yxt.anrui.riskcenter.api.loanrepaymentplandetails.LoanRepaymentPlanDetails; |
|
|
|
import com.yxt.anrui.riskcenter.api.loanrelievemortgage.LoanRelieveMortgageSaveDto; |
|
|
|
import com.yxt.anrui.riskcenter.api.loanrepurchaseapply.*; |
|
|
|
import com.yxt.anrui.riskcenter.api.loanrepurchaseapply.app.AppRepurchaseDetailsVo; |
|
|
|
@ -58,6 +61,7 @@ import com.yxt.anrui.riskcenter.api.loansettlebankcost.LoanSettleBankCostVo; |
|
|
|
import com.yxt.anrui.riskcenter.api.loansettlecompanycost.LoanSettleCompanyCostVo; |
|
|
|
import com.yxt.anrui.riskcenter.api.loansolutions.app.SolutionsDetailsVo; |
|
|
|
import com.yxt.anrui.riskcenter.biz.loanfile.LoanFileService; |
|
|
|
import com.yxt.anrui.riskcenter.biz.loanrepaymentplandetails.LoanRepaymentPlanDetailsService; |
|
|
|
import com.yxt.anrui.riskcenter.biz.loanrelievemortgage.LoanRelieveMortgageService; |
|
|
|
import com.yxt.anrui.riskcenter.biz.loanrepurchasecompanycost.LoanRepurchaseCompanyCostService; |
|
|
|
import com.yxt.anrui.riskcenter.biz.loanrepurchasecost.LoanRepurchaseCostService; |
|
|
|
@ -142,6 +146,10 @@ public class LoanRepurchaseApplyService extends MybatisBaseService<LoanRepurchas |
|
|
|
private BasePurchaseSystemFeign basePurchaseSystemFeign; |
|
|
|
@Autowired |
|
|
|
private DictCommonFeign dictCommonFeign; |
|
|
|
@Autowired |
|
|
|
private FinPaymentrecordFeign finPaymentrecordFeign; |
|
|
|
@Autowired |
|
|
|
private LoanRepaymentPlanDetailsService loanRepaymentPlanDetailsService; |
|
|
|
|
|
|
|
public PagerVo<LoanRepurchaseApplyVo> listPage(PagerQuery<LoanRepurchaseApplyQuery> pq) { |
|
|
|
IPage<LoanRepurchaseApply> page = PagerUtil.queryToPage(pq); |
|
|
|
@ -768,17 +776,41 @@ public class LoanRepurchaseApplyService extends MybatisBaseService<LoanRepurchas |
|
|
|
loanRelieveMortgageSaveDto.setBankName(repurchaseApply.getBankName()); |
|
|
|
loanRelieveMortgageSaveDto.setBusSid(repurchaseApply.getSid()); |
|
|
|
loanRelieveMortgageService.saveRelieveMortgage(loanRelieveMortgageSaveDto); |
|
|
|
try { |
|
|
|
ThreadFactory namedThreadFactory = new ThreadFactoryBuilder() |
|
|
|
.setNameFormat("demo-pool-%d").build(); |
|
|
|
ExecutorService pool = new ThreadPoolExecutor(2, 100, |
|
|
|
0L, TimeUnit.MILLISECONDS, |
|
|
|
new LinkedBlockingQueue<Runnable>(1024), namedThreadFactory, new ThreadPoolExecutor.AbortPolicy()); |
|
|
|
Future future1 = pool.submit(() -> { |
|
|
|
pushRiskToFin(businessSid); |
|
|
|
}); |
|
|
|
} catch (Exception e) { |
|
|
|
e.printStackTrace(); |
|
|
|
LoanRepurchaseCost loanRepurchaseCost = loanRepurchaseCostService.selectByMainSid(businessSid); |
|
|
|
if(loanRepurchaseCost != null){ |
|
|
|
BigDecimal bankSettlePrice = loanRepurchaseCost.getBankSettlePrice();//资方结清金额
|
|
|
|
if(bankSettlePrice != null && bankSettlePrice.compareTo(BigDecimal.ZERO)>0){ |
|
|
|
FinPaymentrecordDto finPaymentrecordDto = new FinPaymentrecordDto(); |
|
|
|
finPaymentrecordDto.setApplySid(loanRepurchaseApply.getSid()); |
|
|
|
finPaymentrecordDto.setPayCompanySid(""); |
|
|
|
finPaymentrecordDto.setPayType(1); |
|
|
|
finPaymentrecordDto.setCreateOrgSid(loanRepurchaseApply.getUseOrgSid()); |
|
|
|
finPaymentrecordDto.setUseOrgSid(loanRepurchaseApply.getUseOrgSid()); |
|
|
|
finPaymentrecordDto.setCostTypeKey("008"); |
|
|
|
finPaymentrecordDto.setCostTypeValue("资方结清款"); |
|
|
|
finPaymentrecordDto.setCostTitleKey("014"); |
|
|
|
finPaymentrecordDto.setCostTitleValue("资方结清款"); |
|
|
|
finPaymentrecordDto.setReceiveBank(""); |
|
|
|
finPaymentrecordDto.setReceiveBankAccount(loanRepurchaseCost.getBankAccount()); |
|
|
|
finPaymentrecordDto.setReceiveCompany(loanRepurchaseCost.getAccountName()); |
|
|
|
if(loanRepurchaseCost.getBankSettlePrice() != null){ |
|
|
|
finPaymentrecordDto.setCost(loanRepurchaseCost.getBankSettlePrice().toString()); |
|
|
|
finPaymentrecordDto.setAccountsReceive(loanRepurchaseCost.getBankSettlePrice().toString()); |
|
|
|
} |
|
|
|
finPaymentrecordDto.setBusSid(loanRepurchaseApply.getBillNo()); |
|
|
|
finPaymentrecordDto.setPayRemark(loanRepurchaseApply.getPayRemarks()); |
|
|
|
finPaymentrecordDto.setPayCode(""); |
|
|
|
finPaymentrecordDto.setCreateBySid(loanRepurchaseApply.getCreateBySid()); |
|
|
|
finPaymentrecordDto.setUpdateBySid(loanRepurchaseApply.getCreateBySid()); |
|
|
|
finPaymentrecordDto.setRemarks(loanRepurchaseApply.getRemarks()); |
|
|
|
finPaymentrecordDto.setPurchaseSystemSid(""); |
|
|
|
finPaymentrecordDto.setPurchaseSystemName(""); |
|
|
|
finPaymentrecordDto.setBusRemarks(loanRepurchaseApply.getPayRemarks()); |
|
|
|
finPaymentrecordDto.setFinDataType(1); |
|
|
|
String sid = finPaymentrecordFeign.save(finPaymentrecordDto).getData(); |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
} |
|
|
|
} else { |
|
|
|
//极光推送
|
|
|
|
@ -804,9 +836,48 @@ public class LoanRepurchaseApplyService extends MybatisBaseService<LoanRepurchas |
|
|
|
|
|
|
|
public void pushRiskToFin(String businessSid){ |
|
|
|
LoanRepurchaseApply loanRepurchaseApply = fetchBySid(businessSid); |
|
|
|
LoanRepurchaseCost loanRepurchaseCost = loanRepurchaseCostService.selectByMainSid(businessSid); |
|
|
|
//查询月还明细表，遍历
|
|
|
|
List<LoanRepaymentPlanDetails> list = loanRepaymentPlanDetailsService.selectByBusVinSid2(loanRepurchaseApply.getBusVinSid()); |
|
|
|
list.removeAll(Collections.singleton(null)); |
|
|
|
if(!list.isEmpty()){ |
|
|
|
BigDecimal bankSettlePrice = loanRepurchaseCost.getBankSettlePrice(); |
|
|
|
if(bankSettlePrice != null && bankSettlePrice.compareTo(BigDecimal.ZERO)>0){ |
|
|
|
for (int jj = 0; jj < list.size(); jj++) { |
|
|
|
LoanRepaymentPlanDetails loanRepaymentPlanDetails = list.get(jj); |
|
|
|
String moneysl = loanRepaymentPlanDetails.getMoneysl(); |
|
|
|
if(StringUtils.isNotBlank(moneysl) && bankSettlePrice.compareTo(BigDecimal.ZERO)>0){ |
|
|
|
if(bankSettlePrice.compareTo(new BigDecimal(moneysl))>0){ |
|
|
|
bankSettlePrice = bankSettlePrice.subtract(new BigDecimal(moneysl)); |
|
|
|
BigDecimal paymentMoney = loanRepaymentPlanDetails.getPaymentMoney(); |
|
|
|
if(paymentMoney != null){ |
|
|
|
paymentMoney = paymentMoney.add(new BigDecimal(moneysl)); |
|
|
|
}else{ |
|
|
|
paymentMoney = new BigDecimal(moneysl); |
|
|
|
} |
|
|
|
loanRepaymentPlanDetails.setPaymentMoney(paymentMoney); |
|
|
|
loanRepaymentPlanDetailsService.updateById(loanRepaymentPlanDetails); |
|
|
|
}else{ |
|
|
|
bankSettlePrice = BigDecimal.ZERO; |
|
|
|
BigDecimal paymentMoney = loanRepaymentPlanDetails.getPaymentMoney(); |
|
|
|
if(paymentMoney != null){ |
|
|
|
paymentMoney = paymentMoney.add(bankSettlePrice); |
|
|
|
}else{ |
|
|
|
paymentMoney = bankSettlePrice; |
|
|
|
} |
|
|
|
loanRepaymentPlanDetails.setPaymentMoney(paymentMoney); |
|
|
|
loanRepaymentPlanDetailsService.updateById(loanRepaymentPlanDetails); |
|
|
|
} |
|
|
|
}else{ |
|
|
|
break; |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
//推送凭证
|
|
|
|
if(loanRepurchaseApply != null){ |
|
|
|
List<Voucher.VoucherResultDetailDto> voucherResultDetailDtos = new ArrayList<>(); |
|
|
|
LoanRepurchaseCost loanRepurchaseCost = loanRepurchaseCostService.selectByMainSid(businessSid); |
|
|
|
DictCommonVo dictCommonVo = dictCommonFeign.selectBykey(loanRepurchaseApply.getBankName(), "investorsCode").getData(); |
|
|
|
Voucher voucher = new Voucher(); |
|
|
|
SysOrganizationVo organizationVo = sysOrganizationFeign.fetchBySid(loanRepurchaseApply.getUseOrgSid()).getData(); |
|
|
|
|
yunuo970428
dimengzhe