Rev 1113 | Rev 1135 | 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 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 changeOrderStatus(self, orderId, status, description):"""Parameters:- orderId- status- description"""passdef addBillingDetails(self, orderId, invoice_number, jacket_number, billed_by):"""Parameters:- orderId- invoice_number- jacket_number- billed_by"""passdef acceptOrder(self, orderId):"""Parameters:- orderId"""passdef billOrder(self, orderId):"""Parameters:- orderId"""passdef getOrdersForTransaction(self, transactionId):"""Parameters:- transactionId"""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 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 getAlerts(self, orderId, valid):"""Parameters:- orderId- valid"""passdef setAlert(self, orderId, unset, type, comment):"""Parameters:- orderId- unset- type- comment"""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 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 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, jacket_number, billed_by):"""Parameters:- orderId- invoice_number- jacket_number- billed_by"""self.send_addBillingDetails(orderId, invoice_number, jacket_number, billed_by)return self.recv_addBillingDetails()def send_addBillingDetails(self, orderId, invoice_number, jacket_number, billed_by):self._oprot.writeMessageBegin('addBillingDetails', TMessageType.CALL, self._seqid)args = addBillingDetails_args()args.orderId = orderIdargs.invoice_number = invoice_numberargs.jacket_number = jacket_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 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):"""Parameters:- transactionId"""self.send_getOrdersForTransaction(transactionId)return self.recv_getOrdersForTransaction()def send_getOrdersForTransaction(self, transactionId):self._oprot.writeMessageBegin('getOrdersForTransaction', TMessageType.CALL, self._seqid)args = getOrdersForTransaction_args()args.transactionId = transactionIdargs.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 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 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()returnclass 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["getAllOrders"] = Processor.process_getAllOrdersself._processMap["getOrdersByBillingDate"] = Processor.process_getOrdersByBillingDateself._processMap["changeOrderStatus"] = Processor.process_changeOrderStatusself._processMap["addBillingDetails"] = Processor.process_addBillingDetailsself._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["markOrdersAsManifested"] = Processor.process_markOrdersAsManifestedself._processMap["markOrdersAsPickedUp"] = Processor.process_markOrdersAsPickedUpself._processMap["markOrdersAsDelivered"] = Processor.process_markOrdersAsDeliveredself._processMap["getAlerts"] = Processor.process_getAlertsself._processMap["setAlert"] = Processor.process_setAlertdef 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_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_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.jacket_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_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)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_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_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()# 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 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 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- jacket_number- billed_by"""thrift_spec = (None, # 0(1, TType.I64, 'orderId', None, None, ), # 1(2, TType.STRING, 'invoice_number', None, None, ), # 2(3, TType.I64, 'jacket_number', None, None, ), # 3(4, TType.STRING, 'billed_by', None, None, ), # 4)def __init__(self, orderId=None, invoice_number=None, jacket_number=None, billed_by=None,):self.orderId = orderIdself.invoice_number = invoice_numberself.jacket_number = jacket_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.I64:self.jacket_number = iprot.readI64();else:iprot.skip(ftype)elif fid == 4: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.jacket_number != None:oprot.writeFieldBegin('jacket_number', TType.I64, 3)oprot.writeI64(self.jacket_number)oprot.writeFieldEnd()if self.billed_by != None:oprot.writeFieldBegin('billed_by', TType.STRING, 4)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 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"""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('getOrdersForTransaction_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 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 = [](_etype45, _size42) = iprot.readListBegin()for _i46 in xrange(_size42):_elem47 = Order()_elem47.read(iprot)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('getOrdersForTransaction_result')if self.success != None:oprot.writeFieldBegin('success', TType.LIST, 0)oprot.writeListBegin(TType.STRUCT, len(self.success))for iter48 in self.success:iter48.write(oprot)oprot.writeListEnd()oprot.writeFieldEnd()if self.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 = [](_etype52, _size49) = iprot.readListBegin()for _i53 in xrange(_size49):_elem54 = Order()_elem54.read(iprot)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('getOrdersForCustomer_result')if self.success != None:oprot.writeFieldBegin('success', TType.LIST, 0)oprot.writeListBegin(TType.STRUCT, len(self.success))for iter55 in self.success:iter55.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 = [](_etype59, _size56) = iprot.readListBegin()for _i60 in xrange(_size56):_elem61 = LineItem()_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('getLineItemsForOrder_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 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.I64,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 = {}(_ktype64, _vtype65, _size63 ) = iprot.readMapBegin()for _i67 in xrange(_size63):_key68 = iprot.readString();_val69 = iprot.readI64();self.pickupDetails[_key68] = _val69iprot.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.I64, len(self.pickupDetails))for kiter70,viter71 in self.pickupDetails.items():oprot.writeString(kiter70)oprot.writeI64(viter71)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 = [](_etype75, _size72) = iprot.readListBegin()for _i76 in xrange(_size72):_elem77 = Order()_elem77.read(iprot)self.success.append(_elem77)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 iter78 in self.success:iter78.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 = {}(_ktype80, _vtype81, _size79 ) = iprot.readMapBegin()for _i83 in xrange(_size79):_key84 = iprot.readString();_val85 = iprot.readString();self.deliveredOrders[_key84] = _val85iprot.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 kiter86,viter87 in self.deliveredOrders.items():oprot.writeString(kiter86)oprot.writeString(viter87)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 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 = [](_etype91, _size88) = iprot.readListBegin()for _i92 in xrange(_size88):_elem93 = Alert()_elem93.read(iprot)self.success.append(_elem93)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 iter94 in self.success:iter94.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)