品牌接口恢复

yujian

2019-11-05 09c716a16d02ddb06df2bc2af5e588128bc7fdb4

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

@@ -13,6 +13,7 @@


import javax.annotation.Resource;



import org.springframework.context.annotation.Lazy;

import org.springframework.stereotype.Service;

import org.springframework.transaction.annotation.Transactional;



@@ -107,6 +108,7 @@
   @Resource

   private UserExtraTaoBaoInfoService userExtraTaoBaoInfoService;



   @Lazy

   @Resource

   private UserSystemCouponService userSystemCouponService;



@@ -145,7 +147,7 @@


   @Transactional

   @Override

   public void addHongBao(List<CommonOrder> commonOrderList, int type) throws HongBaoException {

   public int addHongBao(List<CommonOrder> commonOrderList, int type) throws HongBaoException {

      Set<Integer> stateSet = new HashSet<>();// 订单状态Set

      if (commonOrderList != null && commonOrderList.size() > 0) {

         int orderType = commonOrderList.get(0).getSourceType();

@@ -153,6 +155,7 @@
         Map<Integer, HongBaoOrder> notificationMap = new HashMap<>();

         int goodsCount = 0;

         boolean hasAdd = false;

         boolean hasUpdate = false;

         for (CommonOrder commonOrder : commonOrderList) {

            stateSet.add(commonOrder.getState());

            goodsCount += commonOrder.getCount();

@@ -163,9 +166,12 @@
               saveHongBao(commonOrder, type, notificationMap);

               hasAdd = true;

            } else {

               updateHongBao(hongBaoOrder, commonOrder, type, notificationMap);

               boolean update = updateHongBao(hongBaoOrder, commonOrder, type, notificationMap);

               if (update)

                  hasUpdate = true;

            }

         }

				
         /**

          * 通知用户的返利情况

          */

@@ -242,8 +248,17 @@
               }

            }

         }

      }



         int resultCode = 0;

         if (hasAdd && hasUpdate)

            return 12;

         else if (hasAdd)

            return 1;

         else if (hasUpdate)

            return 2;

         return resultCode;

      }

      return 0;

   }



   private int getOrderState(Set<Integer> states) {

@@ -261,7 +276,7 @@
   }



   @Transactional

   private void updateHongBao(HongBaoOrder hongBaoOrder, CommonOrder commonOrder, int type,

   private boolean updateHongBao(HongBaoOrder hongBaoOrder, CommonOrder commonOrder, int type,

         Map<Integer, HongBaoOrder> notificationMap) throws HongBaoException {

      System.out.println(commonOrder.getOrderNo());

      // 锁行

@@ -270,7 +285,7 @@
         throw new HongBaoException(10, "红包对象不存在");

      // 已经失效，已经领取，新老状态一致的红包不做处理

      if (oldHongBao.getState() == HongBaoV2.STATE_SHIXIAO || oldHongBao.getState() == HongBaoV2.STATE_YILINGQU)

         return;

         return false;



      if (type == HongBaoV2.TYPE_ZIGOU) {// 获取自购的返利比例

         BigDecimal fanliRate = hongBaoManageService.getFanLiRate(commonOrder.getCreateTime().getTime());

@@ -298,7 +313,7 @@
                  MoneyBigDecimalUtil.mul(commonOrder.getEstimate(), fanliRate.divide(new BigDecimal(100))));

            if (mianDan)

               hongBao.setMoney(commonOrder.getPayment());

         } else if (commonOrder.getState() == CommonOrder.STATE_JS) {

         } else if (commonOrder.getState() == CommonOrder.STATE_JS||commonOrder.getState() == CommonOrder.STATE_WQ) {

            hongBao.setState(HongBaoV2.STATE_KELINGQU);

            hongBao.setMoney(

                  MoneyBigDecimalUtil.mul(commonOrder.geteIncome(), fanliRate.divide(new BigDecimal(100))));

@@ -317,7 +332,7 @@


         // 新老红包状态一致不处理

         if (oldHongBao.getState().intValue() == hongBao.getState())

            return;

            return false;



         if (hongBao.getState() == HongBaoV2.STATE_SHIXIAO) {

            if (mianDan) {

@@ -411,7 +426,7 @@
                  BigDecimal firstRate = hongBaoManageService

                        .getFirstInviteRate(boss.getRank() == null ? 0 : boss.getRank());

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

                     return;

                     return true;

                  HongBaoV2 firstHongbao = new HongBaoV2();

                  firstHongbao.setUserInfo(boss);

                  firstHongbao.setUrank(boss.getRank());

@@ -420,6 +435,7 @@
                  firstHongbao.setType(HongBaoV2.TYPE_YIJI);

                  firstHongbao.setVersion(2);

                  firstHongbao.setState(hongBao.getState());

                  firstHongbao.setOrderType(commonOrder.getSourceType());



                  if (hongBao.getState() == HongBaoV2.STATE_KELINGQU) {

                     firstHongbao.setMoney(

@@ -459,7 +475,7 @@
                     BigDecimal secondRate = hongBaoManageService

                           .getSecondInviteRate(boss.getRank() == null ? 0 : boss.getRank());

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

                        return;

                        return true;

                     HongBaoV2 secondHongbao = new HongBaoV2();

                     secondHongbao.setUserInfo(boss);

                     secondHongbao.setUrank(boss.getRank());

@@ -468,6 +484,7 @@
                     secondHongbao.setType(HongBaoV2.TYPE_ERJI);

                     secondHongbao.setVersion(2);

                     secondHongbao.setState(hongBao.getState());

                     secondHongbao.setOrderType(commonOrder.getSourceType());

                     if (hongBao.getState() == HongBaoV2.STATE_KELINGQU) {

                        secondHongbao.setMoney(MoneyBigDecimalUtil.mul(hongBao.getMoney(),

                              secondRate.divide(new BigDecimal(100))));

@@ -526,7 +543,7 @@
            hongBao.setState(HongBaoV2.STATE_BUKELINGQU);

            hongBao.setMoney(

                  MoneyBigDecimalUtil.mul(commonOrder.getEstimate(), fanliRate.divide(new BigDecimal(100))));

         } else if (commonOrder.getState() == CommonOrder.STATE_JS) {

         } else if (commonOrder.getState() == CommonOrder.STATE_JS||commonOrder.getState() == CommonOrder.STATE_WQ) {

            hongBao.setState(HongBaoV2.STATE_KELINGQU);

            hongBao.setMoney(

                  MoneyBigDecimalUtil.mul(commonOrder.geteIncome(), fanliRate.divide(new BigDecimal(100))));

@@ -574,7 +591,7 @@
               }



               // 以实际收入为准计算预估收益

               if (CommonOrder.STATE_JS == commonOrder.getState()) {

               if (CommonOrder.STATE_JS == commonOrder.getState()||CommonOrder.STATE_WQ == commonOrder.getState()) {

                  childUpdate.setMoney(

                        MoneyBigDecimalUtil.mul(hongBao.getMoney(), rate.divide(new BigDecimal(100))));

                  if (commonOrder.getThirdCreateTime().getTime() > TimeUtil.convertToTimeTemp("2019-04-16",

@@ -622,6 +639,8 @@
            }

      } else

         throw new HongBaoException(2, "type错误");



      return true;

   }



   @Transactional

@@ -642,7 +661,6 @@
               CommonOrderGoods goods = commonOrderGoodsMapper

                     .selectByPrimaryKey(commonOrder.getCommonOrderGoods().getId());

               if (goods != null) {



                  try {

                     if (userSystemCouponService.updateCouponRecordUsed(commonOrder.getUserInfo().getId(),

                           commonOrder.getOrderNo(), payMent, Long.parseLong(goods.getGoodsId())))

@@ -673,7 +691,7 @@
            hongBao.setState(HongBaoV2.STATE_BUKELINGQU);

            hongBao.setMoney(

                  MoneyBigDecimalUtil.mul(commonOrder.getEstimate(), fanliRate.divide(new BigDecimal(100))));

         } else if (commonOrder.getState() == CommonOrder.STATE_JS) {

         } else if (commonOrder.getState() == CommonOrder.STATE_JS||CommonOrder.STATE_WQ == commonOrder.getState()) {

            hongBao.setState(HongBaoV2.STATE_KELINGQU);

            hongBao.setMoney(

                  MoneyBigDecimalUtil.mul(commonOrder.geteIncome(), fanliRate.divide(new BigDecimal(100))));

@@ -694,6 +712,7 @@


         UserInfo user = userInfoService.getUserById(commonOrder.getUserInfo().getId());

         hongBao.setUrank(user.getRank());

         hongBao.setOrderType(commonOrder.getSourceType());

         hongBaoV2Mapper.insertSelective(hongBao);

         // 添加红包与订单的映射

         HongBaoOrder hongBaoOrder = new HongBaoOrder();

@@ -735,6 +754,7 @@
            firstHongbao.setType(HongBaoV2.TYPE_YIJI);

            firstHongbao.setVersion(2);

            firstHongbao.setState(hongBao.getState());

            firstHongbao.setOrderType(commonOrder.getSourceType());



            if (hongBao.getState() == HongBaoV2.STATE_KELINGQU) {

               firstHongbao.setMoney(

@@ -787,6 +807,7 @@
               secondHongbao.setType(HongBaoV2.TYPE_ERJI);

               secondHongbao.setVersion(2);

               secondHongbao.setState(hongBao.getState());

               secondHongbao.setOrderType(commonOrder.getSourceType());

               if (hongBao.getState() == HongBaoV2.STATE_KELINGQU) {

                  secondHongbao.setMoney(

                        MoneyBigDecimalUtil.mul(hongBao.getMoney(), secondRate.divide(new BigDecimal(100))));

@@ -877,7 +898,7 @@
            hongBao.setState(HongBaoV2.STATE_BUKELINGQU);

            hongBao.setMoney(

                  MoneyBigDecimalUtil.mul(commonOrder.getEstimate(), shareRate.divide(new BigDecimal(100))));

         } else if (commonOrder.getState() == CommonOrder.STATE_JS) {

         } else if (commonOrder.getState() == CommonOrder.STATE_JS||commonOrder.getState() == CommonOrder.STATE_WQ) {

            hongBao.setState(HongBaoV2.STATE_KELINGQU);

            hongBao.setMoney(

                  MoneyBigDecimalUtil.mul(commonOrder.geteIncome(), shareRate.divide(new BigDecimal(100))));

@@ -890,6 +911,7 @@
         UserInfo user = userInfoService.getUserById(commonOrder.getUserInfo().getId());

         hongBao.setUrank(user.getRank());

         hongBao.setUserInfo(user);

         hongBao.setOrderType(commonOrder.getSourceType());

         hongBaoV2Mapper.insertSelective(hongBao);

         // 插入红包与订单映射

         HongBaoOrder hongBaoOrder = new HongBaoOrder();

@@ -928,7 +950,7 @@
                  child.setState(HongBaoV2.STATE_BUKELINGQU);

                  child.setMoney(MoneyBigDecimalUtil.mul(commonOrder.getEstimate(),

                        firstLevelRate.divide(new BigDecimal(100))));

               } else if (commonOrder.getState() == CommonOrder.STATE_JS) {

               } else if (commonOrder.getState() == CommonOrder.STATE_JS||commonOrder.getState() == CommonOrder.STATE_WQ) {

                  child.setState(HongBaoV2.STATE_KELINGQU);

                  child.setMoney(MoneyBigDecimalUtil.mul(commonOrder.geteIncome(),

                        firstLevelRate.divide(new BigDecimal(100))));

@@ -943,6 +965,7 @@
               child.setUrank(boss.getRank());

               child.setVersion(2);

               child.setCreateTime(new Date());

               child.setOrderType(commonOrder.getSourceType());

               if (child.getMoney().compareTo(new BigDecimal(0)) > 0) {

                  hongBaoV2Mapper.insertSelective(child);

                  // 添加通知

@@ -1067,6 +1090,13 @@
   }



   @Override

   public List<HongBaoV2> listChildrenByIds(List<Long> idList) {

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

         return null;

      return hongBaoV2Mapper.listChildrenByIds(idList);

   }



   @Override

   public List<Long> getUidByNear30DayShareSucceed() {

      return hongBaoV2Mapper.getUidByNear30DayShareSucceed();

   }

@@ -1115,4 +1145,10 @@
         return hongBaoV2List.get(0);

      return null;

   }



   @Override

   public List<HongBaoV2> listByIds(List<Long> idList) {

      return hongBaoV2Mapper.listByIds(idList);

   }



}