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

     Parameters:
      - providerId
     """
     pass
+  def getAllProviders(self, ):
+    """
+    Returns a list containing all the providers.
+    """
+    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.
       return result.success
     if result.lse != None:
       raise result.lse
     raise TApplicationException(TApplicationException.MISSING_RESULT, "getProvider failed: unknown result");
+  def getAllProviders(self, ):
+    """
+    Returns a list containing all the providers.
+    """
+    self.send_getAllProviders()
+    return self.recv_getAllProviders()
+  def send_getAllProviders(self, ):
+    self._oprot.writeMessageBegin('getAllProviders', TMessageType.CALL, self._seqid)
+    args = getAllProviders_args()
+    args.write(self._oprot)
+    self._oprot.writeMessageEnd()
+    self._oprot.trans.flush()
+  def recv_getAllProviders(self, ):
+    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+    if mtype == TMessageType.EXCEPTION:
+      x = TApplicationException()
+      x.read(self._iprot)
+      self._iprot.readMessageEnd()
+      raise x
+    result = getAllProviders_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, "getAllProviders 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["getAllProviders"] = Processor.process_getAllProviders
     self._processMap["getLogisticsEstimation"] = Processor.process_getLogisticsEstimation
     self._processMap["getLogisticsInfo"] = Processor.process_getLogisticsInfo
     self._processMap["getEmptyAWB"] = Processor.process_getEmptyAWB
     self._processMap["getShipmentInfo"] = Processor.process_getShipmentInfo
     oprot.writeMessageBegin("getProvider", TMessageType.REPLY, seqid)
     result.write(oprot)
     oprot.writeMessageEnd()
     oprot.trans.flush()
+  def process_getAllProviders(self, seqid, iprot, oprot):
+    args = getAllProviders_args()
+    args.read(iprot)
+    iprot.readMessageEnd()
+    result = getAllProviders_result()
+    try:
+      result.success = self._handler.getAllProviders()
+    except LogisticsServiceException, lse:
+      result.lse = lse
+    oprot.writeMessageBegin("getAllProviders", 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()
     return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
   def __ne__(self, other):
     return not (self == other)
+class getAllProviders_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))
+      return
+    iprot.readStructBegin()
+    while True:
+      (fname, ftype, fid) = iprot.readFieldBegin()
+      if ftype == TType.STOP:
+        break
+      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('getAllProviders_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 getAllProviders_result:
+  """
+  Attributes:
+   - success
+   - lse
+  """
+  thrift_spec = (
+    (0, TType.LIST, 'success', (TType.STRUCT,(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.LIST:
+          self.success = []
+          (_etype3, _size0) = iprot.readListBegin()
+          for _i4 in xrange(_size0):
+            _elem5 = Provider()
+            _elem5.read(iprot)
+            self.success.append(_elem5)
+          iprot.readListEnd()
+        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('getAllProviders_result')
+    if self.success != None:
+      oprot.writeFieldBegin('success', TType.LIST, 0)
+      oprot.writeListBegin(TType.STRUCT, len(self.success))
+      for iter6 in self.success:
+        iter6.write(oprot)
+      oprot.writeListEnd()
+      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
       if ftype == TType.STOP:
         break
       if fid == 0:
         if ftype == TType.LIST:
           self.success = []
-          (_etype3, _size0) = iprot.readListBegin()
+          (_etype10, _size7) = iprot.readListBegin()
-          for _i4 in xrange(_size0):
+          for _i11 in xrange(_size7):
-            _elem5 = AwbUpdate()
+            _elem12 = AwbUpdate()
-            _elem5.read(iprot)
+            _elem12.read(iprot)
-            self.success.append(_elem5)
+            self.success.append(_elem12)
           iprot.readListEnd()
         else:
           iprot.skip(ftype)
       elif fid == 1:
         if ftype == TType.STRUCT:
       return
     oprot.writeStructBegin('getShipmentInfo_result')
     if self.success != None:
       oprot.writeFieldBegin('success', TType.LIST, 0)
       oprot.writeListBegin(TType.STRUCT, len(self.success))
-      for iter6 in self.success:
+      for iter13 in self.success:
-        iter6.write(oprot)
+        iter13.write(oprot)
       oprot.writeListEnd()
       oprot.writeFieldEnd()
     if self.se != None:
       oprot.writeFieldBegin('se', TType.STRUCT, 1)
       self.se.write(oprot)

Subversion Repositories SmartDukaan

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