From 271ae63c20fcbe28d29c47f1881138ff6551a2a1 Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期三, 10 六月 2020 19:26:26 +0800
Subject: [PATCH] 唯品会订单bug修复，APP端佣金比例展示错误bug修复

---
 fanli/src/main/java/com/yeshi/fanli/dao/order/OrderMoneyDailyCountDao.java |  581 ++++++++++++++++++++++++++++++++++++++++++++++++++--------
 1 files changed, 501 insertions(+), 80 deletions(-)

diff --git a/fanli/src/main/java/com/yeshi/fanli/dao/order/OrderMoneyDailyCountDao.java b/fanli/src/main/java/com/yeshi/fanli/dao/order/OrderMoneyDailyCountDao.java
index f141f17..0a089d3 100644
--- a/fanli/src/main/java/com/yeshi/fanli/dao/order/OrderMoneyDailyCountDao.java
+++ b/fanli/src/main/java/com/yeshi/fanli/dao/order/OrderMoneyDailyCountDao.java
@@ -10,54 +10,31 @@
 import java.util.Locale;
 import java.util.Map;
 
-import javax.annotation.Resource;
-
 import org.springframework.data.domain.Sort;
-import org.springframework.data.mongodb.core.MongoTemplate;
+import org.springframework.data.mongodb.core.aggregation.Aggregation;
+import org.springframework.data.mongodb.core.aggregation.AggregationOperation;
+import org.springframework.data.mongodb.core.aggregation.AggregationResults;
+import org.springframework.data.mongodb.core.aggregation.LookupOperation;
 import org.springframework.data.mongodb.core.query.Criteria;
 import org.springframework.data.mongodb.core.query.Query;
 import org.springframework.data.mongodb.core.query.Update;
 import org.springframework.stereotype.Repository;
+import org.yeshi.utils.DateUtil;
 
 import com.mongodb.BasicDBList;
 import com.mongodb.BasicDBObject;
 import com.mongodb.DBCollection;
 import com.mongodb.DBObject;
 import com.mongodb.GroupCommand;
+import com.yeshi.fanli.dao.MongodbBaseDao;
 import com.yeshi.fanli.entity.order.OrderMoneyDailyCount;
-import com.yeshi.fanli.entity.order.OrderMoneyDailyCount.SourceTypeEnum;
+import com.yeshi.fanli.entity.order.SourceTypeEnum;
+import com.yeshi.fanli.vo.order.OrderRankingVO;
 
 @Repository
-public class OrderMoneyDailyCountDao {
+public class OrderMoneyDailyCountDao extends MongodbBaseDao<OrderMoneyDailyCount> {
 
 	private static String collectionName = "order_money_daily_count";
-
-	@Resource
-	private MongoTemplate mongoTemplate;
-
-	/**
-	 * 鏂板
-	 * 
-	 * @param record
-	 */
-	public void save(OrderMoneyDailyCount record) {
-		if (record == null) {
-			return;
-		}
-		mongoTemplate.save(record);
-	}
-
-	/**
-	 * 鏌ヨID
-	 * 
-	 * @param id
-	 * @return
-	 */
-	public OrderMoneyDailyCount getById(String id) {
-		Query query = new Query();
-		query.addCriteria(Criteria.where("id").is(id));
-		return mongoTemplate.findOne(query, OrderMoneyDailyCount.class);
-	}
 
 	/**
 	 * 閫夋嫨鏇存柊
@@ -76,24 +53,36 @@
 			update.set("orderNum", info.getOrderNum());
 		if (info.getOrderNumTeam() != null)
 			update.set("orderNumTeam", info.getOrderNumTeam());
+		if (info.getTeamReward() != null)
+			update.set("teamReward", info.getTeamReward());
+		if (info.getTeamRewardNum() != null)
+			update.set("teamRewardNum", info.getTeamRewardNum());
+		if (info.getTeamSubsidy() != null)
+			update.set("teamSubsidy", info.getTeamSubsidy());
+		if (info.getTeamSubsidyNum() != null)
+			update.set("teamSubsidyNum", info.getTeamSubsidyNum());
+		if (info.getTeamDividentsOrderNum() != null)
+			update.set("teamDividentsOrderNum", info.getTeamDividentsOrderNum());
+		if (info.getDirectOrderNum() != null)
+			update.set("directOrderNum", info.getDirectOrderNum());
+		if (info.getInDirectOrderNum() != null)
+			update.set("inDirectOrderNum", info.getInDirectOrderNum());
+		if (info.getBeyondOrderNum() != null)
+			update.set("beyondOrderNum", info.getBeyondOrderNum());
 		update.set("updateTime", new Date());
-		mongoTemplate.updateMulti(query, update, OrderMoneyDailyCount.class);
+		update(query, update);
 	}
 
 	// 鏌ヨ
 	public List<OrderMoneyDailyCount> query(Long uid, Date minDay, Date maxDay) {
-		Query query = new Query();
 		List<Criteria> list = new ArrayList<Criteria>();
 		list.add(Criteria.where("uid").is(uid));
+		if (minDay != null)
+			list.add(Criteria.where("countDay").gte(minDay));
+		if (maxDay != null)
+			list.add(Criteria.where("countDay").lt(maxDay));
 
-		if (minDay != null) {
-			list.add(Criteria.where("bossSuperId").lte(uid));
-		}
-
-		if (maxDay != null) {
-			list.add(Criteria.where("bossSuperId").gte(uid));
-		}
-
+		Query query = new Query();
 		if (list.size() > 0) {
 			Criteria[] cas = new Criteria[list.size()];
 			for (int i = 0; i < list.size(); i++)
@@ -101,7 +90,7 @@
 			query.addCriteria(new Criteria().andOperator(cas));
 		}
 		query.with(new Sort(Sort.Direction.ASC, "countDay"));
-		return mongoTemplate.find(query, OrderMoneyDailyCount.class);
+		return findList(query);
 	}
 
 	/**
@@ -113,13 +102,9 @@
 	 * @return
 	 */
 	public List<OrderMoneyDailyCount> sumGroupBySourceType(Long uid, Date minDate, Date maxDate) {
-		String collectionName = "order_money_daily_count";
 		List<OrderMoneyDailyCount> listDailyCount = new ArrayList<>();
-
-		// 缁熻鏂规硶
-		String reduce = "function(doc, aggr){"
-				+ " aggr.totalIncome += parseFloat((Math.round((doc.income)*100)/100).toFixed(2));"
-				+ " aggr.totalNum += doc.orderNum;" + "}";
+		String reduce = "function(doc, aggr){" + " aggr.totalIncome += doc.income;" + " aggr.totalNum += doc.orderNum;"
+				+ "}";
 
 		// 鏌ヨ鏉′欢
 		List<Criteria> list = new ArrayList<Criteria>();
@@ -127,7 +112,7 @@
 		if (minDate != null)
 			list.add(Criteria.where("countDay").gte(minDate));
 		if (maxDate != null)
-			list.add(Criteria.where("countDay").lte(maxDate));
+			list.add(Criteria.where("countDay").lt(maxDate));
 
 		Query query = new Query();
 		if (list.size() > 0) {
@@ -153,6 +138,10 @@
 
 			for (int i = 0; i < mapResult.size(); i++) {
 				BasicDBObject object = mapResult.get(i + "");
+				if (object == null || object.get("sourceType") == null) {
+					continue;
+				}
+
 				SourceTypeEnum sourceTypeEnum = null;
 				for (int m = 0; m < arrayEnun.length; m++) {
 					if (arrayEnun[m].name().equals(object.get("sourceType").toString())) {
@@ -163,7 +152,7 @@
 
 				OrderMoneyDailyCount dailyCount = new OrderMoneyDailyCount();
 				dailyCount.setSourceType(sourceTypeEnum);
-				dailyCount.setIncome(new BigDecimal(object.get("totalIncome").toString()));
+				dailyCount.setIncome(new BigDecimal(object.get("totalIncome").toString()).intValue());
 				dailyCount.setOrderNum(new BigDecimal(object.get("totalNum").toString()).intValue());
 				listDailyCount.add(dailyCount);
 			}
@@ -180,12 +169,10 @@
 	 * @return
 	 */
 	public List<OrderMoneyDailyCount> sumTeamGroupBySourceType(Long uid, Date minDate, Date maxDate) {
-		String collectionName = "order_money_daily_count";
 		List<OrderMoneyDailyCount> listDailyCount = new ArrayList<>();
 
 		// 缁熻鏂规硶
-		String reduce = "function(doc, aggr){"
-				+ " aggr.totalIncome += parseFloat((Math.round((doc.incomeTeam)*100)/100).toFixed(2));"
+		String reduce = "function(doc, aggr){" + " aggr.totalIncome += doc.incomeTeam;"
 				+ " aggr.totalNum += doc.orderNumTeam;" + "}";
 
 		// 鏌ヨ鏉′欢
@@ -194,7 +181,7 @@
 		if (minDate != null)
 			list.add(Criteria.where("countDay").gte(minDate));
 		if (maxDate != null)
-			list.add(Criteria.where("countDay").lte(maxDate));
+			list.add(Criteria.where("countDay").lt(maxDate));
 
 		Query query = new Query();
 		if (list.size() > 0) {
@@ -219,7 +206,9 @@
 			SourceTypeEnum[] arrayEnun = SourceTypeEnum.values();
 			for (int i = 0; i < mapResult.size(); i++) {
 				BasicDBObject object = mapResult.get(i + "");
-				OrderMoneyDailyCount dailyCount = new OrderMoneyDailyCount();
+				if (object == null || object.get("sourceType") == null) {
+					continue;
+				}
 
 				SourceTypeEnum sourceTypeEnum = null;
 				for (int m = 0; m < arrayEnun.length; m++) {
@@ -228,8 +217,9 @@
 						break;
 					}
 				}
+				OrderMoneyDailyCount dailyCount = new OrderMoneyDailyCount();
 				dailyCount.setSourceType(sourceTypeEnum);
-				dailyCount.setIncome(new BigDecimal(object.get("totalIncome").toString()));
+				dailyCount.setIncome(new BigDecimal(object.get("totalIncome").toString()).intValue());
 				dailyCount.setOrderNum(new BigDecimal(object.get("totalNum").toString()).intValue());
 				listDailyCount.add(dailyCount);
 			}
@@ -237,7 +227,28 @@
 		return listDailyCount;
 	}
 
-	
+	private String getReduce() {
+		StringBuilder builder = new StringBuilder();
+		builder.append("function(doc, aggr){ ");
+		builder.append(" aggr.totalIncome += doc.income;");
+		builder.append(" aggr.totalNum += doc.orderNum;");
+		builder.append(" aggr.totalIncomeTeam += doc.incomeTeam;");
+		builder.append(" aggr.totalNumTeam += doc.orderNumTeam;");
+		builder.append(" }");
+		return builder.toString();
+	}
+	// private String getReduce2() {
+	// StringBuilder builder = new StringBuilder();
+	// builder.append("function(doc, aggr){ ");
+	// builder.append(" aggr.totalIncome +=
+	// parseFloat((Math.round((doc.income)*100)/100).toFixed(2));");
+	// builder.append(" aggr.totalNum += doc.orderNum;");
+	// builder.append(" aggr.totalIncomeTeam +=
+	// parseFloat((Math.round((doc.incomeTeam)*100)/100).toFixed(2));");
+	// builder.append(" aggr.totalNumTeam += doc.orderNumTeam;");
+	// builder.append(" }");
+	// return builder.toString();
+	// }
 
 	/**
 	 * 缁熻姣忓ぉ璁㈠崟鏀跺叆銆佹暟閲�
@@ -253,7 +264,7 @@
 		if (minDate != null)
 			list.add(Criteria.where("countDay").gte(minDate));
 		if (maxDate != null)
-			list.add(Criteria.where("countDay").lte(maxDate));
+			list.add(Criteria.where("countDay").lt(maxDate));
 
 		Query query = new Query();
 		if (list.size() > 0) {
@@ -284,7 +295,7 @@
 				if (dbObject == null) {
 					continue;
 				}
-				
+
 				Object object = dbObject.get("countDay");
 				if (object == null) {
 					continue;
@@ -295,9 +306,9 @@
 					Date dtime = sdf.parse(date);
 					OrderMoneyDailyCount dailyCount = new OrderMoneyDailyCount();
 					dailyCount.setCountDay(dtime);
-					dailyCount.setIncome(new BigDecimal(dbObject.get("totalIncome").toString()));
+					dailyCount.setIncome(new BigDecimal(dbObject.get("totalIncome").toString()).intValue());
 					dailyCount.setOrderNum(new BigDecimal(dbObject.get("totalNum").toString()).intValue());
-					dailyCount.setIncomeTeam(new BigDecimal(dbObject.get("totalIncomeTeam").toString()));
+					dailyCount.setIncomeTeam(new BigDecimal(dbObject.get("totalIncomeTeam").toString()).intValue());
 					dailyCount.setOrderNumTeam(new BigDecimal(dbObject.get("totalNumTeam").toString()).intValue());
 					results.add(dailyCount);
 				} catch (ParseException e) {
@@ -309,19 +320,6 @@
 		return results;
 	}
 
-	 	
-	private String getReduce() {
-		StringBuilder builder = new StringBuilder();
-		builder.append("function(doc, aggr){ ");
-		builder.append(" aggr.totalIncome += parseFloat((Math.round((doc.income)*100)/100).toFixed(2));");
-		builder.append(" aggr.totalNum += doc.orderNum;");
-		builder.append(" aggr.totalIncomeTeam += parseFloat((Math.round((doc.incomeTeam)*100)/100).toFixed(2));");
-		builder.append(" aggr.totalNumTeam += doc.orderNumTeam;");
-		builder.append(" }");
-		return builder.toString();
-	}
-	
-	
 	/**
 	 *    缁熻姣忔湀璁㈠崟鏀跺叆銆佹暟閲�
 	 * @param uid
@@ -336,7 +334,7 @@
 		if (minDate != null)
 			list.add(Criteria.where("countDay").gte(minDate));
 		if (maxDate != null)
-			list.add(Criteria.where("countDay").lte(maxDate));
+			list.add(Criteria.where("countDay").lt(maxDate));
 
 		Query query = new Query();
 		if (list.size() > 0) {
@@ -366,17 +364,17 @@
 				if (dbObject == null) {
 					continue;
 				}
-				
+
 				Object object = dbObject.get("yearMonth");
 				if (object == null) {
 					continue;
 				}
-				
+
 				OrderMoneyDailyCount dailyCount = new OrderMoneyDailyCount();
 				dailyCount.setYearMonth(object.toString());
-				dailyCount.setIncome(new BigDecimal(dbObject.get("totalIncome").toString()));
+				dailyCount.setIncome(new BigDecimal(dbObject.get("totalIncome").toString()).intValue());
 				dailyCount.setOrderNum(new BigDecimal(dbObject.get("totalNum").toString()).intValue());
-				dailyCount.setIncomeTeam(new BigDecimal(dbObject.get("totalIncomeTeam").toString()));
+				dailyCount.setIncomeTeam(new BigDecimal(dbObject.get("totalIncomeTeam").toString()).intValue());
 				dailyCount.setOrderNumTeam(new BigDecimal(dbObject.get("totalNumTeam").toString()).intValue());
 				results.add(dailyCount);
 			}
@@ -384,4 +382,427 @@
 		return results;
 	}
 
+	private String getTeamReduce() {
+		StringBuilder builder = new StringBuilder();
+		builder.append("function(doc, aggr){ ");
+		builder.append(" aggr.totalReward += doc.teamReward;");
+		builder.append(" aggr.totalRewardNum += doc.teamRewardNum;");
+		builder.append(" aggr.totalSubsidy += doc.teamSubsidy;");
+		builder.append(" aggr.totalSubsidyNum += doc.teamSubsidyNum;");
+		builder.append(" aggr.totalNum += doc.teamDividentsOrderNum;");
+		builder.append(" }");
+		return builder.toString();
+	}
+
+	/**
+	 * 缁熻姣忓ぉ璁㈠崟鏀跺叆銆佹暟閲�
+	 * @param uid
+	 * @param minDate
+	 * @param maxDate
+	 * @return
+	 */
+	public List<OrderMoneyDailyCount> sumTeamGroupByCountDay(Long uid, Date minDate, Date maxDate) {
+		// 鏌ヨ鏉′欢
+		List<Criteria> list = new ArrayList<Criteria>();
+		list.add(Criteria.where("uid").is(uid));
+		if (minDate != null)
+			list.add(Criteria.where("countDay").gte(minDate));
+		if (maxDate != null)
+			list.add(Criteria.where("countDay").lt(maxDate));
+
+		Query query = new Query();
+		if (list.size() > 0) {
+			Criteria[] cas = new Criteria[list.size()];
+			for (int i = 0; i < list.size(); i++)
+				cas[i] = list.get(i);
+			query.addCriteria(new Criteria().andOperator(cas));
+		}
+
+		Map<String, Object> map = new HashMap<>();
+		map.put("totalReward", 0);
+		map.put("totalRewardNum", 0);
+		map.put("totalSubsidy", 0);
+		map.put("totalSubsidyNum", 0);
+		map.put("totalNum", 0);
+		BasicDBObject initial = new BasicDBObject(map);
+
+		// 杩涜鎸夊ぉ銆佸懆銆佹湀鍒嗙粍
+		BasicDBObject agg = new BasicDBObject("countDay", "");
+		DBCollection collection = mongoTemplate.getCollection(collectionName);
+		GroupCommand xx = new GroupCommand(collection, agg, query.getQueryObject(), initial, getTeamReduce(), null);
+		BasicDBList objects = (BasicDBList) collection.group(xx);
+
+		List<OrderMoneyDailyCount> results = new ArrayList<>();
+		if (objects != null) {
+			SimpleDateFormat sdf = new SimpleDateFormat("EEE MMM dd HH:mm:ss z yyyy", Locale.US);
+			for (int i = 0; i < objects.size(); i++) {
+				BasicDBObject dbObject = (BasicDBObject) objects.get(i);
+				if (dbObject == null) {
+					continue;
+				}
+
+				Object object = dbObject.get("countDay");
+				if (object == null) {
+					continue;
+				}
+
+				try {
+					String date = object.toString();
+					Date dtime = sdf.parse(date);
+					OrderMoneyDailyCount dailyCount = new OrderMoneyDailyCount();
+					dailyCount.setCountDay(dtime);
+					dailyCount.setTeamReward(new BigDecimal(dbObject.get("totalReward").toString()).intValue());
+					dailyCount.setTeamRewardNum(new BigDecimal(dbObject.get("totalRewardNum").toString()).intValue());
+					dailyCount.setTeamSubsidy(new BigDecimal(dbObject.get("totalSubsidy").toString()).intValue());
+					dailyCount.setTeamSubsidyNum(new BigDecimal(dbObject.get("totalSubsidyNum").toString()).intValue());
+					dailyCount.setTeamDividentsOrderNum(new BigDecimal(dbObject.get("totalNum").toString()).intValue());
+					results.add(dailyCount);
+				} catch (ParseException e) {
+					e.printStackTrace();
+					continue;
+				}
+			}
+		}
+		return results;
+	}
+
+	/**
+	 *    缁熻姣忔湀璁㈠崟鏀跺叆銆佹暟閲�
+	 * @param uid
+	 * @param minDate
+	 * @param maxDate
+	 * @return
+	 */
+	public List<OrderMoneyDailyCount> sumTeamGroupByYearMonth(Long uid, Date minDate, Date maxDate) {
+		// 鏌ヨ鏉′欢
+		List<Criteria> list = new ArrayList<Criteria>();
+		list.add(Criteria.where("uid").is(uid));
+		if (minDate != null)
+			list.add(Criteria.where("countDay").gte(minDate));
+		if (maxDate != null)
+			list.add(Criteria.where("countDay").lt(maxDate));
+
+		Query query = new Query();
+		if (list.size() > 0) {
+			Criteria[] cas = new Criteria[list.size()];
+			for (int i = 0; i < list.size(); i++)
+				cas[i] = list.get(i);
+			query.addCriteria(new Criteria().andOperator(cas));
+		}
+
+		Map<String, Object> map = new HashMap<>();
+		map.put("totalReward", 0);
+		map.put("totalRewardNum", 0);
+		map.put("totalSubsidy", 0);
+		map.put("totalSubsidyNum", 0);
+		map.put("totalNum", 0);
+		BasicDBObject initial = new BasicDBObject(map);
+
+		// 杩涜鎸夊ぉ銆佸懆銆佹湀鍒嗙粍
+		BasicDBObject agg = new BasicDBObject("yearMonth", "");
+		DBCollection collection = mongoTemplate.getCollection(collectionName);
+		GroupCommand xx = new GroupCommand(collection, agg, query.getQueryObject(), initial, getTeamReduce(), null);
+		BasicDBList objects = (BasicDBList) collection.group(xx);
+
+		List<OrderMoneyDailyCount> results = new ArrayList<>();
+		if (objects != null) {
+			for (int i = 0; i < objects.size(); i++) {
+				BasicDBObject dbObject = (BasicDBObject) objects.get(i);
+				if (dbObject == null) {
+					continue;
+				}
+
+				Object object = dbObject.get("yearMonth");
+				if (object == null) {
+					continue;
+				}
+
+				OrderMoneyDailyCount dailyCount = new OrderMoneyDailyCount();
+				dailyCount.setYearMonth(object.toString());
+				dailyCount.setTeamReward(new BigDecimal(dbObject.get("totalReward").toString()).intValue());
+				dailyCount.setTeamRewardNum(new BigDecimal(dbObject.get("totalRewardNum").toString()).intValue());
+				dailyCount.setTeamSubsidy(new BigDecimal(dbObject.get("totalSubsidy").toString()).intValue());
+				dailyCount.setTeamSubsidyNum(new BigDecimal(dbObject.get("totalSubsidyNum").toString()).intValue());
+				dailyCount.setTeamDividentsOrderNum(new BigDecimal( dbObject.get("totalNum") .toString()).intValue());
+				results.add(dailyCount);
+			}
+		}
+		return results;
+	}
+
+	private String getTeamOrderNumReduce() {
+		StringBuilder builder = new StringBuilder();
+		builder.append("function(doc, aggr){ ");
+		builder.append(" aggr.directOrderNum += doc.directOrderNum;");
+		builder.append(" aggr.inDirectOrderNum += doc.inDirectOrderNum;");
+		builder.append(" aggr.beyondOrderNum += doc.beyondOrderNum;");
+		builder.append(" }");
+		return builder.toString();
+	}
+
+	/**
+	 *    缁熻姣忔湀璁㈠崟鏀跺叆銆佹暟閲�
+	 * @param uid
+	 * @param minDate
+	 * @param maxDate
+	 * @return
+	 */
+	public List<OrderMoneyDailyCount> sumTeamOrderNumGroupByCountDay(Long uid, Date minDate, Date maxDate) {
+		// 鏌ヨ鏉′欢
+		List<Criteria> list = new ArrayList<Criteria>();
+		list.add(Criteria.where("uid").is(uid));
+		if (minDate != null)
+			list.add(Criteria.where("countDay").gte(minDate));
+		if (maxDate != null)
+			list.add(Criteria.where("countDay").lt(maxDate));
+
+		Query query = new Query();
+		if (list.size() > 0) {
+			Criteria[] cas = new Criteria[list.size()];
+			for (int i = 0; i < list.size(); i++)
+				cas[i] = list.get(i);
+			query.addCriteria(new Criteria().andOperator(cas));
+		}
+
+		Map<String, Object> map = new HashMap<>();
+		map.put("directOrderNum", 0);
+		map.put("inDirectOrderNum", 0);
+		map.put("beyondOrderNum", 0);
+		BasicDBObject initial = new BasicDBObject(map);
+
+		// 杩涜鎸夊ぉ銆佸懆銆佹湀鍒嗙粍
+		BasicDBObject agg = new BasicDBObject("countDay", "");
+		DBCollection collection = mongoTemplate.getCollection(collectionName);
+		GroupCommand xx = new GroupCommand(collection, agg, query.getQueryObject(), initial, getTeamOrderNumReduce(),
+				null);
+		BasicDBList objects = (BasicDBList) collection.group(xx);
+
+		List<OrderMoneyDailyCount> results = new ArrayList<>();
+		if (objects != null) {
+			SimpleDateFormat sdf = new SimpleDateFormat("EEE MMM dd HH:mm:ss z yyyy", Locale.US);
+			for (int i = 0; i < objects.size(); i++) {
+				BasicDBObject dbObject = (BasicDBObject) objects.get(i);
+				if (dbObject == null) {
+					continue;
+				}
+
+				Object object = dbObject.get("countDay");
+				if (object == null) {
+					continue;
+				}
+
+				try {
+					String date = object.toString();
+					Date dtime = sdf.parse(date);
+					OrderMoneyDailyCount dailyCount = new OrderMoneyDailyCount();
+					dailyCount.setCountDay(dtime);
+					dailyCount.setDirectOrderNum(new BigDecimal(dbObject.get("directOrderNum").toString()).intValue());
+					dailyCount.setInDirectOrderNum(
+							new BigDecimal(dbObject.get("inDirectOrderNum").toString()).intValue());
+					dailyCount.setBeyondOrderNum(new BigDecimal(dbObject.get("beyondOrderNum").toString()).intValue());
+					results.add(dailyCount);
+				} catch (Exception e) {
+					e.printStackTrace();
+				}
+			}
+		}
+		return results;
+	}
+
+	/**
+	 *    缁熻姣忔湀璁㈠崟鏀跺叆銆佹暟閲�
+	 * @param uid
+	 * @param minDate
+	 * @param maxDate
+	 * @return
+	 */
+	public List<OrderMoneyDailyCount> sumTeamOrderNumGroupByYearMonth(Long uid, Date minDate, Date maxDate) {
+		// 鏌ヨ鏉′欢
+		List<Criteria> list = new ArrayList<Criteria>();
+		list.add(Criteria.where("uid").is(uid));
+		if (minDate != null)
+			list.add(Criteria.where("countDay").gte(minDate));
+		if (maxDate != null)
+			list.add(Criteria.where("countDay").lt(maxDate));
+
+		Query query = new Query();
+		if (list.size() > 0) {
+			Criteria[] cas = new Criteria[list.size()];
+			for (int i = 0; i < list.size(); i++)
+				cas[i] = list.get(i);
+			query.addCriteria(new Criteria().andOperator(cas));
+		}
+
+		Map<String, Object> map = new HashMap<>();
+		map.put("directOrderNum", 0);
+		map.put("inDirectOrderNum", 0);
+		map.put("beyondOrderNum", 0);
+		BasicDBObject initial = new BasicDBObject(map);
+
+		// 杩涜鎸夊ぉ銆佸懆銆佹湀鍒嗙粍
+		BasicDBObject agg = new BasicDBObject("yearMonth", "");
+		DBCollection collection = mongoTemplate.getCollection(collectionName);
+		GroupCommand xx = new GroupCommand(collection, agg, query.getQueryObject(), initial, getTeamOrderNumReduce(),
+				null);
+		BasicDBList objects = (BasicDBList) collection.group(xx);
+
+		List<OrderMoneyDailyCount> results = new ArrayList<>();
+		if (objects != null) {
+			for (int i = 0; i < objects.size(); i++) {
+				BasicDBObject dbObject = (BasicDBObject) objects.get(i);
+				if (dbObject == null) {
+					continue;
+				}
+
+				Object object = dbObject.get("yearMonth");
+				if (object == null) {
+					continue;
+				}
+
+				OrderMoneyDailyCount dailyCount = new OrderMoneyDailyCount();
+				dailyCount.setYearMonth(object.toString());
+				dailyCount.setDirectOrderNum(new BigDecimal(dbObject.get("directOrderNum").toString()).intValue());
+				dailyCount.setInDirectOrderNum(new BigDecimal(dbObject.get("inDirectOrderNum").toString()).intValue());
+				dailyCount.setBeyondOrderNum(new BigDecimal(dbObject.get("beyondOrderNum").toString()).intValue());
+
+				results.add(dailyCount);
+			}
+		}
+		return results;
+	}
+
+	/**
+	 *    缁熻姣忔湀璁㈠崟鏀跺叆銆佹暟閲�
+	 * @param uid
+	 * @param minDate
+	 * @param maxDate
+	 * @return
+	 */
+	public List<OrderMoneyDailyCount> sumTeamOrderNumGroupByUid(Long uid, Date minDate, Date maxDate) {
+		// 鏌ヨ鏉′欢
+		List<Criteria> list = new ArrayList<Criteria>();
+		list.add(Criteria.where("uid").is(uid));
+		if (minDate != null)
+			list.add(Criteria.where("countDay").gte(minDate));
+		if (maxDate != null)
+			list.add(Criteria.where("countDay").lt(maxDate));
+
+		Query query = new Query();
+		if (list.size() > 0) {
+			Criteria[] cas = new Criteria[list.size()];
+			for (int i = 0; i < list.size(); i++)
+				cas[i] = list.get(i);
+			query.addCriteria(new Criteria().andOperator(cas));
+		}
+
+		Map<String, Object> map = new HashMap<>();
+		map.put("directOrderNum", 0);
+		map.put("inDirectOrderNum", 0);
+		map.put("beyondOrderNum", 0);
+		BasicDBObject initial = new BasicDBObject(map);
+
+		// 杩涜鎸夊ぉ銆佸懆銆佹湀鍒嗙粍
+		BasicDBObject agg = new BasicDBObject("uid", "");
+		DBCollection collection = mongoTemplate.getCollection(collectionName);
+		GroupCommand xx = new GroupCommand(collection, agg, query.getQueryObject(), initial, getTeamOrderNumReduce(),
+				null);
+		BasicDBList objects = (BasicDBList) collection.group(xx);
+
+		List<OrderMoneyDailyCount> results = new ArrayList<>();
+		if (objects != null) {
+			for (int i = 0; i < objects.size(); i++) {
+				BasicDBObject dbObject = (BasicDBObject) objects.get(i);
+				if (dbObject == null) {
+					continue;
+				}
+
+				Object object = dbObject.get("uid");
+				if (object == null) {
+					continue;
+				}
+
+				OrderMoneyDailyCount dailyCount = new OrderMoneyDailyCount();
+				dailyCount.setDirectOrderNum(new BigDecimal(dbObject.get("directOrderNum").toString()).intValue());
+				dailyCount.setInDirectOrderNum(new BigDecimal(dbObject.get("inDirectOrderNum").toString()).intValue());
+				dailyCount.setBeyondOrderNum(new BigDecimal(dbObject.get("beyondOrderNum").toString()).intValue());
+
+				results.add(dailyCount);
+			}
+		}
+		return results;
+	}
+
+	/**
+	 * 鏍规嵁璁㈠崟鎺掕姒滆繘琛寀id鍒嗙粍璁㈠崟鏁伴噺鎺掑簭
+	 * @param uid
+	 * @param minDate
+	 * @param maxDate
+	 * @return
+	 */
+	public List<OrderRankingVO> getRankingByOrderNum(Long uid, Date minDate, Date maxDate) {
+		LookupOperation lookupToLots = LookupOperation.newLookup().from("order_money_daily_count").// 鍏宠仈琛ㄥ悕锛屽鏂�
+				localField("workerUid").// 涓昏〃鍏宠仈瀛楁
+				foreignField("uid").// 娆¤〃瀛楁鍏宠仈瀛楁
+				as("orders"); // 娆¤〃鐨勫埆鍚�
+
+		// 鏌ヨ鏉′欢
+		List<Criteria> list = new ArrayList<Criteria>();
+		list.add(Criteria.where("bossUid").is(uid));
+		list.add(Criteria.where("orders.orderNum").gt(0));
+		if (minDate != null) {
+			minDate = DateUtil.reduceDay(minDate, 1);
+			list.add(Criteria.where("orders.countDay").gt(minDate));
+		}
+		if (maxDate != null) {
+			maxDate = DateUtil.reduceDay(maxDate, 1);
+			list.add(Criteria.where("orders.countDay").lte(maxDate));
+		}
+		// 杞崲鏁扮粍
+		Criteria[] cas = new Criteria[list.size()];
+		for (int i = 0; i < list.size(); i++)
+			cas[i] = list.get(i);
+		// 鏌ヨ鍙傛暟
+		Criteria criteria = new Criteria().andOperator(cas);
+
+		List<AggregationOperation> aggs = new ArrayList<>();
+		// 宸﹁繛鎺�
+		aggs.add(lookupToLots);
+		// 鎷嗗垎瀛愭暟缁�
+		aggs.add(Aggregation.unwind("orders"));
+		// 鏉′欢鍖归厤
+		aggs.add(Aggregation.match(criteria));
+		// 闇�瑕佽繑鍥炵殑瀛楁
+		aggs.add(Aggregation.project().and("workerUid").as("workerUid").and("level").as("level").and("orders.orderNum")
+				.as("number"));
+		// 鍒嗙粍姹傚拰骞惰繑鍥�
+		aggs.add(Aggregation.group("workerUid").first("workerUid").as("workerUid").first("level").as("level")
+				.sum("number").as("number"));
+		// 鎺掑簭
+		aggs.add(Aggregation.sort(new Sort(Sort.Direction.DESC, "number")));
+		aggs.add(Aggregation.limit(10));
+
+		// 缁勭粐鏉′欢
+		Aggregation agg = Aggregation.newAggregation(aggs);
+		// 鎵ц鏌ヨ
+		AggregationResults<BasicDBObject> results = mongoTemplate.aggregate(agg, "threeSaleDetail",
+				BasicDBObject.class);
+
+		// 杩斿洖缁撴灉澶勭悊
+		List<BasicDBObject> livevideo = results.getMappedResults();
+
+		List<OrderRankingVO> resultList = new ArrayList<>();
+		for (BasicDBObject obj : livevideo) {
+			Object object = obj.get("workerUid");
+			if (object == null) {
+				continue;
+			}
+
+			OrderRankingVO vo = new OrderRankingVO();
+			vo.setUid(new BigDecimal(obj.get("workerUid").toString()).longValue());
+			vo.setGrade(new BigDecimal(obj.get("level").toString()).intValue());
+			vo.setNumber(new BigDecimal(obj.get("number").toString()).intValue());
+			resultList.add(vo);
+		}
+		return resultList;
+	}
 }

--
Gitblit v1.8.0