screen-api 增加获取简报接口

kaiyu

2022-03-14 5236663d1e40ca9ed0cbc0885cbc67a67c47943f

screen-api
           增加获取简报接口

 screen-api/src/main/java/com/moral/api/config/properties/BulletinProperties.java

New file
@@ -0,0 +1,27 @@
package com.moral.api.config.properties;

import lombok.Data;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.stereotype.Component;

/**
 * @ClassName
 * @Description TODO
 * @Author 陈凯裕
 * @Date 2022/3/11 15:04
 * @Version TODO
 **/
@Data
@Component
@ConfigurationProperties(prefix = "bulletin")
public class BulletinProperties {
    private String title;

    private String paragraphOne;

    private String paragraphTwo;

    private String paragraphThree;

    private String paragraphFour;
}

 screen-api/src/main/java/com/moral/api/config/properties/SpecialCitiesProperties.java

@@ -24,6 +24,8 @@

    private List<SysArea> heBeiEightCities;

    private List<SysArea> oneSixEightCities;

    public boolean isTwentyEightCities(Integer cityCode){
        for (SysArea city : twentyEightCities) {
            if(city.getAreaCode().equals(cityCode))

 screen-api/src/main/java/com/moral/api/controller/BulletinController.java

New file
@@ -0,0 +1,51 @@
package com.moral.api.controller;

import com.fasterxml.jackson.annotation.JsonFormat;
import com.moral.api.config.properties.BulletinProperties;
import com.moral.api.config.properties.SpecialCitiesProperties;
import com.moral.api.service.CityAqiDailyService;
import com.moral.constant.ResultMessage;
import com.sun.scenario.effect.impl.sw.sse.SSEBlend_SRC_OUTPeer;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.format.annotation.DateTimeFormat;
import org.springframework.web.bind.annotation.CrossOrigin;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import java.util.Date;
import java.util.List;

/**
 * @ClassName
 * @Description 公告controller
 * @Author 陈凯裕
 * @Date 2022/3/11 14:53
 * @Version TODO
 **/
@RestController
@RequestMapping("/bulletin")
@CrossOrigin(origins = "*", maxAge = 3600)
public class BulletinController {

    @Autowired
    CityAqiDailyService cityAqiDailyService;
    @Autowired
    BulletinProperties bulletinProperties;
    @Autowired
    SpecialCitiesProperties specialCitiesProperties;

    /**
    * @Description: 根据地区和时间查询空气质量简报
            * @Param: [regionCode, time]
            * @return: com.moral.constant.ResultMessage
            * @Author: 陈凯裕
            * @Date: 2022/3/11
            */
    @GetMapping("airQualityBulletin")
    public ResultMessage airQualityBulletin(String regionCode,
                                            @DateTimeFormat(pattern = "yyyy-MM-dd") Date time) {
        List<String> strings = cityAqiDailyService.airQualityBulletin(regionCode, time);
        return ResultMessage.ok(strings);
    }
}

 screen-api/src/main/java/com/moral/api/service/CityAqiDailyService.java

@@ -94,5 +94,14 @@
            */
    CityPollutionLevel calculateDaysByTimeAndSysArea(SysArea area, Date startDate, Date endDate);

    /**
    * @Description: 查询空气质量简报
            * @Param: [regionCode, time]
            * @return: java.lang.String
            * @Author: 陈凯裕
            * @Date: 2022/3/11
            */
    List<String> airQualityBulletin(String regionCode,Date time);


}

 screen-api/src/main/java/com/moral/api/service/CityAqiMonthlyService.java

@@ -25,4 +25,12 @@
            */
    List<CityAqiMonthly> getCityAqiMonthByRegionCodeAndTime(Integer regionCode, Date startDate,Date endDate);

    /**
    * @Description: 根据地区码和时间获取月度数据
            * @Param: [regionCode, time]
            * @return: com.moral.api.entity.CityAqiMonthly
            * @Author: 陈凯裕
            * @Date: 2022/3/14
            */
    CityAqiMonthly getCityAqiMonthByRegionCodeAndTime(Integer regionCode, Date time);
}

 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);
    }


}

 screen-api/src/main/java/com/moral/api/service/impl/CityAqiMonthlyServiceImpl.java

@@ -5,9 +5,12 @@
import com.moral.api.mapper.CityAqiMonthlyMapper;
import com.moral.api.service.CityAqiMonthlyService;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.moral.util.DateUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.io.*;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;

@@ -32,4 +35,14 @@
        queryWrapper.between("time",startDate,endDate);
        return cityAqiMonthlyMapper.selectList(queryWrapper);
    }

    @Override
    public CityAqiMonthly getCityAqiMonthByRegionCodeAndTime(Integer regionCode, Date time){
        time = DateUtils.getFirstDayOfMonth(time);
        QueryWrapper<CityAqiMonthly> queryWrapper = new QueryWrapper<>();
        queryWrapper.eq("city_code",regionCode);
        queryWrapper.eq("time",time);
        return cityAqiMonthlyMapper.selectOne(queryWrapper);
    }

}

 screen-api/src/main/resources/application-bulletin.yml

New file
@@ -0,0 +1,6 @@
bulletin:
  title: "{month}月{day}日空气质量情况简报"
  paragraphOne: "{month}月{day}日，我市空气质量为{pollutionLevel}级,{pollutionLevelDescribe}。从空气6因子看，{standardCount}项达标：PM10为{PM10}μg/m³（标准值150μg/m³）；PM2.5为{PM2.5}μg/m³（标准值75μg/m³）；SO2为{SO2}μg/m³（标准值150μg/m³）；NO2为{NO2}μg/m³（标准值80μg/m³）；CO为{CO}mg/m³（标准值4mg/m³）；O3-8H为{O3}μg/m³（标准值160μg/m³）。"
  paragraphTwo: "当前累计 PM2.5 为{yearPM2.5}mg/m³；优良天{fineDays}天，当前累计{days}天。"
  paragraphThree: "我市月度（{month}月1日-{day}日）环境空气质量综合指数为{monthCompositeIndex}，同比{yoyMonthCompositeIndexUpDown}{yoyMonthCompositeIndex}%；PM2.5累计浓度为{monthPM2.5}μg/m3，同比{yoyMonthPM2.5UpDown}{yoyMonthPM2.5}%；优良天数为{monthFineDays}天，与去年同期相比{yoyMonthFineDaysUpDown} {yoyMonthFineDays}天。"
  paragraphFour: "今年以来（1月1日-{month}月{day}日），我市空气质量综合指数为{yearCompositeIndex}，同比{yoyYearCompositeIndexUpDown} {yoyYearCompositeIndex}%，PM2.5累计浓度为{yearPM2.5}μg/m³，同比{yoyYearPM2.5UpDown}{yoyYearPM2.5}%，我市2021年环境空气质量优良{yearFineDays}天，优良天占比{yearFineDaysPer}%，污染天{yearPollutionDays}天，达标天数与去年同期相比{yoyYearFineDaysUpDown}{yoyYearFineDays}天。综合指数在“2+26”城市倒排第{compositeIndex28range}位，同比变化率倒排第{compositeIndexPer28range}位，在“168”城市倒排第{compositeIndex168range}位，同比变化率倒排第{compositeIndexPer168range}位。"

 screen-api/src/main/resources/application-dev.yml

@@ -13,7 +13,7 @@
spring:
  profiles:
    active: dev
    include: specialCity
    include: bulletin,specialCity
  application:
    name: screen-api
  redis:

 screen-api/src/main/resources/application-specialCity.yml

@@ -73,6 +73,346 @@
      areaName: 沧州市
    - areaCode: 130200
      areaName: 唐山市
  oneSixEightCities:
    - areaCode: 110000
      areaName: 北京市
    - areaCode: 120000
      areaName: 天津市
    - areaCode: 130100
      areaName: 石家庄市
    - areaCode: 130200
      areaName: 唐山市
    - areaCode: 130300
      areaName: 秦皇岛市
    - areaCode: 130400
      areaName: 邯郸市
    - areaCode: 130500
      areaName: 邢台市
    - areaCode: 130600
      areaName: 保定市
    - areaCode: 130700
      areaName: 张家口市
    - areaCode: 130800
      areaName: 承德市
    - areaCode: 130900
      areaName: 沧州市
    - areaCode: 131000
      areaName: 廊坊市
    - areaCode: 131100
      areaName: 衡水市
    - areaCode: 140100
      areaName: 太原市
    - areaCode: 140200
      areaName: 大同市
    - areaCode: 140600
      areaName: 朔州市
    - areaCode: 140900
      areaName: 忻州市
    - areaCode: 140300
      areaName: 阳泉市
    - areaCode: 140400
      areaName: 长治市
    - areaCode: 140500
      areaName: 晋城市
    - areaCode: 370100
      areaName: 济南市
    - areaCode: 370200
      areaName: 青岛市
    - areaCode: 370300
      areaName: 淄博市
    - areaCode: 370400
      areaName: 枣庄市
    - areaCode: 370500
      areaName: 东营市
    - areaCode: 370700
      areaName: 潍坊市
    - areaCode: 370800
      areaName: 济宁市
    - areaCode: 370900
      areaName: 泰安市
    - areaCode: 371100
      areaName: 日照市
    - areaCode: 371300
      areaName: 临沂市
    - areaCode: 371400
      areaName: 德州市
    - areaCode: 371500
      areaName: 聊城市
    - areaCode: 371600
      areaName: 滨州市
    - areaCode: 371700
      areaName: 菏泽市
    - areaCode: 410100
      areaName: 郑州市
    - areaCode: 410200
      areaName: 开封市
    - areaCode: 410400
      areaName: 平顶山市
    - areaCode: 410500
      areaName: 安阳市
    - areaCode: 410600
      areaName: 鹤壁市
    - areaCode: 410700
      areaName: 新乡市
    - areaCode: 410800
      areaName: 焦作市
    - areaCode: 410900
      areaName: 濮阳市
    - areaCode: 411000
      areaName: 许昌市
    - areaCode: 411100
      areaName: 漯河市
    - areaCode: 411300
      areaName: 南阳市
    - areaCode: 411400
      areaName: 商丘市
    - areaCode: 411500
      areaName: 信阳市
    - areaCode: 411600
      areaName: 周口市
    - areaCode: 411700
      areaName: 驻马店市
    - areaCode: 150100
      areaName: 呼和浩特市
    - areaCode: 150200
      areaName: 包头市
    - areaCode: 211300
      areaName: 朝阳市
    - areaCode: 210700
      areaName: 锦州市
    - areaCode: 211400
      areaName: 葫芦岛市
    - areaCode: 310000
      areaName: 上海市
    - areaCode: 320100
      areaName: 南京市
    - areaCode: 320200
      areaName: 无锡市
    - areaCode: 320300
      areaName: 徐州市
    - areaCode: 320400
      areaName: 常州市
    - areaCode: 320500
      areaName: 苏州市
    - areaCode: 320600
      areaName: 南通市
    - areaCode: 320700
      areaName: 连云港市
    - areaCode: 320800
      areaName: 淮安市
    - areaCode: 320900
      areaName: 盐城市
    - areaCode: 321000
      areaName: 扬州市
    - areaCode: 321100
      areaName: 镇江市
    - areaCode: 321200
      areaName: 泰州市
    - areaCode: 321300
      areaName: 宿迁市
    - areaCode: 330100
      areaName: 杭州市
    - areaCode: 330200
      areaName: 宁波市
    - areaCode: 330300
      areaName: 温州市
    - areaCode: 330600
      areaName: 绍兴市
    - areaCode: 330500
      areaName: 湖州市
    - areaCode: 330400
      areaName: 嘉兴市
    - areaCode: 330700
      areaName: 金华市
    - areaCode: 330800
      areaName: 衢州市
    - areaCode: 331000
      areaName: 台州市
    - areaCode: 331100
      areaName: 丽水市
    - areaCode: 330900
      areaName: 舟山市
    - areaCode: 340100
      areaName: 合肥市
    - areaCode: 340200
      areaName: 芜湖市
    - areaCode: 340300
      areaName: 蚌埠市
    - areaCode: 340400
      areaName: 淮南市
    - areaCode: 340500
      areaName: 马鞍山市
    - areaCode: 340600
      areaName: 淮北市
    - areaCode: 340700
      areaName: 铜陵市
    - areaCode: 340800
      areaName: 安庆市
    - areaCode: 341000
      areaName: 黄山市
    - areaCode: 341200
      areaName: 阜阳市
    - areaCode: 341300
      areaName: 宿州市
    - areaCode: 341100
      areaName: 滁州市
    - areaCode: 341500
      areaName: 六安市
    - areaCode: 341800
      areaName: 宣城市
    - areaCode: 341700
      areaName: 池州市
    - areaCode: 341600
      areaName: 亳州市
    - areaCode: 141100
      areaName: 吕梁市
    - areaCode: 140700
      areaName: 晋中市
    - areaCode: 141000
      areaName: 临汾市
    - areaCode: 140800
      areaName: 运城市
    - areaCode: 410300
      areaName: 洛阳市
    - areaCode: 411200
      areaName: 三门峡市
    - areaCode: 220403
      areaName: 西安区
    - areaCode: 610400
      areaName: 咸阳市
    - areaCode: 610300
      areaName: 宝鸡市
    - areaCode: 610200
      areaName: 铜川市
    - areaCode: 610500
      areaName: 渭南市
    - areaCode: 500000
      areaName: 重庆市
    - areaCode: 510100
      areaName: 成都市
    - areaCode: 510300
      areaName: 自贡市
    - areaCode: 510500
      areaName: 泸州市
    - areaCode: 510600
      areaName: 德阳市
    - areaCode: 510700
      areaName: 绵阳市
    - areaCode: 510900
      areaName: 遂宁市
    - areaCode: 511000
      areaName: 内江市
    - areaCode: 511100
      areaName: 乐山市
    - areaCode: 511181
      areaName: 峨眉山市
    - areaCode: 511500
      areaName: 宜宾市
    - areaCode: 511800
      areaName: 雅安市
    - areaCode: 512000
      areaName: 资阳市
    - areaCode: 511300
      areaName: 南充市
    - areaCode: 511600
      areaName: 广安市
    - areaCode: 511700
      areaName: 达州市
    - areaCode: 421200
      areaName: 咸宁市
    - areaCode: 420900
      areaName: 孝感市
    - areaCode: 421100
      areaName: 黄冈市
    - areaCode: 420100
      areaName: 武汉市
    - areaCode: 420200
      areaName: 黄石市
    - areaCode: 420700
      areaName: 鄂州市
    - areaCode: 420600
      areaName: 襄阳市
    - areaCode: 420500
      areaName: 宜昌市
    - areaCode: 420800
      areaName: 荆门市
    - areaCode: 421000
      areaName: 荆州市
    - areaCode: 421300
      areaName: 随州市
    - areaCode: 360100
      areaName: 南昌市
    - areaCode: 360300
      areaName: 萍乡市
    - areaCode: 360500
      areaName: 新余市
    - areaCode: 360900
      areaName: 宜春市
    - areaCode: 360400
      areaName: 九江市
    - areaCode: 430100
      areaName: 长沙市
    - areaCode: 430200
      areaName: 株洲市
    - areaCode: 430300
      areaName: 湘潭市
    - areaCode: 430600
      areaName: 岳阳市
    - areaCode: 430700
      areaName: 常德市
    - areaCode: 430900
      areaName: 益阳市
    - areaCode: 440100
      areaName: 广州市
    - areaCode: 440300
      areaName: 深圳市
    - areaCode: 440400
      areaName: 珠海市
    - areaCode: 440600
      areaName: 佛山市
    - areaCode: 440700
      areaName: 江门市
    - areaCode: 441200
      areaName: 肇庆市
    - areaCode: 441300
      areaName: 惠州市
    - areaCode: 441900
      areaName: 东莞市
    - areaCode: 442000
      areaName: 中山市
    - areaCode: 210100
      areaName: 沈阳市
    - areaCode: 210200
      areaName: 大连市
    - areaCode: 220100
      areaName: 长春市
    - areaCode: 230100
      areaName: 哈尔滨市
    - areaCode: 350100
      areaName: 福州市
    - areaCode: 350200
      areaName: 厦门市
    - areaCode: 450100
      areaName: 南宁市
    - areaCode: 460100
      areaName: 海口市
    - areaCode: 520100
      areaName: 贵阳市
    - areaCode: 530100
      areaName: 昆明市
    - areaCode: 540100
      areaName: 拉萨市
    - areaCode: 620100
      areaName: 兰州市
    - areaCode: 630100
      areaName: 西宁市
    - areaCode: 640100
      areaName: 银川市
    - areaCode: 650100
      areaName: 乌鲁木齐市







 screen-common/src/main/java/com/moral/constant/Constants.java

@@ -266,17 +266,17 @@

    public static final String SERVER_WEATHER = "严重污染";

    public static final String EXCELLENT_WEATHER_CODE = "0";
    public static final String EXCELLENT_WEATHER_CODE = "1";

    public static final String GOOD_WEATHER_CODE = "1";
    public static final String GOOD_WEATHER_CODE = "2";

    public static final String MILD_WEATHER_CODE = "2";
    public static final String MILD_WEATHER_CODE = "3";

    public static final String MIDDLE_WEATHER_CODE = "3";
    public static final String MIDDLE_WEATHER_CODE = "4";

    public static final String SERIOUS_WEATHER_CODE = "4";
    public static final String SERIOUS_WEATHER_CODE = "5";

    public static final String SERVER_WEATHER_CODE = "5";
    public static final String SERVER_WEATHER_CODE = "6";

    /*
     * 市内类型

 screen-common/src/main/java/com/moral/util/AQIUtils.java

@@ -24,6 +24,25 @@
    /*空气质量分指数*/
    private static Double[] IAQI_Array = new Double[]{0d,50d,100d,150d,200d,300d,400d,500d};


    //计算6参未超标因子数
    public static int standardCount(Map<String,Object> data){
        int count = 0;
        if(data.get("PM2_5")!=null&&PM2_5IsStandard(Double.valueOf(data.get("PM2_5").toString())))
            count++;
        if(data.get("PM10")!=null&&PM10IsStandard(Double.valueOf(data.get("PM10").toString())))
            count++;
        if(data.get("SO2")!=null&&SO2IsStandard(Double.valueOf(data.get("SO2").toString())))
            count++;
        if(data.get("NO2")!=null&&NO2IsStandard(Double.valueOf(data.get("NO2").toString())))
            count++;
        if(data.get("CO")!=null&&COIsStandard(Double.valueOf(data.get("CO").toString())))
            count++;
        if(data.get("O3")!=null&&O3IsStandard(Double.valueOf(data.get("O3").toString())))
            count++;
        return count;
    }

    //判断aqi是否达标
    public static boolean aqiIsStandard(int aqi){
        if(aqi<=100)