From 405a34a73ddad9367c1a40b03a5f8cec914ad683 Mon Sep 17 00:00:00 2001 From: Junjie <fallin.jie@qq.com> Date: 星期一, 03 七月 2023 13:30:22 +0800 Subject: [PATCH] 命令下发保存二进制报文 --- src/main/java/com/zy/asrs/controller/ShuttleController.java | 51 ++++++++++++++++++++------------------------------- 1 files changed, 20 insertions(+), 31 deletions(-) diff --git a/src/main/java/com/zy/asrs/controller/ShuttleController.java b/src/main/java/com/zy/asrs/controller/ShuttleController.java index 63a991a..f7df68a 100644 --- a/src/main/java/com/zy/asrs/controller/ShuttleController.java +++ b/src/main/java/com/zy/asrs/controller/ShuttleController.java @@ -23,7 +23,6 @@ import com.zy.core.model.ShuttleSlave; import com.zy.core.model.Task; import com.zy.core.model.command.ShuttleAssignCommand; -import com.zy.core.model.command.ShuttleCommand; import com.zy.core.model.protocol.ShuttleProtocol; import com.zy.core.properties.SlaveProperties; import com.zy.core.thread.ShuttleThread; @@ -241,37 +240,27 @@ } @PostMapping("/detl/update") - @ManagerAuth - public R steUpdate(ShuttleDataVo vo){ - BasShuttle basShuttle = basShuttleService.selectById(vo.getShuttleNo()); - if (basShuttle == null) { - return R.error(); + @ManagerAuth(memo = "淇敼鏁版嵁") + public R liftUpdate(@RequestParam Integer shuttleNo, + @RequestParam Short workNo, + @RequestParam String pakMk){ + for (ShuttleSlave shuttleSlave : slaveProperties.getShuttle()) { + ShuttleThread shuttleThread = (ShuttleThread) SlaveConnection.get(SlaveType.Shuttle, shuttleSlave.getId()); + if (shuttleThread == null) { + return R.error("plc宸叉帀绾�"); + } + ShuttleProtocol shuttleProtocol = shuttleThread.getShuttleProtocol(); + if (shuttleProtocol == null) { + return R.error("plc宸叉帀绾�"); + } + if (workNo != null) { + shuttleProtocol.setTaskNo(workNo); + } + if (pakMk != null) { + shuttleProtocol.setPakMk(pakMk.equals("Y")); + } } - // 鑾峰彇鍥涘悜绌挎杞︿俊鎭� - ShuttleThread shuttleThread = (ShuttleThread) SlaveConnection.get(SlaveType.Shuttle, vo.getShuttleNo()); - ShuttleProtocol shuttleProtocol = shuttleThread.getShuttleProtocol(); - if (shuttleProtocol == null) { - throw new CoolException(vo.getShuttleNo() + "鍙峰洓鍚戠┛姊溅涓嶅湪绾匡紝鏃犳硶淇濆瓨"); - } -// if (!Cools.isEmpty(vo.getRow(), vo.getBay(), vo.getLev())) { -// if (!shuttleThread.modifyPosHandle(vo.getRow(), vo.getBay(), vo.getLev())) { -// throw new CoolException("鏈嶅姟鍣ㄩ敊璇�"); -// } -// } - ShuttleCommand shuttleCommand = new ShuttleCommand(); - shuttleCommand.setTaskNo(vo.getWorkNo().shortValue()); - if (MessageQueue.offer(SlaveType.Shuttle, vo.getShuttleNo(), new Task(2, shuttleCommand))) { - } else { - throw new CoolException("鍛戒护涓嬪彂澶辫触"); - } - - basShuttle.setPakMk(vo.getPakMk()); - basShuttle.setWrkNo(vo.getWorkNo()); - basShuttle.setUpdateTime(new Date()); - if (!basShuttleService.updateById(basShuttle)) { - throw new CoolException("淇敼澶辫触"); - } - return R.ok(); + return R.error("plc宸叉帀绾�"); } @PostMapping("/runSpeed/{shuttleNo}") -- Gitblit v1.9.1