reactor：【IoT 物联网】增加 IotDataRuleDO 的定义，对标阿里云 IoT 的「云产品流转」

YunaiV
1 parent 1ad4e08c
Showing 22 changed files with 223 additions and 77 deletions
yudao-module-iot/yudao-module-iot-biz/src/main/java/cn/iocoder/yudao/module/iot/controller/admin/rule/IotDataBridgeController.java
yudao-module-iot/yudao-module-iot-biz/src/main/java/cn/iocoder/yudao/module/iot/controller/admin/rule/vo/databridge/IotDataBridgeSaveReqVO.java
yudao-module-iot/yudao-module-iot-biz/src/main/java/cn/iocoder/yudao/module/iot/controller/admin/rule/vo/databridge/config/IotDataBridgeAbstractConfig.java
yudao-module-iot/yudao-module-iot-biz/src/main/java/cn/iocoder/yudao/module/iot/dal/dataobject/device/IotDeviceDO.java
yudao-module-iot/yudao-module-iot-biz/src/main/java/cn/iocoder/yudao/module/iot/dal/dataobject/rule/IotDataRuleDO.java
yudao-module-iot/yudao-module-iot-biz/src/main/java/cn/iocoder/yudao/module/iot/dal/dataobject/rule/IotDataRuleSourceDO.java
yudao-module-iot/yudao-module-iot-biz/src/main/java/cn/iocoder/yudao/module/iot/dal/dataobject/rule/IotRuleSceneDO.java
yudao-module-iot/yudao-module-iot-biz/src/main/java/cn/iocoder/yudao/module/iot/dal/mysql/rule/IotDataBridgeMapper.java
yudao-module-iot/yudao-module-iot-biz/src/main/java/cn/iocoder/yudao/module/iot/service/rule/IotDataBridgeService.java
yudao-module-iot/yudao-module-iot-biz/src/main/java/cn/iocoder/yudao/module/iot/service/rule/IotDataBridgeServiceImpl.java
yudao-module-iot/yudao-module-iot-biz/src/main/java/cn/iocoder/yudao/module/iot/service/rule/action/IotRuleSceneDataBridgeAction.java
yudao-module-iot/yudao-module-iot-biz/src/main/java/cn/iocoder/yudao/module/iot/service/rule/action/databridge/AbstractCacheableDataBridgeExecute.java
yudao-module-iot/yudao-module-iot-biz/src/main/java/cn/iocoder/yudao/module/iot/service/rule/action/databridge/IotDataBridgeExecute.java
yudao-module-iot/yudao-module-iot-biz/src/main/java/cn/iocoder/yudao/module/iot/service/rule/action/databridge/IotHttpDataBridgeExecute.java
yudao-module-iot/yudao-module-iot-biz/src/main/java/cn/iocoder/yudao/module/iot/service/rule/action/databridge/IotKafkaMQDataBridgeExecute.java
yudao-module-iot/yudao-module-iot-biz/src/main/java/cn/iocoder/yudao/module/iot/service/rule/action/databridge/IotRabbitMQDataBridgeExecute.java
yudao-module-iot/yudao-module-iot-biz/src/main/java/cn/iocoder/yudao/module/iot/service/rule/action/databridge/IotRedisStreamDataBridgeExecute.java
yudao-module-iot/yudao-module-iot-biz/src/main/java/cn/iocoder/yudao/module/iot/service/rule/action/databridge/IotRocketMQDataBridgeExecute.java
yudao-module-iot/yudao-module-iot-biz/src/test/java/cn/iocoder/yudao/module/iot/service/rule/action/databridge/IotDataBridgeExecuteTest.java
@@ -7,13 +7,13 @@ import lombok.RequiredArgsConstructor;
 import java.util.Arrays;
 /**
- * IoT 数据桥接的类型枚举
+ * IoT 数据流转的数据目的的类型枚举
  *
  * @author 芋道源码
  */
 @RequiredArgsConstructor
 @Getter
-public enum IotDataBridgeTypeEnum implements ArrayValuable<Integer> {
+public enum IotDataRuleSinkTypeEnum implements ArrayValuable<Integer> {
     HTTP(1, "HTTP"),
     TCP(2, "TCP"),
@@ -32,7 +32,7 @@ public enum IotDataBridgeTypeEnum implements ArrayValuable&lt;Integer&gt; {
     private final String name;
-    public static final Integer[] ARRAYS = Arrays.stream(values()).map(IotDataBridgeTypeEnum::getType).toArray(Integer[]::new);
+    public static final Integer[] ARRAYS = Arrays.stream(values()).map(IotDataRuleSinkTypeEnum::getType).toArray(Integer[]::new);
     @Override
     public Integer[] array() {
@@ -7,7 +7,7 @@ import cn.iocoder.yudao.framework.common.util.object.BeanUtils;
 import cn.iocoder.yudao.module.iot.controller.admin.rule.vo.databridge.IotDataBridgePageReqVO;
 import cn.iocoder.yudao.module.iot.controller.admin.rule.vo.databridge.IotDataBridgeRespVO;
 import cn.iocoder.yudao.module.iot.controller.admin.rule.vo.databridge.IotDataBridgeSaveReqVO;
-import cn.iocoder.yudao.module.iot.dal.dataobject.rule.IotDataBridgeDO;
+import cn.iocoder.yudao.module.iot.dal.dataobject.rule.IotDataRuleSinkDO;
 import cn.iocoder.yudao.module.iot.service.rule.IotDataBridgeService;
 import io.swagger.v3.oas.annotations.Operation;
 import io.swagger.v3.oas.annotations.Parameter;
@@ -61,7 +61,7 @@ public class IotDataBridgeController {
     @Parameter(name = "id", description = "编号", required = true, example = "1024")
     @PreAuthorize("@ss.hasPermission('iot:data-bridge:query')")
     public CommonResult<IotDataBridgeRespVO> getDataBridge(@RequestParam("id") Long id) {
-        IotDataBridgeDO dataBridge = dataBridgeService.getDataBridge(id);
+        IotDataRuleSinkDO dataBridge = dataBridgeService.getDataBridge(id);
         return success(BeanUtils.toBean(dataBridge, IotDataBridgeRespVO.class));
     }
@@ -69,14 +69,14 @@ public class IotDataBridgeController {
     @Operation(summary = "获得数据桥梁分页")
     @PreAuthorize("@ss.hasPermission('iot:data-bridge:query')")
     public CommonResult<PageResult<IotDataBridgeRespVO>> getDataBridgePage(@Valid IotDataBridgePageReqVO pageReqVO) {
-        PageResult<IotDataBridgeDO> pageResult = dataBridgeService.getDataBridgePage(pageReqVO);
+        PageResult<IotDataRuleSinkDO> pageResult = dataBridgeService.getDataBridgePage(pageReqVO);
         return success(BeanUtils.toBean(pageResult, IotDataBridgeRespVO.class));
     }
     @GetMapping("/simple-list")
     @Operation(summary = "获取数据桥梁的精简信息列表", description = "主要用于前端的下拉选项")
     public CommonResult<List<IotDataBridgeRespVO>> getSimpleDataBridgeList() {
-        List<IotDataBridgeDO> list = dataBridgeService.getDataBridgeList(CommonStatusEnum.ENABLE.getStatus());
+        List<IotDataRuleSinkDO> list = dataBridgeService.getDataBridgeList(CommonStatusEnum.ENABLE.getStatus());
         return success(convertList(list, dataBridge -> // 只返回 id、name 字段
                 new IotDataBridgeRespVO().setId(dataBridge.getId()).setName(dataBridge.getName())));
     }
@@ -4,7 +4,7 @@ import cn.iocoder.yudao.framework.common.enums.CommonStatusEnum;
 import cn.iocoder.yudao.framework.common.validation.InEnum;
 import cn.iocoder.yudao.module.iot.controller.admin.rule.vo.databridge.config.IotDataBridgeAbstractConfig;
 import cn.iocoder.yudao.module.iot.enums.rule.IotDataBridgeDirectionEnum;
-import cn.iocoder.yudao.module.iot.enums.rule.IotDataBridgeTypeEnum;
+import cn.iocoder.yudao.module.iot.enums.rule.IotDataRuleSinkTypeEnum;
 import io.swagger.v3.oas.annotations.media.Schema;
 import jakarta.validation.constraints.NotEmpty;
 import jakarta.validation.constraints.NotNull;
@@ -36,7 +36,7 @@ public class IotDataBridgeSaveReqVO {
     @Schema(description = "桥梁类型", requiredMode = Schema.RequiredMode.REQUIRED, example = "1")
     @NotNull(message = "桥梁类型不能为空")
-    @InEnum(IotDataBridgeTypeEnum.class)
+    @InEnum(IotDataRuleSinkTypeEnum.class)
     private Integer type;
     @Schema(description = "桥梁配置")
 package cn.iocoder.yudao.module.iot.controller.admin.rule.vo.databridge.config;
-import cn.iocoder.yudao.module.iot.enums.rule.IotDataBridgeTypeEnum;
+import cn.iocoder.yudao.module.iot.enums.rule.IotDataRuleSinkTypeEnum;
 import com.fasterxml.jackson.annotation.JsonSubTypes;
 import com.fasterxml.jackson.annotation.JsonTypeInfo;
 import lombok.Data;
@@ -28,7 +28,7 @@ public abstract class IotDataBridgeAbstractConfig {
     /**
      * 配置类型
      *
-     * 枚举 {@link IotDataBridgeTypeEnum#getType()}
+     * 枚举 {@link IotDataRuleSinkTypeEnum#getType()}
      */
     private String type;
@@ -29,6 +29,11 @@ import java.util.Set;
 public class IotDeviceDO extends TenantBaseDO {
     /**
+     * 设备编号 - 全部设备
+     */
+    public static final Long DEVICE_ID_ALL = 0L;
+
+    /**
      * 设备 ID，主键，自增
      */
     @TableId
+package cn.iocoder.yudao.module.iot.dal.dataobject.rule;
+
+import cn.iocoder.yudao.framework.common.enums.CommonStatusEnum;
+import com.baomidou.mybatisplus.annotation.KeySequence;
+import com.baomidou.mybatisplus.annotation.TableName;
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+import java.util.List;
+
+/**
+ * IoT 数据流转 DO
+ *
+ * 组合 {@link IotDataRuleSourceDO} => {@link IotDataRuleSinkDO}
+ *
+ * @author 芋道源码
+ */
+@TableName(value = "iot_data_flow", autoResultMap = true)
+@KeySequence("iot_data_flow_seq") // 用于 Oracle、PostgreSQL、Kingbase、DB2、H2 数据库的主键自增。如果是 MySQL 等数据库，可不写。
+@Data
+@Builder
+@NoArgsConstructor
+@AllArgsConstructor
+public class IotDataRuleDO {
+
+    /**
+     * 数据流转编号
+     */
+    private Long id;
+    /**
+     * 数据流转名称
+     */
+    private String name;
+    /**
+     * 数据流转描述
+     */
+    private String description;
+    /**
+     * 数据流转状态
+     *
+     * 枚举 {@link CommonStatusEnum}
+     */
+    private Integer status;
+
+    /**
+     * 数据源编号
+     *
+     * 关联 {@link IotDataRuleSourceDO#getId()}
+     */
+    private List<Long> sourceIds;
+    /**
+     * 数据目的编号
+     *
+     * 关联 {@link IotDataRuleSinkDO#getId()}
+     */
+    private List<Long> sinkIds;
+
+    // TODO @芋艿：未来考虑使用 groovy；支持数据处理；
+
+}
@@ -4,7 +4,7 @@ import cn.iocoder.yudao.framework.common.enums.CommonStatusEnum;
 import cn.iocoder.yudao.framework.mybatis.core.dataobject.BaseDO;
 import cn.iocoder.yudao.module.iot.controller.admin.rule.vo.databridge.config.IotDataBridgeAbstractConfig;
 import cn.iocoder.yudao.module.iot.enums.rule.IotDataBridgeDirectionEnum;
-import cn.iocoder.yudao.module.iot.enums.rule.IotDataBridgeTypeEnum;
+import cn.iocoder.yudao.module.iot.enums.rule.IotDataRuleSinkTypeEnum;
 import com.baomidou.mybatisplus.annotation.KeySequence;
 import com.baomidou.mybatisplus.annotation.TableField;
 import com.baomidou.mybatisplus.annotation.TableId;
@@ -13,7 +13,7 @@ import com.baomidou.mybatisplus.extension.handlers.JacksonTypeHandler;
 import lombok.*;
 /**
- * IoT 数据桥梁 DO
+ * IoT 数据流转的数据目的 DO
  *
  * @author 芋道源码
  */
@@ -23,19 +23,19 @@ import lombok.*;
 @Builder
 @NoArgsConstructor
 @AllArgsConstructor
-public class IotDataBridgeDO extends BaseDO {
+public class IotDataRuleSinkDO extends BaseDO {
     /**
-     * 桥梁编号
+     * 数据目的编号
      */
     @TableId
     private Long id;
     /**
-     * 桥梁名称
+     * 数据目的名称
      */
     private String name;
     /**
-     * 桥梁描述
+     * 数据目的描述
      */
     private String description;
     /**
@@ -43,23 +43,25 @@ public class IotDataBridgeDO extends BaseDO {
      *
      * 枚举 {@link CommonStatusEnum}
      */
+    @Deprecated // TODO @puhui999：这个删除
     private Integer status;
     /**
      * 桥梁方向
      *
      * 枚举 {@link IotDataBridgeDirectionEnum}
      */
+    @Deprecated // TODO @puhui999：这个删除
     private Integer direction;
     /**
-     * 桥梁类型
+     * 数据目的类型
      *
-     * 枚举 {@link IotDataBridgeTypeEnum}
+     * 枚举 {@link IotDataRuleSinkTypeEnum}
      */
     private Integer type;
     /**
-     * 桥梁配置
+     * 数据目的配置
      */
     @TableField(typeHandler = JacksonTypeHandler.class)
     private IotDataBridgeAbstractConfig config;
+package cn.iocoder.yudao.module.iot.dal.dataobject.rule;
+
+import cn.iocoder.yudao.module.iot.core.enums.IotDeviceMessageMethodEnum;
+import cn.iocoder.yudao.module.iot.dal.dataobject.device.IotDeviceDO;
+import cn.iocoder.yudao.module.iot.dal.dataobject.product.IotProductDO;
+import cn.iocoder.yudao.module.iot.dal.dataobject.thingmodel.IotThingModelDO;
+import com.baomidou.mybatisplus.annotation.KeySequence;
+import com.baomidou.mybatisplus.annotation.TableName;
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+import java.util.List;
+
+/**
+ * IoT 数据流转的数据源 DO
+ *
+ * @author 芋道源码
+ */
+@TableName(value = "iot_data_flow_source", autoResultMap = true)
+@KeySequence("iot_data_flow_source_seq") // 用于 Oracle、PostgreSQL、Kingbase、DB2、H2 数据库的主键自增。如果是 MySQL 等数据库，可不写。
+@Data
+@Builder
+@NoArgsConstructor
+@AllArgsConstructor
+public class IotDataRuleSourceDO {
+
+    /**
+     * 数据源编号
+     */
+    private Long id;
+    /**
+     * 数据源名称
+     */
+    private String name;
+
+    /**
+     * 配置数组
+     */
+    private List<Config> configs;
+
+    /**
+     * 配置
+     */
+    @Data
+    public static class Config {
+
+        /**
+         * 消息方法
+         *
+         * 枚举 {@link IotDeviceMessageMethodEnum} 中的 upstream 上行部分
+         */
+        private String method;
+
+        /**
+         * 产品编号
+         *
+         * 关联 {@link IotProductDO#getId()}
+         */
+        private Long productId;
+        /**
+         * 设备编号
+         *
+         * 关联 {@link IotDeviceDO#getId()}
+         * 特殊：如果为 {@link IotDeviceDO#DEVICE_ID_ALL} 时，则是全部设备
+         */
+        private Long deviceId;
+
+        /**
+         * 标识符
+         *
+         * 1. 物模型时，对应：{@link IotThingModelDO#getIdentifier()}
+         */
+        private String identifier;
+
+    }
+
+}
@@ -201,7 +201,7 @@ public class IotRuleSceneDO extends TenantBaseDO {
          * 数据桥接编号
          *
          * 必填：当 {@link #type} 为 {@link IotRuleSceneActionTypeEnum#DATA_BRIDGE} 时
-         * 关联：{@link IotDataBridgeDO#getId()}
+         * 关联：{@link IotDataRuleSinkDO#getId()}
          */
         private Long dataBridgeId;
 package cn.iocoder.yudao.module.iot.dal.dataobject.rule;
+import cn.iocoder.yudao.framework.common.enums.CommonStatusEnum;
 import cn.iocoder.yudao.framework.tenant.core.db.TenantBaseDO;
 import cn.iocoder.yudao.module.iot.core.mq.message.IotDeviceMessage;
 import cn.iocoder.yudao.module.iot.dal.dataobject.device.IotDeviceDO;
@@ -25,38 +26,35 @@ import java.util.List;
 /**
  * IoT 场景联动 DO
  *
+ * 基于 {@link Trigger} 触发 {@link Action}
+ *
  * @author 芋道源码
  */
-@TableName(value = "iot_rule_scene2", autoResultMap = true)
-@KeySequence("iot_rule_scene_seq") // 用于 Oracle、PostgreSQL、Kingbase、DB2、H2 数据库的主键自增。如果是 MySQL 等数据库，可不写。
+@TableName(value = "iot_scene_rule", autoResultMap = true)
+@KeySequence("iot_scene_rule_seq") // 用于 Oracle、PostgreSQL、Kingbase、DB2、H2 数据库的主键自增。如果是 MySQL 等数据库，可不写。
 @Data
 @Builder
 @NoArgsConstructor
 @AllArgsConstructor
-public class IotRuleScene2DO extends TenantBaseDO {
-
-    /**
-     * 设备编号 - 全部设备
-     */
-    public static final Long DEVICE_ID_ALL = 0L;
+public class IotSceneRuleDO extends TenantBaseDO {
     /**
-     * 场景编号
+     * 场景联动编号
      */
     @TableId
     private Long id;
     /**
-     * 场景名称
+     * 场景联动名称
      */
     private String name;
     /**
-     * 场景描述
+     * 场景联动描述
      */
     private String description;
     /**
-     * 场景状态
+     * 场景联动状态
      *
-     * 枚举 {@link cn.iocoder.yudao.framework.common.enums.CommonStatusEnum}
+     * 枚举 {@link CommonStatusEnum}
      */
     private Integer status;
@@ -103,7 +101,7 @@ public class IotRuleScene2DO extends TenantBaseDO {
          * 设备编号
          *
          * 关联 {@link IotDeviceDO#getId()}
-         * 特殊：如果为 0，则是全部
+         * 特殊：如果为 {@link IotDeviceDO#DEVICE_ID_ALL} 时，则是全部设备
          */
         private Long deviceId;
         /**
@@ -4,7 +4,7 @@ import cn.iocoder.yudao.framework.common.pojo.PageResult;
 import cn.iocoder.yudao.framework.mybatis.core.mapper.BaseMapperX;
 import cn.iocoder.yudao.framework.mybatis.core.query.LambdaQueryWrapperX;
 import cn.iocoder.yudao.module.iot.controller.admin.rule.vo.databridge.IotDataBridgePageReqVO;
-import cn.iocoder.yudao.module.iot.dal.dataobject.rule.IotDataBridgeDO;
+import cn.iocoder.yudao.module.iot.dal.dataobject.rule.IotDataRuleSinkDO;
 import org.apache.ibatis.annotations.Mapper;
 import java.util.List;
@@ -15,20 +15,20 @@ import java.util.List;
  * @author HUIHUI
  */
 @Mapper
-public interface IotDataBridgeMapper extends BaseMapperX<IotDataBridgeDO> {
+public interface IotDataBridgeMapper extends BaseMapperX<IotDataRuleSinkDO> {
-    default PageResult<IotDataBridgeDO> selectPage(IotDataBridgePageReqVO reqVO) {
-        return selectPage(reqVO, new LambdaQueryWrapperX<IotDataBridgeDO>()
-                .likeIfPresent(IotDataBridgeDO::getName, reqVO.getName())
-                .eqIfPresent(IotDataBridgeDO::getStatus, reqVO.getStatus())
-                .betweenIfPresent(IotDataBridgeDO::getCreateTime, reqVO.getCreateTime())
-                .orderByDesc(IotDataBridgeDO::getId));
+    default PageResult<IotDataRuleSinkDO> selectPage(IotDataBridgePageReqVO reqVO) {
+        return selectPage(reqVO, new LambdaQueryWrapperX<IotDataRuleSinkDO>()
+                .likeIfPresent(IotDataRuleSinkDO::getName, reqVO.getName())
+                .eqIfPresent(IotDataRuleSinkDO::getStatus, reqVO.getStatus())
+                .betweenIfPresent(IotDataRuleSinkDO::getCreateTime, reqVO.getCreateTime())
+                .orderByDesc(IotDataRuleSinkDO::getId));
     }
-    default List<IotDataBridgeDO> selectList(Integer status) {
-        return selectList(new LambdaQueryWrapperX<IotDataBridgeDO>()
-                .eqIfPresent(IotDataBridgeDO::getStatus, status)
-                .orderByDesc(IotDataBridgeDO::getId));
+    default List<IotDataRuleSinkDO> selectList(Integer status) {
+        return selectList(new LambdaQueryWrapperX<IotDataRuleSinkDO>()
+                .eqIfPresent(IotDataRuleSinkDO::getStatus, status)
+                .orderByDesc(IotDataRuleSinkDO::getId));
     }
 }
 \ No newline at end of file
@@ -3,7 +3,7 @@ package cn.iocoder.yudao.module.iot.service.rule;
 import cn.iocoder.yudao.framework.common.pojo.PageResult;
 import cn.iocoder.yudao.module.iot.controller.admin.rule.vo.databridge.IotDataBridgePageReqVO;
 import cn.iocoder.yudao.module.iot.controller.admin.rule.vo.databridge.IotDataBridgeSaveReqVO;
-import cn.iocoder.yudao.module.iot.dal.dataobject.rule.IotDataBridgeDO;
+import cn.iocoder.yudao.module.iot.dal.dataobject.rule.IotDataRuleSinkDO;
 import jakarta.validation.Valid;
 import java.util.List;
@@ -43,7 +43,7 @@ public interface IotDataBridgeService {
      * @param id 编号
      * @return 数据桥梁
      */
-    IotDataBridgeDO getDataBridge(Long id);
+    IotDataRuleSinkDO getDataBridge(Long id);
     /**
      * 获得数据桥梁分页
@@ -51,7 +51,7 @@ public interface IotDataBridgeService {
      * @param pageReqVO 分页查询
      * @return 数据桥梁分页
      */
-    PageResult<IotDataBridgeDO> getDataBridgePage(IotDataBridgePageReqVO pageReqVO);
+    PageResult<IotDataRuleSinkDO> getDataBridgePage(IotDataBridgePageReqVO pageReqVO);
     /**
      * 获取数据桥梁列表
@@ -59,6 +59,6 @@ public interface IotDataBridgeService {
      * @param status 状态，如果为空，则不进行筛选
      * @return 数据桥梁列表
      */
-    List<IotDataBridgeDO> getDataBridgeList(Integer status);
+    List<IotDataRuleSinkDO> getDataBridgeList(Integer status);
 }
@@ -4,7 +4,7 @@ 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.rule.vo.databridge.IotDataBridgePageReqVO;
 import cn.iocoder.yudao.module.iot.controller.admin.rule.vo.databridge.IotDataBridgeSaveReqVO;
-import cn.iocoder.yudao.module.iot.dal.dataobject.rule.IotDataBridgeDO;
+import cn.iocoder.yudao.module.iot.dal.dataobject.rule.IotDataRuleSinkDO;
 import cn.iocoder.yudao.module.iot.dal.mysql.rule.IotDataBridgeMapper;
 import jakarta.annotation.Resource;
 import org.springframework.stereotype.Service;
@@ -30,7 +30,7 @@ public class IotDataBridgeServiceImpl implements IotDataBridgeService {
     @Override
     public Long createDataBridge(IotDataBridgeSaveReqVO createReqVO) {
         // 插入
-        IotDataBridgeDO dataBridge = BeanUtils.toBean(createReqVO, IotDataBridgeDO.class);
+        IotDataRuleSinkDO dataBridge = BeanUtils.toBean(createReqVO, IotDataRuleSinkDO.class);
         dataBridgeMapper.insert(dataBridge);
         // 返回
         return dataBridge.getId();
@@ -41,7 +41,7 @@ public class IotDataBridgeServiceImpl implements IotDataBridgeService {
         // 校验存在
         validateDataBridgeExists(updateReqVO.getId());
         // 更新
-        IotDataBridgeDO updateObj = BeanUtils.toBean(updateReqVO, IotDataBridgeDO.class);
+        IotDataRuleSinkDO updateObj = BeanUtils.toBean(updateReqVO, IotDataRuleSinkDO.class);
         dataBridgeMapper.updateById(updateObj);
     }
@@ -60,17 +60,17 @@ public class IotDataBridgeServiceImpl implements IotDataBridgeService {
     }
     @Override
-    public IotDataBridgeDO getDataBridge(Long id) {
+    public IotDataRuleSinkDO getDataBridge(Long id) {
         return dataBridgeMapper.selectById(id);
     }
     @Override
-    public PageResult<IotDataBridgeDO> getDataBridgePage(IotDataBridgePageReqVO pageReqVO) {
+    public PageResult<IotDataRuleSinkDO> getDataBridgePage(IotDataBridgePageReqVO pageReqVO) {
         return dataBridgeMapper.selectPage(pageReqVO);
     }
     @Override
-    public List<IotDataBridgeDO> getDataBridgeList(Integer status) {
+    public List<IotDataRuleSinkDO> getDataBridgeList(Integer status) {
         return dataBridgeMapper.selectList(status);
     }
@@ -3,7 +3,7 @@ package cn.iocoder.yudao.module.iot.service.rule.action;
 import cn.hutool.core.lang.Assert;
 import cn.iocoder.yudao.framework.common.enums.CommonStatusEnum;
 import cn.iocoder.yudao.module.iot.core.mq.message.IotDeviceMessage;
-import cn.iocoder.yudao.module.iot.dal.dataobject.rule.IotDataBridgeDO;
+import cn.iocoder.yudao.module.iot.dal.dataobject.rule.IotDataRuleSinkDO;
 import cn.iocoder.yudao.module.iot.dal.dataobject.rule.IotRuleSceneDO;
 import cn.iocoder.yudao.module.iot.enums.rule.IotRuleSceneActionTypeEnum;
 import cn.iocoder.yudao.module.iot.service.rule.IotDataBridgeService;
@@ -36,7 +36,7 @@ public class IotRuleSceneDataBridgeAction implements IotRuleSceneAction {
         }
         // 1.2 获得数据桥梁
         Assert.notNull(config.getDataBridgeId(), "数据桥梁编号不能为空");
-        IotDataBridgeDO dataBridge = dataBridgeService.getDataBridge(config.getDataBridgeId());
+        IotDataRuleSinkDO dataBridge = dataBridgeService.getDataBridge(config.getDataBridgeId());
         if (dataBridge == null || dataBridge.getConfig() == null) {
             log.error("[execute][message({}) config({}) 对应的数据桥梁不存在]", message, config);
             return;
@@ -2,7 +2,7 @@ package cn.iocoder.yudao.module.iot.service.rule.action.databridge;
 import cn.hutool.core.util.ObjUtil;
 import cn.iocoder.yudao.module.iot.core.mq.message.IotDeviceMessage;
-import cn.iocoder.yudao.module.iot.dal.dataobject.rule.IotDataBridgeDO;
+import cn.iocoder.yudao.module.iot.dal.dataobject.rule.IotDataRuleSinkDO;
 import com.google.common.cache.CacheBuilder;
 import com.google.common.cache.CacheLoader;
 import com.google.common.cache.LoadingCache;
@@ -100,7 +100,7 @@ public abstract class AbstractCacheableDataBridgeExecute&lt;Config, Producer&gt; imple
     @Override
     @SuppressWarnings({"unchecked"})
-    public void execute(IotDeviceMessage message, IotDataBridgeDO dataBridge) {
+    public void execute(IotDeviceMessage message, IotDataRuleSinkDO dataBridge) {
         if (ObjUtil.notEqual(dataBridge.getType(), getType())) {
             return;
         }
 package cn.iocoder.yudao.module.iot.service.rule.action.databridge;
 import cn.iocoder.yudao.module.iot.core.mq.message.IotDeviceMessage;
-import cn.iocoder.yudao.module.iot.dal.dataobject.rule.IotDataBridgeDO;
+import cn.iocoder.yudao.module.iot.dal.dataobject.rule.IotDataRuleSinkDO;
 /**
  * IoT 数据桥梁的执行器 execute 接口
@@ -24,7 +24,7 @@ public interface IotDataBridgeExecute&lt;Config&gt; {
      * @param dataBridge 数据桥梁
      */
     @SuppressWarnings({"unchecked"})
-    default void execute(IotDeviceMessage message, IotDataBridgeDO dataBridge) throws Exception {
+    default void execute(IotDeviceMessage message, IotDataRuleSinkDO dataBridge) throws Exception {
         // 1.1 校验数据桥梁类型
         if (!getType().equals(dataBridge.getType())) {
             return;
@@ -5,7 +5,7 @@ import cn.iocoder.yudao.framework.common.util.http.HttpUtils;
 import cn.iocoder.yudao.framework.common.util.json.JsonUtils;
 import cn.iocoder.yudao.module.iot.controller.admin.rule.vo.databridge.config.IotDataBridgeHttpConfig;
 import cn.iocoder.yudao.module.iot.core.mq.message.IotDeviceMessage;
-import cn.iocoder.yudao.module.iot.enums.rule.IotDataBridgeTypeEnum;
+import cn.iocoder.yudao.module.iot.enums.rule.IotDataRuleSinkTypeEnum;
 import jakarta.annotation.Resource;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.http.*;
@@ -30,7 +30,7 @@ public class IotHttpDataBridgeExecute implements IotDataBridgeExecute&lt;IotDataBri
     @Override
     public Integer getType() {
-        return IotDataBridgeTypeEnum.HTTP.getType();
+        return IotDataRuleSinkTypeEnum.HTTP.getType();
     }
     @Override
@@ -2,7 +2,7 @@ package cn.iocoder.yudao.module.iot.service.rule.action.databridge;
 import cn.iocoder.yudao.module.iot.controller.admin.rule.vo.databridge.config.IotDataBridgeKafkaMQConfig;
 import cn.iocoder.yudao.module.iot.core.mq.message.IotDeviceMessage;
-import cn.iocoder.yudao.module.iot.enums.rule.IotDataBridgeTypeEnum;
+import cn.iocoder.yudao.module.iot.enums.rule.IotDataRuleSinkTypeEnum;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.kafka.clients.producer.ProducerConfig;
 import org.apache.kafka.common.serialization.StringSerializer;
@@ -31,7 +31,7 @@ public class IotKafkaMQDataBridgeExecute extends
     @Override
     public Integer getType() {
-        return IotDataBridgeTypeEnum.KAFKA.getType();
+        return IotDataRuleSinkTypeEnum.KAFKA.getType();
     }
     @Override
@@ -2,7 +2,7 @@ package cn.iocoder.yudao.module.iot.service.rule.action.databridge;
 import cn.iocoder.yudao.module.iot.controller.admin.rule.vo.databridge.config.IotDataBridgeRabbitMQConfig;
 import cn.iocoder.yudao.module.iot.core.mq.message.IotDeviceMessage;
-import cn.iocoder.yudao.module.iot.enums.rule.IotDataBridgeTypeEnum;
+import cn.iocoder.yudao.module.iot.enums.rule.IotDataRuleSinkTypeEnum;
 import com.rabbitmq.client.Channel;
 import com.rabbitmq.client.Connection;
 import com.rabbitmq.client.ConnectionFactory;
@@ -26,7 +26,7 @@ public class IotRabbitMQDataBridgeExecute extends
     @Override
     public Integer getType() {
-        return IotDataBridgeTypeEnum.RABBITMQ.getType();
+        return IotDataRuleSinkTypeEnum.RABBITMQ.getType();
     }
     @Override
@@ -3,7 +3,7 @@ package cn.iocoder.yudao.module.iot.service.rule.action.databridge;
 import cn.hutool.core.util.StrUtil;
 import cn.iocoder.yudao.module.iot.controller.admin.rule.vo.databridge.config.IotDataBridgeRedisStreamConfig;
 import cn.iocoder.yudao.module.iot.core.mq.message.IotDeviceMessage;
-import cn.iocoder.yudao.module.iot.enums.rule.IotDataBridgeTypeEnum;
+import cn.iocoder.yudao.module.iot.enums.rule.IotDataRuleSinkTypeEnum;
 import lombok.extern.slf4j.Slf4j;
 import org.redisson.Redisson;
 import org.redisson.api.RedissonClient;
@@ -29,7 +29,7 @@ public class IotRedisStreamDataBridgeExecute extends
     @Override
     public Integer getType() {
-        return IotDataBridgeTypeEnum.REDIS_STREAM.getType();
+        return IotDataRuleSinkTypeEnum.REDIS_STREAM.getType();
     }
     @Override
@@ -2,7 +2,7 @@ package cn.iocoder.yudao.module.iot.service.rule.action.databridge;
 import cn.iocoder.yudao.module.iot.controller.admin.rule.vo.databridge.config.IotDataBridgeRocketMQConfig;
 import cn.iocoder.yudao.module.iot.core.mq.message.IotDeviceMessage;
-import cn.iocoder.yudao.module.iot.enums.rule.IotDataBridgeTypeEnum;
+import cn.iocoder.yudao.module.iot.enums.rule.IotDataRuleSinkTypeEnum;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.rocketmq.client.producer.DefaultMQProducer;
 import org.apache.rocketmq.client.producer.SendResult;
@@ -25,7 +25,7 @@ public class IotRocketMQDataBridgeExecute extends
     @Override
     public Integer getType() {
-        return IotDataBridgeTypeEnum.ROCKETMQ.getType();
+        return IotDataRuleSinkTypeEnum.ROCKETMQ.getType();
     }
     @Override
@@ -3,7 +3,7 @@ package cn.iocoder.yudao.module.iot.service.rule.action.databridge;
 import cn.iocoder.yudao.framework.test.core.ut.BaseMockitoUnitTest;
 import cn.iocoder.yudao.module.iot.controller.admin.rule.vo.databridge.config.*;
 import cn.iocoder.yudao.module.iot.core.mq.message.IotDeviceMessage;
-import cn.iocoder.yudao.module.iot.dal.dataobject.rule.IotDataBridgeDO;
+import cn.iocoder.yudao.module.iot.dal.dataobject.rule.IotDataRuleSinkDO;
 import lombok.extern.slf4j.Slf4j;
 import org.junit.jupiter.api.BeforeEach;
 import org.junit.jupiter.api.Disabled;
@@ -129,7 +129,7 @@ public class IotDataBridgeExecuteTest extends BaseMockitoUnitTest {
         // 3. 执行测试
         log.info("[testHttpDataBridge][执行HTTP数据桥接测试]");
-        httpDataBridgeExecute.execute(message, new IotDataBridgeDO()
+        httpDataBridgeExecute.execute(message, new IotDataRuleSinkDO()
                 .setType(httpDataBridgeExecute.getType()).setConfig(config));
     }
@@ -144,10 +144,10 @@ public class IotDataBridgeExecuteTest extends BaseMockitoUnitTest {
     private void executeAndVerifyCache(IotDataBridgeExecute<?> action, IotDataBridgeAbstractConfig config, String type)
             throws Exception {
         log.info("[test{}DataBridge][第一次执行，应该会创建新的 producer]", type);
-        action.execute(message, new IotDataBridgeDO().setType(action.getType()).setConfig(config));
+        action.execute(message, new IotDataRuleSinkDO().setType(action.getType()).setConfig(config));
         log.info("[test{}DataBridge][第二次执行，应该会复用缓存的 producer]", type);
-        action.execute(message, new IotDataBridgeDO().setType(action.getType()).setConfig(config));
+        action.execute(message, new IotDataRuleSinkDO().setType(action.getType()).setConfig(config));
     }
 }