fix: 修复各模块新增数据时创建时间记录异常的问题
This commit is contained in:
@@ -31,7 +31,9 @@ async def get_system_config_list(request: Request, config_page_query: ConfigPage
|
|||||||
async def add_system_config(request: Request, add_config: ConfigModel, query_db: AsyncSession = Depends(get_db), current_user: CurrentUserModel = Depends(LoginService.get_current_user)):
|
async def add_system_config(request: Request, add_config: ConfigModel, query_db: AsyncSession = Depends(get_db), current_user: CurrentUserModel = Depends(LoginService.get_current_user)):
|
||||||
try:
|
try:
|
||||||
add_config.create_by = current_user.user.user_name
|
add_config.create_by = current_user.user.user_name
|
||||||
|
add_config.create_time = datetime.now()
|
||||||
add_config.update_by = current_user.user.user_name
|
add_config.update_by = current_user.user.user_name
|
||||||
|
add_config.update_time = datetime.now()
|
||||||
add_config_result = await ConfigService.add_config_services(request, query_db, add_config)
|
add_config_result = await ConfigService.add_config_services(request, query_db, add_config)
|
||||||
if add_config_result.is_success:
|
if add_config_result.is_success:
|
||||||
logger.info(add_config_result.message)
|
logger.info(add_config_result.message)
|
||||||
|
@@ -41,7 +41,9 @@ async def get_system_dept_list(request: Request, dept_query: DeptQueryModel = De
|
|||||||
async def add_system_dept(request: Request, add_dept: DeptModel, query_db: AsyncSession = Depends(get_db), current_user: CurrentUserModel = Depends(LoginService.get_current_user)):
|
async def add_system_dept(request: Request, add_dept: DeptModel, query_db: AsyncSession = Depends(get_db), current_user: CurrentUserModel = Depends(LoginService.get_current_user)):
|
||||||
try:
|
try:
|
||||||
add_dept.create_by = current_user.user.user_name
|
add_dept.create_by = current_user.user.user_name
|
||||||
|
add_dept.create_time = datetime.now()
|
||||||
add_dept.update_by = current_user.user.user_name
|
add_dept.update_by = current_user.user.user_name
|
||||||
|
add_dept.update_time = datetime.now()
|
||||||
add_dept_result = await DeptService.add_dept_services(query_db, add_dept)
|
add_dept_result = await DeptService.add_dept_services(query_db, add_dept)
|
||||||
if add_dept_result.is_success:
|
if add_dept_result.is_success:
|
||||||
logger.info(add_dept_result.message)
|
logger.info(add_dept_result.message)
|
||||||
|
@@ -31,7 +31,9 @@ async def get_system_dict_type_list(request: Request, dict_type_page_query: Dict
|
|||||||
async def add_system_dict_type(request: Request, add_dict_type: DictTypeModel, query_db: AsyncSession = Depends(get_db), current_user: CurrentUserModel = Depends(LoginService.get_current_user)):
|
async def add_system_dict_type(request: Request, add_dict_type: DictTypeModel, query_db: AsyncSession = Depends(get_db), current_user: CurrentUserModel = Depends(LoginService.get_current_user)):
|
||||||
try:
|
try:
|
||||||
add_dict_type.create_by = current_user.user.user_name
|
add_dict_type.create_by = current_user.user.user_name
|
||||||
|
add_dict_type.create_time = datetime.now()
|
||||||
add_dict_type.update_by = current_user.user.user_name
|
add_dict_type.update_by = current_user.user.user_name
|
||||||
|
add_dict_type.update_time = datetime.now()
|
||||||
add_dict_type_result = await DictTypeService.add_dict_type_services(request, query_db, add_dict_type)
|
add_dict_type_result = await DictTypeService.add_dict_type_services(request, query_db, add_dict_type)
|
||||||
if add_dict_type_result.is_success:
|
if add_dict_type_result.is_success:
|
||||||
logger.info(add_dict_type_result.message)
|
logger.info(add_dict_type_result.message)
|
||||||
@@ -160,7 +162,9 @@ async def get_system_dict_data_list(request: Request, dict_data_page_query: Dict
|
|||||||
async def add_system_dict_data(request: Request, add_dict_data: DictDataModel, query_db: AsyncSession = Depends(get_db), current_user: CurrentUserModel = Depends(LoginService.get_current_user)):
|
async def add_system_dict_data(request: Request, add_dict_data: DictDataModel, query_db: AsyncSession = Depends(get_db), current_user: CurrentUserModel = Depends(LoginService.get_current_user)):
|
||||||
try:
|
try:
|
||||||
add_dict_data.create_by = current_user.user.user_name
|
add_dict_data.create_by = current_user.user.user_name
|
||||||
|
add_dict_data.create_time = datetime.now()
|
||||||
add_dict_data.update_by = current_user.user.user_name
|
add_dict_data.update_by = current_user.user.user_name
|
||||||
|
add_dict_data.update_time = datetime.now()
|
||||||
add_dict_data_result = await DictDataService.add_dict_data_services(request, query_db, add_dict_data)
|
add_dict_data_result = await DictDataService.add_dict_data_services(request, query_db, add_dict_data)
|
||||||
if add_dict_data_result.is_success:
|
if add_dict_data_result.is_success:
|
||||||
logger.info(add_dict_data_result.message)
|
logger.info(add_dict_data_result.message)
|
||||||
|
@@ -32,7 +32,9 @@ async def get_system_job_list(request: Request, job_page_query: JobPageQueryMode
|
|||||||
async def add_system_job(request: Request, add_job: JobModel, query_db: AsyncSession = Depends(get_db), current_user: CurrentUserModel = Depends(LoginService.get_current_user)):
|
async def add_system_job(request: Request, add_job: JobModel, query_db: AsyncSession = Depends(get_db), current_user: CurrentUserModel = Depends(LoginService.get_current_user)):
|
||||||
try:
|
try:
|
||||||
add_job.create_by = current_user.user.user_name
|
add_job.create_by = current_user.user.user_name
|
||||||
|
add_job.create_time = datetime.now()
|
||||||
add_job.update_by = current_user.user.user_name
|
add_job.update_by = current_user.user.user_name
|
||||||
|
add_job.update_time = datetime.now()
|
||||||
add_job_result = await JobService.add_job_services(query_db, add_job)
|
add_job_result = await JobService.add_job_services(query_db, add_job)
|
||||||
if add_job_result.is_success:
|
if add_job_result.is_success:
|
||||||
logger.info(add_job_result.message)
|
logger.info(add_job_result.message)
|
||||||
|
@@ -50,7 +50,9 @@ async def get_system_menu_list(request: Request, menu_query: MenuQueryModel = De
|
|||||||
async def add_system_menu(request: Request, add_menu: MenuModel, query_db: AsyncSession = Depends(get_db), current_user: CurrentUserModel = Depends(LoginService.get_current_user)):
|
async def add_system_menu(request: Request, add_menu: MenuModel, query_db: AsyncSession = Depends(get_db), current_user: CurrentUserModel = Depends(LoginService.get_current_user)):
|
||||||
try:
|
try:
|
||||||
add_menu.create_by = current_user.user.user_name
|
add_menu.create_by = current_user.user.user_name
|
||||||
|
add_menu.create_time = datetime.now()
|
||||||
add_menu.update_by = current_user.user.user_name
|
add_menu.update_by = current_user.user.user_name
|
||||||
|
add_menu.update_time = datetime.now()
|
||||||
add_menu_result = await MenuService.add_menu_services(query_db, add_menu)
|
add_menu_result = await MenuService.add_menu_services(query_db, add_menu)
|
||||||
if add_menu_result.is_success:
|
if add_menu_result.is_success:
|
||||||
logger.info(add_menu_result.message)
|
logger.info(add_menu_result.message)
|
||||||
|
@@ -30,7 +30,9 @@ async def get_system_notice_list(request: Request, notice_page_query: NoticePage
|
|||||||
async def add_system_notice(request: Request, add_notice: NoticeModel, query_db: AsyncSession = Depends(get_db), current_user: CurrentUserModel = Depends(LoginService.get_current_user)):
|
async def add_system_notice(request: Request, add_notice: NoticeModel, query_db: AsyncSession = Depends(get_db), current_user: CurrentUserModel = Depends(LoginService.get_current_user)):
|
||||||
try:
|
try:
|
||||||
add_notice.create_by = current_user.user.user_name
|
add_notice.create_by = current_user.user.user_name
|
||||||
|
add_notice.create_time = datetime.now()
|
||||||
add_notice.update_by = current_user.user.user_name
|
add_notice.update_by = current_user.user.user_name
|
||||||
|
add_notice.update_time = datetime.now()
|
||||||
add_notice_result = await NoticeService.add_notice_services(query_db, add_notice)
|
add_notice_result = await NoticeService.add_notice_services(query_db, add_notice)
|
||||||
if add_notice_result.is_success:
|
if add_notice_result.is_success:
|
||||||
logger.info(add_notice_result.message)
|
logger.info(add_notice_result.message)
|
||||||
|
@@ -32,7 +32,9 @@ async def get_system_post_list(request: Request, post_page_query: PostPageQueryM
|
|||||||
async def add_system_post(request: Request, add_post: PostModel, query_db: AsyncSession = Depends(get_db), current_user: CurrentUserModel = Depends(LoginService.get_current_user)):
|
async def add_system_post(request: Request, add_post: PostModel, query_db: AsyncSession = Depends(get_db), current_user: CurrentUserModel = Depends(LoginService.get_current_user)):
|
||||||
try:
|
try:
|
||||||
add_post.create_by = current_user.user.user_name
|
add_post.create_by = current_user.user.user_name
|
||||||
|
add_post.create_time = datetime.now()
|
||||||
add_post.update_by = current_user.user.user_name
|
add_post.update_by = current_user.user.user_name
|
||||||
|
add_post.update_time = datetime.now()
|
||||||
add_post_result = await PostService.add_post_services(query_db, add_post)
|
add_post_result = await PostService.add_post_services(query_db, add_post)
|
||||||
if add_post_result.is_success:
|
if add_post_result.is_success:
|
||||||
logger.info(add_post_result.message)
|
logger.info(add_post_result.message)
|
||||||
|
@@ -46,7 +46,9 @@ async def get_system_role_list(request: Request, role_page_query: RolePageQueryM
|
|||||||
async def add_system_role(request: Request, add_role: AddRoleModel, query_db: AsyncSession = Depends(get_db), current_user: CurrentUserModel = Depends(LoginService.get_current_user)):
|
async def add_system_role(request: Request, add_role: AddRoleModel, query_db: AsyncSession = Depends(get_db), current_user: CurrentUserModel = Depends(LoginService.get_current_user)):
|
||||||
try:
|
try:
|
||||||
add_role.create_by = current_user.user.user_name
|
add_role.create_by = current_user.user.user_name
|
||||||
|
add_role.create_time = datetime.now()
|
||||||
add_role.update_by = current_user.user.user_name
|
add_role.update_by = current_user.user.user_name
|
||||||
|
add_role.update_time = datetime.now()
|
||||||
add_role_result = await RoleService.add_role_services(query_db, add_role)
|
add_role_result = await RoleService.add_role_services(query_db, add_role)
|
||||||
if add_role_result.is_success:
|
if add_role_result.is_success:
|
||||||
logger.info(add_role_result.message)
|
logger.info(add_role_result.message)
|
||||||
|
@@ -47,7 +47,9 @@ async def add_system_user(request: Request, add_user: AddUserModel, query_db: As
|
|||||||
try:
|
try:
|
||||||
add_user.password = PwdUtil.get_password_hash(add_user.password)
|
add_user.password = PwdUtil.get_password_hash(add_user.password)
|
||||||
add_user.create_by = current_user.user.user_name
|
add_user.create_by = current_user.user.user_name
|
||||||
|
add_user.create_time = datetime.now()
|
||||||
add_user.update_by = current_user.user.user_name
|
add_user.update_by = current_user.user.user_name
|
||||||
|
add_user.update_time = datetime.now()
|
||||||
add_user_result = await UserService.add_user_services(query_db, add_user)
|
add_user_result = await UserService.add_user_services(query_db, add_user)
|
||||||
if add_user_result.is_success:
|
if add_user_result.is_success:
|
||||||
logger.info(add_user_result.message)
|
logger.info(add_user_result.message)
|
||||||
|
@@ -275,7 +275,9 @@ class UserService:
|
|||||||
sex=row['sex'],
|
sex=row['sex'],
|
||||||
status=row['status'],
|
status=row['status'],
|
||||||
createBy=current_user.user.user_name,
|
createBy=current_user.user.user_name,
|
||||||
updateBy=current_user.user.user_name
|
createTime=datetime.now(),
|
||||||
|
updateBy=current_user.user.user_name,
|
||||||
|
updateTime=datetime.now()
|
||||||
)
|
)
|
||||||
user_info = await UserDao.get_user_by_info(query_db, UserModel(userName=row['user_name']))
|
user_info = await UserDao.get_user_by_info(query_db, UserModel(userName=row['user_name']))
|
||||||
if user_info:
|
if user_info:
|
||||||
@@ -289,7 +291,8 @@ class UserService:
|
|||||||
phonenumber=str(row['phonenumber']),
|
phonenumber=str(row['phonenumber']),
|
||||||
sex=row['sex'],
|
sex=row['sex'],
|
||||||
status=row['status'],
|
status=row['status'],
|
||||||
updateBy=current_user.user.user_name
|
updateBy=current_user.user.user_name,
|
||||||
|
updateTime=datetime.now()
|
||||||
).model_dump(exclude_unset=True)
|
).model_dump(exclude_unset=True)
|
||||||
await UserDao.edit_user_dao(query_db, edit_user)
|
await UserDao.edit_user_dao(query_db, edit_user)
|
||||||
else:
|
else:
|
||||||
|
Reference in New Issue
Block a user