Subversion Repositories SmartDukaan

Rev

Rev 5978 | Rev 6467 | Go to most recent revision | Details | Compare with Previous | Last modification | View Log | RSS feed

Rev Author Line No. Line
5944 mandeep.dh 1
#
2
# Autogenerated by Thrift Compiler (0.7.0)
3
#
4
# DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
5
#
6
 
7
from thrift.Thrift import *
8
import shop2020.thriftpy.generic.GenericService
9
from ttypes import *
10
from thrift.Thrift import TProcessor
11
from thrift.transport import TTransport
12
from thrift.protocol import TBinaryProtocol, TProtocol
13
try:
14
  from thrift.protocol import fastbinary
15
except:
16
  fastbinary = None
17
 
18
 
19
class Iface(shop2020.thriftpy.generic.GenericService.Iface):
20
  def addWarehouse(self, warehouse):
21
    """
22
    Parameters:
23
     - warehouse
24
    """
25
    pass
26
 
27
  def addVendor(self, vendor):
28
    """
29
    add a new vendor
30
 
31
    Parameters:
32
     - vendor
33
    """
34
    pass
35
 
36
  def updateInventoryHistory(self, warehouse_id, timestamp, availability):
37
    """
38
    Stores the incremental warehouse updates of items.
39
 
40
    Parameters:
41
     - warehouse_id
42
     - timestamp
43
     - availability
44
    """
45
    pass
46
 
47
  def updateInventory(self, warehouse_id, timestamp, availability):
48
    """
49
    Stores the final inventory stocks of items.
50
 
51
    Parameters:
52
     - warehouse_id
53
     - timestamp
54
     - availability
55
    """
56
    pass
57
 
58
  def addInventory(self, itemId, warehouseId, quantity):
59
    """
60
    Add the inventory to existing stock.
61
 
62
    Parameters:
63
     - itemId
64
     - warehouseId
65
     - quantity
66
    """
67
    pass
68
 
69
  def retireWarehouse(self, warehouse_id):
70
    """
71
    Parameters:
72
     - warehouse_id
73
    """
74
    pass
75
 
76
  def getItemInventoryByItemId(self, item_id):
77
    """
78
    Parameters:
79
     - item_id
80
    """
81
    pass
82
 
83
  def getItemAvailibilityAtWarehouse(self, warehouse_id, item_id):
84
    """
85
    Parameters:
86
     - warehouse_id
87
     - item_id
88
    """
89
    pass
90
 
5978 rajveer 91
  def getItemAvailabilityAtLocation(self, itemId, sourceId):
5944 mandeep.dh 92
    """
93
    Determines the warehouse that should be used to fulfil an order for the given item.
94
    It first checks all the warehouses which are in the logistics location given by the
95
    warehouse_loc parameter. If none of the warehouses there have any inventory, then the
96
    preferred warehouse for the item is used.
97
 
98
    Returns an ordered list of size 4 with following elements in the given order:
99
    1. Id of the fulfillment warehouse which was finally picked up.
100
    2. Expected delay added by the category manager.
101
    3. Id of the billing warehouse which was finally picked up.
102
 
103
    Parameters:
104
     - itemId
5978 rajveer 105
     - sourceId
5944 mandeep.dh 106
    """
107
    pass
108
 
109
  def getAllWarehouses(self, isActive):
110
    """
111
    Parameters:
112
     - isActive
113
    """
114
    pass
115
 
116
  def getWarehouse(self, warehouse_id):
117
    """
118
    Returns the warehouse with the given id.
119
 
120
    Parameters:
121
     - warehouse_id
122
    """
123
    pass
124
 
125
  def getAllItemsForWarehouse(self, warehouse_id):
126
    """
127
    Parameters:
128
     - warehouse_id
129
    """
130
    pass
131
 
5966 rajveer 132
  def isOrderBillable(self, itemId, warehouseId, sourceId, orderId):
5944 mandeep.dh 133
    """
5966 rajveer 134
    Depending on reservation in the table, verify if we can bill this order or not.
135
 
136
    Parameters:
137
     - itemId
138
     - warehouseId
139
     - sourceId
140
     - orderId
141
    """
142
    pass
143
 
144
  def reserveItemInWarehouse(self, itemId, warehouseId, sourceId, orderId, createdTimestamp, promisedShippingTimestamp, quantity):
145
    """
5944 mandeep.dh 146
    Increases the reservation count for an item in a warehouse. Should always succeed normally.
147
 
148
    Parameters:
149
     - itemId
150
     - warehouseId
5966 rajveer 151
     - sourceId
152
     - orderId
153
     - createdTimestamp
154
     - promisedShippingTimestamp
5944 mandeep.dh 155
     - quantity
156
    """
157
    pass
158
 
5966 rajveer 159
  def reduceReservationCount(self, itemId, warehouseId, sourceId, orderId, quantity):
5944 mandeep.dh 160
    """
161
    Decreases the reservation count for an item in a warehouse. Should always succeed normally.
162
 
163
    Parameters:
164
     - itemId
165
     - warehouseId
5966 rajveer 166
     - sourceId
167
     - orderId
5944 mandeep.dh 168
     - quantity
169
    """
170
    pass
171
 
172
  def getItemPricing(self, itemId, vendorId):
173
    """
174
    Returns the pricing information of an item associated with the vendor of the given warehouse.
175
    Raises an exception if either the item, vendor or the associated pricing information can't be found.
176
 
177
    Parameters:
178
     - itemId
179
     - vendorId
180
    """
181
    pass
182
 
183
  def getAllItemPricing(self, itemId):
184
    """
185
    Returns the list of vendor pricing information of an item.
186
    Raises an exception if item not found corresponding to itemId
187
 
188
    Parameters:
189
     - itemId
190
    """
191
    pass
192
 
193
  def addVendorItemPricing(self, vendorItemPricing):
194
    """
195
    Adds vendor prices corresponding to the item. If pricing already exists then updates the prices.
196
    Raises an exception if either the item or vendor can't be found corresponding to their ids.
197
 
198
    Parameters:
199
     - vendorItemPricing
200
    """
201
    pass
202
 
203
  def getVendor(self, vendorId):
204
    """
205
    Returns a vendor given its id
206
 
207
    Parameters:
208
     - vendorId
209
    """
210
    pass
211
 
212
  def getAllVendors(self, ):
213
    """
214
    Return list of all vendors
215
    """
216
    pass
217
 
218
  def addVendorItemMapping(self, key, vendorItemMapping):
219
    """
220
    Adds VendorItemMapping. Updates VendorItemMapping if exists corresponding to the item key.
221
 
222
    Parameters:
223
     - key
224
     - vendorItemMapping
225
    """
226
    pass
227
 
228
  def getVendorItemMappings(self, itemId):
229
    """
230
    Returns the list of vendor item mapping corresponding to itemId passed as parameter.
231
    Raises an exception if item not found corresponding to itemId
232
 
233
    Parameters:
234
     - itemId
235
    """
236
    pass
237
 
238
  def getPendingOrdersInventory(self, vendorid):
239
    """
240
    Returns a list of inventory stock for items for which there are pending orders for the given vendor.
241
 
242
    Parameters:
243
     - vendorid
244
    """
245
    pass
246
 
247
  def getWarehouses(self, warehouseType, inventoryType, vendorId, billingWarehouseId, shippingWarehouseId):
248
    """
249
    This method returns all warehouses for a given warehosueType, inventoryType, vendor, billingWarehouse and shippingWarehouse.
250
    getWarehouses(WarehouseType.OURS, InventoryType.GOOD, 3, 7, 7) would return ours warehouse with GOOD type inventory for vendor 1 for billing warehouse 7 and shipping warehouse 7
251
    getWarehouses(WarehouseType.OURS, InventoryType.GOOD, 3, 7, 7) would return ours warehouse with GOOD type inventory for vendor 3 for billing warehouse 7 and shipping warehouse 7
252
       getWarehouses(null, null, 3, 7, 7) would return all type warehouses with all type inventory for vendor 3 for billing warehouse 7 and shipping warehouse 7
253
       getWarehouses(null, null, 0, 0, 7) would return all type warehouses with all type inventory for all vendors for all billing warehouses at shipping warehouse 7
254
 
255
    Parameters:
256
     - warehouseType
257
     - inventoryType
258
     - vendorId
259
     - billingWarehouseId
260
     - shippingWarehouseId
261
    """
262
    pass
263
 
264
  def resetAvailability(self, itemKey, vendorId, quantity, warehouseId):
265
    """
266
    Resets availability of an item to the quantity mentioned in a warehouse.
267
 
268
    Parameters:
269
     - itemKey
270
     - vendorId
271
     - quantity
272
     - warehouseId
273
    """
274
    pass
275
 
276
  def resetAvailabilityForWarehouse(self, warehouseId):
277
    """
278
    Resets availability of a warehouse to zero.
279
 
280
    Parameters:
281
     - warehouseId
282
    """
283
    pass
284
 
285
  def getItemKeysToBeProcessed(self, warehouseId):
286
    """
287
    Returns the list of item keys which need to be processed for a given warehouse.
288
    This is currently used by Support application to send item keys whose inventory needs
289
    to be updated from PLB
290
 
291
    Parameters:
292
     - warehouseId
293
    """
294
    pass
295
 
296
  def markMissedInventoryUpdatesAsProcessed(self, itemKey, warehouseId):
297
    """
298
    Marks/Deletes missed inventory updates for a given key and warehouse.
299
    This generally happens when updates from PLB are applied on the currentinventorysnapshot for an item
300
 
301
    Parameters:
302
     - itemKey
303
     - warehouseId
304
    """
305
    pass
306
 
307
  def getIgnoredItemKeys(self, ):
308
    """
309
    Returns all the item key mappings that have been ignored until date. Value of map has the warehouse id
310
    and the timestamp from where alert was raised.
311
    """
312
    pass
313
 
314
  def addBadInventory(self, itemId, warehouseId, quantity):
315
    """
316
    Add the BAD type inventory to existing stock.
317
 
318
    Parameters:
319
     - itemId
320
     - warehouseId
321
     - quantity
322
    """
323
    pass
324
 
325
  def getShippingLocations(self, ):
326
    """
327
    Returns all shipping locations
328
    """
329
    pass
330
 
331
  def getAllVendorItemMappings(self, ):
332
    """
333
    Fetches all the vendor item mappings present.
334
    """
335
    pass
336
 
337
  def getInventorySnapshot(self, warehouseId):
338
    """
339
    Gets items' inventory for a warehouse
340
    If warehouse is passed as zero, items' inventory across all warehouses is sent
341
 
342
    Parameters:
343
     - warehouseId
344
    """
345
    pass
346
 
347
  def clearItemAvailabilityCache(self, ):
348
    """
349
    Clear item availability cache.
350
    """
351
    pass
352
 
353
  def updateVendorString(self, warehouseId, vendorString):
354
    """
355
    Parameters:
356
     - warehouseId
357
     - vendorString
358
    """
359
    pass
360
 
6096 amit.gupta 361
  def clearItemAvailabilityCacheForItem(self, item_id):
362
    """
363
    Parameters:
364
     - item_id
365
    """
366
    pass
5944 mandeep.dh 367
 
6096 amit.gupta 368
 
5944 mandeep.dh 369
class Client(shop2020.thriftpy.generic.GenericService.Client, Iface):
370
  def __init__(self, iprot, oprot=None):
371
    shop2020.thriftpy.generic.GenericService.Client.__init__(self, iprot, oprot)
372
 
373
  def addWarehouse(self, warehouse):
374
    """
375
    Parameters:
376
     - warehouse
377
    """
378
    self.send_addWarehouse(warehouse)
379
    return self.recv_addWarehouse()
380
 
381
  def send_addWarehouse(self, warehouse):
382
    self._oprot.writeMessageBegin('addWarehouse', TMessageType.CALL, self._seqid)
383
    args = addWarehouse_args()
384
    args.warehouse = warehouse
385
    args.write(self._oprot)
386
    self._oprot.writeMessageEnd()
387
    self._oprot.trans.flush()
388
 
389
  def recv_addWarehouse(self, ):
390
    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
391
    if mtype == TMessageType.EXCEPTION:
392
      x = TApplicationException()
393
      x.read(self._iprot)
394
      self._iprot.readMessageEnd()
395
      raise x
396
    result = addWarehouse_result()
397
    result.read(self._iprot)
398
    self._iprot.readMessageEnd()
399
    if result.success is not None:
400
      return result.success
401
    if result.cex is not None:
402
      raise result.cex
403
    raise TApplicationException(TApplicationException.MISSING_RESULT, "addWarehouse failed: unknown result");
404
 
405
  def addVendor(self, vendor):
406
    """
407
    add a new vendor
408
 
409
    Parameters:
410
     - vendor
411
    """
412
    self.send_addVendor(vendor)
413
    return self.recv_addVendor()
414
 
415
  def send_addVendor(self, vendor):
416
    self._oprot.writeMessageBegin('addVendor', TMessageType.CALL, self._seqid)
417
    args = addVendor_args()
418
    args.vendor = vendor
419
    args.write(self._oprot)
420
    self._oprot.writeMessageEnd()
421
    self._oprot.trans.flush()
422
 
423
  def recv_addVendor(self, ):
424
    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
425
    if mtype == TMessageType.EXCEPTION:
426
      x = TApplicationException()
427
      x.read(self._iprot)
428
      self._iprot.readMessageEnd()
429
      raise x
430
    result = addVendor_result()
431
    result.read(self._iprot)
432
    self._iprot.readMessageEnd()
433
    if result.success is not None:
434
      return result.success
435
    if result.cex is not None:
436
      raise result.cex
437
    raise TApplicationException(TApplicationException.MISSING_RESULT, "addVendor failed: unknown result");
438
 
439
  def updateInventoryHistory(self, warehouse_id, timestamp, availability):
440
    """
441
    Stores the incremental warehouse updates of items.
442
 
443
    Parameters:
444
     - warehouse_id
445
     - timestamp
446
     - availability
447
    """
448
    self.send_updateInventoryHistory(warehouse_id, timestamp, availability)
449
    self.recv_updateInventoryHistory()
450
 
451
  def send_updateInventoryHistory(self, warehouse_id, timestamp, availability):
452
    self._oprot.writeMessageBegin('updateInventoryHistory', TMessageType.CALL, self._seqid)
453
    args = updateInventoryHistory_args()
454
    args.warehouse_id = warehouse_id
455
    args.timestamp = timestamp
456
    args.availability = availability
457
    args.write(self._oprot)
458
    self._oprot.writeMessageEnd()
459
    self._oprot.trans.flush()
460
 
461
  def recv_updateInventoryHistory(self, ):
462
    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
463
    if mtype == TMessageType.EXCEPTION:
464
      x = TApplicationException()
465
      x.read(self._iprot)
466
      self._iprot.readMessageEnd()
467
      raise x
468
    result = updateInventoryHistory_result()
469
    result.read(self._iprot)
470
    self._iprot.readMessageEnd()
471
    if result.cex is not None:
472
      raise result.cex
473
    return
474
 
475
  def updateInventory(self, warehouse_id, timestamp, availability):
476
    """
477
    Stores the final inventory stocks of items.
478
 
479
    Parameters:
480
     - warehouse_id
481
     - timestamp
482
     - availability
483
    """
484
    self.send_updateInventory(warehouse_id, timestamp, availability)
485
    self.recv_updateInventory()
486
 
487
  def send_updateInventory(self, warehouse_id, timestamp, availability):
488
    self._oprot.writeMessageBegin('updateInventory', TMessageType.CALL, self._seqid)
489
    args = updateInventory_args()
490
    args.warehouse_id = warehouse_id
491
    args.timestamp = timestamp
492
    args.availability = availability
493
    args.write(self._oprot)
494
    self._oprot.writeMessageEnd()
495
    self._oprot.trans.flush()
496
 
497
  def recv_updateInventory(self, ):
498
    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
499
    if mtype == TMessageType.EXCEPTION:
500
      x = TApplicationException()
501
      x.read(self._iprot)
502
      self._iprot.readMessageEnd()
503
      raise x
504
    result = updateInventory_result()
505
    result.read(self._iprot)
506
    self._iprot.readMessageEnd()
507
    if result.cex is not None:
508
      raise result.cex
509
    return
510
 
511
  def addInventory(self, itemId, warehouseId, quantity):
512
    """
513
    Add the inventory to existing stock.
514
 
515
    Parameters:
516
     - itemId
517
     - warehouseId
518
     - quantity
519
    """
520
    self.send_addInventory(itemId, warehouseId, quantity)
521
    self.recv_addInventory()
522
 
523
  def send_addInventory(self, itemId, warehouseId, quantity):
524
    self._oprot.writeMessageBegin('addInventory', TMessageType.CALL, self._seqid)
525
    args = addInventory_args()
526
    args.itemId = itemId
527
    args.warehouseId = warehouseId
528
    args.quantity = quantity
529
    args.write(self._oprot)
530
    self._oprot.writeMessageEnd()
531
    self._oprot.trans.flush()
532
 
533
  def recv_addInventory(self, ):
534
    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
535
    if mtype == TMessageType.EXCEPTION:
536
      x = TApplicationException()
537
      x.read(self._iprot)
538
      self._iprot.readMessageEnd()
539
      raise x
540
    result = addInventory_result()
541
    result.read(self._iprot)
542
    self._iprot.readMessageEnd()
543
    if result.cex is not None:
544
      raise result.cex
545
    return
546
 
547
  def retireWarehouse(self, warehouse_id):
548
    """
549
    Parameters:
550
     - warehouse_id
551
    """
552
    self.send_retireWarehouse(warehouse_id)
553
    self.recv_retireWarehouse()
554
 
555
  def send_retireWarehouse(self, warehouse_id):
556
    self._oprot.writeMessageBegin('retireWarehouse', TMessageType.CALL, self._seqid)
557
    args = retireWarehouse_args()
558
    args.warehouse_id = warehouse_id
559
    args.write(self._oprot)
560
    self._oprot.writeMessageEnd()
561
    self._oprot.trans.flush()
562
 
563
  def recv_retireWarehouse(self, ):
564
    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
565
    if mtype == TMessageType.EXCEPTION:
566
      x = TApplicationException()
567
      x.read(self._iprot)
568
      self._iprot.readMessageEnd()
569
      raise x
570
    result = retireWarehouse_result()
571
    result.read(self._iprot)
572
    self._iprot.readMessageEnd()
573
    if result.cex is not None:
574
      raise result.cex
575
    return
576
 
577
  def getItemInventoryByItemId(self, item_id):
578
    """
579
    Parameters:
580
     - item_id
581
    """
582
    self.send_getItemInventoryByItemId(item_id)
583
    return self.recv_getItemInventoryByItemId()
584
 
585
  def send_getItemInventoryByItemId(self, item_id):
586
    self._oprot.writeMessageBegin('getItemInventoryByItemId', TMessageType.CALL, self._seqid)
587
    args = getItemInventoryByItemId_args()
588
    args.item_id = item_id
589
    args.write(self._oprot)
590
    self._oprot.writeMessageEnd()
591
    self._oprot.trans.flush()
592
 
593
  def recv_getItemInventoryByItemId(self, ):
594
    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
595
    if mtype == TMessageType.EXCEPTION:
596
      x = TApplicationException()
597
      x.read(self._iprot)
598
      self._iprot.readMessageEnd()
599
      raise x
600
    result = getItemInventoryByItemId_result()
601
    result.read(self._iprot)
602
    self._iprot.readMessageEnd()
603
    if result.success is not None:
604
      return result.success
605
    if result.cex is not None:
606
      raise result.cex
607
    raise TApplicationException(TApplicationException.MISSING_RESULT, "getItemInventoryByItemId failed: unknown result");
608
 
609
  def getItemAvailibilityAtWarehouse(self, warehouse_id, item_id):
610
    """
611
    Parameters:
612
     - warehouse_id
613
     - item_id
614
    """
615
    self.send_getItemAvailibilityAtWarehouse(warehouse_id, item_id)
616
    return self.recv_getItemAvailibilityAtWarehouse()
617
 
618
  def send_getItemAvailibilityAtWarehouse(self, warehouse_id, item_id):
619
    self._oprot.writeMessageBegin('getItemAvailibilityAtWarehouse', TMessageType.CALL, self._seqid)
620
    args = getItemAvailibilityAtWarehouse_args()
621
    args.warehouse_id = warehouse_id
622
    args.item_id = item_id
623
    args.write(self._oprot)
624
    self._oprot.writeMessageEnd()
625
    self._oprot.trans.flush()
626
 
627
  def recv_getItemAvailibilityAtWarehouse(self, ):
628
    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
629
    if mtype == TMessageType.EXCEPTION:
630
      x = TApplicationException()
631
      x.read(self._iprot)
632
      self._iprot.readMessageEnd()
633
      raise x
634
    result = getItemAvailibilityAtWarehouse_result()
635
    result.read(self._iprot)
636
    self._iprot.readMessageEnd()
637
    if result.success is not None:
638
      return result.success
639
    if result.cex is not None:
640
      raise result.cex
641
    raise TApplicationException(TApplicationException.MISSING_RESULT, "getItemAvailibilityAtWarehouse failed: unknown result");
642
 
5978 rajveer 643
  def getItemAvailabilityAtLocation(self, itemId, sourceId):
5944 mandeep.dh 644
    """
645
    Determines the warehouse that should be used to fulfil an order for the given item.
646
    It first checks all the warehouses which are in the logistics location given by the
647
    warehouse_loc parameter. If none of the warehouses there have any inventory, then the
648
    preferred warehouse for the item is used.
649
 
650
    Returns an ordered list of size 4 with following elements in the given order:
651
    1. Id of the fulfillment warehouse which was finally picked up.
652
    2. Expected delay added by the category manager.
653
    3. Id of the billing warehouse which was finally picked up.
654
 
655
    Parameters:
656
     - itemId
5978 rajveer 657
     - sourceId
5944 mandeep.dh 658
    """
5978 rajveer 659
    self.send_getItemAvailabilityAtLocation(itemId, sourceId)
5944 mandeep.dh 660
    return self.recv_getItemAvailabilityAtLocation()
661
 
5978 rajveer 662
  def send_getItemAvailabilityAtLocation(self, itemId, sourceId):
5944 mandeep.dh 663
    self._oprot.writeMessageBegin('getItemAvailabilityAtLocation', TMessageType.CALL, self._seqid)
664
    args = getItemAvailabilityAtLocation_args()
665
    args.itemId = itemId
5978 rajveer 666
    args.sourceId = sourceId
5944 mandeep.dh 667
    args.write(self._oprot)
668
    self._oprot.writeMessageEnd()
669
    self._oprot.trans.flush()
670
 
671
  def recv_getItemAvailabilityAtLocation(self, ):
672
    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
673
    if mtype == TMessageType.EXCEPTION:
674
      x = TApplicationException()
675
      x.read(self._iprot)
676
      self._iprot.readMessageEnd()
677
      raise x
678
    result = getItemAvailabilityAtLocation_result()
679
    result.read(self._iprot)
680
    self._iprot.readMessageEnd()
681
    if result.success is not None:
682
      return result.success
683
    if result.isex is not None:
684
      raise result.isex
685
    raise TApplicationException(TApplicationException.MISSING_RESULT, "getItemAvailabilityAtLocation failed: unknown result");
686
 
687
  def getAllWarehouses(self, isActive):
688
    """
689
    Parameters:
690
     - isActive
691
    """
692
    self.send_getAllWarehouses(isActive)
693
    return self.recv_getAllWarehouses()
694
 
695
  def send_getAllWarehouses(self, isActive):
696
    self._oprot.writeMessageBegin('getAllWarehouses', TMessageType.CALL, self._seqid)
697
    args = getAllWarehouses_args()
698
    args.isActive = isActive
699
    args.write(self._oprot)
700
    self._oprot.writeMessageEnd()
701
    self._oprot.trans.flush()
702
 
703
  def recv_getAllWarehouses(self, ):
704
    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
705
    if mtype == TMessageType.EXCEPTION:
706
      x = TApplicationException()
707
      x.read(self._iprot)
708
      self._iprot.readMessageEnd()
709
      raise x
710
    result = getAllWarehouses_result()
711
    result.read(self._iprot)
712
    self._iprot.readMessageEnd()
713
    if result.success is not None:
714
      return result.success
715
    if result.cex is not None:
716
      raise result.cex
717
    raise TApplicationException(TApplicationException.MISSING_RESULT, "getAllWarehouses failed: unknown result");
718
 
719
  def getWarehouse(self, warehouse_id):
720
    """
721
    Returns the warehouse with the given id.
722
 
723
    Parameters:
724
     - warehouse_id
725
    """
726
    self.send_getWarehouse(warehouse_id)
727
    return self.recv_getWarehouse()
728
 
729
  def send_getWarehouse(self, warehouse_id):
730
    self._oprot.writeMessageBegin('getWarehouse', TMessageType.CALL, self._seqid)
731
    args = getWarehouse_args()
732
    args.warehouse_id = warehouse_id
733
    args.write(self._oprot)
734
    self._oprot.writeMessageEnd()
735
    self._oprot.trans.flush()
736
 
737
  def recv_getWarehouse(self, ):
738
    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
739
    if mtype == TMessageType.EXCEPTION:
740
      x = TApplicationException()
741
      x.read(self._iprot)
742
      self._iprot.readMessageEnd()
743
      raise x
744
    result = getWarehouse_result()
745
    result.read(self._iprot)
746
    self._iprot.readMessageEnd()
747
    if result.success is not None:
748
      return result.success
749
    if result.cex is not None:
750
      raise result.cex
751
    raise TApplicationException(TApplicationException.MISSING_RESULT, "getWarehouse failed: unknown result");
752
 
753
  def getAllItemsForWarehouse(self, warehouse_id):
754
    """
755
    Parameters:
756
     - warehouse_id
757
    """
758
    self.send_getAllItemsForWarehouse(warehouse_id)
759
    return self.recv_getAllItemsForWarehouse()
760
 
761
  def send_getAllItemsForWarehouse(self, warehouse_id):
762
    self._oprot.writeMessageBegin('getAllItemsForWarehouse', TMessageType.CALL, self._seqid)
763
    args = getAllItemsForWarehouse_args()
764
    args.warehouse_id = warehouse_id
765
    args.write(self._oprot)
766
    self._oprot.writeMessageEnd()
767
    self._oprot.trans.flush()
768
 
769
  def recv_getAllItemsForWarehouse(self, ):
770
    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
771
    if mtype == TMessageType.EXCEPTION:
772
      x = TApplicationException()
773
      x.read(self._iprot)
774
      self._iprot.readMessageEnd()
775
      raise x
776
    result = getAllItemsForWarehouse_result()
777
    result.read(self._iprot)
778
    self._iprot.readMessageEnd()
779
    if result.success is not None:
780
      return result.success
781
    if result.cex is not None:
782
      raise result.cex
783
    raise TApplicationException(TApplicationException.MISSING_RESULT, "getAllItemsForWarehouse failed: unknown result");
784
 
5966 rajveer 785
  def isOrderBillable(self, itemId, warehouseId, sourceId, orderId):
5944 mandeep.dh 786
    """
5978 rajveer 787
    Depending on reservation in the table, verify if we can bill this order or not.
5966 rajveer 788
 
789
    Parameters:
790
     - itemId
791
     - warehouseId
792
     - sourceId
793
     - orderId
794
    """
795
    self.send_isOrderBillable(itemId, warehouseId, sourceId, orderId)
796
    return self.recv_isOrderBillable()
797
 
798
  def send_isOrderBillable(self, itemId, warehouseId, sourceId, orderId):
799
    self._oprot.writeMessageBegin('isOrderBillable', TMessageType.CALL, self._seqid)
800
    args = isOrderBillable_args()
801
    args.itemId = itemId
802
    args.warehouseId = warehouseId
803
    args.sourceId = sourceId
804
    args.orderId = orderId
805
    args.write(self._oprot)
806
    self._oprot.writeMessageEnd()
807
    self._oprot.trans.flush()
808
 
809
  def recv_isOrderBillable(self, ):
810
    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
811
    if mtype == TMessageType.EXCEPTION:
812
      x = TApplicationException()
813
      x.read(self._iprot)
814
      self._iprot.readMessageEnd()
815
      raise x
816
    result = isOrderBillable_result()
817
    result.read(self._iprot)
818
    self._iprot.readMessageEnd()
819
    if result.success is not None:
820
      return result.success
821
    raise TApplicationException(TApplicationException.MISSING_RESULT, "isOrderBillable failed: unknown result");
822
 
823
  def reserveItemInWarehouse(self, itemId, warehouseId, sourceId, orderId, createdTimestamp, promisedShippingTimestamp, quantity):
824
    """
5944 mandeep.dh 825
    Increases the reservation count for an item in a warehouse. Should always succeed normally.
826
 
827
    Parameters:
828
     - itemId
829
     - warehouseId
5966 rajveer 830
     - sourceId
831
     - orderId
832
     - createdTimestamp
833
     - promisedShippingTimestamp
5944 mandeep.dh 834
     - quantity
835
    """
5966 rajveer 836
    self.send_reserveItemInWarehouse(itemId, warehouseId, sourceId, orderId, createdTimestamp, promisedShippingTimestamp, quantity)
5944 mandeep.dh 837
    return self.recv_reserveItemInWarehouse()
838
 
5966 rajveer 839
  def send_reserveItemInWarehouse(self, itemId, warehouseId, sourceId, orderId, createdTimestamp, promisedShippingTimestamp, quantity):
5944 mandeep.dh 840
    self._oprot.writeMessageBegin('reserveItemInWarehouse', TMessageType.CALL, self._seqid)
841
    args = reserveItemInWarehouse_args()
842
    args.itemId = itemId
843
    args.warehouseId = warehouseId
5966 rajveer 844
    args.sourceId = sourceId
845
    args.orderId = orderId
846
    args.createdTimestamp = createdTimestamp
847
    args.promisedShippingTimestamp = promisedShippingTimestamp
5944 mandeep.dh 848
    args.quantity = quantity
849
    args.write(self._oprot)
850
    self._oprot.writeMessageEnd()
851
    self._oprot.trans.flush()
852
 
853
  def recv_reserveItemInWarehouse(self, ):
854
    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
855
    if mtype == TMessageType.EXCEPTION:
856
      x = TApplicationException()
857
      x.read(self._iprot)
858
      self._iprot.readMessageEnd()
859
      raise x
860
    result = reserveItemInWarehouse_result()
861
    result.read(self._iprot)
862
    self._iprot.readMessageEnd()
863
    if result.success is not None:
864
      return result.success
865
    if result.cex is not None:
866
      raise result.cex
867
    raise TApplicationException(TApplicationException.MISSING_RESULT, "reserveItemInWarehouse failed: unknown result");
868
 
5966 rajveer 869
  def reduceReservationCount(self, itemId, warehouseId, sourceId, orderId, quantity):
5944 mandeep.dh 870
    """
871
    Decreases the reservation count for an item in a warehouse. Should always succeed normally.
872
 
873
    Parameters:
874
     - itemId
875
     - warehouseId
5966 rajveer 876
     - sourceId
877
     - orderId
5944 mandeep.dh 878
     - quantity
879
    """
5966 rajveer 880
    self.send_reduceReservationCount(itemId, warehouseId, sourceId, orderId, quantity)
5944 mandeep.dh 881
    return self.recv_reduceReservationCount()
882
 
5966 rajveer 883
  def send_reduceReservationCount(self, itemId, warehouseId, sourceId, orderId, quantity):
5944 mandeep.dh 884
    self._oprot.writeMessageBegin('reduceReservationCount', TMessageType.CALL, self._seqid)
885
    args = reduceReservationCount_args()
886
    args.itemId = itemId
887
    args.warehouseId = warehouseId
5966 rajveer 888
    args.sourceId = sourceId
889
    args.orderId = orderId
5944 mandeep.dh 890
    args.quantity = quantity
891
    args.write(self._oprot)
892
    self._oprot.writeMessageEnd()
893
    self._oprot.trans.flush()
894
 
895
  def recv_reduceReservationCount(self, ):
896
    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
897
    if mtype == TMessageType.EXCEPTION:
898
      x = TApplicationException()
899
      x.read(self._iprot)
900
      self._iprot.readMessageEnd()
901
      raise x
902
    result = reduceReservationCount_result()
903
    result.read(self._iprot)
904
    self._iprot.readMessageEnd()
905
    if result.success is not None:
906
      return result.success
907
    if result.cex is not None:
908
      raise result.cex
909
    raise TApplicationException(TApplicationException.MISSING_RESULT, "reduceReservationCount failed: unknown result");
910
 
911
  def getItemPricing(self, itemId, vendorId):
912
    """
913
    Returns the pricing information of an item associated with the vendor of the given warehouse.
914
    Raises an exception if either the item, vendor or the associated pricing information can't be found.
915
 
916
    Parameters:
917
     - itemId
918
     - vendorId
919
    """
920
    self.send_getItemPricing(itemId, vendorId)
921
    return self.recv_getItemPricing()
922
 
923
  def send_getItemPricing(self, itemId, vendorId):
924
    self._oprot.writeMessageBegin('getItemPricing', TMessageType.CALL, self._seqid)
925
    args = getItemPricing_args()
926
    args.itemId = itemId
927
    args.vendorId = vendorId
928
    args.write(self._oprot)
929
    self._oprot.writeMessageEnd()
930
    self._oprot.trans.flush()
931
 
932
  def recv_getItemPricing(self, ):
933
    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
934
    if mtype == TMessageType.EXCEPTION:
935
      x = TApplicationException()
936
      x.read(self._iprot)
937
      self._iprot.readMessageEnd()
938
      raise x
939
    result = getItemPricing_result()
940
    result.read(self._iprot)
941
    self._iprot.readMessageEnd()
942
    if result.success is not None:
943
      return result.success
944
    if result.cex is not None:
945
      raise result.cex
946
    raise TApplicationException(TApplicationException.MISSING_RESULT, "getItemPricing failed: unknown result");
947
 
948
  def getAllItemPricing(self, itemId):
949
    """
950
    Returns the list of vendor pricing information of an item.
951
    Raises an exception if item not found corresponding to itemId
952
 
953
    Parameters:
954
     - itemId
955
    """
956
    self.send_getAllItemPricing(itemId)
957
    return self.recv_getAllItemPricing()
958
 
959
  def send_getAllItemPricing(self, itemId):
960
    self._oprot.writeMessageBegin('getAllItemPricing', TMessageType.CALL, self._seqid)
961
    args = getAllItemPricing_args()
962
    args.itemId = itemId
963
    args.write(self._oprot)
964
    self._oprot.writeMessageEnd()
965
    self._oprot.trans.flush()
966
 
967
  def recv_getAllItemPricing(self, ):
968
    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
969
    if mtype == TMessageType.EXCEPTION:
970
      x = TApplicationException()
971
      x.read(self._iprot)
972
      self._iprot.readMessageEnd()
973
      raise x
974
    result = getAllItemPricing_result()
975
    result.read(self._iprot)
976
    self._iprot.readMessageEnd()
977
    if result.success is not None:
978
      return result.success
979
    if result.cex is not None:
980
      raise result.cex
981
    raise TApplicationException(TApplicationException.MISSING_RESULT, "getAllItemPricing failed: unknown result");
982
 
983
  def addVendorItemPricing(self, vendorItemPricing):
984
    """
985
    Adds vendor prices corresponding to the item. If pricing already exists then updates the prices.
986
    Raises an exception if either the item or vendor can't be found corresponding to their ids.
987
 
988
    Parameters:
989
     - vendorItemPricing
990
    """
991
    self.send_addVendorItemPricing(vendorItemPricing)
992
    self.recv_addVendorItemPricing()
993
 
994
  def send_addVendorItemPricing(self, vendorItemPricing):
995
    self._oprot.writeMessageBegin('addVendorItemPricing', TMessageType.CALL, self._seqid)
996
    args = addVendorItemPricing_args()
997
    args.vendorItemPricing = vendorItemPricing
998
    args.write(self._oprot)
999
    self._oprot.writeMessageEnd()
1000
    self._oprot.trans.flush()
1001
 
1002
  def recv_addVendorItemPricing(self, ):
1003
    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
1004
    if mtype == TMessageType.EXCEPTION:
1005
      x = TApplicationException()
1006
      x.read(self._iprot)
1007
      self._iprot.readMessageEnd()
1008
      raise x
1009
    result = addVendorItemPricing_result()
1010
    result.read(self._iprot)
1011
    self._iprot.readMessageEnd()
1012
    if result.cex is not None:
1013
      raise result.cex
1014
    return
1015
 
1016
  def getVendor(self, vendorId):
1017
    """
1018
    Returns a vendor given its id
1019
 
1020
    Parameters:
1021
     - vendorId
1022
    """
1023
    self.send_getVendor(vendorId)
1024
    return self.recv_getVendor()
1025
 
1026
  def send_getVendor(self, vendorId):
1027
    self._oprot.writeMessageBegin('getVendor', TMessageType.CALL, self._seqid)
1028
    args = getVendor_args()
1029
    args.vendorId = vendorId
1030
    args.write(self._oprot)
1031
    self._oprot.writeMessageEnd()
1032
    self._oprot.trans.flush()
1033
 
1034
  def recv_getVendor(self, ):
1035
    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
1036
    if mtype == TMessageType.EXCEPTION:
1037
      x = TApplicationException()
1038
      x.read(self._iprot)
1039
      self._iprot.readMessageEnd()
1040
      raise x
1041
    result = getVendor_result()
1042
    result.read(self._iprot)
1043
    self._iprot.readMessageEnd()
1044
    if result.success is not None:
1045
      return result.success
1046
    raise TApplicationException(TApplicationException.MISSING_RESULT, "getVendor failed: unknown result");
1047
 
1048
  def getAllVendors(self, ):
1049
    """
1050
    Return list of all vendors
1051
    """
1052
    self.send_getAllVendors()
1053
    return self.recv_getAllVendors()
1054
 
1055
  def send_getAllVendors(self, ):
1056
    self._oprot.writeMessageBegin('getAllVendors', TMessageType.CALL, self._seqid)
1057
    args = getAllVendors_args()
1058
    args.write(self._oprot)
1059
    self._oprot.writeMessageEnd()
1060
    self._oprot.trans.flush()
1061
 
1062
  def recv_getAllVendors(self, ):
1063
    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
1064
    if mtype == TMessageType.EXCEPTION:
1065
      x = TApplicationException()
1066
      x.read(self._iprot)
1067
      self._iprot.readMessageEnd()
1068
      raise x
1069
    result = getAllVendors_result()
1070
    result.read(self._iprot)
1071
    self._iprot.readMessageEnd()
1072
    if result.success is not None:
1073
      return result.success
1074
    raise TApplicationException(TApplicationException.MISSING_RESULT, "getAllVendors failed: unknown result");
1075
 
1076
  def addVendorItemMapping(self, key, vendorItemMapping):
1077
    """
1078
    Adds VendorItemMapping. Updates VendorItemMapping if exists corresponding to the item key.
1079
 
1080
    Parameters:
1081
     - key
1082
     - vendorItemMapping
1083
    """
1084
    self.send_addVendorItemMapping(key, vendorItemMapping)
1085
    self.recv_addVendorItemMapping()
1086
 
1087
  def send_addVendorItemMapping(self, key, vendorItemMapping):
1088
    self._oprot.writeMessageBegin('addVendorItemMapping', TMessageType.CALL, self._seqid)
1089
    args = addVendorItemMapping_args()
1090
    args.key = key
1091
    args.vendorItemMapping = vendorItemMapping
1092
    args.write(self._oprot)
1093
    self._oprot.writeMessageEnd()
1094
    self._oprot.trans.flush()
1095
 
1096
  def recv_addVendorItemMapping(self, ):
1097
    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
1098
    if mtype == TMessageType.EXCEPTION:
1099
      x = TApplicationException()
1100
      x.read(self._iprot)
1101
      self._iprot.readMessageEnd()
1102
      raise x
1103
    result = addVendorItemMapping_result()
1104
    result.read(self._iprot)
1105
    self._iprot.readMessageEnd()
1106
    if result.cex is not None:
1107
      raise result.cex
1108
    return
1109
 
1110
  def getVendorItemMappings(self, itemId):
1111
    """
1112
    Returns the list of vendor item mapping corresponding to itemId passed as parameter.
1113
    Raises an exception if item not found corresponding to itemId
1114
 
1115
    Parameters:
1116
     - itemId
1117
    """
1118
    self.send_getVendorItemMappings(itemId)
1119
    return self.recv_getVendorItemMappings()
1120
 
1121
  def send_getVendorItemMappings(self, itemId):
1122
    self._oprot.writeMessageBegin('getVendorItemMappings', TMessageType.CALL, self._seqid)
1123
    args = getVendorItemMappings_args()
1124
    args.itemId = itemId
1125
    args.write(self._oprot)
1126
    self._oprot.writeMessageEnd()
1127
    self._oprot.trans.flush()
1128
 
1129
  def recv_getVendorItemMappings(self, ):
1130
    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
1131
    if mtype == TMessageType.EXCEPTION:
1132
      x = TApplicationException()
1133
      x.read(self._iprot)
1134
      self._iprot.readMessageEnd()
1135
      raise x
1136
    result = getVendorItemMappings_result()
1137
    result.read(self._iprot)
1138
    self._iprot.readMessageEnd()
1139
    if result.success is not None:
1140
      return result.success
1141
    if result.cex is not None:
1142
      raise result.cex
1143
    raise TApplicationException(TApplicationException.MISSING_RESULT, "getVendorItemMappings failed: unknown result");
1144
 
1145
  def getPendingOrdersInventory(self, vendorid):
1146
    """
1147
    Returns a list of inventory stock for items for which there are pending orders for the given vendor.
1148
 
1149
    Parameters:
1150
     - vendorid
1151
    """
1152
    self.send_getPendingOrdersInventory(vendorid)
1153
    return self.recv_getPendingOrdersInventory()
1154
 
1155
  def send_getPendingOrdersInventory(self, vendorid):
1156
    self._oprot.writeMessageBegin('getPendingOrdersInventory', TMessageType.CALL, self._seqid)
1157
    args = getPendingOrdersInventory_args()
1158
    args.vendorid = vendorid
1159
    args.write(self._oprot)
1160
    self._oprot.writeMessageEnd()
1161
    self._oprot.trans.flush()
1162
 
1163
  def recv_getPendingOrdersInventory(self, ):
1164
    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
1165
    if mtype == TMessageType.EXCEPTION:
1166
      x = TApplicationException()
1167
      x.read(self._iprot)
1168
      self._iprot.readMessageEnd()
1169
      raise x
1170
    result = getPendingOrdersInventory_result()
1171
    result.read(self._iprot)
1172
    self._iprot.readMessageEnd()
1173
    if result.success is not None:
1174
      return result.success
1175
    raise TApplicationException(TApplicationException.MISSING_RESULT, "getPendingOrdersInventory failed: unknown result");
1176
 
1177
  def getWarehouses(self, warehouseType, inventoryType, vendorId, billingWarehouseId, shippingWarehouseId):
1178
    """
1179
    This method returns all warehouses for a given warehosueType, inventoryType, vendor, billingWarehouse and shippingWarehouse.
1180
    getWarehouses(WarehouseType.OURS, InventoryType.GOOD, 3, 7, 7) would return ours warehouse with GOOD type inventory for vendor 1 for billing warehouse 7 and shipping warehouse 7
1181
    getWarehouses(WarehouseType.OURS, InventoryType.GOOD, 3, 7, 7) would return ours warehouse with GOOD type inventory for vendor 3 for billing warehouse 7 and shipping warehouse 7
1182
       getWarehouses(null, null, 3, 7, 7) would return all type warehouses with all type inventory for vendor 3 for billing warehouse 7 and shipping warehouse 7
1183
       getWarehouses(null, null, 0, 0, 7) would return all type warehouses with all type inventory for all vendors for all billing warehouses at shipping warehouse 7
1184
 
1185
    Parameters:
1186
     - warehouseType
1187
     - inventoryType
1188
     - vendorId
1189
     - billingWarehouseId
1190
     - shippingWarehouseId
1191
    """
1192
    self.send_getWarehouses(warehouseType, inventoryType, vendorId, billingWarehouseId, shippingWarehouseId)
1193
    return self.recv_getWarehouses()
1194
 
1195
  def send_getWarehouses(self, warehouseType, inventoryType, vendorId, billingWarehouseId, shippingWarehouseId):
1196
    self._oprot.writeMessageBegin('getWarehouses', TMessageType.CALL, self._seqid)
1197
    args = getWarehouses_args()
1198
    args.warehouseType = warehouseType
1199
    args.inventoryType = inventoryType
1200
    args.vendorId = vendorId
1201
    args.billingWarehouseId = billingWarehouseId
1202
    args.shippingWarehouseId = shippingWarehouseId
1203
    args.write(self._oprot)
1204
    self._oprot.writeMessageEnd()
1205
    self._oprot.trans.flush()
1206
 
1207
  def recv_getWarehouses(self, ):
1208
    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
1209
    if mtype == TMessageType.EXCEPTION:
1210
      x = TApplicationException()
1211
      x.read(self._iprot)
1212
      self._iprot.readMessageEnd()
1213
      raise x
1214
    result = getWarehouses_result()
1215
    result.read(self._iprot)
1216
    self._iprot.readMessageEnd()
1217
    if result.success is not None:
1218
      return result.success
1219
    raise TApplicationException(TApplicationException.MISSING_RESULT, "getWarehouses failed: unknown result");
1220
 
1221
  def resetAvailability(self, itemKey, vendorId, quantity, warehouseId):
1222
    """
1223
    Resets availability of an item to the quantity mentioned in a warehouse.
1224
 
1225
    Parameters:
1226
     - itemKey
1227
     - vendorId
1228
     - quantity
1229
     - warehouseId
1230
    """
1231
    self.send_resetAvailability(itemKey, vendorId, quantity, warehouseId)
1232
    self.recv_resetAvailability()
1233
 
1234
  def send_resetAvailability(self, itemKey, vendorId, quantity, warehouseId):
1235
    self._oprot.writeMessageBegin('resetAvailability', TMessageType.CALL, self._seqid)
1236
    args = resetAvailability_args()
1237
    args.itemKey = itemKey
1238
    args.vendorId = vendorId
1239
    args.quantity = quantity
1240
    args.warehouseId = warehouseId
1241
    args.write(self._oprot)
1242
    self._oprot.writeMessageEnd()
1243
    self._oprot.trans.flush()
1244
 
1245
  def recv_resetAvailability(self, ):
1246
    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
1247
    if mtype == TMessageType.EXCEPTION:
1248
      x = TApplicationException()
1249
      x.read(self._iprot)
1250
      self._iprot.readMessageEnd()
1251
      raise x
1252
    result = resetAvailability_result()
1253
    result.read(self._iprot)
1254
    self._iprot.readMessageEnd()
1255
    if result.cex is not None:
1256
      raise result.cex
1257
    return
1258
 
1259
  def resetAvailabilityForWarehouse(self, warehouseId):
1260
    """
1261
    Resets availability of a warehouse to zero.
1262
 
1263
    Parameters:
1264
     - warehouseId
1265
    """
1266
    self.send_resetAvailabilityForWarehouse(warehouseId)
1267
    self.recv_resetAvailabilityForWarehouse()
1268
 
1269
  def send_resetAvailabilityForWarehouse(self, warehouseId):
1270
    self._oprot.writeMessageBegin('resetAvailabilityForWarehouse', TMessageType.CALL, self._seqid)
1271
    args = resetAvailabilityForWarehouse_args()
1272
    args.warehouseId = warehouseId
1273
    args.write(self._oprot)
1274
    self._oprot.writeMessageEnd()
1275
    self._oprot.trans.flush()
1276
 
1277
  def recv_resetAvailabilityForWarehouse(self, ):
1278
    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
1279
    if mtype == TMessageType.EXCEPTION:
1280
      x = TApplicationException()
1281
      x.read(self._iprot)
1282
      self._iprot.readMessageEnd()
1283
      raise x
1284
    result = resetAvailabilityForWarehouse_result()
1285
    result.read(self._iprot)
1286
    self._iprot.readMessageEnd()
1287
    if result.cex is not None:
1288
      raise result.cex
1289
    return
1290
 
1291
  def getItemKeysToBeProcessed(self, warehouseId):
1292
    """
1293
    Returns the list of item keys which need to be processed for a given warehouse.
1294
    This is currently used by Support application to send item keys whose inventory needs
1295
    to be updated from PLB
1296
 
1297
    Parameters:
1298
     - warehouseId
1299
    """
1300
    self.send_getItemKeysToBeProcessed(warehouseId)
1301
    return self.recv_getItemKeysToBeProcessed()
1302
 
1303
  def send_getItemKeysToBeProcessed(self, warehouseId):
1304
    self._oprot.writeMessageBegin('getItemKeysToBeProcessed', TMessageType.CALL, self._seqid)
1305
    args = getItemKeysToBeProcessed_args()
1306
    args.warehouseId = warehouseId
1307
    args.write(self._oprot)
1308
    self._oprot.writeMessageEnd()
1309
    self._oprot.trans.flush()
1310
 
1311
  def recv_getItemKeysToBeProcessed(self, ):
1312
    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
1313
    if mtype == TMessageType.EXCEPTION:
1314
      x = TApplicationException()
1315
      x.read(self._iprot)
1316
      self._iprot.readMessageEnd()
1317
      raise x
1318
    result = getItemKeysToBeProcessed_result()
1319
    result.read(self._iprot)
1320
    self._iprot.readMessageEnd()
1321
    if result.success is not None:
1322
      return result.success
1323
    raise TApplicationException(TApplicationException.MISSING_RESULT, "getItemKeysToBeProcessed failed: unknown result");
1324
 
1325
  def markMissedInventoryUpdatesAsProcessed(self, itemKey, warehouseId):
1326
    """
1327
    Marks/Deletes missed inventory updates for a given key and warehouse.
1328
    This generally happens when updates from PLB are applied on the currentinventorysnapshot for an item
1329
 
1330
    Parameters:
1331
     - itemKey
1332
     - warehouseId
1333
    """
1334
    self.send_markMissedInventoryUpdatesAsProcessed(itemKey, warehouseId)
1335
    self.recv_markMissedInventoryUpdatesAsProcessed()
1336
 
1337
  def send_markMissedInventoryUpdatesAsProcessed(self, itemKey, warehouseId):
1338
    self._oprot.writeMessageBegin('markMissedInventoryUpdatesAsProcessed', TMessageType.CALL, self._seqid)
1339
    args = markMissedInventoryUpdatesAsProcessed_args()
1340
    args.itemKey = itemKey
1341
    args.warehouseId = warehouseId
1342
    args.write(self._oprot)
1343
    self._oprot.writeMessageEnd()
1344
    self._oprot.trans.flush()
1345
 
1346
  def recv_markMissedInventoryUpdatesAsProcessed(self, ):
1347
    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
1348
    if mtype == TMessageType.EXCEPTION:
1349
      x = TApplicationException()
1350
      x.read(self._iprot)
1351
      self._iprot.readMessageEnd()
1352
      raise x
1353
    result = markMissedInventoryUpdatesAsProcessed_result()
1354
    result.read(self._iprot)
1355
    self._iprot.readMessageEnd()
1356
    return
1357
 
1358
  def getIgnoredItemKeys(self, ):
1359
    """
1360
    Returns all the item key mappings that have been ignored until date. Value of map has the warehouse id
1361
    and the timestamp from where alert was raised.
1362
    """
1363
    self.send_getIgnoredItemKeys()
1364
    return self.recv_getIgnoredItemKeys()
1365
 
1366
  def send_getIgnoredItemKeys(self, ):
1367
    self._oprot.writeMessageBegin('getIgnoredItemKeys', TMessageType.CALL, self._seqid)
1368
    args = getIgnoredItemKeys_args()
1369
    args.write(self._oprot)
1370
    self._oprot.writeMessageEnd()
1371
    self._oprot.trans.flush()
1372
 
1373
  def recv_getIgnoredItemKeys(self, ):
1374
    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
1375
    if mtype == TMessageType.EXCEPTION:
1376
      x = TApplicationException()
1377
      x.read(self._iprot)
1378
      self._iprot.readMessageEnd()
1379
      raise x
1380
    result = getIgnoredItemKeys_result()
1381
    result.read(self._iprot)
1382
    self._iprot.readMessageEnd()
1383
    if result.success is not None:
1384
      return result.success
1385
    raise TApplicationException(TApplicationException.MISSING_RESULT, "getIgnoredItemKeys failed: unknown result");
1386
 
1387
  def addBadInventory(self, itemId, warehouseId, quantity):
1388
    """
1389
    Add the BAD type inventory to existing stock.
1390
 
1391
    Parameters:
1392
     - itemId
1393
     - warehouseId
1394
     - quantity
1395
    """
1396
    self.send_addBadInventory(itemId, warehouseId, quantity)
1397
    self.recv_addBadInventory()
1398
 
1399
  def send_addBadInventory(self, itemId, warehouseId, quantity):
1400
    self._oprot.writeMessageBegin('addBadInventory', TMessageType.CALL, self._seqid)
1401
    args = addBadInventory_args()
1402
    args.itemId = itemId
1403
    args.warehouseId = warehouseId
1404
    args.quantity = quantity
1405
    args.write(self._oprot)
1406
    self._oprot.writeMessageEnd()
1407
    self._oprot.trans.flush()
1408
 
1409
  def recv_addBadInventory(self, ):
1410
    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
1411
    if mtype == TMessageType.EXCEPTION:
1412
      x = TApplicationException()
1413
      x.read(self._iprot)
1414
      self._iprot.readMessageEnd()
1415
      raise x
1416
    result = addBadInventory_result()
1417
    result.read(self._iprot)
1418
    self._iprot.readMessageEnd()
1419
    if result.cex is not None:
1420
      raise result.cex
1421
    return
1422
 
1423
  def getShippingLocations(self, ):
1424
    """
1425
    Returns all shipping locations
1426
    """
1427
    self.send_getShippingLocations()
1428
    return self.recv_getShippingLocations()
1429
 
1430
  def send_getShippingLocations(self, ):
1431
    self._oprot.writeMessageBegin('getShippingLocations', TMessageType.CALL, self._seqid)
1432
    args = getShippingLocations_args()
1433
    args.write(self._oprot)
1434
    self._oprot.writeMessageEnd()
1435
    self._oprot.trans.flush()
1436
 
1437
  def recv_getShippingLocations(self, ):
1438
    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
1439
    if mtype == TMessageType.EXCEPTION:
1440
      x = TApplicationException()
1441
      x.read(self._iprot)
1442
      self._iprot.readMessageEnd()
1443
      raise x
1444
    result = getShippingLocations_result()
1445
    result.read(self._iprot)
1446
    self._iprot.readMessageEnd()
1447
    if result.success is not None:
1448
      return result.success
1449
    raise TApplicationException(TApplicationException.MISSING_RESULT, "getShippingLocations failed: unknown result");
1450
 
1451
  def getAllVendorItemMappings(self, ):
1452
    """
1453
    Fetches all the vendor item mappings present.
1454
    """
1455
    self.send_getAllVendorItemMappings()
1456
    return self.recv_getAllVendorItemMappings()
1457
 
1458
  def send_getAllVendorItemMappings(self, ):
1459
    self._oprot.writeMessageBegin('getAllVendorItemMappings', TMessageType.CALL, self._seqid)
1460
    args = getAllVendorItemMappings_args()
1461
    args.write(self._oprot)
1462
    self._oprot.writeMessageEnd()
1463
    self._oprot.trans.flush()
1464
 
1465
  def recv_getAllVendorItemMappings(self, ):
1466
    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
1467
    if mtype == TMessageType.EXCEPTION:
1468
      x = TApplicationException()
1469
      x.read(self._iprot)
1470
      self._iprot.readMessageEnd()
1471
      raise x
1472
    result = getAllVendorItemMappings_result()
1473
    result.read(self._iprot)
1474
    self._iprot.readMessageEnd()
1475
    if result.success is not None:
1476
      return result.success
1477
    raise TApplicationException(TApplicationException.MISSING_RESULT, "getAllVendorItemMappings failed: unknown result");
1478
 
1479
  def getInventorySnapshot(self, warehouseId):
1480
    """
1481
    Gets items' inventory for a warehouse
1482
    If warehouse is passed as zero, items' inventory across all warehouses is sent
1483
 
1484
    Parameters:
1485
     - warehouseId
1486
    """
1487
    self.send_getInventorySnapshot(warehouseId)
1488
    return self.recv_getInventorySnapshot()
1489
 
1490
  def send_getInventorySnapshot(self, warehouseId):
1491
    self._oprot.writeMessageBegin('getInventorySnapshot', TMessageType.CALL, self._seqid)
1492
    args = getInventorySnapshot_args()
1493
    args.warehouseId = warehouseId
1494
    args.write(self._oprot)
1495
    self._oprot.writeMessageEnd()
1496
    self._oprot.trans.flush()
1497
 
1498
  def recv_getInventorySnapshot(self, ):
1499
    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
1500
    if mtype == TMessageType.EXCEPTION:
1501
      x = TApplicationException()
1502
      x.read(self._iprot)
1503
      self._iprot.readMessageEnd()
1504
      raise x
1505
    result = getInventorySnapshot_result()
1506
    result.read(self._iprot)
1507
    self._iprot.readMessageEnd()
1508
    if result.success is not None:
1509
      return result.success
1510
    raise TApplicationException(TApplicationException.MISSING_RESULT, "getInventorySnapshot failed: unknown result");
1511
 
1512
  def clearItemAvailabilityCache(self, ):
1513
    """
1514
    Clear item availability cache.
1515
    """
1516
    self.send_clearItemAvailabilityCache()
1517
    self.recv_clearItemAvailabilityCache()
1518
 
1519
  def send_clearItemAvailabilityCache(self, ):
1520
    self._oprot.writeMessageBegin('clearItemAvailabilityCache', TMessageType.CALL, self._seqid)
1521
    args = clearItemAvailabilityCache_args()
1522
    args.write(self._oprot)
1523
    self._oprot.writeMessageEnd()
1524
    self._oprot.trans.flush()
1525
 
1526
  def recv_clearItemAvailabilityCache(self, ):
1527
    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
1528
    if mtype == TMessageType.EXCEPTION:
1529
      x = TApplicationException()
1530
      x.read(self._iprot)
1531
      self._iprot.readMessageEnd()
1532
      raise x
1533
    result = clearItemAvailabilityCache_result()
1534
    result.read(self._iprot)
1535
    self._iprot.readMessageEnd()
1536
    return
1537
 
1538
  def updateVendorString(self, warehouseId, vendorString):
1539
    """
1540
    Parameters:
1541
     - warehouseId
1542
     - vendorString
1543
    """
1544
    self.send_updateVendorString(warehouseId, vendorString)
1545
    self.recv_updateVendorString()
1546
 
1547
  def send_updateVendorString(self, warehouseId, vendorString):
1548
    self._oprot.writeMessageBegin('updateVendorString', TMessageType.CALL, self._seqid)
1549
    args = updateVendorString_args()
1550
    args.warehouseId = warehouseId
1551
    args.vendorString = vendorString
1552
    args.write(self._oprot)
1553
    self._oprot.writeMessageEnd()
1554
    self._oprot.trans.flush()
1555
 
1556
  def recv_updateVendorString(self, ):
1557
    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
1558
    if mtype == TMessageType.EXCEPTION:
1559
      x = TApplicationException()
1560
      x.read(self._iprot)
1561
      self._iprot.readMessageEnd()
1562
      raise x
1563
    result = updateVendorString_result()
1564
    result.read(self._iprot)
1565
    self._iprot.readMessageEnd()
1566
    return
1567
 
6096 amit.gupta 1568
  def clearItemAvailabilityCacheForItem(self, item_id):
1569
    """
1570
    Parameters:
1571
     - item_id
1572
    """
1573
    self.send_clearItemAvailabilityCacheForItem(item_id)
1574
    self.recv_clearItemAvailabilityCacheForItem()
5944 mandeep.dh 1575
 
6096 amit.gupta 1576
  def send_clearItemAvailabilityCacheForItem(self, item_id):
1577
    self._oprot.writeMessageBegin('clearItemAvailabilityCacheForItem', TMessageType.CALL, self._seqid)
1578
    args = clearItemAvailabilityCacheForItem_args()
1579
    args.item_id = item_id
1580
    args.write(self._oprot)
1581
    self._oprot.writeMessageEnd()
1582
    self._oprot.trans.flush()
1583
 
1584
  def recv_clearItemAvailabilityCacheForItem(self, ):
1585
    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
1586
    if mtype == TMessageType.EXCEPTION:
1587
      x = TApplicationException()
1588
      x.read(self._iprot)
1589
      self._iprot.readMessageEnd()
1590
      raise x
1591
    result = clearItemAvailabilityCacheForItem_result()
1592
    result.read(self._iprot)
1593
    self._iprot.readMessageEnd()
1594
    return
1595
 
1596
 
5944 mandeep.dh 1597
class Processor(shop2020.thriftpy.generic.GenericService.Processor, Iface, TProcessor):
1598
  def __init__(self, handler):
1599
    shop2020.thriftpy.generic.GenericService.Processor.__init__(self, handler)
1600
    self._processMap["addWarehouse"] = Processor.process_addWarehouse
1601
    self._processMap["addVendor"] = Processor.process_addVendor
1602
    self._processMap["updateInventoryHistory"] = Processor.process_updateInventoryHistory
1603
    self._processMap["updateInventory"] = Processor.process_updateInventory
1604
    self._processMap["addInventory"] = Processor.process_addInventory
1605
    self._processMap["retireWarehouse"] = Processor.process_retireWarehouse
1606
    self._processMap["getItemInventoryByItemId"] = Processor.process_getItemInventoryByItemId
1607
    self._processMap["getItemAvailibilityAtWarehouse"] = Processor.process_getItemAvailibilityAtWarehouse
1608
    self._processMap["getItemAvailabilityAtLocation"] = Processor.process_getItemAvailabilityAtLocation
1609
    self._processMap["getAllWarehouses"] = Processor.process_getAllWarehouses
1610
    self._processMap["getWarehouse"] = Processor.process_getWarehouse
1611
    self._processMap["getAllItemsForWarehouse"] = Processor.process_getAllItemsForWarehouse
5966 rajveer 1612
    self._processMap["isOrderBillable"] = Processor.process_isOrderBillable
5944 mandeep.dh 1613
    self._processMap["reserveItemInWarehouse"] = Processor.process_reserveItemInWarehouse
1614
    self._processMap["reduceReservationCount"] = Processor.process_reduceReservationCount
1615
    self._processMap["getItemPricing"] = Processor.process_getItemPricing
1616
    self._processMap["getAllItemPricing"] = Processor.process_getAllItemPricing
1617
    self._processMap["addVendorItemPricing"] = Processor.process_addVendorItemPricing
1618
    self._processMap["getVendor"] = Processor.process_getVendor
1619
    self._processMap["getAllVendors"] = Processor.process_getAllVendors
1620
    self._processMap["addVendorItemMapping"] = Processor.process_addVendorItemMapping
1621
    self._processMap["getVendorItemMappings"] = Processor.process_getVendorItemMappings
1622
    self._processMap["getPendingOrdersInventory"] = Processor.process_getPendingOrdersInventory
1623
    self._processMap["getWarehouses"] = Processor.process_getWarehouses
1624
    self._processMap["resetAvailability"] = Processor.process_resetAvailability
1625
    self._processMap["resetAvailabilityForWarehouse"] = Processor.process_resetAvailabilityForWarehouse
1626
    self._processMap["getItemKeysToBeProcessed"] = Processor.process_getItemKeysToBeProcessed
1627
    self._processMap["markMissedInventoryUpdatesAsProcessed"] = Processor.process_markMissedInventoryUpdatesAsProcessed
1628
    self._processMap["getIgnoredItemKeys"] = Processor.process_getIgnoredItemKeys
1629
    self._processMap["addBadInventory"] = Processor.process_addBadInventory
1630
    self._processMap["getShippingLocations"] = Processor.process_getShippingLocations
1631
    self._processMap["getAllVendorItemMappings"] = Processor.process_getAllVendorItemMappings
1632
    self._processMap["getInventorySnapshot"] = Processor.process_getInventorySnapshot
1633
    self._processMap["clearItemAvailabilityCache"] = Processor.process_clearItemAvailabilityCache
1634
    self._processMap["updateVendorString"] = Processor.process_updateVendorString
6096 amit.gupta 1635
    self._processMap["clearItemAvailabilityCacheForItem"] = Processor.process_clearItemAvailabilityCacheForItem
5944 mandeep.dh 1636
 
1637
  def process(self, iprot, oprot):
1638
    (name, type, seqid) = iprot.readMessageBegin()
1639
    if name not in self._processMap:
1640
      iprot.skip(TType.STRUCT)
1641
      iprot.readMessageEnd()
1642
      x = TApplicationException(TApplicationException.UNKNOWN_METHOD, 'Unknown function %s' % (name))
1643
      oprot.writeMessageBegin(name, TMessageType.EXCEPTION, seqid)
1644
      x.write(oprot)
1645
      oprot.writeMessageEnd()
1646
      oprot.trans.flush()
1647
      return
1648
    else:
1649
      self._processMap[name](self, seqid, iprot, oprot)
1650
    return True
1651
 
1652
  def process_addWarehouse(self, seqid, iprot, oprot):
1653
    args = addWarehouse_args()
1654
    args.read(iprot)
1655
    iprot.readMessageEnd()
1656
    result = addWarehouse_result()
1657
    try:
1658
      result.success = self._handler.addWarehouse(args.warehouse)
1659
    except InventoryServiceException, cex:
1660
      result.cex = cex
1661
    oprot.writeMessageBegin("addWarehouse", TMessageType.REPLY, seqid)
1662
    result.write(oprot)
1663
    oprot.writeMessageEnd()
1664
    oprot.trans.flush()
1665
 
1666
  def process_addVendor(self, seqid, iprot, oprot):
1667
    args = addVendor_args()
1668
    args.read(iprot)
1669
    iprot.readMessageEnd()
1670
    result = addVendor_result()
1671
    try:
1672
      result.success = self._handler.addVendor(args.vendor)
1673
    except InventoryServiceException, cex:
1674
      result.cex = cex
1675
    oprot.writeMessageBegin("addVendor", TMessageType.REPLY, seqid)
1676
    result.write(oprot)
1677
    oprot.writeMessageEnd()
1678
    oprot.trans.flush()
1679
 
1680
  def process_updateInventoryHistory(self, seqid, iprot, oprot):
1681
    args = updateInventoryHistory_args()
1682
    args.read(iprot)
1683
    iprot.readMessageEnd()
1684
    result = updateInventoryHistory_result()
1685
    try:
1686
      self._handler.updateInventoryHistory(args.warehouse_id, args.timestamp, args.availability)
1687
    except InventoryServiceException, cex:
1688
      result.cex = cex
1689
    oprot.writeMessageBegin("updateInventoryHistory", TMessageType.REPLY, seqid)
1690
    result.write(oprot)
1691
    oprot.writeMessageEnd()
1692
    oprot.trans.flush()
1693
 
1694
  def process_updateInventory(self, seqid, iprot, oprot):
1695
    args = updateInventory_args()
1696
    args.read(iprot)
1697
    iprot.readMessageEnd()
1698
    result = updateInventory_result()
1699
    try:
1700
      self._handler.updateInventory(args.warehouse_id, args.timestamp, args.availability)
1701
    except InventoryServiceException, cex:
1702
      result.cex = cex
1703
    oprot.writeMessageBegin("updateInventory", TMessageType.REPLY, seqid)
1704
    result.write(oprot)
1705
    oprot.writeMessageEnd()
1706
    oprot.trans.flush()
1707
 
1708
  def process_addInventory(self, seqid, iprot, oprot):
1709
    args = addInventory_args()
1710
    args.read(iprot)
1711
    iprot.readMessageEnd()
1712
    result = addInventory_result()
1713
    try:
1714
      self._handler.addInventory(args.itemId, args.warehouseId, args.quantity)
1715
    except InventoryServiceException, cex:
1716
      result.cex = cex
1717
    oprot.writeMessageBegin("addInventory", TMessageType.REPLY, seqid)
1718
    result.write(oprot)
1719
    oprot.writeMessageEnd()
1720
    oprot.trans.flush()
1721
 
1722
  def process_retireWarehouse(self, seqid, iprot, oprot):
1723
    args = retireWarehouse_args()
1724
    args.read(iprot)
1725
    iprot.readMessageEnd()
1726
    result = retireWarehouse_result()
1727
    try:
1728
      self._handler.retireWarehouse(args.warehouse_id)
1729
    except InventoryServiceException, cex:
1730
      result.cex = cex
1731
    oprot.writeMessageBegin("retireWarehouse", TMessageType.REPLY, seqid)
1732
    result.write(oprot)
1733
    oprot.writeMessageEnd()
1734
    oprot.trans.flush()
1735
 
1736
  def process_getItemInventoryByItemId(self, seqid, iprot, oprot):
1737
    args = getItemInventoryByItemId_args()
1738
    args.read(iprot)
1739
    iprot.readMessageEnd()
1740
    result = getItemInventoryByItemId_result()
1741
    try:
1742
      result.success = self._handler.getItemInventoryByItemId(args.item_id)
1743
    except InventoryServiceException, cex:
1744
      result.cex = cex
1745
    oprot.writeMessageBegin("getItemInventoryByItemId", TMessageType.REPLY, seqid)
1746
    result.write(oprot)
1747
    oprot.writeMessageEnd()
1748
    oprot.trans.flush()
1749
 
1750
  def process_getItemAvailibilityAtWarehouse(self, seqid, iprot, oprot):
1751
    args = getItemAvailibilityAtWarehouse_args()
1752
    args.read(iprot)
1753
    iprot.readMessageEnd()
1754
    result = getItemAvailibilityAtWarehouse_result()
1755
    try:
1756
      result.success = self._handler.getItemAvailibilityAtWarehouse(args.warehouse_id, args.item_id)
1757
    except InventoryServiceException, cex:
1758
      result.cex = cex
1759
    oprot.writeMessageBegin("getItemAvailibilityAtWarehouse", TMessageType.REPLY, seqid)
1760
    result.write(oprot)
1761
    oprot.writeMessageEnd()
1762
    oprot.trans.flush()
1763
 
1764
  def process_getItemAvailabilityAtLocation(self, seqid, iprot, oprot):
1765
    args = getItemAvailabilityAtLocation_args()
1766
    args.read(iprot)
1767
    iprot.readMessageEnd()
1768
    result = getItemAvailabilityAtLocation_result()
1769
    try:
5978 rajveer 1770
      result.success = self._handler.getItemAvailabilityAtLocation(args.itemId, args.sourceId)
5944 mandeep.dh 1771
    except InventoryServiceException, isex:
1772
      result.isex = isex
1773
    oprot.writeMessageBegin("getItemAvailabilityAtLocation", TMessageType.REPLY, seqid)
1774
    result.write(oprot)
1775
    oprot.writeMessageEnd()
1776
    oprot.trans.flush()
1777
 
1778
  def process_getAllWarehouses(self, seqid, iprot, oprot):
1779
    args = getAllWarehouses_args()
1780
    args.read(iprot)
1781
    iprot.readMessageEnd()
1782
    result = getAllWarehouses_result()
1783
    try:
1784
      result.success = self._handler.getAllWarehouses(args.isActive)
1785
    except InventoryServiceException, cex:
1786
      result.cex = cex
1787
    oprot.writeMessageBegin("getAllWarehouses", TMessageType.REPLY, seqid)
1788
    result.write(oprot)
1789
    oprot.writeMessageEnd()
1790
    oprot.trans.flush()
1791
 
1792
  def process_getWarehouse(self, seqid, iprot, oprot):
1793
    args = getWarehouse_args()
1794
    args.read(iprot)
1795
    iprot.readMessageEnd()
1796
    result = getWarehouse_result()
1797
    try:
1798
      result.success = self._handler.getWarehouse(args.warehouse_id)
1799
    except InventoryServiceException, cex:
1800
      result.cex = cex
1801
    oprot.writeMessageBegin("getWarehouse", TMessageType.REPLY, seqid)
1802
    result.write(oprot)
1803
    oprot.writeMessageEnd()
1804
    oprot.trans.flush()
1805
 
1806
  def process_getAllItemsForWarehouse(self, seqid, iprot, oprot):
1807
    args = getAllItemsForWarehouse_args()
1808
    args.read(iprot)
1809
    iprot.readMessageEnd()
1810
    result = getAllItemsForWarehouse_result()
1811
    try:
1812
      result.success = self._handler.getAllItemsForWarehouse(args.warehouse_id)
1813
    except InventoryServiceException, cex:
1814
      result.cex = cex
1815
    oprot.writeMessageBegin("getAllItemsForWarehouse", TMessageType.REPLY, seqid)
1816
    result.write(oprot)
1817
    oprot.writeMessageEnd()
1818
    oprot.trans.flush()
1819
 
5966 rajveer 1820
  def process_isOrderBillable(self, seqid, iprot, oprot):
1821
    args = isOrderBillable_args()
1822
    args.read(iprot)
1823
    iprot.readMessageEnd()
1824
    result = isOrderBillable_result()
1825
    result.success = self._handler.isOrderBillable(args.itemId, args.warehouseId, args.sourceId, args.orderId)
1826
    oprot.writeMessageBegin("isOrderBillable", TMessageType.REPLY, seqid)
1827
    result.write(oprot)
1828
    oprot.writeMessageEnd()
1829
    oprot.trans.flush()
1830
 
5944 mandeep.dh 1831
  def process_reserveItemInWarehouse(self, seqid, iprot, oprot):
1832
    args = reserveItemInWarehouse_args()
1833
    args.read(iprot)
1834
    iprot.readMessageEnd()
1835
    result = reserveItemInWarehouse_result()
1836
    try:
5966 rajveer 1837
      result.success = self._handler.reserveItemInWarehouse(args.itemId, args.warehouseId, args.sourceId, args.orderId, args.createdTimestamp, args.promisedShippingTimestamp, args.quantity)
5944 mandeep.dh 1838
    except InventoryServiceException, cex:
1839
      result.cex = cex
1840
    oprot.writeMessageBegin("reserveItemInWarehouse", TMessageType.REPLY, seqid)
1841
    result.write(oprot)
1842
    oprot.writeMessageEnd()
1843
    oprot.trans.flush()
1844
 
1845
  def process_reduceReservationCount(self, seqid, iprot, oprot):
1846
    args = reduceReservationCount_args()
1847
    args.read(iprot)
1848
    iprot.readMessageEnd()
1849
    result = reduceReservationCount_result()
1850
    try:
5966 rajveer 1851
      result.success = self._handler.reduceReservationCount(args.itemId, args.warehouseId, args.sourceId, args.orderId, args.quantity)
5944 mandeep.dh 1852
    except InventoryServiceException, cex:
1853
      result.cex = cex
1854
    oprot.writeMessageBegin("reduceReservationCount", TMessageType.REPLY, seqid)
1855
    result.write(oprot)
1856
    oprot.writeMessageEnd()
1857
    oprot.trans.flush()
1858
 
1859
  def process_getItemPricing(self, seqid, iprot, oprot):
1860
    args = getItemPricing_args()
1861
    args.read(iprot)
1862
    iprot.readMessageEnd()
1863
    result = getItemPricing_result()
1864
    try:
1865
      result.success = self._handler.getItemPricing(args.itemId, args.vendorId)
1866
    except InventoryServiceException, cex:
1867
      result.cex = cex
1868
    oprot.writeMessageBegin("getItemPricing", TMessageType.REPLY, seqid)
1869
    result.write(oprot)
1870
    oprot.writeMessageEnd()
1871
    oprot.trans.flush()
1872
 
1873
  def process_getAllItemPricing(self, seqid, iprot, oprot):
1874
    args = getAllItemPricing_args()
1875
    args.read(iprot)
1876
    iprot.readMessageEnd()
1877
    result = getAllItemPricing_result()
1878
    try:
1879
      result.success = self._handler.getAllItemPricing(args.itemId)
1880
    except InventoryServiceException, cex:
1881
      result.cex = cex
1882
    oprot.writeMessageBegin("getAllItemPricing", TMessageType.REPLY, seqid)
1883
    result.write(oprot)
1884
    oprot.writeMessageEnd()
1885
    oprot.trans.flush()
1886
 
1887
  def process_addVendorItemPricing(self, seqid, iprot, oprot):
1888
    args = addVendorItemPricing_args()
1889
    args.read(iprot)
1890
    iprot.readMessageEnd()
1891
    result = addVendorItemPricing_result()
1892
    try:
1893
      self._handler.addVendorItemPricing(args.vendorItemPricing)
1894
    except InventoryServiceException, cex:
1895
      result.cex = cex
1896
    oprot.writeMessageBegin("addVendorItemPricing", TMessageType.REPLY, seqid)
1897
    result.write(oprot)
1898
    oprot.writeMessageEnd()
1899
    oprot.trans.flush()
1900
 
1901
  def process_getVendor(self, seqid, iprot, oprot):
1902
    args = getVendor_args()
1903
    args.read(iprot)
1904
    iprot.readMessageEnd()
1905
    result = getVendor_result()
1906
    result.success = self._handler.getVendor(args.vendorId)
1907
    oprot.writeMessageBegin("getVendor", TMessageType.REPLY, seqid)
1908
    result.write(oprot)
1909
    oprot.writeMessageEnd()
1910
    oprot.trans.flush()
1911
 
1912
  def process_getAllVendors(self, seqid, iprot, oprot):
1913
    args = getAllVendors_args()
1914
    args.read(iprot)
1915
    iprot.readMessageEnd()
1916
    result = getAllVendors_result()
1917
    result.success = self._handler.getAllVendors()
1918
    oprot.writeMessageBegin("getAllVendors", TMessageType.REPLY, seqid)
1919
    result.write(oprot)
1920
    oprot.writeMessageEnd()
1921
    oprot.trans.flush()
1922
 
1923
  def process_addVendorItemMapping(self, seqid, iprot, oprot):
1924
    args = addVendorItemMapping_args()
1925
    args.read(iprot)
1926
    iprot.readMessageEnd()
1927
    result = addVendorItemMapping_result()
1928
    try:
1929
      self._handler.addVendorItemMapping(args.key, args.vendorItemMapping)
1930
    except InventoryServiceException, cex:
1931
      result.cex = cex
1932
    oprot.writeMessageBegin("addVendorItemMapping", TMessageType.REPLY, seqid)
1933
    result.write(oprot)
1934
    oprot.writeMessageEnd()
1935
    oprot.trans.flush()
1936
 
1937
  def process_getVendorItemMappings(self, seqid, iprot, oprot):
1938
    args = getVendorItemMappings_args()
1939
    args.read(iprot)
1940
    iprot.readMessageEnd()
1941
    result = getVendorItemMappings_result()
1942
    try:
1943
      result.success = self._handler.getVendorItemMappings(args.itemId)
1944
    except InventoryServiceException, cex:
1945
      result.cex = cex
1946
    oprot.writeMessageBegin("getVendorItemMappings", TMessageType.REPLY, seqid)
1947
    result.write(oprot)
1948
    oprot.writeMessageEnd()
1949
    oprot.trans.flush()
1950
 
1951
  def process_getPendingOrdersInventory(self, seqid, iprot, oprot):
1952
    args = getPendingOrdersInventory_args()
1953
    args.read(iprot)
1954
    iprot.readMessageEnd()
1955
    result = getPendingOrdersInventory_result()
1956
    result.success = self._handler.getPendingOrdersInventory(args.vendorid)
1957
    oprot.writeMessageBegin("getPendingOrdersInventory", TMessageType.REPLY, seqid)
1958
    result.write(oprot)
1959
    oprot.writeMessageEnd()
1960
    oprot.trans.flush()
1961
 
1962
  def process_getWarehouses(self, seqid, iprot, oprot):
1963
    args = getWarehouses_args()
1964
    args.read(iprot)
1965
    iprot.readMessageEnd()
1966
    result = getWarehouses_result()
1967
    result.success = self._handler.getWarehouses(args.warehouseType, args.inventoryType, args.vendorId, args.billingWarehouseId, args.shippingWarehouseId)
1968
    oprot.writeMessageBegin("getWarehouses", TMessageType.REPLY, seqid)
1969
    result.write(oprot)
1970
    oprot.writeMessageEnd()
1971
    oprot.trans.flush()
1972
 
1973
  def process_resetAvailability(self, seqid, iprot, oprot):
1974
    args = resetAvailability_args()
1975
    args.read(iprot)
1976
    iprot.readMessageEnd()
1977
    result = resetAvailability_result()
1978
    try:
1979
      self._handler.resetAvailability(args.itemKey, args.vendorId, args.quantity, args.warehouseId)
1980
    except InventoryServiceException, cex:
1981
      result.cex = cex
1982
    oprot.writeMessageBegin("resetAvailability", TMessageType.REPLY, seqid)
1983
    result.write(oprot)
1984
    oprot.writeMessageEnd()
1985
    oprot.trans.flush()
1986
 
1987
  def process_resetAvailabilityForWarehouse(self, seqid, iprot, oprot):
1988
    args = resetAvailabilityForWarehouse_args()
1989
    args.read(iprot)
1990
    iprot.readMessageEnd()
1991
    result = resetAvailabilityForWarehouse_result()
1992
    try:
1993
      self._handler.resetAvailabilityForWarehouse(args.warehouseId)
1994
    except InventoryServiceException, cex:
1995
      result.cex = cex
1996
    oprot.writeMessageBegin("resetAvailabilityForWarehouse", TMessageType.REPLY, seqid)
1997
    result.write(oprot)
1998
    oprot.writeMessageEnd()
1999
    oprot.trans.flush()
2000
 
2001
  def process_getItemKeysToBeProcessed(self, seqid, iprot, oprot):
2002
    args = getItemKeysToBeProcessed_args()
2003
    args.read(iprot)
2004
    iprot.readMessageEnd()
2005
    result = getItemKeysToBeProcessed_result()
2006
    result.success = self._handler.getItemKeysToBeProcessed(args.warehouseId)
2007
    oprot.writeMessageBegin("getItemKeysToBeProcessed", TMessageType.REPLY, seqid)
2008
    result.write(oprot)
2009
    oprot.writeMessageEnd()
2010
    oprot.trans.flush()
2011
 
2012
  def process_markMissedInventoryUpdatesAsProcessed(self, seqid, iprot, oprot):
2013
    args = markMissedInventoryUpdatesAsProcessed_args()
2014
    args.read(iprot)
2015
    iprot.readMessageEnd()
2016
    result = markMissedInventoryUpdatesAsProcessed_result()
2017
    self._handler.markMissedInventoryUpdatesAsProcessed(args.itemKey, args.warehouseId)
2018
    oprot.writeMessageBegin("markMissedInventoryUpdatesAsProcessed", TMessageType.REPLY, seqid)
2019
    result.write(oprot)
2020
    oprot.writeMessageEnd()
2021
    oprot.trans.flush()
2022
 
2023
  def process_getIgnoredItemKeys(self, seqid, iprot, oprot):
2024
    args = getIgnoredItemKeys_args()
2025
    args.read(iprot)
2026
    iprot.readMessageEnd()
2027
    result = getIgnoredItemKeys_result()
2028
    result.success = self._handler.getIgnoredItemKeys()
2029
    oprot.writeMessageBegin("getIgnoredItemKeys", TMessageType.REPLY, seqid)
2030
    result.write(oprot)
2031
    oprot.writeMessageEnd()
2032
    oprot.trans.flush()
2033
 
2034
  def process_addBadInventory(self, seqid, iprot, oprot):
2035
    args = addBadInventory_args()
2036
    args.read(iprot)
2037
    iprot.readMessageEnd()
2038
    result = addBadInventory_result()
2039
    try:
2040
      self._handler.addBadInventory(args.itemId, args.warehouseId, args.quantity)
2041
    except InventoryServiceException, cex:
2042
      result.cex = cex
2043
    oprot.writeMessageBegin("addBadInventory", TMessageType.REPLY, seqid)
2044
    result.write(oprot)
2045
    oprot.writeMessageEnd()
2046
    oprot.trans.flush()
2047
 
2048
  def process_getShippingLocations(self, seqid, iprot, oprot):
2049
    args = getShippingLocations_args()
2050
    args.read(iprot)
2051
    iprot.readMessageEnd()
2052
    result = getShippingLocations_result()
2053
    result.success = self._handler.getShippingLocations()
2054
    oprot.writeMessageBegin("getShippingLocations", TMessageType.REPLY, seqid)
2055
    result.write(oprot)
2056
    oprot.writeMessageEnd()
2057
    oprot.trans.flush()
2058
 
2059
  def process_getAllVendorItemMappings(self, seqid, iprot, oprot):
2060
    args = getAllVendorItemMappings_args()
2061
    args.read(iprot)
2062
    iprot.readMessageEnd()
2063
    result = getAllVendorItemMappings_result()
2064
    result.success = self._handler.getAllVendorItemMappings()
2065
    oprot.writeMessageBegin("getAllVendorItemMappings", TMessageType.REPLY, seqid)
2066
    result.write(oprot)
2067
    oprot.writeMessageEnd()
2068
    oprot.trans.flush()
2069
 
2070
  def process_getInventorySnapshot(self, seqid, iprot, oprot):
2071
    args = getInventorySnapshot_args()
2072
    args.read(iprot)
2073
    iprot.readMessageEnd()
2074
    result = getInventorySnapshot_result()
2075
    result.success = self._handler.getInventorySnapshot(args.warehouseId)
2076
    oprot.writeMessageBegin("getInventorySnapshot", TMessageType.REPLY, seqid)
2077
    result.write(oprot)
2078
    oprot.writeMessageEnd()
2079
    oprot.trans.flush()
2080
 
2081
  def process_clearItemAvailabilityCache(self, seqid, iprot, oprot):
2082
    args = clearItemAvailabilityCache_args()
2083
    args.read(iprot)
2084
    iprot.readMessageEnd()
2085
    result = clearItemAvailabilityCache_result()
2086
    self._handler.clearItemAvailabilityCache()
2087
    oprot.writeMessageBegin("clearItemAvailabilityCache", TMessageType.REPLY, seqid)
2088
    result.write(oprot)
2089
    oprot.writeMessageEnd()
2090
    oprot.trans.flush()
2091
 
2092
  def process_updateVendorString(self, seqid, iprot, oprot):
2093
    args = updateVendorString_args()
2094
    args.read(iprot)
2095
    iprot.readMessageEnd()
2096
    result = updateVendorString_result()
2097
    self._handler.updateVendorString(args.warehouseId, args.vendorString)
2098
    oprot.writeMessageBegin("updateVendorString", TMessageType.REPLY, seqid)
2099
    result.write(oprot)
2100
    oprot.writeMessageEnd()
2101
    oprot.trans.flush()
2102
 
6096 amit.gupta 2103
  def process_clearItemAvailabilityCacheForItem(self, seqid, iprot, oprot):
2104
    args = clearItemAvailabilityCacheForItem_args()
2105
    args.read(iprot)
2106
    iprot.readMessageEnd()
2107
    result = clearItemAvailabilityCacheForItem_result()
2108
    self._handler.clearItemAvailabilityCacheForItem(args.item_id)
2109
    oprot.writeMessageBegin("clearItemAvailabilityCacheForItem", TMessageType.REPLY, seqid)
2110
    result.write(oprot)
2111
    oprot.writeMessageEnd()
2112
    oprot.trans.flush()
5944 mandeep.dh 2113
 
6096 amit.gupta 2114
 
5944 mandeep.dh 2115
# HELPER FUNCTIONS AND STRUCTURES
2116
 
2117
class addWarehouse_args:
2118
  """
2119
  Attributes:
2120
   - warehouse
2121
  """
2122
 
2123
  thrift_spec = (
2124
    None, # 0
2125
    (1, TType.STRUCT, 'warehouse', (Warehouse, Warehouse.thrift_spec), None, ), # 1
2126
  )
2127
 
2128
  def __init__(self, warehouse=None,):
2129
    self.warehouse = warehouse
2130
 
2131
  def read(self, iprot):
2132
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
2133
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
2134
      return
2135
    iprot.readStructBegin()
2136
    while True:
2137
      (fname, ftype, fid) = iprot.readFieldBegin()
2138
      if ftype == TType.STOP:
2139
        break
2140
      if fid == 1:
2141
        if ftype == TType.STRUCT:
2142
          self.warehouse = Warehouse()
2143
          self.warehouse.read(iprot)
2144
        else:
2145
          iprot.skip(ftype)
2146
      else:
2147
        iprot.skip(ftype)
2148
      iprot.readFieldEnd()
2149
    iprot.readStructEnd()
2150
 
2151
  def write(self, oprot):
2152
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
2153
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
2154
      return
2155
    oprot.writeStructBegin('addWarehouse_args')
2156
    if self.warehouse is not None:
2157
      oprot.writeFieldBegin('warehouse', TType.STRUCT, 1)
2158
      self.warehouse.write(oprot)
2159
      oprot.writeFieldEnd()
2160
    oprot.writeFieldStop()
2161
    oprot.writeStructEnd()
2162
 
2163
  def validate(self):
2164
    return
2165
 
2166
 
2167
  def __repr__(self):
2168
    L = ['%s=%r' % (key, value)
2169
      for key, value in self.__dict__.iteritems()]
2170
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
2171
 
2172
  def __eq__(self, other):
2173
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
2174
 
2175
  def __ne__(self, other):
2176
    return not (self == other)
2177
 
2178
class addWarehouse_result:
2179
  """
2180
  Attributes:
2181
   - success
2182
   - cex
2183
  """
2184
 
2185
  thrift_spec = (
2186
    (0, TType.I64, 'success', None, None, ), # 0
2187
    (1, TType.STRUCT, 'cex', (InventoryServiceException, InventoryServiceException.thrift_spec), None, ), # 1
2188
  )
2189
 
2190
  def __init__(self, success=None, cex=None,):
2191
    self.success = success
2192
    self.cex = cex
2193
 
2194
  def read(self, iprot):
2195
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
2196
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
2197
      return
2198
    iprot.readStructBegin()
2199
    while True:
2200
      (fname, ftype, fid) = iprot.readFieldBegin()
2201
      if ftype == TType.STOP:
2202
        break
2203
      if fid == 0:
2204
        if ftype == TType.I64:
2205
          self.success = iprot.readI64();
2206
        else:
2207
          iprot.skip(ftype)
2208
      elif fid == 1:
2209
        if ftype == TType.STRUCT:
2210
          self.cex = InventoryServiceException()
2211
          self.cex.read(iprot)
2212
        else:
2213
          iprot.skip(ftype)
2214
      else:
2215
        iprot.skip(ftype)
2216
      iprot.readFieldEnd()
2217
    iprot.readStructEnd()
2218
 
2219
  def write(self, oprot):
2220
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
2221
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
2222
      return
2223
    oprot.writeStructBegin('addWarehouse_result')
2224
    if self.success is not None:
2225
      oprot.writeFieldBegin('success', TType.I64, 0)
2226
      oprot.writeI64(self.success)
2227
      oprot.writeFieldEnd()
2228
    if self.cex is not None:
2229
      oprot.writeFieldBegin('cex', TType.STRUCT, 1)
2230
      self.cex.write(oprot)
2231
      oprot.writeFieldEnd()
2232
    oprot.writeFieldStop()
2233
    oprot.writeStructEnd()
2234
 
2235
  def validate(self):
2236
    return
2237
 
2238
 
2239
  def __repr__(self):
2240
    L = ['%s=%r' % (key, value)
2241
      for key, value in self.__dict__.iteritems()]
2242
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
2243
 
2244
  def __eq__(self, other):
2245
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
2246
 
2247
  def __ne__(self, other):
2248
    return not (self == other)
2249
 
2250
class addVendor_args:
2251
  """
2252
  Attributes:
2253
   - vendor
2254
  """
2255
 
2256
  thrift_spec = (
2257
    None, # 0
2258
    (1, TType.STRUCT, 'vendor', (Vendor, Vendor.thrift_spec), None, ), # 1
2259
  )
2260
 
2261
  def __init__(self, vendor=None,):
2262
    self.vendor = vendor
2263
 
2264
  def read(self, iprot):
2265
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
2266
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
2267
      return
2268
    iprot.readStructBegin()
2269
    while True:
2270
      (fname, ftype, fid) = iprot.readFieldBegin()
2271
      if ftype == TType.STOP:
2272
        break
2273
      if fid == 1:
2274
        if ftype == TType.STRUCT:
2275
          self.vendor = Vendor()
2276
          self.vendor.read(iprot)
2277
        else:
2278
          iprot.skip(ftype)
2279
      else:
2280
        iprot.skip(ftype)
2281
      iprot.readFieldEnd()
2282
    iprot.readStructEnd()
2283
 
2284
  def write(self, oprot):
2285
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
2286
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
2287
      return
2288
    oprot.writeStructBegin('addVendor_args')
2289
    if self.vendor is not None:
2290
      oprot.writeFieldBegin('vendor', TType.STRUCT, 1)
2291
      self.vendor.write(oprot)
2292
      oprot.writeFieldEnd()
2293
    oprot.writeFieldStop()
2294
    oprot.writeStructEnd()
2295
 
2296
  def validate(self):
2297
    return
2298
 
2299
 
2300
  def __repr__(self):
2301
    L = ['%s=%r' % (key, value)
2302
      for key, value in self.__dict__.iteritems()]
2303
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
2304
 
2305
  def __eq__(self, other):
2306
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
2307
 
2308
  def __ne__(self, other):
2309
    return not (self == other)
2310
 
2311
class addVendor_result:
2312
  """
2313
  Attributes:
2314
   - success
2315
   - cex
2316
  """
2317
 
2318
  thrift_spec = (
2319
    (0, TType.I64, 'success', None, None, ), # 0
2320
    (1, TType.STRUCT, 'cex', (InventoryServiceException, InventoryServiceException.thrift_spec), None, ), # 1
2321
  )
2322
 
2323
  def __init__(self, success=None, cex=None,):
2324
    self.success = success
2325
    self.cex = cex
2326
 
2327
  def read(self, iprot):
2328
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
2329
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
2330
      return
2331
    iprot.readStructBegin()
2332
    while True:
2333
      (fname, ftype, fid) = iprot.readFieldBegin()
2334
      if ftype == TType.STOP:
2335
        break
2336
      if fid == 0:
2337
        if ftype == TType.I64:
2338
          self.success = iprot.readI64();
2339
        else:
2340
          iprot.skip(ftype)
2341
      elif fid == 1:
2342
        if ftype == TType.STRUCT:
2343
          self.cex = InventoryServiceException()
2344
          self.cex.read(iprot)
2345
        else:
2346
          iprot.skip(ftype)
2347
      else:
2348
        iprot.skip(ftype)
2349
      iprot.readFieldEnd()
2350
    iprot.readStructEnd()
2351
 
2352
  def write(self, oprot):
2353
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
2354
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
2355
      return
2356
    oprot.writeStructBegin('addVendor_result')
2357
    if self.success is not None:
2358
      oprot.writeFieldBegin('success', TType.I64, 0)
2359
      oprot.writeI64(self.success)
2360
      oprot.writeFieldEnd()
2361
    if self.cex is not None:
2362
      oprot.writeFieldBegin('cex', TType.STRUCT, 1)
2363
      self.cex.write(oprot)
2364
      oprot.writeFieldEnd()
2365
    oprot.writeFieldStop()
2366
    oprot.writeStructEnd()
2367
 
2368
  def validate(self):
2369
    return
2370
 
2371
 
2372
  def __repr__(self):
2373
    L = ['%s=%r' % (key, value)
2374
      for key, value in self.__dict__.iteritems()]
2375
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
2376
 
2377
  def __eq__(self, other):
2378
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
2379
 
2380
  def __ne__(self, other):
2381
    return not (self == other)
2382
 
2383
class updateInventoryHistory_args:
2384
  """
2385
  Attributes:
2386
   - warehouse_id
2387
   - timestamp
2388
   - availability
2389
  """
2390
 
2391
  thrift_spec = (
2392
    None, # 0
2393
    (1, TType.I64, 'warehouse_id', None, None, ), # 1
2394
    (2, TType.STRING, 'timestamp', None, None, ), # 2
2395
    (3, TType.MAP, 'availability', (TType.STRING,None,TType.I64,None), None, ), # 3
2396
  )
2397
 
2398
  def __init__(self, warehouse_id=None, timestamp=None, availability=None,):
2399
    self.warehouse_id = warehouse_id
2400
    self.timestamp = timestamp
2401
    self.availability = availability
2402
 
2403
  def read(self, iprot):
2404
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
2405
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
2406
      return
2407
    iprot.readStructBegin()
2408
    while True:
2409
      (fname, ftype, fid) = iprot.readFieldBegin()
2410
      if ftype == TType.STOP:
2411
        break
2412
      if fid == 1:
2413
        if ftype == TType.I64:
2414
          self.warehouse_id = iprot.readI64();
2415
        else:
2416
          iprot.skip(ftype)
2417
      elif fid == 2:
2418
        if ftype == TType.STRING:
2419
          self.timestamp = iprot.readString();
2420
        else:
2421
          iprot.skip(ftype)
2422
      elif fid == 3:
2423
        if ftype == TType.MAP:
2424
          self.availability = {}
2425
          (_ktype19, _vtype20, _size18 ) = iprot.readMapBegin() 
2426
          for _i22 in xrange(_size18):
2427
            _key23 = iprot.readString();
2428
            _val24 = iprot.readI64();
2429
            self.availability[_key23] = _val24
2430
          iprot.readMapEnd()
2431
        else:
2432
          iprot.skip(ftype)
2433
      else:
2434
        iprot.skip(ftype)
2435
      iprot.readFieldEnd()
2436
    iprot.readStructEnd()
2437
 
2438
  def write(self, oprot):
2439
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
2440
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
2441
      return
2442
    oprot.writeStructBegin('updateInventoryHistory_args')
2443
    if self.warehouse_id is not None:
2444
      oprot.writeFieldBegin('warehouse_id', TType.I64, 1)
2445
      oprot.writeI64(self.warehouse_id)
2446
      oprot.writeFieldEnd()
2447
    if self.timestamp is not None:
2448
      oprot.writeFieldBegin('timestamp', TType.STRING, 2)
2449
      oprot.writeString(self.timestamp)
2450
      oprot.writeFieldEnd()
2451
    if self.availability is not None:
2452
      oprot.writeFieldBegin('availability', TType.MAP, 3)
2453
      oprot.writeMapBegin(TType.STRING, TType.I64, len(self.availability))
2454
      for kiter25,viter26 in self.availability.items():
2455
        oprot.writeString(kiter25)
2456
        oprot.writeI64(viter26)
2457
      oprot.writeMapEnd()
2458
      oprot.writeFieldEnd()
2459
    oprot.writeFieldStop()
2460
    oprot.writeStructEnd()
2461
 
2462
  def validate(self):
2463
    return
2464
 
2465
 
2466
  def __repr__(self):
2467
    L = ['%s=%r' % (key, value)
2468
      for key, value in self.__dict__.iteritems()]
2469
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
2470
 
2471
  def __eq__(self, other):
2472
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
2473
 
2474
  def __ne__(self, other):
2475
    return not (self == other)
2476
 
2477
class updateInventoryHistory_result:
2478
  """
2479
  Attributes:
2480
   - cex
2481
  """
2482
 
2483
  thrift_spec = (
2484
    None, # 0
2485
    (1, TType.STRUCT, 'cex', (InventoryServiceException, InventoryServiceException.thrift_spec), None, ), # 1
2486
  )
2487
 
2488
  def __init__(self, cex=None,):
2489
    self.cex = cex
2490
 
2491
  def read(self, iprot):
2492
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
2493
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
2494
      return
2495
    iprot.readStructBegin()
2496
    while True:
2497
      (fname, ftype, fid) = iprot.readFieldBegin()
2498
      if ftype == TType.STOP:
2499
        break
2500
      if fid == 1:
2501
        if ftype == TType.STRUCT:
2502
          self.cex = InventoryServiceException()
2503
          self.cex.read(iprot)
2504
        else:
2505
          iprot.skip(ftype)
2506
      else:
2507
        iprot.skip(ftype)
2508
      iprot.readFieldEnd()
2509
    iprot.readStructEnd()
2510
 
2511
  def write(self, oprot):
2512
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
2513
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
2514
      return
2515
    oprot.writeStructBegin('updateInventoryHistory_result')
2516
    if self.cex is not None:
2517
      oprot.writeFieldBegin('cex', TType.STRUCT, 1)
2518
      self.cex.write(oprot)
2519
      oprot.writeFieldEnd()
2520
    oprot.writeFieldStop()
2521
    oprot.writeStructEnd()
2522
 
2523
  def validate(self):
2524
    return
2525
 
2526
 
2527
  def __repr__(self):
2528
    L = ['%s=%r' % (key, value)
2529
      for key, value in self.__dict__.iteritems()]
2530
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
2531
 
2532
  def __eq__(self, other):
2533
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
2534
 
2535
  def __ne__(self, other):
2536
    return not (self == other)
2537
 
2538
class updateInventory_args:
2539
  """
2540
  Attributes:
2541
   - warehouse_id
2542
   - timestamp
2543
   - availability
2544
  """
2545
 
2546
  thrift_spec = (
2547
    None, # 0
2548
    (1, TType.I64, 'warehouse_id', None, None, ), # 1
2549
    (2, TType.STRING, 'timestamp', None, None, ), # 2
2550
    (3, TType.MAP, 'availability', (TType.STRING,None,TType.I64,None), None, ), # 3
2551
  )
2552
 
2553
  def __init__(self, warehouse_id=None, timestamp=None, availability=None,):
2554
    self.warehouse_id = warehouse_id
2555
    self.timestamp = timestamp
2556
    self.availability = availability
2557
 
2558
  def read(self, iprot):
2559
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
2560
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
2561
      return
2562
    iprot.readStructBegin()
2563
    while True:
2564
      (fname, ftype, fid) = iprot.readFieldBegin()
2565
      if ftype == TType.STOP:
2566
        break
2567
      if fid == 1:
2568
        if ftype == TType.I64:
2569
          self.warehouse_id = iprot.readI64();
2570
        else:
2571
          iprot.skip(ftype)
2572
      elif fid == 2:
2573
        if ftype == TType.STRING:
2574
          self.timestamp = iprot.readString();
2575
        else:
2576
          iprot.skip(ftype)
2577
      elif fid == 3:
2578
        if ftype == TType.MAP:
2579
          self.availability = {}
2580
          (_ktype28, _vtype29, _size27 ) = iprot.readMapBegin() 
2581
          for _i31 in xrange(_size27):
2582
            _key32 = iprot.readString();
2583
            _val33 = iprot.readI64();
2584
            self.availability[_key32] = _val33
2585
          iprot.readMapEnd()
2586
        else:
2587
          iprot.skip(ftype)
2588
      else:
2589
        iprot.skip(ftype)
2590
      iprot.readFieldEnd()
2591
    iprot.readStructEnd()
2592
 
2593
  def write(self, oprot):
2594
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
2595
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
2596
      return
2597
    oprot.writeStructBegin('updateInventory_args')
2598
    if self.warehouse_id is not None:
2599
      oprot.writeFieldBegin('warehouse_id', TType.I64, 1)
2600
      oprot.writeI64(self.warehouse_id)
2601
      oprot.writeFieldEnd()
2602
    if self.timestamp is not None:
2603
      oprot.writeFieldBegin('timestamp', TType.STRING, 2)
2604
      oprot.writeString(self.timestamp)
2605
      oprot.writeFieldEnd()
2606
    if self.availability is not None:
2607
      oprot.writeFieldBegin('availability', TType.MAP, 3)
2608
      oprot.writeMapBegin(TType.STRING, TType.I64, len(self.availability))
2609
      for kiter34,viter35 in self.availability.items():
2610
        oprot.writeString(kiter34)
2611
        oprot.writeI64(viter35)
2612
      oprot.writeMapEnd()
2613
      oprot.writeFieldEnd()
2614
    oprot.writeFieldStop()
2615
    oprot.writeStructEnd()
2616
 
2617
  def validate(self):
2618
    return
2619
 
2620
 
2621
  def __repr__(self):
2622
    L = ['%s=%r' % (key, value)
2623
      for key, value in self.__dict__.iteritems()]
2624
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
2625
 
2626
  def __eq__(self, other):
2627
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
2628
 
2629
  def __ne__(self, other):
2630
    return not (self == other)
2631
 
2632
class updateInventory_result:
2633
  """
2634
  Attributes:
2635
   - cex
2636
  """
2637
 
2638
  thrift_spec = (
2639
    None, # 0
2640
    (1, TType.STRUCT, 'cex', (InventoryServiceException, InventoryServiceException.thrift_spec), None, ), # 1
2641
  )
2642
 
2643
  def __init__(self, cex=None,):
2644
    self.cex = cex
2645
 
2646
  def read(self, iprot):
2647
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
2648
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
2649
      return
2650
    iprot.readStructBegin()
2651
    while True:
2652
      (fname, ftype, fid) = iprot.readFieldBegin()
2653
      if ftype == TType.STOP:
2654
        break
2655
      if fid == 1:
2656
        if ftype == TType.STRUCT:
2657
          self.cex = InventoryServiceException()
2658
          self.cex.read(iprot)
2659
        else:
2660
          iprot.skip(ftype)
2661
      else:
2662
        iprot.skip(ftype)
2663
      iprot.readFieldEnd()
2664
    iprot.readStructEnd()
2665
 
2666
  def write(self, oprot):
2667
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
2668
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
2669
      return
2670
    oprot.writeStructBegin('updateInventory_result')
2671
    if self.cex is not None:
2672
      oprot.writeFieldBegin('cex', TType.STRUCT, 1)
2673
      self.cex.write(oprot)
2674
      oprot.writeFieldEnd()
2675
    oprot.writeFieldStop()
2676
    oprot.writeStructEnd()
2677
 
2678
  def validate(self):
2679
    return
2680
 
2681
 
2682
  def __repr__(self):
2683
    L = ['%s=%r' % (key, value)
2684
      for key, value in self.__dict__.iteritems()]
2685
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
2686
 
2687
  def __eq__(self, other):
2688
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
2689
 
2690
  def __ne__(self, other):
2691
    return not (self == other)
2692
 
2693
class addInventory_args:
2694
  """
2695
  Attributes:
2696
   - itemId
2697
   - warehouseId
2698
   - quantity
2699
  """
2700
 
2701
  thrift_spec = (
2702
    None, # 0
2703
    (1, TType.I64, 'itemId', None, None, ), # 1
2704
    (2, TType.I64, 'warehouseId', None, None, ), # 2
2705
    (3, TType.I64, 'quantity', None, None, ), # 3
2706
  )
2707
 
2708
  def __init__(self, itemId=None, warehouseId=None, quantity=None,):
2709
    self.itemId = itemId
2710
    self.warehouseId = warehouseId
2711
    self.quantity = quantity
2712
 
2713
  def read(self, iprot):
2714
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
2715
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
2716
      return
2717
    iprot.readStructBegin()
2718
    while True:
2719
      (fname, ftype, fid) = iprot.readFieldBegin()
2720
      if ftype == TType.STOP:
2721
        break
2722
      if fid == 1:
2723
        if ftype == TType.I64:
2724
          self.itemId = iprot.readI64();
2725
        else:
2726
          iprot.skip(ftype)
2727
      elif fid == 2:
2728
        if ftype == TType.I64:
2729
          self.warehouseId = iprot.readI64();
2730
        else:
2731
          iprot.skip(ftype)
2732
      elif fid == 3:
2733
        if ftype == TType.I64:
2734
          self.quantity = iprot.readI64();
2735
        else:
2736
          iprot.skip(ftype)
2737
      else:
2738
        iprot.skip(ftype)
2739
      iprot.readFieldEnd()
2740
    iprot.readStructEnd()
2741
 
2742
  def write(self, oprot):
2743
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
2744
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
2745
      return
2746
    oprot.writeStructBegin('addInventory_args')
2747
    if self.itemId is not None:
2748
      oprot.writeFieldBegin('itemId', TType.I64, 1)
2749
      oprot.writeI64(self.itemId)
2750
      oprot.writeFieldEnd()
2751
    if self.warehouseId is not None:
2752
      oprot.writeFieldBegin('warehouseId', TType.I64, 2)
2753
      oprot.writeI64(self.warehouseId)
2754
      oprot.writeFieldEnd()
2755
    if self.quantity is not None:
2756
      oprot.writeFieldBegin('quantity', TType.I64, 3)
2757
      oprot.writeI64(self.quantity)
2758
      oprot.writeFieldEnd()
2759
    oprot.writeFieldStop()
2760
    oprot.writeStructEnd()
2761
 
2762
  def validate(self):
2763
    return
2764
 
2765
 
2766
  def __repr__(self):
2767
    L = ['%s=%r' % (key, value)
2768
      for key, value in self.__dict__.iteritems()]
2769
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
2770
 
2771
  def __eq__(self, other):
2772
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
2773
 
2774
  def __ne__(self, other):
2775
    return not (self == other)
2776
 
2777
class addInventory_result:
2778
  """
2779
  Attributes:
2780
   - cex
2781
  """
2782
 
2783
  thrift_spec = (
2784
    None, # 0
2785
    (1, TType.STRUCT, 'cex', (InventoryServiceException, InventoryServiceException.thrift_spec), None, ), # 1
2786
  )
2787
 
2788
  def __init__(self, cex=None,):
2789
    self.cex = cex
2790
 
2791
  def read(self, iprot):
2792
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
2793
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
2794
      return
2795
    iprot.readStructBegin()
2796
    while True:
2797
      (fname, ftype, fid) = iprot.readFieldBegin()
2798
      if ftype == TType.STOP:
2799
        break
2800
      if fid == 1:
2801
        if ftype == TType.STRUCT:
2802
          self.cex = InventoryServiceException()
2803
          self.cex.read(iprot)
2804
        else:
2805
          iprot.skip(ftype)
2806
      else:
2807
        iprot.skip(ftype)
2808
      iprot.readFieldEnd()
2809
    iprot.readStructEnd()
2810
 
2811
  def write(self, oprot):
2812
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
2813
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
2814
      return
2815
    oprot.writeStructBegin('addInventory_result')
2816
    if self.cex is not None:
2817
      oprot.writeFieldBegin('cex', TType.STRUCT, 1)
2818
      self.cex.write(oprot)
2819
      oprot.writeFieldEnd()
2820
    oprot.writeFieldStop()
2821
    oprot.writeStructEnd()
2822
 
2823
  def validate(self):
2824
    return
2825
 
2826
 
2827
  def __repr__(self):
2828
    L = ['%s=%r' % (key, value)
2829
      for key, value in self.__dict__.iteritems()]
2830
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
2831
 
2832
  def __eq__(self, other):
2833
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
2834
 
2835
  def __ne__(self, other):
2836
    return not (self == other)
2837
 
2838
class retireWarehouse_args:
2839
  """
2840
  Attributes:
2841
   - warehouse_id
2842
  """
2843
 
2844
  thrift_spec = (
2845
    None, # 0
2846
    (1, TType.I64, 'warehouse_id', None, None, ), # 1
2847
  )
2848
 
2849
  def __init__(self, warehouse_id=None,):
2850
    self.warehouse_id = warehouse_id
2851
 
2852
  def read(self, iprot):
2853
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
2854
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
2855
      return
2856
    iprot.readStructBegin()
2857
    while True:
2858
      (fname, ftype, fid) = iprot.readFieldBegin()
2859
      if ftype == TType.STOP:
2860
        break
2861
      if fid == 1:
2862
        if ftype == TType.I64:
2863
          self.warehouse_id = iprot.readI64();
2864
        else:
2865
          iprot.skip(ftype)
2866
      else:
2867
        iprot.skip(ftype)
2868
      iprot.readFieldEnd()
2869
    iprot.readStructEnd()
2870
 
2871
  def write(self, oprot):
2872
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
2873
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
2874
      return
2875
    oprot.writeStructBegin('retireWarehouse_args')
2876
    if self.warehouse_id is not None:
2877
      oprot.writeFieldBegin('warehouse_id', TType.I64, 1)
2878
      oprot.writeI64(self.warehouse_id)
2879
      oprot.writeFieldEnd()
2880
    oprot.writeFieldStop()
2881
    oprot.writeStructEnd()
2882
 
2883
  def validate(self):
2884
    return
2885
 
2886
 
2887
  def __repr__(self):
2888
    L = ['%s=%r' % (key, value)
2889
      for key, value in self.__dict__.iteritems()]
2890
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
2891
 
2892
  def __eq__(self, other):
2893
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
2894
 
2895
  def __ne__(self, other):
2896
    return not (self == other)
2897
 
2898
class retireWarehouse_result:
2899
  """
2900
  Attributes:
2901
   - cex
2902
  """
2903
 
2904
  thrift_spec = (
2905
    None, # 0
2906
    (1, TType.STRUCT, 'cex', (InventoryServiceException, InventoryServiceException.thrift_spec), None, ), # 1
2907
  )
2908
 
2909
  def __init__(self, cex=None,):
2910
    self.cex = cex
2911
 
2912
  def read(self, iprot):
2913
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
2914
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
2915
      return
2916
    iprot.readStructBegin()
2917
    while True:
2918
      (fname, ftype, fid) = iprot.readFieldBegin()
2919
      if ftype == TType.STOP:
2920
        break
2921
      if fid == 1:
2922
        if ftype == TType.STRUCT:
2923
          self.cex = InventoryServiceException()
2924
          self.cex.read(iprot)
2925
        else:
2926
          iprot.skip(ftype)
2927
      else:
2928
        iprot.skip(ftype)
2929
      iprot.readFieldEnd()
2930
    iprot.readStructEnd()
2931
 
2932
  def write(self, oprot):
2933
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
2934
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
2935
      return
2936
    oprot.writeStructBegin('retireWarehouse_result')
2937
    if self.cex is not None:
2938
      oprot.writeFieldBegin('cex', TType.STRUCT, 1)
2939
      self.cex.write(oprot)
2940
      oprot.writeFieldEnd()
2941
    oprot.writeFieldStop()
2942
    oprot.writeStructEnd()
2943
 
2944
  def validate(self):
2945
    return
2946
 
2947
 
2948
  def __repr__(self):
2949
    L = ['%s=%r' % (key, value)
2950
      for key, value in self.__dict__.iteritems()]
2951
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
2952
 
2953
  def __eq__(self, other):
2954
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
2955
 
2956
  def __ne__(self, other):
2957
    return not (self == other)
2958
 
2959
class getItemInventoryByItemId_args:
2960
  """
2961
  Attributes:
2962
   - item_id
2963
  """
2964
 
2965
  thrift_spec = (
2966
    None, # 0
2967
    (1, TType.I64, 'item_id', None, None, ), # 1
2968
  )
2969
 
2970
  def __init__(self, item_id=None,):
2971
    self.item_id = item_id
2972
 
2973
  def read(self, iprot):
2974
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
2975
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
2976
      return
2977
    iprot.readStructBegin()
2978
    while True:
2979
      (fname, ftype, fid) = iprot.readFieldBegin()
2980
      if ftype == TType.STOP:
2981
        break
2982
      if fid == 1:
2983
        if ftype == TType.I64:
2984
          self.item_id = iprot.readI64();
2985
        else:
2986
          iprot.skip(ftype)
2987
      else:
2988
        iprot.skip(ftype)
2989
      iprot.readFieldEnd()
2990
    iprot.readStructEnd()
2991
 
2992
  def write(self, oprot):
2993
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
2994
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
2995
      return
2996
    oprot.writeStructBegin('getItemInventoryByItemId_args')
2997
    if self.item_id is not None:
2998
      oprot.writeFieldBegin('item_id', TType.I64, 1)
2999
      oprot.writeI64(self.item_id)
3000
      oprot.writeFieldEnd()
3001
    oprot.writeFieldStop()
3002
    oprot.writeStructEnd()
3003
 
3004
  def validate(self):
3005
    return
3006
 
3007
 
3008
  def __repr__(self):
3009
    L = ['%s=%r' % (key, value)
3010
      for key, value in self.__dict__.iteritems()]
3011
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
3012
 
3013
  def __eq__(self, other):
3014
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
3015
 
3016
  def __ne__(self, other):
3017
    return not (self == other)
3018
 
3019
class getItemInventoryByItemId_result:
3020
  """
3021
  Attributes:
3022
   - success
3023
   - cex
3024
  """
3025
 
3026
  thrift_spec = (
3027
    (0, TType.STRUCT, 'success', (ItemInventory, ItemInventory.thrift_spec), None, ), # 0
3028
    (1, TType.STRUCT, 'cex', (InventoryServiceException, InventoryServiceException.thrift_spec), None, ), # 1
3029
  )
3030
 
3031
  def __init__(self, success=None, cex=None,):
3032
    self.success = success
3033
    self.cex = cex
3034
 
3035
  def read(self, iprot):
3036
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
3037
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
3038
      return
3039
    iprot.readStructBegin()
3040
    while True:
3041
      (fname, ftype, fid) = iprot.readFieldBegin()
3042
      if ftype == TType.STOP:
3043
        break
3044
      if fid == 0:
3045
        if ftype == TType.STRUCT:
3046
          self.success = ItemInventory()
3047
          self.success.read(iprot)
3048
        else:
3049
          iprot.skip(ftype)
3050
      elif fid == 1:
3051
        if ftype == TType.STRUCT:
3052
          self.cex = InventoryServiceException()
3053
          self.cex.read(iprot)
3054
        else:
3055
          iprot.skip(ftype)
3056
      else:
3057
        iprot.skip(ftype)
3058
      iprot.readFieldEnd()
3059
    iprot.readStructEnd()
3060
 
3061
  def write(self, oprot):
3062
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
3063
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
3064
      return
3065
    oprot.writeStructBegin('getItemInventoryByItemId_result')
3066
    if self.success is not None:
3067
      oprot.writeFieldBegin('success', TType.STRUCT, 0)
3068
      self.success.write(oprot)
3069
      oprot.writeFieldEnd()
3070
    if self.cex is not None:
3071
      oprot.writeFieldBegin('cex', TType.STRUCT, 1)
3072
      self.cex.write(oprot)
3073
      oprot.writeFieldEnd()
3074
    oprot.writeFieldStop()
3075
    oprot.writeStructEnd()
3076
 
3077
  def validate(self):
3078
    return
3079
 
3080
 
3081
  def __repr__(self):
3082
    L = ['%s=%r' % (key, value)
3083
      for key, value in self.__dict__.iteritems()]
3084
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
3085
 
3086
  def __eq__(self, other):
3087
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
3088
 
3089
  def __ne__(self, other):
3090
    return not (self == other)
3091
 
3092
class getItemAvailibilityAtWarehouse_args:
3093
  """
3094
  Attributes:
3095
   - warehouse_id
3096
   - item_id
3097
  """
3098
 
3099
  thrift_spec = (
3100
    None, # 0
3101
    (1, TType.I64, 'warehouse_id', None, None, ), # 1
3102
    (2, TType.I64, 'item_id', None, None, ), # 2
3103
  )
3104
 
3105
  def __init__(self, warehouse_id=None, item_id=None,):
3106
    self.warehouse_id = warehouse_id
3107
    self.item_id = item_id
3108
 
3109
  def read(self, iprot):
3110
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
3111
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
3112
      return
3113
    iprot.readStructBegin()
3114
    while True:
3115
      (fname, ftype, fid) = iprot.readFieldBegin()
3116
      if ftype == TType.STOP:
3117
        break
3118
      if fid == 1:
3119
        if ftype == TType.I64:
3120
          self.warehouse_id = iprot.readI64();
3121
        else:
3122
          iprot.skip(ftype)
3123
      elif fid == 2:
3124
        if ftype == TType.I64:
3125
          self.item_id = iprot.readI64();
3126
        else:
3127
          iprot.skip(ftype)
3128
      else:
3129
        iprot.skip(ftype)
3130
      iprot.readFieldEnd()
3131
    iprot.readStructEnd()
3132
 
3133
  def write(self, oprot):
3134
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
3135
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
3136
      return
3137
    oprot.writeStructBegin('getItemAvailibilityAtWarehouse_args')
3138
    if self.warehouse_id is not None:
3139
      oprot.writeFieldBegin('warehouse_id', TType.I64, 1)
3140
      oprot.writeI64(self.warehouse_id)
3141
      oprot.writeFieldEnd()
3142
    if self.item_id is not None:
3143
      oprot.writeFieldBegin('item_id', TType.I64, 2)
3144
      oprot.writeI64(self.item_id)
3145
      oprot.writeFieldEnd()
3146
    oprot.writeFieldStop()
3147
    oprot.writeStructEnd()
3148
 
3149
  def validate(self):
3150
    return
3151
 
3152
 
3153
  def __repr__(self):
3154
    L = ['%s=%r' % (key, value)
3155
      for key, value in self.__dict__.iteritems()]
3156
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
3157
 
3158
  def __eq__(self, other):
3159
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
3160
 
3161
  def __ne__(self, other):
3162
    return not (self == other)
3163
 
3164
class getItemAvailibilityAtWarehouse_result:
3165
  """
3166
  Attributes:
3167
   - success
3168
   - cex
3169
  """
3170
 
3171
  thrift_spec = (
3172
    (0, TType.I64, 'success', None, None, ), # 0
3173
    (1, TType.STRUCT, 'cex', (InventoryServiceException, InventoryServiceException.thrift_spec), None, ), # 1
3174
  )
3175
 
3176
  def __init__(self, success=None, cex=None,):
3177
    self.success = success
3178
    self.cex = cex
3179
 
3180
  def read(self, iprot):
3181
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
3182
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
3183
      return
3184
    iprot.readStructBegin()
3185
    while True:
3186
      (fname, ftype, fid) = iprot.readFieldBegin()
3187
      if ftype == TType.STOP:
3188
        break
3189
      if fid == 0:
3190
        if ftype == TType.I64:
3191
          self.success = iprot.readI64();
3192
        else:
3193
          iprot.skip(ftype)
3194
      elif fid == 1:
3195
        if ftype == TType.STRUCT:
3196
          self.cex = InventoryServiceException()
3197
          self.cex.read(iprot)
3198
        else:
3199
          iprot.skip(ftype)
3200
      else:
3201
        iprot.skip(ftype)
3202
      iprot.readFieldEnd()
3203
    iprot.readStructEnd()
3204
 
3205
  def write(self, oprot):
3206
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
3207
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
3208
      return
3209
    oprot.writeStructBegin('getItemAvailibilityAtWarehouse_result')
3210
    if self.success is not None:
3211
      oprot.writeFieldBegin('success', TType.I64, 0)
3212
      oprot.writeI64(self.success)
3213
      oprot.writeFieldEnd()
3214
    if self.cex is not None:
3215
      oprot.writeFieldBegin('cex', TType.STRUCT, 1)
3216
      self.cex.write(oprot)
3217
      oprot.writeFieldEnd()
3218
    oprot.writeFieldStop()
3219
    oprot.writeStructEnd()
3220
 
3221
  def validate(self):
3222
    return
3223
 
3224
 
3225
  def __repr__(self):
3226
    L = ['%s=%r' % (key, value)
3227
      for key, value in self.__dict__.iteritems()]
3228
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
3229
 
3230
  def __eq__(self, other):
3231
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
3232
 
3233
  def __ne__(self, other):
3234
    return not (self == other)
3235
 
3236
class getItemAvailabilityAtLocation_args:
3237
  """
3238
  Attributes:
3239
   - itemId
5978 rajveer 3240
   - sourceId
5944 mandeep.dh 3241
  """
3242
 
3243
  thrift_spec = (
3244
    None, # 0
3245
    (1, TType.I64, 'itemId', None, None, ), # 1
5978 rajveer 3246
    (2, TType.I64, 'sourceId', None, None, ), # 2
5944 mandeep.dh 3247
  )
3248
 
5978 rajveer 3249
  def __init__(self, itemId=None, sourceId=None,):
5944 mandeep.dh 3250
    self.itemId = itemId
5978 rajveer 3251
    self.sourceId = sourceId
5944 mandeep.dh 3252
 
3253
  def read(self, iprot):
3254
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
3255
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
3256
      return
3257
    iprot.readStructBegin()
3258
    while True:
3259
      (fname, ftype, fid) = iprot.readFieldBegin()
3260
      if ftype == TType.STOP:
3261
        break
3262
      if fid == 1:
3263
        if ftype == TType.I64:
3264
          self.itemId = iprot.readI64();
3265
        else:
3266
          iprot.skip(ftype)
5978 rajveer 3267
      elif fid == 2:
3268
        if ftype == TType.I64:
3269
          self.sourceId = iprot.readI64();
3270
        else:
3271
          iprot.skip(ftype)
5944 mandeep.dh 3272
      else:
3273
        iprot.skip(ftype)
3274
      iprot.readFieldEnd()
3275
    iprot.readStructEnd()
3276
 
3277
  def write(self, oprot):
3278
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
3279
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
3280
      return
3281
    oprot.writeStructBegin('getItemAvailabilityAtLocation_args')
3282
    if self.itemId is not None:
3283
      oprot.writeFieldBegin('itemId', TType.I64, 1)
3284
      oprot.writeI64(self.itemId)
3285
      oprot.writeFieldEnd()
5978 rajveer 3286
    if self.sourceId is not None:
3287
      oprot.writeFieldBegin('sourceId', TType.I64, 2)
3288
      oprot.writeI64(self.sourceId)
3289
      oprot.writeFieldEnd()
5944 mandeep.dh 3290
    oprot.writeFieldStop()
3291
    oprot.writeStructEnd()
3292
 
3293
  def validate(self):
3294
    return
3295
 
3296
 
3297
  def __repr__(self):
3298
    L = ['%s=%r' % (key, value)
3299
      for key, value in self.__dict__.iteritems()]
3300
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
3301
 
3302
  def __eq__(self, other):
3303
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
3304
 
3305
  def __ne__(self, other):
3306
    return not (self == other)
3307
 
3308
class getItemAvailabilityAtLocation_result:
3309
  """
3310
  Attributes:
3311
   - success
3312
   - isex
3313
  """
3314
 
3315
  thrift_spec = (
3316
    (0, TType.LIST, 'success', (TType.I64,None), None, ), # 0
3317
    (1, TType.STRUCT, 'isex', (InventoryServiceException, InventoryServiceException.thrift_spec), None, ), # 1
3318
  )
3319
 
3320
  def __init__(self, success=None, isex=None,):
3321
    self.success = success
3322
    self.isex = isex
3323
 
3324
  def read(self, iprot):
3325
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
3326
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
3327
      return
3328
    iprot.readStructBegin()
3329
    while True:
3330
      (fname, ftype, fid) = iprot.readFieldBegin()
3331
      if ftype == TType.STOP:
3332
        break
3333
      if fid == 0:
3334
        if ftype == TType.LIST:
3335
          self.success = []
3336
          (_etype39, _size36) = iprot.readListBegin()
3337
          for _i40 in xrange(_size36):
3338
            _elem41 = iprot.readI64();
3339
            self.success.append(_elem41)
3340
          iprot.readListEnd()
3341
        else:
3342
          iprot.skip(ftype)
3343
      elif fid == 1:
3344
        if ftype == TType.STRUCT:
3345
          self.isex = InventoryServiceException()
3346
          self.isex.read(iprot)
3347
        else:
3348
          iprot.skip(ftype)
3349
      else:
3350
        iprot.skip(ftype)
3351
      iprot.readFieldEnd()
3352
    iprot.readStructEnd()
3353
 
3354
  def write(self, oprot):
3355
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
3356
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
3357
      return
3358
    oprot.writeStructBegin('getItemAvailabilityAtLocation_result')
3359
    if self.success is not None:
3360
      oprot.writeFieldBegin('success', TType.LIST, 0)
3361
      oprot.writeListBegin(TType.I64, len(self.success))
3362
      for iter42 in self.success:
3363
        oprot.writeI64(iter42)
3364
      oprot.writeListEnd()
3365
      oprot.writeFieldEnd()
3366
    if self.isex is not None:
3367
      oprot.writeFieldBegin('isex', TType.STRUCT, 1)
3368
      self.isex.write(oprot)
3369
      oprot.writeFieldEnd()
3370
    oprot.writeFieldStop()
3371
    oprot.writeStructEnd()
3372
 
3373
  def validate(self):
3374
    return
3375
 
3376
 
3377
  def __repr__(self):
3378
    L = ['%s=%r' % (key, value)
3379
      for key, value in self.__dict__.iteritems()]
3380
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
3381
 
3382
  def __eq__(self, other):
3383
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
3384
 
3385
  def __ne__(self, other):
3386
    return not (self == other)
3387
 
3388
class getAllWarehouses_args:
3389
  """
3390
  Attributes:
3391
   - isActive
3392
  """
3393
 
3394
  thrift_spec = (
3395
    None, # 0
3396
    (1, TType.BOOL, 'isActive', None, None, ), # 1
3397
  )
3398
 
3399
  def __init__(self, isActive=None,):
3400
    self.isActive = isActive
3401
 
3402
  def read(self, iprot):
3403
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
3404
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
3405
      return
3406
    iprot.readStructBegin()
3407
    while True:
3408
      (fname, ftype, fid) = iprot.readFieldBegin()
3409
      if ftype == TType.STOP:
3410
        break
3411
      if fid == 1:
3412
        if ftype == TType.BOOL:
3413
          self.isActive = iprot.readBool();
3414
        else:
3415
          iprot.skip(ftype)
3416
      else:
3417
        iprot.skip(ftype)
3418
      iprot.readFieldEnd()
3419
    iprot.readStructEnd()
3420
 
3421
  def write(self, oprot):
3422
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
3423
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
3424
      return
3425
    oprot.writeStructBegin('getAllWarehouses_args')
3426
    if self.isActive is not None:
3427
      oprot.writeFieldBegin('isActive', TType.BOOL, 1)
3428
      oprot.writeBool(self.isActive)
3429
      oprot.writeFieldEnd()
3430
    oprot.writeFieldStop()
3431
    oprot.writeStructEnd()
3432
 
3433
  def validate(self):
3434
    return
3435
 
3436
 
3437
  def __repr__(self):
3438
    L = ['%s=%r' % (key, value)
3439
      for key, value in self.__dict__.iteritems()]
3440
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
3441
 
3442
  def __eq__(self, other):
3443
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
3444
 
3445
  def __ne__(self, other):
3446
    return not (self == other)
3447
 
3448
class getAllWarehouses_result:
3449
  """
3450
  Attributes:
3451
   - success
3452
   - cex
3453
  """
3454
 
3455
  thrift_spec = (
3456
    (0, TType.LIST, 'success', (TType.STRUCT,(Warehouse, Warehouse.thrift_spec)), None, ), # 0
3457
    (1, TType.STRUCT, 'cex', (InventoryServiceException, InventoryServiceException.thrift_spec), None, ), # 1
3458
  )
3459
 
3460
  def __init__(self, success=None, cex=None,):
3461
    self.success = success
3462
    self.cex = cex
3463
 
3464
  def read(self, iprot):
3465
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
3466
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
3467
      return
3468
    iprot.readStructBegin()
3469
    while True:
3470
      (fname, ftype, fid) = iprot.readFieldBegin()
3471
      if ftype == TType.STOP:
3472
        break
3473
      if fid == 0:
3474
        if ftype == TType.LIST:
3475
          self.success = []
3476
          (_etype46, _size43) = iprot.readListBegin()
3477
          for _i47 in xrange(_size43):
3478
            _elem48 = Warehouse()
3479
            _elem48.read(iprot)
3480
            self.success.append(_elem48)
3481
          iprot.readListEnd()
3482
        else:
3483
          iprot.skip(ftype)
3484
      elif fid == 1:
3485
        if ftype == TType.STRUCT:
3486
          self.cex = InventoryServiceException()
3487
          self.cex.read(iprot)
3488
        else:
3489
          iprot.skip(ftype)
3490
      else:
3491
        iprot.skip(ftype)
3492
      iprot.readFieldEnd()
3493
    iprot.readStructEnd()
3494
 
3495
  def write(self, oprot):
3496
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
3497
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
3498
      return
3499
    oprot.writeStructBegin('getAllWarehouses_result')
3500
    if self.success is not None:
3501
      oprot.writeFieldBegin('success', TType.LIST, 0)
3502
      oprot.writeListBegin(TType.STRUCT, len(self.success))
3503
      for iter49 in self.success:
3504
        iter49.write(oprot)
3505
      oprot.writeListEnd()
3506
      oprot.writeFieldEnd()
3507
    if self.cex is not None:
3508
      oprot.writeFieldBegin('cex', TType.STRUCT, 1)
3509
      self.cex.write(oprot)
3510
      oprot.writeFieldEnd()
3511
    oprot.writeFieldStop()
3512
    oprot.writeStructEnd()
3513
 
3514
  def validate(self):
3515
    return
3516
 
3517
 
3518
  def __repr__(self):
3519
    L = ['%s=%r' % (key, value)
3520
      for key, value in self.__dict__.iteritems()]
3521
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
3522
 
3523
  def __eq__(self, other):
3524
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
3525
 
3526
  def __ne__(self, other):
3527
    return not (self == other)
3528
 
3529
class getWarehouse_args:
3530
  """
3531
  Attributes:
3532
   - warehouse_id
3533
  """
3534
 
3535
  thrift_spec = (
3536
    None, # 0
3537
    (1, TType.I64, 'warehouse_id', None, None, ), # 1
3538
  )
3539
 
3540
  def __init__(self, warehouse_id=None,):
3541
    self.warehouse_id = warehouse_id
3542
 
3543
  def read(self, iprot):
3544
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
3545
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
3546
      return
3547
    iprot.readStructBegin()
3548
    while True:
3549
      (fname, ftype, fid) = iprot.readFieldBegin()
3550
      if ftype == TType.STOP:
3551
        break
3552
      if fid == 1:
3553
        if ftype == TType.I64:
3554
          self.warehouse_id = iprot.readI64();
3555
        else:
3556
          iprot.skip(ftype)
3557
      else:
3558
        iprot.skip(ftype)
3559
      iprot.readFieldEnd()
3560
    iprot.readStructEnd()
3561
 
3562
  def write(self, oprot):
3563
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
3564
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
3565
      return
3566
    oprot.writeStructBegin('getWarehouse_args')
3567
    if self.warehouse_id is not None:
3568
      oprot.writeFieldBegin('warehouse_id', TType.I64, 1)
3569
      oprot.writeI64(self.warehouse_id)
3570
      oprot.writeFieldEnd()
3571
    oprot.writeFieldStop()
3572
    oprot.writeStructEnd()
3573
 
3574
  def validate(self):
3575
    return
3576
 
3577
 
3578
  def __repr__(self):
3579
    L = ['%s=%r' % (key, value)
3580
      for key, value in self.__dict__.iteritems()]
3581
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
3582
 
3583
  def __eq__(self, other):
3584
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
3585
 
3586
  def __ne__(self, other):
3587
    return not (self == other)
3588
 
3589
class getWarehouse_result:
3590
  """
3591
  Attributes:
3592
   - success
3593
   - cex
3594
  """
3595
 
3596
  thrift_spec = (
3597
    (0, TType.STRUCT, 'success', (Warehouse, Warehouse.thrift_spec), None, ), # 0
3598
    (1, TType.STRUCT, 'cex', (InventoryServiceException, InventoryServiceException.thrift_spec), None, ), # 1
3599
  )
3600
 
3601
  def __init__(self, success=None, cex=None,):
3602
    self.success = success
3603
    self.cex = cex
3604
 
3605
  def read(self, iprot):
3606
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
3607
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
3608
      return
3609
    iprot.readStructBegin()
3610
    while True:
3611
      (fname, ftype, fid) = iprot.readFieldBegin()
3612
      if ftype == TType.STOP:
3613
        break
3614
      if fid == 0:
3615
        if ftype == TType.STRUCT:
3616
          self.success = Warehouse()
3617
          self.success.read(iprot)
3618
        else:
3619
          iprot.skip(ftype)
3620
      elif fid == 1:
3621
        if ftype == TType.STRUCT:
3622
          self.cex = InventoryServiceException()
3623
          self.cex.read(iprot)
3624
        else:
3625
          iprot.skip(ftype)
3626
      else:
3627
        iprot.skip(ftype)
3628
      iprot.readFieldEnd()
3629
    iprot.readStructEnd()
3630
 
3631
  def write(self, oprot):
3632
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
3633
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
3634
      return
3635
    oprot.writeStructBegin('getWarehouse_result')
3636
    if self.success is not None:
3637
      oprot.writeFieldBegin('success', TType.STRUCT, 0)
3638
      self.success.write(oprot)
3639
      oprot.writeFieldEnd()
3640
    if self.cex is not None:
3641
      oprot.writeFieldBegin('cex', TType.STRUCT, 1)
3642
      self.cex.write(oprot)
3643
      oprot.writeFieldEnd()
3644
    oprot.writeFieldStop()
3645
    oprot.writeStructEnd()
3646
 
3647
  def validate(self):
3648
    return
3649
 
3650
 
3651
  def __repr__(self):
3652
    L = ['%s=%r' % (key, value)
3653
      for key, value in self.__dict__.iteritems()]
3654
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
3655
 
3656
  def __eq__(self, other):
3657
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
3658
 
3659
  def __ne__(self, other):
3660
    return not (self == other)
3661
 
3662
class getAllItemsForWarehouse_args:
3663
  """
3664
  Attributes:
3665
   - warehouse_id
3666
  """
3667
 
3668
  thrift_spec = (
3669
    None, # 0
3670
    (1, TType.I64, 'warehouse_id', None, None, ), # 1
3671
  )
3672
 
3673
  def __init__(self, warehouse_id=None,):
3674
    self.warehouse_id = warehouse_id
3675
 
3676
  def read(self, iprot):
3677
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
3678
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
3679
      return
3680
    iprot.readStructBegin()
3681
    while True:
3682
      (fname, ftype, fid) = iprot.readFieldBegin()
3683
      if ftype == TType.STOP:
3684
        break
3685
      if fid == 1:
3686
        if ftype == TType.I64:
3687
          self.warehouse_id = iprot.readI64();
3688
        else:
3689
          iprot.skip(ftype)
3690
      else:
3691
        iprot.skip(ftype)
3692
      iprot.readFieldEnd()
3693
    iprot.readStructEnd()
3694
 
3695
  def write(self, oprot):
3696
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
3697
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
3698
      return
3699
    oprot.writeStructBegin('getAllItemsForWarehouse_args')
3700
    if self.warehouse_id is not None:
3701
      oprot.writeFieldBegin('warehouse_id', TType.I64, 1)
3702
      oprot.writeI64(self.warehouse_id)
3703
      oprot.writeFieldEnd()
3704
    oprot.writeFieldStop()
3705
    oprot.writeStructEnd()
3706
 
3707
  def validate(self):
3708
    return
3709
 
3710
 
3711
  def __repr__(self):
3712
    L = ['%s=%r' % (key, value)
3713
      for key, value in self.__dict__.iteritems()]
3714
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
3715
 
3716
  def __eq__(self, other):
3717
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
3718
 
3719
  def __ne__(self, other):
3720
    return not (self == other)
3721
 
3722
class getAllItemsForWarehouse_result:
3723
  """
3724
  Attributes:
3725
   - success
3726
   - cex
3727
  """
3728
 
3729
  thrift_spec = (
3730
    (0, TType.LIST, 'success', (TType.I64,None), None, ), # 0
3731
    (1, TType.STRUCT, 'cex', (InventoryServiceException, InventoryServiceException.thrift_spec), None, ), # 1
3732
  )
3733
 
3734
  def __init__(self, success=None, cex=None,):
3735
    self.success = success
3736
    self.cex = cex
3737
 
3738
  def read(self, iprot):
3739
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
3740
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
3741
      return
3742
    iprot.readStructBegin()
3743
    while True:
3744
      (fname, ftype, fid) = iprot.readFieldBegin()
3745
      if ftype == TType.STOP:
3746
        break
3747
      if fid == 0:
3748
        if ftype == TType.LIST:
3749
          self.success = []
3750
          (_etype53, _size50) = iprot.readListBegin()
3751
          for _i54 in xrange(_size50):
3752
            _elem55 = iprot.readI64();
3753
            self.success.append(_elem55)
3754
          iprot.readListEnd()
3755
        else:
3756
          iprot.skip(ftype)
3757
      elif fid == 1:
3758
        if ftype == TType.STRUCT:
3759
          self.cex = InventoryServiceException()
3760
          self.cex.read(iprot)
3761
        else:
3762
          iprot.skip(ftype)
3763
      else:
3764
        iprot.skip(ftype)
3765
      iprot.readFieldEnd()
3766
    iprot.readStructEnd()
3767
 
3768
  def write(self, oprot):
3769
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
3770
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
3771
      return
3772
    oprot.writeStructBegin('getAllItemsForWarehouse_result')
3773
    if self.success is not None:
3774
      oprot.writeFieldBegin('success', TType.LIST, 0)
3775
      oprot.writeListBegin(TType.I64, len(self.success))
3776
      for iter56 in self.success:
3777
        oprot.writeI64(iter56)
3778
      oprot.writeListEnd()
3779
      oprot.writeFieldEnd()
3780
    if self.cex is not None:
3781
      oprot.writeFieldBegin('cex', TType.STRUCT, 1)
3782
      self.cex.write(oprot)
3783
      oprot.writeFieldEnd()
3784
    oprot.writeFieldStop()
3785
    oprot.writeStructEnd()
3786
 
3787
  def validate(self):
3788
    return
3789
 
3790
 
3791
  def __repr__(self):
3792
    L = ['%s=%r' % (key, value)
3793
      for key, value in self.__dict__.iteritems()]
3794
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
3795
 
3796
  def __eq__(self, other):
3797
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
3798
 
3799
  def __ne__(self, other):
3800
    return not (self == other)
3801
 
5966 rajveer 3802
class isOrderBillable_args:
3803
  """
3804
  Attributes:
3805
   - itemId
3806
   - warehouseId
3807
   - sourceId
3808
   - orderId
3809
  """
3810
 
3811
  thrift_spec = (
3812
    None, # 0
3813
    (1, TType.I64, 'itemId', None, None, ), # 1
3814
    (2, TType.I64, 'warehouseId', None, None, ), # 2
3815
    (3, TType.I64, 'sourceId', None, None, ), # 3
3816
    (4, TType.I64, 'orderId', None, None, ), # 4
3817
  )
3818
 
3819
  def __init__(self, itemId=None, warehouseId=None, sourceId=None, orderId=None,):
3820
    self.itemId = itemId
3821
    self.warehouseId = warehouseId
3822
    self.sourceId = sourceId
3823
    self.orderId = orderId
3824
 
3825
  def read(self, iprot):
3826
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
3827
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
3828
      return
3829
    iprot.readStructBegin()
3830
    while True:
3831
      (fname, ftype, fid) = iprot.readFieldBegin()
3832
      if ftype == TType.STOP:
3833
        break
3834
      if fid == 1:
3835
        if ftype == TType.I64:
3836
          self.itemId = iprot.readI64();
3837
        else:
3838
          iprot.skip(ftype)
3839
      elif fid == 2:
3840
        if ftype == TType.I64:
3841
          self.warehouseId = iprot.readI64();
3842
        else:
3843
          iprot.skip(ftype)
3844
      elif fid == 3:
3845
        if ftype == TType.I64:
3846
          self.sourceId = iprot.readI64();
3847
        else:
3848
          iprot.skip(ftype)
3849
      elif fid == 4:
3850
        if ftype == TType.I64:
3851
          self.orderId = iprot.readI64();
3852
        else:
3853
          iprot.skip(ftype)
3854
      else:
3855
        iprot.skip(ftype)
3856
      iprot.readFieldEnd()
3857
    iprot.readStructEnd()
3858
 
3859
  def write(self, oprot):
3860
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
3861
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
3862
      return
3863
    oprot.writeStructBegin('isOrderBillable_args')
3864
    if self.itemId is not None:
3865
      oprot.writeFieldBegin('itemId', TType.I64, 1)
3866
      oprot.writeI64(self.itemId)
3867
      oprot.writeFieldEnd()
3868
    if self.warehouseId is not None:
3869
      oprot.writeFieldBegin('warehouseId', TType.I64, 2)
3870
      oprot.writeI64(self.warehouseId)
3871
      oprot.writeFieldEnd()
3872
    if self.sourceId is not None:
3873
      oprot.writeFieldBegin('sourceId', TType.I64, 3)
3874
      oprot.writeI64(self.sourceId)
3875
      oprot.writeFieldEnd()
3876
    if self.orderId is not None:
3877
      oprot.writeFieldBegin('orderId', TType.I64, 4)
3878
      oprot.writeI64(self.orderId)
3879
      oprot.writeFieldEnd()
3880
    oprot.writeFieldStop()
3881
    oprot.writeStructEnd()
3882
 
3883
  def validate(self):
3884
    return
3885
 
3886
 
3887
  def __repr__(self):
3888
    L = ['%s=%r' % (key, value)
3889
      for key, value in self.__dict__.iteritems()]
3890
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
3891
 
3892
  def __eq__(self, other):
3893
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
3894
 
3895
  def __ne__(self, other):
3896
    return not (self == other)
3897
 
3898
class isOrderBillable_result:
3899
  """
3900
  Attributes:
3901
   - success
3902
  """
3903
 
3904
  thrift_spec = (
3905
    (0, TType.BOOL, 'success', None, None, ), # 0
3906
  )
3907
 
3908
  def __init__(self, success=None,):
3909
    self.success = success
3910
 
3911
  def read(self, iprot):
3912
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
3913
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
3914
      return
3915
    iprot.readStructBegin()
3916
    while True:
3917
      (fname, ftype, fid) = iprot.readFieldBegin()
3918
      if ftype == TType.STOP:
3919
        break
3920
      if fid == 0:
3921
        if ftype == TType.BOOL:
3922
          self.success = iprot.readBool();
3923
        else:
3924
          iprot.skip(ftype)
3925
      else:
3926
        iprot.skip(ftype)
3927
      iprot.readFieldEnd()
3928
    iprot.readStructEnd()
3929
 
3930
  def write(self, oprot):
3931
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
3932
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
3933
      return
3934
    oprot.writeStructBegin('isOrderBillable_result')
3935
    if self.success is not None:
3936
      oprot.writeFieldBegin('success', TType.BOOL, 0)
3937
      oprot.writeBool(self.success)
3938
      oprot.writeFieldEnd()
3939
    oprot.writeFieldStop()
3940
    oprot.writeStructEnd()
3941
 
3942
  def validate(self):
3943
    return
3944
 
3945
 
3946
  def __repr__(self):
3947
    L = ['%s=%r' % (key, value)
3948
      for key, value in self.__dict__.iteritems()]
3949
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
3950
 
3951
  def __eq__(self, other):
3952
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
3953
 
3954
  def __ne__(self, other):
3955
    return not (self == other)
3956
 
5944 mandeep.dh 3957
class reserveItemInWarehouse_args:
3958
  """
3959
  Attributes:
3960
   - itemId
3961
   - warehouseId
5966 rajveer 3962
   - sourceId
3963
   - orderId
3964
   - createdTimestamp
3965
   - promisedShippingTimestamp
5944 mandeep.dh 3966
   - quantity
3967
  """
3968
 
3969
  thrift_spec = (
3970
    None, # 0
3971
    (1, TType.I64, 'itemId', None, None, ), # 1
3972
    (2, TType.I64, 'warehouseId', None, None, ), # 2
5966 rajveer 3973
    (3, TType.I64, 'sourceId', None, None, ), # 3
3974
    (4, TType.I64, 'orderId', None, None, ), # 4
3975
    (5, TType.I64, 'createdTimestamp', None, None, ), # 5
3976
    (6, TType.I64, 'promisedShippingTimestamp', None, None, ), # 6
3977
    (7, TType.DOUBLE, 'quantity', None, None, ), # 7
5944 mandeep.dh 3978
  )
3979
 
5966 rajveer 3980
  def __init__(self, itemId=None, warehouseId=None, sourceId=None, orderId=None, createdTimestamp=None, promisedShippingTimestamp=None, quantity=None,):
5944 mandeep.dh 3981
    self.itemId = itemId
3982
    self.warehouseId = warehouseId
5966 rajveer 3983
    self.sourceId = sourceId
3984
    self.orderId = orderId
3985
    self.createdTimestamp = createdTimestamp
3986
    self.promisedShippingTimestamp = promisedShippingTimestamp
5944 mandeep.dh 3987
    self.quantity = quantity
3988
 
3989
  def read(self, iprot):
3990
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
3991
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
3992
      return
3993
    iprot.readStructBegin()
3994
    while True:
3995
      (fname, ftype, fid) = iprot.readFieldBegin()
3996
      if ftype == TType.STOP:
3997
        break
3998
      if fid == 1:
3999
        if ftype == TType.I64:
4000
          self.itemId = iprot.readI64();
4001
        else:
4002
          iprot.skip(ftype)
4003
      elif fid == 2:
4004
        if ftype == TType.I64:
4005
          self.warehouseId = iprot.readI64();
4006
        else:
4007
          iprot.skip(ftype)
4008
      elif fid == 3:
5966 rajveer 4009
        if ftype == TType.I64:
4010
          self.sourceId = iprot.readI64();
4011
        else:
4012
          iprot.skip(ftype)
4013
      elif fid == 4:
4014
        if ftype == TType.I64:
4015
          self.orderId = iprot.readI64();
4016
        else:
4017
          iprot.skip(ftype)
4018
      elif fid == 5:
4019
        if ftype == TType.I64:
4020
          self.createdTimestamp = iprot.readI64();
4021
        else:
4022
          iprot.skip(ftype)
4023
      elif fid == 6:
4024
        if ftype == TType.I64:
4025
          self.promisedShippingTimestamp = iprot.readI64();
4026
        else:
4027
          iprot.skip(ftype)
4028
      elif fid == 7:
5944 mandeep.dh 4029
        if ftype == TType.DOUBLE:
4030
          self.quantity = iprot.readDouble();
4031
        else:
4032
          iprot.skip(ftype)
4033
      else:
4034
        iprot.skip(ftype)
4035
      iprot.readFieldEnd()
4036
    iprot.readStructEnd()
4037
 
4038
  def write(self, oprot):
4039
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
4040
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
4041
      return
4042
    oprot.writeStructBegin('reserveItemInWarehouse_args')
4043
    if self.itemId is not None:
4044
      oprot.writeFieldBegin('itemId', TType.I64, 1)
4045
      oprot.writeI64(self.itemId)
4046
      oprot.writeFieldEnd()
4047
    if self.warehouseId is not None:
4048
      oprot.writeFieldBegin('warehouseId', TType.I64, 2)
4049
      oprot.writeI64(self.warehouseId)
4050
      oprot.writeFieldEnd()
5966 rajveer 4051
    if self.sourceId is not None:
4052
      oprot.writeFieldBegin('sourceId', TType.I64, 3)
4053
      oprot.writeI64(self.sourceId)
4054
      oprot.writeFieldEnd()
4055
    if self.orderId is not None:
4056
      oprot.writeFieldBegin('orderId', TType.I64, 4)
4057
      oprot.writeI64(self.orderId)
4058
      oprot.writeFieldEnd()
4059
    if self.createdTimestamp is not None:
4060
      oprot.writeFieldBegin('createdTimestamp', TType.I64, 5)
4061
      oprot.writeI64(self.createdTimestamp)
4062
      oprot.writeFieldEnd()
4063
    if self.promisedShippingTimestamp is not None:
4064
      oprot.writeFieldBegin('promisedShippingTimestamp', TType.I64, 6)
4065
      oprot.writeI64(self.promisedShippingTimestamp)
4066
      oprot.writeFieldEnd()
5944 mandeep.dh 4067
    if self.quantity is not None:
5966 rajveer 4068
      oprot.writeFieldBegin('quantity', TType.DOUBLE, 7)
5944 mandeep.dh 4069
      oprot.writeDouble(self.quantity)
4070
      oprot.writeFieldEnd()
4071
    oprot.writeFieldStop()
4072
    oprot.writeStructEnd()
4073
 
4074
  def validate(self):
4075
    return
4076
 
4077
 
4078
  def __repr__(self):
4079
    L = ['%s=%r' % (key, value)
4080
      for key, value in self.__dict__.iteritems()]
4081
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
4082
 
4083
  def __eq__(self, other):
4084
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
4085
 
4086
  def __ne__(self, other):
4087
    return not (self == other)
4088
 
4089
class reserveItemInWarehouse_result:
4090
  """
4091
  Attributes:
4092
   - success
4093
   - cex
4094
  """
4095
 
4096
  thrift_spec = (
4097
    (0, TType.BOOL, 'success', None, None, ), # 0
4098
    (1, TType.STRUCT, 'cex', (InventoryServiceException, InventoryServiceException.thrift_spec), None, ), # 1
4099
  )
4100
 
4101
  def __init__(self, success=None, cex=None,):
4102
    self.success = success
4103
    self.cex = cex
4104
 
4105
  def read(self, iprot):
4106
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
4107
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
4108
      return
4109
    iprot.readStructBegin()
4110
    while True:
4111
      (fname, ftype, fid) = iprot.readFieldBegin()
4112
      if ftype == TType.STOP:
4113
        break
4114
      if fid == 0:
4115
        if ftype == TType.BOOL:
4116
          self.success = iprot.readBool();
4117
        else:
4118
          iprot.skip(ftype)
4119
      elif fid == 1:
4120
        if ftype == TType.STRUCT:
4121
          self.cex = InventoryServiceException()
4122
          self.cex.read(iprot)
4123
        else:
4124
          iprot.skip(ftype)
4125
      else:
4126
        iprot.skip(ftype)
4127
      iprot.readFieldEnd()
4128
    iprot.readStructEnd()
4129
 
4130
  def write(self, oprot):
4131
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
4132
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
4133
      return
4134
    oprot.writeStructBegin('reserveItemInWarehouse_result')
4135
    if self.success is not None:
4136
      oprot.writeFieldBegin('success', TType.BOOL, 0)
4137
      oprot.writeBool(self.success)
4138
      oprot.writeFieldEnd()
4139
    if self.cex is not None:
4140
      oprot.writeFieldBegin('cex', TType.STRUCT, 1)
4141
      self.cex.write(oprot)
4142
      oprot.writeFieldEnd()
4143
    oprot.writeFieldStop()
4144
    oprot.writeStructEnd()
4145
 
4146
  def validate(self):
4147
    return
4148
 
4149
 
4150
  def __repr__(self):
4151
    L = ['%s=%r' % (key, value)
4152
      for key, value in self.__dict__.iteritems()]
4153
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
4154
 
4155
  def __eq__(self, other):
4156
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
4157
 
4158
  def __ne__(self, other):
4159
    return not (self == other)
4160
 
4161
class reduceReservationCount_args:
4162
  """
4163
  Attributes:
4164
   - itemId
4165
   - warehouseId
5966 rajveer 4166
   - sourceId
4167
   - orderId
5944 mandeep.dh 4168
   - quantity
4169
  """
4170
 
4171
  thrift_spec = (
4172
    None, # 0
4173
    (1, TType.I64, 'itemId', None, None, ), # 1
4174
    (2, TType.I64, 'warehouseId', None, None, ), # 2
5966 rajveer 4175
    (3, TType.I64, 'sourceId', None, None, ), # 3
4176
    (4, TType.I64, 'orderId', None, None, ), # 4
4177
    (5, TType.DOUBLE, 'quantity', None, None, ), # 5
5944 mandeep.dh 4178
  )
4179
 
5966 rajveer 4180
  def __init__(self, itemId=None, warehouseId=None, sourceId=None, orderId=None, quantity=None,):
5944 mandeep.dh 4181
    self.itemId = itemId
4182
    self.warehouseId = warehouseId
5966 rajveer 4183
    self.sourceId = sourceId
4184
    self.orderId = orderId
5944 mandeep.dh 4185
    self.quantity = quantity
4186
 
4187
  def read(self, iprot):
4188
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
4189
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
4190
      return
4191
    iprot.readStructBegin()
4192
    while True:
4193
      (fname, ftype, fid) = iprot.readFieldBegin()
4194
      if ftype == TType.STOP:
4195
        break
4196
      if fid == 1:
4197
        if ftype == TType.I64:
4198
          self.itemId = iprot.readI64();
4199
        else:
4200
          iprot.skip(ftype)
4201
      elif fid == 2:
4202
        if ftype == TType.I64:
4203
          self.warehouseId = iprot.readI64();
4204
        else:
4205
          iprot.skip(ftype)
4206
      elif fid == 3:
5966 rajveer 4207
        if ftype == TType.I64:
4208
          self.sourceId = iprot.readI64();
4209
        else:
4210
          iprot.skip(ftype)
4211
      elif fid == 4:
4212
        if ftype == TType.I64:
4213
          self.orderId = iprot.readI64();
4214
        else:
4215
          iprot.skip(ftype)
4216
      elif fid == 5:
5944 mandeep.dh 4217
        if ftype == TType.DOUBLE:
4218
          self.quantity = iprot.readDouble();
4219
        else:
4220
          iprot.skip(ftype)
4221
      else:
4222
        iprot.skip(ftype)
4223
      iprot.readFieldEnd()
4224
    iprot.readStructEnd()
4225
 
4226
  def write(self, oprot):
4227
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
4228
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
4229
      return
4230
    oprot.writeStructBegin('reduceReservationCount_args')
4231
    if self.itemId is not None:
4232
      oprot.writeFieldBegin('itemId', TType.I64, 1)
4233
      oprot.writeI64(self.itemId)
4234
      oprot.writeFieldEnd()
4235
    if self.warehouseId is not None:
4236
      oprot.writeFieldBegin('warehouseId', TType.I64, 2)
4237
      oprot.writeI64(self.warehouseId)
4238
      oprot.writeFieldEnd()
5966 rajveer 4239
    if self.sourceId is not None:
4240
      oprot.writeFieldBegin('sourceId', TType.I64, 3)
4241
      oprot.writeI64(self.sourceId)
4242
      oprot.writeFieldEnd()
4243
    if self.orderId is not None:
4244
      oprot.writeFieldBegin('orderId', TType.I64, 4)
4245
      oprot.writeI64(self.orderId)
4246
      oprot.writeFieldEnd()
5944 mandeep.dh 4247
    if self.quantity is not None:
5966 rajveer 4248
      oprot.writeFieldBegin('quantity', TType.DOUBLE, 5)
5944 mandeep.dh 4249
      oprot.writeDouble(self.quantity)
4250
      oprot.writeFieldEnd()
4251
    oprot.writeFieldStop()
4252
    oprot.writeStructEnd()
4253
 
4254
  def validate(self):
4255
    return
4256
 
4257
 
4258
  def __repr__(self):
4259
    L = ['%s=%r' % (key, value)
4260
      for key, value in self.__dict__.iteritems()]
4261
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
4262
 
4263
  def __eq__(self, other):
4264
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
4265
 
4266
  def __ne__(self, other):
4267
    return not (self == other)
4268
 
4269
class reduceReservationCount_result:
4270
  """
4271
  Attributes:
4272
   - success
4273
   - cex
4274
  """
4275
 
4276
  thrift_spec = (
4277
    (0, TType.BOOL, 'success', None, None, ), # 0
4278
    (1, TType.STRUCT, 'cex', (InventoryServiceException, InventoryServiceException.thrift_spec), None, ), # 1
4279
  )
4280
 
4281
  def __init__(self, success=None, cex=None,):
4282
    self.success = success
4283
    self.cex = cex
4284
 
4285
  def read(self, iprot):
4286
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
4287
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
4288
      return
4289
    iprot.readStructBegin()
4290
    while True:
4291
      (fname, ftype, fid) = iprot.readFieldBegin()
4292
      if ftype == TType.STOP:
4293
        break
4294
      if fid == 0:
4295
        if ftype == TType.BOOL:
4296
          self.success = iprot.readBool();
4297
        else:
4298
          iprot.skip(ftype)
4299
      elif fid == 1:
4300
        if ftype == TType.STRUCT:
4301
          self.cex = InventoryServiceException()
4302
          self.cex.read(iprot)
4303
        else:
4304
          iprot.skip(ftype)
4305
      else:
4306
        iprot.skip(ftype)
4307
      iprot.readFieldEnd()
4308
    iprot.readStructEnd()
4309
 
4310
  def write(self, oprot):
4311
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
4312
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
4313
      return
4314
    oprot.writeStructBegin('reduceReservationCount_result')
4315
    if self.success is not None:
4316
      oprot.writeFieldBegin('success', TType.BOOL, 0)
4317
      oprot.writeBool(self.success)
4318
      oprot.writeFieldEnd()
4319
    if self.cex is not None:
4320
      oprot.writeFieldBegin('cex', TType.STRUCT, 1)
4321
      self.cex.write(oprot)
4322
      oprot.writeFieldEnd()
4323
    oprot.writeFieldStop()
4324
    oprot.writeStructEnd()
4325
 
4326
  def validate(self):
4327
    return
4328
 
4329
 
4330
  def __repr__(self):
4331
    L = ['%s=%r' % (key, value)
4332
      for key, value in self.__dict__.iteritems()]
4333
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
4334
 
4335
  def __eq__(self, other):
4336
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
4337
 
4338
  def __ne__(self, other):
4339
    return not (self == other)
4340
 
4341
class getItemPricing_args:
4342
  """
4343
  Attributes:
4344
   - itemId
4345
   - vendorId
4346
  """
4347
 
4348
  thrift_spec = (
4349
    None, # 0
4350
    (1, TType.I64, 'itemId', None, None, ), # 1
4351
    (2, TType.I64, 'vendorId', None, None, ), # 2
4352
  )
4353
 
4354
  def __init__(self, itemId=None, vendorId=None,):
4355
    self.itemId = itemId
4356
    self.vendorId = vendorId
4357
 
4358
  def read(self, iprot):
4359
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
4360
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
4361
      return
4362
    iprot.readStructBegin()
4363
    while True:
4364
      (fname, ftype, fid) = iprot.readFieldBegin()
4365
      if ftype == TType.STOP:
4366
        break
4367
      if fid == 1:
4368
        if ftype == TType.I64:
4369
          self.itemId = iprot.readI64();
4370
        else:
4371
          iprot.skip(ftype)
4372
      elif fid == 2:
4373
        if ftype == TType.I64:
4374
          self.vendorId = iprot.readI64();
4375
        else:
4376
          iprot.skip(ftype)
4377
      else:
4378
        iprot.skip(ftype)
4379
      iprot.readFieldEnd()
4380
    iprot.readStructEnd()
4381
 
4382
  def write(self, oprot):
4383
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
4384
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
4385
      return
4386
    oprot.writeStructBegin('getItemPricing_args')
4387
    if self.itemId is not None:
4388
      oprot.writeFieldBegin('itemId', TType.I64, 1)
4389
      oprot.writeI64(self.itemId)
4390
      oprot.writeFieldEnd()
4391
    if self.vendorId is not None:
4392
      oprot.writeFieldBegin('vendorId', TType.I64, 2)
4393
      oprot.writeI64(self.vendorId)
4394
      oprot.writeFieldEnd()
4395
    oprot.writeFieldStop()
4396
    oprot.writeStructEnd()
4397
 
4398
  def validate(self):
4399
    return
4400
 
4401
 
4402
  def __repr__(self):
4403
    L = ['%s=%r' % (key, value)
4404
      for key, value in self.__dict__.iteritems()]
4405
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
4406
 
4407
  def __eq__(self, other):
4408
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
4409
 
4410
  def __ne__(self, other):
4411
    return not (self == other)
4412
 
4413
class getItemPricing_result:
4414
  """
4415
  Attributes:
4416
   - success
4417
   - cex
4418
  """
4419
 
4420
  thrift_spec = (
4421
    (0, TType.STRUCT, 'success', (VendorItemPricing, VendorItemPricing.thrift_spec), None, ), # 0
4422
    (1, TType.STRUCT, 'cex', (InventoryServiceException, InventoryServiceException.thrift_spec), None, ), # 1
4423
  )
4424
 
4425
  def __init__(self, success=None, cex=None,):
4426
    self.success = success
4427
    self.cex = cex
4428
 
4429
  def read(self, iprot):
4430
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
4431
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
4432
      return
4433
    iprot.readStructBegin()
4434
    while True:
4435
      (fname, ftype, fid) = iprot.readFieldBegin()
4436
      if ftype == TType.STOP:
4437
        break
4438
      if fid == 0:
4439
        if ftype == TType.STRUCT:
4440
          self.success = VendorItemPricing()
4441
          self.success.read(iprot)
4442
        else:
4443
          iprot.skip(ftype)
4444
      elif fid == 1:
4445
        if ftype == TType.STRUCT:
4446
          self.cex = InventoryServiceException()
4447
          self.cex.read(iprot)
4448
        else:
4449
          iprot.skip(ftype)
4450
      else:
4451
        iprot.skip(ftype)
4452
      iprot.readFieldEnd()
4453
    iprot.readStructEnd()
4454
 
4455
  def write(self, oprot):
4456
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
4457
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
4458
      return
4459
    oprot.writeStructBegin('getItemPricing_result')
4460
    if self.success is not None:
4461
      oprot.writeFieldBegin('success', TType.STRUCT, 0)
4462
      self.success.write(oprot)
4463
      oprot.writeFieldEnd()
4464
    if self.cex is not None:
4465
      oprot.writeFieldBegin('cex', TType.STRUCT, 1)
4466
      self.cex.write(oprot)
4467
      oprot.writeFieldEnd()
4468
    oprot.writeFieldStop()
4469
    oprot.writeStructEnd()
4470
 
4471
  def validate(self):
4472
    return
4473
 
4474
 
4475
  def __repr__(self):
4476
    L = ['%s=%r' % (key, value)
4477
      for key, value in self.__dict__.iteritems()]
4478
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
4479
 
4480
  def __eq__(self, other):
4481
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
4482
 
4483
  def __ne__(self, other):
4484
    return not (self == other)
4485
 
4486
class getAllItemPricing_args:
4487
  """
4488
  Attributes:
4489
   - itemId
4490
  """
4491
 
4492
  thrift_spec = (
4493
    None, # 0
4494
    (1, TType.I64, 'itemId', None, None, ), # 1
4495
  )
4496
 
4497
  def __init__(self, itemId=None,):
4498
    self.itemId = itemId
4499
 
4500
  def read(self, iprot):
4501
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
4502
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
4503
      return
4504
    iprot.readStructBegin()
4505
    while True:
4506
      (fname, ftype, fid) = iprot.readFieldBegin()
4507
      if ftype == TType.STOP:
4508
        break
4509
      if fid == 1:
4510
        if ftype == TType.I64:
4511
          self.itemId = iprot.readI64();
4512
        else:
4513
          iprot.skip(ftype)
4514
      else:
4515
        iprot.skip(ftype)
4516
      iprot.readFieldEnd()
4517
    iprot.readStructEnd()
4518
 
4519
  def write(self, oprot):
4520
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
4521
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
4522
      return
4523
    oprot.writeStructBegin('getAllItemPricing_args')
4524
    if self.itemId is not None:
4525
      oprot.writeFieldBegin('itemId', TType.I64, 1)
4526
      oprot.writeI64(self.itemId)
4527
      oprot.writeFieldEnd()
4528
    oprot.writeFieldStop()
4529
    oprot.writeStructEnd()
4530
 
4531
  def validate(self):
4532
    return
4533
 
4534
 
4535
  def __repr__(self):
4536
    L = ['%s=%r' % (key, value)
4537
      for key, value in self.__dict__.iteritems()]
4538
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
4539
 
4540
  def __eq__(self, other):
4541
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
4542
 
4543
  def __ne__(self, other):
4544
    return not (self == other)
4545
 
4546
class getAllItemPricing_result:
4547
  """
4548
  Attributes:
4549
   - success
4550
   - cex
4551
  """
4552
 
4553
  thrift_spec = (
4554
    (0, TType.LIST, 'success', (TType.STRUCT,(VendorItemPricing, VendorItemPricing.thrift_spec)), None, ), # 0
4555
    (1, TType.STRUCT, 'cex', (InventoryServiceException, InventoryServiceException.thrift_spec), None, ), # 1
4556
  )
4557
 
4558
  def __init__(self, success=None, cex=None,):
4559
    self.success = success
4560
    self.cex = cex
4561
 
4562
  def read(self, iprot):
4563
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
4564
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
4565
      return
4566
    iprot.readStructBegin()
4567
    while True:
4568
      (fname, ftype, fid) = iprot.readFieldBegin()
4569
      if ftype == TType.STOP:
4570
        break
4571
      if fid == 0:
4572
        if ftype == TType.LIST:
4573
          self.success = []
4574
          (_etype60, _size57) = iprot.readListBegin()
4575
          for _i61 in xrange(_size57):
4576
            _elem62 = VendorItemPricing()
4577
            _elem62.read(iprot)
4578
            self.success.append(_elem62)
4579
          iprot.readListEnd()
4580
        else:
4581
          iprot.skip(ftype)
4582
      elif fid == 1:
4583
        if ftype == TType.STRUCT:
4584
          self.cex = InventoryServiceException()
4585
          self.cex.read(iprot)
4586
        else:
4587
          iprot.skip(ftype)
4588
      else:
4589
        iprot.skip(ftype)
4590
      iprot.readFieldEnd()
4591
    iprot.readStructEnd()
4592
 
4593
  def write(self, oprot):
4594
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
4595
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
4596
      return
4597
    oprot.writeStructBegin('getAllItemPricing_result')
4598
    if self.success is not None:
4599
      oprot.writeFieldBegin('success', TType.LIST, 0)
4600
      oprot.writeListBegin(TType.STRUCT, len(self.success))
4601
      for iter63 in self.success:
4602
        iter63.write(oprot)
4603
      oprot.writeListEnd()
4604
      oprot.writeFieldEnd()
4605
    if self.cex is not None:
4606
      oprot.writeFieldBegin('cex', TType.STRUCT, 1)
4607
      self.cex.write(oprot)
4608
      oprot.writeFieldEnd()
4609
    oprot.writeFieldStop()
4610
    oprot.writeStructEnd()
4611
 
4612
  def validate(self):
4613
    return
4614
 
4615
 
4616
  def __repr__(self):
4617
    L = ['%s=%r' % (key, value)
4618
      for key, value in self.__dict__.iteritems()]
4619
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
4620
 
4621
  def __eq__(self, other):
4622
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
4623
 
4624
  def __ne__(self, other):
4625
    return not (self == other)
4626
 
4627
class addVendorItemPricing_args:
4628
  """
4629
  Attributes:
4630
   - vendorItemPricing
4631
  """
4632
 
4633
  thrift_spec = (
4634
    None, # 0
4635
    (1, TType.STRUCT, 'vendorItemPricing', (VendorItemPricing, VendorItemPricing.thrift_spec), None, ), # 1
4636
  )
4637
 
4638
  def __init__(self, vendorItemPricing=None,):
4639
    self.vendorItemPricing = vendorItemPricing
4640
 
4641
  def read(self, iprot):
4642
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
4643
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
4644
      return
4645
    iprot.readStructBegin()
4646
    while True:
4647
      (fname, ftype, fid) = iprot.readFieldBegin()
4648
      if ftype == TType.STOP:
4649
        break
4650
      if fid == 1:
4651
        if ftype == TType.STRUCT:
4652
          self.vendorItemPricing = VendorItemPricing()
4653
          self.vendorItemPricing.read(iprot)
4654
        else:
4655
          iprot.skip(ftype)
4656
      else:
4657
        iprot.skip(ftype)
4658
      iprot.readFieldEnd()
4659
    iprot.readStructEnd()
4660
 
4661
  def write(self, oprot):
4662
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
4663
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
4664
      return
4665
    oprot.writeStructBegin('addVendorItemPricing_args')
4666
    if self.vendorItemPricing is not None:
4667
      oprot.writeFieldBegin('vendorItemPricing', TType.STRUCT, 1)
4668
      self.vendorItemPricing.write(oprot)
4669
      oprot.writeFieldEnd()
4670
    oprot.writeFieldStop()
4671
    oprot.writeStructEnd()
4672
 
4673
  def validate(self):
4674
    return
4675
 
4676
 
4677
  def __repr__(self):
4678
    L = ['%s=%r' % (key, value)
4679
      for key, value in self.__dict__.iteritems()]
4680
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
4681
 
4682
  def __eq__(self, other):
4683
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
4684
 
4685
  def __ne__(self, other):
4686
    return not (self == other)
4687
 
4688
class addVendorItemPricing_result:
4689
  """
4690
  Attributes:
4691
   - cex
4692
  """
4693
 
4694
  thrift_spec = (
4695
    None, # 0
4696
    (1, TType.STRUCT, 'cex', (InventoryServiceException, InventoryServiceException.thrift_spec), None, ), # 1
4697
  )
4698
 
4699
  def __init__(self, cex=None,):
4700
    self.cex = cex
4701
 
4702
  def read(self, iprot):
4703
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
4704
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
4705
      return
4706
    iprot.readStructBegin()
4707
    while True:
4708
      (fname, ftype, fid) = iprot.readFieldBegin()
4709
      if ftype == TType.STOP:
4710
        break
4711
      if fid == 1:
4712
        if ftype == TType.STRUCT:
4713
          self.cex = InventoryServiceException()
4714
          self.cex.read(iprot)
4715
        else:
4716
          iprot.skip(ftype)
4717
      else:
4718
        iprot.skip(ftype)
4719
      iprot.readFieldEnd()
4720
    iprot.readStructEnd()
4721
 
4722
  def write(self, oprot):
4723
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
4724
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
4725
      return
4726
    oprot.writeStructBegin('addVendorItemPricing_result')
4727
    if self.cex is not None:
4728
      oprot.writeFieldBegin('cex', TType.STRUCT, 1)
4729
      self.cex.write(oprot)
4730
      oprot.writeFieldEnd()
4731
    oprot.writeFieldStop()
4732
    oprot.writeStructEnd()
4733
 
4734
  def validate(self):
4735
    return
4736
 
4737
 
4738
  def __repr__(self):
4739
    L = ['%s=%r' % (key, value)
4740
      for key, value in self.__dict__.iteritems()]
4741
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
4742
 
4743
  def __eq__(self, other):
4744
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
4745
 
4746
  def __ne__(self, other):
4747
    return not (self == other)
4748
 
4749
class getVendor_args:
4750
  """
4751
  Attributes:
4752
   - vendorId
4753
  """
4754
 
4755
  thrift_spec = (
4756
    None, # 0
4757
    (1, TType.I64, 'vendorId', None, None, ), # 1
4758
  )
4759
 
4760
  def __init__(self, vendorId=None,):
4761
    self.vendorId = vendorId
4762
 
4763
  def read(self, iprot):
4764
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
4765
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
4766
      return
4767
    iprot.readStructBegin()
4768
    while True:
4769
      (fname, ftype, fid) = iprot.readFieldBegin()
4770
      if ftype == TType.STOP:
4771
        break
4772
      if fid == 1:
4773
        if ftype == TType.I64:
4774
          self.vendorId = iprot.readI64();
4775
        else:
4776
          iprot.skip(ftype)
4777
      else:
4778
        iprot.skip(ftype)
4779
      iprot.readFieldEnd()
4780
    iprot.readStructEnd()
4781
 
4782
  def write(self, oprot):
4783
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
4784
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
4785
      return
4786
    oprot.writeStructBegin('getVendor_args')
4787
    if self.vendorId is not None:
4788
      oprot.writeFieldBegin('vendorId', TType.I64, 1)
4789
      oprot.writeI64(self.vendorId)
4790
      oprot.writeFieldEnd()
4791
    oprot.writeFieldStop()
4792
    oprot.writeStructEnd()
4793
 
4794
  def validate(self):
4795
    return
4796
 
4797
 
4798
  def __repr__(self):
4799
    L = ['%s=%r' % (key, value)
4800
      for key, value in self.__dict__.iteritems()]
4801
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
4802
 
4803
  def __eq__(self, other):
4804
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
4805
 
4806
  def __ne__(self, other):
4807
    return not (self == other)
4808
 
4809
class getVendor_result:
4810
  """
4811
  Attributes:
4812
   - success
4813
  """
4814
 
4815
  thrift_spec = (
4816
    (0, TType.STRUCT, 'success', (Vendor, Vendor.thrift_spec), None, ), # 0
4817
  )
4818
 
4819
  def __init__(self, success=None,):
4820
    self.success = success
4821
 
4822
  def read(self, iprot):
4823
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
4824
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
4825
      return
4826
    iprot.readStructBegin()
4827
    while True:
4828
      (fname, ftype, fid) = iprot.readFieldBegin()
4829
      if ftype == TType.STOP:
4830
        break
4831
      if fid == 0:
4832
        if ftype == TType.STRUCT:
4833
          self.success = Vendor()
4834
          self.success.read(iprot)
4835
        else:
4836
          iprot.skip(ftype)
4837
      else:
4838
        iprot.skip(ftype)
4839
      iprot.readFieldEnd()
4840
    iprot.readStructEnd()
4841
 
4842
  def write(self, oprot):
4843
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
4844
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
4845
      return
4846
    oprot.writeStructBegin('getVendor_result')
4847
    if self.success is not None:
4848
      oprot.writeFieldBegin('success', TType.STRUCT, 0)
4849
      self.success.write(oprot)
4850
      oprot.writeFieldEnd()
4851
    oprot.writeFieldStop()
4852
    oprot.writeStructEnd()
4853
 
4854
  def validate(self):
4855
    return
4856
 
4857
 
4858
  def __repr__(self):
4859
    L = ['%s=%r' % (key, value)
4860
      for key, value in self.__dict__.iteritems()]
4861
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
4862
 
4863
  def __eq__(self, other):
4864
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
4865
 
4866
  def __ne__(self, other):
4867
    return not (self == other)
4868
 
4869
class getAllVendors_args:
4870
 
4871
  thrift_spec = (
4872
  )
4873
 
4874
  def read(self, iprot):
4875
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
4876
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
4877
      return
4878
    iprot.readStructBegin()
4879
    while True:
4880
      (fname, ftype, fid) = iprot.readFieldBegin()
4881
      if ftype == TType.STOP:
4882
        break
4883
      else:
4884
        iprot.skip(ftype)
4885
      iprot.readFieldEnd()
4886
    iprot.readStructEnd()
4887
 
4888
  def write(self, oprot):
4889
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
4890
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
4891
      return
4892
    oprot.writeStructBegin('getAllVendors_args')
4893
    oprot.writeFieldStop()
4894
    oprot.writeStructEnd()
4895
 
4896
  def validate(self):
4897
    return
4898
 
4899
 
4900
  def __repr__(self):
4901
    L = ['%s=%r' % (key, value)
4902
      for key, value in self.__dict__.iteritems()]
4903
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
4904
 
4905
  def __eq__(self, other):
4906
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
4907
 
4908
  def __ne__(self, other):
4909
    return not (self == other)
4910
 
4911
class getAllVendors_result:
4912
  """
4913
  Attributes:
4914
   - success
4915
  """
4916
 
4917
  thrift_spec = (
4918
    (0, TType.LIST, 'success', (TType.STRUCT,(Vendor, Vendor.thrift_spec)), None, ), # 0
4919
  )
4920
 
4921
  def __init__(self, success=None,):
4922
    self.success = success
4923
 
4924
  def read(self, iprot):
4925
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
4926
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
4927
      return
4928
    iprot.readStructBegin()
4929
    while True:
4930
      (fname, ftype, fid) = iprot.readFieldBegin()
4931
      if ftype == TType.STOP:
4932
        break
4933
      if fid == 0:
4934
        if ftype == TType.LIST:
4935
          self.success = []
4936
          (_etype67, _size64) = iprot.readListBegin()
4937
          for _i68 in xrange(_size64):
4938
            _elem69 = Vendor()
4939
            _elem69.read(iprot)
4940
            self.success.append(_elem69)
4941
          iprot.readListEnd()
4942
        else:
4943
          iprot.skip(ftype)
4944
      else:
4945
        iprot.skip(ftype)
4946
      iprot.readFieldEnd()
4947
    iprot.readStructEnd()
4948
 
4949
  def write(self, oprot):
4950
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
4951
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
4952
      return
4953
    oprot.writeStructBegin('getAllVendors_result')
4954
    if self.success is not None:
4955
      oprot.writeFieldBegin('success', TType.LIST, 0)
4956
      oprot.writeListBegin(TType.STRUCT, len(self.success))
4957
      for iter70 in self.success:
4958
        iter70.write(oprot)
4959
      oprot.writeListEnd()
4960
      oprot.writeFieldEnd()
4961
    oprot.writeFieldStop()
4962
    oprot.writeStructEnd()
4963
 
4964
  def validate(self):
4965
    return
4966
 
4967
 
4968
  def __repr__(self):
4969
    L = ['%s=%r' % (key, value)
4970
      for key, value in self.__dict__.iteritems()]
4971
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
4972
 
4973
  def __eq__(self, other):
4974
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
4975
 
4976
  def __ne__(self, other):
4977
    return not (self == other)
4978
 
4979
class addVendorItemMapping_args:
4980
  """
4981
  Attributes:
4982
   - key
4983
   - vendorItemMapping
4984
  """
4985
 
4986
  thrift_spec = (
4987
    None, # 0
4988
    (1, TType.STRING, 'key', None, None, ), # 1
4989
    (2, TType.STRUCT, 'vendorItemMapping', (VendorItemMapping, VendorItemMapping.thrift_spec), None, ), # 2
4990
  )
4991
 
4992
  def __init__(self, key=None, vendorItemMapping=None,):
4993
    self.key = key
4994
    self.vendorItemMapping = vendorItemMapping
4995
 
4996
  def read(self, iprot):
4997
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
4998
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
4999
      return
5000
    iprot.readStructBegin()
5001
    while True:
5002
      (fname, ftype, fid) = iprot.readFieldBegin()
5003
      if ftype == TType.STOP:
5004
        break
5005
      if fid == 1:
5006
        if ftype == TType.STRING:
5007
          self.key = iprot.readString();
5008
        else:
5009
          iprot.skip(ftype)
5010
      elif fid == 2:
5011
        if ftype == TType.STRUCT:
5012
          self.vendorItemMapping = VendorItemMapping()
5013
          self.vendorItemMapping.read(iprot)
5014
        else:
5015
          iprot.skip(ftype)
5016
      else:
5017
        iprot.skip(ftype)
5018
      iprot.readFieldEnd()
5019
    iprot.readStructEnd()
5020
 
5021
  def write(self, oprot):
5022
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
5023
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
5024
      return
5025
    oprot.writeStructBegin('addVendorItemMapping_args')
5026
    if self.key is not None:
5027
      oprot.writeFieldBegin('key', TType.STRING, 1)
5028
      oprot.writeString(self.key)
5029
      oprot.writeFieldEnd()
5030
    if self.vendorItemMapping is not None:
5031
      oprot.writeFieldBegin('vendorItemMapping', TType.STRUCT, 2)
5032
      self.vendorItemMapping.write(oprot)
5033
      oprot.writeFieldEnd()
5034
    oprot.writeFieldStop()
5035
    oprot.writeStructEnd()
5036
 
5037
  def validate(self):
5038
    return
5039
 
5040
 
5041
  def __repr__(self):
5042
    L = ['%s=%r' % (key, value)
5043
      for key, value in self.__dict__.iteritems()]
5044
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
5045
 
5046
  def __eq__(self, other):
5047
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
5048
 
5049
  def __ne__(self, other):
5050
    return not (self == other)
5051
 
5052
class addVendorItemMapping_result:
5053
  """
5054
  Attributes:
5055
   - cex
5056
  """
5057
 
5058
  thrift_spec = (
5059
    None, # 0
5060
    (1, TType.STRUCT, 'cex', (InventoryServiceException, InventoryServiceException.thrift_spec), None, ), # 1
5061
  )
5062
 
5063
  def __init__(self, cex=None,):
5064
    self.cex = cex
5065
 
5066
  def read(self, iprot):
5067
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
5068
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
5069
      return
5070
    iprot.readStructBegin()
5071
    while True:
5072
      (fname, ftype, fid) = iprot.readFieldBegin()
5073
      if ftype == TType.STOP:
5074
        break
5075
      if fid == 1:
5076
        if ftype == TType.STRUCT:
5077
          self.cex = InventoryServiceException()
5078
          self.cex.read(iprot)
5079
        else:
5080
          iprot.skip(ftype)
5081
      else:
5082
        iprot.skip(ftype)
5083
      iprot.readFieldEnd()
5084
    iprot.readStructEnd()
5085
 
5086
  def write(self, oprot):
5087
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
5088
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
5089
      return
5090
    oprot.writeStructBegin('addVendorItemMapping_result')
5091
    if self.cex is not None:
5092
      oprot.writeFieldBegin('cex', TType.STRUCT, 1)
5093
      self.cex.write(oprot)
5094
      oprot.writeFieldEnd()
5095
    oprot.writeFieldStop()
5096
    oprot.writeStructEnd()
5097
 
5098
  def validate(self):
5099
    return
5100
 
5101
 
5102
  def __repr__(self):
5103
    L = ['%s=%r' % (key, value)
5104
      for key, value in self.__dict__.iteritems()]
5105
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
5106
 
5107
  def __eq__(self, other):
5108
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
5109
 
5110
  def __ne__(self, other):
5111
    return not (self == other)
5112
 
5113
class getVendorItemMappings_args:
5114
  """
5115
  Attributes:
5116
   - itemId
5117
  """
5118
 
5119
  thrift_spec = (
5120
    None, # 0
5121
    (1, TType.I64, 'itemId', None, None, ), # 1
5122
  )
5123
 
5124
  def __init__(self, itemId=None,):
5125
    self.itemId = itemId
5126
 
5127
  def read(self, iprot):
5128
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
5129
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
5130
      return
5131
    iprot.readStructBegin()
5132
    while True:
5133
      (fname, ftype, fid) = iprot.readFieldBegin()
5134
      if ftype == TType.STOP:
5135
        break
5136
      if fid == 1:
5137
        if ftype == TType.I64:
5138
          self.itemId = iprot.readI64();
5139
        else:
5140
          iprot.skip(ftype)
5141
      else:
5142
        iprot.skip(ftype)
5143
      iprot.readFieldEnd()
5144
    iprot.readStructEnd()
5145
 
5146
  def write(self, oprot):
5147
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
5148
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
5149
      return
5150
    oprot.writeStructBegin('getVendorItemMappings_args')
5151
    if self.itemId is not None:
5152
      oprot.writeFieldBegin('itemId', TType.I64, 1)
5153
      oprot.writeI64(self.itemId)
5154
      oprot.writeFieldEnd()
5155
    oprot.writeFieldStop()
5156
    oprot.writeStructEnd()
5157
 
5158
  def validate(self):
5159
    return
5160
 
5161
 
5162
  def __repr__(self):
5163
    L = ['%s=%r' % (key, value)
5164
      for key, value in self.__dict__.iteritems()]
5165
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
5166
 
5167
  def __eq__(self, other):
5168
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
5169
 
5170
  def __ne__(self, other):
5171
    return not (self == other)
5172
 
5173
class getVendorItemMappings_result:
5174
  """
5175
  Attributes:
5176
   - success
5177
   - cex
5178
  """
5179
 
5180
  thrift_spec = (
5181
    (0, TType.LIST, 'success', (TType.STRUCT,(VendorItemMapping, VendorItemMapping.thrift_spec)), None, ), # 0
5182
    (1, TType.STRUCT, 'cex', (InventoryServiceException, InventoryServiceException.thrift_spec), None, ), # 1
5183
  )
5184
 
5185
  def __init__(self, success=None, cex=None,):
5186
    self.success = success
5187
    self.cex = cex
5188
 
5189
  def read(self, iprot):
5190
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
5191
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
5192
      return
5193
    iprot.readStructBegin()
5194
    while True:
5195
      (fname, ftype, fid) = iprot.readFieldBegin()
5196
      if ftype == TType.STOP:
5197
        break
5198
      if fid == 0:
5199
        if ftype == TType.LIST:
5200
          self.success = []
5201
          (_etype74, _size71) = iprot.readListBegin()
5202
          for _i75 in xrange(_size71):
5203
            _elem76 = VendorItemMapping()
5204
            _elem76.read(iprot)
5205
            self.success.append(_elem76)
5206
          iprot.readListEnd()
5207
        else:
5208
          iprot.skip(ftype)
5209
      elif fid == 1:
5210
        if ftype == TType.STRUCT:
5211
          self.cex = InventoryServiceException()
5212
          self.cex.read(iprot)
5213
        else:
5214
          iprot.skip(ftype)
5215
      else:
5216
        iprot.skip(ftype)
5217
      iprot.readFieldEnd()
5218
    iprot.readStructEnd()
5219
 
5220
  def write(self, oprot):
5221
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
5222
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
5223
      return
5224
    oprot.writeStructBegin('getVendorItemMappings_result')
5225
    if self.success is not None:
5226
      oprot.writeFieldBegin('success', TType.LIST, 0)
5227
      oprot.writeListBegin(TType.STRUCT, len(self.success))
5228
      for iter77 in self.success:
5229
        iter77.write(oprot)
5230
      oprot.writeListEnd()
5231
      oprot.writeFieldEnd()
5232
    if self.cex is not None:
5233
      oprot.writeFieldBegin('cex', TType.STRUCT, 1)
5234
      self.cex.write(oprot)
5235
      oprot.writeFieldEnd()
5236
    oprot.writeFieldStop()
5237
    oprot.writeStructEnd()
5238
 
5239
  def validate(self):
5240
    return
5241
 
5242
 
5243
  def __repr__(self):
5244
    L = ['%s=%r' % (key, value)
5245
      for key, value in self.__dict__.iteritems()]
5246
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
5247
 
5248
  def __eq__(self, other):
5249
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
5250
 
5251
  def __ne__(self, other):
5252
    return not (self == other)
5253
 
5254
class getPendingOrdersInventory_args:
5255
  """
5256
  Attributes:
5257
   - vendorid
5258
  """
5259
 
5260
  thrift_spec = (
5261
    None, # 0
5262
    (1, TType.I64, 'vendorid', None, None, ), # 1
5263
  )
5264
 
5265
  def __init__(self, vendorid=None,):
5266
    self.vendorid = vendorid
5267
 
5268
  def read(self, iprot):
5269
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
5270
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
5271
      return
5272
    iprot.readStructBegin()
5273
    while True:
5274
      (fname, ftype, fid) = iprot.readFieldBegin()
5275
      if ftype == TType.STOP:
5276
        break
5277
      if fid == 1:
5278
        if ftype == TType.I64:
5279
          self.vendorid = iprot.readI64();
5280
        else:
5281
          iprot.skip(ftype)
5282
      else:
5283
        iprot.skip(ftype)
5284
      iprot.readFieldEnd()
5285
    iprot.readStructEnd()
5286
 
5287
  def write(self, oprot):
5288
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
5289
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
5290
      return
5291
    oprot.writeStructBegin('getPendingOrdersInventory_args')
5292
    if self.vendorid is not None:
5293
      oprot.writeFieldBegin('vendorid', TType.I64, 1)
5294
      oprot.writeI64(self.vendorid)
5295
      oprot.writeFieldEnd()
5296
    oprot.writeFieldStop()
5297
    oprot.writeStructEnd()
5298
 
5299
  def validate(self):
5300
    return
5301
 
5302
 
5303
  def __repr__(self):
5304
    L = ['%s=%r' % (key, value)
5305
      for key, value in self.__dict__.iteritems()]
5306
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
5307
 
5308
  def __eq__(self, other):
5309
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
5310
 
5311
  def __ne__(self, other):
5312
    return not (self == other)
5313
 
5314
class getPendingOrdersInventory_result:
5315
  """
5316
  Attributes:
5317
   - success
5318
  """
5319
 
5320
  thrift_spec = (
5321
    (0, TType.LIST, 'success', (TType.STRUCT,(AvailableAndReservedStock, AvailableAndReservedStock.thrift_spec)), None, ), # 0
5322
  )
5323
 
5324
  def __init__(self, success=None,):
5325
    self.success = success
5326
 
5327
  def read(self, iprot):
5328
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
5329
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
5330
      return
5331
    iprot.readStructBegin()
5332
    while True:
5333
      (fname, ftype, fid) = iprot.readFieldBegin()
5334
      if ftype == TType.STOP:
5335
        break
5336
      if fid == 0:
5337
        if ftype == TType.LIST:
5338
          self.success = []
5339
          (_etype81, _size78) = iprot.readListBegin()
5340
          for _i82 in xrange(_size78):
5341
            _elem83 = AvailableAndReservedStock()
5342
            _elem83.read(iprot)
5343
            self.success.append(_elem83)
5344
          iprot.readListEnd()
5345
        else:
5346
          iprot.skip(ftype)
5347
      else:
5348
        iprot.skip(ftype)
5349
      iprot.readFieldEnd()
5350
    iprot.readStructEnd()
5351
 
5352
  def write(self, oprot):
5353
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
5354
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
5355
      return
5356
    oprot.writeStructBegin('getPendingOrdersInventory_result')
5357
    if self.success is not None:
5358
      oprot.writeFieldBegin('success', TType.LIST, 0)
5359
      oprot.writeListBegin(TType.STRUCT, len(self.success))
5360
      for iter84 in self.success:
5361
        iter84.write(oprot)
5362
      oprot.writeListEnd()
5363
      oprot.writeFieldEnd()
5364
    oprot.writeFieldStop()
5365
    oprot.writeStructEnd()
5366
 
5367
  def validate(self):
5368
    return
5369
 
5370
 
5371
  def __repr__(self):
5372
    L = ['%s=%r' % (key, value)
5373
      for key, value in self.__dict__.iteritems()]
5374
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
5375
 
5376
  def __eq__(self, other):
5377
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
5378
 
5379
  def __ne__(self, other):
5380
    return not (self == other)
5381
 
5382
class getWarehouses_args:
5383
  """
5384
  Attributes:
5385
   - warehouseType
5386
   - inventoryType
5387
   - vendorId
5388
   - billingWarehouseId
5389
   - shippingWarehouseId
5390
  """
5391
 
5392
  thrift_spec = (
5393
    None, # 0
5394
    (1, TType.I32, 'warehouseType', None, None, ), # 1
5395
    (2, TType.I32, 'inventoryType', None, None, ), # 2
5396
    (3, TType.I64, 'vendorId', None, None, ), # 3
5397
    (4, TType.I64, 'billingWarehouseId', None, None, ), # 4
5398
    (5, TType.I64, 'shippingWarehouseId', None, None, ), # 5
5399
  )
5400
 
5401
  def __init__(self, warehouseType=None, inventoryType=None, vendorId=None, billingWarehouseId=None, shippingWarehouseId=None,):
5402
    self.warehouseType = warehouseType
5403
    self.inventoryType = inventoryType
5404
    self.vendorId = vendorId
5405
    self.billingWarehouseId = billingWarehouseId
5406
    self.shippingWarehouseId = shippingWarehouseId
5407
 
5408
  def read(self, iprot):
5409
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
5410
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
5411
      return
5412
    iprot.readStructBegin()
5413
    while True:
5414
      (fname, ftype, fid) = iprot.readFieldBegin()
5415
      if ftype == TType.STOP:
5416
        break
5417
      if fid == 1:
5418
        if ftype == TType.I32:
5419
          self.warehouseType = iprot.readI32();
5420
        else:
5421
          iprot.skip(ftype)
5422
      elif fid == 2:
5423
        if ftype == TType.I32:
5424
          self.inventoryType = iprot.readI32();
5425
        else:
5426
          iprot.skip(ftype)
5427
      elif fid == 3:
5428
        if ftype == TType.I64:
5429
          self.vendorId = iprot.readI64();
5430
        else:
5431
          iprot.skip(ftype)
5432
      elif fid == 4:
5433
        if ftype == TType.I64:
5434
          self.billingWarehouseId = iprot.readI64();
5435
        else:
5436
          iprot.skip(ftype)
5437
      elif fid == 5:
5438
        if ftype == TType.I64:
5439
          self.shippingWarehouseId = iprot.readI64();
5440
        else:
5441
          iprot.skip(ftype)
5442
      else:
5443
        iprot.skip(ftype)
5444
      iprot.readFieldEnd()
5445
    iprot.readStructEnd()
5446
 
5447
  def write(self, oprot):
5448
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
5449
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
5450
      return
5451
    oprot.writeStructBegin('getWarehouses_args')
5452
    if self.warehouseType is not None:
5453
      oprot.writeFieldBegin('warehouseType', TType.I32, 1)
5454
      oprot.writeI32(self.warehouseType)
5455
      oprot.writeFieldEnd()
5456
    if self.inventoryType is not None:
5457
      oprot.writeFieldBegin('inventoryType', TType.I32, 2)
5458
      oprot.writeI32(self.inventoryType)
5459
      oprot.writeFieldEnd()
5460
    if self.vendorId is not None:
5461
      oprot.writeFieldBegin('vendorId', TType.I64, 3)
5462
      oprot.writeI64(self.vendorId)
5463
      oprot.writeFieldEnd()
5464
    if self.billingWarehouseId is not None:
5465
      oprot.writeFieldBegin('billingWarehouseId', TType.I64, 4)
5466
      oprot.writeI64(self.billingWarehouseId)
5467
      oprot.writeFieldEnd()
5468
    if self.shippingWarehouseId is not None:
5469
      oprot.writeFieldBegin('shippingWarehouseId', TType.I64, 5)
5470
      oprot.writeI64(self.shippingWarehouseId)
5471
      oprot.writeFieldEnd()
5472
    oprot.writeFieldStop()
5473
    oprot.writeStructEnd()
5474
 
5475
  def validate(self):
5476
    return
5477
 
5478
 
5479
  def __repr__(self):
5480
    L = ['%s=%r' % (key, value)
5481
      for key, value in self.__dict__.iteritems()]
5482
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
5483
 
5484
  def __eq__(self, other):
5485
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
5486
 
5487
  def __ne__(self, other):
5488
    return not (self == other)
5489
 
5490
class getWarehouses_result:
5491
  """
5492
  Attributes:
5493
   - success
5494
  """
5495
 
5496
  thrift_spec = (
5497
    (0, TType.LIST, 'success', (TType.STRUCT,(Warehouse, Warehouse.thrift_spec)), None, ), # 0
5498
  )
5499
 
5500
  def __init__(self, success=None,):
5501
    self.success = success
5502
 
5503
  def read(self, iprot):
5504
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
5505
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
5506
      return
5507
    iprot.readStructBegin()
5508
    while True:
5509
      (fname, ftype, fid) = iprot.readFieldBegin()
5510
      if ftype == TType.STOP:
5511
        break
5512
      if fid == 0:
5513
        if ftype == TType.LIST:
5514
          self.success = []
5515
          (_etype88, _size85) = iprot.readListBegin()
5516
          for _i89 in xrange(_size85):
5517
            _elem90 = Warehouse()
5518
            _elem90.read(iprot)
5519
            self.success.append(_elem90)
5520
          iprot.readListEnd()
5521
        else:
5522
          iprot.skip(ftype)
5523
      else:
5524
        iprot.skip(ftype)
5525
      iprot.readFieldEnd()
5526
    iprot.readStructEnd()
5527
 
5528
  def write(self, oprot):
5529
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
5530
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
5531
      return
5532
    oprot.writeStructBegin('getWarehouses_result')
5533
    if self.success is not None:
5534
      oprot.writeFieldBegin('success', TType.LIST, 0)
5535
      oprot.writeListBegin(TType.STRUCT, len(self.success))
5536
      for iter91 in self.success:
5537
        iter91.write(oprot)
5538
      oprot.writeListEnd()
5539
      oprot.writeFieldEnd()
5540
    oprot.writeFieldStop()
5541
    oprot.writeStructEnd()
5542
 
5543
  def validate(self):
5544
    return
5545
 
5546
 
5547
  def __repr__(self):
5548
    L = ['%s=%r' % (key, value)
5549
      for key, value in self.__dict__.iteritems()]
5550
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
5551
 
5552
  def __eq__(self, other):
5553
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
5554
 
5555
  def __ne__(self, other):
5556
    return not (self == other)
5557
 
5558
class resetAvailability_args:
5559
  """
5560
  Attributes:
5561
   - itemKey
5562
   - vendorId
5563
   - quantity
5564
   - warehouseId
5565
  """
5566
 
5567
  thrift_spec = (
5568
    None, # 0
5569
    (1, TType.STRING, 'itemKey', None, None, ), # 1
5570
    (2, TType.I64, 'vendorId', None, None, ), # 2
5571
    (3, TType.I64, 'quantity', None, None, ), # 3
5572
    (4, TType.I64, 'warehouseId', None, None, ), # 4
5573
  )
5574
 
5575
  def __init__(self, itemKey=None, vendorId=None, quantity=None, warehouseId=None,):
5576
    self.itemKey = itemKey
5577
    self.vendorId = vendorId
5578
    self.quantity = quantity
5579
    self.warehouseId = warehouseId
5580
 
5581
  def read(self, iprot):
5582
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
5583
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
5584
      return
5585
    iprot.readStructBegin()
5586
    while True:
5587
      (fname, ftype, fid) = iprot.readFieldBegin()
5588
      if ftype == TType.STOP:
5589
        break
5590
      if fid == 1:
5591
        if ftype == TType.STRING:
5592
          self.itemKey = iprot.readString();
5593
        else:
5594
          iprot.skip(ftype)
5595
      elif fid == 2:
5596
        if ftype == TType.I64:
5597
          self.vendorId = iprot.readI64();
5598
        else:
5599
          iprot.skip(ftype)
5600
      elif fid == 3:
5601
        if ftype == TType.I64:
5602
          self.quantity = iprot.readI64();
5603
        else:
5604
          iprot.skip(ftype)
5605
      elif fid == 4:
5606
        if ftype == TType.I64:
5607
          self.warehouseId = iprot.readI64();
5608
        else:
5609
          iprot.skip(ftype)
5610
      else:
5611
        iprot.skip(ftype)
5612
      iprot.readFieldEnd()
5613
    iprot.readStructEnd()
5614
 
5615
  def write(self, oprot):
5616
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
5617
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
5618
      return
5619
    oprot.writeStructBegin('resetAvailability_args')
5620
    if self.itemKey is not None:
5621
      oprot.writeFieldBegin('itemKey', TType.STRING, 1)
5622
      oprot.writeString(self.itemKey)
5623
      oprot.writeFieldEnd()
5624
    if self.vendorId is not None:
5625
      oprot.writeFieldBegin('vendorId', TType.I64, 2)
5626
      oprot.writeI64(self.vendorId)
5627
      oprot.writeFieldEnd()
5628
    if self.quantity is not None:
5629
      oprot.writeFieldBegin('quantity', TType.I64, 3)
5630
      oprot.writeI64(self.quantity)
5631
      oprot.writeFieldEnd()
5632
    if self.warehouseId is not None:
5633
      oprot.writeFieldBegin('warehouseId', TType.I64, 4)
5634
      oprot.writeI64(self.warehouseId)
5635
      oprot.writeFieldEnd()
5636
    oprot.writeFieldStop()
5637
    oprot.writeStructEnd()
5638
 
5639
  def validate(self):
5640
    return
5641
 
5642
 
5643
  def __repr__(self):
5644
    L = ['%s=%r' % (key, value)
5645
      for key, value in self.__dict__.iteritems()]
5646
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
5647
 
5648
  def __eq__(self, other):
5649
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
5650
 
5651
  def __ne__(self, other):
5652
    return not (self == other)
5653
 
5654
class resetAvailability_result:
5655
  """
5656
  Attributes:
5657
   - cex
5658
  """
5659
 
5660
  thrift_spec = (
5661
    None, # 0
5662
    (1, TType.STRUCT, 'cex', (InventoryServiceException, InventoryServiceException.thrift_spec), None, ), # 1
5663
  )
5664
 
5665
  def __init__(self, cex=None,):
5666
    self.cex = cex
5667
 
5668
  def read(self, iprot):
5669
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
5670
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
5671
      return
5672
    iprot.readStructBegin()
5673
    while True:
5674
      (fname, ftype, fid) = iprot.readFieldBegin()
5675
      if ftype == TType.STOP:
5676
        break
5677
      if fid == 1:
5678
        if ftype == TType.STRUCT:
5679
          self.cex = InventoryServiceException()
5680
          self.cex.read(iprot)
5681
        else:
5682
          iprot.skip(ftype)
5683
      else:
5684
        iprot.skip(ftype)
5685
      iprot.readFieldEnd()
5686
    iprot.readStructEnd()
5687
 
5688
  def write(self, oprot):
5689
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
5690
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
5691
      return
5692
    oprot.writeStructBegin('resetAvailability_result')
5693
    if self.cex is not None:
5694
      oprot.writeFieldBegin('cex', TType.STRUCT, 1)
5695
      self.cex.write(oprot)
5696
      oprot.writeFieldEnd()
5697
    oprot.writeFieldStop()
5698
    oprot.writeStructEnd()
5699
 
5700
  def validate(self):
5701
    return
5702
 
5703
 
5704
  def __repr__(self):
5705
    L = ['%s=%r' % (key, value)
5706
      for key, value in self.__dict__.iteritems()]
5707
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
5708
 
5709
  def __eq__(self, other):
5710
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
5711
 
5712
  def __ne__(self, other):
5713
    return not (self == other)
5714
 
5715
class resetAvailabilityForWarehouse_args:
5716
  """
5717
  Attributes:
5718
   - warehouseId
5719
  """
5720
 
5721
  thrift_spec = (
5722
    None, # 0
5723
    (1, TType.I64, 'warehouseId', None, None, ), # 1
5724
  )
5725
 
5726
  def __init__(self, warehouseId=None,):
5727
    self.warehouseId = warehouseId
5728
 
5729
  def read(self, iprot):
5730
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
5731
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
5732
      return
5733
    iprot.readStructBegin()
5734
    while True:
5735
      (fname, ftype, fid) = iprot.readFieldBegin()
5736
      if ftype == TType.STOP:
5737
        break
5738
      if fid == 1:
5739
        if ftype == TType.I64:
5740
          self.warehouseId = iprot.readI64();
5741
        else:
5742
          iprot.skip(ftype)
5743
      else:
5744
        iprot.skip(ftype)
5745
      iprot.readFieldEnd()
5746
    iprot.readStructEnd()
5747
 
5748
  def write(self, oprot):
5749
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
5750
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
5751
      return
5752
    oprot.writeStructBegin('resetAvailabilityForWarehouse_args')
5753
    if self.warehouseId is not None:
5754
      oprot.writeFieldBegin('warehouseId', TType.I64, 1)
5755
      oprot.writeI64(self.warehouseId)
5756
      oprot.writeFieldEnd()
5757
    oprot.writeFieldStop()
5758
    oprot.writeStructEnd()
5759
 
5760
  def validate(self):
5761
    return
5762
 
5763
 
5764
  def __repr__(self):
5765
    L = ['%s=%r' % (key, value)
5766
      for key, value in self.__dict__.iteritems()]
5767
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
5768
 
5769
  def __eq__(self, other):
5770
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
5771
 
5772
  def __ne__(self, other):
5773
    return not (self == other)
5774
 
5775
class resetAvailabilityForWarehouse_result:
5776
  """
5777
  Attributes:
5778
   - cex
5779
  """
5780
 
5781
  thrift_spec = (
5782
    None, # 0
5783
    (1, TType.STRUCT, 'cex', (InventoryServiceException, InventoryServiceException.thrift_spec), None, ), # 1
5784
  )
5785
 
5786
  def __init__(self, cex=None,):
5787
    self.cex = cex
5788
 
5789
  def read(self, iprot):
5790
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
5791
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
5792
      return
5793
    iprot.readStructBegin()
5794
    while True:
5795
      (fname, ftype, fid) = iprot.readFieldBegin()
5796
      if ftype == TType.STOP:
5797
        break
5798
      if fid == 1:
5799
        if ftype == TType.STRUCT:
5800
          self.cex = InventoryServiceException()
5801
          self.cex.read(iprot)
5802
        else:
5803
          iprot.skip(ftype)
5804
      else:
5805
        iprot.skip(ftype)
5806
      iprot.readFieldEnd()
5807
    iprot.readStructEnd()
5808
 
5809
  def write(self, oprot):
5810
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
5811
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
5812
      return
5813
    oprot.writeStructBegin('resetAvailabilityForWarehouse_result')
5814
    if self.cex is not None:
5815
      oprot.writeFieldBegin('cex', TType.STRUCT, 1)
5816
      self.cex.write(oprot)
5817
      oprot.writeFieldEnd()
5818
    oprot.writeFieldStop()
5819
    oprot.writeStructEnd()
5820
 
5821
  def validate(self):
5822
    return
5823
 
5824
 
5825
  def __repr__(self):
5826
    L = ['%s=%r' % (key, value)
5827
      for key, value in self.__dict__.iteritems()]
5828
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
5829
 
5830
  def __eq__(self, other):
5831
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
5832
 
5833
  def __ne__(self, other):
5834
    return not (self == other)
5835
 
5836
class getItemKeysToBeProcessed_args:
5837
  """
5838
  Attributes:
5839
   - warehouseId
5840
  """
5841
 
5842
  thrift_spec = (
5843
    None, # 0
5844
    (1, TType.I64, 'warehouseId', None, None, ), # 1
5845
  )
5846
 
5847
  def __init__(self, warehouseId=None,):
5848
    self.warehouseId = warehouseId
5849
 
5850
  def read(self, iprot):
5851
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
5852
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
5853
      return
5854
    iprot.readStructBegin()
5855
    while True:
5856
      (fname, ftype, fid) = iprot.readFieldBegin()
5857
      if ftype == TType.STOP:
5858
        break
5859
      if fid == 1:
5860
        if ftype == TType.I64:
5861
          self.warehouseId = iprot.readI64();
5862
        else:
5863
          iprot.skip(ftype)
5864
      else:
5865
        iprot.skip(ftype)
5866
      iprot.readFieldEnd()
5867
    iprot.readStructEnd()
5868
 
5869
  def write(self, oprot):
5870
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
5871
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
5872
      return
5873
    oprot.writeStructBegin('getItemKeysToBeProcessed_args')
5874
    if self.warehouseId is not None:
5875
      oprot.writeFieldBegin('warehouseId', TType.I64, 1)
5876
      oprot.writeI64(self.warehouseId)
5877
      oprot.writeFieldEnd()
5878
    oprot.writeFieldStop()
5879
    oprot.writeStructEnd()
5880
 
5881
  def validate(self):
5882
    return
5883
 
5884
 
5885
  def __repr__(self):
5886
    L = ['%s=%r' % (key, value)
5887
      for key, value in self.__dict__.iteritems()]
5888
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
5889
 
5890
  def __eq__(self, other):
5891
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
5892
 
5893
  def __ne__(self, other):
5894
    return not (self == other)
5895
 
5896
class getItemKeysToBeProcessed_result:
5897
  """
5898
  Attributes:
5899
   - success
5900
  """
5901
 
5902
  thrift_spec = (
5903
    (0, TType.LIST, 'success', (TType.STRING,None), None, ), # 0
5904
  )
5905
 
5906
  def __init__(self, success=None,):
5907
    self.success = success
5908
 
5909
  def read(self, iprot):
5910
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
5911
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
5912
      return
5913
    iprot.readStructBegin()
5914
    while True:
5915
      (fname, ftype, fid) = iprot.readFieldBegin()
5916
      if ftype == TType.STOP:
5917
        break
5918
      if fid == 0:
5919
        if ftype == TType.LIST:
5920
          self.success = []
5921
          (_etype95, _size92) = iprot.readListBegin()
5922
          for _i96 in xrange(_size92):
5923
            _elem97 = iprot.readString();
5924
            self.success.append(_elem97)
5925
          iprot.readListEnd()
5926
        else:
5927
          iprot.skip(ftype)
5928
      else:
5929
        iprot.skip(ftype)
5930
      iprot.readFieldEnd()
5931
    iprot.readStructEnd()
5932
 
5933
  def write(self, oprot):
5934
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
5935
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
5936
      return
5937
    oprot.writeStructBegin('getItemKeysToBeProcessed_result')
5938
    if self.success is not None:
5939
      oprot.writeFieldBegin('success', TType.LIST, 0)
5940
      oprot.writeListBegin(TType.STRING, len(self.success))
5941
      for iter98 in self.success:
5942
        oprot.writeString(iter98)
5943
      oprot.writeListEnd()
5944
      oprot.writeFieldEnd()
5945
    oprot.writeFieldStop()
5946
    oprot.writeStructEnd()
5947
 
5948
  def validate(self):
5949
    return
5950
 
5951
 
5952
  def __repr__(self):
5953
    L = ['%s=%r' % (key, value)
5954
      for key, value in self.__dict__.iteritems()]
5955
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
5956
 
5957
  def __eq__(self, other):
5958
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
5959
 
5960
  def __ne__(self, other):
5961
    return not (self == other)
5962
 
5963
class markMissedInventoryUpdatesAsProcessed_args:
5964
  """
5965
  Attributes:
5966
   - itemKey
5967
   - warehouseId
5968
  """
5969
 
5970
  thrift_spec = (
5971
    None, # 0
5972
    (1, TType.STRING, 'itemKey', None, None, ), # 1
5973
    (2, TType.I64, 'warehouseId', None, None, ), # 2
5974
  )
5975
 
5976
  def __init__(self, itemKey=None, warehouseId=None,):
5977
    self.itemKey = itemKey
5978
    self.warehouseId = warehouseId
5979
 
5980
  def read(self, iprot):
5981
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
5982
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
5983
      return
5984
    iprot.readStructBegin()
5985
    while True:
5986
      (fname, ftype, fid) = iprot.readFieldBegin()
5987
      if ftype == TType.STOP:
5988
        break
5989
      if fid == 1:
5990
        if ftype == TType.STRING:
5991
          self.itemKey = iprot.readString();
5992
        else:
5993
          iprot.skip(ftype)
5994
      elif fid == 2:
5995
        if ftype == TType.I64:
5996
          self.warehouseId = iprot.readI64();
5997
        else:
5998
          iprot.skip(ftype)
5999
      else:
6000
        iprot.skip(ftype)
6001
      iprot.readFieldEnd()
6002
    iprot.readStructEnd()
6003
 
6004
  def write(self, oprot):
6005
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
6006
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
6007
      return
6008
    oprot.writeStructBegin('markMissedInventoryUpdatesAsProcessed_args')
6009
    if self.itemKey is not None:
6010
      oprot.writeFieldBegin('itemKey', TType.STRING, 1)
6011
      oprot.writeString(self.itemKey)
6012
      oprot.writeFieldEnd()
6013
    if self.warehouseId is not None:
6014
      oprot.writeFieldBegin('warehouseId', TType.I64, 2)
6015
      oprot.writeI64(self.warehouseId)
6016
      oprot.writeFieldEnd()
6017
    oprot.writeFieldStop()
6018
    oprot.writeStructEnd()
6019
 
6020
  def validate(self):
6021
    return
6022
 
6023
 
6024
  def __repr__(self):
6025
    L = ['%s=%r' % (key, value)
6026
      for key, value in self.__dict__.iteritems()]
6027
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
6028
 
6029
  def __eq__(self, other):
6030
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
6031
 
6032
  def __ne__(self, other):
6033
    return not (self == other)
6034
 
6035
class markMissedInventoryUpdatesAsProcessed_result:
6036
 
6037
  thrift_spec = (
6038
  )
6039
 
6040
  def read(self, iprot):
6041
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
6042
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
6043
      return
6044
    iprot.readStructBegin()
6045
    while True:
6046
      (fname, ftype, fid) = iprot.readFieldBegin()
6047
      if ftype == TType.STOP:
6048
        break
6049
      else:
6050
        iprot.skip(ftype)
6051
      iprot.readFieldEnd()
6052
    iprot.readStructEnd()
6053
 
6054
  def write(self, oprot):
6055
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
6056
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
6057
      return
6058
    oprot.writeStructBegin('markMissedInventoryUpdatesAsProcessed_result')
6059
    oprot.writeFieldStop()
6060
    oprot.writeStructEnd()
6061
 
6062
  def validate(self):
6063
    return
6064
 
6065
 
6066
  def __repr__(self):
6067
    L = ['%s=%r' % (key, value)
6068
      for key, value in self.__dict__.iteritems()]
6069
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
6070
 
6071
  def __eq__(self, other):
6072
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
6073
 
6074
  def __ne__(self, other):
6075
    return not (self == other)
6076
 
6077
class getIgnoredItemKeys_args:
6078
 
6079
  thrift_spec = (
6080
  )
6081
 
6082
  def read(self, iprot):
6083
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
6084
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
6085
      return
6086
    iprot.readStructBegin()
6087
    while True:
6088
      (fname, ftype, fid) = iprot.readFieldBegin()
6089
      if ftype == TType.STOP:
6090
        break
6091
      else:
6092
        iprot.skip(ftype)
6093
      iprot.readFieldEnd()
6094
    iprot.readStructEnd()
6095
 
6096
  def write(self, oprot):
6097
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
6098
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
6099
      return
6100
    oprot.writeStructBegin('getIgnoredItemKeys_args')
6101
    oprot.writeFieldStop()
6102
    oprot.writeStructEnd()
6103
 
6104
  def validate(self):
6105
    return
6106
 
6107
 
6108
  def __repr__(self):
6109
    L = ['%s=%r' % (key, value)
6110
      for key, value in self.__dict__.iteritems()]
6111
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
6112
 
6113
  def __eq__(self, other):
6114
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
6115
 
6116
  def __ne__(self, other):
6117
    return not (self == other)
6118
 
6119
class getIgnoredItemKeys_result:
6120
  """
6121
  Attributes:
6122
   - success
6123
  """
6124
 
6125
  thrift_spec = (
6126
    (0, TType.MAP, 'success', (TType.STRING,None,TType.MAP,(TType.I64,None,TType.I64,None)), None, ), # 0
6127
  )
6128
 
6129
  def __init__(self, success=None,):
6130
    self.success = success
6131
 
6132
  def read(self, iprot):
6133
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
6134
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
6135
      return
6136
    iprot.readStructBegin()
6137
    while True:
6138
      (fname, ftype, fid) = iprot.readFieldBegin()
6139
      if ftype == TType.STOP:
6140
        break
6141
      if fid == 0:
6142
        if ftype == TType.MAP:
6143
          self.success = {}
6144
          (_ktype100, _vtype101, _size99 ) = iprot.readMapBegin() 
6145
          for _i103 in xrange(_size99):
6146
            _key104 = iprot.readString();
6147
            _val105 = {}
6148
            (_ktype107, _vtype108, _size106 ) = iprot.readMapBegin() 
6149
            for _i110 in xrange(_size106):
6150
              _key111 = iprot.readI64();
6151
              _val112 = iprot.readI64();
6152
              _val105[_key111] = _val112
6153
            iprot.readMapEnd()
6154
            self.success[_key104] = _val105
6155
          iprot.readMapEnd()
6156
        else:
6157
          iprot.skip(ftype)
6158
      else:
6159
        iprot.skip(ftype)
6160
      iprot.readFieldEnd()
6161
    iprot.readStructEnd()
6162
 
6163
  def write(self, oprot):
6164
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
6165
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
6166
      return
6167
    oprot.writeStructBegin('getIgnoredItemKeys_result')
6168
    if self.success is not None:
6169
      oprot.writeFieldBegin('success', TType.MAP, 0)
6170
      oprot.writeMapBegin(TType.STRING, TType.MAP, len(self.success))
6171
      for kiter113,viter114 in self.success.items():
6172
        oprot.writeString(kiter113)
6173
        oprot.writeMapBegin(TType.I64, TType.I64, len(viter114))
6174
        for kiter115,viter116 in viter114.items():
6175
          oprot.writeI64(kiter115)
6176
          oprot.writeI64(viter116)
6177
        oprot.writeMapEnd()
6178
      oprot.writeMapEnd()
6179
      oprot.writeFieldEnd()
6180
    oprot.writeFieldStop()
6181
    oprot.writeStructEnd()
6182
 
6183
  def validate(self):
6184
    return
6185
 
6186
 
6187
  def __repr__(self):
6188
    L = ['%s=%r' % (key, value)
6189
      for key, value in self.__dict__.iteritems()]
6190
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
6191
 
6192
  def __eq__(self, other):
6193
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
6194
 
6195
  def __ne__(self, other):
6196
    return not (self == other)
6197
 
6198
class addBadInventory_args:
6199
  """
6200
  Attributes:
6201
   - itemId
6202
   - warehouseId
6203
   - quantity
6204
  """
6205
 
6206
  thrift_spec = (
6207
    None, # 0
6208
    (1, TType.I64, 'itemId', None, None, ), # 1
6209
    (2, TType.I64, 'warehouseId', None, None, ), # 2
6210
    (3, TType.I64, 'quantity', None, None, ), # 3
6211
  )
6212
 
6213
  def __init__(self, itemId=None, warehouseId=None, quantity=None,):
6214
    self.itemId = itemId
6215
    self.warehouseId = warehouseId
6216
    self.quantity = quantity
6217
 
6218
  def read(self, iprot):
6219
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
6220
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
6221
      return
6222
    iprot.readStructBegin()
6223
    while True:
6224
      (fname, ftype, fid) = iprot.readFieldBegin()
6225
      if ftype == TType.STOP:
6226
        break
6227
      if fid == 1:
6228
        if ftype == TType.I64:
6229
          self.itemId = iprot.readI64();
6230
        else:
6231
          iprot.skip(ftype)
6232
      elif fid == 2:
6233
        if ftype == TType.I64:
6234
          self.warehouseId = iprot.readI64();
6235
        else:
6236
          iprot.skip(ftype)
6237
      elif fid == 3:
6238
        if ftype == TType.I64:
6239
          self.quantity = iprot.readI64();
6240
        else:
6241
          iprot.skip(ftype)
6242
      else:
6243
        iprot.skip(ftype)
6244
      iprot.readFieldEnd()
6245
    iprot.readStructEnd()
6246
 
6247
  def write(self, oprot):
6248
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
6249
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
6250
      return
6251
    oprot.writeStructBegin('addBadInventory_args')
6252
    if self.itemId is not None:
6253
      oprot.writeFieldBegin('itemId', TType.I64, 1)
6254
      oprot.writeI64(self.itemId)
6255
      oprot.writeFieldEnd()
6256
    if self.warehouseId is not None:
6257
      oprot.writeFieldBegin('warehouseId', TType.I64, 2)
6258
      oprot.writeI64(self.warehouseId)
6259
      oprot.writeFieldEnd()
6260
    if self.quantity is not None:
6261
      oprot.writeFieldBegin('quantity', TType.I64, 3)
6262
      oprot.writeI64(self.quantity)
6263
      oprot.writeFieldEnd()
6264
    oprot.writeFieldStop()
6265
    oprot.writeStructEnd()
6266
 
6267
  def validate(self):
6268
    return
6269
 
6270
 
6271
  def __repr__(self):
6272
    L = ['%s=%r' % (key, value)
6273
      for key, value in self.__dict__.iteritems()]
6274
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
6275
 
6276
  def __eq__(self, other):
6277
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
6278
 
6279
  def __ne__(self, other):
6280
    return not (self == other)
6281
 
6282
class addBadInventory_result:
6283
  """
6284
  Attributes:
6285
   - cex
6286
  """
6287
 
6288
  thrift_spec = (
6289
    None, # 0
6290
    (1, TType.STRUCT, 'cex', (InventoryServiceException, InventoryServiceException.thrift_spec), None, ), # 1
6291
  )
6292
 
6293
  def __init__(self, cex=None,):
6294
    self.cex = cex
6295
 
6296
  def read(self, iprot):
6297
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
6298
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
6299
      return
6300
    iprot.readStructBegin()
6301
    while True:
6302
      (fname, ftype, fid) = iprot.readFieldBegin()
6303
      if ftype == TType.STOP:
6304
        break
6305
      if fid == 1:
6306
        if ftype == TType.STRUCT:
6307
          self.cex = InventoryServiceException()
6308
          self.cex.read(iprot)
6309
        else:
6310
          iprot.skip(ftype)
6311
      else:
6312
        iprot.skip(ftype)
6313
      iprot.readFieldEnd()
6314
    iprot.readStructEnd()
6315
 
6316
  def write(self, oprot):
6317
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
6318
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
6319
      return
6320
    oprot.writeStructBegin('addBadInventory_result')
6321
    if self.cex is not None:
6322
      oprot.writeFieldBegin('cex', TType.STRUCT, 1)
6323
      self.cex.write(oprot)
6324
      oprot.writeFieldEnd()
6325
    oprot.writeFieldStop()
6326
    oprot.writeStructEnd()
6327
 
6328
  def validate(self):
6329
    return
6330
 
6331
 
6332
  def __repr__(self):
6333
    L = ['%s=%r' % (key, value)
6334
      for key, value in self.__dict__.iteritems()]
6335
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
6336
 
6337
  def __eq__(self, other):
6338
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
6339
 
6340
  def __ne__(self, other):
6341
    return not (self == other)
6342
 
6343
class getShippingLocations_args:
6344
 
6345
  thrift_spec = (
6346
  )
6347
 
6348
  def read(self, iprot):
6349
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
6350
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
6351
      return
6352
    iprot.readStructBegin()
6353
    while True:
6354
      (fname, ftype, fid) = iprot.readFieldBegin()
6355
      if ftype == TType.STOP:
6356
        break
6357
      else:
6358
        iprot.skip(ftype)
6359
      iprot.readFieldEnd()
6360
    iprot.readStructEnd()
6361
 
6362
  def write(self, oprot):
6363
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
6364
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
6365
      return
6366
    oprot.writeStructBegin('getShippingLocations_args')
6367
    oprot.writeFieldStop()
6368
    oprot.writeStructEnd()
6369
 
6370
  def validate(self):
6371
    return
6372
 
6373
 
6374
  def __repr__(self):
6375
    L = ['%s=%r' % (key, value)
6376
      for key, value in self.__dict__.iteritems()]
6377
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
6378
 
6379
  def __eq__(self, other):
6380
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
6381
 
6382
  def __ne__(self, other):
6383
    return not (self == other)
6384
 
6385
class getShippingLocations_result:
6386
  """
6387
  Attributes:
6388
   - success
6389
  """
6390
 
6391
  thrift_spec = (
6392
    (0, TType.LIST, 'success', (TType.STRUCT,(Warehouse, Warehouse.thrift_spec)), None, ), # 0
6393
  )
6394
 
6395
  def __init__(self, success=None,):
6396
    self.success = success
6397
 
6398
  def read(self, iprot):
6399
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
6400
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
6401
      return
6402
    iprot.readStructBegin()
6403
    while True:
6404
      (fname, ftype, fid) = iprot.readFieldBegin()
6405
      if ftype == TType.STOP:
6406
        break
6407
      if fid == 0:
6408
        if ftype == TType.LIST:
6409
          self.success = []
6410
          (_etype120, _size117) = iprot.readListBegin()
6411
          for _i121 in xrange(_size117):
6412
            _elem122 = Warehouse()
6413
            _elem122.read(iprot)
6414
            self.success.append(_elem122)
6415
          iprot.readListEnd()
6416
        else:
6417
          iprot.skip(ftype)
6418
      else:
6419
        iprot.skip(ftype)
6420
      iprot.readFieldEnd()
6421
    iprot.readStructEnd()
6422
 
6423
  def write(self, oprot):
6424
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
6425
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
6426
      return
6427
    oprot.writeStructBegin('getShippingLocations_result')
6428
    if self.success is not None:
6429
      oprot.writeFieldBegin('success', TType.LIST, 0)
6430
      oprot.writeListBegin(TType.STRUCT, len(self.success))
6431
      for iter123 in self.success:
6432
        iter123.write(oprot)
6433
      oprot.writeListEnd()
6434
      oprot.writeFieldEnd()
6435
    oprot.writeFieldStop()
6436
    oprot.writeStructEnd()
6437
 
6438
  def validate(self):
6439
    return
6440
 
6441
 
6442
  def __repr__(self):
6443
    L = ['%s=%r' % (key, value)
6444
      for key, value in self.__dict__.iteritems()]
6445
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
6446
 
6447
  def __eq__(self, other):
6448
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
6449
 
6450
  def __ne__(self, other):
6451
    return not (self == other)
6452
 
6453
class getAllVendorItemMappings_args:
6454
 
6455
  thrift_spec = (
6456
  )
6457
 
6458
  def read(self, iprot):
6459
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
6460
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
6461
      return
6462
    iprot.readStructBegin()
6463
    while True:
6464
      (fname, ftype, fid) = iprot.readFieldBegin()
6465
      if ftype == TType.STOP:
6466
        break
6467
      else:
6468
        iprot.skip(ftype)
6469
      iprot.readFieldEnd()
6470
    iprot.readStructEnd()
6471
 
6472
  def write(self, oprot):
6473
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
6474
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
6475
      return
6476
    oprot.writeStructBegin('getAllVendorItemMappings_args')
6477
    oprot.writeFieldStop()
6478
    oprot.writeStructEnd()
6479
 
6480
  def validate(self):
6481
    return
6482
 
6483
 
6484
  def __repr__(self):
6485
    L = ['%s=%r' % (key, value)
6486
      for key, value in self.__dict__.iteritems()]
6487
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
6488
 
6489
  def __eq__(self, other):
6490
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
6491
 
6492
  def __ne__(self, other):
6493
    return not (self == other)
6494
 
6495
class getAllVendorItemMappings_result:
6496
  """
6497
  Attributes:
6498
   - success
6499
  """
6500
 
6501
  thrift_spec = (
6502
    (0, TType.LIST, 'success', (TType.STRUCT,(VendorItemMapping, VendorItemMapping.thrift_spec)), None, ), # 0
6503
  )
6504
 
6505
  def __init__(self, success=None,):
6506
    self.success = success
6507
 
6508
  def read(self, iprot):
6509
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
6510
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
6511
      return
6512
    iprot.readStructBegin()
6513
    while True:
6514
      (fname, ftype, fid) = iprot.readFieldBegin()
6515
      if ftype == TType.STOP:
6516
        break
6517
      if fid == 0:
6518
        if ftype == TType.LIST:
6519
          self.success = []
6520
          (_etype127, _size124) = iprot.readListBegin()
6521
          for _i128 in xrange(_size124):
6522
            _elem129 = VendorItemMapping()
6523
            _elem129.read(iprot)
6524
            self.success.append(_elem129)
6525
          iprot.readListEnd()
6526
        else:
6527
          iprot.skip(ftype)
6528
      else:
6529
        iprot.skip(ftype)
6530
      iprot.readFieldEnd()
6531
    iprot.readStructEnd()
6532
 
6533
  def write(self, oprot):
6534
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
6535
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
6536
      return
6537
    oprot.writeStructBegin('getAllVendorItemMappings_result')
6538
    if self.success is not None:
6539
      oprot.writeFieldBegin('success', TType.LIST, 0)
6540
      oprot.writeListBegin(TType.STRUCT, len(self.success))
6541
      for iter130 in self.success:
6542
        iter130.write(oprot)
6543
      oprot.writeListEnd()
6544
      oprot.writeFieldEnd()
6545
    oprot.writeFieldStop()
6546
    oprot.writeStructEnd()
6547
 
6548
  def validate(self):
6549
    return
6550
 
6551
 
6552
  def __repr__(self):
6553
    L = ['%s=%r' % (key, value)
6554
      for key, value in self.__dict__.iteritems()]
6555
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
6556
 
6557
  def __eq__(self, other):
6558
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
6559
 
6560
  def __ne__(self, other):
6561
    return not (self == other)
6562
 
6563
class getInventorySnapshot_args:
6564
  """
6565
  Attributes:
6566
   - warehouseId
6567
  """
6568
 
6569
  thrift_spec = (
6570
    None, # 0
6571
    (1, TType.I64, 'warehouseId', None, None, ), # 1
6572
  )
6573
 
6574
  def __init__(self, warehouseId=None,):
6575
    self.warehouseId = warehouseId
6576
 
6577
  def read(self, iprot):
6578
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
6579
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
6580
      return
6581
    iprot.readStructBegin()
6582
    while True:
6583
      (fname, ftype, fid) = iprot.readFieldBegin()
6584
      if ftype == TType.STOP:
6585
        break
6586
      if fid == 1:
6587
        if ftype == TType.I64:
6588
          self.warehouseId = iprot.readI64();
6589
        else:
6590
          iprot.skip(ftype)
6591
      else:
6592
        iprot.skip(ftype)
6593
      iprot.readFieldEnd()
6594
    iprot.readStructEnd()
6595
 
6596
  def write(self, oprot):
6597
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
6598
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
6599
      return
6600
    oprot.writeStructBegin('getInventorySnapshot_args')
6601
    if self.warehouseId is not None:
6602
      oprot.writeFieldBegin('warehouseId', TType.I64, 1)
6603
      oprot.writeI64(self.warehouseId)
6604
      oprot.writeFieldEnd()
6605
    oprot.writeFieldStop()
6606
    oprot.writeStructEnd()
6607
 
6608
  def validate(self):
6609
    return
6610
 
6611
 
6612
  def __repr__(self):
6613
    L = ['%s=%r' % (key, value)
6614
      for key, value in self.__dict__.iteritems()]
6615
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
6616
 
6617
  def __eq__(self, other):
6618
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
6619
 
6620
  def __ne__(self, other):
6621
    return not (self == other)
6622
 
6623
class getInventorySnapshot_result:
6624
  """
6625
  Attributes:
6626
   - success
6627
  """
6628
 
6629
  thrift_spec = (
6630
    (0, TType.MAP, 'success', (TType.I64,None,TType.STRUCT,(ItemInventory, ItemInventory.thrift_spec)), None, ), # 0
6631
  )
6632
 
6633
  def __init__(self, success=None,):
6634
    self.success = success
6635
 
6636
  def read(self, iprot):
6637
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
6638
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
6639
      return
6640
    iprot.readStructBegin()
6641
    while True:
6642
      (fname, ftype, fid) = iprot.readFieldBegin()
6643
      if ftype == TType.STOP:
6644
        break
6645
      if fid == 0:
6646
        if ftype == TType.MAP:
6647
          self.success = {}
6648
          (_ktype132, _vtype133, _size131 ) = iprot.readMapBegin() 
6649
          for _i135 in xrange(_size131):
6650
            _key136 = iprot.readI64();
6651
            _val137 = ItemInventory()
6652
            _val137.read(iprot)
6653
            self.success[_key136] = _val137
6654
          iprot.readMapEnd()
6655
        else:
6656
          iprot.skip(ftype)
6657
      else:
6658
        iprot.skip(ftype)
6659
      iprot.readFieldEnd()
6660
    iprot.readStructEnd()
6661
 
6662
  def write(self, oprot):
6663
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
6664
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
6665
      return
6666
    oprot.writeStructBegin('getInventorySnapshot_result')
6667
    if self.success is not None:
6668
      oprot.writeFieldBegin('success', TType.MAP, 0)
6669
      oprot.writeMapBegin(TType.I64, TType.STRUCT, len(self.success))
6670
      for kiter138,viter139 in self.success.items():
6671
        oprot.writeI64(kiter138)
6672
        viter139.write(oprot)
6673
      oprot.writeMapEnd()
6674
      oprot.writeFieldEnd()
6675
    oprot.writeFieldStop()
6676
    oprot.writeStructEnd()
6677
 
6678
  def validate(self):
6679
    return
6680
 
6681
 
6682
  def __repr__(self):
6683
    L = ['%s=%r' % (key, value)
6684
      for key, value in self.__dict__.iteritems()]
6685
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
6686
 
6687
  def __eq__(self, other):
6688
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
6689
 
6690
  def __ne__(self, other):
6691
    return not (self == other)
6692
 
6693
class clearItemAvailabilityCache_args:
6694
 
6695
  thrift_spec = (
6696
  )
6697
 
6698
  def read(self, iprot):
6699
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
6700
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
6701
      return
6702
    iprot.readStructBegin()
6703
    while True:
6704
      (fname, ftype, fid) = iprot.readFieldBegin()
6705
      if ftype == TType.STOP:
6706
        break
6707
      else:
6708
        iprot.skip(ftype)
6709
      iprot.readFieldEnd()
6710
    iprot.readStructEnd()
6711
 
6712
  def write(self, oprot):
6713
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
6714
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
6715
      return
6716
    oprot.writeStructBegin('clearItemAvailabilityCache_args')
6717
    oprot.writeFieldStop()
6718
    oprot.writeStructEnd()
6719
 
6720
  def validate(self):
6721
    return
6722
 
6723
 
6724
  def __repr__(self):
6725
    L = ['%s=%r' % (key, value)
6726
      for key, value in self.__dict__.iteritems()]
6727
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
6728
 
6729
  def __eq__(self, other):
6730
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
6731
 
6732
  def __ne__(self, other):
6733
    return not (self == other)
6734
 
6735
class clearItemAvailabilityCache_result:
6736
 
6737
  thrift_spec = (
6738
  )
6739
 
6740
  def read(self, iprot):
6741
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
6742
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
6743
      return
6744
    iprot.readStructBegin()
6745
    while True:
6746
      (fname, ftype, fid) = iprot.readFieldBegin()
6747
      if ftype == TType.STOP:
6748
        break
6749
      else:
6750
        iprot.skip(ftype)
6751
      iprot.readFieldEnd()
6752
    iprot.readStructEnd()
6753
 
6754
  def write(self, oprot):
6755
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
6756
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
6757
      return
6758
    oprot.writeStructBegin('clearItemAvailabilityCache_result')
6759
    oprot.writeFieldStop()
6760
    oprot.writeStructEnd()
6761
 
6762
  def validate(self):
6763
    return
6764
 
6765
 
6766
  def __repr__(self):
6767
    L = ['%s=%r' % (key, value)
6768
      for key, value in self.__dict__.iteritems()]
6769
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
6770
 
6771
  def __eq__(self, other):
6772
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
6773
 
6774
  def __ne__(self, other):
6775
    return not (self == other)
6776
 
6777
class updateVendorString_args:
6778
  """
6779
  Attributes:
6780
   - warehouseId
6781
   - vendorString
6782
  """
6783
 
6784
  thrift_spec = (
6785
    None, # 0
6786
    (1, TType.I64, 'warehouseId', None, None, ), # 1
6787
    (2, TType.STRING, 'vendorString', None, None, ), # 2
6788
  )
6789
 
6790
  def __init__(self, warehouseId=None, vendorString=None,):
6791
    self.warehouseId = warehouseId
6792
    self.vendorString = vendorString
6793
 
6794
  def read(self, iprot):
6795
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
6796
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
6797
      return
6798
    iprot.readStructBegin()
6799
    while True:
6800
      (fname, ftype, fid) = iprot.readFieldBegin()
6801
      if ftype == TType.STOP:
6802
        break
6803
      if fid == 1:
6804
        if ftype == TType.I64:
6805
          self.warehouseId = iprot.readI64();
6806
        else:
6807
          iprot.skip(ftype)
6808
      elif fid == 2:
6809
        if ftype == TType.STRING:
6810
          self.vendorString = iprot.readString();
6811
        else:
6812
          iprot.skip(ftype)
6813
      else:
6814
        iprot.skip(ftype)
6815
      iprot.readFieldEnd()
6816
    iprot.readStructEnd()
6817
 
6818
  def write(self, oprot):
6819
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
6820
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
6821
      return
6822
    oprot.writeStructBegin('updateVendorString_args')
6823
    if self.warehouseId is not None:
6824
      oprot.writeFieldBegin('warehouseId', TType.I64, 1)
6825
      oprot.writeI64(self.warehouseId)
6826
      oprot.writeFieldEnd()
6827
    if self.vendorString is not None:
6828
      oprot.writeFieldBegin('vendorString', TType.STRING, 2)
6829
      oprot.writeString(self.vendorString)
6830
      oprot.writeFieldEnd()
6831
    oprot.writeFieldStop()
6832
    oprot.writeStructEnd()
6833
 
6834
  def validate(self):
6835
    return
6836
 
6837
 
6838
  def __repr__(self):
6839
    L = ['%s=%r' % (key, value)
6840
      for key, value in self.__dict__.iteritems()]
6841
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
6842
 
6843
  def __eq__(self, other):
6844
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
6845
 
6846
  def __ne__(self, other):
6847
    return not (self == other)
6848
 
6849
class updateVendorString_result:
6850
 
6851
  thrift_spec = (
6852
  )
6853
 
6854
  def read(self, iprot):
6855
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
6856
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
6857
      return
6858
    iprot.readStructBegin()
6859
    while True:
6860
      (fname, ftype, fid) = iprot.readFieldBegin()
6861
      if ftype == TType.STOP:
6862
        break
6863
      else:
6864
        iprot.skip(ftype)
6865
      iprot.readFieldEnd()
6866
    iprot.readStructEnd()
6867
 
6868
  def write(self, oprot):
6869
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
6870
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
6871
      return
6872
    oprot.writeStructBegin('updateVendorString_result')
6873
    oprot.writeFieldStop()
6874
    oprot.writeStructEnd()
6875
 
6876
  def validate(self):
6877
    return
6878
 
6879
 
6880
  def __repr__(self):
6881
    L = ['%s=%r' % (key, value)
6882
      for key, value in self.__dict__.iteritems()]
6883
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
6884
 
6885
  def __eq__(self, other):
6886
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
6887
 
6888
  def __ne__(self, other):
6889
    return not (self == other)
6096 amit.gupta 6890
 
6891
class clearItemAvailabilityCacheForItem_args:
6892
  """
6893
  Attributes:
6894
   - item_id
6895
  """
6896
 
6897
  thrift_spec = (
6898
    None, # 0
6899
    (1, TType.I64, 'item_id', None, None, ), # 1
6900
  )
6901
 
6902
  def __init__(self, item_id=None,):
6903
    self.item_id = item_id
6904
 
6905
  def read(self, iprot):
6906
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
6907
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
6908
      return
6909
    iprot.readStructBegin()
6910
    while True:
6911
      (fname, ftype, fid) = iprot.readFieldBegin()
6912
      if ftype == TType.STOP:
6913
        break
6914
      if fid == 1:
6915
        if ftype == TType.I64:
6916
          self.item_id = iprot.readI64();
6917
        else:
6918
          iprot.skip(ftype)
6919
      else:
6920
        iprot.skip(ftype)
6921
      iprot.readFieldEnd()
6922
    iprot.readStructEnd()
6923
 
6924
  def write(self, oprot):
6925
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
6926
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
6927
      return
6928
    oprot.writeStructBegin('clearItemAvailabilityCacheForItem_args')
6929
    if self.item_id is not None:
6930
      oprot.writeFieldBegin('item_id', TType.I64, 1)
6931
      oprot.writeI64(self.item_id)
6932
      oprot.writeFieldEnd()
6933
    oprot.writeFieldStop()
6934
    oprot.writeStructEnd()
6935
 
6936
  def validate(self):
6937
    return
6938
 
6939
 
6940
  def __repr__(self):
6941
    L = ['%s=%r' % (key, value)
6942
      for key, value in self.__dict__.iteritems()]
6943
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
6944
 
6945
  def __eq__(self, other):
6946
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
6947
 
6948
  def __ne__(self, other):
6949
    return not (self == other)
6950
 
6951
class clearItemAvailabilityCacheForItem_result:
6952
 
6953
  thrift_spec = (
6954
  )
6955
 
6956
  def read(self, iprot):
6957
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
6958
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
6959
      return
6960
    iprot.readStructBegin()
6961
    while True:
6962
      (fname, ftype, fid) = iprot.readFieldBegin()
6963
      if ftype == TType.STOP:
6964
        break
6965
      else:
6966
        iprot.skip(ftype)
6967
      iprot.readFieldEnd()
6968
    iprot.readStructEnd()
6969
 
6970
  def write(self, oprot):
6971
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
6972
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
6973
      return
6974
    oprot.writeStructBegin('clearItemAvailabilityCacheForItem_result')
6975
    oprot.writeFieldStop()
6976
    oprot.writeStructEnd()
6977
 
6978
  def validate(self):
6979
    return
6980
 
6981
 
6982
  def __repr__(self):
6983
    L = ['%s=%r' % (key, value)
6984
      for key, value in self.__dict__.iteritems()]
6985
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
6986
 
6987
  def __eq__(self, other):
6988
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
6989
 
6990
  def __ne__(self, other):
6991
    return not (self == other)