90 lines
3.3 KiB
C++
90 lines
3.3 KiB
C++
#include <eqpalg/algs/meter_bound.h>
|
||
#include <eqpalg/exp_macro/get_macro_replaced_exp.h>
|
||
#include <eqpalg/utility/build_alarm_info.h>
|
||
#include <sstream>
|
||
MeterBound::MeterBound(const string& name, const mix_cc::json& rule_json,
|
||
const string& ruleId, size_t dims)
|
||
: Exp(name, rule_json, ruleId, dims) {
|
||
logger_.reset(new LOG("MeterBound:" + rule_name_, AUTO_CATCH_PID));
|
||
}
|
||
MeterBound::~MeterBound() {}
|
||
|
||
/**
|
||
* @brief 重写 init
|
||
*
|
||
* @return int
|
||
*/
|
||
int MeterBound::init() {
|
||
int ret = 0;
|
||
try {
|
||
AlgBase::init();
|
||
reload_config();
|
||
} catch (const std::exception& e) {
|
||
std::throw_with_nested(
|
||
mix_cc::Exception(-1, "load error", BOOST_CURRENT_LOCATION));
|
||
}
|
||
return ret;
|
||
}
|
||
|
||
int MeterBound::reload_config() {
|
||
string tmp_exp =
|
||
rule_json_.at("alarm_option").at("value").at(1).get<std::string>();
|
||
exp_str_ = get_macro_replaced_exp(tmp_exp);
|
||
|
||
error_up_ = rule_json_.at("alarm_option").at("error_up").at(1).get<double>();
|
||
error_down_ =
|
||
rule_json_.at("alarm_option").at("error_down").at(1).get<double>();
|
||
error_str_ = rule_json_.at("interval").at("error").at(1).get<std::string>();
|
||
if (exp_act_ == nullptr && exp_str_ != "") {
|
||
exp_act_ =
|
||
std::make_unique<mix_cc::matheval::Expression>(exp_str_, &mm_vars);
|
||
}
|
||
return 0;
|
||
}
|
||
|
||
AlarmInfo MeterBound::mon_proc() {
|
||
this->value_ = this->exp_act_->evaluate();
|
||
if (this->value_ > this->error_up_) {
|
||
//报警时间 依赖query_time_range_ 设置
|
||
this->query_time_range_.set_left(this->query_time_range_.get_right() -
|
||
this->delay_time_);
|
||
std::stringstream ss1;
|
||
std::stringstream ss2;
|
||
ss1 << fixed << setprecision(2) << this->value_;
|
||
ss2 << fixed << setprecision(2) << this->error_up_;
|
||
string msg = this->rule_name_ + " " + this->error_str_ + ":" + ss1.str() +
|
||
"大于" + ss2.str();
|
||
this->logger_->Debug() << msg << std::endl;
|
||
return utility::build_alarm_info(MsgLevel::ERROR, rule_id_, rule_name_,
|
||
"MeterBound", msg, query_time_range_);
|
||
} else if (this->value_ < this->error_down_) {
|
||
//报警时间 依赖query_time_range_ 设置
|
||
this->query_time_range_.set_left(this->query_time_range_.get_right() -
|
||
this->delay_time_);
|
||
std::stringstream ss1;
|
||
std::stringstream ss2;
|
||
ss1 << fixed << setprecision(2) << this->value_;
|
||
ss2 << fixed << setprecision(2) << this->error_down_;
|
||
string msg = this->rule_name_ + " " + this->error_str_ + ":" + ss1.str() +
|
||
"小于" + ss2.str();
|
||
this->logger_->Debug() << msg << std::endl;
|
||
return utility::build_alarm_info(MsgLevel::ERROR, rule_id_, rule_name_,
|
||
"MeterBound", msg, query_time_range_);
|
||
}
|
||
return AlarmInfo{};
|
||
}
|
||
|
||
mix_cc::json MeterBound::exec_cron() {}
|
||
|
||
AlarmInfo MeterBound::cron_proc() {}
|
||
|
||
void MeterBound::reset_dev_data() {
|
||
auto reSult = m_memclient.Insert(this->Jkey_.c_str(), this->Jvalue_.c_str());
|
||
auto reSult2 = m_memclient.Insert(string(this->Jkey_ + "_id").c_str(),
|
||
this->rule_id_.c_str());
|
||
if (1 != reSult || 1 != reSult2) {
|
||
this->logger_->Debug() << "m_memclient.Insert异常[0,set data "
|
||
"fail;-1,key=null or value=null]： Insert1:"
|
||
<< reSult << " Insert2:" << reSult2 << endl;
|
||
}
|
||
} |