Subversion Repositories SmartDukaan

Rev

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

Rev 2895 Rev 2981
Line 2... Line 2...
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.model.v1.user.impl import Dataservice
6
from shop2020.model.v1.user.impl import Dataservice
7
from shop2020.utils.Utils import log_entry, to_py_date, to_java_date
7
from shop2020.utils.Utils import log_entry, to_py_date
-
 
8
from shop2020.thriftpy.model.v1.user.ttypes import WidgetType as WType
8
from shop2020.model.v1.user.impl.Dataservice import User, UserCommunication, IPMap,\
9
from shop2020.model.v1.user.impl.Dataservice import User, UserCommunication, IPMap,\
9
    Address, SocialHandle, UserState, InternalInfo, SocialService, Affiliate, Tracker, TrackLog,\
10
    Address, SocialHandle, UserState, InternalInfo, SocialService, Affiliate, Tracker, TrackLog,\
10
    MasterAffiliate, UserNote
11
    MasterAffiliate, UserNote, UserWidgetItem
11
from shop2020.thriftpy.model.v1.user.ttypes import UserContextException,\
12
from shop2020.thriftpy.model.v1.user.ttypes import UserContextException,\
12
    AuthenticationException, AccountStatus, Sex
13
    AuthenticationException, AccountStatus, Sex
13
from shop2020.clients.HelperClient import HelperClient
-
 
14
from elixir import session
14
from elixir import session
15
import datetime, random, string
15
import datetime
16
from shop2020.thriftpy.utils.ttypes import Mail
16
from sqlalchemy import desc
-
 
17
 
17
 
18
 
18
def initialize(dbname='user'):
19
def initialize(dbname='user'):
19
    log_entry("initialize@DataAccessor", "Initializing data service")
20
    log_entry("initialize@DataAccessor", "Initializing data service")
20
    Dataservice.initialize(dbname)
21
    Dataservice.initialize(dbname)
21
 
22
 
Line 513... Line 514...
513
        user_note = user_notes.pop()
514
        user_note = user_notes.pop()
514
        user_note.note = note
515
        user_note.note = note
515
    
516
    
516
    session.commit()
517
    session.commit()
517
 
518
 
-
 
519
 
-
 
520
def get_my_research_items(userId):
-
 
521
    query = UserWidgetItem.query.filter_by(userId=userId)
-
 
522
    query = query.filter_by(widgetId=WType.MY_RESEARCH)
-
 
523
    query = query.order_by(desc(UserWidgetItem.addedOn))
-
 
524
    widgetItems = query.all()
-
 
525
    return [widgetItem.itemId for widgetItem in widgetItems]
-
 
526
    
-
 
527
def get_browse_history_items(userId):
-
 
528
    query = UserWidgetItem.query.filter_by(userId=userId)
-
 
529
    query = query.filter_by(widgetId=WType.BROWSE_HISTORY)
-
 
530
    query = query.order_by(desc(UserWidgetItem.addedOn)).limit(10)
-
 
531
    widgetItems = query.all()
-
 
532
    return [widgetItem.itemId for widgetItem in widgetItems]
-
 
533
        
-
 
534
def update_my_research(userId, itemId):
-
 
535
    isNew = False
-
 
536
    query = UserWidgetItem.query.filter_by(userId=userId)
-
 
537
    query = query.filter_by(widgetId=WType.MY_RESEARCH)
-
 
538
    query = query.filter_by(itemId=itemId)
-
 
539
    widgetItem = query.first()
-
 
540
    if not widgetItem:
-
 
541
        isNew = True
-
 
542
        widgetItem = UserWidgetItem()
-
 
543
        widgetItem.userId = userId
-
 
544
        widgetItem.widgetId = WType.MY_RESEARCH
-
 
545
        widgetItem.itemId = itemId  
-
 
546
    widgetItem.addedOn = datetime.datetime.now()
-
 
547
    session.commit()
-
 
548
    return isNew
-
 
549
 
-
 
550
def update_browse_history(userId, itemId):
-
 
551
    query = UserWidgetItem.query.filter_by(userId=userId)
-
 
552
    query = query.filter_by(widgetId=WType.BROWSE_HISTORY)
-
 
553
    query = query.filter_by(itemId=itemId)
-
 
554
    widgetItem = query.first()
-
 
555
    if not widgetItem:
-
 
556
        widgetItem = UserWidgetItem()
-
 
557
        widgetItem.userId = userId
-
 
558
        widgetItem.widgetId = WType.BROWSE_HISTORY
-
 
559
        widgetItem.itemId = itemId
-
 
560
    widgetItem.addedOn = datetime.datetime.now()
-
 
561
    session.commit()
-
 
562
 
-
 
563
def delete_item_from_my_research(userId, itemId):
-
 
564
    query = UserWidgetItem.query.filter_by(userId=userId)
-
 
565
    query = query.filter_by(widgetId=WType.MY_RESEARCH)
-
 
566
    query = query.filter_by(itemId=itemId)
-
 
567
    widgetItem = query.first()
-
 
568
    if widgetItem:
-
 
569
        widgetItem.delete()
-
 
570
        session.commit()
-
 
571
    else:
-
 
572
        print "Not item in my research to delete with itemId" + itemId
-
 
573
 
518
def close_session():
574
def close_session():
519
    if session.is_active:
575
    if session.is_active:
520
        print "session is active. closing it."
576
        print "session is active. closing it."
521
        session.close()      
577
        session.close()      
522
578