package com.moral.api.controller;

import com.moral.api.service.RadarHourlySummaryService;
import com.moral.api.vo.ComparisonResponse;
import com.moral.api.vo.HourlyResponse;
import com.moral.constant.ResultMessage;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import io.swagger.annotations.ApiParam;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;

import java.time.LocalDateTime;
import java.time.format.DateTimeFormatter;

/**
 * @ClassName RadarProcessController
 * @Description TODO
 * @Author @cjl
 * @Date 2026-09-08 14:12
 * @Version 1.0
 */
@Slf4j
@Api(tags = {"雷达"})
@RestController
@RequestMapping("/radar")
public class RadarProcessController {

    @Autowired
    private RadarHourlySummaryService hourlySummaryService;

    /**
     * 处理上一完整小时
     * GET /radar/process-last
     */
    @GetMapping("/process-last")
    public ResultMessage processLastHour() {
        hourlySummaryService.processLastHour();
        return new ResultMessage();

    }

    /**
     * 处理指定小时
     * GET /radar/process?hour=2026-09-08 09:00:00
     */
    @GetMapping("/process")
    public ResultMessage processHour() {
        String startStr = "2026-09-08 14:00:00";
        String endStr = "2026-09-09 13:00:00";
        DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss");
        LocalDateTime startTime = LocalDateTime.parse(startStr, formatter);
        LocalDateTime endTime = LocalDateTime.parse(endStr, formatter);
        LocalDateTime current = startTime;
        while (!current.isAfter(endTime)) {
            // 将当前时间格式化为字符串并加入列表
            hourlySummaryService.processHour(current.format(formatter));
            // 时间增加 1 小时
            current = current.plusHours(1);
        }

        return new ResultMessage();
    }

    @GetMapping("/process1")
    public ResultMessage processHour1() {
        String startStr = "2026-09-01 00:00:00";
        hourlySummaryService.processHour(startStr);
        return new ResultMessage();
    }

    /**
     * 获取边界层对比数据
     * GET /radar/comparison?location=苏州&time=2026-09-09 09:00:00
     *
     * @param location 位置名称
     * @param time     请求时间，取前一整点作为 current
     */
    @GetMapping("/comparison")
    @ApiOperation("获取最近边界层数据")
    public ResultMessage getComparison(@RequestParam @ApiParam(value = "location",name = "地名") String location,
                                            @RequestParam @ApiParam(value = "time",name = "时间 yyyy-MM-dd HH:mm:ss") String time) {
        if(!location.equals("苏州")){
            return ResultMessage.ok("目前只有苏州区域有");
        }
        ComparisonResponse comparisonResponse = hourlySummaryService.getComparison(location, time);

        return ResultMessage.ok(comparisonResponse);
    }

    /**
     * 获取指定时间范围内每小时的雷达数据
     * GET /radar/hourly?location=苏州&startTime=2026-09-04 09:00:00&endTime=2026-09-09 09:00:00
     *
     * @param location  位置名称
     * @param startTime 起始时间（包含）
     * @param endTime   结束时间（不包含）
     */
    @GetMapping("/hourly")
    @ApiOperation("查询近5天逐小时边界层数据")
    public ResultMessage getHourly5Days(@RequestParam  @ApiParam(value = "location",name = "地名")  String location,
                                         @RequestParam  @ApiParam(value = "startTime",name = "开始时间")  String startTime,
                                         @RequestParam  @ApiParam(value = "endTime",name = "结束时间")  String endTime) {
        if(!location.equals("苏州")){
            return ResultMessage.ok("目前只有苏州区域有");
        }

        HourlyResponse getHourly5Days =  hourlySummaryService.getHourly5Days(location, startTime, endTime);

        return ResultMessage.ok(getHourly5Days);
    }

}