notifications: group notifications for each patron

* Groups notifications through a dispach process.
* Adds a CLI to display time stamp monitoring.
* Fixes different pickup locations for availability notifications.
* Closes #1236.

Co-Authored-by: Peter Weber <peter.weber@rero.ch>

pyproject.toml

@@ -80,6 +80,8 @@ freezegun = "^1.1.0"
 lazyreader = ">1.0.0"
 jinja2 = ">2.11.2"
 jsonmerge = "^1.8.0"
+num2word = "^1.0.1"
+num2words = "^0.5.10"
 
 [tool.poetry.dev-dependencies]
 ## Python packages development dependencies (order matters)

rero_ils/config.py

@@ -207,6 +207,8 @@ def _(x):
 SUPPORT_EMAIL = "software@rero.ch"
 #: Disable email sending by default.
 MAIL_SUPPRESS_SEND = True
+#: Default sender email
+DEFAULT_SENDER_EMAIL = "noreply@rero.ch"
 
 # Assets
 # ======
@@ -307,6 +309,38 @@ def _(x):
         'enabled': False,
         # TODO: in production set this up once a day
     },
+    'notification-dispatch-due_soon': {
+        'task': 'rero_ils.modules.notifications.tasks.process_notifications',
+        'schedule': crontab(minute="*/15"),
+        'kwargs': {
+            'notification_type': Notification.DUE_SOON_NOTIFICATION_TYPE
+        },
+        'enabled': False,
+    },
+    'notification-dispatch-overdue': {
+        'task': 'rero_ils.modules.notifications.tasks.process_notifications',
+        'schedule': timedelta(minutes=15),
+        'kwargs': {
+            'notification_type': Notification.OVERDUE_NOTIFICATION_TYPE
+        },
+        'enabled': False,
+    },
+    'notification-dispatch-availability': {
+        'task': 'rero_ils.modules.notifications.tasks.process_notifications',
+        'schedule': timedelta(minutes=15),
+        'kwargs': {
+            'notification_type': Notification.AVAILABILITY_NOTIFICATION_TYPE
+        },
+        'enabled': False,
+    },
+    'notification-dispatch-recall': {
+        'task': 'rero_ils.modules.notifications.tasks.process_notifications',
+        'schedule': timedelta(minutes=15),
+        'kwargs': {
+            'notification_type': Notification.RECALL_NOTIFICATION_TYPE
+        },
+        'enabled': False,
+    },
     'claims-creation': {
         'task': ('rero_ils.modules.items.tasks'
                  '.process_late_claimed_issues'),

rero_ils/modules/libraries/api.py

@@ -333,17 +333,6 @@ def get_timezone(self):
         default = pytz.timezone('Europe/Zurich')
         return default
 
-    def email_notification_type(self, notification_type):
-        """Get the email corresponding to the given notification type.
-
-        :param notification_type: the notification type.
-        :return: the email corresponding to the notification type.
-        :rtype: string
-        """
-        for setting in self['notification_settings']:
-            if setting['type'] == notification_type:
-                return setting['email']
-
 
 class LibrariesIndexer(IlsRecordsIndexer):
     """Holdings indexing class."""
@@ -356,3 +345,15 @@ def bulk_index(self, record_id_iterator):
         :param record_id_iterator: Iterator yielding record UUIDs.
         """
         super().bulk_index(record_id_iterator, doc_type='lib')
+
+
+def email_notification_type(libray, notification_type):
+    """Get the email corresponding to the given notification type.
+
+    :param notification_type: the notification type.
+    :return: the email corresponding to the notification type.
+    :rtype: string
+    """
+    for setting in libray['notification_settings']:
+        if setting['type'] == notification_type:
+            return setting['email']

rero_ils/modules/loans/api.py

@@ -191,7 +191,7 @@ def check_required_params(self, action, **kwargs):
         required_params = self.action_required_params(action=action)
         missing_params = set(required_params) - set(kwargs)
         if missing_params:
-            message = 'Parameters {} are required'.format(missing_params)
+            message = f'Parameters {missing_params} are required'
             raise MissingRequiredParameterError(description=message)
 
     def update_pickup_location(self, pickup_location_pid):
@@ -574,12 +574,7 @@ def create_notification(self, notification_type=None, counter=0):
             }
             notification = Notification.create(
                 data=record, dbcommit=True, reindex=True)
-            enqueue = notification_type not in [
-                Notification.RECALL_NOTIFICATION_TYPE,
-                Notification.AVAILABILITY_NOTIFICATION_TYPE
-            ]
-            # put into the queue only for batch notifications i.e. overdue
-            return notification.dispatch(enqueue=enqueue)
+            return notification
 
     @classmethod
     def concluded(cls, loan):