对讲机模式

// 启动或关闭对讲机模式
public func enablePushToTalk(enable: Bool) {
    var sendDict: [String: Any] = [
        "type": 1105,
    ]
    sendDict.updateValue(myUid, forKey: "senderId")
    sendDict.updateValue(robotUid, forKey: "receiverId")
    sendDict.updateValue(["enable": enable], forKey: "data")
    
    if let sendData = sendDict.aicall_jsonString.data(using: .utf8) {
        let rtcMsg = AliRtcDataChannelMsg()
        rtcMsg.type = .custom
        rtcMsg.data = sendData
        self.rtcEngine.sendDataChannelMessage(rtcMsg)

        self.rtcEngine.muteLocalMic(enable, mode: .allAudioMode)
    }
}

// 按住讲话，请确保已经启动对讲机模式
public func startPushToTalk() {
    var sendDict: [String: Any] = [
        "type": 1106,
    ]
    sendDict.updateValue(myUid, forKey: "senderId")
    sendDict.updateValue(robotUid, forKey: "receiverId")
    
    if let sendData = sendDict.aicall_jsonString.data(using: .utf8) {
        let rtcMsg = AliRtcDataChannelMsg()
        rtcMsg.type = .custom
        rtcMsg.data = sendData
        self.rtcEngine.sendDataChannelMessage(rtcMsg)
        // 取消静音麦克风
        self.rtcEngine.muteLocalMic(false, mode: .allAudioMode)
    }
}

// 完成讲话，请确保已经启动对讲机模式
public func finishPushToTalk() {
    var sendDict: [String: Any] = [
        "type": 1107,
    ]
    sendDict.updateValue(myUid, forKey: "senderId")
    sendDict.updateValue(robotUid, forKey: "receiverId")
    
    if let sendData = sendDict.aicall_jsonString.data(using: .utf8) {
        let rtcMsg = AliRtcDataChannelMsg()
        rtcMsg.type = .custom
        rtcMsg.data = sendData
        self.rtcEngine.sendDataChannelMessage(rtcMsg)
        // 取消静音麦克风
        self.rtcEngine.muteLocalMic(true, mode: .allAudioMode)
    }
}

// 取消这次发送，请确保已经启动对讲机模式
public func cancelPushToTalk() {
    var sendDict: [String: Any] = [
        "type": 1108,
    ]
    sendDict.updateValue(myUid, forKey: "senderId")
    sendDict.updateValue(robotUid, forKey: "receiverId")
    
    if let sendData = sendDict.aicall_jsonString.data(using: .utf8) {
        let rtcMsg = AliRtcDataChannelMsg()
        rtcMsg.type = .custom
        rtcMsg.data = sendData
        self.rtcEngine.sendDataChannelMessage(rtcMsg)
        // 取消静音麦克风
        self.rtcEngine.muteLocalMic(true, mode: .allAudioMode)
    }
}

// 处理接收到的DataChannel消息
public func onDataChannelMessage(_ uid: String, controlMsg: AliRtcDataChannelMsg) {    
    if controlMsg.type != .custom {
        return
    }

    let dataDict = (try? JSONSerialization.jsonObject(with: controlMsg.data, options: .allowFragments)) as? [String : Any]
    guard let dataDict = dataDict else {
        return
    }
    debugPrint("onDataChannelMessage:\(dataDict)")
    if dataDict["type"] as? Int32 == 1007 {
        let data = dataDict["data"] as? [String: Any]
        if let data = data {
            if let enable = data["enable"] as? Bool {
                // 服务端已经开启/关闭对讲机模式，参考流程
                DispatchQueue.main.async {
                    self.enablePushToTalk = enable
                    self.rtcEngine.muteLocalMic(enable, mode: .allAudioMode)
                }
            }
            
        }
    }
    // 处理其他消息
    ...
}

public void sendCustomMessage(int msgType, JSONObject data) {
    if (null != mAliRtcEngine) {
        try {
            String senderId; // 自己的用户id
            String receiverId; // 机器人用户id

            JSONObject jsonObject = new JSONObject();
            jsonObject.put("type", msgType);
            jsonObject.put("senderId", senderId);
            jsonObject.put("receiverId", receiverId);
            if (null != data) {
                jsonObject.put("data", data);
            }
            AliRtcEngine.AliRtcDataChannelMsg rtcDataChannelMsg = new AliRtcEngine.AliRtcDataChannelMsg();
            rtcDataChannelMsg.type = AliEngineDataMsgCustom;
            rtcDataChannelMsg.data = jsonObject.toString().getBytes(StandardCharsets.UTF_8);
            mAliRtcEngine.sendDataChannelMsg(rtcDataChannelMsg);
        } catch (JSONException ex) {
            ex.printStackTrace();
        }
    }
}

// 启动或关闭对讲机模式
public boolean enablePushToTalk(boolean enable) {
JSONObject jsonObject = new JSONObject();
jsonObject.put("enable", enable);
// 向机器人发送消息
sendCustomMessage(1105, jsonObject);
// 静音麦克风
mAliRtcEngine.muteLocalMic(enable, AliRtcEngine.AliRtcMuteLocalAudioMode.AliRtcMuteAllAudioMode);
}

// 按住讲话，请确保已经启动对讲机模式
public func startPushToTalk() {
    // 向机器人发送消息
    sendCustomMessage(1106, null);
    // 取消静音麦克风
    mAliRtcEngine.muteLocalMic(false, AliRtcEngine.AliRtcMuteLocalAudioMode.AliRtcMuteAllAudioMode);
}

// 完成讲话，请确保已经启动对讲机模式
public func finishPushToTalk() {
    // 向机器人发送消息
    sendCustomMessage(1107, null);
    // 静音麦克风
    mAliRtcEngine.muteLocalMic(true, AliRtcEngine.AliRtcMuteLocalAudioMode.AliRtcMuteAllAudioMode);
}

// 取消这次发送，请确保已经启动对讲机模式
public func cancelPushToTalk() {
    // 向机器人发送消息
    sendCustomMessage(1108, null);
    // 静音麦克风
    mAliRtcEngine.muteLocalMic(true, AliRtcEngine.AliRtcMuteLocalAudioMode.AliRtcMuteAllAudioMode);
}

// 处理接收到的DataChannel消息
private AliRtcEngineNotify mRtcEngineRemoteNotify = new AliRtcEngineNotify() {

    @Override
    public void onDataChannelMessage(String uid, AliRtcEngine.AliRtcDataChannelMsg msg) {
        super.onDataChannelMessage(uid, msg);
        if (msg.type == AliEngineDataMsgCustom) {
            String dataStr = new String(msg.data);
            JSONObject jsonObject = new JSONObject(dataStr);
            JSONObject dataJson = jsonObject.optJSONObject("data");
            int msgType = jsonObject.optInt("type");
            if (msgType == 1007) {
                boolean enable = dataJson.optBoolean("enable");
                // 机器人通知对讲机模式状态，业务处理...
            }
        }
    }
}

// 启动或关闭对讲机模式
public enablePushToTalk(enable: boolean) { }

// 按住讲话，请确保已经启动对讲机模式
public startPushToTalk(): boolean { }

// 完成讲话，请确保已经启动对讲机模式
public finishPushToTalk(): boolean { }

// 取消这次发送，请确保已经启动对讲机模式
public cancelPushToTalk(): boolean { }

controller.on('AICallPushToTalkChanged', (enable: boolean) => {
    // 当前对讲机模式变化为 {enable}
})