Postup z předchozího kola

Implementace #95 (closed).

Chvíli jsem zvažoval, jestli neumět i postup do všech krajských kol najednou, ale zatím ho odkládám, než si rozmyslíme hierarchický pohled z #137 (closed).

mo/web/org_contest.py

@@ -19,7 +19,7 @@ from mo.imports import ImportType, create_import
 import mo.jobs.submit
 from mo.rights import Right, Rights
 import mo.util
-from mo.util_format import inflect_number
+from mo.util_format import inflect_number, inflect_by_number
 from mo.web import app
 import mo.web.util
 from mo.web.util import PagerForm
@@ -1192,7 +1192,7 @@ def org_contest_user(contest_id: int, user_id: int):
 
 
 class AdvanceForm(FlaskForm):
-    boundary = IntegerField('Bodová hranice', description="Postupí všichni účastníci, kteří v minulém kole získali aspoň tolik bodů.", validators=[validators.InputRequired()])
+    boundary = IntegerField('Bodová hranice', description="Postoupí všichni účastníci, kteří v minulém kole získali aspoň tolik bodů.", validators=[validators.InputRequired()])
     status = wtforms.HiddenField()
     preview = wtforms.SubmitField('Zobrazit návrh')
     execute = wtforms.SubmitField('Provést')
@@ -1204,21 +1204,24 @@ def org_contest_advance(contest_id: int):
     conn = sess.connection()
     contest, rr = get_contest_rr(contest_id, Right.manage_contest)
 
+    def redirect_back():
+        return redirect(url_for('org_contest', id=contest_id))
+
     round = contest.round
     if round.state != db.RoundState.preparing:
         flash('Aktuální kolo není ve stavu přípravy', 'danger')
-        return redirect(url_for('org_contest', id=contest_id))
+        return redirect_back()
 
     prev_round = sess.query(db.Round).filter_by(year=round.year, category=round.category, seq=round.seq - 1).one_or_none()
     if prev_round is None:
         flash('Předchozí kolo nenalezeno', 'danger')
-        return redirect(url_for('org_contest', id=contest_id))
+        return redirect_back()
     elif prev_round.state != db.RoundState.closed:
         flash('Předchozí kolo dosud nebylo ukončeno', 'danger')
-        return redirect(url_for('org_contest', id=contest_id))
+        return redirect_back()
     elif prev_round.level < round.level:
         flash('Předchozí kolo se koná ve vyšší oblasti než toto kolo', 'danger')
-        return redirect(url_for('org_contest', id=contest_id))
+        return redirect_back()
 
     prev_contests: List[db.Contest] = []
     accept_by_place_id: Dict[int, int] = {}
@@ -1255,6 +1258,15 @@ def org_contest_advance(contest_id: int):
             accept_uids = None
 
         want_execute = form.execute.data
+        if want_execute:
+            app.logger.info(f'Postup: Z kola #{prev_round.round_id} do #{round.round_id}, soutěž #{contest_id}')
+            mo.util.log(
+                type=db.LogType.contest,
+                what=contest_id,
+                details={'action': 'advance'},
+            )
+
+        really_inserted = 0
         for pp in prev_pions:
             if accept_uids and pp.user_id not in accept_uids:
                 reject_by_place_id[pp.place_id] += 1
@@ -1263,17 +1275,43 @@ def org_contest_advance(contest_id: int):
 
             if want_execute:
                 # ORM neumí ON CONFLICT DO NOTHING, takže musíme o vrstvu níže
-                ins = pgsql_insert(db.Participation.__table__).values(
-                    user_id=pp.user_id,
-                    contest_id=contest.contest_id,
-                    place_id=contest.place.place_id,
-                    state=db.PartState.invited,
-                ).on_conflict_do_nothing()
-                conn.execute(ins)
+                res = conn.execute(
+                    pgsql_insert(db.Participation.__table__)
+                    .values(
+                        user_id=pp.user_id,
+                        contest_id=contest.contest_id,
+                        place_id=contest.place.place_id,
+                        state=db.PartState.invited,
+                    )
+                    .on_conflict_do_nothing()
+                    .returning(db.Participation.contest_id)
+                )
+                inserted = res.fetchall()
+                if inserted:
+                    # Opravdu došlo ke vložení
+                    really_inserted += 1
+                    app.logger.info(f'Postup: Založena účast user=#{pp.user_id} contest=#{contest_id} place=#{contest.place_id}')
+                    mo.util.log(
+                        type=db.LogType.participant,
+                        what=pp.user_id,
+                        details={
+                            'action': 'add-to-contest',
+                            # Tady nemůžeme použít obvyklé row2dict, neboť nemáme v ruce ORMový objekt
+                            'new': {
+                                'contest_id': contest.contest_id,
+                                'place_id': contest.place_id,
+                            },
+                        },
+                    )
 
         if want_execute:
             sess.commit()
-            flash('Provedeno.', 'success')
+            msg = (inflect_by_number(really_inserted, 'Pozván', 'Pozváni', 'Pozváno')
+                   + ' '
+                   + inflect_number(really_inserted, 'nový soutěžící', 'noví soutěžící', 'nových soutěžících')
+                   + '.')
+            flash(msg, 'success')
+            return redirect_back()
 
     return render_template(
         'org_contest_advance.html',