Subversion Repositories SmartDukaan

Rev

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

Rev 10489 Rev 10690
Line 532... Line 532...
532
     - id
532
     - id
533
     - remoteTransferRefNumber
533
     - remoteTransferRefNumber
534
    """
534
    """
535
    pass
535
    pass
536
 
536
 
-
 
537
  def getInventoryItemScannedInForPO(self, itemId, purchaseIds):
-
 
538
    """
-
 
539
    Parameters:
-
 
540
     - itemId
-
 
541
     - purchaseIds
-
 
542
    """
-
 
543
    pass
-
 
544
 
-
 
545
  def getAmazonTransferredSkuDetails(self, itemIds):
-
 
546
    """
-
 
547
    Parameters:
-
 
548
     - itemIds
-
 
549
    """
-
 
550
    pass
-
 
551
 
-
 
552
  def getScansforPurchase(self, purchaseId, scanType):
-
 
553
    """
-
 
554
    Parameters:
-
 
555
     - purchaseId
-
 
556
     - scanType
-
 
557
    """
-
 
558
    pass
-
 
559
 
537
 
560
 
538
class Client(shop2020.thriftpy.generic.GenericService.Client, Iface):
561
class Client(shop2020.thriftpy.generic.GenericService.Client, Iface):
539
  def __init__(self, iprot, oprot=None):
562
  def __init__(self, iprot, oprot=None):
540
    shop2020.thriftpy.generic.GenericService.Client.__init__(self, iprot, oprot)
563
    shop2020.thriftpy.generic.GenericService.Client.__init__(self, iprot, oprot)
541
 
564
 
Line 2419... Line 2442...
2419
    self._iprot.readMessageEnd()
2442
    self._iprot.readMessageEnd()
2420
    if result.wex is not None:
2443
    if result.wex is not None:
2421
      raise result.wex
2444
      raise result.wex
2422
    return
2445
    return
2423
 
2446
 
-
 
2447
  def getInventoryItemScannedInForPO(self, itemId, purchaseIds):
-
 
2448
    """
-
 
2449
    Parameters:
-
 
2450
     - itemId
-
 
2451
     - purchaseIds
-
 
2452
    """
-
 
2453
    self.send_getInventoryItemScannedInForPO(itemId, purchaseIds)
-
 
2454
    return self.recv_getInventoryItemScannedInForPO()
-
 
2455
 
-
 
2456
  def send_getInventoryItemScannedInForPO(self, itemId, purchaseIds):
-
 
2457
    self._oprot.writeMessageBegin('getInventoryItemScannedInForPO', TMessageType.CALL, self._seqid)
-
 
2458
    args = getInventoryItemScannedInForPO_args()
-
 
2459
    args.itemId = itemId
-
 
2460
    args.purchaseIds = purchaseIds
-
 
2461
    args.write(self._oprot)
-
 
2462
    self._oprot.writeMessageEnd()
-
 
2463
    self._oprot.trans.flush()
-
 
2464
 
-
 
2465
  def recv_getInventoryItemScannedInForPO(self, ):
-
 
2466
    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
-
 
2467
    if mtype == TMessageType.EXCEPTION:
-
 
2468
      x = TApplicationException()
-
 
2469
      x.read(self._iprot)
-
 
2470
      self._iprot.readMessageEnd()
-
 
2471
      raise x
-
 
2472
    result = getInventoryItemScannedInForPO_result()
-
 
2473
    result.read(self._iprot)
-
 
2474
    self._iprot.readMessageEnd()
-
 
2475
    if result.success is not None:
-
 
2476
      return result.success
-
 
2477
    if result.wex is not None:
-
 
2478
      raise result.wex
-
 
2479
    raise TApplicationException(TApplicationException.MISSING_RESULT, "getInventoryItemScannedInForPO failed: unknown result");
-
 
2480
 
-
 
2481
  def getAmazonTransferredSkuDetails(self, itemIds):
-
 
2482
    """
-
 
2483
    Parameters:
-
 
2484
     - itemIds
-
 
2485
    """
-
 
2486
    self.send_getAmazonTransferredSkuDetails(itemIds)
-
 
2487
    return self.recv_getAmazonTransferredSkuDetails()
-
 
2488
 
-
 
2489
  def send_getAmazonTransferredSkuDetails(self, itemIds):
-
 
2490
    self._oprot.writeMessageBegin('getAmazonTransferredSkuDetails', TMessageType.CALL, self._seqid)
-
 
2491
    args = getAmazonTransferredSkuDetails_args()
-
 
2492
    args.itemIds = itemIds
-
 
2493
    args.write(self._oprot)
-
 
2494
    self._oprot.writeMessageEnd()
-
 
2495
    self._oprot.trans.flush()
-
 
2496
 
-
 
2497
  def recv_getAmazonTransferredSkuDetails(self, ):
-
 
2498
    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
-
 
2499
    if mtype == TMessageType.EXCEPTION:
-
 
2500
      x = TApplicationException()
-
 
2501
      x.read(self._iprot)
-
 
2502
      self._iprot.readMessageEnd()
-
 
2503
      raise x
-
 
2504
    result = getAmazonTransferredSkuDetails_result()
-
 
2505
    result.read(self._iprot)
-
 
2506
    self._iprot.readMessageEnd()
-
 
2507
    if result.success is not None:
-
 
2508
      return result.success
-
 
2509
    if result.wex is not None:
-
 
2510
      raise result.wex
-
 
2511
    raise TApplicationException(TApplicationException.MISSING_RESULT, "getAmazonTransferredSkuDetails failed: unknown result");
-
 
2512
 
-
 
2513
  def getScansforPurchase(self, purchaseId, scanType):
-
 
2514
    """
-
 
2515
    Parameters:
-
 
2516
     - purchaseId
-
 
2517
     - scanType
-
 
2518
    """
-
 
2519
    self.send_getScansforPurchase(purchaseId, scanType)
-
 
2520
    return self.recv_getScansforPurchase()
-
 
2521
 
-
 
2522
  def send_getScansforPurchase(self, purchaseId, scanType):
-
 
2523
    self._oprot.writeMessageBegin('getScansforPurchase', TMessageType.CALL, self._seqid)
-
 
2524
    args = getScansforPurchase_args()
-
 
2525
    args.purchaseId = purchaseId
-
 
2526
    args.scanType = scanType
-
 
2527
    args.write(self._oprot)
-
 
2528
    self._oprot.writeMessageEnd()
-
 
2529
    self._oprot.trans.flush()
-
 
2530
 
-
 
2531
  def recv_getScansforPurchase(self, ):
-
 
2532
    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
-
 
2533
    if mtype == TMessageType.EXCEPTION:
-
 
2534
      x = TApplicationException()
-
 
2535
      x.read(self._iprot)
-
 
2536
      self._iprot.readMessageEnd()
-
 
2537
      raise x
-
 
2538
    result = getScansforPurchase_result()
-
 
2539
    result.read(self._iprot)
-
 
2540
    self._iprot.readMessageEnd()
-
 
2541
    if result.success is not None:
-
 
2542
      return result.success
-
 
2543
    if result.wex is not None:
-
 
2544
      raise result.wex
-
 
2545
    raise TApplicationException(TApplicationException.MISSING_RESULT, "getScansforPurchase failed: unknown result");
-
 
2546
 
2424
 
2547
 
2425
class Processor(shop2020.thriftpy.generic.GenericService.Processor, Iface, TProcessor):
2548
class Processor(shop2020.thriftpy.generic.GenericService.Processor, Iface, TProcessor):
2426
  def __init__(self, handler):
2549
  def __init__(self, handler):
2427
    shop2020.thriftpy.generic.GenericService.Processor.__init__(self, handler)
2550
    shop2020.thriftpy.generic.GenericService.Processor.__init__(self, handler)
2428
    self._processMap["getInventoryItem"] = Processor.process_getInventoryItem
2551
    self._processMap["getInventoryItem"] = Processor.process_getInventoryItem
Line 2478... Line 2601...
2478
    self._processMap["getHistoricBadInventoryByScans"] = Processor.process_getHistoricBadInventoryByScans
2601
    self._processMap["getHistoricBadInventoryByScans"] = Processor.process_getHistoricBadInventoryByScans
2479
    self._processMap["scanForBadSale"] = Processor.process_scanForBadSale
2602
    self._processMap["scanForBadSale"] = Processor.process_scanForBadSale
2480
    self._processMap["getTransferLotItemsForMarkReceive"] = Processor.process_getTransferLotItemsForMarkReceive
2603
    self._processMap["getTransferLotItemsForMarkReceive"] = Processor.process_getTransferLotItemsForMarkReceive
2481
    self._processMap["markItemsAsReceivedForTransferLotPartial"] = Processor.process_markItemsAsReceivedForTransferLotPartial
2604
    self._processMap["markItemsAsReceivedForTransferLotPartial"] = Processor.process_markItemsAsReceivedForTransferLotPartial
2482
    self._processMap["markTransferLotAsReceivedPartial"] = Processor.process_markTransferLotAsReceivedPartial
2605
    self._processMap["markTransferLotAsReceivedPartial"] = Processor.process_markTransferLotAsReceivedPartial
-
 
2606
    self._processMap["getInventoryItemScannedInForPO"] = Processor.process_getInventoryItemScannedInForPO
-
 
2607
    self._processMap["getAmazonTransferredSkuDetails"] = Processor.process_getAmazonTransferredSkuDetails
-
 
2608
    self._processMap["getScansforPurchase"] = Processor.process_getScansforPurchase
2483
 
2609
 
2484
  def process(self, iprot, oprot):
2610
  def process(self, iprot, oprot):
2485
    (name, type, seqid) = iprot.readMessageBegin()
2611
    (name, type, seqid) = iprot.readMessageBegin()
2486
    if name not in self._processMap:
2612
    if name not in self._processMap:
2487
      iprot.skip(TType.STRUCT)
2613
      iprot.skip(TType.STRUCT)
Line 3192... Line 3318...
3192
    oprot.writeMessageBegin("markTransferLotAsReceivedPartial", TMessageType.REPLY, seqid)
3318
    oprot.writeMessageBegin("markTransferLotAsReceivedPartial", TMessageType.REPLY, seqid)
3193
    result.write(oprot)
3319
    result.write(oprot)
3194
    oprot.writeMessageEnd()
3320
    oprot.writeMessageEnd()
3195
    oprot.trans.flush()
3321
    oprot.trans.flush()
3196
 
3322
 
-
 
3323
  def process_getInventoryItemScannedInForPO(self, seqid, iprot, oprot):
-
 
3324
    args = getInventoryItemScannedInForPO_args()
-
 
3325
    args.read(iprot)
-
 
3326
    iprot.readMessageEnd()
-
 
3327
    result = getInventoryItemScannedInForPO_result()
-
 
3328
    try:
-
 
3329
      result.success = self._handler.getInventoryItemScannedInForPO(args.itemId, args.purchaseIds)
-
 
3330
    except WarehouseServiceException, wex:
-
 
3331
      result.wex = wex
-
 
3332
    oprot.writeMessageBegin("getInventoryItemScannedInForPO", TMessageType.REPLY, seqid)
-
 
3333
    result.write(oprot)
-
 
3334
    oprot.writeMessageEnd()
-
 
3335
    oprot.trans.flush()
-
 
3336
 
-
 
3337
  def process_getAmazonTransferredSkuDetails(self, seqid, iprot, oprot):
-
 
3338
    args = getAmazonTransferredSkuDetails_args()
-
 
3339
    args.read(iprot)
-
 
3340
    iprot.readMessageEnd()
-
 
3341
    result = getAmazonTransferredSkuDetails_result()
-
 
3342
    try:
-
 
3343
      result.success = self._handler.getAmazonTransferredSkuDetails(args.itemIds)
-
 
3344
    except WarehouseServiceException, wex:
-
 
3345
      result.wex = wex
-
 
3346
    oprot.writeMessageBegin("getAmazonTransferredSkuDetails", TMessageType.REPLY, seqid)
-
 
3347
    result.write(oprot)
-
 
3348
    oprot.writeMessageEnd()
-
 
3349
    oprot.trans.flush()
-
 
3350
 
-
 
3351
  def process_getScansforPurchase(self, seqid, iprot, oprot):
-
 
3352
    args = getScansforPurchase_args()
-
 
3353
    args.read(iprot)
-
 
3354
    iprot.readMessageEnd()
-
 
3355
    result = getScansforPurchase_result()
-
 
3356
    try:
-
 
3357
      result.success = self._handler.getScansforPurchase(args.purchaseId, args.scanType)
-
 
3358
    except WarehouseServiceException, wex:
-
 
3359
      result.wex = wex
-
 
3360
    oprot.writeMessageBegin("getScansforPurchase", TMessageType.REPLY, seqid)
-
 
3361
    result.write(oprot)
-
 
3362
    oprot.writeMessageEnd()
-
 
3363
    oprot.trans.flush()
-
 
3364
 
3197
 
3365
 
3198
# HELPER FUNCTIONS AND STRUCTURES
3366
# HELPER FUNCTIONS AND STRUCTURES
3199
 
3367
 
3200
class getInventoryItem_args:
3368
class getInventoryItem_args:
3201
  """
3369
  """
Line 11051... Line 11219...
11051
    if self.wex is not None:
11219
    if self.wex is not None:
11052
      oprot.writeFieldBegin('wex', TType.STRUCT, 1)
11220
      oprot.writeFieldBegin('wex', TType.STRUCT, 1)
11053
      self.wex.write(oprot)
11221
      self.wex.write(oprot)
11054
      oprot.writeFieldEnd()
11222
      oprot.writeFieldEnd()
11055
    oprot.writeFieldStop()
11223
    oprot.writeFieldStop()
-
 
11224
    oprot.writeStructEnd()
-
 
11225
 
-
 
11226
  def validate(self):
-
 
11227
    return
-
 
11228
 
-
 
11229
 
-
 
11230
  def __repr__(self):
-
 
11231
    L = ['%s=%r' % (key, value)
-
 
11232
      for key, value in self.__dict__.iteritems()]
-
 
11233
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
-
 
11234
 
-
 
11235
  def __eq__(self, other):
-
 
11236
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
 
11237
 
-
 
11238
  def __ne__(self, other):
-
 
11239
    return not (self == other)
-
 
11240
 
-
 
11241
class getInventoryItemScannedInForPO_args:
-
 
11242
  """
-
 
11243
  Attributes:
-
 
11244
   - itemId
-
 
11245
   - purchaseIds
-
 
11246
  """
-
 
11247
 
-
 
11248
  thrift_spec = (
-
 
11249
    None, # 0
-
 
11250
    (1, TType.I64, 'itemId', None, None, ), # 1
-
 
11251
    (2, TType.LIST, 'purchaseIds', (TType.I64,None), None, ), # 2
-
 
11252
  )
-
 
11253
 
-
 
11254
  def __init__(self, itemId=None, purchaseIds=None,):
-
 
11255
    self.itemId = itemId
-
 
11256
    self.purchaseIds = purchaseIds
-
 
11257
 
-
 
11258
  def read(self, iprot):
-
 
11259
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
-
 
11260
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
-
 
11261
      return
-
 
11262
    iprot.readStructBegin()
-
 
11263
    while True:
-
 
11264
      (fname, ftype, fid) = iprot.readFieldBegin()
-
 
11265
      if ftype == TType.STOP:
-
 
11266
        break
-
 
11267
      if fid == 1:
-
 
11268
        if ftype == TType.I64:
-
 
11269
          self.itemId = iprot.readI64();
-
 
11270
        else:
-
 
11271
          iprot.skip(ftype)
-
 
11272
      elif fid == 2:
-
 
11273
        if ftype == TType.LIST:
-
 
11274
          self.purchaseIds = []
-
 
11275
          (_etype229, _size226) = iprot.readListBegin()
-
 
11276
          for _i230 in xrange(_size226):
-
 
11277
            _elem231 = iprot.readI64();
-
 
11278
            self.purchaseIds.append(_elem231)
-
 
11279
          iprot.readListEnd()
-
 
11280
        else:
-
 
11281
          iprot.skip(ftype)
-
 
11282
      else:
-
 
11283
        iprot.skip(ftype)
-
 
11284
      iprot.readFieldEnd()
-
 
11285
    iprot.readStructEnd()
-
 
11286
 
-
 
11287
  def write(self, oprot):
-
 
11288
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
-
 
11289
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
-
 
11290
      return
-
 
11291
    oprot.writeStructBegin('getInventoryItemScannedInForPO_args')
-
 
11292
    if self.itemId is not None:
-
 
11293
      oprot.writeFieldBegin('itemId', TType.I64, 1)
-
 
11294
      oprot.writeI64(self.itemId)
-
 
11295
      oprot.writeFieldEnd()
-
 
11296
    if self.purchaseIds is not None:
-
 
11297
      oprot.writeFieldBegin('purchaseIds', TType.LIST, 2)
-
 
11298
      oprot.writeListBegin(TType.I64, len(self.purchaseIds))
-
 
11299
      for iter232 in self.purchaseIds:
-
 
11300
        oprot.writeI64(iter232)
-
 
11301
      oprot.writeListEnd()
-
 
11302
      oprot.writeFieldEnd()
-
 
11303
    oprot.writeFieldStop()
-
 
11304
    oprot.writeStructEnd()
-
 
11305
 
-
 
11306
  def validate(self):
-
 
11307
    return
-
 
11308
 
-
 
11309
 
-
 
11310
  def __repr__(self):
-
 
11311
    L = ['%s=%r' % (key, value)
-
 
11312
      for key, value in self.__dict__.iteritems()]
-
 
11313
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
-
 
11314
 
-
 
11315
  def __eq__(self, other):
-
 
11316
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
 
11317
 
-
 
11318
  def __ne__(self, other):
-
 
11319
    return not (self == other)
-
 
11320
 
-
 
11321
class getInventoryItemScannedInForPO_result:
-
 
11322
  """
-
 
11323
  Attributes:
-
 
11324
   - success
-
 
11325
   - wex
-
 
11326
  """
-
 
11327
 
-
 
11328
  thrift_spec = (
-
 
11329
    (0, TType.LIST, 'success', (TType.STRUCT,(InventoryItem, InventoryItem.thrift_spec)), None, ), # 0
-
 
11330
    (1, TType.STRUCT, 'wex', (WarehouseServiceException, WarehouseServiceException.thrift_spec), None, ), # 1
-
 
11331
  )
-
 
11332
 
-
 
11333
  def __init__(self, success=None, wex=None,):
-
 
11334
    self.success = success
-
 
11335
    self.wex = wex
-
 
11336
 
-
 
11337
  def read(self, iprot):
-
 
11338
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
-
 
11339
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
-
 
11340
      return
-
 
11341
    iprot.readStructBegin()
-
 
11342
    while True:
-
 
11343
      (fname, ftype, fid) = iprot.readFieldBegin()
-
 
11344
      if ftype == TType.STOP:
-
 
11345
        break
-
 
11346
      if fid == 0:
-
 
11347
        if ftype == TType.LIST:
-
 
11348
          self.success = []
-
 
11349
          (_etype236, _size233) = iprot.readListBegin()
-
 
11350
          for _i237 in xrange(_size233):
-
 
11351
            _elem238 = InventoryItem()
-
 
11352
            _elem238.read(iprot)
-
 
11353
            self.success.append(_elem238)
-
 
11354
          iprot.readListEnd()
-
 
11355
        else:
-
 
11356
          iprot.skip(ftype)
-
 
11357
      elif fid == 1:
-
 
11358
        if ftype == TType.STRUCT:
-
 
11359
          self.wex = WarehouseServiceException()
-
 
11360
          self.wex.read(iprot)
-
 
11361
        else:
-
 
11362
          iprot.skip(ftype)
-
 
11363
      else:
-
 
11364
        iprot.skip(ftype)
-
 
11365
      iprot.readFieldEnd()
-
 
11366
    iprot.readStructEnd()
-
 
11367
 
-
 
11368
  def write(self, oprot):
-
 
11369
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
-
 
11370
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
-
 
11371
      return
-
 
11372
    oprot.writeStructBegin('getInventoryItemScannedInForPO_result')
-
 
11373
    if self.success is not None:
-
 
11374
      oprot.writeFieldBegin('success', TType.LIST, 0)
-
 
11375
      oprot.writeListBegin(TType.STRUCT, len(self.success))
-
 
11376
      for iter239 in self.success:
-
 
11377
        iter239.write(oprot)
-
 
11378
      oprot.writeListEnd()
-
 
11379
      oprot.writeFieldEnd()
-
 
11380
    if self.wex is not None:
-
 
11381
      oprot.writeFieldBegin('wex', TType.STRUCT, 1)
-
 
11382
      self.wex.write(oprot)
-
 
11383
      oprot.writeFieldEnd()
-
 
11384
    oprot.writeFieldStop()
-
 
11385
    oprot.writeStructEnd()
-
 
11386
 
-
 
11387
  def validate(self):
-
 
11388
    return
-
 
11389
 
-
 
11390
 
-
 
11391
  def __repr__(self):
-
 
11392
    L = ['%s=%r' % (key, value)
-
 
11393
      for key, value in self.__dict__.iteritems()]
-
 
11394
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
-
 
11395
 
-
 
11396
  def __eq__(self, other):
-
 
11397
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
 
11398
 
-
 
11399
  def __ne__(self, other):
-
 
11400
    return not (self == other)
-
 
11401
 
-
 
11402
class getAmazonTransferredSkuDetails_args:
-
 
11403
  """
-
 
11404
  Attributes:
-
 
11405
   - itemIds
-
 
11406
  """
-
 
11407
 
-
 
11408
  thrift_spec = (
-
 
11409
    None, # 0
-
 
11410
    (1, TType.LIST, 'itemIds', (TType.I64,None), None, ), # 1
-
 
11411
  )
-
 
11412
 
-
 
11413
  def __init__(self, itemIds=None,):
-
 
11414
    self.itemIds = itemIds
-
 
11415
 
-
 
11416
  def read(self, iprot):
-
 
11417
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
-
 
11418
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
-
 
11419
      return
-
 
11420
    iprot.readStructBegin()
-
 
11421
    while True:
-
 
11422
      (fname, ftype, fid) = iprot.readFieldBegin()
-
 
11423
      if ftype == TType.STOP:
-
 
11424
        break
-
 
11425
      if fid == 1:
-
 
11426
        if ftype == TType.LIST:
-
 
11427
          self.itemIds = []
-
 
11428
          (_etype243, _size240) = iprot.readListBegin()
-
 
11429
          for _i244 in xrange(_size240):
-
 
11430
            _elem245 = iprot.readI64();
-
 
11431
            self.itemIds.append(_elem245)
-
 
11432
          iprot.readListEnd()
-
 
11433
        else:
-
 
11434
          iprot.skip(ftype)
-
 
11435
      else:
-
 
11436
        iprot.skip(ftype)
-
 
11437
      iprot.readFieldEnd()
-
 
11438
    iprot.readStructEnd()
-
 
11439
 
-
 
11440
  def write(self, oprot):
-
 
11441
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
-
 
11442
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
-
 
11443
      return
-
 
11444
    oprot.writeStructBegin('getAmazonTransferredSkuDetails_args')
-
 
11445
    if self.itemIds is not None:
-
 
11446
      oprot.writeFieldBegin('itemIds', TType.LIST, 1)
-
 
11447
      oprot.writeListBegin(TType.I64, len(self.itemIds))
-
 
11448
      for iter246 in self.itemIds:
-
 
11449
        oprot.writeI64(iter246)
-
 
11450
      oprot.writeListEnd()
-
 
11451
      oprot.writeFieldEnd()
-
 
11452
    oprot.writeFieldStop()
-
 
11453
    oprot.writeStructEnd()
-
 
11454
 
-
 
11455
  def validate(self):
-
 
11456
    return
-
 
11457
 
-
 
11458
 
-
 
11459
  def __repr__(self):
-
 
11460
    L = ['%s=%r' % (key, value)
-
 
11461
      for key, value in self.__dict__.iteritems()]
-
 
11462
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
-
 
11463
 
-
 
11464
  def __eq__(self, other):
-
 
11465
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
 
11466
 
-
 
11467
  def __ne__(self, other):
-
 
11468
    return not (self == other)
-
 
11469
 
-
 
11470
class getAmazonTransferredSkuDetails_result:
-
 
11471
  """
-
 
11472
  Attributes:
-
 
11473
   - success
-
 
11474
   - wex
-
 
11475
  """
-
 
11476
 
-
 
11477
  thrift_spec = (
-
 
11478
    (0, TType.LIST, 'success', (TType.STRUCT,(AmazonTransferredSkuDetail, AmazonTransferredSkuDetail.thrift_spec)), None, ), # 0
-
 
11479
    (1, TType.STRUCT, 'wex', (WarehouseServiceException, WarehouseServiceException.thrift_spec), None, ), # 1
-
 
11480
  )
-
 
11481
 
-
 
11482
  def __init__(self, success=None, wex=None,):
-
 
11483
    self.success = success
-
 
11484
    self.wex = wex
-
 
11485
 
-
 
11486
  def read(self, iprot):
-
 
11487
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
-
 
11488
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
-
 
11489
      return
-
 
11490
    iprot.readStructBegin()
-
 
11491
    while True:
-
 
11492
      (fname, ftype, fid) = iprot.readFieldBegin()
-
 
11493
      if ftype == TType.STOP:
-
 
11494
        break
-
 
11495
      if fid == 0:
-
 
11496
        if ftype == TType.LIST:
-
 
11497
          self.success = []
-
 
11498
          (_etype250, _size247) = iprot.readListBegin()
-
 
11499
          for _i251 in xrange(_size247):
-
 
11500
            _elem252 = AmazonTransferredSkuDetail()
-
 
11501
            _elem252.read(iprot)
-
 
11502
            self.success.append(_elem252)
-
 
11503
          iprot.readListEnd()
-
 
11504
        else:
-
 
11505
          iprot.skip(ftype)
-
 
11506
      elif fid == 1:
-
 
11507
        if ftype == TType.STRUCT:
-
 
11508
          self.wex = WarehouseServiceException()
-
 
11509
          self.wex.read(iprot)
-
 
11510
        else:
-
 
11511
          iprot.skip(ftype)
-
 
11512
      else:
-
 
11513
        iprot.skip(ftype)
-
 
11514
      iprot.readFieldEnd()
-
 
11515
    iprot.readStructEnd()
-
 
11516
 
-
 
11517
  def write(self, oprot):
-
 
11518
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
-
 
11519
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
-
 
11520
      return
-
 
11521
    oprot.writeStructBegin('getAmazonTransferredSkuDetails_result')
-
 
11522
    if self.success is not None:
-
 
11523
      oprot.writeFieldBegin('success', TType.LIST, 0)
-
 
11524
      oprot.writeListBegin(TType.STRUCT, len(self.success))
-
 
11525
      for iter253 in self.success:
-
 
11526
        iter253.write(oprot)
-
 
11527
      oprot.writeListEnd()
-
 
11528
      oprot.writeFieldEnd()
-
 
11529
    if self.wex is not None:
-
 
11530
      oprot.writeFieldBegin('wex', TType.STRUCT, 1)
-
 
11531
      self.wex.write(oprot)
-
 
11532
      oprot.writeFieldEnd()
-
 
11533
    oprot.writeFieldStop()
-
 
11534
    oprot.writeStructEnd()
-
 
11535
 
-
 
11536
  def validate(self):
-
 
11537
    return
-
 
11538
 
-
 
11539
 
-
 
11540
  def __repr__(self):
-
 
11541
    L = ['%s=%r' % (key, value)
-
 
11542
      for key, value in self.__dict__.iteritems()]
-
 
11543
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
-
 
11544
 
-
 
11545
  def __eq__(self, other):
-
 
11546
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
 
11547
 
-
 
11548
  def __ne__(self, other):
-
 
11549
    return not (self == other)
-
 
11550
 
-
 
11551
class getScansforPurchase_args:
-
 
11552
  """
-
 
11553
  Attributes:
-
 
11554
   - purchaseId
-
 
11555
   - scanType
-
 
11556
  """
-
 
11557
 
-
 
11558
  thrift_spec = (
-
 
11559
    None, # 0
-
 
11560
    (1, TType.I64, 'purchaseId', None, None, ), # 1
-
 
11561
    (2, TType.I32, 'scanType', None, None, ), # 2
-
 
11562
  )
-
 
11563
 
-
 
11564
  def __init__(self, purchaseId=None, scanType=None,):
-
 
11565
    self.purchaseId = purchaseId
-
 
11566
    self.scanType = scanType
-
 
11567
 
-
 
11568
  def read(self, iprot):
-
 
11569
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
-
 
11570
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
-
 
11571
      return
-
 
11572
    iprot.readStructBegin()
-
 
11573
    while True:
-
 
11574
      (fname, ftype, fid) = iprot.readFieldBegin()
-
 
11575
      if ftype == TType.STOP:
-
 
11576
        break
-
 
11577
      if fid == 1:
-
 
11578
        if ftype == TType.I64:
-
 
11579
          self.purchaseId = iprot.readI64();
-
 
11580
        else:
-
 
11581
          iprot.skip(ftype)
-
 
11582
      elif fid == 2:
-
 
11583
        if ftype == TType.I32:
-
 
11584
          self.scanType = iprot.readI32();
-
 
11585
        else:
-
 
11586
          iprot.skip(ftype)
-
 
11587
      else:
-
 
11588
        iprot.skip(ftype)
-
 
11589
      iprot.readFieldEnd()
-
 
11590
    iprot.readStructEnd()
-
 
11591
 
-
 
11592
  def write(self, oprot):
-
 
11593
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
-
 
11594
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
-
 
11595
      return
-
 
11596
    oprot.writeStructBegin('getScansforPurchase_args')
-
 
11597
    if self.purchaseId is not None:
-
 
11598
      oprot.writeFieldBegin('purchaseId', TType.I64, 1)
-
 
11599
      oprot.writeI64(self.purchaseId)
-
 
11600
      oprot.writeFieldEnd()
-
 
11601
    if self.scanType is not None:
-
 
11602
      oprot.writeFieldBegin('scanType', TType.I32, 2)
-
 
11603
      oprot.writeI32(self.scanType)
-
 
11604
      oprot.writeFieldEnd()
-
 
11605
    oprot.writeFieldStop()
-
 
11606
    oprot.writeStructEnd()
-
 
11607
 
-
 
11608
  def validate(self):
-
 
11609
    return
-
 
11610
 
-
 
11611
 
-
 
11612
  def __repr__(self):
-
 
11613
    L = ['%s=%r' % (key, value)
-
 
11614
      for key, value in self.__dict__.iteritems()]
-
 
11615
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
-
 
11616
 
-
 
11617
  def __eq__(self, other):
-
 
11618
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
 
11619
 
-
 
11620
  def __ne__(self, other):
-
 
11621
    return not (self == other)
-
 
11622
 
-
 
11623
class getScansforPurchase_result:
-
 
11624
  """
-
 
11625
  Attributes:
-
 
11626
   - success
-
 
11627
   - wex
-
 
11628
  """
-
 
11629
 
-
 
11630
  thrift_spec = (
-
 
11631
    (0, TType.LIST, 'success', (TType.STRUCT,(Scan, Scan.thrift_spec)), None, ), # 0
-
 
11632
    (1, TType.STRUCT, 'wex', (WarehouseServiceException, WarehouseServiceException.thrift_spec), None, ), # 1
-
 
11633
  )
-
 
11634
 
-
 
11635
  def __init__(self, success=None, wex=None,):
-
 
11636
    self.success = success
-
 
11637
    self.wex = wex
-
 
11638
 
-
 
11639
  def read(self, iprot):
-
 
11640
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
-
 
11641
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
-
 
11642
      return
-
 
11643
    iprot.readStructBegin()
-
 
11644
    while True:
-
 
11645
      (fname, ftype, fid) = iprot.readFieldBegin()
-
 
11646
      if ftype == TType.STOP:
-
 
11647
        break
-
 
11648
      if fid == 0:
-
 
11649
        if ftype == TType.LIST:
-
 
11650
          self.success = []
-
 
11651
          (_etype257, _size254) = iprot.readListBegin()
-
 
11652
          for _i258 in xrange(_size254):
-
 
11653
            _elem259 = Scan()
-
 
11654
            _elem259.read(iprot)
-
 
11655
            self.success.append(_elem259)
-
 
11656
          iprot.readListEnd()
-
 
11657
        else:
-
 
11658
          iprot.skip(ftype)
-
 
11659
      elif fid == 1:
-
 
11660
        if ftype == TType.STRUCT:
-
 
11661
          self.wex = WarehouseServiceException()
-
 
11662
          self.wex.read(iprot)
-
 
11663
        else:
-
 
11664
          iprot.skip(ftype)
-
 
11665
      else:
-
 
11666
        iprot.skip(ftype)
-
 
11667
      iprot.readFieldEnd()
-
 
11668
    iprot.readStructEnd()
-
 
11669
 
-
 
11670
  def write(self, oprot):
-
 
11671
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
-
 
11672
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
-
 
11673
      return
-
 
11674
    oprot.writeStructBegin('getScansforPurchase_result')
-
 
11675
    if self.success is not None:
-
 
11676
      oprot.writeFieldBegin('success', TType.LIST, 0)
-
 
11677
      oprot.writeListBegin(TType.STRUCT, len(self.success))
-
 
11678
      for iter260 in self.success:
-
 
11679
        iter260.write(oprot)
-
 
11680
      oprot.writeListEnd()
-
 
11681
      oprot.writeFieldEnd()
-
 
11682
    if self.wex is not None:
-
 
11683
      oprot.writeFieldBegin('wex', TType.STRUCT, 1)
-
 
11684
      self.wex.write(oprot)
-
 
11685
      oprot.writeFieldEnd()
-
 
11686
    oprot.writeFieldStop()
11056
    oprot.writeStructEnd()
11687
    oprot.writeStructEnd()
11057
 
11688
 
11058
  def validate(self):
11689
  def validate(self):
11059
    return
11690
    return
11060
 
11691