fanli-server.git

			@@ -13,6 +13,7 @@

			import javax.annotation.Resource;

			import com.yeshi.fanli.util.mq.rabbit.RabbitmqManager;
			import org.slf4j.Logger;
			import org.slf4j.LoggerFactory;
			import org.springframework.stereotype.Service;
			@@ -114,6 +115,9 @@

			@Resource
			private RocketMQManager rocketMQManager;

			@Resource
			private HongBaoRecieveCMQManager hongBaoRecieveCMQManager;

			// 下级被封禁，红包失效
			private void invalidHongBaoForbidden(HongBaoV2 hongBaoV2) throws TeamRewardDebtException {
			@@ -497,7 +501,7 @@
			hbIdList.add(v2.getId());
			accountDetailsHongBaoMapService.saveAccountDetailsHongBaoMap(v2.getId(), userMoneyDetail.getId());
			try {
			HongBaoRecieveCMQManager.getInstance().addHongBaoRecieveMsg(v2.getId());
			hongBaoRecieveCMQManager.addHongBaoRecieveMsg(v2.getId());
			} catch (Exception e) {
			LogHelper.errorDetailInfo(e);
			}
			@@ -601,7 +605,7 @@
			for (Long hongBaoId : hbIdList) {
			try {
			if (Constant.ENABLE_MQ)
			HongBaoRecieveCMQManager.getInstance().addHongBaoRecieveMsg(hongBaoId);
			hongBaoRecieveCMQManager.addHongBaoRecieveMsg(hongBaoId);
			} catch (Exception e) {
			LogHelper.errorDetailInfo(e);
			}
			@@ -690,7 +694,7 @@
			for (Long hongBaoId : recieveHongBaoIds) {
			try {
			if (Constant.ENABLE_MQ)
			HongBaoRecieveCMQManager.getInstance().addHongBaoRecieveMsg(hongBaoId);
			hongBaoRecieveCMQManager.addHongBaoRecieveMsg(hongBaoId);
			} catch (Exception e) {
			LogHelper.errorDetailInfo(e);
			}
			@@ -767,7 +771,7 @@
			for (Long hongBaoId : recieveHongBaoIds) {
			try {
			if (Constant.ENABLE_MQ)
			HongBaoRecieveCMQManager.getInstance().addHongBaoRecieveMsg(hongBaoId);
			hongBaoRecieveCMQManager.addHongBaoRecieveMsg(hongBaoId);
			} catch (Exception e) {
			LogHelper.errorDetailInfo(e);
			}