1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16 package org.kuali.mobility.weather.dao;
17
18 import org.jdom.Document;
19 import org.jdom.Element;
20 import org.jdom.JDOMException;
21 import org.jdom.input.SAXBuilder;
22 import org.kuali.mobility.weather.entity.Weather;
23 import org.slf4j.Logger;
24 import org.slf4j.LoggerFactory;
25
26 import java.io.IOException;
27 import java.net.URL;
28 import java.net.URLConnection;
29 import java.util.HashMap;
30 import java.util.Iterator;
31 import java.util.List;
32
33 public class WeatherDaoImpl implements WeatherDao {
34
35 private static Logger LOG = LoggerFactory.getLogger(WeatherDaoImpl.class);
36
37 private String url;
38
39 @SuppressWarnings("unchecked")
40 public Weather parseWeather() {
41 Weather weatherData = new Weather();
42 try {
43 Document doc = retrieveDocumentFromUrl(url, 5000, 5000);
44 Element root = doc.getRootElement();
45 List<Element> data = root.getChildren("data");
46 for (Iterator<Element> iterator = data.iterator(); iterator.hasNext();) {
47 Element dataItem = iterator.next();
48 if ("forecast".equalsIgnoreCase(dataItem.getAttribute("type").getValue().trim())) {
49 List<Element> items = dataItem.getChildren("time-layout");
50 for (Iterator<Element> itemItr = items.iterator(); itemItr.hasNext();) {
51 Element xmlItem = itemItr.next();
52 if (xmlItem.getChild("layout-key").getValue().trim().startsWith("k-p12h-")) {
53 List<Element> items2 = xmlItem.getChildren("start-valid-time");
54 int i = 0;
55 for (Iterator<Element> itemItr2 = items2.iterator(); itemItr2.hasNext();) {
56 Element xmlItem2 = itemItr2.next();
57 HashMap<String, String> temp;
58 try {
59 temp = weatherData.getForecasts().get(i);
60 } catch (Exception e) {
61 temp = new HashMap<String, String>();
62 weatherData.getForecasts().add(temp);
63 }
64 temp.put("name", xmlItem2.getAttributeValue("period-name"));
65 i++;
66 LOG.debug(xmlItem2.getAttributeValue("period-name"));
67 }
68 }
69 }
70 List<Element> itemsIcons = dataItem.getChild("parameters").getChildren("conditions-icon");
71 for (Iterator<Element> itemItr = itemsIcons.iterator(); itemItr.hasNext();) {
72 Element xmlItem = itemItr.next();
73 if (xmlItem.getAttributeValue("time-layout").trim().startsWith("k-p12h-")) {
74 List<Element> items2 = xmlItem.getChildren("icon-link");
75 int i = 0;
76 for (Iterator<Element> itemItr2 = items2.iterator(); itemItr2.hasNext();) {
77 Element xmlItem2 = itemItr2.next();
78 HashMap<String, String> temp;
79 try {
80 temp = weatherData.getForecasts().get(i);
81 } catch (Exception e) {
82 temp = new HashMap<String, String>();
83 weatherData.getForecasts().add(temp);
84 }
85 temp.put("iconLink", xmlItem2.getValue());
86 i++;
87 LOG.debug(xmlItem2.getValue());
88 }
89 }
90 }
91 List<Element> itemsText = dataItem.getChild("parameters").getChildren("wordedForecast");
92 for (Iterator<Element> itemItr = itemsText.iterator(); itemItr.hasNext();) {
93 Element xmlItem = itemItr.next();
94 if (xmlItem.getAttributeValue("time-layout").trim().startsWith("k-p12h-")) {
95 List<Element> items2 = xmlItem.getChildren("text");
96 int i = 0;
97 for (Iterator<Element> itemItr2 = items2.iterator(); itemItr2.hasNext();) {
98 Element xmlItem2 = itemItr2.next();
99 HashMap<String, String> temp;
100 try {
101 temp = weatherData.getForecasts().get(i);
102 } catch (Exception e) {
103 temp = new HashMap<String, String>();
104 weatherData.getForecasts().add(temp);
105 }
106 temp.put("text", xmlItem2.getValue());
107 i++;
108 LOG.debug(xmlItem2.getValue());
109 }
110 }
111 }
112 } else if ("current observations".equalsIgnoreCase(dataItem.getAttribute("type").getValue().trim())) {
113 List<Element> items = dataItem.getChildren("parameters");
114 for (Iterator<Element> itemItr = items.iterator(); itemItr.hasNext();) {
115 Element xmlItem = itemItr.next();
116 if (null != xmlItem.getChild("weather").getChild("weather-conditions").getAttributeValue("weather-summary")) {
117 weatherData.setCurrentCondition(xmlItem.getChild("weather").getChild("weather-conditions").getAttributeValue("weather-summary"));
118 LOG.debug("Current:" + xmlItem.getChild("weather").getChild("weather-conditions").getAttributeValue("weather-summary"));
119 }
120 if ("apparent".equalsIgnoreCase(xmlItem.getChild("temperature").getAttributeValue("type").trim())) {
121 weatherData.setTemperature(xmlItem.getChild("temperature").getChildText("value"));
122 LOG.debug("Temp:" + xmlItem.getChild("temperature").getChildText("value"));
123 }
124 if ("relative".equalsIgnoreCase(xmlItem.getChild("humidity").getAttributeValue("type").trim())) {
125 weatherData.setHumidity(xmlItem.getChild("humidity").getChildText("value"));
126 LOG.debug("Humidity:" + xmlItem.getChild("humidity").getChildText("value"));
127 }
128 if ("barometer".equalsIgnoreCase(xmlItem.getChild("pressure").getAttributeValue("type").trim())) {
129 weatherData.setPressure(xmlItem.getChild("pressure").getChildText("value"));
130 LOG.debug("Pressure:" + xmlItem.getChild("pressure").getChildText("value"));
131 }
132 if ("wind".equalsIgnoreCase(xmlItem.getChild("direction").getAttributeValue("type").trim())) {
133 weatherData.setWindDirection(xmlItem.getChild("direction").getChildText("value"));
134 LOG.debug("Wind direction:" + xmlItem.getChild("direction").getChildText("value"));
135 }
136 List<Element> items2 = xmlItem.getChildren("wind-speed");
137 for (Iterator<Element> itemItr2 = items2.iterator(); itemItr2.hasNext();) {
138 Element xmlItem2 = itemItr2.next();
139 if ("sustained".equalsIgnoreCase(xmlItem2.getAttributeValue("type").trim())) {
140 weatherData.setWindSpeed(xmlItem2.getChildText("value"));
141 LOG.debug("Wind speed:" + xmlItem2.getChildText("value"));
142 }
143 }
144 }
145 }
146 }
147 } catch (Exception e) {
148 weatherData = null;
149 LOG.error(e.getMessage(), e);
150 }
151 return weatherData;
152 }
153
154 private Document retrieveDocumentFromUrl(String urlStr, int connectTimeout, int readTimeout) throws IOException, JDOMException {
155 SAXBuilder builder = new SAXBuilder();
156 Document doc = null;
157 URL urlObj = new URL(urlStr);
158 URLConnection urlConnection = urlObj.openConnection();
159 urlConnection.setConnectTimeout(connectTimeout);
160 urlConnection.setReadTimeout(readTimeout);
161 doc = builder.build(urlConnection.getInputStream());
162 return doc;
163 }
164
165 public String getUrl() {
166 return url;
167 }
168
169 public void setUrl(String url) {
170 this.url = url;
171 }
172
173 }