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

     get_all_verification_agents, get_all_attributes_for_order_id, \
     set_order_attribute_for_transaction, get_billed_orders, get_all_return_orders, \
     mark_order_as_received_at_store, get_receive_pending_orders, \
     get_received_at_store_orders, mark_orders_as_returned_from_store, \
     set_order_attributes, get_orders_collection_at_store, get_order_attribute_value,\
-    change_jacket_number, mark_order_as_rto_in_transit
+    change_jacket_number, mark_order_as_rto_in_transit, get_recharge_order,\
+    get_recharge_orders, update_recharge_order_status, activate_recharge_txn,\
+    get_user_wallet, get_user_wallet_history
 from shop2020.model.v1.order.impl.model.DTHRechargeOrder import DTHRechargeOrder
 from shop2020.model.v1.order.impl.model.MobileRechargeOrder import \
     MobileRechargeOrder
 from shop2020.thriftpy.model.v1.order.ttypes import TransactionServiceException, \
     RechargeType
 from shop2020.utils.Utils import to_py_date, get_fdate_tdate, to_java_date
+from shop2020.model.v1.order.impl.model.DigitalTransaction import DigitalTransaction
+import datetime
 class OrderServiceHandler:
     def createRechargeOrder(self, thriftRechargeOrder):
         """
         Parameters:
          - thriftRechargeOrder
         """
-        if thriftRechargeOrder is None or thriftRechargeOrder.rechargeType is None:
-            raise TransactionServiceException(102, 'Order or the type is Null')
-        rechargeOrder = None
-        if thriftRechargeOrder.rechargeType == RechargeType.MOBILE:
-            rechargeOrder = MobileRechargeOrder()
-        elif thriftRechargeOrder.rechargeType == RechargeType.DTH:
-            rechargeOrder = DTHRechargeOrder()
-        if rechargeOrder is None:
-            raise TransactionServiceException(102, 'Unsupported recharge type')
         try:
+            if thriftRechargeOrder is None or thriftRechargeOrder.rechargeType is None:
+                raise TransactionServiceException(102, 'Order or the type is Null')
+            rechargeOrder = None
+            if thriftRechargeOrder.rechargeType == RechargeType.MOBILE:
+                rechargeOrder = MobileRechargeOrder()
+            elif thriftRechargeOrder.rechargeType == RechargeType.DTH:
+                rechargeOrder = DTHRechargeOrder()
+            if rechargeOrder is None:
+                raise TransactionServiceException(102, 'Unsupported recharge type')
+            transaction = DigitalTransaction()
+            transaction.createdOn = datetime.datetime.now()
+            transaction.userId = rechargeOrder.userId
+            transaction.orders = [rechargeOrder]
             rechargeOrder.from_thrift_object(thriftRechargeOrder)
             session.commit()
-            return rechargeOrder
+            return rechargeOrder.to_thrift_object()
         except:
             raise TransactionServiceException(103, 'Invalid values passed')
         finally:
             self.closeSession()
+    def getRechargeOrder(self, rechargeOrderId):
+        """
+        Parameters:
+         - rechargeOrderId
+        """
+        try:
+            return get_recharge_order(rechargeOrderId)
+        finally:
+            self.closeSession()
+    def getRechargeOrders(self, userId):
+        """
+        Parameters:
+         - userId
+        """
+        try:
+            return [order.to_thrift_object() for order in get_recharge_orders(userId)]
+        finally:
+            self.closeSession()
     def updateRechargeOrderStatus(self, rechargeOrderId, rechargeOrderStatus):
         """
         Parameters:
          - rechargeOrderId
          - rechargeOrderStatus
         """
-        pass
+        try:
+            return update_recharge_order_status(rechargeOrderId, rechargeOrderStatus)
+        finally:
+            self.closeSession()
-    def activateRechargeTxn(self, rechargeCoupons):
+    def activateRechargeTxn(self, rechargeOrderId):
         """
         Parameters:
-         - rechargeCoupons
+         - rechargeOrderId
         """
-        pass
+        try:
+            return True
+            activate_recharge_txn(rechargeOrderId)
+        finally:
+            self.closeSession()
-    def getRechargeOrders(self, customerId):
+    def getUserWallet(self, userId):
         """
         Parameters:
-         - customerId
+         - userId
         """
-        pass
+        try:
+            return get_user_wallet(userId).to_thrift_object()
+        finally:
+            self.closeSession()
-    def getRechargeCoupons(self, customerId, rechargeCouponStatus):
+    def getUserWalletHistory(self, userId):
         """
         Parameters:
-         - customerId
+         - userId
-         - rechargeCouponStatus
         """
-        pass
+        try:
+            return [wallet.to_thrift_object() for wallet in get_user_wallet_history(userId)]
+        finally:
+            self.closeSession()
     def closeSession(self, ):
         close_session()
     def isAlive(self, ):

Subversion Repositories SmartDukaan

(root)/trunk/PyProj/src/shop2020/model/v1/order/impl/OrderServiceHandler.py – Rev 6019 → 6031