hy/aslan-server
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

电报新增配置开关

Browse Source
This commit is contained in:
tianfeng 2026-01-04 22:50:10 +08:00
parent f4c521e9f0
commit 2bf677ebe3
1 changed files with 14 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
rc-service/rc-service-other/other-application/src/main/java/com/red/circle/other/app/service/TelegramMonitorService.java
View File

@ -44,6 +44,11 @@ public class TelegramMonitorService {
@PostConstruct @PostConstruct
public void init() { public void init() {
if (telegramProperties.getBot() == null || telegramProperties.getBot().getToken() == null) {
log.warn("Telegram 配置未启用，跳过初始化");
return;
}
String botToken = telegramProperties.getBot().getToken(); String botToken = telegramProperties.getBot().getToken();
List<String> chatIds = telegramProperties.getMonitor().getChatIds(); List<String> chatIds = telegramProperties.getMonitor().getChatIds();
int alertLimitSeconds = telegramProperties.getMonitor().getAlertLimitSeconds(); int alertLimitSeconds = telegramProperties.getMonitor().getAlertLimitSeconds();
@ -191,7 +196,16 @@ public class TelegramMonitorService {
* 发送到所有配置的 chatId * 发送到所有配置的 chatId
*/ */
private void sendToAllChats(String message) { private void sendToAllChats(String message) {
if (telegramClient == null) {
log.warn("Telegram 未初始化，跳过发送");
return;
}
List<String> chatIds = telegramProperties.getMonitor().getChatIds(); List<String> chatIds = telegramProperties.getMonitor().getChatIds();
if (chatIds == null || chatIds.isEmpty()) {
log.warn("Telegram chatIds 未配置，跳过发送");
return;
}
for (String chatId : chatIds) { for (String chatId : chatIds) {
sendTextToChat(chatId, message); sendTextToChat(chatId, message);
} }