| Line 1837... |
Line 1837... |
| 1837 |
return 'MEDIUM'
|
1837 |
return 'MEDIUM'
|
| 1838 |
else:
|
1838 |
else:
|
| 1839 |
return 'LOW'
|
1839 |
return 'LOW'
|
| 1840 |
|
1840 |
|
| 1841 |
def groupData(previousTimestamp,timestampNow):
|
1841 |
def groupData(previousTimestamp,timestampNow):
|
| - |
|
1842 |
print "inside grouping data*****"
|
| 1842 |
previousData = session.query(MarketPlaceHistory).filter(MarketPlaceHistory.timestamp==previousTimestamp).filter(MarketPlaceHistory.source==OrderSource.SNAPDEAL).all()
|
1843 |
previousData = session.query(MarketPlaceHistory).filter(MarketPlaceHistory.timestamp==previousTimestamp).filter(MarketPlaceHistory.source==OrderSource.SNAPDEAL).all()
|
| 1843 |
for data in previousData:
|
1844 |
for data in previousData:
|
| 1844 |
latestItemData = session.query(MarketPlaceHistory).filter(MarketPlaceHistory.timestamp==timestampNow).filter(MarketPlaceHistory.source==OrderSource.SNAPDEAL).filter(MarketPlaceHistory.item_id==data.item_id).first()
|
1845 |
latestItemData = session.query(MarketPlaceHistory).filter(MarketPlaceHistory.timestamp==timestampNow).filter(MarketPlaceHistory.source==OrderSource.SNAPDEAL).filter(MarketPlaceHistory.item_id==data.item_id).first()
|
| 1845 |
if latestItemData is None:
|
1846 |
if latestItemData is None:
|
| 1846 |
continue
|
1847 |
continue
|
| 1847 |
if data.ourSellingPrice == latestItemData.ourSellingPrice and data.ourOfferPrice == latestItemData.ourOfferPrice and data.competitiveCategory == latestItemData.competitiveCategory:
|
1848 |
if data.ourSellingPrice == latestItemData.ourSellingPrice and data.ourOfferPrice == latestItemData.ourOfferPrice and data.competitiveCategory == latestItemData.competitiveCategory:
|
| - |
|
1849 |
print "yes found",data.item_id
|
| 1848 |
if data.toGroup is None:
|
1850 |
if data.toGroup is None:
|
| 1849 |
data.toGroup=False
|
1851 |
data.toGroup=False
|
| 1850 |
latestItemData.toGroup=True
|
1852 |
latestItemData.toGroup=True
|
| 1851 |
else:
|
1853 |
else:
|
| 1852 |
latestItemData.toGroup=True
|
1854 |
latestItemData.toGroup=True
|
| 1853 |
data.toGroup=False
|
1855 |
data.toGroup=False
|
| 1854 |
else:
|
1856 |
else:
|
| 1855 |
latestItemData=None
|
1857 |
latestItemData=None
|
| 1856 |
session.commit()
|
1858 |
session.commit()
|
| - |
|
1859 |
print "commit****"
|
| - |
|
1860 |
time.sleep(10)
|
| - |
|
1861 |
|
| 1857 |
|
1862 |
|
| 1858 |
def main():
|
1863 |
def main():
|
| 1859 |
parser = optparse.OptionParser()
|
1864 |
parser = optparse.OptionParser()
|
| 1860 |
parser.add_option("-t", "--type", dest="runType",
|
1865 |
parser.add_option("-t", "--type", dest="runType",
|
| 1861 |
default="FULL", type="string",
|
1866 |
default="FULL", type="string",
|