| | |
|---|
| | | import cc.mrbird.febs.mall.service.IApiMallOrderInfoService; |
|---|
| | | import cc.mrbird.febs.mall.service.IMemberProfitService; |
|---|
| | | import cc.mrbird.febs.rabbit.constants.QueueConstants; |
|---|
| | | import cc.mrbird.febs.rabbit.enumerates.RabbitQueueEnum; |
|---|
| | | import com.rabbitmq.client.Channel; |
|---|
| | | import lombok.extern.slf4j.Slf4j; |
|---|
| | | import org.springframework.amqp.core.Message; |
|---|
| | |
|---|
| | | log.error("支付后同意验证:", e); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | @RabbitListener(queues = QueueConstants.YWG_ROLL_SEND) |
|---|
| | | public void rollSendMsg(Long orderId) { |
|---|
| | | log.info("支付后生成我的课程或者我的民宿卷:{}", orderId); |
|---|
| | | try { |
|---|
| | | agentService.rollSendMsg(orderId); |
|---|
| | | } catch (Exception e) { |
|---|
| | | log.error("支付后生成我的课程或者我的民宿卷:", e); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
