| | |
| | | if(RedisOpsUtils.checkExist(RedisConst.OSD_STATUS_PREFIX + device.getChildDeviceSn())){ |
| | | droneStatus = String.valueOf(RedisOpsUtils.get(RedisConst.OSD_STATUS_PREFIX + device.getChildDeviceSn()));; |
| | | } |
| | | String json = getJSONString(device.getDeviceSn(), dockStatus, device.getChildDeviceSn(), droneStatus); |
| | | String json = getJSONString(MessageType.STATE.getType(), device.getDeviceSn(), dockStatus, droneStatus); |
| | | |
| | | // 发送给websocket客户端 |
| | | _dockWebSocketHandler.sendMessageToSubscribers(device.getDeviceSn(), MessageType.STATE.getType(), json); |
| | | } |
| | | } |
| | | |
| | | public String getJSONString(String dockSn, String dockStatus, String droneSn, String droneStatus){ |
| | | public String getJSONString(String messageType, String dockSn, String dockStatus, String droneStatus){ |
| | | Map<String, Object> json = new HashMap<>(); |
| | | json.put("code", 200); |
| | | json.put("type", MessageType.STATE.getType()); |
| | | json.put("gateway", dockSn); |
| | | json.put("type", messageType); |
| | | json.put("message", "success"); |
| | | |
| | | Map<String, String> data = new HashMap<>(); |
| | | data.put("docksn", dockSn); |
| | | data.put("state", dockStatus); |
| | | data.put("dockstate", dockStatus); |
| | | data.put("dronestate", droneStatus); |
| | | |
| | | Map<String, String> data1 = new HashMap<>(); |
| | | data1.put("droneSn", droneSn); |
| | | data1.put("state", droneStatus); |
| | | |
| | | List<Map<String, String>> lstMap = new ArrayList<>(); |
| | | lstMap.add(data); |
| | | lstMap.add(data1); |
| | | |
| | | json.put("data", lstMap); |
| | | json.put("data", data); |
| | | |
| | | // 将Map转换为JSON字符串 |
| | | String jsonString = ""; |