Subversion Repositories SmartDukaan

'''

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()