| | |
|---|
| | | 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())) {// 返利到账
|
|---|
| | | OrderMoneyRecievedMQMsg orderMoneyRecievedMQMsg = new Gson().fromJson(new String(message.getBody()),
|
|---|
| | | OrderMoneyRecievedMQMsg.class);
|
|---|
| | | // 分享订单奖励
|
|---|
| | | if (orderMoneyRecievedMQMsg.getType() == OrderMoneyRecievedMQMsg.TYPE_SHARE) {
|
|---|
| | | try {// 上级分享订单奖励
|
|---|
| | | redPackWinInviteService.orderArriveReward(orderMoneyRecievedMQMsg.getUid(),
|
|---|
| | | orderMoneyRecievedMQMsg.getSourceType(), orderMoneyRecievedMQMsg.getOrderId());
|
|---|
| | | } catch (Exception e) {
|
|---|
| | | e.printStackTrace();
|
|---|
| | | }
|
|---|
| | | // try {
|
|---|
| | | // redPackWinInviteService.orderArriveReward(orderMoneyRecievedMQMsg.getUid(),
|
|---|
| | | // orderMoneyRecievedMQMsg.getSourceType(), orderMoneyRecievedMQMsg.getOrderId());
|
|---|
| | | // } catch (Exception e) {
|
|---|
| | | // e.printStackTrace();
|
|---|
| | | // }
|
|---|
| | | }
|
|---|
| | | } else if (tag.equalsIgnoreCase(OrderTopicTagEnum.orderStatistic.name())) {// 订单统计
|
|---|
| | | OrderMQMsg orderMQMsg = new Gson().fromJson(new String(message.getBody()), OrderMQMsg.class);
|
|---|
| | |
|---|
| | |
|
|---|
| | | if (inviteSucceedReward) {
|
|---|
| | | try {// 邀请奖励
|
|---|
| | | redPackWinInviteService.inviteSucceedReward(uid);
|
|---|
| | | if(uid==6269748)
|
|---|
| | | {
|
|---|
| | | System.out.println(uid);
|
|---|
| | | }
|
|---|
| | | // redPackWinInviteService.inviteSucceedReward(uid);
|
|---|
| | | } catch (Exception e) {
|
|---|
| | | e.printStackTrace();
|
|---|
| | | }
|
|---|
