| Line 67... |
Line 67... |
| 67 |
- status
|
67 |
- status
|
| 68 |
- description
|
68 |
- description
|
| 69 |
"""
|
69 |
"""
|
| 70 |
pass
|
70 |
pass
|
| 71 |
|
71 |
|
| 72 |
def emailTransactionInfoToUser(self, transactionId):
|
72 |
def enqueueTransactionInfoEmail(self, transactionId):
|
| 73 |
"""
|
73 |
"""
|
| 74 |
Parameters:
|
74 |
Parameters:
|
| 75 |
- transactionId
|
75 |
- transactionId
|
| 76 |
"""
|
76 |
"""
|
| 77 |
pass
|
77 |
pass
|
| Line 527... |
Line 527... |
| 527 |
return result.success
|
527 |
return result.success
|
| 528 |
if result.ex != None:
|
528 |
if result.ex != None:
|
| 529 |
raise result.ex
|
529 |
raise result.ex
|
| 530 |
raise TApplicationException(TApplicationException.MISSING_RESULT, "changeTransactionStatus failed: unknown result");
|
530 |
raise TApplicationException(TApplicationException.MISSING_RESULT, "changeTransactionStatus failed: unknown result");
|
| 531 |
|
531 |
|
| 532 |
def emailTransactionInfoToUser(self, transactionId):
|
532 |
def enqueueTransactionInfoEmail(self, transactionId):
|
| 533 |
"""
|
533 |
"""
|
| 534 |
Parameters:
|
534 |
Parameters:
|
| 535 |
- transactionId
|
535 |
- transactionId
|
| 536 |
"""
|
536 |
"""
|
| 537 |
self.send_emailTransactionInfoToUser(transactionId)
|
537 |
self.send_enqueueTransactionInfoEmail(transactionId)
|
| 538 |
return self.recv_emailTransactionInfoToUser()
|
538 |
return self.recv_enqueueTransactionInfoEmail()
|
| 539 |
|
539 |
|
| 540 |
def send_emailTransactionInfoToUser(self, transactionId):
|
540 |
def send_enqueueTransactionInfoEmail(self, transactionId):
|
| 541 |
self._oprot.writeMessageBegin('emailTransactionInfoToUser', TMessageType.CALL, self._seqid)
|
541 |
self._oprot.writeMessageBegin('enqueueTransactionInfoEmail', TMessageType.CALL, self._seqid)
|
| 542 |
args = emailTransactionInfoToUser_args()
|
542 |
args = enqueueTransactionInfoEmail_args()
|
| 543 |
args.transactionId = transactionId
|
543 |
args.transactionId = transactionId
|
| 544 |
args.write(self._oprot)
|
544 |
args.write(self._oprot)
|
| 545 |
self._oprot.writeMessageEnd()
|
545 |
self._oprot.writeMessageEnd()
|
| 546 |
self._oprot.trans.flush()
|
546 |
self._oprot.trans.flush()
|
| 547 |
|
547 |
|
| 548 |
def recv_emailTransactionInfoToUser(self, ):
|
548 |
def recv_enqueueTransactionInfoEmail(self, ):
|
| 549 |
(fname, mtype, rseqid) = self._iprot.readMessageBegin()
|
549 |
(fname, mtype, rseqid) = self._iprot.readMessageBegin()
|
| 550 |
if mtype == TMessageType.EXCEPTION:
|
550 |
if mtype == TMessageType.EXCEPTION:
|
| 551 |
x = TApplicationException()
|
551 |
x = TApplicationException()
|
| 552 |
x.read(self._iprot)
|
552 |
x.read(self._iprot)
|
| 553 |
self._iprot.readMessageEnd()
|
553 |
self._iprot.readMessageEnd()
|
| 554 |
raise x
|
554 |
raise x
|
| 555 |
result = emailTransactionInfoToUser_result()
|
555 |
result = enqueueTransactionInfoEmail_result()
|
| 556 |
result.read(self._iprot)
|
556 |
result.read(self._iprot)
|
| 557 |
self._iprot.readMessageEnd()
|
557 |
self._iprot.readMessageEnd()
|
| 558 |
if result.success != None:
|
558 |
if result.success != None:
|
| 559 |
return result.success
|
559 |
return result.success
|
| 560 |
if result.ex != None:
|
560 |
if result.ex != None:
|
| 561 |
raise result.ex
|
561 |
raise result.ex
|
| 562 |
raise TApplicationException(TApplicationException.MISSING_RESULT, "emailTransactionInfoToUser failed: unknown result");
|
562 |
raise TApplicationException(TApplicationException.MISSING_RESULT, "enqueueTransactionInfoEmail failed: unknown result");
|
| 563 |
|
563 |
|
| 564 |
def getAllOrders(self, status, from_date, to_date, warehouse_id):
|
564 |
def getAllOrders(self, status, from_date, to_date, warehouse_id):
|
| 565 |
"""
|
565 |
"""
|
| 566 |
Parameters:
|
566 |
Parameters:
|
| 567 |
- status
|
567 |
- status
|
| Line 1376... |
Line 1376... |
| 1376 |
self._processMap["getTransaction"] = Processor.process_getTransaction
|
1376 |
self._processMap["getTransaction"] = Processor.process_getTransaction
|
| 1377 |
self._processMap["getTransactionsForCustomer"] = Processor.process_getTransactionsForCustomer
|
1377 |
self._processMap["getTransactionsForCustomer"] = Processor.process_getTransactionsForCustomer
|
| 1378 |
self._processMap["getTransactionsForShoppingCartId"] = Processor.process_getTransactionsForShoppingCartId
|
1378 |
self._processMap["getTransactionsForShoppingCartId"] = Processor.process_getTransactionsForShoppingCartId
|
| 1379 |
self._processMap["getTransactionStatus"] = Processor.process_getTransactionStatus
|
1379 |
self._processMap["getTransactionStatus"] = Processor.process_getTransactionStatus
|
| 1380 |
self._processMap["changeTransactionStatus"] = Processor.process_changeTransactionStatus
|
1380 |
self._processMap["changeTransactionStatus"] = Processor.process_changeTransactionStatus
|
| 1381 |
self._processMap["emailTransactionInfoToUser"] = Processor.process_emailTransactionInfoToUser
|
1381 |
self._processMap["enqueueTransactionInfoEmail"] = Processor.process_enqueueTransactionInfoEmail
|
| 1382 |
self._processMap["getAllOrders"] = Processor.process_getAllOrders
|
1382 |
self._processMap["getAllOrders"] = Processor.process_getAllOrders
|
| 1383 |
self._processMap["getOrdersByBillingDate"] = Processor.process_getOrdersByBillingDate
|
1383 |
self._processMap["getOrdersByBillingDate"] = Processor.process_getOrdersByBillingDate
|
| 1384 |
self._processMap["getReturnableOrdersForCustomer"] = Processor.process_getReturnableOrdersForCustomer
|
1384 |
self._processMap["getReturnableOrdersForCustomer"] = Processor.process_getReturnableOrdersForCustomer
|
| 1385 |
self._processMap["getCancellableOrdersForCustomer"] = Processor.process_getCancellableOrdersForCustomer
|
1385 |
self._processMap["getCancellableOrdersForCustomer"] = Processor.process_getCancellableOrdersForCustomer
|
| 1386 |
self._processMap["changeOrderStatus"] = Processor.process_changeOrderStatus
|
1386 |
self._processMap["changeOrderStatus"] = Processor.process_changeOrderStatus
|
| Line 1511... |
Line 1511... |
| 1511 |
oprot.writeMessageBegin("changeTransactionStatus", TMessageType.REPLY, seqid)
|
1511 |
oprot.writeMessageBegin("changeTransactionStatus", TMessageType.REPLY, seqid)
|
| 1512 |
result.write(oprot)
|
1512 |
result.write(oprot)
|
| 1513 |
oprot.writeMessageEnd()
|
1513 |
oprot.writeMessageEnd()
|
| 1514 |
oprot.trans.flush()
|
1514 |
oprot.trans.flush()
|
| 1515 |
|
1515 |
|
| 1516 |
def process_emailTransactionInfoToUser(self, seqid, iprot, oprot):
|
1516 |
def process_enqueueTransactionInfoEmail(self, seqid, iprot, oprot):
|
| 1517 |
args = emailTransactionInfoToUser_args()
|
1517 |
args = enqueueTransactionInfoEmail_args()
|
| 1518 |
args.read(iprot)
|
1518 |
args.read(iprot)
|
| 1519 |
iprot.readMessageEnd()
|
1519 |
iprot.readMessageEnd()
|
| 1520 |
result = emailTransactionInfoToUser_result()
|
1520 |
result = enqueueTransactionInfoEmail_result()
|
| 1521 |
try:
|
1521 |
try:
|
| 1522 |
result.success = self._handler.emailTransactionInfoToUser(args.transactionId)
|
1522 |
result.success = self._handler.enqueueTransactionInfoEmail(args.transactionId)
|
| 1523 |
except TransactionServiceException, ex:
|
1523 |
except TransactionServiceException, ex:
|
| 1524 |
result.ex = ex
|
1524 |
result.ex = ex
|
| 1525 |
oprot.writeMessageBegin("emailTransactionInfoToUser", TMessageType.REPLY, seqid)
|
1525 |
oprot.writeMessageBegin("enqueueTransactionInfoEmail", TMessageType.REPLY, seqid)
|
| 1526 |
result.write(oprot)
|
1526 |
result.write(oprot)
|
| 1527 |
oprot.writeMessageEnd()
|
1527 |
oprot.writeMessageEnd()
|
| 1528 |
oprot.trans.flush()
|
1528 |
oprot.trans.flush()
|
| 1529 |
|
1529 |
|
| 1530 |
def process_getAllOrders(self, seqid, iprot, oprot):
|
1530 |
def process_getAllOrders(self, seqid, iprot, oprot):
|
| Line 2744... |
Line 2744... |
| 2744 |
return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
|
2744 |
return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
|
| 2745 |
|
2745 |
|
| 2746 |
def __ne__(self, other):
|
2746 |
def __ne__(self, other):
|
| 2747 |
return not (self == other)
|
2747 |
return not (self == other)
|
| 2748 |
|
2748 |
|
| 2749 |
class emailTransactionInfoToUser_args:
|
2749 |
class enqueueTransactionInfoEmail_args:
|
| 2750 |
"""
|
2750 |
"""
|
| 2751 |
Attributes:
|
2751 |
Attributes:
|
| 2752 |
- transactionId
|
2752 |
- transactionId
|
| 2753 |
"""
|
2753 |
"""
|
| 2754 |
|
2754 |
|
| Line 2781... |
Line 2781... |
| 2781 |
|
2781 |
|
| 2782 |
def write(self, oprot):
|
2782 |
def write(self, oprot):
|
| 2783 |
if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
|
2783 |
if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
|
| 2784 |
oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
|
2784 |
oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
|
| 2785 |
return
|
2785 |
return
|
| 2786 |
oprot.writeStructBegin('emailTransactionInfoToUser_args')
|
2786 |
oprot.writeStructBegin('enqueueTransactionInfoEmail_args')
|
| 2787 |
if self.transactionId != None:
|
2787 |
if self.transactionId != None:
|
| 2788 |
oprot.writeFieldBegin('transactionId', TType.I64, 1)
|
2788 |
oprot.writeFieldBegin('transactionId', TType.I64, 1)
|
| 2789 |
oprot.writeI64(self.transactionId)
|
2789 |
oprot.writeI64(self.transactionId)
|
| 2790 |
oprot.writeFieldEnd()
|
2790 |
oprot.writeFieldEnd()
|
| 2791 |
oprot.writeFieldStop()
|
2791 |
oprot.writeFieldStop()
|
| Line 2800... |
Line 2800... |
| 2800 |
return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
|
2800 |
return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
|
| 2801 |
|
2801 |
|
| 2802 |
def __ne__(self, other):
|
2802 |
def __ne__(self, other):
|
| 2803 |
return not (self == other)
|
2803 |
return not (self == other)
|
| 2804 |
|
2804 |
|
| 2805 |
class emailTransactionInfoToUser_result:
|
2805 |
class enqueueTransactionInfoEmail_result:
|
| 2806 |
"""
|
2806 |
"""
|
| 2807 |
Attributes:
|
2807 |
Attributes:
|
| 2808 |
- success
|
2808 |
- success
|
| 2809 |
- ex
|
2809 |
- ex
|
| 2810 |
"""
|
2810 |
"""
|
| Line 2845... |
Line 2845... |
| 2845 |
|
2845 |
|
| 2846 |
def write(self, oprot):
|
2846 |
def write(self, oprot):
|
| 2847 |
if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
|
2847 |
if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
|
| 2848 |
oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
|
2848 |
oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
|
| 2849 |
return
|
2849 |
return
|
| 2850 |
oprot.writeStructBegin('emailTransactionInfoToUser_result')
|
2850 |
oprot.writeStructBegin('enqueueTransactionInfoEmail_result')
|
| 2851 |
if self.success != None:
|
2851 |
if self.success != None:
|
| 2852 |
oprot.writeFieldBegin('success', TType.BOOL, 0)
|
2852 |
oprot.writeFieldBegin('success', TType.BOOL, 0)
|
| 2853 |
oprot.writeBool(self.success)
|
2853 |
oprot.writeBool(self.success)
|
| 2854 |
oprot.writeFieldEnd()
|
2854 |
oprot.writeFieldEnd()
|
| 2855 |
if self.ex != None:
|
2855 |
if self.ex != None:
|