From de84c69b69fd583f37ef29f31fd7a050dce8bcd2 Mon Sep 17 00:00:00 2001
From: "wenhua.zhou" <zhouwenhua@xinyingpower.com>
Date: Tue, 12 Dec 2023 13:20:02 +0800
Subject: [PATCH] ok

---
 src/main/java/com/xydl/mapper/OperationDB.java           | 2 +-
 src/main/java/com/xydl/service/impl/MqttServiceImpl.java | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

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<Map<String, Object>> getDeviceIDAndtime(String tableName);
 
-    void addEarliestTime(int clientId, String tableName, String devId, String earliestTime);
+    void addEarliestTime(String clientId, String tableName, String devId, String earliestTime);
 
     List<Map<String, Object>> 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);
         }