Subversion Repositories SmartDukaan

Rev

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

Rev 9801 Rev 9882
Line 1986... Line 1986...
1986
    Parameters:
1986
    Parameters:
1987
     - source
1987
     - source
1988
    """
1988
    """
1989
    pass
1989
    pass
1990
 
1990
 
1991
  def updateSnapdealOrdersStatus(self, delivered_orders):
1991
  def updateSnapdealOrdersStatus(self, orders):
1992
    """
1992
    """
1993
    Parameters:
1993
    Parameters:
1994
     - delivered_orders
1994
     - orders
1995
    """
1995
    """
1996
    pass
1996
    pass
1997
 
1997
 
1998
  def updateFlipkartOrdersStatus(self, delivered_orders):
1998
  def updateFlipkartOrdersStatus(self, delivered_orders):
1999
    """
1999
    """
Line 9353... Line 9353...
9353
    self._iprot.readMessageEnd()
9353
    self._iprot.readMessageEnd()
9354
    if result.success is not None:
9354
    if result.success is not None:
9355
      return result.success
9355
      return result.success
9356
    raise TApplicationException(TApplicationException.MISSING_RESULT, "getMinCreatedTimeStampUndeliveredOrdersForSource failed: unknown result");
9356
    raise TApplicationException(TApplicationException.MISSING_RESULT, "getMinCreatedTimeStampUndeliveredOrdersForSource failed: unknown result");
9357
 
9357
 
9358
  def updateSnapdealOrdersStatus(self, delivered_orders):
9358
  def updateSnapdealOrdersStatus(self, orders):
9359
    """
9359
    """
9360
    Parameters:
9360
    Parameters:
9361
     - delivered_orders
9361
     - orders
9362
    """
9362
    """
9363
    self.send_updateSnapdealOrdersStatus(delivered_orders)
9363
    self.send_updateSnapdealOrdersStatus(orders)
9364
    self.recv_updateSnapdealOrdersStatus()
9364
    self.recv_updateSnapdealOrdersStatus()
9365
 
9365
 
9366
  def send_updateSnapdealOrdersStatus(self, delivered_orders):
9366
  def send_updateSnapdealOrdersStatus(self, orders):
9367
    self._oprot.writeMessageBegin('updateSnapdealOrdersStatus', TMessageType.CALL, self._seqid)
9367
    self._oprot.writeMessageBegin('updateSnapdealOrdersStatus', TMessageType.CALL, self._seqid)
9368
    args = updateSnapdealOrdersStatus_args()
9368
    args = updateSnapdealOrdersStatus_args()
9369
    args.delivered_orders = delivered_orders
9369
    args.orders = orders
9370
    args.write(self._oprot)
9370
    args.write(self._oprot)
9371
    self._oprot.writeMessageEnd()
9371
    self._oprot.writeMessageEnd()
9372
    self._oprot.trans.flush()
9372
    self._oprot.trans.flush()
9373
 
9373
 
9374
  def recv_updateSnapdealOrdersStatus(self, ):
9374
  def recv_updateSnapdealOrdersStatus(self, ):
Line 12413... Line 12413...
12413
    args = updateSnapdealOrdersStatus_args()
12413
    args = updateSnapdealOrdersStatus_args()
12414
    args.read(iprot)
12414
    args.read(iprot)
12415
    iprot.readMessageEnd()
12415
    iprot.readMessageEnd()
12416
    result = updateSnapdealOrdersStatus_result()
12416
    result = updateSnapdealOrdersStatus_result()
12417
    try:
12417
    try:
12418
      self._handler.updateSnapdealOrdersStatus(args.delivered_orders)
12418
      self._handler.updateSnapdealOrdersStatus(args.orders)
12419
    except TransactionServiceException, ex:
12419
    except TransactionServiceException, ex:
12420
      result.ex = ex
12420
      result.ex = ex
12421
    oprot.writeMessageBegin("updateSnapdealOrdersStatus", TMessageType.REPLY, seqid)
12421
    oprot.writeMessageBegin("updateSnapdealOrdersStatus", TMessageType.REPLY, seqid)
12422
    result.write(oprot)
12422
    result.write(oprot)
12423
    oprot.writeMessageEnd()
12423
    oprot.writeMessageEnd()
Line 42650... Line 42650...
42650
    return not (self == other)
42650
    return not (self == other)
42651
 
42651
 
42652
class updateSnapdealOrdersStatus_args:
42652
class updateSnapdealOrdersStatus_args:
42653
  """
42653
  """
42654
  Attributes:
42654
  Attributes:
42655
   - delivered_orders
42655
   - orders
42656
  """
42656
  """
42657
 
42657
 
42658
  thrift_spec = (
42658
  thrift_spec = (
42659
    None, # 0
42659
    None, # 0
42660
    (1, TType.LIST, 'delivered_orders', (TType.LIST,(TType.STRING,None)), None, ), # 1
42660
    (1, TType.MAP, 'orders', (TType.STRING,None,TType.LIST,(TType.LIST,(TType.STRING,None))), None, ), # 1
42661
  )
42661
  )
42662
 
42662
 
42663
  def __init__(self, delivered_orders=None,):
42663
  def __init__(self, orders=None,):
42664
    self.delivered_orders = delivered_orders
42664
    self.orders = orders
42665
 
42665
 
42666
  def read(self, iprot):
42666
  def read(self, iprot):
42667
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
42667
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
42668
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
42668
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
42669
      return
42669
      return
Line 42671... Line 42671...
42671
    while True:
42671
    while True:
42672
      (fname, ftype, fid) = iprot.readFieldBegin()
42672
      (fname, ftype, fid) = iprot.readFieldBegin()
42673
      if ftype == TType.STOP:
42673
      if ftype == TType.STOP:
42674
        break
42674
        break
42675
      if fid == 1:
42675
      if fid == 1:
42676
        if ftype == TType.LIST:
42676
        if ftype == TType.MAP:
42677
          self.delivered_orders = []
42677
          self.orders = {}
42678
          (_etype921, _size918) = iprot.readListBegin()
42678
          (_ktype919, _vtype920, _size918 ) = iprot.readMapBegin() 
42679
          for _i922 in xrange(_size918):
42679
          for _i922 in xrange(_size918):
-
 
42680
            _key923 = iprot.readString();
42680
            _elem923 = []
42681
            _val924 = []
42681
            (_etype927, _size924) = iprot.readListBegin()
42682
            (_etype928, _size925) = iprot.readListBegin()
42682
            for _i928 in xrange(_size924):
42683
            for _i929 in xrange(_size925):
-
 
42684
              _elem930 = []
-
 
42685
              (_etype934, _size931) = iprot.readListBegin()
-
 
42686
              for _i935 in xrange(_size931):
42683
              _elem929 = iprot.readString();
42687
                _elem936 = iprot.readString();
42684
              _elem923.append(_elem929)
42688
                _elem930.append(_elem936)
-
 
42689
              iprot.readListEnd()
-
 
42690
              _val924.append(_elem930)
42685
            iprot.readListEnd()
42691
            iprot.readListEnd()
42686
            self.delivered_orders.append(_elem923)
42692
            self.orders[_key923] = _val924
42687
          iprot.readListEnd()
42693
          iprot.readMapEnd()
42688
        else:
42694
        else:
42689
          iprot.skip(ftype)
42695
          iprot.skip(ftype)
42690
      else:
42696
      else:
42691
        iprot.skip(ftype)
42697
        iprot.skip(ftype)
42692
      iprot.readFieldEnd()
42698
      iprot.readFieldEnd()
Line 42695... Line 42701...
42695
  def write(self, oprot):
42701
  def write(self, oprot):
42696
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
42702
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
42697
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
42703
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
42698
      return
42704
      return
42699
    oprot.writeStructBegin('updateSnapdealOrdersStatus_args')
42705
    oprot.writeStructBegin('updateSnapdealOrdersStatus_args')
42700
    if self.delivered_orders is not None:
42706
    if self.orders is not None:
42701
      oprot.writeFieldBegin('delivered_orders', TType.LIST, 1)
42707
      oprot.writeFieldBegin('orders', TType.MAP, 1)
-
 
42708
      oprot.writeMapBegin(TType.STRING, TType.LIST, len(self.orders))
-
 
42709
      for kiter937,viter938 in self.orders.items():
-
 
42710
        oprot.writeString(kiter937)
42702
      oprot.writeListBegin(TType.LIST, len(self.delivered_orders))
42711
        oprot.writeListBegin(TType.LIST, len(viter938))
42703
      for iter930 in self.delivered_orders:
42712
        for iter939 in viter938:
42704
        oprot.writeListBegin(TType.STRING, len(iter930))
42713
          oprot.writeListBegin(TType.STRING, len(iter939))
42705
        for iter931 in iter930:
42714
          for iter940 in iter939:
42706
          oprot.writeString(iter931)
42715
            oprot.writeString(iter940)
-
 
42716
          oprot.writeListEnd()
42707
        oprot.writeListEnd()
42717
        oprot.writeListEnd()
42708
      oprot.writeListEnd()
42718
      oprot.writeMapEnd()
42709
      oprot.writeFieldEnd()
42719
      oprot.writeFieldEnd()
42710
    oprot.writeFieldStop()
42720
    oprot.writeFieldStop()
42711
    oprot.writeStructEnd()
42721
    oprot.writeStructEnd()
42712
 
42722
 
42713
  def validate(self):
42723
  def validate(self):
Line 42810... Line 42820...
42810
      if ftype == TType.STOP:
42820
      if ftype == TType.STOP:
42811
        break
42821
        break
42812
      if fid == 1:
42822
      if fid == 1:
42813
        if ftype == TType.LIST:
42823
        if ftype == TType.LIST:
42814
          self.delivered_orders = []
42824
          self.delivered_orders = []
42815
          (_etype935, _size932) = iprot.readListBegin()
42825
          (_etype944, _size941) = iprot.readListBegin()
42816
          for _i936 in xrange(_size932):
42826
          for _i945 in xrange(_size941):
42817
            _elem937 = []
42827
            _elem946 = []
42818
            (_etype941, _size938) = iprot.readListBegin()
42828
            (_etype950, _size947) = iprot.readListBegin()
42819
            for _i942 in xrange(_size938):
42829
            for _i951 in xrange(_size947):
42820
              _elem943 = iprot.readString();
42830
              _elem952 = iprot.readString();
42821
              _elem937.append(_elem943)
42831
              _elem946.append(_elem952)
42822
            iprot.readListEnd()
42832
            iprot.readListEnd()
42823
            self.delivered_orders.append(_elem937)
42833
            self.delivered_orders.append(_elem946)
42824
          iprot.readListEnd()
42834
          iprot.readListEnd()
42825
        else:
42835
        else:
42826
          iprot.skip(ftype)
42836
          iprot.skip(ftype)
42827
      else:
42837
      else:
42828
        iprot.skip(ftype)
42838
        iprot.skip(ftype)
Line 42835... Line 42845...
42835
      return
42845
      return
42836
    oprot.writeStructBegin('updateFlipkartOrdersStatus_args')
42846
    oprot.writeStructBegin('updateFlipkartOrdersStatus_args')
42837
    if self.delivered_orders is not None:
42847
    if self.delivered_orders is not None:
42838
      oprot.writeFieldBegin('delivered_orders', TType.LIST, 1)
42848
      oprot.writeFieldBegin('delivered_orders', TType.LIST, 1)
42839
      oprot.writeListBegin(TType.LIST, len(self.delivered_orders))
42849
      oprot.writeListBegin(TType.LIST, len(self.delivered_orders))
42840
      for iter944 in self.delivered_orders:
42850
      for iter953 in self.delivered_orders:
42841
        oprot.writeListBegin(TType.STRING, len(iter944))
42851
        oprot.writeListBegin(TType.STRING, len(iter953))
42842
        for iter945 in iter944:
42852
        for iter954 in iter953:
42843
          oprot.writeString(iter945)
42853
          oprot.writeString(iter954)
42844
        oprot.writeListEnd()
42854
        oprot.writeListEnd()
42845
      oprot.writeListEnd()
42855
      oprot.writeListEnd()
42846
      oprot.writeFieldEnd()
42856
      oprot.writeFieldEnd()
42847
    oprot.writeFieldStop()
42857
    oprot.writeFieldStop()
42848
    oprot.writeStructEnd()
42858
    oprot.writeStructEnd()
Line 42947... Line 42957...
42947
      if ftype == TType.STOP:
42957
      if ftype == TType.STOP:
42948
        break
42958
        break
42949
      if fid == 1:
42959
      if fid == 1:
42950
        if ftype == TType.LIST:
42960
        if ftype == TType.LIST:
42951
          self.amazonfbasalessnapshotlist = []
42961
          self.amazonfbasalessnapshotlist = []
42952
          (_etype949, _size946) = iprot.readListBegin()
42962
          (_etype958, _size955) = iprot.readListBegin()
42953
          for _i950 in xrange(_size946):
42963
          for _i959 in xrange(_size955):
42954
            _elem951 = AmazonFbaSalesSnapshot()
42964
            _elem960 = AmazonFbaSalesSnapshot()
42955
            _elem951.read(iprot)
42965
            _elem960.read(iprot)
42956
            self.amazonfbasalessnapshotlist.append(_elem951)
42966
            self.amazonfbasalessnapshotlist.append(_elem960)
42957
          iprot.readListEnd()
42967
          iprot.readListEnd()
42958
        else:
42968
        else:
42959
          iprot.skip(ftype)
42969
          iprot.skip(ftype)
42960
      else:
42970
      else:
42961
        iprot.skip(ftype)
42971
        iprot.skip(ftype)
Line 42968... Line 42978...
42968
      return
42978
      return
42969
    oprot.writeStructBegin('bulkAddOrUpdateAmazonFbaSalesSnapshot_args')
42979
    oprot.writeStructBegin('bulkAddOrUpdateAmazonFbaSalesSnapshot_args')
42970
    if self.amazonfbasalessnapshotlist is not None:
42980
    if self.amazonfbasalessnapshotlist is not None:
42971
      oprot.writeFieldBegin('amazonfbasalessnapshotlist', TType.LIST, 1)
42981
      oprot.writeFieldBegin('amazonfbasalessnapshotlist', TType.LIST, 1)
42972
      oprot.writeListBegin(TType.STRUCT, len(self.amazonfbasalessnapshotlist))
42982
      oprot.writeListBegin(TType.STRUCT, len(self.amazonfbasalessnapshotlist))
42973
      for iter952 in self.amazonfbasalessnapshotlist:
42983
      for iter961 in self.amazonfbasalessnapshotlist:
42974
        iter952.write(oprot)
42984
        iter961.write(oprot)
42975
      oprot.writeListEnd()
42985
      oprot.writeListEnd()
42976
      oprot.writeFieldEnd()
42986
      oprot.writeFieldEnd()
42977
    oprot.writeFieldStop()
42987
    oprot.writeFieldStop()
42978
    oprot.writeStructEnd()
42988
    oprot.writeStructEnd()
42979
 
42989