update GetServiceStateAndVersion

Author: wangchangmin

.gitignore

@@ -314,3 +314,8 @@ __debug_bin
 
 CLAUDE.md
 .vercel
+
+
+*package-lock.json
+client/package-lock.json
+yarm.lock

internal/service_manager/database/info_repo.go

@@ -170,3 +170,20 @@ func (d *Database) GetServiceState(ctx context.Context, serviceName string) (*mo
 
 	return &state, nil
 }
+
+func (d *Database) GetServiceStateAndVersion(ctx context.Context, serviceName string, version string) (*model.ServiceState, error) {
+	query := `SELECT service, version, report_at, resolved_at, health_state, correlation_id
+	          FROM service_states WHERE service = $1 AND version = $2 ORDER BY report_at DESC LIMIT 1`
+	row := d.QueryRowContext(ctx, query, serviceName, version)
+
+	var state model.ServiceState
+	if err := row.Scan(&state.Service, &state.Version, &state.ReportAt,
+		&state.ResolvedAt, &state.HealthState, &state.CorrelationID); err != nil {
+		if err == sql.ErrNoRows {
+			return nil, nil
+		}
+		return nil, err
+	}
+
+	return &state, nil
+}

internal/service_manager/service/info_service.go

@@ -70,7 +70,7 @@ func (s *Service) GetServiceActiveVersions(ctx context.Context, serviceName stri
 	var activeVersions []model.ActiveVersionItem
 	for version, versionInstances := range versionMap {
 		// 获取服务状态
-		state, err := s.db.GetServiceState(ctx, serviceName)
+		state, err := s.db.GetServiceStateAndVersion(ctx, serviceName, version)
 		if err != nil {
 			log.Error().Err(err).Str("service", serviceName).Msg("failed to get service state")
 		}