Subversion Repositories SmartDukaan

Rev

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

Rev 4295 Rev 4303
Line 727... Line 727...
727
     - itemId
727
     - itemId
728
     - inventory
728
     - inventory
729
    """
729
    """
730
    pass
730
    pass
731
 
731
 
-
 
732
  def markOrdersAsPORaised(self, vendorId, itemId, quantity, estimate):
-
 
733
    """
-
 
734
    Parameters:
-
 
735
     - vendorId
-
 
736
     - itemId
-
 
737
     - quantity
-
 
738
     - estimate
-
 
739
    """
-
 
740
    pass
-
 
741
 
-
 
742
  def markOrdersAsReversalInitiated(self, vendorId, itemId, quantity, estimate):
-
 
743
    """
-
 
744
    Parameters:
-
 
745
     - vendorId
-
 
746
     - itemId
-
 
747
     - quantity
-
 
748
     - estimate
-
 
749
    """
-
 
750
    pass
-
 
751
 
-
 
752
  def markOrdersAsNotAvailabke(self, vendorId, itemId, quantity, estimate):
-
 
753
    """
-
 
754
    Parameters:
-
 
755
     - vendorId
-
 
756
     - itemId
-
 
757
     - quantity
-
 
758
     - estimate
-
 
759
    """
-
 
760
    pass
-
 
761
 
732
 
762
 
733
class Client(shop2020.thriftpy.generic.GenericService.Client, Iface):
763
class Client(shop2020.thriftpy.generic.GenericService.Client, Iface):
734
  def __init__(self, iprot, oprot=None):
764
  def __init__(self, iprot, oprot=None):
735
    shop2020.thriftpy.generic.GenericService.Client.__init__(self, iprot, oprot)
765
    shop2020.thriftpy.generic.GenericService.Client.__init__(self, iprot, oprot)
736
 
766
 
Line 3082... Line 3112...
3082
      return result.success
3112
      return result.success
3083
    if result.ex is not None:
3113
    if result.ex is not None:
3084
      raise result.ex
3114
      raise result.ex
3085
    raise TApplicationException(TApplicationException.MISSING_RESULT, "acceptOrdersForItemId failed: unknown result");
3115
    raise TApplicationException(TApplicationException.MISSING_RESULT, "acceptOrdersForItemId failed: unknown result");
3086
 
3116
 
-
 
3117
  def markOrdersAsPORaised(self, vendorId, itemId, quantity, estimate):
-
 
3118
    """
-
 
3119
    Parameters:
-
 
3120
     - vendorId
-
 
3121
     - itemId
-
 
3122
     - quantity
-
 
3123
     - estimate
-
 
3124
    """
-
 
3125
    self.send_markOrdersAsPORaised(vendorId, itemId, quantity, estimate)
-
 
3126
    self.recv_markOrdersAsPORaised()
-
 
3127
 
-
 
3128
  def send_markOrdersAsPORaised(self, vendorId, itemId, quantity, estimate):
-
 
3129
    self._oprot.writeMessageBegin('markOrdersAsPORaised', TMessageType.CALL, self._seqid)
-
 
3130
    args = markOrdersAsPORaised_args()
-
 
3131
    args.vendorId = vendorId
-
 
3132
    args.itemId = itemId
-
 
3133
    args.quantity = quantity
-
 
3134
    args.estimate = estimate
-
 
3135
    args.write(self._oprot)
-
 
3136
    self._oprot.writeMessageEnd()
-
 
3137
    self._oprot.trans.flush()
-
 
3138
 
-
 
3139
  def recv_markOrdersAsPORaised(self, ):
-
 
3140
    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
-
 
3141
    if mtype == TMessageType.EXCEPTION:
-
 
3142
      x = TApplicationException()
-
 
3143
      x.read(self._iprot)
-
 
3144
      self._iprot.readMessageEnd()
-
 
3145
      raise x
-
 
3146
    result = markOrdersAsPORaised_result()
-
 
3147
    result.read(self._iprot)
-
 
3148
    self._iprot.readMessageEnd()
-
 
3149
    if result.ex is not None:
-
 
3150
      raise result.ex
-
 
3151
    return
-
 
3152
 
-
 
3153
  def markOrdersAsReversalInitiated(self, vendorId, itemId, quantity, estimate):
-
 
3154
    """
-
 
3155
    Parameters:
-
 
3156
     - vendorId
-
 
3157
     - itemId
-
 
3158
     - quantity
-
 
3159
     - estimate
-
 
3160
    """
-
 
3161
    self.send_markOrdersAsReversalInitiated(vendorId, itemId, quantity, estimate)
-
 
3162
    self.recv_markOrdersAsReversalInitiated()
-
 
3163
 
-
 
3164
  def send_markOrdersAsReversalInitiated(self, vendorId, itemId, quantity, estimate):
-
 
3165
    self._oprot.writeMessageBegin('markOrdersAsReversalInitiated', TMessageType.CALL, self._seqid)
-
 
3166
    args = markOrdersAsReversalInitiated_args()
-
 
3167
    args.vendorId = vendorId
-
 
3168
    args.itemId = itemId
-
 
3169
    args.quantity = quantity
-
 
3170
    args.estimate = estimate
-
 
3171
    args.write(self._oprot)
-
 
3172
    self._oprot.writeMessageEnd()
-
 
3173
    self._oprot.trans.flush()
-
 
3174
 
-
 
3175
  def recv_markOrdersAsReversalInitiated(self, ):
-
 
3176
    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
-
 
3177
    if mtype == TMessageType.EXCEPTION:
-
 
3178
      x = TApplicationException()
-
 
3179
      x.read(self._iprot)
-
 
3180
      self._iprot.readMessageEnd()
-
 
3181
      raise x
-
 
3182
    result = markOrdersAsReversalInitiated_result()
-
 
3183
    result.read(self._iprot)
-
 
3184
    self._iprot.readMessageEnd()
-
 
3185
    if result.ex is not None:
-
 
3186
      raise result.ex
-
 
3187
    return
-
 
3188
 
-
 
3189
  def markOrdersAsNotAvailabke(self, vendorId, itemId, quantity, estimate):
-
 
3190
    """
-
 
3191
    Parameters:
-
 
3192
     - vendorId
-
 
3193
     - itemId
-
 
3194
     - quantity
-
 
3195
     - estimate
-
 
3196
    """
-
 
3197
    self.send_markOrdersAsNotAvailabke(vendorId, itemId, quantity, estimate)
-
 
3198
    self.recv_markOrdersAsNotAvailabke()
-
 
3199
 
-
 
3200
  def send_markOrdersAsNotAvailabke(self, vendorId, itemId, quantity, estimate):
-
 
3201
    self._oprot.writeMessageBegin('markOrdersAsNotAvailabke', TMessageType.CALL, self._seqid)
-
 
3202
    args = markOrdersAsNotAvailabke_args()
-
 
3203
    args.vendorId = vendorId
-
 
3204
    args.itemId = itemId
-
 
3205
    args.quantity = quantity
-
 
3206
    args.estimate = estimate
-
 
3207
    args.write(self._oprot)
-
 
3208
    self._oprot.writeMessageEnd()
-
 
3209
    self._oprot.trans.flush()
-
 
3210
 
-
 
3211
  def recv_markOrdersAsNotAvailabke(self, ):
-
 
3212
    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
-
 
3213
    if mtype == TMessageType.EXCEPTION:
-
 
3214
      x = TApplicationException()
-
 
3215
      x.read(self._iprot)
-
 
3216
      self._iprot.readMessageEnd()
-
 
3217
      raise x
-
 
3218
    result = markOrdersAsNotAvailabke_result()
-
 
3219
    result.read(self._iprot)
-
 
3220
    self._iprot.readMessageEnd()
-
 
3221
    if result.ex is not None:
-
 
3222
      raise result.ex
-
 
3223
    return
-
 
3224
 
3087
 
3225
 
3088
class Processor(shop2020.thriftpy.generic.GenericService.Processor, Iface, TProcessor):
3226
class Processor(shop2020.thriftpy.generic.GenericService.Processor, Iface, TProcessor):
3089
  def __init__(self, handler):
3227
  def __init__(self, handler):
3090
    shop2020.thriftpy.generic.GenericService.Processor.__init__(self, handler)
3228
    shop2020.thriftpy.generic.GenericService.Processor.__init__(self, handler)
3091
    self._processMap["createTransaction"] = Processor.process_createTransaction
3229
    self._processMap["createTransaction"] = Processor.process_createTransaction
Line 3151... Line 3289...
3151
    self._processMap["markOrderCancellationRequestConfirmed"] = Processor.process_markOrderCancellationRequestConfirmed
3289
    self._processMap["markOrderCancellationRequestConfirmed"] = Processor.process_markOrderCancellationRequestConfirmed
3152
    self._processMap["markOrderCancellationRequestDenied"] = Processor.process_markOrderCancellationRequestDenied
3290
    self._processMap["markOrderCancellationRequestDenied"] = Processor.process_markOrderCancellationRequestDenied
3153
    self._processMap["markTransactionAsPaymentFlagRemoved"] = Processor.process_markTransactionAsPaymentFlagRemoved
3291
    self._processMap["markTransactionAsPaymentFlagRemoved"] = Processor.process_markTransactionAsPaymentFlagRemoved
3154
    self._processMap["refundTransaction"] = Processor.process_refundTransaction
3292
    self._processMap["refundTransaction"] = Processor.process_refundTransaction
3155
    self._processMap["acceptOrdersForItemId"] = Processor.process_acceptOrdersForItemId
3293
    self._processMap["acceptOrdersForItemId"] = Processor.process_acceptOrdersForItemId
-
 
3294
    self._processMap["markOrdersAsPORaised"] = Processor.process_markOrdersAsPORaised
-
 
3295
    self._processMap["markOrdersAsReversalInitiated"] = Processor.process_markOrdersAsReversalInitiated
-
 
3296
    self._processMap["markOrdersAsNotAvailabke"] = Processor.process_markOrdersAsNotAvailabke
3156
 
3297
 
3157
  def process(self, iprot, oprot):
3298
  def process(self, iprot, oprot):
3158
    (name, type, seqid) = iprot.readMessageBegin()
3299
    (name, type, seqid) = iprot.readMessageBegin()
3159
    if name not in self._processMap:
3300
    if name not in self._processMap:
3160
      iprot.skip(TType.STRUCT)
3301
      iprot.skip(TType.STRUCT)
Line 4038... Line 4179...
4038
    oprot.writeMessageBegin("acceptOrdersForItemId", TMessageType.REPLY, seqid)
4179
    oprot.writeMessageBegin("acceptOrdersForItemId", TMessageType.REPLY, seqid)
4039
    result.write(oprot)
4180
    result.write(oprot)
4040
    oprot.writeMessageEnd()
4181
    oprot.writeMessageEnd()
4041
    oprot.trans.flush()
4182
    oprot.trans.flush()
4042
 
4183
 
-
 
4184
  def process_markOrdersAsPORaised(self, seqid, iprot, oprot):
-
 
4185
    args = markOrdersAsPORaised_args()
-
 
4186
    args.read(iprot)
-
 
4187
    iprot.readMessageEnd()
-
 
4188
    result = markOrdersAsPORaised_result()
-
 
4189
    try:
-
 
4190
      self._handler.markOrdersAsPORaised(args.vendorId, args.itemId, args.quantity, args.estimate)
-
 
4191
    except TransactionServiceException, ex:
-
 
4192
      result.ex = ex
-
 
4193
    oprot.writeMessageBegin("markOrdersAsPORaised", TMessageType.REPLY, seqid)
-
 
4194
    result.write(oprot)
-
 
4195
    oprot.writeMessageEnd()
-
 
4196
    oprot.trans.flush()
-
 
4197
 
-
 
4198
  def process_markOrdersAsReversalInitiated(self, seqid, iprot, oprot):
-
 
4199
    args = markOrdersAsReversalInitiated_args()
-
 
4200
    args.read(iprot)
-
 
4201
    iprot.readMessageEnd()
-
 
4202
    result = markOrdersAsReversalInitiated_result()
-
 
4203
    try:
-
 
4204
      self._handler.markOrdersAsReversalInitiated(args.vendorId, args.itemId, args.quantity, args.estimate)
-
 
4205
    except TransactionServiceException, ex:
-
 
4206
      result.ex = ex
-
 
4207
    oprot.writeMessageBegin("markOrdersAsReversalInitiated", TMessageType.REPLY, seqid)
-
 
4208
    result.write(oprot)
-
 
4209
    oprot.writeMessageEnd()
-
 
4210
    oprot.trans.flush()
-
 
4211
 
-
 
4212
  def process_markOrdersAsNotAvailabke(self, seqid, iprot, oprot):
-
 
4213
    args = markOrdersAsNotAvailabke_args()
-
 
4214
    args.read(iprot)
-
 
4215
    iprot.readMessageEnd()
-
 
4216
    result = markOrdersAsNotAvailabke_result()
-
 
4217
    try:
-
 
4218
      self._handler.markOrdersAsNotAvailabke(args.vendorId, args.itemId, args.quantity, args.estimate)
-
 
4219
    except TransactionServiceException, ex:
-
 
4220
      result.ex = ex
-
 
4221
    oprot.writeMessageBegin("markOrdersAsNotAvailabke", TMessageType.REPLY, seqid)
-
 
4222
    result.write(oprot)
-
 
4223
    oprot.writeMessageEnd()
-
 
4224
    oprot.trans.flush()
-
 
4225
 
4043
 
4226
 
4044
# HELPER FUNCTIONS AND STRUCTURES
4227
# HELPER FUNCTIONS AND STRUCTURES
4045
 
4228
 
4046
class createTransaction_args:
4229
class createTransaction_args:
4047
  """
4230
  """
Line 13316... Line 13499...
13316
    if self.ex is not None:
13499
    if self.ex is not None:
13317
      oprot.writeFieldBegin('ex', TType.STRUCT, 1)
13500
      oprot.writeFieldBegin('ex', TType.STRUCT, 1)
13318
      self.ex.write(oprot)
13501
      self.ex.write(oprot)
13319
      oprot.writeFieldEnd()
13502
      oprot.writeFieldEnd()
13320
    oprot.writeFieldStop()
13503
    oprot.writeFieldStop()
-
 
13504
    oprot.writeStructEnd()
-
 
13505
 
-
 
13506
  def validate(self):
-
 
13507
    return
-
 
13508
 
-
 
13509
 
-
 
13510
  def __repr__(self):
-
 
13511
    L = ['%s=%r' % (key, value)
-
 
13512
      for key, value in self.__dict__.iteritems()]
-
 
13513
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
-
 
13514
 
-
 
13515
  def __eq__(self, other):
-
 
13516
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
 
13517
 
-
 
13518
  def __ne__(self, other):
-
 
13519
    return not (self == other)
-
 
13520
 
-
 
13521
class markOrdersAsPORaised_args:
-
 
13522
  """
-
 
13523
  Attributes:
-
 
13524
   - vendorId
-
 
13525
   - itemId
-
 
13526
   - quantity
-
 
13527
   - estimate
-
 
13528
  """
-
 
13529
 
-
 
13530
  thrift_spec = (
-
 
13531
    None, # 0
-
 
13532
    (1, TType.I64, 'vendorId', None, None, ), # 1
-
 
13533
    (2, TType.I64, 'itemId', None, None, ), # 2
-
 
13534
    (3, TType.I64, 'quantity', None, None, ), # 3
-
 
13535
    (4, TType.I64, 'estimate', None, None, ), # 4
-
 
13536
  )
-
 
13537
 
-
 
13538
  def __init__(self, vendorId=None, itemId=None, quantity=None, estimate=None,):
-
 
13539
    self.vendorId = vendorId
-
 
13540
    self.itemId = itemId
-
 
13541
    self.quantity = quantity
-
 
13542
    self.estimate = estimate
-
 
13543
 
-
 
13544
  def read(self, iprot):
-
 
13545
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
-
 
13546
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
-
 
13547
      return
-
 
13548
    iprot.readStructBegin()
-
 
13549
    while True:
-
 
13550
      (fname, ftype, fid) = iprot.readFieldBegin()
-
 
13551
      if ftype == TType.STOP:
-
 
13552
        break
-
 
13553
      if fid == 1:
-
 
13554
        if ftype == TType.I64:
-
 
13555
          self.vendorId = iprot.readI64();
-
 
13556
        else:
-
 
13557
          iprot.skip(ftype)
-
 
13558
      elif fid == 2:
-
 
13559
        if ftype == TType.I64:
-
 
13560
          self.itemId = iprot.readI64();
-
 
13561
        else:
-
 
13562
          iprot.skip(ftype)
-
 
13563
      elif fid == 3:
-
 
13564
        if ftype == TType.I64:
-
 
13565
          self.quantity = iprot.readI64();
-
 
13566
        else:
-
 
13567
          iprot.skip(ftype)
-
 
13568
      elif fid == 4:
-
 
13569
        if ftype == TType.I64:
-
 
13570
          self.estimate = iprot.readI64();
-
 
13571
        else:
-
 
13572
          iprot.skip(ftype)
-
 
13573
      else:
-
 
13574
        iprot.skip(ftype)
-
 
13575
      iprot.readFieldEnd()
-
 
13576
    iprot.readStructEnd()
-
 
13577
 
-
 
13578
  def write(self, oprot):
-
 
13579
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
-
 
13580
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
-
 
13581
      return
-
 
13582
    oprot.writeStructBegin('markOrdersAsPORaised_args')
-
 
13583
    if self.vendorId is not None:
-
 
13584
      oprot.writeFieldBegin('vendorId', TType.I64, 1)
-
 
13585
      oprot.writeI64(self.vendorId)
-
 
13586
      oprot.writeFieldEnd()
-
 
13587
    if self.itemId is not None:
-
 
13588
      oprot.writeFieldBegin('itemId', TType.I64, 2)
-
 
13589
      oprot.writeI64(self.itemId)
-
 
13590
      oprot.writeFieldEnd()
-
 
13591
    if self.quantity is not None:
-
 
13592
      oprot.writeFieldBegin('quantity', TType.I64, 3)
-
 
13593
      oprot.writeI64(self.quantity)
-
 
13594
      oprot.writeFieldEnd()
-
 
13595
    if self.estimate is not None:
-
 
13596
      oprot.writeFieldBegin('estimate', TType.I64, 4)
-
 
13597
      oprot.writeI64(self.estimate)
-
 
13598
      oprot.writeFieldEnd()
-
 
13599
    oprot.writeFieldStop()
-
 
13600
    oprot.writeStructEnd()
-
 
13601
 
-
 
13602
  def validate(self):
-
 
13603
    return
-
 
13604
 
-
 
13605
 
-
 
13606
  def __repr__(self):
-
 
13607
    L = ['%s=%r' % (key, value)
-
 
13608
      for key, value in self.__dict__.iteritems()]
-
 
13609
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
-
 
13610
 
-
 
13611
  def __eq__(self, other):
-
 
13612
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
 
13613
 
-
 
13614
  def __ne__(self, other):
-
 
13615
    return not (self == other)
-
 
13616
 
-
 
13617
class markOrdersAsPORaised_result:
-
 
13618
  """
-
 
13619
  Attributes:
-
 
13620
   - ex
-
 
13621
  """
-
 
13622
 
-
 
13623
  thrift_spec = (
-
 
13624
    None, # 0
-
 
13625
    (1, TType.STRUCT, 'ex', (TransactionServiceException, TransactionServiceException.thrift_spec), None, ), # 1
-
 
13626
  )
-
 
13627
 
-
 
13628
  def __init__(self, ex=None,):
-
 
13629
    self.ex = ex
-
 
13630
 
-
 
13631
  def read(self, iprot):
-
 
13632
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
-
 
13633
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
-
 
13634
      return
-
 
13635
    iprot.readStructBegin()
-
 
13636
    while True:
-
 
13637
      (fname, ftype, fid) = iprot.readFieldBegin()
-
 
13638
      if ftype == TType.STOP:
-
 
13639
        break
-
 
13640
      if fid == 1:
-
 
13641
        if ftype == TType.STRUCT:
-
 
13642
          self.ex = TransactionServiceException()
-
 
13643
          self.ex.read(iprot)
-
 
13644
        else:
-
 
13645
          iprot.skip(ftype)
-
 
13646
      else:
-
 
13647
        iprot.skip(ftype)
-
 
13648
      iprot.readFieldEnd()
-
 
13649
    iprot.readStructEnd()
-
 
13650
 
-
 
13651
  def write(self, oprot):
-
 
13652
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
-
 
13653
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
-
 
13654
      return
-
 
13655
    oprot.writeStructBegin('markOrdersAsPORaised_result')
-
 
13656
    if self.ex is not None:
-
 
13657
      oprot.writeFieldBegin('ex', TType.STRUCT, 1)
-
 
13658
      self.ex.write(oprot)
-
 
13659
      oprot.writeFieldEnd()
-
 
13660
    oprot.writeFieldStop()
-
 
13661
    oprot.writeStructEnd()
-
 
13662
 
-
 
13663
  def validate(self):
-
 
13664
    return
-
 
13665
 
-
 
13666
 
-
 
13667
  def __repr__(self):
-
 
13668
    L = ['%s=%r' % (key, value)
-
 
13669
      for key, value in self.__dict__.iteritems()]
-
 
13670
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
-
 
13671
 
-
 
13672
  def __eq__(self, other):
-
 
13673
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
 
13674
 
-
 
13675
  def __ne__(self, other):
-
 
13676
    return not (self == other)
-
 
13677
 
-
 
13678
class markOrdersAsReversalInitiated_args:
-
 
13679
  """
-
 
13680
  Attributes:
-
 
13681
   - vendorId
-
 
13682
   - itemId
-
 
13683
   - quantity
-
 
13684
   - estimate
-
 
13685
  """
-
 
13686
 
-
 
13687
  thrift_spec = (
-
 
13688
    None, # 0
-
 
13689
    (1, TType.I64, 'vendorId', None, None, ), # 1
-
 
13690
    (2, TType.I64, 'itemId', None, None, ), # 2
-
 
13691
    (3, TType.I64, 'quantity', None, None, ), # 3
-
 
13692
    (4, TType.I64, 'estimate', None, None, ), # 4
-
 
13693
  )
-
 
13694
 
-
 
13695
  def __init__(self, vendorId=None, itemId=None, quantity=None, estimate=None,):
-
 
13696
    self.vendorId = vendorId
-
 
13697
    self.itemId = itemId
-
 
13698
    self.quantity = quantity
-
 
13699
    self.estimate = estimate
-
 
13700
 
-
 
13701
  def read(self, iprot):
-
 
13702
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
-
 
13703
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
-
 
13704
      return
-
 
13705
    iprot.readStructBegin()
-
 
13706
    while True:
-
 
13707
      (fname, ftype, fid) = iprot.readFieldBegin()
-
 
13708
      if ftype == TType.STOP:
-
 
13709
        break
-
 
13710
      if fid == 1:
-
 
13711
        if ftype == TType.I64:
-
 
13712
          self.vendorId = iprot.readI64();
-
 
13713
        else:
-
 
13714
          iprot.skip(ftype)
-
 
13715
      elif fid == 2:
-
 
13716
        if ftype == TType.I64:
-
 
13717
          self.itemId = iprot.readI64();
-
 
13718
        else:
-
 
13719
          iprot.skip(ftype)
-
 
13720
      elif fid == 3:
-
 
13721
        if ftype == TType.I64:
-
 
13722
          self.quantity = iprot.readI64();
-
 
13723
        else:
-
 
13724
          iprot.skip(ftype)
-
 
13725
      elif fid == 4:
-
 
13726
        if ftype == TType.I64:
-
 
13727
          self.estimate = iprot.readI64();
-
 
13728
        else:
-
 
13729
          iprot.skip(ftype)
-
 
13730
      else:
-
 
13731
        iprot.skip(ftype)
-
 
13732
      iprot.readFieldEnd()
-
 
13733
    iprot.readStructEnd()
-
 
13734
 
-
 
13735
  def write(self, oprot):
-
 
13736
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
-
 
13737
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
-
 
13738
      return
-
 
13739
    oprot.writeStructBegin('markOrdersAsReversalInitiated_args')
-
 
13740
    if self.vendorId is not None:
-
 
13741
      oprot.writeFieldBegin('vendorId', TType.I64, 1)
-
 
13742
      oprot.writeI64(self.vendorId)
-
 
13743
      oprot.writeFieldEnd()
-
 
13744
    if self.itemId is not None:
-
 
13745
      oprot.writeFieldBegin('itemId', TType.I64, 2)
-
 
13746
      oprot.writeI64(self.itemId)
-
 
13747
      oprot.writeFieldEnd()
-
 
13748
    if self.quantity is not None:
-
 
13749
      oprot.writeFieldBegin('quantity', TType.I64, 3)
-
 
13750
      oprot.writeI64(self.quantity)
-
 
13751
      oprot.writeFieldEnd()
-
 
13752
    if self.estimate is not None:
-
 
13753
      oprot.writeFieldBegin('estimate', TType.I64, 4)
-
 
13754
      oprot.writeI64(self.estimate)
-
 
13755
      oprot.writeFieldEnd()
-
 
13756
    oprot.writeFieldStop()
-
 
13757
    oprot.writeStructEnd()
-
 
13758
 
-
 
13759
  def validate(self):
-
 
13760
    return
-
 
13761
 
-
 
13762
 
-
 
13763
  def __repr__(self):
-
 
13764
    L = ['%s=%r' % (key, value)
-
 
13765
      for key, value in self.__dict__.iteritems()]
-
 
13766
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
-
 
13767
 
-
 
13768
  def __eq__(self, other):
-
 
13769
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
 
13770
 
-
 
13771
  def __ne__(self, other):
-
 
13772
    return not (self == other)
-
 
13773
 
-
 
13774
class markOrdersAsReversalInitiated_result:
-
 
13775
  """
-
 
13776
  Attributes:
-
 
13777
   - ex
-
 
13778
  """
-
 
13779
 
-
 
13780
  thrift_spec = (
-
 
13781
    None, # 0
-
 
13782
    (1, TType.STRUCT, 'ex', (TransactionServiceException, TransactionServiceException.thrift_spec), None, ), # 1
-
 
13783
  )
-
 
13784
 
-
 
13785
  def __init__(self, ex=None,):
-
 
13786
    self.ex = ex
-
 
13787
 
-
 
13788
  def read(self, iprot):
-
 
13789
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
-
 
13790
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
-
 
13791
      return
-
 
13792
    iprot.readStructBegin()
-
 
13793
    while True:
-
 
13794
      (fname, ftype, fid) = iprot.readFieldBegin()
-
 
13795
      if ftype == TType.STOP:
-
 
13796
        break
-
 
13797
      if fid == 1:
-
 
13798
        if ftype == TType.STRUCT:
-
 
13799
          self.ex = TransactionServiceException()
-
 
13800
          self.ex.read(iprot)
-
 
13801
        else:
-
 
13802
          iprot.skip(ftype)
-
 
13803
      else:
-
 
13804
        iprot.skip(ftype)
-
 
13805
      iprot.readFieldEnd()
-
 
13806
    iprot.readStructEnd()
-
 
13807
 
-
 
13808
  def write(self, oprot):
-
 
13809
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
-
 
13810
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
-
 
13811
      return
-
 
13812
    oprot.writeStructBegin('markOrdersAsReversalInitiated_result')
-
 
13813
    if self.ex is not None:
-
 
13814
      oprot.writeFieldBegin('ex', TType.STRUCT, 1)
-
 
13815
      self.ex.write(oprot)
-
 
13816
      oprot.writeFieldEnd()
-
 
13817
    oprot.writeFieldStop()
-
 
13818
    oprot.writeStructEnd()
-
 
13819
 
-
 
13820
  def validate(self):
-
 
13821
    return
-
 
13822
 
-
 
13823
 
-
 
13824
  def __repr__(self):
-
 
13825
    L = ['%s=%r' % (key, value)
-
 
13826
      for key, value in self.__dict__.iteritems()]
-
 
13827
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
-
 
13828
 
-
 
13829
  def __eq__(self, other):
-
 
13830
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
 
13831
 
-
 
13832
  def __ne__(self, other):
-
 
13833
    return not (self == other)
-
 
13834
 
-
 
13835
class markOrdersAsNotAvailabke_args:
-
 
13836
  """
-
 
13837
  Attributes:
-
 
13838
   - vendorId
-
 
13839
   - itemId
-
 
13840
   - quantity
-
 
13841
   - estimate
-
 
13842
  """
-
 
13843
 
-
 
13844
  thrift_spec = (
-
 
13845
    None, # 0
-
 
13846
    (1, TType.I64, 'vendorId', None, None, ), # 1
-
 
13847
    (2, TType.I64, 'itemId', None, None, ), # 2
-
 
13848
    (3, TType.I64, 'quantity', None, None, ), # 3
-
 
13849
    (4, TType.I64, 'estimate', None, None, ), # 4
-
 
13850
  )
-
 
13851
 
-
 
13852
  def __init__(self, vendorId=None, itemId=None, quantity=None, estimate=None,):
-
 
13853
    self.vendorId = vendorId
-
 
13854
    self.itemId = itemId
-
 
13855
    self.quantity = quantity
-
 
13856
    self.estimate = estimate
-
 
13857
 
-
 
13858
  def read(self, iprot):
-
 
13859
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
-
 
13860
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
-
 
13861
      return
-
 
13862
    iprot.readStructBegin()
-
 
13863
    while True:
-
 
13864
      (fname, ftype, fid) = iprot.readFieldBegin()
-
 
13865
      if ftype == TType.STOP:
-
 
13866
        break
-
 
13867
      if fid == 1:
-
 
13868
        if ftype == TType.I64:
-
 
13869
          self.vendorId = iprot.readI64();
-
 
13870
        else:
-
 
13871
          iprot.skip(ftype)
-
 
13872
      elif fid == 2:
-
 
13873
        if ftype == TType.I64:
-
 
13874
          self.itemId = iprot.readI64();
-
 
13875
        else:
-
 
13876
          iprot.skip(ftype)
-
 
13877
      elif fid == 3:
-
 
13878
        if ftype == TType.I64:
-
 
13879
          self.quantity = iprot.readI64();
-
 
13880
        else:
-
 
13881
          iprot.skip(ftype)
-
 
13882
      elif fid == 4:
-
 
13883
        if ftype == TType.I64:
-
 
13884
          self.estimate = iprot.readI64();
-
 
13885
        else:
-
 
13886
          iprot.skip(ftype)
-
 
13887
      else:
-
 
13888
        iprot.skip(ftype)
-
 
13889
      iprot.readFieldEnd()
-
 
13890
    iprot.readStructEnd()
-
 
13891
 
-
 
13892
  def write(self, oprot):
-
 
13893
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
-
 
13894
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
-
 
13895
      return
-
 
13896
    oprot.writeStructBegin('markOrdersAsNotAvailabke_args')
-
 
13897
    if self.vendorId is not None:
-
 
13898
      oprot.writeFieldBegin('vendorId', TType.I64, 1)
-
 
13899
      oprot.writeI64(self.vendorId)
-
 
13900
      oprot.writeFieldEnd()
-
 
13901
    if self.itemId is not None:
-
 
13902
      oprot.writeFieldBegin('itemId', TType.I64, 2)
-
 
13903
      oprot.writeI64(self.itemId)
-
 
13904
      oprot.writeFieldEnd()
-
 
13905
    if self.quantity is not None:
-
 
13906
      oprot.writeFieldBegin('quantity', TType.I64, 3)
-
 
13907
      oprot.writeI64(self.quantity)
-
 
13908
      oprot.writeFieldEnd()
-
 
13909
    if self.estimate is not None:
-
 
13910
      oprot.writeFieldBegin('estimate', TType.I64, 4)
-
 
13911
      oprot.writeI64(self.estimate)
-
 
13912
      oprot.writeFieldEnd()
-
 
13913
    oprot.writeFieldStop()
-
 
13914
    oprot.writeStructEnd()
-
 
13915
 
-
 
13916
  def validate(self):
-
 
13917
    return
-
 
13918
 
-
 
13919
 
-
 
13920
  def __repr__(self):
-
 
13921
    L = ['%s=%r' % (key, value)
-
 
13922
      for key, value in self.__dict__.iteritems()]
-
 
13923
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
-
 
13924
 
-
 
13925
  def __eq__(self, other):
-
 
13926
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
 
13927
 
-
 
13928
  def __ne__(self, other):
-
 
13929
    return not (self == other)
-
 
13930
 
-
 
13931
class markOrdersAsNotAvailabke_result:
-
 
13932
  """
-
 
13933
  Attributes:
-
 
13934
   - ex
-
 
13935
  """
-
 
13936
 
-
 
13937
  thrift_spec = (
-
 
13938
    None, # 0
-
 
13939
    (1, TType.STRUCT, 'ex', (TransactionServiceException, TransactionServiceException.thrift_spec), None, ), # 1
-
 
13940
  )
-
 
13941
 
-
 
13942
  def __init__(self, ex=None,):
-
 
13943
    self.ex = ex
-
 
13944
 
-
 
13945
  def read(self, iprot):
-
 
13946
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
-
 
13947
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
-
 
13948
      return
-
 
13949
    iprot.readStructBegin()
-
 
13950
    while True:
-
 
13951
      (fname, ftype, fid) = iprot.readFieldBegin()
-
 
13952
      if ftype == TType.STOP:
-
 
13953
        break
-
 
13954
      if fid == 1:
-
 
13955
        if ftype == TType.STRUCT:
-
 
13956
          self.ex = TransactionServiceException()
-
 
13957
          self.ex.read(iprot)
-
 
13958
        else:
-
 
13959
          iprot.skip(ftype)
-
 
13960
      else:
-
 
13961
        iprot.skip(ftype)
-
 
13962
      iprot.readFieldEnd()
-
 
13963
    iprot.readStructEnd()
-
 
13964
 
-
 
13965
  def write(self, oprot):
-
 
13966
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
-
 
13967
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
-
 
13968
      return
-
 
13969
    oprot.writeStructBegin('markOrdersAsNotAvailabke_result')
-
 
13970
    if self.ex is not None:
-
 
13971
      oprot.writeFieldBegin('ex', TType.STRUCT, 1)
-
 
13972
      self.ex.write(oprot)
-
 
13973
      oprot.writeFieldEnd()
-
 
13974
    oprot.writeFieldStop()
13321
    oprot.writeStructEnd()
13975
    oprot.writeStructEnd()
13322
 
13976
 
13323
  def validate(self):
13977
  def validate(self):
13324
    return
13978
    return
13325
 
13979