| | |
|---|
| | | import com.moral.api.service.CityAqiDailyService; |
|---|
| | | import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; |
|---|
| | | import com.moral.api.service.CityAqiService; |
|---|
| | | import com.moral.constant.Constants; |
|---|
| | | import com.moral.pojo.AQI; |
|---|
| | | import com.moral.util.AQIUtils; |
|---|
| | | import com.moral.util.AmendUtils; |
|---|
| | |
|---|
| | | } |
|---|
| | | }); |
|---|
| | | |
|---|
| | | //日aqi计算 |
|---|
| | | AQI aqi = AQIUtils.dailyAQI(jsonMap); |
|---|
| | | //日aqi,首要污染物计算 |
|---|
| | | Map<String, Object> sixParamMap = new HashMap<>(); |
|---|
| | | sixParamMap.put(Constants.SENSOR_CODE_PM25, jsonMap.get("PM2_5")); |
|---|
| | | sixParamMap.put(Constants.SENSOR_CODE_PM10, jsonMap.get("PM10")); |
|---|
| | | sixParamMap.put(Constants.SENSOR_CODE_SO2, jsonMap.get("SO2")); |
|---|
| | | sixParamMap.put(Constants.SENSOR_CODE_NO2, jsonMap.get("NO2")); |
|---|
| | | sixParamMap.put(Constants.SENSOR_CODE_CO, jsonMap.get("CO")); |
|---|
| | | sixParamMap.put(Constants.SENSOR_CODE_O3, jsonMap.get("O3")); |
|---|
| | | |
|---|
| | | AQI aqi = AQIUtils.dailyAQI(sixParamMap); |
|---|
| | | jsonMap.put("AQI", aqi.getAQIValue()); |
|---|
| | | jsonMap.put("primaryPollutant", aqi.getPrimaryPollutantNames()); |
|---|
| | | |
|---|
| | | //日综合指数计算 |
|---|
| | | Double compositeIndex = ComprehensiveIndexUtils.dailyData(jsonMap); |
|---|
| | | jsonMap.put("compositeIndex", compositeIndex); |
|---|
| | | |
|---|
| | | //首要污染物计算 |
|---|
| | | jsonMap.put("primaryPollutant", aqi.getPrimaryPollutantNames()); |
|---|
| | | |
|---|
| | | cityAqiDaily.setValue(JSONObject.toJSONString(jsonMap)); |
|---|
| | | cityAqiDailyMapper.insert(cityAqiDaily); |
|---|
