package com.szpg.task;

import java.util.Map;

import org.apache.log4j.Logger;

import com.szpg.plc.message.AppMessageConstants;
import com.szpg.plc.message.command.ReadMemoryCommand;
import com.szpg.plc.protocol.fins.FINSConstants;
import com.szpg.plc.server.ACUClient;
import com.szpg.plc.server.ACUClientUtil;
import com.szpg.plc.util.ByteUtil;
import com.szpg.service.ReadSensorValueService;
import com.szpg.util.Configure;


/**
 * 查询二期温湿度及氧气实时值定时任务
 * @author admin
 *
 */
public class ReadWSYQValueTask implements Runnable {
	
	private ReadSensorValueService service;
	
	public ReadWSYQValueTask() {
		service = new ReadSensorValueService();
	}

	@Override
	public void run() {
		// 查找所有的client
		Map<String, ACUClient> clients = ACUClientUtil.getInstance().getClients();
		for (String key : clients.keySet()) {
			ACUClient client = clients.get(key);
			
			if (client.getFlag().equals("23")) {
				// 构建命令对象
				ReadMemoryCommand command = ReadMemoryCommand.getInstance(AppMessageConstants.CMD_TYPE_READWSYQVALUE);
				String sour = Configure.getProperty("sys", "LOCALHOST.NET") + 
							  Configure.getProperty("sys", "LOCALHOST.NODE") + 
							  Configure.getProperty("sys", "LOCALHOST.UNIT");
				command.setMessageProducerId(sour);
				
				String dest = client.getNet() + client.getNode() + client.getUnit();
				
				command.setDestinationId(dest);
				
				command.setMemoryArea(FINSConstants.MEMORY_DM_AREA);
				
				try {
					command.setStartAddress(ByteUtil.binToHexString(ByteUtil.intToBins(Integer.parseInt(Configure.getProperty("acubl", client.getAcucode() + ".WSYQ.START")), 2)) + "00");
					command.setCountWord(Integer.parseInt(Configure.getProperty("acubl", client.getAcucode() + ".WSYQ.WORDCOUNT")));
					
					// 调用服务过程执行命令发送服务
					service.executeService(client, (ReadMemoryCommand) command);
					Logger.getLogger(this.getClass().getName()).info(command);
				} catch (Exception ex) {
					ex.printStackTrace();
					Logger.getLogger(getClass().getName()).error("发送查询温湿度指令异常" + ex);
					continue;
				}
			}
		}
	}
}