package com.iamberry.app.service;

import java.util.ArrayList;
import java.util.Calendar;
import java.util.Date;
import java.util.IdentityHashMap;
import java.util.LinkedHashMap;
import java.util.LinkedList;
import java.util.List;
import java.util.Map;

import org.apache.commons.lang3.math.NumberUtils;
import org.joda.time.DateTime;
import org.springframework.stereotype.Service;

import com.iamberry.app.config.Constants;
import com.iamberry.app.core.dto.MilkInfoDTO;
import com.iamberry.app.core.dto.RecordCountInfoDTO;
import com.iamberry.app.core.dto.RecordDTO;
import com.iamberry.app.core.entity.MilkDatetimeValue;
import com.iamberry.app.core.entity.MilkImages;
import com.iamberry.app.core.entity.MilkMakingRecord;
import com.iamberry.app.core.entity.MilkPowderInfo;
import com.iamberry.app.core.entity.User;
import com.iamberry.app.face.MilkService;
import com.iamberry.app.ulitity.Utility;
import com.iamberry.wechat.tools.DateTimeUtil;

/**
 * MilkService
 *
 * @author Moon Cheng
 * @date 2016年3月23日 上午11:33:10
 */
@Service
public class MilkServiceImpl extends BaseService implements MilkService {

	/**
	 * setMilkMakingRecord
	 * @param makingRecord
	 * @param token
	 * @param recordId
	 * @return
	 */
	public MilkMakingRecord setMilkMakingRecord(MilkMakingRecord makingRecord, String token) {
		User userInfo = validateUserToken(token);
		if (userInfo == null) {
			return null;
		}
		makingRecord.setUser(userInfo.getId());
		makingRecord.setTimestamp_(new Date());
		milkMapper.insertMilkMakingRecord(makingRecord);
		return makingRecord;
	}

	/**
	 * searchUserRecordsBytime
	 *
	 * @author Moon Cheng
	 * @param userId
	 * @param startTime
	 * @param endTime
	 * @return Milk Making Record List
	 */
	public Map<String, List<RecordDTO>> searchUserRecordsByTime(Long userId, String dateStatus, String chosenDate,
			String machineMac) {

		Map<String, List<RecordDTO>> recordInfos = new LinkedHashMap<String, List<RecordDTO>>();
		String dateType = null, formatter = null;
		Calendar calendar = Calendar.getInstance();
		if (chosenDate != null) {
			// calendar.setTime(Utility.formatStringToDate("yyyy-MM-dd
			// HH:mm:ss", chosenDate));
			// 防止无数据时显示分钟错误
			chosenDate = chosenDate.substring(0, chosenDate.length() - 6) + ":00:00";
			calendar.setTime(Utility.formatStringToDate("yyyy-MM-dd HH:mm:ss", chosenDate));
		} else {
			calendar.setTime(new Date());
		}
		Date start = null, end = null;
		switch (dateStatus) {
		case "day":
			dateType = "days";
			formatter = "%Y%m%d%H";
			calendar.set(calendar.get(Calendar.YEAR), calendar.get(Calendar.MONDAY), calendar.get(Calendar.DATE), 0, 0,
					0);
			start = calendar.getTime();
			calendar.set(calendar.get(Calendar.YEAR), calendar.get(Calendar.MONDAY), calendar.get(Calendar.DATE), 23,
					59, 59);
			end = calendar.getTime();
			recordInfos.put("app", Utility.convertMap(
					milkMapper.selectMilkMakingRecords(start, end, "app", dateType, formatter, userId, machineMac),
					dateType));
			recordInfos.put("machine", Utility.convertMap(
					milkMapper.selectMachineMilkMakingRecords(start, end, "machine", dateType, formatter, machineMac),
					dateType));
			break;
		case "week":
			dateType = "weeks";
			formatter = "%Y%m%d";
			calendar.set(calendar.get(Calendar.YEAR), calendar.get(Calendar.MONDAY), calendar.get(Calendar.DATE), 0, 0,
					0);
			calendar.set(Calendar.DAY_OF_WEEK, Calendar.MONDAY);
			start = calendar.getTime();
			calendar.set(calendar.get(Calendar.YEAR), calendar.get(Calendar.MONDAY), calendar.get(Calendar.DATE), 23,
					59, 59);
			if (Calendar.SUNDAY < Calendar.MONDAY) {
				calendar.add(Calendar.DATE, 7);
			}
			calendar.set(Calendar.DAY_OF_WEEK, Calendar.SUNDAY);
			end = calendar.getTime();
			recordInfos.put("app", Utility.convertMap(
					milkMapper.selectMilkMakingRecords(start, end, "app", dateType, formatter, userId, machineMac),
					dateType));
			recordInfos.put("machine", Utility.convertMap(
					milkMapper.selectMachineMilkMakingRecords(start, end, "machine", dateType, formatter, machineMac),
					dateType));
			break;
		case "year":
			dateType = "years";
			formatter = "%Y%m";
			calendar.set(calendar.get(Calendar.YEAR), 0, 1, 0, 0, 0);
			start = calendar.getTime();
			calendar.set(calendar.get(Calendar.YEAR), 11, 31, 23, 59, 59);
			end = calendar.getTime();
			recordInfos.put("app", Utility.convertMap(
					milkMapper.selectMilkMakingRecords(start, end, "app", dateType, formatter, userId, machineMac),
					dateType));
			recordInfos.put("machine", Utility.convertMap(
					milkMapper.selectMachineMilkMakingRecords(start, end, "machine", dateType, formatter, machineMac),
					dateType));
			break;
		}
		return Utility.fillAppMachineRecordWithZero(Utility.synAppMachineRecord(recordInfos), dateType, chosenDate);
	}

	/**
	 * searchUserRecordById
	 *
	 * @author Moon Cheng
	 * @param recordId
	 * @return Milk Making Record Information
	 */
	public MilkMakingRecord searchUserRecordById(Long recordId) {
		MilkMakingRecord makingRecord = milkMapper.selectMilkMakingRecord(recordId);
		return makingRecord;
	}

	/**
	 * 根据用户，获取冲奶记录的-->总量和次数
	 *
	 * @author Moon Cheng
	 * @param userId
	 * @return
	 */
	public RecordCountInfoDTO getTotalMilkVolumeMadeByUser(Long userId) {
		RecordCountInfoDTO recordcount = milkMapper.getMilkPowderSumByUser(userId);
		return  recordcount;
	}

	/**
	 * setMilkPowderInfo
	 *
	 * @author Moon Cheng
	 * @param entity
	 * @param token
	 * @return Milk Powder Information
	 */
	public MilkPowderInfo setMilkPowderInfo(MilkPowderInfo entity, String token) {
		User userInfo = validateUserToken(token);
		if (userInfo == null) {
			return null;
		}

		// change status as user's phone number
		entity.setStatus_(
				userInfo.getUsername().length() > 11 ? Constants.MILK_POWDER_NOT_APPROVED : userInfo.getUsername());
		entity.setCreated_on(new Date());
		milkMapper.insertMilkPowderInfo(entity);
		return entity;
	}

	/**
	 * searchMilkPowderInfoByBarCode
	 *
	 * @author Moon Cheng
	 * @param barcode
	 * @return Milk Powder Information
	 */
	public MilkPowderInfo searchMilkPowderInfoByBarCode(String barcode) {
		MilkPowderInfo milkPowderInfo = milkMapper.selectMilkPowderInfo(barcode);
		return milkPowderInfo;
	}

	/**
	 * 
	 * 通过品牌名获取奶粉信息
	 * @author Moon Cheng, Yin
	 * @param brand
	 * @return Milk Powder List
	 */
	public Map<String, List<String>> searchMilkPowderInfosByBrand(String brand) {
		brand = "%" + brand.trim() + "%";
		Map<String, List<String>> infos = new IdentityHashMap<String, List<String>>();
		List<MilkInfoDTO> milkInfo = milkMapper.selectMilkInfoBybrand(brand);
		for (int i = 0; i < milkInfo.size(); i++) {
			List<String> list = new LinkedList<String>();
			list.add(milkInfo.get(i).getLevel() + ":" + milkInfo.get(i).getType() + ":"
					+ milkInfo.get(i).getPowder_ratio() + ":" + milkInfo.get(i).getId() + ":"
					+ milkInfo.get(i).getWeight_per_spoon());
			infos.put(milkInfo.get(i).getSeries(),list);
		}
		
		return infos;
	}

	/**
	 * searchMilkPowderBrand
	 *
	 * @return Brand List
	 */
	public List<String> searchMilkPowderBrand() {
		List<String> milkPowderInfos = milkMapper.selectMilkPowderBrand();
		List<String> result = new ArrayList<>();
		milkPowderInfos.forEach(milk -> {
			if (NumberUtils.isNumber(milk) && milk.contains(".")) {
				milk = milk.substring(0, milk.indexOf("."));
			}
			result.add(milk);
		});
		return result;
	}

	/**
	 * searchMilkInfoByBrandSeriesLevel
	 *
	 * @param brand
	 * @param series
	 * @param level
	 * @return
	 */
	public MilkPowderInfo searchMilkInfoByBrandSeriesLevel(String brand, String series, String level) {
		return milkMapper.selectMilkInfoByBrandSeriesLevel(brand, series, level);
	}

	// =====================================TuyaHistoryData======================================
	/**
	 * getLastRecordDate
	 *
	 * @return
	 */
	public Date getLastRecordDate() {
		Date lastDate = milkMapper.selectLastRecordDate();
		return lastDate == null ? new Date() : lastDate;
	}

	/**
	 * addRecordData
	 * @param devId
	 * @param value
	 * @param time
	 */
	public void addRecordData(String devId, String value, Long time, Long userId) {
		MilkMakingRecord milkMakingRecord = new MilkMakingRecord();
		milkMakingRecord.setVolume(Integer.parseInt(value));
		milkMakingRecord.setMachine(devId);
		milkMakingRecord.setTimestamp_(new Date(time));
		milkMakingRecord.setUser(userId);
		milkMapper.insertRecordData(milkMakingRecord);
	}

	@Override
	public void setMilkImages(MilkImages images) {
		// TODO Auto-generated method stub
		milkMapper.insertMilkImages(images);
	}

	@Override
	public List<MilkDatetimeValue> getMilkRecordByTime(String mac, String date) {
		// TODO Auto-generated method stub
		
		// 处理搜索的时间
		date = (date != null ? date : DateTimeUtil.format(new Date(), "yyyy-MM-dd"));
		
		// 获取时间区间
		Date startDate = DateTimeUtil.parse(date, "yyyy-MM-dd");
		
		Calendar calendar = Calendar.getInstance();
		calendar.setTime(startDate);
		calendar.set(Calendar.HOUR_OF_DAY, 24);
		
		// 获取
		List<MilkDatetimeValue> list = milkMapper.getMilkRecordByTime(mac, startDate, calendar.getTime());
		return list;
	}

	@Override
	public List<MilkDatetimeValue> getMilkRecordByDate(String mac, String date) {
		
		// 处理搜索的时间
		date = (date != null ? date : DateTimeUtil.format(new Date(), "yyyy-MM"));
		
		// 判断统计单位：年份或者是月
		boolean isYear = false;
		if (date.indexOf("-") == -1) {
			isYear = true;
		}
		
		// year =  true 表示统计年份，false : 表示统计月
		final boolean year = isYear;
		
		// 返回的数据格式
		String dateFormat = year ? "yyyy-MM" : "yyyy-MM-dd";
		
		// 获取时间区间
		Date startDate = year ? DateTimeUtil.parse(date, "yyyy") : DateTimeUtil.parse(date, "yyyy-MM");
		Date endDate = getLastDayOfYear(startDate, year);
		
		// 查询数据
		List<MilkDatetimeValue> values = milkMapper.getMilkRecordByDate(year, mac, startDate, endDate);
		
		// 如果为空需要填充数据到8条
		if (values == null || values.size() <= 0) {
			values = new ArrayList<MilkDatetimeValue>();
			Date tempDate = startDate;
			for (int i = 0; i < 8; i++) {
				values.add(new MilkDatetimeValue(DateTimeUtil.format(tempDate, dateFormat), 0));
				tempDate = getDate(tempDate, year);
			}
			return values;
		}
		
		// 创建返回对象
		List<MilkDatetimeValue> returnValues = new ArrayList<MilkDatetimeValue>(year ? 12 : 31);
		
		// 当前已经填充的时间
		Date paddDate = null;
		
		for (int i = 0; i < values.size(); i++) {
			
			// 获取当前迭代的数据，如果为空，那么跳过
			MilkDatetimeValue milkDatetimeValue = values.get(i);
			if (milkDatetimeValue == null || milkDatetimeValue.getDateTime() == null) {
				continue;
			}
			
			// 获取当前时间
			Date temp = DateTimeUtil.parse(milkDatetimeValue.getDateTime(), dateFormat);
			
			// 填充
			paddDate = padding(temp, returnValues, year, paddDate, milkDatetimeValue);
		}
		
		// 保证返回数据为8条，可能还需要填充
		if (returnValues.size() <= 8) {
			int count = 8 - returnValues.size();
			Date tempDate = DateTimeUtil.parse(returnValues.get(returnValues.size() - 1).getDateTime(), dateFormat);
			for (int i = 0; i < count; i++) {
				tempDate = getAddDate(tempDate, year);
				returnValues.add(new MilkDatetimeValue(DateTimeUtil.format(tempDate, dateFormat), 0));
			}
		}
		
		// 返回
		return returnValues;
	}
	
	/**
	 * 填充数据方法
	 * @param dateYear
	 * @param values
	 * @param isYear
	 * @author 献
	 * @Time   2016年12月12日
	 */
	public static Date padding(Date dateYear, List<MilkDatetimeValue> values, final boolean isYear, Date paddDate, MilkDatetimeValue milkDatetimeValue) {
		
		// 填充的原则是，如果已经填充过的时间为空，表示可以填充；
		// 如果需要填充的时间大于已经填充的时间，表示可以填充
		if (paddDate == null || dateYear.getTime() > paddDate.getTime()) {
			// next
			Date nextDate = getUpDate(dateYear, isYear);
			if (nextDate != null) {
				padding(nextDate, values, isYear, paddDate, null);
			}
			
			// add Data
			MilkDatetimeValue datetimeValue = new MilkDatetimeValue();
			datetimeValue.setDateTime(DateTimeUtil.format(dateYear, isYear ? "yyyy-MM" : "yyyy-MM-dd"));
			datetimeValue.setValue(milkDatetimeValue == null ? 0 : milkDatetimeValue.getValue());
			values.add(datetimeValue);
			
			// 替换已经填充过的时间
			paddDate = dateYear;
		}
		return paddDate;
	}
	
	/**
	 * 根据当前时间，获取上一个记录的时间
	 * @param date
	 * @param isYear
	 * @return
	 * @author 献
	 * @Time   2016年12月12日
	 */
	public static Date getUpDate(Date date, final boolean isYear) {
		Calendar cal = Calendar.getInstance();
        cal.setTime(date);
        if (isYear) {
        	// 如果当前月份为1月，那么，不需要处理啦，应该跳过
        	if (cal.get(Calendar.MONTH) == 0) {
        		return null;
        	}
        	cal.add(Calendar.MONTH, -1);
        } else {
        	// 如果当前天为1日，那么，不需要处理啦，应该跳过
        	if (cal.get(Calendar.DAY_OF_MONTH) <= 1) {
        		return null;
        	}
            cal.add(Calendar.DAY_OF_MONTH, -1);
        }
		return cal.getTime();
	}
	
	public static Date getDate(Date date, final boolean isYear) {
		Calendar cal = Calendar.getInstance();
        cal.setTime(date);
        if (isYear) {
        	cal.add(Calendar.MONTH, -1);
        } else {
            cal.add(Calendar.DAY_OF_MONTH, -1);
        }
		return cal.getTime();
	}
	
	public static Date getAddDate(Date date, final boolean isYear) {
		Calendar cal = Calendar.getInstance();
        cal.setTime(date);
        if (isYear) {
        	cal.add(Calendar.MONTH, +1);
        } else {
            cal.add(Calendar.DAY_OF_MONTH, +1);
        }
		return cal.getTime();
	}

	/**
	 * 根据一个数据获取对应的结束时间，如果是年，获取本年最后一个月的最后一天
	 * @param date
	 * @param year
	 * @return
	 * @author 献
	 * @Time   2016年12月12日
	 */
    public static Date getLastDayOfYear(Date date, boolean year) {
    	Calendar cal = Calendar.getInstance();
        cal.setTime(date);
        cal.set(Calendar.HOUR_OF_DAY, 24);
        cal.set(Calendar.DAY_OF_MONTH, cal.getActualMaximum(Calendar.DAY_OF_MONTH));
        if (year) {
        	cal.set(Calendar.MONTH, cal.getActualMaximum(Calendar.MONTH));
        }
        return cal.getTime();
    }
}