- {item.link_type === "vehicle" ? (
+ {item.issue_ref ? (
+ {item.title}
+ ) : item.link_type === "vehicle" ? (
{item.title}
) : (
item.title
diff --git a/frontend/src/pages/DataQuality.tsx b/frontend/src/pages/DataQuality.tsx
new file mode 100644
index 0000000..bb2d0f5
--- /dev/null
+++ b/frontend/src/pages/DataQuality.tsx
@@ -0,0 +1,96 @@
+import { useEffect, useState } from "react";
+import { Link } from "react-router-dom";
+import { api } from "../api/client";
+import type { DataQualityIssue } from "../api/types";
+import { SeverityBadge, StatusBadge } from "../components/Badge";
+
+const RULE_TYPES = [
+ "possible_duplicate_customer",
+ "missing_required_field",
+ "odometer_regression",
+ "booking_overlap",
+ "vehicle_status_conflict",
+];
+
+export function DataQuality() {
+ const [issues, setIssues] = useState(null);
+ const [error, setError] = useState(null);
+ const [status, setStatus] = useState("open");
+ const [ruleType, setRuleType] = useState("");
+
+ useEffect(() => {
+ const params = new URLSearchParams();
+ if (status) params.set("status", status);
+ if (ruleType) params.set("rule_type", ruleType);
+ api
+ .get(`/api/v1/data-quality/issues?${params.toString()}`)
+ .then(setIssues)
+ .catch(() => setError("Data-quality issues are unavailable right now."));
+ }, [status, ruleType]);
+
+ return (
+
+
Data Quality
+
+
+
+ {error &&
{error}
}
+ {!error && !issues &&
Loading issues…
}
+ {issues && issues.length === 0 &&
No issues match these filters.
}
+
+ {issues && issues.length > 0 && (
+
+ Data-quality issues
+
+
+ | Reference |
+ Rule |
+ Entity |
+ Severity |
+ Status |
+
+
+
+ {issues.map((i) => (
+
+ |
+ {i.public_ref}
+ |
+ {i.rule_type.replace(/_/g, " ")} |
+ {i.entity_ref} |
+
+
+ |
+
+
+ |
+
+ ))}
+
+
+ )}
+
Both customers in this comparison could not be loaded.
;
+ }
+ const a: EntitySnapshot = issue.entity_snapshot;
+ const b: EntitySnapshot = issue.related_snapshots[0];
+
+ const survivor = survivorRef === a.public_ref ? a : b;
+ const loser = survivorRef === a.public_ref ? b : a;
+
+ async function handleMerge() {
+ setError(null);
+ setSubmitting(true);
+ try {
+ const overrides: Record = {};
+ for (const field of MERGE_FIELDS) {
+ const choice = fieldChoices[field];
+ const chosenSide = choice === "a" ? a : choice === "b" ? b : survivor;
+ if (chosenSide !== survivor && chosenSide[field]) {
+ overrides[field] = String(chosenSide[field]);
+ }
+ }
+ await api.post(`/api/v1/data-quality/issues/${issue.public_ref}/merge-customers`, {
+ survivor_ref: survivor.public_ref,
+ field_overrides: Object.keys(overrides).length > 0 ? overrides : undefined,
+ });
+ onResolved();
+ } catch (err) {
+ setError(err instanceof ApiError ? err.message : "Could not merge these customers.");
+ setConfirming(false);
+ } finally {
+ setSubmitting(false);
+ }
+ }
+
+ if (user?.role !== "operations_manager") {
+ return (
+
+ Merging duplicate customers requires the Operations Manager role. Switch role to resolve
+ this issue.
+
+ );
+ }
+
+ return (
+
+ Compare and merge
+ {error && {error}
}
+
+
+
+
+
+
+ {loser.public_ref} will become a tombstone linked to{" "}
+ {survivor.public_ref}; its bookings will be rewired to the survivor.
+
+
+ {!confirming && (
+
+ )}
+ {confirming && (
+
+
+ Merge {loser.public_ref} into {survivor.public_ref}? This cannot be undone.
+
+
+
+
{error}
;
+ if (!issue) return Loading issue…
;
+
+ return (
+
+
← Back to data quality
+
{issue.public_ref}
+
+
+
+
+ - Rule
- {issue.rule_type.replace(/_/g, " ")}
+ - Entity
- {issue.entity_ref}
+ - Evidence
- {String(issue.evidence.summary ?? "")}
+
+
+ {actionError &&
{actionError}
}
+
+ {issue.status === "open" && issue.rule_type === "possible_duplicate_customer" && (
+
+ )}
+
+ {issue.status === "open" && (
+
+ Resolution
+ {issue.rule_type !== "possible_duplicate_customer" && (
+ <>
+ Evidence for this issue:
+ {JSON.stringify(issue.evidence, null, 2)}
+
+ )}
+ Defer to review later, or reject if this is not a real issue.
+
+
+
+
+
+ )}
+