update_20

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

@@ -1,17 +1,22 @@
 package com.scbfkj.uni.api;
 
+import com.scbfkj.uni.library.DataAliasGetUtil;
+import com.scbfkj.uni.library.UniReturnUtil;
+import com.scbfkj.uni.process.DataBase;
 import com.scbfkj.uni.service.ControlService;
 import org.springframework.http.ResponseEntity;
 import org.springframework.web.bind.annotation.*;
 
+import java.util.List;
 import java.util.Map;
+import java.util.Optional;
 
 @RestController
 @RequestMapping("controlApi")
 public class ControlApi {
     @PostMapping("start")
-    public ResponseEntity<Map<String,Object>> start(@RequestHeader Map<String, String> headers, @RequestBody Map<String, Object> body) throws Exception {
-        Map<String, Object> started = ControlService.startOrStop(body, "1");
+    public ResponseEntity<Map<String, Object>> start( @RequestBody Map<String, Object> body) throws Exception {
+        Map<String, Object> started = ControlService.startOrStop(body, "1", false);
         return ResponseEntity.ok(started);
     }
 
@@ -22,8 +27,50 @@ public class ControlApi {
      * @return
      */
     @PostMapping("stop")
-    public ResponseEntity<Map<String,Object>> stop(@RequestBody Map<String, Object> body) throws Exception {
-        Map<String, Object> stoped = ControlService.startOrStop(body, "0");
+    public ResponseEntity<Map<String, Object>> stop(@RequestBody Map<String, Object> body) throws Exception {
+        Map<String, Object> stoped = ControlService.startOrStop(body, "0", false);
         return ResponseEntity.ok(stoped);
     }
+
+    @PostMapping("startAll")
+    public ResponseEntity<Map<String, Object>> startAll(@RequestBody Map<String, Object> body) throws Exception {
+        Map<String, Object> started = ControlService.startOrStop(body, "1", true);
+        return ResponseEntity.ok(started);
+    }
+
+    /**
+     * 主动采集与被动采集的停止
+     *
+     * @param body 请求内容
+     * @return
+     */
+    @PostMapping("stopAll")
+    public ResponseEntity<Map<String, Object>> stopAll(@RequestBody Map<String, Object> body) throws Exception {
+        Map<String, Object> stoped = ControlService.startOrStop(body, "0", true);
+        return ResponseEntity.ok(stoped);
+    }
+
+
+    /**
+     * 清理缓存
+     *
+     * @param body 请求内容
+     * @return
+     */
+    @PostMapping("cleanCache")
+    public ResponseEntity<Map<String, Object>> cleanCache(@RequestBody Map<String, Object> body) throws Exception {
+        Optional<String> table = DataAliasGetUtil.getValue("table", body);
+        table.ifPresent(tableName -> {
+            List<String> keys = DataBase.cacheDatas.keySet().stream().filter(it -> it.contains(tableName)).toList();
+            keys.parallelStream().forEach(DataBase.cacheDatas::remove);
+        });
+        if (table.isEmpty()) {
+
+            DataBase.cacheDatas.clear();
+        }
+
+        return ResponseEntity.ok(UniReturnUtil.success(true));
+    }
+
+
 }

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

@@ -1,6 +1,7 @@
 package com.scbfkj.uni.api;
 
 import com.google.common.util.concurrent.RateLimiter;
+import com.scbfkj.uni.library.DataAliasGetUtil;
 import com.scbfkj.uni.library.DataFormatUtil;
 import com.scbfkj.uni.library.RequestUtil;
 import com.scbfkj.uni.library.UniReturnUtil;
@@ -33,7 +34,7 @@ public class LogAop {
     private SecurityService securityService;
 
 
-    private static Map<String, RateLimiter> rateLimiterMap=new HashMap<>();
+    private static Map<String, RateLimiter> rateLimiterMap = new HashMap<>();
 
 
     @Around(value = "within( com.scbfkj.uni.api.*Api)")
@@ -57,6 +58,29 @@ public class LogAop {
         String message = null;
 
         try {
+
+//            判断服务状态是否为健康状态 runstate!=0
+            if (args.length > 0) {
+                Object arg = args[0];
+                if (arg instanceof Map map) {
+//                    查找serviceid
+                    Optional serviceid = DataAliasGetUtil.getValue("serviceid", map);
+                    if (serviceid.isPresent()) {
+//                        查找状态
+                        List<Map<String, Object>> mapList = DataBase.query(Config.centerConnectionStr, "select * from servicestate where serviceid=? and containercode = ?", Collections.singletonList(new Object[]{serviceid.get(), Config.containerCode}));
+                        if (!mapList.isEmpty()) {
+                            Map<String, Object> serviceState = mapList.get(0);
+                            Object o = serviceState.get("runstate");
+//                            判断服务状态
+                            if (Objects.equals(o, "0")) {
+                                throw new RuntimeException("服务没有运行或者被熔断");
+                            }
+                        }
+                    }
+                    ;
+
+                }
+            }
             List<Map<String, Object>> ratelimitruleList = DataBase.query(Config.securityConnectionStr, "select * from ratelimitrule where 1=?", Collections.singletonList(new Object[]{1}));
             Optional<Map<String, Object>> optional = ratelimitruleList.stream().filter(it -> {
                 Object pathMatch = it.get("pathmatch");
@@ -66,15 +90,15 @@ public class LogAop {
             if (optional.isPresent()) {
                 Map<String, Object> map = optional.get();
                 String pathMatch = map.get("pathmatch").toString();
-                if(!rateLimiterMap.containsKey(pathMatch)){
+                if (!rateLimiterMap.containsKey(pathMatch)) {
                     String duration = map.getOrDefault("duration", 1).toString();
                     String limitValue = map.getOrDefault("limitvalue", 100).toString();
-                    rateLimiterMap.put(pathMatch,RateLimiter.create(Double.parseDouble(limitValue),Integer.parseInt(duration), TimeUnit.SECONDS));
+                    rateLimiterMap.put(pathMatch, RateLimiter.create(Double.parseDouble(limitValue), Integer.parseInt(duration), TimeUnit.SECONDS));
                 }
                 RateLimiter rateLimiter = rateLimiterMap.get(pathMatch);
                 String timeOut = map.getOrDefault("timeout", 1).toString();
                 boolean acquire = rateLimiter.tryAcquire(Integer.parseInt(timeOut), TimeUnit.SECONDS);
-                if(!acquire){
+                if (!acquire) {
                     message = map.getOrDefault("returnmessage", "请求频率过高，请降低请求频率").toString();
                     return ResponseEntity.ok(UniReturnUtil.fail(message));
                 }
@@ -82,9 +106,9 @@ public class LogAop {
 
 
             if (Config.securityEnable) {
-                 List<Map<String,Object>>   apiInfos = DataBase.query(Config.securityConnectionStr, "select * from apiinfo", new ArrayList<>() {{
-                        add(new Object[]{});
-                    }});
+                List<Map<String, Object>> apiInfos = DataBase.query(Config.securityConnectionStr, "select * from apiinfo", new ArrayList<>() {{
+                    add(new Object[]{});
+                }});
 
 
                 Optional<Map<String, Object>> requestpath = apiInfos.stream().filter(it -> {
@@ -141,7 +165,7 @@ public class LogAop {
                 try {
                     put("applicationid", RequestUtil.getAppId());
                 } catch (Exception e) {
-                        System.out.println(UniReturnUtil.getMessage(e));
+                    System.out.println(UniReturnUtil.getMessage(e));
                 }
             }});
         }

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

@@ -76,41 +76,40 @@ public class JavaScriptEngineUtil {
             JsonNode path = jsonNode.get("path");
             JsonNode className = jsonNode.get("className");
             JsonNode method = jsonNode.get("methodName");
-            if (Objects.nonNull(path) && !path.isNull()) {
-                File file = new File(System.getProperty("user.dir").concat(File.separator).concat("plugins").concat(File.separator).concat(path.asText()));
-                if (!file.exists()) {
-                    throw new RuntimeException("外部文件加载不存在：".concat(System.getProperty("user.dir")).concat(File.separator).concat("plugins").concat(File.separator).concat(path.asText()));
-                }
-                Method addURLMethod = null;
-
-                boolean accessible = false;
-                try {
-                    addURLMethod = URLClassLoader.class.getDeclaredMethod("addURL", URL.class);
-                    URLClassLoader classLoader = (URLClassLoader) ClassLoader.getSystemClassLoader();
-                    accessible = addURLMethod.canAccess(null); //获取方法的访问权限以便恢复:判读是否可以访问: true  代表可以访问
-                    if (!accessible) { //判读是否可以访问，如果是false，那就必须setAccessible(true)
-                        addURLMethod.setAccessible(true);//实际上是为了提效
+            ClassLoader classLoader=null;
+            try{
+                if (Objects.nonNull(path) && !path.isNull()) {
+                    String userPath = System.getProperty("user.dir");
+                    File file = new File(userPath.concat(File.separator).concat("plugins").concat(File.separator).concat(path.asText()));
+                    if (!file.exists()) {
+                        throw new RuntimeException("外部文件加载不存在：".concat(userPath).concat(File.separator).concat("plugins").concat(File.separator).concat(path.asText()));
                     }
-                    addURLMethod.invoke(classLoader, file.toURI().toURL());//加载到系统中
-                } finally {
-                    if (addURLMethod != null && !accessible) {
-                        addURLMethod.setAccessible(false);//恢复原访问权限
+                    URL url = file.toURI().toURL();
+                    classLoader = new URLClassLoader(new URL[]{url},Thread.currentThread().getContextClassLoader());
+                } else {
+                    classLoader = Thread.currentThread().getContextClassLoader();
+                }
+
+                Class<?> classExample = classLoader.loadClass(className.asText()); //获取类实例
+                Object classInstance = classExample.getConstructor().newInstance();//类实例接口 无参数构造
+                Method javaMethod = null;
+                Method closeMethod = null;
+                for (Method currentMethod : classExample.getMethods()) {//循环所有方法
+                    String methodName = currentMethod.getName();
+                    if (methodName.equals(method.asText())) {
+                        javaMethod = currentMethod;
+                    } else if (methodName.equals("close")) {
+                        closeMethod = currentMethod;
                     }
                 }
-            }
-            Class<?> classExample = Class.forName(className.asText()); //获取类实例
-            Object classInstance = classExample.getConstructor().newInstance();//类实例接口 无参数构造
-            Method javaMethod = null;
-            Method closeMethod = null;
-            for (Method currentMethod : classExample.getMethods()) {//循环所有方法
-                String methodName = currentMethod.getName();
-                if (methodName.equals(method.asText())) {
-                    javaMethod = currentMethod;
-                } else if (methodName.equals("close")) {
-                    closeMethod = currentMethod;
+                return new JavaApply(classInstance, javaMethod, closeMethod);
+            }finally {
+                if(Objects.nonNull(classLoader)){
+                    if (classLoader instanceof URLClassLoader cl) {
+                        cl.close();
+                    }
                 }
             }
-            return new JavaApply(classInstance, javaMethod, closeMethod);
         }
 
         @Override
@@ -135,10 +134,11 @@ public class JavaScriptEngineUtil {
             javaApply = javaRefPool.borrowObject(key);
             return UniReturnUtil.success(javaApply.invokeApply(args));
         } catch (Exception e) {
+            e.printStackTrace();
             return UniReturnUtil.fail(e);
         } finally {
             if (Objects.nonNull(javaApply)) {
-                    javaRefPool.returnObject(key, javaApply);
+                javaRefPool.returnObject(key, javaApply);
             }
         }
     }

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

@@ -14,7 +14,7 @@ import java.util.*;
 
 public class DataBase {
 
-    private final static Map<String, Map<String, Object>> cacheDatas = new HashMap<>();
+    public final static Map<String, Map<String, Object>> cacheDatas = new Hashtable<>();
     private static List<Map<String, Object>> cacheConfigList = new ArrayList<>();
     public final static Map<String, HikariPool> dataSourcePools = new HashMap<>();
 

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

@@ -15,10 +15,7 @@ import org.elasticsearch.client.RestClient;
 import org.elasticsearch.client.RestClientBuilder;
 
 import java.io.IOException;
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
-import java.util.Objects;
+import java.util.*;
 import java.util.stream.Collectors;
 
 public class Elasticsearch {
@@ -50,20 +47,25 @@ public class Elasticsearch {
 
         Object finalMethod = method;
         Object finalEndpoint = endpoint;
-        List<HashMap<Object, Object>> results = datas.parallelStream().map(data -> {
+        List<HashMap<Object, Object>> results = new ArrayList<>();
+        datas.stream().map(d -> {
             Request request = new Request(finalMethod.toString(), finalEndpoint.toString());
             request.addParameters(parametersMap);
-            request.setJsonEntity(data);
-            return new HashMap<>() {{
+            request.setJsonEntity(DataFormatUtil.toString(d));
+            return request;
+        }).forEach(r -> {
+            HashMap<Object, Object> result = new HashMap<>() {{
 
                 try {
-                    Response response = restClient.performRequest(request);
+
+                    Response response = restClient.performRequest(r);
                     put("response", response);
                 } catch (IOException e) {
                     put("exception", e);
                 }
             }};
-        }).toList();
+            results.add(result);
+        });
         List<Exception> exceptions = results.stream().map(it -> it.get("exception")).filter(Objects::nonNull).map(it -> ((Exception) it)).toList();
         List<Response> responses = results.stream().map(it -> it.get("response")).filter(Objects::nonNull).map(it -> ((Response) it)).toList();
 

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

@@ -1,20 +1,34 @@
 package com.scbfkj.uni.service;
 
 import com.scbfkj.uni.library.DataAliasGetUtil;
+import com.scbfkj.uni.library.DataFormatUtil;
 import com.scbfkj.uni.library.UniReturnUtil;
+import com.scbfkj.uni.library.script.DatabaseScriptUtil;
 import com.scbfkj.uni.process.DataBase;
 import com.scbfkj.uni.system.Config;
 import com.scbfkj.uni.system.ScheduleUtil;
 
+import java.time.LocalDateTime;
 import java.util.*;
 
 public class ControlService {
 
 
+    public static void stopServiceByContainerCode() throws Exception {
+
+//        查询服务类型为主动采集的服务
+        String queryServiceInfos = "select * from serviceinfo where containercode=? ";
+        List<Map<String, Object>> serviceInfos = DataBase.query(Config.centerConnectionStr, queryServiceInfos, Collections.singletonList(new Object[]{Config.containerCode}));
+//        循环启动
+        for (Map<String, Object> serviceInfo : serviceInfos) {
+            stop(serviceInfo.get("serviceid").toString());
+        }
+    }
+
     public static void startServiceByContainerCode() throws Exception {
 
 //        查询服务类型为主动采集的服务
-        String queryServiceInfos = "select * from serviceinfo where containercode=? and servicetype=4";
+        String queryServiceInfos = "select * from serviceinfo where containercode=? ";
         List<Map<String, Object>> serviceInfos = DataBase.query(Config.centerConnectionStr, queryServiceInfos, Collections.singletonList(new Object[]{Config.containerCode}));
 //        循环启动
         for (Map<String, Object> serviceInfo : serviceInfos) {
@@ -35,24 +49,24 @@ public class ControlService {
         }
         String serviceId = serviceidOpt.get();
         List<Map<String, Object>> serviceInfoList = null;
-        if (serviceId.matches("^\\d+$")) {
             serviceInfoList = DataBase.query(Config.centerConnectionStr, "select * from serviceinfo where serviceid=?", Collections.singletonList(new Object[]{serviceId}));
-        } else {
-            serviceInfoList = DataBase.query(Config.localCenterConnectionStr, "select * from serviceinfo where serviceid=?", Collections.singletonList(new Object[]{serviceId}));
-        }
+
         if (serviceInfoList.isEmpty()) {
-            throw new RuntimeException("服务%s没有配置".formatted(serviceId));
+            return UniReturnUtil.fail("服务%s没有配置".formatted(serviceId));
         }
         Map<String, Object> serviceInfo = serviceInfoList.get(0);
         Object cronexpress = serviceInfo.get("cronexpress");
         if (Objects.isNull(cronexpress)) {
-            return DataProcessService.process(inData);
+//            设置服务状态为运行中
 
+            updateServiceState(serviceId, "1");
+            return UniReturnUtil.success(null);
         } else {
             //启动定时任务：
             boolean start = ScheduleUtil.start(serviceId);
             if (start) {
-                DataBase.updateBatch(Config.centerConnectionStr, "update serviceinfo set runState = 1 where  serviceid =?", Collections.singletonList(new Object[]{serviceId}));
+
+                updateServiceState(serviceId, "1");
                 return UniReturnUtil.success("启动成功");
             } else {
                 return UniReturnUtil.fail("启动失败");
@@ -69,11 +83,30 @@ public class ControlService {
      */
     public static Map<String, Object> stop(String serviceId) throws Exception {
         boolean cancel = ScheduleUtil.cancel(serviceId);
-        DataBase.updateBatch(Config.centerConnectionStr, "update serviceinfo set runState = 0 where  serviceID =?", Collections.singletonList(new Object[]{serviceId}));
-//        LogUtils.log("stop: 2", "0", null, (reset ? "停止成功" : "停止失败"), serviceId, null, null, null,null);//无条件记录数据接收日志
+        updateServiceState(serviceId,"0");
         return UniReturnUtil.success("停止" + (cancel ? "成功" : "失败"));
     }
 
+    private static void updateServiceState(String serviceId, String state) throws Exception {
+        DatabaseScriptUtil.exec(Config.centerConnectionStr, "servicestate", new ArrayList<>() {{
+            add(new HashMap<>() {{
+                put("value", new HashMap<>() {{
+                    put("serviceid", serviceId);
+                    put("starttime", DataFormatUtil.toString(LocalDateTime.now()));
+                    put("containercode", Config.containerCode);
+                    put("runstate", state);
+
+                }});
+                put("filter", new HashMap<>() {{
+                    put("serviceid", serviceId);
+                    put("containercode", Config.containerCode);
+
+                }});
+
+            }});
+        }}, "6", null, null);
+    }
+
     /**
      * 用用户启停定时任务 服务类型为4的服务
      *
@@ -83,20 +116,33 @@ public class ControlService {
      * @throws Exception
      */
 
-    public static Map<String, Object> startOrStop(Map<String, Object> params, String statue) throws Exception {
+    public static Map<String, Object> startOrStop(Map<String, Object> params, String statue, boolean all) throws Exception {
         Optional<String> serviceIdOpt = DataAliasGetUtil.getValue("serviceid", params);
-        if (serviceIdOpt.isEmpty()) return UniReturnUtil.fail("服务ID不能为空");
-        String serviceId = serviceIdOpt.get();
-        Map<String, Object> stop = stop(serviceId);
-        if (statue.equals("0")) {
-            return stop;
-        }
-        List<Map<String, Object>> serviceTypeData = DataBase.query(Config.centerConnectionStr, "select serviceType from serviceinfo where serviceID=? and containercode=? and servicetype='4'", Collections.singletonList(new Object[]{serviceId, Config.containerCode}));
-        if (serviceTypeData.isEmpty()) {
-            throw new RuntimeException("没有找到服务配置");
+        if (serviceIdOpt.isEmpty() && !all) {
+            return UniReturnUtil.fail("服务ID不能为空");
+        } else if (serviceIdOpt.isPresent()) {
+
+            String serviceId = serviceIdOpt.get();
+            Map<String, Object> stop = stop(serviceId);
+            if (statue.equals("0")) {
+                return stop;
+            }
+            List<Map<String, Object>> serviceTypeData = DataBase.query(Config.centerConnectionStr, "select serviceType from serviceinfo where serviceID=? and containercode=? and servicetype='4'", Collections.singletonList(new Object[]{serviceId, Config.containerCode}));
+            if (serviceTypeData.isEmpty()) {
+                throw new RuntimeException("没有找到服务配置");
+            }
+            return start(new HashMap<>() {{
+                put("serviceid", serviceId);
+            }});
+        } else {
+            if (Objects.equals(statue, "0")) {
+                stopServiceByContainerCode();
+
+                return UniReturnUtil.success(true);
+            } else {
+                startServiceByContainerCode();
+                return UniReturnUtil.success(true);
+            }
         }
-        return start(new HashMap<>() {{
-            put("service", serviceId);
-        }});
     }
 }

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

@@ -45,11 +45,8 @@ public class DataProcessService {
 //        熔断
 
             List<Map<String, Object>> algorithmLibraries;
-            if (serviceId.matches("^\\d+$")) {
-                algorithmLibraries = DataBase.query(Config.centerConnectionStr, "select * from algorithmlibrary where serviceid=?", Collections.singletonList(new Object[]{serviceId}));
-            } else {
-                algorithmLibraries = DataBase.query(Config.localCenterConnectionStr, "select * from algorithmlibrary where serviceid=?", Collections.singletonList(new Object[]{serviceId}));
-            }
+            algorithmLibraries = DataBase.query(Config.centerConnectionStr, "select * from algorithmlibrary where serviceid=?", Collections.singletonList(new Object[]{serviceId}));
+
 
             Optional<String> lifecycleidOpt;
             lifecycleidOpt = DataAliasGetUtil.getValue("lifecycleid", inData);
@@ -60,7 +57,6 @@ public class DataProcessService {
             } else {
                 lifecycleid = lifecycleidOpt.get();
             }
-
             for (Map<String, Object> algorithmLibrary : algorithmLibraries) {
 
                 Map<String, Object> algorithmResult = null;
@@ -125,7 +121,7 @@ public class DataProcessService {
 
                 }
                 Object type = algorithmLibrary.get("algorithmtype");
-                algorithmResult = processByAlgorithm(type,  parameters);
+                algorithmResult = processByAlgorithm(type, parameters);
 //                    算法执行结果
                 data.put("result", algorithmResult);
                 execTime = System.currentTimeMillis() - startTime;
@@ -182,7 +178,7 @@ public class DataProcessService {
         switch (type.toString()) {
 //            java反射
             case "1" -> {
-                return JavaScriptEngineUtil.invoke((Map<String, Object>) parameters.get(0), DataFormatUtil.toString(parameters.get(0)), parameters.subList(2, parameters.size()).toArray());
+                return JavaScriptEngineUtil.invoke((Map<String, Object>) parameters.get(0), DataFormatUtil.toString(parameters.get(1)), parameters.subList(2, parameters.size()).toArray());
             }
 //            JS表达式
             case "2" -> {

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

@@ -399,7 +399,7 @@ public class SecurityService {
         String userId = RequestUtil.getUserId();
         String query = """
                                 select userpermissionsid,
-                       t2.userid,
+                       t1.userid,
                        t3.*,
                        t1.serviceid,
                        insetcolumnlist,
@@ -407,10 +407,8 @@ public class SecurityService {
                        selectcolumnlist,
                        filterset
                 from pageconfiguration t3,
-                     userpermissions t1,
-                          userinfo t2
-                where t1.userid = t2.userid
-                  and  t3.pageconfigurationid = t1.pageconfigurationid
+                     userpermissions t1
+                where t3.pageconfigurationid = t1.pageconfigurationid
                   and t1.userid = ?""";
         List<Map<String, Object>> permission = DataBase.query(Config.securityConnectionStr, query, new ArrayList<>() {{
             add(new Object[]{userId});

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

@@ -10,9 +10,6 @@ public class Config {
     public static String centerConnectionStr;
     public static String securityConnectionStr;
 
-    public static String localCenterConnectionStr = """
-            {"jdbcUrl":"jdbc:sqlite:systemset.sqlite","driverClassName":"org.sqlite.JDBC"}""";
-
     //    是否启动安全验证
     public static boolean securityEnable;
     public static boolean debug;

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

@@ -5,7 +5,9 @@ import com.scbfkj.uni.process.DataBase;
 import com.scbfkj.uni.service.DataProcessService;
 import org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler;
 import org.springframework.scheduling.support.CronTrigger;
+import org.springframework.scheduling.support.PeriodicTrigger;
 
+import java.time.Duration;
 import java.util.*;
 import java.util.concurrent.*;
 
@@ -68,11 +70,30 @@ public class ScheduleUtil {
         return true;
     }
 
-
-    public static boolean start(Runnable runnable,String cron){
+    /**
+     * 定时执行 秒级
+     *
+     * @param runnable
+     * @param cron
+     * @return
+     */
+    public static boolean start(Runnable runnable, String cron) {
         threadPoolTaskScheduler.schedule(runnable, new CronTrigger(cron));
         return true;
     }
+
+    /**
+     * 间隔执行 毫秒级 执行结束到下次开始执行时间
+     *
+     * @param runnable
+     * @param frequency
+     * @return
+     */
+    public static boolean start(Runnable runnable, long frequency) {
+        threadPoolTaskScheduler.schedule(runnable, new PeriodicTrigger(Duration.ofMillis(frequency)));
+        return true;
+    }
+
     /**
      * 取消，停止定时任务
      *

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

@@ -50,40 +50,62 @@ public class SystemInit {
         initializeSystemEnvironment();
         ControlService.startServiceByContainerCode();
 //        日志任务
-        ScheduleUtil.start(LoggerService::sendMessage, "*/1 * * * * *");
+        ScheduleUtil.start(LoggerService::sendMessage, 100);
 //        LoggerService.logSystemError(LocalDateTime.now(), "", "");
         LoggerService.log(LoggerService.LogType.SYSTEM, new HashMap<>() {{
             put("occurrencetime", LocalDateTime.now());
         }});
+
+
     }
 
-    private void initializeSystemEnvironment() {
+    private void initializeSystemEnvironment() throws Exception {
 //        运行环境初始化
         File resource = new File("logs");
         boolean exists = resource.exists();
         if (!exists) {
             if (!resource.mkdirs()) {
-                throw new RuntimeException("创建日志目录失败");
+                throw new RuntimeException("创建logs目录失败");
+            } else {
+                System.out.println("创建目录成功:" + resource.getAbsolutePath());
+            }
+        }
+//        运行环境初始化
+        resource = new File("plugins");
+        exists = resource.exists();
+        if (!exists) {
+            if (!resource.mkdirs()) {
+                throw new RuntimeException("创建plugins目录失败");
             } else {
                 System.out.println("创建目录成功:" + resource.getAbsolutePath());
             }
         }
+        readConfigFile();
+        cleanRemoteConfig();
+        ControlService.startServiceByContainerCode();
     }
 
-    private String readConfigFile() throws IOException {
+    private String readConfigFile() throws Exception {
         File resource = new File("config");
-        boolean exists = resource.exists();
-        if (exists) {
+        if (resource.exists()) {
             BufferedInputStream inputStream = new BufferedInputStream(new FileInputStream(resource));
             byte[] bytes = new byte[1024];
             StringBuilder builder = new StringBuilder();
             while (inputStream.read(bytes) > 0) {
                 builder.append(new String(bytes));
             }
-            return builder.toString();
+            String string = builder.toString();
+            return DataEncryptionUtil.decryptRSAByPrivateKey(string);
         } else {
             return "{}";
         }
     }
 
+    /**
+     *
+     */
+    private void cleanRemoteConfig() {
+
+    }
+
 }

src/test/java/com/scbfkj/uni/service/DataProcessServiceTest.java

@@ -0,0 +1,40 @@
+package com.scbfkj.uni.service;
+
+import org.junit.jupiter.api.Test;
+
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.Map;
+import java.util.Objects;
+
+import static org.junit.jupiter.api.Assertions.*;
+
+class DataProcessServiceTest {
+
+    @Test
+    void processByAlgorithm() throws Exception {
+        String data = "hello world";
+        String prikey = "12087a12bee95f5d4ffad39bc664d36d3e5befcec9e38e32214347cf263c7479";
+        String pubkey="04343d06aa7d9fbf3897906755c0172a43faeec77b346a26636ea67bd9a7e319774024ddac2c0ac697ec4b9333db3f823e29ad11cdce4ff377d2d4b3dd64c47310";
+        HashMap<String, Object> config = new HashMap<>() {{
+            put("path", "sm2-1.0-SNAPSHOT-jar-with-dependencies.jar");
+            put("className", "com.bfkj.SM2");
+        }};
+        Map<String, Object> map = DataProcessService.processByAlgorithm("1", new ArrayList<>() {{
+            add(config);
+            add("encrypt");
+            add(data);
+            add(pubkey);
+        }});
+        System.out.println(map);
+       String data2 = map.get("returnData").toString();
+        map = DataProcessService.processByAlgorithm("1", new ArrayList<>() {{
+            add(config);
+            add("decrypt");
+            add(data2);
+            add(prikey);
+        }});
+        System.out.println(map);
+        System.out.println(Objects.equals(data,map.get("returnData")));
+    }
+}