|
@ -1,7 +1,7 @@ |
|
|
from sqlalchemy import delete, select, update, desc,or_,not_ |
|
|
from sqlalchemy import delete, select, update, desc,or_,not_ |
|
|
from sqlalchemy.ext.asyncio import AsyncSession |
|
|
from sqlalchemy.ext.asyncio import AsyncSession |
|
|
from module_admin.entity.do.datastd_do import DataStdCode,DataStdDict,DataAstContent,DataAstContentRela,DataStdMain,DataStdMainAppr,DataStdDictAppr |
|
|
from module_admin.entity.do.datastd_do import DataStdCode,DataStdDict,DataAstContent,DataAstContentRela,DataStdMain,DataStdMainAppr,DataStdDictAppr,DataStdCodeAppr |
|
|
from module_admin.entity.vo.datastd_vo import DataStdCodeModel,DataStdDictModel,DataStdMainModel,DataStdMainApprModel,DataStdDictApprModel |
|
|
from module_admin.entity.vo.datastd_vo import DataStdCodeModel,DataStdDictModel,DataStdMainModel,DataStdMainApprModel,DataStdDictApprModel,DataStdCodeApprModel |
|
|
from module_admin.entity.do.dept_do import SysDept |
|
|
from module_admin.entity.do.dept_do import SysDept |
|
|
from utils.page_util import PageUtil |
|
|
from utils.page_util import PageUtil |
|
|
from sqlalchemy.orm import aliased |
|
|
from sqlalchemy.orm import aliased |
|
@ -154,10 +154,23 @@ class DataStdDao: |
|
|
await db.flush() |
|
|
await db.flush() |
|
|
return col |
|
|
return col |
|
|
|
|
|
|
|
|
|
|
|
@classmethod |
|
|
|
|
|
async def add_std_code_appr(cls, db: AsyncSession,model:DataStdCodeApprModel): |
|
|
|
|
|
col = DataStdCodeAppr( |
|
|
|
|
|
**model.model_dump() |
|
|
|
|
|
) |
|
|
|
|
|
db.add(col) |
|
|
|
|
|
await db.flush() |
|
|
|
|
|
return col |
|
|
|
|
|
|
|
|
@classmethod |
|
|
@classmethod |
|
|
async def delete_std_code(cls, db: AsyncSession, Id: str): |
|
|
async def delete_std_code(cls, db: AsyncSession, Id: str): |
|
|
await db.execute(delete(DataStdCode).where(DataStdCode.id == Id)) |
|
|
await db.execute(delete(DataStdCode).where(DataStdCode.id == Id)) |
|
|
|
|
|
@classmethod |
|
|
|
|
|
async def update_std_code_appr(cls, db: AsyncSession, update_data: DataStdCodeApprModel): |
|
|
|
|
|
|
|
|
|
|
|
await db.execute(update(DataStdCodeAppr), [update_data]) |
|
|
|
|
|
await db.flush() |
|
|
|
|
|
|
|
|
@classmethod |
|
|
@classmethod |
|
|
async def update_std_code(cls, db: AsyncSession, update_data: DataStdCodeModel): |
|
|
async def update_std_code(cls, db: AsyncSession, update_data: DataStdCodeModel): |
|
|