维护信息查询bug

yujian

2019-08-28 fd9e6797ea4efbed1680287eab16c26f7edeeab4

 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<>();

      /**

       * 处理邀请赚订单

       */

@@ -574,14 +581,14 @@
      List<Integer> types = new ArrayList<>();

      types.add(HongBaoV2.TYPE_YIJI);

      types.add(HongBaoV2.TYPE_ERJI);

      long count=   hongBaoV2Mapper.countCanBalanceHongBaoByTypeAndUid(types, uid);

      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);

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

      long count = hongBaoV2Mapper.countCanBalanceHongBaoByTypeAndUid(types, uid);

      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);

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

            hongBaoList.addAll(tempHongBaoList);

      }

      // 灰度测试中，京东/拼多多订单分享/邀请订单不返利

@@ -660,8 +667,8 @@
      types.clear();

      types.add(HongBaoV2.TYPE_SHARE_YIJI);

      types.add(HongBaoV2.TYPE_SHARE_ERJI);

      //TODO 需要处理超过1w条数据的订单

      List<HongBaoV2> hbList = hongBaoV2Mapper.listCanBalanceHongBaoByTypeAndUid(types, uid,0, 10000);

      // TODO 需要处理超过1w条数据的订单

      List<HongBaoV2> hbList = hongBaoV2Mapper.listCanBalanceHongBaoByTypeAndUid(types, uid, 0, 10000);



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

         totalHongBaoList.addAll(hbList);

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

            taoBaoWeiQuanDrawBackService.doWeiQuanInvite(orderId);

      }



      if (hbIdList.size() > 0)

         recieveHongBaoIds.addAll(hbIdList);

      hbIdList.clear();

      drawBackOrders.clear();



@@ -745,8 +753,8 @@
      // 查询UID的分享赚订单

      types.clear();

      types.add(HongBaoV2.TYPE_SHARE_GOODS);

      //TODO 需要处理超过10000条数据的订单

      List<HongBaoV2> hongBaoShareList = hongBaoV2Mapper.listCanBalanceHongBaoByTypeAndUid(types, uid,0, 10000);

      // TODO 需要处理超过10000条数据的订单

      List<HongBaoV2> hongBaoShareList = hongBaoV2Mapper.listCanBalanceHongBaoByTypeAndUid(types, uid, 0, 10000);

      for (HongBaoV2 hongBao : hongBaoShareList) {

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

         hongBao = filterWeiQuanINGHongBao(hongBao);

@@ -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)