Subversion Repositories SmartDukaan

Rev

Rev 15818 | Show entire file | Ignore whitespace | Details | Blame | Last modification | View Log | RSS feed

Rev 15818 Rev 16166
Line 4... Line 4...
4 
@author: amit
 4 
@author: amit
5 
'''
 5 
'''
6 
from dtr.storage import Mysql
 6 
from dtr.storage import Mysql
7 
from dtr.storage.DataService import MissingAmazonOrderUsers, \
 7 
from dtr.storage.DataService import MissingAmazonOrderUsers, \
8 
    PendingToTrackAmazonOrderUsers, initialize
 8 
    PendingToTrackAmazonOrderUsers, initialize
- 
 
 9 
from dtr.utils import utils
9 
from elixir import *
 10 
from elixir import *
10 
from pymongo.mongo_client import MongoClient
 11 
from pymongo.mongo_client import MongoClient
11 
 
 12 
 
12 
 
 13 
 
13 
 
 14 
 
Line 20... Line 21...
20 
    #Mysql.deleteTableData(tableName)
 21 
    #Mysql.deleteTableData(tableName)
21 
    try:
 22 
    try:
22 
        initialize()
 23 
        initialize()
23 
        client = MongoClient('mongodb://localhost:27017/')
 24 
        client = MongoClient('mongodb://localhost:27017/')
24 
        PendingToTrackAmazonOrderUsers.query.delete()
 25 
        PendingToTrackAmazonOrderUsers.query.delete()
25 
        for userId in client.Dtr.merchantOrder.find({"status":"html_required"}).distinct("userId"):
 26 
        for userId in client.Dtr.merchantOrder.find({"subOrders.closed":False,"subOrders.trackingUrl":{"$exists":False},"subOrders.trackAfter":{"$lt":utils.getCurrTimeStamp()}}).distinct("userId"):
26 
            user1 = PendingToTrackAmazonOrderUsers()
 27 
            user1 = PendingToTrackAmazonOrderUsers()
27 
            user1.user_id = userId
 28 
            user1.user_id = userId
28 
        session.commit()
 29 
        session.commit()
29 
        MissingAmazonOrderUsers.query.delete()
 30 
        MissingAmazonOrderUsers.query.delete()
30 
        for userId in client.Dtr.merchantOrder.find({"subOrders.closed":False,"subOrders.trackingUrl":{"$exists":True}}).distinct("userId"):
 31 
        for userId in client.Dtr.merchantOrder.find({"status":"html_required"}).distinct("userId"):
31 
            user1 = MissingAmazonOrderUsers()
 32 
            user1 = MissingAmazonOrderUsers()
32 
            user1.user_id = userId
 33 
            user1.user_id = userId
33 
        session.commit()
 34 
        session.commit()
34 
    finally:
 35 
    finally:
35 
        session.close()
 36 
        session.close()