You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
107 lines
4.3 KiB
107 lines
4.3 KiB
from module_admin.dao.notice_dao import *
|
|
from module_admin.entity.vo.common_vo import CrudResponseModel
|
|
from utils.common_util import export_list2excel, CamelCaseUtil
|
|
|
|
|
|
class NoticeService:
|
|
"""
|
|
通知公告管理模块服务层
|
|
"""
|
|
|
|
@classmethod
|
|
async def get_notice_list_services(cls, query_db: AsyncSession, query_object: NoticePageQueryModel, is_page: bool = True):
|
|
"""
|
|
获取通知公告列表信息service
|
|
:param query_db: orm对象
|
|
:param query_object: 查询参数对象
|
|
:param is_page: 是否开启分页
|
|
:return: 通知公告列表信息对象
|
|
"""
|
|
notice_list_result = await NoticeDao.get_notice_list(query_db, query_object, is_page)
|
|
|
|
return notice_list_result
|
|
|
|
@classmethod
|
|
async def add_notice_services(cls, query_db: AsyncSession, page_object: NoticeModel):
|
|
"""
|
|
新增通知公告信息service
|
|
:param query_db: orm对象
|
|
:param page_object: 新增通知公告对象
|
|
:return: 新增通知公告校验结果
|
|
"""
|
|
notice = await NoticeDao.get_notice_detail_by_info(query_db, page_object)
|
|
if notice:
|
|
result = dict(is_success=False, message='通知公告已存在')
|
|
else:
|
|
try:
|
|
await NoticeDao.add_notice_dao(query_db, page_object)
|
|
await query_db.commit()
|
|
result = dict(is_success=True, message='新增成功')
|
|
except Exception as e:
|
|
await query_db.rollback()
|
|
raise e
|
|
|
|
return CrudResponseModel(**result)
|
|
|
|
@classmethod
|
|
async def edit_notice_services(cls, query_db: AsyncSession, page_object: NoticeModel):
|
|
"""
|
|
编辑通知公告信息service
|
|
:param query_db: orm对象
|
|
:param page_object: 编辑通知公告对象
|
|
:return: 编辑通知公告校验结果
|
|
"""
|
|
edit_notice = page_object.model_dump(exclude_unset=True)
|
|
notice_info = await cls.notice_detail_services(query_db, edit_notice.get('notice_id'))
|
|
if notice_info:
|
|
if notice_info.notice_title != page_object.notice_title or notice_info.notice_type != page_object.notice_type or notice_info.notice_content != page_object.notice_content:
|
|
notice = await NoticeDao.get_notice_detail_by_info(query_db, page_object)
|
|
if notice:
|
|
result = dict(is_success=False, message='通知公告已存在')
|
|
return CrudResponseModel(**result)
|
|
try:
|
|
await NoticeDao.edit_notice_dao(query_db, edit_notice)
|
|
await query_db.commit()
|
|
result = dict(is_success=True, message='更新成功')
|
|
except Exception as e:
|
|
await query_db.rollback()
|
|
raise e
|
|
else:
|
|
result = dict(is_success=False, message='通知公告不存在')
|
|
|
|
return CrudResponseModel(**result)
|
|
|
|
@classmethod
|
|
async def delete_notice_services(cls, query_db: AsyncSession, page_object: DeleteNoticeModel):
|
|
"""
|
|
删除通知公告信息service
|
|
:param query_db: orm对象
|
|
:param page_object: 删除通知公告对象
|
|
:return: 删除通知公告校验结果
|
|
"""
|
|
if page_object.notice_ids.split(','):
|
|
notice_id_list = page_object.notice_ids.split(',')
|
|
try:
|
|
for notice_id in notice_id_list:
|
|
await NoticeDao.delete_notice_dao(query_db, NoticeModel(noticeId=notice_id))
|
|
await query_db.commit()
|
|
result = dict(is_success=True, message='删除成功')
|
|
except Exception as e:
|
|
await query_db.rollback()
|
|
raise e
|
|
else:
|
|
result = dict(is_success=False, message='传入通知公告id为空')
|
|
return CrudResponseModel(**result)
|
|
|
|
@classmethod
|
|
async def notice_detail_services(cls, query_db: AsyncSession, notice_id: int):
|
|
"""
|
|
获取通知公告详细信息service
|
|
:param query_db: orm对象
|
|
:param notice_id: 通知公告id
|
|
:return: 通知公告id对应的信息
|
|
"""
|
|
notice = await NoticeDao.get_notice_detail_by_id(query_db, notice_id=notice_id)
|
|
result = NoticeModel(**CamelCaseUtil.transform_result(notice))
|
|
|
|
return result
|
|
|