加好友任务状态

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)