Dữ liệu offline của cửa hàng trên k3s: PVC local-path, tên node và sao lưu bằng CronJob

# ===== pvc.yaml
# Dữ liệu offline của cửa hàng (SQLite). local-path của k3s tạo PV kiểu local,
# gắn nodeAffinity kubernetes.io/hostname vào đúng node lúc tạo.
apiVersion: v1
kind: PersistentVolumeClaim
metadata:
  name: cuahang-data
  namespace: banhang
  labels:
    app.kubernetes.io/name: cuahang
    app.kubernetes.io/part-of: banhang
spec:
  accessModes:
    - ReadWriteOnce
  storageClassName: local-path
  resources:
    requests:
      storage: 2Gi
# ===== cronjob-sao-luu.yaml
# Sao lưu SQLite mỗi 15 phút sang ổ thứ hai (/mnt/sao-luu), giữ 96 bản (24 giờ),
# rồi thử đẩy bản mới nhất về trụ sở. Nhãn khác "cuahang" để Service không chọn pod của Job.
apiVersion: batch/v1
kind: CronJob
metadata:
  name: cuahang-sao-luu
  namespace: banhang
  labels:
    app.kubernetes.io/name: cuahang-sao-luu
    app.kubernetes.io/part-of: banhang
spec:
  schedule: "*/15 * * * *"
  timeZone: Asia/Ho_Chi_Minh
  concurrencyPolicy: Forbid
  startingDeadlineSeconds: 300
  successfulJobsHistoryLimit: 3
  failedJobsHistoryLimit: 5
  jobTemplate:
    spec:
      backoffLimit: 2
      activeDeadlineSeconds: 600
      template:
        metadata:
          labels:
            app.kubernetes.io/name: cuahang-sao-luu
            app.kubernetes.io/part-of: banhang
        spec:
          restartPolicy: OnFailure
          securityContext:
            runAsNonRoot: true
            runAsUser: 1654
            runAsGroup: 1654
            fsGroup: 1654
            seccompProfile:
              type: RuntimeDefault
          containers:
            - name: sao-luu
              image: registry.banhang.local/banhang/cuahang:2.1.0
              args: ["sao-luu", "--du-lieu", "/data", "--sao-luu", "/sao-luu", "--giu", "96"]
              envFrom:
                - configMapRef:
                    name: cuahang-cauhinh
              resources:
                requests:
                  cpu: 100m
                  memory: 128Mi
                limits:
                  memory: 256Mi
              securityContext:
                allowPrivilegeEscalation: false
                readOnlyRootFilesystem: true
                capabilities:
                  drop: ["ALL"]
              volumeMounts:
                - name: data              # cùng PVC với Deployment: RWO cho phép vì cùng node
                  mountPath: /data
                - name: sao-luu
                  mountPath: /sao-luu
                - name: tmp
                  mountPath: /tmp
          volumes:
            - name: data
              persistentVolumeClaim:
                claimName: cuahang-data
            - name: sao-luu
              hostPath:
                path: /mnt/sao-luu
                type: Directory
            - name: tmp
              emptyDir:
                sizeLimit: 64Mi
# ===== deployment.yaml
# BanHang.CuaHang: backend bán tại quầy, bán được khi mất mạng, đồng bộ về trụ sở.
# Không ghi spec.replicas: HPA (hpa.yaml) giữ số pod trong khoảng 2-3.
apiVersion: apps/v1
kind: Deployment
metadata:
  name: cuahang
  namespace: banhang
  labels:
    app.kubernetes.io/name: cuahang
    app.kubernetes.io/part-of: banhang
spec:
  revisionHistoryLimit: 5
  strategy:
    type: RollingUpdate
    rollingUpdate:
      maxSurge: 1
      maxUnavailable: 0
  selector:
    matchLabels:
      app.kubernetes.io/name: cuahang
  template:
    metadata:
      labels:
        app.kubernetes.io/name: cuahang
        app.kubernetes.io/part-of: banhang
    spec:
      terminationGracePeriodSeconds: 30   # > preStop 5 s + ShutdownTimeout 15 s
      securityContext:
        runAsNonRoot: true
        runAsUser: 1654                    # user "app" của image .NET từ bản 8
        runAsGroup: 1654
        fsGroup: 1654
        seccompProfile:
          type: RuntimeDefault
      initContainers:
        # Volume trống (máy mới, PVC mới) thì chép bản sao lưu mới nhất vào trước khi app chạy.
        - name: khoi-phuc
          image: registry.banhang.local/banhang/cuahang:2.1.0
          args: ["khoi-phuc", "--du-lieu", "/data", "--sao-luu", "/sao-luu"]
          envFrom:
            - configMapRef:
                name: cuahang-cauhinh
          resources:
            requests:
              cpu: 100m
              memory: 128Mi
            limits:
              memory: 256Mi
          securityContext:
            allowPrivilegeEscalation: false
            readOnlyRootFilesystem: true
            capabilities:
              drop: ["ALL"]
          volumeMounts:
            - name: data
              mountPath: /data
            - name: sao-luu
              mountPath: /sao-luu
              readOnly: true
            - name: tmp
              mountPath: /tmp
      containers:
        - name: cuahang
          image: registry.banhang.local/banhang/cuahang:2.1.0
          ports:
            - name: http
              containerPort: 8080
          envFrom:
            - configMapRef:
                name: cuahang-cauhinh
          resources:
            requests:
              cpu: 500m
              memory: 512Mi
            limits:
              cpu: "1"
              memory: 512Mi      # GC tự đặt heap hard limit 75% = 384 MiB
          startupProbe:          # tối đa 24 x 5 s = 120 s để khởi động
            httpGet:
              path: /healthz/live
              port: http
            periodSeconds: 5
            timeoutSeconds: 2
            failureThreshold: 24
          livenessProbe:         # không kiểm phụ thuộc nào
            httpGet:
              path: /healthz/live
              port: http
            periodSeconds: 10
            timeoutSeconds: 2
            failureThreshold: 3
          readinessProbe:        # SQLite cục bộ; mất kết nối trụ sở chỉ là Degraded
            httpGet:
              path: /healthz/ready
              port: http
            periodSeconds: 5
            timeoutSeconds: 2
            failureThreshold: 2
          lifecycle:
            preStop:
              sleep:
                seconds: 5
          securityContext:
            allowPrivilegeEscalation: false
            readOnlyRootFilesystem: true
            capabilities:
              drop: ["ALL"]
          volumeMounts:
            - name: data
              mountPath: /data
            - name: bhpay-api-key
              mountPath: /run/secrets
              readOnly: true
            - name: tmp
              mountPath: /tmp
      volumes:
        - name: data
          persistentVolumeClaim:
            claimName: cuahang-data
        - name: sao-luu                    # ổ thứ hai của máy, gắn sẵn tại /mnt/sao-luu
          hostPath:
            path: /mnt/sao-luu
            type: Directory
        - name: bhpay-api-key              # Secret tạo ngoài Git, xem kustomization.yaml
          secret:
            secretName: bhpay-api-key-v1
            items:
              - key: api-key
                path: BHPay__ApiKey
        - name: tmp
          emptyDir:
            sizeLimit: 64Mi

#:sdk Microsoft.NET.Sdk.Web
#:package Microsoft.Data.Sqlite@10.0.12
// BanHang.CuaHang 2.1.0, bản rút gọn: dotnet run CuaHang.cs -- --urls http://127.0.0.1:8080
// Cùng một file (một image) chạy ba việc: web (mặc định), "sao-luu" (CronJob), "khoi-phuc" (initContainer).
using System.Diagnostics;
using System.Runtime;
using Microsoft.AspNetCore.Diagnostics.HealthChecks;
using Microsoft.Data.Sqlite;
using Microsoft.Extensions.Diagnostics.HealthChecks;

if (args is ["sao-luu", ..]) return await SaoLuu.ChayAsync(args);
if (args is ["khoi-phuc", ..]) return KhoiPhuc.Chay(args);

var batDau = Stopwatch.StartNew();
var builder = WebApplication.CreateBuilder(args);
builder.Logging.ClearProviders();
builder.Configuration.AddKeyPerFile("/run/secrets", optional: true);   // khóa BHPay từ Secret
builder.Services.Configure<HostOptions>(o => o.ShutdownTimeout = TimeSpan.FromSeconds(15));
var cfg = builder.Configuration;
string csdl = cfg.GetConnectionString("CuaHang") ?? "Data Source=cuahang.db";
string maCuaHang = cfg["CuaHang:Ma"] ?? "CHUA-DAT";
DongBo.TruSo = new Uri(cfg["TruSo:Url"] ?? "https://api.banhang.local");
DongBo.ChuKy = TimeSpan.FromSeconds(cfg.GetValue("DongBo:ChuKyGiay", 30));
bool cauHinhCu = cfg.GetValue("CuaHang:CauHinhCu", false);   // bản 2.0.3: đồng bộ chặn lúc khởi động, trụ sở là bắt buộc
Csdl.TaoBang(csdl);

var dangDung = false;
builder.Services.AddHealthChecks()
    .AddCheck("dang-dung", () => dangDung ? HealthCheckResult.Unhealthy() : HealthCheckResult.Healthy(), tags: ["ready"])
    .AddCheck("sqlite", () => Csdl.KiemTra(csdl), tags: ["ready"])
    .AddCheck("tru-so", () => DongBo.VuaThanhCong()
        ? HealthCheckResult.Healthy()
        : new HealthCheckResult(cauHinhCu ? HealthStatus.Unhealthy : HealthStatus.Degraded, "bán offline"),
        tags: ["ready"]);
builder.Services.AddHostedService(_ => new DongBo(csdl, maCuaHang));
var app = builder.Build();

// live: không chạy check nào, chỉ cần tiến trình còn trả lời. ready: SQLite cục bộ, trạng thái trụ sở, đang dừng.
app.MapHealthChecks("/healthz/live", new HealthCheckOptions { Predicate = _ => false });
app.MapHealthChecks("/healthz/ready", new HealthCheckOptions
{
    Predicate = c => c.Tags.Contains("ready"),
    ResponseWriter = (ctx, r) =>
    {
        ctx.Response.ContentType = "text/plain; charset=utf-8";
        return ctx.Response.WriteAsync($"{r.Status} " + string.Join(" ", r.Entries.Select(e => $"{e.Key}={e.Value.Status}")));
    }
});
app.MapPost("/api/don-hang/{maDon}", (string maDon, long tongTien) =>
{
    using var cn = Csdl.Mo(csdl);
    using var cmd = cn.CreateCommand();
    cmd.CommandText = "INSERT OR IGNORE INTO DonHangOffline (MaDon, NgayTao, TongTien) VALUES ($ma, $ngay, $tien)";
    cmd.Parameters.AddWithValue("$ma", maDon);
    cmd.Parameters.AddWithValue("$ngay", DateTime.UtcNow.ToString("O"));
    cmd.Parameters.AddWithValue("$tien", tongTien);
    return cmd.ExecuteNonQuery() == 1 ? Results.Text($"da-ghi {maDon}", statusCode: 201) : Results.Text($"da-co {maDon}");
});
app.MapGet("/api/thong-tin", () =>
{
    var gc = GC.GetGCMemoryInfo();
    var p = Process.GetCurrentProcess();
    return Results.Text($"""
        BanHang.CuaHang 2.1.0 cua hang {maCuaHang}, .NET {Environment.Version}, ServerGC={GCSettings.IsServerGC}
        TotalAvailableMemoryBytes={gc.TotalAvailableMemoryBytes / 1048576.0:F0} MiB, heap={GC.GetTotalMemory(false) / 1048576.0:F1} MiB
        private={p.PrivateMemorySize64 / 1048576.0:F0} MiB, working set={p.WorkingSet64 / 1048576.0:F0} MiB, don cho dong bo={Csdl.ChoDongBo(csdl)}
        """);
});
app.Lifetime.ApplicationStarted.Register(() => Console.WriteLine($"nghe cong sau {batDau.ElapsedMilliseconds} ms"));
app.Lifetime.ApplicationStopping.Register(() => dangDung = true);   // readiness 503; preStop đã chờ trước đó

if (cauHinhCu) await DongBo.MotLanAsync(csdl, maCuaHang, soLan: 3);   // bản 2.0.3: chặn ở đây, chưa mở cổng
app.Run();
return 0;

static class Csdl
{
    public static SqliteConnection Mo(string cs)
    {
        var cn = new SqliteConnection(cs);
        cn.Open();
        return cn;
    }

    public static void TaoBang(string cs)
    {
        using var cn = Mo(cs);
        using var cmd = cn.CreateCommand();
        cmd.CommandText = """
            PRAGMA journal_mode = WAL;
            CREATE TABLE IF NOT EXISTS DonHangOffline (
                MaDon text PRIMARY KEY,
                NgayTao text NOT NULL,
                TongTien integer NOT NULL,          -- đồng
                DaDongBo integer NOT NULL DEFAULT 0
            );
            CREATE INDEX IF NOT EXISTS IX_DonHangOffline_ChoDongBo ON DonHangOffline (MaDon) WHERE DaDongBo = 0;
            """;
        cmd.ExecuteNonQuery();
    }

    public static long ChoDongBo(string cs)
    {
        using var cn = Mo(cs);
        using var cmd = cn.CreateCommand();
        cmd.CommandText = "SELECT COUNT(*) FROM DonHangOffline WHERE DaDongBo = 0";
        return (long)cmd.ExecuteScalar()!;
    }

    public static HealthCheckResult KiemTra(string cs)
    {
        try { return HealthCheckResult.Healthy($"{ChoDongBo(cs)} đơn chờ đồng bộ"); }
        catch (Exception e) { return HealthCheckResult.Unhealthy(e.Message); }
    }

    // Mở file chỉ đọc, kiểm integrity_check và đếm đơn. Dùng cho bản sao lưu.
    public static (bool Tot, long SoDon) KiemFile(string file)
    {
        try
        {
            using var cn = new SqliteConnection($"Data Source={file};Mode=ReadOnly;Pooling=False");
            cn.Open();
            using var cmd = cn.CreateCommand();
            cmd.CommandText = "PRAGMA integrity_check";
            if ((string)cmd.ExecuteScalar()! != "ok") return (false, 0);
            cmd.CommandText = "SELECT COUNT(*) FROM DonHangOffline";
            return (true, (long)cmd.ExecuteScalar()!);
        }
        catch (SqliteException) { return (false, 0); }
    }
}

// Đẩy đơn chưa đồng bộ về BanHang.Api mỗi DongBo:ChuKyGiay giây. Lỗi mạng không làm app dừng.
sealed class DongBo(string csdl, string maCuaHang) : BackgroundService
{
    public static Uri TruSo = new("https://api.banhang.local");
    public static TimeSpan ChuKy = TimeSpan.FromSeconds(30);
    static readonly HttpClient Http = new() { Timeout = TimeSpan.FromSeconds(10) };
    static long _lanCuoi;   // ticks UTC của lần đồng bộ thành công gần nhất
    // Trụ sở "tốt" nếu đồng bộ thành công trong ba chu kỳ gần nhất.
    public static bool VuaThanhCong() => DateTime.UtcNow.Ticks - Interlocked.Read(ref _lanCuoi) < 3 * ChuKy.Ticks;

    protected override async Task ExecuteAsync(CancellationToken ct)
    {
        while (!ct.IsCancellationRequested)
        {
            try { await MotLanAsync(csdl, maCuaHang, soLan: 1, ct); }
            catch (Exception e) when (!ct.IsCancellationRequested) { Console.WriteLine($"dong-bo loi: {e.Message}"); }
            await Task.Delay(ChuKy, ct);
        }
    }

    public static async Task MotLanAsync(string csdl, string maCuaHang, int soLan, CancellationToken ct = default)
    {
        for (int lan = 1; lan <= soLan; lan++)
        {
            try
            {
                using var cn = Csdl.Mo(csdl);
                using var cmd = cn.CreateCommand();
                cmd.CommandText = "SELECT MaDon || ';' || NgayTao || ';' || TongTien FROM DonHangOffline WHERE DaDongBo = 0 LIMIT 100";
                var dong = new List<string>();
                using (var r = cmd.ExecuteReader()) while (r.Read()) dong.Add(r.GetString(0));
                using var res = await Http.PostAsync(new Uri(TruSo, $"/api/cua-hang/{maCuaHang}/don-hang"),
                    new StringContent(string.Join('\n', dong)), ct);
                res.EnsureSuccessStatusCode();   // trụ sở khử trùng theo MaDon
                foreach (var d in dong)
                {
                    cmd.CommandText = "UPDATE DonHangOffline SET DaDongBo = 1 WHERE MaDon = $ma";
                    cmd.Parameters.Clear();
                    cmd.Parameters.AddWithValue("$ma", d.Split(';')[0]);
                    cmd.ExecuteNonQuery();
                }
                Interlocked.Exchange(ref _lanCuoi, DateTime.UtcNow.Ticks);
                return;
            }
            catch (Exception e) when (e is HttpRequestException or TaskCanceledException && !ct.IsCancellationRequested)
            {
                if (lan < soLan) await Task.Delay(TimeSpan.FromSeconds(2), ct);
            }
        }
    }
}

static class SaoLuu
{
    // sao-luu --du-lieu /data --sao-luu /sao-luu --giu 96
    public static async Task<int> ChayAsync(string[] args)
    {
        string duLieu = Tham(args, "--du-lieu", "."), noiLuu = Tham(args, "--sao-luu", "sao-luu");
        int giu = int.Parse(Tham(args, "--giu", "96"));
        if (!File.Exists(Path.Combine(noiLuu, ".o-sao-luu")))
        {
            Console.Error.WriteLine($"o sao luu chua gan: thieu {Path.Combine(noiLuu, ".o-sao-luu")}");   // không ghi nhầm vào ổ chính
            return 2;
        }
        var sw = Stopwatch.StartNew();
        string tam = Path.Combine(noiLuu, $".dang-ghi-{Guid.NewGuid():N}.db");
        using (var nguon = new SqliteConnection($"Data Source={Path.Combine(duLieu, "cuahang.db")};Mode=ReadWrite;Pooling=False"))
        using (var dich = new SqliteConnection($"Data Source={tam};Pooling=False"))
        {
            nguon.Open();
            dich.Open();
            nguon.BackupDatabase(dich);        // sqlite3_backup: một ảnh nhất quán, app vẫn ghi được
            using var cmd = dich.CreateCommand();
            cmd.CommandText = "PRAGMA journal_mode = DELETE";   // bản sao đọc được trên mount chỉ đọc
            cmd.ExecuteNonQuery();
        }
        var (tot, soDon) = Csdl.KiemFile(tam);
        if (!tot) { File.Delete(tam); Console.Error.WriteLine("ban sao loi integrity_check"); return 3; }
        string ten = Path.Combine(noiLuu, $"cuahang-{DateTime.UtcNow:yyyyMMdd-HHmmss}.db");
        File.Move(tam, ten);
        foreach (var cu in Directory.GetFiles(noiLuu, "cuahang-*.db").Order().SkipLast(giu)) File.Delete(cu);
        Console.WriteLine($"sao-luu {Path.GetFileName(ten)}: {soDon} don, {sw.ElapsedMilliseconds} ms");
        try   // có mạng thì đẩy thêm một bản về trụ sở; mất mạng thì bản trên ổ thứ hai là đủ cho lần này
        {
            using var http = new HttpClient { Timeout = TimeSpan.FromSeconds(30) };
            string ma = Environment.GetEnvironmentVariable("CuaHang__Ma") ?? "CHUA-DAT";
            var goc = new Uri(Environment.GetEnvironmentVariable("TruSo__Url") ?? "https://api.banhang.local");
            await using var f = File.OpenRead(ten);
            using var res = await http.PutAsync(new Uri(goc, $"/api/cua-hang/{ma}/sao-luu/{Path.GetFileName(ten)}"), new StreamContent(f));
            Console.WriteLine($"day ve tru so: {(int)res.StatusCode}");
        }
        catch (Exception e) when (e is HttpRequestException or TaskCanceledException)
        {
            Console.WriteLine($"chua day ve tru so: {e.GetType().Name}");
        }
        return 0;
    }

    public static string Tham(string[] args, string ten, string macDinh)
    {
        int i = Array.IndexOf(args, ten);
        return i >= 0 && i + 1 < args.Length ? args[i + 1] : macDinh;
    }
}

static class KhoiPhuc
{
    // khoi-phuc --du-lieu /data --sao-luu /sao-luu: chỉ chạy khi volume còn trống
    public static int Chay(string[] args)
    {
        string duLieu = SaoLuu.Tham(args, "--du-lieu", "."), noiLuu = SaoLuu.Tham(args, "--sao-luu", "sao-luu");
        string dich = Path.Combine(duLieu, "cuahang.db");
        if (File.Exists(dich)) { Console.WriteLine("da co du lieu, bo qua"); return 0; }
        if (!File.Exists(Path.Combine(noiLuu, ".o-sao-luu")))
        {
            Console.WriteLine("CANH BAO: khong thay o sao luu, bat dau voi du lieu trong");
            return 0;
        }
        foreach (var f in Directory.GetFiles(noiLuu, "cuahang-*.db").OrderDescending())
        {
            var (tot, soDon) = Csdl.KiemFile(f);
            if (!tot) { Console.WriteLine($"bo qua {Path.GetFileName(f)}: hong"); continue; }
            File.Copy(f, dich + ".tam", overwrite: true);
            File.Move(dich + ".tam", dich);
            Console.WriteLine($"khoi-phuc tu {Path.GetFileName(f)}: {soDon} don");
            return 0;
        }
        Console.WriteLine("khong co ban sao luu, bat dau voi du lieu trong");
        return 0;
    }
}

#:package Microsoft.Data.Sqlite@10.0.12
// SaoLuuThu.cs: sao lưu file SQLite đang mở bằng ba cách, đếm đơn thiếu và kiểm integrity_check.
// dotnet run SaoLuuThu.cs   (cùng thư mục với CuaHang.cs; phần 3 gọi lệnh sao-luu/khoi-phuc của CuaHang)
using System.Diagnostics;
using Microsoft.Data.Sqlite;

string goc = Directory.CreateTempSubdirectory("saoluu-").FullName;
const string Ddl = """
    PRAGMA journal_mode = WAL;
    CREATE TABLE IF NOT EXISTS DonHangOffline (
        MaDon text PRIMARY KEY, NgayTao text NOT NULL, TongTien integer NOT NULL, DaDongBo integer NOT NULL DEFAULT 0);
    CREATE INDEX IF NOT EXISTS IX_DonHangOffline_ChoDongBo ON DonHangOffline (MaDon) WHERE DaDongBo = 0;
    """;
long soMa = 0;

// Phần 1: app đang mở kết nối (pool), ghi 65 đơn của một ngày bán, rồi sao lưu khi không ai ghi.
string db1 = TaoCsdl("p1", 20_000);
using (var app = Mo(db1)) { for (int i = 0; i < 65; i++) Ghi(app); }   // kết nối trả về pool, vẫn mở
Console.WriteLine("Phan 1: 20.000 don cu da checkpoint, them 65 don, app con mo ket noi");
foreach (var cach in new[] { "chep .db", "chep .db + -wal", "BackupDatabase" })
{
    var (tot, so) = Kiem(SaoLuu(cach, db1, Path.Combine(goc, $"p1-{cach.Replace(' ', '_').Replace('+', 'v')}.db")));
    Console.WriteLine($"  {cach,-18} integrity={(tot ? "ok" : "HONG")}  {so} don, thieu {20_065 - so}");
}

// Phần 2: một luồng ghi liên tục từng đơn một; mỗi cách sao lưu 30 lần giữa lúc đang ghi.
string db2 = TaoCsdl("p2", 20_000);
long daCommit = 20_000;
using var dung = new CancellationTokenSource();
var ghi = Task.Run(() =>
{
    using var cn = Mo(db2);
    while (!dung.IsCancellationRequested) { Ghi(cn); Interlocked.Increment(ref daCommit); Thread.Sleep(2); }
});
Console.WriteLine("\nPhan 2: sao luu trong luc mot luong ghi lien tuc, 30 lan moi cach");
foreach (var cach in new[] { "chep .db", "chep .db + -wal", "BackupDatabase" })
{
    int hong = 0; long thieuMax = 0, thieuTong = 0; var ms = new List<double>();
    for (int lan = 0; lan < 30; lan++)
    {
        Thread.Sleep(200);
        long truoc = Interlocked.Read(ref daCommit);          // đơn đã commit trước khi bắt đầu sao lưu
        var sw = Stopwatch.StartNew();
        string ban = SaoLuu(cach, db2, Path.Combine(goc, $"p2-{lan}-{cach.Length}.db"));
        ms.Add(sw.Elapsed.TotalMilliseconds);
        var (tot, so) = Kiem(ban);
        if (!tot) { hong++; continue; }
        long thieu = Math.Max(0, truoc - so);
        thieuMax = Math.Max(thieuMax, thieu); thieuTong += thieu;
    }
    Console.WriteLine($"  {cach,-18} hong {hong}/30, thieu TB {thieuTong / (30.0 - hong):F0} don, toi da {thieuMax}, thoi gian TB {ms.Average():F0} ms");
}
dung.Cancel(); await ghi;
Console.WriteLine($"  luong ghi da commit {daCommit - 20_000} don trong phan 2");

// Phần 3: chạy đúng lệnh của image: sao-luu, mất ổ dữ liệu, khoi-phuc vào volume trống.
Process.Start("dotnet", "build CuaHang.cs -o out-cuahang -v q").WaitForExit();
string exe = Path.GetFullPath(Path.Combine("out-cuahang", OperatingSystem.IsWindows() ? "CuaHang.exe" : "CuaHang"));
string duLieu = Path.Combine(goc, "data"), noiLuu = Path.Combine(goc, "o-sao-luu"), duLieuMoi = Path.Combine(goc, "data-may-moi");
Directory.CreateDirectory(duLieu); Directory.CreateDirectory(noiLuu); Directory.CreateDirectory(duLieuMoi);
SqliteConnection.ClearAllPools();                                        // đóng hẳn: -wal được gộp vào file chính
File.Copy(db1, Path.Combine(duLieu, "cuahang.db"));
Console.WriteLine("\nPhan 3: lenh cua image");
Chay("sao-luu (chua gan o)", "sao-luu", "--du-lieu", "data", "--sao-luu", "o-sao-luu");
File.WriteAllText(Path.Combine(noiLuu, ".o-sao-luu"), "o thu hai");
Chay("sao-luu", "sao-luu", "--du-lieu", "data", "--sao-luu", "o-sao-luu", "--giu", "96");
Console.WriteLine($"  ban sao luu: {new FileInfo(Directory.GetFiles(noiLuu, "cuahang-*.db").Single()).Length / 1024} KiB");
Chay("khoi-phuc (volume trong)", "khoi-phuc", "--du-lieu", "data-may-moi", "--sao-luu", "o-sao-luu");
Chay("khoi-phuc (da co du lieu)", "khoi-phuc", "--du-lieu", "data-may-moi", "--sao-luu", "o-sao-luu");
Console.WriteLine($"  volume moi: {Kiem(Path.Combine(duLieuMoi, "cuahang.db")).SoDon} don");
return 0;

void Chay(string ten, params string[] a)
{
    var psi = new ProcessStartInfo(exe, a) { RedirectStandardOutput = true, RedirectStandardError = true, WorkingDirectory = goc };
    psi.Environment["TruSo__Url"] = "http://127.0.0.1:9";       // trụ sở không với tới: như lúc mất mạng
    var sw = Stopwatch.StartNew();
    using var p = Process.Start(psi)!;
    string o = (p.StandardOutput.ReadToEnd() + p.StandardError.ReadToEnd()).Trim().Replace(Environment.NewLine, " | ");
    p.WaitForExit();
    Console.WriteLine($"  {ten,-26} exit {p.ExitCode}, {sw.ElapsedMilliseconds} ms: {o}");
}

string TaoCsdl(string ten, int soDon)
{
    string f = Path.Combine(goc, ten + ".db");
    using var cn = Mo(f);
    using (var cmd = cn.CreateCommand()) { cmd.CommandText = Ddl; cmd.ExecuteNonQuery(); }
    using (var tx = cn.BeginTransaction()) { for (int i = 0; i < soDon; i++) Ghi(cn, tx); tx.Commit(); }
    using (var cmd = cn.CreateCommand()) { cmd.CommandText = "PRAGMA wal_checkpoint(TRUNCATE)"; cmd.ExecuteNonQuery(); }
    return f;
}

SqliteConnection Mo(string f) { var cn = new SqliteConnection($"Data Source={f}"); cn.Open(); return cn; }

void Ghi(SqliteConnection cn, SqliteTransaction? tx = null)
{
    using var cmd = cn.CreateCommand();
    cmd.Transaction = tx;
    cmd.CommandText = "INSERT INTO DonHangOffline (MaDon, NgayTao, TongTien) VALUES ($ma, $ngay, 1500000)";
    cmd.Parameters.AddWithValue("$ma", $"CH06-{Interlocked.Increment(ref soMa):D8}");
    cmd.Parameters.AddWithValue("$ngay", DateTime.UtcNow.ToString("O"));
    cmd.ExecuteNonQuery();
}

// Ba cách: "cp" file chính; "cp" file chính rồi file -wal; API sao lưu trực tuyến của SQLite.
string SaoLuu(string cach, string nguon, string dich)
{
    if (cach == "BackupDatabase")
    {
        using var a = new SqliteConnection($"Data Source={nguon};Mode=ReadWrite;Pooling=False");
        using var b = new SqliteConnection($"Data Source={dich};Pooling=False");
        a.Open(); b.Open();
        a.BackupDatabase(b);
        return dich;
    }
    Chep(nguon, dich);
    if (cach.Contains("-wal") && File.Exists(nguon + "-wal")) Chep(nguon + "-wal", dich + "-wal");
    return dich;
}

static void Chep(string tu, string den)    // như cp: đọc file đang được tiến trình khác ghi
{
    using var r = new FileStream(tu, FileMode.Open, FileAccess.Read, FileShare.ReadWrite | FileShare.Delete);
    using var w = File.Create(den);
    r.CopyTo(w);
}

static (bool Tot, long SoDon) Kiem(string f)
{
    try
    {
        using var cn = new SqliteConnection($"Data Source={f};Pooling=False");
        cn.Open();
        using var cmd = cn.CreateCommand();
        cmd.CommandText = "PRAGMA integrity_check";
        if ((string)cmd.ExecuteScalar()! != "ok") return (false, 0);
        cmd.CommandText = "SELECT COUNT(*) FROM DonHangOffline";
        return (true, (long)cmd.ExecuteScalar()!);
    }
    catch (SqliteException) { return (false, 0); }
}