yujian
2019-08-23 89e89fe2b2a1578a94b2e2c8ee81efbfbbf85f08
fanli/src/main/java/com/yeshi/fanli/service/impl/integral/IntegralGetServiceImpl.java
@@ -5,13 +5,18 @@
import javax.annotation.Resource;
import org.springframework.cache.annotation.Cacheable;
import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Service;
import com.yeshi.fanli.entity.bus.user.UserInfo;
import com.yeshi.fanli.entity.integral.IntegralTask;
import com.yeshi.fanli.entity.integral.IntegralTask.FrequencyEnum;
import com.yeshi.fanli.entity.integral.IntegralTask.TaskUniqueKeyEnum;
import com.yeshi.fanli.entity.integral.IntegralTaskRecord;
import com.yeshi.fanli.exception.integral.IntegralGetException;
import com.yeshi.fanli.exception.integral.IntegralTaskRecordException;
import com.yeshi.fanli.log.LogHelper;
import com.yeshi.fanli.service.inter.hongbao.ThreeSaleSerivce;
import com.yeshi.fanli.service.inter.integral.IntegralGetService;
import com.yeshi.fanli.service.inter.integral.IntegralTaskRecordService;
import com.yeshi.fanli.service.inter.integral.IntegralTaskService;
@@ -27,6 +32,9 @@
   @Resource
   private IntegralTaskRecordService integralTaskRecordService;
   @Resource
   private ThreeSaleSerivce threeSaleSerivce;
   @Resource
   private RedisManager redisManager;
@@ -59,10 +67,19 @@
      record.setUid(uid);
      try {
         return integralTaskRecordService.addRecord(record);
          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":
@@ -89,7 +106,7 @@
   }
   @Cacheable(value = "integralGetCache", key = "'addSearchResultScan-'+#uid+'-'+kw")
   @Cacheable(value = "integralGetCache", key = "'addSearchResultScan-'+#uid+'-'+#kw")
   @Override
   public void addSearchResultScan(Long uid, String kw) throws IntegralGetException {
      System.out.println("搜索");
@@ -105,6 +122,28 @@
      // TODO Auto-generated method stub
   }
   @Async()
   private void addInShopLevelOne(Long uid) {
      try {
         addEventStatistic(uid, TaskUniqueKeyEnum.inShopLevelOne.name(), null);
         UserInfo boss = threeSaleSerivce.getBoss(uid);
         if (boss != null)
            addInShopLevelTwo(boss.getId()); // 二级队员
      } catch (Exception e) {
         LogHelper.errorDetailInfo(e);
      }
   }
   @Async()
   private void addInShopLevelTwo(Long uid) {
      try {
         addEventStatistic(uid, TaskUniqueKeyEnum.inShopLevelTwo.name(), null);
      } catch (Exception e) {
         LogHelper.errorDetailInfo(e);
      }
   }
   @Override
   public void addScanPushHistory(Long uid) throws IntegralGetException {
@@ -136,4 +175,310 @@
   }
   @Async()
   @Override
   public void addTaoLiJinBuy(Long uid, Long goodsId) {
      try {
         addEventStatistic(uid, TaskUniqueKeyEnum.taoLiJinBuy.name(), null);
      } catch (Exception e) {
         LogHelper.errorDetailInfo(e);
      }
   }
   @Async()
   @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());
      } catch (Exception e) {
         LogHelper.errorDetailInfo(e);
      }
   }
   /**
    * 间接邀请
    * @param uid
    */
   @Async()
   private void addInviteLevelTwo(Long uid) {
      try {
         addEventStatistic(uid, TaskUniqueKeyEnum.inviteLevelTwo.name(), null);
      } catch (Exception e) {
         LogHelper.errorDetailInfo(e);
      }
   }
   @Async()
   @Override
   public void addShareSingleGoods(Long uid) {
      try {
         addEventStatistic(uid, TaskUniqueKeyEnum.shareSingleGoods.name(), null);
      } catch (Exception e) {
         LogHelper.errorDetailInfo(e);
      }
   }
   @Async()
   @Override
   public void addShareMultipleGoods(Long uid) {
      try {
         addEventStatistic(uid, TaskUniqueKeyEnum.shareMultipleGoods.name(), null);
      } catch (Exception e) {
         LogHelper.errorDetailInfo(e);
      }
   }
   @Async()
   @Override
   public void addShareTLJGoods(Long uid) {
      try {
         addEventStatistic(uid, TaskUniqueKeyEnum.shareTLJGoods.name(), null);
      } catch (Exception e) {
         LogHelper.errorDetailInfo(e);
      }
   }
   @Async()
   @Override
   public void addGiveRebateCoupon(Long uid) {
      try {
         addEventStatistic(uid, TaskUniqueKeyEnum.giveRebateCoupon.name(), null);
      } catch (Exception e) {
         LogHelper.errorDetailInfo(e);
      }
   }
   @Async()
   @Override
   public void addGiveFreeCoupon(Long uid) {
      try {
         addEventStatistic(uid, TaskUniqueKeyEnum.giveFreeCoupon.name(), null);
      } catch (Exception e) {
         LogHelper.errorDetailInfo(e);
      }
   }
   @Async()
   @Override
   public void addGiveTaoLiJin(Long uid) {
      try {
         addEventStatistic(uid, TaskUniqueKeyEnum.giveTaoLiJin.name(), null);
      } catch (Exception e) {
         LogHelper.errorDetailInfo(e);
      }
   }
   @Async()
   @Override
   public void addCloseRecommendGoods(Long uid) {
      try {
         addEventStatistic(uid, TaskUniqueKeyEnum.closeRecommendGoods.name(), null);
      } catch (Exception e) {
         LogHelper.errorDetailInfo(e);
      }
   }
   @Async()
   @Override
   public void addCouponRebate(Long uid) {
      try {
         addEventStatistic(uid, TaskUniqueKeyEnum.couponRebate.name(), null);
         UserInfo boss = threeSaleSerivce.getBoss(uid);
         if (boss != null)
            addCouponRebateLevelOne(boss.getId());
      } catch (Exception e) {
         LogHelper.errorDetailInfo(e);
      }
   }
   /**
    * 一级队员领券返利
    * @param 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()); // 二级队员
      } catch (Exception e) {
         LogHelper.errorDetailInfo(e);
      }
   }
   /**
    *  二级队员领券返利
    * @param uid
    */
   @Async()
   private void addCouponRebateLevelTwo(Long uid) {
      try {
         addEventStatistic(uid, TaskUniqueKeyEnum.couponRebateLevelTwo.name(), null);
      } catch (Exception e) {
         LogHelper.errorDetailInfo(e);
      }
   }
   @Async()
   @Override
   public void addRebateOrder(Long uid) {
      try {
         addEventStatistic(uid, TaskUniqueKeyEnum.rebateOrder.name(), null);
         UserInfo boss = threeSaleSerivce.getBoss(uid);
         if (boss != null)
            addInviteOrderLevelOne(boss.getId());
      } catch (Exception e) {
         LogHelper.errorDetailInfo(e);
      }
   }
   /**
    * 一级队员邀请订单
    * @param 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());
      } catch (Exception e) {
         LogHelper.errorDetailInfo(e);
      }
   }
   /**
    * 二级队员邀请订单
    * @param uid
    */
   @Async()
   private void addInviteOrderLevelTwo(Long uid) {
      try {
         addEventStatistic(uid, TaskUniqueKeyEnum.inviteOrderLevelTwo.name(), null);
      } catch (Exception e) {
         LogHelper.errorDetailInfo(e);
      }
   }
   @Async()
   @Override
   public void addShareOrder(Long uid) {
      try {
         addEventStatistic(uid, TaskUniqueKeyEnum.shareOrder.name(), null);
      } catch (Exception e) {
         LogHelper.errorDetailInfo(e);
      }
   }
   @Async()
   @Override
   public void addBindWeiXin(Long uid) {
      try {
         addEventStatistic(uid, TaskUniqueKeyEnum.bindWeiXin.name(), null);
      } catch (Exception e) {
         LogHelper.errorDetailInfo(e);
      }
   }
   @Async()
   @Override
   public void addBindPhone(Long uid) {
      try {
         addEventStatistic(uid, TaskUniqueKeyEnum.bindPhone.name(), null);
      } catch (Exception e) {
         LogHelper.errorDetailInfo(e);
      }
   }
   @Async()
   @Override
   public void addBindTaoBao(Long uid) {
      try {
         addEventStatistic(uid, TaskUniqueKeyEnum.bindTaoBao.name(), null);
      } catch (Exception e) {
         LogHelper.errorDetailInfo(e);
      }
   }
   @Async()
   @Override
   public void addSetWeiXinNum(Long uid) {
      try {
         addEventStatistic(uid, TaskUniqueKeyEnum.setWeiXinNum.name(), null);
      } catch (Exception e) {
         LogHelper.errorDetailInfo(e);
      }
   }
   @Async()
   @Override
   public void addSetGender(Long uid) {
      try {
         addEventStatistic(uid, TaskUniqueKeyEnum.setGender.name(), null);
      } catch (Exception e) {
         LogHelper.errorDetailInfo(e);
      }
   }
   @Async()
   @Override
   public void addSetPortrait(Long uid) {
      try {
         addEventStatistic(uid, TaskUniqueKeyEnum.setPortrait.name(), null);
      } catch (Exception e) {
         LogHelper.errorDetailInfo(e);
      }
   }
   @Async()
   @Override
   public void addSetNickname(Long uid) {
      try {
         addEventStatistic(uid, TaskUniqueKeyEnum.setNickname.name(), null);
      } catch (Exception e) {
         LogHelper.errorDetailInfo(e);
      }
   }
   @Async()
   @Override
   public void addBindAlipay(Long uid) {
      try {
         addEventStatistic(uid, TaskUniqueKeyEnum.bindAlipay.name(), null);
      } catch (Exception e) {
         LogHelper.errorDetailInfo(e);
      }
   }
   @Async()
   @Override
   public void addInviteActivate(Long uid) {
      try {
         addEventStatistic(uid, TaskUniqueKeyEnum.inviteActivate.name(), null);
      } catch (Exception e) {
         LogHelper.errorDetailInfo(e);
      }
   }
}