运行时设置 重启告警线程

whyclj

2020-04-24 7bffb664b76791665cd0067a08c3beb77ca22559

运行时设置 重启告警线程

 BattMonitor_DB_Builder/src/com/battdata_rt/BattData_RT_RamDB_Thread_SQL.java

@@ -5,9 +5,7 @@
import java.sql.ResultSet;

import java.sql.SQLException;

import java.util.Date;



import main.main_BTS_DB_Builder;



import com.base.Com;

import com.sql.MysqlConnPool;

import com.sql.Sql_Mysql;

@@ -509,7 +507,7 @@
            sql.close_con();

        }

    }



	
    public static void main(String[] args) {

        MysqlConnPool conn_pool = new MysqlConnPool("127.0.0.1",3360,5);

        System.out.println(updateTb_App_Sys_AppServerTable(conn_pool));


 BattMonitor_DB_Builder/src/com/database_util/DB_db_user.java

@@ -71,6 +71,7 @@
//            if(true == recreate) {            
//                sql.sqlMysqlExecute(sql_str01);
//            }
            sql.sqlMysqlUseDB(Sql_Mysql.DB_USER);
            sql.sqlMysqlExecute(sql_str02);
            
            //添加加密告警upassword

 BattMonitor_DB_Builder/src/com/database_util/DB_web_site.java

@@ -923,9 +923,72 @@
        }

    }

    

    /**

     *    创建电池组更换记录表

     */

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

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

        String sql_str02 = "CREATE TABLE IF NOT EXISTS "+Sql_Mysql.BattReplace_Table+" (" + 
                "  num int(11) NOT NULL AUTO_INCREMENT," + 
                "  stationid varchar(64) NOT NULL DEFAULT ''," + 
                "  replaced_producer varchar(64) NOT NULL DEFAULT ''," + 
                "  replaced_moncapstd int(11) NOT NULL DEFAULT '0'," + 
                "  replaced_monvolstd float NOT NULL DEFAULT '0'," + 
                "  replaced_moncount int(11) NOT NULL DEFAULT '0'," + 
                "  replaced_time datetime NOT NULL DEFAULT '2018-01-01 00:00:00'," + 
                "  replaced_uid int(11) NOT NULL DEFAULT '0'," + 
                "  replaced_reason varchar(256) NOT NULL DEFAULT ''," + 
                "  note varchar(64) NOT NULL DEFAULT ''," + 
                "  replace_date date DEFAULT '2020-04-20'," + 
                "  PRIMARY KEY (`num`)," + 
                "  KEY `stationid_index` (`stationid`)" + 
                ") ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8;"; 
        Sql_Mysql sql = new Sql_Mysql(pool.getConn());

        try {

            if(true == recreate) {			
                //sql.sqlMysqlExecute(sql_str01);

                //sql.sqlMysqlExecute(sql_str02);

            }

            sql.sqlMysqlExecute(sql_str02);                                    //创建电池组更换记录表		
            /************************** 添加 replace_date 字段 **************************************/

            String sql_str03 = " SELECT * FROM information_schema.columns  "

                            +  " WHERE table_schema= 'web_site' "

                            +  " AND table_name='tb_batt_replace' "

                            +  " AND column_name='replace_date'";

            ResultSet rs = sql.sqlMysqlQuery(sql_str03);

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

                sql.sqlMysqlExecute(" ALTER TABLE " + Sql_Mysql.BattReplace_Table 
                                + " ADD COLUMN replace_date date DEFAULT '2020-04-20';");

            }

        } catch (SQLException e) {

            e.printStackTrace();

        } finally {

            sql.close_con();

        }

    }

	
    /**

     *    设置指定的线程重启[ 告警线程; ]

     */

    public static void setUpThreadRestart(MysqlConnPool conn_pool) {

        //重启告警线程

        String sql_str = "UPDATE " + Sql_Mysql.ProcessSurvey_Table

                + " SET ServerFlag = 0 "

                + " WHERE ProcessId = 11002 AND ServerFlag != 2";

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

        try {

            sql.sqlMysqlExecute(sql_str);

        } catch (SQLException e) {

            e.printStackTrace();

        } finally {

            sql.close_con();

        }

		
    }

	
    public static void main(String[] args) {

        MysqlConnPool pool = new MysqlConnPool("123.207.82.239", 3360, 10);

        MysqlConnPool pool = new MysqlConnPool("127.0.0.1", 3360, 10);

        DB_web_site website = new DB_web_site();

        website.createThread_utilTable(pool, false);

        website.createBattReplace_Table(pool, false);

    }

}


 BattMonitor_DB_Builder/src/com/sql/Sql_Mysql.java

@@ -149,7 +149,7 @@
    public final static String BattDischargePlan_Table = WEB_Site + ".`tb_battdischarge_plan`";            //放电计划表

    public final static String BattMapInformation_Table = WEB_Site + ".`tb_battmap_information`";        //基站定位表

    public final static String BattDischarge_Table = WEB_Site + ".`tb_batt_discharge`";                    //基站故障表

	
    public final static String BattReplace_Table = WEB_Site + ".`tb_batt_replace`";                        //电池更换记录表

    

    

    


 BattMonitor_DB_Builder/src/main/main_BTS_DB_Builder.java

@@ -122,12 +122,13 @@
        //初始化数据库 db_user

        DB_db_user.init(GB_MysqlConnPool, recreate_tb);

        

        //设置重启告警线程

        DB_web_site.setUpThreadRestart(GB_MysqlConnPool);

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

            m_AppConfig.setMysqlDB_RecreateEn(false);

            m_AppConfig.writeConfigToXml();

        }

		
		
        

        //修改tb_app_sys表中的关键字,让主程序识别

        for(int i=0;i<5;i++) {