From 84e6074af1e636f9467f05e206c1a02d0b301be0 Mon Sep 17 00:00:00 2001
From: qsc <qsc20001102@163.com>
Date: Tue, 16 Dec 2025 19:47:35 +0800
Subject: [PATCH] 11

---
 core/async_task.py | 33 ++++++++++++++++++---------------
 1 file changed, 18 insertions(+), 15 deletions(-)

diff --git a/core/async_task.py b/core/async_task.py
index 903f0a1..f3d9a2a 100644
--- a/core/async_task.py
+++ b/core/async_task.py
@@ -46,21 +46,24 @@ class AsyncTask:
             logger.info(f"开服监控功能关闭")
             return
         while self.kfjk_conf["enable"]:
-            # 获取最新服务状态
-            data = await self.jx3fun.kaifu("梦江南")
-            self.kfjk_server_state_new = data["status"]
-            logger.debug(f"开服监控功能循环中,上次询问服务器状态{self.kfjk_server_state},本次询问的服务器状态{self.kfjk_server_state_new}") 
-            # 判断状态是否变化
-            if self.kfjk_server_state != self.kfjk_server_state_new:
-                logger.info(f"开服监控功能循环中,上次询问服务器状态{self.kfjk_server_state},本次询问的服务器状态{self.kfjk_server_state_new}") 
-                if self.kfjk_server_state and not self.kfjk_server_state_new:
-                    message_chain = MessageChain().message("剑网三服务器已关闭\n休息一会把,开服了喊你！")
-                if self.kfjk_server_state_new and not self.kfjk_server_state:
-                    message_chain = MessageChain().message("剑网三服务器已开启\n快冲！快冲！")
-                if self.kfjk_conf["umos"]:
-                    for umo in self.kfjk_conf["umos"]:
-                        await self.context.send_message(umo, message_chain)
-            self.kfjk_server_state = self.kfjk_server_state_new
+            try:
+                # 获取最新服务状态
+                data = await self.jx3fun.kaifu("梦江南")
+                self.kfjk_server_state_new = data["status"]
+                logger.debug(f"开服监控功能循环中,上次询问服务器状态{self.kfjk_server_state},本次询问的服务器状态{self.kfjk_server_state_new}") 
+                # 判断状态是否变化
+                if self.kfjk_server_state != self.kfjk_server_state_new:
+                    logger.info(f"开服监控功能循环中,上次询问服务器状态{self.kfjk_server_state},本次询问的服务器状态{self.kfjk_server_state_new}") 
+                    if self.kfjk_server_state and not self.kfjk_server_state_new:
+                        message_chain = MessageChain().message("剑网三服务器已关闭\n休息一会把,开服了喊你！")
+                    if self.kfjk_server_state_new and not self.kfjk_server_state:
+                        message_chain = MessageChain().message("剑网三服务器已开启\n快冲！快冲！")
+                    if self.kfjk_conf["umos"]:
+                        for umo in self.kfjk_conf["umos"]:
+                            await self.context.send_message(umo, message_chain)
+                self.kfjk_server_state = self.kfjk_server_state_new
+            except Exception as e:
+                logger.error(f"开服监控循环异常: {e}")
             await asyncio.sleep(self.kfjk_conf["time"])  # 休眠指定时间