From af73b1917e58e37daaa3e63f5303da1056cedfa3 Mon Sep 17 00:00:00 2001 From: wang1 <844966816@qq.com> Date: 星期四, 13 七月 2023 18:18:26 +0800 Subject: [PATCH] 修复生命周期调试异常,整理流程代码 --- Source/UBCS/ubcs-ops/ubcs-flow/src/main/java/com/vci/ubcs/flow/engine/service/impl/FlowTaskUserServiceImpl.java | 60 +++++++----------------------------------------------------- 1 files changed, 7 insertions(+), 53 deletions(-) diff --git a/Source/UBCS/ubcs-ops/ubcs-flow/src/main/java/com/vci/ubcs/flow/engine/service/impl/FlowTaskUserServiceImpl.java b/Source/UBCS/ubcs-ops/ubcs-flow/src/main/java/com/vci/ubcs/flow/engine/service/impl/FlowTaskUserServiceImpl.java index 993a297..09aba05 100644 --- a/Source/UBCS/ubcs-ops/ubcs-flow/src/main/java/com/vci/ubcs/flow/engine/service/impl/FlowTaskUserServiceImpl.java +++ b/Source/UBCS/ubcs-ops/ubcs-flow/src/main/java/com/vci/ubcs/flow/engine/service/impl/FlowTaskUserServiceImpl.java @@ -17,68 +17,22 @@ package com.vci.ubcs.flow.engine.service.impl; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; -import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; -import com.fasterxml.jackson.databind.ObjectMapper; -import com.fasterxml.jackson.databind.node.ObjectNode; -import com.vci.ubcs.flow.core.entity.BladeFlow; -import com.vci.ubcs.flow.core.enums.FlowModeEnum; +import com.vci.ubcs.flow.core.dto.FlowTaskDTO; +import com.vci.ubcs.flow.core.entity.FlowTaskUser; +import com.vci.ubcs.flow.core.entity.ProcessTemplate; import com.vci.ubcs.flow.core.utils.TaskUtil; -import com.vci.ubcs.flow.engine.constant.FlowEngineConstant; import com.vci.ubcs.flow.engine.entity.*; -import com.vci.ubcs.flow.engine.mapper.FlowMapper; import com.vci.ubcs.flow.engine.mapper.FlowTaskUserMapper; import com.vci.ubcs.flow.engine.mapper.ProcessTemplateMapper; import com.vci.ubcs.flow.engine.service.FlowEngineService; import com.vci.ubcs.flow.engine.service.FlowTaskUserService; -import com.vci.ubcs.flow.engine.utils.FlowCache; -import com.vci.ubcs.system.user.cache.UserCache; -import com.vci.ubcs.system.user.entity.User; import lombok.AllArgsConstructor; import lombok.extern.slf4j.Slf4j; -import org.apache.commons.lang3.StringUtils; -import org.flowable.bpmn.converter.BpmnXMLConverter; -import org.flowable.bpmn.model.BpmnModel; -import org.flowable.bpmn.model.Process; -import org.flowable.common.engine.impl.util.IoUtil; -import org.flowable.common.engine.impl.util.io.StringStreamSource; -import org.flowable.editor.language.json.converter.BpmnJsonConverter; -import org.flowable.engine.*; -import org.flowable.engine.history.HistoricActivityInstance; -import org.flowable.engine.history.HistoricProcessInstance; -import org.flowable.engine.impl.persistence.entity.ExecutionEntityImpl; -import org.flowable.engine.impl.persistence.entity.ProcessDefinitionEntityImpl; -import org.flowable.engine.repository.Deployment; -import org.flowable.engine.repository.ProcessDefinition; -import org.flowable.engine.repository.ProcessDefinitionQuery; -import org.flowable.engine.runtime.ProcessInstance; -import org.flowable.engine.runtime.ProcessInstanceQuery; -import org.flowable.engine.task.Comment; -import org.flowable.image.ProcessDiagramGenerator; -import org.springblade.core.launch.constant.FlowConstant; import org.springblade.core.log.exception.ServiceException; import org.springblade.core.mp.support.Condition; -import org.springblade.core.secure.utils.AuthUtil; -import org.springblade.core.tool.utils.DateUtil; -import org.springblade.core.tool.utils.FileUtil; -import org.springblade.core.tool.utils.Func; -import org.springblade.core.tool.utils.StringUtil; import org.springframework.stereotype.Service; -import org.springframework.transaction.annotation.Transactional; -import org.springframework.web.multipart.MultipartFile; -import org.w3c.dom.Document; -import org.w3c.dom.Element; -import org.w3c.dom.NodeList; -import org.xml.sax.InputSource; -import javax.annotation.Resource; -import javax.servlet.http.HttpServletResponse; -import javax.xml.parsers.DocumentBuilder; -import javax.xml.parsers.DocumentBuilderFactory; -import java.io.IOException; -import java.io.InputStream; -import java.io.OutputStream; -import java.io.StringReader; import java.util.*; /** @@ -120,7 +74,7 @@ QueryWrapper<FlowTaskUser> queryWrapper = new QueryWrapper<>(); queryWrapper.eq("CREATED_BY", TaskUtil.getTaskUser()); List<FlowTaskUser> flowTaskUsers = baseMapper.selectList(queryWrapper); - List<FlowTaskUserC> cl = new ArrayList<>(); + List<FlowTaskDTO> cl = new ArrayList<>(); Map<String,List<FlowTaskUser>> nameMap = new HashMap<>(); for(FlowTaskUser flowTaskUser:flowTaskUsers){ @@ -136,7 +90,7 @@ } for (String name:nameMap.keySet()){ - FlowTaskUserC flowTaskUserCR = new FlowTaskUserC(); + FlowTaskDTO flowTaskUserCR = new FlowTaskDTO(); flowTaskUserCR.setName(name);//鏀惰棌鍚嶇О flowTaskUserCR.setModelKey(nameMap.get(name).get(0).getModelKey()); flowTaskUserCR.setModelName(nameMap.get(name).get(0).getModelName()); @@ -146,13 +100,13 @@ kv.put("collect",cl); //鏁版嵁鑺傜偣鏁版嵁 - List<Map<String,String>> tl = flowEngineService.getNodeByFlowableKey(processTemplate.getModelKey()); + List<FlowTaskDTO> tl = flowEngineService.getNodeByFlowableKey(processTemplate.getModelKey()); kv.put("user",tl); return kv; } @Override - public void saveOrUpdateUser(FlowTaskUserC flowTaskUserC){ + public void saveOrUpdateUser(FlowTaskDTO flowTaskUserC){ List<FlowTaskUser> flowTaskUsers = flowTaskUserC.getFlowTaskUsers(); String name = flowTaskUserC.getName();//鏀惰棌鍚嶇О -- Gitblit v1.9.3