From 2be98321c477b47f40bb3994b4d7634a2722f335 Mon Sep 17 00:00:00 2001
From: yujian <yujian@123.com>
Date: 星期二, 27 八月 2019 11:16:22 +0800
Subject: [PATCH] 领取金币

---
 fanli/src/main/java/com/yeshi/fanli/service/impl/integral/IntegralGetServiceImpl.java |  150 ++++++++++++++++++++++++++++---------------------
 1 files changed, 86 insertions(+), 64 deletions(-)

diff --git a/fanli/src/main/java/com/yeshi/fanli/service/impl/integral/IntegralGetServiceImpl.java b/fanli/src/main/java/com/yeshi/fanli/service/impl/integral/IntegralGetServiceImpl.java
index f14c15b..160003f 100644
--- a/fanli/src/main/java/com/yeshi/fanli/service/impl/integral/IntegralGetServiceImpl.java
+++ b/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);
 		}
 	}
-	
+
 }

--
Gitblit v1.8.0