| | |
| | | } 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();
|
| | | }
|
| | | }
|
| | |
| | | } 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();
|
| | | }
|
| | | }
|
| | |
| | | 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();
|
| | | }
|
| | | }
|
| | | }
|