将缓存工具修改为Redis适用（Redis与Caffeine无法通用) / 优化了缓存key 并添加了缓存key生成器(RedisKeyGenerator .joinToString)

zen-api/src/main/kotlin/com/gxzc/zen/api/sys/service/impl/SysDicServiceImpl.kt

@@ -6,11 +6,15 @@ import com.gxzc.zen.api.sys.mapper.SysDicMapper
 import com.gxzc.zen.api.sys.model.SysDic
 import com.gxzc.zen.api.sys.service.ISysDicService
 import com.gxzc.zen.common.contants.CACHEKEYS
+import com.gxzc.zen.common.contants.PLATFORM
 import com.gxzc.zen.common.exception.ZenException
 import com.gxzc.zen.common.exception.ZenExceptionEnum
-import com.gxzc.zen.common.util.CacheUtil
+import com.gxzc.zen.common.properties.PlatformProperties
+import com.gxzc.zen.common.util.RedisCacheUtil
+import com.gxzc.zen.common.util.PlatformUtil
 import com.gxzc.zen.orm.annotation.ZenTransactional
 import org.slf4j.LoggerFactory
+import org.springframework.beans.factory.annotation.Autowired
 import org.springframework.boot.CommandLineRunner
 import org.springframework.stereotype.Service
 
@@ -30,18 +34,23 @@ class SysDicServiceImpl : ServiceImpl<SysDicMapper, SysDic>(), ISysDicService, C
         const val CACHE_KEY_ALL = "dic_all"
     }
 
+    @Autowired
+    private lateinit var platformProperties: PlatformProperties
+
     override fun run(vararg args: String?) {
         logger.debug("${this::class.simpleName} init.")
         getListCacheable()
     }
 
     override fun getListCacheable(): MutableList<SysDic> {
-        val cached = CacheUtil.get(CACHEKEYS.SYS, CACHE_KEY_ALL)?.get() as? MutableList<SysDic>
+        val cached = RedisCacheUtil.get(CACHEKEYS.SYS, CACHE_KEY_ALL)?.get() as? MutableList<SysDic>
         if (cached != null) {
             return cached
         }
         val ret = baseMapper.selectByParams(null)
-        CacheUtil.put(CACHEKEYS.SYS, CACHE_KEY_ALL, ret)
+        if (PlatformUtil.getPlatform(platformProperties) == PLATFORM.SYSTEM) {
+            RedisCacheUtil.put(CACHEKEYS.SYS, CACHE_KEY_ALL, ret)
+        }
         return ret
     }
 
@@ -64,15 +73,17 @@ class SysDicServiceImpl : ServiceImpl<SysDicMapper, SysDic>(), ISysDicService, C
 
     @ZenTransactional
     override fun modify(data: SysDic): SysDic {
-        baseMapper.updateNoLogic(data, EntityWrapper<SysDic>().eq("id", data.id))
-        // 更新缓存
-        val cached = CacheUtil.get(CACHEKEYS.SYS, CACHE_KEY_ALL)?.get() as? MutableList<SysDic>
-        cached?.let {
-            val idx = it.indexOfFirst { it.id == data.id }
-            if (idx != -1) {
-                it[idx] = data
+        if (PlatformUtil.getPlatform() == PLATFORM.SYSTEM) {
+            baseMapper.updateNoLogic(data, EntityWrapper<SysDic>().eq("id", data.id))
+            // 更新缓存
+            val cached = RedisCacheUtil.get(CACHEKEYS.SYS, CACHE_KEY_ALL)?.get() as? MutableList<SysDic>
+            cached?.let {
+                val idx = it.indexOfFirst { it.id == data.id }
+                if (idx != -1) {
+                    it[idx] = data
+                }
+                RedisCacheUtil.put(CACHEKEYS.SYS, CACHE_KEY_ALL, it)
             }
-            CacheUtil.put(CACHEKEYS.SYS, CACHE_KEY_ALL, it)
         }
         return data
     }
@@ -95,28 +106,32 @@ class SysDicServiceImpl : ServiceImpl<SysDicMapper, SysDic>(), ISysDicService, C
 
     @ZenTransactional
     override fun insertCacheable(data: SysDic) {
-        if (baseMapper.insert(data) == 0) {
-            throw ZenException(ZenExceptionEnum.BIZ_INSERT_ERROR)
-        }
-        val cached = CacheUtil.get(CACHEKEYS.SYS, CACHE_KEY_ALL)?.get() as? MutableList<SysDic>
-        cached?.let {
-            it.add(data)
-            CacheUtil.put(CACHEKEYS.SYS, CACHE_KEY_ALL, it)
+        if (PlatformUtil.getPlatform() == PLATFORM.SYSTEM) {
+            if (baseMapper.insert(data) == 0) {
+                throw ZenException(ZenExceptionEnum.BIZ_INSERT_ERROR)
+            }
+            val cached = RedisCacheUtil.get(CACHEKEYS.SYS, CACHE_KEY_ALL)?.get() as? MutableList<SysDic>
+            cached?.let {
+                it.add(data)
+                RedisCacheUtil.put(CACHEKEYS.SYS, CACHE_KEY_ALL, it)
+            }
         }
     }
 
     @ZenTransactional
     override fun physicalDeleteCacheable(id: Long) {
-        if (baseMapper.physicalDelete(EntityWrapper<SysDic>().eq("id", id)) <= 0) {
-            throw ZenException(ZenExceptionEnum.BIZ_DELETE_ERROR)
-        }
-        //
-        val cached = CacheUtil.get(CACHEKEYS.SYS, CACHE_KEY_ALL)?.get() as? MutableList<SysDic>
-        cached?.let {
-            it.removeIf {
-                it.id == id
+        if (PlatformUtil.getPlatform() == PLATFORM.SYSTEM) {
+            if (baseMapper.physicalDelete(EntityWrapper<SysDic>().eq("id", id)) <= 0) {
+                throw ZenException(ZenExceptionEnum.BIZ_DELETE_ERROR)
+            }
+            //
+            val cached = RedisCacheUtil.get(CACHEKEYS.SYS, CACHE_KEY_ALL)?.get() as? MutableList<SysDic>
+            cached?.let {
+                it.removeIf {
+                    it.id == id
+                }
+                RedisCacheUtil.put(CACHEKEYS.SYS, CACHE_KEY_ALL, it)
             }
-            CacheUtil.put(CACHEKEYS.SYS, CACHE_KEY_ALL, it)
         }
     }
 }

zen-api/src/main/kotlin/com/gxzc/zen/api/sys/service/impl/SysParamServiceImpl.kt

@@ -6,11 +6,15 @@ import com.gxzc.zen.api.sys.mapper.SysParamMapper
 import com.gxzc.zen.api.sys.model.SysParam
 import com.gxzc.zen.api.sys.service.ISysParamService
 import com.gxzc.zen.common.contants.CACHEKEYS
+import com.gxzc.zen.common.contants.PLATFORM
 import com.gxzc.zen.common.exception.ZenException
 import com.gxzc.zen.common.exception.ZenExceptionEnum
-import com.gxzc.zen.common.util.CacheUtil
+import com.gxzc.zen.common.properties.PlatformProperties
+import com.gxzc.zen.common.util.RedisCacheUtil
+import com.gxzc.zen.common.util.PlatformUtil
 import com.gxzc.zen.orm.annotation.ZenTransactional
 import org.slf4j.LoggerFactory
+import org.springframework.beans.factory.annotation.Autowired
 import org.springframework.boot.CommandLineRunner
 import org.springframework.stereotype.Service
 
@@ -30,18 +34,23 @@ class SysParamServiceImpl : ServiceImpl<SysParamMapper, SysParam>(), ISysParamSe
         const val CACHE_KEY_ALL = "param_all"
     }
 
+    @Autowired
+    private lateinit var platformProperties: PlatformProperties
+
     override fun run(vararg args: String?) {
         logger.debug("${this::class.simpleName} init.")
         getListCacheable()
     }
 
     override fun getListCacheable(): MutableList<SysParam> {
-        val cached = CacheUtil.get(CACHEKEYS.SYS, CACHE_KEY_ALL)?.get() as? MutableList<SysParam>
+        val cached = RedisCacheUtil.get(CACHEKEYS.SYS, CACHE_KEY_ALL)?.get() as? MutableList<SysParam>
         if (cached != null) {
             return cached
         }
         val ret = baseMapper.selectByParams(null)
-        CacheUtil.put(CACHEKEYS.SYS, CACHE_KEY_ALL, ret)
+        if (PlatformUtil.getPlatform(platformProperties) == PLATFORM.SYSTEM) {
+            RedisCacheUtil.put(CACHEKEYS.SYS, CACHE_KEY_ALL, ret)
+        }
         return ret
     }
 
@@ -64,15 +73,17 @@ class SysParamServiceImpl : ServiceImpl<SysParamMapper, SysParam>(), ISysParamSe
 
     @ZenTransactional
     override fun modify(data: SysParam): SysParam {
-        baseMapper.updateNoLogic(data, EntityWrapper<SysParam>().eq("id", data.id))
-        // 更新缓存
-        val cached = CacheUtil.get(CACHEKEYS.SYS, CACHE_KEY_ALL)?.get() as? MutableList<SysParam>
-        cached?.let {
-            val idx = it.indexOfFirst { it.id == data.id }
-            if (idx != -1) {
-                it[idx] = data
+        if (PlatformUtil.getPlatform() == PLATFORM.SYSTEM) {
+            baseMapper.updateNoLogic(data, EntityWrapper<SysParam>().eq("id", data.id))
+            // 更新缓存
+            val cached = RedisCacheUtil.get(CACHEKEYS.SYS, CACHE_KEY_ALL)?.get() as? MutableList<SysParam>
+            cached?.let {
+                val idx = it.indexOfFirst { it.id == data.id }
+                if (idx != -1) {
+                    it[idx] = data
+                }
+                RedisCacheUtil.put(CACHEKEYS.SYS, CACHE_KEY_ALL, it)
             }
-            CacheUtil.put(CACHEKEYS.SYS, CACHE_KEY_ALL, it)
         }
         return data
     }
@@ -95,28 +106,32 @@ class SysParamServiceImpl : ServiceImpl<SysParamMapper, SysParam>(), ISysParamSe
 
     @ZenTransactional
     override fun insertCacheable(data: SysParam) {
-        if (baseMapper.insert(data) == 0) {
-            throw ZenException(ZenExceptionEnum.BIZ_INSERT_ERROR)
-        }
-        val cached = CacheUtil.get(CACHEKEYS.SYS, CACHE_KEY_ALL)?.get() as? MutableList<SysParam>
-        cached?.let {
-            it.add(data)
-            CacheUtil.put(CACHEKEYS.SYS, CACHE_KEY_ALL, it)
+        if (PlatformUtil.getPlatform() == PLATFORM.SYSTEM) {
+            if (baseMapper.insert(data) == 0) {
+                throw ZenException(ZenExceptionEnum.BIZ_INSERT_ERROR)
+            }
+            val cached = RedisCacheUtil.get(CACHEKEYS.SYS, CACHE_KEY_ALL)?.get() as? MutableList<SysParam>
+            cached?.let {
+                it.add(data)
+                RedisCacheUtil.put(CACHEKEYS.SYS, CACHE_KEY_ALL, it)
+            }
         }
     }
 
     @ZenTransactional
     override fun physicalDeleteCacheable(id: Long) {
-        if (baseMapper.physicalDelete(EntityWrapper<SysParam>().eq("id", id)) <= 0) {
-            throw ZenException(ZenExceptionEnum.BIZ_DELETE_ERROR)
-        }
-        //
-        val cached = CacheUtil.get(CACHEKEYS.SYS, CACHE_KEY_ALL)?.get() as? MutableList<SysParam>
-        cached?.let {
-            it.removeIf {
-                it.id == id
+        if (PlatformUtil.getPlatform() == PLATFORM.SYSTEM) {
+            if (baseMapper.physicalDelete(EntityWrapper<SysParam>().eq("id", id)) <= 0) {
+                throw ZenException(ZenExceptionEnum.BIZ_DELETE_ERROR)
+            }
+            //
+            val cached = RedisCacheUtil.get(CACHEKEYS.SYS, CACHE_KEY_ALL)?.get() as? MutableList<SysParam>
+            cached?.let {
+                it.removeIf {
+                    it.id == id
+                }
+                RedisCacheUtil.put(CACHEKEYS.SYS, CACHE_KEY_ALL, it)
             }
-            CacheUtil.put(CACHEKEYS.SYS, CACHE_KEY_ALL, it)
         }
     }
 }

zen-api/src/main/kotlin/com/gxzc/zen/api/sys/service/impl/SysPermissionServiceImpl.kt

@@ -23,7 +23,7 @@ class SysPermissionServiceImpl : ISysPermissionService {
     @Autowired
     private lateinit var sysUserRoleService: ISysUserRoleService
 
-    @Cacheable(value = [CACHEKEYS.USER_PERM], key = "'uid_' + #id")
+    @Cacheable(value = [CACHEKEYS.USER_PERM], key = "'${CACHEKEYS.USER_PERM}:uid_' + #id")
     override fun getPermissionSetByUserId(id: Long): HashSet<String> {
         val roleList = sysUserRoleService.getUserRoleListByUserId(id)
         val permIds = linkedSetOf<String>()

zen-api/src/main/kotlin/com/gxzc/zen/api/sys/service/impl/SysUserRoleServiceImpl.kt

@@ -24,7 +24,7 @@ class SysUserRoleServiceImpl : ServiceImpl<SysUserRoleMapper, SysUserRole>(), IS
     @Autowired
     private lateinit var sysRoleService: ISysRoleService
 
-    @Cacheable(CACHEKEYS.USER_ROLE, key = "'uid_'+ #id")
+    @Cacheable(CACHEKEYS.USER_ROLE, key = "'${CACHEKEYS.USER_ROLE}:uid_'+ #id")
     override fun getUserRoleListByUserId(id: Long): MutableList<SysRole> {
         return baseMapper.selectUserRoleListByUserId(id)
     }

zen-api/src/main/kotlin/com/gxzc/zen/api/sys/service/impl/SysUserServiceImpl.kt

@@ -6,11 +6,15 @@ import com.gxzc.zen.api.sys.mapper.SysUserMapper
 import com.gxzc.zen.api.sys.model.SysUser
 import com.gxzc.zen.api.sys.service.ISysUserService
 import com.gxzc.zen.common.contants.CACHEKEYS
+import com.gxzc.zen.common.contants.PLATFORM
 import com.gxzc.zen.common.exception.ZenException
 import com.gxzc.zen.common.exception.ZenExceptionEnum
-import com.gxzc.zen.common.util.CacheUtil
+import com.gxzc.zen.common.properties.PlatformProperties
+import com.gxzc.zen.common.util.RedisCacheUtil
+import com.gxzc.zen.common.util.PlatformUtil
 import com.gxzc.zen.orm.annotation.ZenTransactional
 import org.slf4j.LoggerFactory
+import org.springframework.beans.factory.annotation.Autowired
 import org.springframework.boot.CommandLineRunner
 import org.springframework.stereotype.Service
 
@@ -30,18 +34,23 @@ class SysUserServiceImpl : ServiceImpl<SysUserMapper, SysUser>(), ISysUserServic
         const val CACHE_KEY_ALL = "all"
     }
 
+    @Autowired
+    private lateinit var platformProperties: PlatformProperties
+
     override fun run(vararg args: String?) {
         logger.debug("${this::class.simpleName} init.")
         getListCacheable()
     }
 
     override fun getListCacheable(): MutableList<SysUser> {
-        val cached = CacheUtil.get(CACHEKEYS.USER, CACHE_KEY_ALL)?.get() as? MutableList<SysUser>
+        val cached = RedisCacheUtil.get(CACHEKEYS.USER, CACHE_KEY_ALL)?.get() as? MutableList<SysUser>
         if (cached != null) {
             return cached
         }
         val ret = baseMapper.selectByParams(null)
-        CacheUtil.put(CACHEKEYS.USER, CACHE_KEY_ALL, ret)
+        if (PlatformUtil.getPlatform(platformProperties) == PLATFORM.SYSTEM) {
+            RedisCacheUtil.put(CACHEKEYS.USER, CACHE_KEY_ALL, ret)
+        }
         return ret
     }
 
@@ -59,43 +68,49 @@ class SysUserServiceImpl : ServiceImpl<SysUserMapper, SysUser>(), ISysUserServic
 
     @ZenTransactional
     override fun insertCacheable(entity: SysUser) {
-        if (baseMapper.insert(entity) == 0) {
-            throw ZenException(ZenExceptionEnum.BIZ_INSERT_ERROR)
-        }
-        val cached = CacheUtil.get(CACHEKEYS.USER, CACHE_KEY_ALL)?.get() as? MutableList<SysUser>
-        cached?.let {
-            it.add(entity)
-            CacheUtil.put(CACHEKEYS.SYS, CACHE_KEY_ALL, it)
+        if (PlatformUtil.getPlatform() == PLATFORM.SYSTEM) {
+            if (baseMapper.insert(entity) == 0) {
+                throw ZenException(ZenExceptionEnum.BIZ_INSERT_ERROR)
+            }
+            val cached = RedisCacheUtil.get(CACHEKEYS.USER, CACHE_KEY_ALL)?.get() as? MutableList<SysUser>
+            cached?.let {
+                it.add(entity)
+                RedisCacheUtil.put(CACHEKEYS.SYS, CACHE_KEY_ALL, it)
+            }
         }
     }
 
     @ZenTransactional
     override fun modify(entity: SysUser): SysUser {
-        baseMapper.updateNoLogic(entity, EntityWrapper<SysUser>().eq("id", entity.id))
-        // 更新缓存
-        val cached = CacheUtil.get(CACHEKEYS.USER, CACHE_KEY_ALL)?.get() as? MutableList<SysUser>
-        cached?.let {
-            val idx = it.indexOfFirst { it.id == entity.id }
-            if (idx != -1) {
-                it[idx] = entity
+        if (PlatformUtil.getPlatform() == PLATFORM.SYSTEM) {
+            baseMapper.updateNoLogic(entity, EntityWrapper<SysUser>().eq("id", entity.id))
+            // 更新缓存
+            val cached = RedisCacheUtil.get(CACHEKEYS.USER, CACHE_KEY_ALL)?.get() as? MutableList<SysUser>
+            cached?.let {
+                val idx = it.indexOfFirst { it.id == entity.id }
+                if (idx != -1) {
+                    it[idx] = entity
+                }
+                RedisCacheUtil.put(CACHEKEYS.SYS, CACHE_KEY_ALL, it)
             }
-            CacheUtil.put(CACHEKEYS.SYS, CACHE_KEY_ALL, it)
         }
         return entity
     }
 
     @ZenTransactional
     override fun physicalDeleteCacheable(id: Long) {
-        if (baseMapper.physicalDelete(EntityWrapper<SysUser>().eq("id", id)) <= 0) {
-            throw ZenException(ZenExceptionEnum.BIZ_DELETE_ERROR)
-        }
-        //
-        val cached = CacheUtil.get(CACHEKEYS.USER, CACHE_KEY_ALL)?.get() as? MutableList<SysUser>
-        cached?.let {
-            it.removeIf {
-                it.id == id
+        if (PlatformUtil.getPlatform() == PLATFORM.SYSTEM) {
+            if (baseMapper.physicalDelete(EntityWrapper<SysUser>().eq("id", id)) <= 0) {
+                throw ZenException(ZenExceptionEnum.BIZ_DELETE_ERROR)
+            }
+            //
+            val cached = RedisCacheUtil.get(CACHEKEYS.USER, CACHE_KEY_ALL)?.get() as? MutableList<SysUser>
+            cached?.let {
+                it.removeIf {
+                    it.id == id
+                }
+                RedisCacheUtil.put(CACHEKEYS.SYS, CACHE_KEY_ALL, it)
             }
-            CacheUtil.put(CACHEKEYS.SYS, CACHE_KEY_ALL, it)
         }
     }
 }

zen-core/src/main/kotlin/com/gxzc/zen/common/config/cache/caffeine/CacheConfig.kt → zen-core/src/main/kotlin/com/gxzc/zen/common/config/cache/caffeine/CaffeineConfig.kt

@@ -20,7 +20,7 @@ import java.util.concurrent.TimeUnit
 @EnableCaching
 @ConfigurationProperties(prefix = "cache.caffeine")
 @ConditionalOnProperty(prefix = "spring.cache", name = ["type"], havingValue = "caffeine")
-class CacheConfig {
+class CaffeineConfig {
 
     var cacheSpecs: Map<String, CacheSpec>? = null
 

zen-core/src/main/kotlin/com/gxzc/zen/common/config/cache/redis/RedisKeyGenerator.kt

@@ -0,0 +1,22 @@
+package com.gxzc.zen.common.config.cache.redis
+
+/**
+ * Redis key 生成器
+ * @author NorthLan
+ * @date 2018/3/29
+ * @url https://noahlan.com
+ */
+object RedisKeyGenerator {
+    private const val SEPARATOR = ":"
+
+    /**
+     * 根据传入的keys组合key
+     */
+    fun joinToString(vararg keys: String): String {
+        return if (keys.isEmpty()) {
+            ""
+        } else {
+            keys.joinToString(SEPARATOR)
+        }
+    }
+}

zen-core/src/main/kotlin/com/gxzc/zen/common/contants/PLATFORM.kt

@@ -12,5 +12,17 @@ enum class PLATFORM(val id: Int) {
     RECEIVE(2),
     SAVE(3),
     MANAGER(4),
-    UTILIZATION(5)
+    UTILIZATION(5);
+
+    companion object {
+        fun intValueOf(id: Int): PLATFORM {
+            var ret = values().find {
+                it.id == id
+            }
+            if (ret == null) {
+                ret = COMMON
+            }
+            return ret
+        }
+    }
 }

zen-core/src/main/kotlin/com/gxzc/zen/common/properties/PlatformProperties.kt

@@ -1,6 +1,7 @@
 package com.gxzc.zen.common.properties
 
 import org.springframework.boot.context.properties.ConfigurationProperties
+import org.springframework.stereotype.Component
 
 /**
  * 平台配置类
@@ -8,7 +9,8 @@ import org.springframework.boot.context.properties.ConfigurationProperties
  * @date 2018/2/6
  * @url https://noahlan.com
  */
+@Component
 @ConfigurationProperties(prefix = "platform")
-data class PlatformProperties(
-        var id: String
-)
+class PlatformProperties {
+    var id: Int? = null
+}

zen-core/src/main/kotlin/com/gxzc/zen/common/util/CacheUtil.kt

@@ -1,34 +0,0 @@
-package com.gxzc.zen.common.util
-
-import org.springframework.cache.Cache
-import org.springframework.cache.CacheManager
-import kotlin.reflect.KClass
-
-/**
- * 缓存工具类
- * @author NorthLan at 2018/2/8
- */
-object CacheUtil {
-    private val cacheManager = SpringContextHolder.getBean(CacheManager::class.java)
-
-    fun getCahce(key: String): Cache? {
-        return cacheManager.getCache(key)
-    }
-
-    fun <T : Any> get(cacheKey: String, key: Any, type: KClass<T>): T? {
-        return getCahce(cacheKey)?.get(key, type.java)
-    }
-
-    fun get(cacheKey: String, key: Any): Cache.ValueWrapper? {
-        return getCahce(cacheKey)?.get(key)
-    }
-
-    fun put(cacheKey: String, key: Any, value: Any) {
-        getCahce(cacheKey)?.put(key, value)
-
-    }
-
-    fun putIfAbsent(cacheKey: String, key: Any, value: Any) {
-        getCahce(cacheKey)?.putIfAbsent(key, value)
-    }
-}

zen-core/src/main/kotlin/com/gxzc/zen/common/util/PlatformUtil.kt

@@ -1,5 +1,6 @@
 package com.gxzc.zen.common.util
 
+import com.gxzc.zen.common.contants.PLATFORM
 import com.gxzc.zen.common.properties.PlatformProperties
 
 /**
@@ -9,10 +10,22 @@ import com.gxzc.zen.common.properties.PlatformProperties
  * @url https://noahlan.com
  */
 object PlatformUtil {
-    private val properties: PlatformProperties? = SpringContextHolder.getBean(PlatformProperties::class.java)
+    private val properties = SpringContextHolder.getBean(PlatformProperties::class.java)
 
-    fun getPlatformId(): String? {
-        return properties?.id
+    fun getPlatformId(): Int {
+        return properties.id!!
+    }
+
+    fun getPlatform(id: Int): PLATFORM {
+        return PLATFORM.intValueOf(id)
+    }
+
+    fun getPlatform(): PLATFORM {
+        return getPlatform(getPlatformId())
+    }
+
+    fun getPlatform(properties: PlatformProperties): PLATFORM {
+        return getPlatform(properties.id!!)
     }
 
     fun getProperties(): PlatformProperties? {

zen-core/src/main/kotlin/com/gxzc/zen/common/util/RedisCacheUtil.kt

@@ -0,0 +1,35 @@
+package com.gxzc.zen.common.util
+
+import com.gxzc.zen.common.config.cache.redis.RedisKeyGenerator
+import org.springframework.cache.Cache
+import org.springframework.cache.CacheManager
+import kotlin.reflect.KClass
+
+/**
+ * 缓存工具类 适用于 Redis
+ * @author NorthLan at 2018/2/8
+ */
+object RedisCacheUtil {
+    private val cacheManager = SpringContextHolder.getBean(CacheManager::class.java)
+
+    fun getCahce(key: String): Cache? {
+        return cacheManager.getCache(key)
+    }
+
+    fun <T : Any> get(cacheKey: String, key: String, type: KClass<T>): T? {
+        return getCahce(cacheKey)?.get(RedisKeyGenerator.joinToString(cacheKey, key), type.java)
+    }
+
+    fun get(cacheKey: String, key: String): Cache.ValueWrapper? {
+        return getCahce(cacheKey)?.get(RedisKeyGenerator.joinToString(cacheKey, key))
+    }
+
+    fun put(cacheKey: String, key: String, value: Any) {
+        getCahce(cacheKey)?.put(RedisKeyGenerator.joinToString(cacheKey, key), value)
+
+    }
+
+    fun putIfAbsent(cacheKey: String, key: String, value: Any) {
+        getCahce(cacheKey)?.putIfAbsent(RedisKeyGenerator.joinToString(cacheKey, key), value)
+    }
+}