Forráskód Böngészése

添加openfeign 调用

tanlie 1 hónapja
szülő
commit
91e8ed9c6d
12 módosított fájl, 123 hozzáadás és 14 törlés
  1. 13 0
      wishing-platform/platform-core/platform-core-base/src/main/java/cn/qinys/platform/base/constants/ServiceConstants.java
  2. 2 1
      wishing-platform/platform-core/platform-core-base/src/main/java/cn/qinys/platform/base/utils/excel/ExcelUtils.java
  3. 0 3
      wishing-platform/platform-entity/platform-entity-wishing/target/maven-archiver/pom.properties
  4. 0 3
      wishing-platform/platform-entity/platform-entity-wishing/target/maven-status/maven-compiler-plugin/compile/default-compile/createdFiles.lst
  5. 0 3
      wishing-platform/platform-entity/platform-entity-wishing/target/maven-status/maven-compiler-plugin/compile/default-compile/inputFiles.lst
  6. BIN
      wishing-platform/platform-entity/platform-entity-wishing/target/platform-entity-wishing-1.0.0-SNAPSHOT.jar
  7. 8 0
      wishing-platform/platform-service/platform-service-admin/pom.xml
  8. 2 0
      wishing-platform/platform-service/platform-service-admin/src/main/java/cn/qinys/platform/AdminApplication.java
  9. 2 0
      wishing-platform/platform-service/platform-service-admin/src/main/java/cn/qinys/platform/admin/controller/WishTreeController.java
  10. 59 0
      wishing-platform/platform-service/platform-service-admin/src/main/java/cn/qinys/platform/config/FeignConfiguration.java
  11. 32 0
      wishing-platform/platform-service/platform-service-admin/src/main/java/cn/qinys/platform/openfeign/UpmsFeignClient.java
  12. 5 4
      wishing-platform/platform-service/platform-service-upms/src/main/java/cn/qinys/platform/upms/api/controller/GaoDeKeyController.java

+ 13 - 0
wishing-platform/platform-core/platform-core-base/src/main/java/cn/qinys/platform/base/constants/ServiceConstants.java

@@ -0,0 +1,13 @@
+package cn.qinys.platform.base.constants;
+
+/**
+ * @author lie tan
+ * @description
+ * @date 2026-05-24 14:21
+ **/
+public class ServiceConstants {
+
+    public static final String MOBILE_SERVICE = "wishing-mobile";
+    public static final String UPMS_SERVICE = "wishing-upms";
+    public static final String ADMIN_SERVICE = "wishing-admin";
+}

+ 2 - 1
wishing-platform/platform-core/platform-core-base/src/main/java/cn/qinys/platform/base/utils/excel/ExcelUtils.java

@@ -6,6 +6,7 @@ import cn.qinys.platform.base.utils.DateUtils;
 import cn.qinys.platform.base.utils.StreamUtils;
 import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.JSONObject;
+import jakarta.servlet.http.HttpServletResponse;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.lang3.StringUtils;
 import org.apache.poi.hssf.util.HSSFColor;
@@ -17,7 +18,7 @@ import org.springframework.http.HttpHeaders;
 import org.springframework.http.MediaType;
 import org.springframework.web.multipart.MultipartFile;
 
-import javax.servlet.http.HttpServletResponse;
+
 import java.io.BufferedOutputStream;
 import java.io.File;
 import java.io.IOException;

+ 0 - 3
wishing-platform/platform-entity/platform-entity-wishing/target/maven-archiver/pom.properties

@@ -1,3 +0,0 @@
-artifactId=platform-entity-wishing
-groupId=cn.qinys
-version=1.0.0-SNAPSHOT

+ 0 - 3
wishing-platform/platform-entity/platform-entity-wishing/target/maven-status/maven-compiler-plugin/compile/default-compile/createdFiles.lst

@@ -1,3 +0,0 @@
-cn\qinys\platform\entity\wishing\BaseEntity.class
-cn\qinys\platform\entity\wishing\WishingTree.class
-cn\qinys\platform\entity\wishing\WishingUser.class

+ 0 - 3
wishing-platform/platform-entity/platform-entity-wishing/target/maven-status/maven-compiler-plugin/compile/default-compile/inputFiles.lst

@@ -1,3 +0,0 @@
-G:\许愿树\wishing-platform\platform-entity\platform-entity-wishing\src\main\java\cn\qinys\platform\entity\wishing\BaseEntity.java
-G:\许愿树\wishing-platform\platform-entity\platform-entity-wishing\src\main\java\cn\qinys\platform\entity\wishing\WishingTree.java
-G:\许愿树\wishing-platform\platform-entity\platform-entity-wishing\src\main\java\cn\qinys\platform\entity\wishing\WishingUser.java

BIN
wishing-platform/platform-entity/platform-entity-wishing/target/platform-entity-wishing-1.0.0-SNAPSHOT.jar


+ 8 - 0
wishing-platform/platform-service/platform-service-admin/pom.xml

@@ -53,6 +53,14 @@
             <groupId>org.hibernate.validator</groupId>
             <artifactId>hibernate-validator</artifactId>
         </dependency>
+        <dependency>
+            <groupId>org.springframework.cloud</groupId>
+            <artifactId>spring-cloud-starter-openfeign</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.cloud</groupId>
+            <artifactId>spring-cloud-starter-loadbalancer</artifactId>
+        </dependency>
     </dependencies>
     <build>
         <finalName>wishing-admin</finalName>

+ 2 - 0
wishing-platform/platform-service/platform-service-admin/src/main/java/cn/qinys/platform/AdminApplication.java

@@ -2,12 +2,14 @@ package cn.qinys.platform;
 
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.cloud.openfeign.EnableFeignClients;
 
 /**
  * @author lie tan
  * @description
  * @date 2026-05-23 11:50
  **/
+@EnableFeignClients
 @SpringBootApplication
 public class AdminApplication {
 

+ 2 - 0
wishing-platform/platform-service/platform-service-admin/src/main/java/cn/qinys/platform/admin/controller/WishTreeController.java

@@ -5,6 +5,7 @@ import cn.qinys.platform.admin.req.WishingTreePageReq;
 import cn.qinys.platform.admin.resp.WishingTreePageResp;
 import cn.qinys.platform.admin.service.WishTreeService;
 import cn.qinys.platform.base.response.UnifyResponse;
+import cn.qinys.platform.openfeign.UpmsFeignClient;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import jakarta.annotation.Resource;
 import jakarta.validation.Valid;
@@ -23,6 +24,7 @@ public class WishTreeController {
     @Resource
     private WishTreeService wishTreeService;
 
+
     @GetMapping("/page")
     public UnifyResponse<Page<WishingTreePageResp>> getWishTreePage(WishingTreePageReq req) {
         Page<WishingTreePageResp> wishTreePage = wishTreeService.getWishTreePage(req);

+ 59 - 0
wishing-platform/platform-service/platform-service-admin/src/main/java/cn/qinys/platform/config/FeignConfiguration.java

@@ -0,0 +1,59 @@
+package cn.qinys.platform.config;
+
+
+import feign.RequestInterceptor;
+import feign.RequestTemplate;
+import feign.Retryer;
+import jakarta.servlet.http.HttpServletRequest;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.web.context.request.RequestAttributes;
+import org.springframework.web.context.request.RequestContextHolder;
+import org.springframework.web.context.request.ServletRequestAttributes;
+
+import java.util.Enumeration;
+import java.util.List;
+import java.util.Objects;
+
+/**
+ * Feign配置类
+ *
+ * @author v-lishiquan.gx@chinatelecom.cn
+ * @date 2020-08-26
+ */
+@Configuration
+@Slf4j
+public class FeignConfiguration implements RequestInterceptor {
+
+    @Bean
+    Retryer feignRetryer() {
+        return Retryer.NEVER_RETRY;
+    }
+
+    @Override
+    public void apply(RequestTemplate requestTemplate) {
+        RequestAttributes requestAttributes = RequestContextHolder.getRequestAttributes();
+        if (Objects.nonNull(requestAttributes)) {
+            RequestContextHolder.setRequestAttributes(requestAttributes, true);
+            ServletRequestAttributes attributes = (ServletRequestAttributes) RequestContextHolder.currentRequestAttributes();
+            HttpServletRequest request = attributes.getRequest();
+            // 添加请求头
+            Enumeration<String> headerNames = request.getHeaderNames();
+            if (headerNames != null) {
+                while (headerNames.hasMoreElements()) {
+                    String name = headerNames.nextElement();
+                    if(this.removeHead().contains(name)){
+                        continue;
+                    }
+                    String values = request.getHeader(name);
+                    requestTemplate.header(name, values);
+                }
+            }
+        }
+    }
+
+    private List<String> removeHead() {
+        return List.of("content-length");
+    }
+}

+ 32 - 0
wishing-platform/platform-service/platform-service-admin/src/main/java/cn/qinys/platform/openfeign/UpmsFeignClient.java

@@ -0,0 +1,32 @@
+package cn.qinys.platform.openfeign;
+
+import cn.qinys.platform.admin.req.BasePageReq;
+import cn.qinys.platform.base.constants.ServiceConstants;
+import cn.qinys.platform.base.response.Result;
+import cn.qinys.platform.config.FeignConfiguration;
+import com.alibaba.fastjson2.JSONObject;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import org.springframework.cloud.openfeign.FeignClient;
+import org.springframework.stereotype.Component;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.cloud.openfeign.SpringQueryMap;
+
+/**
+ * @author lie tan
+ * @description
+ * @date 2026-05-24 14:12
+ **/
+@Component
+@FeignClient(name = ServiceConstants.UPMS_SERVICE,
+        configuration = FeignConfiguration.class)
+public interface UpmsFeignClient {
+
+
+    /**
+     * 初始化redis中的
+     *
+     * @return 无
+     */
+    @GetMapping("/upms/gaodekey/page")
+    Result<Page<JSONObject>> getGaoDeKeyPage(@SpringQueryMap BasePageReq req);
+}

+ 5 - 4
wishing-platform/platform-service/platform-service-upms/src/main/java/cn/qinys/platform/upms/api/controller/GaoDeKeyController.java

@@ -8,10 +8,11 @@ import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import cn.qinys.platform.upms.api.req.GaoDeKeyPageReq;
 import cn.qinys.platform.upms.api.resp.GaoDeKeyPageResp;
 import cn.qinys.platform.upms.api.service.IGaoDeKeyService;
+import jakarta.servlet.http.HttpServletResponse;
 import lombok.AllArgsConstructor;
 import org.springframework.web.bind.annotation.*;
 
-import javax.servlet.http.HttpServletResponse;
+
 import java.util.ArrayList;
 import java.util.List;
 
@@ -26,7 +27,7 @@ import java.util.List;
 @RequestMapping("/gaodekey")
 public class GaoDeKeyController extends DevBaseController {
 
-    private final IGaoDeKeyService gatewayService;
+    private final IGaoDeKeyService gaoDeKeyService;
 
 
     /**
@@ -37,7 +38,7 @@ public class GaoDeKeyController extends DevBaseController {
     @HasPermission({"dev.gaodekey"})
     @GetMapping("/page")
     public Result<Page<GaoDeKeyPageResp>> queryDictionaries(GaoDeKeyPageReq req) {
-        Page<GaoDeKeyPageResp> respPage = gatewayService.getPage(req);
+        Page<GaoDeKeyPageResp> respPage = gaoDeKeyService.getPage(req);
         return new Result<>(respPage);
     }
 
@@ -54,7 +55,7 @@ public class GaoDeKeyController extends DevBaseController {
         query = query == null ? new GaoDeKeyPageReq() : query;
         query.setCurrent(1);
         query.setSize(5000);
-        Page<GaoDeKeyPageResp> voPage = gatewayService.getPage(query);
+        Page<GaoDeKeyPageResp> voPage = gaoDeKeyService.getPage(query);
         List<ExcelElement> excelElements =new ArrayList<>();
         excelElements.add(new ExcelElement("key", "geoKey"));
         excelElements.add(new ExcelElement("日期", "date"));