| Line 5... |
Line 5... |
| 5 |
'''
|
5 |
'''
|
| 6 |
from datetime import date, datetime, timedelta
|
6 |
from datetime import date, datetime, timedelta
|
| 7 |
from dtr.main import Store, sourceMap
|
7 |
from dtr.main import Store, sourceMap
|
| 8 |
from dtr.reports.amazonreco import generateAmazonReco
|
8 |
from dtr.reports.amazonreco import generateAmazonReco
|
| 9 |
from dtr.storage import Mysql
|
9 |
from dtr.storage import Mysql
|
| - |
|
10 |
from dtr.storage.DataService import Users, Clicks
|
| 10 |
from dtr.storage.Mysql import getOrdersAfterDate, getOrdersByTag
|
11 |
from dtr.storage.Mysql import getOrdersAfterDate, getOrdersByTag
|
| - |
|
12 |
from dtr.utils.utils import fromTimeStamp
|
| - |
|
13 |
from elixir import *
|
| 11 |
from email import encoders
|
14 |
from email import encoders
|
| 12 |
from email.mime.base import MIMEBase
|
15 |
from email.mime.base import MIMEBase
|
| 13 |
from email.mime.multipart import MIMEMultipart
|
16 |
from email.mime.multipart import MIMEMultipart
|
| 14 |
from email.mime.text import MIMEText
|
17 |
from email.mime.text import MIMEText
|
| 15 |
from pymongo.mongo_client import MongoClient
|
18 |
from pymongo.mongo_client import MongoClient
|
| Line 18... |
Line 21... |
| 18 |
from xlwt.Workbook import Workbook
|
21 |
from xlwt.Workbook import Workbook
|
| 19 |
import MySQLdb
|
22 |
import MySQLdb
|
| 20 |
import smtplib
|
23 |
import smtplib
|
| 21 |
import time
|
24 |
import time
|
| 22 |
import xlwt
|
25 |
import xlwt
|
| 23 |
from dtr.utils.utils import fromTimeStamp
|
- |
|
| 24 |
#from xlwt import
|
26 |
#from xlwt import
|
| 25 |
|
27 |
|
| 26 |
client = MongoClient('mongodb://localhost:27017/')
|
28 |
client = MongoClient('mongodb://localhost:27017/')
|
| 27 |
|
29 |
|
| 28 |
SENDER = "cnc.center@shop2020.in"
|
30 |
SENDER = "cnc.center@shop2020.in"
|
| Line 520... |
Line 522... |
| 520 |
wb = copy(rb)
|
522 |
wb = copy(rb)
|
| 521 |
worksheet = wb.add_sheet("All Users")
|
523 |
worksheet = wb.add_sheet("All Users")
|
| 522 |
worksheet1 = wb.add_sheet("Suspected Users")
|
524 |
worksheet1 = wb.add_sheet("Suspected Users")
|
| 523 |
workbook = xlwt.Workbook()
|
525 |
workbook = xlwt.Workbook()
|
| 524 |
sh1 = workbook.add_sheet("All Orders")
|
526 |
sh1 = workbook.add_sheet("All Orders")
|
| - |
|
527 |
sh2 = workbook.add_sheet("Flipkart Orders")
|
| 525 |
|
528 |
|
| 526 |
db=client.Dtr
|
529 |
db=client.Dtr
|
| 527 |
results = Mysql.fetchResult('''
|
530 |
results = Mysql.fetchResult('''
|
| 528 |
select ow.*, u.username, crm1.order_count, u.referrer from order_view ow left join users u on u.id = ow.user_id left join (select user_id, count(*) as order_count from order_view where status = 'ORDER_CREATED' group by user_id) as crm1 on ow.user_id = crm1.user_id where lower(u.referrer) not like 'emp%' or u.referrer is null;
|
531 |
select ow.*, u.username, crm1.order_count, u.referrer from order_view ow left join users u on u.id = ow.user_id left join (select user_id, count(*) as order_count from order_view where status = 'ORDER_CREATED' group by user_id) as crm1 on ow.user_id = crm1.user_id where lower(u.referrer) not like 'emp%' or u.referrer is null;
|
| 529 |
''',)
|
532 |
''',)
|
| Line 570... |
Line 573... |
| 570 |
sh1.write(row, inc(), 'Amount Paid', boldStyle)
|
573 |
sh1.write(row, inc(), 'Amount Paid', boldStyle)
|
| 571 |
sh1.write(row, inc(), 'Catalog Id', boldStyle)
|
574 |
sh1.write(row, inc(), 'Catalog Id', boldStyle)
|
| 572 |
sh1.write(row, inc(), 'Brand', boldStyle)
|
575 |
sh1.write(row, inc(), 'Brand', boldStyle)
|
| 573 |
sh1.write(row, inc(), 'Model', boldStyle)
|
576 |
sh1.write(row, inc(), 'Model', boldStyle)
|
| 574 |
sh1.write(row, inc(), 'Category', boldStyle)
|
577 |
sh1.write(row, inc(), 'Category', boldStyle)
|
| - |
|
578 |
i =-1
|
| - |
|
579 |
sh2.write(row, inc(), 'User Id', boldStyle)
|
| - |
|
580 |
sh2.write(row, inc(), 'User name', boldStyle)
|
| - |
|
581 |
sh2.write(row, inc(), 'Created On', boldStyle)
|
| - |
|
582 |
sh2.write(row, inc(), 'Store', boldStyle)
|
| - |
|
583 |
sh2.write(row, inc(), 'Status', boldStyle)
|
| - |
|
584 |
sh2.write(row, inc(), 'Product title', boldStyle)
|
| - |
|
585 |
sh2.write(row, inc(), 'Price', boldStyle)
|
| - |
|
586 |
sh2.write(row, inc(), 'Quantity', boldStyle)
|
| - |
|
587 |
sh2.write(row, inc(), 'Catalog Id', boldStyle)
|
| - |
|
588 |
sh2.write(row, inc(), 'Brand', boldStyle)
|
| - |
|
589 |
sh2.write(row, inc(), 'Model', boldStyle)
|
| - |
|
590 |
sh2.write(row, inc(), 'Category', boldStyle)
|
| 575 |
|
591 |
|
| 576 |
row=0
|
592 |
row=0
|
| 577 |
row2=0
|
593 |
row2=0
|
| 578 |
row3=0
|
594 |
row3=0
|
| 579 |
db1 = client.Catalog
|
595 |
db1 = client.Catalog
|
| Line 648... |
Line 664... |
| 648 |
if morder.get("reconciled") and morder.get("storeId")==3:
|
664 |
if morder.get("reconciled") and morder.get("storeId")==3:
|
| 649 |
try:
|
665 |
try:
|
| 650 |
worksheet1.write(row2, inc(), db.snapdealOrderAffiliateInfo.find_one({"adId":morder.get("adId"), "reconciled":True}).get("ip"))
|
666 |
worksheet1.write(row2, inc(), db.snapdealOrderAffiliateInfo.find_one({"adId":morder.get("adId"), "reconciled":True}).get("ip"))
|
| 651 |
except:
|
667 |
except:
|
| 652 |
print "Could not find", morder.get("adId"), "that is reconcired for order", morder.get("orderId")
|
668 |
print "Could not find", morder.get("adId"), "that is reconcired for order", morder.get("orderId")
|
| - |
|
669 |
|
| - |
|
670 |
info = list(db.flipkartAffiliateInfo.find()).reverse()
|
| - |
|
671 |
row3=0
|
| - |
|
672 |
for order in info:
|
| - |
|
673 |
userId = None
|
| - |
|
674 |
subTagId = None
|
| - |
|
675 |
email = None
|
| - |
|
676 |
subTagId = order.get("subTagId")
|
| - |
|
677 |
if subTagId:
|
| - |
|
678 |
userId = session.query(Clicks).filter_by(tag=subTagId).first()
|
| - |
|
679 |
if userId is not None:
|
| - |
|
680 |
email = session.query(Users).filter_by(id = userId).first()
|
| - |
|
681 |
|
| - |
|
682 |
row3 += 1
|
| - |
|
683 |
i=-1
|
| - |
|
684 |
sh2.write(row3, inc(), userId)
|
| - |
|
685 |
sh2.write(row3, inc(), email)
|
| - |
|
686 |
sh2.write(row3, inc(), datetime.strptime(order.get("saleDate"), "%Y-%m-%d"), datetime_format)
|
| - |
|
687 |
sh2.write(row3, inc(), "Flipkart")
|
| - |
|
688 |
sh2.write(row3, inc(), order.get("conversionStatus"))
|
| - |
|
689 |
sh2.write(row3, inc(), order.get("productTitle"))
|
| - |
|
690 |
sh2.write(row3, inc(), order.get("price"))
|
| - |
|
691 |
sh2.write(row3, inc(), order.get("quantity"))
|
| - |
|
692 |
skuData = getSkuData(morder.get("storeId"), subOrder.get("productCode"))
|
| - |
|
693 |
if morder.get("storeId") in (1,2,4,5):
|
| - |
|
694 |
skuData = db1.MasterData.find_one({'identifier':subOrder.get("productCode").strip(), 'source_id':morder.get("storeId")})
|
| - |
|
695 |
if skuData is not None:
|
| - |
|
696 |
sh2.write(row3, inc(), skuData.get("skuBundleId"))
|
| - |
|
697 |
sh2.write(row3, inc(), skuData.get("brand"))
|
| - |
|
698 |
sh2.write(row3, inc(), skuData.get("model_name"))
|
| - |
|
699 |
sh2.write(row3, inc(), skuData.get("category"))
|
| 653 |
|
700 |
|
| 654 |
|
701 |
|
| 655 |
wb.save(XLS_FILENAME)
|
702 |
wb.save(XLS_FILENAME)
|
| 656 |
workbook.save(XLS_O_FILENAME)
|
703 |
workbook.save(XLS_O_FILENAME)
|
| 657 |
|
704 |
|