15308555518/ MaxKB
1
0
Fork 0
mirror of https://github.com/1Panel-dev/MaxKB.git synced 2025-12-26 01:33:05 +00:00
Code Issues Actions 2 Packages Projects Releases Wiki Activity

fix: 修复应用日志清除后，对话中的文件在file表中没删掉的缺陷 

--bug=1049852 --user=王孝刚 【应用编排】应用日志清除后，对话中的文件在file表中没删掉 https://www.tapd.cn/57709429/s/1622739
This commit is contained in:
wxg0103 2024-12-02 17:58:24 +08:00 committed by wxg
parent 560d49ddf4
commit 5d4f35da2e
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
apps/common/job/clean_chat_job.py
View File

@ -39,11 +39,12 @@ def clean_chat_log_job():
with transaction.atomic():
logs_to_delete = Chat.objects.filter(query_conditions).values_list('id', flat=True)[:batch_size]
count = logs_to_delete.count()
logs_to_delete_str = [str(uuid) for uuid in logs_to_delete]
if count == 0:
break
deleted_count, _ = Chat.objects.filter(id__in=logs_to_delete).delete()
# 删除对应的文件
File.objects.filter(meta__chat_id__in=[str(uuid) for uuid in logs_to_delete]).delete()
File.objects.filter(meta__chat_id__in=logs_to_delete_str).delete()
if deleted_count < batch_size:
break
@ -57,6 +58,6 @@ def run():
existing_job = scheduler.get_job(job_id='clean_chat_log')
if existing_job is not None:
existing_job.remove()
scheduler.add_job(clean_chat_log_job, 'cron', hour='0', minute='5', id='clean_chat_log')
scheduler.add_job(clean_chat_log_job, 'cron', minute='*/5', id='clean_chat_log')
finally:
lock.un_lock('clean_chat_log_job')