From d2048c247c446be08598abf8e1bc11a4ea77be32 Mon Sep 17 00:00:00 2001
From: luqingyang <lqy5492@163.com>
Date: 星期三, 25 十月 2023 16:41:49 +0800
Subject: [PATCH] Merge remote-tracking branch 'origin/master'
---
consum-base/src/main/java/com/consum/base/cache/RedisFinSysTenantUserCache.java | 82 +++++++++++++++++++++++++++++++++++++++++
1 files changed, 82 insertions(+), 0 deletions(-)
diff --git a/consum-base/src/main/java/com/consum/base/cache/RedisFinSysTenantUserCache.java b/consum-base/src/main/java/com/consum/base/cache/RedisFinSysTenantUserCache.java
new file mode 100644
index 0000000..3ad382f
--- /dev/null
+++ b/consum-base/src/main/java/com/consum/base/cache/RedisFinSysTenantUserCache.java
@@ -0,0 +1,82 @@
+package com.consum.base.cache;
+
+
+import com.consum.base.Constants;
+import com.consum.base.FinSysTenantUserCacheProvider;
+import com.consum.base.service.FinSysTenantUserServiceImpl;
+import com.consum.model.po.FinSysTenantUser;
+import com.walker.support.redis.cache.RedisCacheProvider;
+
+/**
+ * Redis瀹炵幇鐨勫悗鍙扮櫥褰曠敤鎴�
+ * @author 鐜嬫兜
+ * @date 2023-07-18
+ */
+public class RedisFinSysTenantUserCache extends RedisCacheProvider<FinSysTenantUser> implements FinSysTenantUserCacheProvider {
+
+ public RedisFinSysTenantUserCache(){
+ this.setUseRedis(true);
+ this.setLoadPage(false);
+ }
+
+ @Override
+ public FinSysTenantUser get(String userId) {
+ FinSysTenantUser finSysTenantUser = this.getCacheData(userId);
+ if(finSysTenantUser == null){
+ finSysTenantUser = this.finSysTenantUserService.queryOneByUserId(userId);
+ if(finSysTenantUser == null){
+ logger.warn("浠庢暟鎹簱鏈煡璇㈠埌鐢ㄦ埛锛屾棤娉曠紦瀛橈紝userId = {}", userId);
+ return null;
+ }
+ this.putCacheData(userId, finSysTenantUser);
+ }
+ return finSysTenantUser;
+ }
+
+ @Override
+ public void save(FinSysTenantUser e) {
+ this.putCacheData(String.valueOf(e.getSysUserId()), e);
+ this.putCacheData(String.valueOf(e.getId()), e);
+ }
+
+ @Override
+ public void update(FinSysTenantUser e) {
+ this.updateCacheData(String.valueOf(e.getSysUserId()), e);
+ this.updateCacheData(String.valueOf(e.getId()), e);
+ }
+
+ @Override
+ public void remove(String userId) {
+ this.removeCacheData(userId);
+ }
+
+ @Override
+ public FinSysTenantUser getByUserId(String userId) {
+ FinSysTenantUser finSysTenantUser = this.getCacheData(userId);
+ if(finSysTenantUser == null){
+ finSysTenantUser = this.finSysTenantUserService.queryOneById(userId);
+ if(finSysTenantUser == null){
+ logger.warn("浠庢暟鎹簱鏈煡璇㈠埌鐢ㄦ埛锛屾棤娉曠紦瀛橈紝userId = {}", userId);
+ return null;
+ }
+ this.putCacheData(userId, finSysTenantUser);
+ }
+ return finSysTenantUser;
+ }
+
+ @Override
+ public String getProviderName() {
+ return Constants.CACHE_NAME_FIN_TENANT_USER;
+ }
+
+ @Override
+ public Class<?> getProviderType() {
+ return FinSysTenantUser.class;
+ }
+
+ public void setFinSysTenantUserService(FinSysTenantUserServiceImpl finSysTenantUserService) {
+ this.finSysTenantUserService = finSysTenantUserService;
+ }
+
+ private FinSysTenantUserServiceImpl finSysTenantUserService;
+}
--
Gitblit v1.9.1