feat: trigger task record

Author: shaohuzhang1

apps/trigger/migrations/0001_initial.py

@@ -1,5 +1,6 @@
-# Generated by Django 5.2.8 on 2026-01-22 03:09
+# Generated by Django 5.2.9 on 2026-01-23 09:47
 
+import common.encoder.encoder
 import django.db.models.deletion
 import uuid_utils.compat
 from django.db import migrations, models
@@ -40,14 +41,34 @@ class Migration(migrations.Migration):
                 ('update_time', models.DateTimeField(auto_now=True, db_index=True, verbose_name='修改时间')),
                 ('id', models.UUIDField(default=uuid_utils.compat.uuid7, editable=False, primary_key=True, serialize=False, verbose_name='主键id')),
                 ('source_type', models.CharField(choices=[('APPLICATION', 'Application'), ('TOOL', 'Tool')], default='APPLICATION', max_length=256, verbose_name='触发器任务类型')),
-                ('source_id', models.UUIDField(blank=True, null=True, verbose_name='资源id')),
+                ('source_id', models.UUIDField(verbose_name='资源id')),
                 ('is_active', models.BooleanField(db_index=True, default=True)),
                 ('parameter', models.JSONField(default=list)),
                 ('meta', models.JSONField(default=dict)),
                 ('trigger', models.ForeignKey(on_delete=django.db.models.deletion.CASCADE, to='trigger.trigger')),
             ],
             options={
                 'db_table': 'event_trigger_task',
+                'unique_together': {('trigger', 'source_id', 'source_type')},
+            },
+        ),
+        migrations.CreateModel(
+            name='TaskRecord',
+            fields=[
+                ('create_time', models.DateTimeField(auto_now_add=True, db_index=True, verbose_name='创建时间')),
+                ('update_time', models.DateTimeField(auto_now=True, db_index=True, verbose_name='修改时间')),
+                ('id', models.UUIDField(default=uuid_utils.compat.uuid7, editable=False, primary_key=True, serialize=False, verbose_name='主键id')),
+                ('source_type', models.CharField(choices=[('APPLICATION', 'Application'), ('TOOL', 'Tool')], default='APPLICATION', max_length=256, verbose_name='触发器任务类型')),
+                ('source_id', models.UUIDField(verbose_name='资源id')),
+                ('task_record_id', models.UUIDField(verbose_name='任务记录id')),
+                ('meta', models.JSONField(default=dict, encoder=common.encoder.encoder.SystemEncoder)),
+                ('state', models.CharField(choices=[('PENDING', 'Pending'), ('STARTED', 'Started'), ('SUCCESS', 'Success'), ('FAILURE', 'Failure'), ('REVOKE', 'Revoke'), ('REVOKED', 'Revoked')], default='STARTED', max_length=20, verbose_name='状态')),
+                ('run_time', models.FloatField(default=0, verbose_name='运行时长')),
+                ('trigger', models.ForeignKey(on_delete=django.db.models.deletion.CASCADE, to='trigger.trigger')),
+                ('trigger_task', models.ForeignKey(on_delete=django.db.models.deletion.CASCADE, to='trigger.triggertask')),
+            ],
+            options={
+                'db_table': 'event_trigger_task_record',
             },
         ),
     ]

apps/trigger/migrations/0002_taskrecord.py

@@ -48,7 +48,7 @@ class TriggerTask(AppModelMixin):
     source_type = models.CharField(verbose_name="触发器任务类型", choices=TriggerTaskTypeChoices.choices,
                                    default=TriggerTaskTypeChoices.APPLICATION, max_length=256
                                    )
-    source_id = models.UUIDField(verbose_name="资源id", blank=True, null=True)
+    source_id = models.UUIDField(verbose_name="资源id")
     is_active = models.BooleanField(default=True, db_index=True)
     parameter = models.JSONField(default=list)
     meta = models.JSONField(default=dict)
@@ -60,10 +60,15 @@ class Meta:
 
 class TaskRecord(AppModelMixin):
     id = models.UUIDField(primary_key=True, max_length=128, default=uuid.uuid7, editable=False, verbose_name="主键id")
+
+    trigger = models.ForeignKey(Trigger, on_delete=models.CASCADE)
+
+    trigger_task = models.ForeignKey(TriggerTask, on_delete=models.CASCADE)
+
     source_type = models.CharField(verbose_name="触发器任务类型", choices=TriggerTaskTypeChoices.choices,
                                    default=TriggerTaskTypeChoices.APPLICATION, max_length=256)
-    source_id = models.UUIDField(verbose_name="资源id", blank=True, null=True)
-    task_record_id = models.UUIDField(verbose_name="任务记录id", blank=True, null=True)
+    source_id = models.UUIDField(verbose_name="资源id")
+    task_record_id = models.UUIDField(verbose_name="任务记录id")
     meta = models.JSONField(default=dict, encoder=SystemEncoder)
     state = models.CharField(verbose_name='状态', max_length=20,
                              choices=State.choices,

apps/trigger/migrations/0003_alter_taskrecord_task_record_id.py

@@ -6,11 +6,17 @@
     @date：2026/1/14 16:34
     @desc:
 """
+import os
+
+from django.db import models
 from django.db.models import QuerySet
 from django.utils.translation import gettext_lazy as _
 from rest_framework import serializers
 
-from trigger.models import TriggerTask
+from common.db.search import native_page_search, get_dynamics_model
+from common.utils.common import get_file_content
+from maxkb.conf import PROJECT_DIR
+from trigger.models import TriggerTask, TaskRecord
 
 
 class TriggerTaskResponse(serializers.ModelSerializer):
@@ -32,3 +38,38 @@ def list(self, with_valid=True):
         if with_valid:
             self.is_valid(raise_exception=True)
         return [TriggerTaskResponse(row).data for row in self.get_query_set()]
+
+
+class TriggerTaskRecordQuerySerializer(serializers.Serializer):
+    trigger_id = serializers.CharField(required=True, label=_("Trigger ID"))
+    workspace_id = serializers.CharField(required=True, label=_('workspace id'))
+    state = serializers.CharField(required=False, allow_blank=True, allow_null=True, label=_('Trigger task'))
+    name = serializers.CharField(required=False, allow_blank=True, allow_null=True, label=_('Trigger task'))
+
+    def get_query_set(self):
+        trigger_query_set = QuerySet(
+            model=get_dynamics_model({
+                'ett.state': models.CharField(),
+                'sdc.name': models.CharField(),
+                'ett.workspace_id': models.CharField(),
+                'ett.trigger_id': models.UUIDField(),
+            }))
+        trigger_query_set = trigger_query_set.filter(
+            **{'ett.trigger_id': self.data.get("trigger_id")})
+        if self.data.get('state'):
+            trigger_query_set = trigger_query_set.filter(**{'ett.state': self.data.get('state')})
+        if self.data.get("name"):
+            trigger_query_set = trigger_query_set.filter(**{'sdc.name__contains': self.data.get('name')})
+        return trigger_query_set
+
+    def list(self, with_valid=True):
+        if with_valid:
+            self.is_valid(raise_exception=True)
+        return [TriggerTaskResponse(row).data for row in self.get_query_set()]
+
+    def page(self, current_page, page_size, with_valid=True):
+        if with_valid:
+            self.is_valid(raise_exception=True)
+        return native_page_search(current_page, page_size, self.get_query_set(), get_file_content(
+            os.path.join(PROJECT_DIR, "apps", "trigger", "sql", 'get_trigger_task_record_page_list.sql')
+        ))

apps/trigger/migrations/0004_alter_triggertask_unique_together.py

@@ -0,0 +1,27 @@
+WITH source_data_cte AS (SELECT 'APPLICATION' as source_type,
+                                id,
+                                "name",
+                                "desc",
+                                "user_id",
+                                "workspace_id",
+                                "icon",
+                                "type",
+                                "folder_id"
+                         FROM application
+                         UNION ALL
+                         SELECT 'TOOL'            as source_type,
+                                id,
+                                "name",
+                                "desc",
+                                "user_id",
+                                "workspace_id",
+                                "icon",
+                                "tool_type"::text as "type",
+                                "folder_id"
+                         FROM tool)
+select ett.*,
+       sdc.name as source_name,
+       sdc.icon as source_icon
+from event_trigger_task_record ett
+         left join source_data_cte sdc
+                   on ett.source_id = sdc.id and ett.source_type = sdc.source_type

apps/trigger/models/trigger.py

@@ -19,12 +19,17 @@
          name='delete batch'),
     path('workspace/<str:workspace_id>/trigger/batch_activate', views.TriggerView.BatchActivate.as_view(),
          name='activate batch'),
-    path('workspace/<str:workspace_id>/trigger/<str:trigger_id>', views.TriggerView.Operate.as_view(), name='trigger operate'),
+    path('workspace/<str:workspace_id>/trigger/<str:trigger_id>', views.TriggerView.Operate.as_view(),
+         name='trigger operate'),
     path('workspace/<str:workspace_id>/trigger/<int:current_page>/<int:page_size>', views.TriggerView.Page.as_view(),
          name='trigger_page'),
     path('workspace/<str:workspace_id>/<str:source_type>/<str:source_id>/trigger/<str:trigger_id>',
          views.TaskSourceTriggerView.Operate.as_view(), name='task source trigger operate'),
-    path('workspace/<str:workspace_id>/<str:source_type>/<str:source_id>/trigger', views.TaskSourceTriggerView.as_view(), name='task source trigger'),
+    path('workspace/<str:workspace_id>/<str:source_type>/<str:source_id>/trigger',
+         views.TaskSourceTriggerView.as_view(), name='task source trigger'),
+    path(
+        'workspace/<str:workspace_id>/trigger/<str:trigger_id>/task_record/<int:current_page>/<int:page_size>',
+        views.TriggerTaskRecordPageView.as_view(), name='trigger_task_record'),
     path('workspace/<str:workspace_id>/task', views.TriggerTaskView.as_view(), name='task'),
     path('trigger/v1/webhook/<str:trigger_id>', EventTriggerView.as_view(), name='trigger_webhook')
 ]

apps/trigger/serializers/trigger_task.py

@@ -13,7 +13,7 @@
 
 from application.api.application_api import ApplicationCreateAPI
 from common import result
-from trigger.serializers.trigger_task import TriggerTaskQuerySerializer
+from trigger.serializers.trigger_task import TriggerTaskQuerySerializer, TriggerTaskRecordQuerySerializer
 
 
 class TriggerTaskView(APIView):
@@ -30,3 +30,27 @@ class TriggerTaskView(APIView):
     def get(self, request: Request, workspace_id: str, trigger_id: str):
         return result.success(
             TriggerTaskQuerySerializer(data={'workspace_id': workspace_id, 'trigger_id': trigger_id}).list())
+
+
+class TriggerTaskRecordView(APIView):
+    pass
+
+
+class TriggerTaskRecordPageView(APIView):
+    @extend_schema(
+        methods=['GET'],
+        description=_('Get a paginated list of execution records for trigger tasks.'),
+        summary=_('Get a paginated list of execution records for trigger tasks.'),
+        operation_id=_('Get a paginated list of execution records for trigger tasks.'),  # type: ignore
+        parameters=ApplicationCreateAPI.get_parameters(),
+        request=ApplicationCreateAPI.get_request(),
+        responses=ApplicationCreateAPI.get_response(),
+        tags=[_('Trigger')]  # type: ignore
+    )
+    def get(self, request: Request, workspace_id: str, trigger_id: str, current_page: int, page_size: int):
+        return result.success(
+            TriggerTaskRecordQuerySerializer(
+                data={'workspace_id': workspace_id, 'trigger_id': trigger_id,
+                      'state': request.query_params.get('state'),
+                      'name': request.query_params.get('name')})
+            .page(current_page, page_size))