From db4073c381b15b17d907a77056a6b2538b79eef3 Mon Sep 17 00:00:00 2001 From: Derran Date: Tue, 25 Jun 2024 14:26:28 +0800 Subject: [PATCH] =?UTF-8?q?=E5=9F=BA=E7=A1=80=E9=85=8D=E7=BD=AE?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../handler/dingtalk/DingTalkWarningEventHandler.java | 10 ++++++---- 1 file changed, 6 insertions(+), 4 deletions(-) diff --git a/dating-agency-mall-server/src/main/java/com/qniao/dam/application/handler/dingtalk/DingTalkWarningEventHandler.java b/dating-agency-mall-server/src/main/java/com/qniao/dam/application/handler/dingtalk/DingTalkWarningEventHandler.java index 83b706a..91b8502 100644 --- a/dating-agency-mall-server/src/main/java/com/qniao/dam/application/handler/dingtalk/DingTalkWarningEventHandler.java +++ b/dating-agency-mall-server/src/main/java/com/qniao/dam/application/handler/dingtalk/DingTalkWarningEventHandler.java @@ -8,8 +8,10 @@ import com.qniao.dam.domain.aggregate.order.entity.OrderItem; import com.qniao.dam.domain.aggregate.order.repository.OrderRepository; import com.qniao.dam.domian.aggregate.order.event.OrderCompletedEvent; import com.qniao.dam.infrastructure.persistent.dao.activity.ActivityDao; +import com.qniao.dam.infrastructure.persistent.dao.domain.SiteActivityDao; import com.qniao.dam.infrastructure.utils.DingTalkWarningUtil; import com.qniao.dam.query.externalorder.ExternalOrderRelQueryService; +import com.qniao.das.domian.aggregate.siteactivity.SiteActivity; import com.qniao.domain.BaseApplicationService; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.annotation.Value; @@ -33,7 +35,7 @@ public class DingTalkWarningEventHandler extends BaseApplicationService { @Resource private ExternalOrderRelQueryService externalOrderRelQueryService; @Resource - private ActivityDao activityDao; + private SiteActivityDao siteActivityDao; /** * 订单已完成事件 @@ -51,9 +53,9 @@ public class DingTalkWarningEventHandler extends BaseApplicationService { builder.append("产品名称：" + order.getOrderItemList().stream().map(OrderItem::getProductTitle).collect(Collectors.joining("、")) + "
"); ExternalOrderRel externalOrderRel = externalOrderRelQueryService.queryByOrderId(order.getId()); if (Objects.nonNull(externalOrderRel)) { - Activity activity = activityDao.selectById(externalOrderRel.getExternalId()); - if (Objects.nonNull(activity)) { - builder.append("关联活动：" + activity.getActivityName()); + SiteActivity siteActivity = siteActivityDao.selectById(externalOrderRel.getExternalId()); + if (Objects.nonNull(siteActivity)) { + builder.append("关联活动：" + siteActivity.getName()); } } HashMap body = new HashMap<>();