领取金币

yujian

2019-08-27 2be98321c477b47f40bb3994b4d7634a2722f335

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

@@ -21,6 +21,7 @@
import com.yeshi.fanli.service.inter.integral.IntegralTaskRecordService;

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

import com.yeshi.fanli.util.RedisManager;

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



import net.sf.json.JSONObject;



@@ -32,7 +33,7 @@


   @Resource

   private IntegralTaskRecordService integralTaskRecordService;

	


   @Resource

   private ThreeSaleSerivce threeSaleSerivce;



@@ -45,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())

@@ -67,19 +75,11 @@
      record.setUid(uid);



      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;

         IntegralTaskRecord addRecord = integralTaskRecordService.addRecord(record);

         return addRecord;

      } catch (IntegralTaskRecordException e) {

         throw new IntegralGetException(3, "添加记录失败");

      }

		
		
		


      // switch (event) {

      // case "recommendSearch":

@@ -122,19 +122,22 @@
      // TODO Auto-generated method stub



   }

	


   @IntegralGetVersionLimit(uid = "#uid")

   @Async()

   private void addInShopLevelOne(Long uid) {

      try {

         addEventStatistic(uid, TaskUniqueKeyEnum.inShopLevelOne.name(), null);

         UserInfo boss = threeSaleSerivce.getBoss(uid);

         if (boss != null) 
         if (boss != null)

            addInShopLevelTwo(boss.getId()); // 二级队员



         addEventStatistic(uid, TaskUniqueKeyEnum.inShopLevelOne.name(), null);

      } catch (Exception e) {

         LogHelper.errorDetailInfo(e);

      }

   }

	


   @IntegralGetVersionLimit(uid = "#uid")

   @Async()

   private void addInShopLevelTwo(Long uid) {

      try {

@@ -143,7 +146,6 @@
         LogHelper.errorDetailInfo(e);

      }

   }

	


   @Override

   public void addScanPushHistory(Long uid) throws IntegralGetException {

@@ -175,6 +177,7 @@


   }



   @IntegralGetVersionLimit(uid = "#uid")

   @Async()

   @Override

   public void addTaoLiJinBuy(Long uid, Long goodsId) {

@@ -185,23 +188,27 @@
      }

   }



   @IntegralGetVersionLimit(uid = "#uid")

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

			
         addEventStatistic(uid, TaskUniqueKeyEnum.inviteLevelOne.name(), null);

      } catch (Exception e) {

         LogHelper.errorDetailInfo(e);

      }

   }

	


   /**

    * 间接邀请

    * 
    * @param uid

    */

   @IntegralGetVersionLimit(uid = "#uid")

   @Async()

   private void addInviteLevelTwo(Long uid) {

      try {

@@ -210,7 +217,8 @@
         LogHelper.errorDetailInfo(e);

      }

   }

	


   @IntegralGetVersionLimit(uid = "#uid")

   @Async()

   @Override

   public void addShareSingleGoods(Long uid) {

@@ -220,8 +228,8 @@
         LogHelper.errorDetailInfo(e);

      }

   }

	
	


   @IntegralGetVersionLimit(uid = "#uid")

   @Async()

   @Override

   public void addShareMultipleGoods(Long uid) {

@@ -231,8 +239,8 @@
         LogHelper.errorDetailInfo(e);

      }

   }

	
	


   @IntegralGetVersionLimit(uid = "#uid")

   @Async()

   @Override

   public void addShareTLJGoods(Long uid) {

@@ -242,7 +250,8 @@
         LogHelper.errorDetailInfo(e);

      }

   }

	


   @IntegralGetVersionLimit(uid = "#uid")

   @Async()

   @Override

   public void addGiveRebateCoupon(Long uid) {

@@ -252,8 +261,8 @@
         LogHelper.errorDetailInfo(e);

      }

   }

	
	


   @IntegralGetVersionLimit(uid = "#uid")

   @Async()

   @Override

   public void addGiveFreeCoupon(Long uid) {

@@ -263,8 +272,8 @@
         LogHelper.errorDetailInfo(e);

      }

   }

	
	


   @IntegralGetVersionLimit(uid = "#uid")

   @Async()

   @Override

   public void addGiveTaoLiJin(Long uid) {

@@ -274,8 +283,8 @@
         LogHelper.errorDetailInfo(e);

      }

   }

	
	


   @IntegralGetVersionLimit(uid = "#uid")

   @Async()

   @Override

   public void addCloseRecommendGoods(Long uid) {

@@ -285,42 +294,47 @@
         LogHelper.errorDetailInfo(e);

      }

   }

	
	


   @IntegralGetVersionLimit(uid = "#uid")

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

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

      }

   }

	


   /**

    *  二级队员领券返利

    * 二级队员领券返利

    * 
    * @param uid

    */

   @IntegralGetVersionLimit(uid = "#uid")

   @Async()

   private void addCouponRebateLevelTwo(Long uid) {

      try {

@@ -329,42 +343,47 @@
         LogHelper.errorDetailInfo(e);

      }

   }

	


   @IntegralGetVersionLimit(uid = "#uid")

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

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

   @Async()

   private void addInviteOrderLevelTwo(Long uid) {

      try {

@@ -373,7 +392,8 @@
         LogHelper.errorDetailInfo(e);

      }

   }

	


   @IntegralGetVersionLimit(uid = "#uid")

   @Async()

   @Override

   public void addShareOrder(Long uid) {

@@ -383,8 +403,8 @@
         LogHelper.errorDetailInfo(e);

      }

   }

	
	


   @IntegralGetVersionLimit(uid = "#uid")

   @Async()

   @Override

   public void addBindWeiXin(Long uid) {

@@ -394,7 +414,8 @@
         LogHelper.errorDetailInfo(e);

      }

   }

	


   @IntegralGetVersionLimit(uid = "#uid")

   @Async()

   @Override

   public void addBindPhone(Long uid) {

@@ -404,8 +425,8 @@
         LogHelper.errorDetailInfo(e);

      }

   }

	
	


   @IntegralGetVersionLimit(uid = "#uid")

   @Async()

   @Override

   public void addBindTaoBao(Long uid) {

@@ -415,8 +436,8 @@
         LogHelper.errorDetailInfo(e);

      }

   }

	
	


   @IntegralGetVersionLimit(uid = "#uid")

   @Async()

   @Override

   public void addSetWeiXinNum(Long uid) {

@@ -426,7 +447,8 @@
         LogHelper.errorDetailInfo(e);

      }

   }

	


   @IntegralGetVersionLimit(uid = "#uid")

   @Async()

   @Override

   public void addSetGender(Long uid) {

@@ -436,8 +458,8 @@
         LogHelper.errorDetailInfo(e);

      }

   }

	
	


   @IntegralGetVersionLimit(uid = "#uid")

   @Async()

   @Override

   public void addSetPortrait(Long uid) {

@@ -447,19 +469,19 @@
         LogHelper.errorDetailInfo(e);

      }

   }

	
	


   @IntegralGetVersionLimit(uid = "#uid")

   @Async()

   @Override

   public void addSetNickname(Long uid) {

      try {

         addEventStatistic(uid, TaskUniqueKeyEnum.setNickname.name(), null);

         addEventStatistic(uid, TaskUniqueKeyEnum.setNickName.name(), null);

      } catch (Exception e) {

         LogHelper.errorDetailInfo(e);

      }

   }

	
	


   @IntegralGetVersionLimit(uid = "#uid")

   @Async()

   @Override

   public void addBindAlipay(Long uid) {

@@ -469,8 +491,8 @@
         LogHelper.errorDetailInfo(e);

      }

   }

	
	


   @IntegralGetVersionLimit(uid = "#uid")

   @Async()

   @Override

   public void addInviteActivate(Long uid) {

@@ -480,5 +502,5 @@
         LogHelper.errorDetailInfo(e);

      }

   }

	


}