package com.yssh.controller;
|
|
import com.yssh.entity.Yssh3dreli;
|
import com.yssh.service.Yssh3dreliService;
|
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.text.ParseException;
|
import java.util.List;
|
|
/**
|
* @author lishijia
|
* @ClassName Yssh3dreliController
|
* @Description Yssh3dreliController
|
* @date 2022/12/3 21:21
|
* @Version 1.0
|
*/
|
@Api(tags="3维热力")
|
@RestController
|
@CrossOrigin
|
@RequestMapping("/3dreliController")
|
public class Yssh3dreliController {
|
@Autowired
|
private Yssh3dreliService yssh3dreliService;
|
|
@GetMapping("/query")
|
@ApiOperation("查询数据")
|
public Result query(String name){
|
List<Yssh3dreli> data =yssh3dreliService.query(name);
|
return Result.OK(data);
|
}
|
@GetMapping("/getAll")
|
@ApiOperation("查询所有数据")
|
public Result getAll(){
|
List<Yssh3dreli> list = yssh3dreliService.getAll();
|
return Result.OK(list);
|
}
|
|
/**
|
* 创建3维热力表接口
|
* 1、每天自动创建表;格式为 yssh_3dreli_yyyyMMdd
|
*
|
* */
|
@Transactional(rollbackFor = Exception.class)
|
@Synchronized
|
@GetMapping("/create")
|
@ApiOperation("创建3维热力表接口")
|
public AjaxResult create3dreli() {
|
return AjaxResult.success(yssh3dreliService.create3dreliTable());
|
}
|
|
|
/**
|
* 删除3维热力表接口
|
* */
|
@Transactional(rollbackFor = Exception.class)
|
@Synchronized
|
@GetMapping("/drop")
|
@ApiOperation("创建2维热力表接口")
|
public AjaxResult drop3dreliTable() {
|
return AjaxResult.success(yssh3dreliService.drop3dreliTable());
|
}
|
|
|
/**
|
* 查询3维热力表接口
|
* 1、根据time字段查询
|
* 2、返回结果
|
* */
|
@Transactional(rollbackFor = Exception.class)
|
@Synchronized
|
@GetMapping("/query_data")
|
@ApiOperation("查询3维热力表接口")
|
public AjaxResult query3data(Yssh3dreli yssh3dreli,@RequestParam("tableName") String tableName) {
|
return AjaxResult.success(yssh3dreliService.query3data(yssh3dreli,tableName));
|
}
|
|
|
/**
|
* 查询3维热力表接口
|
* 1、根据time字段传入的开始时间和结束时间
|
* 2、根据时间查询记录表,获取数据表名
|
* 3、查询出结果、合并结果并返回结果
|
* */
|
@Transactional(rollbackFor = Exception.class)
|
@Synchronized
|
@GetMapping("/query_by_time")
|
@ApiOperation("查询3维热力表接口")
|
public AjaxResult thrDDataQuery(@RequestParam("startTime") String startTime,@RequestParam("endOfTime") String endOfTime) {
|
return AjaxResult.success(yssh3dreliService.thrDDataQuery(startTime,endOfTime));
|
}
|
/**
|
* 查询3维热力表接口
|
* 1、根据time字段传入的开始时间和结束时间
|
* 2、根据时间查询记录表,获取数据表名
|
* 3、查询出结果、合并结果并返回结果
|
* */
|
@Transactional(rollbackFor = Exception.class)
|
@Synchronized
|
@GetMapping("/qubyt")
|
@ApiOperation("查询3维热力表接口")
|
public Result qubyt(@RequestParam("name") String name,@RequestParam("startTime") String startTime,@RequestParam("endOfTime") String endOfTime) throws ParseException {
|
return Result.OK(yssh3dreliService.qubyt(name,startTime,endOfTime));
|
}
|
|
|
}
|