提交

yq-common/src/main/java/yq/common/webSocket/MyWebSocketHandler.java

@@ -53,18 +53,7 @@ public class MyWebSocketHandler implements WebSocketHandler {
         // session.sendMessage(new TextMessage("我收到了你的消息，感谢你的来信"));
         if(id.contains("dk")){
             Map object = JSON.toJavaObject(msg, Map.class);
-            if(redisCache.hasKey(id)){
-                Double temp = Convert.toDouble(object.get("temp"));
-                Map<String, Object> cacheMap = redisCache.getCacheMap(id);
-                Double temp1 = Convert.toDouble(cacheMap.get("temp"),0.0);
-                if(temp>temp1){
-                    System.out.println("存入到redis" + object);
-                    redisCache.setCacheMap(id,object);
-                }
-            }else {
-                System.out.println("存入到redis" + object);
-                redisCache.setCacheMap(id,object);
-            }
+            redisCache.setCacheMap(id,object);
             redisCache.expire(id,5,TimeUnit.SECONDS);
         }
     }