WebSVN – SmartDukaan – Diff – /trunk/PyProj/src/shop2020/thriftpy/model/v1/catalog/CatalogService.py



    Parameters:
     - source
    """
    pass
 
  def updateMarketPlacePriceUpdateStatus(self, skulist, timestamp, source):
    """
    Parameters:
     - skulist
     - timestamp
     - source
    """
    pass
 
 
class Client(shop2020.thriftpy.generic.GenericService.Client, Iface):

    self._iprot.readMessageEnd()
    if result.success is not None:
      return result.success
    raise TApplicationException(TApplicationException.MISSING_RESULT, "getMarketPlaceItemsForPriceUpdate failed: unknown result");
 
  def updateMarketPlacePriceUpdateStatus(self, skulist, timestamp, source):
    """
    Parameters:
     - skulist
     - timestamp
     - source
    """
    self.send_updateMarketPlacePriceUpdateStatus(skulist, timestamp, source)
    self.recv_updateMarketPlacePriceUpdateStatus()
 
  def send_updateMarketPlacePriceUpdateStatus(self, skulist, timestamp, source):
    self._oprot.writeMessageBegin('updateMarketPlacePriceUpdateStatus', TMessageType.CALL, self._seqid)
    args = updateMarketPlacePriceUpdateStatus_args()
    args.skulist = skulist
    args.timestamp = timestamp
    args.source = source
    args.write(self._oprot)
    self._oprot.writeMessageEnd()
    self._oprot.trans.flush()
 
  def recv_updateMarketPlacePriceUpdateStatus(self, ):

  def process_updateMarketPlacePriceUpdateStatus(self, seqid, iprot, oprot):
    args = updateMarketPlacePriceUpdateStatus_args()
    args.read(iprot)
    iprot.readMessageEnd()
    result = updateMarketPlacePriceUpdateStatus_result()
    self._handler.updateMarketPlacePriceUpdateStatus(args.skulist, args.timestamp, args.source)
    oprot.writeMessageBegin("updateMarketPlacePriceUpdateStatus", TMessageType.REPLY, seqid)
    result.write(oprot)
    oprot.writeMessageEnd()
    oprot.trans.flush()
 

class updateMarketPlacePriceUpdateStatus_args:
  """
  Attributes:
   - skulist
   - timestamp
   - source
  """
 
  thrift_spec = (
    None, # 0
    (1, TType.LIST, 'skulist', (TType.I64,None), None, ), # 1
    (2, TType.I64, 'timestamp', None, None, ), # 2
    (3, TType.I64, 'source', None, None, ), # 3
  )
 
  def __init__(self, skulist=None, timestamp=None, source=None,):
    self.skulist = skulist
    self.timestamp = timestamp
    self.source = source
 
  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

      elif fid == 2:
        if ftype == TType.I64:
          self.timestamp = iprot.readI64();
        else:
          iprot.skip(ftype)
      elif fid == 3:
        if ftype == TType.I64:
          self.source = iprot.readI64();
        else:
          iprot.skip(ftype)
      else:
        iprot.skip(ftype)
      iprot.readFieldEnd()
    iprot.readStructEnd()
 

      oprot.writeFieldEnd()
    if self.timestamp is not None:
      oprot.writeFieldBegin('timestamp', TType.I64, 2)
      oprot.writeI64(self.timestamp)
      oprot.writeFieldEnd()
    if self.source is not None:
      oprot.writeFieldBegin('source', TType.I64, 3)
      oprot.writeI64(self.source)
      oprot.writeFieldEnd()
    oprot.writeFieldStop()
    oprot.writeStructEnd()
 
  def validate(self):
    return

Rev 9779	Rev 9816
Line 1023...	Line 1023...
1023	`Parameters:`	1023	`Parameters:`
1024	`- source`	1024	`- source`
1025	`"""`	1025	`"""`
1026	`pass`	1026	`pass`
1027		1027
1028	`def updateMarketPlacePriceUpdateStatus(self, skulist, timestamp):`	1028	`def updateMarketPlacePriceUpdateStatus(self, skulist, timestamp, source):`
1029	`"""`	1029	`"""`
1030	`Parameters:`	1030	`Parameters:`
1031	`- skulist`	1031	`- skulist`
1032	`- timestamp`	1032	`- timestamp`
-		1033	`- source`
1033	`"""`	1034	`"""`
1034	`pass`	1035	`pass`
1035		1036
1036		1037
1037	`class Client(shop2020.thriftpy.generic.GenericService.Client, Iface):`	1038	`class Client(shop2020.thriftpy.generic.GenericService.Client, Iface):`
Line 5371...	Line 5372...
5371	`self._iprot.readMessageEnd()`	5372	`self._iprot.readMessageEnd()`
5372	`if result.success is not None:`	5373	`if result.success is not None:`
5373	`return result.success`	5374	`return result.success`
5374	`raise TApplicationException(TApplicationException.MISSING_RESULT, "getMarketPlaceItemsForPriceUpdate failed: unknown result");`	5375	`raise TApplicationException(TApplicationException.MISSING_RESULT, "getMarketPlaceItemsForPriceUpdate failed: unknown result");`
5375		5376
5376	`def updateMarketPlacePriceUpdateStatus(self, skulist, timestamp):`	5377	`def updateMarketPlacePriceUpdateStatus(self, skulist, timestamp, source):`
5377	`"""`	5378	`"""`
5378	`Parameters:`	5379	`Parameters:`
5379	`- skulist`	5380	`- skulist`
5380	`- timestamp`	5381	`- timestamp`
-		5382	`- source`
5381	`"""`	5383	`"""`
5382	`self.send_updateMarketPlacePriceUpdateStatus(skulist, timestamp)`	5384	`self.send_updateMarketPlacePriceUpdateStatus(skulist, timestamp, source)`
5383	`self.recv_updateMarketPlacePriceUpdateStatus()`	5385	`self.recv_updateMarketPlacePriceUpdateStatus()`
5384		5386
5385	`def send_updateMarketPlacePriceUpdateStatus(self, skulist, timestamp):`	5387	`def send_updateMarketPlacePriceUpdateStatus(self, skulist, timestamp, source):`
5386	`self._oprot.writeMessageBegin('updateMarketPlacePriceUpdateStatus', TMessageType.CALL, self._seqid)`	5388	`self._oprot.writeMessageBegin('updateMarketPlacePriceUpdateStatus', TMessageType.CALL, self._seqid)`
5387	`args = updateMarketPlacePriceUpdateStatus_args()`	5389	`args = updateMarketPlacePriceUpdateStatus_args()`
5388	`args.skulist = skulist`	5390	`args.skulist = skulist`
5389	`args.timestamp = timestamp`	5391	`args.timestamp = timestamp`
-		5392	`args.source = source`
5390	`args.write(self._oprot)`	5393	`args.write(self._oprot)`
5391	`self._oprot.writeMessageEnd()`	5394	`self._oprot.writeMessageEnd()`
5392	`self._oprot.trans.flush()`	5395	`self._oprot.trans.flush()`
5393		5396
5394	`def recv_updateMarketPlacePriceUpdateStatus(self, ):`	5397	`def recv_updateMarketPlacePriceUpdateStatus(self, ):`
Line 7248...	Line 7251...
7248	`def process_updateMarketPlacePriceUpdateStatus(self, seqid, iprot, oprot):`	7251	`def process_updateMarketPlacePriceUpdateStatus(self, seqid, iprot, oprot):`
7249	`args = updateMarketPlacePriceUpdateStatus_args()`	7252	`args = updateMarketPlacePriceUpdateStatus_args()`
7250	`args.read(iprot)`	7253	`args.read(iprot)`
7251	`iprot.readMessageEnd()`	7254	`iprot.readMessageEnd()`
7252	`result = updateMarketPlacePriceUpdateStatus_result()`	7255	`result = updateMarketPlacePriceUpdateStatus_result()`
7253	`self._handler.updateMarketPlacePriceUpdateStatus(args.skulist, args.timestamp)`	7256	`self._handler.updateMarketPlacePriceUpdateStatus(args.skulist, args.timestamp, args.source)`
7254	`oprot.writeMessageBegin("updateMarketPlacePriceUpdateStatus", TMessageType.REPLY, seqid)`	7257	`oprot.writeMessageBegin("updateMarketPlacePriceUpdateStatus", TMessageType.REPLY, seqid)`
7255	`result.write(oprot)`	7258	`result.write(oprot)`
7256	`oprot.writeMessageEnd()`	7259	`oprot.writeMessageEnd()`
7257	`oprot.trans.flush()`	7260	`oprot.trans.flush()`
7258		7261
Line 25223...	Line 25226...
25223	`class updateMarketPlacePriceUpdateStatus_args:`	25226	`class updateMarketPlacePriceUpdateStatus_args:`
25224	`"""`	25227	`"""`
25225	`Attributes:`	25228	`Attributes:`
25226	`- skulist`	25229	`- skulist`
25227	`- timestamp`	25230	`- timestamp`
-		25231	`- source`
25228	`"""`	25232	`"""`
25229		25233
25230	`thrift_spec = (`	25234	`thrift_spec = (`
25231	`None, # 0`	25235	`None, # 0`
25232	`(1, TType.LIST, 'skulist', (TType.I64,None), None, ), # 1`	25236	`(1, TType.LIST, 'skulist', (TType.I64,None), None, ), # 1`
25233	`(2, TType.I64, 'timestamp', None, None, ), # 2`	25237	`(2, TType.I64, 'timestamp', None, None, ), # 2`
-		25238	`(3, TType.I64, 'source', None, None, ), # 3`
25234	`)`	25239	`)`
25235		25240
25236	`def __init__(self, skulist=None, timestamp=None,):`	25241	`def __init__(self, skulist=None, timestamp=None, source=None,):`
25237	`self.skulist = skulist`	25242	`self.skulist = skulist`
25238	`self.timestamp = timestamp`	25243	`self.timestamp = timestamp`
-		25244	`self.source = source`
25239		25245
25240	`def read(self, iprot):`	25246	`def read(self, iprot):`
25241	`if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:`	25247	`if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:`
25242	`fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))`	25248	`fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))`
25243	`return`	25249	`return`
Line 25259...	Line 25265...
25259	`elif fid == 2:`	25265	`elif fid == 2:`
25260	`if ftype == TType.I64:`	25266	`if ftype == TType.I64:`
25261	`self.timestamp = iprot.readI64();`	25267	`self.timestamp = iprot.readI64();`
25262	`else:`	25268	`else:`
25263	`iprot.skip(ftype)`	25269	`iprot.skip(ftype)`
-		25270	`elif fid == 3:`
-		25271	`if ftype == TType.I64:`
-		25272	`self.source = iprot.readI64();`
-		25273	`else:`
-		25274	`iprot.skip(ftype)`
25264	`else:`	25275	`else:`
25265	`iprot.skip(ftype)`	25276	`iprot.skip(ftype)`
25266	`iprot.readFieldEnd()`	25277	`iprot.readFieldEnd()`
25267	`iprot.readStructEnd()`	25278	`iprot.readStructEnd()`
25268		25279
Line 25280...	Line 25291...
25280	`oprot.writeFieldEnd()`	25291	`oprot.writeFieldEnd()`
25281	`if self.timestamp is not None:`	25292	`if self.timestamp is not None:`
25282	`oprot.writeFieldBegin('timestamp', TType.I64, 2)`	25293	`oprot.writeFieldBegin('timestamp', TType.I64, 2)`
25283	`oprot.writeI64(self.timestamp)`	25294	`oprot.writeI64(self.timestamp)`
25284	`oprot.writeFieldEnd()`	25295	`oprot.writeFieldEnd()`
-		25296	`if self.source is not None:`
-		25297	`oprot.writeFieldBegin('source', TType.I64, 3)`
-		25298	`oprot.writeI64(self.source)`
-		25299	`oprot.writeFieldEnd()`
25285	`oprot.writeFieldStop()`	25300	`oprot.writeFieldStop()`
25286	`oprot.writeStructEnd()`	25301	`oprot.writeStructEnd()`
25287		25302
25288	`def validate(self):`	25303	`def validate(self):`
25289	`return`	25304	`return`

Subversion Repositories SmartDukaan

(root)/trunk/PyProj/src/shop2020/thriftpy/model/v1/catalog/CatalogService.py – Rev 9779 → 9816