Merge remote-tracking branch 'origin/div' into div

admin

2020-04-13 dd5b15229cb15459fa7c31ccea77dac28cbfafbd

 fanli/src/main/java/com/yeshi/fanli/service/impl/order/InviteOrderSubsidyServiceImplV2.java

@@ -4,11 +4,9 @@
import java.util.ArrayList;

import java.util.Calendar;

import java.util.Date;

import java.util.HashSet;

import java.util.Iterator;

import java.util.List;

import java.util.Map;

import java.util.Set;

import java.util.concurrent.ConcurrentHashMap;



import javax.annotation.Resource;

@@ -18,23 +16,19 @@


import com.yeshi.fanli.dao.mybatis.order.InviteOrderSubsidyMapper;

import com.yeshi.fanli.entity.bus.user.HongBaoV2;

import com.yeshi.fanli.entity.bus.user.ThreeSale;

import com.yeshi.fanli.entity.bus.user.UserInfo;

import com.yeshi.fanli.entity.bus.user.vip.UserLevelEnum;

import com.yeshi.fanli.entity.order.CommonOrder;

import com.yeshi.fanli.entity.order.HongBaoOrder;

import com.yeshi.fanli.entity.order.InviteOrderSubsidy;

import com.yeshi.fanli.entity.order.OrderTeamReward;

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.service.inter.order.CommonOrderService;

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

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

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

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

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

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

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

import com.yeshi.fanli.service.inter.order.config.HongBaoManageService;

import com.yeshi.fanli.service.inter.user.invite.ThreeSaleSerivce;

import com.yeshi.fanli.service.inter.user.vip.UserVIPInfoService;

@@ -43,7 +37,7 @@
import com.yeshi.fanli.util.TimeUtil;



@Service

public class InviteOrderSubsidyServiceImplV2 implements InviteOrderSubsidyServiceV2 {

public class InviteOrderSubsidyServiceImplV2 implements InviteOrderSubsidyService {



   @Resource

   private InviteOrderSubsidyMapper inviteOrderSubsidyMapper;

@@ -73,9 +67,6 @@
   private OrderHongBaoMoneyComputeService orderHongBaoMoneyComputeService;



   @Resource

   private OrderTeamRewardService orderTeamRewardService;



   @Resource

   private ThreeSaleSerivce threeSaleSerivce;



   @Override

@@ -86,6 +77,11 @@
   @Override

   public InviteOrderSubsidy getByOrderNoAndTypeForUpdate(Long uid, String orderNo, Integer type) {

      return inviteOrderSubsidyMapper.getByOrderNoAndTypeForUpdate(uid, orderNo, type);

   }



   @Override

   public List<InviteOrderSubsidy> listByOrderNoAndType(String orderNo, Integer type) {

      return inviteOrderSubsidyMapper.listByOrderNoAndType(orderNo, type);

   }



   @Transactional(rollbackFor = Exception.class)

@@ -110,77 +106,10 @@
         update.setState(orderSubsidy.getState());

         update.setUpdateTime(new Date());

         inviteOrderSubsidyMapper.updateByPrimaryKeySelective(update);

         // 添加奖励

         addTeamReward(old.getId());

      } else {// 添加

         if (orderSubsidy.getCreateTime() == null)

            orderSubsidy.setCreateTime(new Date());

         inviteOrderSubsidyMapper.insertSelective(orderSubsidy);

         // 添加奖励

         addTeamReward(orderSubsidy.getId());

      }

   }



   // 添加团队奖励

   private void addTeamReward(Long subsidyId) throws OrderTeamRewardException, CommonOrderException {

      // 查询团队奖励的人

      // 计算相应的比例

      InviteOrderSubsidy subsidy = inviteOrderSubsidyMapper.selectByPrimaryKeyForUpdate(subsidyId);

      if (subsidy == null)

         throw new OrderTeamRewardException(20, "补贴不存在");



      // 获取上4级用户

      List<CommonOrder> commonOrderList = commonOrderService.listBySourceTypeAndOrderId(subsidy.getSourceType(),

            subsidy.getOrderNo());

      if (commonOrderList == null || commonOrderList.size() == 0) {

         throw new CommonOrderException(1, "订单不存在");

      }



      Long sourceUid = commonOrderList.get(0).getUserInfo().getId();



      List<ThreeSale> bossList = threeSaleSerivce.getMyBossDeepList(sourceUid, 4);

      // 无需要团队奖励的上级

      if (bossList.size() < 3)

         return;



      Set<Long> rewardUid = new HashSet<>();

      for (int i = 2; i < bossList.size(); i++) {

         rewardUid.add(bossList.get(i).getBoss().getId());

      }

      // 删除本补贴用户的下级

      for (int i = 0; i < bossList.size(); i++) {

         if (bossList.get(i).getBoss().getId().longValue() == subsidy.getUid()) {

            break;

         } else {

            bossList.remove(i);

            i--;

         }

      }



      // 获取补贴用户的直接上级

      if (bossList.size() > 1 && bossList.get(1).getSucceedTime() < subsidy.getCreateTime().getTime()) {

         UserInfo boss = bossList.get(1).getBoss();

         UserLevelEnum userLevel = userLevelManager.getUserLevel(boss.getId());

         BigDecimal rewardMoney = orderHongBaoMoneyComputeService.computeFirstTeamReward(subsidy.getMoney(),

               subsidy.getCreateTime(), userLevel);



         if (rewardMoney != null) {

            // 添加奖励

            orderTeamRewardService.addOrUpdate(subsidy, rewardMoney, boss.getId(), OrderTeamReward.LEVEL_ONE);

         }



         // 获取补贴的间接上级

         if (bossList.size() > 2 && bossList.get(2).getSucceedTime() < subsidy.getCreateTime().getTime()) {

            boss = bossList.get(2).getBoss();

            userLevel = userLevelManager.getUserLevel(boss.getId());

            rewardMoney = orderHongBaoMoneyComputeService.computeSecondTeamReward(subsidy.getMoney(),

                  subsidy.getCreateTime(), userLevel);

            if (rewardMoney != null) {

               // 添加奖励

               orderTeamRewardService.addOrUpdate(subsidy, rewardMoney, boss.getId(), OrderTeamReward.LEVEL_TWO);

            }

         }



      }

   }



@@ -191,7 +120,8 @@
      if (list != null && list.size() > 0) {

         // 必须是自购订单才返利

         HongBaoV2 parent = hongBaoV2Service.selectByPrimaryKey(list.get(0).getHongBaoV2().getId());

         if (parent != null && parent.getUrank() != UserLevelEnum.superVIP.getOrderRank()) {// 不是超级会员的自购/分享才补贴

         if (parent != null

               && (parent.getType() == HongBaoV2.TYPE_SHARE_GOODS || parent.getType() == HongBaoV2.TYPE_ZIGOU)) {// 不是超级会员的自购/分享才补贴



            List<CommonOrder> orderList = commonOrderService.listBySourceTypeAndOrderId(sourceType, orderId);

            if (orderList == null || orderList.size() == 0)

@@ -224,18 +154,7 @@
               }



               List<HongBaoV2> hbList = hongBaoV2Service.listByIds(idList);

               int state = InviteOrderSubsidy.STATE_UNKNOWN;

               // 确定是否使用了奖励券

               if (orderHongBaoMapService.selectByOrderIdAndSourceType(orderId, sourceType) != null) {

                  state = InviteOrderSubsidy.STATE_INVALID;

               } else {

                  // 确定是否返利到账5天后

                  if (recieveMoneyMoreThan(hbList, 5)) {

                     state = InviteOrderSubsidy.STATE_VALID;

                  } else {

                     state = InviteOrderSubsidy.STATE_UNKNOWN;

                  }

               }

               Integer state = null;



               // 产生改订单的返利总金额

               BigDecimal totalBuyFanLiMoney = new BigDecimal(0);

@@ -244,22 +163,33 @@
                  if (v2.getState() == HongBaoV2.STATE_BUKELINGQU || v2.getState() == HongBaoV2.STATE_KELINGQU

                        || v2.getState() == HongBaoV2.STATE_YILINGQU)

                     totalBuyFanLiMoney = totalBuyFanLiMoney.add(v2.getMoney());



                  if (state == null && (v2.getState() == HongBaoV2.STATE_KELINGQU

                        || v2.getState() == HongBaoV2.STATE_YILINGQU)) {// 红包状态为已领取或者是待领取，则设置为补贴有效

                     state = InviteOrderSubsidy.STATE_VALID;

                  }

               }



               if (state == null)

                  state = InviteOrderSubsidy.STATE_UNKNOWN;

               // 计算奖励金

               for (Iterator<Long> its = uidHongBaoMap.keySet().iterator(); its.hasNext();) {

                  Long uid = its.next();

                  UserLevelEnum userLevel = userLevelManager.getUserLevel(uid);

                  UserLevelEnum userLevel = userLevelManager.getUserLevel(uid, placeOrderTime);



                  int type = uidHongBaoMap.get(uid);

                  if (type == HongBaoV2.TYPE_YIJI || type == HongBaoV2.TYPE_ERJI) {

                  if (type == HongBaoV2.TYPE_YIJI || type == HongBaoV2.TYPE_ERJI

                        || type == HongBaoV2.TYPE_SHARE_YIJI || type == HongBaoV2.TYPE_SHARE_ERJI) {

                     BigDecimal money = null;

                     if (type == HongBaoV2.TYPE_YIJI)

                     if (type == HongBaoV2.TYPE_YIJI || type == HongBaoV2.TYPE_SHARE_YIJI)

                        money = orderHongBaoMoneyComputeService.computeFirstTeamSubsidy(totalBuyFanLiMoney,

                              placeOrderTime, buyerUserLevel, userLevel);

                     else

                        money = orderHongBaoMoneyComputeService.computeSecondTeamSubsidy(totalBuyFanLiMoney,

                              placeOrderTime, buyerUserLevel, userLevel);



                     if (money == null)

                        continue;



                     InviteOrderSubsidy orderSubsidy = new InviteOrderSubsidy();

                     orderSubsidy.setMoney(money);

@@ -268,48 +198,24 @@
                     orderSubsidy.setOrderNo(orderId);

                     orderSubsidy.setSourceType(sourceType);

                     orderSubsidy.setState(state);

                     if (type == HongBaoV2.TYPE_YIJI)

                     if (type == HongBaoV2.TYPE_YIJI || type == HongBaoV2.TYPE_SHARE_YIJI)

                        orderSubsidy.setLevel(InviteOrderSubsidy.LEVEL_ONE);

                     else

                        orderSubsidy.setLevel(InviteOrderSubsidy.LEVEL_TWO);

                     // 会员才能补贴

                     if (userLevel != UserLevelEnum.daRen)

                        try {

                           addOrderSubsidy(orderSubsidy);

                        } catch (OrderTeamRewardException e) {

                           throw new InviteOrderSubsidyException(e.getCode(), e.getMsg());

                        } catch (CommonOrderException e) {

                           throw new InviteOrderSubsidyException(e.getCode(), e.getMsg());

                        }



                     try {

                        addOrderSubsidy(orderSubsidy);

                     } catch (OrderTeamRewardException e) {

                        throw new InviteOrderSubsidyException(e.getCode(), e.getMsg());

                     } catch (CommonOrderException e) {

                        throw new InviteOrderSubsidyException(e.getCode(), e.getMsg());

                     }

                  }

               }

            }

         }

      }



   }



   private boolean recieveMoneyMoreThan(List<HongBaoV2> hbList, int day) {

      // 是否全部是到账状态或失效状态

      int invalidCount = 0;// 失效个数

      int recieveCount = 0;// 到账的个数

      long maxGetTime = 0;

      for (HongBaoV2 v2 : hbList) {

         if (v2.getState() == HongBaoV2.STATE_SHIXIAO)

            invalidCount++;

         else if (v2.getState() == HongBaoV2.STATE_YILINGQU) {

            recieveCount++;

            if (v2.getGetTime() != null && v2.getGetTime().getTime() > maxGetTime)

               maxGetTime = v2.getGetTime().getTime();



         }

      }

      if (invalidCount + recieveCount == hbList.size() && recieveCount > 0 && maxGetTime > 0) {// 全部已到账

         // 查询到账时间距离当前时间是否超过指定天

         if (System.currentTimeMillis() - maxGetTime > 1000 * 60 * 60 * 24L * day)

            return true;

      }

      return false;

   }



   @Override

@@ -328,8 +234,8 @@
               InviteOrderSubsidy update = new InviteOrderSubsidy(subsidy.getId());

               update.setState(InviteOrderSubsidy.STATE_INVALID);

               update.setUpdateTime(new Date());

               update.setInValidTime(new Date());

               inviteOrderSubsidyMapper.updateByPrimaryKeySelective(update);

               orderTeamRewardService.invalidByOrderIdAndSourceType(subsidy.getId());

            }

         }

   }

@@ -359,9 +265,9 @@
               InviteOrderSubsidy update = new InviteOrderSubsidy(subsidy.getId());

               update.setState(InviteOrderSubsidy.STATE_VALID);

               update.setUpdateTime(new Date());

               update.setValidTime(new Date());

               update.setPreGetTime(preGetTime);

               inviteOrderSubsidyMapper.updateByPrimaryKeySelective(update);

               orderTeamRewardService.validByOrderIdAndSourceType(subsidy.getId(), preGetTime);

            }

         }

   }

@@ -375,4 +281,31 @@
      inviteOrderSubsidyMapper.updateByPrimaryKeySelective(orderSubsidy);

   }



   @Override

   public BigDecimal sumRecievedMoneyByUid(long uid, Integer level) {

      BigDecimal money = inviteOrderSubsidyMapper.sumRecievedMoneyByUid(uid, level);

      if (money == null) {

         money = new BigDecimal(0);

      }

      return money;

   }



   @Override

   public BigDecimal sumValidMoneyByUidAndDate(long uid, Integer day, Integer level) {

      BigDecimal money = inviteOrderSubsidyMapper.sumValidMoneyByUidAndDate(uid, day, level);

      if (money == null) {

         money = new BigDecimal(0);

      }

      return money;

   }



   @Override

   public BigDecimal sumMoneyByUidAndDateAndState(long uid, Integer day, Integer level, Integer state) {

      BigDecimal money = inviteOrderSubsidyMapper.sumMoneyByUidAndDateAndState(uid, day, level, state);

      if (money == null) {

         money = new BigDecimal(0);

      }

      return money;

   }



}