浏览代码

增加修改风控配置模版

marxjaw 5 月之前
父节点
当前提交
641d7f5da2

+ 9 - 0
yt-agent/agent-service/src/main/java/com/ytpm/controller/RiskController.java

@@ -107,6 +107,15 @@ public class RiskController {
         return riskFeign.saveConfig(param);
     }
 
+    /**
+     * 修改风控配置
+     */
+    @ApiOperation("修改风控配置")
+    @PostMapping("/updateConfig")
+    public Result<?> updateConfig(@RequestBody RiskConfigParam param){
+        return riskFeign.updateConfig(param);
+    }
+
     /**
      * 查询配置字段选项
      */

+ 3 - 0
yt-risk/risk-feign/src/main/java/com/ytpm/feign/RiskFeign.java

@@ -47,6 +47,9 @@ public interface RiskFeign {
     @PostMapping("/riskConfig/saveConfig")
     Result<?> saveConfig(@RequestBody RiskConfigParam param);
 
+    @PostMapping("/riskConfig/updateConfig")
+    Result<?> updateConfig(@RequestBody RiskConfigParam param);
+
     @GetMapping("/riskConfig/options")
     ResultTable<RiskConfigView> getRiskConfig();
 

+ 10 - 0
yt-risk/risk-manage/src/main/java/com/ytpm/controller/RiskConfigController.java

@@ -78,4 +78,14 @@ public class RiskConfigController {
     public Result<RiskTemplateView> templateView(@RequestParam("templateId")String templateId,@ApiIgnore @AuthenticationPrincipal AgentUserInfo userInfo){
         return riskService.templateView(templateId,userInfo.getUserId());
     }
+
+    /**
+     * 修改风控配置模版
+     */
+    @ApiOperation("修改风控配置模版")
+    @PostMapping("/updateConfig")
+    public Result<?> updateConfig(@RequestBody RiskConfigParam param, @ApiIgnore @AuthenticationPrincipal AgentUserInfo userInfo){
+        param.setChannelId(userInfo.getUserId());
+        return riskService.updateConfig(param);
+    }
 }

+ 5 - 0
yt-risk/risk-manage/src/main/java/com/ytpm/dao/RiskConfigMapper.java

@@ -42,4 +42,9 @@ public interface RiskConfigMapper {
      * 风控配置模板详情
      */
     RiskTemplateView getTemplateView(@Param("templateId") String templateId, @Param("channelId") String channelId);
+
+    /**
+     * 修改配置值
+     */
+    void updateConfigVal(YtRiskConfig config);
 }

+ 5 - 0
yt-risk/risk-manage/src/main/java/com/ytpm/service/RiskService.java

@@ -62,4 +62,9 @@ public interface RiskService {
      * 风控配置模板详情
      */
     Result<RiskTemplateView> templateView(String templateId, String channelId);
+
+    /**
+     * 修改风控配置模版
+     */
+    Result<?> updateConfig(RiskConfigParam param);
 }

+ 34 - 0
yt-risk/risk-manage/src/main/java/com/ytpm/service/impl/RiskServiceImpl.java

@@ -91,6 +91,7 @@ public class RiskServiceImpl extends ReflectUtil implements RiskService {
      * 保存风控配置
      */
     @Override
+    @Transactional(rollbackFor = Exception.class)
     public Result<?> saveConfig(RiskConfigParam param) {
         List<RiskConfigListParam> configList = param.getConfigList();
         if(CollUtil.isEmpty(param.getConfigList())){
@@ -244,6 +245,39 @@ public class RiskServiceImpl extends ReflectUtil implements RiskService {
         return Result.resultObjOk(configMapper.getTemplateView(templateId,channelId));
     }
 
+    /**
+     * 修改风控配置模版
+     */
+    @Override
+    @Transactional(rollbackFor = Exception.class)
+    public Result<?> updateConfig(RiskConfigParam param) {
+        YtRiskTemplate old = configMapper.selectOneTemplate(param.getTemplateId());
+        if(Objects.isNull(old)){
+            return Result.resultErr(RepMessage.OBJECT_NOT_EXIST);
+        }
+        //修改配置值
+        List<RiskConfigListParam> configList = param.getConfigList();
+        StringBuilder content = new StringBuilder();
+        for (RiskConfigListParam listParam : configList) {
+            YtRiskConfig config = new YtRiskConfig();
+            config.setConfigId(listParam.getConfigId());
+            config.setConfigVal(listParam.getConfigVal());
+            configMapper.updateConfigVal(config);
+            String format = String.format(config.getFieldDesc(), config.getConfigVal());
+            if(StrUtil.isNotBlank(format)){
+                content.append(format).append(",");
+            }
+        }
+        //同步修改配置模版内容
+        YtRiskTemplate template = new YtRiskTemplate();
+        BeanUtil.copyProperties(param,template);
+        template.setTemplateContent(content.toString());
+        template.setUpdateTime(new Date());
+        template.setUpdateUserId(param.getChannelId());
+        configMapper.updateByTempId(template);
+        return Result.resultOk(RepMessage.MODIFY_SUCCESS);
+    }
+
     /**
      * 修改用户信息
      */

+ 3 - 0
yt-risk/risk-manage/src/main/resources/mapper/RiskConfigMapper.xml

@@ -79,6 +79,9 @@
         </set>
         where template_id = #{templateId}
     </update>
+    <update id="updateConfigVal">
+        update yt_risk_config set config_val = #{configVal} where config_id = #{configId}
+    </update>
     <select id="getRiskConfigList" resultType="com.ytpm.risk.view.RiskConfigListView">
         SELECT
             t.app_id,