From 594ec478dd07a3e5de8e48a95ddb3ffa1b343d11 Mon Sep 17 00:00:00 2001
From: huangfeng <huangfeng@xinyingpower.com>
Date: Fri, 15 Dec 2023 14:13:19 +0800
Subject: [PATCH] =?UTF-8?q?fix:=20=E4=BC=98=E5=8C=96=E4=BB=A3=E7=A0=81?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 pom.xml                                        |  6 ------
 .../com/xydl/service/impl/MqttServiceImpl.java | 18 ++++++++++--------
 2 files changed, 10 insertions(+), 14 deletions(-)

diff --git a/pom.xml b/pom.xml
index fd6ccc5..328bb8d 100644
--- a/pom.xml
+++ b/pom.xml
@@ -74,12 +74,6 @@
             <version>3.5.0</version>
         </dependency>
 
-        <!-- https://mvnrepository.com/artifact/com.alibaba/druid -->
-        <dependency>
-            <groupId>com.alibaba</groupId>
-            <artifactId>druid</artifactId>
-            <version>1.1.21</version>
-        </dependency>
 
         <!--数据连接池druid-->
         <dependency>
diff --git a/src/main/java/com/xydl/service/impl/MqttServiceImpl.java b/src/main/java/com/xydl/service/impl/MqttServiceImpl.java
index c320e49..d0535f8 100644
--- a/src/main/java/com/xydl/service/impl/MqttServiceImpl.java
+++ b/src/main/java/com/xydl/service/impl/MqttServiceImpl.java
@@ -53,16 +53,18 @@ public class MqttServiceImpl {
         }
         log.info("表{},共{}个设备", tableName, dataEqmids.size());
 
-        mqttUtil.connect();
-        for (int deviceID : dataEqmids) {
-            Object time = devIDLastTimeMap.get(deviceID);
-            if (time == null) {
-                time = "2010-01-01 01:00:00";
-                operationDBMapper.addEarliestTime("10", tableName, String.valueOf(deviceID), time.toString());
+        if (dataEqmids.size() > 0) {
+            mqttUtil.connect();
+            for (int deviceID : dataEqmids) {
+                Object time = devIDLastTimeMap.get(deviceID);
+                if (time == null) {
+                    time = "2010-01-01 01:00:00";
+                    operationDBMapper.addEarliestTime("10", tableName, String.valueOf(deviceID), time.toString());
+                }
+                publishData(String.valueOf(deviceID), time.toString(), sqlExecuting, tableName, fieldMap);
             }
-            publishData(String.valueOf(deviceID), time.toString(), sqlExecuting, tableName, fieldMap);
+            mqttUtil.disconnect();
         }
-        mqttUtil.disconnect();
     }
 
     //推送单个设备数据