Rev 5110 | Rev 5361 | Go to most recent revision | Blame | Compare with Previous | Last modification | View Log | RSS feed
## Autogenerated by Thrift Compiler (0.7.0)## DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING#from thrift.Thrift import *import shop2020.thriftpy.generic.GenericServicefrom ttypes import *from thrift.Thrift import TProcessorfrom thrift.transport import TTransportfrom thrift.protocol import TBinaryProtocol, TProtocoltry:from thrift.protocol import fastbinaryexcept:fastbinary = Noneclass Iface(shop2020.thriftpy.generic.GenericService.Iface):def createSerializedInventoryItem(self, itemId, itemNumber, serialNumber, purchaseId):"""Creating inventory for a serialized itemParameters:- itemId- itemNumber- serialNumber- purchaseId"""passdef createSerializedInventoryItemFromItemNumber(self, itemNumber, serialNumber, purchaseId):"""Creating inventory for a serialized item using item numberParameters:- itemNumber- serialNumber- purchaseId"""passdef createInventoryItem(self, itemId, quantity, purchaseId):"""Creates inventory for an unserailized itemParameters:- itemId- quantity- purchaseId"""passdef getInventoryItem(self, serialNumber):"""Retrieves serialized inventory item given a serial numberParameters:- serialNumber"""passdef getNonSeralizedInventoryItems(self, itemId, quantity, supplierId):"""Retrieves non-serialized inventory items from a given supplierParameters:- itemId- quantity- supplierId"""passdef getInventoryItems(self, itemId):"""Retrieves inventory items for a given itemParameters:- itemId"""passdef getScanForOrder(self, orderId):"""Retrieves scans for a given orderParameters:- orderId"""passdef getScan(self, inventoryItemId):"""Retrieves scans for a given inventory itemParameters:- inventoryItemId"""passdef scanSerializedItem(self, inventoryItem, type, warehouseId):"""Scan serialized items.Parameters:- inventoryItem- type- warehouseId"""passdef scan(self, inventoryItemId, type, quantity, warehouseId):"""Scan non-serialized items.Parameters:- inventoryItemId- type- quantity- warehouseId"""passdef scanSerializedItemForOrder(self, serialNumber, type, orderId, fulfilmentWarehouseId, quantity, billingWarehouseId):"""Scan serialized items linked with an order. Returns its price.Parameters:- serialNumber- type- orderId- fulfilmentWarehouseId- quantity- billingWarehouseId"""passdef scanForOrder(self, inventoryItemId, type, quantity, orderId, fulfilmentWarehouseId):"""Scan non-serialized items linked with an order.Parameters:- inventoryItemId- type- quantity- orderId- fulfilmentWarehouseId"""passdef createItemNumberMapping(self, itemNumber, itemId):"""Created item number to item id mappingParameters:- itemNumber- itemId"""passdef getItemNumbers(self, itemId):"""Get itemNumber mappings for itemIdParameters:- itemId"""passdef getItemIds(self, itemNumber):"""Gets item ids for a given item numberParameters:- itemNumber"""passdef getInventoryItemsFromLastScanType(self, lastScanType):"""Retrieves all inventory items given a last scan typeParameters:- lastScanType"""passdef getInventoryItemFromId(self, inventoryItemId):"""Retrieves inventory item given a inventoryItem idParameters:- inventoryItemId"""passclass Client(shop2020.thriftpy.generic.GenericService.Client, Iface):def __init__(self, iprot, oprot=None):shop2020.thriftpy.generic.GenericService.Client.__init__(self, iprot, oprot)def createSerializedInventoryItem(self, itemId, itemNumber, serialNumber, purchaseId):"""Creating inventory for a serialized itemParameters:- itemId- itemNumber- serialNumber- purchaseId"""self.send_createSerializedInventoryItem(itemId, itemNumber, serialNumber, purchaseId)return self.recv_createSerializedInventoryItem()def send_createSerializedInventoryItem(self, itemId, itemNumber, serialNumber, purchaseId):self._oprot.writeMessageBegin('createSerializedInventoryItem', TMessageType.CALL, self._seqid)args = createSerializedInventoryItem_args()args.itemId = itemIdargs.itemNumber = itemNumberargs.serialNumber = serialNumberargs.purchaseId = purchaseIdargs.write(self._oprot)self._oprot.writeMessageEnd()self._oprot.trans.flush()def recv_createSerializedInventoryItem(self, ):(fname, mtype, rseqid) = self._iprot.readMessageBegin()if mtype == TMessageType.EXCEPTION:x = TApplicationException()x.read(self._iprot)self._iprot.readMessageEnd()raise xresult = createSerializedInventoryItem_result()result.read(self._iprot)self._iprot.readMessageEnd()if result.success is not None:return result.successif result.wex is not None:raise result.wexraise TApplicationException(TApplicationException.MISSING_RESULT, "createSerializedInventoryItem failed: unknown result");def createSerializedInventoryItemFromItemNumber(self, itemNumber, serialNumber, purchaseId):"""Creating inventory for a serialized item using item numberParameters:- itemNumber- serialNumber- purchaseId"""self.send_createSerializedInventoryItemFromItemNumber(itemNumber, serialNumber, purchaseId)return self.recv_createSerializedInventoryItemFromItemNumber()def send_createSerializedInventoryItemFromItemNumber(self, itemNumber, serialNumber, purchaseId):self._oprot.writeMessageBegin('createSerializedInventoryItemFromItemNumber', TMessageType.CALL, self._seqid)args = createSerializedInventoryItemFromItemNumber_args()args.itemNumber = itemNumberargs.serialNumber = serialNumberargs.purchaseId = purchaseIdargs.write(self._oprot)self._oprot.writeMessageEnd()self._oprot.trans.flush()def recv_createSerializedInventoryItemFromItemNumber(self, ):(fname, mtype, rseqid) = self._iprot.readMessageBegin()if mtype == TMessageType.EXCEPTION:x = TApplicationException()x.read(self._iprot)self._iprot.readMessageEnd()raise xresult = createSerializedInventoryItemFromItemNumber_result()result.read(self._iprot)self._iprot.readMessageEnd()if result.success is not None:return result.successif result.wex is not None:raise result.wexraise TApplicationException(TApplicationException.MISSING_RESULT, "createSerializedInventoryItemFromItemNumber failed: unknown result");def createInventoryItem(self, itemId, quantity, purchaseId):"""Creates inventory for an unserailized itemParameters:- itemId- quantity- purchaseId"""self.send_createInventoryItem(itemId, quantity, purchaseId)return self.recv_createInventoryItem()def send_createInventoryItem(self, itemId, quantity, purchaseId):self._oprot.writeMessageBegin('createInventoryItem', TMessageType.CALL, self._seqid)args = createInventoryItem_args()args.itemId = itemIdargs.quantity = quantityargs.purchaseId = purchaseIdargs.write(self._oprot)self._oprot.writeMessageEnd()self._oprot.trans.flush()def recv_createInventoryItem(self, ):(fname, mtype, rseqid) = self._iprot.readMessageBegin()if mtype == TMessageType.EXCEPTION:x = TApplicationException()x.read(self._iprot)self._iprot.readMessageEnd()raise xresult = createInventoryItem_result()result.read(self._iprot)self._iprot.readMessageEnd()if result.success is not None:return result.successif result.wex is not None:raise result.wexraise TApplicationException(TApplicationException.MISSING_RESULT, "createInventoryItem failed: unknown result");def getInventoryItem(self, serialNumber):"""Retrieves serialized inventory item given a serial numberParameters:- serialNumber"""self.send_getInventoryItem(serialNumber)return self.recv_getInventoryItem()def send_getInventoryItem(self, serialNumber):self._oprot.writeMessageBegin('getInventoryItem', TMessageType.CALL, self._seqid)args = getInventoryItem_args()args.serialNumber = serialNumberargs.write(self._oprot)self._oprot.writeMessageEnd()self._oprot.trans.flush()def recv_getInventoryItem(self, ):(fname, mtype, rseqid) = self._iprot.readMessageBegin()if mtype == TMessageType.EXCEPTION:x = TApplicationException()x.read(self._iprot)self._iprot.readMessageEnd()raise xresult = getInventoryItem_result()result.read(self._iprot)self._iprot.readMessageEnd()if result.success is not None:return result.successif result.wex is not None:raise result.wexraise TApplicationException(TApplicationException.MISSING_RESULT, "getInventoryItem failed: unknown result");def getNonSeralizedInventoryItems(self, itemId, quantity, supplierId):"""Retrieves non-serialized inventory items from a given supplierParameters:- itemId- quantity- supplierId"""self.send_getNonSeralizedInventoryItems(itemId, quantity, supplierId)return self.recv_getNonSeralizedInventoryItems()def send_getNonSeralizedInventoryItems(self, itemId, quantity, supplierId):self._oprot.writeMessageBegin('getNonSeralizedInventoryItems', TMessageType.CALL, self._seqid)args = getNonSeralizedInventoryItems_args()args.itemId = itemIdargs.quantity = quantityargs.supplierId = supplierIdargs.write(self._oprot)self._oprot.writeMessageEnd()self._oprot.trans.flush()def recv_getNonSeralizedInventoryItems(self, ):(fname, mtype, rseqid) = self._iprot.readMessageBegin()if mtype == TMessageType.EXCEPTION:x = TApplicationException()x.read(self._iprot)self._iprot.readMessageEnd()raise xresult = getNonSeralizedInventoryItems_result()result.read(self._iprot)self._iprot.readMessageEnd()if result.success is not None:return result.successraise TApplicationException(TApplicationException.MISSING_RESULT, "getNonSeralizedInventoryItems failed: unknown result");def getInventoryItems(self, itemId):"""Retrieves inventory items for a given itemParameters:- itemId"""self.send_getInventoryItems(itemId)return self.recv_getInventoryItems()def send_getInventoryItems(self, itemId):self._oprot.writeMessageBegin('getInventoryItems', TMessageType.CALL, self._seqid)args = getInventoryItems_args()args.itemId = itemIdargs.write(self._oprot)self._oprot.writeMessageEnd()self._oprot.trans.flush()def recv_getInventoryItems(self, ):(fname, mtype, rseqid) = self._iprot.readMessageBegin()if mtype == TMessageType.EXCEPTION:x = TApplicationException()x.read(self._iprot)self._iprot.readMessageEnd()raise xresult = getInventoryItems_result()result.read(self._iprot)self._iprot.readMessageEnd()if result.success is not None:return result.successraise TApplicationException(TApplicationException.MISSING_RESULT, "getInventoryItems failed: unknown result");def getScanForOrder(self, orderId):"""Retrieves scans for a given orderParameters:- orderId"""self.send_getScanForOrder(orderId)return self.recv_getScanForOrder()def send_getScanForOrder(self, orderId):self._oprot.writeMessageBegin('getScanForOrder', TMessageType.CALL, self._seqid)args = getScanForOrder_args()args.orderId = orderIdargs.write(self._oprot)self._oprot.writeMessageEnd()self._oprot.trans.flush()def recv_getScanForOrder(self, ):(fname, mtype, rseqid) = self._iprot.readMessageBegin()if mtype == TMessageType.EXCEPTION:x = TApplicationException()x.read(self._iprot)self._iprot.readMessageEnd()raise xresult = getScanForOrder_result()result.read(self._iprot)self._iprot.readMessageEnd()if result.success is not None:return result.successraise TApplicationException(TApplicationException.MISSING_RESULT, "getScanForOrder failed: unknown result");def getScan(self, inventoryItemId):"""Retrieves scans for a given inventory itemParameters:- inventoryItemId"""self.send_getScan(inventoryItemId)return self.recv_getScan()def send_getScan(self, inventoryItemId):self._oprot.writeMessageBegin('getScan', TMessageType.CALL, self._seqid)args = getScan_args()args.inventoryItemId = inventoryItemIdargs.write(self._oprot)self._oprot.writeMessageEnd()self._oprot.trans.flush()def recv_getScan(self, ):(fname, mtype, rseqid) = self._iprot.readMessageBegin()if mtype == TMessageType.EXCEPTION:x = TApplicationException()x.read(self._iprot)self._iprot.readMessageEnd()raise xresult = getScan_result()result.read(self._iprot)self._iprot.readMessageEnd()if result.success is not None:return result.successraise TApplicationException(TApplicationException.MISSING_RESULT, "getScan failed: unknown result");def scanSerializedItem(self, inventoryItem, type, warehouseId):"""Scan serialized items.Parameters:- inventoryItem- type- warehouseId"""self.send_scanSerializedItem(inventoryItem, type, warehouseId)self.recv_scanSerializedItem()def send_scanSerializedItem(self, inventoryItem, type, warehouseId):self._oprot.writeMessageBegin('scanSerializedItem', TMessageType.CALL, self._seqid)args = scanSerializedItem_args()args.inventoryItem = inventoryItemargs.type = typeargs.warehouseId = warehouseIdargs.write(self._oprot)self._oprot.writeMessageEnd()self._oprot.trans.flush()def recv_scanSerializedItem(self, ):(fname, mtype, rseqid) = self._iprot.readMessageBegin()if mtype == TMessageType.EXCEPTION:x = TApplicationException()x.read(self._iprot)self._iprot.readMessageEnd()raise xresult = scanSerializedItem_result()result.read(self._iprot)self._iprot.readMessageEnd()if result.wex is not None:raise result.wexreturndef scan(self, inventoryItemId, type, quantity, warehouseId):"""Scan non-serialized items.Parameters:- inventoryItemId- type- quantity- warehouseId"""self.send_scan(inventoryItemId, type, quantity, warehouseId)self.recv_scan()def send_scan(self, inventoryItemId, type, quantity, warehouseId):self._oprot.writeMessageBegin('scan', TMessageType.CALL, self._seqid)args = scan_args()args.inventoryItemId = inventoryItemIdargs.type = typeargs.quantity = quantityargs.warehouseId = warehouseIdargs.write(self._oprot)self._oprot.writeMessageEnd()self._oprot.trans.flush()def recv_scan(self, ):(fname, mtype, rseqid) = self._iprot.readMessageBegin()if mtype == TMessageType.EXCEPTION:x = TApplicationException()x.read(self._iprot)self._iprot.readMessageEnd()raise xresult = scan_result()result.read(self._iprot)self._iprot.readMessageEnd()if result.wex is not None:raise result.wexreturndef scanSerializedItemForOrder(self, serialNumber, type, orderId, fulfilmentWarehouseId, quantity, billingWarehouseId):"""Scan serialized items linked with an order. Returns its price.Parameters:- serialNumber- type- orderId- fulfilmentWarehouseId- quantity- billingWarehouseId"""self.send_scanSerializedItemForOrder(serialNumber, type, orderId, fulfilmentWarehouseId, quantity, billingWarehouseId)return self.recv_scanSerializedItemForOrder()def send_scanSerializedItemForOrder(self, serialNumber, type, orderId, fulfilmentWarehouseId, quantity, billingWarehouseId):self._oprot.writeMessageBegin('scanSerializedItemForOrder', TMessageType.CALL, self._seqid)args = scanSerializedItemForOrder_args()args.serialNumber = serialNumberargs.type = typeargs.orderId = orderIdargs.fulfilmentWarehouseId = fulfilmentWarehouseIdargs.quantity = quantityargs.billingWarehouseId = billingWarehouseIdargs.write(self._oprot)self._oprot.writeMessageEnd()self._oprot.trans.flush()def recv_scanSerializedItemForOrder(self, ):(fname, mtype, rseqid) = self._iprot.readMessageBegin()if mtype == TMessageType.EXCEPTION:x = TApplicationException()x.read(self._iprot)self._iprot.readMessageEnd()raise xresult = scanSerializedItemForOrder_result()result.read(self._iprot)self._iprot.readMessageEnd()if result.success is not None:return result.successif result.wex is not None:raise result.wexraise TApplicationException(TApplicationException.MISSING_RESULT, "scanSerializedItemForOrder failed: unknown result");def scanForOrder(self, inventoryItemId, type, quantity, orderId, fulfilmentWarehouseId):"""Scan non-serialized items linked with an order.Parameters:- inventoryItemId- type- quantity- orderId- fulfilmentWarehouseId"""self.send_scanForOrder(inventoryItemId, type, quantity, orderId, fulfilmentWarehouseId)self.recv_scanForOrder()def send_scanForOrder(self, inventoryItemId, type, quantity, orderId, fulfilmentWarehouseId):self._oprot.writeMessageBegin('scanForOrder', TMessageType.CALL, self._seqid)args = scanForOrder_args()args.inventoryItemId = inventoryItemIdargs.type = typeargs.quantity = quantityargs.orderId = orderIdargs.fulfilmentWarehouseId = fulfilmentWarehouseIdargs.write(self._oprot)self._oprot.writeMessageEnd()self._oprot.trans.flush()def recv_scanForOrder(self, ):(fname, mtype, rseqid) = self._iprot.readMessageBegin()if mtype == TMessageType.EXCEPTION:x = TApplicationException()x.read(self._iprot)self._iprot.readMessageEnd()raise xresult = scanForOrder_result()result.read(self._iprot)self._iprot.readMessageEnd()if result.wex is not None:raise result.wexreturndef createItemNumberMapping(self, itemNumber, itemId):"""Created item number to item id mappingParameters:- itemNumber- itemId"""self.send_createItemNumberMapping(itemNumber, itemId)self.recv_createItemNumberMapping()def send_createItemNumberMapping(self, itemNumber, itemId):self._oprot.writeMessageBegin('createItemNumberMapping', TMessageType.CALL, self._seqid)args = createItemNumberMapping_args()args.itemNumber = itemNumberargs.itemId = itemIdargs.write(self._oprot)self._oprot.writeMessageEnd()self._oprot.trans.flush()def recv_createItemNumberMapping(self, ):(fname, mtype, rseqid) = self._iprot.readMessageBegin()if mtype == TMessageType.EXCEPTION:x = TApplicationException()x.read(self._iprot)self._iprot.readMessageEnd()raise xresult = createItemNumberMapping_result()result.read(self._iprot)self._iprot.readMessageEnd()returndef getItemNumbers(self, itemId):"""Get itemNumber mappings for itemIdParameters:- itemId"""self.send_getItemNumbers(itemId)return self.recv_getItemNumbers()def send_getItemNumbers(self, itemId):self._oprot.writeMessageBegin('getItemNumbers', TMessageType.CALL, self._seqid)args = getItemNumbers_args()args.itemId = itemIdargs.write(self._oprot)self._oprot.writeMessageEnd()self._oprot.trans.flush()def recv_getItemNumbers(self, ):(fname, mtype, rseqid) = self._iprot.readMessageBegin()if mtype == TMessageType.EXCEPTION:x = TApplicationException()x.read(self._iprot)self._iprot.readMessageEnd()raise xresult = getItemNumbers_result()result.read(self._iprot)self._iprot.readMessageEnd()if result.success is not None:return result.successraise TApplicationException(TApplicationException.MISSING_RESULT, "getItemNumbers failed: unknown result");def getItemIds(self, itemNumber):"""Gets item ids for a given item numberParameters:- itemNumber"""self.send_getItemIds(itemNumber)return self.recv_getItemIds()def send_getItemIds(self, itemNumber):self._oprot.writeMessageBegin('getItemIds', TMessageType.CALL, self._seqid)args = getItemIds_args()args.itemNumber = itemNumberargs.write(self._oprot)self._oprot.writeMessageEnd()self._oprot.trans.flush()def recv_getItemIds(self, ):(fname, mtype, rseqid) = self._iprot.readMessageBegin()if mtype == TMessageType.EXCEPTION:x = TApplicationException()x.read(self._iprot)self._iprot.readMessageEnd()raise xresult = getItemIds_result()result.read(self._iprot)self._iprot.readMessageEnd()if result.success is not None:return result.successraise TApplicationException(TApplicationException.MISSING_RESULT, "getItemIds failed: unknown result");def getInventoryItemsFromLastScanType(self, lastScanType):"""Retrieves all inventory items given a last scan typeParameters:- lastScanType"""self.send_getInventoryItemsFromLastScanType(lastScanType)return self.recv_getInventoryItemsFromLastScanType()def send_getInventoryItemsFromLastScanType(self, lastScanType):self._oprot.writeMessageBegin('getInventoryItemsFromLastScanType', TMessageType.CALL, self._seqid)args = getInventoryItemsFromLastScanType_args()args.lastScanType = lastScanTypeargs.write(self._oprot)self._oprot.writeMessageEnd()self._oprot.trans.flush()def recv_getInventoryItemsFromLastScanType(self, ):(fname, mtype, rseqid) = self._iprot.readMessageBegin()if mtype == TMessageType.EXCEPTION:x = TApplicationException()x.read(self._iprot)self._iprot.readMessageEnd()raise xresult = getInventoryItemsFromLastScanType_result()result.read(self._iprot)self._iprot.readMessageEnd()if result.success is not None:return result.successif result.wex is not None:raise result.wexraise TApplicationException(TApplicationException.MISSING_RESULT, "getInventoryItemsFromLastScanType failed: unknown result");def getInventoryItemFromId(self, inventoryItemId):"""Retrieves inventory item given a inventoryItem idParameters:- inventoryItemId"""self.send_getInventoryItemFromId(inventoryItemId)return self.recv_getInventoryItemFromId()def send_getInventoryItemFromId(self, inventoryItemId):self._oprot.writeMessageBegin('getInventoryItemFromId', TMessageType.CALL, self._seqid)args = getInventoryItemFromId_args()args.inventoryItemId = inventoryItemIdargs.write(self._oprot)self._oprot.writeMessageEnd()self._oprot.trans.flush()def recv_getInventoryItemFromId(self, ):(fname, mtype, rseqid) = self._iprot.readMessageBegin()if mtype == TMessageType.EXCEPTION:x = TApplicationException()x.read(self._iprot)self._iprot.readMessageEnd()raise xresult = getInventoryItemFromId_result()result.read(self._iprot)self._iprot.readMessageEnd()if result.success is not None:return result.successif result.wex is not None:raise result.wexraise TApplicationException(TApplicationException.MISSING_RESULT, "getInventoryItemFromId failed: unknown result");class Processor(shop2020.thriftpy.generic.GenericService.Processor, Iface, TProcessor):def __init__(self, handler):shop2020.thriftpy.generic.GenericService.Processor.__init__(self, handler)self._processMap["createSerializedInventoryItem"] = Processor.process_createSerializedInventoryItemself._processMap["createSerializedInventoryItemFromItemNumber"] = Processor.process_createSerializedInventoryItemFromItemNumberself._processMap["createInventoryItem"] = Processor.process_createInventoryItemself._processMap["getInventoryItem"] = Processor.process_getInventoryItemself._processMap["getNonSeralizedInventoryItems"] = Processor.process_getNonSeralizedInventoryItemsself._processMap["getInventoryItems"] = Processor.process_getInventoryItemsself._processMap["getScanForOrder"] = Processor.process_getScanForOrderself._processMap["getScan"] = Processor.process_getScanself._processMap["scanSerializedItem"] = Processor.process_scanSerializedItemself._processMap["scan"] = Processor.process_scanself._processMap["scanSerializedItemForOrder"] = Processor.process_scanSerializedItemForOrderself._processMap["scanForOrder"] = Processor.process_scanForOrderself._processMap["createItemNumberMapping"] = Processor.process_createItemNumberMappingself._processMap["getItemNumbers"] = Processor.process_getItemNumbersself._processMap["getItemIds"] = Processor.process_getItemIdsself._processMap["getInventoryItemsFromLastScanType"] = Processor.process_getInventoryItemsFromLastScanTypeself._processMap["getInventoryItemFromId"] = Processor.process_getInventoryItemFromIddef process(self, iprot, oprot):(name, type, seqid) = iprot.readMessageBegin()if name not in self._processMap:iprot.skip(TType.STRUCT)iprot.readMessageEnd()x = TApplicationException(TApplicationException.UNKNOWN_METHOD, 'Unknown function %s' % (name))oprot.writeMessageBegin(name, TMessageType.EXCEPTION, seqid)x.write(oprot)oprot.writeMessageEnd()oprot.trans.flush()returnelse:self._processMap[name](self, seqid, iprot, oprot)return Truedef process_createSerializedInventoryItem(self, seqid, iprot, oprot):args = createSerializedInventoryItem_args()args.read(iprot)iprot.readMessageEnd()result = createSerializedInventoryItem_result()try:result.success = self._handler.createSerializedInventoryItem(args.itemId, args.itemNumber, args.serialNumber, args.purchaseId)except WarehouseServiceException, wex:result.wex = wexoprot.writeMessageBegin("createSerializedInventoryItem", TMessageType.REPLY, seqid)result.write(oprot)oprot.writeMessageEnd()oprot.trans.flush()def process_createSerializedInventoryItemFromItemNumber(self, seqid, iprot, oprot):args = createSerializedInventoryItemFromItemNumber_args()args.read(iprot)iprot.readMessageEnd()result = createSerializedInventoryItemFromItemNumber_result()try:result.success = self._handler.createSerializedInventoryItemFromItemNumber(args.itemNumber, args.serialNumber, args.purchaseId)except WarehouseServiceException, wex:result.wex = wexoprot.writeMessageBegin("createSerializedInventoryItemFromItemNumber", TMessageType.REPLY, seqid)result.write(oprot)oprot.writeMessageEnd()oprot.trans.flush()def process_createInventoryItem(self, seqid, iprot, oprot):args = createInventoryItem_args()args.read(iprot)iprot.readMessageEnd()result = createInventoryItem_result()try:result.success = self._handler.createInventoryItem(args.itemId, args.quantity, args.purchaseId)except WarehouseServiceException, wex:result.wex = wexoprot.writeMessageBegin("createInventoryItem", TMessageType.REPLY, seqid)result.write(oprot)oprot.writeMessageEnd()oprot.trans.flush()def process_getInventoryItem(self, seqid, iprot, oprot):args = getInventoryItem_args()args.read(iprot)iprot.readMessageEnd()result = getInventoryItem_result()try:result.success = self._handler.getInventoryItem(args.serialNumber)except WarehouseServiceException, wex:result.wex = wexoprot.writeMessageBegin("getInventoryItem", TMessageType.REPLY, seqid)result.write(oprot)oprot.writeMessageEnd()oprot.trans.flush()def process_getNonSeralizedInventoryItems(self, seqid, iprot, oprot):args = getNonSeralizedInventoryItems_args()args.read(iprot)iprot.readMessageEnd()result = getNonSeralizedInventoryItems_result()result.success = self._handler.getNonSeralizedInventoryItems(args.itemId, args.quantity, args.supplierId)oprot.writeMessageBegin("getNonSeralizedInventoryItems", TMessageType.REPLY, seqid)result.write(oprot)oprot.writeMessageEnd()oprot.trans.flush()def process_getInventoryItems(self, seqid, iprot, oprot):args = getInventoryItems_args()args.read(iprot)iprot.readMessageEnd()result = getInventoryItems_result()result.success = self._handler.getInventoryItems(args.itemId)oprot.writeMessageBegin("getInventoryItems", TMessageType.REPLY, seqid)result.write(oprot)oprot.writeMessageEnd()oprot.trans.flush()def process_getScanForOrder(self, seqid, iprot, oprot):args = getScanForOrder_args()args.read(iprot)iprot.readMessageEnd()result = getScanForOrder_result()result.success = self._handler.getScanForOrder(args.orderId)oprot.writeMessageBegin("getScanForOrder", TMessageType.REPLY, seqid)result.write(oprot)oprot.writeMessageEnd()oprot.trans.flush()def process_getScan(self, seqid, iprot, oprot):args = getScan_args()args.read(iprot)iprot.readMessageEnd()result = getScan_result()result.success = self._handler.getScan(args.inventoryItemId)oprot.writeMessageBegin("getScan", TMessageType.REPLY, seqid)result.write(oprot)oprot.writeMessageEnd()oprot.trans.flush()def process_scanSerializedItem(self, seqid, iprot, oprot):args = scanSerializedItem_args()args.read(iprot)iprot.readMessageEnd()result = scanSerializedItem_result()try:self._handler.scanSerializedItem(args.inventoryItem, args.type, args.warehouseId)except WarehouseServiceException, wex:result.wex = wexoprot.writeMessageBegin("scanSerializedItem", TMessageType.REPLY, seqid)result.write(oprot)oprot.writeMessageEnd()oprot.trans.flush()def process_scan(self, seqid, iprot, oprot):args = scan_args()args.read(iprot)iprot.readMessageEnd()result = scan_result()try:self._handler.scan(args.inventoryItemId, args.type, args.quantity, args.warehouseId)except WarehouseServiceException, wex:result.wex = wexoprot.writeMessageBegin("scan", TMessageType.REPLY, seqid)result.write(oprot)oprot.writeMessageEnd()oprot.trans.flush()def process_scanSerializedItemForOrder(self, seqid, iprot, oprot):args = scanSerializedItemForOrder_args()args.read(iprot)iprot.readMessageEnd()result = scanSerializedItemForOrder_result()try:result.success = self._handler.scanSerializedItemForOrder(args.serialNumber, args.type, args.orderId, args.fulfilmentWarehouseId, args.quantity, args.billingWarehouseId)except WarehouseServiceException, wex:result.wex = wexoprot.writeMessageBegin("scanSerializedItemForOrder", TMessageType.REPLY, seqid)result.write(oprot)oprot.writeMessageEnd()oprot.trans.flush()def process_scanForOrder(self, seqid, iprot, oprot):args = scanForOrder_args()args.read(iprot)iprot.readMessageEnd()result = scanForOrder_result()try:self._handler.scanForOrder(args.inventoryItemId, args.type, args.quantity, args.orderId, args.fulfilmentWarehouseId)except WarehouseServiceException, wex:result.wex = wexoprot.writeMessageBegin("scanForOrder", TMessageType.REPLY, seqid)result.write(oprot)oprot.writeMessageEnd()oprot.trans.flush()def process_createItemNumberMapping(self, seqid, iprot, oprot):args = createItemNumberMapping_args()args.read(iprot)iprot.readMessageEnd()result = createItemNumberMapping_result()self._handler.createItemNumberMapping(args.itemNumber, args.itemId)oprot.writeMessageBegin("createItemNumberMapping", TMessageType.REPLY, seqid)result.write(oprot)oprot.writeMessageEnd()oprot.trans.flush()def process_getItemNumbers(self, seqid, iprot, oprot):args = getItemNumbers_args()args.read(iprot)iprot.readMessageEnd()result = getItemNumbers_result()result.success = self._handler.getItemNumbers(args.itemId)oprot.writeMessageBegin("getItemNumbers", TMessageType.REPLY, seqid)result.write(oprot)oprot.writeMessageEnd()oprot.trans.flush()def process_getItemIds(self, seqid, iprot, oprot):args = getItemIds_args()args.read(iprot)iprot.readMessageEnd()result = getItemIds_result()result.success = self._handler.getItemIds(args.itemNumber)oprot.writeMessageBegin("getItemIds", TMessageType.REPLY, seqid)result.write(oprot)oprot.writeMessageEnd()oprot.trans.flush()def process_getInventoryItemsFromLastScanType(self, seqid, iprot, oprot):args = getInventoryItemsFromLastScanType_args()args.read(iprot)iprot.readMessageEnd()result = getInventoryItemsFromLastScanType_result()try:result.success = self._handler.getInventoryItemsFromLastScanType(args.lastScanType)except WarehouseServiceException, wex:result.wex = wexoprot.writeMessageBegin("getInventoryItemsFromLastScanType", TMessageType.REPLY, seqid)result.write(oprot)oprot.writeMessageEnd()oprot.trans.flush()def process_getInventoryItemFromId(self, seqid, iprot, oprot):args = getInventoryItemFromId_args()args.read(iprot)iprot.readMessageEnd()result = getInventoryItemFromId_result()try:result.success = self._handler.getInventoryItemFromId(args.inventoryItemId)except WarehouseServiceException, wex:result.wex = wexoprot.writeMessageBegin("getInventoryItemFromId", TMessageType.REPLY, seqid)result.write(oprot)oprot.writeMessageEnd()oprot.trans.flush()# HELPER FUNCTIONS AND STRUCTURESclass createSerializedInventoryItem_args:"""Attributes:- itemId- itemNumber- serialNumber- purchaseId"""thrift_spec = (None, # 0(1, TType.I64, 'itemId', None, None, ), # 1(2, TType.STRING, 'itemNumber', None, None, ), # 2(3, TType.STRING, 'serialNumber', None, None, ), # 3(4, TType.I64, 'purchaseId', None, None, ), # 4)def __init__(self, itemId=None, itemNumber=None, serialNumber=None, purchaseId=None,):self.itemId = itemIdself.itemNumber = itemNumberself.serialNumber = serialNumberself.purchaseId = purchaseIddef read(self, iprot):if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))returniprot.readStructBegin()while True:(fname, ftype, fid) = iprot.readFieldBegin()if ftype == TType.STOP:breakif fid == 1:if ftype == TType.I64:self.itemId = iprot.readI64();else:iprot.skip(ftype)elif fid == 2:if ftype == TType.STRING:self.itemNumber = iprot.readString();else:iprot.skip(ftype)elif fid == 3:if ftype == TType.STRING:self.serialNumber = iprot.readString();else:iprot.skip(ftype)elif fid == 4:if ftype == TType.I64:self.purchaseId = iprot.readI64();else:iprot.skip(ftype)else:iprot.skip(ftype)iprot.readFieldEnd()iprot.readStructEnd()def write(self, oprot):if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))returnoprot.writeStructBegin('createSerializedInventoryItem_args')if self.itemId is not None:oprot.writeFieldBegin('itemId', TType.I64, 1)oprot.writeI64(self.itemId)oprot.writeFieldEnd()if self.itemNumber is not None:oprot.writeFieldBegin('itemNumber', TType.STRING, 2)oprot.writeString(self.itemNumber)oprot.writeFieldEnd()if self.serialNumber is not None:oprot.writeFieldBegin('serialNumber', TType.STRING, 3)oprot.writeString(self.serialNumber)oprot.writeFieldEnd()if self.purchaseId is not None:oprot.writeFieldBegin('purchaseId', TType.I64, 4)oprot.writeI64(self.purchaseId)oprot.writeFieldEnd()oprot.writeFieldStop()oprot.writeStructEnd()def validate(self):returndef __repr__(self):L = ['%s=%r' % (key, value)for key, value in self.__dict__.iteritems()]return '%s(%s)' % (self.__class__.__name__, ', '.join(L))def __eq__(self, other):return isinstance(other, self.__class__) and self.__dict__ == other.__dict__def __ne__(self, other):return not (self == other)class createSerializedInventoryItem_result:"""Attributes:- success- wex"""thrift_spec = ((0, TType.STRUCT, 'success', (InventoryItem, InventoryItem.thrift_spec), None, ), # 0(1, TType.STRUCT, 'wex', (WarehouseServiceException, WarehouseServiceException.thrift_spec), None, ), # 1)def __init__(self, success=None, wex=None,):self.success = successself.wex = wexdef read(self, iprot):if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))returniprot.readStructBegin()while True:(fname, ftype, fid) = iprot.readFieldBegin()if ftype == TType.STOP:breakif fid == 0:if ftype == TType.STRUCT:self.success = InventoryItem()self.success.read(iprot)else:iprot.skip(ftype)elif fid == 1:if ftype == TType.STRUCT:self.wex = WarehouseServiceException()self.wex.read(iprot)else:iprot.skip(ftype)else:iprot.skip(ftype)iprot.readFieldEnd()iprot.readStructEnd()def write(self, oprot):if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))returnoprot.writeStructBegin('createSerializedInventoryItem_result')if self.success is not None:oprot.writeFieldBegin('success', TType.STRUCT, 0)self.success.write(oprot)oprot.writeFieldEnd()if self.wex is not None:oprot.writeFieldBegin('wex', TType.STRUCT, 1)self.wex.write(oprot)oprot.writeFieldEnd()oprot.writeFieldStop()oprot.writeStructEnd()def validate(self):returndef __repr__(self):L = ['%s=%r' % (key, value)for key, value in self.__dict__.iteritems()]return '%s(%s)' % (self.__class__.__name__, ', '.join(L))def __eq__(self, other):return isinstance(other, self.__class__) and self.__dict__ == other.__dict__def __ne__(self, other):return not (self == other)class createSerializedInventoryItemFromItemNumber_args:"""Attributes:- itemNumber- serialNumber- purchaseId"""thrift_spec = (None, # 0(1, TType.STRING, 'itemNumber', None, None, ), # 1(2, TType.STRING, 'serialNumber', None, None, ), # 2(3, TType.I64, 'purchaseId', None, None, ), # 3)def __init__(self, itemNumber=None, serialNumber=None, purchaseId=None,):self.itemNumber = itemNumberself.serialNumber = serialNumberself.purchaseId = purchaseIddef read(self, iprot):if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))returniprot.readStructBegin()while True:(fname, ftype, fid) = iprot.readFieldBegin()if ftype == TType.STOP:breakif fid == 1:if ftype == TType.STRING:self.itemNumber = iprot.readString();else:iprot.skip(ftype)elif fid == 2:if ftype == TType.STRING:self.serialNumber = iprot.readString();else:iprot.skip(ftype)elif fid == 3:if ftype == TType.I64:self.purchaseId = iprot.readI64();else:iprot.skip(ftype)else:iprot.skip(ftype)iprot.readFieldEnd()iprot.readStructEnd()def write(self, oprot):if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))returnoprot.writeStructBegin('createSerializedInventoryItemFromItemNumber_args')if self.itemNumber is not None:oprot.writeFieldBegin('itemNumber', TType.STRING, 1)oprot.writeString(self.itemNumber)oprot.writeFieldEnd()if self.serialNumber is not None:oprot.writeFieldBegin('serialNumber', TType.STRING, 2)oprot.writeString(self.serialNumber)oprot.writeFieldEnd()if self.purchaseId is not None:oprot.writeFieldBegin('purchaseId', TType.I64, 3)oprot.writeI64(self.purchaseId)oprot.writeFieldEnd()oprot.writeFieldStop()oprot.writeStructEnd()def validate(self):returndef __repr__(self):L = ['%s=%r' % (key, value)for key, value in self.__dict__.iteritems()]return '%s(%s)' % (self.__class__.__name__, ', '.join(L))def __eq__(self, other):return isinstance(other, self.__class__) and self.__dict__ == other.__dict__def __ne__(self, other):return not (self == other)class createSerializedInventoryItemFromItemNumber_result:"""Attributes:- success- wex"""thrift_spec = ((0, TType.STRUCT, 'success', (InventoryItem, InventoryItem.thrift_spec), None, ), # 0(1, TType.STRUCT, 'wex', (WarehouseServiceException, WarehouseServiceException.thrift_spec), None, ), # 1)def __init__(self, success=None, wex=None,):self.success = successself.wex = wexdef read(self, iprot):if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))returniprot.readStructBegin()while True:(fname, ftype, fid) = iprot.readFieldBegin()if ftype == TType.STOP:breakif fid == 0:if ftype == TType.STRUCT:self.success = InventoryItem()self.success.read(iprot)else:iprot.skip(ftype)elif fid == 1:if ftype == TType.STRUCT:self.wex = WarehouseServiceException()self.wex.read(iprot)else:iprot.skip(ftype)else:iprot.skip(ftype)iprot.readFieldEnd()iprot.readStructEnd()def write(self, oprot):if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))returnoprot.writeStructBegin('createSerializedInventoryItemFromItemNumber_result')if self.success is not None:oprot.writeFieldBegin('success', TType.STRUCT, 0)self.success.write(oprot)oprot.writeFieldEnd()if self.wex is not None:oprot.writeFieldBegin('wex', TType.STRUCT, 1)self.wex.write(oprot)oprot.writeFieldEnd()oprot.writeFieldStop()oprot.writeStructEnd()def validate(self):returndef __repr__(self):L = ['%s=%r' % (key, value)for key, value in self.__dict__.iteritems()]return '%s(%s)' % (self.__class__.__name__, ', '.join(L))def __eq__(self, other):return isinstance(other, self.__class__) and self.__dict__ == other.__dict__def __ne__(self, other):return not (self == other)class createInventoryItem_args:"""Attributes:- itemId- quantity- purchaseId"""thrift_spec = (None, # 0(1, TType.I64, 'itemId', None, None, ), # 1(2, TType.I64, 'quantity', None, None, ), # 2(3, TType.I64, 'purchaseId', None, None, ), # 3)def __init__(self, itemId=None, quantity=None, purchaseId=None,):self.itemId = itemIdself.quantity = quantityself.purchaseId = purchaseIddef read(self, iprot):if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))returniprot.readStructBegin()while True:(fname, ftype, fid) = iprot.readFieldBegin()if ftype == TType.STOP:breakif fid == 1:if ftype == TType.I64:self.itemId = iprot.readI64();else:iprot.skip(ftype)elif fid == 2:if ftype == TType.I64:self.quantity = iprot.readI64();else:iprot.skip(ftype)elif fid == 3:if ftype == TType.I64:self.purchaseId = iprot.readI64();else:iprot.skip(ftype)else:iprot.skip(ftype)iprot.readFieldEnd()iprot.readStructEnd()def write(self, oprot):if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))returnoprot.writeStructBegin('createInventoryItem_args')if self.itemId is not None:oprot.writeFieldBegin('itemId', TType.I64, 1)oprot.writeI64(self.itemId)oprot.writeFieldEnd()if self.quantity is not None:oprot.writeFieldBegin('quantity', TType.I64, 2)oprot.writeI64(self.quantity)oprot.writeFieldEnd()if self.purchaseId is not None:oprot.writeFieldBegin('purchaseId', TType.I64, 3)oprot.writeI64(self.purchaseId)oprot.writeFieldEnd()oprot.writeFieldStop()oprot.writeStructEnd()def validate(self):returndef __repr__(self):L = ['%s=%r' % (key, value)for key, value in self.__dict__.iteritems()]return '%s(%s)' % (self.__class__.__name__, ', '.join(L))def __eq__(self, other):return isinstance(other, self.__class__) and self.__dict__ == other.__dict__def __ne__(self, other):return not (self == other)class createInventoryItem_result:"""Attributes:- success- wex"""thrift_spec = ((0, TType.STRUCT, 'success', (InventoryItem, InventoryItem.thrift_spec), None, ), # 0(1, TType.STRUCT, 'wex', (WarehouseServiceException, WarehouseServiceException.thrift_spec), None, ), # 1)def __init__(self, success=None, wex=None,):self.success = successself.wex = wexdef read(self, iprot):if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))returniprot.readStructBegin()while True:(fname, ftype, fid) = iprot.readFieldBegin()if ftype == TType.STOP:breakif fid == 0:if ftype == TType.STRUCT:self.success = InventoryItem()self.success.read(iprot)else:iprot.skip(ftype)elif fid == 1:if ftype == TType.STRUCT:self.wex = WarehouseServiceException()self.wex.read(iprot)else:iprot.skip(ftype)else:iprot.skip(ftype)iprot.readFieldEnd()iprot.readStructEnd()def write(self, oprot):if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))returnoprot.writeStructBegin('createInventoryItem_result')if self.success is not None:oprot.writeFieldBegin('success', TType.STRUCT, 0)self.success.write(oprot)oprot.writeFieldEnd()if self.wex is not None:oprot.writeFieldBegin('wex', TType.STRUCT, 1)self.wex.write(oprot)oprot.writeFieldEnd()oprot.writeFieldStop()oprot.writeStructEnd()def validate(self):returndef __repr__(self):L = ['%s=%r' % (key, value)for key, value in self.__dict__.iteritems()]return '%s(%s)' % (self.__class__.__name__, ', '.join(L))def __eq__(self, other):return isinstance(other, self.__class__) and self.__dict__ == other.__dict__def __ne__(self, other):return not (self == other)class getInventoryItem_args:"""Attributes:- serialNumber"""thrift_spec = (None, # 0(1, TType.STRING, 'serialNumber', None, None, ), # 1)def __init__(self, serialNumber=None,):self.serialNumber = serialNumberdef read(self, iprot):if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))returniprot.readStructBegin()while True:(fname, ftype, fid) = iprot.readFieldBegin()if ftype == TType.STOP:breakif fid == 1:if ftype == TType.STRING:self.serialNumber = iprot.readString();else:iprot.skip(ftype)else:iprot.skip(ftype)iprot.readFieldEnd()iprot.readStructEnd()def write(self, oprot):if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))returnoprot.writeStructBegin('getInventoryItem_args')if self.serialNumber is not None:oprot.writeFieldBegin('serialNumber', TType.STRING, 1)oprot.writeString(self.serialNumber)oprot.writeFieldEnd()oprot.writeFieldStop()oprot.writeStructEnd()def validate(self):returndef __repr__(self):L = ['%s=%r' % (key, value)for key, value in self.__dict__.iteritems()]return '%s(%s)' % (self.__class__.__name__, ', '.join(L))def __eq__(self, other):return isinstance(other, self.__class__) and self.__dict__ == other.__dict__def __ne__(self, other):return not (self == other)class getInventoryItem_result:"""Attributes:- success- wex"""thrift_spec = ((0, TType.STRUCT, 'success', (InventoryItem, InventoryItem.thrift_spec), None, ), # 0(1, TType.STRUCT, 'wex', (WarehouseServiceException, WarehouseServiceException.thrift_spec), None, ), # 1)def __init__(self, success=None, wex=None,):self.success = successself.wex = wexdef read(self, iprot):if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))returniprot.readStructBegin()while True:(fname, ftype, fid) = iprot.readFieldBegin()if ftype == TType.STOP:breakif fid == 0:if ftype == TType.STRUCT:self.success = InventoryItem()self.success.read(iprot)else:iprot.skip(ftype)elif fid == 1:if ftype == TType.STRUCT:self.wex = WarehouseServiceException()self.wex.read(iprot)else:iprot.skip(ftype)else:iprot.skip(ftype)iprot.readFieldEnd()iprot.readStructEnd()def write(self, oprot):if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))returnoprot.writeStructBegin('getInventoryItem_result')if self.success is not None:oprot.writeFieldBegin('success', TType.STRUCT, 0)self.success.write(oprot)oprot.writeFieldEnd()if self.wex is not None:oprot.writeFieldBegin('wex', TType.STRUCT, 1)self.wex.write(oprot)oprot.writeFieldEnd()oprot.writeFieldStop()oprot.writeStructEnd()def validate(self):returndef __repr__(self):L = ['%s=%r' % (key, value)for key, value in self.__dict__.iteritems()]return '%s(%s)' % (self.__class__.__name__, ', '.join(L))def __eq__(self, other):return isinstance(other, self.__class__) and self.__dict__ == other.__dict__def __ne__(self, other):return not (self == other)class getNonSeralizedInventoryItems_args:"""Attributes:- itemId- quantity- supplierId"""thrift_spec = (None, # 0(1, TType.I64, 'itemId', None, None, ), # 1(2, TType.I64, 'quantity', None, None, ), # 2(3, TType.I64, 'supplierId', None, None, ), # 3)def __init__(self, itemId=None, quantity=None, supplierId=None,):self.itemId = itemIdself.quantity = quantityself.supplierId = supplierIddef read(self, iprot):if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))returniprot.readStructBegin()while True:(fname, ftype, fid) = iprot.readFieldBegin()if ftype == TType.STOP:breakif fid == 1:if ftype == TType.I64:self.itemId = iprot.readI64();else:iprot.skip(ftype)elif fid == 2:if ftype == TType.I64:self.quantity = iprot.readI64();else:iprot.skip(ftype)elif fid == 3:if ftype == TType.I64:self.supplierId = iprot.readI64();else:iprot.skip(ftype)else:iprot.skip(ftype)iprot.readFieldEnd()iprot.readStructEnd()def write(self, oprot):if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))returnoprot.writeStructBegin('getNonSeralizedInventoryItems_args')if self.itemId is not None:oprot.writeFieldBegin('itemId', TType.I64, 1)oprot.writeI64(self.itemId)oprot.writeFieldEnd()if self.quantity is not None:oprot.writeFieldBegin('quantity', TType.I64, 2)oprot.writeI64(self.quantity)oprot.writeFieldEnd()if self.supplierId is not None:oprot.writeFieldBegin('supplierId', TType.I64, 3)oprot.writeI64(self.supplierId)oprot.writeFieldEnd()oprot.writeFieldStop()oprot.writeStructEnd()def validate(self):returndef __repr__(self):L = ['%s=%r' % (key, value)for key, value in self.__dict__.iteritems()]return '%s(%s)' % (self.__class__.__name__, ', '.join(L))def __eq__(self, other):return isinstance(other, self.__class__) and self.__dict__ == other.__dict__def __ne__(self, other):return not (self == other)class getNonSeralizedInventoryItems_result:"""Attributes:- success"""thrift_spec = ((0, TType.LIST, 'success', (TType.STRUCT,(InventoryItem, InventoryItem.thrift_spec)), None, ), # 0)def __init__(self, success=None,):self.success = successdef read(self, iprot):if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))returniprot.readStructBegin()while True:(fname, ftype, fid) = iprot.readFieldBegin()if ftype == TType.STOP:breakif fid == 0:if ftype == TType.LIST:self.success = [](_etype3, _size0) = iprot.readListBegin()for _i4 in xrange(_size0):_elem5 = InventoryItem()_elem5.read(iprot)self.success.append(_elem5)iprot.readListEnd()else:iprot.skip(ftype)else:iprot.skip(ftype)iprot.readFieldEnd()iprot.readStructEnd()def write(self, oprot):if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))returnoprot.writeStructBegin('getNonSeralizedInventoryItems_result')if self.success is not None:oprot.writeFieldBegin('success', TType.LIST, 0)oprot.writeListBegin(TType.STRUCT, len(self.success))for iter6 in self.success:iter6.write(oprot)oprot.writeListEnd()oprot.writeFieldEnd()oprot.writeFieldStop()oprot.writeStructEnd()def validate(self):returndef __repr__(self):L = ['%s=%r' % (key, value)for key, value in self.__dict__.iteritems()]return '%s(%s)' % (self.__class__.__name__, ', '.join(L))def __eq__(self, other):return isinstance(other, self.__class__) and self.__dict__ == other.__dict__def __ne__(self, other):return not (self == other)class getInventoryItems_args:"""Attributes:- itemId"""thrift_spec = (None, # 0(1, TType.I64, 'itemId', None, None, ), # 1)def __init__(self, itemId=None,):self.itemId = itemIddef read(self, iprot):if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))returniprot.readStructBegin()while True:(fname, ftype, fid) = iprot.readFieldBegin()if ftype == TType.STOP:breakif fid == 1:if ftype == TType.I64:self.itemId = iprot.readI64();else:iprot.skip(ftype)else:iprot.skip(ftype)iprot.readFieldEnd()iprot.readStructEnd()def write(self, oprot):if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))returnoprot.writeStructBegin('getInventoryItems_args')if self.itemId is not None:oprot.writeFieldBegin('itemId', TType.I64, 1)oprot.writeI64(self.itemId)oprot.writeFieldEnd()oprot.writeFieldStop()oprot.writeStructEnd()def validate(self):returndef __repr__(self):L = ['%s=%r' % (key, value)for key, value in self.__dict__.iteritems()]return '%s(%s)' % (self.__class__.__name__, ', '.join(L))def __eq__(self, other):return isinstance(other, self.__class__) and self.__dict__ == other.__dict__def __ne__(self, other):return not (self == other)class getInventoryItems_result:"""Attributes:- success"""thrift_spec = ((0, TType.LIST, 'success', (TType.STRUCT,(InventoryItem, InventoryItem.thrift_spec)), None, ), # 0)def __init__(self, success=None,):self.success = successdef read(self, iprot):if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))returniprot.readStructBegin()while True:(fname, ftype, fid) = iprot.readFieldBegin()if ftype == TType.STOP:breakif fid == 0:if ftype == TType.LIST:self.success = [](_etype10, _size7) = iprot.readListBegin()for _i11 in xrange(_size7):_elem12 = InventoryItem()_elem12.read(iprot)self.success.append(_elem12)iprot.readListEnd()else:iprot.skip(ftype)else:iprot.skip(ftype)iprot.readFieldEnd()iprot.readStructEnd()def write(self, oprot):if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))returnoprot.writeStructBegin('getInventoryItems_result')if self.success is not None:oprot.writeFieldBegin('success', TType.LIST, 0)oprot.writeListBegin(TType.STRUCT, len(self.success))for iter13 in self.success:iter13.write(oprot)oprot.writeListEnd()oprot.writeFieldEnd()oprot.writeFieldStop()oprot.writeStructEnd()def validate(self):returndef __repr__(self):L = ['%s=%r' % (key, value)for key, value in self.__dict__.iteritems()]return '%s(%s)' % (self.__class__.__name__, ', '.join(L))def __eq__(self, other):return isinstance(other, self.__class__) and self.__dict__ == other.__dict__def __ne__(self, other):return not (self == other)class getScanForOrder_args:"""Attributes:- orderId"""thrift_spec = (None, # 0(1, TType.I64, 'orderId', None, None, ), # 1)def __init__(self, orderId=None,):self.orderId = orderIddef read(self, iprot):if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))returniprot.readStructBegin()while True:(fname, ftype, fid) = iprot.readFieldBegin()if ftype == TType.STOP:breakif fid == 1:if ftype == TType.I64:self.orderId = iprot.readI64();else:iprot.skip(ftype)else:iprot.skip(ftype)iprot.readFieldEnd()iprot.readStructEnd()def write(self, oprot):if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))returnoprot.writeStructBegin('getScanForOrder_args')if self.orderId is not None:oprot.writeFieldBegin('orderId', TType.I64, 1)oprot.writeI64(self.orderId)oprot.writeFieldEnd()oprot.writeFieldStop()oprot.writeStructEnd()def validate(self):returndef __repr__(self):L = ['%s=%r' % (key, value)for key, value in self.__dict__.iteritems()]return '%s(%s)' % (self.__class__.__name__, ', '.join(L))def __eq__(self, other):return isinstance(other, self.__class__) and self.__dict__ == other.__dict__def __ne__(self, other):return not (self == other)class getScanForOrder_result:"""Attributes:- success"""thrift_spec = ((0, TType.LIST, 'success', (TType.STRUCT,(Scan, Scan.thrift_spec)), None, ), # 0)def __init__(self, success=None,):self.success = successdef read(self, iprot):if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))returniprot.readStructBegin()while True:(fname, ftype, fid) = iprot.readFieldBegin()if ftype == TType.STOP:breakif fid == 0:if ftype == TType.LIST:self.success = [](_etype17, _size14) = iprot.readListBegin()for _i18 in xrange(_size14):_elem19 = Scan()_elem19.read(iprot)self.success.append(_elem19)iprot.readListEnd()else:iprot.skip(ftype)else:iprot.skip(ftype)iprot.readFieldEnd()iprot.readStructEnd()def write(self, oprot):if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))returnoprot.writeStructBegin('getScanForOrder_result')if self.success is not None:oprot.writeFieldBegin('success', TType.LIST, 0)oprot.writeListBegin(TType.STRUCT, len(self.success))for iter20 in self.success:iter20.write(oprot)oprot.writeListEnd()oprot.writeFieldEnd()oprot.writeFieldStop()oprot.writeStructEnd()def validate(self):returndef __repr__(self):L = ['%s=%r' % (key, value)for key, value in self.__dict__.iteritems()]return '%s(%s)' % (self.__class__.__name__, ', '.join(L))def __eq__(self, other):return isinstance(other, self.__class__) and self.__dict__ == other.__dict__def __ne__(self, other):return not (self == other)class getScan_args:"""Attributes:- inventoryItemId"""thrift_spec = (None, # 0(1, TType.I64, 'inventoryItemId', None, None, ), # 1)def __init__(self, inventoryItemId=None,):self.inventoryItemId = inventoryItemIddef read(self, iprot):if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))returniprot.readStructBegin()while True:(fname, ftype, fid) = iprot.readFieldBegin()if ftype == TType.STOP:breakif fid == 1:if ftype == TType.I64:self.inventoryItemId = iprot.readI64();else:iprot.skip(ftype)else:iprot.skip(ftype)iprot.readFieldEnd()iprot.readStructEnd()def write(self, oprot):if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))returnoprot.writeStructBegin('getScan_args')if self.inventoryItemId is not None:oprot.writeFieldBegin('inventoryItemId', TType.I64, 1)oprot.writeI64(self.inventoryItemId)oprot.writeFieldEnd()oprot.writeFieldStop()oprot.writeStructEnd()def validate(self):returndef __repr__(self):L = ['%s=%r' % (key, value)for key, value in self.__dict__.iteritems()]return '%s(%s)' % (self.__class__.__name__, ', '.join(L))def __eq__(self, other):return isinstance(other, self.__class__) and self.__dict__ == other.__dict__def __ne__(self, other):return not (self == other)class getScan_result:"""Attributes:- success"""thrift_spec = ((0, TType.LIST, 'success', (TType.STRUCT,(Scan, Scan.thrift_spec)), None, ), # 0)def __init__(self, success=None,):self.success = successdef read(self, iprot):if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))returniprot.readStructBegin()while True:(fname, ftype, fid) = iprot.readFieldBegin()if ftype == TType.STOP:breakif fid == 0:if ftype == TType.LIST:self.success = [](_etype24, _size21) = iprot.readListBegin()for _i25 in xrange(_size21):_elem26 = Scan()_elem26.read(iprot)self.success.append(_elem26)iprot.readListEnd()else:iprot.skip(ftype)else:iprot.skip(ftype)iprot.readFieldEnd()iprot.readStructEnd()def write(self, oprot):if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))returnoprot.writeStructBegin('getScan_result')if self.success is not None:oprot.writeFieldBegin('success', TType.LIST, 0)oprot.writeListBegin(TType.STRUCT, len(self.success))for iter27 in self.success:iter27.write(oprot)oprot.writeListEnd()oprot.writeFieldEnd()oprot.writeFieldStop()oprot.writeStructEnd()def validate(self):returndef __repr__(self):L = ['%s=%r' % (key, value)for key, value in self.__dict__.iteritems()]return '%s(%s)' % (self.__class__.__name__, ', '.join(L))def __eq__(self, other):return isinstance(other, self.__class__) and self.__dict__ == other.__dict__def __ne__(self, other):return not (self == other)class scanSerializedItem_args:"""Attributes:- inventoryItem- type- warehouseId"""thrift_spec = (None, # 0(1, TType.STRUCT, 'inventoryItem', (InventoryItem, InventoryItem.thrift_spec), None, ), # 1(2, TType.I32, 'type', None, None, ), # 2(3, TType.I64, 'warehouseId', None, None, ), # 3)def __init__(self, inventoryItem=None, type=None, warehouseId=None,):self.inventoryItem = inventoryItemself.type = typeself.warehouseId = warehouseIddef read(self, iprot):if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))returniprot.readStructBegin()while True:(fname, ftype, fid) = iprot.readFieldBegin()if ftype == TType.STOP:breakif fid == 1:if ftype == TType.STRUCT:self.inventoryItem = InventoryItem()self.inventoryItem.read(iprot)else:iprot.skip(ftype)elif fid == 2:if ftype == TType.I32:self.type = iprot.readI32();else:iprot.skip(ftype)elif fid == 3:if ftype == TType.I64:self.warehouseId = iprot.readI64();else:iprot.skip(ftype)else:iprot.skip(ftype)iprot.readFieldEnd()iprot.readStructEnd()def write(self, oprot):if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))returnoprot.writeStructBegin('scanSerializedItem_args')if self.inventoryItem is not None:oprot.writeFieldBegin('inventoryItem', TType.STRUCT, 1)self.inventoryItem.write(oprot)oprot.writeFieldEnd()if self.type is not None:oprot.writeFieldBegin('type', TType.I32, 2)oprot.writeI32(self.type)oprot.writeFieldEnd()if self.warehouseId is not None:oprot.writeFieldBegin('warehouseId', TType.I64, 3)oprot.writeI64(self.warehouseId)oprot.writeFieldEnd()oprot.writeFieldStop()oprot.writeStructEnd()def validate(self):returndef __repr__(self):L = ['%s=%r' % (key, value)for key, value in self.__dict__.iteritems()]return '%s(%s)' % (self.__class__.__name__, ', '.join(L))def __eq__(self, other):return isinstance(other, self.__class__) and self.__dict__ == other.__dict__def __ne__(self, other):return not (self == other)class scanSerializedItem_result:"""Attributes:- wex"""thrift_spec = (None, # 0(1, TType.STRUCT, 'wex', (WarehouseServiceException, WarehouseServiceException.thrift_spec), None, ), # 1)def __init__(self, wex=None,):self.wex = wexdef read(self, iprot):if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))returniprot.readStructBegin()while True:(fname, ftype, fid) = iprot.readFieldBegin()if ftype == TType.STOP:breakif fid == 1:if ftype == TType.STRUCT:self.wex = WarehouseServiceException()self.wex.read(iprot)else:iprot.skip(ftype)else:iprot.skip(ftype)iprot.readFieldEnd()iprot.readStructEnd()def write(self, oprot):if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))returnoprot.writeStructBegin('scanSerializedItem_result')if self.wex is not None:oprot.writeFieldBegin('wex', TType.STRUCT, 1)self.wex.write(oprot)oprot.writeFieldEnd()oprot.writeFieldStop()oprot.writeStructEnd()def validate(self):returndef __repr__(self):L = ['%s=%r' % (key, value)for key, value in self.__dict__.iteritems()]return '%s(%s)' % (self.__class__.__name__, ', '.join(L))def __eq__(self, other):return isinstance(other, self.__class__) and self.__dict__ == other.__dict__def __ne__(self, other):return not (self == other)class scan_args:"""Attributes:- inventoryItemId- type- quantity- warehouseId"""thrift_spec = (None, # 0(1, TType.I64, 'inventoryItemId', None, None, ), # 1(2, TType.I32, 'type', None, None, ), # 2(3, TType.I64, 'quantity', None, None, ), # 3(4, TType.I64, 'warehouseId', None, None, ), # 4)def __init__(self, inventoryItemId=None, type=None, quantity=None, warehouseId=None,):self.inventoryItemId = inventoryItemIdself.type = typeself.quantity = quantityself.warehouseId = warehouseIddef read(self, iprot):if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))returniprot.readStructBegin()while True:(fname, ftype, fid) = iprot.readFieldBegin()if ftype == TType.STOP:breakif fid == 1:if ftype == TType.I64:self.inventoryItemId = iprot.readI64();else:iprot.skip(ftype)elif fid == 2:if ftype == TType.I32:self.type = iprot.readI32();else:iprot.skip(ftype)elif fid == 3:if ftype == TType.I64:self.quantity = iprot.readI64();else:iprot.skip(ftype)elif fid == 4:if ftype == TType.I64:self.warehouseId = iprot.readI64();else:iprot.skip(ftype)else:iprot.skip(ftype)iprot.readFieldEnd()iprot.readStructEnd()def write(self, oprot):if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))returnoprot.writeStructBegin('scan_args')if self.inventoryItemId is not None:oprot.writeFieldBegin('inventoryItemId', TType.I64, 1)oprot.writeI64(self.inventoryItemId)oprot.writeFieldEnd()if self.type is not None:oprot.writeFieldBegin('type', TType.I32, 2)oprot.writeI32(self.type)oprot.writeFieldEnd()if self.quantity is not None:oprot.writeFieldBegin('quantity', TType.I64, 3)oprot.writeI64(self.quantity)oprot.writeFieldEnd()if self.warehouseId is not None:oprot.writeFieldBegin('warehouseId', TType.I64, 4)oprot.writeI64(self.warehouseId)oprot.writeFieldEnd()oprot.writeFieldStop()oprot.writeStructEnd()def validate(self):returndef __repr__(self):L = ['%s=%r' % (key, value)for key, value in self.__dict__.iteritems()]return '%s(%s)' % (self.__class__.__name__, ', '.join(L))def __eq__(self, other):return isinstance(other, self.__class__) and self.__dict__ == other.__dict__def __ne__(self, other):return not (self == other)class scan_result:"""Attributes:- wex"""thrift_spec = (None, # 0(1, TType.STRUCT, 'wex', (WarehouseServiceException, WarehouseServiceException.thrift_spec), None, ), # 1)def __init__(self, wex=None,):self.wex = wexdef read(self, iprot):if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))returniprot.readStructBegin()while True:(fname, ftype, fid) = iprot.readFieldBegin()if ftype == TType.STOP:breakif fid == 1:if ftype == TType.STRUCT:self.wex = WarehouseServiceException()self.wex.read(iprot)else:iprot.skip(ftype)else:iprot.skip(ftype)iprot.readFieldEnd()iprot.readStructEnd()def write(self, oprot):if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))returnoprot.writeStructBegin('scan_result')if self.wex is not None:oprot.writeFieldBegin('wex', TType.STRUCT, 1)self.wex.write(oprot)oprot.writeFieldEnd()oprot.writeFieldStop()oprot.writeStructEnd()def validate(self):returndef __repr__(self):L = ['%s=%r' % (key, value)for key, value in self.__dict__.iteritems()]return '%s(%s)' % (self.__class__.__name__, ', '.join(L))def __eq__(self, other):return isinstance(other, self.__class__) and self.__dict__ == other.__dict__def __ne__(self, other):return not (self == other)class scanSerializedItemForOrder_args:"""Attributes:- serialNumber- type- orderId- fulfilmentWarehouseId- quantity- billingWarehouseId"""thrift_spec = (None, # 0(1, TType.STRING, 'serialNumber', None, None, ), # 1(2, TType.I32, 'type', None, None, ), # 2(3, TType.I64, 'orderId', None, None, ), # 3(4, TType.I64, 'fulfilmentWarehouseId', None, None, ), # 4(5, TType.DOUBLE, 'quantity', None, None, ), # 5(6, TType.I64, 'billingWarehouseId', None, None, ), # 6)def __init__(self, serialNumber=None, type=None, orderId=None, fulfilmentWarehouseId=None, quantity=None, billingWarehouseId=None,):self.serialNumber = serialNumberself.type = typeself.orderId = orderIdself.fulfilmentWarehouseId = fulfilmentWarehouseIdself.quantity = quantityself.billingWarehouseId = billingWarehouseIddef read(self, iprot):if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))returniprot.readStructBegin()while True:(fname, ftype, fid) = iprot.readFieldBegin()if ftype == TType.STOP:breakif fid == 1:if ftype == TType.STRING:self.serialNumber = iprot.readString();else:iprot.skip(ftype)elif fid == 2:if ftype == TType.I32:self.type = iprot.readI32();else:iprot.skip(ftype)elif fid == 3:if ftype == TType.I64:self.orderId = iprot.readI64();else:iprot.skip(ftype)elif fid == 4:if ftype == TType.I64:self.fulfilmentWarehouseId = iprot.readI64();else:iprot.skip(ftype)elif fid == 5:if ftype == TType.DOUBLE:self.quantity = iprot.readDouble();else:iprot.skip(ftype)elif fid == 6:if ftype == TType.I64:self.billingWarehouseId = iprot.readI64();else:iprot.skip(ftype)else:iprot.skip(ftype)iprot.readFieldEnd()iprot.readStructEnd()def write(self, oprot):if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))returnoprot.writeStructBegin('scanSerializedItemForOrder_args')if self.serialNumber is not None:oprot.writeFieldBegin('serialNumber', TType.STRING, 1)oprot.writeString(self.serialNumber)oprot.writeFieldEnd()if self.type is not None:oprot.writeFieldBegin('type', TType.I32, 2)oprot.writeI32(self.type)oprot.writeFieldEnd()if self.orderId is not None:oprot.writeFieldBegin('orderId', TType.I64, 3)oprot.writeI64(self.orderId)oprot.writeFieldEnd()if self.fulfilmentWarehouseId is not None:oprot.writeFieldBegin('fulfilmentWarehouseId', TType.I64, 4)oprot.writeI64(self.fulfilmentWarehouseId)oprot.writeFieldEnd()if self.quantity is not None:oprot.writeFieldBegin('quantity', TType.DOUBLE, 5)oprot.writeDouble(self.quantity)oprot.writeFieldEnd()if self.billingWarehouseId is not None:oprot.writeFieldBegin('billingWarehouseId', TType.I64, 6)oprot.writeI64(self.billingWarehouseId)oprot.writeFieldEnd()oprot.writeFieldStop()oprot.writeStructEnd()def validate(self):returndef __repr__(self):L = ['%s=%r' % (key, value)for key, value in self.__dict__.iteritems()]return '%s(%s)' % (self.__class__.__name__, ', '.join(L))def __eq__(self, other):return isinstance(other, self.__class__) and self.__dict__ == other.__dict__def __ne__(self, other):return not (self == other)class scanSerializedItemForOrder_result:"""Attributes:- success- wex"""thrift_spec = ((0, TType.STRUCT, 'success', (InventoryItem, InventoryItem.thrift_spec), None, ), # 0(1, TType.STRUCT, 'wex', (WarehouseServiceException, WarehouseServiceException.thrift_spec), None, ), # 1)def __init__(self, success=None, wex=None,):self.success = successself.wex = wexdef read(self, iprot):if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))returniprot.readStructBegin()while True:(fname, ftype, fid) = iprot.readFieldBegin()if ftype == TType.STOP:breakif fid == 0:if ftype == TType.STRUCT:self.success = InventoryItem()self.success.read(iprot)else:iprot.skip(ftype)elif fid == 1:if ftype == TType.STRUCT:self.wex = WarehouseServiceException()self.wex.read(iprot)else:iprot.skip(ftype)else:iprot.skip(ftype)iprot.readFieldEnd()iprot.readStructEnd()def write(self, oprot):if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))returnoprot.writeStructBegin('scanSerializedItemForOrder_result')if self.success is not None:oprot.writeFieldBegin('success', TType.STRUCT, 0)self.success.write(oprot)oprot.writeFieldEnd()if self.wex is not None:oprot.writeFieldBegin('wex', TType.STRUCT, 1)self.wex.write(oprot)oprot.writeFieldEnd()oprot.writeFieldStop()oprot.writeStructEnd()def validate(self):returndef __repr__(self):L = ['%s=%r' % (key, value)for key, value in self.__dict__.iteritems()]return '%s(%s)' % (self.__class__.__name__, ', '.join(L))def __eq__(self, other):return isinstance(other, self.__class__) and self.__dict__ == other.__dict__def __ne__(self, other):return not (self == other)class scanForOrder_args:"""Attributes:- inventoryItemId- type- quantity- orderId- fulfilmentWarehouseId"""thrift_spec = (None, # 0(1, TType.I64, 'inventoryItemId', None, None, ), # 1(2, TType.I32, 'type', None, None, ), # 2(3, TType.I64, 'quantity', None, None, ), # 3(4, TType.I64, 'orderId', None, None, ), # 4(5, TType.I64, 'fulfilmentWarehouseId', None, None, ), # 5)def __init__(self, inventoryItemId=None, type=None, quantity=None, orderId=None, fulfilmentWarehouseId=None,):self.inventoryItemId = inventoryItemIdself.type = typeself.quantity = quantityself.orderId = orderIdself.fulfilmentWarehouseId = fulfilmentWarehouseIddef read(self, iprot):if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))returniprot.readStructBegin()while True:(fname, ftype, fid) = iprot.readFieldBegin()if ftype == TType.STOP:breakif fid == 1:if ftype == TType.I64:self.inventoryItemId = iprot.readI64();else:iprot.skip(ftype)elif fid == 2:if ftype == TType.I32:self.type = iprot.readI32();else:iprot.skip(ftype)elif fid == 3:if ftype == TType.I64:self.quantity = iprot.readI64();else:iprot.skip(ftype)elif fid == 4:if ftype == TType.I64:self.orderId = iprot.readI64();else:iprot.skip(ftype)elif fid == 5:if ftype == TType.I64:self.fulfilmentWarehouseId = iprot.readI64();else:iprot.skip(ftype)else:iprot.skip(ftype)iprot.readFieldEnd()iprot.readStructEnd()def write(self, oprot):if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))returnoprot.writeStructBegin('scanForOrder_args')if self.inventoryItemId is not None:oprot.writeFieldBegin('inventoryItemId', TType.I64, 1)oprot.writeI64(self.inventoryItemId)oprot.writeFieldEnd()if self.type is not None:oprot.writeFieldBegin('type', TType.I32, 2)oprot.writeI32(self.type)oprot.writeFieldEnd()if self.quantity is not None:oprot.writeFieldBegin('quantity', TType.I64, 3)oprot.writeI64(self.quantity)oprot.writeFieldEnd()if self.orderId is not None:oprot.writeFieldBegin('orderId', TType.I64, 4)oprot.writeI64(self.orderId)oprot.writeFieldEnd()if self.fulfilmentWarehouseId is not None:oprot.writeFieldBegin('fulfilmentWarehouseId', TType.I64, 5)oprot.writeI64(self.fulfilmentWarehouseId)oprot.writeFieldEnd()oprot.writeFieldStop()oprot.writeStructEnd()def validate(self):returndef __repr__(self):L = ['%s=%r' % (key, value)for key, value in self.__dict__.iteritems()]return '%s(%s)' % (self.__class__.__name__, ', '.join(L))def __eq__(self, other):return isinstance(other, self.__class__) and self.__dict__ == other.__dict__def __ne__(self, other):return not (self == other)class scanForOrder_result:"""Attributes:- wex"""thrift_spec = (None, # 0(1, TType.STRUCT, 'wex', (WarehouseServiceException, WarehouseServiceException.thrift_spec), None, ), # 1)def __init__(self, wex=None,):self.wex = wexdef read(self, iprot):if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))returniprot.readStructBegin()while True:(fname, ftype, fid) = iprot.readFieldBegin()if ftype == TType.STOP:breakif fid == 1:if ftype == TType.STRUCT:self.wex = WarehouseServiceException()self.wex.read(iprot)else:iprot.skip(ftype)else:iprot.skip(ftype)iprot.readFieldEnd()iprot.readStructEnd()def write(self, oprot):if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))returnoprot.writeStructBegin('scanForOrder_result')if self.wex is not None:oprot.writeFieldBegin('wex', TType.STRUCT, 1)self.wex.write(oprot)oprot.writeFieldEnd()oprot.writeFieldStop()oprot.writeStructEnd()def validate(self):returndef __repr__(self):L = ['%s=%r' % (key, value)for key, value in self.__dict__.iteritems()]return '%s(%s)' % (self.__class__.__name__, ', '.join(L))def __eq__(self, other):return isinstance(other, self.__class__) and self.__dict__ == other.__dict__def __ne__(self, other):return not (self == other)class createItemNumberMapping_args:"""Attributes:- itemNumber- itemId"""thrift_spec = (None, # 0(1, TType.STRING, 'itemNumber', None, None, ), # 1(2, TType.I64, 'itemId', None, None, ), # 2)def __init__(self, itemNumber=None, itemId=None,):self.itemNumber = itemNumberself.itemId = itemIddef read(self, iprot):if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))returniprot.readStructBegin()while True:(fname, ftype, fid) = iprot.readFieldBegin()if ftype == TType.STOP:breakif fid == 1:if ftype == TType.STRING:self.itemNumber = iprot.readString();else:iprot.skip(ftype)elif fid == 2:if ftype == TType.I64:self.itemId = iprot.readI64();else:iprot.skip(ftype)else:iprot.skip(ftype)iprot.readFieldEnd()iprot.readStructEnd()def write(self, oprot):if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))returnoprot.writeStructBegin('createItemNumberMapping_args')if self.itemNumber is not None:oprot.writeFieldBegin('itemNumber', TType.STRING, 1)oprot.writeString(self.itemNumber)oprot.writeFieldEnd()if self.itemId is not None:oprot.writeFieldBegin('itemId', TType.I64, 2)oprot.writeI64(self.itemId)oprot.writeFieldEnd()oprot.writeFieldStop()oprot.writeStructEnd()def validate(self):returndef __repr__(self):L = ['%s=%r' % (key, value)for key, value in self.__dict__.iteritems()]return '%s(%s)' % (self.__class__.__name__, ', '.join(L))def __eq__(self, other):return isinstance(other, self.__class__) and self.__dict__ == other.__dict__def __ne__(self, other):return not (self == other)class createItemNumberMapping_result:thrift_spec = ()def read(self, iprot):if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))returniprot.readStructBegin()while True:(fname, ftype, fid) = iprot.readFieldBegin()if ftype == TType.STOP:breakelse:iprot.skip(ftype)iprot.readFieldEnd()iprot.readStructEnd()def write(self, oprot):if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))returnoprot.writeStructBegin('createItemNumberMapping_result')oprot.writeFieldStop()oprot.writeStructEnd()def validate(self):returndef __repr__(self):L = ['%s=%r' % (key, value)for key, value in self.__dict__.iteritems()]return '%s(%s)' % (self.__class__.__name__, ', '.join(L))def __eq__(self, other):return isinstance(other, self.__class__) and self.__dict__ == other.__dict__def __ne__(self, other):return not (self == other)class getItemNumbers_args:"""Attributes:- itemId"""thrift_spec = (None, # 0(1, TType.I64, 'itemId', None, None, ), # 1)def __init__(self, itemId=None,):self.itemId = itemIddef read(self, iprot):if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))returniprot.readStructBegin()while True:(fname, ftype, fid) = iprot.readFieldBegin()if ftype == TType.STOP:breakif fid == 1:if ftype == TType.I64:self.itemId = iprot.readI64();else:iprot.skip(ftype)else:iprot.skip(ftype)iprot.readFieldEnd()iprot.readStructEnd()def write(self, oprot):if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))returnoprot.writeStructBegin('getItemNumbers_args')if self.itemId is not None:oprot.writeFieldBegin('itemId', TType.I64, 1)oprot.writeI64(self.itemId)oprot.writeFieldEnd()oprot.writeFieldStop()oprot.writeStructEnd()def validate(self):returndef __repr__(self):L = ['%s=%r' % (key, value)for key, value in self.__dict__.iteritems()]return '%s(%s)' % (self.__class__.__name__, ', '.join(L))def __eq__(self, other):return isinstance(other, self.__class__) and self.__dict__ == other.__dict__def __ne__(self, other):return not (self == other)class getItemNumbers_result:"""Attributes:- success"""thrift_spec = ((0, TType.LIST, 'success', (TType.STRING,None), None, ), # 0)def __init__(self, success=None,):self.success = successdef read(self, iprot):if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))returniprot.readStructBegin()while True:(fname, ftype, fid) = iprot.readFieldBegin()if ftype == TType.STOP:breakif fid == 0:if ftype == TType.LIST:self.success = [](_etype31, _size28) = iprot.readListBegin()for _i32 in xrange(_size28):_elem33 = iprot.readString();self.success.append(_elem33)iprot.readListEnd()else:iprot.skip(ftype)else:iprot.skip(ftype)iprot.readFieldEnd()iprot.readStructEnd()def write(self, oprot):if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))returnoprot.writeStructBegin('getItemNumbers_result')if self.success is not None:oprot.writeFieldBegin('success', TType.LIST, 0)oprot.writeListBegin(TType.STRING, len(self.success))for iter34 in self.success:oprot.writeString(iter34)oprot.writeListEnd()oprot.writeFieldEnd()oprot.writeFieldStop()oprot.writeStructEnd()def validate(self):returndef __repr__(self):L = ['%s=%r' % (key, value)for key, value in self.__dict__.iteritems()]return '%s(%s)' % (self.__class__.__name__, ', '.join(L))def __eq__(self, other):return isinstance(other, self.__class__) and self.__dict__ == other.__dict__def __ne__(self, other):return not (self == other)class getItemIds_args:"""Attributes:- itemNumber"""thrift_spec = (None, # 0(1, TType.STRING, 'itemNumber', None, None, ), # 1)def __init__(self, itemNumber=None,):self.itemNumber = itemNumberdef read(self, iprot):if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))returniprot.readStructBegin()while True:(fname, ftype, fid) = iprot.readFieldBegin()if ftype == TType.STOP:breakif fid == 1:if ftype == TType.STRING:self.itemNumber = iprot.readString();else:iprot.skip(ftype)else:iprot.skip(ftype)iprot.readFieldEnd()iprot.readStructEnd()def write(self, oprot):if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))returnoprot.writeStructBegin('getItemIds_args')if self.itemNumber is not None:oprot.writeFieldBegin('itemNumber', TType.STRING, 1)oprot.writeString(self.itemNumber)oprot.writeFieldEnd()oprot.writeFieldStop()oprot.writeStructEnd()def validate(self):returndef __repr__(self):L = ['%s=%r' % (key, value)for key, value in self.__dict__.iteritems()]return '%s(%s)' % (self.__class__.__name__, ', '.join(L))def __eq__(self, other):return isinstance(other, self.__class__) and self.__dict__ == other.__dict__def __ne__(self, other):return not (self == other)class getItemIds_result:"""Attributes:- success"""thrift_spec = ((0, TType.LIST, 'success', (TType.I64,None), None, ), # 0)def __init__(self, success=None,):self.success = successdef read(self, iprot):if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))returniprot.readStructBegin()while True:(fname, ftype, fid) = iprot.readFieldBegin()if ftype == TType.STOP:breakif fid == 0:if ftype == TType.LIST:self.success = [](_etype38, _size35) = iprot.readListBegin()for _i39 in xrange(_size35):_elem40 = iprot.readI64();self.success.append(_elem40)iprot.readListEnd()else:iprot.skip(ftype)else:iprot.skip(ftype)iprot.readFieldEnd()iprot.readStructEnd()def write(self, oprot):if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))returnoprot.writeStructBegin('getItemIds_result')if self.success is not None:oprot.writeFieldBegin('success', TType.LIST, 0)oprot.writeListBegin(TType.I64, len(self.success))for iter41 in self.success:oprot.writeI64(iter41)oprot.writeListEnd()oprot.writeFieldEnd()oprot.writeFieldStop()oprot.writeStructEnd()def validate(self):returndef __repr__(self):L = ['%s=%r' % (key, value)for key, value in self.__dict__.iteritems()]return '%s(%s)' % (self.__class__.__name__, ', '.join(L))def __eq__(self, other):return isinstance(other, self.__class__) and self.__dict__ == other.__dict__def __ne__(self, other):return not (self == other)class getInventoryItemsFromLastScanType_args:"""Attributes:- lastScanType"""thrift_spec = (None, # 0(1, TType.I32, 'lastScanType', None, None, ), # 1)def __init__(self, lastScanType=None,):self.lastScanType = lastScanTypedef read(self, iprot):if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))returniprot.readStructBegin()while True:(fname, ftype, fid) = iprot.readFieldBegin()if ftype == TType.STOP:breakif fid == 1:if ftype == TType.I32:self.lastScanType = iprot.readI32();else:iprot.skip(ftype)else:iprot.skip(ftype)iprot.readFieldEnd()iprot.readStructEnd()def write(self, oprot):if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))returnoprot.writeStructBegin('getInventoryItemsFromLastScanType_args')if self.lastScanType is not None:oprot.writeFieldBegin('lastScanType', TType.I32, 1)oprot.writeI32(self.lastScanType)oprot.writeFieldEnd()oprot.writeFieldStop()oprot.writeStructEnd()def validate(self):returndef __repr__(self):L = ['%s=%r' % (key, value)for key, value in self.__dict__.iteritems()]return '%s(%s)' % (self.__class__.__name__, ', '.join(L))def __eq__(self, other):return isinstance(other, self.__class__) and self.__dict__ == other.__dict__def __ne__(self, other):return not (self == other)class getInventoryItemsFromLastScanType_result:"""Attributes:- success- wex"""thrift_spec = ((0, TType.LIST, 'success', (TType.STRUCT,(InventoryItem, InventoryItem.thrift_spec)), None, ), # 0(1, TType.STRUCT, 'wex', (WarehouseServiceException, WarehouseServiceException.thrift_spec), None, ), # 1)def __init__(self, success=None, wex=None,):self.success = successself.wex = wexdef read(self, iprot):if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))returniprot.readStructBegin()while True:(fname, ftype, fid) = iprot.readFieldBegin()if ftype == TType.STOP:breakif fid == 0:if ftype == TType.LIST:self.success = [](_etype45, _size42) = iprot.readListBegin()for _i46 in xrange(_size42):_elem47 = InventoryItem()_elem47.read(iprot)self.success.append(_elem47)iprot.readListEnd()else:iprot.skip(ftype)elif fid == 1:if ftype == TType.STRUCT:self.wex = WarehouseServiceException()self.wex.read(iprot)else:iprot.skip(ftype)else:iprot.skip(ftype)iprot.readFieldEnd()iprot.readStructEnd()def write(self, oprot):if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))returnoprot.writeStructBegin('getInventoryItemsFromLastScanType_result')if self.success is not None:oprot.writeFieldBegin('success', TType.LIST, 0)oprot.writeListBegin(TType.STRUCT, len(self.success))for iter48 in self.success:iter48.write(oprot)oprot.writeListEnd()oprot.writeFieldEnd()if self.wex is not None:oprot.writeFieldBegin('wex', TType.STRUCT, 1)self.wex.write(oprot)oprot.writeFieldEnd()oprot.writeFieldStop()oprot.writeStructEnd()def validate(self):returndef __repr__(self):L = ['%s=%r' % (key, value)for key, value in self.__dict__.iteritems()]return '%s(%s)' % (self.__class__.__name__, ', '.join(L))def __eq__(self, other):return isinstance(other, self.__class__) and self.__dict__ == other.__dict__def __ne__(self, other):return not (self == other)class getInventoryItemFromId_args:"""Attributes:- inventoryItemId"""thrift_spec = (None, # 0(1, TType.I64, 'inventoryItemId', None, None, ), # 1)def __init__(self, inventoryItemId=None,):self.inventoryItemId = inventoryItemIddef read(self, iprot):if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))returniprot.readStructBegin()while True:(fname, ftype, fid) = iprot.readFieldBegin()if ftype == TType.STOP:breakif fid == 1:if ftype == TType.I64:self.inventoryItemId = iprot.readI64();else:iprot.skip(ftype)else:iprot.skip(ftype)iprot.readFieldEnd()iprot.readStructEnd()def write(self, oprot):if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))returnoprot.writeStructBegin('getInventoryItemFromId_args')if self.inventoryItemId is not None:oprot.writeFieldBegin('inventoryItemId', TType.I64, 1)oprot.writeI64(self.inventoryItemId)oprot.writeFieldEnd()oprot.writeFieldStop()oprot.writeStructEnd()def validate(self):returndef __repr__(self):L = ['%s=%r' % (key, value)for key, value in self.__dict__.iteritems()]return '%s(%s)' % (self.__class__.__name__, ', '.join(L))def __eq__(self, other):return isinstance(other, self.__class__) and self.__dict__ == other.__dict__def __ne__(self, other):return not (self == other)class getInventoryItemFromId_result:"""Attributes:- success- wex"""thrift_spec = ((0, TType.STRUCT, 'success', (InventoryItem, InventoryItem.thrift_spec), None, ), # 0(1, TType.STRUCT, 'wex', (WarehouseServiceException, WarehouseServiceException.thrift_spec), None, ), # 1)def __init__(self, success=None, wex=None,):self.success = successself.wex = wexdef read(self, iprot):if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))returniprot.readStructBegin()while True:(fname, ftype, fid) = iprot.readFieldBegin()if ftype == TType.STOP:breakif fid == 0:if ftype == TType.STRUCT:self.success = InventoryItem()self.success.read(iprot)else:iprot.skip(ftype)elif fid == 1:if ftype == TType.STRUCT:self.wex = WarehouseServiceException()self.wex.read(iprot)else:iprot.skip(ftype)else:iprot.skip(ftype)iprot.readFieldEnd()iprot.readStructEnd()def write(self, oprot):if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))returnoprot.writeStructBegin('getInventoryItemFromId_result')if self.success is not None:oprot.writeFieldBegin('success', TType.STRUCT, 0)self.success.write(oprot)oprot.writeFieldEnd()if self.wex is not None:oprot.writeFieldBegin('wex', TType.STRUCT, 1)self.wex.write(oprot)oprot.writeFieldEnd()oprot.writeFieldStop()oprot.writeStructEnd()def validate(self):returndef __repr__(self):L = ['%s=%r' % (key, value)for key, value in self.__dict__.iteritems()]return '%s(%s)' % (self.__class__.__name__, ', '.join(L))def __eq__(self, other):return isinstance(other, self.__class__) and self.__dict__ == other.__dict__def __ne__(self, other):return not (self == other)