package com.dec.fbs9100;
|
|
import java.util.ArrayList;
|
|
import com.base.AppConfig;
|
import com.battdata_rt.BattData_RT;
|
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 ArrayList<BattData_RT> Rtdata ;
|
public BTS61850_Task_Thread(MysqlConnPool pool, BattData_RT_Array data, AppConfig cfg)
|
{
|
m_ConnPool = pool;
|
m_Al_Data = data;
|
//Rtdata = rtdata;
|
for(int n=0; n<m_Al_Data.getItemCount(); n++) {
|
if(61850 != (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);
|
}
|
}
|
}
|
|
@Override
|
public void run() {
|
System.out.println(this.getName() + " - 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);
|
|
FBS9100_Task_Thread_SQL.createTbBtsStateChange_infTable(m_ConnPool); //创建历史事件记录表
|
|
BTS_61850_SocketClient client = new BTS_61850_SocketClient(m_ConnPool, param, m_Al_Data);
|
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();
|
System.out.println("BTS_IEC61850_DEV" + (n+1) + " Id: " + AL_BTS_IEC61850_DeviceId.get(n) + ", Ip: " + AL_BTS_IEC61850_DeviceIp.get(n));
|
}
|
|
while(true) {
|
try {
|
Thread.sleep(1000);
|
} catch (Exception e1) {
|
//e1.printStackTrace();
|
}
|
}
|
}
|
}
|