From 4f4ee34e8dde998aa4b7d7ccd39b09d6523ef9d0 Mon Sep 17 00:00:00 2001 From: insistence <3055204202@qq.com> Date: Thu, 31 Oct 2024 15:38:58 +0800 Subject: [PATCH 1/8] =?UTF-8?q?style:=20=E4=BF=AE=E5=A4=8D=E4=B9=A6?= =?UTF-8?q?=E5=86=99=E9=94=99=E8=AF=AF?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../module_admin/service/menu_service.py | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/ruoyi-fastapi-backend/module_admin/service/menu_service.py b/ruoyi-fastapi-backend/module_admin/service/menu_service.py index 2852d6c..cb6368a 100644 --- a/ruoyi-fastapi-backend/module_admin/service/menu_service.py +++ b/ruoyi-fastapi-backend/module_admin/service/menu_service.py @@ -99,9 +99,9 @@ class MenuService: :return: 新增菜单校验结果 """ if not await cls.check_menu_name_unique_services(query_db, page_object): - raise ServiceException(message=f'新增菜单{page_object.post_name}失败，菜单名称已存在') + raise ServiceException(message=f'新增菜单{page_object.menu_name}失败，菜单名称已存在') elif page_object.is_frame == MenuConstant.YES_FRAME and not StringUtil.is_http(page_object.path): - raise ServiceException(message=f'新增菜单{page_object.post_name}失败，地址必须以http(s)://开头') + raise ServiceException(message=f'新增菜单{page_object.menu_name}失败，地址必须以http(s)://开头') else: try: await MenuDao.add_menu_dao(query_db, page_object) @@ -124,11 +124,11 @@ class MenuService: menu_info = await cls.menu_detail_services(query_db, page_object.menu_id) if menu_info.menu_id: if not await cls.check_menu_name_unique_services(query_db, page_object): - raise ServiceException(message=f'修改菜单{page_object.post_name}失败，菜单名称已存在') + raise ServiceException(message=f'修改菜单{page_object.menu_name}失败，菜单名称已存在') elif page_object.is_frame == MenuConstant.YES_FRAME and not StringUtil.is_http(page_object.path): - raise ServiceException(message=f'修改菜单{page_object.post_name}失败，地址必须以http(s)://开头') + raise ServiceException(message=f'修改菜单{page_object.menu_name}失败，地址必须以http(s)://开头') elif page_object.menu_id == page_object.parent_id: - raise ServiceException(message=f'修改菜单{page_object.post_name}失败，上级菜单不能选择自己') + raise ServiceException(message=f'修改菜单{page_object.menu_name}失败，上级菜单不能选择自己') else: try: await MenuDao.edit_menu_dao(query_db, edit_menu) From 1ddb1bd5b554ea1ab041938e9054e75f8088d6dd Mon Sep 17 00:00:00 2001 From: insistence <3055204202@qq.com> Date: Wed, 6 Nov 2024 22:28:09 +0800 Subject: [PATCH 2/8] =?UTF-8?q?feat:=20=E5=AE=9A=E6=97=B6=E4=BB=BB?= =?UTF-8?q?=E5=8A=A1=E6=96=B0=E5=A2=9E=E6=94=AF=E6=8C=81=E8=B0=83=E7=94=A8?= =?UTF-8?q?=E5=BC=82=E6=AD=A5=E5=87=BD=E6=95=B0?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- ruoyi-fastapi-backend/config/get_scheduler.py | 46 ++++++++++++++----- .../module_admin/service/job_service.py | 12 ++--- .../module_task/scheduler_test.py | 14 +++++- .../src/views/monitor/job/index.vue | 19 ++++++-- 4 files changed, 65 insertions(+), 26 deletions(-) diff --git a/ruoyi-fastapi-backend/config/get_scheduler.py b/ruoyi-fastapi-backend/config/get_scheduler.py index 0851ca5..a92a169 100644 --- a/ruoyi-fastapi-backend/config/get_scheduler.py +++ b/ruoyi-fastapi-backend/config/get_scheduler.py @@ -1,11 +1,14 @@ import json from apscheduler.events import EVENT_ALL +from apscheduler.executors.asyncio import AsyncIOExecutor from apscheduler.executors.pool import ThreadPoolExecutor, ProcessPoolExecutor -from apscheduler.schedulers.background import BackgroundScheduler from apscheduler.jobstores.memory import MemoryJobStore from apscheduler.jobstores.redis import RedisJobStore from apscheduler.jobstores.sqlalchemy import SQLAlchemyJobStore +from apscheduler.schedulers.asyncio import AsyncIOScheduler +from apscheduler.schedulers.background import BackgroundScheduler from apscheduler.triggers.cron import CronTrigger +from asyncio import iscoroutinefunction from datetime import datetime, timedelta from sqlalchemy.engine import create_engine from sqlalchemy.orm import sessionmaker @@ -109,9 +112,12 @@ job_stores = { ) ), } +async_executors = {'default': AsyncIOExecutor()} executors = {'default': ThreadPoolExecutor(20), 'processpool': ProcessPoolExecutor(5)} job_defaults = {'coalesce': False, 'max_instance': 1} +async_scheduler = AsyncIOScheduler() scheduler = BackgroundScheduler() +async_scheduler.configure(jobstores=job_stores, executors=async_executors, job_defaults=job_defaults) scheduler.configure(jobstores=job_stores, executors=executors, job_defaults=job_defaults) @@ -129,14 +135,14 @@ class SchedulerUtil: """ logger.info('开始启动定时任务...') scheduler.start() + async_scheduler.start() async with AsyncSessionLocal() as session: job_list = await JobDao.get_job_list_for_scheduler(session) for item in job_list: - query_job = cls.get_scheduler_job(job_id=str(item.job_id)) - if query_job: - cls.remove_scheduler_job(job_id=str(item.job_id)) + cls.remove_scheduler_job(job_id=str(item.job_id)) cls.add_scheduler_job(item) scheduler.add_listener(cls.scheduler_event_listener, EVENT_ALL) + async_scheduler.add_listener(cls.scheduler_event_listener, EVENT_ALL) logger.info('系统初始定时任务加载成功') @classmethod @@ -147,6 +153,7 @@ class SchedulerUtil: :return: """ scheduler.shutdown() + async_scheduler.shutdown() logger.info('关闭定时任务成功') @classmethod @@ -157,7 +164,7 @@ class SchedulerUtil: :param job_id: 任务id :return: 任务对象 """ - query_job = scheduler.get_job(job_id=str(job_id)) + query_job = scheduler.get_job(job_id=str(job_id)) or async_scheduler.get_job(job_id=str(job_id)) return query_job @@ -169,8 +176,9 @@ class SchedulerUtil: :param job_info: 任务对象信息 :return: """ - scheduler.add_job( - func=eval(job_info.invoke_target), + job_func = eval(job_info.invoke_target) + job_param = dict( + func=job_func, trigger=MyCronTrigger.from_crontab(job_info.cron_expression), args=job_info.job_args.split(',') if job_info.job_args else None, kwargs=json.loads(job_info.job_kwargs) if job_info.job_kwargs else None, @@ -180,8 +188,11 @@ class SchedulerUtil: coalesce=True if job_info.misfire_policy == '2' else False, max_instances=3 if job_info.concurrent == '0' else 1, jobstore=job_info.job_group, - executor=job_info.job_executor, ) + if iscoroutinefunction(job_func): + async_scheduler.add_job(**job_param) + else: + scheduler.add_job(executor=job_info.job_executor, **job_param) @classmethod def execute_scheduler_job_once(cls, job_info: JobModel): @@ -191,8 +202,9 @@ class SchedulerUtil: :param job_info: 任务对象信息 :return: """ - scheduler.add_job( - func=eval(job_info.invoke_target), + job_func = eval(job_info.invoke_target) + job_param = dict( + func=job_func, trigger='date', run_date=datetime.now() + timedelta(seconds=1), args=job_info.job_args.split(',') if job_info.job_args else None, @@ -203,8 +215,11 @@ class SchedulerUtil: coalesce=True if job_info.misfire_policy == '2' else False, max_instances=3 if job_info.concurrent == '0' else 1, jobstore=job_info.job_group, - executor=job_info.job_executor, ) + if iscoroutinefunction(job_func): + async_scheduler.add_job(**job_param) + else: + scheduler.add_job(executor=job_info.job_executor, **job_param) @classmethod def remove_scheduler_job(cls, job_id: Union[str, int]): @@ -214,7 +229,14 @@ class SchedulerUtil: :param job_id: 任务id :return: """ - scheduler.remove_job(job_id=str(job_id)) + query_job = cls.get_scheduler_job(job_id=job_id) + if query_job: + query_job_info = query_job.__getstate__() + job_func = eval(query_job_info.get('func').replace(':', '.')) + if iscoroutinefunction(job_func): + async_scheduler.remove_job(job_id=str(job_id)) + else: + scheduler.remove_job(job_id=str(job_id)) @classmethod def scheduler_event_listener(cls, event): diff --git a/ruoyi-fastapi-backend/module_admin/service/job_service.py b/ruoyi-fastapi-backend/module_admin/service/job_service.py index 2c4c5bb..2d06b6f 100644 --- a/ruoyi-fastapi-backend/module_admin/service/job_service.py +++ b/ruoyi-fastapi-backend/module_admin/service/job_service.py @@ -129,9 +129,7 @@ class JobService: raise ServiceException(message=f'修改定时任务{page_object.job_name}失败，定时任务已存在') try: await JobDao.edit_job_dao(query_db, edit_job) - query_job = SchedulerUtil.get_scheduler_job(job_id=edit_job.get('job_id')) - if query_job: - SchedulerUtil.remove_scheduler_job(job_id=edit_job.get('job_id')) + SchedulerUtil.remove_scheduler_job(job_id=edit_job.get('job_id')) if edit_job.get('status') == '0': job_info = await cls.job_detail_services(query_db, edit_job.get('job_id')) SchedulerUtil.add_scheduler_job(job_info=job_info) @@ -152,9 +150,7 @@ class JobService: :param page_object: 定时任务对象 :return: 执行一次定时任务结果 """ - query_job = SchedulerUtil.get_scheduler_job(job_id=page_object.job_id) - if query_job: - SchedulerUtil.remove_scheduler_job(job_id=page_object.job_id) + SchedulerUtil.remove_scheduler_job(job_id=page_object.job_id) job_info = await cls.job_detail_services(query_db, page_object.job_id) if job_info: SchedulerUtil.execute_scheduler_job_once(job_info=job_info) @@ -176,9 +172,7 @@ class JobService: try: for job_id in job_id_list: await JobDao.delete_job_dao(query_db, JobModel(jobId=job_id)) - query_job = SchedulerUtil.get_scheduler_job(job_id=job_id) - if query_job: - SchedulerUtil.remove_scheduler_job(job_id=job_id) + SchedulerUtil.remove_scheduler_job(job_id=job_id) await query_db.commit() return CrudResponseModel(is_success=True, message='删除成功') except Exception as e: diff --git a/ruoyi-fastapi-backend/module_task/scheduler_test.py b/ruoyi-fastapi-backend/module_task/scheduler_test.py index 1c8441f..b282732 100644 --- a/ruoyi-fastapi-backend/module_task/scheduler_test.py +++ b/ruoyi-fastapi-backend/module_task/scheduler_test.py @@ -2,6 +2,18 @@ from datetime import datetime def job(*args, **kwargs): + """ + 定时任务执行同步函数示例 + """ print(args) print(kwargs) - print(f'{datetime.now()}执行了') + print(f'{datetime.now()}同步函数执行了') + + +async def async_job(*args, **kwargs): + """ + 定时任务执行异步函数示例 + """ + print(args) + print(kwargs) + print(f'{datetime.now()}异步函数执行了') diff --git a/ruoyi-fastapi-frontend/src/views/monitor/job/index.vue b/ruoyi-fastapi-frontend/src/views/monitor/job/index.vue index 92038a9..3192eac 100644 --- a/ruoyi-fastapi-frontend/src/views/monitor/job/index.vue +++ b/ruoyi-fastapi-frontend/src/views/monitor/job/index.vue @@ -159,7 +159,20 @@ - + + From a1937448d6d3e76d4daa9f5e428349a805afaa73 Mon Sep 17 00:00:00 2001 From: insistence <3055204202@qq.com> Date: Thu, 7 Nov 2024 10:01:49 +0800 Subject: [PATCH 3/8] =?UTF-8?q?refactor:=20=E5=AE=9A=E6=97=B6=E4=BB=BB?= =?UTF-8?q?=E5=8A=A1=E6=94=B9=E7=94=A8AsyncIOScheduler=E5=92=8CAsyncIOExec?= =?UTF-8?q?utor?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- ruoyi-fastapi-backend/config/get_scheduler.py | 46 +++++++------------ 1 file changed, 17 insertions(+), 29 deletions(-) diff --git a/ruoyi-fastapi-backend/config/get_scheduler.py b/ruoyi-fastapi-backend/config/get_scheduler.py index a92a169..2c9457b 100644 --- a/ruoyi-fastapi-backend/config/get_scheduler.py +++ b/ruoyi-fastapi-backend/config/get_scheduler.py @@ -1,12 +1,11 @@ import json from apscheduler.events import EVENT_ALL from apscheduler.executors.asyncio import AsyncIOExecutor -from apscheduler.executors.pool import ThreadPoolExecutor, ProcessPoolExecutor +from apscheduler.executors.pool import ProcessPoolExecutor from apscheduler.jobstores.memory import MemoryJobStore from apscheduler.jobstores.redis import RedisJobStore from apscheduler.jobstores.sqlalchemy import SQLAlchemyJobStore from apscheduler.schedulers.asyncio import AsyncIOScheduler -from apscheduler.schedulers.background import BackgroundScheduler from apscheduler.triggers.cron import CronTrigger from asyncio import iscoroutinefunction from datetime import datetime, timedelta @@ -112,12 +111,9 @@ job_stores = { ) ), } -async_executors = {'default': AsyncIOExecutor()} -executors = {'default': ThreadPoolExecutor(20), 'processpool': ProcessPoolExecutor(5)} +executors = {'default': AsyncIOExecutor(), 'processpool': ProcessPoolExecutor(5)} job_defaults = {'coalesce': False, 'max_instance': 1} -async_scheduler = AsyncIOScheduler() -scheduler = BackgroundScheduler() -async_scheduler.configure(jobstores=job_stores, executors=async_executors, job_defaults=job_defaults) +scheduler = AsyncIOScheduler() scheduler.configure(jobstores=job_stores, executors=executors, job_defaults=job_defaults) @@ -135,14 +131,12 @@ class SchedulerUtil: """ logger.info('开始启动定时任务...') scheduler.start() - async_scheduler.start() async with AsyncSessionLocal() as session: job_list = await JobDao.get_job_list_for_scheduler(session) for item in job_list: cls.remove_scheduler_job(job_id=str(item.job_id)) cls.add_scheduler_job(item) scheduler.add_listener(cls.scheduler_event_listener, EVENT_ALL) - async_scheduler.add_listener(cls.scheduler_event_listener, EVENT_ALL) logger.info('系统初始定时任务加载成功') @classmethod @@ -153,7 +147,6 @@ class SchedulerUtil: :return: """ scheduler.shutdown() - async_scheduler.shutdown() logger.info('关闭定时任务成功') @classmethod @@ -164,7 +157,7 @@ class SchedulerUtil: :param job_id: 任务id :return: 任务对象 """ - query_job = scheduler.get_job(job_id=str(job_id)) or async_scheduler.get_job(job_id=str(job_id)) + query_job = scheduler.get_job(job_id=str(job_id)) return query_job @@ -177,8 +170,11 @@ class SchedulerUtil: :return: """ job_func = eval(job_info.invoke_target) - job_param = dict( - func=job_func, + job_executor = job_info.job_executor + if iscoroutinefunction(job_func): + job_executor = 'default' + scheduler.add_job( + func=eval(job_info.invoke_target), trigger=MyCronTrigger.from_crontab(job_info.cron_expression), args=job_info.job_args.split(',') if job_info.job_args else None, kwargs=json.loads(job_info.job_kwargs) if job_info.job_kwargs else None, @@ -188,11 +184,8 @@ class SchedulerUtil: coalesce=True if job_info.misfire_policy == '2' else False, max_instances=3 if job_info.concurrent == '0' else 1, jobstore=job_info.job_group, + executor=job_executor, ) - if iscoroutinefunction(job_func): - async_scheduler.add_job(**job_param) - else: - scheduler.add_job(executor=job_info.job_executor, **job_param) @classmethod def execute_scheduler_job_once(cls, job_info: JobModel): @@ -203,8 +196,11 @@ class SchedulerUtil: :return: """ job_func = eval(job_info.invoke_target) - job_param = dict( - func=job_func, + job_executor = job_info.job_executor + if iscoroutinefunction(job_func): + job_executor = 'default' + scheduler.add_job( + func=eval(job_info.invoke_target), trigger='date', run_date=datetime.now() + timedelta(seconds=1), args=job_info.job_args.split(',') if job_info.job_args else None, @@ -215,11 +211,8 @@ class SchedulerUtil: coalesce=True if job_info.misfire_policy == '2' else False, max_instances=3 if job_info.concurrent == '0' else 1, jobstore=job_info.job_group, + executor=job_executor, ) - if iscoroutinefunction(job_func): - async_scheduler.add_job(**job_param) - else: - scheduler.add_job(executor=job_info.job_executor, **job_param) @classmethod def remove_scheduler_job(cls, job_id: Union[str, int]): @@ -231,12 +224,7 @@ class SchedulerUtil: """ query_job = cls.get_scheduler_job(job_id=job_id) if query_job: - query_job_info = query_job.__getstate__() - job_func = eval(query_job_info.get('func').replace(':', '.')) - if iscoroutinefunction(job_func): - async_scheduler.remove_job(job_id=str(job_id)) - else: - scheduler.remove_job(job_id=str(job_id)) + scheduler.remove_job(job_id=str(job_id)) @classmethod def scheduler_event_listener(cls, event): From 564d470240312d2e3f4567dd198879947f895997 Mon Sep 17 00:00:00 2001 From: insistence <3055204202@qq.com> Date: Fri, 8 Nov 2024 17:06:21 +0800 Subject: [PATCH 4/8] =?UTF-8?q?perf:=20=E4=BC=98=E5=8C=96=E5=AD=97?= =?UTF-8?q?=E5=85=B8=E6=95=B0=E7=BB=84=E6=9D=A1=E4=BB=B6=E5=88=A4=E6=96=AD?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- ruoyi-fastapi-frontend/src/components/DictTag/index.vue | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/ruoyi-fastapi-frontend/src/components/DictTag/index.vue b/ruoyi-fastapi-frontend/src/components/DictTag/index.vue index 2e55053..19e24e4 100644 --- a/ruoyi-fastapi-frontend/src/components/DictTag/index.vue +++ b/ruoyi-fastapi-frontend/src/components/DictTag/index.vue @@ -55,7 +55,7 @@ const values = computed(() => { const unmatch = computed(() => { unmatchArray.value = []; // 没有value不显示 - if (props.value === null || typeof props.value === 'undefined' || props.value === '' || props.options.length === 0) return false + if (props.value === null || typeof props.value === 'undefined' || props.value === '' || !Array.isArray(props.options) || props.options.length === 0) return false // 传入值为数组 let unmatch = false // 添加一个标志来判断是否有未匹配项 values.value.forEach(item => { From 425d6e00ebf0c0cce2e7e16f9ea57e6e847786f9 Mon Sep 17 00:00:00 2001 From: insistence <3055204202@qq.com> Date: Fri, 8 Nov 2024 17:10:54 +0800 Subject: [PATCH 5/8] =?UTF-8?q?perf:=20=E6=A0=A1=E6=A3=80=E6=96=87?= =?UTF-8?q?=E4=BB=B6=E5=90=8D=E6=98=AF=E5=90=A6=E5=8C=85=E5=90=AB=E7=89=B9?= =?UTF-8?q?=E6=AE=8A=E5=AD=97=E7=AC=A6?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../src/components/FileUpload/index.vue | 7 ++++++- .../src/components/ImageUpload/index.vue | 8 +++++--- 2 files changed, 11 insertions(+), 4 deletions(-) diff --git a/ruoyi-fastapi-frontend/src/components/FileUpload/index.vue b/ruoyi-fastapi-frontend/src/components/FileUpload/index.vue index 2af9672..a860a40 100644 --- a/ruoyi-fastapi-frontend/src/components/FileUpload/index.vue +++ b/ruoyi-fastapi-frontend/src/components/FileUpload/index.vue @@ -104,10 +104,15 @@ function handleBeforeUpload(file) { const fileExt = fileName[fileName.length - 1]; const isTypeOk = props.fileType.indexOf(fileExt) >= 0; if (!isTypeOk) { - proxy.$modal.msgError(`文件格式不正确, 请上传${props.fileType.join("/")}格式文件!`); + proxy.$modal.msgError(`文件格式不正确，请上传${props.fileType.join("/")}格式文件!`); return false; } } + // 校检文件名是否包含特殊字符 + if (file.name.includes(',')) { + proxy.$modal.msgError('文件名不正确，不能包含英文逗号!'); + return false; + } // 校检文件大小 if (props.fileSize) { const isLt = file.size / 1024 / 1024 < props.fileSize; diff --git a/ruoyi-fastapi-frontend/src/components/ImageUpload/index.vue b/ruoyi-fastapi-frontend/src/components/ImageUpload/index.vue index 9d0e048..4d19693 100644 --- a/ruoyi-fastapi-frontend/src/components/ImageUpload/index.vue +++ b/ruoyi-fastapi-frontend/src/components/ImageUpload/index.vue @@ -125,9 +125,11 @@ function handleBeforeUpload(file) { isImg = file.type.indexOf("image") > -1; } if (!isImg) { - proxy.$modal.msgError( - `文件格式不正确, 请上传${props.fileType.join("/")}图片格式文件!` - ); + proxy.$modal.msgError(`文件格式不正确，请上传${props.fileType.join("/")}图片格式文件!`); + return false; + } + if (file.name.includes(',')) { + proxy.$modal.msgError('文件名不正确，不能包含英文逗号!'); return false; } if (props.fileSize) { From c282f362f49383ae5fec255a3ce2e7af4dbf0f00 Mon Sep 17 00:00:00 2001 From: insistence <3055204202@qq.com> Date: Tue, 12 Nov 2024 15:10:17 +0800 Subject: [PATCH 6/8] =?UTF-8?q?perf:=20=E7=A7=BB=E9=99=A4=E5=B7=B2?= =?UTF-8?q?=E5=BC=83=E7=94=A8=E7=9A=84log=5Fdecorator=E8=A3=85=E9=A5=B0?= =?UTF-8?q?=E5=99=A8?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../module_admin/annotation/log_annotation.py | 191 +----------------- 1 file changed, 4 insertions(+), 187 deletions(-) diff --git a/ruoyi-fastapi-backend/module_admin/annotation/log_annotation.py b/ruoyi-fastapi-backend/module_admin/annotation/log_annotation.py index 952dfb8..e038e0b 100644 --- a/ruoyi-fastapi-backend/module_admin/annotation/log_annotation.py +++ b/ruoyi-fastapi-backend/module_admin/annotation/log_annotation.py @@ -3,19 +3,18 @@ import json import os import requests import time -import warnings from datetime import datetime from fastapi import Request from fastapi.responses import JSONResponse, ORJSONResponse, UJSONResponse from functools import lru_cache, wraps -from typing import Literal, Optional, Union +from typing import Literal, Optional from user_agents import parse -from module_admin.entity.vo.log_vo import LogininforModel, OperLogModel -from module_admin.service.log_service import LoginLogService, OperationLogService -from module_admin.service.login_service import LoginService from config.enums import BusinessType from config.env import AppConfig from exceptions.exception import LoginException, ServiceException, ServiceWarning +from module_admin.entity.vo.log_vo import LogininforModel, OperLogModel +from module_admin.service.log_service import LoginLogService, OperationLogService +from module_admin.service.login_service import LoginService from utils.log_util import logger from utils.response_util import ResponseUtil @@ -201,188 +200,6 @@ class Log: return wrapper -def log_decorator( - title: str, - business_type: Union[Literal[0, 1, 2, 3, 4, 5, 6, 7, 8, 9], BusinessType], - log_type: Optional[Literal['login', 'operation']] = 'operation', -): - """ - 日志装饰器 - - :param title: 当前日志装饰器装饰的模块标题 - :param business_type: 业务类型（0其它 1新增 2修改 3删除 4授权 5导出 6导入 7强退 8生成代码 9清空数据） - :param log_type: 日志类型（login表示登录日志，operation表示为操作日志） - :return: - """ - warnings.simplefilter('always', category=DeprecationWarning) - if isinstance(business_type, BusinessType): - business_type = business_type.value - warnings.warn( - '未来版本将会移除@log_decorator装饰器，请使用@Log装饰器', - category=DeprecationWarning, - stacklevel=2, - ) - - def decorator(func): - @wraps(func) - async def wrapper(*args, **kwargs): - start_time = time.time() - # 获取被装饰函数的文件路径 - file_path = inspect.getfile(func) - # 获取项目根路径 - project_root = os.getcwd() - # 处理文件路径，去除项目根路径部分 - relative_path = os.path.relpath(file_path, start=project_root)[0:-2].replace('\\', '.') - # 获取当前被装饰函数所在路径 - func_path = f'{relative_path}{func.__name__}()' - # 获取上下文信息 - request: Request = kwargs.get('request') - token = request.headers.get('Authorization') - query_db = kwargs.get('query_db') - request_method = request.method - operator_type = 0 - user_agent = request.headers.get('User-Agent') - if 'Windows' in user_agent or 'Macintosh' in user_agent or 'Linux' in user_agent: - operator_type = 1 - if 'Mobile' in user_agent or 'Android' in user_agent or 'iPhone' in user_agent: - operator_type = 2 - # 获取请求的url - oper_url = request.url.path - # 获取请求的ip及ip归属区域 - oper_ip = request.headers.get('X-Forwarded-For') - oper_location = '内网IP' - if AppConfig.app_ip_location_query: - oper_location = get_ip_location(oper_ip) - # 根据不同的请求类型使用不同的方法获取请求参数 - content_type = request.headers.get('Content-Type') - if content_type and ( - 'multipart/form-data' in content_type or 'application/x-www-form-urlencoded' in content_type - ): - payload = await request.form() - oper_param = '\n'.join([f'{key}: {value}' for key, value in payload.items()]) - else: - payload = await request.body() - # 通过 request.path_params 直接访问路径参数 - path_params = request.path_params - oper_param = {} - if payload: - oper_param.update(json.loads(str(payload, 'utf-8'))) - if path_params: - oper_param.update(path_params) - oper_param = json.dumps(oper_param, ensure_ascii=False) - # 日志表请求参数字段长度最大为2000，因此在此处判断长度 - if len(oper_param) > 2000: - oper_param = '请求参数过长' - - # 获取操作时间 - oper_time = datetime.now() - # 此处在登录之前向原始函数传递一些登录信息，用于监测在线用户的相关信息 - login_log = {} - if log_type == 'login': - user_agent_info = parse(user_agent) - browser = f'{user_agent_info.browser.family}' - system_os = f'{user_agent_info.os.family}' - if user_agent_info.browser.version != (): - browser += f' {user_agent_info.browser.version[0]}' - if user_agent_info.os.version != (): - system_os += f' {user_agent_info.os.version[0]}' - login_log = dict( - ipaddr=oper_ip, - loginLocation=oper_location, - browser=browser, - os=system_os, - loginTime=oper_time.strftime('%Y-%m-%d %H:%M:%S'), - ) - kwargs['form_data'].login_info = login_log - try: - # 调用原始函数 - result = await func(*args, **kwargs) - except (LoginException, ServiceWarning) as e: - logger.warning(e.message) - result = ResponseUtil.failure(data=e.data, msg=e.message) - except ServiceException as e: - logger.error(e.message) - result = ResponseUtil.error(data=e.data, msg=e.message) - except Exception as e: - logger.exception(e) - result = ResponseUtil.error(msg=str(e)) - # 获取请求耗时 - cost_time = float(time.time() - start_time) * 100 - # 判断请求是否来自api文档 - request_from_swagger = ( - request.headers.get('referer').endswith('docs') if request.headers.get('referer') else False - ) - request_from_redoc = ( - request.headers.get('referer').endswith('redoc') if request.headers.get('referer') else False - ) - # 根据响应结果的类型使用不同的方法获取响应结果参数 - if ( - isinstance(result, JSONResponse) - or isinstance(result, ORJSONResponse) - or isinstance(result, UJSONResponse) - ): - result_dict = json.loads(str(result.body, 'utf-8')) - else: - if request_from_swagger or request_from_redoc: - result_dict = {} - else: - if result.status_code == 200: - result_dict = {'code': result.status_code, 'message': '获取成功'} - else: - result_dict = {'code': result.status_code, 'message': '获取失败'} - json_result = json.dumps(result_dict, ensure_ascii=False) - # 根据响应结果获取响应状态及异常信息 - status = 1 - error_msg = '' - if result_dict.get('code') == 200: - status = 0 - else: - error_msg = result_dict.get('msg') - # 根据日志类型向对应的日志表插入数据 - if log_type == 'login': - # 登录请求来自于api文档时不记录登录日志，其余情况则记录 - if request_from_swagger or request_from_redoc: - pass - else: - user = kwargs.get('form_data') - user_name = user.username - login_log['loginTime'] = oper_time - login_log['userName'] = user_name - login_log['status'] = str(status) - login_log['msg'] = result_dict.get('msg') - - await LoginLogService.add_login_log_services(query_db, LogininforModel(**login_log)) - else: - current_user = await LoginService.get_current_user(request, token, query_db) - oper_name = current_user.user.user_name - dept_name = current_user.user.dept.dept_name if current_user.user.dept else None - operation_log = OperLogModel( - title=title, - businessType=business_type, - method=func_path, - requestMethod=request_method, - operatorType=operator_type, - operName=oper_name, - deptName=dept_name, - operUrl=oper_url, - operIp=oper_ip, - operLocation=oper_location, - operParam=oper_param, - jsonResult=json_result, - status=status, - errorMsg=error_msg, - operTime=oper_time, - costTime=int(cost_time), - ) - await OperationLogService.add_operation_log_services(query_db, operation_log) - - return result - - return wrapper - - return decorator - - @lru_cache() def get_ip_location(oper_ip: str): """ From 51257df07c088de68f21a88deffd27eef6b10ad8 Mon Sep 17 00:00:00 2001 From: insistence <3055204202@qq.com> Date: Tue, 12 Nov 2024 15:30:54 +0800 Subject: [PATCH 7/8] =?UTF-8?q?chore:=20=E5=8D=87=E7=BA=A7=E7=89=88?= =?UTF-8?q?=E6=9C=AC=E8=87=B31.5.1?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- ruoyi-fastapi-backend/.env.dev | 2 +- ruoyi-fastapi-backend/.env.prod | 2 +- ruoyi-fastapi-frontend/package.json | 2 +- 3 files changed, 3 insertions(+), 3 deletions(-) diff --git a/ruoyi-fastapi-backend/.env.dev b/ruoyi-fastapi-backend/.env.dev index 34f973d..afc6dd6 100644 --- a/ruoyi-fastapi-backend/.env.dev +++ b/ruoyi-fastapi-backend/.env.dev @@ -10,7 +10,7 @@ APP_HOST = '0.0.0.0' # 应用端口 APP_PORT = 9099 # 应用版本 -APP_VERSION= '1.5.0' +APP_VERSION= '1.5.1' # 应用是否开启热重载 APP_RELOAD = true # 应用是否开启IP归属区域查询 diff --git a/ruoyi-fastapi-backend/.env.prod b/ruoyi-fastapi-backend/.env.prod index 7780fcb..6dac0e6 100644 --- a/ruoyi-fastapi-backend/.env.prod +++ b/ruoyi-fastapi-backend/.env.prod @@ -10,7 +10,7 @@ APP_HOST = '0.0.0.0' # 应用端口 APP_PORT = 9099 # 应用版本 -APP_VERSION= '1.5.0' +APP_VERSION= '1.5.1' # 应用是否开启热重载 APP_RELOAD = false # 应用是否开启IP归属区域查询 diff --git a/ruoyi-fastapi-frontend/package.json b/ruoyi-fastapi-frontend/package.json index 7193832..996c73b 100644 --- a/ruoyi-fastapi-frontend/package.json +++ b/ruoyi-fastapi-frontend/package.json @@ -1,6 +1,6 @@ { "name": "vfadmin", - "version": "1.5.0", + "version": "1.5.1", "description": "vfadmin管理系统", "author": "insistence", "license": "MIT", From 43b793159117749c4d7f754477d65c2cb6ae48fd Mon Sep 17 00:00:00 2001 From: insistence <3055204202@qq.com> Date: Tue, 12 Nov 2024 15:31:01 +0800 Subject: [PATCH 8/8] =?UTF-8?q?docs:=20=E6=9B=B4=E6=96=B0README=E6=96=87?= =?UTF-8?q?=E6=A1=A3?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- README.md | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/README.md b/README.md index febe38f..0219e86 100644 --- a/README.md +++ b/README.md @@ -1,12 +1,12 @@

logo

-

RuoYi-Vue3-FastAPI v1.5.0

+

RuoYi-Vue3-FastAPI v1.5.1

基于RuoYi-Vue3+FastAPI前后端分离的快速开发框架

- +