GHZMRSpace/Assets/Studio/Scripts/PlayerView/PlayerViewComponent.cs

using BeinLab.Util;
using ShadowStudio.Mgr;
using ShadowStudio.UI;
using System;
using System.Collections;
using System.Collections.Generic;
using UnityEngine;
using UnityEngine.UI;
using XRTool.Util;
using XRTool.WorldUI;
using static BoundingBox;

namespace ShadowStudio.Model
{
    /// <summary>
    /// 用户的视频通话窗口
    /// </summary>
    public class PlayerViewComponent : UIComponent
    {
        public static string viewId = "ArtId_PlayerView";
        public static Dictionary<string, ArtContainerHandler> viewDic = new Dictionary<string, ArtContainerHandler>();
        private string peerid;
        private bool isInit = false;
        private Peer _peer;
        public static event Action<string, bool> ViewChange;
        /// <summary>
        /// 创建一个视频通话窗口
        /// 即时同步
        /// </summary>
        /// <param name="peerid">点击的用户的id</param>
        /// <param name="target"></param>

        public static void CreateViewComponent(string peerid, Transform target, bool isDel = false)
        {
            if (viewDic.ContainsKey(peerid))
            {
                return;
            }
            GoodsInfo data = new GoodsInfo();
            var info = ArtInfoMgr.Instance.GetArtInfo(viewId);
            data.art_id = viewId;
            data.id = UnityEngine.Random.Range(100000, 999999999);
            if (target)
            {
                data.goods_info = UnityUtil.TransferToString(target, 2);
            }
            else
            {
                data.goods_info = UnityUtil.ArtTransferInfo(info);
            }
            data.goods_name = peerid;
            data.rid = int.Parse(UserInfoMgr.Instance.userConfig.Id);
            data.scene_id = -1;
            ///创建本地窗口
            ArtInfoMgr.Instance.SyncGoods(data);
            ///
            ///ArtInfoMgr.Instance.SendTransfer(data);
            if (target && isDel)
            {
                Destroy(target.gameObject);
            }
           
        }

        private bool checkRtc()
        {
            if (_peer != null && StudioRtc.Instance != null && StudioRtc.Instance.customPeerList != null)
            {
                cPeer = (CustomPeer)StudioRtc.Instance.customPeerList.getPeerName(_peer.PeerId);
                if (cPeer != null)
                {
                  //  Debug.Log("cPeer Not NULL" + _peer.PeerId);

                    cPeer.onChangeInfo -= OnChangeInfo;
                    cPeer.onChangeInfo += OnChangeInfo;
                    if (!_peer.IsSlef)
                    {
                        if (cPeer.isAudio && cPeer.cIdA != "")
                        {
                            openAudioEffect();
                        }
                        else
                        {
                            closeAudioEffect();
                        }
                        if (cPeer.isVideo && cPeer.cIdV != "")
                        {
                            openVideoEffect();
                        }
                        else
                        {
                            closeVideoEffect();
                        }
                    }
                }
                if (cPeer != null)
                {
                    return true;
                }
            }
         //   Debug.Log("cPeer is NULL" + _peer.PeerId);
            return false;
        }


        public float volume = 0.2f;
        public Text textMic;
        public GameObject pauseCerAudio;
        public GameObject pauseCerVideo;
        public GameObject pauseAudio;
        public GameObject pauseVideo;
        public GameObject openVideo;
        public GameObject closeVideo;

        public MeshRenderer videoBG;
        public Text nametext;
        public XRIcon touxiang;
        public GameObject openAudio;
        public GameObject closeAudio;
        public GameObject VolumnGo;

        public RawImage agoraShowVideo;
        private void closeVideoEffect()
        {
            if(openVideo)
            {
                openVideo.SetActive(true);
                closeVideo.SetActive(false);
                VideoEmpty.gameObject.SetActive(true);
                if (cPeer != null)
                {
                    pauseCerVideo.SetActive(true);
                    pauseVideo.SetActive(false);
                }
                if (peerid == CommonMethod.MyPeer.PeerId)
                    AgoraVideoAudioManager.Instance.EnableLocalVideo(false);
            }
        }

        private void openVideoEffect()
        {

            openVideo.SetActive(false);
            closeVideo.SetActive(true);
            if (cPeer != null)
            {
                ShowVideo.material.mainTexture = cPeer.tex;
                if (cPeer.isCloseVideo)
                {
                    pauseCerVideo.SetActive(false);
                    pauseVideo.SetActive(true);
                }
            }
            VideoEmpty.gameObject.SetActive(false);

            if (peerid == CommonMethod.MyPeer.PeerId)
                AgoraVideoAudioManager.Instance.EnableLocalVideo(true);
        }


        private void closeAudioEffect()
        {

            pauseCerAudio.SetActive(true);
            pauseAudio.SetActive(false);
            openAudio.SetActive(true);
            closeAudio.SetActive(false);
            VolumnGo.SetActive(false);

            if (peerid == CommonMethod.MyPeer.PeerId)
                AgoraVideoAudioManager.Instance.EnableLoacalAudio(false);
            //else
            //    AgoraVideoAudioManager.Instance.MuteRemoteAudioStream(peerid, false);
        }

        private void openAudioEffect()
        {
            openAudio.SetActive(false);
            closeAudio.SetActive(true);
            VolumnGo.SetActive(true);
            if (cPeer != null)
            {
                volume = cPeer.volumn;
                if (cPeer.isCloseAudio)
                {
                    pauseCerAudio.SetActive(false);
                    pauseAudio.SetActive(true);
                }
            }
            textMic.text = volume.ToString("F2");

            if (peerid == CommonMethod.MyPeer.PeerId)
                AgoraVideoAudioManager.Instance.EnableLoacalAudio(true);
            //else
            //    AgoraVideoAudioManager.Instance.MuteRemoteAudioStream(peerid, true);
        }
        private void OnChangeInfo(string type, string id)
        {
            if (type == "video")
            {

                if (cPeer.isVideo)
                {
                    openVideoEffect();
                    if (cPeer.isCloseVideo)
                    {
                        StudioRtc.Instance.closeRev(cPeer.cIdV);
                    }
                }
                else
                {
                    closeVideoEffect();
                }
            }
            else
            {

                if (cPeer.isAudio)
                {
                    openAudioEffect();
                    if (cPeer.isCloseAudio)
                    {
                        StudioRtc.Instance.closeRev(cPeer.cIdA);
                    }
                }
                else
                {
                    closeAudioEffect();
                }
            }
        }

        private void Update()
        {
            if (checkRtc() && !isRtcInit)
            {
                ShowVideo.material.mainTexture = cPeer.tex;
                isRtcInit = true;
            }
        }
        bool isRtcInit = false;
        CustomPeer cPeer;
        public void setVideo(string peerid)
        {
            _peer = UserItemList.Instance.GetPeer(peerid);
            nametext.text = _peer.NickName;
            if (peerid == CommonMethod.MyPeer.PeerId)
            {
                if (StudioRtc.Instance.me.cIdA != "")
                {
                    openAudioEffect();
                }
                else
                {
                    closeAudioEffect();
                }
                if (StudioRtc.Instance.me.cIdV != "")
                {
                    openVideoEffect();
                }
                else
                {
                    closeVideoEffect();
                }
                ShowVideo.material.mainTexture = StudioRtc.Instance.rt;
                isRtcInit = true;
                return;
            }
            else
            {
                Debug.Log(" Peerid != MyPeer" + peerid);
            }
            if (checkRtc())
            {
                ShowVideo.material.mainTexture = cPeer.tex;
            }

            /*
            if (peerid == CommonMethod.MyPeer.PeerId)
            {
                ShowVideo.material.mainTexture = ConsoleDlg.Instance.vufora_camera.GetComponent<Camera>().targetTexture;
                return;
            }
            peer = UserItemList.Instance.GetPeer(peerid);
            if (peer != null)
            {
                ShowVideo.material.mainTexture = peer.CustomPeer.tex;
            }
            else
            {
                UnityLog.Instance.LogError("Cant Find peerid" + peerid);
            }
            */
        }

        public void addMic()
        {
            volume += 0.1f;
            if (_peer.IsSlef)
            {
                StudioRtc.Instance.setVolume(volume);
            }
            else
            {
                if (cPeer != null && cPeer.cIdA != "")
                {
                    StudioRtc.Instance.setVolume(cPeer.cIdA, volume);

                }
            }
            textMic.text = volume.ToString("F2");
        }
        public void redMic()
        {
            volume -= 0.1f;
            if (_peer.IsSlef)
            {
                StudioRtc.Instance.setVolume(volume);
            }
            else
            {
                if (cPeer != null && cPeer.cIdA != "")
                {
                    StudioRtc.Instance.setVolume(cPeer.cIdA, volume);
                }
            }
            textMic.text = volume.ToString("F2");
        }
        public void closeMic()
        {
            if (_peer.IsSlef)
            {
                if (StudioRtc.Instance.me.cIdA != "")
                {
                    WSHandler.Rtc.closeProducer(StudioRtc.Instance.me.cIdA);
                    StudioRtc.Instance.sendMic(false);
                    closeAudioEffect();
                    StudioRtc.Instance.me.cIdA = "";
                }
                closeAudioEffect();
            }
            else
            {

                if (cPeer != null && cPeer.isAudio && cPeer.cIdA != "" && !cPeer.isCloseAudio)
                {
                    pauseCerAudio.SetActive(false);
                    pauseAudio.SetActive(true);
                    StudioRtc.Instance.closeRev(cPeer.cIdA);
                    cPeer.isCloseAudio = true;
                    //  cPeer.setInfo("audio", cPeer.cIdA, false);
                    AgoraVideoAudioManager.Instance.MuteRemoteAudioStream(peerid, true);
                }
                if(cPeer!=null)
                {
                    pauseCerAudio.SetActive(false);
                    pauseAudio.SetActive(true);
                    cPeer.isCloseAudio = true;
                    //  cPeer.setInfo("audio", cPeer.cIdA, false);
                    AgoraVideoAudioManager.Instance.MuteRemoteAudioStream(peerid, true);
                }
            }
        }
        public void openMic()
        {

            if (_peer.IsSlef)
            {
                StudioRtc.Instance.sendMic(true);
                volume = StudioRtc.Instance.me.volumn;
                openAudioEffect();
            }
            else
            {

                if (cPeer != null && cPeer.isAudio && cPeer.cIdA != "" && cPeer.isCloseAudio)
                {
                    pauseCerAudio.SetActive(true);
                    pauseAudio.SetActive(false);
                    StudioRtc.Instance.startRev(cPeer.cIdA);
                    cPeer.isCloseAudio = false;
                    // cPeer.setInfo("audio", cPeer.cIdA,true);
                    AgoraVideoAudioManager.Instance.MuteRemoteAudioStream(peerid, false);
                }
                if (cPeer != null)
                {
                    pauseCerAudio.SetActive(true);
                    pauseAudio.SetActive(false);
                    cPeer.isCloseAudio = false;
                    // cPeer.setInfo("audio", cPeer.cIdA,true);
                    AgoraVideoAudioManager.Instance.MuteRemoteAudioStream(peerid, false);
                }
               
            }
        }
        public void OpenVideo()
        {
            agoraShowVideo.gameObject.SetActive(true);
            if (_peer.IsSlef)
            {
                StudioRtc.Instance.startCamera();
               // videoBG.gameObject.SetActive(true);
                //videoBG.material.mainTexture = StudioRtc.Instance.rt;
                StudioRtc.Instance.sendVideo(true);
                openVideoEffect();
            }
            else
            {
                if (cPeer != null && cPeer.isVideo && cPeer.cIdV != "" && cPeer.isCloseVideo)
                {
                    pauseCerVideo.SetActive(true);
                    pauseVideo.SetActive(false);
                    StudioRtc.Instance.startRev(cPeer.cIdV);
                    cPeer.isCloseVideo = false;
                    // cPeer.setInfo("audio", cPeer.cIdA,true);
                }
                if(cPeer!=null)
                {
                    pauseCerVideo.SetActive(true);
                    pauseVideo.SetActive(false);
                    cPeer.isCloseVideo = false;
                }
            }
        }
        public void CloseVideo()
        {
            agoraShowVideo.gameObject.SetActive(false);
            if (_peer.IsSlef)
            {
                if (StudioRtc.Instance.me.cIdV != "")
                {
                    WSHandler.Rtc.closeProducer(StudioRtc.Instance.me.cIdV);
                    StudioRtc.Instance.stopCamera();
                    StudioRtc.Instance.sendVideo(false);
                    closeVideoEffect();
                    StudioRtc.Instance.me.cIdV = "";
                }
                closeVideoEffect();
            }
            else
            {
                if (cPeer != null && cPeer.isVideo && cPeer.cIdV != "" && !cPeer.isCloseVideo)
                {
                    pauseCerVideo.SetActive(false);
                    pauseVideo.SetActive(true);
                    StudioRtc.Instance.closeRev(cPeer.cIdV);
                    cPeer.isCloseVideo = true;
                    // cPeer.setInfo("audio", cPeer.cIdA,true);
                }
                if(cPeer!=null)
                {
                    pauseCerVideo.SetActive(false);
                    pauseVideo.SetActive(true);
                    cPeer.isCloseVideo = true;
                }

            }
        }
        private Button closeBtn;

        public Button CloseBtn
        {
            get
            {
                if (!closeBtn)
                {
                    closeBtn = UnityUtil.GetBreadthChild<Button>(transform, "CloseBtn");
                }
                return closeBtn;
            }
        }

        private MeshRenderer showVideo;

        public MeshRenderer ShowVideo
        {
            get
            {
                if (!showVideo)
                {
                    showVideo = UnityUtil.GetBreadthChild<MeshRenderer>(transform, "ShowVideo");
                }
                return showVideo;
            }
        }
        private MeshRenderer videoEmpty;

        public MeshRenderer VideoEmpty
        {
            get
            {
                if (!videoEmpty)
                {
                    videoEmpty = UnityUtil.GetBreadthChild<MeshRenderer>(transform, "VideoEmpty");
                }
                return videoEmpty;
            }
        }

        private void OnDestroy()
        {
            ViewChange?.Invoke(peerid, false);
            if (!string.IsNullOrEmpty(peerid) && viewDic.ContainsKey(peerid))
            {
                viewDic.Remove(peerid);
            }
            if (cPeer != null)
                cPeer.onChangeInfo -= OnChangeInfo;
        }

        private void Start()
        {
            if (CloseBtn)
            {
                //CloseBtn.onClick.AddListener(OnClickClose);
            }
            if (ArtInfoMgr.Instance != null)
            {
                ArtInfoMgr.Instance.UserChange += OnUserChange;
            }
            XBoundingBox boxb= this.GetComponent<XBoundingBox>();
            if(boxb)
            boxb.ActiveAxis= AxisType.None;
            AgoraVideoAudioManager.Instance.AddListShowView(peerid, agoraShowVideo);
        }
        /// <summary>
        /// 用户状态发生改变的时候
        /// </summary>
        /// <param name="peerId"></param>
        /// <param name="isJoin"></param>
        private void OnUserChange(string peerId, bool isJoin)
        {
            ///用户视频列表被创建，但用户退出
            ///删除用户视频列表
            if (viewDic.ContainsKey(peerId))
            {
                if (peerId == this.peerid && !isJoin)
                {
                    OnClickClose();
                }
            }
            else
            {
                ///用户加入
                if (isJoin)
                {
                    base.SendTransfer(2, 0);
                    TimerMgr.Instance.CreateTimer(() =>
                    {
                        base.SendTransfer(2, 0);
                    }, 3f);
                }
            }
        }

        /// <summary>
        /// 点击关闭按钮
        /// 删除此视频通话窗口
        /// 如何删除？发送额外消息
        /// 删除本地
        /// </summary>
        public void OnClickClose()
        {
            if (Container)
            {
                Container.data.goods_extended = "DES";
                base.SendTransfer(2, 0);
            }
            if (cPeer != null)
                cPeer.onChangeInfo -= OnChangeInfo;
            DestroyArt();

          
        }

        public override void DestroyArt()
        {
            base.DestroyArt();
        }
        public override void SendTransfer(int state, int status)
        {
            base.SendTransfer(state, status);
            //if (Container is WorldDlgContainer)
            //{
            //    TimerMgr.Instance.CreateTimer(()=>
            //    {
            //        (Container as WorldDlgContainer).OnTransferSelect(false);
            //    },0.02f);
            //}
        }
        /// <summary>
        /// 设置容器
        /// </summary>
        /// <param name="container"></param>
        /// <param name="art"></param>
        /// <param name="info"></param>
        public override void SetContainer(ArtContainerHandler container, UnityEngine.Object art, ArtInfo info)
        {
            base.SetContainer(container, art, info);
            RectTransform rt = GetComponent<RectTransform>();
            rt.offsetMax = Vector2.zero;
            rt.offsetMin = Vector2.zero;
        }
        public override void TransferSyn(GoodsInfo goods, bool smooth = true)
        {
            base.TransferSyn(goods, smooth);
            if (!isInit)
            {
                if (!viewDic.ContainsKey(goods.goods_name))
                {
                    this.peerid = goods.goods_name;
                    viewDic.Add(goods.goods_name, Container);
                    setVideo(peerid);
                    ///自身点击的，需要发送同步一次
                    if (goods.rid.ToString() == UserInfoMgr.Instance.userConfig.Id)
                    {
                        SendTransfer(2, 0);
                    }
                    ViewChange?.Invoke(goods.goods_name, true);
                    isInit = true;

                   
                }
            }
            if (!string.IsNullOrEmpty(goods.goods_extended))
            {
                if (goods.goods_extended == "DES")
                {
                    DestroyArt();
                }
            }
        }

    }
}