diff --git a/anrui-riskcenter/anrui-riskcenter-biz/src/main/java/com/yxt/anrui/riskcenter/biz/loanlawsuitsubapply/LoanLawsuitSubApplyService.java b/anrui-riskcenter/anrui-riskcenter-biz/src/main/java/com/yxt/anrui/riskcenter/biz/loanlawsuitsubapply/LoanLawsuitSubApplyService.java
index 6c26d4d4a6..9c76a46034 100644
--- a/anrui-riskcenter/anrui-riskcenter-biz/src/main/java/com/yxt/anrui/riskcenter/biz/loanlawsuitsubapply/LoanLawsuitSubApplyService.java
+++ b/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);
+			}
+		}
+	}
+
 
 	/**
 	 * 撤回
diff --git a/anrui-riskcenter/anrui-riskcenter-biz/src/main/java/com/yxt/anrui/riskcenter/biz/loanlawsuitsubveh/LoanLawsuitSubVehMapper.java b/anrui-riskcenter/anrui-riskcenter-biz/src/main/java/com/yxt/anrui/riskcenter/biz/loanlawsuitsubveh/LoanLawsuitSubVehMapper.java
index fd6e8dedb4..5582d18b98 100644
--- a/anrui-riskcenter/anrui-riskcenter-biz/src/main/java/com/yxt/anrui/riskcenter/biz/loanlawsuitsubveh/LoanLawsuitSubVehMapper.java
+++ b/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);
 }
\ No newline at end of file
diff --git a/anrui-riskcenter/anrui-riskcenter-biz/src/main/java/com/yxt/anrui/riskcenter/biz/loanlawsuitsubveh/LoanLawsuitSubVehMapper.xml b/anrui-riskcenter/anrui-riskcenter-biz/src/main/java/com/yxt/anrui/riskcenter/biz/loanlawsuitsubveh/LoanLawsuitSubVehMapper.xml
index 32f86fabc4..581866bc4d 100644
--- a/anrui-riskcenter/anrui-riskcenter-biz/src/main/java/com/yxt/anrui/riskcenter/biz/loanlawsuitsubveh/LoanLawsuitSubVehMapper.xml
+++ b/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>
\ No newline at end of file
diff --git a/anrui-riskcenter/anrui-riskcenter-biz/src/main/java/com/yxt/anrui/riskcenter/biz/loanlawsuitsubveh/LoanLawsuitSubVehService.java b/anrui-riskcenter/anrui-riskcenter-biz/src/main/java/com/yxt/anrui/riskcenter/biz/loanlawsuitsubveh/LoanLawsuitSubVehService.java
index 24244fcb25..a69eea75e3 100644
--- a/anrui-riskcenter/anrui-riskcenter-biz/src/main/java/com/yxt/anrui/riskcenter/biz/loanlawsuitsubveh/LoanLawsuitSubVehService.java
+++ b/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);
+	}
 }
\ No newline at end of file