团队消息

yujian

2020-04-15 c6b718c3cadf5e5fff4c2a47fd1247842439f8c7

 fanli/src/main/java/com/yeshi/fanli/util/rocketmq/consumer/order/InviteOrderSubsidyMessageListener.java

@@ -14,9 +14,12 @@
import com.google.gson.Gson;

import com.yeshi.fanli.dto.mq.order.OrderTopicTagEnum;

import com.yeshi.fanli.dto.mq.order.body.OrderMQMsg;

import com.yeshi.fanli.dto.mq.order.body.TeamRewardPreRecieveMQMsg;

import com.yeshi.fanli.exception.ParamsException;

import com.yeshi.fanli.exception.money.OrderMoneySettleException;

import com.yeshi.fanli.exception.money.TeamEincomeRecordException;

import com.yeshi.fanli.exception.order.CommonOrderException;

import com.yeshi.fanli.exception.order.InviteOrderSubsidyException;

import com.yeshi.fanli.exception.order.OrderTeamRewardException;

import com.yeshi.fanli.log.LogHelper;

import com.yeshi.fanli.service.inter.mq.MQUnSendInfoService;

import com.yeshi.fanli.service.inter.order.CommonOrderService;

@@ -80,9 +83,6 @@
                  } catch (InviteOrderSubsidyException e) {

                     e.printStackTrace();

                     LogHelper.errorDetailInfo(e, new Gson().toJson(dto), "");

                  } catch (OrderTeamRewardException e) {

                     e.printStackTrace();

                     LogHelper.errorDetailInfo(e, new Gson().toJson(dto), "");

                  } catch (CommonOrderException e) {

                     e.printStackTrace();

                     LogHelper.errorDetailInfo(e, new Gson().toJson(dto), "");

@@ -97,6 +97,21 @@
                  }

               }

            }

         } else if (tag.equalsIgnoreCase(OrderTopicTagEnum.teamRewardPreRecieved.name())) {// 团队奖金预到账

            TeamRewardPreRecieveMQMsg dto = new Gson().fromJson(new String(message.getBody()),

                  TeamRewardPreRecieveMQMsg.class);

            try {

               teamSubsidyManager.addToTeamEincome(dto.getUid(), message.getKey(), dto.getPreGetTime());

               return Action.CommitMessage;

            } catch (OrderMoneySettleException e) {

               e.printStackTrace();

            } catch (TeamEincomeRecordException e) {

               e.printStackTrace();

            } catch (ParamsException e) {

               e.printStackTrace();

            }



            return Action.ReconsumeLater;

         }

      }

      return Action.CommitMessage;