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 1afdac4c..db9797b0 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,8 @@ public class OnlineMemberStatistics implements EveryHourExecute { AtomicReference lastNum = new AtomicReference<>(0); onlineMemberVOS = onlineMemberVOS.stream() .filter(onlineMemberVO -> { - if (onlineMemberVO.getDate().before(finalCalendar.getTime())) { + //如果为过滤参数,则记录为过期参数,则为统一时段上一周期的在线人数 + if (!onlineMemberVO.getDate().after(finalCalendar.getTime())) { lastNum.set(onlineMemberVO.getNum()); } return onlineMemberVO.getDate().after(finalCalendar.getTime());