Subversion Repositories SmartDukaan

Rev

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

Rev 2815 Rev 2981
Line 1... Line 1...
1
'''
1
'''
2
Created on 28-Apr-2010
2
Created on 28-Apr-2010
3
 
3
 
4
@author: ashish
4
@author: ashish
5
'''
5
'''
6
from shop2020.utils.Utils import log_entry, to_py_date
6
from shop2020.utils.Utils import log_entry
7
from shop2020.model.v1.user.impl.UserDataAccessors import create_user, update_user, get_user_by_id, get_user_by_email, update_password,\
7
from shop2020.model.v1.user.impl.UserDataAccessors import create_user, update_user, get_user_by_id, get_user_by_email, update_password,\
8
    set_user_as_logged_out, set_user_as_logged_in, remove_address_for_user,\
8
    set_user_as_logged_out, set_user_as_logged_in, remove_address_for_user,\
9
    add_address_for_user, delete_user, authenticate_user, user_exists, get_user_state, initialize, set_default_address,\
9
    add_address_for_user, delete_user, authenticate_user, user_exists, get_user_state, initialize, set_default_address,\
10
    create_anonymous_user, forgot_password, get_all_addresses_for_user, get_address, get_default_address_id, get_default_pincode,\
10
    create_anonymous_user, forgot_password, get_all_addresses_for_user, get_address, get_default_address_id, get_default_pincode,\
11
    create_user_communication, get_user_communication_by_id, get_user_communication_by_user, get_all_user_communications,\
11
    create_user_communication, get_user_communication_by_id, get_user_communication_by_user, get_all_user_communications,\
12
    create_affiliate, get_affiliate_by_id, get_affiliate_by_name, get_tracker_by_id, add_track_log, get_track_log_by_id, get_track_logs_by_affiliate,\
12
    create_affiliate, get_affiliate_by_id, get_affiliate_by_name, get_tracker_by_id, add_track_log, get_track_log_by_id, get_track_logs_by_affiliate,\
13
    get_track_logs_by_user, get_track_logs, create_master_affiliate,\
13
    get_track_logs_by_user, get_track_logs, create_master_affiliate,\
14
    get_master_affiliate_by_id, get_master_affiliate_by_name, get_affiliates_by_master_affiliate, get_all_master_affiliates,\
14
    get_master_affiliate_by_id, get_master_affiliate_by_name, get_affiliates_by_master_affiliate, get_all_master_affiliates,\
15
    get_user_notes, put_user_note
15
    get_user_notes, put_user_note, get_my_research_items,\
-
 
16
    get_browse_history_items, update_my_research, delete_item_from_my_research,\
-
 
17
    update_browse_history
16
from shop2020.model.v1.user.impl.CartDataAccessors import create_cart, get_cart,\
18
from shop2020.model.v1.user.impl.CartDataAccessors import create_cart, get_cart,\
17
    get_cart_by_id, get_cart_by_user_id_and_status, get_carts_by_status,\
19
    get_cart_by_id, get_cart_by_user_id_and_status, get_carts_by_status,\
18
    get_carts_between, change_cart_status, add_item_to_cart,\
20
    get_carts_between, change_cart_status, add_item_to_cart,\
19
    change_item_status, add_address_to_cart, commit_cart,\
21
    change_item_status, add_address_to_cart, commit_cart,\
20
    validate_cart, merge_cart, delete_item_from_cart, check_out, reset_cart,\
22
    validate_cart, merge_cart, delete_item_from_cart, check_out, reset_cart,\
Line 23... Line 25...
23
     to_t_master_affiliate, to_t_affiliate, to_t_tracker, to_t_track_log,\
25
     to_t_master_affiliate, to_t_affiliate, to_t_tracker, to_t_track_log,\
24
    to_t_user_note
26
    to_t_user_note
25
 
27
 
26
from shop2020.thriftpy.model.v1.user.ttypes import ShoppingCartException
28
from shop2020.thriftpy.model.v1.user.ttypes import ShoppingCartException
27
 
29
 
28
from shop2020.model.v1.user.impl.WidgetDataAccessor import update_my_research, get_browse_history,\
-
 
29
    update_browse_history, delete_item_from_my_research, merge_browse_history, get_my_research
-
 
30
from shop2020.model.v1.user.impl.WidgetConverters import to_t_widget
-
 
31
from shop2020.model.v1.user.impl import UserDataAccessors, CartDataAccessors,\
30
from shop2020.model.v1.user.impl import UserDataAccessors, CartDataAccessors
32
    WidgetDataAccessor
-
 
33
 
31
 
34
class UserContextServiceHandler:
32
class UserContextServiceHandler:
35
    
33
    
36
    
34
    
37
    def __init__(self, dbname='user'):
35
    def __init__(self, dbname='user'):
Line 505... Line 503...
505
            return reset_cart(cartId, items)
503
            return reset_cart(cartId, items)
506
        finally:
504
        finally:
507
            CartDataAccessors.close_session()
505
            CartDataAccessors.close_session()
508
 
506
 
509
    #Widget related methods
507
    #Widget related methods
510
    def getMyResearch(self, userId):
-
 
511
        """
-
 
512
        Parameters:
-
 
513
         - user_id
-
 
514
        """
-
 
515
        try:
-
 
516
            return to_t_widget(get_my_research(userId))
-
 
517
        finally:
-
 
518
            WidgetDataAccessor.close_session()
-
 
519
    
-
 
520
    def updateMyResearch(self, userId, itemId):
508
    def updateMyResearch(self, userId, itemId):
521
        """
509
        """
522
        Parameters:
510
        Parameters:
523
         - user_id
511
         - user_id
524
         - item_id
512
         - item_id
525
        """
513
        """
526
        try:
514
        try:
527
            return update_my_research(userId, itemId)
515
            return update_my_research(userId, itemId)
528
        finally:
516
        finally:
529
            WidgetDataAccessor.close_session()
517
            UserDataAccessors.close_session()
530
 
518
 
531
    def deleteItemFromMyResearch(self, userId, itemId):
519
    def deleteItemFromMyResearch(self, userId, itemId):
532
        """
520
        """
533
        Parameters:
521
        Parameters:
534
         - user_id
522
         - user_id
535
         - item_id
523
         - item_id
536
        """
524
        """
537
        try:
525
        try:
538
            return delete_item_from_my_research(userId, itemId)
526
            return delete_item_from_my_research(userId, itemId)
539
        finally:
527
        finally:
540
            WidgetDataAccessor.close_session()
528
            UserDataAccessors.close_session()
541
            
529
            
542
    def updateBrowseHistory(self, userId, itemId):
530
    def updateBrowseHistory(self, userId, itemId):
543
        """
531
        """
544
        Parameters: 
532
        Parameters: 
545
        - user_id
533
        - user_id
546
        - item_id
534
        - item_id
547
        """
535
        """
548
        try:
536
        try:
549
            update_browse_history(userId, itemId)
537
            update_browse_history(userId, itemId)
550
        finally:
538
        finally:
551
            WidgetDataAccessor.close_session()
539
            UserDataAccessors.close_session()
552
            
-
 
553
    def getBrowseHistory(self, userId):
-
 
554
        """
-
 
555
        Parameters:
-
 
556
         - user_id
-
 
557
        """
-
 
558
        try:
-
 
559
            return to_t_widget(get_browse_history(userId))
-
 
560
        finally:
-
 
561
            WidgetDataAccessor.close_session()
-
 
562
            
540
            
563
    def mergeBrowseHistory(self, fromUserId, toUserId):
541
    def mergeBrowseHistory(self, fromUserId, toUserId):
564
        """
542
        """
565
        Parameters:
543
        Parameters:
566
         - user_id
544
         - user_id
567
        """
545
        """
568
        try:
546
        pass
569
            return merge_browse_history(fromUserId, toUserId)
-
 
570
        finally:
-
 
571
            WidgetDataAccessor.close_session()
-
 
572
    
547
    
573
    def saveUserCommunication(self, userId, email, communicationType, orderId, awb, product, subject, message):
548
    def saveUserCommunication(self, userId, email, communicationType, orderId, awb, product, subject, message):
574
        """
549
        """
575
        Parameters:
550
        Parameters:
576
         - userId
551
         - userId
Line 818... Line 793...
818
        try:
793
        try:
819
            return [to_t_user_note(user_note) for user_note in get_user_notes(userId, entityId)]
794
            return [to_t_user_note(user_note) for user_note in get_user_notes(userId, entityId)]
820
        finally:
795
        finally:
821
            UserDataAccessors.close_session()
796
            UserDataAccessors.close_session()
822
    
797
    
823
    def closeSession(self, ):
-
 
824
        CartDataAccessors.close_session()
-
 
825
        UserDataAccessors.close_session()
-
 
826
        WidgetDataAccessor.close_session()
-
 
827
 
798
 
828
        
-
 
829
    '''        
-
 
830
    def addWidget(self, widget):
799
    def getMyResearchItems(self, userId):
831
        """
-
 
832
        Parameters:
-
 
833
         - widget
-
 
834
        """
-
 
835
        try:
-
 
836
            add_widget(widget)
-
 
837
        finally:
-
 
838
            WidgetDataAccessor.close_session()
-
 
839
    
-
 
840
    def addItemToWidget(self, widget_id, items):
-
 
841
        """
800
        """
842
        Parameters:
801
        Parameters:
843
         - widget_id
-
 
844
         - items
-
 
845
        """
-
 
846
        try:
-
 
847
            add_items_to_widget(widget_id, items)
-
 
848
        finally:
-
 
849
            WidgetDataAccessor.close_session()
-
 
850
            
-
 
851
    def updateWidget(self, widgetId, enable):
-
 
852
        """
-
 
853
        Parameters:
-
 
854
         - widgetId
-
 
855
         - enable
-
 
856
        """
-
 
857
        try:
-
 
858
            update_widget(widgetId, enable)
-
 
859
        finally:
-
 
860
            WidgetDataAccessor.close_session()
-
 
861
            
-
 
862
    def updateWidgetItem(self, widgetId, enable):
-
 
863
        """
-
 
864
        Parameters:
-
 
865
         - widgetId
-
 
866
         - enable
-
 
867
        """
-
 
868
        try:
-
 
869
            update_widget(widgetId, enable)
-
 
870
        finally:
-
 
871
            WidgetDataAccessor.close_session()
-
 
872
            
-
 
873
    def deleteItemFromWidget(self, widget_id, item_id):
-
 
874
        """
-
 
875
        Parameters:
-
 
876
         - widget_id
-
 
877
         - item_id
-
 
878
        """
-
 
879
        try:
-
 
880
            return delete_item_from_widget(widget_id, item_id)
-
 
881
        finally:
-
 
882
            WidgetDataAccessor.close_session()
-
 
883
            
-
 
884
    def getWidget(self, type, userId, onlyEnabled):
-
 
885
        """
-
 
886
        Parameters:
-
 
887
         - type
-
 
888
         - userId
802
         - userId
889
         - onlyEnabled
-
 
890
        """
803
        """
891
        try:
804
        try:
892
            widget = get_widget_by_type(type, userId, onlyEnabled)
-
 
893
            return to_t_widget(widget)
805
            return get_my_research_items(userId)
894
        finally:
806
        finally:
895
            WidgetDataAccessor.close_session()
807
            UserDataAccessors.close_session()
896
            
-
 
897
    def updateRatings(self, item_id, type, rating, user_id):
-
 
898
        """
-
 
899
        Parameters:
-
 
900
        - item_id
-
 
901
        - type
-
 
902
        - rating
-
 
903
        - user_id
-
 
904
        """
808
 
905
        try:
-
 
906
            update_ratings(user_id, item_id, rating, type)
-
 
907
        finally:
-
 
908
            WidgetDataAccessor.close_session()
-
 
909
            
-
 
910
    def getRatings(self, item_id, user_id):
809
    def getBrowseHistoryItems(self, userId):
911
        """
810
        """
912
        Parameters:
811
        Parameters:
913
        - item_id
-
 
914
        - user_id
812
         - userId
915
        """
813
        """
916
        try:
814
        try:
917
            all_ratings, user_ratings = get_ratings(user_id, item_id)
-
 
918
            return to_t_ratings(user_ratings, all_ratings, item_id, user_id)
815
            return get_browse_history_items(userId)
919
        finally:
816
        finally:
920
            WidgetDataAccessor.close_session()
817
            UserDataAccessors.close_session()
-
 
818
 
921
            
819
    def closeSession(self, ):
-
 
820
        CartDataAccessors.close_session()
922
    '''
821
        UserDataAccessors.close_session()
923
    
822
    
924
823