lingniu-vehicle-ingest/go/vehicle-gateway/internal/stats/daily_metric_test.go

package stats

import (
	"context"
	"database/sql"
	"strings"
	"testing"
	"time"

	"lingniu-vehicle-ingest/go/vehicle-gateway/internal/envelope"
)

func TestSamplesFromEnvelopeDerivesDailyMileageAndTotal(t *testing.T) {
	loc := time.FixedZone("Asia/Shanghai", 8*3600)
	env := envelope.FrameEnvelope{
		Protocol:    envelope.ProtocolJT808,
		VIN:         "LNBVIN00000000001",
		EventTimeMS: time.Date(2026, 7, 1, 8, 30, 0, 0, loc).UnixMilli(),
		Fields: map[string]any{
			envelope.FieldTotalMileageKM: 10241.2,
		},
	}

	samples, err := SamplesFromEnvelope(env, loc)
	if err != nil {
		t.Fatalf("SamplesFromEnvelope() error = %v", err)
	}
	if len(samples) != 2 {
		t.Fatalf("sample count = %d", len(samples))
	}
	if samples[0].MetricKey != MetricDailyMileageKM || samples[0].MetricValue != 0 {
		t.Fatalf("unexpected daily mileage sample: %#v", samples[0])
	}
	if samples[0].VehicleKey != "LNBVIN00000000001" {
		t.Fatalf("vehicle key = %q", samples[0].VehicleKey)
	}
	if samples[1].MetricKey != MetricDailyTotalMileageKM || samples[1].MetricValue != 10241.2 {
		t.Fatalf("unexpected daily total sample: %#v", samples[1])
	}
	if samples[0].StatDate != "2026-07-01" {
		t.Fatalf("stat date = %q", samples[0].StatDate)
	}
}

func TestSamplesFromEnvelopeUsesVehicleKeyWhenVINIsMissing(t *testing.T) {
	loc := time.FixedZone("Asia/Shanghai", 8*3600)
	samples, err := SamplesFromEnvelope(envelope.FrameEnvelope{
		Protocol:    envelope.ProtocolJT808,
		Phone:       "013307811254",
		EventTimeMS: time.Date(2026, 7, 2, 0, 3, 0, 0, loc).UnixMilli(),
		Fields: map[string]any{
			envelope.FieldTotalMileageKM: 10985.7,
		},
	}, loc)
	if err != nil {
		t.Fatalf("SamplesFromEnvelope() error = %v", err)
	}
	if len(samples) != 2 {
		t.Fatalf("sample count = %d", len(samples))
	}
	if samples[0].VehicleKey != "JT808:013307811254" {
		t.Fatalf("vehicle key = %q", samples[0].VehicleKey)
	}
	if samples[0].VIN != "" {
		t.Fatalf("vin should stay empty for unresolved JT808 identity, got %q", samples[0].VIN)
	}
}

func TestSamplesFromEnvelopeSkipsMissingVehicleKeyOrMileage(t *testing.T) {
	samples, err := SamplesFromEnvelope(envelope.FrameEnvelope{
		Protocol: envelope.ProtocolJT808,
		Fields:   map[string]any{envelope.FieldTotalMileageKM: 1.2},
	}, nil)
	if err != nil {
		t.Fatalf("SamplesFromEnvelope() error = %v", err)
	}
	if len(samples) != 0 {
		t.Fatalf("expected no samples without vehicle key, got %#v", samples)
	}

	samples, err = SamplesFromEnvelope(envelope.FrameEnvelope{
		Protocol: envelope.ProtocolGB32960,
		VIN:      "LNBVIN00000000002",
		Fields:   map[string]any{},
	}, nil)
	if err != nil {
		t.Fatalf("SamplesFromEnvelope() error = %v", err)
	}
	if len(samples) != 0 {
		t.Fatalf("expected no samples without mileage, got %#v", samples)
	}
}

func TestSamplesFromEnvelopeSkipsNonPositiveMileage(t *testing.T) {
	for _, value := range []any{0, 0.0, -1.0, "0"} {
		samples, err := SamplesFromEnvelope(envelope.FrameEnvelope{
			Protocol:    envelope.ProtocolJT808,
			VIN:         "LNBVIN00000000001",
			EventTimeMS: time.Date(2026, 7, 1, 9, 0, 0, 0, time.FixedZone("Asia/Shanghai", 8*3600)).UnixMilli(),
			Fields: map[string]any{
				envelope.FieldTotalMileageKM: value,
			},
		}, nil)
		if err != nil {
			t.Fatalf("SamplesFromEnvelope(%#v) error = %v", value, err)
		}
		if len(samples) != 0 {
			t.Fatalf("expected no samples for non-positive mileage %#v, got %#v", value, samples)
		}
	}
}

func TestWriterEnsuresSchemaAndUpsertsTwoMetrics(t *testing.T) {
	exec := &recordingExec{}
	writer := NewWriter(exec, time.FixedZone("Asia/Shanghai", 8*3600))
	if err := writer.EnsureSchema(context.Background()); err != nil {
		t.Fatalf("EnsureSchema() error = %v", err)
	}
	if err := writer.Append(context.Background(), envelope.FrameEnvelope{
		Protocol:    envelope.ProtocolGB32960,
		VIN:         "LNBVIN00000000002",
		EventTimeMS: time.Date(2026, 7, 1, 9, 0, 0, 0, time.FixedZone("Asia/Shanghai", 8*3600)).UnixMilli(),
		Fields: map[string]any{
			envelope.FieldTotalMileageKM: "10000.0",
		},
	}); err != nil {
		t.Fatalf("Append() error = %v", err)
	}

	if !strings.Contains(exec.calls[0].query, "CREATE TABLE IF NOT EXISTS vehicle_daily_metric") {
		t.Fatalf("unexpected schema sql: %s", exec.calls[0].query)
	}
	if !strings.Contains(exec.calls[0].query, "vehicle_key") {
		t.Fatalf("schema should include vehicle_key: %s", exec.calls[0].query)
	}
	if len(exec.calls) != 3 {
		t.Fatalf("exec calls = %d", len(exec.calls))
	}
	if !strings.Contains(exec.calls[1].query, "ON DUPLICATE KEY UPDATE") {
		t.Fatalf("unexpected upsert sql: %s", exec.calls[1].query)
	}
	if !strings.Contains(exec.calls[1].query, "first_total_mileage_km <= 0") {
		t.Fatalf("upsert should ignore legacy zero first mileage: %s", exec.calls[1].query)
	}
	if got := exec.calls[1].args[0]; got != "LNBVIN00000000002" {
		t.Fatalf("first upsert arg should be vehicle_key, got %#v", got)
	}
}

type execCall struct {
	query string
	args  []any
}

type recordingExec struct {
	calls []execCall
}

func (e *recordingExec) ExecContext(_ context.Context, query string, args ...any) (sql.Result, error) {
	e.calls = append(e.calls, execCall{query: query, args: args})
	return nil, nil
}