package jnpf.workflow.flowable.service;
|
|
import java.time.ZoneId;
|
|
import org.flowable.engine.HistoryService;
|
import org.flowable.engine.RepositoryService;
|
import org.flowable.engine.RuntimeService;
|
import org.flowable.engine.history.HistoricProcessInstance;
|
import org.flowable.engine.repository.ProcessDefinition;
|
import org.flowable.engine.runtime.ProcessInstance;
|
import org.springframework.stereotype.Service;
|
|
import cn.hutool.core.collection.CollectionUtil;
|
import jnpf.workflow.common.exception.BizException;
|
import jnpf.workflow.common.exception.ResultCode;
|
import jnpf.workflow.common.model.fo.InstanceDeleteFo;
|
import jnpf.workflow.common.model.fo.InstanceStartFo;
|
import jnpf.workflow.common.model.vo.HistoricInstanceVo;
|
import jnpf.workflow.common.model.vo.InstanceVo;
|
import jnpf.workflow.common.service.IInstanceService;
|
import lombok.RequiredArgsConstructor;
|
import lombok.extern.slf4j.Slf4j;
|
|
@Slf4j
|
@Service
|
@RequiredArgsConstructor
|
public class InstanceServiceImpl implements IInstanceService {
|
|
private final RepositoryService repositoryService;
|
private final RuntimeService runtimeService;
|
private final HistoryService historyService;
|
|
@Override
|
public InstanceVo startById(InstanceStartFo fo) {
|
ProcessDefinition definition = repositoryService.createProcessDefinitionQuery().deploymentId(fo.getDeploymentId()).singleResult();
|
if (null == definition) {
|
throw new BizException(ResultCode.DEFINITION_NOT_EXIST);
|
}
|
InstanceVo vo = new InstanceVo();
|
ProcessInstance instance = CollectionUtil.isNotEmpty(fo.getVariables())
|
? runtimeService.startProcessInstanceById(definition.getId(), fo.getVariables())
|
: runtimeService.startProcessInstanceById(definition.getId());
|
if (null != instance) {
|
vo.setInstanceId(instance.getId());
|
}
|
return vo;
|
}
|
|
@Override
|
public HistoricInstanceVo getHistoricProcessInstance(String processInstanceId) {
|
HistoricProcessInstance historicInstance = historyService.createHistoricProcessInstanceQuery()
|
.processInstanceId(processInstanceId).singleResult();
|
if (null == historicInstance) {
|
throw new BizException(ResultCode.INSTANCE_NOT_EXIST);
|
}
|
HistoricInstanceVo vo = new HistoricInstanceVo();
|
vo.setInstanceId(historicInstance.getId());
|
vo.setStartTime(historicInstance.getStartTime().toInstant().atZone(ZoneId.systemDefault()).toLocalDateTime());
|
vo.setEndTime(historicInstance.getEndTime() == null ? null
|
: historicInstance.getEndTime().toInstant().atZone(ZoneId.systemDefault()).toLocalDateTime());
|
vo.setDurationInMillis(historicInstance.getDurationInMillis());
|
vo.setDeleteReason(historicInstance.getDeleteReason());
|
return vo;
|
}
|
|
@Override
|
public boolean deleteInstance(InstanceDeleteFo fo) {
|
try {
|
runtimeService.deleteProcessInstance(fo.getInstanceId(), fo.getDeleteReason());
|
return true;
|
} catch (Exception e) {
|
log.error(ResultCode.DELETE_FAILURE.getMsg(), e);
|
return false;
|
}
|
}
|
}
|
