lifegpc/rssbot
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

新增/status指令

Browse Source
This commit is contained in:
lifegpc
2022-09-04 13:52:01 +00:00
parent 474a2bf22c
commit 07d031c94a
2 changed files with 51 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

35
database.py
View File

@@ -320,6 +320,27 @@ class database:
li.append(BlackInfo(i[0], i[1], i[2], i[3], i[4]))
return li
def getChatCount(self) -> int:
with self._value_lock:
cur = self._db.execute('SELECT COUNT(DISTINCT chatId) FROM chatList;')
for i in cur:
return i[0]
return None
def getChatRSSCount(self) -> int:
with self._value_lock:
cur = self._db.execute('SELECT COUNT(*) FROM chatList;')
for i in cur:
return i[0]
return None
def getHashCount(self) -> int:
with self._value_lock:
cur = self._db.execute('SELECT COUNT(*) FROM hashList;')
for i in cur:
return i[0]
return None
def getRSSByIdAndChatId(self, id: int, chatId: int) -> RSSEntry:
while self._value_lock:
cur = self._db.execute('SELECT RSSList.title, RSSList.url, RSSList.interval, RSSList.lastupdatetime, RSSList.id, RSSList.lasterrortime, RSSList.forceupdate, RSSList.errorcount, RSSList.settings, chatList.config FROM chatList INNER JOIN RSSList ON RSSList.id = chatList.id WHERE chatList.chatId = ? AND chatlist.id = ?;', (chatId, id))
@@ -329,6 +350,13 @@ class database:
return rss
return None
def getRSSCount(self) -> int:
with self._value_lock:
cur = self._db.execute('SELECT COUNT(*) FROM RSSList;')
for i in cur:
return i[0]
return None
def getRSSListByChatId(self, chatId: int) -> List[RSSEntry]:
with self._value_lock:
cur = self._db.execute(
@@ -349,6 +377,13 @@ class database:
except Exception:
return None
def getUserBlackListCount(self) -> int:
with self._value_lock:
cur = self._db.execute('SELECT COUNT(*) FROM userBlackList;')
for i in cur:
return i[0]
return None
def getUserStatus(self, userId: int) -> Tuple[userStatus, str]:
with self._value_lock:
try: