|  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | import com.alibaba.fastjson.JSON; | 
|---|
|  |  |  | import com.alibaba.fastjson.JSONObject; | 
|---|
|  |  |  | import com.baomidou.mybatisplus.mapper.EntityWrapper; | 
|---|
|  |  |  | import com.core.annotations.ManagerAuth; | 
|---|
|  |  |  | import com.core.common.BaseRes; | 
|---|
|  |  |  | import com.core.common.Cools; | 
|---|
|  |  |  | 
|---|
|  |  |  | shuttleData.put("moveAdvancePath", null);//穿梭车预计路径 | 
|---|
|  |  |  | if (shuttleProtocol.getTaskNo() != 0) { | 
|---|
|  |  |  | //存在任务,获取指令 | 
|---|
|  |  |  | Object object = redisUtil.get("shuttle_wrk_no_" + shuttleProtocol.getTaskNo()); | 
|---|
|  |  |  | Object object = redisUtil.get(RedisKeyType.SHUTTLE.key + shuttleProtocol.getTaskNo()); | 
|---|
|  |  |  | if (object != null) { | 
|---|
|  |  |  | ShuttleRedisCommand redisCommand = JSON.parseObject(object.toString(), ShuttleRedisCommand.class); | 
|---|
|  |  |  | shuttleData.put("moveAdvancePath", redisCommand.getAssignCommand().getNodes());//穿梭车预计路径 | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | Integer chargeLine = basShuttleService.selectById(slave.getId()).getChargeLine(); | 
|---|
|  |  |  | String lowerPower = "N"; | 
|---|
|  |  |  | if (chargeLine != null && shuttleProtocol.getPowerPercent() != null) { | 
|---|
|  |  |  | lowerPower = shuttleProtocol.getPowerPercent() <= chargeLine ? "Y" : "N"; | 
|---|
|  |  |  | } | 
|---|
|  |  |  | shuttleData.put("lowerPower", lowerPower);//是否低电量 | 
|---|
|  |  |  | baseObj.putAll(shuttleData); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | return R.ok().add(list); | 
|---|
|  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | @RequestMapping(value = "/command/query") | 
|---|
|  |  |  | public R shuttleCommandQuery(@RequestParam("wrkNo") Integer wrkNo) { | 
|---|
|  |  |  | Object o = redisUtil.get("shuttle_wrk_no_" + wrkNo); | 
|---|
|  |  |  | Object o = redisUtil.get(RedisKeyType.SHUTTLE.key + wrkNo); | 
|---|
|  |  |  | if (o == null) { | 
|---|
|  |  |  | return R.error(); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | 
|---|
|  |  |  | @RequestMapping(value = "/command/rollback") | 
|---|
|  |  |  | public R shuttleCommandRollback(@RequestParam("wrkNo") Integer wrkNo | 
|---|
|  |  |  | , @RequestParam("commandStep") Integer commandStep) { | 
|---|
|  |  |  | Object o = redisUtil.get("shuttle_wrk_no_" + wrkNo); | 
|---|
|  |  |  | Object o = redisUtil.get(RedisKeyType.SHUTTLE.key + wrkNo); | 
|---|
|  |  |  | if (o == null) { | 
|---|
|  |  |  | return R.error(); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | ShuttleRedisCommand redisCommand = JSON.parseObject(o.toString(), ShuttleRedisCommand.class); | 
|---|
|  |  |  | redisCommand.setCommandStep(commandStep); | 
|---|
|  |  |  | redisUtil.set("shuttle_wrk_no_" + wrkNo, JSON.toJSONString(redisCommand)); | 
|---|
|  |  |  | redisUtil.set(RedisKeyType.SHUTTLE.key + wrkNo, JSON.toJSONString(redisCommand)); | 
|---|
|  |  |  | return R.ok(); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | 
|---|
|  |  |  | public R shuttleCommandCompleteSwitch(@RequestParam("wrkNo") Integer wrkNo | 
|---|
|  |  |  | , @RequestParam("commandStep") Integer commandStep | 
|---|
|  |  |  | , @RequestParam("complete") Integer complete) { | 
|---|
|  |  |  | Object o = redisUtil.get("shuttle_wrk_no_" + wrkNo); | 
|---|
|  |  |  | Object o = redisUtil.get(RedisKeyType.SHUTTLE.key + wrkNo); | 
|---|
|  |  |  | if (o == null) { | 
|---|
|  |  |  | return R.error(); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | 
|---|
|  |  |  | List<NyShuttleHttpCommand> commands = assignCommand.getCommands(); | 
|---|
|  |  |  | NyShuttleHttpCommand command = commands.get(commandStep); | 
|---|
|  |  |  | command.setComplete(complete != 0); | 
|---|
|  |  |  | redisUtil.set("shuttle_wrk_no_" + wrkNo, JSON.toJSONString(redisCommand)); | 
|---|
|  |  |  | redisUtil.set(RedisKeyType.SHUTTLE.key + wrkNo, JSON.toJSONString(redisCommand)); | 
|---|
|  |  |  | return R.ok(); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | //重启任务(命令) | 
|---|
|  |  |  | @RequestMapping(value = "/command/restart") | 
|---|
|  |  |  | public R shuttleCommandCompleteSwitch(@RequestParam("wrkNo") Integer wrkNo) { | 
|---|
|  |  |  | Object o = redisUtil.get("shuttle_wrk_no_" + wrkNo); | 
|---|
|  |  |  | Object o = redisUtil.get(RedisKeyType.SHUTTLE.key + wrkNo); | 
|---|
|  |  |  | if (o == null) { | 
|---|
|  |  |  | return R.error(); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | 
|---|
|  |  |  | //删除任务(命令) | 
|---|
|  |  |  | @RequestMapping(value = "/command/del") | 
|---|
|  |  |  | public R liftCommandDel(@RequestParam("wrkNo") Integer wrkNo) { | 
|---|
|  |  |  | Object o = redisUtil.get("shuttle_wrk_no_" + wrkNo); | 
|---|
|  |  |  | Object o = redisUtil.get(RedisKeyType.SHUTTLE.key + wrkNo); | 
|---|
|  |  |  | if (o == null) { | 
|---|
|  |  |  | return R.error(); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | redisUtil.del("shuttle_wrk_no_" + wrkNo); | 
|---|
|  |  |  | redisUtil.del(RedisKeyType.SHUTTLE.key + wrkNo); | 
|---|
|  |  |  | return R.ok(); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|