|
@@ -89,13 +89,16 @@ public abstract class AbsRenkeMonitorDataProcessor implements MonitorDataProcess
|
|
|
log.warn("设备ID: {} 的缓存数据中没有有效的传感器数据", deviceId);
|
|
|
}
|
|
|
}
|
|
|
- // Step 6: 保存传感器数据(实时数据 + 缓存数据)
|
|
|
- boolean result = writeSensorDatas(sensorDataList);
|
|
|
- // Step 7: 输出处理结果日志,并在保存成功后进行后置处理
|
|
|
- if (result) {
|
|
|
- postProcess(sensorDataList);
|
|
|
- } else {
|
|
|
- log.error("设备ID: {}, 型号: {} 的数据处理失败", deviceId, modelName);
|
|
|
+ boolean result = false;
|
|
|
+ if (!sensorDataList.isEmpty()) {
|
|
|
+ // Step 6: 保存传感器数据(实时数据 + 缓存数据)
|
|
|
+ result = writeSensorDatas(sensorDataList);
|
|
|
+ // Step 7: 输出处理结果日志,并在保存成功后进行后置处理
|
|
|
+ if (result) {
|
|
|
+ postProcess(sensorDataList);
|
|
|
+ } else {
|
|
|
+ log.error("设备ID: {}, 型号: {} 的数据处理失败", deviceId, modelName);
|
|
|
+ }
|
|
|
}
|
|
|
return result;
|
|
|
}
|