|
|
@@ -1494,7 +1494,7 @@ class GeWeService: |
|
|
|
async def wx_add_contacts_from_chatroom_task_status_async(self,wxid,chatroom_id)->int: |
|
|
|
history_hash_key = f'__AI_OPS_WX__:GROUPS_ADD_CONTACT_HISTORY:{wxid}:{chatroom_id}' |
|
|
|
cache=await self.redis_service.get_hash(history_hash_key) |
|
|
|
cache.keys() |
|
|
|
|
|
|
|
|
|
|
|
group=await self. get_group_members_from_cache_async(wxid,chatroom_id) |
|
|
|
chatroom_member_list = group.get('memberList', []) |
|
|
@@ -1511,7 +1511,7 @@ class GeWeService: |
|
|
|
#unavailable_wixds=set(admin_wxids) |
|
|
|
|
|
|
|
available_members=[m["wxid"] for m in chatroom_member_list if m["wxid"] not in admin_wxids] |
|
|
|
if len(available_members) > len(cache.keys): |
|
|
|
if len(available_members) > len(cache.keys()): |
|
|
|
return 1 |
|
|
|
|
|
|
|
for key, value in cache.items(): |
|
|
|