docs(ПИЛОТ): снимок 19.06 — G1-G7 выкачены на боевой liderra.ru, метод/грабли/бэкапы

Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>

.github/workflows/artisan-run.yml

@@ -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."

.github/workflows/lead-region-ops.yml

@@ -0,0 +1,393 @@
+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
+      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 }}
+      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
+          ssh -i ~/.ssh/liderra_deploy "${LIDERRA_USER}@${LIDERRA_HOST}" \
+            "APP_DIR='$APP_DIR' DIR='$DIR' DRY_FLAG='$DRY_FLAG' bash -s" <<'REMOTE' | tee /tmp/op.log
+            set -e
+            cd "$APP_DIR"
+            echo "=== phone-ranges:import --dir=${DIR} ${DRY_FLAG} ==="
+            sudo -u www-data php artisan phone-ranges:import --dir="$DIR" $DRY_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

.gitignore

@@ -47,6 +47,16 @@ demo-*.jpeg
 # gitleaks
 gitleaks-report.json
 
+# ward (security-сканер) — отчёты в корне
+ward-report.*
+lychee-links-report.txt
+walk-*.png
+
+# ZAP active scan — сырые отчёты (анализ коммитится как .md, сырьё локально:
+# может содержать снимки ответов dev-приложения)
+docs/security/*-zap-active-scan.json
+docs/security/*-zap-active-scan.html
+
 # ── IDE / редакторы ─────────────────────────────────────────────────────────
 .vscode/*
 !.vscode/extensions.json
@@ -129,6 +139,7 @@ c--Users-*/
 # ── Временные файлы ─────────────────────────────────────────────────────────
 *.tmp
 *.bak
+.mcp.json.bak-*
 *.log
 tmp/
 .tmp/
@@ -202,3 +213,14 @@ ruflo-mcp-stderr.log
 .claude/commands/*
 !.claude/commands/security-review.md
 .claude/helpers/
+
+# ── Локальные бэкапы settings.json + эталон-снимки (M7 canon backups, local-only) ──
+.claude/arh settings/
+.claude/settings - *.json
+.claude/settings эталон*.json
+.claude/эталон/
+.claude/scheduled_tasks.lock
+/settings.json
+settings copy.json
+# Строчный Ctemp-дамп (CTemp* выше не ловит из-за регистра)
+Ctemp*

.gitleaks.toml

@@ -89,10 +89,17 @@ paths = [
   '''app/tests/.*\.php''',
   # Database seeders с демо-данными (admin@demo.local + +7916123XXXX демо-телефоны)
   '''app/database/seeders/.*\.php''',
+  # Database factories — генераторы тестовых фикстур (фейковые телефоны/ИНН,
+  # напр. TenantFactory::withRequisites +79150000000), не реальные ПДн. Та же
+  # категория, что seeders/tests.
+  '''app/database/factories/.*\.php''',
   # Audit-internal docs (findings/blocked/report/plan) — содержат демо-телефоны и
   # script-смешанные artifacts как finding'и для review (не реальные ПДн)
   '''docs/superpowers/audits/.*\.md''',
   '''docs/superpowers/plans/.*\.md''',
+  # Internal design specs — внутренние проектные доки с демо-данными (демо-телефоны
+  # в примерах, напр. spec про log-PII-scrubbing), не реальные ПДн. Как plans/audits.
+  '''docs/superpowers/specs/.*\.md''',
   # Mock-данные для UI-разводки фронтенда (фиктивные имена/телефоны)
   '''app/resources/js/composables/mockDeals\.ts''',
   # Vitest-тесты с assertion на mock-данные (mock-телефоны из mockDeals)
@@ -101,7 +108,10 @@ paths = [
   '''app/resources/js/views/settings/.*\.vue''',
   # Test fixtures for the observer PII filter — contains synthetic JWT / AWS /
   # Yandex tokens that the filter is supposed to redact. Not real secrets.
-  '''tools/observer-pii-filter\.test\.mjs'''
+  '''tools/observer-pii-filter\.test\.mjs''',
+  # Test fixture for the secret-scanner / read-path-deny (M5) — PEM-header marker +
+  # AWS EXAMPLE key, used to verify detection. Not a real key; file deleted in brain split.
+  '''tools/enforce-read-path-deny\.test\.mjs'''
 ]
 regexTarget = "match"
 regexes = [

.lychee.toml

@@ -54,8 +54,9 @@ exclude = [
   # Sample/примерные адреса
   "^https?://example\\.com",
   "^https?://example\\.org",
-  # Приватный репозиторий проекта (404 для анонимных запросов — это норма)
-  "^https?://github\\.com/CoralMinister/liderra",
+  # Покойный GitHub-аккаунт CoralMinister (suspended) — все ссылки на него мертвы:
+  # исторические compare/actions-runs в ПИЛОТ.md / handoffs / plans. Бэкап теперь Gitea.
+  "^https?://github\\.com/CoralMinister/",
   # web/v8/*.html — статические концепты, root-relative ссылки на будущие маршруты Vue
   "^/(login|register|legal|dashboard|deals|admin|reports|reminders|billing|impersonation|notifications)(/|$|\\?)",
   # Корневой `/` в концептах (логотип-якорь для будущей главной)

.markdownlintignore

@@ -6,3 +6,4 @@ CLAUDE.md
 .claude/skills/ccpm/
 .claude/skills/data-scientist/
 .claude/skills/marketingskills/
+docs/superpowers/

.mcp.json

@@ -54,6 +54,31 @@
       },
       "comment": "A3 integration-tooling #47 — OpenAPI MCP (ivo-toby/mcp-openapi-server, @ivotoby/openapi-mcp-server v1.14.0, MIT). Exposes Лидерра REST API endpoints (docs/api/openapi.yaml) as MCP tools. Config via env-vars API_BASE_URL + OPENAPI_SPEC_PATH (stdio transport default). READ scope: API discovery/introspection for Claude Code. Формализован в Tooling §4.22, PSR_v1 R10.1 блок 3, Pravila §13.2."
     },
+    "perplexity": {
+      "command": "npx",
+      "args": ["-y", "@perplexity-ai/mcp-server"],
+      "env": {
+        "PERPLEXITY_API_KEY": "${PERPLEXITY_API_KEY}",
+        "PERPLEXITY_BASE_URL": "https://api.aitunnel.ru/v1"
+      },
+      "comment": "research-tooling (Perplexity Pack) #87 — research-канал. Официальный @perplexity-ai/mcp-server (репо perplexityai/modelcontextprotocol), MIT, подписанная сборка. Tools: perplexity_search/ask/research/reason (sonar-*). ПЛАТНЫЙ API; ключ PERPLEXITY_API_KEY только в user env (не в репо). Вет ПРИНЯТ — docs/research/research-vet.md. Перенос plan-v13 2026-06-14 (owner waiver, Вариант 2)."
+    },
+    "exa": {
+      "command": "npx",
+      "args": ["-y", "exa-mcp-server"],
+      "env": {
+        "EXA_API_KEY": "${EXA_API_KEY}"
+      },
+      "comment": "research-tooling (Perplexity Pack) #88 — Exa нейро/семантический поиск. exa-mcp-server (репо exa-labs), MIT (license-поле npm пусто — см. вет). Tools: web_search_exa / web_fetch_exa (default). ПЛАТНЫЙ API; ключ EXA_API_KEY только в user env. Вет ПРИНЯТ — docs/research/research-vet.md."
+    },
+    "firecrawl": {
+      "command": "npx",
+      "args": ["-y", "firecrawl-mcp"],
+      "env": {
+        "FIRECRAWL_API_KEY": "${FIRECRAWL_API_KEY}"
+      },
+      "comment": "research-tooling (Perplexity Pack) #89 — Firecrawl глубокое чтение/обход. firecrawl-mcp (репо firecrawl/firecrawl-mcp-server), MIT, очень активен. Tools: scrape/crawl/extract + firecrawl_agent. ПЛАТНЫЙ API; ключ FIRECRAWL_API_KEY только в user env. Вет ПРИНЯТ — docs/research/research-vet.md."
+    },
     "_disabled_marketing_servers_note": "ОТКЛЮЧЕНЫ 2026-05-31 (владелец: «отрежь маркетинг»). Причина: их авто-генерируемые схемы (особенно wordstat — 128 tools из Яндекс.Директа) — главный подозреваемый в API 400 tools.110/113, ронявшем субагентов при bulk-load всех инструментов (subagent-driven-development). Серверы off-phase и без OAuth-токенов всё равно не стартовали. Полный конфиг — в git до этого коммита. Чтобы вернуть, восстановить три блока mcpServers: marketing-metrika (npx -y github:atomkraft/yandex-metrika-mcp; env YANDEX_OAUTH_TOKEN; READ-ONLY; Tooling §4.53), marketing-wordstat (npx -y github:SvechaPVL/yandex-mcp; env YANDEX_OAUTH_TOKEN; ТОЛЬКО Wordstat per IS9/MKT8; Tooling §4.54), marketing-telegram (npx -y github:chigwell/telegram-mcp; env TELEGRAM_API_ID/API_HASH/SESSION_STRING; выделенный аккаунт IS9; Tooling §4.51). См. docs/security/marketing-vet.md и docs/marketing/README.md.",
     "_comment_postiz_skeleton": "TODO: C1 marketing-tooling #81 — Postiz MCP (gitroomhq/postiz-app self-host + antoniolg/postiz-mcp). Активировать ПОСЛЕ: 1) развернуть Postiz self-hosted (git clone https://github.com/gitroomhq/postiz-app + docker-compose, AGPL-3.0: internal-only, no modifications); 2) провести vet лицензии antoniolg/postiz-mcp (NOT YET VERIFIED — см. docs/marketing/README.md Open vet notes); 3) подключить соцсети в Postiz UI. Будущий entry: \"marketing-postiz\": { \"command\": \"npx\", \"args\": [\"-y\", \"postiz-mcp\"], \"env\": { \"POSTIZ_API_URL\": \"${POSTIZ_API_URL}\", \"POSTIZ_API_KEY\": \"${POSTIZ_API_KEY}\" }, \"comment\": \"C1 #81 post-activation\" }. Tooling §4.52. docs/marketing/README.md."
   }

app/.env.example

@@ -70,6 +70,8 @@ MAIL_USERNAME=null
 MAIL_PASSWORD=null
 MAIL_FROM_ADDRESS="hello@example.com"
 MAIL_FROM_NAME="${APP_NAME}"
+SUPPORT_EMAIL=support@liderra.app
+JIVO_WIDGET_ID=
 
 AWS_ACCESS_KEY_ID=
 AWS_SECRET_ACCESS_KEY=

app/.gitignore

@@ -4,6 +4,7 @@
 .env
 .env.backup
 .env.production
+.env.testing
 .phpactor.json
 .phpunit.result.cache
 /.deptrac.cache

app/app/Console/Commands/DealsBackfillRegionCityCommand.php

@@ -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;
+    }
+}

app/app/Console/Commands/Imitation/ImitationSeedCommand.php

@@ -0,0 +1,142 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App\Console\Commands\Imitation;
+
+use App\Jobs\RouteSupplierLeadJob;
+use App\Models\Project;
+use App\Models\SupplierLead;
+use App\Models\SupplierProject;
+use App\Models\Tenant;
+use App\Models\User;
+use App\Support\RussianRegions;
+use Carbon\Carbon;
+use Database\Seeders\PricingTierSeeder;
+use Illuminate\Console\Command;
+use Illuminate\Support\Facades\Artisan;
+use Illuminate\Support\Facades\DB;
+use Illuminate\Support\Str;
+
+/**
+ * Populate a LOCAL portal with imitation clients and leads for hands-on UI review
+ * (Phase 1 imitation harness). It NEVER runs on production.
+ *
+ * Self-contained on purpose (it must not depend on test-harness helpers): it funds
+ * a few tenant balances locally, disables the external DaData call (region is taken
+ * from the lead tag), builds the routing snapshot for the active date, then injects
+ * synthetic leads through the real RouteSupplierLeadJob so deals, charges and
+ * notifications appear exactly as they would in production.
+ *
+ * Spec: docs/superpowers/specs/2026-06-03-portal-client-imitation-phase1-design.md
+ */
+final class ImitationSeedCommand extends Command
+{
+    protected $signature = 'imitation:seed
+        {--leads=20 : Number of synthetic leads to inject}
+        {--clients=3 : Number of imitation clients to create}';
+
+    protected $description = 'Populate the LOCAL portal with imitation clients and leads for UI review (never on production)';
+
+    public function handle(): int
+    {
+        if ($this->getLaravel()->environment('production')) {
+            $this->error('imitation:seed is forbidden in production.');
+
+            return self::FAILURE;
+        }
+
+        $leads = max(1, (int) $this->option('leads'));
+        $clients = max(1, (int) $this->option('clients'));
+
+        // Region comes from the lead tag — no external (paid) DaData call.
+        config(['services.dadata.enabled' => false]);
+
+        // Reference data required by the ledger.
+        (new PricingTierSeeder)->run();
+
+        $moscow = RussianRegions::nameToCode()['Москва']; // ordinal 82
+
+        // One shared supplier source (B2 site signal). The unique_key must be a
+        // domain-like string: RouteSupplierLeadJob re-resolves the supplier from the
+        // lead payload by (platform, unique_key) and infers signal_type from the
+        // identifier shape (see parseProjectField/resolveOrStub) — a domain → 'site'.
+        $supplierKey = 'imitseed-'.strtolower(Str::random(8)).'.test';
+        $supplier = SupplierProject::factory()->create([
+            'platform' => 'B2',
+            'signal_type' => 'site',
+            'unique_key' => $supplierKey,
+        ]);
+
+        // Funded imitation clients, all targeting Москва, full week, generous limit.
+        for ($i = 1; $i <= $clients; $i++) {
+            $tenant = Tenant::factory()->create(['balance_rub' => '100000.00']);
+            User::factory()->create(['tenant_id' => $tenant->id]);
+
+            $project = Project::factory()
+                ->asSiteSignal('imitseed-'.$i.'-'.Str::random(6).'.test')
+                ->create([
+                    'name' => "IMIT-seed-client-{$i}",
+                    'tenant_id' => $tenant->id,
+                    'regions' => [$moscow],
+                    'delivery_days_mask' => 127,
+                    'daily_limit_target' => 1000,
+                    'is_active' => true,
+                ]);
+
+            DB::table('project_supplier_links')->insert([
+                'project_id' => $project->id,
+                'supplier_project_id' => $supplier->id,
+                'platform' => $supplier->platform,
+                'subject_code' => null,
+            ]);
+        }
+
+        // Build the routing snapshot for the active date the router will query.
+        Artisan::call('snapshot:rebuild', ['--date' => $this->activeDate()]);
+
+        // Inject synthetic leads through the real routing + ledger pipeline.
+        $injected = 0;
+        for ($n = 1; $n <= $leads; $n++) {
+            $phone = '79'.str_pad((string) random_int(0, 999_999_999), 9, '0', STR_PAD_LEFT);
+            $vid = random_int(100_000_000, 999_999_999);
+
+            $lead = SupplierLead::factory()->create([
+                'supplier_project_id' => $supplier->id,
+                'platform' => $supplier->platform,
+                'phone' => $phone,
+                'vid' => $vid,
+                'raw_payload' => [
+                    'vid' => $vid,
+                    'project' => $supplier->platform.'_'.$supplierKey,
+                    'tag' => 'Москва',
+                    'phone' => $phone,
+                    'phones' => [$phone],
+                    'time' => now()->getTimestamp(),
+                ],
+                'received_at' => now(),
+                'source' => 'webhook',
+                'processed_at' => null,
+                'deals_created_count' => null,
+            ]);
+
+            RouteSupplierLeadJob::dispatchSync($lead->id);
+            $injected++;
+        }
+
+        $this->info("imitation:seed done — {$clients} clients, {$injected} leads injected (region from tag, DaData disabled).");
+
+        return self::SUCCESS;
+    }
+
+    /**
+     * Active snapshot date — mirrors LeadRouter::activeSnapshotDate()
+     * (today before 21:00 MSK, tomorrow at/after).
+     */
+    private function activeDate(): string
+    {
+        $msk = Carbon::now('Europe/Moscow');
+
+        return ($msk->hour >= 21 ? $msk->copy()->addDay() : $msk)->format('Y-m-d');
+    }
+}

app/app/Console/Commands/Pd/ScrubSoftDeletedDealsCommand.php

@@ -0,0 +1,119 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App\Console\Commands\Pd;
+
+use App\Models\SystemSetting;
+use Carbon\CarbonImmutable;
+use Illuminate\Console\Command;
+use Illuminate\Database\Query\Builder;
+use Illuminate\Support\Facades\DB;
+
+/**
+ * F-P1 / 152-ФЗ ретеншен: анонимизирует ПДн soft-deleted сделок по истечении
+ * настраиваемого срока (спека 2026-06-17-fp1-deal-pii-retention-spec).
+ *
+ * Срок (дней) — в system_settings, ключ `pd_scrub_soft_deleted_deals_days`.
+ * Отсутствие ключа или значение < 1 → no-op (юридический срок не зашит в код,
+ * выставляется на проде). Паттерн безопасности идентичен PartitionsDropExpired.
+ *
+ * Значения анонимизации идентичны PdErasureService::eraseSubject. Работает
+ * cross-tenant через pgsql_supplier (BYPASSRLS). Идемпотентно: уже затёртые
+ * (phone = ANON_PHONE) исключаются из выборки.
+ */
+class ScrubSoftDeletedDealsCommand extends Command
+{
+    private const DB = 'pgsql_supplier';
+
+    private const SETTING_KEY = 'pd_scrub_soft_deleted_deals_days';
+
+    private const ANON_PHONE = '+7000XXXXXXX';
+
+    private const ANON_NAME = 'Удалено';
+
+    /** @var string */
+    protected $signature = 'pd:scrub-soft-deleted-deals
+                            {--dry-run : Показать число кандидатов, не анонимизировать}';
+
+    /** @var string */
+    protected $description = 'Анонимизирует ПДн (телефон/имя) soft-deleted сделок старше retention-срока (152-ФЗ, F-P1)';
+
+    public function handle(): int
+    {
+        $days = $this->resolveRetentionDays();
+
+        if ($days === null) {
+            $this->line('<fg=gray>skip</> retention не настроен (system_settings.'.self::SETTING_KEY.' отсутствует или < 1).');
+
+            return self::SUCCESS;
+        }
+
+        $cutoff = CarbonImmutable::now()->subDays($days);
+        $candidates = $this->candidateQuery($cutoff)->count();
+
+        if ($this->option('dry-run')) {
+            $this->line("<fg=yellow>[dry-run]</> кандидатов на анонимизацию: {$candidates} (deleted_at старше {$days} дн.)");
+
+            return self::SUCCESS;
+        }
+
+        if ($candidates === 0) {
+            $this->info("Кандидатов на анонимизацию нет (retention={$days} дн.).");
+
+            return self::SUCCESS;
+        }
+
+        $now = CarbonImmutable::now();
+
+        // Bulk-UPDATE атомарен одним SQL; лог — одна summary-запись. Явная
+        // транзакция не нужна и несовместима с shared-PDO в тестах
+        // (pgsql_supplier делит сессию с уже открытой транзакцией pgsql).
+        $this->candidateQuery($cutoff)->update([
+            'phone' => self::ANON_PHONE,
+            'contact_name' => self::ANON_NAME,
+            'phones' => null,
+            'updated_at' => $now,
+        ]);
+
+        // Системное действие: оба actor-поля NULL (допускается chk_pd_actor).
+        // log_hash заполняется триггером цепочки целостности.
+        DB::connection(self::DB)->table('pd_processing_log')->insert([
+            'tenant_id' => null,
+            'subject_type' => 'deal',
+            'subject_id' => null,
+            'action' => 'deleted',
+            'purpose' => '152-FZ retention scrub',
+            'actor_tenant_user_id' => null,
+            'actor_admin_user_id' => null,
+            'created_at' => $now,
+        ]);
+
+        $this->info("Анонимизировано сделок: {$candidates} (retention={$days} дн.).");
+
+        return self::SUCCESS;
+    }
+
+    /** Кандидаты: soft-deleted старше cutoff, ещё не анонимизированные. */
+    private function candidateQuery(CarbonImmutable $cutoff): Builder
+    {
+        return DB::connection(self::DB)->table('deals')
+            ->whereNotNull('deleted_at')
+            ->where('deleted_at', '<', $cutoff)
+            ->where('phone', '<>', self::ANON_PHONE);
+    }
+
+    /** Срок ретеншена из system_settings; null если ключа нет или значение < 1. */
+    private function resolveRetentionDays(): ?int
+    {
+        $setting = SystemSetting::find(self::SETTING_KEY);
+
+        if ($setting === null) {
+            return null;
+        }
+
+        $value = (int) $setting->value;
+
+        return $value >= 1 ? $value : null;
+    }
+}

app/app/Console/Commands/PhoneRangesImportCommand.php

@@ -0,0 +1,446 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App\Console\Commands;
+
+use App\Support\RussianRegions;
+use Illuminate\Console\Command;
+use Illuminate\Database\Connection;
+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, $importId);
+
+            $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) и заливает строки.
+     *
+     * id: НЕ копируем серийный default через INCLUDING DEFAULTS — он ссылается на
+     * исходную последовательность phone_ranges, которую atomic-swap уничтожает
+     * (DROP phone_ranges_old CASCADE) после первого импорта, оставляя staging.id
+     * без default (NOT NULL violation на повторном импорте). Вместо этого даём
+     * staging собственную последовательность с уникальным по import_id именем,
+     * OWNED BY колонкой id → она переезжает при RENAME и дропается вместе со
+     * старой таблицей (без коллизий имён и без утечки последовательностей).
+     *
+     * @param  list<array<string, mixed>>  $rows
+     */
+    private function buildStaging(array $rows, int $importId): void
+    {
+        $c = DB::connection(self::DDL_CONNECTION);
+        $this->elevate($c);
+
+        $seq = "phone_ranges_stg_seq_{$importId}";
+        $c->statement('DROP TABLE IF EXISTS phone_ranges_staging CASCADE');
+        $c->statement('CREATE TABLE phone_ranges_staging (LIKE phone_ranges INCLUDING CONSTRAINTS)');
+        $c->statement("CREATE SEQUENCE {$seq}");
+        $c->statement("ALTER TABLE phone_ranges_staging ALTER COLUMN id SET DEFAULT nextval('{$seq}')");
+        $c->statement("ALTER SEQUENCE {$seq} OWNED BY phone_ranges_staging.id");
+        $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(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
+        }
+    }
+}

app/app/Console/Commands/PhoneRegionSmokeCommand.php

@@ -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);
+    }
+}

app/app/Console/Commands/RemindersDispatchDue.php

@@ -1,110 +0,0 @@
-<?php
-
-declare(strict_types=1);
-
-namespace App\Console\Commands;
-
-use App\Models\Reminder;
-use App\Services\NotificationService;
-use Illuminate\Console\Command;
-use Illuminate\Support\Carbon;
-use Illuminate\Support\Facades\DB;
-
-/**
- * Cron-команда диспатча due-reminders.
- *
- * Идёт по `reminders` где `is_sent=false AND completed_at IS NULL AND
- * remind_at <= NOW()`. Для каждой строки:
- *   1) NotificationService::notifyReminder (email + inapp по prefs);
- *   2) UPDATE is_sent=true, sent_at=NOW().
- *
- * RLS: SET LOCAL app.current_tenant_id = reminder.tenant_id внутри
- * транзакции каждой обработки (по одному reminder в транзакции — иначе
- * нельзя переключить tenant между строками с разных tenant'ов).
- *
- * Запускается каждую минуту через Windows Task Scheduler / cron.
- * Идемпотентна: повторный вызов на отправленных ($is_sent=true) skipаются.
- *
- * --dry-run печатает плановых получателей без реальных INSERT'ов.
- *
- * Источник: db/schema.sql §17.5; ТЗ §6.6 / §18.5.
- */
-class RemindersDispatchDue extends Command
-{
-    /** @var string */
-    protected $signature = 'reminders:dispatch-due
-        {--dry-run : Не отправлять, только напечатать список плановых получателей}
-        {--limit=500 : Максимум reminders за один запуск}';
-
-    /** @var string */
-    protected $description = 'Диспатч due-reminders: email/inapp уведомления + is_sent=true (ТЗ §18.5)';
-
-    public function handle(NotificationService $service): int
-    {
-        $dryRun = (bool) $this->option('dry-run');
-        $limit = max(1, (int) $this->option('limit'));
-        $now = Carbon::now();
-
-        // Cross-tenant gather via BYPASSRLS connection — on prod crm_app_user cannot
-        // call current_setting('app.current_tenant_id') without a GUC set first.
-        // pgsql_supplier (crm_supplier_worker, BYPASSRLS) is the canonical pattern
-        // for SaaS-admin cron queries (precedent: IncidentsWatchFailures, Reset*).
-        $rows = DB::connection('pgsql_supplier')
-            ->table('reminders')
-            ->select(['id', 'tenant_id', 'deal_id', 'remind_at'])
-            ->where('is_sent', false)
-            ->whereNull('completed_at')
-            ->where('remind_at', '<=', $now)
-            ->orderBy('remind_at')
-            ->limit($limit)
-            ->get();
-
-        if ($rows->isEmpty()) {
-            $this->info('Нет due-reminders.');
-
-            return self::SUCCESS;
-        }
-
-        $sent = 0;
-        $failed = 0;
-
-        foreach ($rows as $row) {
-            if ($dryRun) {
-                $this->line(sprintf(
-                    '  would dispatch <fg=yellow>id=%d</> tenant=%d deal=%d remind_at=%s',
-                    $row->id,
-                    $row->tenant_id,
-                    $row->deal_id,
-                    $row->remind_at ?? '-',
-                ));
-
-                continue;
-            }
-
-            try {
-                DB::transaction(function () use ($row, $service): void {
-                    // SET LOCAL scopes GUC to this transaction — PgBouncer-safe.
-                    DB::statement('SET LOCAL app.current_tenant_id = '.(int) $row->tenant_id);
-                    // Fetch the full Eloquent model with tenant context active so
-                    // relations (user, etc.) work correctly inside NotificationService.
-                    $reminder = Reminder::query()->findOrFail((int) $row->id);
-                    $service->notifyReminder($reminder);
-                    $reminder->update([
-                        'is_sent' => true,
-                        'sent_at' => Carbon::now(),
-                    ]);
-                });
-                $sent++;
-                $this->info("  dispatched <fg=green>id={$row->id}</>");
-            } catch (\Throwable $e) {
-                $failed++;
-                $this->error("  failed <fg=red>id={$row->id}</>: {$e->getMessage()}");
-            }
-        }
-
-        $this->newLine();
-        $this->info("Done: {$sent} sent, {$failed} failed (limit={$limit}, dry-run=".($dryRun ? '1' : '0').').');
-
-        return self::SUCCESS;
-    }
-}

app/app/Console/Commands/SnapshotBackfillCommand.php

@@ -28,7 +28,7 @@ final class SnapshotBackfillCommand extends Command
         $weekdayBit = 1 << ($date->isoWeekday() - 1);
 
         $count = DB::connection('pgsql_supplier')->transaction(function () use ($dateStr, $weekdayBit) {
-            return DB::connection('pgsql_supplier')->insert(<<<SQL
+            return DB::connection('pgsql_supplier')->insert(<<<'SQL'
                 INSERT INTO project_routing_snapshots (
                     snapshot_date, project_id, tenant_id,
                     daily_limit, delivery_days_mask, regions,

app/app/Console/Commands/SnapshotRebuildCommand.php

@@ -47,7 +47,7 @@ final class SnapshotRebuildCommand extends Command
             ->where('snapshot_date', $dateStr)
             ->delete();
 
-        $inserted = DB::connection('pgsql_supplier')->insert(<<<SQL
+        $inserted = DB::connection('pgsql_supplier')->insert(<<<'SQL'
             INSERT INTO project_routing_snapshots (
                 snapshot_date, project_id, tenant_id,
                 daily_limit, delivery_days_mask, regions,

app/app/Http/Controllers/Api/AuthController.php

@@ -7,8 +7,8 @@ namespace App\Http\Controllers\Api;
 use App\Http\Controllers\Concerns\WritesAuthLog;
 use App\Http\Controllers\Controller;
 use App\Http\Requests\Auth\LoginRequest;
-use App\Http\Requests\Auth\RegisterRequest;
 use App\Mail\SuspiciousLoginNotification;
+use App\Models\ImpersonationToken;
 use App\Models\Tenant;
 use App\Models\User;
 use App\Services\NotificationService;
@@ -131,46 +131,25 @@ class AuthController extends Controller
         ]);
     }
 
-    public function register(RegisterRequest $request): JsonResponse
-    {
-        // На MVP — attach нового user'а к первому tenant'у (для UI-разводки).
-        // Production: wizard с tenant_name + ИНН + создание Tenant + первый user owner-роли.
-        $tenant = Tenant::first();
-        if (! $tenant) {
-            return response()->json([
-                'message' => 'Tenants не настроены. Обратитесь к администратору.',
-            ], 503);
-        }
-
-        $user = User::create([
-            'tenant_id' => $tenant->id,
-            'email' => $request->string('email')->toString(),
-            'password_hash' => Hash::make($request->string('password')->toString()),
-            'first_name' => 'Новый',
-            'last_name' => 'Пользователь',
-            'is_active' => true,
-            'totp_enabled' => false,
-        ]);
-
-        Auth::login($user);
-        $request->session()->regenerate();
-
-        $this->logAuthEvent('register_success', $user->id, $user->tenant_id, $user->email, $request->ip(), $request->userAgent(), null);
-
-        return response()->json([
-            'user' => $this->userResource($user),
-            'requires_2fa' => false,
-        ], 201);
-    }
-
     public function me(Request $request): JsonResponse
     {
         /** @var User $user */
         $user = $request->user();
+        $resource = $this->userResource($user);
 
-        return response()->json([
-            'user' => $this->userResource($user),
-        ]);
+        $marker = $request->hasSession() ? $request->session()->get('impersonation') : null;
+        if ($marker !== null) {
+            $token = ImpersonationToken::on('pgsql_supplier')->find($marker['token_id']);
+            $tenant = $token?->tenant;
+            $resource['impersonation'] = [
+                'active' => true,
+                'tenant_name' => $tenant?->organization_name,
+                'started_at' => $marker['started_at'] ?? null,
+                'expires_at' => $token?->sessionExpiresAt()?->toIso8601String(),
+            ];
+        }
+
+        return response()->json(['user' => $resource]);
     }
 
     public function logout(Request $request): JsonResponse

app/app/Http/Controllers/Api/BillingController.php

@@ -13,6 +13,7 @@ use App\Models\User;
 use App\Repositories\PricingTierRepository;
 use App\Services\Billing\BalanceToLeadsConverter;
 use App\Services\Billing\BillingTopupService;
+use App\Services\Billing\RunwayCalculator;
 use Illuminate\Database\Eloquent\Collection;
 use Illuminate\Http\JsonResponse;
 use Illuminate\Http\Request;
@@ -316,21 +317,8 @@ class BillingController extends Controller
      */
     private function runwayDays(Tenant $tenant, int $affordableLeads): ?int
     {
-        if ($affordableLeads <= 0) {
-            return 0;
-        }
-
-        $leadsLast30Days = (int) DB::table('lead_charges')
-            ->where('tenant_id', $tenant->id)
-            ->where('charged_at', '>=', now()->subDays(30))
-            ->count();
-
-        if ($leadsLast30Days <= 0) {
-            return null;
-        }
-
-        $avgPerDay = $leadsLast30Days / 30.0;
-
-        return max(0, (int) floor($affordableLeads / $avgPerDay));
+        // F3 (17.06.2026): единый источник расчёта — RunwayCalculator (общий с дашбордом),
+        // чтобы прогноз «хватит на дни» не расходился между биллингом и дашбордом.
+        return app(RunwayCalculator::class)->daysLeft((int) $tenant->id, $affordableLeads);
     }
 }

app/app/Http/Controllers/Api/DashboardController.php

@@ -6,6 +6,10 @@ namespace App\Http\Controllers\Api;
 
 use App\Http\Controllers\Controller;
 use App\Models\Tenant;
+use App\Repositories\PricingTierRepository;
+use App\Services\Billing\BalanceToLeadsConverter;
+use App\Services\Billing\RunwayCalculator;
+use Carbon\Carbon;
 use Carbon\CarbonImmutable;
 use Illuminate\Http\JsonResponse;
 use Illuminate\Http\Request;
@@ -103,13 +107,32 @@ class DashboardController extends Controller
                 ->map(fn ($c) => (int) $c)
                 ->toArray();
 
-            // --- runway ---
-            // runway опирается на приток за фиксированное 7-дневное окно,
-            // независимо от выбранного range (для today/30d $curLeads — не 7-дневный).
-            $leads7d = (clone $base())->whereBetween('received_at', [$now->subDays(7), $now])->count();
-            $avgDaily = $leads7d / 7.0;
-            $balanceLeads = (int) ($tenant->balance_leads ?? 0);
-            $runwayDays = $avgDaily > 0 ? (int) floor($balanceLeads / $avgDaily) : 0;
+            // --- runway (F3, 17.06.2026: единый источник с биллингом) ---
+            // Раньше дашборд считал от legacy `balance_leads` (после Billing v2 ≈0
+            // для рублёвых тенантов) → расходился с биллингом «0 дней ↔ N дней».
+            // Теперь — affordable leads от рублёвого баланса по тарифу
+            // (BalanceToLeadsConverter) + общий RunwayCalculator.
+            $activeTiers = app(PricingTierRepository::class)
+                ->activeAt(Carbon::now('Europe/Moscow'));
+            $conversion = app(BalanceToLeadsConverter::class)->convert(
+                (string) $tenant->balance_rub,
+                (int) ($tenant->delivered_in_month ?? 0),
+                $activeTiers,
+            );
+            $affordableLeads = (int) $conversion['leads'];
+            $runwayDays = app(RunwayCalculator::class)
+                ->daysLeft($tenantId, $affordableLeads) ?? 0;
+
+            // --- средняя стоимость лида (F5): среднее фактически списанных rub-сумм
+            // за окно периода. Только charge_source='rub' (у prepaid цена 0 по CHECK —
+            // иначе среднее занижается); источник тот же, что у карточки сделки (F2).
+            // null, если в окне нет rub-списаний (ничего ещё не списано).
+            $avgKopecks = DB::table('lead_charges')
+                ->where('tenant_id', $tenantId)
+                ->where('charge_source', 'rub')
+                ->whereBetween('charged_at', [$windowStart, $now])
+                ->avg('price_per_lead_kopecks');
+            $avgLeadCostRub = $avgKopecks !== null ? round((float) $avgKopecks / 100, 2) : null;
 
             return [
                 'range' => $range,
@@ -119,10 +142,11 @@ class DashboardController extends Controller
                 'balance' => [
                     'amount_rub' => (string) $tenant->balance_rub,
                     'runway_days' => $runwayDays,
-                    'runway_leads' => $balanceLeads,
+                    'runway_leads' => $affordableLeads,
                 ],
                 'activity' => ['points' => $points, 'labels' => $labels, 'max' => $axisMax],
                 'funnel' => (object) $funnel,
+                'avg_lead_cost_rub' => $avgLeadCostRub,
             ];
         });
 

app/app/Http/Controllers/Api/DealController.php

@@ -7,6 +7,7 @@ namespace App\Http\Controllers\Api;
 use App\Http\Controllers\Controller;
 use App\Models\ActivityLog;
 use App\Models\Deal;
+use App\Models\LeadCharge;
 use App\Models\Project;
 use App\Models\SupplierLeadCost;
 use App\Models\User;
@@ -102,13 +103,6 @@ class DealController extends Controller
             // whereNotNull('deleted_at') фильтрует только удалённые.
             $query = Deal::query()
                 ->select('deals.*')
-                ->addSelect(['next_reminder_at' => DB::table('reminders')
-                    ->select('remind_at')
-                    ->whereColumn('reminders.deal_id', 'deals.id')
-                    ->whereNull('reminders.completed_at')
-                    ->orderBy('remind_at')
-                    ->limit(1),
-                ])
                 ->where('tenant_id', $tenantId)
                 ->with(['project:id,name,signal_type,signal_identifier,sms_keyword,sms_senders', 'manager:id,email,first_name,last_name']);
 
@@ -217,9 +211,6 @@ class DealController extends Controller
                 'project_signal_identifier' => $d->project?->signal_identifier,
                 'project_sms_keyword' => $d->project?->sms_keyword,
                 'project_sms_senders' => $d->project?->sms_senders,
-                'next_reminder_at' => $d->next_reminder_at
-                    ? Carbon::parse($d->next_reminder_at)->toIso8601String()
-                    : null,
             ]),
             'limit' => $limit,
             'next_cursor' => $nextCursor,
@@ -246,7 +237,7 @@ class DealController extends Controller
     {
         $tenantId = (int) $request->user()->tenant_id;
 
-        [$deal, $events] = DB::transaction(function () use ($tenantId, $id) {
+        [$deal, $events, $charge] = DB::transaction(function () use ($tenantId, $id) {
             DB::statement('SET LOCAL app.current_tenant_id = '.$tenantId);
 
             $deal = Deal::query()
@@ -256,7 +247,7 @@ class DealController extends Controller
                 ->first();
 
             if ($deal === null) {
-                return [null, []];
+                return [null, [], null];
             }
 
             $events = ActivityLog::query()
@@ -268,7 +259,14 @@ class DealController extends Controller
                 ->limit(50)
                 ->get();
 
-            return [$deal, $events];
+            // F2: реальная стоимость лида — снимок списания из lead_charges
+            // (rub-провенанс). Запрос в транзакции, где выставлен app.current_tenant_id.
+            $charge = LeadCharge::query()
+                ->where('tenant_id', $tenantId)
+                ->where('deal_id', $id)
+                ->first();
+
+            return [$deal, $events, $charge];
         });
 
         if ($deal === null) {
@@ -309,6 +307,8 @@ class DealController extends Controller
                 'project_signal_identifier' => $deal->project?->signal_identifier,
                 'project_sms_keyword' => $deal->project?->sms_keyword,
                 'project_sms_senders' => $deal->project?->sms_senders,
+                // F2: стоимость лида = снимок rub-списания (копейки) или null (prepaid/не списано).
+                'cost_kopecks' => ($charge && $charge->charge_source === 'rub') ? $charge->price_per_lead_kopecks : null,
             ],
             'events' => $events->map(fn (ActivityLog $e) => [
                 'id' => $e->id,

app/app/Http/Controllers/Api/ImpersonationController.php

@@ -5,12 +5,19 @@ declare(strict_types=1);
 namespace App\Http\Controllers\Api;
 
 use App\Http\Controllers\Controller;
+use App\Mail\ImpersonationCodeMail;
+use App\Mail\ImpersonationEndedMail;
 use App\Models\ImpersonationToken;
 use App\Models\Tenant;
+use App\Models\User;
 use App\Services\Pd\ImpersonationAuditService;
 use Illuminate\Http\JsonResponse;
 use Illuminate\Http\Request;
+use Illuminate\Support\Facades\Auth;
 use Illuminate\Support\Facades\Hash;
+use Illuminate\Support\Facades\Log;
+use Illuminate\Support\Facades\Mail;
+use Illuminate\Support\Str;
 
 /**
  * SaaS-admin impersonation flow (ТЗ §22.7 / Ю-1).
@@ -39,6 +46,8 @@ class ImpersonationController extends Controller
 
     private const MAX_FAILED_ATTEMPTS = 5;
 
+    private const SESSION_TTL_MINUTES = 60;
+
     /**
      * SaaS-admin — кросс-тенантная зона: запросы к impersonation_tokens / tenants
      * идут через BYPASSRLS-подключение pgsql_supplier (роль crm_supplier_worker).
@@ -134,7 +143,12 @@ class ImpersonationController extends Controller
 
         $audit->recordInit($token, adminId: $requestedBy, ip: $request->ip());
 
-        // TODO: отправить email на $tenant->contact_email с $plainCode.
+        try {
+            Mail::to((string) $tenant->contact_email)
+                ->queue(new ImpersonationCodeMail($plainCode, (string) $tenant->contact_email));
+        } catch (\Throwable $e) {
+            Log::warning('impersonation init: не удалось поставить письмо с кодом: '.$e->getMessage());
+        }
         $payload = [
             'token_id' => $token->id,
             'expires_at' => $token->expires_at->toIso8601String(),
@@ -190,10 +204,33 @@ class ImpersonationController extends Controller
             ], 422);
         }
 
-        // Success: mark used. Создание saas_admin_session с
-        // impersonating_token_id — отдельный коммит после saas-admin auth.
+        // Success: целевой пользователь тенанта = самый ранний активный.
+        $targetUser = User::on(self::DB_CONNECTION)
+            ->where('tenant_id', $token->tenant_id)
+            ->where('is_active', true)
+            ->orderBy('id')
+            ->first();
+
+        if ($targetUser === null) {
+            return response()->json(['message' => 'У тенанта нет активного пользователя для входа.'], 422);
+        }
+
+        // Машинный ключ для ИИ: lpimp_<id>_<secret>. Храним только хеш секрета.
+        $secret = Str::random(48);
+        $machineToken = 'lpimp_'.$token->id.'_'.$secret;
+
         $token->update([
             'used_at' => now(),
+            'session_token_hash' => Hash::make($secret),
+        ]);
+
+        // Путь человека: логиним браузер целевым пользователем + маркер impersonation в сессию.
+        Auth::login($targetUser);
+        $request->session()->put('impersonation', [
+            'token_id' => $token->id,
+            'tenant_id' => $token->tenant_id,
+            'target_user_id' => $targetUser->id,
+            'started_at' => now()->toIso8601String(),
         ]);
 
         $audit->recordVerify($token, adminId: (int) $token->requested_by, ip: $request->ip());
@@ -202,6 +239,8 @@ class ImpersonationController extends Controller
             'token_id' => $token->id,
             'tenant_id' => $token->tenant_id,
             'used_at' => $token->used_at->toIso8601String(),
+            'expires_at' => $token->sessionExpiresAt(self::SESSION_TTL_MINUTES)->toIso8601String(),
+            'machine_token' => $machineToken,
             'message' => 'Impersonation начат. Сессия активна 1 час.',
         ]);
     }
@@ -232,7 +271,12 @@ class ImpersonationController extends Controller
 
         $audit->recordEnd($token, adminId: (int) $token->requested_by, ip: $request->ip());
 
-        // TODO: уведомление клиенту по email о завершении (как и в init flow).
+        try {
+            Mail::to((string) $token->sent_to_email)
+                ->queue(new ImpersonationEndedMail((string) $token->sent_to_email));
+        } catch (\Throwable $e) {
+            Log::warning('impersonation end mail: '.$e->getMessage());
+        }
 
         return response()->json([
             'token_id' => $token->id,
@@ -240,4 +284,35 @@ class ImpersonationController extends Controller
             'message' => 'Impersonation завершён.',
         ]);
     }
+
+    /**
+     * POST /api/impersonation/leave — завершить свою impersonation-сессию из кабинета.
+     *
+     * Маркер `impersonation` из сессии НЕ удаляется здесь намеренно:
+     * ImpersonationContext (global web middleware) на следующем запросе
+     * обнаружит isSessionActive()=false и вернёт 401 явно, не доходя до auth:sanctum.
+     * Это обеспечивает корректный 401 как в реальном браузере, так и в тест-среде
+     * (где Auth::guard('web')->logout() может не повлиять на кэш sanctum-guard).
+     */
+    public function leave(Request $request, ImpersonationAuditService $audit): JsonResponse
+    {
+        $marker = $request->session()->get('impersonation');
+        if ($marker === null) {
+            return response()->json(['message' => 'Сессия impersonation не активна.'], 422);
+        }
+
+        $token = ImpersonationToken::on(self::DB_CONNECTION)->find($marker['token_id']);
+        if ($token !== null && $token->session_ended_at === null) {
+            $token->update(['session_ended_at' => now()]);
+            $audit->recordEnd($token, adminId: (int) $token->requested_by, ip: $request->ip());
+            try {
+                Mail::to((string) $token->sent_to_email)
+                    ->queue(new ImpersonationEndedMail((string) $token->sent_to_email));
+            } catch (\Throwable $e) {
+                Log::warning('impersonation leave mail: '.$e->getMessage());
+            }
+        }
+
+        return response()->json(['message' => 'Вы вышли из режима поддержки.']);
+    }
 }

app/app/Http/Controllers/Api/ProjectController.php

@@ -15,6 +15,7 @@ use App\Models\Project;
 use App\Models\Tenant;
 use App\Services\Billing\BalancePreflightService;
 use App\Services\Project\ProjectService;
+use App\Services\Requisites\RequisitesService;
 use Illuminate\Http\JsonResponse;
 use Illuminate\Http\Request;
 
@@ -29,7 +30,10 @@ use Illuminate\Http\Request;
  */
 class ProjectController extends Controller
 {
-    public function __construct(private readonly ProjectService $projects) {}
+    public function __construct(
+        private readonly ProjectService $projects,
+        private readonly RequisitesService $requisites,
+    ) {}
 
     /** GET /api/projects */
     public function index(Request $request): JsonResponse
@@ -122,6 +126,13 @@ class ProjectController extends Controller
     {
         $validated = $request->validated();
         $tenant = $request->user()->tenant;
+
+        // G1/SP2: гейт первого проекта — нельзя создать первый проект без минимальных реквизитов.
+        if (Project::where('tenant_id', $tenant->id)->count() === 0
+            && ! $this->requisites->isLightComplete($tenant)) {
+            return response()->json(['error' => 'requisites_required'], 422);
+        }
+
         $forceSaveBlocked = (bool) ($validated['force_save_blocked'] ?? false);
         unset($validated['force_save_blocked']);
 

app/app/Http/Controllers/Api/RegistrationController.php

@@ -0,0 +1,121 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App\Http\Controllers\Api;
+
+use App\Http\Controllers\Concerns\WritesAuthLog;
+use App\Http\Controllers\Controller;
+use App\Http\Requests\Auth\ConfirmEmailRequest;
+use App\Http\Requests\Auth\RegisterRequest;
+use App\Http\Requests\Auth\ResendCodeRequest;
+use App\Models\User;
+use App\Services\Auth\RegistrationException;
+use App\Services\Auth\RegistrationService;
+use Illuminate\Http\JsonResponse;
+use Illuminate\Support\Facades\Auth;
+
+/**
+ * Самозапись клиента (G1/SP1): register → confirm-email → (вход).
+ * Подтверждение почты 6-значным кодом; новый тенант создаётся в статусе
+ * pending_email_confirm, активируется и получает 300 ₽ при подтверждении.
+ */
+class RegistrationController extends Controller
+{
+    use WritesAuthLog;
+
+    public function register(RegisterRequest $request, RegistrationService $service): JsonResponse
+    {
+        try {
+            $result = $service->register(
+                $request->string('email')->toString(),
+                $request->string('password')->toString(),
+                $request->input('captcha_token'),
+                $request->ip(),
+            );
+        } catch (RegistrationException $e) {
+            return $this->registrationError($e);
+        }
+
+        $payload = [
+            'status' => $result['status'],
+            'email' => $result['user']->email,
+            'expires_at' => $result['verification']->expires_at->toIso8601String(),
+        ];
+        if ($result['dev_code'] !== null) {
+            $payload['_dev_plain_code'] = $result['dev_code'];
+        }
+
+        return response()->json($payload, 201);
+    }
+
+    public function confirmEmail(ConfirmEmailRequest $request, RegistrationService $service): JsonResponse
+    {
+        try {
+            $user = $service->confirm(
+                $request->string('email')->toString(),
+                $request->string('code')->toString(),
+            );
+        } catch (RegistrationException $e) {
+            $payload = ['message' => 'Код подтверждения недействителен.', 'reason' => $e->reason];
+            if ($e->attemptsRemaining !== null) {
+                $payload['attempts_remaining'] = $e->attemptsRemaining;
+            }
+
+            return response()->json($payload, 422);
+        }
+
+        Auth::login($user);
+        $request->session()->regenerate();
+        $this->logAuthEvent('register_success', $user->id, $user->tenant_id, $user->email, $request->ip(), $request->userAgent(), null);
+
+        return response()->json([
+            'user' => $this->userResource($user),
+            'requires_2fa' => false,
+        ]);
+    }
+
+    public function resendCode(ResendCodeRequest $request, RegistrationService $service): JsonResponse
+    {
+        $devCode = $service->resend($request->string('email')->toString());
+
+        $payload = ['message' => 'Если аккаунт ожидает подтверждения, мы отправили новый код на указанный email.'];
+        if ($devCode !== null) {
+            $payload['_dev_plain_code'] = $devCode;
+        }
+
+        return response()->json($payload);
+    }
+
+    private function registrationError(RegistrationException $e): JsonResponse
+    {
+        $map = [
+            'captcha_failed' => ['captcha_token', 'Проверка «я не робот» не пройдена.'],
+            'email_taken' => ['email', 'Аккаунт с таким email уже существует.'],
+        ];
+        [$field, $message] = $map[$e->reason] ?? ['email', 'Не удалось зарегистрировать аккаунт.'];
+
+        return response()->json([
+            'message' => $message,
+            'errors' => [$field => [$message]],
+        ], 422);
+    }
+
+    /** @return array<string, mixed> */
+    private function userResource(User $user): array
+    {
+        return [
+            'id' => $user->id,
+            'email' => $user->email,
+            'first_name' => $user->first_name,
+            'last_name' => $user->last_name,
+            'phone' => $user->phone,
+            'timezone' => $user->timezone,
+            'tenant_id' => $user->tenant_id,
+            'totp_enabled' => $user->totp_enabled,
+            'last_login_at' => $user->last_login_at,
+            'notification_preferences' => $user->notification_preferences,
+            'sound_enabled' => $user->sound_enabled,
+        ];
+    }
+}

app/app/Http/Controllers/Api/ReminderController.php

@@ -1,303 +0,0 @@
-<?php
-
-declare(strict_types=1);
-
-namespace App\Http\Controllers\Api;
-
-use App\Http\Controllers\Controller;
-use App\Models\Reminder;
-use App\Models\User;
-use Illuminate\Http\JsonResponse;
-use Illuminate\Http\Request;
-use Illuminate\Support\Carbon;
-use Illuminate\Support\Facades\DB;
-
-/**
- * Reminders API (schema v8.10 §17.5). Все endpoint'ы под `auth:sanctum`.
- *
- * Фильтры filter= для GET /api/reminders:
- *   today      — completed_at IS NULL AND remind_at в (now-1d, now+1d)
- *   upcoming   — completed_at IS NULL AND remind_at > now+1d
- *   overdue    — completed_at IS NULL AND remind_at < now-1d
- *   completed  — completed_at IS NOT NULL
- *   active     — completed_at IS NULL (default)
- *
- * RLS: внутри транзакции SET LOCAL app.current_tenant_id = $user->tenant_id.
- * Защита от кражи: явный where('tenant_id', $user->tenant_id) поверх RLS.
- */
-class ReminderController extends Controller
-{
-    private const FILTERS = ['active', 'today', 'upcoming', 'overdue', 'completed'];
-
-    /**
-     * GET /api/reminders?filter=&deal_id=&limit=
-     */
-    public function index(Request $request): JsonResponse
-    {
-        $validated = $request->validate([
-            'filter' => 'nullable|string|in:'.implode(',', self::FILTERS),
-            'deal_id' => 'nullable|integer|min:1',
-            'limit' => 'nullable|integer|min:1|max:200',
-        ]);
-
-        /** @var User $user */
-        $user = $request->user();
-        $filter = $validated['filter'] ?? 'active';
-        $limit = (int) ($validated['limit'] ?? 100);
-
-        return DB::transaction(function () use ($user, $filter, $validated, $limit): JsonResponse {
-            DB::statement('SET LOCAL app.current_tenant_id = '.(int) $user->tenant_id);
-
-            $query = Reminder::query()
-                ->with('creator:id,email,first_name,last_name')
-                ->where('tenant_id', $user->tenant_id);
-
-            if (isset($validated['deal_id'])) {
-                $query->where('deal_id', (int) $validated['deal_id']);
-            }
-
-            $now = Carbon::now();
-            switch ($filter) {
-                case 'today':
-                    $query->whereNull('completed_at')
-                        ->whereBetween('remind_at', [$now->copy()->subDay(), $now->copy()->addDay()]);
-                    break;
-                case 'upcoming':
-                    $query->whereNull('completed_at')
-                        ->where('remind_at', '>', $now->copy()->addDay());
-                    break;
-                case 'overdue':
-                    $query->whereNull('completed_at')
-                        ->where('remind_at', '<', $now->copy()->subDay());
-                    break;
-                case 'completed':
-                    $query->whereNotNull('completed_at');
-                    break;
-                case 'active':
-                default:
-                    $query->whereNull('completed_at');
-                    break;
-            }
-
-            $items = $query->orderBy('remind_at')->limit($limit)->get();
-
-            // Counters для UI badges (today/upcoming/overdue) — отдельные SELECT'ы.
-            $base = Reminder::query()->where('tenant_id', $user->tenant_id);
-            $counts = [
-                'today' => (clone $base)->whereNull('completed_at')
-                    ->whereBetween('remind_at', [$now->copy()->subDay(), $now->copy()->addDay()])
-                    ->count(),
-                'upcoming' => (clone $base)->whereNull('completed_at')
-                    ->where('remind_at', '>', $now->copy()->addDay())
-                    ->count(),
-                'overdue' => (clone $base)->whereNull('completed_at')
-                    ->where('remind_at', '<', $now->copy()->subDay())
-                    ->count(),
-                'active' => (clone $base)->whereNull('completed_at')->count(),
-            ];
-
-            return response()->json([
-                'items' => $items->map(fn (Reminder $r) => $this->toResource($r))->all(),
-                'counts' => $counts,
-            ]);
-        });
-    }
-
-    /**
-     * POST /api/reminders {deal_id, text?, remind_at}.
-     */
-    public function store(Request $request): JsonResponse
-    {
-        $validated = $request->validate([
-            'deal_id' => 'required|integer|min:1',
-            'text' => 'nullable|string|max:255',
-            'remind_at' => 'required|date',
-            'assignee_id' => 'nullable|integer|min:1',
-        ]);
-
-        /** @var User $user */
-        $user = $request->user();
-
-        // Manager FK guard для assignee_id: должен принадлежать тому же tenant'у.
-        if (isset($validated['assignee_id'])) {
-            $exists = User::query()
-                ->where('id', $validated['assignee_id'])
-                ->where('tenant_id', $user->tenant_id)
-                ->whereNull('deleted_at')
-                ->where('is_active', true)
-                ->exists();
-            if (! $exists) {
-                return response()->json([
-                    'message' => 'Менеджер не найден в этом тенанте.',
-                    'errors' => ['assignee_id' => ['Не принадлежит вашему тенанту или не активен.']],
-                ], 422);
-            }
-        }
-
-        return DB::transaction(function () use ($user, $validated): JsonResponse {
-            DB::statement('SET LOCAL app.current_tenant_id = '.(int) $user->tenant_id);
-
-            $reminder = Reminder::create([
-                'tenant_id' => $user->tenant_id,
-                'deal_id' => (int) $validated['deal_id'],
-                'text' => $validated['text'] ?? null,
-                'remind_at' => Carbon::parse($validated['remind_at']),
-                'created_by' => $user->id,
-                'assignee_id' => $validated['assignee_id'] ?? null,
-                'is_sent' => false,
-            ]);
-
-            return response()->json([
-                'reminder' => $this->toResource($reminder->load('creator:id,email,first_name,last_name')),
-            ], 201);
-        });
-    }
-
-    /**
-     * PATCH /api/reminders/{id} {text?, remind_at?, assignee_id?}.
-     */
-    public function update(Request $request, int $id): JsonResponse
-    {
-        $validated = $request->validate([
-            'text' => 'nullable|string|max:255',
-            'remind_at' => 'nullable|date',
-            'assignee_id' => 'nullable|integer|min:1',
-        ]);
-
-        if (count($validated) === 0) {
-            return response()->json([
-                'message' => 'Передайте хотя бы одно поле.',
-                'errors' => ['_general' => ['Нужно хотя бы одно поле для обновления.']],
-            ], 422);
-        }
-
-        /** @var User $user */
-        $user = $request->user();
-
-        if (isset($validated['assignee_id'])) {
-            $exists = User::query()
-                ->where('id', $validated['assignee_id'])
-                ->where('tenant_id', $user->tenant_id)
-                ->whereNull('deleted_at')
-                ->where('is_active', true)
-                ->exists();
-            if (! $exists) {
-                return response()->json([
-                    'message' => 'Менеджер не найден.',
-                    'errors' => ['assignee_id' => ['Не принадлежит вашему тенанту или не активен.']],
-                ], 422);
-            }
-        }
-
-        return DB::transaction(function () use ($user, $id, $validated): JsonResponse {
-            DB::statement('SET LOCAL app.current_tenant_id = '.(int) $user->tenant_id);
-
-            $reminder = Reminder::query()
-                ->where('id', $id)
-                ->where('tenant_id', $user->tenant_id)
-                ->first();
-
-            if ($reminder === null) {
-                return response()->json(['message' => 'Напоминание не найдено.'], 404);
-            }
-
-            $update = [];
-            if (array_key_exists('text', $validated)) {
-                $update['text'] = $validated['text'];
-            }
-            if (isset($validated['remind_at'])) {
-                $update['remind_at'] = Carbon::parse($validated['remind_at']);
-                // При сдвиге remind_at сбрасываем is_sent, чтобы cron смог
-                // снова отправить уведомление к новому времени.
-                $update['is_sent'] = false;
-                $update['sent_at'] = null;
-            }
-            if (array_key_exists('assignee_id', $validated)) {
-                $update['assignee_id'] = $validated['assignee_id'];
-            }
-
-            $reminder->update($update);
-
-            return response()->json([
-                'reminder' => $this->toResource($reminder->fresh('creator')),
-            ]);
-        });
-    }
-
-    /**
-     * POST /api/reminders/{id}/complete — пометить выполненным.
-     * Идемпотентно: повторный вызов NO-OP.
-     */
-    public function complete(Request $request, int $id): JsonResponse
-    {
-        /** @var User $user */
-        $user = $request->user();
-
-        return DB::transaction(function () use ($user, $id): JsonResponse {
-            DB::statement('SET LOCAL app.current_tenant_id = '.(int) $user->tenant_id);
-
-            $reminder = Reminder::query()
-                ->where('id', $id)
-                ->where('tenant_id', $user->tenant_id)
-                ->first();
-
-            if ($reminder === null) {
-                return response()->json(['message' => 'Напоминание не найдено.'], 404);
-            }
-
-            if ($reminder->completed_at === null) {
-                $reminder->update(['completed_at' => Carbon::now()]);
-            }
-
-            return response()->json([
-                'reminder' => $this->toResource($reminder->fresh('creator')),
-            ]);
-        });
-    }
-
-    /**
-     * DELETE /api/reminders/{id}.
-     */
-    public function destroy(Request $request, int $id): JsonResponse
-    {
-        /** @var User $user */
-        $user = $request->user();
-
-        return DB::transaction(function () use ($user, $id): JsonResponse {
-            DB::statement('SET LOCAL app.current_tenant_id = '.(int) $user->tenant_id);
-
-            $deleted = Reminder::query()
-                ->where('id', $id)
-                ->where('tenant_id', $user->tenant_id)
-                ->delete();
-
-            if ($deleted === 0) {
-                return response()->json(['message' => 'Напоминание не найдено.'], 404);
-            }
-
-            return response()->json(['message' => 'Удалено.']);
-        });
-    }
-
-    /** @return array<string, mixed> */
-    private function toResource(Reminder $reminder): array
-    {
-        $creator = $reminder->creator;
-
-        return [
-            'id' => $reminder->id,
-            'deal_id' => $reminder->deal_id,
-            'text' => $reminder->text,
-            'remind_at' => $reminder->remind_at?->toIso8601String(),
-            'completed_at' => $reminder->completed_at?->toIso8601String(),
-            'is_sent' => $reminder->is_sent,
-            'sent_at' => $reminder->sent_at?->toIso8601String(),
-            'created_at' => $reminder->created_at?->toIso8601String(),
-            'created_by' => $reminder->created_by,
-            'assignee_id' => $reminder->assignee_id,
-            'creator_name' => $creator
-                ? trim(($creator->first_name ?? '').' '.($creator->last_name ?? '')) ?: $creator->email
-                : null,
-        ];
-    }
-}

app/app/Http/Controllers/Api/SupplierWebhookController.php

@@ -44,9 +44,22 @@ class SupplierWebhookController extends Controller
     /** Audit-fix C2: per-IP rate-limit (DoS-guard), запросов в минуту. */
     private const RATE_LIMIT_PER_MINUTE = 600;
 
-    public function receive(Request $request, string $secret): JsonResponse
+    public function receive(Request $request, string $secret = ''): JsonResponse
     {
-        if (! $this->verifySecret($secret)) {
+        // Аутентификация (аддитивно): URL-секрет (backward-compat) ИЛИ HMAC-подпись
+        // тела (X-Webhook-Signature = hash_hmac sha256 от raw body на том же
+        // supplier_webhook_secret). HMAC позволяет поставщику не слать секрет в URL
+        // — тот течёт в access-логи (P2/E4). verifySecret('') всегда false.
+        $sig = (string) $request->header('X-Webhook-Signature', '');
+        $sig = str_starts_with($sig, 'sha256=') ? substr($sig, 7) : $sig;
+        $secretRow = DB::table('system_settings')->where('key', 'supplier_webhook_secret')->first();
+        $expectedSecret = $secretRow !== null ? (string) $secretRow->value : '';
+        $hmacValid = $sig !== ''
+            && $expectedSecret !== '__SET_ON_DEPLOY__'
+            && strlen($expectedSecret) >= 32
+            && hash_equals(hash_hmac('sha256', $request->getContent(), $expectedSecret), $sig);
+
+        if (! $this->verifySecret($secret) && ! $hmacValid) {
             $this->logSupplierWebhook($request, null, 'rejected_secret');
 
             return response()->json(['message' => 'Not found.'], 404);

app/app/Http/Controllers/Api/SupportRequestController.php

@@ -0,0 +1,55 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App\Http\Controllers\Api;
+
+use App\Http\Controllers\Controller;
+use App\Mail\SupportRequestMail;
+use App\Models\SupportRequest;
+use App\Models\User;
+use Illuminate\Http\JsonResponse;
+use Illuminate\Http\Request;
+use Illuminate\Support\Facades\DB;
+use Illuminate\Support\Facades\Log;
+use Illuminate\Support\Facades\Mail;
+
+/**
+ * G7-A: приём клиентских заявок в техподдержку. Запись в БД — основной канал;
+ * письмо в поддержку — best-effort (сбой SMTP не валит запрос, паттерн G1 sendCode).
+ */
+class SupportRequestController extends Controller
+{
+    public function store(Request $request): JsonResponse
+    {
+        $validated = $request->validate([
+            'name' => 'required|string|max:255',
+            'contact' => 'required|string|max:255',
+            'message' => 'required|string|max:5000',
+        ]);
+
+        /** @var User $user */
+        $user = $request->user();
+
+        $supportRequest = DB::transaction(function () use ($user, $validated): SupportRequest {
+            DB::statement('SET LOCAL app.current_tenant_id = '.(int) $user->tenant_id);
+
+            return SupportRequest::create([
+                'tenant_id' => $user->tenant_id,
+                'user_id' => $user->id,
+                'name' => $validated['name'],
+                'contact' => $validated['contact'],
+                'message' => $validated['message'],
+            ]);
+        });
+
+        // Письмо — best-effort: заявка уже в БД, сбой почты не теряет её и не валит запрос.
+        try {
+            Mail::to(config('services.support.email'))->queue(new SupportRequestMail($supportRequest));
+        } catch (\Throwable $e) {
+            Log::warning('SupportRequestMail queue failed', ['id' => $supportRequest->id, 'error' => $e->getMessage()]);
+        }
+
+        return response()->json(['ok' => true], 201);
+    }
+}

app/app/Http/Controllers/Api/TenantRequisitesController.php

@@ -0,0 +1,57 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App\Http\Controllers\Api;
+
+use App\Http\Controllers\Controller;
+use App\Http\Requests\LookupInnRequest;
+use App\Http\Requests\UpdateRequisitesRequest;
+use App\Http\Resources\RequisitesResource;
+use App\Models\TenantRequisites;
+use App\Services\DaData\PartyLookup;
+use App\Services\Requisites\RequisitesService;
+use Illuminate\Http\JsonResponse;
+use Illuminate\Http\Request;
+
+class TenantRequisitesController extends Controller
+{
+    public function __construct(
+        private readonly RequisitesService $service,
+        private readonly PartyLookup $party,
+    ) {}
+
+    /** GET /api/tenant/requisites */
+    public function show(Request $request): JsonResponse
+    {
+        $req = TenantRequisites::where('tenant_id', $request->user()->tenant_id)->first();
+
+        return response()->json(['data' => $req ? new RequisitesResource($req) : null]);
+    }
+
+    /** PUT /api/tenant/requisites */
+    public function update(UpdateRequisitesRequest $request): JsonResponse
+    {
+        $req = $this->service->upsert($request->user()->tenant, $request->validated());
+
+        return response()->json(['data' => new RequisitesResource($req)]);
+    }
+
+    /** POST /api/tenant/requisites/lookup-inn — мягкая подтяжка, ничего не сохраняет */
+    public function lookupInn(LookupInnRequest $request): JsonResponse
+    {
+        $res = $this->party->findByInn($request->validated()['inn']);
+        if ($res === null) {
+            return response()->json(['found' => false]);
+        }
+
+        return response()->json([
+            'found' => true,
+            'legal_name' => $res->legalName,
+            'kpp' => $res->kpp,
+            'ogrn' => $res->ogrn,
+            'legal_address' => $res->address,
+            'subject_type_hint' => $res->type === 'INDIVIDUAL' ? 'sole_proprietor' : 'legal_entity',
+        ]);
+    }
+}

app/app/Http/Controllers/Api/V1/DealsController.php

@@ -0,0 +1,95 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App\Http\Controllers\Api\V1;
+
+use App\Http\Controllers\Controller;
+use App\Models\Deal;
+use Carbon\Carbon;
+use Illuminate\Http\JsonResponse;
+use Illuminate\Http\Request;
+use Illuminate\Support\Facades\DB;
+
+/**
+ * Публичный read-API сделок тенанта (G6). Аутентификация — middleware ApiKeyAuth
+ * (tenant_id в request->attributes['api_tenant_id']). Только сделки (deals), не
+ * supplier_leads.
+ */
+class DealsController extends Controller
+{
+    public function index(Request $request): JsonResponse
+    {
+        $tenantId = (int) $request->attributes->get('api_tenant_id');
+
+        $limit = max(1, min(500, (int) $request->query('limit', '100')));
+
+        $since = trim((string) $request->query('since', ''));
+        $sinceDt = null;
+        if ($since !== '') {
+            try {
+                $sinceDt = Carbon::parse($since);
+            } catch (\Throwable) {
+                return response()->json(['message' => 'Невалидный since.'], 422);
+            }
+        }
+
+        $cursorRaw = (string) $request->query('cursor', '');
+        $cursor = null;
+        if ($cursorRaw !== '') {
+            $decoded = base64_decode($cursorRaw, true);
+            $parsed = $decoded === false ? null : json_decode($decoded, true);
+            if (! is_array($parsed) || ! isset($parsed['r'], $parsed['i'])) {
+                return response()->json(['message' => 'Невалидный cursor.'], 422);
+            }
+            $cursor = ['r' => (string) $parsed['r'], 'i' => (int) $parsed['i']];
+        }
+
+        [$rows, $next] = DB::transaction(function () use ($tenantId, $limit, $sinceDt, $cursor) {
+            DB::statement('SET LOCAL app.current_tenant_id = '.$tenantId);
+
+            $query = Deal::query()
+                ->where('tenant_id', $tenantId)
+                ->with('project:id,name');
+
+            if ($sinceDt !== null) {
+                $query->where('received_at', '>=', $sinceDt);
+            }
+            if ($cursor !== null) {
+                $query->whereRaw('(received_at, id) < (?, ?)', [$cursor['r'], $cursor['i']]);
+            }
+
+            $rows = $query->orderByDesc('received_at')->orderByDesc('id')
+                ->limit($limit + 1)->get();
+
+            $hasNext = $rows->count() > $limit;
+            if ($hasNext) {
+                $rows = $rows->slice(0, $limit)->values();
+            }
+
+            $next = null;
+            if ($hasNext && $rows->isNotEmpty()) {
+                $last = $rows->last();
+                $next = base64_encode((string) json_encode([
+                    'r' => $last->received_at->toIso8601String(),
+                    'i' => $last->id,
+                ]));
+            }
+
+            return [$rows, $next];
+        });
+
+        return response()->json([
+            'data' => $rows->map(fn (Deal $d) => [
+                'id' => $d->id,
+                'received_at' => $d->received_at->toIso8601String(),
+                'phone' => $d->phone,
+                'contact_name' => $d->contact_name,
+                'city' => $d->city,
+                'status' => $d->status,
+                'project' => $d->project?->name,
+            ])->all(),
+            'next_cursor' => $next,
+        ]);
+    }
+}

app/app/Http/Controllers/Api/WebhookSettingsController.php

@@ -127,15 +127,16 @@ class WebhookSettingsController extends Controller
             ], Response::HTTP_UNPROCESSABLE_ENTITY);
         }
 
-        // SSRF-гард: target_url задаёт админ тенанта; блокируем адреса во
-        // внутренней/зарезервированной сети (cloud-metadata 169.254.169.254,
-        // loopback, RFC1918), которые https://-валидация на сохранении не ловит.
-        $blockReason = WebhookUrlGuard::blockReason($sub->target_url);
-        if ($blockReason !== null) {
+        // SSRF-гард + DNS-rebind пиннинг: ОДИН резолв target_url даёт причину
+        // блокировки И безопасный IP. Блокируем адреса во внутренней/зарезервированной
+        // сети (cloud-metadata 169.254.169.254, loopback, RFC1918), которые
+        // https://-валидация на сохранении не ловит.
+        $delivery = WebhookUrlGuard::safeDeliveryIp($sub->target_url);
+        if ($delivery['blockReason'] !== null) {
             return response()->json([
                 'ok' => false,
                 'status' => null,
-                'message' => $blockReason,
+                'message' => $delivery['blockReason'],
             ], Response::HTTP_UNPROCESSABLE_ENTITY);
         }
 
@@ -145,9 +146,19 @@ class WebhookSettingsController extends Controller
             'message' => 'Тестовая доставка webhook от Лидерра.',
         ];
 
+        // DNS-rebind пиннинг: подключаемся к УЖЕ проверенному IP, не давая
+        // HTTP-клиенту резолвить хост повторно (TOCTOU). Host/SNI — исходный хост.
+        $httpOptions = [];
+        if ($delivery['ip'] !== null) {
+            $host = trim((string) parse_url($sub->target_url, PHP_URL_HOST), '[]');
+            $port = parse_url($sub->target_url, PHP_URL_PORT) ?? 443;
+            $httpOptions['curl'] = [CURLOPT_RESOLVE => ["{$host}:{$port}:{$delivery['ip']}"]];
+        }
+
         // Unsigned connectivity-проверка (HMAC-подписанная доставка — отдельный эпик).
         try {
-            $response = Http::timeout(10)
+            $response = Http::withOptions($httpOptions)
+                ->timeout(10)
                 ->withHeaders(['X-Webhook-Event' => 'webhook.test'])
                 ->post($sub->target_url, $testPayload);
 

app/app/Http/Middleware/ApiKeyAuth.php

@@ -0,0 +1,73 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App\Http\Middleware;
+
+use App\Models\ApiKey;
+use Closure;
+use Illuminate\Http\Request;
+use Illuminate\Support\Facades\Hash;
+use Symfony\Component\HttpFoundation\Response;
+
+/**
+ * Аутентификация публичного API по ключу тенанта (G6).
+ *
+ * Ключ — `Authorization: Bearer lpkapi_...`. В БД лежит bcrypt key_hash + key_prefix
+ * (первые 10 символов). Ищем кандидатов по префиксу через pgsql_supplier (BYPASSRLS —
+ * публичный роут не ставит tenant-GUC, под RLS api_keys вернул бы пусто), затем
+ * Hash::check. Успех → tenant_id в request->attributes (api_tenant_id) + last_used.
+ */
+class ApiKeyAuth
+{
+    public function handle(Request $request, Closure $next): Response
+    {
+        $key = $this->bearer($request);
+        if ($key === null || $key === '') {
+            return response()->json(['message' => 'Требуется API-ключ.'], 401);
+        }
+
+        $prefix = substr($key, 0, 10);
+
+        $candidates = ApiKey::on('pgsql_supplier')
+            ->where('key_prefix', $prefix)
+            ->where('is_active', true)
+            ->where('expires_at', '>', now())
+            ->get();
+
+        $matched = null;
+        foreach ($candidates as $candidate) {
+            if (Hash::check($key, (string) $candidate->key_hash)) {
+                $matched = $candidate;
+                break;
+            }
+        }
+
+        if ($matched === null) {
+            return response()->json(['message' => 'Неверный или неактивный API-ключ.'], 401);
+        }
+
+        if (! in_array('read', (array) $matched->scopes, true)) {
+            return response()->json(['message' => 'Недостаточно прав ключа.'], 403);
+        }
+
+        ApiKey::on('pgsql_supplier')->whereKey($matched->getKey())->update([
+            'last_used_at' => now(),
+            'last_used_ip' => $request->ip(),
+        ]);
+
+        $request->attributes->set('api_tenant_id', (int) $matched->tenant_id);
+
+        return $next($request);
+    }
+
+    private function bearer(Request $request): ?string
+    {
+        $header = (string) $request->header('Authorization', '');
+        if (str_starts_with($header, 'Bearer ')) {
+            return trim(substr($header, 7));
+        }
+
+        return null;
+    }
+}

app/app/Http/Middleware/EnsureSaasAdmin.php

@@ -24,6 +24,9 @@ use Symfony\Component\HttpFoundation\Response;
  * admin_user_id для audit-trail по-прежнему резолвится трейтом
  * ResolvesAdminUserId (стаб super_admin) — это отдельная зона.
  *
+ * G7-B: пока активен impersonation (маркер сессии ИЛИ машинный ключ) —
+ * вход в saas-admin зону запрещён (запрет эскалации к другим тенантам).
+ *
  * TODO (после Б-1 + DO-4): заменить nginx-дверь на настоящий saas-admin
  * guard (Yandex 360 SSO-сессия + роль), вернуть проверку в это middleware.
  */
@@ -31,6 +34,14 @@ class EnsureSaasAdmin
 {
     public function handle(Request $request, Closure $next): Response
     {
+        // G7-B: пока активен impersonation (маркер сессии ИЛИ машинный ключ) —
+        // вход в saas-admin зону запрещён (запрет эскалации к другим тенантам).
+        $hasMarker = $request->hasSession() && $request->session()->has('impersonation');
+        $hasBearer = str_starts_with((string) $request->header('Authorization', ''), 'Bearer lpimp_');
+        if ($hasMarker || $hasBearer) {
+            abort(403, 'Во время сессии impersonation доступ в админ-зону запрещён.');
+        }
+
         return $next($request);
     }
 }

app/app/Http/Middleware/ImpersonationContext.php

@@ -0,0 +1,59 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App\Http\Middleware;
+
+use App\Mail\ImpersonationEndedMail;
+use App\Models\ImpersonationToken;
+use Closure;
+use Illuminate\Http\Request;
+use Illuminate\Support\Facades\Auth;
+use Illuminate\Support\Facades\Log;
+use Illuminate\Support\Facades\Mail;
+use Symfony\Component\HttpFoundation\Response;
+
+/**
+ * G7-B: на web-запросах с активным impersonation-маркером проверяет 60-мин
+ * лимит. Истёк (или токен уже неактивен) → завершает токен, шлёт письмо,
+ * разлогинивает, чистит маркер. No-op, если маркера нет.
+ */
+class ImpersonationContext
+{
+    public function handle(Request $request, Closure $next): Response
+    {
+        if (! $request->hasSession() || ! $request->session()->has('impersonation')) {
+            return $next($request);
+        }
+
+        $marker = $request->session()->get('impersonation');
+        $token = ImpersonationToken::on('pgsql_supplier')->find($marker['token_id'] ?? 0);
+
+        if ($token === null || ! $token->isSessionActive()) {
+            if ($token !== null && $token->session_ended_at === null) {
+                $token->update(['session_ended_at' => now()]);
+                try {
+                    Mail::to((string) $token->sent_to_email)
+                        ->queue(new ImpersonationEndedMail((string) $token->sent_to_email));
+                } catch (\Throwable $e) {
+                    Log::warning('impersonation expiry mail: '.$e->getMessage());
+                }
+            }
+            Auth::guard('web')->logout();
+            $request->session()->forget('impersonation');
+            $request->session()->invalidate();
+            $request->session()->regenerateToken();
+
+            // Завершаем текущий запрос немедленно — auth:sanctum уже мог
+            // резолвить user'а из сессии, поэтому не передаём $next, а
+            // возвращаем 401 явно, чтобы клиент знал о разрыве сессии.
+            if ($request->expectsJson()) {
+                return response()->json(['message' => 'Сессия impersonation истекла.'], 401);
+            }
+
+            return redirect('/login');
+        }
+
+        return $next($request);
+    }
+}

app/app/Http/Requests/Auth/ConfirmEmailRequest.php

@@ -0,0 +1,32 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App\Http\Requests\Auth;
+
+use Illuminate\Foundation\Http\FormRequest;
+
+/**
+ * Валидация POST /api/auth/confirm-email — подтверждение почты 6-значным кодом.
+ */
+class ConfirmEmailRequest extends FormRequest
+{
+    /** @return array<string, mixed> */
+    public function rules(): array
+    {
+        return [
+            'email' => ['required', 'string', 'email', 'max:255'],
+            'code' => ['required', 'string', 'regex:/^\d{6}$/'],
+        ];
+    }
+
+    /** @return array<string, string> */
+    public function messages(): array
+    {
+        return [
+            'email.required' => 'Укажите email.',
+            'code.required' => 'Укажите код из письма.',
+            'code.regex' => 'Код состоит из 6 цифр.',
+        ];
+    }
+}

app/app/Http/Requests/Auth/RegisterRequest.php

@@ -18,14 +18,21 @@ class RegisterRequest extends FormRequest
 {
     use HasPasswordRules;
 
-    /** @return array<string, mixed> */
+    /**
+     * @return array<string, mixed>
+     *
+     * NB: уникальность email НЕ через DB-rule — её решает RegistrationService
+     * (активный email → 422 email_taken; неподтверждённый → перевыпуск кода).
+     * Капча проверяется на КАЖДОМ register-запросе (это независимый публичный POST).
+     */
     public function rules(): array
     {
         return [
-            'email' => ['required', 'string', 'email', 'max:255', Rule::unique('users', 'email')],
+            'email' => ['required', 'string', 'email', 'max:255'],
             'password' => $this->passwordRules(),
             'accept_offer' => ['required', 'accepted'],
             'accept_pdn' => ['required', 'accepted'],
+            'captcha_token' => ['required', 'string'],
         ];
     }
 
@@ -35,9 +42,9 @@ class RegisterRequest extends FormRequest
         return array_merge($this->passwordMessages(), [
             'email.required' => 'Укажите email.',
             'email.email' => 'Email указан некорректно.',
-            'email.unique' => 'Аккаунт с таким email уже существует.',
             'accept_offer.accepted' => 'Необходимо принять оферту.',
             'accept_pdn.accepted' => 'Необходимо согласие на обработку персональных данных.',
+            'captcha_token.required' => 'Подтвердите, что вы не робот.',
         ]);
     }
 }

app/app/Http/Requests/Auth/ResendCodeRequest.php

@@ -0,0 +1,30 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App\Http\Requests\Auth;
+
+use Illuminate\Foundation\Http\FormRequest;
+
+/**
+ * Валидация POST /api/auth/resend-code — повторная отправка кода подтверждения.
+ */
+class ResendCodeRequest extends FormRequest
+{
+    /** @return array<string, mixed> */
+    public function rules(): array
+    {
+        return [
+            'email' => ['required', 'string', 'email', 'max:255'],
+        ];
+    }
+
+    /** @return array<string, string> */
+    public function messages(): array
+    {
+        return [
+            'email.required' => 'Укажите email.',
+            'email.email' => 'Email указан некорректно.',
+        ];
+    }
+}

app/app/Http/Requests/LookupInnRequest.php

@@ -0,0 +1,23 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App\Http\Requests;
+
+use Illuminate\Foundation\Http\FormRequest;
+
+class LookupInnRequest extends FormRequest
+{
+    public function authorize(): bool
+    {
+        return $this->user() !== null;
+    }
+
+    /** @return array<string, mixed> */
+    public function rules(): array
+    {
+        return [
+            'inn' => ['required', 'string', 'regex:/^(\d{10}|\d{12})$/'],
+        ];
+    }
+}

app/app/Http/Requests/UpdateRequisitesRequest.php

@@ -0,0 +1,53 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App\Http\Requests;
+
+use App\Support\InnValidator;
+use App\Support\PhoneNormalizer;
+use Illuminate\Foundation\Http\FormRequest;
+use Illuminate\Validation\Rule;
+
+class UpdateRequisitesRequest extends FormRequest
+{
+    public function authorize(): bool
+    {
+        return $this->user() !== null;
+    }
+
+    /** @return array<string, mixed> */
+    public function rules(): array
+    {
+        $subjectType = (string) $this->input('subject_type');
+
+        return [
+            'subject_type' => ['required', Rule::in(['individual', 'sole_proprietor', 'legal_entity'])],
+            'contact_name' => ['required', 'string', 'max:255'],
+            'contact_phone' => ['required', 'string', function ($attr, $value, $fail) {
+                if (PhoneNormalizer::normalize((string) $value) === null) {
+                    $fail('Некорректный телефон.');
+                }
+            }],
+            'inn' => [
+                Rule::requiredIf(in_array($subjectType, ['legal_entity', 'sole_proprietor'], true)),
+                'nullable', 'string',
+                function ($attr, $value, $fail) use ($subjectType) {
+                    if (in_array($subjectType, ['legal_entity', 'sole_proprietor'], true)
+                        && is_string($value) && $value !== ''
+                        && ! InnValidator::isValid($value, $subjectType)) {
+                        $fail('Некорректный ИНН (контрольная цифра).');
+                    }
+                },
+            ],
+            'legal_name' => ['nullable', 'string', 'max:255'],
+            'kpp' => ['nullable', 'string', 'regex:/^\d{9}$/'],
+            'ogrn' => ['nullable', 'string', 'regex:/^(\d{13}|\d{15})$/'],
+            'legal_address' => ['nullable', 'string'],
+            'bank_name' => ['nullable', 'string', 'max:255'],
+            'bank_bik' => ['nullable', 'string', 'regex:/^\d{9}$/'],
+            'bank_account' => ['nullable', 'string', 'regex:/^\d{20}$/'],
+            'corr_account' => ['nullable', 'string', 'regex:/^\d{20}$/'],
+        ];
+    }
+}

app/app/Http/Resources/RequisitesResource.php

@@ -0,0 +1,33 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App\Http\Resources;
+
+use App\Models\TenantRequisites;
+use Illuminate\Http\Request;
+use Illuminate\Http\Resources\Json\JsonResource;
+
+/** @mixin TenantRequisites */
+class RequisitesResource extends JsonResource
+{
+    /** @return array<string, mixed> */
+    public function toArray(Request $request): array
+    {
+        return [
+            'subject_type' => $this->subject_type,
+            'contact_name' => $this->contact_name,
+            'contact_phone' => $this->contact_phone,
+            'inn' => $this->inn,
+            'legal_name' => $this->legal_name,
+            'kpp' => $this->kpp,
+            'ogrn' => $this->ogrn,
+            'legal_address' => $this->legal_address,
+            'bank_name' => $this->bank_name,
+            'bank_bik' => $this->bank_bik,
+            'bank_account' => $this->bank_account,
+            'corr_account' => $this->corr_account,
+            'requisites_completed_at' => $this->requisites_completed_at,
+        ];
+    }
+}

app/app/Jobs/RouteSupplierLeadJob.php

@@ -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).
      *

app/app/Jobs/SendNewLeadsDigestJob.php

@@ -0,0 +1,58 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App\Jobs;
+
+use App\Models\Deal;
+use App\Models\Tenant;
+use App\Services\NotificationService;
+use Illuminate\Bus\Queueable;
+use Illuminate\Contracts\Queue\ShouldQueue;
+use Illuminate\Database\Eloquent\Collection as EloquentCollection;
+use Illuminate\Foundation\Bus\Dispatchable;
+use Illuminate\Queue\InteractsWithQueue;
+use Illuminate\Support\Facades\DB;
+
+/**
+ * G2-A: раз в 30 минут (routes/console.php) рассылает дайджест новых сделок.
+ * Окно — последние 30 минут по received_at. Идемпотентен (непересекающееся окно).
+ * Паттерн по-тенантного джоба — BalancePreflightSweepJob (SET LOCAL tenant).
+ */
+final class SendNewLeadsDigestJob implements ShouldQueue
+{
+    use Dispatchable;
+    use InteractsWithQueue;
+    use Queueable;
+
+    public function handle(NotificationService $notifier): void
+    {
+        Tenant::query()->whereNull('deleted_at')->chunkById(200, function (EloquentCollection $tenants) use ($notifier): void {
+            foreach ($tenants as $tenant) {
+                /** @var Tenant $tenant */
+                $this->digestForTenant($tenant, $notifier);
+            }
+        });
+    }
+
+    private function digestForTenant(Tenant $tenant, NotificationService $notifier): void
+    {
+        DB::transaction(function () use ($tenant, $notifier): void {
+            DB::statement('SET LOCAL app.current_tenant_id = '.(int) $tenant->id);
+
+            $deals = Deal::query()
+                ->where('tenant_id', $tenant->id)
+                ->where('received_at', '>', now()->subMinutes(30))
+                ->where('is_test', false)
+                ->whereNull('deleted_at')
+                ->orderBy('received_at')
+                ->get();
+
+            if ($deals->isEmpty()) {
+                return;
+            }
+
+            $notifier->notifyNewLeadsDigest($tenant, $deals);
+        });
+    }
+}

app/app/Jobs/SnapshotProjectRoutingJob.php

@@ -20,7 +20,7 @@ use Illuminate\Support\Facades\Log;
  */
 final class SnapshotProjectRoutingJob implements ShouldQueue
 {
-    use Dispatchable, Queueable, InteractsWithQueue, SerializesModels;
+    use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;
 
     public const DB_CONNECTION = 'pgsql_supplier'; // BYPASSRLS
 
@@ -38,10 +38,11 @@ final class SnapshotProjectRoutingJob implements ShouldQueue
             ->exists();
         if ($exists) {
             Log::info('snapshot.already_exists', ['date' => $snapshotDate]);
+
             return;
         }
 
-        $count = DB::connection(self::DB_CONNECTION)->insert(<<<SQL
+        $count = DB::connection(self::DB_CONNECTION)->insert(<<<'SQL'
             INSERT INTO project_routing_snapshots (
                 snapshot_date, project_id, tenant_id,
                 daily_limit, delivery_days_mask, regions,

app/app/Jobs/Supplier/CsvReconcileJob.php

@@ -6,9 +6,11 @@ namespace App\Jobs\Supplier;
 
 use App\Jobs\RouteSupplierLeadJob;
 use App\Mail\CsvDriftAlertMail;
+use App\Mail\TenantBusinessDriftAlertMail;
 use App\Models\SupplierLead;
 use App\Services\Supplier\SupplierCsvParser;
 use App\Services\Supplier\SupplierPortalClient;
+use Carbon\CarbonInterface;
 use Illuminate\Bus\Queueable;
 use Illuminate\Contracts\Cache\LockProvider;
 use Illuminate\Contracts\Mail\Mailer;
@@ -274,8 +276,8 @@ final class CsvReconcileJob implements ShouldQueue
 
     private function detectAndAlertBusinessDrift(
         Mailer $mailer,
-        \Carbon\CarbonInterface $windowStart,
-        \Carbon\CarbonInterface $windowEnd,
+        CarbonInterface $windowStart,
+        CarbonInterface $windowEnd,
     ): void {
         $from = $windowStart->toDateString();
         $to = $windowEnd->toDateString();
@@ -300,7 +302,7 @@ final class CsvReconcileJob implements ShouldQueue
             }
 
             $mailer->to((string) config('services.supplier.alert_email'))
-                ->send(new \App\Mail\TenantBusinessDriftAlertMail(
+                ->send(new TenantBusinessDriftAlertMail(
                     tenantId: (int) $row->tenant_id,
                     snapshotDate: (string) $row->snapshot_date,
                     expected: $expected,

app/app/Logging/PiiScrubbingProcessor.php

@@ -0,0 +1,64 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App\Logging;
+
+use Monolog\LogRecord;
+use Monolog\Processor\ProcessorInterface;
+
+/**
+ * Monolog-процессор: маскирует ПДн в логах перед записью.
+ *
+ * Закрывает Medium go-live: laravel.log (LOG_LEVEL=debug) мог сохранить телефон/email
+ * открытым, если они попадут в текст исключения или контекст. Процессор ловит ВСЕ
+ * записи каналов, к которым подключён (см. App\Logging\ScrubPii + config/logging.php),
+ * централизованно — надёжнее правки отдельных вызовов Log::.
+ */
+final class PiiScrubbingProcessor implements ProcessorInterface
+{
+    /**
+     * Телефоны РФ: 11 цифр в формате 7XXXXXXXXXX / 8XXXXXXXXXX / +7XXXXXXXXXX.
+     * Lookbehind/lookahead не дают маскировать часть более длинной цифровой строки
+     * (например 14-значный технический id).
+     */
+    private const PHONE_PATTERN = '/(?<!\d)(?:\+?7|8)\d{10}(?!\d)/';
+
+    private const EMAIL_PATTERN = '/[\p{L}0-9._%+\-]+@[\p{L}0-9.\-]+\.\p{L}{2,}/u';
+
+    public function __invoke(LogRecord $record): LogRecord
+    {
+        return $record->with(
+            message: $this->scrub($record->message),
+            context: $this->scrubArray($record->context),
+            extra: $this->scrubArray($record->extra),
+        );
+    }
+
+    private function scrub(string $value): string
+    {
+        $value = preg_replace(self::PHONE_PATTERN, '[PHONE]', $value) ?? $value;
+
+        return preg_replace(self::EMAIL_PATTERN, '[EMAIL]', $value) ?? $value;
+    }
+
+    /**
+     * @param  array<array-key, mixed>  $data
+     * @return array<array-key, mixed>
+     */
+    private function scrubArray(array $data): array
+    {
+        $result = [];
+        foreach ($data as $key => $value) {
+            if (is_string($value)) {
+                $result[$key] = $this->scrub($value);
+            } elseif (is_array($value)) {
+                $result[$key] = $this->scrubArray($value);
+            } else {
+                $result[$key] = $value;
+            }
+        }
+
+        return $result;
+    }
+}

app/app/Logging/ScrubPii.php

@@ -0,0 +1,25 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App\Logging;
+
+use Illuminate\Log\Logger;
+
+/**
+ * Tap для config/logging.php: вешает PiiScrubbingProcessor на канал.
+ *
+ * Использование: 'tap' => [\App\Logging\ScrubPii::class] в описании канала.
+ */
+final class ScrubPii
+{
+    public function __invoke(Logger $logger): void
+    {
+        // Illuminate\Log\Logger::getLogger() типизирован как PSR LoggerInterface,
+        // но фактически возвращает Monolog\Logger (у него есть pushProcessor).
+        $monolog = $logger->getLogger();
+        if ($monolog instanceof \Monolog\Logger) {
+            $monolog->pushProcessor(new PiiScrubbingProcessor);
+        }
+    }
+}

app/app/Mail/EmailVerificationCodeMail.php

@@ -0,0 +1,41 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App\Mail;
+
+use Illuminate\Bus\Queueable;
+use Illuminate\Mail\Mailable;
+use Illuminate\Mail\Mailables\Content;
+use Illuminate\Mail\Mailables\Envelope;
+use Illuminate\Queue\SerializesModels;
+
+/**
+ * Письмо с 6-значным кодом подтверждения почты при самозаписи (G1/SP1).
+ */
+final class EmailVerificationCodeMail extends Mailable
+{
+    use Queueable;
+    use SerializesModels;
+
+    public function __construct(
+        public readonly string $code,
+        public readonly string $email,
+    ) {}
+
+    public function envelope(): Envelope
+    {
+        return new Envelope(
+            subject: 'Код подтверждения регистрации в Лидерре',
+            to: [$this->email],
+        );
+    }
+
+    public function content(): Content
+    {
+        return new Content(
+            view: 'emails.email_verification_code',
+            with: ['code' => $this->code],
+        );
+    }
+}

app/app/Mail/ImpersonationCodeMail.php

@@ -0,0 +1,36 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App\Mail;
+
+use Illuminate\Bus\Queueable;
+use Illuminate\Mail\Mailable;
+use Illuminate\Mail\Mailables\Content;
+use Illuminate\Mail\Mailables\Envelope;
+use Illuminate\Queue\SerializesModels;
+
+/** Код-согласие на вход поддержки в кабинет клиента (G7-B / Ю-1). */
+final class ImpersonationCodeMail extends Mailable
+{
+    use Queueable;
+    use SerializesModels;
+
+    public function __construct(
+        public readonly string $code,
+        public readonly string $email,
+    ) {}
+
+    public function envelope(): Envelope
+    {
+        return new Envelope(
+            subject: 'Код доступа: запрос входа поддержки в ваш кабинет',
+            to: [$this->email],
+        );
+    }
+
+    public function content(): Content
+    {
+        return new Content(view: 'emails.impersonation_code', with: ['code' => $this->code]);
+    }
+}

app/app/Mail/ImpersonationEndedMail.php

@@ -0,0 +1,36 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App\Mail;
+
+use Illuminate\Bus\Queueable;
+use Illuminate\Mail\Mailable;
+use Illuminate\Mail\Mailables\Content;
+use Illuminate\Mail\Mailables\Envelope;
+use Illuminate\Queue\SerializesModels;
+
+/** Уведомление о завершении сессии поддержки в кабинете клиента (G7-B / Ю-1). */
+final class ImpersonationEndedMail extends Mailable
+{
+    use Queueable;
+    use SerializesModels;
+
+    public function __construct(
+        public readonly string $email,
+        public readonly ?string $tenantName = null,
+    ) {}
+
+    public function envelope(): Envelope
+    {
+        return new Envelope(
+            subject: 'Сессия поддержки в вашем кабинете завершена',
+            to: [$this->email],
+        );
+    }
+
+    public function content(): Content
+    {
+        return new Content(view: 'emails.impersonation_ended', with: ['tenantName' => $this->tenantName]);
+    }
+}

app/app/Mail/NewLeadsDigestMail.php

@@ -0,0 +1,53 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App\Mail;
+
+use App\Models\Deal;
+use App\Models\Tenant;
+use App\Models\User;
+use Illuminate\Bus\Queueable;
+use Illuminate\Mail\Mailable;
+use Illuminate\Mail\Mailables\Content;
+use Illuminate\Mail\Mailables\Envelope;
+use Illuminate\Queue\SerializesModels;
+use Illuminate\Support\Collection;
+
+/**
+ * Письмо-сводка о новых сделках за окно (G2-A дайджест).
+ * Заменяет пер-лид NewLeadNotification как email-канал события new_lead.
+ *
+ * @property Collection<int, Deal> $deals
+ */
+class NewLeadsDigestMail extends Mailable
+{
+    use Queueable;
+    use SerializesModels;
+
+    public function __construct(
+        public User $user,
+        public Tenant $tenant,
+        public Collection $deals,
+    ) {}
+
+    public function envelope(): Envelope
+    {
+        return new Envelope(
+            subject: 'Лидерра. Новые сделки — '.$this->deals->count(),
+        );
+    }
+
+    public function content(): Content
+    {
+        return new Content(
+            view: 'emails.new_leads_digest',
+            with: [
+                'user' => $this->user,
+                'tenant' => $this->tenant,
+                'deals' => $this->deals,
+                'count' => $this->deals->count(),
+            ],
+        );
+    }
+}

app/app/Mail/ReminderDueNotification.php

@@ -1,54 +0,0 @@
-<?php
-
-declare(strict_types=1);
-
-namespace App\Mail;
-
-use App\Models\Reminder;
-use App\Models\User;
-use Illuminate\Bus\Queueable;
-use Illuminate\Mail\Mailable;
-use Illuminate\Mail\Mailables\Content;
-use Illuminate\Mail\Mailables\Envelope;
-use Illuminate\Queue\SerializesModels;
-
-/**
- * Email-уведомление о наступлении срока напоминания (ТЗ §18.5, событие reminder).
- *
- * Триггер: cron-команда `reminders:dispatch-due` находит rows с
- * `is_sent=false AND completed_at IS NULL AND remind_at <= NOW()`,
- * вызывает NotificationService::notifyReminder для каждой,
- * затем ставит `is_sent=true, sent_at=NOW()`.
- */
-class ReminderDueNotification extends Mailable
-{
-    use Queueable;
-    use SerializesModels;
-
-    public function __construct(
-        public User $recipient,
-        public Reminder $reminder,
-    ) {}
-
-    public function envelope(): Envelope
-    {
-        $shortText = $this->reminder->text
-            ? mb_substr($this->reminder->text, 0, 60)
-            : 'Срок касания клиента';
-
-        return new Envelope(
-            subject: "Лидерра. Напоминание — {$shortText}",
-        );
-    }
-
-    public function content(): Content
-    {
-        return new Content(
-            view: 'emails.reminder',
-            with: [
-                'recipient' => $this->recipient,
-                'reminder' => $this->reminder,
-            ],
-        );
-    }
-}

app/app/Mail/SupportRequestMail.php

@@ -0,0 +1,38 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App\Mail;
+
+use App\Models\SupportRequest;
+use Illuminate\Bus\Queueable;
+use Illuminate\Mail\Mailable;
+use Illuminate\Mail\Mailables\Content;
+use Illuminate\Mail\Mailables\Envelope;
+use Illuminate\Queue\SerializesModels;
+
+/**
+ * Письмо в техподдержку о новой заявке клиента (G7-A). Адресат — config('services.support.email').
+ */
+class SupportRequestMail extends Mailable
+{
+    use Queueable;
+    use SerializesModels;
+
+    public function __construct(public SupportRequest $request) {}
+
+    public function envelope(): Envelope
+    {
+        return new Envelope(
+            subject: 'Лидерра. Заявка в поддержку #'.$this->request->id,
+        );
+    }
+
+    public function content(): Content
+    {
+        return new Content(
+            view: 'emails.support_request',
+            with: ['r' => $this->request],
+        );
+    }
+}

app/app/Models/Deal.php

@@ -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',

app/app/Models/EmailVerification.php

@@ -0,0 +1,71 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App\Models;
+
+use Illuminate\Database\Eloquent\Model;
+use Illuminate\Database\Eloquent\Relations\BelongsTo;
+use Illuminate\Support\Carbon;
+
+/**
+ * Код подтверждения почты при самозаписи клиента (G1/SP1).
+ *
+ * 6-значный код, bcrypt-хеш в code_hash, plain уходит письмом. TTL 15 мин,
+ * 5 попыток. Механика зеркалит ImpersonationToken. Таблица RLS-изолирована
+ * (через user_id→users.tenant_id) — на публичном роуте читается/пишется через
+ * BYPASSRLS pgsql_supplier.
+ *
+ * @property int $id
+ * @property int $user_id
+ * @property string $email
+ * @property string $token
+ * @property string|null $code_hash
+ * @property int $failed_attempts
+ * @property Carbon $expires_at
+ * @property Carbon|null $verified_at
+ * @property Carbon $created_at
+ */
+class EmailVerification extends Model
+{
+    /** schema-таблица не имеет updated_at. */
+    public const UPDATED_AT = null;
+
+    protected $fillable = [
+        'user_id',
+        'email',
+        'token',
+        'code_hash',
+        'failed_attempts',
+        'expires_at',
+        'verified_at',
+    ];
+
+    protected function casts(): array
+    {
+        return [
+            'failed_attempts' => 'integer',
+            'expires_at' => 'datetime',
+            'verified_at' => 'datetime',
+            'created_at' => 'datetime',
+        ];
+    }
+
+    public function isExpired(): bool
+    {
+        return $this->expires_at->isPast();
+    }
+
+    public function isUsable(): bool
+    {
+        return $this->verified_at === null
+            && $this->failed_attempts < 5
+            && ! $this->isExpired();
+    }
+
+    /** @return BelongsTo<User, $this> */
+    public function user(): BelongsTo
+    {
+        return $this->belongsTo(User::class);
+    }
+}

app/app/Models/ImpersonationToken.php

@@ -32,6 +32,7 @@ use Illuminate\Support\Carbon;
  * @property int|null $second_approver_id
  * @property Carbon|null $second_approval_at
  * @property Carbon $created_at
+ * @property string|null $session_token_hash
  *
  * @mixin IdeHelperImpersonationToken
  */
@@ -54,6 +55,7 @@ class ImpersonationToken extends Model
         'invalidated_at',
         'second_approver_id',
         'second_approval_at',
+        'session_token_hash',
     ];
 
     protected function casts(): array
@@ -81,6 +83,20 @@ class ImpersonationToken extends Model
             && ! $this->isExpired();
     }
 
+    /** Сессия impersonation активна: код подтверждён, не завершена, не инвалидирована, в пределах TTL минут. */
+    public function isSessionActive(int $ttlMinutes = 60): bool
+    {
+        return $this->used_at !== null
+            && $this->session_ended_at === null
+            && $this->invalidated_at === null
+            && $this->used_at->copy()->addMinutes($ttlMinutes)->isFuture();
+    }
+
+    public function sessionExpiresAt(int $ttlMinutes = 60): ?Carbon
+    {
+        return $this->used_at?->copy()->addMinutes($ttlMinutes);
+    }
+
     /** @return BelongsTo<Tenant, $this> */
     public function tenant(): BelongsTo
     {

app/app/Models/PersonalAccessToken.php

@@ -0,0 +1,42 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App\Models;
+
+use Illuminate\Database\QueryException;
+use Laravel\Sanctum\PersonalAccessToken as SanctumPersonalAccessToken;
+
+/**
+ * Расширение Sanctum PersonalAccessToken.
+ *
+ * Перехватывает Bearer-токены с префиксом «lpimp_» (машинные ключи
+ * impersonation-guard, G7-B) и возвращает null без обращения к БД.
+ * Это предотвращает crash при отсутствии таблицы personal_access_tokens
+ * (проект использует SPA cookie-auth, таблица не создаётся).
+ */
+class PersonalAccessToken extends SanctumPersonalAccessToken
+{
+    /**
+     * Find the token instance matching the given token.
+     *
+     * Returns null immediately for impersonation machine-key tokens so
+     * Sanctum does not attempt a DB lookup on personal_access_tokens.
+     */
+    public static function findToken($token): ?static
+    {
+        if (str_starts_with((string) $token, 'lpimp_')) {
+            return null;
+        }
+
+        // В проекте нет таблицы personal_access_tokens (SPA cookie-auth, Sanctum
+        // PAT не используются). Без этого try/catch любой иной Bearer на
+        // sanctum-роуте ронял бы запрос в 500 (Undefined table) вместо чистого
+        // 401. Гасим QueryException до null — guard вернёт 401.
+        try {
+            return parent::findToken($token);
+        } catch (QueryException) {
+            return null;
+        }
+    }
+}

app/app/Models/Reminder.php

@@ -1,88 +0,0 @@
-<?php
-
-declare(strict_types=1);
-
-namespace App\Models;
-
-use Database\Factories\ReminderFactory;
-use Illuminate\Database\Eloquent\Factories\HasFactory;
-use Illuminate\Database\Eloquent\Model;
-use Illuminate\Database\Eloquent\Relations\BelongsTo;
-
-/**
- * Напоминание на сделке (schema v8.10 §17.5).
- *
- * Tenant-aware модель с RLS. Композитные индексы:
- * - idx_reminders_due (remind_at) WHERE is_sent=FALSE AND completed_at IS NULL — cron;
- * - idx_reminders_deal (deal_id) — UI карточки сделки;
- * - idx_reminders_tenant_user_active — дашборд «today/last/future».
- *
- * deal_id БЕЗ FK (deals партиционирована, FK на partitioned-родительскую
- * таблицу не поддерживается без partition-key в составе).
- *
- * MVP: assignee_id всегда NULL — паритет с histories[].to оригинала. Поле
- * зарезервировано для Post-MVP (multi-assignee).
- *
- * @mixin IdeHelperReminder
- */
-class Reminder extends Model
-{
-    /** @use HasFactory<ReminderFactory> */
-    use HasFactory;
-
-    protected $fillable = [
-        'tenant_id',
-        'deal_id',
-        'text',
-        'remind_at',
-        'created_by',
-        'assignee_id',
-        'completed_at',
-        'is_sent',
-        'sent_at',
-    ];
-
-    protected function casts(): array
-    {
-        return [
-            'tenant_id' => 'integer',
-            'deal_id' => 'integer',
-            'created_by' => 'integer',
-            'assignee_id' => 'integer',
-            'is_sent' => 'boolean',
-            'remind_at' => 'datetime',
-            'completed_at' => 'datetime',
-            'sent_at' => 'datetime',
-            'created_at' => 'datetime',
-            'updated_at' => 'datetime',
-        ];
-    }
-
-    /** @return BelongsTo<Tenant, $this> */
-    public function tenant(): BelongsTo
-    {
-        return $this->belongsTo(Tenant::class);
-    }
-
-    /** @return BelongsTo<User, $this> */
-    public function creator(): BelongsTo
-    {
-        return $this->belongsTo(User::class, 'created_by');
-    }
-
-    /** @return BelongsTo<User, $this> */
-    public function assignee(): BelongsTo
-    {
-        return $this->belongsTo(User::class, 'assignee_id');
-    }
-
-    public function isCompleted(): bool
-    {
-        return $this->completed_at !== null;
-    }
-
-    public function isOverdue(): bool
-    {
-        return $this->completed_at === null && $this->remind_at < now();
-    }
-}

app/app/Models/SupplierLead.php

@@ -18,6 +18,14 @@ use Illuminate\Database\Eloquent\Relations\BelongsTo;
  *
  * Spec: docs/superpowers/specs/2026-05-10-supplier-integration-design.md §5.1
  *
+ * Поля резолва региона (lead-region) аннотированы явно — ide-helper:models
+ * не подхватил их в стаб IdeHelperSupplierLead:
+ *
+ * @property int|null $dadata_qc
+ * @property string|null $phone_operator
+ * @property string|null $region_source
+ * @property int|null $resolved_subject_code
+ *
  * @mixin IdeHelperSupplierLead
  */
 class SupplierLead extends Model
@@ -41,6 +49,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 +65,8 @@ class SupplierLead extends Model
             'recovered_from_csv_at' => 'datetime',
             'vid' => 'integer',
             'deals_created_count' => 'integer',
+            'resolved_subject_code' => 'integer',
+            'dadata_qc' => 'integer',
         ];
     }
 

app/app/Models/SupportRequest.php

@@ -0,0 +1,35 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App\Models;
+
+use Illuminate\Database\Eloquent\Model;
+use Illuminate\Support\Carbon;
+
+/**
+ * Заявка клиента в техподдержку (G7-A). RLS по tenant_id; created_at — DB default.
+ *
+ * @property int $id
+ * @property int $tenant_id
+ * @property int $user_id
+ * @property string $name
+ * @property string $contact
+ * @property string $message
+ * @property Carbon $created_at
+ */
+class SupportRequest extends Model
+{
+    protected $table = 'support_requests';
+
+    public $timestamps = false; // только created_at (DB DEFAULT now()), updated_at нет
+
+    protected $fillable = [
+        'tenant_id', 'user_id', 'name', 'contact', 'message',
+    ];
+
+    protected function casts(): array
+    {
+        return ['created_at' => 'datetime'];
+    }
+}

app/app/Models/TenantRequisites.php

@@ -0,0 +1,59 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App\Models;
+
+use Illuminate\Database\Eloquent\Model;
+use Illuminate\Support\Carbon;
+
+/**
+ * Реквизиты тенанта (G1/SP2). 1:1 с tenants. RLS по tenant_id.
+ *
+ * Свойства аннотированы явно: `ide-helper:models` пропускает эту модель при
+ * интроспекции (стаб IdeHelperTenantRequisites не генерируется), поэтому
+ *
+ * @property-аннотации заданы вручную по db/schema.sql (tenant_requisites).
+ *
+ * @property int $id
+ * @property int $tenant_id
+ * @property string $subject_type
+ * @property string $contact_name
+ * @property string $contact_phone
+ * @property string|null $inn
+ * @property string|null $legal_name
+ * @property string|null $kpp
+ * @property string|null $ogrn
+ * @property string|null $legal_address
+ * @property string|null $bank_name
+ * @property string|null $bank_bik
+ * @property string|null $bank_account
+ * @property string|null $corr_account
+ * @property array<string, mixed>|null $dadata_raw
+ * @property Carbon|null $dadata_synced_at
+ * @property Carbon|null $requisites_completed_at
+ * @property Carbon|null $created_at
+ * @property Carbon|null $updated_at
+ */
+class TenantRequisites extends Model
+{
+    protected $table = 'tenant_requisites';
+
+    protected $fillable = [
+        'tenant_id', 'subject_type', 'contact_name', 'contact_phone',
+        'inn', 'legal_name', 'kpp', 'ogrn', 'legal_address',
+        'bank_name', 'bank_bik', 'bank_account', 'corr_account',
+        'dadata_raw', 'dadata_synced_at', 'requisites_completed_at',
+    ];
+
+    protected function casts(): array
+    {
+        return [
+            'dadata_raw' => 'array',
+            'dadata_synced_at' => 'datetime',
+            'requisites_completed_at' => 'datetime',
+            'created_at' => 'datetime',
+            'updated_at' => 'datetime',
+        ];
+    }
+}

app/app/Providers/AppServiceProvider.php

@@ -2,14 +2,28 @@
 
 namespace App\Providers;
 
+use App\Models\ImpersonationToken;
+use App\Models\PersonalAccessToken;
+use App\Models\User;
+use App\Services\Captcha\CaptchaVerifier;
+use App\Services\Captcha\NullCaptchaVerifier;
+use App\Services\DaData\DaDataPartyClient;
+use App\Services\DaData\NullPartyLookup;
+use App\Services\DaData\PartyLookup;
 use App\Services\Supplier\Channel\AjaxProjectChannel;
 use App\Services\Supplier\Channel\FailoverProjectChannel;
 use App\Services\Supplier\Channel\FormProjectChannel;
 use App\Services\Supplier\Channel\SupplierProjectChannel;
 use App\Services\Supplier\ProcessFactory;
 use App\Services\Supplier\SymfonyProcessFactory;
+use Illuminate\Cache\RateLimiting\Limit;
 use Illuminate\Contracts\Mail\Mailer;
+use Illuminate\Http\Request;
+use Illuminate\Support\Facades\Auth;
+use Illuminate\Support\Facades\Hash;
+use Illuminate\Support\Facades\RateLimiter;
 use Illuminate\Support\ServiceProvider;
+use Laravel\Sanctum\Sanctum;
 
 class AppServiceProvider extends ServiceProvider
 {
@@ -34,6 +48,22 @@ class AppServiceProvider extends ServiceProvider
                 $app->make(Mailer::class),
             ),
         );
+
+        // Шов капчи самозаписи (G1/SP1). SP1 — Null-драйвер; реальный
+        // Yandex SmartCaptcha встанет сюда позже через match по драйверу.
+        $this->app->bind(
+            CaptchaVerifier::class,
+            NullCaptchaVerifier::class,
+        );
+
+        // Шов подтяжки организации по ИНН (G1/SP2). По флагу party_enabled —
+        // реальный DaData suggestions; иначе Null (dev/тесты не ходят в сеть).
+        $this->app->bind(
+            PartyLookup::class,
+            fn ($app) => config('services.dadata.party_enabled')
+                ? $app->make(DaDataPartyClient::class)
+                : $app->make(NullPartyLookup::class),
+        );
     }
 
     /**
@@ -41,6 +71,54 @@ class AppServiceProvider extends ServiceProvider
      */
     public function boot(): void
     {
-        //
+        // P1 go-live: per-IP route-throttle поверх прикладного per-credential
+        // rate-limit в auth-контроллерах. Именованные лимитеры изолируют счётчики
+        // login / 2fa / password. Применение — throttle:<name> в routes/web.php.
+        // 20/мин — стартовое значение (выше максимума тестовых циклов), снижать по
+        // боевому трафику. Runbook: docs/superpowers/runbooks/2026-06-17-auth-throttle-limits.md
+        foreach (['auth-login', 'auth-2fa', 'auth-password', 'auth-register'] as $limiterName) {
+            RateLimiter::for(
+                $limiterName,
+                fn (Request $request) => Limit::perMinute(20)->by($request->ip() ?: 'unknown'),
+            );
+        }
+
+        // G7-B: заменяем Sanctum PersonalAccessToken на расширение, которое
+        // возвращает null для lpimp_-токенов без запроса к personal_access_tokens.
+        // Проект использует SPA cookie-auth — таблица personal_access_tokens отсутствует.
+        Sanctum::usePersonalAccessTokenModel(PersonalAccessToken::class);
+
+        // G7-B: кастомный auth-guard «impersonation».
+        // По Bearer-токену вида lpimp_<id>_<secret> резолвит первого активного
+        // пользователя тенанта из impersonation_tokens.
+        // Запросы к БД идут через pgsql_supplier (BYPASSRLS), чтобы не упереться
+        // в RLS до SetTenantContext (middleware «tenant» применяется позже).
+        Auth::viaRequest('impersonation', function (Request $request) {
+            $header = (string) $request->header('Authorization', '');
+            if (! str_starts_with($header, 'Bearer lpimp_')) {
+                return null;
+            }
+            $raw = trim(substr($header, 7)); // lpimp_<id>_<secret>
+            $parts = explode('_', $raw, 3);
+            if (count($parts) !== 3 || $parts[0] !== 'lpimp' || ! ctype_digit($parts[1])) {
+                return null;
+            }
+            $idStr = $parts[1];
+            $secret = $parts[2];
+
+            $token = ImpersonationToken::on('pgsql_supplier')->find((int) $idStr);
+            if ($token === null || $token->session_token_hash === null || ! $token->isSessionActive()) {
+                return null;
+            }
+            if (! Hash::check($secret, (string) $token->session_token_hash)) {
+                return null;
+            }
+
+            return User::on('pgsql_supplier')
+                ->where('tenant_id', $token->tenant_id)
+                ->where('is_active', true)
+                ->orderBy('id')
+                ->first();
+        });
     }
 }

app/app/Services/Auth/RegistrationException.php

@@ -0,0 +1,21 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App\Services\Auth;
+
+use RuntimeException;
+
+/**
+ * Доменная ошибка самозаписи. reason — машинный код для ответа контроллера:
+ * email_taken | captcha_failed | not_found | expired | too_many_attempts | invalid_code.
+ */
+final class RegistrationException extends RuntimeException
+{
+    public function __construct(
+        public readonly string $reason,
+        public readonly ?int $attemptsRemaining = null,
+    ) {
+        parent::__construct($reason);
+    }
+}

app/app/Services/Auth/RegistrationService.php

@@ -0,0 +1,264 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App\Services\Auth;
+
+use App\Mail\EmailVerificationCodeMail;
+use App\Models\EmailVerification;
+use App\Models\Tenant;
+use App\Models\User;
+use App\Services\Captcha\CaptchaVerifier;
+use Illuminate\Support\Facades\DB;
+use Illuminate\Support\Facades\Hash;
+use Illuminate\Support\Facades\Log;
+use Illuminate\Support\Facades\Mail;
+use Illuminate\Support\Str;
+
+/**
+ * Оркестрация самозаписи (G1/SP1): register / confirm / resend.
+ *
+ * Все обращения к tenants/users/email_verifications — через BYPASSRLS-подключение
+ * pgsql_supplier: публичные роуты не выставляют app.current_tenant_id, и под RLS
+ * (роль crm_app_user) SELECT/INSERT по этим таблицам не прошёл бы.
+ *
+ * Гонка дублей: в схеме нет глобального UNIQUE(users.email) (только
+ * UNIQUE(tenant_id,email)), поэтому «проверка-потом-вставка» сериализуется
+ * advisory-локом по email внутри транзакции — два параллельных register на один
+ * новый email не создадут два тенанта (лок снимается на commit/rollback).
+ */
+class RegistrationService
+{
+    private const DB_CONNECTION = 'pgsql_supplier';
+
+    private const CODE_TTL_MINUTES = 15;
+
+    private const MAX_FAILED_ATTEMPTS = 5;
+
+    private const START_BALANCE_RUB = '300.00';
+
+    public function __construct(private readonly CaptchaVerifier $captcha) {}
+
+    /**
+     * @return array{status:string, user:User, verification:EmailVerification, dev_code:?string}
+     */
+    public function register(string $email, string $password, ?string $captchaToken, ?string $ip): array
+    {
+        if (! $this->captcha->verify($captchaToken, $ip)) {
+            throw new RegistrationException('captcha_failed');
+        }
+
+        $email = mb_strtolower(trim($email));
+        $conn = DB::connection(self::DB_CONNECTION);
+
+        // Сериализация одновременных регистраций одного email (TOCTOU-защита, см. docblock).
+        // Письмо отправляем ПОСЛЕ commit — не держим SMTP внутри транзакции.
+        $issued = $this->atomic(function () use ($conn, $email, $password) {
+            $conn->statement('SELECT pg_advisory_xact_lock(hashtext(?))', ['liderra:self-register:'.$email]);
+
+            $existing = User::on(self::DB_CONNECTION)->where('email', $email)->first();
+            if ($existing && $existing->is_active) {
+                throw new RegistrationException('email_taken');
+            }
+
+            $user = $existing ?: $this->createPendingTenantOwner($email, $password);
+
+            return $this->createCodeRecord($user);
+        });
+
+        $this->sendCode($issued['user']->email, $issued['plain']);
+
+        return [
+            'status' => 'pending_email_confirm',
+            'user' => $issued['user'],
+            'verification' => $issued['record'],
+            'dev_code' => $issued['dev_code'],
+        ];
+    }
+
+    public function confirm(string $email, string $code): User
+    {
+        $email = mb_strtolower(trim($email));
+        $user = User::on(self::DB_CONNECTION)->where('email', $email)->first();
+        if (! $user) {
+            throw new RegistrationException('not_found');
+        }
+
+        $record = EmailVerification::on(self::DB_CONNECTION)
+            ->where('user_id', $user->id)
+            ->whereNull('verified_at')
+            ->orderByDesc('id')
+            ->first();
+
+        if (! $record || ! $record->isUsable()) {
+            $reason = $record === null ? 'not_found'
+                : ($record->isExpired() ? 'expired' : 'too_many_attempts');
+            throw new RegistrationException($reason);
+        }
+
+        if (! Hash::check($code, (string) $record->code_hash)) {
+            // increment ВНЕ транзакции: счётчик должен пережить 422 (откат сбросил
+            // бы failed_attempts и сломал лимит 5 попыток).
+            $record->increment('failed_attempts');
+            throw new RegistrationException(
+                'invalid_code',
+                max(0, self::MAX_FAILED_ATTEMPTS - $record->failed_attempts),
+            );
+        }
+
+        // Успех — атомарно: пометка кода + активация владельца + статус/баланс тенанта.
+        $this->atomic(function () use ($record, $user): void {
+            $record->update(['verified_at' => now()]);
+            $user->update(['is_active' => true]);
+            Tenant::on(self::DB_CONNECTION)->where('id', $user->tenant_id)->update([
+                'status' => 'active',
+                'balance_rub' => self::START_BALANCE_RUB,
+            ]);
+        });
+
+        return $user->fresh();
+    }
+
+    /** @return ?string dev-код (только local/testing), иначе null. Anti-enumeration: тихо для active/missing. */
+    public function resend(string $email): ?string
+    {
+        $email = mb_strtolower(trim($email));
+        $conn = DB::connection(self::DB_CONNECTION);
+
+        $issued = $this->atomic(function () use ($conn, $email) {
+            $conn->statement('SELECT pg_advisory_xact_lock(hashtext(?))', ['liderra:self-register:'.$email]);
+
+            $user = User::on(self::DB_CONNECTION)->where('email', $email)->first();
+            if ($user && ! $user->is_active) {
+                return $this->createCodeRecord($user);
+            }
+
+            return null;
+        });
+
+        if ($issued === null) {
+            return null;
+        }
+
+        $this->sendCode($issued['user']->email, $issued['plain']);
+
+        return $issued['dev_code'];
+    }
+
+    /**
+     * Выполнить $work атомарно на pgsql_supplier.
+     *
+     * Прод-путь: соединение НЕ в транзакции → открываем свою (`transaction()`),
+     * advisory xact-lock держится до commit/rollback — корректная сериализация.
+     *
+     * Если PDO УЖЕ в транзакции (внешний caller обернул нас ИЛИ тест-харнес
+     * SharesSupplierPdo делит уже-открытый PDO под DatabaseTransactions) —
+     * участвуем в существующей транзакции без вложенного beginTransaction:
+     * pgsql_supplier-connection не отслеживает уровень внешней транзакции, и
+     * `transaction()` попытался бы `PDO::beginTransaction()` поверх открытой →
+     * «There is already an active transaction». Это nested-transaction-safety,
+     * не тест-специфичная ветка: повторный вызов внутри открытой транзакции
+     * корректно переиспользует её.
+     *
+     * @template T
+     *
+     * @param  callable():T  $work
+     * @return T
+     */
+    private function atomic(callable $work): mixed
+    {
+        $conn = DB::connection(self::DB_CONNECTION);
+
+        if ($conn->getPdo()->inTransaction()) {
+            return $work();
+        }
+
+        return $conn->transaction($work);
+    }
+
+    private function createPendingTenantOwner(string $email, string $password): User
+    {
+        $tenant = Tenant::on(self::DB_CONNECTION)->create([
+            'subdomain' => $this->generateSubdomain($email),
+            'organization_name' => $email,   // плейсхолдер; уточняется в SP2 (реквизиты)
+            'contact_email' => $email,
+            'balance_rub' => 0,
+            'is_trial' => true,
+        ]);
+        // tenants.status НЕ в $fillable модели Tenant (колонка DEFAULT 'active') —
+        // выставляем явно, минуя mass-assignment; иначе самозапись активировала бы
+        // тенанта до подтверждения почты (баг: tenant создавался 'active').
+        $tenant->status = 'pending_email_confirm';
+        $tenant->save();
+
+        return User::on(self::DB_CONNECTION)->create([
+            'tenant_id' => $tenant->id,
+            'email' => $email,
+            'password_hash' => Hash::make($password),
+            'first_name' => 'Новый',
+            'last_name' => 'клиент',
+            'is_active' => false,
+            'totp_enabled' => false,
+        ]);
+    }
+
+    /**
+     * @return array{user:User, record:EmailVerification, plain:string, dev_code:?string}
+     */
+    private function createCodeRecord(User $user): array
+    {
+        // Гасим прежние непогашенные коды этого пользователя (делаем неюзабельными).
+        EmailVerification::on(self::DB_CONNECTION)
+            ->where('user_id', $user->id)
+            ->whereNull('verified_at')
+            ->update(['failed_attempts' => self::MAX_FAILED_ATTEMPTS]);
+
+        $plain = (string) random_int(100_000, 999_999);
+
+        $record = EmailVerification::on(self::DB_CONNECTION)->create([
+            'user_id' => $user->id,
+            'email' => $user->email,
+            'token' => (string) Str::uuid(),
+            'code_hash' => Hash::make($plain),
+            'failed_attempts' => 0,
+            'expires_at' => now()->addMinutes(self::CODE_TTL_MINUTES),
+        ]);
+
+        return [
+            'user' => $user,
+            'record' => $record,
+            'plain' => $plain,
+            'dev_code' => app()->environment('local', 'testing') ? $plain : null,
+        ];
+    }
+
+    private function sendCode(string $email, string $plain): void
+    {
+        // Письмо ставим в очередь (не держим SMTP в HTTP-пути) и НЕ валим самозапись
+        // при сбое доставки: запись кода уже создана, клиент может «отправить повторно».
+        // Email в лог не пишем (ПДн §5.2) — только факт и текст ошибки.
+        try {
+            Mail::to($email)->queue(new EmailVerificationCodeMail($plain, $email));
+        } catch (\Throwable $e) {
+            Log::warning('register: не удалось поставить письмо с кодом в очередь: '.$e->getMessage());
+        }
+    }
+
+    private function generateSubdomain(string $email): string
+    {
+        $base = Str::of($email)->before('@')->lower()->replaceMatches('/[^a-z0-9]/', '')->value();
+        if ($base === '') {
+            $base = 'client';
+        }
+        $base = Str::limit($base, 50, '');
+
+        $candidate = $base;
+        $i = 0;
+        while (Tenant::on(self::DB_CONNECTION)->where('subdomain', $candidate)->exists()) {
+            $i++;
+            $candidate = $base.$i;
+        }
+
+        return Str::limit($candidate, 63, '');
+    }
+}

app/app/Services/Billing/RunwayCalculator.php

@@ -0,0 +1,46 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App\Services\Billing;
+
+use Illuminate\Support\Facades\DB;
+
+/**
+ * Единый расчёт «на сколько дней хватит affordable_leads» (F3, 17.06.2026).
+ *
+ * Единственный источник истины для прогноза runway — используется и биллингом
+ * (BillingController::wallet), и дашбордом (DashboardController::summary), чтобы
+ * исключить расхождение «0 дней (дашборд) ↔ N дней (биллинг)»: раньше дашборд
+ * считал от legacy `balance_leads`, а биллинг — от рублёвого affordable.
+ *
+ * Billing v2 Spec A: affordable_leads — выход BalanceToLeadsConverter (точная
+ * конверсия ₽ по ступеням), делённый на среднюю скорость списания за 30 дней
+ * (count(lead_charges)/30).
+ *
+ * - affordable_leads ≤ 0 → 0 (тенант не может купить ни одного лида).
+ * - leadsLast30Days = 0 → null (нет истории, не от чего считать).
+ * - иначе → floor(affordable_leads / (leadsLast30Days / 30)).
+ */
+class RunwayCalculator
+{
+    public function daysLeft(int $tenantId, int $affordableLeads): ?int
+    {
+        if ($affordableLeads <= 0) {
+            return 0;
+        }
+
+        $leadsLast30Days = (int) DB::table('lead_charges')
+            ->where('tenant_id', $tenantId)
+            ->where('charged_at', '>=', now()->subDays(30))
+            ->count();
+
+        if ($leadsLast30Days <= 0) {
+            return null;
+        }
+
+        $avgPerDay = $leadsLast30Days / 30.0;
+
+        return max(0, (int) floor($affordableLeads / $avgPerDay));
+    }
+}

app/app/Services/Captcha/CaptchaVerifier.php

@@ -0,0 +1,16 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App\Services\Captcha;
+
+/**
+ * Шов проверки капчи. SP1 — dev-драйвер NullCaptchaVerifier; реальный
+ * Yandex SmartCaptcha-драйвер подключается позже (SP3/ops) без изменения
+ * контроллера/сервиса — они зовут только этот интерфейс.
+ */
+interface CaptchaVerifier
+{
+    /** true — капча пройдена; false — отклонить регистрацию. */
+    public function verify(?string $token, ?string $ip = null): bool;
+}

app/app/Services/Captcha/NullCaptchaVerifier.php

@@ -0,0 +1,22 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App\Services\Captcha;
+
+/**
+ * Dev/test-драйвер: пустой токен — всегда провал; непустой — исход из конфига
+ * services.captcha.fake_passes (тест переключает на false, чтобы проверить
+ * ветку отклонения). На prod вместо него встанет Yandex SmartCaptcha-драйвер.
+ */
+final class NullCaptchaVerifier implements CaptchaVerifier
+{
+    public function verify(?string $token, ?string $ip = null): bool
+    {
+        if ($token === null || $token === '') {
+            return false;
+        }
+
+        return (bool) config('services.captcha.fake_passes', true);
+    }
+}

app/app/Services/DaData/DaDataBudgetGuard.php

@@ -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');
+    }
+}

app/app/Services/DaData/DaDataException.php

@@ -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 {}

app/app/Services/DaData/DaDataPartyClient.php

@@ -0,0 +1,76 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App\Services\DaData;
+
+use App\Services\DaData\Dto\PartyLookupResult;
+use Illuminate\Http\Client\ConnectionException;
+use Illuminate\Http\Client\Factory as HttpFactory;
+
+/**
+ * Suggestions findById/party — подтяжка организации по ИНН (бесплатный эндпоинт DaData).
+ * POST https://suggestions.dadata.ru/suggestions/api/4_1/rs/findById/party
+ *   Authorization: Token <api_key> ; body {"query":"<inn>"}
+ *
+ * Все ошибки (нет ключа / сеть / 4xx / 5xx / пустой ответ) → null (мягко, не бросаем).
+ */
+final class DaDataPartyClient implements PartyLookup
+{
+    private const URL = 'https://suggestions.dadata.ru/suggestions/api/4_1/rs/findById/party';
+
+    public function __construct(private readonly HttpFactory $http) {}
+
+    public function findByInn(string $inn): ?PartyLookupResult
+    {
+        $cfg = (array) config('services.dadata');
+        $apiKey = (string) ($cfg['api_key'] ?? '');
+        if ($apiKey === '') {
+            return null;
+        }
+        $timeoutSec = max(1, (int) round(((int) ($cfg['timeout_ms'] ?? 2000)) / 1000));
+
+        try {
+            $response = $this->http
+                ->asJson()
+                ->acceptJson()
+                ->timeout($timeoutSec)
+                ->withHeaders(['Authorization' => 'Token '.$apiKey])
+                ->post(self::URL, ['query' => $inn]);
+        } catch (ConnectionException) {
+            return null;
+        }
+
+        if (! $response->successful()) {
+            return null;
+        }
+
+        return $this->parse($response->json());
+    }
+
+    /** @param  mixed  $body */
+    private function parse($body): ?PartyLookupResult
+    {
+        $sug = (is_array($body) && isset($body['suggestions'][0]) && is_array($body['suggestions'][0]))
+            ? $body['suggestions'][0]
+            : null;
+        if ($sug === null) {
+            return null;
+        }
+
+        $data = is_array($sug['data'] ?? null) ? $sug['data'] : [];
+        $name = (string) ($sug['value'] ?? '');
+        if ($name === '') {
+            return null;
+        }
+
+        return new PartyLookupResult(
+            legalName: $name,
+            kpp: isset($data['kpp']) ? (string) $data['kpp'] : null,
+            ogrn: isset($data['ogrn']) ? (string) $data['ogrn'] : null,
+            address: isset($data['address']['value']) ? (string) $data['address']['value'] : null,
+            type: isset($data['type']) ? (string) $data['type'] : '',
+            raw: $sug,
+        );
+    }
+}

app/app/Services/DaData/DaDataPhoneClient.php

@@ -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,
+        );
+    }
+}

app/app/Services/DaData/DaDataPhoneResponse.php

@@ -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,
+    ) {}
+}

app/app/Services/DaData/DaDataQualityCode.php

@@ -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;
+}

app/app/Services/DaData/DaDataTimeoutException.php

@@ -0,0 +1,11 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App\Services\DaData;
+
+/**
+ * Сетевая ошибка / таймаут DaData (после исчерпания retry на сетевые сбои).
+ * Подкласс DaDataException — catch(DaDataException) покрывает оба случая.
+ */
+class DaDataTimeoutException extends DaDataException {}

app/app/Services/DaData/Dto/PartyLookupResult.php

@@ -0,0 +1,18 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App\Services\DaData\Dto;
+
+final class PartyLookupResult
+{
+    /** @param  array<string,mixed>  $raw */
+    public function __construct(
+        public readonly string $legalName,
+        public readonly ?string $kpp,
+        public readonly ?string $ogrn,
+        public readonly ?string $address,
+        public readonly string $type,   // 'LEGAL' | 'INDIVIDUAL' | ''
+        public readonly array $raw,
+    ) {}
+}

app/app/Services/DaData/NullPartyLookup.php

@@ -0,0 +1,15 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App\Services\DaData;
+
+use App\Services\DaData\Dto\PartyLookupResult;
+
+final class NullPartyLookup implements PartyLookup
+{
+    public function findByInn(string $inn): ?PartyLookupResult
+    {
+        return null; // dev/тесты по умолчанию — «не найдено»
+    }
+}

app/app/Services/DaData/PartyLookup.php

@@ -0,0 +1,12 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App\Services\DaData;
+
+use App\Services\DaData\Dto\PartyLookupResult;
+
+interface PartyLookup
+{
+    public function findByInn(string $inn): ?PartyLookupResult;
+}

app/app/Services/Dto/RegionResolution.php

@@ -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,
+        );
+    }
+}

app/app/Services/Dto/RossvyazRecord.php

@@ -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,
+    ) {}
+}

app/app/Services/Import/HistoricalImportService.php

@@ -8,7 +8,6 @@ use App\Models\Deal;
 use App\Models\ImportLog;
 use App\Models\ImportUnknownStatus;
 use App\Models\Project;
-use App\Models\Reminder;
 use App\Services\MonthlyPartitionManager;
 use App\Services\Pd\PdAuditLogger;
 use Illuminate\Support\Facades\DB;
@@ -164,7 +163,6 @@ final class HistoricalImportService
                     'contact_name' => $row->contactName,
                     'comment' => $row->comment,
                 ]);
-                $this->syncReminder($tenantId, $userId, $deal, $row);
 
                 return false;
             }
@@ -188,8 +186,6 @@ final class HistoricalImportService
                 'created_at' => now(),
             ]);
 
-            $this->syncReminder($tenantId, $userId, $deal, $row);
-
             $this->pdLog->record(
                 action: 'created',
                 subjectType: 'lead',
@@ -205,35 +201,6 @@ final class HistoricalImportService
         });
     }
 
-    /**
-     * Создаёт reminders-строку для непустого «Напоминание» (ТЗ §6.3 — поле
-     * deals.reminder_at удалено в v8.3, заменено таблицей reminders).
-     * Идемпотентно: не дублирует напоминание при повторном импорте.
-     */
-    private function syncReminder(int $tenantId, int $userId, Deal $deal, ParsedLeadRow $row): void
-    {
-        if ($row->reminderAt === null) {
-            return;
-        }
-
-        $exists = Reminder::query()
-            ->where('deal_id', $deal->id)
-            ->where('remind_at', $row->reminderAt)
-            ->exists();
-
-        if ($exists) {
-            return;
-        }
-
-        Reminder::create([
-            'tenant_id' => $tenantId,
-            'deal_id' => $deal->id,
-            'text' => 'Импортировано из crm.bp-gr.ru',
-            'remind_at' => $row->reminderAt,
-            'created_by' => $userId,
-        ]);
-    }
-
     /**
      * upsert import_unknown_statuses: инкремент occurrences, маппинг не трогаем.
      *

app/app/Services/LeadRegionResolver.php

@@ -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);
+    }
+}

app/app/Services/LeadRouter.php

@@ -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
     {

app/app/Services/MonthlyPartitionManager.php

@@ -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',
     ];
 
     /**
@@ -91,6 +93,22 @@ class MonthlyPartitionManager
     {
         $this->assertKnownTable($table);
 
+        // migrate:fresh resilience: skip gracefully if the partitioned parent table
+        // does not exist yet. The initial schema-load migration runs
+        // partitions:create-months before later delta-migrations create their own
+        // partitioned tables (project_routing_snapshots, lead_region_resolution_log);
+        // those migrations create their own partitions. Skipping a not-yet-existing
+        // parent here avoids crashing the whole run — and is a targeted guard, so any
+        // other DDL error still surfaces.
+        $parentExists = DB::selectOne(
+            "SELECT 1 AS ok FROM pg_class WHERE relname = ? AND relkind = 'p'",
+            [$table],
+        );
+
+        if ($parentExists === null) {
+            return false;
+        }
+
         $partitionKey = self::PARTITIONED_TABLES[$table];
         $start = $monthStart->copy()->startOfMonth();
         $end = $start->copy()->addMonth();

app/app/Services/NotificationService.php

@@ -5,14 +5,12 @@ declare(strict_types=1);
 namespace App\Services;
 
 use App\Mail\InvoicePaidNotification;
-use App\Mail\NewLeadNotification;
-use App\Mail\ReminderDueNotification;
+use App\Mail\NewLeadsDigestMail;
 use App\Mail\TopupSuccessNotification;
 use App\Mail\ZeroBalancePausedMail;
 use App\Models\Deal;
 use App\Models\InAppNotification;
 use App\Models\Project;
-use App\Models\Reminder;
 use App\Models\Tenant;
 use App\Models\User;
 use Illuminate\Support\Collection;
@@ -27,7 +25,6 @@ use Throwable;
  * Матрица 8 событий × 3 каналов (inapp / push / email) хранится в
  * `users.notification_preferences` JSONB. По умолчанию (см. schema.sql:699):
  *   new_lead         {inapp:true, push:true, email:false}
- *   reminder         {inapp:true, push:true, email:true}
  *   low_balance      {email:true}
  *   zero_balance     {email:true}
  *   topup_success    {email:true}
@@ -44,8 +41,6 @@ class NotificationService
 {
     public const EVENT_NEW_LEAD = 'new_lead';
 
-    public const EVENT_REMINDER = 'reminder';
-
     public const EVENT_LOW_BALANCE = 'low_balance';
 
     public const EVENT_ZERO_BALANCE = 'zero_balance';
@@ -60,7 +55,6 @@ class NotificationService
 
     public const ALL_EVENTS = [
         self::EVENT_NEW_LEAD,
-        self::EVENT_REMINDER,
         self::EVENT_LOW_BALANCE,
         self::EVENT_ZERO_BALANCE,
         self::EVENT_TOPUP_SUCCESS,
@@ -90,11 +84,8 @@ class NotificationService
     {
         $projectName = $deal->project?->name ?? 'Без проекта';
 
-        // Канал email.
-        foreach ($this->recipientsForEvent($tenant, self::EVENT_NEW_LEAD, self::CHANNEL_EMAIL) as $user) {
-            $this->sendEmail($user, self::EVENT_NEW_LEAD, new NewLeadNotification($user, $deal, $tenant));
-        }
-
+        // Канал email события new_lead переведён на дайджест (SendNewLeadsDigestJob).
+        // Здесь — только in-app (колокольчик) на каждую сделку.
         // Канал inapp.
         $title = "Новый лид — {$projectName}";
         $body = $deal->contact_name ?: $deal->phone;
@@ -107,41 +98,14 @@ class NotificationService
     }
 
     /**
-     * Уведомление о наступлении срока напоминания. Получатели:
-     *   — assignee_id, если задан и активен;
-     *   — иначе created_by (создатель напоминания).
-     *
-     * Каналы: email + inapp по prefs пользователя. Триггер — Artisan
-     * команда `reminders:dispatch-due`.
+     * G2-A дайджест: одно письмо-сводка о новых сделках за окно — каждому
+     * активному пользователю тенанта с включённым new_lead.email. Заменяет
+     * пер-лид email-канал события new_lead.
      */
-    public function notifyReminder(Reminder $reminder): void
+    public function notifyNewLeadsDigest(Tenant $tenant, Collection $deals): void
     {
-        $recipientId = $reminder->assignee_id ?? $reminder->created_by;
-        $recipient = User::query()
-            ->where('id', $recipientId)
-            ->where('tenant_id', $reminder->tenant_id)
-            ->where('is_active', true)
-            ->whereNull('deleted_at')
-            ->first();
-
-        if ($recipient === null) {
-            // Получатель удалён/деактивирован — некому слать.
-            return;
-        }
-
-        $shortText = $reminder->text ? mb_substr($reminder->text, 0, 80) : 'Срок касания клиента';
-        $title = "Напоминание — {$shortText}";
-        $body = 'Сделка #'.$reminder->deal_id;
-
-        if ($this->prefEnabled($recipient, self::EVENT_REMINDER, self::CHANNEL_EMAIL)) {
-            $this->sendEmail($recipient, self::EVENT_REMINDER, new ReminderDueNotification($recipient, $reminder));
-        }
-
-        if ($this->prefEnabled($recipient, self::EVENT_REMINDER, self::CHANNEL_INAPP)) {
-            $this->notifyInApp($recipient, self::EVENT_REMINDER, $title, $body, [
-                'reminder_id' => $reminder->id,
-                'deal_id' => $reminder->deal_id,
-            ]);
+        foreach ($this->recipientsForEvent($tenant, self::EVENT_NEW_LEAD, self::CHANNEL_EMAIL) as $user) {
+            $this->sendEmail($user, self::EVENT_NEW_LEAD, new NewLeadsDigestMail($user, $tenant, $deals));
         }
     }
 

app/app/Services/Pd/PdErasureService.php

@@ -135,45 +135,56 @@ class PdErasureService
             $counts['leads'] = $leads->count();
 
             // ------------------------------------------------------------------
-            // 3. deals  (phone + contact_name)
-            //    Deals партиционированы — UPDATE без WHERE на партиции через
-            //    parent table работает начиная с PG 11+.
+            // 3. deals  (скалярный phone + JSONB phones — доп. телефоны субъекта)
+            //    Email в deals не хранится (нет колонки и нет JSONB-поля с email),
+            //    поэтому erasure только по email для сделок — корректный no-op:
+            //    сопоставлять нечего, counts['deals'] остаётся 0 (F-P1b, решение 2).
+            //    Сделки партиционированы — UPDATE по id на parent работает на PG 11+.
             // ------------------------------------------------------------------
-            $dealQuery = DB::connection(self::DB)->table('deals');
-            $dealQuery->where(function ($q) use ($email, $phone): void {
-                if ($phone !== null) {
-                    $q->orWhere('phone', $phone);
+            if ($phone !== null) {
+                $dealQuery = DB::connection(self::DB)->table('deals');
+                $dealQuery->where(function ($q) use ($phone): void {
+                    $q->where('phone', $phone)
+                        ->orWhereRaw('phones @> ?::jsonb', [json_encode([$phone])]);
+                });
+                if ($tenantId !== null) {
+                    $dealQuery->where('tenant_id', $tenantId);
                 }
-                if ($email !== null) {
-                    // Дополнительно: UTM/phones JSONB может хранить email, но в
-                    // минимуме ищем только по phone. Email в deals не хранится
-                    // в отдельной колонке.
+
+                $deals = $dealQuery->get(['id', 'phone', 'phones']);
+
+                // Хирургическое удаление телефона субъекта из JSONB-массива доп.
+                // телефонов: остаются все элементы, не равные $phone; пустой
+                // результат -> NULL. COALESCE — NULL-безопасность; порядок
+                // со-контактов сохраняется (152-ФЗ: чужие телефоны не трогаем).
+                $phonesScrubExpr = '(SELECT JSONB_AGG(elem) '
+                    ."FROM JSONB_ARRAY_ELEMENTS(COALESCE(phones, '[]'::jsonb)) AS elem "
+                    .'WHERE elem <> TO_JSONB(?::text))';
+
+                foreach ($deals as $deal) {
+                    $dealId = (int) $deal->id;
+
+                    if ($deal->phone === $phone) {
+                        // Субъект — владелец сделки: анонимизируем скалярные ПДн
+                        // и хирургически чистим массив доп. телефонов.
+                        DB::connection(self::DB)->update(
+                            'UPDATE deals SET phone = ?, contact_name = ?, '
+                            ."phones = {$phonesScrubExpr}, updated_at = ? WHERE id = ?",
+                            ['+7000XXXXXXX', 'Удалено', $phone, $now, $dealId],
+                        );
+                    } else {
+                        // Субъект — лишь доп. телефон чужой сделки: скалярные
+                        // phone/contact_name владельца НЕ трогаем, чистим только массив.
+                        DB::connection(self::DB)->update(
+                            "UPDATE deals SET phones = {$phonesScrubExpr}, "
+                            .'updated_at = ? WHERE id = ?',
+                            [$phone, $now, $dealId],
+                        );
+                    }
                 }
-            });
-            if ($tenantId !== null) {
-                $dealQuery->where('tenant_id', $tenantId);
+
+                $counts['deals'] = $deals->count();
             }
-            // Исключаем строки без совпадения по phone (когда phone=null — ничего не ищем)
-            if ($phone === null) {
-                // deals не имеет email-колонки, пропускаем
-                $dealQuery->whereRaw('FALSE');
-            }
-
-            $deals = $dealQuery->get(['id']);
-
-            foreach ($deals as $deal) {
-                $dealId = (int) $deal->id;
-
-                DB::connection(self::DB)->table('deals')
-                    ->where('id', $dealId)
-                    ->update([
-                        'phone' => '+7000XXXXXXX',
-                        'contact_name' => 'Удалено',
-                        'updated_at' => $now,
-                    ]);
-            }
-
-            $counts['deals'] = $deals->count();
 
             // ------------------------------------------------------------------
             // 4. Обновить pd_subject_requests если requestId передан

app/app/Services/Requisites/RequisitesService.php

@@ -0,0 +1,46 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App\Services\Requisites;
+
+use App\Models\Tenant;
+use App\Models\TenantRequisites;
+use App\Support\PhoneNormalizer;
+
+final class RequisitesService
+{
+    /**
+     * @param  array<string,mixed>  $data  валидированный payload (телефон ещё в сыром виде)
+     */
+    public function upsert(Tenant $tenant, array $data): TenantRequisites
+    {
+        if (isset($data['contact_phone'])) {
+            $data['contact_phone'] = PhoneNormalizer::normalize((string) $data['contact_phone']);
+        }
+
+        $req = TenantRequisites::firstOrNew(['tenant_id' => $tenant->id]);
+        $req->fill($data);
+        $req->tenant_id = $tenant->id;
+        $req->requisites_completed_at = filled($req->bank_account) ? now() : null;
+        $req->save();
+
+        return $req;
+    }
+
+    public function isLightComplete(Tenant $tenant): bool
+    {
+        $r = TenantRequisites::where('tenant_id', $tenant->id)->first();
+        if ($r === null) {
+            return false;
+        }
+        if (blank($r->subject_type) || blank($r->contact_name) || blank($r->contact_phone)) {
+            return false;
+        }
+        if (in_array($r->subject_type, ['legal_entity', 'sole_proprietor'], true) && blank($r->inn)) {
+            return false;
+        }
+
+        return true;
+    }
+}

app/app/Services/RossvyazPrefixLookup.php

@@ -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,
+        );
+    }
+}

app/app/Support/DaDataRegionMap.php

@@ -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);
+    }
+}

app/app/Support/Imitation/README.md

@@ -0,0 +1,83 @@
+# Imitation Harness — выверенные сигнатуры (Task 0)
+
+Опорный файл для субагентов Фазы 1. Все сигнатуры подтверждены чтением `origin/main`
+(базовый коммит `bd7b1d3e`). НЕ угадывать — сверяться отсюда.
+
+Спек: `docs/superpowers/specs/2026-06-03-portal-client-imitation-phase1-design.md`
+План: `docs/superpowers/plans/2026-06-03-portal-client-imitation-phase1.md`
+
+## ⚠️ КРИТИЧЕСКИЕ ПРАВКИ К ПЛАНУ (иначе ghost'ы)
+
+1. **Коды субъектов — порядковые 1..89, НЕ коды ГИБДД.** В `App\Support\RussianRegions::CODE_TO_NAME`:
+   `82 => 'Москва'`, `83 => 'Санкт-Петербург'`, `77 => 'Тюменская область'`.
+   В тестах/сеялке использовать коды ТОЛЬКО через `RussianRegions::CODE_TO_NAME` /
+   `RussianRegions::nameToCode()`. Пример в плане «77=Москва» — НЕВЕРЕН, Москва = **82**.
+2. **`DaDataPhoneResponse`** — `final readonly`, конструктор 9 аргументов:
+   `(?int $qc, ?int $qcConflict, ?string $type, ?string $phone, ?string $provider, ?string $region, ?string $city, ?string $timezone, array $raw)`.
+3. **`DaDataPhoneClient`** — НЕ final, `__construct(private readonly HttpFactory $http)`,
+   метод `cleanPhone(string $phone): DaDataPhoneResponse`. Фейк — наследник с переопределённым
+   конструктором (без вызова parent) + `cleanPhone`; биндить `app()->instance(DaDataPhoneClient::class, $fake)`.
+4. **Снапшот в Pest-тестах** — НЕ через job (он строит только `tomorrow`). Использовать
+   существующие Pest-хелперы из `app/tests/Pest.php`: `createRoutingSnapshotFromProject(...)`
+   и `linkProjectToSupplier(Project, SupplierProject)`. Для живого портала (Task 14) —
+   `php artisan snapshot:rebuild --date=<activeDate>` (DELETE+INSERT, детерминированно).
+5. **`ProjectFactory`** — есть хелперы `asSiteSignal(string $domain)`, `asCallSignal(string $phone)`.
+   `regions` по умолчанию `'{}'` — задавать явно (массив кодов 1..89). `region_mask`/`region_mode` — legacy.
+6. **`TenantFactory`** НЕ задаёт `balance_rub` (default 0) и `frozen_by_balance_at` (null) — задавать
+   через `ConditionLevers`.
+7. **`deals`** (v8.40) имеет `subject_code` (SMALLINT), `phone_operator` (TEXT),
+   `region_substituted` (BOOLEAN default FALSE) — на них опирается X1.
+8. **RLS в тестах**: паттерн из `RlsSmokeTest` — `SET LOCAL ROLE testing_rls_user` +
+   `SET LOCAL app.current_tenant_id`. Sharing-flow роутинга идёт через `pgsql_supplier`
+   (BYPASSRLS) — следовать существующим slepok/supplier feature-тестам.
+9. **Деградация DaData**: фейк бросает `App\Services\DaData\DaDataException` (extends RuntimeException) —
+   резолвер ловит её и уходит на Россвязь (ветка qc=1 / таймаут / 5xx).
+10. `SupplierLeadFactory` существует (поля: supplier_project_id, platform, raw_payload, vid, phone,
+    received_at, source, processed_at, deals_created_count, error).
+
+## Сигнатуры (verbatim)
+
+### RegionResolution (`app/app/Services/Dto/RegionResolution.php`)
+```php
+final readonly class RegionResolution {
+  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,
+  ) {}
+  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
+  public static function fromSupplierLead(SupplierLead $lead): self
+  public static function fromTag(?int $subjectCode): self
+  public function withCacheHit(bool $hit): self
+  public function forCache(): self
+}
+```
+
+### RossvyazPrefixLookup / RossvyazRecord
+```php
+public function find(string $phone): ?RossvyazRecord
+final readonly class RossvyazRecord { public function __construct(public ?int $subjectCode, public string $region, public string $operator) {} }
+```
+
+### LeadRouter (прод)
+`matchEligibleProjects(SupplierProject $sp, ?int $resolvedSubjectCode = null): Collection<Project>`
+— 3-фазный каскад (exact→all_ru→any), `routing_step` 1/2/3, взвешенный жребий (вес = остаток лимита, ≥1), cap=3. Конструктор: `__construct(private readonly Randomizer $randomizer = new Randomizer)` — в тестах инъектировать сиданный `new Randomizer(new Mt19937(seed))`.
+
+### Снапшот
+- `project_routing_snapshots` колонки: snapshot_date, project_id, tenant_id, daily_limit, delivery_days_mask, regions (int[] default '{}'), signal_type, signal_identifier, sms_senders, sms_keyword, expected_volume, delivered_count, created_at. PK (snapshot_date, project_id). Партиц. по snapshot_date. RLS.
+- `snapshot:backfill --date=YYYY-MM-DD` (idempotent ON CONFLICT DO NOTHING); `snapshot:rebuild --date=YYYY-MM-DD` (DELETE+INSERT).
+
+### Деньги (`LedgerService::chargeForDelivery(Tenant, Deal, ?SupplierLead): ChargeResult`)
+always-rub; тариф по `delivered_in_month+1`; `frozen_by_balance_at` → InsufficientBalance; bcmath `balance_rub*100 ≥ price`; пишет lead_charges (charge_source='rub') + balance_transactions + supplier_lead_costs.
+
+### Приём (`POST /api/webhook/supplier/{secret}`)
+secret ≥32 (`system_settings.supplier_webhook_secret`, hash_equals); IP allowlist (testing fail-open);
+rate-limit 600/мин/IP; time в ±24ч; phone `^7\d{10}$`; vid UNIQUE → дубль 200 «already_processed»; project без `B[123]_` → DIRECT.
+
+### Тест-бутстрап
+`TestCase::setUp` переводит redis cache в array. Feature-тесты: `pest()->extend(TestCase::class)->in('Feature')`. Хелперы `createRoutingSnapshotFromProject()` / `linkProjectToSupplier()` в `Pest.php`.
+
+## Открытые мелочи
+- `DaDataTimeoutException` используется в клиенте, но как отдельный класс не подтверждён — для деградации в тестах бросать базовый `DaDataException`.
+- Все тесты Фазы 1 — группа `imitation` (`->group('imitation')`), вне `composer test`.

app/app/Support/InnValidator.php

@@ -0,0 +1,54 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App\Support;
+
+final class InnValidator
+{
+    public static function isValid(string $inn, string $subjectType): bool
+    {
+        if ($subjectType === 'individual') {
+            return true; // физлицу ИНН не требуется (SP2)
+        }
+        if (! ctype_digit($inn)) {
+            return false;
+        }
+
+        return match ($subjectType) {
+            'legal_entity' => self::valid10($inn),
+            'sole_proprietor' => self::valid12($inn),
+            default => false,
+        };
+    }
+
+    private static function valid10(string $inn): bool
+    {
+        if (strlen($inn) !== 10) {
+            return false;
+        }
+
+        return self::checksum($inn, [2, 4, 10, 3, 5, 9, 4, 6, 8]) === (int) $inn[9];
+    }
+
+    private static function valid12(string $inn): bool
+    {
+        if (strlen($inn) !== 12) {
+            return false;
+        }
+
+        return self::checksum($inn, [7, 2, 4, 10, 3, 5, 9, 4, 6, 8]) === (int) $inn[10]
+            && self::checksum($inn, [3, 7, 2, 4, 10, 3, 5, 9, 4, 6, 8]) === (int) $inn[11];
+    }
+
+    /** @param  int[]  $weights */
+    private static function checksum(string $inn, array $weights): int
+    {
+        $sum = 0;
+        foreach ($weights as $i => $w) {
+            $sum += $w * (int) $inn[$i];
+        }
+
+        return ($sum % 11) % 10;
+    }
+}

app/app/Support/PhoneNormalizer.php

@@ -0,0 +1,26 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App\Support;
+
+final class PhoneNormalizer
+{
+    /**
+     * Нормализует российский номер к виду +7XXXXXXXXXX (12 символов) или null, если невалиден.
+     */
+    public static function normalize(string $raw): ?string
+    {
+        $digits = preg_replace('/\D+/', '', $raw) ?? '';
+
+        if (strlen($digits) === 11 && ($digits[0] === '8' || $digits[0] === '7')) {
+            $digits = '7'.substr($digits, 1);
+        } elseif (strlen($digits) === 10) {
+            $digits = '7'.$digits;
+        } else {
+            return null;
+        }
+
+        return '+'.$digits;
+    }
+}

app/app/Support/RussianRegions.php

@@ -114,9 +114,97 @@ 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;
+        }
+
+        // ХМАО приходит в множестве форм (em-dash/дефис, «Югра», « АО», капитализация) —
+        // ловим по двум устойчивым маркерам до общих правил.
+        if (mb_stripos($segment, 'Ханты') !== false && mb_stripos($segment, 'Мансийск') !== false) {
+            return 'Ханты-Мансийский автономный округ — Югра';
+        }
+
+        if (isset(self::REGION_ALIASES[$segment])) {
+            return self::REGION_ALIASES[$segment];
+        }
+
+        // «обл.» → «область»; « АО» → « автономный округ».
+        $name = (string) preg_replace('/\s*обл\.$/u', ' область', $segment);
+        $name = (string) preg_replace('/\s+АО$/u', ' автономный округ', $name);
+        // Дефис с пробелами → длинное тире (эталон: «Республика Северная Осетия — Алания»).
+        // Безопасно: ни одно каноническое имя не содержит дефис, окружённый пробелами
+        // (составные имена вроде «Кабардино-Балкарская» используют дефис без пробелов).
+        $name = str_replace(' - ', ' — ', $name);
+
+        if (isset(self::nameToCode()[$name])) {
+            return $name;
+        }
+
+        // Перевёрнутый порядок «Республика X» → «X Республика» (Удмуртская/Чеченская/
+        // Чувашская/Кабардино-Балкарская/Карачаево-Черкесская, Донецкая Народная/
+        // Луганская Народная). Республика-first каноны (Татарстан, Карелия…) уже
+        // отловлены прямым попаданием выше.
+        if (preg_match('/^Республика\s+(.+)$/u', $name, $m) === 1) {
+            $reordered = trim($m[1]).' Республика';
+            if (isset(self::nameToCode()[$reordered])) {
+                return $reordered;
+            }
+        }
+
+        return 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));
+    }
 }

app/app/Support/WebhookUrlGuard.php

@@ -38,6 +38,34 @@ final class WebhookUrlGuard
         return null;
     }
 
+    /**
+     * Один резолв хоста для доставки: причина блокировки И безопасный IP для
+     * пиннинга соединения. Закрывает DNS-rebind TOCTOU — блок-решение и адрес
+     * подключения берутся из ОДНОГО резолва, а не из двух независимых (как было
+     * бы при blockReason + повторный резолв в HTTP-клиенте).
+     *
+     * @return array{ip: string|null, blockReason: string|null}
+     */
+    public static function safeDeliveryIp(string $url): array
+    {
+        $host = parse_url($url, PHP_URL_HOST);
+        if (! is_string($host) || $host === '') {
+            return ['ip' => null, 'blockReason' => 'Некорректный URL webhook.'];
+        }
+        $host = trim($host, '[]');
+
+        $ips = self::resolve($host);
+        foreach ($ips as $ip) {
+            if (! self::isPublicIp($ip)) {
+                return ['ip' => null, 'blockReason' => 'URL webhook ведёт во внутреннюю/зарезервированную сеть — запрещено.'];
+            }
+        }
+
+        // Все записи публичны (или хост не резолвится → ip=null, пиннинг не
+        // применяется, запрос упадёт сам — как и в blockReason).
+        return ['ip' => $ips[0] ?? null, 'blockReason' => null];
+    }
+
     /** @return list<string> Все IP, в которые разрешается хост (пусто, если не разрешается). */
     private static function resolve(string $host): array
     {

app/bootstrap/app.php

@@ -1,6 +1,8 @@
 <?php
 
+use App\Http\Middleware\ApiKeyAuth;
 use App\Http\Middleware\EnsureSaasAdmin;
+use App\Http\Middleware\ImpersonationContext;
 use App\Http\Middleware\SetTenantContext;
 use Illuminate\Database\QueryException;
 use Illuminate\Foundation\Application;
@@ -24,8 +26,20 @@ return Application::configure(basePath: dirname(__DIR__))
         $middleware->alias([
             'tenant' => SetTenantContext::class,
             'saas-admin' => EnsureSaasAdmin::class,
+            'apikey' => ApiKeyAuth::class,
         ]);
 
+        $middleware->web(append: [
+            ImpersonationContext::class,
+        ]);
+
+        // Защитные HTTP-заголовки (CSP, X-Frame-Options, X-Content-Type-Options,
+        // Referrer-Policy, HSTS, Permissions-Policy, COOP/CORP) ставит nginx —
+        // единый источник: /etc/nginx/sites-available/liderra (add_header ... always).
+        // App-уровневый middleware SecurityHeaders удалён 18.06.2026: он дублировал
+        // те же заголовки, и на проде add_header always + PHP-заголовок давали дубль
+        // в ответе. CSP в nginx — enforcing (был Report-Only в middleware).
+
         // Webhook receive endpoint (POST /api/webhook/{token}) не должен требовать
         // CSRF — запросы приходят от внешних CRM-систем без сессии браузера.
         // Авторизация — через webhook_token в URL + (на prod) HMAC.