From 4c6ac55bbdfd2426274014047126da179bde367c Mon Sep 17 00:00:00 2001
From: zjj <3272660260@qq.com>
Date: 星期五, 10 一月 2025 16:06:40 +0800
Subject: [PATCH] #

---
 src/main/java/com/zy/asrs/controller/RgvController.java |   81 ++++++++++++++++++++++++++++++----------
 1 files changed, 61 insertions(+), 20 deletions(-)

diff --git a/src/main/java/com/zy/asrs/controller/RgvController.java b/src/main/java/com/zy/asrs/controller/RgvController.java
index 3c86275..29e0663 100644
--- a/src/main/java/com/zy/asrs/controller/RgvController.java
+++ b/src/main/java/com/zy/asrs/controller/RgvController.java
@@ -4,6 +4,7 @@
 import com.core.annotations.ManagerAuth;
 import com.core.common.R;
 import com.core.exception.CoolException;
+import com.zy.asrs.domain.enums.CrnStatusType;
 import com.zy.asrs.domain.enums.RgvStatusType;
 import com.zy.asrs.domain.param.CrnOperatorParam;
 import com.zy.asrs.domain.param.RgvOperatorParam;
@@ -11,10 +12,12 @@
 import com.zy.asrs.domain.vo.RgvStateTableVo;
 import com.zy.asrs.entity.BasRgv;
 import com.zy.asrs.entity.BasRgvErr;
+import com.zy.asrs.entity.TaskWrk;
 import com.zy.asrs.entity.WrkMast;
 import com.zy.asrs.mapper.BasRgvErrMapper;
 import com.zy.asrs.service.BasRgvService;
 import com.zy.asrs.service.LocMastService;
+import com.zy.asrs.service.TaskWrkService;
 import com.zy.asrs.service.WrkMastService;
 import com.zy.asrs.service.impl.MainServiceImpl;
 import com.zy.core.CrnThread;
@@ -64,20 +67,57 @@
     private MainServiceImpl mainService;
     @Autowired
     private LocMastService locMastService;
+    @Autowired
+    private TaskWrkService taskWrkService;
 
 
     @ManagerAuth(memo = "澶嶄綅")
     @PostMapping("/operator/reset")
     public R crnReset(RgvOperatorParam param){
-        // 绯荤粺杩愯鐘舵�佸垽鏂�
-//        if (SystemProperties.WCS_RUNNING_STATUS.get()) {
-//            return R.error("wcs绯荤粺鐘舵�佷负寮�鍚�");
-//        }
-        short[] array = new short[9];
         RgvCommand command = new RgvCommand();
         command.setRgvNo(param.getRgvNo()); // 鍫嗗灈鏈虹紪鍙�
         command.setReset(true);
+        return rgvControl2(command)?R.ok():R.error();
+    }
+    @ManagerAuth(memo = "鑱旀満")
+    @PostMapping("/operator/auto")
+    public R crnAuto(RgvOperatorParam param){
+        RgvCommand command = new RgvCommand();
+        command.setRgvNo(param.getRgvNo()); // 鍫嗗灈鏈虹紪鍙�
+        command.setAuto(true);
+        return rgvControl2(command)?R.ok():R.error();
+    }
+    @ManagerAuth(memo = "鎭㈠浠诲姟")
+    @PostMapping("/operator/restoreTask")
+    public R crnRestoreTask(RgvOperatorParam param){
+        RgvCommand command = new RgvCommand();
+        command.setRgvNo(param.getRgvNo()); // 鍫嗗灈鏈虹紪鍙�
+        command.setRestoreTask(true);
+        return rgvControl2(command)?R.ok():R.error();
+    }
+    @ManagerAuth(memo = "瀹屾垚浠诲姟")
+    @PostMapping("/operator/compTask")
+    public R rgvCompTask(RgvOperatorParam param){
+        RgvCommand command = new RgvCommand();
+        command.setRgvNo(param.getRgvNo()); // 鍫嗗灈鏈虹紪鍙�
+        command.setCompTask(true);
+        return rgvControl2(command)?R.ok():R.error();
+    }
+    @ManagerAuth(memo = "鎬ュ仠")
+    @PostMapping("/operator/stop")
+    public R rgvStop(RgvOperatorParam param){
+        RgvCommand command = new RgvCommand();
+        command.setRgvNo(param.getRgvNo()); // 鍫嗗灈鏈虹紪鍙�
+        command.setStop(true);
+        return rgvControl2(command)?R.ok():R.error();
+    }
 
+    @ManagerAuth(memo = "鍙栨秷鎬ュ仠")
+    @PostMapping("/operator/noStop")
+    public R rgvNoStop(RgvOperatorParam param){
+        RgvCommand command = new RgvCommand();
+        command.setRgvNo(param.getRgvNo()); // 鍫嗗灈鏈虹紪鍙�
+        command.setNoStop(true);
         return rgvControl2(command)?R.ok():R.error();
     }
 
@@ -133,17 +173,19 @@
             vo.setStatusType(rgvProtocol.modeType.desc);   //  妯″紡鐘舵��
             vo.setStatus(rgvProtocol.getStatusType().desc);     //  鐘舵��
             vo.setWorkNo1(rgvProtocol.getTaskNo1());  //  宸ヤ綅1浠诲姟鍙�
-            vo.setStatus1(rgvProtocol.getStatusType1().desc);  // 宸ヤ綅1鐘舵��
-            vo.setLoading1(rgvProtocol.getLoaded1()==1?"鏈夌墿":"鏃犵墿");  // 宸ヤ綅1鏈夌墿
             vo.setRgvPos(rgvProtocol.getRgvPos());
-            vo.setRgvPos1(rgvProtocol.getRgvPosI());
-            vo.setWalkPos(rgvProtocol.getWalkPos()==1?"鍦ㄥ畾浣�":"涓嶅湪瀹氫綅");
             vo.setPakMk(rgvThread.isPakMk()?"鏃犻攣":"閿佸畾");
-//            vo.setWorkNo2(rgvProtocol.getTaskNo2());  //  宸ヤ綅2浠诲姟鍙�
-//            vo.setStatus2(rgvProtocol.getStatusType2().desc);  // 宸ヤ綅2鐘舵��
-//            vo.setLoading2(rgvProtocol.getLoaded2()==1?"鏈夌墿":"鏃犵墿");  // 宸ヤ綅2鏈夌墿
-
+            vo.setWalkPos(rgvProtocol.getAlarm() == 0?"姝e父":"鎶ヨ");
             vo.setWarnCode(String.valueOf(rgvProtocol.getAlarm()));
+            if (rgvProtocol.getTaskNo1()>0) {
+                TaskWrk taskWrk = taskWrkService.selectByWrkNo(rgvProtocol.getTaskNo1().intValue());
+                if (taskWrk != null) {
+                    vo.setStatus(CrnStatusType.process(taskWrk.getIoType()).getDesc());   //  妯″紡鐘舵��
+                    vo.setSourceStaNo(taskWrk.getStartPoint());    //  婧愮珯
+                    vo.setStaNo(taskWrk.getTargetPoint());   //  鐩爣绔�
+                    vo.setBarcode(taskWrk.getBarcode());
+                }
+            }
             if (rgvProtocol.getAlarm() > 0) {
                 BasRgvErr rgvErr = basRgvErrMapper.selectById(rgvProtocol.getAlarm());
                 vo.setAlarm(rgvErr==null?"鏈煡寮傚父":rgvErr.getErrName());
@@ -174,13 +216,12 @@
 
             vo.setWorkNo(rgvProtocol.getTaskNo1());  //  浠诲姟鍙�
             if (rgvProtocol.getTaskNo1()>0) {
-                WrkMast wrkMast = wrkMastService.selectById(rgvProtocol.getTaskNo1());
-                if (wrkMast != null) {
-                    vo.setStatus(RgvStatusType.process(wrkMast.getIoType()).getDesc());   //  妯″紡鐘舵��
-                    vo.setSourceStaNo(wrkMast.getSourceStaNo$());    //  婧愮珯
-                    vo.setStaNo(wrkMast.getStaNo$());   //  鐩爣绔�
-                    vo.setSourceLocNo(wrkMast.getSourceLocNo());    //  婧愬簱浣�
-                    vo.setLocNo(wrkMast.getLocNo());    //  鐩爣搴撲綅
+                TaskWrk taskWrk = taskWrkService.selectByWrkNo(rgvProtocol.getTaskNo1().intValue());
+                if (taskWrk != null) {
+                    vo.setStatus(CrnStatusType.process(taskWrk.getIoType()).getDesc());   //  妯″紡鐘舵��
+                    vo.setSourceStaNo(taskWrk.getStartPoint());    //  婧愮珯
+                    vo.setStaNo(taskWrk.getTargetPoint());   //  鐩爣绔�
+                    vo.setOrigin(taskWrk.getBarcode());
                 }
             } else {
                 vo.setStatus(rgvProtocol.modeType.equals(RgvModeType.AUTO)? rgvProtocol.modeType.desc: RgvModeType.HAND.desc);   //  妯″紡鐘舵��

--
Gitblit v1.9.1