Kullanıcı Fonksiyonları Yazma

using System;
using System.Threading.Tasks;
using Proxus.SDK.BaseFunctions;
using Proxus.Common.Messages;

public class MyCustomLogic : FunctionBase
{
    // Fonksiyon başladığında bir kez çağrılır
    protected override void OnStarted()
    {
        LogInformation("MyCustomLogic fonksiyonu başladı.");
        // İsteğe bağlı: Tekrarlayan bir görev ayarla
        ExecuteScheduledTask(TimeSpan.FromSeconds(30), () =>
        {
            LogInformation("Periyodik kontrol çalışıyor...");
        });
    }

    // Her telemetri paketi için çağrılır
    protected override void OnMessageReceive(FunctionContext ctx)
    {
        // 1. Mesajın TransportData olup olmadığını kontrol et
        if (ctx.Message is TransportData data)
        {
            // 2. Filtrele: Sadece belirli konuları veya cihazları işle
            if (ctx.Topic != "Gen_01")
            {
                return;
            }

            // 3. Değeri Çıkar (Mantığınızda yardımcı metod veya manuel ayrıştırma)
            // Not: TransportData yükü, anahtar-değer çiftlerinin bir listesidir
            var tempMetric = data.Payload.FirstOrDefault(p => p.Key == "Temperature");

            if (tempMetric != null && double.TryParse(tempMetric.Value, out double temp))
            {
                // 4. Mantık: Verimliliği hesapla
                double efficiency = (temp / 120.0) * 100;

                // 5. Aksiyon: Sonucu hatta geri kaydet
                if (efficiency < 50)
                {
                    LogWarning($"Düşük Verimlilik Tespit Edildi: {efficiency:F2}%");

                    // Yeni veri paketi oluştur
                    var resultData = new TransportData();
                    resultData.MetaData.Add(new MetaData { Key = "DeviceName", Value = "Gen_01_Calc" });
                    resultData.Payload.Add(new Payload
                    {
                        Key = "Efficiency",
                        Value = efficiency.ToString(),
                        Type = "Double"
                    });

                    // Sisteme geri gönder
                    Save(resultData);
                }
            }
        }
    }
}

// Otomatik önbellek temizlemeyi etkinleştir (1 saatten eski girişleri kaldırır)
EnableCacheWithExpirationTime = TimeSpan.FromHours(1);

// Önbellek Ekle/Güncelle
Cache.AddOrUpdate(DateTime.UtcNow, data, (k, v) => data);

// Her 10 saniyede bir çalıştır
ExecuteScheduledTask(TimeSpan.FromSeconds(10), () =>
{
// Periyodik hesaplama veya temizlik yap
});

// Harici bir brokera yayınla
PublishMqttMessage("external/topic", "payload");

// Harici konuya abone ol (OnMessageReceive içinde işlenir)
SubscribeToMqttTopic("external/command");