WebSVN – SmartDukaan – Diff – //trunk/PyProj/src/shop2020/thriftpy/crm/CRMService.py

+#
 # DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
+#
 from thrift.Thrift import *
+import shop2020.thriftpy.generic.GenericService
 from ttypes import *
 from thrift.Thrift import TProcessor
 from thrift.transport import TTransport
 from thrift.protocol import TBinaryProtocol
 try:
   from thrift.protocol import fastbinary
 except:
   fastbinary = None
-class Iface:
+class Iface(shop2020.thriftpy.generic.GenericService.Iface):
   def getTickets(self, customerId):
     """
     Parameters:
      - customerId
     """
     Parameters:
      - agentId
     """
     pass
-  def getOpenTickets(self, ):
+  def getUnassignedTickets(self, ):
+    pass
+  def getAllTickets(self, agentId):
+    """
+    Parameters:
+     - agentId
+    """
     pass
   def getTicket(self, ticketId):
     """
     Parameters:
      - ticketId
     """
     pass
-  def updateTicket(self, ticket):
+  def updateTicket(self, ticket, activity):
     """
     Parameters:
      - ticket
+     - activity
     """
     pass
-  def insertTicket(self, ticket):
+  def insertTicket(self, ticket, activity):
     """
     Parameters:
      - ticket
+     - activity
     """
     pass
   def getActivities(self, customerId):
     """
     Parameters:
      - customerId
     """
     pass
+  def getActivitiesByCreator(self, creatorId):
+    """
+    Parameters:
+     - creatorId
+    """
+    pass
   def getActivitiesForTicket(self, ticketId):
     """
     Parameters:
      - ticketId
     """
     Parameters:
      - roleName
     """
     pass
+  def getLastEmailProcessedTimestamp(self, ):
+    pass
+  def updateLastEmailProcessedTimestamp(self, timestamp):
+    """
+    Parameters:
+     - timestamp
+    """
+    pass
-class Client(Iface):
+class Client(shop2020.thriftpy.generic.GenericService.Client, Iface):
   def __init__(self, iprot, oprot=None):
-    self._iprot = self._oprot = iprot
+    shop2020.thriftpy.generic.GenericService.Client.__init__(self, iprot, oprot)
-    if oprot != None:
-      self._oprot = oprot
-    self._seqid = 0
   def getTickets(self, customerId):
     """
     Parameters:
      - customerId
     self._iprot.readMessageEnd()
     if result.success != None:
       return result.success
     raise TApplicationException(TApplicationException.MISSING_RESULT, "getAssignedTickets failed: unknown result");
-  def getOpenTickets(self, ):
+  def getUnassignedTickets(self, ):
-    self.send_getOpenTickets()
+    self.send_getUnassignedTickets()
-    return self.recv_getOpenTickets()
+    return self.recv_getUnassignedTickets()
+  def send_getUnassignedTickets(self, ):
+    self._oprot.writeMessageBegin('getUnassignedTickets', TMessageType.CALL, self._seqid)
+    args = getUnassignedTickets_args()
+    args.write(self._oprot)
+    self._oprot.writeMessageEnd()
+    self._oprot.trans.flush()
+  def recv_getUnassignedTickets(self, ):
+    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+    if mtype == TMessageType.EXCEPTION:
+      x = TApplicationException()
+      x.read(self._iprot)
+      self._iprot.readMessageEnd()
+      raise x
+    result = getUnassignedTickets_result()
+    result.read(self._iprot)
+    self._iprot.readMessageEnd()
+    if result.success != None:
+      return result.success
+    raise TApplicationException(TApplicationException.MISSING_RESULT, "getUnassignedTickets failed: unknown result");
+  def getAllTickets(self, agentId):
+    """
+    Parameters:
+     - agentId
+    """
+    self.send_getAllTickets(agentId)
+    return self.recv_getAllTickets()
-  def send_getOpenTickets(self, ):
+  def send_getAllTickets(self, agentId):
-    self._oprot.writeMessageBegin('getOpenTickets', TMessageType.CALL, self._seqid)
+    self._oprot.writeMessageBegin('getAllTickets', TMessageType.CALL, self._seqid)
-    args = getOpenTickets_args()
+    args = getAllTickets_args()
+    args.agentId = agentId
     args.write(self._oprot)
     self._oprot.writeMessageEnd()
     self._oprot.trans.flush()
-  def recv_getOpenTickets(self, ):
+  def recv_getAllTickets(self, ):
     (fname, mtype, rseqid) = self._iprot.readMessageBegin()
     if mtype == TMessageType.EXCEPTION:
       x = TApplicationException()
       x.read(self._iprot)
       self._iprot.readMessageEnd()
       raise x
-    result = getOpenTickets_result()
+    result = getAllTickets_result()
     result.read(self._iprot)
     self._iprot.readMessageEnd()
     if result.success != None:
       return result.success
-    raise TApplicationException(TApplicationException.MISSING_RESULT, "getOpenTickets failed: unknown result");
+    raise TApplicationException(TApplicationException.MISSING_RESULT, "getAllTickets failed: unknown result");
   def getTicket(self, ticketId):
     """
     Parameters:
      - ticketId
     self._iprot.readMessageEnd()
     if result.success != None:
       return result.success
     raise TApplicationException(TApplicationException.MISSING_RESULT, "getTicket failed: unknown result");
-  def updateTicket(self, ticket):
+  def updateTicket(self, ticket, activity):
     """
     Parameters:
      - ticket
+     - activity
     """
-    self.send_updateTicket(ticket)
+    self.send_updateTicket(ticket, activity)
     self.recv_updateTicket()
-  def send_updateTicket(self, ticket):
+  def send_updateTicket(self, ticket, activity):
     self._oprot.writeMessageBegin('updateTicket', TMessageType.CALL, self._seqid)
     args = updateTicket_args()
     args.ticket = ticket
+    args.activity = activity
     args.write(self._oprot)
     self._oprot.writeMessageEnd()
     self._oprot.trans.flush()
   def recv_updateTicket(self, ):
     result = updateTicket_result()
     result.read(self._iprot)
     self._iprot.readMessageEnd()
     return
-  def insertTicket(self, ticket):
+  def insertTicket(self, ticket, activity):
     """
     Parameters:
      - ticket
+     - activity
     """
-    self.send_insertTicket(ticket)
+    self.send_insertTicket(ticket, activity)
     return self.recv_insertTicket()
-  def send_insertTicket(self, ticket):
+  def send_insertTicket(self, ticket, activity):
     self._oprot.writeMessageBegin('insertTicket', TMessageType.CALL, self._seqid)
     args = insertTicket_args()
     args.ticket = ticket
+    args.activity = activity
     args.write(self._oprot)
     self._oprot.writeMessageEnd()
     self._oprot.trans.flush()
   def recv_insertTicket(self, ):
     self._iprot.readMessageEnd()
     if result.success != None:
       return result.success
     raise TApplicationException(TApplicationException.MISSING_RESULT, "getActivities failed: unknown result");
+  def getActivitiesByCreator(self, creatorId):
+    """
+    Parameters:
+     - creatorId
+    """
+    self.send_getActivitiesByCreator(creatorId)
+    return self.recv_getActivitiesByCreator()
+  def send_getActivitiesByCreator(self, creatorId):
+    self._oprot.writeMessageBegin('getActivitiesByCreator', TMessageType.CALL, self._seqid)
+    args = getActivitiesByCreator_args()
+    args.creatorId = creatorId
+    args.write(self._oprot)
+    self._oprot.writeMessageEnd()
+    self._oprot.trans.flush()
+  def recv_getActivitiesByCreator(self, ):
+    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+    if mtype == TMessageType.EXCEPTION:
+      x = TApplicationException()
+      x.read(self._iprot)
+      self._iprot.readMessageEnd()
+      raise x
+    result = getActivitiesByCreator_result()
+    result.read(self._iprot)
+    self._iprot.readMessageEnd()
+    if result.success != None:
+      return result.success
+    raise TApplicationException(TApplicationException.MISSING_RESULT, "getActivitiesByCreator failed: unknown result");
   def getActivitiesForTicket(self, ticketId):
     """
     Parameters:
      - ticketId
     """
     self._iprot.readMessageEnd()
     if result.success != None:
       return result.success
     raise TApplicationException(TApplicationException.MISSING_RESULT, "getPermissionsForRoleName failed: unknown result");
+  def getLastEmailProcessedTimestamp(self, ):
+    self.send_getLastEmailProcessedTimestamp()
+    return self.recv_getLastEmailProcessedTimestamp()
+  def send_getLastEmailProcessedTimestamp(self, ):
+    self._oprot.writeMessageBegin('getLastEmailProcessedTimestamp', TMessageType.CALL, self._seqid)
+    args = getLastEmailProcessedTimestamp_args()
+    args.write(self._oprot)
+    self._oprot.writeMessageEnd()
+    self._oprot.trans.flush()
+  def recv_getLastEmailProcessedTimestamp(self, ):
+    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+    if mtype == TMessageType.EXCEPTION:
+      x = TApplicationException()
+      x.read(self._iprot)
+      self._iprot.readMessageEnd()
+      raise x
+    result = getLastEmailProcessedTimestamp_result()
+    result.read(self._iprot)
+    self._iprot.readMessageEnd()
-class Processor(Iface, TProcessor):
+    if result.success != None:
+      return result.success
+    raise TApplicationException(TApplicationException.MISSING_RESULT, "getLastEmailProcessedTimestamp failed: unknown result");
+  def updateLastEmailProcessedTimestamp(self, timestamp):
+    """
+    Parameters:
+     - timestamp
+    """
+    self.send_updateLastEmailProcessedTimestamp(timestamp)
+    self.recv_updateLastEmailProcessedTimestamp()
+  def send_updateLastEmailProcessedTimestamp(self, timestamp):
+    self._oprot.writeMessageBegin('updateLastEmailProcessedTimestamp', TMessageType.CALL, self._seqid)
+    args = updateLastEmailProcessedTimestamp_args()
+    args.timestamp = timestamp
+    args.write(self._oprot)
+    self._oprot.writeMessageEnd()
+    self._oprot.trans.flush()
+  def recv_updateLastEmailProcessedTimestamp(self, ):
+    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+    if mtype == TMessageType.EXCEPTION:
+      x = TApplicationException()
+      x.read(self._iprot)
+      self._iprot.readMessageEnd()
+      raise x
+    result = updateLastEmailProcessedTimestamp_result()
+    result.read(self._iprot)
+    self._iprot.readMessageEnd()
+    return
+class Processor(shop2020.thriftpy.generic.GenericService.Processor, Iface, TProcessor):
   def __init__(self, handler):
-    self._handler = handler
+    shop2020.thriftpy.generic.GenericService.Processor.__init__(self, handler)
-    self._processMap = {}
     self._processMap["getTickets"] = Processor.process_getTickets
     self._processMap["getAssignedTickets"] = Processor.process_getAssignedTickets
+    self._processMap["getUnassignedTickets"] = Processor.process_getUnassignedTickets
-    self._processMap["getOpenTickets"] = Processor.process_getOpenTickets
+    self._processMap["getAllTickets"] = Processor.process_getAllTickets
     self._processMap["getTicket"] = Processor.process_getTicket
     self._processMap["updateTicket"] = Processor.process_updateTicket
     self._processMap["insertTicket"] = Processor.process_insertTicket
     self._processMap["getActivities"] = Processor.process_getActivities
+    self._processMap["getActivitiesByCreator"] = Processor.process_getActivitiesByCreator
     self._processMap["getActivitiesForTicket"] = Processor.process_getActivitiesForTicket
     self._processMap["getActivity"] = Processor.process_getActivity
     self._processMap["getLastActivity"] = Processor.process_getLastActivity
     self._processMap["insertActivity"] = Processor.process_insertActivity
     self._processMap["getAllAgents"] = Processor.process_getAllAgents
     self._processMap["getAgent"] = Processor.process_getAgent
     self._processMap["getAgentByEmailId"] = Processor.process_getAgentByEmailId
     self._processMap["updatePasswordForAgent"] = Processor.process_updatePasswordForAgent
     self._processMap["getRoleNamesForAgent"] = Processor.process_getRoleNamesForAgent
     self._processMap["getPermissionsForRoleName"] = Processor.process_getPermissionsForRoleName
+    self._processMap["getLastEmailProcessedTimestamp"] = Processor.process_getLastEmailProcessedTimestamp
+    self._processMap["updateLastEmailProcessedTimestamp"] = Processor.process_updateLastEmailProcessedTimestamp
   def process(self, iprot, oprot):
     (name, type, seqid) = iprot.readMessageBegin()
     if name not in self._processMap:
       iprot.skip(TType.STRUCT)
     oprot.writeMessageBegin("getAssignedTickets", TMessageType.REPLY, seqid)
     result.write(oprot)
     oprot.writeMessageEnd()
     oprot.trans.flush()
+  def process_getUnassignedTickets(self, seqid, iprot, oprot):
+    args = getUnassignedTickets_args()
+    args.read(iprot)
+    iprot.readMessageEnd()
+    result = getUnassignedTickets_result()
+    result.success = self._handler.getUnassignedTickets()
+    oprot.writeMessageBegin("getUnassignedTickets", TMessageType.REPLY, seqid)
+    result.write(oprot)
+    oprot.writeMessageEnd()
+    oprot.trans.flush()
-  def process_getOpenTickets(self, seqid, iprot, oprot):
+  def process_getAllTickets(self, seqid, iprot, oprot):
-    args = getOpenTickets_args()
+    args = getAllTickets_args()
     args.read(iprot)
     iprot.readMessageEnd()
-    result = getOpenTickets_result()
+    result = getAllTickets_result()
-    result.success = self._handler.getOpenTickets()
+    result.success = self._handler.getAllTickets(args.agentId)
-    oprot.writeMessageBegin("getOpenTickets", TMessageType.REPLY, seqid)
+    oprot.writeMessageBegin("getAllTickets", TMessageType.REPLY, seqid)
     result.write(oprot)
     oprot.writeMessageEnd()
     oprot.trans.flush()
   def process_getTicket(self, seqid, iprot, oprot):
   def process_updateTicket(self, seqid, iprot, oprot):
     args = updateTicket_args()
     args.read(iprot)
     iprot.readMessageEnd()
     result = updateTicket_result()
-    self._handler.updateTicket(args.ticket)
+    self._handler.updateTicket(args.ticket, args.activity)
     oprot.writeMessageBegin("updateTicket", TMessageType.REPLY, seqid)
     result.write(oprot)
     oprot.writeMessageEnd()
     oprot.trans.flush()
   def process_insertTicket(self, seqid, iprot, oprot):
     args = insertTicket_args()
     args.read(iprot)
     iprot.readMessageEnd()
     result = insertTicket_result()
-    result.success = self._handler.insertTicket(args.ticket)
+    result.success = self._handler.insertTicket(args.ticket, args.activity)
     oprot.writeMessageBegin("insertTicket", TMessageType.REPLY, seqid)
     result.write(oprot)
     oprot.writeMessageEnd()
     oprot.trans.flush()
     oprot.writeMessageBegin("getActivities", TMessageType.REPLY, seqid)
     result.write(oprot)
     oprot.writeMessageEnd()
     oprot.trans.flush()
+  def process_getActivitiesByCreator(self, seqid, iprot, oprot):
+    args = getActivitiesByCreator_args()
+    args.read(iprot)
+    iprot.readMessageEnd()
+    result = getActivitiesByCreator_result()
+    result.success = self._handler.getActivitiesByCreator(args.creatorId)
+    oprot.writeMessageBegin("getActivitiesByCreator", TMessageType.REPLY, seqid)
+    result.write(oprot)
+    oprot.writeMessageEnd()
+    oprot.trans.flush()
   def process_getActivitiesForTicket(self, seqid, iprot, oprot):
     args = getActivitiesForTicket_args()
     args.read(iprot)
     iprot.readMessageEnd()
     result = getActivitiesForTicket_result()
     oprot.writeMessageBegin("getPermissionsForRoleName", TMessageType.REPLY, seqid)
     result.write(oprot)
     oprot.writeMessageEnd()
     oprot.trans.flush()
+  def process_getLastEmailProcessedTimestamp(self, seqid, iprot, oprot):
+    args = getLastEmailProcessedTimestamp_args()
+    args.read(iprot)
+    iprot.readMessageEnd()
+    result = getLastEmailProcessedTimestamp_result()
+    result.success = self._handler.getLastEmailProcessedTimestamp()
+    oprot.writeMessageBegin("getLastEmailProcessedTimestamp", TMessageType.REPLY, seqid)
+    result.write(oprot)
+    oprot.writeMessageEnd()
+    oprot.trans.flush()
+  def process_updateLastEmailProcessedTimestamp(self, seqid, iprot, oprot):
+    args = updateLastEmailProcessedTimestamp_args()
+    args.read(iprot)
+    iprot.readMessageEnd()
+    result = updateLastEmailProcessedTimestamp_result()
+    self._handler.updateLastEmailProcessedTimestamp(args.timestamp)
+    oprot.writeMessageBegin("updateLastEmailProcessedTimestamp", TMessageType.REPLY, seqid)
+    result.write(oprot)
+    oprot.writeMessageEnd()
+    oprot.trans.flush()
 # HELPER FUNCTIONS AND STRUCTURES
 class getTickets_args:
   """
     return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
   def __ne__(self, other):
     return not (self == other)
-class getOpenTickets_args:
+class getUnassignedTickets_args:
   thrift_spec = (
+  )
   def read(self, iprot):
   def write(self, oprot):
     if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
       oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
       return
-    oprot.writeStructBegin('getOpenTickets_args')
+    oprot.writeStructBegin('getUnassignedTickets_args')
     oprot.writeFieldStop()
     oprot.writeStructEnd()
   def __repr__(self):
     L = ['%s=%r' % (key, value)
     return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
   def __ne__(self, other):
     return not (self == other)
-class getOpenTickets_result:
+class getUnassignedTickets_result:
   """
   Attributes:
    - success
   """
   def write(self, oprot):
     if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
       oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
       return
-    oprot.writeStructBegin('getOpenTickets_result')
+    oprot.writeStructBegin('getUnassignedTickets_result')
     if self.success != None:
       oprot.writeFieldBegin('success', TType.LIST, 0)
       oprot.writeListBegin(TType.STRUCT, len(self.success))
       for iter20 in self.success:
         iter20.write(oprot)
     return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
   def __ne__(self, other):
     return not (self == other)
+class getAllTickets_args:
+  """
+  Attributes:
+   - agentId
+  """
+  thrift_spec = (
+    None, # 0
+    (1, TType.I64, 'agentId', None, None, ), # 1
+  )
+  def __init__(self, agentId=None,):
+    self.agentId = agentId
+  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
+    iprot.readStructBegin()
+    while True:
+      (fname, ftype, fid) = iprot.readFieldBegin()
+      if ftype == TType.STOP:
+        break
+      if fid == 1:
+        if ftype == TType.I64:
+          self.agentId = iprot.readI64();
+        else:
+          iprot.skip(ftype)
+      else:
+        iprot.skip(ftype)
+      iprot.readFieldEnd()
+    iprot.readStructEnd()
+  def write(self, oprot):
+    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
+      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
+      return
+    oprot.writeStructBegin('getAllTickets_args')
+    if self.agentId != None:
+      oprot.writeFieldBegin('agentId', TType.I64, 1)
+      oprot.writeI64(self.agentId)
+      oprot.writeFieldEnd()
+    oprot.writeFieldStop()
+    oprot.writeStructEnd()
+  def __repr__(self):
+    L = ['%s=%r' % (key, value)
+      for key, value in self.__dict__.iteritems()]
+    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
+  def __eq__(self, other):
+    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
+  def __ne__(self, other):
+    return not (self == other)
+class getAllTickets_result:
+  """
+  Attributes:
+   - success
+  """
+  thrift_spec = (
+    (0, TType.LIST, 'success', (TType.STRUCT,(Ticket, Ticket.thrift_spec)), None, ), # 0
+  )
+  def __init__(self, success=None,):
+    self.success = success
+  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
+    iprot.readStructBegin()
+    while True:
+      (fname, ftype, fid) = iprot.readFieldBegin()
+      if ftype == TType.STOP:
+        break
+      if fid == 0:
+        if ftype == TType.LIST:
+          self.success = []
+          (_etype24, _size21) = iprot.readListBegin()
+          for _i25 in xrange(_size21):
+            _elem26 = Ticket()
+            _elem26.read(iprot)
+            self.success.append(_elem26)
+          iprot.readListEnd()
+        else:
+          iprot.skip(ftype)
+      else:
+        iprot.skip(ftype)
+      iprot.readFieldEnd()
+    iprot.readStructEnd()
+  def write(self, oprot):
+    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
+      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
+      return
+    oprot.writeStructBegin('getAllTickets_result')
+    if self.success != None:
+      oprot.writeFieldBegin('success', TType.LIST, 0)
+      oprot.writeListBegin(TType.STRUCT, len(self.success))
+      for iter27 in self.success:
+        iter27.write(oprot)
+      oprot.writeListEnd()
+      oprot.writeFieldEnd()
+    oprot.writeFieldStop()
+    oprot.writeStructEnd()
+  def __repr__(self):
+    L = ['%s=%r' % (key, value)
+      for key, value in self.__dict__.iteritems()]
+    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
+  def __eq__(self, other):
+    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
+  def __ne__(self, other):
+    return not (self == other)
 class getTicket_args:
   """
   Attributes:
    - ticketId
   """
 class updateTicket_args:
   """
   Attributes:
    - ticket
+   - activity
   """
   thrift_spec = (
     None, # 0
     (1, TType.STRUCT, 'ticket', (Ticket, Ticket.thrift_spec), None, ), # 1
+    (2, TType.STRUCT, 'activity', (Activity, Activity.thrift_spec), None, ), # 2
+  )
-  def __init__(self, ticket=None,):
+  def __init__(self, ticket=None, activity=None,):
     self.ticket = ticket
+    self.activity = activity
   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
         if ftype == TType.STRUCT:
           self.ticket = Ticket()
           self.ticket.read(iprot)
         else:
           iprot.skip(ftype)
+      elif fid == 2:
+        if ftype == TType.STRUCT:
+          self.activity = Activity()
+          self.activity.read(iprot)
+        else:
+          iprot.skip(ftype)
       else:
         iprot.skip(ftype)
       iprot.readFieldEnd()
     iprot.readStructEnd()
     oprot.writeStructBegin('updateTicket_args')
     if self.ticket != None:
       oprot.writeFieldBegin('ticket', TType.STRUCT, 1)
       self.ticket.write(oprot)
       oprot.writeFieldEnd()
+    if self.activity != None:
+      oprot.writeFieldBegin('activity', TType.STRUCT, 2)
+      self.activity.write(oprot)
+      oprot.writeFieldEnd()
     oprot.writeFieldStop()
     oprot.writeStructEnd()
   def __repr__(self):
     L = ['%s=%r' % (key, value)
 class insertTicket_args:
   """
   Attributes:
    - ticket
+   - activity
   """
   thrift_spec = (
     None, # 0
     (1, TType.STRUCT, 'ticket', (Ticket, Ticket.thrift_spec), None, ), # 1
+    (2, TType.STRUCT, 'activity', (Activity, Activity.thrift_spec), None, ), # 2
+  )
-  def __init__(self, ticket=None,):
+  def __init__(self, ticket=None, activity=None,):
     self.ticket = ticket
+    self.activity = activity
   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
         if ftype == TType.STRUCT:
           self.ticket = Ticket()
           self.ticket.read(iprot)
         else:
           iprot.skip(ftype)
+      elif fid == 2:
+        if ftype == TType.STRUCT:
+          self.activity = Activity()
+          self.activity.read(iprot)
+        else:
+          iprot.skip(ftype)
       else:
         iprot.skip(ftype)
       iprot.readFieldEnd()
     iprot.readStructEnd()
     oprot.writeStructBegin('insertTicket_args')
     if self.ticket != None:
       oprot.writeFieldBegin('ticket', TType.STRUCT, 1)
       self.ticket.write(oprot)
       oprot.writeFieldEnd()
+    if self.activity != None:
+      oprot.writeFieldBegin('activity', TType.STRUCT, 2)
+      self.activity.write(oprot)
+      oprot.writeFieldEnd()
     oprot.writeFieldStop()
     oprot.writeStructEnd()
   def __repr__(self):
     L = ['%s=%r' % (key, value)
       if ftype == TType.STOP:
         break
       if fid == 0:
         if ftype == TType.LIST:
           self.success = []
-          (_etype24, _size21) = iprot.readListBegin()
+          (_etype31, _size28) = iprot.readListBegin()
-          for _i25 in xrange(_size21):
+          for _i32 in xrange(_size28):
-            _elem26 = Activity()
+            _elem33 = Activity()
-            _elem26.read(iprot)
+            _elem33.read(iprot)
-            self.success.append(_elem26)
+            self.success.append(_elem33)
           iprot.readListEnd()
         else:
           iprot.skip(ftype)
       else:
         iprot.skip(ftype)
       return
     oprot.writeStructBegin('getActivities_result')
     if self.success != None:
       oprot.writeFieldBegin('success', TType.LIST, 0)
       oprot.writeListBegin(TType.STRUCT, len(self.success))
+      for iter34 in self.success:
+        iter34.write(oprot)
+      oprot.writeListEnd()
+      oprot.writeFieldEnd()
+    oprot.writeFieldStop()
+    oprot.writeStructEnd()
+  def __repr__(self):
+    L = ['%s=%r' % (key, value)
+      for key, value in self.__dict__.iteritems()]
+    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
+  def __eq__(self, other):
+    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
+  def __ne__(self, other):
+    return not (self == other)
+class getActivitiesByCreator_args:
+  """
+  Attributes:
+   - creatorId
+  """
+  thrift_spec = (
+    None, # 0
+    (1, TType.I64, 'creatorId', None, None, ), # 1
+  )
+  def __init__(self, creatorId=None,):
+    self.creatorId = creatorId
+  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
+    iprot.readStructBegin()
+    while True:
+      (fname, ftype, fid) = iprot.readFieldBegin()
+      if ftype == TType.STOP:
+        break
+      if fid == 1:
+        if ftype == TType.I64:
+          self.creatorId = iprot.readI64();
+        else:
+          iprot.skip(ftype)
+      else:
+        iprot.skip(ftype)
+      iprot.readFieldEnd()
+    iprot.readStructEnd()
+  def write(self, oprot):
+    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
+      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
+      return
+    oprot.writeStructBegin('getActivitiesByCreator_args')
+    if self.creatorId != None:
+      oprot.writeFieldBegin('creatorId', TType.I64, 1)
+      oprot.writeI64(self.creatorId)
+      oprot.writeFieldEnd()
+    oprot.writeFieldStop()
+    oprot.writeStructEnd()
+  def __repr__(self):
+    L = ['%s=%r' % (key, value)
+      for key, value in self.__dict__.iteritems()]
+    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
+  def __eq__(self, other):
+    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
+  def __ne__(self, other):
+    return not (self == other)
+class getActivitiesByCreator_result:
+  """
+  Attributes:
+   - success
+  """
+  thrift_spec = (
+    (0, TType.LIST, 'success', (TType.STRUCT,(Activity, Activity.thrift_spec)), None, ), # 0
+  )
+  def __init__(self, success=None,):
+    self.success = success
+  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
+    iprot.readStructBegin()
+    while True:
+      (fname, ftype, fid) = iprot.readFieldBegin()
+      if ftype == TType.STOP:
+        break
+      if fid == 0:
+        if ftype == TType.LIST:
+          self.success = []
+          (_etype38, _size35) = iprot.readListBegin()
+          for _i39 in xrange(_size35):
+            _elem40 = Activity()
+            _elem40.read(iprot)
+            self.success.append(_elem40)
+          iprot.readListEnd()
+        else:
+          iprot.skip(ftype)
+      else:
+        iprot.skip(ftype)
+      iprot.readFieldEnd()
+    iprot.readStructEnd()
+  def write(self, oprot):
+    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
+      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
+      return
+    oprot.writeStructBegin('getActivitiesByCreator_result')
+    if self.success != None:
+      oprot.writeFieldBegin('success', TType.LIST, 0)
+      oprot.writeListBegin(TType.STRUCT, len(self.success))
-      for iter27 in self.success:
+      for iter41 in self.success:
-        iter27.write(oprot)
+        iter41.write(oprot)
       oprot.writeListEnd()
       oprot.writeFieldEnd()
     oprot.writeFieldStop()
     oprot.writeStructEnd()
       if ftype == TType.STOP:
         break
       if fid == 0:
         if ftype == TType.LIST:
           self.success = []
-          (_etype31, _size28) = iprot.readListBegin()
+          (_etype45, _size42) = iprot.readListBegin()
-          for _i32 in xrange(_size28):
+          for _i46 in xrange(_size42):
-            _elem33 = Activity()
+            _elem47 = Activity()
-            _elem33.read(iprot)
+            _elem47.read(iprot)
-            self.success.append(_elem33)
+            self.success.append(_elem47)
           iprot.readListEnd()
         else:
           iprot.skip(ftype)
       else:
         iprot.skip(ftype)
       return
     oprot.writeStructBegin('getActivitiesForTicket_result')
     if self.success != None:
       oprot.writeFieldBegin('success', TType.LIST, 0)
       oprot.writeListBegin(TType.STRUCT, len(self.success))
-      for iter34 in self.success:
+      for iter48 in self.success:
-        iter34.write(oprot)
+        iter48.write(oprot)
       oprot.writeListEnd()
       oprot.writeFieldEnd()
     oprot.writeFieldStop()
     oprot.writeStructEnd()
       if ftype == TType.STOP:
         break
       if fid == 0:
         if ftype == TType.LIST:
           self.success = []
-          (_etype38, _size35) = iprot.readListBegin()
+          (_etype52, _size49) = iprot.readListBegin()
-          for _i39 in xrange(_size35):
+          for _i53 in xrange(_size49):
-            _elem40 = Agent()
+            _elem54 = Agent()
-            _elem40.read(iprot)
+            _elem54.read(iprot)
-            self.success.append(_elem40)
+            self.success.append(_elem54)
           iprot.readListEnd()
         else:
           iprot.skip(ftype)
       else:
         iprot.skip(ftype)
       return
     oprot.writeStructBegin('getAllAgents_result')
     if self.success != None:
       oprot.writeFieldBegin('success', TType.LIST, 0)
       oprot.writeListBegin(TType.STRUCT, len(self.success))
-      for iter41 in self.success:
+      for iter55 in self.success:
-        iter41.write(oprot)
+        iter55.write(oprot)
       oprot.writeListEnd()
       oprot.writeFieldEnd()
     oprot.writeFieldStop()
     oprot.writeStructEnd()
       if ftype == TType.STOP:
         break
       if fid == 0:
         if ftype == TType.LIST:
           self.success = []
-          (_etype45, _size42) = iprot.readListBegin()
+          (_etype59, _size56) = iprot.readListBegin()
-          for _i46 in xrange(_size42):
+          for _i60 in xrange(_size56):
-            _elem47 = iprot.readString();
+            _elem61 = iprot.readString();
-            self.success.append(_elem47)
+            self.success.append(_elem61)
           iprot.readListEnd()
         else:
           iprot.skip(ftype)
       else:
         iprot.skip(ftype)
       return
     oprot.writeStructBegin('getRoleNamesForAgent_result')
     if self.success != None:
       oprot.writeFieldBegin('success', TType.LIST, 0)
       oprot.writeListBegin(TType.STRING, len(self.success))
-      for iter48 in self.success:
+      for iter62 in self.success:
-        oprot.writeString(iter48)
+        oprot.writeString(iter62)
       oprot.writeListEnd()
       oprot.writeFieldEnd()
     oprot.writeFieldStop()
     oprot.writeStructEnd()
       if ftype == TType.STOP:
         break
       if fid == 0:
         if ftype == TType.LIST:
           self.success = []
-          (_etype52, _size49) = iprot.readListBegin()
+          (_etype66, _size63) = iprot.readListBegin()
-          for _i53 in xrange(_size49):
+          for _i67 in xrange(_size63):
-            _elem54 = iprot.readString();
+            _elem68 = iprot.readString();
-            self.success.append(_elem54)
+            self.success.append(_elem68)
           iprot.readListEnd()
         else:
           iprot.skip(ftype)
       else:
         iprot.skip(ftype)
       return
     oprot.writeStructBegin('getPermissionsForRoleName_result')
     if self.success != None:
       oprot.writeFieldBegin('success', TType.LIST, 0)
       oprot.writeListBegin(TType.STRING, len(self.success))
-      for iter55 in self.success:
+      for iter69 in self.success:
-        oprot.writeString(iter55)
+        oprot.writeString(iter69)
       oprot.writeListEnd()
       oprot.writeFieldEnd()
     oprot.writeFieldStop()
     oprot.writeStructEnd()
   def __repr__(self):
     L = ['%s=%r' % (key, value)
+      for key, value in self.__dict__.iteritems()]
+    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
+  def __eq__(self, other):
+    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
+  def __ne__(self, other):
+    return not (self == other)
+class getLastEmailProcessedTimestamp_args:
+  thrift_spec = (
+  )
+  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
+    iprot.readStructBegin()
+    while True:
+      (fname, ftype, fid) = iprot.readFieldBegin()
+      if ftype == TType.STOP:
+        break
+      else:
+        iprot.skip(ftype)
+      iprot.readFieldEnd()
+    iprot.readStructEnd()
+  def write(self, oprot):
+    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
+      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
+      return
+    oprot.writeStructBegin('getLastEmailProcessedTimestamp_args')
+    oprot.writeFieldStop()
+    oprot.writeStructEnd()
+  def __repr__(self):
+    L = ['%s=%r' % (key, value)
+      for key, value in self.__dict__.iteritems()]
+    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
+  def __eq__(self, other):
+    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
+  def __ne__(self, other):
+    return not (self == other)
+class getLastEmailProcessedTimestamp_result:
+  """
+  Attributes:
+   - success
+  """
+  thrift_spec = (
+    (0, TType.I64, 'success', None, None, ), # 0
+  )
+  def __init__(self, success=None,):
+    self.success = success
+  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
+    iprot.readStructBegin()
+    while True:
+      (fname, ftype, fid) = iprot.readFieldBegin()
+      if ftype == TType.STOP:
+        break
+      if fid == 0:
+        if ftype == TType.I64:
+          self.success = iprot.readI64();
+        else:
+          iprot.skip(ftype)
+      else:
+        iprot.skip(ftype)
+      iprot.readFieldEnd()
+    iprot.readStructEnd()
+  def write(self, oprot):
+    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
+      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
+      return
+    oprot.writeStructBegin('getLastEmailProcessedTimestamp_result')
+    if self.success != None:
+      oprot.writeFieldBegin('success', TType.I64, 0)
+      oprot.writeI64(self.success)
+      oprot.writeFieldEnd()
+    oprot.writeFieldStop()
+    oprot.writeStructEnd()
+  def __repr__(self):
+    L = ['%s=%r' % (key, value)
+      for key, value in self.__dict__.iteritems()]
+    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
+  def __eq__(self, other):
+    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
+  def __ne__(self, other):
+    return not (self == other)
+class updateLastEmailProcessedTimestamp_args:
+  """
+  Attributes:
+   - timestamp
+  """
+  thrift_spec = (
+    None, # 0
+    (1, TType.I64, 'timestamp', None, None, ), # 1
+  )
+  def __init__(self, timestamp=None,):
+    self.timestamp = timestamp
+  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
+    iprot.readStructBegin()
+    while True:
+      (fname, ftype, fid) = iprot.readFieldBegin()
+      if ftype == TType.STOP:
+        break
+      if fid == 1:
+        if ftype == TType.I64:
+          self.timestamp = iprot.readI64();
+        else:
+          iprot.skip(ftype)
+      else:
+        iprot.skip(ftype)
+      iprot.readFieldEnd()
+    iprot.readStructEnd()
+  def write(self, oprot):
+    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
+      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
+      return
+    oprot.writeStructBegin('updateLastEmailProcessedTimestamp_args')
+    if self.timestamp != None:
+      oprot.writeFieldBegin('timestamp', TType.I64, 1)
+      oprot.writeI64(self.timestamp)
+      oprot.writeFieldEnd()
+    oprot.writeFieldStop()
+    oprot.writeStructEnd()
+  def __repr__(self):
+    L = ['%s=%r' % (key, value)
+      for key, value in self.__dict__.iteritems()]
+    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
+  def __eq__(self, other):
+    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
+  def __ne__(self, other):
+    return not (self == other)
+class updateLastEmailProcessedTimestamp_result:
+  thrift_spec = (
+  )
+  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
+    iprot.readStructBegin()
+    while True:
+      (fname, ftype, fid) = iprot.readFieldBegin()
+      if ftype == TType.STOP:
+        break
+      else:
+        iprot.skip(ftype)
+      iprot.readFieldEnd()
+    iprot.readStructEnd()
+  def write(self, oprot):
+    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
+      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
+      return
+    oprot.writeStructBegin('updateLastEmailProcessedTimestamp_result')
+    oprot.writeFieldStop()
+    oprot.writeStructEnd()
+  def __repr__(self):
+    L = ['%s=%r' % (key, value)
       for key, value in self.__dict__.iteritems()]
     return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
   def __eq__(self, other):
     return isinstance(other, self.__class__) and self.__dict__ == other.__dict__

Subversion Repositories SmartDukaan

(root)//trunk/PyProj/src/shop2020/thriftpy/crm/CRMService.py – Rev 3131 → 3376