| | |
| | | return; |
| | | } |
| | | |
| | | Integer backStationId = stationObjModel.getBarcodeStation() == null ? null : stationObjModel.getBarcodeStation().getStationId(); |
| | | if (backStationId == null) { |
| | | Integer barcodeStationId = stationObjModel.getBarcodeStation() == null ? null : stationObjModel.getBarcodeStation().getStationId(); |
| | | if (barcodeStationId == null) { |
| | | return; |
| | | } |
| | | |
| | |
| | | StationCommandType.MOVE, |
| | | commonService.getWorkNo(WrkIoType.ENABLE_IN.id), |
| | | stationId, |
| | | backStationId, |
| | | barcodeStationId, |
| | | 0 |
| | | ); |
| | | stationCommandDispatcher.dispatch(basDevp.getDevpNo(), command, STATION_COMMAND_SOURCE, "enable-in"); |
| | | Utils.precomputeInTaskEnableRow(backStationId); |
| | | Utils.precomputeInTaskEnableRow(barcodeStationId); |
| | | redisUtil.set(RedisKeyType.GENERATE_ENABLE_IN_STATION_DATA_LIMIT.key + stationId, "lock", 15); |
| | | // 启动入库时删除退回控制key,允许后续异常时再次生成退回命令 |
| | | redisUtil.del(RedisKeyType.GENERATE_STATION_BACK_LIMIT.key + barcodeStationId); |
| | | News.info("{}站点启动入库成功,数据包:{}", stationId, JSON.toJSONString(command)); |
| | | } |
| | | |