WebSVN – SmartDukaan – Diff – //trunk/PyProj/src/shop2020/thriftpy/model/v1/order/TransactionService.py

      - storeId
      - password
     """
     pass
-  def getSourceDetail(self, source):
+  def topupCompanyWallet(self, companyId, amount):
     """
     Parameters:
+     - companyId
-     - source
+     - amount
     """
     pass
-  def getAllCircles(self, ):
+  def getWalletBalanceForCompany(self, companyId):
+    """
+    Parameters:
+     - companyId
+    """
     pass
-  def deleteFrcs(self, frcIdsToDelete):
+  def getSourceDetail(self, source):
     """
     Parameters:
-     - frcIdsToDelete
+     - source
     """
     pass
 class Client(shop2020.thriftpy.generic.GenericService.Client, Iface):
     self._iprot.readMessageEnd()
     if result.success is not None:
       return result.success
     raise TApplicationException(TApplicationException.MISSING_RESULT, "updateHotspotStorePassword failed: unknown result");
-  def getSourceDetail(self, source):
+  def topupCompanyWallet(self, companyId, amount):
     """
     Parameters:
+     - companyId
-     - source
+     - amount
     """
-    self.send_getSourceDetail(source)
+    self.send_topupCompanyWallet(companyId, amount)
-    return self.recv_getSourceDetail()
+    return self.recv_topupCompanyWallet()
-  def send_getSourceDetail(self, source):
+  def send_topupCompanyWallet(self, companyId, amount):
-    self._oprot.writeMessageBegin('getSourceDetail', TMessageType.CALL, self._seqid)
+    self._oprot.writeMessageBegin('topupCompanyWallet', TMessageType.CALL, self._seqid)
-    args = getSourceDetail_args()
+    args = topupCompanyWallet_args()
+    args.companyId = companyId
-    args.source = source
+    args.amount = amount
     args.write(self._oprot)
     self._oprot.writeMessageEnd()
     self._oprot.trans.flush()
-  def recv_getSourceDetail(self, ):
+  def recv_topupCompanyWallet(self, ):
     (fname, mtype, rseqid) = self._iprot.readMessageBegin()
     if mtype == TMessageType.EXCEPTION:
       x = TApplicationException()
       x.read(self._iprot)
       self._iprot.readMessageEnd()
       raise x
-    result = getSourceDetail_result()
+    result = topupCompanyWallet_result()
     result.read(self._iprot)
     self._iprot.readMessageEnd()
     if result.success is not None:
       return result.success
-    raise TApplicationException(TApplicationException.MISSING_RESULT, "getSourceDetail failed: unknown result");
+    raise TApplicationException(TApplicationException.MISSING_RESULT, "topupCompanyWallet failed: unknown result");
-  def getAllCircles(self, ):
+  def getWalletBalanceForCompany(self, companyId):
+    """
+    Parameters:
+     - companyId
+    """
-    self.send_getAllCircles()
+    self.send_getWalletBalanceForCompany(companyId)
-    return self.recv_getAllCircles()
+    return self.recv_getWalletBalanceForCompany()
-  def send_getAllCircles(self, ):
+  def send_getWalletBalanceForCompany(self, companyId):
-    self._oprot.writeMessageBegin('getAllCircles', TMessageType.CALL, self._seqid)
+    self._oprot.writeMessageBegin('getWalletBalanceForCompany', TMessageType.CALL, self._seqid)
-    args = getAllCircles_args()
+    args = getWalletBalanceForCompany_args()
+    args.companyId = companyId
     args.write(self._oprot)
     self._oprot.writeMessageEnd()
     self._oprot.trans.flush()
-  def recv_getAllCircles(self, ):
+  def recv_getWalletBalanceForCompany(self, ):
     (fname, mtype, rseqid) = self._iprot.readMessageBegin()
     if mtype == TMessageType.EXCEPTION:
       x = TApplicationException()
       x.read(self._iprot)
       self._iprot.readMessageEnd()
       raise x
-    result = getAllCircles_result()
+    result = getWalletBalanceForCompany_result()
     result.read(self._iprot)
     self._iprot.readMessageEnd()
     if result.success is not None:
       return result.success
-    raise TApplicationException(TApplicationException.MISSING_RESULT, "getAllCircles failed: unknown result");
+    raise TApplicationException(TApplicationException.MISSING_RESULT, "getWalletBalanceForCompany failed: unknown result");
-  def deleteFrcs(self, frcIdsToDelete):
+  def getSourceDetail(self, source):
     """
     Parameters:
-     - frcIdsToDelete
+     - source
     """
-    self.send_deleteFrcs(frcIdsToDelete)
+    self.send_getSourceDetail(source)
-    return self.recv_deleteFrcs()
+    return self.recv_getSourceDetail()
-  def send_deleteFrcs(self, frcIdsToDelete):
+  def send_getSourceDetail(self, source):
-    self._oprot.writeMessageBegin('deleteFrcs', TMessageType.CALL, self._seqid)
+    self._oprot.writeMessageBegin('getSourceDetail', TMessageType.CALL, self._seqid)
-    args = deleteFrcs_args()
+    args = getSourceDetail_args()
-    args.frcIdsToDelete = frcIdsToDelete
+    args.source = source
     args.write(self._oprot)
     self._oprot.writeMessageEnd()
     self._oprot.trans.flush()
-  def recv_deleteFrcs(self, ):
+  def recv_getSourceDetail(self, ):
     (fname, mtype, rseqid) = self._iprot.readMessageBegin()
     if mtype == TMessageType.EXCEPTION:
       x = TApplicationException()
       x.read(self._iprot)
       self._iprot.readMessageEnd()
       raise x
-    result = deleteFrcs_result()
+    result = getSourceDetail_result()
     result.read(self._iprot)
     self._iprot.readMessageEnd()
     if result.success is not None:
       return result.success
-    raise TApplicationException(TApplicationException.MISSING_RESULT, "deleteFrcs failed: unknown result");
+    raise TApplicationException(TApplicationException.MISSING_RESULT, "getSourceDetail failed: unknown result");
 class Processor(shop2020.thriftpy.generic.GenericService.Processor, Iface, TProcessor):
   def __init__(self, handler):
     shop2020.thriftpy.generic.GenericService.Processor.__init__(self, handler)
     self._processMap["getTelecomCircle"] = Processor.process_getTelecomCircle
     self._processMap["retrieveHotspotRechargeInvoice"] = Processor.process_retrieveHotspotRechargeInvoice
     self._processMap["splitFreebieOrder"] = Processor.process_splitFreebieOrder
     self._processMap["getRechargeTransactionsByNumber"] = Processor.process_getRechargeTransactionsByNumber
     self._processMap["updateHotspotStorePassword"] = Processor.process_updateHotspotStorePassword
+    self._processMap["topupCompanyWallet"] = Processor.process_topupCompanyWallet
+    self._processMap["getWalletBalanceForCompany"] = Processor.process_getWalletBalanceForCompany
     self._processMap["getSourceDetail"] = Processor.process_getSourceDetail
-    self._processMap["getAllCircles"] = Processor.process_getAllCircles
-    self._processMap["deleteFrcs"] = Processor.process_deleteFrcs
   def process(self, iprot, oprot):
     (name, type, seqid) = iprot.readMessageBegin()
     if name not in self._processMap:
       iprot.skip(TType.STRUCT)
     oprot.writeMessageBegin("updateHotspotStorePassword", TMessageType.REPLY, seqid)
     result.write(oprot)
     oprot.writeMessageEnd()
     oprot.trans.flush()
-  def process_getSourceDetail(self, seqid, iprot, oprot):
+  def process_topupCompanyWallet(self, seqid, iprot, oprot):
-    args = getSourceDetail_args()
+    args = topupCompanyWallet_args()
     args.read(iprot)
     iprot.readMessageEnd()
-    result = getSourceDetail_result()
+    result = topupCompanyWallet_result()
-    result.success = self._handler.getSourceDetail(args.source)
+    result.success = self._handler.topupCompanyWallet(args.companyId, args.amount)
-    oprot.writeMessageBegin("getSourceDetail", TMessageType.REPLY, seqid)
+    oprot.writeMessageBegin("topupCompanyWallet", TMessageType.REPLY, seqid)
     result.write(oprot)
     oprot.writeMessageEnd()
     oprot.trans.flush()
-  def process_getAllCircles(self, seqid, iprot, oprot):
+  def process_getWalletBalanceForCompany(self, seqid, iprot, oprot):
-    args = getAllCircles_args()
+    args = getWalletBalanceForCompany_args()
     args.read(iprot)
     iprot.readMessageEnd()
-    result = getAllCircles_result()
+    result = getWalletBalanceForCompany_result()
-    result.success = self._handler.getAllCircles()
+    result.success = self._handler.getWalletBalanceForCompany(args.companyId)
-    oprot.writeMessageBegin("getAllCircles", TMessageType.REPLY, seqid)
+    oprot.writeMessageBegin("getWalletBalanceForCompany", TMessageType.REPLY, seqid)
     result.write(oprot)
     oprot.writeMessageEnd()
     oprot.trans.flush()
-  def process_deleteFrcs(self, seqid, iprot, oprot):
+  def process_getSourceDetail(self, seqid, iprot, oprot):
-    args = deleteFrcs_args()
+    args = getSourceDetail_args()
     args.read(iprot)
     iprot.readMessageEnd()
-    result = deleteFrcs_result()
+    result = getSourceDetail_result()
-    result.success = self._handler.deleteFrcs(args.frcIdsToDelete)
+    result.success = self._handler.getSourceDetail(args.source)
-    oprot.writeMessageBegin("deleteFrcs", TMessageType.REPLY, seqid)
+    oprot.writeMessageBegin("getSourceDetail", TMessageType.REPLY, seqid)
     result.write(oprot)
     oprot.writeMessageEnd()
     oprot.trans.flush()
     return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
   def __ne__(self, other):
     return not (self == other)
-class getSourceDetail_args:
+class topupCompanyWallet_args:
   """
   Attributes:
+   - companyId
-   - source
+   - amount
   """
   thrift_spec = (
     None, # 0
+    (1, TType.I64, 'companyId', None, None, ), # 1
-    (1, TType.I64, 'source', None, None, ), # 1
+    (2, TType.I64, 'amount', None, None, ), # 2
+  )
-  def __init__(self, source=None,):
+  def __init__(self, companyId=None, amount=None,):
+    self.companyId = companyId
-    self.source = source
+    self.amount = amount
   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
       (fname, ftype, fid) = iprot.readFieldBegin()
       if ftype == TType.STOP:
         break
       if fid == 1:
         if ftype == TType.I64:
+          self.companyId = iprot.readI64();
+        else:
+          iprot.skip(ftype)
+      elif fid == 2:
+        if ftype == TType.I64:
-          self.source = iprot.readI64();
+          self.amount = iprot.readI64();
         else:
           iprot.skip(ftype)
       else:
         iprot.skip(ftype)
       iprot.readFieldEnd()
   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('getSourceDetail_args')
+    oprot.writeStructBegin('topupCompanyWallet_args')
+    if self.companyId is not None:
+      oprot.writeFieldBegin('companyId', TType.I64, 1)
+      oprot.writeI64(self.companyId)
+      oprot.writeFieldEnd()
-    if self.source is not None:
+    if self.amount is not None:
-      oprot.writeFieldBegin('source', TType.I64, 1)
+      oprot.writeFieldBegin('amount', TType.I64, 2)
-      oprot.writeI64(self.source)
+      oprot.writeI64(self.amount)
       oprot.writeFieldEnd()
     oprot.writeFieldStop()
     oprot.writeStructEnd()
   def validate(self):
     return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
   def __ne__(self, other):
     return not (self == other)
-class getSourceDetail_result:
+class topupCompanyWallet_result:
   """
   Attributes:
    - success
   """
   thrift_spec = (
-    (0, TType.STRUCT, 'success', (SourceDetail, SourceDetail.thrift_spec), None, ), # 0
+    (0, TType.I64, 'success', None, None, ), # 0
+  )
   def __init__(self, success=None,):
     self.success = success
     while True:
       (fname, ftype, fid) = iprot.readFieldBegin()
       if ftype == TType.STOP:
         break
       if fid == 0:
-        if ftype == TType.STRUCT:
+        if ftype == TType.I64:
-          self.success = SourceDetail()
+          self.success = iprot.readI64();
-          self.success.read(iprot)
         else:
           iprot.skip(ftype)
       else:
         iprot.skip(ftype)
       iprot.readFieldEnd()
   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('getSourceDetail_result')
+    oprot.writeStructBegin('topupCompanyWallet_result')
     if self.success is not None:
-      oprot.writeFieldBegin('success', TType.STRUCT, 0)
+      oprot.writeFieldBegin('success', TType.I64, 0)
-      self.success.write(oprot)
+      oprot.writeI64(self.success)
       oprot.writeFieldEnd()
     oprot.writeFieldStop()
     oprot.writeStructEnd()
   def validate(self):
     return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
   def __ne__(self, other):
     return not (self == other)
-class getAllCircles_args:
+class getWalletBalanceForCompany_args:
+  """
+  Attributes:
+   - companyId
+  """
   thrift_spec = (
+    None, # 0
+    (1, TType.I64, 'companyId', None, None, ), # 1
+  )
+  def __init__(self, companyId=None,):
+    self.companyId = companyId
   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.companyId = iprot.readI64();
+        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('getAllCircles_args')
+    oprot.writeStructBegin('getWalletBalanceForCompany_args')
+    if self.companyId is not None:
+      oprot.writeFieldBegin('companyId', TType.I64, 1)
+      oprot.writeI64(self.companyId)
+      oprot.writeFieldEnd()
     oprot.writeFieldStop()
     oprot.writeStructEnd()
   def validate(self):
     return
     return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
   def __ne__(self, other):
     return not (self == other)
-class getAllCircles_result:
+class getWalletBalanceForCompany_result:
   """
   Attributes:
    - success
   """
   thrift_spec = (
-    (0, TType.LIST, 'success', (TType.STRUCT,(TelecomCircle, TelecomCircle.thrift_spec)), None, ), # 0
+    (0, TType.I64, 'success', None, None, ), # 0
+  )
   def __init__(self, success=None,):
     self.success = success
     while True:
       (fname, ftype, fid) = iprot.readFieldBegin()
       if ftype == TType.STOP:
         break
       if fid == 0:
-        if ftype == TType.LIST:
+        if ftype == TType.I64:
-          self.success = []
-          (_etype768, _size765) = iprot.readListBegin()
-          for _i769 in xrange(_size765):
-            _elem770 = TelecomCircle()
-            _elem770.read(iprot)
-            self.success.append(_elem770)
+          self.success = iprot.readI64();
-          iprot.readListEnd()
         else:
           iprot.skip(ftype)
       else:
         iprot.skip(ftype)
       iprot.readFieldEnd()
   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('getAllCircles_result')
+    oprot.writeStructBegin('getWalletBalanceForCompany_result')
     if self.success is not None:
-      oprot.writeFieldBegin('success', TType.LIST, 0)
+      oprot.writeFieldBegin('success', TType.I64, 0)
-      oprot.writeListBegin(TType.STRUCT, len(self.success))
-      for iter771 in self.success:
+      oprot.writeI64(self.success)
-        iter771.write(oprot)
-      oprot.writeListEnd()
       oprot.writeFieldEnd()
     oprot.writeFieldStop()
     oprot.writeStructEnd()
   def validate(self):
     return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
   def __ne__(self, other):
     return not (self == other)
-class deleteFrcs_args:
+class getSourceDetail_args:
   """
   Attributes:
-   - frcIdsToDelete
+   - source
   """
   thrift_spec = (
     None, # 0
-    (1, TType.LIST, 'frcIdsToDelete', (TType.I64,None), None, ), # 1
+    (1, TType.I64, 'source', None, None, ), # 1
+  )
-  def __init__(self, frcIdsToDelete=None,):
+  def __init__(self, source=None,):
-    self.frcIdsToDelete = frcIdsToDelete
+    self.source = source
   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
     while True:
       (fname, ftype, fid) = iprot.readFieldBegin()
       if ftype == TType.STOP:
         break
       if fid == 1:
-        if ftype == TType.LIST:
+        if ftype == TType.I64:
-          self.frcIdsToDelete = []
-          (_etype775, _size772) = iprot.readListBegin()
-          for _i776 in xrange(_size772):
-            _elem777 = iprot.readI64();
+          self.source = iprot.readI64();
-            self.frcIdsToDelete.append(_elem777)
-          iprot.readListEnd()
         else:
           iprot.skip(ftype)
       else:
         iprot.skip(ftype)
       iprot.readFieldEnd()
   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('deleteFrcs_args')
+    oprot.writeStructBegin('getSourceDetail_args')
-    if self.frcIdsToDelete is not None:
+    if self.source is not None:
-      oprot.writeFieldBegin('frcIdsToDelete', TType.LIST, 1)
+      oprot.writeFieldBegin('source', TType.I64, 1)
-      oprot.writeListBegin(TType.I64, len(self.frcIdsToDelete))
-      for iter778 in self.frcIdsToDelete:
-        oprot.writeI64(iter778)
+      oprot.writeI64(self.source)
-      oprot.writeListEnd()
       oprot.writeFieldEnd()
     oprot.writeFieldStop()
     oprot.writeStructEnd()
   def validate(self):
     return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
   def __ne__(self, other):
     return not (self == other)
-class deleteFrcs_result:
+class getSourceDetail_result:
   """
   Attributes:
    - success
   """
   thrift_spec = (
-    (0, TType.BOOL, 'success', None, None, ), # 0
+    (0, TType.STRUCT, 'success', (SourceDetail, SourceDetail.thrift_spec), None, ), # 0
+  )
   def __init__(self, success=None,):
     self.success = success
     while True:
       (fname, ftype, fid) = iprot.readFieldBegin()
       if ftype == TType.STOP:
         break
       if fid == 0:
-        if ftype == TType.BOOL:
+        if ftype == TType.STRUCT:
-          self.success = iprot.readBool();
+          self.success = SourceDetail()
+          self.success.read(iprot)
         else:
           iprot.skip(ftype)
       else:
         iprot.skip(ftype)
       iprot.readFieldEnd()
   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('deleteFrcs_result')
+    oprot.writeStructBegin('getSourceDetail_result')
     if self.success is not None:
-      oprot.writeFieldBegin('success', TType.BOOL, 0)
+      oprot.writeFieldBegin('success', TType.STRUCT, 0)
-      oprot.writeBool(self.success)
+      self.success.write(oprot)
       oprot.writeFieldEnd()
     oprot.writeFieldStop()
     oprot.writeStructEnd()
   def validate(self):

Subversion Repositories SmartDukaan

(root)//trunk/PyProj/src/shop2020/thriftpy/model/v1/order/TransactionService.py – Rev 7267 → 7285