ZQ/laws-sinotruk-server
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat: 启用流程保存接口

Browse Source
This commit is contained in:
mzaxd
2023-11-21 16:20:49 +08:00
parent 167fca6314
commit 206c425bf4
1 changed files with 24 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files
laws-modules/src/main/java/com/jero/modules/activiti/process/esEnable/service/impl/ProcessEsEnableServiceImpl.java
+24 -9
View File
@@ -17,8 +17,10 @@ import com.jero.modules.activiti.process.esEnable.entity.ProcessEsEnable;
import com.jero.modules.activiti.process.esEnable.entity.vo.ESEnableDataVO;
import com.jero.modules.activiti.process.esEnable.service.ProcessEsEnableService;
import com.jero.modules.activiti.process.esEnable.mapper.ProcessEsEnableMapper;
import com.jero.modules.activiti.process.esRecheck.entity.ProcessEsRecheck;
import com.jero.modules.activiti.service.ProcessAllService;
import com.jero.modules.activiti.service.ProcessNodeLinkService;
import com.jero.modules.laws.common.util.CurrentUserUtil;
import com.jero.modules.sys.utils.UserUtils;
import lombok.extern.slf4j.Slf4j;
import org.activiti.engine.RuntimeService;
@@ -125,30 +127,43 @@ public class ProcessEsEnableServiceImpl extends ServiceImpl<ProcessEsEnableMappe
CommonVO commonVO = enableDataVO.getCommon();
String taskId = commonVO.getTaskId();
ProcessEsEnable esEnable = enableDataVO.getData();
saveOrUpdate(esEnable);
// 先删后增
LambdaUpdateWrapper<ProcessDraft> draftWrapper = new LambdaUpdateWrapper<>();
if (StrUtil.isBlank(taskId)) {
// 第一个节点点击保存没有taskId
String projectId = esEnable.getId();
if (StrUtil.isBlank(projectId)) {
save(esEnable);
} else {
// 先删后增
LambdaUpdateWrapper<ProcessDraft> draftWrapper = new LambdaUpdateWrapper<>();
draftWrapper.eq(ProcessDraft::getPrcType, ProcessTypeEnum.ES_ENABLE.getValue());
draftWrapper.eq(ProcessDraft::getCreateBy, UserUtils.getUserId());
draftWrapper.eq(ProcessDraft::getProjectId, projectId);
processDraftService.remove(draftWrapper);
saveOrUpdate(esEnable);
}
String id = esEnable.getId();
if (StrUtil.isBlank(taskId)) {
// 第一个节点点击保存没有taskId
List<ProcessDraft> draftList = new ArrayList<>();
ProcessDraft draft = new ProcessDraft();
draft.setProjectId(esEnable.getId());
draft.setProjectId(id);
draft.setPrcType(ProcessTypeEnum.ES_ENABLE.getValue());
draft.setPrcName(commonVO.getPrcName());
draft.setHandleText(commonVO.getCommitText()); // 流程审批信息-备注
draft.setHandleFile(commonVO.getCommitFile()); // 流程审批信息-附件
draft.setUserId(CurrentUserUtil.getId()); // 用户id
draftList.add(draft);
processDraftService.saveBatch(draftList);
} else {
String processInstanceId = actFlowCommonService.getProcessInstanceIdByTaskId(taskId);
draftWrapper.eq(ProcessDraft::getProjectId, esEnable.getId());
processDraftService.remove(draftWrapper);
List<ProcessDraft> draftList = new ArrayList<>();
ProcessDraft draft = new ProcessDraft();
draft.setProjectId(esEnable.getId());
draft.setProjectId(id);
draft.setProcessInstanceId(processInstanceId);
draft.setPrcName(commonVO.getPrcName());
draft.setPrcType(ProcessTypeEnum.ES_ENABLE.getValue());
draft.setTaskId(taskId); // 任务id
draft.setHandleText(commonVO.getCommitText()); // 流程审批信息-备注
draft.setHandleFile(commonVO.getCommitFile()); // 流程审批信息-附件
draft.setUserId(CurrentUserUtil.getId()); // 用户id
draftList.add(draft);
processDraftService.saveBatch(draftList);
}