#命令下发队列优化

Junjie

2026-04-14 f7d2eda120867b3c5a2d9001d5f5c9d0396c65bd

 src/main/java/com/zy/core/task/DeviceLogScheduler.java

@@ -149,12 +149,8 @@
                if (prefix == null) {
                    continue;
                }
                String deviceFolderKey = buildDeviceFolderKey(logItem);
                if (deviceFolderKey == null) {
                    continue;
                }
                group.computeIfAbsent(datePart, k -> new HashMap<>())
                        .computeIfAbsent(deviceFolderKey, k -> new ArrayList<>())
                        .computeIfAbsent(prefix, k -> new ArrayList<>())
                        .add(logItem);
            }
            for (Map.Entry<String, Map<String, List<DeviceDataLog>>> dateEntry : group.entrySet()) {
@@ -217,13 +213,6 @@
            return logItem.getType() + "_" + logItem.getDeviceNo() + "_station_" + logItem.getStationId() + "_" + datePart + "_";
        }
        return logItem.getType() + "_" + logItem.getDeviceNo() + "_" + datePart + "_";
    }

    private String buildDeviceFolderKey(DeviceDataLog logItem) {
        if (logItem == null || logItem.getType() == null || logItem.getDeviceNo() == null) {
            return null;
        }
        return logItem.getType() + ":" + logItem.getDeviceNo();
    }

    private Path resolveDeviceDir(Path dayDir, DeviceDataLog logItem) {