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/LocalFinOrgCache.java |   68 ++++++++++++++++++++++++++++++++++
 1 files changed, 68 insertions(+), 0 deletions(-)

diff --git a/consum-base/src/main/java/com/consum/base/cache/LocalFinOrgCache.java b/consum-base/src/main/java/com/consum/base/cache/LocalFinOrgCache.java
new file mode 100644
index 0000000..b5ac8a2
--- /dev/null
+++ b/consum-base/src/main/java/com/consum/base/cache/LocalFinOrgCache.java
@@ -0,0 +1,68 @@
+package com.consum.base.cache;
+
+import com.consum.base.Constants;
+import com.consum.base.FinOrgCacheProvider;
+import com.consum.base.service.FinOrgServiceImpl;
+import com.consum.model.po.FinSysOrg;
+import com.walker.cache.AbstractCacheProvider;
+import com.walker.cache.Cache;
+import com.walker.infrastructure.utils.StringUtils;
+
+import java.util.List;
+
+/**
+ * 鏈湴杩愮淮鏈烘瀯缂撳瓨瀹氫箟銆�
+ * <p>娉ㄦ剰锛氬彧鏈夊湪娴嬭瘯寮�鍙戜腑浣跨敤璇ュ璞★紝鐢熶骇鐜璇烽厤缃负Redis鏂瑰紡銆�</p>
+ * @author 鏃跺厠鑻�
+ * @date 2023-07-05
+ */
+public class LocalFinOrgCache extends AbstractCacheProvider<FinSysOrg> implements FinOrgCacheProvider {
+
+    @Override
+    public FinSysOrg get(String orgCode) {
+        return this.getCacheData(orgCode);
+    }
+
+    @Override
+    public void save(FinSysOrg e) {
+        this.putCacheData(e.getOrgCode(), e);
+    }
+
+    @Override
+    public void update(FinSysOrg e) {
+        this.updateCacheData(e.getOrgCode(), e);
+    }
+
+    @Override
+    public void remove(String orgCode) {
+        this.removeCacheData(orgCode);
+    }
+
+    @Override
+    protected int loadDataToCache(Cache cache) {
+        List<FinSysOrg> hosts = this.finOrgService.selectAll(new FinSysOrg());
+        if(!StringUtils.isEmptyList(hosts)){
+            for(FinSysOrg h : hosts){
+                cache.put(h.getOrgCode(), h);
+            }
+            return hosts.size();
+        }
+        return 0;
+    }
+
+    @Override
+    public String getProviderName() {
+        return Constants.CACHE_NAME_FIN_ORG;
+    }
+
+    @Override
+    public Class<?> getProviderType() {
+        return FinSysOrg.class;
+    }
+
+    public void setFinOrgService(FinOrgServiceImpl finOrgService) {
+        this.finOrgService = finOrgService;
+    }
+
+    private FinOrgServiceImpl finOrgService;
+}

--
Gitblit v1.9.1