| | |
| | | redisCommand.setCommandStep(0);//命令执行步序 |
| | | redisCommand.setAssignCommand(assignCommand);//命令 |
| | | //任务数据保存到redis |
| | | if (redisUtil.set(RedisKeyType.FORK_LIFT.key + assignCommand.getTaskNo(), JSON.toJSONString(redisCommand))) { |
| | | if (redisUtil.set(RedisKeyType.FORK_LIFT_WORK_FLAG.key + assignCommand.getTaskNo(), JSON.toJSONString(redisCommand))) { |
| | | forkLiftThread.setSyncTaskNo(assignCommand.getTaskNo().intValue()); |
| | | return true; |
| | | } |
| | |
| | | } |
| | | |
| | | public synchronized boolean executeWork(Integer liftNo, Integer taskNo) { |
| | | Object obj = redisUtil.get(RedisKeyType.FORK_LIFT.key + taskNo); |
| | | Object obj = redisUtil.get(RedisKeyType.FORK_LIFT_WORK_FLAG.key + taskNo); |
| | | if (obj == null) { |
| | | return false; |
| | | } |
| | |
| | | //更新redis数据 |
| | | redisCommand.setCommandStep(commandStep); |
| | | // 更新redis数据 |
| | | redisUtil.set(RedisKeyType.FORK_LIFT.key + taskNo, JSON.toJSONString(redisCommand)); |
| | | redisUtil.set(RedisKeyType.FORK_LIFT_WORK_FLAG.key + taskNo, JSON.toJSONString(redisCommand)); |
| | | } |
| | | |
| | | return true; |