微调

pqs-common/common-redis/src/main/java/com/njcn/redis/pojo/enums/AppRedisKey.java

@@ -53,4 +53,9 @@ public interface AppRedisKey {
 
     String TIME="time-:";
 
+    /**
+     * 文件分片信息
+     */
+    String FILE_PART="filePartKey:";
+
 }

pqs-user/user-api/src/main/java/com/njcn/user/api/AppUserFeignClient.java

@@ -0,0 +1,25 @@
+package com.njcn.user.api;
+
+import com.njcn.common.pojo.constant.ServerInfo;
+import com.njcn.common.pojo.response.HttpResult;
+import com.njcn.user.api.fallback.AppUserFeignClientFallbackFactory;
+import com.njcn.user.api.fallback.UserFeignClientFallbackFactory;
+import com.njcn.user.pojo.dto.UserDTO;
+import com.njcn.user.pojo.po.User;
+import org.springframework.cloud.openfeign.FeignClient;
+import org.springframework.web.bind.annotation.*;
+
+import java.util.List;
+
+/**
+ * @author hongawen
+ * @version 1.0.0
+ * @date 2021年05月08日 15:11
+ */
+@FeignClient(value = ServerInfo.USER,path = "/appUser",fallbackFactory = AppUserFeignClientFallbackFactory.class,contextId = "appUser")
+public interface AppUserFeignClient {
+
+    @PostMapping("/getAdminInfo")
+    HttpResult<List<User>> getAdminInfo();
+
+}

pqs-user/user-api/src/main/java/com/njcn/user/api/UserFeignClient.java

@@ -64,7 +64,4 @@ public interface UserFeignClient {
      */
     @PostMapping("/userByIdList")
     HttpResult<List<User>> getUserByIdList(@RequestBody List<String> ids);
-
-    @PostMapping("/getAdminInfo")
-    HttpResult<List<User>> getAdminInfo();
 }

pqs-user/user-api/src/main/java/com/njcn/user/api/fallback/AppUserFeignClientFallbackFactory.java

@@ -0,0 +1,50 @@
+package com.njcn.user.api.fallback;
+
+import com.njcn.common.pojo.enums.response.CommonResponseEnum;
+import com.njcn.common.pojo.exception.BusinessException;
+import com.njcn.common.pojo.response.HttpResult;
+import com.njcn.user.api.AppUserFeignClient;
+import com.njcn.user.api.UserFeignClient;
+import com.njcn.user.pojo.dto.UserDTO;
+import com.njcn.user.pojo.po.User;
+import com.njcn.user.utils.UserEnumUtil;
+import feign.hystrix.FallbackFactory;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Component;
+
+import java.util.List;
+
+/**
+ * @author hongawen
+ * @version 1.0.0
+ * @date 2021年08月24日 10:21
+ */
+@Slf4j
+@Component
+public class AppUserFeignClientFallbackFactory implements FallbackFactory<AppUserFeignClient> {
+
+
+    /**
+     * 输出远程请求接口异常日志
+     * @param cause RPC请求异常
+     */
+    @Override
+    public AppUserFeignClient create(Throwable cause) {
+        //判断抛出异常是否为解码器抛出的业务异常
+        Enum<?> exceptionEnum = CommonResponseEnum.SERVICE_FALLBACK;
+        if(cause.getCause() instanceof BusinessException){
+            BusinessException businessException = (BusinessException) cause.getCause();
+            exceptionEnum = UserEnumUtil.getExceptionEnum(businessException.getResult());
+        }
+        Enum<?> finalExceptionEnum = exceptionEnum;
+        return new AppUserFeignClient() {
+
+            @Override
+            public HttpResult<List<User>> getAdminInfo() {
+                log.error("{}异常，降级处理，异常为：{}","获取业务管理员信息",cause.toString());
+                throw new BusinessException(finalExceptionEnum);
+            }
+
+        };
+    }
+}

pqs-user/user-api/src/main/java/com/njcn/user/api/fallback/UserFeignClientFallbackFactory.java

@@ -66,13 +66,6 @@ public class UserFeignClientFallbackFactory implements FallbackFactory<UserFeign
                 log.error("{}异常，降级处理，异常为：{}","根据用户id集合查询用户信息",cause.toString());
                 throw new BusinessException(finalExceptionEnum);
             }
-
-            @Override
-            public HttpResult<List<User>> getAdminInfo() {
-                log.error("{}异常，降级处理，异常为：{}","获取业务管理员信息",cause.toString());
-                throw new BusinessException(finalExceptionEnum);
-            }
-
         };
     }
 }