From 64fa40bb05e09c55617a581e006cd0d25c6fc986 Mon Sep 17 00:00:00 2001
From: yujian <yujian>
Date: 星期五, 11 一月 2019 12:30:28 +0800
Subject: [PATCH] 网页推送、站内信推送时  PushRecord写入推送时间

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

diff --git a/fanli/src/main/java/com/yeshi/fanli/service/impl/user/UserActiveLogServiceImpl.java b/fanli/src/main/java/com/yeshi/fanli/service/impl/user/UserActiveLogServiceImpl.java
index fbd8b64..dad8a40 100644
--- a/fanli/src/main/java/com/yeshi/fanli/service/impl/user/UserActiveLogServiceImpl.java
+++ b/fanli/src/main/java/com/yeshi/fanli/service/impl/user/UserActiveLogServiceImpl.java
@@ -1,14 +1,23 @@
 package com.yeshi.fanli.service.impl.user;
 
+import java.math.BigDecimal;
+import java.text.DecimalFormat;
+import java.text.SimpleDateFormat;
+import java.util.ArrayList;
 import java.util.Date;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
 
 import javax.annotation.Resource;
 
 import org.springframework.stereotype.Service;
+import org.yeshi.utils.DateUtil;
 
 import com.yeshi.fanli.dao.mybatis.user.UserActiveLogMapper;
 import com.yeshi.fanli.entity.bus.user.UserActiveLog;
 import com.yeshi.fanli.service.inter.user.UserActiveLogService;
+import com.yeshi.fanli.util.MoneyBigDecimalUtil;
 
 @Service
 public class UserActiveLogServiceImpl implements UserActiveLogService {
@@ -37,4 +46,297 @@
 		return userActiveLogMapper.selectLatestByUid(uid);
 	}
 
+	
+	@Override
+	public List<Object> countSameDayByChannel(String channel, Integer type, String years,
+			String startTime, String endTime) throws Exception{
+		List<Map<String, Object>> list = userActiveLogMapper.countSameDayByChannel(channel, type, years, 
+				startTime, endTime);
+		
+		if (list == null || list.size() == 0) {
+			return null;
+		} 
+		
+		switch (type){
+			case 1: // 鎸夊ぉ澶勭悊
+				return dayFactory(startTime, endTime, list);
+			case 2: // 鎸夋湀澶勭悊
+				return monthFactory(list);
+			case 3: 
+				return yearFactory(list);
+			default: 
+				return null;
+		}
+	}
+	
+	@Override
+	public List<Object> countSameDayAndBuyGoodsByChannel(String channel, Integer type, String years,
+			String startTime, String endTime) throws Exception {
+		List<Map<String, Object>> list = userActiveLogMapper.countSameDayAndBuyGoodsByChannel(channel, type, years, 
+				startTime, endTime);
+		
+		if (list == null || list.size() == 0) {
+			return null;
+		} 
+		
+		switch (type){
+			case 1: // 鎸夊ぉ澶勭悊
+				return dayFactory(startTime, endTime, list);
+			case 2: // 鎸夋湀澶勭悊
+				return monthFactory(list);
+			case 3: 
+				return yearFactory(list);
+			default: 
+				return null;
+		}
+	}
+	
+	@Override
+	public  List<Map<String, Object>> countOneWeekUserInfo(String channel, String startTime, String endTime, 
+			Integer orderNumber) throws Exception {
+		
+		// 鏃堕棿鍒楄〃
+		List<String> dateList = new ArrayList<String>();
+		// 缁撴灉鍒楄〃
+		List<Map<String, Object>> resultList = new ArrayList<Map<String,Object>>();
+		
+		String middleDay = "";
+		for (int i = 0; i < 100 ; i++) {
+			if (i == 0) {
+				middleDay = startTime;
+			} else {
+				middleDay = DateUtil.plusDay(i, startTime);
+			}
+			
+			dateList.add(middleDay);
+			
+			if (middleDay.equals(endTime)) {
+				break; // 鏃堕棿缁撴潫
+			}
+		}
+		
+		for (String nowDate: dateList) {
+			// 鍔犲叆7澶�
+			String plusDay = DateUtil.plusDay(7, nowDate);
+			
+			// 鎵ц鏌ヨ 骞惰繑鍥炵粨鏋�
+			Map<String, BigDecimal> map= userActiveLogMapper.countOneWeekUserInfo(channel, nowDate, plusDay, orderNumber);
+			
+			// 姣斾緥
+			BigDecimal proportion = null;
+			
+			if (map != null) {
+				// 鏂板鐢ㄦ埛
+				BigDecimal totalUser = map.get("totalUser");
+				// 瀛樺湪璁㈠崟鐨勬柊澧炵敤鎴�
+				BigDecimal orderUser = map.get("orderUser");
+				
+				try {
+					proportion = MoneyBigDecimalUtil.sub(orderUser, totalUser);
+				} catch (Exception e) {
+					e.printStackTrace();
+				}
+			}
+			
+			if (proportion == null) {
+				proportion = new BigDecimal(0);
+			}
+			
+			Map<String, Object> result = new HashMap<String, Object>();
+			result.put("showValue", MoneyBigDecimalUtil.mul(proportion, new BigDecimal(100)));
+			result.put("showDate", nowDate);
+			
+			resultList.add(result);
+		}
+		
+		return resultList;
+		
+	}
+	
+	
+	@Override
+	public List<Object> getBuyProportion(String channel, Integer type, String years,
+			String startTime, String endTime, Integer orderNum) throws Exception{
+		
+		// 缁熻娓犻亾褰撴棩鏂板鐢ㄦ埛
+		List<Object> countList = countSameDayByChannel(channel, type, years, startTime, endTime);
+		
+		if (countList == null || countList.size() == 0) {
+			return null;
+		} 
+		
+		// 缁熻娓犻亾褰撴棩鏂板鐢ㄦ埛瀛樺湪涓嬪崟鐨勭敤鎴锋暟閲�
+		List<Object> countListBuy=  null;
+		if (orderNum <= 1){
+			countListBuy = countSameDayAndBuyGoodsByChannel(channel, type, years, startTime, endTime);
+		} 
+		
+		if (countListBuy == null){
+			new ArrayList<Object>();
+		}
+		
+		List<Object> listObject = new ArrayList<Object>();
+	
+		for (Object object: countList) {
+			
+			float rate = 0;
+			
+			Map<String, Object> mapObject = new HashMap<String, Object>();
+			
+			Map<String, Object> map = (Map<String, Object>) object;
+			Object createDate = map.get("showDate");
+			Object sameDayNum = map.get("showValue");
+			
+			long totle = Long.parseLong(sameDayNum.toString());
+			if (totle > 0 && countListBuy != null && countListBuy.size() > 0) {
+				for (int j = 0; j < countListBuy.size(); j++) {
+					Map<String, Object> mapBuy = (Map<String, Object>) countListBuy.get(j);
+					Object createDate2 = mapBuy.get("showDate");
+					if (createDate.toString().equals(createDate2.toString())) {
+						Object buyNum = mapBuy.get("showValue");
+						long totleBuy = Long.parseLong(buyNum.toString());
+						rate = (float)totleBuy/totle;
+						break;
+					}
+				}
+			}
+			
+			DecimalFormat df = new DecimalFormat("0.00");//鏍煎紡鍖栧皬鏁�
+			mapObject.put("showValue", df.format(rate*100));
+			mapObject.put("showDate", createDate);
+			listObject.add(mapObject);
+		}
+		
+		return listObject;
+	}
+
+	
+	/**
+	 * 澶╂暟鏍煎紡
+	 * @param startTime
+	 * @param endTime
+	 * @param list
+	 * @return
+	 * @throws Exception
+	 */
+	public List<Object> dayFactory(String startTime, String endTime, List<Map<String, Object>> list) throws Exception {
+	    
+		List<Object> listObject = new ArrayList<Object>();
+	
+		if (startTime.equals(endTime)) {
+			
+			Map<String, Object> map = list.get(0);
+			Object sameDayNum = map.get("showValue");
+			
+			if (sameDayNum == null) {
+				map.put("showValue", 0);
+			}
+			listObject.add(map);
+			
+			return listObject;
+		}
+		
+		
+		String plusDay = "";
+		for (int i = 0; i < 1000 ; i++) {
+			if (i == 0) {
+				plusDay = startTime;
+			} else {
+				plusDay = DateUtil.plusDay(i, startTime);
+			}
+			
+			Map<String, Object> mapObject = new HashMap<String, Object>();
+			Object sameDayNum = null; 
+			
+			for (int j = 0; j < list.size(); j++) {
+				Map<String, Object> map = list.get(j);
+				Object createDate = map.get("showDate");
+				String month = createDate.toString();
+				if (plusDay.equalsIgnoreCase(month)) {
+					sameDayNum = map.get("showValue");
+					break;
+				}
+			}
+			
+			if (sameDayNum == null) {
+				sameDayNum = 0;
+			}
+			mapObject.put("showValue", sameDayNum);
+			
+			SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
+	        SimpleDateFormat sdf2 = new SimpleDateFormat("yyyy/MM/dd");
+			Date parseDate = sdf.parse(plusDay.toString());
+			
+			mapObject.put("showDate", sdf2.format(parseDate));
+			
+			listObject.add(mapObject);
+			
+			if (plusDay.equals(endTime)) {
+				break; // 鏃堕棿缁撴潫
+			}
+		}
+		
+		return listObject;
+	}
+	
+	/**
+	 * 鏈堜唤鏍煎紡
+	 * @param list
+	 * @return
+	 */
+	public List<Object> monthFactory(List<Map<String, Object>> list) {
+		
+		List<Object> listObject = new ArrayList<Object>();
+		// 12 涓湀澶勭悊
+		for (int i = 1; i <= 12; i++) {
+			Map<String, Object> mapObject = new HashMap<String, Object>();
+			Object sameDayNum = null;
+			for (int j = 0; j < list.size(); j++) {
+				Map<String, Object> map = list.get(j);
+				Object createDate = map.get("showDate");
+				String month = createDate.toString();
+				if ((i+"").equalsIgnoreCase(month) || i == Integer.parseInt(month)) {
+					sameDayNum = map.get("showValue"); 
+					break;
+				}
+			}
+			
+			if (sameDayNum == null) {
+				sameDayNum = 0;
+			}
+			mapObject.put("showValue", sameDayNum);
+			
+			mapObject.put("showDate", i + "鏈�");
+			
+			listObject.add(mapObject);
+		}
+		return listObject;
+	}
+	
+	/**
+	 * 骞翠唤鏍煎紡
+	 * @param list
+	 * @return
+	 */
+	public List<Object> yearFactory(List<Map<String, Object>> list) {
+		
+		List<Object> listObject = new ArrayList<Object>();
+		
+		for (int i = 0; i < list.size(); i++) {
+			Map<String, Object> map = list.get(i);
+			Object sameDayNum = map.get("showValue"); 
+			Object createDate = map.get("showDate"); 
+			
+			if (sameDayNum == null) {
+				sameDayNum = 0;
+			}
+			map.put("showValue", sameDayNum);
+			map.put("showDate", createDate + "骞�");
+			
+			listObject.add(map);
+		}
+		
+		return listObject;
+	}
+	
 }

--
Gitblit v1.8.0