|
|
|
@ -1,8 +1,10 @@ |
|
|
|
package com.qniao.dam.application.handler.operationlog; |
|
|
|
|
|
|
|
import com.google.common.eventbus.Subscribe; |
|
|
|
import com.qniao.dam.domain.aggregate.order.entity.Order; |
|
|
|
import com.qniao.dam.domian.aggregate.operationlog.event.OrderPaymentLogEvent; |
|
|
|
import com.qniao.dam.domian.aggregate.order.event.OrderCompletedEvent; |
|
|
|
import com.qniao.dam.infrastructure.persistent.dao.domain.OrderDao; |
|
|
|
import com.qniao.dam.infrastructure.persistent.dao.domain.UserDao; |
|
|
|
import com.qniao.das.domian.aggregate.certificate.constant.CertificationAuditStatusEnum; |
|
|
|
import com.qniao.dau.domain.aggregate.user.entity.User; |
|
|
|
@ -24,6 +26,8 @@ public class OperationLogEventHandler extends BaseApplicationService { |
|
|
|
|
|
|
|
@Resource |
|
|
|
private UserDao userDao; |
|
|
|
@Resource |
|
|
|
private OrderDao orderDao; |
|
|
|
|
|
|
|
/** |
|
|
|
* 订单已支付事件 |
|
|
|
@ -32,8 +36,8 @@ public class OperationLogEventHandler extends BaseApplicationService { |
|
|
|
public void handle(OrderCompletedEvent event) { |
|
|
|
try { |
|
|
|
OrderPaymentLogEvent logEvent = new OrderPaymentLogEvent(); |
|
|
|
//预约单号 |
|
|
|
logEvent.setTargetId(event.getId()); |
|
|
|
Order order = orderDao.selectById(event.getId()); |
|
|
|
logEvent.setTargetId(order.getMiId()); |
|
|
|
Map<String, Object> logOperatorParams = event.getLogOperatorParams(); |
|
|
|
handleOperator(logEvent, logOperatorParams); |
|
|
|
//操作时间 |
|
|
|
|