前言

本文我們基于飛書(shū)開(kāi)放平臺(tái)提供的服務(wù)端SDK，展示下如何查詢一個(gè)消息有哪些人已讀了。

代碼示例

本文我們基于飛書(shū)開(kāi)平提供的go-sdk進(jìn)行展示，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) {
    // 創(chuàng)建請(qǐng)求對(duì)象
    req := larkim.NewReadUsersMessageReqBuilder().
        MessageId(msgID).
        UserIdType(larkim.UserIdTypeOpenId).
        PageSize(5).
        Build()

    // 循環(huán)查詢
    for {
        // 發(fā)起請(qǐng)求
        resp, err := client.Im.Message.ReadUsers(context.Background(), req)

        // 處理錯(cuò)誤
        if err != nil {
            fmt.Println(err)
            return
        }

        // 服務(wù)端錯(cuò)誤處理
        if !resp.Success() {
            fmt.Println(resp.Code, resp.Msg, resp.RequestId())
            return
        }

        // 業(yè)務(wù)處理
        fmt.Println(larkcore.Prettify(resp))

        // 是否還有分頁(yè)數(shù)據(jù)，沒(méi)有則直接返回
        if *resp.Data.HasMore == false {
            return
        }

        // 構(gòu)造下一次請(qǐng)求體
        req = larkim.NewReadUsersMessageReqBuilder().
            MessageId("om_d40652dbee7f23b01cba4348102dedd1").
            UserIdType(larkim.UserIdTypeOpenId).
            PageSize(5).
            PageToken(*resp.Data.PageToken). // 下一次查詢
            Build()
    }
}

func main() {
    // 創(chuàng)建 Client
    var appID, appSecret = os.Getenv("APP_ID"), os.Getenv("APP_SECRET")
    client := lark.NewClient(appID, appSecret)

    // 發(fā)送消息
    msgID, err := SendTextMsg2(client)
    if err != nil {
        fmt.Println(err)
        return
    }

    // 讀取已讀信息
    ReadUsersMsg(client, msgID)

    // 讀取已讀信息
    ReadUsersMsg(client, msgID)

}

debug運(yùn)行，然后再ReadUsersMsg處斷點(diǎn)，然后再飛書(shū)上讀消息后，繼續(xù)運(yùn)行結(jié)果如下：

image.png

配套講解視頻

https://www.bilibili.com/video/BV1JY41197rp/?spm_id_from=333.999.0.0&vd_source=7ccc270970b6d95e716350d3f0ebff69