| Line 64... |
Line 64... |
| 64 |
db=client.Dtr
|
64 |
db=client.Dtr
|
| 65 |
db1 = client.Catalog
|
65 |
db1 = client.Catalog
|
| 66 |
cur.execute("delete from allorder where created_on >= %s and created_on < %s", (start_date, end_date))
|
66 |
cur.execute("delete from allorder where created_on >= %s and created_on < %s", (start_date, end_date))
|
| 67 |
con.commit()
|
67 |
con.commit()
|
| 68 |
results = Mysql.fetchResult('''
|
68 |
results = Mysql.fetchResult('''
|
| 69 |
select ow.*, u.username, crm1.order_count, u.referrer, aua.city,aua.state,aua.pincode from order_view ow where created >= %s and created < %s
|
69 |
select ow.*, u.username, crm1.order_count, u.referrer, aua.city,aua.state,aua.pincode from order_view ow
|
| 70 |
left join users u on u.id = ow.user_id
|
70 |
left join users u on u.id = ow.user_id
|
| 71 |
left join (select user_id, count(*) as order_count from order_view where created >= %s and created < %s and status in ('ORDER_CREATED','DETAIL_CREATED') group by user_id)as crm1 on ow.user_id = crm1.user_id
|
71 |
left join (select user_id, count(*) as order_count from order_view where created >= %s and created < %s and status in ('ORDER_CREATED','DETAIL_CREATED') group by user_id)as crm1 on ow.user_id = crm1.user_id
|
| 72 |
left join (select * from (select * from all_user_addresses order by source) s group by user_id)aua on aua.user_id=u.id
|
72 |
left join (select * from (select * from all_user_addresses order by source) s group by user_id)aua on aua.user_id=u.id
|
| 73 |
where (lower(u.referrer) not like %s or u.utm_campaign is not null) and u.activated = 1 and ow.status in ('ORDER_CREATED','DETAIL_CREATED');
|
73 |
where (lower(u.referrer) not like %s or u.utm_campaign is not null) and u.activated = 1 and ow.status in ('ORDER_CREATED','DETAIL_CREATED') and ow.created >= %s and ow.created < %s;
|
| 74 |
''', start_date, end_date, start_date, end_date, 'emp%')
|
74 |
''', start_date, end_date, 'emp%', start_date, end_date, )
|
| 75 |
|
75 |
|
| 76 |
query = """INSERT INTO allorder
|
76 |
query = """INSERT INTO allorder
|
| 77 |
(user_id, user_name, order_id, created_on, store_id, merchant_order_id, status, detailed_status, product_title, referrer, amount_paid, catalog_id, brand, model,category, deal_rank, max_nlc, min_nlc, dp, item_status, city, state, pincode, merchant_suborder_id,cashback_status,cashback_amount)
|
77 |
(user_id, user_name, order_id, created_on, store_id, merchant_order_id, status, detailed_status, product_title, referrer, amount_paid, catalog_id, brand, model,category, deal_rank, max_nlc, min_nlc, dp, item_status, city, state, pincode, merchant_suborder_id,cashback_status,cashback_amount,quantity)
|
| 78 |
VALUES (%s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s)
|
78 |
VALUES (%s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s)
|
| 79 |
"""
|
79 |
"""
|
| 80 |
for result in results:
|
80 |
for result in results:
|
| 81 |
morder = db.merchantOrder.find_one({"orderId":result[0]})
|
81 |
morder = db.merchantOrder.find_one({"orderId":result[0]})
|
| 82 |
if morder is not None:
|
82 |
if morder is not None:
|
| 83 |
subOrders = morder.get("subOrders")
|
83 |
subOrders = morder.get("subOrders")
|
| Line 91... |
Line 91... |
| 91 |
merchant_order_id = morder.get("merchantOrderId")
|
91 |
merchant_order_id = morder.get("merchantOrderId")
|
| 92 |
status = subOrder.get("status")
|
92 |
status = subOrder.get("status")
|
| 93 |
detailed_status = subOrder.get("detailedStatus")
|
93 |
detailed_status = subOrder.get("detailedStatus")
|
| 94 |
product_title= subOrder.get("productTitle")
|
94 |
product_title= subOrder.get("productTitle")
|
| 95 |
referrer = result[9]
|
95 |
referrer = result[9]
|
| 96 |
if int(subOrder.get("quantity")) > 0:
|
96 |
amount_paid = int(subOrder.get("amountPaid"))
|
| 97 |
amount_paid = int(subOrder.get("amountPaid"))/int(subOrder.get("quantity"))
|
97 |
quantity=int(subOrder.get("quantity"))
|
| 98 |
skuData = getSkuData(morder.get("storeId"), subOrder.get("productCode"))
|
98 |
skuData = getSkuData(morder.get("storeId"), subOrder.get("productCode"))
|
| 99 |
if morder.get("storeId") in (1,2,4,5):
|
99 |
if morder.get("storeId") in (1,2,4,5):
|
| 100 |
skuData = db1.MasterData.find_one({'identifier':subOrder.get("productCode").strip(), 'source_id':morder.get("storeId")})
|
100 |
skuData = db1.MasterData.find_one({'identifier':subOrder.get("productCode").strip(), 'source_id':morder.get("storeId")})
|
| 101 |
elif morder.get("storeId") == 3:
|
101 |
elif morder.get("storeId") == 3:
|
| 102 |
skuData = db1.MasterData.find_one({'secondaryIdentifier':subOrder.get("productCode").strip(), 'source_id':morder.get("storeId")})
|
102 |
skuData = db1.MasterData.find_one({'secondaryIdentifier':subOrder.get("productCode").strip(), 'source_id':morder.get("storeId")})
|
| Line 126... |
Line 126... |
| 126 |
city = result[10]
|
126 |
city = result[10]
|
| 127 |
state = result[11]
|
127 |
state = result[11]
|
| 128 |
pincode = result[12]
|
128 |
pincode = result[12]
|
| 129 |
|
129 |
|
| 130 |
print user_id
|
130 |
print user_id
|
| 131 |
values = (user_id, user_name, order_id, created_on, store_id, merchant_order_id, status, detailed_status, product_title, referrer, amount_paid, catalog_id, brand, model,category, deal_rank, max_nlc, min_nlc, dp, item_status, city, state, pincode,merchant_suborder_id,cashback_status,cashback_amount)
|
131 |
values = (user_id, user_name, order_id, created_on, store_id, merchant_order_id, status, detailed_status, product_title, referrer, amount_paid, catalog_id, brand, model,category, deal_rank, max_nlc, min_nlc, dp, item_status, city, state, pincode,merchant_suborder_id,cashback_status,cashback_amount, quantity)
|
| 132 |
cur.execute(query,values)
|
132 |
cur.execute(query,values)
|
| 133 |
con.commit()
|
133 |
con.commit()
|
| 134 |
except _mysql.Error, e:
|
134 |
except _mysql.Error, e:
|
| 135 |
|
135 |
|
| 136 |
print "Error %d: %s" % (e.args[0], e.args[1])
|
136 |
print "Error %d: %s" % (e.args[0], e.args[1])
|