分红修改

admin

2020-04-17 fed386fafac07d40fa3f3627b8fcef13e2d2ec4f

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

@@ -14,15 +14,19 @@
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;

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

import com.yeshi.fanli.service.inter.user.UserSystemCouponRecordService;

import com.yeshi.fanli.service.manger.order.TeamSubsidyManager;

import com.yeshi.fanli.util.Constant;

import com.yeshi.fanli.util.TimeUtil;

import com.yeshi.fanli.util.rocketmq.MQTopicName;



@@ -51,10 +55,7 @@


   @Resource

   private CommonOrderService commonOrderService;



   // 团队奖励开始时间

   private static final long TEAM_REWARD_START_TIME = TimeUtil.convertToTimeTemp("2019-04-15", "yyyy-MM-dd");



	
   public InviteOrderSubsidyMessageListener() {



   }

@@ -73,14 +74,11 @@
            if (dto != null) {

               // 查询出订单创建时间

               Date orderTime = commonOrderService.getThirdCreateTime(dto.getOrderId(), dto.getType());

               if (orderTime.getTime() >= TEAM_REWARD_START_TIME) {

               if (orderTime.getTime() >= Constant.NEW_ORDER_FANLI_RULE_TIME) {

                  try {

                     teamSubsidyManager.addOrUpdateOrder(dto.getOrderId(), dto.getType());

                     return Action.CommitMessage;

                  } 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) {

@@ -97,6 +95,20 @@
                  }

               }

            }

         } 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;