4 * Created on: Oct 31, 2010
16 #include <sys/types.h>
22 #include "W1Configure.hh"
30 W1Store::W1Store(string device_id,
34 store_file_name = get_file_name(device_id, date_time);
35 log_debug("data file name: %s\n", store_file_name.c_str());
38 W1Store::W1Store(string file_name_param) {
41 store_file_name = file_name_param;
45 if (store_data != NULL) {
51 string W1Store::get_dir_name(string device_id, Date *date_time) {
56 d_name = DeviceConfig::get_base_dir_name();
57 snprintf(buffer, 30, "%d/%02d", date_time->year, date_time->month);
58 ret_val = W1Util::concat_paths(d_name, device_id);
59 ret_val = ret_val + "/" + buffer;
63 string W1Store::get_file_name(string device_id, Date *date_time) {
68 snprintf(buffer, 30, "%d-%02d-%02d", date_time->year, date_time->month, date_time->day);
70 fname = fname + DATAFILE_SUFFIX;
71 ret_val = get_dir_name(device_id, date_time);
72 ret_val = W1Util::concat_paths(ret_val, fname);
76 void W1Store::store(std::string device_id,
77 std::list<std::string> *string_list) {
84 f_path = get_file_name(device_id, date);
85 ostream = W1Util::open_for_writing(f_path.c_str());
86 // TODO: add mutex to protect string_list while it's read and emptied
87 if (ostream != NULL) {
88 if (ostream->is_open()) {
89 log_info("[%s] writing %d data values to file: %s\n", device_id.c_str(), string_list->size(), f_path.c_str());
90 while(string_list->size() > 0) {
91 line = string_list->front();
92 string_list->pop_front();
93 if (line.length() > 0) {
94 log_debug("storing line: %s\n", line.c_str());
95 *ostream << line << endl;
101 log_error("[%s] Could not store data to file: %s\n", device_id.c_str(), f_path.c_str());
106 log_error("[%s] Could not store data to file: %s\n", device_id.c_str(), f_path.c_str());
111 void W1Store::load() {
116 if (store_data != NULL) {
120 in.open(store_file_name.c_str());
121 if (in.is_open() == true) {
122 while (in.eof() == false) {
124 data = Data::parse_data_string(line);
125 if (store_data == NULL) {
126 store_data = new DataRange(*data);
129 store_data->add_data(*data);
136 Data *W1Store::get_sum() {
147 if (store_data == NULL) {
150 if (store_data != NULL) {
151 row_count = store_data->get_data_row_count();
152 log_debug("data row count: %d\n", row_count);
154 col_count = store_data->get_data_column_count();
155 log_debug("data item count per row: %d\n", col_count);
156 ret_val = new Data(col_count);
158 for (ii = 0; ii < row_count - 1; ii++) {
159 data = store_data->get_data(ii);
160 for (jj = 0; jj < col_count; jj++) {
161 new_val = data->value_arr[jj];
162 ret_val->value_arr[jj] = ret_val->value_arr[jj] + new_val;
164 if (ii < (row_count - 2)) {
168 //log_debug("new val: %f, sum: %f\n", new_val, sum);
171 ret_val->set_date(data->get_date());
180 Data *W1Store::get_delta() {
190 dr = get_oldest_and_newest_data();
192 row_count = dr->get_data_row_count();
193 if (row_count == 2) {
194 o_data = dr->get_data(0);
195 n_data = dr->get_data(1);
196 col_count = dr->get_data_column_count();
197 ret_val = new Data(col_count);
199 for (ii = 0; ii < col_count; ii++) {
200 ret_val->value_arr[ii] = n_data->value_arr[ii] - o_data->value_arr[ii];
203 ret_val->set_date(n_data->get_date());
212 Data *W1Store::get_mean() {
219 if (store_data == NULL) {
222 if (store_data != NULL) {
223 row_count = store_data->get_data_row_count();
225 col_count = store_data->get_data_column_count();
228 for (ii = 0; ii < col_count; ii++) {
229 ret_val->value_arr[ii] = ret_val->value_arr[ii] / row_count;
230 log_debug("avg: %f\n", ret_val->value_arr[ii]);
238 Data *W1Store::get_max() {
250 if (store_data == NULL) {
253 if (store_data != NULL) {
254 row_count = store_data->get_data_row_count();
255 log_debug("data row count: %d\n", row_count);
257 col_count = store_data->get_data_column_count();
258 log_debug("data item count per row: %d\n", col_count);
259 min_val = numeric_limits<double>::min();
260 ret_val = new Data(col_count, min_val);
262 for (ii = 0; ii < row_count - 1; ii++) {
263 data = store_data->get_data(ii);
264 for (jj = 0; jj < col_count; jj++) {
265 new_val = data->value_arr[jj];
266 if (new_val > ret_val->value_arr[jj]) {
267 ret_val->value_arr[jj] = new_val;
270 if (ii < (row_count - 2)) {
276 ret_val->set_date(data->get_date());
285 Data *W1Store::get_min() {
297 if (store_data == NULL) {
300 if (store_data != NULL) {
301 row_count = store_data->get_data_row_count();
302 log_debug("data row count: %d\n", row_count);
304 col_count = store_data->get_data_column_count();
305 log_debug("data item count per row: %d\n", col_count);
306 max_val = numeric_limits<double>::max();
307 ret_val = new Data(col_count, max_val);
309 for (ii = 0; ii < row_count - 1; ii++) {
310 data = store_data->get_data(ii);
311 for (jj = 0; jj < col_count; jj++) {
312 new_val = data->value_arr[jj];
313 if (new_val < ret_val->value_arr[jj]) {
314 ret_val->value_arr[jj] = new_val;
317 if (ii < (row_count - 2)) {
323 ret_val->set_date(data->get_date());
332 DataRange *W1Store::get_oldest_and_newest_data() {
345 if (store_data != NULL) {
346 row_count = store_data->get_data_row_count();
348 o_data = store_data->get_data(0);
349 n_data = store_data->get_data(row_count - 1);
353 if (range_data != NULL) {
354 row_count = range_data->get_data_row_count();
356 o_data = range_data->get_data(0);
357 n_data = range_data->get_data(row_count - 1);
361 in.open(store_file_name.c_str());
362 while (in.eof() == false) {
364 if (line.empty() == false) {
365 if (o_data == NULL) {
366 o_data = Data::parse_data_string(line);
371 if (prev_line.empty() == false) {
372 n_data = Data::parse_data_string(prev_line);
376 if ((o_data != NULL) &&
378 ret_val = new DataRange(*o_data);
379 ret_val->add_data(*n_data);
380 if (range_data != NULL) {
381 range_data = new DataRange(*o_data);
382 range_data->add_data(*n_data);
385 if (o_data != NULL) {
388 if (n_data != NULL) {
394 Data *W1Store::get_oldest_data() {
400 dr = get_oldest_and_newest_data();
402 row_count = dr->get_data_row_count();
403 if (row_count >= 1) {
404 ret_val = dr->get_data(0);
411 Data *W1Store::get_newest_data() {
417 dr = get_oldest_and_newest_data();
419 row_count = dr->get_data_row_count();
420 if (row_count == 2) {
421 ret_val = dr->get_data(1);