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

---
 src/main/java/com/xydl/service/impl/MqttServiceImpl.java | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

diff --git a/src/main/java/com/xydl/service/impl/MqttServiceImpl.java b/src/main/java/com/xydl/service/impl/MqttServiceImpl.java
index c65372f..cb17ac9 100644
--- a/src/main/java/com/xydl/service/impl/MqttServiceImpl.java
+++ b/src/main/java/com/xydl/service/impl/MqttServiceImpl.java
@@ -68,7 +68,11 @@ public class MqttServiceImpl {
         String jsonStringData = FormatUtil.mqttFormatTransform(dataOfoneDeviceID, fieldMap);
         try {
             if (mqttUtil.publish2MQTT(jsonStringData)) {
-                operationDBMapper.updateSyncRecordsTable(tableName, deviceID, time);
+                String lastRecordTime = dataOfoneDeviceID.get(dataOfoneDeviceID.size()-1).get("d_time").toString();
+                if(tableName.equals("data_eaif_h")){
+                    lastRecordTime = dataOfoneDeviceID.get(dataOfoneDeviceID.size()-1).get("capturetime").toString();
+                }
+                operationDBMapper.updateSyncRecordsTable(tableName, deviceID, lastRecordTime);
                 log.debug("表{}设备{}推送成功:{}", tableName, deviceID, jsonStringData);
             }
         } catch (Exception e) {