// 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"
  }
}
});