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

 from shop2020.clients.LogisticsClient import LogisticsClient
 from shop2020.clients.PaymentClient import PaymentClient
 from shop2020.clients.UserClient import UserClient
 from shop2020.clients.WarehouseClient import WarehouseClient
 from shop2020.model.v1 import order
-from shop2020.model.v1.order.impl import DataService
+from shop2020.model.v1.order.impl import DataService, RechargeService
 from shop2020.model.v1.order.impl.DataService import Transaction, LineItem, \
     Order, BatchNoGenerator, InvoiceIDGenerator, TransactionRequiringExtraProcessing, \
     OrderInventory, Alert, PaymentSettlement, EBSSettlementSummary, \
     CodVerificationAgent, Attribute, RechargeVoucherTracker
 from shop2020.model.v1.order.impl.model.MobileRechargeOrder import \
 from shop2020.thriftpy.model.v1.inventory.ttypes import BillingType, \
     InventoryServiceException, WarehouseType, InventoryType
 from shop2020.thriftpy.model.v1.order.ttypes import TransactionServiceException, \
     TransactionStatus, OrderStatus, DelayReason, ExtraTransactionProcessingType, \
     HotspotAction, TimeoutSummary, OrderStatusGroups, OrderType,\
-    RechargeOrderStatus
+    RechargeOrderStatus, RechargeType
 from shop2020.thriftpy.model.v1.user.ttypes import VoucherType
 from shop2020.thriftpy.payments.ttypes import PaymentException
 from shop2020.thriftpy.warehouse.ttypes import ScanType, \
     WarehouseServiceException
 from shop2020.utils.EmailAttachmentSender import mail, get_attachment_part
 import urllib
 from shop2020.config.client.ConfigClient import ConfigClient
 from shop2020.model.v1.order.impl.model.RechargeOrder import RechargeOrder
 from shop2020.model.v1.order.impl.model.UserWallet import UserWallet
 from shop2020.model.v1.order.impl.model.UserWalletHistory import UserWalletHistory
+from shop2020.model.v1.order.impl.model.ServiceProvider import ServiceProvider
+from shop2020.model.v1.order.impl.model.DTHRechargeOrder import DTHRechargeOrder
 logging.basicConfig(level=logging.DEBUG)
 sourceId = int(ConfigClient().get_property("sourceid"))
 mail_user = 'cnc.center@shop2020.in'
             <td colspan=5>Total Amount</td>
             <td> Rs. $total_amount</td>
         </tr>
         </table>
     </div>
-    <br>Congratulations, your order qualifies for the <b><i>Oh My God Contest</i></b>. Please check the details at <a href="$source_url/static/oh-my-god-contest"> T &amp; C page </a> . We will get in touch with you on the Prize  announcement dates, if you are the Lucky Winner.<br>
     """
     store_address = ""
     if orders[0].pickupStoreId:
         store = LogisticsClient().get_client().getPickupStore(orders[0].pickupStoreId)
                     session.commit()
                     if not quantity:
                         break
 def get_recharge_order(rechargeOrderId):
-    return RechargeOrder.get_by(id = rechargeOrderId).to_thrift_object()
+    return RechargeOrder.get_by(id = rechargeOrderId)
 def get_recharge_orders(userId):
     return RechargeOrder.query.filter_by(userId = userId).all()
 def update_recharge_order_status(rechargeOrderId, rechargeOrderStatus):
                 recharge_order.status = RechargeOrderStatus.PAYMENT_SUCCESSFUL
                 session.commit()
                 raise TransactionServiceException(103, 'Wallet amount has already been used')
-        if activate_recharge_txn(rechargeOrderId):
+        if activate_recharge_txn(recharge_order):
-            rechargeOrderStatus = RechargeOrderStatus.RECHARGE_SUCCESSFUL
+            recharge_order.rechargeOrderStatus = RechargeOrderStatus.RECHARGE_SUCCESSFUL
             session.commit()
             return True
         else:
-            rechargeOrderStatus = RechargeOrderStatus.RECHARGE_FAILED
+            recharge_order.rechargeOrderStatus = RechargeOrderStatus.RECHARGE_FAILED
             update_amount_in_wallet(recharge_order.userId, recharge_order.walletAmount, recharge_order.id)
             update_amount_in_wallet(recharge_order.userId, recharge_order.totalAmount - recharge_order.walletAmount, recharge_order.id)
             session.commit()
             return False
-def activate_recharge_txn(rechargeOrderId):
+def activate_recharge_txn(recharge_order):
+    print type(recharge_order)
+    if isinstance(recharge_order, MobileRechargeOrder):
+        rechargeType = 'MTP'
+        deviceNumber = recharge_order.mobileNumber
+        strProviderCode = get_provider_code(recharge_order.mobileOperatorId)
+    if isinstance(recharge_order, DTHRechargeOrder):
+        rechargeType = 'RCH'
+        deviceNumber = recharge_order.dthAccountNumber
+        strProviderCode = get_provider_code(recharge_order.dthOperatorId)
+    try:
+        retStatus, retCode, spiceTID = RechargeService.rechargeDevice(recharge_order.id, rechargeType, strProviderCode, deviceNumber, recharge_order.totalAmount)
+        if retCode == '00' and retStatus == 'S':
+            recharge_order.spiceTID = spiceTID
+            recharge_order.responseTimestamp = datetime.datetime.now()
+            session.commit()
+            return True
+        else:
+            recharge_order.spiceTID = spiceTID
+            recharge_order.responseTimestamp = datetime.datetime.now()
+            session.commit()
+            return False
+    except:
-    return False
+        return False
 def get_user_wallet(userId):
     wallet = UserWallet.get_by(userId = userId)
     if not wallet:
         wallet = UserWallet()
     if wallet.id:
         return UserWalletHistory.query.filter_by(wallet = wallet).all()
     else:
         return []
+def get_provider_code(providerId):
+    return ServiceProvider.query.filter_by(id = providerId).one().code
+def get_service_providers(recharge_type):
+    providers = ServiceProvider.query.filter_by(type = recharge_type, status = 1).all()
+    serviceProviders = {}
+    for provider in providers:
+        serviceProviders[provider.id] = provider.name
+    return serviceProviders
+def get_service_provider_for_device(deviceNumber):
+    return 0
 def update_amount_in_wallet(userId, amount, orderId):
     if amount == 0:
         return
     wallet = get_user_wallet(userId)
     wallet.amount = wallet.amount + amount
     history.amount = amount
     history.orderId = orderId
     history.wallet = wallet
     history.timestamp = datetime.datetime.now()
     session.commit()
 def close_session():
     if session.is_active:
         print "session is active. closing it."

Subversion Repositories SmartDukaan

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