红包退回消息添加

admin

2019-11-12 e107632bfdd8a887c7c6d50a1879319a931ec70a

红包退回消息添加

 fanli/src/main/java/com/yeshi/fanli/dto/mq/user/UserTopicTagEnum.java

@@ -3,6 +3,7 @@
import com.yeshi.fanli.dto.mq.user.body.IntegralTaskMQMsg;

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

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

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

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

import com.yeshi.fanli.util.annotation.UserActive;



@@ -12,9 +13,10 @@
    useSystemCoupon(UserActive.class), // 系统券使用

    inviteSuccess(UserInviteMQMsg.class), // 邀请成功

    integralTaskFinish(IntegralTaskMQMsg.class), // 完成金币任务

    userRegister(UserRegisterMQMsg.class);// 用户注册

	
	
    userRegister(UserRegisterMQMsg.class),

    redPackGift(UserRedPackGiftMQMsg.class);//红包赠送



    // 用户注册



    private final Class<?> clazz;




 fanli/src/main/java/com/yeshi/fanli/dto/mq/user/body/UserRedPackGiftMQMsg.java

New file
@@ -0,0 +1,25 @@
package com.yeshi.fanli.dto.mq.user.body;



import com.yeshi.fanli.dto.mq.BaseMQMsgBody;



public class UserRedPackGiftMQMsg extends BaseMQMsgBody {

    private Long id;// 红包ID

    private Long uid;// 用户ID



    public Long getId() {

        return id;

    }



    public void setId(Long id) {

        this.id = id;

    }



    public Long getUid() {

        return uid;

    }



    public void setUid(Long uid) {

        this.uid = uid;

    }



}


 fanli/src/main/java/com/yeshi/fanli/util/rocketmq/consumer/redpack/RedPackMessageListener.java

@@ -34,13 +34,13 @@


    @Resource

    private UserSystemCouponService userSystemCouponService;

	


    @Resource

    private RedPackWinInviteService redPackWinInviteService;



    @Override

    public Action consume(Message message, ConsumeContext context) {

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

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

                new String(message.getBody()));

        String tag = message.getTag();

        if (tag == null)

@@ -49,7 +49,6 @@
        if (baseBody.isTest() != Constant.IS_TEST)

            return Action.ReconsumeLater;



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

            if (tag.equalsIgnoreCase(OrderTopicTagEnum.orderFanLiActual.name())) {// 返利到账

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

@@ -63,8 +62,7 @@
                    }

                }

            } else if (tag.equalsIgnoreCase(OrderTopicTagEnum.orderStatistic.name())) {// 订单统计

                OrderMQMsg orderMQMsg = new Gson().fromJson(new String(message.getBody()),

                        OrderMQMsg.class);

                OrderMQMsg orderMQMsg = new Gson().fromJson(new String(message.getBody()), OrderMQMsg.class);

                if (orderMQMsg.isValid()) {

                    try {// 邀请奖励

                        redPackWinInviteService.inviteSucceedReward(orderMQMsg.getUid());

@@ -73,7 +71,7 @@
                    }

                }

            }

			


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

            boolean inviteSucceedReward = false;

            Long uid = null;

@@ -95,16 +93,18 @@
                        IntegralTaskMQMsg.class);

                inviteSucceedReward = true;

                uid = integralTaskMQMsg.getUid();

            } else if (tag.equalsIgnoreCase(UserTopicTagEnum.redPackGift.name())) {// 红包赠送

                // TODO 红包赠送到期未领取

            }

			
            if (inviteSucceedReward ) {



            if (inviteSucceedReward) {

                try {// 邀请奖励

                    redPackWinInviteService.inviteSucceedReward(uid);

                } catch (Exception e) {

                    e.printStackTrace();

                }

            }

			


        }

        return Action.CommitMessage;

    }