Subversion Repositories SmartDukaan

from shop2020.thriftpy.model.v1.user.ttypes import UserContextException,\

from shop2020.thriftpy.model.v1.user.ttypes import UserContextException,\

    AuthenticationException, Sex

    AuthenticationException, Sex

from elixir import session

from elixir import session

import datetime

import datetime

from sqlalchemy import desc

from sqlalchemy import desc

from shop2020.model.v1.user.impl.CartDataAccessors import create_cart

from shop2020.model.v1.user.impl.CartDataAccessors import create_cart

def initialize(dbname='user', db_hostname="localhost"):

def initialize(dbname='user', db_hostname="localhost"):

    log_entry("initialize@DataAccessor", "Initializing data service")

    log_entry("initialize@DataAccessor", "Initializing data service")

    return UserCommunication.query.filter_by(user_id = user_communication_user_id).order_by(-UserCommunication.id).all()

    return UserCommunication.query.filter_by(user_id = user_communication_user_id).order_by(-UserCommunication.id).all()

def get_all_user_communications():

def get_all_user_communications():

    return UserCommunication.query.order_by(-UserCommunication.id).all()

    return UserCommunication.query.order_by(-UserCommunication.id).all()

def create_master_affiliate(name, added_on):

def create_master_affiliate(name, added_on):

    master_affiliate = MasterAffiliate()

    master_affiliate = MasterAffiliate()

    master_affiliate.name = name

    master_affiliate.name = name

    master_affiliate.added_on = to_py_date(added_on)

    master_affiliate.added_on = to_py_date(added_on)

    session.commit()

    session.commit()

def increase_trust_level(userId, trustLevelDelta):

def increase_trust_level(userId, trustLevelDelta):

    user = User.query.filter_by(id = userId).with_lockmode('update').first()

    user = User.query.filter_by(id = userId).with_lockmode('update').first()

    user.trust_level += trustLevelDelta

    user.trust_level += trustLevelDelta

    session.commit()

    session.commit()

def close_session():

def close_session():

    if session.is_active:

    if session.is_active:

        print "session is active. closing it."

        print "session is active. closing it."

        session.close()

        session.close()