package com.iedscout;

import java.util.Date;

import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;

import com.base.Com;
import com.dec.fbs9100.MysqlConnPool;


/**
 * 	数据库更新线程
 * @author DELL
 *
 */
public class UpdateDataToMySQL_Task implements Runnable {
	private BTS_ScoutData_Array scoutData_Array;
	private MysqlConnPool pool;
	
	private boolean m_app_UpdateAlive = true;
	private Logger logger = null;
	
	private boolean m_initTask = false;

	public UpdateDataToMySQL_Task(BTS_ScoutData_Array scoutData_Array,MysqlConnPool pool) {
		this.pool = pool;
		this.scoutData_Array = scoutData_Array;	
		
		this.logger = LogManager.getLogger(this);
		
	}
	
	@Override
	public void run() {
		logger.info("UpdateDataToMySQL_Task Start at " + Com.get_DTF(new Date(), Com.DTF_YMDhms));
		m_app_UpdateAlive = true;
		BTS61850_IEDScout_Task_Thread_SQL.clearIed_NodeState_Table(pool);

				
		while(m_app_UpdateAlive) {
			try {
//				if(m_app_UpdateAlive) {
//					//清空数据库表
//					
//					BTS61850_IEDScout_Task_Thread_SQL.inseartIed_NodeState_Table(pool, scoutData_Array);
//					
//					m_app_UpdateAlive = false;
//				}
				
				//System.err.println("UpdateDataToMySQL_Task : scoutData_Array.Count():" + scoutData_Array.getDataCount());
				//BTS61850_IEDScout_Task_Thread_SQL.updateIed_NodeState_Table(pool, scoutData_Array);
				BTS61850_IEDScout_Task_Thread_SQL.inseartIed_NodeState_Table(pool, scoutData_Array);
				Thread.sleep(2000);
				
			} catch (Exception e) {
				logger.error("UpdateDataToMySQL_Task" + e.toString(), e);
			}		
		}		
		logger.info("UpdateDataToMySQL_Task Stop at " + Com.get_DTF(new Date(), Com.DTF_YMDhms));
	}
	
	
	public void setApp_UpdateAlive(boolean flag) {
		this.m_app_UpdateAlive = flag;
	}

	public boolean isM_initTask() {
		return m_initTask;
	}

	public void setM_initTask(boolean m_initTask) {
		this.m_initTask = m_initTask;
	}
	
	
	
}