首次提交

Administrator

2021-08-12 8467d3be4ce3be340d36f45c83d370def9e7e50f

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
106
107
108
109
110
111
package com.dev.fbs9100; 
 
import java.util.ArrayList; 
 
import com.battdata_rt.BattData_RT_Array; 
import com.config.AppConfig; 
import com.sql.MysqlConnPool; 
 
public class FBS9100_Task_Thread extends Thread{ 
     
    private MysqlConnPool m_ConnPool = null; 
    private BattData_RT_Array m_Al_Data; 
     
    private ArrayList<String> AL_FBSDeviceIp = new ArrayList<String>(); 
    private ArrayList<Integer> AL_FBSDeviceId = new ArrayList<Integer>(); 
    private ArrayList<FBS9100_SocketClient> AL_FBSSocketClient = new ArrayList<FBS9100_SocketClient>(); 
    private ArrayList<FBS9100_StatAndParam> AL_StatAndParam = new ArrayList<FBS9100_StatAndParam>(); 
     
    public FBS9100_Task_Thread(MysqlConnPool pool, BattData_RT_Array data, AppConfig cfg) 
    { 
        m_ConnPool = pool; 
        m_Al_Data = data; 
        for(int n=0; n<m_Al_Data.getItemCount(); n++) 
        { 
            if(910 != (m_Al_Data.getItem(n).FBSDeviceId/100000)) 
            { 
                continue; 
            } 
             
            if(false == AL_FBSDeviceId.contains(m_Al_Data.getItem(n).FBSDeviceId)) 
            { 
                AL_FBSDeviceId.add(m_Al_Data.getItem(n).FBSDeviceId); 
                AL_FBSDeviceIp.add(m_Al_Data.getItem(n).FBSDeviceIp); 
            } 
        } 
    } 
     
    @Override 
    public void run() { 
        System.out.println(this.getName() + " - FBS9100_Client Thread Started: FBS_DEV_Count = " + AL_FBSDeviceId.size()); 
         
        for(int n=0; n<AL_FBSDeviceId.size(); n++) 
        { 
            FBS9100_StatAndParam param = new FBS9100_StatAndParam(AL_FBSDeviceIp.get(n), AL_FBSDeviceId.get(n)); 
            AL_StatAndParam.add(param); 
             
            FBS9100_SocketClient client = new FBS9100_SocketClient(m_ConnPool, param, m_Al_Data); 
            AL_FBSSocketClient.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); 
             
            client.start(); 
            System.out.println("FBS9100_DEV" + (n+1) + " Id: " + AL_FBSDeviceId.get(n) + ", Ip: " + AL_FBSDeviceIp.get(n)); 
        } 
         
        /* 
        //´´½¨tb_fbs9100_StateTable±í²¢Ïò±íÖÐÌí¼ÓÊý¾Ý 
        FBS9100_Task_Thread_SQL.createFBS9100StateTableOnRam(m_ConnPool, AL_StatAndParam); 
        //´´½¨tb_fbs9100_setparam±í²¢Ïò±íÖÐÌí¼ÓÊý¾Ý 
        FBS9100_Task_Thread_SQL.createFBS9100SetTestParamTableOnRam(m_ConnPool, AL_StatAndParam); 
        //´´½¨CmccPowerData±í²¢Ïò±íÖÐÌí¼ÓÊý¾Ý 
        FBS9100_Task_Thread_SQL.createFBS9100CmccPowerDataOnRam(m_ConnPool, AL_StatAndParam); 
        //´´½¨tb_fbs9100S_DFU_StateTable±í²¢Ïò±íÖÐÌí¼ÓÊý¾Ý 
        FBS9100S_DFU_SQL.createFBS9100S_DFU_TableOnRam(m_ConnPool, AL_StatAndParam); 
        */ 
        while(true) 
        { 
            try  
            { 
                /* 
                for(int n=0; n<AL_FBSDeviceId.size(); n++) { 
                     
                } 
                 
                for(int n=0; n<AL_StatAndParam.size(); n++) { 
                    FBS9100_Task_Thread_SQL.updateFbs9100StateByDev_Id(m_ConnPool, AL_StatAndParam.get(n)); 
                } 
                 
                if(AL_StatAndParam.size() > 0) { 
                    FBS9100_Task_Thread_SQL.queryFbs9100SetParam(m_ConnPool, AL_StatAndParam); 
                    FBS9100_Task_Thread_SQL.updateFbs9100SetParamCmd(m_ConnPool, AL_StatAndParam); 
                    FBS9100_Task_Thread_SQL.updateFbs9100SetParam(m_ConnPool, AL_StatAndParam); 
                } 
                 
                for(int n=0; n<AL_StatAndParam.size(); n++) { 
                    FBS9100_StatAndParam fbs9100_st = AL_StatAndParam.get(n); 
                    FBS9100_SysState st = AL_StatAndParam.get(n).m_FBS_VCData.m_SysState; 
                    if((0==st.Alm_RecId) && (st.ErrCommCount>0)) { 
                        st.Alm_RecId = UUID.randomUUID().getLeastSignificantBits(); 
                        if(0 == st.Alm_RecId) { 
                            st.Alm_RecId = UUID.randomUUID().getLeastSignificantBits(); 
                        } 
                        DeviceAlarm_Thread.insertOrUpdateDevAlarmToTable(m_ConnPool, st.Alm_RecId, fbs9100_st.dev_id, fbs9100_st.dev_ipaddr, 
                                                                            DeviceAlarm_Thread.ALM_TYPE_FBS9100_CommError_ID, true); 
                    } else { 
                        if((0!=st.Alm_RecId) && (0==st.ErrCommCount)) { 
                            DeviceAlarm_Thread.insertOrUpdateDevAlarmToTable(m_ConnPool, st.Alm_RecId, fbs9100_st.dev_id, fbs9100_st.dev_ipaddr, 
                                                                            DeviceAlarm_Thread.ALM_TYPE_FBS9100_CommError_ID, false); 
                            st.Alm_RecId = 0; 
                        } 
                    } 
                } 
                */ 
                Thread.sleep(1000); 
            } catch (Exception e1) { 
                //e1.printStackTrace(); 
            }     
        } 
    } 
}