Fixes issue #1014

Author: Your Name

sde_collections/models/collection.py

@@ -634,6 +634,22 @@ def apply_all_patterns(self):
         for pattern in self.deltadivisionpatterns.all():
             pattern.apply()
 
+    def count_curated_urls(self):
+        """Return the count of Curated URLs for the collection."""
+        return CuratedUrl.objects.filter(collection=self).count()
+
+    def count_dump_urls(self):
+        """Return the count of all Dump URLs for the collection."""
+        return DumpUrl.objects.filter(collection=self).count()
+
+    def count_delta_urls(self):
+        """Return the count of Delta URLs identified."""
+        return DeltaUrl.objects.filter(collection=self).count()
+
+    def count_marked_for_deletion_urls(self):
+        """Return the count of Delta URLs marked for deletion."""
+        return DeltaUrl.objects.filter(collection=self, to_delete=True).count()
+    
     def save(self, *args, **kwargs):
         # Call the function to generate the value for the generated_field based on the original_field
         if not self.config_folder:

sde_collections/tasks.py

@@ -1,14 +1,13 @@
 import json
 import os
 import shutil
-
 import boto3
 from django.apps import apps
 from django.conf import settings
 from django.core import management
 from django.core.management.commands import loaddata
 from django.db import transaction
-
+from sde_collections.utils import slack_utils
 from config import celery_app
 from sde_collections.models.collection_choice_fields import (
     ReindexingStatusChoices,
@@ -215,6 +214,14 @@ def fetch_and_replace_full_text(collection_id, server_name):
             collection.reindexing_status = ReindexingStatusChoices.REINDEXING_READY_FOR_CURATION
             collection.save()
 
+        curated_count = collection.count_curated_urls()
+        dump_count = collection.count_dump_urls()
+        delta_count = collection.count_delta_urls()
+        deletion_count = collection.count_marked_for_deletion_urls()
+
+        slack_utils.send_detailed_import_notification(
+            collection.name, total_processed, curated_count, dump_count, delta_count, deletion_count
+        )
         return f"Successfully processed {total_processed} records and updated the database."
 
     except Exception as e:

sde_collections/utils/slack_utils.py

@@ -58,6 +58,16 @@ def format_slack_message(name, details, collection_id):
         return slack_mentions + " " + message_template.format(name=linked_name)
     return message_template.format(name=linked_name)
 
+def send_detailed_import_notification(collection_name, total_processed, curated_count, dump_count, delta_count, deletion_count):
+    message = (f"'{collection_name}' brought into COSMOS. "
+               f"Prior Curated: {curated_count}, URL counts - [Server: {total_processed}, "
+               f"Dump: {dump_count}, New Deltas: {delta_count}, Deleted: {deletion_count}]")
+
+    webhook_url = settings.SLACK_WEBHOOK_URL
+    payload = {"text": message}
+    response = requests.post(webhook_url, json=payload)
+    if response.status_code != 200:
+        print(f"Error sending Slack message: {response.text}")
 
 def send_slack_message(message):
     webhook_url = settings.SLACK_WEBHOOK_URL