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.alert.IotAlertConfigDO;
|
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 cn.iocoder.yudao.module.iot.enums.rule.IotSceneRuleActionTypeEnum;
|
import cn.iocoder.yudao.module.iot.enums.rule.IotSceneRuleConditionOperatorEnum;
|
import cn.iocoder.yudao.module.iot.enums.rule.IotSceneRuleConditionTypeEnum;
|
import cn.iocoder.yudao.module.iot.enums.rule.IotSceneRuleTriggerTypeEnum;
|
import com.baomidou.mybatisplus.annotation.KeySequence;
|
import com.baomidou.mybatisplus.annotation.TableField;
|
import com.baomidou.mybatisplus.annotation.TableId;
|
import com.baomidou.mybatisplus.annotation.TableName;
|
import com.baomidou.mybatisplus.extension.handlers.Jackson3TypeHandler;
|
import lombok.AllArgsConstructor;
|
import lombok.Builder;
|
import lombok.Data;
|
import lombok.NoArgsConstructor;
|
|
import java.time.LocalDateTime;
|
import java.util.List;
|
|
/**
|
* IoT 场景联动规则 DO
|
*
|
* @author 芋道源码
|
*/
|
@TableName(value = "iot_scene_rule", autoResultMap = true)
|
@KeySequence("iot_scene_rule_seq") // 用于 Oracle、PostgreSQL、Kingbase、DB2、H2 数据库的主键自增。如果是 MySQL 等数据库，可不写。
|
@Data
|
@Builder
|
@NoArgsConstructor
|
@AllArgsConstructor
|
public class IotSceneRuleDO extends TenantBaseDO {
|
|
/**
|
* 场景联动编号
|
*/
|
@TableId
|
private Long id;
|
/**
|
* 场景联动名称
|
*/
|
private String name;
|
/**
|
* 场景联动描述
|
*/
|
private String description;
|
/**
|
* 场景联动状态
|
*
|
* 枚举 {@link CommonStatusEnum}
|
*/
|
private Integer status;
|
|
/**
|
* 最后触发时间
|
*/
|
private LocalDateTime lastTriggerTime;
|
|
/**
|
* 场景定义配置
|
*/
|
@TableField(typeHandler = Jackson3TypeHandler.class)
|
private List<Trigger> triggers;
|
|
/**
|
* 场景动作配置
|
*/
|
@TableField(typeHandler = Jackson3TypeHandler.class)
|
private List<Action> actions;
|
|
/**
|
* 场景定义配置
|
*/
|
@Data
|
public static class Trigger {
|
|
// ========== 事件部分 ==========
|
|
/**
|
* 场景事件类型
|
*
|
* 枚举 {@link IotSceneRuleTriggerTypeEnum}
|
* 1. {@link IotSceneRuleTriggerTypeEnum#DEVICE_STATE_UPDATE} 时，operator 非空，并且 value 为在线状态
|
* 2. {@link IotSceneRuleTriggerTypeEnum#DEVICE_PROPERTY_POST}
|
* {@link IotSceneRuleTriggerTypeEnum#DEVICE_EVENT_POST} 时，identifier、operator 非空，并且 value 为属性值
|
* 3. {@link IotSceneRuleTriggerTypeEnum#DEVICE_EVENT_POST}
|
* {@link IotSceneRuleTriggerTypeEnum#DEVICE_SERVICE_INVOKE} 时，identifier 非空，但是 operator、value 为空
|
* 4. {@link IotSceneRuleTriggerTypeEnum#TIMER} 时，conditions 非空，并且设备无关（无需 productId、deviceId 字段）
|
*/
|
private Integer type;
|
|
/**
|
* 产品编号
|
*
|
* 关联 {@link IotProductDO#getId()}
|
*/
|
private Long productId;
|
/**
|
* 设备编号
|
*
|
* 关联 {@link IotDeviceDO#getId()}
|
* 特殊：如果为 {@link IotDeviceDO#DEVICE_ID_ALL} 时，则是全部设备
|
*/
|
private Long deviceId;
|
/**
|
* 物模型标识符
|
*
|
* 对应：{@link IotThingModelDO#getIdentifier()}
|
*/
|
private String identifier;
|
/**
|
* 操作符
|
*
|
* 枚举 {@link IotSceneRuleConditionOperatorEnum}
|
*/
|
private String operator;
|
/**
|
* 参数（属性值、在线状态）
|
* <p>
|
* 如果有多个值，则使用 "," 分隔，类似 "1,2,3"。
|
* 例如说，{@link IotSceneRuleConditionOperatorEnum#IN}、{@link IotSceneRuleConditionOperatorEnum#BETWEEN}
|
*/
|
private String value;
|
|
/**
|
* CRON 表达式
|
*/
|
private String cronExpression;
|
|
// ========== 条件部分 ==========
|
|
/**
|
* 触发条件分组（状态条件分组）的数组
|
* <p>
|
* 第一层 List：分组与分组之间，是“或”的关系
|
* 第二层 List：条件与条件之间，是“且”的关系
|
*/
|
private List<List<TriggerCondition>> conditionGroups;
|
|
}
|
|
/**
|
* 触发条件（状态条件）
|
*/
|
@Data
|
public static class TriggerCondition {
|
|
/**
|
* 触发条件类型
|
*
|
* 枚举 {@link IotSceneRuleConditionTypeEnum}
|
* 1. {@link IotSceneRuleConditionTypeEnum#DEVICE_STATE} 时，operator 非空，并且 value 为在线状态
|
* 2. {@link IotSceneRuleConditionTypeEnum#DEVICE_PROPERTY} 时，identifier、operator 非空，并且 value 为属性值
|
* 3. {@link IotSceneRuleConditionTypeEnum#CURRENT_TIME} 时，operator 非空（使用 DATE_TIME_ 和 TIME_ 部分），并且 value 非空
|
*/
|
private Integer type;
|
|
/**
|
* 产品编号
|
*
|
* 关联 {@link IotProductDO#getId()}
|
*/
|
private Long productId;
|
/**
|
* 设备编号
|
*
|
* 关联 {@link IotDeviceDO#getId()}
|
*/
|
private Long deviceId;
|
/**
|
* 标识符（属性）
|
*
|
* 关联 {@link IotThingModelDO#getIdentifier()}
|
*/
|
private String identifier;
|
/**
|
* 操作符
|
*
|
* 枚举 {@link IotSceneRuleConditionOperatorEnum}
|
*/
|
private String operator;
|
/**
|
* 参数
|
*
|
* 如果有多个值，则使用 "," 分隔，类似 "1,2,3"。
|
* 例如说，{@link IotSceneRuleConditionOperatorEnum#IN}、{@link IotSceneRuleConditionOperatorEnum#BETWEEN}
|
*/
|
private String param;
|
|
}
|
|
/**
|
* 场景动作配置
|
*/
|
@Data
|
public static class Action {
|
|
/**
|
* 执行类型
|
*
|
* 枚举 {@link IotSceneRuleActionTypeEnum}
|
* 1. {@link IotSceneRuleActionTypeEnum#DEVICE_PROPERTY_SET} 时，params 非空
|
* {@link IotSceneRuleActionTypeEnum#DEVICE_SERVICE_INVOKE} 时，params 非空
|
* 2. {@link IotSceneRuleActionTypeEnum#ALERT_TRIGGER} 时，alertConfigId 为空，因为是 {@link IotAlertConfigDO} 里面关联它
|
* 3. {@link IotSceneRuleActionTypeEnum#ALERT_RECOVER} 时，alertConfigId 非空
|
*/
|
private Integer type;
|
|
/**
|
* 产品编号
|
*
|
* 关联 {@link IotProductDO#getId()}
|
*/
|
private Long productId;
|
/**
|
* 设备编号
|
*
|
* 关联 {@link IotDeviceDO#getId()}
|
*/
|
private Long deviceId;
|
|
/**
|
* 标识符（服务）
|
* <p>
|
* 关联 {@link IotThingModelDO#getIdentifier()}
|
*/
|
private String identifier;
|
|
/**
|
* 请求参数
|
*
|
* 一般来说，对应 {@link IotDeviceMessage#getParams()} 请求参数
|
*/
|
private String params;
|
|
/**
|
* 告警配置编号
|
*
|
* 关联 {@link IotAlertConfigDO#getId()}
|
*/
|
private Long alertConfigId;
|
|
}
|
|
}
|
