148 lines
4.6 KiB
Python
148 lines
4.6 KiB
Python
import json
|
|
|
|
import asyncio
|
|
|
|
from init import db, Meals, scheduler, flask_app
|
|
import datetime
|
|
import time
|
|
import httpx
|
|
|
|
nomeal = 'Essen nicht (mehr) verfügbar'
|
|
|
|
|
|
async def getMeals(day: datetime):
|
|
"""
|
|
Liefert alle Mahlzeiten eines Tages. \n
|
|
Befinden sie sich schon in der Datenbank, werden diese zurückgegeben. \n
|
|
Wenn nicht, wird getMealsFromAPI() aufgerufen. \n
|
|
:param day:
|
|
:return [Name1, Name2, ...]:
|
|
"""
|
|
day = formatDay(day)
|
|
essen = []
|
|
query = Meals.query.filter_by(date=day).all()
|
|
if len(query) != 0:
|
|
for i in query:
|
|
essen += [i.name]
|
|
essen.sort(key=len, reverse=True)
|
|
return essen
|
|
return await getMealsFromAPI(day, dbentry=True)
|
|
|
|
|
|
async def getMealsFromAPI(day: str, dbentry: bool = False):
|
|
"""
|
|
Fragt die Mensa-API nach den Mahlzeiten eines Tages ab. \n
|
|
Wenn dbentry: Schreibt die Ergebnisse in die Datenbank. \n
|
|
TODO: Andere Mensen berücksichtigen.
|
|
:param day:
|
|
:param dbentry:
|
|
:return [Name1, Name2, ...]:
|
|
"""
|
|
async with httpx.AsyncClient() as s:
|
|
response = await s.get(url=f"https://dh-api.paulmartin.cloud/plans/{day}?canteens=erzberger")
|
|
response = response.content
|
|
jres = json.loads(response.decode("utf-8"))
|
|
essen = []
|
|
try:
|
|
num = len(jres["data"][0]["lines"])
|
|
for i in range(num):
|
|
try:
|
|
jsmeal = jres["data"][0]["lines"][i]["meals"]
|
|
cont = True
|
|
except IndexError:
|
|
essen = []
|
|
cont = False
|
|
if cont:
|
|
for e in range(len(jsmeal)):
|
|
ji = jsmeal[e]
|
|
name = ji["name"]
|
|
if pricetofloat(ji["price"]) >= 1.1:
|
|
vegan = ji["classifiers"].count("VG") == 1
|
|
schwein = ji["classifiers"].count("S") == 1
|
|
if vegan:
|
|
veget = True
|
|
else:
|
|
veget = ji["classifiers"].count("VEG") == 1
|
|
if veget:
|
|
if name.count("Reibekäse") > 0:
|
|
vegan = True
|
|
|
|
essen += [name]
|
|
if dbentry:
|
|
mid = int(time.time() * 1000) % 100000
|
|
neu = Meals(date=day, name=name, id=mid, vegan=vegan, vegetarian=veget, schwein=schwein)
|
|
db.session.add(neu)
|
|
db.session.commit()
|
|
if not essen:
|
|
essen = [nomeal]
|
|
except KeyError:
|
|
essen = [nomeal]
|
|
return essen
|
|
|
|
|
|
def pricetofloat(price: str):
|
|
"""
|
|
Konvertiert den Preis-String der Mensa-API zu einem Python-Float.
|
|
:param price:
|
|
:return float:
|
|
"""
|
|
price = price[:-2]
|
|
price = price.replace(",", ".")
|
|
try:
|
|
return float(price)
|
|
except ValueError:
|
|
return 0
|
|
|
|
|
|
def formatDay(day: datetime):
|
|
"""
|
|
Füllt ein Datum mit Nullen auf. \n
|
|
"2023-1-1" → "2023-01-01".
|
|
:param day:
|
|
:return str:
|
|
"""
|
|
if day.month < 10:
|
|
mon = "0" + str(day.month)
|
|
else:
|
|
mon = str(day.month)
|
|
if day.day < 10:
|
|
tag = "0" + str(day.day)
|
|
else:
|
|
tag = str(day.day)
|
|
day = str(day.year) + "-" + mon + "-" + tag
|
|
return day
|
|
|
|
|
|
async def refreshMeals():
|
|
"""
|
|
Aktualisiert immer vormittags alle Mahlzeiten in der Datenbank. \n
|
|
Datenbankeinträge werden ersetzt, wenn die API andere Mahlzeiten liefert.
|
|
"""
|
|
print("Aktualisiere Essenspläne...\n")
|
|
|
|
table = Meals.query.all()
|
|
dates = []
|
|
for i in table:
|
|
if i.date not in dates:
|
|
dates += [i.date]
|
|
for i in range(len(dates)):
|
|
dates[i] = formatDay(dates[i])
|
|
for i in dates:
|
|
apinames = await getMealsFromAPI(i)
|
|
apinames = await getMealsFromAPI(i)
|
|
dbmeals = Meals.query.filter_by(date=i).all()
|
|
dbnames = []
|
|
for m in dbmeals:
|
|
dbnames += [m.name]
|
|
if set(dbnames) != set(apinames) and nomeal not in apinames:
|
|
for n in dbnames:
|
|
db.session.delete(Meals.query.filter_by(date=i, name=n).first())
|
|
db.session.commit()
|
|
await getMealsFromAPI(i, True)
|
|
|
|
|
|
@scheduler.task('cron', id="mensaschedule", hour='8-11', day_of_week='*', minute='*/15', week='*', second='5')
|
|
def mensaschedule():
|
|
with flask_app.app_context():
|
|
asyncio.run(refreshMeals())
|