Package com.bytedesk.core.workflow_edge

Class WorkflowEdgeService

java.lang.Object

com.bytedesk.core.workflow_edge.WorkflowEdgeService

@Service
public class WorkflowEdgeService
extends Object

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

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	WorkflowEdgeService.WorkflowEdgeStats	工作流边统计信息

Field Summary

Fields

Modifier and Type	Field	Description
private WorkflowEdgeRestService	workflowEdgeRestService

Constructor Summary

Constructors

Constructor	Description
WorkflowEdgeService()

Method Summary

Modifier and Type	Method	Description
WorkflowEdgeEntity	cloneEdge(WorkflowEdgeEntity sourceEdge, WorkflowEntity targetWorkflow, String newEdgeUid, String newSourceNodeId, String newTargetNodeId)	复制边（用于模板克隆）
WorkflowEdgeEntity	createEdge(WorkflowEntity workflow, WorkflowEdge edge)	创建工作流边
List<WorkflowEdgeEntity>	createEdges(WorkflowEntity workflow, List<WorkflowEdge> edges)	批量创建边（用于导入工作流）
void	deleteEdge(String uid)	删除边
void	deleteEdgesByWorkflow(WorkflowEntity workflow)	删除工作流的所有边
void	deleteEdgesConnectingNode(WorkflowEntity workflow, String nodeId)	删除连接指定节点的所有边
List<WorkflowEdge>	exportWorkflowEdges(WorkflowEntity workflow)	导出工作流边数据（用于备份或迁移）
WorkflowEdgeEntity	findByUid(String uid)	根据边UID查找边
List<WorkflowEdgeEntity>	findByWorkflow(WorkflowEntity workflow)	查找工作流的所有边
List<WorkflowEdgeEntity>	findByWorkflowAndType(WorkflowEntity workflow, WorkflowEdgeTypeEnum type)	查找工作流的特定类型边
List<WorkflowEdgeEntity>	findEdgesBetweenNodes(WorkflowEntity workflow, String sourceNodeId, String targetNodeId)	查找连接两个特定节点的边
List<WorkflowEdgeEntity>	findEdgesConnectingNode(WorkflowEntity workflow, String nodeId)	查找连接指定节点的所有边
List<WorkflowEdgeEntity>	findEdgesFromNode(WorkflowEntity workflow, String sourceNodeId)	查找从指定节点出发的边
List<WorkflowEdgeEntity>	findEdgesToNode(WorkflowEntity workflow, String targetNodeId)	查找到达指定节点的边
List<WorkflowEdgeEntity>	findEnabledEdgesByWorkflow(WorkflowEntity workflow)	查找工作流的启用边
WorkflowEdgeService.WorkflowEdgeStats	getWorkflowEdgeStats(WorkflowEntity workflow)	获取工作流边的统计信息
List<WorkflowEdgeEntity>	importWorkflowEdges(WorkflowEntity workflow, List<WorkflowEdge> edges)	导入工作流边数据（用于恢复或迁移）
WorkflowEdgeEntity	toggleEdgeEnabled(String uid, boolean enabled)	启用/禁用边
WorkflowEdge	toWorkflowEdge(WorkflowEdgeEntity entity)	转换边实体为WorkflowEdge
List<WorkflowEdge>	toWorkflowEdges(List<WorkflowEdgeEntity> entities)	转换边实体列表为WorkflowEdge列表
WorkflowEdgeEntity	updateEdge(String uid, WorkflowEdge edge)	更新边数据
WorkflowEdgeEntity	updateExecutionStats(String uid, String result)	更新边执行统计
private void	validateEdgeConnection(WorkflowEntity workflow, String sourceNodeId, String targetNodeId)	验证边连接的有效性

Methods inherited from class java.lang.Object

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

Field Details

workflowEdgeRestService

@Autowired
private WorkflowEdgeRestService workflowEdgeRestService

Constructor Details

WorkflowEdgeService

public WorkflowEdgeService()

Method Details

createEdge

@Transactional
public WorkflowEdgeEntity createEdge(WorkflowEntity workflow,
 WorkflowEdge edge)

创建工作流边

createEdges

@Transactional
public List<WorkflowEdgeEntity> createEdges(WorkflowEntity workflow,
 List<WorkflowEdge> edges)

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

updateEdge

@Transactional
public WorkflowEdgeEntity updateEdge(String uid,
 WorkflowEdge edge)

更新边数据

updateExecutionStats

@Transactional
public WorkflowEdgeEntity updateExecutionStats(String uid,
 String result)

更新边执行统计

findByUid

public WorkflowEdgeEntity findByUid(String uid)

根据边UID查找边

findByWorkflow

public List<WorkflowEdgeEntity> findByWorkflow(WorkflowEntity workflow)

查找工作流的所有边

findByWorkflowAndType

public List<WorkflowEdgeEntity> findByWorkflowAndType(WorkflowEntity workflow,
 WorkflowEdgeTypeEnum type)

查找工作流的特定类型边

findEnabledEdgesByWorkflow

public List<WorkflowEdgeEntity> findEnabledEdgesByWorkflow(WorkflowEntity workflow)

查找工作流的启用边

findEdgesConnectingNode

public List<WorkflowEdgeEntity> findEdgesConnectingNode(WorkflowEntity workflow,
 String nodeId)

查找连接指定节点的所有边

findEdgesFromNode

public List<WorkflowEdgeEntity> findEdgesFromNode(WorkflowEntity workflow,
 String sourceNodeId)

查找从指定节点出发的边

findEdgesToNode

public List<WorkflowEdgeEntity> findEdgesToNode(WorkflowEntity workflow,
 String targetNodeId)

查找到达指定节点的边

findEdgesBetweenNodes

public List<WorkflowEdgeEntity> findEdgesBetweenNodes(WorkflowEntity workflow,
 String sourceNodeId,
 String targetNodeId)

查找连接两个特定节点的边

toWorkflowEdge

public WorkflowEdge toWorkflowEdge(WorkflowEdgeEntity entity)

转换边实体为WorkflowEdge

toWorkflowEdges

public List<WorkflowEdge> toWorkflowEdges(List<WorkflowEdgeEntity> entities)

转换边实体列表为WorkflowEdge列表

toggleEdgeEnabled

@Transactional
public WorkflowEdgeEntity toggleEdgeEnabled(String uid,
 boolean enabled)

启用/禁用边

deleteEdge

@Transactional
public void deleteEdge(String uid)

删除边

deleteEdgesConnectingNode

@Transactional
public void deleteEdgesConnectingNode(WorkflowEntity workflow,
 String nodeId)

删除连接指定节点的所有边

deleteEdgesByWorkflow

@Transactional
public void deleteEdgesByWorkflow(WorkflowEntity workflow)

删除工作流的所有边

cloneEdge

@Transactional
public WorkflowEdgeEntity cloneEdge(WorkflowEdgeEntity sourceEdge,
 WorkflowEntity targetWorkflow,
 String newEdgeUid,
 String newSourceNodeId,
 String newTargetNodeId)

复制边（用于模板克隆）

exportWorkflowEdges

public List<WorkflowEdge> exportWorkflowEdges(WorkflowEntity workflow)

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

importWorkflowEdges

@Transactional
public List<WorkflowEdgeEntity> importWorkflowEdges(WorkflowEntity workflow,
 List<WorkflowEdge> edges)

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

getWorkflowEdgeStats

public WorkflowEdgeService.WorkflowEdgeStats getWorkflowEdgeStats(WorkflowEntity workflow)

获取工作流边的统计信息

validateEdgeConnection

private void validateEdgeConnection(WorkflowEntity workflow,
 String sourceNodeId,
 String targetNodeId)

验证边连接的有效性