fanli-server.git

			@@ -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;

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;
			}

			}

			@@ -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());
			@@ -95,6 +93,8 @@
			IntegralTaskMQMsg.class);
			inviteSucceedReward = true;
			uid = integralTaskMQMsg.getUid();
			} else if (tag.equalsIgnoreCase(UserTopicTagEnum.redPackGift.name())) {// 红包赠送
			// TODO 红包赠送到期未领取
			}

			if (inviteSucceedReward ) {

	fanli/src/main/java/com/yeshi/fanli/dto/mq/user/UserTopicTagEnum.java	6 ●●●●● 补丁 \| 查看 \| 原始文档 \| blame \| 历史
	fanli/src/main/java/com/yeshi/fanli/dto/mq/user/body/UserRedPackGiftMQMsg.java	25 ●●●●● 补丁 \| 查看 \| 原始文档 \| blame \| 历史
	fanli/src/main/java/com/yeshi/fanli/util/rocketmq/consumer/redpack/RedPackMessageListener.java	6 ●●●●● 补丁 \| 查看 \| 原始文档 \| blame \| 历史