// 实时活动效果监控
public class RealTimeEventTracker
{
    public static void TrackEvent(string eventType, Dictionary<string, object> data)
    {
        // 发送到实时数据流 (Kafka/WebSocket)
        RealTimeStream.Send(eventType, data);

        // 同时记录到离线分析系统
        AnalyticsMgr.LogEvent(eventType, data);
    }

    // 活动转化漏斗实时监控
    public static void MonitorFunnel(string funnelId, string step, string userId)
    {
        TrackEvent("funnel_step", new Dictionary<string, object>{
            {"funnel_id", funnelId},
            {"step", step},
            {"user_id", userId},
            {"timestamp", DateTime.UtcNow}
        });
    }
}

public class ABTestManager
{
    // 基于用户ID的一致性哈希分流
    public static string GetExperimentGroup(string experimentName, string userId)
    {
        // 确保用户始终在同一实验组
        int hash = (experimentName + userId).GetHashCode();
        int bucket = Math.Abs(hash) % 100;

        // 50%对照组，50%实验组
        return bucket < 50 ? "control" : "treatment";
    }

    // 多变量测试 (MVT)
    public static string GetMVTGroup(string experimentName, string userId,
        Dictionary<string, float> variantWeights)
    {
        int hash = (experimentName + userId).GetHashCode();
        int bucket = Math.Abs(hash) % 100;

        float cumulative = 0;
        foreach (var variant in variantWeights)
        {
            cumulative += variant.Value;
            \text{if} (bucket < cumulative * 100)
                return variant.Key;
        }
        return "control";
    }
}

public class StatisticalAnalyzer
{
    // 计算置信区间 (95%)
    public static (double lower, double upper) CalculateConfidenceInterval(
        double conversionRate, int sampleSize)
    {
        double standardError = Math.Sqrt(conversionRate * (1 - conversionRate) / sampleSize);
        double margin = 1.96 * standardError; // 95%置信度
        return (conversionRate - margin, conversionRate + margin);
    }

    // A/B测试效果评估
    public static bool IsSignificant(ExperimentResult control, ExperimentResult treatment)
    {
        // 使用Z检验计算p值
        double pooledP = (control.Conversions + treatment.Conversions) /
                        (control.Users + treatment.Users);
        double se = Math.Sqrt(pooledP * (1 - pooledP) *
                    (1.0/control.Users + 1.0/treatment.Users));
        double zScore = (treatment.ConversionRate - control.ConversionRate) / se;

        return Math.Abs(zScore) > 1.96; // p < 0.05
    }
}

public class DashboardGenerator
{
    // 留存率热力图
    public static void GenerateRetentionHeatmap()
    {
        var retentionData = GetRetentionData();
        // 使用颜色深浅表示留存率高低
        // 红色: 低留存 (< 20%)
        // 黄色: 中等留存 (20-40%)
        // 绿色: 高留存 (> 40%)
    }

    // 收入预测曲线
    public static void GenerateRevenueForecast()
    {
        var historicalData = GetHistoricalRevenue();
        var forecast = TimeSeriesForecast(historicalData, days: 30);
        // 显示置信区间
        ShowForecastWithConfidence(forecast);
    }
}

public class DataQualityMonitor
{
    // 数据完整性检查
    public static void ValidateDataCompleteness()
    {
        var expectedEvents = GetExpectedEvents();
        var actualEvents = GetActualEvents();

        double completeness = (double)actualEvents / expectedEvents;
        \text{if} (completeness < 0.95) // 95%完整性阈值
        {
            AlertManager.SendAlert("Data completeness below threshold");
        }
    }

    // 异常值检测（使用3σ原则）
    public static List<DataPoint> DetectOutliers(List<DataPoint> data)
    {
        double mean = data.Average(d => d.Value);
        double stdDev = CalculateStandardDeviation(data);

        return data.Where(d => Math.Abs(d.Value - mean) > 3 * stdDev).ToList();
    }
}

public static class AnalyticsMgr
{
    public static void LogEvent(string eventName, Dictionary<string, object> params)
    {
        // 1. 添加通用参数 (User ID, Device, etc.)
        params["user_id"] = UserProfile.ID;
        params["ts"] = DateTime.UtcNow.ToUnixTimeSeconds();

        // 2. 发送给第三方 SDK (Unity Analytics, Firebase, ThinkingData)
        // SDK.Track(eventName, params);

        // 3. 开发模式下打印日志
        \text{if} (Debug.isDebugBuild)
        {
            Debug.Log($"[Analytics] {eventName}: {JsonConvert.SerializeObject(params)}");
        }
    }

    // 封装常用方法，防止拼写错误
    public static void LogLevelStart(int levelId, string difficulty) { ... }
    public static void LogResourceChange(string type, int amount, string reason) { ... }
}