DELL
2024-07-02 0c2a13425088177cda9f9c1caf5c99131645b74a
iec61850_forFoShanAES_Model/src/com/dec/fbs9100/FBS9100_Task_Thread_SQL.java
@@ -1331,6 +1331,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();
      }
   }
@@ -1535,6 +1542,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();
      }
   }
@@ -1707,4 +1721,122 @@
      queryBTS61850OffLineyhPlanOnRam(pool, param);
      
   }
   /**
    * 查询设备的告警参数
    * @param con_pool
    * @param param
    */
   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);
      try {
         if(res.next())
         {
            if(null != param) {
               param.m_FBS_AlmParam.op_cmd = res.getInt("op_cmd");
               param.m_FBS_AlmParam.groupvol_high_val = res.getFloat("groupvol_high_val");;   //'组端电压高阈值',
               param.m_FBS_AlmParam.groupvol_low_val = res.getFloat("groupvol_low_val");      //'组端电压低阈值',
               param.m_FBS_AlmParam.monvol_high_val = res.getFloat("monvol_high_val");         //'单体电压高阈值',
               param.m_FBS_AlmParam.monvol_low_val = res.getFloat("monvol_low_val");         //'单体电压低阈值',
               param.m_FBS_AlmParam.montmp_high_val = res.getFloat("montmp_high_val");         //'单体温度高阈值',
               param.m_FBS_AlmParam.montmp_low_val = res.getFloat("montmp_low_val");         //'单体温度低阈值',
               param.m_FBS_AlmParam.monres_high_val = res.getFloat("monres_high_val");         //'单体内阻高阈值',
               param.m_FBS_AlmParam.monres_low_val = res.getFloat("monres_low_val");         //'单体内阻低阈值',
               param.m_FBS_AlmParam.moncap_high_val = res.getFloat("moncap_high_val");         //'单体容量高阈值',
               param.m_FBS_AlmParam.moncap_low_val = res.getFloat("moncap_low_val");         //'单体容量低阈值',
            }
         }
      } catch (SQLException e) {
         sql.logger.error("FBS9100_Task_Thread_SQL.queryDev6185AlmParamBydev_id():" + e.toString(), e);
      } finally {
         if(null != res) {
            try {
               res.close();
            } catch (SQLException e) {
               sql.logger.error("FBS9100_Task_Thread_SQL.queryDev6185AlmParamBydev_id():" + e.toString(), e);
            }
         }
         sql.close_con();
      }
   }
   public static void UpdateDev61850AlmParam(MysqlConnPool con_pool,FBS9100_AlarmParam almparam,FBS9100_StatAndParam param){
      String sql_str_base = Sql_Mysql.Dev_6185_AlmParam
            + " SET "
            + "dev_id=" + param.dev_id + ", "
            + "groupvol_high_val=" + almparam.groupvol_high_val + ", "
            + "groupvol_low_val=" + almparam.groupvol_low_val + ", "
            + "monvol_high_val=" + almparam.monvol_high_val + ", "
            + "monvol_low_val=" + almparam.monvol_low_val + ", "
            + "montmp_high_val=" + almparam.montmp_high_val + ", "
            + "montmp_low_val=" + almparam.montmp_low_val + ", "
            + "monres_high_val=" + almparam.monres_high_val + ", "
            + "monres_low_val=" + almparam.monres_low_val + ", "
            + "moncap_high_val=" + almparam.moncap_high_val + ", "
            + "moncap_low_val=" + almparam.moncap_low_val ;
      String sql_str_update = "UPDATE " + sql_str_base + " WHERE dev_id=" + param.dev_id;
      Sql_Mysql sql = new Sql_Mysql(con_pool);
      try {
         sql.sqlMysqlExecute(sql_str_update);
      } catch (SQLException e) {
         sql.logger.error("FBS9100_Task_Thread_SQL.inseartOrUpdateFBS9100SFODParam():" + e.toString(), e);
      } finally {
         sql.close_con();
      }
   }
   public static void updateDev61850AlmParamCmdBydev_id(MysqlConnPool con_pool, FBS9100_StatAndParam param)
   {
      if((param.op_cmd == FBS9100_ComBase.CMD_ReadAlarmParam_ACK)
            || (param.op_cmd == FBS9100_ComBase.CMD_FAIL)
            || (param.op_cmd == FBS9100_ComBase.CMD_WriteAlarmParam_ACK))
      {
         String sql_str_base = Sql_Mysql.Dev_6185_AlmParam + " SET "
               + " dev_id=" + param.dev_id + ", "
               + " op_cmd=" + param.op_cmd + " "
               + " where dev_id = "+param.dev_id;
         String sql_str_update = "UPDATE " + sql_str_base;
         Sql_Mysql sql = new Sql_Mysql(con_pool);
         try {
            sql.sqlMysqlExecute(sql_str_update);
         } catch (SQLException e) {
            sql.logger.error("FBS9100_Task_Thread_SQL.updateDev61850AlmParamCmdBydev_id():" + e.toString(), e);
         } finally {
            sql.close_con();
         }
         param.m_FBS_AlmParam.op_cmd = param.op_cmd;
         param.op_cmd = FBS9100_ComBase.CMD_NULL;
      }
   }
   /****************************************************************************************************/
   public static void inseartDev_6185_AlmParam(MysqlConnPool con_pool,int dev_id){
      String sql_str_ins = " insert into " + Sql_Mysql.Dev_6185_AlmParam+ "(dev_id) values(" + dev_id +");";
      Sql_Mysql sql = new Sql_Mysql(con_pool);
      ResultSet res = null;
      try {
         res = sql.sqlMysqlQuery("SELECT num FROM " + Sql_Mysql.Dev_6185_AlmParam
               + " WHERE dev_id = " + dev_id);
         if(!res.next()) {
            sql.sqlMysqlExecute(sql_str_ins);
         }
      } catch (SQLException e) {
         sql.logger.error("FBS9100_Task_Thread_SQL.inseartDev_6185_AlmParam():" + e.toString(), e);
      } finally {
         if(null != res) {
            try {
               res.close();
            } catch (SQLException e) {
               sql.logger.error("FBS9100_Task_Thread_SQL.inseartOrUpdateFBS9100SFODParam():" + e.toString(), e);
            }
         }
         sql.close_con();
      }
   }
}