From 7e37f77192fa701e309fa04f821aa5fd5259ca33 Mon Sep 17 00:00:00 2001
From: yujian <yujian@163.com>
Date: 星期三, 01 四月 2020 09:28:31 +0800
Subject: [PATCH] 队员列表

---
 fanli/src/main/java/com/yeshi/fanli/service/impl/user/invite/UserInviteValidNumServiceImpl.java |   23 +++++++++--------------
 1 files changed, 9 insertions(+), 14 deletions(-)

diff --git a/fanli/src/main/java/com/yeshi/fanli/service/impl/user/invite/UserInviteValidNumServiceImpl.java b/fanli/src/main/java/com/yeshi/fanli/service/impl/user/invite/UserInviteValidNumServiceImpl.java
index 200a87b..bf9338d 100644
--- a/fanli/src/main/java/com/yeshi/fanli/service/impl/user/invite/UserInviteValidNumServiceImpl.java
+++ b/fanli/src/main/java/com/yeshi/fanli/service/impl/user/invite/UserInviteValidNumServiceImpl.java
@@ -5,8 +5,8 @@
 
 import javax.annotation.Resource;
 
-import org.springframework.context.annotation.Lazy;
 import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
 
 import com.yeshi.fanli.dao.mybatis.user.UserInviteValidNumMapper;
 import com.yeshi.fanli.dao.mybatis.user.UserInviteValidRecordMapper;
@@ -14,7 +14,6 @@
 import com.yeshi.fanli.entity.bus.user.UserInviteValidNum;
 import com.yeshi.fanli.entity.bus.user.UserInviteValidRecord;
 import com.yeshi.fanli.log.LogHelper;
-import com.yeshi.fanli.service.inter.order.CommonOrderService;
 import com.yeshi.fanli.service.inter.user.invite.ThreeSaleSerivce;
 import com.yeshi.fanli.service.inter.user.invite.UserInviteValidNumService;
 import com.yeshi.fanli.util.Constant;
@@ -42,12 +41,14 @@
 	 *  鐩存帴绮変笣 +1
 	 * @param uid
 	 */
+	@Transactional(rollbackFor = Exception.class)
 	private void addNumFirst(Long uid) {
 		UserInviteValidNum inviteValid = userInviteValidNumMapper.selectForUpdate(uid);
 		if (inviteValid != null) {
 			userInviteValidNumMapper.addNumFirst(uid, 1);
 		} else {
 			inviteValid = new UserInviteValidNum();
+			inviteValid.setId(uid);
 			inviteValid.setNumFirst(1);
 			inviteValid.setNumSecond(0);
 			inviteValid.setUpdateTime(new Date());
@@ -59,12 +60,14 @@
 	 *  闂存帴绮変笣 +1
 	 * @param uid
 	 */
+	@Transactional(rollbackFor = Exception.class)
 	private void addNumSecond(Long uid) {
 		UserInviteValidNum inviteValid = userInviteValidNumMapper.selectForUpdate(uid);
 		if (inviteValid != null) {
 			userInviteValidNumMapper.addNumSecond(uid, 1);
 		} else {
 			inviteValid = new UserInviteValidNum();
+			inviteValid.setId(uid);
 			inviteValid.setNumFirst(0);
 			inviteValid.setNumSecond(1);
 			inviteValid.setUpdateTime(new Date());
@@ -73,6 +76,7 @@
 	}
 	
 	@Override
+	@Transactional(rollbackFor = Exception.class)
 	public void addValidTeamNum(Long uid, BigDecimal payment, Date payDate) {
 		if (uid == null || payment == null || payDate == null) {
 			return;
@@ -123,13 +127,14 @@
 				return;
 			}
 			
+			// 闂存帴鍏崇郴
 			Long bossIdSuper = threeSaleSuper.getBoss().getId();
-			String uniqueKeySuper = StringUtil.Md5(bossIdSuper + "#" + bossId + "#" + UserInviteValidRecord.TYPE_TWO);
+			String uniqueKeySuper = StringUtil.Md5(bossIdSuper + "#" + uid + "#" + UserInviteValidRecord.TYPE_TWO);
 			UserInviteValidRecord recordSuper = userInviteValidRecordMapper.selectByUniqueKey(uniqueKeySuper);
 			if (recordSuper == null) {
 				recordSuper = new UserInviteValidRecord();
 				recordSuper.setUid(bossIdSuper);
-				recordSuper.setWorkerId(bossId);
+				recordSuper.setWorkerId(uid);
 				recordSuper.setType(UserInviteValidRecord.TYPE_TWO);
 				recordSuper.setUniqueKey(uniqueKeySuper);
 				recordSuper.setCreateTime(new Date());
@@ -142,15 +147,5 @@
 			LogHelper.error(e);
 		}
 	}
-	
-	
-	
-	
-	
-	
-	
-	
-	
-	
 	 
 }

--
Gitblit v1.8.0