From 54665ca8160c1e23cb669593f30caf3bb263d72d Mon Sep 17 00:00:00 2001
From: 777 <123@qwe.com>
Date: Thu, 21 Aug 2025 01:14:43 +0800
Subject: [PATCH] V13

---
 .../src/test/java/com/ruoyi/test/OpTest.java  | 25 +++++++++++++++++++
 .../impl/AnchorImCountDayServiceImpl.java     | 15 +++++------
 .../mapper/cai/AnchorImCountDayMapper.xml     |  2 +-
 3 files changed, 34 insertions(+), 8 deletions(-)

diff --git a/ruoyi-admin/src/test/java/com/ruoyi/test/OpTest.java b/ruoyi-admin/src/test/java/com/ruoyi/test/OpTest.java
index 98fc89ea..c854b692 100644
--- a/ruoyi-admin/src/test/java/com/ruoyi/test/OpTest.java
+++ b/ruoyi-admin/src/test/java/com/ruoyi/test/OpTest.java
@@ -1,14 +1,19 @@
 package com.ruoyi.test;
 
 import com.alibaba.fastjson.JSON;
+import com.ruoyi.cai.service.AnchorImCountDayService;
+import com.ruoyi.web.controller.monitor.SysOperlogController;
 import com.ruoyi.yunxin.client.ImUserRefClient;
 import com.ruoyi.yunxin.req.GetUnifoReq;
 import com.ruoyi.yunxin.resp.YxUpdateUinfoR;
 import lombok.extern.slf4j.Slf4j;
 import org.junit.jupiter.api.Test;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.boot.test.context.SpringBootTest;
 
 import javax.annotation.Resource;
+import java.time.LocalDate;
+import java.time.LocalDateTime;
 
 @SpringBootTest // 此注解只能在 springboot 主包下使用 需包含 main 方法与 yml 配置文件
 @Slf4j
@@ -16,6 +21,8 @@ public class OpTest {
 
     @Resource
     private ImUserRefClient imUserRefClient;
+    @Autowired
+    private AnchorImCountDayService anchorImCountDayService;
 
     @Test
     public void test(){
@@ -25,4 +32,22 @@ public class OpTest {
         YxUpdateUinfoR uinfos = imUserRefClient.getUinfos(getUnifoReq);
         log.info(JSON.toJSONString(uinfos));
     }
+
+    @Test
+    public void test1(){
+        anchorImCountDayService.incCount(2L);
+        anchorImCountDayService.incCount(2L);
+        anchorImCountDayService.incCount(2L);
+        anchorImCountDayService.incCount(2L);
+        anchorImCountDayService.incCount(2L);
+        anchorImCountDayService.incCount(2L);
+        anchorImCountDayService.incCount(4L);
+        anchorImCountDayService.incCount(4L);
+        anchorImCountDayService.incCount(4L);
+        anchorImCountDayService.incCount(4L);
+        anchorImCountDayService.incCount(4L);
+        System.out.println("asd");
+        anchorImCountDayService.refreshCount(LocalDate.now());
+        anchorImCountDayService.totalUserCount();
+    }
 }
diff --git a/ruoyi-cai/src/main/java/com/ruoyi/cai/service/impl/AnchorImCountDayServiceImpl.java b/ruoyi-cai/src/main/java/com/ruoyi/cai/service/impl/AnchorImCountDayServiceImpl.java
index e59f55ba..5988fdae 100644
--- a/ruoyi-cai/src/main/java/com/ruoyi/cai/service/impl/AnchorImCountDayServiceImpl.java
+++ b/ruoyi-cai/src/main/java/com/ruoyi/cai/service/impl/AnchorImCountDayServiceImpl.java
@@ -74,8 +74,8 @@ public class AnchorImCountDayServiceImpl extends ServiceImpl<AnchorImCountDayMap
     public void incCount(Long userId){
         try {
             String redisKey = getRedisKey(LocalDate.now());
-            RMap<Long, Long> map = redissonClient.getMap(redisKey);
-            Long newScore = map.addAndGet(userId, 1);
+            RMap<Long, Integer> map = redissonClient.getMap(redisKey);
+            Integer newScore = map.addAndGet(userId, 1);
             if(newScore == 1){
                 map.expire(5, TimeUnit.DAYS);
             }
@@ -87,11 +87,11 @@ public class AnchorImCountDayServiceImpl extends ServiceImpl<AnchorImCountDayMap
     @Override
     public void refreshCount(LocalDate localDate){
         String redisKey = getRedisKey(localDate);
-        RMap<Long, Long> map = redissonClient.getMap(redisKey);
-        Map<Long, Long> longMap = map.readAllMap();
-        for (Map.Entry<Long, Long> entry : longMap.entrySet()) {
+        RMap<Long, Integer> map = redissonClient.getMap(redisKey);
+        Map<Long, Integer> longMap = map.readAllMap();
+        for (Map.Entry<Long, Integer> entry : longMap.entrySet()) {
             Long userId = entry.getKey();
-            Long imCount = entry.getValue();
+            Integer imCount = entry.getValue();
             AnchorImCountDay one = this.getOne(Wrappers.lambdaQuery(AnchorImCountDay.class)
                     .eq(AnchorImCountDay::getCountDate, localDate)
                     .eq(AnchorImCountDay::getUserId, userId));
@@ -101,7 +101,8 @@ public class AnchorImCountDayServiceImpl extends ServiceImpl<AnchorImCountDayMap
                         .set(AnchorImCountDay::getImCount, imCount));
             }else{
                 one = new AnchorImCountDay();
-                one.setImCount(imCount);
+                one.setCountDate(localDate);
+                one.setImCount(Long.valueOf(imCount));
                 one.setUserId(userId);
                 one.setRefreshTime(LocalDateTime.now());
                 this.save(one);
diff --git a/ruoyi-cai/src/main/resources/mapper/cai/AnchorImCountDayMapper.xml b/ruoyi-cai/src/main/resources/mapper/cai/AnchorImCountDayMapper.xml
index 73a6e685..294c5ea0 100644
--- a/ruoyi-cai/src/main/resources/mapper/cai/AnchorImCountDayMapper.xml
+++ b/ruoyi-cai/src/main/resources/mapper/cai/AnchorImCountDayMapper.xml
@@ -6,7 +6,7 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
     <select id="pageAdmin" resultType="com.ruoyi.cai.dto.admin.vo.AnchorImCountDayAdminVO">
         select t1.*,t2.usercode,t2.nickname,t2.mobile,t2.avatar,t2.gender,t2.is_anchor,t2.age,t2.im_speck,t2.enable_im,t2.status
         from cai_anchor_im_count_day t1
-        left join cai_user t2 on t1.user_id = t2.id
+        join cai_user t2 on t1.user_id = t2.id
         <where>
             <if test="bo.mobile != null and bo.mobile != ''">
                 and t2.mobile = #{bo.mobile}