feat 完善负载中心

src/main/java/com/car/config/InitConnectWeight.java

@@ -9,18 +9,10 @@ import com.aliyun.ecs20140526.models.DescribeInstancesResponse;
 import com.aliyun.tea.TeaException;
 import com.aliyun.teautil.models.RuntimeOptions;
 import com.car.demos.ConnectWeight;
-import com.car.demos.loadenter.Auth;
+import com.car.demos.car.LoadEnterNumber;
-import com.car.demos.loadenter.Content;
+import com.car.demos.car.Node;
-import com.car.demos.loadenter.LoadEnterNumber;
-import com.car.demos.loadenter.Node;
 import com.car.service.impl.ConnectServiceImpl;
 import lombok.extern.slf4j.Slf4j;
-import org.apache.http.HttpResponse;
-import org.apache.http.client.HttpClient;
-import org.apache.http.client.methods.CloseableHttpResponse;
-import org.apache.http.client.methods.HttpPost;
-import org.apache.http.impl.client.HttpClients;
-import org.apache.http.util.EntityUtils;
 import org.springframework.amqp.rabbit.core.RabbitTemplate;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.boot.ApplicationArguments;
@@ -29,7 +21,7 @@ import org.springframework.data.redis.core.RedisTemplate;
 import org.springframework.http.*;
 import org.springframework.stereotype.Component;
 import org.springframework.web.client.RestTemplate;
-import java.io.IOException;
+
 import java.math.BigDecimal;
 import java.math.RoundingMode;
 import java.util.*;
@@ -55,6 +47,8 @@ public class InitConnectWeight implements ApplicationRunner {
 
     @Autowired
     private RabbitTemplate rabbitTemplate;
+
+
     @Override
     public void run(ApplicationArguments args) {
         connectService.loadCenterDel();

src/main/java/com/car/controller/ConnectController.java

@@ -1,13 +1,10 @@
 package com.car.controller;
 
-import com.alibaba.fastjson.JSONObject;
 import com.car.demos.MqttServerModel;
 import com.car.demos.Result;
 import com.car.demos.car.Car;
-import com.car.demos.car.CarReq;
+import com.car.demos.car.LoadEnterNumber;
-import com.car.demos.loadenter.LoadEnterNumber;
+import com.car.demos.car.Node;
-import com.car.demos.loadenter.Node;
-import com.car.demos.loadenter.NodeReq;
 import com.car.demos.req.VehicleConnectionReq;
 import com.car.service.ConnectService;
 import lombok.extern.log4j.Log4j2;
@@ -32,7 +29,7 @@ public class ConnectController {
 
     @Autowired
     private ConnectService connectService;
-    @PostMapping("/getConnect")
+    @PostMapping("/connect")
     public Result<MqttServerModel>getConnect(@RequestBody VehicleConnectionReq vehicleConnectionReq){
         Result<MqttServerModel> connect = connectService.getConnect(vehicleConnectionReq);
         log.info("车辆上线的返回值:{}",connect);

src/main/java/com/car/demos/car/LoadEnterNumber.java

@@ -1,4 +1,4 @@
-package com.car.demos.loadenter;
+package com.car.demos.car;
 
 import lombok.AllArgsConstructor;
 import lombok.Data;

src/main/java/com/car/demos/car/Node.java

@@ -1,4 +1,4 @@
-package com.car.demos.loadenter;
+package com.car.demos.car;
 
 import lombok.AllArgsConstructor;
 import lombok.Data;

src/main/java/com/car/mapper/ConnerMapper.java

@@ -1,8 +1,8 @@
 package com.car.mapper;
 
 import com.car.demos.car.Car;
-import com.car.demos.loadenter.LoadEnterNumber;
+import com.car.demos.car.LoadEnterNumber;
-import com.car.demos.loadenter.Node;
+import com.car.demos.car.Node;
 import org.apache.ibatis.annotations.Mapper;
 
 import java.util.List;

src/main/java/com/car/service/ConnectService.java

@@ -3,8 +3,8 @@ package com.car.service;
 import com.car.demos.MqttServerModel;
 import com.car.demos.Result;
 import com.car.demos.car.Car;
-import com.car.demos.loadenter.LoadEnterNumber;
+import com.car.demos.car.LoadEnterNumber;
-import com.car.demos.loadenter.Node;
+import com.car.demos.car.Node;
 import com.car.demos.req.VehicleConnectionReq;
 
 import java.util.List;

src/main/java/com/car/service/impl/ConnectServiceImpl.java

@@ -6,8 +6,8 @@ import com.car.demos.MqttServerModel;
 import com.car.demos.Result;
 
 import com.car.demos.car.Car;
-import com.car.demos.loadenter.LoadEnterNumber;
+import com.car.demos.car.LoadEnterNumber;
-import com.car.demos.loadenter.Node;
+import com.car.demos.car.Node;
 import com.car.demos.req.VehicleConnectionReq;
 import com.car.mapper.ConnerMapper;
 import com.car.service.ConnectService;

src/main/resources/application.yml

@@ -4,7 +4,7 @@ server:
 
 spring:
   rabbitmq:
-    host: 115.159.211.196
+    host: 101.34.243.166
     port: 5672
     username: guest
     password: guest
@@ -14,15 +14,15 @@ spring:
       matching-strategy: ant_path_matcher
   datasource:
     driver-class-name: com.mysql.cj.jdbc.Driver
-    url: jdbc:mysql://115.159.211.196:3306/zncar?useUnicode=true&characterEncoding=utf8&allowMultiQueries=true&useSSL=false
+    url: jdbc:mysql://101.34.243.166:3306/zncar?useUnicode=true&characterEncoding=utf8&allowMultiQueries=true&useSSL=false
     username: root
-    password: yl@123
+    password: wan@123
   application:
     name: shop-server
   redis:
-    host: 115.159.211.196
+    host: 101.34.243.166
     port: 6379
-    password: yl030509
+#    password: yl030509
 
 # mybatis
 mybatis:

src/main/resources/mapper/ConnerMapper.xml

@@ -23,7 +23,7 @@
     <delete id="delNode">
         DELETE FROM `zncar`.`node`
     </delete>
-    <select id="select" resultType="com.car.demos.loadenter.LoadEnterNumber">
+    <select id="select" resultType="com.car.demos.car.LoadEnterNumber">
         select * from load_enter_number
     </select>
     <select id="selectCar" resultType="com.car.demos.car.Car">
@@ -31,7 +31,7 @@
 
             order by timestamp desc
     </select>
-    <select id="selectNode" resultType="com.car.demos.loadenter.Node">
+    <select id="selectNode" resultType="com.car.demos.car.Node">
         select * from node  order by node_weights desc
     </select>