车辆和终端做对应代码实现

online-taxi-public/service-driver-user/pom.xml

@@ -45,6 +45,16 @@
             <artifactId>freemarker</artifactId>
             <version>2.3.28</version>
         </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>
 
 </project>

online-taxi-public/service-driver-user/src/main/java/com/taxi/servicedriveruser/ServiceDriverUserApplication.java

@@ -3,8 +3,10 @@ package com.taxi.servicedriveruser;
 import org.mybatis.spring.annotation.MapperScan;
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.cloud.openfeign.EnableFeignClients;
 
 @SpringBootApplication
+@EnableFeignClients
 @MapperScan("com.taxi.servicedriveruser.mapper")
 public class ServiceDriverUserApplication {
 

online-taxi-public/service-driver-user/src/main/java/com/taxi/servicedriveruser/remote/ServiceMapClient.java

@@ -0,0 +1,15 @@
+package com.taxi.servicedriveruser.remote;
+
+import com.internal.dto.ResponseResult;
+import com.internal.dto.TerminalResponse;
+import org.springframework.cloud.openfeign.FeignClient;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestMethod;
+import org.springframework.web.bind.annotation.RequestParam;
+
+@FeignClient("service-map")
+public interface ServiceMapClient {
+
+    @RequestMapping(method = RequestMethod.POST,value = "/terminal/addTerminal")
+    ResponseResult<TerminalResponse> addTerminal(@RequestParam String name);
+}

online-taxi-public/service-driver-user/src/main/java/com/taxi/servicedriveruser/service/CarService.java

@@ -2,7 +2,9 @@ package com.taxi.servicedriveruser.service;
 
 import com.internal.dto.Car;
 import com.internal.dto.ResponseResult;
+import com.internal.dto.TerminalResponse;
 import com.taxi.servicedriveruser.mapper.CarMapper;
+import com.taxi.servicedriveruser.remote.ServiceMapClient;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
@@ -13,13 +15,22 @@ public class CarService {
 
     @Autowired
     private CarMapper carMapper;
-
+    @Autowired
+    private ServiceMapClient serviceMapClient;
 
     public ResponseResult addCar(Car car) {
         LocalDateTime localDateTime = LocalDateTime.now();
         car.setGmtCreate(localDateTime);
         car.setGmtModified(localDateTime);
+
+        //获取此车辆对应的tid
+        ResponseResult<TerminalResponse> responseResult = serviceMapClient.addTerminal(car.getVehicleNo());
+        String tid = responseResult.getData().getTid();
+        car.setTid(tid);
+
         carMapper.insert(car);
+
+
         return ResponseResult.success();
     }
 }

online-taxi-public/service-map/src/main/java/com/taxi/servicemap/controller/TerminalController.java

@@ -1,6 +1,7 @@
 package com.taxi.servicemap.controller;
 
 import com.internal.dto.ResponseResult;
+import com.internal.dto.TerminalResponse;
 import com.taxi.servicemap.service.TerminalService;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.PostMapping;
@@ -13,7 +14,7 @@ public class TerminalController {
     @Autowired
     TerminalService terminalService;
     @PostMapping("/addTerminal")
-    public ResponseResult addTerminal(String name){
+    public ResponseResult<TerminalResponse> addTerminal(String name){
         return terminalService.addTerminal(name);
     }
 

online-taxi-public/service-map/src/main/java/com/taxi/servicemap/remote/TerminalClient.java

@@ -33,7 +33,7 @@ public class TerminalClient {
      * @param name
      * @return
      */
-    public ResponseResult addTerminal(String name){
+    public ResponseResult<TerminalResponse> addTerminal(String name){
         //拼接请求的URL
         StringBuilder url = new StringBuilder();
         url.append(AmapConfigConstant.TERMINAL_MAP_ADD_URL);

online-taxi-public/service-map/src/main/java/com/taxi/servicemap/service/TerminalService.java

@@ -1,6 +1,7 @@
 package com.taxi.servicemap.service;
 
 import com.internal.dto.ResponseResult;
+import com.internal.dto.TerminalResponse;
 import com.taxi.servicemap.remote.TerminalClient;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
@@ -10,7 +11,7 @@ public class TerminalService {
     @Autowired
     TerminalClient terminalClient;
 
-    public ResponseResult addTerminal(String name){
+    public ResponseResult<TerminalResponse> addTerminal(String name){
         return terminalClient.addTerminal(name);
     }
 }