Alex-Devera/3x-ui
1
0
Fork 0
mirror of https://github.com/MHSanaei/3x-ui.git synced 2025-09-07 10:46:19 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

[tgbot] Fix Notify

Browse source
This commit is contained in:
somebodywashere 2023-12-25 22:33:02 +03:00
parent 9b5ace0cc7
commit 719ebef037
1 changed files with 3 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
web/service/tgbot.go
View file

@ -1377,8 +1377,6 @@ func (t *Tgbot) notifyExhausted() {
trDiff := int64(0) trDiff := int64(0)
exDiff := int64(0) exDiff := int64(0)
now := time.Now().Unix() * 1000 now := time.Now().Unix() * 1000
var disabledClients []xray.ClientTraffic
var exhaustedClients []xray.ClientTraffic
TrafficThreshold, err := t.settingService.GetTrafficDiff() TrafficThreshold, err := t.settingService.GetTrafficDiff()
if err == nil && TrafficThreshold > 0 { if err == nil && TrafficThreshold > 0 {
@ -1393,12 +1391,12 @@ func (t *Tgbot) notifyExhausted() {
logger.Warning("Unable to load Inbounds", err) logger.Warning("Unable to load Inbounds", err)
} }
var chatIDsDone []string
for _, inbound := range inbounds { for _, inbound := range inbounds {
if inbound.Enable { if inbound.Enable {
if len(inbound.ClientStats) > 0 { if len(inbound.ClientStats) > 0 {
clients, err := t.inboundService.GetClients(inbound) clients, err := t.inboundService.GetClients(inbound)
if err == nil { if err == nil {
var chatIDsDone []string
for _, client := range clients { for _, client := range clients {
if client.TgID != "" { if client.TgID != "" {
chatID, err := strconv.ParseInt(client.TgID, 10, 64) chatID, err := strconv.ParseInt(client.TgID, 10, 64)
@ -1407,6 +1405,8 @@ func (t *Tgbot) notifyExhausted() {
continue continue
} }
if !slices.Contains(chatIDsDone, client.TgID) && !checkAdmin(chatID) { if !slices.Contains(chatIDsDone, client.TgID) && !checkAdmin(chatID) {
var disabledClients []xray.ClientTraffic
var exhaustedClients []xray.ClientTraffic
traffics, err := t.inboundService.GetClientTrafficTgBot(client.TgID) traffics, err := t.inboundService.GetClientTrafficTgBot(client.TgID)
if err == nil { if err == nil {
output := t.I18nBot("tgbot.messages.exhaustedCount", "Type=="+t.I18nBot("tgbot.clients")) output := t.I18nBot("tgbot.messages.exhaustedCount", "Type=="+t.I18nBot("tgbot.clients"))