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