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

     """
     Parameters:
      - id
     """
     self.send_getMessage(id)
-    self.recv_getMessage()
+    return self.recv_getMessage()
   def send_getMessage(self, id):
     self._oprot.writeMessageBegin('getMessage', TMessageType.CALL, self._seqid)
     args = getMessage_args()
     args.id = id
       self._iprot.readMessageEnd()
       raise x
     result = getMessage_result()
     result.read(self._iprot)
     self._iprot.readMessageEnd()
+    if result.success != None:
+      return result.success
     if result.se != None:
       raise result.se
-    return
+    raise TApplicationException(TApplicationException.MISSING_RESULT, "getMessage failed: unknown result");
   def getSubstitutedMessage(self, id, params):
     """
     Parameters:
      - id
      - params
     """
     self.send_getSubstitutedMessage(id, params)
-    self.recv_getSubstitutedMessage()
+    return self.recv_getSubstitutedMessage()
   def send_getSubstitutedMessage(self, id, params):
     self._oprot.writeMessageBegin('getSubstitutedMessage', TMessageType.CALL, self._seqid)
     args = getSubstitutedMessage_args()
     args.id = id
       self._iprot.readMessageEnd()
       raise x
     result = getSubstitutedMessage_result()
     result.read(self._iprot)
     self._iprot.readMessageEnd()
+    if result.success != None:
+      return result.success
     if result.se != None:
       raise result.se
-    return
+    raise TApplicationException(TApplicationException.MISSING_RESULT, "getSubstitutedMessage failed: unknown result");
 class Processor(Iface, TProcessor):
   def __init__(self, handler):
     self._handler = handler
     args = getMessage_args()
     args.read(iprot)
     iprot.readMessageEnd()
     result = getMessage_result()
     try:
-      self._handler.getMessage(args.id)
+      result.success = self._handler.getMessage(args.id)
     except HelperServiceException, se:
       result.se = se
     oprot.writeMessageBegin("getMessage", TMessageType.REPLY, seqid)
     result.write(oprot)
     oprot.writeMessageEnd()
     args = getSubstitutedMessage_args()
     args.read(iprot)
     iprot.readMessageEnd()
     result = getSubstitutedMessage_result()
     try:
-      self._handler.getSubstitutedMessage(args.id, args.params)
+      result.success = self._handler.getSubstitutedMessage(args.id, args.params)
     except HelperServiceException, se:
       result.se = se
     oprot.writeMessageBegin("getSubstitutedMessage", TMessageType.REPLY, seqid)
     result.write(oprot)
     oprot.writeMessageEnd()
         else:
           iprot.skip(ftype)
       elif fid == 2:
         if ftype == TType.MAP:
           self.location = {}
-          (_ktype8, _vtype9, _size7 ) = iprot.readMapBegin()
+          (_ktype15, _vtype16, _size14 ) = iprot.readMapBegin()
-          for _i11 in xrange(_size7):
+          for _i18 in xrange(_size14):
-            _key12 = iprot.readString();
+            _key19 = iprot.readString();
-            _val13 = iprot.readString();
+            _val20 = iprot.readString();
-            self.location[_key12] = _val13
+            self.location[_key19] = _val20
           iprot.readMapEnd()
         else:
           iprot.skip(ftype)
       else:
         iprot.skip(ftype)
       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 kiter14,viter15 in self.location.items():
+      for kiter21,viter22 in self.location.items():
-        oprot.writeString(kiter14)
+        oprot.writeString(kiter21)
-        oprot.writeString(viter15)
+        oprot.writeString(viter22)
       oprot.writeMapEnd()
       oprot.writeFieldEnd()
     oprot.writeFieldStop()
     oprot.writeStructEnd()
       if ftype == TType.STOP:
         break
       if fid == 0:
         if ftype == TType.LIST:
           self.success = []
-          (_etype19, _size16) = iprot.readListBegin()
+          (_etype26, _size23) = iprot.readListBegin()
-          for _i20 in xrange(_size16):
+          for _i27 in xrange(_size23):
-            _elem21 = ItemLogistics()
+            _elem28 = ItemLogistics()
-            _elem21.read(iprot)
+            _elem28.read(iprot)
-            self.success.append(_elem21)
+            self.success.append(_elem28)
           iprot.readListEnd()
         else:
           iprot.skip(ftype)
       elif fid == 1:
         if ftype == TType.STRUCT:
       return
     oprot.writeStructBegin('getLogisticsEstimation_result')
     if self.success != None:
       oprot.writeFieldBegin('success', TType.LIST, 0)
       oprot.writeListBegin(TType.STRUCT, len(self.success))
-      for iter22 in self.success:
+      for iter29 in self.success:
-        iter22.write(oprot)
+        iter29.write(oprot)
       oprot.writeListEnd()
       oprot.writeFieldEnd()
     if self.se != None:
       oprot.writeFieldBegin('se', TType.STRUCT, 1)
       self.se.write(oprot)
     return not (self == other)
 class getMessage_result:
   """
   Attributes:
+   - success
    - se
   """
   thrift_spec = (
-    None, # 0
+    (0, TType.STRUCT, 'success', (Message, Message.thrift_spec), None, ), # 0
     (1, TType.STRUCT, 'se', (HelperServiceException, HelperServiceException.thrift_spec), None, ), # 1
+  )
-  def __init__(self, se=None,):
+  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))
     iprot.readStructBegin()
     while True:
       (fname, ftype, fid) = iprot.readFieldBegin()
       if ftype == TType.STOP:
         break
-      if fid == 1:
+      if fid == 0:
+        if ftype == TType.STRUCT:
+          self.success = Message()
+          self.success.read(iprot)
+        else:
+          iprot.skip(ftype)
+      elif fid == 1:
         if ftype == TType.STRUCT:
           self.se = HelperServiceException()
           self.se.read(iprot)
         else:
           iprot.skip(ftype)
   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('getMessage_result')
+    if self.success != None:
+      oprot.writeFieldBegin('success', TType.STRUCT, 0)
+      self.success.write(oprot)
+      oprot.writeFieldEnd()
     if self.se != None:
       oprot.writeFieldBegin('se', TType.STRUCT, 1)
       self.se.write(oprot)
       oprot.writeFieldEnd()
     oprot.writeFieldStop()
         else:
           iprot.skip(ftype)
       elif fid == 2:
         if ftype == TType.MAP:
           self.params = {}
-          (_ktype24, _vtype25, _size23 ) = iprot.readMapBegin()
+          (_ktype31, _vtype32, _size30 ) = iprot.readMapBegin()
-          for _i27 in xrange(_size23):
+          for _i34 in xrange(_size30):
-            _key28 = iprot.readString();
+            _key35 = iprot.readString();
-            _val29 = iprot.readString();
+            _val36 = iprot.readString();
-            self.params[_key28] = _val29
+            self.params[_key35] = _val36
           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 kiter30,viter31 in self.params.items():
+      for kiter37,viter38 in self.params.items():
-        oprot.writeString(kiter30)
+        oprot.writeString(kiter37)
-        oprot.writeString(viter31)
+        oprot.writeString(viter38)
       oprot.writeMapEnd()
       oprot.writeFieldEnd()
     oprot.writeFieldStop()
     oprot.writeStructEnd()
     return not (self == other)
 class getSubstitutedMessage_result:
   """
   Attributes:
+   - success
    - se
   """
   thrift_spec = (
-    None, # 0
+    (0, TType.STRUCT, 'success', (Message, Message.thrift_spec), None, ), # 0
     (1, TType.STRUCT, 'se', (HelperServiceException, HelperServiceException.thrift_spec), None, ), # 1
+  )
-  def __init__(self, se=None,):
+  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))
     iprot.readStructBegin()
     while True:
       (fname, ftype, fid) = iprot.readFieldBegin()
       if ftype == TType.STOP:
         break
-      if fid == 1:
+      if fid == 0:
+        if ftype == TType.STRUCT:
+          self.success = Message()
+          self.success.read(iprot)
+        else:
+          iprot.skip(ftype)
+      elif fid == 1:
         if ftype == TType.STRUCT:
           self.se = HelperServiceException()
           self.se.read(iprot)
         else:
           iprot.skip(ftype)
   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('getSubstitutedMessage_result')
+    if self.success != None:
+      oprot.writeFieldBegin('success', TType.STRUCT, 0)
+      self.success.write(oprot)
+      oprot.writeFieldEnd()
     if self.se != None:
       oprot.writeFieldBegin('se', TType.STRUCT, 1)
       self.se.write(oprot)
       oprot.writeFieldEnd()
     oprot.writeFieldStop()

Subversion Repositories SmartDukaan

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