C2G_LoginGameHandler.cs 2.7 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667
  1. using System;
  2. using Newtonsoft.Json.Linq;
  3. namespace ET.Server
  4. {
  5. /// <summary>
  6. /// 登入游戏服.获取角色列表
  7. /// </summary>
  8. [MessageHandler(SceneType.Game)]
  9. public class C2G_LoginGameHandler : AMRpcHandler<C2G_LoginGame, G2C_LoginGame>
  10. {
  11. protected override async ETTask Run(Session session, C2G_LoginGame request, G2C_LoginGame response, Action reply)
  12. {
  13. if (session.DomainScene().SceneType != SceneType.Game)
  14. {
  15. Log.Debug($"Game 请求的Scene错误...SceneType={session.DomainScene().SceneType}");
  16. session.Dispose();
  17. return;
  18. }
  19. // 移除session自动超时组件
  20. session.RemoveComponent<SessionAcceptTimeoutComponent>();
  21. Scene scene = session.DomainScene();
  22. bool tokenIsNull = string.IsNullOrEmpty(request.Token.Trim()) || "NoToken".Equals(request.Token.Trim());
  23. scene.GetComponent<GameDouyinComponent>().TokenIsNull = tokenIsNull;
  24. // 预先创建数据
  25. PlayerInfo playerInfo = new PlayerInfo();
  26. playerInfo.Id = IdGenerater.Instance.GenerateUnitId(scene.DomainZone());
  27. if (tokenIsNull)
  28. {
  29. // Token为空初始化信息
  30. playerInfo.RoomId = playerInfo.Id;
  31. playerInfo.AnchorOpenId = playerInfo.Id.ToString();
  32. playerInfo.AvatarUrl = "测试头像";
  33. playerInfo.Name = "主播-" + playerInfo.Id;
  34. }
  35. else
  36. {
  37. JObject roomInfo = scene.GetComponent<GameDouyinComponent>().GetRoomInfo(request.Token.Trim());
  38. playerInfo.RoomId = Convert.ToInt64(roomInfo.SelectToken("data").SelectToken("info").SelectToken("room_id"));
  39. playerInfo.AnchorOpenId = Convert.ToString(roomInfo.SelectToken("data").SelectToken("info").SelectToken("anchor_open_id"));
  40. playerInfo.AvatarUrl = Convert.ToString(roomInfo.SelectToken("data").SelectToken("info").SelectToken("avatar_url"));
  41. playerInfo.Name = Convert.ToString(roomInfo.SelectToken("data").SelectToken("info").SelectToken("nick_name"));
  42. }
  43. playerInfo.Sex = 0;
  44. playerInfo.Pro = (int)PlayerProType.CANG_LANG;
  45. playerInfo.Level = 1;
  46. playerInfo.Exp = 0;
  47. // 添加session组件,用于绑定角色
  48. session.AddComponent<SessionPlayerComponent, PlayerInfo>(playerInfo);
  49. session.AddComponent<MailBoxComponent, MailboxType>(MailboxType.GateSession);
  50. response.Player = PlayerHelper.PlayerInfoToPlayerBasicProto(playerInfo);
  51. reply();
  52. await ETTask.CompletedTask;
  53. }
  54. }
  55. }