Feat: Dref Summary Generation workflow

api/test_views.py

@@ -31,8 +31,9 @@
     DrefFactory,
     DrefFinalReportFactory,
     DrefOperationalUpdateFactory,
+    DrefSummaryFactory,
 )
-from dref.models import Dref, DrefFile
+from dref.models import Dref, DrefFile, DrefSummary
 from main.test_case import APITestCase
 from per.factories import OpsLearningFactory
 
@@ -1535,3 +1536,37 @@ def test_dref_operational_update_with_timeline_ops_updates(self):
         self.assertIsNotNone(dref_data)
         self.assertIsNotNone(dref_data["final_report_details"])
         self.assertEqual(len(dref_data["timeline_operational_updates"]), 3)
+
+    def test_dref_summary_fields_present_when_summary_exists(self):
+        event = EventFactory.create(dtype=self.disaster_type)
+        dref = self._approved_dref(event)
+        DrefSummaryFactory.create(
+            dref=dref,
+            status=DrefSummary.SummaryStatus.SUCCESS,
+            situational_overview="overview text",
+            operational_strategy="strategy text",
+            people_centered_approach="approach text",
+            challenges_identified="challenges text",
+            lessons_learned="lessons text",
+        )
+
+        data = self._get(event).data
+
+        self.assertEqual(data["stage"], EventStage.DREF_APPLICATION)
+        summary = data["dref"]["summary"]
+        self.assertIsNotNone(summary)
+        self.assertEqual(summary["status"], DrefSummary.SummaryStatus.SUCCESS)
+        self.assertEqual(summary["situational_overview"], "overview text")
+        self.assertEqual(summary["operational_strategy"], "strategy text")
+        self.assertEqual(summary["people_centered_approach"], "approach text")
+        self.assertEqual(summary["challenges_identified"], "challenges text")
+        self.assertEqual(summary["lessons_learned"], "lessons text")
+
+    def test_dref_summary_is_none_when_no_summary_exists(self):
+        event = EventFactory.create(dtype=self.disaster_type)
+        self._approved_dref(event)
+
+        data = self._get(event).data
+
+        self.assertEqual(data["stage"], EventStage.DREF_APPLICATION)
+        self.assertIsNone(data["dref"]["summary"])

docker-compose.yml

@@ -33,6 +33,8 @@ x-server: &base_server_setup
     CACHE_TEST_REDIS_URL: ${CACHE_TEST_REDIS_URL:-redis://redis:6379/11}
     CACHE_MIDDLEWARE_SECONDS: ${CACHE_MIDDLEWARE_SECONDS:-600}
     ELASTIC_SEARCH_HOST: ${ELASTIC_SEARCH_HOST:-elasticsearch://elasticsearch:9200}
+    # LLM
+    USE_DUMMY_LLM_CLIENT: ${USE_DUMMY_LLM_CLIENT:-true}
     # Appeal API
     APPEALS_USER: ${APPEALS_USER:-}
     APPEALS_PASS: ${APPEALS_PASS:-}

dref/admin.py

@@ -1,20 +1,22 @@
-from django.contrib import admin
+from django.contrib import admin, messages
 from reversion_compare.admin import CompareVersionAdmin
 
-from lang.admin import TranslationAdmin
+from lang.admin import TranslationAdmin, TranslationInlineModelAdmin
 
 from .models import (
     Dref,
     DrefFile,
     DrefFinalReport,
     DrefOperationalUpdate,
+    DrefSummary,
     IdentifiedNeed,
     NationalSocietyAction,
     PlannedIntervention,
     ProposedAction,
     RiskSecurity,
     SourceInformation,
 )
+from .tasks import generate_dref_summary
 
 
 class ReadOnlyMixin:
@@ -125,8 +127,31 @@ class SourceInformationAdmin(admin.ModelAdmin):
     search_fields = ("source_name",)
 
 
+class DrefSummaryInline(admin.StackedInline, TranslationInlineModelAdmin):
+    model = DrefSummary
+    extra = 0
+    readonly_fields = (
+        "status",
+        "source_hash",
+        "created_at",
+        "updated_at",
+    )
+    fields = (
+        "status",
+        "source_hash",
+        "situational_overview",
+        "operational_strategy",
+        "people_centered_approach",
+        "challenges_identified",
+        "lessons_learned",
+        "created_at",
+        "updated_at",
+    )
+
+
 @admin.register(Dref)
 class DrefAdmin(CompareVersionAdmin, TranslationAdmin, admin.ModelAdmin):
+    inlines = [DrefSummaryInline]
     search_fields = ("title", "appeal_code")
     list_display = (
         "title",
@@ -301,3 +326,37 @@ def save_model(self, request, obj, form, change):
 @admin.register(ProposedAction)
 class ProposedActionAdmin(ReadOnlyMixin, admin.ModelAdmin):
     search_fields = ["action"]
+
+
+@admin.register(DrefSummary)
+class DrefSummaryAdmin(TranslationAdmin, admin.ModelAdmin):
+    list_display = ("dref", "status", "source", "source_id", "created_at", "updated_at")
+    list_filter = ("status",)
+    search_fields = ("dref__title", "dref__appeal_code")
+    readonly_fields = ("source_hash", "created_at", "updated_at")
+    autocomplete_fields = ("dref",)
+    actions = ["regenerate_summary"]
+    fields = (
+        "dref",
+        "status",
+        "source_hash",
+        "situational_overview",
+        "operational_strategy",
+        "people_centered_approach",
+        "challenges_identified",
+        "lessons_learned",
+        "created_at",
+        "updated_at",
+    )
+
+    @admin.action(description="Regenerate summary for selected DREFs")
+    def regenerate_summary(self, request, queryset):
+        """Re-trigger summary generation from the DREF's current latest approved source."""
+        queryset.filter(status=DrefSummary.SummaryStatus.PROCESSING).update(status=DrefSummary.SummaryStatus.FAILED)
+        for summary in queryset:
+            generate_dref_summary.delay(dref_id=summary.dref_id, overwrite=True)
+        self.message_user(
+            request,
+            f"Queued summary regeneration for {queryset.count()} DREF(s).",
+            messages.SUCCESS,
+        )

dref/factories/dref.py

@@ -9,6 +9,7 @@
     DrefFile,
     DrefFinalReport,
     DrefOperationalUpdate,
+    DrefSummary,
     IdentifiedNeed,
     NationalSocietyAction,
     PlannedIntervention,
@@ -198,3 +199,19 @@ class Meta:
         model = ProposedAction
 
     proposed_type = fuzzy.FuzzyChoice(ProposedAction.Action)
+
+
+class DrefSummaryFactory(factory.django.DjangoModelFactory):
+    class Meta:
+        model = DrefSummary
+
+    dref = factory.SubFactory(DrefFactory)
+    source_hash = factory.Sequence(lambda n: f"{n:064d}")
+    source = DrefSummary.SourceModel.DREF
+    source_id = factory.SelfAttribute("dref.id")
+    status = DrefSummary.SummaryStatus.SUCCESS
+    situational_overview = fuzzy.FuzzyText(length=100)
+    operational_strategy = fuzzy.FuzzyText(length=100)
+    people_centered_approach = fuzzy.FuzzyText(length=100)
+    challenges_identified = fuzzy.FuzzyText(length=100)
+    lessons_learned = fuzzy.FuzzyText(length=100)

dref/migrations/0090_drefsummary.py

@@ -0,0 +1,54 @@
+# Generated by Django 5.2.14 on 2026-07-03 00:58
+
+import django.db.models.deletion
+from django.db import migrations, models
+
+
+class Migration(migrations.Migration):
+
+    dependencies = [
+        ('dref', '0089_remove_dref_field_report_dref_event'),
+    ]
+
+    operations = [
+        migrations.CreateModel(
+            name='DrefSummary',
+            fields=[
+                ('id', models.AutoField(auto_created=True, primary_key=True, serialize=False, verbose_name='ID')),
+                ('created_at', models.DateTimeField(auto_now_add=True)),
+                ('updated_at', models.DateTimeField(auto_now=True)),
+                ('source', models.IntegerField(choices=[(100, 'Dref'), (200, 'Dref Operational Update'), (300, 'Dref Final Report')], help_text='The model this summary was generated from.', verbose_name='source')),
+                ('source_id', models.PositiveBigIntegerField(verbose_name='source id')),
+                ('source_hash', models.CharField(max_length=64, unique=True)),
+                ('situational_overview', models.TextField(blank=True, null=True)),
+                ('situational_overview_en', models.TextField(blank=True, null=True)),
+                ('situational_overview_es', models.TextField(blank=True, null=True)),
+                ('situational_overview_fr', models.TextField(blank=True, null=True)),
+                ('situational_overview_ar', models.TextField(blank=True, null=True)),
+                ('operational_strategy', models.TextField(blank=True, null=True)),
+                ('operational_strategy_en', models.TextField(blank=True, null=True)),
+                ('operational_strategy_es', models.TextField(blank=True, null=True)),
+                ('operational_strategy_fr', models.TextField(blank=True, null=True)),
+                ('operational_strategy_ar', models.TextField(blank=True, null=True)),
+                ('people_centered_approach', models.TextField(blank=True, null=True)),
+                ('people_centered_approach_en', models.TextField(blank=True, null=True)),
+                ('people_centered_approach_es', models.TextField(blank=True, null=True)),
+                ('people_centered_approach_fr', models.TextField(blank=True, null=True)),
+                ('people_centered_approach_ar', models.TextField(blank=True, null=True)),
+                ('challenges_identified', models.TextField(blank=True, null=True)),
+                ('challenges_identified_en', models.TextField(blank=True, null=True)),
+                ('challenges_identified_es', models.TextField(blank=True, null=True)),
+                ('challenges_identified_fr', models.TextField(blank=True, null=True)),
+                ('challenges_identified_ar', models.TextField(blank=True, null=True)),
+                ('lessons_learned', models.TextField(blank=True, null=True)),
+                ('lessons_learned_en', models.TextField(blank=True, null=True)),
+                ('lessons_learned_es', models.TextField(blank=True, null=True)),
+                ('lessons_learned_fr', models.TextField(blank=True, null=True)),
+                ('lessons_learned_ar', models.TextField(blank=True, null=True)),
+                ('status', models.IntegerField(choices=[(100, 'Pending'), (200, 'Processing'), (300, 'Success'), (400, 'Failed')], default=100)),
+                ('translation_module_original_language', models.CharField(choices=[('en', 'English'), ('es', 'Spanish'), ('fr', 'French'), ('ar', 'Arabic')], default='en', help_text='Language used to create this entity', max_length=2, verbose_name='Entity Original language')),
+                ('translation_module_skip_auto_translation', models.BooleanField(default=False, help_text='Skip auto translation operation for this entity?', verbose_name='Skip auto translation')),
+                ('dref', models.OneToOneField(on_delete=django.db.models.deletion.CASCADE, related_name='summary', to='dref.dref')),
+            ],
+        ),
+    ]

dref/models.py

@@ -1233,6 +1233,10 @@ class DrefOperationalUpdate(models.Model):
     source_information = models.ManyToManyField(SourceInformation, blank=True, verbose_name=_("Source Information"))
     __budget_file_id = None
 
+    # TYPING
+    id: int
+    budget_file_id: int | None
+
     class Meta:
         verbose_name = _("Dref Operational Update")
         verbose_name_plural = _("Dref Operational Updates")
@@ -1657,6 +1661,9 @@ class DrefFinalReport(models.Model):
     )
     __financial_report_id = None
 
+    # TYPING
+    id: int
+
     class Meta:
         verbose_name = _("Dref Final Report")
         verbose_name_plural = _("Dref Final Reports")
@@ -1700,3 +1707,70 @@ def get_for(user, status=None):
         if status == Dref.Status.APPROVED:
             return queryset.filter(status=Dref.Status.APPROVED)
         return queryset
+
+
+class DrefSummary(models.Model):
+
+    class SummaryStatus(models.IntegerChoices):
+        PENDING = 100, _("Pending")
+        PROCESSING = 200, _("Processing")
+        SUCCESS = 300, _("Success")
+        FAILED = 400, _("Failed")
+
+    class SourceModel(models.IntegerChoices):
+        DREF = 100, _("Dref")
+        DREF_OPERATIONAL_UPDATE = 200, _("Dref Operational Update")
+        DREF_FINAL_REPORT = 300, _("Dref Final Report")
+
+    dref = models.OneToOneField(
+        Dref,
+        on_delete=models.CASCADE,
+        related_name="summary",
+    )
+
+    created_at = models.DateTimeField(auto_now_add=True)
+    updated_at = models.DateTimeField(auto_now=True)
+
+    source = models.IntegerField(
+        verbose_name=_("source"),
+        help_text=_("The model this summary was generated from."),
+        choices=SourceModel.choices,
+    )
+    source_id = models.PositiveBigIntegerField(
+        verbose_name=_("source id"),
+    )
+
+    source_hash = models.CharField(
+        max_length=64,
+        unique=True,
+    )
+
+    situational_overview = models.TextField(
+        blank=True,
+        null=True,
+    )
+
+    operational_strategy = models.TextField(
+        blank=True,
+        null=True,
+    )
+
+    people_centered_approach = models.TextField(
+        blank=True,
+        null=True,
+    )
+
+    challenges_identified = models.TextField(
+        blank=True,
+        null=True,
+    )
+
+    lessons_learned = models.TextField(
+        blank=True,
+        null=True,
+    )
+
+    status = models.IntegerField(
+        choices=SummaryStatus.choices,
+        default=SummaryStatus.PENDING,
+    )

dref/serializers.py

@@ -25,6 +25,7 @@
     DrefFile,
     DrefFinalReport,
     DrefOperationalUpdate,
+    DrefSummary,
     IdentifiedNeed,
     NationalSocietyAction,
     PlannedIntervention,
@@ -2427,6 +2428,25 @@ def get_dref_contacts(self, obj):
         return get_dref_emergency_contacts(obj)
 
 
+class DrefSummarySerializer(ModelSerializer):
+    status_display = serializers.CharField(source="get_status_display", read_only=True)
+
+    class Meta:
+        model = DrefSummary
+        fields = (
+            "id",
+            "status",
+            "status_display",
+            "situational_overview",
+            "operational_strategy",
+            "people_centered_approach",
+            "challenges_identified",
+            "lessons_learned",
+            "created_at",
+            "updated_at",
+        )
+
+
 class EmergencyDrefSerializer(serializers.ModelSerializer):
     status_display = serializers.CharField(source="get_status_display", read_only=True)
     country_details = MiniCountrySerializer(source="country", read_only=True)
@@ -2436,6 +2456,7 @@ class EmergencyDrefSerializer(serializers.ModelSerializer):
     cover_image_file = DrefFileSerializer(source="cover_image", required=False, allow_null=True)
     disaster_type_details = DisasterTypeSerializer(source="disaster_type", read_only=True)
     type_of_dref_display = serializers.CharField(source="get_type_of_dref_display", read_only=True)
+    summary = DrefSummarySerializer(read_only=True)
 
     # Dref operational update
     operational_update_details = serializers.SerializerMethodField()
@@ -2498,6 +2519,8 @@ class Meta:
             "timeline_operational_updates",
             # Contacts
             "dref_contacts",
+            # Summary
+            "summary",
         )
 
     @extend_schema_field(TimelineEmergencyDrefOperationalUpdateSerializer(many=True))