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 | 371 ++++++++++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 369 insertions(+), 2 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 9b69afd..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
@@ -5,17 +5,23 @@
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;
import com.yeshi.fanli.util.RedisManager;
+import com.yeshi.fanli.util.annotation.integral.IntegralGetVersionLimit;
import net.sf.json.JSONObject;
@@ -29,6 +35,9 @@
private IntegralTaskRecordService integralTaskRecordService;
@Resource
+ private ThreeSaleSerivce threeSaleSerivce;
+
+ @Resource
private RedisManager redisManager;
@Override
@@ -37,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())
@@ -59,7 +75,8 @@
record.setUid(uid);
try {
- return integralTaskRecordService.addRecord(record);
+ IntegralTaskRecord addRecord = integralTaskRecordService.addRecord(record);
+ return addRecord;
} catch (IntegralTaskRecordException e) {
throw new IntegralGetException(3, "娣诲姞璁板綍澶辫触");
}
@@ -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("鎼滅储");
@@ -104,6 +121,30 @@
public void addIntoShop(Long uid) throws IntegralGetException {
// TODO Auto-generated method stub
+ }
+
+ @IntegralGetVersionLimit(uid = "#uid")
+ @Async()
+ private void addInShopLevelOne(Long uid) {
+ try {
+ UserInfo boss = threeSaleSerivce.getBoss(uid);
+ 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 {
+ addEventStatistic(uid, TaskUniqueKeyEnum.inShopLevelTwo.name(), null);
+ } catch (Exception e) {
+ LogHelper.errorDetailInfo(e);
+ }
}
@Override
@@ -136,4 +177,330 @@
}
+ @IntegralGetVersionLimit(uid = "#uid")
+ @Async()
+ @Override
+ public void addTaoLiJinBuy(Long uid, Long goodsId) {
+ try {
+ addEventStatistic(uid, TaskUniqueKeyEnum.taoLiJinBuy.name(), null);
+ } catch (Exception e) {
+ LogHelper.errorDetailInfo(e);
+ }
+ }
+
+ @IntegralGetVersionLimit(uid = "#uid")
+ @Async()
+ @Override
+ public void addInviteLevelOne(Long uid, Long workerId) {
+ try {
+ 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 {
+ addEventStatistic(uid, TaskUniqueKeyEnum.inviteLevelTwo.name(), null);
+ } catch (Exception e) {
+ LogHelper.errorDetailInfo(e);
+ }
+ }
+
+ @IntegralGetVersionLimit(uid = "#uid")
+ @Async()
+ @Override
+ public void addShareSingleGoods(Long uid) {
+ try {
+ addEventStatistic(uid, TaskUniqueKeyEnum.shareSingleGoods.name(), null);
+ } catch (Exception e) {
+ LogHelper.errorDetailInfo(e);
+ }
+ }
+
+ @IntegralGetVersionLimit(uid = "#uid")
+ @Async()
+ @Override
+ public void addShareMultipleGoods(Long uid) {
+ try {
+ addEventStatistic(uid, TaskUniqueKeyEnum.shareMultipleGoods.name(), null);
+ } catch (Exception e) {
+ LogHelper.errorDetailInfo(e);
+ }
+ }
+
+ @IntegralGetVersionLimit(uid = "#uid")
+ @Async()
+ @Override
+ public void addShareTLJGoods(Long uid) {
+ try {
+ addEventStatistic(uid, TaskUniqueKeyEnum.shareTLJGoods.name(), null);
+ } catch (Exception e) {
+ LogHelper.errorDetailInfo(e);
+ }
+ }
+
+ @IntegralGetVersionLimit(uid = "#uid")
+ @Async()
+ @Override
+ public void addGiveRebateCoupon(Long uid) {
+ try {
+ addEventStatistic(uid, TaskUniqueKeyEnum.giveRebateCoupon.name(), null);
+ } catch (Exception e) {
+ LogHelper.errorDetailInfo(e);
+ }
+ }
+
+ @IntegralGetVersionLimit(uid = "#uid")
+ @Async()
+ @Override
+ public void addGiveFreeCoupon(Long uid) {
+ try {
+ addEventStatistic(uid, TaskUniqueKeyEnum.giveFreeCoupon.name(), null);
+ } catch (Exception e) {
+ LogHelper.errorDetailInfo(e);
+ }
+ }
+
+ @IntegralGetVersionLimit(uid = "#uid")
+ @Async()
+ @Override
+ public void addGiveTaoLiJin(Long uid) {
+ try {
+ addEventStatistic(uid, TaskUniqueKeyEnum.giveTaoLiJin.name(), null);
+ } catch (Exception e) {
+ LogHelper.errorDetailInfo(e);
+ }
+ }
+
+ @IntegralGetVersionLimit(uid = "#uid")
+ @Async()
+ @Override
+ public void addCloseRecommendGoods(Long uid) {
+ try {
+ addEventStatistic(uid, TaskUniqueKeyEnum.closeRecommendGoods.name(), null);
+ } catch (Exception e) {
+ LogHelper.errorDetailInfo(e);
+ }
+ }
+
+ @IntegralGetVersionLimit(uid = "#uid")
+ @Async()
+ @Override
+ public void addCouponRebate(Long uid) {
+ try {
+ 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 {
+ 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 {
+ addEventStatistic(uid, TaskUniqueKeyEnum.couponRebateLevelTwo.name(), null);
+ } catch (Exception e) {
+ LogHelper.errorDetailInfo(e);
+ }
+ }
+
+ @IntegralGetVersionLimit(uid = "#uid")
+ @Async()
+ @Override
+ public void addRebateOrder(Long uid) {
+ try {
+ 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 {
+ 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 {
+ addEventStatistic(uid, TaskUniqueKeyEnum.inviteOrderLevelTwo.name(), null);
+ } catch (Exception e) {
+ LogHelper.errorDetailInfo(e);
+ }
+ }
+
+ @IntegralGetVersionLimit(uid = "#uid")
+ @Async()
+ @Override
+ public void addShareOrder(Long uid) {
+ try {
+ addEventStatistic(uid, TaskUniqueKeyEnum.shareOrder.name(), null);
+ } catch (Exception e) {
+ LogHelper.errorDetailInfo(e);
+ }
+ }
+
+ @IntegralGetVersionLimit(uid = "#uid")
+ @Async()
+ @Override
+ public void addBindWeiXin(Long uid) {
+ try {
+ addEventStatistic(uid, TaskUniqueKeyEnum.bindWeiXin.name(), null);
+ } catch (Exception e) {
+ LogHelper.errorDetailInfo(e);
+ }
+ }
+
+ @IntegralGetVersionLimit(uid = "#uid")
+ @Async()
+ @Override
+ public void addBindPhone(Long uid) {
+ try {
+ addEventStatistic(uid, TaskUniqueKeyEnum.bindPhone.name(), null);
+ } catch (Exception e) {
+ LogHelper.errorDetailInfo(e);
+ }
+ }
+
+ @IntegralGetVersionLimit(uid = "#uid")
+ @Async()
+ @Override
+ public void addBindTaoBao(Long uid) {
+ try {
+ addEventStatistic(uid, TaskUniqueKeyEnum.bindTaoBao.name(), null);
+ } catch (Exception e) {
+ LogHelper.errorDetailInfo(e);
+ }
+ }
+
+ @IntegralGetVersionLimit(uid = "#uid")
+ @Async()
+ @Override
+ public void addSetWeiXinNum(Long uid) {
+ try {
+ addEventStatistic(uid, TaskUniqueKeyEnum.setWeiXinNum.name(), null);
+ } catch (Exception e) {
+ LogHelper.errorDetailInfo(e);
+ }
+ }
+
+ @IntegralGetVersionLimit(uid = "#uid")
+ @Async()
+ @Override
+ public void addSetGender(Long uid) {
+ try {
+ addEventStatistic(uid, TaskUniqueKeyEnum.setGender.name(), null);
+ } catch (Exception e) {
+ LogHelper.errorDetailInfo(e);
+ }
+ }
+
+ @IntegralGetVersionLimit(uid = "#uid")
+ @Async()
+ @Override
+ public void addSetPortrait(Long uid) {
+ try {
+ addEventStatistic(uid, TaskUniqueKeyEnum.setPortrait.name(), null);
+ } catch (Exception e) {
+ LogHelper.errorDetailInfo(e);
+ }
+ }
+
+ @IntegralGetVersionLimit(uid = "#uid")
+ @Async()
+ @Override
+ public void addSetNickname(Long uid) {
+ try {
+ addEventStatistic(uid, TaskUniqueKeyEnum.setNickName.name(), null);
+ } catch (Exception e) {
+ LogHelper.errorDetailInfo(e);
+ }
+ }
+
+ @IntegralGetVersionLimit(uid = "#uid")
+ @Async()
+ @Override
+ public void addBindAlipay(Long uid) {
+ try {
+ addEventStatistic(uid, TaskUniqueKeyEnum.bindAlipay.name(), null);
+ } catch (Exception e) {
+ LogHelper.errorDetailInfo(e);
+ }
+ }
+
+ @IntegralGetVersionLimit(uid = "#uid")
+ @Async()
+ @Override
+ public void addInviteActivate(Long uid) {
+ try {
+ addEventStatistic(uid, TaskUniqueKeyEnum.inviteActivate.name(), null);
+ } catch (Exception e) {
+ LogHelper.errorDetailInfo(e);
+ }
+ }
+
}
--
Gitblit v1.8.0