1 changed files with 5 additions and 4 deletions
+ 5
- 4
tasks.py
View File
| @@ -230,11 +230,12 @@ def scheduled_task_add_contacts_from_chatrooms(self, redis_config, kafka_config, | |||
| chatroom_member=await gewe_service.get_group_members_from_cache_async(wxid, chatroom_id) | |||
| chatroom_nickname = chatroom.get('nickName') | |||
| chatroom_owner_wxid = chatroom_member.get('chatroomOwner', None) | |||
| admin_wxid = chatroom_member.get('adminWxid', None) | |||
| logger.info(f'{chatroom_nickname} 的群主是 {chatroom_owner_wxid}，管理员是{admin_wxid}') | |||
| admin_wxids = chatroom_member.get('adminWxid', []) | |||
| logger.info(f'{chatroom_nickname} 的群主是 {chatroom_owner_wxid}，管理员是{admin_wxids}') | |||
| contact_wxids_set = set(contact_wxids) | |||
| if admin_wxid is not None: | |||
| contact_wxids_set.add(admin_wxid) | |||
| # for admin_wxid in admin_wxids: | |||
| # contact_wxids_set.add(admin_wxid) | |||
| contact_wxids_set.update(admin_wxids) | |||
| if chatroom_owner_wxid is not None: | |||
| contact_wxids_set.add(chatroom_owner_wxid) | |||
Loading…