diff --git a/src/main/java/com/xydl/mapper/OperationDB.java b/src/main/java/com/xydl/mapper/OperationDB.java index 2e798cb..4f42163 100644 --- a/src/main/java/com/xydl/mapper/OperationDB.java +++ b/src/main/java/com/xydl/mapper/OperationDB.java @@ -24,7 +24,7 @@ public interface OperationDB { List> getDeviceIDAndtime(String tableName); - void addEarliestTime(int clientId, String tableName, String devId, String earliestTime); + void addEarliestTime(String clientId, String tableName, String devId, String earliestTime); List> getData(String sql); diff --git a/src/main/java/com/xydl/service/impl/MqttServiceImpl.java b/src/main/java/com/xydl/service/impl/MqttServiceImpl.java index 1d2eeea..d333e4c 100644 --- a/src/main/java/com/xydl/service/impl/MqttServiceImpl.java +++ b/src/main/java/com/xydl/service/impl/MqttServiceImpl.java @@ -53,7 +53,7 @@ public class MqttServiceImpl { Object time = devIDLastTimeMap.get(deviceID); if (time == null) { time = "2000-01-01 01:00:00"; - operationDBMapper.addEarliestTime(10, tableName, String.valueOf(deviceID), time.toString()); + operationDBMapper.addEarliestTime("10", tableName, String.valueOf(deviceID), time.toString()); } publishData(deviceID, time.toString(), sqlExecuting, tableName, fieldMap); }