| | |
| | | return false; |
| | | } |
| | | |
| | | Integer lockTaskNo = stationProtocol.getTaskNo(); |
| | | String lockKey = (lockTaskNo != null && lockTaskNo > 0) |
| | | ? RedisKeyType.GENERATE_STATION_BACK_LIMIT.key + lockTaskNo |
| | | : RedisKeyType.GENERATE_STATION_BACK_LIMIT.key + "station_" + stationProtocol.getStationId(); |
| | | String lockKey = RedisKeyType.GENERATE_STATION_BACK_LIMIT.key + stationProtocol.getStationId(); |
| | | Object lock = redisUtil.get(lockKey); |
| | | if (lock != null) { |
| | | return false; |
| | |
| | | return false; |
| | | } |
| | | stationCommandDispatcher.dispatch(basDevp.getDevpNo(), command, "gsl-process", "station-back"); |
| | | News.taskInfo(stationProtocol.getTaskNo(), "扫码异常,已退回至{}", backStation.getStationId()); |
| | | redisUtil.set(lockKey, "lock", 10); |
| | | News.info("{}扫码站异常,已退回至{},条码站状态:{}", stationProtocol.getTaskNo(), backStation.getStationId(), JSON.toJSONString(stationProtocol)); |
| | | redisUtil.set(lockKey, "lock", 15); |
| | | return false; |
| | | } |
| | | |