update

src/main/java/com/scbfkj/uni/dtos/Expression.java

@@ -1,105 +0,0 @@
-package com.scbfkj.uni.dtos;
-
-import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
-
-import java.util.Objects;
-import java.util.UUID;
-
-@JsonIgnoreProperties(ignoreUnknown = true)
-public class Expression {
-
-    private String valuekey;
-    private String expression;
-    private String opt;
-
-    private Object comparevalue;
-    private Object returnvalue;
-    private Object elsevalue;
-    private Long algorithmlibraryid;
-
-    public Long getAlgorithmlibraryid() {
-        return algorithmlibraryid;
-    }
-
-    public void setAlgorithmlibraryid(Long algorithmlibraryid) {
-        this.algorithmlibraryid = algorithmlibraryid;
-    }
-
-    public String getExpression() {
-        return expression;
-    }
-
-    public void setExpression(String expression) {
-        this.expression = expression;
-    }
-
-    public String getOpt() {
-        return opt;
-    }
-
-    public void setOpt(String opt) {
-        this.opt = opt;
-    }
-
-    public Object getComparevalue() {
-        return comparevalue;
-    }
-
-    public void setComparevalue(Object comparevalue) {
-        this.comparevalue = comparevalue;
-    }
-
-    public Object getReturnvalue() {
-        return returnvalue;
-    }
-
-    public void setReturnvalue(Object returnvalue) {
-        this.returnvalue = returnvalue;
-    }
-
-    public Object getElsevalue() {
-        return elsevalue;
-    }
-
-    public void setElsevalue(Object elsevalue) {
-        this.elsevalue = elsevalue;
-    }
-
-    public String getValuekey() {
-        return valuekey;
-    }
-
-    public void setValuekey(String valuekey) {
-        this.valuekey = valuekey;
-    }
-
-    public String toScript() {
-        String randKey = (Objects.isNull(valuekey) || valuekey.trim().isEmpty()) ? ("a" + UUID.randomUUID().toString().replaceAll("-", "")) : valuekey;
-        if (Objects.nonNull(expression) && Objects.nonNull(opt) && (Objects.nonNull(returnvalue) || Objects.nonNull(elsevalue))) {
-            return """
-                    var %s = ( %s %s %s ) ? %s : %s;
-                    %s;
-                    """.formatted(randKey, expression, opt, Objects.isNull(comparevalue) ? "null" : comparevalue, Objects.isNull(returnvalue) ? "null" : returnvalue, Objects.isNull(elsevalue) ? "null" : elsevalue, randKey);
-        } else if (Objects.nonNull(expression) && Objects.isNull(opt) && (Objects.nonNull(returnvalue) || Objects.nonNull(elsevalue))) {
-            return """
-                    var %s = ( %s ) ? %s : %s;
-                    %s;
-                    """.formatted(randKey, expression, Objects.isNull(returnvalue) ? "null" : returnvalue, Objects.isNull(elsevalue) ? "null" : elsevalue, randKey);
-
-        } else if (Objects.isNull(opt) && Objects.nonNull(expression)) {
-            return """
-                    var %s = %s;
-                    """.formatted(randKey, expression);
-        } else if (Objects.isNull(opt) && Objects.nonNull(returnvalue)) {
-            return """
-                    var %s = %s;
-                    """.formatted(randKey, returnvalue);
-        } else {
-            return """
-                    var %s = null;
-                    %s;
-                    """.formatted(randKey, randKey);
-
-        }
-    }
-}

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

@@ -1,8 +1,6 @@
 package com.scbfkj.uni.service;
 
-import com.fasterxml.jackson.core.JsonProcessingException;
 import com.jayway.jsonpath.JsonPath;
-import com.scbfkj.uni.dtos.Expression;
 import com.scbfkj.uni.library.DataAliasGetUtil;
 import com.scbfkj.uni.library.DataFormatUtil;
 import com.scbfkj.uni.library.UniReturnUtil;
@@ -112,22 +110,10 @@ public class DataProcessService {
                 data.put("algorithmlibraryid", algorithmlibraryid);
                 source.put("args", resource);
                 source.put("algorithm", algorithmLibrary);
-//                计算前置算法
-                List<Map<String, Object>> preScriptExpressions = DATA_BASE.query(Config.getCenterConnectionStr(), "select * from scriptexpression where algorithmlibraryid=?", algorithmlibraryid);
                 Map<String, Object> eval = null;
 
 
-                if (!preScriptExpressions.isEmpty()) {
-                    List<String> expressions = preScriptExpressions.stream().map(DataFormatUtil::toString).map(it -> {
-                        try {
-                            return DataFormatUtil.getObjectMapper().readValue(it, Expression.class);
-                        } catch (JsonProcessingException e) {
-                            throw new RuntimeException(e);
-                        }
-                    }).map(Expression::toScript).toList();
-                    String preExpression = String.join("\n", expressions);
-                    eval = JsScriptEngineUtil.eval(preExpression, resource);
-                } else if (Objects.nonNull(preConditions)) {
+                if (Objects.nonNull(preConditions)) {
                     eval = JsScriptEngineUtil.eval(preConditions.toString(), resource);
                 }
 

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

@@ -89,7 +89,7 @@ public class ProcessUtil {
                 algorithmLibrariesOrders.put(id, i + 1);
             }
 
-            List<AgorithmLibraryGroup> groups = algorithmLibraries.stream().map(it -> {
+            List<AlgorithmLibraryGroup> groups = algorithmLibraries.stream().map(it -> {
                 Object groupNameObj = it.get("groupname");
                 if (Objects.isNull(groupNameObj)) {
                     groupNameObj = "N" + it.get("algorithmlibraryid");
@@ -99,12 +99,12 @@ public class ProcessUtil {
                     loopcountObj = 1;
                 }
                 int count = Integer.parseInt(loopcountObj.toString());
-                return new AgorithmLibraryGroup(groupNameObj.toString(), count);
+                return new AlgorithmLibraryGroup(groupNameObj.toString(), count);
             }).distinct().toList();
 
 
             String preCode = "0";
-            for (AgorithmLibraryGroup group : groups) {
+            for (AlgorithmLibraryGroup group : groups) {
                 List<Map<String, Object>> list = algorithmLibraries.stream().filter(it -> {
                     Object groupNameObj = it.get("groupname");
                     if (Objects.isNull(groupNameObj)) {
@@ -115,7 +115,7 @@ public class ProcessUtil {
 
                 for (int g = 0; g < group.count; g++) {
                     for (Map<String, Object> algorithmLibrary : list) {
-                        preCode="0";
+                        preCode = "0";
                         startDateTime = LocalDateTime.now();
                         long startTime = System.currentTimeMillis();
                         algorithmlibraryid = algorithmLibrary.get("algorithmlibraryid");
@@ -327,12 +327,8 @@ public class ProcessUtil {
 
         String[] split = jsonPtrExpr.split("/", 2);
 
-        if (split.length > 1) {
-            if (split[0].isEmpty()) {
-                if (split.length == 2) {
-                    jsonPtrExpr = split[1];
-                }
-            }
+        if (split.length > 1 && (split[0].isEmpty()) && (split.length == 2)) {
+            jsonPtrExpr = split[1];
         }
         if (!jsonPtrExpr.equalsIgnoreCase("/") && jsonPtrExpr.endsWith("/")) {
             jsonPtrExpr = jsonPtrExpr.substring(0, jsonPtrExpr.length() - 1);
@@ -394,46 +390,11 @@ public class ProcessUtil {
         if (jsonPtrExpr.endsWith("/") && jsonPtrExpr.length() > 1) {
             jsonPtrExpr = jsonPtrExpr.substring(0, jsonPtrExpr.length() - 1);
         }
-        JsonNode node = "/".equalsIgnoreCase(jsonPtrExpr) ? jsonNode : jsonNode.at(jsonPtrExpr);
-//        if (!List.of("string", "list", "map", "array", "long", "integer", "boolean", "double", "float", "datetime").contains(type.toLowerCase())) {
-//            if ("null".equalsIgnoreCase(type)) {
-//                return null;
-//            } else {
-//                throw new RuntimeException("数据类型错误: " + type);
-//            }
-//        }
-//        if ("String".equalsIgnoreCase(type)) {
-//            return node.toString();
-//        } else if ("List".equalsIgnoreCase(type)) {
-//            return DataFormatUtil.toList(node);
-//        } else if ("Array".equalsIgnoreCase(type)) {
-//            return DataFormatUtil.toArray(node);
-//        } else if ("Map".equalsIgnoreCase(type)) {
-//            return DataFormatUtil.toMap(node);
-//        } else if ("Long".equalsIgnoreCase(type)) {
-//            return node.asLong();
-//        } else if ("Integer".equalsIgnoreCase(type)) {
-//            return node.asInt();
-//        } else if ("Double".equalsIgnoreCase(type)) {
-//            return node.asDouble();
-//        } else if ("Float".equalsIgnoreCase(type)) {
-//            return node.floatValue();
-//        } else if ("Boolean".equalsIgnoreCase(type)) {
-//            return node.asBoolean();
-//        } else if ("Datetime".equalsIgnoreCase(type)) {
-//            String string = node.asText();
-//            String patten = "yyyy-MM-dd HH:mm:ss";
-//            if (string.contains("(")) {
-//                patten = string.substring(string.indexOf("(") + 1, string.length() - 1);
-//                string = string.substring(0, string.indexOf("("));
-//            }
-//            return LocalDateTime.parse(string, DateTimeFormatter.ofPattern(patten));
-//        }
-        return node;
+        return "/".equalsIgnoreCase(jsonPtrExpr) ? jsonNode : jsonNode.at(jsonPtrExpr);
     }
 
 
-    public static class AgorithmLibraryGroup {
+    public static class AlgorithmLibraryGroup {
         private String groupName;
         private int count;
 
@@ -453,14 +414,14 @@ public class ProcessUtil {
             this.count = count;
         }
 
-        public AgorithmLibraryGroup(String groupName, int count) {
+        public AlgorithmLibraryGroup(String groupName, int count) {
             this.groupName = groupName;
             this.count = count;
         }
 
         @Override
         public String toString() {
-            return "AgorithmLibraryGroup{" +
+            return "AlgorithmLibraryGroup{" +
                    "groupName='" + groupName + '\'' +
                    ", count=" + count +
                    '}';
@@ -470,7 +431,7 @@ public class ProcessUtil {
         public boolean equals(Object o) {
             if (this == o) return true;
             if (o == null || getClass() != o.getClass()) return false;
-            AgorithmLibraryGroup that = (AgorithmLibraryGroup) o;
+            AlgorithmLibraryGroup that = (AlgorithmLibraryGroup) o;
             return count == that.count && Objects.equals(groupName, that.groupName);
         }
 

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

@@ -1,6 +1,7 @@
 package com.scbfkj.uni.system;
 
 import com.fasterxml.jackson.databind.JsonNode;
+import com.fasterxml.jackson.databind.node.ArrayNode;
 import com.scbfkj.uni.library.DataEncryptionUtil;
 import com.scbfkj.uni.library.DataFormatUtil;
 import com.scbfkj.uni.library.UniReturnUtil;
@@ -30,6 +31,8 @@ import java.util.concurrent.ExecutorService;
 import java.util.concurrent.Executors;
 import java.util.concurrent.ScheduledExecutorService;
 import java.util.concurrent.TimeUnit;
+import java.util.regex.Matcher;
+import java.util.regex.Pattern;
 import java.util.stream.Collectors;
 
 
@@ -47,6 +50,10 @@ public class SystemInit {
     @Value("${db.security.config}")
     private String securityConfig;
 
+    @Value("${app.singleton.enable:false}")
+    private boolean singletonEnable = false;
+    @Value("${app.singleton.file:./config/config.sqlite}")
+    private String singletonFile;
     @Value("${app.security.enable:true}")
     private boolean securityEnable = false;
     @Value("${app.security.encrypt:true}")
@@ -59,7 +66,7 @@ public class SystemInit {
 
     @Value("${app.enable-reset-config:false}")
     private boolean enableResetConfig = false;
-    List<String> qualityControlIds = new ArrayList<>();
+    Set<String> qualityControlIds = new HashSet<>();
     Set<String> qualityControlIds2 = new HashSet<>();
 
 
@@ -107,17 +114,47 @@ public class SystemInit {
         Config.setContainerCode(containerCode);
         Config.setSecurityEnable(securityEnable);
         Config.setDebug(debug);
-        if (encryptEnable) {
-            Config.setCenterConnectionStr(DataEncryptionUtil.decryptRSAByPrivateKey(centerConfig));
-            Config.setSecurityConnectionStr(DataEncryptionUtil.decryptRSAByPrivateKey(securityConfig));
+        if (singletonEnable) {
+            String config = """
+                    {
+                      "jdbcUrl": "jdbc:sqlite:%s",
+                      "driverClassName": "org.sqlite.JDBC"
+                    }""".formatted(singletonFile);
+            Config.setCenterConnectionStr(config);
+            Config.setSecurityConnectionStr(config);
+            if (enableResetConfig) {
+                resetRemoteConfig(Config.getCenterConnectionStr(), "classpath:sql/sqlite/*");
+            }
         } else {
-            Config.setCenterConnectionStr(centerConfig);
-            Config.setSecurityConnectionStr(securityConfig);
-        }
-        if (enableResetConfig) {
-            cleanRemoteConfig(Config.getCenterConnectionStr(), "classpath:sql/systemset/*");
-            cleanRemoteConfig(Config.getSecurityConnectionStr(), "classpath:sql/uniauth/*");
-
+            if (encryptEnable) {
+                Config.setCenterConnectionStr(DataEncryptionUtil.decryptRSAByPrivateKey(centerConfig));
+                Config.setSecurityConnectionStr(DataEncryptionUtil.decryptRSAByPrivateKey(securityConfig));
+            } else {
+                Config.setCenterConnectionStr(centerConfig);
+                Config.setSecurityConnectionStr(securityConfig);
+            }
+            if (enableResetConfig) {
+//                使用正则判断 Config.getCenterConnectionStr()链接字符串配置中的jdbc数据库类型
+//                声明一个正则表达式
+                String regex = "jdbc:([a-zA-Z]+)";
+
+                // 创建 Pattern 对象
+                Pattern pattern = Pattern.compile(regex);
+
+                // 创建 Matcher 对象
+                Matcher matcher = pattern.matcher(Config.getCenterConnectionStr());
+
+                // 查找匹配的子串
+                if (matcher.find()) {
+                    String dbType = matcher.group(1);
+                    resetRemoteConfig(Config.getCenterConnectionStr(), "classpath:sql/%s/systemset/*".formatted(dbType));
+                    resetRemoteConfig(Config.getSecurityConnectionStr(), "classpath:sql/%s/uniauth/*".formatted(dbType));
+
+                } else {
+                    resetRemoteConfig(Config.getCenterConnectionStr(), "classpath:sql/mysql/systemset/*");
+                    resetRemoteConfig(Config.getSecurityConnectionStr(), "classpath:sql/mysql/uniauth/*");
+                }
+            }
         }
 
 //        日志配置初始化
@@ -169,38 +206,14 @@ public class SystemInit {
                 System.out.println("创建目录成功:" + resource.getAbsolutePath());
             }
         }
-        readConfigFile();
         ControlService.startServiceByContainerCode(Config.getContainerCode());
     }
-
-    private String readConfigFile() throws Exception {
-        File resource = new File("config");
-        if (resource.exists()) {
-            StringBuilder builder;
-            try (BufferedInputStream inputStream = new BufferedInputStream(new FileInputStream(resource))) {
-                byte[] bytes = new byte[1024];
-                builder = new StringBuilder();
-                while (inputStream.read(bytes) > 0) {
-                    builder.append(new String(bytes));
-                }
-            }
-            String string = builder.toString();
-            return DataEncryptionUtil.decryptRSAByPrivateKey(string);
-        } else {
-            return "{}";
-        }
-    }
-
     /**
-     * 清理远程数据配置
+     * 重置远程数据配置
      */
-    private void cleanRemoteConfig(String connection, String path) throws Exception {
-
-
+    private void resetRemoteConfig(String connection, String path) throws Exception {
         Resource[] resources = resourcePatternResolver.getResources(path);
-
         for (Resource resource : resources) {
-
             StringBuilder stringBuilder = new StringBuilder();
             try (InputStream inputStream = resource.getInputStream();
                  BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(inputStream, StandardCharsets.UTF_8))) {
@@ -218,7 +231,6 @@ public class SystemInit {
                 }
             }
         }
-
     }
 
     /**
@@ -468,10 +480,10 @@ public class SystemInit {
         }
     }
 
-
     private void checkAppKey(String url, String key) throws IOException {
         // 获取本地机器的MAC地址
         String mac = Util.mac();
+        System.out.println(mac);
 
         // 尝试从本地许可证文件进行验证
         String licensePath = SpringContextApplication.getString("app.license.file");
@@ -526,12 +538,15 @@ public class SystemInit {
             Object data = result.get("returnData");
             JsonNode json = DataFormatUtil.toJsonNode(data.toString());
 
-            String exp = json.get("returnData").get(0).get("exptime").asText();
+            ArrayNode jsonNode = json.withArray("returnData");
+            if (jsonNode.isEmpty()){
+                throw new RuntimeException("无效的密钥");
+            }
+            String exp = jsonNode.get(0).get("exptime").asText();
             LocalDateTime expLocalDateTime = LocalDateTime.parse(exp);
             if (expLocalDateTime.isBefore(LocalDateTime.now())) {
                 throw new RuntimeException("密钥已过期");
             }
         }
     }
-
 }

src/main/resources/application-dev.yml

@@ -4,7 +4,7 @@ app:
   debug: false
   security:
     encrypt: false
-    enable: true
+    enable: false
   inner:
     ssl:
       enable: false

src/main/resources/application.yml

@@ -5,6 +5,10 @@ app:
   security:
     enable: true
     encrypt: true
+  singleton:
+    enable: false
+    file: ./config/config.sqlite
+
 server:
   port: 9500
 spring:

src/main/resources/sql/mysql/systemset/V0.0__drop_table.sql

@@ -0,0 +1,28 @@
+drop table if exists algorithmlibrary;
+
+drop table if exists algorithmparameters;
+
+drop table if exists algorithmsourcelibrary;
+
+drop table if exists container;
+
+drop table if exists containerdeploy;
+
+drop table if exists datacache;
+
+drop table if exists datasource;
+
+drop table if exists keyalias;
+
+drop table if exists qualitycontrol;
+
+drop table if exists serviceinfo;
+
+drop table if exists servicestate;
+
+drop table if exists servicetype;
+
+drop table if exists systeminfo;
+
+drop table if exists tablejoin;
+

src/main/resources/sql/mysql/systemset/V1.0__create_table.sql

@@ -0,0 +1,195 @@
+create table algorithmlibrary
+(
+    algorithmlibraryid       int auto_increment comment '算法编号'
+        primary key,
+    serviceid                int         null comment '服务编号',
+    computingexpression      text        null comment '计算表达式',
+    preconditions            text        null comment '前置计算条件',
+    executionorder           varchar(8)  null comment '执行顺序',
+    algorithmdescription     text        null comment '描述',
+    algorithmsourcelibraryid int         null comment '算法库算法id',
+    groupname                varchar(64) null,
+    loopcount                int         null
+)
+    row_format = DYNAMIC;
+
+create table algorithmparameters
+(
+    algorithmparametersid   int auto_increment
+        primary key,
+    algorithmlibraryid      int         null comment '所属算法编号',
+    parametername           tinytext    null comment '参数名',
+    subscriptionexpressions tinytext    null comment '参数订阅规则',
+    parametertype           tinytext    not null comment '参数类型',
+    datasource              tinytext    null,
+    algorithmname           tinytext    null comment '算法名称',
+    datasourcekey           varchar(12) null comment '是否是数据源字段'
+)
+    comment '算法参数' row_format = DYNAMIC;
+
+create table algorithmsourcelibrary
+(
+    id            int auto_increment
+        primary key,
+    superiorid    int unsigned null comment '上级编号',
+    type          tinytext     not null comment '类型',
+    name          tinytext     not null comment '名称',
+    code          tinytext     not null comment '编码',
+    datatype      tinytext     null comment '数据类型',
+    datasource    tinytext     null comment '数据来源',
+    defaultvalue  tinytext     null comment '默认值',
+    description   tinytext     null comment '描述',
+    templatejson  text         null comment '模板JSON',
+    library       tinytext     null comment '类库',
+    filepath      tinytext     null comment '文件路径',
+    datasourcekey int          null comment '是否是数据源'
+)
+    row_format = DYNAMIC;
+
+create table container
+(
+    containerid       int auto_increment
+        primary key,
+    containercode     tinytext null comment '容器编号',
+    containername     tinytext null comment '名称',
+    containerdescribe tinytext null comment '用途说明',
+    requesturi        tinytext null comment '访问路径',
+    containervesion   tinytext null comment '版本号',
+    runstate          tinytext null comment '当前状态',
+    lasttime          datetime null comment '最后活跃时间',
+    workpath          tinytext null
+)
+    row_format = DYNAMIC;
+
+create table containerdeploy
+(
+    containerdeployid int auto_increment
+        primary key,
+    serviceid         int      null comment '服务id',
+    servicename       tinytext null comment '服务名称',
+    containerid       int      null comment '容器id',
+    containercode     tinytext null comment '容器编号',
+    containername     tinytext null comment '容器名称',
+    workpath          tinytext null comment '服务运行路径'
+)
+    comment '容器服务部署' row_format = DYNAMIC;
+
+create table datacache
+(
+    datacacheid       int auto_increment
+        primary key,
+    connectset        text null comment '连接字符串',
+    querysql          text null comment '查询语句',
+    querytable        text null comment '查询表名',
+    effectiveduration int  null comment '缓存时长（秒）',
+    datacachedescribe text null comment '描述'
+)
+    comment '二级缓存配置' row_format = DYNAMIC;
+
+create table datasource
+(
+    datasourceid       int auto_increment
+        primary key,
+    datasourcedescribe tinytext null comment '数据源说明',
+    datasourcetype     tinytext null comment '数据源类型',
+    host               tinytext null comment 'ip',
+    username           tinytext null comment '用户名',
+    password           tinytext null comment '密码',
+    httpheaders        text     null comment 'http请求头',
+    httpbody           text     null comment 'http请求体',
+    driverclassname    tinytext null comment '类名（驱动）'
+)
+    row_format = DYNAMIC;
+
+create table keyalias
+(
+    aliasid       int auto_increment
+        primary key,
+    keyname       tinytext null comment '键名',
+    aliasname     tinytext null comment '别名',
+    aliasdescribe tinytext null comment '备注'
+)
+    row_format = DYNAMIC;
+
+create table qualitycontrol
+(
+    id                   int auto_increment
+        primary key,
+    sourceid             int          not null comment '数据源',
+    sourcename           varchar(64)  null,
+    target               varchar(128) not null,
+    targetname           varchar(128) null,
+    rules                text         not null,
+    frequency            int          null,
+    single               int          null,
+    enablelog            int          null,
+    messagetemplate      int          null,
+    lastruncontainercode varchar(16)  null comment '最后运行容器',
+    lastruntime          timestamp    null comment '最后运行时间',
+    resultfilter         text         null
+);
+
+create table serviceinfo
+(
+    serviceid   int auto_increment comment '主键'
+        primary key,
+    servicename tinytext null comment '名称',
+    tasktype    int      null comment '定时类型',
+    cronexpress tinytext null comment '定时器表达式',
+    urilist     tinytext null comment '对外暴露URI列表',
+    loopcount   int      null comment '循环次数',
+    frequency   int      null comment '频率',
+    enablelog   int      null comment '运行日志',
+    raw         int      null comment '是否返回原始数据 1返回原始数据 否则返回包装数据'
+)
+    row_format = DYNAMIC;
+
+create table servicestate
+(
+    servicestateid int auto_increment
+        primary key,
+    serviceid      int      null comment '服务编号',
+    servicename    tinytext null,
+    containerid    int      null comment '容器编号',
+    containercode  tinytext null comment '运行实例编号',
+    starttime      datetime null comment '启动时间',
+    stoptime       datetime null comment '停止时间',
+    runstate       tinytext null comment '当前状态',
+    lasttime       datetime null comment '最后活跃时间',
+    workpath       tinytext null
+)
+    row_format = DYNAMIC;
+
+create table servicetype
+(
+    servicetypeid       int auto_increment
+        primary key,
+    servicetypename     tinytext null comment '服务类型名称',
+    servicetypedescribe text     null comment '描述'
+)
+    row_format = DYNAMIC;
+
+create table systeminfo
+(
+    systemid       int auto_increment
+        primary key,
+    keyname        tinytext null comment '键名',
+    datasourceid   int      null comment '数据源id',
+    expression     tinytext null comment '表达式',
+    systemdescribe tinytext null comment '系统描述'
+)
+    row_format = DYNAMIC;
+
+create table tablejoin
+(
+    id                int auto_increment
+        primary key,
+    sourcetable       tinytext null comment '源表',
+    targettable       tinytext null comment '目标表',
+    sourcejoincolumn  tinytext null comment '源关联列名',
+    targetjoincolumn  tinytext null comment '目标关联列名',
+    targetshowcolumns tinytext null comment '目标显示列名列表',
+    datasourceid      int      null comment '数据源'
+)
+    comment '外键关联' row_format = DYNAMIC;
+

src/main/resources/sql/mysql/uniauth/V0.0__drop_table.sql

@@ -0,0 +1,28 @@
+drop table apiinfo;
+
+drop table appconnectlog;
+
+drop table application;
+
+drop table applicationpermissions;
+
+drop table breakerrule;
+
+drop table pageconfiguration;
+
+drop table ratelimitrule;
+
+drop table tempsecuritycode;
+
+drop table tenantManage;
+
+drop table usergroup;
+
+drop table usergrouppermissions;
+
+drop table userinfo;
+
+drop table userloginlog;
+
+drop table userpermissions;
+

src/main/resources/sql/mysql/uniauth/V1.0__create_table.sql

@@ -0,0 +1,236 @@
+create table apiinfo
+(
+    apiid            int auto_increment
+        primary key,
+    apiname          tinytext null comment 'api名称',
+    apitype          tinytext null comment 'api类型',
+    requestpath      tinytext null comment '请求地址',
+    routepath        tinytext null comment '响应地址',
+    securitykey      tinytext null comment '安全认证类型',
+    superiorid       int null comment '所属api编号',
+    apicode          tinytext null comment '参数编码',
+    datatype         tinytext null comment '参数数据类型',
+    datadefaultvalue tinytext null comment '默认参数值',
+    constraint apiinfo_pk
+        unique (apiid)
+);
+
+create table appconnectlog
+(
+    connid      int auto_increment
+        primary key,
+    appid       tinytext null comment '应用编号',
+    requesttime datetime null comment '请求时间',
+    requestip   tinytext null comment '请求地址',
+    apptoken    tinytext null comment '连接令牌',
+    expiretime  datetime null comment '令牌过期时间',
+    lasttime    datetime null comment '最后活跃时间'
+);
+
+create table application
+(
+    applicationid         int auto_increment
+        primary key,
+    appid                 tinytext null comment '编号',
+    appsecret             tinytext null comment '连接密钥',
+    appname               tinytext null comment '名称',
+    appengname            tinytext null comment '英文名称',
+    appdescribe           tinytext null comment '描述',
+    applogo               longtext null comment '图标',
+    smalllogo             longtext null comment '小图标',
+    backgroundimage       longtext null comment '背景图',
+    apptokeneffective     int null comment '令牌有效时长',
+    securitycoderule      tinytext null comment '验证码规则',
+    securitycodeeffective int null comment '验证码有效时长',
+    multilogin            int null comment '多机登陆',
+    passwordrule          tinytext null comment '密码规则',
+    passwordeffective     int null comment '密码有效时长'
+);
+
+create table applicationpermissions
+(
+    applicationpermissionsid int auto_increment
+        primary key,
+    appid                    tinytext null comment '应用编号',
+    apiid                    int null comment 'API编号',
+    columnlist               tinytext null comment '列权限',
+    filterset                tinytext null comment '行权限'
+);
+
+create table breakerrule
+(
+    breakerruleid        int auto_increment comment '熔断规则自增id'
+        primary key,
+    breakerrulename      tinytext null comment '熔断规则名称',
+    duration             int null comment '熔断时间',
+    limitvalue           int null comment '熔断范围值',
+    averageerrorrate     decimal(5, 2) null comment '平均错误率',
+    errorcount           int null comment '错误次数',
+    averageexecutiontime int null comment '平均执行时间',
+    returnmessage        tinytext null comment '返回消息'
+);
+
+create table pageconfiguration
+(
+    pageconfigurationid          int auto_increment
+        primary key,
+    pagetype                     tinytext not null comment '类型（模块、页面、按钮、Table表格、树、数据项、From表单）',
+    superiorid                   int null comment '上级编号',
+    pagename                     tinytext not null comment '名称',
+    pagecode                     tinytext not null comment '编码',
+    pagedescribe                 tinytext null comment '描述',
+    serviceid                    int null comment '绑定服务编号',
+    shortcutkeys                 tinytext null comment '快捷键(核心用于按钮)',
+    openmode                     tinytext null comment '打开方式（新页、弹出或抽屉、同页关联查询）',
+    pageroute                    tinytext null comment '路由',
+    pageaddress                  tinytext null comment '地址',
+    passparameters               longtext null comment '传递参数',
+    defaultfilter                tinytext null comment '页面打开时的默认查询条件',
+    pageicon                     tinytext null comment '图标',
+    rowbackgroundcolorexpression tinytext null comment '行背景色表达式',
+    rowfontcolorexpression       tinytext null comment '行字体色表达式',
+    datatype                     tinytext null comment '渲染类型',
+    datalength                   int null comment '数据长度',
+    isdisplay                    tinytext null comment '是否显示',
+    displaynumber                int null comment '显示顺序',
+    displaywidth                 int null comment '显示宽度',
+    backgroundcolorexpression    tinytext null comment '背景色表达式',
+    fontcolorexpression          tinytext null comment '字体色表达式',
+    enablesort                   int null comment '启用排序功能',
+    enablefilter                 int null comment '启用过滤功能',
+    enablegroup                  int null comment '是否分组',
+    enablecount                  int null comment '启用合计',
+    counttopmost                 int null comment '合计置顶',
+    isfiltercolumn               int null comment '是否为查询条件',
+    isprimarykey                 int null comment '是否主键',
+    defaultparameters            tinytext null comment '默认查询参数',
+    dropdownlist                 tinytext null comment '下来列表（服务编号）',
+    dropdownlistid               tinytext null comment '下来列表键值',
+    dropdownlistlabel            tinytext null comment '下来列表显示名称',
+    isrequired                   int null comment '是否必填',
+    uniquitytype                 tinytext null comment '唯一性',
+    formatrule                   tinytext null comment '格式校验规则',
+    defaultvalue                 tinytext null comment '默认值',
+    calculationformula           tinytext null comment '计算公式',
+    servicetype                  int null,
+    groupid                      tinytext null comment '所属分组',
+    alias                        tinytext null comment '别名',
+    labelcode                    tinytext null comment '下拉数据关联项编码',
+    selected                     int null comment '是否勾选',
+    triggerserviceid             int null comment '勾选触发的服务id',
+    charttype                    tinytext null comment '图表类型',
+    easysearch                   int default 0 null
+);
+
+create table ratelimitrule
+(
+    ratelimitingid   int auto_increment
+        primary key,
+    ratelimitingname tinytext null comment '策略名',
+    duration         int null comment '单位时间频率(秒)',
+    timeout          int null comment '超时shi''c',
+    limitvalue       int null comment '数量上限',
+    returnmessage    tinytext null comment '超限返回提示',
+    serviceid        tinytext null comment '适用服务编号列表',
+    pathmatch        tinytext null comment '路径匹配'
+);
+
+create table tempsecuritycode
+(
+    codeid       int auto_increment
+        primary key,
+    appid        tinytext null comment '应用编号',
+    requestip    tinytext null comment '请求地址',
+    sessionid    tinytext null comment '请求编号',
+    securitycode tinytext null comment '验证码',
+    expiretime   datetime null comment '验证码过期时间'
+);
+
+create table tenantManage
+(
+    tenantId       int not null comment '租户ID'
+        primary key,
+    tenantName     varchar(24) null comment '租户名称',
+    tenantEngName  varchar(32) null comment '英文名称',
+    tenantDescribe text null comment '描述',
+    validStartTime datetime null comment '有效开始时间',
+    validEndTime   datetime null comment '有效结束时间',
+    contact        varchar(12) null comment '联系人',
+    phone          varchar(16) null comment '联系电话'
+);
+
+create table usergroup
+(
+    usergroupid       int auto_increment
+        primary key,
+    superiorid        int null comment '上级编号',
+    usergroupname     tinytext null comment '名称',
+    usergroupdescribe text null comment '描述',
+    isenable          int null comment '是否启用',
+    isdelete          int null comment '删除状态',
+    grouptype         tinytext null comment '组织类型'
+);
+
+create table usergrouppermissions
+(
+    userpermissionsid   int auto_increment
+        primary key,
+    usergroupid         int null comment '用户组编号',
+    pageconfigurationid int null comment '权限项编号',
+    serviceid           int null comment '服务编号',
+    insetcolumnlist     text null comment '新增权限',
+    updatecolumnlist    text null comment '更新权限',
+    selectcolumnlist    text null comment '查询权限',
+    filterset           text null comment '过滤权限'
+);
+
+create table userinfo
+(
+    userid               int auto_increment
+        primary key,
+    usergroupid          int null comment '所属用户组编号',
+    username             varchar(255) null comment '用户名',
+    account              varchar(255) not null comment '账号',
+    userpassword         varchar(255) null comment '密码',
+    userdescribe         text null comment '描述',
+    isenable             int null comment '是否启用',
+    secondarypassword    varchar(255) null comment '二次密码',
+    multilogin           int null comment '多机登录',
+    passwordlastmodified datetime null comment '密码最后修改时间',
+    isdelete             int null comment '删除状态',
+    email                varchar(64) null comment '右键',
+    constraint account
+        unique (account)
+);
+
+create table userloginlog
+(
+    loginid       int auto_increment
+        primary key,
+    userid        int null comment '用户编号',
+    requestip     tinytext null comment '请求地址',
+    sessionid     tinytext null comment '请求编号',
+    logintime     datetime null comment '登录时间',
+    usertoken     tinytext null comment '用户令牌',
+    lasttime      datetime null comment '最后活跃时间',
+    lastheartbeat datetime null comment '最后心跳时间',
+    logouttime    datetime null comment '登出时间',
+    apptoken      tinytext null comment '连接令牌',
+    isexpires     tinyint null comment '是否过期',
+    appid         tinytext null comment '应用编号',
+    expirestime   datetime null comment '过期时间'
+);
+
+create table userpermissions
+(
+    userpermissionsid   int auto_increment
+        primary key,
+    userid              int null comment '用户变化',
+    pageconfigurationid int null comment '权限项编号',
+    serviceid           int null comment '服务编号',
+    insetcolumnlist     text null comment '新增',
+    updatecolumnlist    text null comment '更新',
+    selectcolumnlist    text null comment '查询',
+    filterset           text null comment '过滤',
+    parentserviceid     int null
+);

src/main/resources/sql/mysql/uniauth/v1.1__init_data.sql

@@ -0,0 +1,6 @@
+INSERT INTO uniauth.apiinfo (apiid, apiname, apitype, requestpath, routepath, securitykey, superiorid, apicode, datatype, datadefaultvalue) VALUES (1, '获取token', '外部API', '/user/getToken', null, null, null, null, null, null);
+INSERT INTO uniauth.apiinfo (apiid, apiname, apitype, requestpath, routepath, securitykey, superiorid, apicode, datatype, datadefaultvalue) VALUES (2, '刷新token', '外部API', '/user/refreshToken', null, 'token', null, null, null, null);
+INSERT INTO uniauth.apiinfo (apiid, apiname, apitype, requestpath, routepath, securitykey, superiorid, apicode, datatype, datadefaultvalue) VALUES (3, '新增', '外部API', '/openApi/newdata', null, 'usertoken', null, null, null, null);
+INSERT INTO uniauth.apiinfo (apiid, apiname, apitype, requestpath, routepath, securitykey, superiorid, apicode, datatype, datadefaultvalue) VALUES (4, '修改', '外部API', '/openApi/modifydata', null, 'usertoken', null, null, null, null);
+INSERT INTO uniauth.apiinfo (apiid, apiname, apitype, requestpath, routepath, securitykey, superiorid, apicode, datatype, datadefaultvalue) VALUES (5, '删除', '外部API', '/openApi/movedata', null, 'usertoken', null, null, null, null);
+INSERT INTO uniauth.apiinfo (apiid, apiname, apitype, requestpath, routepath, securitykey, superiorid, apicode, datatype, datadefaultvalue) VALUES (6, '查询', '外部API', '/openApi/query', null, 'usertoken', null, null, null, null);

src/main/resources/sql/sqlite/V0.0__drop_table.sql

@@ -0,0 +1,57 @@
+drop table if exists algorithmlibrary;
+
+drop table if exists algorithmparameters;
+
+drop table if exists algorithmsourcelibrary;
+
+drop table if exists apiinfo;
+
+drop table if exists appconnectlog;
+
+drop table if exists application;
+
+drop table if exists applicationpermissions;
+
+drop table if exists breakerrule;
+
+drop table if exists container;
+
+drop table if exists containerdeploy;
+
+drop table if exists datacache;
+
+drop table if exists datasource;
+
+drop table if exists keyalias;
+
+drop table if exists pageconfiguration;
+
+drop table if exists qualitycontrol;
+
+drop table if exists ratelimitrule;
+
+drop table if exists serviceinfo;
+
+drop table if exists servicestate;
+
+drop table if exists servicetype;
+
+
+drop table if exists systeminfo;
+
+drop table if exists tablejoin;
+
+drop table if exists tempsecuritycode;
+
+drop table if exists tenantManage;
+
+drop table if exists usergroup;
+
+drop table if exists usergrouppermissions;
+
+drop table if exists userinfo;
+
+drop table if exists userloginlog;
+
+drop table if exists userpermissions;
+

src/main/resources/sql/sqlite/V1.0__create_table.sql

@@ -0,0 +1,388 @@
+create table algorithmlibrary
+(
+    algorithmlibraryid       integer,
+    serviceid                integer,
+    computingexpression      text,
+    preconditions            text,
+    executionorder           varchar(8),
+    algorithmdescription     text,
+    algorithmsourcelibraryid integer,
+    groupname                varchar(64),
+    loopcount                integer
+);
+
+create table algorithmparameters
+(
+    algorithmparametersid   integer,
+    algorithmlibraryid      integer,
+    parametername           varchar,
+    subscriptionexpressions varchar,
+    parametertype           varchar,
+    datasource              varchar,
+    algorithmname           varchar,
+    datasourcekey           varchar(12)
+);
+
+create table algorithmsourcelibrary
+(
+    id            integer,
+    superiorid    unsigned bigint,
+    type          varchar,
+    name          varchar,
+    code          varchar,
+    datatype      varchar,
+    datasource    varchar,
+    defaultvalue  varchar,
+    description   varchar,
+    templatejson  text,
+    library       varchar,
+    filepath      varchar,
+    datasourcekey integer
+);
+
+create table apiinfo
+(
+    apiid            integer,
+    apiname          varchar,
+    apitype          varchar,
+    requestpath      varchar,
+    routepath        varchar,
+    securitykey      varchar,
+    superiorid       integer,
+    apicode          varchar,
+    datatype         varchar,
+    datadefaultvalue varchar
+);
+
+create table appconnectlog
+(
+    connid      integer,
+    appid       varchar,
+    requesttime datetime,
+    requestip   varchar,
+    apptoken    varchar,
+    expiretime  datetime,
+    lasttime    datetime
+);
+
+create table application
+(
+    applicationid         integer,
+    appid                 varchar,
+    appsecret             varchar,
+    appname               varchar,
+    appengname            varchar,
+    appdescribe           varchar,
+    applogo               longvarchar,
+    smalllogo             longvarchar,
+    backgroundimage       longvarchar,
+    apptokeneffective     integer,
+    securitycoderule      varchar,
+    securitycodeeffective integer,
+    multilogin            integer,
+    passwordrule          varchar,
+    passwordeffective     integer
+);
+
+create table applicationpermissions
+(
+    applicationpermissionsid integer,
+    appid                    varchar,
+    apiid                    integer,
+    columnlist               varchar,
+    filterset                varchar
+);
+
+create table breakerrule
+(
+    breakerruleid        integer,
+    breakerrulename      varchar,
+    duration             integer,
+    limitvalue           integer,
+    averageerrorrate     decimal(5, 2),
+    errorcount           integer,
+    averageexecutiontime integer,
+    returnmessage        varchar
+);
+
+create table container
+(
+    containerid       integer,
+    containercode     varchar,
+    containername     varchar,
+    containerdescribe varchar,
+    requesturi        varchar,
+    containervesion   varchar,
+    runstate          varchar,
+    lasttime          datetime,
+    workpath          varchar
+);
+
+create table containerdeploy
+(
+    containerdeployid integer,
+    serviceid         integer,
+    servicename       varchar,
+    containerid       integer,
+    containercode     varchar,
+    containername     varchar,
+    workpath          varchar
+);
+
+create table datacache
+(
+    datacacheid       integer,
+    connectset        text,
+    querysql          text,
+    querytable        text,
+    effectiveduration integer,
+    datacachedescribe text
+);
+
+create table datasource
+(
+    datasourceid       integer,
+    datasourcedescribe varchar,
+    datasourcetype     varchar,
+    host               varchar,
+    username           varchar,
+    password           varchar,
+    httpheaders        text,
+    httpbody           text,
+    driverclassname    varchar
+);
+
+create table keyalias
+(
+    aliasid       integer,
+    keyname       varchar,
+    aliasname     varchar,
+    aliasdescribe varchar
+);
+
+create table pageconfiguration
+(
+    pageconfigurationid          integer,
+    pagetype                     varchar,
+    superiorid                   integer,
+    pagename                     varchar,
+    pagecode                     varchar,
+    pagedescribe                 varchar,
+    serviceid                    integer,
+    shortcutkeys                 varchar,
+    openmode                     varchar,
+    pageroute                    varchar,
+    pageaddress                  varchar,
+    passparameters               longvarchar,
+    defaultfilter                varchar,
+    pageicon                     varchar,
+    rowbackgroundcolorexpression varchar,
+    rowfontcolorexpression       varchar,
+    datatype                     varchar,
+    datalength                   integer,
+    isdisplay                    varchar,
+    displaynumber                integer,
+    displaywidth                 integer,
+    backgroundcolorexpression    varchar,
+    fontcolorexpression          varchar,
+    enablesort                   integer,
+    enablefilter                 integer,
+    enablegroup                  integer,
+    enablecount                  integer,
+    counttopmost                 integer,
+    isfiltercolumn               integer,
+    isprimarykey                 integer,
+    defaultparameters            varchar,
+    dropdownlist                 varchar,
+    dropdownlistid               varchar,
+    dropdownlistlabel            varchar,
+    isrequired                   integer,
+    uniquitytype                 varchar,
+    formatrule                   varchar,
+    defaultvalue                 varchar,
+    calculationformula           varchar,
+    servicetype                  integer,
+    groupid                      varchar,
+    alias                        varchar,
+    labelcode                    varchar,
+    selected                     integer,
+    triggerserviceid             integer,
+    charttype                    varchar,
+    easysearch                   integer
+);
+
+create table qualitycontrol
+(
+    id                   integer,
+    sourceid             integer,
+    sourcename           varchar(64),
+    target               varchar(128),
+    targetname           varchar(128),
+    rules                text,
+    frequency            integer,
+    single               integer,
+    enablelog            integer,
+    messagetemplate      integer,
+    lastruncontainercode varchar(16),
+    lastruntime          datetime,
+    resultfilter         text
+);
+
+create table ratelimitrule
+(
+    ratelimitingid   integer,
+    ratelimitingname varchar,
+    duration         integer,
+    timeout          integer,
+    limitvalue       integer,
+    returnmessage    varchar,
+    serviceid        varchar,
+    pathmatch        varchar
+);
+
+create table serviceinfo
+(
+    serviceid   integer,
+    servicename varchar,
+    tasktype    integer,
+    cronexpress varchar,
+    urilist     varchar,
+    loopcount   integer,
+    frequency   integer,
+    enablelog   integer,
+    raw         integer
+);
+
+create table servicestate
+(
+    servicestateid integer,
+    serviceid      integer,
+    servicename    varchar,
+    containerid    integer,
+    containercode  varchar,
+    starttime      datetime,
+    stoptime       datetime,
+    runstate       varchar,
+    lasttime       datetime,
+    workpath       varchar
+);
+
+create table servicetype
+(
+    servicetypeid       integer,
+    servicetypename     varchar,
+    servicetypedescribe text
+);
+
+
+create table systeminfo
+(
+    systemid       integer,
+    keyname        varchar,
+    datasourceid   integer,
+    expression     varchar,
+    systemdescribe varchar
+);
+
+create table tablejoin
+(
+    id                integer,
+    sourcetable       varchar,
+    targettable       varchar,
+    sourcejoincolumn  varchar,
+    targetjoincolumn  varchar,
+    targetshowcolumns varchar,
+    datasourceid      integer
+);
+
+create table tempsecuritycode
+(
+    codeid       integer,
+    appid        varchar,
+    requestip    varchar,
+    sessionid    varchar,
+    securitycode varchar,
+    expiretime   datetime
+);
+
+create table tenantManage
+(
+    tenantId       integer,
+    tenantName     varchar(24),
+    tenantEngName  varchar(32),
+    tenantDescribe text,
+    validStartTime datetime,
+    validEndTime   datetime,
+    contact        varchar(12),
+    phone          varchar(16)
+);
+
+create table usergroup
+(
+    usergroupid       integer,
+    superiorid        integer,
+    usergroupname     varchar,
+    usergroupdescribe text,
+    isenable          integer,
+    isdelete          integer,
+    grouptype         varchar
+);
+
+create table usergrouppermissions
+(
+    userpermissionsid   integer,
+    usergroupid         integer,
+    pageconfigurationid integer,
+    serviceid           integer,
+    insetcolumnlist     text,
+    updatecolumnlist    text,
+    selectcolumnlist    text,
+    filterset           text
+);
+
+create table userinfo
+(
+    userid               integer,
+    usergroupid          integer,
+    username             varchar(255),
+    account              varchar(255),
+    userpassword         varchar(255),
+    userdescribe         text,
+    isenable             integer,
+    secondarypassword    varchar(255),
+    multilogin           integer,
+    passwordlastmodified datetime,
+    isdelete             integer,
+    email                varchar(64)
+);
+
+create table userloginlog
+(
+    loginid       integer,
+    userid        integer,
+    requestip     varchar,
+    sessionid     varchar,
+    logintime     datetime,
+    usertoken     varchar,
+    lasttime      datetime,
+    lastheartbeat datetime,
+    logouttime    datetime,
+    apptoken      varchar,
+    isexpires     tinyint,
+    appid         varchar,
+    expirestime   datetime
+);
+
+create table userpermissions
+(
+    userpermissionsid   integer,
+    userid              integer,
+    pageconfigurationid integer,
+    serviceid           integer,
+    insetcolumnlist     text,
+    updatecolumnlist    text,
+    selectcolumnlist    text,
+    filterset           text,
+    parentserviceid     integer
+);
+

src/main/resources/sql/sqlite/v1.1__init_data.sql

@@ -0,0 +1,6 @@
+INSERT INTO apiinfo (apiid, apiname, apitype, requestpath, routepath, securitykey, superiorid, apicode, datatype, datadefaultvalue) VALUES (1, '获取token', '外部API', '/user/getToken', null, null, null, null, null, null);
+INSERT INTO apiinfo (apiid, apiname, apitype, requestpath, routepath, securitykey, superiorid, apicode, datatype, datadefaultvalue) VALUES (2, '刷新token', '外部API', '/user/refreshToken', null, 'token', null, null, null, null);
+INSERT INTO apiinfo (apiid, apiname, apitype, requestpath, routepath, securitykey, superiorid, apicode, datatype, datadefaultvalue) VALUES (3, '新增', '外部API', '/openApi/newdata', null, 'usertoken', null, null, null, null);
+INSERT INTO apiinfo (apiid, apiname, apitype, requestpath, routepath, securitykey, superiorid, apicode, datatype, datadefaultvalue) VALUES (4, '修改', '外部API', '/openApi/modifydata', null, 'usertoken', null, null, null, null);
+INSERT INTO apiinfo (apiid, apiname, apitype, requestpath, routepath, securitykey, superiorid, apicode, datatype, datadefaultvalue) VALUES (5, '删除', '外部API', '/openApi/movedata', null, 'usertoken', null, null, null, null);
+INSERT INTO apiinfo (apiid, apiname, apitype, requestpath, routepath, securitykey, superiorid, apicode, datatype, datadefaultvalue) VALUES (6, '查询', '外部API', '/openApi/query', null, 'usertoken', null, null, null, null);