#include <list>
#include <string>
#include <fstream>
-#include <valarray>
#include <limits>
#include <time.h>
return ret_val;
}
-void W1Store::store(string device_id,
- list<string> *string_list) {
- string f_path;
- string line;
- ofstream *ostream;
- Date *date;
-
- date = new Date();
- f_path = get_file_name(device_id, date);
- ostream = W1Util::open_for_writing(f_path.c_str());
+void W1Store::save(string device_id,
+ std::list<Data *> *data_list,
+ int dec_precision) {
+ string n_path;
+ string f_path;
+ string line;
+ Data *data;
+ ofstream *ostream;
+ Date date;
+ list<Data *>::iterator iter;
+
+ ostream = NULL;
+ f_path = "";
+ log_info("[%s] writing %d data values to save.\n", device_id.c_str(), data_list->size());
// TODO: add mutex to protect string_list while it's read and emptied
- if (ostream != NULL) {
- if (ostream->is_open()) {
- log_info("[%s] writing %d data values to file: %s\n", device_id.c_str(), string_list->size(), f_path.c_str());
- while(string_list->size() > 0) {
- line = string_list->front();
- string_list->pop_front();
- if (line.length() > 0) {
- log_debug("storing line: %s\n", line.c_str());
- *ostream << line << endl;
- }
+ for(iter = data_list->begin(); iter != data_list->end(); iter++) {
+ data = (Data *)*iter;
+ date = data->get_date();
+ n_path = get_file_name(device_id, &date);
+ if (n_path.compare(f_path) != 0) {
+ if (ostream != NULL) {
+ ostream->close();
+ delete(ostream);
+ }
+ f_path = n_path;
+ log_info("[%s] Opening file for save: %s\n", device_id.c_str(), f_path.c_str());
+ ostream = W1Util::open_for_writing(f_path.c_str());
+ }
+ if ((ostream != NULL) &&
+ (ostream->is_open() == true)) {
+ line = data->to_string(dec_precision);
+ if (line.length() > 0) {
+ log_debug("storing line: %s\n", line.c_str());
+ *ostream << line << endl;
}
- ostream->close();
}
else {
- log_error("[%s] Could not store data to file: %s\n", device_id.c_str(), f_path.c_str());
+ log_error("[%s] File open for data save failed: %s\n", device_id.c_str(), f_path.c_str());
}
- delete(ostream);
}
- else {
- log_error("[%s] Could not store data to file: %s\n", device_id.c_str(), f_path.c_str());
+ if (ostream != NULL) {
+ ostream->close();
+ delete(ostream);
}
- delete(date);
}
bool W1Store::load() {
Data *data;
ifstream in;
- string line;
+ string data_str;
bool ret_val;
ret_val = false;
delete(store_data);
store_data = NULL;
}
+ log_debug("opening file: %s\n", store_file_name.c_str());
in.open(store_file_name.c_str());
if (in.is_open() == true) {
while (in.eof() == false) {
- getline(in, line);
- data = Data::parse_data_string(line);
- if (store_data == NULL) {
- store_data = new DataRange(*data);
- }
- else {
- store_data->add_data(*data);
+ getline(in, data_str);
+ if (data_str.empty() == false) {
+ data = Data::parse_string(data_str);
+ if (data != NULL) {
+ if (store_data == NULL) {
+ store_data = new DataRange(data);
+ }
+ else {
+ store_data->add_data(data);
+ }
+ delete(data);
+ }
}
- delete(data);
}
ret_val = true;
}
int jj;
Data *data;
Data *ret_val;
+ Date date;
ret_val = NULL;
data = NULL;
//log_debug("new val: %f, sum: %f\n", new_val, sum);
}
}
- ret_val->set_date(data->get_date());
+ date = data->get_date();
+ ret_val->set_date(&date);
if (data != NULL) {
delete(data);
}
Data *ret_val;
int ii;
DataRange *dr;
+ Date date;
ret_val = NULL;
dr = get_oldest_and_newest_data();
ret_val = new Data(col_count);
if (col_count > 0) {
for (ii = 0; ii < col_count; ii++) {
+ log_debug("old_data[%d]: %f new data: %f\n", ii, o_data->value_arr[ii], n_data->value_arr[ii]);
ret_val->value_arr[ii] = n_data->value_arr[ii] - o_data->value_arr[ii];
}
}
- ret_val->set_date(n_data->get_date());
+ date = n_data->get_date();
+ ret_val->set_date(&date);
delete(o_data);
delete(n_data);
}
Data *data;
Data *ret_val;
double min_val;
+ Date date;
ret_val = NULL;
data = NULL;
col_count = store_data->get_data_column_count();
log_debug("data item count per row: %d\n", col_count);
min_val = numeric_limits<double>::min();
- ret_val = new Data(col_count, min_val);
+ data = store_data->get_data(0);
+ ret_val = new Data(col_count,
+ min_val,
+ data->get_unit());
if (col_count > 0) {
for (ii = 0; ii < row_count - 1; ii++) {
data = store_data->get_data(ii);
}
}
}
- ret_val->set_date(data->get_date());
+ date = data->get_date();
+ ret_val->set_date(&date);
if (data != NULL) {
delete(data);
}
Data *data;
Data *ret_val;
double max_val;
+ Date date;
ret_val = NULL;
data = NULL;
col_count = store_data->get_data_column_count();
log_debug("data item count per row: %d\n", col_count);
max_val = numeric_limits<double>::max();
- ret_val = new Data(col_count, max_val);
+ data = store_data->get_data(0);
+ ret_val = new Data(col_count,
+ max_val,
+ data->get_unit());
if (col_count > 0) {
for (ii = 0; ii < row_count - 1; ii++) {
data = store_data->get_data(ii);
}
}
}
- ret_val->set_date(data->get_date());
+ date = data->get_date();
+ ret_val->set_date(&date);
if (data != NULL) {
delete(data);
}
return ret_val;
}
-vector<Data *> W1Store::get_mean(int freq_sec) {
+vector<Data *> *W1Store::get_sum(int freq_sec) {
+ int row_count;
+ int col_count;
+ int jj;
+ int ii;
+ Data *data;
+ Data *calc;
+ Date *limit_d;
+ Date date;
+ vector<Data *> *ret_val;
+
+ ret_val = new vector<Data *>();
+ calc = NULL;
+ limit_d = NULL;
+ if (store_data == NULL) {
+ load();
+ }
+ if (store_data != NULL) {
+ row_count = store_data->get_data_row_count();
+ if (row_count > 0) {
+ col_count = store_data->get_data_column_count();
+ if (col_count > 0) {
+ for (ii = 0; ii < row_count; ii++) {
+ data = store_data->get_data(ii);
+ if (data != NULL) {
+ if (calc == NULL) {
+ calc = data->clone();
+ limit_d = data->get_date().clone();
+ limit_d->min = 0;
+ limit_d->sec = 0;
+ limit_d->inc_seconds(freq_sec);
+ }
+ else {
+ date = data->get_date();
+ if (date.before(*limit_d)) {
+ for (jj = 0; jj < col_count; jj++) {
+ calc->value_arr[jj] = calc->value_arr[jj] + data->value_arr[jj];
+ }
+ }
+ else {
+ ret_val->push_back(calc);
+ calc = data->clone();
+ if (limit_d != NULL) {
+ delete(limit_d);
+ }
+ limit_d = data->get_date().clone();
+ limit_d->min = 0;
+ limit_d->sec = 0;
+ limit_d->inc_seconds(freq_sec);
+ }
+ }
+ delete(data);
+ }
+ }
+ if (calc != NULL) {
+ delete(calc);
+ calc = NULL;
+ }
+ if (limit_d != NULL) {
+ delete(limit_d);
+ }
+ }
+ }
+ }
+ return ret_val;
+}
+
+vector<Data *> *W1Store::get_mean(int freq_sec) {
int row_count;
int col_count;
int d_count;
Data *calc;
Date *limit_d;
Date date;
- vector<Data *> ret_val;
+ vector<Data *> *ret_val;
+ ret_val = new vector<Data *>();
calc = NULL;
limit_d = NULL;
d_count = 1;
for (jj = 0; jj < col_count; jj++) {
calc->value_arr[jj] = calc->value_arr[jj] / d_count;
}
- ret_val.push_back(calc);
+ ret_val->push_back(calc);
d_count = 1;
calc = data->clone();
if (limit_d != NULL) {
return ret_val;
}
-vector<Data *> W1Store::get_delta(int freq_sec) {
+vector<Data *> *W1Store::get_delta(int freq_sec) {
int row_count;
int col_count;
int jj;
Data *calc2;
Date *limit_d;
Date date;
- vector<Data *> ret_val;
+ vector<Data *> *ret_val;
+ ret_val = new vector<Data *>();
calc1 = NULL;
calc2 = NULL;
limit_d = NULL;
for (jj = 0; jj < col_count; jj++) {
calc2->value_arr[jj] = calc2->value_arr[jj] - calc1->value_arr[jj];
}
- ret_val.push_back(calc2);
+ ret_val->push_back(calc2);
delete(calc1);
calc1 = data->clone();
calc2 = NULL; // do not delete calc2 as it's stored to array
return ret_val;
}
+vector<Data *> *W1Store::get_max_or_min(int freq_sec, bool max) {
+ int row_count;
+ int col_count;
+ int jj;
+ int ii;
+ Data *data;
+ Data *calc;
+ Date *limit_d;
+ Date date;
+ vector<Data *> *ret_val;
+
+ ret_val = new vector<Data *>();
+ calc = NULL;
+ limit_d = NULL;
+ if (store_data == NULL) {
+ load();
+ }
+ if (store_data != NULL) {
+ row_count = store_data->get_data_row_count();
+ if (row_count > 0) {
+ col_count = store_data->get_data_column_count();
+ if (col_count > 0) {
+ for (ii = 0; ii < row_count; ii++) {
+ data = store_data->get_data(ii);
+ if (data != NULL) {
+ if (calc == NULL) {
+ calc = data->clone();
+ limit_d = data->get_date().clone();
+ limit_d->min = 0;
+ limit_d->sec = 0;
+ limit_d->inc_seconds(freq_sec);
+ }
+ else {
+ date = data->get_date();
+ if (date.before(*limit_d)) {
+ if (max == true) {
+ for (jj = 0; jj < col_count; jj++) {
+ if (calc->value_arr[jj] < data->value_arr[jj]) {
+ calc->value_arr[jj] = data->value_arr[jj];
+ }
+ }
+ }
+ else {
+ for (jj = 0; jj < col_count; jj++) {
+ if (data->value_arr[jj] < calc->value_arr[jj]) {
+ calc->value_arr[jj] = data->value_arr[jj];
+ }
+ }
+ }
+ }
+ else {
+ ret_val->push_back(calc);
+ calc = data->clone();
+ if (limit_d != NULL) {
+ delete(limit_d);
+ }
+ limit_d = data->get_date().clone();
+ limit_d->min = 0;
+ limit_d->sec = 0;
+ limit_d->inc_seconds(freq_sec);
+ }
+ }
+ delete(data);
+ }
+ }
+ if (calc != NULL) {
+ delete(calc);
+ calc = NULL;
+ }
+ if (limit_d != NULL) {
+ delete(limit_d);
+ }
+ }
+ }
+ }
+ return ret_val;
+}
+
+vector<Data *> *W1Store::get_max(int freq_sec) {
+ vector<Data *> *ret_val;
+
+ ret_val = get_max_or_min(freq_sec, true);
+ return ret_val;
+}
+
+vector<Data *> *W1Store::get_min(int freq_sec) {
+ vector<Data *> *ret_val;
+
+ ret_val = get_max_or_min(freq_sec, false);
+ return ret_val;
+}
+
DataRange *W1Store::get_oldest_and_newest_data() {
DataRange *ret_val;
ifstream in;
getline(in, line);
if (line.empty() == false) {
if (o_data == NULL) {
- o_data = Data::parse_data_string(line);
+ o_data = Data::parse_string(line);
}
prev_line = line;
}
}
if (prev_line.empty() == false) {
- n_data = Data::parse_data_string(prev_line);
+ n_data = Data::parse_string(prev_line);
}
}
}
if ((o_data != NULL) &&
(n_data != NULL)) {
- ret_val = new DataRange(*o_data);
- ret_val->add_data(*n_data);
+ ret_val = new DataRange(o_data);
+ ret_val->add_data(n_data);
if (range_data != NULL) {
- range_data = new DataRange(*o_data);
- range_data->add_data(*n_data);
+ range_data = new DataRange(o_data);
+ range_data->add_data(n_data);
}
}
if (o_data != NULL) {