feat(pbn_api): interaktywne narzędzie pbn_test_wysylka_interaktywna (Faza 1)

.github/workflows/build-docker-images.yml

@@ -164,8 +164,19 @@ jobs:
             echo "::notice::Docker build — znaleziono flage [docker-build] w commit message"
           else
             echo "should_build=false" >> "$GITHUB_OUTPUT"
+            # Dla pull_request event github.ref_name to "<PR#>/merge"
+            # (wewnetrzny merge-ref GH, nie branch). `gh workflow run --ref`
+            # wymaga nazwy brancha — dla PR pobieramy ja z `gh pr view`,
+            # dla push event'u uzywamy REF_NAME.
+            if [ "$EVENT_NAME" = "pull_request" ]; then
+              PR_NUM="${REF_NAME%/merge}"
+              DISPATCH_REF=$(gh pr view "$PR_NUM" --repo "$REPO" \
+                             --json headRefName --jq '.headRefName')
+            else
+              DISPATCH_REF="$REF_NAME"
+            fi
             echo "::notice::Pomijam Docker build — brak flagi [docker-build] w commit message"
-            echo "::notice::Aby wymusic build, dodaj [docker-build] do commit message lub uruchom: gh workflow run build-docker-images.yml --ref ${REF_NAME}"
+            echo "::notice::Aby wymusic build, dodaj [docker-build] do commit message lub uruchom recznie: gh workflow run build-docker-images.yml --ref ${DISPATCH_REF}"
           fi
 
   docker:

src/bpp/admin/helpers/pbn_api/common.py

@@ -43,7 +43,7 @@ def sprawdz_wysylke_do_pbn_w_parametrach_uczelni(uczelnia):
     return uczelnia
 
 
-def sprobuj_wyslac_do_pbn(
+def sprobuj_wyslac_do_pbn(  # noqa: C901
     obj, pbn_client, uczelnia, notificator, force_upload=False, raise_exceptions=False
 ):
     # Sprawdź, czy wydawnictwo nadrzędne ma odpowoednik PBN:
@@ -156,7 +156,6 @@ def sprobuj_wyslac_do_pbn(
             obj,
             notificator=notificator,
             force_upload=force_upload,
-            delete_statements_before_upload=uczelnia.pbn_api_kasuj_przed_wysylka,
             export_pk_zero=not uczelnia.pbn_api_nie_wysylaj_prac_bez_pk,
             always_affiliate_to_uid=(
                 uczelnia.pbn_uid_id
@@ -247,8 +246,8 @@ def sprobuj_wyslac_do_pbn(
         extra = ""
         if link_do_wyslanych:
             extra = (
-                '<a target=_blank href="%s">Kliknij, aby otworzyć widok wysłanych danych</a>.'
-                % link_do_wyslanych
+                f'<a target=_blank href="{link_do_wyslanych}">'
+                f"Kliknij, aby otworzyć widok wysłanych danych</a>."
             )
 
         notificator.warning(

src/bpp/admin/uczelnia.py

@@ -106,7 +106,7 @@ class UczelniaAdmin(
                     "pbn_app_name",
                     "pbn_app_token",
                     "pbn_api_user",
-                    "pbn_api_kasuj_przed_wysylka",
+                    "pbn_kasuj_dyscypliny_selektywnie",
                     "pbn_api_nie_wysylaj_prac_bez_pk",
                     "pbn_api_afiliacja_zawsze_na_uczelnie",
                     "pbn_wysylaj_bez_oswiadczen",

src/bpp/migrations/0414_uczelnia_pbn_kasuj_dyscypliny_selektywnie.py

@@ -0,0 +1,32 @@
+from django.db import migrations, models
+
+
+class Migration(migrations.Migration):
+
+    dependencies = [
+        ("bpp", "0413_bppuser_autor_onetoone"),
+    ]
+
+    operations = [
+        migrations.RemoveField(
+            model_name="uczelnia",
+            name="pbn_api_kasuj_przed_wysylka",
+        ),
+        migrations.AddField(
+            model_name="uczelnia",
+            name="pbn_kasuj_dyscypliny_selektywnie",
+            field=models.BooleanField(
+                default=True,
+                help_text=(
+                    "Gdy zaznaczone: ``sync_publication`` usuwa oświadczenia "
+                    "selektywnie per-osoba (DELETE ``/publications/{id}`` z "
+                    "``{personId, role}``) i wysyła tylko brakujące. Gdy "
+                    "odznaczone: usuwa wszystkie oświadczenia publikacji jednym "
+                    "DELETE (``{all: True}``), a następnie wysyła wszystkie "
+                    "lokalne jako batch. Wariant selektywny zachowuje metadata "
+                    "PBN (``addedTimestamp`` itd.) dla identycznych rekordów."
+                ),
+                verbose_name="Kasuj oświadczenia selektywnie (per osoba)",
+            ),
+        ),
+    ]

src/bpp/migrations/0416_merge_20260504_1024.py

@@ -0,0 +1,13 @@
+# Generated by Django 5.2.13 on 2026-05-04 08:24
+
+from django.db import migrations
+
+
+class Migration(migrations.Migration):
+
+    dependencies = [
+        ("bpp", "0414_uczelnia_pbn_kasuj_dyscypliny_selektywnie"),
+        ("bpp", "0415_merge_20260504_0907"),
+    ]
+
+    operations = []

src/bpp/models/uczelnia.py

@@ -381,8 +381,18 @@ class Uczelnia(ModelZAdnotacjami, ModelZPBN_ID, NazwaISkrot, NazwaWDopelniaczu):
     pbn_app_token = models.CharField(
         "Token aplikacji w PBN", blank=True, default="", max_length=128
     )
-    pbn_api_kasuj_przed_wysylka = models.BooleanField(
-        "Kasuj oświadczenia rekordu przed wysłaniem do PBN", default=False
+    pbn_kasuj_dyscypliny_selektywnie = models.BooleanField(
+        "Kasuj oświadczenia selektywnie (per osoba)",
+        default=True,
+        help_text=(
+            "Gdy zaznaczone: ``sync_publication`` usuwa oświadczenia "
+            "selektywnie per-osoba (DELETE ``/publications/{id}`` z "
+            "``{personId, role}``) i wysyła tylko brakujące. Gdy "
+            "odznaczone: usuwa wszystkie oświadczenia publikacji jednym "
+            "DELETE (``{all: True}``), a następnie wysyła wszystkie "
+            "lokalne jako batch. Wariant selektywny zachowuje metadata "
+            "PBN (``addedTimestamp`` itd.) dla identycznych rekordów."
+        ),
     )
     pbn_api_nie_wysylaj_prac_bez_pk = models.BooleanField(
         "Nie wysyłaj do PBN prac z PK=0", default=False

src/bpp/newsfragments/+pbn-post-statements-subset.bugfix.rst

@@ -0,0 +1,17 @@
+Poprawka w ``sync_publication``: POST oświadczeń publikacji w trybie
+selektywnym (``Uczelnia.pbn_kasuj_dyscypliny_selektywnie=True``, default)
+wysyła teraz TYLKO oświadczenia brakujące w PBN (``only_in_intended``),
+nie pełen zestaw lokalnych. Wcześniej kod wywoływał
+``WydawnictwoPBNAdapter.pbn_get_api_statements()`` zwracające wszystkie
+lokalne statements i POST-ował kompletny zestaw — także te oświadczenia,
+które już były w PBN. Przy założeniu że API PBN może nie być
+idempotentne (odrzucić duplikaty, utworzyć zduplikowane rekordy albo
+zachowywać się nieprzewidywalnie), wysyłanie tylko brakujących jest
+bezpieczniejsze — nie dublujemy żądań dla już istniejących oświadczeń,
+co zachowuje ich metadata w PBN (``addedTimestamp`` itp.).
+
+Krok 3 algorytmu (PBN puste + BPP ma) nadal wysyła wszystkie oświadczenia
+publikacji, bo w tym scenariuszu ``only_in_intended`` = wszystkie klucze
+lokalne. Krok 5 (tryb batch, ``pbn_kasuj_dyscypliny_selektywnie=False``)
+pozostaje bez zmian — po ``delete_all`` PBN jest puste, więc POST wysyła
+pełen zestaw BPP (wipe+rewrite).

src/bpp/newsfragments/+pbn-sync-publication-split-flow.bugfix.rst

@@ -0,0 +1,28 @@
+Refaktoryzacja wysyłki publikacji do PBN (``sync_publication``): publikacja
+jest zawsze wysyłana przez endpoint repozytoryjny
+``POST /api/v1/repositorium/publications`` (bez oświadczeń w body), a
+dyscypliny/oświadczenia synchronizowane są w osobnym kroku przez
+``/api/v2/institution-profile/statements`` dopiero po potwierdzeniu
+wysyłki publikacji. Dzięki temu nieudana wysyłka publikacji (np. HTTP
+423 Locked albo inna przejściowa awaria PBN) nie kasuje już istniejących
+oświadczeń w profilu instytucji — wcześniej kasowanie działo się przed
+POST i tracono dane przy każdym niepowodzeniu.
+
+Algorytm synchronizacji oświadczeń: GET aktualnego stanu PBN, porównanie
+z intencją BPP (``WydawnictwoPBNAdapter.pbn_get_json_statements()``)
+przez klucz ``(personId, disciplineId)``, selektywne DELETE (per-osoba
+przez ``delete_publication_statement(personId, role)``) brakujących w
+BPP + POST dodatkowych. Tryb kasowania sterowany nową flagą
+``Uczelnia.pbn_kasuj_dyscypliny_selektywnie`` (domyślnie ``True``;
+``False`` używa ``delete_all`` + POST batch).
+
+Nowy wyjątek ``StatementsResendFailedException`` (w
+``pbn_api.exceptions``) jest podnoszony gdy retry x3 z exponential
+backoff (2s/4s/8s) na GET/DELETE/POST /v2/statements się wyczerpie.
+Klasyfikowany w ``pbn_export_queue`` jako ``RETRY_LATER`` — kolejka
+ponowi wysyłkę za kilka minut.
+
+Usunięto pole ``Uczelnia.pbn_api_kasuj_przed_wysylka`` (obsolete —
+stary pre-upload DELETE zastąpiony nowym algorytmem diff po wysyłce).
+Flaga ``Uczelnia.pbn_wysylaj_bez_oswiadczen`` pozostaje z dotychczasową
+semantyką (odmawia wysyłki publikacji bez oświadczeń).

src/bpp/newsfragments/+pbn-test-narzedzie-fix-compare.bugfix.rst

@@ -0,0 +1,20 @@
+Poprawka w narzędziu CLI ``pbn_test_wysylka_interaktywna``:
+
+- krok porównania oświadczeń (KROK 6/8) używał lokalnego cache'a
+  ``OswiadczenieInstytucji`` (snapshot z poprzedniej synchronizacji
+  PBN) jako reprezentanta „stanu BPP", co powodowało fałszywą
+  identyczność po zmianach w rekordzie — skasowaniu autora,
+  zmianie/wypięciu dyscypliny lub innej edycji ``Wydawnictwo_*_Autor``
+  (cache nie był re-synchronizowany, pokazywał stare 3 oświadczenia
+  nawet po faktycznym zmniejszeniu intencji BPP do 2). Narzędzie
+  teraz porównuje **intencję BPP na żywo** — to co by wygenerował
+  ``WydawnictwoPBNAdapter.pbn_get_api_statements()`` gdyby wysyłać
+  teraz — z aktualnym stanem PBN. Dodatkowo KROK 1/8 pokazuje zarówno
+  cache jak i intencję żywą, żeby od razu widać było rozjazd.
+- narzędzie zawsze pyta osobno o DELETE oświadczeń i osobno o POST
+  oświadczeń, także gdy porównanie zwróciło identyczność —
+  użytkownik może wymusić operację np. dla empirycznego sprawdzenia
+  reakcji PBN (wcześniej flow kończył się wczesnym ``return`` po
+  identyczności bez opcji kontynuacji). Domyślna wartość pytania
+  zależy od wyniku porównania: „identyczne" → default ``n``,
+  „różnice" → default ``t``.

src/bpp/newsfragments/+pbn-test-wysylka-interaktywna.feature.rst

@@ -0,0 +1,13 @@
+Dodano interaktywne narzędzie CLI
+``pbn_test_wysylka_interaktywna`` (Django management command) do
+eksperymentalnego testowania flow wysyłki publikacji i oświadczeń do PBN
+krok po kroku. Narzędzie prowadzi użytkownika przez kolejne fazy —
+generowanie JSON publikacji, wybór endpointa (``/api/v1/publications``
+all-in-one albo ``/api/v1/repositorium/publications`` bez oświadczeń),
+POST publikacji, GET i porównanie oświadczeń lokalnych z tym co jest w
+PBN, DELETE oświadczeń i POST przez ``/api/v2/institution-profile/statements``
+— pokazując dla każdego kroku metodę HTTP, URL, body i odpowiedź
+serwera. Narzędzie nie modyfikuje lokalnej bazy BPP i posiada tryb
+``--dry-run``. Służy jako baza do audytu zachowania PBN API i
+projektowania bezpieczniejszej kolejności operacji wysyłki (scenariusz:
+nieudana wysyłka publikacji kasowała wcześniej istniejące oświadczenia).

src/bpp/newsfragments/+pbn-v2-retry.bugfix.rst

@@ -0,0 +1,13 @@
+Dodano exponential backoff (5 prób, max ~30 sekund) przy pobieraniu
+``PublikacjaInstytucji_V2`` (UUID publikacji z PBN API v2). Poprzednio
+jedna próba kończyła się warningiem "nie jest błędem", co myliło użytkowników
+— brak V2 oznacza brak możliwości generowania linków do PBN Interfejs
+i wysyłki oświadczeń (wymagany UUID). Teraz system automatycznie ponawia
+z rosnącym czasem oczekiwania (2s, 4s, 8s, 16s, 32s).
+
+Jeśli po wszystkich próbach nadal nie ma V2 — wyświetlany jest BŁĄD (czerwony)
+z sugestią użycia wysyłki w tle (PBN Export Queue) zamiast interaktywnej.
+
+**Ważne dla deploymentu**: przy interaktywnej wysyłce z admina może być potrzebne
+zwiększenie timeoutu nginx/gunicorn dla ścieżek ``/admin/`` do minimum 90-120 sekund
+(domyślne 30-60s może być za mało przy 5 próbach z opóźnieniami).

src/bpp_setup_wizard/forms.py

@@ -183,8 +183,8 @@ def save(self, commit=True):
         uczelnia = super().save(commit=False)
 
         # Set the fields that should always be True
-        uczelnia.pbn_api_kasuj_przed_wysylka = (
-            True  # Kasuj oświadczenia przed wysłaniem do PBN
+        uczelnia.pbn_kasuj_dyscypliny_selektywnie = (
+            True  # Selektywny DELETE oświadczeń per-osoba (nowy flow)
         )
         uczelnia.pbn_api_nie_wysylaj_prac_bez_pk = (
             True  # Nie wysyłaj do PBN prac z PK=0

src/bpp_setup_wizard/tests.py

@@ -263,7 +263,7 @@ def test_uczelnia_setup_create_uczelnia(admin_user):
     assert uczelnia.uzywaj_wydzialow is True
 
     # Verify the automatically set fields
-    assert uczelnia.pbn_api_kasuj_przed_wysylka is True
+    assert uczelnia.pbn_kasuj_dyscypliny_selektywnie is True
     assert uczelnia.pbn_api_nie_wysylaj_prac_bez_pk is True
     assert uczelnia.pbn_api_afiliacja_zawsze_na_uczelnie is True
     assert uczelnia.pbn_wysylaj_bez_oswiadczen is True

src/django_bpp/settings/base.py

@@ -1380,6 +1380,15 @@ def iter_namespace(ns_pkg):
             "level": "INFO",
             "propagate": False,
         },
+        # Logger dla pbn_api - WARNING+ na konsolę. W szczególności
+        # `_check_error_response` w transport.py loguje pełne body
+        # i headers przy odpowiedziach >= 400, co jest kluczowe przy
+        # diagnostyce błędów typu „400 Bad Request" bez czytelnego body.
+        "pbn_api": {
+            "handlers": ["console"],
+            "level": "WARNING",
+            "propagate": False,
+        },
     },
 }
 

src/importer_publikacji/migrations/0006_merge_20260420_2212.py

@@ -0,0 +1,13 @@
+# Generated by Django 5.2.13 on 2026-04-20 20:12
+
+from django.db import migrations
+
+
+class Migration(migrations.Migration):
+
+    dependencies = [
+        ("importer_publikacji", "0005_alter_importsession_created_by"),
+        ("importer_publikacji", "0005_importsession_wydawnictwo_nadrzedne"),
+    ]
+
+    operations = []

src/importer_publikacji/migrations/0007_merge_20260421_1248.py

@@ -0,0 +1,13 @@
+# Generated by Django 5.2.13 on 2026-04-21 10:48
+
+from django.db import migrations
+
+
+class Migration(migrations.Migration):
+
+    dependencies = [
+        ("importer_publikacji", "0006_merge_20260420_2212"),
+        ("importer_publikacji", "0006_merge_20260421_1100"),
+    ]
+
+    operations = []

src/pbn_api/adapters/wydawnictwo.py

@@ -237,16 +237,35 @@ def _build_open_access_base_fields(self) -> dict:
         return oa
 
     def _build_open_access_release_date(self, oa: dict) -> None:
-        """Add release date fields to OpenAccess dict."""
-        if self.original.public_dostep_dnia is not None:
+        """Ustawia pola daty udostępnienia OpenAccess.
+
+        Priorytet źródeł (od najbardziej dedykowanego):
+
+        1. ``openaccess_data_opublikowania`` — pole dedykowane OpenAccess
+           (``ModelZOpenAccess``), ustawiane przez importer z PBN i przez
+           redakcję ręcznie. To powinno być podstawowe źródło.
+        2. ``public_dostep_dnia`` — data wolnego dostępu do strony WWW
+           (``ModelZWWW``). Fallback dla starszych rekordów bez dedykowanej
+           daty OpenAccess.
+        3. ``dostep_dnia`` — data płatnego dostępu. Ostatni fallback.
+
+        Gdy żadna z dat nie jest wypełniona, pola ``releaseDate``,
+        ``releaseDateMonth``, ``releaseDateYear`` NIE są ustawiane.
+        Wcześniejsza implementacja wstawiała hardcoded
+        ``{"releaseDateMonth": "JANUARY", "releaseDateYear": str(rok)}``,
+        co wysyłało do PBN nieprawdziwe dane (styczeń niezależnie od
+        faktycznego miesiąca publikacji). Lepiej pominąć pola i zmusić
+        PBN do zwrócenia validation error (lub zaakceptowania, jeśli
+        spec pozwala), niż wysyłać kłamliwy miesiąc.
+        """
+        data_oa = getattr(self.original, "openaccess_data_opublikowania", None)
+        if data_oa is not None:
+            oa["releaseDate"] = str(data_oa)
+        elif self.original.public_dostep_dnia is not None:
             oa["releaseDate"] = str(self.original.public_dostep_dnia)
         elif self.original.dostep_dnia is not None:
             oa["releaseDate"] = str(self.original.dostep_dnia)
 
-        if oa.get("releaseDate") is None:
-            oa["releaseDateMonth"] = "JANUARY"
-            oa["releaseDateYear"] = str(self.original.rok)
-
     def _build_open_access(self, pub_type: str) -> dict | None:
         """Build OpenAccess data structure if all required fields are present."""
         oa = self._build_open_access_base_fields()