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
index 92b6b23f..1afdac4c 100644
--- 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 class OnlineMemberStatistics implements EveryHourExecute {
         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());