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

      - startDate
      - endDate
     """
     pass
+  def getPurchaseScansByGrnDate(self, startDate, endDate):
+    """
+    Returns the purchase scans between grn dates grouped by items for Purchase register reconciliation
+    Parameters:
+     - startDate
+     - endDate
+    """
+    pass
   def fetchScansPerInvoiceNumber(self, date):
     """
     Returns the invoices and the count of scans against on a given day.
     Parameters:
      - startDate
      - endDate
     """
     pass
+  def getCompleteMovementSerializedInventoryByScans(self, startDate, endDate):
+    """
+    Parameters:
+     - startDate
+     - endDate
+    """
+    pass
+  def getCompleteMovementNonSerializedInventoryByScans(self, startDate, endDate):
+    """
+    Parameters:
+     - startDate
+     - endDate
+    """
+    pass
   def scanfreebie(self, orderId, freebieItemId, freebieWarehouseId, scanType):
     """
     Parameters:
      - orderId
      - freebieItemId
     self._iprot.readMessageEnd()
     if result.success is not None:
       return result.success
     raise TApplicationException(TApplicationException.MISSING_RESULT, "getPurchaseScans failed: unknown result");
+  def getPurchaseScansByGrnDate(self, startDate, endDate):
+    """
+    Returns the purchase scans between grn dates grouped by items for Purchase register reconciliation
+    Parameters:
+     - startDate
+     - endDate
+    """
+    self.send_getPurchaseScansByGrnDate(startDate, endDate)
+    return self.recv_getPurchaseScansByGrnDate()
+  def send_getPurchaseScansByGrnDate(self, startDate, endDate):
+    self._oprot.writeMessageBegin('getPurchaseScansByGrnDate', TMessageType.CALL, self._seqid)
+    args = getPurchaseScansByGrnDate_args()
+    args.startDate = startDate
+    args.endDate = endDate
+    args.write(self._oprot)
+    self._oprot.writeMessageEnd()
+    self._oprot.trans.flush()
+  def recv_getPurchaseScansByGrnDate(self, ):
+    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+    if mtype == TMessageType.EXCEPTION:
+      x = TApplicationException()
+      x.read(self._iprot)
+      self._iprot.readMessageEnd()
+      raise x
+    result = getPurchaseScansByGrnDate_result()
+    result.read(self._iprot)
+    self._iprot.readMessageEnd()
+    if result.success is not None:
+      return result.success
+    raise TApplicationException(TApplicationException.MISSING_RESULT, "getPurchaseScansByGrnDate failed: unknown result");
   def fetchScansPerInvoiceNumber(self, date):
     """
     Returns the invoices and the count of scans against on a given day.
     Parameters:
     self._iprot.readMessageEnd()
     if result.success is not None:
       return result.success
     raise TApplicationException(TApplicationException.MISSING_RESULT, "getMovementSerializedInventoryByScans failed: unknown result");
+  def getCompleteMovementSerializedInventoryByScans(self, startDate, endDate):
+    """
+    Parameters:
+     - startDate
+     - endDate
+    """
+    self.send_getCompleteMovementSerializedInventoryByScans(startDate, endDate)
+    return self.recv_getCompleteMovementSerializedInventoryByScans()
+  def send_getCompleteMovementSerializedInventoryByScans(self, startDate, endDate):
+    self._oprot.writeMessageBegin('getCompleteMovementSerializedInventoryByScans', TMessageType.CALL, self._seqid)
+    args = getCompleteMovementSerializedInventoryByScans_args()
+    args.startDate = startDate
+    args.endDate = endDate
+    args.write(self._oprot)
+    self._oprot.writeMessageEnd()
+    self._oprot.trans.flush()
+  def recv_getCompleteMovementSerializedInventoryByScans(self, ):
+    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+    if mtype == TMessageType.EXCEPTION:
+      x = TApplicationException()
+      x.read(self._iprot)
+      self._iprot.readMessageEnd()
+      raise x
+    result = getCompleteMovementSerializedInventoryByScans_result()
+    result.read(self._iprot)
+    self._iprot.readMessageEnd()
+    if result.success is not None:
+      return result.success
+    raise TApplicationException(TApplicationException.MISSING_RESULT, "getCompleteMovementSerializedInventoryByScans failed: unknown result");
+  def getCompleteMovementNonSerializedInventoryByScans(self, startDate, endDate):
+    """
+    Parameters:
+     - startDate
+     - endDate
+    """
+    self.send_getCompleteMovementNonSerializedInventoryByScans(startDate, endDate)
+    return self.recv_getCompleteMovementNonSerializedInventoryByScans()
+  def send_getCompleteMovementNonSerializedInventoryByScans(self, startDate, endDate):
+    self._oprot.writeMessageBegin('getCompleteMovementNonSerializedInventoryByScans', TMessageType.CALL, self._seqid)
+    args = getCompleteMovementNonSerializedInventoryByScans_args()
+    args.startDate = startDate
+    args.endDate = endDate
+    args.write(self._oprot)
+    self._oprot.writeMessageEnd()
+    self._oprot.trans.flush()
+  def recv_getCompleteMovementNonSerializedInventoryByScans(self, ):
+    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+    if mtype == TMessageType.EXCEPTION:
+      x = TApplicationException()
+      x.read(self._iprot)
+      self._iprot.readMessageEnd()
+      raise x
+    result = getCompleteMovementNonSerializedInventoryByScans_result()
+    result.read(self._iprot)
+    self._iprot.readMessageEnd()
+    if result.success is not None:
+      return result.success
+    raise TApplicationException(TApplicationException.MISSING_RESULT, "getCompleteMovementNonSerializedInventoryByScans failed: unknown result");
   def scanfreebie(self, orderId, freebieItemId, freebieWarehouseId, scanType):
     """
     Parameters:
      - orderId
      - freebieItemId
     self._processMap["getItemNumbers"] = Processor.process_getItemNumbers
     self._processMap["getItemIds"] = Processor.process_getItemIds
     self._processMap["getInventoryItemsFromLastScanType"] = Processor.process_getInventoryItemsFromLastScanType
     self._processMap["getInventoryItemFromId"] = Processor.process_getInventoryItemFromId
     self._processMap["getPurchaseScans"] = Processor.process_getPurchaseScans
+    self._processMap["getPurchaseScansByGrnDate"] = Processor.process_getPurchaseScansByGrnDate
     self._processMap["fetchScansPerInvoiceNumber"] = Processor.process_fetchScansPerInvoiceNumber
     self._processMap["getInventoryItemFromOrder"] = Processor.process_getInventoryItemFromOrder
     self._processMap["getInventoryAge"] = Processor.process_getInventoryAge
     self._processMap["getInventoryScansForItem"] = Processor.process_getInventoryScansForItem
     self._processMap["getScanRecordsForSerialNumber"] = Processor.process_getScanRecordsForSerialNumber
     self._processMap["getHistoricNonSerializedInventoryByScans"] = Processor.process_getHistoricNonSerializedInventoryByScans
     self._processMap["scanForOursExternalSale"] = Processor.process_scanForOursExternalSale
     self._processMap["scanForOursExternalSaleReturn"] = Processor.process_scanForOursExternalSaleReturn
     self._processMap["getMovementNonSerializedInventoryByScans"] = Processor.process_getMovementNonSerializedInventoryByScans
     self._processMap["getMovementSerializedInventoryByScans"] = Processor.process_getMovementSerializedInventoryByScans
+    self._processMap["getCompleteMovementSerializedInventoryByScans"] = Processor.process_getCompleteMovementSerializedInventoryByScans
+    self._processMap["getCompleteMovementNonSerializedInventoryByScans"] = Processor.process_getCompleteMovementNonSerializedInventoryByScans
     self._processMap["scanfreebie"] = Processor.process_scanfreebie
     self._processMap["reshipfreebie"] = Processor.process_reshipfreebie
   def process(self, iprot, oprot):
     (name, type, seqid) = iprot.readMessageBegin()
     oprot.writeMessageBegin("getPurchaseScans", TMessageType.REPLY, seqid)
     result.write(oprot)
     oprot.writeMessageEnd()
     oprot.trans.flush()
+  def process_getPurchaseScansByGrnDate(self, seqid, iprot, oprot):
+    args = getPurchaseScansByGrnDate_args()
+    args.read(iprot)
+    iprot.readMessageEnd()
+    result = getPurchaseScansByGrnDate_result()
+    result.success = self._handler.getPurchaseScansByGrnDate(args.startDate, args.endDate)
+    oprot.writeMessageBegin("getPurchaseScansByGrnDate", TMessageType.REPLY, seqid)
+    result.write(oprot)
+    oprot.writeMessageEnd()
+    oprot.trans.flush()
   def process_fetchScansPerInvoiceNumber(self, seqid, iprot, oprot):
     args = fetchScansPerInvoiceNumber_args()
     args.read(iprot)
     iprot.readMessageEnd()
     result = fetchScansPerInvoiceNumber_result()
     oprot.writeMessageBegin("getMovementSerializedInventoryByScans", TMessageType.REPLY, seqid)
     result.write(oprot)
     oprot.writeMessageEnd()
     oprot.trans.flush()
+  def process_getCompleteMovementSerializedInventoryByScans(self, seqid, iprot, oprot):
+    args = getCompleteMovementSerializedInventoryByScans_args()
+    args.read(iprot)
+    iprot.readMessageEnd()
+    result = getCompleteMovementSerializedInventoryByScans_result()
+    result.success = self._handler.getCompleteMovementSerializedInventoryByScans(args.startDate, args.endDate)
+    oprot.writeMessageBegin("getCompleteMovementSerializedInventoryByScans", TMessageType.REPLY, seqid)
+    result.write(oprot)
+    oprot.writeMessageEnd()
+    oprot.trans.flush()
+  def process_getCompleteMovementNonSerializedInventoryByScans(self, seqid, iprot, oprot):
+    args = getCompleteMovementNonSerializedInventoryByScans_args()
+    args.read(iprot)
+    iprot.readMessageEnd()
+    result = getCompleteMovementNonSerializedInventoryByScans_result()
+    result.success = self._handler.getCompleteMovementNonSerializedInventoryByScans(args.startDate, args.endDate)
+    oprot.writeMessageBegin("getCompleteMovementNonSerializedInventoryByScans", TMessageType.REPLY, seqid)
+    result.write(oprot)
+    oprot.writeMessageEnd()
+    oprot.trans.flush()
   def process_scanfreebie(self, seqid, iprot, oprot):
     args = scanfreebie_args()
     args.read(iprot)
     iprot.readMessageEnd()
     result = scanfreebie_result()
     return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
   def __ne__(self, other):
     return not (self == other)
+class getPurchaseScansByGrnDate_args:
+  """
+  Attributes:
+   - startDate
+   - endDate
+  """
+  thrift_spec = (
+    None, # 0
+    (1, TType.I64, 'startDate', None, None, ), # 1
+    (2, TType.I64, 'endDate', None, None, ), # 2
+  )
+  def __init__(self, startDate=None, endDate=None,):
+    self.startDate = startDate
+    self.endDate = endDate
+  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.startDate = iprot.readI64();
+        else:
+          iprot.skip(ftype)
+      elif fid == 2:
+        if ftype == TType.I64:
+          self.endDate = 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('getPurchaseScansByGrnDate_args')
+    if self.startDate is not None:
+      oprot.writeFieldBegin('startDate', TType.I64, 1)
+      oprot.writeI64(self.startDate)
+      oprot.writeFieldEnd()
+    if self.endDate is not None:
+      oprot.writeFieldBegin('endDate', TType.I64, 2)
+      oprot.writeI64(self.endDate)
+      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 getPurchaseScansByGrnDate_result:
+  """
+  Attributes:
+   - success
+  """
+  thrift_spec = (
+    (0, TType.LIST, 'success', (TType.STRUCT,(DetailedPurchaseScan, DetailedPurchaseScan.thrift_spec)), None, ), # 0
+  )
+  def __init__(self, success=None,):
+    self.success = success
+  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 = []
+          (_etype31, _size28) = iprot.readListBegin()
+          for _i32 in xrange(_size28):
+            _elem33 = DetailedPurchaseScan()
+            _elem33.read(iprot)
+            self.success.append(_elem33)
+          iprot.readListEnd()
+        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('getPurchaseScansByGrnDate_result')
+    if self.success is not None:
+      oprot.writeFieldBegin('success', TType.LIST, 0)
+      oprot.writeListBegin(TType.STRUCT, len(self.success))
+      for iter34 in self.success:
+        iter34.write(oprot)
+      oprot.writeListEnd()
+      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 fetchScansPerInvoiceNumber_args:
   """
   Attributes:
    - date
   """
       if ftype == TType.STOP:
         break
       if fid == 0:
         if ftype == TType.LIST:
           self.success = []
-          (_etype31, _size28) = iprot.readListBegin()
+          (_etype38, _size35) = iprot.readListBegin()
-          for _i32 in xrange(_size28):
+          for _i39 in xrange(_size35):
-            _elem33 = InvoiceScan()
+            _elem40 = InvoiceScan()
-            _elem33.read(iprot)
+            _elem40.read(iprot)
-            self.success.append(_elem33)
+            self.success.append(_elem40)
           iprot.readListEnd()
         else:
           iprot.skip(ftype)
       else:
         iprot.skip(ftype)
       return
     oprot.writeStructBegin('fetchScansPerInvoiceNumber_result')
     if self.success is not None:
       oprot.writeFieldBegin('success', TType.LIST, 0)
       oprot.writeListBegin(TType.STRUCT, len(self.success))
-      for iter34 in self.success:
+      for iter41 in self.success:
-        iter34.write(oprot)
+        iter41.write(oprot)
       oprot.writeListEnd()
       oprot.writeFieldEnd()
     oprot.writeFieldStop()
     oprot.writeStructEnd()
       if ftype == TType.STOP:
         break
       if fid == 0:
         if ftype == TType.LIST:
           self.success = []
-          (_etype38, _size35) = iprot.readListBegin()
+          (_etype45, _size42) = iprot.readListBegin()
-          for _i39 in xrange(_size35):
+          for _i46 in xrange(_size42):
-            _elem40 = InventoryAge()
+            _elem47 = InventoryAge()
-            _elem40.read(iprot)
+            _elem47.read(iprot)
-            self.success.append(_elem40)
+            self.success.append(_elem47)
           iprot.readListEnd()
         else:
           iprot.skip(ftype)
       else:
         iprot.skip(ftype)
       return
     oprot.writeStructBegin('getInventoryAge_result')
     if self.success is not None:
       oprot.writeFieldBegin('success', TType.LIST, 0)
       oprot.writeListBegin(TType.STRUCT, len(self.success))
-      for iter41 in self.success:
+      for iter48 in self.success:
-        iter41.write(oprot)
+        iter48.write(oprot)
       oprot.writeListEnd()
       oprot.writeFieldEnd()
     oprot.writeFieldStop()
     oprot.writeStructEnd()
       if ftype == TType.STOP:
         break
       if fid == 0:
         if ftype == TType.LIST:
           self.success = []
-          (_etype45, _size42) = iprot.readListBegin()
+          (_etype52, _size49) = iprot.readListBegin()
-          for _i46 in xrange(_size42):
+          for _i53 in xrange(_size49):
-            _elem47 = Scan()
+            _elem54 = Scan()
-            _elem47.read(iprot)
+            _elem54.read(iprot)
-            self.success.append(_elem47)
+            self.success.append(_elem54)
           iprot.readListEnd()
         else:
           iprot.skip(ftype)
       else:
         iprot.skip(ftype)
       return
     oprot.writeStructBegin('getInventoryScansForItem_result')
     if self.success is not None:
       oprot.writeFieldBegin('success', TType.LIST, 0)
       oprot.writeListBegin(TType.STRUCT, len(self.success))
-      for iter48 in self.success:
+      for iter55 in self.success:
-        iter48.write(oprot)
+        iter55.write(oprot)
       oprot.writeListEnd()
       oprot.writeFieldEnd()
     oprot.writeFieldStop()
     oprot.writeStructEnd()
       if ftype == TType.STOP:
         break
       if fid == 0:
         if ftype == TType.LIST:
           self.success = []
-          (_etype52, _size49) = iprot.readListBegin()
+          (_etype59, _size56) = iprot.readListBegin()
-          for _i53 in xrange(_size49):
+          for _i60 in xrange(_size56):
-            _elem54 = Scan()
+            _elem61 = Scan()
-            _elem54.read(iprot)
+            _elem61.read(iprot)
-            self.success.append(_elem54)
+            self.success.append(_elem61)
           iprot.readListEnd()
         else:
           iprot.skip(ftype)
       else:
         iprot.skip(ftype)
       return
     oprot.writeStructBegin('getScanRecordsForSerialNumber_result')
     if self.success is not None:
       oprot.writeFieldBegin('success', TType.LIST, 0)
       oprot.writeListBegin(TType.STRUCT, len(self.success))
-      for iter55 in self.success:
+      for iter62 in self.success:
-        iter55.write(oprot)
+        iter62.write(oprot)
       oprot.writeListEnd()
       oprot.writeFieldEnd()
     oprot.writeFieldStop()
     oprot.writeStructEnd()
       if ftype == TType.STOP:
         break
       if fid == 1:
         if ftype == TType.LIST:
           self.saleReturnItems = []
-          (_etype59, _size56) = iprot.readListBegin()
+          (_etype66, _size63) = iprot.readListBegin()
-          for _i60 in xrange(_size56):
+          for _i67 in xrange(_size63):
-            _elem61 = InventoryItem()
+            _elem68 = InventoryItem()
-            _elem61.read(iprot)
+            _elem68.read(iprot)
-            self.saleReturnItems.append(_elem61)
+            self.saleReturnItems.append(_elem68)
           iprot.readListEnd()
         else:
           iprot.skip(ftype)
       elif fid == 2:
         if ftype == TType.I64:
       return
     oprot.writeStructBegin('scanForPurchaseReturn_args')
     if self.saleReturnItems is not None:
       oprot.writeFieldBegin('saleReturnItems', TType.LIST, 1)
       oprot.writeListBegin(TType.STRUCT, len(self.saleReturnItems))
-      for iter62 in self.saleReturnItems:
+      for iter69 in self.saleReturnItems:
-        iter62.write(oprot)
+        iter69.write(oprot)
       oprot.writeListEnd()
       oprot.writeFieldEnd()
     if self.vendorId is not None:
       oprot.writeFieldBegin('vendorId', TType.I64, 2)
       oprot.writeI64(self.vendorId)
       if ftype == TType.STOP:
         break
       if fid == 1:
         if ftype == TType.LIST:
           self.lostItems = []
-          (_etype66, _size63) = iprot.readListBegin()
+          (_etype73, _size70) = iprot.readListBegin()
-          for _i67 in xrange(_size63):
+          for _i74 in xrange(_size70):
-            _elem68 = InventoryItem()
+            _elem75 = InventoryItem()
-            _elem68.read(iprot)
+            _elem75.read(iprot)
-            self.lostItems.append(_elem68)
+            self.lostItems.append(_elem75)
           iprot.readListEnd()
         else:
           iprot.skip(ftype)
       elif fid == 2:
         if ftype == TType.I64:
       return
     oprot.writeStructBegin('scanForLostItem_args')
     if self.lostItems is not None:
       oprot.writeFieldBegin('lostItems', TType.LIST, 1)
       oprot.writeListBegin(TType.STRUCT, len(self.lostItems))
-      for iter69 in self.lostItems:
+      for iter76 in self.lostItems:
-        iter69.write(oprot)
+        iter76.write(oprot)
       oprot.writeListEnd()
       oprot.writeFieldEnd()
     if self.vendorId is not None:
       oprot.writeFieldBegin('vendorId', TType.I64, 2)
       oprot.writeI64(self.vendorId)
       if ftype == TType.STOP:
         break
       if fid == 0:
         if ftype == TType.LIST:
           self.success = []
-          (_etype73, _size70) = iprot.readListBegin()
+          (_etype80, _size77) = iprot.readListBegin()
-          for _i74 in xrange(_size70):
+          for _i81 in xrange(_size77):
-            _elem75 = InventoryAvailability()
+            _elem82 = InventoryAvailability()
-            _elem75.read(iprot)
+            _elem82.read(iprot)
-            self.success.append(_elem75)
+            self.success.append(_elem82)
           iprot.readListEnd()
         else:
           iprot.skip(ftype)
       else:
         iprot.skip(ftype)
       return
     oprot.writeStructBegin('getCurrentSerializedInventoryByScans_result')
     if self.success is not None:
       oprot.writeFieldBegin('success', TType.LIST, 0)
       oprot.writeListBegin(TType.STRUCT, len(self.success))
-      for iter76 in self.success:
+      for iter83 in self.success:
-        iter76.write(oprot)
+        iter83.write(oprot)
       oprot.writeListEnd()
       oprot.writeFieldEnd()
     oprot.writeFieldStop()
     oprot.writeStructEnd()
       if ftype == TType.STOP:
         break
       if fid == 0:
         if ftype == TType.LIST:
           self.success = []
-          (_etype80, _size77) = iprot.readListBegin()
+          (_etype87, _size84) = iprot.readListBegin()
-          for _i81 in xrange(_size77):
+          for _i88 in xrange(_size84):
-            _elem82 = InventoryAvailability()
+            _elem89 = InventoryAvailability()
-            _elem82.read(iprot)
+            _elem89.read(iprot)
-            self.success.append(_elem82)
+            self.success.append(_elem89)
           iprot.readListEnd()
         else:
           iprot.skip(ftype)
       else:
         iprot.skip(ftype)
       return
     oprot.writeStructBegin('getCurrentNonSerializedInventoryByScans_result')
     if self.success is not None:
       oprot.writeFieldBegin('success', TType.LIST, 0)
       oprot.writeListBegin(TType.STRUCT, len(self.success))
-      for iter83 in self.success:
+      for iter90 in self.success:
-        iter83.write(oprot)
+        iter90.write(oprot)
       oprot.writeListEnd()
       oprot.writeFieldEnd()
     oprot.writeFieldStop()
     oprot.writeStructEnd()
       if ftype == TType.STOP:
         break
       if fid == 0:
         if ftype == TType.LIST:
           self.success = []
-          (_etype87, _size84) = iprot.readListBegin()
+          (_etype94, _size91) = iprot.readListBegin()
-          for _i88 in xrange(_size84):
+          for _i95 in xrange(_size91):
-            _elem89 = InventoryAvailability()
+            _elem96 = InventoryAvailability()
-            _elem89.read(iprot)
+            _elem96.read(iprot)
-            self.success.append(_elem89)
+            self.success.append(_elem96)
           iprot.readListEnd()
         else:
           iprot.skip(ftype)
       else:
         iprot.skip(ftype)
       return
     oprot.writeStructBegin('getHistoricSerializedInventoryByScans_result')
     if self.success is not None:
       oprot.writeFieldBegin('success', TType.LIST, 0)
       oprot.writeListBegin(TType.STRUCT, len(self.success))
-      for iter90 in self.success:
+      for iter97 in self.success:
-        iter90.write(oprot)
+        iter97.write(oprot)
       oprot.writeListEnd()
       oprot.writeFieldEnd()
     oprot.writeFieldStop()
     oprot.writeStructEnd()
       if ftype == TType.STOP:
         break
       if fid == 0:
         if ftype == TType.LIST:
           self.success = []
-          (_etype94, _size91) = iprot.readListBegin()
+          (_etype101, _size98) = iprot.readListBegin()
-          for _i95 in xrange(_size91):
+          for _i102 in xrange(_size98):
-            _elem96 = InventoryAvailability()
+            _elem103 = InventoryAvailability()
-            _elem96.read(iprot)
+            _elem103.read(iprot)
-            self.success.append(_elem96)
+            self.success.append(_elem103)
           iprot.readListEnd()
         else:
           iprot.skip(ftype)
       else:
         iprot.skip(ftype)
       return
     oprot.writeStructBegin('getHistoricNonSerializedInventoryByScans_result')
     if self.success is not None:
       oprot.writeFieldBegin('success', TType.LIST, 0)
       oprot.writeListBegin(TType.STRUCT, len(self.success))
-      for iter97 in self.success:
+      for iter104 in self.success:
-        iter97.write(oprot)
+        iter104.write(oprot)
       oprot.writeListEnd()
       oprot.writeFieldEnd()
     oprot.writeFieldStop()
     oprot.writeStructEnd()
       if ftype == TType.STOP:
         break
       if fid == 0:
         if ftype == TType.LIST:
           self.success = []
-          (_etype101, _size98) = iprot.readListBegin()
+          (_etype108, _size105) = iprot.readListBegin()
-          for _i102 in xrange(_size98):
+          for _i109 in xrange(_size105):
-            _elem103 = InventoryMovement()
+            _elem110 = InventoryMovement()
-            _elem103.read(iprot)
+            _elem110.read(iprot)
-            self.success.append(_elem103)
+            self.success.append(_elem110)
           iprot.readListEnd()
         else:
           iprot.skip(ftype)
       else:
         iprot.skip(ftype)
       return
     oprot.writeStructBegin('getMovementNonSerializedInventoryByScans_result')
     if self.success is not None:
       oprot.writeFieldBegin('success', TType.LIST, 0)
       oprot.writeListBegin(TType.STRUCT, len(self.success))
-      for iter104 in self.success:
+      for iter111 in self.success:
-        iter104.write(oprot)
+        iter111.write(oprot)
       oprot.writeListEnd()
       oprot.writeFieldEnd()
     oprot.writeFieldStop()
     oprot.writeStructEnd()
       if ftype == TType.STOP:
         break
       if fid == 0:
         if ftype == TType.LIST:
           self.success = []
-          (_etype108, _size105) = iprot.readListBegin()
+          (_etype115, _size112) = iprot.readListBegin()
-          for _i109 in xrange(_size105):
+          for _i116 in xrange(_size112):
-            _elem110 = InventoryMovement()
+            _elem117 = InventoryMovement()
-            _elem110.read(iprot)
+            _elem117.read(iprot)
-            self.success.append(_elem110)
+            self.success.append(_elem117)
           iprot.readListEnd()
         else:
           iprot.skip(ftype)
       else:
         iprot.skip(ftype)
       return
     oprot.writeStructBegin('getMovementSerializedInventoryByScans_result')
     if self.success is not None:
       oprot.writeFieldBegin('success', TType.LIST, 0)
       oprot.writeListBegin(TType.STRUCT, len(self.success))
-      for iter111 in self.success:
+      for iter118 in self.success:
-        iter111.write(oprot)
+        iter118.write(oprot)
+      oprot.writeListEnd()
+      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 getCompleteMovementSerializedInventoryByScans_args:
+  """
+  Attributes:
+   - startDate
+   - endDate
+  """
+  thrift_spec = (
+    None, # 0
+    (1, TType.I64, 'startDate', None, None, ), # 1
+    (2, TType.I64, 'endDate', None, None, ), # 2
+  )
+  def __init__(self, startDate=None, endDate=None,):
+    self.startDate = startDate
+    self.endDate = endDate
+  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.startDate = iprot.readI64();
+        else:
+          iprot.skip(ftype)
+      elif fid == 2:
+        if ftype == TType.I64:
+          self.endDate = 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('getCompleteMovementSerializedInventoryByScans_args')
+    if self.startDate is not None:
+      oprot.writeFieldBegin('startDate', TType.I64, 1)
+      oprot.writeI64(self.startDate)
+      oprot.writeFieldEnd()
+    if self.endDate is not None:
+      oprot.writeFieldBegin('endDate', TType.I64, 2)
+      oprot.writeI64(self.endDate)
+      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 getCompleteMovementSerializedInventoryByScans_result:
+  """
+  Attributes:
+   - success
+  """
+  thrift_spec = (
+    (0, TType.LIST, 'success', (TType.STRUCT,(InventoryMovement, InventoryMovement.thrift_spec)), None, ), # 0
+  )
+  def __init__(self, success=None,):
+    self.success = success
+  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 = []
+          (_etype122, _size119) = iprot.readListBegin()
+          for _i123 in xrange(_size119):
+            _elem124 = InventoryMovement()
+            _elem124.read(iprot)
+            self.success.append(_elem124)
+          iprot.readListEnd()
+        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('getCompleteMovementSerializedInventoryByScans_result')
+    if self.success is not None:
+      oprot.writeFieldBegin('success', TType.LIST, 0)
+      oprot.writeListBegin(TType.STRUCT, len(self.success))
+      for iter125 in self.success:
+        iter125.write(oprot)
+      oprot.writeListEnd()
+      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 getCompleteMovementNonSerializedInventoryByScans_args:
+  """
+  Attributes:
+   - startDate
+   - endDate
+  """
+  thrift_spec = (
+    None, # 0
+    (1, TType.I64, 'startDate', None, None, ), # 1
+    (2, TType.I64, 'endDate', None, None, ), # 2
+  )
+  def __init__(self, startDate=None, endDate=None,):
+    self.startDate = startDate
+    self.endDate = endDate
+  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.startDate = iprot.readI64();
+        else:
+          iprot.skip(ftype)
+      elif fid == 2:
+        if ftype == TType.I64:
+          self.endDate = 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('getCompleteMovementNonSerializedInventoryByScans_args')
+    if self.startDate is not None:
+      oprot.writeFieldBegin('startDate', TType.I64, 1)
+      oprot.writeI64(self.startDate)
+      oprot.writeFieldEnd()
+    if self.endDate is not None:
+      oprot.writeFieldBegin('endDate', TType.I64, 2)
+      oprot.writeI64(self.endDate)
+      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 getCompleteMovementNonSerializedInventoryByScans_result:
+  """
+  Attributes:
+   - success
+  """
+  thrift_spec = (
+    (0, TType.LIST, 'success', (TType.STRUCT,(InventoryMovement, InventoryMovement.thrift_spec)), None, ), # 0
+  )
+  def __init__(self, success=None,):
+    self.success = success
+  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 = []
+          (_etype129, _size126) = iprot.readListBegin()
+          for _i130 in xrange(_size126):
+            _elem131 = InventoryMovement()
+            _elem131.read(iprot)
+            self.success.append(_elem131)
+          iprot.readListEnd()
+        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('getCompleteMovementNonSerializedInventoryByScans_result')
+    if self.success is not None:
+      oprot.writeFieldBegin('success', TType.LIST, 0)
+      oprot.writeListBegin(TType.STRUCT, len(self.success))
+      for iter132 in self.success:
+        iter132.write(oprot)
       oprot.writeListEnd()
       oprot.writeFieldEnd()
     oprot.writeFieldStop()
     oprot.writeStructEnd()

Subversion Repositories SmartDukaan

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