| | |
| | | Integer workNum = platformJobJoinMapper.selectCount(new QueryWrapper<PlatformJob>().lambda() |
| | | .eq(PlatformJob::getIsdeleted,Constants.ZERO) |
| | | .eq(PlatformJob::getPlatformId,platform.getId()) |
| | | .in(PlatformJob::getStatus,Constants.PlatformJobStatus.CALLED.getKey(),Constants.PlatformJobStatus.WORKING.getKey()) |
| | | .in(PlatformJob::getStatus,Constants.PlatformJobStatus.CALLED.getKey() |
| | | ,Constants.PlatformJobStatus.WORKING.getKey()) |
| | | ) .intValue(); |
| | | if(workNum>=workingNum){ |
| | | log.error("========月台自动叫号============结束:超过自动叫号作业限制-"+platform.getName()); |
| | |
| | | Integer callNum = platformJobJoinMapper.selectCount(new QueryWrapper<PlatformJob>().lambda() |
| | | .eq(PlatformJob::getIsdeleted,Constants.ZERO) |
| | | .eq(PlatformJob::getPlatformId,platform.getId()) |
| | | .eq(PlatformJob::getStatus,Constants.PlatformJobStatus.IN_WAIT.getKey())).intValue(); |
| | | if(callNum>=callReadyNum){ |
| | | .eq(PlatformJob::getStatus,Constants.PlatformJobStatus.IN_WAIT.getKey())) |
| | | .intValue(); |
| | | if(callReadyNum ==0 || callNum>=callReadyNum){ |
| | | continue; |
| | | }; |
| | | |