package com.yssh.controller;

import com.yssh.entity.Yssh2dreli;
import com.yssh.service.Yssh2dreliService;
import com.yssh.utils.AjaxResult;
import com.yssh.utils.Result;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import lombok.Synchronized;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.web.bind.annotation.*;

import java.util.List;

/**
 * @author lishijia
 * @ClassName Yssh2dreliController
 * @Description Yssh2dreliController
 * @date 2022/12/3 21:21
 * @Version 1.0
 */
@Api(tags="2维热力")
@CrossOrigin
@RestController
@RequestMapping("/2dreliController")
public class Yssh2dreliController {
    @Autowired
    private Yssh2dreliService yssh2dreliService;


    @GetMapping("/getAll")
    @ApiOperation("查询所有数据")
    public Result getAll(){
        List<Yssh2dreli> list =  yssh2dreliService.getAll();
        return Result.OK(list);
    }

    /**
     * 创建2维热力表接口
     * 1、每天自动创建表；格式为 yssh_2dreli_yyyyMMdd
     *
     * */
    @Transactional(rollbackFor = Exception.class)
    @Synchronized
    @GetMapping("/create")
    @ApiOperation("创建2维热力表接口")
    public AjaxResult create2dreli() {
        return AjaxResult.success(yssh2dreliService.create2dreliTable());
    }

    /**
     * 查询2维热力表接口
     * 1、根据time字段查询
     * 2、返回结果
     * */
    @Transactional(rollbackFor = Exception.class)
    @Synchronized
    @GetMapping("/query_data")
    @ApiOperation("查询2维热力表接口")
    public AjaxResult query2data(Yssh2dreli yssh2dreli,@RequestParam("tableName") String tableName) {
        return AjaxResult.success(yssh2dreliService.query2data(yssh2dreli,tableName));
    }

    /**
     * 删除2维热力表接口
     * */
    @Transactional(rollbackFor = Exception.class)
    @Synchronized
    @GetMapping("/drop")
    @ApiOperation("创建2维热力表接口")
    public AjaxResult drop2dreliTable() {
        return AjaxResult.success(yssh2dreliService.drop2dreliTable());
    }



    /**
     * 查询2维热力表接口
     * 1、根据time字段传入的开始时间和结束时间
     * 2、根据时间查询记录表，获取数据表名
     * 3、查询出结果、合并结果并返回结果
     * */
    @Transactional(rollbackFor = Exception.class)
    @Synchronized
    @GetMapping("/query_by_time")
    @ApiOperation("查询2维热力表接口")
    public AjaxResult twoDDataQuery(@RequestParam("startTime") String startTime,@RequestParam("endOfTime") String endOfTime) {
        return AjaxResult.success(yssh2dreliService.twoDDataQuery(startTime,endOfTime));
    }

    /**
     * 查询2维热力表接口
     * 1、根据time字段传入的开始时间和结束时间
     * 2、根据时间查询记录表，获取数据表名
     * 3、查询出结果、合并结果并返回结果
     * */
    @Transactional(rollbackFor = Exception.class)
    @Synchronized
    @GetMapping("/qubyt")
    @ApiOperation("查询2维热力表接口")
    public Result qubyt(@RequestParam("startTime") String startTime,@RequestParam("endOfTime") String endOfTime) {
        return Result.OK(yssh2dreliService.qubyt(startTime,endOfTime));
    }






}