blame | history | patch | commit | commitdiff | ignore whitespace
lizijie
2022-03-15 009c553b99fa6a6b7aeaa6a6115ab1c6a90669d2 
 screen-api/src/main/java/com/moral/api/controller/AqiController.java


@@ -1,16 +1,19 @@


package com.moral.api.controller;




import com.moral.api.pojo.dto.cityAQI.BarChartOfPollutionLevelVO;


import com.moral.api.pojo.dto.cityAQI.BarChartTableOfPollutionLevelVO;


import com.moral.api.pojo.dto.cityAQI.PieChartOfPollutionLevelVO;


import com.moral.api.pojo.form.aqi.QueryPieChartOfPollutionLevelForm;


import com.moral.api.config.properties.SpecialCitiesProperties;


import com.moral.api.entity.SysArea;


import com.moral.api.pojo.dto.cityAQI.*;


import com.moral.api.pojo.form.aqi.*;


import com.moral.api.pojo.vo.cityAQI.*;


import com.moral.api.service.CityAqiDailyService;




import com.moral.api.service.CityAqiYearlyService;


import io.swagger.annotations.Api;


import io.swagger.annotations.ApiImplicitParam;


import io.swagger.annotations.ApiImplicitParams;


import io.swagger.annotations.ApiOperation;


import org.springframework.beans.factory.annotation.Autowired;


import org.springframework.beans.factory.annotation.Required;


import org.springframework.util.ObjectUtils;


import org.springframework.web.bind.annotation.CrossOrigin;


import org.springframework.web.bind.annotation.GetMapping;


@@ -20,11 +23,13 @@


import java.util.*;




import javax.servlet.http.HttpServletRequest;


import javax.validation.constraints.NotNull;




import com.moral.api.service.CityAqiService;


import com.moral.constant.ResponseCodeEnum;


import com.moral.constant.ResultMessage;


import com.moral.util.WebUtils;


import sun.security.util.Resources_sv;




@RestController


@RequestMapping("/aqi")


@@ -36,6 +41,10 @@


    private CityAqiService cityAqiService;


    @Autowired


    private CityAqiDailyService cityAqiDailyService;


    @Autowired


    SpecialCitiesProperties specialCitiesProperties;


    @Autowired


    CityAqiYearlyService cityAqiYearlyService;




    @GetMapping("compareO3")


    @ApiOperation(value = "预测和实测臭氧对比", notes = "预测和实测臭氧对比")


@@ -98,7 +107,7 @@


     * @Date: 2021/11/11


     */


    @GetMapping("queryPieChartOfPollutionLevel")


    public ResultMessage queryPieChartOfPollutionLevel(QueryPieChartOfPollutionLevelForm form) {


    public ResultMessage queryPieChartOfPollutionLevel(ChartOfPollutionLevelForm form) {


        //判断是否缺少参数


        if (!form.valid())


            return ResultMessage.fail(ResponseCodeEnum.PARAMETERS_IS_MISSING.getCode(),


@@ -108,213 +117,47 @@


        return ResultMessage.ok(VO);


    }




    @GetMapping("test1")


    public ResultMessage test1(){


        List<PieChartOfPollutionLevelVO> dtos = new ArrayList<>();


        PieChartOfPollutionLevelVO dto = new PieChartOfPollutionLevelVO();


        dto.setTime("2021-11");


        dto.setTotalDays(10);


        List<Map<String,Object>> list = new ArrayList<>();


        Map<String,Object> map = new HashMap<>();


        map.put("proportion","40%");


        map.put("days",4);


        map.put("pollution",0);


        list.add(map);




        Map<String,Object> map1 = new HashMap<>();


        map1.put("proportion","30%");


        map1.put("days",3);


        map1.put("pollution",1);


        list.add(map1);




        Map<String,Object> map2 = new HashMap<>();


        map2.put("proportion","30%");


        map2.put("days",3);


        map2.put("pollution",2);


        list.add(map2);




        Map<String,Object> map3 = new HashMap<>();


        map3.put("proportion","0%");


        map3.put("days",0);


        map3.put("pollution",3);


        list.add(map3);




        Map<String,Object> map4 = new HashMap<>();


        map4.put("proportion","0%");


        map4.put("days",0);


        map4.put("pollution",4);


        list.add(map4);




        Map<String,Object> map5 = new HashMap<>();


        map5.put("proportion","0%");


        map5.put("days",0);


        map5.put("pollution",5);


        list.add(map5);


        dto.setValues(list);




        PieChartOfPollutionLevelVO dto1 = new PieChartOfPollutionLevelVO();


        dto1.setTime("2021-11");


        List<Map<String,Object>> list1 = new ArrayList<>();




        Map<String,Object> map11 = new HashMap<>();


        map11.put("proportion","40%");


        map11.put("days",4);


        map11.put("pollution",0);


        list1.add(map11);




        Map<String,Object> map12 = new HashMap<>();


        map12.put("proportion","30%");


        map12.put("days",3);


        map12.put("pollution",1);


        list1.add(map12);




        Map<String,Object> map13 = new HashMap<>();


        map13.put("proportion","30%");


        map13.put("days",3);


        map13.put("pollution",2);


        list1.add(map13);




        Map<String,Object> map14 = new HashMap<>();


        map14.put("proportion","0%");


        map14.put("days",0);


        map14.put("pollution",3);


        list1.add(map14);




        Map<String,Object> map15 = new HashMap<>();


        map15.put("proportion","0%");


        map15.put("days",0);


        map15.put("pollution",4);


        list1.add(map15);




        Map<String,Object> map16 = new HashMap<>();


        map16.put("proportion","0%");


        map16.put("days",0);


        map16.put("pollution",5);


        list1.add(map16);


        dto1.setValues(list1);


        dto1.setTotalDays(10);




        dtos.add(dto);


        dtos.add(dto1);


        return ResultMessage.ok(dtos);


    }




    /**


     * @Description: 获取城市优良天气占比的柱状图数据


     * @Param: [form]


     * @return: com.moral.constant.ResultMessage


     * @Author: 陈凯裕


     * @Date: 2021/11/22


     */


    @GetMapping("queryBarChartOfPollutionLevel")


    public ResultMessage queryBarChartOfPollutionLevel(){


        BarChartOfPollutionLevelVO dto = new BarChartOfPollutionLevelVO();


        List<String> time = new ArrayList<>();


        time.add("2021-10");


        time.add("2021-11");


        List<Map<String,Object>> values = new ArrayList<>();




        Map<String,Object> map1 = new HashMap<>();


        map1.put("pollution",0);


        List<Integer> days1 = new ArrayList<>();


        days1.add(4);


        days1.add(6);


        List<String> proportion1 = new ArrayList<>();


        proportion1.add("40%");


        proportion1.add("60%");


        map1.put("days",days1);


        map1.put("proportion",proportion1);




        Map<String,Object> map2 = new HashMap<>();


        map2.put("pollution",1);


        List<Integer> days2 = new ArrayList<>();


        days2.add(1);


        days2.add(0);


        List<String> proportion2 = new ArrayList<>();


        proportion2.add("10%");


        proportion2.add("0%");


        map2.put("days",days2);


        map2.put("proportion",proportion2);




        Map<String,Object> map3 = new HashMap<>();


        map3.put("pollution",2);


        List<Integer> days3 = new ArrayList<>();


        days3.add(1);


        days3.add(0);


        List<String> proportion3 = new ArrayList<>();


        proportion3.add("10%");


        proportion3.add("0%");


        map3.put("days",days3);


        map3.put("proportion",proportion3);






        Map<String,Object> map4 = new HashMap<>();


        map4.put("pollution",3);


        List<Integer> days4 = new ArrayList<>();


        days4.add(2);


        days4.add(2);


        List<String> proportion4 = new ArrayList<>();


        proportion4.add("20%");


        proportion4.add("20%");


        map4.put("days",days4);


        map4.put("proportion",proportion4);






        Map<String,Object> map5 = new HashMap<>();


        map5.put("pollution",4);


        List<Integer> days5 = new ArrayList<>();


        days5.add(2);


        days5.add(2);


        List<String> proportion5 = new ArrayList<>();


        proportion5.add("20%");


        proportion5.add("20%");


        map5.put("days",days5);


        map5.put("proportion",proportion5);






        Map<String,Object> map6 = new HashMap<>();


        map6.put("pollution",5);


        List<Integer> days6 = new ArrayList<>();


        days6.add(0);


        days6.add(0);


        List<String> proportion6 = new ArrayList<>();


        proportion6.add("0%");


        proportion6.add("0%");


        map6.put("days",days6);


        map6.put("proportion",proportion6);




        values.add(map1);


        values.add(map2);


        values.add(map3);


        values.add(map4);


        values.add(map5);


        values.add(map6);




        dto.setTime(time);


        dto.setValues(values);


        return ResultMessage.ok(dto);


    public ResultMessage queryBarChartOfPollutionLevel(ChartOfPollutionLevelForm form) {


        //判断是否缺少参数


        if (!form.valid())


            return ResultMessage.fail(ResponseCodeEnum.PARAMETERS_IS_MISSING.getCode(),


                    ResponseCodeEnum.PARAMETERS_IS_MISSING.getMsg());


        //查询数据


        List<MonthlyPollutionLevel> datas = cityAqiDailyService.queryBarChartOfPollutionLevels(form);


        //数据格式转换


        BarChartOfPollutionLevelVO vo = BarChartOfPollutionLevelVO.convert(datas);


        return ResultMessage.ok(vo);




    }




    /**


     * @Description: 获取城市优良天气占比的柱状图下的表格数据


     * @Param: [form]


     * @return: com.moral.constant.ResultMessage


     * @Author: 陈凯裕


     * @Date: 2021/11/22


     */


    @GetMapping("queryBarChatTableOfPollutionLevel")


    public ResultMessage queryBarChatTableOfPollutionLevel(){


    public ResultMessage queryBarChatTableOfPollutionLevel(ChartOfPollutionLevelForm form) {


        //判断是否缺少参数


        if (!form.valid())


            return ResultMessage.fail(ResponseCodeEnum.PARAMETERS_IS_MISSING.getCode(),


                    ResponseCodeEnum.PARAMETERS_IS_MISSING.getMsg());


        //查询数据


        List<MonthlyPollutionLevel> datas = cityAqiDailyService.queryBarChartOfPollutionLevels(form);


        List<BarChartTableOfPollutionLevelVO> vos = new ArrayList<>();




        BarChartTableOfPollutionLevelVO vo1 = new BarChartTableOfPollutionLevelVO();


        BarChartTableOfPollutionLevelVO vo2 = new BarChartTableOfPollutionLevelVO();


        vo1.setExcellent("4(40%)");


        vo1.setGood("1(10%)");


        vo1.setMild("1(10%)");


        vo1.setMiddle("2(20%)");


        vo1.setSerious("2(20%)");


        vo1.setServer("0(0%)");


        vo1.setTotal("10(100%)");


        vo1.setTime("2021年10月");




        vo2.setExcellent("6(60%)");


        vo2.setGood("0(0%)");


        vo2.setMild("0(0%)");


        vo2.setMiddle("2(20%)");


        vo2.setSerious("2(20%)");


        vo2.setServer("0(0%)");


        vo2.setTotal("10(100%)");


        vo2.setTime("2021年11月");




        vos.add(vo1);


        vos.add(vo2);


        for (MonthlyPollutionLevel data : datas) {


            BarChartTableOfPollutionLevelVO vo = BarChartTableOfPollutionLevelVO.convert(data);


            vos.add(vo);


        }


        return ResultMessage.ok(vos);


    }




@@ -339,7 +182,7 @@


            @ApiImplicitParam(name = "time", value = "时间，排名类型为day,month,year是需传此参", required = true, paramType = "query", dataType = "String"),


            @ApiImplicitParam(name = "start", value = "开始时间，排名类型为custom自定义是传此参，精确到日，如：2021-11-02", required = true, paramType = "query", dataType = "String"),


            @ApiImplicitParam(name = "end", value = "结束时间，排名类型为custom自定义是传此参，精确到日，如：2021-11-03", required = true, paramType = "query", dataType = "String"),


            @ApiImplicitParam(name = "cityType", value = "城市类型，省内城市：province，市区排名：city", required = true, paramType = "query", dataType = "String"),


            @ApiImplicitParam(name = "cityType", value = "城市类型，省内城市：province，市区排名：city，2+28城市排名：28", required = true, paramType = "query", dataType = "String"),


    })


    public ResultMessage rankingDetails(HttpServletRequest request) {


        Map<String, Object> params = WebUtils.getParametersStartingWith(request, null);


@@ -361,4 +204,115 @@


        return ResultMessage.ok(response);


    }




    /**


     * @Description: 查询一个城市所有县级市的优良天气


     * @Param: [regionCode]


     * @return: com.moral.constant.ResultMessage


     * @Author: 陈凯裕


     * @Date: 2021/12/30


     */


    @GetMapping("queryAreaPollutionLevel")


    public ResultMessage queryAreaPollutionLevel(AreaPollutionLevelForm form) {


        //判断是否缺少参数


        if (!form.valid())


            return ResultMessage.fail(ResponseCodeEnum.PARAMETERS_IS_MISSING.getCode(),


                    ResponseCodeEnum.PARAMETERS_IS_MISSING.getMsg());


        //查询业务数据


        List<CityPollutionLevel> datas = cityAqiDailyService.queryAreaPollutionLevel(form);


        //返回数据


        return ResultMessage.ok(datas);


    }




    /**


     * @Description: 查询26+2城市优良天气数据


     * @Param: [form]


     * @return: com.moral.constant.ResultMessage


     * @Author: 陈凯裕


     * @Date: 2021/12/31


     */


    @GetMapping("qeury28CitiesPollutionLevel")


    public ResultMessage query28CitiesPollutionLevel(SpecialCitiesPollutionLevelForm form) {


        //判断是否缺少参数


        if (!form.valid())


            return ResultMessage.fail(ResponseCodeEnum.PARAMETERS_IS_MISSING.getCode(),


                    ResponseCodeEnum.PARAMETERS_IS_MISSING.getMsg());


        //查询业务数据


        List<CityPollutionLevel> datas = cityAqiDailyService.querySpecialCitiesPollutionLevel(form);


        //返回数据


        return ResultMessage.ok(datas);


    }




    /**


    * @Description: 查询一个省内所有城市的优良天数


            * @Param: [form]


            * @return: com.moral.constant.ResultMessage


            * @Author: 陈凯裕


            * @Date: 2022/1/7


            */


    @GetMapping("queryProvinceCitiesPollutionLevel")


    public ResultMessage queryProvinceCitiesPollutionLevel(ProvinceCitiesPollutionLevelForm form) {


        //判断是否缺少参数


        if (!form.valid())


            return ResultMessage.fail(ResponseCodeEnum.PARAMETERS_IS_MISSING.getCode(),


                    ResponseCodeEnum.PARAMETERS_IS_MISSING.getMsg());


        //查询业务数据


        List<CityPollutionLevel> datas = cityAqiDailyService.queryProvinceCitiesPollutionLevel(form);


        //返回数据


        return ResultMessage.ok(datas);


    }




    /** 


    * @Description: 查询城市空气质量同期对比数据


            * @Param: [form]


            * @return: com.moral.constant.ResultMessage


            * @Author: 陈凯裕


            * @Date: 2022/1/12


            */ 


    @GetMapping("queryAirQualityComparison")


    public ResultMessage queryAirQualityComparison(AirQualityComparisonForm form){


        //判断是否缺少参数


        if (!form.valid())


            return ResultMessage.fail(ResponseCodeEnum.PARAMETERS_IS_MISSING.getCode(),


                    ResponseCodeEnum.PARAMETERS_IS_MISSING.getMsg());


        //查询业务


        List<AirQualityComparisonVO> datas = cityAqiService.queryAirQualityComparison(form);


        //返回数据


        return ResultMessage.ok(datas);


    }




    /**


    * @Description: 优良天变化率分析


            * @Param: [year, cityCode]


            * @return: com.moral.constant.ResultMessage


            * @Author: 陈凯裕


            * @Date: 2022/2/10


            */


    @GetMapping("queryPollutionLevelAnalysis")


    public ResultMessage queryPollutionLevelAnalysis( String year, Integer cityCode){


        if(year==null||cityCode==null)


            return ResultMessage.fail(ResponseCodeEnum.PARAMETERS_IS_MISSING.getCode(),


                    ResponseCodeEnum.PARAMETERS_IS_MISSING.getMsg());


        Map<String, DataPercentRange> result = cityAqiYearlyService.analysisPollutionLevel(year, cityCode);


        return ResultMessage.ok(result);


    }




    @GetMapping("queryComplianceDaysAnalysis")


    public ResultMessage queryComplianceDaysAnalysis( String year, Integer cityCode){


        if(year==null||cityCode==null)


            return ResultMessage.fail(ResponseCodeEnum.PARAMETERS_IS_MISSING.getCode(),


                    ResponseCodeEnum.PARAMETERS_IS_MISSING.getMsg());


        List<ComplianceDaysDTO> dtos = cityAqiYearlyService.analysisComplianceDays(year, cityCode);


        return  ResultMessage.ok(ComplianceDaysVO.convert(dtos));


    }




    @GetMapping("momDate")


    public ResultMessage momDate(Integer regionCode, Integer size, Integer current, Integer orgId){


        if(regionCode==null || size==null || current==null){


            return ResultMessage.fail(ResponseCodeEnum.PARAMETERS_IS_MISSING.getCode(),


                    ResponseCodeEnum.PARAMETERS_IS_MISSING.getMsg());


        }


        Map<String, Object> result = cityAqiService.momData(regionCode, size, current, orgId);


        return  ResultMessage.ok(result);


    }




}