Subversion Repositories SmartDukaan

Rev

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

Rev 4668 Rev 5326
Line 4... Line 4...
4
@author: ashish
4
@author: ashish
5
'''
5
'''
6
from shop2020.utils.Utils import log_entry
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, authenticate_user, user_exists, 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, get_my_research_items,\
15
    get_user_notes, put_user_note, get_my_research_items,\
16
    get_browse_history_items, update_my_research, delete_item_from_my_research,\
16
    get_browse_history_items, update_my_research, delete_item_from_my_research,\
17
    update_browse_history, get_user_by_mobile_number, is_alive, increase_trust_level
17
    update_browse_history, get_user_by_mobile_number, is_alive, increase_trust_level,\
-
 
18
    get_user_by_cart_id
18
 
19
 
19
from shop2020.model.v1.user.impl.CartDataAccessors import create_cart, get_cart,\
20
from shop2020.model.v1.user.impl.CartDataAccessors import create_cart, get_cart,\
20
    get_cart_by_id, get_cart_by_user_id_and_status, get_carts_by_status,\
-
 
21
    get_carts_between, change_cart_status, add_item_to_cart,\
21
    get_cart_by_id, get_carts_between, add_item_to_cart,\
22
    change_item_status, add_address_to_cart, commit_cart,\
22
    add_address_to_cart, commit_cart,\
23
    validate_cart, merge_cart, delete_item_from_cart, check_out, reset_cart,\
23
    validate_cart, merge_cart, delete_item_from_cart, check_out, reset_cart,\
24
    apply_coupon_to_cart, remove_coupon, get_carts_with_coupon_count,\
24
    apply_coupon_to_cart, remove_coupon, get_carts_with_coupon_count,\
25
    delete_discounts_from_cart, save_discounts, show_cod_option
25
    delete_discounts_from_cart, save_discounts, show_cod_option
26
from shop2020.model.v1.user.impl.Converters import to_t_user, to_t_user_state, to_t_cart, to_t_address, to_t_user_communication,\
26
from shop2020.model.v1.user.impl.Converters import to_t_user, to_t_cart, to_t_address, to_t_user_communication,\
27
     to_t_master_affiliate, to_t_affiliate, to_t_tracker, to_t_track_log,\
27
     to_t_master_affiliate, to_t_affiliate, to_t_tracker, to_t_track_log,\
28
    to_t_user_note
28
    to_t_user_note
29
 
29
 
30
from shop2020.thriftpy.model.v1.user.ttypes import ShoppingCartException
30
from shop2020.thriftpy.model.v1.user.ttypes import ShoppingCartException
31
 
31
 
Line 40... Line 40...
40
    """
40
    """
41
    service
41
    service
42
    """
42
    """
43
    def createAnonymousUser(self, jsessionId):
43
    def createAnonymousUser(self, jsessionId):
44
        try:
44
        try:
45
            cart = create_cart(-1)
-
 
46
            return to_t_user(create_anonymous_user(jsessionId, cart))
45
            return to_t_user(create_anonymous_user(jsessionId))
47
        finally:
46
        finally:
48
            self.closeSession()
47
            self.closeSession()
49
 
48
 
50
    def getUserById(self, userId):
49
    def getUserById(self, userId):
51
        """
50
        """
Line 55... Line 54...
55
        try:
54
        try:
56
            return to_t_user(get_user_by_id(userId))
55
            return to_t_user(get_user_by_id(userId))
57
        finally:
56
        finally:
58
            self.closeSession()
57
            self.closeSession()
59
 
58
 
-
 
59
    def getUserByCartId(self, cartId):
-
 
60
        """
-
 
61
        Parameters:
-
 
62
        - cartId
-
 
63
        """
-
 
64
        try:
-
 
65
            return to_t_user(get_user_by_cart_id(cartId))
-
 
66
        finally:
-
 
67
            self.closeSession()
-
 
68
        
60
    def getUserByMobileNumber(self, mobileNumber):
69
    def getUserByMobileNumber(self, mobileNumber):
61
        """
70
        """
62
        Parameters:
71
        Parameters:
63
        - mobileNumber
72
        - mobileNumber
64
        """
73
        """
Line 81... Line 90...
81
        """
90
        """
82
        Parameters:
91
        Parameters:
83
        - user
92
        - user
84
        """
93
        """
85
        try:
94
        try:
86
            cart = create_cart(-1)
-
 
87
            return to_t_user(create_user(user, cart))
95
            return to_t_user(create_user(user))
88
        finally:
96
        finally:
89
            self.closeSession()
97
            self.closeSession()
90
 
98
 
91
    def updateUser(self, user):
99
    def updateUser(self, user):
92
        """
100
        """
Line 96... Line 104...
96
        try:
104
        try:
97
            return to_t_user(update_user(user))
105
            return to_t_user(update_user(user))
98
        finally:
106
        finally:
99
            self.closeSession()
107
            self.closeSession()
100
            
108
            
101
    def deleteUser(self, userId):
-
 
102
        """
-
 
103
        Parameters:
-
 
104
        - userId
-
 
105
        """
-
 
106
        try:
-
 
107
            return delete_user(userId)
-
 
108
        finally:
-
 
109
            self.closeSession()
-
 
110
            
-
 
111
    def getUserState(self, userId):
-
 
112
        """
-
 
113
        Parameters:
-
 
114
        - userId
-
 
115
        """
-
 
116
        log_entry(self, "get State")
-
 
117
        try:
-
 
118
            return to_t_user_state(get_user_state(userId))
-
 
119
        finally:
-
 
120
            self.closeSession()
-
 
121
            
-
 
122
    def authenticateUser(self, email, password):
109
    def authenticateUser(self, email, password):
123
        """
110
        """
124
        Parameters:
111
        Parameters:
125
        - email
112
        - email
126
        - password
113
        - password
Line 307... Line 294...
307
            else:
294
            else:
308
                raise ShoppingCartException(101, "not cart attached to this id")
295
                raise ShoppingCartException(101, "not cart attached to this id")
309
        finally:
296
        finally:
310
            self.closeSession()
297
            self.closeSession()
311
            
298
            
312
    def getCartsForUser(self, userId, status):
-
 
313
        """
-
 
314
        Parameters:
-
 
315
         - userId
-
 
316
         - status
-
 
317
        """
-
 
318
        try:
-
 
319
            if not userId:
-
 
320
                raise ShoppingCartException(101, "user_id is not provided")
-
 
321
            
-
 
322
            carts = get_cart_by_user_id_and_status(userId, status)
-
 
323
            t_carts = []
-
 
324
            if carts:
-
 
325
                for cart in carts:
-
 
326
                    t_carts.append(to_t_cart(cart))
-
 
327
            return t_carts
-
 
328
        finally:
-
 
329
            self.closeSession()
-
 
330
                
-
 
331
    def getCartsByStatus(self, status):
-
 
332
        """
-
 
333
        Parameters:
-
 
334
         - status
-
 
335
        """
-
 
336
        try:
-
 
337
            carts = get_carts_by_status(status)
-
 
338
            t_carts = []
-
 
339
            if carts:
-
 
340
                for cart in carts:
-
 
341
                    t_carts.append(to_t_cart(cart))
-
 
342
            return t_carts
-
 
343
        finally:
-
 
344
            self.closeSession()
-
 
345
            
-
 
346
    def getCartsByTime(self, from_time, to_time, status):
299
    def getCartsByTime(self, from_time, to_time, status):
347
        """
300
        """
348
        Parameters:
301
        Parameters:
349
         - from_time
302
         - from_time
350
         - to_time
303
         - to_time
Line 358... Line 311...
358
                    t_carts.append(to_t_cart(cart))
311
                    t_carts.append(to_t_cart(cart))
359
            return t_carts
312
            return t_carts
360
        finally:
313
        finally:
361
            self.closeSession()
314
            self.closeSession()
362
            
315
            
363
    def changeCartStatus(self, cartId, status):
-
 
364
        """
-
 
365
        Parameters:
-
 
366
         - cartId
-
 
367
         - status
-
 
368
        """
-
 
369
        try:
-
 
370
            change_cart_status(cartId, status)
-
 
371
        finally:
-
 
372
            self.closeSession()
-
 
373
            
-
 
374
    def addItemToCart(self, cartId, itemId, quantity, sourceId):
316
    def addItemToCart(self, cartId, itemId, quantity, sourceId):
375
        """
317
        """
376
        Parameters:
318
        Parameters:
377
         - cartId
319
         - cartId
378
         - itemId
320
         - itemId
Line 392... Line 334...
392
        try:
334
        try:
393
            delete_item_from_cart(cartId, itemId)
335
            delete_item_from_cart(cartId, itemId)
394
        finally:
336
        finally:
395
            self.closeSession()
337
            self.closeSession()
396
            
338
            
397
    def changeItemStatus(self, cartId, itemId, status):
-
 
398
        """
-
 
399
        Parameters:
-
 
400
         - cartId
-
 
401
         - itemId
-
 
402
        """
-
 
403
        try:
-
 
404
            return change_item_status(cartId, itemId, status)
-
 
405
        finally:
-
 
406
            self.closeSession()
-
 
407
            
-
 
408
    def addAddressToCart(self, cartId, addressId):
339
    def addAddressToCart(self, cartId, addressId):
409
        """
340
        """
410
        Parameters:
341
        Parameters:
411
         - cartId
342
         - cartId
412
         - addressId
343
         - addressId
Line 437... Line 368...
437
        try:
368
        try:
438
            remove_coupon(cartId)
369
            remove_coupon(cartId)
439
        finally:
370
        finally:
440
            self.closeSession()
371
            self.closeSession()
441
    
372
    
442
    def createOrders(self, cartId, sessionSource, sessionTime, firstSource, firstSourceTime):
373
    def createOrders(self, cartId, sessionSource, sessionTime, firstSource, firstSourceTime, userId):
443
        """
374
        """
444
        Parameters:
375
        Parameters:
445
         - cartId
376
         - cartId
446
         - sessionSource
377
         - sessionSource
447
        """
378
        """
448
        try:
379
        try:
449
            return commit_cart(cartId, sessionSource, sessionTime, firstSource, firstSourceTime)
380
            return commit_cart(cartId, sessionSource, sessionTime, firstSource, firstSourceTime, userId)
450
        finally:
381
        finally:
451
            self.closeSession()
382
            self.closeSession()
452
 
383
 
453
    def validateCart(self, cartId, sourceId):
384
    def validateCart(self, cartId, sourceId):
454
        """
385
        """