From f5da8dd57cdd274c56a8c5703abfed256e4ca680 Mon Sep 17 00:00:00 2001 From: H Vs Date: Tue, 8 Apr 2025 18:12:06 +0800 Subject: [PATCH] =?UTF-8?q?=E5=8A=A0=E5=A5=BD=E5=8F=8B=E4=BB=BB=E5=8A=A1?= =?UTF-8?q?=E7=8A=B6=E6=80=81?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- tasks.py | 9 ++++++++- 1 file changed, 8 insertions(+), 1 deletion(-) diff --git a/tasks.py b/tasks.py index 52126ed..58a4ac7 100644 --- a/tasks.py +++ b/tasks.py @@ -673,6 +673,13 @@ def scheduled_task_add_contacts_from_chatrooms(self, redis_config, kafka_config, nickname = next((member['nickName'] for member in chatroom_member_list if member['wxid'] == wxid), None) + if not remaining_chatroot_members: + logger.info(f'{nickname}-{wxid} 在 {chatroom_nickname} 群里没有好友可以邀请') + # 任务状态推送到kafka + k_message=wx_add_contacts_from_chatroom_task_status(wxid,chatroom_id,2) + await kafka_service.send_message_async(k_message) + continue + logger.info(f'{nickname}-{wxid} 在 {chatroom_nickname} 群里还可以邀请的好友有：{[x.get("nickName") for x in remaining_chatroot_members]}') for m in remaining_chatroot_members: # 判断本次任务是否已经邀请了30个好友 @@ -740,7 +747,7 @@ def scheduled_task_add_contacts_from_chatrooms(self, redis_config, kafka_config, await kafka_service.send_message_async(k_message) await asyncio.sleep(random.uniform(1.5, 3)) - # 任务推送到kafka + # 任务状态推送到kafka task_status=await gewe_service.wx_add_contacts_from_chatroom_task_status_async(wxid,chatroom_id) wx_add_contacts_from_chatroom_task_status(wxid,chatroom_id,task_status) await kafka_service.send_message_async(k_message)