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