package com.dec.fbs9100;
|
|
import java.util.ArrayList;
|
import java.util.List;
|
|
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 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("2CPSS2BTSE.icd");
|
m_ServerModel = serverSaps.get(0).serverModel;
|
} catch (Exception e1) {
|
logger.error("Error parsing SCL file: " + 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_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);
|
}
|
}
|
}
|
}
|
