feat: add 'file_clean_time' field to Application model and update related logic

Author: wxg0103

apps/application/migrations/0006_application_file_clean_time.py

@@ -0,0 +1,24 @@
+# Generated by Django 5.2.9 on 2026-01-14 06:51
+
+from django.db import migrations, models
+
+
+def insert_default_data(apps, schema_editor):
+    Application = apps.get_model('application', 'Application')
+    # 批量修改 把所有的file_clean_time的值设置成clean_time的值
+    Application.objects.all().update(file_clean_time=models.F('clean_time'))
+
+
+class Migration(migrations.Migration):
+    dependencies = [
+        ('application', '0005_chatrecord_vote_other_content_chatrecord_vote_reason'),
+    ]
+
+    operations = [
+        migrations.AddField(
+            model_name='application',
+            name='file_clean_time',
+            field=models.IntegerField(default=180, verbose_name='文件清理时间'),
+        ),
+        migrations.RunPython(insert_default_data)
+    ]

apps/application/models/application.py

@@ -103,6 +103,7 @@ class Application(AppModelMixin):
     application_enable = models.BooleanField(verbose_name="应用是否启用", default=False)
     application_ids = models.JSONField(verbose_name="应用ID列表", default=list)
     mcp_output_enable = models.BooleanField(verbose_name="MCP输出是否启用", default=True)
+    file_clean_time = models.IntegerField(verbose_name="文件清理时间", default=180)
 
     @staticmethod
     def get_default_model_prompt():

apps/application/serializers/application.py

@@ -678,6 +678,7 @@ def to_application(application, workspace_id, user_id, update_tool_map, folder_i
                            stt_model_enable=application.get('stt_model_enable'),
                            tts_type=application.get('tts_type'),
                            clean_time=application.get('clean_time'),
+                           file_clean_time=application.get('file_clean_time'),
                            file_upload_enable=application.get('file_upload_enable'),
                            file_upload_setting=application.get('file_upload_setting'),
                            )
@@ -987,7 +988,7 @@ def edit(self, instance: Dict, with_valid=True):
                        'stt_model_params_setting',
                        'mcp_enable', 'mcp_tool_ids', 'mcp_servers', 'mcp_source', 'tool_enable', 'tool_ids',
                        'mcp_output_enable', 'application_enable', 'application_ids',
-                       'problem_optimization_prompt', 'clean_time', 'folder_id']
+                       'problem_optimization_prompt', 'clean_time', 'file_clean_time','folder_id']
         for update_key in update_keys:
             if update_key in instance and instance.get(update_key) is not None:
                 application.__setattr__(update_key, instance.get(update_key))

apps/common/job/clean_chat_job.py

@@ -23,15 +23,29 @@ def clean_chat_log_job_lock():
     maxkb_logger.info(_('start clean chat log'))
     now = timezone.now()
 
-    applications = Application.objects.all().values('id', 'clean_time')
+    applications = Application.objects.all().values('id', 'clean_time', 'file_clean_time')
     cutoff_dates = {
         app['id']: now - datetime.timedelta(days=app['clean_time'] or 180)
         for app in applications
     }
+    file_cutoff_dates = {
+        app['id']: now - datetime.timedelta(days=app['file_clean_time'] or app['clean_time'] or 180)
+        for app in applications
+    }
+    file_conditions = Q()
+    for app_id, cutoff_date in file_cutoff_dates.items():
+        file_conditions |= Q(chat__application_id=app_id, create_time__lt=cutoff_date)
+    clean_method(file_conditions, clean_log=False)
 
     query_conditions = Q()
     for app_id, cutoff_date in cutoff_dates.items():
         query_conditions |= Q(chat__application_id=app_id, create_time__lt=cutoff_date)
+    clean_method(query_conditions)
+
+    maxkb_logger.info(_('end clean chat log'))
+
+
+def clean_method(query_conditions, clean_log=True):
     batch_size = 500
     while True:
         with transaction.atomic():
@@ -54,20 +68,20 @@ def clean_chat_log_job_lock():
                     (item['max_create_time'] for item in max_create_times if item['chat_id'] == record.chat_id), None)
                 if max_create_time:
                     files_to_delete.extend(
-                        File.objects.filter(meta__chat_id=str(record.chat_id), create_time__lt=max_create_time)
+                        File.objects.filter(source_id=str(record.chat_id), create_time__lt=max_create_time)
                     )
             # 删除 ChatRecord
-            deleted_count = ChatRecord.objects.filter(id__in=chat_record_ids).delete()[0]
+            deleted_count = 0
+            if clean_log:
+                deleted_count = ChatRecord.objects.filter(id__in=chat_record_ids).delete()[0]
 
-            # 删除没有关联 ChatRecord 的 Chat
-            Chat.objects.filter(chatrecord__isnull=True, id__in=chat_ids).delete()
+                # 删除没有关联 ChatRecord 的 Chat
+                Chat.objects.filter(chatrecord__isnull=True, id__in=chat_ids).delete()
             File.objects.filter(loid__in=[file.loid for file in files_to_delete]).delete()
 
             if deleted_count < batch_size:
                 break
 
-    maxkb_logger.info(_('end clean chat log'))
-
 
 def run():
     rlock = RedisLock()

ui/src/locales/lang/en-US/views/chat-log.ts

@@ -23,6 +23,7 @@ export default {
   },
   addToKnowledge: 'Add to Knowledge',
   daysText: 'Days ago',
+  fileDaysText: 'The attachment uploaded from the previous conversation',
   selectKnowledge: 'Select Knowledge',
   selectKnowledgePlaceholder: 'Please select a knowledge',
   saveToDocument: 'Save to Document',

ui/src/locales/lang/zh-CN/views/chat-log.ts

@@ -23,6 +23,7 @@ export default {
   },
   addToKnowledge: '添加至知识库',
   daysText: '天之前的对话记录',
+  fileDaysText: '天之前的对话上传的附件',
   selectKnowledge: '选择知识库',
   selectKnowledgePlaceholder: '请选择知识库',
   saveToDocument: '保存至文档',

ui/src/locales/lang/zh-Hant/views/chat-log.ts

@@ -23,6 +23,7 @@ export default {
   },
   addToKnowledge: '添加至知識庫',
   daysText: '天之前的對話記錄',
+  fileDaysText: '天之前的對話上傳的附件',
   selectKnowledge: '選擇知識庫',
   selectKnowledgePlaceholder: '請選擇知識庫',
   saveToDocument: '保存至文件',