文章目錄

• Activiti的使用技巧
• • 1、環境的搭建：activiti-spring 7.0.0+連接池+mysql
  • • 1.1 依賴如下：
    • 1.2 連接池和數據庫配置：
    • 1.3 activiti的配置，通過config文件注入的方式：
  • 2、部署
  • • 2.1 自動部署
    • 2.2 手動部署
    • 2.3 表單介紹
  • 3、創建流程表
  • 4、開始流程
  • 5、處理任務
  • • 5.1 獲取任務
    • 5.2 處理任務
  • 6、監聽器設置:
  • • 6.1 class方式：填寫的是class全路徑，具體的方法通過實現ExecutionListener,TaskListener判斷實現
    • 6.2 expression方式：填寫的是具體的方法,也就是class.method()
    • 6.3 delegateExpression方式：處理的是eventlistener,是處理對事件的監聽，delegateExpression的意思是：class和events描述，delegate的意思是表達的方式是不是直接告訴Expression，有通過activiti。
  • 7、變量的設置：
  • 8、流程的操作
  • • 8.1 委派任務
    • 8.2 根據指定人查詢任務
    • 8.3 根據任務擁有者查詢任務
    • 8.4 委派人完成任務
    • 8.5 將任務委派他人完成
    • 8.5 掛起流程實例
    • 8.6 刪除流程實例
    • 8.7激活掛起的流程實例
    • 8.8 激活、掛起流程定義

Activiti的使用技巧

1、環境的搭建：activiti-spring 7.0.0+連接池+mysql

1.1 依賴如下：

<properties><java.version>1.11</java.version></properties><dependencies><dependency><groupId>mysql</groupId><artifactId>mysql-connector-java</artifactId><scope>runtime</scope></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-test</artifactId><scope>test</scope></dependency><dependency><groupId>org.activiti</groupId><artifactId>activiti-spring</artifactId><version>7.0.0.GA</version></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency><dependency><groupId>com.alibaba</groupId><artifactId>druid-spring-boot-starter</artifactId><version>1.1.9</version></dependency><dependency><groupId>org.projectlombok</groupId><artifactId>lombok</artifactId><version>1.18.6</version></dependency></dependencies>

1.2 連接池和數據庫配置：

注意配置nullCatalogMeansCurrent=true，否則自動部署時，表無法創建成功。

spring:#業務核心數據源datasource:url: jdbc:mysql://localhost:3306/d201903290931?characterEncoding=utf8&useSSL=true&serverTimezone=GMT%2B8&nullCatalogMeansCurrent=trueusername: rootpassword: 880808driver-class-name: com.mysql.jdbc.Drivertype: com.alibaba.druid.pool.DruidDataSource#druid配置druid:#initialSizeinitialSize: 10#minPoolSizeminIdle: 10#maxPoolSizemaxActive: 100poolPreparedStatements: truemaxPoolPreparedStatementPerConnectionSize: 100#是否自動提交事務，如果應用中通過Spring或其他框架顯示控制事務提交則可以設置為false，否則設置為truedefaultAutoCommit: false#配置獲取連接等待超時的時間maxWait: 10000#配置間隔多久才進行一次檢測,檢測需要關閉的空閑連接,單位毫秒timeBetweenEvictionRunsMillis: 60000#配置一個連接在池中最小生存的時間,單位毫秒minEvictableIdleTimeMillis: 300000#連接檢測屬性配置testWhileIdle: truevalidationQuery: SELECT 'x' FROM DUALvalidationQueryTimeout: 5000connectionProperties: oracle.net.CONNECT_TIMEOUT=3000;oracle.net.READ_TIMEOUT=5000removeAbandoned: trueremoveAbandonedTimeoutMillis: 300000testOnBorrow: false

1.3 activiti的配置，通過config文件注入的方式：

關注2點：自動部署的文件路徑，監聽器通過bean注入。

@Configuration public class ActivitiConfig {@Autowiredprivate MyExecutionListener myExecutionListener;@Autowiredprivate MyTaskListener1 myTaskListener1;@Beanpublic ProcessEngine processEngine(DataSourceTransactionManager transactionManager, DataSource dataSource) throws IOException {SpringProcessEngineConfiguration configuration = new SpringProcessEngineConfiguration();//自動部署已有的流程文件Resource[] resources = new PathMatchingResourcePatternResolver().getResources(ResourceLoader.CLASSPATH_URL_PREFIX + "/processes/*.xml");configuration.setTransactionManager(transactionManager);configuration.setDataSource(dataSource);configuration.setDatabaseSchemaUpdate("true");configuration.setAsyncExecutorActivate(true);configuration.setHistoryLevel(HistoryLevel.FULL);configuration.setDeploymentResources(resources);Map<Object, Object> beans = new HashMap<>(10);beans.put("myExecutionListener", myExecutionListener);beans.put("myTaskListener1", myTaskListener1); /* beans.put("surveyProcessListener", surveyProcessListener);beans.put("lossVerificationProcessListener", lossVerificationProcessListener);beans.put("investigateProcessListener", investigateProcessListener);*/configuration.setBeans(beans);//configuration.setDbIdentityUsed(false);return configuration.buildProcessEngine();}@Beanpublic RepositoryService repositoryService(ProcessEngine processEngine) {return processEngine.getRepositoryService();}@Beanpublic RuntimeService runtimeService(ProcessEngine processEngine) {return processEngine.getRuntimeService();}@Beanpublic TaskService taskService(ProcessEngine processEngine) {return processEngine.getTaskService();}@Beanpublic HistoryService historyService(ProcessEngine processEngine) {return processEngine.getHistoryService();}@Beanpublic ManagementService managementService(ProcessEngine processEngine) {return processEngine.getManagementService();}//@Bean//public IdentityService identityService(ProcessEngine processEngine) { // return processEngine.getIdentityService(); // }}

當無法注入的時候，可以使用通用類，直接注入：

import org.springframework.beans.BeansException; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.context.ApplicationContext; import org.springframework.context.ApplicationContextAware; import org.springframework.stereotype.Component;/*** @author xmaxing* @description* @date 2019-03-29 16:45*/ @Component public class SpringContextUtil implements ApplicationContextAware {// Spring應用上下文環境@Autowiredprivate static ApplicationContext applicationContext;/*** 實現ApplicationContextAware接口的回調方法，設置上下文環境** @param applicationContext*/@Overridepublic void setApplicationContext(ApplicationContext applicationContext) {SpringContextUtil.applicationContext = applicationContext;}/*** @return ApplicationContext*/public static ApplicationContext getApplicationContext() {return applicationContext;}/*** 獲取對象** @param name* @return Object* @throws BeansException*/public static Object getBean(String name) throws BeansException {return applicationContext.getBean(name);}}

2、部署

2.1 自動部署

springboot會自動部署，就可以直接開始流程處理了。

2.2 手動部署

@Overridepublic boolean devlopActiviti(String folderPath, HashMap<String, String> map) {Deployment deploy = repositoryService.createDeployment()// 創建一個部署構建器.addClasspathResource(folderPath + File.separator + map.get("id") + ".bpmn")// 從類路徑一次只能添加一個文件.addClasspathResource(folderPath + File.separator + map.get("id") + ".png")// 流程圖片.name(map.get("name")).category(map.get("category")).deploy();LOGGER.info("流程名稱【 {}】", deploy.getName());LOGGER.info("流程id【{}】", deploy.getId());LOGGER.info("流程類別【{}】", deploy.getCategory());return true;}@Overridepublic boolean deployActivitiByZip(String folderPath, HashMap<String, String> map) {InputStream in = this.getClass().getClassLoader().getResourceAsStream("folderPath" + File.separator + map.get("id") + ".bpmn");ZipInputStream zipInputStream = new ZipInputStream(in);Deployment deploy = repositoryService.createDeployment()// 創建一個部署構建器.addZipInputStream(zipInputStream).name(map.get("name")).category(map.get("category")).deploy();LOGGER.info("流程名稱【 {}】", deploy.getName());LOGGER.info("流程id【{}】", deploy.getId());LOGGER.info("流程類別【{}】", deploy.getCategory());return true;}

測試

@Testpublic void deplomentActiviti() {String folderPath = "study/activiti/diagrams/leaveBill";HashMap<String, String> map = new HashMap<>();map.put("name", "請假流程");// 名稱map.put("id", "leaveBill");// idmap.put("category", "辦公流程");// 類別

2.3 表單介紹

ACT_RE_DEPLOYMENT（部署對象表） ACT_RE_PROCDEF（流程定義表） ACT_GE_BYTEARRAY（資源文件表） ACT_GE_PROPERTY（主鍵生成表）ACT_RE_*: 'RE'表示repository。 這個前綴的表包含了流程定義和流程靜態資源 （圖片，規則，等等）。 ACT_RU_*: 'RU'表示runtime。 這些運行時的表，包含流程實例，任務，變量，異步任務，等運行中的數據。 Activiti只在流程實例執行過程中保存這些數據， 在流程結束時就會刪除這些記錄。 這樣運行時表可以一直很小速度很快。 ACT_ID_*: 'ID'表示identity。 這些表包含身份信息，比如用戶，組等等。 ACT_HI_*: 'HI'表示history。 這些表包含歷史數據，比如歷史流程實例， 變量，任務等等。 ACT_GE_*: 'GE'表示general。通用數據， 用于不同場景下，如存放資源文件。資源庫流程規則表1) act_re_deployment 部署信息表2) act_re_model 流程設計模型部署表3) act_re_procdef 流程定義數據表運行時數據庫表1) act_ru_execution運行時流程執行實例表2) act_ru_identitylink運行時流程人員表，主要存儲任務節點與參與者的相關信息3) act_ru_task運行時任務節點表4) act_ru_variable運行時流程變量數據表歷史數據庫表1) act_hi_actinst 歷史節點表2) act_hi_attachment歷史附件表3) act_hi_comment歷史意見表4) act_hi_identitylink歷史流程人員表5) act_hi_detail歷史詳情表，提供歷史變量的查詢6) act_hi_procinst歷史流程實例表7) act_hi_taskinst歷史任務實例表8) act_hi_varinst歷史變量表組織機構表1) act_id_group用戶組信息表2) act_id_info用戶擴展信息表3) act_id_membership用戶與用戶組對應信息表4) act_id_user用戶信息表這四張表很常見，基本的組織機構管理，關于用戶認證方面建議還是自己開發一套，組件自帶的功能太簡單，使用中有很多需求難以滿足通用數據表1) act_ge_bytearray二進制數據表2) act_ge_property屬性數據表存儲整個流程引擎級別的數據,初始化表結構時，會默認插入三條記錄。

3、創建流程表

startevent–>usertask1–>usertask2–>endevent

<process id="listenerTask1" name="任務監聽器流程" isExecutable="true"><startEvent id="startevent" name="Start"><extensionElements><activiti:executionListener event="start" expression="${myExecutionListener.processStart(execution)}"></activiti:executionListener></extensionElements></startEvent><endEvent id="endevent1" name="End"></endEvent><userTask id="usertask1" name="User Task" activiti:assignee="#{createLoginName}"><extensionElements><activiti:taskListener event="complete" expression="${myTaskListener1.taskComplete(task)}"><activiti:field name="arg"><activiti:string><![CDATA[gengzhn]]></activiti:string></activiti:field></activiti:taskListener></extensionElements></userTask><sequenceFlow id="flow1" sourceRef="startevent" targetRef="usertask1"></sequenceFlow><sequenceFlow id="flow2" sourceRef="usertask1" targetRef="endevent1"></sequenceFlow><userTask id="usertask2" name="User Task" activiti:assignee="#{checkBywhom}"></userTask><sequenceFlow id="flow3" sourceRef="usertask1" targetRef="usertask2"></sequenceFlow><endEvent id="endevent2" name="End"></endEvent><sequenceFlow id="flow4" sourceRef="usertask2" targetRef="endevent2"></sequenceFlow></process>

4、開始流程

@Overridepublic boolean startActiviti(String processDefinitionKey, HashMap<String, Object> map) {// 取得流程實例ProcessInstance processInstance = runtimeService.startProcessInstanceByKey(processDefinitionKey, map);LOGGER.info("流程(流程執行對象實例)id【{}】", processInstance.getId());// execution對象LOGGER.info("流程實例id:【{}】", processInstance.getProcessInstanceId());// processInstance對象LOGGER.info("流程定義id【{}】", processInstance.getProcessDefinitionId());// 默認為最新的idreturn true;} @Testpublic void startActiviti() {String processDefinitionKey = "listenerTask1";// 設置變量HashMap<String, Object> map = new HashMap<>();map.put("createLoginName", "31smart.geng.123");activitiService.startActiviti(processDefinitionKey, map);}

注意：流程實例ID（process的ID），流程定義ID(process的定義描述ID)，執行對象ID(process的具體task的ID)，processDefinitionKey為流程的定義的名稱。

2019-03-31 22:27:18.776 INFO 1528 --- [ main] c.e.d.service.Impl.ActivitiServiceImpl : 流程(流程執行對象實例)id【175001】 2019-03-31 22:27:18.776 INFO 1528 --- [ main] c.e.d.service.Impl.ActivitiServiceImpl : 流程實例id:【175001】 2019-03-31 22:27:18.777 INFO 1528 --- [ main] c.e.d.service.Impl.ActivitiServiceImpl : 流程定義id【listenerTask1:10:160009】

5、處理任務

5.1 獲取任務

@Overridepublic boolean getTaskByLoginName(String processDefinitionKey, String loginName) {TaskQuery taskQuery = taskService.createTaskQuery();List<Task> list = taskQuery.processDefinitionKey(processDefinitionKey).taskAssignee(loginName).list();for (Task task : list) {LOGGER.info("任務處理人【{}】", task.getAssignee());LOGGER.info("流程名稱【{}】", task.getName());LOGGER.info("任務id【{}】", task.getId());LOGGER.info("流程定義id【{}】", task.getProcessDefinitionId());LOGGER.info("執行對象id【{}】", task.getExecutionId());}return true;} @Overridepublic List<Task> getTaskByDeploymentId(String deploymentId, String processDefinitionKey, String executionId,String loginName) {List<Task> list = taskService.createTaskQuery().processDefinitionKey(processDefinitionKey).deploymentId(deploymentId).taskAssignee(loginName).executionId(executionId).list();// 獲取當前人的return list;}

5.2 處理任務

@Overridepublic boolean startActivitiAndFinsh(String processDefinitionKey, HashMap<String, Object> map) {// 取得流程實例ProcessInstance processInstance = runtimeService.startProcessInstanceByKey(processDefinitionKey, map);LOGGER.info("流程(流程執行對象實例)id【{}】", processInstance.getId());// execution對象LOGGER.info("流程實例id:【{}】", processInstance.getProcessInstanceId());// processInstance對象LOGGER.info("流程定義id【{}】", processInstance.getProcessDefinitionId());// 默認為最新的idLOGGER.info("流程實例id【{}】", processInstance.getSuperExecutionId());List<Task> tasks = this.getTaskByDeploymentId(processInstance.getDeploymentId(), processDefinitionKey,processInstance.getId(), (String) map.get("createLoginName"));for (Task task : tasks) {this.finshTask(task.getId());}return true;} @Testpublic void finshTask() {String taskId = "137507";// 設置變量HashMap<String, Object> map = new HashMap<>();map.put("checkBywhom", "3001smart.geng.123");activitiService.finshTask(taskId,map); // activitiService.finshTask(taskId);}

6、監聽器設置:

6.1 class方式：填寫的是class全路徑，具體的方法通過實現ExecutionListener,TaskListener判斷實現

<process id="listenerTask" name="任務監聽器流程" isExecutable="true"><startEvent id="startevent" name="Start"><extensionElements><activiti:executionListener event="start" class="com.example.demo13.service.ActivitiListener"></activiti:executionListener></extensionElements></startEvent><endEvent id="endevent1" name="End"></endEvent><userTask id="usertask1" name="User Task" activiti:assignee="#{createLoginName}"><extensionElements><activiti:taskListener event="complete" class="com.example.demo13.service.MyTaskListener"><activiti:field name="arg"><activiti:string><![CDATA[gengzhn]]></activiti:string></activiti:field></activiti:taskListener></extensionElements> public class ActivitiListener implements ExecutionListener,TaskListener {private static final Logger LOGGER = LoggerFactory.getLogger(ActivitiServiceImpl.class);private static final long serialVersionUID = 6200534335483960408L;private Expression arg;public Expression getArg() {return arg;}public void setArg(Expression arg) {this.arg = arg;}@Overridepublic void notify(DelegateExecution execution) {String eventName = execution.getEventName();// startif ("start".equals(eventName)) {LOGGER.info("start=========");HashMap<String, Object> map = new HashMap<>();} else if ("end".equals(eventName)) {LOGGER.info("end=========");} else if ("take".equals(eventName)) {LOGGER.info("take=========");}}@Overridepublic void notify(DelegateTask delegateTask) {// 實現TaskListener中的方法String eventName = delegateTask.getEventName();LOGGER.info("任務監聽器:{}", arg.getValue(delegateTask));if ("create".endsWith(eventName)) {LOGGER.info("create=========");} else if ("assignment".endsWith(eventName)) {LOGGER.info("assignment========");} else if ("complete".endsWith(eventName)) {LOGGER.info("complete===========");} else if ("delete".endsWith(eventName)) {LOGGER.info("delete=============");}}}

6.2 expression方式：填寫的是具體的方法,也就是class.method()

<process id="listenerTask1" name="任務監聽器流程" isExecutable="true"><startEvent id="startevent" name="Start"><extensionElements><activiti:executionListener event="start" expression="${myExecutionListener.processStart(execution)}"></activiti:executionListener></extensionElements></startEvent><endEvent id="endevent1" name="End"></endEvent><userTask id="usertask1" name="User Task" activiti:assignee="#{createLoginName}"><extensionElements><activiti:taskListener event="complete" expression="${myTaskListener1.taskComplete(task)}"><activiti:field name="arg"><activiti:string><![CDATA[gengzhn]]></activiti:string></activiti:field></activiti:taskListener></extensionElements>

類需要添加到bean()

Map<Object, Object> beans = new HashMap<>(10);beans.put("myExecutionListener", myExecutionListener);beans.put("myTaskListener1", myTaskListener1); /* beans.put("surveyProcessListener", surveyProcessListener);beans.put("lossVerificationProcessListener", lossVerificationProcessListener);beans.put("investigateProcessListener", investigateProcessListener);*/configuration.setBeans(beans); @Service public class MyExecutionListener {private static final Logger LOGGER = LoggerFactory.getLogger(ActivitiServiceImpl.class);public void processStart(DelegateExecution execution) {LOGGER.info("start===================================================================");}} @Service public class MyTaskListener1 {private static final Logger LOGGER = LoggerFactory.getLogger(ActivitiServiceImpl.class);private Expression arg;public Expression getArg() {return arg;}public void setArg(Expression arg) {this.arg = arg;}public void taskComplete(DelegateTask task) { // LOGGER.info("任務監聽器:{}", arg.getValue(delegateTask));LOGGER.info("任務監聽器:complete===========");}}

6.3 delegateExpression方式：處理的是eventlistener,是處理對事件的監聽，delegateExpression的意思是：class和events描述，delegate的意思是表達的方式是不是直接告訴Expression，有通過activiti。

示例如下：

<extensionElements><activiti:eventListener events="ACTIVITY_CANCELLED" delegateExpression="${surveyProcessListener}"></activiti:eventListener></extensionElements> <extensionElements><activiti:eventListener class="org.activiti.engine.test.MyEventListener" /><activiti:eventListener delegateExpression="${testEventListener}" events="JOB_EXECUTION_SUCCESS,JOB_EXECUTION_FAILURE" /></extensionElements> <extensionElements><activiti:eventListener class="org.activiti.engine.test.MyEventListener" entityType="task" /><activiti:eventListener delegateExpression="${testEventListener}" events="ENTITY_CREATED" entityType="task" /></extensionElements> Supported values for the entityType are: attachment, comment, execution, identity-link, job, process-instance, process-definition, task. @Service public class SurveyProcessListener implements ActivitiEventListener {}@Overridepublic void onEvent(ActivitiEvent event) {//如果流程取消if (ActivitiEventType.ACTIVITY_CANCELLED == event.getType()) {// TODO: 2019-03-08 流程取消，發送各種消息，String processInstanceId = event.getProcessInstanceId();log.info("surveyProcessListener.onEvent.ACTIVITY_CANCELLED, processInstanceId:{}", processInstanceId);}}@Overridepublic boolean isFailOnException() {return false;} }

7、變量的設置：

在代理監聽器里無法注入RuntimeService或者taskService，使用bean注入，或者使用delegateTask.setVariable

((RuntimeService)SpringContextUtil.getBean("runtimeService")).setVariable(delegateTask.getExecutionId(),"checkBywhom", "x00000000xoo");runtimeService.setVariable(delegateTask.getExecutionId(),"checkBywhom", "xxoo"); delegateTask.setVariable("checkBywhom", "xxxxxxx");LOGGER.info("complete==========="); @Overridepublic boolean setVariableByExcutionId(String executionId, boolean isLocal, HashMap<String, Object> map) {/** runtimeService.setVariablesLocal(executionId, variableName, value);** 設置本執行對象的變量，該作用域只在當前的executionId中 runtimeService.setVariableLocal(executionId,* variableName, value);** 可以設置對個變量，放在map中*/if (isLocal) {runtimeService.setVariablesLocal(executionId, map);} else {runtimeService.setVariables(executionId, map);}return true;}@Overridepublic Map<String, Object> getVariableByExcutionId(String executionId, boolean isLocal) {Map<String, Object> variablesMap = new HashMap<String, Object>();if (isLocal) {variablesMap = runtimeService.getVariablesLocal(executionId);} else {variablesMap = runtimeService.getVariables(executionId);}return variablesMap;}@Overridepublic boolean setVariableByTaskId(String taskId, String objectName, Object object) {taskService.setVariable(taskId, objectName, object);return true;}@Overridepublic boolean setVariableByTaskId(String taskId, boolean isLocal, HashMap<String, Object> map) {/** taskService.setVariable(taskId, variableName, value);** 設置本執行對象的變量，該作用域只在當前的executionId中 taskService.setVariableLocal(taskId,* variableName, value); 可以設置對個變量，放在map中*/if (isLocal) {taskService.setVariablesLocal(taskId, map);} else {taskService.setVariables(taskId, map);}return true;}@Overridepublic Map<String, Object> getVariableByTaskId(String taskId, boolean isLocal) {Map<String, Object> variablesMap = new HashMap<String, Object>();if (isLocal) {variablesMap = taskService.getVariablesLocal(taskId);} else {variablesMap = taskService.getVariables(taskId);}return variablesMap;}@Overridepublic <T> T getVariableByTaskId(String taskId, String objectName, Class<T> tClass) {T bean = (T) taskService.getVariable(taskId, objectName);return bean;}@Overridepublic boolean delegateTask(String taskId, String loginName) {taskService.delegateTask(taskId, loginName);return true;}

8、流程的操作

8.1 委派任務

/*** 委派任務** @param taskId* @param loginName* @return*/boolean delegateTask(String taskId, String loginName);@Overridepublic boolean delegateTask(String taskId, String loginName) {taskService.delegateTask(taskId, loginName);return true;}/*** 指定代辦人*/@Testpublic void delegateTask() {String taskId = "2511";String loginName = "0003";activitiService.delegateTask(taskId, loginName);}

8.2 根據指定人查詢任務

/*** 根據指定人查詢任務** @param processDefinitionKey* @param assignee* @return*/boolean getTaskByAssignee(String processDefinitionKey, String assignee);@Overridepublic boolean getTaskByAssignee(String processDefinitionKey, String assignee) {TaskQuery taskQuery = taskService.createTaskQuery();// 任務列表List<Task> list = taskQuery.processDefinitionKey(processDefinitionKey).taskAssignee(assignee).list();// 指定辦理人for (Task task : list) {LOGGER.info("任務處理人【{}】", task.getAssignee());LOGGER.info("流程名稱【{}】", task.getName());LOGGER.info("任務id【{}】", task.getId());LOGGER.info("流程定義id【{}】", task.getProcessDefinitionId());LOGGER.info("執行對象id【{}】", task.getExecutionId());}return true;}@Testpublic void getTaskByAssignee() {String processDefinitionKey = "delegateTask";String assignee = "0003";activitiService.getTaskByAssignee(processDefinitionKey, assignee);}

8.3 根據任務擁有者查詢任務

/*** 根據任務擁有者查詢任務** @param processDefinitionKey* @param owner* @return*/ boolean getTaskByOwner(String processDefinitionKey, String owner);@Overridepublic boolean getTaskByOwner(String processDefinitionKey, String owner) {TaskQuery taskQuery = taskService.createTaskQuery();// 任務列表List<Task> list = taskQuery.processDefinitionKey(processDefinitionKey).taskOwner(owner).list();// 指定辦理人for (Task task : list) {LOGGER.info("任務處理人【{}】", task.getAssignee());LOGGER.info("流程名稱【{}】", task.getName());LOGGER.info("任務id【{}】", task.getId());LOGGER.info("流程定義id【{}】", task.getProcessDefinitionId());LOGGER.info("執行對象id【{}】", task.getExecutionId());LOGGER.info("任務擁有者【{}】", task.getOwner());}return true;}@Testpublic void getTaskByOwner() {String processDefinitionKey = "delegateTask";String owner = "0003";activitiService.getTaskByOwner(processDefinitionKey, owner);}

8.4 委派人完成任務

/*** 委派人完成任務** @param taskId* @param map* @return*/ boolean resolveTask(String taskId, Map<String, Object> map);@Overridepublic boolean resolveTask(String taskId, Map<String, Object> map) {taskService.resolveTask(taskId, map);return true;}/*** 正在運行的任務表中被委派人辦理任務后任務會回到委派人 ，歷史任務表中也一樣,只是多了一個人進行審批*/@Testpublic void resolveTask() {String taskId = "2511";Map<String, Object> map = new HashMap<>();activitiService.resolveTask(taskId, map);}

8.5 將任務委派他人完成

/*** 將任務委派他人完成** @param taskId* @param assignee* @return*/ boolean trunTask(String taskId, String assignee);@Overridepublic boolean trunTask(String taskId, String assignee) {taskService.setAssignee(taskId, assignee);return true;}/*** 任務轉辦,將任務交給其他人處理*/@Testpublic void turnTask() {String taskId = "7511";String assignee = "0003";activitiService.trunTask(taskId, assignee);}

8.5 掛起流程實例

/*** 掛起流程實例** @param processInstanceId* @return*/ boolean suspendProcessInstanceById(String processInstanceId);@Overridepublic boolean suspendProcessInstanceById(String processInstanceId) {runtimeService.suspendProcessInstanceById(processInstanceId);return true;}/*** 掛起流程*/@Testpublic void suspendProcess() {//SuspensionState ACTIVE = new SuspensionStateImpl(1, "active"); 激活// SuspensionState SUSPENDED = new SuspensionStateImpl(2, "suspended"); 掛起String processInstanceId = "70001";activitiService.suspendProcessInstanceById(processInstanceId);}

8.6 刪除流程實例

/*** 刪除流程實例** @param processInstanceId* @param reason* @return*/ boolean deleteProcessInstance(String processInstanceId, String reason);@Overridepublic boolean deleteProcessInstance(String processInstanceId, String reason) {runtimeService.deleteProcessInstance(processInstanceId, reason);return true;}@Testpublic void deleteProcessInstance() {String processInstanceId = "70001";String reason = "刪除原因";activitiService.deleteProcessInstance(processInstanceId, reason);}

8.7激活掛起的流程實例

/*** 激活流程實例（激活掛起的流程實例）** @param processInstanceId* @return*/ boolean activateProcessInstanceById(String processInstanceId);@Overridepublic boolean activateProcessInstanceById(String processInstanceId) {runtimeService.activateProcessInstanceById(processInstanceId);return true;}@Testpublic void activateProcessInstanceById(){String processInstanceId = "70001";activitiService.activateProcessInstanceById(processInstanceId);}

8.8 激活、掛起流程定義

/*** 掛起流程定義** @param processDefineKey* @param cascade* @return*/ boolean suspendProcessDefineKey(String processDefineKey, boolean cascade);/*** 激活流程定義** @param processDefineKey* @param cascade* @return*/ boolean activateProcessDefinitionByKey(String processDefineKey, boolean cascade);@Overridepublic boolean suspendProcessDefineKey(String processDefineKey, boolean cascade) {repositoryService.suspendProcessDefinitionByKey(processDefineKey,cascade,new Date());return true;}@Overridepublic boolean activateProcessDefinitionByKey(String processDefineKey,boolean cascade){repositoryService.activateProcessDefinitionByKey(processDefineKey,cascade,new Date());return true;@Testpublic void suspendProcessDefineBykey(){String processDefineKey = "";boolean cascade = true;activitiService.suspendProcessDefineKey(processDefineKey,cascade);}

總結

以上是生活随笔為你收集整理的Activiti的使用技巧的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。