|  |  |  | 
|---|
|  |  |  | * @description: 光电站点任务下发 | 
|---|
|  |  |  | * @version 1.0 | 
|---|
|  |  |  | */ | 
|---|
|  |  |  | @Scheduled(cron = "0/5 * * * * ?  ") | 
|---|
|  |  |  | //    @Scheduled(cron = "0/5 * * * * ?  ") | 
|---|
|  |  |  | @Transactional(rollbackFor = Exception.class) | 
|---|
|  |  |  | public void taskToWCS() throws Exception { | 
|---|
|  |  |  | Long loginUserId = SystemAuthUtils.getLoginUserId(); | 
|---|
|  |  |  | 
|---|
|  |  |  | //主参数 | 
|---|
|  |  |  | taskParams.setBatch(task.getBarcode()); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | BasStation station = basStationService.getOne(new LambdaQueryWrapper<BasStation>().eq(BasStation::getStationName, task.getTargSite())); | 
|---|
|  |  |  | if (Objects.isNull(station)) { | 
|---|
|  |  |  | throw new CoolException("站点不存在!!"); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | BasStation station = null; | 
|---|
|  |  |  | if (!task.getTaskType().equals(TaskType.TASK_TYPE_LOC_MOVE.type)) { | 
|---|
|  |  |  | station = basStationService.getOne(new LambdaQueryWrapper<BasStation>().eq(BasStation::getStationName, task.getTargSite())); | 
|---|
|  |  |  | if (Objects.isNull(station)) { | 
|---|
|  |  |  | throw new CoolException("站点不存在!!"); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | /**判断是否光电站点,非光店站点需管控站点状态*/ | 
|---|
|  |  |  | if (station.getType().equals(StationTypeEnum.STATION_TYPE_NORMAL.type)) { | 
|---|
|  |  |  | if (!Objects.isNull(station) && station.getType().equals(StationTypeEnum.STATION_TYPE_NORMAL.type)) { | 
|---|
|  |  |  | if (task.getTaskType() <= TaskType.TASK_TYPE_CHECK_IN.type && !task.getTaskType().equals(TaskType.TASK_TYPE_LOC_MOVE.type)) { | 
|---|
|  |  |  | if (!station.getUseStatus().equals(LocStsType.LOC_STS_TYPE_F.type)) { | 
|---|
|  |  |  | throw new CoolException("当前站点不是F.在库状态状态!!"); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | //                if (!station.getUseStatus().equals(LocStsType.LOC_STS_TYPE_F.type)) { | 
|---|
|  |  |  | //                    throw new CoolException( "当前站点不是F.在库状态状态!!"); | 
|---|
|  |  |  | //                } | 
|---|
|  |  |  | station.setUseStatus(LocStsType.LOC_STS_TYPE_R.type); | 
|---|
|  |  |  | if (!basStationService.updateById(station)) { | 
|---|
|  |  |  | throw new CoolException("站点状态更新失败!!"); | 
|---|