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

fix(platform): count dashboard vehicles by vin

Browse Source
This commit is contained in:
lingniu
2026-07-03 22:31:25 +08:00
parent 1293035045
commit e68028799e
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -41,10 +41,10 @@ func OpenSQL(ctx context.Context, driver, dsn string) (*sql.DB, error) {
func (s *ProductionStore) DashboardSummary(ctx context.Context) (DashboardSummary, error) { func (s *ProductionStore) DashboardSummary(ctx context.Context) (DashboardSummary, error) {
var summary DashboardSummary var summary DashboardSummary
if err := s.db.QueryRowContext(ctx, `SELECT COUNT(*) FROM vehicle_realtime_snapshot WHERE updated_at >= DATE_SUB(NOW(), INTERVAL 1 MINUTE)`).Scan(&summary.OnlineVehicles); err != nil { if err := s.db.QueryRowContext(ctx, `SELECT COUNT(DISTINCT vin) FROM vehicle_realtime_snapshot WHERE vin IS NOT NULL AND vin <> '' AND updated_at >= DATE_SUB(NOW(), INTERVAL 1 MINUTE)`).Scan(&summary.OnlineVehicles); err != nil {
return DashboardSummary{}, err return DashboardSummary{}, err
} }
if err := s.db.QueryRowContext(ctx, `SELECT COUNT(DISTINCT vin) FROM vehicle_realtime_snapshot WHERE updated_at >= CURDATE()`).Scan(&summary.ActiveToday); err != nil { if err := s.db.QueryRowContext(ctx, `SELECT COUNT(DISTINCT vin) FROM vehicle_realtime_snapshot WHERE vin IS NOT NULL AND vin <> '' AND updated_at >= CURDATE()`).Scan(&summary.ActiveToday); err != nil {
return DashboardSummary{}, err return DashboardSummary{}, err
} }
if err := s.db.QueryRowContext(ctx, `SELECT COUNT(*) FROM vehicle_realtime_snapshot WHERE vin = '' OR vin IS NULL`).Scan(&summary.IssueVehicles); err != nil { if err := s.db.QueryRowContext(ctx, `SELECT COUNT(*) FROM vehicle_realtime_snapshot WHERE vin = '' OR vin IS NULL`).Scan(&summary.IssueVehicles); err != nil {