From 1da71777d77b32b3c0411586c784773bacf2f87f Mon Sep 17 00:00:00 2001 From: H Vs Date: Wed, 9 Apr 2025 18:15:03 +0800 Subject: [PATCH] =?UTF-8?q?=E7=BE=A4=E5=8A=A0=E5=A5=BD=E5=8F=8B=E8=A7=84?= =?UTF-8?q?=E5=88=99?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- tasks.py | 13 +++++++------ 1 file changed, 7 insertions(+), 6 deletions(-) diff --git a/tasks.py b/tasks.py index 0171fdb..838b98f 100644 --- a/tasks.py +++ b/tasks.py @@ -528,9 +528,10 @@ def scheduled_task_add_contacts_from_chatrooms_p2(self, redis_config, kafka_conf def scheduled_task_add_contacts_from_chatrooms(self, redis_config, kafka_config, gewe_config): ''' - 关于群加好友的请求规则:一次30人,间隔2小时做1次,一天做3次,即最多90人/天。 + 关于群加好友的请求规则: 每个智能体一次最多30人,间隔2小时做1次,即最多90人/天。 加好友规则:每天处理次数、间隔时间(分钟)、每次加好友人数这3个参数都可以设置。目前默认只是上面的设置。 ''' + async def task(): try: now = datetime.now() @@ -558,17 +559,17 @@ def scheduled_task_add_contacts_from_chatrooms(self, redis_config, kafka_config, oneday_add_contacts_total=90 once_add_contacts_total=30 - oneday_times=3 + #oneday_times=3 if scheduled_task_add_contacts_from_chatrooms_config: oneday_add_contacts_total=scheduled_task_add_contacts_from_chatrooms_config.get('oneDayAddContactsTotal',90) once_add_contacts_total=scheduled_task_add_contacts_from_chatrooms_config.get('onceAddContactsTotal',30) - oneday_times=scheduled_task_add_contacts_from_chatrooms_config.get('oneDayTimes',3) + #oneday_times=scheduled_task_add_contacts_from_chatrooms_config.get('oneDayTimes',3) cache_task_run_time_logs= await gewe_service.get_task_run_time_async('scheduled_task_add_contacts_from_chatrooms') - if len(cache_task_run_time_logs) == oneday_times: - logger.info(f"今日定时群成员定时添好友任务已达上限 {oneday_times} 次！") - return + # if len(cache_task_run_time_logs) == oneday_times: + # logger.info(f"今日定时群成员定时添好友任务已达上限 {oneday_times} 次！") + # return if cache_task_run_time_logs: sorted_tasks = sorted(cache_task_run_time_logs, key=lambda x: x.get("runTime"), reverse=True)