流程审批基本都是通用的，但是业务审批却是多态的，一模一样流程图的两个不同流程，调用的方法截然不同，而获取资源的写法基本一致，为了降低代码耦合度，可以定制通过的审批信息获取表，来获取数据。
基于Activiti 6.0
GitHub https://github.com/oldguys/ActivitiDemo
设计思路:
1.通过流程图获取各个流程节点，对流程节点进行分类。
2.然后根据任务 taskDefinitionKey 与 ProcessDefinitionId 将自定义表与流程串起来。
- 连线配置同理
功能界面图:
节点状态.png
连线配置.png
1.审批状态实体
/**
* @author ren
* @date 2019/1/23
*/
@Entity
@Data
public class ProcessAuditStatus extends BaseEntity {
/**
* 流程定义Key
*/
private String processDefinitionKey;
/**
* 流程定义ID
*/
private String processDefinitionId;
/**
* 节点
*/
private String userTask;
/**
* 审核状态码
*/
private String auditCode;
/**
* 审核状态描述
*/
private String auditMessage;
}
2. 连线配置实体
/**
* @Date: 2019/1/26 0026
* @Author: ren
* @Description:
*/
@Entity
@Data
public class ProcessTaskConfig extends BaseEntity{
/**
* 流程定义ID
*/
private String processDefinitionId;
/**
* 流程定义Key
*/
private String processDefinitionKey;
/**
* 流程判定标识
*/
private String flowFlag;
/**
* 连线ID
*/
private String flowId;
/**
* 显示按钮名称
*/
private String btn;
/**
* 相应后台链接
*/
private String url;
}
获取流程图节点信息:
com.oldguy.example.modules.workflow.service.ProcessService
/**
* 流程定义详情配置页
*
* @param processDefinitionId
* @return
*/
public ProcessDefinitionInfo processDefinitionInfo(String processDefinitionId) {
ProcessDefinition processDefinition = repositoryService.getProcessDefinition(processDefinitionId);
BpmnModel bpmnModel = repositoryService.getBpmnModel(processDefinitionId);
Process process = bpmnModel.getProcesses().get(0);
Collection<FlowElement> flowElements = process.getFlowElements();
ProcessDefinitionInfo info = new ProcessDefinitionInfo(processDefinition.getId(), processDefinition.getKey(), processDefinition.getName(), processDefinition.getDeploymentId(), processDefinition.getVersion());
// 任务节点
List<ProcessDefinitionInfo.TaskElement> elements = new ArrayList<>();
info.setElements(elements);
// 任务连线
List<TaskFlow> taskFlowList = new ArrayList<>();
info.setTaskFlowList(taskFlowList);
for (FlowElement element : flowElements) {
if (element instanceof UserTask) {
elements.add(new ProcessDefinitionInfo.TaskElement(element.getId(), element.getName()));
} else if (element instanceof EndEvent) {
elements.add(new ProcessDefinitionInfo.TaskElement(element.getId(), "完成"));
}
if (element instanceof SequenceFlow) {
SequenceFlow flow = (SequenceFlow) element;
// 获取源节点名称
FlowElement sourceTask = process.getFlowElement(flow.getSourceRef());
String sourceTaskName = getTaskNameByFlowElement(process, sourceTask, "source");
// 获取指向节点名称
FlowElement targetTask = process.getFlowElement(flow.getTargetRef());
String targetTaskName = getTaskNameByFlowElement(process, targetTask, "target");
taskFlowList.add(new TaskFlow(flow.getId(), flow.getName(), flow.getConditionExpression(), sourceTaskName, targetTaskName));
}
}
// 获取当前已存在数据库中 节点状态记录
info.setElementValueMap(processAuditStatusService.getMap(info.getKey(), processDefinitionId));
// 获取当前已存在数据库中 连线配置记录
info.setTaskConfigMap(processTaskConfigService.getProcessTaskConfigMap(info.getKey(), processDefinitionId));
return info;
}
以上是连线配置 设置界面的数据相关信息。
下面是怎样关联 流程模型 与 审批记录和连线配置
获取连线按钮
- 获取当前任务连线（通过获取当前任务的ID，从Bpmn实例中获取输出连线）
com.oldguy.example.modules.workflow.service.ProcessService
/**
* 获取输出路线
*
* @param processInstanceId
* @param taskDefinitionKey
* @return
*/
public List<SequenceFlow> getOutputLinkList(String processInstanceId, String taskDefinitionKey) {
ProcessInstance pi = runtimeService.createProcessInstanceQuery().processInstanceId(processInstanceId).singleResult();
BpmnModel bpmnModel = repositoryService.getBpmnModel(pi.getProcessDefinitionId());
// ID 为 流程定义Key
Process process = bpmnModel.getProcessById(pi.getProcessDefinitionKey());
UserTask userTask = (UserTask) process.getFlowElement(taskDefinitionKey);
List<SequenceFlow> outGoingFlows = userTask.getOutgoingFlows();
// 判断是否排他网关，是则获取下一节点
if (outGoingFlows.size() == 1) {
SequenceFlow sequenceFlow = outGoingFlows.get(0);
FlowElement nextElement = sequenceFlow.getTargetFlowElement();
if (nextElement instanceof ExclusiveGateway) {
outGoingFlows = ((ExclusiveGateway) nextElement).getOutgoingFlows();
}
}
return outGoingFlows;
}
- 配置连线信息
com.oldguy.example.modules.workflow.service.AbstractProcessInstanceService
@Override
public List<WorkBtn> getWorkBtnList(String processDefinitionId, String taskDefinitionKey, List<SequenceFlow> outPutLinks) {
List<WorkBtn> list = new ArrayList<>(outPutLinks.size());
Map<String, ProcessTaskConfig> processTaskConfigMap = processTaskConfigService.getProcessTaskConfigMap(className, processDefinitionId);
outPutLinks.forEach(obj -> {
// 配置连线信息
ProcessTaskConfig processTaskConfig = processTaskConfigMap.get(obj.getId());
if(null != processTaskConfig){
list.add(new WorkBtn(processTaskConfig.getBtn(), processTaskConfig.getUrl(), processTaskConfig.getFlowFlag()));
}
});
return list;
}
这样就完成，通过连线获取动态流程按钮。
com.oldguy.example.modules.workflow.service.UserTaskService 获取流程审核状态
public int updateAuditStatus(String processInstanceId) {
String auditCode = "";
HistoricProcessInstance historicProcessInstance = historyService.createHistoricProcessInstanceQuery().processInstanceId(processInstanceId).singleResult();
if (null != historicProcessInstance) {
// 流程已完成
if (null != historicProcessInstance.getEndTime()) {
ProcessAuditStatus processAuditStatus = processAuditStatusMapper.findByProcessDefinitionIdAndUserTask(historicProcessInstance.getProcessDefinitionId(), WorkFlowConfiguration.PROCESS_END_EVENT_FLAG);
if (null != processAuditStatus) {
auditCode = processAuditStatus.getAuditCode();
}
}else{
// 流程未完成
List<HistoricTaskInstance> taskList = historyService.createHistoricTaskInstanceQuery().processInstanceId(processInstanceId).orderByTaskCreateTime().desc().list();
if (!taskList.isEmpty()) {
HistoricTaskInstance historicTaskInstance = taskList.get(0);
ProcessAuditStatus processAuditStatus = processAuditStatusMapper.findByProcessDefinitionIdAndUserTask(historicTaskInstance.getProcessDefinitionId(), historicTaskInstance.getTaskDefinitionKey());
if (null != processAuditStatus) {
auditCode = processAuditStatus.getAuditCode();
}
}
}
}
// 更新业务
return commonWorkEntityService.updateAuditStatus(historicProcessInstance.getBusinessKey(),auditCode);
}
获取当前流程状态
/**
* 获取流程审核状态
*
* @param processInstanceId
* @return
*/
public int updateAuditStatus(String processInstanceId) {
String auditCode = "";
HistoricProcessInstance historicProcessInstance = historyService.createHistoricProcessInstanceQuery().processInstanceId(processInstanceId).singleResult();
if (null != historicProcessInstance) {
// 流程已完成
if (null != historicProcessInstance.getEndTime()) {
ProcessAuditStatus processAuditStatus = processAuditStatusMapper.findByProcessDefinitionIdAndUserTask(historicProcessInstance.getProcessDefinitionId(), WorkFlowConfiguration.PROCESS_END_EVENT_FLAG);
if (null != processAuditStatus) {
auditCode = processAuditStatus.getAuditCode();
}
} else {
// 流程未完成
List<HistoricTaskInstance> taskList = historyService.createHistoricTaskInstanceQuery().processInstanceId(processInstanceId).orderByTaskCreateTime().desc().list();
if (!taskList.isEmpty()) {
HistoricTaskInstance historicTaskInstance = taskList.get(0);
ProcessAuditStatus processAuditStatus = processAuditStatusMapper.findByProcessDefinitionIdAndUserTask(historicTaskInstance.getProcessDefinitionId(), historicTaskInstance.getTaskDefinitionKey());
if (null != processAuditStatus) {
auditCode = processAuditStatus.getAuditCode();
}
}
}
}
// 更新业务
return commonWorkEntityService.updateAuditStatus(historicProcessInstance.getBusinessKey(), auditCode);
}
网友评论