Package com.bytedesk.core.workflow_node

Class WorkflowNodeEntity

java.lang.Object
com.bytedesk.core.base.BaseEntity
com.bytedesk.core.workflow_node.WorkflowNodeEntity
All Implemented Interfaces:
Serializable
@Entity public class WorkflowNodeEntity extends BaseEntity
WorkflowNode entity for workflow node storage and management Stores workflow node definitions compatible with the node framework Database Table: bytedesk_core_workflow_node Purpose: Stores workflow node definitions, execution states, and configuration
See Also:

  • Field Details

    • serialVersionUID

      private static final long serialVersionUID
      See Also:

    • name

      private String name
      节点名称

    • description

      private String description
      节点描述

    • type

      private String type
      节点类型 (START, END, CONDITION, LOOP, LLM, TEXT, COMMENT, GROUP)

    • status

      private String status
      节点状态 (IDLE, RUNNING, SUCCESS, FAILED, WAITING)

    • sortOrder

      private Integer sortOrder
      节点在工作流中的执行顺序

    • parentNodeUid

      private String parentNodeUid
      父节点UID（用于组织节点层次结构）

    • nodeData

      private String nodeData
      节点完整配置数据（JSON格式存储WorkflowBaseNode及其子类的完整数据） 包含：data(NodeData), meta(WorkflowNodeMeta), 特定节点类型字段等

    • executionResult

      private String executionResult
      节点执行结果数据（JSON格式）

    • executionStartTime

      private ZonedDateTime executionStartTime
      节点执行开始时间

    • executionEndTime

      private ZonedDateTime executionEndTime
      节点执行结束时间

    • errorMessage

      private String errorMessage
      节点执行错误信息

    • enabled

      private Boolean enabled
      是否启用该节点

    • workflow

      private WorkflowEntity workflow
      关联的工作流

  • Constructor Details

    • WorkflowNodeEntity

      public WorkflowNodeEntity()

  • Method Details

    • toWorkflowNode

      public WorkflowBaseNode toWorkflowNode()
      从JSON数据转换为WorkflowBaseNode实例

    • fromWorkflowNode

      public void fromWorkflowNode(WorkflowBaseNode node)
      从WorkflowBaseNode实例更新实体数据

    • updateExecutionStatus

      public void updateExecutionStatus(WorkflowNodeStatusEnum status, String result, String error)
      更新节点执行状态

    • getNodeTypeEnum

      public WorkflowNodeTypeEnum getNodeTypeEnum()
      获取节点类型枚举

    • getNodeStatusEnum

      public WorkflowNodeStatusEnum getNodeStatusEnum()
      获取节点状态枚举

    • isContainerNode

      public boolean isContainerNode()
      是否为容器节点（GROUP, LOOP）

    • isControlNode

      public boolean isControlNode()
      是否为控制节点（START, END, CONDITION）

    • isProcessingNode

      public boolean isProcessingNode()
      是否为处理节点（LLM, TEXT）

    • getExecutionStartTimeString

      public String getExecutionStartTimeString()
      获取执行开始时间的字符串格式

    • getExecutionEndTimeString

      public String getExecutionEndTimeString()
      获取执行结束时间的字符串格式

    • getExecutionDurationMillis

      public Long getExecutionDurationMillis()
      获取执行耗时（毫秒）

    • getExecutionDurationSeconds

      public Double getExecutionDurationSeconds()
      获取执行耗时（秒）

    • parseNodeData

      private WorkflowBaseNode parseNodeData(String jsonData, String nodeType)
      根据节点类型解析JSON数据

    • of

      public static WorkflowNodeEntity of(WorkflowEntity workflow, WorkflowBaseNode node)
      创建节点实体的便捷方法

    • of

      public static WorkflowNodeEntity of(WorkflowEntity workflow, String nodeUid, String name, WorkflowNodeTypeEnum type)
      创建简单节点实体