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

admin

2020-04-13 dd5b15229cb15459fa7c31ccea77dac28cbfafbd

 fanli/src/main/java/com/yeshi/fanli/service/manger/order/TeamDividentsManager.java

@@ -16,25 +16,31 @@
import com.yeshi.fanli.entity.bus.user.ThreeSale;

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

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

import com.yeshi.fanli.entity.money.UserMoneyDetail;

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

import com.yeshi.fanli.entity.order.dividents.TeamDividentsDebt;

import com.yeshi.fanli.entity.order.dividents.TeamDividentsRecord;

import com.yeshi.fanli.entity.order.dividents.TeamDividentsSourceOrder;

import com.yeshi.fanli.entity.order.dividents.TeamDividentsSourceUser;

import com.yeshi.fanli.exception.ParamsException;

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

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

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

import com.yeshi.fanli.exception.order.dividents.TeamDividentsRecordException;

import com.yeshi.fanli.exception.order.dividents.TeamDividentsSourceOrderException;

import com.yeshi.fanli.service.inter.money.TeamDividentsDebtService;

import com.yeshi.fanli.service.inter.money.UserMoneyService;

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

import com.yeshi.fanli.service.inter.order.dividents.TeamDividentsRecordService;

import com.yeshi.fanli.service.inter.order.dividents.TeamDividentsSourceOrderService;

import com.yeshi.fanli.service.inter.order.dividents.TeamDividentsSourceUserService;

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

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

import com.yeshi.fanli.service.manger.money.TeamEincomeManager;

import com.yeshi.fanli.util.Constant;

import com.yeshi.fanli.util.MoneyBigDecimalUtil;

import com.yeshi.fanli.util.TimeUtil;

import com.yeshi.fanli.util.factory.UserMoneyDetailFactory;

import com.yeshi.fanli.util.factory.order.dividents.TeamDividentsSourceOrderFactory;

import com.yeshi.fanli.util.user.UserLevelUtil;



/**

 * 团队分红管理

@@ -65,6 +71,28 @@
   @Resource

   private UserMoneyService userMoneyService;



   @Resource

   private HongBaoManageService hongBaoManageService;



   @Resource

   private TeamEincomeManager teamEincomeManager;



   @Transactional(rollbackFor = Exception.class)

   public void addDividentsSourceOrder(List<CommonOrder> commonOrderList) throws TeamDividentsSourceOrderException {

      UserLevelEnum level = UserLevelUtil.getByOrderRank(commonOrderList.get(0).getUrank());

      if (level == null)

         level = UserLevelEnum.daRen;

      BigDecimal rate = getSourceOrderDividentsRate(level);

      TeamDividentsSourceOrder order = TeamDividentsSourceOrderFactory.create(commonOrderList, rate);

      try {

         teamDividentsSourceOrderService.addTeamDividentsSourceOrder(order);

      } catch (TeamDividentsSourceOrderException e) {

         e.printStackTrace();

      } catch (ParamsException e) {

         e.printStackTrace();

      }

   }



   /**

    *  开始分红

    * @Title: startDividents

@@ -77,6 +105,44 @@
   public void startDividents(Long sourceUid) throws ParamsException {

      String day = TimeUtil.getGernalTime(System.currentTimeMillis(), "yyyy-MM-dd");

      Date preSendTime = new Date(TimeUtil.convertToTimeTemp(day, "yyyy-MM-dd"));

      startDividents(sourceUid, preSendTime);

   }



   // 是否可以分红

   private boolean isCanDividents(TeamUserLevelStatistic tus) {

      if (Constant.IS_TEST)

         return true;



      if (tus != null && (tus.getLevel() == UserLevelEnum.highVIP || tus.getLevel() == UserLevelEnum.superVIP

            || tus.getLevel() == UserLevelEnum.tearcher)) {

         if (tus.getLevel() == UserLevelEnum.highVIP) {

            int vipFirstCount = tus.getNormalFirstCount() + tus.getHighFirstCount() + tus.getSuperFirstCount()

                  + tus.getTearcherFirstCount();

            if (vipFirstCount >= 3)// 直接粉丝普通会员等级以上的用户>=3

               return true;

         } else if (tus.getLevel() == UserLevelEnum.superVIP) {

            int firstCount = tus.getSuperFirstCount() + tus.getTearcherFirstCount();

            int secondCount = tus.getNormalSecondCount() + tus.getHighSecondCount() + tus.getSuperSecondCount()

                  + tus.getTearcherSecondCount();

            if (firstCount >= 3 && secondCount >= 3) {// 直接粉丝超级会员等级以上的用户>=3

                                             // 间接粉丝普通会员以上等级>=3

               return true;

            }

         } else {

            int firstCount = tus.getSuperFirstCount() + tus.getTearcherFirstCount();

            int secondCount = tus.getHighSecondCount() + tus.getSuperSecondCount() + tus.getTearcherSecondCount();

            if (firstCount >= 3 && secondCount >= 3) {// 直接粉丝超级会员等级以上的用户>=3

                                             // 间接粉丝高级会员以上等级>=3

               return true;

            }

         }

      }

      return false;

   }



   @Transactional(rollbackFor = Exception.class)

   public void startDividents(Long sourceUid, Date preSendTime) throws ParamsException {

      String day = TimeUtil.getGernalTime(preSendTime.getTime(), "yyyy-MM-dd");

      // 查询出可用于分红的用户的总金额

      long count = teamDividentsSourceOrderService.countCanSendByUidAndPreSendTime(sourceUid, preSendTime);

      int pageSize = 1000;

@@ -100,15 +166,24 @@
         }

      }



      // 分红金额为0的不参与

      if (totalMoney.compareTo(new BigDecimal(0)) <= 0)

         return;



      // 查询出可以参与分红的用户

      List<ThreeSale> threeSalesList = threeSaleSerivce.getMyBossDeepList(sourceUid);

      if (threeSalesList == null)

         return;



      Map<Long, UserLevelEnum> uidLevel = new HashMap<Long, UserLevelEnum>();

      for (ThreeSale ts : threeSalesList) {

         if (ts.getBoss() != null) {

            TeamUserLevelStatistic tus = teamUserLevelStatisticService.selectByUid(ts.getBoss().getId());

            if (tus != null

                  && (tus.getLevel() == UserLevelEnum.highVIP || tus.getLevel() == UserLevelEnum.superVIP)) {

               // TODO 需要判断团队的超级会员与高级会员

            if (tus == null)

               teamUserLevelStatisticService.initData(ts.getBoss().getId());

            tus = teamUserLevelStatisticService.selectByUid(ts.getBoss().getId());



            if (isCanDividents(tus)) {

               uidLevel.put(tus.getId(), tus.getLevel());

            }

         }

@@ -126,6 +201,8 @@
         teamDividentsSourceUser.setTargetUid(uid);

         teamDividentsSourceUserService.addTeamDividentsSourceUser(teamDividentsSourceUser);

      }

      // if (1 / 0 > 0)

      // return;

   }



   // 计算平均分红

@@ -146,6 +223,8 @@
      if (userLevel == UserLevelEnum.highVIP) {

         return perDivident;

      } else if (userLevel == UserLevelEnum.superVIP) {

         return MoneyBigDecimalUtil.mul(perDivident, new BigDecimal(2));

      } else if (userLevel == UserLevelEnum.tearcher) {

         return MoneyBigDecimalUtil.mul(perDivident, new BigDecimal(2));

      }

      return null;

@@ -177,11 +256,12 @@
    * @throws

    */

   @Transactional(rollbackFor = Exception.class)

   public void addDividents(Long uid, String day)

         throws TeamDividentsRecordException, TeamDividentsDebtException, UserMoneyDetailException, ParamsException {

   public void addToTeamEincome(Long uid, String day) throws TeamDividentsRecordException, TeamDividentsDebtException,

         UserMoneyDetailException, ParamsException, TeamEincomeRecordException {

      Date preSendTime = new Date(TimeUtil.convertToTimeTemp(day, "yyyy-MM-dd"));

      BigDecimal money = teamDividentsSourceUserService.sumMoneyByUidAndDay(uid, day);

      // 查询需要扣除的资金

      List<TeamDividentsDebt> list = teamDividentsDebtService.listNeedRepayDebt(uid, 1, 1000);

      List<TeamDividentsDebt> list = teamDividentsDebtService.listNeedRepayDebt(uid, preSendTime, 1, 1000);

      for (TeamDividentsDebt debt : list) {

         if (money.subtract(debt.getLeftMoney()).compareTo(new BigDecimal(0)) >= 0) {// 还有钱还

            money = money.subtract(debt.getLeftMoney());

@@ -201,12 +281,11 @@
      record.setUid(uid);

      teamDividentsRecordService.addTeamDividentsRecord(record);



      UserMoneyDetail detail = UserMoneyDetailFactory.createOrderTeamDividents(uid, money, new Date());

      // 增加资金

      userMoneyService.addUserMoney(uid, money, detail);

      // 有分红才显示资金明细

      if (money.compareTo(new BigDecimal(0)) > 0) {



      // TODO 加入通知



         teamEincomeManager.addTeamDividents(uid, preSendTime, money);

      }

   }



   /**

@@ -234,6 +313,9 @@
         BigDecimal money = sourceOrder.getMoney();

         // 查询参与这一单分红的人

         String day = TimeUtil.getGernalTime(sourceOrder.getSendTime().getTime(), "yyyy-MM-dd");

         if (Constant.IS_TEST)

            day = TimeUtil.getGernalTime(sourceOrder.getPreSendTime().getTime(), "yyyy-MM-dd");



         List<TeamDividentsSourceUser> list = teamDividentsSourceUserService

               .listBySourceUidAndDay(sourceOrder.getUid(), day);

         // 计算每个人的比例

@@ -260,4 +342,18 @@


   }



   /**

    * 获取源订单需要参与分红的比例

    * @Title: getSourceOrderDividentsRate

    * @Description: 
    * @param level

    * @return 
    * BigDecimal 返回类型

    * @throws

    */

   public BigDecimal getSourceOrderDividentsRate(UserLevelEnum level) {

      String rate = hongBaoManageService.get("team_source_order_dividents_" + level.getLevel());

      return new BigDecimal(rate);

   }



}