取消多统计的实例

byit-myth-admin/src/main/java/com/byit/service/impl/ApiFlowServiceImpl.java

@@ -815,17 +815,17 @@ public class ApiFlowServiceImpl implements ApiFlowService {
         //统计视力表啊的数据
         long notStartFlowCount = statusMap.get("1") == null?0:statusMap.get("1");
         //统计等待表哦数据
-        List<WaitingRecord> allByCondition = waitingRecordMapper.findAllByCondition(statisticsConditionDto);
+        //List<WaitingRecord> allByCondition = waitingRecordMapper.findAllByCondition(statisticsConditionDto);
         int waitFlowCount = 0;
         if(CollectionUtil.isNotEmpty(allFlow)) {
             waitFlowCount = allFlow.size();
         }
-        int allWaitRecount = 0;
+        /*int allWaitRecount = 0;
         if(CollectionUtil.isNotEmpty(allByCondition)) {
             allWaitRecount = allByCondition.size();
-        }
+        }*/
         //待运行的数据
-        long waitTotal = notStartFlowCount + waitFlowCount + allWaitRecount;
+        long waitTotal = notStartFlowCount + waitFlowCount;
 
         CollectData collectData = new CollectData();
         //工作流数据灌输

byit-myth-core/myth-admin-core/src/main/java/com/byit/thread/helper/JobSnapshotThreadRunHelper.java

@@ -70,7 +70,7 @@ public class JobSnapshotThreadRunHelper extends BaseThreadRunHelper {
         StatisticsConditionDto statisticsConditionDto = new StatisticsConditionDto();
         statisticsConditionDto.setStartTime(startTime);
         statisticsConditionDto.setEndTime(endTime);
-        List<WaitingRecord> waitingRecordsList = waitingRecordMapper.findAllByCondition(statisticsConditionDto);
+        //List<WaitingRecord> waitingRecordsList = waitingRecordMapper.findAllByCondition(statisticsConditionDto);
         //未运行的工作流
         List<FlowStatusSnapshoot> waitFlow = new ArrayList<>(15);
         //运行中的工作流
@@ -89,7 +89,7 @@ public class JobSnapshotThreadRunHelper extends BaseThreadRunHelper {
         log.debug("------------开始筛选等待的工作流---------");
         filterWaitFlow(thisDayRunRecording,waitFlow);
         flowToFlowStatusSnapshoot(thisDayFlow,waitFlow);
-        filterWaitingRecordFlow(waitingRecordsList,waitFlow);
+        //filterWaitingRecordFlow(waitingRecordsList,waitFlow);
         log.debug("------------开始筛选运行中的工作流---------");
         filterRuningFlow(thisDayRunRecording,runIngFlow);
         log.debug("------------开始暂停运行的工作流---------");