package org.dromara.workflow.service.impl;
|
|
import cn.hutool.core.bean.BeanUtil;
|
import cn.hutool.core.codec.Base64;
|
import cn.hutool.core.collection.CollUtil;
|
import cn.hutool.core.collection.CollectionUtil;
|
import cn.hutool.core.io.IoUtil;
|
import cn.hutool.core.util.ObjectUtil;
|
import lombok.RequiredArgsConstructor;
|
import lombok.SneakyThrows;
|
import org.apache.commons.io.IOUtils;
|
import org.dromara.common.core.exception.ServiceException;
|
import org.dromara.common.core.utils.StreamUtils;
|
import org.dromara.common.core.utils.StringUtils;
|
import org.dromara.common.mybatis.core.page.TableDataInfo;
|
import org.dromara.common.tenant.helper.TenantHelper;
|
import org.dromara.workflow.common.constant.FlowConstant;
|
import org.dromara.workflow.domain.WfCategory;
|
import org.dromara.workflow.domain.bo.ProcessDefinitionBo;
|
import org.dromara.workflow.domain.vo.ProcessDefinitionVo;
|
import org.dromara.workflow.service.IActProcessDefinitionService;
|
import org.dromara.workflow.service.IWfCategoryService;
|
import org.flowable.engine.HistoryService;
|
import org.flowable.engine.ProcessMigrationService;
|
import org.flowable.engine.RepositoryService;
|
import org.flowable.engine.impl.bpmn.deployer.ResourceNameUtil;
|
import org.flowable.engine.repository.*;
|
import org.flowable.task.api.history.HistoricTaskInstance;
|
import org.springframework.stereotype.Service;
|
import org.springframework.web.multipart.MultipartFile;
|
|
import java.io.IOException;
|
import java.io.InputStream;
|
import java.nio.charset.StandardCharsets;
|
import java.util.ArrayList;
|
import java.util.List;
|
import java.util.stream.Collectors;
|
import java.util.zip.ZipInputStream;
|
|
/**
|
* 流程定义 服务层实现
|
*
|
* @author may
|
*/
|
@RequiredArgsConstructor
|
@Service
|
public class ActProcessDefinitionServiceImpl implements IActProcessDefinitionService {
|
|
private final RepositoryService repositoryService;
|
|
private final HistoryService historyService;
|
|
private final ProcessMigrationService processMigrationService;
|
|
private final IWfCategoryService wfCategoryService;
|
|
/**
|
* 分页查询
|
*
|
* @param processDefinitionBo 参数
|
* @return 返回分页列表
|
*/
|
@Override
|
public TableDataInfo<ProcessDefinitionVo> page(ProcessDefinitionBo processDefinitionBo) {
|
ProcessDefinitionQuery query = repositoryService.createProcessDefinitionQuery();
|
if (TenantHelper.isEnable()) {
|
query.processDefinitionTenantId(TenantHelper.getTenantId());
|
}
|
if (StringUtils.isNotEmpty(processDefinitionBo.getKey())) {
|
query.processDefinitionKey(processDefinitionBo.getKey());
|
}
|
if (StringUtils.isNotEmpty(processDefinitionBo.getCategoryCode())) {
|
query.processDefinitionCategory(processDefinitionBo.getCategoryCode());
|
}
|
if (StringUtils.isNotEmpty(processDefinitionBo.getName())) {
|
query.processDefinitionNameLike("%" + processDefinitionBo.getName() + "%");
|
}
|
query.orderByDeploymentId().desc();
|
// 分页查询
|
List<ProcessDefinitionVo> processDefinitionVoList = new ArrayList<>();
|
List<ProcessDefinition> definitionList = query.latestVersion().listPage(processDefinitionBo.getPageNum(), processDefinitionBo.getPageSize());
|
List<Deployment> deploymentList = null;
|
if (CollUtil.isNotEmpty(definitionList)) {
|
List<String> deploymentIds = StreamUtils.toList(definitionList, ProcessDefinition::getDeploymentId);
|
deploymentList = repositoryService.createDeploymentQuery().deploymentIds(deploymentIds).list();
|
}
|
for (ProcessDefinition processDefinition : definitionList) {
|
ProcessDefinitionVo processDefinitionVo = BeanUtil.toBean(processDefinition, ProcessDefinitionVo.class);
|
if (CollUtil.isNotEmpty(deploymentList)) {
|
// 部署时间
|
deploymentList.stream().filter(e -> e.getId().equals(processDefinition.getDeploymentId())).findFirst().ifPresent(e -> {
|
processDefinitionVo.setDeploymentTime(e.getDeploymentTime());
|
});
|
}
|
processDefinitionVoList.add(processDefinitionVo);
|
}
|
// 总记录数
|
long total = query.count();
|
|
return new TableDataInfo<>(processDefinitionVoList, total);
|
}
|
|
/**
|
* 查询历史流程定义列表
|
*
|
* @param key 流程定义key
|
*/
|
@Override
|
public List<ProcessDefinitionVo> getProcessDefinitionListByKey(String key) {
|
List<ProcessDefinitionVo> processDefinitionVoList = new ArrayList<>();
|
ProcessDefinitionQuery query = repositoryService.createProcessDefinitionQuery();
|
if (TenantHelper.isEnable()) {
|
query.processDefinitionTenantId(TenantHelper.getTenantId());
|
}
|
List<ProcessDefinition> definitionList = query.processDefinitionKey(key).list();
|
List<Deployment> deploymentList = null;
|
if (CollUtil.isNotEmpty(definitionList)) {
|
List<String> deploymentIds = definitionList.stream().map(ProcessDefinition::getDeploymentId).collect(Collectors.toList());
|
deploymentList = repositoryService.createDeploymentQuery()
|
.deploymentIds(deploymentIds).list();
|
}
|
for (ProcessDefinition processDefinition : definitionList) {
|
ProcessDefinitionVo processDefinitionVo = BeanUtil.toBean(processDefinition, ProcessDefinitionVo.class);
|
if (CollUtil.isNotEmpty(deploymentList)) {
|
// 部署时间
|
deploymentList.stream().filter(e -> e.getId().equals(processDefinition.getDeploymentId())).findFirst().ifPresent(e -> {
|
processDefinitionVo.setDeploymentTime(e.getDeploymentTime());
|
});
|
}
|
processDefinitionVoList.add(processDefinitionVo);
|
}
|
return CollectionUtil.reverse(processDefinitionVoList);
|
}
|
|
/**
|
* 查看流程定义图片
|
*
|
* @param processDefinitionId 流程定义id
|
*/
|
@SneakyThrows
|
@Override
|
public String processDefinitionImage(String processDefinitionId) {
|
InputStream inputStream = repositoryService.getProcessDiagram(processDefinitionId);
|
return Base64.encode(IOUtils.toByteArray(inputStream));
|
}
|
|
/**
|
* 查看流程定义xml文件
|
*
|
* @param processDefinitionId 流程定义id
|
*/
|
@Override
|
public String processDefinitionXml(String processDefinitionId) {
|
StringBuilder xml = new StringBuilder();
|
ProcessDefinition processDefinition = repositoryService.getProcessDefinition(processDefinitionId);
|
InputStream inputStream;
|
try {
|
inputStream = repositoryService.getResourceAsStream(processDefinition.getDeploymentId(), processDefinition.getResourceName());
|
xml.append(IOUtils.toString(inputStream, StandardCharsets.UTF_8));
|
} catch (IOException e) {
|
e.printStackTrace();
|
}
|
return xml.toString();
|
}
|
|
/**
|
* 删除流程定义
|
*
|
* @param deploymentId 部署id
|
* @param processDefinitionId 流程定义id
|
*/
|
@Override
|
public boolean deleteDeployment(String deploymentId, String processDefinitionId) {
|
try {
|
List<HistoricTaskInstance> taskInstanceList = historyService.createHistoricTaskInstanceQuery()
|
.processDefinitionId(processDefinitionId).list();
|
if (CollectionUtil.isNotEmpty(taskInstanceList)) {
|
throw new ServiceException("当前流程定义已被使用不可删除！");
|
}
|
//删除流程定义
|
repositoryService.deleteDeployment(deploymentId);
|
return true;
|
} catch (Exception e) {
|
e.printStackTrace();
|
throw new ServiceException(e.getMessage());
|
}
|
}
|
|
/**
|
* 激活或者挂起流程定义
|
*
|
* @param processDefinitionId 流程定义id
|
*/
|
@Override
|
public boolean updateProcessDefState(String processDefinitionId) {
|
try {
|
ProcessDefinitionQuery query = repositoryService.createProcessDefinitionQuery();
|
if (TenantHelper.isEnable()) {
|
query.processDefinitionTenantId(TenantHelper.getTenantId());
|
}
|
ProcessDefinition processDefinition = query.processDefinitionId(processDefinitionId).singleResult();
|
//将当前为挂起状态更新为激活状态
|
//参数说明：参数1：流程定义id,参数2：是否激活（true是否级联对应流程实例，激活了则对应流程实例都可以审批），
|
//参数3：什么时候激活，如果为null则立即激活，如果为具体时间则到达此时间后激活
|
if (processDefinition.isSuspended()) {
|
repositoryService.activateProcessDefinitionById(processDefinitionId, true, null);
|
} else {
|
repositoryService.suspendProcessDefinitionById(processDefinitionId, true, null);
|
}
|
return true;
|
} catch (Exception e) {
|
e.printStackTrace();
|
throw new ServiceException("操作失败:" + e.getMessage());
|
}
|
}
|
|
/**
|
* 迁移流程定义
|
*
|
* @param currentProcessDefinitionId 当前流程定义id
|
* @param fromProcessDefinitionId 需要迁移到的流程定义id
|
*/
|
|
@Override
|
public boolean migrationProcessDefinition(String currentProcessDefinitionId, String fromProcessDefinitionId) {
|
try {
|
// 迁移验证
|
boolean migrationValid = processMigrationService.createProcessInstanceMigrationBuilder()
|
.migrateToProcessDefinition(currentProcessDefinitionId)
|
.validateMigrationOfProcessInstances(fromProcessDefinitionId)
|
.isMigrationValid();
|
if (!migrationValid) {
|
throw new ServiceException("流程定义差异过大无法迁移，请修改流程图");
|
}
|
// 已结束的流程实例不会迁移
|
processMigrationService.createProcessInstanceMigrationBuilder()
|
.migrateToProcessDefinition(currentProcessDefinitionId)
|
.migrateProcessInstances(fromProcessDefinitionId);
|
return true;
|
} catch (Exception e) {
|
throw new ServiceException(e.getMessage());
|
}
|
}
|
|
/**
|
* 流程定义转换为模型
|
*
|
* @param processDefinitionId 流程定义id
|
*/
|
@Override
|
public boolean convertToModel(String processDefinitionId) {
|
ProcessDefinition pd = repositoryService.createProcessDefinitionQuery()
|
.processDefinitionId(processDefinitionId).singleResult();
|
InputStream inputStream = repositoryService.getResourceAsStream(pd.getDeploymentId(), pd.getResourceName());
|
ModelQuery query = repositoryService.createModelQuery();
|
if (TenantHelper.isEnable()) {
|
query.modelTenantId(TenantHelper.getTenantId());
|
}
|
Model model = query.modelKey(pd.getKey()).singleResult();
|
try {
|
if (ObjectUtil.isNotNull(model)) {
|
repositoryService.addModelEditorSource(model.getId(), IoUtil.readBytes(inputStream));
|
} else {
|
Model modelData = repositoryService.newModel();
|
modelData.setKey(pd.getKey());
|
modelData.setName(pd.getName());
|
modelData.setTenantId(pd.getTenantId());
|
repositoryService.saveModel(modelData);
|
repositoryService.addModelEditorSource(modelData.getId(), IoUtil.readBytes(inputStream));
|
}
|
return true;
|
} catch (Exception e) {
|
e.printStackTrace();
|
throw new ServiceException(e.getMessage());
|
}
|
}
|
|
/**
|
* 通过zip或xml部署流程定义
|
*
|
* @param file 文件
|
* @param categoryCode 分类
|
*/
|
@Override
|
public boolean deployByFile(MultipartFile file, String categoryCode) {
|
try {
|
WfCategory wfCategory = wfCategoryService.queryByCategoryCode(categoryCode);
|
if (wfCategory == null) {
|
throw new ServiceException("流程分类不存在");
|
}
|
// 文件名 = 流程名称-流程key
|
String filename = file.getOriginalFilename();
|
assert filename != null;
|
String[] splitFilename = filename.substring(0, filename.lastIndexOf(".")).split("-");
|
if (splitFilename.length < 2) {
|
throw new ServiceException("流程分类不能为空(文件名 = 流程名称-流程key)");
|
}
|
//流程名称
|
String processName = splitFilename[0];
|
//流程key
|
String processKey = splitFilename[1];
|
// 文件后缀名
|
String suffix = filename.substring(filename.lastIndexOf(".") + 1).toUpperCase();
|
InputStream inputStream = file.getInputStream();
|
Deployment deployment;
|
if (FlowConstant.ZIP.equals(suffix)) {
|
DeploymentBuilder query = repositoryService.createDeployment();
|
if (TenantHelper.isEnable()) {
|
query.tenantId(TenantHelper.getTenantId());
|
}
|
deployment = query.addZipInputStream(new ZipInputStream(inputStream))
|
.name(processName).key(processKey).category(categoryCode).deploy();
|
} else {
|
String[] list = ResourceNameUtil.BPMN_RESOURCE_SUFFIXES;
|
boolean flag = false;
|
for (String str : list) {
|
if (filename.contains(str)) {
|
flag = true;
|
break;
|
}
|
}
|
if (flag) {
|
DeploymentBuilder query = repositoryService.createDeployment();
|
if (TenantHelper.isEnable()) {
|
query.tenantId(TenantHelper.getTenantId());
|
}
|
deployment = query.addInputStream(filename, inputStream)
|
.name(processName).key(processKey).category(categoryCode).deploy();
|
} else {
|
throw new ServiceException("文件类型上传错误！");
|
}
|
}
|
// 更新分类
|
ProcessDefinition definition = repositoryService.createProcessDefinitionQuery().deploymentId(deployment.getId()).singleResult();
|
repositoryService.setProcessDefinitionCategory(definition.getId(), categoryCode);
|
|
return true;
|
} catch (IOException e) {
|
e.printStackTrace();
|
throw new ServiceException("部署失败" + e.getMessage());
|
}
|
}
|
}
|
