vip等级

yujian

2020-03-17 761422e416fcd7f8ac3b75a2b17f9c3977f3b787

vip等级

 fanli/src/main/java/com/yeshi/fanli/util/rocketmq/consumer/user/UserVIPMessageListener.java

@@ -24,45 +24,46 @@
 * @author Administrator

 *

 */

@Component

public class UserVIPMessageListener implements MessageListener {

//@Component implements MessageListener

public class UserVIPMessageListener  {



    @Resource

    private UserVIPPreInfoService userVIPPreInfoService;



    @Override

    public Action consume(Message message, ConsumeContext context) {

        LogHelper.mqInfo("consumer-UserVIPMessageListener", message.getMsgID(), message.getTopic(),

                message.getTag(), new String(message.getBody()));

        String tag = message.getTag();

        if (tag == null)

            tag = "";



        // 邀请相关

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

            // 邀请成功

            if (tag.equalsIgnoreCase(UserTopicTagEnum.inviteSuccess.name())) {

                UserInviteMQMsg msg = new Gson().fromJson(new String(message.getBody()),UserInviteMQMsg.class);

                // 会员等级升级

                userVIPPreInfoService.verifyVipPreInfo(msg.getBossId(), true);

            }

        }

		
        // 订单到账相关

        if (tag.equalsIgnoreCase(OrderTopicTagEnum.orderFanLiActual.name())) {

            OrderMoneyRecievedMQMsg dto = new Gson().fromJson(new String(message.getBody()),

                    OrderMoneyRecievedMQMsg.class);

            if (dto != null) {

                if (dto.getType() == OrderMoneyRecievedMQMsg.TYPE_ZIGOU) {// 自购到账

                    // 会员等级升级

                    userVIPPreInfoService.verifyVipPreInfo(dto.getUid(), false);

                } else if (dto.getType() == OrderMoneyRecievedMQMsg.TYPE_SHARE) {// 分享到账

                    // 会员等级升级

                    userVIPPreInfoService.verifyVipPreInfo(dto.getUid(), false);

                }

            }

        }

		
        return Action.CommitMessage;

    }

//    @Override

//    public Action consume(Message message, ConsumeContext context) {

//		
//        LogHelper.mqInfo("consumer-UserVIPMessageListener", message.getMsgID(), message.getTopic(),

//                message.getTag(), new String(message.getBody()));

//        String tag = message.getTag();

//        if (tag == null)

//            tag = "";

//

//        // 邀请相关

//        if (MQTopicName.TOPIC_USER.name().equalsIgnoreCase(message.getTopic())) {

//            // 邀请成功

//            if (tag.equalsIgnoreCase(UserTopicTagEnum.inviteSuccess.name())) {

//                UserInviteMQMsg msg = new Gson().fromJson(new String(message.getBody()),UserInviteMQMsg.class);

//                // 会员等级升级

//                userVIPPreInfoService.verifyVipPreInfo(msg.getBossId(), true);

//            }

//        }

//		
//        // 订单到账相关

//        if (tag.equalsIgnoreCase(OrderTopicTagEnum.orderFanLiActual.name())) {

//            OrderMoneyRecievedMQMsg dto = new Gson().fromJson(new String(message.getBody()),

//                    OrderMoneyRecievedMQMsg.class);

//            if (dto != null) {

//                if (dto.getType() == OrderMoneyRecievedMQMsg.TYPE_ZIGOU) {// 自购到账

//                    // 会员等级升级

//                    userVIPPreInfoService.verifyVipPreInfo(dto.getUid(), false);

//                } else if (dto.getType() == OrderMoneyRecievedMQMsg.TYPE_SHARE) {// 分享到账

//                    // 会员等级升级

//                    userVIPPreInfoService.verifyVipPreInfo(dto.getUid(), false);

//                }

//            }

//        }

//		
//        return Action.CommitMessage;

//    }

}