Commit b72b576b by guo_minglei@163.com

添加工作流名称

parent 83d040dd
...@@ -951,7 +951,7 @@ public class ApiFlowServiceImpl implements ApiFlowService { ...@@ -951,7 +951,7 @@ public class ApiFlowServiceImpl implements ApiFlowService {
//设置触发时间 //设置触发时间
Long triggerTime = System.currentTimeMillis(); Long triggerTime = System.currentTimeMillis();
Map<String, List<WaitingTask>> waitTaskMap = buildTask(nodeList, nodeNameList, repairTimeList, triggerTime); Map<String, List<WaitingTask>> waitTaskMap = buildTask(nodeList, nodeNameList, repairTimeList, triggerTime, flowName);
//将时间排序 //将时间排序
Collections.sort(repairTimeList); Collections.sort(repairTimeList);
//查看当前排队的工作流最大排队序号 //查看当前排队的工作流最大排队序号
...@@ -991,7 +991,7 @@ public class ApiFlowServiceImpl implements ApiFlowService { ...@@ -991,7 +991,7 @@ public class ApiFlowServiceImpl implements ApiFlowService {
} }
private Map<String, List<WaitingTask>> buildTask(List<Node> nodeList, List<String> nodeNameList, List<String> repairTimeList, Long triggerTime){ private Map<String, List<WaitingTask>> buildTask(List<Node> nodeList, List<String> nodeNameList, List<String> repairTimeList, Long triggerTime, String flowName){
Map<String, List<WaitingTask>> result = new HashMap<>(); Map<String, List<WaitingTask>> result = new HashMap<>();
String usernName = currentUserUtils.account(); String usernName = currentUserUtils.account();
List<WaitingTask> waitingTaskList = new ArrayList<>(); List<WaitingTask> waitingTaskList = new ArrayList<>();
...@@ -1010,6 +1010,7 @@ public class ApiFlowServiceImpl implements ApiFlowService { ...@@ -1010,6 +1010,7 @@ public class ApiFlowServiceImpl implements ApiFlowService {
}); });
waitingTask.setNodeDepend(Joiner.on(",").join(dependNodeIdList)); waitingTask.setNodeDepend(Joiner.on(",").join(dependNodeIdList));
} }
waitingTask.setFlowName(flowName);
waitingTask.setTriggerTime(triggerTime); waitingTask.setTriggerTime(triggerTime);
waitingTask.setOperator(usernName); waitingTask.setOperator(usernName);
waitingTask.setScheduleType(ScheduleTypeEnum.REPAIR.getCode()); waitingTask.setScheduleType(ScheduleTypeEnum.REPAIR.getCode());
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment