From 364b9ccc44bc6863280c5cc00aa8512cfff548d4 Mon Sep 17 00:00:00 2001 From: ZY <zc857179121@qq.com> Date: 星期五, 25 四月 2025 15:27:18 +0800 Subject: [PATCH] 123 --- src/main/java/com/zy/asrs/controller/ConsoleController.java | 78 ++++++++++++++++++++++----------------- 1 files changed, 44 insertions(+), 34 deletions(-) diff --git a/src/main/java/com/zy/asrs/controller/ConsoleController.java b/src/main/java/com/zy/asrs/controller/ConsoleController.java index 6a5eb26..d7da4a6 100644 --- a/src/main/java/com/zy/asrs/controller/ConsoleController.java +++ b/src/main/java/com/zy/asrs/controller/ConsoleController.java @@ -17,6 +17,7 @@ import com.zy.asrs.mapper.BasCrnErrorMapper; import com.zy.asrs.mapper.LocMastMapper; import com.zy.asrs.mapper.ReportQueryMapper; +import com.zy.asrs.service.BasCrnpService; import com.zy.asrs.service.BasDevpService; import com.zy.asrs.service.DeviceErrorService; import com.zy.asrs.service.WrkMastService; @@ -67,29 +68,31 @@ private ReportQueryMapper reportQueryMapper; @Autowired private DeviceErrorService deviceErrorService; + @Autowired + private BasCrnpService basCrnpService; @PostMapping("/system/running/status") @ManagerAuth(memo = "绯荤粺杩愯鐘舵��") - public R systemRunningStatus(){ + public R systemRunningStatus() { return R.ok().add(Cools.add("status", SystemProperties.WCS_RUNNING_STATUS.get())); } @PostMapping("/system/switch") @ManagerAuth(memo = "绯荤粺杩愯寮�鍏虫搷浣�") public R systemSwitch(SystemSwitchParam param) throws InterruptedException { - if (Cools.isEmpty(param.getOperatorType())){ + if (Cools.isEmpty(param.getOperatorType())) { return R.error(); } if (param.getOperatorType() == 0) { - if (Cools.isEmpty(param.getPassword())){ + if (Cools.isEmpty(param.getPassword())) { return R.error("璇疯緭鍏ュ彛浠�"); } - if (!param.getPassword().equals(SystemProperties.WCS_PASSWORD)){ + if (!param.getPassword().equals(SystemProperties.WCS_PASSWORD)) { return R.error("鍙d护閿欒"); } } Thread.sleep(200L); - SystemProperties.WCS_RUNNING_STATUS.set(param.getOperatorType()==1?Boolean.TRUE:Boolean.FALSE); + SystemProperties.WCS_RUNNING_STATUS.set(param.getOperatorType() == 1 ? Boolean.TRUE : Boolean.FALSE); return R.ok().add(Cools.add("status", SystemProperties.WCS_RUNNING_STATUS.get())); } @@ -99,7 +102,7 @@ @PostMapping("/latest/data/site") @ManagerAuth(memo = "绔欑偣瀹炴椂鏁版嵁") - public R siteLatestData(){ + public R siteLatestData() { List<SiteLatestDataVo> vos = new ArrayList<>(); Map<Integer, StaProtocol> stations = new HashMap<>(); for (DevpSlave devp : slaveProperties.getDevp()) { @@ -122,7 +125,7 @@ @PostMapping("/latest/data/crn") @ManagerAuth(memo = "鍫嗗灈鏈哄疄鏃舵暟鎹�") - public R crnLatestData(){ + public R crnLatestData() { List<CrnLatestDataVo> vos = new ArrayList<>(); for (CrnSlave crn : slaveProperties.getCrn()) { // 鑾峰彇鍫嗗灈鏈轰俊鎭� @@ -147,15 +150,15 @@ if (crnProtocol.getAlarm1() > 0) { vo.setCrnStatus(CrnStatusType.MACHINE_ERROR); } else { - if (crnProtocol.getTaskNo()>0) { + if (crnProtocol.getTaskNo() > 0) { WrkMast wrkMast = wrkMastService.selectById(crnProtocol.getTaskNo()); if (wrkMast != null) { vo.setCrnStatus(CrnStatusType.process(wrkMast.getIoType())); } else { - vo.setCrnStatus(crnProtocol.modeType.equals(CrnModeType.AUTO)? CrnStatusType.MACHINE_AUTO: CrnStatusType.MACHINE_UN_AUTO); + vo.setCrnStatus(crnProtocol.modeType.equals(CrnModeType.AUTO) ? CrnStatusType.MACHINE_AUTO : CrnStatusType.MACHINE_UN_AUTO); } } else { - vo.setCrnStatus(crnProtocol.modeType.equals(CrnModeType.AUTO)? CrnStatusType.MACHINE_AUTO: CrnStatusType.MACHINE_UN_AUTO); + vo.setCrnStatus(crnProtocol.modeType.equals(CrnModeType.AUTO) ? CrnStatusType.MACHINE_AUTO : CrnStatusType.MACHINE_UN_AUTO); } } vos.add(vo); @@ -166,7 +169,7 @@ @PostMapping("/latest/data/barcode") @ManagerAuth(memo = "鏉$爜鎵弿浠疄鏃舵暟鎹�") - public R barcodeLatestData(){ + public R barcodeLatestData() { List<BarcodeDataVo> list = new ArrayList<>(); for (Slave barcode : slaveProperties.getBarcode()) { BarcodeThread barcodeThread = (BarcodeThread) SlaveConnection.get(SlaveType.Barcode, barcode.getId()); @@ -183,7 +186,7 @@ @PostMapping("/latest/data/scale") @ManagerAuth(memo = "纾呯Г瀹炴椂鏁版嵁") - public R scaleLatestData(){ + public R scaleLatestData() { List<ScaleDataVo> list = new ArrayList<>(); for (Slave scale : slaveProperties.getScale()) { ScaleThread scaleThread = (ScaleThread) SlaveConnection.get(SlaveType.Scale, scale.getId()); @@ -258,8 +261,8 @@ @PostMapping("/site/detail") @ManagerAuth(memo = "杈撻�佽澶囨暟鎹鎯�") - public R siteDetail(@RequestParam Integer siteId){ - if (Cools.isEmpty(siteId)){ + public R siteDetail(@RequestParam Integer siteId) { + if (Cools.isEmpty(siteId)) { return R.parse(CodeRes.EMPTY); } SiteDetailVo vo = new SiteDetailVo(); @@ -287,8 +290,8 @@ } } - vo.setAutoing(staProtocol.isAutoing()?"Y":"N"); // 鑷姩 - vo.setLoading(staProtocol.isLoading()?"Y":"N"); // 鏈夌墿 + vo.setAutoing(staProtocol.isAutoing() ? "Y" : "N"); // 鑷姩 + vo.setLoading(staProtocol.isLoading() ? "Y" : "N"); // 鏈夌墿 vo.setCanining(basDevp.getCanining()); // 鑳藉叆 vo.setCanouting(basDevp.getCanouting()); // 鑳藉嚭 @@ -303,13 +306,18 @@ @PostMapping("/crn/detail") @ManagerAuth(memo = "鍫嗗灈鏈鸿澶囨暟鎹鎯�") - public R crnDetail(@RequestParam Integer crnNo){ - if (Cools.isEmpty(crnNo)){ + public R crnDetail(@RequestParam Integer crnNo) { + if (Cools.isEmpty(crnNo)) { return R.parse(CodeRes.EMPTY); } CrnDetailVo vo = new CrnDetailVo(); for (CrnSlave crnSlave : slaveProperties.getCrn()) { if (crnSlave.getId().equals(crnNo)) { + BasCrnp basCrnp = basCrnpService.selectById(crnNo); + if (basCrnp == null) { + return R.error("鏁版嵁搴撶淮鎶ゅ紓甯�"); + } + SiemensCrnThread crnThread = (SiemensCrnThread) SlaveConnection.get(SlaveType.Crn, crnSlave.getId()); CrnProtocol crnProtocol = crnThread.getCrnProtocol(); vo.setCrnNo(crnNo); @@ -334,6 +342,8 @@ vo.setError(""); // todo } } + vo.setInEnable(basCrnp.getInEnable());//鍙叆 + vo.setOutEnable(basCrnp.getOutEnable());//鍙嚭 return R.ok().add(vo); } } @@ -343,19 +353,19 @@ @Deprecated @PostMapping("/site/update") @ManagerAuth(memo = "杈撻�佽澶囨暟鎹慨鏀�") - public R updateSite(){ + public R updateSite() { return R.ok(); } @Deprecated @PostMapping("/crn/update") @ManagerAuth(memo = "鍫嗗灈鏈烘暟鎹慨鏀�") - public R updateCrn(){ + public R updateCrn() { return R.ok(); } @GetMapping("/barcode/output/site") - public R crnOutput(){ + public R crnOutput() { ArrayList<JSONObject> jsonObjects = new ArrayList<>(OutputQueue.SCALE); jsonObjects.sort(new Comparator<JSONObject>() { @Override @@ -369,12 +379,12 @@ } @PostMapping("loc/pie/charts") - public R dsa(){ - Map<String,Object> map=new HashMap<String, Object>(); - List<ChartBean> list = new ArrayList<ChartBean>(); + public R dsa() { + Map<String, Object> map = new HashMap<String, Object>(); + List<ChartBean> list = new ArrayList<ChartBean>(); LocChartPie locUseRate = reportQueryMapper.getLocUseRate(); - if(locUseRate!=null) { + if (locUseRate != null) { ChartBean fqty = new ChartBean(); fqty.setName("鍦ㄥ簱搴撲綅"); fqty.setY(locUseRate.getFqty()); @@ -395,37 +405,37 @@ xqty.setY(locUseRate.getXqty()); list.add(xqty); } - map.put("rows",list); + map.put("rows", list); return R.ok(map); } @PostMapping("locIo/line/charts") - public R locIoLineCharts(){ - Map<String,Object> map=new HashMap<String, Object>(); + public R locIoLineCharts() { + Map<String, Object> map = new HashMap<String, Object>(); List<AxisBean> list = new ArrayList<AxisBean>(); List<WorkChartAxis> listChart = reportQueryMapper.getChartAxis(); - if(listChart!=null) { + if (listChart != null) { ArrayList<Integer> data1 = new ArrayList<Integer>(); ArrayList<Integer> data2 = new ArrayList<Integer>(); SimpleDateFormat sf = new SimpleDateFormat("yyyy-MM-dd"); Calendar calendar = Calendar.getInstance(); calendar.add(Calendar.DATE, -12); - for(int i=0;i<12;i++) { + for (int i = 0; i < 12; i++) { boolean flag = true; calendar.add(Calendar.DATE, 1); String str = sf.format(calendar.getTime()); - for(WorkChartAxis workChart : listChart) { - if(str.equals(workChart.getYmd())) { + for (WorkChartAxis workChart : listChart) { + if (str.equals(workChart.getYmd())) { data1.add(workChart.getInqty()); data2.add(workChart.getOutqty()); flag = false; break; } } - if(flag) { + if (flag) { data1.add(0); data2.add(0); } @@ -441,7 +451,7 @@ outqty.setData(data2.toArray(array2)); list.add(outqty); } - map.put("rows",list); + map.put("rows", list); return R.ok(map); } -- Gitblit v1.9.1