@page "/"
@using Blazor.IndexedDB
@using DBTest.DB
@using Microsoft.Data.SqlClient

@inject IIndexedDbFactory DbFactory

<PageTitle>Home</PageTitle>

<h1>Artikelliste</h1>

@if (artikelliste == null)
{
    <div class="d-flex justify-content-center align-items-center">
        <p class="text-muted fs-4">Loading...</p>
    </div>
}
else
{
    <div class="container">
        <div class="row row-cols-1 row-cols-md-2 row-cols-lg-3 g-4">
            @foreach (var quote in artikelliste)
            {
                <div class="col">
                    <div class="card shadow-sm h-100">
                        <div class="card-body d-flex flex-column">
                            <blockquote class="blockquote mb-4">
                                <p class="fs-5">"@quote.Barcode"</p>
                            </blockquote>
                            <footer class="blockquote-footer mt-auto text-end">
                                <cite title="Author">@quote.Bezeichnung</cite>
                            </footer>
                        </div>
                    </div>
                </div>
            }
        </div>
        <div class="text-center mt-5">
            <button class="btn btn-primary btn-lg" @onclick="ForceRefresh">Force Refresh</button>
        </div>
    </div>
}

@code  {
    private List<Artikel> artikelliste;

    protected override async Task OnInitializedAsync()
    {
        await LoadQuotesAsync();
    }

    private async Task LoadQuotesAsync()
    {
        using (var db = await DbFactory.Create<ArtikelDB>())
        {
            // Load quotes from IndexedDB
            artikelliste = db.ArtikelListe.ToList();
            // If no quotes exist in IndexedDB, fetch from API
            if (artikelliste == null || artikelliste.Count == 0)
            {
                await FetchAndStoreQuotesFromDBAsync();
            }
        }
    }

    private async Task FetchAndStoreQuotesFromDBAsync()
    {
        using (var db = await DbFactory.Create<ArtikelDB>())
        {
            using (SqlConnection con = new SqlConnection("Data Source=APP03AC;Initial Catalog=KassenSystem;User Id=KassenManager;Password=ks;Max Pool Size=600;Connection Timeout=3000;encrypt=true;"))
            {
                con.Open();

                //                                         0                1                      2          3                4                   5
                string sql = "SELECT [ArtikelMA].[ArtikelId], [ArtikelNummer], [ArtikelMA].[Barcode], [Bontext], [Mengeneinheit], isnull([Farbe], '')  FROM [Kassensystem].[KS].[ArtikelMA] left join [Kassensystem].[KS].[ArtikelVariantenMA] on [ArtikelMA].[ArtikelId] = [ArtikelVariantenMA].[ArtikelId] where [ArtikelMA].GeloeschtAm is null and istAusgeblendet = 0 and [ArtikelVariantenMA].GeloeschtAm is null order by ArtikelId, Farbe";

                using(SqlCommand cmd = new SqlCommand(sql, con))
                {
                    using(SqlDataReader reader = cmd.ExecuteReader())
                    {
                        while(reader.Read())
                        {
                            Artikel a1 = new Artikel();
                            a1.Key = reader.GetString(0);
                            a1.ArtikelNummer = reader.GetString(1);
                            a1.Variante = reader.GetString(5);
                            a1.Bezeichnung = reader.GetString(3);

                            db.ArtikelListe.Add(a1); 
                        }
                    }
                }

            }
            await db.SaveChanges(); // Save changes
        }
    }

    private async Task ForceRefresh()
    {
        using (var db = await DbFactory.Create<ArtikelDB>())
        {
            db.ArtikelListe.Clear(); // Clear existing data from IndexedDB
            await db.SaveChanges();
        }
        await FetchAndStoreQuotesFromDBAsync(); // Fetch fresh data from API
    }

}