package com.moral.service.impl;

import java.time.LocalDateTime;
import java.time.temporal.ChronoUnit;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

import com.alibaba.fastjson.JSONObject;
import com.moral.entity.Device;

import org.apache.log4j.Logger;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.util.ObjectUtils;

import com.moral.mapper.DeviceMapper;
import com.moral.mapper.HistoryHourlyMapper;
import com.moral.mapper.HistoryMapper;
import com.moral.service.DeviceService;
import com.moral.util.AlarmUtils_2;

@Service
public class DeviceServiceImpl implements DeviceService {

    public static Logger log = Logger.getLogger(DeviceServiceImpl.class);

    private static Double[] PM2_5 = {0d, 35d, 75d, 115d, 150d, 250d};
    private static Double[] PM10 = {0d, 50d, 150d, 250d, 350d, 420d};
    private static Double[] SO2 = {0d, 150d, 500d, 650d, 800d, 1600d};
    private static Double[] NO2 = {0d, 100d, 200d, 700d, 1200d, 2340d};
    private static Double[] CO = {0d, 5d, 10d, 35d, 60d, 90d};
    private static Double[] O3 = {0d, 160d, 200d, 300d, 400d, 800d};
    private static Double[] TVOC = {0d, 1.5d, 3d, 5d};

    @Autowired
    private DeviceMapper deviceMapper;

    @Autowired
    private HistoryMapper historyMapper;

    @Autowired
    private HistoryHourlyMapper historyHourlyMapper;

    @Override
    public List<Map<String, Object>> getSensorData(Map<String, Object> parameters) {
        return historyMapper.getSensorData(parameters);
    }

    @Override
    public List<Map<String, Object>> getSensorDataOnce(Map<String, Object> parameters) {
        return historyMapper.getSensorDataOnce(parameters);
    }

    @Override
    public List<Map<String, Object>> getSensorDataByMac(Map<String, Object> parameters) {
        return historyMapper.getSensorDataByMac(parameters);
    }

    @Override
    public List<Map<String, Object>> getSensorDataByMacOnce(Map<String, Object> parameters) {
        return historyMapper.getSensorDataByMacOnce(parameters);
    }

    @Override
    public List<String> getMacs() {
        return deviceMapper.getMacs();
    }

    @Override
    public List<String> getMacByOrganizationid(List<Object> organizationIdList) {
        return deviceMapper.getMacByOrganizationid(organizationIdList);
    }

    @Override
    public List<Map<String, Object>> macAndOrganizationIdMap(List<String> macs) {
        return deviceMapper.macAndOrganizationIdMap(macs);
    }

    @Override
    public List<Map<String, Object>> getAllByMacList(List<String> macList) {
        return deviceMapper.getAllByMacList(macList);
    }

    @Override
    public Device getDeviceByID(int id) {
        Device result = deviceMapper.selectByPrimaryKey(id);
        return result;
    }

    @Override
    public void alarmSms(Map<String, Object> params) {
        LocalDateTime time = LocalDateTime.now().truncatedTo(ChronoUnit.HOURS);
        Map<String, Object> hashMap = new HashMap<>();
        hashMap.put("time", time);
        List<String> sensors = Arrays.asList("e1", "e2", "e11", "e16", "e10", "e15", "e17");
        hashMap.put("sensorKeys", sensors);
        for (Map.Entry<String, Object> entry : params.entrySet()) {
            String orgId = entry.getKey();
            List<String> emails = (List<String>) entry.getValue();
            List<Map<String, Object>> devices = deviceMapper.getAllDeviceByOrg(orgId);
            List<String> result = new ArrayList<>();
            for (Map<String, Object> device : devices) {
                String name = device.get("name").toString();
                String mac = device.get("mac").toString();
                hashMap.put("mac", mac);
                Map<String, Object> data = JSONObject.parseObject(historyHourlyMapper.selectDataByMac(hashMap), Map.class);
                List<String> alarmInfo = new ArrayList<>();
                Double pm25Value = Double.parseDouble(((List) data.get("e1")).get(0).toString());
                Double pm10Value = Double.parseDouble(((List) data.get("e2")).get(0).toString());
                Double so2Value = Double.parseDouble(((List) data.get("e11")).get(0).toString());
                Double no2Value = Double.parseDouble(((List) data.get("e16")).get(0).toString());
                Double coValue = Double.parseDouble(((List) data.get("e10")).get(0).toString());
                Double o3Value = Double.parseDouble(((List) data.get("e15")).get(0).toString());
                Double tvocValue = Double.parseDouble(((List) data.get("e17")).get(0).toString());
                String pm25 = alarmInfo("PM2.5", pm25Value, PM2_5);
                String pm10 = alarmInfo("PM10", pm10Value, PM10);
                String so2 = alarmInfo("SO2", so2Value, SO2);
                String no2 = alarmInfo("NO2", no2Value, NO2);
                String co = alarmInfo("CO", coValue, CO);
                String o3 = alarmInfo("O3", o3Value, O3);
                String tvoc = alarmInfo("TVOC", tvocValue, TVOC);
                if (pm25 != null) {
                    alarmInfo.add(pm25);
                }
                if (pm10 != null) {
                    alarmInfo.add(pm10);
                }
                if (so2 != null) {
                    alarmInfo.add(so2);
                }
                if (no2 != null) {
                    alarmInfo.add(no2);
                }
                if (co != null) {
                    alarmInfo.add(co);
                }
                if (o3 != null) {
                    alarmInfo.add(o3);
                }
                if (tvoc != null) {
                    alarmInfo.add(tvoc);
                }
                if (!ObjectUtils.isEmpty(alarmInfo)) {
                    result.add(name + alarmInfo);
                }
            }

            if (!ObjectUtils.isEmpty(result)) {
                for (String email : emails) {
                    AlarmUtils_2.sendMail(email, "设备因子浓度报警！！！", result.toString());
                }
            }
        }
    }

    private String alarmInfo(String sensorName, Double value, Double[] doubles) {
        int state = 1;
        for (int i = doubles.length - 1; i >= 0; i--) {
            Double aDouble = doubles[i];
            if (value >= aDouble) {
                state = i + 1;
                break;
            }
        }
        if (state != 1) {
            StringBuilder builder = new StringBuilder();
            builder.append(sensorName).append("浓度值==").append(value).append("-->超出限定值");
            if (state == 6) {
                builder.append(doubles[5]);
            } else if (state == 5) {
                builder.append(doubles[4]);
            } else if (state == 4) {
                builder.append(doubles[3]);
            } else if (state == 3) {
                builder.append(doubles[2]);
            } else if (state == 2) {
                builder.append(doubles[1]);
            }
            return builder.toString();
        }
        return null;
    }
}