清理15天之前的访客

domain/cache/group_c/enter_room.go

@@ -66,8 +66,10 @@ func GetUserRecentRooms(model *domain.Model, userId uint64) (imGroupIds []string
 // 15天前访问的
 func RemoveRoomVisitors(model *domain.Model, imGroupId string) {
 	groupKey := group_k.GetUserEnterRoomGroupKey(imGroupId)
-	err := model.Redis.ZRemRangeByScore(model, groupKey, "-inf", fmt.Sprintf("%d", time.Now().AddDate(0, 0, -15).Unix())).Err()
+	n, err := model.Redis.ZRemRangeByScore(model, groupKey, "-inf", fmt.Sprintf("%d", time.Now().AddDate(0, 0, -15).Unix())).Result()
 	if err != nil {
 		model.Log.Errorf("RemoveRoomVisitors fail:%v", err)
+	} else {
+		model.Log.Infof("RemoveRoomVisitors key:%v,n:%v", groupKey, n)
 	}
 }

route/group_r/group_list.go

@@ -973,6 +973,8 @@ func GetGroupVisitors(c *gin.Context) (*mycontext.MyContext, error) {
 		}
 	}
 	resp.ResponseOk(c, result)
+	// 清理15天之前的访客
+	group_c.RemoveRoomVisitors(model, groupId)
 	return myContext, nil
 }
 

test/user_test.go

@@ -2,6 +2,7 @@ package test
 
 import (
 	"git.hilo.cn/hilo-common/domain"
+	"hilo-group/domain/cache/group_c"
 	"hilo-group/domain/model/user_m"
 	"testing"
 )
@@ -23,3 +24,7 @@ func TestGetUserVipMap(t *testing.T) {
 	res, err := user_m.BatchGetVips(userIds)
 	t.Logf("%v-%v", res, err)
 }
+
+func TestRemoveRoomVisit(t *testing.T) {
+	group_c.RemoveRoomVisitors(domain.CreateModelNil(), "HTGS#a47478749")
+}