对上一周期的参数赋值做处理

newcardriver · May 13, 2022 · 81f48d9 · 81f48d9
1 parent 6331b0d
commit 81f48d9
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/consumer/src/main/java/cn/lili/timetask/handler/impl/statistics/OnlineMemberStatistics.java b/consumer/src/main/java/cn/lili/timetask/handler/impl/statistics/OnlineMemberStatistics.java
@@ -59,7 +59,9 @@ public void execute() {
         AtomicReference<Integer> lastNum = new AtomicReference<>(0);
         onlineMemberVOS = onlineMemberVOS.stream()
                 .filter(onlineMemberVO -> {
-                    lastNum.set(onlineMemberVO.getNum());
+                    if (onlineMemberVO.getDate().before(finalCalendar.getTime())) {
+                        lastNum.set(onlineMemberVO.getNum());
+                    }
                     return onlineMemberVO.getDate().after(finalCalendar.getTime());
                 })
                 .collect(Collectors.toList());