mirrors/postgsail
1
0
Fork 0
mirror of https://github.com/xbgmsharp/postgsail.git synced 2025-09-17 11:17:46 +00:00
Code Issues Packages Projects Releases Wiki Activity

Update notificaiton jobs, fix sql query for no_vessel,no_metadata,no_activitye

Browse Source
This commit is contained in:
xbgmsharp
2023-10-10 13:51:51 +02:00
parent 2f3912582a
commit b7e717afbc
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
initdb/02_2_signalk_cron.sql
View File

@@ -404,7 +404,7 @@ BEGIN
WHERE v.owner_email = a.email) WHERE v.owner_email = a.email)
LOOP LOOP
RAISE NOTICE '-> cron_process_no_vessel_rec_fn for [%]', no_vessel; RAISE NOTICE '-> cron_process_no_vessel_rec_fn for [%]', no_vessel;
SELECT json_build_object('email', no_vessel.email, 'recipient', a.first) into user_settings; SELECT json_build_object('email', no_vessel.email, 'recipient', no_vessel.first) into user_settings;
RAISE NOTICE '-> debug cron_process_no_vessel_rec_fn [%]', user_settings; RAISE NOTICE '-> debug cron_process_no_vessel_rec_fn [%]', user_settings;
-- Send notification -- Send notification
PERFORM send_notification_fn('no_vessel'::TEXT, user_settings::JSONB); PERFORM send_notification_fn('no_vessel'::TEXT, user_settings::JSONB);
@@ -434,7 +434,7 @@ BEGIN
WHERE v.vessel_id = m.vessel_id) AND v.owner_email = a.email WHERE v.vessel_id = m.vessel_id) AND v.owner_email = a.email
LOOP LOOP
RAISE NOTICE '-> cron_process_no_activity_rec_fn for [%]', no_metadata_rec; RAISE NOTICE '-> cron_process_no_activity_rec_fn for [%]', no_metadata_rec;
SELECT json_build_object('email', no_metadata_rec.email, 'recipient', a.first) into user_settings; SELECT json_build_object('email', no_metadata_rec.email, 'recipient', no_metadata_rec.first) into user_settings;
RAISE NOTICE '-> debug cron_process_no_metadata_rec_fn [%]', user_settings; RAISE NOTICE '-> debug cron_process_no_metadata_rec_fn [%]', user_settings;
-- Send notification -- Send notification
PERFORM send_notification_fn('no_metadata'::TEXT, user_settings::JSONB); PERFORM send_notification_fn('no_metadata'::TEXT, user_settings::JSONB);
@@ -456,13 +456,13 @@ BEGIN
RAISE NOTICE 'cron_process_no_activity_fn'; RAISE NOTICE 'cron_process_no_activity_fn';
FOR no_activity_rec in FOR no_activity_rec in
SELECT SELECT
v.owner_email,m.name,m.vessel_id,m.time v.owner_email,m.name,m.vessel_id,m.time,a.first
FROM api.metadata m FROM api.metadata m
LEFT JOIN auth.vessels v ON v.vessel_id = m.vessel_id LEFT JOIN auth.vessels v ON v.vessel_id = m.vessel_id
WHERE m.time <= NOW() AT TIME ZONE 'UTC' - INTERVAL '200 DAYS' WHERE m.time <= NOW() AT TIME ZONE 'UTC' - INTERVAL '200 DAYS'
LOOP LOOP
RAISE NOTICE '-> cron_process_no_activity_rec_fn for [%]', no_activity_rec; RAISE NOTICE '-> cron_process_no_activity_rec_fn for [%]', no_activity_rec;
SELECT json_build_object('email', no_activity_rec.owner_email, 'recipient', a.first) into user_settings; SELECT json_build_object('email', no_activity_rec.owner_email, 'recipient', no_activity_rec.first) into user_settings;
RAISE NOTICE '-> debug cron_process_no_activity_rec_fn [%]', user_settings; RAISE NOTICE '-> debug cron_process_no_activity_rec_fn [%]', user_settings;
-- Send notification -- Send notification
PERFORM send_notification_fn('no_activity'::TEXT, user_settings::JSONB); PERFORM send_notification_fn('no_activity'::TEXT, user_settings::JSONB);