diff --git a/fw-dalaran-server/src/main/java/cn/fw/dalaran/server/task/TodoTask.java b/fw-dalaran-server/src/main/java/cn/fw/dalaran/server/task/TodoTask.java index 210e474..76d6415 100644 --- a/fw-dalaran-server/src/main/java/cn/fw/dalaran/server/task/TodoTask.java +++ b/fw-dalaran-server/src/main/java/cn/fw/dalaran/server/task/TodoTask.java @@ -144,7 +144,7 @@ public class TodoTask { final long timeSub = System.currentTimeMillis() - item.getEndTime().getTime(); return 24 * 3600 * 1000 < timeSub && timeSub < 2 * 24 * 3600 * 1000; }) - .collect(Collectors.toList());// 找到需要审计的主题 + .collect(Collectors.toList());// 找到(理论上)需要审计的主题 if (CollectionUtils.isEmpty(themeList)) return; final List bestLives = livePoolService.lambdaQuery() @@ -156,7 +156,7 @@ public class TodoTask { .list();// 找到主题对应的所有人的最佳直播 final List waitCheckThemeIds = bestLives.stream() .map(LivePool::getThemeId).distinct() - .collect(Collectors.toList());// 找到需要审核的主题id集合 + .collect(Collectors.toList());// 根据最佳直播分布, 找到(真正)需要审核的主题id集合 if (CollectionUtils.isEmpty(waitCheckThemeIds)) return; final List usersInShopIds = accountService.lambdaQuery() @@ -170,7 +170,7 @@ public class TodoTask { .distinct()// 祛除重复门店 .collect(Collectors.toList());// 最佳直播的账户分布在对应的门店id集合 final List themeVos = themeList.stream() - .filter(item -> waitCheckThemeIds.contains(item.getId())) + .filter(item -> waitCheckThemeIds.contains(item.getId()))// 过滤出(真正)需要审核的主题 .map(ActivityTheme::toVO) .collect(Collectors.toList());// 将主题转换成vo if (CollectionUtils.isEmpty(themeVos)) @@ -187,7 +187,7 @@ public class TodoTask { .map(item -> {// 遍历每个门店 TodoHistory todo = new TodoHistory(); List users = userRoleRpcService.getUsers(item, Constants.ZBSJ_ROLE_CODE);// 获取门店拥有'直播审计'角色的人 - if (users.size() > 0) { + if (!users.isEmpty()) { todo.setSend(false); todo.setDone(false); todo.setTodoDone(false);