// 示例：物聯(lián)網(wǎng)設(shè)備監(jiān)控?cái)?shù)據(jù)模型
public class SensorData 
{
    [BsonId] // 自動(dòng)增長(zhǎng)ID
    public int Id { get; set; }

    // 時(shí)間戳（Unix時(shí)間戳，節(jié)省存儲(chǔ)空間）
    public long Timestamp { get; set; }

    // 設(shè)備唯一標(biāo)識(shí)符（可作為索引字段）
    public string DeviceId { get; set; }

    // 傳感器指標(biāo)集合（嵌套文檔結(jié)構(gòu)）
    public Dictionary<string, double> Metrics { get; set; } = new Dictionary<string, double>();

    // 額外元數(shù)據(jù)（如地理位置、傳感器類型）
    public BsonDocument Metadata { get; set; } = new BsonDocument();
}

// 示例：將1分鐘內(nèi)的傳感器數(shù)據(jù)合并為一個(gè)文檔
public class AggregatedSensorData 
{
    [BsonId]
    public int Id { get; set; }

    // 時(shí)間窗口標(biāo)識(shí)（格式：YYYY-MM-DD_HH-MM）
    public string WindowKey { get; set; }

    // 設(shè)備ID
    public string DeviceId { get; set; }

    // 聚合統(tǒng)計(jì)（平均值、最大值、最小值）
    public Dictionary<string, SensorStats> Aggregates { get; set; } = new Dictionary<string, SensorStats>();
}

// 統(tǒng)計(jì)信息類
public class SensorStats 
{
    public double AvgValue { get; set; }
    public double MaxValue { get; set; }
    public double MinValue { get; set; }
    public int SampleCount { get; set; }
}

// 創(chuàng)建或打開(kāi)數(shù)據(jù)庫(kù)
using (var db = new LiteDatabase(@"Sensors.db"))
{
    // 創(chuàng)建傳感器數(shù)據(jù)集合（自動(dòng)創(chuàng)建索引）
    var sensorCollection = db.GetCollection<SensorData>("sensor_data");
    
    // 創(chuàng)建復(fù)合索引（設(shè)備ID + 時(shí)間戳）
    sensorCollection.EnsureIndex(x => x.DeviceId + ":" + x.Timestamp, unique: false);
    
    // 插入單條記錄
    var data = new SensorData 
    {
        Timestamp = DateTimeOffset.UtcNow.ToUnixTimeSeconds(),
        DeviceId = "DVC-001",
        Metrics = new Dictionary<string, double> 
        {
            { "Temperature", 25.3 },
            { "Humidity", 60.5 }
        }
    };
    sensorCollection.Insert(data);
}

using (var db = new LiteDatabase(@"Sensors.db"))
{
    var sensorCollection = db.GetCollection<SensorData>("sensor_data");
    
    using (var bulk = sensorCollection.BulkInsert())
    {
        for (int i = 0; i < 1000; i++)
        {
            var data = new SensorData 
            {
                Timestamp = DateTimeOffset.UtcNow.AddSeconds(-i).ToUnixTimeSeconds(),
                DeviceId = $"DVC-{i % 10:000}",
                Metrics = new Dictionary<string, double> 
                {
                    { "Voltage", 3.3 + (i % 10) * 0.1 },
                    { "Current", 0.5 + (i % 5) * 0.05 }
                }
            };
            bulk.Insert(data);
        }
    }
}

using (var db = new LiteDatabase(@"Sensors.db"))
{
    var sensorCollection = db.GetCollection<SensorData>("sensor_data");
    
    // 查詢2025年7月1日00:00到00:30的數(shù)據(jù)
    var query = sensorCollection.Query()
        .Where(x => x.Timestamp >= new DateTimeOffset(2025, 7, 1, 0, 0, 0, TimeSpan.Zero).ToUnixTimeSeconds() &&
                    x.Timestamp <= new DateTimeOffset(2025, 7, 1, 0, 30, 0, TimeSpan.Zero).ToUnixTimeSeconds())
        .OrderBy(x => x.Timestamp)
        .Limit(1000);
    
    var results = query.ToList();
}

// 實(shí)時(shí)聚合任務(wù)（建議使用Quartz.NET等調(diào)度框架）
public void AggregateSensorData()
{
    using (var db = new LiteDatabase(@"Sensors.db"))
    {
        var rawCollection = db.GetCollection<SensorData>("sensor_data");
        var aggCollection = db.GetCollection<AggregatedSensorData>("aggregated_data");
        
        // 獲取當(dāng)前時(shí)間窗口（每分鐘）
        var now = DateTimeOffset.UtcNow;
        var windowStart = new DateTimeOffset(now.Year, now.Month, now.Day, now.Hour, now.Minute, 0, TimeSpan.Zero);
        var windowKey = windowStart.ToString("yyyy-MM-dd_HH-mm");
        
        // 查詢當(dāng)前時(shí)間窗口內(nèi)的原始數(shù)據(jù)
        var rawQuery = rawCollection.Query()
            .Where(x => x.Timestamp >= windowStart.ToUnixTimeSeconds() &&
                        x.Timestamp < (windowStart.AddMinutes(1)).ToUnixTimeSeconds());
        
        var rawResults = rawQuery.ToList();
        
        if (rawResults.Count > 0)
        {
            var aggregates = new Dictionary<string, SensorStats>();
            
            foreach (var metric in rawResults.First().Metrics.Keys)
            {
                aggregates[metric] = new SensorStats 
                {
                    AvgValue = rawResults.Average(x => x.Metrics[metric]),
                    MaxValue = rawResults.Max(x => x.Metrics[metric]),
                    MinValue = rawResults.Min(x => x.Metrics[metric]),
                    SampleCount = rawResults.Count
                };
            }
            
            // 插入聚合結(jié)果
            var aggData = new AggregatedSensorData 
            {
                WindowKey = windowKey,
                DeviceId = rawResults.First().DeviceId,
                Aggregates = aggregates
            };
            
            aggCollection.Insert(aggData);
        }
    }
}

// 自定義數(shù)值存儲(chǔ)轉(zhuǎn)換器
public class QuantizedDoubleConverter : IBsonConverter<double>
{
    public double Read(BsonReader reader, Type type, BsonDeserializationContext context)
    {
        return reader.ReadDouble();
    }

    public void Write(BsonWriter writer, double value, Type type, BsonSerializationContext context)
    {
        // 將雙精度浮點(diǎn)數(shù)轉(zhuǎn)換為4字節(jié)整數(shù)（保留3位小數(shù)）
        writer.WriteInt32((int)(value * 1000));
    }
}

// 注冊(cè)自定義轉(zhuǎn)換器
BsonMapper.Global.RegisterType<double, QuantizedDoubleConverter>();

// 創(chuàng)建部分索引示例
sensorCollection.EnsureIndex(
    x => x.DeviceId, 
    unique: false, 
    options: new IndexOptions 
    { 
        PartialFilter = BsonValue.Create(new BsonDocument("DeviceId" , "DVC-001"))
    });

// 自定義連接字符串參數(shù)
var connectionString = new ConnectionString 
{ 
    Filename = "Sensors.db", 
    Mode = FileMode.OpenOrCreate, 
    Version = 2, 
    WriteBufferSize = 1024 * 1024 * 10 // 10MB寫(xiě)緩沖區(qū)
};

using (var db = new LiteDatabase(connectionString))
{
    // 配置完成后進(jìn)行操作
}

// 樂(lè)觀鎖更新示例
var data = sensorCollection.FindById(1);
data.Metrics["Voltage"] = 3.4;

// 檢查版本號(hào)是否匹配
if (sensorCollection.Update(data))
{
    Console.WriteLine("Update succeeded");
}
else
{
    Console.WriteLine("Conflict detected, retry...");
}

// 實(shí)時(shí)折線圖綁定數(shù)據(jù)源
public class SensorViewModel : INotifyPropertyChanged
{
    private ChartValues<double> _temperatureData = new ChartValues<double>();
    public ChartValues<double> TemperatureData 
    { 
        get => _temperatureData; 
        set 
        { 
            _temperatureData = value; 
            OnPropertyChanged(); 
        } 
    }

    public void UpdateChart(SensorData newData)
    {
        TemperatureData.Add(newData.Metrics["Temperature"]);
        if (TemperatureData.Count > 100)
        {
            TemperatureData.RemoveAt(0);
        }
    }

    // 實(shí)現(xiàn)INotifyPropertyChanged接口
    public event PropertyChangedEventHandler PropertyChanged;
    protected void OnPropertyChanged([CallerMemberName] string name = null)
    {
        PropertyChanged?.Invoke(this, new PropertyChangedEventArgs(name));
    }
}