WebSVN – SmartDukaan – Diff – /trunk/PyProj/src/shop2020/thriftpy/model/v1/order/TransactionService.py

     Returns a map containing the number of risky orders keyed by item id. A risky order
     is defined as one whose shipping date is about to expire.
     """
     pass
+  def getOrdersForItemIds(self, itemIds):
+    """
+    Returns a list of all orders which have items with given id
+    Parameters:
+     - itemIds
+    """
+    pass
   def markOrderCancellationRequestReceived(self, orderId):
     """
     Mark order as cancellation request received. If customer sends request of cancellation of
     a particular order, this method will be called. It will just change status of the order
     depending on its current status. It also records the previous status, so that we can move
     self._iprot.readMessageEnd()
     if result.success is not None:
       return result.success
     raise TApplicationException(TApplicationException.MISSING_RESULT, "getItemWiseRiskyOrdersCount failed: unknown result");
+  def getOrdersForItemIds(self, itemIds):
+    """
+    Returns a list of all orders which have items with given id
+    Parameters:
+     - itemIds
+    """
+    self.send_getOrdersForItemIds(itemIds)
+    return self.recv_getOrdersForItemIds()
+  def send_getOrdersForItemIds(self, itemIds):
+    self._oprot.writeMessageBegin('getOrdersForItemIds', TMessageType.CALL, self._seqid)
+    args = getOrdersForItemIds_args()
+    args.itemIds = itemIds
+    args.write(self._oprot)
+    self._oprot.writeMessageEnd()
+    self._oprot.trans.flush()
+  def recv_getOrdersForItemIds(self, ):
+    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+    if mtype == TMessageType.EXCEPTION:
+      x = TApplicationException()
+      x.read(self._iprot)
+      self._iprot.readMessageEnd()
+      raise x
+    result = getOrdersForItemIds_result()
+    result.read(self._iprot)
+    self._iprot.readMessageEnd()
+    if result.success is not None:
+      return result.success
+    raise TApplicationException(TApplicationException.MISSING_RESULT, "getOrdersForItemIds failed: unknown result");
   def markOrderCancellationRequestReceived(self, orderId):
     """
     Mark order as cancellation request received. If customer sends request of cancellation of
     a particular order, this method will be called. It will just change status of the order
     depending on its current status. It also records the previous status, so that we can move
     self._processMap["addDelayReason"] = Processor.process_addDelayReason
     self._processMap["reconcileCodCollection"] = Processor.process_reconcileCodCollection
     self._processMap["getTransactionsRequiringExtraProcessing"] = Processor.process_getTransactionsRequiringExtraProcessing
     self._processMap["markTransactionAsProcessed"] = Processor.process_markTransactionAsProcessed
     self._processMap["getItemWiseRiskyOrdersCount"] = Processor.process_getItemWiseRiskyOrdersCount
+    self._processMap["getOrdersForItemIds"] = Processor.process_getOrdersForItemIds
     self._processMap["markOrderCancellationRequestReceived"] = Processor.process_markOrderCancellationRequestReceived
     self._processMap["markOrderCancellationRequestConfirmed"] = Processor.process_markOrderCancellationRequestConfirmed
     self._processMap["markOrderCancellationRequestDenied"] = Processor.process_markOrderCancellationRequestDenied
     self._processMap["markTransactionAsPaymentFlagRemoved"] = Processor.process_markTransactionAsPaymentFlagRemoved
     self._processMap["refundTransaction"] = Processor.process_refundTransaction
     oprot.writeMessageBegin("getItemWiseRiskyOrdersCount", TMessageType.REPLY, seqid)
     result.write(oprot)
     oprot.writeMessageEnd()
     oprot.trans.flush()
+  def process_getOrdersForItemIds(self, seqid, iprot, oprot):
+    args = getOrdersForItemIds_args()
+    args.read(iprot)
+    iprot.readMessageEnd()
+    result = getOrdersForItemIds_result()
+    result.success = self._handler.getOrdersForItemIds(args.itemIds)
+    oprot.writeMessageBegin("getOrdersForItemIds", TMessageType.REPLY, seqid)
+    result.write(oprot)
+    oprot.writeMessageEnd()
+    oprot.trans.flush()
   def process_markOrderCancellationRequestReceived(self, seqid, iprot, oprot):
     args = markOrderCancellationRequestReceived_args()
     args.read(iprot)
     iprot.readMessageEnd()
     result = markOrderCancellationRequestReceived_result()
       oprot.writeFieldEnd()
     oprot.writeFieldStop()
     oprot.writeStructEnd()
   def validate(self):
+    return
+  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 getOrdersForItemIds_args:
+  """
+  Attributes:
+   - itemIds
+  """
+  thrift_spec = (
+    None, # 0
+    (1, TType.LIST, 'itemIds', (TType.I64,None), None, ), # 1
+  )
+  def __init__(self, itemIds=None,):
+    self.itemIds = itemIds
+  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))
+      return
+    iprot.readStructBegin()
+    while True:
+      (fname, ftype, fid) = iprot.readFieldBegin()
+      if ftype == TType.STOP:
+        break
+      if fid == 1:
+        if ftype == TType.LIST:
+          self.itemIds = []
+          (_etype250, _size247) = iprot.readListBegin()
+          for _i251 in xrange(_size247):
+            _elem252 = iprot.readI64();
+            self.itemIds.append(_elem252)
+          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)))
+      return
+    oprot.writeStructBegin('getOrdersForItemIds_args')
+    if self.itemIds is not None:
+      oprot.writeFieldBegin('itemIds', TType.LIST, 1)
+      oprot.writeListBegin(TType.I64, len(self.itemIds))
+      for iter253 in self.itemIds:
+        oprot.writeI64(iter253)
+      oprot.writeListEnd()
+      oprot.writeFieldEnd()
+    oprot.writeFieldStop()
+    oprot.writeStructEnd()
+  def validate(self):
+    return
+  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 getOrdersForItemIds_result:
+  """
+  Attributes:
+   - success
+  """
+  thrift_spec = (
+    (0, TType.LIST, 'success', (TType.STRUCT,(Order, Order.thrift_spec)), None, ), # 0
+  )
+  def __init__(self, success=None,):
+    self.success = success
+  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))
+      return
+    iprot.readStructBegin()
+    while True:
+      (fname, ftype, fid) = iprot.readFieldBegin()
+      if ftype == TType.STOP:
+        break
+      if fid == 0:
+        if ftype == TType.LIST:
+          self.success = []
+          (_etype257, _size254) = iprot.readListBegin()
+          for _i258 in xrange(_size254):
+            _elem259 = Order()
+            _elem259.read(iprot)
+            self.success.append(_elem259)
+          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)))
+      return
+    oprot.writeStructBegin('getOrdersForItemIds_result')
+    if self.success is not None:
+      oprot.writeFieldBegin('success', TType.LIST, 0)
+      oprot.writeListBegin(TType.STRUCT, len(self.success))
+      for iter260 in self.success:
+        iter260.write(oprot)
+      oprot.writeListEnd()
+      oprot.writeFieldEnd()
+    oprot.writeFieldStop()
+    oprot.writeStructEnd()
+  def validate(self):
     return
   def __repr__(self):
     L = ['%s=%r' % (key, value)

Subversion Repositories SmartDukaan

(root)/trunk/PyProj/src/shop2020/thriftpy/model/v1/order/TransactionService.py – Rev 4285 → 4295