Subversion Repositories SmartDukaan

Rev

Rev 13828 | Rev 13849 | Go to most recent revision | Show entire file | Ignore whitespace | Details | Blame | Last modification | View Log | RSS feed

Rev 13828 Rev 13843
Line 3... Line 3...
3 
from shop2020.model.v1.catalog.impl.DataService import PrivateDeals, Item
 3 
from shop2020.model.v1.catalog.impl.DataService import PrivateDeals, Item
4 
from sqlalchemy.sql.functions import now
 4 
from sqlalchemy.sql.functions import now
5 
from datetime import datetime, timedelta
 5 
from datetime import datetime, timedelta
6 
import pymongo
 6 
import pymongo
7 
from dtr.utils.utils import to_java_date
 7 
from dtr.utils.utils import to_java_date
- 
 
 8 
import optparse
8 
 
 9 
 
9 
dealsMap = {}
 10 
dealsMap = {}
10 
con = None
 11 
con = None
11 
dealsCatalogIds = []
 12 
dealsCatalogIds = []
12 
itemCatalogMap = {}
 13 
itemCatalogMap = {}
13 
timestamp = datetime.now()
 14 
timestamp = datetime.now()
14 
print to_java_date(timestamp)
 15 
print to_java_date(timestamp)
15 
 
 16 
 
- 
 
 17 
parser = optparse.OptionParser()
- 
 
 18 
parser.add_option("-H", "--host", dest="hostname",
- 
 
 19 
                      default="localhost",
- 
 
 20 
                      type="string", help="The HOST where the DB server is running",
- 
 
 21 
                      metavar="HOST")
- 
 
 22 
 
16 
DataService.initialize(db_hostname='localhost')
 23 
DataService.initialize(db_hostname=options.hostname)
17 
 
 24 
 
18 
def get_mongo_connection(host='localhost', port=27017):
 25 
def get_mongo_connection(host='localhost', port=27017):
19 
    global con
 26 
    global con
20 
    if con is None:
 27 
    if con is None:
21 
        print "Establishing connection %s host and port %d" %(host,port)
 28 
        print "Establishing connection %s host and port %d" %(host,port)