From bfe51f9c2ce2181fee372ed5f9017c7af59cc896 Mon Sep 17 00:00:00 2001
From: zhang <zc857179121@qq.com>
Date: 星期一, 01 九月 2025 12:49:55 +0800
Subject: [PATCH] 1

---
 zy-acs-manager/src/main/java/com/zy/acs/manager/system/service/impl/ConfigServiceImpl.java |   78 +++++++++++++++++++++++++++++++++++----
 1 files changed, 70 insertions(+), 8 deletions(-)

diff --git a/zy-acs-manager/src/main/java/com/zy/acs/manager/system/service/impl/ConfigServiceImpl.java b/zy-acs-manager/src/main/java/com/zy/acs/manager/system/service/impl/ConfigServiceImpl.java
index 2f65707..ba0d1e8 100644
--- a/zy-acs-manager/src/main/java/com/zy/acs/manager/system/service/impl/ConfigServiceImpl.java
+++ b/zy-acs-manager/src/main/java/com/zy/acs/manager/system/service/impl/ConfigServiceImpl.java
@@ -4,14 +4,18 @@
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.zy.acs.common.utils.GsonUtils;
 import com.zy.acs.framework.common.DateUtils;
+import com.zy.acs.manager.manager.enums.StatusType;
 import com.zy.acs.manager.system.entity.Config;
 import com.zy.acs.manager.system.enums.ConfigType;
 import com.zy.acs.manager.system.mapper.ConfigMapper;
 import com.zy.acs.manager.system.service.ConfigService;
 import org.springframework.stereotype.Service;
 
+import javax.annotation.PostConstruct;
 import java.util.Date;
 import java.util.List;
+import java.util.Map;
+import java.util.concurrent.ConcurrentHashMap;
 
 /**
  * Created by vincent on 8/30/2024
@@ -19,18 +23,31 @@
 @Service("configService")
 public class ConfigServiceImpl extends ServiceImpl<ConfigMapper, Config> implements ConfigService {
 
+    public static final Map<String, Config> CONFIG_CACHE = new ConcurrentHashMap<>();
+
+    @PostConstruct
+    public void init() {
+        List<Config> list = this.list(new LambdaQueryWrapper<Config>().eq(Config::getStatus, StatusType.ENABLE.val));
+        for (Config config : list) {
+            CONFIG_CACHE.put(config.getFlag(), config);
+        }
+    }
+
     @Override
     @SuppressWarnings("unchecked")
     public <T> T getVal(String key, Class<T> clazz) {
-        List<Config> list = this.list(new LambdaQueryWrapper<Config>().eq(Config::getFlag, key));
-        Config config = list.stream().findFirst().orElse(null);
-        if (null == config) {
-            return null;
+        Config config = CONFIG_CACHE.get(key);
+        if (config == null) {
+            List<Config> list = this.list(new LambdaQueryWrapper<Config>().eq(Config::getFlag, key));
+            config = list.stream().findFirst().orElse(null);
+            if (null == config) {
+                return null;
+            }
         }
         String val = config.getVal();
         switch (ConfigType.query(config.getType())) {
             case BOOLEAN:
-                if (val.equals("1") || val.trim().toUpperCase().equals("TRUE")) {
+                if (val.equals("1") || val.trim().equalsIgnoreCase("TRUE")) {
                     return (T) Boolean.TRUE;
                 }
                 return (T) Boolean.FALSE;
@@ -56,13 +73,58 @@
         }
     }
 
+
+    @Override
+    @SuppressWarnings("unchecked")
+    public <T> T getVal(String key, Class<T> clazz, T t) {
+        Config config = CONFIG_CACHE.get(key);
+        if (config == null) {
+            List<Config> list = this.list(new LambdaQueryWrapper<Config>().eq(Config::getFlag, key));
+            config = list.stream().findFirst().orElse(null);
+            if (null == config) {
+                return t;
+            }
+        }
+        String val = config.getVal();
+        switch (ConfigType.query(config.getType())) {
+            case BOOLEAN:
+                if (val.equals("1") || val.trim().equalsIgnoreCase("TRUE")) {
+                    return (T) Boolean.TRUE;
+                }
+                return (T) Boolean.FALSE;
+            case NUMBER:
+                if (clazz == Integer.class) {
+                    return (T) Integer.valueOf(val);
+                } else if (clazz == Short.class) {
+                    return (T) Short.valueOf(val);
+                } else if (clazz == Long.class) {
+                    return (T) Long.valueOf(val);
+                } else if (clazz == Double.class) {
+                    return (T) Double.valueOf(val);
+                }
+                throw new UnsupportedOperationException("Unsupported type: " + clazz.getName());
+            case STRING:
+                return (T) val;
+            case JSON:
+                return GsonUtils.fromJson(val, clazz);
+            case DATE:
+                return (T) DateUtils.convert(val);
+            default:
+                return t;
+        }
+    }
+
     @Override
     public <T> boolean setVal(String key, T val) {
-        List<Config> list = this.list(new LambdaQueryWrapper<Config>().eq(Config::getFlag, key));
-        Config config = list.stream().findFirst().orElse(null);
+        Config config = CONFIG_CACHE.get(key);
         if (config == null) {
-            return false;
+            List<Config> list = this.list(new LambdaQueryWrapper<Config>().eq(Config::getFlag, key));
+            config = list.stream().findFirst().orElse(null);
+            if (null == config) {
+                return false;
+            }
         }
+
         ConfigType configType = ConfigType.query(config.getType());
         switch (configType) {
             case BOOLEAN:

--
Gitblit v1.9.1