Package com.bytedesk.core.workflow_node

Class WorkflowNodeService

java.lang.Object

com.bytedesk.core.workflow_node.WorkflowNodeService

@Service
public class WorkflowNodeService
extends Object

工作流节点服务类 提供节点的CRUD操作和格式转换功能

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	WorkflowNodeService.WorkflowNodeStats	工作流节点统计信息

Field Summary

Fields

Modifier and Type	Field	Description
private WorkflowNodeRestService	workflowNodeRestService

Constructor Summary

Constructors

Constructor	Description
WorkflowNodeService()

Method Summary

Modifier and Type	Method	Description
WorkflowNodeEntity	cloneNode(WorkflowNodeEntity sourceNode, WorkflowEntity targetWorkflow, String newNodeUid)	复制节点（用于模板克隆）
WorkflowNodeEntity	createNode(WorkflowEntity workflow, WorkflowBaseNode node)	创建工作流节点
List<WorkflowNodeEntity>	createNodes(WorkflowEntity workflow, List<WorkflowBaseNode> nodes)	批量创建节点（用于导入工作流）
void	deleteNode(String uid)	删除节点
void	deleteNodesByWorkflow(WorkflowEntity workflow)	删除工作流的所有节点
List<WorkflowBaseNode>	exportWorkflowNodes(WorkflowEntity workflow)	导出工作流节点数据（用于备份或迁移）
WorkflowNodeEntity	findByUid(String uid)	根据节点UID查找节点
List<WorkflowNodeEntity>	findByWorkflow(WorkflowEntity workflow)	查找工作流的所有节点（按排序字段升序）
List<WorkflowNodeEntity>	findByWorkflowAndType(WorkflowEntity workflow, WorkflowNodeTypeEnum type)	查找工作流的特定类型节点
List<WorkflowNodeEntity>	findEnabledNodesByWorkflow(WorkflowEntity workflow)	查找工作流的启用节点
List<WorkflowNodeEntity>	findEndNodes(WorkflowEntity workflow)	获取工作流的结束节点
List<WorkflowNodeEntity>	findProcessingNodes(WorkflowEntity workflow)	获取处理中的节点
Optional<WorkflowNodeEntity>	findStartNode(WorkflowEntity workflow)	获取工作流的开始节点
WorkflowNodeService.WorkflowNodeStats	getWorkflowNodeStats(WorkflowEntity workflow)	获取工作流节点的统计信息
List<WorkflowNodeEntity>	importWorkflowNodes(WorkflowEntity workflow, List<WorkflowBaseNode> nodes)	导入工作流节点数据（用于恢复或迁移）
void	resetExecutionStatus(WorkflowEntity workflow)	重置节点执行状态（用于重新执行工作流）
WorkflowNodeEntity	toggleNodeEnabled(String uid, boolean enabled)	启用/禁用节点
WorkflowBaseNode	toWorkflowNode(WorkflowNodeEntity entity)	转换节点实体为WorkflowBaseNode
List<WorkflowBaseNode>	toWorkflowNodes(List<WorkflowNodeEntity> entities)	转换节点实体列表为WorkflowBaseNode列表
WorkflowNodeEntity	updateNode(String uid, WorkflowBaseNode node)	更新节点数据
WorkflowNodeEntity	updateNodeStatus(String uid, WorkflowNodeStatusEnum status, String result, String error)	更新节点执行状态

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

workflowNodeRestService

@Autowired
private WorkflowNodeRestService workflowNodeRestService

Constructor Details

WorkflowNodeService

public WorkflowNodeService()

Method Details

createNode

@Transactional
public WorkflowNodeEntity createNode(WorkflowEntity workflow,
 WorkflowBaseNode node)

创建工作流节点

createNodes

@Transactional
public List<WorkflowNodeEntity> createNodes(WorkflowEntity workflow,
 List<WorkflowBaseNode> nodes)

批量创建节点（用于导入工作流）

updateNode

@Transactional
public WorkflowNodeEntity updateNode(String uid,
 WorkflowBaseNode node)

更新节点数据

updateNodeStatus

@Transactional
public WorkflowNodeEntity updateNodeStatus(String uid,
 WorkflowNodeStatusEnum status,
 String result,
 String error)

更新节点执行状态

findByUid

public WorkflowNodeEntity findByUid(String uid)

根据节点UID查找节点

findByWorkflow

public List<WorkflowNodeEntity> findByWorkflow(WorkflowEntity workflow)

查找工作流的所有节点（按排序字段升序）

findByWorkflowAndType

public List<WorkflowNodeEntity> findByWorkflowAndType(WorkflowEntity workflow,
 WorkflowNodeTypeEnum type)

查找工作流的特定类型节点

findEnabledNodesByWorkflow

public List<WorkflowNodeEntity> findEnabledNodesByWorkflow(WorkflowEntity workflow)

查找工作流的启用节点

toWorkflowNode

public WorkflowBaseNode toWorkflowNode(WorkflowNodeEntity entity)

转换节点实体为WorkflowBaseNode

toWorkflowNodes

public List<WorkflowBaseNode> toWorkflowNodes(List<WorkflowNodeEntity> entities)

转换节点实体列表为WorkflowBaseNode列表

findStartNode

public Optional<WorkflowNodeEntity> findStartNode(WorkflowEntity workflow)

获取工作流的开始节点

findEndNodes

public List<WorkflowNodeEntity> findEndNodes(WorkflowEntity workflow)

获取工作流的结束节点

findProcessingNodes

public List<WorkflowNodeEntity> findProcessingNodes(WorkflowEntity workflow)

获取处理中的节点

toggleNodeEnabled

@Transactional
public WorkflowNodeEntity toggleNodeEnabled(String uid,
 boolean enabled)

启用/禁用节点

deleteNode

@Transactional
public void deleteNode(String uid)

删除节点

deleteNodesByWorkflow

@Transactional
public void deleteNodesByWorkflow(WorkflowEntity workflow)

删除工作流的所有节点

cloneNode

@Transactional
public WorkflowNodeEntity cloneNode(WorkflowNodeEntity sourceNode,
 WorkflowEntity targetWorkflow,
 String newNodeUid)

复制节点（用于模板克隆）

resetExecutionStatus

@Transactional
public void resetExecutionStatus(WorkflowEntity workflow)

重置节点执行状态（用于重新执行工作流）

exportWorkflowNodes

public List<WorkflowBaseNode> exportWorkflowNodes(WorkflowEntity workflow)

导出工作流节点数据（用于备份或迁移）

importWorkflowNodes

@Transactional
public List<WorkflowNodeEntity> importWorkflowNodes(WorkflowEntity workflow,
 List<WorkflowBaseNode> nodes)

导入工作流节点数据（用于恢复或迁移）

getWorkflowNodeStats

public WorkflowNodeService.WorkflowNodeStats getWorkflowNodeStats(WorkflowEntity workflow)

获取工作流节点的统计信息