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

enhancement: #I1X83D 提一个优化：flow.xml配置文件中，编排的节点找不到时，需要打印出日志，方便找出哪个节点，好定位问题

Browse Source
This commit is contained in:
bryan31
2020-10-25 23:52:14 +08:00
parent 0bb1756e93
commit 68543a2ca5
1 changed files with 8 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
liteflow-core/src/main/java/com/yomahub/liteflow/parser/XmlFlowParser.java
View File

@@ -7,8 +7,10 @@ import java.util.Map.Entry;
import java.util.regex.Matcher;
import java.util.regex.Pattern;
import cn.hutool.core.util.StrUtil;
import com.yomahub.liteflow.entity.flow.*;
import com.yomahub.liteflow.exception.ExecutableItemNotFoundException;
import com.yomahub.liteflow.util.SpringAware;
import org.apache.commons.lang3.StringUtils;
import org.dom4j.Document;
import org.dom4j.Element;
@@ -44,13 +46,15 @@ public abstract class XmlFlowParser {
String clazz = null;
Node node = null;
NodeComponent component = null;
Class<NodeComponent> nodeComponentClass;
for (Element e : nodeList) {
node = new Node();
id = e.attributeValue("id");
clazz = e.attributeValue("class");
node.setId(id);
node.setClazz(clazz);
component = (NodeComponent) Class.forName(clazz).newInstance();
nodeComponentClass = (Class<NodeComponent>)Class.forName(clazz);
component = SpringAware.registerOrGet(nodeComponentClass);
if (component == null) {
LOG.error("couldn't find component class [{}] ", clazz);
}
@@ -72,7 +76,7 @@ public abstract class XmlFlowParser {
parseOneChain(e);
}
} catch (Exception e) {
LOG.error("FlowParser parser exception: {}", e);
LOG.error("FlowParser parser exception", e);
throw e;
}
}
@@ -118,7 +122,8 @@ public abstract class XmlFlowParser {
Chain chain = FlowBus.getChain(item);
chainNodeList.add(chain);
}else{
throw new ExecutableItemNotFoundException();
String errorMsg = StrUtil.format("executable node[{}] is not found!",regexEntity.getItem());
throw new ExecutableItemNotFoundException(errorMsg);
}
}
if (condE.getName().equals("then")) {