package com.qianwen.mdc.listener;

import java.util.List;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

import com.qianwen.mdc.collector.CollectorHelper;
import com.qianwen.mdc.collector.DataCollector;
import com.qianwen.mdc.collector.moxa.MoxaCollector;
import com.qianwen.mdc.domain.Machine;
import com.qianwen.mdc.domain.MachineProtocol;
import com.qianwen.mdc.mapper.MachineMapper;
import com.qianwen.mdc.mapper.MachineProtocolMapper;

@Component
public class CollectTask implements Runnable{
	private static final Logger logger = LoggerFactory.getLogger(CollectTask.class);
	@Autowired
	private CollectorHelper collectorHelper;
	@Autowired
	private MachineMapper machineMapper;
	@Autowired
	private MachineProtocolMapper protocolMapper;
	@Override
	public void run() {
		//查询所有的机器，并且找出合适的collector交给collect处理
		
		List<Machine> machines = machineMapper.collectableMachines();
		MachineProtocol protocol;
		for(Machine machine : machines) {
			protocol = protocolMapper.selectById(machine.getProtocolId());
			try {
				DataCollector collector = collectorHelper.getCollector(protocol);
				collector.collect(machine);
			}catch(Exception ex) {
				logger.error("采集设备信息失败,machineId={}",machine.getId(),ex);
			}
		}
			
	}

}