金融产品政策

anrui-riskcenter/anrui-riskcenter-api/src/main/java/com/yxt/anrui/riskcenter/api/loanfinpolicy/LoanFinPolicyFeign.java

@@ -33,9 +33,13 @@ public interface LoanFinPolicyFeign {
     @DeleteMapping("deletePolicy")
     ResultBean deletePolicy(@RequestBody String[] sids);
 
-    @ApiOperation("停用、开启:useState为1时走停用，为0时走开启")
+    @ApiOperation("使用状态停用、开启:useState为1时走停用，为0时走开启")
     @PostMapping("setState")
-    ResultBean setState(@RequestParam("sid") String sid, @RequestParam("useState") String useState);
+    ResultBean setState(@RequestBody LoanFinPolicyStateQuery query);
+
+    @ApiOperation("风控状态禁用、启用:useState为1时走禁用，为0时走启用")
+    @PostMapping("setRiskState")
+    ResultBean setRiskState(@RequestBody LoanRiskStateQuery query);
 
     @ApiOperation("金融产品政策管理分页列表")
     @PostMapping("pagerList")

anrui-riskcenter/anrui-riskcenter-api/src/main/java/com/yxt/anrui/riskcenter/api/loanfinpolicy/LoanFinPolicyStateQuery.java

@@ -0,0 +1,20 @@
+package com.yxt.anrui.riskcenter.api.loanfinpolicy;
+
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+import java.util.ArrayList;
+import java.util.List;
+
+/**
+ * @description:
+ * @author: dimengzhe
+ * @date: 2023/7/11
+ **/
+@Data
+public class LoanFinPolicyStateQuery {
+    @ApiModelProperty("sids")
+    private List<String> sidsList = new ArrayList<>();
+    @ApiModelProperty("useState为1时走停用，为0时走开启")
+    private String useState;
+}

anrui-riskcenter/anrui-riskcenter-api/src/main/java/com/yxt/anrui/riskcenter/api/loanfinpolicy/LoanRiskStateQuery.java

@@ -0,0 +1,21 @@
+package com.yxt.anrui.riskcenter.api.loanfinpolicy;
+
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+import java.util.ArrayList;
+import java.util.List;
+
+/**
+ * @description:
+ * @author: dimengzhe
+ * @date: 2023/7/11
+ **/
+@Data
+public class LoanRiskStateQuery {
+
+    @ApiModelProperty("sids")
+    private List<String> sidsList = new ArrayList<>();
+    @ApiModelProperty("riskState为1时走禁用，为0时走启用")
+    private String riskState;
+}

anrui-riskcenter/anrui-riskcenter-biz/src/main/java/com/yxt/anrui/riskcenter/biz/loanfinpolicy/LoanFinPolicyMapper.xml

@@ -12,7 +12,7 @@
                    when 0 then '正常'
                    end                   as riskStateValue,
                case lfp.useSate
-                   when 1 then '禁用'
+                   when 1 then '停用'
                    when 0 then '正常'
                    end                   as useSateValue,
                lfp.validDateTo,

anrui-riskcenter/anrui-riskcenter-biz/src/main/java/com/yxt/anrui/riskcenter/biz/loanfinpolicy/LoanFinPolicyRest.java

@@ -38,8 +38,13 @@ public class LoanFinPolicyRest implements LoanFinPolicyFeign {
     }
 
     @Override
-    public ResultBean setState(String sid, String useState) {
-        return loanFinPolicyService.setState(sid, useState);
+    public ResultBean setState(LoanFinPolicyStateQuery query) {
+        return loanFinPolicyService.setState(query);
+    }
+
+    @Override
+    public ResultBean setRiskState(LoanRiskStateQuery query) {
+        return loanFinPolicyService.setRiskState(query);
     }
 
     @Override

anrui-riskcenter/anrui-riskcenter-biz/src/main/java/com/yxt/anrui/riskcenter/biz/loanfinpolicy/LoanFinPolicyService.java

@@ -21,8 +21,10 @@ import com.yxt.common.core.result.ResultBean;
 import com.yxt.common.core.vo.PagerVo;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
 
 import java.util.Arrays;
+import java.util.Collections;
 import java.util.List;
 import java.util.stream.Collectors;
 
@@ -182,12 +184,20 @@ public class LoanFinPolicyService extends MybatisBaseService<LoanFinPolicyMapper
         return rb.success();
     }
 
-    public ResultBean setState(String sid, String useState) {
+    @Transactional(rollbackFor = Exception.class)
+    public ResultBean setState(LoanFinPolicyStateQuery query) {
         ResultBean rb = ResultBean.fireFail();
         //ToDo:是否可以停用或开启，需补充条件
+        List<String> sidsList = query.getSidsList();
+        sidsList.removeAll(Collections.singleton(null));
+        if (sidsList.isEmpty()) {
+            return rb.setMsg("请选择数据");
+        }
+        String useState = query.getUseState();
+        for (String sid : sidsList) {
             LoanFinPolicy loanFinPolicy = fetchBySid(sid);
             if (loanFinPolicy == null) {
-            return rb.setMsg("该金融产品政策不存在");
+                return rb.setMsg("选择中包含金融产品政策不存在的数据，请刷新后操作");
             }
             loanFinPolicy.setUseSate(Integer.valueOf(useState).intValue());
             baseMapper.updateById(loanFinPolicy);
@@ -196,6 +206,7 @@ public class LoanFinPolicyService extends MybatisBaseService<LoanFinPolicyMapper
                 loanFinOtherPolicy.setUseSate(Integer.valueOf(useState).intValue());
                 loanFinOtherPolicyService.updateById(loanFinOtherPolicy);
             }
+        }
         return rb.success();
     }
 
@@ -299,4 +310,30 @@ public class LoanFinPolicyService extends MybatisBaseService<LoanFinPolicyMapper
         PagerVo<LoanFinPolicyVos> p = PagerUtil.pageToVo(pagging, null);
         return p;
     }
+
+    @Transactional(rollbackFor = Exception.class)
+    public ResultBean setRiskState(LoanRiskStateQuery query) {
+        ResultBean rb = ResultBean.fireFail();
+        //ToDo:是否可以停用或开启，需补充条件
+        List<String> sidsList = query.getSidsList();
+        sidsList.removeAll(Collections.singleton(null));
+        if (sidsList.isEmpty()) {
+            return rb.setMsg("请选择数据");
+        }
+        String riskState = query.getRiskState();
+        for (String sid : sidsList) {
+            LoanFinPolicy loanFinPolicy = fetchBySid(sid);
+            if (loanFinPolicy == null) {
+                return rb.setMsg("选择中包含金融产品政策不存在的数据，请刷新后操作");
+            }
+            loanFinPolicy.setRiskState(Integer.valueOf(riskState).intValue());
+            baseMapper.updateById(loanFinPolicy);
+            LoanFinOtherPolicy loanFinOtherPolicy = loanFinOtherPolicyService.selectByMainSid(sid);
+            if (loanFinOtherPolicy != null) {
+                loanFinOtherPolicy.setRiskState(Integer.valueOf(riskState).intValue());
+                loanFinOtherPolicyService.updateById(loanFinOtherPolicy);
+            }
+        }
+        return rb.success();
+    }
 }