Subversion Repositories SmartDukaan

Rev

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

Rev 3499 Rev 3530
Line 500... Line 500...
500 
    """
 500 
    """
501 
    Parameters:
 501 
    Parameters:
502 
     - transactionId
 502 
     - transactionId
503 
    """
 503 
    """
504 
    self.send_processCODTxn(transactionId)
 504 
    self.send_processCODTxn(transactionId)
505 
    self.recv_processCODTxn()
 - 
 
506 
 
 505 
 
507 
  def send_processCODTxn(self, transactionId):
 506 
  def send_processCODTxn(self, transactionId):
508 
    self._oprot.writeMessageBegin('processCODTxn', TMessageType.CALL, self._seqid)
 507 
    self._oprot.writeMessageBegin('processCODTxn', TMessageType.CALL, self._seqid)
509 
    args = processCODTxn_args()
 508 
    args = processCODTxn_args()
510 
    args.transactionId = transactionId
 509 
    args.transactionId = transactionId
511 
    args.write(self._oprot)
 510 
    args.write(self._oprot)
512 
    self._oprot.writeMessageEnd()
 511 
    self._oprot.writeMessageEnd()
513 
    self._oprot.trans.flush()
 512 
    self._oprot.trans.flush()
514 
 
 513 
 
515 
  def recv_processCODTxn(self, ):
 - 
 
516 
    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
 - 
 
517 
    if mtype == TMessageType.EXCEPTION:
 - 
 
518 
      x = TApplicationException()
 - 
 
519 
      x.read(self._iprot)
 - 
 
520 
      self._iprot.readMessageEnd()
 - 
 
521 
      raise x
 - 
 
522 
    result = processCODTxn_result()
 - 
 
523 
    result.read(self._iprot)
 - 
 
524 
    self._iprot.readMessageEnd()
 - 
 
525 
    return
 - 
 
526 
 
 - 
 
527 
 
 - 
 
528 
class Processor(shop2020.thriftpy.generic.GenericService.Processor, Iface, TProcessor):
 514 
class Processor(shop2020.thriftpy.generic.GenericService.Processor, Iface, TProcessor):
529 
  def __init__(self, handler):
 515 
  def __init__(self, handler):
530 
    shop2020.thriftpy.generic.GenericService.Processor.__init__(self, handler)
 516 
    shop2020.thriftpy.generic.GenericService.Processor.__init__(self, handler)
531 
    self._processMap["getTickets"] = Processor.process_getTickets
 517 
    self._processMap["getTickets"] = Processor.process_getTickets
532 
    self._processMap["getUnassignedTickets"] = Processor.process_getUnassignedTickets
 518 
    self._processMap["getUnassignedTickets"] = Processor.process_getUnassignedTickets
Line 703... Line 689...
703 
 
 689 
 
704 
  def process_processCODTxn(self, seqid, iprot, oprot):
 690 
  def process_processCODTxn(self, seqid, iprot, oprot):
705 
    args = processCODTxn_args()
 691 
    args = processCODTxn_args()
706 
    args.read(iprot)
 692 
    args.read(iprot)
707 
    iprot.readMessageEnd()
 693 
    iprot.readMessageEnd()
708 
    result = processCODTxn_result()
 - 
 
709 
    self._handler.processCODTxn(args.transactionId)
 694 
    self._handler.processCODTxn(args.transactionId)
710 
    oprot.writeMessageBegin("processCODTxn", TMessageType.REPLY, seqid)
 - 
 
711 
    result.write(oprot)
 - 
 
712 
    oprot.writeMessageEnd()
 - 
 
713 
    oprot.trans.flush()
 695 
    return
714 
 
 696 
 
715 
 
 697 
 
716 
# HELPER FUNCTIONS AND STRUCTURES
 698 
# HELPER FUNCTIONS AND STRUCTURES
717 
 
 699 
 
718 
class getTickets_args:
 700 
class getTickets_args:
Line 2311... Line 2293...
2311 
    oprot.writeFieldStop()
 2293 
    oprot.writeFieldStop()
2312 
    oprot.writeStructEnd()
 2294 
    oprot.writeStructEnd()
2313 
 
 2295 
 
2314 
  def validate(self):
 2296 
  def validate(self):
2315 
    return
 2297 
    return
2316 
 
 - 
 
2317 
 
 - 
 
2318 
  def __repr__(self):
 - 
 
2319 
    L = ['%s=%r' % (key, value)
 - 
 
2320 
      for key, value in self.__dict__.iteritems()]
 - 
 
2321 
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
 - 
 
2322 
 
 - 
 
2323 
  def __eq__(self, other):
 - 
 
2324 
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
 - 
 
2325 
 
 - 
 
2326 
  def __ne__(self, other):
 - 
 
2327 
    return not (self == other)
 - 
 
2328 
 
 - 
 
2329 
class processCODTxn_result:
 - 
 
2330 
 
 - 
 
2331 
  thrift_spec = (
 - 
 
2332 
  )
 - 
 
2333 
 
 - 
 
2334 
  def read(self, iprot):
 - 
 
2335 
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
 - 
 
2336 
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
 - 
 
2337 
      return
 - 
 
2338 
    iprot.readStructBegin()
 - 
 
2339 
    while True:
 - 
 
2340 
      (fname, ftype, fid) = iprot.readFieldBegin()
 - 
 
2341 
      if ftype == TType.STOP:
 - 
 
2342 
        break
 - 
 
2343 
      else:
 - 
 
2344 
        iprot.skip(ftype)
 - 
 
2345 
      iprot.readFieldEnd()
 - 
 
2346 
    iprot.readStructEnd()
 - 
 
2347 
 
 - 
 
2348 
  def write(self, oprot):
 - 
 
2349 
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
 - 
 
2350 
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
 - 
 
2351 
      return
 - 
 
2352 
    oprot.writeStructBegin('processCODTxn_result')
 - 
 
2353 
    oprot.writeFieldStop()
 - 
 
2354 
    oprot.writeStructEnd()
 - 
 
2355 
 
 - 
 
2356 
  def validate(self):
 - 
 
2357 
    return
 - 
 
2358 
 
 2298 
 
2359 
 
 2299 
 
2360 
  def __repr__(self):
 2300 
  def __repr__(self):
2361 
    L = ['%s=%r' % (key, value)
 2301 
    L = ['%s=%r' % (key, value)
2362 
      for key, value in self.__dict__.iteritems()]
 2302 
      for key, value in self.__dict__.iteritems()]