package cn.iocoder.yudao.module.iot.dal.tdengine;
|
|
import cn.iocoder.yudao.module.iot.controller.admin.device.vo.message.IotDeviceMessagePageReqVO;
|
import cn.iocoder.yudao.module.iot.dal.dataobject.device.IotDeviceMessageDO;
|
import cn.iocoder.yudao.module.iot.framework.tdengine.core.annotation.TDengineDS;
|
import com.baomidou.mybatisplus.annotation.InterceptorIgnore;
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
import org.apache.ibatis.annotations.Mapper;
|
import org.apache.ibatis.annotations.Param;
|
|
import java.util.Collection;
|
import java.util.List;
|
import java.util.Map;
|
|
/**
|
* 设备消息 {@link IotDeviceMessageDO} Mapper 接口
|
*/
|
@Mapper
|
@TDengineDS
|
@InterceptorIgnore(tenantLine = "true") // 避免 SQL 解析，因为 JSqlParser 对 TDengine 的 SQL 解析会报错
|
public interface IotDeviceMessageMapper {
|
|
/**
|
* 创建设备消息超级表
|
*/
|
void createSTable();
|
|
/**
|
* 查询设备消息表是否存在
|
*
|
* @return 存在则返回表名；不存在则返回 null
|
*/
|
String showSTable();
|
|
/**
|
* 插入设备消息数据
|
*
|
* 如果子表不存在，会自动创建子表
|
*
|
* @param message 设备消息数据
|
*/
|
void insert(IotDeviceMessageDO message);
|
|
/**
|
* 获得设备消息分页
|
*
|
* @param reqVO 分页查询条件
|
* @return 设备消息列表
|
*/
|
IPage<IotDeviceMessageDO> selectPage(IPage<IotDeviceMessageDO> page,
|
@Param("reqVO") IotDeviceMessagePageReqVO reqVO);
|
|
/**
|
* 统计设备消息数量
|
*
|
* @param createTime 创建时间，如果为空，则统计所有消息数量
|
* @return 消息数量
|
*/
|
Long selectCountByCreateTime(@Param("createTime") Long createTime);
|
|
/**
|
* 按照 requestIds 批量查询消息
|
*
|
* @param deviceId 设备编号
|
* @param requestIds 请求编号集合
|
* @param reply 是否回复消息
|
* @return 消息列表
|
*/
|
List<IotDeviceMessageDO> selectListByRequestIdsAndReply(@Param("deviceId") Long deviceId,
|
@Param("requestIds") Collection<String> requestIds,
|
@Param("reply") Boolean reply);
|
|
/**
|
* 按照时间范围（小时），统计设备的消息数量
|
*/
|
List<Map<String, Object>> selectDeviceMessageCountGroupByDate(@Param("startTime") Long startTime,
|
@Param("endTime") Long endTime);
|
|
}
|
