From 4e9d40cece4d7ab340994a3fea2374e3309c4ba8 Mon Sep 17 00:00:00 2001
From: Junjie <fallin.jie@qq.com>
Date: 星期二, 28 三月 2023 08:43:54 +0800
Subject: [PATCH] 错误码枚举

---
 src/main/java/com/zy/asrs/controller/ShuttleController.java |  101 ++++++++++++++++++++++++++++----------------------
 1 files changed, 56 insertions(+), 45 deletions(-)

diff --git a/src/main/java/com/zy/asrs/controller/ShuttleController.java b/src/main/java/com/zy/asrs/controller/ShuttleController.java
index d1d94ea..01ef21f 100644
--- a/src/main/java/com/zy/asrs/controller/ShuttleController.java
+++ b/src/main/java/com/zy/asrs/controller/ShuttleController.java
@@ -6,13 +6,9 @@
 import com.core.common.Cools;
 import com.core.common.R;
 import com.core.exception.CoolException;
-import com.zy.asrs.domain.enums.CrnStatusType;
 import com.zy.asrs.domain.param.ShuttleOperatorParam;
-import com.zy.asrs.domain.param.SteModeParam;
-import com.zy.asrs.domain.param.SteOperatorParam;
 import com.zy.asrs.domain.vo.*;
 import com.zy.asrs.entity.BasShuttle;
-import com.zy.asrs.entity.BasSte;
 import com.zy.asrs.entity.WrkMast;
 import com.zy.asrs.service.BasShuttleService;
 import com.zy.asrs.service.WrkMastService;
@@ -21,16 +17,12 @@
 import com.zy.core.cache.SlaveConnection;
 import com.zy.core.enums.*;
 import com.zy.core.model.ShuttleSlave;
-import com.zy.core.model.SteSlave;
 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.command.SteCommand;
 import com.zy.core.model.protocol.ShuttleProtocol;
-import com.zy.core.model.protocol.SteProtocol;
 import com.zy.core.properties.SlaveProperties;
-import com.zy.core.properties.SystemProperties;
 import com.zy.core.thread.ShuttleThread;
-import com.zy.core.thread.SteThread;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.*;
@@ -38,6 +30,7 @@
 import java.util.ArrayList;
 import java.util.Date;
 import java.util.List;
+import java.util.Random;
 
 /**
  * 鍥涘悜绌挎杞︽帴鍙�
@@ -70,24 +63,32 @@
                 continue;
             }
             ShuttleProtocol shuttleProtocol = shuttleThread.getShuttleProtocol();
-            if (shuttleProtocol == null) {
+            if (shuttleProtocol == null || shuttleProtocol.getShuttleNo()==null) {
                 continue;
             }
             vo.setTaskNo(shuttleProtocol.getTaskNo().intValue());  //  浠诲姟鍙�
-            if (!Cools.isEmpty(shuttleProtocol.getBusyStatus())) {
-                vo.setStatus(shuttleProtocol.getBusyStatusType().desc); //  鐘舵��
-            }
-            vo.setRow(shuttleProtocol.getRow());
-            vo.setBay(shuttleProtocol.getBay());
-            vo.setLev(shuttleProtocol.getLev());
-            vo.setBatteryPower(shuttleProtocol.getBatteryPower() + "%");
-            vo.setSpeed(shuttleProtocol.getCurrentMoveServoSpeed());
+            vo.setBusyStatus(shuttleProtocol.getBusyStatusType().desc); //鍥涘悜绌挎杞︾姸鎬�
+            vo.setStatus(shuttleProtocol.getProtocolStatusType().desc);//褰撳墠浠诲姟鐘舵��
+            vo.setCurrentCode(shuttleProtocol.getCurrentCode());//褰撳墠浜岀淮鐮�
+            vo.setBatteryPower(shuttleProtocol.getBatteryPower$() == null ? "" : shuttleProtocol.getBatteryPower$() + "%");//鐢垫睜鐢甸噺
+            vo.setBatteryTemp(shuttleProtocol.getBatteryTemp$() == null ? "" : shuttleProtocol.getBatteryTemp$() + "掳");//鐢垫睜娓╁害
             if (!Cools.isEmpty(shuttleProtocol.getErrorCode())) {
-                vo.setAlarm1(String.valueOf(shuttleProtocol.getErrorCode()));
+                vo.setErrorCode(shuttleProtocol.getErrorCodeType().desc);//閿欒缂栧彿
             }
+            vo.setPlcOutputStatusIO(shuttleProtocol.getPlcOutputStatusIO());//Plc杈撳嚭鐘舵�両O
             if (!Cools.isEmpty(shuttleProtocol.getStatusErrorCode())) {
-                vo.setAlarm2(String.valueOf(shuttleProtocol.getStatusErrorCode()));
+                vo.setStatusErrorCode(shuttleProtocol.getStatusErrorCode());//閿欒淇℃伅鐮�
             }
+            vo.setPlcInputStatus(shuttleProtocol.getPlcInputStatus());//PLC杈撳叆鐘舵��
+            vo.setCurrentOrBeforeCode(shuttleProtocol.getCurrentOrBeforeCode());//褰撳墠鎴栬�呬箣鍓嶈鍒扮殑浜岀淮鐮佸��
+            vo.setCodeOffsetX(shuttleProtocol.getCodeOffsetX());//璇诲埌鐨勪簩缁寸爜X鏂瑰悜鍋忕Щ閲�
+            vo.setCodeOffsetY(shuttleProtocol.getCodeOffsetY());//璇诲埌鐨勪簩缁寸爜Y鏂瑰悜鍋忕Щ閲�
+            vo.setCurrentVoltage(shuttleProtocol.getCurrentVoltage());//褰撳墠鐨勭數鍘嬪��
+            vo.setCurrentAnalogValue(shuttleProtocol.getCurrentAnalogValue());//褰撳墠鐨勬ā鎷熼噺鍊�
+            vo.setCurrentLiftServoSpeed(shuttleProtocol.getCurrentLiftServoSpeed());//褰撳墠鐨勫崌闄嶄己鏈嶉�熷害
+            vo.setCurrentMoveServoSpeed(shuttleProtocol.getCurrentMoveServoSpeed());//褰撳墠鐨勮璧颁己鏈嶉�熷害
+            vo.setCurrentLiftServoLoad(shuttleProtocol.getCurrentLiftServoLoad());//褰撳墠鐨勫崌闄嶄己鏈嶈礋杞界巼
+            vo.setCurrentMoveServoLoad(shuttleProtocol.getCurrentMoveServoLoad());//褰撳墠鐨勮璧颁己鏈嶈礋杞界巼
         }
         return R.ok().add(list);
     }
@@ -112,21 +113,34 @@
                 continue;
             }
 
-            vo.setWorkNo(shuttleProtocol.getTaskNo().intValue());  //  浠诲姟鍙�
+            vo.setWorkNo(shuttleProtocol.getTaskNo().intValue());//浠诲姟鍙�
             if (shuttleProtocol.getTaskNo() > 0) {
                 WrkMast wrkMast = wrkMastService.selectById(shuttleProtocol.getTaskNo());
                 if (wrkMast != null) {
-                    //vo.setStatus(CrnStatusType.process(wrkMast.getIoType()).getDesc());   //  妯″紡鐘舵��
-                    vo.setSourceStaNo(wrkMast.getSourceStaNo$());    //  婧愮珯
-                    vo.setStaNo(wrkMast.getStaNo$());   //  鐩爣绔�
-                    vo.setSourceLocNo(wrkMast.getSourceLocNo());    //  婧愬簱浣�
-                    vo.setLocNo(wrkMast.getLocNo());    //  鐩爣搴撲綅
+                    vo.setSourceLocNo(wrkMast.getSourceLocNo());//婧愬簱浣�
+                    vo.setDistLocNo(wrkMast.getLocNo());//鐩爣搴撲綅
                 }
             }
-            vo.setSpeed(shuttleProtocol.getCurrentMoveServoSpeed());  // 閫熷害
-            vo.setPakMk(shuttleProtocol.getPakMk());    // 浣滀笟鏍囪
+            if (shuttleProtocol.getProtocolStatusType() != null) {
+                vo.setStatus(shuttleProtocol.getProtocolStatusType().desc);//鐘舵��
+            }
+            vo.setCodeOffsetX(shuttleProtocol.getCodeOffsetX());//璇诲埌鐨勪簩缁寸爜X鏂瑰悜鍋忕Щ閲�
+            vo.setCodeOffsetY(shuttleProtocol.getCodeOffsetY());//璇诲埌鐨勪簩缁寸爜Y鏂瑰悜鍋忕Щ閲�
+            vo.setCurrentVoltage(shuttleProtocol.getCurrentVoltage());//褰撳墠鐨勭數鍘嬪��
+            vo.setCurrentAnalogValue(shuttleProtocol.getCurrentAnalogValue());//褰撳墠鐨勬ā鎷熼噺鍊�
+            vo.setCurrentMoveServoSpeed(shuttleProtocol.getCurrentMoveServoSpeed());//褰撳墠鐨勮璧颁己鏈嶉�熷害
+            vo.setCurrentMoveServoLoad(shuttleProtocol.getCurrentMoveServoLoad() == null ? "" : shuttleProtocol.getCurrentMoveServoLoad() + "%");//褰撳墠鐨勮璧颁己鏈嶈礋杞界巼
+            vo.setCurrentLiftServoLoad(shuttleProtocol.getCurrentLiftServoLoad() == null ? "" : shuttleProtocol.getCurrentLiftServoLoad() + "%");//褰撳墠鐨勫崌闄嶄己鏈嶈礋杞界巼
+            vo.setCurrentLiftServoSpeed(shuttleProtocol.getCurrentLiftServoSpeed());//褰撳墠鐨勫崌闄嶄己鏈嶉�熷害
+            vo.setPakMk(shuttleProtocol.getPakMk()?"Y" : "N");    // 浣滀笟鏍囪
         }
         return R.ok().add(list);
+    }
+
+    @PostMapping("/latest/data/shuttle")
+    @ManagerAuth(memo = "鍥涘悜绌挎杞﹀疄鏃舵暟鎹�")
+    public R shuttleLatestData(){
+        return R.ok();
     }
 
     @PostMapping("/output/shuttle")
@@ -226,7 +240,7 @@
 //            }
 //        }
         ShuttleCommand shuttleCommand = new ShuttleCommand();
-        shuttleCommand.setTaskNo(vo.getWorkNo());
+        shuttleCommand.setTaskNo(vo.getWorkNo().shortValue());
         if (MessageQueue.offer(SlaveType.Shuttle, vo.getShuttleNo(), new Task(2, shuttleCommand))) {
         } else {
             throw new CoolException("鍛戒护涓嬪彂澶辫触");
@@ -255,6 +269,10 @@
             return R.parse(BaseRes.PARAM);
         }
 
+        if (Cools.isEmpty(param.getSourceLocNo(), param.getDistLocNo())) {
+            return R.parse(BaseRes.PARAM);
+        }
+
         for (ShuttleSlave shuttleSlave : slaveProperties.getShuttle()) {
             if (param.getShuttleNo().equals(shuttleSlave.getId())) {
                 ShuttleThread shuttleThread = (ShuttleThread) SlaveConnection.get(SlaveType.Shuttle, shuttleSlave.getId());
@@ -265,23 +283,16 @@
                 if (shuttleProtocol == null) {
                     throw new CoolException("鍥涘悜绌挎杞︿笉鍦ㄧ嚎");
                 }
+
                 ShuttleTaskModeType shuttleTaskModeType = ShuttleTaskModeType.get(param.getShuttleTaskMode());
-                ShuttleCommand shuttleCommand = new ShuttleCommand();
-                shuttleCommand.setShuttleNo(shuttleSlave.getId()); // 鍥涘悜绌挎杞︾紪鍙�
-//                if (param.getShuttleTaskMode() == 16) {
-//                    steCommand.setComplete(true);
-//                } else if (param.getSteTaskMode() == 99) {
-//                    steCommand.setControlMode((short) 1);
-//                } else if (param.getSteTaskMode() == 100) {
-//                    steCommand.setControlMode((short) 0);
-//                } else {
-//                    if (steTaskModeType == null) {
-//                        throw new CoolException("浠诲姟绫诲瀷閿欒");
-//                    }
-//                    steCommand.setTaskNo(param.getTaskNo()); // 宸ヤ綔鍙�
-//                    steCommand.setTaskMode(steTaskModeType);
-//                }
-                if (MessageQueue.offer(SlaveType.Shuttle, shuttleSlave.getId(), new Task(2, shuttleCommand))) {
+                ShuttleAssignCommand command = new ShuttleAssignCommand();
+                command.setShuttleNo(shuttleSlave.getId().shortValue()); // 鍥涘悜绌挎杞︾紪鍙�
+                command.setTaskMode(shuttleTaskModeType.id.shortValue());
+                command.setSourceLocNo(param.getSourceLocNo());
+                command.setDistLocNo(param.getDistLocNo());
+                command.setTaskNo((short) 9999);
+
+                if (MessageQueue.offer(SlaveType.Shuttle, shuttleSlave.getId(), new Task(3, command))) {
                     return R.ok();
                 } else {
                     throw new CoolException("鍛戒护涓嬪彂澶辫触");

--
Gitblit v1.9.1