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

     pass
   def markOrdersAsManifested(self, warehouseId, providerId, cod):
     """
     Depending on the third parameter, marks either all prepaid or all cod orders BILLED by the
+    given warehouse and were picked up by the given provider as MANIFESTED.
+    Parameters:
+     - warehouseId
+     - providerId
+     - cod
+    """
+    pass
+  def markOrdersAsShippedFromWarehouse(self, warehouseId, providerId, cod):
+    """
+    Depending on the third parameter, marks either all prepaid or all cod orders BILLED and marked as MANIFESTED by the
     given warehouse and were picked up by the given provider as SHIPPED_FROM_WH.
     Parameters:
      - warehouseId
      - providerId
     raise TApplicationException(TApplicationException.MISSING_RESULT, "addBillingDetails failed: unknown result");
   def markOrdersAsManifested(self, warehouseId, providerId, cod):
     """
     Depending on the third parameter, marks either all prepaid or all cod orders BILLED by the
-    given warehouse and were picked up by the given provider as SHIPPED_FROM_WH.
+    given warehouse and were picked up by the given provider as MANIFESTED.
     Parameters:
      - warehouseId
      - providerId
      - cod
       return result.success
     if result.ex is not None:
       raise result.ex
     raise TApplicationException(TApplicationException.MISSING_RESULT, "markOrdersAsManifested failed: unknown result");
+  def markOrdersAsShippedFromWarehouse(self, warehouseId, providerId, cod):
+    """
+    Depending on the third parameter, marks either all prepaid or all cod orders BILLED and marked as MANIFESTED by the
+    given warehouse and were picked up by the given provider as SHIPPED_FROM_WH.
+    Parameters:
+     - warehouseId
+     - providerId
+     - cod
+    """
+    self.send_markOrdersAsShippedFromWarehouse(warehouseId, providerId, cod)
+    return self.recv_markOrdersAsShippedFromWarehouse()
+  def send_markOrdersAsShippedFromWarehouse(self, warehouseId, providerId, cod):
+    self._oprot.writeMessageBegin('markOrdersAsShippedFromWarehouse', TMessageType.CALL, self._seqid)
+    args = markOrdersAsShippedFromWarehouse_args()
+    args.warehouseId = warehouseId
+    args.providerId = providerId
+    args.cod = cod
+    args.write(self._oprot)
+    self._oprot.writeMessageEnd()
+    self._oprot.trans.flush()
+  def recv_markOrdersAsShippedFromWarehouse(self, ):
+    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+    if mtype == TMessageType.EXCEPTION:
+      x = TApplicationException()
+      x.read(self._iprot)
+      self._iprot.readMessageEnd()
+      raise x
+    result = markOrdersAsShippedFromWarehouse_result()
+    result.read(self._iprot)
+    self._iprot.readMessageEnd()
+    if result.success is not None:
+      return result.success
+    if result.ex is not None:
+      raise result.ex
+    raise TApplicationException(TApplicationException.MISSING_RESULT, "markOrdersAsShippedFromWarehouse 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.
     self._processMap["markOrderAsOutOfStock"] = Processor.process_markOrderAsOutOfStock
     self._processMap["verifyOrder"] = Processor.process_verifyOrder
     self._processMap["acceptOrder"] = Processor.process_acceptOrder
     self._processMap["addBillingDetails"] = Processor.process_addBillingDetails
     self._processMap["markOrdersAsManifested"] = Processor.process_markOrdersAsManifested
+    self._processMap["markOrdersAsShippedFromWarehouse"] = Processor.process_markOrdersAsShippedFromWarehouse
     self._processMap["markOrdersAsPickedUp"] = Processor.process_markOrdersAsPickedUp
     self._processMap["markOrdersAsDelivered"] = Processor.process_markOrdersAsDelivered
     self._processMap["markOrdersAsFailed"] = Processor.process_markOrdersAsFailed
     self._processMap["updateNonDeliveryReason"] = Processor.process_updateNonDeliveryReason
     self._processMap["getUndeliveredOrders"] = Processor.process_getUndeliveredOrders
     oprot.writeMessageBegin("markOrdersAsManifested", TMessageType.REPLY, seqid)
     result.write(oprot)
     oprot.writeMessageEnd()
     oprot.trans.flush()
+  def process_markOrdersAsShippedFromWarehouse(self, seqid, iprot, oprot):
+    args = markOrdersAsShippedFromWarehouse_args()
+    args.read(iprot)
+    iprot.readMessageEnd()
+    result = markOrdersAsShippedFromWarehouse_result()
+    try:
+      result.success = self._handler.markOrdersAsShippedFromWarehouse(args.warehouseId, args.providerId, args.cod)
+    except TransactionServiceException, ex:
+      result.ex = ex
+    oprot.writeMessageBegin("markOrdersAsShippedFromWarehouse", 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()
     if self.success is not None:
       oprot.writeFieldBegin('success', TType.BOOL, 0)
       oprot.writeBool(self.success)
       oprot.writeFieldEnd()
     if self.ex is not None:
+      oprot.writeFieldBegin('ex', TType.STRUCT, 1)
+      self.ex.write(oprot)
+      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 markOrdersAsShippedFromWarehouse_args:
+  """
+  Attributes:
+   - warehouseId
+   - providerId
+   - cod
+  """
+  thrift_spec = (
+    None, # 0
+    (1, TType.I64, 'warehouseId', None, None, ), # 1
+    (2, TType.I64, 'providerId', None, None, ), # 2
+    (3, TType.BOOL, 'cod', None, None, ), # 3
+  )
+  def __init__(self, warehouseId=None, providerId=None, cod=None,):
+    self.warehouseId = warehouseId
+    self.providerId = providerId
+    self.cod = cod
+  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.I64:
+          self.warehouseId = iprot.readI64();
+        else:
+          iprot.skip(ftype)
+      elif fid == 2:
+        if ftype == TType.I64:
+          self.providerId = iprot.readI64();
+        else:
+          iprot.skip(ftype)
+      elif fid == 3:
+        if ftype == TType.BOOL:
+          self.cod = 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)))
+      return
+    oprot.writeStructBegin('markOrdersAsShippedFromWarehouse_args')
+    if self.warehouseId is not None:
+      oprot.writeFieldBegin('warehouseId', TType.I64, 1)
+      oprot.writeI64(self.warehouseId)
+      oprot.writeFieldEnd()
+    if self.providerId is not None:
+      oprot.writeFieldBegin('providerId', TType.I64, 2)
+      oprot.writeI64(self.providerId)
+      oprot.writeFieldEnd()
+    if self.cod is not None:
+      oprot.writeFieldBegin('cod', TType.BOOL, 3)
+      oprot.writeBool(self.cod)
+      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 markOrdersAsShippedFromWarehouse_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 = success
+    self.ex = ex
+  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.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)))
+      return
+    oprot.writeStructBegin('markOrdersAsShippedFromWarehouse_result')
+    if self.success is not None:
+      oprot.writeFieldBegin('success', TType.BOOL, 0)
+      oprot.writeBool(self.success)
+      oprot.writeFieldEnd()
+    if self.ex is not None:
       oprot.writeFieldBegin('ex', TType.STRUCT, 1)
       self.ex.write(oprot)
       oprot.writeFieldEnd()
     oprot.writeFieldStop()
     oprot.writeStructEnd()

Subversion Repositories SmartDukaan

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