渠道信息编辑

src/main/java/cn/quantgroup/cashloanflowboss/api/channel/controller/ChannelConfController.java

@@ -6,6 +6,7 @@ import cn.quantgroup.cashloanflowboss.component.security.annotiation.Security;
 import cn.quantgroup.cashloanflowboss.core.annotation.ChannelIdInit;
 import cn.quantgroup.cashloanflowboss.core.annotation.CheckChannelRole;
 import cn.quantgroup.cashloanflowboss.core.base.Result;
+import cn.quantgroup.cashloanflowboss.spi.clf.service.CLFCenterService;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.*;
 
@@ -23,6 +24,8 @@ public class ChannelConfController {
 
     @Autowired
     private ChannelConfService channelConfService;
+    @Autowired
+    private CLFCenterService clfCenterService;
 
 
     /**
@@ -67,7 +70,14 @@ public class ChannelConfController {
     @CheckChannelRole(isObjParam = true, paramClazz = ChannelConfVo.class)
     @PostMapping("/cfg/info")
     public Result editChannelConfInfo(@RequestBody @Valid ChannelConfVo channelConfVo) {
-        return Result.buildSuccess(channelConfService.editChannelConfInfo(channelConfVo));
+        Boolean aBoolean = channelConfService.editChannelConfInfo(channelConfVo);
+
+        if (aBoolean) {
+            // 属性ka缓存
+            clfCenterService.reloadKAConfiguration();
+        }
+
+        return Result.buildSuccess(aBoolean ? "编辑修改成功" : "编辑修改失败");
     }
 
 

src/main/java/cn/quantgroup/cashloanflowboss/spi/clf/service/CLFCenter.java

@@ -2,6 +2,7 @@ package cn.quantgroup.cashloanflowboss.spi.clf.service;
 
 import org.springframework.cloud.netflix.feign.FeignClient;
 import org.springframework.stereotype.Component;
+import org.springframework.web.bind.annotation.GetMapping;
 import org.springframework.web.bind.annotation.PostMapping;
 import org.springframework.web.bind.annotation.RequestParam;
 
@@ -10,14 +11,22 @@ import org.springframework.web.bind.annotation.RequestParam;
 public interface CLFCenter {
 
     @PostMapping(value = "/test//loanMq/batch", consumes = "application/x-www-form-urlencoded")
-  public void loanMq(@RequestParam("json") String loanMq);
+    void loanMq(@RequestParam("json") String loanMq);
+
+    @GetMapping(value = "/configuration/lPm6usTlPYLqtDPQHIldvszWakDHlDh4", consumes = "application/x-www-form-urlencoded")
+    void reloadKASetting(@RequestParam("token") String token);
 
     @Component
     class Fallback implements CLFCenter {
 
         @Override
         public void loanMq(String loanMq) {
-      return ;
+            return;
+        }
+
+        @Override
+        public void reloadKASetting(String token) {
+
         }
     }
 

src/main/java/cn/quantgroup/cashloanflowboss/spi/clf/service/CLFCenterService.java

@@ -34,4 +34,6 @@ public interface CLFCenterService {
     void saveOrderCall(List<ClfOrderCallBack> clfOrderCallBackList);
 
     ClfOrderCallBack findOrderCallBackByByCallbackStatusAndChannelId(String name, Long channelId);
+
+    void reloadKAConfiguration();
 }

src/main/java/cn/quantgroup/cashloanflowboss/spi/clf/service/CLFCenterServiceImpl.java

@@ -25,6 +25,9 @@ import java.util.Objects;
 public class CLFCenterServiceImpl implements CLFCenterService{
 
 
+    @Autowired
+    private CLFCenter clfCenter;
+
     @Autowired
     private CallbackFailRecordRepository callbackFailRecordRepository;
     @Autowired
@@ -132,4 +135,9 @@ public class CLFCenterServiceImpl implements CLFCenterService{
     public ClfOrderCallBack findOrderCallBackByByCallbackStatusAndChannelId(String kaNoticeName, Long channelId) {
         return clfOrderCallbackRepository.findByCallbackStatusAndRegisteredFrom(kaNoticeName, channelId);
     }
+
+    @Override
+    public void reloadKAConfiguration() {
+        clfCenter.reloadKASetting("");
+    }
 }