From 348da0f1093bc6d83e91dc19a76122f1b5ecea5a Mon Sep 17 00:00:00 2001
From: yj <Administrator@192>
Date: 星期日, 15 三月 2020 19:51:28 +0800
Subject: [PATCH] 会员等级

---
 fanli/src/main/java/com/yeshi/fanli/service/impl/user/vip/UserVIPPreInfoServiceImpl.java |  130 +++++++++++++++++++++++++++++++++++++++++++
 1 files changed, 130 insertions(+), 0 deletions(-)

diff --git a/fanli/src/main/java/com/yeshi/fanli/service/impl/user/vip/UserVIPPreInfoServiceImpl.java b/fanli/src/main/java/com/yeshi/fanli/service/impl/user/vip/UserVIPPreInfoServiceImpl.java
index 33d69e1..4ca3a02 100644
--- a/fanli/src/main/java/com/yeshi/fanli/service/impl/user/vip/UserVIPPreInfoServiceImpl.java
+++ b/fanli/src/main/java/com/yeshi/fanli/service/impl/user/vip/UserVIPPreInfoServiceImpl.java
@@ -8,17 +8,34 @@
 import javax.annotation.Resource;
 
 import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
 
 import com.yeshi.fanli.dao.mybatis.user.vip.UserVIPPreInfoMapper;
+import com.yeshi.fanli.entity.bus.user.HongBaoV2;
+import com.yeshi.fanli.entity.bus.user.vip.UserVIPInfo;
 import com.yeshi.fanli.entity.bus.user.vip.UserVIPPreInfo;
 import com.yeshi.fanli.exception.user.vip.UserVIPPreInfoException;
+import com.yeshi.fanli.service.inter.count.HongBaoV2CountService;
+import com.yeshi.fanli.service.inter.user.invite.ThreeSaleSerivce;
+import com.yeshi.fanli.service.inter.user.vip.UserVIPInfoService;
 import com.yeshi.fanli.service.inter.user.vip.UserVIPPreInfoService;
+import com.yeshi.fanli.util.Constant;
+import com.yeshi.fanli.util.annotation.RequestSerializableByKeyService;
 
 @Service
 public class UserVIPPreInfoServiceImpl implements UserVIPPreInfoService {
 
 	@Resource
 	private UserVIPPreInfoMapper userVIPPreInfoMapper;
+	
+	@Resource
+	private HongBaoV2CountService hongBaoV2CountService;
+	
+	@Resource
+	private ThreeSaleSerivce threeSaleSerivce;
+	
+	@Resource
+	private UserVIPInfoService userVIPInfoService;
 
 	@Override
 	public void addUserVIPPreInfo(UserVIPPreInfo info) throws UserVIPPreInfoException {
@@ -51,4 +68,117 @@
 		return infoList.get(0);
 	}
 
+	
+	@RequestSerializableByKeyService(key = "#uid")
+	@Transactional(rollbackFor = Exception.class)
+	@Override
+	public void verifyVipCondition(Long uid) {
+		if (uid == null || uid <= 0)
+			return;
+		
+		// 楠岃瘉鏄惁VIP
+		boolean vip = userVIPInfoService.isVIP(uid);
+		if (vip) {
+			return;
+		}
+		
+		// 閭�璇疯鍗�
+		long countZiGou = hongBaoV2CountService.counOrderByUidAndOrderType(uid, Constant.VIP_ORDER_PAY, HongBaoV2.TYPE_ZIGOU);
+		// 閭�璇疯鍗�
+		long countShare = hongBaoV2CountService.counOrderByUidAndOrderType(uid, Constant.VIP_ORDER_PAY, HongBaoV2.TYPE_SHARE_GOODS);
+		// 闃熷憳
+		long firstTeam = threeSaleSerivce.countFirstTeam(uid, 1);
+		long secondTeam = threeSaleSerivce.countSecondTeam(uid, 1);
+		
+		// 涓�闃舵
+		boolean process1 = oneProcess(uid, countZiGou, countShare, firstTeam, secondTeam);
+		if (!process1) {
+			return;
+		}
+		
+		// 涓�闃舵
+		boolean process2 = twoProcess(uid, countZiGou, countShare, firstTeam, secondTeam);
+		if (!process2) {
+			return;
+		}
+				
+		vipProcess(uid, countZiGou, countShare, firstTeam, secondTeam);
+	}
+	
+	/**
+	 * 涓�闃舵
+	 * @param uid
+	 * @param countZiGou
+	 * @param countShare
+	 * @param firstTeam
+	 * @param secondTeam
+	 */
+	private boolean oneProcess(Long uid, long countZiGou, long countShare, long firstTeam, long secondTeam) {
+		UserVIPPreInfo oldInfo = userVIPPreInfoMapper.selectByUidAndProcess(uid, UserVIPPreInfo.PROCESS_1);
+		if (oldInfo != null) {
+			return true;
+		}
+		
+		if (countZiGou >= Constant.VIP_PROCESS_1_ZIGOU || countShare >= Constant.VIP_PROCESS_1_SHARE
+				|| (firstTeam >= Constant.VIP_PROCESS_1_TEAM && secondTeam >= Constant.VIP_PROCESS_1_TEAM_SECOND)) {
+			UserVIPPreInfo info = new UserVIPPreInfo();
+			info.setUid(uid);
+			info.setProcess(UserVIPPreInfo.PROCESS_1);
+			info.setCreateTime(new Date());
+			info.setUpdateTime(new Date());
+			userVIPPreInfoMapper.insertSelective(info);
+			return true;
+		}
+		return false;
+	}
+	
+	
+	/**
+	 * 涓�闃舵
+	 * @param uid
+	 * @param countZiGou
+	 * @param countShare
+	 * @param firstTeam
+	 * @param secondTeam
+	 */
+	private boolean twoProcess(Long uid, long countZiGou, long countShare, long firstTeam, long secondTeam) {
+		UserVIPPreInfo oldInfo = userVIPPreInfoMapper.selectByUidAndProcess(uid, UserVIPPreInfo.PROCESS_2);
+		if (oldInfo != null) {
+			return true;
+		}
+		
+		if (countZiGou >= Constant.VIP_PROCESS_2_ZIGOU || countShare >= Constant.VIP_PROCESS_2_SHARE
+				|| (firstTeam >= Constant.VIP_PROCESS_2_TEAM && secondTeam >= Constant.VIP_PROCESS_2_TEAM_SECOND)) {
+			UserVIPPreInfo info = new UserVIPPreInfo();
+			info.setUid(uid);
+			info.setProcess(UserVIPPreInfo.PROCESS_2);
+			info.setCreateTime(new Date());
+			info.setUpdateTime(new Date());
+			userVIPPreInfoMapper.insertSelective(info);
+			return true;
+		}
+		return false;
+	}
+	
+	
+	/**
+	 * 涓�闃舵
+	 * @param uid
+	 * @param countZiGou
+	 * @param countShare
+	 * @param firstTeam
+	 * @param secondTeam
+	 */
+	private boolean vipProcess(Long uid, long countZiGou, long countShare, long firstTeam, long secondTeam) {
+		if (countZiGou >= Constant.VIP_PROCESS_3_ZIGOU || countShare >= Constant.VIP_PROCESS_3_SHARE
+				|| (firstTeam >= Constant.VIP_PROCESS_3_TEAM && secondTeam >= Constant.VIP_PROCESS_3_TEAM_SECOND)) {
+			 
+			
+			
+			return true;
+		}
+		return false;
+	}
+	
+	
 }

--
Gitblit v1.8.0