From c77ab6ee3e6281914de4356a79c07876e199eec9 Mon Sep 17 00:00:00 2001
From: xuyang <748613696@qq.com>
Date: Tue, 22 Aug 2023 10:05:30 +0800
Subject: [PATCH] =?UTF-8?q?=E6=B6=88=E6=81=AF=E9=85=8D=E7=BD=AE=E5=8A=9F?=
 =?UTF-8?q?=E8=83=BD=E8=B0=83=E6=95=B4?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../com/njcn/cssystem/api/AppInfoSetFeignClient.java   |  6 ++++--
 .../fallback/AppInfoSetFeignClientFallbackFactory.java |  6 ++++++
 .../controller/messageConfig/AppInfoSetController.java | 10 ++++++++++
 3 files changed, 20 insertions(+), 2 deletions(-)

diff --git a/cs-system/cs-system-api/src/main/java/com/njcn/cssystem/api/AppInfoSetFeignClient.java b/cs-system/cs-system-api/src/main/java/com/njcn/cssystem/api/AppInfoSetFeignClient.java
index b04f51e..ca4a947 100644
--- a/cs-system/cs-system-api/src/main/java/com/njcn/cssystem/api/AppInfoSetFeignClient.java
+++ b/cs-system/cs-system-api/src/main/java/com/njcn/cssystem/api/AppInfoSetFeignClient.java
@@ -4,9 +4,9 @@ import com.njcn.common.pojo.constant.ServerInfo;
 import com.njcn.common.pojo.response.HttpResult;
 import com.njcn.cssystem.api.fallback.AppInfoSetFeignClientFallbackFactory;
 import com.njcn.cssystem.pojo.po.AppInfoSet;
-import io.swagger.annotations.ApiOperation;
 import org.springframework.cloud.openfeign.FeignClient;
 import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
 
 /**
  * @author xy
@@ -15,8 +15,10 @@ import org.springframework.web.bind.annotation.PostMapping;
 
 public interface AppInfoSetFeignClient {
 
+    @PostMapping("/add")
+    HttpResult<String> add(@RequestBody AppInfoSet appInfoSet);
+
     @PostMapping("/queryByUserId")
-    @ApiOperation("查看用户消息推送配置")
     HttpResult<AppInfoSet> queryByUserId();
 
 }
diff --git a/cs-system/cs-system-api/src/main/java/com/njcn/cssystem/api/fallback/AppInfoSetFeignClientFallbackFactory.java b/cs-system/cs-system-api/src/main/java/com/njcn/cssystem/api/fallback/AppInfoSetFeignClientFallbackFactory.java
index 535b35c..367d785 100644
--- a/cs-system/cs-system-api/src/main/java/com/njcn/cssystem/api/fallback/AppInfoSetFeignClientFallbackFactory.java
+++ b/cs-system/cs-system-api/src/main/java/com/njcn/cssystem/api/fallback/AppInfoSetFeignClientFallbackFactory.java
@@ -31,6 +31,12 @@ public class AppInfoSetFeignClientFallbackFactory implements FallbackFactory<App
         Enum<?> finalExceptionEnum = exceptionEnum;
         return new AppInfoSetFeignClient() {
 
+            @Override
+            public HttpResult<String> add(AppInfoSet appInfoSet) {
+                log.error("{}异常，降级处理，异常为：{}","新增用户消息推送配置",cause.toString());
+                throw new BusinessException(finalExceptionEnum);
+            }
+
             @Override
             public HttpResult<AppInfoSet> queryByUserId() {
                 log.error("{}异常，降级处理，异常为：{}","查看用户消息推送配置",cause.toString());
diff --git a/cs-system/cs-system-boot/src/main/java/com/njcn/cssystem/controller/messageConfig/AppInfoSetController.java b/cs-system/cs-system-boot/src/main/java/com/njcn/cssystem/controller/messageConfig/AppInfoSetController.java
index 46c0893..9e09f6e 100644
--- a/cs-system/cs-system-boot/src/main/java/com/njcn/cssystem/controller/messageConfig/AppInfoSetController.java
+++ b/cs-system/cs-system-boot/src/main/java/com/njcn/cssystem/controller/messageConfig/AppInfoSetController.java
@@ -35,6 +35,16 @@ public class AppInfoSetController extends BaseController {
 
     private final IAppInfoSetService appInfoSetService;
 
+    @OperateInfo(info = LogEnum.BUSINESS_COMMON)
+    @PostMapping("/add")
+    @ApiOperation("新增用户消息推送配置")
+    @ApiImplicitParam(name = "appInfoSet", value = "参数实体", required = true)
+    public HttpResult<String> add(@RequestBody AppInfoSet appInfoSet){
+        String methodDescribe = getMethodDescribe("add");
+        appInfoSetService.save(appInfoSet);
+        return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, "success", methodDescribe);
+    }
+
     @OperateInfo(info = LogEnum.BUSINESS_COMMON)
     @PostMapping("/queryByUserId")
     @ApiOperation("查看用户消息推送配置")