From 2f73a671db8bf132baaba12a5c2a9c3b611589e9 Mon Sep 17 00:00:00 2001
From: wuxw <928255095@qq.com>
Date: 星期四, 01 八月 2019 17:14:26 +0800
Subject: [PATCH] 修复 添加房屋时的侦听 类修改

---
 java110-common/src/main/java/com/java110/common/cache/MappingCache.java |   12 +++++++-----
 1 files changed, 7 insertions(+), 5 deletions(-)

diff --git a/java110-common/src/main/java/com/java110/common/cache/MappingCache.java b/java110-common/src/main/java/com/java110/common/cache/MappingCache.java
index 415af63..5319ef6 100644
--- a/java110-common/src/main/java/com/java110/common/cache/MappingCache.java
+++ b/java110-common/src/main/java/com/java110/common/cache/MappingCache.java
@@ -14,6 +14,8 @@
  */
 public class MappingCache extends BaseCache {
 
+    //鍚庣紑 鐢ㄦ潵鍒风紦瀛樻椂鍒犻櫎 鎵�鏈変互杩欎釜涓哄悗缂�鐨勬暟鎹�
+    public final static String _SUFFIX_MAPPING = "_SUFFIX_MAPPING";
 
     /**
      * 鑾峰彇鍊�
@@ -25,7 +27,7 @@
         Jedis redis = null;
         try {
             redis = getJedis();
-            Object object = SerializeUtil.unserialize(redis.get((domain + key).getBytes()));
+            Object object = SerializeUtil.unserialize(redis.get((domain + key+_SUFFIX_MAPPING).getBytes()));
             if (object == null) {
                 return null;
             }
@@ -53,7 +55,7 @@
         Jedis redis = null;
         try {
             redis = getJedis();
-            Object obj = SerializeUtil.unserialize(redis.get((DomainContant.COMMON_DOMAIN+key).getBytes()));
+            Object obj = SerializeUtil.unserialize(redis.get((DomainContant.COMMON_DOMAIN+key+_SUFFIX_MAPPING).getBytes()));
             if(obj instanceof Mapping){
                 return (Mapping) obj;
             }
@@ -74,7 +76,7 @@
         Jedis redis = null;
         try {
             redis = getJedis();
-            return SerializeUtil.unserializeList(redis.get(domain.getBytes()),Mapping.class);
+            return SerializeUtil.unserializeList(redis.get((domain+_SUFFIX_MAPPING).getBytes()),Mapping.class);
         }finally {
             if(redis != null){
                 redis.close();
@@ -90,7 +92,7 @@
         Jedis redis = null;
         try {
             redis = getJedis();
-            redis.set((mapping.getDomain()+mapping.getKey()).getBytes(),SerializeUtil.serialize(mapping));
+            redis.set((mapping.getDomain()+mapping.getKey()+_SUFFIX_MAPPING).getBytes(),SerializeUtil.serialize(mapping));
         }finally {
             if(redis != null){
                 redis.close();
@@ -106,7 +108,7 @@
         Jedis redis = null;
         try {
             redis = getJedis();
-            redis.set((mappings.get(0).getDomain()).getBytes(),SerializeUtil.serializeList(mappings));
+            redis.set((mappings.get(0).getDomain()+_SUFFIX_MAPPING).getBytes(),SerializeUtil.serializeList(mappings));
         }finally {
             if(redis != null){
                 redis.close();

--
Gitblit v1.8.0