ok

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) {