Rev 15814 | Go to most recent revision | Blame | Compare with Previous | Last modification | View Log | RSS feed
'''Created on Jul 8, 2015@author: amit'''from dtr.storage import Mysqlfrom dtr.storage.DataService import MissingAmazonOrderUsers, \PendingToTrackAmazonOrderUsers, initializefrom elixir import *from pymongo.mongo_client import MongoClientdef main():#Mysql.deleteTableData(tableName)try:initialize()client = MongoClient('mongodb://localhost:27017/')PendingToTrackAmazonOrderUsers.query.delete()for userId in client.Dtr.merchantOrder.find({"status":"html_required"}).distinct("userId"):user1 = PendingToTrackAmazonOrderUsers()user1.user_id = userIdsession.commit()MissingAmazonOrderUsers.query.delete()for userId in client.Dtr.merchantOrder.find({"subOrders.closed":False,"subOrders.trackingUrl":{"$exists":True}}).distinct("userId"):user1 = MissingAmazonOrderUsers()user1.user_id = userIdsession.commit()finally:session.close()if __name__ == '__main__':main()