| Line 6458... |
Line 6458... |
| 6458 |
item_ordercount[item[0]] = item[1]
|
6458 |
item_ordercount[item[0]] = item[1]
|
| 6459 |
return item_ordercount
|
6459 |
return item_ordercount
|
| 6460 |
|
6460 |
|
| 6461 |
|
6461 |
|
| 6462 |
def get_min_created_timestamp_undelivered_orders_for_source(source):
|
6462 |
def get_min_created_timestamp_undelivered_orders_for_source(source):
|
| 6463 |
order = order = Order.query.filter(Order.source== source).filter(Order.delivery_timestamp == None).limit(1).one()
|
6463 |
order = order = Order.query.filter(Order.source== source).filter(Order.delivery_timestamp == None).filter(Order.status == OrderStatus.SHIPPED_FROM_WH).limit(1).one()
|
| 6464 |
print to_java_date(order.created_timestamp)
|
6464 |
print to_java_date(order.created_timestamp)
|
| 6465 |
return to_java_date(order.created_timestamp)
|
6465 |
return to_java_date(order.created_timestamp)
|
| 6466 |
|
6466 |
|
| 6467 |
def update_snapdeal_orders_status(delivered_orders):
|
6467 |
def update_snapdeal_orders_status(delivered_orders):
|
| 6468 |
for del_order in delivered_orders:
|
6468 |
for del_order in delivered_orders:
|
| Line 6471... |
Line 6471... |
| 6471 |
dlvry_timestamp = del_order[2]
|
6471 |
dlvry_timestamp = del_order[2]
|
| 6472 |
|
6472 |
|
| 6473 |
if snapdeal_order_exists(sub_order_code, ref_code):
|
6473 |
if snapdeal_order_exists(sub_order_code, ref_code):
|
| 6474 |
snapdeal_order = get_snapdeal_order(None, ref_code, sub_order_code)
|
6474 |
snapdeal_order = get_snapdeal_order(None, ref_code, sub_order_code)
|
| 6475 |
order = get_order(snapdeal_order.orderId)
|
6475 |
order = get_order(snapdeal_order.orderId)
|
| - |
|
6476 |
if order.status == OrderStatus.SHIPPED_FROM_WH:
|
| 6476 |
order.delivery_timestamp = datetime.datetime.strptime(dlvry_timestamp, "%Y-%m-%d %H:%M:%S")
|
6477 |
order.delivery_timestamp = datetime.datetime.strptime(dlvry_timestamp, "%Y-%m-%d %H:%M:%S")
|
| 6477 |
order.receiver = order.customer_name
|
6478 |
order.receiver = order.customer_name
|
| 6478 |
order.status = OrderStatus.DELIVERY_SUCCESS
|
6479 |
order.status = OrderStatus.DELIVERY_SUCCESS
|
| 6479 |
order.statusDescription = "Order delivered"
|
6480 |
order.statusDescription = "Order delivered"
|
| 6480 |
session.commit()
|
6481 |
session.commit()
|
| 6481 |
|
6482 |
|
| 6482 |
def update_flipkart_orders_status(delivered_orders):
|
6483 |
def update_flipkart_orders_status(delivered_orders):
|
| 6483 |
for del_order in delivered_orders:
|
6484 |
for del_order in delivered_orders:
|
| 6484 |
flipkart_order_id = del_order[0]
|
6485 |
flipkart_order_id = del_order[0]
|
| 6485 |
sub_order_code = del_order[1]
|
6486 |
sub_order_code = del_order[1]
|
| 6486 |
dlvry_timestamp = del_order[2]
|
6487 |
dlvry_timestamp = del_order[2]
|
| 6487 |
|
6488 |
|
| 6488 |
if flipkart_order_exists(flipkart_order_id,sub_order_code):
|
6489 |
if flipkart_order_exists(flipkart_order_id,sub_order_code):
|
| 6489 |
flipkart_order = get_flipkart_order_by_subOrderId(sub_order_code)
|
6490 |
flipkart_order = get_flipkart_order_by_subOrderId(sub_order_code)
|
| 6490 |
order = get_order(flipkart_order.orderId)
|
6491 |
order = get_order(flipkart_order.orderId)
|
| 6491 |
if order.status != OrderStatus.DELIVERY_SUCCESS:
|
6492 |
if order.status == OrderStatus.SHIPPED_FROM_WH:
|
| 6492 |
order.delivery_timestamp = datetime.datetime.strptime(dlvry_timestamp, "%Y-%m-%d %H:%M:%S")
|
6493 |
order.delivery_timestamp = datetime.datetime.strptime(dlvry_timestamp, "%Y-%m-%d %H:%M:%S")
|
| 6493 |
order.receiver = order.customer_name
|
6494 |
order.receiver = order.customer_name
|
| 6494 |
order.status = OrderStatus.DELIVERY_SUCCESS
|
6495 |
order.status = OrderStatus.DELIVERY_SUCCESS
|
| 6495 |
order.statusDescription = "Order delivered"
|
6496 |
order.statusDescription = "Order delivered"
|
| 6496 |
session.commit()
|
6497 |
session.commit()
|