| Line 1... |
Line 1... |
| 1 |
from elixir import *
|
1 |
from elixir import *
|
| 2 |
from shop2020.config.client.ConfigClient import ConfigClient
|
2 |
from shop2020.config.client.ConfigClient import ConfigClient
|
| 3 |
from shop2020.model.v1.order.impl import DataService
|
3 |
from shop2020.model.v1.order.impl import DataService
|
| 4 |
from shop2020.model.v1.order.impl.DataService import MobileActivationRecord, Order, LineItem
|
4 |
from shop2020.model.v1.order.impl.DataService import MobileActivationRecord, Order, LineItem
|
| 5 |
from shop2020.thriftpy.model.v1.order.ttypes import OrderStatus, OrderSource
|
5 |
from shop2020.thriftpy.model.v1.order.ttypes import OrderStatus, OrderSource, OrderType
|
| 6 |
from requests import request
|
6 |
from requests import request
|
| 7 |
import datetime
|
7 |
import datetime
|
| 8 |
|
8 |
|
| 9 |
config_client = ConfigClient()
|
9 |
config_client = ConfigClient()
|
| 10 |
host = config_client.get_property('transaction_service_db_hostname')
|
10 |
host = config_client.get_property('transaction_service_db_hostname')
|
| Line 33... |
Line 33... |
| 33 |
if len(activatedIds) > 0:
|
33 |
if len(activatedIds) > 0:
|
| 34 |
orders = query.filter(~Order.id.in_((activatedIds))).all()
|
34 |
orders = query.filter(~Order.id.in_((activatedIds))).all()
|
| 35 |
else:
|
35 |
else:
|
| 36 |
orders = query.all()
|
36 |
orders = query.all()
|
| 37 |
for order in orders:
|
37 |
for order in orders:
|
| - |
|
38 |
if order.lineitems[0].serial_number is None:
|
| - |
|
39 |
continue
|
| 38 |
if (order.source in (OrderSource.WEBSITE, OrderSource.SNAPDEAL, OrderSource.AMAZON, OrderSource.FLIPKART)) and order.status == OrderStatus.DELIVERY_SUCCESS:
|
40 |
if (order.source in (OrderSource.WEBSITE, OrderSource.SNAPDEAL, OrderSource.AMAZON, OrderSource.FLIPKART)) and order.status == OrderStatus.DELIVERY_SUCCESS:
|
| 39 |
det = __Details(order.source,order.id,(order.lineitems[0].serial_number).strip(),None,None,None,None)
|
41 |
det = __Details(order.source,order.id,(order.lineitems[0].serial_number).strip(),None,None,None,None)
|
| 40 |
records.append(det)
|
42 |
records.append(det)
|
| 41 |
elif (order.source == OrderSource.EBAY) and order.status in (OrderStatus.SHIPPED_FROM_WH,OrderStatus.DELIVERY_SUCCESS):
|
43 |
elif (order.source == OrderSource.EBAY) and order.status in (OrderStatus.SHIPPED_FROM_WH,OrderStatus.DELIVERY_SUCCESS):
|
| 42 |
det = __Details(order.source,order.id,(order.lineitems[0].serial_number).strip(),None,None,None,None)
|
44 |
det = __Details(order.source,order.id,(order.lineitems[0].serial_number).strip(),None,None,None,None)
|
| Line 48... |
Line 50... |
| 48 |
session.close()
|
50 |
session.close()
|
| 49 |
|
51 |
|
| 50 |
def main():
|
52 |
def main():
|
| 51 |
activatedIds = getActivatedDevices()
|
53 |
activatedIds = getActivatedDevices()
|
| 52 |
records = populateNewRecords(activatedIds)
|
54 |
records = populateNewRecords(activatedIds)
|
| - |
|
55 |
print "Getting activation details for ",len(records)
|
| 53 |
for rec in records:
|
56 |
for rec in records:
|
| 54 |
serial_number_list = rec.serial_number.split(',')
|
57 |
serial_number_list = rec.serial_number.split(',')
|
| 55 |
for serial_number in serial_number_list:
|
58 |
for serial_number in serial_number_list:
|
| 56 |
url = base_url+serial_number
|
59 |
url = base_url+serial_number
|
| 57 |
response = request('GET', url)
|
60 |
response = request('GET', url)
|