| | |
|---|
| | | import com.yeshi.fanli.entity.bus.user.HongBaoV2;
|
|---|
| | | import com.yeshi.fanli.entity.order.HongBaoOrder;
|
|---|
| | | import com.yeshi.fanli.entity.order.HongBaoV2SettleTemp;
|
|---|
| | | import com.yeshi.fanli.log.LogHelper;
|
|---|
| | | import com.yeshi.fanli.service.inter.hongbao.HongBaoV2SettleTempService;
|
|---|
| | | import com.yeshi.fanli.service.inter.order.HongBaoOrderService;
|
|---|
| | | import com.yeshi.fanli.service.inter.order.HongBaoV2Service;
|
|---|
| | |
|---|
| | |
|
|---|
| | | @Override
|
|---|
| | | public Action consume(Message message, ConsumeContext context) {
|
|---|
| | | LogHelper.mqInfo("consumer:OrderMoneyRecievedMessageListener", message.getMsgID(), message.getTopic(),
|
|---|
| | | message.getTag(), new String(message.getBody()));
|
|---|
| | | // 根据红包做订单分发
|
|---|
| | | if (MQTopicName.TOPIC_ORDER.name().equalsIgnoreCase(message.getTopic())) {
|
|---|
| | | if (OrderTopicTagEnum.orderFanLiActual.name().equalsIgnoreCase(message.getTag())) {
|
|---|
