| | |
| | | import io.swagger.annotations.ApiImplicitParams; |
| | | import io.swagger.annotations.ApiOperation; |
| | | import org.springframework.beans.factory.annotation.Autowired; |
| | | import org.springframework.util.ObjectUtils; |
| | | import org.springframework.web.bind.annotation.CrossOrigin; |
| | | import org.springframework.web.bind.annotation.GetMapping; |
| | | import org.springframework.web.bind.annotation.RequestMapping; |
| | |
| | | @ApiImplicitParams(value = { |
| | | @ApiImplicitParam(name = "regionCode", value = "区号", required = true, paramType = "query", dataType = "String") |
| | | }) |
| | | public ResultMessage MeasuredCompareForecast(HttpServletRequest request) { |
| | | public ResultMessage measuredCompareForecast(HttpServletRequest request) { |
| | | Map<String, Object> params = WebUtils.getParametersStartingWith(request, null); |
| | | if (!params.containsKey("regionCode") || !params.containsKey("time")) { |
| | | return ResultMessage.fail(ResponseCodeEnum.PARAMETERS_IS_MISSING.getCode(), ResponseCodeEnum.PARAMETERS_IS_MISSING.getMsg()); |
| | |
| | | List<Map<String, Object>> response = cityAqiService.measuredCompareForecastOfO3(params); |
| | | return ResultMessage.ok(response); |
| | | } |
| | | |
| | | /** |
| | | * @Description: 查询最新的6参和aqi数据 |
| | | * @Param: [regionCode] |
| | | * @return: com.moral.constant.ResultMessage |
| | | * @Author: 陈凯裕 |
| | | * @Date: 2021/11/1 |
| | | */ |
| | | @GetMapping("queryByRegionCode") |
| | | public ResultMessage queryByRegionCode(Integer regionCode) { |
| | | Map<String, Object> value = cityAqiService.queryCityAqiByRegionCode(regionCode); |
| | | return ResultMessage.ok(value); |
| | | } |
| | | |
| | | /** |
| | | * @Description: 查询最近24小时的aqi数据 |
| | | * @Param: [regionCode] |
| | | * @return: com.moral.constant.ResultMessage |
| | | * @Author: 陈凯裕 |
| | | * @Date: 2021/11/1 |
| | | */ |
| | | @GetMapping("query24HoursAQI") |
| | | public ResultMessage query24HoursAQIByRegionCode(Integer regionCode) { |
| | | Map<String, Object> datas = cityAqiService.query24HoursAqiByRegionCode(regionCode); |
| | | return ResultMessage.ok(datas); |
| | | } |
| | | |
| | | /** |
| | | * @Description: 查询当天的累计aqi以及主要污染物 |
| | | * @Param: [RegionCode] |
| | | * @return: com.moral.constant.ResultMessage |
| | | * @Author: 陈凯裕 |
| | | * @Date: 2021/11/2 |
| | | */ |
| | | @GetMapping("queryTodayAqiAndPollutant") |
| | | public ResultMessage queryTodayAqiAndPollutant(Integer regionCode) { |
| | | Map<String, Object> datas = cityAqiService.queryTodayAqiAndPollutant(regionCode); |
| | | return ResultMessage.ok(datas); |
| | | } |
| | | |
| | | @GetMapping("provincialRanking") |
| | | @ApiOperation(value = "省内排名", notes = "省内排名") |
| | | @ApiImplicitParams(value = { |
| | | @ApiImplicitParam(name = "organizationId", value = "组织id", required = true, paramType = "query", dataType = "Integer") |
| | | }) |
| | | public ResultMessage provincialRanking(Integer organizationId) { |
| | | if (ObjectUtils.isEmpty(organizationId)) { |
| | | return ResultMessage.fail(ResponseCodeEnum.PARAMETERS_IS_MISSING.getCode(), ResponseCodeEnum.PARAMETERS_IS_MISSING.getMsg()); |
| | | } |
| | | Map<String, Object> response = cityAqiService.provincialRanking(organizationId); |
| | | return ResultMessage.ok(response); |
| | | } |
| | | |
| | | @GetMapping("rankingDetails") |
| | | @ApiOperation(value = "排名详情", notes = "排名详情") |
| | | @ApiImplicitParams(value = { |
| | | @ApiImplicitParam(name = "type", value = "排名类型,今日累计:today,小时:hour,日:day,月:month,年:year,自定义:custom", required = true, paramType = "query", dataType = "String"), |
| | | @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"), |
| | | }) |
| | | public ResultMessage rankingDetails(HttpServletRequest request) { |
| | | Map<String, Object> params = WebUtils.getParametersStartingWith(request, null); |
| | | if (!params.containsKey("type") || !params.containsKey("cityType")) { |
| | | return ResultMessage.fail(ResponseCodeEnum.PARAMETERS_IS_MISSING.getCode(), ResponseCodeEnum.PARAMETERS_IS_MISSING.getMsg()); |
| | | } |
| | | Object type = params.get("type"); |
| | | if ("hour".equals(type) || "day".equals(type) || "month".equals(type) || "year".equals(type)) { |
| | | if (!params.containsKey("time")) { |
| | | return ResultMessage.fail(ResponseCodeEnum.PARAMETERS_IS_MISSING.getCode(), ResponseCodeEnum.PARAMETERS_IS_MISSING.getMsg()); |
| | | } |
| | | } |
| | | if ("custom".equals(type)) { |
| | | if (!params.containsKey("start") || !params.containsKey("end")) { |
| | | return ResultMessage.fail(ResponseCodeEnum.PARAMETERS_IS_MISSING.getCode(), ResponseCodeEnum.PARAMETERS_IS_MISSING.getMsg()); |
| | | } |
| | | } |
| | | List<Map<String, Object>> response = cityAqiService.rankingDetails(params); |
| | | return ResultMessage.ok(response); |
| | | } |
| | | } |