Package com.bytedesk.core.workflow

Class WorkflowService

java.lang.Object

com.bytedesk.core.workflow.WorkflowService

@Service
public class WorkflowService
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
private final org.springframework.transaction.PlatformTransactionManager	transactionManager
private final UidUtils	uidUtils
private final WorkflowLogRepository	workflowLogRepository
private final WorkflowRestService	workflowRestService

Constructor Summary

Constructors

Constructor	Description
WorkflowService()

Method Summary

Modifier and Type	Method	Description
private String	buildStackTrace(Exception e)
private long	elapsed(long startedAt)
WorkflowResponse	execute(WorkflowRequest request)
private WorkflowEntity	executeWorkflowFromNode(WorkflowEntity workflow, String nodeId, WorkflowRequest request, com.alibaba.fastjson2.JSONObject workflowJson, String executionUid, AtomicInteger sequence, List<WorkflowLogEntity> executionLogs)	从指定节点开始执行工作流
private void	failNodeLog(WorkflowLogEntity logEntity, Exception e, long startedAt)
private com.alibaba.fastjson2.JSONObject	findNodeById(com.alibaba.fastjson2.JSONArray nodes, String nodeId)	在节点数组中查找指定ID的节点
private String	findStartNodeId(com.alibaba.fastjson2.JSONObject workflowJson)	查找工作流中的开始节点ID
private void	finishNodeLog(WorkflowLogEntity logEntity, WorkflowNodeExecutionResult result, long startedAt)
private void	persistLogs(List<WorkflowLogEntity> logs)
private String	resolveOrgUid(WorkflowEntity workflow, WorkflowRequest request)
private String	resolveUserUid(WorkflowEntity workflow, WorkflowRequest request)
private String	serialize(Object payload)
private WorkflowLogEntity	startNodeLog(WorkflowEntity workflow, WorkflowBaseNode node, WorkflowRequest request, String executionUid, int sequence)

Methods inherited from class java.lang.Object

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

Field Details

workflowRestService

private final WorkflowRestService workflowRestService

workflowLogRepository

private final WorkflowLogRepository workflowLogRepository

uidUtils

private final UidUtils uidUtils

transactionManager

private final org.springframework.transaction.PlatformTransactionManager transactionManager

Constructor Details

WorkflowService

public WorkflowService()

Method Details

execute

@Transactional
public WorkflowResponse execute(WorkflowRequest request)

findStartNodeId

private String findStartNodeId(com.alibaba.fastjson2.JSONObject workflowJson)

查找工作流中的开始节点ID

Parameters:

content - 工作流JSON内容

Returns:

开始节点的UID

executeWorkflowFromNode

private WorkflowEntity executeWorkflowFromNode(WorkflowEntity workflow,
 String nodeId,
 WorkflowRequest request,
 com.alibaba.fastjson2.JSONObject workflowJson,
 String executionUid,
 AtomicInteger sequence,
 List<WorkflowLogEntity> executionLogs)

从指定节点开始执行工作流

Parameters:

workflow - 工作流实体

nodeId - 当前节点UID

request - 请求参数

findNodeById

private com.alibaba.fastjson2.JSONObject findNodeById(com.alibaba.fastjson2.JSONArray nodes,
 String nodeId)

在节点数组中查找指定ID的节点

startNodeLog

private WorkflowLogEntity startNodeLog(WorkflowEntity workflow,
 WorkflowBaseNode node,
 WorkflowRequest request,
 String executionUid,
 int sequence)

finishNodeLog

private void finishNodeLog(WorkflowLogEntity logEntity,
 WorkflowNodeExecutionResult result,
 long startedAt)

failNodeLog

private void failNodeLog(WorkflowLogEntity logEntity,
 Exception e,
 long startedAt)

elapsed

private long elapsed(long startedAt)

serialize

private String serialize(Object payload)

resolveOrgUid

private String resolveOrgUid(WorkflowEntity workflow,
 WorkflowRequest request)

resolveUserUid

private String resolveUserUid(WorkflowEntity workflow,
 WorkflowRequest request)

buildStackTrace

private String buildStackTrace(Exception e)

persistLogs

private void persistLogs(List<WorkflowLogEntity> logs)