销售订单车辆表添加风控专员字段

逾期车辆列表分配风控专员接口开发
逾期车辆列表返回销售订单车辆表sid
根据组织全路径查询当前部门下的所有员工接口开发

anrui-buscenter/anrui-buscenter-api/src/main/java/com/yxt/anrui/buscenter/api/bussalesordervehicle/BusSalesOrderVehicle.java

@@ -75,4 +75,8 @@ public class BusSalesOrderVehicle extends BaseEntity {
     private String borrowName;
     @ApiModelProperty("消贷合同sid")
     private String loanContractSid;
+    @ApiModelProperty("风控专员用户sid")
+    private String riskStaffUserSid;
+    @ApiModelProperty("风控专员用户姓名")
+    private String riskStaffUserName;
 }

anrui-portal/anrui-portal-api/src/main/java/com/yxt/anrui/portal/api/sysstafforg/SysStaffOrgFeign.java

@@ -121,4 +121,9 @@ public interface SysStaffOrgFeign {
     @ApiOperation("根据分公司全路径和角色sid模糊查询本公司本角色下的所有员工userSid")
     ResultBean<List<SysStaffOrgByUserVo>> selAllByOrgPath(@RequestParam("orgSidPath") String orgSidPath,@RequestParam("roleSid") String roleSid);
 
+    @PostMapping("/selAllByOrgSidPath")
+    @ResponseBody
+    @ApiOperation("根据组织全路径查询当前部门下的所有员工")
+    ResultBean<List<SysStaffOrgByUserVo>> selAllByOrgSidPath(@RequestParam("orgSidPath") String orgSidPath);
+
 }

anrui-portal/anrui-portal-api/src/main/java/com/yxt/anrui/portal/api/sysstafforg/SysStaffOrgFeignFallback.java

@@ -110,6 +110,11 @@ public class SysStaffOrgFeignFallback implements SysStaffOrgFeign {
 		return null;
 	}
 
+	@Override
+	public ResultBean<List<SysStaffOrgByUserVo>> selAllByOrgSidPath(String orgSidPath) {
+		return null;
+	}
+
 	@Override
 	public ResultBean<SysStaffOrg> selectAllByStaffSid(String staffSid) {
 		return null;

anrui-portal/anrui-portal-biz/src/main/java/com/yxt/anrui/portal/biz/sysstafforg/SysStaffOrgMapper.java

@@ -117,4 +117,6 @@ public interface SysStaffOrgMapper extends BaseMapper<SysStaffOrg> {
     List<String> selectStaffByOrg(String orgSid);
 
     List<SysStaffOrgByUserVo> selAllByOrgPath(@Param(Constants.WRAPPER) QueryWrapper qw);
+
+    List<SysStaffOrgByUserVo> selAllByOrgSidPath(String orgSidPath);
 }

anrui-portal/anrui-portal-biz/src/main/java/com/yxt/anrui/portal/biz/sysstafforg/SysStaffOrgMapper.xml

@@ -147,4 +147,15 @@
             ${ew.sqlSegment}
         </where>
     </select>
+
+    <select id="selAllByOrgSidPath" resultType="com.yxt.anrui.portal.api.sysstafforg.SysStaffOrgByUserVo">
+        SELECT su.sid,
+               ss.`name`
+        FROM sys_staff_org so
+                     LEFT JOIN sys_user su
+                ON so.`staffSid` = su.`staffSid`
+                     LEFT JOIN sys_staffinfo ss
+                ON so.`staffSid` = ss.`sid`
+        WHERE so.`orgSidPath` = #{orgSidPath}
+    </select>
 </mapper>

anrui-portal/anrui-portal-biz/src/main/java/com/yxt/anrui/portal/biz/sysstafforg/SysStaffOrgRest.java

@@ -145,6 +145,11 @@ public class SysStaffOrgRest implements SysStaffOrgFeign {
         return sysStaffOrgService.selAllByOrgPath(orgSidPath,roleSid);
     }
 
+    @Override
+    public ResultBean<List<SysStaffOrgByUserVo>> selAllByOrgSidPath(String orgSidPath) {
+        return sysStaffOrgService.selAllByOrgSidPath(orgSidPath);
+    }
+
     @Override
     public ResultBean<SysStaffOrg> selectAllByStaffSid(String staffSid) {
         return sysStaffOrgService.selectAllByStaffSid(staffSid);

anrui-portal/anrui-portal-biz/src/main/java/com/yxt/anrui/portal/biz/sysstafforg/SysStaffOrgService.java

@@ -334,4 +334,10 @@ public class SysStaffOrgService extends MybatisBaseService<SysStaffOrgMapper, Sy
         orgPath = sysOrganizationService.getOrgSid(orgSid);
         return rb.success().setData(orgPath);
     }
+
+    public ResultBean<List<SysStaffOrgByUserVo>> selAllByOrgSidPath(String orgSidPath) {
+        ResultBean rb = ResultBean.fireFail();
+        List<SysStaffOrgByUserVo> sysStaffOrgByUserVoList = baseMapper.selAllByOrgSidPath(orgSidPath);
+        return rb.success().setData(sysStaffOrgByUserVoList);
+    }
 }

anrui-riskcenter/anrui-riskcenter-api/src/main/java/com/yxt/anrui/riskcenter/api/loanbeoverdueveh/LoanBeOverdueVehFegin.java

@@ -19,4 +19,8 @@ public interface LoanBeOverdueVehFegin {
     @ApiOperation("根据条件分页查询数据的列表")
     @PostMapping("/listPage")
     public ResultBean<PagerVo<LoanBeOverdueVehVo>> listPage(@RequestBody PagerQuery<LoanBeOverdueVehQuery> pq);
+
+    @ApiOperation("分配风控专员")
+    @PostMapping("/allocationRiskStaff")
+    public ResultBean allocationRiskStaff(@RequestParam("saleVehSid") String saleVehSid, @RequestParam("userSid") String userSid, @RequestParam("userName") String userName);
 }

anrui-riskcenter/anrui-riskcenter-api/src/main/java/com/yxt/anrui/riskcenter/api/loanbeoverdueveh/LoanBeOverdueVehVo.java

@@ -10,6 +10,8 @@ import java.util.Date;
 @Data
 public class LoanBeOverdueVehVo implements Vo {
 
+    @ApiModelProperty("销售订单车辆sid")
+    private String saleVehSid;
     @ApiModelProperty("分公司")
     private String useOrgName;
     @ApiModelProperty("销售部门")

anrui-riskcenter/anrui-riskcenter-biz/src/main/java/com/yxt/anrui/riskcenter/biz/loanbeoverdueveh/LoanBeOverdueVehMapper.java

@@ -17,4 +17,5 @@ public interface LoanBeOverdueVehMapper {
 
     IPage<LoanBeOverdueVehVo> selectPageVo(IPage<LoanBeOverdueVehVo> page, @Param(Constants.WRAPPER) Wrapper<LoanBeOverdueVehVo> qw);
 
+    void allocationRiskStaff(@Param("saleVehSid") String saleVehSid, @Param("userSid") String userSid, @Param("userName") String userName);
 }

anrui-riskcenter/anrui-riskcenter-biz/src/main/java/com/yxt/anrui/riskcenter/biz/loanbeoverdueveh/LoanBeOverdueVehMapper.xml

@@ -5,7 +5,8 @@
     <!--    ${ew.customSqlSegment} -->
 
     <select id="selectPageVo" resultType="com.yxt.anrui.riskcenter.api.loanbeoverdueveh.LoanBeOverdueVehVo">
-        SELECT a1.`useOrgName`,
+        SELECT a1.busVinSid     AS saleVehSid,
+               a1.`useOrgName`,
                a1.`dept`        AS saleDeptName,
                a1.`loanContractNo`,
                a1.borrowerName,
@@ -19,6 +20,7 @@
                SUM(a1.yd_dkje)  AS advMoney,
                SUM(a1.yd_zjzyf) AS fundPossCostMoney
         FROM (SELECT lrpd.sid,
+                     lrpd.busVinSid,
                      lrpd.`useOrgName`,
                      lrpd.`dept`,
                      lrpd.`loanContractNo`,
@@ -44,6 +46,15 @@
               GROUP BY lrpd.`sid`
               HAVING (yq_total > 0)) a1
         GROUP BY a1.loanContractNo,
-                 a1.vinNo
+                 a1.vinNo,
+                 a1.busVinSid
     </select>
+
+    <update id="allocationRiskStaff">
+        UPDATE
+                anrui_buscenter.`bus_sales_order_vehicle`
+        SET riskStaffUserSid  = #{userSid},
+            riskStaffUserName = #{userName}
+        WHERE sid = #{saleVehSid}
+    </update>
 </mapper>

anrui-riskcenter/anrui-riskcenter-biz/src/main/java/com/yxt/anrui/riskcenter/biz/loanbeoverdueveh/LoanBeOverdueVehRest.java

@@ -26,4 +26,9 @@ public class LoanBeOverdueVehRest implements LoanBeOverdueVehFegin {
         PagerVo<LoanBeOverdueVehVo> pv = loanBeOverdueVehService.listPageVo(pq);
         return rb.success().setData(pv);
     }
+
+    @Override
+    public ResultBean allocationRiskStaff(String saleVehSid, String userSid, String userName) {
+        return loanBeOverdueVehService.allocationRiskStaff(saleVehSid, userSid, userName);
+    }
 }

anrui-riskcenter/anrui-riskcenter-biz/src/main/java/com/yxt/anrui/riskcenter/biz/loanbeoverdueveh/LoanBeOverdueVehService.java

@@ -17,7 +17,7 @@ import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
 @Service
-public class LoanBeOverdueVehService{
+public class LoanBeOverdueVehService {
 
     @Autowired
     private SysUserFeign sysUserFeign;
@@ -67,42 +67,48 @@ public class LoanBeOverdueVehService{
                 return p;
             }
         }
-        if (StringUtils.isNotBlank(query.getUseOrgName())){
-            qw.like("a1.useOrgName",query.getUseOrgName());
+        if (StringUtils.isNotBlank(query.getUseOrgName())) {
+            qw.like("a1.useOrgName", query.getUseOrgName());
         }
-        if (StringUtils.isNotBlank(query.getDept())){
-            qw.like("a1.dept",query.getDept());
+        if (StringUtils.isNotBlank(query.getDept())) {
+            qw.like("a1.dept", query.getDept());
         }
-        if (StringUtils.isNotBlank(query.getLoanContractNo())){
-            qw.like("a1.loanContractNo",query.getLoanContractNo());
+        if (StringUtils.isNotBlank(query.getLoanContractNo())) {
+            qw.like("a1.loanContractNo", query.getLoanContractNo());
         }
-        if (StringUtils.isNotBlank(query.getBorrowerName())){
-            qw.like("a1.borrowerName",query.getBorrowerName());
+        if (StringUtils.isNotBlank(query.getBorrowerName())) {
+            qw.like("a1.borrowerName", query.getBorrowerName());
         }
-        if (StringUtils.isNotBlank(query.getVinNo())){
-            qw.like("a1.vinNo",query.getVinNo());
+        if (StringUtils.isNotBlank(query.getVinNo())) {
+            qw.like("a1.vinNo", query.getVinNo());
         }
-        if (StringUtils.isNotBlank(query.getCarNum())){
-            qw.like("",query.getCarNum());
+        if (StringUtils.isNotBlank(query.getCarNum())) {
+            qw.like("", query.getCarNum());
         }
-        if (StringUtils.isNotBlank(query.getBankName())){
-            qw.like("a1.bankName",query.getBankName());
+        if (StringUtils.isNotBlank(query.getBankName())) {
+            qw.like("a1.bankName", query.getBankName());
         }
-        if (StringUtils.isNotBlank(query.getBankContractNo())){
-            qw.like("a1.bankContractNo",query.getBankContractNo());
+        if (StringUtils.isNotBlank(query.getBankContractNo())) {
+            qw.like("a1.bankContractNo", query.getBankContractNo());
         }
-        if (StringUtils.isNotBlank(query.getBeOverduePeriod())){
-            qw.having("beOverduePeriod = {0}",query.getBeOverduePeriod());
+        if (StringUtils.isNotBlank(query.getBeOverduePeriod())) {
+            qw.having("beOverduePeriod = {0}", query.getBeOverduePeriod());
         }
-        if (StringUtils.isNotBlank(query.getBeOverdueMoney())){
-            qw.like("beOverdueMoney = {0}",query.getBeOverdueMoney());
+        if (StringUtils.isNotBlank(query.getBeOverdueMoney())) {
+            qw.like("beOverdueMoney = {0}", query.getBeOverdueMoney());
         }
-        if (StringUtils.isNotBlank(query.getBeOverdueMoneyAndPeriod())){
-            qw.like("beOverdueMoneyAndPeriod = {0}",query.getBeOverdueMoneyAndPeriod());
+        if (StringUtils.isNotBlank(query.getBeOverdueMoneyAndPeriod())) {
+            qw.like("beOverdueMoneyAndPeriod = {0}", query.getBeOverdueMoneyAndPeriod());
         }
         IPage<LoanBeOverdueVehVo> page = PagerUtil.queryToPage(pq);
         IPage<LoanBeOverdueVehVo> pagging = loanBeOverdueVehMapper.selectPageVo(page, qw);
         PagerVo<LoanBeOverdueVehVo> p = PagerUtil.pageToVo(pagging, null);
         return p;
     }
+
+    public ResultBean allocationRiskStaff(String saleVehSid, String userSid, String userName) {
+        ResultBean rb = ResultBean.fireFail();
+        loanBeOverdueVehMapper.allocationRiskStaff(saleVehSid,userSid,userName);
+        return rb.success();
+    }
 }