分享赚比例修改 增加单品的分享记录

admin

2018-12-10 5f01b1bf63bd3dd242fc29e012e15c37fc03a190

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

@@ -26,6 +26,7 @@
import com.yeshi.fanli.dao.mybatis.order.OrderItemMapper;

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

import com.yeshi.fanli.dao.mybatis.share.PidUserMapper;

import com.yeshi.fanli.dao.mybatis.taobao.TaoBaoWeiQuanOrderMapper;

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

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

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

@@ -44,7 +45,10 @@
import com.yeshi.fanli.exception.OrderItemException;

import com.yeshi.fanli.exception.TaoBaoWeiQuanException;

import com.yeshi.fanli.log.LogHelper;

import com.yeshi.fanli.service.inter.hongbao.AccountDetailsHongBaoMapService;

import com.yeshi.fanli.service.inter.hongbao.HongBaoManageService;

import com.yeshi.fanli.service.inter.hongbao.HongBaoService;

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

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

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

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

@@ -128,6 +132,18 @@
   @Resource

   private RedisManager redisManager;



   @Resource

   private LostOrderService lostOrderService;



   @Resource

   private TaoBaoWeiQuanOrderMapper taoBaoWeiQuanOrderMapper;



   @Resource

   private HongBaoManageService hongBaoManageService;



   @Resource

   private AccountDetailsHongBaoMapService accountDetailsHongBaoMapService;



   @Override

   public void processOrder(Map<String, List<TaoBaoOrder>> orders) {

      List<TaoBaoUnionConfig> configList = taoBaoUnionConfigService.getConfigByTypeCache(PidUser.TYPE_FANLI_ANDROID);

@@ -163,6 +179,7 @@


   /**

    * 利用redis的原子性将订单号锁住，不让其他处理

    * 
    * @param orderId

    */

   private void redisLockOrder(String orderId) {

@@ -172,6 +189,7 @@


   /**

    * 订单解锁

    * 
    * @param orderId

    */

   private void redisUnlockOrder(String orderId) {

@@ -181,6 +199,7 @@


   /**

    * 订单是否被锁住了

    * 
    * @param orderId

    * @return

    */

@@ -202,12 +221,16 @@
         try {

            String orderId = its.next();

            // 处理红包与子红包

//            if (isRedisLockOrder(orderId))

//               continue;

//            redisLockOrder(orderId);

            // if (isRedisLockOrder(orderId))

            // continue;

            // redisLockOrder(orderId);

            processShopingFanliOrder(orderId, orders.get(orderId));

//            redisUnlockOrder(orderId);

            // redisUnlockOrder(orderId);

            // 出错了就不处理该订单了，需要定期检查



            // 更改丢失订单的状态

            lostOrderService.processSuceess(orderId);



         } catch (HongBaoException e1) {

            e1.printStackTrace();

         } catch (OrderItemException e2) {

@@ -383,8 +406,13 @@
         } else// 计算订单的总金额

         {

            BigDecimal money = new BigDecimal(0);

            for (TaoBaoOrder o : orderList)

               money = money.add(o.getPayment());

            for (TaoBaoOrder o : orderList) {

               if (o.getOrderState().equalsIgnoreCase("订单结算"))

                  money = money.add(o.getSettlement());

               else {

                  money = money.add(o.getPayment());

               }

            }

            updateOrder.setMoney(money);

            String thirdState = null;

            for (TaoBaoOrder o : orderList)

@@ -397,7 +425,7 @@
         orderMapper.updateByPrimaryKeySelective(updateOrder);

         Order order = oldOrder;

         // 订单返利比例

         BigDecimal rate = new BigDecimal(hongBaoManageMapper.selectByKey("hongbao_goods_proportion").getValue());

         BigDecimal rate = hongBaoManageService.getFanLiRate();



         // 查找是否存在红包

         List<HongBao> hongBaoList = hongBaoMapper.selectByOid(order.getId());

@@ -438,6 +466,16 @@
   public void fanli(HongBao hb) throws TaoBaoWeiQuanException {

      // 查询最新的红包数据

      hb = hongBaoMapper.selectByPrimaryKeyForUpdate(hb.getId());

      // 维权中的不返利

      List<TaoBaoWeiQuanOrder> taoBaoWeiQuanList = taoBaoWeiQuanOrderMapper

            .selectListByOrderIdAndState(hb.getOrderId(), "维权创建");

      if (taoBaoWeiQuanList != null && taoBaoWeiQuanList.size() > 0)

         return;



      taoBaoWeiQuanList = taoBaoWeiQuanOrderMapper.selectListByOrderIdAndState(hb.getOrderId(), "等待处理");

      if (taoBaoWeiQuanList != null && taoBaoWeiQuanList.size() > 0)

         return;



      long currentTimeMillis = System.currentTimeMillis();

      if (hb.getState() != HongBao.STATE_SHIXIAO) {

         // 设置为已返利

@@ -470,6 +508,9 @@
            AccountDetails accountDetails = AccountDetailsFactory.create("+" + hb.getMoney(),

                  AccountDetailsFactory.FANLI, orderItem, null, hb.getUserInfo());

            accountDetailsMapper.insertSelective(accountDetails);



            // 添加资金明细与红包的映射关系

            accountDetailsHongBaoMapService.saveAccountDetailsHongBaoMap(hb.getId(), accountDetails.getId());



            // 维权扣款（2018-08-05后开始实行）

            if (hb.getBalanceTime() != null

@@ -505,9 +546,9 @@


      List<TaoBaoOrder> orderList = taoBaoOrderService.getTaoBaoOrderByOrderId(order.getOrderId());

      if (orderList != null && orderList.size() > 0 & !StringUtil.isNullOrEmpty(orderList.get(0).getSettlementTime()))

         order.setJieSuanTime(orderList.get(0).getSettlementTime());

      if (TimeUtil.convertToTimeTemp(order.getJieSuanTime(), "yyyy-MM-dd HH:mm:ss") >= TimeUtil

            .convertToTimeTemp("2018-08-05", "yyyy-MM-dd")) {

         order.setJieSuanTime(

               new Date(TimeUtil.convertToTimeTemp(orderList.get(0).getSettlementTime(), "yyyy-MM-dd HH:mm:ss")));

      if (order.getJieSuanTime().getTime() >= TimeUtil.convertToTimeTemp("2018-08-05", "yyyy-MM-dd")) {

         return;

      }

      try {

@@ -543,17 +584,39 @@
      }

   }



   private HongBao filterWeiQuanINGHongBao(HongBao hongBao) {



      List<TaoBaoWeiQuanOrder> taoBaoWeiQuanList = taoBaoWeiQuanOrderMapper

            .selectListByOrderIdAndState(hongBao.getOrderId(), "维权创建");



      List<TaoBaoWeiQuanOrder> taoBaoWeiQuanList1 = taoBaoWeiQuanOrderMapper

            .selectListByOrderIdAndState(hongBao.getOrderId(), "等待处理");

      if ((taoBaoWeiQuanList != null && taoBaoWeiQuanList.size() > 0)

            || (taoBaoWeiQuanList1 != null && taoBaoWeiQuanList1.size() > 0)) {

         return null;

      }

      return hongBao;

   }



   @Override

   @Transactional

   public void fanliInvaiteAndShare(Long uid) throws TaoBaoWeiQuanException {

      /**

       * 处理邀请赚订单

       */

      // 查询UID的邀请赚订单

      List<HongBao> hongBaoList = hongBaoMapper.selectCanBalanceHongBaoByChildHongBaoAndUid(uid);

      BigDecimal money = new BigDecimal(0);



      List<Long> hbIdList = new ArrayList<>();



      BigDecimal money = new BigDecimal(0);

      // 需要判断退款的订单号

      Set<String> drawBackOrders = new HashSet<String>();



      for (HongBao hongBao : hongBaoList) {

         hongBao = filterWeiQuanINGHongBao(hongBao);

         if (hongBao == null)

            continue;



         hongBao = hongBaoMapper.selectByPrimaryKeyForUpdate(hongBao.getId());

         if (hongBao.getState() == HongBao.STATE_BUKELINGQU || hongBao.getState() == HongBao.STATE_KELINGQU) {

            money = money.add(hongBao.getMoney());

@@ -562,6 +625,8 @@
            updateHongBao.setGetTime(System.currentTimeMillis());

            updateHongBao.setState(HongBao.STATE_YILINGQU);

            hongBaoMapper.updateByPrimaryKeySelective(updateHongBao);

            // 添加到红包返利记录集合

            hbIdList.add(hongBao.getId());

            // 2018-08-05 过后的订单才处理维权

            Date balanceTime = null;

            if (hongBao.getParent() != null)

@@ -578,10 +643,17 @@
         }

      }



      /**

       * 处理顶级分享赚

       */



      // 查询UID的分享赚订单

      List<PidOrder> pidOrderList = pidOrderMapper.getCanBalanceListByUid(uid);

      for (PidOrder pidOrder : pidOrderList) {

         HongBao hongBao = hongBaoMapper.selectByPrimaryKeyForUpdate(pidOrder.getHongBao().getId());

         hongBao = filterWeiQuanINGHongBao(hongBao);

         if (hongBao == null)

            continue;

         if (hongBao.getState() == HongBao.STATE_BUKELINGQU || hongBao.getState() == HongBao.STATE_KELINGQU) {

            money = money.add(hongBao.getMoney());

            HongBao updateHongBao = new HongBao();

@@ -589,6 +661,8 @@
            updateHongBao.setGetTime(System.currentTimeMillis());

            updateHongBao.setState(HongBao.STATE_YILINGQU);

            hongBaoMapper.updateByPrimaryKeySelective(updateHongBao);

            // 添加到红包返利记录集合

            hbIdList.add(hongBao.getId());

            // 2018-08-05 过后的订单才处理维权

            Date balanceTime = null;

            if (hongBao.getParent() != null)

@@ -602,10 +676,15 @@
         }

      }



      /**

       * 处理一级二级分享赚

       */



      List<HongBao> totalHongBaoList = new ArrayList<>();

      // 查询UID的二级或者三级分享赚订单

      // TODO 暂时查询10000条数据，后面再做分页

      List<HongBao> hbList = hongBaoMapper.selectCanBalanceHongBaoByTypeAndUid(HongBao.TYPE_SHARE_YIJI, uid, 10000);



      if (hbList != null && hbList.size() > 0)

         totalHongBaoList.addAll(hbList);



@@ -615,16 +694,25 @@


      for (HongBao hb : totalHongBaoList) {

         if (hb.getState() == HongBao.STATE_BUKELINGQU || hb.getState() == HongBao.STATE_KELINGQU) {

            hb = filterWeiQuanINGHongBao(hb);

            if (hb == null)

               continue;

            money = money.add(hb.getMoney());

            HongBao updateHongBao = new HongBao();

            updateHongBao.setId(hb.getId());

            updateHongBao.setGetTime(System.currentTimeMillis());

            updateHongBao.setState(HongBao.STATE_YILINGQU);

            hongBaoMapper.updateByPrimaryKeySelective(updateHongBao);

            // 添加到红包返利记录集合

            hbIdList.add(hb.getId());

            if (!StringUtil.isNullOrEmpty(hb.getOrderId()))

               drawBackOrders.add(hb.getOrderId());

         }

      }



      /**

       * 增加用户资金记录

       */



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

         userInfoMapper.addHongBaoByUid(uid, money);

@@ -632,6 +720,10 @@
         AccountDetails accountDetails = AccountDetailsFactory.create("+" + money, AccountDetailsFactory.TICHENG,

               null, null, new UserInfo(uid));

         accountDetailsMapper.insertSelective(accountDetails);

         // 记录返利红包与资金详情的对应关系



         // 添加到红包返利记录集合

         accountDetailsHongBaoMapService.saveAccountDetailsHongBaoMap(hbIdList, accountDetails.getId());



         // 发送推送

         try {