前言
本文我们基于飞书开放平台提供的服务端SDK，展示下如何查询一个消息有哪些人已读了。
代码示例
本文我们基于飞书开平提供的go-sdk进行展示，go-sdk的github地址为：
https://github.com/larksuite/oapi-sdk-go
代码示例如下：
package main
import (
"context"
"errors"
"fmt"
"github.com/larksuite/oapi-sdk-go/v3"
"github.com/larksuite/oapi-sdk-go/v3/core"
"github.com/larksuite/oapi-sdk-go/v3/service/im/v1"
"os"
)
// GET /open-apis/im/v1/messages/:message_id/read_users
func SendTextMsg2(client *lark.Client) (string, error) {
content := larkim.NewTextMsgBuilder().
Text("hello,world").
Build()
resp, err := client.Im.Message.Create(context.Background(), larkim.NewCreateMessageReqBuilder().
ReceiveIdType(larkim.ReceiveIdTypeChatId).
Body(larkim.NewCreateMessageReqBodyBuilder().
MsgType(larkim.MsgTypeText).
ReceiveId("oc_ccd2e318ba972a9d5d282e4da2a3d160").
Content(content).
Build()).
Build())
if err != nil {
return "", err
}
if !resp.Success() {
return "", errors.New(fmt.Sprintf("%d,%s,%s", resp.Code, resp.Msg, resp.RequestId()))
}
fmt.Println(resp.Data.MessageId)
fmt.Println(larkcore.Prettify(resp))
fmt.Println(resp.RequestId())
return *resp.Data.MessageId, nil
}
func ReadUsersMsg(client *lark.Client, msgID string) {
// 创建请求对象
req := larkim.NewReadUsersMessageReqBuilder().
MessageId(msgID).
UserIdType(larkim.UserIdTypeOpenId).
PageSize(5).
Build()
// 循环查询
for {
// 发起请求
resp, err := client.Im.Message.ReadUsers(context.Background(), req)
// 处理错误
if err != nil {
fmt.Println(err)
return
}
// 服务端错误处理
if !resp.Success() {
fmt.Println(resp.Code, resp.Msg, resp.RequestId())
return
}
// 业务处理
fmt.Println(larkcore.Prettify(resp))
// 是否还有分页数据，没有则直接返回
if *resp.Data.HasMore == false {
return
}
// 构造下一次请求体
req = larkim.NewReadUsersMessageReqBuilder().
MessageId("om_d40652dbee7f23b01cba4348102dedd1").
UserIdType(larkim.UserIdTypeOpenId).
PageSize(5).
PageToken(*resp.Data.PageToken). // 下一次查询
Build()
}
}
func main() {
// 创建 Client
var appID, appSecret = os.Getenv("APP_ID"), os.Getenv("APP_SECRET")
client := lark.NewClient(appID, appSecret)
// 发送消息
msgID, err := SendTextMsg2(client)
if err != nil {
fmt.Println(err)
return
}
// 读取已读信息
ReadUsersMsg(client, msgID)
// 读取已读信息
ReadUsersMsg(client, msgID)
}
debug运行，然后再ReadUsersMsg处断点，然后再飞书上读消息后，继续运行结果如下：
image.png
