1.实现新增消息接口

This commit is contained in:
haotian 2025-07-30 10:37:33 +08:00
parent b9ea308be1
commit 7f4aa185c5
3 changed files with 33 additions and 28 deletions

View File

@ -35,7 +35,8 @@ message_page_query: MessagePageQueryModel = Depends(MessagePageQueryModel.as_que
return ResponseUtil.success(model_content=message_page_query_result)
@messageController.post(''
# 该接口只做测试用, 并不对外开放
@messageController.post('/add_message'
# , dependencies=[Depends(CheckUserInterfaceAuth('system:message:add'))]
)
@ValidateFields(validate_model='add_message')
@ -50,6 +51,7 @@ async def add_system_message(
add_message.create_by = current_user.user.user_name
add_message.update_time = datetime.now()
add_message.update_by = current_user.user.user_name
add_message.status = '0'
add_message_result = await MessageService.add_message_services(query_db, add_message)
logger.info(add_message_result.message)

View File

@ -23,32 +23,32 @@ class MessageModel(BaseModel):
update_time: Optional[datetime] = Field(default=None, description='更新时间')
update_by: Optional[str] = Field(default=None, description='更新者')
@NotBlank(field_name='type', message='类型不能为空')
def get_type(self):
return self.type
@NotBlank(field_name='status', message='状态不能为空')
def get_status(self):
return self.status
@NotBlank(field_name='create_time', message='创建时间不能为空')
def get_create_time(self):
return self.create_time
@NotBlank(field_name='update_time', message='更新时间不能为空')
def get_update_time(self):
return self.update_time
@NotBlank(field_name='update_by', message='更新者不能为空')
def get_update_by(self):
return self.update_by
def validate_fields(self):
self.get_type()
self.get_status()
self.get_create_time()
self.get_update_time()
self.get_update_by()
# @NotBlank(field_name='type', message='类型不能为空')
# def get_type(self):
# return self.type
#
# @NotBlank(field_name='status', message='状态不能为空')
# def get_status(self):
# return self.status
#
# @NotBlank(field_name='create_time', message='创建时间不能为空')
# def get_create_time(self):
# return self.create_time
#
# @NotBlank(field_name='update_time', message='更新时间不能为空')
# def get_update_time(self):
# return self.update_time
#
# @NotBlank(field_name='update_by', message='更新者不能为空')
# def get_update_by(self):
# return self.update_by
#
# def validate_fields(self):
# self.get_type()
# self.get_status()
# self.get_create_time()
# self.get_update_time()
# self.get_update_by()

View File

@ -26,6 +26,7 @@ from module_admin.controller.test_controller import testController
from module_admin.controller.words_controller import wordsController
from module_admin.controller.info_controller import infoController
from module_generator.controller.gen_controller import genController
from module_admin.controller.message_controller import messageController
from sub_applications.handle import handle_sub_applications
from utils.common_util import worship
@ -85,7 +86,9 @@ controller_list = [
{'router': genController, 'tags': ['代码生成']},
# {'router': testController, 'tags': ['测试模块']},
{'router': wordsController, 'tags': ['引导词管理']},
{'router': infoController, 'tage':['机器人信息管理']}
{'router': infoController, 'tage':['机器人信息管理']},
{'router': messageController, 'tags': ['消息管理']},
]
for controller in controller_list: