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/hongbao/ThreeSaleSerivceImpl.java |   64 +++++++++++++++++++-------------
 1 files changed, 38 insertions(+), 26 deletions(-)

diff --git a/fanli/src/main/java/com/yeshi/fanli/service/impl/hongbao/ThreeSaleSerivceImpl.java b/fanli/src/main/java/com/yeshi/fanli/service/impl/hongbao/ThreeSaleSerivceImpl.java
index de660c3..0316022 100644
--- a/fanli/src/main/java/com/yeshi/fanli/service/impl/hongbao/ThreeSaleSerivceImpl.java
+++ b/fanli/src/main/java/com/yeshi/fanli/service/impl/hongbao/ThreeSaleSerivceImpl.java
@@ -18,11 +18,12 @@
 import com.yeshi.fanli.entity.bus.user.ThreeSaleExtraInfo;
 import com.yeshi.fanli.entity.bus.user.UserActiveLog;
 import com.yeshi.fanli.entity.bus.user.UserInfo;
-import com.yeshi.fanli.entity.bus.user.UserInfoExtra;
 import com.yeshi.fanli.exception.ThreeSaleException;
 import com.yeshi.fanli.log.LogHelper;
 import com.yeshi.fanli.service.inter.hongbao.HongBaoManageService;
+import com.yeshi.fanli.service.inter.hongbao.ThreeSaleExtraInfoSerivce;
 import com.yeshi.fanli.service.inter.hongbao.ThreeSaleSerivce;
+import com.yeshi.fanli.service.inter.integral.IntegralGetService;
 import com.yeshi.fanli.service.inter.msg.MsgInviteDetailService;
 import com.yeshi.fanli.service.inter.msg.UserInviteMsgNotificationService;
 import com.yeshi.fanli.service.inter.tlj.UserTaoLiJinOriginService;
@@ -66,6 +67,14 @@
 	
 	@Resource
 	private UserInfoExtraService userInfoExtraService;
+	
+	@Resource
+	private ThreeSaleExtraInfoSerivce threeSaleExtraInfoSerivce;
+	
+	@Resource
+	private IntegralGetService  integralGetService;
+	
+	
 	
 	@Resource(name = "taskExecutor")
 	private TaskExecutor executor;
@@ -345,7 +354,7 @@
 	public List<ThreeSale> listbyIdAndBossId(Long id, Long uid, Integer expire) {
 		return threeSaleMapper.listbyIdAndBossId(id, uid, expire);
 	}
-
+	
 	@Override
 	public JSONObject getMyFirstTeam(long start, int count, Long uid, Integer state) {
 
@@ -356,7 +365,7 @@
 
 		long countTotal = threeSaleMapper.countFirstTeam(uid, state);
 
-		return organizeTeam(countTotal, list, uid);
+		return organizeTeam(countTotal, list);
 	}
 
 	@Override
@@ -368,10 +377,10 @@
 
 		long countTotal = threeSaleMapper.countSecondTeam(uid, state);
 
-		return organizeTeam(countTotal, list, uid);
+		return organizeTeam(countTotal, list);
 	}
 
-	public JSONObject organizeTeam(long count, List<ThreeSale> list, Long uid) {
+	public JSONObject organizeTeam(long count, List<ThreeSale> list) {
 
 		JSONObject result = new JSONObject();
 
@@ -402,18 +411,15 @@
 			object.put("memoName", memoName);
 
 			String nickName = "";
-			Long  workerId= null;
 			String portrait = "";
 			Long lastLoginTime = null;
 
 			UserInfo worker = threeSale.getWorker();
 			if (worker != null) {
-				workerId = worker.getId();
 				portrait = worker.getPortrait();
 				lastLoginTime = worker.getLastLoginTime();
 				nickName = worker.getNickName();
 			}
-			object.put("workerId", workerId);
 			object.put("nickName", nickName);
 			object.put("portrait", portrait);
 
@@ -438,15 +444,8 @@
 					// 寰�骞�
 					contentJson.put("content", "鏈�杩戠櫥褰� " + format.format(lastLoginTime));
 				}
+
 				array.add(contentJson);
-				
-				
-				if (workerId != null) {
-					UserInfoExtra userInfoExtra = userInfoExtraService.getUserInfoExtra(workerId);
-					if (userInfoExtra != null) 
-						object.put("weiXin", userInfoExtra.getWeiXin());
-				}
-				
 
 			} else if (threeSale.getExpire() != null
 					&& (threeSale.getExpire() == 1 || threeSale.getExpire().equals(1))) {
@@ -490,18 +489,13 @@
 			resultArray.add(object);
 		}
 
-		boolean bdWeiXin = false;
-		UserInfoExtra userInfoExtra = userInfoExtraService.getUserInfoExtra(uid);
-		if (userInfoExtra != null && !StringUtil.isNullOrEmpty(userInfoExtra.getWeiXin())) 
-			bdWeiXin = true;
-		
-		result.put("bdWeiXin", bdWeiXin);
 		result.put("count", count);
 		result.put("result_list", resultArray);
 
 		return result;
 	}
-
+	
+	
 	@Override
 	public List<ThreeSale> listByWorkerId(Long workerId) {
 		return threeSaleMapper.listByWorkerId(workerId);
@@ -514,7 +508,7 @@
 
 	@Override
 	@Transactional
-	public void bindRelationshipByInviteCode(UserInfo invitee, UserInfo inviter, String platform, String version) throws ThreeSaleException {
+	public void bindRelationshipByInviteCode(UserInfo invitee, UserInfo inviter) throws ThreeSaleException {
 
 		if (invitee == null || inviter == null) 
 			throw new ThreeSaleException(1, "鐢ㄦ埛淇℃伅涓虹┖");
@@ -524,6 +518,8 @@
 
 		if (threeSale != null) {
 			// 鏈夋晥鍏崇郴--鐢熸晥
+			threeSale.setBoss(inviter);
+			threeSale.setWorker(invitee);
 			threeSale.setState(true);
 			threeSale.setExpire(ThreeSale.EXPIRE_NORMAL);
 			threeSale.setSucceedTime(java.lang.System.currentTimeMillis());
@@ -561,8 +557,9 @@
 		executor.execute(new Runnable() {
 			@Override
 			public void run() {
+				
+				UserActiveLog activeLog  = userActiveLogService.getUserLatestActiveInfo(inviter.getId());
 				try {
-					UserActiveLog activeLog  = userActiveLogService.getUserLatestActiveInfo(inviter.getId());
 					if (activeLog != null  && !StringUtil.isNullOrEmpty(activeLog.getVersionCode()) ) {
 						String versionCode = activeLog.getVersionCode();
 						String channel = activeLog.getChannel();
@@ -591,6 +588,9 @@
 				} catch (Exception e) {
 					LogHelper.errorDetailInfo(e);
 				}
+				
+				// 閭�璇烽噾甯�
+				integralGetService.addInviteLevelOne(inviter.getId(), invitee.getId());
 			}
 		});
 		
@@ -599,7 +599,7 @@
 
 	@Override
 	@Transactional
-	public void bindRelationshipByWX(UserInfo invitee, Long inviterId, ThreeSale threeSaleOld, String platform, String version) throws ThreeSaleException {
+	public void bindRelationshipByWX(UserInfo invitee, Long inviterId, ThreeSale threeSaleOld) throws ThreeSaleException {
 
 		if (invitee == null || (inviterId == null && threeSaleOld == null))
 			throw new ThreeSaleException(1, "鐢ㄦ埛淇℃伅涓虹┖");
@@ -642,6 +642,7 @@
 		
 		UserInfo boss = userInfoService.selectByPKey(threeSale.getBoss().getId());
 		threeSale.setBoss(boss);
+		threeSale.setWorker(invitee);
 		
 		// 娣诲姞鍒伴槦鍒�
 		ThreeSaleCMQManager.getInstance().addThreeSaleMsg(threeSale);
@@ -714,5 +715,16 @@
 	public List<ThreeSale> getSuccessByDate(Long bossId, Long minTime, Long maxTime){
 		return threeSaleMapper.getSuccessByDate(bossId, minTime, maxTime);
 	}
+	
+	
+	@Override
+	public List<ThreeSale> listFirstTeam(long start, int count, Long uid, Integer state) {
+		return threeSaleMapper.listFirstTeam(start, count, uid, state);
+	}
+	
+	@Override
+	public List<ThreeSale> listSecondTeam(long start, int count, Long uid, Integer state) {
+		return threeSaleMapper.listSecondTeam(start, count, uid, state);
+	}
 
 }

--
Gitblit v1.8.0