优化IEDScout 逻辑

DELL

2024-02-23 7a1e39c59364ef80d68ea36c3e5aa004185077ba

优化IEDScout 逻辑

 iec61850_forFoShanAES_Model/bin/config.xml

@@ -2,7 +2,7 @@

<root>
  <mysql_ramdb_recreate_en>false</mysql_ramdb_recreate_en>
  <mysql_server_ip>127.0.0.1</mysql_server_ip>
  <mysql_server_ip>192.168.10.82</mysql_server_ip>
  <!--SOURCE_BATTDATA_TYPE_FBSDEV = 0-->
  <!--SOURCE_BATTDATA_TYPE_SQLSERVER = 1-->
  <!--SOURCE_BATTDATA_TYPE_C_INTERFACE = 2-->

 iec61850_forFoShanAES_Model/config.xml

@@ -2,7 +2,7 @@

<root>
  <mysql_ramdb_recreate_en>false</mysql_ramdb_recreate_en>
  <mysql_server_ip>127.0.0.1</mysql_server_ip>
  <mysql_server_ip>192.168.10.82</mysql_server_ip>
  <!--SOURCE_BATTDATA_TYPE_FBSDEV = 0-->
  <!--SOURCE_BATTDATA_TYPE_SQLSERVER = 1-->
  <!--SOURCE_BATTDATA_TYPE_C_INTERFACE = 2-->

 iec61850_forFoShanAES_Model/src/com/iedscout/BTS61850_IEDScout_Task.java

@@ -186,7 +186,8 @@
                    

                    //手动停止连接

                    if(BTS61850_IEDScout_Task_Thread_SQL.queryIed_NodeState_TableStopConnect(pool)) {

        				
                        m_App_IsConnect = false;

                        logger.error("DevIp:"+param.target_ip + " Remote DisConnect ... ");

                    }

                    

                    if(null == DataSetIt) {

@@ -208,6 +209,8 @@
            

            param.setConn_st(IEDScout_Param.CONN_STATE_FAIL);

            BTS61850_IEDScout_Task_Thread_SQL.updateConnect_Inf_Table(pool, param);     

        	
            logger.error("DevIp:"+param.target_ip + " DisConnect ... ");

        }

    }

    


 iec61850_forFoShanAES_Model/src/com/iedscout/BTS61850_IEDScout_Task_Thread_SQL.java

@@ -19,15 +19,15 @@
        Sql_Mysql sql = new Sql_Mysql(pool);

        try {

            res = sql.sqlMysqlQuery(sql_str);

            if(!res.next()) {

                sql.sqlMysqlExecute("INSERT INTO  " + Sql_Mysql.Connect_Inf_Table + "(target_ip,target_port,conn_st) VALUES('127.0.0.1',102,0);");

            }else{

            if(res.next()) {

                int count_num = res.getInt("count_num");

                if(count_num > 1) {

                    sql.sqlMysqlExecute("DELETE FROM " + Sql_Mysql.Connect_Inf_Table + " WHERE num > 1");

                    sql.sqlMysqlExecute("DELETE FROM " + Sql_Mysql.Connect_Inf_Table);

                    sql.sqlMysqlExecute("INSERT INTO  " + Sql_Mysql.Connect_Inf_Table + "(num,target_ip,target_port,conn_st) VALUES(1,'127.0.0.1',102,0);");

                }else {

                }else if(count_num == 1){

                    sql.sqlMysqlExecute(" UPDATE " + Sql_Mysql.Connect_Inf_Table + " set conn_st = 0;");

                }else {

                    sql.sqlMysqlExecute("INSERT INTO  " + Sql_Mysql.Connect_Inf_Table + "(num,target_ip,target_port,conn_st) VALUES(1,'127.0.0.1',102,0);");

                }

            }

        } catch (SQLException e) {

@@ -205,7 +205,33 @@
    }



    public static boolean queryIed_NodeState_TableStopConnect(MysqlConnPool pool) {

        String sql_str = "SELECT * FROM " + Sql_Mysql.Connect_Inf_Table +" where  conn_st = 0;";

        boolean flag = false;

        ResultSet res = null; 
        Sql_Mysql sql = new Sql_Mysql(pool);

        try {

            res = sql.sqlMysqlQuery(sql_str);

            if(res.next()) {

                flag = true;

            }

        } catch (SQLException e) {

            sql.logger.error("BTS61850_IEDScout_Task_Thread_SQL.insertIntoIed_NodeState_Table():" + e.toString(), e);

        } finally {

            if(null != res) {

                try {

                    res.close();

                } catch (SQLException e) {

                    sql.logger.error("BTS61850_IEDScout_Task_Thread_SQL.insertIntoIed_NodeState_Table():" + e.toString(), e);

                }

            }

            sql.close_con();

        }

        return flag;

    }

	
    public static void main(String[] args) {

        MysqlConnPool pool = new MysqlConnPool("192.168.10.82", 3360, 5);

        System.out.println(queryIed_NodeState_TableStopConnect(pool));;

        

        return false;

    }

}