From d46dea27b6ec3e0fb32ec7d137699e9fc7d609b0 Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期四, 12 十二月 2019 14:18:11 +0800
Subject: [PATCH] 订单补贴消息修改

---
 fanli/src/main/java/com/yeshi/fanli/controller/client/v2/InviteControllerV2.java |   84 +++++++++++++++++++++++++++++++++++-------
 1 files changed, 70 insertions(+), 14 deletions(-)

diff --git a/fanli/src/main/java/com/yeshi/fanli/controller/client/v2/InviteControllerV2.java b/fanli/src/main/java/com/yeshi/fanli/controller/client/v2/InviteControllerV2.java
index 0416440..ab38acd 100644
--- a/fanli/src/main/java/com/yeshi/fanli/controller/client/v2/InviteControllerV2.java
+++ b/fanli/src/main/java/com/yeshi/fanli/controller/client/v2/InviteControllerV2.java
@@ -5,12 +5,14 @@
 import java.util.ArrayList;
 import java.util.Date;
 import java.util.List;
+import java.util.Map;
 
 import javax.annotation.Resource;
 
 import org.springframework.stereotype.Controller;
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RequestMethod;
+import org.yeshi.utils.DateUtil;
 import org.yeshi.utils.JsonUtil;
 
 import com.yeshi.fanli.dto.wx.WXAccountInfoDTO;
@@ -21,6 +23,7 @@
 import com.yeshi.fanli.entity.bus.user.ThreeSaleExtraInfo;
 import com.yeshi.fanli.entity.bus.user.UserInfo;
 import com.yeshi.fanli.entity.bus.user.UserInfoExtra;
+import com.yeshi.fanli.entity.bus.user.UserInviteSeparate;
 import com.yeshi.fanli.entity.bus.user.WeiXinUser;
 import com.yeshi.fanli.exception.user.UserAccountException;
 import com.yeshi.fanli.exception.user.UserInfoExtraException;
@@ -29,11 +32,14 @@
 import com.yeshi.fanli.service.inter.push.PushService;
 import com.yeshi.fanli.service.inter.user.UserInfoExtraService;
 import com.yeshi.fanli.service.inter.user.UserInfoService;
+import com.yeshi.fanli.service.inter.user.UserInviteSeparateService;
 import com.yeshi.fanli.service.inter.user.invite.ThreeSaleExtraInfoSerivce;
 import com.yeshi.fanli.service.inter.user.invite.ThreeSaleSerivce;
+import com.yeshi.fanli.service.inter.user.vip.UserVIPInfoService;
 import com.yeshi.fanli.util.Constant;
 import com.yeshi.fanli.util.RedisManager;
 import com.yeshi.fanli.util.StringUtil;
+import com.yeshi.fanli.util.VersionUtil;
 import com.yeshi.fanli.util.annotation.RequestSerializableByKey;
 import com.yeshi.fanli.util.wx.WXLoginUtil;
 
@@ -46,7 +52,7 @@
 
 	@Resource
 	private RedisManager redisManager;
-	
+
 	@Resource
 	private ConfigService configService;
 
@@ -67,6 +73,12 @@
 
 	@Resource
 	private ThreeSaleExtraInfoSerivce threeSaleExtraInfoSerivce;
+
+	@Resource
+	private UserVIPInfoService userVIPInfoService;
+	
+	@Resource
+	private UserInviteSeparateService userInviteSeparateService;
 
 	/**
 	 * 閭�璇风爜楠岃瘉
@@ -100,17 +112,17 @@
 			WeiXinUser weiXinUser = WXLoginUtil.getWeiXinUser(code, wxAccount.getAppId(), wxAccount.getAppSecret());
 			if (weiXinUser == null)
 				throw new UserInfoExtraException(1, "寰俊鎺堟潈澶辫触");
-			
+
 			String wxUnionId = weiXinUser.getUnionid();
 			if (wxUnionId == null || wxUnionId.trim().length() == 0)
 				throw new UserInfoExtraException(1, "寰俊鎺堟潈澶辫触");
-			
+
 			String activeWX = StringUtil.Md5("activeWX:" + weiXinUser.getUnionid());
 			redisManager.cacheCommonString(activeWX, JsonUtil.getSimpleGson().toJson(weiXinUser), 60 * 20);
-			
+
 			// 閭�璇峰叧绯荤敤鎴蜂俊鎭�
 			UserInfo userInfo = userInfoExtraService.getInviterInfo(uid, wxUnionId);
-			
+
 			JSONObject data = new JSONObject();
 			data.put("nickName", userInfo.getNickName());
 			data.put("portrait", userInfo.getPortrait());
@@ -124,9 +136,11 @@
 
 	/**
 	 * 寰俊婵�娲�
+	 * 
 	 * @param acceptData
 	 * @param uid
-	 * @param key 楠岃瘉杩斿洖鐨刱ey
+	 * @param key
+	 *            楠岃瘉杩斿洖鐨刱ey
 	 * @param out
 	 */
 	@RequestSerializableByKey(key = "'activeInviteWX-'+#uid")
@@ -136,15 +150,15 @@
 			String value = redisManager.getCommonString(key);
 			if (StringUtil.isNullOrEmpty(value))
 				throw new UserAccountException(1, "寰俊鎺堟潈澶辨晥");
-			
+
 			WeiXinUser weiXinUser = JsonUtil.getSimpleGson().fromJson(value, WeiXinUser.class);
 			if (weiXinUser == null)
 				throw new UserAccountException(1, "寰俊鎺堟潈澶辨晥");
-			
+
 			userInfoExtraService.activeInviteWX(uid, weiXinUser);
 			// 鍒犻櫎缂撳瓨
 			redisManager.removeCommonString(key);
-			
+
 			out.print(JsonUtil.loadTrueResult("閭�璇风爜婵�娲绘垚鍔�"));
 		} catch (UserInfoExtraException e) {
 			out.print(JsonUtil.loadFalseResult(e.getMsg()));
@@ -153,9 +167,7 @@
 			e.printStackTrace();
 		}
 	}
-	
-	
-	
+
 	/**
 	 * 鐢ㄦ埛闃熷憳鍒楄〃鏌ヨ 1.5.3鏌ヨ鏈夋晥闃熷憳
 	 * 
@@ -180,8 +192,12 @@
 			count = threeSaleSerivce.countSecondTeam(uid, 1);
 		}
 
+		boolean needVIPInfo = false;
+		if (VersionUtil.greaterThan_2_1(acceptData.getPlatform(), acceptData.getVersion()))
+			needVIPInfo = true;
+
 		// 缁勭粐鏁版嵁
-		JSONObject resultData = organizeTeam(count, listTeam, uid, type);
+		JSONObject resultData = organizeTeam(count, listTeam, uid, type,needVIPInfo);
 
 		// 绗竴椤靛垽鏂槸鍚︽縺娲� 鏄惁鏈夐槦鍛�
 		if (type == 1 && page == 1) {
@@ -206,7 +222,7 @@
 	 * @param type
 	 * @return
 	 */
-	private JSONObject organizeTeam(long count, List<ThreeSale> list, Long uid, int type) {
+	private JSONObject organizeTeam(long count, List<ThreeSale> list, Long uid, int type, boolean needVipInfo) {
 		JSONObject result = new JSONObject();
 		JSONArray resultArray = new JSONArray();
 
@@ -215,6 +231,14 @@
 		SimpleDateFormat format = new SimpleDateFormat("yyyy.MM.dd HH:mm");
 		SimpleDateFormat formatYears = new SimpleDateFormat("yyyy");
 
+		List<Long> workerIdList = new ArrayList<>();
+		Map<Long, Boolean> vipMap = null;
+		if (needVipInfo) {
+			for (ThreeSale threeSale : list)
+				workerIdList.add(threeSale.getWorker().getId());
+			if (workerIdList.size() > 0)
+				vipMap = userVIPInfoService.listByUids(workerIdList);
+		}
 		for (ThreeSale threeSale : list) {
 			UserInfo worker = threeSale.getWorker();
 			if (worker == null) {
@@ -230,7 +254,39 @@
 
 			Date inviteTime = new Date(threeSale.getCreateTime());
 			object.put("inviteTime", format.format(inviteTime) + " 鍔犲叆");
+			// 娣诲姞鏄惁涓篤IP
+			if (vipMap != null && vipMap.get(worker.getId()) != null) {
+				object.put("vip", vipMap.get(worker.getId()));
+				if (vipMap.get(worker.getId())) {
+					UserInviteSeparate separate = userInviteSeparateService.selectByWorkerIdAndBossId(worker.getId(), uid);
+					if (separate != null && separate.getEndTime() != null) {
+						try {
+							
+						
+							JSONObject contentJson1 = new JSONObject();
+							contentJson1.put("color", "#888888");
+							contentJson1.put("content", "灏嗕簬");
 
+							JSONObject contentJson2 = new JSONObject();
+							contentJson2.put("color", "#F14242");
+							contentJson2.put("content", DateUtil.dateDiff4(new Date(), separate.getEndTime()));
+
+							JSONObject contentJson3 = new JSONObject();
+							contentJson3.put("color", "#888888");
+							contentJson3.put("content", "鍚庤劚绂婚個璇峰叧绯�");
+							
+							JSONArray array = new JSONArray();
+							array.add(contentJson1);
+							array.add(contentJson2);
+							array.add(contentJson3);
+							object.put("vipBreakTime",array);
+						
+						} catch (Exception e) {
+							e.printStackTrace();
+						}
+					}
+				}
+			}
 			String fontColor1 = "#888888";
 			JSONArray array = new JSONArray();
 			if (threeSale.getState()) {

--
Gitblit v1.8.0