|
|
|
@ -29,7 +29,10 @@ import cn.hutool.core.bean.BeanUtil; |
|
|
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; |
|
|
|
import com.baomidou.mybatisplus.core.metadata.IPage; |
|
|
|
import com.baomidou.mybatisplus.extension.api.R; |
|
|
|
import com.google.common.util.concurrent.ThreadFactoryBuilder; |
|
|
|
import com.yxt.anrui.base.api.basevehiclestate.BaseVehicleStateFeign; |
|
|
|
import com.yxt.anrui.buscenter.api.bussalesorder.BusSalesOrder; |
|
|
|
import com.yxt.anrui.buscenter.api.bussalesorder.BusSalesOrderFeign; |
|
|
|
import com.yxt.anrui.buscenter.api.bussalesorderborrower.BusSalesOrderBorrowerDetailsVo; |
|
|
|
import com.yxt.anrui.buscenter.api.bussalesorderborrower.BusSalesOrderBorrowerFeign; |
|
|
|
import com.yxt.anrui.buscenter.api.bussalesorderloancontract.BusSalesOrderLoancontractDetailsVo; |
|
|
|
@ -40,6 +43,7 @@ import com.yxt.anrui.buscenter.api.bussalesordervehicle.BusSalesOrderVehicle; |
|
|
|
import com.yxt.anrui.buscenter.api.bussalesordervehicle.BusSalesOrderVehicleFeign; |
|
|
|
import com.yxt.anrui.portal.api.sysuser.PrivilegeQuery; |
|
|
|
import com.yxt.anrui.portal.api.sysuser.SysUserFeign; |
|
|
|
import com.yxt.anrui.portal.api.sysuser.SysUserVo; |
|
|
|
import com.yxt.anrui.riskcenter.api.loanfileexamine.LoanFileexamineDto; |
|
|
|
import com.yxt.anrui.riskcenter.api.loanhomevisitinvestigatefile.LoanAttachTypeEnum; |
|
|
|
import com.yxt.anrui.riskcenter.api.loanhomevisitinvestigatefile.LoanHomevisitInvestigateFileDetailsVo; |
|
|
|
@ -48,6 +52,8 @@ import com.yxt.anrui.riskcenter.api.loanhomevisitprep.LoanHomevisitPrepVo; |
|
|
|
import com.yxt.anrui.riskcenter.biz.loanfileexamine.LoanFileexamineService; |
|
|
|
import com.yxt.anrui.riskcenter.biz.loanhomevisitinvestigatefile.LoanHomevisitInvestigateFileService; |
|
|
|
import com.yxt.common.base.config.component.FileUploadComponent; |
|
|
|
import com.yxt.messagecenter.api.message.MessageFeign; |
|
|
|
import com.yxt.messagecenter.api.message.PushMessageQuery; |
|
|
|
import org.apache.commons.lang3.StringUtils; |
|
|
|
import com.yxt.common.base.service.MybatisBaseService; |
|
|
|
import com.yxt.common.base.utils.PagerUtil; |
|
|
|
@ -61,11 +67,13 @@ import com.yxt.anrui.riskcenter.api.loancapitalcreditresult.LoanCapitalCreditRes |
|
|
|
import com.yxt.anrui.riskcenter.api.loancapitalcreditresult.LoanCapitalCreditResultDto; |
|
|
|
import com.yxt.anrui.riskcenter.api.loancapitalcreditresult.LoanCapitalCreditResultFeign; |
|
|
|
|
|
|
|
import org.apache.tomcat.util.threads.ThreadPoolExecutor; |
|
|
|
import org.springframework.beans.factory.annotation.Autowired; |
|
|
|
import org.springframework.stereotype.Service; |
|
|
|
|
|
|
|
import java.util.ArrayList; |
|
|
|
import java.util.List; |
|
|
|
import java.util.concurrent.*; |
|
|
|
|
|
|
|
/** |
|
|
|
* Project: anrui-riskcenter(资方信审终审结果反馈) <br/> |
|
|
|
@ -97,12 +105,15 @@ public class LoanCapitalCreditResultService extends MybatisBaseService<LoanCapit |
|
|
|
private BaseVehicleStateFeign baseVehicleStateFeign; |
|
|
|
@Autowired |
|
|
|
private BusSalesOrderVehicleFeign busSalesOrderVehicleFeign; |
|
|
|
@Autowired |
|
|
|
private BusSalesOrderFeign busSalesOrderFeign; |
|
|
|
@Autowired |
|
|
|
private MessageFeign messageFeign; |
|
|
|
|
|
|
|
public PagerVo<LoanCapitalCreditResultVo> listPageVo(PagerQuery<LoanCapitalCreditResultQuery> pq) { |
|
|
|
LoanCapitalCreditResultQuery query = pq.getParams(); |
|
|
|
QueryWrapper<LoanCapitalCreditResult> qw = new QueryWrapper<>(); |
|
|
|
qw.eq("lr.state", query.getType()); |
|
|
|
qw.eq("lf.state","2"); |
|
|
|
if ("1".equals(query.getType())) { |
|
|
|
qw.eq("bl.busNo", 304); |
|
|
|
} |
|
|
|
@ -220,6 +231,40 @@ public class LoanCapitalCreditResultService extends MybatisBaseService<LoanCapit |
|
|
|
if (busSalesOrderVehicle.getData() != null) { |
|
|
|
ResultBean updateManageState = baseVehicleStateFeign.updateManageState(busSalesOrderVehicle.getData().getSid()); |
|
|
|
} |
|
|
|
//获取销售专员userSid
|
|
|
|
List<String> receIveUserSidList = new ArrayList<>(); |
|
|
|
BusSalesOrder busSalesOrder = busSalesOrderFeign.fetchBySid(loanCapitalCreditResult.getSaleOrderSid()).getData(); |
|
|
|
SysUserVo sysUserVo = sysUserFeign.selectByStaffsid(busSalesOrder.getStaffSid()).getData(); |
|
|
|
receIveUserSidList.add(sysUserVo.getSid()); |
|
|
|
//获取车辆信息
|
|
|
|
List<BusSalesOrderVehicle> busSalesOrderVehicles = busSalesOrderVehicleFeign.selectListByOrderSidAndXdConSid(loanCapitalCreditResult.getSaleOrderSid(), loanCapitalCreditResult.getLoanContractSid()).getData(); |
|
|
|
String vinNo = ""; |
|
|
|
for (BusSalesOrderVehicle salesOrderVehicle : busSalesOrderVehicles) { |
|
|
|
vinNo = vinNo + salesOrderVehicle.getLinkNo().substring(salesOrderVehicle.getLinkNo().length() - 8) + "，"; |
|
|
|
} |
|
|
|
vinNo = vinNo.substring(vinNo.lastIndexOf("，")); |
|
|
|
//发送通知给销售专员
|
|
|
|
try { |
|
|
|
ThreadFactory namedThreadFactory = new ThreadFactoryBuilder() |
|
|
|
.setNameFormat("demo-pool-%d").build(); |
|
|
|
ExecutorService pool = new ThreadPoolExecutor(1, 10, |
|
|
|
1000, TimeUnit.MILLISECONDS, |
|
|
|
new LinkedBlockingQueue<Runnable>(1024), namedThreadFactory, new ThreadPoolExecutor.AbortPolicy()); |
|
|
|
String finalVinNo = vinNo; |
|
|
|
Future future1 = pool.submit(() -> { |
|
|
|
PushMessageQuery pushMessageQuery = new PushMessageQuery(); |
|
|
|
pushMessageQuery.setReceivedSids(receIveUserSidList); |
|
|
|
pushMessageQuery.setModuleName("风控"); |
|
|
|
pushMessageQuery.setMsgContent(busSalesOrderVehicles.get(0).getBorrowName() + "的" + finalVinNo + "已经资方信审终审通过了。"); |
|
|
|
pushMessageQuery.setApp_type("2"); |
|
|
|
pushMessageQuery.setModuleSid("fec4e243-491a-11ec-94cd-fa163e0cb33c"); |
|
|
|
pushMessageQuery.setMsgTitle("家访资料问题反馈"); |
|
|
|
// 消息推送
|
|
|
|
messageFeign.pushNoUriMessage(pushMessageQuery); |
|
|
|
}); |
|
|
|
} catch (Exception e) { |
|
|
|
e.printStackTrace(); |
|
|
|
} |
|
|
|
}else{ |
|
|
|
BusSalesOrderLoancontractDetailsVo loancontractDetailsVo = busSalesOrderLoancontractFeign.fetchDetailsBySid(loanCapitalCreditResult.getLoanContractSid()).getData(); |
|
|
|
baseMapper.setState(loancontractDetailsVo.getBorrowerSid()); |
|
|
|
|
dimengzhe
2 years ago