using System; using System.Collections; using System.Collections.Generic; using UnityEngine; using XFramework; using XFramework.NetOuter; //注册内置维修场景场景同步发送逻辑、网络消息监听事件 处理网络同步消息 public class SyncBuildInScene { int startActionIndex = 0;//接到开始指令次数 /// /// 注册 监听事件 发送方法 /// public SyncBuildInScene() { SyncGOManager.Instance.sendInterval = 0;//车辆同步时一帧发送一次位置信息 SyncGOManager.Instance.RegisterSendFun(SendSyncMsg); if (!GroupLearnHelper.isMaster)//组员端监听 { NetUDPManager.Instance.AddListener("MasterAction", new MasterActionExcute());//监听组长开始/结束操作指令网络消息 EventCenter.Instance.AddEventListener("SyncMasterAction", SyncMasterAction);//执行操作指令 } //组长+组员监听 NetUDPManager.Instance.AddListener("SceneSync", new ABSceneSyncExcute());//添加AB场景同步处理逻辑 物体+虚拟VR人物位置信息同步 NetUDPManager.Instance.AddListener("ActionSync", new ActionProtoExcute());//添加AB场景同步处理逻辑 物体行为 获取/释放权限 操作响应动画启动 } //当前场景状态同步数据发送方法 public void SendSyncMsg(List senders) { SceneSyncData sceneSyncData = new SceneSyncData(); for (int i = 0; i < senders.Count; i++) { Type dataType = senders[i].GetMsgType(); if (dataType == typeof(TransGesture))//场景物体位置同步数据 { sceneSyncData.syncGGDic[senders[i].GetSoleName()] = (TransGesture)senders[i].GetSyncMsg(); } else if (dataType == typeof(PersonSyncData))//场景物体位置同步数据 { sceneSyncData.vrPerson = (PersonSyncData)senders[i].GetSyncMsg(); } } IProtoBuilder builder = new SceneSyncProtoBuilder(sceneSyncData); NetUDPManager.Instance.SendNetMess(builder.GetProto()); } //结束场景同步 注销监听事件 public void StopSync() { SyncGOManager.Instance.RemoveSendFun(SendSyncMsg); if (!GroupLearnHelper.isMaster)//组员端监听 { NetUDPManager.Instance.RemovListener("MasterAction");//监听组长开始/结束操作指令 EventCenter.Instance.RemoveEnvetListener("SyncMasterAction", SyncMasterAction); } //组长+组员监听 NetUDPManager.Instance.RemovListener("SceneSync");//添加AB场景同步处理逻辑 物体+虚拟VR人物位置信息同步 NetUDPManager.Instance.RemovListener("ActionSync");//添加AB场景同步处理逻辑 物体 获取/释放权限 展开/收起动画 } /// /// 协同训练时接收组长端指令 /// private void SyncMasterAction(MasterActionType actionType) { switch (actionType) { case MasterActionType.StartSyncOperation: Debug.Log("接到组长端开始虚拟维修指令"); startActionIndex++; if (startActionIndex < 3) //正常情况下只会接收到两次开始指令 1拆 2装两个流程 { ProcessManager.Instance.SetProcess((ProcessEnum)startActionIndex); ProcessManager.Instance.StartProcess(); } else { Debug.Log("异常的开始指令,无法处理"); } break; case MasterActionType.PauseSyncOperation: break; case MasterActionType.StopSyncOperation: Debug.Log("接到组长端结束训练指令"); EventCenter.Instance.EventTrigger("StopLearning"); break; default: break; } } }