build: 转移mqtt代码位置

xymanager_admin/src/main/java/com/shxy/xymanager_admin/controller/MqttController.java

@@ -4,7 +4,7 @@ import com.shxy.xymanager_common.annotation.Log;
 import com.shxy.xymanager_common.base.BaseController;
 import com.shxy.xymanager_common.base.ResponseReult;
 import com.shxy.xymanager_common.model.mqtt.MessageSend;
-import com.shxy.xymanager_framework.mqtt.MqttPublisherService;
+import com.shxy.xymanager_service.mqtt.MqttPublisherService;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
 import lombok.extern.slf4j.Slf4j;

xymanager_framework/pom.xml

@@ -62,13 +62,6 @@
             <optional>true</optional>
         </dependency>
 
-        <!-- MQTT 客户端库 -->
-        <dependency>
-            <groupId>org.eclipse.paho</groupId>
-            <artifactId>org.eclipse.paho.client.mqttv3</artifactId>
-            <version>1.2.5</version>
-        </dependency>
-
         <!--缓存-->
         <dependency>
             <groupId>org.springframework.boot</groupId>

xymanager_service/pom.xml

@@ -26,6 +26,12 @@
             <groupId>com.shxy</groupId>
             <artifactId>xymanager_dao</artifactId>
         </dependency>
+        <!-- MQTT 客户端库 -->
+        <dependency>
+            <groupId>org.eclipse.paho</groupId>
+            <artifactId>org.eclipse.paho.client.mqttv3</artifactId>
+            <version>1.2.5</version>
+        </dependency>
     </dependencies>
 
 </project>

xymanager_service/src/main/java/com/shxy/xymanager_service/mqtt/DataMessageListener.java

@@ -1,4 +1,4 @@
-package com.shxy.xymanager_framework.mqtt;
+package com.shxy.xymanager_service.mqtt;
 
 import com.shxy.xymanager_common.exception.ApiException;
 import com.shxy.xymanager_common.model.mqtt.*;

xymanager_service/src/main/java/com/shxy/xymanager_service/mqtt/GPSHandler.java

@@ -1,4 +1,4 @@
-package com.shxy.xymanager_framework.mqtt;
+package com.shxy.xymanager_service.mqtt;
 
 import com.shxy.xymanager_common.entity.TerminalPositions;
 import com.shxy.xymanager_common.entity.Terminals;

xymanager_service/src/main/java/com/shxy/xymanager_service/mqtt/HeartbeatHandler.java

@@ -1,4 +1,4 @@
-package com.shxy.xymanager_framework.mqtt;
+package com.shxy.xymanager_service.mqtt;
 
 import com.shxy.xymanager_common.entity.TerminalStatus;
 import com.shxy.xymanager_common.entity.Terminals;

xymanager_service/src/main/java/com/shxy/xymanager_service/mqtt/MqttPublisherService.java

@@ -1,4 +1,4 @@
-package com.shxy.xymanager_framework.mqtt;
+package com.shxy.xymanager_service.mqtt;
 
 import com.shxy.xymanager_common.model.mqtt.MessageSend;
 import com.shxy.xymanager_common.util.JSONUtil;

xymanager_service/src/main/java/com/shxy/xymanager_service/mqtt/MqttSubscriberService.java

@@ -1,4 +1,4 @@
-package com.shxy.xymanager_framework.mqtt;
+package com.shxy.xymanager_service.mqtt;
 
 import lombok.extern.slf4j.Slf4j;
 import org.eclipse.paho.client.mqttv3.MqttClient;

xymanager_service/src/main/java/com/shxy/xymanager_service/mqtt/PhotoHandler.java

@@ -1,4 +1,4 @@
-package com.shxy.xymanager_framework.mqtt;
+package com.shxy.xymanager_service.mqtt;
 
 import com.shxy.xymanager_common.entity.TerminalPhoto;
 import com.shxy.xymanager_common.entity.Terminals;

xymanager_service/src/main/java/com/shxy/xymanager_service/mqtt/PullHandler.java

@@ -1,4 +1,4 @@
-package com.shxy.xymanager_framework.mqtt;
+package com.shxy.xymanager_service.mqtt;
 
 import com.shxy.xymanager_common.entity.LeadPulls;
 import com.shxy.xymanager_common.entity.LeadPullsExample;

xymanager_service/src/main/java/com/shxy/xymanager_service/mqtt/RespMessageListener.java

@@ -1,4 +1,4 @@
-package com.shxy.xymanager_framework.mqtt;
+package com.shxy.xymanager_service.mqtt;
 
 import com.shxy.xymanager_common.exception.ApiException;
 import lombok.extern.slf4j.Slf4j;

xymanager_service/src/main/java/com/shxy/xymanager_service/mqtt/StatusHandler.java

@@ -1,4 +1,4 @@
-package com.shxy.xymanager_framework.mqtt;
+package com.shxy.xymanager_service.mqtt;
 
 import com.shxy.xymanager_common.entity.TerminalStatus;
 import com.shxy.xymanager_common.entity.Terminals;

xymanager_service/src/main/java/com/shxy/xymanager_service/mqtt/WeatherHandler.java

@@ -1,4 +1,4 @@
-package com.shxy.xymanager_framework.mqtt;
+package com.shxy.xymanager_service.mqtt;
 
 import com.shxy.xymanager_common.entity.Terminals;
 import com.shxy.xymanager_common.entity.Weathers;