| Line 4... |
Line 4... |
| 4 |
from shop2020.model.v1.order.impl import DataService as OrderDataService
|
4 |
from shop2020.model.v1.order.impl import DataService as OrderDataService
|
| 5 |
from shop2020.model.v1.catalog.impl import DataService as CatalogDataService
|
5 |
from shop2020.model.v1.catalog.impl import DataService as CatalogDataService
|
| 6 |
from shop2020.model.v1.order.impl.DataService import Order, LineItem
|
6 |
from shop2020.model.v1.order.impl.DataService import Order, LineItem
|
| 7 |
from shop2020.model.v1.catalog.impl.DataService import Item
|
7 |
from shop2020.model.v1.catalog.impl.DataService import Item
|
| 8 |
from shop2020.thriftpy.model.v1.order.ttypes import OrderStatus, OrderSource
|
8 |
from shop2020.thriftpy.model.v1.order.ttypes import OrderStatus, OrderSource
|
| - |
|
9 |
import shutil
|
| 9 |
|
10 |
|
| 10 |
dtrUserMap = {}
|
11 |
dtrUserMap = {}
|
| 11 |
|
12 |
|
| 12 |
negative_items = []
|
13 |
negative_items = []
|
| 13 |
negative_categories = [10013,10017]
|
14 |
negative_categories = [10013,10017]
|
| Line 16... |
Line 17... |
| 16 |
|
17 |
|
| 17 |
startDate = datetime.datetime.strptime('01-04-2016 00:00:00', '%d-%m-%Y %H:%M:%S')
|
18 |
startDate = datetime.datetime.strptime('01-04-2016 00:00:00', '%d-%m-%Y %H:%M:%S')
|
| 18 |
endDate = datetime.datetime.strptime('01-05-2016 00:00:00', '%d-%m-%Y %H:%M:%S')
|
19 |
endDate = datetime.datetime.strptime('01-05-2016 00:00:00', '%d-%m-%Y %H:%M:%S')
|
| 19 |
run_time = to_java_date(datetime.datetime.now())
|
20 |
run_time = to_java_date(datetime.datetime.now())
|
| 20 |
|
21 |
|
| - |
|
22 |
cache_path = "/var/www/dtrdashboard/app/tmp/cache/target/"
|
| - |
|
23 |
|
| 21 |
|
24 |
|
| 22 |
class UserOrderData:
|
25 |
class UserOrderData:
|
| 23 |
def __init__(self, dtr_user_id, delivered_order_value, pending_order_value):
|
26 |
def __init__(self, dtr_user_id, delivered_order_value, pending_order_value):
|
| 24 |
self.dtr_user_id = dtr_user_id
|
27 |
self.dtr_user_id = dtr_user_id
|
| 25 |
self.delivered_order_value = delivered_order_value
|
28 |
self.delivered_order_value = delivered_order_value
|
| Line 67... |
Line 70... |
| 67 |
|
70 |
|
| 68 |
def commit():
|
71 |
def commit():
|
| 69 |
for k, v in dtrUserMap.iteritems():
|
72 |
for k, v in dtrUserMap.iteritems():
|
| 70 |
get_mongo_connection().Catalog.PromoOffer.update({'user_id':v.dtr_user_id},{"$set":{'pending_order_value':v.pending_order_value,'delivered_order_value':v.delivered_order_value,'last_run_timestamp': run_time}})
|
73 |
get_mongo_connection().Catalog.PromoOffer.update({'user_id':v.dtr_user_id},{"$set":{'pending_order_value':v.pending_order_value,'delivered_order_value':v.delivered_order_value,'last_run_timestamp': run_time}})
|
| 71 |
|
74 |
|
| - |
|
75 |
def removeCache():
|
| - |
|
76 |
shutil.rmtree(cache_path)
|
| - |
|
77 |
|
| 72 |
if __name__ == '__main__':
|
78 |
if __name__ == '__main__':
|
| 73 |
main()
|
79 |
main()
|
| 74 |
fetchNegativeItems()
|
80 |
fetchNegativeItems()
|
| 75 |
fetchOrders()
|
81 |
fetchOrders()
|
| 76 |
commit()
|
82 |
commit()
|
| - |
|
83 |
removeCache()
|
| 77 |
|
84 |
|
| 78 |
|
85 |
|