From e7ee6502ce70f0aa1728b9a67780ec28f6218a45 Mon Sep 17 00:00:00 2001 From: luxiaotao1123 <t1341870251@163.com> Date: 星期二, 20 九月 2022 14:45:04 +0800 Subject: [PATCH] # --- src/main/java/com/zy/asrs/controller/SteController.java | 29 ++++++++++++++++++++++++++--- 1 files changed, 26 insertions(+), 3 deletions(-) diff --git a/src/main/java/com/zy/asrs/controller/SteController.java b/src/main/java/com/zy/asrs/controller/SteController.java index ba77109..8d9ec7d 100644 --- a/src/main/java/com/zy/asrs/controller/SteController.java +++ b/src/main/java/com/zy/asrs/controller/SteController.java @@ -69,7 +69,7 @@ if (steProtocol == null) { continue; } - vo.setTaskNo(steProtocol.getTaskNo()); // 浠诲姟鍙� + vo.setTaskNo(steProtocol.getTaskNo().intValue()); // 浠诲姟鍙� vo.setStatusType(steProtocol.mode == 0 ? "绂荤嚎" : "鍦ㄧ嚎"); // 妯″紡鐘舵�� if (!Cools.isEmpty(steProtocol.getStatus())) { vo.setStatus(steProtocol.getStatusType().desc); // 鐘舵�� @@ -119,7 +119,7 @@ continue; } - vo.setWorkNo(steProtocol.getTaskNo()); // 浠诲姟鍙� + vo.setWorkNo(steProtocol.getTaskNo().intValue()); // 浠诲姟鍙� if (steProtocol.getTaskNo() > 0) { WrkMast wrkMast = wrkMastService.selectById(steProtocol.getTaskNo()); if (wrkMast != null) { @@ -134,6 +134,7 @@ } vo.setSpeed(steProtocol.getSpeed()); // 閫熷害 vo.setCloser(steProtocol.getCloser()); // 杩戠偣璺濈 + vo.setPakMk(steProtocol.getPakMk()); // 浣滀笟鏍囪 } return R.ok().add(list); } @@ -164,6 +165,7 @@ vo.setLev(basSte.getLev()); vo.setCrnNo(basSte.getCrnNo()); vo.setWorkNo(basSte.getWrkNo()); + vo.setPakMk(basSte.getPakMk()); } break; } @@ -178,7 +180,24 @@ if (basSte == null) { return R.error(); } - + // 鑾峰彇绌挎杞︿俊鎭� + SteThread steThread = (SteThread) SlaveConnection.get(SlaveType.Ste, vo.getSteNo()); + SteProtocol steProtocol = steThread.getSteProtocol(); + if (steProtocol == null) { + throw new CoolException(vo.getSteNo() + "鍙风┛姊溅涓嶅湪绾匡紝鏃犳硶淇濆瓨"); + } + if (!Cools.isEmpty(vo.getRow(), vo.getBay(), vo.getLev())) { + if (!steThread.modifyPosHandle(vo.getRow(), vo.getBay(), vo.getLev())) { + throw new CoolException("鏈嶅姟鍣ㄩ敊璇�"); + } + } + SteCommand steCommand = new SteCommand(); + steCommand.setTaskNo(vo.getWorkNo()); + if (MessageQueue.offer(SlaveType.Ste, vo.getSteNo(), new Task(2, steCommand))) { + } else { + throw new CoolException("鍛戒护涓嬪彂澶辫触"); + } + basSte.setPakMk(vo.getPakMk()); basSte.setWrkNo(vo.getWorkNo()); basSte.setCrnNo(vo.getCrnNo()); basSte.setUpdateTime(new Date()); @@ -216,6 +235,10 @@ steCommand.setSteNo(ste.getId()); // 绌挎杞︾紪鍙� if (param.getSteTaskMode() == 16) { steCommand.setComplete(true); + } else if (param.getSteTaskMode() == 17) { + steCommand.setControlMode((short) 1); + } else if (param.getSteTaskMode() == 18) { + steCommand.setControlMode((short) 0); } else { if (steTaskModeType == null) { throw new CoolException("浠诲姟绫诲瀷閿欒"); -- Gitblit v1.9.1