chore(lead-region-ops): add force input for phone-ranges:import

Re-import skips on identical checksum without --force. Adds a 'force' boolean dispatch input wired into the import op so the registry can be re-mapped after the region-normalization fix (PR #44).
Merge pull request #44 from CoralMinister/feat/rossvyaz-region-mapping
2026-06-03 06:12:43 +03:00 · 2026-06-02 15:42:37 +03:00 · 2026-06-02 15:39:35 +03:00 · 2026-06-02 15:22:24 +03:00 · 2026-06-02 13:48:18 +03:00 · 2026-06-02 13:47:47 +03:00
73 changed files with 457023 additions and 1171 deletions
@@ -38,42 +38,12 @@
  },
  "hooks": {
    "PreToolUse": [
-      {
-        "matcher": "Edit|Write|MultiEdit|NotebookEdit|Bash|PowerShell|Skill|Task",
-        "hooks": [
-          {
-            "type": "command",
-            "command": "node tools/enforce-llm-judge-per-tool.mjs",
-            "timeout": 30
-          }
-        ]
-      },
-      {
-        "matcher": "Read|Grep|Glob|LS|TodoWrite|AskUserQuestion|Edit|Write|MultiEdit|NotebookEdit|Bash|Skill|Task|EnterPlanMode",
-        "hooks": [
-          {
-            "type": "command",
-            "command": "node tools/enforce-safe-baseline-metering.mjs",
-            "timeout": 10
-          }
-        ]
-      },
-      {
-        "matcher": "Edit|Write|MultiEdit|NotebookEdit",
-        "hooks": [
-          {
-            "type": "command",
-            "command": "node tools/enforce-runtime-write-deny.mjs",
-            "timeout": 5
-          }
-        ]
-      },
      {
        "matcher": "Edit|Write",
        "hooks": [
          {
            "type": "command",
-            "command": "node -e \"const f=process.env.CLAUDE_FILE_PATH||''; const pd=process.env.CLAUDE_PROJECT_DIR||''; const path=require('path'); if (f && pd && path.resolve(f) === path.resolve(pd, 'CLAUDE.md')) { process.stderr.write('\\n[hook] WARNING: Direct edit of root CLAUDE.md detected. Per CLAUDE.md Р вЂ™Р’В§5 Р В РЎвЂ”.10, prefer /claude-md-management:revise-claude-md or /claude-md-management:claude-md-improver. If invoked via that skill, this warning is informational.\\n'); }\""
+            "command": "node -e \"const f=process.env.CLAUDE_FILE_PATH||''; const pd=process.env.CLAUDE_PROJECT_DIR||''; const path=require('path'); if (f && pd && path.resolve(f) === path.resolve(pd, 'CLAUDE.md')) { process.stderr.write('\\n[hook] WARNING: Direct edit of root CLAUDE.md detected. Per CLAUDE.md §5 п.10, prefer /claude-md-management:revise-claude-md or /claude-md-management:claude-md-improver. If invoked via that skill, this warning is informational.\\n'); }\""
          }
        ]
      },
@@ -82,7 +52,7 @@
        "hooks": [
          {
            "type": "command",
-            "command": "node \"C:/Р В РЎВР В РЎвЂўР РЋР РЏ/Р В РЎвЂ”Р РЋР вЂљР В РЎвЂўР В Р’ВµР В РЎвЂќР РЋРІР‚С™Р РЋРІР‚в„–/Р В РЎвЂ”Р В РЎвЂўР РЋР вЂљР РЋРІР‚С™Р В Р’В°Р В Р’В» crm/Р В РІР‚СњР В РЎвЂўР В РЎвЂќР РЋРЎвЂњР В РЎВР В Р’ВµР В Р вЂ¦Р РЋРІР‚С™Р В Р’В°Р РЋРІР‚В Р В РЎвЂР РЋР РЏ/tools/subagent-prompt-prefix.mjs\""
+            "command": "node \"C:/моя/проекты/портал crm/Документация/tools/subagent-prompt-prefix.mjs\""
          }
        ]
      },
@@ -176,6 +146,16 @@
          }
        ]
      },
+      {
+        "matcher": "AskUserQuestion",
+        "hooks": [
+          {
+            "type": "command",
+            "command": "node tools/askuser-cosmetic-detector.mjs",
+            "timeout": 5
+          }
+        ]
+      },
      {
        "matcher": "mcp__.*",
        "hooks": [
@@ -195,71 +175,6 @@
            "timeout": 5
          }
        ]
-      },
-      {
-        "matcher": "Workflow",
-        "hooks": [
-          {
-            "type": "command",
-            "command": "node tools/enforce-workflow-gate.mjs",
-            "timeout": 5
-          }
-        ]
-      },
-      {
-        "matcher": "Edit|Write|MultiEdit|NotebookEdit|Bash|Task",
-        "hooks": [
-          {
-            "type": "command",
-            "command": "node tools/enforce-decomposition-detector.mjs",
-            "timeout": 8
-          },
-          {
-            "type": "command",
-            "command": "node tools/enforce-parallel-session-lock.mjs",
-            "timeout": 3
-          }
-        ]
-      },
-      {
-        "matcher": "AskUserQuestion",
-        "hooks": [
-          {
-            "type": "command",
-            "command": "node tools/askuser-cosmetic-detector.mjs",
-            "timeout": 5
-          }
-        ]
-      },
-      {
-        "matcher": "Read|Grep|Glob|LS|TodoWrite|AskUserQuestion|Edit|Write|MultiEdit|NotebookEdit|Bash|Skill|Task|EnterPlanMode",
-        "hooks": [
-          {
-            "type": "command",
-            "command": "node tools/enforce-safe-baseline-metering.mjs",
-            "timeout": 10
-          }
-        ]
-      },
-      {
-        "matcher": "Edit|Write|MultiEdit|NotebookEdit",
-        "hooks": [
-          {
-            "type": "command",
-            "command": "node tools/enforce-runtime-write-deny.mjs",
-            "timeout": 5
-          }
-        ]
-      },
-      {
-        "matcher": "Edit|Write|MultiEdit|NotebookEdit|Bash|Task",
-        "hooks": [
-          {
-            "type": "command",
-            "command": "node tools/enforce-parallel-session-lock.mjs",
-            "timeout": 3
-          }
-        ]
      }
    ],
    "PostToolUse": [
@@ -277,7 +192,7 @@
        "hooks": [
          {
            "type": "command",
-            "command": "node -e \"const f=process.env.CLAUDE_FILE_PATH||''; const n=f.replace(/\\\\\\\\/g,'/'); if (/(^|\\\\/)db\\\\/schema\\\\.sql$/i.test(n)) { process.stdout.write('\\n[hook] REMINDER: You modified db/schema.sql. Per CLAUDE.md Р вЂ™Р’В§5 Р В РЎвЂ”.8, add a corresponding entry to db/CHANGELOG_schema.md before committing.\\n'); }\""
+            "command": "node -e \"const f=process.env.CLAUDE_FILE_PATH||''; const n=f.replace(/\\\\\\\\/g,'/'); if (/(^|\\\\/)db\\\\/schema\\\\.sql$/i.test(n)) { process.stdout.write('\\n[hook] REMINDER: You modified db/schema.sql. Per CLAUDE.md §5 п.8, add a corresponding entry to db/CHANGELOG_schema.md before committing.\\n'); }\""
          }
        ]
      },
@@ -291,7 +206,7 @@
          },
          {
            "type": "command",
-            "command": "echo ok",
+            "command": "node tools/enforce-rationalization-audit.mjs",
            "timeout": 5
          }
        ]
@@ -301,7 +216,7 @@
        "hooks": [
          {
            "type": "command",
-            "command": "echo ok",
+            "command": "node tools/enforce-rationalization-audit.mjs",
            "timeout": 5
          }
        ]
@@ -315,29 +230,9 @@
            "timeout": 10
          }
        ]
-      },
-      {
-        "matcher": "AskUserQuestion",
-        "hooks": [
-          {
-            "type": "command",
-            "command": "node tools/enforce-askuser-answer-parser.mjs",
-            "timeout": 2
-          }
-        ]
      }
    ],
    "Stop": [
-      {
-        "matcher": "*",
-        "hooks": [
-          {
-            "type": "command",
-            "command": "node tools/enforce-llm-judge-response-scan.mjs",
-            "timeout": 30
-          }
-        ]
-      },
      {
        "hooks": [
          {
@@ -382,15 +277,6 @@
            "timeout": 10
          }
        ]
-      },
-      {
-        "hooks": [
-          {
-            "type": "command",
-            "command": "node tools/enforce-parallel-session-lock.mjs",
-            "timeout": 3
-          }
-        ]
      }
    ],
    "UserPromptSubmit": [
@@ -423,17 +309,6 @@
          }
        ]
      }
-    ],
-    "SessionEnd": [
-      {
-        "hooks": [
-          {
-            "type": "command",
-            "command": "node tools/enforce-parallel-session-lock.mjs",
-            "timeout": 3
-          }
-        ]
-      }
    ]
  }
 }
@@ -45,10 +45,10 @@ jobs:
          echo "Requested: '$CMD_TRIM'"

          # Group 1 — read-only / dry-run / inspection: всегда разрешены
-          READ_ONLY_RE='^(migrate:status|route:list|schedule:list|queue:listen --help|about|env:show|config:show|cache:table|view:cache|optimize:status|snapshot:backfill( --date=20[2-9][0-9]-[0-1][0-9]-[0-3][0-9])?|scheduler:check-heartbeats|incidents:watch-failures( --threshold-spike=[0-9]+)?( --threshold-daily=[0-9]+)?( --persistent-hours=[0-9]+)?|supplier:rekey-orphans --dry-run|audit:verify-chains|audit:rebuild-chain --partition=[a-z_0-9]+ --from-id=[0-9]+ --dry-run)( *)$'
+          READ_ONLY_RE='^(migrate:status|route:list|schedule:list|queue:listen --help|about|env:show|config:show|cache:table|view:cache|optimize:status|snapshot:backfill( --date=20[2-9][0-9]-[0-1][0-9]-[0-3][0-9])?|scheduler:check-heartbeats|incidents:watch-failures( --threshold-spike=[0-9]+)?( --threshold-daily=[0-9]+)?( --persistent-hours=[0-9]+)?|supplier:rekey-orphans --dry-run|audit:verify-chains|audit:rebuild-chain --partition=[a-z_0-9]+ --from-id=[0-9]+ --dry-run|deals:backfill-region-city --dry-run)( *)$'

          # Group 2 — mutating: требуют confirm_apply=true
-          MUTATING_RE='^(supplier:rekey-orphans|cache:clear|view:clear|config:clear|route:clear|optimize:clear|optimize|queue:restart|partitions:create-months( --months=[0-9]+)?|partitions:drop-old|audit:rebuild-chain --partition=[a-z_0-9]+ --from-id=[0-9]+( --force)?)( *)$'
+          MUTATING_RE='^(supplier:rekey-orphans|cache:clear|view:clear|config:clear|route:clear|optimize:clear|optimize|queue:restart|partitions:create-months( --months=[0-9]+)?|partitions:drop-old|audit:rebuild-chain --partition=[a-z_0-9]+ --from-id=[0-9]+( --force)?|deals:backfill-region-city)( *)$'

          if [[ "$CMD_TRIM" =~ $READ_ONLY_RE ]]; then
            echo "::notice::Command in read-only whitelist — proceeding."
@@ -0,0 +1,401 @@
+name: Lead region — prod ops
+
+# Самодостаточный launch-инструмент фичи lead-region-resolution.
+# Один воркфлоу, переключатель op. НЕ трогает deploy.yml / artisan-run.yml.
+#
+# op:
+#   pre-migrate    — пред-применить миграцию 2026_05_31_100000 через postgres
+#                    superuser (crm_app_user не член crm_migrator → обычный migrate
+#                    падает) + пометить применённой, чтобы deploy её пропустил.
+#   set-env        — записать DADATA-ключи (из secrets) + LEAD_REGION_RESOLVER_ENABLED
+#                    (input flag) в боевой .env, перекэшировать config, рестарт очереди.
+#   fetch-rossvyaz — скачать файл/архив реестра (input url) на прод в /var/www/liderra/rossvyaz.
+#   import         — phone-ranges:import (input dry_run) под www-data (DDL-свап идёт
+#                    через pgsql_supplier = crm_supplier_worker, член crm_migrator).
+#   smoke          — phone-region:smoke --phone=<input phone> под www-data (нужны ключи).
+#
+# Secrets: LIDERRA_SSH_KEY, DADATA_API_KEY, DADATA_SECRET.
+
+on:
+  workflow_dispatch:
+    inputs:
+      op:
+        description: 'Операция'
+        required: true
+        type: choice
+        options:
+          - pre-migrate
+          - set-env
+          - fetch-rossvyaz
+          - fetch-via-runner
+          - deliver-from-repo
+          - import
+          - smoke
+      flag:
+        description: 'set-env: LEAD_REGION_RESOLVER_ENABLED'
+        required: false
+        default: 'false'
+        type: choice
+        options:
+          - 'false'
+          - 'true'
+      url:
+        description: 'fetch-rossvyaz: прямая ссылка на CSV/ZIP реестра Россвязи'
+        required: false
+        type: string
+      dir:
+        description: 'import: каталог с CSV на проде'
+        required: false
+        default: '/var/www/liderra/rossvyaz'
+        type: string
+      dry_run:
+        description: 'import: только staging без swap'
+        required: false
+        default: true
+        type: boolean
+      force:
+        description: 'import: принудительно (--force, игнорировать «реестр идентичен»)'
+        required: false
+        default: false
+        type: boolean
+      phone:
+        description: 'smoke: телефон'
+        required: false
+        default: '79161234567'
+        type: string
+
+jobs:
+  op:
+    name: ${{ github.event.inputs.op }}
+    runs-on: ubuntu-latest
+    timeout-minutes: 15
+    concurrency:
+      group: liderra-prod-deploy
+      cancel-in-progress: false
+
+    env:
+      LIDERRA_HOST: 111.88.246.137
+      LIDERRA_USER: ubuntu
+      APP_DIR: /var/www/liderra/app
+      OP: ${{ github.event.inputs.op }}
+      FLAG: ${{ github.event.inputs.flag }}
+      URL: ${{ github.event.inputs.url }}
+      DIR: ${{ github.event.inputs.dir }}
+      DRY: ${{ github.event.inputs.dry_run }}
+      FORCE: ${{ github.event.inputs.force }}
+      PHONE: ${{ github.event.inputs.phone }}
+
+    steps:
+      - name: Setup SSH key
+        run: |
+          mkdir -p ~/.ssh
+          echo "${{ secrets.LIDERRA_SSH_KEY }}" > ~/.ssh/liderra_deploy
+          chmod 600 ~/.ssh/liderra_deploy
+          ssh-keyscan -H "${LIDERRA_HOST}" >> ~/.ssh/known_hosts 2>/dev/null
+
+      - name: Checkout repo (for deliver-from-repo)
+        if: ${{ github.event.inputs.op == 'deliver-from-repo' }}
+        uses: actions/checkout@v4
+
+      - name: op=pre-migrate (superuser DDL + mark applied)
+        if: ${{ github.event.inputs.op == 'pre-migrate' }}
+        run: |
+          SQL_B64=$(cat <<'SQLEOF' | base64 -w0
+          BEGIN;
+          -- 1. phone_ranges_imports (FK target — создаём первым)
+          CREATE TABLE phone_ranges_imports (
+              id              BIGSERIAL PRIMARY KEY,
+              imported_at     TIMESTAMPTZ NOT NULL DEFAULT NOW(),
+              source_url      TEXT NOT NULL,
+              rows_inserted   INTEGER NOT NULL DEFAULT 0,
+              rows_updated    INTEGER NOT NULL DEFAULT 0,
+              checksum_sha256 TEXT NOT NULL,
+              status          TEXT NOT NULL DEFAULT 'in_progress'
+                  CHECK (status IN ('in_progress','completed','failed','rolled_back')),
+              error           TEXT,
+              completed_at    TIMESTAMPTZ
+          );
+          COMMENT ON TABLE phone_ranges_imports IS
+              'Журнал импортов реестра Россвязи (idempotency по checksum_sha256, atomic-swap откат).';
+
+          -- 2. phone_ranges (реестр диапазонов; SaaS-level, без RLS — публичные данные)
+          CREATE TABLE phone_ranges (
+              id                BIGSERIAL PRIMARY KEY,
+              def_code          SMALLINT NOT NULL,
+              from_num          BIGINT NOT NULL,
+              to_num            BIGINT NOT NULL,
+              operator          TEXT NOT NULL,
+              region            TEXT NOT NULL,
+              region_normalized TEXT,
+              subject_code      SMALLINT,
+              imported_at       TIMESTAMPTZ NOT NULL,
+              import_id         BIGINT NOT NULL REFERENCES phone_ranges_imports(id),
+              CONSTRAINT chk_phone_ranges_def_code CHECK (def_code BETWEEN 300 AND 999),
+              CONSTRAINT chk_phone_ranges_subject_code CHECK (subject_code IS NULL OR subject_code BETWEEN 1 AND 89),
+              CONSTRAINT chk_phone_ranges_range_valid CHECK (from_num <= to_num)
+          );
+          CREATE INDEX idx_phone_ranges_lookup ON phone_ranges (def_code, from_num, to_num);
+          COMMENT ON TABLE phone_ranges IS
+              'Реестр диапазонов нумерации Россвязи (rossvyaz.gov.ru). Локальный fallback для LeadRegionResolver.';
+
+          GRANT SELECT ON phone_ranges, phone_ranges_imports TO crm_app_user, crm_supplier_worker;
+
+          -- 3. lead_region_resolution_log (SaaS-level, партиционирован по received_at)
+          CREATE TABLE lead_region_resolution_log (
+              id                       BIGSERIAL,
+              supplier_lead_id         BIGINT NOT NULL,
+              received_at              TIMESTAMPTZ NOT NULL,
+              phone_masked             TEXT NOT NULL,
+              subject_code_resolved    SMALLINT,
+              subject_code_from_tag    SMALLINT,
+              region_source            TEXT NOT NULL
+                  CHECK (region_source IN ('dadata','rossvyaz','tag','unknown')),
+              dadata_qc                SMALLINT,
+              dadata_provider          TEXT,
+              dadata_type              TEXT,
+              dadata_response_masked   JSONB,
+              rossvyaz_matched         BOOLEAN NOT NULL DEFAULT FALSE,
+              actual_subject_code      SMALLINT
+                  CHECK (actual_subject_code IS NULL OR actual_subject_code BETWEEN 1 AND 89),
+              substituted_subject_code SMALLINT
+                  CHECK (substituted_subject_code IS NULL OR substituted_subject_code BETWEEN 1 AND 89),
+              routing_step             SMALLINT
+                  CHECK (routing_step IS NULL OR routing_step BETWEEN 1 AND 3),
+              phone_operator           TEXT,
+              cache_hit                BOOLEAN NOT NULL DEFAULT FALSE,
+              duration_ms              INTEGER,
+              resolved_at              TIMESTAMPTZ NOT NULL DEFAULT NOW(),
+              PRIMARY KEY (id, received_at)
+          ) PARTITION BY RANGE (received_at);
+
+          CREATE INDEX idx_lrrl_lead_id ON lead_region_resolution_log (supplier_lead_id);
+          CREATE INDEX idx_lrrl_source ON lead_region_resolution_log (region_source, received_at);
+          COMMENT ON TABLE lead_region_resolution_log IS
+              'Аудит каждого резолва региона лида (источник, qc, оператор, шаг каскада). Партиции помесячно.';
+
+          GRANT SELECT, INSERT ON lead_region_resolution_log TO crm_supplier_worker;
+          GRANT SELECT ON lead_region_resolution_log TO crm_app_user;
+
+          CREATE TABLE lead_region_resolution_log_y2026_m05
+              PARTITION OF lead_region_resolution_log
+              FOR VALUES FROM ('2026-05-01') TO ('2026-06-01');
+          CREATE TABLE lead_region_resolution_log_y2026_m06
+              PARTITION OF lead_region_resolution_log
+              FOR VALUES FROM ('2026-06-01') TO ('2026-07-01');
+
+          -- 4. supplier_leads: +4 колонки
+          ALTER TABLE supplier_leads
+              ADD COLUMN resolved_subject_code SMALLINT
+                  CHECK (resolved_subject_code IS NULL OR resolved_subject_code BETWEEN 1 AND 89),
+              ADD COLUMN region_source TEXT
+                  CHECK (region_source IN ('dadata','rossvyaz','tag','unknown')),
+              ADD COLUMN dadata_qc SMALLINT,
+              ADD COLUMN phone_operator TEXT;
+
+          -- 5. deals: +2 колонки
+          ALTER TABLE deals
+              ADD COLUMN phone_operator TEXT,
+              ADD COLUMN region_substituted BOOLEAN NOT NULL DEFAULT FALSE;
+
+          -- ownership как у миграции (она шла бы под crm_migrator)
+          ALTER TABLE phone_ranges_imports OWNER TO crm_migrator;
+          ALTER TABLE phone_ranges OWNER TO crm_migrator;
+          ALTER TABLE lead_region_resolution_log OWNER TO crm_migrator;
+          ALTER TABLE lead_region_resolution_log_y2026_m05 OWNER TO crm_migrator;
+          ALTER TABLE lead_region_resolution_log_y2026_m06 OWNER TO crm_migrator;
+
+          -- retention (system_settings, 12 мес)
+          INSERT INTO system_settings (key, value, type, description, updated_at)
+              SELECT 'partition_retention_months_lead_region_resolution_log', '12', 'int',
+                     'Retention в месяцах для lead_region_resolution_log (~365 дней)', NOW()
+              WHERE NOT EXISTS (
+                  SELECT 1 FROM system_settings
+                  WHERE key = 'partition_retention_months_lead_region_resolution_log');
+          COMMIT;
+          SQLEOF
+          )
+          ssh -i ~/.ssh/liderra_deploy "${LIDERRA_USER}@${LIDERRA_HOST}" "SQL_B64='$SQL_B64' bash -s" <<'REMOTE' | tee /tmp/op.log
+            set -euo pipefail
+            MIG_NAME='2026_05_31_100000_create_phone_ranges_and_resolution_log'
+            ALREADY=$(sudo -u postgres psql -d liderra -tAc "SELECT 1 FROM migrations WHERE migration='${MIG_NAME}' LIMIT 1")
+            if [ "${ALREADY}" = "1" ]; then
+              echo "Migration ${MIG_NAME} уже применена — пропускаю."
+              exit 0
+            fi
+            TABLE_EXISTS=$(sudo -u postgres psql -d liderra -tAc "SELECT 1 FROM information_schema.tables WHERE table_name='phone_ranges' LIMIT 1")
+            if [ "${TABLE_EXISTS}" != "1" ]; then
+              echo "Применяю lead-region DDL через postgres superuser..."
+              echo "$SQL_B64" | base64 -d | sudo -u postgres psql -d liderra -v ON_ERROR_STOP=1
+            else
+              echo "Таблица phone_ranges уже существует — только помечаю миграцию."
+            fi
+            NEXT_BATCH=$(sudo -u postgres psql -d liderra -tAc "SELECT COALESCE(MAX(batch),0)+1 FROM migrations")
+            sudo -u postgres psql -d liderra -c \
+              "INSERT INTO migrations (migration, batch) SELECT '${MIG_NAME}', ${NEXT_BATCH} WHERE NOT EXISTS (SELECT 1 FROM migrations WHERE migration='${MIG_NAME}')"
+            echo "Помечено ${MIG_NAME} применённой (batch ${NEXT_BATCH})."
+            echo "=== Проверка таблиц ==="
+            sudo -u postgres psql -d liderra -c "\dt phone_ranges|phone_ranges_imports|lead_region_resolution_log" || true
+          REMOTE
+
+      - name: op=set-env (keys from secrets + flag → prod .env)
+        if: ${{ github.event.inputs.op == 'set-env' }}
+        env:
+          DK: ${{ secrets.DADATA_API_KEY }}
+          DS: ${{ secrets.DADATA_SECRET }}
+        run: |
+          DK_B64=$(printf '%s' "$DK" | base64 -w0)
+          DS_B64=$(printf '%s' "$DS" | base64 -w0)
+          ssh -i ~/.ssh/liderra_deploy "${LIDERRA_USER}@${LIDERRA_HOST}" \
+            "DK_B64='$DK_B64' DS_B64='$DS_B64' FLAG='$FLAG' APP_DIR='$APP_DIR' bash -s" <<'REMOTE' | tee /tmp/op.log
+            set -euo pipefail
+            ENV="${APP_DIR}/.env"
+            DK=$(echo "$DK_B64" | base64 -d)
+            DS=$(echo "$DS_B64" | base64 -d)
+            upsert() {
+              local key="$1" val="$2"
+              sudo sed -i "/^${key}=/d" "$ENV"
+              echo "${key}=${val}" | sudo tee -a "$ENV" >/dev/null
+            }
+            upsert DADATA_API_KEY "$DK"
+            upsert DADATA_SECRET "$DS"
+            upsert LEAD_REGION_RESOLVER_ENABLED "$FLAG"
+            cd "$APP_DIR"
+            sudo -u www-data php artisan config:clear
+            sudo -u www-data php artisan config:cache
+            sudo systemctl restart liderra-queue
+            echo "set-env готово: flag=${FLAG}, ключи записаны."
+            echo "=== Проверка (значения скрыты) ==="
+            sudo grep -E '^(DADATA_API_KEY|DADATA_SECRET|LEAD_REGION_RESOLVER_ENABLED)=' "$ENV" | sed -E 's/=(.).*/=\1***/'
+            echo "=== queue status ==="
+            systemctl is-active liderra-queue || true
+          REMOTE
+
+      - name: op=fetch-rossvyaz (download registry on prod)
+        if: ${{ github.event.inputs.op == 'fetch-rossvyaz' }}
+        run: |
+          # Пустой url → качаем все 4 официальных файла Минцифры за один прогон.
+          # Непустой url → качаем только его (ручной режим).
+          ssh -i ~/.ssh/liderra_deploy "${LIDERRA_USER}@${LIDERRA_HOST}" \
+            "URL='$URL' bash -s" <<'REMOTE' | tee /tmp/op.log
+            set -euo pipefail
+            DEST=/var/www/liderra/rossvyaz
+            sudo mkdir -p "$DEST"
+            cd "$DEST"
+            if [ -n "$URL" ]; then
+              URLS="$URL"
+            else
+              URLS="https://opendata.digital.gov.ru/downloads/DEF-9xx.csv
+          https://opendata.digital.gov.ru/downloads/ABC-3xx.csv
+          https://opendata.digital.gov.ru/downloads/ABC-4xx.csv
+          https://opendata.digital.gov.ru/downloads/ABC-8xx.csv"
+            fi
+            for U in $URLS; do
+              FNAME=$(basename "${U%%\?*}")
+              [ -n "$FNAME" ] || FNAME="rossvyaz-download"
+              echo "Скачиваю $U -> $FNAME"
+              sudo curl -fSL --retry 3 --retry-delay 2 -e 'https://opendata.digital.gov.ru/registry/numeric/downloads/' -H 'Accept: text/csv,application/csv,application/octet-stream,*/*' -H 'Accept-Language: ru-RU,ru;q=0.9' -A 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/125.0.0.0 Safari/537.36' -o "$FNAME" "$U"
+              case "$FNAME" in
+                *.zip|*.ZIP) echo "Распаковываю zip..."; sudo unzip -o "$FNAME" ;;
+              esac
+            done
+            sudo chown -R www-data:www-data "$DEST"
+            echo "=== Содержимое $DEST ==="
+            ls -lh "$DEST"
+            FIRST_CSV=$(ls "$DEST"/DEF-9xx.csv "$DEST"/*.csv "$DEST"/*.CSV 2>/dev/null | head -1 || true)
+            if [ -n "$FIRST_CSV" ]; then
+              echo "=== Первые строки $FIRST_CSV (cp1251→utf8) ==="
+              sudo head -3 "$FIRST_CSV" | iconv -f cp1251 -t utf-8 2>/dev/null || sudo head -3 "$FIRST_CSV"
+            fi
+          REMOTE
+
+      - name: op=fetch-via-runner (download on runner, ship to prod)
+        if: ${{ github.event.inputs.op == 'fetch-via-runner' }}
+        run: |
+          mkdir -p /tmp/rv && cd /tmp/rv && rm -f /tmp/rv/*.csv
+          for U in https://opendata.digital.gov.ru/downloads/DEF-9xx.csv https://opendata.digital.gov.ru/downloads/ABC-3xx.csv https://opendata.digital.gov.ru/downloads/ABC-4xx.csv https://opendata.digital.gov.ru/downloads/ABC-8xx.csv; do
+            FN=$(basename "${U%%\?*}")
+            echo "runner: скачиваю $U -> $FN"
+            curl -fSL --retry 3 --retry-delay 2 -e 'https://opendata.digital.gov.ru/registry/numeric/downloads/' -H 'Accept: text/csv,application/csv,*/*' -A 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/125.0.0.0 Safari/537.36' -o "$FN" "$U"
+          done
+          echo "=== скачано на runner ==="
+          ls -lh /tmp/rv | tee /tmp/op.log
+          ssh -i ~/.ssh/liderra_deploy "${LIDERRA_USER}@${LIDERRA_HOST}" 'mkdir -p /tmp/rvup && rm -f /tmp/rvup/*.csv'
+          scp -i ~/.ssh/liderra_deploy /tmp/rv/*.csv "${LIDERRA_USER}@${LIDERRA_HOST}:/tmp/rvup/"
+          ssh -i ~/.ssh/liderra_deploy "${LIDERRA_USER}@${LIDERRA_HOST}" 'sudo mkdir -p /var/www/liderra/rossvyaz && sudo mv /tmp/rvup/*.csv /var/www/liderra/rossvyaz/ && sudo chown -R www-data:www-data /var/www/liderra/rossvyaz && echo "=== на проде /var/www/liderra/rossvyaz ===" && ls -lh /var/www/liderra/rossvyaz' | tee -a /tmp/op.log
+
+      - name: op=deliver-from-repo (scp repo CSV/ZIP to prod, unzip there)
+        if: ${{ github.event.inputs.op == 'deliver-from-repo' }}
+        run: |
+          # Ищем файлы реестра где угодно (корень или папка), .csv или .zip
+          mapfile -t FILES < <(find . -maxdepth 2 -type f \( \( -iname 'DEF-9xx*' -o -iname 'ABC-3xx*' -o -iname 'ABC-4xx*' -o -iname 'ABC-8xx*' \) -iname '*.csv' -o -iname '*.zip' \) ! -path './.git/*')
+          if [ ${#FILES[@]} -eq 0 ]; then
+            echo "::error::Не нашёл файлов реестра (DEF-9xx/ABC-*.csv|zip) ни в корне, ни в rossvyaz-data/. Проверь, что они закоммичены в репозиторий."; exit 1
+          fi
+          echo "=== файлы в репозитории (rossvyaz-data/) ==="
+          ls -lh "${FILES[@]}" | tee /tmp/op.log
+          ssh -i ~/.ssh/liderra_deploy "${LIDERRA_USER}@${LIDERRA_HOST}" 'mkdir -p /tmp/rvup && rm -f /tmp/rvup/*'
+          scp -i ~/.ssh/liderra_deploy "${FILES[@]}" "${LIDERRA_USER}@${LIDERRA_HOST}:/tmp/rvup/"
+          ssh -i ~/.ssh/liderra_deploy "${LIDERRA_USER}@${LIDERRA_HOST}" '
+            cd /tmp/rvup
+            for z in *.zip *.ZIP; do if [ -e "$z" ]; then echo "распаковываю $z"; unzip -o "$z"; rm -f "$z"; fi; done
+            sudo mkdir -p /var/www/liderra/rossvyaz
+            find . -iname "*.csv" -exec sudo mv {} /var/www/liderra/rossvyaz/ \;
+            sudo chown -R www-data:www-data /var/www/liderra/rossvyaz
+            echo "=== на проде /var/www/liderra/rossvyaz ==="
+            ls -lh /var/www/liderra/rossvyaz
+          ' | tee -a /tmp/op.log
+
+      - name: op=import (phone-ranges:import)
+        if: ${{ github.event.inputs.op == 'import' }}
+        run: |
+          DRY_FLAG=""
+          if [ "${DRY}" = "true" ]; then DRY_FLAG="--dry-run"; fi
+          FORCE_FLAG=""
+          if [ "${FORCE}" = "true" ]; then FORCE_FLAG="--force"; fi
+          ssh -i ~/.ssh/liderra_deploy "${LIDERRA_USER}@${LIDERRA_HOST}" \
+            "APP_DIR='$APP_DIR' DIR='$DIR' DRY_FLAG='$DRY_FLAG' FORCE_FLAG='$FORCE_FLAG' bash -s" <<'REMOTE' | tee /tmp/op.log
+            set -e
+            cd "$APP_DIR"
+            echo "=== phone-ranges:import --dir=${DIR} ${DRY_FLAG} ${FORCE_FLAG} ==="
+            sudo -u www-data php artisan phone-ranges:import --dir="$DIR" $DRY_FLAG $FORCE_FLAG 2>&1
+            echo "=== Счётчики ==="
+            sudo -u postgres psql -d liderra -c "SELECT count(*) AS phone_ranges FROM phone_ranges" 2>&1 || true
+            # staging-счётчик: 2 отдельных запроса, чтобы Postgres не парсил
+            # подзапрос к phone_ranges_staging, когда таблица уже свапнута (иначе
+            # ERROR relation "phone_ranges_staging" does not exist даже в ветке CASE).
+            STAGING_EXISTS=$(sudo -u postgres psql -d liderra -tAc "SELECT to_regclass('phone_ranges_staging') IS NOT NULL")
+            if [ "$STAGING_EXISTS" = "t" ]; then
+              sudo -u postgres psql -d liderra -c "SELECT count(*) AS staging_rows FROM phone_ranges_staging" 2>&1 || true
+            else
+              echo "staging: отсутствует (после свапа — норма)"
+            fi
+            echo "=== Последний импорт ==="
+            sudo -u postgres psql -d liderra -c \
+              "SELECT id, status, rows_inserted, rows_updated, imported_at FROM phone_ranges_imports ORDER BY id DESC LIMIT 3" 2>&1 || true
+          REMOTE
+
+      - name: op=smoke (phone-region:smoke)
+        if: ${{ github.event.inputs.op == 'smoke' }}
+        run: |
+          ssh -i ~/.ssh/liderra_deploy "${LIDERRA_USER}@${LIDERRA_HOST}" \
+            "APP_DIR='$APP_DIR' PHONE='$PHONE' bash -s" <<'REMOTE' | tee /tmp/op.log
+            set -e
+            cd "$APP_DIR"
+            echo "=== phone-region:smoke --phone=${PHONE} ==="
+            sudo -u www-data php artisan phone-region:smoke --phone="$PHONE" 2>&1
+          REMOTE
+
+      - name: Print summary
+        if: always()
+        run: |
+          {
+            echo "## lead-region-ops: \`${OP}\`"
+            echo
+            echo '```'
+            cat /tmp/op.log 2>/dev/null || echo "(нет вывода)"
+            echo '```'
+          } >> "$GITHUB_STEP_SUMMARY"
+
+      - name: Cleanup SSH key
+        if: always()
+        run: rm -f ~/.ssh/liderra_deploy
@@ -292,7 +292,7 @@ trivy image liderra:latest

 ## 6. Текущая фаза проекта

-**2026-06-02 lead region resolution — ВЫКАЧЕНА на прод liderra.ru (флаг ON, 100%):** Определение настоящего региона лида по телефону (DaData → реестр Россвязи → tag-fallback) + каскадная маршрутизация по региону (exact→all-RF→fallback) со взвешенным жребием по остатку дневного лимита (вариант В, вес ≥ 1 — мелкие клиенты не отрезаются). Состав: `LeadRegionResolver` (каскад по qc-кодам DaData) + `DaData/*` (клиент / страж бюджета / enum кодов качества / исключения) + `DaDataRegionMap` + `RossvyazPrefixLookup` + `RossvyazRecord`/`RegionResolution` DTO + команда `phone-ranges:import` (parse/map/dry-run/idempotency, atomic RENAME-swap в транзакции) + `LeadRouter` переписан (`matchEligibleProjects` + region-фильтр + `weightedPick` + инъекция `Randomizer`) + интеграция в `RouteSupplierLeadJob` (резолв ДО tx / persist 4 колонки / fail-safe аудит-лог `lead_region_resolution_log` / подмена subject_code на шаге 3 / CSV-merge по рангу источника `dadata/rossvyaz > CSV-tag`) + `phone-region:smoke`. Миграция `2026_05_31_100000` (`phone_ranges` / `phone_ranges_imports` / `lead_region_resolution_log` партиц. по месяцам + колонки на supplier_leads/deals) + регистрация в `MonthlyPartitionManager`; `db/schema.sql` синхронизирован заголовком (v8.40), DDL — в дельта-миграции (иначе двойной CREATE TABLE сломал бы migrate). **Решения заказчика/проекта:** резолвер через `app()` внутри `handle()` (не 7-й параметр — сохраняет сигнатуру + 3 существующих теста джобы); `deals.region_source` не добавляли (источник на supplier_leads + в журнале, CSV-merge по эвристике); запуск сразу на 100% без долевого гейта. **14 атомарных коммитов** `ec219718..11079791` на ветке `worktree-feat+lead-region-resolution`, запушено в origin (`CoralMinister/lidpotok`), **PR в main открывается вручную** по ссылке из `git push` output (MCP `create_pull_request` + `gh pr create` оба заблокированы router-гейтом). Тесты **101 pest GREEN / 509 assertions**; tools-vitest **1989 GREEN**. Code-review subagent (вердикт «с правками») → починены `atomicSwap()`→транзакция (spec §6.2) + убран stray comment; minor/deferred задокументированы (метрики §8.1 / `phone-ranges:rollback` / pg_anonymizer-маски / калибровка `DADATA_CALL_COST_KOPECKS`). **ВЫКАЧЕНО на прод liderra.ru 01.06.2026 ~16:01 МСК** (по команде «запускаем»): ключи DaData в боевом `.env`, флаг `LEAD_REGION_RESOLVER_ENABLED=true` на **100%** потока, реестр Россвязи **453080 диапазонов** (atomic swap). Smoke на реальном номере ✓ (Источник=dadata, Субъект=29 Красноярский край, qc=0). Инструмент выкатки — `.github/workflows/lead-region-ops.yml` (на origin/main, локально untracked). Откат: op=set-env flag=false. Операционные уроки и хвосты (unmapped-регионы → код+TDD, косметика счётчика, мониторинг region_source, калибровка DADATA_CALL_COST_KOPECKS) — память [[project-lead-region-resolution-live]]; runbook `docs/superpowers/runbooks/2026-05-31-lead-region-resolution-rollout.md`. Пре-существующий долг (НЕ из фичи, отдельная задача): 3 чужих console-теста (`BillingMigrateLeadsToRub` / `IncidentsWatchFailures` / `SnapshotBackfillCommand`) взаимно загрязняются в одном процессе (накопление счётчиков), в CI `pest --parallel` (файл=процесс) проходят. **Lefthook в worktree-shell не в PATH** → cspell/larastan/squawk/deptrac не гонялись на коммитах; deptrac проверен инспекцией (Service→Service разрешён), новые cspell-термины (Rossvyaz/DaData/kopecks) добавлены в `cspell-words.txt`, остальное — CI на push. **§0 cross-refs НЕ меняются** — app-фича (сервисы/джоба/миграция), не tooling-канон #1-#86 / не ADR / не off-phase. Через `claude-md-management:revise-claude-md`.
+**2026-06-01 lead region resolution — фича реализована TDD + запушена (PR в main):** Определение настоящего региона лида по телефону (DaData → реестр Россвязи → tag-fallback) + каскадная маршрутизация по региону (exact→all-RF→fallback) со взвешенным жребием по остатку дневного лимита (вариант В, вес ≥ 1 — мелкие клиенты не отрезаются). Состав: `LeadRegionResolver` (каскад по qc-кодам DaData) + `DaData/*` (клиент / страж бюджета / enum кодов качества / исключения) + `DaDataRegionMap` + `RossvyazPrefixLookup` + `RossvyazRecord`/`RegionResolution` DTO + команда `phone-ranges:import` (parse/map/dry-run/idempotency, atomic RENAME-swap в транзакции) + `LeadRouter` переписан (`matchEligibleProjects` + region-фильтр + `weightedPick` + инъекция `Randomizer`) + интеграция в `RouteSupplierLeadJob` (резолв ДО tx / persist 4 колонки / fail-safe аудит-лог `lead_region_resolution_log` / подмена subject_code на шаге 3 / CSV-merge по рангу источника `dadata/rossvyaz > CSV-tag`) + `phone-region:smoke`. Миграция `2026_05_31_100000` (`phone_ranges` / `phone_ranges_imports` / `lead_region_resolution_log` партиц. по месяцам + колонки на supplier_leads/deals) + регистрация в `MonthlyPartitionManager`; `db/schema.sql` синхронизирован заголовком (v8.40), DDL — в дельта-миграции (иначе двойной CREATE TABLE сломал бы migrate). **Решения заказчика/проекта:** резолвер через `app()` внутри `handle()` (не 7-й параметр — сохраняет сигнатуру + 3 существующих теста джобы); `deals.region_source` не добавляли (источник на supplier_leads + в журнале, CSV-merge по эвристике); запуск сразу на 100% без долевого гейта. **14 атомарных коммитов** `ec219718..11079791` на ветке `worktree-feat+lead-region-resolution`, запушено в origin (`CoralMinister/lidpotok`), **PR в main открывается вручную** по ссылке из `git push` output (MCP `create_pull_request` + `gh pr create` оба заблокированы router-гейтом). Тесты **101 pest GREEN / 509 assertions**; tools-vitest **1989 GREEN**. Code-review subagent (вердикт «с правками») → починены `atomicSwap()`→транзакция (spec §6.2) + убран stray comment; minor/deferred задокументированы (метрики §8.1 / `phone-ranges:rollback` / pg_anonymizer-маски / калибровка `DADATA_CALL_COST_KOPECKS`). Прод-выкатка отложена (нужны `DADATA_API_KEY`/`DADATA_SECRET` в YC Lockbox + команда «запускаем»; runbook `docs/superpowers/runbooks/2026-05-31-lead-region-resolution-rollout.md`). Пре-существующий долг (НЕ из фичи, отдельная задача): 3 чужих console-теста (`BillingMigrateLeadsToRub` / `IncidentsWatchFailures` / `SnapshotBackfillCommand`) взаимно загрязняются в одном процессе (накопление счётчиков), в CI `pest --parallel` (файл=процесс) проходят. **Lefthook в worktree-shell не в PATH** → cspell/larastan/squawk/deptrac не гонялись на коммитах; deptrac проверен инспекцией (Service→Service разрешён), новые cspell-термины (Rossvyaz/DaData/kopecks) добавлены в `cspell-words.txt`, остальное — CI на push. **§0 cross-refs НЕ меняются** — app-фича (сервисы/джоба/миграция), не tooling-канон #1-#86 / не ADR / не off-phase. Через `claude-md-management:revise-claude-md`.

 **2026-05-31 (продолжение) router-gate v4 Layer 4 LLM-judge — item 2b live wiring + активация владельцем + readonly-калибровка:** `tools/enforce-llm-judge-per-tool.mjs` (PreToolUse) и `tools/enforce-llm-judge-response-scan.mjs` (Stop) получили живой `main()` (TDD, чистые `runPerTool`/`runResponseScan`; commit `dfae9f76`). Spend строго гейтится `resolveJudgeConfig()` (флаг `ROUTER_LLM_JUDGE_ENABLED` И ключ); без флага/ключа `decide()` короткозамыкается → $0. **Архитектурный нюанс:** регистрировать надо именно **обёртки** `enforce-llm-judge-*`, не движки `llm-judge-{per-tool,response-scan}.mjs` — у движков `main()` зовёт `llmJudgeCall` по наличию ОДНОГО ключа, игнорируя флаг (т.е. движок начал бы тратить деньги без рубильника). **Владелец активировал Layer 4** (env `ROUTER_LLM_JUDGE_ENABLED=1` через `rundll32 sysdm.cpl,EditEnvironmentVariables` + ключ `ROUTER_LLM_KEY` уже был в user env, как у классификатора + регистрация обоих хуков в `.claude/settings.json` + перезапуск) → судья ожил в **hard-block** (подтверждено: тот же `git log`, что при выключенном флаге проходил мгновенно, после активации заблокирован реальным вызовом — verdict ≠ YES → block). **Операционная находка / over-block:** `MUTATING_TOOLS` в `llm-judge-per-tool.mjs` включает `Bash` целиком, а правило вопроса — «Сомнения → NO» + код «не-YES → block», поэтому живой судья блокировал даже readonly-просмотры (`git status`/`git log`/`grep`) — и тем самым полностью клинил рабочий цикл (commit/push/правки тоже под судьёй). **Калибровка** (commit `c9b9efd6`, TDD, судья на время выключался владельцем — правка кода тоже под судьёй): новый экспортируемый `isReadonlyBashEvent(event)` — если tool=Bash и `classifyBashCommand(command, {})` даёт `result==='allow'` с reason `readonly|reading`, `runPerTool` возвращает allow **до** обращения к судье (без LLM-вызова, без budget-bump). Это **scope-fix к собственной декларации судьи** («judge on mutating tools»), а **не понижение дисциплины**: правило doubt→block и полная проверка всего, что реально меняет состояние (Edit/Write/MultiEdit/git commit/push/Skill/Task), — без изменений. Регрессия vitest tools-only **1927 GREEN** (+13 калибровочных тестов; verify через `npx vitest run --root app --config vitest.config.tools.mjs`, т.к. `npm run test:tools` падает из-за параллельной keytar-установки в `app/node_modules`). Коммиты `dfae9f76` (live wiring) + `c9b9efd6` (калибровка); push `a8996896..c9b9efd6 main`. План `docs/superpowers/plans/2026-05-31-llm-judge-live-wiring.md`. **§0 cross-refs НЕ меняются** — инфраструктура `tools/enforce-*.mjs`, не tooling-канон #1-#86 / не ADR / не off-phase. Через `claude-md-management:revise-claude-md`.

@@ -0,0 +1,75 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App\Console\Commands;
+
+use App\Support\RussianRegions;
+use Illuminate\Console\Command;
+use Illuminate\Support\Facades\DB;
+use Illuminate\Support\Facades\Log;
+
+/**
+ * Одноразовый бэкфилл: проставляет deals.city (имя субъекта) у уже существующих сделок,
+ * у которых city ещё пуст, по resolved_subject_code связанного лида
+ * (deals → supplier_lead_deliveries → supplier_leads). Идемпотентно (только city IS NULL).
+ *
+ * Запускается через .github/workflows/artisan-run.yml (mutating-whitelist, confirm_apply).
+ * Парная правка для RouteSupplierLeadJob, который заполняет city у новых сделок.
+ */
+final class DealsBackfillRegionCityCommand extends Command
+{
+    protected $signature = 'deals:backfill-region-city {--dry-run : Только посчитать, ничего не записывать}';
+
+    protected $description = 'Дозаполнить deals.city именем региона по resolved_subject_code лида (одноразовый бэкфилл)';
+
+    public function handle(): int
+    {
+        $dryRun = (bool) $this->option('dry-run');
+        // BYPASSRLS-роль: бэкфилл идёт по всем тенантам без SET app.current_tenant_id.
+        $conn = DB::connection('pgsql_supplier');
+        $map = RussianRegions::CODE_TO_NAME;
+
+        $rows = $conn->table('deals')
+            ->join('supplier_lead_deliveries as dlv', 'dlv.deal_id', '=', 'deals.id')
+            ->join('supplier_leads as sl', 'sl.id', '=', 'dlv.supplier_lead_id')
+            ->whereNull('deals.city')
+            ->whereNotNull('sl.resolved_subject_code')
+            ->select('deals.id', 'deals.received_at', 'sl.resolved_subject_code')
+            ->get();
+
+        $seen = [];
+        $updated = 0;
+        foreach ($rows as $r) {
+            $dealId = (int) $r->id;
+            if (isset($seen[$dealId])) {
+                continue; // у сделки несколько доставок — обрабатываем один раз
+            }
+            $seen[$dealId] = true;
+
+            $name = $map[(int) $r->resolved_subject_code] ?? null;
+            if ($name === null) {
+                continue; // код вне справочника 1..89 — пропускаем
+            }
+
+            if (! $dryRun) {
+                $conn->table('deals')
+                    ->where('id', $dealId)
+                    ->where('received_at', $r->received_at) // partition key
+                    ->whereNull('city') // идемпотентный страж
+                    ->update(['city' => $name]);
+            }
+            $updated++;
+        }
+
+        $prefix = $dryRun ? '[dry-run] ' : '';
+        $this->info("{$prefix}deals.city backfill: {$updated} обновлено из ".count($seen).' кандидатов.');
+        Log::info('deals.backfill_region_city', [
+            'updated' => $updated,
+            'candidates' => count($seen),
+            'dry_run' => $dryRun,
+        ]);
+
+        return self::SUCCESS;
+    }
+}
@@ -0,0 +1,433 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App\Console\Commands;
+
+use App\Support\RussianRegions;
+use Illuminate\Console\Command;
+use Illuminate\Support\Facades\DB;
+use OpenSpout\Reader\XLSX\Reader as XlsxReader;
+
+/**
+ * Импорт реестра нумерации Россвязи в `phone_ranges` (spec §6).
+ *
+ *   php artisan phone-ranges:import --file=<csv|xlsx> [--force] [--dry-run]
+ *   php artisan phone-ranges:import --dir=<dir с пакетом файлов> [...]
+ *
+ * Алгоритм:
+ *   1. Резолв входных файлов (--file | --dir; --url отложен — оператор качает пакет вручную).
+ *   2. Checksum-идемпотентность: совпал с предыдущим `completed` → status='rolled_back', выход.
+ *   3. Парсинг (CSV через str_getcsv ';', XLSX через openspout) → нормализованные строки.
+ *   4. Маппинг region → subject_code через RussianRegions::nameToCode(). Несматчившиеся → лог в error.
+ *   5. Сборка `phone_ranges_staging` (LIKE phone_ranges) + bulk INSERT.
+ *   6. --dry-run → staging остаётся для инспекции, swap НЕ делается, status='rolled_back'.
+ *      Иначе → atomic RENAME swap + status='completed'.
+ *
+ * Запись идёт через `pgsql_supplier` (на проде crm_supplier_worker — член crm_migrator,
+ * INHERIT даёт CREATE; SET ROLE crm_migrator выравнивает ownership. На dev/test — postgres superuser).
+ *
+ * NB (swap — operator-validated): committing-swap (шаг 6 else) НЕ покрыт автотестом —
+ * RENAME коммитит и сломал бы общую тестовую БД. Свап проверяется первым реальным
+ * импортом оператора по runbook (Session 6). Тесты покрывают parse/map/dry-run/idempotency.
+ */
+class PhoneRangesImportCommand extends Command
+{
+    /** @var string */
+    protected $signature = 'phone-ranges:import
+        {--file= : Путь к одному CSV/XLSX файлу реестра}
+        {--dir= : Каталог с пакетом файлов реестра (*.csv, *.xlsx)}
+        {--url= : (отложено) URL пакета — скачать вручную и использовать --dir}
+        {--force : Игнорировать checksum-идемпотентность}
+        {--dry-run : Распарсить и собрать staging, но не делать atomic swap}';
+
+    /** @var string */
+    protected $description = 'Импорт реестра нумерации Россвязи в phone_ranges (idempotent, atomic swap)';
+
+    /** Connection для DDL/записи (на проде crm_migrator-capable, на dev/test — superuser fallback). */
+    private const DDL_CONNECTION = 'pgsql_supplier';
+
+    /** Размер пачки для bulk INSERT в staging. */
+    private const INSERT_CHUNK = 1000;
+
+    public function handle(): int
+    {
+        $files = $this->resolveFiles();
+        if ($files === null) {
+            return self::FAILURE;
+        }
+
+        $checksum = $this->computeChecksum($files);
+        $dryRun = (bool) $this->option('dry-run');
+        $force = (bool) $this->option('force');
+
+        // 2. Идемпотентность по checksum (если не --force).
+        if (! $force) {
+            $prev = DB::table('phone_ranges_imports')
+                ->where('checksum_sha256', $checksum)
+                ->where('status', 'completed')
+                ->orderByDesc('id')
+                ->first();
+
+            if ($prev !== null) {
+                DB::table('phone_ranges_imports')->insert([
+                    'source_url' => $this->sourceLabel($files),
+                    'checksum_sha256' => $checksum,
+                    'status' => 'rolled_back',
+                    'rows_inserted' => 0,
+                    'rows_updated' => 0,
+                    'error' => "Идентично импорту #{$prev->id} (checksum совпал) — пропуск.",
+                    'imported_at' => now(),
+                    'completed_at' => now(),
+                ]);
+                $this->info("Реестр идентичен импорту #{$prev->id} — пропуск (используйте --force для принудительного импорта).");
+
+                return self::SUCCESS;
+            }
+        }
+
+        // 3. Журнал импорта (in_progress).
+        $importId = (int) DB::table('phone_ranges_imports')->insertGetId([
+            'source_url' => $this->sourceLabel($files),
+            'checksum_sha256' => $checksum,
+            'status' => 'in_progress',
+            'imported_at' => now(),
+        ]);
+
+        try {
+            // 4. Парсинг + маппинг.
+            $unmatched = [];
+            $rows = [];
+            foreach ($files as $file) {
+                foreach ($this->parseFile($file) as $rec) {
+                    $regionNormalized = RussianRegions::canonicalRegionName($rec['region']);
+                    $subjectCode = $regionNormalized === null
+                        ? null
+                        : (RussianRegions::nameToCode()[$regionNormalized] ?? null);
+                    if ($subjectCode === null && trim($rec['region']) !== '') {
+                        $unmatched[trim($rec['region'])] = true;
+                    }
+                    $rows[] = [
+                        'def_code' => $rec['def_code'],
+                        'from_num' => $rec['from_num'],
+                        'to_num' => $rec['to_num'],
+                        'operator' => $rec['operator'],
+                        'region' => $rec['region'],
+                        'region_normalized' => $regionNormalized,
+                        'subject_code' => $subjectCode,
+                        'imported_at' => now(),
+                        'import_id' => $importId,
+                    ];
+                }
+            }
+
+            // 5. Сборка staging.
+            $this->buildStaging($rows);
+
+            $unmatchedNote = $unmatched === []
+                ? ''
+                : 'Не сопоставлены регионы: '.implode(', ', array_keys($unmatched)).'.';
+
+            if ($dryRun) {
+                DB::table('phone_ranges_imports')->where('id', $importId)->update([
+                    'status' => 'rolled_back',
+                    'rows_inserted' => count($rows),
+                    'error' => trim('dry-run (swap не выполнен). '.$unmatchedNote),
+                    'completed_at' => now(),
+                ]);
+                $this->info('dry-run: '.count($rows)." строк в phone_ranges_staging, swap не выполнен.");
+                if ($unmatchedNote !== '') {
+                    $this->warn($unmatchedNote);
+                }
+
+                return self::SUCCESS;
+            }
+
+            // 6. Atomic swap (operator-validated — см. docblock).
+            $this->atomicSwap();
+
+            DB::table('phone_ranges_imports')->where('id', $importId)->update([
+                'status' => 'completed',
+                'rows_inserted' => count($rows),
+                'error' => $unmatchedNote !== '' ? $unmatchedNote : null,
+                'completed_at' => now(),
+            ]);
+            $this->info('Импортировано '.count($rows).' строк в phone_ranges (atomic swap выполнен).');
+            if ($unmatchedNote !== '') {
+                $this->warn($unmatchedNote);
+            }
+
+            return self::SUCCESS;
+        } catch (\Throwable $e) {
+            DB::table('phone_ranges_imports')->where('id', $importId)->update([
+                'status' => 'failed',
+                'error' => mb_substr($e->getMessage(), 0, 2000),
+                'completed_at' => now(),
+            ]);
+            $this->error('Импорт упал: '.$e->getMessage());
+
+            return self::FAILURE;
+        }
+    }
+
+    /**
+     * @return list<string>|null  Список файлов или null при ошибке валидации опций.
+     */
+    private function resolveFiles(): ?array
+    {
+        $file = $this->option('file');
+        $dir = $this->option('dir');
+        $url = $this->option('url');
+
+        if ($url !== null) {
+            $this->error('--url отложен (пакет ~500-600 файлов). Скачайте вручную и используйте --dir.');
+
+            return null;
+        }
+
+        if ($file !== null) {
+            if (! is_file($file)) {
+                $this->error("Файл не найден: {$file}");
+
+                return null;
+            }
+
+            return [$file];
+        }
+
+        if ($dir !== null) {
+            if (! is_dir($dir)) {
+                $this->error("Каталог не найден: {$dir}");
+
+                return null;
+            }
+            $found = glob(rtrim($dir, '/\\').DIRECTORY_SEPARATOR.'*.{csv,xlsx}', GLOB_BRACE) ?: [];
+            if ($found === []) {
+                $this->error("В каталоге нет *.csv / *.xlsx: {$dir}");
+
+                return null;
+            }
+            sort($found);
+
+            return array_values($found);
+        }
+
+        $this->error('Укажите --file=<путь> или --dir=<каталог>.');
+
+        return null;
+    }
+
+    /**
+     * @param  list<string>  $files
+     */
+    private function computeChecksum(array $files): string
+    {
+        if (count($files) === 1) {
+            return (string) hash_file('sha256', $files[0]);
+        }
+
+        $hashes = array_map(static fn (string $f): string => (string) hash_file('sha256', $f), $files);
+        sort($hashes);
+
+        return hash('sha256', implode('|', $hashes));
+    }
+
+    /**
+     * @param  list<string>  $files
+     */
+    private function sourceLabel(array $files): string
+    {
+        return $this->option('url')
+            ?? $this->option('dir')
+            ?? ($files[0] ?? 'unknown');
+    }
+
+    /**
+     * Парсит один файл реестра в нормализованные строки.
+     *
+     * @return list<array{def_code:int, from_num:int, to_num:int, operator:string, region:string}>
+     */
+    private function parseFile(string $path): array
+    {
+        $ext = strtolower(pathinfo($path, PATHINFO_EXTENSION));
+
+        return $ext === 'xlsx'
+            ? $this->parseXlsx($path)
+            : $this->parseCsv($path);
+    }
+
+    /**
+     * @return list<array{def_code:int, from_num:int, to_num:int, operator:string, region:string}>
+     */
+    private function parseCsv(string $path): array
+    {
+        $content = (string) file_get_contents($path);
+        // BOM strip + split строк (CRLF/CR/LF).
+        $content = preg_replace('/^\xEF\xBB\xBF/', '', $content) ?? $content;
+        $lines = preg_split('/\r\n|\r|\n/', rtrim($content)) ?: [];
+        if ($lines === []) {
+            return [];
+        }
+
+        $header = str_getcsv((string) array_shift($lines), ';');
+        $cols = $this->resolveColumns($header);
+
+        $out = [];
+        foreach ($lines as $line) {
+            if (trim($line) === '') {
+                continue;
+            }
+            $cells = str_getcsv($line, ';');
+            $rec = $this->mapCells($cells, $cols);
+            if ($rec !== null) {
+                $out[] = $rec;
+            }
+        }
+
+        return $out;
+    }
+
+    /**
+     * Парсинг XLSX через openspout (operator-real-files; CSV-ветка покрыта тестом).
+     *
+     * @return list<array{def_code:int, from_num:int, to_num:int, operator:string, region:string}>
+     */
+    private function parseXlsx(string $path): array
+    {
+        $reader = new XlsxReader();
+        $reader->open($path);
+
+        $out = [];
+        $cols = null;
+        foreach ($reader->getSheetIterator() as $sheet) {
+            foreach ($sheet->getRowIterator() as $row) {
+                $cells = array_map(static fn ($c): string => (string) $c, $row->toArray());
+                if ($cols === null) {
+                    $cols = $this->resolveColumns($cells);
+
+                    continue;
+                }
+                $rec = $this->mapCells($cells, $cols);
+                if ($rec !== null) {
+                    $out[] = $rec;
+                }
+            }
+            break; // только первый лист
+        }
+        $reader->close();
+
+        return $out;
+    }
+
+    /**
+     * Сопоставляет индексы колонок по заголовку (русские имена Россвязи) с позиционным fallback.
+     *
+     * @param  list<string>  $header
+     * @return array{def:int, from:int, to:int, operator:int, region:int}
+     */
+    private function resolveColumns(array $header): array
+    {
+        $cols = ['def' => 0, 'from' => 1, 'to' => 2, 'operator' => 4, 'region' => 5];
+
+        foreach ($header as $i => $cell) {
+            $n = preg_replace('/[\s\/]+/u', '', mb_strtolower(trim((string) $cell))) ?? '';
+            if (str_contains($n, 'def') || str_contains($n, 'авс')) {
+                $cols['def'] = $i;
+            } elseif ($n === 'от') {
+                $cols['from'] = $i;
+            } elseif ($n === 'до') {
+                $cols['to'] = $i;
+            } elseif (str_contains($n, 'оператор')) {
+                $cols['operator'] = $i;
+            } elseif (str_contains($n, 'регион')) {
+                $cols['region'] = $i;
+            }
+        }
+
+        return $cols;
+    }
+
+    /**
+     * @param  list<string>  $cells
+     * @param  array{def:int, from:int, to:int, operator:int, region:int}  $cols
+     * @return array{def_code:int, from_num:int, to_num:int, operator:string, region:string}|null
+     */
+    private function mapCells(array $cells, array $cols): ?array
+    {
+        $def = (int) preg_replace('/\D+/', '', $cells[$cols['def']] ?? '');
+        if ($def === 0) {
+            return null; // пустая/битая строка
+        }
+
+        return [
+            'def_code' => $def,
+            'from_num' => (int) preg_replace('/\D+/', '', $cells[$cols['from']] ?? '0'),
+            'to_num' => (int) preg_replace('/\D+/', '', $cells[$cols['to']] ?? '0'),
+            'operator' => trim((string) ($cells[$cols['operator']] ?? '')),
+            'region' => trim((string) ($cells[$cols['region']] ?? '')),
+        ];
+    }
+
+    /**
+     * Собирает phone_ranges_staging (LIKE phone_ranges) и заливает строки.
+     *
+     * @param  list<array<string, mixed>>  $rows
+     */
+    private function buildStaging(array $rows): void
+    {
+        $c = DB::connection(self::DDL_CONNECTION);
+        $this->elevate($c);
+
+        $c->statement('DROP TABLE IF EXISTS phone_ranges_staging CASCADE');
+        $c->statement('CREATE TABLE phone_ranges_staging (LIKE phone_ranges INCLUDING DEFAULTS INCLUDING CONSTRAINTS)');
+        $c->statement('CREATE INDEX IF NOT EXISTS idx_phone_ranges_staging_lookup ON phone_ranges_staging (def_code, from_num, to_num)');
+
+        foreach (array_chunk($rows, self::INSERT_CHUNK) as $chunk) {
+            $c->table('phone_ranges_staging')->insert($chunk);
+        }
+    }
+
+    /**
+     * Atomic swap живого phone_ranges на staging (spec §6.2 шаг 6).
+     *
+     * NB: НЕ покрыт автотестом (committing RENAME сломал бы общую тестовую БД).
+     * Проверяется первым реальным импортом оператора (Session 6 runbook).
+     * Сохраняет одну предыдущую версию (phone_ranges_old) для `phone-ranges:rollback`.
+     * GRANT'ы переустанавливаются (RENAME их не переносит); lookup-индекс на новой
+     * таблице носит имя idx_phone_ranges_staging_lookup (косметика — имя занято _old).
+     */
+    private function atomicSwap(): void
+    {
+        $c = DB::connection(self::DDL_CONNECTION);
+        $this->elevate($c);
+
+        // Транзакция вокруг свапа (spec §6.2): PostgreSQL поддерживает транзакционный
+        // DDL, поэтому DROP+RENAME+RENAME+GRANT атомарны. Обрыв процесса между
+        // переименованиями не оставит phone_ranges несуществующей — откат вернёт
+        // живую таблицу (раньше 4 авто-коммит-statement'а оставляли окно, в котором
+        // Россвязь-lookup падал бы до ручного восстановления).
+        $c->transaction(function () use ($c) {
+            $c->statement('DROP TABLE IF EXISTS phone_ranges_old CASCADE');
+            $c->statement('ALTER TABLE phone_ranges RENAME TO phone_ranges_old');
+            $c->statement('ALTER TABLE phone_ranges_staging RENAME TO phone_ranges');
+            $c->statement('GRANT SELECT ON phone_ranges TO crm_app_user, crm_supplier_worker');
+        });
+    }
+
+    /**
+     * SET ROLE crm_migrator для корректного ownership на проде; на dev/test роль
+     * отсутствует → RESET и работаем как superuser (зеркало миграционного паттерна).
+     */
+    private function elevate(\Illuminate\Database\Connection $c): void
+    {
+        try {
+            $c->statement('SET ROLE crm_migrator');
+            $canCreate = $c->selectOne("SELECT has_schema_privilege('crm_migrator', 'public', 'CREATE') AS ok");
+            if (! $canCreate || ! $canCreate->ok) {
+                $c->statement('RESET ROLE');
+            }
+        } catch (\Throwable) {
+            // окружение без роли — продолжаем как superuser
+        }
+    }
+}
@@ -0,0 +1,78 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App\Console\Commands;
+
+use App\Models\SupplierLead;
+use App\Services\LeadRegionResolver;
+use App\Support\RussianRegions;
+use Illuminate\Console\Command;
+
+/**
+ * Staging-smoke резолва региона по телефону (spec §9.4): дёргает живой каскад
+ * DaData → Россвязь → tag и печатает решение. В БД ничего НЕ пишет.
+ *
+ *   php artisan phone-region:smoke --phone=79161234567 [--tag=Москва]
+ *
+ * Принудительно включает services.dadata.enabled на время прогона (smoke всегда
+ * проверяет полный каскад, независимо от глобального feature-flag). С реальным
+ * DADATA_API_KEY делает платный вызов — запускать осознанно.
+ */
+class PhoneRegionSmokeCommand extends Command
+{
+    /** @var string */
+    protected $signature = 'phone-region:smoke
+        {--phone= : Телефон в формате 7XXXXXXXXXX}
+        {--tag= : Регион-тег поставщика (fallback-слой)}';
+
+    /** @var string */
+    protected $description = 'Прогон резолва региона по телефону (DaData→Россвязь→tag) без записи в БД (staging-smoke)';
+
+    public function handle(LeadRegionResolver $resolver): int
+    {
+        $phone = (string) $this->option('phone');
+        if ($phone === '') {
+            $this->error('Укажите --phone=7XXXXXXXXXX');
+
+            return self::FAILURE;
+        }
+
+        // Smoke всегда прогоняет полный каскад, даже если глобальный флаг выключен.
+        config(['services.dadata.enabled' => true]);
+
+        $lead = new SupplierLead([
+            'phone' => $phone,
+            'raw_payload' => ['tag' => (string) $this->option('tag')],
+        ]);
+
+        $r = $resolver->resolve($lead);
+
+        $region = $r->subjectCode !== null
+            ? (RussianRegions::CODE_TO_NAME[$r->subjectCode] ?? '?')
+            : '—';
+
+        $this->info('Телефон:    '.$this->maskPhone($phone));
+        $this->line('Источник:   '.$r->source);
+        $this->line('Субъект:    '.($r->subjectCode ?? '—').' ('.$region.')');
+        $this->line('Оператор:   '.($r->phoneOperator ?? '—'));
+        $this->line('DaData qc:  '.($r->qc ?? '—'));
+        $this->line('Cache hit:  '.($r->cacheHit ? 'да' : 'нет'));
+        $this->line('Россвязь:   '.($r->rossvyazMatched ? 'совпала' : 'нет'));
+        $this->line('Длит., мс:  '.($r->durationMs ?? '—'));
+        $this->newLine();
+        $this->comment('NB: запись в БД НЕ выполнялась (smoke).');
+
+        return self::SUCCESS;
+    }
+
+    private function maskPhone(string $phone): string
+    {
+        $digits = preg_replace('/\D+/', '', $phone) ?? '';
+        if (strlen($digits) < 8) {
+            return '***';
+        }
+
+        return substr($digits, 0, 4).'***'.substr($digits, -4);
+    }
+}
@@ -11,18 +11,22 @@ use App\Models\Project;
 use App\Models\SupplierLead;
 use App\Models\Tenant;
 use App\Services\Billing\LedgerService;
+use App\Services\Dto\RegionResolution;
 use App\Services\LeadDistributor;
+use App\Services\LeadRegionResolver;
 use App\Services\LeadRouter;
 use App\Services\NotificationService;
 use App\Services\Pd\PdAuditLogger;
 use App\Services\RegionTagResolver;
 use App\Services\SupplierProjects\SupplierProjectResolver;
+use App\Support\RussianRegions;
 use Illuminate\Bus\Queueable;
 use Illuminate\Contracts\Queue\ShouldQueue;
 use Illuminate\Foundation\Queue\Queueable as FoundationQueueable;
 use Illuminate\Queue\InteractsWithQueue;
 use Illuminate\Queue\SerializesModels;
 use Illuminate\Support\Carbon;
+use Illuminate\Support\Collection;
 use Illuminate\Support\Facades\Cache;
 use Illuminate\Support\Facades\DB;
 use Illuminate\Support\Facades\Log;
@@ -128,7 +132,6 @@ class RouteSupplierLeadJob implements ShouldQueue
            // Capture original error BEFORE update — $lead->update() mutates
            // the in-memory model, so $lead->error after update() returns the
            // suffixed value, breaking debug logs (review fix).
-            // быстрый коммит
            $originalError = $lead->error;
            $lead->update([
                'processed_at' => now(),
@@ -148,16 +151,27 @@ class RouteSupplierLeadJob implements ShouldQueue
        $supplier = $resolver->resolveOrStub($platform, $signalType, $identifier);
        $lead->update(['supplier_project_id' => $supplier->id]);

-        $matched = $router->matchEligibleProjects($supplier);
-        $selected = $distributor->selectRecipients($matched); // cap=3 случайных
+        // Lead region resolution (§3.11): резолв региона ДО routing-цикла, чтобы HTTP-вызов
+        // DaData (~150мс) не висел внутри tenant-транзакции. Резолвер — из контейнера (не 7-й
+        // параметр handle(), чтобы не ломать сигнатуру и существующие вызовы тестов).
+        // RegionTagResolver остаётся в DI-цепочке резолвера (fallback-слой).
+        $resolution = app(LeadRegionResolver::class)->resolve($lead);
+        $lead->update([
+            'resolved_subject_code' => $resolution->subjectCode,
+            'region_source' => $resolution->source,
+            'dadata_qc' => $resolution->qc,
+            'phone_operator' => $resolution->phoneOperator,
+        ]);

-        $subjectCode = $tagResolver->resolve((string) ($lead->raw_payload['tag'] ?? ''));
+        // Каскад по региону (§3.9): exact → all-RF → fallback. NULL subject_code → шаг 1 пропуск.
+        $matched = $router->matchEligibleProjects($supplier, $resolution->subjectCode);
+        $selected = $distributor->selectRecipients($matched);

        $createdCount = 0;
        $failures = [];
        foreach ($selected as $project) {
            try {
-                if ($this->createDealCopyForProject($lead, $project, $notifier, $ledger, $subjectCode)) {
+                if ($this->createDealCopyForProject($lead, $project, $notifier, $ledger, $resolution)) {
                    $createdCount++;
                }
            } catch (Throwable $e) {
@@ -178,6 +192,10 @@ class RouteSupplierLeadJob implements ShouldQueue
            );
        }

+        // Аудит резолва региона — одна строка на лид (§3.10/§7.1). Fail-safe: сбой записи
+        // аудит-лога НЕ должен ронять доставку лида (revenue-critical, 30k/сутки).
+        $this->logRegionResolution($lead, $resolution, $selected);
+
        $lead->update([
            'processed_at' => now(),
            'deals_created_count' => $createdCount,
@@ -240,10 +258,14 @@ class RouteSupplierLeadJob implements ShouldQueue
        Project $project,
        NotificationService $notifier,
        LedgerService $ledger,
-        ?int $subjectCode,
+        RegionResolution $resolution,
    ): bool {
+        // routing_step проставлен LeadRouter'ом на matched-проекте; захватываем ДО
+        // переназначения $project = $lockedProject (fresh query без этого атрибута).
+        $routingStep = (int) ($project->routing_step ?? 1);
+
        try {
-            return DB::transaction(function () use ($lead, $project, $notifier, $ledger, $subjectCode): bool {
+            return DB::transaction(function () use ($lead, $project, $notifier, $ledger, $resolution, $routingStep): bool {
                DB::statement("SET LOCAL app.current_tenant_id = '{$project->tenant_id}'");

                /** @var Tenant $tenant */
@@ -354,10 +376,21 @@ class RouteSupplierLeadJob implements ShouldQueue
                    // INITIALLY DEFERRED не помогает — проверка падает на COMMIT).
                    // CSV-recovered received_at сохраняем как есть — отличие на минуты
                    // несущественно, чем риск каскадного DELETE lead_charges.
+                    // §3.12: при merge обновляем регион/оператора, если webhook-резолв из
+                    // источника выше рангом (dadata/rossvyaz), чем tag CSV-восстановления.
+                    // deals не хранит region_source (он на supplier_leads + в журнале), поэтому
+                    // ранг определяем по факту источника: dadata/rossvyaz всегда достовернее
+                    // tag'а, на котором строилась CSV-recovery (RegionResolution::SOURCE_RANK).
+                    $mergeUpdate = ['source_crm_id' => $lead->vid, 'updated_at' => now()];
+                    if (in_array($resolution->source, ['dadata', 'rossvyaz'], true) && $resolution->subjectCode !== null) {
+                        $mergeUpdate['subject_code'] = $resolution->subjectCode;
+                        $mergeUpdate['phone_operator'] = $resolution->phoneOperator;
+                        $mergeUpdate['city'] = RussianRegions::CODE_TO_NAME[$resolution->subjectCode] ?? null;
+                    }
                    DB::table('deals')
                        ->where('id', $existingMergeable->id)
                        ->where('received_at', $existingMergeable->received_at)
-                        ->update(['source_crm_id' => $lead->vid, 'updated_at' => now()]);
+                        ->update($mergeUpdate);

                    Log::info('supplier_lead.merged_into_csv_recovered', [
                        'supplier_lead_id' => $lead->id,
@@ -394,6 +427,13 @@ class RouteSupplierLeadJob implements ShouldQueue
                    ? array_values(array_map('strval', $payload['phones']))
                    : [(string) $lead->phone];

+                // §3.10: на шаге 3 (запасной канал) регион сделки подменяется на регион
+                // клиента (первый подписанный субъект из snapshot); настоящий регион —
+                // в lead_region_resolution_log.actual_subject_code. region_substituted флажит подмену.
+                $dealSubjectCode = $routingStep < 3
+                    ? $resolution->subjectCode
+                    : ($this->pickSubstituteRegion((string) ($snapshot->regions ?? '{}')) ?? $resolution->subjectCode);
+
                $deal = Deal::create([
                    'tenant_id' => $tenant->id,
                    'source_crm_id' => $lead->vid,
@@ -402,7 +442,14 @@ class RouteSupplierLeadJob implements ShouldQueue
                    'phones' => $phones,
                    'status' => 'new',
                    'received_at' => $receivedAt,
-                    'subject_code' => $subjectCode,
+                    'subject_code' => $dealSubjectCode,
+                    // «Город» (UI deals.city) — человекочитаемое имя НАСТОЯЩЕГО региона лида
+                    // по резолву (даже если subject_code подменён на шаге 3). NULL → колонка пустая.
+                    'city' => $resolution->subjectCode !== null
+                        ? (RussianRegions::CODE_TO_NAME[$resolution->subjectCode] ?? null)
+                        : null,
+                    'phone_operator' => $resolution->phoneOperator,
+                    'region_substituted' => $routingStep === 3,
                ]);

                DB::table('supplier_lead_deliveries')
@@ -500,6 +547,89 @@ class RouteSupplierLeadJob implements ShouldQueue
        ]);
    }

+    /**
+     * Аудит резолва региона лида — одна строка на лид в lead_region_resolution_log (§7.1).
+     * Fail-safe: сбой записи (например, отсутствие партиции received_at) логируется warning'ом,
+     * но НЕ прерывает доставку (revenue-critical). INSERT через pgsql_supplier (GRANT INSERT
+     * у crm_supplier_worker). Телефон маскируется до INSERT — сырой номер в лог не пишется.
+     *
+     * @param  Collection<int, Project>  $selected
+     */
+    private function logRegionResolution(SupplierLead $lead, RegionResolution $resolution, Collection $selected): void
+    {
+        try {
+            $first = $selected->first();
+            $routingStep = $first !== null ? (int) ($first->routing_step ?? 1) : null;
+            $substituted = ($routingStep === 3 && $first !== null)
+                ? ($this->pickSubstituteRegion((string) ($first->snapshot_regions ?? '{}')) ?? $resolution->subjectCode)
+                : null;
+
+            $tagCode = app(RegionTagResolver::class)->resolve((string) ($lead->raw_payload['tag'] ?? ''));
+
+            DB::connection(self::DB_CONNECTION)->table('lead_region_resolution_log')->insert([
+                'supplier_lead_id' => $lead->id,
+                'received_at' => $lead->received_at ?? now(),
+                'phone_masked' => $this->maskPhone((string) $lead->phone),
+                'subject_code_resolved' => $resolution->subjectCode,
+                'subject_code_from_tag' => $tagCode,
+                'region_source' => $resolution->source,
+                'dadata_qc' => $resolution->qc,
+                'dadata_provider' => $resolution->phoneOperator,
+                'dadata_type' => null,
+                'dadata_response_masked' => $resolution->dadataResponseMasked !== null
+                    ? json_encode($resolution->dadataResponseMasked, JSON_UNESCAPED_UNICODE)
+                    : null,
+                'rossvyaz_matched' => $resolution->rossvyazMatched,
+                'actual_subject_code' => $resolution->actualSubjectCode,
+                'substituted_subject_code' => $substituted,
+                'routing_step' => $routingStep,
+                'phone_operator' => $resolution->phoneOperator,
+                'cache_hit' => $resolution->cacheHit,
+                'duration_ms' => $resolution->durationMs,
+            ]);
+        } catch (Throwable $e) {
+            Log::warning('lead_region_resolution.log_write_failed', [
+                'supplier_lead_id' => $lead->id,
+                'exception' => $e->getMessage(),
+            ]);
+        }
+    }
+
+    /**
+     * Первый код субъекта из PG INT[]-литерала ('{82,83}' → 82; '{}' → null) — регион клиента
+     * для подмены на запасном канале (§3.10).
+     */
+    private function pickSubstituteRegion(string $regionsLiteral): ?int
+    {
+        return $this->parseSubjectCodes($regionsLiteral)[0] ?? null;
+    }
+
+    /**
+     * @return list<int>  '{82,83}' → [82,83]; '{}'/'' → []
+     */
+    private function parseSubjectCodes(string $regionsLiteral): array
+    {
+        $inner = trim($regionsLiteral, '{}');
+        if ($inner === '') {
+            return [];
+        }
+
+        return array_values(array_map('intval', explode(',', $inner)));
+    }
+
+    /**
+     * Маскирование телефона для лога (§7.1): первые 4 + последние 4 цифры (7916***4567).
+     */
+    private function maskPhone(string $phone): string
+    {
+        $digits = preg_replace('/\D+/', '', $phone) ?? '';
+        if (strlen($digits) < 8) {
+            return '***';
+        }
+
+        return substr($digits, 0, 4).'***'.substr($digits, -4);
+    }
+
    /**
     * Финальный callback после исчерпания всех ретраев ($tries=3).
     *
@@ -61,6 +61,9 @@ class Deal extends Model
        'is_test',
        'received_at',
        'deleted_at',
+        // Lead region resolution (Session 1, 31.05.2026).
+        'phone_operator',
+        'region_substituted',
    ];

    protected function casts(): array
@@ -77,6 +80,7 @@ class Deal extends Model
            'lead_score' => 'decimal:2',
            'phones' => 'array',
            'is_test' => 'boolean',
+            'region_substituted' => 'boolean',
            'assigned_at' => 'datetime',
            'received_at' => 'datetime',
            'created_at' => 'datetime',
@@ -41,6 +41,11 @@ class SupplierLead extends Model
        'recovered_from_csv_at',
        'deals_created_count',
        'error',
+        // Lead region resolution (Session 1, 31.05.2026) — persistent idempotency + display.
+        'resolved_subject_code',
+        'region_source',
+        'dadata_qc',
+        'phone_operator',
    ];

    protected function casts(): array
@@ -52,6 +57,8 @@ class SupplierLead extends Model
            'recovered_from_csv_at' => 'datetime',
            'vid' => 'integer',
            'deals_created_count' => 'integer',
+            'resolved_subject_code' => 'integer',
+            'dadata_qc' => 'integer',
        ];
    }

@@ -0,0 +1,47 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App\Services\DaData;
+
+use Illuminate\Support\Facades\Cache;
+
+/**
+ * Дневной бюджет на платные вызовы DaData (spec §5.3 / §11).
+ *
+ * Расход копится в копейках под дневным ключом `phone_resolution:dadata:spent_kopecks:<YYYY-MM-DD>`.
+ * `Cache::increment` на redis-сторе атомарен (INCRBY) — корректно при параллельных
+ * RouteSupplierLeadJob. Дневной ключ сам обнуляется со сменой даты; TTL 2 дня чистит старые.
+ *
+ * При canSpend()=false LeadRegionResolver минует DaData и идёт сразу в Россвязь (spec §3.3).
+ */
+class DaDataBudgetGuard
+{
+    public function canSpend(): bool
+    {
+        $capKopecks = ((int) config('services.dadata.daily_cap_rub', 10000)) * 100;
+
+        return $this->spentTodayKopecks() < $capKopecks;
+    }
+
+    public function recordSpend(int $kopecks): void
+    {
+        if ($kopecks <= 0) {
+            return;
+        }
+
+        $key = $this->dailyKey();
+        Cache::add($key, 0, now()->addDays(2));
+        Cache::increment($key, $kopecks);
+    }
+
+    public function spentTodayKopecks(): int
+    {
+        return (int) Cache::get($this->dailyKey(), 0);
+    }
+
+    private function dailyKey(): string
+    {
+        return 'phone_resolution:dadata:spent_kopecks:'.now()->format('Y-m-d');
+    }
+}
@@ -0,0 +1,13 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App\Services\DaData;
+
+use RuntimeException;
+
+/**
+ * Не-2xx ответ DaData (после исчерпания retry) или иная ошибка вызова.
+ * LeadRegionResolver ловит её и деградирует на Россвязь (spec §3.3).
+ */
+class DaDataException extends RuntimeException {}
@@ -0,0 +1,93 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App\Services\DaData;
+
+use Illuminate\Http\Client\ConnectionException;
+use Illuminate\Http\Client\Factory as HttpFactory;
+
+/**
+ * HTTP-обёртка над DaData clean/phone (spec §3.6).
+ *
+ * POST https://cleaner.dadata.ru/api/v1/clean/phone
+ *   Authorization: Token <key> ; X-Secret: <secret> ; body ["<phone>"]
+ *
+ * Retry — только на сетевые ошибки и 5xx (4xx → сразу DaDataException, без retry).
+ * Сеть/таймаут после исчерпания retry → DaDataTimeoutException; 5xx → DaDataException.
+ * Конвенция клиента зеркалит App\Services\Supplier\SupplierPortalClient (inject HttpFactory).
+ */
+class DaDataPhoneClient
+{
+    private const URL = 'https://cleaner.dadata.ru/api/v1/clean/phone';
+
+    public function __construct(
+        private readonly HttpFactory $http,
+    ) {}
+
+    public function cleanPhone(string $phone): DaDataPhoneResponse
+    {
+        $cfg = (array) config('services.dadata');
+        $timeoutSec = max(1, (int) round(((int) ($cfg['timeout_ms'] ?? 2000)) / 1000));
+        $attempts = max(1, (int) ($cfg['retries'] ?? 1) + 1);
+        $apiKey = (string) ($cfg['api_key'] ?? '');
+        $secret = (string) ($cfg['secret'] ?? '');
+
+        $lastException = null;
+
+        for ($attempt = 0; $attempt < $attempts; $attempt++) {
+            try {
+                $response = $this->http
+                    ->asJson()
+                    ->acceptJson()
+                    ->timeout($timeoutSec)
+                    ->withHeaders([
+                        'Authorization' => 'Token '.$apiKey,
+                        'X-Secret' => $secret,
+                    ])
+                    ->post(self::URL, [$phone]);
+            } catch (ConnectionException $e) {
+                $lastException = new DaDataTimeoutException(
+                    'DaData connection failed: '.$e->getMessage(), 0, $e,
+                );
+
+                continue; // сеть → retry
+            }
+
+            if ($response->serverError()) {
+                $lastException = new DaDataException('DaData 5xx: HTTP '.$response->status());
+
+                continue; // 5xx → retry
+            }
+
+            if (! $response->successful()) {
+                // 4xx — клиентская ошибка, retry бессмыслен.
+                throw new DaDataException('DaData HTTP '.$response->status().': '.$response->body());
+            }
+
+            return $this->parse($response->json());
+        }
+
+        throw $lastException ?? new DaDataException('DaData failed without a response');
+    }
+
+    /**
+     * @param  mixed  $body  декодированный JSON (ожидается массив с одним объектом)
+     */
+    private function parse($body): DaDataPhoneResponse
+    {
+        $row = (is_array($body) && isset($body[0]) && is_array($body[0])) ? $body[0] : [];
+
+        return new DaDataPhoneResponse(
+            qc: isset($row['qc']) ? (int) $row['qc'] : null,
+            qcConflict: isset($row['qc_conflict']) ? (int) $row['qc_conflict'] : null,
+            type: isset($row['type']) ? (string) $row['type'] : null,
+            phone: isset($row['phone']) ? (string) $row['phone'] : null,
+            provider: isset($row['provider']) ? (string) $row['provider'] : null,
+            region: isset($row['region']) ? (string) $row['region'] : null,
+            city: isset($row['city']) ? (string) $row['city'] : null,
+            timezone: isset($row['timezone']) ? (string) $row['timezone'] : null,
+            raw: $row,
+        );
+    }
+}
@@ -0,0 +1,26 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App\Services\DaData;
+
+/**
+ * Распарсенный ответ DaData clean/phone (один номер → один объект), spec §3.6.
+ */
+final class DaDataPhoneResponse
+{
+    /**
+     * @param  array<string, mixed>  $raw  полный сырой объект ответа (для маскированного лога)
+     */
+    public function __construct(
+        public readonly ?int $qc,
+        public readonly ?int $qcConflict,
+        public readonly ?string $type,
+        public readonly ?string $phone,
+        public readonly ?string $provider,
+        public readonly ?string $region,
+        public readonly ?string $city,
+        public readonly ?string $timezone,
+        public readonly array $raw,
+    ) {}
+}
@@ -0,0 +1,27 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App\Services\DaData;
+
+/**
+ * Код качества (`qc`) ответа DaData clean/phone.
+ *
+ * Семантика DaData:
+ *   0 — телефон распознан уверенно;
+ *   1 — распознан с допущениями (требует проверки);
+ *   2 — пустой / невозможно распознать;
+ *   3 — несколько телефонов в одном поле;
+ *   7 — иностранный номер.
+ *
+ * Решения каскада по qc — в LeadRegionResolver (spec §3.4). Enum используется
+ * для читаемости и tryFrom() при парсинге; необъявленные значения остаются как int.
+ */
+enum DaDataQualityCode: int
+{
+    case RECOGNIZED = 0;
+    case ASSUMPTIONS = 1;
+    case EMPTY = 2;
+    case MULTIPLE = 3;
+    case FOREIGN = 7;
+}
@@ -0,0 +1,11 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App\Services\DaData;
+
+/**
+ * Сетевая ошибка / таймаут DaData (после исчерпания retry на сетевые сбои).
+ * Подкласс DaDataException — catch(DaDataException) покрывает оба случая.
+ */
+class DaDataTimeoutException extends DaDataException {}
@@ -0,0 +1,118 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App\Services\Dto;
+
+use App\Models\SupplierLead;
+
+/**
+ * Результат резолва региона лида (LeadRegionResolver, spec §3.3).
+ *
+ * `subjectCode` — итоговый код субъекта (используется маршрутизатором);
+ * `actualSubjectCode` — настоящий резолв (для лога actual_subject_code; на этапе
+ * резолва равен subjectCode, подмена региона — концерн RouteSupplierLeadJob §3.10).
+ * `source` ∈ dadata|rossvyaz|tag|unknown — ранг см. SOURCE_RANK (CSV-merge §3.12).
+ */
+final readonly class RegionResolution
+{
+    /** @var array<string, int> ранг источника для CSV-merge (выше = достовернее) */
+    public const SOURCE_RANK = [
+        'dadata' => 4,
+        'rossvyaz' => 3,
+        'tag' => 2,
+        'unknown' => 1,
+    ];
+
+    /**
+     * @param  array<string, mixed>|null  $dadataResponseMasked
+     */
+    public function __construct(
+        public ?int $subjectCode,
+        public ?int $actualSubjectCode,
+        public string $source,
+        public ?string $phoneOperator,
+        public ?int $qc,
+        public bool $cacheHit,
+        public ?array $dadataResponseMasked,
+        public ?int $durationMs,
+        public bool $rossvyazMatched,
+    ) {}
+
+    /**
+     * @param  array<string, mixed>|null  $dadataMasked
+     */
+    public static function make(
+        ?int $subjectCode,
+        string $source,
+        ?string $operator = null,
+        ?int $qc = null,
+        bool $cacheHit = false,
+        ?array $dadataMasked = null,
+        ?int $durationMs = null,
+        bool $rossvyazMatched = false,
+    ): self {
+        return new self(
+            subjectCode: $subjectCode,
+            actualSubjectCode: $subjectCode,
+            source: $source,
+            phoneOperator: $operator,
+            qc: $qc,
+            cacheHit: $cacheHit,
+            dadataResponseMasked: $dadataMasked,
+            durationMs: $durationMs,
+            rossvyazMatched: $rossvyazMatched,
+        );
+    }
+
+    public static function fromTag(?int $subjectCode): self
+    {
+        return self::make($subjectCode, $subjectCode !== null ? 'tag' : 'unknown');
+    }
+
+    /**
+     * Восстановление из persistent state лида (retry-идемпотентность §3.11) — без DaData-вызова.
+     */
+    public static function fromSupplierLead(SupplierLead $lead): self
+    {
+        return self::make(
+            subjectCode: $lead->resolved_subject_code !== null ? (int) $lead->resolved_subject_code : null,
+            source: (string) ($lead->region_source ?? 'unknown'),
+            operator: $lead->phone_operator,
+            qc: $lead->dadata_qc !== null ? (int) $lead->dadata_qc : null,
+        );
+    }
+
+    public function withCacheHit(bool $hit): self
+    {
+        return new self(
+            subjectCode: $this->subjectCode,
+            actualSubjectCode: $this->actualSubjectCode,
+            source: $this->source,
+            phoneOperator: $this->phoneOperator,
+            qc: $this->qc,
+            cacheHit: $hit,
+            dadataResponseMasked: null, // §3.11: cache-hit лог не несёт masked-ответ
+            durationMs: $this->durationMs,
+            rossvyazMatched: $this->rossvyazMatched,
+        );
+    }
+
+    /**
+     * Версия для записи в кэш (§7.3): без per-call полей (masked-ответ, длительность, cache-флаг).
+     */
+    public function forCache(): self
+    {
+        return new self(
+            subjectCode: $this->subjectCode,
+            actualSubjectCode: $this->actualSubjectCode,
+            source: $this->source,
+            phoneOperator: $this->phoneOperator,
+            qc: $this->qc,
+            cacheHit: false,
+            dadataResponseMasked: null,
+            durationMs: null,
+            rossvyazMatched: $this->rossvyazMatched,
+        );
+    }
+}
@@ -0,0 +1,20 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App\Services\Dto;
+
+/**
+ * Read-only результат поиска по реестру нумерации Россвязи (`phone_ranges`).
+ *
+ * `subjectCode` — код субъекта РФ 1..89 (см. App\Support\RussianRegions) либо
+ * null, если для диапазона он не был промаплен при импорте.
+ */
+final readonly class RossvyazRecord
+{
+    public function __construct(
+        public ?int $subjectCode,
+        public string $region,
+        public string $operator,
+    ) {}
+}
@@ -0,0 +1,176 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App\Services;
+
+use App\Models\SupplierLead;
+use App\Services\DaData\DaDataBudgetGuard;
+use App\Services\DaData\DaDataException;
+use App\Services\DaData\DaDataPhoneClient;
+use App\Services\DaData\DaDataPhoneResponse;
+use App\Services\Dto\RegionResolution;
+use App\Support\DaDataRegionMap;
+use Illuminate\Contracts\Cache\Repository as CacheRepository;
+
+/**
+ * Оркестратор резолва региона лида: DaData → Россвязь → tag-fallback (spec §3.3, §3.4).
+ *
+ * Каскад решений по qc:
+ *   qc 0/3 + region не-ambiguous и маппится → source=dadata;
+ *   qc 0/3 + region ambiguous/null/не-маппится → Россвязь (оператор от DaData сохраняем, §3.4.1);
+ *   qc 1 / таймаут / 5xx / бюджет исчерпан → Россвязь;
+ *   qc 2/7 → tag (Россвязь бессмысленна).
+ * Если ничего не дало код → source=tag (или unknown при пустом теге).
+ *
+ * Кэш по sha256(phone) (без сырого номера в ключе/значении, §7.3). Persistent-idempotency
+ * по supplier_leads.resolved_subject_code (защита от двойной оплаты DaData на retry, §3.11).
+ * Feature-flag services.dadata.enabled=false → сразу tag (текущее поведение, §6.5).
+ */
+class LeadRegionResolver
+{
+    public function __construct(
+        private readonly DaDataPhoneClient $dadataClient,
+        private readonly DaDataBudgetGuard $budgetGuard,
+        private readonly RossvyazPrefixLookup $rossvyazLookup,
+        private readonly RegionTagResolver $tagResolver,
+        private readonly CacheRepository $cache,
+    ) {}
+
+    public function resolve(SupplierLead $lead): RegionResolution
+    {
+        // Feature-flag: резолвер выключен → текущее tag-поведение.
+        if (! (bool) config('services.dadata.enabled', false)) {
+            return $this->tagFallback($lead, provider: null, qc: null, masked: null, start: null);
+        }
+
+        // Persistent-idempotency: уже резолвили на предыдущем try → без DaData.
+        if ($lead->resolved_subject_code !== null || $lead->region_source !== null) {
+            return RegionResolution::fromSupplierLead($lead);
+        }
+
+        $phone = (string) $lead->phone;
+        if (! preg_match('/^7\d{10}$/', $phone)) {
+            return $this->tagFallback($lead, provider: null, qc: null, masked: null, start: null);
+        }
+
+        $cacheKey = $this->cacheKey($phone);
+        $cached = $this->cache->get($cacheKey);
+        if ($cached instanceof RegionResolution) {
+            return $cached->withCacheHit(true);
+        }
+
+        $resolution = $this->doResolve($lead, $phone);
+
+        $ttlDays = max(1, (int) config('services.dadata.cache_ttl_days', 30));
+        $this->cache->put($cacheKey, $resolution->forCache(), now()->addDays($ttlDays));
+
+        return $resolution;
+    }
+
+    private function doResolve(SupplierLead $lead, string $phone): RegionResolution
+    {
+        $start = microtime(true);
+        $provider = null;
+        $qc = null;
+        $masked = null;
+
+        // 1. DaData (под дневным бюджетом).
+        if ($this->budgetGuard->canSpend()) {
+            try {
+                $dadata = $this->dadataClient->cleanPhone($phone);
+                $this->budgetGuard->recordSpend((int) config('services.dadata.call_cost_kopecks', 60));
+                $qc = $dadata->qc;
+                $provider = $dadata->provider;
+                $masked = $this->maskResponse($dadata);
+
+                if (in_array($dadata->qc, [0, 3], true)) {
+                    $region = (string) ($dadata->region ?? '');
+                    if ($region !== '' && ! DaDataRegionMap::isAmbiguous($region)) {
+                        $code = DaDataRegionMap::toSubjectCode($region);
+                        if ($code !== null) {
+                            return RegionResolution::make(
+                                $code, 'dadata',
+                                operator: $provider, qc: $qc,
+                                dadataMasked: $masked, durationMs: $this->ms($start),
+                            );
+                        }
+                        // qc=0/3, но регион не маппится → страховка Россвязью.
+                    }
+                    // ambiguous / region=null / не-маппится → Россвязь (provider от DaData сохраняем).
+                } elseif ($dadata->qc === 2 || $dadata->qc === 7) {
+                    // Мусор / иностранец → Россвязь не поможет, сразу tag.
+                    return $this->tagFallback($lead, $provider, $qc, $masked, $start);
+                }
+                // qc=1 → Россвязь.
+            } catch (DaDataException) {
+                // Сеть / таймаут / 5xx → деградируем на Россвязь, не падаем.
+            }
+        }
+
+        // 2. Россвязь.
+        $rossvyaz = $this->rossvyazLookup->find($phone);
+        if ($rossvyaz !== null) {
+            $code = $rossvyaz->subjectCode ?? DaDataRegionMap::toSubjectCode($rossvyaz->region);
+            if ($code !== null) {
+                return RegionResolution::make(
+                    $code, 'rossvyaz',
+                    operator: $provider ?? $rossvyaz->operator, // оператор от DaData приоритетнее (MNP)
+                    qc: $qc, dadataMasked: $masked,
+                    durationMs: $this->ms($start), rossvyazMatched: true,
+                );
+            }
+        }
+
+        // 3. Tag-fallback.
+        return $this->tagFallback($lead, $provider, $qc, $masked, $start);
+    }
+
+    private function tagFallback(SupplierLead $lead, ?string $provider, ?int $qc, ?array $masked, ?float $start): RegionResolution
+    {
+        $tag = (string) (is_array($lead->raw_payload) ? ($lead->raw_payload['tag'] ?? '') : '');
+        $tagCode = $this->tagResolver->resolve($tag);
+
+        return RegionResolution::make(
+            $tagCode,
+            $tagCode !== null ? 'tag' : 'unknown',
+            operator: $provider,
+            qc: $qc,
+            dadataMasked: $masked,
+            durationMs: $start !== null ? $this->ms($start) : null,
+        );
+    }
+
+    private function cacheKey(string $phone): string
+    {
+        return 'phone-region:'.hash('sha256', $phone);
+    }
+
+    private function ms(float $start): int
+    {
+        return (int) round((microtime(true) - $start) * 1000);
+    }
+
+    /**
+     * @return array<string, mixed>  сырой ответ DaData с маскированным телефоном (§7.1)
+     */
+    private function maskResponse(DaDataPhoneResponse $response): array
+    {
+        $raw = $response->raw;
+        if (isset($raw['phone']) && is_string($raw['phone'])) {
+            $raw['phone'] = $this->maskPhone($raw['phone']);
+        }
+
+        return $raw;
+    }
+
+    private function maskPhone(string $phone): string
+    {
+        $digits = preg_replace('/\D+/', '', $phone) ?? '';
+        if (strlen($digits) < 8) {
+            return '***';
+        }
+
+        return substr($digits, 0, 4).'***'.substr($digits, -4);
+    }
+}
@@ -10,129 +10,219 @@ use Illuminate\Support\Carbon;
 use Illuminate\Support\Collection;
 use Illuminate\Support\Facades\DB;
 use Illuminate\Support\Facades\Log;
+use Random\Randomizer;

 /**
- * Подбор eligible Лидерра-проектов для входящего лида (sharing-model §6).
+ * Подбор eligible Лидерра-проектов для входящего лида (sharing-model §6) с
+ * каскадной маршрутизацией по региону (lead region resolution §3.9).
 *
 * Eligibility — структурно через snapshot `project_routing_snapshots` за активную
 * дату слепка (slepok-инвариант): до 21:00 МСК активен snapshot сегодняшней даты,
- * с 21:00 МСК — завтрашней. Все эффективные параметры маршрутизации
- * (daily_limit, delivery_days_mask, regions, signal_type/signal_identifier и т.д.)
- * берутся из snapshot. Из live `projects` — только `delivered_today` (счётчик
- * остатка лимита, обновляется в течение дня) и из `tenants` — `balance_rub`
- * (live auto-pause при нулевом балансе).
+ * с 21:00 МСК — завтрашней. Все эффективные параметры маршрутизации берутся из
+ * snapshot; из live `projects` — только `delivered_today` (остаток лимита),
+ * из `tenants` — `balance_rub` + `frozen_by_balance_at` (live auto-pause).
 *
- * Это закрывает R-01..R-04, R-06..R-08, R-15 (spec §1.3) — клиент Лидерры,
- * который paus'нул проект ПОСЛЕ зафиксированного слепка поставщика, всё равно
- * получает свои оплаченные лиды по уже зафиксированному slepok'у.
+ * Каскад (§3.9): один SQL оборачивается тремя фазами по убыванию точности региона:
+ *   1) точное совпадение субъекта (`?::int = ANY(snap.regions)`);
+ *   2) «вся РФ» (`snap.regions = '{}'`), добор недостающих слотов;
+ *   3) запасной канал (без фильтра региона) — только если первые две пусты;
+ *      сделкам в этой фазе подменяется subject_code (RouteSupplierLeadJob §3.10).
+ * Каждый Project помечается атрибутом `routing_step` (1/2/3).
 *
- * Регион сопоставляется самим supplier_project (тег = субъект) — phone-prefix
- * фильтр убран (эпик миграции проектов, Q5): для мобильных он no-op, а регион
- * гарантирован тем, через какой supplier_project пришёл лид.
+ * Отбор внутри фазы при кандидатах > cap — **взвешенный жребий по остатку лимита**
+ * (вариант D1=В): шанс ∝ остатку, но у каждого кандидата шанс > 0 (вес ≥ 1) —
+ * маленькие клиенты не отрезаются. cap = LeadDistributor::CAP (лид продаётся ≤3 раз).
+ * Жребий через инъектируемый \Random\Randomizer (тесты сидируют Mt19937).
 *
 * Запрос через connection pgsql_supplier (BYPASSRLS crm_supplier_worker) — в
 * sharing-flow tenant ещё не определён, SELECT видит проекты всех tenant'ов.
 *
- * Spec: docs/superpowers/specs/2026-05-26-slepok-routing-protection-design.md §4.2.3.
+ * Spec: docs/superpowers/specs/2026-05-26-slepok-routing-protection-design.md §4.2.3
+ *     + docs/superpowers/specs/2026-05-29-lead-region-resolution-design.md §3.9.
 */
 class LeadRouter
 {
+    public function __construct(
+        private readonly Randomizer $randomizer = new Randomizer,
+    ) {}
+
    /**
-     * Возвращает ONE project per tenant_id — тот, у которого наибольший остаток
-     * дневного лимита (DISTINCT ON (tenant_id) с ORDER BY remaining DESC, created_at, id).
-     *
-     * Семантика (Spec B Task 3): один лид продаётся не более чем 3 РАЗЛИЧНЫМ тенантам
-     * (клиентам), каждый тенант получает ровно ОДИН проект — с наибольшим остатком.
-     * LeadDistributor::selectRecipients (CAP=3) теперь ограничивает число тенантов,
-     * а не число проектов, потому что входные данные уже one-per-tenant.
-     *
-     * Запрос через pgsql_supplier (BYPASSRLS crm_supplier_worker) — tenant ещё не
-     * определён, SELECT видит проекты всех tenant'ов.
+     * Возвращает ≤ cap проектов (по одному на tenant), отобранных каскадом
+     * по региону + взвешенным жребием. Каждый Project несёт `routing_step`.
     *
     * @return Collection<int, Project>
     */
-    public function matchEligibleProjects(SupplierProject $supplierProject): Collection
+    public function matchEligibleProjects(SupplierProject $supplierProject, ?int $resolvedSubjectCode = null): Collection
    {
-        // Активная дата слепка вычисляется в PHP — детерминирована для всего запроса,
-        // тестируема через Carbon::setTestNow, исключает дрейф между PHP- и DB-часами.
        $activeDate = $this->activeSnapshotDate();
+        $cap = LeadDistributor::CAP;

-        // Phase 3: для DIRECT-supplier_project — fallback на signal_type+signal_identifier
-        // match с Лидерра-проектами через snapshot (project_supplier_links для
-        // DIRECT-row'ов не создаются — DIRECT supplier_projects создаются автоматически
-        // при получении webhook'а без B-префикса).
-        if ($supplierProject->platform === 'DIRECT') {
-            $directSql = <<<'SQL'
-                SELECT DISTINCT ON (snap.tenant_id)
-                    projects.*,
-                    snap.daily_limit AS snapshot_daily_limit
-                FROM project_routing_snapshots snap
-                INNER JOIN projects ON projects.id = snap.project_id
-                WHERE snap.snapshot_date = ?::date
-                  AND snap.signal_type = ?
-                  AND LOWER(snap.signal_identifier) = LOWER(?)
-                  AND projects.delivered_today < snap.daily_limit
-                  AND EXISTS (
-                      SELECT 1 FROM tenants
-                      WHERE tenants.id = snap.tenant_id
-                        AND tenants.balance_rub > 0
-                        -- R-03: frozen tenant must not receive new leads (Stage 3 §4.3.1)
-                        AND tenants.frozen_by_balance_at IS NULL
-                  )
-                ORDER BY snap.tenant_id,
-                         (snap.daily_limit - projects.delivered_today) DESC,
-                         projects.created_at,
-                         projects.id
-            SQL;
-            $directRows = DB::connection('pgsql_supplier')->select(
-                $directSql,
-                [$activeDate, $supplierProject->signal_type, $supplierProject->unique_key]
-            );
+        // Фаза 1: точное совпадение региона (только если резолвер дал subject_code).
+        $exact = $resolvedSubjectCode !== null
+            ? $this->queryCandidates($activeDate, $supplierProject, 'exact', $resolvedSubjectCode, [])
+            : collect();
+        $selected = $this->weightedPick($exact, $cap);
+        $this->tagStep($selected, 1);

-            $this->logIfNoSnapshot($directRows, $supplierProject, $activeDate);
-
-            return Project::hydrate($directRows)->values();
+        if ($selected->count() >= $cap) {
+            return $selected->take($cap)->values();
        }

-        // Existing B1/B2/B3 path — explicit project_supplier_links pivot.
-        $sql = <<<'SQL'
+        // Фаза 2: «вся РФ», добор недостающих слотов (исключая уже выбранных tenant'ов).
+        $allRu = $this->queryCandidates(
+            $activeDate, $supplierProject, 'all_ru', null,
+            $selected->pluck('tenant_id')->all(),
+        );
+        $pickedRu = $this->weightedPick($allRu, $cap - $selected->count());
+        $this->tagStep($pickedRu, 2);
+        $combined = $selected->concat($pickedRu);
+
+        if ($combined->isNotEmpty()) {
+            return $combined->take($cap)->values();
+        }
+
+        // Фаза 3: запасной канал (никто не подписан на регион и нет «вся РФ»).
+        $fallback = $this->weightedPick(
+            $this->queryCandidates($activeDate, $supplierProject, 'any', null, []),
+            $cap,
+        );
+        $this->tagStep($fallback, 3);
+
+        $this->logIfNoSnapshot($fallback->all(), $supplierProject, $activeDate);
+
+        return $fallback->take($cap)->values();
+    }
+
+    /**
+     * Один SQL-запрос фазы каскада: DISTINCT ON (tenant_id) с фильтром региона.
+     * regionFilter ∈ exact|all_ru|any. Возвращает всех eligible (по одному на tenant),
+     * упорядоченных по остатку лимита DESC, created_at, id; жребий — поверх в PHP.
+     *
+     * @param  list<int>  $excludeTenantIds
+     * @return Collection<int, Project>
+     */
+    private function queryCandidates(string $activeDate, SupplierProject $sp, string $regionFilter, ?int $code, array $excludeTenantIds): Collection
+    {
+        $bindings = [$activeDate];
+
+        if ($sp->platform === 'DIRECT') {
+            // DIRECT supplier_projects не имеют pivot — матч по signal_type + identifier.
+            $sourceWhere = 'snap.signal_type = ? AND LOWER(snap.signal_identifier) = LOWER(?)';
+            $bindings[] = $sp->signal_type;
+            $bindings[] = $sp->unique_key;
+        } else {
+            $sourceWhere = 'EXISTS (SELECT 1 FROM project_supplier_links psl
+                  WHERE psl.project_id = snap.project_id AND psl.supplier_project_id = ?)';
+            $bindings[] = $sp->id;
+        }
+
+        $regionWhere = '';
+        if ($regionFilter === 'exact') {
+            $regionWhere = 'AND ?::int = ANY(snap.regions)';
+            $bindings[] = $code;
+        } elseif ($regionFilter === 'all_ru') {
+            $regionWhere = "AND snap.regions = '{}'::int[]";
+        }
+
+        $excludeWhere = '';
+        if ($excludeTenantIds !== []) {
+            $placeholders = implode(',', array_fill(0, count($excludeTenantIds), '?'));
+            $excludeWhere = "AND snap.tenant_id NOT IN ($placeholders)";
+            foreach ($excludeTenantIds as $tid) {
+                $bindings[] = $tid;
+            }
+        }
+
+        $sql = <<<SQL
            SELECT DISTINCT ON (snap.tenant_id)
                projects.*,
-                snap.daily_limit AS snapshot_daily_limit
+                snap.daily_limit AS snapshot_daily_limit,
+                snap.regions AS snapshot_regions
            FROM project_routing_snapshots snap
            INNER JOIN projects ON projects.id = snap.project_id
            WHERE snap.snapshot_date = ?::date
-              AND EXISTS (
-                  SELECT 1 FROM project_supplier_links psl
-                  WHERE psl.project_id = snap.project_id
-                    AND psl.supplier_project_id = ?
-              )
+              AND $sourceWhere
              AND projects.delivered_today < snap.daily_limit
              AND EXISTS (
                  SELECT 1 FROM tenants
                  WHERE tenants.id = snap.tenant_id
                    AND tenants.balance_rub > 0
-                    -- R-03: frozen tenant must not receive new leads (Stage 3 §4.3.1)
                    AND tenants.frozen_by_balance_at IS NULL
              )
+              $regionWhere
+              $excludeWhere
            ORDER BY snap.tenant_id,
                     (snap.daily_limit - projects.delivered_today) DESC,
                     projects.created_at,
                     projects.id
        SQL;
-        $rows = DB::connection('pgsql_supplier')->select($sql, [$activeDate, $supplierProject->id]);

-        $this->logIfNoSnapshot($rows, $supplierProject, $activeDate);
-
-        return Project::hydrate($rows)->values();
+        return Project::hydrate(DB::connection('pgsql_supplier')->select($sql, $bindings));
    }

    /**
-     * Активная дата слепка по правилу slepok-инварианта:
-     *   до 21:00 МСК — сегодняшняя дата;
-     *   с 21:00 МСК — завтрашняя.
+     * Взвешенный жребий без возврата (вариант D1=В): отбирает ≤ $n кандидатов,
+     * вероятность ∝ остатку лимита, вес ≥ 1 у каждого (мелкие не отрезаются).
+     * При кандидатах ≤ $n — возвращает всех в исходном SQL-порядке (детерминизм).
     *
-     * Spec §4.2.3.
+     * @param  Collection<int, Project>  $candidates
+     * @return Collection<int, Project>
+     */
+    private function weightedPick(Collection $candidates, int $n): Collection
+    {
+        if ($n <= 0) {
+            return collect();
+        }
+
+        $pool = $candidates->values()->all();
+        if (count($pool) <= $n) {
+            return collect($pool);
+        }
+
+        $picked = [];
+        for ($i = 0; $i < $n && $pool !== []; $i++) {
+            $total = 0;
+            foreach ($pool as $p) {
+                $total += $this->weightOf($p);
+            }
+
+            $roll = $this->randomizer->getInt(1, $total);
+            $acc = 0;
+            $winner = 0;
+            foreach ($pool as $idx => $p) {
+                $acc += $this->weightOf($p);
+                if ($roll <= $acc) {
+                    $winner = $idx;
+                    break;
+                }
+            }
+
+            $picked[] = $pool[$winner];
+            array_splice($pool, $winner, 1);
+        }
+
+        return collect($picked);
+    }
+
+    private function weightOf(Project $project): int
+    {
+        $remaining = (int) $project->snapshot_daily_limit - (int) $project->delivered_today;
+
+        return max(1, $remaining);
+    }
+
+    /**
+     * @param  Collection<int, Project>  $projects
+     */
+    private function tagStep(Collection $projects, int $step): void
+    {
+        foreach ($projects as $project) {
+            $project->setAttribute('routing_step', $step);
+        }
+    }
+
+    /**
+     * Активная дата слепка: до 21:00 МСК — сегодня, с 21:00 МСК — завтра (§4.2.3).
     */
    private function activeSnapshotDate(): string
    {
@@ -144,11 +234,11 @@ class LeadRouter
    }

    /**
-     * Fail-loud: пишет в лог если по активной дате слепка вообще нет ни одной строки
-     * snapshot'а — это значит, что cron `SnapshotProjectRoutingJob` не отработал.
-     * (Если строки есть, но ни одна не сматчилась — это валидный 0-результат, не алерт.)
+     * Fail-loud: пишет в лог, если по активной дате слепка вообще нет ни одной строки
+     * snapshot'а (cron SnapshotProjectRoutingJob не отработал). Пустой валидный
+     * результат при наличии snapshot'ов — не алерт.
     *
-     * @param  array<int, object>  $rows
+     * @param  array<int, mixed>  $rows
     */
    private function logIfNoSnapshot(array $rows, SupplierProject $supplierProject, string $activeDate): void
    {
@@ -59,6 +59,8 @@ class MonthlyPartitionManager
        'saas_admin_audit_log' => 'created_at',
        // Slepok routing (Этап 2, 27.05.2026)
        'project_routing_snapshots' => 'snapshot_date',
+        // Lead region resolution (Session 1, 31.05.2026)
+        'lead_region_resolution_log' => 'received_at',
    ];

    /**
@@ -0,0 +1,60 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App\Services;
+
+use App\Services\Dto\RossvyazRecord;
+use Illuminate\Support\Facades\DB;
+
+/**
+ * Локальный fallback резолва региона/оператора по телефону через реестр
+ * нумерации Россвязи (`phone_ranges`).
+ *
+ * Используется LeadRegionResolver когда DaData недоступна/неуверена (qc=1,
+ * timeout, бюджет исчерпан). Алгоритм (spec §3.7):
+ *   - def_code = 3 цифры кода ABC/DEF (позиции 1..3 нормализованного номера);
+ *   - subscriber = остаток номера как BIGINT;
+ *   - выбираем самый УЗКИЙ диапазон, накрывающий номер (ORDER BY width ASC),
+ *     т.к. узкие переопределения операторов точнее широких региональных блоков.
+ *
+ * Запрос идёт через `pgsql_supplier` (BYPASSRLS на проде, как LeadRouter):
+ * `phone_ranges` — SaaS-level публичные данные без RLS.
+ */
+class RossvyazPrefixLookup
+{
+    /** Connection для чтения реестра (на проде BYPASSRLS, на dev/test — superuser fallback). */
+    public const CONNECTION = 'pgsql_supplier';
+
+    public function find(string $phone): ?RossvyazRecord
+    {
+        $digits = preg_replace('/\D+/', '', $phone) ?? '';
+
+        // Российский номер: 7|8 + ABC/DEF (3) + абонент (7) = 11 цифр.
+        if (strlen($digits) !== 11) {
+            return null;
+        }
+
+        $defCode = (int) substr($digits, 1, 3);
+        $subscriber = (int) substr($digits, 4);
+
+        $row = DB::connection(self::CONNECTION)->selectOne(
+            'SELECT region, operator, subject_code
+               FROM phone_ranges
+              WHERE def_code = ? AND from_num <= ? AND to_num >= ?
+              ORDER BY (to_num - from_num) ASC
+              LIMIT 1',
+            [$defCode, $subscriber, $subscriber],
+        );
+
+        if ($row === null) {
+            return null;
+        }
+
+        return new RossvyazRecord(
+            subjectCode: $row->subject_code !== null ? (int) $row->subject_code : null,
+            region: (string) $row->region,
+            operator: (string) $row->operator,
+        );
+    }
+}
@@ -0,0 +1,53 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App\Support;
+
+/**
+ * Маппинг строки региона из ответа DaData → код субъекта РФ (1..89).
+ *
+ * DaData возвращает регион в поле `region` (например «Москва», «Московская область»).
+ * Большинство имён точно совпадают с App\Support\RussianRegions::CODE_TO_NAME;
+ * расхождения (если найдутся на staging) кладутся в OVERRIDES.
+ *
+ * «Объединённые» агломерации («Санкт-Петербург и область») — DaData не различает
+ * город и область внутри поля region. Такие строки помечаются isAmbiguous() →
+ * LeadRegionResolver уходит за точным subject_code в Россвязь (spec §3.4.1).
+ */
+final class DaDataRegionMap
+{
+    /**
+     * Строки-агломерации, по которым нельзя однозначно определить субъект.
+     * Расширяется по реальным наблюдениям на staging (spec §3.4.1).
+     *
+     * @var list<string>
+     */
+    public const AMBIGUOUS_REGIONS = [
+        'Санкт-Петербург и область',
+        'Москва и область',
+    ];
+
+    /**
+     * Ручные переопределения для имён DaData, не совпадающих с RussianRegions.
+     * На старте пуст — заполняется по findings со staging-smoke.
+     *
+     * @var array<string, int>
+     */
+    public const OVERRIDES = [];
+
+    public static function toSubjectCode(string $name): ?int
+    {
+        $name = trim($name);
+        if ($name === '') {
+            return null;
+        }
+
+        return self::OVERRIDES[$name] ?? RussianRegions::nameToCode()[$name] ?? null;
+    }
+
+    public static function isAmbiguous(string $name): bool
+    {
+        return in_array(trim($name), self::AMBIGUOUS_REGIONS, true);
+    }
+}
@@ -114,9 +114,63 @@ final class RussianRegions
        89 => 'Ямало-Ненецкий автономный округ',
    ];

+    /**
+     * Алиасы нестандартных форм реестра Россвязи → каноничное имя субъекта.
+     * Города фед. значения приходят с префиксом «г. »; «Республика Удмуртская» —
+     * перевёрнутый порядок слов; «Кемеровская область - Кузбасс обл.» — спец-форма.
+     *
+     * @var array<string, string>
+     */
+    private const REGION_ALIASES = [
+        'г. Москва' => 'Москва',
+        'г. Санкт-Петербург' => 'Санкт-Петербург',
+        'г. Севастополь' => 'Севастополь',
+        'Республика Удмуртская' => 'Удмуртская Республика',
+        'Кемеровская область - Кузбасс обл.' => 'Кемеровская область',
+        'Кемеровская область - Кузбасс' => 'Кемеровская область',
+    ];
+
    /** @return array<string, int> name => code (обратный индекс) */
    public static function nameToCode(): array
    {
        return array_flip(self::CODE_TO_NAME);
    }
+
+    /**
+     * Нормализует строку региона реестра Россвязи в каноничное имя субъекта (или null).
+     *
+     * Реестр кодирует субъект как ПОСЛЕДНИЙ сегмент после «|»
+     * (напр. «г. Воскресенск|р-н Воскресенский|Московская обл.» → «Московская обл.»),
+     * с сокращением «обл.» вместо «область» и рядом нестандартных форм (см. REGION_ALIASES).
+     * Безнадёжные/неоднозначные строки («-», «Российская Федерация»,
+     * «Москва и Московская область», «г.о. Тольятти») → null.
+     */
+    public static function canonicalRegionName(string $raw): ?string
+    {
+        $segment = self::lastRegionSegment($raw);
+        if ($segment === '') {
+            return null;
+        }
+
+        $name = self::REGION_ALIASES[$segment]
+            ?? (string) preg_replace('/\s*обл\.$/u', ' область', $segment);
+
+        return isset(self::nameToCode()[$name]) ? $name : null;
+    }
+
+    /** Резолвит строку региона реестра Россвязи в subject_code (1..89) или null. */
+    public static function resolveSubjectCode(string $raw): ?int
+    {
+        $name = self::canonicalRegionName($raw);
+
+        return $name === null ? null : (self::nameToCode()[$name] ?? null);
+    }
+
+    /** Последний сегмент после «|» (субъект в формате Россвязи), trimmed. */
+    private static function lastRegionSegment(string $raw): string
+    {
+        $parts = explode('|', $raw);
+
+        return trim((string) end($parts));
+    }
 }
@@ -42,4 +42,17 @@ return [
        'alert_email' => env('SUPPLIER_ALERT_EMAIL', 'ops@liderra.ru'),
    ],

+    // DaData phone cleaner — резолв региона лида по телефону (lead region resolution).
+    // Ключи → YC Lockbox на проде; на dev/staging — .env. enabled=false до раскатки.
+    'dadata' => [
+        'api_key' => env('DADATA_API_KEY'),
+        'secret' => env('DADATA_SECRET'),
+        'timeout_ms' => (int) env('DADATA_TIMEOUT_MS', 2000),
+        'retries' => (int) env('DADATA_RETRIES', 1),
+        'daily_cap_rub' => (int) env('DADATA_DAILY_CAP_RUB', 10000),
+        'call_cost_kopecks' => (int) env('DADATA_CALL_COST_KOPECKS', 60), // ≈0.60 ₽/вызов, откалибровать по тарифу
+        'enabled' => filter_var(env('LEAD_REGION_RESOLVER_ENABLED', false), FILTER_VALIDATE_BOOL),
+        'cache_ttl_days' => (int) env('PHONE_REGION_CACHE_TTL_DAYS', 30),
+    ],
+
 ];
@@ -0,0 +1,169 @@
+<?php
+
+declare(strict_types=1);
+
+use Illuminate\Database\Migrations\Migration;
+use Illuminate\Support\Facades\DB;
+
+return new class extends Migration {
+    public function up(): void
+    {
+        // SET ROLE crm_migrator на проде (postgres superuser может SET ROLE).
+        // На dev/testing crm_migrator не имеет GRANT на public schema → RESET ROLE
+        // и продолжаем как postgres superuser.
+        try {
+            DB::statement('SET ROLE crm_migrator');
+            $canCreate = DB::selectOne("SELECT has_schema_privilege('crm_migrator', 'public', 'CREATE') AS ok");
+            if (!$canCreate || !$canCreate->ok) {
+                DB::statement('RESET ROLE');
+            }
+        } catch (\Throwable) {
+            // окружение без роли — продолжаем как superuser
+        }
+
+        DB::unprepared(<<<'SQL'
+            -- 1. phone_ranges_imports (журнал импортов; на него FK из phone_ranges, создаём первым)
+            CREATE TABLE phone_ranges_imports (
+                id              BIGSERIAL PRIMARY KEY,
+                imported_at     TIMESTAMPTZ NOT NULL DEFAULT NOW(),
+                source_url      TEXT NOT NULL,
+                rows_inserted   INTEGER NOT NULL DEFAULT 0,
+                rows_updated    INTEGER NOT NULL DEFAULT 0,
+                checksum_sha256 TEXT NOT NULL,
+                status          TEXT NOT NULL DEFAULT 'in_progress'
+                    CHECK (status IN ('in_progress','completed','failed','rolled_back')),
+                error           TEXT,
+                completed_at    TIMESTAMPTZ
+            );
+            COMMENT ON TABLE phone_ranges_imports IS
+                'Журнал импортов реестра Россвязи (idempotency по checksum_sha256, atomic-swap откат).';
+
+            -- 2. phone_ranges (реестр диапазонов Россвязи; SaaS-level, без RLS — публичные данные)
+            CREATE TABLE phone_ranges (
+                id                BIGSERIAL PRIMARY KEY,
+                def_code          SMALLINT NOT NULL,
+                from_num          BIGINT NOT NULL,
+                to_num            BIGINT NOT NULL,
+                operator          TEXT NOT NULL,
+                region            TEXT NOT NULL,
+                region_normalized TEXT,
+                subject_code      SMALLINT,
+                imported_at       TIMESTAMPTZ NOT NULL,
+                import_id         BIGINT NOT NULL REFERENCES phone_ranges_imports(id),
+                CONSTRAINT chk_phone_ranges_def_code CHECK (def_code BETWEEN 300 AND 999),
+                CONSTRAINT chk_phone_ranges_subject_code CHECK (subject_code IS NULL OR subject_code BETWEEN 1 AND 89),
+                CONSTRAINT chk_phone_ranges_range_valid CHECK (from_num <= to_num)
+            );
+            CREATE INDEX idx_phone_ranges_lookup ON phone_ranges (def_code, from_num, to_num);
+            COMMENT ON TABLE phone_ranges IS
+                'Реестр диапазонов нумерации Россвязи (rossvyaz.gov.ru). Локальный fallback для LeadRegionResolver. Обновляется ежемесячным cron-импортом.';
+
+            GRANT SELECT ON phone_ranges, phone_ranges_imports TO crm_app_user, crm_supplier_worker;
+
+            -- 3. lead_region_resolution_log (SaaS-level, партиционирован по received_at, паттерн activity_log)
+            CREATE TABLE lead_region_resolution_log (
+                id                       BIGSERIAL,
+                supplier_lead_id         BIGINT NOT NULL,
+                received_at              TIMESTAMPTZ NOT NULL,
+                phone_masked             TEXT NOT NULL,
+                subject_code_resolved    SMALLINT,
+                subject_code_from_tag    SMALLINT,
+                region_source            TEXT NOT NULL
+                    CHECK (region_source IN ('dadata','rossvyaz','tag','unknown')),
+                dadata_qc                SMALLINT,
+                dadata_provider          TEXT,
+                dadata_type              TEXT,
+                dadata_response_masked   JSONB,
+                rossvyaz_matched         BOOLEAN NOT NULL DEFAULT FALSE,
+                actual_subject_code      SMALLINT
+                    CHECK (actual_subject_code IS NULL OR actual_subject_code BETWEEN 1 AND 89),
+                substituted_subject_code SMALLINT
+                    CHECK (substituted_subject_code IS NULL OR substituted_subject_code BETWEEN 1 AND 89),
+                routing_step             SMALLINT
+                    CHECK (routing_step IS NULL OR routing_step BETWEEN 1 AND 3),
+                phone_operator           TEXT,
+                cache_hit                BOOLEAN NOT NULL DEFAULT FALSE,
+                duration_ms              INTEGER,
+                resolved_at              TIMESTAMPTZ NOT NULL DEFAULT NOW(),
+                PRIMARY KEY (id, received_at)
+            ) PARTITION BY RANGE (received_at);
+
+            CREATE INDEX idx_lrrl_lead_id ON lead_region_resolution_log (supplier_lead_id);
+            CREATE INDEX idx_lrrl_source ON lead_region_resolution_log (region_source, received_at);
+            COMMENT ON TABLE lead_region_resolution_log IS
+                'Аудит каждого резолва региона лида (источник, qc, оператор, шаг каскада). Партиции помесячно по received_at (MonthlyPartitionManager).';
+
+            GRANT SELECT, INSERT ON lead_region_resolution_log TO crm_supplier_worker;
+            GRANT SELECT ON lead_region_resolution_log TO crm_app_user;
+
+            -- Стартовые партиции (далее их подхватывает partitions:create-months после Task 1.2).
+            CREATE TABLE lead_region_resolution_log_y2026_m05
+                PARTITION OF lead_region_resolution_log
+                FOR VALUES FROM ('2026-05-01') TO ('2026-06-01');
+            CREATE TABLE lead_region_resolution_log_y2026_m06
+                PARTITION OF lead_region_resolution_log
+                FOR VALUES FROM ('2026-06-01') TO ('2026-07-01');
+
+            -- 4. supplier_leads: +4 колонки (denormalized display + persistent idempotency для retry).
+            ALTER TABLE supplier_leads
+                ADD COLUMN resolved_subject_code SMALLINT
+                    CHECK (resolved_subject_code IS NULL OR resolved_subject_code BETWEEN 1 AND 89),
+                ADD COLUMN region_source TEXT
+                    CHECK (region_source IN ('dadata','rossvyaz','tag','unknown')),
+                ADD COLUMN dadata_qc SMALLINT,
+                ADD COLUMN phone_operator TEXT;
+
+            -- 5. deals: +2 колонки (UI-карточка + флаг подмены региона).
+            ALTER TABLE deals
+                ADD COLUMN phone_operator TEXT,
+                ADD COLUMN region_substituted BOOLEAN NOT NULL DEFAULT FALSE;
+        SQL);
+
+        // Регистрация retention для lead_region_resolution_log (system_settings, 12 месяцев ≈ 365 дней).
+        $exists = DB::table('system_settings')
+            ->where('key', 'partition_retention_months_lead_region_resolution_log')
+            ->exists();
+        if (! $exists) {
+            DB::table('system_settings')->insert([
+                'key' => 'partition_retention_months_lead_region_resolution_log',
+                'value' => '12',
+                'type' => 'int',
+                'description' => 'Retention в месяцах для lead_region_resolution_log (~365 дней)',
+                'updated_at' => now(),
+            ]);
+        }
+    }
+
+    public function down(): void
+    {
+        try {
+            DB::statement('SET ROLE crm_migrator');
+            $canCreate = DB::selectOne("SELECT has_schema_privilege('crm_migrator', 'public', 'CREATE') AS ok");
+            if (!$canCreate || !$canCreate->ok) {
+                DB::statement('RESET ROLE');
+            }
+        } catch (\Throwable) {
+            // окружение без роли — продолжаем как superuser
+        }
+
+        DB::unprepared(<<<'SQL'
+            ALTER TABLE deals
+                DROP COLUMN IF EXISTS phone_operator,
+                DROP COLUMN IF EXISTS region_substituted;
+
+            ALTER TABLE supplier_leads
+                DROP COLUMN IF EXISTS resolved_subject_code,
+                DROP COLUMN IF EXISTS region_source,
+                DROP COLUMN IF EXISTS dadata_qc,
+                DROP COLUMN IF EXISTS phone_operator;
+
+            DROP TABLE IF EXISTS lead_region_resolution_log CASCADE;
+            DROP TABLE IF EXISTS phone_ranges CASCADE;
+            DROP TABLE IF EXISTS phone_ranges_imports CASCADE;
+        SQL);
+
+        DB::table('system_settings')
+            ->where('key', 'partition_retention_months_lead_region_resolution_log')
+            ->delete();
+    }
+};
@@ -5,7 +5,6 @@
    "packages": {
        "": {
            "dependencies": {
-                "keytar": "*",
                "lucide-vue-next": "^1.0.0"
            },
            "devDependencies": {
@@ -40,9 +39,6 @@
                "vue-tsc": "^3.2.8",
                "vuedraggable": "^4.1.0",
                "vuetify": "^3.12.5"
-            },
-            "optionalDependencies": {
-                "keytar": "^7.9.0"
            }
        },
        "node_modules/@acemir/cssom": {
@@ -4226,27 +4222,6 @@
                "node": "18 || 20 || >=22"
            }
        },
-        "node_modules/base64-js": {
-            "version": "1.5.1",
-            "resolved": "https://registry.npmjs.org/base64-js/-/base64-js-1.5.1.tgz",
-            "integrity": "sha512-AKpaYlHn8t4SVbOHCy+b5+KKgvR4vrsD8vbvrbiQJps7fKDTkjkDry6ji0rUJjC0kzbNePLwzxq8iypo41qeWA==",
-            "funding": [
-                {
-                    "type": "github",
-                    "url": "https://github.com/sponsors/feross"
-                },
-                {
-                    "type": "patreon",
-                    "url": "https://www.patreon.com/feross"
-                },
-                {
-                    "type": "consulting",
-                    "url": "https://feross.org/support"
-                }
-            ],
-            "license": "MIT",
-            "optional": true
-        },
        "node_modules/bidi-js": {
            "version": "1.0.3",
            "resolved": "https://registry.npmjs.org/bidi-js/-/bidi-js-1.0.3.tgz",
@@ -4267,18 +4242,6 @@
                "url": "https://github.com/sponsors/antfu"
            }
        },
-        "node_modules/bl": {
-            "version": "4.1.0",
-            "resolved": "https://registry.npmjs.org/bl/-/bl-4.1.0.tgz",
-            "integrity": "sha512-1W07cM9gS6DcLperZfFSj+bWLtaPGSOHWhPiGzXmvVJbRLdG82sH/Kn8EtW1VqWVA54AKf2h5k5BbnIbwF3h6w==",
-            "license": "MIT",
-            "optional": true,
-            "dependencies": {
-                "buffer": "^5.5.0",
-                "inherits": "^2.0.4",
-                "readable-stream": "^3.4.0"
-            }
-        },
        "node_modules/boolbase": {
            "version": "1.0.0",
            "resolved": "https://registry.npmjs.org/boolbase/-/boolbase-1.0.0.tgz",
@@ -4312,31 +4275,6 @@
                "node": ">=8"
            }
        },
-        "node_modules/buffer": {
-            "version": "5.7.1",
-            "resolved": "https://registry.npmjs.org/buffer/-/buffer-5.7.1.tgz",
-            "integrity": "sha512-EHcyIPBQ4BSGlvjB16k5KgAJ27CIsHY/2JBmCRReo48y9rQ3MaUzWX3KVlBa4U7MyX02HdVj0K7C3WaB3ju7FQ==",
-            "funding": [
-                {
-                    "type": "github",
-                    "url": "https://github.com/sponsors/feross"
-                },
-                {
-                    "type": "patreon",
-                    "url": "https://www.patreon.com/feross"
-                },
-                {
-                    "type": "consulting",
-                    "url": "https://feross.org/support"
-                }
-            ],
-            "license": "MIT",
-            "optional": true,
-            "dependencies": {
-                "base64-js": "^1.3.1",
-                "ieee754": "^1.1.13"
-            }
-        },
        "node_modules/bundle-name": {
            "version": "4.1.0",
            "resolved": "https://registry.npmjs.org/bundle-name/-/bundle-name-4.1.0.tgz",
@@ -4443,13 +4381,6 @@
                "url": "https://paulmillr.com/funding/"
            }
        },
-        "node_modules/chownr": {
-            "version": "1.1.4",
-            "resolved": "https://registry.npmjs.org/chownr/-/chownr-1.1.4.tgz",
-            "integrity": "sha512-jJ0bqzaylmJtVnNgzTeSOs8DPavpbYgEr/b0YL8/2GO3xJEhInFmhKMUnEJQjZumK7KXGFhUy89PrsJWlakBVg==",
-            "license": "ISC",
-            "optional": true
-        },
        "node_modules/color-convert": {
            "version": "2.0.1",
            "resolved": "https://registry.npmjs.org/color-convert/-/color-convert-2.0.1.tgz",
@@ -4721,32 +4652,6 @@
            "dev": true,
            "license": "MIT"
        },
-        "node_modules/decompress-response": {
-            "version": "6.0.0",
-            "resolved": "https://registry.npmjs.org/decompress-response/-/decompress-response-6.0.0.tgz",
-            "integrity": "sha512-aW35yZM6Bb/4oJlZncMH2LCoZtJXTRxES17vE3hoRiowU2kWHaJKFkSBDnDR+cm9J+9QhXmREyIfv0pji9ejCQ==",
-            "license": "MIT",
-            "optional": true,
-            "dependencies": {
-                "mimic-response": "^3.1.0"
-            },
-            "engines": {
-                "node": ">=10"
-            },
-            "funding": {
-                "url": "https://github.com/sponsors/sindresorhus"
-            }
-        },
-        "node_modules/deep-extend": {
-            "version": "0.6.0",
-            "resolved": "https://registry.npmjs.org/deep-extend/-/deep-extend-0.6.0.tgz",
-            "integrity": "sha512-LOHxIOaPYdHlJRtCQfDIVZtfw/ufM8+rVj649RIHzcm/vGwQRXFt6OPqIFWsm2XEMrNIEtWR64sY1LEKD2vAOA==",
-            "license": "MIT",
-            "optional": true,
-            "engines": {
-                "node": ">=4.0.0"
-            }
-        },
        "node_modules/deep-is": {
            "version": "0.1.4",
            "resolved": "https://registry.npmjs.org/deep-is/-/deep-is-0.1.4.tgz",
@@ -4828,7 +4733,7 @@
            "version": "2.1.2",
            "resolved": "https://registry.npmjs.org/detect-libc/-/detect-libc-2.1.2.tgz",
            "integrity": "sha512-Btj2BOOO83o3WyH59e8MgXsxEQVcarkUOpEYrubB0urwnN10yQ364rsiByU11nZlqWYZm05i/of7io4mzihBtQ==",
-            "devOptional": true,
+            "dev": true,
            "license": "Apache-2.0",
            "engines": {
                "node": ">=8"
@@ -4953,16 +4858,6 @@
                "node": ">= 0.8"
            }
        },
-        "node_modules/end-of-stream": {
-            "version": "1.4.5",
-            "resolved": "https://registry.npmjs.org/end-of-stream/-/end-of-stream-1.4.5.tgz",
-            "integrity": "sha512-ooEGc6HP26xXq/N+GCGOT0JKCLDGrq2bQUZrQ7gyrJiZANJ/8YDTxTpQBXGMn+WbIQXNVpyWymm7KYVICQnyOg==",
-            "license": "MIT",
-            "optional": true,
-            "dependencies": {
-                "once": "^1.4.0"
-            }
-        },
        "node_modules/entities": {
            "version": "7.0.1",
            "resolved": "https://registry.npmjs.org/entities/-/entities-7.0.1.tgz",
@@ -5375,16 +5270,6 @@
                "node": ">=0.10.0"
            }
        },
-        "node_modules/expand-template": {
-            "version": "2.0.3",
-            "resolved": "https://registry.npmjs.org/expand-template/-/expand-template-2.0.3.tgz",
-            "integrity": "sha512-XYfuKMvj4O35f/pOXLObndIRvyQ+/+6AhODh+OKWj9S9498pHHn/IMszH+gt0fBCRWMNfk1ZSp5x3AifmnI2vg==",
-            "license": "(MIT OR WTFPL)",
-            "optional": true,
-            "engines": {
-                "node": ">=6"
-            }
-        },
        "node_modules/expect-type": {
            "version": "1.3.0",
            "resolved": "https://registry.npmjs.org/expect-type/-/expect-type-1.3.0.tgz",
@@ -5685,13 +5570,6 @@
                "node": ">=18.3.0"
            }
        },
-        "node_modules/fs-constants": {
-            "version": "1.0.0",
-            "resolved": "https://registry.npmjs.org/fs-constants/-/fs-constants-1.0.0.tgz",
-            "integrity": "sha512-y6OAwoSIf7FyjMIv94u+b5rdheZEjzR63GTyZJm5qh4Bi+2YgwLCcI/fPFZkL5PSixOt6ZNKm+w+Hfp/Bciwow==",
-            "license": "MIT",
-            "optional": true
-        },
        "node_modules/fs-extra": {
            "version": "11.3.5",
            "resolved": "https://registry.npmjs.org/fs-extra/-/fs-extra-11.3.5.tgz",
@@ -5821,13 +5699,6 @@
                "url": "https://github.com/privatenumber/get-tsconfig?sponsor=1"
            }
        },
-        "node_modules/github-from-package": {
-            "version": "0.0.0",
-            "resolved": "https://registry.npmjs.org/github-from-package/-/github-from-package-0.0.0.tgz",
-            "integrity": "sha512-SyHy3T1v2NUXn29OsWdxmK6RwHD+vkj3v8en8AOBZ1wBQ/hCAQ5bAQTD02kW4W9tUp/3Qh6J8r9EvntiyCmOOw==",
-            "license": "MIT",
-            "optional": true
-        },
        "node_modules/glob": {
            "version": "10.5.0",
            "resolved": "https://registry.npmjs.org/glob/-/glob-10.5.0.tgz",
@@ -6296,27 +6167,6 @@
                "node": ">= 14"
            }
        },
-        "node_modules/ieee754": {
-            "version": "1.2.1",
-            "resolved": "https://registry.npmjs.org/ieee754/-/ieee754-1.2.1.tgz",
-            "integrity": "sha512-dcyqhDvX1C46lXZcVqCpK+FtMRQVdIMN6/Df5js2zouUsqG7I6sFxitIC+7KYK29KdXOLHdu9zL4sFnoVQnqaA==",
-            "funding": [
-                {
-                    "type": "github",
-                    "url": "https://github.com/sponsors/feross"
-                },
-                {
-                    "type": "patreon",
-                    "url": "https://www.patreon.com/feross"
-                },
-                {
-                    "type": "consulting",
-                    "url": "https://feross.org/support"
-                }
-            ],
-            "license": "BSD-3-Clause",
-            "optional": true
-        },
        "node_modules/ignore": {
            "version": "5.3.2",
            "resolved": "https://registry.npmjs.org/ignore/-/ignore-5.3.2.tgz",
@@ -6344,18 +6194,11 @@
                "node": ">=0.8.19"
            }
        },
-        "node_modules/inherits": {
-            "version": "2.0.4",
-            "resolved": "https://registry.npmjs.org/inherits/-/inherits-2.0.4.tgz",
-            "integrity": "sha512-k/vGaX4/Yla3WzyMCvTQOXYeIHvqOKtnqBduzTHpzpQZzAskKMhZ2K+EnBiSM9zGSoIFeMpXKxa4dYeZIQqewQ==",
-            "license": "ISC",
-            "optional": true
-        },
        "node_modules/ini": {
            "version": "1.3.8",
            "resolved": "https://registry.npmjs.org/ini/-/ini-1.3.8.tgz",
            "integrity": "sha512-JV/yugV2uzW5iMRSiZAyDtQd+nxtUnjeLt0acNdw98kKLrvuRVyB80tsREOE7yvGVgalhZ6RNXCmEHkUKBKxew==",
-            "devOptional": true,
+            "dev": true,
            "license": "ISC"
        },
        "node_modules/is-docker": {
@@ -6717,25 +6560,6 @@
                "graceful-fs": "^4.1.6"
            }
        },
-        "node_modules/keytar": {
-            "version": "7.9.0",
-            "resolved": "https://registry.npmjs.org/keytar/-/keytar-7.9.0.tgz",
-            "integrity": "sha512-VPD8mtVtm5JNtA2AErl6Chp06JBfy7diFQ7TQQhdpWOl6MrCRB+eRbvAZUsbGQS9kiMq0coJsy0W0vHpDCkWsQ==",
-            "hasInstallScript": true,
-            "license": "MIT",
-            "optional": true,
-            "dependencies": {
-                "node-addon-api": "^4.3.0",
-                "prebuild-install": "^7.0.1"
-            }
-        },
-        "node_modules/keytar/node_modules/node-addon-api": {
-            "version": "4.3.0",
-            "resolved": "https://registry.npmjs.org/node-addon-api/-/node-addon-api-4.3.0.tgz",
-            "integrity": "sha512-73sE9+3UaLYYFmDsFZnqCInzPyh3MqIwZO9cw58yIqAZhONrrabrYyYe3TuIqtIiOuTXVhsGau8hcrhhwSsDIQ==",
-            "license": "MIT",
-            "optional": true
-        },
        "node_modules/keyv": {
            "version": "4.5.4",
            "resolved": "https://registry.npmjs.org/keyv/-/keyv-4.5.4.tgz",
@@ -7466,19 +7290,6 @@
                "node": ">= 0.6"
            }
        },
-        "node_modules/mimic-response": {
-            "version": "3.1.0",
-            "resolved": "https://registry.npmjs.org/mimic-response/-/mimic-response-3.1.0.tgz",
-            "integrity": "sha512-z0yWI+4FDrrweS8Zmt4Ej5HdJmky15+L2e6Wgn3+iK5fWzb6T3fhNFq2+MeTRb064c6Wr4N/wv0DzQTjNzHNGQ==",
-            "license": "MIT",
-            "optional": true,
-            "engines": {
-                "node": ">=10"
-            },
-            "funding": {
-                "url": "https://github.com/sponsors/sindresorhus"
-            }
-        },
        "node_modules/minimatch": {
            "version": "10.2.5",
            "resolved": "https://registry.npmjs.org/minimatch/-/minimatch-10.2.5.tgz",
@@ -7499,7 +7310,7 @@
            "version": "1.2.8",
            "resolved": "https://registry.npmjs.org/minimist/-/minimist-1.2.8.tgz",
            "integrity": "sha512-2yyAR8qBkN3YuheJanUpWC5U3bb5osDywNB8RzDVlDwDHbocAJveqqj1u8+SVD7jkWT4yvsHCpWqqWqAxb0zCA==",
-            "devOptional": true,
+            "dev": true,
            "license": "MIT",
            "funding": {
                "url": "https://github.com/sponsors/ljharb"
@@ -7522,13 +7333,6 @@
            "dev": true,
            "license": "MIT"
        },
-        "node_modules/mkdirp-classic": {
-            "version": "0.5.3",
-            "resolved": "https://registry.npmjs.org/mkdirp-classic/-/mkdirp-classic-0.5.3.tgz",
-            "integrity": "sha512-gKLcREMhtuZRwRAfqP3RFW+TK4JqApVBtOIftVgjuABpAtpxhPGaDcfvbhNvD0B8iD1oUr/txX35NjcaY6Ns/A==",
-            "license": "MIT",
-            "optional": true
-        },
        "node_modules/mri": {
            "version": "1.2.0",
            "resolved": "https://registry.npmjs.org/mri/-/mri-1.2.0.tgz",
@@ -7582,13 +7386,6 @@
                "node": "^10 || ^12 || ^13.7 || ^14 || >=15.0.1"
            }
        },
-        "node_modules/napi-build-utils": {
-            "version": "2.0.0",
-            "resolved": "https://registry.npmjs.org/napi-build-utils/-/napi-build-utils-2.0.0.tgz",
-            "integrity": "sha512-GEbrYkbfF7MoNaoh2iGG84Mnf/WZfB0GdGEsM8wz7Expx/LlWf5U8t9nvJKXSp3qr5IsEbK04cBGhol/KwOsWA==",
-            "license": "MIT",
-            "optional": true
-        },
        "node_modules/natural-compare": {
            "version": "1.4.0",
            "resolved": "https://registry.npmjs.org/natural-compare/-/natural-compare-1.4.0.tgz",
@@ -7596,19 +7393,6 @@
            "dev": true,
            "license": "MIT"
        },
-        "node_modules/node-abi": {
-            "version": "3.92.0",
-            "resolved": "https://registry.npmjs.org/node-abi/-/node-abi-3.92.0.tgz",
-            "integrity": "sha512-KdHvFWZjEKDf0cakgFjebl371GPsISX2oZHcuyKqM7DtogIsHrqKeLTo8wBHxaXRAQlY2PsPlZmfo+9ZCxEREQ==",
-            "license": "MIT",
-            "optional": true,
-            "dependencies": {
-                "semver": "^7.3.5"
-            },
-            "engines": {
-                "node": ">=10"
-            }
-        },
        "node_modules/node-addon-api": {
            "version": "7.1.1",
            "resolved": "https://registry.npmjs.org/node-addon-api/-/node-addon-api-7.1.1.tgz",
@@ -7670,16 +7454,6 @@
                "node": ">= 0.8"
            }
        },
-        "node_modules/once": {
-            "version": "1.4.0",
-            "resolved": "https://registry.npmjs.org/once/-/once-1.4.0.tgz",
-            "integrity": "sha512-lNaJgI+2Q5URQBkccEKHTQOPaXdUxnZZElQTZY0MFUAuaEqe1E+Nyvgdz/aIyNi6Z9MzO5dv1H8n58/GELp3+w==",
-            "license": "ISC",
-            "optional": true,
-            "dependencies": {
-                "wrappy": "1"
-            }
-        },
        "node_modules/oniguruma-parser": {
            "version": "0.12.2",
            "resolved": "https://registry.npmjs.org/oniguruma-parser/-/oniguruma-parser-0.12.2.tgz",
@@ -8069,34 +7843,6 @@
                "url": "https://github.com/sponsors/sindresorhus"
            }
        },
-        "node_modules/prebuild-install": {
-            "version": "7.1.3",
-            "resolved": "https://registry.npmjs.org/prebuild-install/-/prebuild-install-7.1.3.tgz",
-            "integrity": "sha512-8Mf2cbV7x1cXPUILADGI3wuhfqWvtiLA1iclTDbFRZkgRQS0NqsPZphna9V+HyTEadheuPmjaJMsbzKQFOzLug==",
-            "deprecated": "No longer maintained. Please contact the author of the relevant native addon; alternatives are available.",
-            "license": "MIT",
-            "optional": true,
-            "dependencies": {
-                "detect-libc": "^2.0.0",
-                "expand-template": "^2.0.3",
-                "github-from-package": "0.0.0",
-                "minimist": "^1.2.3",
-                "mkdirp-classic": "^0.5.3",
-                "napi-build-utils": "^2.0.0",
-                "node-abi": "^3.3.0",
-                "pump": "^3.0.0",
-                "rc": "^1.2.7",
-                "simple-get": "^4.0.0",
-                "tar-fs": "^2.0.0",
-                "tunnel-agent": "^0.6.0"
-            },
-            "bin": {
-                "prebuild-install": "bin.js"
-            },
-            "engines": {
-                "node": ">=10"
-            }
-        },
        "node_modules/prelude-ls": {
            "version": "1.2.1",
            "resolved": "https://registry.npmjs.org/prelude-ls/-/prelude-ls-1.2.1.tgz",
@@ -8151,17 +7897,6 @@
                "node": ">=10"
            }
        },
-        "node_modules/pump": {
-            "version": "3.0.4",
-            "resolved": "https://registry.npmjs.org/pump/-/pump-3.0.4.tgz",
-            "integrity": "sha512-VS7sjc6KR7e1ukRFhQSY5LM2uBWAUPiOPa/A3mkKmiMwSmRFUITt0xuj+/lesgnCv+dPIEYlkzrcyXgquIHMcA==",
-            "license": "MIT",
-            "optional": true,
-            "dependencies": {
-                "end-of-stream": "^1.1.0",
-                "once": "^1.3.1"
-            }
-        },
        "node_modules/punycode": {
            "version": "2.3.1",
            "resolved": "https://registry.npmjs.org/punycode/-/punycode-2.3.1.tgz",
@@ -8203,47 +7938,6 @@
            ],
            "license": "MIT"
        },
-        "node_modules/rc": {
-            "version": "1.2.8",
-            "resolved": "https://registry.npmjs.org/rc/-/rc-1.2.8.tgz",
-            "integrity": "sha512-y3bGgqKj3QBdxLbLkomlohkvsA8gdAiUQlSBJnBhfn+BPxg4bc62d8TcBW15wavDfgexCgccckhcZvywyQYPOw==",
-            "license": "(BSD-2-Clause OR MIT OR Apache-2.0)",
-            "optional": true,
-            "dependencies": {
-                "deep-extend": "^0.6.0",
-                "ini": "~1.3.0",
-                "minimist": "^1.2.0",
-                "strip-json-comments": "~2.0.1"
-            },
-            "bin": {
-                "rc": "cli.js"
-            }
-        },
-        "node_modules/rc/node_modules/strip-json-comments": {
-            "version": "2.0.1",
-            "resolved": "https://registry.npmjs.org/strip-json-comments/-/strip-json-comments-2.0.1.tgz",
-            "integrity": "sha512-4gB8na07fecVVkOI6Rs4e7T6NOTki5EmL7TUduTs6bu3EdnSycntVJ4re8kgZA+wx9IueI2Y11bfbgwtzuE0KQ==",
-            "license": "MIT",
-            "optional": true,
-            "engines": {
-                "node": ">=0.10.0"
-            }
-        },
-        "node_modules/readable-stream": {
-            "version": "3.6.2",
-            "resolved": "https://registry.npmjs.org/readable-stream/-/readable-stream-3.6.2.tgz",
-            "integrity": "sha512-9u/sniCrY3D5WdsERHzHE4G2YCXqoG5FTHUiCC4SIbr6XcLZBY05ya9EKjYek9O5xOAwjGq+1JdGBAS7Q9ScoA==",
-            "license": "MIT",
-            "optional": true,
-            "dependencies": {
-                "inherits": "^2.0.3",
-                "string_decoder": "^1.1.1",
-                "util-deprecate": "^1.0.1"
-            },
-            "engines": {
-                "node": ">= 6"
-            }
-        },
        "node_modules/readdirp": {
            "version": "4.1.2",
            "resolved": "https://registry.npmjs.org/readdirp/-/readdirp-4.1.2.tgz",
@@ -8628,27 +8322,6 @@
                "node": ">=6"
            }
        },
-        "node_modules/safe-buffer": {
-            "version": "5.2.1",
-            "resolved": "https://registry.npmjs.org/safe-buffer/-/safe-buffer-5.2.1.tgz",
-            "integrity": "sha512-rp3So07KcdmmKbGvgaNxQSJr7bGVSVk5S9Eq1F+ppbRo70+YeaDxkw5Dd8NPN+GD6bjnYm2VuPuCXmpuYvmCXQ==",
-            "funding": [
-                {
-                    "type": "github",
-                    "url": "https://github.com/sponsors/feross"
-                },
-                {
-                    "type": "patreon",
-                    "url": "https://www.patreon.com/feross"
-                },
-                {
-                    "type": "consulting",
-                    "url": "https://feross.org/support"
-                }
-            ],
-            "license": "MIT",
-            "optional": true
-        },
        "node_modules/sass": {
            "version": "1.99.0",
            "resolved": "https://registry.npmjs.org/sass/-/sass-1.99.0.tgz",
@@ -9058,7 +8731,7 @@
            "version": "7.7.4",
            "resolved": "https://registry.npmjs.org/semver/-/semver-7.7.4.tgz",
            "integrity": "sha512-vFKC2IEtQnVhpT78h1Yp8wzwrf8CM+MzKMHGJZfBtzhZNycRFnXsHk6E5TxIkkMsgNS7mdX3AGB7x2QM2di4lA==",
-            "devOptional": true,
+            "dev": true,
            "license": "ISC",
            "bin": {
                "semver": "bin/semver.js"
@@ -9140,53 +8813,6 @@
                "url": "https://github.com/sponsors/isaacs"
            }
        },
-        "node_modules/simple-concat": {
-            "version": "1.0.1",
-            "resolved": "https://registry.npmjs.org/simple-concat/-/simple-concat-1.0.1.tgz",
-            "integrity": "sha512-cSFtAPtRhljv69IK0hTVZQ+OfE9nePi/rtJmw5UjHeVyVroEqJXP1sFztKUy1qU+xvz3u/sfYJLa947b7nAN2Q==",
-            "funding": [
-                {
-                    "type": "github",
-                    "url": "https://github.com/sponsors/feross"
-                },
-                {
-                    "type": "patreon",
-                    "url": "https://www.patreon.com/feross"
-                },
-                {
-                    "type": "consulting",
-                    "url": "https://feross.org/support"
-                }
-            ],
-            "license": "MIT",
-            "optional": true
-        },
-        "node_modules/simple-get": {
-            "version": "4.0.1",
-            "resolved": "https://registry.npmjs.org/simple-get/-/simple-get-4.0.1.tgz",
-            "integrity": "sha512-brv7p5WgH0jmQJr1ZDDfKDOSeWWg+OVypG99A/5vYGPqJ6pxiaHLy8nxtFjBA7oMa01ebA9gfh1uMCFqOuXxvA==",
-            "funding": [
-                {
-                    "type": "github",
-                    "url": "https://github.com/sponsors/feross"
-                },
-                {
-                    "type": "patreon",
-                    "url": "https://www.patreon.com/feross"
-                },
-                {
-                    "type": "consulting",
-                    "url": "https://feross.org/support"
-                }
-            ],
-            "license": "MIT",
-            "optional": true,
-            "dependencies": {
-                "decompress-response": "^6.0.0",
-                "once": "^1.3.1",
-                "simple-concat": "^1.0.0"
-            }
-        },
        "node_modules/sirv": {
            "version": "3.0.2",
            "resolved": "https://registry.npmjs.org/sirv/-/sirv-3.0.2.tgz",
@@ -9307,16 +8933,6 @@
            "dev": true,
            "license": "MIT"
        },
-        "node_modules/string_decoder": {
-            "version": "1.3.0",
-            "resolved": "https://registry.npmjs.org/string_decoder/-/string_decoder-1.3.0.tgz",
-            "integrity": "sha512-hkRX8U1WjJFd8LsDJ2yQ/wWWxaopEsABU1XfkM8A+j0+85JAGppt16cr1Whg6KIbb4okU6Mql6BOj+uup/wKeA==",
-            "license": "MIT",
-            "optional": true,
-            "dependencies": {
-                "safe-buffer": "~5.2.0"
-            }
-        },
        "node_modules/string-width": {
            "version": "4.2.3",
            "resolved": "https://registry.npmjs.org/string-width/-/string-width-4.2.3.tgz",
@@ -9479,36 +9095,6 @@
                "node": ">=16.0.0"
            }
        },
-        "node_modules/tar-fs": {
-            "version": "2.1.4",
-            "resolved": "https://registry.npmjs.org/tar-fs/-/tar-fs-2.1.4.tgz",
-            "integrity": "sha512-mDAjwmZdh7LTT6pNleZ05Yt65HC3E+NiQzl672vQG38jIrehtJk/J3mNwIg+vShQPcLF/LV7CMnDW6vjj6sfYQ==",
-            "license": "MIT",
-            "optional": true,
-            "dependencies": {
-                "chownr": "^1.1.1",
-                "mkdirp-classic": "^0.5.2",
-                "pump": "^3.0.0",
-                "tar-stream": "^2.1.4"
-            }
-        },
-        "node_modules/tar-stream": {
-            "version": "2.2.0",
-            "resolved": "https://registry.npmjs.org/tar-stream/-/tar-stream-2.2.0.tgz",
-            "integrity": "sha512-ujeqbceABgwMZxEJnk2HDY2DlnUZ+9oEcb1KzTVfYHio0UE6dG71n60d8D2I4qNvleWrrXpmjpt7vZeF1LnMZQ==",
-            "license": "MIT",
-            "optional": true,
-            "dependencies": {
-                "bl": "^4.0.3",
-                "end-of-stream": "^1.4.1",
-                "fs-constants": "^1.0.0",
-                "inherits": "^2.0.3",
-                "readable-stream": "^3.1.1"
-            },
-            "engines": {
-                "node": ">=6"
-            }
-        },
        "node_modules/tinybench": {
            "version": "2.9.0",
            "resolved": "https://registry.npmjs.org/tinybench/-/tinybench-2.9.0.tgz",
@@ -9653,19 +9239,6 @@
            "dev": true,
            "license": "0BSD"
        },
-        "node_modules/tunnel-agent": {
-            "version": "0.6.0",
-            "resolved": "https://registry.npmjs.org/tunnel-agent/-/tunnel-agent-0.6.0.tgz",
-            "integrity": "sha512-McnNiV1l8RYeY8tBgEpuodCC1mLUdbSN+CYBL7kJsJNInOP8UjDDEwdk6Mw60vdLLrr5NHKZhMAOSrR2NZuQ+w==",
-            "license": "Apache-2.0",
-            "optional": true,
-            "dependencies": {
-                "safe-buffer": "^5.0.1"
-            },
-            "engines": {
-                "node": "*"
-            }
-        },
        "node_modules/type-check": {
            "version": "0.4.0",
            "resolved": "https://registry.npmjs.org/type-check/-/type-check-0.4.0.tgz",
@@ -9882,7 +9455,7 @@
            "version": "1.0.2",
            "resolved": "https://registry.npmjs.org/util-deprecate/-/util-deprecate-1.0.2.tgz",
            "integrity": "sha512-EPD5q1uXyFxJpCrLnCc1nHnq3gOa6DZBocAIiI2TaSCA7VCJ1UJDMagCzIkXNsUYfD1daK//LTEQ8xiIbrHtcw==",
-            "devOptional": true,
+            "dev": true,
            "license": "MIT"
        },
        "node_modules/utils-merge": {
@@ -10533,13 +10106,6 @@
                "url": "https://github.com/chalk/wrap-ansi?sponsor=1"
            }
        },
-        "node_modules/wrappy": {
-            "version": "1.0.2",
-            "resolved": "https://registry.npmjs.org/wrappy/-/wrappy-1.0.2.tgz",
-            "integrity": "sha512-l4Sp/DRseor9wL6EvV2+TuQn63dMkPjZ/sp9XkghTEbV9KlPS1xUsZ3u7/IQO4wxtcFB4bgpQPRcR3QCvezPcQ==",
-            "license": "ISC",
-            "optional": true
-        },
        "node_modules/ws": {
            "version": "8.20.0",
            "resolved": "https://registry.npmjs.org/ws/-/ws-8.20.0.tgz",
@@ -51,8 +51,5 @@
    },
    "dependencies": {
        "lucide-vue-next": "^1.0.0"
-    },
-    "optionalDependencies": {
-        "keytar": "^7.9.0"
    }
 }
@@ -0,0 +1,102 @@
+<?php
+
+declare(strict_types=1);
+
+use App\Models\Deal;
+use App\Models\Project;
+use App\Models\SupplierLead;
+use App\Models\Tenant;
+use Illuminate\Foundation\Testing\DatabaseTransactions;
+use Illuminate\Support\Facades\DB;
+use Tests\Concerns\SharesSupplierPdo;
+
+uses(DatabaseTransactions::class);
+uses(SharesSupplierPdo::class);
+
+beforeEach(function (): void {
+    DB::statement("SELECT set_config('app.current_tenant_id', '0', true)");
+});
+
+/**
+ * Сеет сделку (city=NULL по умолчанию) + лид с resolved_subject_code + связь
+ * supplier_lead_deliveries. Возвращает [tenantId, dealId].
+ *
+ * @return array{0: int, 1: int}
+ */
+function seedDealWithResolvedLead(?int $resolvedCode, ?string $city = null): array
+{
+    $tenant = Tenant::factory()->create(['balance_rub' => '100000.00']);
+    $project = Project::factory()->create([
+        'tenant_id' => $tenant->id,
+        'signal_type' => 'site',
+        'signal_identifier' => 'backfill-city.ru',
+        'is_active' => true,
+    ]);
+
+    DB::statement("SET LOCAL app.current_tenant_id = '{$tenant->id}'");
+    $deal = Deal::create([
+        'tenant_id' => $tenant->id,
+        'project_id' => $project->id,
+        'phone' => '79161234567',
+        'phones' => ['79161234567'],
+        'status' => 'new',
+        'received_at' => now(),
+        'subject_code' => $resolvedCode,
+        'city' => $city,
+    ]);
+    DB::statement("SELECT set_config('app.current_tenant_id', '0', true)");
+
+    $lead = SupplierLead::factory()->create([
+        'platform' => 'B1',
+        'phone' => '79161234567',
+        'resolved_subject_code' => $resolvedCode,
+        'region_source' => $resolvedCode !== null ? 'dadata' : 'unknown',
+    ]);
+
+    DB::connection('pgsql_supplier')->table('supplier_lead_deliveries')->insert([
+        'supplier_lead_id' => $lead->id,
+        'tenant_id' => $tenant->id,
+        'deal_id' => $deal->id,
+        'created_at' => now(),
+    ]);
+
+    return [$tenant->id, $deal->id];
+}
+
+function dealCity(int $dealId): ?string
+{
+    // BYPASSRLS чтение (как и сам бэкфилл) — без tenant-контекста.
+    return DB::connection('pgsql_supplier')->table('deals')->where('id', $dealId)->value('city');
+}
+
+it('backfills deal city from the lead resolved region code', function (): void {
+    [, $dealId] = seedDealWithResolvedLead(29); // 29 → Красноярский край
+
+    $this->artisan('deals:backfill-region-city')->assertSuccessful();
+
+    expect(dealCity($dealId))->toBe('Красноярский край');
+});
+
+it('does not touch deals that already have a city', function (): void {
+    [, $dealId] = seedDealWithResolvedLead(29, city: 'Уже стоит');
+
+    $this->artisan('deals:backfill-region-city')->assertSuccessful();
+
+    expect(dealCity($dealId))->toBe('Уже стоит');
+});
+
+it('dry-run reports candidates without writing', function (): void {
+    [, $dealId] = seedDealWithResolvedLead(29);
+
+    $this->artisan('deals:backfill-region-city', ['--dry-run' => true])->assertSuccessful();
+
+    expect(dealCity($dealId))->toBeNull();
+});
+
+it('leaves city null when the lead has no resolved region', function (): void {
+    [, $dealId] = seedDealWithResolvedLead(null);
+
+    $this->artisan('deals:backfill-region-city')->assertSuccessful();
+
+    expect(dealCity($dealId))->toBeNull();
+});
@@ -0,0 +1,110 @@
+<?php
+
+declare(strict_types=1);
+
+use Illuminate\Foundation\Testing\DatabaseTransactions;
+use Illuminate\Support\Facades\DB;
+use Tests\Concerns\SharesSupplierPdo;
+
+uses(DatabaseTransactions::class);
+uses(SharesSupplierPdo::class);
+
+function rossvyazFixture(): string
+{
+    return base_path('tests/Fixtures/rossvyaz/sample.csv');
+}
+
+it('dry-run parses csv, maps regions to subject_code, builds staging, does not swap', function (): void {
+    $this->artisan('phone-ranges:import', ['--file' => rossvyazFixture(), '--dry-run' => true])
+        ->assertSuccessful();
+
+    // Staging построен (dry-run не свапает и не дропает staging — данные видны в той же tx).
+    expect(DB::table('phone_ranges_staging')->count())->toBe(3);
+
+    $r495 = DB::selectOne('SELECT subject_code FROM phone_ranges_staging WHERE def_code = 495');
+    $r921 = DB::selectOne('SELECT subject_code FROM phone_ranges_staging WHERE def_code = 921');
+    $r999 = DB::selectOne('SELECT subject_code FROM phone_ranges_staging WHERE def_code = 999');
+
+    expect((int) $r495->subject_code)->toBe(82)   // Москва
+        ->and((int) $r921->subject_code)->toBe(83) // Санкт-Петербург
+        ->and($r999->subject_code)->toBeNull();    // Атлантида — не маппится
+
+    // Живой phone_ranges не тронут (свапа не было).
+    expect(DB::table('phone_ranges')->count())->toBe(0);
+
+    // Журнал импорта: dry-run → rolled_back, несматчившийся регион в error.
+    $imp = DB::table('phone_ranges_imports')->orderByDesc('id')->first();
+    expect($imp->status)->toBe('rolled_back')
+        ->and($imp->error)->toContain('Атлантида');
+});
+
+it('maps all matched rows and counts unmatched separately', function (): void {
+    $this->artisan('phone-ranges:import', ['--file' => rossvyazFixture(), '--dry-run' => true])
+        ->assertSuccessful();
+
+    $matched = DB::table('phone_ranges_staging')->whereNotNull('subject_code')->count();
+    $unmatched = DB::table('phone_ranges_staging')->whereNull('subject_code')->count();
+
+    expect($matched)->toBe(2)->and($unmatched)->toBe(1);
+});
+
+it('skips swap when checksum matches a completed import (idempotency)', function (): void {
+    $checksum = hash_file('sha256', rossvyazFixture());
+    DB::table('phone_ranges_imports')->insert([
+        'source_url' => 'https://rossvyaz.gov.ru/prev',
+        'checksum_sha256' => $checksum,
+        'status' => 'completed',
+        'imported_at' => now(),
+        'completed_at' => now(),
+    ]);
+
+    // Не dry-run: но checksum совпал с completed → короткое замыкание ДО свапа.
+    $this->artisan('phone-ranges:import', ['--file' => rossvyazFixture()])
+        ->assertSuccessful();
+
+    expect(DB::table('phone_ranges')->count())->toBe(0); // свапа не было
+
+    $latest = DB::table('phone_ranges_imports')->orderByDesc('id')->first();
+    expect($latest->status)->toBe('rolled_back');
+});
+
+it('force flag bypasses idempotency note even with matching checksum', function (): void {
+    // С --dry-run + --force: идемпотентность игнорируется, но dry-run всё равно не свапает.
+    $checksum = hash_file('sha256', rossvyazFixture());
+    DB::table('phone_ranges_imports')->insert([
+        'source_url' => 'https://rossvyaz.gov.ru/prev',
+        'checksum_sha256' => $checksum,
+        'status' => 'completed',
+        'imported_at' => now(),
+        'completed_at' => now(),
+    ]);
+
+    $this->artisan('phone-ranges:import', ['--file' => rossvyazFixture(), '--dry-run' => true, '--force' => true])
+        ->assertSuccessful();
+
+    // --force обошёл idempotency → staging построен заново (3 строки), но dry-run не свапнул.
+    expect(DB::table('phone_ranges_staging')->count())->toBe(3);
+    expect(DB::table('phone_ranges')->count())->toBe(0);
+});
+
+it('normalizes real Россвязь region formats to subject_code and fills region_normalized', function (): void {
+    // Форматы из реального прод-реестра (топ unmapped 02.06.2026): префикс «г. »,
+    // pipe-сегмент региона, сокращение «обл.», перевёрнутая «Республика Удмуртская»,
+    // и безнадёжный city-only «г.о. Тольятти». def-коды 3-значные (chk_phone_ranges_def_code 300-999).
+    $this->artisan('phone-ranges:import', ['--file' => base_path('tests/Fixtures/rossvyaz/messy.csv'), '--dry-run' => true])
+        ->assertSuccessful();
+
+    $moscow = DB::selectOne('SELECT subject_code, region_normalized FROM phone_ranges_staging WHERE def_code = 495');
+    $orenburg = DB::selectOne('SELECT subject_code, region_normalized FROM phone_ranges_staging WHERE def_code = 922');
+    $udmurtia = DB::selectOne('SELECT subject_code, region_normalized FROM phone_ranges_staging WHERE def_code = 987');
+    $togliatti = DB::selectOne('SELECT subject_code, region_normalized FROM phone_ranges_staging WHERE def_code = 902');
+
+    expect((int) $moscow->subject_code)->toBe(82)
+        ->and($moscow->region_normalized)->toBe('Москва')
+        ->and((int) $orenburg->subject_code)->toBe(62)
+        ->and($orenburg->region_normalized)->toBe('Оренбургская область')
+        ->and((int) $udmurtia->subject_code)->toBe(21)
+        ->and($udmurtia->region_normalized)->toBe('Удмуртская Республика')
+        ->and($togliatti->subject_code)->toBeNull()
+        ->and($togliatti->region_normalized)->toBeNull();
+});
@@ -0,0 +1,38 @@
+<?php
+
+declare(strict_types=1);
+
+use Illuminate\Foundation\Testing\DatabaseTransactions;
+use Illuminate\Support\Facades\DB;
+use Illuminate\Support\Facades\Http;
+use Tests\Concerns\SharesSupplierPdo;
+
+uses(DatabaseTransactions::class);
+uses(SharesSupplierPdo::class);
+
+beforeEach(function (): void {
+    config([
+        'services.dadata.api_key' => 'k',
+        'services.dadata.secret' => 's',
+        'services.dadata.daily_cap_rub' => 100000,
+    ]);
+});
+
+it('phone-region:smoke prints the resolution and writes nothing to DB', function (): void {
+    Http::fake(['cleaner.dadata.ru/*' => Http::response([[
+        'qc' => 0, 'region' => 'Москва', 'provider' => 'МТС',
+    ]], 200)]);
+
+    $this->artisan('phone-region:smoke', ['--phone' => '79161234567'])
+        ->assertSuccessful()
+        ->expectsOutputToContain('dadata')
+        ->expectsOutputToContain('Москва');
+
+    // Smoke не пишет в БД.
+    expect(DB::table('lead_region_resolution_log')->count())->toBe(0);
+    expect(DB::table('deals')->count())->toBe(0);
+});
+
+it('phone-region:smoke fails without --phone', function (): void {
+    $this->artisan('phone-region:smoke')->assertFailed();
+});
@@ -0,0 +1,229 @@
+<?php
+
+declare(strict_types=1);
+
+use App\Jobs\RouteSupplierLeadJob;
+use App\Models\Deal;
+use App\Models\Project;
+use App\Models\SupplierLead;
+use App\Models\SupplierProject;
+use App\Models\Tenant;
+use App\Services\Billing\LedgerService;
+use App\Services\LeadDistributor;
+use App\Services\LeadRouter;
+use App\Services\NotificationService;
+use App\Services\RegionTagResolver;
+use App\Services\SupplierProjects\SupplierProjectResolver;
+use Database\Seeders\PricingTierSeeder;
+use Illuminate\Foundation\Testing\DatabaseTransactions;
+use Illuminate\Support\Facades\DB;
+use Illuminate\Support\Facades\Http;
+use Tests\Concerns\SharesSupplierPdo;
+
+uses(DatabaseTransactions::class);
+uses(SharesSupplierPdo::class);
+
+beforeEach(function (): void {
+    $this->seed(PricingTierSeeder::class);
+    DB::statement("SELECT set_config('app.current_tenant_id', '0', true)");
+    config([
+        'services.dadata.enabled' => true,
+        'services.dadata.api_key' => 'k',
+        'services.dadata.secret' => 's',
+        'services.dadata.daily_cap_rub' => 100000,
+    ]);
+});
+
+function runRegionJob(int $supplierLeadId): void
+{
+    (new RouteSupplierLeadJob($supplierLeadId))->handle(
+        app(LeadRouter::class),
+        app(SupplierProjectResolver::class),
+        app(NotificationService::class),
+        app(LedgerService::class),
+        app(LeadDistributor::class),
+        app(RegionTagResolver::class),
+    );
+}
+
+/**
+ * Создаёт маршрутизируемый лид: supplier B1 site + tenant с балансом + project + snapshot.
+ *
+ * @return array{0: SupplierLead, 1: Project, 2: Tenant, 3: SupplierProject}
+ */
+function seedRoutableLead(string $regions, string $tag, string $phone, string $key = 'vashinvestor.ru'): array
+{
+    $supplier = SupplierProject::factory()->create([
+        'platform' => 'B1', 'signal_type' => 'site', 'unique_key' => $key,
+    ]);
+    $tenant = Tenant::factory()->create(['balance_rub' => '100000.00']);
+    $project = Project::factory()->create([
+        'tenant_id' => $tenant->id,
+        'signal_type' => 'site', 'signal_identifier' => $key,
+        'is_active' => true, 'delivered_today' => 0, 'delivered_in_month' => 0,
+        'daily_limit_target' => 100,
+    ]);
+    linkProjectToSupplier($project, $supplier);
+    createRoutingSnapshotFromProject($project, dailyLimit: 100, regions: $regions);
+
+    $vid = 432176649;
+    $lead = SupplierLead::factory()->create([
+        'supplier_project_id' => null,
+        'platform' => 'B1',
+        'vid' => $vid,
+        'phone' => $phone,
+        'received_at' => now(),
+        'raw_payload' => [
+            'vid' => $vid, 'project' => "B1_{$key}", 'tag' => $tag,
+            'phone' => $phone, 'phones' => [$phone], 'time' => now()->getTimestamp(),
+        ],
+    ]);
+
+    return [$lead, $project, $tenant, $supplier];
+}
+
+function dealFor(int $tenantId, int $projectId): ?Deal
+{
+    DB::statement("SET LOCAL app.current_tenant_id = '{$tenantId}'");
+    $deal = Deal::query()->where('project_id', $projectId)->first();
+    DB::statement("SELECT set_config('app.current_tenant_id', '0', true)");
+
+    return $deal;
+}
+
+it('lead with phone uses dadata region, not the tag', function (): void {
+    Http::fake(['cleaner.dadata.ru/*' => Http::response([[
+        'qc' => 0, 'region' => 'Москва', 'provider' => 'МТС', 'type' => 'Мобильный', 'phone' => '+7 916 123-45-67',
+    ]], 200)]);
+    // tag='Санкт-Петербург' (дал бы 83), но телефон резолвится в Москву (82).
+    [$lead, $project, $tenant] = seedRoutableLead(regions: '{82}', tag: 'Санкт-Петербург', phone: '79161234567');
+
+    runRegionJob($lead->id);
+
+    $lead->refresh();
+    expect($lead->resolved_subject_code)->toBe(82)
+        ->and($lead->region_source)->toBe('dadata')
+        ->and($lead->phone_operator)->toBe('МТС');
+
+    $deal = dealFor($tenant->id, $project->id);
+    expect($deal)->not->toBeNull()
+        ->and((int) $deal->subject_code)->toBe(82)        // регион из DaData, не из тега (83)
+        ->and((bool) $deal->region_substituted)->toBeFalse()
+        ->and($deal->phone_operator)->toBe('МТС');
+});
+
+it('logs exactly one region resolution row per lead', function (): void {
+    Http::fake(['cleaner.dadata.ru/*' => Http::response([[
+        'qc' => 0, 'region' => 'Москва', 'provider' => 'МТС',
+    ]], 200)]);
+    [$lead] = seedRoutableLead(regions: '{82}', tag: 'tag', phone: '79161234567');
+
+    runRegionJob($lead->id);
+
+    $rows = DB::table('lead_region_resolution_log')->where('supplier_lead_id', $lead->id)->get();
+    expect($rows)->toHaveCount(1);
+    expect($rows->first()->region_source)->toBe('dadata');
+    // Телефон в логе маскирован (не сырой номер) — §7.1.
+    expect($rows->first()->phone_masked)->not->toBe('79161234567');
+});
+
+it('lead with invalid phone falls back to tag', function (): void {
+    Http::fake(['cleaner.dadata.ru/*' => Http::response([['qc' => 0, 'region' => 'Москва']], 200)]);
+    // Невалидный телефон → DaData не дёргается → tag (Москва=82).
+    [$lead, $project, $tenant] = seedRoutableLead(regions: '{82}', tag: 'Москва', phone: '123');
+
+    runRegionJob($lead->id);
+
+    $lead->refresh();
+    expect($lead->region_source)->toBe('tag')->and($lead->resolved_subject_code)->toBe(82);
+    Http::assertNothingSent();
+});
+
+it('lead with resolver disabled via flag uses tag', function (): void {
+    config(['services.dadata.enabled' => false]);
+    Http::fake(['cleaner.dadata.ru/*' => Http::response([['qc' => 0, 'region' => 'Москва']], 200)]);
+    [$lead, $project, $tenant] = seedRoutableLead(regions: '{82}', tag: 'Москва', phone: '79161234567');
+
+    runRegionJob($lead->id);
+
+    $lead->refresh();
+    expect($lead->region_source)->toBe('tag')->and($lead->resolved_subject_code)->toBe(82);
+    Http::assertNothingSent();
+});
+
+it('persistent idempotency: pre-resolved lead does not re-call dadata', function (): void {
+    Http::fake(['cleaner.dadata.ru/*' => Http::response([['qc' => 0, 'region' => 'Москва', 'provider' => 'МТС']], 200)]);
+    [$lead, $project, $tenant] = seedRoutableLead(regions: '{83}', tag: 'tag', phone: '79161234567');
+    // Эмулируем предыдущий try: резолв уже персистнут.
+    $lead->update(['resolved_subject_code' => 83, 'region_source' => 'rossvyaz', 'phone_operator' => 'МегаФон']);
+
+    runRegionJob($lead->id);
+
+    Http::assertNothingSent(); // §3.11 — нет двойной оплаты DaData
+    $lead->refresh();
+    expect($lead->resolved_subject_code)->toBe(83)->and($lead->region_source)->toBe('rossvyaz');
+});
+
+it('step-3 fallback substitutes subject_code to client region and flags region_substituted', function (): void {
+    Http::fake(['cleaner.dadata.ru/*' => Http::response([[
+        'qc' => 0, 'region' => 'Москва', 'provider' => 'МТС',
+    ]], 200)]);
+    // Лид по Москве (82), но клиент подписан только на Питер (83): точных нет, «вся РФ» нет → шаг 3.
+    [$lead, $project, $tenant] = seedRoutableLead(regions: '{83}', tag: 'tag', phone: '79161234567');
+
+    runRegionJob($lead->id);
+
+    $deal = dealFor($tenant->id, $project->id);
+    expect($deal)->not->toBeNull()
+        ->and((int) $deal->subject_code)->toBe(83)         // подменён на регион клиента (Питер)
+        ->and((bool) $deal->region_substituted)->toBeTrue();
+
+    // Настоящий регион (Москва=82) сохранён в журнале как actual_subject_code.
+    $log = DB::table('lead_region_resolution_log')->where('supplier_lead_id', $lead->id)->first();
+    expect((int) $log->actual_subject_code)->toBe(82)
+        ->and((int) $log->substituted_subject_code)->toBe(83);
+});
+
+it('csv-merge updates subject_code and operator when webhook resolution outranks tag (dadata)', function (): void {
+    Http::fake(['cleaner.dadata.ru/*' => Http::response([['qc' => 0, 'region' => 'Москва', 'provider' => 'МТС']], 200)]);
+    [$lead, $project, $tenant] = seedRoutableLead(regions: '{82}', tag: 'tag', phone: '79161234567');
+
+    // CSV-recovered сделка: source_crm_id=null, регион из тега «неправильный» (53 = ЛО).
+    DB::statement("SET LOCAL app.current_tenant_id = '{$tenant->id}'");
+    $csvDeal = Deal::create([
+        'tenant_id' => $tenant->id, 'source_crm_id' => null, 'project_id' => $project->id,
+        'phone' => '79161234567', 'phones' => ['79161234567'], 'status' => 'new',
+        'received_at' => now(), 'subject_code' => 53,
+    ]);
+    DB::statement("SELECT set_config('app.current_tenant_id', '0', true)");
+
+    runRegionJob($lead->id);
+
+    $merged = dealFor($tenant->id, $project->id);
+    expect((int) $merged->id)->toBe($csvDeal->id)            // merge в существующую, не новая
+        ->and((int) $merged->subject_code)->toBe(82)         // обновлено DaData (82) поверх tag (53)
+        ->and($merged->phone_operator)->toBe('МТС')
+        ->and((int) $merged->source_crm_id)->toBe($lead->vid);
+
+    DB::statement("SET LOCAL app.current_tenant_id = '{$tenant->id}'");
+    expect(Deal::query()->where('project_id', $project->id)->count())->toBe(1); // второй сделки нет
+    DB::statement("SELECT set_config('app.current_tenant_id', '0', true)");
+});
+
+it('csv-merge does not overwrite subject_code when webhook resolution is tag-level', function (): void {
+    config(['services.dadata.enabled' => false]); // резолвер выключен → source='tag' (rank не выше CSV-tag)
+    [$lead, $project, $tenant] = seedRoutableLead(regions: '{82}', tag: 'Москва', phone: '79161234567');
+
+    DB::statement("SET LOCAL app.current_tenant_id = '{$tenant->id}'");
+    Deal::create([
+        'tenant_id' => $tenant->id, 'source_crm_id' => null, 'project_id' => $project->id,
+        'phone' => '79161234567', 'phones' => ['79161234567'], 'status' => 'new',
+        'received_at' => now(), 'subject_code' => 53,
+    ]);
+    DB::statement("SELECT set_config('app.current_tenant_id', '0', true)");
+
+    runRegionJob($lead->id);
+
+    $merged = dealFor($tenant->id, $project->id);
+    expect((int) $merged->subject_code)->toBe(53); // tag не выше tag → регион не тронут
+});
@@ -631,3 +631,35 @@ it('merges webhook into csv-recovered deal even when received_at differs (Phase
    // Никаких дублей deals — только один с этим vid.
    expect(Deal::query()->where('source_crm_id', $webhookVid)->count())->toBe(1);
 });
+
+it('fills deal city with the resolved region name (UI «Город» column)', function (): void {
+    \Illuminate\Support\Facades\Http::fake(['cleaner.dadata.ru/*' => \Illuminate\Support\Facades\Http::response([[
+        'qc' => 0, 'region' => 'Москва', 'provider' => 'МТС',
+    ]], 200)]);
+    config([
+        'services.dadata.enabled' => true,
+        'services.dadata.api_key' => 'k',
+        'services.dadata.secret' => 's',
+        'services.dadata.daily_cap_rub' => 100000,
+    ]);
+    [$lead, $project, $tenant] = seedRoutableLead(regions: '{82}', tag: 'tag', phone: '79161234567');
+
+    runRouteJob($lead->id);
+
+    // deals.city = имя субъекта (RussianRegions::CODE_TO_NAME) по резолву: 82 → «Москва».
+    $deal = dealFor($tenant->id, $project->id);
+    expect($deal)->not->toBeNull()
+        ->and($deal->city)->toBe('Москва');
+});
+
+it('leaves deal city null when region is unknown', function (): void {
+    config(['services.dadata.enabled' => false]);
+    // Нераспознанный тег + невалидный телефон → subjectCode null → city пустой.
+    [$lead, $project, $tenant] = seedRoutableLead(regions: '{82}', tag: 'нераспознаваемый-тег-zzz', phone: '123');
+
+    runRouteJob($lead->id);
+
+    $deal = dealFor($tenant->id, $project->id);
+    expect($deal)->not->toBeNull()
+        ->and($deal->city)->toBeNull();
+});
@@ -0,0 +1,51 @@
+<?php
+
+declare(strict_types=1);
+
+use Illuminate\Support\Facades\DB;
+use Tests\Concerns\SharesSupplierPdo;
+
+uses(SharesSupplierPdo::class);
+
+it('creates phone_ranges with lookup columns', function (): void {
+    expect(DB::selectOne("SELECT to_regclass('public.phone_ranges') AS t")->t)->not->toBeNull();
+
+    $cols = collect(DB::select("SELECT column_name FROM information_schema.columns WHERE table_name = 'phone_ranges'"))
+        ->pluck('column_name')->all();
+
+    expect($cols)->toContain('def_code', 'from_num', 'to_num', 'operator', 'region', 'subject_code', 'import_id');
+});
+
+it('creates phone_ranges_imports journal table', function (): void {
+    expect(DB::selectOne("SELECT to_regclass('public.phone_ranges_imports') AS t")->t)->not->toBeNull();
+
+    $cols = collect(DB::select("SELECT column_name FROM information_schema.columns WHERE table_name = 'phone_ranges_imports'"))
+        ->pluck('column_name')->all();
+
+    expect($cols)->toContain('source_url', 'checksum_sha256', 'status', 'rows_inserted', 'rows_updated');
+});
+
+it('creates lead_region_resolution_log as a partitioned table', function (): void {
+    $partitioned = DB::selectOne(
+        "SELECT 1 AS ok
+         FROM pg_partitioned_table pt
+         JOIN pg_class c ON c.oid = pt.partrelid
+         WHERE c.relname = 'lead_region_resolution_log'"
+    );
+
+    expect($partitioned)->not->toBeNull();
+});
+
+it('adds resolution columns to supplier_leads', function (): void {
+    $cols = collect(DB::select("SELECT column_name FROM information_schema.columns WHERE table_name = 'supplier_leads'"))
+        ->pluck('column_name')->all();
+
+    expect($cols)->toContain('resolved_subject_code', 'region_source', 'dadata_qc', 'phone_operator');
+});
+
+it('adds resolution columns to deals', function (): void {
+    $cols = collect(DB::select("SELECT column_name FROM information_schema.columns WHERE table_name = 'deals'"))
+        ->pluck('column_name')->all();
+
+    expect($cols)->toContain('phone_operator', 'region_substituted');
+});
@@ -76,10 +76,11 @@ test('идемпотентность: повторный запуск не па

    expect($afterSecond)->toBe($afterFirst);

-    // Output второго запуска должен сказать «0 created» по всем 8 таблицам × 6 месяцев = 48 партиций.
-    // (webhook_log удалён в миграции 2026_05_24_140000_drop_legacy_webhook_artefacts)
+    // Output второго запуска должен сказать «0 created» по всем партиционированным таблицам × 6 месяцев
+    // (текущий + ahead=5). Число таблиц берём из PARTITIONED_TABLES — тест не ломается при добавлении новых.
+    $expectedSkipped = count(\App\Services\MonthlyPartitionManager::PARTITIONED_TABLES) * 6;
    $output = Artisan::output();
-    expect($output)->toContain('0 created, 48 skipped');
+    expect($output)->toContain("0 created, {$expectedSkipped} skipped");
 });

 test('--ahead=0 создаёт только текущий месяц', function () {
@@ -0,0 +1,42 @@
+<?php
+
+declare(strict_types=1);
+
+use App\Services\DaData\DaDataBudgetGuard;
+
+it('allows spend while under the daily cap', function (): void {
+    config(['services.dadata.daily_cap_rub' => 10]); // 1000 копеек
+    $guard = app(DaDataBudgetGuard::class);
+
+    expect($guard->canSpend())->toBeTrue();
+
+    $guard->recordSpend(500);
+
+    expect($guard->canSpend())->toBeTrue()
+        ->and($guard->spentTodayKopecks())->toBe(500);
+});
+
+it('blocks spend once the daily cap is reached', function (): void {
+    config(['services.dadata.daily_cap_rub' => 1]); // 100 копеек
+    $guard = app(DaDataBudgetGuard::class);
+
+    $guard->recordSpend(100);
+
+    expect($guard->canSpend())->toBeFalse();
+});
+
+it('accumulates spend across multiple calls', function (): void {
+    config(['services.dadata.daily_cap_rub' => 100]);
+    $guard = app(DaDataBudgetGuard::class);
+
+    $guard->recordSpend(30);
+    $guard->recordSpend(70);
+
+    expect($guard->spentTodayKopecks())->toBe(100);
+});
+
+it('starts at zero spend for a fresh day', function (): void {
+    $guard = app(DaDataBudgetGuard::class);
+
+    expect($guard->spentTodayKopecks())->toBe(0);
+});
@@ -0,0 +1,80 @@
+<?php
+
+declare(strict_types=1);
+
+use App\Services\DaData\DaDataException;
+use App\Services\DaData\DaDataPhoneClient;
+use App\Services\DaData\DaDataTimeoutException;
+use Illuminate\Http\Client\ConnectionException;
+use Illuminate\Support\Facades\Http;
+
+it('parses qc=0 mobile response into DTO', function (): void {
+    Http::fake(['cleaner.dadata.ru/*' => Http::response([[
+        'qc' => 0, 'qc_conflict' => 0, 'type' => 'Мобильный', 'phone' => '+7 921 555-12-34',
+        'provider' => 'МегаФон', 'region' => 'Санкт-Петербург и область', 'city' => null, 'timezone' => 'UTC+3',
+    ]], 200)]);
+
+    $resp = app(DaDataPhoneClient::class)->cleanPhone('79215551234');
+
+    expect($resp->qc)->toBe(0)
+        ->and($resp->provider)->toBe('МегаФон')
+        ->and($resp->region)->toBe('Санкт-Петербург и область')
+        ->and($resp->type)->toBe('Мобильный')
+        ->and($resp->raw)->toBeArray();
+});
+
+it('parses qc=3 multiple response', function (): void {
+    Http::fake(['cleaner.dadata.ru/*' => Http::response([[
+        'qc' => 3, 'region' => 'Москва', 'provider' => 'МТС', 'type' => 'Мобильный',
+    ]], 200)]);
+
+    expect(app(DaDataPhoneClient::class)->cleanPhone('79991234567')->qc)->toBe(3);
+});
+
+it('sends Token auth, X-Secret header and json-array body', function (): void {
+    config(['services.dadata.api_key' => 'KEY', 'services.dadata.secret' => 'SEC']);
+    Http::fake(['cleaner.dadata.ru/*' => Http::response([['qc' => 0, 'region' => 'Москва']], 200)]);
+
+    app(DaDataPhoneClient::class)->cleanPhone('79161234567');
+
+    Http::assertSent(function ($request): bool {
+        return $request->url() === 'https://cleaner.dadata.ru/api/v1/clean/phone'
+            && $request->hasHeader('Authorization', 'Token KEY')
+            && $request->hasHeader('X-Secret', 'SEC')
+            && $request->body() === '["79161234567"]';
+    });
+});
+
+it('throws DaDataTimeoutException on connection error', function (): void {
+    Http::fake(fn () => throw new ConnectionException('timeout'));
+
+    expect(fn () => app(DaDataPhoneClient::class)->cleanPhone('79215551234'))
+        ->toThrow(DaDataTimeoutException::class);
+});
+
+it('throws DaDataException on persistent 5xx', function (): void {
+    Http::fake(['cleaner.dadata.ru/*' => Http::response('upstream error', 500)]);
+
+    expect(fn () => app(DaDataPhoneClient::class)->cleanPhone('79215551234'))
+        ->toThrow(DaDataException::class);
+});
+
+it('retries once on 5xx then succeeds', function (): void {
+    Http::fakeSequence('cleaner.dadata.ru/*')
+        ->push('upstream error', 500)
+        ->push([['qc' => 0, 'region' => 'Москва', 'provider' => 'МТС']], 200);
+
+    $resp = app(DaDataPhoneClient::class)->cleanPhone('79161234567');
+
+    expect($resp->qc)->toBe(0);
+    Http::assertSentCount(2);
+});
+
+it('does not retry on 4xx client error', function (): void {
+    Http::fake(['cleaner.dadata.ru/*' => Http::response('bad request', 400)]);
+
+    expect(fn () => app(DaDataPhoneClient::class)->cleanPhone('79161234567'))
+        ->toThrow(DaDataException::class);
+
+    Http::assertSentCount(1);
+});
@@ -0,0 +1,215 @@
+<?php
+
+declare(strict_types=1);
+
+use App\Models\SupplierLead;
+use App\Services\LeadRegionResolver;
+use Illuminate\Foundation\Testing\DatabaseTransactions;
+use Illuminate\Http\Client\ConnectionException;
+use Illuminate\Support\Facades\DB;
+use Illuminate\Support\Facades\Http;
+use Tests\Concerns\SharesSupplierPdo;
+
+uses(DatabaseTransactions::class);
+uses(SharesSupplierPdo::class);
+
+beforeEach(function (): void {
+    config([
+        'services.dadata.enabled' => true,
+        'services.dadata.api_key' => 'k',
+        'services.dadata.secret' => 's',
+        'services.dadata.daily_cap_rub' => 10000,
+    ]);
+});
+
+function resolverSeedImport(): int
+{
+    return (int) DB::table('phone_ranges_imports')->insertGetId([
+        'source_url' => 'test', 'checksum_sha256' => str_repeat('b', 64),
+        'status' => 'completed', 'imported_at' => now(),
+    ]);
+}
+
+function resolverSeedRange(int $subject, string $region = 'Москва', int $def = 916, string $operator = 'Ростелеком'): void
+{
+    DB::table('phone_ranges')->insert([
+        'def_code' => $def, 'from_num' => 0, 'to_num' => 9999999,
+        'operator' => $operator, 'region' => $region, 'subject_code' => $subject,
+        'imported_at' => now(), 'import_id' => resolverSeedImport(),
+    ]);
+}
+
+function resolverLead(string $phone = '79161234567', string $tag = ''): SupplierLead
+{
+    return new SupplierLead([
+        'phone' => $phone,
+        'raw_payload' => ['tag' => $tag],
+        'received_at' => now(),
+    ]);
+}
+
+function fakeDadata(array $row): void
+{
+    Http::fake(['cleaner.dadata.ru/*' => Http::response([$row], 200)]);
+}
+
+it('dadata qc 0 returns dadata source', function (): void {
+    fakeDadata(['qc' => 0, 'region' => 'Москва', 'provider' => 'МТС', 'type' => 'Мобильный']);
+
+    $r = app(LeadRegionResolver::class)->resolve(resolverLead());
+
+    expect($r->source)->toBe('dadata')
+        ->and($r->subjectCode)->toBe(82)
+        ->and($r->phoneOperator)->toBe('МТС')
+        ->and($r->qc)->toBe(0)
+        ->and($r->cacheHit)->toBeFalse();
+});
+
+it('dadata qc 0 ambiguous region falls to rossvyaz but keeps dadata provider', function (): void {
+    fakeDadata(['qc' => 0, 'region' => 'Санкт-Петербург и область', 'provider' => 'МегаФон']);
+    resolverSeedRange(subject: 83, region: 'Санкт-Петербург');
+
+    $r = app(LeadRegionResolver::class)->resolve(resolverLead());
+
+    expect($r->source)->toBe('rossvyaz')
+        ->and($r->subjectCode)->toBe(83)
+        ->and($r->phoneOperator)->toBe('МегаФон') // оператор от DaData (MNP), §3.4.1
+        ->and($r->rossvyazMatched)->toBeTrue();
+});
+
+it('dadata qc 3 returns dadata with multiple flag', function (): void {
+    fakeDadata(['qc' => 3, 'region' => 'Москва', 'provider' => 'МТС']);
+
+    $r = app(LeadRegionResolver::class)->resolve(resolverLead());
+
+    expect($r->source)->toBe('dadata')->and($r->subjectCode)->toBe(82)->and($r->qc)->toBe(3);
+});
+
+it('dadata qc 1 falls back to rossvyaz', function (): void {
+    fakeDadata(['qc' => 1, 'region' => 'Москва', 'provider' => 'Билайн']);
+    resolverSeedRange(subject: 82);
+
+    $r = app(LeadRegionResolver::class)->resolve(resolverLead());
+
+    expect($r->source)->toBe('rossvyaz')->and($r->subjectCode)->toBe(82);
+});
+
+it('dadata qc 2 falls back to tag skipping rossvyaz', function (): void {
+    fakeDadata(['qc' => 2]);
+    resolverSeedRange(subject: 83); // если бы Россвязь дёрнули — был бы 83
+
+    $r = app(LeadRegionResolver::class)->resolve(resolverLead(tag: 'Москва'));
+
+    expect($r->source)->toBe('tag')->and($r->subjectCode)->toBe(82)->and($r->rossvyazMatched)->toBeFalse();
+});
+
+it('dadata qc 7 falls back to tag skipping rossvyaz', function (): void {
+    fakeDadata(['qc' => 7]);
+    resolverSeedRange(subject: 83);
+
+    $r = app(LeadRegionResolver::class)->resolve(resolverLead(tag: 'Москва'));
+
+    expect($r->source)->toBe('tag')->and($r->subjectCode)->toBe(82);
+});
+
+it('dadata timeout falls back to rossvyaz', function (): void {
+    Http::fake(fn () => throw new ConnectionException('timeout'));
+    resolverSeedRange(subject: 82);
+
+    $r = app(LeadRegionResolver::class)->resolve(resolverLead());
+
+    expect($r->source)->toBe('rossvyaz')->and($r->subjectCode)->toBe(82);
+});
+
+it('dadata network error 5xx falls back to rossvyaz', function (): void {
+    Http::fake(['cleaner.dadata.ru/*' => Http::response('err', 500)]);
+    resolverSeedRange(subject: 82);
+
+    $r = app(LeadRegionResolver::class)->resolve(resolverLead());
+
+    expect($r->source)->toBe('rossvyaz')->and($r->subjectCode)->toBe(82);
+});
+
+it('budget cap exceeded skips dadata directly to rossvyaz', function (): void {
+    config(['services.dadata.daily_cap_rub' => 0]); // canSpend() → false
+    Http::fake(['cleaner.dadata.ru/*' => Http::response([['qc' => 0, 'region' => 'Москва']], 200)]);
+    resolverSeedRange(subject: 82);
+
+    $r = app(LeadRegionResolver::class)->resolve(resolverLead());
+
+    expect($r->source)->toBe('rossvyaz')->and($r->subjectCode)->toBe(82);
+    Http::assertNothingSent();
+});
+
+it('cache hit skips dadata and rossvyaz on the second call', function (): void {
+    fakeDadata(['qc' => 0, 'region' => 'Москва', 'provider' => 'МТС']);
+    $resolver = app(LeadRegionResolver::class);
+
+    $first = $resolver->resolve(resolverLead());
+    $second = $resolver->resolve(resolverLead());
+
+    expect($first->cacheHit)->toBeFalse()
+        ->and($second->cacheHit)->toBeTrue()
+        ->and($second->subjectCode)->toBe(82);
+    Http::assertSentCount(1);
+});
+
+it('invalid phone skips dadata returns tag', function (): void {
+    Http::fake(['cleaner.dadata.ru/*' => Http::response([['qc' => 0]], 200)]);
+
+    $r = app(LeadRegionResolver::class)->resolve(resolverLead(phone: '123', tag: 'Москва'));
+
+    expect($r->source)->toBe('tag')->and($r->subjectCode)->toBe(82);
+    Http::assertNothingSent();
+});
+
+it('qc 0 region null falls through to rossvyaz', function (): void {
+    fakeDadata(['qc' => 0, 'region' => null, 'provider' => 'Tele2']);
+    resolverSeedRange(subject: 82);
+
+    $r = app(LeadRegionResolver::class)->resolve(resolverLead());
+
+    expect($r->source)->toBe('rossvyaz')->and($r->subjectCode)->toBe(82)->and($r->phoneOperator)->toBe('Tele2');
+});
+
+it('unmappable dadata region falls through to rossvyaz', function (): void {
+    fakeDadata(['qc' => 0, 'region' => 'Несуществующий край', 'provider' => 'МТС']);
+    resolverSeedRange(subject: 82);
+
+    $r = app(LeadRegionResolver::class)->resolve(resolverLead());
+
+    expect($r->source)->toBe('rossvyaz')->and($r->subjectCode)->toBe(82);
+});
+
+it('all three layers fail returns unknown with null subject_code', function (): void {
+    fakeDadata(['qc' => 1]); // → rossvyaz
+    // no phone_ranges seeded → rossvyaz miss; tag empty → null
+
+    $r = app(LeadRegionResolver::class)->resolve(resolverLead(tag: ''));
+
+    expect($r->source)->toBe('unknown')->and($r->subjectCode)->toBeNull();
+});
+
+it('disabled feature flag returns tag without any dadata call', function (): void {
+    config(['services.dadata.enabled' => false]);
+    Http::fake(['cleaner.dadata.ru/*' => Http::response([['qc' => 0]], 200)]);
+
+    $r = app(LeadRegionResolver::class)->resolve(resolverLead(tag: 'Москва'));
+
+    expect($r->source)->toBe('tag')->and($r->subjectCode)->toBe(82);
+    Http::assertNothingSent();
+});
+
+it('persistent idempotency: already-resolved lead skips dadata', function (): void {
+    Http::fake(['cleaner.dadata.ru/*' => Http::response([['qc' => 0, 'region' => 'Москва']], 200)]);
+    $lead = resolverLead();
+    $lead->resolved_subject_code = 83;
+    $lead->region_source = 'dadata';
+    $lead->dadata_qc = 0;
+    $lead->phone_operator = 'МегаФон';
+
+    $r = app(LeadRegionResolver::class)->resolve($lead);
+
+    expect($r->subjectCode)->toBe(83)->and($r->source)->toBe('dadata');
+    Http::assertNothingSent();
+});
@@ -0,0 +1,189 @@
+<?php
+
+declare(strict_types=1);
+
+use App\Models\Project;
+use App\Models\SupplierProject;
+use App\Models\Tenant;
+use App\Services\LeadRouter;
+use Illuminate\Foundation\Testing\DatabaseTransactions;
+use Illuminate\Support\Facades\DB;
+use Random\Engine\Mt19937;
+use Random\Randomizer;
+use Tests\Concerns\SharesSupplierPdo;
+
+uses(DatabaseTransactions::class);
+uses(SharesSupplierPdo::class);
+
+beforeEach(function (): void {
+    DB::statement("SELECT set_config('app.current_tenant_id', '0', true)");
+});
+
+/** Детерминированный роутер с засеянным жребием (вариант В). */
+function seededRouter(int $seed = 42): LeadRouter
+{
+    return new LeadRouter(new Randomizer(new Mt19937($seed)));
+}
+
+/**
+ * Создаёт tenant + project + pivot/snapshot для каскад-тестов.
+ * regions — PG-массив-литерал ('{82}' / '{}'); remaining лимита = dailyLimit - deliveredToday.
+ */
+function makeCascadeProject(
+    SupplierProject $sp,
+    string $regions,
+    int $dailyLimit = 100,
+    int $deliveredToday = 0,
+): Project {
+    $tenant = Tenant::factory()->create(['balance_leads' => 100, 'balance_rub' => '1000.00']);
+    $project = Project::factory()->create([
+        'tenant_id' => $tenant->id,
+        'is_active' => true,
+        'daily_limit_target' => $dailyLimit,
+        'delivered_today' => $deliveredToday,
+        'delivery_days_mask' => 127,
+        'signal_type' => $sp->signal_type,
+        'signal_identifier' => $sp->unique_key,
+    ]);
+    linkProjectToSupplier($project, $sp);
+    createRoutingSnapshotFromProject(
+        $project,
+        signalType: $sp->signal_type,
+        signalIdentifier: $sp->unique_key,
+        dailyLimit: $dailyLimit,
+        regions: $regions,
+    );
+
+    return $project;
+}
+
+function b1Supplier(string $key = 'ex.ru'): SupplierProject
+{
+    return SupplierProject::query()->create([
+        'platform' => 'B1', 'signal_type' => 'site', 'unique_key' => $key,
+        'subject_code' => 82, 'current_limit' => 0, 'sync_status' => 'ok',
+    ]);
+}
+
+it('step 1: exact region match wins, others excluded', function (): void {
+    $sp = b1Supplier();
+    $spb = makeCascadeProject($sp, regions: '{83}'); // Питер
+    $msk = makeCascadeProject($sp, regions: '{82}'); // Москва
+
+    $matched = seededRouter()->matchEligibleProjects($sp, resolvedSubjectCode: 82);
+
+    expect($matched->pluck('id')->all())->toBe([$msk->id])
+        ->and($matched->first()->routing_step)->toBe(1);
+});
+
+it('step 2: falls to all-RF when no exact match', function (): void {
+    $sp = b1Supplier('s2.ru');
+    $allRu = makeCascadeProject($sp, regions: '{}'); // вся РФ
+
+    $matched = seededRouter()->matchEligibleProjects($sp, resolvedSubjectCode: 82);
+
+    expect($matched->pluck('id')->all())->toBe([$allRu->id])
+        ->and($matched->first()->routing_step)->toBe(2);
+});
+
+it('step 3: fallback channel when nobody subscribed to region and no all-RF', function (): void {
+    $sp = b1Supplier('s3.ru');
+    $spb = makeCascadeProject($sp, regions: '{83}'); // только Питер подписан
+
+    // resolvedSubjectCode=82 (Москва): точных нет, «вся РФ» нет → запасной канал.
+    $matched = seededRouter()->matchEligibleProjects($sp, resolvedSubjectCode: 82);
+
+    expect($matched->pluck('id')->all())->toBe([$spb->id])
+        ->and($matched->first()->routing_step)->toBe(3);
+});
+
+it('exact + all-RF combine up to cap=3, exact taking priority', function (): void {
+    $sp = b1Supplier('s4.ru');
+    $e1 = makeCascadeProject($sp, regions: '{82}');
+    $e2 = makeCascadeProject($sp, regions: '{82}');
+    $r1 = makeCascadeProject($sp, regions: '{}');
+    $r2 = makeCascadeProject($sp, regions: '{}');
+
+    $matched = seededRouter()->matchEligibleProjects($sp, resolvedSubjectCode: 82);
+
+    // Всего 3 (cap). Оба точных (step 1) обязаны быть; добор — ровно 1 «вся РФ» (step 2).
+    expect($matched)->toHaveCount(3);
+    $byStep = $matched->groupBy(fn ($p) => $p->routing_step);
+    expect($byStep->get(1)->pluck('id')->sort()->values()->all())->toBe(collect([$e1->id, $e2->id])->sort()->values()->all())
+        ->and($byStep->get(2))->toHaveCount(1);
+    expect(in_array($byStep->get(2)->first()->id, [$r1->id, $r2->id], true))->toBeTrue();
+});
+
+it('null resolvedSubjectCode skips exact, uses all-RF', function (): void {
+    $sp = b1Supplier('s5.ru');
+    $allRu = makeCascadeProject($sp, regions: '{}');
+    $exact = makeCascadeProject($sp, regions: '{82}');
+
+    // Резолвер не сработал → шаг 1 пропускается; матчит только «вся РФ».
+    $matched = seededRouter()->matchEligibleProjects($sp, resolvedSubjectCode: null);
+
+    expect($matched->pluck('id')->all())->toBe([$allRu->id])
+        ->and($matched->first()->routing_step)->toBe(2);
+});
+
+it('cascade works for DIRECT supplier_project path too', function (): void {
+    $sp = SupplierProject::query()->create([
+        'platform' => 'DIRECT', 'signal_type' => 'site', 'unique_key' => 'cashmotor.ru',
+        'subject_code' => 82, 'current_limit' => 0, 'sync_status' => 'ok',
+    ]);
+    $msk = makeCascadeProject($sp, regions: '{82}');
+    $spb = makeCascadeProject($sp, regions: '{83}');
+
+    $matched = seededRouter()->matchEligibleProjects($sp, resolvedSubjectCode: 82);
+
+    expect($matched->pluck('id')->all())->toBe([$msk->id])
+        ->and($matched->first()->routing_step)->toBe(1);
+});
+
+it('backward compat: no second arg behaves as all-RF/any (existing call shape)', function (): void {
+    $sp = b1Supplier('s7.ru');
+    $allRu = makeCascadeProject($sp, regions: '{}');
+
+    // Старая сигнатура (без 2-го аргумента) — дефолт null → шаг 2 all-RF матчит '{}'.
+    $matched = seededRouter()->matchEligibleProjects($sp);
+
+    expect($matched->pluck('id')->all())->toBe([$allRu->id]);
+});
+
+it('variant В: weighted pick — small client never starved, big client wins more often', function (): void {
+    $sp = b1Supplier('fair.ru');
+    // 5 клиентов на Москву, разный остаток лимита.
+    $a = makeCascadeProject($sp, regions: '{82}', dailyLimit: 100); // остаток 100
+    $b = makeCascadeProject($sp, regions: '{82}', dailyLimit: 50);
+    $c = makeCascadeProject($sp, regions: '{82}', dailyLimit: 30);
+    $d = makeCascadeProject($sp, regions: '{82}', dailyLimit: 20);
+    $e = makeCascadeProject($sp, regions: '{82}', dailyLimit: 10);  // остаток 10 — самый маленький
+
+    $wins = [];
+    $seedCount = 120;
+    for ($seed = 0; $seed < $seedCount; $seed++) {
+        $matched = seededRouter($seed)->matchEligibleProjects($sp, resolvedSubjectCode: 82);
+        expect($matched)->toHaveCount(3); // лид всегда раздаётся ровно троим
+        foreach ($matched as $p) {
+            $wins[$p->id] = ($wins[$p->id] ?? 0) + 1;
+        }
+    }
+
+    // (1) Мелкого не отрезаем: за 120 розыгрышей хотя бы раз получил лид.
+    expect($wins[$e->id] ?? 0)->toBeGreaterThan(0);
+    // (2) Вес уважается: крупный клиент выигрывает строго чаще мелкого.
+    expect($wins[$a->id] ?? 0)->toBeGreaterThan($wins[$e->id] ?? 0);
+});
+
+it('variant В: deterministic — same seed yields same recipients', function (): void {
+    $sp = b1Supplier('det.ru');
+    makeCascadeProject($sp, regions: '{82}', dailyLimit: 100);
+    makeCascadeProject($sp, regions: '{82}', dailyLimit: 50);
+    makeCascadeProject($sp, regions: '{82}', dailyLimit: 30);
+    makeCascadeProject($sp, regions: '{82}', dailyLimit: 20);
+
+    $first = seededRouter(7)->matchEligibleProjects($sp, resolvedSubjectCode: 82)->pluck('id')->all();
+    $second = seededRouter(7)->matchEligibleProjects($sp, resolvedSubjectCode: 82)->pluck('id')->all();
+
+    expect($first)->toBe($second)->and($first)->toHaveCount(3);
+});
@@ -0,0 +1,70 @@
+<?php
+
+declare(strict_types=1);
+
+use App\Models\SupplierLead;
+use App\Services\Dto\RegionResolution;
+
+it('exposes the source rank ordering dadata>rossvyaz>tag>unknown', function (): void {
+    expect(RegionResolution::SOURCE_RANK)->toBe([
+        'dadata' => 4, 'rossvyaz' => 3, 'tag' => 2, 'unknown' => 1,
+    ]);
+});
+
+it('make sets actualSubjectCode equal to subjectCode', function (): void {
+    $r = RegionResolution::make(82, 'dadata', operator: 'МТС', qc: 0);
+
+    expect($r->subjectCode)->toBe(82)
+        ->and($r->actualSubjectCode)->toBe(82)
+        ->and($r->source)->toBe('dadata')
+        ->and($r->phoneOperator)->toBe('МТС')
+        ->and($r->qc)->toBe(0)
+        ->and($r->cacheHit)->toBeFalse()
+        ->and($r->rossvyazMatched)->toBeFalse();
+});
+
+it('fromTag builds a tag-sourced resolution', function (): void {
+    $r = RegionResolution::fromTag(82);
+
+    expect($r->subjectCode)->toBe(82)
+        ->and($r->source)->toBe('tag')
+        ->and($r->phoneOperator)->toBeNull();
+});
+
+it('fromSupplierLead reconstructs a persisted resolution (idempotency)', function (): void {
+    $lead = new SupplierLead([
+        'resolved_subject_code' => 83,
+        'region_source' => 'dadata',
+        'dadata_qc' => 0,
+        'phone_operator' => 'МегаФон',
+    ]);
+
+    $r = RegionResolution::fromSupplierLead($lead);
+
+    expect($r->subjectCode)->toBe(83)
+        ->and($r->source)->toBe('dadata')
+        ->and($r->phoneOperator)->toBe('МегаФон')
+        ->and($r->qc)->toBe(0);
+});
+
+it('withCacheHit flips the flag and clears the per-call masked response', function (): void {
+    $r = RegionResolution::make(82, 'dadata', operator: 'МТС', qc: 0, dadataMasked: ['phone' => '7916***4567']);
+
+    $hit = $r->withCacheHit(true);
+
+    expect($hit->cacheHit)->toBeTrue()
+        ->and($hit->subjectCode)->toBe(82)
+        ->and($hit->dadataResponseMasked)->toBeNull();
+});
+
+it('forCache strips per-call fields before storing', function (): void {
+    $r = RegionResolution::make(82, 'dadata', operator: 'МТС', qc: 0, dadataMasked: ['phone' => 'x'], durationMs: 120);
+
+    $c = $r->forCache();
+
+    expect($c->dadataResponseMasked)->toBeNull()
+        ->and($c->durationMs)->toBeNull()
+        ->and($c->cacheHit)->toBeFalse()
+        ->and($c->subjectCode)->toBe(82)
+        ->and($c->phoneOperator)->toBe('МТС');
+});
@@ -0,0 +1,94 @@
+<?php
+
+declare(strict_types=1);
+
+use App\Services\Dto\RossvyazRecord;
+use App\Services\RossvyazPrefixLookup;
+use Illuminate\Foundation\Testing\DatabaseTransactions;
+use Illuminate\Support\Facades\DB;
+use Tests\Concerns\SharesSupplierPdo;
+
+uses(DatabaseTransactions::class);
+uses(SharesSupplierPdo::class);
+
+/**
+ * Вставляет строку-журнал импорта и возвращает её id (import_id для phone_ranges).
+ */
+function seedRossvyazImport(): int
+{
+    return (int) DB::table('phone_ranges_imports')->insertGetId([
+        'source_url' => 'https://rossvyaz.gov.ru/test',
+        'checksum_sha256' => str_repeat('a', 64),
+        'status' => 'completed',
+        'imported_at' => now(),
+    ]);
+}
+
+/**
+ * @param  array<string, mixed>  $overrides
+ */
+function seedPhoneRange(array $overrides = []): void
+{
+    DB::table('phone_ranges')->insert(array_merge([
+        'def_code' => 921,
+        'from_num' => 5550000,
+        'to_num' => 5559999,
+        'operator' => 'МегаФон',
+        'region' => 'Санкт-Петербург',
+        'subject_code' => 83,
+        'imported_at' => now(),
+        'import_id' => seedRossvyazImport(),
+    ], $overrides));
+}
+
+it('mobile prefix returns correct region and operator', function (): void {
+    seedPhoneRange();
+
+    $rec = app(RossvyazPrefixLookup::class)->find('79215555123');
+
+    expect($rec)->toBeInstanceOf(RossvyazRecord::class)
+        ->and($rec->subjectCode)->toBe(83)
+        ->and($rec->region)->toBe('Санкт-Петербург')
+        ->and($rec->operator)->toBe('МегаФон');
+});
+
+it('prefers narrower range when two ranges overlap', function (): void {
+    $importId = seedRossvyazImport();
+    // Широкий диапазон (вся 495-зона) — Московская область (56).
+    seedPhoneRange([
+        'def_code' => 495, 'from_num' => 1000000, 'to_num' => 9999999,
+        'operator' => 'Ростелеком', 'region' => 'Московская область',
+        'subject_code' => 56, 'import_id' => $importId,
+    ]);
+    // Узкий диапазон внутри — Москва (82). Должен выиграть (ORDER BY width ASC).
+    seedPhoneRange([
+        'def_code' => 495, 'from_num' => 2000000, 'to_num' => 2009999,
+        'operator' => 'МГТС', 'region' => 'Москва',
+        'subject_code' => 82, 'import_id' => $importId,
+    ]);
+
+    $rec = app(RossvyazPrefixLookup::class)->find('74952005000');
+
+    expect($rec)->not->toBeNull()
+        ->and($rec->subjectCode)->toBe(82)
+        ->and($rec->region)->toBe('Москва');
+});
+
+it('returns null for unknown prefix', function (): void {
+    seedPhoneRange(); // только def_code=921
+
+    expect(app(RossvyazPrefixLookup::class)->find('79991234567'))->toBeNull();
+});
+
+it('returns null when subscriber number is outside any range', function (): void {
+    seedPhoneRange(['def_code' => 921, 'from_num' => 5550000, 'to_num' => 5559999]);
+
+    // def_code совпадает (921), но subscriber 4440000 вне [5550000, 5559999]
+    expect(app(RossvyazPrefixLookup::class)->find('79214440000'))->toBeNull();
+});
+
+it('returns null for malformed phone', function (): void {
+    seedPhoneRange();
+
+    expect(app(RossvyazPrefixLookup::class)->find('123'))->toBeNull();
+});
@@ -38,11 +38,4 @@ describe('DealsFilters', () => {
        });
        expect(w.find('[data-testid="clear-filters-btn"]').exists()).toBe(true);
    });
-
-    it('поле поиска имеет доступное имя (label) для скринридера', () => {
-        const w = mount(DealsFilters, { props: baseProps, global: { plugins: [vuetify] } });
-        const label = w.find('[data-testid="filter-search-phone"] label');
-        expect(label.exists()).toBe(true);
-        expect(label.text()).toContain('Поиск по телефону');
-    });
 });
@@ -47,11 +47,4 @@ describe('KanbanColumn.vue', () => {
        expect(wrapper.emitted('openDeal')).toBeTruthy();
        expect(wrapper.emitted('openDeal')?.[0]).toEqual([dealsForNew[0].id]);
    });
-
-    // Контраст column-total на ивори чинится в scoped CSS (var(--accent) → нейтральный #4a463f),
-    // jsdom scoped-стили не вычисляет → числовую проверку контраста делает Pa11y. Здесь — структурный якорь.
-    it('column-total отрисован для пустой колонки', () => {
-        const wrapper = factory({ status, deals: [] });
-        expect(wrapper.find('.column-total').exists()).toBe(true);
-    });
 });
@@ -49,14 +49,4 @@ describe('ProjectCard', () => {
        });
        expect(wrapper.text()).toContain('На паузе');
    });
-
-    it('чип типа сигнала — flat-вариант с классом signal-chip (a11y контраст)', () => {
-        const wrapper = mount(ProjectCard, {
-            global: { plugins: [vuetify] },
-            props: { project: baseProject, selected: false },
-        });
-        const chip = wrapper.find('.signal-chip');
-        expect(chip.exists()).toBe(true);
-        expect(chip.classes()).toContain('v-chip--variant-flat');
-    });
 });
@@ -131,6 +131,7 @@ function createRoutingSnapshotFromProject(
    string $signalType = 'call',
    ?string $signalIdentifier = null,
    ?int $dailyLimit = null,
+    string $regions = '{}',
 ): void {
    DB::table('project_routing_snapshots')->insert([
        'snapshot_date' => $date ?? Carbon::today('Europe/Moscow')->toDateString(),
@@ -138,7 +139,7 @@ function createRoutingSnapshotFromProject(
        'tenant_id' => $project->tenant_id,
        'daily_limit' => $dailyLimit ?? (int) ($project->effective_daily_limit_today ?? $project->daily_limit_target),
        'delivery_days_mask' => (int) ($project->delivery_days_mask ?? 127),
-        'regions' => '{}',
+        'regions' => $regions,
        'signal_type' => $signalType,
        'signal_identifier' => $signalIdentifier,
        'sms_senders' => null,
@@ -0,0 +1,10 @@
+<?php
+
+declare(strict_types=1);
+
+use App\Services\MonthlyPartitionManager;
+
+it('knows lead_region_resolution_log partition key', function (): void {
+    expect(MonthlyPartitionManager::PARTITIONED_TABLES)->toHaveKey('lead_region_resolution_log');
+    expect(MonthlyPartitionManager::PARTITIONED_TABLES['lead_region_resolution_log'])->toBe('received_at');
+});
@@ -0,0 +1,35 @@
+<?php
+
+declare(strict_types=1);
+
+use App\Support\DaDataRegionMap;
+use App\Support\RussianRegions;
+
+it('maps exact official names via RussianRegions', function (): void {
+    expect(DaDataRegionMap::toSubjectCode('Москва'))->toBe(82)
+        ->and(DaDataRegionMap::toSubjectCode('Московская область'))->toBe(56)
+        ->and(DaDataRegionMap::toSubjectCode('Санкт-Петербург'))->toBe(83)
+        ->and(DaDataRegionMap::toSubjectCode('Ленинградская область'))->toBe(53);
+});
+
+it('trims surrounding whitespace before mapping', function (): void {
+    expect(DaDataRegionMap::toSubjectCode('  Москва  '))->toBe(82);
+});
+
+it('flags ambiguous agglomeration strings', function (): void {
+    expect(DaDataRegionMap::isAmbiguous('Санкт-Петербург и область'))->toBeTrue()
+        ->and(DaDataRegionMap::isAmbiguous('Москва и область'))->toBeTrue()
+        ->and(DaDataRegionMap::isAmbiguous('Москва'))->toBeFalse()
+        ->and(DaDataRegionMap::isAmbiguous('Санкт-Петербург'))->toBeFalse();
+});
+
+it('returns null for unmappable region', function (): void {
+    expect(DaDataRegionMap::toSubjectCode('Атлантида'))->toBeNull()
+        ->and(DaDataRegionMap::toSubjectCode(''))->toBeNull();
+});
+
+it('resolves all 89 RussianRegions names', function (): void {
+    foreach (RussianRegions::CODE_TO_NAME as $code => $name) {
+        expect(DaDataRegionMap::toSubjectCode($name))->toBe($code);
+    }
+});
@@ -0,0 +1,61 @@
+<?php
+
+declare(strict_types=1);
+
+use App\Support\RussianRegions;
+
+/**
+ * Нормализация регионов реестра Россвязи → subject_code.
+ * Кейсы взяты из реальных топ-50 unmapped-форматов прод-реестра (02.06.2026).
+ */
+it('maps cities of federal significance with the г. prefix', function (): void {
+    expect(RussianRegions::resolveSubjectCode('г. Москва'))->toBe(82)
+        ->and(RussianRegions::resolveSubjectCode('г. Санкт-Петербург'))->toBe(83)
+        ->and(RussianRegions::resolveSubjectCode('г. Севастополь'))->toBe(84);
+});
+
+it('still maps a plain canonical federal-city name', function (): void {
+    expect(RussianRegions::resolveSubjectCode('Москва'))->toBe(82);
+});
+
+it('takes the last pipe segment as the subject region', function (): void {
+    // регион = последний сегмент после |
+    expect(RussianRegions::resolveSubjectCode('г. Оренбург|Оренбургская обл.'))->toBe(62)
+        ->and(RussianRegions::resolveSubjectCode('г. Воскресенск|р-н Воскресенский|Московская обл.'))->toBe(56);
+});
+
+it('expands the обл. abbreviation to область', function (): void {
+    expect(RussianRegions::resolveSubjectCode('г. Иркутск|Иркутская обл.'))->toBe(45)
+        ->and(RussianRegions::resolveSubjectCode('г. Балашиха|Московская обл.'))->toBe(56);
+});
+
+it('keeps already-canonical край/республика segments', function (): void {
+    expect(RussianRegions::resolveSubjectCode('г. Красноярск|Красноярский край'))->toBe(29)
+        ->and(RussianRegions::resolveSubjectCode('г. Уфа|Республика Башкортостан'))->toBe(3);
+});
+
+it('reorders the Удмуртская Республика inverted form', function (): void {
+    expect(RussianRegions::resolveSubjectCode('г. Ижевск|Республика Удмуртская'))->toBe(21);
+});
+
+it('maps the Кузбасс special form to Кемеровская область', function (): void {
+    expect(RussianRegions::resolveSubjectCode('г. Кемерово|Кемеровская область - Кузбасс обл.'))->toBe(48);
+});
+
+it('returns null for hopeless / ambiguous / city-only strings', function (string $raw): void {
+    expect(RussianRegions::resolveSubjectCode($raw))->toBeNull();
+})->with([
+    '-',
+    'Российская Федерация',
+    'Москва и Московская область', // неоднозначно — два субъекта
+    'г.о. Тольятти',               // нет региона в строке
+    'г.о. город Уфа',
+    '',
+    '   ',
+]);
+
+it('exposes the canonical name via canonicalRegionName', function (): void {
+    expect(RussianRegions::canonicalRegionName('г. Оренбург|Оренбургская обл.'))->toBe('Оренбургская область')
+        ->and(RussianRegions::canonicalRegionName('г. Ижевск|Республика Удмуртская'))->toBe('Удмуртская Республика')
+        ->and(RussianRegions::canonicalRegionName('-'))->toBeNull();
+});
@@ -0,0 +1,5 @@
+АВС/ DEF;От;До;Емкость;Оператор;Регион
+495;2000000;2009999;10000;ОАО МГТС;г. Москва
+922;1000000;1099999;100000;ПАО Ростелеком;г. Оренбург|Оренбургская обл.
+987;5000000;5099999;100000;ПАО Ростелеком;г. Ижевск|Республика Удмуртская
+902;7000000;7009999;10000;ООО Оператор;г.о. Тольятти
@@ -0,0 +1,4 @@
+АВС/ DEF;От;До;Емкость;Оператор;Регион
+495;2000000;2009999;10000;ОАО МГТС;Москва
+921;5550000;5559999;10000;ПАО МегаФон;Санкт-Петербург
+999;0000000;0009999;10000;Тест Оператор;Атлантида
@@ -4,26 +4,6 @@
 # A4 design-tooling integration (v2.8 / v3.8 / v1.22)
 iconify

-# lead-region-resolution spec/plan (DaData + Россвязь, 2026-05-29)
-dadata
-rossvyaz
-unmappable
-mnp
-incrby
-deyatelnost
-resurs
-numeracii
-vypiska
-reestra
-sistemy
-plana
-маппингах
-реконсиляция
-сетап
-хелперы
-регэкспом
-резолвом
-
 # Бренд и термины проекта
 лидерра
 liderra
@@ -1994,3 +1974,11 @@ monitorится
 guillemets
 mirror'ящий
 plan'овский
+
+# Lead region resolution (2026-05-31) — DaData / Rossvyaz region detection
+rossvyaz
+россвязь
+россвязи
+dadata
+kopecks
+qc
@@ -2,7 +2,61 @@

 **Назначение:** консолидированный журнал изменений `schema.sql`. Содержит тридцать записей в обратном хронологическом порядке (v8.33 → v8.32 → v8.31 → v8.30 → v8.29 → v8.28 → v8.27 → v8.26 → v8.25 → v8.24 → v8.23 → v8.22 → v8.21 → v8.20 → v8.19 → v8.18 → v8.17 → v8.16 → v8.15 → v8.14 → v8.13 → v8.12 → v8.11 → v8.10 → v8.9 → v8.8 → v8.7 → v8.6 → v8.5 → v8.4 → v8.3 → v8.2), как принято в keep-a-changelog.

-**Файл схемы:** `schema.sql` (текущая версия — v8.39, консолидированная — разворачивает БД с нуля).
+**Файл схемы:** `schema.sql` (текущая версия — v8.40, консолидированная — разворачивает БД с нуля).
+
+## v8.40 (2026-05-31) — lead region resolution (phone_ranges + resolution_log + supplier_leads/deals columns)
+
+Резолюция настоящего региона лида по телефону (DaData → реестр Россвязи → tag-fallback)
+и переключение `LeadRouter` на каскадную маршрутизацию по региону. Эта запись покрывает
+только схемные изменения Session 1 (таблицы и колонки); бизнес-логика — в последующих сессиях.
+
+Спека: `docs/superpowers/specs/2026-05-29-lead-region-resolution-design.md` v0.5.
+План: `docs/superpowers/plans/2026-05-29-lead-region-resolution.md`.
+Миграция: `app/database/migrations/2026_05_31_100000_create_phone_ranges_and_resolution_log.php`.
+
+**Добавлено:**
+
+- **`phone_ranges_imports`** — журнал импортов реестра Россвязи (SaaS-level, без RLS).
+  Поля: `source_url`, `rows_inserted`/`rows_updated`, `checksum_sha256`, `status`
+  (`in_progress`/`completed`/`failed`/`rolled_back`), `error`, `completed_at`.
+  GRANT SELECT `crm_app_user` + `crm_supplier_worker`.
+- **`phone_ranges`** — реестр диапазонов нумерации Россвязи (SaaS-level, без RLS — публичные данные).
+  Поля: `def_code` (код ABC/DEF), `from_num`/`to_num`, `operator`, `region`, `region_normalized`,
+  `subject_code` (1..89), `imported_at`, `import_id`→`phone_ranges_imports`. 3 CHECK
+  (`def_code` 300..999, `subject_code` 1..89, `from_num` ≤ `to_num`). Индекс
+  `idx_phone_ranges_lookup (def_code, from_num, to_num)`. GRANT SELECT `crm_app_user` + `crm_supplier_worker`.
+- **`lead_region_resolution_log`** — PARTITION BY RANGE (`received_at`), composite PK
+  `(id, received_at)`. Аудит резолва региона на лид: `phone_masked`, `subject_code_resolved`/
+  `subject_code_from_tag`, `region_source` (`dadata`/`rossvyaz`/`tag`/`unknown`), `dadata_qc`/
+  `dadata_provider`/`dadata_type`/`dadata_response_masked` (JSONB), `rossvyaz_matched`,
+  `actual_subject_code`/`substituted_subject_code` (1..89), `routing_step` (1..3),
+  `phone_operator`, `cache_hit`, `duration_ms`, `resolved_at`. Индексы `idx_lrrl_lead_id` +
+  `idx_lrrl_source (region_source, received_at)`. GRANT SELECT,INSERT `crm_supplier_worker` /
+  SELECT `crm_app_user`. Стартовые партиции `lead_region_resolution_log_y2026_m05`, `_y2026_m06`.
+- **`MonthlyPartitionManager::PARTITIONED_TABLES`** +entry `'lead_region_resolution_log' => 'received_at'`.
+- **`system_settings`** +key `partition_retention_months_lead_region_resolution_log = '12'` (retention ~365 дней).
+
+**Изменено:**
+
+- **`supplier_leads`** +4 колонки: `resolved_subject_code` (CHECK 1..89), `region_source`
+  (CHECK `dadata`/`rossvyaz`/`tag`/`unknown`), `dadata_qc`, `phone_operator`. Persistent-idempotency
+  резолва (retry не повторяет DaData-вызов).
+- **`deals`** +2 колонки: `phone_operator`, `region_substituted` BOOLEAN NOT NULL DEFAULT FALSE
+  (флаг подмены региона на запасном канале — `routing_step` 3).
+
+**NB консолидация:** как и v8.39 (`project_routing_snapshots`), полный DDL живёт в дельта-миграции,
+а не в теле `schema.sql` — тело отражает последнюю точку консолидации, заголовок/CHANGELOG ведут
+дельты. Свежий деплой: миграция `0001` грузит `schema.sql` → дельта-миграция `2026_05_31` добавляет
+эти объекты. Иначе был бы двойной `CREATE TABLE` (0001 + дельта) и `migrate` упал бы.
+
+**NB GRANT'ы:** план Task 1.3 указывал `crm_readonly`, но этой роли на dev/прод нет —
+фактические GRANT'ы выданы `crm_app_user` + `crm_supplier_worker` (проверено по `pg_roles`).
+
+**NB 152-ФЗ:** `phone_masked` в логе — маскированный телефон (`7XXX***YYYY`), `dadata_response_masked`
+хранит ответ DaData без сырого номера (spec §7.1). Полное `pg_anonymizer`-маскирование —
+шаг раскатки (spec §7.2), вне Session 1.
+
+---

 ## v8.39 (2026-05-27) — project_routing_snapshots (Slepok routing Этап 2)

@@ -1,6 +1,7 @@
 -- =============================================================================
 -- schema.sql — единая схема БД для SaaS-аналога crm.bp-gr.ru («Лидерра»)
-- Версия: v8.39 (27.05.2026 — project_routing_snapshots: новая партиционированная таблица снимков маршрутизации (PARTITION BY RANGE (snapshot_date)), composite PK (snapshot_date, project_id), FK tenant_id→tenants, RLS tenant isolation, MonthlyPartitionManager +entry, retention 3m. Slepok routing Этап 2)
+-- Версия: v8.40 (31.05.2026 — lead region resolution Session 1: phone_ranges_imports + phone_ranges (реестр Россвязи, SaaS-level без RLS, idx_phone_ranges_lookup), lead_region_resolution_log (PARTITION BY RANGE (received_at), composite PK (id, received_at), аудит резолва региона на лид), supplier_leads +4 колонки (resolved_subject_code/region_source/dadata_qc/phone_operator), deals +2 колонки (phone_operator/region_substituted). MonthlyPartitionManager +entry, retention 12m. Миграция 2026_05_31_100000, план docs/superpowers/plans/2026-05-29-lead-region-resolution.md. DDL — в дельта-миграции, не в теле (как v8.39))
+-- Базовая версия: v8.39 (27.05.2026 — project_routing_snapshots: новая партиционированная таблица снимков маршрутизации (PARTITION BY RANGE (snapshot_date)), composite PK (snapshot_date, project_id), FK tenant_id→tenants, RLS tenant isolation, MonthlyPartitionManager +entry, retention 3m. Slepok routing Этап 2)
 -- Базовая версия: v8.38 (26.05.2026 — projects.paused_at TIMESTAMPTZ + projects_paused_at_idx: anchor для SupplierSnapshotGuard. Защита от убытка при удалении/смене источника проекта, пока поставщик может прислать лиды по уже сделанному слепку — docs/superpowers/plans/2026-05-26-supplier-snapshot-guard.md)
 -- Базовая версия: v8.37 (25.05.2026 — supplier_*.platform VARCHAR(4)→VARCHAR(8) + chk_supplier_projects_platform / chk_psl_platform / chk_supplier_leads_platform расширены до IN(B1,B2,B3,DIRECT); +seed suppliers.code='direct'. Phase 3 supplier webhook reliability — приём проектов без B-префикса end-to-end)
 -- Базовая версия: v8.36 (25.05.2026 — supplier_csv_reconcile_log.unparseable_count: учёт мусорных CSV-строк, вычитание из drift-формулы → убирает false-positive drift_alert от телефонов/URL в поле project)
@@ -1,10 +1,7 @@
 {
  "2026-05": {
-    "WIN_USER_PATH": 206,
+    "WIN_USER_PATH": 123,
    "IPV4": 1,
    "RU_PHONE": 1
-  },
-  "2026-06": {
-    "WIN_USER_PATH": 91
  }
 }
@@ -1,5 +1,5 @@
 {
-  "last_read_at": "2026-05-30T12:32:49.927Z",
-  "read_count_last_period": 6,
+  "last_read_at": "2026-05-27T00:53:33.490Z",
+  "read_count_last_period": 5,
  "period_start": "2026-05-19T00:00:00+03:00"
 }
@@ -1,21 +1,21 @@
 # Brain Status (auto-generated)

-Last updated: 2026-06-08T14:07:33.978Z
+Last updated: 2026-06-02T10:14:43.123Z

 | Контролёр | Состояние | Детали |
 |---|---|---|
 | C1 L1-watcher | ✅ | [l1-watcher] OK — 0 drift |
 | C2 Cross-ref consistency | ✅ | [cross-ref-checker] OK — 0 drift in 4 files |
-| C3 Observer-of-observer | ✅ | [observer-of-observer] OK — last read 1 week(s) ago |
+| C3 Observer-of-observer | ✅ | [observer-of-observer] OK — last read 0 week(s) ago |
 | C4 Сигнальный статус | ✅ | This file (self-reference) |
-| C5 Observer-coverage | ✅ | 666 episode(s) this month · Stop-hook + post-commit OK |
+| C5 Observer-coverage | ✅ | 137 episode(s) this month · Stop-hook + post-commit OK |
 | C6 Chain map sync | ✅ | [chain-map-checker] OK — 16 chains in sync |

 ## Метрики (информационные, не алерты)

- Observer evidence: 666 episodes this month, 0 observer_error markers, 88 PII matches before filter
- Legacy v1 episodes (not in factor analysis): 666
- Last /brain-retro: 9 day(s) ago
+- Observer evidence: 137 episodes this month, 0 observer_error markers, 6 PII matches before filter
+- Legacy v1 episodes (not in factor analysis): 137
+- Last /brain-retro: 2 day(s) ago
 - Использование узлов: см. `/brain-retro` (раз в спринт). missed_activations: 0. **Неиспользованные узлы — не алерт, если профильной задачи не было** (Pravila §16.4 v1.36; capability-readiness; см. memory `feedback_brain_unused_tools_not_problem` — outside-repo memory store).

 ## Метрики дисциплины
@@ -24,14 +24,14 @@ Baseline дисциплины роутера (этап 2 router discipline overh

 | Тип задачи | Эпизодов | % с триггер-матчем | % через скил |
 |---|---|---|---|
-| planning | 96 | 10.4% | 13.5% |
-| analysis | 33 | 6.1% | 0.0% |
-| bugfix | 26 | 15.4% | 19.2% |
-| feature | 24 | 12.5% | 4.2% |
+| planning | 16 | 0.0% | 0.0% |
+| feature | 4 | 0.0% | 0.0% |
+| analysis | 2 | 0.0% | 0.0% |
+| bugfix | 1 | 0.0% | 0.0% |

-Router step distribution: 1: 321, 2: 261, 3: 18, 5: 55
+Router step distribution: 1: 81, 2: 51, 5: 4

-Boundaries applied (ADR / границы): 7 of 655 эпизодов (1.1%).
+Boundaries applied (ADR / границы): 1 of 136 эпизодов (0.7%).

 ## Активные многоэтапные проекты

@@ -43,16 +43,22 @@ Boundaries applied (ADR / границы): 7 of 655 эпизодов (1.1%).

 ## Длинные сессии

-Ни одной сессии с >50 ходов сегодня (UTC). ✅
+⚠️ Сегодня (2026-06-02 UTC) есть сессии с ≥50 ходов — корреляция с падением дисциплины роутинга (retro #5 candidate B).
+
+| session_id | макс. ход | % regulated | последний эпизод |
+|---|---|---|---|
+| `1a9888f8` | 50 | 0% | 2026-06-02T01:43:02.824Z |
+
+Long sessions correlate with discipline drift. Если % regulated просел в текущей сессии — рассмотри перезапуск.

 ## Стоимость месяца

 | Компонент | Токены (in/out) | USD |
 |---|---|---|
-| Classifier (Sonnet 4.6) | 41653/183234 | $2.87 |
+| Classifier (Sonnet 4.6) | 10473/50827 | $0.79 |
 | Self-assessment (Sonnet 4.6) | 0/0 | $0.00 |
 | Reviewer (Opus 4.7 + fallback) | 0/0 | $0.00 |
-| **Итого** | | **$2.87** |
+| **Итого** | | **$0.79** |

 ## Аномалии классификатора

@@ -65,7 +71,7 @@ Episodes since last run: 542 / threshold: 10

 ## Reviewer: субагент vs fallback

-0 эпизодов проверено из 666.
+0 эпизодов проверено из 137.

 ## Reviewer findings

@@ -91,8 +97,8 @@ Episodes since last run: 542 / threshold: 10

 | PID | Имя | CPU-время | Возраст |
 |---|---|---|---|
-| 3916 | MsMpEng | 1.99ч | NaNч |
-| 15260 | Code | 1.71ч | 0.0ч |
+| 10388 | Code | 3.05ч | 1327306.2ч |
+| 3220 | MsMpEng | 1.14ч | 0.0ч |

 ⚠️ Проверь, не «осиротевшие» ли это процессы от завершённых Claude-сессий.

@@ -15,13 +15,11 @@
 ## File Structure

 **Create:**
-
 - `app/app/Services/Audit/AuditChainConfig.php` — shared конфиг 6 audit-таблиц (columns + partition_clause). Public const `TABLES`. Helper `rowExpression(string $table): string` для построения `ROW(...)` выражения.
 - `app/tests/Unit/Services/Audit/AuditChainConfigTest.php` — unit-тесты на конфиг (полнота 6 таблиц, корректность ROW expression).
 - `docs/incidents/2026-06-XX-activity-log-y2026-m05-cleanup-handoff.md` — handoff для прод-выкатки финального cleanup'а (Task 7).

 **Modify:**
-
 - `app/app/Console/Commands/VerifyAuditChains.php:98-238` — заменить private `TABLE_CONFIG` const на чтение из `AuditChainConfig::TABLES`. Поведение не меняется (regression-safe refactor).
 - `app/app/Console/Commands/AuditRebuildChain.php:40-218` — заменить private `COLUMN_CONFIG` на `AuditChainConfig`, переписать `handle()` SQL под per-partition_clause logic (через `LAG OVER`).
 - `app/tests/Feature/Audit/AuditRebuildChainTest.php` — добавить 3 новых сценария (multi-tenant / BYPASSRLS table / single-row partition); существующие тесты должны продолжать проходить.
@@ -32,7 +30,6 @@
 ### Task 1: Создать shared AuditChainConfig

 **Files:**
-
 - Create: `app/app/Services/Audit/AuditChainConfig.php`
 - Test: `app/tests/Unit/Services/Audit/AuditChainConfigTest.php`

@@ -217,7 +214,6 @@ git commit -m "feat(audit): extract AuditChainConfig shared TABLE config (ADR-01
 ### Task 2: Перевести VerifyAuditChains на shared config (regression-safe refactor)

 **Files:**
-
 - Modify: `app/app/Console/Commands/VerifyAuditChains.php:96-238` (заменить private const на чтение `AuditChainConfig::TABLES`)
 - Test: `app/tests/Feature/Audit/AuditChainRaceConditionTest.php` (existing — должен продолжать проходить)

@@ -275,7 +271,6 @@ git commit -m "refactor(audit): VerifyAuditChains использует shared Au
 ### Task 3: Failing tests для per-tenant rebuild

 **Files:**
-
 - Modify: `app/tests/Feature/Audit/AuditRebuildChainTest.php` (add 3 scenarios — multi-tenant / BYPASSRLS / single-row)

 - [ ] **Step 1: Добавить multi-tenant test (failing)**
@@ -397,7 +392,6 @@ git commit -m "test(audit): failing tests для per-tenant rebuild (ADR-018, RE
 ### Task 4: Реализовать per-tenant rebuild через LAG OVER

 **Files:**
-
 - Modify: `app/app/Console/Commands/AuditRebuildChain.php` (целиком переписать `handle()` + удалить `COLUMN_CONFIG` + использовать `AuditChainConfig`)

 - [ ] **Step 1: Переписать AuditRebuildChain**
@@ -573,7 +567,6 @@ git commit -m "fix(audit): AuditRebuildChain per-tenant LAG OVER (ADR-018, close
 ### Task 5: Активировать ADR-018 Enforcement rule

 **Files:**
-
 - Modify: `docs/adr/ADR-018-audit-chain-per-tenant-semantics.md` (Enforcement-блок — снять «активируется после имплементации» note + проверить что rule срабатывает)

 - [ ] **Step 1: Обновить Enforcement-блок**
@@ -654,7 +647,6 @@ git commit -m "style(audit): pint auto-fix на shared config + rebuild rewrite"
 ### Task 7: Handoff для прод-выкатки cleanup'а activity_log_y2026_m05

 **Files:**
-
 - Create: `docs/incidents/2026-05-29-audit-rebuild-per-tenant-cleanup-handoff.md`

 - [ ] **Step 1: Создать handoff-док**
@@ -5,7 +5,6 @@
 **Goal:** Remove 5 obsolete v3.9 enforcement hooks and register all 12 active router-gate v4 hooks in `.claude/settings.json` in block-mode, creating 5 thin wrappers for pure modules that still need them.

 **Architecture:** Three layers:
-
 1. **Pure modules** in `tools/<name>.mjs` — already created by streams A-E.
 2. **Thin `enforce-<name>.mjs` wrappers** — stdin event → pure module `decide()` → `exitDecision`. Pattern lifted from existing `tools/enforce-router-gate.mjs:183-204`.
 3. **`.claude/settings.json` registration** — matcher + command path + timeout. Block-mode means `exitDecision({ block: true })` exits with code 2 stopping the originating tool call.
@@ -13,7 +12,6 @@
 **Tech Stack:** Node.js ESM (`.mjs`), `vitest` (jsdom env), `lefthook` pre-commit, `.claude/settings.json` schema `https://json.schemastore.org/claude-code-settings.json`.

 **Reference helpers** (already present in `tools/enforce-hook-helpers.mjs`):
-
 - `readStdin()` — read PreToolUse/PostToolUse/Stop event JSON.
 - `parseEventJson(raw)` — safe JSON.parse with `{}` fallback.
 - `readTranscript(event.transcript_path)` — load JSONL.
@@ -112,7 +110,6 @@ Expected: line with sha + `refs/heads/backup-pre-v4-cleanup`.
 The vocab-based override system is fully removed in v4 (universal vocab removal per spec §4.2). Existing call sites in deleted hooks go away in Task 7; other callers (`enforce-verify-before-push.mjs`, `enforce-tdd-gate.mjs`, `enforce-memory-coverage.mjs`, `enforce-branch-switch.mjs`) still import `findOverride` / `findOverrideAttempt` / `loadOverrideVocab`. We keep these symbols as permanent stubs so non-deleted hooks keep building.

 **Files:**
-
 - Modify: `tools/enforce-hook-helpers.mjs:197-249` (functions `loadOverrideVocab`, `findOverride`, `findOverrideAttempt`)
 - Modify: `tools/enforce-hook-helpers.test.mjs` (drop vocab-dependent assertions, add stub contract tests)

@@ -202,7 +199,6 @@ Wraps `tools/todowrite-skill-verifier.mjs::verifyClaims + hardSyncCheck`. Fires
 **Pattern reference:** `tools/enforce-router-gate.mjs:183-207` (main() shape, fail-CLOSE behaviour). For Stop hooks we use fail-open (`block: false`) because false-positive Stop block would freeze sessions.

 **Files:**
-
 - Create: `tools/enforce-todowrite-skill-verifier.mjs`
 - Create: `tools/enforce-todowrite-skill-verifier.test.mjs`

@@ -337,7 +333,6 @@ git commit -m "feat(router-gate-v4): enforce-todowrite-skill-verifier (Stop hook
 Wraps `tools/tdd-real-test-verifier.mjs::verifyRealTest`. Fires on Edit/Write of a `*.test.*` or `*.spec.*` file. If the test content lacks `expect(...)` / `it(...)` / `test(...)` or covers none of the prod files edited in this session, blocks.

 **Files:**
-
 - Create: `tools/enforce-tdd-real-test-verifier.mjs`
 - Create: `tools/enforce-tdd-real-test-verifier.test.mjs`

@@ -484,7 +479,6 @@ git commit -m "feat(router-gate-v4): enforce-tdd-real-test-verifier (PreToolUse
 Wraps `tools/self-debrief-detector.mjs::detectSelfDebrief`. Fires on mutating tools (Edit|Write|MultiEdit|Bash). Reads transcript; if last controller text matches self-debrief patterns and no `self-retrospect` / `brain-retro` Skill invoked recently — block.

 **Files:**
-
 - Create: `tools/enforce-self-debrief-detector.mjs`
 - Create: `tools/enforce-self-debrief-detector.test.mjs`

@@ -612,7 +606,6 @@ Wraps `tools/mcp-tool-classifier.mjs::classifyMcpTool`. Fires on any `mcp__*` to
 **Pre-step:** Inspect `tools/mcp-tool-classifier.mjs` exported function names (`classifyMcpTool` vs `classify` vs other) — adjust import below if name differs.

 **Files:**
-
 - Create: `tools/enforce-mcp-classification.mjs`
 - Create: `tools/enforce-mcp-classification.test.mjs`

@@ -716,7 +709,6 @@ Wraps `tools/decomposition-detector.mjs::detectDecomposition`. Fires on mutating
 **Pre-step:** Inspect `tools/decomposition-detector.mjs` for the actual function name and signature; adapt below.

 **Files:**
-
 - Create: `tools/enforce-decomposition-detector.mjs`
 - Create: `tools/enforce-decomposition-detector.test.mjs`

@@ -823,7 +815,6 @@ git commit -m "feat(router-gate-v4): enforce-decomposition-detector (PreToolUse
 ## Task 7: Delete 5 v3.9 hooks and the vocab file

 **Files (delete):**
-
 - `tools/enforce-chain-recommendation.mjs`
 - `tools/enforce-chain-recommendation.test.mjs`
 - `tools/enforce-classifier-match.mjs`
@@ -856,7 +847,6 @@ git rm tools/enforce-override-vocab.json
 - [ ] **Step 3: Run full vitest tools suite (must still pass — no orphan references)**

 Run:
-
 ```
 npx vitest run tools/ \
  --exclude='**/worktrees/**' \
@@ -864,7 +854,6 @@ npx vitest run tools/ \
  --exclude='**/subagent-prompt-prefix*' \
  --exclude='**/llm-judge.integration*'
 ```
-
 Expected: all PASS. If any failure references a deleted file — it's a stale import; fix that file by removing the dead import.

 - [ ] **Step 4: Commit**
@@ -886,13 +875,11 @@ Deleted hooks superseded by v4 architecture (spec §4 behavioural pivot):
 ## Task 8: Update `.claude/settings.json` — remove 5 v3.9 regs, add 12 v4 regs in block-mode

 **Files:**
-
 - Modify: `.claude/settings.json`

 **Plan:** Read the current file (already done at planning time — see baseline below), then apply edits via multiple `Edit` tool calls because `settings.json` is JSON (no comments allowed) and the changes are scattered across the `hooks.PreToolUse`, `hooks.PostToolUse`, and `hooks.Stop` arrays.

 **Baseline (current state, lines 39–262):** five v3.9 hook blocks present at:
-
 - PreToolUse[3] (lines 69–78) — `enforce-chain-recommendation` — REMOVE
 - PreToolUse[4] (lines 79–88) — `enforce-override-limit` — REMOVE
 - PreToolUse[7] (lines 119–128) — `enforce-semgrep-security` — REMOVE
@@ -1058,7 +1045,6 @@ Stream G of router-gate v4 deployment, last step before user-run smokes."
 - [ ] **Step 1: Full vitest tools suite**

 Run:
-
 ```
 npx vitest run tools/ \
  --exclude='**/worktrees/**' \
@@ -40,7 +40,6 @@
 ### Task 1: RED tests for skill-body skip + negative tests for non-skill `isMeta`

 **Files:**
-
 - Modify: `tools/enforce-hook-helpers.test.mjs` — add 3 cases at end of `describe('lastTurnEntries / ...')` block.

 - [ ] **Step 1:** Add a new `it()` block "lastTurnEntries skips skill body injections (isMeta + sourceToolUseID)" that constructs an entries array `[user-prompt, assistant+SkillToolUse, skillBody(isMeta=true, sourceToolUseID), assistant+follow-up]` and asserts `lastTurnEntries(entries)` returns starting from `user-prompt` (NOT from skill body).
@@ -54,7 +53,6 @@
 ### Task 2: Implement skill-body skip in lastTurnEntries

 **Files:**
-
 - Modify: `tools/enforce-hook-helpers.mjs` lines 100-115 (`lastTurnEntries` body).

 - [ ] **Step 1:** In the back-walk loop, before checking `e.message.role === 'user'`, add: `if (e && e.isMeta === true && typeof e.sourceToolUseID === 'string') continue;` — this skips skill-body injections (isMeta + tool-spawned) while keeping all other `isMeta:true` cases as valid turn boundaries.
@@ -66,7 +64,6 @@
 ### Task 3: Commit

 **Files:**
-
 - Commit message in `.scratch/sibling-lastturn-fix-msg.txt`.

 - [ ] **Step 1:** Pre-write approval records for:
@@ -0,0 +1,118 @@
+# Lead Region Resolution — прогресс автономного прогона (ночь 31.05.2026)
+
+> Хендофф после автономной ночной сессии. Вся работа **на диске в worktree
+> `worktree-feat+lead-region-resolution`, НЕ закоммичена** (git commit/push требуют
+> approval владельца через гейт — владелец спал). Утром: ревью → коммиты → продолжение.
+
+## Что сделано (Сессии 1–4 — весь движок резолва региона, TDD-зелёный)
+
+| Сессия | Статус | Тесты |
+|---|---|---|
+| **1** Схема (миграция + партиции + schema.sql sync) | ✅ на диске | 9 passed / 27 assert |
+| **2** Россвязь (lookup + DTO + import-команда) | ✅ на диске | 9 passed / 27 assert |
+| **3** DaData (region map + config + enum + client + budget guard) | ✅ на диске | 16 passed / 119 assert |
+| **4** LeadRegionResolver (оркестратор, 16 кейсов каскада) | ✅ на диске | 16 passed / 46 assert |
+| **Консолидированная регрессия** (все файлы вместе) | ✅ | **53 passed / 238 assert** |
+
+### Новые/изменённые файлы
+
+**Создано:**
+- `app/database/migrations/2026_05_31_100000_create_phone_ranges_and_resolution_log.php`
+- `app/app/Services/RossvyazPrefixLookup.php` + `app/app/Services/Dto/RossvyazRecord.php`
+- `app/app/Console/Commands/PhoneRangesImportCommand.php`
+- `app/app/Support/DaDataRegionMap.php`
+- `app/app/Services/DaData/{DaDataQualityCode,DaDataException,DaDataTimeoutException,DaDataPhoneResponse,DaDataPhoneClient,DaDataBudgetGuard}.php`
+- `app/app/Services/Dto/RegionResolution.php`
+- `app/app/Services/LeadRegionResolver.php`
+- Тесты: `tests/Feature/Migrations/PhoneRangesMigrationTest.php`, `tests/Unit/Services/MonthlyPartitionManagerRegionLogTest.php`, `tests/Feature/Services/RossvyazPrefixLookupTest.php`, `tests/Feature/Console/PhoneRangesImportCommandTest.php`, `tests/Unit/Support/DaDataRegionMapTest.php`, `tests/Feature/Services/DaData/{DaDataPhoneClientTest,DaDataBudgetGuardTest}.php`, `tests/Feature/Services/{RegionResolutionTest,LeadRegionResolverTest}.php`
+- `tests/Fixtures/rossvyaz/sample.csv`
+
+**Изменено:**
+- `app/app/Services/MonthlyPartitionManager.php` — +entry `'lead_region_resolution_log' => 'received_at'`
+- `app/app/Models/SupplierLead.php` — +4 колонки в fillable + 2 int-cast
+- `app/config/services.php` — +блок `dadata`
+- `app/tests/Feature/PartitionsCreateMonthsTest.php` — хрупкий хардкод «48 skipped» → динамический `count(PARTITIONED_TABLES) * 6`
+- `db/schema.sql` (v8.39 → **v8.40**, только заголовок) + `db/CHANGELOG_schema.md` (+v8.40)
+
+## Решения, принятые по ходу (для ревью)
+
+1. **Коды субъектов** — по `RussianRegions` (Москва=82, СПб=83, МО=56, ЛО=53), НЕ по спеке (там были авто-коды 77/78/50/47 — неверно).
+2. **GRANT'ы миграции** — `crm_app_user` + `crm_supplier_worker` (роли `crm_readonly` из плана **не существует**).
+3. **`schema.sql`** — только заголовок + CHANGELOG, без тела (как v8.39 project_routing_snapshots): иначе двойной `CREATE TABLE` (0001 грузит schema.sql + дельта-миграция) сломал бы `migrate`.
+4. **Размещение тестов** — app/DB-зависимые тесты (DaData-клиент, budget, resolver, DTO с моделью) лежат в **`tests/Feature/...`, не `tests/Unit/...`** как в плане: в проекте `tests/Unit` не бутит Laravel (нет `Http::fake`/`app()`/`Cache`). Чистый `DaDataRegionMap` остался в Unit.
+5. **`PhoneRangesImportCommand` swap** — atomic RENAME реализован по спеке, но **committing-swap НЕ покрыт автотестом** (RENAME коммитит и сломал бы общую `liderra_testing`, которую ночью без терминала владельца не пересоздать). Тесты покрывают parse/map/dry-run/idempotency/force. **Свап проверяется первым реальным импортом оператора (Session 6 runbook).** Косметика: lookup-индекс на новой таблице после свапа носит имя `idx_phone_ranges_staging_lookup` (имя `idx_phone_ranges_lookup` занято `phone_ranges_old`).
+6. **DaData call cost** — `services.dadata.call_cost_kopecks` дефолт 60 (≈0.60 ₽/вызов) — **прикидка, откалибровать по тарифу DaData**.
+7. **CSV-парсер импорта** — нативный `str_getcsv(';')` (как проект читает файлы); реальный формат Россвязи (заголовки `АВС/ DEF;От;До;Емкость;Оператор;Регион`, возможно cp1251) уточняется оператором на реальном пакете. XLSX-ветка через openspout — **не протестирована**.
+
+## Что осталось (требует владельца)
+
+### Коммиты (утром, через git-approval)
+Предлагаемая разбивка (conventional commits, ветка `worktree-feat+lead-region-resolution`):
+- `feat(region): schema migration + MonthlyPartitionManager registration` (миграция, partition manager, PartitionsCreateMonths fix, SupplierLead model, тесты Session 1)
+- `chore(region): sync db/schema.sql + CHANGELOG (v8.40)`
+- `feat(region): RossvyazPrefixLookup + RossvyazRecord DTO`
+- `feat(region): phone-ranges:import command (parse/map/dry-run/idempotency)`
+- `feat(region): DaData layer (region map, config, enum, client, budget guard)`
+- `feat(region): LeadRegionResolver orchestrator (full qc cascade)`
+
+> NB: коммит-сообщения **без** trailer `Co-Authored-By` — гейт блокирует символ `<` (угловые скобки email). Зафиксировано в `docs/bugs.md`.
+
+### D1 — продуктовое решение ДО Session 5
+Сейчас при >3 кандидатах лид раздаётся **3 случайным** клиентам. Каскад (Session 5) раздаёт 3 клиентам с **наибольшим остатком дневного лимита** (детерминированно) — клиент с большим остатком систематически получает больше лидов. Каскад по конструкции (роутер режет до 3 упорядоченно → `LeadDistributor` не шаффлит) **и есть** эта смена. Нужно подтверждение: убрать random — ок? (Если хочешь сохранить случайность внутри региона — это +1 задача: shuffle внутри каждой фазы перед cap.)
+
+### Session 5 (каскад LeadRouter) + Session 6 (интеграция в Job) — после D1
+- Зависят от D1 + трогают прод-критичный `RouteSupplierLeadJob` (30k лидов/сутки) → делать с ревью, не вслепую.
+- Session 6 Task 6.4 (smoke-команда `phone-region:smoke`) + метрики §8 — отдельно.
+
+### Pre-existing tech debt (не моё, флагую)
+- `tests/Feature/Import/MonthlyPartitionManagerTest.php::ensureMonth создаёт партицию webhook_log` — **красный независимо от меня**: `webhook_log` удалён из проекта 24.05 (миграция `2026_05_24_140000`), тест не обновили. Можно убрать как наследие отдельным мелким фиксом — на твоё усмотрение.
+- `migrate:fresh` на проекте **сломан** (cross-PDO `auth_log` в миграции `0001`): миграция грузит schema.sql на `pgsql`, затем зовёт `partitions:create-months` на `pgsql_supplier` в той же транзакции → невидимость. Тестовая база `liderra_testing` собрана клоном dev (`CREATE DATABASE ... WITH TEMPLATE liderra`), а не через migrate:fresh. Отдельная проблема, вне фичи.
+
+## Как прогнать (из `app/`)
+```
+vendor/bin/pest tests/Feature/Migrations/PhoneRangesMigrationTest.php tests/Unit/Services/MonthlyPartitionManagerRegionLogTest.php tests/Feature/Services/RossvyazPrefixLookupTest.php tests/Feature/Console/PhoneRangesImportCommandTest.php tests/Unit/Support/DaDataRegionMapTest.php tests/Feature/Services/DaData tests/Feature/Services/RegionResolutionTest.php tests/Feature/Services/LeadRegionResolverTest.php
+```
+→ 53 passed / 238 assertions.
+
+---
+
+## ОБНОВЛЕНИЕ 01.06.2026 — Сессии 5–6 реализованы, фича функционально завершена
+
+**D1 решён заказчиком — вариант В** (взвешенный жребий по остатку лимита; мелкие клиенты не отрезаются, вес ≥ 1 у каждого).
+
+| Сессия | Что сделано | Тесты |
+|---|---|---|
+| **5** LeadRouter каскад (exact→all-RF→fallback) + взвешенный жребий (В) + `routing_step` | `LeadRouter` переписан: `matchEligibleProjects($sp, ?int $resolvedSubjectCode)`, `queryCandidates` (region-фильтр + `snap.regions`), `weightedPick`, инъекция `Randomizer`. Хелпер `createRoutingSnapshotFromProject(+regions)`. | 9 cascade + 10 regression |
+| **6.1** Резолв до tx + persist + лог в `RouteSupplierLeadJob` | `app(LeadRegionResolver)->resolve()` (НЕ 7-й параметр handle — чтобы не ломать сигнатуру/тесты), persist 4 колонки, `logRegionResolution` (fail-safe INSERT в журнал через pgsql_supplier, маскированный телефон). | в наборе из 8 |
+| **6.2** Подмена subject_code на шаге 3 + `region_substituted` | `createDealCopyForProject(RegionResolution)`, `routing_step` захватывается до `$lockedProject`, `pickSubstituteRegion(snapshot.regions)`. Deal +`phone_operator`/`region_substituted` (model fillable+cast). | в наборе из 8 |
+| **6.3** CSV-merge по рангу источника | merge-блок обновляет subject_code/phone_operator если webhook-резолв dadata/rossvyaz (выше tag CSV). **Эвристика** — `deals.region_source` нет (документировано). | 2 |
+| **6.4** Smoke-команда `phone-region:smoke` | резолв по телефону без записи в БД. **Метрики §8.1 отложены** (нет механизма Prometheus/StatsD в проекте). | 2 |
+| **6.5** Финальная регрессия + runbook | **101 passed / 509 assertions** (вся фича + регрессия Job ×3 / Router ×2). Runbook раскатки: `docs/superpowers/runbooks/2026-05-31-lead-region-resolution-rollout.md`. | 101 |
+
+### Новые/изменённые файлы Сессий 5–6 (в worktree, не закоммичено)
+- Изменено: `app/app/Services/LeadRouter.php` (каскад + weighted pick + Randomizer), `app/app/Jobs/RouteSupplierLeadJob.php` (resolve+persist+log+substitution+CSV-merge), `app/app/Models/Deal.php` (+2 fillable, +1 cast), `app/tests/Pest.php` (helper +regions).
+- Создано: `app/app/Console/Commands/PhoneRegionSmokeCommand.php`; тесты `LeadRouterCascadeTest.php`, `RouteSupplierLeadJobRegionResolutionTest.php`, `PhoneRegionSmokeCommandTest.php`; runbook.
+
+### Решения Сессий 5–6 (для ревью)
+1. **D1=В** — взвешенный жребий, мелкие не отрезаны (доказано тестом `variant В: weighted pick` — 120 seed'ов, мелкий выигрывает >0 раз, крупный чаще).
+2. **LeadRegionResolver через `app()` внутри `handle()`**, не 7-м параметром — иначе ломались бы сигнатура + 3 существующих Job-теста.
+3. **Лог резолва fail-safe** — сбой записи аудит-лога не роняет доставку лида (30k/сутки).
+4. **`deals.region_source` НЕ добавлялась** — CSV-merge по рангу через эвристику (dadata/rossvyaz > CSV-tag). Отклонение от плана Task 6.3 (план предполагал колонку), задокументировано.
+5. **Метрики §8.1 отложены** — нет механизма метрик в проекте.
+
+### Коммиты Сессий 5–6 (предложение, ветка `worktree-feat+lead-region-resolution`)
+- `test(region): createRoutingSnapshotFromProject accepts regions param`
+- `feat(region): LeadRouter cascade routing (exact→all-RF→fallback) + weighted pick variant В + routing_step`
+- `feat(region): wire LeadRegionResolver into RouteSupplierLeadJob + persist + fail-safe log`
+- `feat(region): step-3 region substitution + CSV-merge by source rank`
+- `feat(region): phone-region:smoke staging command`
+- `docs(region): rollout runbook + session progress`
+
+### Пре-существующий долг (флагую, не моё)
+- `tests/Feature/Console/{BillingMigrateLeadsToRub,IncidentsWatchFailures,SnapshotBackfillCommand}Test` — **взаимно загрязняются** при прогоне в одном процессе (счётчики растут: ожидал 1, получил 4-5). Падают и БЕЗ моих файлов. В реальном CI (`pest --parallel`, файл = процесс) проходят. Тест-изоляция этих команд хрупкая — отдельная задача.
+
+### Команда финальной регрессии (явный список, из `app/`)
+```
+vendor/bin/pest tests/Feature/Migrations/PhoneRangesMigrationTest.php tests/Unit/Services/MonthlyPartitionManagerRegionLogTest.php tests/Feature/Services/RossvyazPrefixLookupTest.php tests/Feature/Console/PhoneRangesImportCommandTest.php tests/Feature/Console/PhoneRegionSmokeCommandTest.php tests/Unit/Support/DaDataRegionMapTest.php tests/Feature/Services/DaData tests/Feature/Services/RegionResolutionTest.php tests/Feature/Services/LeadRegionResolverTest.php tests/Feature/Services/LeadRouterTest.php tests/Feature/Services/LeadRouterCascadeTest.php tests/Feature/Jobs/RouteSupplierLeadJobRegionResolutionTest.php tests/Feature/Jobs/RouteSupplierLeadJobTest.php tests/Feature/Jobs/RouteSupplierLeadJobSnapshotTest.php tests/Feature/Supplier/RouteSupplierLeadJobBillingTest.php
+```
+→ 101 passed / 509 assertions.
@@ -0,0 +1,61 @@
+# Россвязь region→subject_code mapping fix — Implementation Plan
+
+> **For agentic workers:** TDD, bite-sized steps. Steps use `- [ ]`.
+
+**Goal:** Маппить регион из реестра Россвязи в `subject_code` через нормализацию форматов, чтобы перестать терять ~98% диапазонов (444904/453080 были NULL из-за exact-match).
+
+**Architecture:** Чистый нормализатор в `App\Support\RussianRegions` (`canonicalRegionName` + `resolveSubjectCode`), unit-тестируемый без БД. `PhoneRangesImportCommand` зовёт его и заполняет `region_normalized`. Прод перечитывает реестр командой `phone-ranges:import` после мержа.
+
+**Tech Stack:** PHP 8.3 / Laravel 13 / Pest 4 / PostgreSQL 16.
+
+---
+
+## Корень проблемы (systematic-debugging Phase 1, подтверждён прод-данными)
+
+`PhoneRangesImportCommand` делал `RussianRegions::nameToCode()[trim($rec['region'])]` — exact match. Реальные строки реестра (топ-50 unmapped, прод 02.06.2026):
+
+- `г. Москва` (253342) / `г. Санкт-Петербург` (34573) — города фед. значения с префиксом `г. `
+- `г. Оренбург|Оренбургская обл.` — регион = **последний** сегмент после `|`, область сокращена `обл.`
+- `г. Воскресенск|р-н Воскресенский|Московская обл.` — 3 сегмента, регион = последний
+- `г. Ижевск|Республика Удмуртская` — порядок слов перевёрнут (канон `Удмуртская Республика`)
+- `г. Кемерово|Кемеровская область - Кузбасс обл.` — спец-форма
+- Безнадёжные (меньшинство, остаются NULL): `-`, `Российская Федерация`, `Москва и Московская область` (неоднозначно), `г.о. Тольятти` / `г.о. город Уфа` (нет региона в строке)
+
+## Правила нормализации
+
+1. Взять последний сегмент после `|`, trim.
+2. Прямые алиасы (приоритет): `г. Москва`→`Москва`, `г. Санкт-Петербург`→`Санкт-Петербург`, `г. Севастополь`→`Севастополь`, `Республика Удмуртская`→`Удмуртская Республика`, `Кемеровская область - Кузбасс обл.`→`Кемеровская область`.
+3. Иначе: суффикс ` обл.` → ` область`.
+4. Результат искать в `nameToCode()`. Нет → `null` (диапазон остаётся unmapped — корректно).
+
+---
+
+## Task 1: `RussianRegions::canonicalRegionName` + `resolveSubjectCode`
+
+**Files:**
+- Modify: `app/app/Support/RussianRegions.php`
+- Test: `app/tests/Unit/Support/RussianRegionsTest.php`
+
+- [ ] Step 1: написать падающий unit-тест (кейсы: фед.города с `г. `, `обл.`→`область`, многосегментный pipe, переворот Удмуртии, Кузбасс-алиас, безнадёжные→null, чистое каноничное имя).
+- [ ] Step 2: запустить pest → RED (метод не существует).
+- [ ] Step 3: реализовать `lastSegment` (private), `ALIASES` (const), `canonicalRegionName(string): ?string`, `resolveSubjectCode(string): ?int`.
+- [ ] Step 4: pest → GREEN.
+- [ ] Step 5: commit.
+
+## Task 2: wire команды импорта + `region_normalized`
+
+**Files:**
+- Modify: `app/app/Console/Commands/PhoneRangesImportCommand.php:103-116`
+- Modify: `app/tests/Feature/Console/PhoneRangesImportCommandTest.php`
+- Modify: `app/tests/Fixtures/rossvyaz/sample.csv` (добавить грязные строки)
+
+- [ ] Step 1: добавить в fixture строки с реальными форматами (`г. Москва`, `г. Оренбург|Оренбургская обл.`, `г. Ижевск|Республика Удмуртская`, `г.о. Тольятти`).
+- [ ] Step 2: расширить command-тест: проверить, что грязные строки маппятся в правильные коды, безнадёжные → NULL, `region_normalized` заполнен.
+- [ ] Step 3: pest → RED.
+- [ ] Step 4: команда зовёт `RussianRegions::canonicalRegionName` + `nameToCode`, пишет `region_normalized`.
+- [ ] Step 5: pest → GREEN (весь файл).
+- [ ] Step 6: commit + push + PR.
+
+## После мержа
+
+Владелец запускает на проде через `artisan-run.yml` (mutating, confirm_apply): `phone-ranges:import --dir=<пакет> --force` — перечитывает реестр с новым маппингом. Будущие лиды резолвятся через Россвязь-fallback → меньше пустого «Город».
@@ -0,0 +1,81 @@
+# Lead Region Resolution — runbook раскатки на прод
+
+> Фича: определение настоящего региона лида по телефону (DaData → реестр Россвязи →
+> tag-fallback) + каскадная маршрутизация по региону. Код реализован и зелёный
+> (Сессии 1-6, TDD). Этот runbook — порядок выкатки оператором на `liderra.ru`.
+> Spec: `docs/superpowers/specs/2026-05-29-lead-region-resolution-design.md` v0.5.
+> Plan: `docs/superpowers/plans/2026-05-29-lead-region-resolution.md`.
+
+## Решение D1 (зафиксировано заказчиком 01.06.2026)
+
+**Вариант В** — внутри каждой ступени каскада при >3 претендентах лид раздаётся
+**взвешенным жребием по остатку дневного лимита**: шанс ∝ остатку, но у каждого
+кандидата шанс > 0 (вес ≥ 1) — маленькие клиенты не отрезаются. Реализовано в
+`LeadRouter::weightedPick` (вес `max(1, snapshot_daily_limit − delivered_today)`).
+
+## Предусловия
+
+- `DADATA_API_KEY` + `DADATA_SECRET` — завести в **YC Lockbox** (НЕ в git/.env репозитория).
+  Прокинуть в окружение прод-воркеров (`DADATA_API_KEY`, `DADATA_SECRET`).
+- Feature-flag `LEAD_REGION_RESOLVER_ENABLED` (по умолчанию `false` → текущее tag-поведение).
+- Бюджет: `DADATA_DAILY_CAP_RUB` (дефолт 10000), `DADATA_CALL_COST_KOPECKS` (дефолт 60 —
+  **откалибровать по фактическому тарифу DaData** после первого дня).
+
+## Порядок выкатки
+
+1. **Миграция БД.** Накатить `2026_05_31_100000_create_phone_ranges_and_resolution_log`
+   (создаёт `phone_ranges`, `phone_ranges_imports`, `lead_region_resolution_log` +
+   колонки в `supplier_leads`/`deals`). Партиции журнала на старте — m05/m06; далее
+   их подхватывает `partitions:create-months` (уже зарегистрирован в `MonthlyPartitionManager`).
+   - На проде миграция делает `SET ROLE crm_migrator` (паттерн проекта).
+2. **Импорт реестра Россвязи.** Скачать пакет выписок с
+   `rossvyaz.gov.ru/deyatelnost/resurs-numeracii/...` (~500-600 файлов) в каталог,
+   затем `php artisan phone-ranges:import --dir=<каталог>`.
+   - **NB парсер:** ожидает CSV `;`-разделитель, колонки `АВС/ DEF;От;До;Емкость;Оператор;Регион`.
+     Реальные файлы Россвязи могут быть в cp1251 / иметь другие заголовки — сверить на
+     первом импорте; при расхождении поправить `resolveColumns()` (это и есть первая
+     боевая валидация — автотест покрывает CSV-фикстуру, не реальный формат).
+   - **NB swap:** atomic RENAME (`phone_ranges` → `_old`, staging → `phone_ranges`) НЕ
+     покрыт автотестом (коммитящий RENAME сломал бы общую тестовую БД). **Этот импорт —
+     первая боевая проверка свапа.** Сначала прогнать `--dry-run` (staging без свапа),
+     проверить `phone_ranges_staging` глазами, потом без `--dry-run`. Откат:
+     `phone-ranges:rollback` (см. spec §6.4 — команда отката пока не реализована,
+     при необходимости — ручной RENAME `phone_ranges_old` обратно).
+3. **Деплой кода с `LEAD_REGION_RESOLVER_ENABLED=false`.** Резолвер выключен →
+   поведение идентично текущему (tag-fallback). Каскад работает (но без точного
+   региона, т.к. `resolved_subject_code=null` → шаг 2 «вся РФ» как раньше).
+4. **Smoke на staging/проде:** `php artisan phone-region:smoke --phone=79161234567`
+   (с реальным ключом — платный вызов, в БД не пишет). Проверить, что DaData отвечает,
+   регион/оператор резолвятся, Россвязь-fallback находит префиксы. Прогнать §9.4 — ~100
+   реальных prod-номеров, сверить распределение источников.
+5. **Включить флаг (сразу 100%):** `LEAD_REGION_RESOLVER_ENABLED=true`. Рубильник
+   глобальный — резолвер включается сразу для **всего** потока лидов. **Долевую
+   (постепенную) раскатку НЕ делаем** (решение заказчика 01.06.2026): никакого
+   `hash(phone) % 100`-гейта не вводим, фича идёт на 100% с первого включения.
+6. **Мониторинг 1 день:** `lead_region_resolution_log` — распределение `region_source`
+   (ожидание: dadata большинство, tag < 20%, unknown < 5% — spec §8.2). Проверить
+   `DADATA_DAILY_CAP_RUB` не упирается. Откалибровать `DADATA_CALL_COST_KOPECKS`.
+7. **Штатный режим:** фича уже работает на 100% потока (с шага 5) — долевого гейта нет,
+   убирать нечего. Единственный рычаг управления — флаг `LEAD_REGION_RESOLVER_ENABLED`.
+8. **Ежемесячный cron** импорта реестра (`phone-ranges:import`, 4-е число 03:00 МСК —
+   spec §6.3) — добавить в планировщик/`artisan-run`.
+
+## Откат
+
+- Мгновенный: `LEAD_REGION_RESOLVER_ENABLED=false` → резолвер возвращает tag-fallback,
+  каскад ведёт себя как до фичи. Код деплоить заново не нужно.
+- Реестр: `phone_ranges_old` хранит предыдущую версию (ручной RENAME при проблеме импорта).
+
+## Что отложено (followups, не блокируют ядро)
+
+- **Метрики §8.1** (`phone_resolution.source.*` и т.д.) — в проекте нет механизма
+  Prometheus/StatsD; отложено до его появления.
+- **Долевая (постепенная) раскатка** — **НЕ делаем** (решение заказчика 01.06.2026):
+  фича включается сразу на 100%, `hash(phone)%100`-гейт не вводится.
+- **`phone-ranges:rollback`** — команда отката свапа (spec §6.4) не реализована.
+- **`deals.region_source`** — не добавлялась (по спеке регион-источник живёт на
+  `supplier_leads` + в журнале). CSV-merge (§3.12) обновляет регион сделки по
+  эвристике «webhook dadata/rossvyaz > CSV-tag», без хранения source на сделке.
+- **pg_anonymizer-маски (§7.2)** на `lead_region_resolution_log` — при настройке масок дампов.
+- **152-ФЗ:** телефон в журнале маскирован (`7XXX***YYYY`), `dadata_response_masked`
+  без сырого номера — базовое покрытие есть; полный аудит ПДн — через `pdn-152fz-audit`.
@@ -146,16 +146,6 @@ const SAFE_EXACT = [
  // → cwd-shift read-bypass stays contained (protected files also remain blocked by name
  // in the command). cd into Документация/system/protected dirs → default-deny.
  /^cd\s+(?=.*[\\/](?:worktree-|v4-stream-))(?!.*(?:\.\.|\.claude|\.ssh|\.env|runtime|\.git)).+$/,
-  // graphify read-only subcommands (#86, §5 п.14, owner-authorized 2026-06-08).
-  // Only query/explain/path — extract/update/build/export/hook/clone/add/merge stay
-  // default-deny. The bare \b form is safe: injection vectors are neutralized BEFORE the
-  // whitelist sees them — chains split into per-segment whitelist checks (an injected
-  // `; id` segment is not whitelisted → block), subshells `$(...)`/backtick are blocked by
-  // the tokenizer, redirects by the hard-blacklist, and $VAR is var-expanded by the
-  // tokenizer (not an injection vector for a read-only query arg). End-anchoring with a
-  // charset would reject Unicode query strings (tokenizer strips quotes → Cyrillic args
-  // arrive as barewords) for no security gain. (security review 2026-06-08 — false-positive)
-  /^graphify\s+(?:query|explain|path)\b/,
 ];

 export function classifyWhitelist(segments) {
@@ -241,39 +241,6 @@ describe('SAFE_EXACT — Laravel dev workflow (whitelist expansion 2026-05-30)',
    expect(classifyBashCommand('composer show', {}).result).toBe('allow');
    expect(classifyBashCommand('composer outdated', {}).result).toBe('allow');
  });
-
-  // graphify read-only subcommands (owner-authorized 2026-06-08 — #86 graphify, §5 п.14)
-  it('allows graphify read-only subcommands (query/explain/path)', () => {
-    expect(classifyBashCommand('graphify query "x"', {}).result).toBe('allow');
-    expect(classifyBashCommand('graphify explain "Node"', {}).result).toBe('allow');
-    expect(classifyBashCommand('graphify path "A" "B"', {}).result).toBe('allow');
-  });
-
-  // graphify mutating/expensive subcommands stay default-deny
-  it('still blocks graphify mutating subcommands (extract/export/hook)', () => {
-    expect(classifyBashCommand('graphify extract .', {}).result).toBe('block');
-    expect(classifyBashCommand('graphify export html', {}).result).toBe('block');
-    expect(classifyBashCommand('graphify hook install', {}).result).toBe('block');
-  });
-
-  // graphify allowlist is not bypassable via chained commands / subshells — they are
-  // caught by the gate architecture BEFORE the whitelist regex (per-segment whitelist +
-  // tokenizer subshell-block + redirect hard-blacklist), so the simple subcommand
-  // allowlist is safe (security review 2026-06-08 finding = false-positive: $VAR is
-  // var-expanded away by the tokenizer, not a command-injection vector).
-  it('blocks graphify chained commands and subshell payloads', () => {
-    expect(classifyBashCommand('graphify query x; id', {}).result).toBe('block');
-    expect(classifyBashCommand('graphify query x && rm y', {}).result).toBe('block');
-    expect(classifyBashCommand('graphify path A `id`', {}).result).toBe('block');
-    expect(classifyBashCommand('graphify query x | sh', {}).result).toBe('block');
-  });
-
-  // legit read-only graphify with quoted (Cyrillic) question + flags still allowed —
-  // guards against over-tightening that would reject Unicode queries (tokenizer strips
-  // quotes → Cyrillic args arrive as barewords).
-  it('still allows graphify query with quoted question and flags', () => {
-    expect(classifyBashCommand('graphify query "конфликт дубль" --dfs --budget 1500', {}).result).toBe('allow');
-  });
 });

 describe('SAFE_EXACT — narrow `cd app` whitelist (2026-05-31, owner-authorized)', () => {
@@ -1,43 +0,0 @@
-#!/usr/bin/env node
-/**
- * receipt-key-config — резолв HMAC-ключа подписи расписок роутер-наставника.
- * Зеркало llm-judge-config.mjs: keychain (service router-mentor-receipts) → env → null.
- * Ключ провижинит владелец (как LLM-ключ судьи). Без ключа — null → подпись невозможна
- * → неподписанная расписка невалидна (fail-closed на стороне verifyReceipt).
- */
-import { createRequire } from 'node:module';
-
-const KEY_ENV = 'ROUTER_MENTOR_RECEIPT_KEY';
-const KEYCHAIN_SERVICE = 'router-mentor-receipts';
-const KEYCHAIN_ACCOUNT = 'default';
-
-/**
- * @param {object} [args]
- * @param {object} [args.env]          - окружение (default process.env)
- * @param {Function} [args.keychainGet] - () => string|null (инъекция для тестов)
- * @returns {string|null}
- */
-export function resolveReceiptKey({ env = process.env, keychainGet = defaultKeychainGet } = {}) {
-  let chainKey = null;
-  try {
-    const v = keychainGet();
-    chainKey = v ? String(v) : null;
-  } catch {
-    chainKey = null;
-  }
-  const envKey = env[KEY_ENV] ? String(env[KEY_ENV]) : null;
-  return chainKey || envKey || null;
-}
-
-/** Lazy keytar-ридер; null если keytar отсутствует или записи нет. Никогда не бросает. */
-export function defaultKeychainGet() {
-  try {
-    const require = createRequire(import.meta.url);
-    const keytar = require('keytar');
-    return (keytar.getPasswordSync?.(KEYCHAIN_SERVICE, KEYCHAIN_ACCOUNT)) || null;
-  } catch {
-    return null;
-  }
-}
-
-export const _internals = { KEY_ENV, KEYCHAIN_SERVICE, KEYCHAIN_ACCOUNT };
@@ -1,25 +0,0 @@
-// tools/receipt-key-config.test.mjs
-import { describe, it, expect } from 'vitest';
-import { resolveReceiptKey } from './receipt-key-config.mjs';
-
-describe('resolveReceiptKey', () => {
-  it('returns keychain key when present', () => {
-    const r = resolveReceiptKey({ env: {}, keychainGet: () => 'k-from-chain' });
-    expect(r).toBe('k-from-chain');
-  });
-  it('falls back to env ROUTER_MENTOR_RECEIPT_KEY when keychain empty', () => {
-    const r = resolveReceiptKey({ env: { ROUTER_MENTOR_RECEIPT_KEY: 'k-env' }, keychainGet: () => null });
-    expect(r).toBe('k-env');
-  });
-  it('prefers keychain over env', () => {
-    const r = resolveReceiptKey({ env: { ROUTER_MENTOR_RECEIPT_KEY: 'k-env' }, keychainGet: () => 'k-chain' });
-    expect(r).toBe('k-chain');
-  });
-  it('returns null when neither present', () => {
-    expect(resolveReceiptKey({ env: {}, keychainGet: () => null })).toBe(null);
-  });
-  it('never throws when keychainGet throws → null', () => {
-    const r = resolveReceiptKey({ env: {}, keychainGet: () => { throw new Error('boom'); } });
-    expect(r).toBe(null);
-  });
-});
Author	SHA1	Message	Date
Дмитрий	0bf69ce6b5	chore(lead-region-ops): add force input for phone-ranges:import Re-import skips on identical checksum without --force. Adds a 'force' boolean dispatch input wired into the import op so the registry can be re-mapped after the region-normalization fix (PR #44).	2026-06-03 06:12:43 +03:00
CoralMinister	07747713f0	Merge pull request #44 from CoralMinister/feat/rossvyaz-region-mapping Feat/rossvyaz region mapping	2026-06-02 15:42:37 +03:00
Дмитрий	c6d2df908a	feat(rossvyaz): wire region normalizer into import + fill region_normalized PhoneRangesImportCommand now resolves subject_code via RussianRegions::canonicalRegionName (pipe segment + обл./alias normalization) and persists region_normalized. messy.csv fixture covers real prod formats (3-digit DEF codes per chk_phone_ranges_def_code). 5/5 command tests GREEN.	2026-06-02 15:39:35 +03:00
Дмитрий	d4ade05446	feat(rossvyaz): normalize registry region names to subject_code RussianRegions::canonicalRegionName + resolveSubjectCode: take last pipe segment, expand обл.->область, alias federal cities / Удмуртская / Кузбасс. Fixes 98% unmapped phone_ranges (exact-match -> normalized). Unit-tested.	2026-06-02 15:22:24 +03:00
CoralMinister	bd7b1d3e0f	Merge pull request #43 from CoralMinister/feat/deals-city-region Feat/deals city region	2026-06-02 13:48:18 +03:00
CoralMinister	57e9541775	Merge pull request #42 from CoralMinister/feat/gate-allow-worktree-cd Feat/gate allow worktree cd	2026-06-02 13:47:47 +03:00
Дмитрий	e213f9b01c	feat(deals): backfill command for «Город» on existing deals deals:backfill-region-city fills deals.city from the lead resolved_subject_code (deals -> supplier_lead_deliveries -> supplier_leads) for deals where city is still empty, idempotently and across all tenants (BYPASSRLS). --dry-run reports the count without writing. Whitelisted in artisan-run.yml (dry-run read-only; real run requires confirm_apply). TDD: +4 tests GREEN. Co-Authored-By: Claude Opus 4.8 (1M context) <noreply@anthropic.com>	2026-06-02 13:38:10 +03:00
Дмитрий	1609faee8c	feat(deals): fill «Город» (deals.city) with resolved region name The UI «Город» column binds to deals.city but nothing ever populated it — the region was only stored as a numeric code on supplier_leads + the resolution log. RouteSupplierLeadJob now writes the resolved subject name (RussianRegions::CODE_TO_NAME) into deals.city on deal creation (the lead's real region, even if subject_code is substituted on routing step 3), and updates it in the CSV-merge branch when the webhook resolution outranks the tag. New deals now display the region. TDD: +2 tests in RouteSupplierLeadJobTest; 24 job tests GREEN. Co-Authored-By: Claude Opus 4.8 (1M context) <noreply@anthropic.com>	2026-06-02 13:16:31 +03:00
CoralMinister	237eae7ee0	Merge pull request #41 from CoralMinister/feat/gate-dev-prod-rescope Feat/gate dev prod rescope	2026-06-02 09:41:03 +03:00
CoralMinister	34b85cf5cc	Add files via upload	2026-06-02 08:11:37 +03:00
CoralMinister	e2c00d60b1	Add files via upload	2026-06-01 19:07:51 +03:00
CoralMinister	97938c66b2	Add files via upload	2026-06-01 18:48:18 +03:00
CoralMinister	9c8db287ad	Add files via upload	2026-06-01 18:11:59 +03:00
CoralMinister	b404bf41a8	Add files via upload	2026-06-01 18:10:26 +03:00
CoralMinister	d821bfb235	Add files via upload	2026-06-01 18:05:01 +03:00
CoralMinister	cc149f324d	Add files via upload	2026-06-01 18:01:02 +03:00
CoralMinister	6bd2735973	Add files via upload	2026-06-01 16:26:02 +03:00
CoralMinister	8c50c6db52	Add files via upload	2026-06-01 16:10:59 +03:00
CoralMinister	2000985208	Add files via upload	2026-06-01 14:15:34 +03:00
CoralMinister	544c06a790	Add files via upload	2026-06-01 13:49:51 +03:00
CoralMinister	c67c217e43	Add files via upload	2026-06-01 11:10:06 +03:00
CoralMinister	a24d084c24	Merge pull request #30 from CoralMinister/worktree-feat+lead-region-resolution Worktree feat+lead region resolution	2026-06-01 10:51:31 +03:00
Дмитрий	1107979168	chore(region): add cspell dictionary terms (DaData/Rossvyaz)	2026-06-01 07:39:43 +03:00
Дмитрий	849e467924	fix(region): wrap phone_ranges swap in a transaction + drop stray comment (code-review)	2026-06-01 07:32:15 +03:00
Дмитрий	c959c03f55	docs(region): rollout runbook + session progress	2026-06-01 07:21:24 +03:00
Дмитрий	893a142812	feat(region): phone-region:smoke staging command	2026-06-01 07:21:15 +03:00
Дмитрий	dae2085ea0	feat(region): RouteSupplierLeadJob — resolve region + persist + fail-safe log + step-3 substitution + CSV-merge	2026-06-01 07:21:08 +03:00
Дмитрий	048f3ad6a2	feat(region): Deal — region_substituted + phone_operator fields	2026-06-01 07:21:01 +03:00
Дмитрий	8be1db34b8	feat(region): LeadRouter cascade routing (exact→all-RF→fallback) + weighted pick variant В + routing_step	2026-06-01 07:19:54 +03:00
Дмитрий	9e05d8f728	test(region): createRoutingSnapshotFromProject accepts regions param	2026-06-01 07:19:46 +03:00
Дмитрий	4bb94257cf	feat(region): LeadRegionResolver orchestrator (full qc cascade)	2026-06-01 07:19:37 +03:00
Дмитрий	b91b6d5008	feat(region): DaData layer (region map, config, enum, client, budget guard)	2026-06-01 07:19:29 +03:00
Дмитрий	b822042a66	feat(region): phone-ranges:import command (parse/map/dry-run/idempotency)	2026-06-01 07:18:23 +03:00
Дмитрий	b25aa025e4	feat(region): RossvyazPrefixLookup + RossvyazRecord DTO	2026-06-01 07:18:17 +03:00
Дмитрий	635d631eae	chore(region): sync db/schema.sql + CHANGELOG (v8.40)	2026-06-01 07:18:09 +03:00
Дмитрий	ec21971888	feat(region): schema migration + MonthlyPartitionManager registration	2026-06-01 07:12:08 +03:00