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