前言

本文我们基于飞书开放平台提供的服务端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处断点，然后再飞书上读消息后，继续运行结果如下：