admin
2019-07-11 3824cbcaec6e6c67418d5280a53e9c2fedeef6f9
fanli/src/main/java/com/yeshi/fanli/service/impl/taobao/TaoBaoWeiQuanDrawBackServiceImpl.java
@@ -22,6 +22,8 @@
import com.yeshi.fanli.dao.mybatis.taobao.TaoBaoWeiQuanDrawBackMapper;
import com.yeshi.fanli.entity.bus.user.HongBaoV2;
import com.yeshi.fanli.entity.bus.user.UserInfo;
import com.yeshi.fanli.entity.money.UserMoneyDebt;
import com.yeshi.fanli.entity.money.UserMoneyDebt.UserMoneyDebtTypeEnum;
import com.yeshi.fanli.entity.money.UserMoneyDetail;
import com.yeshi.fanli.entity.order.CommonOrder;
import com.yeshi.fanli.entity.order.HongBaoOrder;
@@ -29,11 +31,14 @@
import com.yeshi.fanli.entity.taobao.TaoBaoWeiQuanDrawBack;
import com.yeshi.fanli.entity.taobao.TaoBaoWeiQuanOrder;
import com.yeshi.fanli.exception.TaoBaoWeiQuanException;
import com.yeshi.fanli.exception.money.UserMoneyDebtException;
import com.yeshi.fanli.exception.money.UserMoneyDetailException;
import com.yeshi.fanli.log.LogHelper;
import com.yeshi.fanli.service.inter.money.UserMoneyDebtService;
import com.yeshi.fanli.service.inter.msg.UserMoneyMsgNotificationService;
import com.yeshi.fanli.service.inter.taobao.TaoBaoWeiQuanDrawBackService;
import com.yeshi.fanli.service.inter.taobao.TaoBaoWeiQuanOrderService;
import com.yeshi.fanli.service.inter.user.UserMoneyService;
import com.yeshi.fanli.service.inter.user.UserNotificationService;
import com.yeshi.fanli.util.Constant;
import com.yeshi.fanli.util.MoneyBigDecimalUtil;
@@ -73,10 +78,29 @@
   @Resource
   private UserMoneyMsgNotificationService userMoneyMsgNotificationService;
   @Resource
   private UserMoneyDebtService userMoneyDebtService;
   @Resource
   private UserMoneyService userMoneyService;
   @Override
   public void addWeiQuanDrawBack(TaoBaoWeiQuanDrawBack taoBaoWeiQuanDrawBack) {
      taoBaoWeiQuanDrawBackMapper.selectByOrderItemIdAndUid(taoBaoWeiQuanDrawBack.getOrderItemId(),
            taoBaoWeiQuanDrawBack.getUser().getId());
   }
   @Transactional
   private void addDebt(Long uid, Long hbId, BigDecimal money) throws UserMoneyDebtException {
      UserMoneyDebt debt = new UserMoneyDebt();
      debt.setBeiZhu(null);
      debt.setCreateTime(new Date());
      debt.setLeftMoney(money);
      debt.setOriginMoney(money);
      debt.setSourceId(hbId);
      debt.setType(UserMoneyDebtTypeEnum.order);
      debt.setUid(uid);
      userMoneyDebtService.addUserMoneyDebt(debt);
   }
   @Transactional
@@ -93,8 +117,11 @@
      // 计算淘宝联盟返给平台的资金
      BigDecimal sumFee = new BigDecimal("0");
      for (TaoBaoOrder order : orderList)
         if (order.getOrderState().equalsIgnoreCase("订单结算"))
         if (order.getOrderState().equalsIgnoreCase("订单结算")) {
            sumFee = sumFee.add(order.geteIncome());
            if (order.getSubsidy() != null)
               sumFee = sumFee.add(order.getSubsidy());
         }
      if (new BigDecimal(0).compareTo(sumFee) == 0)
         throw new TaoBaoWeiQuanException(TaoBaoWeiQuanException.CODE_NEDD_UPDATE_ORDER, "需要更新订单");
@@ -157,6 +184,7 @@
         BigDecimal fanMoney = new BigDecimal("0");
         // 统计用户在这个单中需要扣除的资金
         TaoBaoWeiQuanDrawBack weiQuanDrawBack = null;
         List<TaoBaoWeiQuanDrawBack> newWeiQuanDrawBackList = new ArrayList<>();
         for (TaoBaoWeiQuanOrder weiQuanOrder : list) {
            weiQuanDrawBack = taoBaoWeiQuanDrawBackMapper.selectByOrderItemIdAndUid(weiQuanOrder.getOrderItemId(),
                  uid);
@@ -164,7 +192,6 @@
               continue;
            // 退款的资金
            fanMoney = fanMoney.add(weiQuanOrder.getFanMoney());
            // 插入记录
            weiQuanDrawBack = new TaoBaoWeiQuanDrawBack();
            weiQuanDrawBack.setCreateTime(new Date());
            // 暂时设为0
@@ -172,20 +199,58 @@
            weiQuanDrawBack.setOrderId(weiQuanOrder.getOrderId());
            weiQuanDrawBack.setOrderItemId(weiQuanOrder.getOrderItemId());
            weiQuanDrawBack.setUser(new UserInfo(uid));
            taoBaoWeiQuanDrawBackMapper.insertSelective(weiQuanDrawBack);
            newWeiQuanDrawBackList.add(weiQuanDrawBack);
         }
         if (fanMoney.compareTo(new BigDecimal("0")) <= 0)
            continue;
         // 插入记录
         for (TaoBaoWeiQuanDrawBack drawBack : newWeiQuanDrawBackList) {
            taoBaoWeiQuanDrawBackMapper.insertSelective(drawBack);
         }
         // 退款金额
         BigDecimal drawBackMoney = MoneyBigDecimalUtil.div(userGetMoney.multiply(fanMoney), sumFee);
         userInfoMapper.subHongBaoByUid(uid, drawBackMoney);
         if (drawBackMoney.compareTo(userGetMoney) > 0)
            drawBackMoney = userGetMoney;// 退款金额不能比获得的金额大
         // 计算资金是否充足
         UserInfo user = userInfoMapper.selectByPKey(uid);
         if (user != null && user.getMyHongBao().compareTo(drawBackMoney) < 0)// 资金不足
         {
            // 添加债务
            for (TaoBaoWeiQuanOrder weiQuanOrder : list) {
               TaoBaoOrder taoBaoOrder = taoBaoOrderMapper
                     .selectTaoBaoOrderByTradeId(weiQuanOrder.getOrderItemId());
               if (taoBaoOrder != null) {
                  BigDecimal totalFee = taoBaoOrder.geteIncome();
                  if (taoBaoOrder.getSubsidy() != null)
                     totalFee = totalFee.add(taoBaoOrder.getSubsidy());
                  //
                  CommonOrder co = commonOrderMapper.selectBySourceTypeAndTradeId(Constant.SOURCE_TYPE_TAOBAO,
                        weiQuanOrder.getOrderItemId());
                  if (co != null) {
                     HongBaoOrder hongBaoOrder = hongBaoOrderMapper.selectByCommonOrderId(co.getId());
                     if (hongBaoOrder != null && hongBaoOrder.getHongBaoV2() != null) {
                        BigDecimal drawback = MoneyBigDecimalUtil.div(
                              hongBaoOrder.getHongBaoV2().getMoney().multiply(weiQuanOrder.getFanMoney()),
                              totalFee);
                        try {
                           addDebt(uid, hongBaoOrder.getHongBaoV2().getId(), drawback);
                        } catch (UserMoneyDebtException e) {
                           throw new TaoBaoWeiQuanException(101, "资金借贷异常");
                        }
                     }
                  }
               }
            }
            continue;
         }
         UserMoneyDetail userMoneyDetail = null;
         // 新版资金记录
         try {
            UserMoneyDetail userMoneyDetail = UserMoneyDetailFactory.createFanLiWeiQuan(uid, weiQuanDrawBack,
                  drawBackMoney);
            userMoneyDetailMapper.insert(userMoneyDetail);
            userMoneyDetail = UserMoneyDetailFactory.createFanLiWeiQuan(uid, weiQuanDrawBack, drawBackMoney);
         } catch (UserMoneyDetailException e) {
            try {
               LogHelper.errorDetailInfo(e);
@@ -193,6 +258,7 @@
               e1.printStackTrace();
            }
         }
         userMoneyService.subUserMoney(uid, drawBackMoney, userMoneyDetail);
         // 新版通知
         userMoneyMsgNotificationService.fanliOrderWeiQuan(uid, orderId, drawBackMoney,
@@ -216,8 +282,11 @@
      // 计算淘宝联盟返给平台的资金
      BigDecimal sumFee = new BigDecimal("0");
      for (TaoBaoOrder order : orderList)
         if (order.getOrderState().equalsIgnoreCase("订单结算"))
         if (order.getOrderState().equalsIgnoreCase("订单结算")) {
            sumFee = sumFee.add(order.geteIncome());
            if (order.getSubsidy() != null)
               sumFee = sumFee.add(order.getSubsidy());
         }
      // 获取和该订单号有关联的用户
      // 获取主红包(同一个订单号的单只会对应同一个用户)
@@ -253,8 +322,8 @@
            if (hongBao.getState() == HongBaoV2.STATE_SHIXIAO)
               continue;
            // 返利红包不计入
            if (hongBao.getType() != HongBaoV2.TYPE_ZIGOU) {
            // 只计入分享赚的红包
            if (hongBao.getType() == HongBaoV2.TYPE_SHARE_GOODS) {
               // 累计主红包的金额
               if (fanMoneyMap.get(hongBao.getUserInfo().getId()) == null) {
                  fanMoneyMap.put(hongBao.getUserInfo().getId(), hongBao.getMoney());
@@ -262,18 +331,6 @@
                  fanMoneyMap.put(hongBao.getUserInfo().getId(),
                        fanMoneyMap.get(hongBao.getUserInfo().getId()).add(hongBao.getMoney()));
            }
            // 累计子红包的金额
            List<HongBaoV2> childHongBaoList = hongBaoV2Mapper.listChildrenById(hongBao.getId());
            if (childHongBaoList != null)
               for (HongBaoV2 child : childHongBaoList) {
                  if (child.getState() == HongBaoV2.STATE_SHIXIAO)
                     continue;
                  if (fanMoneyMap.get(child.getUserInfo().getId()) == null) {
                     fanMoneyMap.put(child.getUserInfo().getId(), child.getMoney());
                  } else
                     fanMoneyMap.put(child.getUserInfo().getId(),
                           fanMoneyMap.get(child.getUserInfo().getId()).add(child.getMoney()));
               }
         }
      // 计算每个用户的返利比例
@@ -284,6 +341,8 @@
         BigDecimal fanMoney = new BigDecimal("0");
         // 统计用户在这个单中需要扣除的资金
         TaoBaoWeiQuanDrawBack weiQuanDrawBack = null;
         List<TaoBaoWeiQuanDrawBack> newWeiQuanDrawBackList = new ArrayList<>();
         for (TaoBaoWeiQuanOrder weiQuanOrder : list) {
            weiQuanDrawBack = taoBaoWeiQuanDrawBackMapper.selectByOrderItemIdAndUid(weiQuanOrder.getOrderItemId(),
                  uid);
@@ -299,7 +358,7 @@
            weiQuanDrawBack.setOrderId(weiQuanOrder.getOrderId());
            weiQuanDrawBack.setOrderItemId(weiQuanOrder.getOrderItemId());
            weiQuanDrawBack.setUser(new UserInfo(uid));
            taoBaoWeiQuanDrawBackMapper.insertSelective(weiQuanDrawBack);
            newWeiQuanDrawBackList.add(weiQuanDrawBack);
         }
         if (fanMoney.compareTo(new BigDecimal("0")) <= 0)
@@ -307,12 +366,67 @@
         // 退款金额
         BigDecimal drawBackMoney = MoneyBigDecimalUtil.div(userGetMoney.multiply(fanMoney), sumFee);
         userInfoMapper.subHongBaoByUid(uid, drawBackMoney);
         if (drawBackMoney.compareTo(userGetMoney) > 0)
            drawBackMoney = userGetMoney;
         for (TaoBaoWeiQuanDrawBack drawBack : newWeiQuanDrawBackList)
            taoBaoWeiQuanDrawBackMapper.insertSelective(drawBack);
         // 计算资金是否充足
         UserInfo user = userInfoMapper.selectByPKey(uid);
         if (user != null && user.getMyHongBao().compareTo(drawBackMoney) < 0)// 资金不足
         {
            // 添加债务
            for (TaoBaoWeiQuanOrder weiQuanOrder : list) {
               TaoBaoOrder taoBaoOrder = taoBaoOrderMapper
                     .selectTaoBaoOrderByTradeId(weiQuanOrder.getOrderItemId());
               if (taoBaoOrder != null) {
                  BigDecimal totalFee = taoBaoOrder.geteIncome();
                  if (taoBaoOrder.getSubsidy() != null)
                     totalFee = totalFee.add(taoBaoOrder.getSubsidy());
                  //
                  CommonOrder co = commonOrderMapper.selectBySourceTypeAndTradeId(Constant.SOURCE_TYPE_TAOBAO,
                        weiQuanOrder.getOrderItemId());
                  if (co != null) {
                     HongBaoOrder hongBaoOrder = hongBaoOrderMapper.selectByCommonOrderId(co.getId());
                     BigDecimal drawback = MoneyBigDecimalUtil.div(
                           hongBaoOrder.getHongBaoV2().getMoney().multiply(weiQuanOrder.getFanMoney()),
                           totalFee);
                     try {
                        addDebt(uid, hongBaoOrder.getHongBaoV2().getId(), drawback);
                     } catch (UserMoneyDebtException e) {
                        throw new TaoBaoWeiQuanException(101, "资金借贷异常");
                     }
                     if (hongBaoOrder != null && hongBaoOrder.getHongBaoV2() != null) {
                        List<HongBaoV2> hongBaoList = hongBaoV2Mapper
                              .listChildrenById(hongBaoOrder.getHongBaoV2().getId());
                        for (int i = 0; i < hongBaoList.size(); i++) {
                           if (hongBaoList.get(i).getUserInfo().getId().longValue() != uid) {
                              hongBaoList.remove(i);
                              i--;
                           }
                        }
                        for (HongBaoV2 hb : hongBaoList) {
                           drawback = MoneyBigDecimalUtil
                                 .div(hb.getMoney().multiply(weiQuanOrder.getFanMoney()), totalFee);
                           try {
                              addDebt(hb.getUserInfo().getId(), hb.getId(), drawback);
                           } catch (UserMoneyDebtException e) {
                              throw new TaoBaoWeiQuanException(101, "资金借贷异常");
                           }
                        }
                     }
                  }
               }
            }
            continue;
         }
         UserMoneyDetail userMoneyDetail = null;
         // 新版资金记录
         try {
            UserMoneyDetail userMoneyDetail = UserMoneyDetailFactory.createShareWeiQuan(uid, weiQuanDrawBack,
                  drawBackMoney);
            userMoneyDetailMapper.insert(userMoneyDetail);
            userMoneyDetail = UserMoneyDetailFactory.createShareWeiQuan(uid, weiQuanDrawBack, drawBackMoney);
         } catch (UserMoneyDetailException e) {
            try {
               LogHelper.errorDetailInfo(e);
@@ -320,13 +434,13 @@
               e1.printStackTrace();
            }
         }
         userMoneyService.subUserMoney(uid, drawBackMoney, userMoneyDetail);
         userMoneyMsgNotificationService.shareOrderWeiQuan(uid, orderId, drawBackMoney,
               userInfoMapper.selectByPrimaryKey(uid).getMyHongBao());
         userNotificationService.weiQuanTiCheng(uid, orderId, drawBackMoney);
      }
   }
   @Transactional
@@ -339,124 +453,106 @@
      if (list == null || list.size() == 0)
         return;
      // 查询订单库
      List<TaoBaoOrder> orderList = taoBaoOrderMapper.selectTaoBaoOrderByOrderId(orderId);
      // 计算淘宝联盟返给平台的资金
      BigDecimal sumFee = new BigDecimal("0");
      for (TaoBaoOrder order : orderList)
         if (order.getOrderState().equalsIgnoreCase("订单结算"))
            sumFee = sumFee.add(order.geteIncome());
      // 获取和该订单号有关联的用户
      // 获取主红包(同一个订单号的单只会对应同一个用户)
      List<CommonOrderVO> typeList = new ArrayList<>();
      CommonOrderVO cv = new CommonOrderVO();
      cv.setSourceType(Constant.SOURCE_TYPE_TAOBAO);
      cv.setOrderNo(orderId);
      typeList.add(cv);
      List<CommonOrderVO> commonOrderList = commonOrderMapper.listOrderGoodsInfo(typeList);
      List<HongBaoV2> mainHongBaoList = new ArrayList<>();
      if (commonOrderList != null)
         for (CommonOrderVO vo : commonOrderList) {
            CommonOrder co = commonOrderMapper.selectByPrimaryKey(vo.getId());
            if (co.getState() != CommonOrder.STATE_WQ) {
               co = new CommonOrder(vo.getId());
               co.setState(CommonOrder.STATE_WQ);
               co.setUpdateTime(new Date());
               commonOrderMapper.updateByPrimaryKeySelective(co);
            }
            HongBaoOrder hongBaoOrder = hongBaoOrderMapper.selectByCommonOrderId(vo.getId());
            mainHongBaoList.add(hongBaoOrder.getHongBaoV2());
      for (TaoBaoWeiQuanOrder weiQuanOrder : list) {
         TaoBaoOrder taoBaoOrder = taoBaoOrderMapper.selectTaoBaoOrderByTradeId(weiQuanOrder.getOrderItemId());
         BigDecimal fanMoney = weiQuanOrder.getFanMoney();
         if (taoBaoOrder == null)
            throw new TaoBaoWeiQuanException(1, "来源交易ID有误");
         BigDecimal sumFee = new BigDecimal("0");
         if (taoBaoOrder.getOrderState().equalsIgnoreCase("订单结算")) {
            sumFee = sumFee.add(taoBaoOrder.geteIncome());
            if (taoBaoOrder.getSubsidy() != null)
               sumFee = sumFee.add(taoBaoOrder.getSubsidy());
         }
      if (mainHongBaoList == null || mainHongBaoList.size() == 0)
         return;
      // 主用户ID
      Map<Long, BigDecimal> fanMoneyMap = new HashMap<>();
         // 查询下级子用户
         CommonOrder commonOrder = commonOrderMapper.selectBySourceTypeAndTradeId(Constant.SOURCE_TYPE_TAOBAO,
               weiQuanOrder.getOrderItemId());
         if (commonOrder == null)
            throw new TaoBaoWeiQuanException(2, "订单有误");
      if (mainHongBaoList != null)
         for (HongBaoV2 hongBao : mainHongBaoList) {
            HongBaoV2 hb = hongBaoV2Mapper.selectByPrimaryKey(hongBao.getId());
            hongBao = hb;
         HongBaoOrder hongbaoOrder = hongBaoOrderMapper.selectByCommonOrderId(commonOrder.getId());
            if (hongBao.getState() == HongBaoV2.STATE_SHIXIAO)
               continue;
            // 返利红包不计入
            if (hongBao.getType() != HongBaoV2.TYPE_ZIGOU) {
               // 累计主红包的金额
               if (fanMoneyMap.get(hongBao.getUserInfo().getId()) == null) {
                  fanMoneyMap.put(hongBao.getUserInfo().getId(), hongBao.getMoney());
               } else
                  fanMoneyMap.put(hongBao.getUserInfo().getId(),
                        fanMoneyMap.get(hongBao.getUserInfo().getId()).add(hongBao.getMoney()));
            }
            // 累计子红包的金额
            List<HongBaoV2> childHongBaoList = hongBaoV2Mapper.listChildrenById(hongBao.getId());
            if (childHongBaoList != null)
               for (HongBaoV2 child : childHongBaoList) {
                  if (child.getState() == HongBaoV2.STATE_SHIXIAO)
                     continue;
                  if (fanMoneyMap.get(child.getUserInfo().getId()) == null) {
                     fanMoneyMap.put(child.getUserInfo().getId(), child.getMoney());
                  } else
                     fanMoneyMap.put(child.getUserInfo().getId(),
                           fanMoneyMap.get(child.getUserInfo().getId()).add(child.getMoney()));
         if (hongbaoOrder == null || hongbaoOrder.getHongBaoV2() == null)
            throw new TaoBaoWeiQuanException(3, "红包有误");
         List<HongBaoV2> childList = hongBaoV2Mapper.listChildrenById(hongbaoOrder.getHongBaoV2().getId());
         if (childList != null)
            for (HongBaoV2 child : childList) {
               Long uid = child.getUserInfo().getId();
               if (child.getState() != HongBaoV2.STATE_YILINGQU)
                  continue;
               TaoBaoWeiQuanDrawBack weiQuanDrawBack = taoBaoWeiQuanDrawBackMapper
                     .selectByOrderItemIdAndUid(weiQuanOrder.getOrderItemId(), child.getUserInfo().getId());
               if (weiQuanDrawBack != null)
                  continue;
               BigDecimal drawBackMoney = MoneyBigDecimalUtil.div(child.getMoney().multiply(fanMoney), sumFee);
               if (drawBackMoney.compareTo(child.getMoney()) > 0)
                  drawBackMoney = child.getMoney();
               weiQuanDrawBack = new TaoBaoWeiQuanDrawBack();
               weiQuanDrawBack.setCreateTime(new Date());
               weiQuanDrawBack.setDrawBackMoney(drawBackMoney);
               weiQuanDrawBack.setOrderId(weiQuanOrder.getOrderId());
               weiQuanDrawBack.setOrderItemId(weiQuanOrder.getOrderItemId());
               weiQuanDrawBack.setUser(child.getUserInfo());
               taoBaoWeiQuanDrawBackMapper.insertSelective(weiQuanDrawBack);// 加入返还记录
               // 判断资金是否足够扣款
               UserInfo user = userInfoMapper.selectByPKey(uid);
               if (user != null && user.getMyHongBao().compareTo(drawBackMoney) < 0)// 资金不足
               {
                  try {
                     addDebt(uid, child.getId(), drawBackMoney);
                  } catch (UserMoneyDebtException e) {
                     throw new TaoBaoWeiQuanException(101, "资金借贷异常");
                  }
                  continue;
               }
         }
      // 计算每个用户的返利比例
      Iterator<Long> its = fanMoneyMap.keySet().iterator();
      while (its.hasNext()) {
         Long uid = its.next();
         BigDecimal userGetMoney = fanMoneyMap.get(uid);
         BigDecimal fanMoney = new BigDecimal("0");
         // 统计用户在这个单中需要扣除的资金
         TaoBaoWeiQuanDrawBack weiQuanDrawBack = null;
         for (TaoBaoWeiQuanOrder weiQuanOrder : list) {
            weiQuanDrawBack = taoBaoWeiQuanDrawBackMapper.selectByOrderItemIdAndUid(weiQuanOrder.getOrderItemId(),
                  uid);
            if (weiQuanDrawBack != null)
               continue;
            // 退款的资金
            fanMoney = fanMoney.add(weiQuanOrder.getFanMoney());
            // 插入记录
            weiQuanDrawBack = new TaoBaoWeiQuanDrawBack();
            weiQuanDrawBack.setCreateTime(new Date());
            // TODO 暂时设为0
            weiQuanDrawBack.setDrawBackMoney(new BigDecimal(0));
            weiQuanDrawBack.setOrderId(weiQuanOrder.getOrderId());
            weiQuanDrawBack.setOrderItemId(weiQuanOrder.getOrderItemId());
            weiQuanDrawBack.setUser(new UserInfo(uid));
            taoBaoWeiQuanDrawBackMapper.insertSelective(weiQuanDrawBack);
         }
               UserMoneyDetail userMoneyDetail = null;
               // 新版资金记录
               try {
                  userMoneyDetail = UserMoneyDetailFactory.createInviteWeiQuan(uid, weiQuanDrawBack,
                        drawBackMoney);
               } catch (UserMoneyDetailException e) {
                  try {
                     LogHelper.errorDetailInfo(e);
                  } catch (Exception e1) {
                     e1.printStackTrace();
                  }
               }
         if (fanMoney.compareTo(new BigDecimal("0")) <= 0)
            continue;
               userMoneyService.subUserMoney(uid, drawBackMoney, userMoneyDetail);
         // 退款金额
         BigDecimal drawBackMoney = MoneyBigDecimalUtil.div(userGetMoney.multiply(fanMoney), sumFee);
         userInfoMapper.subHongBaoByUid(uid, drawBackMoney);
         // 新版资金记录
         try {
            UserMoneyDetail userMoneyDetail = UserMoneyDetailFactory.createInviteWeiQuan(uid, weiQuanDrawBack,
                  drawBackMoney);
            userMoneyDetailMapper.insert(userMoneyDetail);
         } catch (UserMoneyDetailException e) {
            try {
               LogHelper.errorDetailInfo(e);
            } catch (Exception e1) {
               e1.printStackTrace();
               // 新版通知
               userMoneyMsgNotificationService.inviteOrderWeiQuan(uid, orderId, drawBackMoney,
                     userInfoMapper.selectByPrimaryKey(uid).getMyHongBao());
            }
         }
         // 新版通知
         userMoneyMsgNotificationService.inviteOrderWeiQuan(uid, orderId, drawBackMoney,
               userInfoMapper.selectByPrimaryKey(uid).getMyHongBao());
         userNotificationService.weiQuanTiCheng(uid, orderId, drawBackMoney);
      }
   }
   @Override
   public TaoBaoWeiQuanDrawBack selectByOrderItemId(String orderItemId) {
      List<TaoBaoWeiQuanDrawBack> list = taoBaoWeiQuanDrawBackMapper.selectByOrderItemId(orderItemId);
      if (list != null && list.size() > 0)
         return list.get(0);
      else
         return null;
   }
   @Override
   public TaoBaoWeiQuanDrawBack selectByHongBaoId(Long hbId) {
      Long uid = null;
      HongBaoV2 hb = hongBaoV2Mapper.selectByPrimaryKey(hbId);
      uid = hb.getUserInfo().getId();
      if (hb.getParent() != null)
         hb = hb.getParent();
      HongBaoOrder hbo = hongBaoOrderMapper.selectByHongBaoId(hb.getId());
      if (hbo != null && hbo.getCommonOrder() != null) {
         return taoBaoWeiQuanDrawBackMapper.selectByOrderItemIdAndUid(hbo.getCommonOrder().getTradeId(), uid);
      }
      return null;
   }
}