| | |
| | | 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; |
| | | }; |
| | | |
| | |
| | | } |
| | | try{ |
| | | this.sendInPark(platformJob); |
| | | if(!Constants.equalsInteger(platformJob.getType(),Constants.FOUR) |
| | | && StringUtils.isNotBlank(platformJob.getBillCode())){ |
| | | //通知WMS绑定月台信息 |
| | | wmsService.orderPlatformBind(platformJob,1); |
| | | } |
| | | // if(!Constants.equalsInteger(platformJob.getType(),Constants.FOUR) |
| | | // && StringUtils.isNotBlank(platformJob.getBillCode())){ |
| | | // //通知WMS绑定月台信息 |
| | | // wmsService.orderPlatformBind(platformJob,1); |
| | | // } |
| | | }catch (Exception e){ |
| | | log.error("自动叫号入园权限下发失败:{}"+JSONObject.toJSONString(platformJob)); |
| | | } |