Use flask_sqlalchemy to manage the database connection.

[philipp/winterrodeln/wradmin.git] / wradmin / controllers / bericht.py

diff --git a/wradmin/controllers/bericht.py b/wradmin/controllers/bericht.py
index e8f2f690e2b158d79d1cae9150e01f078639b1b1..7084929ea036e92f713fb1fb4be3a57c44d86227 100644 (file)
--- a/wradmin/controllers/bericht.py
+++ b/wradmin/controllers/bericht.py
@@ -2,7 +2,11 @@ import datetime
 from flask import request, abort, redirect, url_for, flash, render_template
 import paginate
 import sqlalchemy as sa
-import wradmin.model as model
+
+import wrpylib.wrmwcache
+
+from wradmin import db
+from wradmin.model import WrReport
 
 
 class BerichtController:
@@ -23,8 +27,8 @@ class BerichtController:
 
     def list(self):
         """Lists all reports"""
-        q = model.meta.Session.query(model.WrReport)
-        q = q.order_by(sa.sql.expression.desc(model.WrReport.id))
+        q = db.session.query(WrReport)
+        q = q.order_by(sa.sql.expression.desc(WrReport.id))
         paginator = paginate.Page(q.all(), page=int(request.args.get('page', 1)),
                                   url_maker=lambda page: url_for('bericht_list', page=page),
                                   items_per_page=25)
@@ -32,7 +36,7 @@ class BerichtController:
 
     def view(self, id):
         """Displays a report"""
-        q = model.meta.Session.query(model.WrReport)
+        q = db.session.query(WrReport)
         wrreport = q.get(id)
         if wrreport is None:
             abort(404)
@@ -43,7 +47,7 @@ class BerichtController:
         assert request.method == 'POST'
         if id is None:
             abort(404)
-        wrreport_q = model.meta.Session.query(model.WrReport)
+        wrreport_q = db.session.query(WrReport)
         wrreport = wrreport_q.get(id)
         if wrreport is None:
             abort(404)
@@ -63,6 +67,18 @@ class BerichtController:
                 flash(str(e))
                 return redirect(url_for('bericht_view', id=id))
             wrreport.date_invalid = date_userdefined
-        model.meta.Session.commit()
+        db.session.commit()
         flash('Datum wurde erfolgreich geändert')
         return redirect(url_for('bericht_view', id=id))
+
+    def update_reportcache(self):
+        """Updates the wrreportcache table."""
+        c = db.session.connection()
+        try:
+            wrpylib.wrmwcache.update_wrreportcache(c)
+            db.session.commit()
+            flash('Die Berichtzusammenfassung-Tabelle wurde erfolgreich aktualisiesrt.', 'info')
+        except wrpylib.wrmwcache.UpdateCacheError as e:
+            flash(str(e), 'error')
+        # Redirect to result page
+        return redirect(url_for('bericht_list'))