init_02

pom.xml

@@ -24,7 +24,7 @@
 		</dependency>
 		<dependency>
 			<groupId>org.springframework.boot</groupId>
-			<artifactId>spring-boot-starter-webflux</artifactId>
+			<artifactId>spring-boot-starter-web</artifactId>
 		</dependency>
 
 		<dependency>

src/main/java/com/scbfkj/uni/UniApplication.java

@@ -2,12 +2,14 @@ package com.scbfkj.uni;
 
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.context.annotation.EnableAspectJAutoProxy;
 
 @SpringBootApplication
+@EnableAspectJAutoProxy
 public class UniApplication {
 
-	public static void main(String[] args) {
-		SpringApplication.run(UniApplication.class, args);
-	}
+    public static void main(String[] args) {
+        SpringApplication.run(UniApplication.class, args);
+    }
 
 }

src/main/java/com/scbfkj/uni/api/LogAop.java

@@ -1,10 +1,14 @@
 package com.scbfkj.uni.api;
 
+import com.scbfkj.uni.library.UniReturnUtil;
+import jakarta.servlet.http.HttpServletRequest;
 import org.aspectj.lang.ProceedingJoinPoint;
 import org.aspectj.lang.annotation.Around;
 import org.aspectj.lang.annotation.Aspect;
 import org.aspectj.lang.annotation.Pointcut;
 import org.springframework.stereotype.Component;
+import org.springframework.web.context.request.RequestContextHolder;
+import org.springframework.web.context.request.ServletRequestAttributes;
 
 import java.util.Map;
 
@@ -17,10 +21,46 @@ public class LogAop {
 
     }
 
-    @Around("pointcut() && args(body,params)")
-    public Object invoke(ProceedingJoinPoint joinPoint, Map<String, Object> body, Map<String, String> params) {
-//        todo 待实现
-        return null;
+    @Around(value = "pointcut() && args(headers,body)", argNames = "joinPoint,headers,body")
+    public Object invoke(ProceedingJoinPoint joinPoint, Map<String, Object> headers, Map<String, Object> body) {
+//        当前时间戳
+        long beforeTime = System.currentTimeMillis();
+//        请求
+        ServletRequestAttributes requestAttributes = (ServletRequestAttributes) RequestContextHolder.currentRequestAttributes();
+//
+        HttpServletRequest request = requestAttributes.getRequest();
+        String uri = request.getRequestURI();
+        String ip = getIpAddr(request);
+//        请求参数
+        Object[] args = joinPoint.getArgs();
+//        返回结果
+        Object proceed = null;
+        try {
+            proceed = joinPoint.proceed(args);
+        } catch (Throwable e) {
+//            错误异常消息
+            proceed = UniReturnUtil.fail(e.getMessage());
+        }
+//        执行后时间戳
+        long afterTime = System.currentTimeMillis();
+//        执行时间
+        long execTime = afterTime - beforeTime;
+        System.out.println("执行时长："+execTime);
+//        返回结果
+        return proceed;
     }
 
+    public String getIpAddr(HttpServletRequest request) {
+        String ip = request.getHeader("x-forwarded-for");
+        if (ip == null || ip.length() == 0 || "unknown".equalsIgnoreCase(ip)) {
+            ip = request.getHeader("Proxy-Client-IP");
+        }
+        if (ip == null || ip.length() == 0 || "unknown".equalsIgnoreCase(ip)) {
+            ip = request.getHeader("WL-Proxy-Client-IP");
+        }
+        if (ip == null || ip.length() == 0 || "unknown".equalsIgnoreCase(ip)) {
+            ip = request.getRemoteAddr();
+        }
+        return ip;
+    }
 }

src/main/java/com/scbfkj/uni/api/SecurityApi.java

@@ -1,13 +1,13 @@
 package com.scbfkj.uni.api;
 
-import com.fasterxml.jackson.core.JsonProcessingException;
+import com.scbfkj.uni.library.UniReturnUtil;
 import org.springframework.http.ResponseEntity;
-import org.springframework.http.server.reactive.ServerHttpRequest;
 import org.springframework.web.bind.annotation.PostMapping;
 import org.springframework.web.bind.annotation.RequestBody;
 import org.springframework.web.bind.annotation.RequestHeader;
 import org.springframework.web.bind.annotation.RestController;
 
+import java.util.HashMap;
 import java.util.Map;
 
 @RestController
@@ -22,18 +22,19 @@ public class SecurityApi {
      * @return
      */
     @PostMapping("user/getToken")
-    public ResponseEntity getToken(@RequestHeader Map<String, Object> headers, @RequestBody Map<String, Object> body, ServerHttpRequest httpRequest) throws JsonProcessingException {
-        return ResponseEntity.ok(null);
+    public ResponseEntity getToken(@RequestHeader Map<String, Object> headers, @RequestBody Map<String, Object> body) throws Exception {
+        return ResponseEntity.ok(UniReturnUtil.fail("逻辑还没有实现"));
     }
 
     /**
      * 刷新appToken
      *
      * @param headers
+     * @param body
      * @return
      */
     @PostMapping("user/refreshToken")
-    public ResponseEntity refreshToken(@RequestHeader Map<String, Object> headers, ServerHttpRequest httpRequest) throws JsonProcessingException {
+    public ResponseEntity refreshToken(@RequestHeader Map<String, Object> headers, @RequestBody Map<String, Object> body) throws Exception {
         return ResponseEntity.ok(null);
     }
 
@@ -45,7 +46,7 @@ public class SecurityApi {
      * @return
      */
     @PostMapping({"user/testToken", "foxlibc/testToken"})
-    public ResponseEntity testToken(@RequestHeader Map<String, Object> headers, @RequestBody Map<String, Object> body, ServerHttpRequest httpRequest) throws JsonProcessingException {
+    public ResponseEntity testToken(@RequestHeader Map<String, Object> headers, @RequestBody Map<String, Object> body) throws Exception {
         return ResponseEntity.ok(null);
     }
 
@@ -57,7 +58,7 @@ public class SecurityApi {
      * @return
      */
     @PostMapping({"user/verifyCode", "foxlibc/verification-code"})
-    public ResponseEntity getCode(@RequestHeader Map<String, Object> headers, @RequestBody Map<String, Object> body, ServerHttpRequest httpRequest) throws JsonProcessingException {
+    public ResponseEntity getCode(@RequestHeader Map<String, Object> headers, @RequestBody Map<String, Object> body) throws Exception {
         return ResponseEntity.ok(null);
     }
 
@@ -69,7 +70,7 @@ public class SecurityApi {
      * @return
      */
     @PostMapping({"user/forceLogin", "foxlibc/force_sign"})
-    public ResponseEntity forceLogin(@RequestHeader Map<String, Object> headers, @RequestBody Map<String, Object> body, ServerHttpRequest httpRequest) throws JsonProcessingException {
+    public ResponseEntity forceLogin(@RequestHeader Map<String, Object> headers, @RequestBody Map<String, Object> body) throws Exception {
         return ResponseEntity.ok(null);
     }
 
@@ -81,7 +82,7 @@ public class SecurityApi {
      * @return
      */
     @PostMapping({"user/login", "foxlibc/sign-in"})
-    public ResponseEntity login(@RequestHeader Map<String, Object> headers, @RequestBody Map<String, Object> body, ServerHttpRequest httpRequest) throws JsonProcessingException {
+    public ResponseEntity login(@RequestHeader Map<String, Object> headers, @RequestBody Map<String, Object> body) throws Exception {
         return ResponseEntity.ok(null);
     }
 
@@ -93,7 +94,7 @@ public class SecurityApi {
      * @return
      */
     @PostMapping({"user/permissions", "foxlibc/permissions"})
-    public ResponseEntity getPermissions(@RequestHeader Map<String, Object> headers, @RequestBody Map<String, Object> body, ServerHttpRequest httpRequest) throws JsonProcessingException {
+    public ResponseEntity getPermissions(@RequestHeader Map<String, Object> headers, @RequestBody Map<String, Object> body) throws Exception {
         return ResponseEntity.ok(null);
     }
 
@@ -106,7 +107,7 @@ public class SecurityApi {
      * @return
      */
     @PostMapping({"user/changePassword", "foxlibc/reset-passwd"})
-    public ResponseEntity changePwd(@RequestHeader Map<String, Object> headers, @RequestBody Map<String, Object> body, ServerHttpRequest httpRequest) throws JsonProcessingException {
+    public ResponseEntity changePwd(@RequestHeader Map<String, Object> headers, @RequestBody Map<String, Object> body) throws Exception {
         return ResponseEntity.ok(null);
     }
 
@@ -118,7 +119,7 @@ public class SecurityApi {
      * @return
      */
     @PostMapping({"user/logOut", "foxlibc/sign-out"})
-    public ResponseEntity logOut(@RequestHeader Map<String, Object> headers, @RequestBody Map<String, Object> body, ServerHttpRequest httpRequest) throws JsonProcessingException {
+    public ResponseEntity logOut(@RequestHeader Map<String, Object> headers, @RequestBody Map<String, Object> body) throws Exception {
         return ResponseEntity.ok(null);
     }
 
@@ -130,7 +131,7 @@ public class SecurityApi {
      * @return
      */
     @PostMapping({"user/health", "foxlibc/health"})
-    public ResponseEntity health(@RequestHeader Map<String, Object> headers, @RequestBody Map<String, Object> body, ServerHttpRequest httpRequest) {
+    public ResponseEntity health(@RequestHeader Map<String, Object> headers, @RequestBody Map<String, Object> body) {
         return ResponseEntity.ok(null);
     }
 }

src/main/java/com/scbfkj/uni/config/CorsConfig.java

@@ -1,11 +1,11 @@
 package com.scbfkj.uni.config;
 
 import org.springframework.context.annotation.Configuration;
-import org.springframework.web.reactive.config.CorsRegistry;
-import org.springframework.web.reactive.config.WebFluxConfigurer;
+import org.springframework.web.servlet.config.annotation.CorsRegistry;
+import org.springframework.web.servlet.config.annotation.WebMvcConfigurer;
 
 @Configuration // 一定不要忽略此注解
-public class CorsConfig implements WebFluxConfigurer {
+public class CorsConfig implements WebMvcConfigurer {
     @Override
     public void addCorsMappings(CorsRegistry registry) {
         registry.addMapping("/**") // 所有接口

src/main/java/com/scbfkj/uni/config/InitBeanConfig.java

@@ -11,31 +11,4 @@ import org.springframework.context.annotation.Configuration;
 @Configuration
 public class InitBeanConfig {
 
-    @Value("${db.url:jdbc:h2:file:./center.h2}")
-    private String url;
-    @Value("${db.username}")
-    private String username;
-    @Value("${db.password}")
-    private String password;
-    @Value("${db.driver:org.h2.Driver}")
-    private String driver;
-
-    @Value("${cer.private-key}")
-    private String privateKeyStr;
-
-    private final String TYPE = "RSA";
-
-    private final String ALGORITHM = "RSA/ECB/PKCS1Padding";
-
-    @Bean("centerPool")
-    public HikariPool hikariPool() throws Exception {
-        HikariConfig hikariConfig = new HikariConfig();
-        hikariConfig.setJdbcUrl(DataEncryptionUtil.decryptByPrivateKey(url, privateKeyStr, TYPE, ALGORITHM));
-        hikariConfig.setUsername(username);
-        hikariConfig.setPassword(password);
-        hikariConfig.setDriverClassName(driver);
-        hikariConfig.setAutoCommit(false);
-        hikariConfig.setPoolName("center");
-        return new HikariPool(hikariConfig);
-    }
 }

src/main/java/com/scbfkj/uni/library/DataFormatUtil.java

@@ -1,4 +1,54 @@
 package com.scbfkj.uni.library;
 
-public class DataFormatUtil {
+import com.fasterxml.jackson.annotation.JsonInclude;
+import com.fasterxml.jackson.core.JsonProcessingException;
+import com.fasterxml.jackson.databind.JsonNode;
+import com.fasterxml.jackson.databind.ObjectMapper;
+import com.fasterxml.jackson.databind.node.ArrayNode;
+import com.fasterxml.jackson.databind.node.ObjectNode;
+import com.fasterxml.jackson.datatype.jdk8.Jdk8Module;
+import com.fasterxml.jackson.datatype.jsr310.JavaTimeModule;
+import jakarta.json.JsonObject;
+
+import java.time.LocalDate;
+import java.time.LocalDateTime;
+import java.time.format.DateTimeFormatter;
+import java.time.temporal.Temporal;
+
+public final class DataFormatUtil {
+    private final static ObjectMapper objectMapper = new ObjectMapper();
+
+    static {
+        objectMapper.registerModule(new Jdk8Module());
+        objectMapper.registerModule(new JavaTimeModule());
+        objectMapper.setSerializationInclusion(JsonInclude.Include.NON_NULL);
+    }
+
+    public static JsonNode stringToJsonNode(String source) throws JsonProcessingException {
+        return objectMapper.readTree(source);
+    }
+
+    public static ObjectNode stringToObjectNode(String source) throws JsonProcessingException {
+        return objectMapper.readValue(source, ObjectNode.class);
+    }
+
+    public static ArrayNode stringToArrayNode(String source) throws JsonProcessingException {
+        return objectMapper.readValue(source, ArrayNode.class);
+    }
+
+    public static String toString(Object source) throws JsonProcessingException {
+        if (source instanceof String || source instanceof Number)
+            return source.toString();
+        if (source instanceof LocalDate result) result.format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"));
+        if (source instanceof LocalDateTime result) result.format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"));
+        return objectMapper.writeValueAsString(source);
+    }
+
+    public static LocalDate stringToDate(String dateStr) {
+        return LocalDate.parse(dateStr);
+    }
+
+    public static LocalDateTime stringToDateTime(String dateTimeStr) {
+        return LocalDateTime.parse(dateTimeStr);
+    }
 }

src/main/java/com/scbfkj/uni/library/DbUtil.java

@@ -0,0 +1,46 @@
+package com.scbfkj.uni.library;
+
+import java.sql.ResultSet;
+import java.sql.ResultSetMetaData;
+import java.sql.SQLException;
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+public class DbUtil {
+
+    private static final Map<String, List<String>> columns = new HashMap<>();
+
+    public static List<String> getColumns(String connection,String sql, ResultSet resultSet) throws SQLException {
+        if (columns.containsKey(connection+sql)) {
+            return columns.get(sql);
+        }
+
+        ArrayList<String> cs = new ArrayList<>();
+        ResultSetMetaData metaData = resultSet.getMetaData();
+        for (int i = 0; i < metaData.getColumnCount(); i++) {
+            cs.add(metaData.getColumnName(i));
+        }
+
+        columns.put(sql, cs);
+        return cs;
+
+    }
+
+    public static List<Map<String, Object>> getResult(String connection, String sql, ResultSet resultSet) throws SQLException {
+        List<String> cs = getColumns(connection,sql, resultSet);
+
+        List<Map<String, Object>> result = new ArrayList<>();
+        while (resultSet.next()) {
+            Map<String, Object> resultMap = new HashMap<>();
+            for (String c : cs) {
+                Object object = resultSet.getObject(c);
+                resultMap.put(c, object);
+            }
+            result.add(resultMap);
+        }
+        return result;
+
+    }
+}

src/main/java/com/scbfkj/uni/library/RequestUtil.java

@@ -0,0 +1,62 @@
+package com.scbfkj.uni.library;
+
+import jakarta.servlet.http.HttpServletRequest;
+import org.springframework.web.context.request.RequestContextHolder;
+import org.springframework.web.context.request.ServletRequestAttributes;
+
+import java.util.Objects;
+
+import static org.springframework.web.context.request.RequestAttributes.SCOPE_REQUEST;
+
+public class RequestUtil {
+
+    public static String getIpAddr() {
+//        请求
+        ServletRequestAttributes requestAttributes = (ServletRequestAttributes) RequestContextHolder.currentRequestAttributes();
+//
+        HttpServletRequest request = requestAttributes.getRequest();
+        String ip = request.getHeader("x-forwarded-for");
+        if (ip == null || ip.length() == 0 || "unknown".equalsIgnoreCase(ip)) {
+            ip = request.getHeader("Proxy-Client-IP");
+        }
+        if (ip == null || ip.length() == 0 || "unknown".equalsIgnoreCase(ip)) {
+            ip = request.getHeader("WL-Proxy-Client-IP");
+        }
+        if (ip == null || ip.length() == 0 || "unknown".equalsIgnoreCase(ip)) {
+            ip = request.getRemoteAddr();
+        }
+        return ip;
+    }
+
+    public static String getAppToken() {
+//        请求
+        ServletRequestAttributes requestAttributes = (ServletRequestAttributes) RequestContextHolder.currentRequestAttributes();
+//
+        Object appToken = requestAttributes.getAttribute("token", SCOPE_REQUEST);
+        return Objects.nonNull(appToken) ? appToken.toString() : null;
+
+    }
+
+    public static String getUserToken() {
+//        请求
+        ServletRequestAttributes requestAttributes = (ServletRequestAttributes) RequestContextHolder.currentRequestAttributes();
+//
+        Object appToken = requestAttributes.getAttribute("usertoken", SCOPE_REQUEST);
+        return Objects.nonNull(appToken) ? appToken.toString() : null;
+
+    }
+    public static String getAppId() {
+//        请求
+        ServletRequestAttributes requestAttributes = (ServletRequestAttributes) RequestContextHolder.currentRequestAttributes();
+//
+        Object appid = requestAttributes.getAttribute("appid", SCOPE_REQUEST);
+        return Objects.nonNull(appid) ? appid.toString() : null;
+
+    }
+
+    public static String getSessionId() {
+        return RequestContextHolder.currentRequestAttributes().getSessionId();
+
+    }
+
+}

src/main/java/com/scbfkj/uni/library/UniReturnUtil.java

@@ -6,14 +6,14 @@ import java.util.Objects;
 
 public class UniReturnUtil {
 
-    public Map<String, Object> success(Object data) {
+    public static Map<String, Object> success(Object data) {
         HashMap<String, Object> result = new HashMap<>();
         result.put("code", "0");
 
         return result;
     }
 
-    public Map<String, Object> success(Object data, Map<String, Object> other) {
+    public static Map<String, Object> success(Object data, Map<String, Object> other) {
         Map<String, Object> result = success(data);
         if (Objects.nonNull(other)) {
             result.putAll(other);
@@ -21,7 +21,7 @@ public class UniReturnUtil {
         return result;
     }
 
-    public Map<String, Object> fail(String message, Map<String, Object> other) {
+    public static Map<String, Object> fail(String message, Map<String, Object> other) {
         Map<String, Object> result = fail(message);
         if (Objects.nonNull(other)) {
             result.putAll(other);
@@ -29,14 +29,14 @@ public class UniReturnUtil {
         return result;
     }
 
-    public Map<String, Object> fail(String message) {
+    public static Map<String, Object> fail(String message) {
         HashMap<String, Object> result = new HashMap<>();
         result.put("message", message);
         result.put("code", "-1");
         return result;
     }
 
-    public Map<String, Object> fail(String code, String message, Map<String, Object> other) {
+    public static Map<String, Object> fail(String code, String message, Map<String, Object> other) {
         Map<String, Object> result = fail(code, message);
         if (Objects.nonNull(other)) {
             result.putAll(other);
@@ -44,7 +44,7 @@ public class UniReturnUtil {
         return result;
     }
 
-    public Map<String, Object> fail(String code, String message) {
+    public static Map<String, Object> fail(String code, String message) {
         HashMap<String, Object> result = new HashMap<>();
         result.put("message", message);
         result.put("code", code);

src/main/java/com/scbfkj/uni/process/DataBase.java

@@ -1,22 +1,132 @@
 package com.scbfkj.uni.process;
 
+import com.scbfkj.uni.library.DbUtil;
+import com.scbfkj.uni.system.Config;
 import com.zaxxer.hikari.pool.HikariPool;
 
-import java.util.ArrayList;
-import java.util.List;
-import java.util.Map;
+import java.sql.Connection;
+import java.sql.PreparedStatement;
+import java.sql.ResultSet;
+import java.util.*;
+import java.util.regex.Matcher;
+import java.util.regex.Pattern;
+import java.util.stream.Collectors;
 
 public class DataBase {
 
-    public static List<Map<String, Object>> query(HikariPool pool, String sql, List<Object[]> argsList) {
-        return new ArrayList<>();
+    public static List<Map<String, Object>> query(String connectionStr, String sql, List<Object[]> argsList) throws Exception {
+        HikariPool dataSourcePool = Config.getDataSourcePool(connectionStr);
+
+        List<Map<String, Object>> result = new ArrayList<>();
+        for (Object[] args : argsList) {
+            try (Connection connection = dataSourcePool.getConnection();
+                 PreparedStatement preparedStatement = connection.prepareStatement(sql)
+            ) {
+                for (int i = 0; i < args.length; i++) {
+                    preparedStatement.setObject(i + 1, args[i]);
+                }
+                ResultSet resultSet = preparedStatement.executeQuery();
+                result.addAll(DbUtil.getResult(connectionStr, sql, resultSet));
+            }
+
+        }
+
+        return result;
+
+    }
+
+    public static int[] updateBatch(String connectionStr, String sql, List<Object[]> argsList) throws Exception {
+        HikariPool dataSourcePool = Config.getDataSourcePool(connectionStr);
+        try (Connection connection = dataSourcePool.getConnection();
+             PreparedStatement preparedStatement = connection.prepareStatement(sql)
+        ) {
+            for (Object[] args : argsList) {
+                for (int i = 0; i < args.length; i++) {
+                    preparedStatement.setObject(i + 1, args[i]);
+                }
+                preparedStatement.addBatch();
+                try {
+                    connection.commit();
+                } catch (Exception e) {
+                    connection.rollback();
+                    throw e;
+                }
+            }
+            return preparedStatement.executeBatch();
+        }
     }
 
-    public static int[] updateBatch(HikariPool pool, String sql, List<Object[]> argsList) {
-        return new int[]{};
+    public static int exec(String connectionStr, String sql) throws Exception {
+        HikariPool dataSourcePool = Config.getDataSourcePool(connectionStr);
+        try (Connection connection = dataSourcePool.getConnection();
+             PreparedStatement preparedStatement = connection.prepareStatement(sql)
+        ) {
+            int i = preparedStatement.executeUpdate();
+            try {
+                connection.commit();
+            } catch (Exception e) {
+                connection.rollback();
+                throw e;
+            }
+            return i;
+        }
     }
-    public static int[] exec(HikariPool pool, String sql) {
-        return new int[]{};
+
+    public static List<Map<String, Object>> query(String connectionStr, String sql, List<Map<String, Object>> argsList, List<String> filterColumns, Map<String, Object> filterLines) throws Exception {
+
+        sql = sql.replaceAll("(\\r)?\\n", " ");
+
+        if (Objects.nonNull(filterLines) && !filterLines.isEmpty()) {
+            sql = " (%s %s %s) ".formatted(sql, sql.contains(" where ") ? " " : " where ", filterLines.entrySet().stream().map(it -> "%s = %s".formatted(it.getKey(), it.getValue())).collect(Collectors.joining(" and ")));
+        }
+        if (Objects.nonNull(filterColumns) && !filterColumns.isEmpty()) {
+            sql = "select %s from %s".formatted(filterColumns.stream().collect(Collectors.joining(",")), sql);
+        } else {
+            sql = "select * from %s".formatted(sql);
+        }
+
+        List<List<Object>> result = new ArrayList<>();
+        List<String> names = new ArrayList<>();
+        if (sql.matches("《.*》")) {
+            Pattern compile = Pattern.compile("(?=《).*(?=》)");
+            Matcher matcher = compile.matcher(sql);
+            int index = 0;
+            while (matcher.find()) {
+                String name = matcher.group(index);
+                names.add(name);
+            }
+        }
+        if (names.size() == 1 && names.contains("whereStr")) {
+            List<Map<String, Object>> list = new ArrayList<>();
+            for (Map<String, Object> stringObjectMap : argsList) {
+                List<Object> args = new ArrayList<>();
+                StringJoiner joiner = new StringJoiner(" and ");
+                for (Map.Entry<String, Object> entry : stringObjectMap.entrySet()) {
+                    String formatted = "%s = ?".formatted(entry.getKey());
+                    args.add(entry.getValue());
+                    joiner.add(formatted);
+                }
+                String whereStr = " " + joiner;
+                String sqlStr = sql.replace("《whereStr》", whereStr);
+                List<Map<String, Object>> apply = query(connectionStr, sqlStr, new ArrayList<>() {{
+                    add(args.toArray());
+                }});
+                list.addAll(apply);
+            }
+            return list;
+        } else {
+            for (String it : names) {
+                sql = sql.replace("《%s》".formatted(it), " ? ");
+            }
+            for (Map<String, Object> map : argsList) {
+                List<Object> args = new ArrayList<>();
+                for (String name : names) {
+                    args.add(map.get(name));
+                }
+                result.add(args);
+            }
+            return query(connectionStr, sql, result.stream().map(List::toArray).toList());
+        }
     }
 
 }

src/main/java/com/scbfkj/uni/service/CodeCacheService.java

@@ -0,0 +1,46 @@
+package com.scbfkj.uni.service;
+
+import com.scbfkj.uni.process.DataBase;
+import com.scbfkj.uni.system.Config;
+import org.springframework.stereotype.Service;
+
+import java.time.LocalDateTime;
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Map;
+
+@Service
+public class CodeCacheService {
+
+
+    public void addCode(String code, String sessionId, String appid, Long securitycodeeffective, String requestIp) throws Exception {
+//      使用数据库
+        LocalDateTime localDateTime = LocalDateTime.now().plusSeconds(securitycodeeffective);
+        String insertSql = "insert into tempsecuritycode(appid,requestip,sessionid,securitycode,expiretime) values (?,?,?,?,?)";
+        DataBase.updateBatch(Config.securityConnectionStr, insertSql, new ArrayList<>() {{
+            add(new Object[]{insertSql, appid, requestIp, sessionId, code, localDateTime});
+        }});
+        String deleteSql = "delete from tempsecuritycode where expiretime < now() and 1=?";
+        DataBase.updateBatch(Config.securityConnectionStr, deleteSql, new ArrayList<>() {{
+            add(new Object[]{1});
+        }});
+    }
+
+    public boolean check(String code, String sessionId, String appid, String requestIp) throws Exception {
+
+        String selectSql = "select * from tempsecuritycode where securitycode=? and sessionid=? and appid=? and requestip=?";
+        List<Map<String, Object>> map = DataBase.query(Config.securityConnectionStr, selectSql, new ArrayList<>() {{
+            add(new Object[]{code, sessionId, appid, requestIp});
+        }});
+        return !map.isEmpty();
+
+    }
+
+    public void remove(String code, String sessionId, String appid, String requestIp) throws Exception {
+        String deleteSql = "delete from tempsecuritycode where securitycode=? and sessionid=? and appid=? and requestip=?";
+        DataBase.updateBatch(Config.securityConnectionStr, deleteSql, new ArrayList<>() {{
+            add(new Object[]{code, sessionId, appid, requestIp});
+        }});
+
+    }
+}

src/main/java/com/scbfkj/uni/service/LoggerService.java

@@ -1,4 +1,61 @@
 package com.scbfkj.uni.service;
 
+import com.fasterxml.jackson.databind.JsonNode;
+import com.fasterxml.jackson.databind.node.ArrayNode;
+import com.fasterxml.jackson.databind.node.ObjectNode;
+
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
 public class LoggerService {
+
+    private static Map<String, List<ObjectNode>> logs = new HashMap<>();
+
+
+    public enum LogTarget {
+
+        DB, ES, KAFKA;
+        private String target;
+        private String connection;
+
+        public String getTarget() {
+            return target;
+        }
+
+        public void setTarget(String target) {
+            this.target = target;
+        }
+
+        public String getConnection() {
+            return connection;
+        }
+
+        public void setConnection(String connection) {
+            this.connection = connection;
+        }
+    }
+
+
+    public static void log(List<LogTarget> targetList, JsonNode data) {
+        if (data instanceof ArrayNode nodes) {
+            for (JsonNode node : nodes) {
+                log(targetList, node);
+            }
+        } else if (data instanceof ObjectNode node) {
+            for (LogTarget target : targetList) {
+                write(target, node);
+            }
+        }
+    }
+
+    private static void write(LogTarget target, ObjectNode node) {
+        String key = target.getTarget() + ";" + target.getConnection();
+        if (!logs.containsKey(key)) {
+            logs.put(key, List.of(node));
+        } else {
+            logs.get(key).add(node);
+        }
+    }
+
 }

src/main/java/com/scbfkj/uni/service/SecurityService.java

@@ -1,4 +1,406 @@
 package com.scbfkj.uni.service;
 
+import com.fasterxml.jackson.annotation.JsonInclude;
+import com.fasterxml.jackson.core.JsonProcessingException;
+import com.fasterxml.jackson.databind.ObjectMapper;
+import com.scbfkj.uni.library.*;
+import com.scbfkj.uni.process.DataBase;
+import com.scbfkj.uni.system.Config;
+import jakarta.annotation.Resource;
+import org.bouncycastle.cert.ocsp.Req;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.stereotype.Service;
+import org.springframework.web.context.request.RequestAttributes;
+import org.springframework.web.context.request.RequestContextHolder;
+
+import java.time.LocalDateTime;
+import java.time.format.DateTimeFormatter;
+import java.util.*;
+
+import static org.springframework.web.context.request.RequestAttributes.SCOPE_REQUEST;
+
+@Service
 public class SecurityService {
+
+
+    @Value("${app.token-effective:604800}")
+    private long defaultAppTokenEffective;
+    @Value("${app.code-effective:600}")
+    private long defaultSecurityCodeEffective;
+
+
+    private final static String TYPE = "RSA";
+
+    private final static String ALGORITHM = "RSA/ECB/PKCS1Padding";
+
+    @Value("${cer.private-key}")
+    private static String privateKeyStr;
+    private final static Map<String, List<String>> alias = new HashMap<>();
+
+    static {
+        alias.put("appid", List.of("appid", "app_id", "appId", "APPID"));
+        alias.put("appsecret", List.of("appSecret", "app_secret", "APP_SECRET", "appsecret", "APPSECRET"));
+        alias.put("sessionid", List.of("sessionId", "sessionid", "SESSIONID", "SESSION_ID", "session_id"));
+        alias.put("requestip", List.of("requestIp", "requestip", "request_ip", "REQUEST_IP", "request_ip", "REQUESTIP", "ip"));
+        alias.put("username", List.of("username", "userName", "user_name", "USER_NAME", "USERNAME"));
+        alias.put("password", List.of("password", "pwd", "PWD", "PASSWORD"));
+        alias.put("version", List.of("version", "Version", "VERSION"));
+        alias.put("verifycode", List.of("verifycode", "verifyCode", "code"));
+    }
+
+    private final static String CLEAN_APPLICATION_CONNECTION_LOG = "delete from appconnectlog where expiretime < NOW() and 1 = ?";
+    private final static String QUERY_APPLICATION_BY_APPID_AND_APPSECRET = "select * from application where appid = ? and appsecret";
+    private final static String QUERY_APPLICATION_BY_APPID = "select * from application where appid = ? ";
+    private final static String QUERY_USER_INFO_BY_ACCOUNT_AND_PASSWORD = "select * from userinfo where  username =? and userpassword=? ";
+    private final static String QUERY_USER_INFO_BY_USER_ID = "select * from userinfo where  userid=?";
+    private final static String DELETE_USER_LOGIN_LOG_BY_USER_ID = "delete from userloginlog where  userid=?";
+    private final static String QUERY_USER_LOGIN_LOG_BY_USER_ID = "select * from userloginlog where userid=?";
+    private final static String UPDATE_USER_LOGIN_LOG_WITH_USER_TOKEN_BY_ID = "update userloginlog set apptoken=null,usertoken=?,lasttime=? where  loginid=?";
+    private final static String QUERY_USER_LOGIN_LOG_BY_APP_TOKEN_AND_SESSION_ID_AND_IP = "select * from userloginlog where apptoken=? and sessionid=? and requestip=? and isexpires=0 ";
+    private final static String INSERT_USER_LOGIN_LOG = "insert into userloginlog ( userid, requestip, sessionid, logintime, usertoken, lasttime, lastheartbeat,apptoken,isexpires,appid)values (?,?,?,?,?,?,?,?,0,?)";
+    private final static String QUERY_APP_CONNECT_LOG_BY_APPTOKEN_AND_REQUEST_IP = "select * from appconnectlog where apptoken=? and requestip =?";
+    private final static String UPDATE_APP_CONNECT_LOG_WITH_EXPIRE_TIME_BY_APPTOKEN_AND_REQUEST_IP_AND_APPID = "update appconnectlog set expiretime=? where apptoken =? and requestip =? and appid=?";
+    private final static String QUERY_USER_LOGIN_LOG_BY_USER_TOKEN_AND_IP = "select * from userloginlog where isexpires=0 and usertoken=? and sessionid=?";
+
+    private final CodeCacheService codeCacheService;
+
+    public SecurityService(CodeCacheService codeCacheService) {
+
+        this.codeCacheService = codeCacheService;
+    }
+
+    //安全类服务
+    //连接认证--获取连接令牌
+
+    public Map<String, Object> getToken(Map<String, Object> requestData) throws Exception {
+        Optional<String> appid = getValue("appid", requestData);
+        Optional<String> appSecret = getValue("appsecret", requestData);
+        Optional<String> sessionId = getValue("sessionid", requestData);
+        if (appSecret.isPresent() && appid.isPresent()) {
+            DataBase.updateBatch(Config.securityConnectionStr, CLEAN_APPLICATION_CONNECTION_LOG, new ArrayList<>() {{
+                add(new Object[]{1});
+            }});
+            List<Map<String, Object>> applicationList = DataBase.query(Config.securityConnectionStr, QUERY_APPLICATION_BY_APPID_AND_APPSECRET, new ArrayList<>() {{
+                add(new Object[]{appid.get()});
+                add(new Object[]{appSecret.get()});
+            }});
+
+            if (applicationList.isEmpty()) {
+                return UniReturnUtil.fail("appid 或 appsecret 错误");
+            }
+            Map<String, Object> application = applicationList.get(0);
+
+            Object apptokeneffectiveObj = application.get("apptokeneffective");
+            Long apptokeneffective = defaultAppTokenEffective;
+            if (Objects.nonNull(apptokeneffectiveObj)) {
+                apptokeneffective = Long.getLong(apptokeneffectiveObj.toString());
+            }
+            LocalDateTime expiresTime = LocalDateTime.now().plusSeconds(apptokeneffective);
+            String appToken = DataEncryptionUtil.signatureMD5("%s:%s".formatted(LocalDateTime.now(), sessionId));
+            Map<String, Object> data = new HashMap<>();
+            data.put("token", appToken);
+            data.put("expirestime", DataFormatUtil.toString(expiresTime));
+            data.put("appname", application.get("appname"));
+            data.put("appenname", application.get("appengname"));
+            data.put("logo", application.get("applog"));
+            data.put("smalllogo", application.get("smalllogo"));
+            data.put("background", application.get("backgroundimage"));
+            data.put("securitycoderule", application.get("securitycoderule"));
+            RequestContextHolder.currentRequestAttributes().setAttribute("application", application, SCOPE_REQUEST);
+            return UniReturnUtil.success(data);
+        }
+        return UniReturnUtil.fail("appid 或 appsecret 不能为空");
+    }
+
+    //校验连接令牌
+
+    public Map<String, Object> verifyToken(String appToken) throws Exception {
+
+        DataBase.updateBatch(Config.securityConnectionStr, CLEAN_APPLICATION_CONNECTION_LOG, new ArrayList<>() {{
+            add(new Object[]{1});
+        }});
+
+        String requestIp = RequestUtil.getIpAddr();
+        List<Map<String, Object>> appConnectLogList = DataBase.query(Config.securityConnectionStr, QUERY_APP_CONNECT_LOG_BY_APPTOKEN_AND_REQUEST_IP, new ArrayList<>() {{
+            add(new Object[]{appToken, requestIp});
+        }});
+        Map<String, Object> data = new HashMap<>();
+        if (!appConnectLogList.isEmpty()) {
+            Map<String, Object> appConnectLog = appConnectLogList.get(0);
+            data.put("validstatus", true);
+            data.put("appid", appConnectLog.get("appid"));
+            return UniReturnUtil.success(data);
+        }
+        data.put("validstatus", false);
+        return UniReturnUtil.success(data);
+    }
+
+    //刷新连接令牌
+
+    public Map<String, Object> refreshToken() throws Exception {
+
+        RequestAttributes requestAttributes = RequestContextHolder.getRequestAttributes();
+        Object appid = requestAttributes.getAttribute("appid", SCOPE_REQUEST);
+        List<Map<String, Object>> applicationList = DataBase.query(Config.securityConnectionStr, QUERY_APPLICATION_BY_APPID, new ArrayList<>() {{
+            add(new Object[]{appid});
+        }});
+        if (!applicationList.isEmpty()) {
+            return UniReturnUtil.fail("应用配置错误");
+        }
+        Map<String, Object> application = applicationList.get(0);
+
+        Long apptokeneffective = defaultAppTokenEffective;
+        Object apptokeneffectiveObj = application.get("apptokeneffective");
+
+        if (Objects.nonNull(apptokeneffectiveObj)) {
+            apptokeneffective = Long.getLong(apptokeneffectiveObj.toString());
+        }
+        LocalDateTime expiresTime = LocalDateTime.now().plusSeconds(apptokeneffective);
+        Object appToken = RequestUtil.getAppToken();
+        Map<String, Object> data = new HashMap<>();
+        try {
+            DataBase.updateBatch(Config.securityConnectionStr, UPDATE_APP_CONNECT_LOG_WITH_EXPIRE_TIME_BY_APPTOKEN_AND_REQUEST_IP_AND_APPID, new ArrayList<>() {{
+                add(new Object[]{expiresTime, appToken, RequestUtil.getIpAddr(), appid});
+            }});
+            data.put("expirestime", DataFormatUtil.toString(expiresTime));
+            data.put("token", appToken);
+            return UniReturnUtil.success(data);
+        } catch (Exception exception) {
+            return UniReturnUtil.fail("刷新令牌失败：%s".formatted(exception.getMessage()));
+        }
+    }
+
+    //获取登录验证码
+
+    public Map<String, Object> verifyCode() throws Exception {
+
+        String appId = RequestUtil.getAppId();
+        List<Map<String, Object>> applicationList = DataBase.query(Config.securityConnectionStr, QUERY_APPLICATION_BY_APPID, new ArrayList<>() {{
+            add(new Object[]{appId});
+        }});
+        if (!applicationList.isEmpty()) {
+            return UniReturnUtil.fail("应用配置错误");
+        }
+        Map<String, Object> application = applicationList.get(0);
+        Object securityCodeRule = application.get("securitycoderule");
+        Object securityCodeEffectiveObj = application.get("securitycodeeffective");
+        if (Objects.nonNull(securityCodeRule)) {
+            String rule = "";
+            String codeRule = (String) securityCodeRule;
+//                数字
+            if (codeRule.contains("N")) {
+                rule += "23456789";
+            }
+//            大小写字母 world
+            if (codeRule.contains("W")) {
+                rule += "ABCDEFGHGKMNPQRSTUVWXYZ";
+                rule += "abcdefghgkmnpqrstuvwxyz";
+//                大写字母 upperCase
+            } else if (codeRule.contains("U")) {
+                rule += "ABCDEFGHGKMNPQRSTUVWXYZ";
+//                小写字母 lower
+            } else if (codeRule.contains("L")) {
+                rule += "abcdefghgkmnpqrstuvwxyz";
+            }
+//            字符 c
+            if (codeRule.contains("C")) {
+                rule += "~!@#%&-_;:";
+            }
+//            最后四位长度为最小长度和最大长度
+            String minMax = codeRule.substring(codeRule.length() - 4);
+
+            Integer min = Integer.getInteger(minMax.substring(0, 2));
+            Integer max = Integer.getInteger(minMax.substring(2));
+
+            Integer length = min;
+            if (!Objects.equals(min, max)) {
+                Random random = new Random();
+                do {
+                    length = random.nextInt(max);
+                } while (length <= min);
+            }
+            String code = CodeUtil.createCode(length, rule);
+            String base64Code = ImageUtil.stringToImage(code);
+            String sessionId = RequestUtil.getSessionId();
+            String ip = RequestUtil.getIpAddr();
+            Long securityCodeEffective = defaultSecurityCodeEffective;
+            if (Objects.nonNull(securityCodeEffectiveObj)) {
+                securityCodeEffective = Long.getLong(securityCodeEffectiveObj.toString());
+            }
+            codeCacheService.addCode(code, sessionId, appId, securityCodeEffective, ip);
+
+            Map<String, Object> data = new HashMap<>();
+            data.put("verifyCodeImage", base64Code);
+            return UniReturnUtil.success(data);
+        }
+        return UniReturnUtil.fail("没有配置验证码规则");
+    }
+
+
+    //用户登录
+
+    public Map<String, Object> login(Map<String, Object> requestData) throws Exception {
+
+        Optional<String> username = getValue("username", requestData);
+        Optional<String> password = getValue("password", requestData);
+        Optional<String> verifycode = getValue("verifycode", requestData);
+//        解密验证码
+        String code = DataEncryptionUtil.decryptByPrivateKey(verifycode.get(), privateKeyStr, TYPE, ALGORITHM);
+        String appId = RequestUtil.getAppId();
+        List<Map<String, Object>> applicationList = DataBase.query(Config.securityConnectionStr, QUERY_APPLICATION_BY_APPID, new ArrayList<>() {{
+            add(new Object[]{appId});
+        }});
+        if (!applicationList.isEmpty()) {
+            return UniReturnUtil.fail("应用配置错误");
+        }
+        Map<String, Object> application = applicationList.get(0);
+        Object securityCodeRule = application.get("securitycoderule");
+        String sessionId = RequestUtil.getSessionId();
+        String ip = RequestUtil.getIpAddr();
+        if (Objects.nonNull(securityCodeRule) && !codeCacheService.check(code, sessionId, appId, ip)) {
+            return UniReturnUtil.fail("验证码错误");
+        }
+
+        List<Map<String, Object>> userInfoList = DataBase.query(Config.securityConnectionStr, QUERY_USER_INFO_BY_ACCOUNT_AND_PASSWORD, new ArrayList<>() {{
+            add(new Object[]{username.get(), DataEncryptionUtil.decryptByPrivateKey(password.get(), privateKeyStr, TYPE, ALGORITHM)});
+        }});
+        if (userInfoList.isEmpty()) {
+            return UniReturnUtil.fail("用户名密码错误");
+        }
+        Map<String, Object> userInfo = userInfoList.get(0);
+        Object userId = userInfo.get("userid");
+        List<Map<String, Object>> userLoginLogList = DataBase.query(Config.securityConnectionStr, QUERY_USER_LOGIN_LOG_BY_USER_ID, new ArrayList<>() {{
+            add(new Object[]{userInfo.get("userid")});
+        }});
+
+        Map<String, Object> data = new HashMap<>();
+        String appToken = RequestUtil.getAppToken();
+        if (userLoginLogList.isEmpty()) {
+            data.put("userstatus", "0");
+            DataBase.updateBatch(Config.securityConnectionStr, INSERT_USER_LOGIN_LOG, new ArrayList<>() {{
+                add(new Object[]{userId, ip, sessionId, LocalDateTime.now(), null, LocalDateTime.now(), LocalDateTime.now(), appToken, appId});
+            }});
+        } else {
+            Object multilogin = application.get("multilogin");
+            if (Objects.equals(multilogin, "1")) {
+                Optional<Map<String, Object>> log = userLoginLogList.stream().filter(it -> it.get("sessionid").equals(sessionId)).findAny();
+                if (log.isEmpty()) {
+                    DataBase.updateBatch(Config.securityConnectionStr, INSERT_USER_LOGIN_LOG, new ArrayList<>() {{
+                        add(new Object[]{userId, ip, sessionId, LocalDateTime.now(), null, LocalDateTime.now(), LocalDateTime.now(), appToken, appId});
+                    }});
+                }
+                data.put("userstatus", "0");
+
+            } else {
+                Optional<Map<String, Object>> log = userLoginLogList.stream().filter(it -> it.get("sessionid").equals(sessionId)).findAny();
+                if (log.isEmpty()) {
+
+                    DataBase.updateBatch(Config.securityConnectionStr, INSERT_USER_LOGIN_LOG, new ArrayList<>() {{
+                        add(new Object[]{userId, ip, sessionId, LocalDateTime.now(), null, LocalDateTime.now(), LocalDateTime.now(), appToken, appId});
+                    }});
+                }
+                data.put("userstatus", "1");
+            }
+        }
+
+
+        return UniReturnUtil.success(data);
+    }
+
+
+    //强制登录
+
+    public Map<String, Object> forceLogin() throws Exception {
+        String appId = RequestUtil.getAppId();
+        List<Map<String, Object>> applicationList = DataBase.query(Config.securityConnectionStr, QUERY_APPLICATION_BY_APPID, new ArrayList<>() {{
+            add(new Object[]{appId});
+        }});
+        if (!applicationList.isEmpty()) {
+            return UniReturnUtil.fail("应用配置错误");
+        }
+        Map<String, Object> application = applicationList.get(0);
+
+        String appToken = RequestUtil.getAppToken();
+        String ip = RequestUtil.getIpAddr();
+        String sessionId = RequestUtil.getSessionId();
+        List<Map<String, Object>> userLoginLogList = DataBase.query(Config.securityConnectionStr, QUERY_USER_LOGIN_LOG_BY_APP_TOKEN_AND_SESSION_ID_AND_IP, new ArrayList<>() {{
+            add(new Object[]{appToken, sessionId, ip});
+        }});
+        if (userLoginLogList.isEmpty()) {
+            return UniReturnUtil.fail("登录失败");
+        }
+        Map<String, Object> userLoginLog = userLoginLogList.get(0);
+        Object securityCodeEffectiveObj = application.get("securitycodeeffective");
+        Long securityCodeEffective = defaultSecurityCodeEffective;
+        if (Objects.nonNull(securityCodeEffectiveObj)) {
+            securityCodeEffective = Long.getLong(securityCodeEffectiveObj.toString());
+        }
+        LocalDateTime expiresTime = LocalDateTime.now().plusSeconds(securityCodeEffective);
+        String userToken = DataEncryptionUtil.signatureMD5("%s:%s".formatted(LocalDateTime.now(), sessionId));
+        DataBase.updateBatch(Config.securityConnectionStr, UPDATE_USER_LOGIN_LOG_WITH_USER_TOKEN_BY_ID, new ArrayList<>() {{
+            add(new Object[]{userToken, expiresTime, userLoginLog.get("loginid")});
+        }});
+        HashMap<String, Object> data = new HashMap<>();
+        data.put("expirestime", expiresTime);
+        data.put("usertoken", userToken);
+
+        return UniReturnUtil.success(data);
+
+    }
+
+    private Map<String, Object> checkUserToken(String userToken) {
+        //       Todo
+        return null;
+
+    }
+
+    //用户登出
+
+    public Map<String, Object> logOut(Map<String, Object> requestData) throws Exception {
+        //       Todo
+        String userToken = RequestUtil.getUserToken();
+        String sessionId = RequestUtil.getSessionId();
+        String ip = RequestUtil.getIpAddr();
+
+        List<Map<String, Object>> userLoginLogList = DataBase.query(Config.securityConnectionStr, QUERY_USER_LOGIN_LOG_BY_USER_TOKEN_AND_IP, new ArrayList<>() {{
+            add(new Object[]{userToken, ip});
+        }});
+
+        if (userLoginLogList.isEmpty()) {
+            return UniReturnUtil.fail("登出失败");
+        }
+        Map<String, Object> userLoginLog = userLoginLogList.get(0);
+        Object userIdObj = userLoginLog.get("userid");
+        DataBase.updateBatch(Config.securityConnectionStr, DELETE_USER_LOGIN_LOG_BY_USER_ID, new ArrayList<>() {{
+            add(new Object[]{userIdObj});
+        }});
+
+
+        return UniReturnUtil.success("成功");
+    }
+
+
+    //获取用户权限
+
+    public Map<String, Object> permission(Map<String, Object> requestData) throws JsonProcessingException {
+//       Todo
+        return null;
+    }
+
+    //应用API及数据权限
+    public Map<String, Object> changePassword(Map<String, Object> requestData) throws JsonProcessingException {
+        //       Todo
+        return null;
+    }
+
+    //用户心跳
+    public List<Map<String, Object>> userHeartbeat(Map<String, Object> requestData) {
+        //       Todo
+        return null;
+    }
+
+
+    private Optional<String> getValue(String key, Map<String, Object> data) {
+        return alias.getOrDefault(key, Collections.singletonList(key)).stream().map(data::get).filter(Objects::nonNull).map(Object::toString).findAny();
+    }
 }

src/main/java/com/scbfkj/uni/system/Config.java

@@ -1,4 +1,72 @@
 package com.scbfkj.uni.system;
 
+import com.fasterxml.jackson.core.JsonProcessingException;
+import com.fasterxml.jackson.databind.JsonNode;
+import com.oracle.truffle.api.Option;
+import com.scbfkj.uni.library.DataEncryptionUtil;
+import com.scbfkj.uni.library.DataFormatUtil;
+import com.zaxxer.hikari.HikariConfig;
+import com.zaxxer.hikari.pool.HikariPool;
+import jakarta.annotation.Nonnull;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.stereotype.Component;
+
+import java.util.HashMap;
+import java.util.Map;
+import java.util.Objects;
+import java.util.Optional;
+
+@Component
 public class Config {
+
+    public static String centerConnectionStr;
+    public static String securityConnectionStr;
+
+
+    private final static String TYPE = "RSA";
+
+    private final static String ALGORITHM = "RSA/ECB/PKCS1Padding";
+
+    @Value("${cer.private-key}")
+    private static String privateKeyStr;
+
+    private final static Map<String, HikariPool> dataSourcePools = new HashMap<>();
+
+
+    public static HikariPool getDataSourcePool(String connectionStr) throws Exception {
+        if (dataSourcePools.containsKey(connectionStr)) {
+            return dataSourcePools.get(connectionStr);
+        }
+        JsonNode jsonNode = DataFormatUtil.stringToJsonNode(connectionStr);
+
+        JsonNode jdbcUrl = jsonNode.get("jdbcUrl");
+        JsonNode username = jsonNode.get("username");
+        JsonNode password = jsonNode.get("password");
+        JsonNode driverClassName = jsonNode.get("driverClassName");
+        HikariPool dataSourcePool = createDataSourcePool(jdbcUrl.asText(), username.asText(), password.asText(), driverClassName.asText(), "center");
+        dataSourcePools.put(connectionStr, dataSourcePool);
+        return dataSourcePool;
+    }
+
+
+
+    public static HikariPool createDataSourcePool(@Nonnull String url, String username, String password, String driver, String poolName) throws Exception {
+        HikariConfig hikariConfig = new HikariConfig();
+        hikariConfig.setJdbcUrl(DataEncryptionUtil.decryptByPrivateKey(url, privateKeyStr, TYPE, ALGORITHM));
+
+        if (Objects.nonNull(username)) {
+            hikariConfig.setUsername(DataEncryptionUtil.decryptByPrivateKey(username, privateKeyStr, TYPE, ALGORITHM));
+        }
+        if (Objects.nonNull(password)) {
+            hikariConfig.setPassword(DataEncryptionUtil.decryptByPrivateKey(password, privateKeyStr, TYPE, ALGORITHM));
+        }
+        if (Objects.nonNull(driver)) {
+            hikariConfig.setDriverClassName(driver);
+        }
+        if (Objects.nonNull(poolName)) {
+            hikariConfig.setPoolName(poolName);
+        }
+        hikariConfig.setAutoCommit(false);
+        return new HikariPool(hikariConfig);
+    }
 }

src/main/java/com/scbfkj/uni/system/SystemInit.java

@@ -1,16 +1,65 @@
 package com.scbfkj.uni.system;
 
+import com.fasterxml.jackson.core.JsonProcessingException;
+import com.fasterxml.jackson.databind.node.JsonNodeFactory;
+import com.fasterxml.jackson.databind.node.ObjectNode;
+import com.scbfkj.uni.library.DataEncryptionUtil;
+import com.scbfkj.uni.library.DataFormatUtil;
 import jakarta.annotation.PostConstruct;
+import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Component;
+import org.springframework.util.StringUtils;
+
+import java.util.HashMap;
+import java.util.Map;
+import java.util.Objects;
 
 @Component
-public class SystemInit  {
+public class SystemInit {
 
 
-    @PostConstruct
-    public void init(){
+    @Value("${db.center.url:jdbc:h2:file:./center.h2}")
+    private String centerUrl;
+    @Value("${db.center.username}")
+    private String centerUsername = null;
+    @Value("${db.center.password}")
+    private String centerPassword = null;
+    @Value("${db.center.driver:org.h2.Driver}")
+    private String centerDriver;
+
+    @Value("${db.security.url:jdbc:h2:file:./security.h2}")
+    private String securityUrl;
+    @Value("${db.security.username}")
+    private String securityUsername = null;
+    @Value("${db.security.password}")
+    private String securityPassword = null;
+    @Value("${db.security.driver:org.h2.Driver}")
+    private String securityDriver;
 
 
+    @PostConstruct
+    public void init() throws JsonProcessingException {
+        Map<String, Object> centerConnectionMap = initConnection(centerUrl, centerUsername, centerPassword, centerDriver);
+        Config.centerConnectionStr = DataFormatUtil.toString(centerConnectionMap);
+        Map<String, Object> securityConnectionMap = initConnection(securityUrl, securityUsername, securityPassword, securityDriver);
+        Config.securityConnectionStr = DataFormatUtil.toString(securityConnectionMap);
+
+    }
 
+    private Map<String, Object> initConnection(String url, String username, String password, String driver) {
+        HashMap<String, Object> connectionMap = new HashMap<>();
+        if (Objects.nonNull(url)) {
+            connectionMap.put("jdbcUrl", url);
+        }
+        if (Objects.nonNull(username) && StringUtils.hasText(username)) {
+            connectionMap.put("username", username);
+        }
+        if (Objects.nonNull(password) && StringUtils.hasText(password)) {
+            connectionMap.put("password", password);
+        }
+        if (Objects.nonNull(driver) && StringUtils.hasText(driver)) {
+            connectionMap.put("driverClassName", driver);
+        }
+        return connectionMap;
     }
 }

src/main/resources/application.properties

@@ -1,4 +1,10 @@
-db.url=XwvGDpBZSBmSSTgwYR/tP7TpjDOvxCbfcglDFj++b1Fedp1LiiAhzeXvfe2025PchJIJuMDp6u0fxe24i8VfQxYG8MY2n8tyiQftih0drHi8OA7dqB8pEtZm5xs1d3kYSt2Q1ffs8fmnJC7aRkmJSk+urgyS/M1q70B3ikpMkKs=
-db.driver=org.h2.Driver
+db.center.url=XwvGDpBZSBmSSTgwYR/tP7TpjDOvxCbfcglDFj++b1Fedp1LiiAhzeXvfe2025PchJIJuMDp6u0fxe24i8VfQxYG8MY2n8tyiQftih0drHi8OA7dqB8pEtZm5xs1d3kYSt2Q1ffs8fmnJC7aRkmJSk+urgyS/M1q70B3ikpMkKs=
+db.center.driver=org.h2.Driver
+db.center.username=
+db.center.password=
+db.security.url=XwvGDpBZSBmSSTgwYR/tP7TpjDOvxCbfcglDFj++b1Fedp1LiiAhzeXvfe2025PchJIJuMDp6u0fxe24i8VfQxYG8MY2n8tyiQftih0drHi8OA7dqB8pEtZm5xs1d3kYSt2Q1ffs8fmnJC7aRkmJSk+urgyS/M1q70B3ikpMkKs=
+db.security.driver=org.h2.Driver
+db.security.username=
+db.security.password=
 cer.public-key=MIGfMA0GCSqGSIb3DQEBAQUAA4GNADCBiQKBgQCfbyuRrG+YUX7dy/ziNqxsPP7YPKUnti+m3yDfJdN2MKa1GcIvPkfIXZ5EfEkoI9m5NwPfeC+kwM1fDWxvY/oMo/lWpIAo2zkhxssIXSkukF79I0N4vH+JAcuHN7llPYgMGkkyIe/FP/A1ZkGEayjMMqm4cfPs3vthsWgdmbnxHwIDAQAB
 cer.private-key=MIICdgIBADANBgkqhkiG9w0BAQEFAASCAmAwggJcAgEAAoGBAJ9vK5Gsb5hRft3L/OI2rGw8/tg8pSe2L6bfIN8l03YwprUZwi8+R8hdnkR8SSgj2bk3A994L6TAzV8NbG9j+gyj+VakgCjbOSHGywhdKS6QXv0jQ3i8f4kBy4c3uWU9iAwaSTIh78U/8DVmQYRrKMwyqbhx8+ze+2GxaB2ZufEfAgMBAAECgYAyMdTcuxYzNU0k1SkbqyzjstxlBcrVUtVzywHVX1pQ9oY1tBNfvlLpMRg35Y0+tvLADiMJAxS04QKHb3l5JFe/jE24hNxMj2h9JfxO36bGblyqZ7PlS+5/pvXdVaFYolN+5Rocf63/Iq2RSCb8W3D5uUQqLwO/i1iFQT+UROUA4QJBAOvvOJSB4BIu4VD/6XGqZ5cLU3DMtwzHIyvTTH2REGF33eEHc0z83VYi4xbUDGxvDD1d58bPqkpnvJiByXmYVa8CQQCs/mHfpO8fDy7ZKGzs1u4eBsPowSnJLsGbY2mYiaawnHeeLYOaGEdtxRVk06+seTFLw5oi3FDJG8U8LP6FiGeRAkAjZiQeHBJrh/8kcREsjb23KurdDMoWL7a2N6DNYjuL9DklL0H8diAbcWaTIUOv7UVv26wP506MlV31n9uD0/hfAkBo3gwWtrT97wZHPepJ6ECQkylPf0kFXAKhX7Izdb5GcZNRn+WXFAC42jAN3wUvWIg5lWlqmIOgZeU6hUwFRpsBAkEAsSe8v0cho1YTdmXiGQ7uhUxZ455mrw81AdzmuvDxvWFLx1uHAZna9eylZsfbEa7Y9DcmakLJKGWaTvKvYc55ZQ==