From 76faa8c936745ea4220c28c70ab1182b68aa862c Mon Sep 17 00:00:00 2001 From: yechuan Date: Fri, 11 Aug 2023 13:51:34 +0800 Subject: [PATCH] =?UTF-8?q?=E6=8B=86=E5=88=86?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- sink/src/main/java/work/xuye/sink/handler/ItemHandler.java | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/sink/src/main/java/work/xuye/sink/handler/ItemHandler.java b/sink/src/main/java/work/xuye/sink/handler/ItemHandler.java index d74a0b1..7a0149f 100644 --- a/sink/src/main/java/work/xuye/sink/handler/ItemHandler.java +++ b/sink/src/main/java/work/xuye/sink/handler/ItemHandler.java @@ -10,6 +10,7 @@ import org.springframework.util.DigestUtils; import org.springframework.util.ObjectUtils; import work.xuye.common.constant.MessageConstants; import work.xuye.common.constant.StageConstants; +import work.xuye.common.db.entity.Mapping; import work.xuye.common.db.entity.Task; import work.xuye.common.db.entity.vo.SinkParams; import work.xuye.common.db.entity.vo.TableTemplate; @@ -83,7 +84,9 @@ public class ItemHandler { SinkParams.CheckDelete checkDeleteConfig = taskVO.getTask().getSinkParams().getCheckDelete(); // 根据消息体，和映射关系，使用SpEL表达式，得到计算结果 - HashMap expressionResultMap = evaluator.evaluate(taskVO.getTemplateMappingMap().get(templateName).getTableMapping(), message); + Map templateMappingMap = taskVO.getTemplateMappingMap(); + Mapping mapping = templateMappingMap.get(templateName); + HashMap expressionResultMap = evaluator.evaluate(mapping.getTableMapping(), message); // 如果不能通过校验，则抛出异常 this.validate(expressionResultMap, template); // 将计算结果合并到模板中，此刻的模板是拥有值的