yujian
2019-08-27 2be98321c477b47f40bb3994b4d7634a2722f335
fanli/src/main/java/com/yeshi/fanli/service/impl/integral/IntegralGetServiceImpl.java
@@ -46,6 +46,13 @@
      IntegralTask task = integralTaskService.getByCidAndUniqueKey(null, event);
      if (task == null)
         throw new IntegralGetException(1, "事件类型不存在");
      if (TaskUniqueKeyEnum.inShop == TaskUniqueKeyEnum.valueOf(event)) {
         UserInfo boss = threeSaleSerivce.getBoss(uid);
         if (boss != null)
            addInShopLevelOne(boss.getId()); // 下级浏览店铺
      }
      if (task.getFrequency() == FrequencyEnum.everyday) {
         int count = integralTaskRecordService.countGetCountByTaskIdAndDay(task.getId(), uid, nowDate);
         if (count >= task.getUpperLimit())
@@ -69,18 +76,10 @@
      try {
          IntegralTaskRecord addRecord = integralTaskRecordService.addRecord(record);
          if (TaskUniqueKeyEnum.inShop == TaskUniqueKeyEnum.valueOf(event)) {
             UserInfo boss = threeSaleSerivce.getBoss(uid);
             if (boss != null)
                addInShopLevelOne(boss.getId()); // 下级浏览店铺
          }
          return addRecord;
      } catch (IntegralTaskRecordException e) {
         throw new IntegralGetException(3, "添加记录失败");
      }
      // switch (event) {
      // case "recommendSearch":
@@ -128,10 +127,11 @@
   @Async()
   private void addInShopLevelOne(Long uid) {
      try {
         addEventStatistic(uid, TaskUniqueKeyEnum.inShopLevelOne.name(), null);
         UserInfo boss = threeSaleSerivce.getBoss(uid);
         if (boss != null) 
            addInShopLevelTwo(boss.getId()); // 二级队员
         addEventStatistic(uid, TaskUniqueKeyEnum.inShopLevelOne.name(), null);
      } catch (Exception e) {
         LogHelper.errorDetailInfo(e);
      }
@@ -146,7 +146,6 @@
         LogHelper.errorDetailInfo(e);
      }
   }
   @Override
   public void addScanPushHistory(Long uid) throws IntegralGetException {
@@ -194,10 +193,11 @@
   @Override
   public void addInviteLevelOne(Long uid, Long workerId) {
      try {
         addEventStatistic(uid, TaskUniqueKeyEnum.inviteLevelOne.name(), null);
         UserInfo boss = threeSaleSerivce.getBoss(uid);
         if (boss != null)
            addInviteLevelTwo(boss.getId());
         addEventStatistic(uid, TaskUniqueKeyEnum.inviteLevelOne.name(), null);
      } catch (Exception e) {
         LogHelper.errorDetailInfo(e);
      }
@@ -205,6 +205,7 @@
   
   /**
    * 间接邀请
    *
    * @param uid
    */
   @IntegralGetVersionLimit(uid="#uid")
@@ -228,7 +229,6 @@
      }
   }
   
   @IntegralGetVersionLimit(uid="#uid")
   @Async()
   @Override
@@ -239,7 +239,6 @@
         LogHelper.errorDetailInfo(e);
      }
   }
   
   @IntegralGetVersionLimit(uid="#uid")
   @Async()
@@ -274,7 +273,6 @@
      }
   }
   
   @IntegralGetVersionLimit(uid="#uid")
   @Async()
   @Override
@@ -285,7 +283,6 @@
         LogHelper.errorDetailInfo(e);
      }
   }
   
   @IntegralGetVersionLimit(uid="#uid")
   @Async()
@@ -303,28 +300,30 @@
   @Override
   public void addCouponRebate(Long uid) {
      try {
         addEventStatistic(uid, TaskUniqueKeyEnum.couponRebate.name(), null);
         UserInfo boss = threeSaleSerivce.getBoss(uid);
         if (boss != null)
            addCouponRebateLevelOne(boss.getId());
         addEventStatistic(uid, TaskUniqueKeyEnum.couponRebate.name(), null);
      } catch (Exception e) {
         LogHelper.errorDetailInfo(e);
      }
   }
   
   /**
    * 一级队员领券返利
    *
    * @param uid
    */
   @IntegralGetVersionLimit(uid="#uid")
   @Async()
   private void addCouponRebateLevelOne(Long uid) {
      try {
         addEventStatistic(uid, TaskUniqueKeyEnum.couponRebateLevelOne.name(), null);
         UserInfo boss = threeSaleSerivce.getBoss(uid);
         if (boss != null)
            addCouponRebateLevelTwo(boss.getId()); // 二级队员
         addEventStatistic(uid, TaskUniqueKeyEnum.couponRebateLevelOne.name(), null);
      } catch (Exception e) {
         LogHelper.errorDetailInfo(e);
      }
@@ -332,6 +331,7 @@
   
   /**
    *  二级队员领券返利
    *
    * @param uid
    */
   @IntegralGetVersionLimit(uid="#uid")
@@ -349,36 +349,38 @@
   @Override
   public void addRebateOrder(Long uid) {
      try {
         addEventStatistic(uid, TaskUniqueKeyEnum.rebateOrder.name(), null);
         UserInfo boss = threeSaleSerivce.getBoss(uid);
         if (boss != null)
            addInviteOrderLevelOne(boss.getId());
         addEventStatistic(uid, TaskUniqueKeyEnum.rebateOrder.name(), null);
      } catch (Exception e) {
         LogHelper.errorDetailInfo(e);
      }
   }
   
   /**
    * 一级队员邀请订单
    *
    * @param uid
    */
   @IntegralGetVersionLimit(uid="#uid")
   @Async()
   private void addInviteOrderLevelOne(Long uid) {
      try {
         addEventStatistic(uid, TaskUniqueKeyEnum.inviteOrderLevelOne.name(), null);
         UserInfo boss = threeSaleSerivce.getBoss(uid);
         if (boss != null)
            addInviteOrderLevelTwo(boss.getId());
         addEventStatistic(uid, TaskUniqueKeyEnum.inviteOrderLevelOne.name(), null);
      } catch (Exception e) {
         LogHelper.errorDetailInfo(e);
      }
   }
   
   /**
    * 二级队员邀请订单
    *
    * @param uid
    */
   @IntegralGetVersionLimit(uid="#uid")
@@ -402,7 +404,6 @@
      }
   }
   
   @IntegralGetVersionLimit(uid="#uid")
   @Async()
   @Override
@@ -424,7 +425,6 @@
         LogHelper.errorDetailInfo(e);
      }
   }
   
   @IntegralGetVersionLimit(uid="#uid")
   @Async()
@@ -459,7 +459,6 @@
      }
   }
   
   @IntegralGetVersionLimit(uid="#uid")
   @Async()
   @Override
@@ -471,7 +470,6 @@
      }
   }
   
   @IntegralGetVersionLimit(uid="#uid")
   @Async()
   @Override
@@ -482,7 +480,6 @@
         LogHelper.errorDetailInfo(e);
      }
   }
   
   @IntegralGetVersionLimit(uid="#uid")
   @Async()