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

 from shop2020.thriftpy.model.v1.order.ttypes import TransactionServiceException, \
     TransactionStatus, OrderStatus, DelayReason, ExtraTransactionProcessingType, \
     HotspotAction, TimeoutSummary, OrderStatusGroups, OrderType, RechargeOrderStatus, \
     RechargeType, RechargeStatistics, DeviceNumberInfo, EmiChargeType, PayMethod, \
     OrderSource, StorePaymentStatus, ProductCondition, TaxType, \
-    AmazonFCWarehouseLocation
+    AmazonFCWarehouseLocation, RechargeMode
 from shop2020.thriftpy.utils.ttypes import UserSmsInfo, SmsType
 from shop2020.thriftpy.model.v1.user.ttypes import VoucherType, CouponCategory, \
     User, Sex
 from shop2020.thriftpy.payments.ttypes import PaymentException
 from shop2020.thriftpy.warehouse.ttypes import ScanType, \
     WarehouseServiceException
 from shop2020.utils.EmailAttachmentSender import mail, get_attachment_part, \
     mail_html
-from shop2020.utils.Utils import to_py_date, to_java_date
+from shop2020.utils.Utils import to_py_date, to_java_date, getAsyncOperatorsForRecharge
 from sqlalchemy.orm.exc import NoResultFound, MultipleResultsFound
 from sqlalchemy.sql import func
 from sqlalchemy.sql.expression import and_, or_, desc, not_, distinct, cast, \
     between
 from string import Template
     email_header = Template(html_header).substitute(dict(order_date = formated_order_date, customer_name = customer_name, source_url = source_url, otgLink = otgLink, saddress = saddress))
     email_footer = Template(html_footer).substitute(dict(total_amount = "%.2f" % total_amount, emi_amount = "%.2f" % emi_amount, advance_amount = "%.2f" % advance_amount, net_amount = "%.2f" % (total_amount-order.gvAmount), secret_code = random_text, store_address = store_address, store_delivery_date = store_delivery_date, source_url = source_url, source_name = source_name, amount_string = amount_string))
     if otgSms:
         smsText = smsText +" Order comes under On Time Guarantee We Pay if we Delay. T&C Apply"
     try:
         helper_client = HelperClient().get_client()
         helper_client.saveUserEmailForSending([user_email], "", subject, email_header + html_table + email_footer, str(transaction_id), "TransactionInfo", [], bcc, orders[0].source)
         send_transaction_sms(customerId, mobileNo, smsText, SmsType.TRANSACTIONAL)
         return True
                 update_amount_in_wallet(recharge_order.userId, recharge_order.walletAmount, recharge_order.id, 1)
                 update_amount_in_wallet(recharge_order.userId, recharge_order.totalAmount - recharge_order.walletAmount - recharge_order.couponAmount, recharge_order.id, 0)
                 session.commit()
                 return False
         except:
+            if isinstance(recharge_order, MobileRechargeOrder):
+                if recharge_order.mobileOperatorId in (getAsyncOperatorsForRecharge()):
+                    return False
+            if isinstance(recharge_order, DTHRechargeOrder):
+                if recharge_order.dthOperatorId in (getAsyncOperatorsForRecharge()):
+                    return False
             transaction_requiring_extra_processing = TransactionRequiringExtraProcessing()
             transaction_requiring_extra_processing.category = 'RECHARGE_UNKNOWN'
             transaction_requiring_extra_processing.transaction_id = recharge_order.transaction_id
             session.commit()
             return False
     if isinstance(recharge_order, MobileRechargeOrder):
         rechargeType = 'MTP'
         deviceNumber = recharge_order.mobileNumber
         strProviderCode = get_provider_code(recharge_order.mobileOperatorId)
         plan = recharge_order.rechargePlan
+        if recharge_order.mobileOperatorId in (getAsyncOperatorsForRecharge()):
+            __activate_recharge_txn_asynchronously(recharge_order,rechargeType,deviceNumber,strProviderCode,plan)
     if isinstance(recharge_order, DTHRechargeOrder):
         rechargeType = 'RCH'
         deviceNumber = recharge_order.dthAccountNumber
         strProviderCode = get_provider_code(recharge_order.dthOperatorId)
         plan = ''
+        if recharge_order.dthOperatorId in (getAsyncOperatorsForRecharge()):
+            __activate_recharge_txn_asynchronously(recharge_order,rechargeType,deviceNumber,strProviderCode,plan)
-    retStatus, retCode, spiceTID, description, aggTID, providerTID = RechargeService.rechargeDevice(recharge_order.id, rechargeType, strProviderCode, deviceNumber, recharge_order.totalAmount, plan)
+    retStatus, retCode, spiceTID, description, aggTID, providerTID = RechargeService.rechargeDevice(recharge_order.id, rechargeType, strProviderCode, deviceNumber, recharge_order.totalAmount, plan, )
     recharge_order.spiceTID = spiceTID
     recharge_order.responseTimestamp = datetime.datetime.now()
     recharge_order.description = description
     session.commit()
     if retCode == '00' and retStatus == 'S':
                     promotionServiceClient.get_client().trackCouponUsage(couponCode, recharge_order.id, recharge_order.userId)
                 except Exception as e:
                     print 'Unable to track the usage of coupon - ' + recharge_order.couponCode + ' and spiceTID - ' + str(spiceTID)
                     print e
         return True
-    elif retCode in ('STO', 'US', 'UP') and retStatus == 'S':
+    elif retCode in ('STO', 'US', 'UP','STP') and retStatus == 'S':
+        if recharge_order.couponAmount > 0 :
+            couponCode = recharge_order.couponCode
+            if couponCode :
+                try:
+                    promotionServiceClient = PromotionClient()
+                    promotionServiceClient.get_client().trackCouponUsage(couponCode, recharge_order.id, recharge_order.userId)
+                except Exception as e:
+                    print 'Unable to track the usage of coupon - ' + recharge_order.couponCode + ' and spiceTID - ' + str(spiceTID)
+                    print e
         raise TransactionServiceException(111, "No response from operator within specified time")
     else:
         recharge_order.status = RechargeOrderStatus.RECHARGE_FAILED
         if retCode in ('SVAI', 'SVIA', 'AI', 'IA', 'EAI', 'SVEAI'):
             recharge_order.description = "Invalid Amount"
         elif retCode in ('CI', 'ECI', 'ESP', 'SVCI', 'SVECI', 'SVESP', 'SV_ECI', 'SV ECI'):
             recharge_order.description = "Invalid Device Number"
         session.commit()
         return False
+def __activate_recharge_txn_asynchronously(recharge_order, rechargeType, deviceNumber, strProviderCode, plan):
+    retStatus, retCode, spiceTID, description, aggTID, providerTID = RechargeService.rechargeDevice(recharge_order.id, rechargeType, strProviderCode, deviceNumber, recharge_order.totalAmount, plan, RechargeMode._NAMES_TO_VALUES.get('ASYNC'))
+    recharge_order.spiceTID = spiceTID
+    recharge_order.responseTimestamp = datetime.datetime.now()
+    recharge_order.status = RechargeOrderStatus.RECHARGE_UNKNOWN
+    recharge_order.description = 'Recharge In Process'
+    session.commit()
+    if recharge_order.couponAmount > 0 :
+        couponCode = recharge_order.couponCode
+        if couponCode :
+            try:
+                promotionServiceClient = PromotionClient()
+                promotionServiceClient.get_client().trackCouponUsage(couponCode, recharge_order.id, recharge_order.userId)
+            except Exception as e:
+                print 'Unable to track the usage of coupon - ' + recharge_order.couponCode + ' and spiceTID - ' + str(spiceTID)
+                print e
+    raise(TransactionServiceException(111, "Explicitly raising exception, will try to fetch final status"))
 def get_user_wallet(userId):
     wallet = UserWallet.get_by(userId = userId)
     if not wallet:
         wallet = UserWallet()
     strProviderCode = get_provider_code(rechargeTransaction.operatorId)
     if rechargeTransaction.deviceType == 1:
         rtype = 'MTP'
     else:
         rtype = 'RCH'
+    if rechargeTransaction.operatorId in (getAsyncOperatorsForRecharge()):
+        rechargeMode = RechargeMode._NAMES_TO_VALUES.get('ASYNC')
+    else:
+        rechargeMode = RechargeMode._NAMES_TO_VALUES.get('SYNC')
-    retStatus, retCode, spiceTID, description, aggTID, providerTID = RechargeService.rechargeDevice(rechargeTransaction.id, rtype, strProviderCode, rechargeTransaction.deviceNum, rechargeTransaction.amount, rechargeTransaction.plan, store.hotspotId)
+    retStatus, retCode, spiceTID, description, aggTID, providerTID = RechargeService.rechargeDevice(rechargeTransaction.id, rtype, strProviderCode, rechargeTransaction.deviceNum, rechargeTransaction.amount, rechargeTransaction.plan, store.hotspotId, rechargeMode)
     rechargeTransaction.spiceTID = spiceTID
     rechargeTransaction.aggTID = aggTID
     rechargeTransaction.providerTID = providerTID
     rechargeTransaction.responseTime = datetime.datetime.now()
     rechargeTransaction.description = description
+    if rechargeMode == RechargeMode._NAMES_TO_VALUES.get('SYNC'):
-    if retCode == '00' and retStatus == 'S':
+        if retCode == '00' and retStatus == 'S':
-        rechargeTransaction.status = RechargeOrderStatus.RECHARGE_SUCCESSFUL
+            rechargeTransaction.status = RechargeOrderStatus.RECHARGE_SUCCESSFUL
-        rechargeTransaction.invoiceNumber = get_next_invoice_number(OrderType.RCH4HOTSPOT)
+            rechargeTransaction.invoiceNumber = get_next_invoice_number(OrderType.RCH4HOTSPOT)
-    elif retCode in ('STO', 'US', 'UP') and retStatus == 'S':
+        elif retCode in ('STO', 'US', 'UP') and retStatus == 'S':
-        rechargeTransaction.status = RechargeOrderStatus.RECHARGE_UNKNOWN
+            rechargeTransaction.status = RechargeOrderStatus.RECHARGE_UNKNOWN
-    else:
+        else:
-        rechargeTransaction.status = RechargeOrderStatus.RECHARGE_FAILED
+            rechargeTransaction.status = RechargeOrderStatus.RECHARGE_FAILED
-        if retCode in ('SVAI', 'SVIA', 'AI', 'IA', 'EAI', 'SVEAI'):
+            if retCode in ('SVAI', 'SVIA', 'AI', 'IA', 'EAI', 'SVEAI'):
-            rechargeTransaction.description = "Invalid Amount"
+                rechargeTransaction.description = "Invalid Amount"
-        elif retCode in ('ECL', 'SVECL', 'SCL'):
+            elif retCode in ('ECL', 'SVECL', 'SCL'):
-            rechargeTransaction.description = "Customer Exceeded Daily Limit"
+                rechargeTransaction.description = "Customer Exceeded Daily Limit"
-        elif retCode in ('CI', 'ECI', 'ESP', 'SVCI', 'SVECI', 'SVESP', 'SV_ECI', 'SV ECI'):
+            elif retCode in ('CI', 'ECI', 'ESP', 'SVCI', 'SVECI', 'SVESP', 'SV_ECI', 'SV ECI'):
-            rechargeTransaction.description = "Invalid Device Number"
+                rechargeTransaction.description = "Invalid Device Number"
-        store = HotspotStore.get_by(id=rechargeTransaction.storeId)
+            store = HotspotStore.get_by(id=rechargeTransaction.storeId)
-        wallet = WalletForCompany.query.filter(WalletForCompany.companyId==store.companyId).with_lockmode("update").one()
+            wallet = WalletForCompany.query.filter(WalletForCompany.companyId==store.companyId).with_lockmode("update").one()
-        wh = WalletHistoryForCompany()
+            wh = WalletHistoryForCompany()
-        wh.walletId = wallet.id
+            wh.walletId = wallet.id
-        wh.amount = rechargeTransaction.amount
+            wh.amount = rechargeTransaction.amount
-        wh.transactionTime = rechargeTransaction.responseTime
+            wh.transactionTime = rechargeTransaction.responseTime
-        wh.openingBal = wallet.amount
+            wh.openingBal = wallet.amount
-        wh.closingBal = wallet.amount + wh.amount
+            wh.closingBal = wallet.amount + wh.amount
-        wh.referenceNumber = rechargeTransaction.id
+            wh.referenceNumber = rechargeTransaction.id
-        wh.description = "Credited amount"
+            wh.description = "Credited amount"
-        wallet.amount = wallet.amount + rechargeTransaction.amount
+            wallet.amount = wallet.amount + rechargeTransaction.amount
-        store.availableLimit = store.availableLimit + rechargeTransaction.amount
+            store.availableLimit = store.availableLimit + rechargeTransaction.amount
-        store.collectedAmount = store.collectedAmount - rechargeTransaction.amount + rechargeTransaction.discount
+            store.collectedAmount = store.collectedAmount - rechargeTransaction.amount + rechargeTransaction.discount
+    else:
+        rechargeTransaction.status = RechargeOrderStatus.RECHARGE_IN_PROCESS
+        rechargeTransaction.description = 'Recharge In Process'
     session.commit()
     return rechargeTransaction
 def get_frcs(circleId, operatorId):
     query = FRC.query.filter(FRC.circleId == circleId)
     if(operatorId > 0):
                 fa_Order.cancelReason = faOrder.cancelReason
                 fa_Order.returnReason = faOrder.returnReason
                 fa_Order.freebieItemId = faOrder.freebieItemId
                 fa_Order.productTitle = faOrder.productTitle
     session.commit()
+def get_recharge_order_status(rechargeOrderId, final):
+    d_rechargeOrder = get_recharge_order(rechargeOrderId)
+    if d_rechargeOrder.status == RechargeOrderStatus.RECHARGE_UNKNOWN:
+        try:
+            status, description = RechargeService.checkTransactionStatus('', str(rechargeOrderId))
+            print status, description
+            if status:
+                update_recharge_order_status(rechargeOrderId, RechargeOrderStatus.RECHARGE_SUCCESSFUL)
+            else:
+                update_recharge_order_status(rechargeOrderId, RechargeOrderStatus.RECHARGE_FAILED)
+        except:
+            if final:
+                d_rechargeOrder.status = RechargeOrderStatus.PAYMENT_SUCCESSFUL
+        finally:
+            return get_recharge_order(rechargeOrderId)
+    else:
+        return d_rechargeOrder
+def get_recharge_transaction_status(rechargeTransactionId, final):
+    d_rechargeTransaction = get_recharge_transaction(rechargeTransactionId)
+    if d_rechargeTransaction.status == RechargeOrderStatus.RECHARGE_IN_PROCESS:
+        try:
+            status, description = RechargeService.checkTransactionStatus('', str(rechargeTransactionId))
+            print status, description
+            if status:
+                update_recharge_transaction_status(rechargeTransactionId, RechargeOrderStatus.RECHARGE_SUCCESSFUL)
+            else:
+                update_recharge_transaction_status(rechargeTransactionId, RechargeOrderStatus.RECHARGE_FAILED)
+        except:
+            if final:
+                d_rechargeTransaction.status = RechargeOrderStatus.RECHARGE_UNKNOWN
+        finally:
+            return get_recharge_transaction(rechargeTransactionId)
+    else:
+        return d_rechargeTransaction
 if __name__ == '__main__':
     print get_orders_by_mobile_number("9650889334")

Subversion Repositories SmartDukaan

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