71 lines
2.2 KiB
Python
71 lines
2.2 KiB
Python
import json
|
|
from datetime import datetime
|
|
|
|
from app.db import DbOper
|
|
from app.db.models.sitestatistic import SiteStatistic
|
|
|
|
|
|
class SiteStatisticOper(DbOper):
|
|
"""
|
|
站点统计管理
|
|
"""
|
|
|
|
def success(self, domain: str, seconds: int = None):
|
|
"""
|
|
站点访问成功
|
|
"""
|
|
lst_date = datetime.now().strftime("%Y-%m-%d %H:%M:%S")
|
|
sta = SiteStatistic.get_by_domain(self._db, domain)
|
|
if sta:
|
|
avg_seconds, note = None, {}
|
|
if seconds is not None:
|
|
note: dict = json.loads(sta.note or "{}")
|
|
note[lst_date] = seconds or 1
|
|
avg_times = len(note.keys())
|
|
if avg_times > 10:
|
|
note = dict(sorted(note.items(), key=lambda x: x[0], reverse=True)[:10])
|
|
avg_seconds = sum([v for v in note.values()]) // avg_times
|
|
sta.update(self._db, {
|
|
"success": sta.success + 1,
|
|
"seconds": avg_seconds or sta.seconds,
|
|
"lst_state": 0,
|
|
"lst_mod_date": lst_date,
|
|
"note": json.dumps(note) if note else sta.note
|
|
})
|
|
else:
|
|
note = {}
|
|
if seconds is not None:
|
|
note = {
|
|
lst_date: seconds or 1
|
|
}
|
|
SiteStatistic(
|
|
domain=domain,
|
|
success=1,
|
|
fail=0,
|
|
seconds=seconds or 1,
|
|
lst_state=0,
|
|
lst_mod_date=lst_date,
|
|
note=json.dumps(note)
|
|
).create(self._db)
|
|
|
|
def fail(self, domain: str):
|
|
"""
|
|
站点访问失败
|
|
"""
|
|
lst_date = datetime.now().strftime("%Y-%m-%d %H:%M:%S")
|
|
sta = SiteStatistic.get_by_domain(self._db, domain)
|
|
if sta:
|
|
sta.update(self._db, {
|
|
"fail": sta.fail + 1,
|
|
"lst_state": 1,
|
|
"lst_mod_date": lst_date
|
|
})
|
|
else:
|
|
SiteStatistic(
|
|
domain=domain,
|
|
success=0,
|
|
fail=1,
|
|
lst_state=1,
|
|
lst_mod_date=lst_date
|
|
).create(self._db)
|