projects/stargazer/plugins/store/postgresql/postgresql_store_tariffs.cpp

   1 /*
   2  *    This program is free software; you can redistribute it and/or modify
   3  *    it under the terms of the GNU General Public License as published by
   4  *    the Free Software Foundation; either version 2 of the License, or
   5  *    (at your option) any later version.
   6  *
   7  *    This program is distributed in the hope that it will be useful,
   8  *    but WITHOUT ANY WARRANTY; without even the implied warranty of
   9  *    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  10  *    GNU General Public License for more details.
  11  *
  12  *    You should have received a copy of the GNU General Public License
  13  *    along with this program; if not, write to the Free Software
  14  *    Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
  15  */
  16
  17 /*
  18  *    Author : Maxim Mamontov <faust@stargazer.dp.ua>
  19  */
  20
  21 /*
  22  *  Tariffs manipulation methods
  23  *
  24  *  $Revision: 1.2 $
  25  *  $Date: 2009/06/09 12:32:40 $
  26  *
  27  */
  28
  29 #include <string>
  30 #include <vector>
  31 #include <sstream>
  32 #include <cmath>
  33
  34 #include <libpq-fe.h>
  35
  36 #include "postgresql_store.h"
  37 #include "stg/locker.h"
  38
  39 namespace
  40 {
  41
  42 const int pt_mega = 1024 * 1024;
  43
  44 }
  45
  46 //-----------------------------------------------------------------------------
  47 int POSTGRESQL_STORE::GetTariffsList(std::vector<std::string> * tariffsList) const
  48 {
  49 STG_LOCKER lock(&mutex);
  50
  51 if (PQstatus(connection) != CONNECTION_OK)
  52     {
  53     printfd(__FILE__, "POSTGRESQL_STORE::GetTariffsList(): 'Connection lost. Trying to reconnect...'\n", strError.c_str());
  54     if (Reset())
  55         {
  56         strError = "Connection lost";
  57         printfd(__FILE__, "POSTGRESQL_STORE::GetTariffsList(): '%s'\n", strError.c_str());
  58         return -1;
  59         }
  60     }
  61
  62 PGresult * result;
  63
  64 if (StartTransaction())
  65     {
  66     printfd(__FILE__, "POSTGRESQL_STORE::GetTariffsList(): 'Failed to start transaction'\n");
  67     return -1;
  68     }
  69
  70 result = PQexec(connection, "SELECT name FROM tb_tariffs");
  71
  72 if (PQresultStatus(result) != PGRES_TUPLES_OK)
  73     {
  74     strError = PQresultErrorMessage(result);
  75     PQclear(result);
  76     printfd(__FILE__, "POSTGRESQL_STORE::GetTariffsList(): '%s'\n", strError.c_str());
  77     if (RollbackTransaction())
  78         {
  79         printfd(__FILE__, "POSTGRESQL_STORE::GetTariffsList(): 'Failed to rollback transaction'\n");
  80         }
  81     return -1;
  82     }
  83
  84 int tuples = PQntuples(result);
  85
  86 for (int i = 0; i < tuples; ++i)
  87     {
  88     tariffsList->push_back(PQgetvalue(result, i, 0));
  89     }
  90
  91 PQclear(result);
  92
  93 if (CommitTransaction())
  94     {
  95     printfd(__FILE__, "POSTGRESQL_STORE::GetTariffsList(): 'Failed to commit transaction'\n");
  96     return -1;
  97     }
  98
  99 return 0;
 100 }
 101
 102 //-----------------------------------------------------------------------------
 103 int POSTGRESQL_STORE::AddTariff(const std::string & name) const
 104 {
 105 STG_LOCKER lock(&mutex);
 106
 107 if (PQstatus(connection) != CONNECTION_OK)
 108     {
 109     printfd(__FILE__, "POSTGRESQL_STORE::AddTariff(): 'Connection lost. Trying to reconnect...'\n", strError.c_str());
 110     if (Reset())
 111         {
 112         strError = "Connection lost";
 113         printfd(__FILE__, "POSTGRESQL_STORE::AddTariff(): '%s'\n", strError.c_str());
 114         return -1;
 115         }
 116     }
 117
 118 PGresult * result;
 119
 120 if (StartTransaction())
 121     {
 122     printfd(__FILE__, "POSTGRESQL_STORE::AddTariff(): 'Failed to start transaction'\n");
 123     return -1;
 124     }
 125
 126 std::string ename = name;
 127
 128 if (EscapeString(ename))
 129     {
 130     printfd(__FILE__, "POSTGRESQL_STORE::AddTariff(): 'Failed to escape name'\n");
 131     if (RollbackTransaction())
 132         {
 133         printfd(__FILE__, "POSTGRESQL_STORE::AddTariff(): 'Failed to rollback transaction'\n");
 134         }
 135     return -1;
 136     }
 137
 138 std::ostringstream query;
 139 query << "SELECT sp_add_tariff('" << ename << "', " << DIR_NUM << ")";
 140
 141 result = PQexec(connection, query.str().c_str());
 142
 143 if (PQresultStatus(result) != PGRES_TUPLES_OK)
 144     {
 145     strError = PQresultErrorMessage(result);
 146     PQclear(result);
 147     printfd(__FILE__, "POSTGRESQL_STORE::AddTariff(): '%s'\n", strError.c_str());
 148     if (RollbackTransaction())
 149         {
 150         printfd(__FILE__, "POSTGRESQL_STORE::AddTariff(): 'Failed to rollback transaction'\n");
 151         }
 152     return -1;
 153     }
 154
 155 PQclear(result);
 156
 157 if (CommitTransaction())
 158     {
 159     printfd(__FILE__, "POSTGRESQL_STORE::AddTariff(): 'Failed to commit transaction'\n");
 160     return -1;
 161     }
 162
 163 return 0;
 164 }
 165 //-----------------------------------------------------------------------------
 166 int POSTGRESQL_STORE::DelTariff(const std::string & name) const
 167 {
 168 STG_LOCKER lock(&mutex);
 169
 170 if (PQstatus(connection) != CONNECTION_OK)
 171     {
 172     printfd(__FILE__, "POSTGRESQL_STORE::DelTariff(): 'Connection lost. Trying to reconnect...'\n", strError.c_str());
 173     if (Reset())
 174         {
 175         strError = "Connection lost";
 176         printfd(__FILE__, "POSTGRESQL_STORE::DelTariff(): '%s'\n", strError.c_str());
 177         return -1;
 178         }
 179     }
 180
 181 PGresult * result;
 182
 183 if (StartTransaction())
 184     {
 185     printfd(__FILE__, "POSTGRESQL_STORE::DelTariff(): 'Failed to start transaction'\n");
 186     return -1;
 187     }
 188
 189 std::string ename = name;
 190
 191 if (EscapeString(ename))
 192     {
 193     printfd(__FILE__, "POSTGRESQL_STORE::AddTariff(): 'Failed to escape name'\n");
 194     if (RollbackTransaction())
 195         {
 196         printfd(__FILE__, "POSTGRESQL_STORE::AddTariff(): 'Failed to rollback transaction'\n");
 197         }
 198     return -1;
 199     }
 200
 201 std::ostringstream query;
 202 query << "DELETE FROM tb_tariffs WHERE name = '" << ename << "'";
 203
 204 result = PQexec(connection, query.str().c_str());
 205
 206 if (PQresultStatus(result) != PGRES_COMMAND_OK)
 207     {
 208     strError = PQresultErrorMessage(result);
 209     PQclear(result);
 210     printfd(__FILE__, "POSTGRESQL_STORE::DelTariff(): '%s'\n", strError.c_str());
 211     if (RollbackTransaction())
 212         {
 213         printfd(__FILE__, "POSTGRESQL_STORE::DelTariff(): 'Failed to rollback transaction'\n");
 214         }
 215     return -1;
 216     }
 217
 218 PQclear(result);
 219
 220 if (CommitTransaction())
 221     {
 222     printfd(__FILE__, "POSTGRESQL_STORE::DelTariff(): 'Failed to commit transaction'\n");
 223     return -1;
 224     }
 225
 226 return 0;
 227 }
 228 //-----------------------------------------------------------------------------
 229 int POSTGRESQL_STORE::SaveTariff(const TARIFF_DATA & td,
 230                                  const std::string & tariffName) const
 231 {
 232 STG_LOCKER lock(&mutex);
 233
 234 if (PQstatus(connection) != CONNECTION_OK)
 235     {
 236     printfd(__FILE__, "POSTGRESQL_STORE::SaveTariff(): 'Connection lost. Trying to reconnect...'\n", strError.c_str());
 237     if (Reset())
 238         {
 239         strError = "Connection lost";
 240         printfd(__FILE__, "POSTGRESQL_STORE::SaveTariff(): '%s'\n", strError.c_str());
 241         return -1;
 242         }
 243     }
 244
 245 PGresult * result;
 246
 247 if (StartTransaction())
 248     {
 249     printfd(__FILE__, "POSTGRESQL_STORE::SaveTariff(): 'Failed to start transaction'\n");
 250     return -1;
 251     }
 252
 253 std::string ename = tariffName;
 254
 255 if (EscapeString(ename))
 256     {
 257     printfd(__FILE__, "POSTGRESQL_STORE::SaveTariff(): 'Failed to escape name'\n");
 258     if (RollbackTransaction())
 259         {
 260         printfd(__FILE__, "POSTGRESQL_STORE::SaveTariff(): 'Failed to rollback transaction'\n");
 261         }
 262     return -1;
 263     }
 264
 265     {
 266     std::ostringstream query;
 267     query << "SELECT pk_tariff FROM tb_tariffs WHERE name = '" << ename << "'";
 268
 269     result = PQexec(connection, query.str().c_str());
 270     }
 271
 272 if (PQresultStatus(result) != PGRES_TUPLES_OK)
 273     {
 274     strError = PQresultErrorMessage(result);
 275     PQclear(result);
 276     printfd(__FILE__, "POSTGRESQL_STORE::SaveTariff(): '%s'\n", strError.c_str());
 277     if (RollbackTransaction())
 278         {
 279         printfd(__FILE__, "POSTGRESQL_STORE::SaveTariff(): 'Failed to rollback transaction'\n");
 280         }
 281     return -1;
 282     }
 283
 284 int tuples = PQntuples(result);
 285
 286 if (tuples != 1)
 287     {
 288     strError = "Failed to fetch tariff ID";
 289     printfd(__FILE__, "POSTGRESQL_STORE::SaveTariff(): 'Invalid number of tuples. Wanted 1, actulally %d'\n", tuples);
 290     PQclear(result);
 291     if (RollbackTransaction())
 292         {
 293         printfd(__FILE__, "POSTGRESQL_STORE::SaveTariff(): 'Failed to rollback transaction'\n");
 294         }
 295     return -1;
 296     }
 297
 298 int32_t id;
 299
 300     {
 301     std::stringstream tuple;
 302     tuple << PQgetvalue(result, 0, 0);
 303
 304     PQclear(result);
 305
 306     tuple >> id;
 307     }
 308
 309     {
 310     std::ostringstream query;
 311     query << "UPDATE tb_tariffs SET \
 312                   fee = " << td.tariffConf.fee << ", \
 313                   free = " << td.tariffConf.free << ", \
 314                   passive_cost = " << td.tariffConf.passiveCost << ", \
 315                   traff_type = " << td.tariffConf.traffType;
 316
 317     if (version > 6)
 318         query << ", period = '" << TARIFF::PeriodToString(td.tariffConf.period) << "'";
 319
 320     if (version > 7)
 321         query << ", change_policy = '" << TARIFF::ChangePolicyToString(td.tariffConf.changePolicy) << "', \
 322                   change_policy_timeout = CAST('" << Int2TS(td.tariffConf.changePolicyTimeout) << "' AS TIMESTAMP)";
 323
 324     query << " WHERE pk_tariff = " << id;
 325
 326     result = PQexec(connection, query.str().c_str());
 327     }
 328
 329 if (PQresultStatus(result) != PGRES_COMMAND_OK)
 330     {
 331     strError = PQresultErrorMessage(result);
 332     PQclear(result);
 333     printfd(__FILE__, "POSTGRESQL_STORE::SaveTariff(): '%s'\n", strError.c_str());
 334     if (RollbackTransaction())
 335         {
 336         printfd(__FILE__, "POSTGRESQL_STORE::SaveTariff(): 'Failed to rollback transaction'\n");
 337         }
 338     return -1;
 339     }
 340
 341 PQclear(result);
 342
 343 for(int i = 0; i < DIR_NUM; i++)
 344     {
 345     double pda = td.dirPrice[i].priceDayA * 1024 * 1024;
 346     double pdb = td.dirPrice[i].priceDayB * 1024 * 1024;
 347     double pna = 0;
 348     double pnb = 0;
 349
 350     if (td.dirPrice[i].singlePrice)
 351         {
 352         pna = pda;
 353         pnb = pdb;
 354         }
 355     else
 356         {
 357         pna = td.dirPrice[i].priceNightA * 1024 * 1024;
 358         pnb = td.dirPrice[i].priceNightB * 1024 * 1024;
 359         }
 360
 361     int threshold = 0;
 362     if (td.dirPrice[i].noDiscount)
 363         {
 364         threshold = 0xffFFffFF;
 365         }
 366     else
 367         {
 368         threshold = td.dirPrice[i].threshold;
 369         }
 370
 371         {
 372         std::ostringstream query;
 373         query << "UPDATE tb_tariffs_params SET \
 374                       price_day_a = " << pda << ", \
 375                       price_day_b = " << pdb << ", \
 376                       price_night_a = " << pna << ", \
 377                       price_night_b = " << pnb << ", \
 378                       threshold = " << threshold << ", \
 379                       time_day_begins = CAST('" << td.dirPrice[i].hDay
 380                                                 << ":"
 381                                                 << td.dirPrice[i].mDay << "' AS TIME), \
 382                       time_day_ends = CAST('" << td.dirPrice[i].hNight
 383                                               << ":"
 384                                               << td.dirPrice[i].mNight << "' AS TIME) \
 385                  WHERE fk_tariff = " << id << " AND dir_num = " << i;
 386
 387         result = PQexec(connection, query.str().c_str());
 388         }
 389
 390     if (PQresultStatus(result) != PGRES_COMMAND_OK)
 391         {
 392         strError = PQresultErrorMessage(result);
 393         PQclear(result);
 394         printfd(__FILE__, "POSTGRESQL_STORE::SaveTariff(): '%s'\n", strError.c_str());
 395         if (RollbackTransaction())
 396             {
 397             printfd(__FILE__, "POSTGRESQL_STORE::SaveTariff(): 'Failed to rollback transaction'\n");
 398             }
 399         return -1;
 400         }
 401
 402     PQclear(result);
 403     }
 404
 405 if (CommitTransaction())
 406     {
 407     printfd(__FILE__, "POSTGRESQL_STORE::SaveTariff(): 'Failed to commit transaction'\n");
 408     return -1;
 409     }
 410
 411 return 0;
 412 }
 413 //-----------------------------------------------------------------------------
 414 int POSTGRESQL_STORE::RestoreTariff(TARIFF_DATA * td,
 415                                   const std::string & tariffName) const
 416 {
 417 STG_LOCKER lock(&mutex);
 418
 419 if (PQstatus(connection) != CONNECTION_OK)
 420     {
 421     printfd(__FILE__, "POSTGRESQL_STORE::RestoreTariff(): 'Connection lost. Trying to reconnect...'\n", strError.c_str());
 422     if (Reset())
 423         {
 424         strError = "Connection lost";
 425         printfd(__FILE__, "POSTGRESQL_STORE::RestoreTariff(): '%s'\n", strError.c_str());
 426         return -1;
 427         }
 428     }
 429
 430 PGresult * result;
 431
 432 if (StartTransaction())
 433     {
 434     printfd(__FILE__, "POSTGRESQL_STORE::RestoreTariff(): 'Failed to start transaction'\n");
 435     return -1;
 436     }
 437
 438 std::string ename = tariffName;
 439
 440 if (EscapeString(ename))
 441     {
 442     printfd(__FILE__, "POSTGRESQL_STORE::RestoreTariff(): 'Failed to escape name'\n");
 443     if (RollbackTransaction())
 444         {
 445         printfd(__FILE__, "POSTGRESQL_STORE::RestoreTariff(): 'Failed to rollback transaction'\n");
 446         }
 447     return -1;
 448     }
 449
 450 td->tariffConf.name = tariffName;
 451
 452 std::ostringstream query;
 453 query << "SELECT pk_tariff, \
 454                  fee, \
 455                  free, \
 456                  passive_cost, \
 457                  traff_type";
 458
 459 if (version > 6)
 460     query << ", period";
 461
 462 if (version > 7)
 463     query << ", change_policy";
 464
 465 query << " FROM tb_tariffs WHERE name = '" << ename << "'";
 466
 467 result = PQexec(connection, query.str().c_str());
 468
 469 if (PQresultStatus(result) != PGRES_TUPLES_OK)
 470     {
 471     strError = PQresultErrorMessage(result);
 472     PQclear(result);
 473     printfd(__FILE__, "POSTGRESQL_STORE::RestoreTariff(): '%s'\n", strError.c_str());
 474     if (RollbackTransaction())
 475         {
 476         printfd(__FILE__, "POSTGRESQL_STORE::RestoreTariff(): 'Failed to rollback transaction'\n");
 477         }
 478     return -1;
 479     }
 480
 481 int tuples = PQntuples(result);
 482
 483 if (tuples != 1)
 484     {
 485     strError = "Failed to fetch tariff data";
 486     printfd(__FILE__, "POSTGRESQL_STORE::RestoreTariff(): 'Invalid number of tuples. Wanted 1, actulally %d'\n", tuples);
 487     PQclear(result);
 488     if (RollbackTransaction())
 489         {
 490         printfd(__FILE__, "POSTGRESQL_STORE::RestoreTariff(): 'Failed to rollback transaction'\n");
 491         }
 492     return -1;
 493     }
 494
 495 int id;
 496
 497     {
 498     std::stringstream tuple;
 499     tuple << PQgetvalue(result, 0, 0) << " ";
 500     tuple << PQgetvalue(result, 0, 1) << " ";
 501     tuple << PQgetvalue(result, 0, 2) << " ";
 502     tuple << PQgetvalue(result, 0, 3) << " ";
 503     tuple << PQgetvalue(result, 0, 4) << " ";
 504
 505     tuple >> id;
 506     tuple >> td->tariffConf.fee;
 507     tuple >> td->tariffConf.free;
 508     tuple >> td->tariffConf.passiveCost;
 509     tuple >> td->tariffConf.traffType;
 510     }
 511
 512 if (version > 6)
 513     td->tariffConf.period = TARIFF::StringToPeriod(PQgetvalue(result, 0, 5));
 514
 515 if (version > 7)
 516     td->tariffConf.changePolicy = TARIFF::StringToChangePolicy(PQgetvalue(result, 0, 6));
 517
 518 PQclear(result);
 519
 520 query.str("");
 521 query << "SELECT dir_num, \
 522                  price_day_a, \
 523                  price_day_b, \
 524                  price_night_a, \
 525                  price_night_b, \
 526                  threshold, \
 527                  EXTRACT(hour FROM time_day_begins), \
 528                  EXTRACT(minute FROM time_day_begins), \
 529                  EXTRACT(hour FROM time_day_ends), \
 530                  EXTRACT(minute FROM time_day_ends) \
 531           FROM tb_tariffs_params \
 532           WHERE fk_tariff = " << id;
 533
 534 result = PQexec(connection, query.str().c_str());
 535
 536 if (PQresultStatus(result) != PGRES_TUPLES_OK)
 537     {
 538     strError = PQresultErrorMessage(result);
 539     PQclear(result);
 540     printfd(__FILE__, "POSTGRESQL_STORE::RestoreTariff(): '%s'\n", strError.c_str());
 541     if (RollbackTransaction())
 542         {
 543         printfd(__FILE__, "POSTGRESQL_STORE::RestoreTariff(): 'Failed to rollback transaction'\n");
 544         }
 545     return -1;
 546     }
 547
 548 tuples = PQntuples(result);
 549
 550 if (tuples != DIR_NUM)
 551     {
 552     printfd(__FILE__, "POSTGRESQL_STORE::RestoreTariff(): 'Tariff params count and DIR_NUM does not feet (wanted %d, actually %d)'\n", DIR_NUM, tuples);
 553     }
 554
 555 for (int i = 0; i < std::min(tuples, DIR_NUM); ++i)
 556     {
 557     int dir;
 558
 559         {
 560         std::stringstream tuple;
 561         tuple << PQgetvalue(result, i, 0) << " ";
 562         tuple << PQgetvalue(result, i, 1) << " ";
 563         tuple << PQgetvalue(result, i, 2) << " ";
 564         tuple << PQgetvalue(result, i, 3) << " ";
 565         tuple << PQgetvalue(result, i, 4) << " ";
 566         tuple << PQgetvalue(result, i, 5) << " ";
 567         tuple << PQgetvalue(result, i, 6) << " ";
 568         tuple << PQgetvalue(result, i, 7) << " ";
 569         tuple << PQgetvalue(result, i, 8) << " ";
 570         tuple << PQgetvalue(result, i, 9) << " ";
 571
 572         tuple >> dir;
 573         tuple >> td->dirPrice[dir].priceDayA;
 574         td->dirPrice[dir].priceDayA /= 1024 * 1024;
 575         tuple >> td->dirPrice[dir].priceDayB;
 576         td->dirPrice[dir].priceDayB /= 1024 * 1024;
 577         tuple >> td->dirPrice[dir].priceNightA;
 578         td->dirPrice[dir].priceNightA /= 1024 * 1024;
 579         tuple >> td->dirPrice[dir].priceNightB;
 580         td->dirPrice[dir].priceNightB /= 1024 * 1024;
 581         tuple >> td->dirPrice[dir].threshold;
 582         tuple >> td->dirPrice[dir].hDay;
 583         tuple >> td->dirPrice[dir].mDay;
 584         tuple >> td->dirPrice[dir].hNight;
 585         tuple >> td->dirPrice[dir].mNight;
 586         }
 587
 588     if (std::fabs(td->dirPrice[dir].priceDayA - td->dirPrice[dir].priceNightA) < 1.0e-3 / pt_mega &&
 589         std::fabs(td->dirPrice[dir].priceDayB - td->dirPrice[dir].priceNightB) < 1.0e-3 / pt_mega)
 590         {
 591         td->dirPrice[dir].singlePrice = true;
 592         }
 593     else
 594         {
 595         td->dirPrice[dir].singlePrice = false;
 596         }
 597     if (td->dirPrice[dir].threshold == (int)0xffFFffFF)
 598         {
 599         td->dirPrice[dir].noDiscount = true;
 600         }
 601     else
 602         {
 603
 604         td->dirPrice[dir].noDiscount = false;
 605         }
 606
 607     }
 608
 609 PQclear(result);
 610
 611 if (CommitTransaction())
 612     {
 613     printfd(__FILE__, "POSTGRESQL_STORE::RestoreTariff(): 'Failed to commit transaction'\n");
 614     return -1;
 615     }
 616
 617 return 0;
 618 }
 619 //-----------------------------------------------------------------------------
 620