WebSVN – SmartDukaan – Diff – //trunk/PyProj/src/shop2020/thriftpy/warehouse/WarehouseService.py

     Parameters:
      - id
     """
     pass
-  def scanForTransfer(self, inventoryItems, type, transferLotId):
+  def scanForTransferOut(self, inventoryItems, type, transferLotId):
     """
     Parameters:
      - inventoryItems
      - type
      - transferLotId
     """
     pass
+  def scanForTransferIn(self, inventoryItems, type, transferLotId):
+    """
+    Parameters:
+     - inventoryItems
+     - type
+     - transferLotId
+    """
+    pass
+  def scanForOursThirdPartyReceive(self, inventoryItems, id):
+    """
+    Parameters:
+     - inventoryItems
+     - id
+    """
+    pass
 class Client(shop2020.thriftpy.generic.GenericService.Client, Iface):
   def __init__(self, iprot, oprot=None):
     shop2020.thriftpy.generic.GenericService.Client.__init__(self, iprot, oprot)
       return result.success
     if result.wex is not None:
       raise result.wex
     raise TApplicationException(TApplicationException.MISSING_RESULT, "updateTransferLotAfterItemReceive failed: unknown result");
-  def scanForTransfer(self, inventoryItems, type, transferLotId):
+  def scanForTransferOut(self, inventoryItems, type, transferLotId):
     """
     Parameters:
      - inventoryItems
      - type
      - transferLotId
     """
-    self.send_scanForTransfer(inventoryItems, type, transferLotId)
+    self.send_scanForTransferOut(inventoryItems, type, transferLotId)
-    self.recv_scanForTransfer()
+    self.recv_scanForTransferOut()
-  def send_scanForTransfer(self, inventoryItems, type, transferLotId):
+  def send_scanForTransferOut(self, inventoryItems, type, transferLotId):
-    self._oprot.writeMessageBegin('scanForTransfer', TMessageType.CALL, self._seqid)
+    self._oprot.writeMessageBegin('scanForTransferOut', TMessageType.CALL, self._seqid)
-    args = scanForTransfer_args()
+    args = scanForTransferOut_args()
     args.inventoryItems = inventoryItems
     args.type = type
     args.transferLotId = transferLotId
     args.write(self._oprot)
     self._oprot.writeMessageEnd()
     self._oprot.trans.flush()
-  def recv_scanForTransfer(self, ):
+  def recv_scanForTransferOut(self, ):
     (fname, mtype, rseqid) = self._iprot.readMessageBegin()
     if mtype == TMessageType.EXCEPTION:
       x = TApplicationException()
       x.read(self._iprot)
       self._iprot.readMessageEnd()
       raise x
+    result = scanForTransferOut_result()
+    result.read(self._iprot)
+    self._iprot.readMessageEnd()
+    if result.wex is not None:
+      raise result.wex
+    return
+  def scanForTransferIn(self, inventoryItems, type, transferLotId):
+    """
+    Parameters:
+     - inventoryItems
+     - type
+     - transferLotId
+    """
+    self.send_scanForTransferIn(inventoryItems, type, transferLotId)
+    self.recv_scanForTransferIn()
+  def send_scanForTransferIn(self, inventoryItems, type, transferLotId):
+    self._oprot.writeMessageBegin('scanForTransferIn', TMessageType.CALL, self._seqid)
+    args = scanForTransferIn_args()
+    args.inventoryItems = inventoryItems
+    args.type = type
+    args.transferLotId = transferLotId
+    args.write(self._oprot)
+    self._oprot.writeMessageEnd()
+    self._oprot.trans.flush()
+  def recv_scanForTransferIn(self, ):
+    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+    if mtype == TMessageType.EXCEPTION:
+      x = TApplicationException()
+      x.read(self._iprot)
+      self._iprot.readMessageEnd()
+      raise x
-    result = scanForTransfer_result()
+    result = scanForTransferIn_result()
+    result.read(self._iprot)
+    self._iprot.readMessageEnd()
+    if result.wex is not None:
+      raise result.wex
+    return
+  def scanForOursThirdPartyReceive(self, inventoryItems, id):
+    """
+    Parameters:
+     - inventoryItems
+     - id
+    """
+    self.send_scanForOursThirdPartyReceive(inventoryItems, id)
+    self.recv_scanForOursThirdPartyReceive()
+  def send_scanForOursThirdPartyReceive(self, inventoryItems, id):
+    self._oprot.writeMessageBegin('scanForOursThirdPartyReceive', TMessageType.CALL, self._seqid)
+    args = scanForOursThirdPartyReceive_args()
+    args.inventoryItems = inventoryItems
+    args.id = id
+    args.write(self._oprot)
+    self._oprot.writeMessageEnd()
+    self._oprot.trans.flush()
+  def recv_scanForOursThirdPartyReceive(self, ):
+    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+    if mtype == TMessageType.EXCEPTION:
+      x = TApplicationException()
+      x.read(self._iprot)
+      self._iprot.readMessageEnd()
+      raise x
+    result = scanForOursThirdPartyReceive_result()
     result.read(self._iprot)
     self._iprot.readMessageEnd()
     if result.wex is not None:
       raise result.wex
     return
     self._processMap["getTransferLotsByDate"] = Processor.process_getTransferLotsByDate
     self._processMap["getAllowedDestinationWarehousesForTransfer"] = Processor.process_getAllowedDestinationWarehousesForTransfer
     self._processMap["getItemsInTransferLot"] = Processor.process_getItemsInTransferLot
     self._processMap["markItemsAsReceivedForTransferLot"] = Processor.process_markItemsAsReceivedForTransferLot
     self._processMap["updateTransferLotAfterItemReceive"] = Processor.process_updateTransferLotAfterItemReceive
+    self._processMap["scanForTransferOut"] = Processor.process_scanForTransferOut
-    self._processMap["scanForTransfer"] = Processor.process_scanForTransfer
+    self._processMap["scanForTransferIn"] = Processor.process_scanForTransferIn
+    self._processMap["scanForOursThirdPartyReceive"] = Processor.process_scanForOursThirdPartyReceive
   def process(self, iprot, oprot):
     (name, type, seqid) = iprot.readMessageBegin()
     if name not in self._processMap:
       iprot.skip(TType.STRUCT)
     oprot.writeMessageBegin("updateTransferLotAfterItemReceive", TMessageType.REPLY, seqid)
     result.write(oprot)
     oprot.writeMessageEnd()
     oprot.trans.flush()
+  def process_scanForTransferOut(self, seqid, iprot, oprot):
+    args = scanForTransferOut_args()
+    args.read(iprot)
+    iprot.readMessageEnd()
+    result = scanForTransferOut_result()
+    try:
+      self._handler.scanForTransferOut(args.inventoryItems, args.type, args.transferLotId)
+    except WarehouseServiceException, wex:
+      result.wex = wex
+    oprot.writeMessageBegin("scanForTransferOut", TMessageType.REPLY, seqid)
+    result.write(oprot)
+    oprot.writeMessageEnd()
+    oprot.trans.flush()
-  def process_scanForTransfer(self, seqid, iprot, oprot):
+  def process_scanForTransferIn(self, seqid, iprot, oprot):
-    args = scanForTransfer_args()
+    args = scanForTransferIn_args()
+    args.read(iprot)
+    iprot.readMessageEnd()
+    result = scanForTransferIn_result()
+    try:
+      self._handler.scanForTransferIn(args.inventoryItems, args.type, args.transferLotId)
+    except WarehouseServiceException, wex:
+      result.wex = wex
+    oprot.writeMessageBegin("scanForTransferIn", TMessageType.REPLY, seqid)
+    result.write(oprot)
+    oprot.writeMessageEnd()
+    oprot.trans.flush()
+  def process_scanForOursThirdPartyReceive(self, seqid, iprot, oprot):
+    args = scanForOursThirdPartyReceive_args()
     args.read(iprot)
     iprot.readMessageEnd()
-    result = scanForTransfer_result()
+    result = scanForOursThirdPartyReceive_result()
     try:
-      self._handler.scanForTransfer(args.inventoryItems, args.type, args.transferLotId)
+      self._handler.scanForOursThirdPartyReceive(args.inventoryItems, args.id)
     except WarehouseServiceException, wex:
       result.wex = wex
-    oprot.writeMessageBegin("scanForTransfer", TMessageType.REPLY, seqid)
+    oprot.writeMessageBegin("scanForOursThirdPartyReceive", TMessageType.REPLY, seqid)
     result.write(oprot)
     oprot.writeMessageEnd()
     oprot.trans.flush()
     return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
   def __ne__(self, other):
     return not (self == other)
-class scanForTransfer_args:
+class scanForTransferOut_args:
   """
   Attributes:
    - inventoryItems
    - type
    - transferLotId
   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('scanForTransfer_args')
+    oprot.writeStructBegin('scanForTransferOut_args')
     if self.inventoryItems is not None:
       oprot.writeFieldBegin('inventoryItems', TType.LIST, 1)
       oprot.writeListBegin(TType.STRUCT, len(self.inventoryItems))
       for iter162 in self.inventoryItems:
         iter162.write(oprot)
     return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
   def __ne__(self, other):
     return not (self == other)
+class scanForTransferOut_result:
+  """
+  Attributes:
+   - wex
+  """
+  thrift_spec = (
+    None, # 0
+    (1, TType.STRUCT, 'wex', (WarehouseServiceException, WarehouseServiceException.thrift_spec), None, ), # 1
+  )
+  def __init__(self, wex=None,):
+    self.wex = wex
+  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.STRUCT:
+          self.wex = WarehouseServiceException()
+          self.wex.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('scanForTransferOut_result')
+    if self.wex is not None:
+      oprot.writeFieldBegin('wex', TType.STRUCT, 1)
+      self.wex.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 scanForTransferIn_args:
+  """
+  Attributes:
+   - inventoryItems
+   - type
+   - transferLotId
+  """
+  thrift_spec = (
+    None, # 0
+    (1, TType.LIST, 'inventoryItems', (TType.STRUCT,(InventoryItem, InventoryItem.thrift_spec)), None, ), # 1
+    (2, TType.I32, 'type', None, None, ), # 2
+    (3, TType.I64, 'transferLotId', None, None, ), # 3
+  )
+  def __init__(self, inventoryItems=None, type=None, transferLotId=None,):
+    self.inventoryItems = inventoryItems
+    self.type = type
+    self.transferLotId = transferLotId
+  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.LIST:
+          self.inventoryItems = []
+          (_etype166, _size163) = iprot.readListBegin()
+          for _i167 in xrange(_size163):
+            _elem168 = InventoryItem()
+            _elem168.read(iprot)
+            self.inventoryItems.append(_elem168)
+          iprot.readListEnd()
+        else:
+          iprot.skip(ftype)
+      elif fid == 2:
+        if ftype == TType.I32:
+          self.type = iprot.readI32();
+        else:
+          iprot.skip(ftype)
+      elif fid == 3:
+        if ftype == TType.I64:
+          self.transferLotId = 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('scanForTransferIn_args')
+    if self.inventoryItems is not None:
+      oprot.writeFieldBegin('inventoryItems', TType.LIST, 1)
+      oprot.writeListBegin(TType.STRUCT, len(self.inventoryItems))
+      for iter169 in self.inventoryItems:
+        iter169.write(oprot)
+      oprot.writeListEnd()
+      oprot.writeFieldEnd()
+    if self.type is not None:
+      oprot.writeFieldBegin('type', TType.I32, 2)
+      oprot.writeI32(self.type)
+      oprot.writeFieldEnd()
+    if self.transferLotId is not None:
+      oprot.writeFieldBegin('transferLotId', TType.I64, 3)
+      oprot.writeI64(self.transferLotId)
+      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 scanForTransfer_result:
+class scanForTransferIn_result:
+  """
+  Attributes:
+   - wex
+  """
+  thrift_spec = (
+    None, # 0
+    (1, TType.STRUCT, 'wex', (WarehouseServiceException, WarehouseServiceException.thrift_spec), None, ), # 1
+  )
+  def __init__(self, wex=None,):
+    self.wex = wex
+  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.STRUCT:
+          self.wex = WarehouseServiceException()
+          self.wex.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('scanForTransferIn_result')
+    if self.wex is not None:
+      oprot.writeFieldBegin('wex', TType.STRUCT, 1)
+      self.wex.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 scanForOursThirdPartyReceive_args:
+  """
+  Attributes:
+   - inventoryItems
+   - id
+  """
+  thrift_spec = (
+    None, # 0
+    (1, TType.LIST, 'inventoryItems', (TType.STRUCT,(InventoryItem, InventoryItem.thrift_spec)), None, ), # 1
+    (2, TType.I64, 'id', None, None, ), # 2
+  )
+  def __init__(self, inventoryItems=None, id=None,):
+    self.inventoryItems = inventoryItems
+    self.id = id
+  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.LIST:
+          self.inventoryItems = []
+          (_etype173, _size170) = iprot.readListBegin()
+          for _i174 in xrange(_size170):
+            _elem175 = InventoryItem()
+            _elem175.read(iprot)
+            self.inventoryItems.append(_elem175)
+          iprot.readListEnd()
+        else:
+          iprot.skip(ftype)
+      elif fid == 2:
+        if ftype == TType.I64:
+          self.id = 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('scanForOursThirdPartyReceive_args')
+    if self.inventoryItems is not None:
+      oprot.writeFieldBegin('inventoryItems', TType.LIST, 1)
+      oprot.writeListBegin(TType.STRUCT, len(self.inventoryItems))
+      for iter176 in self.inventoryItems:
+        iter176.write(oprot)
+      oprot.writeListEnd()
+      oprot.writeFieldEnd()
+    if self.id is not None:
+      oprot.writeFieldBegin('id', TType.I64, 2)
+      oprot.writeI64(self.id)
+      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 scanForOursThirdPartyReceive_result:
   """
   Attributes:
    - wex
   """
   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('scanForTransfer_result')
+    oprot.writeStructBegin('scanForOursThirdPartyReceive_result')
     if self.wex is not None:
       oprot.writeFieldBegin('wex', TType.STRUCT, 1)
       self.wex.write(oprot)
       oprot.writeFieldEnd()
     oprot.writeFieldStop()

Subversion Repositories SmartDukaan

(root)//trunk/PyProj/src/shop2020/thriftpy/warehouse/WarehouseService.py – Rev 7410 → 7459