Rev 1731 | Rev 2446 | Go to most recent revision | Blame | Compare with Previous | Last modification | View Log | RSS feed
## Autogenerated by Thrift## DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING#from thrift.Thrift import *from ttypes import *from thrift.Thrift import TProcessorfrom thrift.transport import TTransportfrom thrift.protocol import TBinaryProtocoltry:from thrift.protocol import fastbinaryexcept:fastbinary = Noneclass Iface:def closeSession(self, ):"""For closing the open session in sqlalchemy"""passdef createTransaction(self, transaction):"""Parameters:- transaction"""passdef getTransaction(self, id):"""Parameters:- id"""passdef getTransactionsForCustomer(self, customerId, from_date, to_date, status):"""Parameters:- customerId- from_date- to_date- status"""passdef getTransactionsForShoppingCartId(self, shoppingCartId):"""Parameters:- shoppingCartId"""passdef getTransactionStatus(self, transactionId):"""Parameters:- transactionId"""passdef changeTransactionStatus(self, transactionId, status, description):"""Parameters:- transactionId- status- description"""passdef enqueueTransactionInfoEmail(self, transactionId):"""Parameters:- transactionId"""passdef getAllOrders(self, status, from_date, to_date, warehouse_id):"""Parameters:- status- from_date- to_date- warehouse_id"""passdef getOrdersByBillingDate(self, status, start_billing_date, end_billing_date, warehouse_id):"""Returns orders within a range of their billing datesParameters:- status- start_billing_date- end_billing_date- warehouse_id"""passdef getReturnableOrdersForCustomer(self, customer_id, limit):"""Returns order ids for orders which can be returnedParameters:- customer_id- limit"""passdef getCancellableOrdersForCustomer(self, customer_id, limit):"""Returns order ids for orders which can be cancelledParameters:- customer_id- limit"""passdef changeOrderStatus(self, orderId, status, description):"""Parameters:- orderId- status- description"""passdef addBillingDetails(self, orderId, invoice_number, billed_by):"""Add billing details such as the bill number and the biller to the Order.Parameters:- orderId- invoice_number- billed_by"""passdef addJacketNumber(self, orderId, jacketNumber):"""Adds jacket number to the order. Return false if it doesn't find the order with the given ID.Parameters:- orderId- jacketNumber"""passdef acceptOrder(self, orderId):"""Parameters:- orderId"""passdef billOrder(self, orderId):"""Parameters:- orderId"""passdef getOrdersForTransaction(self, transactionId, customerId):"""Returns list of orders for given transaction Id. Also filters based on customer Id so thatonly user who owns the transaction can view its order details.Parameters:- transactionId- customerId"""passdef getOrdersForCustomer(self, customerId, from_date, to_date, status):"""Parameters:- customerId- from_date- to_date- status"""passdef createOrder(self, order):"""Parameters:- order"""passdef getOrder(self, id):"""Parameters:- id"""passdef getLineItemsForOrder(self, orderId):"""Parameters:- orderId"""passdef getOrderForCustomer(self, orderId, customerId):"""Returns an order for the order Id. Also checks if the order belongs to the customer whose Id is passed.Throws exception if either order Id is invalid or order does not below to the customer whose Id is passed.Parameters:- orderId- customerId"""passdef batchOrders(self, warehouseId):"""Create a batch of all the pending orders for the given warehouse.The returned list is orderd by created_timestamp.If there are no pending orders, an empty list is returned.Parameters:- warehouseId"""passdef markOrderAsOutOfStock(self, orderId):"""Mark the given order as out of stock. Throws an exception if the order with the given Id couldn't be found.Parameters:- orderId"""passdef markOrdersAsManifested(self, warehouseId, providerId):"""Marks all BILLED orders for a warehouse and a provider as SHIPPED_FROM_WHParameters:- warehouseId- providerId"""passdef markOrdersAsPickedUp(self, providerId, pickupDetails):"""Marks all SHIPPED_FROM_WH orders of the previous day for a provider as SHIPPED_TO_LOGISTICS.Returns a list of orders that were shipped from warehouse but did not appear in the pick-up report.Raises an exception if we encounter report for an AWB number that we did not ship.Parameters:- providerId- pickupDetails"""passdef markOrdersAsDelivered(self, providerId, deliveredOrders):"""Marks all orders with AWBs in the given map as delivered. Also sets the delivery timestamp andthe name of the receiver.Raises an exception if we encounter report for an AWB number that we did not ship.Parameters:- providerId- deliveredOrders"""passdef markOrdersAsFailed(self, providerId, returnedOrders):"""Mark all orders with AWBs in the given map as failed. Also sets the delivery timestamp.Raises an exception if we encounter report for an AWB number that we did not ship.Parameters:- providerId- returnedOrders"""passdef updateNonDeliveryReason(self, providerId, undeliveredOrders):"""Update the status description of orders whose AWB numbers are keys of the Map.Parameters:- providerId- undeliveredOrders"""passdef getUndeliveredOrders(self, providerId, warehouseId):"""Returns the list of orders whose delivery time has passed but have not beendelivered yet for the given provider and warehouse. To get a complete list ofundelivered orders, pass them as -1.Returns an empty list if no such orders exist.Parameters:- providerId- warehouseId"""passdef getAlerts(self, orderId, valid):"""Parameters:- orderId- valid"""passdef setAlert(self, orderId, unset, type, comment):"""Parameters:- orderId- unset- type- comment"""passdef getValidOrderCount(self, ):"""Return the number of valid orders. (OrderStatus >= OrderStatus.SUBMITTED_FOR_PROCESSING)"""passdef getNoOfCustomersWithSuccessfulTransaction(self, ):"""Returns the number of distinct customers who have done successful transactions"""passdef getValidOrdersAmountRange(self, ):"""Returns the minimum and maximum amounts of a valid order. (OrderStatus >= OrderStatus.SUBMITTED_FOR_PROCESSING)List contains two values, first minimum amount and second maximum amount."""passdef getValidOrders(self, limit):"""Returns list of Orders in descending order by Order creation date. List is restricted to limit Orders.If limit is passed as 0, then all valid Orders are returned.Parameters:- limit"""passclass Client(Iface):def __init__(self, iprot, oprot=None):self._iprot = self._oprot = iprotif oprot != None:self._oprot = oprotself._seqid = 0def closeSession(self, ):"""For closing the open session in sqlalchemy"""self.send_closeSession()self.recv_closeSession()def send_closeSession(self, ):self._oprot.writeMessageBegin('closeSession', TMessageType.CALL, self._seqid)args = closeSession_args()args.write(self._oprot)self._oprot.writeMessageEnd()self._oprot.trans.flush()def recv_closeSession(self, ):(fname, mtype, rseqid) = self._iprot.readMessageBegin()if mtype == TMessageType.EXCEPTION:x = TApplicationException()x.read(self._iprot)self._iprot.readMessageEnd()raise xresult = closeSession_result()result.read(self._iprot)self._iprot.readMessageEnd()returndef createTransaction(self, transaction):"""Parameters:- transaction"""self.send_createTransaction(transaction)return self.recv_createTransaction()def send_createTransaction(self, transaction):self._oprot.writeMessageBegin('createTransaction', TMessageType.CALL, self._seqid)args = createTransaction_args()args.transaction = transactionargs.write(self._oprot)self._oprot.writeMessageEnd()self._oprot.trans.flush()def recv_createTransaction(self, ):(fname, mtype, rseqid) = self._iprot.readMessageBegin()if mtype == TMessageType.EXCEPTION:x = TApplicationException()x.read(self._iprot)self._iprot.readMessageEnd()raise xresult = createTransaction_result()result.read(self._iprot)self._iprot.readMessageEnd()if result.success != None:return result.successif result.ex != None:raise result.exraise TApplicationException(TApplicationException.MISSING_RESULT, "createTransaction failed: unknown result");def getTransaction(self, id):"""Parameters:- id"""self.send_getTransaction(id)return self.recv_getTransaction()def send_getTransaction(self, id):self._oprot.writeMessageBegin('getTransaction', TMessageType.CALL, self._seqid)args = getTransaction_args()args.id = idargs.write(self._oprot)self._oprot.writeMessageEnd()self._oprot.trans.flush()def recv_getTransaction(self, ):(fname, mtype, rseqid) = self._iprot.readMessageBegin()if mtype == TMessageType.EXCEPTION:x = TApplicationException()x.read(self._iprot)self._iprot.readMessageEnd()raise xresult = getTransaction_result()result.read(self._iprot)self._iprot.readMessageEnd()if result.success != None:return result.successif result.ex != None:raise result.exraise TApplicationException(TApplicationException.MISSING_RESULT, "getTransaction failed: unknown result");def getTransactionsForCustomer(self, customerId, from_date, to_date, status):"""Parameters:- customerId- from_date- to_date- status"""self.send_getTransactionsForCustomer(customerId, from_date, to_date, status)return self.recv_getTransactionsForCustomer()def send_getTransactionsForCustomer(self, customerId, from_date, to_date, status):self._oprot.writeMessageBegin('getTransactionsForCustomer', TMessageType.CALL, self._seqid)args = getTransactionsForCustomer_args()args.customerId = customerIdargs.from_date = from_dateargs.to_date = to_dateargs.status = statusargs.write(self._oprot)self._oprot.writeMessageEnd()self._oprot.trans.flush()def recv_getTransactionsForCustomer(self, ):(fname, mtype, rseqid) = self._iprot.readMessageBegin()if mtype == TMessageType.EXCEPTION:x = TApplicationException()x.read(self._iprot)self._iprot.readMessageEnd()raise xresult = getTransactionsForCustomer_result()result.read(self._iprot)self._iprot.readMessageEnd()if result.success != None:return result.successif result.ex != None:raise result.exraise TApplicationException(TApplicationException.MISSING_RESULT, "getTransactionsForCustomer failed: unknown result");def getTransactionsForShoppingCartId(self, shoppingCartId):"""Parameters:- shoppingCartId"""self.send_getTransactionsForShoppingCartId(shoppingCartId)return self.recv_getTransactionsForShoppingCartId()def send_getTransactionsForShoppingCartId(self, shoppingCartId):self._oprot.writeMessageBegin('getTransactionsForShoppingCartId', TMessageType.CALL, self._seqid)args = getTransactionsForShoppingCartId_args()args.shoppingCartId = shoppingCartIdargs.write(self._oprot)self._oprot.writeMessageEnd()self._oprot.trans.flush()def recv_getTransactionsForShoppingCartId(self, ):(fname, mtype, rseqid) = self._iprot.readMessageBegin()if mtype == TMessageType.EXCEPTION:x = TApplicationException()x.read(self._iprot)self._iprot.readMessageEnd()raise xresult = getTransactionsForShoppingCartId_result()result.read(self._iprot)self._iprot.readMessageEnd()if result.success != None:return result.successif result.ex != None:raise result.exraise TApplicationException(TApplicationException.MISSING_RESULT, "getTransactionsForShoppingCartId failed: unknown result");def getTransactionStatus(self, transactionId):"""Parameters:- transactionId"""self.send_getTransactionStatus(transactionId)return self.recv_getTransactionStatus()def send_getTransactionStatus(self, transactionId):self._oprot.writeMessageBegin('getTransactionStatus', TMessageType.CALL, self._seqid)args = getTransactionStatus_args()args.transactionId = transactionIdargs.write(self._oprot)self._oprot.writeMessageEnd()self._oprot.trans.flush()def recv_getTransactionStatus(self, ):(fname, mtype, rseqid) = self._iprot.readMessageBegin()if mtype == TMessageType.EXCEPTION:x = TApplicationException()x.read(self._iprot)self._iprot.readMessageEnd()raise xresult = getTransactionStatus_result()result.read(self._iprot)self._iprot.readMessageEnd()if result.success != None:return result.successif result.ex != None:raise result.exraise TApplicationException(TApplicationException.MISSING_RESULT, "getTransactionStatus failed: unknown result");def changeTransactionStatus(self, transactionId, status, description):"""Parameters:- transactionId- status- description"""self.send_changeTransactionStatus(transactionId, status, description)return self.recv_changeTransactionStatus()def send_changeTransactionStatus(self, transactionId, status, description):self._oprot.writeMessageBegin('changeTransactionStatus', TMessageType.CALL, self._seqid)args = changeTransactionStatus_args()args.transactionId = transactionIdargs.status = statusargs.description = descriptionargs.write(self._oprot)self._oprot.writeMessageEnd()self._oprot.trans.flush()def recv_changeTransactionStatus(self, ):(fname, mtype, rseqid) = self._iprot.readMessageBegin()if mtype == TMessageType.EXCEPTION:x = TApplicationException()x.read(self._iprot)self._iprot.readMessageEnd()raise xresult = changeTransactionStatus_result()result.read(self._iprot)self._iprot.readMessageEnd()if result.success != None:return result.successif result.ex != None:raise result.exraise TApplicationException(TApplicationException.MISSING_RESULT, "changeTransactionStatus failed: unknown result");def enqueueTransactionInfoEmail(self, transactionId):"""Parameters:- transactionId"""self.send_enqueueTransactionInfoEmail(transactionId)return self.recv_enqueueTransactionInfoEmail()def send_enqueueTransactionInfoEmail(self, transactionId):self._oprot.writeMessageBegin('enqueueTransactionInfoEmail', TMessageType.CALL, self._seqid)args = enqueueTransactionInfoEmail_args()args.transactionId = transactionIdargs.write(self._oprot)self._oprot.writeMessageEnd()self._oprot.trans.flush()def recv_enqueueTransactionInfoEmail(self, ):(fname, mtype, rseqid) = self._iprot.readMessageBegin()if mtype == TMessageType.EXCEPTION:x = TApplicationException()x.read(self._iprot)self._iprot.readMessageEnd()raise xresult = enqueueTransactionInfoEmail_result()result.read(self._iprot)self._iprot.readMessageEnd()if result.success != None:return result.successif result.ex != None:raise result.exraise TApplicationException(TApplicationException.MISSING_RESULT, "enqueueTransactionInfoEmail failed: unknown result");def getAllOrders(self, status, from_date, to_date, warehouse_id):"""Parameters:- status- from_date- to_date- warehouse_id"""self.send_getAllOrders(status, from_date, to_date, warehouse_id)return self.recv_getAllOrders()def send_getAllOrders(self, status, from_date, to_date, warehouse_id):self._oprot.writeMessageBegin('getAllOrders', TMessageType.CALL, self._seqid)args = getAllOrders_args()args.status = statusargs.from_date = from_dateargs.to_date = to_dateargs.warehouse_id = warehouse_idargs.write(self._oprot)self._oprot.writeMessageEnd()self._oprot.trans.flush()def recv_getAllOrders(self, ):(fname, mtype, rseqid) = self._iprot.readMessageBegin()if mtype == TMessageType.EXCEPTION:x = TApplicationException()x.read(self._iprot)self._iprot.readMessageEnd()raise xresult = getAllOrders_result()result.read(self._iprot)self._iprot.readMessageEnd()if result.success != None:return result.successif result.ex != None:raise result.exraise TApplicationException(TApplicationException.MISSING_RESULT, "getAllOrders failed: unknown result");def getOrdersByBillingDate(self, status, start_billing_date, end_billing_date, warehouse_id):"""Returns orders within a range of their billing datesParameters:- status- start_billing_date- end_billing_date- warehouse_id"""self.send_getOrdersByBillingDate(status, start_billing_date, end_billing_date, warehouse_id)return self.recv_getOrdersByBillingDate()def send_getOrdersByBillingDate(self, status, start_billing_date, end_billing_date, warehouse_id):self._oprot.writeMessageBegin('getOrdersByBillingDate', TMessageType.CALL, self._seqid)args = getOrdersByBillingDate_args()args.status = statusargs.start_billing_date = start_billing_dateargs.end_billing_date = end_billing_dateargs.warehouse_id = warehouse_idargs.write(self._oprot)self._oprot.writeMessageEnd()self._oprot.trans.flush()def recv_getOrdersByBillingDate(self, ):(fname, mtype, rseqid) = self._iprot.readMessageBegin()if mtype == TMessageType.EXCEPTION:x = TApplicationException()x.read(self._iprot)self._iprot.readMessageEnd()raise xresult = getOrdersByBillingDate_result()result.read(self._iprot)self._iprot.readMessageEnd()if result.success != None:return result.successif result.ex != None:raise result.exraise TApplicationException(TApplicationException.MISSING_RESULT, "getOrdersByBillingDate failed: unknown result");def getReturnableOrdersForCustomer(self, customer_id, limit):"""Returns order ids for orders which can be returnedParameters:- customer_id- limit"""self.send_getReturnableOrdersForCustomer(customer_id, limit)return self.recv_getReturnableOrdersForCustomer()def send_getReturnableOrdersForCustomer(self, customer_id, limit):self._oprot.writeMessageBegin('getReturnableOrdersForCustomer', TMessageType.CALL, self._seqid)args = getReturnableOrdersForCustomer_args()args.customer_id = customer_idargs.limit = limitargs.write(self._oprot)self._oprot.writeMessageEnd()self._oprot.trans.flush()def recv_getReturnableOrdersForCustomer(self, ):(fname, mtype, rseqid) = self._iprot.readMessageBegin()if mtype == TMessageType.EXCEPTION:x = TApplicationException()x.read(self._iprot)self._iprot.readMessageEnd()raise xresult = getReturnableOrdersForCustomer_result()result.read(self._iprot)self._iprot.readMessageEnd()if result.success != None:return result.successif result.ex != None:raise result.exraise TApplicationException(TApplicationException.MISSING_RESULT, "getReturnableOrdersForCustomer failed: unknown result");def getCancellableOrdersForCustomer(self, customer_id, limit):"""Returns order ids for orders which can be cancelledParameters:- customer_id- limit"""self.send_getCancellableOrdersForCustomer(customer_id, limit)return self.recv_getCancellableOrdersForCustomer()def send_getCancellableOrdersForCustomer(self, customer_id, limit):self._oprot.writeMessageBegin('getCancellableOrdersForCustomer', TMessageType.CALL, self._seqid)args = getCancellableOrdersForCustomer_args()args.customer_id = customer_idargs.limit = limitargs.write(self._oprot)self._oprot.writeMessageEnd()self._oprot.trans.flush()def recv_getCancellableOrdersForCustomer(self, ):(fname, mtype, rseqid) = self._iprot.readMessageBegin()if mtype == TMessageType.EXCEPTION:x = TApplicationException()x.read(self._iprot)self._iprot.readMessageEnd()raise xresult = getCancellableOrdersForCustomer_result()result.read(self._iprot)self._iprot.readMessageEnd()if result.success != None:return result.successif result.ex != None:raise result.exraise TApplicationException(TApplicationException.MISSING_RESULT, "getCancellableOrdersForCustomer failed: unknown result");def changeOrderStatus(self, orderId, status, description):"""Parameters:- orderId- status- description"""self.send_changeOrderStatus(orderId, status, description)return self.recv_changeOrderStatus()def send_changeOrderStatus(self, orderId, status, description):self._oprot.writeMessageBegin('changeOrderStatus', TMessageType.CALL, self._seqid)args = changeOrderStatus_args()args.orderId = orderIdargs.status = statusargs.description = descriptionargs.write(self._oprot)self._oprot.writeMessageEnd()self._oprot.trans.flush()def recv_changeOrderStatus(self, ):(fname, mtype, rseqid) = self._iprot.readMessageBegin()if mtype == TMessageType.EXCEPTION:x = TApplicationException()x.read(self._iprot)self._iprot.readMessageEnd()raise xresult = changeOrderStatus_result()result.read(self._iprot)self._iprot.readMessageEnd()if result.success != None:return result.successif result.ex != None:raise result.exraise TApplicationException(TApplicationException.MISSING_RESULT, "changeOrderStatus failed: unknown result");def addBillingDetails(self, orderId, invoice_number, billed_by):"""Add billing details such as the bill number and the biller to the Order.Parameters:- orderId- invoice_number- billed_by"""self.send_addBillingDetails(orderId, invoice_number, billed_by)return self.recv_addBillingDetails()def send_addBillingDetails(self, orderId, invoice_number, billed_by):self._oprot.writeMessageBegin('addBillingDetails', TMessageType.CALL, self._seqid)args = addBillingDetails_args()args.orderId = orderIdargs.invoice_number = invoice_numberargs.billed_by = billed_byargs.write(self._oprot)self._oprot.writeMessageEnd()self._oprot.trans.flush()def recv_addBillingDetails(self, ):(fname, mtype, rseqid) = self._iprot.readMessageBegin()if mtype == TMessageType.EXCEPTION:x = TApplicationException()x.read(self._iprot)self._iprot.readMessageEnd()raise xresult = addBillingDetails_result()result.read(self._iprot)self._iprot.readMessageEnd()if result.success != None:return result.successif result.ex != None:raise result.exraise TApplicationException(TApplicationException.MISSING_RESULT, "addBillingDetails failed: unknown result");def addJacketNumber(self, orderId, jacketNumber):"""Adds jacket number to the order. Return false if it doesn't find the order with the given ID.Parameters:- orderId- jacketNumber"""self.send_addJacketNumber(orderId, jacketNumber)return self.recv_addJacketNumber()def send_addJacketNumber(self, orderId, jacketNumber):self._oprot.writeMessageBegin('addJacketNumber', TMessageType.CALL, self._seqid)args = addJacketNumber_args()args.orderId = orderIdargs.jacketNumber = jacketNumberargs.write(self._oprot)self._oprot.writeMessageEnd()self._oprot.trans.flush()def recv_addJacketNumber(self, ):(fname, mtype, rseqid) = self._iprot.readMessageBegin()if mtype == TMessageType.EXCEPTION:x = TApplicationException()x.read(self._iprot)self._iprot.readMessageEnd()raise xresult = addJacketNumber_result()result.read(self._iprot)self._iprot.readMessageEnd()if result.success != None:return result.successif result.ex != None:raise result.exraise TApplicationException(TApplicationException.MISSING_RESULT, "addJacketNumber failed: unknown result");def acceptOrder(self, orderId):"""Parameters:- orderId"""self.send_acceptOrder(orderId)return self.recv_acceptOrder()def send_acceptOrder(self, orderId):self._oprot.writeMessageBegin('acceptOrder', TMessageType.CALL, self._seqid)args = acceptOrder_args()args.orderId = orderIdargs.write(self._oprot)self._oprot.writeMessageEnd()self._oprot.trans.flush()def recv_acceptOrder(self, ):(fname, mtype, rseqid) = self._iprot.readMessageBegin()if mtype == TMessageType.EXCEPTION:x = TApplicationException()x.read(self._iprot)self._iprot.readMessageEnd()raise xresult = acceptOrder_result()result.read(self._iprot)self._iprot.readMessageEnd()if result.success != None:return result.successif result.ex != None:raise result.exraise TApplicationException(TApplicationException.MISSING_RESULT, "acceptOrder failed: unknown result");def billOrder(self, orderId):"""Parameters:- orderId"""self.send_billOrder(orderId)return self.recv_billOrder()def send_billOrder(self, orderId):self._oprot.writeMessageBegin('billOrder', TMessageType.CALL, self._seqid)args = billOrder_args()args.orderId = orderIdargs.write(self._oprot)self._oprot.writeMessageEnd()self._oprot.trans.flush()def recv_billOrder(self, ):(fname, mtype, rseqid) = self._iprot.readMessageBegin()if mtype == TMessageType.EXCEPTION:x = TApplicationException()x.read(self._iprot)self._iprot.readMessageEnd()raise xresult = billOrder_result()result.read(self._iprot)self._iprot.readMessageEnd()if result.success != None:return result.successif result.ex != None:raise result.exraise TApplicationException(TApplicationException.MISSING_RESULT, "billOrder failed: unknown result");def getOrdersForTransaction(self, transactionId, customerId):"""Returns list of orders for given transaction Id. Also filters based on customer Id so thatonly user who owns the transaction can view its order details.Parameters:- transactionId- customerId"""self.send_getOrdersForTransaction(transactionId, customerId)return self.recv_getOrdersForTransaction()def send_getOrdersForTransaction(self, transactionId, customerId):self._oprot.writeMessageBegin('getOrdersForTransaction', TMessageType.CALL, self._seqid)args = getOrdersForTransaction_args()args.transactionId = transactionIdargs.customerId = customerIdargs.write(self._oprot)self._oprot.writeMessageEnd()self._oprot.trans.flush()def recv_getOrdersForTransaction(self, ):(fname, mtype, rseqid) = self._iprot.readMessageBegin()if mtype == TMessageType.EXCEPTION:x = TApplicationException()x.read(self._iprot)self._iprot.readMessageEnd()raise xresult = getOrdersForTransaction_result()result.read(self._iprot)self._iprot.readMessageEnd()if result.success != None:return result.successif result.ex != None:raise result.exraise TApplicationException(TApplicationException.MISSING_RESULT, "getOrdersForTransaction failed: unknown result");def getOrdersForCustomer(self, customerId, from_date, to_date, status):"""Parameters:- customerId- from_date- to_date- status"""self.send_getOrdersForCustomer(customerId, from_date, to_date, status)return self.recv_getOrdersForCustomer()def send_getOrdersForCustomer(self, customerId, from_date, to_date, status):self._oprot.writeMessageBegin('getOrdersForCustomer', TMessageType.CALL, self._seqid)args = getOrdersForCustomer_args()args.customerId = customerIdargs.from_date = from_dateargs.to_date = to_dateargs.status = statusargs.write(self._oprot)self._oprot.writeMessageEnd()self._oprot.trans.flush()def recv_getOrdersForCustomer(self, ):(fname, mtype, rseqid) = self._iprot.readMessageBegin()if mtype == TMessageType.EXCEPTION:x = TApplicationException()x.read(self._iprot)self._iprot.readMessageEnd()raise xresult = getOrdersForCustomer_result()result.read(self._iprot)self._iprot.readMessageEnd()if result.success != None:return result.successif result.ex != None:raise result.exraise TApplicationException(TApplicationException.MISSING_RESULT, "getOrdersForCustomer failed: unknown result");def createOrder(self, order):"""Parameters:- order"""self.send_createOrder(order)return self.recv_createOrder()def send_createOrder(self, order):self._oprot.writeMessageBegin('createOrder', TMessageType.CALL, self._seqid)args = createOrder_args()args.order = orderargs.write(self._oprot)self._oprot.writeMessageEnd()self._oprot.trans.flush()def recv_createOrder(self, ):(fname, mtype, rseqid) = self._iprot.readMessageBegin()if mtype == TMessageType.EXCEPTION:x = TApplicationException()x.read(self._iprot)self._iprot.readMessageEnd()raise xresult = createOrder_result()result.read(self._iprot)self._iprot.readMessageEnd()if result.success != None:return result.successif result.ex != None:raise result.exraise TApplicationException(TApplicationException.MISSING_RESULT, "createOrder failed: unknown result");def getOrder(self, id):"""Parameters:- id"""self.send_getOrder(id)return self.recv_getOrder()def send_getOrder(self, id):self._oprot.writeMessageBegin('getOrder', TMessageType.CALL, self._seqid)args = getOrder_args()args.id = idargs.write(self._oprot)self._oprot.writeMessageEnd()self._oprot.trans.flush()def recv_getOrder(self, ):(fname, mtype, rseqid) = self._iprot.readMessageBegin()if mtype == TMessageType.EXCEPTION:x = TApplicationException()x.read(self._iprot)self._iprot.readMessageEnd()raise xresult = getOrder_result()result.read(self._iprot)self._iprot.readMessageEnd()if result.success != None:return result.successif result.ex != None:raise result.exraise TApplicationException(TApplicationException.MISSING_RESULT, "getOrder failed: unknown result");def getLineItemsForOrder(self, orderId):"""Parameters:- orderId"""self.send_getLineItemsForOrder(orderId)return self.recv_getLineItemsForOrder()def send_getLineItemsForOrder(self, orderId):self._oprot.writeMessageBegin('getLineItemsForOrder', TMessageType.CALL, self._seqid)args = getLineItemsForOrder_args()args.orderId = orderIdargs.write(self._oprot)self._oprot.writeMessageEnd()self._oprot.trans.flush()def recv_getLineItemsForOrder(self, ):(fname, mtype, rseqid) = self._iprot.readMessageBegin()if mtype == TMessageType.EXCEPTION:x = TApplicationException()x.read(self._iprot)self._iprot.readMessageEnd()raise xresult = getLineItemsForOrder_result()result.read(self._iprot)self._iprot.readMessageEnd()if result.success != None:return result.successif result.ex != None:raise result.exraise TApplicationException(TApplicationException.MISSING_RESULT, "getLineItemsForOrder failed: unknown result");def getOrderForCustomer(self, orderId, customerId):"""Returns an order for the order Id. Also checks if the order belongs to the customer whose Id is passed.Throws exception if either order Id is invalid or order does not below to the customer whose Id is passed.Parameters:- orderId- customerId"""self.send_getOrderForCustomer(orderId, customerId)return self.recv_getOrderForCustomer()def send_getOrderForCustomer(self, orderId, customerId):self._oprot.writeMessageBegin('getOrderForCustomer', TMessageType.CALL, self._seqid)args = getOrderForCustomer_args()args.orderId = orderIdargs.customerId = customerIdargs.write(self._oprot)self._oprot.writeMessageEnd()self._oprot.trans.flush()def recv_getOrderForCustomer(self, ):(fname, mtype, rseqid) = self._iprot.readMessageBegin()if mtype == TMessageType.EXCEPTION:x = TApplicationException()x.read(self._iprot)self._iprot.readMessageEnd()raise xresult = getOrderForCustomer_result()result.read(self._iprot)self._iprot.readMessageEnd()if result.success != None:return result.successif result.ex != None:raise result.exraise TApplicationException(TApplicationException.MISSING_RESULT, "getOrderForCustomer failed: unknown result");def batchOrders(self, warehouseId):"""Create a batch of all the pending orders for the given warehouse.The returned list is orderd by created_timestamp.If there are no pending orders, an empty list is returned.Parameters:- warehouseId"""self.send_batchOrders(warehouseId)return self.recv_batchOrders()def send_batchOrders(self, warehouseId):self._oprot.writeMessageBegin('batchOrders', TMessageType.CALL, self._seqid)args = batchOrders_args()args.warehouseId = warehouseIdargs.write(self._oprot)self._oprot.writeMessageEnd()self._oprot.trans.flush()def recv_batchOrders(self, ):(fname, mtype, rseqid) = self._iprot.readMessageBegin()if mtype == TMessageType.EXCEPTION:x = TApplicationException()x.read(self._iprot)self._iprot.readMessageEnd()raise xresult = batchOrders_result()result.read(self._iprot)self._iprot.readMessageEnd()if result.success != None:return result.successif result.ex != None:raise result.exraise TApplicationException(TApplicationException.MISSING_RESULT, "batchOrders failed: unknown result");def markOrderAsOutOfStock(self, orderId):"""Mark the given order as out of stock. Throws an exception if the order with the given Id couldn't be found.Parameters:- orderId"""self.send_markOrderAsOutOfStock(orderId)return self.recv_markOrderAsOutOfStock()def send_markOrderAsOutOfStock(self, orderId):self._oprot.writeMessageBegin('markOrderAsOutOfStock', TMessageType.CALL, self._seqid)args = markOrderAsOutOfStock_args()args.orderId = orderIdargs.write(self._oprot)self._oprot.writeMessageEnd()self._oprot.trans.flush()def recv_markOrderAsOutOfStock(self, ):(fname, mtype, rseqid) = self._iprot.readMessageBegin()if mtype == TMessageType.EXCEPTION:x = TApplicationException()x.read(self._iprot)self._iprot.readMessageEnd()raise xresult = markOrderAsOutOfStock_result()result.read(self._iprot)self._iprot.readMessageEnd()if result.success != None:return result.successif result.ex != None:raise result.exraise TApplicationException(TApplicationException.MISSING_RESULT, "markOrderAsOutOfStock failed: unknown result");def markOrdersAsManifested(self, warehouseId, providerId):"""Marks all BILLED orders for a warehouse and a provider as SHIPPED_FROM_WHParameters:- warehouseId- providerId"""self.send_markOrdersAsManifested(warehouseId, providerId)return self.recv_markOrdersAsManifested()def send_markOrdersAsManifested(self, warehouseId, providerId):self._oprot.writeMessageBegin('markOrdersAsManifested', TMessageType.CALL, self._seqid)args = markOrdersAsManifested_args()args.warehouseId = warehouseIdargs.providerId = providerIdargs.write(self._oprot)self._oprot.writeMessageEnd()self._oprot.trans.flush()def recv_markOrdersAsManifested(self, ):(fname, mtype, rseqid) = self._iprot.readMessageBegin()if mtype == TMessageType.EXCEPTION:x = TApplicationException()x.read(self._iprot)self._iprot.readMessageEnd()raise xresult = markOrdersAsManifested_result()result.read(self._iprot)self._iprot.readMessageEnd()if result.success != None:return result.successif result.ex != None:raise result.exraise TApplicationException(TApplicationException.MISSING_RESULT, "markOrdersAsManifested failed: unknown result");def markOrdersAsPickedUp(self, providerId, pickupDetails):"""Marks all SHIPPED_FROM_WH orders of the previous day for a provider as SHIPPED_TO_LOGISTICS.Returns a list of orders that were shipped from warehouse but did not appear in the pick-up report.Raises an exception if we encounter report for an AWB number that we did not ship.Parameters:- providerId- pickupDetails"""self.send_markOrdersAsPickedUp(providerId, pickupDetails)return self.recv_markOrdersAsPickedUp()def send_markOrdersAsPickedUp(self, providerId, pickupDetails):self._oprot.writeMessageBegin('markOrdersAsPickedUp', TMessageType.CALL, self._seqid)args = markOrdersAsPickedUp_args()args.providerId = providerIdargs.pickupDetails = pickupDetailsargs.write(self._oprot)self._oprot.writeMessageEnd()self._oprot.trans.flush()def recv_markOrdersAsPickedUp(self, ):(fname, mtype, rseqid) = self._iprot.readMessageBegin()if mtype == TMessageType.EXCEPTION:x = TApplicationException()x.read(self._iprot)self._iprot.readMessageEnd()raise xresult = markOrdersAsPickedUp_result()result.read(self._iprot)self._iprot.readMessageEnd()if result.success != None:return result.successif result.ex != None:raise result.exraise TApplicationException(TApplicationException.MISSING_RESULT, "markOrdersAsPickedUp failed: unknown result");def markOrdersAsDelivered(self, providerId, deliveredOrders):"""Marks all orders with AWBs in the given map as delivered. Also sets the delivery timestamp andthe name of the receiver.Raises an exception if we encounter report for an AWB number that we did not ship.Parameters:- providerId- deliveredOrders"""self.send_markOrdersAsDelivered(providerId, deliveredOrders)self.recv_markOrdersAsDelivered()def send_markOrdersAsDelivered(self, providerId, deliveredOrders):self._oprot.writeMessageBegin('markOrdersAsDelivered', TMessageType.CALL, self._seqid)args = markOrdersAsDelivered_args()args.providerId = providerIdargs.deliveredOrders = deliveredOrdersargs.write(self._oprot)self._oprot.writeMessageEnd()self._oprot.trans.flush()def recv_markOrdersAsDelivered(self, ):(fname, mtype, rseqid) = self._iprot.readMessageBegin()if mtype == TMessageType.EXCEPTION:x = TApplicationException()x.read(self._iprot)self._iprot.readMessageEnd()raise xresult = markOrdersAsDelivered_result()result.read(self._iprot)self._iprot.readMessageEnd()if result.ex != None:raise result.exreturndef markOrdersAsFailed(self, providerId, returnedOrders):"""Mark all orders with AWBs in the given map as failed. Also sets the delivery timestamp.Raises an exception if we encounter report for an AWB number that we did not ship.Parameters:- providerId- returnedOrders"""self.send_markOrdersAsFailed(providerId, returnedOrders)self.recv_markOrdersAsFailed()def send_markOrdersAsFailed(self, providerId, returnedOrders):self._oprot.writeMessageBegin('markOrdersAsFailed', TMessageType.CALL, self._seqid)args = markOrdersAsFailed_args()args.providerId = providerIdargs.returnedOrders = returnedOrdersargs.write(self._oprot)self._oprot.writeMessageEnd()self._oprot.trans.flush()def recv_markOrdersAsFailed(self, ):(fname, mtype, rseqid) = self._iprot.readMessageBegin()if mtype == TMessageType.EXCEPTION:x = TApplicationException()x.read(self._iprot)self._iprot.readMessageEnd()raise xresult = markOrdersAsFailed_result()result.read(self._iprot)self._iprot.readMessageEnd()if result.ex != None:raise result.exreturndef updateNonDeliveryReason(self, providerId, undeliveredOrders):"""Update the status description of orders whose AWB numbers are keys of the Map.Parameters:- providerId- undeliveredOrders"""self.send_updateNonDeliveryReason(providerId, undeliveredOrders)self.recv_updateNonDeliveryReason()def send_updateNonDeliveryReason(self, providerId, undeliveredOrders):self._oprot.writeMessageBegin('updateNonDeliveryReason', TMessageType.CALL, self._seqid)args = updateNonDeliveryReason_args()args.providerId = providerIdargs.undeliveredOrders = undeliveredOrdersargs.write(self._oprot)self._oprot.writeMessageEnd()self._oprot.trans.flush()def recv_updateNonDeliveryReason(self, ):(fname, mtype, rseqid) = self._iprot.readMessageBegin()if mtype == TMessageType.EXCEPTION:x = TApplicationException()x.read(self._iprot)self._iprot.readMessageEnd()raise xresult = updateNonDeliveryReason_result()result.read(self._iprot)self._iprot.readMessageEnd()if result.ex != None:raise result.exreturndef getUndeliveredOrders(self, providerId, warehouseId):"""Returns the list of orders whose delivery time has passed but have not beendelivered yet for the given provider and warehouse. To get a complete list ofundelivered orders, pass them as -1.Returns an empty list if no such orders exist.Parameters:- providerId- warehouseId"""self.send_getUndeliveredOrders(providerId, warehouseId)return self.recv_getUndeliveredOrders()def send_getUndeliveredOrders(self, providerId, warehouseId):self._oprot.writeMessageBegin('getUndeliveredOrders', TMessageType.CALL, self._seqid)args = getUndeliveredOrders_args()args.providerId = providerIdargs.warehouseId = warehouseIdargs.write(self._oprot)self._oprot.writeMessageEnd()self._oprot.trans.flush()def recv_getUndeliveredOrders(self, ):(fname, mtype, rseqid) = self._iprot.readMessageBegin()if mtype == TMessageType.EXCEPTION:x = TApplicationException()x.read(self._iprot)self._iprot.readMessageEnd()raise xresult = getUndeliveredOrders_result()result.read(self._iprot)self._iprot.readMessageEnd()if result.success != None:return result.successraise TApplicationException(TApplicationException.MISSING_RESULT, "getUndeliveredOrders failed: unknown result");def getAlerts(self, orderId, valid):"""Parameters:- orderId- valid"""self.send_getAlerts(orderId, valid)return self.recv_getAlerts()def send_getAlerts(self, orderId, valid):self._oprot.writeMessageBegin('getAlerts', TMessageType.CALL, self._seqid)args = getAlerts_args()args.orderId = orderIdargs.valid = validargs.write(self._oprot)self._oprot.writeMessageEnd()self._oprot.trans.flush()def recv_getAlerts(self, ):(fname, mtype, rseqid) = self._iprot.readMessageBegin()if mtype == TMessageType.EXCEPTION:x = TApplicationException()x.read(self._iprot)self._iprot.readMessageEnd()raise xresult = getAlerts_result()result.read(self._iprot)self._iprot.readMessageEnd()if result.success != None:return result.successraise TApplicationException(TApplicationException.MISSING_RESULT, "getAlerts failed: unknown result");def setAlert(self, orderId, unset, type, comment):"""Parameters:- orderId- unset- type- comment"""self.send_setAlert(orderId, unset, type, comment)self.recv_setAlert()def send_setAlert(self, orderId, unset, type, comment):self._oprot.writeMessageBegin('setAlert', TMessageType.CALL, self._seqid)args = setAlert_args()args.orderId = orderIdargs.unset = unsetargs.type = typeargs.comment = commentargs.write(self._oprot)self._oprot.writeMessageEnd()self._oprot.trans.flush()def recv_setAlert(self, ):(fname, mtype, rseqid) = self._iprot.readMessageBegin()if mtype == TMessageType.EXCEPTION:x = TApplicationException()x.read(self._iprot)self._iprot.readMessageEnd()raise xresult = setAlert_result()result.read(self._iprot)self._iprot.readMessageEnd()returndef getValidOrderCount(self, ):"""Return the number of valid orders. (OrderStatus >= OrderStatus.SUBMITTED_FOR_PROCESSING)"""self.send_getValidOrderCount()return self.recv_getValidOrderCount()def send_getValidOrderCount(self, ):self._oprot.writeMessageBegin('getValidOrderCount', TMessageType.CALL, self._seqid)args = getValidOrderCount_args()args.write(self._oprot)self._oprot.writeMessageEnd()self._oprot.trans.flush()def recv_getValidOrderCount(self, ):(fname, mtype, rseqid) = self._iprot.readMessageBegin()if mtype == TMessageType.EXCEPTION:x = TApplicationException()x.read(self._iprot)self._iprot.readMessageEnd()raise xresult = getValidOrderCount_result()result.read(self._iprot)self._iprot.readMessageEnd()if result.success != None:return result.successraise TApplicationException(TApplicationException.MISSING_RESULT, "getValidOrderCount failed: unknown result");def getNoOfCustomersWithSuccessfulTransaction(self, ):"""Returns the number of distinct customers who have done successful transactions"""self.send_getNoOfCustomersWithSuccessfulTransaction()return self.recv_getNoOfCustomersWithSuccessfulTransaction()def send_getNoOfCustomersWithSuccessfulTransaction(self, ):self._oprot.writeMessageBegin('getNoOfCustomersWithSuccessfulTransaction', TMessageType.CALL, self._seqid)args = getNoOfCustomersWithSuccessfulTransaction_args()args.write(self._oprot)self._oprot.writeMessageEnd()self._oprot.trans.flush()def recv_getNoOfCustomersWithSuccessfulTransaction(self, ):(fname, mtype, rseqid) = self._iprot.readMessageBegin()if mtype == TMessageType.EXCEPTION:x = TApplicationException()x.read(self._iprot)self._iprot.readMessageEnd()raise xresult = getNoOfCustomersWithSuccessfulTransaction_result()result.read(self._iprot)self._iprot.readMessageEnd()if result.success != None:return result.successraise TApplicationException(TApplicationException.MISSING_RESULT, "getNoOfCustomersWithSuccessfulTransaction failed: unknown result");def getValidOrdersAmountRange(self, ):"""Returns the minimum and maximum amounts of a valid order. (OrderStatus >= OrderStatus.SUBMITTED_FOR_PROCESSING)List contains two values, first minimum amount and second maximum amount."""self.send_getValidOrdersAmountRange()return self.recv_getValidOrdersAmountRange()def send_getValidOrdersAmountRange(self, ):self._oprot.writeMessageBegin('getValidOrdersAmountRange', TMessageType.CALL, self._seqid)args = getValidOrdersAmountRange_args()args.write(self._oprot)self._oprot.writeMessageEnd()self._oprot.trans.flush()def recv_getValidOrdersAmountRange(self, ):(fname, mtype, rseqid) = self._iprot.readMessageBegin()if mtype == TMessageType.EXCEPTION:x = TApplicationException()x.read(self._iprot)self._iprot.readMessageEnd()raise xresult = getValidOrdersAmountRange_result()result.read(self._iprot)self._iprot.readMessageEnd()if result.success != None:return result.successraise TApplicationException(TApplicationException.MISSING_RESULT, "getValidOrdersAmountRange failed: unknown result");def getValidOrders(self, limit):"""Returns list of Orders in descending order by Order creation date. List is restricted to limit Orders.If limit is passed as 0, then all valid Orders are returned.Parameters:- limit"""self.send_getValidOrders(limit)return self.recv_getValidOrders()def send_getValidOrders(self, limit):self._oprot.writeMessageBegin('getValidOrders', TMessageType.CALL, self._seqid)args = getValidOrders_args()args.limit = limitargs.write(self._oprot)self._oprot.writeMessageEnd()self._oprot.trans.flush()def recv_getValidOrders(self, ):(fname, mtype, rseqid) = self._iprot.readMessageBegin()if mtype == TMessageType.EXCEPTION:x = TApplicationException()x.read(self._iprot)self._iprot.readMessageEnd()raise xresult = getValidOrders_result()result.read(self._iprot)self._iprot.readMessageEnd()if result.success != None:return result.successraise TApplicationException(TApplicationException.MISSING_RESULT, "getValidOrders failed: unknown result");class Processor(Iface, TProcessor):def __init__(self, handler):self._handler = handlerself._processMap = {}self._processMap["closeSession"] = Processor.process_closeSessionself._processMap["createTransaction"] = Processor.process_createTransactionself._processMap["getTransaction"] = Processor.process_getTransactionself._processMap["getTransactionsForCustomer"] = Processor.process_getTransactionsForCustomerself._processMap["getTransactionsForShoppingCartId"] = Processor.process_getTransactionsForShoppingCartIdself._processMap["getTransactionStatus"] = Processor.process_getTransactionStatusself._processMap["changeTransactionStatus"] = Processor.process_changeTransactionStatusself._processMap["enqueueTransactionInfoEmail"] = Processor.process_enqueueTransactionInfoEmailself._processMap["getAllOrders"] = Processor.process_getAllOrdersself._processMap["getOrdersByBillingDate"] = Processor.process_getOrdersByBillingDateself._processMap["getReturnableOrdersForCustomer"] = Processor.process_getReturnableOrdersForCustomerself._processMap["getCancellableOrdersForCustomer"] = Processor.process_getCancellableOrdersForCustomerself._processMap["changeOrderStatus"] = Processor.process_changeOrderStatusself._processMap["addBillingDetails"] = Processor.process_addBillingDetailsself._processMap["addJacketNumber"] = Processor.process_addJacketNumberself._processMap["acceptOrder"] = Processor.process_acceptOrderself._processMap["billOrder"] = Processor.process_billOrderself._processMap["getOrdersForTransaction"] = Processor.process_getOrdersForTransactionself._processMap["getOrdersForCustomer"] = Processor.process_getOrdersForCustomerself._processMap["createOrder"] = Processor.process_createOrderself._processMap["getOrder"] = Processor.process_getOrderself._processMap["getLineItemsForOrder"] = Processor.process_getLineItemsForOrderself._processMap["getOrderForCustomer"] = Processor.process_getOrderForCustomerself._processMap["batchOrders"] = Processor.process_batchOrdersself._processMap["markOrderAsOutOfStock"] = Processor.process_markOrderAsOutOfStockself._processMap["markOrdersAsManifested"] = Processor.process_markOrdersAsManifestedself._processMap["markOrdersAsPickedUp"] = Processor.process_markOrdersAsPickedUpself._processMap["markOrdersAsDelivered"] = Processor.process_markOrdersAsDeliveredself._processMap["markOrdersAsFailed"] = Processor.process_markOrdersAsFailedself._processMap["updateNonDeliveryReason"] = Processor.process_updateNonDeliveryReasonself._processMap["getUndeliveredOrders"] = Processor.process_getUndeliveredOrdersself._processMap["getAlerts"] = Processor.process_getAlertsself._processMap["setAlert"] = Processor.process_setAlertself._processMap["getValidOrderCount"] = Processor.process_getValidOrderCountself._processMap["getNoOfCustomersWithSuccessfulTransaction"] = Processor.process_getNoOfCustomersWithSuccessfulTransactionself._processMap["getValidOrdersAmountRange"] = Processor.process_getValidOrdersAmountRangeself._processMap["getValidOrders"] = Processor.process_getValidOrdersdef 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_closeSession(self, seqid, iprot, oprot):args = closeSession_args()args.read(iprot)iprot.readMessageEnd()result = closeSession_result()self._handler.closeSession()oprot.writeMessageBegin("closeSession", TMessageType.REPLY, seqid)result.write(oprot)oprot.writeMessageEnd()oprot.trans.flush()def process_createTransaction(self, seqid, iprot, oprot):args = createTransaction_args()args.read(iprot)iprot.readMessageEnd()result = createTransaction_result()try:result.success = self._handler.createTransaction(args.transaction)except TransactionServiceException, ex:result.ex = exoprot.writeMessageBegin("createTransaction", TMessageType.REPLY, seqid)result.write(oprot)oprot.writeMessageEnd()oprot.trans.flush()def process_getTransaction(self, seqid, iprot, oprot):args = getTransaction_args()args.read(iprot)iprot.readMessageEnd()result = getTransaction_result()try:result.success = self._handler.getTransaction(args.id)except TransactionServiceException, ex:result.ex = exoprot.writeMessageBegin("getTransaction", TMessageType.REPLY, seqid)result.write(oprot)oprot.writeMessageEnd()oprot.trans.flush()def process_getTransactionsForCustomer(self, seqid, iprot, oprot):args = getTransactionsForCustomer_args()args.read(iprot)iprot.readMessageEnd()result = getTransactionsForCustomer_result()try:result.success = self._handler.getTransactionsForCustomer(args.customerId, args.from_date, args.to_date, args.status)except TransactionServiceException, ex:result.ex = exoprot.writeMessageBegin("getTransactionsForCustomer", TMessageType.REPLY, seqid)result.write(oprot)oprot.writeMessageEnd()oprot.trans.flush()def process_getTransactionsForShoppingCartId(self, seqid, iprot, oprot):args = getTransactionsForShoppingCartId_args()args.read(iprot)iprot.readMessageEnd()result = getTransactionsForShoppingCartId_result()try:result.success = self._handler.getTransactionsForShoppingCartId(args.shoppingCartId)except TransactionServiceException, ex:result.ex = exoprot.writeMessageBegin("getTransactionsForShoppingCartId", TMessageType.REPLY, seqid)result.write(oprot)oprot.writeMessageEnd()oprot.trans.flush()def process_getTransactionStatus(self, seqid, iprot, oprot):args = getTransactionStatus_args()args.read(iprot)iprot.readMessageEnd()result = getTransactionStatus_result()try:result.success = self._handler.getTransactionStatus(args.transactionId)except TransactionServiceException, ex:result.ex = exoprot.writeMessageBegin("getTransactionStatus", TMessageType.REPLY, seqid)result.write(oprot)oprot.writeMessageEnd()oprot.trans.flush()def process_changeTransactionStatus(self, seqid, iprot, oprot):args = changeTransactionStatus_args()args.read(iprot)iprot.readMessageEnd()result = changeTransactionStatus_result()try:result.success = self._handler.changeTransactionStatus(args.transactionId, args.status, args.description)except TransactionServiceException, ex:result.ex = exoprot.writeMessageBegin("changeTransactionStatus", TMessageType.REPLY, seqid)result.write(oprot)oprot.writeMessageEnd()oprot.trans.flush()def process_enqueueTransactionInfoEmail(self, seqid, iprot, oprot):args = enqueueTransactionInfoEmail_args()args.read(iprot)iprot.readMessageEnd()result = enqueueTransactionInfoEmail_result()try:result.success = self._handler.enqueueTransactionInfoEmail(args.transactionId)except TransactionServiceException, ex:result.ex = exoprot.writeMessageBegin("enqueueTransactionInfoEmail", TMessageType.REPLY, seqid)result.write(oprot)oprot.writeMessageEnd()oprot.trans.flush()def process_getAllOrders(self, seqid, iprot, oprot):args = getAllOrders_args()args.read(iprot)iprot.readMessageEnd()result = getAllOrders_result()try:result.success = self._handler.getAllOrders(args.status, args.from_date, args.to_date, args.warehouse_id)except TransactionServiceException, ex:result.ex = exoprot.writeMessageBegin("getAllOrders", TMessageType.REPLY, seqid)result.write(oprot)oprot.writeMessageEnd()oprot.trans.flush()def process_getOrdersByBillingDate(self, seqid, iprot, oprot):args = getOrdersByBillingDate_args()args.read(iprot)iprot.readMessageEnd()result = getOrdersByBillingDate_result()try:result.success = self._handler.getOrdersByBillingDate(args.status, args.start_billing_date, args.end_billing_date, args.warehouse_id)except TransactionServiceException, ex:result.ex = exoprot.writeMessageBegin("getOrdersByBillingDate", TMessageType.REPLY, seqid)result.write(oprot)oprot.writeMessageEnd()oprot.trans.flush()def process_getReturnableOrdersForCustomer(self, seqid, iprot, oprot):args = getReturnableOrdersForCustomer_args()args.read(iprot)iprot.readMessageEnd()result = getReturnableOrdersForCustomer_result()try:result.success = self._handler.getReturnableOrdersForCustomer(args.customer_id, args.limit)except TransactionServiceException, ex:result.ex = exoprot.writeMessageBegin("getReturnableOrdersForCustomer", TMessageType.REPLY, seqid)result.write(oprot)oprot.writeMessageEnd()oprot.trans.flush()def process_getCancellableOrdersForCustomer(self, seqid, iprot, oprot):args = getCancellableOrdersForCustomer_args()args.read(iprot)iprot.readMessageEnd()result = getCancellableOrdersForCustomer_result()try:result.success = self._handler.getCancellableOrdersForCustomer(args.customer_id, args.limit)except TransactionServiceException, ex:result.ex = exoprot.writeMessageBegin("getCancellableOrdersForCustomer", TMessageType.REPLY, seqid)result.write(oprot)oprot.writeMessageEnd()oprot.trans.flush()def process_changeOrderStatus(self, seqid, iprot, oprot):args = changeOrderStatus_args()args.read(iprot)iprot.readMessageEnd()result = changeOrderStatus_result()try:result.success = self._handler.changeOrderStatus(args.orderId, args.status, args.description)except TransactionServiceException, ex:result.ex = exoprot.writeMessageBegin("changeOrderStatus", TMessageType.REPLY, seqid)result.write(oprot)oprot.writeMessageEnd()oprot.trans.flush()def process_addBillingDetails(self, seqid, iprot, oprot):args = addBillingDetails_args()args.read(iprot)iprot.readMessageEnd()result = addBillingDetails_result()try:result.success = self._handler.addBillingDetails(args.orderId, args.invoice_number, args.billed_by)except TransactionServiceException, ex:result.ex = exoprot.writeMessageBegin("addBillingDetails", TMessageType.REPLY, seqid)result.write(oprot)oprot.writeMessageEnd()oprot.trans.flush()def process_addJacketNumber(self, seqid, iprot, oprot):args = addJacketNumber_args()args.read(iprot)iprot.readMessageEnd()result = addJacketNumber_result()try:result.success = self._handler.addJacketNumber(args.orderId, args.jacketNumber)except TransactionServiceException, ex:result.ex = exoprot.writeMessageBegin("addJacketNumber", TMessageType.REPLY, seqid)result.write(oprot)oprot.writeMessageEnd()oprot.trans.flush()def process_acceptOrder(self, seqid, iprot, oprot):args = acceptOrder_args()args.read(iprot)iprot.readMessageEnd()result = acceptOrder_result()try:result.success = self._handler.acceptOrder(args.orderId)except TransactionServiceException, ex:result.ex = exoprot.writeMessageBegin("acceptOrder", TMessageType.REPLY, seqid)result.write(oprot)oprot.writeMessageEnd()oprot.trans.flush()def process_billOrder(self, seqid, iprot, oprot):args = billOrder_args()args.read(iprot)iprot.readMessageEnd()result = billOrder_result()try:result.success = self._handler.billOrder(args.orderId)except TransactionServiceException, ex:result.ex = exoprot.writeMessageBegin("billOrder", TMessageType.REPLY, seqid)result.write(oprot)oprot.writeMessageEnd()oprot.trans.flush()def process_getOrdersForTransaction(self, seqid, iprot, oprot):args = getOrdersForTransaction_args()args.read(iprot)iprot.readMessageEnd()result = getOrdersForTransaction_result()try:result.success = self._handler.getOrdersForTransaction(args.transactionId, args.customerId)except TransactionServiceException, ex:result.ex = exoprot.writeMessageBegin("getOrdersForTransaction", TMessageType.REPLY, seqid)result.write(oprot)oprot.writeMessageEnd()oprot.trans.flush()def process_getOrdersForCustomer(self, seqid, iprot, oprot):args = getOrdersForCustomer_args()args.read(iprot)iprot.readMessageEnd()result = getOrdersForCustomer_result()try:result.success = self._handler.getOrdersForCustomer(args.customerId, args.from_date, args.to_date, args.status)except TransactionServiceException, ex:result.ex = exoprot.writeMessageBegin("getOrdersForCustomer", TMessageType.REPLY, seqid)result.write(oprot)oprot.writeMessageEnd()oprot.trans.flush()def process_createOrder(self, seqid, iprot, oprot):args = createOrder_args()args.read(iprot)iprot.readMessageEnd()result = createOrder_result()try:result.success = self._handler.createOrder(args.order)except TransactionServiceException, ex:result.ex = exoprot.writeMessageBegin("createOrder", TMessageType.REPLY, seqid)result.write(oprot)oprot.writeMessageEnd()oprot.trans.flush()def process_getOrder(self, seqid, iprot, oprot):args = getOrder_args()args.read(iprot)iprot.readMessageEnd()result = getOrder_result()try:result.success = self._handler.getOrder(args.id)except TransactionServiceException, ex:result.ex = exoprot.writeMessageBegin("getOrder", TMessageType.REPLY, seqid)result.write(oprot)oprot.writeMessageEnd()oprot.trans.flush()def process_getLineItemsForOrder(self, seqid, iprot, oprot):args = getLineItemsForOrder_args()args.read(iprot)iprot.readMessageEnd()result = getLineItemsForOrder_result()try:result.success = self._handler.getLineItemsForOrder(args.orderId)except TransactionServiceException, ex:result.ex = exoprot.writeMessageBegin("getLineItemsForOrder", TMessageType.REPLY, seqid)result.write(oprot)oprot.writeMessageEnd()oprot.trans.flush()def process_getOrderForCustomer(self, seqid, iprot, oprot):args = getOrderForCustomer_args()args.read(iprot)iprot.readMessageEnd()result = getOrderForCustomer_result()try:result.success = self._handler.getOrderForCustomer(args.orderId, args.customerId)except TransactionServiceException, ex:result.ex = exoprot.writeMessageBegin("getOrderForCustomer", TMessageType.REPLY, seqid)result.write(oprot)oprot.writeMessageEnd()oprot.trans.flush()def process_batchOrders(self, seqid, iprot, oprot):args = batchOrders_args()args.read(iprot)iprot.readMessageEnd()result = batchOrders_result()try:result.success = self._handler.batchOrders(args.warehouseId)except TransactionServiceException, ex:result.ex = exoprot.writeMessageBegin("batchOrders", TMessageType.REPLY, seqid)result.write(oprot)oprot.writeMessageEnd()oprot.trans.flush()def process_markOrderAsOutOfStock(self, seqid, iprot, oprot):args = markOrderAsOutOfStock_args()args.read(iprot)iprot.readMessageEnd()result = markOrderAsOutOfStock_result()try:result.success = self._handler.markOrderAsOutOfStock(args.orderId)except TransactionServiceException, ex:result.ex = exoprot.writeMessageBegin("markOrderAsOutOfStock", TMessageType.REPLY, seqid)result.write(oprot)oprot.writeMessageEnd()oprot.trans.flush()def process_markOrdersAsManifested(self, seqid, iprot, oprot):args = markOrdersAsManifested_args()args.read(iprot)iprot.readMessageEnd()result = markOrdersAsManifested_result()try:result.success = self._handler.markOrdersAsManifested(args.warehouseId, args.providerId)except TransactionServiceException, ex:result.ex = exoprot.writeMessageBegin("markOrdersAsManifested", TMessageType.REPLY, seqid)result.write(oprot)oprot.writeMessageEnd()oprot.trans.flush()def process_markOrdersAsPickedUp(self, seqid, iprot, oprot):args = markOrdersAsPickedUp_args()args.read(iprot)iprot.readMessageEnd()result = markOrdersAsPickedUp_result()try:result.success = self._handler.markOrdersAsPickedUp(args.providerId, args.pickupDetails)except TransactionServiceException, ex:result.ex = exoprot.writeMessageBegin("markOrdersAsPickedUp", TMessageType.REPLY, seqid)result.write(oprot)oprot.writeMessageEnd()oprot.trans.flush()def process_markOrdersAsDelivered(self, seqid, iprot, oprot):args = markOrdersAsDelivered_args()args.read(iprot)iprot.readMessageEnd()result = markOrdersAsDelivered_result()try:self._handler.markOrdersAsDelivered(args.providerId, args.deliveredOrders)except TransactionServiceException, ex:result.ex = exoprot.writeMessageBegin("markOrdersAsDelivered", TMessageType.REPLY, seqid)result.write(oprot)oprot.writeMessageEnd()oprot.trans.flush()def process_markOrdersAsFailed(self, seqid, iprot, oprot):args = markOrdersAsFailed_args()args.read(iprot)iprot.readMessageEnd()result = markOrdersAsFailed_result()try:self._handler.markOrdersAsFailed(args.providerId, args.returnedOrders)except TransactionServiceException, ex:result.ex = exoprot.writeMessageBegin("markOrdersAsFailed", TMessageType.REPLY, seqid)result.write(oprot)oprot.writeMessageEnd()oprot.trans.flush()def process_updateNonDeliveryReason(self, seqid, iprot, oprot):args = updateNonDeliveryReason_args()args.read(iprot)iprot.readMessageEnd()result = updateNonDeliveryReason_result()try:self._handler.updateNonDeliveryReason(args.providerId, args.undeliveredOrders)except TransactionServiceException, ex:result.ex = exoprot.writeMessageBegin("updateNonDeliveryReason", TMessageType.REPLY, seqid)result.write(oprot)oprot.writeMessageEnd()oprot.trans.flush()def process_getUndeliveredOrders(self, seqid, iprot, oprot):args = getUndeliveredOrders_args()args.read(iprot)iprot.readMessageEnd()result = getUndeliveredOrders_result()result.success = self._handler.getUndeliveredOrders(args.providerId, args.warehouseId)oprot.writeMessageBegin("getUndeliveredOrders", TMessageType.REPLY, seqid)result.write(oprot)oprot.writeMessageEnd()oprot.trans.flush()def process_getAlerts(self, seqid, iprot, oprot):args = getAlerts_args()args.read(iprot)iprot.readMessageEnd()result = getAlerts_result()result.success = self._handler.getAlerts(args.orderId, args.valid)oprot.writeMessageBegin("getAlerts", TMessageType.REPLY, seqid)result.write(oprot)oprot.writeMessageEnd()oprot.trans.flush()def process_setAlert(self, seqid, iprot, oprot):args = setAlert_args()args.read(iprot)iprot.readMessageEnd()result = setAlert_result()self._handler.setAlert(args.orderId, args.unset, args.type, args.comment)oprot.writeMessageBegin("setAlert", TMessageType.REPLY, seqid)result.write(oprot)oprot.writeMessageEnd()oprot.trans.flush()def process_getValidOrderCount(self, seqid, iprot, oprot):args = getValidOrderCount_args()args.read(iprot)iprot.readMessageEnd()result = getValidOrderCount_result()result.success = self._handler.getValidOrderCount()oprot.writeMessageBegin("getValidOrderCount", TMessageType.REPLY, seqid)result.write(oprot)oprot.writeMessageEnd()oprot.trans.flush()def process_getNoOfCustomersWithSuccessfulTransaction(self, seqid, iprot, oprot):args = getNoOfCustomersWithSuccessfulTransaction_args()args.read(iprot)iprot.readMessageEnd()result = getNoOfCustomersWithSuccessfulTransaction_result()result.success = self._handler.getNoOfCustomersWithSuccessfulTransaction()oprot.writeMessageBegin("getNoOfCustomersWithSuccessfulTransaction", TMessageType.REPLY, seqid)result.write(oprot)oprot.writeMessageEnd()oprot.trans.flush()def process_getValidOrdersAmountRange(self, seqid, iprot, oprot):args = getValidOrdersAmountRange_args()args.read(iprot)iprot.readMessageEnd()result = getValidOrdersAmountRange_result()result.success = self._handler.getValidOrdersAmountRange()oprot.writeMessageBegin("getValidOrdersAmountRange", TMessageType.REPLY, seqid)result.write(oprot)oprot.writeMessageEnd()oprot.trans.flush()def process_getValidOrders(self, seqid, iprot, oprot):args = getValidOrders_args()args.read(iprot)iprot.readMessageEnd()result = getValidOrders_result()result.success = self._handler.getValidOrders(args.limit)oprot.writeMessageBegin("getValidOrders", TMessageType.REPLY, seqid)result.write(oprot)oprot.writeMessageEnd()oprot.trans.flush()# HELPER FUNCTIONS AND STRUCTURESclass closeSession_args: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('closeSession_args')oprot.writeFieldStop()oprot.writeStructEnd()def __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 closeSession_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('closeSession_result')oprot.writeFieldStop()oprot.writeStructEnd()def __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 createTransaction_args:"""Attributes:- transaction"""thrift_spec = (None, # 0(1, TType.STRUCT, 'transaction', (Transaction, Transaction.thrift_spec), None, ), # 1)def __init__(self, transaction=None,):self.transaction = transactiondef 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.transaction = Transaction()self.transaction.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('createTransaction_args')if self.transaction != None:oprot.writeFieldBegin('transaction', TType.STRUCT, 1)self.transaction.write(oprot)oprot.writeFieldEnd()oprot.writeFieldStop()oprot.writeStructEnd()def __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 createTransaction_result:"""Attributes:- success- ex"""thrift_spec = ((0, TType.I64, 'success', None, None, ), # 0(1, TType.STRUCT, 'ex', (TransactionServiceException, TransactionServiceException.thrift_spec), None, ), # 1)def __init__(self, success=None, ex=None,):self.success = successself.ex = exdef 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.I64:self.success = iprot.readI64();else:iprot.skip(ftype)elif fid == 1:if ftype == TType.STRUCT:self.ex = TransactionServiceException()self.ex.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('createTransaction_result')if self.success != None:oprot.writeFieldBegin('success', TType.I64, 0)oprot.writeI64(self.success)oprot.writeFieldEnd()if self.ex != None:oprot.writeFieldBegin('ex', TType.STRUCT, 1)self.ex.write(oprot)oprot.writeFieldEnd()oprot.writeFieldStop()oprot.writeStructEnd()def __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 getTransaction_args:"""Attributes:- id"""thrift_spec = (None, # 0(1, TType.I64, 'id', None, None, ), # 1)def __init__(self, id=None,):self.id = iddef 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.id = 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('getTransaction_args')if self.id != None:oprot.writeFieldBegin('id', TType.I64, 1)oprot.writeI64(self.id)oprot.writeFieldEnd()oprot.writeFieldStop()oprot.writeStructEnd()def __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 getTransaction_result:"""Attributes:- success- ex"""thrift_spec = ((0, TType.STRUCT, 'success', (Transaction, Transaction.thrift_spec), None, ), # 0(1, TType.STRUCT, 'ex', (TransactionServiceException, TransactionServiceException.thrift_spec), None, ), # 1)def __init__(self, success=None, ex=None,):self.success = successself.ex = exdef 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 = Transaction()self.success.read(iprot)else:iprot.skip(ftype)elif fid == 1:if ftype == TType.STRUCT:self.ex = TransactionServiceException()self.ex.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('getTransaction_result')if self.success != None:oprot.writeFieldBegin('success', TType.STRUCT, 0)self.success.write(oprot)oprot.writeFieldEnd()if self.ex != None:oprot.writeFieldBegin('ex', TType.STRUCT, 1)self.ex.write(oprot)oprot.writeFieldEnd()oprot.writeFieldStop()oprot.writeStructEnd()def __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 getTransactionsForCustomer_args:"""Attributes:- customerId- from_date- to_date- status"""thrift_spec = (None, # 0(1, TType.I64, 'customerId', None, None, ), # 1(2, TType.I64, 'from_date', None, None, ), # 2(3, TType.I64, 'to_date', None, None, ), # 3(4, TType.I32, 'status', None, None, ), # 4)def __init__(self, customerId=None, from_date=None, to_date=None, status=None,):self.customerId = customerIdself.from_date = from_dateself.to_date = to_dateself.status = statusdef 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.customerId = iprot.readI64();else:iprot.skip(ftype)elif fid == 2:if ftype == TType.I64:self.from_date = iprot.readI64();else:iprot.skip(ftype)elif fid == 3:if ftype == TType.I64:self.to_date = iprot.readI64();else:iprot.skip(ftype)elif fid == 4:if ftype == TType.I32:self.status = 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('getTransactionsForCustomer_args')if self.customerId != None:oprot.writeFieldBegin('customerId', TType.I64, 1)oprot.writeI64(self.customerId)oprot.writeFieldEnd()if self.from_date != None:oprot.writeFieldBegin('from_date', TType.I64, 2)oprot.writeI64(self.from_date)oprot.writeFieldEnd()if self.to_date != None:oprot.writeFieldBegin('to_date', TType.I64, 3)oprot.writeI64(self.to_date)oprot.writeFieldEnd()if self.status != None:oprot.writeFieldBegin('status', TType.I32, 4)oprot.writeI32(self.status)oprot.writeFieldEnd()oprot.writeFieldStop()oprot.writeStructEnd()def __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 getTransactionsForCustomer_result:"""Attributes:- success- ex"""thrift_spec = ((0, TType.LIST, 'success', (TType.STRUCT,(Transaction, Transaction.thrift_spec)), None, ), # 0(1, TType.STRUCT, 'ex', (TransactionServiceException, TransactionServiceException.thrift_spec), None, ), # 1)def __init__(self, success=None, ex=None,):self.success = successself.ex = exdef 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 = Transaction()_elem19.read(iprot)self.success.append(_elem19)iprot.readListEnd()else:iprot.skip(ftype)elif fid == 1:if ftype == TType.STRUCT:self.ex = TransactionServiceException()self.ex.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('getTransactionsForCustomer_result')if self.success != 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()if self.ex != None:oprot.writeFieldBegin('ex', TType.STRUCT, 1)self.ex.write(oprot)oprot.writeFieldEnd()oprot.writeFieldStop()oprot.writeStructEnd()def __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 getTransactionsForShoppingCartId_args:"""Attributes:- shoppingCartId"""thrift_spec = (None, # 0(1, TType.I64, 'shoppingCartId', None, None, ), # 1)def __init__(self, shoppingCartId=None,):self.shoppingCartId = shoppingCartIddef 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.shoppingCartId = 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('getTransactionsForShoppingCartId_args')if self.shoppingCartId != None:oprot.writeFieldBegin('shoppingCartId', TType.I64, 1)oprot.writeI64(self.shoppingCartId)oprot.writeFieldEnd()oprot.writeFieldStop()oprot.writeStructEnd()def __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 getTransactionsForShoppingCartId_result:"""Attributes:- success- ex"""thrift_spec = ((0, TType.LIST, 'success', (TType.STRUCT,(Transaction, Transaction.thrift_spec)), None, ), # 0(1, TType.STRUCT, 'ex', (TransactionServiceException, TransactionServiceException.thrift_spec), None, ), # 1)def __init__(self, success=None, ex=None,):self.success = successself.ex = exdef 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 = Transaction()_elem26.read(iprot)self.success.append(_elem26)iprot.readListEnd()else:iprot.skip(ftype)elif fid == 1:if ftype == TType.STRUCT:self.ex = TransactionServiceException()self.ex.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('getTransactionsForShoppingCartId_result')if self.success != 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()if self.ex != None:oprot.writeFieldBegin('ex', TType.STRUCT, 1)self.ex.write(oprot)oprot.writeFieldEnd()oprot.writeFieldStop()oprot.writeStructEnd()def __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 getTransactionStatus_args:"""Attributes:- transactionId"""thrift_spec = (None, # 0(1, TType.I64, 'transactionId', None, None, ), # 1)def __init__(self, transactionId=None,):self.transactionId = transactionIddef 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.transactionId = 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('getTransactionStatus_args')if self.transactionId != None:oprot.writeFieldBegin('transactionId', TType.I64, 1)oprot.writeI64(self.transactionId)oprot.writeFieldEnd()oprot.writeFieldStop()oprot.writeStructEnd()def __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 getTransactionStatus_result:"""Attributes:- success- ex"""thrift_spec = ((0, TType.I32, 'success', None, None, ), # 0(1, TType.STRUCT, 'ex', (TransactionServiceException, TransactionServiceException.thrift_spec), None, ), # 1)def __init__(self, success=None, ex=None,):self.success = successself.ex = exdef 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.I32:self.success = iprot.readI32();else:iprot.skip(ftype)elif fid == 1:if ftype == TType.STRUCT:self.ex = TransactionServiceException()self.ex.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('getTransactionStatus_result')if self.success != None:oprot.writeFieldBegin('success', TType.I32, 0)oprot.writeI32(self.success)oprot.writeFieldEnd()if self.ex != None:oprot.writeFieldBegin('ex', TType.STRUCT, 1)self.ex.write(oprot)oprot.writeFieldEnd()oprot.writeFieldStop()oprot.writeStructEnd()def __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 changeTransactionStatus_args:"""Attributes:- transactionId- status- description"""thrift_spec = (None, # 0(1, TType.I64, 'transactionId', None, None, ), # 1(2, TType.I32, 'status', None, None, ), # 2(3, TType.STRING, 'description', None, None, ), # 3)def __init__(self, transactionId=None, status=None, description=None,):self.transactionId = transactionIdself.status = statusself.description = descriptiondef 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.transactionId = iprot.readI64();else:iprot.skip(ftype)elif fid == 2:if ftype == TType.I32:self.status = iprot.readI32();else:iprot.skip(ftype)elif fid == 3:if ftype == TType.STRING:self.description = 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('changeTransactionStatus_args')if self.transactionId != None:oprot.writeFieldBegin('transactionId', TType.I64, 1)oprot.writeI64(self.transactionId)oprot.writeFieldEnd()if self.status != None:oprot.writeFieldBegin('status', TType.I32, 2)oprot.writeI32(self.status)oprot.writeFieldEnd()if self.description != None:oprot.writeFieldBegin('description', TType.STRING, 3)oprot.writeString(self.description)oprot.writeFieldEnd()oprot.writeFieldStop()oprot.writeStructEnd()def __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 changeTransactionStatus_result:"""Attributes:- success- ex"""thrift_spec = ((0, TType.BOOL, 'success', None, None, ), # 0(1, TType.STRUCT, 'ex', (TransactionServiceException, TransactionServiceException.thrift_spec), None, ), # 1)def __init__(self, success=None, ex=None,):self.success = successself.ex = exdef 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.BOOL:self.success = iprot.readBool();else:iprot.skip(ftype)elif fid == 1:if ftype == TType.STRUCT:self.ex = TransactionServiceException()self.ex.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('changeTransactionStatus_result')if self.success != None:oprot.writeFieldBegin('success', TType.BOOL, 0)oprot.writeBool(self.success)oprot.writeFieldEnd()if self.ex != None:oprot.writeFieldBegin('ex', TType.STRUCT, 1)self.ex.write(oprot)oprot.writeFieldEnd()oprot.writeFieldStop()oprot.writeStructEnd()def __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 enqueueTransactionInfoEmail_args:"""Attributes:- transactionId"""thrift_spec = (None, # 0(1, TType.I64, 'transactionId', None, None, ), # 1)def __init__(self, transactionId=None,):self.transactionId = transactionIddef 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.transactionId = 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('enqueueTransactionInfoEmail_args')if self.transactionId != None:oprot.writeFieldBegin('transactionId', TType.I64, 1)oprot.writeI64(self.transactionId)oprot.writeFieldEnd()oprot.writeFieldStop()oprot.writeStructEnd()def __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 enqueueTransactionInfoEmail_result:"""Attributes:- success- ex"""thrift_spec = ((0, TType.BOOL, 'success', None, None, ), # 0(1, TType.STRUCT, 'ex', (TransactionServiceException, TransactionServiceException.thrift_spec), None, ), # 1)def __init__(self, success=None, ex=None,):self.success = successself.ex = exdef 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.BOOL:self.success = iprot.readBool();else:iprot.skip(ftype)elif fid == 1:if ftype == TType.STRUCT:self.ex = TransactionServiceException()self.ex.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('enqueueTransactionInfoEmail_result')if self.success != None:oprot.writeFieldBegin('success', TType.BOOL, 0)oprot.writeBool(self.success)oprot.writeFieldEnd()if self.ex != None:oprot.writeFieldBegin('ex', TType.STRUCT, 1)self.ex.write(oprot)oprot.writeFieldEnd()oprot.writeFieldStop()oprot.writeStructEnd()def __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 getAllOrders_args:"""Attributes:- status- from_date- to_date- warehouse_id"""thrift_spec = (None, # 0(1, TType.I32, 'status', None, None, ), # 1(2, TType.I64, 'from_date', None, None, ), # 2(3, TType.I64, 'to_date', None, None, ), # 3(4, TType.I64, 'warehouse_id', None, None, ), # 4)def __init__(self, status=None, from_date=None, to_date=None, warehouse_id=None,):self.status = statusself.from_date = from_dateself.to_date = to_dateself.warehouse_id = warehouse_iddef 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.status = iprot.readI32();else:iprot.skip(ftype)elif fid == 2:if ftype == TType.I64:self.from_date = iprot.readI64();else:iprot.skip(ftype)elif fid == 3:if ftype == TType.I64:self.to_date = iprot.readI64();else:iprot.skip(ftype)elif fid == 4:if ftype == TType.I64:self.warehouse_id = 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('getAllOrders_args')if self.status != None:oprot.writeFieldBegin('status', TType.I32, 1)oprot.writeI32(self.status)oprot.writeFieldEnd()if self.from_date != None:oprot.writeFieldBegin('from_date', TType.I64, 2)oprot.writeI64(self.from_date)oprot.writeFieldEnd()if self.to_date != None:oprot.writeFieldBegin('to_date', TType.I64, 3)oprot.writeI64(self.to_date)oprot.writeFieldEnd()if self.warehouse_id != None:oprot.writeFieldBegin('warehouse_id', TType.I64, 4)oprot.writeI64(self.warehouse_id)oprot.writeFieldEnd()oprot.writeFieldStop()oprot.writeStructEnd()def __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 getAllOrders_result:"""Attributes:- success- ex"""thrift_spec = ((0, TType.LIST, 'success', (TType.STRUCT,(Order, Order.thrift_spec)), None, ), # 0(1, TType.STRUCT, 'ex', (TransactionServiceException, TransactionServiceException.thrift_spec), None, ), # 1)def __init__(self, success=None, ex=None,):self.success = successself.ex = exdef 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 = Order()_elem33.read(iprot)self.success.append(_elem33)iprot.readListEnd()else:iprot.skip(ftype)elif fid == 1:if ftype == TType.STRUCT:self.ex = TransactionServiceException()self.ex.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('getAllOrders_result')if self.success != None:oprot.writeFieldBegin('success', TType.LIST, 0)oprot.writeListBegin(TType.STRUCT, len(self.success))for iter34 in self.success:iter34.write(oprot)oprot.writeListEnd()oprot.writeFieldEnd()if self.ex != None:oprot.writeFieldBegin('ex', TType.STRUCT, 1)self.ex.write(oprot)oprot.writeFieldEnd()oprot.writeFieldStop()oprot.writeStructEnd()def __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 getOrdersByBillingDate_args:"""Attributes:- status- start_billing_date- end_billing_date- warehouse_id"""thrift_spec = (None, # 0(1, TType.I32, 'status', None, None, ), # 1(2, TType.I64, 'start_billing_date', None, None, ), # 2(3, TType.I64, 'end_billing_date', None, None, ), # 3(4, TType.I64, 'warehouse_id', None, None, ), # 4)def __init__(self, status=None, start_billing_date=None, end_billing_date=None, warehouse_id=None,):self.status = statusself.start_billing_date = start_billing_dateself.end_billing_date = end_billing_dateself.warehouse_id = warehouse_iddef 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.status = iprot.readI32();else:iprot.skip(ftype)elif fid == 2:if ftype == TType.I64:self.start_billing_date = iprot.readI64();else:iprot.skip(ftype)elif fid == 3:if ftype == TType.I64:self.end_billing_date = iprot.readI64();else:iprot.skip(ftype)elif fid == 4:if ftype == TType.I64:self.warehouse_id = 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('getOrdersByBillingDate_args')if self.status != None:oprot.writeFieldBegin('status', TType.I32, 1)oprot.writeI32(self.status)oprot.writeFieldEnd()if self.start_billing_date != None:oprot.writeFieldBegin('start_billing_date', TType.I64, 2)oprot.writeI64(self.start_billing_date)oprot.writeFieldEnd()if self.end_billing_date != None:oprot.writeFieldBegin('end_billing_date', TType.I64, 3)oprot.writeI64(self.end_billing_date)oprot.writeFieldEnd()if self.warehouse_id != None:oprot.writeFieldBegin('warehouse_id', TType.I64, 4)oprot.writeI64(self.warehouse_id)oprot.writeFieldEnd()oprot.writeFieldStop()oprot.writeStructEnd()def __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 getOrdersByBillingDate_result:"""Attributes:- success- ex"""thrift_spec = ((0, TType.LIST, 'success', (TType.STRUCT,(Order, Order.thrift_spec)), None, ), # 0(1, TType.STRUCT, 'ex', (TransactionServiceException, TransactionServiceException.thrift_spec), None, ), # 1)def __init__(self, success=None, ex=None,):self.success = successself.ex = exdef 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 = Order()_elem40.read(iprot)self.success.append(_elem40)iprot.readListEnd()else:iprot.skip(ftype)elif fid == 1:if ftype == TType.STRUCT:self.ex = TransactionServiceException()self.ex.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('getOrdersByBillingDate_result')if self.success != None:oprot.writeFieldBegin('success', TType.LIST, 0)oprot.writeListBegin(TType.STRUCT, len(self.success))for iter41 in self.success:iter41.write(oprot)oprot.writeListEnd()oprot.writeFieldEnd()if self.ex != None:oprot.writeFieldBegin('ex', TType.STRUCT, 1)self.ex.write(oprot)oprot.writeFieldEnd()oprot.writeFieldStop()oprot.writeStructEnd()def __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 getReturnableOrdersForCustomer_args:"""Attributes:- customer_id- limit"""thrift_spec = (None, # 0(1, TType.I64, 'customer_id', None, None, ), # 1(2, TType.I64, 'limit', None, None, ), # 2)def __init__(self, customer_id=None, limit=None,):self.customer_id = customer_idself.limit = limitdef 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.customer_id = iprot.readI64();else:iprot.skip(ftype)elif fid == 2:if ftype == TType.I64:self.limit = 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('getReturnableOrdersForCustomer_args')if self.customer_id != None:oprot.writeFieldBegin('customer_id', TType.I64, 1)oprot.writeI64(self.customer_id)oprot.writeFieldEnd()if self.limit != None:oprot.writeFieldBegin('limit', TType.I64, 2)oprot.writeI64(self.limit)oprot.writeFieldEnd()oprot.writeFieldStop()oprot.writeStructEnd()def __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 getReturnableOrdersForCustomer_result:"""Attributes:- success- ex"""thrift_spec = ((0, TType.LIST, 'success', (TType.I64,None), None, ), # 0(1, TType.STRUCT, 'ex', (TransactionServiceException, TransactionServiceException.thrift_spec), None, ), # 1)def __init__(self, success=None, ex=None,):self.success = successself.ex = exdef 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 = iprot.readI64();self.success.append(_elem47)iprot.readListEnd()else:iprot.skip(ftype)elif fid == 1:if ftype == TType.STRUCT:self.ex = TransactionServiceException()self.ex.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('getReturnableOrdersForCustomer_result')if self.success != None:oprot.writeFieldBegin('success', TType.LIST, 0)oprot.writeListBegin(TType.I64, len(self.success))for iter48 in self.success:oprot.writeI64(iter48)oprot.writeListEnd()oprot.writeFieldEnd()if self.ex != None:oprot.writeFieldBegin('ex', TType.STRUCT, 1)self.ex.write(oprot)oprot.writeFieldEnd()oprot.writeFieldStop()oprot.writeStructEnd()def __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 getCancellableOrdersForCustomer_args:"""Attributes:- customer_id- limit"""thrift_spec = (None, # 0(1, TType.I64, 'customer_id', None, None, ), # 1(2, TType.I64, 'limit', None, None, ), # 2)def __init__(self, customer_id=None, limit=None,):self.customer_id = customer_idself.limit = limitdef 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.customer_id = iprot.readI64();else:iprot.skip(ftype)elif fid == 2:if ftype == TType.I64:self.limit = 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('getCancellableOrdersForCustomer_args')if self.customer_id != None:oprot.writeFieldBegin('customer_id', TType.I64, 1)oprot.writeI64(self.customer_id)oprot.writeFieldEnd()if self.limit != None:oprot.writeFieldBegin('limit', TType.I64, 2)oprot.writeI64(self.limit)oprot.writeFieldEnd()oprot.writeFieldStop()oprot.writeStructEnd()def __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 getCancellableOrdersForCustomer_result:"""Attributes:- success- ex"""thrift_spec = ((0, TType.LIST, 'success', (TType.I64,None), None, ), # 0(1, TType.STRUCT, 'ex', (TransactionServiceException, TransactionServiceException.thrift_spec), None, ), # 1)def __init__(self, success=None, ex=None,):self.success = successself.ex = exdef 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 = [](_etype52, _size49) = iprot.readListBegin()for _i53 in xrange(_size49):_elem54 = iprot.readI64();self.success.append(_elem54)iprot.readListEnd()else:iprot.skip(ftype)elif fid == 1:if ftype == TType.STRUCT:self.ex = TransactionServiceException()self.ex.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('getCancellableOrdersForCustomer_result')if self.success != None:oprot.writeFieldBegin('success', TType.LIST, 0)oprot.writeListBegin(TType.I64, len(self.success))for iter55 in self.success:oprot.writeI64(iter55)oprot.writeListEnd()oprot.writeFieldEnd()if self.ex != None:oprot.writeFieldBegin('ex', TType.STRUCT, 1)self.ex.write(oprot)oprot.writeFieldEnd()oprot.writeFieldStop()oprot.writeStructEnd()def __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 changeOrderStatus_args:"""Attributes:- orderId- status- description"""thrift_spec = (None, # 0(1, TType.I64, 'orderId', None, None, ), # 1(2, TType.I32, 'status', None, None, ), # 2(3, TType.STRING, 'description', None, None, ), # 3)def __init__(self, orderId=None, status=None, description=None,):self.orderId = orderIdself.status = statusself.description = descriptiondef 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)elif fid == 2:if ftype == TType.I32:self.status = iprot.readI32();else:iprot.skip(ftype)elif fid == 3:if ftype == TType.STRING:self.description = 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('changeOrderStatus_args')if self.orderId != None:oprot.writeFieldBegin('orderId', TType.I64, 1)oprot.writeI64(self.orderId)oprot.writeFieldEnd()if self.status != None:oprot.writeFieldBegin('status', TType.I32, 2)oprot.writeI32(self.status)oprot.writeFieldEnd()if self.description != None:oprot.writeFieldBegin('description', TType.STRING, 3)oprot.writeString(self.description)oprot.writeFieldEnd()oprot.writeFieldStop()oprot.writeStructEnd()def __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 changeOrderStatus_result:"""Attributes:- success- ex"""thrift_spec = ((0, TType.BOOL, 'success', None, None, ), # 0(1, TType.STRUCT, 'ex', (TransactionServiceException, TransactionServiceException.thrift_spec), None, ), # 1)def __init__(self, success=None, ex=None,):self.success = successself.ex = exdef 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.BOOL:self.success = iprot.readBool();else:iprot.skip(ftype)elif fid == 1:if ftype == TType.STRUCT:self.ex = TransactionServiceException()self.ex.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('changeOrderStatus_result')if self.success != None:oprot.writeFieldBegin('success', TType.BOOL, 0)oprot.writeBool(self.success)oprot.writeFieldEnd()if self.ex != None:oprot.writeFieldBegin('ex', TType.STRUCT, 1)self.ex.write(oprot)oprot.writeFieldEnd()oprot.writeFieldStop()oprot.writeStructEnd()def __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 addBillingDetails_args:"""Attributes:- orderId- invoice_number- billed_by"""thrift_spec = (None, # 0(1, TType.I64, 'orderId', None, None, ), # 1(2, TType.STRING, 'invoice_number', None, None, ), # 2(3, TType.STRING, 'billed_by', None, None, ), # 3)def __init__(self, orderId=None, invoice_number=None, billed_by=None,):self.orderId = orderIdself.invoice_number = invoice_numberself.billed_by = billed_bydef 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)elif fid == 2:if ftype == TType.STRING:self.invoice_number = iprot.readString();else:iprot.skip(ftype)elif fid == 3:if ftype == TType.STRING:self.billed_by = 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('addBillingDetails_args')if self.orderId != None:oprot.writeFieldBegin('orderId', TType.I64, 1)oprot.writeI64(self.orderId)oprot.writeFieldEnd()if self.invoice_number != None:oprot.writeFieldBegin('invoice_number', TType.STRING, 2)oprot.writeString(self.invoice_number)oprot.writeFieldEnd()if self.billed_by != None:oprot.writeFieldBegin('billed_by', TType.STRING, 3)oprot.writeString(self.billed_by)oprot.writeFieldEnd()oprot.writeFieldStop()oprot.writeStructEnd()def __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 addBillingDetails_result:"""Attributes:- success- ex"""thrift_spec = ((0, TType.BOOL, 'success', None, None, ), # 0(1, TType.STRUCT, 'ex', (TransactionServiceException, TransactionServiceException.thrift_spec), None, ), # 1)def __init__(self, success=None, ex=None,):self.success = successself.ex = exdef 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.BOOL:self.success = iprot.readBool();else:iprot.skip(ftype)elif fid == 1:if ftype == TType.STRUCT:self.ex = TransactionServiceException()self.ex.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('addBillingDetails_result')if self.success != None:oprot.writeFieldBegin('success', TType.BOOL, 0)oprot.writeBool(self.success)oprot.writeFieldEnd()if self.ex != None:oprot.writeFieldBegin('ex', TType.STRUCT, 1)self.ex.write(oprot)oprot.writeFieldEnd()oprot.writeFieldStop()oprot.writeStructEnd()def __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 addJacketNumber_args:"""Attributes:- orderId- jacketNumber"""thrift_spec = (None, # 0(1, TType.I64, 'orderId', None, None, ), # 1(2, TType.I64, 'jacketNumber', None, None, ), # 2)def __init__(self, orderId=None, jacketNumber=None,):self.orderId = orderIdself.jacketNumber = jacketNumberdef 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)elif fid == 2:if ftype == TType.I64:self.jacketNumber = 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('addJacketNumber_args')if self.orderId != None:oprot.writeFieldBegin('orderId', TType.I64, 1)oprot.writeI64(self.orderId)oprot.writeFieldEnd()if self.jacketNumber != None:oprot.writeFieldBegin('jacketNumber', TType.I64, 2)oprot.writeI64(self.jacketNumber)oprot.writeFieldEnd()oprot.writeFieldStop()oprot.writeStructEnd()def __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 addJacketNumber_result:"""Attributes:- success- ex"""thrift_spec = ((0, TType.BOOL, 'success', None, None, ), # 0(1, TType.STRUCT, 'ex', (TransactionServiceException, TransactionServiceException.thrift_spec), None, ), # 1)def __init__(self, success=None, ex=None,):self.success = successself.ex = exdef 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.BOOL:self.success = iprot.readBool();else:iprot.skip(ftype)elif fid == 1:if ftype == TType.STRUCT:self.ex = TransactionServiceException()self.ex.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('addJacketNumber_result')if self.success != None:oprot.writeFieldBegin('success', TType.BOOL, 0)oprot.writeBool(self.success)oprot.writeFieldEnd()if self.ex != None:oprot.writeFieldBegin('ex', TType.STRUCT, 1)self.ex.write(oprot)oprot.writeFieldEnd()oprot.writeFieldStop()oprot.writeStructEnd()def __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 acceptOrder_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('acceptOrder_args')if self.orderId != None:oprot.writeFieldBegin('orderId', TType.I64, 1)oprot.writeI64(self.orderId)oprot.writeFieldEnd()oprot.writeFieldStop()oprot.writeStructEnd()def __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 acceptOrder_result:"""Attributes:- success- ex"""thrift_spec = ((0, TType.BOOL, 'success', None, None, ), # 0(1, TType.STRUCT, 'ex', (TransactionServiceException, TransactionServiceException.thrift_spec), None, ), # 1)def __init__(self, success=None, ex=None,):self.success = successself.ex = exdef 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.BOOL:self.success = iprot.readBool();else:iprot.skip(ftype)elif fid == 1:if ftype == TType.STRUCT:self.ex = TransactionServiceException()self.ex.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('acceptOrder_result')if self.success != None:oprot.writeFieldBegin('success', TType.BOOL, 0)oprot.writeBool(self.success)oprot.writeFieldEnd()if self.ex != None:oprot.writeFieldBegin('ex', TType.STRUCT, 1)self.ex.write(oprot)oprot.writeFieldEnd()oprot.writeFieldStop()oprot.writeStructEnd()def __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 billOrder_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('billOrder_args')if self.orderId != None:oprot.writeFieldBegin('orderId', TType.I64, 1)oprot.writeI64(self.orderId)oprot.writeFieldEnd()oprot.writeFieldStop()oprot.writeStructEnd()def __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 billOrder_result:"""Attributes:- success- ex"""thrift_spec = ((0, TType.BOOL, 'success', None, None, ), # 0(1, TType.STRUCT, 'ex', (TransactionServiceException, TransactionServiceException.thrift_spec), None, ), # 1)def __init__(self, success=None, ex=None,):self.success = successself.ex = exdef 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.BOOL:self.success = iprot.readBool();else:iprot.skip(ftype)elif fid == 1:if ftype == TType.STRUCT:self.ex = TransactionServiceException()self.ex.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('billOrder_result')if self.success != None:oprot.writeFieldBegin('success', TType.BOOL, 0)oprot.writeBool(self.success)oprot.writeFieldEnd()if self.ex != None:oprot.writeFieldBegin('ex', TType.STRUCT, 1)self.ex.write(oprot)oprot.writeFieldEnd()oprot.writeFieldStop()oprot.writeStructEnd()def __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 getOrdersForTransaction_args:"""Attributes:- transactionId- customerId"""thrift_spec = (None, # 0(1, TType.I64, 'transactionId', None, None, ), # 1(2, TType.I64, 'customerId', None, None, ), # 2)def __init__(self, transactionId=None, customerId=None,):self.transactionId = transactionIdself.customerId = customerIddef 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.transactionId = iprot.readI64();else:iprot.skip(ftype)elif fid == 2:if ftype == TType.I64:self.customerId = 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('getOrdersForTransaction_args')if self.transactionId != None:oprot.writeFieldBegin('transactionId', TType.I64, 1)oprot.writeI64(self.transactionId)oprot.writeFieldEnd()if self.customerId != None:oprot.writeFieldBegin('customerId', TType.I64, 2)oprot.writeI64(self.customerId)oprot.writeFieldEnd()oprot.writeFieldStop()oprot.writeStructEnd()def __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 getOrdersForTransaction_result:"""Attributes:- success- ex"""thrift_spec = ((0, TType.LIST, 'success', (TType.STRUCT,(Order, Order.thrift_spec)), None, ), # 0(1, TType.STRUCT, 'ex', (TransactionServiceException, TransactionServiceException.thrift_spec), None, ), # 1)def __init__(self, success=None, ex=None,):self.success = successself.ex = exdef 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 = [](_etype59, _size56) = iprot.readListBegin()for _i60 in xrange(_size56):_elem61 = Order()_elem61.read(iprot)self.success.append(_elem61)iprot.readListEnd()else:iprot.skip(ftype)elif fid == 1:if ftype == TType.STRUCT:self.ex = TransactionServiceException()self.ex.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('getOrdersForTransaction_result')if self.success != None:oprot.writeFieldBegin('success', TType.LIST, 0)oprot.writeListBegin(TType.STRUCT, len(self.success))for iter62 in self.success:iter62.write(oprot)oprot.writeListEnd()oprot.writeFieldEnd()if self.ex != None:oprot.writeFieldBegin('ex', TType.STRUCT, 1)self.ex.write(oprot)oprot.writeFieldEnd()oprot.writeFieldStop()oprot.writeStructEnd()def __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 getOrdersForCustomer_args:"""Attributes:- customerId- from_date- to_date- status"""thrift_spec = (None, # 0(1, TType.I64, 'customerId', None, None, ), # 1(2, TType.I64, 'from_date', None, None, ), # 2(3, TType.I64, 'to_date', None, None, ), # 3(4, TType.I32, 'status', None, None, ), # 4)def __init__(self, customerId=None, from_date=None, to_date=None, status=None,):self.customerId = customerIdself.from_date = from_dateself.to_date = to_dateself.status = statusdef 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.customerId = iprot.readI64();else:iprot.skip(ftype)elif fid == 2:if ftype == TType.I64:self.from_date = iprot.readI64();else:iprot.skip(ftype)elif fid == 3:if ftype == TType.I64:self.to_date = iprot.readI64();else:iprot.skip(ftype)elif fid == 4:if ftype == TType.I32:self.status = 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('getOrdersForCustomer_args')if self.customerId != None:oprot.writeFieldBegin('customerId', TType.I64, 1)oprot.writeI64(self.customerId)oprot.writeFieldEnd()if self.from_date != None:oprot.writeFieldBegin('from_date', TType.I64, 2)oprot.writeI64(self.from_date)oprot.writeFieldEnd()if self.to_date != None:oprot.writeFieldBegin('to_date', TType.I64, 3)oprot.writeI64(self.to_date)oprot.writeFieldEnd()if self.status != None:oprot.writeFieldBegin('status', TType.I32, 4)oprot.writeI32(self.status)oprot.writeFieldEnd()oprot.writeFieldStop()oprot.writeStructEnd()def __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 getOrdersForCustomer_result:"""Attributes:- success- ex"""thrift_spec = ((0, TType.LIST, 'success', (TType.STRUCT,(Order, Order.thrift_spec)), None, ), # 0(1, TType.STRUCT, 'ex', (TransactionServiceException, TransactionServiceException.thrift_spec), None, ), # 1)def __init__(self, success=None, ex=None,):self.success = successself.ex = exdef 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 = [](_etype66, _size63) = iprot.readListBegin()for _i67 in xrange(_size63):_elem68 = Order()_elem68.read(iprot)self.success.append(_elem68)iprot.readListEnd()else:iprot.skip(ftype)elif fid == 1:if ftype == TType.STRUCT:self.ex = TransactionServiceException()self.ex.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('getOrdersForCustomer_result')if self.success != None:oprot.writeFieldBegin('success', TType.LIST, 0)oprot.writeListBegin(TType.STRUCT, len(self.success))for iter69 in self.success:iter69.write(oprot)oprot.writeListEnd()oprot.writeFieldEnd()if self.ex != None:oprot.writeFieldBegin('ex', TType.STRUCT, 1)self.ex.write(oprot)oprot.writeFieldEnd()oprot.writeFieldStop()oprot.writeStructEnd()def __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 createOrder_args:"""Attributes:- order"""thrift_spec = (None, # 0(1, TType.STRUCT, 'order', (Order, Order.thrift_spec), None, ), # 1)def __init__(self, order=None,):self.order = orderdef 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.order = Order()self.order.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('createOrder_args')if self.order != None:oprot.writeFieldBegin('order', TType.STRUCT, 1)self.order.write(oprot)oprot.writeFieldEnd()oprot.writeFieldStop()oprot.writeStructEnd()def __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 createOrder_result:"""Attributes:- success- ex"""thrift_spec = ((0, TType.I64, 'success', None, None, ), # 0(1, TType.STRUCT, 'ex', (TransactionServiceException, TransactionServiceException.thrift_spec), None, ), # 1)def __init__(self, success=None, ex=None,):self.success = successself.ex = exdef 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.I64:self.success = iprot.readI64();else:iprot.skip(ftype)elif fid == 1:if ftype == TType.STRUCT:self.ex = TransactionServiceException()self.ex.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('createOrder_result')if self.success != None:oprot.writeFieldBegin('success', TType.I64, 0)oprot.writeI64(self.success)oprot.writeFieldEnd()if self.ex != None:oprot.writeFieldBegin('ex', TType.STRUCT, 1)self.ex.write(oprot)oprot.writeFieldEnd()oprot.writeFieldStop()oprot.writeStructEnd()def __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 getOrder_args:"""Attributes:- id"""thrift_spec = (None, # 0(1, TType.I64, 'id', None, None, ), # 1)def __init__(self, id=None,):self.id = iddef 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.id = 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('getOrder_args')if self.id != None:oprot.writeFieldBegin('id', TType.I64, 1)oprot.writeI64(self.id)oprot.writeFieldEnd()oprot.writeFieldStop()oprot.writeStructEnd()def __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 getOrder_result:"""Attributes:- success- ex"""thrift_spec = ((0, TType.STRUCT, 'success', (Order, Order.thrift_spec), None, ), # 0(1, TType.STRUCT, 'ex', (TransactionServiceException, TransactionServiceException.thrift_spec), None, ), # 1)def __init__(self, success=None, ex=None,):self.success = successself.ex = exdef 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 = Order()self.success.read(iprot)else:iprot.skip(ftype)elif fid == 1:if ftype == TType.STRUCT:self.ex = TransactionServiceException()self.ex.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('getOrder_result')if self.success != None:oprot.writeFieldBegin('success', TType.STRUCT, 0)self.success.write(oprot)oprot.writeFieldEnd()if self.ex != None:oprot.writeFieldBegin('ex', TType.STRUCT, 1)self.ex.write(oprot)oprot.writeFieldEnd()oprot.writeFieldStop()oprot.writeStructEnd()def __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 getLineItemsForOrder_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('getLineItemsForOrder_args')if self.orderId != None:oprot.writeFieldBegin('orderId', TType.I64, 1)oprot.writeI64(self.orderId)oprot.writeFieldEnd()oprot.writeFieldStop()oprot.writeStructEnd()def __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 getLineItemsForOrder_result:"""Attributes:- success- ex"""thrift_spec = ((0, TType.LIST, 'success', (TType.STRUCT,(LineItem, LineItem.thrift_spec)), None, ), # 0(1, TType.STRUCT, 'ex', (TransactionServiceException, TransactionServiceException.thrift_spec), None, ), # 1)def __init__(self, success=None, ex=None,):self.success = successself.ex = exdef 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 = [](_etype73, _size70) = iprot.readListBegin()for _i74 in xrange(_size70):_elem75 = LineItem()_elem75.read(iprot)self.success.append(_elem75)iprot.readListEnd()else:iprot.skip(ftype)elif fid == 1:if ftype == TType.STRUCT:self.ex = TransactionServiceException()self.ex.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('getLineItemsForOrder_result')if self.success != None:oprot.writeFieldBegin('success', TType.LIST, 0)oprot.writeListBegin(TType.STRUCT, len(self.success))for iter76 in self.success:iter76.write(oprot)oprot.writeListEnd()oprot.writeFieldEnd()if self.ex != None:oprot.writeFieldBegin('ex', TType.STRUCT, 1)self.ex.write(oprot)oprot.writeFieldEnd()oprot.writeFieldStop()oprot.writeStructEnd()def __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 getOrderForCustomer_args:"""Attributes:- orderId- customerId"""thrift_spec = (None, # 0(1, TType.I64, 'orderId', None, None, ), # 1(2, TType.I64, 'customerId', None, None, ), # 2)def __init__(self, orderId=None, customerId=None,):self.orderId = orderIdself.customerId = customerIddef 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)elif fid == 2:if ftype == TType.I64:self.customerId = 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('getOrderForCustomer_args')if self.orderId != None:oprot.writeFieldBegin('orderId', TType.I64, 1)oprot.writeI64(self.orderId)oprot.writeFieldEnd()if self.customerId != None:oprot.writeFieldBegin('customerId', TType.I64, 2)oprot.writeI64(self.customerId)oprot.writeFieldEnd()oprot.writeFieldStop()oprot.writeStructEnd()def __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 getOrderForCustomer_result:"""Attributes:- success- ex"""thrift_spec = ((0, TType.STRUCT, 'success', (Order, Order.thrift_spec), None, ), # 0(1, TType.STRUCT, 'ex', (TransactionServiceException, TransactionServiceException.thrift_spec), None, ), # 1)def __init__(self, success=None, ex=None,):self.success = successself.ex = exdef 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 = Order()self.success.read(iprot)else:iprot.skip(ftype)elif fid == 1:if ftype == TType.STRUCT:self.ex = TransactionServiceException()self.ex.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('getOrderForCustomer_result')if self.success != None:oprot.writeFieldBegin('success', TType.STRUCT, 0)self.success.write(oprot)oprot.writeFieldEnd()if self.ex != None:oprot.writeFieldBegin('ex', TType.STRUCT, 1)self.ex.write(oprot)oprot.writeFieldEnd()oprot.writeFieldStop()oprot.writeStructEnd()def __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 batchOrders_args:"""Attributes:- warehouseId"""thrift_spec = (None, # 0(1, TType.I64, 'warehouseId', None, None, ), # 1)def __init__(self, warehouseId=None,):self.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.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('batchOrders_args')if self.warehouseId != None:oprot.writeFieldBegin('warehouseId', TType.I64, 1)oprot.writeI64(self.warehouseId)oprot.writeFieldEnd()oprot.writeFieldStop()oprot.writeStructEnd()def __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 batchOrders_result:"""Attributes:- success- ex"""thrift_spec = ((0, TType.LIST, 'success', (TType.STRUCT,(Order, Order.thrift_spec)), None, ), # 0(1, TType.STRUCT, 'ex', (TransactionServiceException, TransactionServiceException.thrift_spec), None, ), # 1)def __init__(self, success=None, ex=None,):self.success = successself.ex = exdef 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 = [](_etype80, _size77) = iprot.readListBegin()for _i81 in xrange(_size77):_elem82 = Order()_elem82.read(iprot)self.success.append(_elem82)iprot.readListEnd()else:iprot.skip(ftype)elif fid == 1:if ftype == TType.STRUCT:self.ex = TransactionServiceException()self.ex.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('batchOrders_result')if self.success != None:oprot.writeFieldBegin('success', TType.LIST, 0)oprot.writeListBegin(TType.STRUCT, len(self.success))for iter83 in self.success:iter83.write(oprot)oprot.writeListEnd()oprot.writeFieldEnd()if self.ex != None:oprot.writeFieldBegin('ex', TType.STRUCT, 1)self.ex.write(oprot)oprot.writeFieldEnd()oprot.writeFieldStop()oprot.writeStructEnd()def __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 markOrderAsOutOfStock_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('markOrderAsOutOfStock_args')if self.orderId != None:oprot.writeFieldBegin('orderId', TType.I64, 1)oprot.writeI64(self.orderId)oprot.writeFieldEnd()oprot.writeFieldStop()oprot.writeStructEnd()def __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 markOrderAsOutOfStock_result:"""Attributes:- success- ex"""thrift_spec = ((0, TType.BOOL, 'success', None, None, ), # 0(1, TType.STRUCT, 'ex', (TransactionServiceException, TransactionServiceException.thrift_spec), None, ), # 1)def __init__(self, success=None, ex=None,):self.success = successself.ex = exdef 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.BOOL:self.success = iprot.readBool();else:iprot.skip(ftype)elif fid == 1:if ftype == TType.STRUCT:self.ex = TransactionServiceException()self.ex.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('markOrderAsOutOfStock_result')if self.success != None:oprot.writeFieldBegin('success', TType.BOOL, 0)oprot.writeBool(self.success)oprot.writeFieldEnd()if self.ex != None:oprot.writeFieldBegin('ex', TType.STRUCT, 1)self.ex.write(oprot)oprot.writeFieldEnd()oprot.writeFieldStop()oprot.writeStructEnd()def __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 markOrdersAsManifested_args:"""Attributes:- warehouseId- providerId"""thrift_spec = (None, # 0(1, TType.I64, 'warehouseId', None, None, ), # 1(2, TType.I64, 'providerId', None, None, ), # 2)def __init__(self, warehouseId=None, providerId=None,):self.warehouseId = warehouseIdself.providerId = providerIddef 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.warehouseId = iprot.readI64();else:iprot.skip(ftype)elif fid == 2:if ftype == TType.I64:self.providerId = 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('markOrdersAsManifested_args')if self.warehouseId != None:oprot.writeFieldBegin('warehouseId', TType.I64, 1)oprot.writeI64(self.warehouseId)oprot.writeFieldEnd()if self.providerId != None:oprot.writeFieldBegin('providerId', TType.I64, 2)oprot.writeI64(self.providerId)oprot.writeFieldEnd()oprot.writeFieldStop()oprot.writeStructEnd()def __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 markOrdersAsManifested_result:"""Attributes:- success- ex"""thrift_spec = ((0, TType.BOOL, 'success', None, None, ), # 0(1, TType.STRUCT, 'ex', (TransactionServiceException, TransactionServiceException.thrift_spec), None, ), # 1)def __init__(self, success=None, ex=None,):self.success = successself.ex = exdef 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.BOOL:self.success = iprot.readBool();else:iprot.skip(ftype)elif fid == 1:if ftype == TType.STRUCT:self.ex = TransactionServiceException()self.ex.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('markOrdersAsManifested_result')if self.success != None:oprot.writeFieldBegin('success', TType.BOOL, 0)oprot.writeBool(self.success)oprot.writeFieldEnd()if self.ex != None:oprot.writeFieldBegin('ex', TType.STRUCT, 1)self.ex.write(oprot)oprot.writeFieldEnd()oprot.writeFieldStop()oprot.writeStructEnd()def __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 markOrdersAsPickedUp_args:"""Attributes:- providerId- pickupDetails"""thrift_spec = (None, # 0(1, TType.I64, 'providerId', None, None, ), # 1(2, TType.MAP, 'pickupDetails', (TType.STRING,None,TType.STRING,None), None, ), # 2)def __init__(self, providerId=None, pickupDetails=None,):self.providerId = providerIdself.pickupDetails = pickupDetailsdef 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.providerId = iprot.readI64();else:iprot.skip(ftype)elif fid == 2:if ftype == TType.MAP:self.pickupDetails = {}(_ktype85, _vtype86, _size84 ) = iprot.readMapBegin()for _i88 in xrange(_size84):_key89 = iprot.readString();_val90 = iprot.readString();self.pickupDetails[_key89] = _val90iprot.readMapEnd()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('markOrdersAsPickedUp_args')if self.providerId != None:oprot.writeFieldBegin('providerId', TType.I64, 1)oprot.writeI64(self.providerId)oprot.writeFieldEnd()if self.pickupDetails != None:oprot.writeFieldBegin('pickupDetails', TType.MAP, 2)oprot.writeMapBegin(TType.STRING, TType.STRING, len(self.pickupDetails))for kiter91,viter92 in self.pickupDetails.items():oprot.writeString(kiter91)oprot.writeString(viter92)oprot.writeMapEnd()oprot.writeFieldEnd()oprot.writeFieldStop()oprot.writeStructEnd()def __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 markOrdersAsPickedUp_result:"""Attributes:- success- ex"""thrift_spec = ((0, TType.LIST, 'success', (TType.STRUCT,(Order, Order.thrift_spec)), None, ), # 0(1, TType.STRUCT, 'ex', (TransactionServiceException, TransactionServiceException.thrift_spec), None, ), # 1)def __init__(self, success=None, ex=None,):self.success = successself.ex = exdef 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 = [](_etype96, _size93) = iprot.readListBegin()for _i97 in xrange(_size93):_elem98 = Order()_elem98.read(iprot)self.success.append(_elem98)iprot.readListEnd()else:iprot.skip(ftype)elif fid == 1:if ftype == TType.STRUCT:self.ex = TransactionServiceException()self.ex.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('markOrdersAsPickedUp_result')if self.success != None:oprot.writeFieldBegin('success', TType.LIST, 0)oprot.writeListBegin(TType.STRUCT, len(self.success))for iter99 in self.success:iter99.write(oprot)oprot.writeListEnd()oprot.writeFieldEnd()if self.ex != None:oprot.writeFieldBegin('ex', TType.STRUCT, 1)self.ex.write(oprot)oprot.writeFieldEnd()oprot.writeFieldStop()oprot.writeStructEnd()def __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 markOrdersAsDelivered_args:"""Attributes:- providerId- deliveredOrders"""thrift_spec = (None, # 0(1, TType.I64, 'providerId', None, None, ), # 1(2, TType.MAP, 'deliveredOrders', (TType.STRING,None,TType.STRING,None), None, ), # 2)def __init__(self, providerId=None, deliveredOrders=None,):self.providerId = providerIdself.deliveredOrders = deliveredOrdersdef 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.providerId = iprot.readI64();else:iprot.skip(ftype)elif fid == 2:if ftype == TType.MAP:self.deliveredOrders = {}(_ktype101, _vtype102, _size100 ) = iprot.readMapBegin()for _i104 in xrange(_size100):_key105 = iprot.readString();_val106 = iprot.readString();self.deliveredOrders[_key105] = _val106iprot.readMapEnd()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('markOrdersAsDelivered_args')if self.providerId != None:oprot.writeFieldBegin('providerId', TType.I64, 1)oprot.writeI64(self.providerId)oprot.writeFieldEnd()if self.deliveredOrders != None:oprot.writeFieldBegin('deliveredOrders', TType.MAP, 2)oprot.writeMapBegin(TType.STRING, TType.STRING, len(self.deliveredOrders))for kiter107,viter108 in self.deliveredOrders.items():oprot.writeString(kiter107)oprot.writeString(viter108)oprot.writeMapEnd()oprot.writeFieldEnd()oprot.writeFieldStop()oprot.writeStructEnd()def __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 markOrdersAsDelivered_result:"""Attributes:- ex"""thrift_spec = (None, # 0(1, TType.STRUCT, 'ex', (TransactionServiceException, TransactionServiceException.thrift_spec), None, ), # 1)def __init__(self, ex=None,):self.ex = exdef 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.ex = TransactionServiceException()self.ex.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('markOrdersAsDelivered_result')if self.ex != None:oprot.writeFieldBegin('ex', TType.STRUCT, 1)self.ex.write(oprot)oprot.writeFieldEnd()oprot.writeFieldStop()oprot.writeStructEnd()def __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 markOrdersAsFailed_args:"""Attributes:- providerId- returnedOrders"""thrift_spec = (None, # 0(1, TType.I64, 'providerId', None, None, ), # 1(2, TType.MAP, 'returnedOrders', (TType.STRING,None,TType.STRING,None), None, ), # 2)def __init__(self, providerId=None, returnedOrders=None,):self.providerId = providerIdself.returnedOrders = returnedOrdersdef 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.providerId = iprot.readI64();else:iprot.skip(ftype)elif fid == 2:if ftype == TType.MAP:self.returnedOrders = {}(_ktype110, _vtype111, _size109 ) = iprot.readMapBegin()for _i113 in xrange(_size109):_key114 = iprot.readString();_val115 = iprot.readString();self.returnedOrders[_key114] = _val115iprot.readMapEnd()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('markOrdersAsFailed_args')if self.providerId != None:oprot.writeFieldBegin('providerId', TType.I64, 1)oprot.writeI64(self.providerId)oprot.writeFieldEnd()if self.returnedOrders != None:oprot.writeFieldBegin('returnedOrders', TType.MAP, 2)oprot.writeMapBegin(TType.STRING, TType.STRING, len(self.returnedOrders))for kiter116,viter117 in self.returnedOrders.items():oprot.writeString(kiter116)oprot.writeString(viter117)oprot.writeMapEnd()oprot.writeFieldEnd()oprot.writeFieldStop()oprot.writeStructEnd()def __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 markOrdersAsFailed_result:"""Attributes:- ex"""thrift_spec = (None, # 0(1, TType.STRUCT, 'ex', (TransactionServiceException, TransactionServiceException.thrift_spec), None, ), # 1)def __init__(self, ex=None,):self.ex = exdef 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.ex = TransactionServiceException()self.ex.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('markOrdersAsFailed_result')if self.ex != None:oprot.writeFieldBegin('ex', TType.STRUCT, 1)self.ex.write(oprot)oprot.writeFieldEnd()oprot.writeFieldStop()oprot.writeStructEnd()def __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 updateNonDeliveryReason_args:"""Attributes:- providerId- undeliveredOrders"""thrift_spec = (None, # 0(1, TType.I64, 'providerId', None, None, ), # 1(2, TType.MAP, 'undeliveredOrders', (TType.STRING,None,TType.STRING,None), None, ), # 2)def __init__(self, providerId=None, undeliveredOrders=None,):self.providerId = providerIdself.undeliveredOrders = undeliveredOrdersdef 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.providerId = iprot.readI64();else:iprot.skip(ftype)elif fid == 2:if ftype == TType.MAP:self.undeliveredOrders = {}(_ktype119, _vtype120, _size118 ) = iprot.readMapBegin()for _i122 in xrange(_size118):_key123 = iprot.readString();_val124 = iprot.readString();self.undeliveredOrders[_key123] = _val124iprot.readMapEnd()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('updateNonDeliveryReason_args')if self.providerId != None:oprot.writeFieldBegin('providerId', TType.I64, 1)oprot.writeI64(self.providerId)oprot.writeFieldEnd()if self.undeliveredOrders != None:oprot.writeFieldBegin('undeliveredOrders', TType.MAP, 2)oprot.writeMapBegin(TType.STRING, TType.STRING, len(self.undeliveredOrders))for kiter125,viter126 in self.undeliveredOrders.items():oprot.writeString(kiter125)oprot.writeString(viter126)oprot.writeMapEnd()oprot.writeFieldEnd()oprot.writeFieldStop()oprot.writeStructEnd()def __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 updateNonDeliveryReason_result:"""Attributes:- ex"""thrift_spec = (None, # 0(1, TType.STRUCT, 'ex', (TransactionServiceException, TransactionServiceException.thrift_spec), None, ), # 1)def __init__(self, ex=None,):self.ex = exdef 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.ex = TransactionServiceException()self.ex.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('updateNonDeliveryReason_result')if self.ex != None:oprot.writeFieldBegin('ex', TType.STRUCT, 1)self.ex.write(oprot)oprot.writeFieldEnd()oprot.writeFieldStop()oprot.writeStructEnd()def __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 getUndeliveredOrders_args:"""Attributes:- providerId- warehouseId"""thrift_spec = (None, # 0(1, TType.I64, 'providerId', None, None, ), # 1(2, TType.I64, 'warehouseId', None, None, ), # 2)def __init__(self, providerId=None, warehouseId=None,):self.providerId = providerIdself.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.providerId = iprot.readI64();else:iprot.skip(ftype)elif fid == 2: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('getUndeliveredOrders_args')if self.providerId != None:oprot.writeFieldBegin('providerId', TType.I64, 1)oprot.writeI64(self.providerId)oprot.writeFieldEnd()if self.warehouseId != None:oprot.writeFieldBegin('warehouseId', TType.I64, 2)oprot.writeI64(self.warehouseId)oprot.writeFieldEnd()oprot.writeFieldStop()oprot.writeStructEnd()def __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 getUndeliveredOrders_result:"""Attributes:- success"""thrift_spec = ((0, TType.LIST, 'success', (TType.STRUCT,(Order, Order.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 = [](_etype130, _size127) = iprot.readListBegin()for _i131 in xrange(_size127):_elem132 = Order()_elem132.read(iprot)self.success.append(_elem132)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('getUndeliveredOrders_result')if self.success != None:oprot.writeFieldBegin('success', TType.LIST, 0)oprot.writeListBegin(TType.STRUCT, len(self.success))for iter133 in self.success:iter133.write(oprot)oprot.writeListEnd()oprot.writeFieldEnd()oprot.writeFieldStop()oprot.writeStructEnd()def __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 getAlerts_args:"""Attributes:- orderId- valid"""thrift_spec = (None, # 0(1, TType.I64, 'orderId', None, None, ), # 1(2, TType.BOOL, 'valid', None, None, ), # 2)def __init__(self, orderId=None, valid=None,):self.orderId = orderIdself.valid = validdef 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)elif fid == 2:if ftype == TType.BOOL:self.valid = iprot.readBool();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('getAlerts_args')if self.orderId != None:oprot.writeFieldBegin('orderId', TType.I64, 1)oprot.writeI64(self.orderId)oprot.writeFieldEnd()if self.valid != None:oprot.writeFieldBegin('valid', TType.BOOL, 2)oprot.writeBool(self.valid)oprot.writeFieldEnd()oprot.writeFieldStop()oprot.writeStructEnd()def __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 getAlerts_result:"""Attributes:- success"""thrift_spec = ((0, TType.LIST, 'success', (TType.STRUCT,(Alert, Alert.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 = [](_etype137, _size134) = iprot.readListBegin()for _i138 in xrange(_size134):_elem139 = Alert()_elem139.read(iprot)self.success.append(_elem139)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('getAlerts_result')if self.success != None:oprot.writeFieldBegin('success', TType.LIST, 0)oprot.writeListBegin(TType.STRUCT, len(self.success))for iter140 in self.success:iter140.write(oprot)oprot.writeListEnd()oprot.writeFieldEnd()oprot.writeFieldStop()oprot.writeStructEnd()def __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 setAlert_args:"""Attributes:- orderId- unset- type- comment"""thrift_spec = (None, # 0(1, TType.I64, 'orderId', None, None, ), # 1(2, TType.BOOL, 'unset', None, None, ), # 2(3, TType.I64, 'type', None, None, ), # 3(4, TType.STRING, 'comment', None, None, ), # 4)def __init__(self, orderId=None, unset=None, type=None, comment=None,):self.orderId = orderIdself.unset = unsetself.type = typeself.comment = commentdef 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)elif fid == 2:if ftype == TType.BOOL:self.unset = iprot.readBool();else:iprot.skip(ftype)elif fid == 3:if ftype == TType.I64:self.type = iprot.readI64();else:iprot.skip(ftype)elif fid == 4:if ftype == TType.STRING:self.comment = 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('setAlert_args')if self.orderId != None:oprot.writeFieldBegin('orderId', TType.I64, 1)oprot.writeI64(self.orderId)oprot.writeFieldEnd()if self.unset != None:oprot.writeFieldBegin('unset', TType.BOOL, 2)oprot.writeBool(self.unset)oprot.writeFieldEnd()if self.type != None:oprot.writeFieldBegin('type', TType.I64, 3)oprot.writeI64(self.type)oprot.writeFieldEnd()if self.comment != None:oprot.writeFieldBegin('comment', TType.STRING, 4)oprot.writeString(self.comment)oprot.writeFieldEnd()oprot.writeFieldStop()oprot.writeStructEnd()def __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 setAlert_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('setAlert_result')oprot.writeFieldStop()oprot.writeStructEnd()def __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 getValidOrderCount_args: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('getValidOrderCount_args')oprot.writeFieldStop()oprot.writeStructEnd()def __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 getValidOrderCount_result:"""Attributes:- success"""thrift_spec = ((0, TType.I64, 'success', 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.I64:self.success = 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('getValidOrderCount_result')if self.success != None:oprot.writeFieldBegin('success', TType.I64, 0)oprot.writeI64(self.success)oprot.writeFieldEnd()oprot.writeFieldStop()oprot.writeStructEnd()def __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 getNoOfCustomersWithSuccessfulTransaction_args: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('getNoOfCustomersWithSuccessfulTransaction_args')oprot.writeFieldStop()oprot.writeStructEnd()def __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 getNoOfCustomersWithSuccessfulTransaction_result:"""Attributes:- success"""thrift_spec = ((0, TType.I64, 'success', 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.I64:self.success = 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('getNoOfCustomersWithSuccessfulTransaction_result')if self.success != None:oprot.writeFieldBegin('success', TType.I64, 0)oprot.writeI64(self.success)oprot.writeFieldEnd()oprot.writeFieldStop()oprot.writeStructEnd()def __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 getValidOrdersAmountRange_args: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('getValidOrdersAmountRange_args')oprot.writeFieldStop()oprot.writeStructEnd()def __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 getValidOrdersAmountRange_result:"""Attributes:- success"""thrift_spec = ((0, TType.LIST, 'success', (TType.DOUBLE,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 = [](_etype144, _size141) = iprot.readListBegin()for _i145 in xrange(_size141):_elem146 = iprot.readDouble();self.success.append(_elem146)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('getValidOrdersAmountRange_result')if self.success != None:oprot.writeFieldBegin('success', TType.LIST, 0)oprot.writeListBegin(TType.DOUBLE, len(self.success))for iter147 in self.success:oprot.writeDouble(iter147)oprot.writeListEnd()oprot.writeFieldEnd()oprot.writeFieldStop()oprot.writeStructEnd()def __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 getValidOrders_args:"""Attributes:- limit"""thrift_spec = (None, # 0(1, TType.I64, 'limit', None, None, ), # 1)def __init__(self, limit=None,):self.limit = limitdef 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.limit = 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('getValidOrders_args')if self.limit != None:oprot.writeFieldBegin('limit', TType.I64, 1)oprot.writeI64(self.limit)oprot.writeFieldEnd()oprot.writeFieldStop()oprot.writeStructEnd()def __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 getValidOrders_result:"""Attributes:- success"""thrift_spec = ((0, TType.LIST, 'success', (TType.STRUCT,(Order, Order.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 = [](_etype151, _size148) = iprot.readListBegin()for _i152 in xrange(_size148):_elem153 = Order()_elem153.read(iprot)self.success.append(_elem153)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('getValidOrders_result')if self.success != None:oprot.writeFieldBegin('success', TType.LIST, 0)oprot.writeListBegin(TType.STRUCT, len(self.success))for iter154 in self.success:iter154.write(oprot)oprot.writeListEnd()oprot.writeFieldEnd()oprot.writeFieldStop()oprot.writeStructEnd()def __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)