|
|
|
@ -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("、")) + "<br>"); |
|
|
|
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<String, String> body = new HashMap<>(); |
|
|
|
|