Commit 500fa5ae by 吴星煌

即时通讯服务概览查询bug

parent 8e75b9fd
...@@ -44,12 +44,13 @@ public class ImOverviewImpl implements ImOverview { ...@@ -44,12 +44,13 @@ public class ImOverviewImpl implements ImOverview {
log.info("即时通讯服务概览的入参appId为{}",appId); log.info("即时通讯服务概览的入参appId为{}",appId);
OverviewVo overviewVo = new OverviewVo(); OverviewVo overviewVo = new OverviewVo();
//今日活跃用户 //今日活跃用户
Integer activeUser = imMessageService.count(new LambdaQueryWrapper<ImMessage>() List<ImMessage> imMessageList = imMessageService.list(new LambdaQueryWrapper<ImMessage>()
.eq(ImMessage::getFkAppid, appId) .eq(ImMessage::getFkAppid, appId)
.ge(ImMessage::getCreateTime, LocalDateTime.of(LocalDate.now(), LocalTime.MIN)) .ge(ImMessage::getCreateTime, LocalDateTime.of(LocalDate.now(), LocalTime.MIN))
.groupBy(ImMessage::getSender) .groupBy(ImMessage::getSender)
.select(ImMessage::getSender) .select(ImMessage::getSender)
); );
Integer activeUser = imMessageList.size();
overviewVo.setActiveUser(activeUser); overviewVo.setActiveUser(activeUser);
log.info("即时通讯服务概览的今日活跃用户数量为{}",activeUser); log.info("即时通讯服务概览的今日活跃用户数量为{}",activeUser);
//总注册用户数 //总注册用户数
......
...@@ -44,7 +44,7 @@ public class OverviewScheduled { ...@@ -44,7 +44,7 @@ public class OverviewScheduled {
for (ImApplication imApplication : imApplicationList) { for (ImApplication imApplication : imApplicationList) {
Long appId = imApplication.getId(); Long appId = imApplication.getId();
//统计活跃用户数量并保存 //统计活跃用户数量并保存
Integer activeUser = imMessageService.count(new LambdaQueryWrapper<ImMessage>() List<ImMessage> imMessageList = imMessageService.list(new LambdaQueryWrapper<ImMessage>()
.eq(ImMessage::getFkAppid, appId) .eq(ImMessage::getFkAppid, appId)
.between(ImMessage::getCreateTime, .between(ImMessage::getCreateTime,
LocalDateTime.of(LocalDate.now(), LocalTime.MIN).minusDays(1), LocalDateTime.of(LocalDate.now(), LocalTime.MIN).minusDays(1),
...@@ -52,6 +52,7 @@ public class OverviewScheduled { ...@@ -52,6 +52,7 @@ public class OverviewScheduled {
.groupBy(ImMessage::getSender) .groupBy(ImMessage::getSender)
.select(ImMessage::getSender) .select(ImMessage::getSender)
); );
Integer activeUser = imMessageList.size();
ImStatistics userStatistics = new ImStatistics(); ImStatistics userStatistics = new ImStatistics();
userStatistics.setData(activeUser); userStatistics.setData(activeUser);
userStatistics.setFkAppid(appId); userStatistics.setFkAppid(appId);
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment