|
@@ -384,7 +384,8 @@ public class GetWeather {
|
|
|
String time = date.get(i).toString();
|
|
|
HeFengDay heFengDay = new HeFengDay();
|
|
|
heFengDay.setTs(convertStringToTimestamp(time));
|
|
|
- heFengDay.setWindSpeedDay(windSpeedDay.get(i) == null ? -0.99f : new BigDecimal(windSpeedDay.get(i).toString()).floatValue() * 1000 / 3600);
|
|
|
+ heFengDay.setWindSpeedDay(windSpeedDay.get(i) == null ? -0.99f : new BigDecimal(windSpeedDay.get(i).toString()).floatValue());
|
|
|
+ heFengDay.setWindSpeedMDay(windSpeedDay.get(i) == null ? -0.99f : new BigDecimal(windSpeedDay.get(i).toString()).floatValue() * 1000 / 3600);
|
|
|
heFengDay.setWindScaleDay(speedLevel(windSpeedDay.get(i) == null ? "0" : windSpeedDay.get(i).toString()));
|
|
|
heFengDay.setWind360Day(direction.get(i).toString() == null ? -0.99f : new BigDecimal(direction.get(i).toString()).floatValue());
|
|
|
heFengDay.setPrecip(precip.get(i) == null ? -0.99f : new BigDecimal(precip.get(i).toString()).floatValue());
|
|
@@ -400,14 +401,14 @@ public class GetWeather {
|
|
|
}
|
|
|
for (HeFengDay item : heFengDayList) {
|
|
|
String insertSQL = "INSERT INTO hefeng_day_unit_" + areaCode + " USING hefeng_day_unit TAGS('" + areaCode + "') " +
|
|
|
- "(ts,wind_speed_day,wind_scale_day,wind_360_Day,precip,text_day,temp_max,temp_min,humidity,dswrf) values('"
|
|
|
- + item.getTs() + "', " + item.getWindSpeedDay() + ", " + item.getWindScaleDay() + ", " + item.getWind360Day() + ", "
|
|
|
+ "(ts,wind_speed_day,wind_speed_m_day,wind_scale_day,wind_360_Day,precip,text_day,temp_max,temp_min,humidity,dswrf) values('"
|
|
|
+ + item.getTs() + "', " + item.getWindSpeedDay() + ", " + item.getWindSpeedMDay() + ", " + item.getWindScaleDay() + ", " + item.getWind360Day() + ", "
|
|
|
+ item.getPrecip() + ", '" + item.getTextDay() + "', " + item.getTempMax() + ", " + item.getTempMin() + ", " + item.getHumidity() + ", "
|
|
|
+ item.getDswrf() + ")";
|
|
|
SimpleDateFormat simpleFormatter = new SimpleDateFormat("yyyy-MM-dd");
|
|
|
String insertSnap = "INSERT INTO weather_day_snap_" + areaCode + "_" + simpleFormatter.format(new Date()) + " USING hefeng_day_unit TAGS('" + areaCode + "','" + simpleFormatter.format(new Date()) + "') " +
|
|
|
- "(ts,wind_speed_day,wind_scale_day,wind_360_Day,precip,text_day,temp_max,temp_min,humidity,dswrf) values('"
|
|
|
- + item.getTs() + "', " + item.getWindSpeedDay() + ", " + item.getWindScaleDay() + ", " + item.getWind360Day() + ", "
|
|
|
+ "(ts,wind_speed_day,wind_speed_m_day,wind_scale_day,wind_360_Day,precip,text_day,temp_max,temp_min,humidity,dswrf) values('"
|
|
|
+ + item.getTs() + "', " + item.getWindSpeedDay() + ", " + item.getWindSpeedMDay() + ", " + item.getWindScaleDay() + ", " + item.getWind360Day() + ", "
|
|
|
+ item.getPrecip() + ", '" + item.getTextDay() + "', " + item.getTempMax() + ", " + item.getTempMin() + ", " + item.getHumidity() + ", "
|
|
|
+ item.getDswrf() + ")";
|
|
|
int affectedRows = ps.executeUpdate(insertSQL);
|