diff --git a/muyu-common/muyu-common-cache/src/main/java/com/muyu/common/cache/abs/HashCacheAbs.java b/muyu-common/muyu-common-cache/src/main/java/com/muyu/common/cache/abs/HashCacheAbs.java index 126fbf0..95671fe 100644 --- a/muyu-common/muyu-common-cache/src/main/java/com/muyu/common/cache/abs/HashCacheAbs.java +++ b/muyu-common/muyu-common-cache/src/main/java/com/muyu/common/cache/abs/HashCacheAbs.java @@ -109,7 +109,9 @@ public abstract class HashCacheAbs implements HashCache { */ @Override public void put (K key, List dataList, Function hashKey) { - + Map dataMap = new HashMap<>(); + dataList.forEach((data) -> dataMap.put(hashKey.apply(data), data)); + redisService.setCacheMap(encode(key), encodeMap(dataMap)); } /** @@ -121,7 +123,7 @@ public abstract class HashCacheAbs implements HashCache { */ @Override public void put (K key, HK hashKey, HV hashValue) { - + redisService.setCacheMapValue(encode(key), encodeHashKey(hashKey), hashValue); } /** @@ -131,7 +133,7 @@ public abstract class HashCacheAbs implements HashCache { */ @Override public void remove (K key) { - + redisService.deleteObject(encode(key)); } /** @@ -142,7 +144,7 @@ public abstract class HashCacheAbs implements HashCache { */ @Override public void remove (K key, HK hashKey) { - + redisService.deleteCacheMapValue(encode(key), encodeHashKey(hashKey)); } /** @@ -166,4 +168,11 @@ public abstract class HashCacheAbs implements HashCache { encodeDataMap.forEach((hashKey, hashValue) -> dataMap.put(decodeHashKey(hashKey), hashValue)); return dataMap; } + + // getData + + /** + * 默认值 + */ + public abstract HV defaultValue(); }