按绿波ID筛选

76aa4b5f · zhoushiguang · e9f8a3f0 · 76aa4b5f
Commit 76aa4b5f authored Jul 16, 2024 by zhoushiguang
Hide whitespace changes
Inline Side-by-side

Showing with 1 addition and 1 deletion

LanePeriodicDataProcessServiceImpl.java ...nter/service/impl/LanePeriodicDataProcessServiceImpl.java +1 -1

No files found.
--- a/wj-datacenter-service/src/main/java/net/wanji/datacenter/service/impl/LanePeriodicDataProcessServiceImpl.java
+++ b/wj-datacenter-service/src/main/java/net/wanji/datacenter/service/impl/LanePeriodicDataProcessServiceImpl.java
@@ -854,7 +854,7 @@ public class LanePeriodicDataProcessServiceImpl implements DataProcessService {
        }

        // 取最新的一条
-        Optional<LineCongestion> latest = dtoList.stream()
+        Optional<LineCongestion> latest = dtoList.stream().filter(o->Objects.equals(po.getGreenId(),o.getGreenWaveId()))
                .max(Comparator.comparingLong(LineCongestion::getDetectTime));
        LineCongestion lineCongestion = latest.orElse(null);
        if (ObjectUtil.isEmpty(lineCongestion)) {