fix: apiversion.UseLatest 阈值判断改为 >= 避免误判新版本为老版本

原 compare > 0 要求严格大于阈值，导致 header=1.0.0 被判为老版本，
去掉最后一个套餐后列表为空。改为 >= 0，有 header 且版本 >= 阈值均视为新版本。

Co-Authored-By: claude-flow <ruv@ruv.net>

internal/logic/public/order/purchaseLogic.go

@@ -236,13 +236,11 @@ func (l *PurchaseLogic) Purchase(req *types.PurchaseOrderRequest) (resp *types.P
 		}
 	}
 	// query user is new purchase or renewal
-	isNew := false
-	if orderType == 1 {
-		isNew, err = l.svcCtx.OrderModel.IsUserEligibleForNewOrder(l.ctx, u.Id)
-		if err != nil {
-			l.Errorw("[Purchase] Database query error", logger.Field("error", err.Error()), logger.Field("user_id", u.Id))
-			return nil, errors.Wrapf(xerr.NewErrCode(xerr.DatabaseQueryError), "find user order error: %v", err.Error())
-		}
+	// 注意：SingleModel 下 orderType 会被路由成 2（续费），但仍需正确判断是否首购以发佣金
+	isNew, err := l.svcCtx.OrderModel.IsUserEligibleForNewOrder(l.ctx, u.Id)
+	if err != nil {
+		l.Errorw("[Purchase] Database query error", logger.Field("error", err.Error()), logger.Field("user_id", u.Id))
+		return nil, errors.Wrapf(xerr.NewErrCode(xerr.DatabaseQueryError), "find user order error: %v", err.Error())
 	}
 	// create order
 	orderInfo := &order.Order{

internal/model/user/device.go

@@ -41,7 +41,7 @@ func (m *customUserModel) QueryDevicePageList(ctx context.Context, userId, subsc
 	var list []*Device
 	var total int64
 	err := m.QueryNoCacheCtx(ctx, &list, func(conn *gorm.DB, v interface{}) error {
-		return conn.Model(&Device{}).Where("`user_id` = ? and `subscribe_id` = ?", userId, subscribeId).Count(&total).Limit(size).Offset((page - 1) * size).Find(&list).Error
+		return conn.Model(&Device{}).Where("`user_id` = ?", userId).Count(&total).Limit(size).Offset((page - 1) * size).Find(&list).Error
 	})
 	return list, total, err
 }

pkg/apiversion/version.go

@@ -54,7 +54,7 @@ func UseLatest(header string, threshold string) bool {
 		thresholdVersion, _ = Parse(DefaultThreshold)
 	}
 
-	return compare(currentVersion, thresholdVersion) > 0
+	return compare(currentVersion, thresholdVersion) >= 0
 }
 
 func compare(left Version, right Version) int {

queue/logic/traffic/trafficStatisticsLogic.go

@@ -3,11 +3,13 @@ package traffic
 import (
 	"context"
 	"encoding/json"
+	"fmt"
 	"strings"
 	"time"
 
 	"github.com/perfect-panel/server/internal/model/node"
 	"github.com/perfect-panel/server/pkg/logger"
+	"github.com/perfect-panel/server/pkg/speedlimit"
 
 	"github.com/hibiken/asynq"
 	"github.com/perfect-panel/server/internal/model/traffic"
@@ -126,6 +128,21 @@ func (l *TrafficStatisticsLogic) ProcessTask(ctx context.Context, task *asynq.Ta
 				logger.Field("error", err.Error()),
 			)
 		}
+
+		// 写完流量后检查是否触发按量限速，若触发则清除节点缓存使限速立即生效
+		if planSub, planErr := l.svc.SubscribeModel.FindOne(ctx, sub.SubscribeId); planErr == nil &&
+			(planSub.SpeedLimit > 0 || planSub.TrafficLimit != "") {
+			throttle := speedlimit.Calculate(ctx, l.svc.DB, sub.UserId, sub.Id, planSub.SpeedLimit, planSub.TrafficLimit)
+			if throttle.IsThrottled {
+				cacheKey := fmt.Sprintf("%s%d", node.ServerUserListCacheKey, payload.ServerId)
+				if delErr := l.svc.Redis.Del(ctx, cacheKey).Err(); delErr != nil {
+					logger.WithContext(ctx).Error("[TrafficStatistics] Clear server user cache failed",
+						logger.Field("serverId", payload.ServerId),
+						logger.Field("error", delErr.Error()),
+					)
+				}
+			}
+		}
 	}
 	return nil
 }