From aa33e56e37cd19b88ae8eea69c5ebc7c6da8b1d2 Mon Sep 17 00:00:00 2001
From: Administrator <pjb>
Date: 星期四, 05 六月 2025 17:59:47 +0800
Subject: [PATCH] Merge remote-tracking branch 'origin/glccwcs' into glccwcs

---
 src/main/java/com/zy/asrs/controller/ConsoleController.java |   49 +++++++++++++++++++++++++++++--------------------
 1 files changed, 29 insertions(+), 20 deletions(-)

diff --git a/src/main/java/com/zy/asrs/controller/ConsoleController.java b/src/main/java/com/zy/asrs/controller/ConsoleController.java
index d7da4a6..a77541d 100644
--- a/src/main/java/com/zy/asrs/controller/ConsoleController.java
+++ b/src/main/java/com/zy/asrs/controller/ConsoleController.java
@@ -17,6 +17,7 @@
 import com.zy.asrs.mapper.BasCrnErrorMapper;
 import com.zy.asrs.mapper.LocMastMapper;
 import com.zy.asrs.mapper.ReportQueryMapper;
+import com.zy.asrs.mapper.TaskWrkMapper;
 import com.zy.asrs.service.BasCrnpService;
 import com.zy.asrs.service.BasDevpService;
 import com.zy.asrs.service.DeviceErrorService;
@@ -42,6 +43,7 @@
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.*;
 
+import javax.annotation.Resource;
 import java.text.SimpleDateFormat;
 import java.util.*;
 
@@ -70,6 +72,9 @@
     private DeviceErrorService deviceErrorService;
     @Autowired
     private BasCrnpService basCrnpService;
+
+    @Resource
+    private TaskWrkMapper taskWrkMapper;
 
     @PostMapping("/system/running/status")
     @ManagerAuth(memo = "绯荤粺杩愯鐘舵��")
@@ -143,7 +148,7 @@
 //            Short totalBay = locMastMapper.selectTotalBay();
 
             vo.setOffset((double) new Random().nextInt(560));     //  鍫嗗灈鏈哄亸绉婚噺
-            vo.setBay((short) (crnProtocol.getBay() - crn.getOffset()));    //  褰撳墠鍒�
+            vo.setBay(crnProtocol.getBay());    //  褰撳墠鍒�
             /**
              * 鍫嗗灈鏈虹姸鎬佸垽鏂�
              */
@@ -151,9 +156,10 @@
                 vo.setCrnStatus(CrnStatusType.MACHINE_ERROR);
             } else {
                 if (crnProtocol.getTaskNo() > 0) {
-                    WrkMast wrkMast = wrkMastService.selectById(crnProtocol.getTaskNo());
-                    if (wrkMast != null) {
-                        vo.setCrnStatus(CrnStatusType.process(wrkMast.getIoType()));
+//                    WrkMast wrkMast = wrkMastService.selectById(crnProtocol.getTaskNo());
+                    TaskWrk taskWrk = taskWrkMapper.selectByWrkNo(Integer.valueOf(crnProtocol.getTaskNo()));
+                    if (taskWrk != null) {
+                        vo.setCrnStatus(CrnStatusType.process(taskWrk.getIoType()));
                     } else {
                         vo.setCrnStatus(crnProtocol.modeType.equals(CrnModeType.AUTO) ? CrnStatusType.MACHINE_AUTO : CrnStatusType.MACHINE_UN_AUTO);
                     }
@@ -279,14 +285,16 @@
                     vo.setWorkNo(staProtocol.getWorkNo());   // 宸ヤ綔鍙�
 
                     if (staProtocol.getWorkNo() > 0) {
-                        WrkMast wrkMast = wrkMastService.selectById(staProtocol.getWorkNo());
-                        if (wrkMast != null) {
-                            vo.setWrkSts(wrkMast.getWrkSts$());   // 宸ヤ綔鐘舵��
-                            vo.setIoType(wrkMast.getIoType$());   //  鍏ュ嚭搴撶被鍨�
-                            vo.setSourceStaNo(wrkMast.getSourceStaNo$());
-                            vo.setStaNo(wrkMast.getStaNo$());
-                            vo.setSourceLocNo(wrkMast.getSourceLocNo$());
-                            vo.setLocNo(wrkMast.getLocNo$());
+//                        WrkMast wrkMast = wrkMastService.selectById(staProtocol.getWorkNo());
+                        TaskWrk taskWrk = taskWrkMapper.selectByWrkNo(Integer.valueOf(staProtocol.getWorkNo()));
+
+                        if (taskWrk != null) {
+                            vo.setWrkSts(taskWrk.getWrkSts$());   // 宸ヤ綔鐘舵��
+                            vo.setIoType(taskWrk.getIoType$());   //  鍏ュ嚭搴撶被鍨�
+                            vo.setSourceStaNo(taskWrk.getStartPoint());
+                            vo.setStaNo(taskWrk.getTargetPoint());
+                            vo.setSourceLocNo(taskWrk.getStartPoint());
+                            vo.setLocNo(taskWrk.getTargetPoint());
                         }
                     }
 
@@ -330,14 +338,15 @@
                 }
 
                 if (crnProtocol.getTaskNo() > 0) {
-                    WrkMast wrkMast = wrkMastService.selectById(crnProtocol.getTaskNo());
-                    if (wrkMast != null) {
-                        vo.setSourceStaNo(wrkMast.getSourceStaNo$());
-                        vo.setStaNo(wrkMast.getStaNo$());
-                        vo.setWrkSts(wrkMast.getWrkSts$());   // 宸ヤ綔鐘舵��
-                        vo.setIoType(wrkMast.getIoType$());   //  鍏ュ嚭搴撶被鍨�
-                        vo.setSourceLocNo(wrkMast.getSourceLocNo$());
-                        vo.setLocNo(wrkMast.getLocNo$());
+                    TaskWrk taskWrk = taskWrkMapper.selectByWrkNo(Integer.valueOf(crnProtocol.getTaskNo()));
+//                    WrkMast wrkMast = wrkMastService.selectById(crnProtocol.getTaskNo());
+                    if (taskWrk != null) {
+                        vo.setSourceStaNo(taskWrk.getStartPoint());
+                        vo.setStaNo(taskWrk.getTargetPoint());
+                        vo.setWrkSts(taskWrk.getWrkSts$());   // 宸ヤ綔鐘舵��
+                        vo.setIoType(taskWrk.getIoType$());   //  鍏ュ嚭搴撶被鍨�
+                        vo.setSourceLocNo(taskWrk.getStartPoint());
+                        vo.setLocNo(taskWrk.getTargetPoint());
                         vo.setCrnStatus(crnProtocol.getStatusType().desc);
                         vo.setError("");    // todo
                     }

--
Gitblit v1.9.1