返利到账后获取金币的机制建立

admin

2019-08-28 0fdccf0fa23d0f039f563de9b31c974342d00a48

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

@@ -66,6 +66,7 @@
import com.yeshi.fanli.util.StringUtil;

import com.yeshi.fanli.util.TaoBaoConstant;

import com.yeshi.fanli.util.TimeUtil;

import com.yeshi.fanli.util.cmq.HongBaoRecieveCMQManager;

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

import com.yeshi.fanli.util.jd.JDApiUtil;

import com.yeshi.fanli.util.pinduoduo.PinDuoDuoApiUtil;

@@ -404,6 +405,11 @@
         // 添加资金明细与红包的映射关系

         for (HongBaoV2 v2 : userHongBao.get(uid)) {

            accountDetailsHongBaoMapService.saveAccountDetailsHongBaoMap(v2.getId(), userMoneyDetail.getId());

            try {

               HongBaoRecieveCMQManager.getInstance().addHongBaoRecieveMsg(v2.getId());

            } catch (Exception e) {

               LogHelper.errorDetailInfo(e);

            }

         }



         // 站内信+推送

@@ -567,6 +573,7 @@
   @Override

   @Transactional

   public void fanliInvaiteAndShare(Long uid) throws TaoBaoWeiQuanException {

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

      /**

       * 处理邀请赚订单

       */

@@ -578,9 +585,9 @@
      List<HongBaoV2> hongBaoList =new ArrayList<>();

       //1000条数据为1页

      int page=(int)   (count%1000==0?count/1000:count/1000+1);

      for(int i=0;i<page;i++)

      {

         List<HongBaoV2> tempHongBaoList = hongBaoV2Mapper.listCanBalanceHongBaoByTypeAndUid(types, uid, i*1000,1000);

      for (int i = 0; i < page; i++) {

         List<HongBaoV2> tempHongBaoList = hongBaoV2Mapper.listCanBalanceHongBaoByTypeAndUid(types, uid, i * 1000,

               1000);

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

            hongBaoList.addAll(tempHongBaoList);

      }

@@ -731,7 +738,8 @@
         for (String orderId : drawBackOrders)

            taoBaoWeiQuanDrawBackService.doWeiQuanInvite(orderId);

      }



      if (hbIdList.size() > 0)

         recieveHongBaoIds.addAll(hbIdList);

      hbIdList.clear();

      drawBackOrders.clear();



@@ -807,6 +815,8 @@


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

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

            if (hbIdList.size() > 0)

               recieveHongBaoIds.addAll(hbIdList);

         } catch (UserMoneyDetailException e) {

            try {

               LogHelper.errorDetailInfo(e);

@@ -823,6 +833,16 @@
            taoBaoWeiQuanDrawBackService.doWeiQuanShare(orderId);

      }



      // 所有的返利到账红包ID

      for (Long hongBaoId : recieveHongBaoIds) {

         try {

            HongBaoRecieveCMQManager.getInstance().addHongBaoRecieveMsg(hongBaoId);

         } catch (Exception e) {

            LogHelper.errorDetailInfo(e);

         }



      }



   }



   @Transactional(propagation = Propagation.REQUIRED, rollbackFor = Exception.class)