package com.moral.api.controller;

import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.CrossOrigin;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import java.util.List;

import com.moral.api.entity.CityAqi;
import com.moral.api.entity.CityWeather;
import com.moral.api.entity.HistoryAqi;
import com.moral.api.service.CityAqiService;
import com.moral.api.service.CityWeatherService;
import com.moral.api.service.HistoryAqiService;
import com.moral.constant.ResultMessage;

@Slf4j
@Api(tags = {"接收job返回的正式库第三方数据"})
@RestController
@CrossOrigin(origins = "*", maxAge = 3600)
@RequestMapping("/dataReplication")
public class DataReplicationController {

    @Autowired
    private CityAqiService cityAqiService;

    @Autowired
    private CityWeatherService cityWeatherService;

    @Autowired
    private HistoryAqiService historyAqiService;

    @ApiOperation(value = "城市aqi数据处理", notes = "城市aqi数据处理")
    @PostMapping("insertCityAqi")
    public ResultMessage insertCityAqi(@RequestBody List<CityAqi> cityAqis) {
        cityAqis.forEach(cityAqi -> cityAqiService.save(cityAqi));
        return ResultMessage.ok();
    }

    @ApiOperation(value = "城市气象数据处理", notes = "城市气象数据处理")
    @PostMapping("insertCityWeather")
    public ResultMessage insertCityWeather(@RequestBody List<CityWeather> cityWeathers) {
        cityWeathers.forEach(cityWeather -> cityWeatherService.save(cityWeather));
        return ResultMessage.ok();
    }

    @ApiOperation(value = "国控站aqi数据处理", notes = "国控站aqi数据处理")
    @PostMapping("insertHistory")
    public ResultMessage insertHistory(@RequestBody List<HistoryAqi> historyAqis) {
        historyAqis.forEach(historyAqi -> historyAqiService.save(historyAqi));
        return ResultMessage.ok();
    }

}