Subversion Repositories SmartDukaan

Rev

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

Rev 11424 Rev 11896
Line 2015... Line 2015...
2015
    Parameters:
2015
    Parameters:
2016
     - flipkartorderids
2016
     - flipkartorderids
2017
    """
2017
    """
2018
    pass
2018
    pass
2019
 
2019
 
-
 
2020
  def isPrivateDealTransaction(self, transactionId):
-
 
2021
    """
-
 
2022
    Parameters:
-
 
2023
     - transactionId
-
 
2024
    """
-
 
2025
    pass
-
 
2026
 
2020
 
2027
 
2021
class Client(shop2020.thriftpy.generic.GenericService.Client, Iface):
2028
class Client(shop2020.thriftpy.generic.GenericService.Client, Iface):
2022
  def __init__(self, iprot, oprot=None):
2029
  def __init__(self, iprot, oprot=None):
2023
    shop2020.thriftpy.generic.GenericService.Client.__init__(self, iprot, oprot)
2030
    shop2020.thriftpy.generic.GenericService.Client.__init__(self, iprot, oprot)
2024
 
2031
 
Line 9481... Line 9488...
9481
    self._iprot.readMessageEnd()
9488
    self._iprot.readMessageEnd()
9482
    if result.success is not None:
9489
    if result.success is not None:
9483
      return result.success
9490
      return result.success
9484
    raise TApplicationException(TApplicationException.MISSING_RESULT, "getCreatedOrdersForFlipkart failed: unknown result");
9491
    raise TApplicationException(TApplicationException.MISSING_RESULT, "getCreatedOrdersForFlipkart failed: unknown result");
9485
 
9492
 
-
 
9493
  def isPrivateDealTransaction(self, transactionId):
-
 
9494
    """
-
 
9495
    Parameters:
-
 
9496
     - transactionId
-
 
9497
    """
-
 
9498
    self.send_isPrivateDealTransaction(transactionId)
-
 
9499
    return self.recv_isPrivateDealTransaction()
-
 
9500
 
-
 
9501
  def send_isPrivateDealTransaction(self, transactionId):
-
 
9502
    self._oprot.writeMessageBegin('isPrivateDealTransaction', TMessageType.CALL, self._seqid)
-
 
9503
    args = isPrivateDealTransaction_args()
-
 
9504
    args.transactionId = transactionId
-
 
9505
    args.write(self._oprot)
-
 
9506
    self._oprot.writeMessageEnd()
-
 
9507
    self._oprot.trans.flush()
-
 
9508
 
-
 
9509
  def recv_isPrivateDealTransaction(self, ):
-
 
9510
    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
-
 
9511
    if mtype == TMessageType.EXCEPTION:
-
 
9512
      x = TApplicationException()
-
 
9513
      x.read(self._iprot)
-
 
9514
      self._iprot.readMessageEnd()
-
 
9515
      raise x
-
 
9516
    result = isPrivateDealTransaction_result()
-
 
9517
    result.read(self._iprot)
-
 
9518
    self._iprot.readMessageEnd()
-
 
9519
    if result.success is not None:
-
 
9520
      return result.success
-
 
9521
    raise TApplicationException(TApplicationException.MISSING_RESULT, "isPrivateDealTransaction failed: unknown result");
-
 
9522
 
9486
 
9523
 
9487
class Processor(shop2020.thriftpy.generic.GenericService.Processor, Iface, TProcessor):
9524
class Processor(shop2020.thriftpy.generic.GenericService.Processor, Iface, TProcessor):
9488
  def __init__(self, handler):
9525
  def __init__(self, handler):
9489
    shop2020.thriftpy.generic.GenericService.Processor.__init__(self, handler)
9526
    shop2020.thriftpy.generic.GenericService.Processor.__init__(self, handler)
9490
    self._processMap["createTransaction"] = Processor.process_createTransaction
9527
    self._processMap["createTransaction"] = Processor.process_createTransaction
Line 9709... Line 9746...
9709
    self._processMap["getMinCreatedTimeStampUndeliveredOrdersForSource"] = Processor.process_getMinCreatedTimeStampUndeliveredOrdersForSource
9746
    self._processMap["getMinCreatedTimeStampUndeliveredOrdersForSource"] = Processor.process_getMinCreatedTimeStampUndeliveredOrdersForSource
9710
    self._processMap["updateSnapdealOrdersStatus"] = Processor.process_updateSnapdealOrdersStatus
9747
    self._processMap["updateSnapdealOrdersStatus"] = Processor.process_updateSnapdealOrdersStatus
9711
    self._processMap["updateFlipkartOrdersStatus"] = Processor.process_updateFlipkartOrdersStatus
9748
    self._processMap["updateFlipkartOrdersStatus"] = Processor.process_updateFlipkartOrdersStatus
9712
    self._processMap["bulkAddOrUpdateAmazonFbaSalesSnapshot"] = Processor.process_bulkAddOrUpdateAmazonFbaSalesSnapshot
9749
    self._processMap["bulkAddOrUpdateAmazonFbaSalesSnapshot"] = Processor.process_bulkAddOrUpdateAmazonFbaSalesSnapshot
9713
    self._processMap["getCreatedOrdersForFlipkart"] = Processor.process_getCreatedOrdersForFlipkart
9750
    self._processMap["getCreatedOrdersForFlipkart"] = Processor.process_getCreatedOrdersForFlipkart
-
 
9751
    self._processMap["isPrivateDealTransaction"] = Processor.process_isPrivateDealTransaction
9714
 
9752
 
9715
  def process(self, iprot, oprot):
9753
  def process(self, iprot, oprot):
9716
    (name, type, seqid) = iprot.readMessageBegin()
9754
    (name, type, seqid) = iprot.readMessageBegin()
9717
    if name not in self._processMap:
9755
    if name not in self._processMap:
9718
      iprot.skip(TType.STRUCT)
9756
      iprot.skip(TType.STRUCT)
Line 12498... Line 12536...
12498
    oprot.writeMessageBegin("getCreatedOrdersForFlipkart", TMessageType.REPLY, seqid)
12536
    oprot.writeMessageBegin("getCreatedOrdersForFlipkart", TMessageType.REPLY, seqid)
12499
    result.write(oprot)
12537
    result.write(oprot)
12500
    oprot.writeMessageEnd()
12538
    oprot.writeMessageEnd()
12501
    oprot.trans.flush()
12539
    oprot.trans.flush()
12502
 
12540
 
-
 
12541
  def process_isPrivateDealTransaction(self, seqid, iprot, oprot):
-
 
12542
    args = isPrivateDealTransaction_args()
-
 
12543
    args.read(iprot)
-
 
12544
    iprot.readMessageEnd()
-
 
12545
    result = isPrivateDealTransaction_result()
-
 
12546
    result.success = self._handler.isPrivateDealTransaction(args.transactionId)
-
 
12547
    oprot.writeMessageBegin("isPrivateDealTransaction", TMessageType.REPLY, seqid)
-
 
12548
    result.write(oprot)
-
 
12549
    oprot.writeMessageEnd()
-
 
12550
    oprot.trans.flush()
-
 
12551
 
12503
 
12552
 
12504
# HELPER FUNCTIONS AND STRUCTURES
12553
# HELPER FUNCTIONS AND STRUCTURES
12505
 
12554
 
12506
class createTransaction_args:
12555
class createTransaction_args:
12507
  """
12556
  """
Line 43233... Line 43282...
43233
      oprot.writeFieldEnd()
43282
      oprot.writeFieldEnd()
43234
    oprot.writeFieldStop()
43283
    oprot.writeFieldStop()
43235
    oprot.writeStructEnd()
43284
    oprot.writeStructEnd()
43236
 
43285
 
43237
  def validate(self):
43286
  def validate(self):
-
 
43287
    return
-
 
43288
 
-
 
43289
 
-
 
43290
  def __repr__(self):
-
 
43291
    L = ['%s=%r' % (key, value)
-
 
43292
      for key, value in self.__dict__.iteritems()]
-
 
43293
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
-
 
43294
 
-
 
43295
  def __eq__(self, other):
-
 
43296
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
 
43297
 
-
 
43298
  def __ne__(self, other):
-
 
43299
    return not (self == other)
-
 
43300
 
-
 
43301
class isPrivateDealTransaction_args:
-
 
43302
  """
-
 
43303
  Attributes:
-
 
43304
   - transactionId
-
 
43305
  """
-
 
43306
 
-
 
43307
  thrift_spec = (
-
 
43308
    None, # 0
-
 
43309
    (1, TType.I64, 'transactionId', None, None, ), # 1
-
 
43310
  )
-
 
43311
 
-
 
43312
  def __init__(self, transactionId=None,):
-
 
43313
    self.transactionId = transactionId
-
 
43314
 
-
 
43315
  def read(self, iprot):
-
 
43316
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
-
 
43317
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
-
 
43318
      return
-
 
43319
    iprot.readStructBegin()
-
 
43320
    while True:
-
 
43321
      (fname, ftype, fid) = iprot.readFieldBegin()
-
 
43322
      if ftype == TType.STOP:
-
 
43323
        break
-
 
43324
      if fid == 1:
-
 
43325
        if ftype == TType.I64:
-
 
43326
          self.transactionId = iprot.readI64();
-
 
43327
        else:
-
 
43328
          iprot.skip(ftype)
-
 
43329
      else:
-
 
43330
        iprot.skip(ftype)
-
 
43331
      iprot.readFieldEnd()
-
 
43332
    iprot.readStructEnd()
-
 
43333
 
-
 
43334
  def write(self, oprot):
-
 
43335
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
-
 
43336
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
-
 
43337
      return
-
 
43338
    oprot.writeStructBegin('isPrivateDealTransaction_args')
-
 
43339
    if self.transactionId is not None:
-
 
43340
      oprot.writeFieldBegin('transactionId', TType.I64, 1)
-
 
43341
      oprot.writeI64(self.transactionId)
-
 
43342
      oprot.writeFieldEnd()
-
 
43343
    oprot.writeFieldStop()
-
 
43344
    oprot.writeStructEnd()
-
 
43345
 
-
 
43346
  def validate(self):
-
 
43347
    return
-
 
43348
 
-
 
43349
 
-
 
43350
  def __repr__(self):
-
 
43351
    L = ['%s=%r' % (key, value)
-
 
43352
      for key, value in self.__dict__.iteritems()]
-
 
43353
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
-
 
43354
 
-
 
43355
  def __eq__(self, other):
-
 
43356
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
 
43357
 
-
 
43358
  def __ne__(self, other):
-
 
43359
    return not (self == other)
-
 
43360
 
-
 
43361
class isPrivateDealTransaction_result:
-
 
43362
  """
-
 
43363
  Attributes:
-
 
43364
   - success
-
 
43365
  """
-
 
43366
 
-
 
43367
  thrift_spec = (
-
 
43368
    (0, TType.BOOL, 'success', None, None, ), # 0
-
 
43369
  )
-
 
43370
 
-
 
43371
  def __init__(self, success=None,):
-
 
43372
    self.success = success
-
 
43373
 
-
 
43374
  def read(self, iprot):
-
 
43375
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
-
 
43376
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
-
 
43377
      return
-
 
43378
    iprot.readStructBegin()
-
 
43379
    while True:
-
 
43380
      (fname, ftype, fid) = iprot.readFieldBegin()
-
 
43381
      if ftype == TType.STOP:
-
 
43382
        break
-
 
43383
      if fid == 0:
-
 
43384
        if ftype == TType.BOOL:
-
 
43385
          self.success = iprot.readBool();
-
 
43386
        else:
-
 
43387
          iprot.skip(ftype)
-
 
43388
      else:
-
 
43389
        iprot.skip(ftype)
-
 
43390
      iprot.readFieldEnd()
-
 
43391
    iprot.readStructEnd()
-
 
43392
 
-
 
43393
  def write(self, oprot):
-
 
43394
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
-
 
43395
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
-
 
43396
      return
-
 
43397
    oprot.writeStructBegin('isPrivateDealTransaction_result')
-
 
43398
    if self.success is not None:
-
 
43399
      oprot.writeFieldBegin('success', TType.BOOL, 0)
-
 
43400
      oprot.writeBool(self.success)
-
 
43401
      oprot.writeFieldEnd()
-
 
43402
    oprot.writeFieldStop()
-
 
43403
    oprot.writeStructEnd()
-
 
43404
 
-
 
43405
  def validate(self):
43238
    return
43406
    return
43239
 
43407
 
43240
 
43408
 
43241
  def __repr__(self):
43409
  def __repr__(self):
43242
    L = ['%s=%r' % (key, value)
43410
    L = ['%s=%r' % (key, value)