package com.szpg.service;

import org.apache.log4j.Logger;

import com.szpg.db.dao.PgAcuDao;
import com.szpg.db.dao.PgAcuCmdDao;
import com.szpg.db.dao.impl.PgAcuDaoImpl;
import com.szpg.db.dao.impl.PgAcuCmdDaoImpl;
import com.szpg.db.data.PgAcu;
import com.szpg.db.data.PgAcuCmd;
import com.szpg.plc.message.CommandResponse;
import com.szpg.plc.message.command.WriteMemoryCommand;
import com.szpg.plc.protocol.DTProtocolInterface;
import com.szpg.plc.protocol.ProtocolFactory;
import com.szpg.plc.server.ACUClient;
import com.szpg.plc.server.ACUClientUtil;

/**
 * 设置环境变量报警阈值的服务过程
 * 
 * @author admin
 *
 */
public class SetSensorThresholdService {
	
	private final Logger logger = Logger.getLogger(this.getClass().getName());
	
	private PgAcuCmdDao cmdDao = new PgAcuCmdDaoImpl();
	private PgAcuDao acuDao = new PgAcuDaoImpl();
	
	public void executeService(ACUClient client, WriteMemoryCommand command) {
		// 解析命令对象为字节数组
		DTProtocolInterface finspi = ProtocolFactory.getDefaultDTProtocol();
		byte[] content = finspi.messageToBytes(command);
		
		// 通过socket接口发送出去
		ACUClientUtil.getInstance().sendACUCommand(client, content);
		
		// 1查找数据库中的ACU对象
		PgAcu acu = acuDao.findACUByDest(command.getDestinationId());
		if (null == acu) {
			return;
		}
		
		// 2生成读取命令对象
		PgAcuCmd cmd = new PgAcuCmd();
		cmd.setCmd_type(command.getCommandType());
		cmd.setDest_acu_code(acu.getAcu_code());
		cmd.setTm(command.getTime().getTime());
		
		// 3将命令保存入数据库
		cmdDao.addCmdRecord(cmd);
		
		// 4阻塞，循环查找响应消息池，找到对应的响应消息
		boolean flag = false;
		int times = 0;
		CommandResponse response = null;
		while (flag == false && times < 240) {
			response = ACUClientUtil.getInstance().responsePool.getResponse(cmd.getId());
			
			if (null != response && response.equals("") == false) {
				flag = true;
			}
			
			times++;
			try {
				Thread.sleep(500);
			} catch (InterruptedException e) {
				// TODO 阻塞线程被打断，需要处理异常
				// 目前的处理流程为1）记录日志；2）将命令置为超时
				logger.error("在响应池中查找命令的响应消息阻塞线程被异常打断", e);
				cmdDao.updateCmdRecordTimeout(cmd.getId());
				
				return;
			}
		}
		
		// 5若未超时，将值存入数据库
		if (null != response) {
			// 6根据命令类型的不同将监测值存入对应的数据库
			// 7如果监测值未发生变化则退出
			// 8如果监测值发生变化则调用接口将变量值推送出去
			response.afterAction();
		} else {
			// 9超时，将命令的超时标志位置1
			logger.warn("命令超时" + cmd.getId());
			cmdDao.updateCmdRecordTimeout(cmd.getId());
		}
	}
	
}