Subversion Repositories SmartDukaan

Rev

Rev 1891 | Rev 1899 | Go to most recent revision | Details | Compare with Previous | Last modification | View Log | RSS feed

Rev Author Line No. Line
130 ashish 1 
'''
2 
Created on 28-Apr-2010
3 
 
4 
@author: ashish
5 
'''
1891 ankur.sing 6 
from shop2020.utils.Utils import log_entry, to_py_date
1491 vikas 7 
from shop2020.model.v1.user.impl.UserDataAccessors import create_user, update_user, get_user_by_id, get_user_by_email, update_password,\
557 chandransh 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,\
1894 vikas 10 
    create_anonymous_user, forgot_password, get_all_addresses_for_user, get_address, get_default_address_id, get_default_pincode,\
1845 vikas 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, create_tracker, get_tracker_by_id, get_trackers_by_affiliate,\
13 
    add_track_log, get_track_log_by_id, get_track_logs_by_tracker, 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
557 chandransh 15 
from shop2020.model.v1.user.impl.CartDataAccessors import create_cart, get_cart,\
16 
    get_cart_by_id, get_cart_by_user_id_and_status, get_carts_by_status,\
17 
    get_carts_between, change_cart_status, add_item_to_cart,\
643 chandransh 18 
    change_item_status, add_address_to_cart, commit_cart,\
691 chandransh 19 
    validate_cart, merge_cart, delete_item_from_cart, check_out, reset_cart
1845 vikas 20 
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,\
21 
     to_t_master_affiliate, to_t_affiliate, to_t_tracker, to_t_track_log
576 chandransh 22 
 
557 chandransh 23 
from shop2020.thriftpy.model.v1.user.ttypes import ShoppingCartException
130 ashish 24 
 
772 rajveer 25 
from shop2020.model.v1.user.impl.WidgetDataAccessor import update_my_research, get_browse_history,\
26 
    update_browse_history, delete_item_from_my_research, merge_browse_history, get_my_research
27 
from shop2020.model.v1.user.impl.WidgetConverters import to_t_widget
766 rajveer 28 
from shop2020.model.v1.user.impl import UserDataAccessors, CartDataAccessors,\
29 
    WidgetDataAccessor
557 chandransh 30 
 
130 ashish 31 
class UserContextServiceHandler:
32 
 
404 rajveer 33 
 
1249 chandransh 34 
    def __init__(self, dbname='user'):
35 
        initialize(dbname)
557 chandransh 36 
 
130 ashish 37 
    """
557 chandransh 38 
    service
130 ashish 39 
    """
557 chandransh 40 
    def createAnonymousUser(self, jsessionId):
766 rajveer 41 
        try:
42 
            cart = create_cart(-1)
43 
            return to_t_user(create_anonymous_user(jsessionId, cart))
44 
        finally:
45 
            UserDataAccessors.close_session()
557 chandransh 46 
    def getUserById(self, userId):
130 ashish 47 
        """
48 
        Parameters:
557 chandransh 49 
        - userId
130 ashish 50 
        """
766 rajveer 51 
        try:
52 
            return to_t_user(get_user_by_id(userId))
53 
        finally:
54 
            UserDataAccessors.close_session()
1491 vikas 55 
 
56 
    def getUserByEmail(self, email):
57 
        """
58 
        Parameters:
59 
         - email
60 
        """
61 
        try:
62 
            return to_t_user(get_user_by_email(email))
63 
        finally:
64 
            UserDataAccessors.close_session()
65 
 
66 
 
557 chandransh 67 
    def createUser(self, user):
130 ashish 68 
        """
69 
        Parameters:
557 chandransh 70 
        - user
130 ashish 71 
        """
766 rajveer 72 
        try:
73 
            cart = create_cart(-1)
74 
            return to_t_user(create_user(user, cart))
75 
        finally:
76 
            UserDataAccessors.close_session()
77 
 
557 chandransh 78 
    def updateUser(self, user):
130 ashish 79 
        """
80 
        Parameters:
557 chandransh 81 
        - user
130 ashish 82 
        """
766 rajveer 83 
        try:
84 
            return to_t_user(update_user(user))
85 
        finally:
86 
            UserDataAccessors.close_session()
87 
 
557 chandransh 88 
    def deleteUser(self, userId):
130 ashish 89 
        """
90 
        Parameters:
557 chandransh 91 
        - userId
130 ashish 92 
        """
766 rajveer 93 
        try:
94 
            return delete_user(userId)
95 
        finally:
96 
            UserDataAccessors.close_session()
97 
 
557 chandransh 98 
    def getUserState(self, userId):
99 
        """
100 
        Parameters:
101 
        - userId
102 
        """
130 ashish 103 
        log_entry(self, "get State")
766 rajveer 104 
        try:
105 
            return to_t_user_state(get_user_state(userId))
106 
        finally:
107 
            UserDataAccessors.close_session()
108 
 
557 chandransh 109 
    def authenticateUser(self, email, password):
130 ashish 110 
        """
111 
        Parameters:
557 chandransh 112 
        - email
113 
        - password
114 
        """
115 
        log_entry(self, "authenticate user")
766 rajveer 116 
        try:
117 
            return to_t_user(authenticate_user(email, password))
118 
        finally:
119 
            UserDataAccessors.close_session()
120 
 
557 chandransh 121 
    def userExists(self, email):
122 
        """
123 
        Parameters:
124 
        - email
125 
        """
126 
        log_entry(self, "user exists")
766 rajveer 127 
        try:
128 
            return user_exists(email)
129 
        finally:
130 
            UserDataAccessors.close_session()
131 
 
567 rajveer 132 
    def addAddressForUser(self, userId, address, setDefault):
557 chandransh 133 
        """
134 
        Parameters:
135 
        - userId
136 
        - address
137 
        - setDefault
138 
        """
139 
        log_entry(self, "add address for user")
766 rajveer 140 
        try:
141 
            return add_address_for_user(address, userId, setDefault)
142 
        finally:
143 
            UserDataAccessors.close_session()
144 
 
557 chandransh 145 
    def removeAddressForUser(self, userid, addressId):
146 
        """
147 
        Parameters:
148 
        - userid
149 
        - addressId
150 
        """
151 
        log_entry(self, "removing address")
766 rajveer 152 
        try:
153 
            return remove_address_for_user(userid, addressId)
154 
        finally:
155 
            UserDataAccessors.close_session()
156 
 
557 chandransh 157 
    def setUserAsLoggedIn(self, userId, timestamp):
158 
        """
159 
        Parameters:
160 
        - userId
161 
        - timestamp
162 
        """
163 
        log_entry(self, "set_user_as_logged_in")
766 rajveer 164 
        try:
165 
            return set_user_as_logged_in(userId, timestamp)
166 
        finally:
167 
            UserDataAccessors.close_session()
168 
 
557 chandransh 169 
    def setUserAsLoggedOut(self, userId, timestamp):
170 
        """
171 
        Parameters:
172 
        - userId
173 
        - timestamp
174 
        """
175 
        log_entry(self, "set user as logged out")
766 rajveer 176 
        try:
177 
            return set_user_as_logged_out(userId, timestamp)
178 
        finally:
179 
            UserDataAccessors.close_session()
180 
 
557 chandransh 181 
    def setDefaultAddress(self, userId, addressId):
182 
        """
183 
        Parameters:
184 
        - userId
185 
        - addressId
186 
        """
766 rajveer 187 
        try:
188 
            return set_default_address(userId, addressId)
189 
        finally:
190 
            UserDataAccessors.close_session()
191 
 
594 rajveer 192 
    def updatePassword(self, userid, oldPassword, newPassword):
557 chandransh 193 
        """
194 
        Parameters:
594 rajveer 195 
         - userid
196 
         - oldPassword
197 
         - newPassword
557 chandransh 198 
        """
199 
        log_entry(self, "updating password")
766 rajveer 200 
        try:
201 
            return update_password(userid, oldPassword, newPassword)
202 
        finally:
203 
            UserDataAccessors.close_session()
204 
 
884 rajveer 205 
    def forgotPassword(self, email, password):
581 rajveer 206 
        """
207 
        Parameters:
208 
         - email
209 
        """
210 
        log_entry(self, "forgot password")
766 rajveer 211 
        try:
884 rajveer 212 
            return forgot_password(email, password)
766 rajveer 213 
        finally:
214 
            UserDataAccessors.close_session()
215 
 
594 rajveer 216 
    def getAllAddressesForUser(self, userId):
217 
        """
218 
        Parameters:
219 
         - userId
220 
        """
766 rajveer 221 
        try:
222 
            addresses = get_all_addresses_for_user(userId)
223 
 
224 
            t_addresses = list()
225 
            for address in addresses:
226 
                t_addresses.append(to_t_address(address))
227 
            return t_addresses
228 
        finally:
229 
            UserDataAccessors.close_session()
594 rajveer 230 
 
1894 vikas 231 
    def getAddressById(self, addressId):
232 
        """
233 
        Parameters:
234 
         - addressId
235 
        """
236 
        try:
237 
            return to_t_address(get_address(addressId))
238 
        finally:
239 
            UserDataAccessors.close_session()
240 
 
594 rajveer 241 
    def getDefaultAddressId(self, userId):
242 
        """
243 
        Parameters:
244 
         - userId
245 
        """
766 rajveer 246 
        try:
785 rajveer 247 
            return get_default_address_id(userId)
766 rajveer 248 
        finally:
249 
            UserDataAccessors.close_session()
785 rajveer 250 
 
251 
    def getDefaultPincode(self, userId):
252 
        """
253 
        Parameters:
254 
         - userId
255 
        """
256 
        try:
257 
            return get_default_pincode(userId)
258 
        finally:
259 
            UserDataAccessors.close_session()
260 
 
557 chandransh 261 
    def createCart(self, userId):
262 
        """
263 
        Parameters:
264 
        - userId
265 
        """
766 rajveer 266 
        try:
267 
            return create_cart(userId).id
268 
        finally:
269 
            UserDataAccessors.close_session()
270 
 
557 chandransh 271 
    def getCurrentCart(self, userId):
272 
        """
273 
        Parameters:
130 ashish 274 
         - userId
275 
        """
766 rajveer 276 
        try:
277 
            cart = get_cart(userId)
278 
            if cart:
279 
                return to_t_cart(cart)
280 
            else:
281 
                raise ShoppingCartException(101, "not cart attached to this user")
282 
        finally:
283 
            CartDataAccessors.close_session()
284 
 
557 chandransh 285 
    def getCart(self, cartId):
286 
        """
287 
        Parameters:
288 
         - cartId
289 
        """
766 rajveer 290 
        try:
291 
            cart = get_cart_by_id(cartId)
292 
            if cart:
293 
                return to_t_cart(cart)
294 
            else:
295 
                raise ShoppingCartException(101, "not cart attached to this id")
296 
        finally:
297 
            CartDataAccessors.close_session()
298 
 
557 chandransh 299 
    def getCartsForUser(self, userId, status):
130 ashish 300 
        """
301 
        Parameters:
302 
         - userId
557 chandransh 303 
         - status
130 ashish 304 
        """
766 rajveer 305 
        try:
306 
            if not userId:
307 
                raise ShoppingCartException(101, "user_id is not provided")
308 
 
309 
            carts = get_cart_by_user_id_and_status(userId, status)
310 
            t_carts = []
311 
            if carts:
312 
                for cart in carts:
313 
                    t_carts.append(to_t_cart(cart))
314 
            return t_carts
315 
        finally:
316 
            CartDataAccessors.close_session()
317 
 
557 chandransh 318 
    def getCartsByStatus(self, status):
130 ashish 319 
        """
320 
        Parameters:
557 chandransh 321 
         - status
130 ashish 322 
        """
766 rajveer 323 
        try:
324 
            carts = get_carts_by_status(status)
325 
            t_carts = []
326 
            if carts:
327 
                for cart in carts:
328 
                    t_carts.append(to_t_cart(cart))
329 
            return t_carts
330 
        finally:
331 
            CartDataAccessors.close_session()
332 
 
557 chandransh 333 
    def getCartsByTime(self, from_time, to_time, status):
130 ashish 334 
        """
335 
        Parameters:
557 chandransh 336 
         - from_time
337 
         - to_time
338 
         - status
130 ashish 339 
        """
766 rajveer 340 
        try:
341 
            carts = get_carts_between(from_time, to_time, status)
342 
            t_carts = []
343 
            if carts:
344 
                for cart in carts:
345 
                    t_carts.append(to_t_cart(cart))
346 
            return t_carts
347 
        finally:
348 
            CartDataAccessors.close_session()
349 
 
557 chandransh 350 
    def changeCartStatus(self, cartId, status):
130 ashish 351 
        """
352 
        Parameters:
557 chandransh 353 
         - cartId
354 
         - status
130 ashish 355 
        """
766 rajveer 356 
        try:
357 
            change_cart_status(cartId, status)
358 
        finally:
359 
            CartDataAccessors.close_session()
360 
 
557 chandransh 361 
    def addItemToCart(self, cartId, itemId, quantity):
130 ashish 362 
        """
363 
        Parameters:
557 chandransh 364 
         - cartId
365 
         - itemId
366 
         - quantity
130 ashish 367 
        """
766 rajveer 368 
        try:
369 
            add_item_to_cart(cartId, itemId, quantity)
370 
        finally:
371 
            CartDataAccessors.close_session()
372 
 
557 chandransh 373 
    def deleteItemFromCart(self, cartId, itemId):
130 ashish 374 
        """
375 
        Parameters:
557 chandransh 376 
         - cartId
377 
         - itemId
130 ashish 378 
        """
766 rajveer 379 
        try:
380 
            delete_item_from_cart(cartId, itemId)
381 
        finally:
382 
            CartDataAccessors.close_session()
383 
 
557 chandransh 384 
    def changeQuantity(self, cartId, itemId, quantity):
385 
        """
386 
        Parameters:
387 
         - cartId
388 
         - itemId
389 
         - quantity
390 
        """
766 rajveer 391 
        try:
392 
            add_item_to_cart(cartId, itemId, quantity)
393 
        finally:
394 
            CartDataAccessors.close_session()
395 
 
557 chandransh 396 
    def changeItemStatus(self, cartId, itemId, status):
130 ashish 397 
        """
398 
        Parameters:
557 chandransh 399 
         - cartId
400 
         - itemId
401 
        """
766 rajveer 402 
        try:
403 
            return change_item_status(cartId, itemId, status)
404 
        finally:
405 
            CartDataAccessors.close_session()
406 
 
557 chandransh 407 
    def addAddressToCart(self, cartId, addressId):
408 
        """
409 
        Parameters:
410 
         - cartId
130 ashish 411 
         - addressId
412 
        """
766 rajveer 413 
        try:
414 
            return add_address_to_cart(cartId, addressId)
415 
        finally:
416 
            CartDataAccessors.close_session()
417 
 
690 chandransh 418 
    def createOrders(self, cartId):
130 ashish 419 
        """
420 
        Parameters:
557 chandransh 421 
         - cartId
130 ashish 422 
        """
766 rajveer 423 
        try:
424 
            return commit_cart(cartId)
425 
        finally:
426 
            CartDataAccessors.close_session()
1466 ankur.sing 427 
 
557 chandransh 428 
    def validateCart(self, cartId):
130 ashish 429 
        """
1466 ankur.sing 430 
        Validates that:
431 
        1. The checkout timestamp is greater than the updatedOn timestamp.
432 
        2. All of the lines in the cart are active items.
433 
        3. The estimate for any of the lines in cart doesn't change.
434 
        If all three are true, returns empty string; else returns appropriate message.
435 
 
130 ashish 436 
        Parameters:
557 chandransh 437 
         - cartId
130 ashish 438 
        """
766 rajveer 439 
        try:
440 
            return validate_cart(cartId)
441 
        finally:
442 
            CartDataAccessors.close_session()
443 
 
557 chandransh 444 
    def mergeCart(self, fromCartId, toCartId):
513 rajveer 445 
        """
446 
        Parameters:
557 chandransh 447 
         - fromCartId
448 
         - toCartId
513 rajveer 449 
        """
766 rajveer 450 
        try:
451 
            merge_cart(fromCartId, toCartId)
452 
        finally:
453 
            CartDataAccessors.close_session()
454 
 
691 chandransh 455 
    def checkOut(self, cartId):
456 
        """
457 
        Sets the checkedOutOn timestamp of the cart. Raises an exception if the specified cart can't be found.
458 
 
459 
        Parameters:
460 
         - cartId
461 
        """
766 rajveer 462 
        try:
463 
            return check_out(cartId)
464 
        finally:
465 
            CartDataAccessors.close_session()
466 
 
691 chandransh 467 
    def resetCart(self, cartId, items):
468 
        """
469 
        The second parameter is a map of item ids and their quantities which have been successfully processed.
470 
        This methods removes the specified quantiry of the specified item from the cart.
471 
 
472 
        Parameters:
473 
         - cartId
474 
         - items
475 
        """
766 rajveer 476 
        try:
477 
            return reset_cart(cartId, items)
478 
        finally:
479 
            CartDataAccessors.close_session()
772 rajveer 480 
 
481 
    #Widget related methods
482 
    def getMyResearch(self, userId):
483 
        """
484 
        Parameters:
485 
         - user_id
486 
        """
487 
        try:
488 
            return to_t_widget(get_my_research(userId))
489 
        finally:
490 
            WidgetDataAccessor.close_session()
491 
 
492 
    def updateMyResearch(self, userId, itemId):
493 
        """
494 
        Parameters:
495 
         - user_id
496 
         - item_id
497 
        """
498 
        try:
499 
            return update_my_research(userId, itemId)
500 
        finally:
501 
            WidgetDataAccessor.close_session()
502 
 
503 
    def deleteItemFromMyResearch(self, userId, itemId):
504 
        """
505 
        Parameters:
506 
         - user_id
507 
         - item_id
508 
        """
509 
        try:
510 
            return delete_item_from_my_research(userId, itemId)
511 
        finally:
512 
            WidgetDataAccessor.close_session()
766 rajveer 513 
 
772 rajveer 514 
    def updateBrowseHistory(self, userId, itemId):
515 
        """
516 
        Parameters:
517 
        - user_id
518 
        - item_id
519 
        """
520 
        try:
521 
            update_browse_history(userId, itemId)
522 
        finally:
523 
            WidgetDataAccessor.close_session()
524 
 
525 
    def getBrowseHistory(self, userId):
526 
        """
527 
        Parameters:
528 
         - user_id
529 
        """
530 
        try:
531 
            return to_t_widget(get_browse_history(userId))
532 
        finally:
533 
            WidgetDataAccessor.close_session()
534 
 
535 
    def mergeBrowseHistory(self, fromUserId, toUserId):
536 
        """
537 
        Parameters:
538 
         - user_id
539 
        """
540 
        try:
541 
            return merge_browse_history(fromUserId, toUserId)
542 
        finally:
543 
            WidgetDataAccessor.close_session()
544 
 
1273 varun.gupt 545 
    def saveUserCommunication(self, userId, email, communicationType, orderId, awb, product, subject, message):
546 
        """
547 
        Parameters:
548 
         - userId
549 
         - email
550 
         - communicationType
551 
         - orderId
552 
         - awb
553 
         - product
554 
         - subject
555 
         - message
556 
        """
557 
        try:
558 
            return create_user_communication(userId, email, communicationType, orderId, awb, product, subject, message)
559 
        finally:
1605 varun.gupt 560 
            UserDataAccessors.close_session()
1273 varun.gupt 561 
 
1583 varun.gupt 562 
    def getUserCommunicationById(self, id):
563 
        """
564 
        Parameters:
565 
         - id
566 
        """
567 
        try:
568 
            return to_t_user_communication(get_user_communication_by_id(id))
569 
        finally:
1605 varun.gupt 570 
            UserDataAccessors.close_session()
1583 varun.gupt 571 
 
572 
    def getUserCommunicationByUser(self, userId):
573 
        """
574 
        Parameters:
575 
         - userId
576 
        """
577 
        try:
578 
            return [to_t_user_communication(user_communication) for user_communication in get_user_communication_by_user(userId)]
579 
        finally:
1605 varun.gupt 580 
            UserDataAccessors.close_session()
1583 varun.gupt 581 
 
582 
    def getAllUserCommunications(self):
583 
        try:
584 
            return [to_t_user_communication(user_communication) for user_communication in get_all_user_communications()]
585 
        finally:
1605 varun.gupt 586 
            UserDataAccessors.close_session()
1596 ankur.sing 587 
 
1859 vikas 588 
    def createMasterAffiliate(self, name, addedOn):
1845 vikas 589 
        """
590 
        Parameters
591 
         - name
1859 vikas 592 
         - addedOn
1845 vikas 593 
        """
594 
        try:
1859 vikas 595 
            return to_t_master_affiliate(create_master_affiliate(name, addedOn))
1845 vikas 596 
        finally:
597 
            UserDataAccessors.close_session()
598 
 
599 
    def getMasterAffiliateById(self, id):
600 
        """
601 
        Parameters
602 
         - id
603 
        """
604 
        try:
605 
            return to_t_master_affiliate(get_master_affiliate_by_id(id))
606 
        finally:
607 
            UserDataAccessors.close_session()
608 
 
609 
    def getMasterAffiliateByName(self, name):
610 
        """
611 
        Parameters
612 
         - id
613 
        """
614 
        try:
615 
            return to_t_master_affiliate(get_master_affiliate_by_name(name))
616 
        finally:
617 
            UserDataAccessors.close_session()
618 
 
1859 vikas 619 
    def createAffiliate(self, name, url, masterAffiliateId, addedOn):
1845 vikas 620 
        """
621 
        Parameters
622 
         - name
623 
         - url
1859 vikas 624 
         - masterAffiliateId
625 
         - addedOn
1845 vikas 626 
        """
627 
        try:
1859 vikas 628 
            return to_t_affiliate(create_affiliate(name, url, masterAffiliateId, addedOn))
1845 vikas 629 
        finally:
630 
            UserDataAccessors.close_session()
631 
 
632 
    def getAffiliateById(self, id):
633 
        """
634 
        Parameters
635 
         - id
636 
        """
637 
        try:
638 
            return to_t_affiliate(get_affiliate_by_id(id))
639 
        finally:
640 
            UserDataAccessors.close_session()
641 
 
642 
    def getAffiliateByName(self, name):
643 
        """
644 
        Parameters
645 
         - name
646 
        """
647 
        try:
648 
            return to_t_affiliate(get_affiliate_by_name(name))
649 
        finally:
650 
            UserDataAccessors.close_session()
651 
 
652 
    def getAffiliatesByMasterAffiliate(self, master_affiliate_id):
653 
        """
654 
        Parameters
655 
         - master_id
656 
        """
657 
        try:
658 
            return [to_t_affiliate(affiliate) for affiliate in get_affiliates_by_master_affiliate(master_affiliate_id)]
659 
        finally:
660 
            UserDataAccessors.close_session()
661 
 
1859 vikas 662 
    def createTracker(self, affilateId, addedOn):
1845 vikas 663 
        """
664 
        Parameters
665 
         - affiliateId
1859 vikas 666 
         - addedOn
1845 vikas 667 
        """
668 
        try:
1859 vikas 669 
            return to_t_tracker(create_tracker(affilateId, addedOn))
1845 vikas 670 
        finally:
671 
            UserDataAccessors.close_session()
672 
 
673 
    def getTrackerById(self, id):
674 
        """
675 
        Parameters
676 
         - id
677 
        """
678 
        try:
679 
            return to_t_tracker(get_tracker_by_id(id))
680 
        finally:
681 
            UserDataAccessors.close_session()
682 
 
683 
    def getTrackersByAffiliate(self, affiliateId):
684 
        """
685 
        Parameters
686 
         - affiliateId
687 
        """
688 
        try:
689 
            return [to_t_tracker(tracker) for tracker in get_trackers_by_affiliate(affiliateId)]
690 
        finally:
691 
            UserDataAccessors.close_session()
692 
 
1859 vikas 693 
    def addTrackLog(self, trackerId, userId, event, url, data, addedOn):
1845 vikas 694 
        """
695 
        Parameter
696 
         - trackerId
697 
         - userId
698 
         - event
699 
         - url
700 
         - data
1859 vikas 701 
         - addedOn
1845 vikas 702 
        """
703 
        try:
1859 vikas 704 
            return add_track_log(trackerId, userId, event, url, data, addedOn)
1845 vikas 705 
        finally:
706 
            UserDataAccessors.close_session()
707 
 
708 
    def getTrackLogById(self, id):
709 
        """
710 
        Parameter
711 
         - id
712 
        """
713 
        try:
714 
            return to_t_track_log(get_track_log_by_id(id))
715 
        finally:
716 
            UserDataAccessors.close_session()
717 
 
718 
    def getTrackLogsByTracker(self, tracker_id):
719 
        """
720 
        Parameter
721 
         - tracker_id
722 
        """
723 
        try:
724 
            return [to_t_track_log(track_log) for track_log in get_track_logs_by_tracker(tracker_id)]
725 
        finally:
726 
            UserDataAccessors.close_session()
727 
 
728 
    def getTrackLogsByUser(self, user_id):
729 
        """
730 
        Parameter
731 
         - user_id
732 
        """
733 
        try:
734 
            return [to_t_track_log(track_log) for track_log in get_track_logs_by_user(user_id)]
735 
        finally:
736 
            UserDataAccessors.close_session()
737 
 
738 
    def getTrackLogs(self, trackerId, userId, event, url):
739 
        """
740 
        Parameter
741 
         - user_id
742 
        """
743 
        try:
744 
            return [to_t_track_log(track_log) for track_log in get_track_logs(trackerId, userId, event, url)]
745 
        finally:
746 
            UserDataAccessors.close_session()
747 
 
1596 ankur.sing 748 
    def getUserCount(self, userType):
749 
        """
750 
        Returns number of registered users.
1612 ankur.sing 751 
        If userType = null, then it returns count of all users, including anonymous
752 
        If userType = UserType.ANONYMOUS, then it returns count of anonymous users only
753 
        If userType = UserType.USER, then it returns count of non-anonymous users only
1596 ankur.sing 754 
 
755 
        Parameters:
1612 ankur.sing 756 
         - userType
1596 ankur.sing 757 
        """
1673 ankur.sing 758 
        try:
759 
            return UserDataAccessors.get_user_count(userType)
760 
        finally:
761 
            UserDataAccessors.close_session()
762 
 
1891 ankur.sing 763 
    def getAllUsers(self, userType, startDate, endDate):
1673 ankur.sing 764 
        """
765 
        Returns list of users of type userType. If userType is null, then returns all the users.
766 
 
767 
        Parameters:
768 
         - userType
769 
        """
770 
        try:
1891 ankur.sing 771 
            users = UserDataAccessors.get_users(userType, startDate, endDate)
1673 ankur.sing 772 
            t_users = list()
773 
            for user in users:
774 
                t_users.append(to_t_user(user))
775 
            return t_users
776 
        finally:
777 
            UserDataAccessors.close_session()
1583 varun.gupt 778 
 
772 rajveer 779 
    def closeSession(self, ):
780 
        CartDataAccessors.close_session()
781 
        UserDataAccessors.close_session()
782 
        WidgetDataAccessor.close_session()
1596 ankur.sing 783 
 
772 rajveer 784 
 
785 
    '''
557 chandransh 786 
    def addWidget(self, widget):
130 ashish 787 
        """
788 
        Parameters:
557 chandransh 789 
         - widget
130 ashish 790 
        """
766 rajveer 791 
        try:
792 
            add_widget(widget)
793 
        finally:
794 
            WidgetDataAccessor.close_session()
130 ashish 795 
 
557 chandransh 796 
    def addItemToWidget(self, widget_id, items):
130 ashish 797 
        """
798 
        Parameters:
557 chandransh 799 
         - widget_id
800 
         - items
130 ashish 801 
        """
766 rajveer 802 
        try:
803 
            add_items_to_widget(widget_id, items)
804 
        finally:
805 
            WidgetDataAccessor.close_session()
806 
 
557 chandransh 807 
    def updateWidget(self, widgetId, enable):
130 ashish 808 
        """
809 
        Parameters:
557 chandransh 810 
         - widgetId
811 
         - enable
130 ashish 812 
        """
766 rajveer 813 
        try:
814 
            update_widget(widgetId, enable)
815 
        finally:
816 
            WidgetDataAccessor.close_session()
817 
 
557 chandransh 818 
    def updateWidgetItem(self, widgetId, enable):
130 ashish 819 
        """
820 
        Parameters:
557 chandransh 821 
         - widgetId
822 
         - enable
130 ashish 823 
        """
766 rajveer 824 
        try:
825 
            update_widget(widgetId, enable)
826 
        finally:
827 
            WidgetDataAccessor.close_session()
828 
 
557 chandransh 829 
    def deleteItemFromWidget(self, widget_id, item_id):
830 
        """
831 
        Parameters:
832 
         - widget_id
833 
         - item_id
834 
        """
766 rajveer 835 
        try:
836 
            return delete_item_from_widget(widget_id, item_id)
837 
        finally:
838 
            WidgetDataAccessor.close_session()
839 
 
557 chandransh 840 
    def getWidget(self, type, userId, onlyEnabled):
130 ashish 841 
        """
842 
        Parameters:
557 chandransh 843 
         - type
844 
         - userId
845 
         - onlyEnabled
130 ashish 846 
        """
766 rajveer 847 
        try:
848 
            widget = get_widget_by_type(type, userId, onlyEnabled)
849 
            return to_t_widget(widget)
850 
        finally:
851 
            WidgetDataAccessor.close_session()
852 
 
557 chandransh 853 
    def updateRatings(self, item_id, type, rating, user_id):
130 ashish 854 
        """
855 
        Parameters:
557 chandransh 856 
        - item_id
857 
        - type
858 
        - rating
859 
        - user_id
130 ashish 860 
        """
766 rajveer 861 
        try:
862 
            update_ratings(user_id, item_id, rating, type)
863 
        finally:
864 
            WidgetDataAccessor.close_session()
557 chandransh 865 
 
866 
    def getRatings(self, item_id, user_id):
867 
        """
868 
        Parameters:
869 
        - item_id
870 
        - user_id
871 
        """
766 rajveer 872 
        try:
873 
            all_ratings, user_ratings = get_ratings(user_id, item_id)
874 
            return to_t_ratings(user_ratings, all_ratings, item_id, user_id)
875 
        finally:
876 
            WidgetDataAccessor.close_session()
877 
 
772 rajveer 878 
    '''
879