首次提交

Administrator

2021-11-26 0deb53a184ea4bb5ca6967b2d9342cb597b53ab2

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
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
package com.dev.ess.comm; 
 
import java.util.ArrayList; 
 
import org.apache.logging.log4j.LogManager; 
import org.apache.logging.log4j.Logger; 
 
import com.battmonitor.data.BattData_RT_Array; 
import com.battmonitor.sql.MysqlConnPool; 
import com.config.AppConfig; 
import com.dev.btse.data.FBS9100_StatAndParam; 
 
 
public class ESS3100_ServerSocket_Thread extends Thread{ 
 
    private MysqlConnPool m_ConnPool = null; 
    private BattData_RT_Array m_Al_Data; 
     
    private ArrayList<String> AL_ESS_STORAGE_DeviceIp = new ArrayList<String>(); 
    private ArrayList<Integer> AL_ESS_STORAGE_DeviceId = new ArrayList<Integer>(); 
    private ArrayList<ESS3100_SocketClient_Thread> AL_ESS_SocketClient = new ArrayList<ESS3100_SocketClient_Thread>(); 
    private ArrayList<FBS9100_StatAndParam> AL_StatAndParam = new ArrayList<FBS9100_StatAndParam>(); 
     
    private Logger logger = null; 
     
    public ESS3100_ServerSocket_Thread(MysqlConnPool pool, BattData_RT_Array data, AppConfig cfg) 
    { 
        logger = LogManager.getLogger(this.getClass()); 
         
        m_ConnPool = pool; 
        m_Al_Data = data; 
    } 
     
    public void reInitClient() { 
        for(int n=0; n<AL_ESS_SocketClient.size(); n++) { 
            try { 
                /** 
                 *     ½áÊøµ±Ç°ÒÑÓеÄÁ¬½Ó 
                 */ 
                AL_ESS_SocketClient.get(n).Set_AppAliveState(false); 
            } catch (Exception e) { 
                logger.error(e.toString(), e); 
            } 
        } 
        createClient(); 
    } 
     
    private void createClient() { 
         
        AL_ESS_STORAGE_DeviceIp.clear(); 
        AL_ESS_STORAGE_DeviceId.clear(); 
        AL_ESS_SocketClient.clear(); 
        AL_StatAndParam.clear(); 
         
        for(int n=0; n<m_Al_Data.getItemCount(); n++) { 
            if(3100 != (m_Al_Data.getItem(n).FBSDeviceId/100000)) { 
                continue; 
            } 
             
            if(false == AL_ESS_STORAGE_DeviceId.contains(m_Al_Data.getItem(n).FBSDeviceId)) { 
                AL_ESS_STORAGE_DeviceId.add(m_Al_Data.getItem(n).FBSDeviceId); 
                AL_ESS_STORAGE_DeviceIp.add(m_Al_Data.getItem(n).FBSDeviceIp); 
            } 
        } 
         
        logger.info("ESS5100_ServerSocket_Thread Thread Started: BTS_IEC61850_DEV_Count = " + AL_ESS_STORAGE_DeviceId.size()); 
         
        for(int n=0; n<AL_ESS_STORAGE_DeviceId.size(); n++) { 
            FBS9100_StatAndParam param = new FBS9100_StatAndParam(AL_ESS_STORAGE_DeviceIp.get(n), AL_ESS_STORAGE_DeviceId.get(n)); 
            //param.dev_ipaddr = "127.0.0.1"; 
            AL_StatAndParam.add(param); 
             
            ESS3100_SocketClient_Thread client = new ESS3100_SocketClient_Thread(m_ConnPool,m_Al_Data, param); 
            AL_ESS_SocketClient.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); 
*/ 
             
            new Thread(client).start(); 
            logger.info("AL_ESS_STORAGE_DEV" + (n+1) + " Id: " + AL_ESS_STORAGE_DeviceId.get(n) + ", Ip: " + AL_ESS_STORAGE_DeviceIp.get(n)); 
        } 
    } 
     
    @Override 
    public void run() { 
         
        createClient(); 
         
        while(true) { 
            try { 
                Thread.sleep(1000); 
            } catch (Exception e1) { 
                //e1.printStackTrace(); 
                logger.error(e1.toString(), e1); 
            } 
        } 
    } 
     
}