package com.moral.controller;

import java.math.BigDecimal;
import java.text.SimpleDateFormat;
import java.time.LocalDate;
import java.time.LocalDateTime;
import java.time.temporal.ChronoUnit;
import java.time.temporal.TemporalAdjusters;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.Collections;
import java.util.Comparator;
import java.util.Date;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

import javax.annotation.Resource;
import javax.servlet.http.HttpServletRequest;

import org.apache.commons.lang3.time.DateUtils;
import org.springframework.util.ObjectUtils;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.moral.common.util.WebUtils;
import com.moral.mapper.AlarmDailyMapper;
import com.moral.mapper.DemoMapper;
import com.moral.mapper.HistoryMapper;


@RestController
@RequestMapping("demo")
public class DemoConreoller {

	@Resource
    private DemoMapper demoMapper;

	@Resource
	private AlarmDailyMapper alarmDailyMapper;

	@Resource
	private HistoryMapper historyMapper;

	@GetMapping("list")
	public List<Map<String, Object>> getDatas(HttpServletRequest request){
		Map<String, Object> parameters = WebUtils.getParametersStartingWith(request, null);
		parameters.put("size", Integer.valueOf(parameters.get("size").toString()));
		List<Map<String, Object>> list = demoMapper.getDatas(parameters);
		Collections.sort(list, new Comparator<Map<String, Object>>() {
			@Override
			public int compare(Map<String, Object> o1, Map<String, Object> o2) {
				return ((Date)o1.get("time")).compareTo((Date)o2.get("time"));
			}
		});
		return list;
	}

	@GetMapping("pollution")
	public List<Map<String, Object>> getPollutionDatas(HttpServletRequest request){
		Map<String, Object> parameters = WebUtils.getParametersStartingWith(request, null);
		Object sensorKey = parameters.get("sensorKey");
		parameters.put("sensorKeys", Arrays.asList(sensorKey));
		parameters.put("start", LocalDate.now().with(TemporalAdjusters.firstDayOfMonth()));
		parameters.put("end", LocalDate.now().with(TemporalAdjusters.firstDayOfNextMonth()));
		List<Map<String, Object>> alarmData = alarmDailyMapper.getAlarmData(parameters);
		Collections.sort(alarmData, new Comparator<Map<String, Object>>() {
			@Override
			public int compare(Map<String, Object> o1, Map<String, Object> o2) {
				return ((BigDecimal) o2.get(sensorKey)).compareTo((BigDecimal) o1.get(sensorKey));
			}
		});
		return alarmData;
	}
	
	@GetMapping("compare")
	public List<Map<String, Object>> getCompareDatas(HttpServletRequest request){
		List<Map<String, Object>> thisMonth = getDatas(request);
		List<Date> timeList = new ArrayList<Date>();
		SimpleDateFormat simpleDateFormat = new SimpleDateFormat("dd日HH时");
		for (Map<String, Object> map : thisMonth) {
			timeList.add(DateUtils.addMonths((Date)map.get("time"), -1));
			JSONObject json = JSON.parseObject(map.remove("aqi_json").toString());
			map.put("this_month_PM2_5",json.get("PM2_5"));
			map.put("this_month_PM10",json.get("PM10"));
			map.put("format_time", simpleDateFormat.format((Date)map.get("time")));
		}
		Map<String, Object> parameters = new HashMap<String, Object>();
		parameters.put("timeList", timeList);
		List<Map<String, Object>> lastMonth = demoMapper.getDatas(parameters);
		for (Map<String, Object> map : thisMonth) {
			String formatTime = map.get("format_time").toString();
			for (Map<String, Object> last : lastMonth) {
				if (formatTime.equals(simpleDateFormat.format((Date)last.get("time")))) {
					JSONObject json = JSON.parseObject(last.remove("aqi_json").toString());
					map.put("last_month_PM2_5",json.get("PM2_5"));
					map.put("last_month_PM10",json.get("PM10"));
					lastMonth.remove(last);
					break;
				}
			}
		}
		return thisMonth;
	}

	/**
	 *
	 * 功能描述: 
	 *
	 * @param: startTime 开始时间
	 * @param: endTime 结束时间
	 * @return:
	 * @author: fengxiang
	 * @date: 2018/7/30 11:27
	 */
    @GetMapping("get-dayaqis")
	public List<Map<String, Object>> getDayAqis(Date startTime,Date endTime) {
		return  demoMapper.selectByTimeZones(startTime,endTime);
	}
    
	@GetMapping("avg")
	public Map<String, Object> getAvgDatas(HttpServletRequest request){
		Map<String, Object> parameters = WebUtils.getParametersStartingWith(request, null);
		parameters.put("sensorKeys", Arrays.asList("e1", "e2", "e3", "e13"));
		LocalDateTime now = LocalDateTime.now();
		parameters.put("start", now.minusHours(1).truncatedTo(ChronoUnit.HOURS));
		parameters.put("end", now.truncatedTo(ChronoUnit.HOURS));
		List<Map<String, Object>> avgs = historyMapper.getAreaAllDataByAccount(parameters);
		if (ObjectUtils.isEmpty(avgs)) {
			return new HashMap<String, Object>();
		} else {
			return avgs.get(0);
		}
	}

}