fix：redis

只缓存上报的数据

server-web/src/main/java/com/makeit/mqtt/PushCallback.java

@@ -43,6 +43,8 @@ public class PushCallback implements MqttCallback {
     public static final String DEVICE_BR_DATA = "device:brhr:data:";
     public static final String DEVICE_SPACE_DATA = "device:space:data:";
     public static final String DEVICE_FALL_DATA = "device:fall:data:";
+
+    public static final String REPORT_PROPERTY = "REPORT_PROPERTY";
     @Autowired
     private MqttConfig mqttConfig;
 
@@ -101,15 +103,15 @@ public class PushCallback implements MqttCallback {
         HeaderInfo headers = device.getHeaders();
         List<HeaderInfo.Bind> bindings = headers.getBindings();
         // TODO 先这样判断
-        if (headers.getProductName().contains("呼吸")) {
+        if (REPORT_PROPERTY.equals(device.getMessageType()) && headers.getProductName().contains("呼吸")) {
             redisTemplate.opsForValue().set(DEVICE_BR_DATA + device.getDeviceId(),JSON.toJSONString(device.getProperties()),
                     1000, TimeUnit.MILLISECONDS);
         }
-        if (headers.getProductName().contains("空间")) {
+        if (REPORT_PROPERTY.equals(device.getMessageType()) && headers.getProductName().contains("空间")) {
             redisTemplate.opsForValue().set(DEVICE_SPACE_DATA + device.getDeviceId(),JSON.toJSONString(device.getProperties()),
                     1000, TimeUnit.MILLISECONDS);
         }
-        if (headers.getProductName().contains("跌倒")) {
+        if (REPORT_PROPERTY.equals(device.getMessageType())  && headers.getProductName().contains("跌倒")) {
             redisTemplate.opsForValue().set(DEVICE_FALL_DATA + device.getDeviceId(),JSON.toJSONString(device.getProperties()),
                     1000, TimeUnit.MILLISECONDS);
         }