V10.534 收緊 PChome rescore 覆核語意

scripts/audit_competitor_match_attempt_rescore.py

@@ -20,8 +20,10 @@ from services.competitor_match_attempt_rescore_audit import (  # noqa: E402
     DEFAULT_RESCAN_STATUSES,
     build_match_attempt_rescore_audit,
     fetch_match_attempt_rescore_rows,
+    fetch_unsafe_rescore_accept_review_rows,
     fetch_variant_rescore_accept_review_rows,
     materialize_rescore_accept_reviews,
+    retract_unsafe_rescore_accept_reviews,
     retract_variant_rescore_accept_reviews,
     summarize_match_attempt_rescore,
 )
@@ -92,12 +94,20 @@ def main(argv: list[str] | None = None) -> int:
             "attempts that contain variant_selection_review; never writes competitor_prices."
         ),
     )
+    parser.add_argument(
+        "--retract-unsafe-accepted",
+        action="store_true",
+        help=(
+            "Append low-confidence retraction rows for latest rescore_accepted_current "
+            "attempts that no longer pass the current accept-review gate; never writes competitor_prices."
+        ),
+    )
     args = parser.parse_args(argv)
 
     statuses = tuple(args.statuses or DEFAULT_RESCAN_STATUSES)
     if args.input:
-        if args.apply_accepted or args.retract_variant_accepted:
-            parser.error("--apply-accepted/--retract-variant-accepted require DB mode; do not combine them with --input.")
+        if args.apply_accepted or args.retract_variant_accepted or args.retract_unsafe_accepted:
+            parser.error("write modes require DB mode; do not combine them with --input.")
         rows = [row for row in _read_jsonl(args.input) if not row.get("_invalid_json")]
         summary = summarize_match_attempt_rescore(
             rows,
@@ -108,9 +118,33 @@ def main(argv: list[str] | None = None) -> int:
         from config import DATABASE_PATH
 
         engine = create_engine(DATABASE_PATH)
-        if args.apply_accepted and args.retract_variant_accepted:
-            parser.error("Choose only one write mode: --apply-accepted or --retract-variant-accepted.")
-        if args.retract_variant_accepted:
+        write_modes = sum(bool(flag) for flag in (
+            args.apply_accepted,
+            args.retract_variant_accepted,
+            args.retract_unsafe_accepted,
+        ))
+        if write_modes > 1:
+            parser.error("Choose only one write mode.")
+        if args.retract_unsafe_accepted:
+            with engine.begin() as conn:
+                rows = fetch_unsafe_rescore_accept_review_rows(
+                    conn,
+                    source=args.source,
+                    limit=args.limit,
+                    min_score=args.min_score,
+                )
+                summary = {
+                    "selection_mode": "latest_sku_only",
+                    "scanned": len(rows),
+                    "rows": rows[: max(0, args.sample_limit)],
+                    "retraction": retract_unsafe_rescore_accept_reviews(
+                        conn,
+                        rows,
+                        source=args.source,
+                        min_score=args.min_score,
+                    ),
+                }
+        elif args.retract_variant_accepted:
             with engine.begin() as conn:
                 rows = fetch_variant_rescore_accept_review_rows(
                     conn,