From f7382b7d041e90d6db8d2f7394a04a3f44eb7805 Mon Sep 17 00:00:00 2001
From: Mili <mili@mili.cyou>
Date: Tue, 14 Mar 2023 00:08:34 +0800
Subject: [PATCH] =?UTF-8?q?=E6=B7=BB=E5=8A=A0SQL=E6=9C=8D=E5=8A=A1?=
 =?UTF-8?q?=E5=99=A8=E5=BF=83=E8=B7=B3=E6=9F=A5=E8=AF=A2=E6=9C=BA=E5=88=B6?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 FunGame.Server/Model/ServerModel.cs | 16 ++++++++++++++++
 1 file changed, 16 insertions(+)

diff --git a/FunGame.Server/Model/ServerModel.cs b/FunGame.Server/Model/ServerModel.cs
index 6faa457..109f135 100644
--- a/FunGame.Server/Model/ServerModel.cs
+++ b/FunGame.Server/Model/ServerModel.cs
@@ -367,6 +367,10 @@ namespace Milimoe.FunGame.Server.Model
             {
                 CreateStreamReader();
             });
+            Task PeriodicalQuerier = Task.Factory.StartNew(() =>
+            {
+                CreatePeriodicalQuerier();
+            });
         }
 
         public void SetTaskAndClientName(Task t, string ClientName)
@@ -460,6 +464,18 @@ namespace Milimoe.FunGame.Server.Model
                 }
             }
         }
+        
+        private void CreatePeriodicalQuerier()
+        {
+            Thread.Sleep(100);
+            ServerHelper.WriteLine("Creating: PeriodicalQuerier -> " + SocketHelper.MakeClientName(ClientName, User) + " ...OK");
+            while (Running)
+            {
+                // 每两小时触发一次SQL服务器的心跳查询，防止SQL服务器掉线
+                Thread.Sleep(2 * 1000 * 3600);
+                SQLHelper.ExecuteDataSet(UserQuery.Select_DuplicateUsername(UserName), out _);
+            }
+        }
 
         private void Close()
         {