添加通信异常逻辑

DELL

2024-10-12 75f29de7f6ec9c9d8e537fe9c5214075e70edef3

 iec61850_forFoShanAES_Model/src/com/dec/fbs9100/FBS9100_Task_Thread_SQL.java

@@ -655,8 +655,9 @@
   {

      String sql_str = "SELECT * FROM " + Sql_Mysql.FBS9100SetParam_Table;

      Sql_Mysql sql = new Sql_Mysql(con_pool);

      ResultSet res = sql.sqlMysqlQuery(sql_str);

      ResultSet res = null;

      try {

         res = sql.sqlMysqlQuery(sql_str);

         while(res.next())

         {

            FBS9100_StatAndParam param = null;

@@ -712,8 +713,9 @@
   {

      String sql_str = "SELECT * FROM " + Sql_Mysql.FBS9100SetParam_Table + " where dev_id = " + param.dev_id;

      Sql_Mysql sql = new Sql_Mysql(con_pool);

      ResultSet res = sql.sqlMysqlQuery(sql_str);

      ResultSet res = null;

      try {

         res = sql.sqlMysqlQuery(sql_str);

         if(res.next())

         {

            if(null != param) {

@@ -820,8 +822,9 @@
      //System.out.println(param.dev_id);

      String sql_str = "SELECT * FROM " + Sql_Mysql.FBS9100SetDLParam_Table + " where dev_id = " + param.dev_id;

      Sql_Mysql sql = new Sql_Mysql(con_pool);

      ResultSet res = sql.sqlMysqlQuery(sql_str);

      ResultSet res = null;

      try {

         res = sql.sqlMysqlQuery(sql_str);

         if(res.next())

         {

            if(null != param) {

@@ -1299,8 +1302,9 @@
   public static void queryFBS9100SysParamBydev_id(MysqlConnPool con_pool, FBS9100_StatAndParam param) {

      String sql_str = "SELECT * FROM " + Sql_Mysql.FBS9100SysParam_Table + " where dev_id = " + param.dev_id;

      Sql_Mysql sql = new Sql_Mysql(con_pool);

      ResultSet res = sql.sqlMysqlQuery(sql_str);

      ResultSet res = null;

      try {

         res = sql.sqlMysqlQuery(sql_str);

         if(res.next())

         {

            if(null != param) {

@@ -1329,6 +1333,13 @@
      } catch (SQLException e) {

         sql.logger.error("FBS9100_Task_Thread_SQL.queryFBS9100SysParamBydev_id():" + e.toString(), e);

      } finally {

         if(null != res) {

            try {

               res.close();

            } catch (SQLException e) {

               sql.logger.error("FBS9100_Task_Thread_SQL.queryFBS9100SysParamBydev_id():" + e.toString(), e);

            }

         }

         sql.close_con();

      }

   }

@@ -1515,9 +1526,10 @@
   public static void queryBTS61850OffLineyhPlanOnRam(MysqlConnPool m_ConnPool, FBS9100_StatAndParam param) {

      String sql_str = " SELECT * FROM " + Sql_Mysql.FBS9100_offlineyhplan + " WHERE dev_id = " + param.dev_id ;

      Sql_Mysql sql = new Sql_Mysql(m_ConnPool);

      ResultSet res = sql.sqlMysqlQuery(sql_str);

      BTS61850_OffLineYHPlan plan = param.bts61850_OffLineYHPlan;

      ResultSet res = null;

      try {

         res = sql.sqlMysqlQuery(sql_str);

         if(res.next()) {

            plan.OffLineYH_Cycle = res.getInt("OffLineYH_Cycle");

            plan.OffLineYHOnceCycle = res.getInt("OffLineYHOnceCycle");

@@ -1532,6 +1544,13 @@
      } catch (SQLException e) {

         sql.logger.error("FBS9100_Task_Thread_SQL.queryBTS61850OffLineyhPlanOnRam():" + e.toString(), e);

      } finally {

         if(null != res) {

            try {

               res.close();

            } catch (SQLException e) {

               e.printStackTrace();

            }

         }

         sql.close_con();

      }

   }