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/LocalFinSysTenantUserCache.java | 67 +++++++++++++++++++++++++++++++++ 1 files changed, 67 insertions(+), 0 deletions(-) diff --git a/consum-base/src/main/java/com/consum/base/cache/LocalFinSysTenantUserCache.java b/consum-base/src/main/java/com/consum/base/cache/LocalFinSysTenantUserCache.java new file mode 100644 index 0000000..f605002 --- /dev/null +++ b/consum-base/src/main/java/com/consum/base/cache/LocalFinSysTenantUserCache.java @@ -0,0 +1,67 @@ +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.cache.AbstractCacheProvider; +import com.walker.cache.Cache; +import com.walker.infrastructure.utils.StringUtils; + +import java.util.List; + +public class LocalFinSysTenantUserCache extends AbstractCacheProvider<FinSysTenantUser> implements FinSysTenantUserCacheProvider { + + @Override + public FinSysTenantUser get(String userId) { + return this.getCacheData(userId); + } + + @Override + public void save(FinSysTenantUser e) { + this.putCacheData(String.valueOf(e.getSysUserId()), e); + } + + @Override + public void update(FinSysTenantUser e) { + this.updateCacheData(String.valueOf(e.getSysUserId()), e); + } + + @Override + public void remove(String userId) { + this.removeCacheData(userId); + } + + @Override + public FinSysTenantUser getByUserId(String userId) { + return this.getCacheData(userId); + } + + @Override + protected int loadDataToCache(Cache cache) { + List<FinSysTenantUser> hosts = this.finSysTenantUserService.selectAll(new FinSysTenantUser()); + if(!StringUtils.isEmptyList(hosts)){ + for(FinSysTenantUser h : hosts){ + cache.put(String.valueOf(h.getSysUserId()), h); + } + return hosts.size(); + } + return 0; + } + + @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