Subversion Repositories SmartDukaan

Rev

Rev 3546 | Rev 4948 | Go to most recent revision | Show entire file | Ignore whitespace | Details | Blame | Last modification | View Log | RSS feed

Rev 3546 Rev 4008
Line 102... Line 102...
102 
    Parameters:
 102 
    Parameters:
103 
     - timestamp
 103 
     - timestamp
104 
    """
 104 
    """
105 
    pass
 105 
    pass
106 
 
 106 
 
107 
  def processCODTxn(self, transactionId):
 - 
 
108 
    """
 - 
 
109 
    Parameters:
 - 
 
110 
     - transactionId
 - 
 
111 
    """
 - 
 
112 
    pass
 - 
 
113 
 
 - 
 
114 
 
 107 
 
115 
class Client(shop2020.thriftpy.generic.GenericService.Client, Iface):
 108 
class Client(shop2020.thriftpy.generic.GenericService.Client, Iface):
116 
  def __init__(self, iprot, oprot=None):
 109 
  def __init__(self, iprot, oprot=None):
117 
    shop2020.thriftpy.generic.GenericService.Client.__init__(self, iprot, oprot)
 110 
    shop2020.thriftpy.generic.GenericService.Client.__init__(self, iprot, oprot)
118 
 
 111 
 
Line 494... Line 487...
494 
    result = updateLastEmailProcessedTimestamp_result()
 487 
    result = updateLastEmailProcessedTimestamp_result()
495 
    result.read(self._iprot)
 488 
    result.read(self._iprot)
496 
    self._iprot.readMessageEnd()
 489 
    self._iprot.readMessageEnd()
497 
    return
 490 
    return
498 
 
 491 
 
499 
  def processCODTxn(self, transactionId):
 - 
 
500 
    """
 - 
 
501 
    Parameters:
 - 
 
502 
     - transactionId
 - 
 
503 
    """
 - 
 
504 
    self.send_processCODTxn(transactionId)
 - 
 
505 
 
 - 
 
506 
  def send_processCODTxn(self, transactionId):
 - 
 
507 
    self._oprot.writeMessageBegin('processCODTxn', TMessageType.CALL, self._seqid)
 - 
 
508 
    args = processCODTxn_args()
 - 
 
509 
    args.transactionId = transactionId
 - 
 
510 
    args.write(self._oprot)
 - 
 
511 
    self._oprot.writeMessageEnd()
 - 
 
512 
    self._oprot.trans.flush()
 - 
 
513 
 
 492 
 
514 
class Processor(shop2020.thriftpy.generic.GenericService.Processor, Iface, TProcessor):
 493 
class Processor(shop2020.thriftpy.generic.GenericService.Processor, Iface, TProcessor):
515 
  def __init__(self, handler):
 494 
  def __init__(self, handler):
516 
    shop2020.thriftpy.generic.GenericService.Processor.__init__(self, handler)
 495 
    shop2020.thriftpy.generic.GenericService.Processor.__init__(self, handler)
517 
    self._processMap["getTickets"] = Processor.process_getTickets
 496 
    self._processMap["getTickets"] = Processor.process_getTickets
Line 525... Line 504...
525 
    self._processMap["updatePasswordForAgent"] = Processor.process_updatePasswordForAgent
 504 
    self._processMap["updatePasswordForAgent"] = Processor.process_updatePasswordForAgent
526 
    self._processMap["getRoleNamesForAgent"] = Processor.process_getRoleNamesForAgent
 505 
    self._processMap["getRoleNamesForAgent"] = Processor.process_getRoleNamesForAgent
527 
    self._processMap["getPermissionsForRoleName"] = Processor.process_getPermissionsForRoleName
 506 
    self._processMap["getPermissionsForRoleName"] = Processor.process_getPermissionsForRoleName
528 
    self._processMap["getLastEmailProcessedTimestamp"] = Processor.process_getLastEmailProcessedTimestamp
 507 
    self._processMap["getLastEmailProcessedTimestamp"] = Processor.process_getLastEmailProcessedTimestamp
529 
    self._processMap["updateLastEmailProcessedTimestamp"] = Processor.process_updateLastEmailProcessedTimestamp
 508 
    self._processMap["updateLastEmailProcessedTimestamp"] = Processor.process_updateLastEmailProcessedTimestamp
530 
    self._processMap["processCODTxn"] = Processor.process_processCODTxn
 - 
 
531 
 
 509 
 
532 
  def process(self, iprot, oprot):
 510 
  def process(self, iprot, oprot):
533 
    (name, type, seqid) = iprot.readMessageBegin()
 511 
    (name, type, seqid) = iprot.readMessageBegin()
534 
    if name not in self._processMap:
 512 
    if name not in self._processMap:
535 
      iprot.skip(TType.STRUCT)
 513 
      iprot.skip(TType.STRUCT)
Line 685... Line 663...
685 
    oprot.writeMessageBegin("updateLastEmailProcessedTimestamp", TMessageType.REPLY, seqid)
 663 
    oprot.writeMessageBegin("updateLastEmailProcessedTimestamp", TMessageType.REPLY, seqid)
686 
    result.write(oprot)
 664 
    result.write(oprot)
687 
    oprot.writeMessageEnd()
 665 
    oprot.writeMessageEnd()
688 
    oprot.trans.flush()
 666 
    oprot.trans.flush()
689 
 
 667 
 
690 
  def process_processCODTxn(self, seqid, iprot, oprot):
 - 
 
691 
    args = processCODTxn_args()
 - 
 
692 
    args.read(iprot)
 - 
 
693 
    iprot.readMessageEnd()
 - 
 
694 
    self._handler.processCODTxn(args.transactionId)
 - 
 
695 
    return
 - 
 
696 
 
 - 
 
697 
 
 668 
 
698 
# HELPER FUNCTIONS AND STRUCTURES
 669 
# HELPER FUNCTIONS AND STRUCTURES
699 
 
 670 
 
700 
class getTickets_args:
 671 
class getTickets_args:
701 
  """
 672 
  """
Line 2233... Line 2204...
2233 
    oprot.writeFieldStop()
 2204 
    oprot.writeFieldStop()
2234 
    oprot.writeStructEnd()
 2205 
    oprot.writeStructEnd()
2235 
 
 2206 
 
2236 
  def validate(self):
 2207 
  def validate(self):
2237 
    return
 2208 
    return
2238 
 
 - 
 
2239 
 
 - 
 
2240 
  def __repr__(self):
 - 
 
2241 
    L = ['%s=%r' % (key, value)
 - 
 
2242 
      for key, value in self.__dict__.iteritems()]
 - 
 
2243 
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
 - 
 
2244 
 
 - 
 
2245 
  def __eq__(self, other):
 - 
 
2246 
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
 - 
 
2247 
 
 - 
 
2248 
  def __ne__(self, other):
 - 
 
2249 
    return not (self == other)
 - 
 
2250 
 
 - 
 
2251 
class processCODTxn_args:
 - 
 
2252 
  """
 - 
 
2253 
  Attributes:
 - 
 
2254 
   - transactionId
 - 
 
2255 
  """
 - 
 
2256 
 
 - 
 
2257 
  thrift_spec = (
 - 
 
2258 
    None, # 0
 - 
 
2259 
    (1, TType.I64, 'transactionId', None, None, ), # 1
 - 
 
2260 
  )
 - 
 
2261 
 
 - 
 
2262 
  def __init__(self, transactionId=None,):
 - 
 
2263 
    self.transactionId = transactionId
 - 
 
2264 
 
 - 
 
2265 
  def read(self, iprot):
 - 
 
2266 
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
 - 
 
2267 
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
 - 
 
2268 
      return
 - 
 
2269 
    iprot.readStructBegin()
 - 
 
2270 
    while True:
 - 
 
2271 
      (fname, ftype, fid) = iprot.readFieldBegin()
 - 
 
2272 
      if ftype == TType.STOP:
 - 
 
2273 
        break
 - 
 
2274 
      if fid == 1:
 - 
 
2275 
        if ftype == TType.I64:
 - 
 
2276 
          self.transactionId = iprot.readI64();
 - 
 
2277 
        else:
 - 
 
2278 
          iprot.skip(ftype)
 - 
 
2279 
      else:
 - 
 
2280 
        iprot.skip(ftype)
 - 
 
2281 
      iprot.readFieldEnd()
 - 
 
2282 
    iprot.readStructEnd()
 - 
 
2283 
 
 - 
 
2284 
  def write(self, oprot):
 - 
 
2285 
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
 - 
 
2286 
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
 - 
 
2287 
      return
 - 
 
2288 
    oprot.writeStructBegin('processCODTxn_args')
 - 
 
2289 
    if self.transactionId is not None:
 - 
 
2290 
      oprot.writeFieldBegin('transactionId', TType.I64, 1)
 - 
 
2291 
      oprot.writeI64(self.transactionId)
 - 
 
2292 
      oprot.writeFieldEnd()
 - 
 
2293 
    oprot.writeFieldStop()
 - 
 
2294 
    oprot.writeStructEnd()
 - 
 
2295 
 
 - 
 
2296 
  def validate(self):
 - 
 
2297 
    return
 - 
 
2298 
 
 2209 
 
2299 
 
 2210 
 
2300 
  def __repr__(self):
 2211 
  def __repr__(self):
2301 
    L = ['%s=%r' % (key, value)
 2212 
    L = ['%s=%r' % (key, value)
2302 
      for key, value in self.__dict__.iteritems()]
 2213 
      for key, value in self.__dict__.iteritems()]