转诉讼申请通过后修改车辆的风控状态为直接诉讼立案或者亏损立案

anrui-riskcenter/anrui-riskcenter-biz/src/main/java/com/yxt/anrui/riskcenter/biz/loanlawsuitsubapply/LoanLawsuitSubApplyService.java

@@ -35,6 +35,7 @@ import com.yxt.anrui.base.common.utils.Rule;
 import com.yxt.anrui.buscenter.api.bussalesorder.BusSalesOrder;
 import com.yxt.anrui.buscenter.api.bussalesordervehicle.BusSalesOrderVehicle;
 import com.yxt.anrui.buscenter.api.bussalesordervehicle.BusSalesOrderVehicleFeign;
+import com.yxt.anrui.buscenter.api.bussalesordervehicle.BusVinStateSetQuery;
 import com.yxt.anrui.flowable.api.flow.FlowableFeign;
 import com.yxt.anrui.flowable.api.flow.UpdateFlowFieldVo;
 import com.yxt.anrui.flowable.api.flow2.FlowDelegateQuery;
@@ -55,6 +56,7 @@ import com.yxt.anrui.riskcenter.api.loanlawsuitapply.LoanLawsuitVehVo;
 import com.yxt.anrui.riskcenter.api.loanlawsuitsubapply.flow.*;
 import com.yxt.anrui.riskcenter.api.loanlawsuitsubveh.LoanLawsuitSubVehDetailsVo;
 import com.yxt.anrui.riskcenter.api.loanlawsuitsubveh.LoanLawsuitSubVehDto;
+import com.yxt.anrui.riskcenter.api.loanreturninboundapply.LoanReturnInboundApply;
 import com.yxt.anrui.riskcenter.api.loansettleapply.SettleApplyCommonVo;
 import com.yxt.anrui.riskcenter.biz.loancaseprogress.LoanCaseProgressService;
 import com.yxt.anrui.riskcenter.biz.loanlawsuitapply.LoanLawsuitApplyService;
@@ -467,6 +469,19 @@ public class LoanLawsuitSubApplyService extends MybatisBaseService<LoanLawsuitSu
 			UpdateFlowFieldVo ufVo = resultBean.getData();
 			int i = updateFlowFiled(BeanUtil.beanToMap(resultBean.getData()));
 			if ("Event_end".equals(resultBean.getData().getTaskDefKey())) {
+				//设置车辆的风控状态
+				try {
+					ThreadFactory namedThreadFactory = new ThreadFactoryBuilder()
+							.setNameFormat("demo-pool-%d").build();
+					ExecutorService pool = new org.apache.tomcat.util.threads.ThreadPoolExecutor(2, 100,
+							0L, TimeUnit.MILLISECONDS,
+							new LinkedBlockingQueue<Runnable>(1024), namedThreadFactory, new org.apache.tomcat.util.threads.ThreadPoolExecutor.AbortPolicy());
+					Future future1 = pool.submit(() -> {
+						setRiskState(businessSid);
+					});
+				} catch (Exception e) {
+					e.printStackTrace();
+				}
 
 			} else {
 				//极光推送
@@ -490,6 +505,41 @@ public class LoanLawsuitSubApplyService extends MybatisBaseService<LoanLawsuitSu
 		}
 	}
 
+	public void setRiskState(String businessSid){
+		List<String> busVinSidJh = new ArrayList<>();
+		List<String> busVinSidSecond = new ArrayList<>();
+		//判断车辆是交回、未交回还是二次销售
+		List<String> busVinSidList = loanLawsuitSubVehService.selectByMainSid(businessSid);
+		busVinSidList.removeAll(Collections.singleton(null));
+		if(!busVinSidList.isEmpty()){
+			for (int j = 0; j < busVinSidList.size(); j++) {
+				String busVinSid = busVinSidList.get(j);
+				BusSalesOrderVehicle busSalesOrderVehicle = busSalesOrderVehicleFeign.fetchBySalesOrderVehiclerSid(busVinSid).getData();
+				if(busSalesOrderVehicle != null){
+					if("0".equals(busSalesOrderVehicle.getRiskState().toString())
+							|| "1".equals(busSalesOrderVehicle.getRiskState().toString())){//正常和交回的，转为9
+						busVinSidJh.add(busVinSid);
+					}else if("7".equals(busSalesOrderVehicle.getRiskState().toString())){
+						busVinSidSecond.add(busVinSid);
+					}
+				}
+			}
+			//将交回、正常的车辆的风控状态设置为9直接诉讼立案
+			BusVinStateSetQuery busVinStateSetQuery = new BusVinStateSetQuery();
+			if(!busVinSidJh.isEmpty()){
+				busVinStateSetQuery.setState(9);
+				busVinStateSetQuery.setBusVinSidList(busVinSidJh);
+				busSalesOrderVehicleFeign.setRiskState(busVinStateSetQuery);
+			}
+			//将处置损失的车辆的风控状态设置为11亏损立案
+			if(!busVinSidSecond.isEmpty()){
+				busVinStateSetQuery.setState(11);
+				busVinStateSetQuery.setBusVinSidList(busVinSidJh);
+				busSalesOrderVehicleFeign.setRiskState(busVinStateSetQuery);
+			}
+		}
+	}
+
 
 	/**
 	 * 撤回

anrui-riskcenter/anrui-riskcenter-biz/src/main/java/com/yxt/anrui/riskcenter/biz/loanlawsuitsubveh/LoanLawsuitSubVehMapper.java

@@ -42,4 +42,6 @@ public interface LoanLawsuitSubVehMapper extends BaseMapper<LoanLawsuitSubVeh> {
 
 	@Select("select * from loan_lawsuit_sub_veh where mainSid = #{mainSid}")
 	List<LoanLawsuitSubVehDetailsVo> selByMainSid(String mainSid);
+
+    List<String> selectByMainSid(String businessSid);
 }

anrui-riskcenter/anrui-riskcenter-biz/src/main/java/com/yxt/anrui/riskcenter/biz/loanlawsuitsubveh/LoanLawsuitSubVehMapper.xml

@@ -4,4 +4,8 @@
 <!--    <where> ${ew.sqlSegment} </where>-->
 <!--    ${ew.customSqlSegment} -->
 
+
+<select id="selectByMainSid" resultType="java.lang.String">
+    select busVinSid from loan_lawsuit_sub_veh where mainSid = #{businessSid}
+    </select>
 </mapper>

anrui-riskcenter/anrui-riskcenter-biz/src/main/java/com/yxt/anrui/riskcenter/biz/loanlawsuitsubveh/LoanLawsuitSubVehService.java

@@ -51,4 +51,8 @@ public class LoanLawsuitSubVehService extends MybatisBaseService<LoanLawsuitSubV
 	public List<LoanLawsuitSubVehDetailsVo> selByMainSid(String mainSid) {
 		return baseMapper.selByMainSid(mainSid);
 	}
+
+	public List<String> selectByMainSid(String businessSid) {
+		return baseMapper.selectByMainSid(businessSid);
+	}
 }