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