diff options
Diffstat (limited to 'web')
| -rw-r--r-- | web/job/periodic_traffic_reset_job.go | 6 |
1 files changed, 5 insertions, 1 deletions
diff --git a/web/job/periodic_traffic_reset_job.go b/web/job/periodic_traffic_reset_job.go index 79001973..1369c200 100644 --- a/web/job/periodic_traffic_reset_job.go +++ b/web/job/periodic_traffic_reset_job.go @@ -20,12 +20,16 @@ func NewPeriodicTrafficResetJob(period Period) *PeriodicTrafficResetJob { func (j *PeriodicTrafficResetJob) Run() { inbounds, err := j.inboundService.GetInboundsByTrafficReset(string(j.period)) - logger.Infof("Running periodic traffic reset job for period: %s", j.period) if err != nil { logger.Warning("Failed to get inbounds for traffic reset:", err) return } + if len(inbounds) == 0 { + return + } + logger.Infof("Running periodic traffic reset job for period: %s (%d matching inbounds)", j.period, len(inbounds)) + resetCount := 0 for _, inbound := range inbounds { |