From 822e2bc06f9e95f357867d457c004e7bb1f67db8 Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期一, 26 八月 2019 16:27:15 +0800
Subject: [PATCH] 签到通知
---
fanli/src/main/java/com/yeshi/fanli/service/impl/integral/IntegralGetServiceImpl.java | 384 ++++++++++++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 379 insertions(+), 5 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 8d9442d..44beb06 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
@@ -4,16 +4,24 @@
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;
@@ -25,6 +33,12 @@
@Resource
private IntegralTaskRecordService integralTaskRecordService;
+
+ @Resource
+ private ThreeSaleSerivce threeSaleSerivce;
+
+ @Resource
+ private RedisManager redisManager;
@Override
public IntegralTaskRecord addEventStatistic(Long uid, String event, JSONObject params) throws IntegralGetException {
@@ -54,10 +68,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":
@@ -84,15 +107,14 @@
}
+ @Cacheable(value = "integralGetCache", key = "'addSearchResultScan-'+#uid+'-'+#kw")
@Override
- public void addSearchResultScan(Long uid) throws IntegralGetException {
- // TODO Auto-generated method stub
-
+ public void addSearchResultScan(Long uid, String kw) throws IntegralGetException {
+ System.out.println("鎼滅储");
}
@Override
public void addShareInvite(Long uid) throws IntegralGetException {
- // TODO Auto-generated method stub
}
@@ -101,6 +123,30 @@
// 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)
+ addInShopLevelTwo(boss.getId()); // 浜岀骇闃熷憳
+ } 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
public void addScanPushHistory(Long uid) throws IntegralGetException {
@@ -132,4 +178,332 @@
}
+ @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 {
+ 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
+ */
+ @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 {
+ 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
+ */
+ @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()); // 浜岀骇闃熷憳
+ } 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 {
+ 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
+ */
+ @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());
+ } 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