From 0a107debd7676141376a59bd3d4472912b24f7dc Mon Sep 17 00:00:00 2001 From: 于紫祥_1901 <email@yuzixiang_1910> Date: Thu, 13 Aug 2020 09:37:43 +0800 Subject: [PATCH] 风场图update --- src/main/java/com/moral/service/impl/WeatherServiceImpl.java | 733 ++++++++++++++++++++++++++++++++++++++++++++++++-------- 1 files changed, 629 insertions(+), 104 deletions(-) diff --git a/src/main/java/com/moral/service/impl/WeatherServiceImpl.java b/src/main/java/com/moral/service/impl/WeatherServiceImpl.java index baf855b..7687544 100644 --- a/src/main/java/com/moral/service/impl/WeatherServiceImpl.java +++ b/src/main/java/com/moral/service/impl/WeatherServiceImpl.java @@ -1,130 +1,655 @@ package com.moral.service.impl; +import java.text.ParseException; +import java.text.SimpleDateFormat; import java.util.ArrayList; +import java.util.Calendar; import java.util.Collection; +import java.util.Collections; +import java.util.Date; import java.util.HashMap; import java.util.List; import java.util.Map; import javax.annotation.Resource; +import org.apache.jasper.compiler.JspUtil; import org.dom4j.Element; import org.springframework.stereotype.Service; import org.springframework.util.ObjectUtils; import org.springframework.web.client.RestTemplate; +import com.alibaba.fastjson.JSONObject; import com.moral.common.util.Dom4jUtils; import com.moral.common.util.ValidateUtil; +import com.moral.entity.Area; import com.moral.entity.AreaNames; +import com.moral.entity.City; +import com.moral.entity.Device; +import com.moral.entity.MonitorPoint; import com.moral.entity.Organization; +import com.moral.entity.Province; +import com.moral.mapper.AreaMapper; +import com.moral.mapper.CityMapper; +import com.moral.mapper.DeviceMapper; +import com.moral.mapper.ForecastWeatherMapper; +import com.moral.mapper.HangzhouAqiMapper; +import com.moral.mapper.HistoryHourlyMapper; +import com.moral.mapper.MonitorPointMapper; +import com.moral.mapper.ProvinceMapper; +import com.moral.mapper.RealWeatherMapper; import com.moral.service.OrganizationService; import com.moral.service.WeatherService; @Service public class WeatherServiceImpl implements WeatherService { - - @Resource - private OrganizationService organizationService; - - @Override - public Map<String, Object> getWeatherDataByRegion(Map<String, Object> parameters) { - Object organizationId = parameters.get("organizationId"); - ValidateUtil.notNull(organizationId, "param.is.null"); - String areaName = "���������"; - String parentName = ""; - Organization organization = organizationService.getOrganizationById(Integer.valueOf(parameters.get("organizationId").toString())); - if(organization.getAreaNames()!=null){ - AreaNames areaNames = organization.getAreaNames(); - if (ObjectUtils.isEmpty(areaNames.getAreaName())) { - if (ObjectUtils.isEmpty(areaNames.getCityName())) { - areaName = areaNames.getProvinceName(); - } else { - areaName = areaNames.getCityName(); - } - } else { - areaName = areaNames.getAreaName(); - parentName = areaNames.getCityName(); - if ("���������".equals(areaName)) { - areaName = parentName; - } - } - } - List<Element> elements = Dom4jUtils.readDocument(); - String cityID = "1102"; - for (Element element : elements) { - String name = element.element("name").getText(); - if (areaName.equals(name)) { - cityID = element.element("Fid").getText(); - break; - } - if (name.endsWith(areaName)) { - if (name.startsWith(parentName)) { - cityID = element.element("Fid").getText(); - break; - } - } - } - RestTemplate restTemplate = new RestTemplate(); - Map<String, Object> map = restTemplate.getForObject("http://sapi.7drlb.com/api/mj?cityID={1}&apiKey=aqi", Map.class,cityID); - Map<String, Object> result = (Map<String, Object>) ((Map)map.get("data")).get("aqi"); - map = restTemplate.getForObject("http://sapi.7drlb.com/api/mj?cityID={1}&apiKey=condition", Map.class,cityID); - result.putAll((Map<? extends String, ? extends Object>) ((Map)map.get("data")).get("condition")); - return result; - } - - @Override - public Map<String, Object> get15DayWeatherDataByRegion(Map<String, Object> parameters) { - Object organizationId = parameters.get("organizationId"); - ValidateUtil.notNull(organizationId, "param.is.null"); - String areaName = "���������"; - String parentName = ""; - Organization organization = organizationService.getOrganizationById(Integer.valueOf(parameters.get("organizationId").toString())); - if(organization.getAreaNames()!=null){ - AreaNames areaNames = organization.getAreaNames(); - if (ObjectUtils.isEmpty(areaNames.getAreaName())) { - if (ObjectUtils.isEmpty(areaNames.getCityName())) { - areaName = areaNames.getProvinceName(); - } else { - areaName = areaNames.getCityName(); - } - } else { - areaName = areaNames.getAreaName(); - parentName = areaNames.getCityName(); - if ("���������".equals(areaName)) { - areaName = parentName; - } - } - } - List<Element> elements = Dom4jUtils.readDocument(); - String cityID = "1102"; - for (Element element : elements) { - String name = element.element("name").getText(); - if (areaName.equals(name)) { - cityID = element.element("Fid").getText(); - break; - } - if (name.endsWith(areaName)) { - if (name.startsWith(parentName)) { - cityID = element.element("Fid").getText(); - break; - } - } - } - RestTemplate restTemplate = new RestTemplate(); - Map<String, Object> map = restTemplate.getForObject("http://sapi.7drlb.com/api/mj?cityID={1}&apiKey=aqi", Map.class,cityID); - List<Map<String, Object>> result = new ArrayList<>(); - map = restTemplate.getForObject("http://sapi.7drlb.com/api/mj?cityID={1}&apiKey=forecast15days", Map.class,cityID); - result.addAll((Collection<? extends Map<String, Object>>) ((Map)map.get("data")).get("forecast")); - for (Map<String, Object> map2 : result) { - Map<String, Object> returnMap = new HashMap<>(); - String predictDate = map2.get("predictDate").toString(); - String time = parameters.get("time").toString(); - if (predictDate.equals(time)) { - returnMap = map2; - return returnMap; - } - } - return null; - } + @Resource + private OrganizationService organizationService; + + @Resource + private HangzhouAqiMapper hangzhouAqiMapper; + + @Resource + private MonitorPointMapper monitorPointMapper; + + @Resource + private ForecastWeatherMapper forecastWeatherMapper; + + @Resource + private AreaMapper areaMapper; + + @Resource + private CityMapper cityMapper; + + @Resource + private ProvinceMapper provinceMapper; + + @Resource + private RealWeatherMapper realWeatherMapper; + + @Resource + private DeviceMapper deviceMapper; + + @Resource + private HistoryHourlyMapper historyHourlyMapper; + + @Override + public Map<String, Object> getWeatherDataByRegion(Map<String, Object> parameters) { + Object organizationId = parameters.get("organizationId"); + ValidateUtil.notNull(organizationId, "param.is.null"); + String areaName = "���������"; + String parentName = ""; + Organization organization = organizationService.getOrganizationById(Integer.valueOf(parameters.get("organizationId").toString())); + if (organization.getAreaNames() != null) { + AreaNames areaNames = organization.getAreaNames(); + if (ObjectUtils.isEmpty(areaNames.getAreaName())) { + if (ObjectUtils.isEmpty(areaNames.getCityName())) { + areaName = areaNames.getProvinceName(); + } else { + areaName = areaNames.getCityName(); + } + } else { + areaName = areaNames.getAreaName(); + parentName = areaNames.getCityName(); + if ("���������".equals(areaName)) { + areaName = parentName; + } + } + } + List<Element> elements = Dom4jUtils.readDocument(); + String cityID = "1102"; + for (Element element : elements) { + String name = element.element("name").getText(); + if (areaName.equals(name)) { + cityID = element.element("Fid").getText(); + break; + } + if (name.endsWith(areaName)) { + if (name.startsWith(parentName)) { + cityID = element.element("Fid").getText(); + break; + } + } + } + RestTemplate restTemplate = new RestTemplate(); + Map<String, Object> map = restTemplate.getForObject("http://sapi.7drlb.com/api/mj?cityID={1}&apiKey=aqi", Map.class, cityID); + Map<String, Object> result = (Map<String, Object>) ((Map) map.get("data")).get("aqi"); + map = restTemplate.getForObject("http://sapi.7drlb.com/api/mj?cityID={1}&apiKey=condition", Map.class, cityID); + result.putAll((Map<? extends String, ? extends Object>) ((Map) map.get("data")).get("condition")); + return result; + } + + @Override + public Map<String, Object> get15DayWeatherDataByRegion(Map<String, Object> parameters) { + Object organizationId = parameters.get("organizationId"); + ValidateUtil.notNull(organizationId, "param.is.null"); + String areaName = "���������"; + String parentName = ""; + Organization organization = organizationService.getOrganizationById(Integer.valueOf(parameters.get("organizationId").toString())); + if (organization.getAreaNames() != null) { + AreaNames areaNames = organization.getAreaNames(); + if (ObjectUtils.isEmpty(areaNames.getAreaName())) { + if (ObjectUtils.isEmpty(areaNames.getCityName())) { + areaName = areaNames.getProvinceName(); + } else { + areaName = areaNames.getCityName(); + } + } else { + areaName = areaNames.getAreaName(); + parentName = areaNames.getCityName(); + if ("���������".equals(areaName)) { + areaName = parentName; + } + } + } + List<Element> elements = Dom4jUtils.readDocument(); + String cityID = "1102"; + for (Element element : elements) { + String name = element.element("name").getText(); + if (areaName.equals(name)) { + cityID = element.element("Fid").getText(); + break; + } + if (name.endsWith(areaName)) { + if (name.startsWith(parentName)) { + cityID = element.element("Fid").getText(); + break; + } + } + } + RestTemplate restTemplate = new RestTemplate(); + Map<String, Object> map = restTemplate.getForObject("http://sapi.7drlb.com/api/mj?cityID={1}&apiKey=aqi", Map.class, cityID); + List<Map<String, Object>> result = new ArrayList<>(); + map = restTemplate.getForObject("http://sapi.7drlb.com/api/mj?cityID={1}&apiKey=forecast15days", Map.class, cityID); + result.addAll((Collection<? extends Map<String, Object>>) ((Map) map.get("data")).get("forecast")); + for (Map<String, Object> map2 : result) { + Map<String, Object> returnMap = new HashMap<>(); + String predictDate = map2.get("predictDate").toString(); + String time = parameters.get("time").toString(); + if (predictDate.equals(time)) { + returnMap = map2; + return returnMap; + } + } + return null; + } + + @Override + public List<Map<String, Object>> getForecastAndReal(Map<String, Object> parameters) throws ParseException { + parameters.put("typeFormat", "%Y-%m-%d %H:%i:%s"); + String monitorPointId = parameters.get("monitorPointId").toString(); + SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); + String time = parameters.get("time").toString() + " 00:00:00"; + Calendar c = Calendar.getInstance(); + c.setTime(sdf.parse(time)); + c.add(Calendar.HOUR_OF_DAY, 1); + time = sdf.format(c.getTime()); + c.add(Calendar.DAY_OF_MONTH, 1); + String nextDay = sdf.format(c.getTime()); + parameters.put("start", sdf.parse(time)); + parameters.put("end", sdf.parse(nextDay)); + MonitorPoint monitorPoint = monitorPointMapper.selectByPrimaryKey(Integer.valueOf(monitorPointId)); + if (monitorPoint.getAreaCode() == null) { + parameters.put("cityCode", monitorPoint.getCityCode()); + } else { + parameters.put("cityCode", monitorPoint.getAreaCode()); + } + List<Map<String, Object>> aqiList = hangzhouAqiMapper.getAqiDataByAreaCode(parameters); + List<Map<String, Object>> forecastList = forecastWeatherMapper.getForecastHour(parameters); + + if (aqiList.size() == 0) { + parameters.put("cityCode", monitorPoint.getCityCode()); + aqiList = hangzhouAqiMapper.getAqiDataByAreaCode(parameters); + } + for (Map<String, Object> map : aqiList) { + String O3 = map.get("O3").toString().replace("\"", ""); + map.put("O3", O3); + } + + List<Map<String, Object>> resultList = new ArrayList<>(); + if (forecastList.size() == 0 && aqiList.size() == 0) { + return new ArrayList<>(); + } else if (forecastList.size() == 0) { + for (Map<String, Object> aqiMap : aqiList) { + Map<String, Object> map = new HashMap<>(); + List<String> values = new ArrayList<>(); + String hour = aqiMap.get("time").toString().split(" ")[1].split(":")[0]; + if (hour.equals("00")) { + hour = "24"; + } + map.put("time", Integer.valueOf(hour)); + values.add(""); + values.add(aqiMap.get("O3").toString()); + map.put("values", values); + resultList.add(map); + } + + } else if (aqiList.size() == 0) { + for (Map<String, Object> forecastMap : forecastList) { + Map<String, Object> map = new HashMap<>(); + List<String> values = new ArrayList<>(); + String hour = forecastMap.get("time").toString().split(" ")[1].split(":")[0]; + if (hour.equals("00")) { + hour = "24"; + } + map.put("time", Integer.valueOf(hour)); + if (forecastMap.get("result") != null) { + values.add(forecastMap.get("result").toString().replace("\"", "")); + } else { + values.add(""); + } + values.add(""); + map.put("values", values); + resultList.add(map); + } + } else { + for (Map<String, Object> forecastMap : forecastList) { + Map<String, Object> map = new HashMap<>(); + List<String> values = new ArrayList<>(); + String hour = forecastMap.get("time").toString().split(" ")[1].split(":")[0]; + if (hour.equals("00")) { + hour = "24"; + } + map.put("time", Integer.valueOf(hour)); + if (forecastMap.get("result") != null) { + values.add(forecastMap.get("result").toString().replace("\"", "")); + } else { + values.add(""); + } + for (Map<String, Object> aqiMap : aqiList) { + if (forecastMap.get("time").equals(aqiMap.get("time"))) { + values.add(aqiMap.get("O3").toString()); + } + } + map.put("values", values); + resultList.add(map); + } + } + for (Map<String, Object> resultMap : resultList) { + ArrayList<String> values = (ArrayList<String>) resultMap.get("values"); + if (values.size() == 1) { + values.add(""); + } + } + return resultList; + } + + @Override + public List<Map<String, Object>> getWeatherData(Map<String, Object> parameters) throws ParseException { + parameters.put("typeFormat", "%Y-%m-%d %H:%i:%s"); + String cityName = parameters.get("city").toString(); + Area area = areaMapper.getAreaByName(cityName); + Integer code = 0; + String name = ""; + if (area == null) { + City city = cityMapper.getCityByName(cityName); + if (city == null) { + Province province = provinceMapper.getProvinceByName(cityName); + code = province.getProvinceCode(); + name = province.getProvinceName(); + } else { + code = city.getCityCode(); + name = city.getCityName(); + } + } else { + code = area.getAreaCode(); + name = area.getAreaName(); + } + + parameters.put("cityCode", code); + parameters.put("name", name); + String time = parameters.get("time").toString(); + SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd"); + SimpleDateFormat sdf1 = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); + Date now = new Date(); + Date selectTime = sdf1.parse(time + " 01:00:00"); + Calendar cal = Calendar.getInstance(); + cal.setTime(selectTime); + cal.add(Calendar.DAY_OF_MONTH, 1); + Date end = cal.getTime(); + cal.setTime(sdf.parse(time)); + cal.add(Calendar.DAY_OF_MONTH, -1); + String beforeDay = sdf.format(cal.getTime()); + parameters.put("start", selectTime); + parameters.put("end", end); + Integer fcode = 0; + List<Map<String, Object>> forecastList = forecastWeatherMapper.getForecast(parameters); + if (forecastList.size() == 0) { + List<Area> areaList = areaMapper.getAreaByCityCode(code); + for (Area area1 : areaList) { + if (area1 != null) { + parameters.put("cityCode", area1.getAreaCode()); + fcode = area1.getAreaCode(); + forecastList = forecastWeatherMapper.getForecast(parameters); + if (forecastList.size() != 0) { + break; + } + } + } + } else { + fcode = Integer.valueOf(parameters.get("cityCode").toString()); + } + + List<Map<String, Object>> foreList = new ArrayList<>(); + for (Map<String, Object> forecastMap : forecastList) { + Map<String, Object> hashMap = new HashMap<>(); + hashMap.put("time", forecastMap.get("time").toString()); + hashMap.put("type", "������"); + hashMap.put("TVOC", ""); + hashMap.put("altitude", ""); + hashMap.put("vegetation", ""); + hashMap.put("river", ""); + hashMap.put("AQI", ""); + hashMap.put("SO2C", ""); + hashMap.put("NO2C", ""); + hashMap.put("COC", ""); + hashMap.put("O3C", ""); + hashMap.put("PM25C", ""); + hashMap.put("PM10C", ""); + hashMap.put("city", parameters.get("name").toString()); + hashMap.put("code", fcode); + if (sdf.parse(time).getTime() <= now.getTime()) { + hashMap.put("fxTime", (beforeDay + " 15:00").substring(5, 16)); + } else { + String format = sdf1.format(now).split(" ")[0]; + Date date1 = sdf1.parse(format + " 07:00:00"); + Date date2 = sdf1.parse(format + " 15:00:00"); + if (now.getTime() > date2.getTime()) { + hashMap.put("fxTime", (beforeDay + " 15:00").substring(5, 16)); + } else if (now.getTime() > date1.getTime() && (now.getTime() < date2.getTime() || now.getTime() == date2.getTime())) { + hashMap.put("fxTime", (beforeDay + " 07:00").substring(5, 16)); + } + } + Map<String, Object> jsonMap = (Map<String, Object>) JSONObject.parse(forecastMap.get("json").toString()); + hashMap.putAll(jsonMap); + foreList.add(hashMap); + } + + for (Map<String, Object> foreMap : foreList) { + String ftime = foreMap.get("time").toString(); + Date endTime = sdf1.parse(ftime); + cal.setTime(endTime); + cal.add(Calendar.HOUR, -6); + Date startTime = cal.getTime(); + Map<String, Object> hashMap = new HashMap<>(); + hashMap.put("start", startTime); + hashMap.put("end", endTime); + hashMap.put("cityCode", Integer.valueOf(parameters.get("cityCode").toString())); + Map<String, Object> precip6HourMap = forecastWeatherMapper.getPrecip6Hour(hashMap); + foreMap.put("precip6", ""); + if (precip6HourMap != null) { + foreMap.put("precip6", precip6HourMap.get("precip6").toString()); + } + } + + String ac = parameters.get("cityCode").toString(); + List<Map<String, Object>> aqiList = hangzhouAqiMapper.getAqi(parameters); + if (aqiList.size() == 0) { + parameters.put("cityCode", code);//320500 + aqiList = hangzhouAqiMapper.getAqi(parameters); + if (aqiList.size() == 0) { + List<Area> areaList = areaMapper.getAreaByCityCode(code); + for (Area area1 : areaList) { + if (area1 != null) { + parameters.put("cityCode", area1.getAreaCode()); + aqiList = hangzhouAqiMapper.getAqi(parameters); + if (aqiList.size() != 0) { + break; + } + } + } + } + } + List<Map<String, Object>> realAqilist = new ArrayList<>(); + for (Map<String, Object> aqiMap : aqiList) { + Map<String, Object> hashMap = new HashMap<>(); + hashMap.put("time", aqiMap.get("time")); + Map<String, Object> jsonMap = (Map<String, Object>) JSONObject.parse(aqiMap.get("json").toString()); + hashMap.putAll(jsonMap); + hashMap.put("city", parameters.get("name").toString()); + realAqilist.add(hashMap); + } + for (Map<String, Object> map : realAqilist) { + Date endTime = sdf1.parse(map.get("time").toString()); + cal.setTime(endTime); + cal.add(Calendar.HOUR, -8); + Date startTime = cal.getTime(); + Map<String, Object> hashMap = new HashMap<>(); + hashMap.put("cityCode", Integer.valueOf(parameters.get("cityCode").toString())); + hashMap.put("start", startTime); + hashMap.put("end", endTime); + Map<String, Object> O3Map = hangzhouAqiMapper.getAvgO3EightHours(hashMap); + map.put("O3C_8H", O3Map.get("O3C_8H").toString()); + } + //������ + + Map<String, Object> params = new HashMap<>(); + if (ac.endsWith("00")) { + params.put("cityCode", Integer.valueOf(ac)); + } else { + params.put("areaCode", Integer.valueOf(ac)); + } + List<MonitorPoint> monitorList = monitorPointMapper.getMonitorList(params); + + List<Integer> pointList = new ArrayList<>(); + for (MonitorPoint point : monitorList) { + Integer pointId = point.getId(); + pointList.add(pointId); + } + List<Device> deviceList = deviceMapper.getDeviceListByMonitorPointIds(pointList); + List<String> macList = new ArrayList<>(); + List<String> macList1 = new ArrayList<>(); + List<Map<String, Object>> beamList = new ArrayList<>(); + List<Map<String, Object>> tvocList=new ArrayList<>(); + if (deviceList.size() != 0) { + for (Device device : deviceList) { + macList.add(device.getMac()); + } + + parameters.put("macs", macList); + beamList = historyHourlyMapper.getBeamByMacs(parameters); + Map<String, Object> map = new HashMap<>(); + if (name.equals("���������")) { + List<Integer> list=new ArrayList<>(); + list.add(48); + List<Device> pointIds = deviceMapper.getDeviceListByMonitorPointIds(list); + for (Device device : pointIds) { + if (device.getId() != 1075) { + macList1.add(device.getMac()); + } + } + }else { + macList1=macList; + } + map.put("macs", macList1); + map.put("start", parameters.get("start")); + map.put("end", parameters.get("end")); + tvocList = historyHourlyMapper.getTVOCByMacs(map); + } + List<Map<String, Object>> realList = realWeatherMapper.getRealWeather(parameters); + List<Map<String, Object>> realWeatherList = new ArrayList<>(); + for (Map<String, Object> realMap : realList) { + Map<String, Object> hashMap = new HashMap<>(); + hashMap.put("time", realMap.get("time")); + Map<String, Object> jsonMap = (Map<String, Object>) JSONObject.parse(realMap.get("json").toString()); + hashMap.putAll(jsonMap); + hashMap.put("city", parameters.get("name").toString()); + realWeatherList.add(hashMap); + } + + for (Map<String, Object> realMap : realWeatherList) { + String rtime = realMap.get("time").toString(); + for (Map<String, Object> beamMap : beamList) { + String btime = beamMap.get("time").toString(); + if (btime.equals(rtime)) { + realMap.put("beam", Math.floor((Double) beamMap.get("beam"))); + } + } + + Date endTime = sdf1.parse(rtime); + cal.setTime(endTime); + cal.add(Calendar.HOUR, -6); + Date startTime = cal.getTime(); + Map<String, Object> hashMap = new HashMap<>(); + hashMap.put("cityCode", Integer.valueOf(parameters.get("cityCode").toString())); + hashMap.put("start", startTime); + hashMap.put("end", endTime); + + Map<String, Object> precip6HourMap = realWeatherMapper.getPrecip6Hour(hashMap); + + if (precip6HourMap != null) { + realMap.put("precip6", precip6HourMap.get("precip6").toString()); + } + + for (Map<String, Object> tvocMap : tvocList) { + String ttime = tvocMap.get("time").toString(); + if (ttime.equals(rtime)) { + realMap.put("TVOC", tvocMap.get("TVOC").toString()); + } + } + + } + + List<Map<String, Object>> list = new ArrayList<>(); + for (int i = 0; i < 24; i++) { + list.add(null); + } + + for (Map<String, Object> map : realWeatherList) { + Integer t1 = Integer.valueOf(map.get("time").toString().split(" ")[1].split(":")[0]); + if (t1 == 0) { + list.set(list.size() - 1, map); + } else { + list.set(t1 - 1, map); + } + } + + for (Map<String, Object> map : realAqilist) { + Integer t1 = Integer.valueOf(map.get("time").toString().split(" ")[1].split(":")[0]); + if (t1 == 0) { + Map<String, Object> map1 = list.get(list.size() - 1); + if (map1 == null) { + list.set(list.size() - 1, map); + } else { + map1.putAll(map); + list.set(list.size() - 1, map1); + } + } else { + Map<String, Object> map1 = list.get(t1 - 1); + if (map1 == null) { + list.set(t1 - 1, map); + } else { + map1.putAll(map); + list.set(t1 - 1, map1); + } + } + } + + list.removeAll(Collections.singleton(null)); + for (Map<String, Object> map : list) { + map.put("type", "������"); + map.put("city", parameters.get("name").toString()); + } + + List<Map<String, Object>> resultList = new ArrayList<>(); + + for (Map<String, Object> foreMap : foreList) { + for (Map<String, Object> realMap : list) { + if (foreMap.get("time").equals(realMap.get("time"))) { + resultList.add(foreMap); + resultList.add(realMap); + } + } + } + for (int i = list.size(); i < foreList.size(); i++) { + Map<String, Object> map = foreList.get(i); + resultList.add(map); + Map<String, Object> hashMap = new HashMap<>(); + hashMap.put("time", map.get("time").toString()); + hashMap.put("type", "������"); + hashMap.put("city", parameters.get("name").toString()); + resultList.add(hashMap); + } + + for (Map<String, Object> map : resultList) { + String date = map.get("time").toString().substring(0, 16); + map.put("time", date); + if (map.get("AQI") != null) { + String aqi = map.get("AQI").toString().split("\\.")[0]; + map.put("AQI", aqi); + } + if (map.get("precip") != null) { + String aqi = map.get("precip").toString(); + if (aqi.equals("0.0")) { + map.put("precip", ""); + } + } + if (map.get("precip6") != null) { + String aqi = map.get("precip6").toString(); + if (aqi.equals("0.0")) { + map.put("precip6", ""); + } + } + if ((!map.containsKey("SO2C")) && map.containsKey("SO2")) { + map.put("SO2C", map.get("SO2").toString()); + } + if ((!map.containsKey("NO2C")) && map.containsKey("NO2")) { + map.put("NO2C", map.get("NO2").toString()); + } + if ((!map.containsKey("O3C")) && map.containsKey("O3")) { + map.put("O3C", map.get("O3").toString()); + } + if ((!map.containsKey("COC")) && map.containsKey("CO")) { + map.put("COC", map.get("CO").toString()); + } + if ((!map.containsKey("PM25C")) && map.containsKey("PM2_5")) { + map.put("PM25C", map.get("PM2_5").toString()); + } + if ((!map.containsKey("PM10C")) && map.containsKey("PM10")) { + map.put("PM10C", map.get("PM10").toString()); + } + + } + return resultList; + } + + + @Override + public void updateForecastWeather(Map<String, Object> parameters) { + List<Integer> list = new ArrayList<>(); + List<Map<String, Object>> resultList = new ArrayList<>(); + for (int i = 0; i < 48; i++) { + list.add(i); + resultList.add(null); + } + for (Integer s : list) { + Map<String, Object> map = new HashMap<>(); + for (String key : parameters.keySet()) { + String replace = key.split("\\[")[0]; + if (replace.equals(s + "")) { + String ss = key.split("\\[")[1].replace("]", ""); + map.put(ss, parameters.get(key).toString()); + } + } + resultList.set(s, map); + } + for (Map<String, Object> map : resultList) { + if (map.get("type").equals("������")) { + String time = map.get("time").toString() + ":00"; + Map<String, Object> hashMap = new HashMap<>(); + hashMap.put("time", time); + hashMap.put("cityCode", Integer.valueOf(map.get("code").toString())); + Map<String, Object> jsonMap = new HashMap<>(); + for (String key : map.keySet()) { + if (!key.equals("city") && !key.equals("time") && !key.equals("type") && !key.equals("fxTime") && !key.equals("code")) { + String value = map.get(key).toString(); + jsonMap.put(key, value); + } + } + hashMap.put("json", JSONObject.toJSONString(jsonMap)); + forecastWeatherMapper.updateForecastWeather(hashMap); + } + } + } } -- Gitblit v1.8.0