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