【代码评审】IoT：设备日志 TDengine 表与模拟设备

YunaiV
1 parent 16120820
Showing 18 changed files with 89 additions and 86 deletions
yudao-module-iot/yudao-module-iot-biz/src/main/java/cn/iocoder/yudao/module/iot/controller/admin/device/IotDeviceDataController.java
yudao-module-iot/yudao-module-iot-biz/src/main/java/cn/iocoder/yudao/module/iot/controller/admin/device/vo/device/IotDeviceSaveReqVO.java
yudao-module-iot/yudao-module-iot-biz/src/main/java/cn/iocoder/yudao/module/iot/controller/admin/device/vo/deviceData/IotDeviceDataSimulatorSaveReqVO.java
yudao-module-iot/yudao-module-iot-biz/src/main/java/cn/iocoder/yudao/module/iot/controller/admin/device/vo/deviceData/IotDeviceLogPageReqVO.java
yudao-module-iot/yudao-module-iot-biz/src/main/java/cn/iocoder/yudao/module/iot/controller/admin/device/vo/deviceData/IotDeviceLogRespVO.java
yudao-module-iot/yudao-module-iot-biz/src/main/java/cn/iocoder/yudao/module/iot/controller/admin/thingmodel/IotThingModelController.java
yudao-module-iot/yudao-module-iot-biz/src/main/java/cn/iocoder/yudao/module/iot/controller/admin/thingmodel/vo/IotThingModelListReqVO.java
yudao-module-iot/yudao-module-iot-biz/src/main/java/cn/iocoder/yudao/module/iot/dal/dataobject/device/IotDeviceLogDO.java
yudao-module-iot/yudao-module-iot-biz/src/main/java/cn/iocoder/yudao/module/iot/dal/dataobject/tdengine/ThingModelMessageDO.java
yudao-module-iot/yudao-module-iot-biz/src/main/java/cn/iocoder/yudao/module/iot/dal/tdengine/IotDeviceLogDataMapper.java
yudao-module-iot/yudao-module-iot-biz/src/main/java/cn/iocoder/yudao/module/iot/dal/tdengine/TdThingModelMessageMapper.java
yudao-module-iot/yudao-module-iot-biz/src/main/java/cn/iocoder/yudao/module/iot/framework/tdengine/config/TDengineTableInitConfiguration.java
yudao-module-iot/yudao-module-iot-biz/src/main/java/cn/iocoder/yudao/module/iot/service/device/IotDeviceLogDataService.java
yudao-module-iot/yudao-module-iot-biz/src/main/java/cn/iocoder/yudao/module/iot/service/device/IotDeviceLogDataServiceImpl.java
yudao-module-iot/yudao-module-iot-biz/src/main/java/cn/iocoder/yudao/module/iot/service/device/IotDevicePropertyDataServiceImpl.java
yudao-module-iot/yudao-module-iot-biz/src/main/java/cn/iocoder/yudao/module/iot/service/product/IotProductServiceImpl.java
yudao-module-iot/yudao-module-iot-biz/src/main/java/cn/iocoder/yudao/module/iot/service/tdengine/IotThingModelMessageServiceImpl.java
yudao-module-iot/yudao-module-iot-biz/src/main/resources/mapper/device/IotDeviceLogDataMapper.xml
@@ -3,7 +3,6 @@ package cn.iocoder.yudao.module.iot.controller.admin.device;
 import cn.iocoder.yudao.framework.common.pojo.CommonResult;
 import cn.iocoder.yudao.framework.common.pojo.PageResult;
 import cn.iocoder.yudao.framework.common.util.object.BeanUtils;
-import cn.iocoder.yudao.module.iot.controller.admin.device.vo.device.IotDeviceSaveReqVO;
 import cn.iocoder.yudao.module.iot.controller.admin.device.vo.deviceData.*;
 import cn.iocoder.yudao.module.iot.dal.dataobject.device.IotDeviceDataDO;
 import cn.iocoder.yudao.module.iot.dal.dataobject.device.IotDeviceLogDO;
@@ -13,7 +12,6 @@ import io.swagger.v3.oas.annotations.Operation;
 import io.swagger.v3.oas.annotations.tags.Tag;
 import jakarta.annotation.Resource;
 import jakarta.validation.Valid;
-import org.springframework.security.access.prepost.PreAuthorize;
 import org.springframework.validation.annotation.Validated;
 import org.springframework.web.bind.annotation.*;
@@ -34,7 +32,7 @@ public class IotDeviceDataController {
     @Resource
     private IotDeviceLogDataService iotDeviceLogDataService;
-    @Resource
+    @Resource // TODO @super：service 之间，不用空行；原因是，这样更简洁；空行，主要是为了“间隔”，提升可读性
     private IotDeviceLogDataService deviceLogDataService;
     // TODO @浩浩：这里的 /latest-list，包括方法名。
@@ -52,14 +50,17 @@ public class IotDeviceDataController {
         PageResult<Map<String, Object>> list = deviceDataService.getHistoryDeviceProperties(deviceDataReqVO);
         return success(BeanUtils.toBean(list, IotTimeDataRespVO.class));
     }
+
     // TODO:数据权限
     @PostMapping("/simulator")
     @Operation(summary = "模拟设备")
     public CommonResult<Boolean> simulatorDevice(@Valid @RequestBody IotDeviceDataSimulatorSaveReqVO simulatorReqVO) {
         //TODO:先生成一下设备日志  后续完善模拟设备代码逻辑
+        // TODO @super：应该 deviceDataService 里面有个 simulatorDevice，然后里面去 insert 日志！
         iotDeviceLogDataService.createDeviceLog(simulatorReqVO);
         return success(true);
     }
+
     // TODO:数据权限
     @GetMapping("/log/page")
     @Operation(summary = "获得设备日志分页")
@@ -14,7 +14,7 @@ public class IotDeviceSaveReqVO {
     private Long id;
     @Schema(description = "设备编号", requiredMode = Schema.RequiredMode.AUTO, example = "177")
-    @Size(max = 50, message = "设备编号长度不能超过50个字符")
+    @Size(max = 50, message = "设备编号长度不能超过 50 个字符")
     private String deviceKey;
     @Schema(description = "设备名称", requiredMode = Schema.RequiredMode.REQUIRED, example = "王五")
@@ -3,27 +3,27 @@ package cn.iocoder.yudao.module.iot.controller.admin.device.vo.deviceData;
 import io.swagger.v3.oas.annotations.media.Schema;
 import jakarta.validation.constraints.NotEmpty;
 import lombok.Data;
-import org.springframework.format.annotation.DateTimeFormat;
-
-import java.time.LocalDateTime;
-
-import static cn.iocoder.yudao.framework.common.util.date.DateUtils.FORMAT_YEAR_MONTH_DAY_HOUR_MINUTE_SECOND;
+// TODO super： SaveReqVO => ReqVO
 @Schema(description = "管理后台 - IoT 模拟设备数据 Request VO")
 @Data
 public class IotDeviceDataSimulatorSaveReqVO {
-    @Schema(description = "消息ID", requiredMode = Schema.RequiredMode.REQUIRED, example = "msg123")
+    // TODO @super：感觉后端随机更合适？
+    @Schema(description = "消息 ID", requiredMode = Schema.RequiredMode.REQUIRED, example = "msg123")
     private String id;
+    // TODO @super：不用传递 productKey，因为 deviceKey 可以推导出来
     @Schema(description = "产品ID", requiredMode = Schema.RequiredMode.REQUIRED, example = "product123")
     @NotEmpty(message = "产品ID不能为空")
     private String productKey;
+    // TODO @super：中文写作规范，中英文之间，要有空格。例如说，设备 ID。ps：这里应该是设备标识
     @Schema(description = "设备ID", requiredMode = Schema.RequiredMode.REQUIRED, example = "device123")
     @NotEmpty(message = "设备ID不能为空")
     private String deviceKey;
+    // TODO @super：type、subType，是不是不用传递，因为模拟只有属性？？？
     @Schema(description = "消息/日志类型", requiredMode = Schema.RequiredMode.REQUIRED, example = "property")
     @NotEmpty(message = "消息类型不能为空")
     private String type;
@@ -36,6 +36,7 @@ public class IotDeviceDataSimulatorSaveReqVO {
     @NotEmpty(message = "数据内容不能为空")
     private String content;
+    // TODO @芋艿：需要讨论下，reportTime 到底以那个为准！
     @Schema(description = "上报时间", requiredMode = Schema.RequiredMode.REQUIRED)
     private Long reportTime;
@@ -18,13 +18,16 @@ public class IotDeviceLogPageReqVO extends PageParam {
     @NotEmpty(message = "设备标识不能为空")
     private String deviceKey;
+    // TODO @super：对应的枚举类
     @Schema(description = "消息类型", example = "property")
     private String type;
     @Schema(description = "标识符", example = "temperature")
+    // TODO @super：对应的枚举类
     private String subType;
     @Schema(description = "创建时间")
     @DateTimeFormat(pattern = FORMAT_YEAR_MONTH_DAY_HOUR_MINUTE_SECOND)
     private LocalDateTime[] createTime;
-} 
 \ No newline at end of file
+
+}
 \ No newline at end of file
@@ -11,8 +11,10 @@ public class IotDeviceLogRespVO {
     @Schema(description = "日志编号", requiredMode = Schema.RequiredMode.REQUIRED, example = "1024")
     private String id;
+
     @Schema(description = "产品标识", requiredMode = Schema.RequiredMode.REQUIRED, example = "product123")
     private String productKey;
+
     @Schema(description = "设备标识", requiredMode = Schema.RequiredMode.REQUIRED, example = "device123")
     private String deviceKey;
@@ -30,4 +32,5 @@ public class IotDeviceLogRespVO {
     @Schema(description = "记录时间戳", requiredMode = Schema.RequiredMode.REQUIRED)
     private LocalDateTime ts;
-} 
 \ No newline at end of file
+
+}
 \ No newline at end of file
@@ -74,6 +74,7 @@ public class IotThingModelController {
         return success(IotThingModelConvert.INSTANCE.convertList(list));
     }
+    // TODO @puhui @super：getThingModelListByProductId 和 getThingModelListByProductId 可以融合么？
     @GetMapping("/list")
     @Operation(summary = "获得产品物模型列表")
     @PreAuthorize("@ss.hasPermission('iot:thing-model:query')")
@@ -6,11 +6,10 @@ import io.swagger.v3.oas.annotations.media.Schema;
 import jakarta.validation.constraints.NotNull;
 import lombok.Data;
-
-
 @Schema(description = "管理后台 - IoT 产品物模型List Request VO")
 @Data
 public class IotThingModelListReqVO {
+
     @Schema(description = "功能标识")
     private String identifier;
@@ -21,7 +20,8 @@ public class IotThingModelListReqVO {
     @InEnum(IotThingModelTypeEnum.class)
     private Integer type;
-    @Schema(description = "产品ID", requiredMode = Schema.RequiredMode.REQUIRED)
-    @NotNull(message = "产品ID不能为空")
+    @Schema(description = "产品 ID", requiredMode = Schema.RequiredMode.REQUIRED)
+    @NotNull(message = "产品 ID 不能为空")
     private Long productId;
+
 }
 package cn.iocoder.yudao.module.iot.dal.dataobject.device;
-import cn.hutool.core.date.DateTime;
 import lombok.AllArgsConstructor;
 import lombok.Builder;
 import lombok.Data;
 import lombok.NoArgsConstructor;
-import java.time.LocalDateTime;
-
 /**
  * IoT 设备日志数据 DO
  *
+ * 目前使用 TDengine 存储
+ *
  * @author alwayssuper
  */
 @Data
@@ -18,33 +17,41 @@ import java.time.LocalDateTime;
 @NoArgsConstructor
 @AllArgsConstructor
 public class IotDeviceLogDO {
+
+    // TODO @芋艿：消息 ID 的生成逻辑
     /**
-     * 消息ID
+     * 消息 ID
      */
     private String id;
+    // TODO @super：关联要 @下
     /**
-     * 产品ID
+     * 产品标识
      */
     private String productKey;
+    // TODO @super：关联要 @下
     /**
-     * 设备ID
+     * 设备标识
      */
     private String deviceKey;
+    // TODO @super：枚举类
     /**
-     * 消息/日志类型
+     * 日志类型
      */
     private String type;
+    // TODO @super：枚举类
     /**
      * 标识符：用于标识具体的属性、事件或服务
      */
     private String subType;
     /**
-     * 数据内容：存储具体的消息数据内容，通常是JSON格式
+     * 数据内容
+     *
+     * 存储具体的消息数据内容，通常是 JSON 格式
      */
     private String content;
@@ -58,5 +65,4 @@ public class IotDeviceLogDO {
      */
     private Long ts;
-
 }
@@ -6,7 +6,7 @@ import lombok.Data;
 import lombok.NoArgsConstructor;
 // TODO @芋艿：纠结下字段
-@Deprecated
+@Deprecated // TODO @super：看看啥时候删除下哈。
 /**
  * TD 物模型消息日志的数据库
  */
@@ -25,7 +25,7 @@ public class ThingModelMessageDO {
     /**
      * 系统扩展参数
-     * 
+     *
      * 例如：设备状态、系统时间、固件版本等系统级信息
      */
     private Object system;
 package cn.iocoder.yudao.module.iot.dal.tdengine;
-import cn.iocoder.yudao.framework.common.pojo.PageResult;
 import cn.iocoder.yudao.module.iot.controller.admin.device.vo.deviceData.IotDeviceLogPageReqVO;
 import cn.iocoder.yudao.module.iot.dal.dataobject.device.IotDeviceLogDO;
 import cn.iocoder.yudao.module.iot.framework.tdengine.core.annotation.TDengineDS;
@@ -12,7 +11,7 @@ import java.util.List;
 /**
  * IOT 设备日志数据 Mapper 接口
- * 
+ *
  * 基于 TDengine 实现设备日志的存储
  */
 @Mapper
@@ -22,11 +21,12 @@ public interface IotDeviceLogDataMapper {
     /**
      * 创建设备日志超级表
-     * 
+     *
      * 注意：初始化时只需创建一次
      */
     void createDeviceLogSTable();
+    // TODO @super：是不是删除哈
     /**
      * 创建设备日志子表
      *
@@ -34,11 +34,12 @@ public interface IotDeviceLogDataMapper {
      */
     void createDeviceLogTable(@Param("deviceKey") String deviceKey);
+    // TODO @super：单个参数，不用加 @Param
     /**
      * 插入设备日志数据
-     * 
+     *
      * 如果子表不存在，会自动创建子表
-     * 
+     *
      * @param log 设备日志数据
      */
     void insert(@Param("log") IotDeviceLogDO log);
@@ -58,4 +59,5 @@ public interface IotDeviceLogDataMapper {
      * @return 日志总数
      */
     Long selectCount(@Param("reqVO") IotDeviceLogPageReqVO reqVO);
+
 }
 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.ThingModelMessage;
-import cn.iocoder.yudao.module.iot.dal.dataobject.tdengine.ThingModelMessageDO;
 import cn.iocoder.yudao.module.iot.framework.tdengine.core.annotation.TDengineDS;
-import com.baomidou.dynamic.datasource.annotation.DS;
 import com.baomidou.mybatisplus.annotation.InterceptorIgnore;
 import org.apache.ibatis.annotations.Mapper;
 import org.apache.ibatis.annotations.Param;
@@ -13,7 +9,7 @@ import org.apache.ibatis.annotations.Param;
  * 处理 TD 中物模型消息日志的操作
  */
 @Mapper
-@Deprecated
+@Deprecated // TODO super：什么时候，删除下哈。
 @TDengineDS
 @InterceptorIgnore(tenantLine = "true") // 避免 SQL 解析，因为 JSqlParser 对 TDengine 的 SQL 解析会报错
 public interface TdThingModelMessageMapper {
@@ -16,7 +16,7 @@ import org.springframework.core.annotation.Order;
 @Slf4j
 @RequiredArgsConstructor
 @Configuration
-@Order(Integer.MAX_VALUE) // 保证在最后执行
+@Order
 public class TDengineTableInitConfiguration implements ApplicationRunner {
     private final IotDeviceLogDataService deviceLogService;
@@ -26,15 +26,18 @@ public class TDengineTableInitConfiguration implements ApplicationRunner {
         try {
             // 初始化设备日志表
             deviceLogService.initTDengineSTable();
-            log.info("初始化 设备日志表 TDengine 表结构成功");
+            // TODO @super：这个日志，是不是不用打，不然重复啦！！！
+            log.info("[run]初始化 设备日志表 TDengine 表结构成功");
         } catch (Exception ex) {
+            // TODO @super：初始化失败，打印 error 日志，退出系统。。不然跑起来，就初始啦！！！
             if (ex.getMessage().contains("Table already exists")) {
                 log.info("TDengine 设备日志超级表已存在，跳过创建");
                 return;
-            }else{
+            } else{
                 log.error("初始化 设备日志表 TDengine  表结构失败", ex);
             }
             throw ex;
         }
     }
+
 }
@@ -5,7 +5,6 @@ import cn.iocoder.yudao.module.iot.controller.admin.device.vo.deviceData.IotDevi
 import cn.iocoder.yudao.module.iot.controller.admin.device.vo.deviceData.IotDeviceLogPageReqVO;
 import cn.iocoder.yudao.module.iot.dal.dataobject.device.IotDeviceLogDO;
-
 /**
  * IoT 设备日志数据 Service 接口
  *
@@ -15,7 +14,7 @@ public interface IotDeviceLogDataService {
     /**
      * 初始化 TDengine 超级表
-     * 
+     *
      *系统启动时，会自动初始化一次
      */
     void initTDengineSTable();
 package cn.iocoder.yudao.module.iot.service.device;
-import cn.hutool.core.date.DateTime;
 import cn.iocoder.yudao.framework.common.pojo.PageResult;
 import cn.iocoder.yudao.framework.common.util.object.BeanUtils;
 import cn.iocoder.yudao.module.iot.controller.admin.device.vo.deviceData.IotDeviceDataSimulatorSaveReqVO;
@@ -12,8 +11,6 @@ import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Service;
 import org.springframework.validation.annotation.Validated;
-import java.time.LocalDateTime;
-import java.time.ZoneId;
 import java.util.List;
 /**
@@ -29,34 +26,30 @@ public class IotDeviceLogDataServiceImpl implements IotDeviceLogDataService{
     @Resource
     private IotDeviceLogDataMapper iotDeviceLogDataMapper;
-
+    // TODO @super：方法名。defineDeviceLog。。未来，有可能别人使用别的记录日志，例如说 es 之类的。
     @Override
     public void initTDengineSTable() {
-        try {
-            // 创建设备日志超级表
-            iotDeviceLogDataMapper.createDeviceLogSTable();
-            log.info("创建设备日志超级表成功");
-        } catch (Exception ex) {
-            throw ex;
-        }
+        // TODO @super：改成不存在才创建。
+        iotDeviceLogDataMapper.createDeviceLogSTable();
     }
     @Override
     public void createDeviceLog(IotDeviceDataSimulatorSaveReqVO simulatorReqVO) {
-        //TODO:讨论一下，iotkit这块TS和上报时间都是外部传入的   但是看TDengine文档 他是建议对TS在SQL中直接NOW   咱们的TS数据获取是走哪一种
-
         // 1. 转换请求对象为 DO
         IotDeviceLogDO iotDeviceLogDO = BeanUtils.toBean(simulatorReqVO, IotDeviceLogDO.class);
-        
+
         // 2. 处理时间字段
+        // TODO @super：一次性的字段，不用单独给个变量
         long currentTime = System.currentTimeMillis();
         // 2.1 设置时序时间为当前时间
-        iotDeviceLogDO.setTs(currentTime);
+        iotDeviceLogDO.setTs(currentTime); // TODO @super：TS在SQL中直接NOW   咱们的TS数据获取是走哪一种；走 now()
         // 3. 插入数据
+        // TODO @super：不要直接调用对方的 IotDeviceLogDataMapper，通过 service 哈！
         iotDeviceLogDataMapper.insert(iotDeviceLogDO);
     }
+    // TODO @super：在 iotDeviceLogDataService 写
     @Override
     public PageResult<IotDeviceLogDO> getDeviceLogPage(IotDeviceLogPageReqVO pageReqVO) {
         // 查询数据
@@ -65,4 +58,5 @@ public class IotDeviceLogDataServiceImpl implements IotDeviceLogDataService{
         // 构造分页结果
         return new PageResult<>(list, total);
     }
+
 }
@@ -18,7 +18,6 @@ import cn.iocoder.yudao.module.iot.dal.dataobject.thingmodel.IotThingModelDO;
 import cn.iocoder.yudao.module.iot.dal.redis.deviceData.DeviceDataRedisDAO;
 import cn.iocoder.yudao.module.iot.dal.tdengine.IotDevicePropertyDataMapper;
 import cn.iocoder.yudao.module.iot.dal.tdengine.TdEngineDMLMapper;
-import cn.iocoder.yudao.module.iot.dal.tdengine.TdThingModelMessageMapper;
 import cn.iocoder.yudao.module.iot.enums.IotConstants;
 import cn.iocoder.yudao.module.iot.enums.thingmodel.IotDataSpecsDataTypeEnum;
 import cn.iocoder.yudao.module.iot.enums.thingmodel.IotThingModelTypeEnum;
@@ -111,7 +110,6 @@ public class IotDevicePropertyDataServiceImpl implements IotDevicePropertyDataSe
                 return;
             }
             newFields.add(0, new TDengineTableField(TDengineTableField.FIELD_TS, TDengineTableField.TYPE_TIMESTAMP));
-            // 2.1.1 创建产品超级表
             devicePropertyDataMapper.createProductPropertySTable(product.getProductKey(), newFields);
             return;
         }
@@ -9,7 +9,6 @@ import cn.iocoder.yudao.module.iot.dal.dataobject.product.IotProductDO;
 import cn.iocoder.yudao.module.iot.dal.mysql.product.IotProductMapper;
 import cn.iocoder.yudao.module.iot.enums.product.IotProductStatusEnum;
 import cn.iocoder.yudao.module.iot.service.device.IotDevicePropertyDataService;
-import cn.iocoder.yudao.module.iot.service.tdengine.IotThingModelMessageService;
 import com.baomidou.dynamic.datasource.annotation.DSTransactional;
 import jakarta.annotation.Resource;
 import org.springframework.context.annotation.Lazy;
@@ -116,14 +115,15 @@ public class IotProductServiceImpl implements IotProductService {
     public void updateProductStatus(Long id, Integer status) {
         // 1. 校验存在
         validateProductExists(id);
-        // 2. 更新
-        IotProductDO updateObj = IotProductDO.builder().id(id).status(status).build();
-        // 3. 产品是发布状态
+
+        // 2. 产品是发布状态
         if (Objects.equals(status, IotProductStatusEnum.PUBLISHED.getStatus())) {
-            // 3.1 创建产品超级表数据模型
+            // 创建产品超级表数据模型
             devicePropertyDataService.defineDevicePropertyData(id);
-
         }
+
+        // 3. 更新
+        IotProductDO updateObj = IotProductDO.builder().id(id).status(status).build();
         productMapper.updateById(updateObj);
     }
@@ -7,20 +7,20 @@ import cn.iocoder.yudao.framework.tenant.core.aop.TenantIgnore;
 import cn.iocoder.yudao.module.iot.controller.admin.device.vo.device.IotDeviceStatusUpdateReqVO;
 import cn.iocoder.yudao.module.iot.dal.dataobject.device.IotDeviceDO;
 import cn.iocoder.yudao.module.iot.dal.dataobject.device.IotDeviceDataDO;
-import cn.iocoder.yudao.module.iot.dal.dataobject.tdengine.*;
+import cn.iocoder.yudao.module.iot.dal.dataobject.tdengine.FieldParser;
+import cn.iocoder.yudao.module.iot.dal.dataobject.tdengine.TdFieldDO;
+import cn.iocoder.yudao.module.iot.dal.dataobject.tdengine.TdTableDO;
+import cn.iocoder.yudao.module.iot.dal.dataobject.tdengine.ThingModelMessage;
 import cn.iocoder.yudao.module.iot.dal.dataobject.thingmodel.IotThingModelDO;
-import cn.iocoder.yudao.module.iot.dal.dataobject.product.IotProductDO;
 import cn.iocoder.yudao.module.iot.dal.redis.deviceData.DeviceDataRedisDAO;
 import cn.iocoder.yudao.module.iot.dal.tdengine.TdEngineDDLMapper;
 import cn.iocoder.yudao.module.iot.dal.tdengine.TdEngineDMLMapper;
-import cn.iocoder.yudao.module.iot.dal.tdengine.TdThingModelMessageMapper;
 import cn.iocoder.yudao.module.iot.enums.IotConstants;
 import cn.iocoder.yudao.module.iot.enums.device.IotDeviceStatusEnum;
 import cn.iocoder.yudao.module.iot.enums.thingmodel.IotThingModelTypeEnum;
 import cn.iocoder.yudao.module.iot.service.device.IotDeviceService;
-import cn.iocoder.yudao.module.iot.service.thingmodel.IotThingModelService;
 import cn.iocoder.yudao.module.iot.service.product.IotProductService;
-import cn.iocoder.yudao.module.iot.util.IotTdDatabaseUtils;
+import cn.iocoder.yudao.module.iot.service.thingmodel.IotThingModelService;
 import jakarta.annotation.Resource;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Value;
@@ -62,12 +62,8 @@ public class IotThingModelMessageServiceImpl implements IotThingModelMessageServ
     private TdEngineDMLMapper tdEngineDMLMapper;
     @Resource
-    private TdThingModelMessageMapper tdThingModelMessageMapper;
-
-    @Resource
     private DeviceDataRedisDAO deviceDataRedisDAO;
-
-
+    
     // TODO @haohao：这个方法，可以考虑加下 1. 2. 3. 更有层次感
     @Override
     @TenantIgnore
@@ -7,19 +7,19 @@
     <!-- 创建设备日志超级表   初始化只创建一次-->
     <update id="createDeviceLogSTable">
         CREATE STABLE device_log (
-        ts TIMESTAMP,
-        id NCHAR(50),
-        product_key NCHAR(50),
-        type NCHAR(50),
-        subType NCHAR(50),
-        content NCHAR(1024),
-        report_time TIMESTAMP
-        )TAGS (
-        device_key NCHAR(50)
-        )
+            ts TIMESTAMP,
+            id NCHAR(50),
+            product_key NCHAR(50),
+            type NCHAR(50),
+            <!-- TODO @super：下划线 sub_type -->
+            subType NCHAR(50),
+            content NCHAR(1024),
+            report_time TIMESTAMP
+            ) TAGS (
+                device_key NCHAR(50)
+            )
     </update>
-
     <!-- 创建设备日志子表  讨论：TDengine 在子表不存在的情况下 可在数据插入时 自动建表  要不要去掉创建子表的逻辑  由第一次插入数据时自动创建-->
     <update id="createDeviceLogTable">
         CREATE TABLE device_log_${deviceKey} USING device_log TAGS('${deviceKey}')