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<>();