// addSimpleMsgListenerを呼び出してイベントリスナーを設定します
V2TIMManager.getInstance().addSimpleMsgListener(sdkListener);

/**
 * 1対1チャットのカスタムメッセージを受信します
 * @param msgID メッセージID
 * @param sender 送信者情報
 * @param customData 送信内容
 */
public void onRecvC2CCustomMessage(String msgID, V2TIMUserInfo sender, byte[] customData) {
    Log.i("onRecvC2CCustomMessage", "msgID:" + msgID + ", from:" + sender.getNickName() + ", content:" + new String(customData));
    try {
        String jsonString = new String(customData, "UTF-8");
        JSONObject jsonObject = new JSONObject(jsonString);
        System.out.println("onRecvGroupCustomMessage: " + jsonObject);
        handleMessage(jsonObject);
     } catch (UnsupportedEncodingException e) {
        System.out.println("The data is not a dictionary.");
     } catch (JSONException e) {
        System.out.println("Error parsing JSON: " + e);
     }
}

const onMessageReceived = (event) => {
  const messageList = event.data;
  messageList?.forEach((msg) => {
    if (msg.type === TencentCloudChat.TYPES.MSG_CUSTOM) {
      console.log('カスタムメッセージを受信しました', event);
      const { data } = msg.payload;
      try {
        const jsonData = JSON.parse(data);
        console.log(`receive custom msg from ${msg.from} data: ${data}`);
        if (jsonData.type === 10000) {
          console.log('字幕メッセージ', jsonData);
          return;
        }
        if (jsonData.type === 10001) {
          console.log('ボットの状態', jsonData);
          return;
        }
        if (jsonData.type === 10010) {
          console.log('大規模モデルメッセージのパススルー・ダウンリンク', jsonData);
          return;
        }
      } catch (error) {
        console.error('receive custom msg', data, error);
      }
    }
  });
}

// メッセージを監視
chat.on(TencentCloudChat.EVENT.MESSAGE_RECEIVED, onMessageReceived);

public void interruptAi() {
    long timestamp = System.currentTimeMillis();
    Map<String, Object> payload = new HashMap<>();
    payload.put("id", userId + "_" + roomId + "_" + timestamp); // メッセージid、uuidを使用可能、問題の調査に使用
    payload.put("timestamp", timestamp); // タイムスタンプ、問題の調査に使用
    payload.put("taskid", aiTaskId);

    Map<String, Object> content = new HashMap<>();
    content.put("type", 20001);
    content.put("sender", userId);
    content.put("receiver", Collections.singletonList(botId));
    content.put("payload", payload);

    String contentString = new JSONObject(content).toString();

    Map<String, Object> dataDict = new HashMap<>();
    dataDict.put("service_command", "trtc_ai_service.SendCustomCmdMsg");
    dataDict.put("request_content", contentString);

    try {
        byte[] jsonData = new JSONObject(dataDict).toString().getBytes("UTF-8");
        V2TIMManager.getInstance().callExperimentalAPI("sendTRTCCustomData", jsonData, new V2TIMValueCallback() {
            @Override
            public void onSuccess(Object o) {
                System.out.println("sendTRTCCustomData success");
            }
            @Override
            public void onError(int code, String desc) {
                System.out.println("sendTRTCCustomData error, " + code + ", " + (desc != null ? desc : "null"));
            }
        });
    } catch (UnsupportedEncodingException e) {
        System.out.println("Error serializing dictionary to JSON: " + e);
    }
}

// 中断シグナルを送信
chat.callExperimentalAPI('sendTRTCCustomData', {
serviceCommand: 'trtc_ai_service.SendCustomCmdMsg',
data: {
  type: 20001,
  sender: "user_a", // 送信者useridであり、サーバー側はこのuseridが有効かどうかをチェックします
  receiver: ["user_bot"], // 受信者 userid リストであり、ボットのuseridを記入するだけで十分です
  payload: {
    id: "uuid", // メッセージid、uuidを使用可能、問題の調査に使用
    timestamp: 123, // タイムスタンプ、問題の調査に使用
    taskid: "タスクのtaskid"
  }
}
});