GHZLangChao/Assets/Game/Blue/RTC/Service/RTCService.cs

using System.Collections;
using System.Collections.Generic;
using System.Text;
using Blue;
using GHZLangChao;
using Newtonsoft.Json;
using Newtonsoft.Json.Linq;
using UnityEngine;
using UnityEngine.Networking;

public class RTCService : IRTCService
{
    private string mToken;
    private RTCRoomInfo mRTCRoomInfo;
    private List<RTCUserInfo> mUserList =new List<RTCUserInfo>(); // 房间用户列表
    public Dictionary<int, RTCUserInfo> mUserDic{ get; private set; } = new Dictionary<int, RTCUserInfo>(); // 房间用户字典
    public void OnInit()
    {
        // 创建房间
        this.RegisterEvent<RTCCreatRoomSuccessEvent>(RTCCreatRoomSuccess);
        // 连接RTC
        this.RegisterEvent<RTCConnectSuccessEvent>(RTCConnectSuccess);
        this.RegisterEvent<RTCConnectFailEvent>(RTCConnectFail);
        // 加入房间
        this.RegisterEvent<JoinRoomSuccessEvent>(JoinRoomSuccess);
        // 其他用户加入房间
        this.RegisterEvent<OtherUserJoinRoomEvent>(OtherUserJoinRoom);
        this.RegisterEvent<OtherLeaveRoomEvent>(OtherLeaveRoom);
    }

    /// <summary>
    /// 关闭RTC
    /// </summary>
    public void CloseRTC()
    {

    }

    /// <summary>
    /// 根据Token创建房间
    /// </summary>
    public void CreatRoom()
    {
        CoroutineSystem.Instance.StartCoroutine(RTCCreateRoom());
    }

    /// <summary>
    /// 根据url连接rtc
    /// </summary>
    public void ConnectByRTCUrl(string URL)
    {
        this.SendEvent<RTCConnectSuccessEvent>();
        //this.SendEvent<RTCConnectFailEvent>();
    }

    /// <summary>s
    /// 加入房间
    /// </summary>
    public void JoinRoom(int roomId)
    {
        CoroutineSystem.Instance.StartCoroutine(RTCJoinRoom(roomId.ToString()));
    }

    /// <summary>
    /// 退出房间
    /// </summary>
    public void LeaveRoom()
    {
        mUserList.Clear();
        mUserDic.Clear();
        Debug.LogError($"离开房间");
    }

    /// <summary>
    /// 控制摄像头
    /// </summary>
    public void ActiveVideo(bool active)
    {
        Debug.LogError($"ActiveVideo:{active}");
    }
    /// <summary>
    /// 控制麦克风
    /// </summary>
    public void ActiveAudio(bool active)
    {
        Debug.LogError($"ActiveAudio:{active}");
    }

    /// <summary>
    /// 将远程视频流静音
    /// </summary>
    public void MuteRemoteVideoStream(string userID, bool active)
    {
        Debug.LogError($"远程视频流===> 用户：{userID},开关：{active}");
    }

    /// <summary>
    /// 将远程音频流静音
    /// </summary>
    public void MuteRemoteAudioStream(string userID, bool active)
    {
        Debug.LogError($"远程视频流===> 用户：{userID},开关：{active}");
    }

    /// <summary>
    /// 视频静音
    /// </summary>
    public void MuteVideo(bool active)
    {
        Debug.LogError($"视频静音：{active}");
    }

    /// <summary>
    /// 音频静音
    /// </summary>
    public void MuteAudio(bool active)
    {
        Debug.LogError($"音频静音{active}");
    }

    /// <summary>
    /// 打开本地视频
    /// </summary>
    public void LocalVideo(bool active)
    {
        Debug.LogError($"打开本地视频{active}");
    }

    /// <summary>
    /// 打开本地音频
    /// </summary>
    public void LoacalAudio(bool active)
    {
        Debug.LogError($"打开本地音频{active}");
    }


    #region  事件

    // 创建房间
    private void RTCCreatRoomSuccess(RTCCreatRoomSuccessEvent e)
    {
        Debug.LogError($"创建房间成功,房间ID:{e.rtcRoomInfo.roomId}");
        //ConnectByRTCUrl(e.rtcRoomInfo.host);

        JoinRoom(e.rtcRoomInfo.roomId);
    }

    // 加入房间
    private void JoinRoomSuccess(JoinRoomSuccessEvent e)
    {
        Debug.LogError($"加入房间成功，房间号：{e.rtcRoomInfo.roomId}");
    }

    // 连接RTC
    private void RTCConnectSuccess(RTCConnectSuccessEvent e)
    {
        Debug.LogError($"RTC:RTCConnectSuccess");
        this.UnRegisterEvent<RTCConnectSuccessEvent>(RTCConnectSuccess);
    }
    private void RTCConnectFail(RTCConnectFailEvent e)
    {
        Debug.LogError($"RTC:RTCConnectFail");
        this.UnRegisterEvent<RTCConnectFailEvent>(RTCConnectFail);
    }

    // 其他用户
    private void OtherUserJoinRoom(OtherUserJoinRoomEvent e)
    {
        RTCUserInfo RTCUserInfo = JsonConvert.DeserializeObject<RTCUserInfo>(e.rtcUserInfoJsonString);
        if(!mUserDic.ContainsKey(RTCUserInfo.UserID))
        {
            mUserDic.Add(RTCUserInfo.UserID,RTCUserInfo);
            mUserList.Add(RTCUserInfo);
        }
        this.UnRegisterEvent<OtherUserJoinRoomEvent>(OtherUserJoinRoom);
    }
    private void OtherLeaveRoom(OtherLeaveRoomEvent e)
    {
        RTCUserInfo RTCUserInfo = JsonConvert.DeserializeObject<RTCUserInfo>(e.rtcUserInfoJsonString);
        if(mUserDic.ContainsKey(RTCUserInfo.UserID))
        {
            mUserDic.Remove(RTCUserInfo.UserID);
            mUserList.Remove(RTCUserInfo);
        }
        this.UnRegisterEvent<OtherLeaveRoomEvent>(OtherLeaveRoom);
    }
    #endregion

    #region 协程

    private string message;
    public IEnumerator RTCCreateRoom()
    {
        UnityWebRequest webRequest = new UnityWebRequest(HttpAction.mEndustryURL+HttpAction.rtc_CreateRoom,"POST");
        //foreach( var head in HttpTool.Instance.RequestHeader) webRequest.SetRequestHeader(head.Key,head.Value); 暂时使用直接写的方式，等后续确定使用此行代码
        webRequest.SetRequestHeader("Content-Type","application/x-www-form-urlencoded");
        webRequest.SetRequestHeader("Authorization",login.UserInfo.Instance.Token);
        webRequest.downloadHandler = new DownloadHandlerBuffer();
        yield return webRequest.SendWebRequest();
        if (webRequest.result== UnityWebRequest.Result.ProtocolError || webRequest.result == UnityWebRequest.Result.ConnectionError)
            Debug.LogError($"Error:{webRequest.error},DownloadHandler:{webRequest.downloadHandler.text}");
        else
        {
            if (!string.IsNullOrWhiteSpace(webRequest.downloadHandler.text))
            {
                message = webRequest.downloadHandler.text;
                JObject jobject = JObject.Parse(message);
                if (jobject["code"].ToString() == "200")
                {
                    message = jobject["data"].ToString();
                    if (!string.IsNullOrWhiteSpace(message))
                    {
                        mRTCRoomInfo =  JsonConvert.DeserializeObject<RTCRoomInfo>(message);
                        this.SendEvent(new RTCCreatRoomSuccessEvent() { rtcRoomInfo =  mRTCRoomInfo});
                    }
                }
            }
        }
    }

    public IEnumerator RTCJoinRoom(string roomID)
    {
        UnityWebRequest webRequest = new UnityWebRequest(HttpAction.mEndustryURL+HttpAction.rtc_CreateRoom,"POST");
        //foreach( var head in HttpTool.Instance.RequestHeader) webRequest.SetRequestHeader(head.Key,head.Value); 暂时使用直接写的方式，等后续确定使用此行代码
        webRequest.SetRequestHeader("Content-Type","application/x-www-form-urlencoded");
        webRequest.SetRequestHeader("Authorization",login.UserInfo.Instance.Token);
        byte[] bodyRaw = Encoding.UTF8.GetBytes(roomID);
        webRequest.uploadHandler = (UploadHandler)new UploadHandlerRaw(bodyRaw);
        webRequest.downloadHandler = new DownloadHandlerBuffer();
        yield return webRequest.SendWebRequest();
        if (webRequest.result== UnityWebRequest.Result.ProtocolError || webRequest.result == UnityWebRequest.Result.ConnectionError)
        {
            Debug.LogError($"Error:{webRequest.error},DownloadHandler:{webRequest.downloadHandler.text}");
        }
        else
        {
            if (!string.IsNullOrWhiteSpace(webRequest.downloadHandler.text))
            {
                message = webRequest.downloadHandler.text;
                JObject jobject = JObject.Parse(message);
                if (jobject["code"].ToString() == "200" && !string.IsNullOrEmpty(jobject["data"].ToString()))
                {
                    message = jobject["data"].ToString();
                    mRTCRoomInfo =  JsonConvert.DeserializeObject<RTCRoomInfo>(message);
                    this.SendEvent(new JoinRoomSuccessEvent() { rtcRoomInfo =  mRTCRoomInfo});
                }
            }
        }
    }
    #endregion
}