diff --git a/app/db/models/transferhistory.py b/app/db/models/transferhistory.py index e1957605..5868e8e9 100644 --- a/app/db/models/transferhistory.py +++ b/app/db/models/transferhistory.py @@ -212,3 +212,11 @@ class TransferHistory(Base): "download_hash": download_hash } ) + + @staticmethod + @db_query + def list_by_date(db: Session, date: str): + """ + 查询某时间之后的转移历史 + """ + return db.query(TransferHistory).filter(TransferHistory.date > date).order_by(TransferHistory.id.desc()).all() diff --git a/app/db/transferhistory_oper.py b/app/db/transferhistory_oper.py index 247b22eb..eedac77a 100644 --- a/app/db/transferhistory_oper.py +++ b/app/db/transferhistory_oper.py @@ -177,3 +177,10 @@ class TransferHistoryOper(DbOper): errmsg="未识别到媒体信息" ) return his + + def list_by_date(self, date: str) -> List[TransferHistory]: + """ + 查询某时间之后的转移历史 + :param date: 日期 + """ + return TransferHistory.list_by_date(self._db, date)