package org.flume.alarm.resp;

import net.sf.json.JSONArray;
import net.sf.json.JSONObject;
import org.flume.alarm.AlarmEnumDTO.DigAlarmEnum;
import org.flume.alarm.AlarmEnumDTO.NoiseAlarmEnum;
import org.flume.alarm.base.AbstractResponse;
import org.flume.alarm.base.DeviceTypeEnum;
import org.flume.alarm.manager.*;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.context.support.ClassPathXmlApplicationContext;

import java.io.IOException;

/**
 * Created by lenovo on 2018/1/9.
 */
public class DigResponse extends AbstractResponse {

    private final Logger logger = LoggerFactory.getLogger(this.getClass().getName());
    private static final String[] mType = {"Data", "Event", "SetResponse", "GetResponse"};
    private static final String[] bType = {"DigEvent", "DigOnline", "DigOffline"};

    @Override
    public void process(String content) {
        ClassPathXmlApplicationContext ac = this.getAc();
        DigManager digManager = ac.getBean(DigManager.class);
        DigHeartManager digHeartManager = ac.getBean(DigHeartManager.class);
        AlarmRecordManager alarmRecordManager = ac.getBean(AlarmRecordManager.class);
        DeviceConfigManager deviceConfigManager = ac.getBean(DeviceConfigManager.class);
        JSONObject json = JSONObject.fromObject(content);
        String devCode = json.get("devCode").toString();
        logger.info("--------RECEIVE:设备编号：" + devCode + "，上传数据：" + json.toString() + "-------");
        JSONObject jsonObject = (JSONObject) json.get("mBody");
        if (mType[0].equals(json.get("mType"))) {//存储上报数据
            JSONArray jsonArray = (JSONArray) jsonObject.get("datas");
            for (int i = 0; i < jsonArray.size(); i++) {
                try {
                    String mark = ((JSONObject) jsonArray.get(i)).get("mark").toString();
                    String distance = ((JSONObject) jsonArray.get(i)).get("distance").toString();
                    String angle = ((JSONObject) jsonArray.get(i)).get("angle").toString();
                    digManager.saveData(devCode, mark, distance, angle);//存采集数据
                } catch (IOException e) {
                    e.printStackTrace();
                    logger.error("--------ERROR:设备编号：" + devCode + "，存储数据：" + jsonArray.get(i).toString() + "失败-------");
                }
            }
        } else if (mType[1].equals(json.get("mType"))) {//存储报警事件
            if (bType[0].equals(jsonObject.get("bType"))) {
                JSONArray jsonArray = (JSONArray) jsonObject.get("eventType");
                for (int i = 0; i < jsonArray.size(); i++) {
                    try {
                        alarmRecordManager.saveData(devCode, DeviceTypeEnum.Dig.toString(), "",
                                String.valueOf(DigAlarmEnum.valueOf(jsonArray.get(i).toString()).getIndex()),"1");
                    } catch (IOException e) {
                        e.printStackTrace();
                        logger.error("--------ERROR:设备编号：" + devCode + "，存储报警数据：" + jsonArray.get(i).toString() + "失败-------");
                    }
                }
            }else if (bType[1].equals(jsonObject.get("bType"))) {
                try {
                    digHeartManager.saveData(devCode,"1");//在线
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }else if (bType[2].equals(jsonObject.get("bType"))) {
                try {
                    digHeartManager.saveData(devCode,"0");//离线
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
        } else if (mType[2].equals(json.get("mType"))) {//更新下发参数状态
            try {
                if (DeviceTypeEnum.Noise.name().equals(json.get("devType"))) {
                    if ("DigConfigSuccess".equals(jsonObject.get("bType"))) {
                        deviceConfigManager.updateStatus(devCode);
                    }
                }
            } catch (Exception e) {
                e.printStackTrace();
                logger.error("--------ERROR:设备编号：" + devCode + "，更新参数下发状态失败-------");
            }
        }

    }
}