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;