WebSVN – SmartDukaan – Diff – /trunk/PyProj/src/shop2020/thriftpy/logistics/LogisticsService.py

 except:
   fastbinary = None
 class Iface:
+  def getProvider(self, providerId):
+    """
+    Returns a provider for a given provider ID. Throws an exception if none found.
+    Parameters:
+     - providerId
+    """
+    pass
   def getLogisticsEstimation(self, itemId, destination_pin):
     """
     Returns a LogisticsInfo structure w/o an airway bill number. Use this method during the estimation phase.
     Raises an exception if this pincode is not allocated to any warehouse zone or provider. Also, if the pincode
     is allocated to a warehouse zone but there are no actual warehouses in that zone, an exception is raised.
     self._iprot = self._oprot = iprot
     if oprot != None:
       self._oprot = oprot
     self._seqid = 0
+  def getProvider(self, providerId):
+    """
+    Returns a provider for a given provider ID. Throws an exception if none found.
+    Parameters:
+     - providerId
+    """
+    self.send_getProvider(providerId)
+    return self.recv_getProvider()
+  def send_getProvider(self, providerId):
+    self._oprot.writeMessageBegin('getProvider', TMessageType.CALL, self._seqid)
+    args = getProvider_args()
+    args.providerId = providerId
+    args.write(self._oprot)
+    self._oprot.writeMessageEnd()
+    self._oprot.trans.flush()
+  def recv_getProvider(self, ):
+    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+    if mtype == TMessageType.EXCEPTION:
+      x = TApplicationException()
+      x.read(self._iprot)
+      self._iprot.readMessageEnd()
+      raise x
+    result = getProvider_result()
+    result.read(self._iprot)
+    self._iprot.readMessageEnd()
+    if result.success != None:
+      return result.success
+    if result.lse != None:
+      raise result.lse
+    raise TApplicationException(TApplicationException.MISSING_RESULT, "getProvider failed: unknown result");
   def getLogisticsEstimation(self, itemId, destination_pin):
     """
     Returns a LogisticsInfo structure w/o an airway bill number. Use this method during the estimation phase.
     Raises an exception if this pincode is not allocated to any warehouse zone or provider. Also, if the pincode
     is allocated to a warehouse zone but there are no actual warehouses in that zone, an exception is raised.
 class Processor(Iface, TProcessor):
   def __init__(self, handler):
     self._handler = handler
     self._processMap = {}
+    self._processMap["getProvider"] = Processor.process_getProvider
     self._processMap["getLogisticsEstimation"] = Processor.process_getLogisticsEstimation
     self._processMap["getLogisticsInfo"] = Processor.process_getLogisticsInfo
     self._processMap["getEmptyAWB"] = Processor.process_getEmptyAWB
     self._processMap["getShipmentInfo"] = Processor.process_getShipmentInfo
       return
     else:
       self._processMap[name](self, seqid, iprot, oprot)
     return True
+  def process_getProvider(self, seqid, iprot, oprot):
+    args = getProvider_args()
+    args.read(iprot)
+    iprot.readMessageEnd()
+    result = getProvider_result()
+    try:
+      result.success = self._handler.getProvider(args.providerId)
+    except LogisticsServiceException, lse:
+      result.lse = lse
+    oprot.writeMessageBegin("getProvider", TMessageType.REPLY, seqid)
+    result.write(oprot)
+    oprot.writeMessageEnd()
+    oprot.trans.flush()
   def process_getLogisticsEstimation(self, seqid, iprot, oprot):
     args = getLogisticsEstimation_args()
     args.read(iprot)
     iprot.readMessageEnd()
     result = getLogisticsEstimation_result()
     oprot.trans.flush()
 # HELPER FUNCTIONS AND STRUCTURES
+class getProvider_args:
+  """
+  Attributes:
+   - providerId
+  """
+  thrift_spec = (
+    None, # 0
+    (1, TType.I64, 'providerId', None, None, ), # 1
+  )
+  def __init__(self, providerId=None,):
+    self.providerId = providerId
+  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.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)))
+      return
+    oprot.writeStructBegin('getProvider_args')
+    if self.providerId != None:
+      oprot.writeFieldBegin('providerId', TType.I64, 1)
+      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 getProvider_result:
+  """
+  Attributes:
+   - success
+   - lse
+  """
+  thrift_spec = (
+    (0, TType.STRUCT, 'success', (Provider, Provider.thrift_spec), None, ), # 0
+    (1, TType.STRUCT, 'lse', (LogisticsServiceException, LogisticsServiceException.thrift_spec), None, ), # 1
+  )
+  def __init__(self, success=None, lse=None,):
+    self.success = success
+    self.lse = lse
+  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.STRUCT:
+          self.success = Provider()
+          self.success.read(iprot)
+        else:
+          iprot.skip(ftype)
+      elif fid == 1:
+        if ftype == TType.STRUCT:
+          self.lse = LogisticsServiceException()
+          self.lse.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('getProvider_result')
+    if self.success != None:
+      oprot.writeFieldBegin('success', TType.STRUCT, 0)
+      self.success.write(oprot)
+      oprot.writeFieldEnd()
+    if self.lse != None:
+      oprot.writeFieldBegin('lse', TType.STRUCT, 1)
+      self.lse.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 getLogisticsEstimation_args:
   """
   Attributes:
    - itemId
    - destination_pin

Subversion Repositories SmartDukaan

(root)/trunk/PyProj/src/shop2020/thriftpy/logistics/LogisticsService.py – Rev 647 → 669