whyclj
2020-05-19 6fbf87a8e692b8eaed6ade2ce867f3a9fa12a8e2
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
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();
            }    
        }
    }
}