public/liteFlow
1
0
Fork 0
mirror of https://gitee.com/dromara/liteFlow.git synced 2026-05-14 20:22:07 +08:00
Code Issues Packages Projects Releases Wiki Activity

初步完成 liteflow-solon-plugin 适配

Browse Source
This commit is contained in:
noear
2022-12-22 14:59:23 +08:00
parent 28d3c717f2
commit 27ae30f218
2 changed files with 68 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
liteflow-solon-plugin/src/main/java/com/yomahub/liteflow/solon/config/LiteflowProperty.java
View File

@@ -1,7 +1,6 @@
package com.yomahub.liteflow.solon.config;
import org.noear.solon.Utils;
import org.noear.solon.annotation.Configuration;
import org.noear.solon.annotation.Inject;
@@ -86,7 +85,7 @@ public class LiteflowProperty {
public void setRuleSource(String ruleSource) {
if (ruleSource.contains("*")) {
this.ruleSource = String.join(",", Utils.resolvePaths(ruleSource));
this.ruleSource = String.join(",", PathsUtils.resolvePaths(ruleSource));
} else {
this.ruleSource = ruleSource;
}

67
liteflow-solon-plugin/src/main/java/com/yomahub/liteflow/solon/config/PathsUtils.java Normal file
View File

@@ -0,0 +1,67 @@
package com.yomahub.liteflow.solon.config;
import org.noear.solon.core.util.ScanUtil;
import java.util.ArrayList;
import java.util.Collection;
import java.util.List;
import java.util.regex.Pattern;
/**
* solon 1.11.7 之后才有 Utils.resolvePaths；所以临时用下先
*
* @author noear
* @since 1.11
*/
public class PathsUtils {
public static Collection<String> resolvePaths(String pathExpr) {
List<String> paths = new ArrayList<>();
if (pathExpr.contains("/*") == false) { //说明没有*符
paths.add(pathExpr);
return paths;
}
//确定目录
int dirIdx = pathExpr.indexOf("/*");
String dir = pathExpr.substring(0, dirIdx);
//确定后缀
int sufIdx = pathExpr.lastIndexOf(".");
String suf = null;
if (sufIdx > 0) {
suf = pathExpr.substring(sufIdx);
if (suf.contains("*")) {
sufIdx = -1;
suf = null;
}
}
int sufIdx2 = sufIdx;
String suf2 = suf;
//匹配表达式
String expr = pathExpr.replaceAll("/\\*\\.", "/[^\\.]*\\.");
expr = expr.replaceAll("/\\*\\*/", "(/[^/]*)*/");
Pattern pattern = Pattern.compile(expr);
ScanUtil.scan(dir, n -> {
//进行后缀过滤，相对比较快
if (sufIdx2 > 0) {
return n.endsWith(suf2);
} else {
return true;
}
})
.forEach(uri -> {
//再进行表达式过滤
if (pattern.matcher(uri).find()) {
paths.add(uri);
}
});
return paths;
}
}