sis/web/datacenter-hb/src/main/java/com/gyee/datacenter/controller/DataqueryController.java

package com.gyee.datacenter.controller;

import com.gyee.common.model.StringUtils;
import com.gyee.common.vo.datacenter.PointDataVo;
import com.gyee.common.vo.datacenter.RealExport;
import com.gyee.datacenter.config.R;
import com.gyee.datacenter.model.auto.Datacenter;
import com.gyee.datacenter.model.auto.Datacenterpoint;
import com.gyee.datacenter.service.DataqueryService;
import org.springframework.web.bind.annotation.*;

import javax.annotation.Resource;
import javax.servlet.http.HttpServletResponse;
import java.io.IOException;
import java.util.ArrayList;
import java.util.List;

/**
 * @ClassName : DatacenterController
 * @Author : xieshengjie
 * @Date: 2022/2/21 17:45
 * @Description :
 */
@RestController
@RequestMapping("//dataquery")
public class DataqueryController {
    @Resource
    private DataqueryService dataqueryService;

    /**
     * 获取所有表名
     * @return
     */
    @GetMapping("/tables")
    @ResponseBody
    @CrossOrigin(origins = "*", maxAge = 3600)
    public R getTables(){
        List<Datacenter> tables = dataqueryService.getTables();
        if (StringUtils.isNotNull(tables)) {
            return R.ok(tables.size()).data(tables);
        }else{
            return R.error().message("访问失败");
        }
    }

    /**
     * 根据表名点名查询数据
     * @param tableid
     * @param pointId
     * @return
     */
    @GetMapping("/realtimeData")
    @ResponseBody
    @CrossOrigin(origins = "*", maxAge = 3600)
    public R getRealtimedata(@RequestParam(value = "tableid",required = true)String tableid,
                             @RequestParam(value = "pointId",required = false)String pointId,
                             @RequestParam(value = "pointName",required = false)String pointName,
                             @RequestParam(value = "pageNum",required = true)String pageNum,
                             @RequestParam(value = "pageSize",required = true)String pageSize) {
        List<Datacenterpoint> realtimeList = dataqueryService.getRealtimeList(tableid, pointId, pointName);
        List<PointDataVo> vos = new ArrayList<>();
        if(StringUtils.isNotNull(realtimeList) && StringUtils.isNotEmpty(realtimeList)){
            vos = dataqueryService.getRealtimedata(realtimeList,pageNum,pageSize);
        }
        if (StringUtils.isNotNull(vos)) {
            return R.ok(vos.size()).data(vos);
        }else {
            return R.error().data("访问失败");
        }
    }

    /**
     * 根据点名查询历史数据
     * @param pointId
     * @param begin
     * @param end
     * @param interval
     * @return
     */
    @GetMapping("/historyData")
    @ResponseBody
    @CrossOrigin(origins = "*", maxAge = 3600)
    public R gethistoryData(@RequestParam(value = "pointId",required = true)String pointId,
                            @RequestParam(value = "begin",required = true)String begin,
                            @RequestParam(value = "end",required = true)String end,
                            @RequestParam(value = "interval",required = false)String interval,
                            @RequestParam(value = "type",required = false)String type) {
        List<PointDataVo> vos = dataqueryService.gethistoryData(pointId,begin,end,interval,type);
        if (StringUtils.isNotNull(vos)) {
            return R.ok(vos.size()).data(vos);
        }else {
            return R.error().message("访问失败");
        }
    }

    @GetMapping("/realtimeExport")
    @ResponseBody
    @CrossOrigin(origins = "*", maxAge = 3600)
    public R realtimeExport(@RequestParam(value = "tableid",required = true)String tableid,
                            @RequestParam(value = "pointId",required = false)String pointId,
                            @RequestParam(value = "pointName",required = false)String pointName, HttpServletResponse response) throws IOException {

        List<RealExport> list = dataqueryService.getRealtimeExport(tableid,pointId,pointName);
        if (StringUtils.isNotNull(list)) {
            return R.ok(list.size()).data(list);
        }else {
            return R.error().data("访问失败");
        }
    }

}