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

     OrderInventory, Alert, PaymentSettlement, EBSSettlementSummary, \
     CodVerificationAgent, Attribute, RechargeVoucherTracker, EmiScheme, MiscCharges, \
     BlockedIpRange, DeniedIpAddress, InsuranceDetailForOrder, DocumentStore, \
     RechargeTransaction, HotspotStore, WalletForCompany, WalletHistoryForCompany, \
     FRC, OperatorSeries, SourceDetail, Company, EbayOrder,AmazonFbaSalesSnapshot, \
-    AmazonOrder, StoreOrderDetail, EdcBank, StoreOrderCollection, HotspotServiceMatrix
+    AmazonOrder, StoreOrderDetail, EdcBank, StoreOrderCollection, HotspotServiceMatrix,\
+    SnapdealOrder
 from shop2020.model.v1.order.impl.model.BaseOrder import BaseOrder
 from shop2020.model.v1.order.impl.model.DTHRechargeOrder import DTHRechargeOrder
 from shop2020.model.v1.order.impl.model.MobileRechargeOrder import \
     MobileRechargeOrder
 from shop2020.model.v1.order.impl.model.RechargeDenomination import \
     #new status and status description to be added
     order.status = t_order.status
     order.statusDescription = t_order.statusDescription
     order.total_amount = t_order.total_amount
     order.gvAmount = t_order.gvAmount
+    order.cod = t_order.cod
     order.total_weight = t_order.total_weight
     if t_order.created_timestamp:
         order.created_timestamp = to_py_date(t_order.created_timestamp)
     else:
         order.created_timestamp = datetime.datetime.now()
         insuranceDetail.order = order
     if t_order.freebieItemId:
         order.freebieItemId = t_order.freebieItemId
     order.source = t_order.source
     #Change this temporary
-    if t_order.orderType is None:
+    if t_order.orderType is None or t_order.orderType ==OrderType.B2C:
         order.orderType = 0
     order.advanceAmount = t_order.advanceAmount
     order.storeId = t_order.storeId
     return order
             if order.transaction.status == TransactionStatus.AUTHORIZED:
                 __capture_txn(order)
         order.status = OrderStatus.ACCEPTED
         order.statusDescription = "Order Accepted"
         order.accepted_timestamp = datetime.datetime.now()
-        if order.source == 6:
+        if order.source == 6 or order.source == 7:
             session.commit()
             return "True"
         __amend_fulfilment_warehouse(order)
         __update_transfer_price(order, order.fulfilmentWarehouseId)
         session.commit()
     order = Order.get_by(id=orderId)
     if not order:
         raise TransactionServiceException(101, "No order found for the given order id" + str(orderId))
     if jacketNumber is None or jacketNumber <= 0:
-        if order.source == 6:
+        if order.source == 6 or order.source == 7:
             print "Skipping Jacket Number field for OrderId " + str(orderId)
         else:
             raise TransactionServiceException(110, "Invalid jacket number")
     '''
     item = catalog_client.getItem(item_id)
     if order.status == OrderStatus.ACCEPTED:
         order.jacket_number = jacketNumber
         if order.source == 6:
             order.jacket_number = "eby"+str(orderId)
+        if order.source == 7:
+            order.jacket_number = "snp"+str(orderId)
         if itemNumbers:
             lineitem.item_number = itemNumbers[0]
         if serialNumbers:
             lineitem.serial_number = serialNumbers[0]
         ebay_order.subsidyAmount= old_ebay_order.subsidyAmount
         ebay_order.ebayTxnDate= old_ebay_order.ebayTxnDate
         ebay_order.transactionId= old_ebay_order.transactionId
         ebay_order.listingName= old_ebay_order.listingName
         session.commit()
+    if order.source == 7:
+        old_snapdeal_order = SnapdealOrder.get_by(orderId=order.id)
+        snapdeal_order = SnapdealOrder()
+        snapdeal_order.orderId = new_order.id
+        snapdeal_order.subOrderId = old_snapdeal_order.subOrderId
+        snapdeal_order.referenceCode = old_snapdeal_order.referenceCode
+        snapdeal_order.productName = old_snapdeal_order.productName
+        snapdeal_order.listingPrice = old_snapdeal_order.listingPrice
+        snapdeal_order.snapdealTxnDate = old_snapdeal_order.snapdealTxnDate
+        session.commit()
     attributes = Attribute.query.filter(Attribute.orderId == order.id).all()
     if attributes:
         for attribute in attributes:
             newattribute = Attribute()
     fromDate = toDate-timedelta(days = interval)
     fbasalessnapshot = AmazonFbaSalesSnapshot.query.filter(AmazonFbaSalesSnapshot.dateOfSale.between (fromDate.date(),toDate.date())).order_by(AmazonFbaSalesSnapshot.dateOfSale).all()
     print fbasalessnapshot
     return fbasalessnapshot
+def create_snapdeal_order(t_snapdeal_order):
+    snapdealOrder = SnapdealOrder()
+    snapdealOrder.orderId = t_snapdeal_order.orderId
+    snapdealOrder.subOrderId = t_snapdeal_order.subOrderId
+    snapdealOrder.referenceCode = t_snapdeal_order.referenceCode
+    snapdealOrder.productName = t_snapdeal_order.productName
+    snapdealOrder.listingPrice = t_snapdeal_order.listingPrice
+    snapdealOrder.snapdealTxnDate = to_py_date(t_snapdeal_order.snapdealTxnDate)
+    session.commit()
+def get_snapdeal_order(order_id, reference_code, subOrder_id):
+    query = SnapdealOrder.query
+    if order_id:
+        query = query.filter(SnapdealOrder.orderId == order_id)
+    if reference_code:
+        query = query.filter(SnapdealOrder.referenceCode == reference_code)
+    if subOrder_id:
+        query = query.filter(SnapdealOrder.subOrderId == subOrder_id)
+    return query.one()
+def snapdeal_order_exists(suborder_id):
+    snapdeal_order = SnapdealOrder.get_by(subOrderId = suborder_id)
+    if snapdeal_order is not None:
+        return True
+    else:
+        return False
 def get_amazon_fba_sales_latest_snapshot_for_item(item_id):
     return AmazonFbaSalesSnapshot.query.filter(AmazonFbaSalesSnapshot.item_id==item_id).order_by(desc(AmazonFbaSalesSnapshot.dateOfSale)).first()
 if __name__ == '__main__':

Subversion Repositories SmartDukaan

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