#include <string>
#include <fstream>
#include <valarray>
+#include <limits>
#include <time.h>
#include <dirent.h>
Date *date_time) {
store_data = NULL;
range_data = NULL;
- store_file_name = get_store_file_name(device_id, date_time);
+ store_file_name = get_file_name(device_id, date_time);
log_debug("data file name: %s\n", store_file_name.c_str());
}
}
}
-void W1Store::set_store_base_dir(string store_param) {
+void W1Store::set_base_dir_name(string store_param) {
int pos;
int b_count;
}
}
-string W1Store::get_store_base_dir() {
+string W1Store::get_base_dir_name() {
return store_base_dir;
}
-string W1Store::get_store_dir_name(string device_id, Date *date_time) {
+string W1Store::get_dir_name(string device_id, Date *date_time) {
string ret_val;
char buffer[30];
return ret_val;
}
-string W1Store::get_store_file_name(string device_id, Date *date_time) {
+string W1Store::get_file_name(string device_id, Date *date_time) {
string ret_val;
string fname;
char buffer[30];
snprintf(buffer, 30, "%d-%02d-%02d", date_time->year, date_time->month, date_time->day);
fname = buffer;
fname = fname + DATAFILE_SUFFIX;
- ret_val = get_store_dir_name(device_id, date_time);
+ ret_val = get_dir_name(device_id, date_time);
ret_val = W1Util::concat_paths(ret_val, fname);
return ret_val;
}
Date *date;
date = new Date();
- f_path = get_store_file_name(device_id, date);
+ f_path = get_file_name(device_id, date);
ostream = W1Util::open_for_writing(f_path.c_str());
// TODO: add mutex to protect string_list while it's read and emptied
if (ostream != NULL) {
if (in.is_open() == true) {
while (in.eof() == false) {
getline(in, line);
- data = W1Util::parse_data_line(line);
+ data = Data::parse_data_string(line);
if (store_data == NULL) {
store_data = new DataRange(*data);
}
}
}
+Data *W1Store::get_sum() {
+ int row_count;
+ int col_count;
+ double new_val;
+ int ii;
+ int jj;
+ Date *date;
+ Data *data;
+ Data *ret_val;
+
+ ret_val = NULL;
+ data = NULL;
+ if (store_data == NULL) {
+ load();
+ }
+ if (store_data != NULL) {
+ row_count = store_data->get_data_row_count();
+ log_debug("data row count: %d\n", row_count);
+ if (row_count > 0) {
+ col_count = store_data->get_data_column_count();
+ log_debug("data item count per row: %d\n", col_count);
+ ret_val = new Data(col_count);
+ if (col_count > 0) {
+ for (ii = 0; ii < row_count - 1; ii++) {
+ data = store_data->get_data(ii);
+ for (jj = 0; jj < col_count; jj++) {
+ new_val = data->value_arr[jj];
+ ret_val->value_arr[jj] = ret_val->value_arr[jj] + new_val;
+ }
+ if (ii < (row_count - 2)) {
+ delete(data);
+ data = NULL;
+ }
+ //log_debug("new val: %f, sum: %f\n", new_val, sum);
+ }
+ }
+ ret_val->set_date(data->get_date());
+ if (data != NULL) {
+ delete(data);
+ }
+ }
+ }
+ return ret_val;
+}
+
Data *W1Store::get_delta() {
int row_count;
int col_count;
Data *W1Store::get_mean() {
int row_count;
int col_count;
- double avg;
+ int ii;
+ Data *ret_val;
+
+ ret_val = 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();
+ ret_val = get_sum();
+ if (col_count > 0) {
+ for (ii = 0; ii < col_count; ii++) {
+ ret_val->value_arr[ii] = ret_val->value_arr[ii] / row_count;
+ log_debug("avg: %f\n", ret_val->value_arr[ii]);
+ }
+ }
+ }
+ }
+ return ret_val;
+}
+
+Data *W1Store::get_max() {
+ int row_count;
+ int col_count;
double new_val;
int ii;
int jj;
Date *date;
Data *data;
Data *ret_val;
+ double min_val;
ret_val = NULL;
data = NULL;
if (row_count > 0) {
col_count = store_data->get_data_column_count();
log_debug("data item count per row: %d\n", col_count);
- ret_val = new Data(col_count);
+ min_val = numeric_limits<double>::min();
+ ret_val = new Data(col_count, min_val);
if (col_count > 0) {
for (ii = 0; ii < row_count - 1; ii++) {
data = store_data->get_data(ii);
for (jj = 0; jj < col_count; jj++) {
- new_val = data->value_arr[jj];
- ret_val->value_arr[jj] = ret_val->value_arr[jj] + new_val;
+ new_val = data->value_arr[jj];
+ if (new_val > ret_val->value_arr[jj]) {
+ ret_val->value_arr[jj] = new_val;
+ }
}
if (ii < (row_count - 2)) {
delete(data);
data = NULL;
}
- //log_debug("new val: %f, sum: %f\n", new_val, sum);
}
- for (ii = 0; ii < col_count; ii++) {
- ret_val->value_arr[ii] = ret_val->value_arr[ii] / row_count;
- log_debug("avg: %f\n", ret_val->value_arr[ii]);
+ }
+ ret_val->set_date(data->get_date());
+ if (data != NULL) {
+ delete(data);
+ }
+ }
+ }
+ return ret_val;
+}
+
+Data *W1Store::get_min() {
+ int row_count;
+ int col_count;
+ double new_val;
+ int ii;
+ int jj;
+ Date *date;
+ Data *data;
+ Data *ret_val;
+ double max_val;
+
+ ret_val = NULL;
+ data = NULL;
+ if (store_data == NULL) {
+ load();
+ }
+ if (store_data != NULL) {
+ row_count = store_data->get_data_row_count();
+ log_debug("data row count: %d\n", row_count);
+ if (row_count > 0) {
+ 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);
+ if (col_count > 0) {
+ for (ii = 0; ii < row_count - 1; ii++) {
+ data = store_data->get_data(ii);
+ for (jj = 0; jj < col_count; jj++) {
+ new_val = data->value_arr[jj];
+ if (new_val < ret_val->value_arr[jj]) {
+ ret_val->value_arr[jj] = new_val;
+ }
+ }
+ if (ii < (row_count - 2)) {
+ delete(data);
+ data = NULL;
+ }
}
}
ret_val->set_date(data->get_date());
getline(in, line);
if (line.empty() == false) {
if (o_data == NULL) {
- o_data = W1Util::parse_data_line(line);
+ o_data = Data::parse_data_string(line);
}
prev_line = line;
}
}
if (prev_line.empty() == false) {
- n_data = W1Util::parse_data_line(prev_line);
+ n_data = Data::parse_data_string(prev_line);
}
}
}