|
|
|
@ -55,29 +55,23 @@ public class DataAcquisition implements Runnable { |
|
|
|
public void receiveRealtimeData(RealTimeData data) {// 实时数据接收处理
|
|
|
|
public void receiveRealtimeData(RealTimeData data) {// 实时数据接收处理
|
|
|
|
// 遍历节点数据。数据包括网络设备的数据以及各个节点数据。温湿度数据存放在节点数据中
|
|
|
|
// 遍历节点数据。数据包括网络设备的数据以及各个节点数据。温湿度数据存放在节点数据中
|
|
|
|
for (NodeData nd : data.getNodeList()) { |
|
|
|
for (NodeData nd : data.getNodeList()) { |
|
|
|
System.out.println("实时数据->设备地址:" + data.getDeviceId() |
|
|
|
// System.out.println("实时数据->设备地址:" + data.getDeviceId()
|
|
|
|
+ "\t节点:" + nd.getNodeId() + "\t温度:" + nd.getTem() |
|
|
|
// + "\t节点:" + nd.getNodeId() + "\t温度:" + nd.getTem()
|
|
|
|
+ "\t湿度:" + nd.getHum() + "\t经度:" + data.getLng() |
|
|
|
// + "\t湿度:" + nd.getHum() + "\t经度:" + data.getLng()
|
|
|
|
+ "\t纬度:" + data.getLat() + "\t坐标类型:" |
|
|
|
// + "\t纬度:" + data.getLat() + "\t坐标类型:"
|
|
|
|
+ data.getCoordinateType() + "\t继电器状态:" |
|
|
|
// + data.getCoordinateType() + "\t继电器状态:"
|
|
|
|
+ data.getRelayStatus()); |
|
|
|
// + data.getRelayStatus());
|
|
|
|
Map<String, Object> map = new HashMap(); |
|
|
|
Map<String, Object> map = new HashMap(); |
|
|
|
map.put("wd", nd.getTem()); |
|
|
|
map.put("wd", nd.getTem()); |
|
|
|
map.put("sd", nd.getHum()); |
|
|
|
map.put("sd", nd.getHum()); |
|
|
|
|
|
|
|
|
|
|
|
CacheUtil.put(SYS_CACHE, "dataAcquisition:id:", data.getDeviceId() + "-" + nd.getNodeId(), map); |
|
|
|
CacheUtil.put(SYS_CACHE, "dataAcquisition:id:", data.getDeviceId() + "-" + nd.getNodeId(), map); |
|
|
|
// boolean set = redisUtil.set(SYS_CACHE + ":" + "dataAcquisition:id:" + data.getDeviceId() + "-" + nd.getNodeId(), JSONObject.toJSONString(map));
|
|
|
|
|
|
|
|
// System.out.println("isChengGong: " + set);
|
|
|
|
|
|
|
|
// String str = (String) redisUtil.get(data.getDeviceId() + "-" + nd.getNodeId());
|
|
|
|
|
|
|
|
// System.out.println(str);
|
|
|
|
|
|
|
|
// Map map3 = JSONObject.parseObject(str, Map.class);
|
|
|
|
|
|
|
|
// System.out.println("map3: " + map3);
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
Map map1 = CacheUtil.get(SYS_CACHE, "dataAcquisition:id:", data.getDeviceId() + "-" + nd.getNodeId(), Map.class); |
|
|
|
Map map1 = CacheUtil.get(SYS_CACHE, "dataAcquisition:id:", data.getDeviceId() + "-" + nd.getNodeId(), Map.class); |
|
|
|
System.out.println(data.getDeviceId() + "-" + nd.getNodeId() + ":" + map1); |
|
|
|
// System.out.println(data.getDeviceId() + "-" + nd.getNodeId() + ":" + map1);
|
|
|
|
System.out.println("==================="); |
|
|
|
// System.out.println("===================");
|
|
|
|
} |
|
|
|
} |
|
|
|
System.out.println("========================================================================"); |
|
|
|
// System.out.println("========================================================================");
|
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
@Override |
|
|
|
@Override |
|
|
|
|