| | |
|---|
| | | CopyOnWriteArraySet<SingleDeviceServer> sockets = SingleDeviceServer.sockets; |
|---|
| | | for (SingleDeviceServer socket : sockets) { |
|---|
| | | //判断消息书否数据该socket |
|---|
| | | //取出基本信息 |
|---|
| | | String messageMac = (String) message.get("mac"); |
|---|
| | | String mac = socket.getMac(); |
|---|
| | | if(!mac.equals(messageMac)) |
|---|
| | | continue; |
|---|
| | | //取出基本信息 |
|---|
| | | Map<String, Device> devicesInfo = socket.getDevicesInfo(); |
|---|
| | | Device device = devicesInfo.get(mac); |
|---|
| | | //创建最终消息对象 |
|---|
| | |
|---|
| | | resultMessgae.put(sensor.getCode(), sourceData); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | resultMessgae.put("DataTime",message.get("DataTime")); |
|---|
| | | resultMessgae.put("time",message.get("time")); |
|---|
| | | resultMessgae.put("time1",message.get("time1")); |
|---|
| | | resultMessgae.put("serverTime",System.currentTimeMillis()); |
|---|
| | | socket.sendMessage(JSON.toJSONString(resultMessgae)); |
|---|
| | | } |
|---|
