| | |
| | | vo.setRgvNo(basRgv.getRgvNo()); // RGV号 |
| | | list.add(vo); |
| | | // 获取RGV信息 |
| | | RgvThread rgvThread = (RgvThread) SlaveConnection.get(SlaveType.Crn, basRgv.getRgvNo()); |
| | | RgvThread rgvThread = (RgvThread) SlaveConnection.get(SlaveType.Rgv, basRgv.getRgvNo()); |
| | | if (rgvThread == null) { |
| | | continue; |
| | | } |
| | |
| | | continue; |
| | | } |
| | | |
| | | vo.setWorkNo1(rgvProtocol.getTaskNo1()); // 任务号 |
| | | vo.setWorkNo(rgvProtocol.getTaskNo1()); // 任务号 |
| | | if (rgvProtocol.getTaskNo1()>0) { |
| | | WrkMast wrkMast = wrkMastService.selectById(rgvProtocol.getTaskNo1()); |
| | | if (wrkMast != null) { |
| | |
| | | StringBuilder str = new StringBuilder(); |
| | | String s; |
| | | int i = 0; |
| | | while((s = OutputQueue.CRN.poll()) != null && i <=10) { |
| | | while((s = OutputQueue.RGV.poll()) != null && i <=10) { |
| | | str.append("\n").append(s); |
| | | i++; |
| | | } |
| | | return R.ok().add(str.toString()); |
| | | } |
| | | |
| | | @GetMapping("/demo/status") |
| | | public R demoStatus(){ |
| | | List<Map<String, Object>> res = new ArrayList<>(); |
| | | for (RgvSlave rgvSlave : slaveProperties.getRgv()) { |
| | | Map<String, Object> map = new HashMap<>(); |
| | | map.put("rgvNo", rgvSlave.getId()); |
| | | map.put("demo", rgvSlave.getDemo()); |
| | | res.add(map); |
| | | } |
| | | return R.ok().add(res); |
| | | } |
| | | |
| | | /****************************************************************/ |