创建61850离线养护计划参数表

whyclj

2020-04-21 c0905f4b6b8c4cc8eb1cbb5b92afacc9983db42b

创建61850离线养护计划参数表

 BattMonitor_DB_Builder/src/com/database_util/DB_battinf.java

@@ -246,7 +246,7 @@
    

    

    /**

     *    创建机房配租记录表

     *    创建机房配组记录表

     */

    public static void createBattinfRebuild_TABLE(MysqlConnPool pool, boolean recreate) {

        String sql_str01 = " DROP TABLE IF EXISTS "+Sql_Mysql.BattinfRebuild_TABLE;


 BattMonitor_DB_Builder/src/com/database_util/DB_web_site.java

@@ -281,7 +281,7 @@
                "  `OutTime` int(11) NOT NULL DEFAULT '60'," +                                     //超时时长

                "  PRIMARY KEY (`num`)," +             

                "  UNIQUE KEY `ProcessId` (`ProcessId`)" + 

                ") ENGINE=InnoDB AUTO_INCREMENT=11 DEFAULT CHARSET=utf8;";

                ") ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8;";

        Sql_Mysql sql = new Sql_Mysql(pool.getConn());

        ResultSet res = null;

        try {

@@ -292,58 +292,63 @@
            //添加主程序记录

            res = sql.sqlMysqlQuery("SELECT * FROM "+ Sql_Mysql.ProcessSurvey_Table + " WHERE ProcessId = 11001");

            if(false == res.next()) {                

                sql.sqlMysqlExecute("INSERT INTO " + Sql_Mysql.ProcessSurvey_Table + "(num,ProcessId,ProcessName,ProcessTime,Process_starttime,ServerName,ServerFlag,ProcessVersion,note,OutTime) VALUES ('1', '11001', 'BMS_FBSDEV',                 '1970-01-01 00:00:00', '1970-01-01 00:00:00', 'BMS_FBSDEV', '1', 'V1.585', '主程序线程', '300');");

                sql.sqlMysqlExecute("INSERT INTO " + Sql_Mysql.ProcessSurvey_Table + "(ProcessId,ProcessName,ProcessTime,Process_starttime,ServerName,ServerFlag,ProcessVersion,note,OutTime) VALUES ('11001', 'BMS_FBSDEV', '1970-01-01 00:00:00', '1970-01-01 00:00:00', 'BMS_FBSDEV', '1', 'V1.585', '主程序线程', '300');");

            }

            //添加电池告警进程记录

            res = sql.sqlMysqlQuery("SELECT * FROM "+ Sql_Mysql.ProcessSurvey_Table + " WHERE ProcessId = 11002");

            if(false == res.next()) {                

                sql.sqlMysqlExecute("INSERT INTO " + Sql_Mysql.ProcessSurvey_Table + "(num,ProcessId,ProcessName,ProcessTime,Process_starttime,ServerName,ServerFlag,ProcessVersion,note,OutTime) VALUES ('2', '11002', 'BMS_FBSDEV_ALARM_BATT',     '1970-01-01 00:00:00', '1970-01-01 00:00:00', 'BMS_FBSDEV_ALARM', '1', 'V1.109', '电池告警线程', '300');");

                sql.sqlMysqlExecute("INSERT INTO " + Sql_Mysql.ProcessSurvey_Table + "(ProcessId,ProcessName,ProcessTime,Process_starttime,ServerName,ServerFlag,ProcessVersion,note,OutTime) VALUES ('11002', 'BMS_FBSDEV_ALARM_BATT',     '1970-01-01 00:00:00', '1970-01-01 00:00:00', 'BMS_FBSDEV_ALARM', '1', 'V1.109', '电池告警线程', '300');");

            }

            //添加设备告警进程记录

            res = sql.sqlMysqlQuery("SELECT * FROM "+ Sql_Mysql.ProcessSurvey_Table + " WHERE ProcessId = 11003");

            if(false == res.next()) {                

                sql.sqlMysqlExecute("INSERT INTO " + Sql_Mysql.ProcessSurvey_Table + "(num,ProcessId,ProcessName,ProcessTime,Process_starttime,ServerName,ServerFlag,ProcessVersion,note,OutTime) VALUES ('3', '11003', 'BMS_FBSDEV_ALARM_DEV',         '1970-01-01 00:00:00', '1970-01-01 00:00:00', 'BMS_FBSDEV_ALARM', '1', 'V1.109', '设备告警线程', '300');");

                sql.sqlMysqlExecute("INSERT INTO " + Sql_Mysql.ProcessSurvey_Table + "(ProcessId,ProcessName,ProcessTime,Process_starttime,ServerName,ServerFlag,ProcessVersion,note,OutTime) VALUES ('11003', 'BMS_FBSDEV_ALARM_DEV',         '1970-01-01 00:00:00', '1970-01-01 00:00:00', 'BMS_FBSDEV_ALARM', '1', 'V1.109', '设备告警线程', '300');");

            }

            //添加落后单体进程记录

            res = sql.sqlMysqlQuery("SELECT * FROM "+ Sql_Mysql.ProcessSurvey_Table + " WHERE ProcessId = 11004");

            if(false == res.next()) {

                sql.sqlMysqlExecute("INSERT INTO " + Sql_Mysql.ProcessSurvey_Table + "(num,ProcessId,ProcessName,ProcessTime,Process_starttime,ServerName,ServerFlag,ProcessVersion,note,OutTime) VALUES ('4', '11004', 'BMS_FBSDEV_BADBATT_MON',     '1970-01-01 00:00:00', '1970-01-01 00:00:00', 'BMS_FBSDEV_BADBATT', '1', 'v2.303', '落后单体线程', '300');");

                sql.sqlMysqlExecute("INSERT INTO " + Sql_Mysql.ProcessSurvey_Table + "(ProcessId,ProcessName,ProcessTime,Process_starttime,ServerName,ServerFlag,ProcessVersion,note,OutTime) VALUES ('11004', 'BMS_FBSDEV_BADBATT_MON',     '1970-01-01 00:00:00', '1970-01-01 00:00:00', 'BMS_FBSDEV_BADBATT', '1', 'v2.303', '落后单体线程', '300');");

            }

            //添加容量告警进程记录

            res = sql.sqlMysqlQuery("SELECT * FROM "+ Sql_Mysql.ProcessSurvey_Table + " WHERE ProcessId = 11005");

            if(false == res.next()) {                

                sql.sqlMysqlExecute("INSERT INTO " + Sql_Mysql.ProcessSurvey_Table + "(num,ProcessId,ProcessName,ProcessTime,Process_starttime,ServerName,ServerFlag,ProcessVersion,note,OutTime) VALUES ('5', '11005', 'BMS_FBSDEV_BADBATT_CAP',     '1970-01-01 00:00:00', '1970-01-01 00:00:00', 'BMS_FBSDEV_BADBATT', '1', 'v2.303', '容量告警线程', '300');");

                sql.sqlMysqlExecute("INSERT INTO " + Sql_Mysql.ProcessSurvey_Table + "(ProcessId,ProcessName,ProcessTime,Process_starttime,ServerName,ServerFlag,ProcessVersion,note,OutTime) VALUES ('11005', 'BMS_FBSDEV_BADBATT_CAP',     '1970-01-01 00:00:00', '1970-01-01 00:00:00', 'BMS_FBSDEV_BADBATT', '1', 'v2.303', '容量告警线程', '300');");

            }

            //添加放电计划进程记录

            res = sql.sqlMysqlQuery("SELECT * FROM "+ Sql_Mysql.ProcessSurvey_Table + " WHERE ProcessId = 11006");

            if(false == res.next()) {

                sql.sqlMysqlExecute("INSERT INTO " + Sql_Mysql.ProcessSurvey_Table + "(num,ProcessId,ProcessName,ProcessTime,Process_starttime,ServerName,ServerFlag,ProcessVersion,note,OutTime) VALUES ('6', '11006', 'BMS_FBSDEV_PLAN',             '1970-01-01 00:00:00', '1970-01-01 00:00:00', 'BMS_FBSDEV_PLAN', '2', ' ', '放电计划线程', '300');");

                sql.sqlMysqlExecute("INSERT INTO " + Sql_Mysql.ProcessSurvey_Table + "(ProcessId,ProcessName,ProcessTime,Process_starttime,ServerName,ServerFlag,ProcessVersion,note,OutTime) VALUES ('11006', 'BMS_FBSDEV_PLAN',             '1970-01-01 00:00:00', '1970-01-01 00:00:00', 'BMS_FBSDEV_PLAN', '2', ' ', '放电计划线程', '300');");

            }

            //添加机房停电进程记录

            res = sql.sqlMysqlQuery("SELECT * FROM "+ Sql_Mysql.ProcessSurvey_Table + " WHERE ProcessId = 11007");

            if(false == res.next()) {

                sql.sqlMysqlExecute("INSERT INTO " + Sql_Mysql.ProcessSurvey_Table + "(num,ProcessId,ProcessName,ProcessTime,Process_starttime,ServerName,ServerFlag,ProcessVersion,note,OutTime) VALUES ('7', '11007', 'BMS_FBSDEV_POWER_FAIL',     '1970-01-01 00:00:00', '1970-01-01 00:00:00', 'BMS_FBSDEV_POWER_FAIL', '2', ' ', '机房停电线程', '300');");

                sql.sqlMysqlExecute("INSERT INTO " + Sql_Mysql.ProcessSurvey_Table + "(ProcessId,ProcessName,ProcessTime,Process_starttime,ServerName,ServerFlag,ProcessVersion,note,OutTime) VALUES ('11007', 'BMS_FBSDEV_POWER_FAIL',     '1970-01-01 00:00:00', '1970-01-01 00:00:00', 'BMS_FBSDEV_POWER_FAIL', '2', ' ', '机房停电线程', '300');");

            }

            //添加线程监控进程记录

            res = sql.sqlMysqlQuery("SELECT * FROM "+ Sql_Mysql.ProcessSurvey_Table + " WHERE ProcessId = 11008");

            if(false == res.next()) {

                sql.sqlMysqlExecute("INSERT INTO " + Sql_Mysql.ProcessSurvey_Table + "(num,ProcessId,ProcessName,ProcessTime,Process_starttime,ServerName,ServerFlag,ProcessVersion,note,OutTime) VALUES ('8', '11008', 'BMS_FBSDEV_LISTEN',         '1970-01-01 00:00:00', '1970-01-01 00:00:00', 'BMS_FBSDEV_LISTEN', '1', 'V1.101', '线程监控线程', '300');");

                sql.sqlMysqlExecute("INSERT INTO " + Sql_Mysql.ProcessSurvey_Table + "(ProcessId,ProcessName,ProcessTime,Process_starttime,ServerName,ServerFlag,ProcessVersion,note,OutTime) VALUES ('11008', 'BMS_FBSDEV_LISTEN',         '1970-01-01 00:00:00', '1970-01-01 00:00:00', 'BMS_FBSDEV_LISTEN', '1', 'V1.101', '线程监控线程', '300');");

            }

            //添加61850进程记录

            res = sql.sqlMysqlQuery("SELECT * FROM "+ Sql_Mysql.ProcessSurvey_Table + " WHERE ProcessId = 11009");

            if(false == res.next()) {

                sql.sqlMysqlExecute("INSERT INTO " + Sql_Mysql.ProcessSurvey_Table + "(num,ProcessId,ProcessName,ProcessTime,Process_starttime,ServerName,ServerFlag,ProcessVersion,note,OutTime) VALUES ('9', '11009', 'BMS_FBS61850_BATT',         '1970-01-01 00:00:00', '1970-01-01 00:00:00', 'BMS_FBS61850_BATT', '2', 'V1.101', '61850通讯线程', '300');");

                sql.sqlMysqlExecute("INSERT INTO " + Sql_Mysql.ProcessSurvey_Table + "(ProcessId,ProcessName,ProcessTime,Process_starttime,ServerName,ServerFlag,ProcessVersion,note,OutTime) VALUES ('11009', 'BMS_FBS61850_BATT',         '1970-01-01 00:00:00', '1970-01-01 00:00:00', 'BMS_FBS61850_BATT', '2', 'V1.101', '61850通讯线程', '300');");

            }

            //添加9600进程记录

            res = sql.sqlMysqlQuery("SELECT * FROM "+ Sql_Mysql.ProcessSurvey_Table + " WHERE ProcessId = 11010");

            if(false == res.next()) {

                sql.sqlMysqlExecute("INSERT INTO " + Sql_Mysql.ProcessSurvey_Table + "(num,ProcessId,ProcessName,ProcessTime,Process_starttime,ServerName,ServerFlag,ProcessVersion,note,OutTime) VALUES ('10', '11010', 'BMS_FBS9600_DISPLAY',         '1970-01-01 00:00:00', '1970-01-01 00:00:00', 'BMS_FBS9600_DISPLAY', '2', 'v1.101', '9600显示模块线程', '300');");

                sql.sqlMysqlExecute("INSERT INTO " + Sql_Mysql.ProcessSurvey_Table + "(ProcessId,ProcessName,ProcessTime,Process_starttime,ServerName,ServerFlag,ProcessVersion,note,OutTime) VALUES ('11010', 'BMS_FBS9600_DISPLAY',         '1970-01-01 00:00:00', '1970-01-01 00:00:00', 'BMS_FBS9600_DISPLAY', '2', 'v1.101', '9600显示模块线程', '300');");

            }

            //添加FBS汇集器通讯进程记录

            res = sql.sqlMysqlQuery("SELECT * FROM "+ Sql_Mysql.ProcessSurvey_Table + " WHERE ProcessId = 11011");

            if(false == res.next()) {

                sql.sqlMysqlExecute("INSERT INTO " + Sql_Mysql.ProcessSurvey_Table + "(ProcessId,ProcessName,ProcessTime,Process_starttime,ServerName,ServerFlag,ProcessVersion,note,OutTime) VALUES ('11011', 'BMS_FBS_CONCENTRATOR',         '1970-01-01 00:00:00', '1970-01-01 00:00:00', 'BMS_FBS_CONCENTRATOR', '2', 'v1.101', 'FBS汇集器通讯线程', '300');");

            }

            //添加9度通讯线程

            res = sql.sqlMysqlQuery("SELECT * FROM "+ Sql_Mysql.ProcessSurvey_Table + " WHERE ProcessId = 11012");

            if(false == res.next()) {

                sql.sqlMysqlExecute(" INSERT INTO " + Sql_Mysql.ProcessSurvey_Table + "(ProcessId,ProcessName,ProcessTime,Process_starttime,ServerName,ServerFlag,ProcessVersion,note,OutTime) VALUES ('11012', 'BMS_LD-9_DEV',         '1970-01-01 00:00:00', '1970-01-01 00:00:00', 'BMS_LD-9_DEV', '2', 'v1.101', '9度设备通讯线程', '300');");

            }

        

        } catch (SQLException e) {

            e.printStackTrace();


 BattMonitor_DB_Builder/src/com/dev/fbs9100/FBS9100_Task_Thread_SQL.java

@@ -206,6 +206,9 @@
                sql.sqlMysqlExecute("ALTER TABLE " + Sql_Mysql.FBS9100State_Table 

                        + " ADD COLUMN `batt_online_state` INT NOT NULL DEFAULT 0;");

            }

			
			
			
            //sql.sqlMysqlExecute(str3);

        } catch (SQLException e) {

            // TODO Auto-generated catch block

@@ -372,6 +375,34 @@
                sql.sqlMysqlExecute("ALTER TABLE " + Sql_Mysql.FBS9100SetParam_Table 

                                + " ADD COLUMN `OffLineYH_Cycle`  int NOT NULL DEFAULT 0;");

            }

            //添加指定的OffLineYHstarttime列(养护计划开始时间)

            res = sql.sqlMysqlQuery("SELECT * FROM information_schema.columns"

                    + " WHERE table_schema='db_ram_db'"

                    + " AND table_name='tb_fbs9100_setparam'"

                    + " AND column_name='OffLineYHstarttime'");

            if(false == res.next()) {

                sql.sqlMysqlExecute("ALTER TABLE " + Sql_Mysql.FBS9100SetParam_Table 
                                + " ADD COLUMN `OffLineYHstarttime` datetime NOT NULL DEFAULT '2000-01-01 00:00:00';");

            }

            //添加指定的OffLineYHTimes列(离线养护执行次数)

            res = sql.sqlMysqlQuery("SELECT * FROM information_schema.columns"

                    + " WHERE table_schema='db_ram_db'"

                    + " AND table_name='tb_fbs9100_setparam'"

                    + " AND column_name='OffLineYHTimes'");

            if(false == res.next()) {

                sql.sqlMysqlExecute("ALTER TABLE " + Sql_Mysql.FBS9100SetParam_Table 
                                + " ADD COLUMN `OffLineYHTimes` int(11) NOT NULL DEFAULT '1';");

            }

            //添加指定的OffLineYHOnceCycle列(离线养护每次执行周期)

            res = sql.sqlMysqlQuery("SELECT * FROM information_schema.columns"

                    + " WHERE table_schema='db_ram_db'"

                    + " AND table_name='tb_fbs9100_setparam'"

                    + " AND column_name='OffLineYHOnceCycle'");

            if(false == res.next()) {

                sql.sqlMysqlExecute("ALTER TABLE " + Sql_Mysql.FBS9100SetParam_Table 
                                + " ADD COLUMN `OffLineYHOnceCycle` int(11) NOT NULL DEFAULT '1';");

            }

			
        } catch (SQLException e) {

            e.printStackTrace();

        } finally {

@@ -624,4 +655,39 @@
    }



    

    /**

     *     创建61850离线养护计划参数表

     * @param pool

     * @param recreate_tb

     */

    public static void createFBS9100_offlineyhplanOnRam(MysqlConnPool pool, boolean recreate_tb) {

        String sql_str0 = "DROP TABLE IF EXISTS " + Sql_Mysql.FBS9100_offlineyhplan + "; ";

		
        String sql_str1 = "CREATE TABLE IF NOT EXISTS  "+Sql_Mysql.FBS9100_offlineyhplan+" (" + 
                "  num bigint(20) NOT NULL AUTO_INCREMENT," + 
                "  dev_id int(11) NOT NULL DEFAULT '1'," + 
                "  OffLineYH_Cycle int(11) NOT NULL DEFAULT '1'," + 
                "  OffLineYHstarttime datetime NOT NULL DEFAULT '2000-01-01 00:00:00'," + 
                "  OffLineYHTimes int(11) NOT NULL DEFAULT '0'," + 
                "  OffLineYHOnceCycle int(11) NOT NULL DEFAULT '0'," + 
                "  note varchar(255) NOT NULL DEFAULT ''," + 
                "  PRIMARY KEY (`num`)" + 
                ") ENGINE=InnoDB DEFAULT CHARSET=utf8; ";

				
        Sql_Mysql sql = new Sql_Mysql(pool.getConn());

        try {

            if(true == recreate_tb) {

                sql.sqlMysqlExecute(sql_str0);

            } else {

				
            }

            sql.sqlMysqlExecute(sql_str1);

        } catch (SQLException e) {

            e.printStackTrace();

        } finally {

            sql.close_con();

        }		
    }

	
	
}


 BattMonitor_DB_Builder/src/com/sql/Sql_Mysql.java

@@ -84,6 +84,8 @@
    public final static String FBS9100BattParam_Table = DB_RamDB + ".`tb_fbs9100_battparam`";                        //电池组参数表

    

    public final static String TB_61850_JHState_Table = DB_RamDB +".tb_61850_jhstate";                                //61850均衡61850供电模块信息

	
    public final static String FBS9100_offlineyhplan = DB_RamDB + ".tb_fbs9100_offlineyhplan";                        //61850离线养护计划参数表

    //--------------------------------------------------------------------------------------------//

    //--------------------------------------------------------------------------------------------//

    public final static String AppSys_Table = DB_AppSys + ".`tb_app_sys`";

@@ -650,7 +652,7 @@
                        }

                //---------------------------------------------------------------------------------------------//

                        //为紫晶南网平台添加指定的列

                        boolean isZijing = true;

                        boolean isZijing = false;

                        if(isZijing) {

                            //添加电压等级列

                            res = sqlMysqlQuery("SELECT * FROM information_schema.columns"


 BattMonitor_DB_Builder/src/main/main_BTS_DB_Builder.java

@@ -6,6 +6,7 @@
import com.battdata_rt.BattData_RT_RamDB_Thread_SQL;

import com.config.AppConfig;

import com.database_util.DB_battinf;

import com.database_util.DB_db_user;

import com.database_util.DB_web_site;

import com.dev.fbs9100.FBS9100S_DFU_SQL;

import com.dev.fbs9100.FBS9100_Task_Thread_SQL;

@@ -108,6 +109,9 @@
        //创建61850均衡模块信息表

        FBS9100_Task_Thread_SQL.createTB_61850_JHState_TableOnRam(GB_MysqlConnPool,recreate_tb);

        

        //创建61850离线养护计划参数表

        FBS9100_Task_Thread_SQL.createFBS9100_offlineyhplanOnRam(GB_MysqlConnPool, recreate_tb);

		
        

        //初始化数据库  db_battinf

        DB_battinf.init(GB_MysqlConnPool, recreate_tb);

@@ -115,6 +119,8 @@
        //初始化数据库 web_site

        DB_web_site.init(GB_MysqlConnPool, recreate_tb);                

        

        //初始化数据库 db_user

        DB_db_user.init(GB_MysqlConnPool, recreate_tb);

        

        if(true == m_AppConfig.getMysqlDB_RecreateEn()) {

            m_AppConfig.setMysqlDB_RecreateEn(false);