大淘客搜索接口升级

admin

2020-11-28 dc5be7d38446f70e6ff86df311119c32b41fe7f8

 fanli/src/main/java/com/yeshi/fanli/service/impl/money/tb/TaoBaoWeiQuanDrawBackServiceImpl.java

@@ -22,28 +22,23 @@
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.InviteOrderSubsidyDebt;

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;

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

import com.yeshi.fanli.entity.taobao.TaoBaoOrder;

import com.yeshi.fanli.entity.taobao.TaoBaoWeiQuanDrawBack;

import com.yeshi.fanli.entity.taobao.TaoBaoWeiQuanOrder;

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

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

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

import com.yeshi.fanli.exception.order.TaoBaoWeiQuanException;

import com.yeshi.fanli.log.LogHelper;

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

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

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

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

import com.yeshi.fanli.service.inter.money.msg.UserMoneyMsgNotificationService;

import com.yeshi.fanli.service.inter.money.tb.TaoBaoWeiQuanDrawBackService;

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

import com.yeshi.fanli.service.inter.order.tb.TaoBaoWeiQuanOrderService;

import com.yeshi.fanli.util.Constant;

import com.yeshi.fanli.util.StringUtil;

@@ -84,11 +79,6 @@
   @Resource

   private UserMoneyService userMoneyService;



   @Resource

   private InviteOrderSubsidyService inviteOrderSubsidyService;



   @Resource

   private InviteOrderSubsidyDebtService inviteOrderSubsidyDebtService;



   @Resource

   private UserMoneyDetailService userMoneyDetailService;

@@ -227,7 +217,7 @@
         // 退款金额

         BigDecimal drawBackMoney = computeDrawBackMoney(settleMent, wqMoney, userGetMoney);

         userSubMoneyMap.put(uid, drawBackMoney);

         if (subMoneySync) {

         if (subMoneySync) {//同步减去资金

            // 计算资金是否充足

            UserInfo user = userInfoMapper.selectByPrimaryKey(uid);

            if (user != null && user.getMyHongBao().compareTo(drawBackMoney) < 0)// 资金不足

@@ -274,8 +264,24 @@
            userMoneyService.subUserMoney(uid, drawBackMoney, userMoneyDetail);



            // 新版通知

            List<CommonOrder> orderList = commonOrderMapper.listBySourceTypeAndOrderNo(Constant.SOURCE_TYPE_TAOBAO,

                  orderId);

            int goodsCount = 0;

            for (CommonOrder co : orderList) {

               if (co.getState() != CommonOrder.STATE_SX)

                  goodsCount += co.getCount();

            }



            BigDecimal fanliMoney = new BigDecimal(0);

            List<HongBaoOrder> hongBaoOrderList = hongBaoOrderMapper.listDetailByOrderIdAndSourceType(orderId,

                  Constant.SOURCE_TYPE_TAOBAO);

            for (HongBaoOrder hb : hongBaoOrderList) {

               fanliMoney = fanliMoney.add(hb.getHongBaoV2().getMoney());

            }



            userMoneyMsgNotificationService.fanliOrderWeiQuan(uid, orderId, Constant.SOURCE_TYPE_TAOBAO,

                  drawBackMoney, userInfoMapper.selectByPrimaryKey(uid).getMyHongBao());

                  drawBackMoney, fanliMoney, goodsCount, orderList.get(0).getThirdCreateTime());



         } else {// 记录资金记录，但是不显示给用户



            UserMoneyDetail userMoneyDetail = null;

@@ -469,9 +475,25 @@
            }

         }

         userMoneyService.subUserMoney(uid, drawBackMoney, userMoneyDetail);

         userMoneyMsgNotificationService.shareOrderWeiQuan(uid, orderId, Constant.SOURCE_TYPE_TAOBAO, drawBackMoney,



               userInfoMapper.selectByPrimaryKey(uid).getMyHongBao());

         // 新版通知

         List<CommonOrder> orderList = commonOrderMapper.listBySourceTypeAndOrderNo(Constant.SOURCE_TYPE_TAOBAO,

               orderId);

         int goodsCount = 0;

         for (CommonOrder co : orderList) {

            if (co.getState() != CommonOrder.STATE_SX)

               goodsCount += co.getCount();

         }



         BigDecimal fanliMoney = new BigDecimal(0);

         List<HongBaoOrder> hongBaoOrderList = hongBaoOrderMapper.listDetailByOrderIdAndSourceType(orderId,

               Constant.SOURCE_TYPE_TAOBAO);

         for (HongBaoOrder hb : hongBaoOrderList) {

            fanliMoney = fanliMoney.add(hb.getHongBaoV2().getMoney());

         }



         userMoneyMsgNotificationService.shareOrderWeiQuan(uid, orderId, Constant.SOURCE_TYPE_TAOBAO, drawBackMoney,

               fanliMoney, goodsCount, orderList.get(0).getThirdCreateTime());

      }

   }



@@ -495,7 +517,7 @@
            settleMent = settleMent.add(taoBaoOrder.getSettlement());

         }



         // 查询下级子用户



         CommonOrder commonOrder = commonOrderMapper.selectBySourceTypeAndTradeId(Constant.SOURCE_TYPE_TAOBAO,

               weiQuanOrder.getOrderItemId());

         if (commonOrder == null)

@@ -506,6 +528,7 @@
         if (hongbaoOrder == null || hongbaoOrder.getHongBaoV2() == null)

            throw new TaoBaoWeiQuanException(3, "红包有误");



         // 查询下级子用户

         List<HongBaoV2> childList = hongBaoV2Mapper.listChildrenById(hongbaoOrder.getHongBaoV2().getId());



         if (childList != null)

@@ -525,11 +548,6 @@
               weiQuanDrawBack.setOrderItemId(weiQuanOrder.getOrderItemId());

               weiQuanDrawBack.setUser(child.getUserInfo());

               taoBaoWeiQuanDrawBackMapper.insertSelective(weiQuanDrawBack);// 加入返还记录



               // 加入邀请补贴返还记录

               doInviteOrderSubsidy(orderId, Constant.SOURCE_TYPE_TAOBAO, uid, settleMent, wqMoney,

                     weiQuanOrder.getOrderItemId());



               // 如果资金大于0才扣除



               if (drawBackMoney != null && drawBackMoney.compareTo(new BigDecimal(0)) > 0) {

@@ -561,45 +579,10 @@


                  userMoneyService.subUserMoney(uid, drawBackMoney, userMoneyDetail);



                  // 新版通知

                  userMoneyMsgNotificationService.inviteOrderWeiQuan(uid, orderId, Constant.SOURCE_TYPE_TAOBAO,

                        drawBackMoney, userInfoMapper.selectAvailableByPrimaryKey(uid).getMyHongBao());

               }

            }

      }

   }



   /**

    * 邀请订单补贴维权处理

    * 
    * @param orderId

    * @param sourceType

    */

   private void doInviteOrderSubsidy(String orderId, int sourceType, Long uid, BigDecimal settleMent,

         BigDecimal weiQuanMoney, String tradeId) throws TaoBaoWeiQuanException {

      InviteOrderSubsidy subSidy = inviteOrderSubsidyService.getByOrderNoAndType(uid, orderId, sourceType);

      if (subSidy != null)// 添加借贷关系

      {

         BigDecimal drawBackMoney = computeDrawBackMoney(settleMent, weiQuanMoney, subSidy.getOriginalMoney());

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

            return;

         InviteOrderSubsidyDebt debt = new InviteOrderSubsidyDebt();

         debt.setBeiZhu("订单售后:" + orderId + "-" + sourceType);

         debt.setOriginMoney(drawBackMoney);

         debt.setUid(uid);

         debt.setCreateTime(new Date());

         debt.setSourceId(subSidy.getId());

         debt.setTradeId(tradeId);

         try {

            inviteOrderSubsidyDebtService.addDebt(debt);

         } catch (InviteOrderSubsidyDebtException e) {

            throw new TaoBaoWeiQuanException(101, "邀请订单补贴异常");

         }



         //TODO 删除团队奖励维权处理

      }

   }





   @Override

   public TaoBaoWeiQuanDrawBack selectByOrderItemId(String orderItemId) {