ET9_WebGL_Dev/Server/Hotfix/Module/Message/InnerMessageDispatcher.cs

using System;
using ETModel;

namespace ETHotfix
{
	public class InnerMessageDispatcher: IMessageDispatcher
	{
		public void Dispatch(Session session, ushort opcode, object message)
		{
			// 收到actor消息,放入actor队列
			switch (message)
			{
				case IActorRequest iActorRequest:
				{
					Entity entity = (Entity)Game.EventSystem.Get(iActorRequest.ActorId);
					if (entity == null)
					{
						Log.Warning($"not found actor: {iActorRequest.ActorId}");
						ActorResponse response = new ActorResponse
						{
							Error = ErrorCode.ERR_NotFoundActor,
							RpcId = iActorRequest.RpcId
						};
						session.Reply(response);
						return;
					}
	
					MailBoxComponent mailBoxComponent = entity.GetComponent<MailBoxComponent>();
					if (mailBoxComponent == null)
					{
						ActorResponse response = new ActorResponse
						{
							Error = ErrorCode.ERR_ActorNoMailBoxComponent,
							RpcId = iActorRequest.RpcId
						};
						session.Reply(response);
						Log.Error($"actor没有挂载MailBoxComponent组件: {entity.GetType().Name} {entity.Id}");
						return;
					}
				
					mailBoxComponent.Add(new ActorMessageInfo() { Session = session, Message = iActorRequest });
					return;
				}
				case IActorMessage iactorMessage:
				{
					Entity entity = (Entity)Game.EventSystem.Get(iactorMessage.ActorId);
					if (entity == null)
					{
						Log.Error($"not found actor: {iactorMessage.ActorId}");
						return;
					}
	
					MailBoxComponent mailBoxComponent = entity.GetComponent<MailBoxComponent>();
					if (mailBoxComponent == null)
					{
						Log.Error($"actor not add MailBoxComponent: {iactorMessage.ActorId}");
						return;
					}
				
					mailBoxComponent.Add(new ActorMessageInfo() { Session = session, Message = iactorMessage });
					return;
				}
				default:
				{
					Game.Scene.GetComponent<MessageDispatherComponent>().Handle(session, new MessageInfo(opcode, message));
					break;
				}
			}
		}
	}
}