Subversion Repositories SmartDukaan

Rev

Rev 6857 | Rev 7281 | Go to most recent revision | Show entire file | Ignore whitespace | Details | Blame | Last modification | View Log | RSS feed

Rev 6857 Rev 7149
Line 449... Line 449...
449
    pass
449
    pass
450
 
450
 
451
  def getNonZeroItemStockPurchaseParams(self, ):
451
  def getNonZeroItemStockPurchaseParams(self, ):
452
    pass
452
    pass
453
 
453
 
-
 
454
  def getBillableInventoryAndPendingOrders(self, ):
-
 
455
    """
-
 
456
    Returns a list of inventory stock for items for which there are pending orders or have billable inventory.
-
 
457
    """
-
 
458
    pass
-
 
459
 
454
 
460
 
455
class Client(shop2020.thriftpy.generic.GenericService.Client, Iface):
461
class Client(shop2020.thriftpy.generic.GenericService.Client, Iface):
456
  def __init__(self, iprot, oprot=None):
462
  def __init__(self, iprot, oprot=None):
457
    shop2020.thriftpy.generic.GenericService.Client.__init__(self, iprot, oprot)
463
    shop2020.thriftpy.generic.GenericService.Client.__init__(self, iprot, oprot)
458
 
464
 
Line 2062... Line 2068...
2062
    self._iprot.readMessageEnd()
2068
    self._iprot.readMessageEnd()
2063
    if result.success is not None:
2069
    if result.success is not None:
2064
      return result.success
2070
      return result.success
2065
    raise TApplicationException(TApplicationException.MISSING_RESULT, "getNonZeroItemStockPurchaseParams failed: unknown result");
2071
    raise TApplicationException(TApplicationException.MISSING_RESULT, "getNonZeroItemStockPurchaseParams failed: unknown result");
2066
 
2072
 
-
 
2073
  def getBillableInventoryAndPendingOrders(self, ):
-
 
2074
    """
-
 
2075
    Returns a list of inventory stock for items for which there are pending orders or have billable inventory.
-
 
2076
    """
-
 
2077
    self.send_getBillableInventoryAndPendingOrders()
-
 
2078
    return self.recv_getBillableInventoryAndPendingOrders()
-
 
2079
 
-
 
2080
  def send_getBillableInventoryAndPendingOrders(self, ):
-
 
2081
    self._oprot.writeMessageBegin('getBillableInventoryAndPendingOrders', TMessageType.CALL, self._seqid)
-
 
2082
    args = getBillableInventoryAndPendingOrders_args()
-
 
2083
    args.write(self._oprot)
-
 
2084
    self._oprot.writeMessageEnd()
-
 
2085
    self._oprot.trans.flush()
-
 
2086
 
-
 
2087
  def recv_getBillableInventoryAndPendingOrders(self, ):
-
 
2088
    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
-
 
2089
    if mtype == TMessageType.EXCEPTION:
-
 
2090
      x = TApplicationException()
-
 
2091
      x.read(self._iprot)
-
 
2092
      self._iprot.readMessageEnd()
-
 
2093
      raise x
-
 
2094
    result = getBillableInventoryAndPendingOrders_result()
-
 
2095
    result.read(self._iprot)
-
 
2096
    self._iprot.readMessageEnd()
-
 
2097
    if result.success is not None:
-
 
2098
      return result.success
-
 
2099
    raise TApplicationException(TApplicationException.MISSING_RESULT, "getBillableInventoryAndPendingOrders failed: unknown result");
-
 
2100
 
2067
 
2101
 
2068
class Processor(shop2020.thriftpy.generic.GenericService.Processor, Iface, TProcessor):
2102
class Processor(shop2020.thriftpy.generic.GenericService.Processor, Iface, TProcessor):
2069
  def __init__(self, handler):
2103
  def __init__(self, handler):
2070
    shop2020.thriftpy.generic.GenericService.Processor.__init__(self, handler)
2104
    shop2020.thriftpy.generic.GenericService.Processor.__init__(self, handler)
2071
    self._processMap["addWarehouse"] = Processor.process_addWarehouse
2105
    self._processMap["addWarehouse"] = Processor.process_addWarehouse
Line 2115... Line 2149...
2115
    self._processMap["updateItemStockPurchaseParams"] = Processor.process_updateItemStockPurchaseParams
2149
    self._processMap["updateItemStockPurchaseParams"] = Processor.process_updateItemStockPurchaseParams
2116
    self._processMap["getItemStockPurchaseParams"] = Processor.process_getItemStockPurchaseParams
2150
    self._processMap["getItemStockPurchaseParams"] = Processor.process_getItemStockPurchaseParams
2117
    self._processMap["addOosStatusForItem"] = Processor.process_addOosStatusForItem
2151
    self._processMap["addOosStatusForItem"] = Processor.process_addOosStatusForItem
2118
    self._processMap["getOosStatusesForXDaysForItem"] = Processor.process_getOosStatusesForXDaysForItem
2152
    self._processMap["getOosStatusesForXDaysForItem"] = Processor.process_getOosStatusesForXDaysForItem
2119
    self._processMap["getNonZeroItemStockPurchaseParams"] = Processor.process_getNonZeroItemStockPurchaseParams
2153
    self._processMap["getNonZeroItemStockPurchaseParams"] = Processor.process_getNonZeroItemStockPurchaseParams
-
 
2154
    self._processMap["getBillableInventoryAndPendingOrders"] = Processor.process_getBillableInventoryAndPendingOrders
2120
 
2155
 
2121
  def process(self, iprot, oprot):
2156
  def process(self, iprot, oprot):
2122
    (name, type, seqid) = iprot.readMessageBegin()
2157
    (name, type, seqid) = iprot.readMessageBegin()
2123
    if name not in self._processMap:
2158
    if name not in self._processMap:
2124
      iprot.skip(TType.STRUCT)
2159
      iprot.skip(TType.STRUCT)
Line 2736... Line 2771...
2736
    oprot.writeMessageBegin("getNonZeroItemStockPurchaseParams", TMessageType.REPLY, seqid)
2771
    oprot.writeMessageBegin("getNonZeroItemStockPurchaseParams", TMessageType.REPLY, seqid)
2737
    result.write(oprot)
2772
    result.write(oprot)
2738
    oprot.writeMessageEnd()
2773
    oprot.writeMessageEnd()
2739
    oprot.trans.flush()
2774
    oprot.trans.flush()
2740
 
2775
 
-
 
2776
  def process_getBillableInventoryAndPendingOrders(self, seqid, iprot, oprot):
-
 
2777
    args = getBillableInventoryAndPendingOrders_args()
-
 
2778
    args.read(iprot)
-
 
2779
    iprot.readMessageEnd()
-
 
2780
    result = getBillableInventoryAndPendingOrders_result()
-
 
2781
    result.success = self._handler.getBillableInventoryAndPendingOrders()
-
 
2782
    oprot.writeMessageBegin("getBillableInventoryAndPendingOrders", TMessageType.REPLY, seqid)
-
 
2783
    result.write(oprot)
-
 
2784
    oprot.writeMessageEnd()
-
 
2785
    oprot.trans.flush()
-
 
2786
 
2741
 
2787
 
2742
# HELPER FUNCTIONS AND STRUCTURES
2788
# HELPER FUNCTIONS AND STRUCTURES
2743
 
2789
 
2744
class addWarehouse_args:
2790
class addWarehouse_args:
2745
  """
2791
  """
Line 9223... Line 9269...
9223
      oprot.writeListEnd()
9269
      oprot.writeListEnd()
9224
      oprot.writeFieldEnd()
9270
      oprot.writeFieldEnd()
9225
    oprot.writeFieldStop()
9271
    oprot.writeFieldStop()
9226
    oprot.writeStructEnd()
9272
    oprot.writeStructEnd()
9227
 
9273
 
-
 
9274
  def validate(self):
-
 
9275
    return
-
 
9276
 
-
 
9277
 
-
 
9278
  def __repr__(self):
-
 
9279
    L = ['%s=%r' % (key, value)
-
 
9280
      for key, value in self.__dict__.iteritems()]
-
 
9281
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
-
 
9282
 
-
 
9283
  def __eq__(self, other):
-
 
9284
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
 
9285
 
-
 
9286
  def __ne__(self, other):
-
 
9287
    return not (self == other)
-
 
9288
 
-
 
9289
class getBillableInventoryAndPendingOrders_args:
-
 
9290
 
-
 
9291
  thrift_spec = (
-
 
9292
  )
-
 
9293
 
-
 
9294
  def read(self, iprot):
-
 
9295
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
-
 
9296
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
-
 
9297
      return
-
 
9298
    iprot.readStructBegin()
-
 
9299
    while True:
-
 
9300
      (fname, ftype, fid) = iprot.readFieldBegin()
-
 
9301
      if ftype == TType.STOP:
-
 
9302
        break
-
 
9303
      else:
-
 
9304
        iprot.skip(ftype)
-
 
9305
      iprot.readFieldEnd()
-
 
9306
    iprot.readStructEnd()
-
 
9307
 
-
 
9308
  def write(self, oprot):
-
 
9309
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
-
 
9310
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
-
 
9311
      return
-
 
9312
    oprot.writeStructBegin('getBillableInventoryAndPendingOrders_args')
-
 
9313
    oprot.writeFieldStop()
-
 
9314
    oprot.writeStructEnd()
-
 
9315
 
-
 
9316
  def validate(self):
-
 
9317
    return
-
 
9318
 
-
 
9319
 
-
 
9320
  def __repr__(self):
-
 
9321
    L = ['%s=%r' % (key, value)
-
 
9322
      for key, value in self.__dict__.iteritems()]
-
 
9323
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
-
 
9324
 
-
 
9325
  def __eq__(self, other):
-
 
9326
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
 
9327
 
-
 
9328
  def __ne__(self, other):
-
 
9329
    return not (self == other)
-
 
9330
 
-
 
9331
class getBillableInventoryAndPendingOrders_result:
-
 
9332
  """
-
 
9333
  Attributes:
-
 
9334
   - success
-
 
9335
  """
-
 
9336
 
-
 
9337
  thrift_spec = (
-
 
9338
    (0, TType.LIST, 'success', (TType.STRUCT,(AvailableAndReservedStock, AvailableAndReservedStock.thrift_spec)), None, ), # 0
-
 
9339
  )
-
 
9340
 
-
 
9341
  def __init__(self, success=None,):
-
 
9342
    self.success = success
-
 
9343
 
-
 
9344
  def read(self, iprot):
-
 
9345
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
-
 
9346
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
-
 
9347
      return
-
 
9348
    iprot.readStructBegin()
-
 
9349
    while True:
-
 
9350
      (fname, ftype, fid) = iprot.readFieldBegin()
-
 
9351
      if ftype == TType.STOP:
-
 
9352
        break
-
 
9353
      if fid == 0:
-
 
9354
        if ftype == TType.LIST:
-
 
9355
          self.success = []
-
 
9356
          (_etype210, _size207) = iprot.readListBegin()
-
 
9357
          for _i211 in xrange(_size207):
-
 
9358
            _elem212 = AvailableAndReservedStock()
-
 
9359
            _elem212.read(iprot)
-
 
9360
            self.success.append(_elem212)
-
 
9361
          iprot.readListEnd()
-
 
9362
        else:
-
 
9363
          iprot.skip(ftype)
-
 
9364
      else:
-
 
9365
        iprot.skip(ftype)
-
 
9366
      iprot.readFieldEnd()
-
 
9367
    iprot.readStructEnd()
-
 
9368
 
-
 
9369
  def write(self, oprot):
-
 
9370
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
-
 
9371
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
-
 
9372
      return
-
 
9373
    oprot.writeStructBegin('getBillableInventoryAndPendingOrders_result')
-
 
9374
    if self.success is not None:
-
 
9375
      oprot.writeFieldBegin('success', TType.LIST, 0)
-
 
9376
      oprot.writeListBegin(TType.STRUCT, len(self.success))
-
 
9377
      for iter213 in self.success:
-
 
9378
        iter213.write(oprot)
-
 
9379
      oprot.writeListEnd()
-
 
9380
      oprot.writeFieldEnd()
-
 
9381
    oprot.writeFieldStop()
-
 
9382
    oprot.writeStructEnd()
-
 
9383
 
9228
  def validate(self):
9384
  def validate(self):
9229
    return
9385
    return
9230
 
9386
 
9231
 
9387
 
9232
  def __repr__(self):
9388
  def __repr__(self):