create scheduled task for expiring pending tickets (#5887)

Author: uds5501

app/__init__.py

@@ -29,7 +29,7 @@
 from app.views import BlueprintsManager
 from app.api.helpers.auth import AuthManager
 from app.api.helpers.scheduled_jobs import send_after_event_mail, send_event_fee_notification, \
-    send_event_fee_notification_followup, change_session_state_on_event_completion
+    send_event_fee_notification_followup, change_session_state_on_event_completion, expire_pending_tickets_after_one_day
 from app.models.event import Event
 from app.models.role_invite import RoleInvite
 from app.views.healthcheck import health_check_celery, health_check_db, health_check_migrations, check_migrations
@@ -243,6 +243,7 @@ def update_sent_state(sender=None, body=None, **kwargs):
 scheduler.add_job(send_event_fee_notification, 'cron', day=1)
 scheduler.add_job(send_event_fee_notification_followup, 'cron', day=15)
 scheduler.add_job(change_session_state_on_event_completion, 'cron', hour=5, minute=30)
+scheduler.add_job(expire_pending_tickets_after_one_day, 'cron', hour=5)
 scheduler.start()
 
 

app/api/helpers/scheduled_jobs.py

@@ -140,3 +140,12 @@ def send_event_fee_notification_followup():
                                                         app_name,
                                                         link,
                                                         incomplete_invoice.event.id)
+
+
+def expire_pending_tickets_after_one_day():
+    from app import current_app as app
+    with app.app_context():
+        db.session.query(Order).filter(Order.status == 'pending',
+                                       (datetime.datetime.today() - Order.created_at).days > 1).\
+                                       update({'status': 'expired'})
+        db.session.commit()