基于Java核心技术的医院门诊系统设计源码

package com.lzh.hosp.aop; import cn.hutool.core.date.LocalDateTimeUtil; import cn.hutool.core.exceptions.ExceptionUtil; import cn.hutool.core.util.ArrayUtil; import cn.hutool.core.util.StrUtil; import com.google.common.collect.Maps; import com.lzh.hosp.enums.OperateTypeEnum; import com.lzh.hosp.model.CommonResult; import com.lzh.hosp.model.OperateLog; import com.lzh.hosp.model.ResponseResult; import com.lzh.hosp.service.OperateLogFrameworkService; import com.lzh.hosp.service.SystemOperateLogService; import com.lzh.hosp.utils.JsonUtils; import com.lzh.hosp.utils.ServletUtils; import com.lzh.hosp.utils.TracerUtils; import com.lzh.hosp.utils.WebFrameworkUtils; import io.swagger.v3.oas.annotations.Operation; import io.swagger.v3.oas.annotations.tags.Tag; import lombok.extern.slf4j.Slf4j; import org.aspectj.lang.ProceedingJoinPoint; import org.aspectj.lang.annotation.Around; import org.aspectj.lang.annotation.Aspect; import org.aspectj.lang.reflect.MethodSignature; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.core.annotation.AnnotationUtils; import org.springframework.stereotype.Component; import org.springframework.validation.BindingResult; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RequestMethod; import org.springframework.web.multipart.MultipartFile; import javax.annotation.Resource; import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletResponse; import java.lang.annotation.Annotation; import java.lang.reflect.Array; import java.time.LocalDateTime; import java.util.*; import java.util.function.Predicate; import java.util.stream.IntStream; /** * 拦截使用 @OperateLog 注解，如果满足条件，则生成操作日志。 * 满足如下任一条件，则会进行记录： * 1. 使用 @ApiOperation + 非 @GetMapping * 2. 使用 @OperateLog 注解 * <p> * 但是，如果声明 @OperateLog 注解时，将 enable 属性设置为 false 时，强制不记录。 * */ @Aspect @Slf4j @Component public class OperateLogAspect { /** * 用于记录操作内容的上下文 * * @see OperateLog#getContent() */ private static final ThreadLocal<String> CONTENT = new ThreadLocal<>(); /** * 用于记录拓展字段的上下文 * * @see OperateLog#getExts() */ private static final ThreadLocal<Map<String, Object>> EXTS = new ThreadLocal<>(); @Autowired private SystemOperateLogService systemOperateLogService; @Around("@annotation(operation)") public Object around(ProceedingJoinPoint joinPoint, Operation operation) throws Throwable { // 可能也添加了 @ApiOperation 注解 com.lzh.hosp.annotation.OperateLog operateLog = getMethodAnnotation(joinPoint, com.lzh.hosp.annotation.OperateLog.class); return around0(joinPoint, operateLog, operation); } @Around("!@annotation(io.swagger.v3.oas.annotations.Operation) && @annotation(operateLog)") // 兼容处理，只添加 @OperateLog 注解的情况 public Object around(ProceedingJoinPoint joinPoint, com.lzh.hosp.annotation.OperateLog operateLog) throws Throwable { return around0(joinPoint, operateLog, null); } private Object around0(ProceedingJoinPoint joinPoint, com.lzh.hosp.annotation.OperateLog operateLog, Operation operation) throws Throwable { // 目前，只有管理员，才记录操作日志！所以非管理员，直接调用，不进行记录 // Integer userType = WebFrameworkUtils.getLoginUserType(); // if (!Objects.equals(userType, UserTypeEnum.ADMIN.getValue())) { // return joinPoint.proceed(); // } // 记录开始时间 LocalDateTime startTime = LocalDateTime.now(); try { // 执行原有方法 Object result = joinPoint.proceed(); // 记录正常执行时的操作日志 this.log(joinPoint, operateLog, operation, startTime, result, null); return result; } catch (Throwable exception) { this.log(joinPoint, operateLog, operation, startTime, null, exception); throw exception; } finally { clearThreadLocal(); } } public static void setContent(String content) { CONTENT.set(content); } public static void addExt(String key, Object value) { if (EXTS.get() == null) { EXTS.set(new HashMap<>()); } EXTS.get().put(key, value); } private static void clearThreadLocal() { CONTENT.remove(); EXTS.remove(); } private void log(ProceedingJoinPoint joinPoint, com.lzh.hosp.annotation.OperateLog operateLog, Operation operation, LocalDateTime startTime, Object result, Throwable exception) { try { // 判断不记录的情况 if (!isLogEnable(joinPoint, operateLog)) { return; } // 真正记录操作日志 this.log0(joinPoint, operateLog, operation, startTime, result, exception); } catch (Throwable ex) { log.error("[log][记录操作日志时，发生异常，其中参数是 joinPoint({}) operateLog({}) apiOperation({}) result({}) exception({}) ]", joinPoint, operateLog, operation, result, exception, ex); } } private void log0(ProceedingJoinPoint joinPoint, com.lzh.hosp.annotation.OperateLog operateLog, Operation operation, LocalDateTime startTime, Object result, Throwable exception) { OperateLog operateLogObj = new OperateLog(); // 补全通用字段 operateLogObj.setTraceId(TracerUtils.getTraceId()); operateLogObj.setStartTime(startTime); // 补充用户信息 fillUserFields(operateLogObj); // 补全模块信息 fillModuleFields(operateLogObj, joinPoint, operateLog, operation); // 补全请求信息 fillRequestFields(operateLogObj); // 补全方法信息 fillMethodFields(operateLogObj, joinPoint, operateLog, startTime, result, exception); // 异步记录日志 systemOperateLogService.createOperateLog(operateLogObj); // operateLogFrameworkService.createOperateLog(operateLogObj); } private static void fillUserFields(OperateLog operateLogObj) { operateLogObj.setUserId(WebFrameworkUtils.getUserId()); // operateLogObj.setUserType(WebFrameworkUtils.getLoginUserType()); } private static void fillModuleFields(OperateLog operateLogObj, ProceedingJoinPoint joinPoint, com.lzh.hosp.annotation.OperateLog operateLog, Operation operation) { // module 属性 if (operateLog != null) { operateLogObj.setModule(operateLog.module()); } if (StrUtil.isEmpty(operateLogObj.getModule())) { Tag tag = getClassAnnotation(joinPoint, Tag.class); if (tag != null) { // 优先读取 @Tag 的 name 属性 if (StrUtil.isNotEmpty(tag.name())) { operateLogObj.setModule(tag.name()); } // 没有的话，读取 @API 的 description 属性 if (StrUtil.isEmpty(operateLogObj.getModule()) && ArrayUtil.isNotEmpty(tag.description())) { operateLogObj.setModule(tag.description()); } } } // name 属性 if (operateLog != null) { operateLogObj.setName(operateLog.name()); } if (StrUtil.isEmpty(operateLogObj.getName()) && operation != null) {