资金验证优化

admin

2020-08-26 26f7accb815f55f18f8eedfca4324700a96884ec

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

@@ -125,87 +125,7 @@
   public void inviteSettleTB(Long uid, Date maxPregetTime) throws OrderMoneySettleException {

      // 查询UID的一二级邀请赚

      int sourceType = Constant.SOURCE_TYPE_TAOBAO;

      List<Integer> types = new ArrayList<>();

      types.add(HongBaoV2.TYPE_YIJI);

      types.add(HongBaoV2.TYPE_ERJI);

      types.add(HongBaoV2.TYPE_SHARE_YIJI);

      types.add(HongBaoV2.TYPE_SHARE_ERJI);

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

      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, sourceType,

               maxPregetTime, i * 1000, 1000);

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

            hongBaoList.addAll(tempHongBaoList);

      }



      for (int i = 0; i < hongBaoList.size(); i++) {

         HongBaoV2 item = hongBaoList.get(i);

         if (item != null && item.getParent() != null) {

            if (item != null) {

               HongBaoOrder hongBaoOrder = hongBaoOrderMapper.selectByHongBaoId(item.getParent().getId());

               if (hongBaoOrder != null && hongBaoOrder.getCommonOrder() != null) {

                  CommonOrder co = hongBaoOrder.getCommonOrder();

                  // 上级用户不是正常用户，订单均不能到账

                  UserInfo userInfo = userInfoMapper.selectAvailableByPrimaryKey(co.getUserInfo().getId());

                  if (userInfo == null || userInfo.getState() != UserInfo.STATE_NORMAL) {

                     invalidHongBaoForbidden(item.getId());

                     hongBaoList.remove(i);

                     i--;

                  }

               }

            }

         }

      }

		
      if(hongBaoList.size()==0)

         return;



      String taskKey = getTaskKey(uid);



      TeamRewardPreRecieveMQMsg mqMsg = new TeamRewardPreRecieveMQMsg(taskKey, uid, sourceType, maxPregetTime,

            new Date());



      Message msg = MQMsgBodyFactory.create(MQTopicName.TOPIC_ORDER, OrderTopicTagEnum.teamRewardPreRecieved, mqMsg);



      msg.setKey(taskKey);

		
		
      // 添加事务消息

      try {

         orderTransactionProducer.send(msg, new LocalTransactionExecuter() {

            @Override

            public TransactionStatus execute(Message arg0, Object arg1) {

               try {

                  fanliInvite(hongBaoList, uid, Constant.SOURCE_TYPE_TAOBAO, taskKey, maxPregetTime);

               } catch (Exception e) {

                  e.printStackTrace();

                  return TransactionStatus.RollbackTransaction;

               }

               return TransactionStatus.CommitTransaction;

            }

         }, null);

			
//         rocketMQManager.sendTransactionalMsg(msg, taskKey, new RocketMQManager.ITransactionalMQEvent() {

//            @Override

//            public TransactionStatus excute(Message arg0, Object arg1) {

//               try {

//                  fanliInvite(hongBaoList, uid, Constant.SOURCE_TYPE_TAOBAO, taskKey, maxPregetTime);

//               } catch (Exception e) {

//                  e.printStackTrace();

//                  return TransactionStatus.RollbackTransaction;

//               }

//               return TransactionStatus.CommitTransaction;

//            }

//         });

			
      } catch (Exception e) {

         e.printStackTrace();

         LogHelper.mqError(e.getMessage(), msg.getTopic(), msg.getTag(), new Gson().toJson(mqMsg));

      }

      System.out.println(new Gson().toJson(mqMsg));

        inviteSettle(uid,sourceType,maxPregetTime);

   }



   @Transactional(rollbackFor = Exception.class)

@@ -213,68 +133,7 @@
   public void inviteSettleJD(Long uid, Date maxPregetTime) throws OrderMoneySettleException {

      // 查询UID的一二级邀请赚

      int sourceType = Constant.SOURCE_TYPE_JD;

      List<Integer> types = new ArrayList<>();

      types.add(HongBaoV2.TYPE_YIJI);

      types.add(HongBaoV2.TYPE_ERJI);

      types.add(HongBaoV2.TYPE_SHARE_YIJI);

      types.add(HongBaoV2.TYPE_SHARE_ERJI);

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

      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, sourceType,

               maxPregetTime, i * 1000, 1000);

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

            hongBaoList.addAll(tempHongBaoList);

      }



      for (int i = 0; i < hongBaoList.size(); i++) {

         HongBaoV2 item = hongBaoList.get(i);

         if (item != null && item.getParent() != null) {

            if (item != null) {

               HongBaoOrder hongBaoOrder = hongBaoOrderMapper.selectByHongBaoId(item.getParent().getId());

               if (hongBaoOrder != null && hongBaoOrder.getCommonOrder() != null) {

                  CommonOrder co = hongBaoOrder.getCommonOrder();

                  // 上级用户不是正常用户，订单均不能到账

                  UserInfo userInfo = userInfoMapper.selectAvailableByPrimaryKey(co.getUserInfo().getId());

                  if (userInfo == null || userInfo.getState() != UserInfo.STATE_NORMAL) {

                     invalidHongBaoForbidden(item.getId());

                     hongBaoList.remove(i);

                     i--;

                  }

               }

            }

         }

      }

		
      if(hongBaoList.size()==0)

         return;



      // 邀请赚到账事务消息



      String taskKey = getTaskKey(uid);

      TeamRewardPreRecieveMQMsg mqMsg = new TeamRewardPreRecieveMQMsg(taskKey, uid, sourceType, maxPregetTime,

            new Date());

      Message msg = MQMsgBodyFactory.create(MQTopicName.TOPIC_ORDER, OrderTopicTagEnum.teamRewardPreRecieved, mqMsg);

      msg.setKey(taskKey);

      // 添加事务消息

      try {

         orderTransactionProducer.send(msg, new LocalTransactionExecuter() {

            @Override

            public TransactionStatus execute(Message arg0, Object arg1) {

               try {

                  fanliInvite(hongBaoList, uid, sourceType, taskKey, maxPregetTime);

               } catch (Exception e) {

                  e.printStackTrace();

                  return TransactionStatus.RollbackTransaction;

               }

               return TransactionStatus.CommitTransaction;

            }

         }, null);

      } catch (Exception e) {

         LogHelper.mqError(e.getMessage(), msg.getTopic(), msg.getTag(), new Gson().toJson(mqMsg));

      }

        inviteSettle(uid,sourceType,maxPregetTime);

   }



   @Transactional(rollbackFor = Exception.class)

@@ -282,66 +141,7 @@
   public void inviteSettlePDD(Long uid, Date maxPregetTime) throws OrderMoneySettleException {

      // 查询UID的一二级邀请赚

      int sourceType = Constant.SOURCE_TYPE_PDD;

      List<Integer> types = new ArrayList<>();

      types.add(HongBaoV2.TYPE_YIJI);

      types.add(HongBaoV2.TYPE_ERJI);

      types.add(HongBaoV2.TYPE_SHARE_YIJI);

      types.add(HongBaoV2.TYPE_SHARE_ERJI);

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

      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, sourceType,

               maxPregetTime, i * 1000, 1000);

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

            hongBaoList.addAll(tempHongBaoList);

      }



      for (int i = 0; i < hongBaoList.size(); i++) {

         HongBaoV2 item = hongBaoList.get(i);

         if (item != null && item.getParent() != null) {

            if (item != null) {

               HongBaoOrder hongBaoOrder = hongBaoOrderMapper.selectByHongBaoId(item.getParent().getId());

               if (hongBaoOrder != null && hongBaoOrder.getCommonOrder() != null) {

                  CommonOrder co = hongBaoOrder.getCommonOrder();

                  // 上级用户不是正常用户，订单均不能到账

                  UserInfo userInfo = userInfoMapper.selectAvailableByPrimaryKey(co.getUserInfo().getId());

                  if (userInfo == null || userInfo.getState() != UserInfo.STATE_NORMAL) {

                     invalidHongBaoForbidden(item.getId());

                     hongBaoList.remove(i);

                     i--;

                  }

               }

            }

         }

      }

		
      if(hongBaoList.size()==0)

         return;



      // 邀请赚到账事务消息

      String taskKey = getTaskKey(uid);

      TeamRewardPreRecieveMQMsg mqMsg = new TeamRewardPreRecieveMQMsg(taskKey, uid, sourceType, maxPregetTime,

            new Date());

      Message msg = MQMsgBodyFactory.create(MQTopicName.TOPIC_ORDER, OrderTopicTagEnum.teamRewardPreRecieved, mqMsg);

      msg.setKey(taskKey);

      // 添加事务消息

      try {

         orderTransactionProducer.send(msg, new LocalTransactionExecuter() {

            @Override

            public TransactionStatus execute(Message arg0, Object arg1) {

               try {

                  fanliInvite(hongBaoList, uid, sourceType, taskKey, maxPregetTime);

               } catch (Exception e) {

                  return TransactionStatus.RollbackTransaction;

               }

               return TransactionStatus.CommitTransaction;

            }

         }, null);

      } catch (Exception e) {

         LogHelper.mqError(e.getMessage(), msg.getTopic(), msg.getTag(), new Gson().toJson(mqMsg));

      }

        inviteSettle(uid,sourceType,maxPregetTime);

   }



   @Transactional(rollbackFor = Exception.class)

@@ -349,6 +149,21 @@
   public void inviteSettleVipShop(Long uid, Date maxPregetTime) throws OrderMoneySettleException {

      // 查询UID的一二级邀请赚

      int sourceType = Constant.SOURCE_TYPE_VIP;

        inviteSettle(uid,sourceType,maxPregetTime);

    }





    @Transactional(rollbackFor = Exception.class)

    @Override

    public void inviteSettleSuning(Long uid, Date maxPregetTime) throws OrderMoneySettleException {

        // 查询UID的一二级邀请赚

        int sourceType = Constant.SOURCE_TYPE_SUNING;

        inviteSettle(uid,sourceType,maxPregetTime);

    }





    private void inviteSettle(Long uid, int sourceType, Date maxPregetTime) throws OrderMoneySettleException {

        // 查询UID的一二级邀请赚

      List<Integer> types = new ArrayList<>();

      types.add(HongBaoV2.TYPE_YIJI);

      types.add(HongBaoV2.TYPE_ERJI);

@@ -501,16 +316,22 @@
   @Transactional(rollbackFor = Exception.class)

   @Override

   public void shareSettlePDD(Long uid, Date maxPregetTime) throws OrderMoneySettleException {

      shareSettleVipShop(Constant.SOURCE_TYPE_PDD, uid, maxPregetTime);

        shareSettle(Constant.SOURCE_TYPE_PDD, uid, maxPregetTime);

   }



   @Transactional(rollbackFor = Exception.class)

   @Override

   public void shareSettleVipShop(Long uid, Date maxPregetTime) throws OrderMoneySettleException {

      shareSettleVipShop(Constant.SOURCE_TYPE_VIP, uid, maxPregetTime);

        shareSettle(Constant.SOURCE_TYPE_VIP, uid, maxPregetTime);

   }



   private void shareSettleVipShop(int sourceType, Long uid, Date maxPregetTime) throws OrderMoneySettleException {

    @Transactional(rollbackFor = Exception.class)

    @Override

    public void shareSettleSuning(Long uid, Date maxPregetTime) throws OrderMoneySettleException {

        shareSettle(Constant.SOURCE_TYPE_SUNING, uid, maxPregetTime);

    }



    private void shareSettle(int sourceType, Long uid, Date maxPregetTime) throws OrderMoneySettleException {

      /**

       * 处理分享赚

       */

@@ -695,7 +516,6 @@
      return hongBao;

   }



   @Transactional

   private void fanliInvite(List<HongBaoV2> hongBaoList, Long uid, int sourceType, String key, Date maxPreGetTime)

         throws TeamEincomeRecordException, ParamsException, TeamRewardDebtException {

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

@@ -722,7 +542,7 @@
            HongBaoV2 updateHongBao = new HongBaoV2();

            updateHongBao.setId(hongBao.getId());

            updateHongBao.setGetTime(new Date());

            updateHongBao.setState(HongBaoV2.STATE_YILINGQU);

                updateHongBao.setState(HongBaoV2.STATE_LINGQUING);

            updateHongBao.setUpdateTime(new Date());

            hongBaoV2Mapper.updateByPrimaryKeySelective(updateHongBao);

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