| | |
|---|
| | | Integer stationId = data.getInteger("stationId"); |
|---|
| | | Integer deviceNo = data.getInteger("deviceNo"); |
|---|
| | | |
|---|
| | | Object lock = redisUtil.get(RedisKeyType.RECEIVE_IN_TASK_CHANGE_STATION_TASK_SEND_LIMIT.key + stationId); |
|---|
| | | Object lock = redisUtil.get(RedisKeyType.SEND_LIMIT_RECEIVE_IN_TASK_CHANGE_STATION_TASK.key + stationId); |
|---|
| | | if(lock != null){ |
|---|
| | | continue; |
|---|
| | | } |
|---|
| | |
|---|
| | | |
|---|
| | | //缓存命令相同，下发命令改变入库任务号信息 |
|---|
| | | MessageQueue.offer(SlaveType.Devp, deviceNo, new Task(2, command)); |
|---|
| | | redisUtil.set(RedisKeyType.RECEIVE_IN_TASK_CHANGE_STATION_TASK_SEND_LIMIT.key + stationId, "lock", 5); |
|---|
| | | redisUtil.set(RedisKeyType.SEND_LIMIT_RECEIVE_IN_TASK_CHANGE_STATION_TASK.key + stationId, "lock", 5); |
|---|
| | | } |
|---|
| | | |
|---|
| | | } |
|---|
