-
Notifications
You must be signed in to change notification settings - Fork 20
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
Showing
4 changed files
with
152 additions
and
14 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,18 @@ | ||
| package dto | ||
|
|
||
| import ( | ||
| "gorm.io/gen/field" | ||
| "time" | ||
| ) | ||
|
|
||
| type ContactDto struct { | ||
| ID int64 `json:"ID"` | ||
| // 头像 | ||
| Avatar field.String `json:"avatar"` | ||
| // 会话名称 | ||
| Name string `json:"name"` | ||
| // 最后一条消息内容 | ||
| LastMsg string `json:"last_msg"` | ||
| // 最后一条消息时间 | ||
| LastTime time.Time `json:"last_time"` | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -1 +1,115 @@ | ||
| package service | ||
|
|
||
| import ( | ||
| "DiTing-Go/dal" | ||
| "DiTing-Go/dal/model" | ||
| "DiTing-Go/domain/dto" | ||
| "DiTing-Go/domain/enum" | ||
| "DiTing-Go/global" | ||
| cursorUtils "DiTing-Go/pkg/cursor" | ||
| "DiTing-Go/pkg/resp" | ||
| "context" | ||
| "github.com/gin-gonic/gin" | ||
| "log" | ||
| "strconv" | ||
| ) | ||
|
|
||
| func GetContactListService(c *gin.Context) { | ||
| uid := c.GetInt64("uid") | ||
| // 游标翻页 | ||
| // 默认值 | ||
| var cursor *string = nil | ||
| var pageSize int = 20 | ||
| pageRequest := cursorUtils.PageReq{ | ||
| Cursor: cursor, | ||
| PageSize: pageSize, | ||
| } | ||
| if err := c.ShouldBindQuery(&pageRequest); err != nil { //ShouldBind()会自动推导 | ||
| resp.ErrorResponse(c, "参数错误") | ||
| c.Abort() | ||
| return | ||
| } | ||
| pageResp, err := GetContactList(uid, pageRequest) | ||
| if err != nil { | ||
| resp.ErrorResponse(c, "查询会话列表失败") | ||
| c.Abort() | ||
| return | ||
| } | ||
| resp.SuccessResponse(c, pageResp) | ||
| c.Abort() | ||
| return | ||
| } | ||
|
|
||
| func GetContactList(uid int64, pageRequest cursorUtils.PageReq) (*cursorUtils.PageResp, error) { | ||
| db := dal.DB | ||
| contact := make([]model.Contact, 0) | ||
| condition := []string{"uid=?", strconv.FormatInt(uid, 10)} | ||
| pageResp, err := cursorUtils.Paginate(db, pageRequest, &contact, "active_time", false, condition...) | ||
| if err != nil { | ||
| log.Printf("查询会话列表失败: %s", err.Error()) | ||
| return nil, err | ||
| } | ||
| contactList := pageResp.Data.(*[]model.Contact) | ||
| contactDtoList := make([]dto.ContactDto, 0) | ||
| for _, contact := range *contactList { | ||
| contactDto, err := getContactDto(contact) | ||
| if err != nil { | ||
| log.Printf("查询会话列表失败: %s", err.Error()) | ||
| return nil, err | ||
| } | ||
| contactDtoList = append(contactDtoList, *contactDto) | ||
| } | ||
| pageResp.Data = contactDtoList | ||
| return pageResp, nil | ||
| } | ||
|
|
||
| // 获取会话dto | ||
| func getContactDto(contact model.Contact) (*dto.ContactDto, error) { | ||
| ctx := context.Background() | ||
| room := global.Query.Room | ||
| roomQ := room.WithContext(ctx) | ||
| contactDto := new(dto.ContactDto) | ||
| contactDto.ID = contact.ID | ||
| // 查询房间类型 | ||
| roomR, err := roomQ.Where(room.ID.Eq(contact.RoomID)).First() | ||
| if err != nil { | ||
| return nil, err | ||
| } | ||
| // 如果是个人会话，名称是对方的昵称 | ||
| if roomR.Type == enum.PERSONAL { | ||
| // 查询好友房间信息 | ||
| roomFriend := global.Query.RoomFriend | ||
| roomFriendQ := roomFriend.WithContext(ctx) | ||
| roomFriendR, err := roomFriendQ.Where(roomFriend.RoomID.Eq(roomR.ID)).First() | ||
| if err != nil { | ||
| return nil, err | ||
| } | ||
| var friendUid int64 | ||
| if roomFriendR.Uid1 == contact.UID { | ||
| friendUid = roomFriendR.Uid2 | ||
| } else { | ||
| friendUid = roomFriendR.Uid1 | ||
| } | ||
| user := global.Query.User | ||
| userQ := user.WithContext(ctx) | ||
| userR, err := userQ.Where(user.ID.Eq(friendUid)).First() | ||
| if err != nil { | ||
| return nil, err | ||
| } | ||
| contactDto.Name = userR.Name | ||
| contactDto.Avatar = user.Avatar | ||
| contactDto.LastTime = contact.ActiveTime | ||
|
|
||
| // TODO: 支持多种消息 | ||
| msg := global.Query.Message | ||
| msgQ := msg.WithContext(ctx) | ||
| msgR, err := msgQ.Where(msg.ID.Eq(contact.LastMsgID)).First() | ||
| if err != nil { | ||
| return nil, err | ||
| } | ||
| contactDto.LastMsg = msgR.Content | ||
| } | ||
| // TODO: 返回消息未读数 | ||
| // TODO: 群聊 | ||
| return contactDto, nil | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters