变更库表后更新

DELL

2025-04-21 ee35cff26345898d032dfcddf5a417ed6ce4e13d

变更库表后更新

 BattMonitor_ElectLock_ListenSystemForLinux/ServerRestart.bat

@@ -2,6 +2,4 @@
cd /d "%~dp0"

net stop BMS_ELECT_LOCK_COMM

net start BMS_ELECT_LOCK_COMM

net stop BMS_ELECT_LOCK_ALARM

net start BMS_ELECT_LOCK_ALARM

exit


 BattMonitor_ElectLock_ListenSystemForLinux/bin/com/listen/ListenSystem_SQL.class

Binary files differ

 BattMonitor_ElectLock_ListenSystemForLinux/bin/com/listen/ListenSystem_Thread.class

Binary files differ

 BattMonitor_ElectLock_ListenSystemForLinux/bin/com/sql/Sql_Mysql.class

Binary files differ

 BattMonitor_ElectLock_ListenSystemForLinux/config.xml

@@ -1,7 +1,7 @@
<?xml version="1.0" encoding="gbk"?>

<root>
  <sql_server_ip>127.0.0.1</sql_server_ip>
  <sql_server_ip>192.168.10.82</sql_server_ip>
  <sql_server_port>3382</sql_server_port>
  <sql_conncount_max>200</sql_conncount_max>
  <lockAcceptPort>9001</lockAcceptPort>

 BattMonitor_ElectLock_ListenSystemForLinux/src/com/listen/ListenSystem_SQL.java

@@ -37,7 +37,7 @@
                        + "(8,11008, 'BMS_ELECT_LOCK_LISTEN', '1970-01-01 00:00:00','1970-01-01 00:00:00', 'BMS_ELECT_LOCK_LISTEN', 1,' ', '线程监控线程', 300),";

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

        try {

            sql.sqlMysqlUseDB(Sql_Mysql.DB_USER);

            sql.sqlMysqlUseDB(Sql_Mysql.PLUS_USER);

            if(false == sql.sqlMysqlCheckIfTableExist(TB_Process_SurveyTable))

            {

                sql.sqlMysqlExecute(sql_str);            

@@ -108,7 +108,7 @@
            }

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

            try {

                sql.sqlMysqlUseDB(Sql_Mysql.DB_USER);

                sql.sqlMysqlUseDB(Sql_Mysql.PLUS_USER);

                sql.makeManualCommit(sqls);

            } catch (SQLException e) {

                sql.logger.error(e.toString(), e);

@@ -142,7 +142,7 @@
            }

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

            try {

                sql.sqlMysqlUseDB(Sql_Mysql.DB_USER);

                sql.sqlMysqlUseDB(Sql_Mysql.PLUS_USER);

                sql.makeManualCommit(sqls);

            } catch (SQLException e) {

                sql.logger.error(e.toString(), e);


 BattMonitor_ElectLock_ListenSystemForLinux/src/com/sql/Sql_Mysql.java

@@ -19,35 +19,41 @@
public class Sql_Mysql 

{

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

    public static final String DB_AREA                     = "`db_area`";

    public static final String DB_LOCK_RAM                 = "`db_lock_ram`";

    public static final String DB_USER                     = "`db_user`";

    public static final String DB_LOCK_HIS                 = "`db_lock_his`";      //锁具历史状态库

    public static final String DB_LOCK_ALARM             = "`db_lock_alarm`";    //锁具告警库

    public static final String PLUS_INF                 = "`plus_inf`";

    public static final String PLUS_LOCK_RAM             = "`plus_lock_ram`";

    public static final String PLUS_USER                 = "plus_user";

    public static final String PLUS_LOCK_HIS             = "`plus_lock_his`";                      //锁具历史状态库

    public static final String PLUS_LOCK_ALARM             = "`plus_lock_alarm`";                    //锁具告警库

//    public static final String DB_AREA                     = "`db_area`";

//    public static final String DB_LOCK_RAM                 = "`db_lock_ram`";

//    public static final String DB_USER                     = "`db_user`";

//    public static final String DB_LOCK_HIS                 = "`db_lock_his`";                      //锁具历史状态库

//    public static final String DB_LOCK_ALARM             = "`db_lock_alarm`";                    //锁具告警库





    /*********************************************************/

    public static final String Lock_Rt_Table             = DB_LOCK_RAM + ".tb_lock_rt";

    public static final String Lock_Ctl_Log_Table         = DB_LOCK_RAM + ".tb_lock_ctl_log";

    public static final String Lock_Report_Table         = DB_LOCK_RAM + ".tb_lock_report";        //锁具开锁次数统计表

    public static final String Lock_Rt_Table             = PLUS_LOCK_RAM + ".tb_lock_rt";

    public static final String Lock_Ctl_Log_Table         = PLUS_LOCK_RAM + ".tb_lock_ctl_log";

    public static final String Lock_Report_Table         = PLUS_LOCK_RAM + ".tb_lock_report";        //锁具开锁次数统计表

    /*********************************************************/

    /***************  ************ db_area  ******************************/

    public static final String Lock_Inf_Table             = DB_AREA + ".tb_lock_inf";

    public static final String Key_Inf_Table             = DB_AREA + ".tb_key_inf";

    public static final String Auth_Idcard_Table         = DB_AREA + ".tb_auth_idcard";            //批量添加授权和取消授权表

    public static final String Auth_Idcard_His_Table     = DB_AREA + ".tb_auth_idcard_his";        //批量添加授权和取消授权历史表

    public static final String Lock_Inf_Table             = PLUS_INF + ".tb_lock_inf";

    public static final String Key_Inf_Table             = PLUS_INF + ".tb_key_inf";

    public static final String Auth_Idcard_Table         = PLUS_INF + ".tb_auth_idcard";            //批量添加授权和取消授权表

    public static final String Auth_Idcard_His_Table     = PLUS_INF + ".tb_auth_idcard_his";        //批量添加授权和取消授权历史表

    /*********************************************************/

    /***************************** db_lock_his ****************************/

    public static final String Lock_His_Table             = DB_LOCK_HIS + ".tb_lock_his_";        //锁具开锁次数统计表

    public static final String Lock_His_Table             = PLUS_LOCK_HIS + ".tb_lock_his_";        //锁具开锁次数统计表

    

    /*********************************************************/

    /***************************** db_user ****************************/

    public static final String Process_Survey_Table     = DB_USER + ".tb_process_survey";        //线程管理表

    public static final String Process_Survey_Table     = PLUS_USER + ".tb_process_survey";        //线程管理表

    

    /***************************** db_lock_alarm ****************************/



    public static final String Lock_Alarm_Table     = DB_LOCK_ALARM + ".tb_lock_alarm";        //实时告警

    public static final String Lock_Alm_Temp_Table     = DB_LOCK_ALARM + ".tb_lock_alm_temp";    //告警临时表

    public static final String Lock_Alarm_His_Table = DB_LOCK_ALARM + ".tb_lock_alarm_";    //历史告警表    //--------------------------------------------------------------------------------------------//

    public static final String Lock_Alarm_Table     = PLUS_LOCK_ALARM + ".tb_lock_alarm";        //实时告警

    public static final String Lock_Alm_Temp_Table     = PLUS_LOCK_ALARM + ".tb_lock_alm_temp";    //告警临时表

    public static final String Lock_Alarm_His_Table = PLUS_LOCK_ALARM + ".tb_lock_alarm_";    //历史告警表    //--------------------------------------------------------------------------------------------//

    public Connection mysql_con;

    public Logger logger;