From d1ef13d1f116e69a7f44e78d64fd0fe4ce2cad80 Mon Sep 17 00:00:00 2001
From: Junjie <fallin.jie@qq.com>
Date: 星期一, 10 二月 2025 13:17:10 +0800
Subject: [PATCH] #

---
 src/main/java/com/zy/asrs/controller/SiteController.java |   49 ++++++++++++++++++++++++++++++++-----------------
 1 files changed, 32 insertions(+), 17 deletions(-)

diff --git a/src/main/java/com/zy/asrs/controller/SiteController.java b/src/main/java/com/zy/asrs/controller/SiteController.java
index 30500f8..2f5acc9 100644
--- a/src/main/java/com/zy/asrs/controller/SiteController.java
+++ b/src/main/java/com/zy/asrs/controller/SiteController.java
@@ -7,6 +7,7 @@
 import com.zy.asrs.domain.vo.SiteTableVo;
 import com.zy.asrs.entity.BasDevp;
 import com.zy.asrs.service.BasDevpService;
+import com.zy.core.DevpThread;
 import com.zy.core.cache.MessageQueue;
 import com.zy.core.cache.OutputQueue;
 import com.zy.core.cache.SlaveConnection;
@@ -15,19 +16,16 @@
 import com.zy.core.model.Task;
 import com.zy.core.model.protocol.StaProtocol;
 import com.zy.core.properties.SlaveProperties;
-import com.zy.core.thread.DevpThread;
+import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.*;
 
-import java.util.ArrayList;
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
+import java.util.*;
 
 /**
  * 杈撻�佽澶囨帴鍙�
- * Created by vincent on 2020-06-01
  */
+@Slf4j
 @RestController
 @RequestMapping("/site")
 public class SiteController {
@@ -60,9 +58,30 @@
             vo.setLoading(staProtocol.isLoading()?"Y":"N");     // 鏈夌墿
             vo.setInEnable(staProtocol.isInEnable()?"Y":"N");   // 鍙叆
             vo.setOutEnable(staProtocol.isOutEnable()?"Y":"N"); // 鍙嚭
+            vo.setLiftArrival(staProtocol.isLiftArrival()?"Y":"N"); // 鎻愬崌鏈哄埌浣嶄俊鍙�
+            vo.setShuttleTakeEnable(staProtocol.isShuttleTakeEnable()?"Y":"N"); // 绌挎杞﹀彲鍙栦俊鍙�
             vo.setPakMk(staProtocol.isPakMk()?"Y":"N");       // 鍏ュ簱鏍囪
             vo.setEmptyMk(staProtocol.isEmptyMk()?"Y":"N");     // 绌烘澘淇″彿
-            vo.setStaNo(staProtocol.getStaNo());                // 鐩爣绔�
+            vo.setStaNo(staProtocol.getStaNo() == null ? 0 : staProtocol.getStaNo());                // 鐩爣绔�
+            vo.setLocType1(staProtocol.getLocType1()==null?"-":staProtocol.getLocType1().toString());                // 楂樹綆淇″彿
+
+            String outInModel = "-";
+            if (staProtocol.getOutInModel() != null) {
+                switch (staProtocol.getOutInModel().intValue()) {
+                    case 0:
+                        outInModel = "default";
+                        break;
+                    case 1:
+                        outInModel = "in";
+                        break;
+                    case 2:
+                        outInModel = "out";
+                        break;
+                    default:
+                        outInModel = "-";
+                }
+            }
+            vo.setOutInModel(outInModel);                // 鍑哄叆搴撴ā寮�
         }
         return R.ok().add(list);
     }
@@ -77,14 +96,6 @@
 
             for(Map.Entry<Integer, StaProtocol> entry : station.entrySet()) {
                 StaProtocol staProtocol = entry.getValue();
-//                if (staProtocol) {
-//                    PlcErrorTableVo vo = new PlcErrorTableVo();
-//                    vo.setNo(entry.getKey());   //  搴忓彿
-//
-//                    vo.setPlcDesc("");  //  todo:luxiaotao plc閿欒鎻忚堪
-//                    vo.setError("");    //  todo:luxiaotao 寮傚父淇℃伅
-//                    list.add(vo);
-//                }
             }
 
         }
@@ -97,7 +108,6 @@
             }else{
                 return -1;
             }
-
         });
         return R.ok().add(list);
     }
@@ -148,19 +158,24 @@
     @ManagerAuth(memo = "淇敼绔欑偣鏁版嵁")
     public R siteDetlUpdate(@RequestParam Integer siteId,
                             @RequestParam Short workNo,
-                            @RequestParam Short staNo){
+                            @RequestParam Short staNo,
+                            @RequestParam String pakMk){
         for (DevpSlave devp : slaveProperties.getDevp()) {
             DevpThread devpThread = (DevpThread) SlaveConnection.get(SlaveType.Devp, devp.getId());
             Map<Integer, StaProtocol> station = devpThread.getStation();
             for (Map.Entry<Integer, StaProtocol> entry : station.entrySet()) {
                 if (siteId.equals(entry.getKey())) {
                     StaProtocol staProtocol = entry.getValue();
+                    staProtocol = staProtocol.clone();
                     if (workNo != null) {
                         staProtocol.setWorkNo(workNo);
                     }
                     if (staNo != null) {
                         staProtocol.setStaNo(staNo);
                     }
+                    if (pakMk != null) {
+                        staProtocol.setPakMk(pakMk.equals("Y"));
+                    }
                     boolean result = MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(2, staProtocol));
                     if (result) {
                         return R.ok();

--
Gitblit v1.9.1