Subversion Repositories SmartDukaan

Rev

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

Rev 9762 Rev 10050
Line 603... Line 603...
603
     - warehouseId
603
     - warehouseId
604
     - source
604
     - source
605
    """
605
    """
606
    pass
606
    pass
607
 
607
 
-
 
608
  def addOrUpdateFlipkartInventorySnapshot(self, flipkartInventorySnapshot):
-
 
609
    """
-
 
610
    Parameters:
-
 
611
     - flipkartInventorySnapshot
-
 
612
    """
-
 
613
    pass
-
 
614
 
-
 
615
  def getFlipkartInventorySnapshot(self, ):
-
 
616
    pass
-
 
617
 
608
 
618
 
609
class Client(shop2020.thriftpy.generic.GenericService.Client, Iface):
619
class Client(shop2020.thriftpy.generic.GenericService.Client, Iface):
610
  def __init__(self, iprot, oprot=None):
620
  def __init__(self, iprot, oprot=None):
611
    shop2020.thriftpy.generic.GenericService.Client.__init__(self, iprot, oprot)
621
    shop2020.thriftpy.generic.GenericService.Client.__init__(self, iprot, oprot)
612
 
622
 
Line 2859... Line 2869...
2859
    self._iprot.readMessageEnd()
2869
    self._iprot.readMessageEnd()
2860
    if result.success is not None:
2870
    if result.success is not None:
2861
      return result.success
2871
      return result.success
2862
    raise TApplicationException(TApplicationException.MISSING_RESULT, "getHoldInventoryDetails failed: unknown result");
2872
    raise TApplicationException(TApplicationException.MISSING_RESULT, "getHoldInventoryDetails failed: unknown result");
2863
 
2873
 
-
 
2874
  def addOrUpdateFlipkartInventorySnapshot(self, flipkartInventorySnapshot):
-
 
2875
    """
-
 
2876
    Parameters:
-
 
2877
     - flipkartInventorySnapshot
-
 
2878
    """
-
 
2879
    self.send_addOrUpdateFlipkartInventorySnapshot(flipkartInventorySnapshot)
-
 
2880
    self.recv_addOrUpdateFlipkartInventorySnapshot()
-
 
2881
 
-
 
2882
  def send_addOrUpdateFlipkartInventorySnapshot(self, flipkartInventorySnapshot):
-
 
2883
    self._oprot.writeMessageBegin('addOrUpdateFlipkartInventorySnapshot', TMessageType.CALL, self._seqid)
-
 
2884
    args = addOrUpdateFlipkartInventorySnapshot_args()
-
 
2885
    args.flipkartInventorySnapshot = flipkartInventorySnapshot
-
 
2886
    args.write(self._oprot)
-
 
2887
    self._oprot.writeMessageEnd()
-
 
2888
    self._oprot.trans.flush()
-
 
2889
 
-
 
2890
  def recv_addOrUpdateFlipkartInventorySnapshot(self, ):
-
 
2891
    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
-
 
2892
    if mtype == TMessageType.EXCEPTION:
-
 
2893
      x = TApplicationException()
-
 
2894
      x.read(self._iprot)
-
 
2895
      self._iprot.readMessageEnd()
-
 
2896
      raise x
-
 
2897
    result = addOrUpdateFlipkartInventorySnapshot_result()
-
 
2898
    result.read(self._iprot)
-
 
2899
    self._iprot.readMessageEnd()
-
 
2900
    return
-
 
2901
 
-
 
2902
  def getFlipkartInventorySnapshot(self, ):
-
 
2903
    self.send_getFlipkartInventorySnapshot()
-
 
2904
    return self.recv_getFlipkartInventorySnapshot()
-
 
2905
 
-
 
2906
  def send_getFlipkartInventorySnapshot(self, ):
-
 
2907
    self._oprot.writeMessageBegin('getFlipkartInventorySnapshot', TMessageType.CALL, self._seqid)
-
 
2908
    args = getFlipkartInventorySnapshot_args()
-
 
2909
    args.write(self._oprot)
-
 
2910
    self._oprot.writeMessageEnd()
-
 
2911
    self._oprot.trans.flush()
-
 
2912
 
-
 
2913
  def recv_getFlipkartInventorySnapshot(self, ):
-
 
2914
    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
-
 
2915
    if mtype == TMessageType.EXCEPTION:
-
 
2916
      x = TApplicationException()
-
 
2917
      x.read(self._iprot)
-
 
2918
      self._iprot.readMessageEnd()
-
 
2919
      raise x
-
 
2920
    result = getFlipkartInventorySnapshot_result()
-
 
2921
    result.read(self._iprot)
-
 
2922
    self._iprot.readMessageEnd()
-
 
2923
    if result.success is not None:
-
 
2924
      return result.success
-
 
2925
    raise TApplicationException(TApplicationException.MISSING_RESULT, "getFlipkartInventorySnapshot failed: unknown result");
-
 
2926
 
2864
 
2927
 
2865
class Processor(shop2020.thriftpy.generic.GenericService.Processor, Iface, TProcessor):
2928
class Processor(shop2020.thriftpy.generic.GenericService.Processor, Iface, TProcessor):
2866
  def __init__(self, handler):
2929
  def __init__(self, handler):
2867
    shop2020.thriftpy.generic.GenericService.Processor.__init__(self, handler)
2930
    shop2020.thriftpy.generic.GenericService.Processor.__init__(self, handler)
2868
    self._processMap["addWarehouse"] = Processor.process_addWarehouse
2931
    self._processMap["addWarehouse"] = Processor.process_addWarehouse
Line 2933... Line 2996...
2933
    self._processMap["getHeldInventoryMapForItem"] = Processor.process_getHeldInventoryMapForItem
2996
    self._processMap["getHeldInventoryMapForItem"] = Processor.process_getHeldInventoryMapForItem
2934
    self._processMap["addOrUpdateAllAmazonFbaInventory"] = Processor.process_addOrUpdateAllAmazonFbaInventory
2997
    self._processMap["addOrUpdateAllAmazonFbaInventory"] = Processor.process_addOrUpdateAllAmazonFbaInventory
2935
    self._processMap["addOrUpdateAllSnapdealInventory"] = Processor.process_addOrUpdateAllSnapdealInventory
2998
    self._processMap["addOrUpdateAllSnapdealInventory"] = Processor.process_addOrUpdateAllSnapdealInventory
2936
    self._processMap["getSnapdealInventorySnapshot"] = Processor.process_getSnapdealInventorySnapshot
2999
    self._processMap["getSnapdealInventorySnapshot"] = Processor.process_getSnapdealInventorySnapshot
2937
    self._processMap["getHoldInventoryDetails"] = Processor.process_getHoldInventoryDetails
3000
    self._processMap["getHoldInventoryDetails"] = Processor.process_getHoldInventoryDetails
-
 
3001
    self._processMap["addOrUpdateFlipkartInventorySnapshot"] = Processor.process_addOrUpdateFlipkartInventorySnapshot
-
 
3002
    self._processMap["getFlipkartInventorySnapshot"] = Processor.process_getFlipkartInventorySnapshot
2938
 
3003
 
2939
  def process(self, iprot, oprot):
3004
  def process(self, iprot, oprot):
2940
    (name, type, seqid) = iprot.readMessageBegin()
3005
    (name, type, seqid) = iprot.readMessageBegin()
2941
    if name not in self._processMap:
3006
    if name not in self._processMap:
2942
      iprot.skip(TType.STRUCT)
3007
      iprot.skip(TType.STRUCT)
Line 3791... Line 3856...
3791
    oprot.writeMessageBegin("getHoldInventoryDetails", TMessageType.REPLY, seqid)
3856
    oprot.writeMessageBegin("getHoldInventoryDetails", TMessageType.REPLY, seqid)
3792
    result.write(oprot)
3857
    result.write(oprot)
3793
    oprot.writeMessageEnd()
3858
    oprot.writeMessageEnd()
3794
    oprot.trans.flush()
3859
    oprot.trans.flush()
3795
 
3860
 
-
 
3861
  def process_addOrUpdateFlipkartInventorySnapshot(self, seqid, iprot, oprot):
-
 
3862
    args = addOrUpdateFlipkartInventorySnapshot_args()
-
 
3863
    args.read(iprot)
-
 
3864
    iprot.readMessageEnd()
-
 
3865
    result = addOrUpdateFlipkartInventorySnapshot_result()
-
 
3866
    self._handler.addOrUpdateFlipkartInventorySnapshot(args.flipkartInventorySnapshot)
-
 
3867
    oprot.writeMessageBegin("addOrUpdateFlipkartInventorySnapshot", TMessageType.REPLY, seqid)
-
 
3868
    result.write(oprot)
-
 
3869
    oprot.writeMessageEnd()
-
 
3870
    oprot.trans.flush()
-
 
3871
 
-
 
3872
  def process_getFlipkartInventorySnapshot(self, seqid, iprot, oprot):
-
 
3873
    args = getFlipkartInventorySnapshot_args()
-
 
3874
    args.read(iprot)
-
 
3875
    iprot.readMessageEnd()
-
 
3876
    result = getFlipkartInventorySnapshot_result()
-
 
3877
    result.success = self._handler.getFlipkartInventorySnapshot()
-
 
3878
    oprot.writeMessageBegin("getFlipkartInventorySnapshot", TMessageType.REPLY, seqid)
-
 
3879
    result.write(oprot)
-
 
3880
    oprot.writeMessageEnd()
-
 
3881
    oprot.trans.flush()
-
 
3882
 
3796
 
3883
 
3797
# HELPER FUNCTIONS AND STRUCTURES
3884
# HELPER FUNCTIONS AND STRUCTURES
3798
 
3885
 
3799
class addWarehouse_args:
3886
class addWarehouse_args:
3800
  """
3887
  """
Line 12929... Line 13016...
12929
      oprot.writeListEnd()
13016
      oprot.writeListEnd()
12930
      oprot.writeFieldEnd()
13017
      oprot.writeFieldEnd()
12931
    oprot.writeFieldStop()
13018
    oprot.writeFieldStop()
12932
    oprot.writeStructEnd()
13019
    oprot.writeStructEnd()
12933
 
13020
 
-
 
13021
  def validate(self):
-
 
13022
    return
-
 
13023
 
-
 
13024
 
-
 
13025
  def __repr__(self):
-
 
13026
    L = ['%s=%r' % (key, value)
-
 
13027
      for key, value in self.__dict__.iteritems()]
-
 
13028
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
-
 
13029
 
-
 
13030
  def __eq__(self, other):
-
 
13031
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
 
13032
 
-
 
13033
  def __ne__(self, other):
-
 
13034
    return not (self == other)
-
 
13035
 
-
 
13036
class addOrUpdateFlipkartInventorySnapshot_args:
-
 
13037
  """
-
 
13038
  Attributes:
-
 
13039
   - flipkartInventorySnapshot
-
 
13040
  """
-
 
13041
 
-
 
13042
  thrift_spec = None
-
 
13043
  def __init__(self, flipkartInventorySnapshot=None,):
-
 
13044
    self.flipkartInventorySnapshot = flipkartInventorySnapshot
-
 
13045
 
-
 
13046
  def read(self, iprot):
-
 
13047
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
-
 
13048
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
-
 
13049
      return
-
 
13050
    iprot.readStructBegin()
-
 
13051
    while True:
-
 
13052
      (fname, ftype, fid) = iprot.readFieldBegin()
-
 
13053
      if ftype == TType.STOP:
-
 
13054
        break
-
 
13055
      if fid == -1:
-
 
13056
        if ftype == TType.LIST:
-
 
13057
          self.flipkartInventorySnapshot = []
-
 
13058
          (_etype284, _size281) = iprot.readListBegin()
-
 
13059
          for _i285 in xrange(_size281):
-
 
13060
            _elem286 = FlipkartInventorySnapshot()
-
 
13061
            _elem286.read(iprot)
-
 
13062
            self.flipkartInventorySnapshot.append(_elem286)
-
 
13063
          iprot.readListEnd()
-
 
13064
        else:
-
 
13065
          iprot.skip(ftype)
-
 
13066
      else:
-
 
13067
        iprot.skip(ftype)
-
 
13068
      iprot.readFieldEnd()
-
 
13069
    iprot.readStructEnd()
-
 
13070
 
-
 
13071
  def write(self, oprot):
-
 
13072
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
-
 
13073
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
-
 
13074
      return
-
 
13075
    oprot.writeStructBegin('addOrUpdateFlipkartInventorySnapshot_args')
-
 
13076
    if self.flipkartInventorySnapshot is not None:
-
 
13077
      oprot.writeFieldBegin('flipkartInventorySnapshot', TType.LIST, -1)
-
 
13078
      oprot.writeListBegin(TType.STRUCT, len(self.flipkartInventorySnapshot))
-
 
13079
      for iter287 in self.flipkartInventorySnapshot:
-
 
13080
        iter287.write(oprot)
-
 
13081
      oprot.writeListEnd()
-
 
13082
      oprot.writeFieldEnd()
-
 
13083
    oprot.writeFieldStop()
-
 
13084
    oprot.writeStructEnd()
-
 
13085
 
-
 
13086
  def validate(self):
-
 
13087
    return
-
 
13088
 
-
 
13089
 
-
 
13090
  def __repr__(self):
-
 
13091
    L = ['%s=%r' % (key, value)
-
 
13092
      for key, value in self.__dict__.iteritems()]
-
 
13093
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
-
 
13094
 
-
 
13095
  def __eq__(self, other):
-
 
13096
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
 
13097
 
-
 
13098
  def __ne__(self, other):
-
 
13099
    return not (self == other)
-
 
13100
 
-
 
13101
class addOrUpdateFlipkartInventorySnapshot_result:
-
 
13102
 
-
 
13103
  thrift_spec = (
-
 
13104
  )
-
 
13105
 
-
 
13106
  def read(self, iprot):
-
 
13107
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
-
 
13108
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
-
 
13109
      return
-
 
13110
    iprot.readStructBegin()
-
 
13111
    while True:
-
 
13112
      (fname, ftype, fid) = iprot.readFieldBegin()
-
 
13113
      if ftype == TType.STOP:
-
 
13114
        break
-
 
13115
      else:
-
 
13116
        iprot.skip(ftype)
-
 
13117
      iprot.readFieldEnd()
-
 
13118
    iprot.readStructEnd()
-
 
13119
 
-
 
13120
  def write(self, oprot):
-
 
13121
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
-
 
13122
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
-
 
13123
      return
-
 
13124
    oprot.writeStructBegin('addOrUpdateFlipkartInventorySnapshot_result')
-
 
13125
    oprot.writeFieldStop()
-
 
13126
    oprot.writeStructEnd()
-
 
13127
 
-
 
13128
  def validate(self):
-
 
13129
    return
-
 
13130
 
-
 
13131
 
-
 
13132
  def __repr__(self):
-
 
13133
    L = ['%s=%r' % (key, value)
-
 
13134
      for key, value in self.__dict__.iteritems()]
-
 
13135
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
-
 
13136
 
-
 
13137
  def __eq__(self, other):
-
 
13138
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
 
13139
 
-
 
13140
  def __ne__(self, other):
-
 
13141
    return not (self == other)
-
 
13142
 
-
 
13143
class getFlipkartInventorySnapshot_args:
-
 
13144
 
-
 
13145
  thrift_spec = (
-
 
13146
  )
-
 
13147
 
-
 
13148
  def read(self, iprot):
-
 
13149
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
-
 
13150
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
-
 
13151
      return
-
 
13152
    iprot.readStructBegin()
-
 
13153
    while True:
-
 
13154
      (fname, ftype, fid) = iprot.readFieldBegin()
-
 
13155
      if ftype == TType.STOP:
-
 
13156
        break
-
 
13157
      else:
-
 
13158
        iprot.skip(ftype)
-
 
13159
      iprot.readFieldEnd()
-
 
13160
    iprot.readStructEnd()
-
 
13161
 
-
 
13162
  def write(self, oprot):
-
 
13163
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
-
 
13164
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
-
 
13165
      return
-
 
13166
    oprot.writeStructBegin('getFlipkartInventorySnapshot_args')
-
 
13167
    oprot.writeFieldStop()
-
 
13168
    oprot.writeStructEnd()
-
 
13169
 
-
 
13170
  def validate(self):
-
 
13171
    return
-
 
13172
 
-
 
13173
 
-
 
13174
  def __repr__(self):
-
 
13175
    L = ['%s=%r' % (key, value)
-
 
13176
      for key, value in self.__dict__.iteritems()]
-
 
13177
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
-
 
13178
 
-
 
13179
  def __eq__(self, other):
-
 
13180
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
 
13181
 
-
 
13182
  def __ne__(self, other):
-
 
13183
    return not (self == other)
-
 
13184
 
-
 
13185
class getFlipkartInventorySnapshot_result:
-
 
13186
  """
-
 
13187
  Attributes:
-
 
13188
   - success
-
 
13189
  """
-
 
13190
 
-
 
13191
  thrift_spec = (
-
 
13192
    (0, TType.LIST, 'success', (TType.STRUCT,(FlipkartInventorySnapshot, FlipkartInventorySnapshot.thrift_spec)), None, ), # 0
-
 
13193
  )
-
 
13194
 
-
 
13195
  def __init__(self, success=None,):
-
 
13196
    self.success = success
-
 
13197
 
-
 
13198
  def read(self, iprot):
-
 
13199
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
-
 
13200
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
-
 
13201
      return
-
 
13202
    iprot.readStructBegin()
-
 
13203
    while True:
-
 
13204
      (fname, ftype, fid) = iprot.readFieldBegin()
-
 
13205
      if ftype == TType.STOP:
-
 
13206
        break
-
 
13207
      if fid == 0:
-
 
13208
        if ftype == TType.LIST:
-
 
13209
          self.success = []
-
 
13210
          (_etype291, _size288) = iprot.readListBegin()
-
 
13211
          for _i292 in xrange(_size288):
-
 
13212
            _elem293 = FlipkartInventorySnapshot()
-
 
13213
            _elem293.read(iprot)
-
 
13214
            self.success.append(_elem293)
-
 
13215
          iprot.readListEnd()
-
 
13216
        else:
-
 
13217
          iprot.skip(ftype)
-
 
13218
      else:
-
 
13219
        iprot.skip(ftype)
-
 
13220
      iprot.readFieldEnd()
-
 
13221
    iprot.readStructEnd()
-
 
13222
 
-
 
13223
  def write(self, oprot):
-
 
13224
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
-
 
13225
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
-
 
13226
      return
-
 
13227
    oprot.writeStructBegin('getFlipkartInventorySnapshot_result')
-
 
13228
    if self.success is not None:
-
 
13229
      oprot.writeFieldBegin('success', TType.LIST, 0)
-
 
13230
      oprot.writeListBegin(TType.STRUCT, len(self.success))
-
 
13231
      for iter294 in self.success:
-
 
13232
        iter294.write(oprot)
-
 
13233
      oprot.writeListEnd()
-
 
13234
      oprot.writeFieldEnd()
-
 
13235
    oprot.writeFieldStop()
-
 
13236
    oprot.writeStructEnd()
-
 
13237
 
12934
  def validate(self):
13238
  def validate(self):
12935
    return
13239
    return
12936
 
13240
 
12937
 
13241
 
12938
  def __repr__(self):
13242
  def __repr__(self):