diff --git a/tasks.py b/tasks.py index 7e8e273..3000c4a 100644 --- a/tasks.py +++ b/tasks.py @@ -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)