| | |
| | | platformWorkVO.setCallNum( |
| | | platformJobs.stream().filter(i->Constants.equalsInteger(i.getPlatformId(),platform.getId()) && Constants.equalsInteger(i.getStatus(),Constants.PlatformJobStatus.CALLED.getKey())).collect(Collectors.toList()).size() |
| | | ); |
| | | System.out.printf(String.valueOf(platformJobs.stream().filter(i-> |
| | | Constants.equalsInteger(i.getStatus(),Constants.PlatformJobStatus.WAIT_CALL.getKey()) |
| | | ).collect(Collectors.toList()).size()) |
| | | ); |
| | | System.out.printf(String.valueOf(platformJobList.stream().filter(i-> |
| | | Constants.equalsInteger(i.getStatus(),Constants.PlatformJobStatus.IN_WAIT.getKey()) || |
| | | ( Constants.equalsInteger(platform.getId(),i.getPlatformId()) && |
| | | Constants.equalsInteger(i.getStatus(),Constants.PlatformJobStatus.TRANSFERING.getKey()) |
| | | ) |
| | | ).collect(Collectors.toList()).size()) |
| | | ); |
| | | |
| | | platformWorkVO.setWaitNum( |
| | | |
| | | platformJobs.stream().filter(i-> |
| | | Constants.equalsInteger(i.getStatus(),Constants.PlatformJobStatus.WAIT_CALL.getKey()) |
| | | ).collect(Collectors.toList()).size() |
| | | + |
| | | platformJobList.stream().filter(i->Constants.equalsInteger(platform.getId(),i.getPlatformId()) |
| | | && (Constants.equalsInteger(i.getStatus(),Constants.PlatformJobStatus.IN_WAIT.getKey()) || Constants.equalsInteger(i.getStatus(),Constants.PlatformJobStatus.TRANSFERING.getKey()) |
| | | platformJobList.stream().filter(i-> |
| | | ( Constants.equalsInteger(i.getStatus(),Constants.PlatformJobStatus.IN_WAIT.getKey()) && Constants.equalsInteger(i.getPlatformGroupId(),platform.getGroupId()) )|| |
| | | ( Constants.equalsInteger(platform.getId(),i.getPlatformId()) && |
| | | Constants.equalsInteger(i.getStatus(),Constants.PlatformJobStatus.TRANSFERING.getKey()) |
| | | ) |
| | | ).collect(Collectors.toList()).size() |
| | | ); |