Subversion Repositories SmartDukaan

Rev

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

Rev 10485 Rev 10544
Line 641... Line 641...
641
    pass
641
    pass
642
 
642
 
643
  def getStateMaster(self, ):
643
  def getStateMaster(self, ):
644
    pass
644
    pass
645
 
645
 
-
 
646
  def updateSnapdealStockAtEOD(self, allsnapdealstock):
-
 
647
    """
-
 
648
    Parameters:
-
 
649
     - allsnapdealstock
-
 
650
    """
-
 
651
    pass
-
 
652
 
-
 
653
  def updateFlipkartStockAtEOD(self, allflipkartstock):
-
 
654
    """
-
 
655
    Parameters:
-
 
656
     - allflipkartstock
-
 
657
    """
-
 
658
    pass
-
 
659
 
646
 
660
 
647
class Client(shop2020.thriftpy.generic.GenericService.Client, Iface):
661
class Client(shop2020.thriftpy.generic.GenericService.Client, Iface):
648
  def __init__(self, iprot, oprot=None):
662
  def __init__(self, iprot, oprot=None):
649
    shop2020.thriftpy.generic.GenericService.Client.__init__(self, iprot, oprot)
663
    shop2020.thriftpy.generic.GenericService.Client.__init__(self, iprot, oprot)
650
 
664
 
Line 3073... Line 3087...
3073
    self._iprot.readMessageEnd()
3087
    self._iprot.readMessageEnd()
3074
    if result.success is not None:
3088
    if result.success is not None:
3075
      return result.success
3089
      return result.success
3076
    raise TApplicationException(TApplicationException.MISSING_RESULT, "getStateMaster failed: unknown result");
3090
    raise TApplicationException(TApplicationException.MISSING_RESULT, "getStateMaster failed: unknown result");
3077
 
3091
 
-
 
3092
  def updateSnapdealStockAtEOD(self, allsnapdealstock):
-
 
3093
    """
-
 
3094
    Parameters:
-
 
3095
     - allsnapdealstock
-
 
3096
    """
-
 
3097
    self.send_updateSnapdealStockAtEOD(allsnapdealstock)
-
 
3098
    self.recv_updateSnapdealStockAtEOD()
-
 
3099
 
-
 
3100
  def send_updateSnapdealStockAtEOD(self, allsnapdealstock):
-
 
3101
    self._oprot.writeMessageBegin('updateSnapdealStockAtEOD', TMessageType.CALL, self._seqid)
-
 
3102
    args = updateSnapdealStockAtEOD_args()
-
 
3103
    args.allsnapdealstock = allsnapdealstock
-
 
3104
    args.write(self._oprot)
-
 
3105
    self._oprot.writeMessageEnd()
-
 
3106
    self._oprot.trans.flush()
-
 
3107
 
-
 
3108
  def recv_updateSnapdealStockAtEOD(self, ):
-
 
3109
    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
-
 
3110
    if mtype == TMessageType.EXCEPTION:
-
 
3111
      x = TApplicationException()
-
 
3112
      x.read(self._iprot)
-
 
3113
      self._iprot.readMessageEnd()
-
 
3114
      raise x
-
 
3115
    result = updateSnapdealStockAtEOD_result()
-
 
3116
    result.read(self._iprot)
-
 
3117
    self._iprot.readMessageEnd()
-
 
3118
    return
-
 
3119
 
-
 
3120
  def updateFlipkartStockAtEOD(self, allflipkartstock):
-
 
3121
    """
-
 
3122
    Parameters:
-
 
3123
     - allflipkartstock
-
 
3124
    """
-
 
3125
    self.send_updateFlipkartStockAtEOD(allflipkartstock)
-
 
3126
    self.recv_updateFlipkartStockAtEOD()
-
 
3127
 
-
 
3128
  def send_updateFlipkartStockAtEOD(self, allflipkartstock):
-
 
3129
    self._oprot.writeMessageBegin('updateFlipkartStockAtEOD', TMessageType.CALL, self._seqid)
-
 
3130
    args = updateFlipkartStockAtEOD_args()
-
 
3131
    args.allflipkartstock = allflipkartstock
-
 
3132
    args.write(self._oprot)
-
 
3133
    self._oprot.writeMessageEnd()
-
 
3134
    self._oprot.trans.flush()
-
 
3135
 
-
 
3136
  def recv_updateFlipkartStockAtEOD(self, ):
-
 
3137
    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
-
 
3138
    if mtype == TMessageType.EXCEPTION:
-
 
3139
      x = TApplicationException()
-
 
3140
      x.read(self._iprot)
-
 
3141
      self._iprot.readMessageEnd()
-
 
3142
      raise x
-
 
3143
    result = updateFlipkartStockAtEOD_result()
-
 
3144
    result.read(self._iprot)
-
 
3145
    self._iprot.readMessageEnd()
-
 
3146
    return
-
 
3147
 
3078
 
3148
 
3079
class Processor(shop2020.thriftpy.generic.GenericService.Processor, Iface, TProcessor):
3149
class Processor(shop2020.thriftpy.generic.GenericService.Processor, Iface, TProcessor):
3080
  def __init__(self, handler):
3150
  def __init__(self, handler):
3081
    shop2020.thriftpy.generic.GenericService.Processor.__init__(self, handler)
3151
    shop2020.thriftpy.generic.GenericService.Processor.__init__(self, handler)
3082
    self._processMap["addWarehouse"] = Processor.process_addWarehouse
3152
    self._processMap["addWarehouse"] = Processor.process_addWarehouse
Line 3153... Line 3223...
3153
    self._processMap["getHoldInventoryDetails"] = Processor.process_getHoldInventoryDetails
3223
    self._processMap["getHoldInventoryDetails"] = Processor.process_getHoldInventoryDetails
3154
    self._processMap["addOrUpdateFlipkartInventorySnapshot"] = Processor.process_addOrUpdateFlipkartInventorySnapshot
3224
    self._processMap["addOrUpdateFlipkartInventorySnapshot"] = Processor.process_addOrUpdateFlipkartInventorySnapshot
3155
    self._processMap["getFlipkartInventorySnapshot"] = Processor.process_getFlipkartInventorySnapshot
3225
    self._processMap["getFlipkartInventorySnapshot"] = Processor.process_getFlipkartInventorySnapshot
3156
    self._processMap["getFlipkartlInventoryForItem"] = Processor.process_getFlipkartlInventoryForItem
3226
    self._processMap["getFlipkartlInventoryForItem"] = Processor.process_getFlipkartlInventoryForItem
3157
    self._processMap["getStateMaster"] = Processor.process_getStateMaster
3227
    self._processMap["getStateMaster"] = Processor.process_getStateMaster
-
 
3228
    self._processMap["updateSnapdealStockAtEOD"] = Processor.process_updateSnapdealStockAtEOD
-
 
3229
    self._processMap["updateFlipkartStockAtEOD"] = Processor.process_updateFlipkartStockAtEOD
3158
 
3230
 
3159
  def process(self, iprot, oprot):
3231
  def process(self, iprot, oprot):
3160
    (name, type, seqid) = iprot.readMessageBegin()
3232
    (name, type, seqid) = iprot.readMessageBegin()
3161
    if name not in self._processMap:
3233
    if name not in self._processMap:
3162
      iprot.skip(TType.STRUCT)
3234
      iprot.skip(TType.STRUCT)
Line 4077... Line 4149...
4077
    oprot.writeMessageBegin("getStateMaster", TMessageType.REPLY, seqid)
4149
    oprot.writeMessageBegin("getStateMaster", TMessageType.REPLY, seqid)
4078
    result.write(oprot)
4150
    result.write(oprot)
4079
    oprot.writeMessageEnd()
4151
    oprot.writeMessageEnd()
4080
    oprot.trans.flush()
4152
    oprot.trans.flush()
4081
 
4153
 
-
 
4154
  def process_updateSnapdealStockAtEOD(self, seqid, iprot, oprot):
-
 
4155
    args = updateSnapdealStockAtEOD_args()
-
 
4156
    args.read(iprot)
-
 
4157
    iprot.readMessageEnd()
-
 
4158
    result = updateSnapdealStockAtEOD_result()
-
 
4159
    self._handler.updateSnapdealStockAtEOD(args.allsnapdealstock)
-
 
4160
    oprot.writeMessageBegin("updateSnapdealStockAtEOD", TMessageType.REPLY, seqid)
-
 
4161
    result.write(oprot)
-
 
4162
    oprot.writeMessageEnd()
-
 
4163
    oprot.trans.flush()
-
 
4164
 
-
 
4165
  def process_updateFlipkartStockAtEOD(self, seqid, iprot, oprot):
-
 
4166
    args = updateFlipkartStockAtEOD_args()
-
 
4167
    args.read(iprot)
-
 
4168
    iprot.readMessageEnd()
-
 
4169
    result = updateFlipkartStockAtEOD_result()
-
 
4170
    self._handler.updateFlipkartStockAtEOD(args.allflipkartstock)
-
 
4171
    oprot.writeMessageBegin("updateFlipkartStockAtEOD", TMessageType.REPLY, seqid)
-
 
4172
    result.write(oprot)
-
 
4173
    oprot.writeMessageEnd()
-
 
4174
    oprot.trans.flush()
-
 
4175
 
4082
 
4176
 
4083
# HELPER FUNCTIONS AND STRUCTURES
4177
# HELPER FUNCTIONS AND STRUCTURES
4084
 
4178
 
4085
class addWarehouse_args:
4179
class addWarehouse_args:
4086
  """
4180
  """
Line 13973... Line 14067...
13973
    oprot.writeFieldStop()
14067
    oprot.writeFieldStop()
13974
    oprot.writeStructEnd()
14068
    oprot.writeStructEnd()
13975
 
14069
 
13976
  def validate(self):
14070
  def validate(self):
13977
    return
14071
    return
-
 
14072
 
-
 
14073
 
-
 
14074
  def __repr__(self):
-
 
14075
    L = ['%s=%r' % (key, value)
-
 
14076
      for key, value in self.__dict__.iteritems()]
-
 
14077
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
-
 
14078
 
-
 
14079
  def __eq__(self, other):
-
 
14080
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
 
14081
 
-
 
14082
  def __ne__(self, other):
-
 
14083
    return not (self == other)
-
 
14084
 
-
 
14085
class updateSnapdealStockAtEOD_args:
-
 
14086
  """
-
 
14087
  Attributes:
-
 
14088
   - allsnapdealstock
-
 
14089
  """
-
 
14090
 
-
 
14091
  thrift_spec = None
-
 
14092
  def __init__(self, allsnapdealstock=None,):
-
 
14093
    self.allsnapdealstock = allsnapdealstock
-
 
14094
 
-
 
14095
  def read(self, iprot):
-
 
14096
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
-
 
14097
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
-
 
14098
      return
-
 
14099
    iprot.readStructBegin()
-
 
14100
    while True:
-
 
14101
      (fname, ftype, fid) = iprot.readFieldBegin()
-
 
14102
      if ftype == TType.STOP:
-
 
14103
        break
-
 
14104
      if fid == -1:
-
 
14105
        if ftype == TType.LIST:
-
 
14106
          self.allsnapdealstock = []
-
 
14107
          (_etype321, _size318) = iprot.readListBegin()
-
 
14108
          for _i322 in xrange(_size318):
-
 
14109
            _elem323 = SnapdealStockAtEOD()
-
 
14110
            _elem323.read(iprot)
-
 
14111
            self.allsnapdealstock.append(_elem323)
-
 
14112
          iprot.readListEnd()
-
 
14113
        else:
-
 
14114
          iprot.skip(ftype)
-
 
14115
      else:
-
 
14116
        iprot.skip(ftype)
-
 
14117
      iprot.readFieldEnd()
-
 
14118
    iprot.readStructEnd()
-
 
14119
 
-
 
14120
  def write(self, oprot):
-
 
14121
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
-
 
14122
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
-
 
14123
      return
-
 
14124
    oprot.writeStructBegin('updateSnapdealStockAtEOD_args')
-
 
14125
    if self.allsnapdealstock is not None:
-
 
14126
      oprot.writeFieldBegin('allsnapdealstock', TType.LIST, -1)
-
 
14127
      oprot.writeListBegin(TType.STRUCT, len(self.allsnapdealstock))
-
 
14128
      for iter324 in self.allsnapdealstock:
-
 
14129
        iter324.write(oprot)
-
 
14130
      oprot.writeListEnd()
-
 
14131
      oprot.writeFieldEnd()
-
 
14132
    oprot.writeFieldStop()
-
 
14133
    oprot.writeStructEnd()
-
 
14134
 
-
 
14135
  def validate(self):
-
 
14136
    return
-
 
14137
 
-
 
14138
 
-
 
14139
  def __repr__(self):
-
 
14140
    L = ['%s=%r' % (key, value)
-
 
14141
      for key, value in self.__dict__.iteritems()]
-
 
14142
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
-
 
14143
 
-
 
14144
  def __eq__(self, other):
-
 
14145
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
 
14146
 
-
 
14147
  def __ne__(self, other):
-
 
14148
    return not (self == other)
-
 
14149
 
-
 
14150
class updateSnapdealStockAtEOD_result:
-
 
14151
 
-
 
14152
  thrift_spec = (
-
 
14153
  )
-
 
14154
 
-
 
14155
  def read(self, iprot):
-
 
14156
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
-
 
14157
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
-
 
14158
      return
-
 
14159
    iprot.readStructBegin()
-
 
14160
    while True:
-
 
14161
      (fname, ftype, fid) = iprot.readFieldBegin()
-
 
14162
      if ftype == TType.STOP:
-
 
14163
        break
-
 
14164
      else:
-
 
14165
        iprot.skip(ftype)
-
 
14166
      iprot.readFieldEnd()
-
 
14167
    iprot.readStructEnd()
-
 
14168
 
-
 
14169
  def write(self, oprot):
-
 
14170
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
-
 
14171
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
-
 
14172
      return
-
 
14173
    oprot.writeStructBegin('updateSnapdealStockAtEOD_result')
-
 
14174
    oprot.writeFieldStop()
-
 
14175
    oprot.writeStructEnd()
-
 
14176
 
-
 
14177
  def validate(self):
-
 
14178
    return
-
 
14179
 
-
 
14180
 
-
 
14181
  def __repr__(self):
-
 
14182
    L = ['%s=%r' % (key, value)
-
 
14183
      for key, value in self.__dict__.iteritems()]
-
 
14184
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
-
 
14185
 
-
 
14186
  def __eq__(self, other):
-
 
14187
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
 
14188
 
-
 
14189
  def __ne__(self, other):
-
 
14190
    return not (self == other)
-
 
14191
 
-
 
14192
class updateFlipkartStockAtEOD_args:
-
 
14193
  """
-
 
14194
  Attributes:
-
 
14195
   - allflipkartstock
-
 
14196
  """
-
 
14197
 
-
 
14198
  thrift_spec = None
-
 
14199
  def __init__(self, allflipkartstock=None,):
-
 
14200
    self.allflipkartstock = allflipkartstock
-
 
14201
 
-
 
14202
  def read(self, iprot):
-
 
14203
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
-
 
14204
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
-
 
14205
      return
-
 
14206
    iprot.readStructBegin()
-
 
14207
    while True:
-
 
14208
      (fname, ftype, fid) = iprot.readFieldBegin()
-
 
14209
      if ftype == TType.STOP:
-
 
14210
        break
-
 
14211
      if fid == -1:
-
 
14212
        if ftype == TType.LIST:
-
 
14213
          self.allflipkartstock = []
-
 
14214
          (_etype328, _size325) = iprot.readListBegin()
-
 
14215
          for _i329 in xrange(_size325):
-
 
14216
            _elem330 = FlipkartStockAtEOD()
-
 
14217
            _elem330.read(iprot)
-
 
14218
            self.allflipkartstock.append(_elem330)
-
 
14219
          iprot.readListEnd()
-
 
14220
        else:
-
 
14221
          iprot.skip(ftype)
-
 
14222
      else:
-
 
14223
        iprot.skip(ftype)
-
 
14224
      iprot.readFieldEnd()
-
 
14225
    iprot.readStructEnd()
-
 
14226
 
-
 
14227
  def write(self, oprot):
-
 
14228
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
-
 
14229
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
-
 
14230
      return
-
 
14231
    oprot.writeStructBegin('updateFlipkartStockAtEOD_args')
-
 
14232
    if self.allflipkartstock is not None:
-
 
14233
      oprot.writeFieldBegin('allflipkartstock', TType.LIST, -1)
-
 
14234
      oprot.writeListBegin(TType.STRUCT, len(self.allflipkartstock))
-
 
14235
      for iter331 in self.allflipkartstock:
-
 
14236
        iter331.write(oprot)
-
 
14237
      oprot.writeListEnd()
-
 
14238
      oprot.writeFieldEnd()
-
 
14239
    oprot.writeFieldStop()
-
 
14240
    oprot.writeStructEnd()
-
 
14241
 
-
 
14242
  def validate(self):
-
 
14243
    return
-
 
14244
 
-
 
14245
 
-
 
14246
  def __repr__(self):
-
 
14247
    L = ['%s=%r' % (key, value)
-
 
14248
      for key, value in self.__dict__.iteritems()]
-
 
14249
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
-
 
14250
 
-
 
14251
  def __eq__(self, other):
-
 
14252
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
 
14253
 
-
 
14254
  def __ne__(self, other):
-
 
14255
    return not (self == other)
-
 
14256
 
-
 
14257
class updateFlipkartStockAtEOD_result:
-
 
14258
 
-
 
14259
  thrift_spec = (
-
 
14260
  )
-
 
14261
 
-
 
14262
  def read(self, iprot):
-
 
14263
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
-
 
14264
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
-
 
14265
      return
-
 
14266
    iprot.readStructBegin()
-
 
14267
    while True:
-
 
14268
      (fname, ftype, fid) = iprot.readFieldBegin()
-
 
14269
      if ftype == TType.STOP:
-
 
14270
        break
-
 
14271
      else:
-
 
14272
        iprot.skip(ftype)
-
 
14273
      iprot.readFieldEnd()
-
 
14274
    iprot.readStructEnd()
-
 
14275
 
-
 
14276
  def write(self, oprot):
-
 
14277
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
-
 
14278
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
-
 
14279
      return
-
 
14280
    oprot.writeStructBegin('updateFlipkartStockAtEOD_result')
-
 
14281
    oprot.writeFieldStop()
-
 
14282
    oprot.writeStructEnd()
-
 
14283
 
-
 
14284
  def validate(self):
-
 
14285
    return
13978
 
14286
 
13979
 
14287
 
13980
  def __repr__(self):
14288
  def __repr__(self):
13981
    L = ['%s=%r' % (key, value)
14289
    L = ['%s=%r' % (key, value)
13982
      for key, value in self.__dict__.iteritems()]
14290
      for key, value in self.__dict__.iteritems()]