// index.js
Page({
  subscribeMessage() {
    // 这里填写 能力-互动能力-消息管理-订阅消息 中的模版消息id
    const updateMsgTplId = 'MSG164161657291480498528979256';
    const orderSuccessTplId = 'MSG164158927218123174309792040';

    tt.requestSubscribeMessage({
      // 开放平台申请的模版id  支持最多3个同类型模版
      tmplIds: [updateMsgTplId, orderSuccessTplId],
      success(res) {
        console.log("订阅成功: ", res);
        //订阅成功回调
        let msg1 = "";
        let and = "";
        let msg2 = "";
        if (tt.canIUse('requestSubscribeMessage.success.templateSettings')) {
          const updateResult = res.templateSettings[updateMsgTplId]
          const orderResult = res.templateSettings[orderSuccessTplId]
          msg1 = `更新提醒通知: ${updateResult.status}，是否记住选择${updateResult.alwaysSubscribe}，用户同意的提醒方式: ${updateResult.allowReminderWay.filter(reminder => reminder.reminderStatus === 'accept').map(reminder => reminder.reminderType).join('、')}`;
          msg2 = `下单成功通知: ${orderResult.status}，是否记住选择${orderResult.alwaysSubscribe}，用户同意的提醒方式: ${orderResult.allowReminderWay.filter(reminder => reminder.reminderStatus === 'accept').map(reminder => reminder.reminderType).join('、')}`;
          console.log(msg1)
          console.log(msg2)
          tt.showModal({
            title: '订阅成功',
            content: `${msg1}\n${msg2}`,
            showCancel: false
          })
        } else {
          console.log("更新提醒通知: " + res[updateMsgTplId]);
          console.log("下单成功通知: " + res[orderSuccessTplId]);
          msg1 = res[updateMsgTplId] === "accept" ? "更新提醒通知" : "";
          msg2 = res[orderSuccessTplId] === "accept" ? "下单成功通知" : "";
          and = msg1 && msg2 && "及";
          tt.showModal({
            content: `${msg1}${and}${msg2} 订阅成功`,
            showCancel: false
          })
        }
      },
      fail(res) {
        //订阅失败回调
        console.log("订阅失败,错误码: ", res.errNo);
        tt.showModal({
          title: "订阅失败",
          content: `errNo: ${res.errNo || "暂时未加"}`,
          showCancel: false
        });
      },
      complete(res) {
        //完成回调
        console.log("API调用完成: " + res.errMsg);
      },
    });
  }
})

{
    "event": "user_subscribe_action",
    "clieng_key": "tt5daf2b12c28579**",
    "FromUserID": "12934983615879**",
    "content": {
        "msg_id": "MSG351287538173587336778382563**",
        "time": 1714029835,
        "subscribe_action": 1
    }
}

curl --location --request POST 'https://open.douyin.com/api/notification/v2/subscription/notify_user/' \
--header 'access-token: clt.828745d039ea5257c2dadd0d9f263a64CvAcJRBeZ7VhZukAHxVFcXGn*******' \
--header 'content-type: application/json' \
--data '
  {
  "msg_id": "MSG35128757637369807924748699***",
  "open_id": "-cg5WWbptADwbO**",
  "data": {
    "小程序模板keyword1": "测试值1",
    "小程序模板keyword2": "测试值2"
  },
  "notify_type":[1,2]
  "page": "pages/index?a=b"
  }
'

import (
    "context"
    "errors"
    credential "github.com/bytedance/douyin-openapi-credential-go/client"
    openApiSdkClient "github.com/bytedance/douyin-openapi-sdk-go/client"
)

func NotifyUser(ctx context.Context) (errNo int32, errMsg string, err error) {
    // 控制台-开发-开发配置-小程序Key
    var appId = "tt5daf2b12c2857***"
    var appSecret = "ce842aa2db63bf351cdba292e05f41c5955fd***"

    // 初始化SDK client
    opt := new(credential.Config).
       SetClientKey(appId).
       SetClientSecret(appSecret)

    // token获取与注入
    // credential包提供了默认的token获取方法，但是该实现方式是基于单实例的，如果用户多实例场景使用会出现token互刷的问题。
    // 开发者如果有多实例部署的需求可以自行实现token获取的逻辑
    credentialHandler, err := credential.NewCredential(opt)
    if err != nil {
       return errNo, errMsg, err
    }
    token, err := credentialHandler.GetClientToken()
    if err != nil {
       return errNo, errMsg, err
    }

    // 初始化参数
    var key1 = "小程序模板key1"
    var key2 = "小程序模板key2"
    var val1 = "小程序模板val1"
    var val2 = "小程序模板val2"
    var msgId = "MSG35128757127369095129904351***"
    var openId = "T25CX9BGuQLeA***"
    var notifyTypePush, notifyTypeNotice = 1, 2
    var notifyType = []*int{&notifyTypePush, &notifyTypeNotice}
    var page = "pages/index?a=b"

    sdkClient, err := openApiSdkClient.NewClient(opt)
    if err != nil {
       return errNo, errMsg, err
    }
    sdkRequest := &openApiSdkClient.SubscriptionNotifyUserRequest{
       AccessToken: token.AccessToken,
       Data: map[string]*string{
          key1: &val1,
          key2: &val2,
       },
       MsgId:      &msgId,
       OpenId:     &openId,
       NotifyType: notifyType,
       Page:       &page,
    }
    // sdk调用
    sdkResponse, err := sdkClient.SubscriptionNotifyUser(sdkRequest)
    if err != nil {
       return errNo, errMsg, err
    }
    if sdkResponse == nil {
       return errNo, errMsg, errors.New("resp is nil")
    }

    errNo = *sdkResponse.ErrNo
    errMsg = *sdkResponse.ErrMsg

    return
}