From 2870958e202e0346a48aaab5c066a97051557449 Mon Sep 17 00:00:00 2001 From: lin <550210817@qq.com> Date: Tue, 16 Apr 2024 16:29:15 +0800 Subject: [PATCH] =?UTF-8?q?feat:=20=E6=B7=BB=E5=8A=A0=E8=8E=B7=E5=8F=96?= =?UTF-8?q?=E7=BE=A4=E7=BB=84=E6=88=90=E5=91=98=E5=88=97=E8=A1=A8?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- domain/dto/group_dto.go | 16 +++ domain/vo/req/get_group_member_list_req.go | 8 ++ routes/init_router.go | 1 + service/group_service.go | 119 +++++++++++++++++++++ 4 files changed, 144 insertions(+) create mode 100644 domain/dto/group_dto.go create mode 100644 domain/vo/req/get_group_member_list_req.go diff --git a/domain/dto/group_dto.go b/domain/dto/group_dto.go new file mode 100644 index 0000000..1027ac4 --- /dev/null +++ b/domain/dto/group_dto.go @@ -0,0 +1,16 @@ +package dto + +import "time" + +type GetGroupMemberDto struct { + // 用户ID + UID int64 `json:"uid"` + // 用户名 + Name string `json:"name"` + // 头像 + Avatar string `json:"avatar"` + // 用户状态 + ActiveStatus int32 `json:"active_status"` + // 最后活跃时间 + LastOptTime time.Time `json:"last_active_time"` +} diff --git a/domain/vo/req/get_group_member_list_req.go b/domain/vo/req/get_group_member_list_req.go new file mode 100644 index 0000000..c2aa437 --- /dev/null +++ b/domain/vo/req/get_group_member_list_req.go @@ -0,0 +1,8 @@ +package req + +type GetGroupMemberListReq struct { + // 房间ID + ID int64 `form:"id" binding:"required"` + Cursor *string `form:"cursor" binding:"required"` + PageSize int `form:"page_size" binding:"required"` +} diff --git a/routes/init_router.go b/routes/init_router.go index 9625d90..44a4777 100644 --- a/routes/init_router.go +++ b/routes/init_router.go @@ -69,6 +69,7 @@ func initGin() { apiGroup.DELETE("/:id", service.DeleteGroupService) apiGroup.POST("/join", service.JoinGroupService) apiGroup.POST("/quit", service.QuitGroupService) + apiGroup.GET("/getGroupMemberList", service.GetGroupMemberListService) } apiContact := router.Group("/api/contact") diff --git a/service/group_service.go b/service/group_service.go index 1bbd7c8..76b118b 100644 --- a/service/group_service.go +++ b/service/group_service.go @@ -2,13 +2,18 @@ package service import ( "DiTing-Go/dal/model" + "DiTing-Go/domain/dto" "DiTing-Go/domain/enum" "DiTing-Go/domain/vo/req" "DiTing-Go/global" + "DiTing-Go/pkg/cursor" "DiTing-Go/pkg/resp" "context" + "fmt" "github.com/gin-gonic/gin" "gorm.io/gorm" + "strconv" + "strings" "time" ) @@ -514,3 +519,117 @@ func QuitGroupService(c *gin.Context) { resp.SuccessResponseWithMsg(c, "success") return } + +// GetGroupMemberListService 退出群聊 +// +// @Summary 退出群聊 +// @Produce json +// @Param id body int true "房间id" +// @Success 200 {object} resp.ResponseData "成功" +// @Failure 500 {object} resp.ResponseData "内部错误" +// @Router /api/group/getGroupMemberList [get] +func GetGroupMemberListService(c *gin.Context) { + uid := c.GetInt64("uid") + getGroupMemberListReq := req.GetGroupMemberListReq{} + if err := c.ShouldBindQuery(&getGroupMemberListReq); err != nil { + resp.ErrorResponse(c, "参数错误") + global.Logger.Errorf("参数错误: %v", err) + c.Abort() + return + } + ctx := context.Background() + + // 查询房间表 + room := global.Query.Room + roomQ := room.WithContext(ctx) + roomR, err := roomQ.Where(room.ID.Eq(getGroupMemberListReq.ID)).First() + if err != nil { + resp.ErrorResponse(c, "查询群聊失败") + global.Logger.Errorf("查询房间失败 %s", err) + c.Abort() + return + } + // 查询群聊表 + roomGroup := global.Query.RoomGroup + roomGroupQ := roomGroup.WithContext(ctx) + roomGroupR, err := roomGroupQ.Where(roomGroup.RoomID.Eq(roomR.ID)).First() + if err != nil { + resp.ErrorResponse(c, "查询群聊失败") + global.Logger.Errorf("查询群聊失败 %s", err) + c.Abort() + return + } + + // 查询用户是否在群聊中 + groupMember := global.Query.GroupMember + groupMemberQ := groupMember.WithContext(ctx) + _, err = groupMemberQ.Where(groupMember.UID.Eq(uid), groupMember.GroupID.Eq(roomGroupR.ID)).First() + if err != nil { + resp.ErrorResponse(c, "查询群聊失败") + global.Logger.Errorf("查询群组成员表失败 %s", err) + c.Abort() + return + } + + // 分页查询 + // 默认值 + // 划分游标，status_activateTime + var userR []dto.GetGroupMemberDto + status, activeTime := cursorSplit(getGroupMemberListReq.Cursor) + // 查询群组成员表,联表游标翻页 + user := global.Query.User + userQ := user.WithContext(ctx) + if err := userQ.Select(user.Name, user.Avatar, user.ActiveStatus, user.LastOptTime).LeftJoin(groupMemberQ, user.ID.EqCol(groupMember.UID)).Where(groupMember.GroupID.Eq(roomGroupR.ID), user.ActiveStatus.Eq(int32(status)), user.LastOptTime.Gt(activeTime)).Limit(getGroupMemberListReq.PageSize).Scan(&userR); err != nil { + resp.ErrorResponse(c, "查询群聊失败") + global.Logger.Errorf("查询群组成员表失败 %s", err) + c.Abort() + return + } + // 不足，用不在线的补充 + if len(userR) < getGroupMemberListReq.PageSize && status == 1 { + var add []dto.GetGroupMemberDto + if err := userQ.Select(user.Name, user.Avatar, user.ActiveStatus, user.LastOptTime).LeftJoin(groupMemberQ, user.ID.EqCol(groupMember.UID)).Where(groupMember.GroupID.Eq(roomGroupR.ID), user.ActiveStatus.Eq(2)).Limit(getGroupMemberListReq.PageSize - len(userR)).Scan(&add); err != nil { + resp.ErrorResponse(c, "查询群聊失败") + global.Logger.Errorf("查询群组成员表失败 %s", err) + c.Abort() + return + } + userR = append(userR, add...) + } + + newCursor := genCursor(userR) + resp.SuccessResponse(c, cursor.PageResp{ + Cursor: &newCursor, + IsLast: len(userR) < getGroupMemberListReq.PageSize, + Data: userR, + }) +} + +// 分割游标 +func cursorSplit(cursor *string) (int, time.Time) { + if cursor == nil { + return 1, time.Time{} + } + // TODO： 抽取为常量 + lines := strings.Split(*cursor, "_") + status, err := strconv.Atoi(lines[0]) + if err != nil { + return 1, time.Time{} + } + timeUnix, err := strconv.ParseInt(lines[1], 10, 64) + if err != nil { + return 1, time.Time{} + } + activeTime := time.Unix(timeUnix, timeUnix%1000000000) + return status, activeTime +} + +func genCursor(users []dto.GetGroupMemberDto) string { + if users == nil || len(users) == 0 { + return fmt.Sprintf("%d_%d", 2, time.Now().Unix()) + } + status := users[len(users)-1].ActiveStatus + activeTime := users[len(users)-1].LastOptTime + newCursor := fmt.Sprintf("%d_%d", status, activeTime.Unix()) + return newCursor +}