package com.szpg.plc.message.response.read;

import com.szpg.db.dao.PgAlarmDao;
import com.szpg.db.dao.PgAlarmRuleDao;
import com.szpg.db.dao.PgDeviceDao;
import com.szpg.db.dao.PgO2Dao;
import com.szpg.db.dao.impl.PgAlarmDaoImpl;
import com.szpg.db.dao.impl.PgAlarmRuleDaoImpl;
import com.szpg.db.dao.impl.PgDeviceDaoImpl;
import com.szpg.db.dao.impl.PgO2DaoImpl;
import com.szpg.db.data.PgAlarm;
import com.szpg.db.data.PgAlarmRule;
import com.szpg.db.data.PgO2;
import com.szpg.plc.message.response.ReadMemoryCommandResponse;
import com.szpg.util.*;
import org.apache.commons.lang3.StringUtils;
import org.apache.log4j.Logger;

import java.util.ArrayList;
import java.util.List;

/**
 * 读取氧气值指令的响应消息
 * @author TAN YUE
 */
public class ReadO2ValueCommandResponse extends ReadMemoryCommandResponse {
	
	/**
	 * 
	 */
	private static final long serialVersionUID = -2816512676498637196L;

	private final Logger logger = Logger.getLogger(this.getClass().getName());

	/**
	 * 氧气浓度值
	 */
	private List<Float> o2nd;

	/**
	 * 氧气联动报警值
	 */
	private List<Float> o2ldbjz;

	/**
	 * 氧气监测设备资产列表，从配置文件中获取
	 */
	private String[] zcList;

	private boolean O2_ON_FJ;
	private long CLASS_RED_ALARM_INTERVAL;

	public ReadO2ValueCommandResponse() {
		o2nd = new ArrayList<Float>();
		o2ldbjz = new ArrayList<Float>();

		O2_ON_FJ = Boolean.valueOf(Configure.getProperty("sys", "O2_ON_FJ", "false"));
		CLASS_RED_ALARM_INTERVAL = Integer.parseInt(Configure.getProperty("sys", "CLASS_RED_ALARM_INTERVAL", "60")) * 60 * 1000L;
	}

	public List<Float> getO2nd() {
		return o2nd;
	}

	public void setO2nd(List<Float> o2nd) {
		this.o2nd = o2nd;
	}

	public List<Float> getO2ldbjz() {
		return o2ldbjz;
	}

	public void setO2ldbjz(List<Float> o2ldbjz) {
		this.o2ldbjz = o2ldbjz;
	}
	
	public String[] getZcList() {
		return zcList;
	}

	public void setZcList(String[] zcList) {
		this.zcList = zcList;
	}

	@Override
	public void afterAction() {
		// 1将氧气浓度数据存入数据库
		PgO2Dao o2Dao = new PgO2DaoImpl();
		PgDeviceDao deviceDao = new PgDeviceDaoImpl();
		PgAlarmRuleDao ruleDao = new PgAlarmRuleDaoImpl();
		PgAlarmDao alarmDao = new PgAlarmDaoImpl();
		
		if (null != zcList && zcList.length > 0) {
			// 遍历氧气设备列表，将氧气浓度监测值存入数据库
			for (int i = 0; i < zcList.length; i++) {
				// 资产编号（设备编号）
				String zcbh = zcList[i];

				// 监测值
				float value = o2nd.get(i);
				
				int deviceId = deviceDao.findDeviceIdByCode(zcbh);
				if (deviceId > 0) {
					// 1 取出报警规则
					PgAlarmRule rule = ruleDao.findRuleByDevice(deviceId);

					// 默认的报警阈值
					double low = 18.0;
					if (null != rule) {
						try {
							low = NumberFormat.parseDouble(rule.getLowvalue(), "0.00");
						} catch (Exception ex) {
							logger.error(ex);
							ex.printStackTrace();
						}
					}

					// 1 判断是否报警
					if (low > 0.0001 && value < low) {
						// 2 需要报警，处理报警记录和监测值
						// 2.1 取出上一个报警记录
						PgAlarm lastAlarm = alarmDao.findLatestAlarmByDevice(deviceId);
						if (null != lastAlarm) {
							// 2.2 计算与上一个报警记录的操作时间间隔
							long alarmTimeInterval = this.getTime().getTimeInMillis() - lastAlarm.getLog_time().getTime();

							// 2.3 上一个报警值
							double lastAlarmValue = 0.0;
							try {
								lastAlarmValue = NumberFormat.parseDouble(lastAlarm.getAlarm_value(), "0.00");
							} catch (Exception ex) {
								logger.error(ex);
								ex.printStackTrace();
							}

							// 2.4 如果与前值相同 并且 时间在设定的阈值范围内 则不处理报警
							if (Math.abs(value - lastAlarmValue) < 0.01 && alarmTimeInterval < CLASS_RED_ALARM_INTERVAL) {
								continue;
							}
						}

						// 2.5 插入监测数值
						o2Dao.addPblzRecord(value, TimeFormat.formatTimestamp(this.getTime().getTime()), deviceId);

						// 2.6 推送给市管廊公司平台
						String o2Resp = DataPushInterface.addO2Data(zcbh, NumberFormat.format(value, "0.00"), TimeFormat.format(this.getTime().getTime(), "yyyyMMddHHmmss"));
						logger.info("同步氧气浓度值结果：" + o2Resp);

						// 2.7 生成报警记录
						PgAlarm alarm = new PgAlarm().getO2AlarmInstance();

						alarm.setAlarm_date(this.getTime().getTime());
						alarm.setAlarm_value(NumberFormat.format(value, "0.00"));
						alarm.setAlarmdevid(deviceId);
						alarm.setLog_time(this.getTime().getTime());

						// 2.8 将上一条报警记录消警
						alarmDao.insertAlarmRecord(alarm);
						deviceDao.updateDeviceStatus(deviceId, "氧气浓度过低");

						// 2.9 向市级平台推送报警日志
						String date = TimeFormat.formatDate(getTime().getTime());
						int count = alarmDao.findAlarmCountByDate(date);
						String bjbh = "THXC." + date + "." + NumberFormat.format(count+1, "0000");
						String bjms = alarm.getDescription() + "，氧气浓度值为" + value;
						String bjsj = date.replace("-", "");
						String jwbjResp = DataPushInterface.addO2AlarmData(bjbh, zcbh, bjms, bjsj);
						logger.info("同步氧气报警记录日志结果：" + jwbjResp);

						// 2.10 联动打开风机
						// 自动打开当前舱段的排风机，手动关闭风机
						// 首先找到当前舱段的排风机资产编号
						if (O2_ON_FJ == true) {
							String baseURL = Configure.getProperty("sys", "PGDSC_API_URL");
							HttpRequest.sendGet(baseURL + "remote/turnOnFjReactAlarm.action", "zcbh=" + zcbh);
						}
					} else {
						// 3 不需要报警，只处理监测值
						// 3.1 取出上一个监测值
						PgO2 lastRec = o2Dao.findLastRecordByDevice(deviceId);

						// 3.2 计算数值的时间间隔
						long valueTimeInterval = this.getTime().getTimeInMillis() - lastRec.getUptime().getTime();

						// 3.3 判断条件：是否与原值相同且相距在一小时以内
						if (Math.abs(value - lastRec.getO2()) > 0.01 || valueTimeInterval > CLASS_RED_ALARM_INTERVAL) {
							// 3.4 将数据存入数据库
							o2Dao.addPblzRecord(value, TimeFormat.formatTimestamp(this.getTime().getTime()), deviceId);

							// 3.5 推送给市管廊公司平台
							String o2Resp = DataPushInterface.addO2Data(zcbh, NumberFormat.format(value, "0.00"), TimeFormat.format(this.getTime().getTime(), "yyyyMMddHHmmss"));
							logger.info("同步氧气浓度值结果：" + o2Resp);
						}

						// 3.6 如果有报警记录，则将报警自动清除
						alarmDao.autoClearAlarm(deviceId);
						deviceDao.updateDeviceStatus(deviceId, "正常");
					}
				} else {
					logger.warn("未找到资产[" + zcbh + "]");
				}
			}
		}
	}

	@Override
	public void parseData() {
		// 获取目标ACU的代码
		String acucode = this.getAcucode();
		byte[] messageData = this.getResponseData();
		
		logger.info("开始解析[读取氧气浓度值][" + acucode + "]指令响应");
		
		// 判断数据的长度是否满足要求
		if (messageData.length != Integer.parseInt(Configure.getProperty("acubl", acucode + ".YQ.WORDCOUNT")) * 2) {
			logger.error("返回的数据长度与读取的不一致！");
			this.setValid(false);
			return;
		}
		
		// 获取目标ACU氧气监测值内存区域的起始字地址
		int start = Integer.parseInt(Configure.getProperty("acubl", acucode + ".YQ.START"));
		
		// 获取目标ACU氧气相关的资产列表，即氧气设备列表
		String zcListStr = Configure.getProperty("acubl", acucode + ".YQ.ZC.LIST");
		if (StringUtils.isEmpty(zcListStr) == true) {
			this.setValid(false);
			return;
		}
		zcList = zcListStr.split(";");
		
		// 解析氧气浓度监测值以及氧气浓度报警阈值
		for (int i = 0; i < zcList.length; i++) {
			String zcbh = zcList[i];
			
			// 1解析氧气浓度监测值
			float value = getValueFromData(zcbh, start, messageData, zcbh + ".Value");
			
			// 2解析氧气浓度报警阈值
			float threshold = getValueFromData(zcbh, start, messageData, zcbh + ".Set");
			
			getO2nd().add(value);
			getO2ldbjz().add(threshold);
			
			logger.info("[" + zcbh + "][氧气浓度值" + value + "][氧气浓度报警阈值" + threshold + "]");
		}
		
		logger.info("解析[读取氧气浓度值]响应指令结束");
	}

}