Method one

apps/trigger/serializers/trigger.py:586–635

(self, with_valid=True)

        return True

    def one(self, with_valid=True):
        if with_valid:
            self.is_valid()
        trigger_id = self.data.get('trigger_id')
        workspace_id = self.data.get('workspace_id')
        trigger = QuerySet(Trigger).filter(workspace_id=workspace_id, id=trigger_id).first()

        trigger_tasks = list(QuerySet(TriggerTask).filter(trigger_id=trigger_id))

        application_ids = []
        tool_ids = []
        for task in trigger_tasks:
            if task.source_type == TriggerTaskTypeChoices.APPLICATION:
                application_ids.append(task.source_id)
            elif task.source_type == TriggerTaskTypeChoices.TOOL:
                tool_ids.append(task.source_id)

        trigger_task_list = TriggerTaskModelSerializer(trigger_tasks, many=True).data

        application_task_list = []
        if application_ids:
            applications = Application.objects.filter(workspace_id=workspace_id, id__in=application_ids)
            application_task_list = ApplicationTriggerTaskSerializer(applications, many=True).data
        tool_task_list = []
        if tool_ids:
            tools = Tool.objects.filter(workspace_id=workspace_id, id__in=tool_ids)
            workflows = ToolWorkflow.objects.filter(
                tool_id__in=tools.filter(tool_type='WORKFLOW').values_list('id', flat=True),
                is_publish=True
            )
            workflow_dict = {wf.tool_id: wf.work_flow for wf in workflows}
            tool_task_list = []
            for tool in tools:
                tool_data = {
                    'id': str(tool.id),
                    'name': tool.name,
                    'input_field_list': tool.input_field_list,
                    'icon': tool.icon,
                    'tool_type': tool.tool_type
                }
                # 如果是工作流类型，添加 work_flow 字段
                if tool.tool_type == 'WORKFLOW':
                    tool_data['work_flow'] = workflow_dict.get(tool.id)
                tool_task_list.append(tool_data)
        return {
            **TriggerModelSerializer(trigger).data,
            'trigger_task': trigger_task_list,
            'application_task_list': application_task_list,
            'tool_task_list': tool_task_list,
        }


class TriggerQuerySerializer(serializers.Serializer):