| | |
| | | package com.zy.asrs.controller; |
| | | |
| | | import com.alibaba.fastjson.JSONObject; |
| | | import com.baomidou.mybatisplus.mapper.EntityWrapper; |
| | | import com.core.common.Arith; |
| | | import com.core.common.Cools; |
| | | import com.core.common.R; |
| | |
| | | import com.zy.asrs.domain.dto.LocChartPie; |
| | | import com.zy.asrs.domain.dto.WorkChartAxis; |
| | | import com.zy.asrs.entity.BasShuttleErr; |
| | | import com.zy.asrs.entity.WrkMast; |
| | | import com.zy.asrs.mapper.ReportQueryMapper; |
| | | import com.zy.asrs.service.BasDevpService; |
| | | import com.zy.asrs.service.BasShuttleErrService; |
| | |
| | | private SlaveProperties slaveProperties; |
| | | @Autowired |
| | | private BasShuttleErrService basShuttleErrService; |
| | | |
| | | |
| | | @Autowired |
| | | private RedisUtil redisUtil; |
| | |
| | | public R monitorLed(@RequestParam("ledId") Integer ledId) { |
| | | int dev_no1 = 1011; |
| | | int dev_no2 = 1012; |
| | | int dev_no3 = 1015; |
| | | int dev_no3 = 0; |
| | | if (ledId == 1) { |
| | | dev_no1 = 1011; |
| | | dev_no2 = 1012; |
| | |
| | | Object o2 = redisUtil.get("LED_" + dev_no2); |
| | | Object o3 = redisUtil.get("LED_" + dev_no3); |
| | | if (o1 != null) { |
| | | //log.info("电视机显示1:{}", JSONObject.toJSONString(o1)); |
| | | log.info("电视机显示1:{}", JSONObject.toJSONString(o1)); |
| | | return R.ok().add(o1); |
| | | } else if (o2 != null) { |
| | | //log.info("电视机显示2:{}", JSONObject.toJSONString(o2)); |
| | | log.info("电视机显示2:{}", JSONObject.toJSONString(o2)); |
| | | return R.ok().add(o2); |
| | | } else if (o3 != null) { |
| | | //log.info("电视机显示3:{}", JSONObject.toJSONString(o3)); |
| | | log.info("电视机显示3:{}", JSONObject.toJSONString(o3)); |
| | | return R.ok().add(o3); |
| | | } |
| | | return R.ok(); |
| | |
| | | /** |
| | | * 设备异常通知 |
| | | */ |
| | | @GetMapping("/sta/mode") |
| | | public R monitorStaMode(@RequestParam("ledId") Integer ledId) { |
| | | List<WrkMast> wrkMastList1 = null; |
| | | List<WrkMast> wrkMastList2 = null; |
| | | switch (ledId) { |
| | | case 1: |
| | | wrkMastList1 = wrkMastService.selectList(new EntityWrapper<WrkMast>().in("source_sta_no", 1014, 1022, 1025)); |
| | | wrkMastList2 = wrkMastService.selectList(new EntityWrapper<WrkMast>().in("sta_no", 1013, 1021, 1024)); |
| | | break; |
| | | case 2: |
| | | wrkMastList1 = wrkMastService.selectList(new EntityWrapper<WrkMast>().in("source_sta_no", 1012, 1022, 1025)); |
| | | wrkMastList2 = wrkMastService.selectList(new EntityWrapper<WrkMast>().in("sta_no", 1011, 1021, 1024)); |
| | | break; |
| | | case 3: |
| | | wrkMastList1 = wrkMastService.selectList(new EntityWrapper<WrkMast>().in("source_sta_no", 1012, 1014, 1025)); |
| | | wrkMastList2 = wrkMastService.selectList(new EntityWrapper<WrkMast>().in("sta_no", 1011, 1013, 1024)); |
| | | break; |
| | | case 4: |
| | | wrkMastList1 = wrkMastService.selectList(new EntityWrapper<WrkMast>().in("source_sta_no", 1012, 1014, 1022)); |
| | | wrkMastList2 = wrkMastService.selectList(new EntityWrapper<WrkMast>().in("sta_no", 1011, 1013, 1021)); |
| | | break; |
| | | default: |
| | | break; |
| | | } |
| | | if (!Cools.isEmpty(wrkMastList1)) { |
| | | String msg = "站点在入库;"; |
| | | Set<Integer> set = new HashSet<>(); |
| | | for (WrkMast wrkMast : wrkMastList1) { |
| | | set.add(wrkMast.getSourceStaNo()); |
| | | } |
| | | return R.ok().add(set.toString() + msg); |
| | | } |
| | | if (!Cools.isEmpty(wrkMastList2)) { |
| | | String msg = "站点在出库;"; |
| | | Set<Integer> set = new HashSet<>(); |
| | | for (WrkMast wrkMast : wrkMastList2) { |
| | | set.add(wrkMast.getSourceStaNo()); |
| | | } |
| | | return R.ok().add(set.toString() + msg); |
| | | } |
| | | return R.ok(); |
| | | } |
| | | |
| | | |
| | | /** |
| | | * 设备异常通知 |
| | | */ |
| | | @GetMapping("/device/error") |
| | | public R monitorDeviceError() { |
| | | public R monitorStaInfo() { |
| | | ArrayList<HashMap<String, Object>> list = new ArrayList<>(); |
| | | |
| | | for (ShuttleSlave shuttleSlave : slaveProperties.getShuttle()) { |