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

 def change_transaction_status(transaction_id, new_status, description, pickUp, orderType, source):
     logging.info("########change transaction status called" + str(transaction_id))
     transaction = get_transaction(transaction_id)
     if new_status in (TransactionStatus.AUTHORIZED, TransactionStatus.FLAGGED, TransactionStatus.COD_IN_PROCESS):
         wallet_amount_used = 0.0
         for order in transaction.orders:
             wallet_amount_used = wallet_amount_used + order.wallet_amount
         if wallet_amount_used > 0:
             user_wallet = get_user_wallet(transaction.orders[0].customer_id)
                 item_pricing = inventory_client.getItemPricing(item_id, -1)
                 order.lineitems[0].transfer_price = item_pricing.transferPrice
                 order.lineitems[0].nlc = item_pricing.nlc
             except:
                 print "Not able to get transfer price. Skipping"
-    elif new_status == TransactionStatus.COD_IN_PROCESS:
-        expectedDelayMap = {}
-        billingWarehouseIdMap = {}
-        billingWarehouseTxnMap = {}
-        subOrderAmountsMap = {}
-        for order in transaction.orders:
-            order.status = OrderStatus.COD_VERIFICATION_PENDING
-            order.statusDescription = "Verification Pending"
-            order.cod = True
-            #OrderType cant be changed
-            #order.orderType = orderType
-            #After we got payment success, we will set logistics info also
-            logistics_client = LogisticsClient().get_client()
-            #FIXME line item is only one now. If multiple will come, need to fix.
-            item_id = order.lineitems[0].item_id
-            try:
-                #Get the id and location of actual warehouse that'll be used to fulfil this order.
-                inventory_client = InventoryClient().get_client()
-                fulfilmentWhId, expected_delay, billingWarehouseId, sellingPrice, totalAvailability, weight = inventory_client.getItemAvailabilityAtLocation(item_id, 1, -1)
-            except Exception as ex:
-                raise TransactionServiceException(103, "Unable to fetch inventory information about this item.")
-            expectedDelayMap[item_id] = expected_delay
-            if billingWarehouseIdMap.has_key(billingWarehouseId):
-                ordersList = billingWarehouseIdMap.get(billingWarehouseId)
-                ordersList.append(order)
-                billingWarehouseIdMap[billingWarehouseId] = ordersList
-            else:
-                ordersList = []
-                ordersList.append(order)
-                billingWarehouseIdMap[billingWarehouseId] = ordersList
-            if billingWarehouseTxnMap.has_key(billingWarehouseId):
-                transactionAmount , transactionWeight = billingWarehouseTxnMap.get(billingWarehouseId)
-                transactionAmount = transactionAmount+order.total_amount
-                transactionWeight = transactionWeight+order.total_weight
-                billingWarehouseTxnMap[billingWarehouseId] = transactionAmount , transactionWeight
-            else:
-                billingWarehouseTxnMap[billingWarehouseId] = order.total_amount , order.total_weight
-            subOrderAmountsMap[long(order.lineitems[0].unit_price)] = order
-            order.fulfilmentWarehouseId = fulfilmentWhId
-            order.warehouse_id = billingWarehouseId
-            if order.productCondition != ProductCondition.BAD:
-                inventory_client.reserveItemInWarehouse(item_id, order.fulfilmentWarehouseId, sourceId, order.id, to_java_date(order.created_timestamp), to_java_date(order.promised_shipping_time), order.lineitems[0].quantity)
-            try:
-                item_pricing = inventory_client.getItemPricing(item_id, -1)
-                order.lineitems[0].transfer_price = item_pricing.transferPrice
-                order.lineitems[0].nlc = item_pricing.nlc
-            except:
-                print "Not able to get transfer price. Skipping"
     session.commit()
-    if new_status in (TransactionStatus.AUTHORIZED, TransactionStatus.FLAGGED, TransactionStatus.COD_IN_PROCESS):
-        try:
-            if order.source == OrderSource.WEBSITE:
-                if new_status == TransactionStatus.COD_IN_PROCESS:
-                    transaction_requiring_extra_processing = TransactionRequiringExtraProcessing()
-                    transaction_requiring_extra_processing.category = 'COD_VERIFICATION'
-                    transaction_requiring_extra_processing.transaction_id = transaction_id
-                    session.commit()
-                elif new_status == TransactionStatus.FLAGGED:
-                    transaction_requiring_extra_processing = TransactionRequiringExtraProcessing()
-                    transaction_requiring_extra_processing.category = 'PAYMENT_FLAGGED'
-                    transaction_requiring_extra_processing.transaction_id = transaction_id
-                    session.commit()
-            else:
-                order.otg = False
-                session.commit()
-        except Exception as e:
-            print "Error inserting transaction Id: " + str(transaction_id) + " due to " + str(e)
     return True
 def __create_recharge_voucher_tracker(order, amount, voucherType):
     rvt = RechargeVoucherTracker()
     rvt.order = order
     userClient, isFofo = __is_Fofo(userClient, order.customer_id)
     if isFofo:
         stateId = warehouse.stateId
     if warehouse.id == warehouse.billingWarehouseId:
         itemAvailabilityLocation = inventoryClient.getItemAvailabilityAtLocation(lineitem.item_id, sourceId, stateId)
+        if warehouse.billingWarehouseId == itemAvailabilityLocation[2]:
-        vendor_warehouse_id=itemAvailabilityLocation[0]
+            billing_warehouse_id=itemAvailabilityLocation[2]
-        billing_warehouse_id=itemAvailabilityLocation[2]
+            vendor_warehouse_id=itemAvailabilityLocation[0]
+        else:
+            vendor_warehouse_id = 8489
     else:
         vendor_warehouse_id = warehouse_id
         billing_warehouse_id=warehouse.billingWarehouseId
     #if vendorWarehouse is None or vendorWarehouse.billingWarehouseId != warehouse.id:
 if __name__ == '__main__':
     DataService.initialize(db_hostname="192.168.190.112")
     #transaction_ids=[1030084,1030087,1030090,1030093,1030096,1030099,1030102,1030105,1030108,1030111,1030114,1030117,1030120,1030123,1030144,1030147,1030153]
-    transaction_ids=[1043579, 1043580, 1043581, 1043582, 1043584, 1043588, 1043589]
+    #transaction_ids=[1043579, 1043580, 1043581, 1043582, 1043584, 1043588, 1043589]
     #transaction_ids=[1043577]
-    for transaction_id in transaction_ids:
+    #for transaction_id in transaction_ids:
-        process_failed_payment(TransactionStatus.AUTHORIZED, transaction_id, "Transaction Authorised", 1, PickUpType.SELF)
+    #    process_failed_payment(TransactionStatus.AUTHORIZED, transaction_id, "Transaction Authorised", 1, PickUpType.SELF)
+    #
+    ##################################################################################################################################
+    refund_order(1588409, "backend-team", "As per Customer's Request")
 #    mark_order_for_selfpickup_temp(transaction_ids)
 #    get_billed_orders_for_manifest_gen(7441, 2, True)
 #    ordersmap = {'911319502886601':1544266,'911319502890314':1544266,'x911319502903141':1544269,'x911319502916655':1544269,'x911319502950985':1544269,'x911319502836309':1544269,'x911319502972369':1544269,'x911319502950860':1544269,'x911319502918313':1544269,
 #                 'x911319502943436':1544269,'x911319502928056':1544269,'x911319502838263':1544269,'911319502794144':1544269,'x911319502821616':1544269,'x911319502974746':1544269,'x911319502821442':1544269,'x911319502903984':1544269,'x911319502820980':1544269,

Subversion Repositories SmartDukaan

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