From 12397b2d0a8d001b8f46f82fa2cb975cefc8a942 Mon Sep 17 00:00:00 2001 From: iamhujiebin <458249864@qq.com> Date: Sun, 3 Sep 2023 14:03:07 +0800 Subject: [PATCH] =?UTF-8?q?feat:SyncGroupRoomLiving=E5=8A=9F=E6=88=90?= =?UTF-8?q?=E8=BA=AB=E9=80=80?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- route/router.go | 24 ------------------------ 1 file changed, 24 deletions(-) diff --git a/route/router.go b/route/router.go index 14dbf43..ef4619c 100644 --- a/route/router.go +++ b/route/router.go @@ -5,11 +5,9 @@ import ( "git.hilo.cn/hilo-common/domain" "git.hilo.cn/hilo-common/mycontext" "github.com/gin-gonic/gin" - "github.com/go-redis/redis/v8" ginSwagger "github.com/swaggo/gin-swagger" "github.com/swaggo/gin-swagger/swaggerFiles" "hilo-user/_const/enum/msg_e" - "hilo-user/_const/redis_key/group_k" _ "hilo-user/docs" "hilo-user/domain/model/msg_m" "hilo-user/resp" @@ -90,7 +88,6 @@ func InitRouter() *gin.Engine { innerProp.POST("/ride/send", wrapper(user_r.SendUserRide)) // 下发座驾 } r.GET("/test", wrapper(Test)) - r.GET("/sync/group_room_living", wrapper(SyncGroupRoomLiving)) return r } @@ -106,24 +103,3 @@ func Test(c *gin.Context) (*mycontext.MyContext, error) { resp.ResponseOk(c, struct{}{}) return myCtx, nil } - -func SyncGroupRoomLiving(c *gin.Context) (*mycontext.MyContext, error) { - myCtx := mycontext.CreateMyContext(c.Keys) - var model = domain.CreateModelContext(myCtx) - key := group_k.GetPrefixGroupRoomLiving() - res, err := model.Redis.ZRangeWithScores(model, key, 0, -1).Result() - if err != nil { - return myCtx, err - } - for _, v := range res { - err := model.RedisCluster.ZAdd(model, key, &redis.Z{ - Score: v.Score, - Member: v.Member, - }).Err() - if err != nil { - return myCtx, err - } - } - resp.ResponseOk(c, struct{}{}) - return myCtx, nil -} -- 2.22.0