From 562c18ed0b3ac91589cf8d23511981675f59fabd Mon Sep 17 00:00:00 2001 From: zjj <3272660260@qq.com> Date: 星期一, 18 十二月 2023 16:08:08 +0800 Subject: [PATCH] # --- src/main/java/com/zy/asrs/controller/SiteController.java | 88 ++++++++++++++++++++++++++++++++++++++++++++ 1 files changed, 88 insertions(+), 0 deletions(-) diff --git a/src/main/java/com/zy/asrs/controller/SiteController.java b/src/main/java/com/zy/asrs/controller/SiteController.java index 1305824..45efdff 100644 --- a/src/main/java/com/zy/asrs/controller/SiteController.java +++ b/src/main/java/com/zy/asrs/controller/SiteController.java @@ -232,6 +232,94 @@ } return R.error("鏇存柊澶辫触"); } + @PostMapping("/detl/out") + @ManagerAuth(memo = "淇敼绔欑偣鏁版嵁") + public R siteDetlout(@RequestParam Integer devNo, + @RequestParam Short workNo, + @RequestParam Short staNo, + @RequestParam(required = false) String pakMk, + @RequestParam(required = false) Boolean inEnable, + @RequestParam(required = false) Boolean outEnable + ) { + BasDevp basDevp = basDevpService.selectById(devNo); + if (basDevp == null) { + return R.error("绔欑偣涓嶅瓨鍦�"); + } + 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 (devNo.equals(entry.getKey())) { + StaProtocol staProtocol = entry.getValue(); + if (staProtocol == null) { + continue; + } else { + staProtocol = staProtocol.clone(); + } + if (pakMk != null) { + staProtocol.setPakMk(pakMk.equals("Y")); + } + if (inEnable != null) { + staProtocol.setInEnable(inEnable); + basDevp.setInEnable(inEnable ? "Y" : "N"); + } + if (outEnable != null) { + staProtocol.setOutEnable(outEnable); + basDevp.setOutEnable(outEnable ? "Y" : "N"); + } + staProtocol.setWorkNo((short) 0); + staProtocol.setStaNo((short) 0); + basDevpService.updateById(basDevp); + boolean result = CommandUtils.offer(SlaveType.Devp, devp.getId(), new Task(3, staProtocol), false); + if (result) { + return R.ok(); + } else { + return R.error("涓嬪彂鍛戒护澶辫触"); + } + } + } + } + return R.error("鏇存柊澶辫触"); + } + @PostMapping("/detl/in") + @ManagerAuth(memo = "淇敼绔欑偣鏁版嵁") + public R siteDetlint(@RequestParam Integer devNo, + @RequestParam Short workNo, + @RequestParam Short staNo, + @RequestParam(required = false) String pakMk, + @RequestParam(required = false) Boolean inEnable, + @RequestParam(required = false) Boolean outEnable + ) { + BasDevp basDevp = basDevpService.selectById(devNo); + if (basDevp == null) { + return R.error("绔欑偣涓嶅瓨鍦�"); + } + for (DevpSlave devp : slaveProperties.getDevp()) { + // 閬嶅巻鍏ュ簱鍙� + for (DevpSlave.Sta inSta : devp.getInSta()) { + if (!devNo.equals(inSta.getBackSta()) ){ + continue; + } + // 鑾峰彇鍏ュ簱绔欎俊鎭� + DevpThread devpThread = (DevpThread) SlaveConnection.get(SlaveType.Devp, devp.getId()); + StaProtocol staProtocol = devpThread.getStation().get(inSta.getBackSta()); + if (staProtocol == null) { + continue; + } else { + staProtocol = staProtocol.clone(); + } + staProtocol.setWorkNo((short) 9999); + staProtocol.setStaNo(inSta.getStaNo().shortValue()); + boolean result = CommandUtils.offer(SlaveType.Devp, devp.getId(), new Task(3, staProtocol), false); + if (result) { + return R.ok(); + } else { + return R.error("涓嬪彂鍛戒护澶辫触"); + } + } + } + return R.error("鏇存柊澶辫触"); + } public List<PlcErrorTableVo> staPlcErr(Map.Entry<Integer, StaProtocol> entry){ List<PlcErrorTableVo> list = new ArrayList<>(); -- Gitblit v1.9.1