From 744594ef1a2f530fc3e86ea9dc48b62247f79420 Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期二, 19 五月 2020 17:13:23 +0800
Subject: [PATCH] 饿了么绘图,添加口碑

---
 fanli/src/main/java/com/yeshi/fanli/controller/client/v2/UserMoneyControllerV2.java |  239 ++++++++++++++++++++++++++++++++++++++++++++++++-----------
 1 files changed, 194 insertions(+), 45 deletions(-)

diff --git a/fanli/src/main/java/com/yeshi/fanli/controller/client/v2/UserMoneyControllerV2.java b/fanli/src/main/java/com/yeshi/fanli/controller/client/v2/UserMoneyControllerV2.java
index eda6631..b8ad8ae 100644
--- a/fanli/src/main/java/com/yeshi/fanli/controller/client/v2/UserMoneyControllerV2.java
+++ b/fanli/src/main/java/com/yeshi/fanli/controller/client/v2/UserMoneyControllerV2.java
@@ -24,8 +24,10 @@
 import com.google.gson.JsonPrimitive;
 import com.google.gson.JsonSerializationContext;
 import com.google.gson.JsonSerializer;
+import com.google.gson.reflect.TypeToken;
 import com.yeshi.fanli.entity.accept.AcceptData;
 import com.yeshi.fanli.entity.bus.user.Extract;
+import com.yeshi.fanli.entity.bus.user.PreviewInfo.PreviewEnum;
 import com.yeshi.fanli.entity.bus.user.UserInfo;
 import com.yeshi.fanli.entity.money.TeamEincomeRecord;
 import com.yeshi.fanli.entity.money.UserMoneyDetail.UserMoneyDetailTypeEnum;
@@ -39,6 +41,7 @@
 import com.yeshi.fanli.service.inter.money.extract.ExtractService;
 import com.yeshi.fanli.service.inter.order.HongBaoV2Service;
 import com.yeshi.fanli.service.inter.order.OrderMoneyDailyCountService;
+import com.yeshi.fanli.service.inter.user.PreviewInfoService;
 import com.yeshi.fanli.service.inter.user.UserInfoExtraService;
 import com.yeshi.fanli.service.inter.user.UserInfoService;
 import com.yeshi.fanli.util.Constant;
@@ -87,11 +90,14 @@
 
 	@Resource
 	private OrderMoneyDailyCountService orderMoneyDailyCountService;
-	
+
 	@Resource
 	private TeamEincomeRecordService teamEincomeRecordService;
-
 	
+	@Resource
+	private PreviewInfoService previewInfoService;
+	
+
 	private Gson getGson() {
 		GsonBuilder builder = new GsonBuilder();
 		builder.registerTypeAdapter(BigDecimal.class, new JsonSerializer<BigDecimal>() {
@@ -108,7 +114,7 @@
 		});
 		return builder.create();
 	}
-	
+
 	/**
 	 * 鐢ㄦ埛璧勯噾缁熻
 	 * 
@@ -122,13 +128,36 @@
 			out.print(JsonUtil.loadFalseResult(1, "鐢ㄦ埛鏈櫥褰�"));
 			return;
 		}
+		
+		// VIP鏁版嵁棰勮
+		MoneyStatisticVO vo = null;
+		String redisContent = previewInfoService.getRedisContent(uid, PreviewEnum.moneyInfo);
+		if (!StringUtil.isNullOrEmpty(redisContent)) {
+			vo = new Gson().fromJson(redisContent, MoneyStatisticVO.class);
+			if (vo != null) {
+				vo.setLink(configService.get(ConfigKeyEnum.autoExtractHelpUrl.getKey()));
+				vo.setExtractDesc("鎻愮幇閲戦灏辨槸宸叉垚鍔熸彁鐜板埌鏀粯瀹濈殑璧勯噾");
+				vo.setMoneyArrivalDesc("璁㈠崟宸插埌璐﹀悗鎻愮幇鏃堕棿鍜岄噾棰濆潎涓嶅彈闄愬埗");
+			}
+		}
+		
+		if (vo == null) {
+			vo = createMoneyStatistic(uid);
+		}
+		
+		Gson gson = getGson();
+		out.print(JsonUtil.loadTrueResult(gson.toJson(vo)));
+	}
+	
+	
+	public MoneyStatisticVO createMoneyStatistic(Long uid) {
 		UserInfo user = userInfoService.getUserById(uid);
 
 		MoneyStatisticVO vo = new MoneyStatisticVO();
 		vo.setLink(configService.get(ConfigKeyEnum.autoExtractHelpUrl.getKey()));
 		vo.setBalanceMoney(user.getMyHongBao());
-		vo.setExtractDesc("鎻愮幇閲戦灏辨槸宸叉垚鍔熻浆璐﹀埌鎻愮幇鏀粯瀹濈殑璧勯噾銆�");
-		vo.setMoneyArrivalDesc("璧勯噾宸插埌璐﹀悗鎻愮幇鏃堕棿涓嶅彈闄愬埗銆侀噾棰濆彈闄愬埗銆�");
+		vo.setExtractDesc("鎻愮幇閲戦灏辨槸宸叉垚鍔熸彁鐜板埌鏀粯瀹濈殑璧勯噾");
+		vo.setMoneyArrivalDesc("璁㈠崟宸插埌璐﹀悗鎻愮幇鏃堕棿鍜岄噾棰濆潎涓嶅彈闄愬埗");
 
 		// 鑾峰彇鎻愮幇涓殑淇℃伅
 		BigDecimal extractingMoney = extractService.sumVerifyingMoney(uid);
@@ -235,13 +264,29 @@
 				.convertToTimeTemp(calendar.get(Calendar.YEAR) + "-" + (calendar.get(Calendar.MONTH) + 1), "yyyy-M"));
 		calendar.add(Calendar.MONTH, -1);
 		vo.setMonthPredict(cratePredictVO(orderMoneyDailyCountService.query(uid, minDate, maxDate)));
-
-		Gson gson = getGson();
-		out.print(JsonUtil.loadTrueResult(gson.toJson(vo)));
+		return vo;
 	}
 	
 	
-	
+
+	@RequestMapping(value = "getUserMoneyInfo")
+	public void getUserMoneyInfo(AcceptData acceptData, Long uid, PrintWriter out) {
+		if (uid == null || uid == 0) {
+			out.print(JsonUtil.loadFalseResult(1, "鐢ㄦ埛鏈櫥褰�"));
+			return;
+		}
+		UserInfo user = userInfoService.getUserById(uid);
+
+		MoneyStatisticVO vo = new MoneyStatisticVO();
+		vo.setLink(configService.get(ConfigKeyEnum.autoExtractHelpUrl.getKey()));
+		vo.setBalanceMoney(user.getMyHongBao());
+		// 鑾峰彇鎻愮幇涓殑淇℃伅
+		BigDecimal extractingMoney = extractService.sumVerifyingMoney(uid);
+		if (extractingMoney.compareTo(new BigDecimal(0)) > 0)
+			vo.setExtractingMoneyInfo("鎻愮幇涓�:楼" + extractingMoney.setScale(2, RoundingMode.HALF_UP));
+		Gson gson = getGson();
+		out.print(JsonUtil.loadTrueResult(gson.toJson(vo)));
+	}
 
 	private MoneyPredictVO cratePredictVO(List<OrderMoneyDailyCount> list) {
 		MoneyPredictVO predictVO = new MoneyPredictVO();
@@ -257,9 +302,11 @@
 				if (dailyCount.getOrderNumTeam() != null)
 					predictVO.setTeamNum(predictVO.getTeamNum() + dailyCount.getOrderNumTeam());
 				if (dailyCount.getIncome() != null)
-					predictVO.setMineMoney(predictVO.getMineMoney().add(MoneyBigDecimalUtil.div(BigDecimal.valueOf(dailyCount.getIncome()), hundred)));
+					predictVO.setMineMoney(predictVO.getMineMoney()
+							.add(MoneyBigDecimalUtil.div(BigDecimal.valueOf(dailyCount.getIncome()), hundred)));
 				if (dailyCount.getIncomeTeam() != null)
-					predictVO.setTeamMoney(predictVO.getTeamMoney().add(MoneyBigDecimalUtil.div(BigDecimal.valueOf(dailyCount.getIncomeTeam()), hundred)));
+					predictVO.setTeamMoney(predictVO.getTeamMoney()
+							.add(MoneyBigDecimalUtil.div(BigDecimal.valueOf(dailyCount.getIncomeTeam()), hundred)));
 			}
 		}
 		predictVO.setTotalNum(predictVO.getTeamNum() + predictVO.getMineNum());
@@ -281,10 +328,22 @@
 			return;
 		}
 
-		List<Extract> list = extractService.getExtractSucceedRecord(page, Constant.PAGE_SIZE, uid);
-		if (list == null) {
-			list = new ArrayList<>();
+		List<Extract> list = null;
+		String redisContent = previewInfoService.getRedisContent(uid, PreviewEnum.extractRecord);
+		if (!StringUtil.isNullOrEmpty(redisContent)) {
+			Gson gson = new Gson();
+			list = gson.fromJson(redisContent, new TypeToken<ArrayList<Extract>>() {}.getType());
 		}
+		
+		// 鏌ヨ鐪熷疄
+		long count = 0;
+		if (list == null) {
+			list = extractService.getExtractSucceedRecord(page, Constant.PAGE_SIZE, uid);
+			count = extractService.countExtractSucceedRecord(uid);
+		}
+			
+		if (list == null)
+			list = new ArrayList<>();
 
 		JSONArray JSONArray = new JSONArray();
 		for (Extract extract : list) {
@@ -303,13 +362,11 @@
 		}
 
 		JSONObject json = new JSONObject();
-		json.put("count", extractService.countExtractSucceedRecord(uid));
+		json.put("count", count == 0 ? list.size() : 0);
 		json.put("list", JSONArray);
 		out.print(JsonUtil.loadTrueResult(json));
 	}
 
-	
-	
 	/**
 	 * 鍘嗗彶璇︽儏
 	 * 
@@ -387,19 +444,23 @@
 						Date countDay = dailyCount.getCountDay();
 						if (datetype == 1 && countDay != null && countDate.equals(formatDay.format(countDay))) {
 							predictVO.setMineNum(dailyCount.getOrderNum());
-							predictVO.setMineMoney(MoneyBigDecimalUtil.div(BigDecimal.valueOf(dailyCount.getIncome()), hundred));
+							predictVO.setMineMoney(
+									MoneyBigDecimalUtil.div(BigDecimal.valueOf(dailyCount.getIncome()), hundred));
 							predictVO.setTeamNum(dailyCount.getOrderNumTeam());
-							predictVO.setTeamMoney(MoneyBigDecimalUtil.div(BigDecimal.valueOf(dailyCount.getIncomeTeam()), hundred));
+							predictVO.setTeamMoney(
+									MoneyBigDecimalUtil.div(BigDecimal.valueOf(dailyCount.getIncomeTeam()), hundred));
 							break;
 						}
 
 						String yearMonth = dailyCount.getYearMonth();
-						if (datetype == 2 && !StringUtil.isNullOrEmpty(yearMonth)
-								&& countDate.equals(formatMonth.format(TimeUtil.parseYYYYMMDD(DateUtil.getFirstDayOfMonth(yearMonth))))) {
+						if (datetype == 2 && !StringUtil.isNullOrEmpty(yearMonth) && countDate.equals(
+								formatMonth.format(TimeUtil.parseYYYYMMDD(DateUtil.getFirstDayOfMonth(yearMonth))))) {
 							predictVO.setMineNum(dailyCount.getOrderNum());
-							predictVO.setMineMoney(MoneyBigDecimalUtil.div(BigDecimal.valueOf(dailyCount.getIncome()), hundred));
+							predictVO.setMineMoney(
+									MoneyBigDecimalUtil.div(BigDecimal.valueOf(dailyCount.getIncome()), hundred));
 							predictVO.setTeamNum(dailyCount.getOrderNumTeam());
-							predictVO.setTeamMoney(MoneyBigDecimalUtil.div(BigDecimal.valueOf(dailyCount.getIncomeTeam()), hundred));
+							predictVO.setTeamMoney(
+									MoneyBigDecimalUtil.div(BigDecimal.valueOf(dailyCount.getIncomeTeam()), hundred));
 							break;
 						}
 					}
@@ -473,7 +534,8 @@
 				for (OrderMoneyDailyCount dailyCount : listDailyCount) {
 					if (dailyCount.getSourceType() == typeEnum) {
 						detail.setNum(detail.getNum() + dailyCount.getOrderNum());
-						detail.setMoney(detail.getMoney().add(MoneyBigDecimalUtil.div(BigDecimal.valueOf(dailyCount.getIncome()), hundred)));
+						detail.setMoney(detail.getMoney()
+								.add(MoneyBigDecimalUtil.div(BigDecimal.valueOf(dailyCount.getIncome()), hundred)));
 					}
 				}
 			}
@@ -488,8 +550,6 @@
 		out.print(JsonUtil.loadTrueResult(object));
 	}
 
-	
-	
 	/**
 	 * 鍥㈤槦鍒嗙孩
 	 * @param acceptData
@@ -525,7 +585,6 @@
 		BigDecimal subsidy = teamEincomeRecordService.sumRecieveByType(uid, TeamEincomeRecord.TYPE_TEAM_SUBSIDY);
 		BigDecimal reward = teamEincomeRecordService.sumRecieveByType(uid, TeamEincomeRecord.TYPE_TEAM_DIVIDENTS);
 
-		
 		Gson gson = getGson();
 		JSONObject object = new JSONObject();
 		object.put("total", subsidy.add(reward).setScale(2).toString());
@@ -535,10 +594,9 @@
 		object.put("month", gson.toJson(monthVO));
 		out.print(JsonUtil.loadTrueResult(object));
 	}
-	
-	
+
 	private TeamPredictVO crateTeamPredictVO(List<OrderMoneyDailyCount> list) {
-		TeamPredictVO predictVO = new TeamPredictVO(BigDecimal.ZERO,0,BigDecimal.ZERO,0);
+		TeamPredictVO predictVO = new TeamPredictVO(BigDecimal.ZERO, 0, BigDecimal.ZERO, 0);
 		if (list != null && list.size() > 0) {
 			BigDecimal hundred = BigDecimal.valueOf(100);
 			for (OrderMoneyDailyCount dailyCount : list) {
@@ -547,20 +605,19 @@
 				if (dailyCount.getTeamSubsidyNum() != null)
 					predictVO.setSubsidyNum(predictVO.getSubsidyNum() + dailyCount.getTeamSubsidyNum());
 				if (dailyCount.getTeamReward() != null)
-					predictVO.setReward(predictVO.getReward().add(MoneyBigDecimalUtil.div(BigDecimal.valueOf(dailyCount.getTeamReward()), hundred)));
+					predictVO.setReward(predictVO.getReward()
+							.add(MoneyBigDecimalUtil.div(BigDecimal.valueOf(dailyCount.getTeamReward()), hundred)));
 				if (dailyCount.getTeamSubsidy() != null)
-					predictVO.setSubsidy(predictVO.getSubsidy().add(MoneyBigDecimalUtil.div(BigDecimal.valueOf(dailyCount.getTeamSubsidy()), hundred)));
-			
-				
+					predictVO.setSubsidy(predictVO.getSubsidy()
+							.add(MoneyBigDecimalUtil.div(BigDecimal.valueOf(dailyCount.getTeamSubsidy()), hundred)));
+
 			}
 		}
 		predictVO.setTotalNum(predictVO.getRewardNum() + predictVO.getSubsidyNum());
 		predictVO.setTotalMoney(predictVO.getReward().add(predictVO.getSubsidy()));
 		return predictVO;
 	}
-	
-	
-	
+
 	/**
 	 * 鍘嗗彶璇︽儏
 	 * 
@@ -570,7 +627,8 @@
 	 * @param out
 	 */
 	@RequestMapping(value = "getTeamDividendHistory")
-	public void getTeamDividendHistory(AcceptData acceptData, Long uid, String date, Integer datetype, PrintWriter out) {
+	public void getTeamDividendHistory(AcceptData acceptData, Long uid, String date, Integer datetype,
+			PrintWriter out) {
 		if (uid == null || uid == 0) {
 			out.print(JsonUtil.loadFalseResult(1, "鐢ㄦ埛鏈櫥褰�"));
 			return;
@@ -638,19 +696,23 @@
 						Date countDay = dailyCount.getCountDay();
 						if (datetype == 1 && countDay != null && countDate.equals(formatDay.format(countDay))) {
 							predictVO.setRewardNum(dailyCount.getTeamRewardNum());
-							predictVO.setReward(MoneyBigDecimalUtil.div(BigDecimal.valueOf(dailyCount.getTeamReward()), hundred));
+							predictVO.setReward(
+									MoneyBigDecimalUtil.div(BigDecimal.valueOf(dailyCount.getTeamReward()), hundred));
 							predictVO.setSubsidyNum(dailyCount.getTeamSubsidyNum());
-							predictVO.setSubsidy(MoneyBigDecimalUtil.div(BigDecimal.valueOf(dailyCount.getTeamSubsidy()), hundred));
+							predictVO.setSubsidy(
+									MoneyBigDecimalUtil.div(BigDecimal.valueOf(dailyCount.getTeamSubsidy()), hundred));
 							break;
 						}
 
 						String yearMonth = dailyCount.getYearMonth();
-						if (datetype == 2 && !StringUtil.isNullOrEmpty(yearMonth)
-								&& countDate.equals(formatMonth.format(TimeUtil.parseYYYYMMDD(DateUtil.getFirstDayOfMonth(yearMonth))))) {
+						if (datetype == 2 && !StringUtil.isNullOrEmpty(yearMonth) && countDate.equals(
+								formatMonth.format(TimeUtil.parseYYYYMMDD(DateUtil.getFirstDayOfMonth(yearMonth))))) {
 							predictVO.setRewardNum(dailyCount.getTeamRewardNum());
-							predictVO.setReward(MoneyBigDecimalUtil.div(BigDecimal.valueOf(dailyCount.getTeamReward()), hundred));
+							predictVO.setReward(
+									MoneyBigDecimalUtil.div(BigDecimal.valueOf(dailyCount.getTeamReward()), hundred));
 							predictVO.setSubsidyNum(dailyCount.getTeamSubsidyNum());
-							predictVO.setSubsidy(MoneyBigDecimalUtil.div(BigDecimal.valueOf(dailyCount.getTeamSubsidy()), hundred));
+							predictVO.setSubsidy(
+									MoneyBigDecimalUtil.div(BigDecimal.valueOf(dailyCount.getTeamSubsidy()), hundred));
 							break;
 						}
 					}
@@ -670,6 +732,93 @@
 			e.printStackTrace();
 		}
 	}
-	
 
+	
+	/**
+	 * 璁㈠崟缁熻-h5
+	 * 
+	 * @param acceptData
+	 * @param id
+	 * @param out
+	 */
+	@RequestMapping(value = "countTeamOrderNum")
+	public void countTeamOrderNum(String callback, AcceptData acceptData, Long uid, PrintWriter out) {
+		try {
+			
+			Date minDate = null;
+			Date maxDate = null;
+			long timeStamp = System.currentTimeMillis();
+			
+			Calendar calendar = Calendar.getInstance();
+			calendar.setTimeInMillis(timeStamp);
+			
+			// 浠婃棩棰勪及
+			calendar.add(Calendar.DAY_OF_YEAR, -1);
+			minDate = new Date(TimeUtil.convertDateToTemp(TimeUtil.getGernalTime(timeStamp)));
+			OrderMoneyDailyCount todayRecord = createVO(orderMoneyDailyCountService.sumTeamOrderNumGroupByCountDay(uid, minDate, null));
+
+			// 鏄ㄦ棩棰勪及
+			calendar.add(Calendar.DAY_OF_YEAR, -1);
+			maxDate = new Date(TimeUtil.convertDateToTemp(TimeUtil.getGernalTime(timeStamp)));
+			minDate = DateUtil.reduceDay(1, maxDate);
+			OrderMoneyDailyCount yesterdayRecord = createVO(orderMoneyDailyCountService.sumTeamOrderNumGroupByCountDay(uid, minDate, maxDate));
+
+			// 鏈湀棰勪及
+			maxDate = new Date(timeStamp);
+			calendar = Calendar.getInstance();
+			minDate = new Date(TimeUtil
+					.convertToTimeTemp(calendar.get(Calendar.YEAR) + "-" + (calendar.get(Calendar.MONTH) + 1), "yyyy-M"));
+			calendar.add(Calendar.MONTH, -1);
+			OrderMoneyDailyCount monthRecord = createVO(orderMoneyDailyCountService.sumTeamOrderNumGroupByYearMonth(uid, minDate, maxDate));
+			
+			// 绱
+			OrderMoneyDailyCount totalityRecord = createVO(orderMoneyDailyCountService.sumTeamOrderNumGroupByUid(uid, null, null));
+			
+			JSONObject today = new JSONObject();
+			today.put("direct", todayRecord.getDirectOrderNum());
+			today.put("indirect", todayRecord.getInDirectOrderNum());
+			today.put("beyond", todayRecord.getBeyondOrderNum());
+			
+			JSONObject yesterday = new JSONObject();
+			yesterday.put("direct", yesterdayRecord.getDirectOrderNum());
+			yesterday.put("indirect", yesterdayRecord.getInDirectOrderNum());
+			yesterday.put("beyond", yesterdayRecord.getBeyondOrderNum());
+			
+			JSONObject month = new JSONObject();
+			month.put("direct", monthRecord.getDirectOrderNum());
+			month.put("indirect", monthRecord.getInDirectOrderNum());
+			month.put("beyond", monthRecord.getBeyondOrderNum());
+			
+			JSONObject totality = new JSONObject();
+			totality.put("direct", totalityRecord.getDirectOrderNum());
+			totality.put("indirect", totalityRecord.getInDirectOrderNum());
+			totality.put("beyond", totalityRecord.getBeyondOrderNum());
+			
+			
+			JSONObject json = new JSONObject();
+			json.put("today", today);
+			json.put("yesterday", yesterday);
+			json.put("month", month);
+			json.put("totality", totality);
+			JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult(json));
+		} catch (Exception e) {
+			JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("缁熻澶辫触"));
+			e.printStackTrace();
+		}
+	}
+	
+	
+	private OrderMoneyDailyCount createVO(List<OrderMoneyDailyCount> list) {
+		OrderMoneyDailyCount totalityRecord = new OrderMoneyDailyCount(0,0,0);
+		
+		if (list != null && list.size() > 0) {
+			for (OrderMoneyDailyCount record: list) {
+				totalityRecord.setDirectOrderNum(totalityRecord.getDirectOrderNum() + record.getDirectOrderNum());
+				totalityRecord.setInDirectOrderNum(totalityRecord.getInDirectOrderNum() + record.getInDirectOrderNum());
+				totalityRecord.setBeyondOrderNum(totalityRecord.getBeyondOrderNum() + record.getBeyondOrderNum());
+			}
+		}  
+		
+		return totalityRecord;
+	}
 }

--
Gitblit v1.8.0