【正文】 處理。(org\activiti\db\mapping\entity\ insertTask)在act_hi_taskinst表中插入用戶任務(wù)執(zhí)行的情況(org\activiti\db\mapping\entity\ insertHistoricTaskInstance) 查詢待辦任務(wù)并提交任務(wù)/** *查詢待辦任務(wù)并提交任務(wù) */ @Test public void queryTaskAndComplete(){ String assignee=張三。 TaskService taskService = ()。 ListTask taskList=() .taskAssignee(assignee) .list()。 if(taskList!=null){ for(Task task:taskList){ (代辦任務(wù)ID:+())。 (代辦任務(wù)名稱:+())。 (任務(wù)創(chuàng)建時間:+())。 (所屬的流程ID:+())。 (執(zhí)行對象ID:+())。 (流程定義ID:+())。 MapString,Object variables = new HashMapString,Object()。 (申請理由, 理由123)。 ((), variables)。 } } }其中taskId對應(yīng)act_ru_task表的主鍵ID，因為當(dāng)前待辦任務(wù)為第一個節(jié)點提交申請，當(dāng)執(zhí)行完這個待辦后下一條待辦數(shù)據(jù)將會流轉(zhuǎn)到審批【部門經(jīng)理】那，然后以此類推可以將部門經(jīng)理和總經(jīng)理的待辦任務(wù)全部查詢和執(zhí)行完成。 查詢和刪除流程定義/** * 查詢流程定義 */ @Test public void queryProcessDefinition(){ RepositoryService repositoryService=()。 ListProcessDefinition list=() .orderByProcessDefinitionVersion()// .deploymentId(deploymentId)// .processDefinitionId(processDefinitionId)// .processDefinitionKey(processDefinitionKey)// .processDefinitionCategoryLike(processDefinitionCategoryLike) .asc()// .singleResult() .list()。 if(list!=null){ for(ProcessDefinition def:list){ (流程定義ID:+())。 (流程定義名稱:+())。 (流程定義key:+())。 (流程定義版本:+())。 (資源名稱bpmn文件:+())。 (資源名稱png文件:+())。 (部署ID:+())。 } } }/** * 刪除流程定義 */ @Test public void delProcessDefinition(){ RepositoryService repositoryService=()。 (1,true)。//刪除流程定義，級聯(lián)刪除該定義的啟動流程的所有信息 }5 源代碼調(diào)試數(shù)據(jù)庫操作的關(guān)鍵類：DbSqlSession定時調(diào)度器：DefaultJobExecutorpublic void executeJobs(ListString jobIds) { try { (new ExecuteJobsRunnable(this, jobIds))。 } catch (RejectedExecutionException e) { (this, jobIds)。 } }ExecuteJobsRunnablepublic void run() { if (jobIds != null) { handleMultipleJobs()。 } if (job != null) { handleSingleJob()。 } }protected void handleMultipleJobs() { final MultipleJobsExecutorContext jobExecutorContext = new MultipleJobsExecutorContext()。 final ListString currentProcessorJobQueue = ()。 final CommandExecutor mandExecutor = ()。 (jobIds)。 (jobExecutorContext)。 try { while (!()) { String currentJobId = (0)。 try { (new ExecuteJobsCmd(currentJobId))。 } catch (Throwable e) { (exception during job execution: {}, (), e)。 } finally { (currentJobId)。 } } } finally { ()。 } }MessageEntitypublic void execute(CommandContext mandContext) { ExecutionEntity execution = null。 if (executionId != null) { execution = ().findExecutionById(executionId)。 } MapString, JobHandler jobHandlers = ().getJobHandlers()。 JobHandler jobHandler = (jobHandlerType)。 (this, jobHandlerConfiguration, execution, mandContext)。 } timerintermediatetransition=event=@1717334, timertransition=, suspendprocessdefinition=, asynccontinuation= timerstartevent=, activateprocessdefinition=AsyncContinuationJobHandlerpublic void execute(JobEntity job, String configuration, ExecutionEntity execution, CommandContext mandContext) { // ATM only AtomicOperationTransitionCreateScope can be performed asynchronously AtomicOperation atomicOperation = 。 (atomicOperation, execution)。 }流程中的節(jié)點生命周期處理類AtomicOperationTransitionCreateScope –AtomicOperationTransitionNotifyListenerStartAtomicOperationActivityExecute AtomicOperationTransitionNotifyListenerEnd AtomicOperationTransitionDestroyScopeAtomicOperationTransitionNotifyListenerTake AtomicOperationTransitionCreateScope 依次循環(huán)并行節(jié)點處理類：ParallelGatewayActivityBehaviorpublic void execute(ActivityExecution execution) throws Exception { // Join PvmActivity activity = ()。 ListPvmTransition outgoingTransitions = ().getOutgoingTransitions()。 ()。 lockConcurrentRoot(execution)。 ListActivityExecution joinedExecutions = (activity)。 int nbrOfExecutionsToJoin = ().getIningTransitions().size()。 int nbrOfExecutionsJoined = ()。 ().getHistoryManager().recordActivityEnd((ExecutionEntity) execution)。 if (nbrOfExecutionsJoined==nbrOfExecutionsToJoin) { // Fork if(()) { (parallel gateway 39。{}39。 activates: {} of {} joined, (), nbrOfExecutionsJoined, nbrOfExecutionsToJoin)。 } (outgoingTransitions, joinedExecutions)。 } else if (()){ (parallel gateway 39。{}39。 does not activate: {} of {} joined, (), nbrOfExecutionsJoined, nbrOfExecutionsToJoin)。 } }