project-redbud/FunGame-Server
6
1
Fork 0
mirror of https://github.com/project-redbud/FunGame-Server.git synced 2025-04-22 03:59:36 +08:00
Code Issues Packages Projects Releases Wiki Activity

使用统一方法

Browse Source
This commit is contained in:
milimoe 2023-07-09 15:41:50 +08:00
parent 30b82723b4
commit 0de2bd94a8
Signed by: milimoe
GPG Key ID: 05D280912DA6C69E
3 changed files with 34 additions and 30 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
FunGame.Server/Controllers/DataRequestController.cs
View File

@ -55,7 +55,7 @@ namespace Milimoe.FunGame.Server.Controller
string msg = "无法找回您的密码，请稍后再试。"; // 返回的验证信息 string msg = "无法找回您的密码，请稍后再试。"; // 返回的验证信息
if (RequestData.Count >= 2) if (RequestData.Count >= 2)
{ {
ServerHelper.WriteLine("[" + ServerSocket.GetTypeString(SocketMessageType.DataRequest) + "] " + ServerHelper.MakeClientName(Server.ClientName, Server.User) + " -> ForgetPassword"); ServerHelper.WriteLine("[" + ServerSocket.GetTypeString(SocketMessageType.DataRequest) + "] " + Server.GetClientName() + " -> ForgetPassword");
string username = DataRequest.GetHashtableJsonObject<string>(RequestData, ForgetVerifyCodes.Column_Username) ?? ""; string username = DataRequest.GetHashtableJsonObject<string>(RequestData, ForgetVerifyCodes.Column_Username) ?? "";
string email = DataRequest.GetHashtableJsonObject<string>(RequestData, ForgetVerifyCodes.Column_Email) ?? ""; string email = DataRequest.GetHashtableJsonObject<string>(RequestData, ForgetVerifyCodes.Column_Email) ?? "";
string verifycode = DataRequest.GetHashtableJsonObject<string>(RequestData, ForgetVerifyCodes.Column_ForgetVerifyCode) ?? ""; string verifycode = DataRequest.GetHashtableJsonObject<string>(RequestData, ForgetVerifyCodes.Column_ForgetVerifyCode) ?? "";
@ -71,7 +71,7 @@ namespace Milimoe.FunGame.Server.Controller
DateTime SendTime = (DateTime)SQLHelper.DataSet.Tables[0].Rows[0][ForgetVerifyCodes.Column_SendTime]; DateTime SendTime = (DateTime)SQLHelper.DataSet.Tables[0].Rows[0][ForgetVerifyCodes.Column_SendTime];
if ((DateTime.Now - SendTime).TotalMinutes >= 10) if ((DateTime.Now - SendTime).TotalMinutes >= 10)
{ {
ServerHelper.WriteLine(ServerHelper.MakeClientName(Server.ClientName, Server.User) + " 验证码已过期"); ServerHelper.WriteLine(Server.GetClientName() + " 验证码已过期");
msg = "此验证码已过期，请重新找回密码。"; msg = "此验证码已过期，请重新找回密码。";
SQLHelper.Execute(ForgetVerifyCodes.Delete_ForgetVerifyCode(username, email)); SQLHelper.Execute(ForgetVerifyCodes.Delete_ForgetVerifyCode(username, email));
} }
@ -118,18 +118,18 @@ namespace Milimoe.FunGame.Server.Controller
string[] To = new string[] { email }; string[] To = new string[] { email };
if (MailSender.Send(MailSender.CreateMail(Subject, Body, System.Net.Mail.MailPriority.Normal, true, To)) == MailSendResult.Success) if (MailSender.Send(MailSender.CreateMail(Subject, Body, System.Net.Mail.MailPriority.Normal, true, To)) == MailSendResult.Success)
{ {
ServerHelper.WriteLine(ServerHelper.MakeClientName(Server.ClientName, Server.User) + $" 已向{email}发送验证码：{ForgetVerify}"); ServerHelper.WriteLine(Server.GetClientName() + $" 已向{email}发送验证码：{ForgetVerify}");
msg = ""; msg = "";
} }
else else
{ {
ServerHelper.WriteLine(ServerHelper.MakeClientName(Server.ClientName, Server.User) + " 无法发送验证码"); ServerHelper.WriteLine(Server.GetClientName() + " 无法发送验证码");
ServerHelper.WriteLine(MailSender.ErrorMsg); ServerHelper.WriteLine(MailSender.ErrorMsg);
} }
} }
else // 不使用MailSender的情况 else // 不使用MailSender的情况
{ {
ServerHelper.WriteLine(ServerHelper.MakeClientName(Server.ClientName, Server.User) + $" 验证码为：{ForgetVerify}，请服务器管理员告知此用户"); ServerHelper.WriteLine(Server.GetClientName() + $" 验证码为：{ForgetVerify}，请服务器管理员告知此用户");
msg = ""; msg = "";
} }
} }
@ -138,7 +138,7 @@ namespace Milimoe.FunGame.Server.Controller
{ {
// 发送过验证码且验证码没有过期 // 发送过验证码且验证码没有过期
string ForgetVerifyCode = (string)SQLHelper.DataSet.Tables[0].Rows[0][ForgetVerifyCodes.Column_ForgetVerifyCode]; string ForgetVerifyCode = (string)SQLHelper.DataSet.Tables[0].Rows[0][ForgetVerifyCodes.Column_ForgetVerifyCode];
ServerHelper.WriteLine(ServerHelper.MakeClientName(Server.ClientName, Server.User) + $" 十分钟内已向{email}发送过验证码：{ForgetVerifyCode}"); ServerHelper.WriteLine(Server.GetClientName() + $" 十分钟内已向{email}发送过验证码：{ForgetVerifyCode}");
msg = ""; msg = "";
} }
} }
@ -157,7 +157,7 @@ namespace Milimoe.FunGame.Server.Controller
string msg = "无法更新您的密码，请稍后再试。"; string msg = "无法更新您的密码，请稍后再试。";
if (RequestData.Count >= 2) if (RequestData.Count >= 2)
{ {
ServerHelper.WriteLine("[" + ServerSocket.GetTypeString(SocketMessageType.DataRequest) + "] " + ServerHelper.MakeClientName(Server.ClientName, Server.User) + " -> UpdatePassword"); ServerHelper.WriteLine("[" + ServerSocket.GetTypeString(SocketMessageType.DataRequest) + "] " + Server.GetClientName() + " -> UpdatePassword");
string username = DataRequest.GetHashtableJsonObject<string>(RequestData, UserQuery.Column_Username) ?? ""; string username = DataRequest.GetHashtableJsonObject<string>(RequestData, UserQuery.Column_Username) ?? "";
string password = DataRequest.GetHashtableJsonObject<string>(RequestData, UserQuery.Column_Password) ?? ""; string password = DataRequest.GetHashtableJsonObject<string>(RequestData, UserQuery.Column_Password) ?? "";
if (username.Trim() != "" && password.Trim() != "") if (username.Trim() != "" && password.Trim() != "")

45
FunGame.Server/Models/ServerModel.cs
View File

@ -75,7 +75,7 @@ namespace Milimoe.FunGame.Server.Model
// 验证Token // 验证Token
if (type != SocketMessageType.RunTime_HeartBeat && token != Token) if (type != SocketMessageType.RunTime_HeartBeat && token != Token)
{ {
ServerHelper.WriteLine(ServerHelper.MakeClientName(ClientName, User) + " 使用了非法方式传输消息，服务器拒绝回应 -> [" + ServerSocket.GetTypeString(type) + "] "); ServerHelper.WriteLine(GetClientName() + " 使用了非法方式传输消息，服务器拒绝回应 -> [" + ServerSocket.GetTypeString(type) + "] ");
return false; return false;
} }
@ -90,9 +90,9 @@ namespace Milimoe.FunGame.Server.Model
if (!IgnoreType.Contains(type)) if (!IgnoreType.Contains(type))
{ {
if (msg.Trim() == "") if (msg.Trim() == "")
ServerHelper.WriteLine("[" + ServerSocket.GetTypeString(type) + "] " + ServerHelper.MakeClientName(ClientName, User)); ServerHelper.WriteLine("[" + ServerSocket.GetTypeString(type) + "] " + GetClientName());
else else
ServerHelper.WriteLine("[" + ServerSocket.GetTypeString(type) + "] " + ServerHelper.MakeClientName(ClientName, User) + " -> " + msg); ServerHelper.WriteLine("[" + ServerSocket.GetTypeString(type) + "] " + GetClientName() + " -> " + msg);
} }
switch (type) switch (type)
@ -236,14 +236,14 @@ namespace Milimoe.FunGame.Server.Model
SQLHelper.ExecuteDataSet(UserQuery.Select_IsExistUsername(username)); SQLHelper.ExecuteDataSet(UserQuery.Select_IsExistUsername(username));
if (SQLHelper.Result == SQLResult.Success) if (SQLHelper.Result == SQLResult.Success)
{ {
ServerHelper.WriteLine(ServerHelper.MakeClientName(ClientName, User) + " 账号已被注册"); ServerHelper.WriteLine(GetClientName() + " 账号已被注册");
return Send(socket, type, RegInvokeType.DuplicateUserName); return Send(socket, type, RegInvokeType.DuplicateUserName);
} }
// 检查邮箱是否重复 // 检查邮箱是否重复
SQLHelper.ExecuteDataSet(UserQuery.Select_IsExistEmail(email)); SQLHelper.ExecuteDataSet(UserQuery.Select_IsExistEmail(email));
if (SQLHelper.Result == SQLResult.Success) if (SQLHelper.Result == SQLResult.Success)
{ {
ServerHelper.WriteLine(ServerHelper.MakeClientName(ClientName, User) + " 邮箱已被注册"); ServerHelper.WriteLine(GetClientName() + " 邮箱已被注册");
return Send(socket, type, RegInvokeType.DuplicateEmail); return Send(socket, type, RegInvokeType.DuplicateEmail);
} }
// 检查验证码是否发送过 // 检查验证码是否发送过
@ -254,7 +254,7 @@ namespace Milimoe.FunGame.Server.Model
string RegVerifyCode = (string)SQLHelper.DataSet.Tables[0].Rows[0][RegVerifyCodes.Column_RegVerifyCode]; string RegVerifyCode = (string)SQLHelper.DataSet.Tables[0].Rows[0][RegVerifyCodes.Column_RegVerifyCode];
if ((DateTime.Now - RegTime).TotalMinutes < 10) if ((DateTime.Now - RegTime).TotalMinutes < 10)
{ {
ServerHelper.WriteLine(ServerHelper.MakeClientName(ClientName, User) + $" 十分钟内已向{email}发送过验证码：{RegVerifyCode}"); ServerHelper.WriteLine(GetClientName() + $" 十分钟内已向{email}发送过验证码：{RegVerifyCode}");
} }
return Send(socket, type, RegInvokeType.InputVerifyCode); return Send(socket, type, RegInvokeType.InputVerifyCode);
} }
@ -273,17 +273,17 @@ namespace Milimoe.FunGame.Server.Model
string[] To = new string[] { email }; string[] To = new string[] { email };
if (MailSender.Send(MailSender.CreateMail(Subject, Body, System.Net.Mail.MailPriority.Normal, true, To)) == MailSendResult.Success) if (MailSender.Send(MailSender.CreateMail(Subject, Body, System.Net.Mail.MailPriority.Normal, true, To)) == MailSendResult.Success)
{ {
ServerHelper.WriteLine(ServerHelper.MakeClientName(ClientName, User) + $" 已向{email}发送验证码：{RegVerify}"); ServerHelper.WriteLine(GetClientName() + $" 已向{email}发送验证码：{RegVerify}");
} }
else else
{ {
ServerHelper.WriteLine(ServerHelper.MakeClientName(ClientName, User) + " 无法发送验证码"); ServerHelper.WriteLine(GetClientName() + " 无法发送验证码");
ServerHelper.WriteLine(MailSender.ErrorMsg); ServerHelper.WriteLine(MailSender.ErrorMsg);
} }
} }
else // 不使用MailSender的情况 else // 不使用MailSender的情况
{ {
ServerHelper.WriteLine(ServerHelper.MakeClientName(ClientName, User) + $" 验证码为：{RegVerify}，请服务器管理员告知此用户"); ServerHelper.WriteLine(GetClientName() + $" 验证码为：{RegVerify}，请服务器管理员告知此用户");
} }
return Send(socket, type, RegInvokeType.InputVerifyCode); return Send(socket, type, RegInvokeType.InputVerifyCode);
} }
@ -309,7 +309,7 @@ namespace Milimoe.FunGame.Server.Model
DateTime RegTime = (DateTime)SQLHelper.DataSet.Tables[0].Rows[0][RegVerifyCodes.Column_RegTime]; DateTime RegTime = (DateTime)SQLHelper.DataSet.Tables[0].Rows[0][RegVerifyCodes.Column_RegTime];
if ((DateTime.Now - RegTime).TotalMinutes >= 10) if ((DateTime.Now - RegTime).TotalMinutes >= 10)
{ {
ServerHelper.WriteLine(ServerHelper.MakeClientName(ClientName, User) + " 验证码已过期"); ServerHelper.WriteLine(GetClientName() + " 验证码已过期");
msg = "此验证码已过期，请重新注册。"; msg = "此验证码已过期，请重新注册。";
SQLHelper.Execute(RegVerifyCodes.Delete_RegVerifyCode(username, email)); SQLHelper.Execute(RegVerifyCodes.Delete_RegVerifyCode(username, email));
return Send(socket, type, false, msg); return Send(socket, type, false, msg);
@ -413,7 +413,7 @@ namespace Milimoe.FunGame.Server.Model
SQLHelper.Execute(RoomQuery.Delete_QuitRoom(roomid, User.Id)); SQLHelper.Execute(RoomQuery.Delete_QuitRoom(roomid, User.Id));
if (SQLHelper.Result == SQLResult.Success) if (SQLHelper.Result == SQLResult.Success)
{ {
ServerHelper.WriteLine(ServerHelper.MakeClientName(ClientName, User) + " 解散了房间 " + roomid); ServerHelper.WriteLine(GetClientName() + " 解散了房间 " + roomid);
} }
} }
} }
@ -461,7 +461,7 @@ namespace Milimoe.FunGame.Server.Model
} }
catch (Exception e) catch (Exception e)
{ {
ServerHelper.WriteLine(ServerHelper.MakeClientName(ClientName, User) + " 没有回应。"); ServerHelper.WriteLine(GetClientName() + " 没有回应。");
ServerHelper.Error(e); ServerHelper.Error(e);
return false; return false;
} }
@ -515,14 +515,14 @@ namespace Milimoe.FunGame.Server.Model
} }
object obj = objs[0]; object obj = objs[0];
if (obj.GetType() == typeof(string) && (string)obj != "") if (obj.GetType() == typeof(string) && (string)obj != "")
ServerHelper.WriteLine("[" + ServerSocket.GetTypeString(type) + "] " + ServerHelper.MakeClientName(ClientName, User) + " <- " + obj); ServerHelper.WriteLine("[" + ServerSocket.GetTypeString(type) + "] " + GetClientName() + " <- " + obj);
return true; return true;
} }
throw new CanNotSendToClientException(); throw new CanNotSendToClientException();
} }
catch (Exception e) catch (Exception e)
{ {
ServerHelper.WriteLine(ServerHelper.MakeClientName(ClientName, User) + " 没有回应。"); ServerHelper.WriteLine(GetClientName() + " 没有回应。");
ServerHelper.Error(e); ServerHelper.Error(e);
return false; return false;
} }
@ -540,6 +540,11 @@ namespace Milimoe.FunGame.Server.Model
_ClientName = ClientName; _ClientName = ClientName;
} }
public string GetClientName()
{
return ServerHelper.MakeClientName(ClientName, User);
}
private void KickUser() private void KickUser()
{ {
if (User.Id != 0) if (User.Id != 0)
@ -596,7 +601,7 @@ namespace Milimoe.FunGame.Server.Model
private void CreateStreamReader() private void CreateStreamReader()
{ {
Thread.Sleep(100); Thread.Sleep(100);
ServerHelper.WriteLine("Creating: StreamReader -> " + ServerHelper.MakeClientName(ClientName, User) + " ...OK"); ServerHelper.WriteLine("Creating: StreamReader -> " + GetClientName() + " ...OK");
while (Running) while (Running)
{ {
if (Socket != null) if (Socket != null)
@ -608,8 +613,8 @@ namespace Milimoe.FunGame.Server.Model
{ {
RemoveUser(); RemoveUser();
Close(); Close();
ServerHelper.WriteLine(ServerHelper.MakeClientName(ClientName, User) + " Error -> Too Many Faileds."); ServerHelper.WriteLine(GetClientName() + " Error -> Too Many Faileds.");
ServerHelper.WriteLine(ServerHelper.MakeClientName(ClientName, User) + " Close -> StreamReader is Closed."); ServerHelper.WriteLine(GetClientName() + " Close -> StreamReader is Closed.");
break; break;
} }
} }
@ -619,8 +624,8 @@ namespace Milimoe.FunGame.Server.Model
{ {
RemoveUser(); RemoveUser();
Close(); Close();
ServerHelper.WriteLine(ServerHelper.MakeClientName(ClientName, User) + " Error -> Socket is Closed."); ServerHelper.WriteLine(GetClientName() + " Error -> Socket is Closed.");
ServerHelper.WriteLine(ServerHelper.MakeClientName(ClientName, User) + " Close -> StringStream is Closed."); ServerHelper.WriteLine(GetClientName() + " Close -> StringStream is Closed.");
break; break;
} }
} }
@ -629,7 +634,7 @@ namespace Milimoe.FunGame.Server.Model
private void CreatePeriodicalQuerier() private void CreatePeriodicalQuerier()
{ {
Thread.Sleep(100); Thread.Sleep(100);
ServerHelper.WriteLine("Creating: PeriodicalQuerier -> " + ServerHelper.MakeClientName(ClientName, User) + " ...OK"); ServerHelper.WriteLine("Creating: PeriodicalQuerier -> " + GetClientName() + " ...OK");
while (Running) while (Running)
{ {
// 每两小时触发一次SQL服务器的心跳查询，防止SQL服务器掉线 // 每两小时触发一次SQL服务器的心跳查询，防止SQL服务器掉线

5
FunGame.Server/Utilities/MySQLHelper.cs
View File

@ -104,7 +104,7 @@ namespace Milimoe.FunGame.Server.Utility
{ {
// _IsOneTime = false需要手动调用此方法 // _IsOneTime = false需要手动调用此方法
_Connection?.Close(); _Connection?.Close();
ServerHelper.WriteLine($"{GetClientName()}已释放MySQL连接"); ServerHelper.WriteLine($"{GetClientName()} 已释放MySQL连接");
} }
/// <summary> /// <summary>
@ -167,8 +167,7 @@ namespace Milimoe.FunGame.Server.Utility
/// <returns></returns> /// <returns></returns>
private string GetClientName() private string GetClientName()
{ {
if (ServerModel is null) return ""; return ServerModel?.GetClientName() ?? string.Empty;
return ServerHelper.MakeClientName(ServerModel.ClientName, ServerModel.User) + " ";
} }
} }
} }