Subversion Repositories SmartDukaan

Rev

Rev 15818 | Blame | Compare with Previous | Last modification | View Log | RSS feed

'''
Created on Jul 8, 2015

@author: amit
'''
from dtr.storage import Mysql
from dtr.storage.DataService import MissingAmazonOrderUsers, \
    PendingToTrackAmazonOrderUsers, initialize
from dtr.utils import utils
from elixir import *
from pymongo.mongo_client import MongoClient








def main():
    #Mysql.deleteTableData(tableName)
    try:
        initialize()
        client = MongoClient('mongodb://localhost:27017/')
        PendingToTrackAmazonOrderUsers.query.delete()
        for userId in client.Dtr.merchantOrder.find({"subOrders.closed":False,"subOrders.trackingUrl":{"$exists":False},"subOrders.trackAfter":{"$lt":utils.getCurrTimeStamp()}}).distinct("userId"):
            user1 = PendingToTrackAmazonOrderUsers()
            user1.user_id = userId
        session.commit()
        MissingAmazonOrderUsers.query.delete()
        for userId in client.Dtr.merchantOrder.find({"status":"html_required"}).distinct("userId"):
            user1 = MissingAmazonOrderUsers()
            user1.user_id = userId
        session.commit()
    finally:
        session.close()






    
if __name__ == '__main__':
    main()