]> git.stg.codes - stg.git/blob - projects/stargazer/tariffs_impl.cpp
Added user-related params.
[stg.git] / projects / stargazer / tariffs_impl.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  *    Date: 07.11.2007
19  */
20
21 /*
22  *    Author : Boris Mikhailenko <stg34@stargazer.dp.ua>
23  */
24
25 /*
26  $Revision: 1.9 $
27  $Date: 2010/10/07 18:43:21 $
28  $Author: faust $
29  */
30
31 #include <cassert>
32 #include <algorithm>
33 #include <vector>
34
35 #include "stg/locker.h"
36 #include "stg/logger.h"
37 #include "stg/store.h"
38 #include "stg/admin.h"
39 #include "tariffs_impl.h"
40
41 using namespace std;
42
43 //-----------------------------------------------------------------------------
44 TARIFFS_IMPL::TARIFFS_IMPL(STORE * st)
45     : TARIFFS(),
46       tariffs(),
47       store(st),
48       WriteServLog(GetStgLogger()),
49       mutex(),
50       strError(),
51       noTariff(NO_TARIFF_NAME),
52       onAddNotifiers(),
53       onDelNotifiers()
54 {
55 pthread_mutex_init(&mutex, NULL);
56 ReadTariffs();
57 }
58 //-----------------------------------------------------------------------------
59 TARIFFS_IMPL::~TARIFFS_IMPL()
60 {
61 pthread_mutex_destroy(&mutex);
62 }
63 //-----------------------------------------------------------------------------
64 int TARIFFS_IMPL::ReadTariffs()
65 {
66 STG_LOCKER lock(&mutex, __FILE__, __LINE__);
67
68 vector<string> tariffsList;
69 if (store->GetTariffsList(&tariffsList))
70     {
71     WriteServLog("Cannot get tariffs list.");
72     WriteServLog("%s", store->GetStrError().c_str());
73     }
74
75 Tariffs::size_type tariffsNum = tariffsList.size();
76
77 for (Tariffs::size_type i = 0; i < tariffsNum; i++)
78     {
79     TARIFF_DATA td;
80     if (store->RestoreTariff(&td, tariffsList[i]))
81         {
82         WriteServLog("Cannot read tariff %s.", tariffsList[i].c_str());
83         WriteServLog("%s", store->GetStrError().c_str());
84         return -1;
85         }
86     tariffs.push_back(TARIFF_IMPL(td));
87     }
88
89 return 0;
90 }
91 //-----------------------------------------------------------------------------
92 size_t TARIFFS_IMPL::Count() const
93 {
94 STG_LOCKER lock(&mutex, __FILE__, __LINE__);
95 return tariffs.size();
96 }
97 //-----------------------------------------------------------------------------
98 const TARIFF * TARIFFS_IMPL::FindByName(const string & name) const
99 {
100 if (name == NO_TARIFF_NAME)
101     return &noTariff;
102
103 STG_LOCKER lock(&mutex, __FILE__, __LINE__);
104 list<TARIFF_IMPL>::const_iterator ti;
105 ti = find(tariffs.begin(), tariffs.end(), TARIFF_IMPL(name));
106
107 if (ti != tariffs.end())
108     return &(*ti);
109
110 return NULL;
111 }
112 //-----------------------------------------------------------------------------
113 int TARIFFS_IMPL::Chg(const TARIFF_DATA & td, const ADMIN * admin)
114 {
115 const PRIV * priv = admin->GetPriv();
116
117 if (!priv->tariffChg)
118     {
119     string s = admin->GetLogStr() + " Change tariff \'"
120                + td.tariffConf.name + "\'. Access denied.";
121     strError = "Access denied.";
122     WriteServLog(s.c_str());
123     return -1;
124     }
125
126 STG_LOCKER lock(&mutex, __FILE__, __LINE__);
127
128 list<TARIFF_IMPL>::iterator ti;
129 ti = find(tariffs.begin(), tariffs.end(), TARIFF_IMPL(td.tariffConf.name));
130
131 if (ti == tariffs.end())
132     {
133     strError = "Tariff \'" + td.tariffConf.name + "\' cannot be changed. Tariff does not exist.";
134     WriteServLog("%s %s", admin->GetLogStr().c_str(), strError.c_str());
135     return -1;
136     }
137
138 *ti = td;
139
140 if (store->SaveTariff(td, td.tariffConf.name))
141     {
142     string error = "Tariff " + td.tariffConf.name + " writing error. " + store->GetStrError();
143     WriteServLog(error.c_str());
144     return -1;
145     }
146
147 WriteServLog("%s Tariff \'%s\' changed.",
148              admin->GetLogStr().c_str(), td.tariffConf.name.c_str());
149
150 return 0;
151 }
152 //-----------------------------------------------------------------------------
153 int TARIFFS_IMPL::Del(const string & name, const ADMIN * admin)
154 {
155 const PRIV * priv = admin->GetPriv();
156
157 if (!priv->tariffChg)
158     {
159     string s = admin->GetLogStr() + " Delete tariff \'"
160                + name + "\'. Access denied.";
161     strError = "Access denied.";
162     WriteServLog(s.c_str());
163     return -1;
164     }
165
166 TARIFF_DATA td;
167
168     {
169     STG_LOCKER lock(&mutex, __FILE__, __LINE__);
170
171     list<TARIFF_IMPL>::iterator ti;
172     ti = find(tariffs.begin(), tariffs.end(), TARIFF_IMPL(name));
173
174     if (ti == tariffs.end())
175         {
176         strError = "Tariff \'" + name + "\' cannot be deleted. Tariff does not exist.";
177         WriteServLog("%s %s", admin->GetLogStr().c_str(), strError.c_str());
178         return -1;
179         }
180
181     if (store->DelTariff(name))
182         {
183         WriteServLog("Cannot delete tariff %s.", name.c_str());
184         WriteServLog("%s", store->GetStrError().c_str());
185         return -1;
186         }
187     
188     td = ti->GetTariffData();
189
190     tariffs.erase(ti);
191     }
192
193 std::set<NOTIFIER_BASE<TARIFF_DATA> *>::iterator ni = onDelNotifiers.begin();
194 while (ni != onDelNotifiers.end())
195     {
196     (*ni)->Notify(td);
197     ++ni;
198     }
199
200 WriteServLog("%s Tariff \'%s\' deleted.",
201              admin->GetLogStr().c_str(),
202              name.c_str());
203 return 0;
204 }
205 //-----------------------------------------------------------------------------
206 int TARIFFS_IMPL::Add(const string & name, const ADMIN * admin)
207 {
208 const PRIV * priv = admin->GetPriv();
209
210 if (!priv->tariffChg)
211     {
212     string s = admin->GetLogStr() + " Add tariff \'"
213                + name + "\'. Access denied.";
214     strError = "Access denied.";
215     WriteServLog(s.c_str());
216     return -1;
217     }
218
219     {
220     STG_LOCKER lock(&mutex, __FILE__, __LINE__);
221
222     list<TARIFF_IMPL>::iterator ti;
223     ti = find(tariffs.begin(), tariffs.end(), TARIFF_IMPL(name));
224
225     if (ti != tariffs.end())
226         {
227         strError = "Tariff \'" + name + "\' cannot be added. Tariff already exist.";
228         WriteServLog("%s %s", admin->GetLogStr().c_str(), strError.c_str());
229         return -1;
230         }
231
232     tariffs.push_back(TARIFF_IMPL(name));
233     }
234
235 if (store->AddTariff(name) < 0)
236     {
237     strError = "Tariff " + name + " adding error. " + store->GetStrError();
238     WriteServLog(strError.c_str());
239     return -1;
240     }
241
242 // Fire all "on add" notifiers
243 std::set<NOTIFIER_BASE<TARIFF_DATA> *>::iterator ni = onAddNotifiers.begin();
244 while (ni != onAddNotifiers.end())
245     {
246     (*ni)->Notify(tariffs.back().GetTariffData());
247     ++ni;
248     }
249
250 WriteServLog("%s Tariff \'%s\' added.",
251                  admin->GetLogStr().c_str(), name.c_str());
252
253 return 0;
254 }
255 //-----------------------------------------------------------------------------
256 void TARIFFS_IMPL::GetTariffsData(std::list<TARIFF_DATA> * tdl)
257 {
258 assert(tdl != NULL && "Tariffs data list is not null");
259 STG_LOCKER lock(&mutex, __FILE__, __LINE__);
260
261 Tariffs::const_iterator it = tariffs.begin();
262 for (; it != tariffs.end(); ++it)
263     {
264     tdl->push_back(it->GetTariffData());
265     }
266 }
267 //-----------------------------------------------------------------------------
268 void TARIFFS_IMPL::AddNotifierAdd(NOTIFIER_BASE<TARIFF_DATA> * n)
269 {
270 STG_LOCKER lock(&mutex, __FILE__, __LINE__);
271 onAddNotifiers.insert(n);
272 }
273 //-----------------------------------------------------------------------------
274 void TARIFFS_IMPL::DelNotifierAdd(NOTIFIER_BASE<TARIFF_DATA> * n)
275 {
276 STG_LOCKER lock(&mutex, __FILE__, __LINE__);
277 onAddNotifiers.erase(n);
278 }
279 //-----------------------------------------------------------------------------
280 void TARIFFS_IMPL::AddNotifierDel(NOTIFIER_BASE<TARIFF_DATA> * n)
281 {
282 STG_LOCKER lock(&mutex, __FILE__, __LINE__);
283 onDelNotifiers.insert(n);
284 }
285 //-----------------------------------------------------------------------------
286 void TARIFFS_IMPL::DelNotifierDel(NOTIFIER_BASE<TARIFF_DATA> * n)
287 {
288 STG_LOCKER lock(&mutex, __FILE__, __LINE__);
289 onDelNotifiers.erase(n);
290 }
291 //-----------------------------------------------------------------------------