add batch task to backfill processing time data

give it a start date and an end date, and it'll send data to the
performance platform for all dates in that (inclusive)

app/commands.py

@@ -16,6 +16,8 @@ from app.dao.services_dao import (
 )
 from app.dao.provider_rates_dao import create_provider_rates
 from app.dao.users_dao import (delete_model_user, delete_user_verify_codes)
+from app.utils import get_midnight_for_day_before, get_london_midnight_in_utc
+from app.performance_platform.processing_time import send_processing_time_for_start_and_end
 
 
 class CreateProviderRateCommand(Command):
@@ -197,3 +199,32 @@ class PopulateMonthlyBilling(Command):
         print("Finished populating data for {} for service id {}".format(month, str(service_id)))
         print('SMS: {}'.format(sms_res.monthly_totals))
         print('Email: {}'.format(email_res.monthly_totals))
+
+
+class BackfillProcessingTime(Command):
+    option_list = (
+        Option('-s', '--start_date', dest='start_date', help="Date (%Y-%m-%d) start date inclusive"),
+        Option('-e', '--end_date', dest='end_date', help="Date (%Y-%m-%d) end date inclusive"),
+    )
+
+    def run(self, start_date, end_date):
+        start_date = datetime.strptime(start_date, '%Y-%m-%d')
+        end_date = datetime.strptime(end_date, '%Y-%m-%d')
+
+        delta = end_date - start_date
+
+        print('Sending notification processing-time data for all days between {} and {}'.format(start_date, end_date))
+
+        for i in range(delta.days + 1):
+            # because the tz conversion funcs talk about midnight, and the midnight before last,
+            # we want to pretend we're running this from the next morning, so add one.
+            process_date = start_date + timedelta(days=i + 1)
+
+            process_start_date = get_midnight_for_day_before(process_date)
+            process_end_date = get_london_midnight_in_utc(process_date)
+
+            print('Sending notification processing-time for {} - {}'.format(
+                process_start_date.isoformat(),
+                process_end_date.isoformat()
+            ))
+            send_processing_time_for_start_and_end(process_start_date, process_end_date)

app/performance_platform/processing_time.py

@@ -12,6 +12,10 @@ def send_processing_time_to_performance_platform():
     start_date = get_midnight_for_day_before(today)
     end_date = get_london_midnight_in_utc(today)
 
+    send_processing_time_for_start_and_end(start_date, end_date)
+
+
+def send_processing_time_for_start_and_end(start_date, end_date):
     result = dao_get_total_notifications_sent_per_day_for_performance_platform(start_date, end_date)
 
     current_app.logger.info(

tests/app/test_commands.py

@@ -0,0 +1,13 @@
+from datetime import datetime
+
+from app.commands import BackfillProcessingTime
+
+def test_backfill_processing_time_works_for_correct_dates(mocker):
+    send_mock = mocker.patch('app.commands.send_processing_time_for_start_and_end')
+
+    BackfillProcessingTime().run('2017-08-01', '2017-08-03')
+
+    assert send_mock.call_count == 3
+    send_mock.assert_any_call(datetime(2017, 7, 31, 23, 0), datetime(2017, 8, 1, 23, 0))
+    send_mock.assert_any_call(datetime(2017, 8, 1, 23, 0), datetime(2017, 8, 2, 23, 0))
+    send_mock.assert_any_call(datetime(2017, 8, 2, 23, 0), datetime(2017, 8, 3, 23, 0))