feat: 删除旧逻辑(回收站、SSE记录表)，并去除无用方法

feat: 主控数据缓存逻辑，缓解sqlite压力
feat: 服务数据缓存逻辑，环节sqlite压力

Author: Mecozea

cmd/server/main.go

@@ -8,6 +8,7 @@ import (
 	"NodePassDash/internal/endpointcache"
 	"NodePassDash/internal/nodepass"
 	"NodePassDash/internal/router"
+	"NodePassDash/internal/servicecache"
 
 	// "NodePassDash/internal/lifecycle"
 	log "NodePassDash/internal/log"
@@ -217,6 +218,13 @@ func initializeServices(sseDebugLog bool) (*gorm.DB, *auth.Service, *endpoint.Se
 	}
 	log.Infof("✅ Endpoint内存缓存初始化成功，已加载 %d 个端点", endpointcache.Shared.Count())
 
+	// 初始化Service内存缓存
+	if err := servicecache.InitShared(gormDB); err != nil {
+		log.Errorf("初始化Service内存缓存失败: %v", err)
+		return nil, nil, nil, nil, nil, nil, nil, nil, fmt.Errorf("初始化Service缓存失败: %v", err)
+	}
+	log.Infof("✅ Service内存缓存初始化成功，已加载 %d 个服务", servicecache.Shared.Count())
+
 	// 初始化其他服务
 	endpointService := endpoint.NewService(gormDB)
 	tunnelService := tunnel.NewService(gormDB)
@@ -301,9 +309,27 @@ func startBackgroundServices(gormDB *gorm.DB, sseService *sse.Service, sseManage
 	}()
 	log.Info("Endpoint缓存定时持久化任务已启动（间隔: 30秒）")
 
+	// 启动Service缓存定时持久化任务（每30秒持久化一次变更）
+	go func() {
+		ticker := time.NewTicker(30 * time.Second)
+		defer ticker.Stop()
+
+		for range ticker.C {
+			if err := servicecache.Shared.PersistIfNeeded(gormDB); err != nil {
+				log.Errorf("❌ 持久化Service缓存失败: %v", err)
+			} else {
+				stats := servicecache.Shared.GetStats()
+				dirtyCount := stats["dirty_count"].(int)
+				if dirtyCount > 0 {
+					log.Debugf("💾 持久化了 %d 个变更的服务", dirtyCount)
+				}
+			}
+		}
+	}()
+	log.Info("Service缓存定时持久化任务已启动（间隔: 30秒）")
+
 	// 启动SSE相关服务
 	go func() {
-		sseService.StartStoreWorkers(4) // 减少worker数量
 		sseManager.StartDaemon()
 
 		// 初始化SSE系统
@@ -340,6 +366,14 @@ func gracefulShutdown(server *http.Server, gormDB *gorm.DB, trafficScheduler *da
 		log.Infof("✅ Endpoint缓存已成功关闭并持久化")
 	}
 
+	// 2. 持久化Service缓存（保证数据不丢失）
+	log.Infof("💾 正在持久化Service缓存...")
+	if err := servicecache.Shared.Shutdown(gormDB); err != nil {
+		log.Errorf("❌ 关闭Service缓存失败: %v", err)
+	} else {
+		log.Infof("✅ Service缓存已成功关闭并持久化")
+	}
+
 	// 关闭增强系统（暂时注释掉）
 	// if err := lifecycleManager.Shutdown(); err != nil {
 	// 	log.Errorf("增强系统关闭失败: %v", err)

internal/api/data.go

@@ -1,8 +1,8 @@
 package api
 
 import (
-	"NodePassDash/internal/db"
 	"NodePassDash/internal/endpoint"
+	"NodePassDash/internal/endpointcache"
 	log "NodePassDash/internal/log"
 	"NodePassDash/internal/models"
 	"NodePassDash/internal/nodepass"
@@ -408,7 +408,15 @@ func (h *DataHandler) handleImportV1(c *gin.Context, baseData struct {
 		go func() {
 			time.Sleep(100 * time.Millisecond) // 稍作延迟确保事务提交完成
 			for _, ep := range newEndpoints {
-				updateEndpointTunnelCountForData(ep.ID)
+				// 查询隧道数量
+				var count int64
+				if err := h.db.Model(&models.Tunnel{}).Where("endpoint_id = ?", ep.ID).Count(&count).Error; err != nil {
+					log.Errorf("[数据导入] 查询端点 %d 隧道计数失败: %v", ep.ID, err)
+					continue
+				}
+				// 直接更新缓存
+				endpointcache.Shared.UpdateTunnelCount(ep.ID, count)
+				log.Debugf("[数据导入] 端点 %d 隧道计数已更新为: %d (已缓存)", ep.ID, count)
 			}
 		}()
 	}
@@ -533,20 +541,6 @@ func (h *DataHandler) handleImportV2(c *gin.Context, baseData struct {
 	})
 }
 
-// updateEndpointTunnelCountForData 更新端点的隧道计数，用于数据导入后的异步更新
-func updateEndpointTunnelCountForData(endpointID int64) {
-	err := db.ExecuteWithRetry(func(db *gorm.DB) error {
-		return db.Model(&models.Endpoint{}).Where("id = ?", endpointID).
-			Update("tunnel_count", gorm.Expr("(SELECT COUNT(*) FROM tunnels WHERE endpoint_id = ?)", endpointID)).Error
-	})
-
-	if err != nil {
-		log.Errorf("[数据导入]更新端点 %d 隧道计数失败: %v", endpointID, err)
-	} else {
-		log.Debugf("[数据导入]端点 %d 隧道计数已更新", endpointID)
-	}
-}
-
 // ValidateImportResult 单个主控的验证结果
 type ValidateImportResult struct {
 	Name      string `json:"name"`