package cn.iocoder.yudao.module.iot.service.rule.scene.matcher.condition;
|
|
import cn.iocoder.yudao.module.iot.core.mq.message.IotDeviceMessage;
|
import cn.iocoder.yudao.module.iot.dal.dataobject.rule.IotSceneRuleDO;
|
import cn.iocoder.yudao.module.iot.enums.rule.IotSceneRuleConditionOperatorEnum;
|
import cn.iocoder.yudao.module.iot.enums.rule.IotSceneRuleConditionTypeEnum;
|
import cn.iocoder.yudao.module.iot.service.rule.scene.matcher.IotBaseConditionMatcherTest;
|
import org.junit.jupiter.api.BeforeEach;
|
import org.junit.jupiter.api.Test;
|
|
import java.util.HashMap;
|
import java.util.Map;
|
|
import static cn.iocoder.yudao.framework.test.core.util.RandomUtils.randomLongId;
|
import static org.junit.jupiter.api.Assertions.*;
|
|
/**
|
* {@link IotDevicePropertyConditionMatcher} 的单元测试
|
*
|
* @author HUIHUI
|
*/
|
public class IotDevicePropertyConditionMatcherTest extends IotBaseConditionMatcherTest {
|
|
private IotDevicePropertyConditionMatcher matcher;
|
|
@BeforeEach
|
public void setUp() {
|
matcher = new IotDevicePropertyConditionMatcher();
|
}
|
|
@Test
|
public void testGetSupportedConditionType() {
|
// 调用
|
IotSceneRuleConditionTypeEnum result = matcher.getSupportedConditionType();
|
|
// 断言
|
assertEquals(IotSceneRuleConditionTypeEnum.DEVICE_PROPERTY, result);
|
}
|
|
@Test
|
public void testGetPriority() {
|
// 调用
|
int result = matcher.getPriority();
|
|
// 断言
|
assertEquals(25, result); // 修正：实际返回值是 25
|
}
|
|
@Test
|
public void testMatches_temperatureEquals_success() {
|
// 准备参数：创建属性上报消息
|
String propertyIdentifier = "temperature";
|
Double propertyValue = 25.5;
|
IotDeviceMessage message = createPropertyPostMessage(propertyIdentifier, propertyValue);
|
IotSceneRuleDO.TriggerCondition condition = createValidCondition(
|
propertyIdentifier,
|
IotSceneRuleConditionOperatorEnum.EQUALS.getOperator(),
|
String.valueOf(propertyValue)
|
);
|
|
// 调用
|
boolean result = matcher.matches(message, condition);
|
|
// 断言
|
assertTrue(result);
|
}
|
|
@Test
|
public void testMatches_humidityGreaterThan_success() {
|
// 准备参数：创建属性上报消息
|
String propertyIdentifier = "humidity";
|
Integer propertyValue = 75;
|
Integer compareValue = 70;
|
IotDeviceMessage message = createPropertyPostMessage(propertyIdentifier, propertyValue);
|
IotSceneRuleDO.TriggerCondition condition = createValidCondition(
|
propertyIdentifier,
|
IotSceneRuleConditionOperatorEnum.GREATER_THAN.getOperator(),
|
String.valueOf(compareValue)
|
);
|
|
// 调用
|
boolean result = matcher.matches(message, condition);
|
|
// 断言
|
assertTrue(result);
|
}
|
|
@Test
|
public void testMatches_pressureLessThan_success() {
|
// 准备参数：创建属性上报消息
|
String propertyIdentifier = "pressure";
|
Double propertyValue = 1010.5;
|
Integer compareValue = 1020;
|
IotDeviceMessage message = createPropertyPostMessage(propertyIdentifier, propertyValue);
|
IotSceneRuleDO.TriggerCondition condition = createValidCondition(
|
propertyIdentifier,
|
IotSceneRuleConditionOperatorEnum.LESS_THAN.getOperator(),
|
String.valueOf(compareValue)
|
);
|
|
// 调用
|
boolean result = matcher.matches(message, condition);
|
|
// 断言
|
assertTrue(result);
|
}
|
|
@Test
|
public void testMatches_statusNotEquals_success() {
|
// 准备参数：创建属性上报消息
|
String propertyIdentifier = "status";
|
String propertyValue = "active";
|
String compareValue = "inactive";
|
IotDeviceMessage message = createPropertyPostMessage(propertyIdentifier, propertyValue);
|
IotSceneRuleDO.TriggerCondition condition = createValidCondition(
|
propertyIdentifier,
|
IotSceneRuleConditionOperatorEnum.NOT_EQUALS.getOperator(),
|
compareValue
|
);
|
|
// 调用
|
boolean result = matcher.matches(message, condition);
|
|
// 断言
|
assertTrue(result);
|
}
|
|
@Test
|
public void testMatches_propertyMismatch_fail() {
|
// 准备参数：创建属性上报消息，值不满足条件
|
String propertyIdentifier = "temperature";
|
Double propertyValue = 15.0;
|
Integer compareValue = 20;
|
IotDeviceMessage message = createPropertyPostMessage(propertyIdentifier, propertyValue);
|
IotSceneRuleDO.TriggerCondition condition = createValidCondition(
|
propertyIdentifier,
|
IotSceneRuleConditionOperatorEnum.GREATER_THAN.getOperator(),
|
String.valueOf(compareValue)
|
);
|
|
// 调用
|
boolean result = matcher.matches(message, condition);
|
|
// 断言
|
assertFalse(result);
|
}
|
|
@Test
|
public void testMatches_identifierMismatch_fail() {
|
// 准备参数：标识符不匹配
|
String messageIdentifier = "temperature";
|
String conditionIdentifier = "humidity";
|
Double propertyValue = 25.5;
|
IotDeviceMessage message = createPropertyPostMessage(messageIdentifier, propertyValue);
|
IotSceneRuleDO.TriggerCondition condition = createValidCondition(
|
conditionIdentifier,
|
IotSceneRuleConditionOperatorEnum.EQUALS.getOperator(),
|
String.valueOf(propertyValue)
|
);
|
|
// 调用
|
boolean result = matcher.matches(message, condition);
|
|
// 断言
|
assertFalse(result);
|
}
|
|
@Test
|
public void testMatches_nullCondition_fail() {
|
// 准备参数
|
IotDeviceMessage message = createPropertyPostMessage("temperature", 25.5);
|
|
// 调用
|
boolean result = matcher.matches(message, null);
|
|
// 断言
|
assertFalse(result);
|
}
|
|
@Test
|
public void testMatches_nullConditionType_fail() {
|
// 准备参数
|
IotDeviceMessage message = createPropertyPostMessage("temperature", 25.5);
|
IotSceneRuleDO.TriggerCondition condition = new IotSceneRuleDO.TriggerCondition();
|
condition.setType(null);
|
|
// 调用
|
boolean result = matcher.matches(message, condition);
|
|
// 断言
|
assertFalse(result);
|
}
|
|
@Test
|
public void testMatches_missingIdentifier_fail() {
|
// 准备参数
|
IotDeviceMessage message = createPropertyPostMessage("temperature", 25.5);
|
IotSceneRuleDO.TriggerCondition condition = new IotSceneRuleDO.TriggerCondition();
|
condition.setType(IotSceneRuleConditionTypeEnum.DEVICE_PROPERTY.getType());
|
condition.setIdentifier(null); // 缺少标识符
|
condition.setOperator(IotSceneRuleConditionOperatorEnum.GREATER_THAN.getOperator());
|
condition.setParam("20");
|
|
// 调用
|
boolean result = matcher.matches(message, condition);
|
|
// 断言
|
assertFalse(result);
|
}
|
|
@Test
|
public void testMatches_missingOperator_fail() {
|
// 准备参数
|
IotDeviceMessage message = createPropertyPostMessage("temperature", 25.5);
|
IotSceneRuleDO.TriggerCondition condition = new IotSceneRuleDO.TriggerCondition();
|
condition.setType(IotSceneRuleConditionTypeEnum.DEVICE_PROPERTY.getType());
|
condition.setIdentifier("temperature");
|
condition.setOperator(null); // 缺少操作符
|
condition.setParam("20");
|
|
// 调用
|
boolean result = matcher.matches(message, condition);
|
|
// 断言
|
assertFalse(result);
|
}
|
|
@Test
|
public void testMatches_missingParam_fail() {
|
// 准备参数
|
IotDeviceMessage message = createPropertyPostMessage("temperature", 25.5);
|
IotSceneRuleDO.TriggerCondition condition = new IotSceneRuleDO.TriggerCondition();
|
condition.setType(IotSceneRuleConditionTypeEnum.DEVICE_PROPERTY.getType());
|
condition.setIdentifier("temperature");
|
condition.setOperator(IotSceneRuleConditionOperatorEnum.GREATER_THAN.getOperator());
|
condition.setParam(null); // 缺少参数
|
|
// 调用
|
boolean result = matcher.matches(message, condition);
|
|
// 断言
|
assertFalse(result);
|
}
|
|
@Test
|
public void testMatches_nullMessage_fail() {
|
// 准备参数
|
IotSceneRuleDO.TriggerCondition condition = createValidCondition(
|
"temperature",
|
IotSceneRuleConditionOperatorEnum.GREATER_THAN.getOperator(),
|
"20"
|
);
|
|
// 调用
|
boolean result = matcher.matches(null, condition);
|
|
// 断言
|
assertFalse(result);
|
}
|
|
@Test
|
public void testMatches_nullDeviceProperties_fail() {
|
// 准备参数：消息的 params 为 null
|
IotDeviceMessage message = new IotDeviceMessage();
|
message.setParams(null);
|
IotSceneRuleDO.TriggerCondition condition = createValidCondition(
|
"temperature",
|
IotSceneRuleConditionOperatorEnum.GREATER_THAN.getOperator(),
|
"20"
|
);
|
|
// 调用
|
boolean result = matcher.matches(message, condition);
|
|
// 断言
|
assertFalse(result);
|
}
|
|
@Test
|
public void testMatches_propertiesStructure_success() {
|
// 测试使用 properties 结构的消息（真实的属性上报场景）
|
String identifier = "temperature";
|
Double propertyValue = 25.5;
|
IotDeviceMessage message = createPropertyPostMessageWithProperties(identifier, propertyValue);
|
IotSceneRuleDO.TriggerCondition condition = createValidCondition(
|
identifier,
|
IotSceneRuleConditionOperatorEnum.GREATER_THAN.getOperator(),
|
"20"
|
);
|
|
// 调用
|
boolean result = matcher.matches(message, condition);
|
|
// 断言：修复后的实现应该能正确从 properties 中提取属性值
|
assertTrue(result);
|
}
|
|
@Test
|
public void testMatches_simpleValueMessage_success() {
|
// 测试简单值消息（params 直接是属性值）
|
Double propertyValue = 25.5;
|
IotDeviceMessage message = createSimpleValueMessage(propertyValue);
|
IotSceneRuleDO.TriggerCondition condition = createValidCondition(
|
"any", // 对于简单值消息，标识符匹配会被跳过
|
IotSceneRuleConditionOperatorEnum.GREATER_THAN.getOperator(),
|
"20"
|
);
|
|
// 调用
|
boolean result = matcher.matches(message, condition);
|
|
// 断言：修复后的实现应该能处理简单值消息
|
// 但由于标识符匹配失败，结果为 false
|
assertFalse(result);
|
}
|
|
@Test
|
public void testMatches_valueFieldStructure_success() {
|
// 测试使用 value 字段的消息结构
|
String identifier = "temperature";
|
Double propertyValue = 25.5;
|
|
IotDeviceMessage message = new IotDeviceMessage();
|
message.setDeviceId(randomLongId());
|
message.setMethod("thing.event.post");
|
|
Map<String, Object> params = new HashMap<>();
|
params.put("identifier", identifier);
|
params.put("value", propertyValue);
|
message.setParams(params);
|
|
IotSceneRuleDO.TriggerCondition condition = createValidCondition(
|
identifier,
|
IotSceneRuleConditionOperatorEnum.GREATER_THAN.getOperator(),
|
"20"
|
);
|
|
// 调用
|
boolean result = matcher.matches(message, condition);
|
|
// 断言：修复后的实现应该能从 value 字段提取属性值
|
assertTrue(result);
|
}
|
|
@Test
|
public void testMatches_voltageGreaterThanOrEquals_success() {
|
// 准备参数：创建属性上报消息
|
String propertyIdentifier = "voltage";
|
Double propertyValue = 12.0;
|
IotDeviceMessage message = createPropertyPostMessage(propertyIdentifier, propertyValue);
|
IotSceneRuleDO.TriggerCondition condition = createValidCondition(
|
propertyIdentifier,
|
IotSceneRuleConditionOperatorEnum.GREATER_THAN_OR_EQUALS.getOperator(),
|
String.valueOf(propertyValue)
|
);
|
|
// 调用
|
boolean result = matcher.matches(message, condition);
|
|
// 断言
|
assertTrue(result);
|
}
|
|
@Test
|
public void testMatches_currentLessThanOrEquals_success() {
|
// 准备参数：创建属性上报消息
|
String propertyIdentifier = "current";
|
Double propertyValue = 2.5;
|
Double compareValue = 3.0;
|
IotDeviceMessage message = createPropertyPostMessage(propertyIdentifier, propertyValue);
|
IotSceneRuleDO.TriggerCondition condition = createValidCondition(
|
propertyIdentifier,
|
IotSceneRuleConditionOperatorEnum.LESS_THAN_OR_EQUALS.getOperator(),
|
String.valueOf(compareValue)
|
);
|
|
// 调用
|
boolean result = matcher.matches(message, condition);
|
|
// 断言
|
assertTrue(result);
|
}
|
|
@Test
|
public void testMatches_stringProperty_success() {
|
// 准备参数：创建属性上报消息
|
String propertyIdentifier = "mode";
|
String propertyValue = "auto";
|
IotDeviceMessage message = createPropertyPostMessage(propertyIdentifier, propertyValue);
|
IotSceneRuleDO.TriggerCondition condition = createValidCondition(
|
propertyIdentifier,
|
IotSceneRuleConditionOperatorEnum.EQUALS.getOperator(),
|
propertyValue
|
);
|
|
// 调用
|
boolean result = matcher.matches(message, condition);
|
|
// 断言
|
assertTrue(result);
|
}
|
|
@Test
|
public void testMatches_booleanProperty_success() {
|
// 准备参数：创建属性上报消息
|
String propertyIdentifier = "enabled";
|
Boolean propertyValue = true;
|
IotDeviceMessage message = createPropertyPostMessage(propertyIdentifier, propertyValue);
|
IotSceneRuleDO.TriggerCondition condition = createValidCondition(
|
propertyIdentifier,
|
IotSceneRuleConditionOperatorEnum.EQUALS.getOperator(),
|
String.valueOf(propertyValue)
|
);
|
|
// 调用
|
boolean result = matcher.matches(message, condition);
|
|
// 断言
|
assertTrue(result);
|
}
|
|
// ========== 辅助方法 ==========
|
|
/**
|
* 创建设备消息用于测试
|
*
|
* 支持的消息格式：
|
* 1. 直接属性值：params 直接是属性值（适用于简单消息）
|
* 2. 标识符+值：params 包含 identifier 和对应的属性值
|
* 3. properties 结构：params.properties[identifier] = value
|
* 4. data 结构：params.data[identifier] = value
|
* 5. value 字段：params.value = value
|
*/
|
private IotDeviceMessage createPropertyPostMessage(String identifier, Object value) {
|
IotDeviceMessage message = new IotDeviceMessage();
|
message.setDeviceId(randomLongId());
|
message.setMethod("thing.event.post"); // 使用事件上报方法
|
|
// 创建符合修复后逻辑的 params 结构
|
Map<String, Object> params = new HashMap<>();
|
params.put("identifier", identifier);
|
// 直接将属性值放在标识符对应的字段中
|
params.put(identifier, value);
|
message.setParams(params);
|
|
return message;
|
}
|
|
/**
|
* 创建使用 properties 结构的消息（模拟真实的属性上报消息）
|
*/
|
private IotDeviceMessage createPropertyPostMessageWithProperties(String identifier, Object value) {
|
IotDeviceMessage message = new IotDeviceMessage();
|
message.setDeviceId(randomLongId());
|
message.setMethod("thing.property.post"); // 属性上报方法
|
|
Map<String, Object> properties = new HashMap<>();
|
properties.put(identifier, value);
|
|
Map<String, Object> params = new HashMap<>();
|
params.put("properties", properties);
|
message.setParams(params);
|
|
return message;
|
}
|
|
/**
|
* 创建简单值消息（params 直接是属性值）
|
*/
|
private IotDeviceMessage createSimpleValueMessage(Object value) {
|
IotDeviceMessage message = new IotDeviceMessage();
|
message.setDeviceId(randomLongId());
|
message.setMethod("thing.property.post");
|
// 直接将属性值作为 params
|
message.setParams(value);
|
|
return message;
|
}
|
|
/**
|
* 创建有效的条件
|
*/
|
private IotSceneRuleDO.TriggerCondition createValidCondition(String identifier, String operator, String param) {
|
IotSceneRuleDO.TriggerCondition condition = new IotSceneRuleDO.TriggerCondition();
|
condition.setType(IotSceneRuleConditionTypeEnum.DEVICE_PROPERTY.getType());
|
condition.setIdentifier(identifier);
|
condition.setOperator(operator);
|
condition.setParam(param);
|
return condition;
|
}
|
|
}
|
