Uses of Class
com.bytedesk.core.workflow.WorkflowEntity
Packages that use WorkflowEntity
Package
Description
-
Uses of WorkflowEntity in com.bytedesk.core.workflow
Fields in com.bytedesk.core.workflow declared as WorkflowEntityMethods in com.bytedesk.core.workflow that return WorkflowEntityModifier and TypeMethodDescriptionprotected WorkflowEntityWorkflowRestService.doSave(WorkflowEntity entity) private WorkflowEntityWorkflowService.executeWorkflowFromNode(WorkflowEntity workflow, String nodeId, WorkflowRequest request, com.alibaba.fastjson2.JSONObject workflowJson, String executionUid, AtomicInteger sequence, List<WorkflowLogEntity> executionLogs) 从指定节点开始执行工作流WorkflowRestService.handleOptimisticLockingFailureException(org.springframework.orm.ObjectOptimisticLockingFailureException e, WorkflowEntity entity) Methods in com.bytedesk.core.workflow that return types with arguments of type WorkflowEntityModifier and TypeMethodDescriptionprotected org.springframework.data.jpa.domain.Specification<WorkflowEntity>WorkflowRestService.createSpecification(WorkflowRequest request) protected org.springframework.data.domain.Page<WorkflowEntity>WorkflowRestService.executePageQuery(org.springframework.data.jpa.domain.Specification<WorkflowEntity> spec, org.springframework.data.domain.Pageable pageable) static org.springframework.data.jpa.domain.Specification<WorkflowEntity>WorkflowSpecification.search(WorkflowRequest request, AuthService authService) Methods in com.bytedesk.core.workflow with parameters of type WorkflowEntityModifier and TypeMethodDescriptionWorkflowRestService.convertToResponse(WorkflowEntity entity) protected WorkflowEntityWorkflowRestService.doSave(WorkflowEntity entity) private WorkflowEntityWorkflowService.executeWorkflowFromNode(WorkflowEntity workflow, String nodeId, WorkflowRequest request, com.alibaba.fastjson2.JSONObject workflowJson, String executionUid, AtomicInteger sequence, List<WorkflowLogEntity> executionLogs) 从指定节点开始执行工作流WorkflowRestService.handleOptimisticLockingFailureException(org.springframework.orm.ObjectOptimisticLockingFailureException e, WorkflowEntity entity) voidWorkflowEntityListener.onPostPersist(WorkflowEntity workflow) voidWorkflowEntityListener.onPostUpdate(WorkflowEntity workflow) private StringWorkflowService.resolveOrgUid(WorkflowEntity workflow, WorkflowRequest request) private StringWorkflowService.resolveUserUid(WorkflowEntity workflow, WorkflowRequest request) private WorkflowLogEntityWorkflowService.startNodeLog(WorkflowEntity workflow, WorkflowBaseNode node, WorkflowRequest request, String executionUid, int sequence) Method parameters in com.bytedesk.core.workflow with type arguments of type WorkflowEntityModifier and TypeMethodDescriptionprotected org.springframework.data.domain.Page<WorkflowEntity>WorkflowRestService.executePageQuery(org.springframework.data.jpa.domain.Specification<WorkflowEntity> spec, org.springframework.data.domain.Pageable pageable) -
Uses of WorkflowEntity in com.bytedesk.core.workflow_edge
Fields in com.bytedesk.core.workflow_edge declared as WorkflowEntityMethods in com.bytedesk.core.workflow_edge with parameters of type WorkflowEntityModifier and TypeMethodDescriptionintWorkflowEdgeRepository.batchDeleteEdgesConnectingNode(WorkflowEntity workflow, String nodeId) 批量删除连接指定节点的边intWorkflowEdgeRepository.batchUpdateEdgeEnabled(WorkflowEntity workflow, List<String> edgeUids, Boolean enabled) 批量启用/禁用边WorkflowEdgeService.cloneEdge(WorkflowEdgeEntity sourceEdge, WorkflowEntity targetWorkflow, String newEdgeUid, String newSourceNodeId, String newTargetNodeId) 复制边(用于模板克隆)WorkflowEdgeRepository.countEdgesByType(WorkflowEntity workflow) 统计工作流中各类型边的数量WorkflowEdgeService.createEdge(WorkflowEntity workflow, WorkflowEdge edge) 创建工作流边WorkflowEdgeService.createEdges(WorkflowEntity workflow, List<WorkflowEdge> edges) 批量创建边(用于导入工作流)voidWorkflowEdgeService.deleteEdgesByWorkflow(WorkflowEntity workflow) 删除工作流的所有边voidWorkflowEdgeService.deleteEdgesConnectingNode(WorkflowEntity workflow, String nodeId) 删除连接指定节点的所有边WorkflowEdgeService.exportWorkflowEdges(WorkflowEntity workflow) 导出工作流边数据(用于备份或迁移)WorkflowEdgeRestService.findByWorkflow(WorkflowEntity workflow) WorkflowEdgeService.findByWorkflow(WorkflowEntity workflow) 查找工作流的所有边WorkflowEdgeRepository.findByWorkflowAndDeletedFalse(WorkflowEntity workflow) 查找工作流的所有边WorkflowEdgeRepository.findByWorkflowAndEnabledFalseAndDeletedFalse(WorkflowEntity workflow) 查找工作流中禁用的边WorkflowEdgeRepository.findByWorkflowAndEnabledTrueAndDeletedFalse(WorkflowEntity workflow) 查找工作流中启用的边WorkflowEdgeRepository.findByWorkflowAndSourceNodeIdAndDeletedFalse(WorkflowEntity workflow, String sourceNodeId) 查找从指定节点出发的边WorkflowEdgeRepository.findByWorkflowAndSourceNodeIdAndSourcePortIdAndDeletedFalse(WorkflowEntity workflow, String sourceNodeId, String sourcePortId) 查找从指定端口出发的边WorkflowEdgeRepository.findByWorkflowAndSourceNodeIdAndTargetNodeIdAndDeletedFalse(WorkflowEntity workflow, String sourceNodeId, String targetNodeId) 查找连接两个特定节点的边WorkflowEdgeRepository.findByWorkflowAndTargetNodeIdAndDeletedFalse(WorkflowEntity workflow, String targetNodeId) 查找到达指定节点的边WorkflowEdgeRepository.findByWorkflowAndTargetNodeIdAndTargetPortIdAndDeletedFalse(WorkflowEntity workflow, String targetNodeId, String targetPortId) 查找到达指定端口的边WorkflowEdgeRestService.findByWorkflowAndType(WorkflowEntity workflow, String type) WorkflowEdgeService.findByWorkflowAndType(WorkflowEntity workflow, WorkflowEdgeTypeEnum type) 查找工作流的特定类型边WorkflowEdgeRepository.findByWorkflowAndTypeAndDeletedFalse(WorkflowEntity workflow, String type) 查找工作流中特定类型的边WorkflowEdgeRepository.findConditionalEdges(WorkflowEntity workflow) 查找有条件表达式的边WorkflowEdgeRestService.findEdgesBetweenNodes(WorkflowEntity workflow, String sourceNodeId, String targetNodeId) WorkflowEdgeService.findEdgesBetweenNodes(WorkflowEntity workflow, String sourceNodeId, String targetNodeId) 查找连接两个特定节点的边WorkflowEdgeRepository.findEdgesByWeightRange(WorkflowEntity workflow, Integer minWeight, Integer maxWeight) 查找指定权重范围的边WorkflowEdgeRepository.findEdgesConnectingNode(WorkflowEntity workflow, String nodeId) 查找连接指定节点的所有边(作为源或目标)WorkflowEdgeRestService.findEdgesConnectingNode(WorkflowEntity workflow, String nodeId) WorkflowEdgeService.findEdgesConnectingNode(WorkflowEntity workflow, String nodeId) 查找连接指定节点的所有边WorkflowEdgeRestService.findEdgesFromNode(WorkflowEntity workflow, String sourceNodeId) WorkflowEdgeService.findEdgesFromNode(WorkflowEntity workflow, String sourceNodeId) 查找从指定节点出发的边WorkflowEdgeRestService.findEdgesToNode(WorkflowEntity workflow, String targetNodeId) WorkflowEdgeService.findEdgesToNode(WorkflowEntity workflow, String targetNodeId) 查找到达指定节点的边WorkflowEdgeRestService.findEnabledEdgesByWorkflow(WorkflowEntity workflow) WorkflowEdgeService.findEnabledEdgesByWorkflow(WorkflowEntity workflow) 查找工作流的启用边WorkflowEdgeRepository.findFrequentlyUsedEdges(WorkflowEntity workflow, Long minCount) 查找执行次数超过指定值的边WorkflowEdgeRepository.findOrphanedEdges(WorkflowEntity workflow) 查找孤立的边(连接的节点不存在) 注意:这个查询需要根据实际的节点表结构进行调整WorkflowEdgeRepository.findRecentlyExecutedEdges(WorkflowEntity workflow, ZonedDateTime since) 查找最近执行过的边WorkflowEdgeRepository.findSelfLoopEdges(WorkflowEntity workflow) 查找环形连接的边 注意:这是一个简化的环检测,复杂的环检测需要在业务层实现WorkflowEdgeService.getWorkflowEdgeStats(WorkflowEntity workflow) 获取工作流边的统计信息WorkflowEdgeService.importWorkflowEdges(WorkflowEntity workflow, List<WorkflowEdge> edges) 导入工作流边数据(用于恢复或迁移)static WorkflowEdgeEntityWorkflowEdgeEntity.of(WorkflowEntity workflow, WorkflowEdge edge) 创建边实体的便捷方法static WorkflowEdgeEntityWorkflowEdgeEntity.of(WorkflowEntity workflow, String edgeUid, String name, String sourceNodeId, String targetNodeId, WorkflowEdgeTypeEnum type) 创建简单边实体static WorkflowEdgeEntityWorkflowEdgeEntity.ofCondition(WorkflowEntity workflow, String edgeUid, String name, String sourceNodeId, String targetNodeId, String condition) 创建条件边实体static WorkflowEdgeEntityWorkflowEdgeConvert.toEntity(WorkflowEdgeRequest request, WorkflowEntity workflow) Convert WorkflowEdgeRequest to WorkflowEdgeEntityprivate voidWorkflowEdgeService.validateEdgeConnection(WorkflowEntity workflow, String sourceNodeId, String targetNodeId) 验证边连接的有效性 -
Uses of WorkflowEntity in com.bytedesk.core.workflow_node
Fields in com.bytedesk.core.workflow_node declared as WorkflowEntityMethods in com.bytedesk.core.workflow_node with parameters of type WorkflowEntityModifier and TypeMethodDescriptionWorkflowNodeService.cloneNode(WorkflowNodeEntity sourceNode, WorkflowEntity targetWorkflow, String newNodeUid) 复制节点(用于模板克隆)longWorkflowNodeRepository.countByWorkflowAndStatus(WorkflowEntity workflow, String status) 统计工作流中特定状态的节点数量longWorkflowNodeRepository.countByWorkflowAndType(WorkflowEntity workflow, String type) 统计工作流中特定类型的节点数量WorkflowNodeService.createNode(WorkflowEntity workflow, WorkflowBaseNode node) 创建工作流节点WorkflowNodeService.createNodes(WorkflowEntity workflow, List<WorkflowBaseNode> nodes) 批量创建节点(用于导入工作流)voidWorkflowNodeUsageExample.createSimpleWorkflowExample(WorkflowEntity workflow) 示例1:创建一个简单的工作流节点并保存到数据库voidWorkflowNodeRepository.deleteByWorkflow(WorkflowEntity workflow) 删除工作流的所有节点voidWorkflowNodeService.deleteNodesByWorkflow(WorkflowEntity workflow) 删除工作流的所有节点voidWorkflowNodeUsageExample.executeWorkflowExample(WorkflowEntity workflow) 示例3:执行工作流节点状态管理voidWorkflowNodeUsageExample.exportImportWorkflowExample(WorkflowEntity sourceWorkflow, WorkflowEntity targetWorkflow) 示例4:导出和导入工作流WorkflowNodeService.exportWorkflowNodes(WorkflowEntity workflow) 导出工作流节点数据(用于备份或迁移)WorkflowNodeService.findByWorkflow(WorkflowEntity workflow) 查找工作流的所有节点(按排序字段升序)WorkflowNodeRepository.findByWorkflowAndEnabledTrueOrderBySortOrderAsc(WorkflowEntity workflow) 根据工作流查找启用的节点,按执行顺序排序WorkflowNodeRestService.findByWorkflowAndEnabledTrueOrderBySortOrderAsc(WorkflowEntity workflow) WorkflowNodeRepository.findByWorkflowAndName(WorkflowEntity workflow, String name) 根据工作流和节点名称查找节点WorkflowNodeRepository.findByWorkflowAndParentNodeUid(WorkflowEntity workflow, String parentNodeUid) 根据工作流和父节点UID查找子节点WorkflowNodeRepository.findByWorkflowAndParentNodeUidIsNull(WorkflowEntity workflow) 查找工作流的根节点(没有父节点的节点)WorkflowNodeRepository.findByWorkflowAndStatus(WorkflowEntity workflow, String status) 根据工作流和状态查找节点WorkflowNodeRestService.findByWorkflowAndStatus(WorkflowEntity workflow, String status) WorkflowNodeRepository.findByWorkflowAndType(WorkflowEntity workflow, String type) 根据工作流和节点类型查找节点WorkflowNodeRestService.findByWorkflowAndType(WorkflowEntity workflow, String type) WorkflowNodeService.findByWorkflowAndType(WorkflowEntity workflow, WorkflowNodeTypeEnum type) 查找工作流的特定类型节点WorkflowNodeRepository.findByWorkflowOrderBySortOrderAsc(WorkflowEntity workflow) 根据工作流查找所有节点,按执行顺序排序WorkflowNodeRestService.findByWorkflowOrderBySortOrderAsc(WorkflowEntity workflow) WorkflowNodeRepository.findCompletedNodes(WorkflowEntity workflow) 查找工作流中已完成的节点WorkflowNodeService.findEnabledNodesByWorkflow(WorkflowEntity workflow) 查找工作流的启用节点WorkflowNodeRepository.findEndNodes(WorkflowEntity workflow) 查找工作流中的结束节点WorkflowNodeService.findEndNodes(WorkflowEntity workflow) 获取工作流的结束节点WorkflowNodeRepository.findFailedNodes(WorkflowEntity workflow) 查找工作流中执行失败的节点WorkflowNodeRepository.findNodesExecutedBetween(WorkflowEntity workflow, ZonedDateTime startTime, ZonedDateTime endTime) 查找指定时间范围内执行的节点WorkflowNodeRepository.findProcessingNodes(WorkflowEntity workflow) 查找工作流中正在执行的节点WorkflowNodeService.findProcessingNodes(WorkflowEntity workflow) 获取处理中的节点WorkflowNodeRepository.findRetryableNodes(WorkflowEntity workflow) 查找需要重试的节点(失败且允许重试的)WorkflowNodeService.findStartNode(WorkflowEntity workflow) 获取工作流的开始节点WorkflowNodeRepository.findStartNodes(WorkflowEntity workflow) 查找工作流中的开始节点WorkflowNodeRepository.getWorkflowExecutionStatistics(WorkflowEntity workflow) 获取工作流执行统计信息WorkflowNodeService.getWorkflowNodeStats(WorkflowEntity workflow) 获取工作流节点的统计信息WorkflowNodeService.importWorkflowNodes(WorkflowEntity workflow, List<WorkflowBaseNode> nodes) 导入工作流节点数据(用于恢复或迁移)voidWorkflowNodeUsageExample.loadAndConvertNodesExample(WorkflowEntity workflow) 示例2:从数据库读取节点并转换为WorkflowBaseNodevoidWorkflowNodeUsageExample.nodeStatisticsExample(WorkflowEntity workflow) 示例5:节点类型统计和查询static WorkflowNodeEntityWorkflowNodeEntity.of(WorkflowEntity workflow, WorkflowBaseNode node) 创建节点实体的便捷方法static WorkflowNodeEntityWorkflowNodeEntity.of(WorkflowEntity workflow, String nodeUid, String name, WorkflowNodeTypeEnum type) 创建简单节点实体voidWorkflowNodeService.resetExecutionStatus(WorkflowEntity workflow) 重置节点执行状态(用于重新执行工作流)static WorkflowNodeEntityWorkflowNodeConvert.toEntity(WorkflowNodeRequest request, WorkflowEntity workflow) Convert WorkflowNodeRequest to WorkflowNodeEntity -
Uses of WorkflowEntity in com.bytedesk.core.workflow.compiler
Fields in com.bytedesk.core.workflow.compiler declared as WorkflowEntity -
Uses of WorkflowEntity in com.bytedesk.core.workflow.event
Fields in com.bytedesk.core.workflow.event declared as WorkflowEntityMethods in com.bytedesk.core.workflow.event that return WorkflowEntityModifier and TypeMethodDescriptionAbstractWorkflowEvent.getWorkflow()private WorkflowEntityAbstractWorkflowEvent.snapshot(WorkflowEntity source) Methods in com.bytedesk.core.workflow.event with parameters of type WorkflowEntityModifier and TypeMethodDescriptionprivate WorkflowEntityAbstractWorkflowEvent.snapshot(WorkflowEntity source) Constructors in com.bytedesk.core.workflow.event with parameters of type WorkflowEntityModifierConstructorDescriptionprotectedAbstractWorkflowEvent(Object source, WorkflowEntity workflow) WorkflowCreateEvent(WorkflowEntity workflow) WorkflowDeleteEvent(WorkflowEntity workflow) WorkflowUpdateEvent(WorkflowEntity workflow) -
Uses of WorkflowEntity in com.bytedesk.service.routing_strategy
Methods in com.bytedesk.service.routing_strategy that return WorkflowEntityModifier and TypeMethodDescriptionprivate WorkflowEntityWorkflowThreadRoutingStrategy.getWorkflowEntity(String workflowUid) 获取工作流实体Methods in com.bytedesk.service.routing_strategy with parameters of type WorkflowEntityModifier and TypeMethodDescriptionprivate ThreadEntityWorkflowThreadRoutingStrategy.getOrCreateWorkflowThread(VisitorRequest request, WorkflowEntity workflowEntity, String topic) 获取或创建工作流会话private MessageProtobufWorkflowThreadRoutingStrategy.getWorkflowContinueMessage(WorkflowEntity workflowEntity, ThreadEntity thread) 获取工作流继续对话消息private StringWorkflowThreadRoutingStrategy.getWorkflowWelcomeMessage(WorkflowEntity workflowEntity) 获取工作流欢迎消息private MessageProtobufWorkflowThreadRoutingStrategy.handleExistingWorkflowThread(WorkflowEntity workflowEntity, ThreadEntity thread) 处理现有的工作流会话private MessageProtobufWorkflowThreadRoutingStrategy.processNewWorkflowThread(VisitorRequest request, ThreadEntity thread, WorkflowEntity workflowEntity) 处理新的工作流会话 -
Uses of WorkflowEntity in com.bytedesk.service.utils
Methods in com.bytedesk.service.utils with parameters of type WorkflowEntityModifier and TypeMethodDescriptionstatic WelcomeContentWelcomeContentUtils.buildWorkflowWelcomeContent(WorkflowEntity workflow) static WelcomeContentWelcomeContentUtils.buildWorkflowWelcomeContent(WorkflowEntity workflow, String tip) static UserProtobufServiceConvertUtils.convertToUserProtobuf(WorkflowEntity workflow) static StringServiceConvertUtils.convertToUserProtobufString(WorkflowEntity workflow) static StringServiceConvertUtils.convertToWorkflowProtobufString(WorkflowEntity workflow) 将工作流实体转换为 UserProtobuf JSON 字符串 只包含基本信息(uid, nickname, avatar)和 schema,不包含 nodes/edgesstatic StringWelcomeContentUtils.resolveWorkflowWelcomeTip(WorkflowEntity workflow) Resolve welcome tip for workflow with fallback to description. -
Uses of WorkflowEntity in com.bytedesk.service.visitor_thread
Methods in com.bytedesk.service.visitor_thread with parameters of type WorkflowEntityModifier and TypeMethodDescriptionprivate StringVisitorThreadService.buildWorkflowExtra(VisitorRequest visitorRequest, WorkflowEntity workflow) 根据请求与工作流实体构建 thread.extra - 工作流暂时不支持 debug 预览VisitorThreadService.createWorkflowThread(VisitorRequest visitorRequest, WorkflowEntity workflow, String topic) VisitorThreadService.reInitWorkflowThreadExtra(VisitorRequest visitorRequest, ThreadEntity thread, WorkflowEntity workflow)