mirror of
https://github.com/wtc86939209/WeChatMsg110.git
synced 2026-05-19 19:00:39 +08:00
@@ -87,6 +87,24 @@ class Msg:
|
||||
result.sort(key=lambda x: x[5])
|
||||
return result
|
||||
|
||||
def get_messages_length(self):
|
||||
sql = '''
|
||||
select count(*)
|
||||
from MSG
|
||||
'''
|
||||
if not self.open_flag:
|
||||
return None
|
||||
try:
|
||||
lock.acquire(True)
|
||||
self.cursor.execute(sql)
|
||||
result = self.cursor.fetchone()
|
||||
except Exception as e:
|
||||
result = None
|
||||
finally:
|
||||
lock.release()
|
||||
return result[0]
|
||||
|
||||
|
||||
def get_message_by_num(self, username_, local_id):
|
||||
sql = '''
|
||||
select localId,TalkerId,Type,SubType,IsSender,CreateTime,Status,StrContent,strftime('%Y-%m-%d %H:%M:%S',CreateTime,'unixepoch','localtime') as StrTime
|
||||
|
||||
Reference in New Issue
Block a user