update_21

pom.xml

@@ -8,14 +8,14 @@
 		<version>3.1.4</version>
 		<relativePath/> <!-- lookup parent from repository -->
 	</parent>
-	<groupId>com.example</groupId>
+	<groupId>com.scbfkj</groupId>
 	<artifactId>uni</artifactId>
 	<version>0.0.1</version>
 	<name>uni</name>
 	<description>uni</description>
 	<properties>
 		<java.version>17</java.version>
-		<graalvm.version>23.0.1</graalvm.version>
+		<graalvm.version>23.1.1</graalvm.version>
 	</properties>
 	<dependencies>
 		<dependency>
@@ -75,10 +75,29 @@
 			<artifactId>commons-net</artifactId>
 			<version>3.9.0</version>
 		</dependency>
+		<!--
+        The polyglot dependency is always required for Java embeddings.
+        It contains the polyglot embedding APIs to include any polyglot language. -->
 		<dependency>
-			<groupId>org.graalvm.js</groupId>
+			<groupId>org.graalvm.polyglot</groupId>
+			<artifactId>polyglot</artifactId>
+			<version>${graalvm.version}</version>
+		</dependency>
+		<!--
+        Choose here which languages should be used.
+        Available languages in the polyglot group are:
+            js, ruby, python, wasm, llvm, llvm-native, java
+
+        Switch to community licenses by adding a `-community` suffix to the artefact id (e.g. `js-communtiy`).
+        Switch to native isolate versions of languages by adding a `-isolate` suffix. (`js-isolate`).
+
+        Any dependency in the org.graalvm.polyglot group is intended for use by polyglot embeddings.
+        -->
+		<dependency>
+			<groupId>org.graalvm.polyglot</groupId>
 			<artifactId>js</artifactId>
 			<version>${graalvm.version}</version>
+			<type>pom</type>
 		</dependency>
 		<dependency>
 			<groupId>com.zaxxer</groupId>

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

@@ -6,10 +6,7 @@ import com.scbfkj.uni.service.DataProcessService;
 import com.scbfkj.uni.system.Config;
 import org.springframework.http.HttpStatusCode;
 import org.springframework.http.ResponseEntity;
-import org.springframework.web.bind.annotation.PostMapping;
-import org.springframework.web.bind.annotation.RequestBody;
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RestController;
+import org.springframework.web.bind.annotation.*;
 
 import java.util.Collections;
 import java.util.List;
@@ -47,8 +44,8 @@ public class GenericApi {
      * @throws Exception
      */
 
-    @PostMapping("{path}")
-    public ResponseEntity<Map<String,Object>> matchService(@RequestBody Map<String, Object> body) throws Exception {
+    @PostMapping("*")
+    public ResponseEntity<Map<String,Object>> matchService( @RequestBody Map<String, Object> body) throws Exception {
         String uri = RequestUtil.getUri();
         List<Map<String, Object>> serviceinfoList = DataBase.query(Config.centerConnectionStr, "select * from serviceinfo where urilist like concat('%',?,'%')", Collections.singletonList(new Object[]{"/openApi/%s".formatted(uri)}));
 

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

@@ -14,6 +14,8 @@ import jakarta.servlet.http.HttpServletRequest;
 import org.aspectj.lang.ProceedingJoinPoint;
 import org.aspectj.lang.annotation.Around;
 import org.aspectj.lang.annotation.Aspect;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 import org.springframework.http.ResponseEntity;
 import org.springframework.stereotype.Component;
 import org.springframework.web.context.request.RequestContextHolder;
@@ -29,6 +31,8 @@ import java.util.stream.Stream;
 @Aspect
 public class LogAop {
 
+    private static final Logger logger= LoggerFactory.getLogger(LogAop.class);
+
 
     @Resource
     private SecurityService securityService;
@@ -57,6 +61,15 @@ public class LogAop {
         Object returnData = null;
         String message = null;
 
+
+        if(Config.debug){
+            logger.info("请求参数：{}",DataFormatUtil.toString(args));
+            logger.info("请求路径：{}",uri);
+            logger.info("请求session：{}",RequestUtil.getSessionId());
+            logger.info("请求ip：{}",RequestUtil.getIpAddr());
+            logger.info("请求appToken：{}",RequestUtil.getAppToken());
+        }
+
         try {
 
 //            判断服务状态是否为健康状态 runstate!=0
@@ -77,8 +90,6 @@ public class LogAop {
                             }
                         }
                     }
-                    ;
-
                 }
             }
             List<Map<String, Object>> ratelimitruleList = DataBase.query(Config.securityConnectionStr, "select * from ratelimitrule where 1=?", Collections.singletonList(new Object[]{1}));
@@ -146,6 +157,10 @@ public class LogAop {
                 }
             }
             returnData = joinPoint.proceed(args);
+
+            if(Config.debug){
+                logger.info("返回值：{}",DataFormatUtil.toString(returnData));
+            }
             return ((ResponseEntity<Map<String, Object>>) returnData);
         } catch (Throwable e) {
             if (Config.debug) {

src/main/java/com/scbfkj/uni/library/script/DatabaseScriptUtil.java

@@ -21,7 +21,7 @@ public class DatabaseScriptUtil {
 
         if (Objects.isNull(filterColumns)) filterColumns = new ArrayList<>();
         if (Objects.isNull(filterLines)) filterLines = new ArrayList<>();
-        String filterLineWhereStr =null;
+        String filterLineWhereStr = null;
         for (Object f : filterLines) {
             Map<String, Object> it = ((Map<String, Object>) f);
             filterLineWhereStr = " %s %s %s %s %s %s %s %s ".formatted(
@@ -30,7 +30,7 @@ public class DatabaseScriptUtil {
                     it.get("column"),
                     it.get("comparator"),
                     Objects.equals(it.get("comparator"), " is null ") ? "" : "?",
-                    !Objects.equals(it.get("comparator"), " is null ")?" ":it.get("value"),
+                    !Objects.equals(it.get("comparator"), " is null ") ? " " : it.get("value"),
                     it.getOrDefault("right", ""),
                     it.getOrDefault("connector", "")
             );
@@ -45,7 +45,7 @@ public class DatabaseScriptUtil {
                 Map<String, Object> map = args.get(0);
                 Map<String, Object> filter = ((Map<String, Object>) map.getOrDefault("filter", map));
                 filterNames = filter.keySet().stream().toList();
-                String whereStr =null;
+                String whereStr = null;
                 for (Object f : filterLines) {
                     Map<String, Object> it = ((Map<String, Object>) f);
                     whereStr = " %s %s %s %s %s %s %s %s ".formatted(
@@ -54,7 +54,7 @@ public class DatabaseScriptUtil {
                             it.get("column"),
                             it.get("comparator"),
                             Objects.equals(it.get("comparator"), " is null ") ? "" : "?",
-                            !Objects.equals(it.get("comparator"), " is null ")?" ":it.get("value"),
+                            !Objects.equals(it.get("comparator"), " is null ") ? " " : it.get("value"),
                             it.getOrDefault("right", ""),
                             it.getOrDefault("connector", "")
                     );
@@ -64,8 +64,8 @@ public class DatabaseScriptUtil {
                         filterNames.stream().map("%s = ?"::formatted).collect(Collectors.joining(" and ")),
                         Objects.isNull(filterLineWhereStr) ? " 1=1 " : filterLineWhereStr);
 
-                if( !filterColumns.isEmpty()){
-                    expression= "select %s from (%s) as T".formatted(String.join(",", filterColumns),expression);
+                if (!filterColumns.isEmpty()) {
+                    expression = "select %s from (%s) as T".formatted(String.join(",", filterColumns), expression);
                 }
 
                 List<Object[]> values = new ArrayList<>();
@@ -103,16 +103,20 @@ public class DatabaseScriptUtil {
                         insertValues.add(arg);
                     }
                 }
-                Map<String, Object> insertResult = exec(connectionStr, expression, insertValues, "1", filterColumns, filterLines);
-                Map<String, Object> updateResult = exec(connectionStr, expression, updateValues, "2", filterColumns, filterLines);
+                Map<String, Object> insertResult=null;
+                if (!insertValues.isEmpty())
+                    insertResult = exec(connectionStr, expression, insertValues, "1", filterColumns, filterLines);
+                Map<String, Object> updateResult = null;
+                if (!updateValues.isEmpty())
+                    updateResult = exec(connectionStr, expression, updateValues, "2", filterColumns, filterLines);
 
+                Map<String, Object> finalInsertResult = insertResult;
+                Map<String, Object> finalUpdateResult = updateResult;
                 return UniReturnUtil.success(new HashMap<>() {{
-                    put("insert", insertResult);
-                    put("update", updateResult);
+                    put("insert", finalInsertResult);
+                    put("update", finalUpdateResult);
                 }});
-
             } else {
-
 //                新增
                 if (Objects.equals("1", event)) {
                     Map<String, Object> map = args.get(0);
@@ -129,7 +133,7 @@ public class DatabaseScriptUtil {
 
                     expression = "update %s set %s where %s and %s".formatted(expression, valueNames.stream().map("%s = ?"::formatted).collect(Collectors.joining(",")),
                             filterNames.stream().map("%s = ?"::formatted).collect(Collectors.joining(" and ")),
-                            Objects.isNull(filterLineWhereStr)  ? " 1=1 " : filterLineWhereStr);
+                            Objects.isNull(filterLineWhereStr) ? " 1=1 " : filterLineWhereStr);
 //                    删除
                 } else if (Objects.equals("3", event)) {
                     Map<String, Object> map = args.get(0);
@@ -137,7 +141,7 @@ public class DatabaseScriptUtil {
                     filterNames = filter.keySet().stream().toList();
                     expression = "delete from %s where %s and  %s".formatted(expression,
                             filterNames.stream().map("%s = ?"::formatted).collect(Collectors.joining(" and ")),
-                            Objects.isNull(filterLineWhereStr)  ? " 1=1 " : filterLineWhereStr);
+                            Objects.isNull(filterLineWhereStr) ? " 1=1 " : filterLineWhereStr);
                 }
                 List<Object[]> values = new ArrayList<>();
 //                按照名称 和过滤条件取值
@@ -162,7 +166,7 @@ public class DatabaseScriptUtil {
                     }
                     values.add(objects.toArray());
                 }
-                int[] ints =  DataBase.updateBatch(connectionStr, expression, values);
+                int[] ints = DataBase.updateBatch(connectionStr, expression, values);
                 return UniReturnUtil.success(ints);
             }
 
@@ -196,16 +200,16 @@ public class DatabaseScriptUtil {
                     whereStr += list.stream().map("%s = ?"::formatted).collect(Collectors.joining(" and "));
                     dbFilter.addAll(list.stream().map(Map.Entry::getValue).toList());
                 }
-            }else if(filter instanceof Map<?,?> filterMap && !filterMap.isEmpty()){
+            } else if (filter instanceof Map<?, ?> filterMap && !filterMap.isEmpty()) {
                 List<? extends Map.Entry<?, ?>> list = filterMap.entrySet().stream().toList();
-                whereStr += list.stream().map(it->"%s = ?".formatted(it.getKey())).collect(Collectors.joining(" and "));
+                whereStr += list.stream().map(it -> "%s = ?".formatted(it.getKey())).collect(Collectors.joining(" and "));
                 dbFilter.addAll(list.stream().map(Map.Entry::getValue).toList());
             }
-            whereStr = " %s and  %s".formatted(whereStr, Objects.isNull(filterLineWhereStr)  ? " 1=1 " : filterLineWhereStr);
+            whereStr = " %s and  %s".formatted(whereStr, Objects.isNull(filterLineWhereStr) ? " 1=1 " : filterLineWhereStr);
             String sql = expression.replaceAll("《whereStr》", " " + whereStr);
 
-            if( !filterColumns.isEmpty()){
-                sql= "select %s from (%s) as T".formatted(String.join(",", filterColumns),sql);
+            if (!filterColumns.isEmpty()) {
+                sql = "select %s from (%s) as T".formatted(String.join(",", filterColumns), sql);
             }
 
             List<Map<String, Object>> queryResult = DataBase.query(connectionStr, sql, Collections.singletonList(dbFilter.toArray()));
@@ -213,7 +217,7 @@ public class DatabaseScriptUtil {
 
         } else {
             if (Objects.equals(event, "0")) {
-                List<Map<String, Object>> queryResult =  DataBase.query(connectionStr, expression, args, filterColumns, filterLines);
+                List<Map<String, Object>> queryResult = DataBase.query(connectionStr, expression, args, filterColumns, filterLines);
                 return UniReturnUtil.success(queryResult);
             } else if (Objects.equals(event, "1")) {
                 if (sqlStrVarList.containsKey(expression)) {
@@ -228,7 +232,7 @@ public class DatabaseScriptUtil {
                     getSQLVarList(expression);
                 }
                 List<String> names = sqlStrVarList.get(expression);
-                String sql = " %s  and %s".formatted(sqlStrNewSQL.get(expression), Objects.isNull(filterLineWhereStr)  ? " 1=1 " : filterLineWhereStr);
+                String sql = " %s  and %s".formatted(sqlStrNewSQL.get(expression), Objects.isNull(filterLineWhereStr) ? " 1=1 " : filterLineWhereStr);
                 int[] updateResult = DataBase.updateBatch(connectionStr, sql, args.stream().map(it -> names.stream().map(it::get).toArray()).toList());
                 return UniReturnUtil.success(updateResult);
             }
@@ -255,6 +259,7 @@ public class DatabaseScriptUtil {
         }
         return sqlvarList;
     }
+
     private static boolean exists(String connectionStr, String sql, Object[] args) throws Exception {
         List<Map<String, Object>> mapList = DataBase.query(connectionStr, sql, Collections.singletonList(args));
         if (mapList.isEmpty()) return false;

src/main/java/com/scbfkj/uni/library/script/JsScriptEngineUtil.java

@@ -1,7 +1,6 @@
 package com.scbfkj.uni.library.script;
 
 import com.scbfkj.uni.library.UniReturnUtil;
-import com.scbfkj.uni.service.LoggerService;
 import org.apache.commons.pool2.BaseKeyedPooledObjectFactory;
 import org.apache.commons.pool2.KeyedObjectPool;
 import org.apache.commons.pool2.PooledObject;
@@ -12,8 +11,6 @@ import org.graalvm.polyglot.Context;
 import org.graalvm.polyglot.Source;
 import org.graalvm.polyglot.Value;
 
-import java.time.LocalDateTime;
-import java.util.HashMap;
 import java.util.Map;
 import java.util.Objects;
 

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

@@ -110,6 +110,17 @@ public class DataBase {
         }
     }
 
+    public static boolean baseUpdate(String connectionStr, String sql) throws Exception {
+        HikariPool dataSourcePool = getDataSourcePool(connectionStr);
+        try (Connection connection = dataSourcePool.getConnection();
+             PreparedStatement preparedStatement = connection.prepareStatement(sql)
+        ) {
+            boolean execute = preparedStatement.execute();
+            connection.commit();
+            return execute;
+        }
+    }
+
 
     public static List<Map<String, Object>> query(String connectionStr, String sql, List<Map<String, Object>> argsList, List<String> filterColumns, List<Map<String, Object>> filterLines) throws Exception {
 
@@ -256,4 +267,11 @@ public class DataBase {
     }
 
 
+    public static String formatConfig(String configStr) {
+        Map<?, ?> config = DataFormatUtil.toMap(configStr);
+//        todo 把不不标准的key复制成标准的key
+        return DataFormatUtil.toString(config);
+    }
+
+
 }

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

@@ -63,7 +63,7 @@ public class ControlService {
             return UniReturnUtil.success(null);
         } else {
             //启动定时任务：
-            boolean start = ScheduleUtil.start(serviceId);
+            boolean start = ScheduleUtil.startByService(serviceId);
             if (start) {
 
                 updateServiceState(serviceId, "1");

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

@@ -274,12 +274,20 @@ public class SecurityService {
             }});
         } 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 (Objects.equals(DataFormatUtil.toString(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, new ArrayList<>() {{
                         add(new Object[]{userId, ip, sessionId, LocalDateTime.now(), null, LocalDateTime.now(), LocalDateTime.now(), appToken, appId});
                     }});
+                }else{
+                    Map<String, Object> map = log.get();
+                    if(Objects.isNull(map.get("apptoken"))){
+
+                        DataBase.updateBatch(Config.securityConnectionStr, "update  userloginlog set apptoken = ? where loginid = ?", new ArrayList<>() {{
+                            add(new Object[]{appToken,map.get("loginid")});
+                        }});
+                    }
                 }
                 data.put("userstatus", "0");
 

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

@@ -1,41 +1,52 @@
 package com.scbfkj.uni.system;
 
+import com.scbfkj.uni.library.UniReturnUtil;
 import com.scbfkj.uni.service.DataProcessService;
 
 import java.util.HashMap;
+import java.util.Objects;
 
 public class ScheduleTask implements Runnable {
 
 
-    private String id; // 服务ID
+    private final String id; // 服务ID
 
     public String getId() {
         return id;
     }
 
-    Integer loopCount = 0;
+    private final Integer loopCount;
     int count = 0;
 
     public ScheduleTask(String id, Integer loopCount) {
         this.id = id;
-        this.loopCount = loopCount;
+        this.loopCount = Objects.isNull(loopCount) || loopCount < 0 ? 0 : loopCount;
     }
 
     @Override
     public void run() {
 
-        do {
-            if (loopCount > 0) {
-                count++;
-            }
+        if (loopCount > 0) {
+            count++;
+        }
+        try {
+            DataProcessService.process(new HashMap<>() {{
+                put("serviceid", id);
+            }});
+        } catch (Exception e) {
+            throw new RuntimeException(e);
+        }
+        if (loopCount < count) {
             try {
-                DataProcessService.process(new HashMap<>() {{
-                    put("serviceid", id);
-                }});
+                ScheduleUtil.cancel(id);
             } catch (Exception e) {
-                throw new RuntimeException(e);
+                if (Config.debug) {
+                    e.printStackTrace();
+                } else {
+                    System.out.println(UniReturnUtil.getMessage(e));
+                }
             }
-        } while (loopCount > count);
+        }
     }
 
 

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

@@ -1,8 +1,8 @@
 package com.scbfkj.uni.system;
 
-import com.scbfkj.uni.library.UniReturnUtil;
 import com.scbfkj.uni.process.DataBase;
-import com.scbfkj.uni.service.DataProcessService;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 import org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler;
 import org.springframework.scheduling.support.CronTrigger;
 import org.springframework.scheduling.support.PeriodicTrigger;
@@ -13,6 +13,8 @@ import java.util.concurrent.*;
 
 public class ScheduleUtil {
 
+    private final static Logger logger = LoggerFactory.getLogger(ScheduleUtil.class);
+
 
     private static ThreadPoolTaskScheduler threadPoolTaskScheduler = new ThreadPoolTaskScheduler();
 
@@ -25,7 +27,7 @@ public class ScheduleUtil {
     static {
         threadPoolTaskScheduler.setPoolSize(8);
         threadPoolTaskScheduler.initialize();
-        System.out.println("定时任务线程池启动");
+       logger.info("定时任务线程池启动");
     }
 
     /**
@@ -33,7 +35,7 @@ public class ScheduleUtil {
      *
      * @param serviceId 服务id
      */
-    public static boolean start(String serviceId) throws Exception {
+    public static boolean startByService(String serviceId) throws Exception {
 
         if (!serviceInfoesMap.containsKey(serviceId)) {
             //采集数据源及参数配置
@@ -77,7 +79,7 @@ public class ScheduleUtil {
      * @param cron
      * @return
      */
-    public static boolean start(Runnable runnable, String cron) {
+    public static boolean startByCron(Runnable runnable, String cron) {
         threadPoolTaskScheduler.schedule(runnable, new CronTrigger(cron));
         return true;
     }
@@ -89,7 +91,7 @@ public class ScheduleUtil {
      * @param frequency
      * @return
      */
-    public static boolean start(Runnable runnable, long frequency) {
+    public static boolean startByService(Runnable runnable, long frequency) {
         threadPoolTaskScheduler.schedule(runnable, new PeriodicTrigger(Duration.ofMillis(frequency)));
         return true;
     }

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

@@ -1,20 +1,22 @@
 package com.scbfkj.uni.system;
 
 import com.scbfkj.uni.library.DataEncryptionUtil;
-import com.scbfkj.uni.library.DataFormatUtil;
 import com.scbfkj.uni.process.DataBase;
 import com.scbfkj.uni.service.ControlService;
 import com.scbfkj.uni.service.LoggerService;
 import jakarta.annotation.PostConstruct;
+import org.apache.kafka.common.utils.ByteBufferInputStream;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.core.io.ClassPathResource;
 import org.springframework.stereotype.Component;
+import org.springframework.util.ResourceUtils;
 
 import java.io.*;
+import java.nio.ByteBuffer;
 import java.time.LocalDateTime;
 import java.util.Collections;
 import java.util.HashMap;
-import java.util.List;
+import java.util.Scanner;
 
 
 @Component
@@ -33,7 +35,7 @@ public class SystemInit {
     private String containerCode;
 
 
-    @Value("${debug:false}")
+    @Value("${app.debug:false}")
     private boolean debug = true;
 
     @PostConstruct
@@ -50,7 +52,7 @@ public class SystemInit {
         initializeSystemEnvironment();
         ControlService.startServiceByContainerCode();
 //        日志任务
-        ScheduleUtil.start(LoggerService::sendMessage, 100);
+        ScheduleUtil.startByService(LoggerService::sendMessage, 100);
 //        LoggerService.logSystemError(LocalDateTime.now(), "", "");
         LoggerService.log(LoggerService.LogType.SYSTEM, new HashMap<>() {{
             put("occurrencetime", LocalDateTime.now());
@@ -102,10 +104,44 @@ public class SystemInit {
     }
 
     /**
-     *
+     * 清理远程数据配置
      */
-    private void cleanRemoteConfig() {
+    private void cleanRemoteConfig() throws Exception {
+        File file = ResourceUtils.getFile("classpath:sql");
+        removeRemoteData();
+        if (file.exists()) {
+            if (!file.isFile()) {
+                for (File listFile : file.listFiles()) {
+                    String sqls = readFileToString(listFile);
+                    for (String sql : sqls.split(";")) {
+                        if (!sql.trim().isEmpty()) {
+                            DataBase.baseUpdate(Config.centerConnectionStr, sql);
+                        }
+                    }
+                }
+            }
+        }
+    }
+
+    /**
+     * 删除远程数据库
+     */
+    private void removeRemoteData() {
+
+    }
 
+    public static String readFileToString(File file) {
+        StringBuilder content = new StringBuilder();
+        try {
+            Scanner scanner = new Scanner(file);
+            while (scanner.hasNextLine()) {
+                content.append(scanner.nextLine());
+            }
+            scanner.close();
+        } catch (FileNotFoundException e) {
+            e.printStackTrace();
+        }
+        return content.toString();
     }
 
 }

src/main/resources/application-dev.properties

@@ -4,4 +4,4 @@ db.security.config=Jnj84d14EmSgKEXyAbSH+bratWGkpV89/VA5Er4yQOt7qlnKtGYJzBVJNNYMB
 server.port=9500
 app.container.code=dev
 app.security.enable=false
-debug=true
+app.debug=true

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

@@ -84,7 +84,9 @@ class DataEncryptionUtilTest {
 
 
     @Test
-    void encrypt() {
+    void encrypt() throws Exception {
+        String password = DataEncryptionUtil.encryptRSAByPublicKey("123!@#QWEqwe");
+        System.out.println(password);
     }
 
     @Test

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

@@ -2,15 +2,10 @@ package com.scbfkj.uni.library;
 
 import com.fasterxml.jackson.core.JsonProcessingException;
 import com.fasterxml.jackson.databind.JsonNode;
-import com.fasterxml.jackson.databind.ObjectMapper;
-import com.jayway.jsonpath.JsonPath;
-import jdk.swing.interop.SwingInterOpUtils;
 import org.junit.jupiter.api.Test;
 
 import java.util.HashMap;
 
-import static org.junit.jupiter.api.Assertions.*;
-
 class DataFormatUtilTest {
 
     @Test