From 6e4ea35877963ef0787830ff61d6351d0baa1359 Mon Sep 17 00:00:00 2001
From: Junjie <fallin.jie@qq.com>
Date: 星期日, 12 四月 2026 17:45:59 +0800
Subject: [PATCH] #日志采集优化
---
src/main/java/com/zy/core/thread/impl/v5/StationV5StatusReader.java | 44 +++++++++++++++++++++++++++++++++++---------
1 files changed, 35 insertions(+), 9 deletions(-)
diff --git a/src/main/java/com/zy/core/thread/impl/v5/StationV5StatusReader.java b/src/main/java/com/zy/core/thread/impl/v5/StationV5StatusReader.java
index d38818f..a0e7e35 100644
--- a/src/main/java/com/zy/core/thread/impl/v5/StationV5StatusReader.java
+++ b/src/main/java/com/zy/core/thread/impl/v5/StationV5StatusReader.java
@@ -17,13 +17,14 @@
import com.zy.core.model.protocol.StationProtocol;
import com.zy.core.network.ZyStationConnectDriver;
import com.zy.core.network.entity.ZyStationStatusEntity;
+import com.zy.core.task.DeviceAsyncLogPublisher;
import com.zy.core.thread.support.RecentStationArrivalTracker;
import com.zy.core.thread.support.StationErrLogSupport;
-import com.zy.core.utils.DeviceLogRedisKeyBuilder;
import java.text.MessageFormat;
import java.util.ArrayList;
import java.util.Date;
+import java.util.HashMap;
import java.util.LinkedHashSet;
import java.util.List;
@@ -32,6 +33,7 @@
private final DeviceConfig deviceConfig;
private final RedisUtil redisUtil;
private final RecentStationArrivalTracker recentArrivalTracker;
+ private final DeviceAsyncLogPublisher devpAsyncLogPublisher;
private final List<StationProtocol> statusList = new ArrayList<>();
private volatile List<Integer> taskNoList = new ArrayList<>();
private boolean initialized = false;
@@ -43,6 +45,7 @@
this.deviceConfig = deviceConfig;
this.redisUtil = redisUtil;
this.recentArrivalTracker = recentArrivalTracker;
+ this.devpAsyncLogPublisher = SpringUtils.getBean(DeviceAsyncLogPublisher.class);
}
public void readStatus(ZyStationConnectDriver zyStationConnectDriver) {
@@ -128,18 +131,41 @@
StationErrLogSupport.sync(deviceConfig, redisUtil, statusList);
if (System.currentTimeMillis() - deviceDataLogTime > deviceLogCollectTime) {
- DeviceDataLog deviceDataLog = new DeviceDataLog();
- deviceDataLog.setOriginData(JSON.toJSONString(zyStationStatusEntities));
- deviceDataLog.setWcsData(JSON.toJSONString(statusList));
- deviceDataLog.setType(String.valueOf(SlaveType.Devp));
- deviceDataLog.setDeviceNo(deviceConfig.getDeviceNo());
- deviceDataLog.setCreateTime(new Date());
-
- redisUtil.set(DeviceLogRedisKeyBuilder.build(deviceDataLog), deviceDataLog, 60 * 60 * 24);
+ Date createTime = new Date();
+ HashMap<Integer, ZyStationStatusEntity> originDataMap = buildStationStatusMap(zyStationStatusEntities);
+ for (int i = 0; i < statusList.size(); i++) {
+ StationProtocol stationProtocol = statusList.get(i);
+ if (stationProtocol == null || stationProtocol.getStationId() == null) {
+ continue;
+ }
+ DeviceDataLog deviceDataLog = new DeviceDataLog();
+ ZyStationStatusEntity originEntity = originDataMap.get(stationProtocol.getStationId());
+ deviceDataLog.setOriginData(originEntity == null ? null : JSON.toJSONString(originEntity));
+ deviceDataLog.setWcsData(JSON.toJSONString(stationProtocol));
+ deviceDataLog.setType(String.valueOf(SlaveType.Devp));
+ deviceDataLog.setDeviceNo(deviceConfig.getDeviceNo());
+ deviceDataLog.setStationId(stationProtocol.getStationId());
+ deviceDataLog.setCreateTime(createTime);
+ devpAsyncLogPublisher.publishLatest(deviceDataLog);
+ }
deviceDataLogTime = System.currentTimeMillis();
}
}
+ private HashMap<Integer, ZyStationStatusEntity> buildStationStatusMap(List<ZyStationStatusEntity> zyStationStatusEntities) {
+ HashMap<Integer, ZyStationStatusEntity> map = new HashMap<>();
+ if (zyStationStatusEntities == null) {
+ return map;
+ }
+ for (ZyStationStatusEntity statusEntity : zyStationStatusEntities) {
+ if (statusEntity == null || statusEntity.getStationId() == null) {
+ continue;
+ }
+ map.put(statusEntity.getStationId(), statusEntity);
+ }
+ return map;
+ }
+
public List<StationProtocol> getStatusList() {
return statusList;
}
--
Gitblit v1.9.1