diff --git a/anrui-portal/anrui-portal-biz/pom.xml b/anrui-portal/anrui-portal-biz/pom.xml
index 182567e5c9..a77f68f1cf 100644
--- a/anrui-portal/anrui-portal-biz/pom.xml
+++ b/anrui-portal/anrui-portal-biz/pom.xml
@@ -142,6 +142,12 @@
             <version>0.0.1-SNAPSHOT</version>
             <scope>compile</scope>
         </dependency>
+        <dependency>
+            <groupId>com.yxt.anrui</groupId>
+            <artifactId>anrui-riskcenter-api</artifactId>
+            <version>0.0.1-SNAPSHOT</version>
+            <scope>compile</scope>
+        </dependency>
 
 
     </dependencies>
diff --git a/anrui-portal/anrui-portal-biz/src/main/java/com/yxt/anrui/portal/PortalApplication.java b/anrui-portal/anrui-portal-biz/src/main/java/com/yxt/anrui/portal/PortalApplication.java
index d6bba6d94f..c161336265 100644
--- a/anrui-portal/anrui-portal-biz/src/main/java/com/yxt/anrui/portal/PortalApplication.java
+++ b/anrui-portal/anrui-portal-biz/src/main/java/com/yxt/anrui/portal/PortalApplication.java
@@ -14,7 +14,7 @@ import org.springframework.cloud.openfeign.EnableFeignClients;
         "com.yxt.anrui.portal"
 })
 @EnableDiscoveryClient
-@EnableFeignClients(basePackages = {"com.yxt.anrui.crm", "com.yxt.anrui.flowable", "com.yxt.messagecenter", "com.yxt.anrui.terminal", "com.yxt.anrui.base", "com.yxt.anrui.scm", "com.yxt.anrui.fin", "com.yxt.anrui.buscenter"})
+@EnableFeignClients(basePackages = {"com.yxt.anrui.crm", "com.yxt.anrui.flowable", "com.yxt.messagecenter", "com.yxt.anrui.terminal", "com.yxt.anrui.base", "com.yxt.anrui.scm", "com.yxt.anrui.fin", "com.yxt.anrui.buscenter", "com.yxt.anrui.riskcenter"})
 public class PortalApplication {
 
     public static void main(String[] args) {
diff --git a/anrui-portal/anrui-portal-biz/src/main/java/com/yxt/anrui/portal/biz/index/AppIndexEnum.java b/anrui-portal/anrui-portal-biz/src/main/java/com/yxt/anrui/portal/biz/index/AppIndexEnum.java
index f030ef57e1..3ade996276 100644
--- a/anrui-portal/anrui-portal-biz/src/main/java/com/yxt/anrui/portal/biz/index/AppIndexEnum.java
+++ b/anrui-portal/anrui-portal-biz/src/main/java/com/yxt/anrui/portal/biz/index/AppIndexEnum.java
@@ -16,8 +16,9 @@ public class AppIndexEnum {
          */
         GYL("98ff0724-5df4-4fc7-ab6d-3996e7706acd", "供应链"),
 
-        YW("e25e13b5-f2ed-421f-bdb3-6f2eca2a3028", "业务");
+        YW("e25e13b5-f2ed-421f-bdb3-6f2eca2a3028", "业务"),
 
+        FK("fec4e243-491a-11ec-94cd-fa163e0cb33c","风控");
         /**
          * code值
          */
@@ -51,6 +52,8 @@ public class AppIndexEnum {
         SC("92659535-38f6-4456-a45a-ab5e9ced3fac", "收车"),
         HTSH("f4d75ebc-cbab-4c44-bf93-2d38f70c1c15", "合同审核"),
         JZKHBA("6a80aa48-c988-4880-b0a0-f2a406d8cad5", "价值客户备案"),
+        JFKC("a204a3fa-c8ac-4795-966c-df1d0e131bcf", "家访考察"),
+        FKZLSC("65dc12e0-9213-4364-ae81-18afa9c7e1ee", "放款资料上传"),
         ;
 
         /**
diff --git a/anrui-portal/anrui-portal-biz/src/main/java/com/yxt/anrui/portal/biz/index/AppIndexService.java b/anrui-portal/anrui-portal-biz/src/main/java/com/yxt/anrui/portal/biz/index/AppIndexService.java
index e5d211fe4b..7b9cb63c7f 100644
--- a/anrui-portal/anrui-portal-biz/src/main/java/com/yxt/anrui/portal/biz/index/AppIndexService.java
+++ b/anrui-portal/anrui-portal-biz/src/main/java/com/yxt/anrui/portal/biz/index/AppIndexService.java
@@ -17,12 +17,16 @@ import com.yxt.anrui.portal.biz.sysmobilemenu.SysMobileMenuService;
 import com.yxt.anrui.portal.biz.sysmobilemenurole.SysMobileMenuRoleService;
 import com.yxt.anrui.portal.biz.sysuser.SysUserService;
 import com.yxt.anrui.portal.biz.sysuserrole.SysUserRoleService;
+import com.yxt.anrui.riskcenter.api.loanfileexamine.LoanFileexamineFeign;
+import com.yxt.anrui.riskcenter.api.loanhomevisitinvestigate.LoanHomevisitInvestigateFeign;
+import com.yxt.anrui.riskcenter.api.loanhomevisitinvestigate.RiskToDoNumQuery;
 import com.yxt.anrui.scm.api.scmvehicleenterlibrary.ScmVehicleEnterlibraryFeign;
 import com.yxt.anrui.scm.api.scmvehicleexamine.AppToDoNumQuery;
 import com.yxt.anrui.scm.api.scmvehicleexamine.ScmVehicleExamineFeign;
 import com.yxt.anrui.scm.api.scmvehiclegression.ScmVehicleGressionFeign;
 import com.yxt.anrui.scm.api.scmvehicleinventory.ScmVehicleInventoryFeign;
 import com.yxt.anrui.scm.api.scmvehiclepatrolinspection.ScmVehiclePatrolinspectionFeign;
+import com.yxt.anrui.terminal.api.risk.loanhomevisitinvestigate.LoanHomeVisitInvestigateFeign;
 import com.yxt.common.base.utils.StringUtils;
 import com.yxt.common.core.result.ResultBean;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -59,11 +63,14 @@ public class AppIndexService {
     private ScmVehiclePatrolinspectionFeign scmVehiclePatrolinspectionFeign;
     @Autowired
     private SysUserService sysUserService;
-
     @Autowired
     private CommonContractFeign commonContractFeign;
     @Autowired
     private BusValcustFilingFeign busValcustFilingFeign;
+    @Autowired
+    private LoanHomevisitInvestigateFeign loanHomevisitInvestigateFeign;
+    @Autowired
+    private LoanFileexamineFeign loanFileexamineFeign;
 
     public ResultBean<List<AppIndexNewVo>> getBusinessList(String userSid, String appSid, String orgPath) {
         ResultBean<List<AppIndexNewVo>> rb = ResultBean.fireFail();
@@ -125,8 +132,10 @@ public class AppIndexService {
         appToDoNumQuery.setOrgPath(orgPath);
         CommonToDoNumQuery commonToDoNumQuery = new CommonToDoNumQuery();
         BusToDoNumQuery busToDoNumQuery = new BusToDoNumQuery();
+        RiskToDoNumQuery riskToDoNumQuery = new RiskToDoNumQuery();
         BeanUtil.copyProperties(appToDoNumQuery, commonToDoNumQuery);
         BeanUtil.copyProperties(appToDoNumQuery, busToDoNumQuery);
+        BeanUtil.copyProperties(appToDoNumQuery, riskToDoNumQuery);
         //根据appSid查询菜单的信息
         List<SysMobileMenu> sysMobileMenus = sysMobileMenuService.getMenu(appSid);
         List<AppIndexNumVo> list = new ArrayList<>();
@@ -184,6 +193,23 @@ public class AppIndexService {
                 list.add(appIndexNumVo);
             }
 
+        }else if (AppIndexEnum.AppVersionSubAppSid.FK.getCode().equals(appSid)){
+            //风控
+            for (SysMobileMenu menu : sysMobileMenus) {
+                AppIndexNumVo appIndexNumVo = new AppIndexNumVo();
+                appIndexNumVo.setSid(menu.getSid());
+                //家访考察
+                if (AppIndexEnum.AppMenu.JFKC.getRemarks().equals(menu.getTitle())) {
+                    String num = loanHomevisitInvestigateFeign.getToDoNum(riskToDoNumQuery).getData();
+                    appIndexNumVo.setNum(num);
+                }
+                //放款资料上传
+                if (AppIndexEnum.AppMenu.FKZLSC.getRemarks().equals(menu.getTitle())) {
+                    String num = loanFileexamineFeign.getToDoNum(riskToDoNumQuery).getData();
+                    appIndexNumVo.setNum(num);
+                }
+                list.add(appIndexNumVo);
+            }
         }
 
         return rb.success().setData(list);
diff --git a/anrui-riskcenter-ui/src/views/managementcreditaudit/managementcreditaudit.vue b/anrui-riskcenter-ui/src/views/managementcreditaudit/managementcreditaudit.vue
index 10b9e6e5a0..3689b7647d 100644
--- a/anrui-riskcenter-ui/src/views/managementcreditaudit/managementcreditaudit.vue
+++ b/anrui-riskcenter-ui/src/views/managementcreditaudit/managementcreditaudit.vue
@@ -98,6 +98,11 @@
                 <span>{{ scope.row.loanContractNo }}</span>
               </template>
             </el-table-column>
+            <el-table-column label="车架号" align="center" width="100">
+              <template slot-scope="scope">
+                <span>{{ scope.row.vinNo }}</span>
+              </template>
+            </el-table-column>
             <el-table-column label="台数" align="center" width="60">
               <template slot-scope="scope">
                 <span>{{ scope.row.num }}</span>
diff --git a/anrui-riskcenter-ui/src/views/managementcreditaudit/managementcreditauditfeedback.vue b/anrui-riskcenter-ui/src/views/managementcreditaudit/managementcreditauditfeedback.vue
index 5f20ec8e0d..8832f8c1b0 100644
--- a/anrui-riskcenter-ui/src/views/managementcreditaudit/managementcreditauditfeedback.vue
+++ b/anrui-riskcenter-ui/src/views/managementcreditaudit/managementcreditauditfeedback.vue
@@ -88,6 +88,11 @@
                 <span>{{ scope.row.loanContractNo }}</span>
               </template>
             </el-table-column>
+            <el-table-column label="车架号" align="center" width="100">
+              <template slot-scope="scope">
+                <span>{{ scope.row.vinNo }}</span>
+              </template>
+            </el-table-column>
             <el-table-column label="台数" align="center" width="60">
               <template slot-scope="scope">
                 <span>{{ scope.row.num }}</span>
diff --git a/anrui-riskcenter/anrui-riskcenter-api/src/main/java/com/yxt/anrui/riskcenter/api/loancapitalcreditresult/LoanCapitalCreditResultVo.java b/anrui-riskcenter/anrui-riskcenter-api/src/main/java/com/yxt/anrui/riskcenter/api/loancapitalcreditresult/LoanCapitalCreditResultVo.java
index 54943c8c53..c9b559fdd2 100644
--- a/anrui-riskcenter/anrui-riskcenter-api/src/main/java/com/yxt/anrui/riskcenter/api/loancapitalcreditresult/LoanCapitalCreditResultVo.java
+++ b/anrui-riskcenter/anrui-riskcenter-api/src/main/java/com/yxt/anrui/riskcenter/api/loancapitalcreditresult/LoanCapitalCreditResultVo.java
@@ -83,4 +83,6 @@ public class LoanCapitalCreditResultVo implements Vo {
     private String customerName;
     @ApiModelProperty("销售订单合同号")
     private String contractNo;
+    @ApiModelProperty("车架号")
+    private String vinNo;
 }
diff --git a/anrui-riskcenter/anrui-riskcenter-api/src/main/java/com/yxt/anrui/riskcenter/api/loanfileexamine/LoanFileexamineFeign.java b/anrui-riskcenter/anrui-riskcenter-api/src/main/java/com/yxt/anrui/riskcenter/api/loanfileexamine/LoanFileexamineFeign.java
index 68b64c303e..e12d006ecd 100644
--- a/anrui-riskcenter/anrui-riskcenter-api/src/main/java/com/yxt/anrui/riskcenter/api/loanfileexamine/LoanFileexamineFeign.java
+++ b/anrui-riskcenter/anrui-riskcenter-api/src/main/java/com/yxt/anrui/riskcenter/api/loanfileexamine/LoanFileexamineFeign.java
@@ -25,12 +25,14 @@
  *********************************************************/
 package com.yxt.anrui.riskcenter.api.loanfileexamine;
 
+import com.yxt.anrui.riskcenter.api.loanhomevisitinvestigate.RiskToDoNumQuery;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
 import com.yxt.common.core.query.PagerQuery;
 import com.yxt.common.core.result.ResultBean;
 import com.yxt.common.core.vo.PagerVo;
 import org.springframework.cloud.openfeign.FeignClient;
+import org.springframework.cloud.openfeign.SpringQueryMap;
 import org.springframework.web.bind.annotation.*;
 
 import java.util.List;
@@ -85,4 +87,9 @@ public interface LoanFileexamineFeign {
     @GetMapping("/selectOrderSidAndContract")
     @ResponseBody
     ResultBean<LoanFileexamine> selectOrderSidAndContract(@RequestParam("saleOrderSid") String saleOrderSid, @RequestParam(value = "loanContractSid",required = false) String loanContractSid);
+
+    @ApiOperation("手机端-查询本分公司下代办数量:切换机构")
+    @GetMapping("/getToDoNum")
+    @ResponseBody
+    ResultBean<String> getToDoNum(@SpringQueryMap RiskToDoNumQuery riskToDoNumQuery);
 }
\ No newline at end of file
diff --git a/anrui-riskcenter/anrui-riskcenter-api/src/main/java/com/yxt/anrui/riskcenter/api/loanfileexamine/LoanFileexamineFeignFallback.java b/anrui-riskcenter/anrui-riskcenter-api/src/main/java/com/yxt/anrui/riskcenter/api/loanfileexamine/LoanFileexamineFeignFallback.java
index d1471cf646..98203d171e 100644
--- a/anrui-riskcenter/anrui-riskcenter-api/src/main/java/com/yxt/anrui/riskcenter/api/loanfileexamine/LoanFileexamineFeignFallback.java
+++ b/anrui-riskcenter/anrui-riskcenter-api/src/main/java/com/yxt/anrui/riskcenter/api/loanfileexamine/LoanFileexamineFeignFallback.java
@@ -25,6 +25,7 @@
  *********************************************************/
 package com.yxt.anrui.riskcenter.api.loanfileexamine;
 
+import com.yxt.anrui.riskcenter.api.loanhomevisitinvestigate.RiskToDoNumQuery;
 import com.yxt.common.core.query.PagerQuery;
 import com.yxt.common.core.result.ResultBean;
 import com.yxt.common.core.vo.PagerVo;
@@ -79,4 +80,9 @@ public class LoanFileexamineFeignFallback implements LoanFileexamineFeign {
 	public ResultBean<LoanFileexamine> selectOrderSidAndContract(String saleOrderSid, String loanContractSid) {
 		return null;
 	}
+
+	@Override
+	public ResultBean<String> getToDoNum(RiskToDoNumQuery riskToDoNumQuery) {
+		return null;
+	}
 }
\ No newline at end of file
diff --git a/anrui-riskcenter/anrui-riskcenter-api/src/main/java/com/yxt/anrui/riskcenter/api/loanhomevisitinvestigate/LoanHomevisitInvestigateFeign.java b/anrui-riskcenter/anrui-riskcenter-api/src/main/java/com/yxt/anrui/riskcenter/api/loanhomevisitinvestigate/LoanHomevisitInvestigateFeign.java
index 9836553d59..b6dd8d9b28 100644
--- a/anrui-riskcenter/anrui-riskcenter-api/src/main/java/com/yxt/anrui/riskcenter/api/loanhomevisitinvestigate/LoanHomevisitInvestigateFeign.java
+++ b/anrui-riskcenter/anrui-riskcenter-api/src/main/java/com/yxt/anrui/riskcenter/api/loanhomevisitinvestigate/LoanHomevisitInvestigateFeign.java
@@ -42,6 +42,7 @@ import com.yxt.common.core.query.PagerQuery;
 import com.yxt.common.core.result.ResultBean;
 import com.yxt.common.core.vo.PagerVo;
 import org.springframework.cloud.openfeign.FeignClient;
+import org.springframework.cloud.openfeign.SpringQueryMap;
 import org.springframework.web.bind.annotation.*;
 
 import javax.validation.Valid;
@@ -206,4 +207,9 @@ public interface LoanHomevisitInvestigateFeign {
     @GetMapping("/details2")
     @ResponseBody
     public ResultBean<LoanHomeVisitInvestigateInitZLVo> details2(@RequestParam("sid") String sid);
+
+    @ApiOperation("手机端-查询本分公司下代办数量:切换机构")
+    @GetMapping("/getToDoNum")
+    @ResponseBody
+    ResultBean<String> getToDoNum(@SpringQueryMap RiskToDoNumQuery riskToDoNumQuery);
 }
\ No newline at end of file
diff --git a/anrui-riskcenter/anrui-riskcenter-api/src/main/java/com/yxt/anrui/riskcenter/api/loanhomevisitinvestigate/LoanHomevisitInvestigateFeignFallback.java b/anrui-riskcenter/anrui-riskcenter-api/src/main/java/com/yxt/anrui/riskcenter/api/loanhomevisitinvestigate/LoanHomevisitInvestigateFeignFallback.java
index 92ab05db6c..5629dbd091 100644
--- a/anrui-riskcenter/anrui-riskcenter-api/src/main/java/com/yxt/anrui/riskcenter/api/loanhomevisitinvestigate/LoanHomevisitInvestigateFeignFallback.java
+++ b/anrui-riskcenter/anrui-riskcenter-api/src/main/java/com/yxt/anrui/riskcenter/api/loanhomevisitinvestigate/LoanHomevisitInvestigateFeignFallback.java
@@ -200,4 +200,9 @@ public class LoanHomevisitInvestigateFeignFallback implements LoanHomevisitInves
 	public ResultBean<LoanHomeVisitInvestigateInitZLVo> details2(String sid) {
 		return null;
 	}
+
+	@Override
+	public ResultBean<String> getToDoNum(RiskToDoNumQuery riskToDoNumQuery) {
+		return null;
+	}
 }
\ No newline at end of file
diff --git a/anrui-riskcenter/anrui-riskcenter-api/src/main/java/com/yxt/anrui/riskcenter/api/loanhomevisitinvestigate/RiskToDoNumQuery.java b/anrui-riskcenter/anrui-riskcenter-api/src/main/java/com/yxt/anrui/riskcenter/api/loanhomevisitinvestigate/RiskToDoNumQuery.java
new file mode 100644
index 0000000000..b82c78bbf5
--- /dev/null
+++ b/anrui-riskcenter/anrui-riskcenter-api/src/main/java/com/yxt/anrui/riskcenter/api/loanhomevisitinvestigate/RiskToDoNumQuery.java
@@ -0,0 +1,13 @@
+package com.yxt.anrui.riskcenter.api.loanhomevisitinvestigate;
+
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+@Data
+public class RiskToDoNumQuery {
+
+    @ApiModelProperty("用户sid")
+    private String userSid;
+    @ApiModelProperty("组织机构sid")
+    private String orgPath;
+}
diff --git a/anrui-riskcenter/anrui-riskcenter-biz/src/main/java/com/yxt/anrui/riskcenter/biz/loancapitalcreditresult/LoanCapitalCreditResultMapper.xml b/anrui-riskcenter/anrui-riskcenter-biz/src/main/java/com/yxt/anrui/riskcenter/biz/loancapitalcreditresult/LoanCapitalCreditResultMapper.xml
index a7be2740dd..2493441325 100644
--- a/anrui-riskcenter/anrui-riskcenter-biz/src/main/java/com/yxt/anrui/riskcenter/biz/loancapitalcreditresult/LoanCapitalCreditResultMapper.xml
+++ b/anrui-riskcenter/anrui-riskcenter-biz/src/main/java/com/yxt/anrui/riskcenter/biz/loancapitalcreditresult/LoanCapitalCreditResultMapper.xml
@@ -20,18 +20,21 @@
         bl.`bankContractNo`,
         lr.loanContractSid,
         bo.customerName,
-        bo.contractNo
+        bo.contractNo,
+        GROUP_CONCAT(RIGHT(bv.`linkNo`, 8)) AS vinNo
         FROM
         loan_capital_credit_result lr
-        LEFT JOIN loan_homevisit_fileexamine lf
-        ON lr.`homeVisitSid` = lf.`homeVisitSid`
         LEFT JOIN anrui_buscenter.bus_sales_order_loancontract bl
         ON lr.`loanContractSid` = bl.`sid`
+        LEFT JOIN anrui_buscenter.`bus_sales_order_vehicle` bv
+        ON lr.`saleOrderSid` = bv.`salesOrderSid`
+        AND lr.`loanContractSid` = bv.`loanContractSid`
         LEFT JOIN anrui_buscenter.`bus_sales_order` bo
         ON lr.`saleOrderSid` = bo.`sid`
         <where>
             ${ew.sqlSegment}
         </where>
+        GROUP BY lr.`sid`
     </select>
 
     <select id="selectListAllVo"
diff --git a/anrui-riskcenter/anrui-riskcenter-biz/src/main/java/com/yxt/anrui/riskcenter/biz/loancapitalcreditresult/LoanCapitalCreditResultService.java b/anrui-riskcenter/anrui-riskcenter-biz/src/main/java/com/yxt/anrui/riskcenter/biz/loancapitalcreditresult/LoanCapitalCreditResultService.java
index 9d8f1e2fe1..93d0e2712a 100644
--- a/anrui-riskcenter/anrui-riskcenter-biz/src/main/java/com/yxt/anrui/riskcenter/biz/loancapitalcreditresult/LoanCapitalCreditResultService.java
+++ b/anrui-riskcenter/anrui-riskcenter-biz/src/main/java/com/yxt/anrui/riskcenter/biz/loancapitalcreditresult/LoanCapitalCreditResultService.java
@@ -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());
diff --git a/anrui-riskcenter/anrui-riskcenter-biz/src/main/java/com/yxt/anrui/riskcenter/biz/loanfileexamine/LoanFileexamineMapper.java b/anrui-riskcenter/anrui-riskcenter-biz/src/main/java/com/yxt/anrui/riskcenter/biz/loanfileexamine/LoanFileexamineMapper.java
index 5a90a12771..2f8d32eb38 100644
--- a/anrui-riskcenter/anrui-riskcenter-biz/src/main/java/com/yxt/anrui/riskcenter/biz/loanfileexamine/LoanFileexamineMapper.java
+++ b/anrui-riskcenter/anrui-riskcenter-biz/src/main/java/com/yxt/anrui/riskcenter/biz/loanfileexamine/LoanFileexamineMapper.java
@@ -64,4 +64,6 @@ public interface LoanFileexamineMapper extends BaseMapper<LoanFileexamine> {
 	List<LoanFileexamineVo> selectListVo();
 
     LoanFileexamine selectOrderSidAndContract(@Param("saleOrderSid") String saleOrderSid, @Param("loanContractSid") String loanContractSid);
+
+    int getToDoNum(@Param("orgPath") String orgPath,@Param("userSid") String userSid);
 }
\ No newline at end of file
diff --git a/anrui-riskcenter/anrui-riskcenter-biz/src/main/java/com/yxt/anrui/riskcenter/biz/loanfileexamine/LoanFileexamineMapper.xml b/anrui-riskcenter/anrui-riskcenter-biz/src/main/java/com/yxt/anrui/riskcenter/biz/loanfileexamine/LoanFileexamineMapper.xml
index 7cee1c1870..c5d573eb8e 100644
--- a/anrui-riskcenter/anrui-riskcenter-biz/src/main/java/com/yxt/anrui/riskcenter/biz/loanfileexamine/LoanFileexamineMapper.xml
+++ b/anrui-riskcenter/anrui-riskcenter-biz/src/main/java/com/yxt/anrui/riskcenter/biz/loanfileexamine/LoanFileexamineMapper.xml
@@ -40,4 +40,14 @@
     <select id="selectOrderSidAndContract" resultType="com.yxt.anrui.riskcenter.api.loanfileexamine.LoanFileexamine">
         SELECT * FROM loan_fileexamine where saleOrderSid = #{saleOrderSid} and loanContractSid = #{loanContractSid} order by id desc limit 1
     </select>
+
+    <select id="getToDoNum" resultType="int">
+        SELECT COUNT(*)
+        FROM loan_fileexamine lf
+                     LEFT JOIN anrui_buscenter.`bus_sales_order` bo
+                ON lf.`saleOrderSid` = bo.`sid`
+        WHERE bo.createBySid = #{userSid}
+          AND bo.orgSidPath = #{orgPath}
+          AND lf.`zlState` = '0'
+    </select>
 </mapper>
\ No newline at end of file
diff --git a/anrui-riskcenter/anrui-riskcenter-biz/src/main/java/com/yxt/anrui/riskcenter/biz/loanfileexamine/LoanFileexamineRest.java b/anrui-riskcenter/anrui-riskcenter-biz/src/main/java/com/yxt/anrui/riskcenter/biz/loanfileexamine/LoanFileexamineRest.java
index 7ec9b453f6..324626c6bf 100644
--- a/anrui-riskcenter/anrui-riskcenter-biz/src/main/java/com/yxt/anrui/riskcenter/biz/loanfileexamine/LoanFileexamineRest.java
+++ b/anrui-riskcenter/anrui-riskcenter-biz/src/main/java/com/yxt/anrui/riskcenter/biz/loanfileexamine/LoanFileexamineRest.java
@@ -26,6 +26,7 @@
 package com.yxt.anrui.riskcenter.biz.loanfileexamine;
 
 import com.yxt.anrui.riskcenter.api.loanfileexamine.*;
+import com.yxt.anrui.riskcenter.api.loanhomevisitinvestigate.RiskToDoNumQuery;
 import com.yxt.common.core.query.PagerQuery;
 import com.yxt.common.core.result.ResultBean;
 import com.yxt.common.core.vo.PagerVo;
@@ -104,4 +105,9 @@ public class LoanFileexamineRest implements LoanFileexamineFeign {
 	public ResultBean<LoanFileexamine> selectOrderSidAndContract(String saleOrderSid, String loanContractSid) {
 		return loanFileexamineService.selectOrderSidAndContract(saleOrderSid,loanContractSid);
 	}
+
+	@Override
+	public ResultBean<String> getToDoNum(RiskToDoNumQuery riskToDoNumQuery) {
+		return loanFileexamineService.getToDoNum(riskToDoNumQuery);
+	}
 }
diff --git a/anrui-riskcenter/anrui-riskcenter-biz/src/main/java/com/yxt/anrui/riskcenter/biz/loanfileexamine/LoanFileexamineService.java b/anrui-riskcenter/anrui-riskcenter-biz/src/main/java/com/yxt/anrui/riskcenter/biz/loanfileexamine/LoanFileexamineService.java
index dd006a0b76..3f667faaa7 100644
--- a/anrui-riskcenter/anrui-riskcenter-biz/src/main/java/com/yxt/anrui/riskcenter/biz/loanfileexamine/LoanFileexamineService.java
+++ b/anrui-riskcenter/anrui-riskcenter-biz/src/main/java/com/yxt/anrui/riskcenter/biz/loanfileexamine/LoanFileexamineService.java
@@ -47,6 +47,7 @@ import com.yxt.anrui.portal.api.sysuser.SysUserFeign;
 import com.yxt.anrui.riskcenter.api.loanfile.LoanFileEnum;
 import com.yxt.anrui.riskcenter.api.loanfileexamine.*;
 import com.yxt.anrui.riskcenter.api.loanhomevisitfileexamine.LoanHomevisitFileexamineVo;
+import com.yxt.anrui.riskcenter.api.loanhomevisitinvestigate.RiskToDoNumQuery;
 import com.yxt.anrui.riskcenter.api.loanhomevisitinvestigatefile.LoanAttachTypeEnum;
 import com.yxt.anrui.riskcenter.api.loanhomevisitinvestigatefile.LoanHomevisitInvestigateFileDetailsVo;
 import com.yxt.anrui.riskcenter.api.loanhomevisitinvestigatefile.LoanHomevisitInvestigateFileDto;
@@ -509,4 +510,12 @@ public class LoanFileexamineService extends MybatisBaseService<LoanFileexamineMa
         }
         return rb.success().setData(loanFileexamine);
     }
+
+    public ResultBean<String> getToDoNum(RiskToDoNumQuery riskToDoNumQuery) {
+        ResultBean rb = ResultBean.fireFail();
+        String userSid = riskToDoNumQuery.getUserSid();
+        String orgPath = riskToDoNumQuery.getOrgPath();
+        int count = baseMapper.getToDoNum(orgPath, userSid);
+        return rb.success().setData(String.valueOf(count));
+    }
 }
\ No newline at end of file
diff --git a/anrui-riskcenter/anrui-riskcenter-biz/src/main/java/com/yxt/anrui/riskcenter/biz/loanhomevisitfileexamine/LoanHomevisitFileexamineService.java b/anrui-riskcenter/anrui-riskcenter-biz/src/main/java/com/yxt/anrui/riskcenter/biz/loanhomevisitfileexamine/LoanHomevisitFileexamineService.java
index dbc97bc262..b7b36e32bf 100644
--- a/anrui-riskcenter/anrui-riskcenter-biz/src/main/java/com/yxt/anrui/riskcenter/biz/loanhomevisitfileexamine/LoanHomevisitFileexamineService.java
+++ b/anrui-riskcenter/anrui-riskcenter-biz/src/main/java/com/yxt/anrui/riskcenter/biz/loanhomevisitfileexamine/LoanHomevisitFileexamineService.java
@@ -667,7 +667,7 @@ public class LoanHomevisitFileexamineService extends MybatisBaseService<LoanHome
                 PushMessageQuery pushMessageQuery = new PushMessageQuery();
                 pushMessageQuery.setReceivedSids(receIveUserSidList);
                 pushMessageQuery.setModuleName("风控");
-                pushMessageQuery.setMsgContent("贷款人" + busSalesOrderBorrowerDetailsVo.getBorrowerName() + saleOrderPushMessage.getProblemRemarks());
+                pushMessageQuery.setMsgContent(busSalesOrderBorrowerDetailsVo.getBorrowerName() + "的家访资料存在问题：" + saleOrderPushMessage.getProblemRemarks());
                 pushMessageQuery.setApp_type("2");
                 pushMessageQuery.setModuleSid("fec4e243-491a-11ec-94cd-fa163e0cb33c");
                 pushMessageQuery.setMsgTitle("家访资料问题反馈");
diff --git a/anrui-riskcenter/anrui-riskcenter-biz/src/main/java/com/yxt/anrui/riskcenter/biz/loanhomevisitinvestigate/LoanHomevisitInvestigateMapper.java b/anrui-riskcenter/anrui-riskcenter-biz/src/main/java/com/yxt/anrui/riskcenter/biz/loanhomevisitinvestigate/LoanHomevisitInvestigateMapper.java
index 0436153195..bf32aac60b 100644
--- a/anrui-riskcenter/anrui-riskcenter-biz/src/main/java/com/yxt/anrui/riskcenter/biz/loanhomevisitinvestigate/LoanHomevisitInvestigateMapper.java
+++ b/anrui-riskcenter/anrui-riskcenter-biz/src/main/java/com/yxt/anrui/riskcenter/biz/loanhomevisitinvestigate/LoanHomevisitInvestigateMapper.java
@@ -84,4 +84,6 @@ public interface LoanHomevisitInvestigateMapper extends BaseMapper<LoanHomevisit
 
     @Update("update loan_homevisit_investigate set state = #{state},investigateKey = '',investigateValue = '' where sid = #{sid}")
     void updateState(@Param("sid") String sid, @Param("state") String state);
+
+    int getToDoNum(@Param("orgPath") String orgPath,@Param("userSid") String userSid);
 }
\ No newline at end of file
diff --git a/anrui-riskcenter/anrui-riskcenter-biz/src/main/java/com/yxt/anrui/riskcenter/biz/loanhomevisitinvestigate/LoanHomevisitInvestigateMapper.xml b/anrui-riskcenter/anrui-riskcenter-biz/src/main/java/com/yxt/anrui/riskcenter/biz/loanhomevisitinvestigate/LoanHomevisitInvestigateMapper.xml
index a3a9e2b770..4bd4ebf3fe 100644
--- a/anrui-riskcenter/anrui-riskcenter-biz/src/main/java/com/yxt/anrui/riskcenter/biz/loanhomevisitinvestigate/LoanHomevisitInvestigateMapper.xml
+++ b/anrui-riskcenter/anrui-riskcenter-biz/src/main/java/com/yxt/anrui/riskcenter/biz/loanhomevisitinvestigate/LoanHomevisitInvestigateMapper.xml
@@ -75,16 +75,32 @@
     </select>
 
     <select id="selectName" resultType="java.lang.String">
-        select bb.borrowerName from loan_homevisit_investigate li left join
-            anrui_buscenter.bus_sales_order_borrower bb on bb.sid = li.saleOrderBorrowerSid
+        select bb.borrowerName
+        from loan_homevisit_investigate li
+                     left join
+                     anrui_buscenter.bus_sales_order_borrower bb on bb.sid = li.saleOrderBorrowerSid
         where li.sid = #{sid}
     </select>
 
     <update id="setState">
-        update anrui_buscenter.bus_sales_order_borrower set state = 0 where sid = #{saleOrderBorrowerSid}
+        update anrui_buscenter.bus_sales_order_borrower
+        set state = 0
+        where sid = #{saleOrderBorrowerSid}
     </update>
 
     <update id="setState2">
-        update anrui_buscenter.bus_sales_order_loancontract set state = 0 where borrowerSid = #{saleOrderBorrowerSid}
+        update anrui_buscenter.bus_sales_order_loancontract
+        set state = 0
+        where borrowerSid = #{saleOrderBorrowerSid}
     </update>
+
+    <select id="getToDoNum" resultType="int">
+        SELECT COUNT(*)
+        FROM loan_homevisit_investigate li
+                     LEFT JOIN anrui_buscenter.`bus_sales_order` bo
+                ON li.`saleOrderSid` = bo.`sid`
+        WHERE bo.createBySid = #{userSid}
+          AND bo.orgSidPath = #{orgPath}
+          AND li.`state` = '1'
+    </select>
 </mapper>
\ No newline at end of file
diff --git a/anrui-riskcenter/anrui-riskcenter-biz/src/main/java/com/yxt/anrui/riskcenter/biz/loanhomevisitinvestigate/LoanHomevisitInvestigateRest.java b/anrui-riskcenter/anrui-riskcenter-biz/src/main/java/com/yxt/anrui/riskcenter/biz/loanhomevisitinvestigate/LoanHomevisitInvestigateRest.java
index fd6bfc9ccb..abfd1785ce 100644
--- a/anrui-riskcenter/anrui-riskcenter-biz/src/main/java/com/yxt/anrui/riskcenter/biz/loanhomevisitinvestigate/LoanHomevisitInvestigateRest.java
+++ b/anrui-riskcenter/anrui-riskcenter-biz/src/main/java/com/yxt/anrui/riskcenter/biz/loanhomevisitinvestigate/LoanHomevisitInvestigateRest.java
@@ -223,4 +223,9 @@ public class LoanHomevisitInvestigateRest implements LoanHomevisitInvestigateFei
     public ResultBean<LoanHomeVisitInvestigateInitZLVo> details2(String sid) {
         return loanHomevisitInvestigateService.details2(sid);
     }
+
+    @Override
+    public ResultBean<String> getToDoNum(RiskToDoNumQuery riskToDoNumQuery) {
+        return loanHomevisitInvestigateService.getToDoNum(riskToDoNumQuery);
+    }
 }
diff --git a/anrui-riskcenter/anrui-riskcenter-biz/src/main/java/com/yxt/anrui/riskcenter/biz/loanhomevisitinvestigate/LoanHomevisitInvestigateService.java b/anrui-riskcenter/anrui-riskcenter-biz/src/main/java/com/yxt/anrui/riskcenter/biz/loanhomevisitinvestigate/LoanHomevisitInvestigateService.java
index b48adab4e8..61f36d303a 100644
--- a/anrui-riskcenter/anrui-riskcenter-biz/src/main/java/com/yxt/anrui/riskcenter/biz/loanhomevisitinvestigate/LoanHomevisitInvestigateService.java
+++ b/anrui-riskcenter/anrui-riskcenter-biz/src/main/java/com/yxt/anrui/riskcenter/biz/loanhomevisitinvestigate/LoanHomevisitInvestigateService.java
@@ -1732,4 +1732,12 @@ public class LoanHomevisitInvestigateService extends MybatisBaseService<LoanHome
     public void updateState(String sid, String state) {
         baseMapper.updateState(sid,state);
     }
+
+    public ResultBean<String> getToDoNum(RiskToDoNumQuery riskToDoNumQuery) {
+        ResultBean rb = ResultBean.fireFail();
+        String userSid = riskToDoNumQuery.getUserSid();
+        String orgPath = riskToDoNumQuery.getOrgPath();
+        int count = baseMapper.getToDoNum(orgPath, userSid);
+        return rb.success().setData(String.valueOf(count));
+    }
 }
\ No newline at end of file
diff --git a/anrui-riskcenter/anrui-riskcenter-biz/src/main/java/com/yxt/anrui/riskcenter/biz/loanpreloancreditapply/LoanPreloanCreditApplyService.java b/anrui-riskcenter/anrui-riskcenter-biz/src/main/java/com/yxt/anrui/riskcenter/biz/loanpreloancreditapply/LoanPreloanCreditApplyService.java
index 2bc8804c9f..575dfa1436 100644
--- a/anrui-riskcenter/anrui-riskcenter-biz/src/main/java/com/yxt/anrui/riskcenter/biz/loanpreloancreditapply/LoanPreloanCreditApplyService.java
+++ b/anrui-riskcenter/anrui-riskcenter-biz/src/main/java/com/yxt/anrui/riskcenter/biz/loanpreloancreditapply/LoanPreloanCreditApplyService.java
@@ -26,6 +26,7 @@
 package com.yxt.anrui.riskcenter.biz.loanpreloancreditapply;
 
 import cn.hutool.core.bean.BeanUtil;
+import cn.hutool.core.date.DateUtil;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.yxt.anrui.base.api.commonappendix.CommonAppendixDto;
@@ -33,6 +34,7 @@ import com.yxt.anrui.base.api.commonappendix.CommonAppendixFeign;
 import com.yxt.anrui.base.api.commonappendix.CommonAppendixSelectQuery;
 import com.yxt.anrui.base.api.commonappendix.CommonAppendixVo;
 import com.yxt.anrui.crm.api.crmcustomertemp.CrmCustomerTempFeign;
+import com.yxt.anrui.portal.api.sysparameter.SysParameterFeign;
 import com.yxt.anrui.riskcenter.api.loancreditappealapply.LoanCreditAppealApply;
 import com.yxt.anrui.riskcenter.api.loanfinpolicy.LoanFinPolicy;
 import com.yxt.anrui.riskcenter.api.loanpreloancreditapply.*;
@@ -51,6 +53,7 @@ import com.yxt.anrui.portal.api.sysuser.SysUserFeign;
 import com.yxt.anrui.riskcenter.biz.loansolutions.LoanSolutionsService;
 import com.yxt.common.base.config.component.FileUploadComponent;
 import com.yxt.common.base.service.MybatisBaseService;
+import com.yxt.common.base.utils.DateUtils;
 import com.yxt.common.base.utils.PagerUtil;
 import com.yxt.common.core.query.PagerQuery;
 import com.yxt.common.core.result.ResultBean;
@@ -60,9 +63,7 @@ import org.apache.poi.ss.formula.functions.Now;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
-import java.util.ArrayList;
-import java.util.Collections;
-import java.util.List;
+import java.util.*;
 
 @Service
 public class LoanPreloanCreditApplyService extends MybatisBaseService<LoanPreloanCreditApplyMapper, LoanPreloanCreditApply> {
@@ -82,7 +83,7 @@ public class LoanPreloanCreditApplyService extends MybatisBaseService<LoanPreloa
     @Autowired
     private LoanFinPolicyService loanFinPolicyService;
     @Autowired
-    private LoanParameterService loanParameterService;
+    private SysParameterFeign sysParameterFeign;
     @Autowired
     private CrmCustomerTempFeign crmCustomerTempFeign;
 
@@ -564,8 +565,12 @@ public class LoanPreloanCreditApplyService extends MybatisBaseService<LoanPreloa
             return rb.setMsg("保存失败");
         }
         String sid = stringResultBean.getData();
-        String dqxyshyxq = loanParameterService.fetchByParNo("DQXYSHYXQ").getData();
-        baseMapper.updateStateBySid(sid, 2, dqxyshyxq);
+        String dqxyshyxq = sysParameterFeign.fetchByParNo("DQXYSHYXQ").getData();
+        Calendar calendar = Calendar.getInstance();
+        calendar.setTime(new Date());
+        calendar.add(Calendar.DATE,Integer.parseInt(dqxyshyxq));
+        Date time = calendar.getTime();
+        baseMapper.updateStateBySid(sid, 2, DateUtil.formatDate(time));
         return rb.success();
     }