WebSVN – SmartDukaan – Diff – /trunk/PyProj/src/shop2020/thriftpy/utils/HelperService.py

 except:
   fastbinary = None
 class Iface:
-  def getLogisticsEstimation(self, itemId, location):
-    """
-    Parameters:
-     - itemId
-     - location
-    """
-    pass
   def sendMail(self, mail):
     """
     Parameters:
      - mail
     """
     self._iprot = self._oprot = iprot
     if oprot != None:
       self._oprot = oprot
     self._seqid = 0
-  def getLogisticsEstimation(self, itemId, location):
-    """
-    Parameters:
-     - itemId
-     - location
-    """
-    self.send_getLogisticsEstimation(itemId, location)
-    return self.recv_getLogisticsEstimation()
-  def send_getLogisticsEstimation(self, itemId, location):
-    self._oprot.writeMessageBegin('getLogisticsEstimation', TMessageType.CALL, self._seqid)
-    args = getLogisticsEstimation_args()
-    args.itemId = itemId
-    args.location = location
-    args.write(self._oprot)
-    self._oprot.writeMessageEnd()
-    self._oprot.trans.flush()
-  def recv_getLogisticsEstimation(self, ):
-    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
-    if mtype == TMessageType.EXCEPTION:
-      x = TApplicationException()
-      x.read(self._iprot)
-      self._iprot.readMessageEnd()
-      raise x
-    result = getLogisticsEstimation_result()
-    result.read(self._iprot)
-    self._iprot.readMessageEnd()
-    if result.success != None:
-      return result.success
-    if result.se != None:
-      raise result.se
-    raise TApplicationException(TApplicationException.MISSING_RESULT, "getLogisticsEstimation failed: unknown result");
   def sendMail(self, mail):
     """
     Parameters:
      - mail
     """
 class Processor(Iface, TProcessor):
   def __init__(self, handler):
     self._handler = handler
     self._processMap = {}
-    self._processMap["getLogisticsEstimation"] = Processor.process_getLogisticsEstimation
     self._processMap["sendMail"] = Processor.process_sendMail
     self._processMap["sendText"] = Processor.process_sendText
     self._processMap["addMessage"] = Processor.process_addMessage
     self._processMap["updateMessage"] = Processor.process_updateMessage
     self._processMap["getMessage"] = Processor.process_getMessage
       return
     else:
       self._processMap[name](self, seqid, iprot, oprot)
     return True
-  def process_getLogisticsEstimation(self, seqid, iprot, oprot):
-    args = getLogisticsEstimation_args()
-    args.read(iprot)
-    iprot.readMessageEnd()
-    result = getLogisticsEstimation_result()
-    try:
-      result.success = self._handler.getLogisticsEstimation(args.itemId, args.location)
-    except HelperServiceException, se:
-      result.se = se
-    oprot.writeMessageBegin("getLogisticsEstimation", TMessageType.REPLY, seqid)
-    result.write(oprot)
-    oprot.writeMessageEnd()
-    oprot.trans.flush()
   def process_sendMail(self, seqid, iprot, oprot):
     args = sendMail_args()
     args.read(iprot)
     iprot.readMessageEnd()
     result = sendMail_result()
     oprot.trans.flush()
 # HELPER FUNCTIONS AND STRUCTURES
-class getLogisticsEstimation_args:
-  """
-  Attributes:
-   - itemId
-   - location
-  """
-  thrift_spec = (
-    None, # 0
-    (1, TType.I64, 'itemId', None, None, ), # 1
-    (2, TType.MAP, 'location', (TType.STRING,None,TType.STRING,None), None, ), # 2
-  )
-  def __init__(self, itemId=None, location=None,):
-    self.itemId = itemId
-    self.location = location
-  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.itemId = iprot.readI64();
-        else:
-          iprot.skip(ftype)
-      elif fid == 2:
-        if ftype == TType.MAP:
-          self.location = {}
-          (_ktype15, _vtype16, _size14 ) = iprot.readMapBegin()
-          for _i18 in xrange(_size14):
-            _key19 = iprot.readString();
-            _val20 = iprot.readString();
-            self.location[_key19] = _val20
-          iprot.readMapEnd()
-        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('getLogisticsEstimation_args')
-    if self.itemId != None:
-      oprot.writeFieldBegin('itemId', TType.I64, 1)
-      oprot.writeI64(self.itemId)
-      oprot.writeFieldEnd()
-    if self.location != None:
-      oprot.writeFieldBegin('location', TType.MAP, 2)
-      oprot.writeMapBegin(TType.STRING, TType.STRING, len(self.location))
-      for kiter21,viter22 in self.location.items():
-        oprot.writeString(kiter21)
-        oprot.writeString(viter22)
-      oprot.writeMapEnd()
-      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_result:
-  """
-  Attributes:
-   - success
-   - se
-  """
-  thrift_spec = (
-    (0, TType.LIST, 'success', (TType.STRUCT,(ItemLogistics, ItemLogistics.thrift_spec)), None, ), # 0
-    (1, TType.STRUCT, 'se', (HelperServiceException, HelperServiceException.thrift_spec), None, ), # 1
-  )
-  def __init__(self, success=None, se=None,):
-    self.success = success
-    self.se = se
-  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 = []
-          (_etype26, _size23) = iprot.readListBegin()
-          for _i27 in xrange(_size23):
-            _elem28 = ItemLogistics()
-            _elem28.read(iprot)
-            self.success.append(_elem28)
-          iprot.readListEnd()
-        else:
-          iprot.skip(ftype)
-      elif fid == 1:
-        if ftype == TType.STRUCT:
-          self.se = HelperServiceException()
-          self.se.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('getLogisticsEstimation_result')
-    if self.success != None:
-      oprot.writeFieldBegin('success', TType.LIST, 0)
-      oprot.writeListBegin(TType.STRUCT, len(self.success))
-      for iter29 in self.success:
-        iter29.write(oprot)
-      oprot.writeListEnd()
-      oprot.writeFieldEnd()
-    if self.se != None:
-      oprot.writeFieldBegin('se', TType.STRUCT, 1)
-      self.se.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 sendMail_args:
   """
   Attributes:
    - mail
   """
         else:
           iprot.skip(ftype)
       elif fid == 2:
         if ftype == TType.MAP:
           self.params = {}
-          (_ktype31, _vtype32, _size30 ) = iprot.readMapBegin()
+          (_ktype15, _vtype16, _size14 ) = iprot.readMapBegin()
-          for _i34 in xrange(_size30):
+          for _i18 in xrange(_size14):
-            _key35 = iprot.readString();
+            _key19 = iprot.readString();
-            _val36 = iprot.readString();
+            _val20 = iprot.readString();
-            self.params[_key35] = _val36
+            self.params[_key19] = _val20
           iprot.readMapEnd()
         else:
           iprot.skip(ftype)
       else:
         iprot.skip(ftype)
       oprot.writeI64(self.id)
       oprot.writeFieldEnd()
     if self.params != None:
       oprot.writeFieldBegin('params', TType.MAP, 2)
       oprot.writeMapBegin(TType.STRING, TType.STRING, len(self.params))
-      for kiter37,viter38 in self.params.items():
+      for kiter21,viter22 in self.params.items():
-        oprot.writeString(kiter37)
+        oprot.writeString(kiter21)
-        oprot.writeString(viter38)
+        oprot.writeString(viter22)
       oprot.writeMapEnd()
       oprot.writeFieldEnd()
     oprot.writeFieldStop()
     oprot.writeStructEnd()

Subversion Repositories SmartDukaan

(root)/trunk/PyProj/src/shop2020/thriftpy/utils/HelperService.py – Rev 353 → 472