Subversion Repositories SmartDukaan

Rev

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

Rev 18743 Rev 18764
Line 6... Line 6...
6 
from elixir import session
 6 
from elixir import session
7 
from shop2020.model.v1.user.impl import Dataservice
 7 
from shop2020.model.v1.user.impl import Dataservice
8 
from shop2020.model.v1.user.impl.CartDataAccessors import create_cart
 8 
from shop2020.model.v1.user.impl.CartDataAccessors import create_cart
9 
from shop2020.model.v1.user.impl.Dataservice import User, UserCommunication, \
 9 
from shop2020.model.v1.user.impl.Dataservice import User, UserCommunication, \
10 
    Address, Affiliate, Tracker, TrackLog, MasterAffiliate, UserWidgetItem, \
 10 
    Address, Affiliate, Tracker, TrackLog, MasterAffiliate, UserWidgetItem, \
11 
    FacebookUser, UserSource, PrivateDealUser, Counter, AccessTokenizer, PrivateDealUserAddressMapping
 11 
    FacebookUser, UserSource, PrivateDealUser, Counter, AccessTokenizer, PrivateDealUserAddressMapping, \
- 
 
 12 
    Line
12 
from shop2020.thriftpy.model.v1.user.ttypes import UserContextException, \
 13 
from shop2020.thriftpy.model.v1.user.ttypes import UserContextException, \
13 
    AuthenticationException, Sex, WidgetType as WType
 14 
    AuthenticationException, Sex, WidgetType as WType
14 
from shop2020.utils.Utils import log_entry, to_py_date
 15 
from shop2020.utils.Utils import log_entry, to_py_date
15 
from sqlalchemy import desc, select
 16 
from sqlalchemy import desc, select
16 
from sqlalchemy.sql import and_
 17 
from sqlalchemy.sql import and_
17 
from sqlalchemy.sql.expression import or_
 18 
from sqlalchemy.sql.expression import or_
18 
import datetime
 19 
import datetime
19 
import os, binascii
 20 
import os, binascii
- 
 
 21 
from shop2020.model.v1.user.impl.Converters import to_t_line
20 
 
 22 
 
21 
CounterStateMap = {"Telangana" : "TS", "Andhra Pradesh" : "AP", "Delhi" : "DL"}
 23 
CounterStateMap = {"Telangana" : "TS", "Andhra Pradesh" : "AP", "Delhi" : "DL"}
22 
 
 24 
 
23 
def initialize(dbname='user', db_hostname="localhost"):
 25 
def initialize(dbname='user', db_hostname="localhost"):
24 
    log_entry("initialize@DataAccessor", "Initializing data service")
 26 
    log_entry("initialize@DataAccessor", "Initializing data service")
Line 770... Line 772...
770 
            return True
 772 
            return True
771 
        else:
 773 
        else:
772 
            return False
 774 
            return False
773 
    except:
 775 
    except:
774 
        return False
 776 
        return False
- 
 
 777 
 
- 
 
 778 
def get_cart_by_value(cartIds):
- 
 
 779 
    returnMap = {}
- 
 
 780 
    lines = Line.query.filter(Line.cart_id.in_(cartIds)).all()
- 
 
 781 
    for line in lines:
- 
 
 782 
        if returnMap.has_key(line.cart_id):
- 
 
 783 
            returnMap.get(line.cart_id).append(to_t_line(line))
- 
 
 784 
        else:
- 
 
 785 
            returnMap[line.cart_id] = [to_t_line(line)]
- 
 
 786 
    return returnMap
775
787
776 
def close_session():
 788 
def close_session():
777 
    if session.is_active:
 789 
    if session.is_active:
778 
        print "session is active. closing it."
 790 
        print "session is active. closing it."
779 
        session.close()
 791 
        session.close()
Line 781... Line 793...
781 
def is_alive():
 793 
def is_alive():
782 
    try:
 794 
    try:
783 
        session.query(User.id).limit(1).one()
 795 
        session.query(User.id).limit(1).one()
784 
        return True
 796 
        return True
785 
    except:
 797 
    except:
786 
        return False
 - 
 
787 

            798
            
        return False

          

          

            -
            
 

            799
            
    

          

          

            -
            
 

            800
            
if __name__ == '__main__':

          

          

            -
            
 

            801
            
    Dataservice.initialize()

          

          

            -
            
 

            802
            
    print (get_cart_by_value([1005394]))

          

          

            -
            
 

            803
            

          

          

            788
            

            804