From 11eaa61d046200bb5eeecfc35d1ca1964505136d Mon Sep 17 00:00:00 2001
From: lsh <lsh@163.com>
Date: 星期三, 23 十月 2024 11:46:07 +0800
Subject: [PATCH] *

---
 src/main/java/com/zy/asrs/controller/SiteController.java |   38 ++++++++++++++++++++++++++++++++++----
 1 files changed, 34 insertions(+), 4 deletions(-)

diff --git a/src/main/java/com/zy/asrs/controller/SiteController.java b/src/main/java/com/zy/asrs/controller/SiteController.java
index e0aba4d..7923b03 100644
--- a/src/main/java/com/zy/asrs/controller/SiteController.java
+++ b/src/main/java/com/zy/asrs/controller/SiteController.java
@@ -2,20 +2,26 @@
 
 import com.baomidou.mybatisplus.mapper.EntityWrapper;
 import com.core.annotations.ManagerAuth;
+import com.core.common.Cools;
 import com.core.common.R;
 import com.zy.asrs.domain.vo.PlcErrorTableVo;
 import com.zy.asrs.domain.vo.SiteTableVo;
+import com.zy.asrs.domain.vo.SteDataVo;
 import com.zy.asrs.entity.BasDevp;
+import com.zy.asrs.entity.BasSte;
 import com.zy.asrs.service.BasDevpService;
+import com.zy.asrs.service.BasSteService;
 import com.zy.core.cache.MessageQueue;
 import com.zy.core.cache.OutputQueue;
 import com.zy.core.cache.SlaveConnection;
 import com.zy.core.enums.SlaveType;
 import com.zy.core.model.DevpSlave;
+import com.zy.core.model.SteSlave;
 import com.zy.core.model.Task;
 import com.zy.core.model.protocol.StaProtocol;
 import com.zy.core.properties.SlaveProperties;
 import com.zy.core.DevpThread;
+import com.zy.core.thread.SiemensDevpThread;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.*;
 
@@ -32,6 +38,8 @@
 @RequestMapping("/site")
 public class SiteController {
 
+    @Autowired
+    private BasSteService basSteService;
     @Autowired
     private SlaveProperties slaveProperties;
     @Autowired
@@ -121,7 +129,7 @@
     /************************** 璇︽儏鎿嶄綔 ******************************/
     /****************************************************************/
 
-    @GetMapping("/detl/{siteId}")
+    @GetMapping("/detl/wcs/{siteId}")
     public R siteDetl(@PathVariable("siteId") Integer siteId){
         SiteTableVo vo = new SiteTableVo();
         for (DevpSlave devp : slaveProperties.getDevp()) {
@@ -150,8 +158,8 @@
     @PostMapping("/detl/update")
     @ManagerAuth(memo = "淇敼绔欑偣鏁版嵁")
     public R siteDetlUpdate(@RequestParam Integer siteId,
-                            @RequestParam Short workNo,
-                            @RequestParam Short staNo,
+                            @RequestParam Long workNo,
+                            @RequestParam Integer staNo,
                             @RequestParam String pakMk){
         for (DevpSlave devp : slaveProperties.getDevp()) {
             DevpThread devpThread = (DevpThread) SlaveConnection.get(SlaveType.Devp, devp.getId());
@@ -173,7 +181,7 @@
                     if (pakMk != null) {
                         staProtocol.setPakMk(pakMk.equals("Y"));
                     }
-                    boolean result = MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(2, staProtocol));
+                    boolean result = MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(5, staProtocol));
                     if (result) {
                         return R.ok();
                     } else {
@@ -185,5 +193,27 @@
         return R.error("plc宸叉帀绾�");
     }
 
+    @GetMapping("/detl/{steNo}")
+    public R steDetl(@PathVariable("steNo") Integer steNo){
+        SteDataVo vo = new SteDataVo();
+        for (SteSlave ste : slaveProperties.getSte()) {
+            if (steNo.equals(ste.getId())) {
+                vo.setSteNo(ste.getId());
+                BasSte basSte = basSteService.selectById(ste.getId());
+                if (!Cools.isEmpty(basSte)) {
+                    vo.setRow(basSte.getRow());
+                    vo.setBay(basSte.getBay());
+                    vo.setLev(basSte.getLev());
+                    vo.setCrnNo(basSte.getCrnNo());
+                    vo.setWorkNo(basSte.getWrkNo());
+                    vo.setPakMk(basSte.getPakMk());
+                }
+                break;
+            }
+        }
+        return R.ok().add(vo);
+    }
+
+
 
 }

--
Gitblit v1.9.1