| Line 4... |
Line 4... |
| 4 |
|
4 |
|
| 5 |
@author: amit
|
5 |
@author: amit
|
| 6 |
'''
|
6 |
'''
|
| 7 |
from base64 import encode
|
7 |
from base64 import encode
|
| 8 |
from bs4 import BeautifulSoup
|
8 |
from bs4 import BeautifulSoup
|
| 9 |
from datetime import datetime, timedelta
|
9 |
from datetime import datetime, timedelta, date
|
| 10 |
from dtr.api.Order import process_rejects
|
10 |
from dtr.api.Order import process_rejects
|
| 11 |
from dtr.dao import Order, SubOrder, AmazonAffiliateInfo
|
11 |
from dtr.dao import Order, SubOrder, AmazonAffiliateInfo
|
| 12 |
from dtr.main import getStore, Store as MStore, ParseException, getBrowserObject, \
|
12 |
from dtr.main import getStore, Store as MStore, ParseException, getBrowserObject, \
|
| 13 |
ungzipResponse, tprint
|
13 |
ungzipResponse, tprint
|
| 14 |
from dtr.sources.flipkart import todict, AFF_REPORT_URL
|
14 |
from dtr.sources.flipkart import todict, AFF_REPORT_URL
|
| Line 655... |
Line 655... |
| 655 |
session.close()
|
655 |
session.close()
|
| 656 |
|
656 |
|
| 657 |
|
657 |
|
| 658 |
|
658 |
|
| 659 |
def main():
|
659 |
def main():
|
| - |
|
660 |
getSummaryFile("/AmazonTrack/User8703/")
|
| 660 |
#process_rejects("/home/amit/Downloads/RejectCashbackTemplate.xlsx")
|
661 |
#process_rejects("/home/amit/Downloads/RejectCashbackTemplate.xlsx")
|
| 661 |
#str1 = readSSh("/AmazonTrack/User2466/orderSummary28-06:13:25:08")
|
662 |
#str1 = readSSh("/AmazonTrack/User2466/orderSummary28-06:13:25:08")
|
| 662 |
#str1 = readSSh("/AmazonTrack/User2466/orderSummary24-06:17:38:04")
|
663 |
#str1 = readSSh("/AmazonTrack/User2466/orderSummary24-06:17:38:04")
|
| 663 |
#str1 = readSSh("/AmazonTrack/User2466/orderSummary24-06:17:38:01")
|
664 |
#str1 = readSSh("/AmazonTrack/User2466/orderSummary24-06:17:38:01")
|
| 664 |
#str1 = readSSh("/AmazonTrack/User2466/orderSummary24-06:17:31:53")
|
665 |
#str1 = readSSh("/AmazonTrack/User2466/orderSummary24-06:17:31:53")
|
| Line 683... |
Line 684... |
| 683 |
#store.trackOrdersForUser(4355, "https://www.amazon.in/gp/css/summary/edit.html?orderID=171-4824011-7090713", readSSh("~/4355"))
|
684 |
#store.trackOrdersForUser(4355, "https://www.amazon.in/gp/css/summary/edit.html?orderID=171-4824011-7090713", readSSh("~/4355"))
|
| 684 |
#readSSh("/tmp/User211/2015-04-12 10:32:41.905765")
|
685 |
#readSSh("/tmp/User211/2015-04-12 10:32:41.905765")
|
| 685 |
#store.scrapeAffiliate()
|
686 |
#store.scrapeAffiliate()
|
| 686 |
#parseDetailNotCreated()
|
687 |
#parseDetailNotCreated()
|
| 687 |
#parseOrderNotCreated()
|
688 |
#parseOrderNotCreated()
|
| - |
|
689 |
for userId in store.db.merchantOrder.find({"storeId":1, "closed":True, "subOrders.closed":False}).distinct("userId"):
|
| - |
|
690 |
print userId
|
| - |
|
691 |
directory = "/AmazonTrack/User" + str(userId) + "/"
|
| - |
|
692 |
summaryFile=getSummaryFile(directory)
|
| - |
|
693 |
if summaryFile is None:
|
| - |
|
694 |
print "No summary for", userId
|
| - |
|
695 |
else:
|
| - |
|
696 |
print userId, directory+summaryFile
|
| - |
|
697 |
#store.trackOrdersForUser(userId, 'https://www.amazon.in/gp/css/order-history', readSSh(directory + summaryFile))
|
| - |
|
698 |
|
| 688 |
store.trackOrdersForUser(8703, 'https://www.amazon.in/gp/css/order-history', readSSh('/home/amit/Downloads/orderSummary06-10_12_15_54'))
|
699 |
#store.trackOrdersForUser(8703, 'https://www.amazon.in/gp/css/order-history', readSSh('/home/amit/Downloads/orderSummary06-10_12_15_54'))
|
| - |
|
700 |
|
| - |
|
701 |
def getSummaryFile(directory):
|
| - |
|
702 |
date1 = datetime(2015,1,1)
|
| - |
|
703 |
finalFile = None
|
| - |
|
704 |
try:
|
| - |
|
705 |
for file in os.listdir(directory):
|
| - |
|
706 |
if file.startswith("orderSummary"):
|
| - |
|
707 |
date2 = datetime.strptime("2015-" + file.split("orderSummary")[1].split(":")[0], "%Y-%d-%m")
|
| - |
|
708 |
if date2 > date1:
|
| - |
|
709 |
date1 = date2
|
| - |
|
710 |
finalFile=file
|
| - |
|
711 |
except:
|
| - |
|
712 |
print "Missing directory"
|
| - |
|
713 |
return finalFile
|
| - |
|
714 |
|
| 689 |
|
715 |
|
| 690 |
def parseDetailNotCreated():
|
716 |
def parseDetailNotCreated():
|
| 691 |
try:
|
717 |
try:
|
| 692 |
store=getStore(1)
|
718 |
store=getStore(1)
|
| 693 |
orders = session.query(OrdersRaw).filter_by(status='DETAIL_NOT_CREATED_UNKNOWN').all()
|
719 |
orders = session.query(OrdersRaw).filter_by(status='DETAIL_NOT_CREATED_UNKNOWN').all()
|