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 data =yssh3dreliService.query(name); return Result.OK(data); } @GetMapping("/getAll") @ApiOperation("查询所有数据") public Result getAll(){ List 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)); } }