券退回消息处理

admin

2019-11-12 0cf8c0bf5649b0b7269f78f6eae7c09cffea75cd

 fanli/src/main/java/com/yeshi/fanli/util/rocketmq/consumer/coupon/SystemCouponMessageListener.java

@@ -12,6 +12,8 @@
import com.yeshi.fanli.dto.mq.BaseMQMsgBody;

import com.yeshi.fanli.dto.mq.order.OrderTopicTagEnum;

import com.yeshi.fanli.dto.mq.order.body.OrderMoneyRecievedMQMsg;

import com.yeshi.fanli.dto.mq.user.UserTopicTagEnum;

import com.yeshi.fanli.dto.mq.user.body.UserSystemCouponUseMQMsg;

import com.yeshi.fanli.log.LogHelper;

import com.yeshi.fanli.service.inter.user.UserSystemCouponService;

import com.yeshi.fanli.util.Constant;

@@ -51,6 +53,13 @@
               }

            }

         }

      } else if (MQTopicName.TOPIC_USER.name().equalsIgnoreCase(message.getTopic())) {

         if (UserTopicTagEnum.systemCouponDrawback.name().equalsIgnoreCase(tag)) {// 券退回

            UserSystemCouponUseMQMsg userSystemCouponUseMQMsg = new Gson().fromJson(new String(message.getBody()),

                  UserSystemCouponUseMQMsg.class);

            //TODO处理券退回

				
         }

      }

      return Action.CommitMessage;

   }