|
|
@@ -202,6 +202,10 @@ def scheduled_task_sync_wx_info(self, redis_config, kafka_config, gewe_config): |
|
|
|
def scheduled_task_add_contacts_from_chatrooms(self, redis_config, kafka_config, gewe_config): |
|
|
|
async def task(): |
|
|
|
try: |
|
|
|
now = datetime.datetime.now() |
|
|
|
if now.hour < 8: |
|
|
|
logger.info(f"定时群成员定时添好友任务不启动,当前时间为 {now.strftime('%Y-%m-%d %H:%M:%S')},早于8点") |
|
|
|
return |
|
|
|
logger.info('定时群成员定时添好友任务开始') |
|
|
|
redis_service = RedisService() |
|
|
|
await redis_service.init(**redis_config) |
|
|
@@ -250,7 +254,7 @@ def scheduled_task_add_contacts_from_chatrooms(self, redis_config, kafka_config, |
|
|
|
contact_wxids_set = set(contact_wxids) |
|
|
|
# for admin_wxid in admin_wxids: |
|
|
|
# contact_wxids_set.add(admin_wxid) |
|
|
|
contact_wxids_set.update(admin_wxids) |
|
|
|
contact_wxids_set.update(set(admin_wxids)) |
|
|
|
if chatroom_owner_wxid is not None: |
|
|
|
contact_wxids_set.add(chatroom_owner_wxid) |
|
|
|
|
|
|
|