| Line 22... |
Line 22... |
| 22 |
import paramiko
|
22 |
import paramiko
|
| 23 |
import re
|
23 |
import re
|
| 24 |
import time
|
24 |
import time
|
| 25 |
import traceback
|
25 |
import traceback
|
| 26 |
import urllib2
|
26 |
import urllib2
|
| - |
|
27 |
from dtr.storage.Mongo import getDealRank
|
| 27 |
|
28 |
|
| 28 |
ORDER_REDIRECT_URL = 'https://www.amazon.in/gp/css/summary/edit.html?orderID=%s'
|
29 |
ORDER_REDIRECT_URL = 'https://www.amazon.in/gp/css/summary/edit.html?orderID=%s'
|
| 29 |
ORDER_SUCCESS_URL = 'https://www.amazon.in/gp/buy/spc/handlers/static-submit-decoupled.html'
|
30 |
ORDER_SUCCESS_URL = 'https://www.amazon.in/gp/buy/spc/handlers/static-submit-decoupled.html'
|
| 30 |
THANKYOU_URL = 'https://www.amazon.in/gp/buy/thankyou/handlers/display.html'
|
31 |
THANKYOU_URL = 'https://www.amazon.in/gp/buy/thankyou/handlers/display.html'
|
| 31 |
AMAZON_AFF_URL = 'https://assoc-datafeeds-eu.amazon.com/datafeed/listReports'
|
32 |
AMAZON_AFF_URL = 'https://assoc-datafeeds-eu.amazon.com/datafeed/listReports'
|
| Line 233... |
Line 234... |
| 233 |
createdOn = datetime.fromtimestamp(merchantOrder.createdOnInt)
|
234 |
createdOn = datetime.fromtimestamp(merchantOrder.createdOnInt)
|
| 234 |
subOrder.trackAfter = int(time.mktime(max(estDlvyTime-timedelta(days=4),createdOn + timedelta(days=3)).timetuple()))
|
235 |
subOrder.trackAfter = int(time.mktime(max(estDlvyTime-timedelta(days=4),createdOn + timedelta(days=3)).timetuple()))
|
| 235 |
subOrder.productCode = productUrl.split('/')[5]
|
236 |
subOrder.productCode = productUrl.split('/')[5]
|
| 236 |
subOrder.detailedStatus = detailedStatus
|
237 |
subOrder.detailedStatus = detailedStatus
|
| 237 |
(cashbackAmount, percentage) = self.getCashbackAmount(subOrder.productCode, unitPrice*quantity)
|
238 |
(cashbackAmount, percentage) = self.getCashbackAmount(subOrder.productCode, unitPrice*quantity)
|
| - |
|
239 |
dealRank = getDealRank(subOrder.productCode, self.store_id, merchantOrder.userId)
|
| - |
|
240 |
subOrder.dealRank = dealRank.get('rank')
|
| - |
|
241 |
subOrder.rankDesc = dealRank.get('description')
|
| 238 |
cashbackStatus = Store.CB_PENDING
|
242 |
cashbackStatus = Store.CB_PENDING
|
| 239 |
if cashbackAmount <= 0:
|
243 |
if cashbackAmount <= 0:
|
| 240 |
cashbackStatus = Store.CB_NA
|
244 |
cashbackStatus = Store.CB_NA
|
| 241 |
subOrder.cashBackStatus = cashbackStatus
|
245 |
subOrder.cashBackStatus = cashbackStatus
|
| 242 |
subOrder.cashBackAmount = cashbackAmount
|
246 |
subOrder.cashBackAmount = cashbackAmount
|
| Line 332... |
Line 336... |
| 332 |
subOrder.trackAfter = int(time.mktime(max(estDlvyTime-timedelta(days=4),createdOn + timedelta(days=3)).timetuple()))
|
336 |
subOrder.trackAfter = int(time.mktime(max(estDlvyTime-timedelta(days=4),createdOn + timedelta(days=3)).timetuple()))
|
| 333 |
subOrder.detailedStatus = subOrderStatus
|
337 |
subOrder.detailedStatus = subOrderStatus
|
| 334 |
subOrder.deliveryCharges = shippingPrice
|
338 |
subOrder.deliveryCharges = shippingPrice
|
| 335 |
subOrder.imgUrl = imgDiv.img["src"]
|
339 |
subOrder.imgUrl = imgDiv.img["src"]
|
| 336 |
(cashbackAmount, percentage) = self.getCashbackAmount(subOrder.productCode, amountPaid)
|
340 |
(cashbackAmount, percentage) = self.getCashbackAmount(subOrder.productCode, amountPaid)
|
| - |
|
341 |
dealRank = getDealRank(subOrder.productCode, self.store_id, merchantOrder.userId)
|
| - |
|
342 |
subOrder.dealRank = dealRank.get('rank')
|
| - |
|
343 |
subOrder.rankDesc = dealRank.get('description')
|
| 337 |
cashbackStatus = Store.CB_PENDING
|
344 |
cashbackStatus = Store.CB_PENDING
|
| 338 |
if cashbackAmount <= 0:
|
345 |
if cashbackAmount <= 0:
|
| 339 |
cashbackStatus = Store.CB_NA
|
346 |
cashbackStatus = Store.CB_NA
|
| 340 |
subOrder.cashBackStatus = cashbackStatus
|
347 |
subOrder.cashBackStatus = cashbackStatus
|
| 341 |
subOrder.cashBackAmount = cashbackAmount
|
348 |
subOrder.cashBackAmount = cashbackAmount
|
| Line 563... |
Line 570... |
| 563 |
|
570 |
|
| 564 |
|
571 |
|
| 565 |
|
572 |
|
| 566 |
|
573 |
|
| 567 |
def main():
|
574 |
def main():
|
| 568 |
str1 = readSSh("/home/amit/2809")
|
575 |
#str1 = readSSh("/AmazonTrack/User533/403-3748792-1516356")
|
| 569 |
#readSSh("/tmp/User2/404-2225153-7073122")
|
576 |
#readSSh("/tmp/User2/404-2225153-7073122")
|
| 570 |
|
577 |
|
| 571 |
store = getStore(1)
|
578 |
store = getStore(1)
|
| 572 |
#store.scrapeStoreOrders()
|
579 |
#store.scrapeStoreOrders()
|
| 573 |
# br = mechanize.Browser()
|
580 |
# br = mechanize.Browser()
|
| Line 575... |
Line 582... |
| 575 |
# ('Accept', 'text/html,application/xhtml+xml,application/json,application/xml;q=0.9,*/*;q=0.8'),
|
582 |
# ('Accept', 'text/html,application/xhtml+xml,application/json,application/xml;q=0.9,*/*;q=0.8'),
|
| 576 |
# ('Accept-Encoding', 'gzip,deflate,sdch'),
|
583 |
# ('Accept-Encoding', 'gzip,deflate,sdch'),
|
| 577 |
# ('Accept-Language', 'en-US,en;q=0.8'),
|
584 |
# ('Accept-Language', 'en-US,en;q=0.8'),
|
| 578 |
# ('Accept-Charset', 'ISO-8859-1,utf-8;q=0.7,*;q=0.3')]
|
585 |
# ('Accept-Charset', 'ISO-8859-1,utf-8;q=0.7,*;q=0.3')]
|
| 579 |
# store.scrapeStoreOrders()
|
586 |
# store.scrapeStoreOrders()
|
| 580 |
#store.parseOrderRawHtml(1306, "13232", 14, readSSh("/home/amit/2158.html"), "https://www.amazon.in/gp/buy/spc/handlers/static-submit-decoupled.html/ref=ox_spc_place_order?ie=UTF8&fromAnywhere=1&hasWorkingJav")
|
587 |
store.parseOrderRawHtml(1306, "13232", 14, readSSh("/AmazonTrack/User533/403-3748792-1516356"), "https://www.amazon.in/gp/css/summary/edit.html?orderID=403-3748792-1516356")
|
| 581 |
store.trackOrdersForUser(94, "https://www.amazon.in/gp/css/summary/edit.html?orderID=404-5725877-2507524", str1)
|
588 |
#store.trackOrdersForUser(94, "https://www.amazon.in/gp/css/summary/edit.html?orderID=404-5725877-2507524", str1)
|
| 582 |
#readSSh("/tmp/User211/2015-04-12 10:32:41.905765")
|
589 |
#readSSh("/tmp/User211/2015-04-12 10:32:41.905765")
|
| 583 |
#store.scrapeAffiliate()
|
590 |
#store.scrapeAffiliate()
|
| 584 |
def readSSh(fileName):
|
591 |
def readSSh(fileName):
|
| 585 |
try:
|
592 |
try:
|
| 586 |
str1 = open(fileName).read()
|
593 |
str1 = open(fileName).read()
|