|
|
|
@ -84,7 +84,7 @@ public class MqttServiceImpl {
|
|
|
|
|
lastRecordTime = dataOfoneDeviceID.get(dataOfoneDeviceID.size() - 1).get("d_time").toString();
|
|
|
|
|
}
|
|
|
|
|
operationDBMapper.updateSyncRecordsTable(tableName, deviceID, lastRecordTime);
|
|
|
|
|
log.debug("表{}设备{}推送成功", tableName, deviceID);
|
|
|
|
|
log.debug("表{}设备{}推送成功{}条数据,最后时间{}", tableName, deviceID, dataOfoneDeviceID.size(), lastRecordTime);
|
|
|
|
|
}
|
|
|
|
|
} catch (Exception e) {
|
|
|
|
|
log.error("表{}设备{}推送异常", tableName, deviceID, e);
|
|
|
|
|