From dd5b15229cb15459fa7c31ccea77dac28cbfafbd Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期一, 13 四月 2020 10:04:20 +0800
Subject: [PATCH] Merge remote-tracking branch 'origin/div' into div

---
 fanli/src/main/java/com/yeshi/fanli/service/impl/user/invite/UserInviteSeparateServiceImpl.java |  103 +++++++++++++++++++++++++++++++++++++++++++++++++++
 1 files changed, 103 insertions(+), 0 deletions(-)

diff --git a/fanli/src/main/java/com/yeshi/fanli/service/impl/user/invite/UserInviteSeparateServiceImpl.java b/fanli/src/main/java/com/yeshi/fanli/service/impl/user/invite/UserInviteSeparateServiceImpl.java
index d4dec47..2dd4cef 100644
--- a/fanli/src/main/java/com/yeshi/fanli/service/impl/user/invite/UserInviteSeparateServiceImpl.java
+++ b/fanli/src/main/java/com/yeshi/fanli/service/impl/user/invite/UserInviteSeparateServiceImpl.java
@@ -1,14 +1,26 @@
 package com.yeshi.fanli.service.impl.user.invite;
 
+import java.util.Date;
 import java.util.List;
 
 import javax.annotation.Resource;
 
+import org.springframework.context.annotation.Lazy;
 import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+import org.yeshi.utils.DateUtil;
 
 import com.yeshi.fanli.dao.mybatis.user.UserInviteSeparateMapper;
+import com.yeshi.fanli.entity.bus.user.ThreeSale;
+import com.yeshi.fanli.entity.bus.user.UserInfo;
 import com.yeshi.fanli.entity.bus.user.UserInviteSeparate;
+import com.yeshi.fanli.entity.bus.user.vip.UserVIPPreInfo;
+import com.yeshi.fanli.service.inter.user.UserInfoService;
 import com.yeshi.fanli.service.inter.user.UserInviteSeparateService;
+import com.yeshi.fanli.service.inter.user.invite.ThreeSaleSerivce;
+import com.yeshi.fanli.service.inter.user.invite.UserInviteMsgNotificationService;
+import com.yeshi.fanli.service.inter.user.vip.UserVIPPreInfoService;
+import com.yeshi.fanli.service.inter.user.vip.UserVipConfigService;
 
 @Service
 public class UserInviteSeparateServiceImpl implements UserInviteSeparateService {
@@ -16,10 +28,49 @@
 	@Resource
 	private UserInviteSeparateMapper userInviteSeparateMapper;
 	
+	@Resource
+	private UserVipConfigService userVipConfigService;
+	
+	@Lazy
+	@Resource
+	private ThreeSaleSerivce threeSaleSerivce;
+	
+	@Lazy
+	@Resource
+	private UserVIPPreInfoService userVIPPreInfoService;
+	
+	@Lazy
+	@Resource
+	private UserInfoService userInfoService;
+	
+	@Lazy
+	@Resource
+	private UserInviteMsgNotificationService userInviteMsgNotificationService;
 
 	@Override
 	public void insertSelective(UserInviteSeparate record) {
 		userInviteSeparateMapper.insertSelective(record);
+	}
+	
+	
+	@Override
+	@Transactional(rollbackFor = Exception.class)
+	public void addPreSeparateRecord(Long workerId, Long bossId) {
+		// 鏇存柊涔嬪墠鐘舵�佸け鏁�
+		userInviteSeparateMapper.updateStateByWorkerIdAndBossId(workerId, bossId, UserInviteSeparate.STATE_INVALID);
+		
+		// 闄愬埗澶╂暟
+		int limitDays = Integer.parseInt(userVipConfigService.getValueByKey("invite_separate_limit_days"));
+		
+		// 淇濆瓨璁板綍
+		UserInviteSeparate inviteSeparate = new UserInviteSeparate();
+		inviteSeparate.setBossId(bossId);
+		inviteSeparate.setWorkerId(workerId);
+		inviteSeparate.setState(UserInviteSeparate.STATE_INIT);
+		inviteSeparate.setEndTime(DateUtil.plusDayDate(limitDays, new Date()));
+		inviteSeparate.setCreateTime(new Date());
+		inviteSeparate.setUpdateTime(new Date());
+		userInviteSeparateMapper.insertSelective(inviteSeparate);
 	}
 	
 	@Override
@@ -42,4 +93,56 @@
 		return userInviteSeparateMapper.getHandleOverdue(start, count);
 	}
 	
+	
+	@Override
+	@Transactional(rollbackFor = Exception.class)
+	public void inviteSeparate(UserInviteSeparate record) {
+		if (record == null)
+			return;
+
+		Long workerId = record.getWorkerId();
+		Long bossId = record.getBossId();
+		ThreeSale threeSale = threeSaleSerivce.getMyBoss(workerId);
+		if (threeSale == null) {
+			// 鎴愬姛鑴辩 涓嶅彂娑堟伅
+			userInviteSeparateMapper.updateStateByWorkerIdAndBossId(workerId, bossId, UserInviteSeparate.STATE_SUCCESS);
+			return;
+		} 
+		
+		boolean separate = false;
+		UserVIPPreInfo info = userVIPPreInfoService.getVipByProcess(bossId, UserVIPPreInfo.PROCESS_1);
+		if (info == null) {
+			separate = true;
+		} else if (info.getCreateTime().getTime() >= record.getEndTime().getTime()) {
+			separate = true;	 
+		}
+		
+
+		if (!separate) { 
+			// 鏈劚绂�
+			userInviteSeparateMapper.updateStateByWorkerIdAndBossId(workerId, bossId, UserInviteSeparate.STATE_INVALID);
+		} else { 
+			// 鑴辩鍏崇郴
+			userInviteSeparateMapper.updateStateByWorkerIdAndBossId(workerId, bossId, UserInviteSeparate.STATE_SUCCESS);
+			// 鑴辩閭�璇峰叧绯�
+			threeSaleSerivce.inviteSeparate(workerId, bossId);
+
+			
+			UserInfo worker = userInfoService.selectByPKey(workerId);
+			
+			// 鎻愰啋涓婄骇鑴辩
+			userInviteMsgNotificationService.fansDivorced(bossId, worker.getNickName(), new Date());
+			
+			// 鎻愰啋涓婁笂绾ц劚绂�
+			ThreeSale threeSaleSuper = threeSaleSerivce.getMyBoss(bossId);
+			if (threeSaleSuper != null) { // 绮変笣鍗囩骇鎻愰啋
+				Long bossIdSuper = threeSaleSuper.getBoss().getId();
+				UserInfo boss = userInfoService.selectByPKey(workerId);
+				userInviteMsgNotificationService.fansDivorcedIndirect(bossIdSuper, worker.getNickName(),
+						boss.getNickName(), new Date());
+			}
+		}
+	}
+	
+	
 }

--
Gitblit v1.8.0