package cn.iocoder.yudao.module.iot.service.rule.scene.matcher.trigger;
|
|
import cn.hutool.core.map.MapUtil;
|
import cn.iocoder.yudao.module.iot.core.enums.IotDeviceMessageMethodEnum;
|
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.IotSceneRuleTriggerTypeEnum;
|
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.hutool.core.util.RandomUtil.randomDouble;
|
import static cn.hutool.core.util.RandomUtil.randomInt;
|
import static cn.iocoder.yudao.framework.test.core.util.RandomUtils.randomLongId;
|
import static cn.iocoder.yudao.framework.test.core.util.RandomUtils.randomString;
|
import static org.junit.jupiter.api.Assertions.*;
|
|
/**
|
* {@link IotDevicePropertyPostTriggerMatcher} 的单元测试
|
*
|
* @author HUIHUI
|
*/
|
public class IotDevicePropertyPostTriggerMatcherTest extends IotBaseConditionMatcherTest {
|
|
private IotDevicePropertyPostTriggerMatcher matcher;
|
|
@BeforeEach
|
public void setUp() {
|
matcher = new IotDevicePropertyPostTriggerMatcher();
|
}
|
|
@Test
|
public void testGetSupportedTriggerType_success() {
|
// 准备参数
|
// 无需准备参数
|
|
// 调用
|
IotSceneRuleTriggerTypeEnum result = matcher.getSupportedTriggerType();
|
|
// 断言
|
assertEquals(IotSceneRuleTriggerTypeEnum.DEVICE_PROPERTY_POST, result);
|
}
|
|
@Test
|
public void testGetPriority_success() {
|
// 准备参数
|
// 无需准备参数
|
|
// 调用
|
int result = matcher.getPriority();
|
|
// 断言
|
assertEquals(20, result);
|
}
|
|
@Test
|
public void testIsEnabled_success() {
|
// 准备参数
|
// 无需准备参数
|
|
// 调用
|
boolean result = matcher.isEnabled();
|
|
// 断言
|
assertTrue(result);
|
}
|
|
@Test
|
public void testMatches_numericPropertyGreaterThanSuccess() {
|
// 准备参数
|
String propertyName = randomString();
|
Double propertyValue = 25.5;
|
Integer compareValue = 20;
|
Map<String, Object> properties = MapUtil.builder(new HashMap<String, Object>())
|
.put(propertyName, propertyValue)
|
.build();
|
IotDeviceMessage message = createPropertyPostMessage(properties);
|
IotSceneRuleDO.Trigger trigger = createValidTrigger(
|
propertyName,
|
IotSceneRuleConditionOperatorEnum.GREATER_THAN.getOperator(),
|
String.valueOf(compareValue)
|
);
|
|
// 调用
|
boolean result = matcher.matches(message, trigger);
|
|
// 断言
|
assertTrue(result);
|
}
|
|
@Test
|
public void testMatches_integerPropertyEqualsSuccess() {
|
// 准备参数
|
String propertyName = randomString();
|
Integer propertyValue = randomInt();
|
Map<String, Object> properties = MapUtil.builder(new HashMap<String, Object>())
|
.put(propertyName, propertyValue)
|
.build();
|
IotDeviceMessage message = createPropertyPostMessage(properties);
|
IotSceneRuleDO.Trigger trigger = createValidTrigger(
|
propertyName,
|
IotSceneRuleConditionOperatorEnum.EQUALS.getOperator(),
|
String.valueOf(propertyValue)
|
);
|
|
// 调用
|
boolean result = matcher.matches(message, trigger);
|
|
// 断言
|
assertTrue(result);
|
}
|
|
@Test
|
public void testMatches_propertyValueNotMeetCondition() {
|
// 准备参数
|
String propertyName = randomString();
|
Double propertyValue = 15.0;
|
Integer compareValue = 20;
|
Map<String, Object> properties = MapUtil.builder(new HashMap<String, Object>())
|
.put(propertyName, propertyValue)
|
.build();
|
IotDeviceMessage message = createPropertyPostMessage(properties);
|
IotSceneRuleDO.Trigger trigger = createValidTrigger(
|
propertyName,
|
IotSceneRuleConditionOperatorEnum.GREATER_THAN.getOperator(),
|
String.valueOf(compareValue)
|
);
|
|
// 调用
|
boolean result = matcher.matches(message, trigger);
|
|
// 断言
|
assertFalse(result);
|
}
|
|
@Test
|
public void testMatches_propertyNotFound() {
|
// 准备参数
|
String existingProperty = randomString();
|
String missingProperty = randomString();
|
Map<String, Object> properties = MapUtil.builder(new HashMap<String, Object>())
|
.put(existingProperty, randomDouble())
|
.build();
|
IotDeviceMessage message = createPropertyPostMessage(properties);
|
IotSceneRuleDO.Trigger trigger = createValidTrigger(
|
missingProperty, // 不存在的属性
|
IotSceneRuleConditionOperatorEnum.GREATER_THAN.getOperator(),
|
String.valueOf(randomInt())
|
);
|
|
// 调用
|
boolean result = matcher.matches(message, trigger);
|
|
// 断言
|
assertFalse(result);
|
}
|
|
@Test
|
public void testMatches_wrongMessageMethod() {
|
// 准备参数
|
String propertyName = randomString();
|
Map<String, Object> properties = MapUtil.builder(new HashMap<String, Object>())
|
.put(propertyName, randomDouble())
|
.build();
|
IotDeviceMessage message = new IotDeviceMessage();
|
message.setDeviceId(randomLongId());
|
message.setMethod(IotDeviceMessageMethodEnum.STATE_UPDATE.getMethod());
|
message.setParams(properties);
|
IotSceneRuleDO.Trigger trigger = createValidTrigger(
|
propertyName,
|
IotSceneRuleConditionOperatorEnum.GREATER_THAN.getOperator(),
|
String.valueOf(randomInt())
|
);
|
|
// 调用
|
boolean result = matcher.matches(message, trigger);
|
|
// 断言
|
assertFalse(result);
|
}
|
|
@Test
|
public void testMatches_nullTriggerIdentifier() {
|
// 准备参数
|
String propertyName = randomString();
|
Map<String, Object> properties = MapUtil.builder(new HashMap<String, Object>())
|
.put(propertyName, randomDouble())
|
.build();
|
IotDeviceMessage message = createPropertyPostMessage(properties);
|
IotSceneRuleDO.Trigger trigger = new IotSceneRuleDO.Trigger();
|
trigger.setType(IotSceneRuleTriggerTypeEnum.DEVICE_PROPERTY_POST.getType());
|
trigger.setIdentifier(null); // 缺少标识符
|
trigger.setOperator(IotSceneRuleConditionOperatorEnum.GREATER_THAN.getOperator());
|
trigger.setValue(String.valueOf(randomInt()));
|
|
// 调用
|
boolean result = matcher.matches(message, trigger);
|
|
// 断言
|
assertFalse(result);
|
}
|
|
@Test
|
public void testMatches_nullMessageParams() {
|
// 准备参数
|
String propertyName = randomString();
|
IotDeviceMessage message = new IotDeviceMessage();
|
message.setDeviceId(randomLongId());
|
message.setMethod(IotDeviceMessageMethodEnum.PROPERTY_POST.getMethod());
|
message.setParams(null);
|
IotSceneRuleDO.Trigger trigger = createValidTrigger(
|
propertyName,
|
IotSceneRuleConditionOperatorEnum.GREATER_THAN.getOperator(),
|
String.valueOf(randomInt())
|
);
|
|
// 调用
|
boolean result = matcher.matches(message, trigger);
|
|
// 断言
|
assertFalse(result);
|
}
|
|
@Test
|
public void testMatches_invalidMessageParams() {
|
// 准备参数
|
String propertyName = randomString();
|
IotDeviceMessage message = new IotDeviceMessage();
|
message.setDeviceId(randomLongId());
|
message.setMethod(IotDeviceMessageMethodEnum.PROPERTY_POST.getMethod());
|
message.setParams(randomString()); // 不是 Map 类型
|
IotSceneRuleDO.Trigger trigger = createValidTrigger(
|
propertyName,
|
IotSceneRuleConditionOperatorEnum.GREATER_THAN.getOperator(),
|
String.valueOf(randomInt())
|
);
|
|
// 调用
|
boolean result = matcher.matches(message, trigger);
|
|
// 断言
|
assertFalse(result);
|
}
|
|
@Test
|
public void testMatches_lessThanOperatorSuccess() {
|
// 准备参数
|
String propertyName = randomString();
|
Double propertyValue = 15.0;
|
Integer compareValue = 20;
|
Map<String, Object> properties = MapUtil.builder(new HashMap<String, Object>())
|
.put(propertyName, propertyValue)
|
.build();
|
IotDeviceMessage message = createPropertyPostMessage(properties);
|
IotSceneRuleDO.Trigger trigger = createValidTrigger(
|
propertyName,
|
IotSceneRuleConditionOperatorEnum.LESS_THAN.getOperator(),
|
String.valueOf(compareValue)
|
);
|
|
// 调用
|
boolean result = matcher.matches(message, trigger);
|
|
// 断言
|
assertTrue(result);
|
}
|
|
@Test
|
public void testMatches_notEqualsOperatorSuccess() {
|
// 准备参数
|
String propertyName = randomString();
|
String propertyValue = randomString();
|
String compareValue = randomString();
|
Map<String, Object> properties = MapUtil.builder(new HashMap<String, Object>())
|
.put(propertyName, propertyValue)
|
.build();
|
IotDeviceMessage message = createPropertyPostMessage(properties);
|
IotSceneRuleDO.Trigger trigger = createValidTrigger(
|
propertyName,
|
IotSceneRuleConditionOperatorEnum.NOT_EQUALS.getOperator(),
|
compareValue
|
);
|
|
// 调用
|
boolean result = matcher.matches(message, trigger);
|
|
// 断言
|
assertTrue(result);
|
}
|
|
@Test
|
public void testMatches_multiplePropertiesTargetPropertySuccess() {
|
// 准备参数
|
String targetProperty = randomString();
|
Integer targetValue = randomInt();
|
Map<String, Object> properties = MapUtil.builder(new HashMap<String, Object>())
|
.put(randomString(), randomDouble())
|
.put(targetProperty, targetValue)
|
.put(randomString(), randomString())
|
.build();
|
IotDeviceMessage message = createPropertyPostMessage(properties);
|
IotSceneRuleDO.Trigger trigger = createValidTrigger(
|
targetProperty,
|
IotSceneRuleConditionOperatorEnum.EQUALS.getOperator(),
|
String.valueOf(targetValue)
|
);
|
|
// 调用
|
boolean result = matcher.matches(message, trigger);
|
|
// 断言
|
assertTrue(result);
|
}
|
|
// ========== 辅助方法 ==========
|
|
/**
|
* 创建属性上报消息
|
*/
|
private IotDeviceMessage createPropertyPostMessage(Map<String, Object> properties) {
|
IotDeviceMessage message = new IotDeviceMessage();
|
message.setDeviceId(randomLongId());
|
message.setMethod(IotDeviceMessageMethodEnum.PROPERTY_POST.getMethod());
|
message.setParams(properties);
|
return message;
|
}
|
|
/**
|
* 创建有效的触发器
|
*/
|
private IotSceneRuleDO.Trigger createValidTrigger(String identifier, String operator, String value) {
|
IotSceneRuleDO.Trigger trigger = new IotSceneRuleDO.Trigger();
|
trigger.setType(IotSceneRuleTriggerTypeEnum.DEVICE_PROPERTY_POST.getType());
|
trigger.setIdentifier(identifier);
|
trigger.setOperator(operator);
|
trigger.setValue(value);
|
return trigger;
|
}
|
|
}
|
