赋码任务调整

fuliqi

2025-01-10 78667db7845e68c59cea853db3fee67c1611d239

 business/src/main/java/com/ycl/task/FlowableTask.java

@@ -33,6 +33,7 @@
    private ProjectInfoMapper projectInfoMapper;
    @Autowired
    private ProcessCodingMapper processCodingMapper;

    /**
     * 赋码任务
     * 两个逻辑 改项目码、改节点颜色
@@ -45,11 +46,14 @@
        List<String> taskIds = taskList.stream().map(TaskInfo::getId).collect(Collectors.toList());
        //需要监控的赋码任务
        List<ProcessCoding> processCodingList = processCodingMapper.selectList(new QueryWrapper<ProcessCoding>().in("task_id",taskIds));
        Map<String, ProcessCoding> taskMap = new HashMap<>();
        Map<String, Date> startTaskMap = new HashMap<>();
        if (!CollectionUtils.isEmpty(processCodingList)) {
            //key为taskId value为本体对象
            Map<String, ProcessCoding> taskMap = processCodingList.stream().collect(Collectors.toMap(ProcessCoding::getTaskId, Function.identity()));
            taskMap = processCodingList.stream().collect(Collectors.toMap(ProcessCoding::getTaskId, Function.identity()));
            //拿到开始计时的节点集合 key:taskId value:开始时间
            Map<String, Date> startTaskMap = getStartTaskList(processCodingList);
            startTaskMap = getStartTaskList(processCodingList);
        }
            //提前准备接收数据的map key:流程实例id value:需要改变的颜色
            Map<String, List<String>> map = new HashMap<>();
            List<ProcessCoding> list = new ArrayList<>();
@@ -89,7 +93,7 @@
            map.forEach((key,value)-> updateProjectCoding(value, key));
            //更新节点状态 自定义的mybatis方法
            if(!CollectionUtils.isEmpty(list)) processCodingMapper.updateBatch(list);
        }

        log.info("结束赋码");
    }