Fix kfet and edt_notif
This commit is contained in:
parent
ba67968a77
commit
eb84420152
2 changed files with 4 additions and 3 deletions
|
@ -2,7 +2,7 @@ import datetime
|
||||||
|
|
||||||
import requests
|
import requests
|
||||||
from feedparser import parse
|
from feedparser import parse
|
||||||
from sqlalchemy import Column, Integer, String, Boolean, Date
|
from sqlalchemy import Column, Integer, String, Boolean, DateTime
|
||||||
from sqlalchemy.ext.declarative import declarative_base
|
from sqlalchemy.ext.declarative import declarative_base
|
||||||
|
|
||||||
from TelegramEDT.EDTcalendar import Calendar
|
from TelegramEDT.EDTcalendar import Calendar
|
||||||
|
@ -23,7 +23,7 @@ class User(Base):
|
||||||
nt = Column(Boolean, default=False)
|
nt = Column(Boolean, default=False)
|
||||||
nt_time = Column(Integer, default=20)
|
nt_time = Column(Integer, default=20)
|
||||||
nt_cooldown = Column(Integer, default=20)
|
nt_cooldown = Column(Integer, default=20)
|
||||||
nt_last = Column(Date, default=get_now)
|
nt_last = Column(DateTime, default=get_now)
|
||||||
kfet = Column(Integer, default=0)
|
kfet = Column(Integer, default=0)
|
||||||
await_cmd = Column(String, default="")
|
await_cmd = Column(String, default="")
|
||||||
tomuss_rss = Column(String)
|
tomuss_rss = Column(String)
|
||||||
|
@ -38,7 +38,7 @@ class User(Base):
|
||||||
c = self.calendar(pass_week=False)
|
c = self.calendar(pass_week=False)
|
||||||
for e in c.timeline:
|
for e in c.timeline:
|
||||||
if 0 < (e.begin - now).total_seconds() // 60 <= self.nt_time and \
|
if 0 < (e.begin - now).total_seconds() // 60 <= self.nt_time and \
|
||||||
0 < (now - self.nt_last).total_seconds() // 60 >= self.nt_cooldown:
|
0 < (now.replace(tzinfo=None) - self.nt_last).total_seconds() // 60 >= self.nt_cooldown:
|
||||||
self.nt_last = get_now()
|
self.nt_last = get_now()
|
||||||
return e
|
return e
|
||||||
return None
|
return None
|
||||||
|
|
|
@ -94,6 +94,7 @@ async def notif():
|
||||||
else:
|
else:
|
||||||
kf = lang(u, "kfet_err")
|
kf = lang(u, "kfet_err")
|
||||||
await bot.send_message(u.id, kf, parse_mode=ParseMode.MARKDOWN)
|
await bot.send_message(u.id, kf, parse_mode=ParseMode.MARKDOWN)
|
||||||
|
session.commit()
|
||||||
|
|
||||||
|
|
||||||
def load():
|
def load():
|
||||||
|
|
Reference in a new issue