LoginHelper.cs 15 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393
  1. using System;
  2. using GFGGame;
  3. namespace ET
  4. {
  5. public static class LoginHelper
  6. {
  7. public static async ETTask<int> CheckVersion(Scene zoneScene, string address, string version)
  8. {
  9. A2C_CheckVersion a2C_GetVersion = null;
  10. Session session = null;
  11. try
  12. {
  13. session = zoneScene.GetComponent<NetKcpComponent>().Create(NetworkHelper.ToIPEndPoint(address));
  14. a2C_GetVersion = (A2C_CheckVersion)await session.Call(new C2A_CheckVersion() { Version = version });
  15. }
  16. catch (Exception e)
  17. {
  18. Log.Error(e.ToString());
  19. return ErrorCode.ERR_NetWorkError;
  20. }
  21. finally
  22. {
  23. session?.Dispose();
  24. }
  25. if (a2C_GetVersion.Error != ErrorCode.ERR_Success)
  26. {
  27. return a2C_GetVersion.Error;
  28. }
  29. return ErrorCode.ERR_Success;
  30. }
  31. public static async ETTask<int> LoginTest(Scene zoneScene, string address, string account)
  32. {
  33. A2C_LoginAccount a2CLoginAccount = null;
  34. Session accountSession = null;
  35. try
  36. {
  37. accountSession = zoneScene.GetComponent<NetKcpComponent>().Create(NetworkHelper.ToIPEndPoint(address));
  38. a2CLoginAccount = (A2C_LoginAccount)await accountSession.Call(new C2A_LoginTest() { Account = account });
  39. }
  40. catch (Exception e)
  41. {
  42. accountSession?.Dispose();
  43. Log.Error(e.ToString());
  44. return ErrorCode.ERR_NetWorkError;
  45. }
  46. if (a2CLoginAccount.Error != ErrorCode.ERR_Success)
  47. {
  48. accountSession?.Dispose();
  49. return a2CLoginAccount.Error;
  50. }
  51. OnLoginSuccess(zoneScene, a2CLoginAccount, accountSession);
  52. return ErrorCode.ERR_Success;
  53. }
  54. public static async ETTask<int> Login(Scene zoneScene, string address, string account, string password, bool isMD5)
  55. {
  56. A2C_LoginAccount a2CLoginAccount = null;
  57. Session accountSession = null;
  58. try
  59. {
  60. accountSession = zoneScene.GetComponent<NetKcpComponent>().Create(NetworkHelper.ToIPEndPoint(address));
  61. var passwordMD5 = password;
  62. //密码禁止明文传输
  63. if (!isMD5)
  64. {
  65. passwordMD5 = MD5Helper.stringMD5(password);
  66. }
  67. a2CLoginAccount = (A2C_LoginAccount)await accountSession.Call(new C2A_LoginAccount() { Account = account, Password = passwordMD5 });
  68. }
  69. catch (Exception e)
  70. {
  71. accountSession?.Dispose();
  72. Log.Error(e.ToString());
  73. return ErrorCode.ERR_NetWorkError;
  74. }
  75. if (a2CLoginAccount.Error != ErrorCode.ERR_Success)
  76. {
  77. accountSession?.Dispose();
  78. return a2CLoginAccount.Error;
  79. }
  80. OnLoginSuccess(zoneScene, a2CLoginAccount, accountSession);
  81. return ErrorCode.ERR_Success;
  82. }
  83. public static void OnLoginSuccess(Scene zoneScene, A2C_LoginAccount a2CLoginAccount, Session accountSession)
  84. {
  85. if (zoneScene.GetComponent<SessionComponent>() == null)
  86. {
  87. zoneScene.AddComponent<SessionComponent>();
  88. }
  89. zoneScene.GetComponent<SessionComponent>().Session = accountSession;
  90. accountSession.AddComponent<PingComponent>();
  91. accountSession.AddComponent<DisConnectedCompnent>();
  92. AccountInfoComponent accountInfoComponent = zoneScene.GetComponent<AccountInfoComponent>();
  93. accountInfoComponent.Token = a2CLoginAccount.Token;
  94. accountInfoComponent.AccountId = a2CLoginAccount.AccountId;
  95. accountInfoComponent.NoticeAddress = a2CLoginAccount.NoticeAddress;
  96. }
  97. public static async ETTask<int> Register(Scene zoneScene, string address, string account, string password, string name, string identityNum, string code)
  98. {
  99. A2C_Register r2C_Register = null;
  100. Session session = null;
  101. try
  102. {
  103. session = zoneScene.GetComponent<NetKcpComponent>().Create(NetworkHelper.ToIPEndPoint(address));
  104. {
  105. //密码禁止明文传输
  106. var passwordMD5 = MD5Helper.stringMD5(password);
  107. r2C_Register = (A2C_Register)await session.Call(new C2A_Register()
  108. { Account = account, Password = passwordMD5, Name = name, IdentityNum = identityNum, Code = code });
  109. if (r2C_Register.Error != ErrorCode.ERR_Success)
  110. {
  111. return r2C_Register.Error;
  112. }
  113. }
  114. }
  115. catch (Exception e)
  116. {
  117. session?.Dispose();
  118. Log.Error(e.ToString());
  119. return ErrorCode.ERR_NetWorkError;
  120. }
  121. return ErrorCode.ERR_Success;
  122. }
  123. public static async ETTask<int> GetServerInfos(Scene zoneScene)
  124. {
  125. A2C_GetServerInfos a2C_GetServerInfos = null;
  126. try
  127. {
  128. a2C_GetServerInfos = (A2C_GetServerInfos)await zoneScene.GetComponent<SessionComponent>().Session.Call(new C2A_GetServerInfos()
  129. {
  130. AccountId = zoneScene.GetComponent<AccountInfoComponent>().AccountId,
  131. Token = zoneScene.GetComponent<AccountInfoComponent>().Token
  132. });
  133. }
  134. catch (Exception e)
  135. {
  136. Log.Error(e.ToString());
  137. return ErrorCode.ERR_NetWorkError;
  138. }
  139. if (a2C_GetServerInfos.Error != ErrorCode.ERR_Success)
  140. {
  141. return a2C_GetServerInfos.Error;
  142. }
  143. zoneScene.GetComponent<ServerInfosComponent>()?.ServerInfoList?.Clear();
  144. foreach (var serverInfoProto in a2C_GetServerInfos.ServerInfosList)
  145. {
  146. ServerInfo serverInfo = zoneScene.GetComponent<ServerInfosComponent>().AddChild<ServerInfo>();
  147. serverInfo.FromMessage(serverInfoProto);
  148. zoneScene.GetComponent<ServerInfosComponent>().Add(serverInfo);
  149. }
  150. zoneScene.GetComponent<ServerInfosComponent>().SetRecentlyServerInfo(a2C_GetServerInfos.RecentId);
  151. await ETTask.CompletedTask;
  152. return ErrorCode.ERR_Success;
  153. }
  154. public static async ETTask<int> GetRoles(Scene zoneScene)
  155. {
  156. A2C_GetRoles a2C_GetRoles = null;
  157. try
  158. {
  159. a2C_GetRoles = (A2C_GetRoles)await zoneScene.GetComponent<SessionComponent>().Session.Call(new C2A_GetRoles()
  160. {
  161. AccountId = zoneScene.GetComponent<AccountInfoComponent>().AccountId,
  162. Token = zoneScene.GetComponent<AccountInfoComponent>().Token,
  163. ServerId = zoneScene.GetComponent<ServerInfosComponent>().CurrentServerId,
  164. });
  165. }
  166. catch (Exception e)
  167. {
  168. Log.Error(e.ToString());
  169. return ErrorCode.ERR_NetWorkError;
  170. }
  171. if (a2C_GetRoles.Error != ErrorCode.ERR_Success)
  172. {
  173. Log.Error(a2C_GetRoles.Error.ToString());
  174. return a2C_GetRoles.Error;
  175. }
  176. zoneScene.GetComponent<RoleInfosComponent>().RoleInfos.Clear();
  177. foreach (var roleInfoProto in a2C_GetRoles.RoleInfos)
  178. {
  179. RoleInfo roleInfo = zoneScene.GetComponent<RoleInfosComponent>().AddChild<RoleInfo>();
  180. roleInfo.FromMessage(roleInfoProto);
  181. zoneScene.GetComponent<RoleInfosComponent>().RoleInfos.Add(roleInfo);
  182. }
  183. return ErrorCode.ERR_Success;
  184. }
  185. public static async ETTask<int> CreateRole(Scene zoneScene, string name)
  186. {
  187. A2C_CreateRole a2C_CreateRole = null;
  188. try
  189. {
  190. a2C_CreateRole = (A2C_CreateRole)await zoneScene.GetComponent<SessionComponent>().Session.Call(new C2A_CreateRole
  191. {
  192. AccountId = zoneScene.GetComponent<AccountInfoComponent>().AccountId,
  193. Token = zoneScene.GetComponent<AccountInfoComponent>().Token,
  194. Name = name,
  195. ServerId = zoneScene.GetComponent<ServerInfosComponent>().CurrentServerId,
  196. });
  197. }
  198. catch (Exception e)
  199. {
  200. Log.Error(e.ToString());
  201. return ErrorCode.ERR_NetWorkError;
  202. }
  203. if (a2C_CreateRole.Error != ErrorCode.ERR_Success)
  204. {
  205. Log.Error(a2C_CreateRole.Error.ToString());
  206. return a2C_CreateRole.Error;
  207. }
  208. RoleInfo newRoleInfo = zoneScene.GetComponent<RoleInfosComponent>().AddChild<RoleInfo>();
  209. newRoleInfo.FromMessage(a2C_CreateRole.RoleInfo);
  210. zoneScene.GetComponent<RoleInfosComponent>().RoleInfos.Add(newRoleInfo);
  211. return ErrorCode.ERR_Success;
  212. }
  213. public static async ETTask<int> DeleteRole(Scene zoneScene, long roleId)
  214. {
  215. A2C_DeleteRole a2C_DeleteRole = null;
  216. try
  217. {
  218. a2C_DeleteRole = (A2C_DeleteRole)await zoneScene.GetComponent<SessionComponent>().Session.Call(new C2A_DeleteRole()
  219. {
  220. AccountId = zoneScene.GetComponent<AccountInfoComponent>().AccountId,
  221. Token = zoneScene.GetComponent<AccountInfoComponent>().Token,
  222. RoleInfoId = roleId,
  223. ServerId = zoneScene.GetComponent<ServerInfosComponent>().CurrentServerId,
  224. });
  225. }
  226. catch (Exception e)
  227. {
  228. Log.Error(e.ToString());
  229. return ErrorCode.ERR_NetWorkError;
  230. }
  231. if (a2C_DeleteRole.Error != ErrorCode.ERR_Success)
  232. {
  233. Log.Error(a2C_DeleteRole.Error.ToString());
  234. return a2C_DeleteRole.Error;
  235. }
  236. int index = zoneScene.GetComponent<RoleInfosComponent>().RoleInfos.FindIndex((info) => { return info.Id == a2C_DeleteRole.DeleteRoleInfoId; });
  237. zoneScene.GetComponent<RoleInfosComponent>().RoleInfos.RemoveAt(index);
  238. await ETTask.CompletedTask;
  239. return ErrorCode.ERR_Success;
  240. }
  241. public static async ETTask<int> GetRealmKey(Scene zoneScene)
  242. {
  243. A2C_GetRealmKey a2C_GetRealmKey = null;
  244. try
  245. {
  246. a2C_GetRealmKey = (A2C_GetRealmKey)await zoneScene.GetComponent<SessionComponent>().Session.Call(new C2A_GetRealmKey()
  247. {
  248. AccountId = zoneScene.GetComponent<AccountInfoComponent>().AccountId,
  249. Token = zoneScene.GetComponent<AccountInfoComponent>().Token,
  250. ServerId = zoneScene.GetComponent<ServerInfosComponent>().CurrentServerId,
  251. });
  252. }
  253. catch (Exception e)
  254. {
  255. Log.Error(e.ToString());
  256. return ErrorCode.ERR_NetWorkError;
  257. }
  258. if (a2C_GetRealmKey.Error != ErrorCode.ERR_Success)
  259. {
  260. Log.Error(a2C_GetRealmKey.Error.ToString());
  261. return a2C_GetRealmKey.Error;
  262. }
  263. zoneScene.GetComponent<AccountInfoComponent>().RealmKey = a2C_GetRealmKey.RealmKey;
  264. zoneScene.GetComponent<AccountInfoComponent>().RealmAddress = a2C_GetRealmKey.RealmAddress;
  265. zoneScene.GetComponent<SessionComponent>().Disconnect();
  266. await ETTask.CompletedTask;
  267. return ErrorCode.ERR_Success;
  268. }
  269. public static async ETTask<int> EnterGame(Scene zoneScene)
  270. {
  271. string realmAddress = zoneScene.GetComponent<AccountInfoComponent>().RealmAddress;
  272. //1.连接Realm,获取分配的Gate
  273. R2C_LoginRealm r2C_LoginRealm = null;
  274. Session session = zoneScene.GetComponent<NetKcpComponent>().Create(NetworkHelper.ToIPEndPoint(realmAddress));
  275. try
  276. {
  277. r2C_LoginRealm = (R2C_LoginRealm)await session.Call(new C2R_LoginRealm()
  278. {
  279. AccountId = zoneScene.GetComponent<AccountInfoComponent>().AccountId,
  280. RealmTokenKey = zoneScene.GetComponent<AccountInfoComponent>().RealmKey
  281. });
  282. }
  283. catch (Exception e)
  284. {
  285. Log.Error(e);
  286. session?.Dispose();
  287. return ErrorCode.ERR_NetWorkError;
  288. }
  289. session?.Dispose();
  290. if (r2C_LoginRealm.Error != ErrorCode.ERR_Success)
  291. {
  292. return r2C_LoginRealm.Error;
  293. }
  294. Log.Warning($"GateAddress : {r2C_LoginRealm.GateAddress}");
  295. Session gateSession = zoneScene.GetComponent<NetKcpComponent>().Create(NetworkHelper.ToIPEndPoint(r2C_LoginRealm.GateAddress));
  296. gateSession.AddComponent<PingComponent>();
  297. gateSession.AddComponent<DisConnectedCompnent>();
  298. zoneScene.GetComponent<SessionComponent>().Session = gateSession;
  299. //2.开始连接Gate
  300. long currentRoleId = zoneScene.GetComponent<RoleInfosComponent>().CurrentRoleId;
  301. G2C_LoginGate g2C_LoginGate = null;
  302. try
  303. {
  304. long accountId = zoneScene.GetComponent<AccountInfoComponent>().AccountId;
  305. g2C_LoginGate = (G2C_LoginGate)await gateSession.Call(new C2G_LoginGate()
  306. {
  307. Key = r2C_LoginRealm.GateSessionKey,
  308. AccountId = accountId,
  309. RoleId = currentRoleId
  310. });
  311. }
  312. catch (Exception e)
  313. {
  314. Log.Error(e);
  315. zoneScene.GetComponent<SessionComponent>().Session?.Dispose();
  316. return ErrorCode.ERR_NetWorkError;
  317. }
  318. if (g2C_LoginGate.Error != ErrorCode.ERR_Success)
  319. {
  320. zoneScene.GetComponent<SessionComponent>().Session?.Dispose();
  321. return g2C_LoginGate.Error;
  322. }
  323. Log.Debug("登陆gate成功!");
  324. //3.角色正式请求进入游戏逻辑服
  325. G2C_EnterGame g2C_EnterGame = null;
  326. try
  327. {
  328. g2C_EnterGame = (G2C_EnterGame)await gateSession.Call(new C2G_EnterGame() { });
  329. }
  330. catch (Exception e)
  331. {
  332. Log.Error(e);
  333. zoneScene.GetComponent<SessionComponent>().Session.Dispose();
  334. return ErrorCode.ERR_NetWorkError;
  335. }
  336. if (g2C_EnterGame.Error != ErrorCode.ERR_Success)
  337. {
  338. Log.Error(g2C_EnterGame.Error.ToString());
  339. return g2C_EnterGame.Error;
  340. }
  341. Log.Debug("角色进入游戏成功!");
  342. zoneScene.GetComponent<PlayerComponent>().MyId = g2C_EnterGame.MyId;
  343. await zoneScene.GetComponent<ObjectWait>().Wait<WaitType.Wait_SceneChangeFinish>();
  344. await ETTask.CompletedTask;
  345. return ErrorCode.ERR_Success;
  346. }
  347. }
  348. }