From 3db6aee66535ff30cfba67009124ad28cccca928 Mon Sep 17 00:00:00 2001 From: jay li <221531386@qq.com> Date: Tue, 10 Sep 2024 22:39:15 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E8=8E=B7=E5=8F=96bean?= =?UTF-8?q?=E6=96=B9=E5=BC=8F?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../yomahub/liteflow/parser/sql/SQLXmlELParser.java | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/liteflow-rule-plugin/liteflow-rule-sql/src/main/java/com/yomahub/liteflow/parser/sql/SQLXmlELParser.java b/liteflow-rule-plugin/liteflow-rule-sql/src/main/java/com/yomahub/liteflow/parser/sql/SQLXmlELParser.java index 655d21a26..5e15fc7c5 100644 --- a/liteflow-rule-plugin/liteflow-rule-sql/src/main/java/com/yomahub/liteflow/parser/sql/SQLXmlELParser.java +++ b/liteflow-rule-plugin/liteflow-rule-sql/src/main/java/com/yomahub/liteflow/parser/sql/SQLXmlELParser.java @@ -18,6 +18,7 @@ import com.yomahub.liteflow.property.LiteflowConfigGetter; import com.yomahub.liteflow.spi.holder.ContextAwareHolder; import com.yomahub.liteflow.util.JsonUtil; +import java.util.Map; import java.util.Objects; /** @@ -34,9 +35,6 @@ public class SQLXmlELParser extends ClassXmlFlowELParser { private static final String ERROR_COMMON_MSG = "rule-source-ext-data is empty"; - // 返回用户接口自定义sql - private CustomSqlRead customSqlRead; - /** * 构造函数 */ @@ -55,9 +53,11 @@ public class SQLXmlELParser extends ClassXmlFlowELParser { } // 自定义sql - if (ContextAwareHolder.loadContextAware().hasBean("CustomSqlRead")) { - this.customSqlRead = ContextAwareHolder.loadContextAware().getBean("CustomSqlRead"); + Map beansOfType = ContextAwareHolder.loadContextAware().getBeansOfType(CustomSqlRead.class); + for (Map.Entry entry : beansOfType.entrySet()) { + CustomSqlRead customSqlRead = entry.getValue(); String customChainSql = customSqlRead.getCustomChainSql(); + if (StrUtil.isNotBlank(customChainSql)) { sqlParserVO.setCustomSql(customChainSql); }