| Line 12... |
Line 12... |
| 12 |
TransactionServiceException, TransactionStatus, OrderStatus
|
12 |
TransactionServiceException, TransactionStatus, OrderStatus
|
| 13 |
import datetime
|
13 |
import datetime
|
| 14 |
import time
|
14 |
import time
|
| 15 |
from elixir import *
|
15 |
from elixir import *
|
| 16 |
from shop2020.utils.Utils import to_py_date, to_java_date
|
16 |
from shop2020.utils.Utils import to_py_date, to_java_date
|
| 17 |
from sqlalchemy.sql.expression import and_, or_
|
17 |
from sqlalchemy.sql.expression import and_, or_, desc
|
| 18 |
from sqlalchemy.sql import func
|
18 |
from sqlalchemy.sql import func
|
| 19 |
from shop2020.model.v1 import order
|
19 |
from shop2020.model.v1 import order
|
| 20 |
from shop2020.clients.LogisticsClient import LogisticsClient
|
20 |
from shop2020.clients.LogisticsClient import LogisticsClient
|
| 21 |
from shop2020.clients.InventoryClient import InventoryClient
|
21 |
from shop2020.clients.InventoryClient import InventoryClient
|
| 22 |
from shop2020.clients.UserClient import UserClient
|
22 |
from shop2020.clients.UserClient import UserClient
|
| Line 545... |
Line 545... |
| 545 |
def get_valid_orders_amount_range():
|
545 |
def get_valid_orders_amount_range():
|
| 546 |
orders = Order.query.filter(Order.status >= OrderStatus.SUBMITTED_FOR_PROCESSING).all()
|
546 |
orders = Order.query.filter(Order.status >= OrderStatus.SUBMITTED_FOR_PROCESSING).all()
|
| 547 |
order_amounts = [o.total_amount for o in orders]
|
547 |
order_amounts = [o.total_amount for o in orders]
|
| 548 |
return [min(order_amounts), max(order_amounts)]
|
548 |
return [min(order_amounts), max(order_amounts)]
|
| 549 |
|
549 |
|
| - |
|
550 |
def get_valid_orders(limit):
|
| - |
|
551 |
query = Order.query.filter(Order.status >= OrderStatus.SUBMITTED_FOR_PROCESSING)
|
| - |
|
552 |
query = query.order_by(desc(Order.created_timestamp))
|
| - |
|
553 |
if limit > 0:
|
| - |
|
554 |
query = query.limit(limit)
|
| - |
|
555 |
elif limit < 0:
|
| - |
|
556 |
raise TransactionServiceException(101, "Invalid argument limit " + limit)
|
| - |
|
557 |
return query.all()
|
| - |
|
558 |
|
| 550 |
def close_session():
|
559 |
def close_session():
|
| 551 |
if session.is_active:
|
560 |
if session.is_active:
|
| 552 |
print "session is active. closing it."
|
561 |
print "session is active. closing it."
|
| 553 |
session.close()
|
562 |
session.close()
|
| 554 |
|
563 |
|