| | |
|---|
| | | String tag = message.getTag();
|
|---|
| | | if (tag == null)
|
|---|
| | | tag = "";
|
|---|
| | | BaseMQMsgBody baseBody = new Gson().fromJson(new String(message.getBody()), BaseMQMsgBody.class);
|
|---|
| | | if (baseBody.isTest() != Constant.IS_TEST)
|
|---|
| | | return Action.ReconsumeLater;
|
|---|
| | |
|
|---|
| | | if (MQTopicName.TOPIC_ORDER.name().equalsIgnoreCase(message.getTopic())) {
|
|---|
| | | if (tag.equalsIgnoreCase(OrderTopicTagEnum.orderFanLiActual.name())) {// 返利到账
|
|---|
| | |
|---|
| | |
|
|---|
| | | if (inviteSucceedReward) {
|
|---|
| | | try {// 邀请奖励
|
|---|
| | | if(uid==6269748)
|
|---|
| | | {
|
|---|
| | | System.out.println(uid);
|
|---|
| | | }
|
|---|
| | | redPackWinInviteService.inviteSucceedReward(uid);
|
|---|
| | | } catch (Exception e) {
|
|---|
| | | e.printStackTrace();
|
|---|
