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 add(@RequestBody AppInfoSet appInfoSet); + @PostMapping("/queryByUserId") - @ApiOperation("查看用户消息推送配置") HttpResult 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 finalExceptionEnum = exceptionEnum; return new AppInfoSetFeignClient() { + @Override + public HttpResult add(AppInfoSet appInfoSet) { + log.error("{}异常,降级处理,异常为:{}","新增用户消息推送配置",cause.toString()); + throw new BusinessException(finalExceptionEnum); + } + @Override public HttpResult 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 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("查看用户消息推送配置")