package com.moral.monitor.controller;

import java.util.HashMap;
import java.util.LinkedHashMap;
import java.util.List;
import java.util.Map;

import javax.servlet.http.HttpServletRequest;

import org.apache.commons.collections.CollectionUtils;
import org.apache.commons.lang.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.ResponseBody;
import org.springframework.web.bind.annotation.RestController;

import com.alibaba.fastjson.JSON;
import com.moral.monitor.entity.AccountEntity;
import com.moral.monitor.entity.Equipment;
import com.moral.monitor.entity.State;
import com.moral.monitor.service.ScreenApiService;
import com.moral.monitor.service.ScreenService;
import com.moral.monitor.util.Crypto;
import com.moral.monitor.util.ScreenApiData;

/**
 * Created by a on 2017/7/12.
 */
@RestController
@RequestMapping(value = "screen")
public class ScreenApiController {

	@Autowired
    ScreenApiService screenApiService;

    @Autowired
    private ScreenService screenService;
    /**
     * 所有区域/指定区域 设备状态：总数，正常，离线，报警。返回数量信息
     * @param area  地区信息，值为空 字符串则查询所有设备
     * @return
     */
     @RequestMapping(value = "equcount")
     @ResponseBody
    public ScreenApiData equstatus(String area){

        area = area.trim();

        ScreenApiData screenApiData = new ScreenApiData();
        LinkedHashMap<String, Integer> map = new LinkedHashMap<String, Integer>();

        int total = screenApiService.equstatus_total(area);
        int ok = screenApiService.equstatus_online(area);
        int warn = screenApiService.equstatus_warn(area);
        int offline = screenApiService.equstatus_offline(area);

        map.put("total",total);
        map.put("ok",ok);
        map.put("warn",warn);
        map.put("offline",offline);

        String data = JSON.toJSONString(map);
        screenApiData.setData(data);
        return screenApiData;
    }


    /**
     * 所有/区域 设备列表：总数，正常，离线，报警。返回实体信息列表。 ,
     * @param area        值为空字符串则查询所有区域
     * @param pageIndex   pageIndex ,pageSize 默认为 1 ，10
     * @param pageSize
     * @param status     status值约定为  在线 离线 报警，为空字符串则为 查询所有状态
     * @return
     */
    @RequestMapping(value = "equlist")
    @ResponseBody
    public ScreenApiData equlist(String area,String pageIndex,String pageSize,String status){

        area   = area.trim();
        status = status.trim();

        int index=Integer.parseInt(pageIndex);
        int  size=Integer.parseInt(pageSize);
            index =(index-1)*size;

        List<Equipment> equlist = screenApiService.equlist(area, index, size, status);
        int total = screenApiService.equlist_size(area, status);

        int totalpages;
        if (total % size == 0) {
            totalpages = total / size;
        } else {
            totalpages = total / size + 1;
        }

        ScreenApiData screenApiData = new ScreenApiData();
        screenApiData.setData(equlist);
        screenApiData.setExtData(totalpages);
        return screenApiData;
    }


    /*按名称搜索设备信息。返回实体信息*/
    @RequestMapping(value = "equinfo")
    @ResponseBody
    public ScreenApiData equinfo(String name,String pageIndex,String pageSize){

        int index=Integer.parseInt(pageIndex);
        int  size=Integer.parseInt(pageSize);
        index =(index-1)*size;

        List<Equipment> equinfo = screenApiService.equinfo(name,index,size);
        int total = screenApiService.equinfo_size(name);

        int totalpages;
        if (total % size == 0) {
            totalpages = total / size;
        } else {
            totalpages = total / size + 1;
        }

        ScreenApiData screenApiData = new ScreenApiData();
        screenApiData.setData(equinfo);
        screenApiData.setExtData(totalpages);
        return screenApiData;

    }



    /* 设备传感器即时数据 */
    @RequestMapping(value = "equsensorstate")
    @ResponseBody
    public ScreenApiData equsensorstate(String mac){
        List<State> equsensorstate = screenApiService.equsensorstate(mac);
        LinkedHashMap<String, Double> map = new LinkedHashMap<String, Double>();
        for (State s: equsensorstate){
            map.put(s.getSensor(),s.getMac_value());
        }
        String data = JSON.toJSONString(map);
        ScreenApiData screenApiData = new ScreenApiData();
        screenApiData.setData(data);
        return screenApiData;
    }


    
	/**
	 * Screen login.
	 *
	 * @param request the request
	 * @return the map
	 */
	@RequestMapping(value = "/login", method = RequestMethod.POST)
	public Map<String, Object> screenLogin(HttpServletRequest request) {
		Map<String, Object> resultMap = new HashMap<String, Object>();
		String msg = "";
		Integer accountId = -1;
		String account = request.getParameter("account");
		String password = request.getParameter("password");
		if (StringUtils.isBlank(account) || StringUtils.isBlank(password)) {
			msg = "用户名及密码不允许为空！";
		} else {
			try {
				password = Crypto.md5(password);
				List<AccountEntity> accountLists = screenService.getAccountLists(account, password);
				if (CollectionUtils.isEmpty(accountLists) || accountLists.size() != 1) {
					msg = "用户名及密码输入错误！";
				} else {
					AccountEntity accountEntity = accountLists.get(0);
					if ("1".equals(accountEntity.getEnable())) {
						msg = "登录成功！";
						accountId = accountEntity.getId();
					} else {
						msg = "您的账号已禁用，请联系管理员！";
					}
				}
			} catch (Exception e) {
				e.printStackTrace();
				msg = "系统正忙，请稍后再试！";
			}
		}
		resultMap.put("msg", msg);
		resultMap.put("accountId", accountId);
		return resultMap;
	}
	
}