qsc20001102/astrbot_plugin_jx3
0
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

11

Browse Source
This commit is contained in:
qsc
2025-12-16 19:47:35 +08:00
parent 3bdf2b9f54
commit 84e6074af1
1 changed files with 18 additions and 15 deletions
Download Patch File Download Diff File Expand all files Collapse all files
core/async_task.py
+18 -15
View File
@@ -46,21 +46,24 @@ class AsyncTask:
logger.info(f"开服监控功能关闭") logger.info(f"开服监控功能关闭")
return return
while self.kfjk_conf["enable"]: while self.kfjk_conf["enable"]:
# 获取最新服务状态 try:
data = await self.jx3fun.kaifu("梦江南") # 获取最新服务状态
self.kfjk_server_state_new = data["status"] data = await self.jx3fun.kaifu("梦江南")
logger.debug(f"开服监控功能循环中,上次询问服务器状态{self.kfjk_server_state},本次询问的服务器状态{self.kfjk_server_state_new}") 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 != self.kfjk_server_state_new:
if self.kfjk_server_state and not self.kfjk_server_state_new: logger.info(f"开服监控功能循环中,上次询问服务器状态{self.kfjk_server_state},本次询问的服务器状态{self.kfjk_server_state_new}")
message_chain = MessageChain().message("剑网三服务器已关闭\n休息一会把,开服了喊你！") if self.kfjk_server_state and not self.kfjk_server_state_new:
if self.kfjk_server_state_new and not self.kfjk_server_state: message_chain = MessageChain().message("剑网三服务器已关闭\n休息一会把,开服了喊你！")
message_chain = MessageChain().message("剑网三服务器已开启\n快冲！快冲！") if self.kfjk_server_state_new and not self.kfjk_server_state:
if self.kfjk_conf["umos"]: message_chain = MessageChain().message("剑网三服务器已开启\n快冲！快冲！")
for umo in self.kfjk_conf["umos"]: if self.kfjk_conf["umos"]:
await self.context.send_message(umo, message_chain) for umo in self.kfjk_conf["umos"]:
self.kfjk_server_state = self.kfjk_server_state_new 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"]) # 休眠指定时间 await asyncio.sleep(self.kfjk_conf["time"]) # 休眠指定时间