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