smallchill
6 years ago
13 changed files with 540 additions and 16 deletions
@ -0,0 +1,99 @@
|
||||
/* |
||||
* Copyright (c) 2018-2028, Chill Zhuang All rights reserved. |
||||
* |
||||
* Redistribution and use in source and binary forms, with or without |
||||
* modification, are permitted provided that the following conditions are met: |
||||
* |
||||
* Redistributions of source code must retain the above copyright notice, |
||||
* this list of conditions and the following disclaimer. |
||||
* Redistributions in binary form must reproduce the above copyright |
||||
* notice, this list of conditions and the following disclaimer in the |
||||
* documentation and/or other materials provided with the distribution. |
||||
* Neither the name of the dreamlu.net developer nor the names of its |
||||
* contributors may be used to endorse or promote products derived from |
||||
* this software without specific prior written permission. |
||||
* Author: Chill 庄骞 (smallchill@163.com) |
||||
*/ |
||||
package org.springblade.flowable.business.controller; |
||||
|
||||
import com.baomidou.mybatisplus.core.metadata.IPage; |
||||
import io.swagger.annotations.Api; |
||||
import io.swagger.annotations.ApiOperation; |
||||
import io.swagger.annotations.ApiParam; |
||||
import lombok.AllArgsConstructor; |
||||
import org.springblade.core.mp.support.Condition; |
||||
import org.springblade.core.mp.support.Query; |
||||
import org.springblade.core.tool.api.R; |
||||
import org.springblade.flowable.business.service.FlowBusinessService; |
||||
import org.springblade.flowable.core.entity.BladeFlow; |
||||
import org.springblade.flowable.engine.entity.FlowProcess; |
||||
import org.springblade.flowable.engine.service.FlowService; |
||||
import org.springframework.web.bind.annotation.GetMapping; |
||||
import org.springframework.web.bind.annotation.RequestMapping; |
||||
import org.springframework.web.bind.annotation.RestController; |
||||
|
||||
/** |
||||
* 流程事务通用接口 |
||||
* |
||||
* @author Chill |
||||
*/ |
||||
@RestController |
||||
@AllArgsConstructor |
||||
@RequestMapping("work") |
||||
@Api(value = "流程事务通用接口", tags = "流程事务通用接口") |
||||
public class WorkController { |
||||
|
||||
private FlowService flowService; |
||||
private FlowBusinessService flowBusinessService; |
||||
|
||||
/** |
||||
* 发起事务列表页 |
||||
*/ |
||||
@GetMapping("start-list") |
||||
@ApiOperation(value = "发起事务列表页", notes = "传入流程类型", position = 1) |
||||
public R<IPage<FlowProcess>> startList(@ApiParam("流程类型") String category, Query query) { |
||||
IPage<FlowProcess> pages = flowService.selectProcessPage(Condition.getPage(query), category); |
||||
return R.data(pages); |
||||
} |
||||
|
||||
/** |
||||
* 待签事务列表页 |
||||
*/ |
||||
@GetMapping("claim-list") |
||||
@ApiOperation(value = "待签事务列表页", notes = "传入流程信息", position = 2) |
||||
public R<IPage<BladeFlow>> claimList(@ApiParam("流程信息") BladeFlow bladeFlow, Query query) { |
||||
IPage<BladeFlow> pages = flowBusinessService.selectClaimPage(Condition.getPage(query), bladeFlow); |
||||
return R.data(pages); |
||||
} |
||||
|
||||
/** |
||||
* 待办事务列表页 |
||||
*/ |
||||
@GetMapping("todo-list") |
||||
@ApiOperation(value = "待办事务列表页", notes = "传入流程信息", position = 3) |
||||
public R<IPage<BladeFlow>> todoList(@ApiParam("流程信息") BladeFlow bladeFlow, Query query) { |
||||
IPage<BladeFlow> pages = flowBusinessService.selectTodoPage(Condition.getPage(query), bladeFlow); |
||||
return R.data(pages); |
||||
} |
||||
|
||||
/** |
||||
* 已发事务列表页 |
||||
*/ |
||||
@GetMapping("send-list") |
||||
@ApiOperation(value = "已发事务列表页", notes = "传入流程信息", position = 4) |
||||
public R<IPage<BladeFlow>> sendList(@ApiParam("流程信息") BladeFlow bladeFlow, Query query) { |
||||
IPage<BladeFlow> pages = flowBusinessService.selectSendPage(Condition.getPage(query), bladeFlow); |
||||
return R.data(pages); |
||||
} |
||||
|
||||
/** |
||||
* 办结事务列表页 |
||||
*/ |
||||
@GetMapping("done-list") |
||||
@ApiOperation(value = "办结事务列表页", notes = "传入流程信息", position = 5) |
||||
public R<IPage<BladeFlow>> doneList(@ApiParam("流程信息") BladeFlow bladeFlow, Query query) { |
||||
IPage<BladeFlow> pages = flowBusinessService.selectDonePage(Condition.getPage(query), bladeFlow); |
||||
return R.data(pages); |
||||
} |
||||
|
||||
} |
||||
@ -0,0 +1,64 @@
|
||||
/* |
||||
* Copyright (c) 2018-2028, Chill Zhuang All rights reserved. |
||||
* |
||||
* Redistribution and use in source and binary forms, with or without |
||||
* modification, are permitted provided that the following conditions are met: |
||||
* |
||||
* Redistributions of source code must retain the above copyright notice, |
||||
* this list of conditions and the following disclaimer. |
||||
* Redistributions in binary form must reproduce the above copyright |
||||
* notice, this list of conditions and the following disclaimer in the |
||||
* documentation and/or other materials provided with the distribution. |
||||
* Neither the name of the dreamlu.net developer nor the names of its |
||||
* contributors may be used to endorse or promote products derived from |
||||
* this software without specific prior written permission. |
||||
* Author: Chill 庄骞 (smallchill@163.com) |
||||
*/ |
||||
package org.springblade.flowable.business.service; |
||||
|
||||
import com.baomidou.mybatisplus.core.metadata.IPage; |
||||
import org.springblade.flowable.core.entity.BladeFlow; |
||||
|
||||
/** |
||||
* 流程业务类 |
||||
* |
||||
* @author Chill |
||||
*/ |
||||
public interface FlowBusinessService { |
||||
|
||||
/** |
||||
* 流程待签列表 |
||||
* |
||||
* @param page 分页工具 |
||||
* @param bladeFlow 流程类 |
||||
* @return |
||||
*/ |
||||
IPage<BladeFlow> selectClaimPage(IPage<BladeFlow> page, BladeFlow bladeFlow); |
||||
|
||||
/** |
||||
* 流程待办列表 |
||||
* |
||||
* @param page 分页工具 |
||||
* @param bladeFlow 流程类 |
||||
* @return |
||||
*/ |
||||
IPage<BladeFlow> selectTodoPage(IPage<BladeFlow> page, BladeFlow bladeFlow); |
||||
|
||||
/** |
||||
* 流程已发列表 |
||||
* |
||||
* @param page 分页工具 |
||||
* @param bladeFlow 流程类 |
||||
* @return |
||||
*/ |
||||
IPage<BladeFlow> selectSendPage(IPage<BladeFlow> page, BladeFlow bladeFlow); |
||||
|
||||
/** |
||||
* 流程办结列表 |
||||
* |
||||
* @param page 分页工具 |
||||
* @param bladeFlow 流程类 |
||||
* @return |
||||
*/ |
||||
IPage<BladeFlow> selectDonePage(IPage<BladeFlow> page, BladeFlow bladeFlow); |
||||
} |
||||
@ -0,0 +1,235 @@
|
||||
/* |
||||
* Copyright (c) 2018-2028, Chill Zhuang All rights reserved. |
||||
* |
||||
* Redistribution and use in source and binary forms, with or without |
||||
* modification, are permitted provided that the following conditions are met: |
||||
* |
||||
* Redistributions of source code must retain the above copyright notice, |
||||
* this list of conditions and the following disclaimer. |
||||
* Redistributions in binary form must reproduce the above copyright |
||||
* notice, this list of conditions and the following disclaimer in the |
||||
* documentation and/or other materials provided with the distribution. |
||||
* Neither the name of the dreamlu.net developer nor the names of its |
||||
* contributors may be used to endorse or promote products derived from |
||||
* this software without specific prior written permission. |
||||
* Author: Chill 庄骞 (smallchill@163.com) |
||||
*/ |
||||
package org.springblade.flowable.business.service.impl; |
||||
|
||||
import com.baomidou.mybatisplus.core.metadata.IPage; |
||||
import lombok.AllArgsConstructor; |
||||
import org.flowable.engine.HistoryService; |
||||
import org.flowable.engine.RepositoryService; |
||||
import org.flowable.engine.TaskService; |
||||
import org.flowable.engine.history.HistoricProcessInstance; |
||||
import org.flowable.engine.history.HistoricProcessInstanceQuery; |
||||
import org.flowable.engine.repository.ProcessDefinition; |
||||
import org.flowable.task.api.TaskQuery; |
||||
import org.flowable.task.api.history.HistoricTaskInstance; |
||||
import org.flowable.task.api.history.HistoricTaskInstanceQuery; |
||||
import org.springblade.core.secure.utils.SecureUtil; |
||||
import org.springblade.core.tool.utils.Func; |
||||
import org.springblade.flowable.business.service.FlowBusinessService; |
||||
import org.springblade.flowable.core.entity.BladeFlow; |
||||
import org.springblade.flowable.engine.constant.FlowableConstant; |
||||
import org.springblade.flowable.engine.utils.FlowCache; |
||||
import org.springframework.stereotype.Service; |
||||
|
||||
import java.util.LinkedList; |
||||
import java.util.List; |
||||
|
||||
/** |
||||
* 流程业务实现类 |
||||
* |
||||
* @author Chill |
||||
*/ |
||||
@Service |
||||
@AllArgsConstructor |
||||
public class FlowBusinessServiceImpl implements FlowBusinessService { |
||||
|
||||
private RepositoryService repositoryService; |
||||
private TaskService taskService; |
||||
private HistoryService historyService; |
||||
|
||||
@Override |
||||
public IPage<BladeFlow> selectClaimPage(IPage<BladeFlow> page, BladeFlow bladeFlow) { |
||||
String taskUser = SecureUtil.getUserAccount(); |
||||
List<BladeFlow> flowList = new LinkedList<>(); |
||||
|
||||
// 等待签收的任务
|
||||
TaskQuery claimQuery = taskService.createTaskQuery().taskCandidateUser(taskUser) |
||||
.includeProcessVariables().active().orderByTaskCreateTime().desc(); |
||||
|
||||
// 构建列表数据
|
||||
buildFlowTaskList(bladeFlow, flowList, claimQuery, FlowableConstant.STATUS_CLAIM); |
||||
|
||||
// 计算总数
|
||||
long count = claimQuery.count(); |
||||
// 设置页数
|
||||
page.setSize(count); |
||||
// 设置总数
|
||||
page.setTotal(count); |
||||
// 设置数据
|
||||
page.setRecords(flowList); |
||||
return null; |
||||
} |
||||
|
||||
@Override |
||||
public IPage<BladeFlow> selectTodoPage(IPage<BladeFlow> page, BladeFlow bladeFlow) { |
||||
String taskUser = SecureUtil.getUserAccount(); |
||||
List<BladeFlow> flowList = new LinkedList<>(); |
||||
|
||||
// 已签收的任务
|
||||
TaskQuery todoQuery = taskService.createTaskQuery().taskAssignee(taskUser).active() |
||||
.includeProcessVariables().orderByTaskCreateTime().desc(); |
||||
|
||||
// 构建列表数据
|
||||
buildFlowTaskList(bladeFlow, flowList, todoQuery, FlowableConstant.STATUS_TODO); |
||||
|
||||
// 计算总数
|
||||
long count = todoQuery.count(); |
||||
// 设置页数
|
||||
page.setSize(count); |
||||
// 设置总数
|
||||
page.setTotal(count); |
||||
// 设置数据
|
||||
page.setRecords(flowList); |
||||
return page; |
||||
} |
||||
|
||||
@Override |
||||
public IPage<BladeFlow> selectSendPage(IPage<BladeFlow> page, BladeFlow bladeFlow) { |
||||
String taskUser = SecureUtil.getUserAccount(); |
||||
List<BladeFlow> flowList = new LinkedList<>(); |
||||
|
||||
HistoricProcessInstanceQuery historyQuery = historyService.createHistoricProcessInstanceQuery().startedBy(taskUser).orderByProcessInstanceStartTime().desc(); |
||||
// 查询列表
|
||||
List<HistoricProcessInstance> historyList = historyQuery.listPage(Func.toInt(page.getCurrent() - 1), Func.toInt(page.getSize())); |
||||
|
||||
historyList.forEach(historicProcessInstance -> { |
||||
BladeFlow bf = new BladeFlow(); |
||||
// historicProcessInstance
|
||||
bf.setCreateTime(historicProcessInstance.getStartTime()); |
||||
bf.setEndTime(historicProcessInstance.getEndTime()); |
||||
bf.setVariables(historicProcessInstance.getProcessVariables()); |
||||
bf.setBusinessId(historicProcessInstance.getBusinessKey()); |
||||
bf.setHisActInsActName(historicProcessInstance.getName()); |
||||
bf.setProcessInstanceId(historicProcessInstance.getId()); |
||||
bf.setHistoryProcessInstanceId(historicProcessInstance.getId()); |
||||
// ProcessDefinition
|
||||
ProcessDefinition pd = FlowCache.getProcessDefinition(historicProcessInstance.getProcessDefinitionId()); |
||||
bf.setProcessDefinitionId(pd.getId()); |
||||
bf.setProcessDefinitionName(pd.getName()); |
||||
bf.setProcessDefinitionKey(pd.getKey()); |
||||
bf.setProcessDefinitionVersion(pd.getVersion()); |
||||
bf.setProcessInstanceId(historicProcessInstance.getId()); |
||||
// HistoricTaskInstance
|
||||
HistoricTaskInstance historyTask = historyService.createHistoricTaskInstanceQuery().processInstanceId(historicProcessInstance.getId()).orderByHistoricTaskInstanceEndTime().desc().list().get(0); |
||||
bf.setTaskId(historyTask.getId()); |
||||
bf.setTaskName(historyTask.getName()); |
||||
bf.setTaskDefinitionKey(historyTask.getTaskDefinitionKey()); |
||||
// Status
|
||||
if (historicProcessInstance.getEndActivityId() != null) { |
||||
bf.setProcessIsFinished(FlowableConstant.STATUS_FINISHED); |
||||
} else { |
||||
bf.setProcessIsFinished(FlowableConstant.STATUS_UNFINISHED); |
||||
} |
||||
bf.setStatus(FlowableConstant.STATUS_FINISH); |
||||
flowList.add(bf); |
||||
}); |
||||
|
||||
// 计算总数
|
||||
long count = historyQuery.count(); |
||||
// 设置总数
|
||||
page.setTotal(count); |
||||
page.setRecords(flowList); |
||||
return page; |
||||
} |
||||
|
||||
@Override |
||||
public IPage<BladeFlow> selectDonePage(IPage<BladeFlow> page, BladeFlow bladeFlow) { |
||||
String taskUser = SecureUtil.getUserAccount(); |
||||
List<BladeFlow> flowList = new LinkedList<>(); |
||||
|
||||
HistoricTaskInstanceQuery doneQuery = historyService.createHistoricTaskInstanceQuery().taskAssignee(taskUser).finished() |
||||
.includeProcessVariables().orderByHistoricTaskInstanceEndTime().desc(); |
||||
|
||||
if (bladeFlow.getBeginDate() != null) { |
||||
doneQuery.taskCompletedAfter(bladeFlow.getBeginDate()); |
||||
} |
||||
if (bladeFlow.getEndDate() != null) { |
||||
doneQuery.taskCompletedBefore(bladeFlow.getEndDate()); |
||||
} |
||||
|
||||
// 查询列表
|
||||
List<HistoricTaskInstance> doneList = doneQuery.listPage(Func.toInt(page.getCurrent() - 1), Func.toInt(page.getSize())); |
||||
doneList.forEach(historicTaskInstance -> { |
||||
BladeFlow bf = new BladeFlow(); |
||||
bf.setTaskId(historicTaskInstance.getId()); |
||||
bf.setTaskDefinitionKey(historicTaskInstance.getTaskDefinitionKey()); |
||||
bf.setTaskName(historicTaskInstance.getName()); |
||||
bf.setAssignee(historicTaskInstance.getAssignee()); |
||||
bf.setCreateTime(historicTaskInstance.getCreateTime()); |
||||
bf.setExecutionId(historicTaskInstance.getExecutionId()); |
||||
bf.setHistoryTaskEndTime(historicTaskInstance.getEndTime()); |
||||
bf.setVariables(historicTaskInstance.getProcessVariables()); |
||||
|
||||
ProcessDefinition pd = FlowCache.getProcessDefinition(historicTaskInstance.getProcessDefinitionId()); |
||||
bf.setProcessDefinitionId(pd.getId()); |
||||
bf.setProcessDefinitionName(pd.getName()); |
||||
bf.setProcessDefinitionKey(pd.getKey()); |
||||
bf.setProcessDefinitionVersion(pd.getVersion()); |
||||
|
||||
bf.setProcessInstanceId(historicTaskInstance.getProcessInstanceId()); |
||||
bf.setHistoryProcessInstanceId(historicTaskInstance.getProcessInstanceId()); |
||||
HistoricProcessInstance historicProcessInstance = historyService.createHistoricProcessInstanceQuery().processInstanceId(historicTaskInstance.getProcessInstanceId()).singleResult(); |
||||
if (historicProcessInstance.getEndActivityId() != null) { |
||||
bf.setProcessIsFinished(FlowableConstant.STATUS_FINISHED); |
||||
} else { |
||||
bf.setProcessIsFinished(FlowableConstant.STATUS_UNFINISHED); |
||||
} |
||||
bf.setStatus(FlowableConstant.STATUS_FINISH); |
||||
|
||||
flowList.add(bf); |
||||
}); |
||||
|
||||
|
||||
// 计算总数
|
||||
long count = doneQuery.count(); |
||||
// 设置总数
|
||||
page.setTotal(count); |
||||
page.setRecords(flowList); |
||||
return page; |
||||
} |
||||
|
||||
private void buildFlowTaskList(BladeFlow bladeFlow, List<BladeFlow> flowList, TaskQuery taskQuery, String status) { |
||||
if (bladeFlow.getBeginDate() != null) { |
||||
taskQuery.taskCreatedAfter(bladeFlow.getBeginDate()); |
||||
} |
||||
if (bladeFlow.getEndDate() != null) { |
||||
taskQuery.taskCreatedBefore(bladeFlow.getEndDate()); |
||||
} |
||||
taskQuery.list().forEach(task -> { |
||||
BladeFlow bf = new BladeFlow(); |
||||
bf.setTaskId(task.getId()); |
||||
bf.setTaskDefinitionKey(task.getTaskDefinitionKey()); |
||||
bf.setTaskName(task.getName()); |
||||
bf.setAssignee(task.getAssignee()); |
||||
bf.setCreateTime(task.getCreateTime()); |
||||
bf.setClaimTime(task.getClaimTime()); |
||||
bf.setExecutionId(task.getExecutionId()); |
||||
bf.setVariables(task.getProcessVariables()); |
||||
bf.setCategory(task.getCategory()); |
||||
bf.setCategoryName(FlowCache.getCategoryName(task.getCategory())); |
||||
ProcessDefinition pd = FlowCache.getProcessDefinition(task.getProcessDefinitionId()); |
||||
bf.setProcessDefinitionId(pd.getId()); |
||||
bf.setProcessDefinitionName(pd.getName()); |
||||
bf.setProcessDefinitionKey(pd.getKey()); |
||||
bf.setProcessDefinitionVersion(pd.getVersion()); |
||||
bf.setProcessInstanceId(task.getProcessInstanceId()); |
||||
bf.setStatus(status); |
||||
flowList.add(bf); |
||||
}); |
||||
} |
||||
|
||||
} |
||||
@ -0,0 +1,73 @@
|
||||
/* |
||||
* Copyright (c) 2018-2028, Chill Zhuang All rights reserved. |
||||
* |
||||
* Redistribution and use in source and binary forms, with or without |
||||
* modification, are permitted provided that the following conditions are met: |
||||
* |
||||
* Redistributions of source code must retain the above copyright notice, |
||||
* this list of conditions and the following disclaimer. |
||||
* Redistributions in binary form must reproduce the above copyright |
||||
* notice, this list of conditions and the following disclaimer in the |
||||
* documentation and/or other materials provided with the distribution. |
||||
* Neither the name of the dreamlu.net developer nor the names of its |
||||
* contributors may be used to endorse or promote products derived from |
||||
* this software without specific prior written permission. |
||||
* Author: Chill 庄骞 (smallchill@163.com) |
||||
*/ |
||||
package org.springblade.flowable.engine.utils; |
||||
|
||||
import org.flowable.engine.RepositoryService; |
||||
import org.flowable.engine.repository.ProcessDefinition; |
||||
import org.springblade.core.cache.utils.CacheUtil; |
||||
import org.springblade.core.tool.utils.Func; |
||||
import org.springblade.core.tool.utils.SpringUtil; |
||||
import org.springblade.core.tool.utils.StringPool; |
||||
import org.springblade.system.utils.DictUtil; |
||||
|
||||
/** |
||||
* 流程缓存 |
||||
* |
||||
* @author Chill |
||||
*/ |
||||
public class FlowCache { |
||||
|
||||
private static final String FLOW_CACHE = "flow:process"; |
||||
private static final String FLOW_CACHE_PD_ID_ = "definition_id_"; |
||||
|
||||
private static RepositoryService repositoryService; |
||||
|
||||
static { |
||||
repositoryService = SpringUtil.getBean(RepositoryService.class); |
||||
} |
||||
|
||||
/** |
||||
* 获得流程定义对象 |
||||
* |
||||
* @param procDefId 流程对象id |
||||
* @return |
||||
*/ |
||||
public static ProcessDefinition getProcessDefinition(String procDefId) { |
||||
ProcessDefinition pd = CacheUtil.get(FLOW_CACHE, FLOW_CACHE_PD_ID_ + procDefId, ProcessDefinition.class); |
||||
if (Func.isEmpty(pd)) { |
||||
pd = repositoryService.createProcessDefinitionQuery().processDefinitionId(procDefId).singleResult(); |
||||
if (Func.isNotEmpty(pd)) { |
||||
CacheUtil.put(FLOW_CACHE, FLOW_CACHE_PD_ID_ + procDefId, pd); |
||||
} |
||||
} |
||||
return pd; |
||||
} |
||||
|
||||
/** |
||||
* 获取流程类型名 |
||||
* |
||||
* @param category 流程类型 |
||||
* @return |
||||
*/ |
||||
public static String getCategoryName(String category) { |
||||
if (Func.isEmpty(category)) { |
||||
return StringPool.EMPTY; |
||||
} |
||||
return DictUtil.getValue(category.split(StringPool.UNDERSCORE)[0], Func.toInt(category.split(StringPool.UNDERSCORE)[1])); |
||||
} |
||||
|
||||
} |
||||
Loading…
Reference in new issue