darkhelm/notifications-api
1
0
Fork 0
mirror of https://github.com/GSA/notifications-api.git synced 2026-08-23 07:46:06 -04:00
Code Issues Packages Projects Releases Wiki Activity

Update existing ft_notification_status data to get rid of repeats

Browse Source
This commit is contained in:
Pea Tyczynska
2018-11-08 11:07:33 +00:00
parent ca2db56b9d
commit 1c4d2c7625
1 changed files with 6 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
app/commands.py
View File

@@ -527,6 +527,12 @@ def migrate_data_to_ft_notification_status(start_date, end_date):
while process_date < end_date: while process_date < end_date:
start_time = datetime.now() start_time = datetime.now()
# migrate data into ft_notification_status and update if record already exists # migrate data into ft_notification_status and update if record already exists
db.session.execute(
'delete from ft_notification_status where bst_date = :process_date',
{"process_date": process_date}
)
sql = \ sql = \
""" """
insert into ft_notification_status (bst_date, template_id, service_id, job_id, notification_type, key_type, insert into ft_notification_status (bst_date, template_id, service_id, job_id, notification_type, key_type,
@@ -546,9 +552,6 @@ def migrate_data_to_ft_notification_status(start_date, end_date):
and n.created_at < (date :end + time '00:00:00') at time zone 'Europe/London' at time zone 'UTC' and n.created_at < (date :end + time '00:00:00') at time zone 'Europe/London' at time zone 'UTC'
group by bst_date, template_id, service_id, job_id, notification_type, key_type, notification_status group by bst_date, template_id, service_id, job_id, notification_type, key_type, notification_status
order by bst_date order by bst_date
on conflict on constraint ft_notification_status_pkey do update set
notification_count = excluded.notification_count,
updated_at = now()
""" """
result = db.session.execute(sql, {"start": process_date, "end": process_date + timedelta(days=1)}) result = db.session.execute(sql, {"start": process_date, "end": process_date + timedelta(days=1)})
db.session.commit() db.session.commit()