refactor: 设备事件上报时，用物模型验证事件是否有效

芯火源
1 parent 71f2a7c0
Showing 1 changed file with 5 additions and 0 deletions
rule-engine/rule-engine-components/src/main/java/org/thingsboard/rule/engine/yunteng/event/TkMsgEventNode.java
--- a/rule-engine/rule-engine-components/src/main/java/org/thingsboard/rule/engine/yunteng/event/TkMsgEventNode.java
View file @4ec6a13
+++ b/rule-engine/rule-engine-components/src/main/java/org/thingsboard/rule/engine/yunteng/event/TkMsgEventNode.java
View file @4ec6a13
@@ -23,6 +23,7 @@ import org.thingsboard.server.common.data.DeviceProfile;
 import org.thingsboard.server.common.data.id.DeviceProfileId;
 import org.thingsboard.server.common.data.id.TenantId;
 import org.thingsboard.server.common.data.plugin.ComponentType;
+import org.thingsboard.server.common.data.yunteng.core.exception.ThingsKitException;
 import org.thingsboard.server.common.data.yunteng.dto.TkEventKvEntry;
 import org.thingsboard.server.common.data.yunteng.dto.TkThingsModel;
 import org.thingsboard.server.common.data.yunteng.enums.FunctionTypeEnum;
@@ -80,6 +81,10 @@ public class TkMsgEventNode implements TbNode {
             item.setEventType(i.getEventType());
             item.setEventName(i.getFunctionName());
         });
+        if(eventList.isEmpty()){
+            ctx.tellFailure(msg,new TbNodeException(String.format("产品物模型中未申明,上报的事件类型【%s】。", eventIdentifier)));
+            return;
+        }
         ////TODO: 验证事件类型、事件标识符和数据建是否与产品物模型中的事件匹配
         long ts = System.currentTimeMillis();
         String src = msg.getData();