WebSVN – SmartDukaan – Diff – //trunk/PyProj/src/shop2020/thriftpy/payments/PaymentService.py

     pass
   def capturePayment(self, merchantTxnId):
     """
     Capture the payment for the given merchant transaction id. It processes the last payment for the given
-    transaction. If the capture attempt failed, the payment is marked as failed. PaymentException with error
-    code 104 is	thrown in case no payments are found for the transaction id passed.
+    transaction. PaymentException with error code 104 is thrown in case no payments are found for the transaction id passed.
     PaymentException is also thrown with error code 106 in case capture was not possible due to connection
     issue. Here, we	payment also gets updated to CAPTURE_INPROCESS state
     Parameters:
      - merchantTxnId
     """
     pass
+  def refundPayment(self, merchantTxnId, amount, isDigital):
+    """
+    Capture the payment for the given merchant transaction id. It processes the last payment for the given
+    transaction. If the capture attempt failed, the payment is marked as failed. PaymentException with error
+    code 104 is	thrown in case no payments are found for the transaction id passed. PaymentException is also
+    thrown with error code 106 in case capture was not possible due to connection
+    issue.
+    Parameters:
+     - merchantTxnId
+     - amount
+     - isDigital
+    """
+    pass
   def partiallyCapturePayment(self, merchantTxnId, amount, xferBy, xferTxnId, xferDate):
     """
     Adds the given amount to the captured amount of a COD payment.
     Updates the captured amount for the corresponding payment and marks it as PARTIALLY CAPTURED.
     If the captured amount becomes equal to total amount, then the payment status is set as SUCCESS.
     raise TApplicationException(TApplicationException.MISSING_RESULT, "createRefund failed: unknown result");
   def capturePayment(self, merchantTxnId):
     """
     Capture the payment for the given merchant transaction id. It processes the last payment for the given
-    transaction. If the capture attempt failed, the payment is marked as failed. PaymentException with error
-    code 104 is	thrown in case no payments are found for the transaction id passed.
+    transaction. PaymentException with error code 104 is thrown in case no payments are found for the transaction id passed.
     PaymentException is also thrown with error code 106 in case capture was not possible due to connection
     issue. Here, we	payment also gets updated to CAPTURE_INPROCESS state
     Parameters:
      - merchantTxnId
       return result.success
     if result.pe is not None:
       raise result.pe
     raise TApplicationException(TApplicationException.MISSING_RESULT, "capturePayment failed: unknown result");
+  def refundPayment(self, merchantTxnId, amount, isDigital):
+    """
+    Capture the payment for the given merchant transaction id. It processes the last payment for the given
+    transaction. If the capture attempt failed, the payment is marked as failed. PaymentException with error
+    code 104 is	thrown in case no payments are found for the transaction id passed. PaymentException is also
+    thrown with error code 106 in case capture was not possible due to connection
+    issue.
+    Parameters:
+     - merchantTxnId
+     - amount
+     - isDigital
+    """
+    self.send_refundPayment(merchantTxnId, amount, isDigital)
+    return self.recv_refundPayment()
+  def send_refundPayment(self, merchantTxnId, amount, isDigital):
+    self._oprot.writeMessageBegin('refundPayment', TMessageType.CALL, self._seqid)
+    args = refundPayment_args()
+    args.merchantTxnId = merchantTxnId
+    args.amount = amount
+    args.isDigital = isDigital
+    args.write(self._oprot)
+    self._oprot.writeMessageEnd()
+    self._oprot.trans.flush()
+  def recv_refundPayment(self, ):
+    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+    if mtype == TMessageType.EXCEPTION:
+      x = TApplicationException()
+      x.read(self._iprot)
+      self._iprot.readMessageEnd()
+      raise x
+    result = refundPayment_result()
+    result.read(self._iprot)
+    self._iprot.readMessageEnd()
+    if result.success is not None:
+      return result.success
+    if result.pe is not None:
+      raise result.pe
+    raise TApplicationException(TApplicationException.MISSING_RESULT, "refundPayment failed: unknown result");
   def partiallyCapturePayment(self, merchantTxnId, amount, xferBy, xferTxnId, xferDate):
     """
     Adds the given amount to the captured amount of a COD payment.
     Updates the captured amount for the corresponding payment and marks it as PARTIALLY CAPTURED.
     If the captured amount becomes equal to total amount, then the payment status is set as SUCCESS.
     self._processMap["initializeHdfcPayment"] = Processor.process_initializeHdfcPayment
     self._processMap["doHdfcPaymentForDigitalOrder"] = Processor.process_doHdfcPaymentForDigitalOrder
     self._processMap["initializeHdfcEmiPayment"] = Processor.process_initializeHdfcEmiPayment
     self._processMap["createRefund"] = Processor.process_createRefund
     self._processMap["capturePayment"] = Processor.process_capturePayment
+    self._processMap["refundPayment"] = Processor.process_refundPayment
     self._processMap["partiallyCapturePayment"] = Processor.process_partiallyCapturePayment
     self._processMap["getPaymentsRequiringExtraProcessing"] = Processor.process_getPaymentsRequiringExtraProcessing
     self._processMap["markPaymentAsProcessed"] = Processor.process_markPaymentAsProcessed
   def process(self, iprot, oprot):
     oprot.writeMessageBegin("capturePayment", TMessageType.REPLY, seqid)
     result.write(oprot)
     oprot.writeMessageEnd()
     oprot.trans.flush()
+  def process_refundPayment(self, seqid, iprot, oprot):
+    args = refundPayment_args()
+    args.read(iprot)
+    iprot.readMessageEnd()
+    result = refundPayment_result()
+    try:
+      result.success = self._handler.refundPayment(args.merchantTxnId, args.amount, args.isDigital)
+    except PaymentException, pe:
+      result.pe = pe
+    oprot.writeMessageBegin("refundPayment", TMessageType.REPLY, seqid)
+    result.write(oprot)
+    oprot.writeMessageEnd()
+    oprot.trans.flush()
   def process_partiallyCapturePayment(self, seqid, iprot, oprot):
     args = partiallyCapturePayment_args()
     args.read(iprot)
     iprot.readMessageEnd()
     result = partiallyCapturePayment_result()
     if self.success is not None:
       oprot.writeFieldBegin('success', TType.BOOL, 0)
       oprot.writeBool(self.success)
       oprot.writeFieldEnd()
     if self.pe is not None:
+      oprot.writeFieldBegin('pe', TType.STRUCT, 1)
+      self.pe.write(oprot)
+      oprot.writeFieldEnd()
+    oprot.writeFieldStop()
+    oprot.writeStructEnd()
+  def validate(self):
+    return
+  def __repr__(self):
+    L = ['%s=%r' % (key, value)
+      for key, value in self.__dict__.iteritems()]
+    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
+  def __eq__(self, other):
+    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
+  def __ne__(self, other):
+    return not (self == other)
+class refundPayment_args:
+  """
+  Attributes:
+   - merchantTxnId
+   - amount
+   - isDigital
+  """
+  thrift_spec = (
+    None, # 0
+    (1, TType.I64, 'merchantTxnId', None, None, ), # 1
+    (2, TType.DOUBLE, 'amount', None, None, ), # 2
+    (3, TType.BOOL, 'isDigital', None, None, ), # 3
+  )
+  def __init__(self, merchantTxnId=None, amount=None, isDigital=None,):
+    self.merchantTxnId = merchantTxnId
+    self.amount = amount
+    self.isDigital = isDigital
+  def read(self, iprot):
+    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
+      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
+      return
+    iprot.readStructBegin()
+    while True:
+      (fname, ftype, fid) = iprot.readFieldBegin()
+      if ftype == TType.STOP:
+        break
+      if fid == 1:
+        if ftype == TType.I64:
+          self.merchantTxnId = iprot.readI64();
+        else:
+          iprot.skip(ftype)
+      elif fid == 2:
+        if ftype == TType.DOUBLE:
+          self.amount = iprot.readDouble();
+        else:
+          iprot.skip(ftype)
+      elif fid == 3:
+        if ftype == TType.BOOL:
+          self.isDigital = iprot.readBool();
+        else:
+          iprot.skip(ftype)
+      else:
+        iprot.skip(ftype)
+      iprot.readFieldEnd()
+    iprot.readStructEnd()
+  def write(self, oprot):
+    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
+      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
+      return
+    oprot.writeStructBegin('refundPayment_args')
+    if self.merchantTxnId is not None:
+      oprot.writeFieldBegin('merchantTxnId', TType.I64, 1)
+      oprot.writeI64(self.merchantTxnId)
+      oprot.writeFieldEnd()
+    if self.amount is not None:
+      oprot.writeFieldBegin('amount', TType.DOUBLE, 2)
+      oprot.writeDouble(self.amount)
+      oprot.writeFieldEnd()
+    if self.isDigital is not None:
+      oprot.writeFieldBegin('isDigital', TType.BOOL, 3)
+      oprot.writeBool(self.isDigital)
+      oprot.writeFieldEnd()
+    oprot.writeFieldStop()
+    oprot.writeStructEnd()
+  def validate(self):
+    return
+  def __repr__(self):
+    L = ['%s=%r' % (key, value)
+      for key, value in self.__dict__.iteritems()]
+    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
+  def __eq__(self, other):
+    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
+  def __ne__(self, other):
+    return not (self == other)
+class refundPayment_result:
+  """
+  Attributes:
+   - success
+   - pe
+  """
+  thrift_spec = (
+    (0, TType.BOOL, 'success', None, None, ), # 0
+    (1, TType.STRUCT, 'pe', (PaymentException, PaymentException.thrift_spec), None, ), # 1
+  )
+  def __init__(self, success=None, pe=None,):
+    self.success = success
+    self.pe = pe
+  def read(self, iprot):
+    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
+      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
+      return
+    iprot.readStructBegin()
+    while True:
+      (fname, ftype, fid) = iprot.readFieldBegin()
+      if ftype == TType.STOP:
+        break
+      if fid == 0:
+        if ftype == TType.BOOL:
+          self.success = iprot.readBool();
+        else:
+          iprot.skip(ftype)
+      elif fid == 1:
+        if ftype == TType.STRUCT:
+          self.pe = PaymentException()
+          self.pe.read(iprot)
+        else:
+          iprot.skip(ftype)
+      else:
+        iprot.skip(ftype)
+      iprot.readFieldEnd()
+    iprot.readStructEnd()
+  def write(self, oprot):
+    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
+      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
+      return
+    oprot.writeStructBegin('refundPayment_result')
+    if self.success is not None:
+      oprot.writeFieldBegin('success', TType.BOOL, 0)
+      oprot.writeBool(self.success)
+      oprot.writeFieldEnd()
+    if self.pe is not None:
       oprot.writeFieldBegin('pe', TType.STRUCT, 1)
       self.pe.write(oprot)
       oprot.writeFieldEnd()
     oprot.writeFieldStop()
     oprot.writeStructEnd()

Subversion Repositories SmartDukaan

(root)//trunk/PyProj/src/shop2020/thriftpy/payments/PaymentService.py – Rev 6228 → 6486