pqs/pqs-influx/src/main/java/com/njcn/influx/service/CommonService.java

package com.njcn.influx.service;

import com.njcn.influx.pojo.dto.StatisticalDataDTO;

import java.util.List;

/**
 * Description:
 * Date: 2023/6/2  16:00【需求编号】
 *
 * @author clam
 * @version V1.0.0
 */
public interface CommonService {
      List<StatisticalDataDTO> commonquery(String lineId, String tableName, String columnName);

      /**
       * 根据条件获取监测点数据
       * @param lineId        监测点Id
       * @param tableName     表名
       * @param columnName    字段名
       * @param phasic        相别
       * @param dataType      数据类型
       * @return
       */
      StatisticalDataDTO getLineRtData(String lineId, String tableName, String columnName, String phasic, String dataType);

      /**
       * 根据条件获取监测点数据
       * @param lineIds        监测点Id
       * @param tableName     表名
       * @param columnName    字段名
       * @param phasic        相别
       * @param dataType      数据类型
       * @return
       */
      List<StatisticalDataDTO> getDeviceRtData(List<String> lineIds, String tableName, String columnName, String phasic, String dataType);
      /**
      * @Description: getDeviceRtDataByTime
       * @param lineIds        监测点Id
       * @param tableName     表名
       * @param columnName    字段名
       * @param phasic        相别
       * @param dataType      数据类型
       *@param startTime start time
       * @param endTime end time
      * @return: java.util.List<com.njcn.influx.pojo.dto.StatisticalDataDTO>
      * @Author: clam
      * @Date: 2023/6/13
      */
      List<StatisticalDataDTO> getDeviceRtDataByTime(List<String> lineIds, String tableName, String columnName, String phasic, String dataType,String startTime, String endTime);

      /**
       * 根据条件获取监测点时间范围内的最大最小值
       * @param lineId        监测点Id
       * @param tableName     表名
       * @param columnName    字段名
       * @param phasic        相别
       * @param dataType      数据类型
       * @return
       */
      StatisticalDataDTO getLineHistoryData(String lineId, String tableName, String columnName, String startTime, String endTime);


}