diff --git a/pom.xml b/pom.xml
index fd6ccc5..328bb8d 100644
--- a/pom.xml
+++ b/pom.xml
@@ -74,12 +74,6 @@
3.5.0
-
-
- com.alibaba
- druid
- 1.1.21
-
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();
}
//推送单个设备数据