爆破的微服务对公司微服务中相关api的调用

hxgc-burst/pom.xml

@@ -60,6 +60,17 @@
             <version>1.1.10</version>
         </dependency>
 
+        <dependency>
+            <groupId>org.springframework.cloud</groupId>
+            <artifactId>spring-cloud-starter-openfeign</artifactId>
+        </dependency>
+
+        <dependency>
+            <groupId>com.hxgc</groupId>
+            <artifactId>hxgc-entity</artifactId>
+            <version>1.0-SNAPSHOT</version>
+        </dependency>
+
     </dependencies>
 
 </project>

hxgc-burst/src/main/java/com/hxgc/BurstApp.java

@@ -3,10 +3,13 @@ package com.hxgc;
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
 import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
+import org.springframework.cloud.openfeign.EnableFeignClients;
 
 
 @SpringBootApplication
 @EnableDiscoveryClient
+//开启openfeign支持
+@EnableFeignClients
 public class BurstApp {
     public static void main(String[] args) {
         SpringApplication.run(BurstApp.class,args);

hxgc-burst/src/main/java/com/hxgc/api/CompanyApi.java

@@ -0,0 +1,39 @@
+package com.hxgc.api;
+
+import com.hxgc.Jifen;
+import org.springframework.cloud.openfeign.FeignClient;
+import org.springframework.web.bind.annotation.*;
+import java.util.List;
+import java.util.Map;
+
+
+/**
+ * 公司信息接口（api）的声明
+ */
+
+//feignclient 放入微服务的应用名
+@FeignClient("hxgc-company")
+@RequestMapping("company")
+public interface CompanyApi {
+    @PostMapping(value = "/save")
+    public Map save(@RequestBody Jifen jifen);
+
+    @PostMapping(value = "/update")
+    public Map update(@RequestBody Jifen jifen);
+
+    @GetMapping(value = "/delete")
+    public Map deleteById(Integer jifenId) ;
+
+
+    //注意传参问题 加上注解requestParam
+    @GetMapping(value = "/{jifenId}")
+    public Jifen findJifenById(@PathVariable Integer jifenId) ;
+
+    @GetMapping(value = "/search")
+    public Jifen search(Integer uid,String type);
+
+    @PostMapping(value = "/searchByEntity")
+    public List<Jifen> searchMap(@RequestBody  Jifen jifen) ;
+
+
+}

hxgc-burst/src/main/java/com/hxgc/controller/BurstController.java

@@ -1,6 +1,9 @@
 package com.hxgc.controller;
 
 
+import com.hxgc.Jifen;
+import com.hxgc.api.CompanyApi;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.GetMapping;
 import org.springframework.web.bind.annotation.PathVariable;
 import org.springframework.web.bind.annotation.RequestMapping;
@@ -21,9 +24,22 @@ public class BurstController {
             put("BurstInfo","123");
         }};
 
-
     }
 
 
+    @Autowired
+    private CompanyApi companyApi;
+
+    @RequestMapping("test1")
+    public Map test01(){
+
+        //远程调用服务
+        //url= http://hxgc---
+        Map sas = companyApi.save(new Jifen(1, 2, "sas"));
+
+        return sas;
+
+    }
+
 
 }

hxgc-company/pom.xml

@@ -39,6 +39,13 @@
             <groupId>com.alibaba.cloud</groupId>
             <artifactId>spring-cloud-starter-alibaba-nacos-config</artifactId>
         </dependency>
+        <!--  导入实体类的依赖   -->
+        <dependency>
+            <groupId>com.hxgc</groupId>
+            <artifactId>hxgc-entity</artifactId>
+            <version>1.0-SNAPSHOT</version>
+        </dependency>
+
     </dependencies>
 
 

hxgc-company/src/main/java/com/hxgc/controller/CompanyController.java

@@ -0,0 +1,76 @@
+package com.hxgc.controller;
+
+import com.hxgc.Jifen;
+import org.springframework.web.bind.annotation.*;
+
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+
+@RestController
+@RequestMapping("company")
+public class CompanyController {
+    @PostMapping(value = "/save")
+    public Map save(@RequestBody Jifen jifen) {
+
+        System.out.println("调用了积分保存接口");
+        System.out.println(jifen);
+        return new HashMap(){{
+            put("isSuccess",true);
+            put("msg","save success");
+        }};
+
+    }
+
+    @PostMapping(value = "/update")
+    public Map update(@RequestBody Jifen jifen) {
+
+        System.out.println(jifen);
+        return new HashMap(){{
+            put("isSuccess",true);
+            put("msg","update success");
+        }};
+
+    }
+
+
+
+    @GetMapping(value = "/delete")
+    public Map deleteById(Integer jifenId) {
+        System.out.println("删除id为"+jifenId+"的积分信息");
+        return new HashMap(){{
+            put("isSuccess",true);
+            put("msg","delete success");
+        }};
+
+    }
+
+
+
+
+    @GetMapping(value = "/{jifenId}")
+    public Jifen findJifenById(@PathVariable Integer jifenId) {
+        System.out.println("已经查询到"+jifenId+"积分数据");
+        return new Jifen(jifenId, 12,jifenId+"号积分");
+    }
+
+
+    @GetMapping(value = "/search")
+    public Jifen search(Integer uid,String type) {
+        System.out.println("uid:"+uid+"type:"+type);
+        return new Jifen(uid, 12,type);
+    }
+
+    @PostMapping(value = "/searchByEntity")
+    public List<Jifen> searchMap(@RequestBody  Jifen jifen) {
+
+        System.out.println(jifen);
+
+        List<Jifen> jifens = new ArrayList<Jifen>();
+        jifens.add(new Jifen(110,12,"下单积分"));
+        jifens.add(new Jifen(111,18,"支付积分"));
+        return  jifens;
+    }
+}

hxgc-company/src/main/java/com/hxgc/controller/company.java

@@ -1,36 +0,0 @@
-package com.hxgc.controller;
-
-import org.springframework.web.bind.annotation.PostMapping;
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RestController;
-import java.util.HashMap;
-import java.util.Map;
-
-
-@RestController
-@RequestMapping("company")
-public class company {
-    @PostMapping(value = "/save")
-    public Map save() {
-
-        System.out.println("调用了积分保存接口");
-        //System.out.println(jifen);
-        return new HashMap(){{
-            put("isSuccess",true);
-            put("msg","save success");
-        }};
-
-    }
-
-    @PostMapping(value = "/update")
-    public Map update() {
-
-        //System.out.println(jifen);
-        return new HashMap() {{
-            put("isSuccess", true);
-            put("msg", "update success");
-        }};
-    }
-
-
-}

hxgc-entity/src/main/java/com/hxgc/company.java → hxgc-entity/src/main/java/com/hxgc/Jifen.java

@@ -7,7 +7,7 @@ import lombok.NoArgsConstructor;
 @Data
 @AllArgsConstructor
 @NoArgsConstructor
-public class company {
+public class Jifen {
 
         private Integer jifenId;