From 4c2f3a313076b4d4f44d9cfe5070eee22ca72ccd Mon Sep 17 00:00:00 2001 From: Vadim Iskuchekov Date: Wed, 1 Oct 2025 20:01:20 +0000 Subject: [PATCH] fix: improve error handling in periodic traffic reset job --- web/job/periodic_traffic_reset_job.go | 16 +++++++++++----- 1 file changed, 11 insertions(+), 5 deletions(-) diff --git a/web/job/periodic_traffic_reset_job.go b/web/job/periodic_traffic_reset_job.go index 6a370a51..6a7fb6f2 100644 --- a/web/job/periodic_traffic_reset_job.go +++ b/web/job/periodic_traffic_reset_job.go @@ -37,13 +37,19 @@ func (j *PeriodicTrafficResetJob) Run() { resetCount := 0 for _, inbound := range inbounds { - if err := j.inboundService.ResetAllClientTraffics(inbound.Id); err != nil { - logger.Warning("Failed to reset traffic for inbound", inbound.Id, ":", err) - continue + resetInboundErr := j.inboundService.ResetAllTraffics() + if resetInboundErr != nil { + logger.Warning("Failed to reset traffic for inbound", inbound.Id, ":", resetInboundErr) } - resetCount++ - logger.Infof("Reset traffic for inbound %d (%s)", inbound.Id, inbound.Remark) + resetClientErr := j.inboundService.ResetAllClientTraffics(inbound.Id) + if resetClientErr != nil { + logger.Warning("Failed to reset traffic for all users of inbound", inbound.Id, ":", resetClientErr) + } + + if resetInboundErr == nil && resetClientErr == nil { + resetCount++ + } } if resetCount > 0 {