From d8a9cfff5ff3f3deb33ef3dd1862f53415cc9b46 Mon Sep 17 00:00:00 2001 From: Junjie <xjj@123> Date: 星期一, 17 二月 2025 14:23:34 +0800 Subject: [PATCH] # --- src/main/java/com/zy/asrs/controller/ConsoleController.java | 165 ------------------------------------------------------- 1 files changed, 0 insertions(+), 165 deletions(-) diff --git a/src/main/java/com/zy/asrs/controller/ConsoleController.java b/src/main/java/com/zy/asrs/controller/ConsoleController.java index 7aa5a3b..89acbce 100644 --- a/src/main/java/com/zy/asrs/controller/ConsoleController.java +++ b/src/main/java/com/zy/asrs/controller/ConsoleController.java @@ -2,36 +2,18 @@ import com.alibaba.fastjson.JSON; import com.core.annotations.ManagerAuth; -import com.core.common.Arith; import com.core.common.Cools; import com.core.common.R; -import com.zy.asrs.domain.enums.SiteStatusType; import com.zy.asrs.domain.param.SystemSwitchParam; -import com.zy.asrs.domain.vo.*; -import com.zy.asrs.entity.BasDevp; import com.zy.asrs.entity.BasMap; -import com.zy.asrs.entity.WrkMast; -import com.zy.asrs.mapper.LocMastMapper; -import com.zy.asrs.service.BasDevpService; import com.zy.asrs.service.BasMapService; -import com.zy.asrs.service.WrkMastService; -import com.zy.common.CodeRes; import com.zy.common.model.MapNode; import com.zy.common.model.enums.NavigationMapType; import com.zy.common.utils.NavigateMapData; import com.zy.common.utils.RedisUtil; -import com.zy.core.DevpThread; -import com.zy.core.Slave; -import com.zy.core.cache.OutputQueue; -import com.zy.core.cache.SlaveConnection; import com.zy.core.enums.RedisKeyType; -import com.zy.core.enums.SlaveType; -import com.zy.core.model.DevpSlave; -import com.zy.core.model.protocol.StaProtocol; import com.zy.core.properties.SlaveProperties; import com.zy.core.properties.SystemProperties; -import com.zy.core.thread.BarcodeThread; -import com.zy.core.thread.ScaleThread; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Value; @@ -52,13 +34,7 @@ @Autowired private SlaveProperties slaveProperties; @Autowired - private WrkMastService wrkMastService; - @Autowired - private BasDevpService basDevpService; - @Autowired private BasMapService basMapService; - @Autowired - private LocMastMapper locMastMapper; @Autowired private RedisUtil redisUtil; @Value("${super.pwd}") @@ -89,147 +65,6 @@ Thread.sleep(200L); SystemProperties.WCS_RUNNING_STATUS.set(param.getOperatorType()==1?Boolean.TRUE:Boolean.FALSE); return R.ok().add(Cools.add("status", SystemProperties.WCS_RUNNING_STATUS.get())); - } - - /****************************************************************/ - /************************** 瀹炴椂鏁版嵁 ******************************/ - /****************************************************************/ - - @PostMapping("/latest/data/site") - @ManagerAuth(memo = "绔欑偣瀹炴椂鏁版嵁") - public R siteLatestData(){ - List<SiteLatestDataVo> vos = new ArrayList<>(); - Map<Integer, StaProtocol> stations = new HashMap<>(); - for (DevpSlave devp : slaveProperties.getDevp()) { - DevpThread devpThread = (DevpThread) SlaveConnection.get(SlaveType.Devp, devp.getId()); - if (null != devpThread) { - stations.putAll(devpThread.getStation()); - } - } - for (Map.Entry<Integer, StaProtocol> entry : stations.entrySet()) { - SiteLatestDataVo vo = new SiteLatestDataVo(); - StaProtocol staProtocol = entry.getValue(); - vo.setSiteId(String.valueOf(entry.getKey())); // 绔欑偣缂栧彿 - vo.setWorkNo(staProtocol.getWorkNo()); // 宸ヤ綔鍙� - vo.setSiteStatus(SiteStatusType.process(staProtocol)); // 鐘舵�� - vos.add(vo); - } - return R.ok().add(vos); - } - - @PostMapping("/latest/data/barcode") - @ManagerAuth(memo = "鏉$爜鎵弿浠疄鏃舵暟鎹�") - public R barcodeLatestData(){ - List<BarcodeDataVo> list = new ArrayList<>(); - for (Slave barcode : slaveProperties.getBarcode()) { - BarcodeThread barcodeThread = (BarcodeThread) SlaveConnection.get(SlaveType.Barcode, barcode.getId()); - if (null == barcodeThread) { - continue; - } - BarcodeDataVo vo = new BarcodeDataVo(); - vo.setBarcodeId(barcode.getId()); - vo.setCodeValue(barcodeThread.getBarcode()); - list.add(vo); - } - return R.ok().add(list); - } - - @PostMapping("/latest/data/scale") - @ManagerAuth(memo = "纾呯Г瀹炴椂鏁版嵁") - public R scaleLatestData(){ - List<ScaleDataVo> list = new ArrayList<>(); - for (Slave scale : slaveProperties.getScale()) { - ScaleThread scaleThread = (ScaleThread) SlaveConnection.get(SlaveType.Scale, scale.getId()); - if (null == scaleThread) { - continue; - } - ScaleDataVo vo = new ScaleDataVo(); - vo.setScaleId(scale.getId()); - vo.setValue(String.valueOf(Arith.multiplys(1, scaleThread.getScale(), 1))); - list.add(vo); - } - return R.ok().add(list); - } - - /****************************************************************/ - /************************** 璇︽儏鎿嶄綔 ******************************/ - /****************************************************************/ - - @PostMapping("/site/detail") - @ManagerAuth(memo = "杈撻�佽澶囨暟鎹鎯�") - public R siteDetail(@RequestParam Integer siteId){ - if (Cools.isEmpty(siteId)){ - return R.parse(CodeRes.EMPTY); - } - SiteDetailVo vo = new SiteDetailVo(); - for (DevpSlave devp : slaveProperties.getDevp()) { - DevpThread devpThread = (DevpThread) SlaveConnection.get(SlaveType.Devp, devp.getId()); - if (null != devpThread) { - StaProtocol staProtocol = devpThread.getStation().get(siteId); - if (staProtocol != null) { - BasDevp basDevp = basDevpService.selectById(siteId); - if (basDevp == null) { - return R.error("鏁版嵁搴撶淮鎶ゅ紓甯�"); - } - vo.setSiteId(siteId); // 绔欑偣缂栧彿 - 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$()); - } - } - - vo.setAutoing(staProtocol.isAutoing()?"Y":"N"); // 鑷姩 - vo.setLoading(staProtocol.isLoading()?"Y":"N"); // 鏈夌墿 - - vo.setCanining(basDevp.getCanining()); // 鑳藉叆 - vo.setCanouting(basDevp.getCanouting()); // 鑳藉嚭 - - return R.ok().add(vo); - } - } - } - return R.error(); - - } - - @Deprecated - @PostMapping("/site/update") - @ManagerAuth(memo = "杈撻�佽澶囨暟鎹慨鏀�") - public R updateSite(){ - return R.ok(); - } - - @Deprecated - @PostMapping("/crn/update") - @ManagerAuth(memo = "鍫嗗灈鏈烘暟鎹慨鏀�") - public R updateCrn(){ - return R.ok(); - } - - @GetMapping("/barcode/output/site") - public R barcodeOutput(){ - return R.ok().add(JSON.toJSONString(new ArrayList<>(OutputQueue.BARCODE))); - } - - @GetMapping("/barcode/list") - public R barcodeList(){ - ArrayList<HashMap<String, Object>> list = new ArrayList<>(); - for (Slave slave : slaveProperties.getBarcode()) { - HashMap<String, Object> map = new HashMap<>(); - BarcodeThread barcodeThread = (BarcodeThread) SlaveConnection.get(SlaveType.Barcode, slave.getId()); - map.put("id", slave.getId()); - map.put("barcode", barcodeThread.getBarcode()); - list.add(map); - } - return R.ok().add(list); } /** -- Gitblit v1.9.1