fix: Fixed cron job and added tests - EVent Invoice Due Marking

Author: mrsaicharan1

app/api/helpers/scheduled_jobs.py

@@ -3,6 +3,7 @@
 import pytz
 from dateutil.relativedelta import relativedelta
 from flask import render_template
+from sqlalchemy import update
 
 from app.api.helpers.db import safe_query, save_to_db
 from app.api.helpers.mail import send_email_after_event, send_email_for_monthly_fee_payment, \
@@ -164,12 +165,12 @@ def expire_pending_tickets():
 def event_invoices_mark_due():
     from app import current_app as app
     with app.app_context():
-        db.session.query(EventInvoice).\
+        db.session.query(EventInvoice).join(Event).\
                     filter(EventInvoice.status == 'upcoming',
-                           EventInvoice.event.ends_at >= datetime.datetime.now(),
+                           Event.ends_at >= datetime.datetime.now(),
                            (EventInvoice.created_at + datetime.timedelta(days=30) <=
                             datetime.datetime.now())).\
-                    update({'status': 'due'})
+                    update({'status': 'due'}, synchronize_session=False)
 
         db.session.commit()
 

tests/all/integration/api/helpers/test_scheduled_jobs.py

@@ -0,0 +1,32 @@
+import unittest
+import datetime
+
+from app import current_app as app, db
+from app.factories.event_invoice import EventInvoiceFactory
+from app.api.helpers.db import save_to_db
+from app.models.event_invoice import EventInvoice
+from app.factories.event import EventFactoryBasic
+from app.api.helpers.scheduled_jobs import event_invoices_mark_due
+
+from tests.all.integration.setup_database import Setup
+from tests.all.integration.utils import OpenEventTestCase
+
+
+class TestScheduledJobs(OpenEventTestCase):
+    def setUp(self):
+        self.app = Setup.create_app()
+
+    def test_event_invoices_mark_due(self):
+        """Method to test marking of event invoices as due"""
+
+        with app.test_request_context():
+            event_invoice_obj = EventInvoiceFactory(event__ends_at=datetime.datetime(2019, 7, 20))
+            save_to_db(event_invoice_obj)
+            event_invoices_mark_due()
+            status = db.session.query(EventInvoice).\
+                        filter(EventInvoice.id == event_invoice_obj.id).first().status
+            self.assertEqual(status, "due")
+
+
+if __name__ == '__main__':
+    unittest.main()