WebSVN – SmartDukaan – Diff – //trunk/PyProj/src/shop2020/model/v1/order/impl/DataAccessors.py

     if end_billing_date:
         query = query.filter(Order.billing_timestamp <= end_billing_date)
     return query.all()
-def get_orders_by_shipping_date(from_shipping_date, to_shipping_date, provider_id, warehouse_id):
+def get_orders_by_shipping_date(from_shipping_date, to_shipping_date, provider_id, warehouse_id, cod):
-    query = Order.query
+    query = Order.query.filter(Order.cod == cod)
     if warehouse_id and warehouse_id != -1:
         query = query.filter(Order.warehouse_id == warehouse_id)
     if provider_id and provider_id != -1:
 def create_purchase_order(warehouseId):
     if not warehouseId:
         raise TransactionServiceException(101, "bad warehouse id")
-    query = Order.query.filter_by(warehouse_id=warehouseId)
+    query = Order.query.with_lockmode("update").filter_by(warehouse_id=warehouseId)
     query = query.filter_by(status=OrderStatus.SUBMITTED_FOR_PROCESSING)
     query = query.filter_by(purchase_order_id=None)
     query = query.order_by(Order.created_timestamp)
     pending_orders = query.all()
     for order in pending_orders:
         order.purchase_order_id = po_id
     session.commit()
     return po_id
+def update_weight(order_id, weight):
+    order = get_order(order_id)
+    order.total_weight = weight
+    lineitems = order.lineitems
+    for lineitem in lineitems:
+        lineitem.total_weight = weight
+    session.commit()
+    return order
 def close_session():
     if session.is_active:
         print "session is active. closing it."
         session.close()

Subversion Repositories SmartDukaan

(root)//trunk/PyProj/src/shop2020/model/v1/order/impl/DataAccessors.py – Rev 3427 → 3451