首次提交

Administrator

2021-08-09 92aad2bdb3fc2552dfc199801c32b8bd9bb61472

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
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
package main; 
import java.util.Date; 
import java.util.TimeZone; 
 
import com.battmonitor.base.AppParam; 
import com.battmonitor.base.Com; 
import com.battmonitor.data.BattData_RT_Array; 
import com.battmonitor.sql.MysqlConnPool; 
import com.battmonitor.sql.Sql_Mysql; 
import com.batttest.BattDataTestPro_Thread; 
import com.batttest.BattResStorePro_Thread; 
import com.config.AppConfig; 
import com.dev.btse.comm.BattRealDataPro_Thread; 
import com.dev_concentrator.data.Concentrator_ServerSocketThread; 
import com.dev_concentrator.data.Concentrator_SocketThread_SQL; 
 
public class main_MonitorServer_Concentrator { 
    /**************************************************************************/ 
    /**************************************************************************/ 
    /**************************************************************************/ 
    /*********************  Ï·½É豸ֻÄÜÑ¡ÔñÒ»¸ö    *******************************/ 
    public final static boolean is_app_for_cmcc_only = false; 
    public final static boolean is_app_for_fbo_data_only = false; 
    public final static boolean is_app_for_fbs_free_only = false; 
    public final static boolean is_app_for_bpm7100_only = false; 
    public final static boolean is_app_for_FBS9100S_only = true; 
    /**************************************************************************/ 
    /**************************************************************************/ 
    /**************************************************************************/ 
    /**************************************************************************/ 
    public final static boolean app_debug = false; 
    public final static double m_VersionNum = 1.103; 
    public final static String m_Version = "Welcome To Use main_MonitorServer_Concentrator V"  
                                            + m_VersionNum + " RC_20190112"; 
    /**************************************************************************/ 
    /**************************************************************************/ 
    public static final int DEF_MysqlServerFBS9100S_Port = 3360; 
    public static int MysqlServer_Port = DEF_MysqlServerFBS9100S_Port; 
     
    private static AppConfig m_AppConfig; 
     
    private static MysqlConnPool GB_MysqlConnPool; 
    private static BattData_RT_Array GB_DataArray; 
    private static AppParam GB_App_Param; 
     
    public static boolean isFlushData = true; 
    /*********************************************************************************************/ 
    /*********************************************************************************************/ 
    public static void main(String[] args) { 
        TimeZone.setDefault(TimeZone.getTimeZone("GMT+8")); 
         
        String ver = m_Version; 
        MysqlServer_Port = DEF_MysqlServerFBS9100S_Port; 
         
        System.out.println("/****************************************************************"); 
        System.out.println("*****************************************************************"); 
        System.out.println("****************************************************************/"); 
        System.out.println(ver); 
        System.out.println("Server Started At DateTime: " + Com.getDateTimeFormat(new Date(), Com.DTF_YMDhms)); 
        //´´½¨config.xmlÎļþ 
        m_AppConfig = new AppConfig(); 
         
        System.out.println("ÕýÔÚÁ¬½ÓÊý¾Ý¿â DBserver IP£º" + m_AppConfig.getMysqlServerIp() + ", port: " + MysqlServer_Port); 
         
        //³õʼ»¯Á¬½Ó³ØÖеĸ÷ÖÖ²ÎÊýÐÅÏ¢ 
        GB_MysqlConnPool = new MysqlConnPool(m_AppConfig.getMysqlServerIp(), MysqlServer_Port,  
                                                m_AppConfig.getMysqlConnCountMax()); 
         
        Sql_Mysql sql_ck = new Sql_Mysql(GB_MysqlConnPool.getConn()); 
        try { 
            if(null != sql_ck.mysql_con) { 
                System.out.println("³É¹¦Á¬½ÓÊý¾Ý¿â"  
                                    + " DBserver IP£º" + m_AppConfig.getMysqlServerIp()  
                                    + ", port: " + MysqlServer_Port  
                                    + " @ " + Com.getDateTimeFormat(new Date(), Com.DTF_YMDhms)); 
            } 
        } finally { 
            sql_ck.close_con(); 
        } 
         
        //´´½¨tb_app_param±í,²¢ÇÒÉèÖñíÖеÄÊý¾Ý 
        GB_App_Param = new AppParam(GB_MysqlConnPool); 
         
        GB_DataArray = new BattData_RT_Array(m_AppConfig, GB_App_Param, GB_MysqlConnPool); 
        //¸üÐÂtb_batt_rtdata,tb_server_state,tb_batt_rtstate±íÖеÄÊý¾Ý 
        GB_DataArray.initBattDataRT_Inf(m_VersionNum); 
     
        /*********************************************************************************/ 
        /*********************************************************************************/ 
        /******************************  »ã¼¯Æ÷ͨѶÏ̠߳ ***************************************************/ 
        { 
             
            Concentrator_ServerSocketThread serverthread = new Concentrator_ServerSocketThread(GB_MysqlConnPool,GB_DataArray); 
            serverthread.start(); 
        } 
     
         
        /******************************  ÄÚ×èÀúÊ·Êý¾Ý¼Ç¼Ï̠߳ ***************************************************/ 
        { 
            BattResStorePro_Thread res_pro = new BattResStorePro_Thread(GB_MysqlConnPool, m_AppConfig, GB_DataArray); 
            res_pro.start(); 
             
        } 
         
        /******************************  µç³Ø²âÊÔÀúÊ·Êý¾Ý¼Ç¼Ï̠߳ ***************************************************/ 
        { 
            BattDataTestPro_Thread batt_test  
                = new BattDataTestPro_Thread(GB_MysqlConnPool, GB_App_Param, m_AppConfig, GB_DataArray); 
            batt_test.start(); 
        } 
         
        /************************************ µç³Ø×éÀúʷʵʱÊý¾Ý¼Ç¼Ï̠߳***************************************************************/ 
        if(true == m_AppConfig.isRealDataRecord_fn_En())  
        { 
            BattRealDataPro_Thread batt_realdata = new BattRealDataPro_Thread(GB_MysqlConnPool, m_AppConfig, GB_DataArray); 
            batt_realdata.start(); 
        } 
         
        /*********************************************************************************/ 
        Concentrator_SocketThread_SQL.initConcentratorThreadSQL(GB_MysqlConnPool); 
        Concentrator_SocketThread_SQL.updateConcentratorThread_StartTime(GB_MysqlConnPool, "V" + m_VersionNum); 
        while(true) { 
            try { 
                 
                Concentrator_SocketThread_SQL.updateConcentratorThread_Time(GB_MysqlConnPool); 
                //isFlushData = false; 
                 
                Thread.sleep(1500); 
                //System.out.println("getNumBusyConnections: " + GB_MysqlConnPool.getNumBusyConnections()); 
                //System.out.println("getNumIdleConnections: " + GB_MysqlConnPool.getNumIdleConnections()); 
                GB_DataArray.checkAndReinitBattGroupData(); 
            } catch (Exception e) { 
                e.printStackTrace(); 
            } 
        } 
        /*********************************************************************************/ 
    } 
}