From 34981c30a78e8bbd7791131059a9210f9928b62c Mon Sep 17 00:00:00 2001
From: 刘光辉 <347230014@qq.com>
Date: 星期四, 17 九月 2026 09:24:09 +0800
Subject: [PATCH] Merge remote-tracking branch 'origin/master' into master
---
jnpf-flow-engine/src/main/java/jnpf/workflow/flowable/service/InstanceServiceImpl.java | 76 ++++++++++++++++++++++++++++++++++++++
1 files changed, 76 insertions(+), 0 deletions(-)
diff --git a/jnpf-flow-engine/src/main/java/jnpf/workflow/flowable/service/InstanceServiceImpl.java b/jnpf-flow-engine/src/main/java/jnpf/workflow/flowable/service/InstanceServiceImpl.java
new file mode 100644
index 0000000..c265c01
--- /dev/null
+++ b/jnpf-flow-engine/src/main/java/jnpf/workflow/flowable/service/InstanceServiceImpl.java
@@ -0,0 +1,76 @@
+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;
+ }
+ }
+}
--
Gitblit v1.8.0