Subversion Repositories SmartDukaan

Rev

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

Rev 5527 Rev 5553
Line 527... Line 527...
527
     - deliveryTimestamp
527
     - deliveryTimestamp
528
     - receiver
528
     - receiver
529
    """
529
    """
530
    pass
530
    pass
531
 
531
 
-
 
532
  def markOrderAsReceivedAtStore(self, orderId, deliveryTimestamp):
-
 
533
    """
-
 
534
    Parameters:
-
 
535
     - orderId
-
 
536
     - deliveryTimestamp
-
 
537
    """
-
 
538
    pass
-
 
539
 
532
  def markOrderDoaRequestReceived(self, orderId):
540
  def markOrderDoaRequestReceived(self, orderId):
533
    """
541
    """
534
    Once user raise the request for a DOA, order status will be changed from DELVIERY_SUCCESS to DOA_REQUEST_RECEIVED
542
    Once user raise the request for a DOA, order status will be changed from DELVIERY_SUCCESS to DOA_REQUEST_RECEIVED
535
 
543
 
536
    Parameters:
544
    Parameters:
Line 1197... Line 1205...
1197
     - transactionId
1205
     - transactionId
1198
     - attribute
1206
     - attribute
1199
    """
1207
    """
1200
    pass
1208
    pass
1201
 
1209
 
-
 
1210
  def getReceivePendingOrders(self, storeId):
-
 
1211
    """
-
 
1212
    Parameters:
-
 
1213
     - storeId
-
 
1214
    """
-
 
1215
    pass
-
 
1216
 
-
 
1217
  def getReceivedAtStoreOrders(self, storeId):
-
 
1218
    """
-
 
1219
    Parameters:
-
 
1220
     - storeId
-
 
1221
    """
-
 
1222
    pass
-
 
1223
 
1202
 
1224
 
1203
class Client(shop2020.thriftpy.generic.GenericService.Client, Iface):
1225
class Client(shop2020.thriftpy.generic.GenericService.Client, Iface):
1204
  def __init__(self, iprot, oprot=None):
1226
  def __init__(self, iprot, oprot=None):
1205
    shop2020.thriftpy.generic.GenericService.Client.__init__(self, iprot, oprot)
1227
    shop2020.thriftpy.generic.GenericService.Client.__init__(self, iprot, oprot)
1206
 
1228
 
Line 3017... Line 3039...
3017
    self._iprot.readMessageEnd()
3039
    self._iprot.readMessageEnd()
3018
    if result.ex is not None:
3040
    if result.ex is not None:
3019
      raise result.ex
3041
      raise result.ex
3020
    return
3042
    return
3021
 
3043
 
-
 
3044
  def markOrderAsReceivedAtStore(self, orderId, deliveryTimestamp):
-
 
3045
    """
-
 
3046
    Parameters:
-
 
3047
     - orderId
-
 
3048
     - deliveryTimestamp
-
 
3049
    """
-
 
3050
    self.send_markOrderAsReceivedAtStore(orderId, deliveryTimestamp)
-
 
3051
    self.recv_markOrderAsReceivedAtStore()
-
 
3052
 
-
 
3053
  def send_markOrderAsReceivedAtStore(self, orderId, deliveryTimestamp):
-
 
3054
    self._oprot.writeMessageBegin('markOrderAsReceivedAtStore', TMessageType.CALL, self._seqid)
-
 
3055
    args = markOrderAsReceivedAtStore_args()
-
 
3056
    args.orderId = orderId
-
 
3057
    args.deliveryTimestamp = deliveryTimestamp
-
 
3058
    args.write(self._oprot)
-
 
3059
    self._oprot.writeMessageEnd()
-
 
3060
    self._oprot.trans.flush()
-
 
3061
 
-
 
3062
  def recv_markOrderAsReceivedAtStore(self, ):
-
 
3063
    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
-
 
3064
    if mtype == TMessageType.EXCEPTION:
-
 
3065
      x = TApplicationException()
-
 
3066
      x.read(self._iprot)
-
 
3067
      self._iprot.readMessageEnd()
-
 
3068
      raise x
-
 
3069
    result = markOrderAsReceivedAtStore_result()
-
 
3070
    result.read(self._iprot)
-
 
3071
    self._iprot.readMessageEnd()
-
 
3072
    if result.ex is not None:
-
 
3073
      raise result.ex
-
 
3074
    return
-
 
3075
 
3022
  def markOrderDoaRequestReceived(self, orderId):
3076
  def markOrderDoaRequestReceived(self, orderId):
3023
    """
3077
    """
3024
    Once user raise the request for a DOA, order status will be changed from DELVIERY_SUCCESS to DOA_REQUEST_RECEIVED
3078
    Once user raise the request for a DOA, order status will be changed from DELVIERY_SUCCESS to DOA_REQUEST_RECEIVED
3025
 
3079
 
3026
    Parameters:
3080
    Parameters:
Line 5308... Line 5362...
5308
    result = setOrderAttributeForTransaction_result()
5362
    result = setOrderAttributeForTransaction_result()
5309
    result.read(self._iprot)
5363
    result.read(self._iprot)
5310
    self._iprot.readMessageEnd()
5364
    self._iprot.readMessageEnd()
5311
    return
5365
    return
5312
 
5366
 
-
 
5367
  def getReceivePendingOrders(self, storeId):
-
 
5368
    """
-
 
5369
    Parameters:
-
 
5370
     - storeId
-
 
5371
    """
-
 
5372
    self.send_getReceivePendingOrders(storeId)
-
 
5373
    return self.recv_getReceivePendingOrders()
-
 
5374
 
-
 
5375
  def send_getReceivePendingOrders(self, storeId):
-
 
5376
    self._oprot.writeMessageBegin('getReceivePendingOrders', TMessageType.CALL, self._seqid)
-
 
5377
    args = getReceivePendingOrders_args()
-
 
5378
    args.storeId = storeId
-
 
5379
    args.write(self._oprot)
-
 
5380
    self._oprot.writeMessageEnd()
-
 
5381
    self._oprot.trans.flush()
-
 
5382
 
-
 
5383
  def recv_getReceivePendingOrders(self, ):
-
 
5384
    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
-
 
5385
    if mtype == TMessageType.EXCEPTION:
-
 
5386
      x = TApplicationException()
-
 
5387
      x.read(self._iprot)
-
 
5388
      self._iprot.readMessageEnd()
-
 
5389
      raise x
-
 
5390
    result = getReceivePendingOrders_result()
-
 
5391
    result.read(self._iprot)
-
 
5392
    self._iprot.readMessageEnd()
-
 
5393
    if result.success is not None:
-
 
5394
      return result.success
-
 
5395
    raise TApplicationException(TApplicationException.MISSING_RESULT, "getReceivePendingOrders failed: unknown result");
-
 
5396
 
-
 
5397
  def getReceivedAtStoreOrders(self, storeId):
-
 
5398
    """
-
 
5399
    Parameters:
-
 
5400
     - storeId
-
 
5401
    """
-
 
5402
    self.send_getReceivedAtStoreOrders(storeId)
-
 
5403
    return self.recv_getReceivedAtStoreOrders()
-
 
5404
 
-
 
5405
  def send_getReceivedAtStoreOrders(self, storeId):
-
 
5406
    self._oprot.writeMessageBegin('getReceivedAtStoreOrders', TMessageType.CALL, self._seqid)
-
 
5407
    args = getReceivedAtStoreOrders_args()
-
 
5408
    args.storeId = storeId
-
 
5409
    args.write(self._oprot)
-
 
5410
    self._oprot.writeMessageEnd()
-
 
5411
    self._oprot.trans.flush()
-
 
5412
 
-
 
5413
  def recv_getReceivedAtStoreOrders(self, ):
-
 
5414
    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
-
 
5415
    if mtype == TMessageType.EXCEPTION:
-
 
5416
      x = TApplicationException()
-
 
5417
      x.read(self._iprot)
-
 
5418
      self._iprot.readMessageEnd()
-
 
5419
      raise x
-
 
5420
    result = getReceivedAtStoreOrders_result()
-
 
5421
    result.read(self._iprot)
-
 
5422
    self._iprot.readMessageEnd()
-
 
5423
    if result.success is not None:
-
 
5424
      return result.success
-
 
5425
    raise TApplicationException(TApplicationException.MISSING_RESULT, "getReceivedAtStoreOrders failed: unknown result");
-
 
5426
 
5313
 
5427
 
5314
class Processor(shop2020.thriftpy.generic.GenericService.Processor, Iface, TProcessor):
5428
class Processor(shop2020.thriftpy.generic.GenericService.Processor, Iface, TProcessor):
5315
  def __init__(self, handler):
5429
  def __init__(self, handler):
5316
    shop2020.thriftpy.generic.GenericService.Processor.__init__(self, handler)
5430
    shop2020.thriftpy.generic.GenericService.Processor.__init__(self, handler)
5317
    self._processMap["createTransaction"] = Processor.process_createTransaction
5431
    self._processMap["createTransaction"] = Processor.process_createTransaction
Line 5364... Line 5478...
5364
    self._processMap["markOrdersAsFirstDeliveryAttempted"] = Processor.process_markOrdersAsFirstDeliveryAttempted
5478
    self._processMap["markOrdersAsFirstDeliveryAttempted"] = Processor.process_markOrdersAsFirstDeliveryAttempted
5365
    self._processMap["getUndeliveredOrders"] = Processor.process_getUndeliveredOrders
5479
    self._processMap["getUndeliveredOrders"] = Processor.process_getUndeliveredOrders
5366
    self._processMap["getUndeliveredOrdersExpectedDeliveryDateNotMet"] = Processor.process_getUndeliveredOrdersExpectedDeliveryDateNotMet
5480
    self._processMap["getUndeliveredOrdersExpectedDeliveryDateNotMet"] = Processor.process_getUndeliveredOrdersExpectedDeliveryDateNotMet
5367
    self._processMap["toggleDOAFlag"] = Processor.process_toggleDOAFlag
5481
    self._processMap["toggleDOAFlag"] = Processor.process_toggleDOAFlag
5368
    self._processMap["markOrderAsDelivered"] = Processor.process_markOrderAsDelivered
5482
    self._processMap["markOrderAsDelivered"] = Processor.process_markOrderAsDelivered
-
 
5483
    self._processMap["markOrderAsReceivedAtStore"] = Processor.process_markOrderAsReceivedAtStore
5369
    self._processMap["markOrderDoaRequestReceived"] = Processor.process_markOrderDoaRequestReceived
5484
    self._processMap["markOrderDoaRequestReceived"] = Processor.process_markOrderDoaRequestReceived
5370
    self._processMap["markOrderDoaRequestAuthorized"] = Processor.process_markOrderDoaRequestAuthorized
5485
    self._processMap["markOrderDoaRequestAuthorized"] = Processor.process_markOrderDoaRequestAuthorized
5371
    self._processMap["markOrderReturnRequestReceived"] = Processor.process_markOrderReturnRequestReceived
5486
    self._processMap["markOrderReturnRequestReceived"] = Processor.process_markOrderReturnRequestReceived
5372
    self._processMap["markOrderReturnRequestAuthorized"] = Processor.process_markOrderReturnRequestAuthorized
5487
    self._processMap["markOrderReturnRequestAuthorized"] = Processor.process_markOrderReturnRequestAuthorized
5373
    self._processMap["requestPickupNumber"] = Processor.process_requestPickupNumber
5488
    self._processMap["requestPickupNumber"] = Processor.process_requestPickupNumber
Line 5429... Line 5544...
5429
    self._processMap["updateOrderOnlyAsPaidToVendor"] = Processor.process_updateOrderOnlyAsPaidToVendor
5544
    self._processMap["updateOrderOnlyAsPaidToVendor"] = Processor.process_updateOrderOnlyAsPaidToVendor
5430
    self._processMap["getRefundedOrdersMarkedPaid"] = Processor.process_getRefundedOrdersMarkedPaid
5545
    self._processMap["getRefundedOrdersMarkedPaid"] = Processor.process_getRefundedOrdersMarkedPaid
5431
    self._processMap["getAllVerificationAgents"] = Processor.process_getAllVerificationAgents
5546
    self._processMap["getAllVerificationAgents"] = Processor.process_getAllVerificationAgents
5432
    self._processMap["getAllAttributesForOrderId"] = Processor.process_getAllAttributesForOrderId
5547
    self._processMap["getAllAttributesForOrderId"] = Processor.process_getAllAttributesForOrderId
5433
    self._processMap["setOrderAttributeForTransaction"] = Processor.process_setOrderAttributeForTransaction
5548
    self._processMap["setOrderAttributeForTransaction"] = Processor.process_setOrderAttributeForTransaction
-
 
5549
    self._processMap["getReceivePendingOrders"] = Processor.process_getReceivePendingOrders
-
 
5550
    self._processMap["getReceivedAtStoreOrders"] = Processor.process_getReceivedAtStoreOrders
5434
 
5551
 
5435
  def process(self, iprot, oprot):
5552
  def process(self, iprot, oprot):
5436
    (name, type, seqid) = iprot.readMessageBegin()
5553
    (name, type, seqid) = iprot.readMessageBegin()
5437
    if name not in self._processMap:
5554
    if name not in self._processMap:
5438
      iprot.skip(TType.STRUCT)
5555
      iprot.skip(TType.STRUCT)
Line 6128... Line 6245...
6128
    oprot.writeMessageBegin("markOrderAsDelivered", TMessageType.REPLY, seqid)
6245
    oprot.writeMessageBegin("markOrderAsDelivered", TMessageType.REPLY, seqid)
6129
    result.write(oprot)
6246
    result.write(oprot)
6130
    oprot.writeMessageEnd()
6247
    oprot.writeMessageEnd()
6131
    oprot.trans.flush()
6248
    oprot.trans.flush()
6132
 
6249
 
-
 
6250
  def process_markOrderAsReceivedAtStore(self, seqid, iprot, oprot):
-
 
6251
    args = markOrderAsReceivedAtStore_args()
-
 
6252
    args.read(iprot)
-
 
6253
    iprot.readMessageEnd()
-
 
6254
    result = markOrderAsReceivedAtStore_result()
-
 
6255
    try:
-
 
6256
      self._handler.markOrderAsReceivedAtStore(args.orderId, args.deliveryTimestamp)
-
 
6257
    except TransactionServiceException, ex:
-
 
6258
      result.ex = ex
-
 
6259
    oprot.writeMessageBegin("markOrderAsReceivedAtStore", TMessageType.REPLY, seqid)
-
 
6260
    result.write(oprot)
-
 
6261
    oprot.writeMessageEnd()
-
 
6262
    oprot.trans.flush()
-
 
6263
 
6133
  def process_markOrderDoaRequestReceived(self, seqid, iprot, oprot):
6264
  def process_markOrderDoaRequestReceived(self, seqid, iprot, oprot):
6134
    args = markOrderDoaRequestReceived_args()
6265
    args = markOrderDoaRequestReceived_args()
6135
    args.read(iprot)
6266
    args.read(iprot)
6136
    iprot.readMessageEnd()
6267
    iprot.readMessageEnd()
6137
    result = markOrderDoaRequestReceived_result()
6268
    result = markOrderDoaRequestReceived_result()
Line 6999... Line 7130...
6999
    oprot.writeMessageBegin("setOrderAttributeForTransaction", TMessageType.REPLY, seqid)
7130
    oprot.writeMessageBegin("setOrderAttributeForTransaction", TMessageType.REPLY, seqid)
7000
    result.write(oprot)
7131
    result.write(oprot)
7001
    oprot.writeMessageEnd()
7132
    oprot.writeMessageEnd()
7002
    oprot.trans.flush()
7133
    oprot.trans.flush()
7003
 
7134
 
-
 
7135
  def process_getReceivePendingOrders(self, seqid, iprot, oprot):
-
 
7136
    args = getReceivePendingOrders_args()
-
 
7137
    args.read(iprot)
-
 
7138
    iprot.readMessageEnd()
-
 
7139
    result = getReceivePendingOrders_result()
-
 
7140
    result.success = self._handler.getReceivePendingOrders(args.storeId)
-
 
7141
    oprot.writeMessageBegin("getReceivePendingOrders", TMessageType.REPLY, seqid)
-
 
7142
    result.write(oprot)
-
 
7143
    oprot.writeMessageEnd()
-
 
7144
    oprot.trans.flush()
-
 
7145
 
-
 
7146
  def process_getReceivedAtStoreOrders(self, seqid, iprot, oprot):
-
 
7147
    args = getReceivedAtStoreOrders_args()
-
 
7148
    args.read(iprot)
-
 
7149
    iprot.readMessageEnd()
-
 
7150
    result = getReceivedAtStoreOrders_result()
-
 
7151
    result.success = self._handler.getReceivedAtStoreOrders(args.storeId)
-
 
7152
    oprot.writeMessageBegin("getReceivedAtStoreOrders", TMessageType.REPLY, seqid)
-
 
7153
    result.write(oprot)
-
 
7154
    oprot.writeMessageEnd()
-
 
7155
    oprot.trans.flush()
-
 
7156
 
7004
 
7157
 
7005
# HELPER FUNCTIONS AND STRUCTURES
7158
# HELPER FUNCTIONS AND STRUCTURES
7006
 
7159
 
7007
class createTransaction_args:
7160
class createTransaction_args:
7008
  """
7161
  """
Line 14519... Line 14672...
14519
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
14672
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
14520
 
14673
 
14521
  def __ne__(self, other):
14674
  def __ne__(self, other):
14522
    return not (self == other)
14675
    return not (self == other)
14523
 
14676
 
-
 
14677
class markOrderAsReceivedAtStore_args:
-
 
14678
  """
-
 
14679
  Attributes:
-
 
14680
   - orderId
-
 
14681
   - deliveryTimestamp
-
 
14682
  """
-
 
14683
 
-
 
14684
  thrift_spec = (
-
 
14685
    None, # 0
-
 
14686
    (1, TType.I64, 'orderId', None, None, ), # 1
-
 
14687
    (2, TType.I64, 'deliveryTimestamp', None, None, ), # 2
-
 
14688
  )
-
 
14689
 
-
 
14690
  def __init__(self, orderId=None, deliveryTimestamp=None,):
-
 
14691
    self.orderId = orderId
-
 
14692
    self.deliveryTimestamp = deliveryTimestamp
-
 
14693
 
-
 
14694
  def read(self, iprot):
-
 
14695
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
-
 
14696
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
-
 
14697
      return
-
 
14698
    iprot.readStructBegin()
-
 
14699
    while True:
-
 
14700
      (fname, ftype, fid) = iprot.readFieldBegin()
-
 
14701
      if ftype == TType.STOP:
-
 
14702
        break
-
 
14703
      if fid == 1:
-
 
14704
        if ftype == TType.I64:
-
 
14705
          self.orderId = iprot.readI64();
-
 
14706
        else:
-
 
14707
          iprot.skip(ftype)
-
 
14708
      elif fid == 2:
-
 
14709
        if ftype == TType.I64:
-
 
14710
          self.deliveryTimestamp = iprot.readI64();
-
 
14711
        else:
-
 
14712
          iprot.skip(ftype)
-
 
14713
      else:
-
 
14714
        iprot.skip(ftype)
-
 
14715
      iprot.readFieldEnd()
-
 
14716
    iprot.readStructEnd()
-
 
14717
 
-
 
14718
  def write(self, oprot):
-
 
14719
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
-
 
14720
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
-
 
14721
      return
-
 
14722
    oprot.writeStructBegin('markOrderAsReceivedAtStore_args')
-
 
14723
    if self.orderId is not None:
-
 
14724
      oprot.writeFieldBegin('orderId', TType.I64, 1)
-
 
14725
      oprot.writeI64(self.orderId)
-
 
14726
      oprot.writeFieldEnd()
-
 
14727
    if self.deliveryTimestamp is not None:
-
 
14728
      oprot.writeFieldBegin('deliveryTimestamp', TType.I64, 2)
-
 
14729
      oprot.writeI64(self.deliveryTimestamp)
-
 
14730
      oprot.writeFieldEnd()
-
 
14731
    oprot.writeFieldStop()
-
 
14732
    oprot.writeStructEnd()
-
 
14733
 
-
 
14734
  def validate(self):
-
 
14735
    return
-
 
14736
 
-
 
14737
 
-
 
14738
  def __repr__(self):
-
 
14739
    L = ['%s=%r' % (key, value)
-
 
14740
      for key, value in self.__dict__.iteritems()]
-
 
14741
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
-
 
14742
 
-
 
14743
  def __eq__(self, other):
-
 
14744
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
 
14745
 
-
 
14746
  def __ne__(self, other):
-
 
14747
    return not (self == other)
-
 
14748
 
-
 
14749
class markOrderAsReceivedAtStore_result:
-
 
14750
  """
-
 
14751
  Attributes:
-
 
14752
   - ex
-
 
14753
  """
-
 
14754
 
-
 
14755
  thrift_spec = (
-
 
14756
    None, # 0
-
 
14757
    (1, TType.STRUCT, 'ex', (TransactionServiceException, TransactionServiceException.thrift_spec), None, ), # 1
-
 
14758
  )
-
 
14759
 
-
 
14760
  def __init__(self, ex=None,):
-
 
14761
    self.ex = ex
-
 
14762
 
-
 
14763
  def read(self, iprot):
-
 
14764
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
-
 
14765
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
-
 
14766
      return
-
 
14767
    iprot.readStructBegin()
-
 
14768
    while True:
-
 
14769
      (fname, ftype, fid) = iprot.readFieldBegin()
-
 
14770
      if ftype == TType.STOP:
-
 
14771
        break
-
 
14772
      if fid == 1:
-
 
14773
        if ftype == TType.STRUCT:
-
 
14774
          self.ex = TransactionServiceException()
-
 
14775
          self.ex.read(iprot)
-
 
14776
        else:
-
 
14777
          iprot.skip(ftype)
-
 
14778
      else:
-
 
14779
        iprot.skip(ftype)
-
 
14780
      iprot.readFieldEnd()
-
 
14781
    iprot.readStructEnd()
-
 
14782
 
-
 
14783
  def write(self, oprot):
-
 
14784
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
-
 
14785
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
-
 
14786
      return
-
 
14787
    oprot.writeStructBegin('markOrderAsReceivedAtStore_result')
-
 
14788
    if self.ex is not None:
-
 
14789
      oprot.writeFieldBegin('ex', TType.STRUCT, 1)
-
 
14790
      self.ex.write(oprot)
-
 
14791
      oprot.writeFieldEnd()
-
 
14792
    oprot.writeFieldStop()
-
 
14793
    oprot.writeStructEnd()
-
 
14794
 
-
 
14795
  def validate(self):
-
 
14796
    return
-
 
14797
 
-
 
14798
 
-
 
14799
  def __repr__(self):
-
 
14800
    L = ['%s=%r' % (key, value)
-
 
14801
      for key, value in self.__dict__.iteritems()]
-
 
14802
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
-
 
14803
 
-
 
14804
  def __eq__(self, other):
-
 
14805
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
 
14806
 
-
 
14807
  def __ne__(self, other):
-
 
14808
    return not (self == other)
-
 
14809
 
14524
class markOrderDoaRequestReceived_args:
14810
class markOrderDoaRequestReceived_args:
14525
  """
14811
  """
14526
  Attributes:
14812
  Attributes:
14527
   - orderId
14813
   - orderId
14528
  """
14814
  """
Line 23534... Line 23820...
23534
      if ftype == TType.STOP:
23820
      if ftype == TType.STOP:
23535
        break
23821
        break
23536
      if fid == 0:
23822
      if fid == 0:
23537
        if ftype == TType.LIST:
23823
        if ftype == TType.LIST:
23538
          self.success = []
23824
          self.success = []
23539
          (_etype560, _size557) = iprot.readListBegin()
23825
          (_etype567, _size564) = iprot.readListBegin()
23540
          for _i561 in xrange(_size557):
23826
          for _i568 in xrange(_size564):
23541
            _elem562 = Attribute()
23827
            _elem569 = Attribute()
23542
            _elem562.read(iprot)
23828
            _elem569.read(iprot)
23543
            self.success.append(_elem562)
23829
            self.success.append(_elem569)
23544
          iprot.readListEnd()
23830
          iprot.readListEnd()
23545
        else:
23831
        else:
23546
          iprot.skip(ftype)
23832
          iprot.skip(ftype)
23547
      else:
23833
      else:
23548
        iprot.skip(ftype)
23834
        iprot.skip(ftype)
Line 23555... Line 23841...
23555
      return
23841
      return
23556
    oprot.writeStructBegin('getAllAttributesForOrderId_result')
23842
    oprot.writeStructBegin('getAllAttributesForOrderId_result')
23557
    if self.success is not None:
23843
    if self.success is not None:
23558
      oprot.writeFieldBegin('success', TType.LIST, 0)
23844
      oprot.writeFieldBegin('success', TType.LIST, 0)
23559
      oprot.writeListBegin(TType.STRUCT, len(self.success))
23845
      oprot.writeListBegin(TType.STRUCT, len(self.success))
23560
      for iter563 in self.success:
23846
      for iter570 in self.success:
23561
        iter563.write(oprot)
23847
        iter570.write(oprot)
23562
      oprot.writeListEnd()
23848
      oprot.writeListEnd()
23563
      oprot.writeFieldEnd()
23849
      oprot.writeFieldEnd()
23564
    oprot.writeFieldStop()
23850
    oprot.writeFieldStop()
23565
    oprot.writeStructEnd()
23851
    oprot.writeStructEnd()
23566
 
23852
 
Line 23674... Line 23960...
23674
    oprot.writeFieldStop()
23960
    oprot.writeFieldStop()
23675
    oprot.writeStructEnd()
23961
    oprot.writeStructEnd()
23676
 
23962
 
23677
  def validate(self):
23963
  def validate(self):
23678
    return
23964
    return
-
 
23965
 
-
 
23966
 
-
 
23967
  def __repr__(self):
-
 
23968
    L = ['%s=%r' % (key, value)
-
 
23969
      for key, value in self.__dict__.iteritems()]
-
 
23970
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
-
 
23971
 
-
 
23972
  def __eq__(self, other):
-
 
23973
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
 
23974
 
-
 
23975
  def __ne__(self, other):
-
 
23976
    return not (self == other)
-
 
23977
 
-
 
23978
class getReceivePendingOrders_args:
-
 
23979
  """
-
 
23980
  Attributes:
-
 
23981
   - storeId
-
 
23982
  """
-
 
23983
 
-
 
23984
  thrift_spec = (
-
 
23985
    None, # 0
-
 
23986
    (1, TType.I64, 'storeId', None, None, ), # 1
-
 
23987
  )
-
 
23988
 
-
 
23989
  def __init__(self, storeId=None,):
-
 
23990
    self.storeId = storeId
-
 
23991
 
-
 
23992
  def read(self, iprot):
-
 
23993
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
-
 
23994
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
-
 
23995
      return
-
 
23996
    iprot.readStructBegin()
-
 
23997
    while True:
-
 
23998
      (fname, ftype, fid) = iprot.readFieldBegin()
-
 
23999
      if ftype == TType.STOP:
-
 
24000
        break
-
 
24001
      if fid == 1:
-
 
24002
        if ftype == TType.I64:
-
 
24003
          self.storeId = iprot.readI64();
-
 
24004
        else:
-
 
24005
          iprot.skip(ftype)
-
 
24006
      else:
-
 
24007
        iprot.skip(ftype)
-
 
24008
      iprot.readFieldEnd()
-
 
24009
    iprot.readStructEnd()
-
 
24010
 
-
 
24011
  def write(self, oprot):
-
 
24012
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
-
 
24013
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
-
 
24014
      return
-
 
24015
    oprot.writeStructBegin('getReceivePendingOrders_args')
-
 
24016
    if self.storeId is not None:
-
 
24017
      oprot.writeFieldBegin('storeId', TType.I64, 1)
-
 
24018
      oprot.writeI64(self.storeId)
-
 
24019
      oprot.writeFieldEnd()
-
 
24020
    oprot.writeFieldStop()
-
 
24021
    oprot.writeStructEnd()
-
 
24022
 
-
 
24023
  def validate(self):
-
 
24024
    return
-
 
24025
 
-
 
24026
 
-
 
24027
  def __repr__(self):
-
 
24028
    L = ['%s=%r' % (key, value)
-
 
24029
      for key, value in self.__dict__.iteritems()]
-
 
24030
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
-
 
24031
 
-
 
24032
  def __eq__(self, other):
-
 
24033
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
 
24034
 
-
 
24035
  def __ne__(self, other):
-
 
24036
    return not (self == other)
-
 
24037
 
-
 
24038
class getReceivePendingOrders_result:
-
 
24039
  """
-
 
24040
  Attributes:
-
 
24041
   - success
-
 
24042
  """
-
 
24043
 
-
 
24044
  thrift_spec = (
-
 
24045
    (0, TType.LIST, 'success', (TType.STRUCT,(Order, Order.thrift_spec)), None, ), # 0
-
 
24046
  )
-
 
24047
 
-
 
24048
  def __init__(self, success=None,):
-
 
24049
    self.success = success
-
 
24050
 
-
 
24051
  def read(self, iprot):
-
 
24052
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
-
 
24053
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
-
 
24054
      return
-
 
24055
    iprot.readStructBegin()
-
 
24056
    while True:
-
 
24057
      (fname, ftype, fid) = iprot.readFieldBegin()
-
 
24058
      if ftype == TType.STOP:
-
 
24059
        break
-
 
24060
      if fid == 0:
-
 
24061
        if ftype == TType.LIST:
-
 
24062
          self.success = []
-
 
24063
          (_etype574, _size571) = iprot.readListBegin()
-
 
24064
          for _i575 in xrange(_size571):
-
 
24065
            _elem576 = Order()
-
 
24066
            _elem576.read(iprot)
-
 
24067
            self.success.append(_elem576)
-
 
24068
          iprot.readListEnd()
-
 
24069
        else:
-
 
24070
          iprot.skip(ftype)
-
 
24071
      else:
-
 
24072
        iprot.skip(ftype)
-
 
24073
      iprot.readFieldEnd()
-
 
24074
    iprot.readStructEnd()
-
 
24075
 
-
 
24076
  def write(self, oprot):
-
 
24077
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
-
 
24078
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
-
 
24079
      return
-
 
24080
    oprot.writeStructBegin('getReceivePendingOrders_result')
-
 
24081
    if self.success is not None:
-
 
24082
      oprot.writeFieldBegin('success', TType.LIST, 0)
-
 
24083
      oprot.writeListBegin(TType.STRUCT, len(self.success))
-
 
24084
      for iter577 in self.success:
-
 
24085
        iter577.write(oprot)
-
 
24086
      oprot.writeListEnd()
-
 
24087
      oprot.writeFieldEnd()
-
 
24088
    oprot.writeFieldStop()
-
 
24089
    oprot.writeStructEnd()
-
 
24090
 
-
 
24091
  def validate(self):
-
 
24092
    return
-
 
24093
 
-
 
24094
 
-
 
24095
  def __repr__(self):
-
 
24096
    L = ['%s=%r' % (key, value)
-
 
24097
      for key, value in self.__dict__.iteritems()]
-
 
24098
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
-
 
24099
 
-
 
24100
  def __eq__(self, other):
-
 
24101
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
 
24102
 
-
 
24103
  def __ne__(self, other):
-
 
24104
    return not (self == other)
-
 
24105
 
-
 
24106
class getReceivedAtStoreOrders_args:
-
 
24107
  """
-
 
24108
  Attributes:
-
 
24109
   - storeId
-
 
24110
  """
-
 
24111
 
-
 
24112
  thrift_spec = (
-
 
24113
    None, # 0
-
 
24114
    (1, TType.I64, 'storeId', None, None, ), # 1
-
 
24115
  )
-
 
24116
 
-
 
24117
  def __init__(self, storeId=None,):
-
 
24118
    self.storeId = storeId
-
 
24119
 
-
 
24120
  def read(self, iprot):
-
 
24121
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
-
 
24122
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
-
 
24123
      return
-
 
24124
    iprot.readStructBegin()
-
 
24125
    while True:
-
 
24126
      (fname, ftype, fid) = iprot.readFieldBegin()
-
 
24127
      if ftype == TType.STOP:
-
 
24128
        break
-
 
24129
      if fid == 1:
-
 
24130
        if ftype == TType.I64:
-
 
24131
          self.storeId = iprot.readI64();
-
 
24132
        else:
-
 
24133
          iprot.skip(ftype)
-
 
24134
      else:
-
 
24135
        iprot.skip(ftype)
-
 
24136
      iprot.readFieldEnd()
-
 
24137
    iprot.readStructEnd()
-
 
24138
 
-
 
24139
  def write(self, oprot):
-
 
24140
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
-
 
24141
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
-
 
24142
      return
-
 
24143
    oprot.writeStructBegin('getReceivedAtStoreOrders_args')
-
 
24144
    if self.storeId is not None:
-
 
24145
      oprot.writeFieldBegin('storeId', TType.I64, 1)
-
 
24146
      oprot.writeI64(self.storeId)
-
 
24147
      oprot.writeFieldEnd()
-
 
24148
    oprot.writeFieldStop()
-
 
24149
    oprot.writeStructEnd()
-
 
24150
 
-
 
24151
  def validate(self):
-
 
24152
    return
-
 
24153
 
-
 
24154
 
-
 
24155
  def __repr__(self):
-
 
24156
    L = ['%s=%r' % (key, value)
-
 
24157
      for key, value in self.__dict__.iteritems()]
-
 
24158
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
-
 
24159
 
-
 
24160
  def __eq__(self, other):
-
 
24161
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
 
24162
 
-
 
24163
  def __ne__(self, other):
-
 
24164
    return not (self == other)
-
 
24165
 
-
 
24166
class getReceivedAtStoreOrders_result:
-
 
24167
  """
-
 
24168
  Attributes:
-
 
24169
   - success
-
 
24170
  """
-
 
24171
 
-
 
24172
  thrift_spec = (
-
 
24173
    (0, TType.LIST, 'success', (TType.STRUCT,(Order, Order.thrift_spec)), None, ), # 0
-
 
24174
  )
-
 
24175
 
-
 
24176
  def __init__(self, success=None,):
-
 
24177
    self.success = success
-
 
24178
 
-
 
24179
  def read(self, iprot):
-
 
24180
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
-
 
24181
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
-
 
24182
      return
-
 
24183
    iprot.readStructBegin()
-
 
24184
    while True:
-
 
24185
      (fname, ftype, fid) = iprot.readFieldBegin()
-
 
24186
      if ftype == TType.STOP:
-
 
24187
        break
-
 
24188
      if fid == 0:
-
 
24189
        if ftype == TType.LIST:
-
 
24190
          self.success = []
-
 
24191
          (_etype581, _size578) = iprot.readListBegin()
-
 
24192
          for _i582 in xrange(_size578):
-
 
24193
            _elem583 = Order()
-
 
24194
            _elem583.read(iprot)
-
 
24195
            self.success.append(_elem583)
-
 
24196
          iprot.readListEnd()
-
 
24197
        else:
-
 
24198
          iprot.skip(ftype)
-
 
24199
      else:
-
 
24200
        iprot.skip(ftype)
-
 
24201
      iprot.readFieldEnd()
-
 
24202
    iprot.readStructEnd()
-
 
24203
 
-
 
24204
  def write(self, oprot):
-
 
24205
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
-
 
24206
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
-
 
24207
      return
-
 
24208
    oprot.writeStructBegin('getReceivedAtStoreOrders_result')
-
 
24209
    if self.success is not None:
-
 
24210
      oprot.writeFieldBegin('success', TType.LIST, 0)
-
 
24211
      oprot.writeListBegin(TType.STRUCT, len(self.success))
-
 
24212
      for iter584 in self.success:
-
 
24213
        iter584.write(oprot)
-
 
24214
      oprot.writeListEnd()
-
 
24215
      oprot.writeFieldEnd()
-
 
24216
    oprot.writeFieldStop()
-
 
24217
    oprot.writeStructEnd()
-
 
24218
 
-
 
24219
  def validate(self):
-
 
24220
    return
23679
 
24221
 
23680
 
24222
 
23681
  def __repr__(self):
24223
  def __repr__(self):
23682
    L = ['%s=%r' % (key, value)
24224
    L = ['%s=%r' % (key, value)
23683
      for key, value in self.__dict__.iteritems()]
24225
      for key, value in self.__dict__.iteritems()]