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