From a2ea437fedc7a89a8303dc46a349e8ebb5e4572a Mon Sep 17 00:00:00 2001
From: 13693261870 <252740454@qq.com>
Date: 星期五, 06 十二月 2024 14:15:28 +0800
Subject: [PATCH] 1

---
 se-modules/se-system/pom.xml                                                       |    7 +++
 se-modules/se-system/src/main/java/com/se/system/service/impl/IsimUserService.java |    6 ++
 se-modules/se-system/src/main/java/com/se/system/utils/CaffeineUtils.java          |   81 ++++++++++++++++++++++++++++++++++++++++
 se-modules/se-system/src/main/java/com/se/system/service/impl/SyncUserService.java |    5 ++
 se-modules/se-system/src/main/java/com/se/system/utils/WebUtils.java               |    5 ++
 5 files changed, 102 insertions(+), 2 deletions(-)

diff --git a/se-modules/se-system/pom.xml b/se-modules/se-system/pom.xml
index 5a727b5..d6142f2 100644
--- a/se-modules/se-system/pom.xml
+++ b/se-modules/se-system/pom.xml
@@ -123,6 +123,13 @@
                 </exclusion>
             </exclusions>
         </dependency>
+
+        <!--Caffeine-->
+        <dependency>
+            <groupId>com.github.ben-manes.caffeine</groupId>
+            <artifactId>caffeine</artifactId>
+            <version>2.9.3</version>
+        </dependency>
     </dependencies>
 
     <build>
diff --git a/se-modules/se-system/src/main/java/com/se/system/service/impl/IsimUserService.java b/se-modules/se-system/src/main/java/com/se/system/service/impl/IsimUserService.java
index d908f46..efe11a3 100644
--- a/se-modules/se-system/src/main/java/com/se/system/service/impl/IsimUserService.java
+++ b/se-modules/se-system/src/main/java/com/se/system/service/impl/IsimUserService.java
@@ -1,15 +1,19 @@
 package com.se.system.service.impl;
 
 import com.se.system.api.domain.SysUser;
+import com.se.system.utils.WebUtils;
 import lombok.extern.slf4j.Slf4j;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 import org.springframework.stereotype.Service;
 
 import java.util.List;
 
-@Slf4j
 @Service
 @SuppressWarnings("ALL")
 public class IsimUserService {
+    private static final Logger log = LoggerFactory.getLogger(IsimUserService.class);
+
     public void insertUser(SysUser user) {
         try {
             System.out.println("insertUser");
diff --git a/se-modules/se-system/src/main/java/com/se/system/service/impl/SyncUserService.java b/se-modules/se-system/src/main/java/com/se/system/service/impl/SyncUserService.java
index 7d88aba..8a407bb 100644
--- a/se-modules/se-system/src/main/java/com/se/system/service/impl/SyncUserService.java
+++ b/se-modules/se-system/src/main/java/com/se/system/service/impl/SyncUserService.java
@@ -3,6 +3,8 @@
 import com.se.system.api.domain.SysUser;
 import lombok.SneakyThrows;
 import lombok.extern.slf4j.Slf4j;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 import org.springframework.stereotype.Service;
 
 import javax.annotation.Resource;
@@ -11,10 +13,11 @@
 import java.util.concurrent.ExecutorService;
 import java.util.concurrent.Executors;
 
-@Slf4j
 @Service
 @SuppressWarnings("ALL")
 public class SyncUserService {
+    private static final Logger log = LoggerFactory.getLogger(SyncUserService.class);
+
     @Resource
     IsimUserService isimUserService;
 
diff --git a/se-modules/se-system/src/main/java/com/se/system/utils/CaffeineUtils.java b/se-modules/se-system/src/main/java/com/se/system/utils/CaffeineUtils.java
new file mode 100644
index 0000000..921640e
--- /dev/null
+++ b/se-modules/se-system/src/main/java/com/se/system/utils/CaffeineUtils.java
@@ -0,0 +1,81 @@
+package com.se.system.utils;
+
+import com.github.benmanes.caffeine.cache.Cache;
+import com.github.benmanes.caffeine.cache.Caffeine;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import java.math.BigInteger;
+import java.security.MessageDigest;
+import java.util.List;
+import java.util.concurrent.TimeUnit;
+
+@SuppressWarnings("ALL")
+public class CaffeineUtils {
+    private static Cache<String, Object> cache;
+
+    private static final Logger log = LoggerFactory.getLogger(CaffeineUtils.class);
+
+    public static void init(Integer cacheTime) {
+        cache = Caffeine.newBuilder()
+                .initialCapacity(16)
+                .maximumSize(4096)
+                .expireAfterWrite(cacheTime, TimeUnit.MINUTES)
+                .build();
+    }
+
+    public static Object get(String key) {
+        return cache.getIfPresent(key);
+    }
+
+    public static void put(String key, Object obj) {
+        cache.put(key, obj);
+    }
+
+    public static void remove(String key) {
+        cache.invalidate(key);
+    }
+
+    public static void clear() {
+        cache.invalidateAll();
+    }
+
+    public static <T> List<T> getListByKey(String key) {
+        Object obj = get(key);
+        if (obj instanceof List<?>) {
+            return (List<T>) obj;
+        }
+
+        return null;
+    }
+
+    public static <T> void putListByKey(String key, List<T> list) {
+        if (null != list && list.size() > 0) {
+            put(key, list);
+        }
+    }
+
+    public static String getMd5(String str) {
+        if (StringUtils.isEmpty(str)) {
+            return null;
+        }
+
+        try {
+            MessageDigest md5 = MessageDigest.getInstance("MD5");
+            md5.update(str.getBytes());
+            byte[] byteArray = md5.digest();
+
+            BigInteger bigInt = new BigInteger(1, byteArray);
+
+            String result = bigInt.toString(16);
+
+            while (result.length() < 32) {
+                result = "0" + result;
+            }
+
+            return result;
+        } catch (Exception e) {
+            return null;
+        }
+    }
+}
diff --git a/se-modules/se-system/src/main/java/com/se/system/utils/WebUtils.java b/se-modules/se-system/src/main/java/com/se/system/utils/WebUtils.java
index 6c74369..a795c06 100644
--- a/se-modules/se-system/src/main/java/com/se/system/utils/WebUtils.java
+++ b/se-modules/se-system/src/main/java/com/se/system/utils/WebUtils.java
@@ -203,6 +203,11 @@
         return ctx.getRealPath("/" + path);
     }
 
+    public static boolean writeStr2Page(int status, HttpServletResponse res, String str) {
+        res.setStatus(status);
+        return writeStr2Page(res, str);
+    }
+
     public static boolean writeStr2Page(HttpServletResponse res, String str) {
         try {
             res.setContentType("application/json;charset=UTF-8");

--
Gitblit v1.9.3