diff --git a/yudao-module-iot/yudao-module-iot-biz/src/main/java/cn/iocoder/yudao/module/iot/dal/dataobject/tdengine/FieldParser.java b/yudao-module-iot/yudao-module-iot-biz/src/main/java/cn/iocoder/yudao/module/iot/dal/dataobject/tdengine/FieldParser.java deleted file mode 100644 index 2e4e0f507e..0000000000 --- a/yudao-module-iot/yudao-module-iot-biz/src/main/java/cn/iocoder/yudao/module/iot/dal/dataobject/tdengine/FieldParser.java +++ /dev/null @@ -1,85 +0,0 @@ -package cn.iocoder.yudao.module.iot.dal.dataobject.tdengine; - -import cn.iocoder.yudao.module.iot.controller.admin.thingmodel.model.ThingModelProperty; -import cn.iocoder.yudao.module.iot.controller.admin.thingmodel.model.ThingModelRespVO; - -import java.util.HashMap; -import java.util.List; - -import static cn.iocoder.yudao.framework.common.util.collection.CollectionUtils.convertList; - -/** - * FieldParser 类用于解析和转换物模型字段到 TDengine 字段 - */ -public class FieldParser { - - /** - * 物模型到td数据类型映射 - */ - @Deprecated - private static final HashMap TYPE_MAPPING = new HashMap<>() { - { - put("INT", "INT"); - put("FLOAT", "FLOAT"); - put("DOUBLE", "DOUBLE"); - put("BOOL", "BOOL"); - put("ENUM", "NCHAR"); - put("TEXT", "NCHAR"); - put("DATE", "NCHAR"); - } - }; - - /** - * 将物模型字段转换为td字段 - * - * @param property 物模型属性 - * @return TdField对象 - */ - public static TdFieldDO parse(ThingModelProperty property) { - // 将物模型字段类型映射为 td 字段类型 - String fieldName = property.getIdentifier().toLowerCase(); - String fType = TYPE_MAPPING.get(property.getDataType().toUpperCase()); - // 如果字段类型为NCHAR，默认长度为64 - int dataLength = 0; - if ("NCHAR".equals(fType)) { - dataLength = 64; - } - return new TdFieldDO(fieldName, fType, dataLength); - } - - /** - * 从物模型中获取字段列表 - * - * @param thingModel 物模型响应对象 - * @return 字段列表 - */ - public static List parse(ThingModelRespVO thingModel) { - return convertList(thingModel.getModel().getProperties(), FieldParser::parse); - } - - /** - * 将从库中查出来的字段信息转换为 TDengine 字段对象 - * - * @param rows 从库中查出的字段信息列表 - * @return 转换后的 TDengine 字段对象列表 - */ - public static List parse(List> rows) { - return convertList(rows, row -> { - String type = row.get(1).toString().toUpperCase(); - // TODO @puhui999："NCHAR" 最好枚举下 - int dataLength = "NCHAR".equals(type) ? Integer.parseInt(row.get(2).toString()) : -1; - return new TdFieldDO(row.get(0).toString(), type, dataLength); - }); - } - - /** - * 获取字段字义 - */ - @Deprecated - public static String getFieldDefine(TdFieldDO field) { - return "`" + field.getFieldName() + "`" + " " - + (field.getDataLength() > 0 ? String.format("%s(%d)", field.getDataType(), field.getDataLength()) - : field.getDataType()); - } - -} \ No newline at end of file diff --git a/yudao-module-iot/yudao-module-iot-biz/src/main/java/cn/iocoder/yudao/module/iot/dal/dataobject/tdengine/SelectDO.java b/yudao-module-iot/yudao-module-iot-biz/src/main/java/cn/iocoder/yudao/module/iot/dal/dataobject/tdengine/SelectDO.java deleted file mode 100644 index fb4cd459a6..0000000000 --- a/yudao-module-iot/yudao-module-iot-biz/src/main/java/cn/iocoder/yudao/module/iot/dal/dataobject/tdengine/SelectDO.java +++ /dev/null @@ -1,48 +0,0 @@ -package cn.iocoder.yudao.module.iot.dal.dataobject.tdengine; - -import lombok.Data; - -// TODO @haohao：类似这个，其实可以参考 mybatis plus，querywrapper，搞个 TdEngineQueryWrapper。这样看起来会更好懂。 -/** - * 查询DO - */ -@Data -@Deprecated -public class SelectDO { - - // TODO @haoha：database 是个单词 - /** - * 数据库名称 - */ - private String dataBaseName; - - /** - * 超级表名称 - */ - private String tableName; - - /** - * 查询字段 - */ - private String fieldName; - - /** - * 开始时间 - */ - private Long startTime; - - /** - * 结束时间 - */ - private Long endTime; - - /** - * 查询类型 - */ - private String type; - - /** - * 设备ID - */ - private String deviceId; -} diff --git a/yudao-module-iot/yudao-module-iot-biz/src/main/java/cn/iocoder/yudao/module/iot/dal/dataobject/tdengine/TagsSelectDO.java b/yudao-module-iot/yudao-module-iot-biz/src/main/java/cn/iocoder/yudao/module/iot/dal/dataobject/tdengine/TagsSelectDO.java deleted file mode 100644 index 3538308241..0000000000 --- a/yudao-module-iot/yudao-module-iot-biz/src/main/java/cn/iocoder/yudao/module/iot/dal/dataobject/tdengine/TagsSelectDO.java +++ /dev/null @@ -1,37 +0,0 @@ -package cn.iocoder.yudao.module.iot.dal.dataobject.tdengine; - -import lombok.Data; - -/** - * tags查询DO - */ -@Data -@Deprecated -public class TagsSelectDO { - - /** - * 数据库名称 - */ - private String dataBaseName; - - /** - * 超级表名称 - */ - private String stableName; - - /** - * tags名称 - */ - private String tagsName; - - /** - * tags值 - */ - private Long startTime; - - /** - * tags值 - */ - private Long endTime; - -} diff --git a/yudao-module-iot/yudao-module-iot-biz/src/main/java/cn/iocoder/yudao/module/iot/dal/dataobject/tdengine/TdFieldDO.java b/yudao-module-iot/yudao-module-iot-biz/src/main/java/cn/iocoder/yudao/module/iot/dal/dataobject/tdengine/TdFieldDO.java deleted file mode 100644 index 10c9b9fe7d..0000000000 --- a/yudao-module-iot/yudao-module-iot-biz/src/main/java/cn/iocoder/yudao/module/iot/dal/dataobject/tdengine/TdFieldDO.java +++ /dev/null @@ -1,49 +0,0 @@ -package cn.iocoder.yudao.module.iot.dal.dataobject.tdengine; - -import lombok.AllArgsConstructor; -import lombok.Builder; -import lombok.Data; -import lombok.NoArgsConstructor; - -// TODO 芋艿：看看是不是后续简化掉。 -/** - * TD 引擎的字段 - */ -@Data -@NoArgsConstructor -@AllArgsConstructor -@Builder -@Deprecated -public class TdFieldDO { - - /** - * 字段名称 - */ - private String fieldName; - - /** - * 字段类型 - */ - private String dataType; - - /** - * 字段长度 - */ - private Integer dataLength = 0; - - /** - * 字段值 - */ - private Object fieldValue; - - public TdFieldDO(String fieldName, String dataType, Integer dataLength) { - this.fieldName = fieldName; - this.dataType = dataType; - this.dataLength = dataLength; - } - - public TdFieldDO(String fieldName, Object fieldValue) { - this.fieldName = fieldName; - this.fieldValue = fieldValue; - } -} \ No newline at end of file diff --git a/yudao-module-iot/yudao-module-iot-biz/src/main/java/cn/iocoder/yudao/module/iot/dal/dataobject/tdengine/TdResponse.java b/yudao-module-iot/yudao-module-iot-biz/src/main/java/cn/iocoder/yudao/module/iot/dal/dataobject/tdengine/TdResponse.java deleted file mode 100644 index 8b64f6854d..0000000000 --- a/yudao-module-iot/yudao-module-iot-biz/src/main/java/cn/iocoder/yudao/module/iot/dal/dataobject/tdengine/TdResponse.java +++ /dev/null @@ -1,42 +0,0 @@ -package cn.iocoder.yudao.module.iot.dal.dataobject.tdengine; - -import lombok.AllArgsConstructor; -import lombok.Data; -import lombok.NoArgsConstructor; - -import java.util.List; - -/** - * TdResponse 类用于处理 TDengine 的响应 - */ -@Data -@NoArgsConstructor -@AllArgsConstructor -@Deprecated -public class TdResponse { - - public static final int CODE_SUCCESS = 0; - public static final int CODE_TB_NOT_EXIST = 866; - - /** - * 状态 - */ - private String status; - - /** - * 错误码 - */ - private int code; - - /** - * 错误信息 - */ - private String desc; - - /** - * 列信息 - * [["time","TIMESTAMP",8,""],["powerstate","TINYINT",1,""],["brightness","INT",4,""],["deviceid","NCHAR",32,"TAG"]] - */ - private List data; - -} \ No newline at end of file diff --git a/yudao-module-iot/yudao-module-iot-biz/src/main/java/cn/iocoder/yudao/module/iot/dal/dataobject/tdengine/TdRestApi.java b/yudao-module-iot/yudao-module-iot-biz/src/main/java/cn/iocoder/yudao/module/iot/dal/dataobject/tdengine/TdRestApi.java deleted file mode 100644 index 1bb793a45a..0000000000 --- a/yudao-module-iot/yudao-module-iot-biz/src/main/java/cn/iocoder/yudao/module/iot/dal/dataobject/tdengine/TdRestApi.java +++ /dev/null @@ -1,59 +0,0 @@ -package cn.iocoder.yudao.module.iot.dal.dataobject.tdengine; - -import cn.hutool.http.HttpRequest; -import cn.hutool.http.HttpResponse; -import cn.hutool.json.JSONUtil; -import lombok.extern.slf4j.Slf4j; -import org.springframework.beans.factory.annotation.Value; -import org.springframework.stereotype.Service; - -// TODO @haohao：有部分非实体的部分，是不是可以搞到 iot 的 framework 包下，搞个 tdengine 包，作为框架级的封装，放在 dataobject，感觉不是很合理哈。【可以微信讨论下】 -/** - * TdRestApi 类用于处理 TDengine 的 REST API 请求 - */ -@Slf4j -@Service -@Deprecated // TODO 芋艿：貌似没用到 -public class TdRestApi { - - @Value("${spring.datasource.dynamic.datasource.tdengine.url}") - private String url; - - @Value("${spring.datasource.dynamic.datasource.tdengine.username}") - private String username; - - @Value("${spring.datasource.dynamic.datasource.tdengine.password}") - private String password; - - /** - * 获取 REST API URL - */ - private String getRestApiUrl() { - String restUrl = url.replace("jdbc:TAOS-RS://", "") - .replaceAll("\\?.*", ""); - int idx = restUrl.lastIndexOf("/"); - return String.format("%s/rest/sql/%s", restUrl.substring(0, idx), restUrl.substring(idx + 1)); - } - - - /** - * 新建td api请求对象 - */ - public HttpRequest newApiRequest(String sql) { - return HttpRequest - .post(getRestApiUrl()) - .body(sql) - .basicAuth(username, password); - } - - /** - * 执行sql - */ - public TdResponse execSql(String sql) { - log.info("exec td sql:{}", sql); - HttpRequest request = newApiRequest(sql); - HttpResponse response = request.execute(); - return JSONUtil.toBean(response.body(), TdResponse.class); - } - -} \ No newline at end of file diff --git a/yudao-module-iot/yudao-module-iot-biz/src/main/java/cn/iocoder/yudao/module/iot/dal/dataobject/tdengine/TdTableDO.java b/yudao-module-iot/yudao-module-iot-biz/src/main/java/cn/iocoder/yudao/module/iot/dal/dataobject/tdengine/TdTableDO.java deleted file mode 100644 index 104be26837..0000000000 --- a/yudao-module-iot/yudao-module-iot-biz/src/main/java/cn/iocoder/yudao/module/iot/dal/dataobject/tdengine/TdTableDO.java +++ /dev/null @@ -1,71 +0,0 @@ -package cn.iocoder.yudao.module.iot.dal.dataobject.tdengine; - -import lombok.AllArgsConstructor; -import lombok.Builder; -import lombok.Data; -import lombok.NoArgsConstructor; - -import java.util.List; - -@Deprecated -/** - * TD 引擎的数据库 - */ -@Data -@Builder -@NoArgsConstructor -@AllArgsConstructor -public class TdTableDO { - - /** - * 数据库名称 - */ - private String dataBaseName; - - // TODO @haohao：superTableName 和 tableName 是不是合并。因为每个 mapper 操作的时候，有且只会使用到其中一个。 - /** - * 超级表名称 - */ - private String superTableName; - - /** - * 表名称 - */ - private String tableName; - - private String productKey; - - private String deviceKey; - - /** - * COLUMN 字段 - */ - private TdFieldDO column; - - /** - * TAG 字段 - */ - private TdFieldDO tag; - - /** - * COLUMN 字段 - 列表 - */ - private List columns; - - /** - * TAG 字段 - 列表 - */ - private List tags; - - public TdTableDO(String dataBaseName, String superTableName, List columns, List tags) { - this.dataBaseName = dataBaseName; - this.superTableName = superTableName; - this.columns = columns; - this.tags = tags; - } - - public TdTableDO(String dataBaseName, String superTableName) { - this.dataBaseName = dataBaseName; - this.superTableName = superTableName; - } -} diff --git a/yudao-module-iot/yudao-module-iot-biz/src/main/java/cn/iocoder/yudao/module/iot/dal/dataobject/tdengine/ThingModelMessageDO.java b/yudao-module-iot/yudao-module-iot-biz/src/main/java/cn/iocoder/yudao/module/iot/dal/dataobject/tdengine/ThingModelMessageDO.java deleted file mode 100644 index ae70da37bb..0000000000 --- a/yudao-module-iot/yudao-module-iot-biz/src/main/java/cn/iocoder/yudao/module/iot/dal/dataobject/tdengine/ThingModelMessageDO.java +++ /dev/null @@ -1,61 +0,0 @@ -package cn.iocoder.yudao.module.iot.dal.dataobject.tdengine; - -import lombok.AllArgsConstructor; -import lombok.Builder; -import lombok.Data; -import lombok.NoArgsConstructor; - -// TODO @芋艿：纠结下字段 -@Deprecated // TODO @super：看看啥时候删除下哈。 -/** - * TD 物模型消息日志的数据库 - */ -@Data -@Builder -@NoArgsConstructor -@AllArgsConstructor -public class ThingModelMessageDO { - - - - /** - * 消息 ID - */ - private String id; - - /** - * 系统扩展参数 - * - * 例如：设备状态、系统时间、固件版本等系统级信息 - */ - private Object system; - - /** - * 请求方法 - * - * 例如：thing.event.property.post - */ - private String method; - - /** - * 请求参数 - */ - private Object params; - - /** - * 属性上报时间戳 - */ - private Long time; - - /** - * 设备信息 - */ - private String productKey; - - - /** - * 设备 key - */ - private String deviceKey; - -} diff --git a/yudao-module-iot/yudao-module-iot-biz/src/main/java/cn/iocoder/yudao/module/iot/dal/tdengine/IotDevicePropertyDataMapper.java b/yudao-module-iot/yudao-module-iot-biz/src/main/java/cn/iocoder/yudao/module/iot/dal/tdengine/IotDevicePropertyDataMapper.java index 1599ce957c..42b5e01eb8 100644 --- a/yudao-module-iot/yudao-module-iot-biz/src/main/java/cn/iocoder/yudao/module/iot/dal/tdengine/IotDevicePropertyDataMapper.java +++ b/yudao-module-iot/yudao-module-iot-biz/src/main/java/cn/iocoder/yudao/module/iot/dal/tdengine/IotDevicePropertyDataMapper.java @@ -4,7 +4,6 @@ import cn.hutool.core.collection.CollUtil; import cn.hutool.core.util.ObjectUtil; import cn.iocoder.yudao.framework.tenant.core.aop.TenantIgnore; import cn.iocoder.yudao.module.iot.dal.dataobject.tdengine.SelectVisualDO; -import cn.iocoder.yudao.module.iot.dal.dataobject.tdengine.TdTableDO; import cn.iocoder.yudao.module.iot.framework.tdengine.core.TDengineTableField; import cn.iocoder.yudao.module.iot.framework.tdengine.core.annotation.TDengineDS; import com.baomidou.mybatisplus.annotation.InterceptorIgnore; @@ -78,27 +77,6 @@ public interface IotDevicePropertyDataMapper { void alterProductPropertySTableDropField(@Param("productKey") String productKey, @Param("field") TDengineTableField field); - //TODO:先参考一下老逻辑，后续改进 - /** - * 插入数据 - 指定列插入数据 - * - * @param table 数据 - * productKey 产品 key - * deviceKey 设备 key - * columns 列 - */ - void insertDevicePropertyData(TdTableDO table); - - //TODO:先参考一下老逻辑，后续改进 - /** - * 查看超级表 - 获取超级表的结构信息 - * SQL：DESCRIBE [db_name.]stb_name; - * - * @param superTable 超级表信息 - * productKey 产品 key - */ - List> describeSuperTable(TdTableDO superTable); - /** * 获取历史数据列表 * diff --git a/yudao-module-iot/yudao-module-iot-biz/src/main/java/cn/iocoder/yudao/module/iot/dal/tdengine/TdEngineDDLMapper.java b/yudao-module-iot/yudao-module-iot-biz/src/main/java/cn/iocoder/yudao/module/iot/dal/tdengine/TdEngineDDLMapper.java deleted file mode 100644 index eeb061cc55..0000000000 --- a/yudao-module-iot/yudao-module-iot-biz/src/main/java/cn/iocoder/yudao/module/iot/dal/tdengine/TdEngineDDLMapper.java +++ /dev/null @@ -1,147 +0,0 @@ -package cn.iocoder.yudao.module.iot.dal.tdengine; - -import cn.iocoder.yudao.framework.tenant.core.aop.TenantIgnore; -import cn.iocoder.yudao.module.iot.dal.dataobject.tdengine.TdTableDO; -import com.baomidou.dynamic.datasource.annotation.DS; -import org.apache.ibatis.annotations.Mapper; -import org.apache.ibatis.annotations.Param; - -import java.util.List; -import java.util.Map; - -/** - * 专门处理 DDL（数据定义语言）操作，包含所有的数据库和表的定义操作，例如创建数据库、创建超级表、创建子表等 - */ -@Mapper -@DS("tdengine") -public interface TdEngineDDLMapper { - - /** - * 创建数据库 - * SQL：CREATE DATABASE [IF NOT EXISTS] db_name [database_options]; - * - * @param dataBaseName 数据库名称 - */ - @TenantIgnore - void createDatabase(@Param("dataBaseName") String dataBaseName); - - /** - * 创建超级表 - * SQL：CREATE STABLE [IF NOT EXISTS] stb_name (create_definition [, create_definition] ...) TAGS (create_definition [, create_definition] ...) [table_options]; - * - * @param superTable 超级表信息 - * dataBaseName 数据库名称 - * superTableName 超级表名称 - * columns 列信息 - * tags 标签信息 - */ - @TenantIgnore - void createSuperTable(TdTableDO superTable); - - /** - * 查看超级表 - 显示当前数据库下的所有超级表信息 - * SQL：SHOW STABLES [LIKE tb_name_wildcard]; - * - * @param superTable 超级表信息 - * dataBaseName 数据库名称 - * superTableName 超级表名称 - */ - @TenantIgnore - List> showSuperTables(TdTableDO superTable); - - /** - * 查看超级表 - 获取超级表的结构信息 - * SQL：DESCRIBE [db_name.]stb_name; - * - * @param superTable 超级表信息 - * dataBaseName 数据库名称 - * superTableName 超级表名称 - */ - @TenantIgnore - List> describeSuperTable(TdTableDO superTable); - - /** - * 修改超级表 - 增加列 - * SQL：ALTER STABLE stb_name ADD COLUMN col_name column_type; - * - * @param superTable 超级表信息 - * dataBaseName 数据库名称 - * superTableName 超级表名称 - * column 列信息 - */ - @TenantIgnore - void addColumnForSuperTable(TdTableDO superTable); - - /** - * 修改超级表 - 删除列 - * SQL：ALTER STABLE stb_name DROP COLUMN col_name; - * - * @param superTable 超级表信息 - * dataBaseName 数据库名称 - * superTableName 超级表名称 - * column 列信息 - */ - @TenantIgnore - void dropColumnForSuperTable(TdTableDO superTable); - - /** - * 修改超级表 - 修改列宽 - * SQL：ALTER STABLE stb_name MODIFY COLUMN col_name data_type(length); - * - * @param superTable 超级表信息 - * dataBaseName 数据库名称 - * superTableName 超级表名称 - * column 列信息 - */ - @TenantIgnore - void modifyColumnWidthForSuperTable(TdTableDO superTable); - - /** - * 修改超级表 - 为超级表添加标签 - * - * @param superTable 超级表信息 - * dataBaseName 数据库名称 - * superTableName 超级表名称 - * tag 标签信息 - */ - @TenantIgnore - void addTagForSuperTable(TdTableDO superTable); - - /** - * 修改超级表 - 为超级表删除标签 - * - * @param superTable 超级表信息 - * dataBaseName 数据库名称 - * superTableName 超级表名称 - * tag 标签信息 - */ - @TenantIgnore - void dropTagForSuperTable(TdTableDO superTable); - - /** - * 创建子表 - 创建子表 - * SQL：CREATE TABLE [IF NOT EXISTS] tb_name USING stb_name TAGS (tag_value1, ...); - * - * @param table 表信息 - * dataBaseName 数据库名称 - * superTableName 超级表名称 - * tableName 子表名称 - * tags TAG 字段 - */ - @TenantIgnore - void createTable(TdTableDO table); - - /** - * 创建子表 - 创建子表并指定标签的值 - * SQL：CREATE TABLE [IF NOT EXISTS] tb_name USING stb_name (tag_name1, ...) TAGS (tag_value1, ...); - * - * @param table 表信息 - * dataBaseName 数据库名称 - * superTableName 超级表名称 - * tableName 子表名称 - * tags TAG 字段 - */ - @TenantIgnore - void createTableWithTags(TdTableDO table); - -} diff --git a/yudao-module-iot/yudao-module-iot-biz/src/main/java/cn/iocoder/yudao/module/iot/dal/tdengine/TdEngineDMLMapper.java b/yudao-module-iot/yudao-module-iot-biz/src/main/java/cn/iocoder/yudao/module/iot/dal/tdengine/TdEngineDMLMapper.java deleted file mode 100644 index 12b2c232c3..0000000000 --- a/yudao-module-iot/yudao-module-iot-biz/src/main/java/cn/iocoder/yudao/module/iot/dal/tdengine/TdEngineDMLMapper.java +++ /dev/null @@ -1,103 +0,0 @@ -package cn.iocoder.yudao.module.iot.dal.tdengine; - -import cn.iocoder.yudao.framework.tenant.core.aop.TenantIgnore; -import cn.iocoder.yudao.module.iot.dal.dataobject.tdengine.SelectDO; -import cn.iocoder.yudao.module.iot.dal.dataobject.tdengine.SelectVisualDO; -import cn.iocoder.yudao.module.iot.dal.dataobject.tdengine.TagsSelectDO; -import cn.iocoder.yudao.module.iot.dal.dataobject.tdengine.TdTableDO; -import com.baomidou.dynamic.datasource.annotation.DS; -import org.apache.ibatis.annotations.Mapper; - -import java.util.List; -import java.util.Map; - -/** - * 专门处理 TD Engine 的 DML（数据操作语言）操作，处理所有的数据查询和写入操作，如插入数据、查询数据等 - */ -@Mapper -@DS("tdengine") -public interface TdEngineDMLMapper { - - /** - * 插入数据 - 指定列插入数据 - * - * @param table 数据 - * dataBaseName 数据库名 - * tableName 表名 - * columns 列 - */ - @TenantIgnore - void insertData(TdTableDO table); - - /** - * 根据时间戳查询数据 - * - * @param selectDO 查询条件 - * @return 查询结果列表 - */ - @TenantIgnore - List> selectByTimestamp(SelectDO selectDO); - - /** - * 根据时间戳获取数据条数 - * - * @param selectDO 查询条件 - * @return 数据条数 - */ - @TenantIgnore - Map selectCountByTimestamp(SelectDO selectDO); - - /** - * 获取最新数据 - * - * @param selectDO 查询条件 - * @return 最新数据 - */ - @TenantIgnore - Map selectOneLastData(SelectDO selectDO); - - /** - * 获取历史数据列表 - * - * @param selectVisualDO 查询条件 - * @return 历史数据列表 - */ - @TenantIgnore - List> selectHistoryDataList(SelectVisualDO selectVisualDO); - - /** - * 获取实时数据列表 - * - * @param selectVisualDO 查询条件 - * @return 实时数据列表 - */ - @TenantIgnore - List> selectRealtimeDataList(SelectVisualDO selectVisualDO); - - /** - * 获取聚合数据列表 - * - * @param selectVisualDO 查询条件 - * @return 聚合数据列表 - */ - @TenantIgnore - List> selectAggregateDataList(SelectVisualDO selectVisualDO); - - /** - * 根据标签获取最新数据列表 - * - * @param tagsSelectDO 查询条件 - * @return 最新数据列表 - */ - @TenantIgnore - List> selectLastDataListByTags(TagsSelectDO tagsSelectDO); - - /** - * 获取历史数据条数 - * - * @param selectVisualDO 查询条件 - * @return 数据条数 - */ - @TenantIgnore - Long selectHistoryCount(SelectVisualDO selectVisualDO); -} \ No newline at end of file diff --git a/yudao-module-iot/yudao-module-iot-biz/src/main/java/cn/iocoder/yudao/module/iot/framework/tdengine/config/TDengineTableInitConfiguration.java b/yudao-module-iot/yudao-module-iot-biz/src/main/java/cn/iocoder/yudao/module/iot/framework/tdengine/config/TDengineTableInitRunner.java similarity index 74% rename from yudao-module-iot/yudao-module-iot-biz/src/main/java/cn/iocoder/yudao/module/iot/framework/tdengine/config/TDengineTableInitConfiguration.java rename to yudao-module-iot/yudao-module-iot-biz/src/main/java/cn/iocoder/yudao/module/iot/framework/tdengine/config/TDengineTableInitRunner.java index 3e84ac11c8..3517e1e58c 100644 --- a/yudao-module-iot/yudao-module-iot-biz/src/main/java/cn/iocoder/yudao/module/iot/framework/tdengine/config/TDengineTableInitConfiguration.java +++ b/yudao-module-iot/yudao-module-iot-biz/src/main/java/cn/iocoder/yudao/module/iot/framework/tdengine/config/TDengineTableInitRunner.java @@ -5,17 +5,17 @@ import lombok.RequiredArgsConstructor; import lombok.extern.slf4j.Slf4j; import org.springframework.boot.ApplicationArguments; import org.springframework.boot.ApplicationRunner; -import org.springframework.context.annotation.Configuration; +import org.springframework.stereotype.Component; /** * TDengine 表初始化的 Configuration * * @author alwayssuper */ -@Configuration -@Slf4j +@Component @RequiredArgsConstructor -public class TDengineTableInitConfiguration implements ApplicationRunner { +@Slf4j +public class TDengineTableInitRunner implements ApplicationRunner { private final IotDeviceLogService deviceLogService; @@ -26,7 +26,7 @@ public class TDengineTableInitConfiguration implements ApplicationRunner { deviceLogService.defineDeviceLog(); } catch (Exception ex) { // 初始化失败时打印错误日志并退出系统 - log.error("[TDengine] 初始化设备日志表结构失败，系统无法正常运行，即将退出", ex); + log.error("[run][TDengine初始化设备日志表结构失败，系统无法正常运行，即将退出]", ex); System.exit(1); } } diff --git a/yudao-module-iot/yudao-module-iot-biz/src/main/resources/mapper/tdengine/TdEngineDDLMapper.xml b/yudao-module-iot/yudao-module-iot-biz/src/main/resources/mapper/tdengine/TdEngineDDLMapper.xml deleted file mode 100644 index 091b77f642..0000000000 --- a/yudao-module-iot/yudao-module-iot-biz/src/main/resources/mapper/tdengine/TdEngineDDLMapper.xml +++ /dev/null @@ -1,101 +0,0 @@ - - - - - - - CREATE DATABASE IF NOT EXISTS ${dataBaseName} - - - - - CREATE STABLE IF NOT EXISTS ${dataBaseName}.${superTableName} - - ${item.fieldName} ${item.dataType} - - (${item.dataLength}) - - - TAGS - - ${item.fieldName} ${item.dataType} - - (${item.dataLength}) - - - - - - - - - - - - - ALTER STABLE ${dataBaseName}.${superTableName} ADD COLUMN ${column.fieldName} ${column.dataType} - - (${column.dataLength}) - - - - - - ALTER STABLE ${dataBaseName}.${superTableName} DROP COLUMN ${column.fieldName} - - - - - ALTER STABLE ${dataBaseName}.${superTableName} MODIFY COLUMN ${column.fieldName} ${column.dataType} - - (${column.dataLength}) - - - - - - ALTER STABLE ${dataBaseName}.${superTableName} ADD TAG ${tag.fieldName} ${tag.dataType} - - (${tag.dataLength}) - - - - - - ALTER STABLE ${dataBaseName}.${superTableName} DROP TAG ${tag.fieldName} - - - - - CREATE TABLE IF NOT EXISTS ${dataBaseName}.${tableName} - USING ${dataBaseName}.${superTableName} - TAGS - - #{item.fieldValue} - - - - - - CREATE TABLE IF NOT EXISTS ${dataBaseName}.${tableName} - USING ${dataBaseName}.${superTableName} - - #{item.fieldName} - - TAGS - - #{item.fieldValue} - - - - \ No newline at end of file diff --git a/yudao-module-iot/yudao-module-iot-biz/src/main/resources/mapper/tdengine/TdEngineDMLMapper.xml b/yudao-module-iot/yudao-module-iot-biz/src/main/resources/mapper/tdengine/TdEngineDMLMapper.xml deleted file mode 100644 index b4084374cf..0000000000 --- a/yudao-module-iot/yudao-module-iot-biz/src/main/resources/mapper/tdengine/TdEngineDMLMapper.xml +++ /dev/null @@ -1,86 +0,0 @@ - - - - - - - INSERT INTO ${dataBaseName}.${tableName} - - ${item.fieldName} - - VALUES - - #{item.fieldValue} - - - - - - - - - - - - - - - - - - - - - - - - - - - - \ No newline at end of file diff --git a/yudao-module-iot/yudao-module-iot-biz/src/main/resources/mapper/tdengine/TdThinkModelMessageMapper.xml b/yudao-module-iot/yudao-module-iot-biz/src/main/resources/mapper/tdengine/TdThinkModelMessageMapper.xml deleted file mode 100644 index 474bb7c54c..0000000000 --- a/yudao-module-iot/yudao-module-iot-biz/src/main/resources/mapper/tdengine/TdThinkModelMessageMapper.xml +++ /dev/null @@ -1,35 +0,0 @@ - - - - - - - CREATE STABLE thing_model_message_${productKey}( - ts TIMESTAMP, - id NCHAR(64), - sys NCHAR(2048), - method NCHAR(255), - params NCHAR(2048), - device_name NCHAR(64) - )TAGS ( - device_key NCHAR(50) - ) - - - - - CREATE STABLE ${deviceKey} - USING thing_model_message_${productKey}( - ts, - id , - sys , - method , - params , - device_name - )TAGS( - #{device_key} - ) - - \ No newline at end of file