S-VPN/server
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix(subscribe): ensure active status and reset timestamps during traffic resets

Browse Source
This commit is contained in:
Chang lue Tsen 2025-08-23 09:07:56 -04:00
parent d33f4cd1ce
commit d5460d0cd1
1 changed files with 12 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
queue/logic/traffic/resetTrafficLogic.go
View File

@ -238,8 +238,10 @@ func (l *ResetTrafficLogic) resetMonth(ctx context.Context) error {
err = db.Model(&user.Subscribe{}).Where("`id` IN ?", monthlyResetUsers). err = db.Model(&user.Subscribe{}).Where("`id` IN ?", monthlyResetUsers).
Updates(map[string]interface{}{ Updates(map[string]interface{}{
"upload": 0, "upload": 0,
"download": 0, "download": 0,
"status": 1, // Ensure status is active
"finished_at": nil,
}).Error }).Error
if err != nil { if err != nil {
logger.Errorw("[ResetTraffic] Failed to update monthly reset users", logger.Field("error", err.Error())) logger.Errorw("[ResetTraffic] Failed to update monthly reset users", logger.Field("error", err.Error()))
@ -321,8 +323,10 @@ func (l *ResetTrafficLogic) reset1st(ctx context.Context, cache resetTrafficCach
// Reset upload and download traffic to zero // Reset upload and download traffic to zero
err = db.Model(&user.Subscribe{}).Where("`id` IN ?", users1stReset). err = db.Model(&user.Subscribe{}).Where("`id` IN ?", users1stReset).
Updates(map[string]interface{}{ Updates(map[string]interface{}{
"upload": 0, "upload": 0,
"download": 0, "download": 0,
"status": 1, // Ensure status is active
"finished_at": nil,
}).Error }).Error
if err != nil { if err != nil {
logger.Errorw("[ResetTraffic] Failed to update 1st reset users", logger.Field("error", err.Error())) logger.Errorw("[ResetTraffic] Failed to update 1st reset users", logger.Field("error", err.Error()))
@ -405,8 +409,10 @@ func (l *ResetTrafficLogic) resetYear(ctx context.Context) error {
// Reset upload and download traffic to zero // Reset upload and download traffic to zero
err = db.Model(&user.Subscribe{}).Where("`id` IN ?", usersYearReset). err = db.Model(&user.Subscribe{}).Where("`id` IN ?", usersYearReset).
Updates(map[string]interface{}{ Updates(map[string]interface{}{
"upload": 0, "upload": 0,
"download": 0, "download": 0,
"status": 1, // Ensure status is active
"finished_at": nil,
}).Error }).Error
if err != nil { if err != nil {
logger.Errorw("[ResetTraffic] Failed to update yearly reset users", logger.Field("error", err.Error())) logger.Errorw("[ResetTraffic] Failed to update yearly reset users", logger.Field("error", err.Error()))