支持重新发送
This commit is contained in:
@@ -33,3 +33,4 @@ class settings:
|
|||||||
) and int(d['minTTL']) >= 1 else 5
|
) and int(d['minTTL']) >= 1 else 5
|
||||||
self._maxTTL = int(d['maxTTL']) if 'maxTTL' in d and d['maxTTL'].isnumeric(
|
self._maxTTL = int(d['maxTTL']) if 'maxTTL' in d and d['maxTTL'].isnumeric(
|
||||||
) and int(d['maxTTL']) >= self._minTTL else max(1440, self._minTTL)
|
) and int(d['maxTTL']) >= self._minTTL else max(1440, self._minTTL)
|
||||||
|
self._maxRetryCount = int(d['maxRetryCount']) if 'maxRetryCount' in d and d['maxRetryCount'].isnumeric() and int(d['maxRetryCount']) >= 0 else 3
|
||||||
|
|||||||
@@ -39,8 +39,15 @@ class RSSCheckerThread(Thread):
|
|||||||
for info in rss.chatList:
|
for info in rss.chatList:
|
||||||
chatEntry: ChatEntry = info
|
chatEntry: ChatEntry = info
|
||||||
try:
|
try:
|
||||||
self._main._sendMessage(
|
for i in range(self._main._setting._maxRetryCount + 1):
|
||||||
chatEntry.chatId, meta, item, chatEntry.config)
|
if self._main._sendMessage(chatEntry.chatId, meta, item, chatEntry.config):
|
||||||
|
break
|
||||||
|
sleep(5)
|
||||||
|
if i < self._main._setting._maxRetryCount:
|
||||||
|
print(f'开始第{i+i}次重试')
|
||||||
|
else:
|
||||||
|
self._main._request('sendMessage', 'post', {
|
||||||
|
'chat_id': chatEntry.chatId, 'text': f'已尝试重发{i}次,发送失败。'})
|
||||||
except:
|
except:
|
||||||
print(format_exc())
|
print(format_exc())
|
||||||
self._main._db.updateRSS(
|
self._main._db.updateRSS(
|
||||||
|
|||||||
Reference in New Issue
Block a user