From b1f1b9a63a18eaa8e0f6b901a6ca4ca8736a5879 Mon Sep 17 00:00:00 2001 From: haotian <2421912570@qq.com> Date: Wed, 30 Jul 2025 17:59:09 +0800 Subject: [PATCH] =?UTF-8?q?=E5=88=9D=E5=A7=8B=E5=8C=96=E8=AE=B2=E8=A7=A3?= =?UTF-8?q?=E5=86=85=E5=AE=B9=E6=9C=89=E5=85=B3=E5=86=85=E5=AE=B9?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../explanation_content_controller.py | 115 +++++++++++++++ .../dao/explanation_content_dao.py | 135 +++++++++++++++++ .../entity/do/explanation_content_do.py | 25 ++++ .../entity/vo/explanation_content_vo.py | 67 +++++++++ .../service/explanation_content_service.py | 136 ++++++++++++++++++ 5 files changed, 478 insertions(+) create mode 100644 ruoyi-fastapi-backend/module_admin/controller/explanation_content_controller.py create mode 100644 ruoyi-fastapi-backend/module_admin/dao/explanation_content_dao.py create mode 100644 ruoyi-fastapi-backend/module_admin/entity/do/explanation_content_do.py create mode 100644 ruoyi-fastapi-backend/module_admin/entity/vo/explanation_content_vo.py create mode 100644 ruoyi-fastapi-backend/module_admin/service/explanation_content_service.py diff --git a/ruoyi-fastapi-backend/module_admin/controller/explanation_content_controller.py b/ruoyi-fastapi-backend/module_admin/controller/explanation_content_controller.py new file mode 100644 index 0000000..71e034a --- /dev/null +++ b/ruoyi-fastapi-backend/module_admin/controller/explanation_content_controller.py @@ -0,0 +1,115 @@ +from datetime import datetime +from fastapi import APIRouter, Depends, Form, Request +from pydantic_validation_decorator import ValidateFields +from sqlalchemy.ext.asyncio import AsyncSession +from config.enums import BusinessType +from config.get_db import get_db +from module_admin.annotation.log_annotation import Log +from module_admin.aspect.interface_auth import CheckUserInterfaceAuth +from module_admin.entity.vo.user_vo import CurrentUserModel +from module_admin.service.login_service import LoginService +from module_admin.service.explanation_content_service import Explanation_contentService +from module_admin.entity.vo.explanation_content_vo import DeleteExplanation_contentModel, Explanation_contentModel, Explanation_contentPageQueryModel +from utils.common_util import bytes2file_response +from utils.log_util import logger +from utils.page_util import PageResponseModel +from utils.response_util import ResponseUtil + + +explanation_contentController = APIRouter(prefix='/system/explanation_content', dependencies=[Depends(LoginService.get_current_user)]) + + +@explanation_contentController.get( + '/list', response_model=PageResponseModel + # , dependencies=[Depends(CheckUserInterfaceAuth('system:explanation_content:list'))] +) +async def get_system_explanation_content_list( + request: Request, +explanation_content_page_query: Explanation_contentPageQueryModel = Depends(Explanation_contentPageQueryModel.as_query), + query_db: AsyncSession = Depends(get_db), +): + # 获取分页数据 + explanation_content_page_query_result = await Explanation_contentService.get_explanation_content_list_services(query_db, explanation_content_page_query, is_page=True) + logger.info('获取成功') + + return ResponseUtil.success(model_content=explanation_content_page_query_result) + + +@explanation_contentController.post('' + # , dependencies=[Depends(CheckUserInterfaceAuth('system:explanation_content:add'))] + ) +@ValidateFields(validate_model='add_explanation_content') +@Log(title='讲解内容', business_type=BusinessType.INSERT) +async def add_system_explanation_content( + request: Request, + add_explanation_content: Explanation_contentModel, + query_db: AsyncSession = Depends(get_db), + current_user: CurrentUserModel = Depends(LoginService.get_current_user), +): + add_explanation_content.create_time = datetime.now() + add_explanation_content.create_by = current_user.user.user_name + add_explanation_content.update_time = datetime.now() + add_explanation_content.update_by = current_user.user.user_name + add_explanation_content_result = await Explanation_contentService.add_explanation_content_services(query_db, add_explanation_content) + logger.info(add_explanation_content_result.message) + + return ResponseUtil.success(msg=add_explanation_content_result.message) + + +@explanation_contentController.put('' + # , dependencies=[Depends(CheckUserInterfaceAuth('system:explanation_content:edit'))] + ) +@ValidateFields(validate_model='edit_explanation_content') +@Log(title='讲解内容', business_type=BusinessType.UPDATE) +async def edit_system_explanation_content( + request: Request, + edit_explanation_content: Explanation_contentModel, + query_db: AsyncSession = Depends(get_db), + current_user: CurrentUserModel = Depends(LoginService.get_current_user), +): + edit_explanation_content.update_by = current_user.user.user_name + edit_explanation_content.update_time = datetime.now() + edit_explanation_content_result = await Explanation_contentService.edit_explanation_content_services(query_db, edit_explanation_content) + logger.info(edit_explanation_content_result.message) + + return ResponseUtil.success(msg=edit_explanation_content_result.message) + + +@explanation_contentController.delete('/{explanation_content_ids}' + # , dependencies=[Depends(CheckUserInterfaceAuth('system:explanation_content:remove'))] + ) +@Log(title='讲解内容', business_type=BusinessType.DELETE) +async def delete_system_explanation_content(request: Request, explanation_content_ids: str, query_db: AsyncSession = Depends(get_db)): + delete_explanation_content = DeleteExplanation_contentModel(explanationContentIds=explanation_content_ids) + delete_explanation_content_result = await Explanation_contentService.delete_explanation_content_services(query_db, delete_explanation_content) + logger.info(delete_explanation_content_result.message) + + return ResponseUtil.success(msg=delete_explanation_content_result.message) + + +@explanation_contentController.get( + '/{explanation_content_id}', response_model=Explanation_contentModel + # , dependencies=[Depends(CheckUserInterfaceAuth('system:explanation_content:query'))] +) +async def query_detail_system_explanation_content(request: Request, explanation_content_id: int, query_db: AsyncSession = Depends(get_db)): + explanation_content_detail_result = await Explanation_contentService.explanation_content_detail_services(query_db, explanation_content_id) + logger.info(f'获取explanation_content_id为{explanation_content_id}的信息成功') + + return ResponseUtil.success(data=explanation_content_detail_result) + + +# @explanation_contentController.post('/export' +# # , dependencies=[Depends(CheckUserInterfaceAuth('system:explanation_content:export'))] +# ) +# @Log(title='讲解内容', business_type=BusinessType.EXPORT) +# async def export_system_explanation_content_list( +# request: Request, +# explanation_content_page_query: Explanation_contentPageQueryModel = Form(), +# query_db: AsyncSession = Depends(get_db), +# ): +# # 获取全量数据 +# explanation_content_query_result = await Explanation_contentService.get_explanation_content_list_services(query_db, explanation_content_page_query, is_page=False) +# explanation_content_export_result = await Explanation_contentService.export_explanation_content_list_services(explanation_content_query_result) +# logger.info('导出成功') +# +# return ResponseUtil.streaming(data=bytes2file_response(explanation_content_export_result)) diff --git a/ruoyi-fastapi-backend/module_admin/dao/explanation_content_dao.py b/ruoyi-fastapi-backend/module_admin/dao/explanation_content_dao.py new file mode 100644 index 0000000..951ca4c --- /dev/null +++ b/ruoyi-fastapi-backend/module_admin/dao/explanation_content_dao.py @@ -0,0 +1,135 @@ +from datetime import datetime, time +from sqlalchemy import delete, select, update +from sqlalchemy.ext.asyncio import AsyncSession +from module_admin.entity.do.explanation_content_do import ExplanationContent +from module_admin.entity.vo.explanation_content_vo import Explanation_contentModel, Explanation_contentPageQueryModel +from utils.page_util import PageUtil + + +class Explanation_contentDao: + """ + 讲解内容模块数据库操作层 + """ + + @classmethod + async def get_explanation_content_detail_by_id(cls, db: AsyncSession, explanation_content_id: int): + """ + 根据主键ID获取讲解内容详细信息 + + :param db: orm对象 + :param explanation_content_id: 主键ID + :return: 讲解内容信息对象 + """ + explanation_content_info = ( + ( + await db.execute( + select(ExplanationContent) + .where( + ExplanationContent.explanation_content_id == explanation_content_id + ) + ) + ) + .scalars() + .first() + ) + + return explanation_content_info + + @classmethod + async def get_explanation_content_detail_by_info(cls, db: AsyncSession, explanation_content: Explanation_contentModel): + """ + 根据讲解内容参数获取讲解内容信息 + + :param db: orm对象 + :param explanation_content: 讲解内容参数对象 + :return: 讲解内容信息对象 + """ + explanation_content_info = ( + ( + await db.execute( + select(ExplanationContent).where( + ) + ) + ) + .scalars() + .first() + ) + + return explanation_content_info + + @classmethod + async def get_explanation_content_list(cls, db: AsyncSession, query_object: Explanation_contentPageQueryModel, is_page: bool = False): + """ + 根据查询参数获取讲解内容列表信息 + + :param db: orm对象 + :param query_object: 查询参数对象 + :param is_page: 是否开启分页 + :return: 讲解内容列表信息对象 + """ + query = ( + select(ExplanationContent) + .where( + ExplanationContent.title == query_object.title if query_object.title else True, + ExplanationContent.content == query_object.content if query_object.content else True, + ExplanationContent.type == query_object.type if query_object.type else True, + ExplanationContent.spend_time == query_object.spend_time if query_object.spend_time else True, + ExplanationContent.language == query_object.language if query_object.language else True, + ExplanationContent.status == query_object.status if query_object.status else True, + ExplanationContent.create_time.between( + datetime.combine(datetime.strptime(query_object.begin_create_time, '%Y-%m-%d'), time(00, 00, 00)), + datetime.combine(datetime.strptime(query_object.end_create_time, '%Y-%m-%d'), time(23, 59, 59)), + ) + if query_object.begin_create_time and query_object.end_create_time + else True, + ExplanationContent.update_time.between( + datetime.combine(datetime.strptime(query_object.begin_update_time, '%Y-%m-%d'), time(00, 00, 00)), + datetime.combine(datetime.strptime(query_object.end_update_time, '%Y-%m-%d'), time(23, 59, 59)), + ) + if query_object.begin_update_time and query_object.end_update_time + else True, + ) + .order_by(ExplanationContent.explanation_content_id) + .distinct() + ) + explanation_content_list = await PageUtil.paginate(db, query, query_object.page_num, query_object.page_size, is_page) + + return explanation_content_list + + @classmethod + async def add_explanation_content_dao(cls, db: AsyncSession, explanation_content: Explanation_contentModel): + """ + 新增讲解内容数据库操作 + + :param db: orm对象 + :param explanation_content: 讲解内容对象 + :return: + """ + db_explanation_content = ExplanationContent(**explanation_content.model_dump(exclude={})) + db.add(db_explanation_content) + await db.flush() + + return db_explanation_content + + @classmethod + async def edit_explanation_content_dao(cls, db: AsyncSession, explanation_content: dict): + """ + 编辑讲解内容数据库操作 + + :param db: orm对象 + :param explanation_content: 需要更新的讲解内容字典 + :return: + """ + await db.execute(update(ExplanationContent), [explanation_content]) + + @classmethod + async def delete_explanation_content_dao(cls, db: AsyncSession, explanation_content: Explanation_contentModel): + """ + 删除讲解内容数据库操作 + + :param db: orm对象 + :param explanation_content: 讲解内容对象 + :return: + """ + await db.execute(delete(ExplanationContent).where(ExplanationContent.explanation_content_id.in_([explanation_content.explanation_content_id]))) + diff --git a/ruoyi-fastapi-backend/module_admin/entity/do/explanation_content_do.py b/ruoyi-fastapi-backend/module_admin/entity/do/explanation_content_do.py new file mode 100644 index 0000000..6eb29dc --- /dev/null +++ b/ruoyi-fastapi-backend/module_admin/entity/do/explanation_content_do.py @@ -0,0 +1,25 @@ +from sqlalchemy import Column, Text, DateTime, String, BigInteger, Integer +from config.database import Base + + +class ExplanationContent(Base): + """ + 讲解内容表 + """ + + __tablename__ = 'explanation_content' + + explanation_content_id = Column(BigInteger, primary_key=True, autoincrement=True, nullable=False, comment='主键ID') + title = Column(String(64), nullable=False, comment='标题') + content = Column(Text, nullable=True, comment='讲解内容') + type = Column(String(2), nullable=True, comment='类型(0科技类)') + spend_time = Column(Integer, nullable=True, comment='预计时长(分钟)') + language = Column(String(2), nullable=True, comment='语言(0中文,1英文)') + status = Column(String(2), nullable=True, comment='状态(0未开始,1已就绪,2播放中,3已完成)') + create_time = Column(DateTime, nullable=True, comment='创建时间') + create_by = Column(String(64), nullable=True, comment='创建者') + update_time = Column(DateTime, nullable=True, comment='修改时间') + update_by = Column(String(64), nullable=True, comment='修改者') + + + diff --git a/ruoyi-fastapi-backend/module_admin/entity/vo/explanation_content_vo.py b/ruoyi-fastapi-backend/module_admin/entity/vo/explanation_content_vo.py new file mode 100644 index 0000000..d552d35 --- /dev/null +++ b/ruoyi-fastapi-backend/module_admin/entity/vo/explanation_content_vo.py @@ -0,0 +1,67 @@ +from datetime import datetime +from pydantic import BaseModel, ConfigDict, Field +from pydantic.alias_generators import to_camel +from pydantic_validation_decorator import NotBlank +from typing import Optional +from module_admin.annotation.pydantic_annotation import as_query + + + + +class Explanation_contentModel(BaseModel): + """ + 讲解内容表对应pydantic模型 + """ + model_config = ConfigDict(alias_generator=to_camel, from_attributes=True) + + explanation_content_id: Optional[int] = Field(default=None, description='主键ID') + title: Optional[str] = Field(default=None, description='标题') + content: Optional[str] = Field(default=None, description='讲解内容') + type: Optional[str] = Field(default=None, description='类型(0科技类)') + spend_time: Optional[int] = Field(default=None, description='预计时长(分钟)') + language: Optional[str] = Field(default=None, description='语言(0中文,1英文)') + status: Optional[str] = Field(default=None, description='状态(0未开始,1已就绪,2播放中,3已完成)') + create_time: Optional[datetime] = Field(default=None, description='创建时间') + create_by: Optional[str] = Field(default=None, description='创建者') + update_time: Optional[datetime] = Field(default=None, description='修改时间') + update_by: Optional[str] = Field(default=None, description='修改者') + + @NotBlank(field_name='title', message='标题不能为空') + def get_title(self): + return self.title + + + def validate_fields(self): + self.get_title() + + + + +class Explanation_contentQueryModel(Explanation_contentModel): + """ + 讲解内容不分页查询模型 + """ + begin_create_time: Optional[str] = Field(default=None, description='开始创建时间') + end_create_time: Optional[str] = Field(default=None, description='结束创建时间') + begin_update_time: Optional[str] = Field(default=None, description='开始修改时间') + end_update_time: Optional[str] = Field(default=None, description='结束修改时间') + + +@as_query +class Explanation_contentPageQueryModel(Explanation_contentQueryModel): + """ + 讲解内容分页查询模型 + """ + + page_num: int = Field(default=1, description='当前页码') + page_size: int = Field(default=10, description='每页记录数') + + +class DeleteExplanation_contentModel(BaseModel): + """ + 删除讲解内容模型 + """ + + model_config = ConfigDict(alias_generator=to_camel) + + explanation_content_ids: str = Field(description='需要删除的主键ID') diff --git a/ruoyi-fastapi-backend/module_admin/service/explanation_content_service.py b/ruoyi-fastapi-backend/module_admin/service/explanation_content_service.py new file mode 100644 index 0000000..70c250d --- /dev/null +++ b/ruoyi-fastapi-backend/module_admin/service/explanation_content_service.py @@ -0,0 +1,136 @@ +from sqlalchemy.ext.asyncio import AsyncSession +from typing import List +from config.constant import CommonConstant +from exceptions.exception import ServiceException +from module_admin.entity.vo.common_vo import CrudResponseModel +from module_admin.dao.explanation_content_dao import Explanation_contentDao +from module_admin.entity.vo.explanation_content_vo import DeleteExplanation_contentModel, Explanation_contentModel, Explanation_contentPageQueryModel +from utils.common_util import CamelCaseUtil +from utils.excel_util import ExcelUtil + + +class Explanation_contentService: + """ + 讲解内容模块服务层 + """ + + @classmethod + async def get_explanation_content_list_services( + cls, query_db: AsyncSession, query_object: Explanation_contentPageQueryModel, is_page: bool = False + ): + """ + 获取讲解内容列表信息service + + :param query_db: orm对象 + :param query_object: 查询参数对象 + :param is_page: 是否开启分页 + :return: 讲解内容列表信息对象 + """ + explanation_content_list_result = await Explanation_contentDao.get_explanation_content_list(query_db, query_object, is_page) + + return explanation_content_list_result + + + @classmethod + async def add_explanation_content_services(cls, query_db: AsyncSession, page_object: Explanation_contentModel): + """ + 新增讲解内容信息service + + :param query_db: orm对象 + :param page_object: 新增讲解内容对象 + :return: 新增讲解内容校验结果 + """ + try: + await Explanation_contentDao.add_explanation_content_dao(query_db, page_object) + await query_db.commit() + return CrudResponseModel(is_success=True, message='新增成功') + except Exception as e: + await query_db.rollback() + raise e + + @classmethod + async def edit_explanation_content_services(cls, query_db: AsyncSession, page_object: Explanation_contentModel): + """ + 编辑讲解内容信息service + + :param query_db: orm对象 + :param page_object: 编辑讲解内容对象 + :return: 编辑讲解内容校验结果 + """ + edit_explanation_content = page_object.model_dump(exclude_unset=True, exclude={'create_time', 'create_by', }) + explanation_content_info = await cls.explanation_content_detail_services(query_db, page_object.explanation_content_id) + if explanation_content_info.explanation_content_id: + try: + await Explanation_contentDao.edit_explanation_content_dao(query_db, edit_explanation_content) + await query_db.commit() + return CrudResponseModel(is_success=True, message='更新成功') + except Exception as e: + await query_db.rollback() + raise e + else: + raise ServiceException(message='讲解内容不存在') + + @classmethod + async def delete_explanation_content_services(cls, query_db: AsyncSession, page_object: DeleteExplanation_contentModel): + """ + 删除讲解内容信息service + + :param query_db: orm对象 + :param page_object: 删除讲解内容对象 + :return: 删除讲解内容校验结果 + """ + if page_object.explanation_content_ids: + explanation_content_id_list = page_object.explanation_content_ids.split(',') + try: + for explanation_content_id in explanation_content_id_list: + await Explanation_contentDao.delete_explanation_content_dao(query_db, Explanation_contentModel(explanationContentId=explanation_content_id)) + await query_db.commit() + return CrudResponseModel(is_success=True, message='删除成功') + except Exception as e: + await query_db.rollback() + raise e + else: + raise ServiceException(message='传入主键ID为空') + + @classmethod + async def explanation_content_detail_services(cls, query_db: AsyncSession, explanation_content_id: int): + """ + 获取讲解内容详细信息service + + :param query_db: orm对象 + :param explanation_content_id: 主键ID + :return: 主键ID对应的信息 + """ + explanation_content = await Explanation_contentDao.get_explanation_content_detail_by_id(query_db, explanation_content_id=explanation_content_id) + if explanation_content: + result = Explanation_contentModel(**CamelCaseUtil.transform_result(explanation_content)) + else: + result = Explanation_contentModel(**dict()) + + return result + + @staticmethod + async def export_explanation_content_list_services(explanation_content_list: List): + """ + 导出讲解内容信息service + + :param explanation_content_list: 讲解内容信息列表 + :return: 讲解内容信息对应excel的二进制数据 + """ + # 创建一个映射字典，将英文键映射到中文键 + mapping_dict = { + 'explanationContentId': '主键ID', + 'title': '标题', + 'content': '讲解内容', + 'type': '类型(0科技类)', + 'spendTime': '预计时长(分钟)', + 'language': '语言(0中文,1英文)', + 'status': '状态(0未开始,1已就绪,2播放中,3已完成)', + 'createTime': '创建时间', + 'createBy': '创建者', + 'updateTime': '修改时间', + 'updateBy': '修改者', + } + binary_data = ExcelUtil.export_list2excel(explanation_content_list, mapping_dict) + + return binary_data