package com.moral.monitor.controller;

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.serializer.SerializerFeature;
import com.moral.monitor.entity.*;
import com.moral.monitor.service.MgrService;
import com.moral.monitor.util.Round;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;

import javax.annotation.Resource;
import java.util.*;

/**
 * Created by a on 2017/7/19.
 */
@Controller
public class MgrController {

    @Resource
    MgrService mgrService;

    @RequestMapping(value = "randpoint")
    @ResponseBody
    public Map randpoint(){

        List<MonitorPoint> randpoint = mgrService.randpoint();

        LinkedHashMap<String, List<Equipment>> point_equ = new LinkedHashMap<String, List<Equipment>>();


        for (MonitorPoint point:randpoint){
            String name = point.getName();
            List<Equipment> equipments = mgrService.pointequ(name);
            if (equipments.size()>0){
                point_equ.put(name,equipments);
            }
        }


        Set<Map.Entry<String, List<Equipment>>> entries = point_equ.entrySet();
        Iterator<Map.Entry<String, List<Equipment>>> iterator = entries.iterator();

        ArrayList<PointAvg> pointAvgs = new ArrayList<PointAvg>();

        //所有平均构成 最终的平均
        double[] totle={0,0,0,0,0,0};// pm2.5 pm10,co,no2,so2,o3
        while (iterator.hasNext()){  //点
            Map.Entry<String, List<Equipment>> next = iterator.next();
            String name = next.getKey();
            List<Equipment> equipments = next.getValue();

            //设备的平均-->组成监测点的平均
            double[] equsv={0,0,0,0,0,0};
            for(Equipment e:equipments ){  //设备
                String mac = e.getMac();
                List<State> equsensorstate = mgrService.equsensorstate(mac);
                   for (State s:equsensorstate){    //设备传感器
                       String sensor = s.getSensor();
                       if (sensor.equals("Pm2.5")){
                           double mac_value = s.getMac_value();
                           equsv[0]+=mac_value;
                       }else if (sensor.equals("Pm10")){
                           double mac_value = s.getMac_value();
                           equsv[1]+=mac_value;
                       }else if (sensor.equals("一氧化碳（CO）")){
                           double mac_value = s.getMac_value();
                           equsv[2]+=mac_value;
                       }else if (sensor.equals("二氧化氮（NO2）")){
                           double mac_value = s.getMac_value();
                           equsv[3]+=mac_value;
                       }else if (sensor.equals("二氧化硫（SO2）")){
                           double mac_value = s.getMac_value();
                           equsv[4]+=mac_value;
                       }else if (sensor.equals("臭氧（O3）")){
                           double mac_value = s.getMac_value();
                           equsv[5]+=mac_value;
                       }
                   }
            }


            int size = equipments.size();
            for (int i = 0; i <equsv.length; i++) {
                equsv[i]=equsv[i]/size;
            }

            for (int i = 0; i < totle.length; i++) {
                totle[i]+=equsv[i];
            }

            //构建监测点
            PointAvg pa = new PointAvg();
            pa.setName(name);
            pa.setPm25(equsv[0]);
            pa.setPm10(equsv[1]);
            pa.setCo(equsv[2]);
            pa.setNo2(equsv[3]);
            pa.setSo2(equsv[4]);
            pa.setO3(equsv[5]);
            pointAvgs.add(pa);

        }

         //总平均
        int size = entries.size();
        for (int i = 0; i < totle.length; i++) {
            totle[i]=totle[i]/size;
            totle[i] = Round.digit(totle[i], 0);
        }

        Map<String, Object> data = new LinkedHashMap<String, Object>();
        data.put("data",pointAvgs);
        data.put("avg",totle);
        return  data;
    }




    @RequestMapping(value = "top100")
    @ResponseBody
    public String top100(){

        List<MonitorPoint> randpoint = mgrService.allpoint();

        LinkedHashMap<String, List<Equipment>> point_equ = new LinkedHashMap<String, List<Equipment>>();



        for (MonitorPoint point:randpoint){
            String name = point.getName();
            List<Equipment> equipments = mgrService.pointequ(name);
            if (equipments.size()>0){
                point_equ.put(name,equipments);
            }
        }



        Set<Map.Entry<String, List<Equipment>>> entries = point_equ.entrySet();
        Iterator<Map.Entry<String, List<Equipment>>> iterator = entries.iterator();

        ArrayList<PointAvg> pointAvgs = new ArrayList<PointAvg>();

        //所有平均构成 最终的平均
        double[] totle={0,0,0,0,0,0};// pm2.5 pm10,co,no2,so2,o3
        while (iterator.hasNext()){ //点
            Map.Entry<String, List<Equipment>> next = iterator.next();
            String name = next.getKey();
            List<Equipment> equipments = next.getValue();

            //设备的平均-->组成监测点的平均
            double[] equsv={0,0,0,0,0,0};
            for(Equipment e:equipments ){  //设备
                String mac = e.getMac();
                List<State> equsensorstate = mgrService.equsensorstate(mac);
                for (State s:equsensorstate){    //设备传感器
                    String sensor = s.getSensor();
                    if (sensor.equals("Pm2.5")){
                        double mac_value = s.getMac_value();
                        equsv[0]+=mac_value;
                    }else if (sensor.equals("Pm10")){
                        double mac_value = s.getMac_value();
                        equsv[1]+=mac_value;
                    }else if (sensor.equals("一氧化碳（CO）")){
                        double mac_value = s.getMac_value();
                        equsv[2]+=mac_value;
                    }else if (sensor.equals("二氧化氮（NO2）")){
                        double mac_value = s.getMac_value();
                        equsv[3]+=mac_value;
                    }else if (sensor.equals("二氧化硫（SO2）")){
                        double mac_value = s.getMac_value();
                        equsv[4]+=mac_value;
                    }else if (sensor.equals("臭氧（O3）")){
                        double mac_value = s.getMac_value();
                        equsv[5]+=mac_value;
                    }
                }
            }


            int size = equipments.size();
            for (int i = 0; i <equsv.length; i++) {
                equsv[i]=equsv[i]/size;
            }

            for (int i = 0; i < totle.length; i++) {
                totle[i]+=equsv[i];

            }

            //构建监测点
            PointAvg pa = new PointAvg();
            pa.setName(name);
            pa.setPm25(equsv[0]);
            pa.setPm10(equsv[1]);
            pa.setCo(equsv[2]);
            pa.setNo2(equsv[3]);
            pa.setSo2(equsv[4]);
            pa.setO3(equsv[5]);
            pointAvgs.add(pa);

        }

        //总平均
        int size = entries.size();
        for (int i = 0; i < totle.length; i++) {
            totle[i]=totle[i]/size;
            totle[i] = Round.digit(totle[i], 0);
        }



        Map<String, Object> data = new LinkedHashMap<String, Object>();
        Collections.sort(pointAvgs);

        ArrayList<PointAvg> top100 = new ArrayList<PointAvg>();
        ArrayList<PointAvg> top10 =  new ArrayList<PointAvg>();
        ArrayList<PointAvg> last10 = new ArrayList<PointAvg>();

        int s = pointAvgs.size();


        if(s<=100){
            //取出所有
            for(PointAvg i:pointAvgs){
                top100.add(i);
            }
        }else {
            for (int i=0;i<100;i++){
                //取出前100
                PointAvg v = pointAvgs.get(i);
                top100.add(v);
            }
        }



        //前十后十
        if(s<=10){
            for(PointAvg i:pointAvgs){
                //取出前10
                top10.add(i);
            }
            //取出last10
            for (int i =s-1; i >= 0; i--) {
                PointAvg v = pointAvgs.get(i);
                last10.add(v);
            }

        }else {
            for (int i=0;i<10;i++){
                //取出前10
                PointAvg v = pointAvgs.get(i);
                top10.add(v);
            }
            //取出last10
            for (int i =s-1; i >=s-10; i--) {
                PointAvg v = pointAvgs.get(i);
                last10.add(v);
            }
        }



        data.put("top100",top100);
        data.put("top10",top10);

        data.put("last10",last10);

        String s1 = JSON.toJSONString(data, SerializerFeature.DisableCircularReferenceDetect);
        System.out.println(s1);
        return  s1;
    }



    @RequestMapping("/allPointInstantData")
    @ResponseBody
    public Map allPointInstantData(@RequestBody QueryHelper queryHelper){

        String search = queryHelper.getSearch();

        String trim = queryHelper.getSearch().trim();
        if(trim.equals("")){
            queryHelper.setSearch("");
        }


        LinkedHashMap<String, Object> map = new LinkedHashMap<String, Object>();

        List<PointAvg> pointAvgs = mgrService.allPointsData(queryHelper);

        int total = mgrService.pointcount(queryHelper);

        for (PointAvg pointavg:pointAvgs){
            String name = pointavg.getName();
            List<Equipment> equipments = mgrService.pointequ(name);



            //设备的平均-->组成监测点的平均
            double[] equsv={0,0,0,0,0,0};
            for(Equipment e:equipments ){  //设备
                String mac = e.getMac();
                List<State> equsensorstate = mgrService.equsensorstate(mac);
                for (State s:equsensorstate){  //设备传感器
                    String sensor = s.getSensor();
                    if (sensor.equals("Pm2.5")){
                        double mac_value = s.getMac_value();
                        equsv[0]+=mac_value;
                    }else if (sensor.equals("Pm10")){
                        double mac_value = s.getMac_value();
                        equsv[1]+=mac_value;
                    }else if (sensor.equals("一氧化碳（CO）")){
                        double mac_value = s.getMac_value();
                        equsv[2]+=mac_value;
                    }else if (sensor.equals("二氧化氮（NO2）")){
                        double mac_value = s.getMac_value();
                        equsv[3]+=mac_value;
                    }else if (sensor.equals("二氧化硫（SO2）")){
                        double mac_value = s.getMac_value();
                        equsv[4]+=mac_value;
                    }else if (sensor.equals("臭氧（O3）")){
                        double mac_value = s.getMac_value();
                        equsv[5]+=mac_value;
                    }
                }
            }


            int size = equipments.size();

            if(size>0){
                for (int i = 0; i <equsv.length; i++) {
                    equsv[i]=equsv[i]/size;
                }
                pointavg.setPm25(equsv[0]);
                pointavg.setPm10(equsv[0]);
                pointavg.setCo(equsv[0]);
                pointavg.setNo2(equsv[0]);
                pointavg.setSo2(equsv[0]);
                pointavg.setO3(equsv[0]);
                pointavg.setEqucount(size);
            }

        }


        map.put("rows",pointAvgs);



        map.put("total",total);

        System.out.println(1212);
        return map;
    }






}