|
|
@ -2163,122 +2163,120 @@ public class BusHandoverService extends MybatisBaseService<BusHandoverMapper, Bu |
|
|
|
} catch (Exception e) { |
|
|
|
e.printStackTrace(); |
|
|
|
} |
|
|
|
} |
|
|
|
//------------------推送抵押办理------------------------
|
|
|
|
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()); |
|
|
|
BusHandover mortgageHandover = busHandover; |
|
|
|
Future future1 = pool.submit(() -> { |
|
|
|
String orderSid = mortgageHandover.getOrderSid(); |
|
|
|
BusSalesOrder salesOrder = busSalesOrderService.fetchBySid(orderSid); |
|
|
|
String createBySid = ""; |
|
|
|
String staff = ""; |
|
|
|
String staffSid = ""; |
|
|
|
String bankName = ""; |
|
|
|
String bankSid = ""; |
|
|
|
String orgPath = ""; |
|
|
|
String dept = ""; |
|
|
|
String deptSid = ""; |
|
|
|
if (null != salesOrder) { |
|
|
|
if (StringUtils.isNotBlank(salesOrder.getPayTypeKey())) { |
|
|
|
if ("2".equals(salesOrder.getPayTypeKey())) { |
|
|
|
if (StringUtils.isNotBlank(salesOrder.getCreateBySid())) { |
|
|
|
createBySid = salesOrder.getCreateBySid(); |
|
|
|
} |
|
|
|
if (StringUtils.isNotBlank(salesOrder.getOrgSidPath())) { |
|
|
|
orgPath = salesOrder.getOrgSidPath(); |
|
|
|
} |
|
|
|
if (StringUtils.isNotBlank(salesOrder.getStaffSid())) { |
|
|
|
staffSid = salesOrder.getStaffSid(); |
|
|
|
} |
|
|
|
if (StringUtils.isNotBlank(salesOrder.getStaffName())) { |
|
|
|
staff = salesOrder.getStaffName(); |
|
|
|
} |
|
|
|
if (StringUtils.isNotBlank(salesOrder.getOrgName())) { |
|
|
|
dept = salesOrder.getOrgName(); |
|
|
|
} |
|
|
|
if (StringUtils.isNotBlank(salesOrder.getOrgSid())) { |
|
|
|
deptSid = salesOrder.getOrgSid(); |
|
|
|
} |
|
|
|
LoanSolutions solutions = loanSolutionsFeign.getOneByOrderSid(orderSid).getData(); |
|
|
|
if (null != solutions) { |
|
|
|
if (StringUtils.isNotBlank(solutions.getPolicySid())) { |
|
|
|
LoanFinPolicyVo policyVo = loanFinPolicyFeign.details(solutions.getPolicySid()).getData(); |
|
|
|
if (null != policyVo) { |
|
|
|
if (StringUtils.isNotBlank(policyVo.getBankSid())) { |
|
|
|
bankSid = policyVo.getBankSid(); |
|
|
|
} |
|
|
|
if (StringUtils.isNotBlank(policyVo.getBankShortName())) { |
|
|
|
bankName = policyVo.getBankShortName(); |
|
|
|
//------------------推送抵押办理------------------------
|
|
|
|
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()); |
|
|
|
BusHandover mortgageHandover = busHandover; |
|
|
|
Future future1 = pool.submit(() -> { |
|
|
|
String orderSid = mortgageHandover.getOrderSid(); |
|
|
|
BusSalesOrder salesOrder = busSalesOrderService.fetchBySid(orderSid); |
|
|
|
String createBySid = ""; |
|
|
|
String staff = ""; |
|
|
|
String staffSid = ""; |
|
|
|
String bankName = ""; |
|
|
|
String bankSid = ""; |
|
|
|
String orgPath = ""; |
|
|
|
String dept = ""; |
|
|
|
String deptSid = ""; |
|
|
|
if (null != salesOrder) { |
|
|
|
if (StringUtils.isNotBlank(salesOrder.getPayTypeKey())) { |
|
|
|
if ("2".equals(salesOrder.getPayTypeKey())) { |
|
|
|
if (StringUtils.isNotBlank(salesOrder.getCreateBySid())) { |
|
|
|
createBySid = salesOrder.getCreateBySid(); |
|
|
|
} |
|
|
|
if (StringUtils.isNotBlank(salesOrder.getOrgSidPath())) { |
|
|
|
orgPath = salesOrder.getOrgSidPath(); |
|
|
|
} |
|
|
|
if (StringUtils.isNotBlank(salesOrder.getStaffSid())) { |
|
|
|
staffSid = salesOrder.getStaffSid(); |
|
|
|
} |
|
|
|
if (StringUtils.isNotBlank(salesOrder.getStaffName())) { |
|
|
|
staff = salesOrder.getStaffName(); |
|
|
|
} |
|
|
|
if (StringUtils.isNotBlank(salesOrder.getOrgName())) { |
|
|
|
dept = salesOrder.getOrgName(); |
|
|
|
} |
|
|
|
if (StringUtils.isNotBlank(salesOrder.getOrgSid())) { |
|
|
|
deptSid = salesOrder.getOrgSid(); |
|
|
|
} |
|
|
|
LoanSolutions solutions = loanSolutionsFeign.getOneByOrderSid(orderSid).getData(); |
|
|
|
if (null != solutions) { |
|
|
|
if (StringUtils.isNotBlank(solutions.getPolicySid())) { |
|
|
|
LoanFinPolicyVo policyVo = loanFinPolicyFeign.details(solutions.getPolicySid()).getData(); |
|
|
|
if (null != policyVo) { |
|
|
|
if (StringUtils.isNotBlank(policyVo.getBankSid())) { |
|
|
|
bankSid = policyVo.getBankSid(); |
|
|
|
} |
|
|
|
if (StringUtils.isNotBlank(policyVo.getBankShortName())) { |
|
|
|
bankName = policyVo.getBankShortName(); |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
List<BusHandoverItems> vinItems = busHandoverItemsService.getItemsListByMainSid(mortgageHandover.getSid()).getData(); |
|
|
|
vinItems.removeAll(Collections.singleton(null)); |
|
|
|
if (!vinItems.isEmpty()) { |
|
|
|
vinItems = vinItems.stream().filter(obj -> obj.getVehivelOrTrailer().equals("主车")).collect(Collectors.toList()); |
|
|
|
for (BusHandoverItems vinItem : vinItems) { |
|
|
|
LoanMortgageInformationTransactDto mortagageDto = new LoanMortgageInformationTransactDto(); |
|
|
|
mortagageDto.setCreateBySid(createBySid); |
|
|
|
mortagageDto.setOrgSidPath(orgPath); |
|
|
|
mortagageDto.setSalesOrderSid(orderSid); |
|
|
|
mortagageDto.setBankName(bankName); |
|
|
|
mortagageDto.setBankSid(bankSid); |
|
|
|
mortagageDto.setDept(dept); |
|
|
|
mortagageDto.setDeptSid(deptSid); |
|
|
|
mortagageDto.setStaffSid(staffSid); |
|
|
|
mortagageDto.setStaff(staff); |
|
|
|
if (StringUtils.isNotBlank(vinItem.getVinSid())) { |
|
|
|
mortagageDto.setVehSid(vinItem.getVinSid()); |
|
|
|
BusSalesOrderVehicle busSalesOrderVehicle = busSalesOrderVehicleService.selectOneByVehSidAndOrderSid(vinItem.getVinSid(), orderSid); |
|
|
|
if (null != busSalesOrderVehicle) { |
|
|
|
if (StringUtils.isNotBlank(busSalesOrderVehicle.getLinkNo())) { |
|
|
|
String linkNo = busSalesOrderVehicle.getLinkNo(); |
|
|
|
if (linkNo.length() > 8) { |
|
|
|
String substringLinkNo = linkNo.substring(linkNo.length() - 8); |
|
|
|
mortagageDto.setVinNo(substringLinkNo); |
|
|
|
} else { |
|
|
|
mortagageDto.setVinNo(linkNo); |
|
|
|
List<BusHandoverItems> vinItems = busHandoverItemsService.getItemsListByMainSid(mortgageHandover.getSid()).getData(); |
|
|
|
vinItems.removeAll(Collections.singleton(null)); |
|
|
|
if (!vinItems.isEmpty()) { |
|
|
|
vinItems = vinItems.stream().filter(obj -> obj.getVehivelOrTrailer().equals("主车")).collect(Collectors.toList()); |
|
|
|
for (BusHandoverItems vinItem : vinItems) { |
|
|
|
LoanMortgageInformationTransactDto mortagageDto = new LoanMortgageInformationTransactDto(); |
|
|
|
mortagageDto.setCreateBySid(createBySid); |
|
|
|
mortagageDto.setOrgSidPath(orgPath); |
|
|
|
mortagageDto.setSalesOrderSid(orderSid); |
|
|
|
mortagageDto.setBankName(bankName); |
|
|
|
mortagageDto.setBankSid(bankSid); |
|
|
|
mortagageDto.setDept(dept); |
|
|
|
mortagageDto.setDeptSid(deptSid); |
|
|
|
mortagageDto.setStaffSid(staffSid); |
|
|
|
mortagageDto.setStaff(staff); |
|
|
|
if (StringUtils.isNotBlank(vinItem.getVinSid())) { |
|
|
|
mortagageDto.setVehSid(vinItem.getVinSid()); |
|
|
|
BusSalesOrderVehicle busSalesOrderVehicle = busSalesOrderVehicleService.selectOneByVehSidAndOrderSid(vinItem.getVinSid(), orderSid); |
|
|
|
if (null != busSalesOrderVehicle) { |
|
|
|
if (StringUtils.isNotBlank(busSalesOrderVehicle.getLinkNo())) { |
|
|
|
String linkNo = busSalesOrderVehicle.getLinkNo(); |
|
|
|
if (linkNo.length() > 8) { |
|
|
|
String substringLinkNo = linkNo.substring(linkNo.length() - 8); |
|
|
|
mortagageDto.setVinNo(substringLinkNo); |
|
|
|
} else { |
|
|
|
mortagageDto.setVinNo(linkNo); |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
if (StringUtils.isNotBlank(busSalesOrderVehicle.getSid())) { |
|
|
|
mortagageDto.setBusVinSid(busSalesOrderVehicle.getSid()); |
|
|
|
} |
|
|
|
if (StringUtils.isNotBlank(busSalesOrderVehicle.getBorrowerSid())) { |
|
|
|
mortagageDto.setBorrowerSid(busSalesOrderVehicle.getBorrowerSid()); |
|
|
|
} |
|
|
|
if (StringUtils.isNotBlank(busSalesOrderVehicle.getBorrowName())) { |
|
|
|
mortagageDto.setBorrowerName(busSalesOrderVehicle.getBorrowName()); |
|
|
|
} |
|
|
|
if (StringUtils.isNotBlank(busSalesOrderVehicle.getLoanContractSid())) { |
|
|
|
mortagageDto.setLoanContractSid(busSalesOrderVehicle.getLoanContractSid()); |
|
|
|
BusSalesOrderLoancontract loancontract = busSalesOrderLoancontractService.fetchBySid(busSalesOrderVehicle.getLoanContractSid()); |
|
|
|
if (null != loancontract) { |
|
|
|
if (StringUtils.isNotBlank(loancontract.getLoanContractNo())) { |
|
|
|
mortagageDto.setLoanContractNo(loancontract.getLoanContractNo()); |
|
|
|
if (StringUtils.isNotBlank(busSalesOrderVehicle.getSid())) { |
|
|
|
mortagageDto.setBusVinSid(busSalesOrderVehicle.getSid()); |
|
|
|
} |
|
|
|
if (StringUtils.isNotBlank(busSalesOrderVehicle.getBorrowerSid())) { |
|
|
|
mortagageDto.setBorrowerSid(busSalesOrderVehicle.getBorrowerSid()); |
|
|
|
} |
|
|
|
if (StringUtils.isNotBlank(busSalesOrderVehicle.getBorrowName())) { |
|
|
|
mortagageDto.setBorrowerName(busSalesOrderVehicle.getBorrowName()); |
|
|
|
} |
|
|
|
if (StringUtils.isNotBlank(busSalesOrderVehicle.getLoanContractSid())) { |
|
|
|
mortagageDto.setLoanContractSid(busSalesOrderVehicle.getLoanContractSid()); |
|
|
|
BusSalesOrderLoancontract loancontract = busSalesOrderLoancontractService.fetchBySid(busSalesOrderVehicle.getLoanContractSid()); |
|
|
|
if (null != loancontract) { |
|
|
|
if (StringUtils.isNotBlank(loancontract.getLoanContractNo())) { |
|
|
|
mortagageDto.setLoanContractNo(loancontract.getLoanContractNo()); |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
} |
|
|
|
} |
|
|
|
loanMortgageInformationTransactFeign.saveMortgageInfo(mortagageDto); |
|
|
|
} |
|
|
|
loanMortgageInformationTransactFeign.saveMortgageInfo(mortagageDto); |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
}); |
|
|
|
} catch (Exception e) { |
|
|
|
e.printStackTrace(); |
|
|
|
}); |
|
|
|
} catch (Exception e) { |
|
|
|
e.printStackTrace(); |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
return rb.success().setData(resultBean.getData()); |
|
|
|
} else { |
|
|
|
return rb.setMsg("操作失败!提交的数据不一致"); |
|
|
|