|
|
@@ -644,9 +644,9 @@ def scheduled_task_add_contacts_from_chatrooms(self, redis_config, kafka_config, |
|
|
|
logger.info(f"{wxid}上次定时群成员定时添好友任务在2小时内,不再执行") |
|
|
|
return |
|
|
|
|
|
|
|
time_difference_seconds = today_seconds_remaining() |
|
|
|
|
|
|
|
cache_task_run_time_wxid_logs.append({"runTime":int(time.time())}) |
|
|
|
await gewe_service.save_task_run_time_by_wxid_async(wxid,'scheduled_task_add_contacts_from_chatrooms',cache_task_run_time_wxid_logs,time_difference_seconds) |
|
|
|
await gewe_service.save_task_run_time_by_wxid_async(wxid,'scheduled_task_add_contacts_from_chatrooms',cache_task_run_time_wxid_logs,3600*2) |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|