DeXun/be-process-control-system
9
1
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

app更新对l2数据显示

Browse Source
This commit is contained in:
86156
2026-01-15 20:18:36 +08:00
parent 0c94099e5a
commit 14aa9bf13c
1 changed files with 6 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
business/src/main/java/com/fizz/business/service/DeviceSnapshotService.java
View File

@@ -88,7 +88,7 @@ public class DeviceSnapshotService {
AppMeasureCoatMessage coat = (AppMeasureCoatMessage) latestMeasurements.get(AppMeasureCoatMessage.class); AppMeasureCoatMessage coat = (AppMeasureCoatMessage) latestMeasurements.get(AppMeasureCoatMessage.class);
AppMeasureExitMessage exit = (AppMeasureExitMessage) latestMeasurements.get(AppMeasureExitMessage.class); AppMeasureExitMessage exit = (AppMeasureExitMessage) latestMeasurements.get(AppMeasureExitMessage.class);
log.info("测量数据状态 - entry: {}, furnace: {}, coat: {}, exit: {}", log.info("测量数据状态 - entry: {}, furnace: {}, coat: {}, exit: {}",
entry != null ? "有数据" : "null", entry != null ? "有数据" : "null",
furnace != null ? "有数据" : "null", furnace != null ? "有数据" : "null",
coat != null ? "有数据" : "null", coat != null ? "有数据" : "null",
@@ -127,18 +127,18 @@ public class DeviceSnapshotService {
int result = deviceSnapshotMapper.insert(snapshot); int result = deviceSnapshotMapper.insert(snapshot);
if (result > 0) { if (result > 0) {
savedCount++; savedCount++;
log.debug("设备快照保存成功: deviceCode={}, createTime={}", log.debug("设备快照保存成功: deviceCode={}, createTime={}",
snapshot.getDeviceCode(), snapshot.getCreateTime()); snapshot.getDeviceCode(), snapshot.getCreateTime());
} else { } else {
log.warn("设备快照保存失败（insert返回0）: deviceCode={}", snapshot.getDeviceCode()); log.warn("设备快照保存失败（insert返回0）: deviceCode={}", snapshot.getDeviceCode());
} }
} catch (Exception e) { } catch (Exception e) {
log.error("保存设备快照到数据库失败: deviceCode={}, error={}", log.error("保存设备快照到数据库失败: deviceCode={}, error={}",
snapshot.getDeviceCode(), e.getMessage(), e); snapshot.getDeviceCode(), e.getMessage(), e);
} }
} }
log.info("成功保存{}个设备数据快照到数据库", savedCount); log.info("成功保存{}个设备数据快照到数据库", savedCount);
// 推送所有设备的历史趋势数据 // 推送所有设备的历史趋势数据
pushAllDevicesHistoryTrend(); pushAllDevicesHistoryTrend();
@@ -758,7 +758,6 @@ public class DeviceSnapshotService {
snapshot.setDeviceName(device.getDesc()); snapshot.setDeviceName(device.getDesc());
snapshot.setSectionType(device.getSectionType().name()); snapshot.setSectionType(device.getSectionType().name());
snapshot.setSourceType(device.getSourceType().name()); snapshot.setSourceType(device.getSourceType().name());
snapshot.setBasePosition(device.getBasePosition());
List<String> paramFields = device.getParamFields(); List<String> paramFields = device.getParamFields();
log.debug("设备[{}]参数字段列表: {}", device.name(), paramFields); log.debug("设备[{}]参数字段列表: {}", device.name(), paramFields);
@@ -821,7 +820,7 @@ public class DeviceSnapshotService {
*/ */
private void extractData(Object message, List<String> fields, ObjectNode dataNode) { private void extractData(Object message, List<String> fields, ObjectNode dataNode) {
if (message == null || fields == null || fields.isEmpty()) { if (message == null || fields == null || fields.isEmpty()) {
log.debug("extractData参数无效: message={}, fields={}", log.debug("extractData参数无效: message={}, fields={}",
message != null ? message.getClass().getSimpleName() : "null", message != null ? message.getClass().getSimpleName() : "null",
fields != null ? fields.size() : "null"); fields != null ? fields.size() : "null");
return; return;
@@ -875,7 +874,7 @@ public class DeviceSnapshotService {
log.warn("获取字段[{}]值失败: {}", field, e.getMessage()); log.warn("获取字段[{}]值失败: {}", field, e.getMessage());
} }
} }
log.debug("从[{}]提取了{}个字段，共{}个字段", log.debug("从[{}]提取了{}个字段，共{}个字段",
message.getClass().getSimpleName(), extractedCount, fields.size()); message.getClass().getSimpleName(), extractedCount, fields.size());
} catch (Exception e) { } catch (Exception e) {
log.error("提取数据时发生错误: {}", e.getMessage(), e); log.error("提取数据时发生错误: {}", e.getMessage(), e);