2024-09-06 异常结束时，跳出通信线程，重新连接设备，修复异常掉线无法重连

DELL

2024-09-06 beddba43b46bc4b664dc63e42988b2724b7a5aab

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

@@ -717,8 +717,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;

@@ -774,8 +775,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) {

@@ -928,7 +930,6 @@
      String sql_str_update = "UPDATE " + sql_str_base + " WHERE dev_id=" + param.dev_id;

      

      Sql_Mysql sql = new Sql_Mysql(con_pool);

      ResultSet res = null;

      try {

         sql.sqlMysqlExecute(sql_str_update);

      } catch (SQLException e) {

@@ -943,8 +944,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) {

@@ -1446,8 +1448,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) {

@@ -1496,8 +1499,9 @@
   public static void queryDev6185AlmParamBydev_id(MysqlConnPool con_pool, FBS9100_StatAndParam param) {

      String sql_str = "SELECT * FROM " + Sql_Mysql.Dev_6185_AlmParam + " 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) {

@@ -1710,9 +1714,10 @@
   public static void queryBTS61851OffLineyhPlanOnRam(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);

      ResultSet res = null;

      BTS61850_OffLineYHPlan plan = param.bts61850_OffLineYHPlan;

      try {

         res = sql.sqlMysqlQuery(sql_str);

         if(res.next()) {

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

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

@@ -1727,6 +1732,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) {

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

            }

         }

         sql.close_con();

      }

   }