shishengliang/lingniu-vehicle-ingest
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat(platform): include plates in raw history

Browse Source
This commit is contained in:
lingniu
2026-07-03 23:17:23 +08:00
parent a644a6617c
commit a4e9a8afb8
6 changed files with 60 additions and 25 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
vehicle-data-platform/apps/api/internal/platform/handler_test.go
View File

@@ -110,7 +110,7 @@ func TestHandlerHistoryMileageQualityOps(t *testing.T) {
want string
}{
{"/api/history/locations?limit=10", "totalMileageKm"},
{"/api/history/raw-frames?protocol=GB32960&vin=LB9A32A24R0LS1426&limit=1&includeFields=true", "rawSizeBytes"},
{"/api/history/raw-frames?protocol=GB32960&vin=LB9A32A24R0LS1426&limit=1&includeFields=true", "plate"},
{"/api/mileage/daily?limit=10", "dailyMileageKm"},
{"/api/quality/issues?limit=10", "issueType"},
{"/api/ops/health", "linkHealth"},

2
vehicle-data-platform/apps/api/internal/platform/mock_store.go
View File

@@ -221,7 +221,7 @@ func (m *MockStore) RawFrames(_ context.Context, query RawFrameQuery) (Page[RawF
protocol := defaultString(query.Protocol, "GB32960")
vin := defaultString(query.VIN, "LB9A32A24R0LS1426")
rows := []RawFrameRow{
{ID: "raw-20260703-001", VIN: vin, Protocol: protocol, FrameType: "realtime", DeviceTime: "2026-07-03 20:12:06", ServerTime: "2026-07-03 20:12:06", RawSizeBytes: 430, ParsedFields: fields},
{ID: "raw-20260703-001", VIN: vin, Plate: "粤AG18312", Protocol: protocol, FrameType: "realtime", DeviceTime: "2026-07-03 20:12:06", ServerTime: "2026-07-03 20:12:06", RawSizeBytes: 430, ParsedFields: fields},
}
limit := query.Limit
if limit <= 0 {

1
vehicle-data-platform/apps/api/internal/platform/model.go
View File

@@ -122,6 +122,7 @@ type HistoryLocationRow struct {
type RawFrameRow struct {
ID string `json:"id"`
VIN string `json:"vin"`
Plate string `json:"plate"`
Protocol string `json:"protocol"`
FrameType string `json:"frameType"`
DeviceTime string `json:"deviceTime"`

76
vehicle-data-platform/apps/api/internal/platform/production_store.go
View File

@@ -305,31 +305,10 @@ func (s *ProductionStore) enrichHistoryLocationPlates(ctx context.Context, items
seen[vin] = struct{}{}
vins = append(vins, vin)
}
if len(vins) == 0 {
return nil
}
placeholders := make([]string, len(vins))
args := make([]any, len(vins))
for index, vin := range vins {
placeholders[index] = "?"
args[index] = vin
}
rows, err := s.db.QueryContext(ctx, `SELECT vin, COALESCE(plate, '') FROM vehicle_identity_binding WHERE vin IN (`+strings.Join(placeholders, ",")+`)`, args...)
plates, err := s.platesByVIN(ctx, vins)
if err != nil {
return err
}
defer rows.Close()
plates := map[string]string{}
for rows.Next() {
var vin, plate string
if err := rows.Scan(&vin, &plate); err != nil {
return err
}
plates[vin] = plate
}
if err := rows.Err(); err != nil {
return err
}
for index := range items {
if strings.TrimSpace(items[index].Plate) != "" {
continue
@@ -339,6 +318,56 @@ func (s *ProductionStore) enrichHistoryLocationPlates(ctx context.Context, items
return nil
}
func (s *ProductionStore) enrichRawFramePlates(ctx context.Context, items []RawFrameRow) error {
vins := make([]string, 0)
seen := map[string]struct{}{}
for _, item := range items {
vin := strings.TrimSpace(item.VIN)
if vin == "" {
continue
}
if _, ok := seen[vin]; ok {
continue
}
seen[vin] = struct{}{}
vins = append(vins, vin)
}
plates, err := s.platesByVIN(ctx, vins)
if err != nil {
return err
}
for index := range items {
items[index].Plate = plates[items[index].VIN]
}
return nil
}
func (s *ProductionStore) platesByVIN(ctx context.Context, vins []string) (map[string]string, error) {
if len(vins) == 0 {
return map[string]string{}, nil
}
placeholders := make([]string, len(vins))
args := make([]any, len(vins))
for index, vin := range vins {
placeholders[index] = "?"
args[index] = vin
}
rows, err := s.db.QueryContext(ctx, `SELECT vin, COALESCE(plate, '') FROM vehicle_identity_binding WHERE vin IN (`+strings.Join(placeholders, ",")+`)`, args...)
if err != nil {
return nil, err
}
defer rows.Close()
plates := map[string]string{}
for rows.Next() {
var vin, plate string
if err := rows.Scan(&vin, &plate); err != nil {
return nil, err
}
plates[vin] = plate
}
return plates, rows.Err()
}
func (s *ProductionStore) RawFrames(ctx context.Context, query RawFrameQuery) (Page[RawFrameRow], error) {
if s.tdengine == nil {
return Page[RawFrameRow]{Items: []RawFrameRow{}, Total: 0, Limit: query.Limit, Offset: query.Offset}, nil
@@ -382,6 +411,9 @@ func (s *ProductionStore) RawFrames(ctx context.Context, query RawFrameQuery) (P
if built.CountText == "" {
total = len(items)
}
if err := s.enrichRawFramePlates(ctx, items); err != nil {
return Page[RawFrameRow]{}, err
}
return Page[RawFrameRow]{Items: items, Total: total, Limit: query.Limit, Offset: query.Offset}, nil
}