From 8e03c614bfda649a26d0a9bfc5d2c6f4c3a3cf37 Mon Sep 17 00:00:00 2001 From: Daniel Mursa Date: Fri, 10 Jan 2025 13:47:20 +0100 Subject: [PATCH] [#310] Update migrations --- ...atie_adres_nummeraanduiding_id_and_more.py | 53 +++++++---------- ...ezoekadres_nummeraanduiding_id_and_more.py | 58 ++++++++----------- 2 files changed, 44 insertions(+), 67 deletions(-) diff --git a/src/openklant/components/contactgegevens/migrations/0004_alter_organisatie_adres_nummeraanduiding_id_and_more.py b/src/openklant/components/contactgegevens/migrations/0004_alter_organisatie_adres_nummeraanduiding_id_and_more.py index 344cc026..d87b95be 100644 --- a/src/openklant/components/contactgegevens/migrations/0004_alter_organisatie_adres_nummeraanduiding_id_and_more.py +++ b/src/openklant/components/contactgegevens/migrations/0004_alter_organisatie_adres_nummeraanduiding_id_and_more.py @@ -10,25 +10,19 @@ logger = logging.getLogger(__name__) -def _check_nummeraanduiding_length(apps, schema_editor): - - Organisatie = apps.get_model("contactgegevens", "Organisatie") - Persoon = apps.get_model("contactgegevens", "Persoon") - - organisatie_queryset = Organisatie.objects.annotate( - length=Length("adres_nummeraanduiding_id") - ).filter(length__gt=16) - - logger.info("--- START Organisatie INFO ---") +def _log_records(records, model_name): + logger.info("--- START %s INFO ---", model_name) logger.info( - "Found %s records for Organisatie that have adres_nummeraanduiding_id length > 16 chars", - organisatie_queryset.count(), + "Found %s records for %s that have adres_nummeraanduiding_id length > 16 chars", + model_name, + records.count(), ) - for record in organisatie_queryset: + for record in records: logger.warning( json.dumps( { + "model_name": model_name, "pk": record.pk, "uuid": str(record.uuid), "adres_nummeraanduiding_id": record.adres_nummeraanduiding_id, @@ -36,29 +30,24 @@ def _check_nummeraanduiding_length(apps, schema_editor): ) ) - logger.info("--- END Organisatie INFO ---") + logger.info("--- END %s INFO ---", model_name) - persoon_queryset = Persoon.objects.annotate( + +def _check_field_length(apps, schema_editor): + + Organisatie = apps.get_model("contactgegevens", "Organisatie") + Persoon = apps.get_model("contactgegevens", "Persoon") + + organisatie_queryset = Organisatie.objects.annotate( length=Length("adres_nummeraanduiding_id") ).filter(length__gt=16) - logger.info("--- START Persoon INFO ---") - logger.info( - "Found %s records for Persoon that have adres_nummeraanduiding_id length > 16 chars", - persoon_queryset.count(), - ) + persoon_queryset = Persoon.objects.annotate( + length=Length("adres_nummeraanduiding_id") + ).filter(length__gt=16) - for record in persoon_queryset: - logger.warning( - json.dumps( - { - "pk": record.pk, - "uuid": str(record.uuid), - "adres_nummeraanduiding_id": record.adres_nummeraanduiding_id, - } - ) - ) - logger.info("--- END Persoon INFO ---") + _log_records(organisatie_queryset, "Organisatie") + _log_records(persoon_queryset, "Persoon") if organisatie_queryset or persoon_queryset: raise CommandError( @@ -74,7 +63,7 @@ class Migration(migrations.Migration): operations = [ migrations.RunPython( - code=_check_nummeraanduiding_length, + code=_check_field_length, reverse_code=migrations.RunPython.noop, ), migrations.AlterField( diff --git a/src/openklant/components/klantinteracties/migrations/0024_alter_betrokkene_bezoekadres_nummeraanduiding_id_and_more.py b/src/openklant/components/klantinteracties/migrations/0024_alter_betrokkene_bezoekadres_nummeraanduiding_id_and_more.py index e0c82b98..6c307e6e 100644 --- a/src/openklant/components/klantinteracties/migrations/0024_alter_betrokkene_bezoekadres_nummeraanduiding_id_and_more.py +++ b/src/openklant/components/klantinteracties/migrations/0024_alter_betrokkene_bezoekadres_nummeraanduiding_id_and_more.py @@ -10,26 +10,20 @@ logger = logging.getLogger(__name__) -def _check_nummeraanduiding_length(apps, schema_editor): - - Betrokkene = apps.get_model("klantinteracties", "Betrokkene") - Partij = apps.get_model("klantinteracties", "Partij") - - betrokkene_queryset = Betrokkene.objects.annotate( - length1=Length("bezoekadres_nummeraanduiding_id"), - length2=Length("correspondentieadres_nummeraanduiding_id"), - ).filter(models.Q(length1__gt=16) | models.Q(length2__gt=16)) - - logger.info("--- START Betrokkene INFO ---") +def _log_records(records, model_name): + logger.info("--- START %s INFO ---", model_name) logger.info( - "Found %s records for Betrokkene that have bezoekadres_nummeraanduiding_id or correspondentieadres_nummeraanduiding_id length > 16 chars", - betrokkene_queryset.count(), + "Found %s records for %s that have bezoekadres_nummeraanduiding_id " + "or correspondentieadres_nummeraanduiding_id length > 16 chars", + model_name, + records.count(), ) - for record in betrokkene_queryset: + for record in records: logger.warning( json.dumps( { + "model_name": model_name, "pk": record.pk, "uuid": str(record.uuid), "bezoekadres_nummeraanduiding_id": record.bezoekadres_nummeraanduiding_id, @@ -38,32 +32,26 @@ def _check_nummeraanduiding_length(apps, schema_editor): ) ) - logger.info("--- END Betrokkene INFO ---") + logger.info("--- END %s INFO ---", model_name) - partij_queryset = Partij.objects.annotate( + +def _check_field_length(apps, schema_editor): + + Betrokkene = apps.get_model("klantinteracties", "Betrokkene") + Partij = apps.get_model("klantinteracties", "Partij") + + betrokkene_queryset = Betrokkene.objects.annotate( length1=Length("bezoekadres_nummeraanduiding_id"), length2=Length("correspondentieadres_nummeraanduiding_id"), ).filter(models.Q(length1__gt=16) | models.Q(length2__gt=16)) - logger.info("--- START Partij INFO ---") - logger.info( - "Found %s records for Partij that have bezoekadres_nummeraanduiding_id or correspondentieadres_nummeraanduiding_id length > 16 chars", - partij_queryset.count(), - ) - - for record in partij_queryset: - logger.info( - json.dumps( - { - "pk": record.pk, - "uuid": str(record.uuid), - "bezoekadres_nummeraanduiding_id": record.bezoekadres_nummeraanduiding_id, - "correspondentieadres_nummeraanduiding_id": record.correspondentieadres_nummeraanduiding_id, - } - ) - ) + partij_queryset = Partij.objects.annotate( + length1=Length("bezoekadres_nummeraanduiding_id"), + length2=Length("correspondentieadres_nummeraanduiding_id"), + ).filter(models.Q(length1__gt=16) | models.Q(length2__gt=16)) - logger.warning("--- END Partij INFO ---") + _log_records(betrokkene_queryset, "Betrokkene") + _log_records(partij_queryset, "Partij") if betrokkene_queryset or partij_queryset: raise CommandError( @@ -79,7 +67,7 @@ class Migration(migrations.Migration): operations = [ migrations.RunPython( - code=_check_nummeraanduiding_length, + code=_check_field_length, reverse_code=migrations.RunPython.noop, ), migrations.AlterField(