Commit 61a0c05279613e6b9a95ef4ecc80cce7b2d3dc44
1 parent
05c54827
【新增功能】 集成 tdengine
Showing
8 changed files
with
4 additions
and
78 deletions
yudao-module-iot/yudao-module-iot-api/src/main/java/cn/iocoder/yudao/module/iot/domain/BaseEntity.java
| @@ -2,13 +2,6 @@ package cn.iocoder.yudao.module.iot.domain; | @@ -2,13 +2,6 @@ package cn.iocoder.yudao.module.iot.domain; | ||
| 2 | 2 | ||
| 3 | import lombok.Data; | 3 | import lombok.Data; |
| 4 | 4 | ||
| 5 | -/** | ||
| 6 | - * @ClassDescription: tdEngine的基础实体类 | ||
| 7 | - * @ClassName: BaseEntity | ||
| 8 | - * @Author: fxlinks | ||
| 9 | - * @Date: 2021-12-30 14:39:25 | ||
| 10 | - * @Version 1.0 | ||
| 11 | - */ | ||
| 12 | @Data | 5 | @Data |
| 13 | public class BaseEntity { | 6 | public class BaseEntity { |
| 14 | private static final long serialVersionUID = 1L; | 7 | private static final long serialVersionUID = 1L; |
yudao-module-iot/yudao-module-iot-api/src/main/java/cn/iocoder/yudao/module/iot/domain/Fields.java
| @@ -2,13 +2,6 @@ package cn.iocoder.yudao.module.iot.domain; | @@ -2,13 +2,6 @@ package cn.iocoder.yudao.module.iot.domain; | ||
| 2 | 2 | ||
| 3 | import lombok.Data; | 3 | import lombok.Data; |
| 4 | 4 | ||
| 5 | -/** | ||
| 6 | - * @ClassDescription: 建表的字段实体类 | ||
| 7 | - * @ClassName: Fields | ||
| 8 | - * @Author: fxlinks | ||
| 9 | - * @Date: 2021-12-28 09:09:04 | ||
| 10 | - * @Version 1.0 | ||
| 11 | - */ | ||
| 12 | @Data | 5 | @Data |
| 13 | public class Fields { | 6 | public class Fields { |
| 14 | private static final long serialVersionUID = 1L; | 7 | private static final long serialVersionUID = 1L; |
yudao-module-iot/yudao-module-iot-api/src/main/java/cn/iocoder/yudao/module/iot/domain/FieldsVo.java
| @@ -6,13 +6,6 @@ import java.sql.SQLException; | @@ -6,13 +6,6 @@ import java.sql.SQLException; | ||
| 6 | import java.util.ArrayList; | 6 | import java.util.ArrayList; |
| 7 | import java.util.List; | 7 | import java.util.List; |
| 8 | 8 | ||
| 9 | -/** | ||
| 10 | - * @ClassDescription: 建表的字段实体类的vo类 | ||
| 11 | - * @ClassName: FieldsVo | ||
| 12 | - * @Author: fxlinks | ||
| 13 | - * @Date: 2021-12-28 11:30:06 | ||
| 14 | - * @Version 1.0 | ||
| 15 | - */ | ||
| 16 | @Data | 9 | @Data |
| 17 | public class FieldsVo { | 10 | public class FieldsVo { |
| 18 | private static final long serialVersionUID = 1L; | 11 | private static final long serialVersionUID = 1L; |
| @@ -32,13 +25,6 @@ public class FieldsVo { | @@ -32,13 +25,6 @@ public class FieldsVo { | ||
| 32 | */ | 25 | */ |
| 33 | private Integer size; | 26 | private Integer size; |
| 34 | 27 | ||
| 35 | - /** | ||
| 36 | - * @param fields 字段实体类 | ||
| 37 | - * @return FieldsVo 字段实体vo类 | ||
| 38 | - * @MethodDescription 字段实体类转为vo类 | ||
| 39 | - * @author fx | ||
| 40 | - * @Date 2021/12/28 13:48 | ||
| 41 | - */ | ||
| 42 | public static FieldsVo fieldsTranscoding(Fields fields) throws SQLException { | 28 | public static FieldsVo fieldsTranscoding(Fields fields) throws SQLException { |
| 43 | // if (StringUtils.isBlank(fields.getFieldName()) || fields.getDataType() == null) { | 29 | // if (StringUtils.isBlank(fields.getFieldName()) || fields.getDataType() == null) { |
| 44 | // throw new SQLException("invalid operation: fieldName or dataType can not be null"); | 30 | // throw new SQLException("invalid operation: fieldName or dataType can not be null"); |
| @@ -51,13 +37,6 @@ public class FieldsVo { | @@ -51,13 +37,6 @@ public class FieldsVo { | ||
| 51 | return null; | 37 | return null; |
| 52 | } | 38 | } |
| 53 | 39 | ||
| 54 | - /** | ||
| 55 | - * @param fieldsList 字段实体类集合 | ||
| 56 | - * @return List<FieldsVo> 字段实体vo类集合 | ||
| 57 | - * @MethodDescription 字段实体类集合转为vo类集合 | ||
| 58 | - * @author fx | ||
| 59 | - * @Date 2021/12/28 14:00 | ||
| 60 | - */ | ||
| 61 | public static List<FieldsVo> fieldsTranscoding(List<Fields> fieldsList) throws SQLException { | 40 | public static List<FieldsVo> fieldsTranscoding(List<Fields> fieldsList) throws SQLException { |
| 62 | List<FieldsVo> fieldsVoList = new ArrayList<>(); | 41 | List<FieldsVo> fieldsVoList = new ArrayList<>(); |
| 63 | for (Fields fields : fieldsList) { | 42 | for (Fields fields : fieldsList) { |
yudao-module-iot/yudao-module-iot-api/src/main/java/cn/iocoder/yudao/module/iot/domain/ProductSuperTableModel.java
| @@ -7,21 +7,11 @@ import java.sql.Timestamp; | @@ -7,21 +7,11 @@ import java.sql.Timestamp; | ||
| 7 | import java.util.HashMap; | 7 | import java.util.HashMap; |
| 8 | import java.util.Optional; | 8 | import java.util.Optional; |
| 9 | 9 | ||
| 10 | -/** | ||
| 11 | - * @Description: 产品超级表模型 | ||
| 12 | - * @Author: fx | ||
| 13 | - * @Website: http://www.sxfxck.com | ||
| 14 | - * @CreateDate: 2022/1/1$ 19:37$ | ||
| 15 | - * @UpdateUser: fx | ||
| 16 | - * @UpdateDate: 2022/1/1$ 19:37$ | ||
| 17 | - * @UpdateRemark: 修改内容 | ||
| 18 | - * @Version: V1.0 | ||
| 19 | - */ | ||
| 20 | @Data | 10 | @Data |
| 21 | public class ProductSuperTableModel { | 11 | public class ProductSuperTableModel { |
| 22 | private static final long serialVersionUID = 1L; | 12 | private static final long serialVersionUID = 1L; |
| 23 | 13 | ||
| 24 | - @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss.SSS" , timezone = "GMT+8") | 14 | + @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss.SSS", timezone = "GMT+8") |
| 25 | private Timestamp ts; | 15 | private Timestamp ts; |
| 26 | 16 | ||
| 27 | private String superTableName; | 17 | private String superTableName; |
yudao-module-iot/yudao-module-iot-api/src/main/java/cn/iocoder/yudao/module/iot/domain/SelectDto.java
| @@ -4,13 +4,6 @@ import lombok.Data; | @@ -4,13 +4,6 @@ import lombok.Data; | ||
| 4 | 4 | ||
| 5 | import java.util.Set; | 5 | import java.util.Set; |
| 6 | 6 | ||
| 7 | -/** | ||
| 8 | - * @ClassDescription: 查询所需入参对象 | ||
| 9 | - * @ClassName: SelectDto | ||
| 10 | - * @Author: fxlinks | ||
| 11 | - * @Date: 2022-01-07 14:12:26 | ||
| 12 | - * @Version 1.0 | ||
| 13 | - */ | ||
| 14 | @Data | 7 | @Data |
| 15 | public class SelectDto { | 8 | public class SelectDto { |
| 16 | 9 |
yudao-module-iot/yudao-module-iot-api/src/main/java/cn/iocoder/yudao/module/iot/domain/SuperTableDto.java
| @@ -4,13 +4,6 @@ import lombok.Data; | @@ -4,13 +4,6 @@ import lombok.Data; | ||
| 4 | 4 | ||
| 5 | import java.util.List; | 5 | import java.util.List; |
| 6 | 6 | ||
| 7 | -/** | ||
| 8 | - * @ClassDescription: 创建超级表需要的入参的实体类 | ||
| 9 | - * @ClassName: SuperTableDto | ||
| 10 | - * @Author: fxlinks | ||
| 11 | - * @Date: 2021-12-28 15:03:45 | ||
| 12 | - * @Version 1.0 | ||
| 13 | - */ | ||
| 14 | @Data | 7 | @Data |
| 15 | public class SuperTableDto extends BaseEntity { | 8 | public class SuperTableDto extends BaseEntity { |
| 16 | 9 |
yudao-module-iot/yudao-module-iot-api/src/main/java/cn/iocoder/yudao/module/iot/domain/TableDto.java
| @@ -4,13 +4,6 @@ import lombok.Data; | @@ -4,13 +4,6 @@ import lombok.Data; | ||
| 4 | 4 | ||
| 5 | import java.util.List; | 5 | import java.util.List; |
| 6 | 6 | ||
| 7 | -/** | ||
| 8 | - * @ClassDescription: 创建超级表的子表需要的入参的实体类 | ||
| 9 | - * @ClassName: TableDto | ||
| 10 | - * @Author: fxlinks | ||
| 11 | - * @Date: 2021-12-30 14:42:47 | ||
| 12 | - * @Version 1.0 | ||
| 13 | - */ | ||
| 14 | @Data | 7 | @Data |
| 15 | public class TableDto extends BaseEntity { | 8 | public class TableDto extends BaseEntity { |
| 16 | 9 |
yudao-module-iot/yudao-module-iot-api/src/main/java/cn/iocoder/yudao/module/iot/domain/TagsSelectDao.java
| @@ -3,24 +3,16 @@ package cn.iocoder.yudao.module.iot.domain; | @@ -3,24 +3,16 @@ package cn.iocoder.yudao.module.iot.domain; | ||
| 3 | import lombok.Data; | 3 | import lombok.Data; |
| 4 | 4 | ||
| 5 | 5 | ||
| 6 | -/** | ||
| 7 | - * @program: fxlinks | ||
| 8 | - * @description: 标签查询模型 | ||
| 9 | - * @packagename: com.fx.tdengine.api.domain.rule | ||
| 10 | - * @author: fx | ||
| 11 | - * @e-mainl: 13733918655@163.com | ||
| 12 | - * @date: 2022-07-27 18:40 | ||
| 13 | - **/ | ||
| 14 | @Data | 6 | @Data |
| 15 | public class TagsSelectDao { | 7 | public class TagsSelectDao { |
| 16 | 8 | ||
| 17 | -// @NotBlank(message = "invalid operation: dataBaseName can not be empty") | 9 | + // @NotBlank(message = "invalid operation: dataBaseName can not be empty") |
| 18 | private String dataBaseName; | 10 | private String dataBaseName; |
| 19 | 11 | ||
| 20 | -// @NotBlank(message = "invalid operation: stableName can not be empty") | 12 | + // @NotBlank(message = "invalid operation: stableName can not be empty") |
| 21 | private String stableName; | 13 | private String stableName; |
| 22 | 14 | ||
| 23 | -// @NotBlank(message = "invalid operation: tagsName can not be empty") | 15 | + // @NotBlank(message = "invalid operation: tagsName can not be empty") |
| 24 | private String tagsName; | 16 | private String tagsName; |
| 25 | 17 | ||
| 26 | // @NotNull(message = "invalid operation: startTime can not be null") | 18 | // @NotNull(message = "invalid operation: startTime can not be null") |