init_05

.gitignore

@@ -31,3 +31,5 @@ build/
 
 ### VS Code ###
 .vscode/
+/images/
+/jdk/

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

@@ -3,13 +3,16 @@ package com.scbfkj.uni.api;
 import com.scbfkj.uni.library.RequestUtil;
 import com.scbfkj.uni.library.UniReturnUtil;
 import com.scbfkj.uni.process.DataBase;
+import com.scbfkj.uni.service.LoggerService;
 import com.scbfkj.uni.service.SecurityService;
 import com.scbfkj.uni.system.Config;
+import com.scbfkj.uni.system.LogTarget;
 import jakarta.annotation.Resource;
 import jakarta.servlet.http.HttpServletRequest;
 import org.aspectj.lang.ProceedingJoinPoint;
 import org.aspectj.lang.annotation.Around;
 import org.aspectj.lang.annotation.Aspect;
+import org.springframework.beans.factory.annotation.Value;
 import org.springframework.http.ResponseEntity;
 import org.springframework.stereotype.Component;
 import org.springframework.web.context.request.RequestContextHolder;
@@ -21,6 +24,9 @@ import java.util.*;
 @Aspect
 public class LogAop {
 
+    @Resource
+    private LoggerService loggerService;
+
     @Resource
     private SecurityService securityService;
 
@@ -28,16 +34,20 @@ public class LogAop {
 
 
     @Around(value = "within( com.scbfkj.uni.api.*)")
-    public Object invokeAround(ProceedingJoinPoint joinPoint) {
+    public ResponseEntity<Map<String, Object>> invokeAround(ProceedingJoinPoint joinPoint) {
 //        当前时间戳
         long beforeTime = System.currentTimeMillis();
 
+        ServletRequestAttributes requestAttributes = (ServletRequestAttributes) RequestContextHolder.currentRequestAttributes();
+//            前端需求添加header
+        if (requestAttributes.getResponse() != null) {
+            requestAttributes.getResponse().addHeader("Set-Cookie", "SameSite=None");
+        }
+        HttpServletRequest request = requestAttributes.getRequest();
+
         try {
 
 //        请求
-            ServletRequestAttributes requestAttributes = (ServletRequestAttributes) RequestContextHolder.currentRequestAttributes();
-//
-            HttpServletRequest request = requestAttributes.getRequest();
             String uri = request.getRequestURI();
 //        请求参数
             Object[] args = joinPoint.getArgs();
@@ -56,30 +66,33 @@ public class LogAop {
                     Map<String, Object> stringObjectMap = requestpath.get();
                     Object o = stringObjectMap.get("securitykey");
                     if (Objects.nonNull(o)) {
-                        if (Objects.equals(o, "token")) {
-                            String appToken = RequestUtil.getAppToken();
-                            if(Objects.isNull(appToken)){
-                                return ResponseEntity.ok(UniReturnUtil.fail("没有找到token"));
-                            }
-                            Map<String, Object> result = securityService.verifyToken(appToken);
-                            if (!result.get("code").equals("0")) {
-                                return result;
-                            }
-                        }
-                        if (Objects.equals("usertoken", o)) {
-                            String userToken = RequestUtil.getUserToken();
-                            if(Objects.isNull(userToken)){
-                                return ResponseEntity.ok(UniReturnUtil.fail("没有找到 usertoken"));
+                        String[] securityCheck = o.toString().split(",");
+                        for (String s : securityCheck) {
+                            if (Objects.equals(s, "token")) {
+                                String appToken = RequestUtil.getAppToken();
+                                if (Objects.isNull(appToken)) {
+                                    return ResponseEntity.ok(UniReturnUtil.fail("没有找到token"));
+                                }
+                                Map<String, Object> result = securityService.verifyToken(appToken);
+                                if (!result.get("code").equals("0")) {
+                                    return ResponseEntity.ok(result);
+                                }
                             }
-                            Map<String, Object> result = securityService.checkUserToken(userToken);
-                            if (!result.get("code").equals("0")) {
-                                return result;
+                            if (Objects.equals("usertoken", s)) {
+                                String userToken = RequestUtil.getUserToken();
+                                if (Objects.isNull(userToken)) {
+                                    return ResponseEntity.ok(UniReturnUtil.fail("没有找到 usertoken"));
+                                }
+                                Map<String, Object> result = securityService.checkUserToken(userToken);
+                                if (!result.get("code").equals("0")) {
+                                    return ResponseEntity.ok(result);
+                                }
                             }
                         }
                     }
                 }
             }
-            return joinPoint.proceed(args);
+            return ((ResponseEntity<Map<String, Object>>) joinPoint.proceed(args));
         } catch (Throwable e) {
             e.printStackTrace();
 //            错误异常消息

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

@@ -27,7 +27,7 @@ public class SecurityApi {
      * @return
      */
     @PostMapping("user/getToken")
-    public ResponseEntity getToken(@RequestBody Map<String, Object> body) throws Exception {
+    public ResponseEntity<Map<String,Object>> getToken(@RequestBody Map<String, Object> body) throws Exception {
         return ResponseEntity.ok(securityService.getToken(body));
     }
 
@@ -37,7 +37,7 @@ public class SecurityApi {
      * @return
      */
     @PostMapping("user/refreshToken")
-    public ResponseEntity refreshToken() throws Exception {
+    public ResponseEntity<Map<String,Object>> refreshToken() throws Exception {
         return ResponseEntity.ok(securityService.refreshToken());
     }
 
@@ -47,7 +47,7 @@ public class SecurityApi {
      * @return
      */
     @PostMapping({"user/testToken", "foxlibc/testToken"})
-    public ResponseEntity testToken() throws Exception {
+    public ResponseEntity<Map<String,Object>> testToken() throws Exception {
         String appToken = RequestUtil.getAppToken();
         return ResponseEntity.ok(securityService.verifyToken(appToken));
     }
@@ -58,7 +58,7 @@ public class SecurityApi {
      * @return
      */
     @PostMapping({"user/verifyCode", "foxlibc/verification-code"})
-    public ResponseEntity getCode() throws Exception {
+    public ResponseEntity<Map<String,Object>> getCode() throws Exception {
         return ResponseEntity.ok(securityService.verifyCode());
     }
 
@@ -68,7 +68,7 @@ public class SecurityApi {
      * @return
      */
     @PostMapping({"user/forceLogin", "foxlibc/force_sign"})
-    public ResponseEntity forceLogin() throws Exception {
+    public ResponseEntity<Map<String,Object>> forceLogin() throws Exception {
         return ResponseEntity.ok(securityService.forceLogin());
     }
 
@@ -79,7 +79,7 @@ public class SecurityApi {
      * @return
      */
     @PostMapping({"user/login", "foxlibc/sign-in"})
-    public ResponseEntity login(@RequestBody Map<String, Object> body) throws Exception {
+    public ResponseEntity<Map<String,Object>> login(@RequestBody Map<String, Object> body) throws Exception {
         return ResponseEntity.ok(securityService.login(body));
     }
 
@@ -89,7 +89,7 @@ public class SecurityApi {
      * @return
      */
     @PostMapping({"user/permissions", "foxlibc/permissions"})
-    public ResponseEntity getPermissions() throws Exception {
+    public ResponseEntity<Map<String,Object>> getPermissions() throws Exception {
         return ResponseEntity.ok(securityService.permission());
     }
 
@@ -101,7 +101,7 @@ public class SecurityApi {
      * @return
      */
     @PostMapping({"user/changePassword", "foxlibc/reset-passwd"})
-    public ResponseEntity changePwd(@RequestBody Map<String, Object> body) throws Exception {
+    public ResponseEntity<Map<String,Object>> changePwd(@RequestBody Map<String, Object> body) throws Exception {
         return ResponseEntity.ok(securityService.changePassword(body));
     }
 
@@ -111,7 +111,7 @@ public class SecurityApi {
      * @return
      */
     @PostMapping({"user/logOut", "foxlibc/sign-out"})
-    public ResponseEntity logOut() throws Exception {
+    public ResponseEntity<Map<String,Object>> logOut() throws Exception {
         return ResponseEntity.ok(securityService.logOut());
     }
 
@@ -121,7 +121,7 @@ public class SecurityApi {
      * @return
      */
     @PostMapping({"user/health", "foxlibc/health"})
-    public ResponseEntity health() throws Exception {
+    public ResponseEntity<Map<String,Object>> health() throws Exception {
         return ResponseEntity.ok(securityService.userHeartbeat());
     }
 }

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

@@ -11,7 +11,7 @@ public class CorsConfig implements WebMvcConfigurer {
         registry.addMapping("/**") // 所有接口
                 .allowCredentials(true) // 是否发送 Cookie
                 .allowedOriginPatterns("*") // 支持域
-                .allowedMethods(new String[]{"GET", "POST", "PUT", "DELETE"}) // 支持方法
+                .allowedMethods("GET", "POST", "PUT", "DELETE") // 支持方法
                 .allowedHeaders("*")
                 .exposedHeaders("*");
     }

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

@@ -1,11 +1,5 @@
 package com.scbfkj.uni.config;
 
-import com.oracle.truffle.js.runtime.builtins.temporal.TemporalYear;
-import com.scbfkj.uni.library.DataEncryptionUtil;
-import com.zaxxer.hikari.HikariConfig;
-import com.zaxxer.hikari.pool.HikariPool;
-import org.springframework.beans.factory.annotation.Value;
-import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
 
 @Configuration

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

@@ -1,24 +1,24 @@
 package com.scbfkj.uni.library;
 
+import com.scbfkj.uni.process.DataBase;
+import com.scbfkj.uni.system.Config;
+
 import java.util.*;
 
 public class DataAliasGetUtil {
 
-    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 static List<Map<String, Object>> keyAlias = null;
+
+    public static Optional<String> getValue(String key, Map<String, Object> data) throws Exception {
 
-    public static Optional<String> getValue(String key, Map<String, Object> data) {
-        if(Objects.isNull(data) || data.isEmpty()) return Optional.empty();
-        return alias.getOrDefault(key, Collections.singletonList(key)).stream().map(data::get).filter(Objects::nonNull).map(Object::toString).findAny();
+        Optional<String> result = Optional.ofNullable(data.get(key)).map(Object::toString);
+        if (result.isPresent()) return result;
+        if (Objects.isNull(keyAlias) || keyAlias.isEmpty()) {
+            keyAlias = DataBase.query(Config.centerConnectionStr, "select * from keyalias where aliasid>?", Collections.singletonList(new Object[]{0}));
+        }
+        List<Map<String, Object>> keynames = keyAlias.stream().filter(it -> Objects.equals(it.get("keyname"), key)).toList();
+        if (keynames.isEmpty()) return Optional.empty();
+        return keynames.stream().map(it -> it.get("aliasname")).map(data::get).filter(Objects::nonNull).map(Object::toString).findAny();
     }
 }

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

@@ -30,6 +30,9 @@ public final class DataFormatUtil {
     public static JsonNode stringToJsonNode(String source) throws JsonProcessingException {
         return objectMapper.readTree(source);
     }
+    public static <T> T  stringToBean(String source,Class<T> clazz) throws JsonProcessingException {
+        return objectMapper.readValue(source,clazz);
+    }
 
     public static ObjectNode stringToObjectNode(String source) throws JsonProcessingException {
         return objectMapper.readValue(source, ObjectNode.class);

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

@@ -1,9 +1,13 @@
 package com.scbfkj.uni.library;
 
+import com.scbfkj.uni.process.DataBase;
+import com.scbfkj.uni.system.Config;
 import jakarta.servlet.http.HttpServletRequest;
 import org.springframework.web.context.request.RequestContextHolder;
 import org.springframework.web.context.request.ServletRequestAttributes;
 
+import java.util.ArrayList;
+import java.util.List;
 import java.util.Map;
 import java.util.Objects;
 
@@ -15,16 +19,15 @@ 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)) {
+        if (ip == null || ip.isEmpty() || "unknown".equalsIgnoreCase(ip)) {
             ip = request.getHeader("Proxy-Client-IP");
         }
-        if (ip == null || ip.length() == 0 || "unknown".equalsIgnoreCase(ip)) {
+        if (ip == null || ip.isEmpty() || "unknown".equalsIgnoreCase(ip)) {
             ip = request.getHeader("WL-Proxy-Client-IP");
         }
-        if (ip == null || ip.length() == 0 || "unknown".equalsIgnoreCase(ip)) {
+        if (ip == null || ip.isEmpty() || "unknown".equalsIgnoreCase(ip)) {
             ip = request.getRemoteAddr();
         }
         return ip;
@@ -33,35 +36,57 @@ public class RequestUtil {
     public static String getAppToken() {
 //        请求
         ServletRequestAttributes requestAttributes = (ServletRequestAttributes) RequestContextHolder.currentRequestAttributes();
-//
         Object appToken = requestAttributes.getRequest().getHeader("token");
         return Objects.nonNull(appToken) ? appToken.toString() : null;
 
     }
 
     public static String getUserToken() {
-//        请求
         ServletRequestAttributes requestAttributes = (ServletRequestAttributes) RequestContextHolder.currentRequestAttributes();
-//
-        Object userToken =  requestAttributes.getRequest().getHeader("usertoken");
+        Object userToken = requestAttributes.getRequest().getHeader("usertoken");
         return Objects.nonNull(userToken) ? userToken.toString() : null;
 
     }
     public static String getAppId() {
 //        请求
         ServletRequestAttributes requestAttributes = (ServletRequestAttributes) RequestContextHolder.currentRequestAttributes();
-//
         Object appid = requestAttributes.getAttribute("appid", SCOPE_SESSION);
         return Objects.nonNull(appid) ? appid.toString() : null;
 
     }
-    public static Map<String,Object> getApplication() {
+
+    public static Map<String, Object> getApplication() throws Exception {
 //        请求
         ServletRequestAttributes requestAttributes = (ServletRequestAttributes) RequestContextHolder.currentRequestAttributes();
 //
         Object application = requestAttributes.getAttribute("application", SCOPE_SESSION);
-        return Objects.nonNull(application) ? (Map<String, Object>) application : null;
+        if (Objects.isNull(application)) {
+            throw new RuntimeException("获取应用失败 当前连接没有找到应用");
+        }
+        if (Objects.nonNull(application)) {
+            return (Map<String, Object>) application;
+        }
+
+        String appToken = getAppToken();
+        String requestIp = getIpAddr();
+        String query = "select * from appconnectlog where apptoken=? and requestip =?";
+        List<Map<String, Object>> appConnectLogList = DataBase.query(Config.securityConnectionStr, query, new ArrayList<>() {{
+            add(new Object[]{appToken, requestIp});
+        }});
+        if (appConnectLogList.isEmpty()) {
+            throw new RuntimeException("当前连接未登录");
+        }
+        Map<String, Object> stringObjectMap = appConnectLogList.get(0);
+        Object applicationid = stringObjectMap.get("applicationid");
 
+        query = "select * from application where applicationid=?";
+        List<Map<String, Object>> applicationList = DataBase.query(Config.securityConnectionStr, query, new ArrayList<>() {{
+            add(new Object[]{applicationid});
+        }});
+        if (applicationList.isEmpty()) {
+            throw new RuntimeException("获取应用失败");
+        }
+        return applicationList.get(0);
     }
     public static String getUserId() {
 //        请求
@@ -71,7 +96,8 @@ public class RequestUtil {
         return Objects.nonNull(appid) ? appid.toString() : null;
 
     }
-    public static Map<String,Object> getUserInfo() {
+
+    public static Map<String, Object> getUserInfo() {
 //        请求
         ServletRequestAttributes requestAttributes = (ServletRequestAttributes) RequestContextHolder.currentRequestAttributes();
 //
@@ -81,7 +107,6 @@ public class RequestUtil {
 
     public static String getSessionId() {
         return RequestContextHolder.currentRequestAttributes().getSessionId();
-
     }
 
 }

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

@@ -16,7 +16,6 @@ public final class ScriptEngineUtil {
             (value) => {
                 if (typeof value === 'string') return value
                 return JSON.stringify(value);
-
             }
             """;
 

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

@@ -20,8 +20,6 @@ public class DataBase {
 
     public static List<Map<String, Object>> query(String connectionStr, String sql, List<Object[]> argsList) throws Exception {
         HikariPool dataSourcePool = getDataSourcePool(connectionStr);
-
-
         return argsList.parallelStream().flatMap(args -> {
             try (Connection connection = dataSourcePool.getConnection();
                  PreparedStatement preparedStatement = connection.prepareStatement(sql)
@@ -153,7 +151,7 @@ public class DataBase {
         JsonNode username = jsonNode.get("username");
         JsonNode password = jsonNode.get("password");
         JsonNode driverClassName = jsonNode.get("driverClassName");
-        HikariPool dataSourcePool = createDataSourcePool(jdbcUrl.asText(), Objects.isNull(username) ? null : username.asText(), Objects.isNull(password) ? null : password.asText(), driverClassName.asText(), null);
+        HikariPool dataSourcePool = createDataSourcePool(jdbcUrl.asText(), Objects.isNull(username) ? null : username.asText(), Objects.isNull(password) ? null : password.asText(), driverClassName.asText(), connectionStr);
         dataSourcePools.put(connectionStr, dataSourcePool);
         return dataSourcePool;
     }

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

@@ -18,11 +18,11 @@ public class CodeCacheService {
         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});
+            add(new Object[]{ appid, requestIp, sessionId, code, localDateTime});
         }});
-        String deleteSql = "delete from tempsecuritycode where expiretime < now() and 1=?";
+        String deleteSql = "delete from tempsecuritycode where expiretime < ?";
         DataBase.updateBatch(Config.securityConnectionStr, deleteSql, new ArrayList<>() {{
-            add(new Object[]{1});
+            add(new Object[]{LocalDateTime.now()});
         }});
     }
 

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

@@ -1,4 +1,20 @@
 package com.scbfkj.uni.service;
 
+import java.util.Map;
+
 public class ControlService {
+
+    public Map<String,Object> start(String serviceId){
+
+        return null;
+    }
+
+    public Map<String,Object> stop(String serviceId){
+
+        return null;
+    }
+    public Map<String,Object> restart(String serviceId){
+
+        return null;
+    }
 }

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

@@ -16,7 +16,7 @@ import java.util.stream.Collectors;
 
 @Service
 public class DataProcessService {
-    public Map<String, Object> process(Map<String, Object> inData) {
+    public Map<String, Object> process(Map<String, Object> inData) throws Exception {
         Optional<String> serviceIdOpt = DataAliasGetUtil.getValue("serviceid", inData);
         if (serviceIdOpt.isEmpty()) {
             return UniReturnUtil.fail("服务编号不能为空");

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

@@ -3,38 +3,19 @@ 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 com.scbfkj.uni.system.LogTarget;
+import org.springframework.stereotype.Service;
 
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
 
+@Service
 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) {
@@ -50,7 +31,7 @@ public class LoggerService {
     }
 
     private static void write(LogTarget target, ObjectNode node) {
-        String key = target.getTarget() + ";" + target.getConnection();
+        String key = target.getType() + ";" + target.getConnection();
         if (!logs.containsKey(key)) {
             logs.put(key, List.of(node));
         } else {

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

@@ -24,31 +24,6 @@ public class SecurityService {
     @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 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 UPDATE_USER_INFO_WITH_PASSWORD_BY_USER_ID = "update userinfo set userpassword=? 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_SESSION_ID = "select * from userloginlog where isexpires=0 and usertoken=? and sessionid=?";
-    private final static String QUERY_USER_PERMISSIONS_BY_USER_ID = " select userpermissionsid, t2.userid,  t3.pagecode, t1.serviceid, insertcolumnlist, updatecolumnlist, selectcolumnlist, filterset from userinfo t2,userpermissions t1 left join pageconfiguration t3 on t3.pageconfigurationid=t1.pageconfigurationid where t1.userid=t2.userid and t1.userid = ?";
-
     private final CodeCacheService codeCacheService;
 
     public SecurityService(CodeCacheService codeCacheService) {
@@ -226,7 +201,7 @@ public class SecurityService {
         Optional<String> password = getValue("password", requestData);
         Optional<String> verifycode = getValue("verifycode", requestData);
 //        解密验证码
-        String code = DataEncryptionUtil.decryptByPrivateKey(verifycode.get(), privateKeyStr, TYPE, ALGORITHM);
+        String code = DataEncryptionUtil.decryptByPrivateKey(verifycode.get(), Config.privateKeyStr, Config.TYPE, Config.ALGORITHM);
         String appId = RequestUtil.getAppId();
 
         Map<String, Object> application = RequestUtil.getApplication();
@@ -239,7 +214,7 @@ public class SecurityService {
 
         String query = "select * from userinfo where  username =? and userpassword=? ";
         List<Map<String, Object>> userInfoList = DataBase.query(Config.securityConnectionStr, query, new ArrayList<>() {{
-            add(new Object[]{username.get(), DataEncryptionUtil.decryptByPrivateKey(password.get(), privateKeyStr, TYPE, ALGORITHM)});
+            add(new Object[]{username.get(), DataEncryptionUtil.decryptByPrivateKey(password.get(), Config.privateKeyStr, Config.TYPE, Config.ALGORITHM)});
         }});
         if (userInfoList.isEmpty()) {
             return UniReturnUtil.fail("用户名密码错误");
@@ -284,6 +259,7 @@ public class SecurityService {
             }
         }
 
+        codeCacheService.remove(code, sessionId, appId, ip);
 
         return UniReturnUtil.success(data);
     }
@@ -327,7 +303,7 @@ public class SecurityService {
 
     public Map<String, Object> checkUserToken(String userToken) throws Exception {
         String sessionId = RequestUtil.getSessionId();
-        String query = "select * from userloginlog where isexpires=0 and usertoken=? and sessionid=?";
+        String query = "select * from userloginlog where isexpires = 0 and usertoken = ? and sessionid = ?";
         List<Map<String, Object>> userLoginLogList = DataBase.query(Config.securityConnectionStr, query, new ArrayList<>() {{
             add(new Object[]{userToken, sessionId});
         }});
@@ -398,8 +374,8 @@ public class SecurityService {
         Optional<String> passwordOpt = getValue("password", requestData);
         Map<String, Object> userInfo = RequestUtil.getUserInfo();
         String userpassword = userInfo.get("userpassword").toString();
-        String password = DataEncryptionUtil.decryptByPrivateKey(passwordOpt.get(), privateKeyStr, TYPE, ALGORITHM);
-        String oldPassword = DataEncryptionUtil.decryptByPrivateKey(oldPasswordOpt.get(), privateKeyStr, TYPE, ALGORITHM);
+        String password = DataEncryptionUtil.decryptByPrivateKey(passwordOpt.get(), Config.privateKeyStr, Config.TYPE, Config.ALGORITHM);
+        String oldPassword = DataEncryptionUtil.decryptByPrivateKey(oldPasswordOpt.get(), Config.privateKeyStr, Config.TYPE, Config.ALGORITHM);
         if (!userpassword.equals(oldPassword)) {
             return UniReturnUtil.fail("密码错误");
         } else {

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

@@ -13,10 +13,7 @@ import org.springframework.beans.factory.annotation.Value;
 import org.springframework.core.env.Environment;
 import org.springframework.stereotype.Component;
 
-import java.util.HashMap;
-import java.util.Map;
-import java.util.Objects;
-import java.util.Optional;
+import java.util.*;
 
 @Component
 public class Config {
@@ -26,4 +23,11 @@ public class Config {
 
     public static boolean enable;
 
+    public static List<LogTarget> logTargets=new ArrayList<>();
+
+    public static   String privateKeyStr="MIICdgIBADANBgkqhkiG9w0BAQEFAASCAmAwggJcAgEAAoGBAJ9vK5Gsb5hRft3L/OI2rGw8/tg8pSe2L6bfIN8l03YwprUZwi8+R8hdnkR8SSgj2bk3A994L6TAzV8NbG9j+gyj+VakgCjbOSHGywhdKS6QXv0jQ3i8f4kBy4c3uWU9iAwaSTIh78U/8DVmQYRrKMwyqbhx8+ze+2GxaB2ZufEfAgMBAAECgYAyMdTcuxYzNU0k1SkbqyzjstxlBcrVUtVzywHVX1pQ9oY1tBNfvlLpMRg35Y0+tvLADiMJAxS04QKHb3l5JFe/jE24hNxMj2h9JfxO36bGblyqZ7PlS+5/pvXdVaFYolN+5Rocf63/Iq2RSCb8W3D5uUQqLwO/i1iFQT+UROUA4QJBAOvvOJSB4BIu4VD/6XGqZ5cLU3DMtwzHIyvTTH2REGF33eEHc0z83VYi4xbUDGxvDD1d58bPqkpnvJiByXmYVa8CQQCs/mHfpO8fDy7ZKGzs1u4eBsPowSnJLsGbY2mYiaawnHeeLYOaGEdtxRVk06+seTFLw5oi3FDJG8U8LP6FiGeRAkAjZiQeHBJrh/8kcREsjb23KurdDMoWL7a2N6DNYjuL9DklL0H8diAbcWaTIUOv7UVv26wP506MlV31n9uD0/hfAkBo3gwWtrT97wZHPepJ6ECQkylPf0kFXAKhX7Izdb5GcZNRn+WXFAC42jAN3wUvWIg5lWlqmIOgZeU6hUwFRpsBAkEAsSe8v0cho1YTdmXiGQ7uhUxZ455mrw81AdzmuvDxvWFLx1uHAZna9eylZsfbEa7Y9DcmakLJKGWaTvKvYc55ZQ==";
+
+    public final static String TYPE = "RSA";
+
+    public final static String ALGORITHM = "RSA/ECB/PKCS1Padding";
 }

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

@@ -0,0 +1,30 @@
+package com.scbfkj.uni.system;
+
+public class LogTarget {
+    private LogTargetType type;
+    private String connection;
+
+    public LogTarget(LogTargetType type, String connection) {
+        this.type = type;
+        this.connection = connection;
+    }
+
+    public LogTarget() {
+    }
+
+    public LogTargetType getType() {
+        return type;
+    }
+
+    public void setType(LogTargetType type) {
+        this.type = type;
+    }
+
+    public String getConnection() {
+        return connection;
+    }
+
+    public void setConnection(String connection) {
+        this.connection = connection;
+    }
+}

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

@@ -0,0 +1,5 @@
+package com.scbfkj.uni.system;
+
+public enum LogTargetType {
+    ES,DB,KAFKA
+}

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

@@ -1,4 +1,31 @@
 package com.scbfkj.uni.system;
 
-public class ScheduleTask {
+import java.time.LocalDateTime;
+import java.util.Date;
+
+public class ScheduleTask implements Runnable {
+    private final String id; // 服务ID
+
+    private final String name;
+    Integer loopCount;
+    int count = 0;
+    public LocalDateTime taskValid;
+    public LocalDateTime taskInvalid;
+
+    /**
+     * @param id 任务ID
+     */
+    public ScheduleTask(String name, String id, Integer loopCount, LocalDateTime taskValid, LocalDateTime taskInvalid) {
+        this.name = name;
+        this.id = id;
+        this.loopCount = loopCount;
+        this.taskValid = taskValid;
+        this.taskInvalid = taskInvalid;
+    }
+
+    @Override
+    public void run() {
+
+    }
+
 }

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

@@ -1,10 +1,14 @@
 package com.scbfkj.uni.system;
 
 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 java.util.List;
+
+
 @Component
 public class SystemInit {
 
@@ -15,9 +19,6 @@ public class SystemInit {
     @Value("${db.security.config}")
     private String securityconfig;
 
-    @Value("${cer.private-key}")
-    private String privateKeyStr;
-
     @Value("${app.security.enable:true}")
     private boolean enableSecurity;
 
@@ -26,11 +27,22 @@ public class SystemInit {
 
     private final static String ALGORITHM = "RSA/ECB/PKCS1Padding";
 
+    @Value("${log.target}")
+    private List<String> targets;
+
 
     @PostConstruct
     public void init() throws Exception {
         Config.enable = enableSecurity;
-        Config.centerConnectionStr = DataEncryptionUtil.decryptByPrivateKey(centerConfig, privateKeyStr, TYPE, ALGORITHM);
-        Config.securityConnectionStr = DataEncryptionUtil.decryptByPrivateKey(securityconfig, privateKeyStr, TYPE, ALGORITHM);
+        Config.centerConnectionStr = DataEncryptionUtil.decryptByPrivateKey(centerConfig, Config.privateKeyStr, TYPE, ALGORITHM);
+        Config.securityConnectionStr = DataEncryptionUtil.decryptByPrivateKey(securityconfig, Config.privateKeyStr, TYPE, ALGORITHM);
+
+        for (String targetStr : targets) {
+
+            String target = DataEncryptionUtil.decryptByPrivateKey(targetStr, Config.privateKeyStr, TYPE, ALGORITHM);
+            Config.logTargets.add(DataFormatUtil.stringToBean(target, LogTarget.class));
+
+        }
+
     }
 }

src/main/resources/application.properties

@@ -1,6 +1,6 @@
-db.center.config=Se48Cp+uVFb7LO8DqY22FY61LC/nXVsArwtFd9cQT4F+Tb+i/N22a2SpOCgEHuqU33asvO8Hf1F54k7dRminlFcHNRfEi8cRbQzUyrbrNimODQXEgPdGq9kl1H7Dqe85lKKKfAwRZfiCR9CkfLEyq82ZcmEVBviFR13+186u/Fs=
-
-db.security.config=DMz+NaApH3QRq4vaGJb2zCB4ADR4sw5c768OsQQu74mKLURIbWqNDoCRjRKd1GQPYH/NxZCpEeR5LC8yTdJut0BEPD20fBD58wVhD3SUNkBKN45cT7j3AOVJkCL26qVneTJ3V0ybNJG70xsa/aGRj3gq5S1nafn5jbEQriA+9rk=
-
+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==
 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==
+db.center.config=Ozv/+moZAen+UIE6yFPRwjEXiwnfjSlPIXlkUiv4DXdf5U2/a+zV3pewOY1GF79GMZbZqfgdUBcXkzJ1zPptw5OHTzqMw5a/K6+o+OLNfSUtk4IvTTWT3qfsE5S1MBwprbSz694Nyf4dFLQc4s3Nbd1USGsLfGF8bi6juzZcBpg=
+db.security.config=K3FX+3Jtr4unWWODD1+hWjueXJiJpA5ML5iRcM4bVn+gJHBZyA/TTb3zzv0fA5QLy6yOO2ngakhL0DsL3txcXeQGeXh5sFNjAlYXv169FQdKf6XIXiCCzR9VWKy6h4yhC9L3ib5h2LXVZ+lQQnLLswpq0FYYhgdm7KAxrTZrviA=
+log.target=B7xSbq4imA5zapX8kEO42mU/5sA2TyF/Ba2Y/++F3z9Np7iT4ywDUkbRC4w/Xrxv1kMSR8PQMJ4dfYwc3mYj0SJJivN5A5/6hI+ZSQBabfZZrYwaIIRdM1XIk4wo1SIrSCXKzef8X6YUH70R2tnh+Uq6KNNp08KaZ2ZXM8vX5Ss=
+server.port=8085

src/test/java/com/scbfkj/uni/UniApplicationTests.java

@@ -3,11 +3,36 @@ package com.scbfkj.uni;
 import org.junit.jupiter.api.Test;
 import org.springframework.boot.test.context.SpringBootTest;
 
-@SpringBootTest
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+
 class UniApplicationTests {
+	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"));
+	}
 	@Test
 	void contextLoads() {
+		String sql ="insert into keyalias (keyname,aliasname) values";
+		StringBuilder stringBuilder = new StringBuilder(sql);
+		alias.forEach((key,value)->{
+
+		value.forEach(it->{
+			stringBuilder.append("('%s','%s'),".formatted(key,it));
+		});
+		});
+
+		System.out.println(stringBuilder);
 	}
 
 }

src/test/java/com/scbfkj/uni/library/DataEncryptionUtilTest.java

@@ -0,0 +1,64 @@
+package com.scbfkj.uni.library;
+
+import org.junit.jupiter.api.Assertions;
+import org.junit.jupiter.api.Test;
+
+import java.security.KeyPairGenerator;
+
+import static org.junit.jupiter.api.Assertions.*;
+
+class DataEncryptionUtilTest {
+    @Test
+    void rsaEncodeAndDecrypt() throws Exception {
+
+        String type = "RSA";
+
+        // 将公钥和私钥转换为Base64编码的字符串
+//        String publicKeyString = Base64.getEncoder().encodeToString(publicKey.getEncoded());
+        String publicKeyString = "MIGfMA0GCSqGSIb3DQEBAQUAA4GNADCBiQKBgQCfbyuRrG+YUX7dy/ziNqxsPP7YPKUnti+m3yDfJdN2MKa1GcIvPkfIXZ5EfEkoI9m5NwPfeC+kwM1fDWxvY/oMo/lWpIAo2zkhxssIXSkukF79I0N4vH+JAcuHN7llPYgMGkkyIe/FP/A1ZkGEayjMMqm4cfPs3vthsWgdmbnxHwIDAQAB";
+//        String privateKeyString = Base64.getEncoder().encodeToString(privateKey.getEncoded());
+        String privateKeyString = "MIICdgIBADANBgkqhkiG9w0BAQEFAASCAmAwggJcAgEAAoGBAJ9vK5Gsb5hRft3L/OI2rGw8/tg8pSe2L6bfIN8l03YwprUZwi8+R8hdnkR8SSgj2bk3A994L6TAzV8NbG9j+gyj+VakgCjbOSHGywhdKS6QXv0jQ3i8f4kBy4c3uWU9iAwaSTIh78U/8DVmQYRrKMwyqbhx8+ze+2GxaB2ZufEfAgMBAAECgYAyMdTcuxYzNU0k1SkbqyzjstxlBcrVUtVzywHVX1pQ9oY1tBNfvlLpMRg35Y0+tvLADiMJAxS04QKHb3l5JFe/jE24hNxMj2h9JfxO36bGblyqZ7PlS+5/pvXdVaFYolN+5Rocf63/Iq2RSCb8W3D5uUQqLwO/i1iFQT+UROUA4QJBAOvvOJSB4BIu4VD/6XGqZ5cLU3DMtwzHIyvTTH2REGF33eEHc0z83VYi4xbUDGxvDD1d58bPqkpnvJiByXmYVa8CQQCs/mHfpO8fDy7ZKGzs1u4eBsPowSnJLsGbY2mYiaawnHeeLYOaGEdtxRVk06+seTFLw5oi3FDJG8U8LP6FiGeRAkAjZiQeHBJrh/8kcREsjb23KurdDMoWL7a2N6DNYjuL9DklL0H8diAbcWaTIUOv7UVv26wP506MlV31n9uD0/hfAkBo3gwWtrT97wZHPepJ6ECQkylPf0kFXAKhX7Izdb5GcZNRn+WXFAC42jAN3wUvWIg5lWlqmIOgZeU6hUwFRpsBAkEAsSe8v0cho1YTdmXiGQ7uhUxZ455mrw81AdzmuvDxvWFLx1uHAZna9eylZsfbEa7Y9DcmakLJKGWaTvKvYc55ZQ==";
+
+        System.out.println("public:  " + publicKeyString);
+        System.out.println("private:  " + privateKeyString);
+
+        String algorithm = "RSA/ECB/PKCS1Padding";
+        String data = """
+                 {
+                  "jdbcUrl": "jdbc:sqlite:systemset.sqlite",
+                  "driverClassName": "org.sqlite.JDBC"
+                }
+                                """;
+        String encryptedData = DataEncryptionUtil.encryptByPublicKey(data, publicKeyString, type, algorithm);
+        String decryptedData = DataEncryptionUtil.decryptByPrivateKey(encryptedData, privateKeyString, type, algorithm);
+        System.out.println(data + ": " + encryptedData);
+        Assertions.assertEquals(data, decryptedData);
+        data = """
+                {
+                  "jdbcUrl": "jdbc:sqlite:uniauth.sqlite",
+                  "driverClassName": "org.sqlite.JDBC"
+                }
+                                """;
+        encryptedData = DataEncryptionUtil.encryptByPublicKey(data, publicKeyString, type, algorithm);
+        decryptedData = DataEncryptionUtil.decryptByPrivateKey(encryptedData, privateKeyString, type, algorithm);
+        System.out.println(data + ": " + encryptedData);
+        Assertions.assertEquals(data, decryptedData);
+        data = """
+                {"type": "ES","connection": "{\\"jdbcUrl\\": \\"jdbc:sqlite:log.sqlite\\",\\"driverClassName\\": \\"org.sqlite.JDBC\\"}"}
+                                                """.trim();
+        encryptedData = DataEncryptionUtil.encryptByPublicKey(data, publicKeyString, type, algorithm);
+        decryptedData = DataEncryptionUtil.decryptByPrivateKey(encryptedData, privateKeyString, type, algorithm);
+        System.out.println(data + ": " + encryptedData);
+        Assertions.assertEquals(data, decryptedData);
+//         data = "jdbc:h2:file:./center.h2";
+//         encryptedData = DataEncryption.encryptByPublicKey(data, publicKeyString, type, algorithm);
+//         decryptedData = DataEncryption.decryptByPrivateKey(encryptedData, privateKeyString, type, algorithm);
+//        System.out.println(data+": "+encryptedData);
+//        Assertions.assertEquals(data, decryptedData);
+//        encryptedData = DataEncryption.encryptByPrivateKey(data, privateKeyString, type, algorithm);
+//        decryptedData = DataEncryption.decryptByPublicKey(encryptedData, publicKeyString, type, algorithm);
+//        Assertions.assertEquals(data, decryptedData);
+    }
+
+
+}

src/test/java/com/scbfkj/uni/library/ScriptEngineUtilTest.java

@@ -6,14 +6,4 @@ import static org.junit.jupiter.api.Assertions.*;
 
 class ScriptEngineUtilTest {
 
-    @Test
-    void eval() throws Exception {
-        long l = System.currentTimeMillis();
-        for (int i = 0; i < 1; i++) {
-
-        String eval = ScriptEngineUtil.eval("()=>{ return 1}");
-            System.out.println(eval);
-        }
-        System.out.println(System.currentTimeMillis()-l);
-    }
 }

src/test/java/com/scbfkj/uni/process/DataBaseTest.java

@@ -12,18 +12,4 @@ import static org.junit.jupiter.api.Assertions.*;
 
 class DataBaseTest {
 
-    @Test
-    void query() throws Exception {
-        List<Map<String, Object>> mapList = DataBase.query("""
-                {
-                  "jdbcUrl": "jdbc:sqlite:D:\\\\code\\\\uni\\\\sqlite.db",
-                  "driverClassName":"org.sqlite.JDBC"
-                }
-                """, "select *  from testtable where age=?", new ArrayList<>() {{
-            add(new Object[]{1});
-            add(new Object[]{2});
-            add(new Object[]{3});
-        }});
-        System.out.println(DataFormatUtil.toString(mapList));
-    }
 }