self/ruz-bot
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

logging

Browse Source
This commit is contained in:
Administrator 2022-10-22 22:33:48 +03:00
parent c9ad723222
commit 6a69681e9f
2 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
daemons/notify.py
View File

@ -11,10 +11,12 @@ from helpers.ruz import ruz
def process(): def process():
time_now = now()
print(time_now)
for user in mongo.users_collection.find({"notify_minutes": {"$ne": None}, "hse_id": {"$ne": None}}): for user in mongo.users_collection.find({"notify_minutes": {"$ne": None}, "hse_id": {"$ne": None}}):
for lesson in mongo.lessons_collection.find({ for lesson in mongo.lessons_collection.find({
"hse_user_id": user["hse_id"], "hse_user_id": user["hse_id"],
"begin": {"$lte": now() + datetime.timedelta(minutes=user["notify_minutes"])}, "begin": {"$lte": time_now + datetime.timedelta(minutes=user["notify_minutes"])},
"notified": False "notified": False
}): }):
ans = "" ans = ""
@ -30,7 +32,6 @@ def process():
except ApiTelegramException: except ApiTelegramException:
pass pass
mongo.lessons_collection.update_one({"_id": lesson['_id']}, {"$set": {"notified": True}}) mongo.lessons_collection.update_one({"_id": lesson['_id']}, {"$set": {"notified": True}})
time_now = now()
for user in mongo.users_collection.find({"next_daily_notify_time": {"$lte": time_now}}): for user in mongo.users_collection.find({"next_daily_notify_time": {"$lte": time_now}}):
user_model = UserSchema().load(user) user_model = UserSchema().load(user)
if time_now.weekday() != 6: if time_now.weekday() != 6:

3
helpers/__init__.py
View File

@ -20,6 +20,9 @@ def get_next_daily_notify_time(user: User, time_now: datetime.datetime | None =
hour=hours, hour=hours,
minute=minutes minute=minutes
) )
print('now time is', time_now)
print('user wants to notify at', hours, minutes)
if time_now.hour * 60 + time_now.minute < hours * 60 + minutes: if time_now.hour * 60 + time_now.minute < hours * 60 + minutes:
print('go to next day')
next_time = next_time + datetime.timedelta(days=1) next_time = next_time + datetime.timedelta(days=1)
return next_time return next_time