fix: 清空 MediaServerItem 表
This commit is contained in:
parent
d2c9f7a778
commit
024f1de4f1
@ -52,7 +52,7 @@ class MediaServerChain(ChainBase):
|
|||||||
# 汇总统计
|
# 汇总统计
|
||||||
total_count = 0
|
total_count = 0
|
||||||
# 清空登记薄
|
# 清空登记薄
|
||||||
self.dboper.empty(server=settings.MEDIASERVER)
|
self.dboper.empty()
|
||||||
# 同步黑名单
|
# 同步黑名单
|
||||||
sync_blacklist = settings.MEDIASERVER_SYNC_BLACKLIST.split(
|
sync_blacklist = settings.MEDIASERVER_SYNC_BLACKLIST.split(
|
||||||
",") if settings.MEDIASERVER_SYNC_BLACKLIST else []
|
",") if settings.MEDIASERVER_SYNC_BLACKLIST else []
|
||||||
|
@ -25,7 +25,7 @@ class MediaServerOper(DbOper):
|
|||||||
return True
|
return True
|
||||||
return False
|
return False
|
||||||
|
|
||||||
def empty(self, server: str):
|
def empty(self, server: Optional[str] = None):
|
||||||
"""
|
"""
|
||||||
清空媒体服务器数据
|
清空媒体服务器数据
|
||||||
"""
|
"""
|
||||||
|
@ -1,4 +1,5 @@
|
|||||||
from datetime import datetime
|
from datetime import datetime
|
||||||
|
from typing import Optional
|
||||||
|
|
||||||
from sqlalchemy import Column, Integer, String, Sequence
|
from sqlalchemy import Column, Integer, String, Sequence
|
||||||
from sqlalchemy.orm import Session
|
from sqlalchemy.orm import Session
|
||||||
@ -9,7 +10,7 @@ from app.db.models import Base, db_update
|
|||||||
|
|
||||||
class MediaServerItem(Base):
|
class MediaServerItem(Base):
|
||||||
"""
|
"""
|
||||||
站点表
|
媒体服务器媒体条目表
|
||||||
"""
|
"""
|
||||||
id = Column(Integer, Sequence('id'), primary_key=True, index=True)
|
id = Column(Integer, Sequence('id'), primary_key=True, index=True)
|
||||||
# 服务器类型
|
# 服务器类型
|
||||||
@ -48,7 +49,10 @@ class MediaServerItem(Base):
|
|||||||
|
|
||||||
@staticmethod
|
@staticmethod
|
||||||
@db_update
|
@db_update
|
||||||
def empty(db: Session, server: str):
|
def empty(db: Session, server: Optional[str] = None):
|
||||||
|
if server is None:
|
||||||
|
db.query(MediaServerItem).delete()
|
||||||
|
else:
|
||||||
db.query(MediaServerItem).filter(MediaServerItem.server == server).delete()
|
db.query(MediaServerItem).filter(MediaServerItem.server == server).delete()
|
||||||
|
|
||||||
@staticmethod
|
@staticmethod
|
||||||
|
Loading…
x
Reference in New Issue
Block a user