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;
}
}
}