| 45 |
45 |
|
| 46 |
46 |
|
| 47 |
47 |
class WcsOlapFeeder(object):
|
|
48 |
|
|
49 |
channels = [
|
|
50 |
[1, 'web', u'web'],
|
|
51 |
[2, 'mail', u'courrier'],
|
|
52 |
[3, 'phone', u'téléphone'],
|
|
53 |
[4, 'counter', u'guichet'],
|
|
54 |
[5, 'backoffice', u'backoffice'],
|
|
55 |
[6, 'email', u'email'],
|
|
56 |
[7, 'fax', u'fax'],
|
|
57 |
]
|
|
58 |
channel_to_id = dict((c[1], c[0]) for c in channels)
|
|
59 |
id_to_channel = dict((c[0], c[1]) for c in channels)
|
|
60 |
|
|
61 |
status = [
|
|
62 |
[1, 'Nouveau'],
|
|
63 |
[2, 'En cours'],
|
|
64 |
[3, 'Terminé'],
|
|
65 |
]
|
|
66 |
status_to_id = dict((c[1], c[0]) for c in channels)
|
|
67 |
id_to_status = dict((c[0], c[1]) for c in channels)
|
|
68 |
|
| 48 |
69 |
def __init__(self, api, pg_dsn, schema, logger=None, config=None, do_feed=True, fake=False):
|
| 49 |
70 |
self.api = api
|
| 50 |
71 |
self.fake = fake
|
| ... | ... | |
| 310 |
331 |
generate_series('2010-01-01'::date, '2020-01-01'::date, '1 day'::interval)
|
| 311 |
332 |
AS the_date(the_date));''')
|
| 312 |
333 |
|
| 313 |
|
channels = [
|
| 314 |
|
[1, 'web', u'web'],
|
| 315 |
|
[2, 'mail', u'courrier'],
|
| 316 |
|
[3, 'phone', u'téléphone'],
|
| 317 |
|
[4, 'counter', u'guichet'],
|
| 318 |
|
[5, 'backoffice', u'backoffice'],
|
| 319 |
|
[6, 'email', u'email'],
|
| 320 |
|
[7, 'fax', u'fax'],
|
| 321 |
|
]
|
| 322 |
|
channel_to_id = dict((c[1], c[0]) for c in channels)
|
| 323 |
|
id_to_channel = dict((c[0], c[1]) for c in channels)
|
| 324 |
|
|
| 325 |
|
status = [
|
| 326 |
|
[1, 'Nouveau'],
|
| 327 |
|
[2, 'En cours'],
|
| 328 |
|
[3, 'Terminé'],
|
| 329 |
|
]
|
| 330 |
|
status_to_id = dict((c[1], c[0]) for c in channels)
|
| 331 |
|
id_to_status = dict((c[0], c[1]) for c in channels)
|
| 332 |
|
|
| 333 |
334 |
def create_table(self, name, columns, inherits=None, comment=None):
|
| 334 |
335 |
sql = 'CREATE TABLE %s' % name
|
| 335 |
336 |
sql += '(' + ', '.join('%s %s' % (n, t) for n, t in columns) + ')'
|
| 336 |
|
-
|