From de04015a9eaf4a9928a1cba6cdfceed03146a720 Mon Sep 17 00:00:00 2001
From: xiangpei <xiangpei@timesnew.cn>
Date: 星期五, 29 十一月 2024 20:06:07 +0800
Subject: [PATCH] 项目启动流程、变更流程逻辑调整
---
business/src/main/resources/mapper/ProjectProcessMapper.xml | 4 +
business/src/main/java/com/ycl/service/impl/ProjectProcessServiceImpl.java | 70 ++++++++++++++++++++++-------------
business/src/main/java/com/ycl/controller/ProjectProcessController.java | 4 +-
business/src/main/java/com/ycl/service/ProjectProcessService.java | 2
4 files changed, 50 insertions(+), 30 deletions(-)
diff --git a/business/src/main/java/com/ycl/controller/ProjectProcessController.java b/business/src/main/java/com/ycl/controller/ProjectProcessController.java
index 31de96f..f264714 100644
--- a/business/src/main/java/com/ycl/controller/ProjectProcessController.java
+++ b/business/src/main/java/com/ycl/controller/ProjectProcessController.java
@@ -42,7 +42,7 @@
@PostMapping("/set")
- @ApiOperation(value = "椤圭洰璁剧疆娴佺▼", notes = "椤圭洰璁剧疆娴佺▼")
+ @ApiOperation(value = "椤圭洰鍙樻洿娴佺▼", notes = "椤圭洰鍙樻洿娴佺▼")
// @PreAuthorize("@ss.hasPermi('projectProcess:set')")
public Result projectSetProcess(@RequestBody @Validated ProjectProcessForm form) {
return projectProcessService.projectSetProcess(form);
@@ -59,7 +59,7 @@
@PostMapping("/start/{projectId}/{processDefId}")
@ApiOperation(value = "鍚姩娴佺▼", notes = "鍚姩娴佺▼")
// @PreAuthorize("@ss.hasPermi('projectProcess:start')")
- public Result startProcess(@PathVariable("projectId") String projectId, @PathVariable("processDefId") String processDefId) {
+ public Result startProcess(@PathVariable("projectId") Long projectId, @PathVariable("processDefId") String processDefId) {
return projectProcessService.startProcess(projectId, processDefId);
}
diff --git a/business/src/main/java/com/ycl/service/ProjectProcessService.java b/business/src/main/java/com/ycl/service/ProjectProcessService.java
index 7ef2719..80a5fbd 100644
--- a/business/src/main/java/com/ycl/service/ProjectProcessService.java
+++ b/business/src/main/java/com/ycl/service/ProjectProcessService.java
@@ -47,7 +47,7 @@
* @param projectId 椤圭洰id锛屼綔涓轰笟鍔d瀛樺叆activity琛�
* @return
*/
- Result startProcess(String projectId, String processDefId);
+ Result startProcess(Long projectId, String processDefId);
/**
* 鏌ヨ浠诲姟鍒楄〃
diff --git a/business/src/main/java/com/ycl/service/impl/ProjectProcessServiceImpl.java b/business/src/main/java/com/ycl/service/impl/ProjectProcessServiceImpl.java
index 3dd0831..92336c5 100644
--- a/business/src/main/java/com/ycl/service/impl/ProjectProcessServiceImpl.java
+++ b/business/src/main/java/com/ycl/service/impl/ProjectProcessServiceImpl.java
@@ -85,52 +85,69 @@
}
@Override
+ @Transactional(rollbackFor = Exception.class)
public Result projectSetProcess(ProjectProcessForm form) {
// 鏌ヨ璇ラ」鐩槸鍚﹀凡缁忕粦瀹氳繃娴佺▼浜嗭紝妫�鏌ョ粦瀹氱殑娴佺▼鏄惁鍦ㄨ繍琛岋紝鍦ㄨ繍琛屽氨鍒犱簡
ProjectProcess pp = new LambdaQueryChainWrapper<>(baseMapper)
.eq(ProjectProcess::getProjectId, form.getProjectId())
.one();
- if (Objects.nonNull(pp)) {
- // TODO 澶勭悊涔嬪墠缁戝畾杩囩殑娴佺▼鏁版嵁
- new LambdaUpdateChainWrapper<>(baseMapper)
- .eq(ProjectProcess::getProjectId, form.getProjectId())
- .set(ProjectProcess::getProcessDefId, form.getProcessDefId())
- .update();
- } else {
- ProjectProcess entity = ProjectProcessForm.getEntityByForm(form, null);
- baseMapper.insert(entity);
+ if (Objects.isNull(pp)) {
+ throw new RuntimeException("璇ラ」鐩湭缁戝畾娴佺▼");
}
+ if (Objects.nonNull(pp.getProcessInsId())) {
+ HistoricProcessInstance historicProcessInstance =
+ historyService.createHistoricProcessInstanceQuery().processInstanceId(pp.getProcessInsId()).singleResult();
+ // 鍒犻櫎涔嬪墠娴佺▼鐨勬暟鎹�
+ if (historicProcessInstance.getEndTime() != null) {
+ historyService.deleteHistoricProcessInstance(historicProcessInstance.getId());
+ } else {
+ // 鍒犻櫎娴佺▼瀹炰緥
+ runtimeService.deleteProcessInstance(pp.getProcessInsId(), "");
+ // 鍒犻櫎鍘嗗彶娴佺▼瀹炰緥
+ historyService.deleteHistoricProcessInstance(pp.getProcessInsId());
+ }
+ }
+ String processInsId = this.startPro(form.getProjectId(), form.getProcessDefId());
+ new LambdaUpdateChainWrapper<>(baseMapper)
+ .eq(ProjectProcess::getProjectId, form.getProjectId())
+ .set(ProjectProcess::getProcessDefId, form.getProcessDefId())
+ .set(ProjectProcess::getProcessInsId, processInsId)
+ .update();
return Result.ok("娴佺▼鍙樻洿鎴愬姛");
}
@Override
@Transactional(rollbackFor = Exception.class)
- public Result startProcess(String projectId, String processDefId) {
+ public Result startProcess(Long projectId, String processDefId) {
+ String processInsId = this.startPro(projectId, processDefId);
+ ProjectProcess entity = new ProjectProcess();
+ entity.setProjectId(projectId);
+ entity.setProcessDefId(processDefId);
+ entity.setProcessInsId(processInsId);
+ baseMapper.insert(entity);
+ return Result.ok("娴佺▼鍚姩鎴愬姛");
+ }
+
+ /**
+ * 鍚姩娴佺▼
+ *
+ * @param projectId
+ * @param processDefId
+ * @return
+ */
+ private String startPro(Long projectId, String processDefId) {
ProcessDefinition processDefinition = repositoryService.createProcessDefinitionQuery().processDefinitionId(processDefId)
.latestVersion().singleResult();
if (Objects.nonNull(processDefinition) && processDefinition.isSuspended()) {
- return Result.error("璇ユ祦绋嬪凡琚寕璧�,璇峰厛婵�娲绘祦绋�");
+ throw new RuntimeException("璇ユ祦绋嬪凡琚寕璧�,璇峰厛婵�娲绘祦绋�");
}
Map<String, Object> variables = new HashMap<>(2);
// 璁剧疆娴佺▼鍙戣捣浜篒d鍒版祦绋嬩腑
SysUser sysUser = SecurityUtils.getLoginUser().getUser();
identityService.setAuthenticatedUserId(sysUser.getUserId().toString());
variables.put(ProcessConstants.PROCESS_INITIATOR, sysUser.getUserId());
- ProcessInstance processInstance = runtimeService.startProcessInstanceById(processDefId, projectId, variables);
-// // 娴佺▼鍙戣捣鏃� 璺宠繃鍙戣捣浜鸿妭鐐�
-// // 缁欑涓�姝ョ敵璇蜂汉鑺傜偣璁剧疆浠诲姟鎵ц浜哄拰鎰忚
-// Task task = taskService.createTaskQuery().processInstanceId(processInstance.getProcessInstanceId()).singleResult();
-// if (Objects.nonNull(task)) {
-// taskService.addComment(task.getId(), processInstance.getProcessInstanceId(), FlowComment.NORMAL.getType(), sysUser.getNickName() + "鍙戣捣娴佺▼鐢宠");
-// taskService.complete(task.getId(), variables);
-// }
- // 椤圭洰娴佺▼鍏宠仈娴佺▼瀹炰緥id
- new LambdaUpdateChainWrapper<>(baseMapper)
- .eq(ProjectProcess::getProjectId, projectId)
- .eq(ProjectProcess::getProcessDefId, processDefId)
- .set(ProjectProcess::getProcessInsId, processInstance.getProcessInstanceId())
- .update();
- return Result.ok("娴佺▼鍚姩鎴愬姛");
+ ProcessInstance processInstance = runtimeService.startProcessInstanceById(processDefId, projectId + "", variables);
+ return processInstance.getId();
}
/**
@@ -458,6 +475,7 @@
* @param identityLinkInfos 濡傛灉鏄凡瀹屾垚鐨勪换鍔★紝鐢ㄨ繖涓幓鍙栧叧鑱旂殑鐢ㄦ埛/鐢ㄦ埛缁�
*/
private void setPromoterAndHandler(CustomerTaskVO taskVO, List<? extends IdentityLinkInfo> identityLinkInfos) {
+ // TODO 鍙戣捣浜烘槸鍚﹀簲涓轰笂涓�鑺傜偣鐨勫鐞嗕汉
// 娴佺▼鍙戣捣浜轰俊鎭�
HistoricProcessInstance historicProcessInstance = historyService.createHistoricProcessInstanceQuery()
.processInstanceId(taskVO.getProcessInsId())
diff --git a/business/src/main/resources/mapper/ProjectProcessMapper.xml b/business/src/main/resources/mapper/ProjectProcessMapper.xml
index ae53deb..7fe3996 100644
--- a/business/src/main/resources/mapper/ProjectProcessMapper.xml
+++ b/business/src/main/resources/mapper/ProjectProcessMapper.xml
@@ -38,6 +38,7 @@
<result column="update_by" property="updateBy" />
<result column="create_by" property="createBy" />
<result column="process_def_id" property="processDefId" />
+ <result column="process_ins_id" property="processInsId" />
<!-- <association property="id" column=""-->
</resultMap>
@@ -59,7 +60,8 @@
<select id="getPage" resultMap="BaseResultMap">
SELECT
PI.*,
- TPP.process_def_id
+ TPP.process_def_id,
+ TPP.process_ins_id
FROM
t_project_info PI
LEFT JOIN t_project_process TPP ON TPP.project_id = PI.id AND TPP.deleted = 0 AND PI.deleted = 0
--
Gitblit v1.8.0