加入任务

admin

2019-09-06 2012b3b5db3c6b06535a68f775bcc81b16151b90

 fanli/src/main/java/com/yeshi/fanli/service/impl/integral/IntegralGetServiceImpl.java

@@ -10,16 +10,21 @@


import com.yeshi.fanli.dao.mybatis.ThreeSaleMapper;

import com.yeshi.fanli.entity.bus.user.UserInfo;

import com.yeshi.fanli.entity.bus.user.UserInfoExtra;

import com.yeshi.fanli.entity.bus.user.UserRank;

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.IntegralTaskRank;

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.integral.IntegralGetService;

import com.yeshi.fanli.service.inter.integral.IntegralTaskRankService;

import com.yeshi.fanli.service.inter.integral.IntegralTaskRecordService;

import com.yeshi.fanli.service.inter.integral.IntegralTaskService;

import com.yeshi.fanli.service.inter.user.UserInfoExtraService;

import com.yeshi.fanli.util.RedisManager;

import com.yeshi.fanli.util.annotation.integral.IntegralGetFrequencyLimit;

import com.yeshi.fanli.util.annotation.integral.IntegralGetVersionLimit;

@@ -39,6 +44,12 @@


   @Resource

   private RedisManager redisManager;



   @Resource

   private UserInfoExtraService userInfoExtraService;



   @Resource

   private IntegralTaskRankService integralTaskRankService;



   // TODO 有bug

   private UserInfo getBossByUid(Long uid) {

@@ -69,9 +80,30 @@
            throw new IntegralGetException(2, "事件触发达到上限");

      }



      UserInfoExtra userInfoExtra = userInfoExtraService.getUserInfoExtra(uid);

      if (userInfoExtra == null)

         throw new IntegralGetException(2, "额外信息不存在");



      UserRank userRank = userInfoExtra.getUserRank();

      if (userRank == null)

         throw new IntegralGetException(2, "等级信息不存在");



      int goldCoin = task.getGoldCoin();

      if (task.getDoubleNum() != null && task.getDoubleNum() > 0)

         goldCoin = task.getDoubleNum() * goldCoin;



      Long taskId = task.getId();

      IntegralTaskRank traskRank = integralTaskRankService.getByTsakIdAndRankId(taskId, userRank.getId());

      if (traskRank != null) {

         Integer addCoin = traskRank.getAddCoin();

         if (addCoin != null && addCoin > 0)

            goldCoin += addCoin;



         Integer doubleNum = traskRank.getDoubleNum();

         if (doubleNum != null && doubleNum > 0) {

            goldCoin = goldCoin * doubleNum;

         }

      }



      IntegralTaskRecord record = new IntegralTaskRecord();

      record.setCid(task.getTaskClass().getId());

@@ -110,8 +142,8 @@


      return null;

   }



   @IntegralGetFrequencyLimit(key = "'addShareInvite-'+#uid")

	
   @IntegralGetFrequencyLimit(key = "'addShareInvite-'+#uid", time = 30)

   @Override

   public IntegralTaskRecord addShareInvite(Long uid) {

      try {

@@ -214,6 +246,7 @@
   }



   @IntegralGetVersionLimit(uid = "#uid")

   @IntegralGetFrequencyLimit(key = "'taoLiJinBuy-'+#uid", time = 30)

   @Async()

   @Override

   public void addTaoLiJinBuy(Long uid, Long goodsId) {

@@ -255,6 +288,7 @@
   }



   @IntegralGetVersionLimit(uid = "#uid")

   @IntegralGetFrequencyLimit(key = "'shareSingleGoods-'+#uid", time = 45)

   @Async()

   @Override

   public void addShareSingleGoods(Long uid) {

@@ -266,6 +300,7 @@
   }



   @IntegralGetVersionLimit(uid = "#uid")

   @IntegralGetFrequencyLimit(key = "'shareMultipleGoods-'+#uid", time = 45)

   @Async()

   @Override

   public void addShareMultipleGoods(Long uid) {

@@ -277,6 +312,7 @@
   }



   @IntegralGetVersionLimit(uid = "#uid")

   @IntegralGetFrequencyLimit(key = "'shareTLJGoods-'+#uid", time = 45)

   @Async()

   @Override

   public void addShareTLJGoods(Long uid) {

@@ -321,6 +357,7 @@
   }



   @IntegralGetVersionLimit(uid = "#uid")

   @IntegralGetFrequencyLimit(key = "'closeRecommendGoods-'+#uid", time = 30)

   @Async()

   @Override

   public void addCloseRecommendGoods(Long uid) {

@@ -332,6 +369,7 @@
   }



   @IntegralGetVersionLimit(uid = "#uid")

   @IntegralGetFrequencyLimit(key = "'couponRebate-'+#uid", time = 30)

   @Async()

   @Override

   public void addCouponRebate(Long uid) {

@@ -385,10 +423,6 @@
   @Override

   public void addRebateOrder(Long uid) {

      try {

         UserInfo boss = getBossByUid(uid);

         if (boss != null)

            addInviteOrderLevelOne(boss.getId());



         addEventStatistic(uid, TaskUniqueKeyEnum.rebateOrder.name());

      } catch (Exception e) {

         LogHelper.errorDetailInfo(e);

@@ -402,12 +436,9 @@
    */

   @IntegralGetVersionLimit(uid = "#uid")

   @Async()

   private void addInviteOrderLevelOne(Long uid) {

   @Override

   public void addInviteOrderLevelOne(Long uid) {

      try {

         UserInfo boss = getBossByUid(uid);

         if (boss != null)

            addInviteOrderLevelTwo(boss.getId());



         addEventStatistic(uid, TaskUniqueKeyEnum.inviteOrderLevelOne.name());

      } catch (Exception e) {

         LogHelper.errorDetailInfo(e);

@@ -421,7 +452,8 @@
    */

   @IntegralGetVersionLimit(uid = "#uid")

   @Async()

   private void addInviteOrderLevelTwo(Long uid) {

   @Override

   public void addInviteOrderLevelTwo(Long uid) {

      try {

         addEventStatistic(uid, TaskUniqueKeyEnum.inviteOrderLevelTwo.name());

      } catch (Exception e) {