UserDomain 一括追加 API を修正する
This commit is contained in:
@@ -254,7 +254,7 @@ async def userdomain_details(
|
|||||||
async def create_userdomain(
|
async def create_userdomain(
|
||||||
request: Request,
|
request: Request,
|
||||||
userid: int,
|
userid: int,
|
||||||
domainids:list,
|
domainids:List[int] ,
|
||||||
db=Depends(get_db),
|
db=Depends(get_db),
|
||||||
):
|
):
|
||||||
try:
|
try:
|
||||||
|
|||||||
@@ -224,16 +224,11 @@ def edit_domain(
|
|||||||
db.refresh(db_domain)
|
db.refresh(db_domain)
|
||||||
return db_domain
|
return db_domain
|
||||||
|
|
||||||
def add_userdomain(db: Session, userid:int,domainids:list):
|
def add_userdomain(db: Session, userid:int,domainids:list[str]):
|
||||||
for domainid in domainids:
|
dbCommits = list(map(lambda domainid: models.UserDomain(userid = userid, domainid = domainid ), domainids))
|
||||||
db_domain = models.UserDomain(
|
db.bulk_save_objects(dbCommits)
|
||||||
userid = userid,
|
|
||||||
domainid = domainid
|
|
||||||
)
|
|
||||||
db.add(db_domain)
|
|
||||||
db.commit()
|
db.commit()
|
||||||
db.refresh(db_domain)
|
return dbCommits
|
||||||
return db_domain
|
|
||||||
|
|
||||||
def delete_userdomain(db: Session, userid: int,domainid: int):
|
def delete_userdomain(db: Session, userid: int,domainid: int):
|
||||||
db_domain = db.query(models.UserDomain).filter(and_(models.UserDomain.userid == userid,models.UserDomain.domainid == domainid)).first()
|
db_domain = db.query(models.UserDomain).filter(and_(models.UserDomain.userid == userid,models.UserDomain.domainid == domainid)).first()
|
||||||
|
|||||||
Reference in New Issue
Block a user