mirror of
https://github.com/GSA/notifications-api.git
synced 2026-02-01 07:35:34 -05:00
Rename to performance_dashboard
Fix totals to return totals for all time rather than for date range. Added more test data
This commit is contained in:
0
app/performance_dashboard/__init__.py
Normal file
0
app/performance_dashboard/__init__.py
Normal file
10
app/performance_dashboard/performance_dashboard_schema.py
Normal file
10
app/performance_dashboard/performance_dashboard_schema.py
Normal file
@@ -0,0 +1,10 @@
|
||||
performance_dashboard_request = {
|
||||
"$schema": "http://json-schema.org/draft-04/schema#",
|
||||
"description": "Performance dashboard request schema",
|
||||
"type": "object",
|
||||
"title": "Performance dashboard request",
|
||||
"properties": {
|
||||
"start_date": {"type": ["string", "null"], "format": "date"},
|
||||
"end_date": {"type": ["string", "null"], "format": "date"},
|
||||
}
|
||||
}
|
||||
86
app/performance_dashboard/rest.py
Normal file
86
app/performance_dashboard/rest.py
Normal file
@@ -0,0 +1,86 @@
|
||||
from datetime import datetime
|
||||
|
||||
from flask import Blueprint, request, jsonify
|
||||
|
||||
from app.dao.fact_notification_status_dao import get_total_notifications_for_date_range
|
||||
from app.dao.fact_processing_time_dao import get_processing_time_percentage_for_date_range
|
||||
from app.dao.services_dao import get_live_services_with_organisation
|
||||
from app.errors import register_errors
|
||||
from app.performance_dashboard.performance_dashboard_schema import performance_dashboard_request
|
||||
from app.schema_validation import validate
|
||||
|
||||
performance_dashboard_blueprint = Blueprint('performance_dashboard', __name__, url_prefix='/performance-dashboard')
|
||||
|
||||
register_errors(performance_dashboard_blueprint)
|
||||
|
||||
|
||||
@performance_dashboard_blueprint.route('')
|
||||
def get_performance_dashboard():
|
||||
# All statistics are as of last night this matches the existing performance platform
|
||||
# and avoids the need to query notifications.
|
||||
if request.args:
|
||||
# Is it ok to reuse this? - should probably create a new one
|
||||
validate(request.args, performance_dashboard_request)
|
||||
|
||||
# If start and end date are not set, we are expecting today's stats.
|
||||
today = str(datetime.utcnow().date())
|
||||
|
||||
start_date = datetime.strptime(request.args.get('start_date', today), '%Y-%m-%d').date()
|
||||
end_date = datetime.strptime(request.args.get('end_date', today), '%Y-%m-%d').date()
|
||||
total_for_all_time = get_total_notifications_for_date_range(start_date=None, end_date=None)
|
||||
total_notifications, emails, sms, letters = transform_results_into_totals(total_for_all_time)
|
||||
totals_for_date_range = get_total_notifications_for_date_range(start_date=start_date, end_date=end_date)
|
||||
processing_time_results = get_processing_time_percentage_for_date_range(start_date=start_date, end_date=end_date)
|
||||
services = get_live_services_with_organisation()
|
||||
stats = {
|
||||
"total_notifications": total_notifications,
|
||||
"email_notifications": emails,
|
||||
"sms_notifications": sms,
|
||||
"letter_notifications": letters,
|
||||
"notifications_by_type": transform_into_notification_by_type_json(totals_for_date_range),
|
||||
"processing_time": transform_processing_time_results_to_json(processing_time_results),
|
||||
"live_service_count": len(services),
|
||||
"services_using_notify": transform_services_to_json(services)
|
||||
|
||||
}
|
||||
|
||||
return jsonify(stats)
|
||||
|
||||
|
||||
def transform_results_into_totals(total_notifications_results):
|
||||
total_notifications = 0
|
||||
emails = 0
|
||||
sms = 0
|
||||
letters = 0
|
||||
for x in total_notifications_results:
|
||||
total_notifications += x.emails
|
||||
total_notifications += x.sms
|
||||
total_notifications += x.letters
|
||||
emails += x.emails
|
||||
sms += x.sms
|
||||
letters += x.letters
|
||||
return total_notifications, emails, sms, letters
|
||||
|
||||
|
||||
def transform_into_notification_by_type_json(total_notifications):
|
||||
j = []
|
||||
for x in total_notifications:
|
||||
j.append({"date": x.bst_date, "emails": x.emails, "sms": x.sms, "letters": x.letters})
|
||||
return j
|
||||
|
||||
|
||||
def transform_processing_time_results_to_json(processing_time_results):
|
||||
j = []
|
||||
for x in processing_time_results:
|
||||
j.append({"date": x.date, "percentage_under_10_seconds": round(x.percentage, 1)})
|
||||
|
||||
return j
|
||||
|
||||
|
||||
def transform_services_to_json(services_results):
|
||||
j = []
|
||||
for x in services_results:
|
||||
j.append({"service_id": x.service_id, "service_name": x.service_name,
|
||||
"organisation_id": x.organisation_id, "organisation_name": x.organisation_name}
|
||||
)
|
||||
return j
|
||||
Reference in New Issue
Block a user