Commit a5027f25 by guo_minglei@163.com

修改统计类型

parent 1fab7330
...@@ -855,9 +855,12 @@ public class ApiFlowServiceImpl implements ApiFlowService { ...@@ -855,9 +855,12 @@ public class ApiFlowServiceImpl implements ApiFlowService {
} }
StatisticData nodeStatisticData = jobTaskRunLogMapper.findStatusByStartAndEndTime(new Date(startTime), new Date(endTime), flowIdList); StatisticData nodeStatisticData = jobTaskRunLogMapper.findStatusByStartAndEndTime(new Date(startTime), new Date(endTime), flowIdList);
StatisticData unstartNodeStatisticData = waitingTaskMapper.findStatusByStartAndEndTime(flowIdList); List<Node> nodeList = nodeMapper.findbyFlowIds(flowIdList);
if (null != unstartNodeStatisticData){ if (null == nodeStatisticData){
nodeStatisticData.setUnstart(nodeStatisticData.getUnstart() + unstartNodeStatisticData.getUnstart()); nodeStatisticData = new StatisticData();
nodeStatisticData.setUnstart(nodeList.size());
}else {
nodeStatisticData.setUnstart(nodeList.size() - nodeStatisticData.getUnstart());
} }
List<FlowStatusSnapshoot> flowStatusSnapshootList = flowStatusSnapshootMapper.findByTime(startTime, endTime); List<FlowStatusSnapshoot> flowStatusSnapshootList = flowStatusSnapshootMapper.findByTime(startTime, endTime);
......
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