From 5236663d1e40ca9ed0cbc0885cbc67a67c47943f Mon Sep 17 00:00:00 2001
From: kaiyu <404897439@qq.com>
Date: Mon, 14 Mar 2022 16:27:23 +0800
Subject: [PATCH] screen-api 增加获取简报接口
---
screen-api/src/main/java/com/moral/api/service/impl/CityAqiDailyServiceImpl.java | 325 +++++++++++++++++++++++++++++++++++++++++++++++++++--
1 files changed, 310 insertions(+), 15 deletions(-)
diff --git a/screen-api/src/main/java/com/moral/api/service/impl/CityAqiDailyServiceImpl.java b/screen-api/src/main/java/com/moral/api/service/impl/CityAqiDailyServiceImpl.java
index 2ef07d2..8ee0561 100644
--- a/screen-api/src/main/java/com/moral/api/service/impl/CityAqiDailyServiceImpl.java
+++ b/screen-api/src/main/java/com/moral/api/service/impl/CityAqiDailyServiceImpl.java
@@ -3,10 +3,14 @@
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.moral.api.config.properties.BulletinProperties;
import com.moral.api.config.properties.SpecialCitiesProperties;
import com.moral.api.entity.CityAqiDaily;
+import com.moral.api.entity.CityAqiMonthly;
+import com.moral.api.entity.CityAqiYearly;
import com.moral.api.entity.SysArea;
import com.moral.api.mapper.CityAqiDailyMapper;
+import com.moral.api.mapper.CityAqiMonthlyMapper;
import com.moral.api.pojo.dto.cityAQI.CityPollutionLevel;
import com.moral.api.pojo.dto.cityAQI.MonthlyPollutionLevel;
import com.moral.api.pojo.dto.cityAQI.PollutionDaysAndProportion;
@@ -18,14 +22,12 @@
import com.moral.api.service.CityAqiYearlyService;
import com.moral.api.service.SysAreaService;
import com.moral.constant.Constants;
-import com.moral.util.AQIUtils;
-import com.moral.util.ComprehensiveIndexUtils;
-import com.moral.util.DateUtils;
-import com.moral.util.MathUtils;
+import com.moral.util.*;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.util.ObjectUtils;
+import java.text.DecimalFormat;
import java.text.SimpleDateFormat;
import java.util.*;
@@ -46,12 +48,18 @@
SysAreaService sysAreaService;
@Autowired
SpecialCitiesProperties specialCitiesProperties;
+ @Autowired
+ BulletinProperties bulletinProperties;
+ @Autowired
+ CityAqiMonthlyService cityAqiMonthlyService;
+ @Autowired
+ CityAqiYearlyService cityAqiYearlyService;
@Override
public List<CityAqiDaily> getCityAqiDailyByRegionCodeAndTime(Integer regionCode, Date startDate, Date endDate) {
QueryWrapper<CityAqiDaily> queryWrapper = new QueryWrapper<>();
- queryWrapper.eq("city_code",regionCode);
- queryWrapper.between("time",startDate,endDate);
+ queryWrapper.eq("city_code", regionCode);
+ queryWrapper.between("time", startDate, endDate);
return cityAqiDailyMapper.selectList(queryWrapper);
}
@@ -349,14 +357,6 @@
return datas;
}
-
- /**
- * @Description: ���������������������������������������������������������
- * @Param: [area, startDate, endDate]
- * @return: com.moral.api.pojo.dto.cityAQI.CityPollutionLevel
- * @Author: ���������
- * @Date: 2021/12/31
- */
@Override
public CityPollutionLevel calculateDaysByTimeAndSysArea(SysArea area, Date startDate, Date endDate) {
//������������
@@ -365,7 +365,7 @@
wrapper.between("time", startDate, endDate);
wrapper.orderByAsc("time");
List<CityAqiDaily> cityAqiDailies = cityAqiDailyMapper.selectList(wrapper);
- if(ObjectUtils.isEmpty(cityAqiDailies))
+ if (ObjectUtils.isEmpty(cityAqiDailies))
return null;
//���������������������������������������
Map<String, CityAqiDaily> tmpMap = new LinkedHashMap<>();
@@ -404,8 +404,303 @@
return cityPollutionLevel;
}
+ @Override
+ public List<String> airQualityBulletin(String regionCode, Date time) {
+ List<String> result = new ArrayList<>();
+ //���������������
+ QueryWrapper<CityAqiDaily> dailyWrapper = new QueryWrapper<>();
+ dailyWrapper.eq("city_code", regionCode);
+ dailyWrapper.eq("time", time);
+ CityAqiDaily cityAqiDaily = cityAqiDailyMapper.selectOne(dailyWrapper);
+ if (cityAqiDaily == null)
+ return null;
+ Map<String, Object> dailyDataMap = JSON.parseObject(cityAqiDaily.getValue(), Map.class);
+ //���������������
+ int year = DateUtils.getYear(time);
+ int month = DateUtils.getMonth(time);
+ int day = DateUtils.getDay(time);
+ //������������title
+ String title = getBulletinTitle(month + "", day + "");
+ if (title == null)
+ return null;
+ //���������������������������
+ String paragraphOne = getParagraphOne(month + "", day + "", dailyDataMap);
+ if (paragraphOne == null)
+ return null;
+ //���������������������
+ List<String> paragraphTwoAndFour = getParagraphTwoAndFour(year + "", month + "", day + "", regionCode, time);
+ if(paragraphTwoAndFour==null)
+ return null;
+ String paragraphTwo = paragraphTwoAndFour.get(0);
+ //���������������������������
+ String paragraphThree = getParagraphThree(month + "", day + "", regionCode, time);
+ if (paragraphThree == null)
+ return null;
+ //���������������������
+ String paragraphFour = paragraphTwoAndFour.get(1);
+ result.add(title);
+ result.add(paragraphOne);
+ result.add(paragraphTwo);
+ result.add(paragraphThree);
+ result.add(paragraphFour);
+ return result;
+ }
+
+ //������������title������
+ private String getBulletinTitle(String month, String day) {
+ String title = bulletinProperties.getTitle();
+ title = title.replace("{month}", month);
+ title = title.replace("{day}", day);
+ return title;
+ }
+
+ //���������������������������
+ private String getParagraphOne(String month, String day, Map<String, Object> dailyData) {
+ //������������������
+ String pollutionLevelDescribe = AQIUtils.classOfPollutionByAqi(Integer.parseInt(dailyData.get("AQI").toString()));
+ String pollutionLevel = AQIUtils.classCodeOfPollutionByAqi(Integer.parseInt(dailyData.get("AQI").toString()));
+ //���������������������������
+ int standardCount = AQIUtils.standardCount(dailyData);
+ String paragraphOne = bulletinProperties.getParagraphOne();
+ paragraphOne = paragraphOne.replace("{month}", month);
+ paragraphOne = paragraphOne.replace("{day}", day);
+ paragraphOne = paragraphOne.replace("{pollutionLevel}", pollutionLevel);
+ paragraphOne = paragraphOne.replace("{pollutionLevelDescribe}", pollutionLevelDescribe);
+ paragraphOne = paragraphOne.replace("{standardCount}", standardCount + "");
+ paragraphOne = paragraphOne.replace("{PM2.5}", dailyData.get("PM2_5").toString());
+ paragraphOne = paragraphOne.replace("{SO2}", dailyData.get("SO2").toString());
+ paragraphOne = paragraphOne.replace("{NO2}", dailyData.get("NO2").toString());
+ paragraphOne = paragraphOne.replace("{CO}", dailyData.get("CO").toString());
+ paragraphOne = paragraphOne.replace("{O3}", dailyData.get("O3").toString());
+ paragraphOne = paragraphOne.replace("{PM10}", dailyData.get("PM10").toString());
+ return paragraphOne;
+ }
+
+ //���������������������������������������
+ private List<String> getParagraphTwoAndFour(String year, String month, String day, String regionCode, Date time) {
+ List<String> result = new ArrayList<>();
+ String paragraphTwo = bulletinProperties.getParagraphTwo();
+ String paragraphFour = bulletinProperties.getParagraphFour();
+ Date startTime = DateUtils.getFirstDayOfYear(time);
+ Date endTime = time;
+ Date compareStartTime = DateUtils.addMonths(startTime, -12);
+ Date compareEndTime = DateUtils.addMonths(endTime, -12);
+ SysArea area = new SysArea();
+ area.setAreaCode(Integer.parseInt(regionCode));
+ //������������������������
+ CityPollutionLevel days = calculateDaysByTimeAndSysArea(area, startTime, endTime);
+ //������������������������������
+ CityPollutionLevel compareDays = calculateDaysByTimeAndSysArea(area, compareStartTime, compareEndTime);
+ //������������������
+ List<CityAqiYearly> yearDataList = cityAqiYearlyService.getCityAqiYearlyByRegionCodeAndTime(Integer.parseInt(regionCode), startTime, endTime);
+ List<CityAqiYearly> compareYearDataList = cityAqiYearlyService.getCityAqiYearlyByRegionCodeAndTime(Integer.parseInt(regionCode), compareStartTime, compareEndTime);
+ if (ObjectUtils.isEmpty(yearDataList) || ObjectUtils.isEmpty(compareYearDataList))
+ return null;
+ CityAqiYearly yearData = yearDataList.get(0);
+ CityAqiYearly compareYearData = compareYearDataList.get(0);
+ Map<String, Object> dataMap = JSON.parseObject(yearData.getValue(), Map.class);
+ Map<String, Object> compareDataMap = JSON.parseObject(compareYearData.getValue(), Map.class);
+ //���������������������
+ String yearPM_5 = dataMap.get("PM2_5").toString();
+ String fineDays = days.getExcellentWeatherDays() + days.getGoodWeatherDays() + "";
+ int allDays = DateUtils.getDays(startTime, endTime)+1;
+ paragraphTwo = paragraphTwo.replace("{year}", year);
+ paragraphTwo = paragraphTwo.replace("{yearPM2.5}", yearPM_5);
+ paragraphTwo = paragraphTwo.replace("{fineDays}", fineDays);
+ paragraphTwo = paragraphTwo.replace("{days}", allDays + "");
+ result.add(paragraphTwo);
+
+ //���������������������
+ //������������������������
+ Double compositeIndex = Double.valueOf(dataMap.get("compositeIndex").toString());
+ Double compareCompositeIndex = Double.valueOf(compareDataMap.get("compositeIndex").toString());
+ //������������������������������������
+ String yoyYearCompositeIndexUpDown = getUpOrDown(compositeIndex, compareCompositeIndex);
+ //������������������������������������������
+ String yoyYearCompositeIndex = calculateComparePerPositive(compositeIndex, compareCompositeIndex).toString();
+
+ //������������PM2.5
+ Double PM2_5 = Double.valueOf(dataMap.get("PM2_5").toString());
+ Double comparePM2_5 = Double.valueOf(compareDataMap.get("PM2_5").toString());
+ //������PM2.5������������������
+ String yoyYearPM2_5UpDown = getUpOrDown(PM2_5, comparePM2_5);
+ //������PM2.5������������������������
+ String yoyYearPM2_5 = calculateComparePerPositive(PM2_5, comparePM2_5).toString();
+
+ //������������������������
+ int yearFineDays = days.getExcellentWeatherDays() + days.getGoodWeatherDays();
+ //������������������������������
+ int compareYearFineDays = compareDays.getExcellentWeatherDays() + days.getGoodWeatherDays();
+ //������������������������
+ int yoyYearFineDaysInt = yearFineDays - compareYearFineDays;
+ String yoyYearFineDays = yoyYearFineDaysInt > 0 ? yoyYearFineDaysInt + "" : yoyYearFineDaysInt * (-1) + "";
+ //���������������������������������
+ String yoyYearFineDaysUpDown = getIncreaseOrDecrease(yearFineDays, compareYearFineDays);
+ //������������������������
+ int yearPollutionDays = days.getMildWeatherDays() + days.getMiddleWeatherDays() + days.getSeriousWeatherDays() + days.getServerWeatherDays();
+ //������������������������������
+ String yearFineDaysPer = String.valueOf(MathUtils.division(yearFineDays*100 ,allDays,2));
+
+ //������168������������������������������������������������������
+ List<Integer> oneSixEightRanges = rangeByCities(compositeIndex,
+ calculateCompare(compositeIndex, compareCompositeIndex),
+ startTime, endTime, compareStartTime, compareEndTime,
+ specialCitiesProperties.getOneSixEightCities());
+
+ //������28������������������������������������������������������
+ List<Integer> twentyEightRanges = rangeByCities(compositeIndex,
+ calculateCompare(compositeIndex, compareCompositeIndex),
+ startTime, endTime, compareStartTime, compareEndTime,
+ specialCitiesProperties.getTwentyEightCities());
+
+ String compositeIndex28range = twentyEightRanges.get(0).toString();
+ String compositeIndexPer28range = twentyEightRanges.get(1).toString();
+ String compositeIndex168range = oneSixEightRanges.get(0).toString();
+ String compositeIndexPer168range = oneSixEightRanges.get(1).toString();
+ //������������������
+ paragraphFour = paragraphFour.replace("{month}",month);
+ paragraphFour = paragraphFour.replace("{day}",day);
+ paragraphFour = paragraphFour.replace("{yearCompositeIndex}",compositeIndex+"");
+ paragraphFour = paragraphFour.replace("{yoyYearCompositeIndex}",yoyYearCompositeIndex);
+ paragraphFour = paragraphFour.replace("{yoyYearCompositeIndexUpDown}",yoyYearCompositeIndexUpDown);
+ paragraphFour = paragraphFour.replace("{yearPM2.5}",PM2_5+"");
+ paragraphFour = paragraphFour.replace("{yoyYearPM2.5UpDown}",yoyYearPM2_5UpDown);
+ paragraphFour = paragraphFour.replace("{yoyYearPM2.5}",yoyYearPM2_5);
+ paragraphFour = paragraphFour.replace("{yearFineDays}",yearFineDays+"");
+ paragraphFour = paragraphFour.replace("{yearFineDaysPer}",yearFineDaysPer);
+ paragraphFour = paragraphFour.replace("{yearPollutionDays}",yearPollutionDays+"");
+ paragraphFour = paragraphFour.replace("{yoyYearFineDaysUpDown}",yoyYearFineDaysUpDown);
+ paragraphFour = paragraphFour.replace("{yoyYearFineDays}",yoyYearFineDays);
+ paragraphFour = paragraphFour.replace("{compositeIndex28range}",compositeIndex28range);
+ paragraphFour = paragraphFour.replace("{compositeIndexPer28range}",compositeIndexPer28range);
+ paragraphFour = paragraphFour.replace("{compositeIndex168range}",compositeIndex168range);
+ paragraphFour = paragraphFour.replace("{compositeIndexPer168range}",compositeIndexPer168range);
+ result.add(paragraphFour);
+ return result;
+ }
+
+ //������������������������������������������������������
+ private List<Integer> rangeByCities(
+ Double compositeIndex,
+ Double compositeIndexPer,
+ Date startTime,
+ Date endTime,
+ Date compareStartTime,
+ Date compareEndTime, List<SysArea> areas){
+ List<Double> compositeIndexList = new ArrayList<>();
+ List<Double> compositePerList = new ArrayList<>();
+ for (SysArea sysArea : areas) {
+ //������������
+ List<CityAqiYearly> data = cityAqiYearlyService.getCityAqiYearlyByRegionCodeAndTime(sysArea.getAreaCode(), startTime, endTime);
+ //������������������
+ List<CityAqiYearly> compareData = cityAqiYearlyService.getCityAqiYearlyByRegionCodeAndTime(sysArea.getAreaCode(), compareStartTime, compareEndTime);
+ if(ObjectUtils.isEmpty(data)||ObjectUtils.isEmpty(compareData))
+ continue;
+ Map<String,Object> dataMap = JSON.parseObject(data.get(0).getValue(),Map.class);
+ Map<String,Object> compareDataMap = JSON.parseObject(compareData.get(0).getValue(),Map.class);
+ //������������������
+ compositeIndexList.add(Double.valueOf(dataMap.get("compositeIndex").toString()));
+ //���������������������������
+ Double per = calculateCompare(Double.valueOf(dataMap.get("compositeIndex").toString()),Double.valueOf(compareDataMap.get("compositeIndex").toString()));
+ compositePerList.add(per);
+ }
+ Collections.sort(compositeIndexList);
+ Collections.sort(compositePerList);
+ Integer compositeIndexRange = compositeIndexList.indexOf(compositeIndex);
+ Integer compositePerRange = compositePerList.indexOf(compositeIndexPer);
+ return Arrays.asList((compositeIndexRange+1),(compositePerRange+1));
+ }
+
+ //���������������������������
+ private String getParagraphThree(String month, String day, String regionCode, Date time) {
+ String paragraphThree = bulletinProperties.getParagraphThree();
+ //������������������������
+ CityAqiMonthly monthlyData = cityAqiMonthlyService.getCityAqiMonthByRegionCodeAndTime(Integer.parseInt(regionCode), time);
+ //������������������������
+ Date compareTime = DateUtils.addMonths(time, -12);
+ CityAqiMonthly compareMonthlyData = cityAqiMonthlyService.getCityAqiMonthByRegionCodeAndTime(Integer.parseInt(regionCode), compareTime);
+ if (monthlyData == null || compareMonthlyData == null)
+ return null;
+ Map<String, Object> monthlyDataMap = JSON.parseObject(monthlyData.getValue(), Map.class);
+ Map<String, Object> compareMonthlyDataMap = JSON.parseObject(compareMonthlyData.getValue(), Map.class);
+ //������������������
+ Date endTime = time;
+ Date startTime = DateUtils.getFirstDayOfMonth(time);
+ Date compareStartTime = DateUtils.addMonths(startTime, -12);
+ Date compareEndTime = DateUtils.addMonths(endTime, -12);
+ SysArea area = new SysArea();
+ area.setAreaCode(Integer.parseInt(regionCode));
+ CityPollutionLevel days = calculateDaysByTimeAndSysArea(area, startTime, endTime);
+ CityPollutionLevel compareDays = calculateDaysByTimeAndSysArea(area, compareStartTime, compareEndTime);
+ if (days == null || compareDays == null)
+ return null;
+ //������������������������
+ Double compositeIndex = Double.valueOf(monthlyDataMap.get("compositeIndex").toString());
+ Double compareCompositeIndex = Double.valueOf(compareMonthlyDataMap.get("compositeIndex").toString());
+ //������������������������������������
+ String yoyMonthCompositeIndexUpDown = getUpOrDown(compositeIndex, compareCompositeIndex);
+ //������������������������������������������
+ String yoyMonthCompositeIndex = calculateComparePerPositive(compositeIndex, compareCompositeIndex).toString();
+
+ //������������PM2.5
+ Double PM2_5 = Double.valueOf(monthlyDataMap.get("PM2_5").toString());
+ Double comparePM2_5 = Double.valueOf(compareMonthlyDataMap.get("PM2_5").toString());
+ //������PM2.5������������������
+ String yoyMonthPM2_5UpDown = getUpOrDown(PM2_5, comparePM2_5);
+ //������PM2.5������������������������
+ String yoyMonthPM2_5 = calculateComparePerPositive(PM2_5, comparePM2_5).toString();
+
+ //������������������������
+ int monthFineDays = days.getExcellentWeatherDays() + days.getGoodWeatherDays();
+ //������������������������������
+ int compareMonthFineDays = compareDays.getExcellentWeatherDays() + days.getGoodWeatherDays();
+ //������������������������
+ int yoyMonthFineDaysInt = monthFineDays - compareMonthFineDays;
+ String yoyMonthFineDays = yoyMonthFineDaysInt > 0 ? yoyMonthFineDaysInt + "" : yoyMonthFineDaysInt * (-1) + "";
+ //���������������������������������
+ String yoyMonthFineDaysUpDown = getIncreaseOrDecrease(monthFineDays, compareMonthFineDays);
+
+ paragraphThree = paragraphThree.replace("{month}", month);
+ paragraphThree = paragraphThree.replace("{day}", day);
+ paragraphThree = paragraphThree.replace("{monthCompositeIndex}", compositeIndex.toString());
+ paragraphThree = paragraphThree.replace("{yoyMonthCompositeIndex}", yoyMonthCompositeIndex);
+ paragraphThree = paragraphThree.replace("{yoyMonthCompositeIndexUpDown}", yoyMonthCompositeIndexUpDown);
+ paragraphThree = paragraphThree.replace("{monthPM2.5}", PM2_5.toString());
+ paragraphThree = paragraphThree.replace("{yoyMonthPM2.5UpDown}", yoyMonthPM2_5UpDown);
+ paragraphThree = paragraphThree.replace("{yoyMonthPM2.5}", yoyMonthPM2_5);
+ paragraphThree = paragraphThree.replace("{monthFineDays}", monthFineDays + "");
+ paragraphThree = paragraphThree.replace("{yoyMonthFineDaysUpDown}", yoyMonthFineDaysUpDown);
+ paragraphThree = paragraphThree.replace("{yoyMonthFineDays}", yoyMonthFineDays);
+ return paragraphThree;
+ }
+
+ //������currentData���compareData���������������"������","������".currentData>compareData���������������
+ private String getUpOrDown(Double currentData, Double compareData) {
+ if (MathUtils.sub(currentData, compareData) > 0)
+ return "������";
+ return "������";
+ }
+
+ //������������������������������������������������������������"������","������".currentData>compareData���������������
+ private String getIncreaseOrDecrease(int currentDays, int compareDays) {
+ if (currentDays - compareDays > 0)
+ return "������";
+ return "������";
+ }
+ //������������������/������������ ���������������������-���������������/������������ ���������������
+ private Double calculateComparePerPositive(Double currentData, Double compareData) {
+ double tmp1 = MathUtils.sub(currentData, compareData);
+ double result = MathUtils.mul(MathUtils.division(tmp1, compareData, 4),100d);
+ return result > 0 ? result : MathUtils.mul(result, -1d);
+ }
+
+ //������������������/������������ ���������������������-���������������/������������ ���������������
+ private Double calculateCompare(Double currentData, Double compareData) {
+ double tmp1 = MathUtils.sub(currentData, compareData);
+ return MathUtils.mul(MathUtils.division(tmp1, compareData, 4),100d);
+ }
}
--
Gitblit v1.8.0