Subversion Repositories SmartDukaan

Rev

Rev 5407 | Rev 6389 | Go to most recent revision | Show entire file | Ignore whitespace | Details | Blame | Last modification | View Log | RSS feed

Rev 5407 Rev 5623
Line 14... Line 14...
14
from elixir import session
14
from elixir import session
15
import datetime
15
import datetime
16
from sqlalchemy import desc
16
from sqlalchemy import desc
17
from sqlalchemy import select
17
from sqlalchemy import select
18
from shop2020.model.v1.user.impl.CartDataAccessors import create_cart
18
from shop2020.model.v1.user.impl.CartDataAccessors import create_cart
19
 
-
 
-
 
19
from sqlalchemy.sql import and_
20
 
20
 
21
def initialize(dbname='user', db_hostname="localhost"):
21
def initialize(dbname='user', db_hostname="localhost"):
22
    log_entry("initialize@DataAccessor", "Initializing data service")
22
    log_entry("initialize@DataAccessor", "Initializing data service")
23
    Dataservice.initialize(dbname, db_hostname)
23
    Dataservice.initialize(dbname, db_hostname)
24
 
24
 
Line 491... Line 491...
491
    session.commit()
491
    session.commit()
492
 
492
 
493
def get_trust_level(userId):
493
def get_trust_level(userId):
494
    user = User.query.filter_by(id = userId).first()
494
    user = User.query.filter_by(id = userId).first()
495
    return user.trust_level
495
    return user.trust_level
-
 
496
 
-
 
497
def get_user_emails(start_date, end_date):
-
 
498
    emails = select([User.table.c.communication_email], and_(User.table.c.active_since >= start_date, User.table.c.active_since <= end_date, User.table.c.is_anonymous==0)).execute()
-
 
499
    email_addresses = []
-
 
500
    
-
 
501
    for email in emails:
-
 
502
        email_addresses.append(str(email[0]))
-
 
503
    
-
 
504
    return email_addresses
496
    
505
    
497
def close_session():
506
def close_session():
498
    if session.is_active:
507
    if session.is_active:
499
        print "session is active. closing it."
508
        print "session is active. closing it."
500
        session.close()
509
        session.close()