liuwei_x_x/abot
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

调整日志

Browse Source
This commit is contained in:
liuwei
2025-12-22 15:48:59 +08:00
parent 8a68338ffe
commit 38cb74517e
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
robot.py
View File

@@ -230,7 +230,7 @@ class Robot:
self.LOG.info("开始处理wechat_ipad消息") self.LOG.info("开始处理wechat_ipad消息")
while self.ipad_running: while self.ipad_running:
try: try:
data = await self.ipad_bot.sync_message() data_temp = await self.ipad_bot.sync_message()
except Exception as e: except Exception as e:
self.LOG.error(f"获取新消息失败 {e}") self.LOG.error(f"获取新消息失败 {e}")
if "用户可能退出" in str(e): if "用户可能退出" in str(e):
@@ -242,7 +242,7 @@ class Robot:
await asyncio.sleep(5) await asyncio.sleep(5)
continue continue
data = data.get("AddMsgs") data = data_temp.get("AddMsgs")
if data: if data:
for message in data: for message in data:
# self.LOG.debug(f"sync_message.处理消息消息内容: {message}") # self.LOG.debug(f"sync_message.处理消息消息内容: {message}")
@@ -262,7 +262,7 @@ class Robot:
# 并发执行，限制最大并发数 # 并发执行，限制最大并发数
xx = asyncio.create_task(self._process_with_semaphore(wxmsg)) xx = asyncio.create_task(self._process_with_semaphore(wxmsg))
else: else:
self.LOG.debug(f"MESSAGE：{data}") self.LOG.debug(f"MESSAGE：{data_temp}")
# 使用异步睡眠替代忙等待循环 # 使用异步睡眠替代忙等待循环
await asyncio.sleep(2) await asyncio.sleep(2)