射洪市项目管理系统
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
zxl
2025-03-20 baf60bc658c1bfb7fc0dd79d2bfc03abcb126488 
 business/src/main/java/com/ycl/service/impl/FlowTaskServiceImpl.java


@@ -23,9 +23,11 @@


import com.ycl.domain.dto.FlowTaskDto;


import com.ycl.domain.dto.FlowViewerDto;


import com.ycl.domain.entity.ProcessCoding;


import com.ycl.domain.entity.ProcessLog;


import com.ycl.domain.entity.ProjectProcess;


import com.ycl.domain.entity.SysForm;


import com.ycl.domain.json.RejectData;


import com.ycl.domain.vo.DoFormDetailVO;


import com.ycl.domain.vo.FlowQueryVo;


import com.ycl.domain.vo.FlowTaskVo;


import com.ycl.domain.vo.FormDetailVO;


@@ -68,6 +70,7 @@


import org.flowable.task.api.TaskQuery;


import org.flowable.task.api.history.HistoricTaskInstance;


import org.flowable.task.api.history.HistoricTaskInstanceQuery;


import org.springframework.beans.BeanUtils;


import org.springframework.context.ApplicationEventPublisher;


import org.springframework.stereotype.Service;


import org.springframework.transaction.annotation.Transactional;


@@ -152,28 +155,18 @@


            return AjaxResult.error("项目流程未绑定");


        }




        Map<String, Object> processVariables = new HashMap<>();


        //查出字典中需要注入的字段信息


        // 查出字典中需要注入的字段信息


        List<String> dictList = sysDictDService.selectDictDataByType("flow_variables").stream().map(SysDictData::getDictValue).collect(Collectors.toList());


        Map<String, Object> newV = new HashMap<>(2);


        if (!org.springframework.util.CollectionUtils.isEmpty(variables)) {


            for (String key : variables.keySet()) {


                newV.put(task.getTaskDefinitionKey() + "&" + key, variables.get(key));


                //字典里有就放入流程变量中


                // 字典里有就不做处理


                if (!CollectionUtils.isEmpty(dictList) && dictList.contains(key)) {


                    if ("money".equals(key)) {


                        // 万元转元


                        Object w = variables.get(key);


                        BigDecimal y = new BigDecimal(w.toString()).multiply(new BigDecimal(10000));


                        processVariables.put(key, y);


                    } else {


                        processVariables.put(key,variables.get(key));


                    }


                    newV.put(key,variables.get(key));


                }


            }


        }


        //添加流程变量


        if(!processVariables.isEmpty()) taskService.setVariables(taskId,processVariables);


        taskService.addComment(taskId, task.getProcessInstanceId(), FlowComment.SUBMIT.getType(), "完成提交");


        if (DelegationState.PENDING.equals(task.getDelegationState())) {


            taskService.resolveTask(taskId, newV);


@@ -188,6 +181,7 @@


                projectProcess.getProjectId(),


                projectProcess.getProcessInsId(),


                taskId,


                task.getTaskDefinitionKey(),


                task.getName(),


                ProcessLogEventTypeEnum.FINISHED,


                null));


@@ -329,6 +323,7 @@


                projectProcess.getProjectId(),


                projectProcess.getProcessInsId(),


                flowTaskVo.getTaskId(),


                task.getTaskDefinitionKey(),


                task.getName(),


                ProcessLogEventTypeEnum.REJECT,


                new RejectData(flowTaskVo.getComment())));


@@ -1191,8 +1186,9 @@


                    .list();




            //扩展 获取这个流程实例的监控信息 key:TaskId value:实体类


            Map<String, ProcessCoding> processCodingMap = processCodingMapper


                    .selectList(new QueryWrapper<ProcessCoding>().eq("process_ins_id", procInsId))


            Map<String, ProcessCoding> processCodingMap = new LambdaQueryChainWrapper<>(processCodingMapper)


                    .eq(ProcessCoding::getProcessInsId, procInsId)


                    .list()


                    .stream()


                    .collect(Collectors.toMap(ProcessCoding::getTaskId, Function.identity()));


            // 保存已经完成的流程节点编号


@@ -1276,17 +1272,35 @@


            if (node.getCurrent()) {


                return Boolean.TRUE;


            }


            HistoricTaskInstance beforeTask = historyService.createHistoricTaskInstanceQuery().processInstanceId(finalProcessInsId).finished().taskDefinitionKey(node.getBeforeNodeDefId()).singleResult();


            return Objects.nonNull(beforeTask);


            List<HistoricTaskInstance> beforeTasks = historyService.createHistoricTaskInstanceQuery()


                    .processInstanceId(finalProcessInsId)


                    .finished()


                    .taskDefinitionKey(node.getBeforeNodeDefId())


                    .orderByTaskCreateTime()


                    .desc()


                    .list();


            return CollectionUtils.isNotEmpty(beforeTasks) && Objects.nonNull(beforeTasks.get(0));


        }).collect(Collectors.toList());


        beforeNodes.forEach(node -> {


        List<DoFormDetailVO> vos = beforeNodes.stream().map(node -> {


            if (node.getCurrent()) {


                if (processLogService.taskIsHangup(taskId, finalProcessInsId)) {


                    node.setTaskStatus(TaskStatusEnum.HANGUP);


                }


            }


        });


        return AjaxResult.success(beforeNodes);


            // 判断任务是否存在特殊操作(如跳过、转办等)，需要在前端展示出来


            List<ProcessLog> logList = new LambdaQueryChainWrapper<>(processLogService.getBaseMapper())


                    .eq(ProcessLog::getTaskDefKey, node.getBeforeNodeDefId())


                    .eq(ProcessLog::getProcessInsId, finalProcessInsId)


                    .orderByDesc(ProcessLog::getGmtCreate)


                    .list();


            DoFormDetailVO vo = new DoFormDetailVO();


            BeanUtils.copyProperties(node, vo);


            if (CollectionUtils.isNotEmpty(logList)) {


                vo.setEvents(logList);


            }


            return vo;


        }).collect(Collectors.toList());


        return AjaxResult.success(vos);


    }




    @Override


@@ -1309,7 +1323,26 @@


                HistoricTaskInstance beforeTask = historyService.createHistoricTaskInstanceQuery().processInstanceId(hisTask.getProcessInstanceId()).finished().taskDefinitionKey(node.getBeforeNodeDefId()).singleResult();


                return Objects.nonNull(beforeTask);


            }).collect(Collectors.toList());


            return AjaxResult.success(dataList);


            List<DoFormDetailVO> vos = dataList.stream().map(node -> {


                if (node.getCurrent()) {


                    if (processLogService.taskIsHangup(taskId, hisTask.getProcessInstanceId())) {


                        node.setTaskStatus(TaskStatusEnum.HANGUP);


                    }


                }


                // 判断任务是否存在特殊操作(如跳过、转办等)，需要在前端展示出来


                List<ProcessLog> logList = new LambdaQueryChainWrapper<>(processLogService.getBaseMapper())


                        .eq(ProcessLog::getTaskId, hisTask.getId())


                        .eq(ProcessLog::getProcessInsId, hisTask.getProcessInstanceId())


                        .orderByDesc(ProcessLog::getGmtCreate)


                        .list();


                DoFormDetailVO vo = new DoFormDetailVO();


                BeanUtils.copyProperties(node, vo);


                if (CollectionUtils.isNotEmpty(logList)) {


                    vo.setEvents(logList);


                }


                return vo;


            }).collect(Collectors.toList());


            return AjaxResult.success(vos);


        } else {


            parameters = taskService.getVariables(taskId);


            List<FormDetailVO> beforeNodes = this.getBeforeNodeForm(parameters, task.getFormKey(), task.getName(), task.getProcessDefinitionId(), task.getTaskDefinitionKey(), Boolean.TRUE);


@@ -1317,10 +1350,35 @@


                if (node.getCurrent()) {


                    return Boolean.TRUE;


                }


                HistoricTaskInstance beforeTask = historyService.createHistoricTaskInstanceQuery().processInstanceId(task.getProcessInstanceId()).finished().taskDefinitionKey(node.getBeforeNodeDefId()).singleResult();


                return Objects.nonNull(beforeTask);


                List<HistoricTaskInstance> beforeTaskList = historyService.createHistoricTaskInstanceQuery()


                        .processInstanceId(task.getProcessInstanceId())


                        .finished()


                        .taskDefinitionKey(node.getBeforeNodeDefId())


                        .orderByTaskCreateTime()


                        .desc()


                        .list();


                return CollectionUtils.isNotEmpty(beforeTaskList) && Objects.nonNull(beforeTaskList.get(0));


            }).collect(Collectors.toList());


            return AjaxResult.success(dataList);


            List<DoFormDetailVO> vos = dataList.stream().map(node -> {


                if (node.getCurrent()) {


                    if (processLogService.taskIsHangup(taskId, task.getProcessInstanceId())) {


                        node.setTaskStatus(TaskStatusEnum.HANGUP);


                    }


                }


                // 判断任务是否存在特殊操作(如跳过、转办等)，需要在前端展示出来


                List<ProcessLog> logList = new LambdaQueryChainWrapper<>(processLogService.getBaseMapper())


                        .eq(ProcessLog::getTaskId, task.getId())


                        .eq(ProcessLog::getProcessInsId, task.getProcessInstanceId())


                        .orderByDesc(ProcessLog::getGmtCreate)


                        .list();


                DoFormDetailVO vo = new DoFormDetailVO();


                BeanUtils.copyProperties(node, vo);


                if (CollectionUtils.isNotEmpty(logList)) {


                    vo.setEvents(logList);


                }


                return vo;


            }).collect(Collectors.toList());


            return AjaxResult.success(vos);


        }


    }