refactor(cache): streamline subscription cache clearing logic

queue/logic/traffic/resetTrafficLogic.go

@@ -9,12 +9,10 @@ import (
 	"time"
 
 	"github.com/perfect-panel/server/internal/model/log"
-	"github.com/perfect-panel/server/internal/model/node"
 	"github.com/perfect-panel/server/internal/model/subscribe"
 	"github.com/perfect-panel/server/internal/model/user"
 	"github.com/perfect-panel/server/internal/svc"
 	"github.com/perfect-panel/server/pkg/logger"
-	"github.com/perfect-panel/server/pkg/tool"
 	"github.com/perfect-panel/server/queue/types"
 
 	"github.com/hibiken/asynq"
@@ -598,31 +596,11 @@ func (l *ResetTrafficLogic) clearCache(ctx context.Context, list []*user.Subscri
 		}
 
 		for sub, _ := range subs {
-			info, err := l.svc.SubscribeModel.FindOne(ctx, sub)
-			if err != nil {
-				logger.Errorw("[CheckSubscription] FindOne subscribe failed", logger.Field("error", err.Error()), logger.Field("subscribe_id", sub))
-				continue
-			}
-			if info != nil && info.Id == sub {
-				var nodes []int64
-				if info.Nodes != "" {
-					nodes = tool.StringToInt64Slice(info.Nodes)
-				}
-				var tag []string
-				if info.NodeTags != "" {
-					tag = strings.Split(info.NodeTags, ",")
-				}
-
-				err = l.svc.NodeModel.ClearNodeCache(ctx, &node.FilterNodeParams{
-					Page:     1,
-					Size:     1000,
-					Tag:      tag,
-					ServerId: nodes,
-				})
-				if err != nil {
-					logger.Errorw("[CheckSubscription] ClearNodeCache failed", logger.Field("error", err.Error()), logger.Field("subscribe_id", sub))
-					continue
-				}
+			if err := l.svc.SubscribeModel.ClearCache(ctx, sub); err != nil {
+				logger.Errorw("[ResetTraffic] Failed to clear subscription cache",
+					logger.Field("subscribeId", sub),
+					logger.Field("error", err.Error()),
+				)
 			}
 		}
 	}