package com.dec.fbs9100;

import java.io.File;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
import org.openmuc.openiec61850.ServerModel;
import org.openmuc.openiec61850.ServerSap;

import com.base.AppConfig;
import com.battdata_rt.BattData_RT_Array;

public class BTS61850_Task_Thread extends Thread{
	
	private MysqlConnPool m_ConnPool = null;
	private BattData_RT_Array m_Al_Data;
	
	/**
	 * 	预加载的公共模型文件
	 */
	private static Map<String,ServerModel> al_ServerModel = new HashMap<>();
 	
	private ArrayList<String> AL_BTS_IEC61850_DeviceIp = new ArrayList<String>();
	private ArrayList<Integer> AL_BTS_IEC61850_DeviceId = new ArrayList<Integer>();
	private ArrayList<BTS_61850_SocketClient> AL_BTS_IEC61850_Client = new ArrayList<BTS_61850_SocketClient>();
	private ArrayList<FBS9100_StatAndParam> AL_StatAndParam = new ArrayList<FBS9100_StatAndParam>();
	
	private Logger logger = null;
	
	private ServerModel m_ServerModel = null;
	
	public BTS61850_Task_Thread(MysqlConnPool pool, BattData_RT_Array data, AppConfig cfg)
	{
		logger = LogManager.getLogger(this.getClass());
		
		m_ConnPool = pool;
		m_Al_Data = data;
		
//		logger.info("reading model from file...");
//        try {
//        	//加载模型文件
//        	List<ServerSap> serverSaps = ServerSap.getSapsFromSclFile("TEMPLATE.iid");
//        	m_ServerModel = serverSaps.get(0).serverModel;
//        	System.out.println("SSSS"+m_ServerModel.getBaseDevName());
//        } catch (Exception e1) {
//        	logger.error("Error parsing SCL file:TEMPLATE.iid " + e1.getMessage());
//            return;
//        }
//
//        logger.info("successfully read model");
	}
	
	public void reInitClient() {
		for(int n=0; n<AL_BTS_IEC61850_Client.size(); n++) {
			try {
				AL_BTS_IEC61850_Client.get(n).Set_AppAliveState(false);
			} catch (Exception e) {
				logger.error(e.toString(), e);
			}
		}
		createClient();
	}
	
	private void createClient() {
		
//		if(null == m_ServerModel) {
//			logger.error("error, the iec61850 server model is null....");
//			return;
//		}
		al_ServerModel.clear();
		logger.info("BTS61850_Task_Thread Start Parse ICD Source");
		try {
			File icdsource = new File("icdsource");
			if(!icdsource.exists()) {
				icdsource.mkdir();
			}
			File[] icdfiles = icdsource.listFiles();
			for (File file : icdfiles) {
				//System.out.println(file.getName() + " == " +file.getAbsolutePath());				
				try {
		        	//加载模型文件
		        	List<ServerSap> serverSaps = ServerSap.getSapsFromSclFile(file.getAbsolutePath());
		        	ServerModel tmp_Model = serverSaps.get(0).serverModel;
		        	if(null != tmp_Model) {
		        		logger.info("预加载'" + file.getName() + "'协议文件成功");
		        		al_ServerModel.put(file.getName(), tmp_Model);
		        	}
		        } catch (Exception e1) {
		        	logger.error("Error parsing SCL file:" + file.getName() + e1.getMessage());
		        }				
			}
		} catch (Exception e) {
			logger.error(e.toString(), e);
		}
		
		
		AL_BTS_IEC61850_DeviceIp.clear();
		AL_BTS_IEC61850_DeviceId.clear();
		AL_BTS_IEC61850_Client.clear();
		AL_StatAndParam.clear();
		
		
		for(int n=0; n<m_Al_Data.getItemCount(); n++) {
			if(61850 != (m_Al_Data.getItem(n).FBSDeviceId/10000)) {
			//if(71850 != (m_Al_Data.getItem(n).FBSDeviceId/10000)) {
				continue;
			}
			
			if(false == AL_BTS_IEC61850_DeviceId.contains(m_Al_Data.getItem(n).FBSDeviceId)) {
				AL_BTS_IEC61850_DeviceId.add(m_Al_Data.getItem(n).FBSDeviceId);
				AL_BTS_IEC61850_DeviceIp.add(m_Al_Data.getItem(n).FBSDeviceIp);
			}
		}
		
		logger.info("BTS_IEC61850_DEV_Client Thread Started: BTS_IEC61850_DEV_Count = " + AL_BTS_IEC61850_DeviceId.size());
		
		for(int n=0; n<AL_BTS_IEC61850_DeviceId.size(); n++) {
			FBS9100_StatAndParam param = new FBS9100_StatAndParam(AL_BTS_IEC61850_DeviceIp.get(n), AL_BTS_IEC61850_DeviceId.get(n));
			//param.dev_ipaddr = "127.0.0.1";
			AL_StatAndParam.add(param);
			
			BTS_61850_SocketClient client = new BTS_61850_SocketClient(m_ConnPool, param, m_Al_Data, m_ServerModel);
			AL_BTS_IEC61850_Client.add(client);
			FBS9100_Task_Thread_SQL.updateFbs9100StateByDev_Id(m_ConnPool, param);
			param.op_cmd = FBS9100_ComBase.CMD_GetDischargeParmAck;
			FBS9100_Task_Thread_SQL.updateFbs9100SetParamBydev_id(m_ConnPool, param);
			param.op_cmd = FBS9100_ComBase.CMD_GetSYSSetParamAck;		
			FBS9100_Task_Thread_SQL.updateFbs9100SysParamParamBydev_id(m_ConnPool, param);
			client.start();
			logger.info("BTS_IEC61850_DEV" + (n+1) + " Id: " + AL_BTS_IEC61850_DeviceId.get(n) + ", Ip: " + AL_BTS_IEC61850_DeviceIp.get(n));
		}
	}
	
	@Override
    public void run() {
		FBS9100_Task_Thread_SQL.createTbBtsStateChange_infTable(m_ConnPool);					//创建历史事件记录表
		
		createClient();
		
		while(true) {
			try {
				Thread.sleep(1000);
			} catch (Exception e1) {
				//e1.printStackTrace();
				logger.error(e1.toString(), e1);
			}
		}
	}
	
	/**
	 * 	获取ICD模型文件
	 * @param icdName
	 * @return
	 */
	public static ServerModel getServerModel(String icdName) {
		//System.out.println("icdName:"+icdName);;
		return al_ServerModel.get(icdName);
	}
	
}