caojiahao/dev_caojiahao
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

上一周期数据问题处理

Browse Source
This commit is contained in:
Chopper 2022-05-25 17:41:31 +08:00
parent 026b6aca07
commit 90671729ea
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
consumer/src/main/java/cn/lili/timetask/handler/impl/statistics/OnlineMemberStatistics.java
View File

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