diff --git a/das/src/main/java/com/das/modules/data/domain/DeviceEventInfo.java b/das/src/main/java/com/das/modules/data/domain/DeviceEventInfo.java
index 86d06672..2ee1b88b 100644
--- a/das/src/main/java/com/das/modules/data/domain/DeviceEventInfo.java
+++ b/das/src/main/java/com/das/modules/data/domain/DeviceEventInfo.java
@@ -11,6 +11,8 @@ public class DeviceEventInfo {
     @JsonSerialize(using = ToStringSerializer.class)
     private Long eventId;
 
+    private String attributeCode;
+
     private Integer eventType;
 
     private Integer eventLevel;
diff --git a/das/src/main/java/com/das/modules/data/service/TDEngineService.java b/das/src/main/java/com/das/modules/data/service/TDEngineService.java
index 8bd752a2..8bd72647 100644
--- a/das/src/main/java/com/das/modules/data/service/TDEngineService.java
+++ b/das/src/main/java/com/das/modules/data/service/TDEngineService.java
@@ -400,6 +400,8 @@ public class TDEngineService {
                     sb.append(",");
                     sb.append(dv.getEventId());
                     sb.append(",");
+                    sb.append(dv.getAttributeCode());
+                    sb.append(",");
                     sb.append(dv.getEventType());
                     sb.append(",");
                     sb.append(dv.getEventLevel());
diff --git a/das/src/main/java/com/das/modules/data/service/impl/DataServiceImpl.java b/das/src/main/java/com/das/modules/data/service/impl/DataServiceImpl.java
index 14c6a467..f9b0787d 100644
--- a/das/src/main/java/com/das/modules/data/service/impl/DataServiceImpl.java
+++ b/das/src/main/java/com/das/modules/data/service/impl/DataServiceImpl.java
@@ -218,7 +218,7 @@ public class DataServiceImpl implements DataService {
             Map<String, String> HighModelFieldList = allIotModelField.stream().filter(field -> field.getHighSpeed() == 1 && field.getAttributeType() != 199).collect(Collectors.toMap(SysIotModelField::getAttributeCode, SysIotModelField::getDataType, (value1, value2) -> value1));
             Map<String, String> calculateFieldList = allIotModelField.stream().filter(field -> field.getAttributeType() == 199).collect(Collectors.toMap(SysIotModelField::getAttributeCode, SysIotModelField::getDataType, (value1, value2) -> value1));
             Map<String, String> fieldCodeNameList = allIotModelField.stream().collect(Collectors.toMap(SysIotModelField::getAttributeCode, SysIotModelField::getAttributeName, (value1, value2) -> value1));
-            Map<String, Integer> eventLevelList = allIotModelField.stream().filter(field -> field.getAttributeType() == 140 && field.getLevel() != null).collect(Collectors.toMap(SysIotModelField::getAttributeCode, SysIotModelField::getLevel, (value1, value2) -> value1));
+            Map<String, Integer> eventLevelList = allIotModelField.stream().filter(field -> field.getAttributeType() == 140).collect(Collectors.toMap(SysIotModelField::getAttributeCode, SysIotModelField::getLevel, (value1, value2) -> value1));
             Map<String, Object> map = new HashMap<>();
             for (String field : HighModelFieldList.keySet()) {
                 map.put(field, HighModelFieldList.get(field));
diff --git a/das/src/main/java/com/das/modules/node/service/impl/NodeMessageServiceImpl.java b/das/src/main/java/com/das/modules/node/service/impl/NodeMessageServiceImpl.java
index b7df0c61..395465c3 100644
--- a/das/src/main/java/com/das/modules/node/service/impl/NodeMessageServiceImpl.java
+++ b/das/src/main/java/com/das/modules/node/service/impl/NodeMessageServiceImpl.java
@@ -346,6 +346,7 @@ public class NodeMessageServiceImpl extends TextWebSocketHandler implements Node
             DeviceEventInfo deviceEventInfo = new DeviceEventInfo();
             deviceEventInfo.setEventTime(item.getEventTime());
             deviceEventInfo.setEventId(IdWorker.getId());
+            deviceEventInfo.setAttributeCode(item.getAttrCode());
             deviceEventInfo.setDeviceId(item.getDeviceId());
             deviceEventInfo.setDeviceName(deviceInfoCache.getDeviceName());
             deviceEventInfo.setDeviceCode(deviceInfoCache.getDeviceCode());
@@ -367,7 +368,7 @@ public class NodeMessageServiceImpl extends TextWebSocketHandler implements Node
                     deviceEventInfo.setEventLevel(0);
                 } else {
                     deviceEventInfo.setEventText(fieldName + " 动作");
-                    Integer level = dataService.eventLevelMap.get(model).get(fieldName);
+                    Integer level = dataService.eventLevelMap.get(model).get(item.getAttrCode());
                     log.info("缓存为：{}",dataService.eventLevelMap.get(model));
                     log.info("level:{}",level);
                     log.info("fieldname{}",fieldName);
diff --git a/das/src/main/resources/mapper/SysIotModelMapper.xml b/das/src/main/resources/mapper/SysIotModelMapper.xml
index e4436ec7..510289f3 100644
--- a/das/src/main/resources/mapper/SysIotModelMapper.xml
+++ b/das/src/main/resources/mapper/SysIotModelMapper.xml
@@ -78,7 +78,7 @@
         where se.id = #{id}
     </select>
     <select id="getAllIotModelField" resultType="com.das.modules.equipment.entity.SysIotModelField">
-        select simf.attribute_name as attributeName, simf.attribute_code as attributeCode,simf.highspeed as highSpeed,simf.datatype as dataType,simf.attribute_type as attributeType from sys_iot_model_field simf where simf.iot_model_id = #{id} order by simf.attribute_code
+        select simf.attribute_name as attributeName, simf.attribute_code as attributeCode,simf.highspeed as highSpeed,simf.datatype as dataType,simf.attribute_type as attributeType,simf.level as level from sys_iot_model_field simf where simf.iot_model_id = #{id} order by simf.attribute_code
     </select>