From 70d2a5d0f9c6951b2d4cac954041ed73582ff7eb Mon Sep 17 00:00:00 2001
From: liujie <1793218484@qq.com>
Date: 星期一, 09 六月 2025 11:54:00 +0800
Subject: [PATCH] 6.9新增登录失败冻结逻辑
---
springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/config/ParamOutAspect.java | 286 ++++++++++++++++++++++++++++----------------------------
1 files changed, 143 insertions(+), 143 deletions(-)
diff --git a/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/config/ParamOutAspect.java b/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/config/ParamOutAspect.java
index 7d1df28..915bcf9 100644
--- a/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/config/ParamOutAspect.java
+++ b/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/config/ParamOutAspect.java
@@ -1,143 +1,143 @@
-package com.panzhihua.service_community.config;
-
-import java.lang.reflect.Method;
-import java.util.Arrays;
-import java.util.List;
-import java.util.Map;
-import java.util.stream.Collectors;
-import java.util.stream.IntStream;
-
-import javax.servlet.http.HttpServletRequest;
-import javax.servlet.http.HttpServletResponse;
-
-import org.aspectj.lang.ProceedingJoinPoint;
-import org.aspectj.lang.annotation.Around;
-import org.aspectj.lang.annotation.Aspect;
-import org.aspectj.lang.annotation.Pointcut;
-import org.aspectj.lang.reflect.MethodSignature;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-import org.springframework.core.LocalVariableTableParameterNameDiscoverer;
-import org.springframework.stereotype.Component;
-import org.springframework.util.ObjectUtils;
-
-import com.alibaba.fastjson.JSONObject;
-import com.panzhihua.common.model.vos.R;
-import com.panzhihua.common.utlis.DateUtils;
-
-import lombok.extern.slf4j.Slf4j;
-
-/**
- * 应用模块名称
- * <p>
- * 代码描述
- * <p>
- * 拦截controller，输出入参、响应内容和响应时间 Copyright: Copyright (C) 2021 XXX, Inc. All rights reserved.
- * <p>
- * Company: 成都呐喊信息技术有限公司
- * <p>
- *
- * @author manailin
- * @since 2021/8/24 15:30
- */
-@Slf4j
-@Aspect
-@Component
-public class ParamOutAspect {
-
- /**
- * 记录特定日志的声明
- */
- private final Logger slowClassAndMethodLog = LoggerFactory.getLogger("slowClassAndMethodLog");
- /**
- * 设定方法的执行时间限制毫秒数
- */
- private long maxReduceTime = 100;
-
- @Pointcut("execution(* com.panzhihua.service_community.api..*.*(..)) || execution (public * com.panzhihua.service_community.service..* (..))")
- public void aspect() {}
-
- /**
- * [方法描述] 环绕通知，拦截controller，输出请求参数、响应内容和响应时间
- *
- * @param joinPoint
- * @return java.lang.Object
- * @author manailin
- * @date 2021/8/24 17:04
- */
- @Around("aspect()")
- public Object processLog(ProceedingJoinPoint joinPoint) {
- log.info("进入方法性能检查方法");
- Method method = ((MethodSignature)joinPoint.getSignature()).getMethod();
- String className = method.getDeclaringClass().getName();
- // 获取方法名称
- String methodName = method.getName();
- // 获取参数名称
- LocalVariableTableParameterNameDiscoverer paramNames = new LocalVariableTableParameterNameDiscoverer();
- String[] params = paramNames.getParameterNames(method);
- // 获取参数
- Object[] args = joinPoint.getArgs();
- // 过滤掉request和response,不能序列化
- List<Object> filteredArgs = Arrays.stream(args)
- .filter(arg -> (!(arg instanceof HttpServletRequest) && !(arg instanceof HttpServletResponse)))
- .collect(Collectors.toList());
- JSONObject rqsJson = new JSONObject();
- rqsJson.put("rqsMethod", methodName);
- rqsJson.put("rqsTime", DateUtils.getCurrentDateStr_MS());
- if (ObjectUtils.isEmpty(filteredArgs)) {
- rqsJson.put("rqsParams", null);
- } else {
- // 拼接请求参数
- Map<String, Object> rqsParams = IntStream.range(0, filteredArgs.size()).boxed()
- .collect(Collectors.toMap(j -> params[j], j -> filteredArgs.get(j)));
- rqsJson.put("rqsParams", rqsParams);
- }
- log.info(className + ":" + methodName + "请求信息为：" + rqsJson.toJSONString());
- Object resObj = null;
- long startTime = System.currentTimeMillis();
- try {
- // 执行原方法
- resObj = joinPoint.proceed(args);
- } catch (Throwable e) {
- log.error(className + ":" + methodName + "方法执行异常!", e);
- // throw new ServiceException(methodName + "方法执行异常!");
- }
- long endTime = System.currentTimeMillis();
- if (resObj != null) {
- if (resObj instanceof R) {
- // 输出响应信息
- R resJson = (R)resObj;
- // 打印耗时的信息
- this.printExecTime(className , methodName,rqsJson,resJson, startTime, endTime);
- return resJson;
- } else {
- return resObj;
- }
- } else {
- return R.ok();
- }
- }
-
- /**
- * [方法描述] 打印方法执行耗时的信息，如果超过了一定的时间，才打印
- *
- * @param methodName
- * 执行方法名
- * @param startTime
- * 执行开始时间
- * @param endTime
- * 执行结束时间
- * @author manailin
- * @date 2021/8/24 17:05
- */
- private void printExecTime(String className,String methodName, JSONObject rqsJson,R resJson, long startTime, long endTime) {
- long diffTime = endTime - startTime;
- if (diffTime > maxReduceTime) {
- slowClassAndMethodLog.info(className+":"+methodName + " 方法执行耗时：" + diffTime + " ms");
- slowClassAndMethodLog.info(methodName + " 请求参数：" +rqsJson.toJSONString());
- slowClassAndMethodLog.info(className + " 响应信息：" + JSONObject.toJSONString(resJson));
- }
- // TODO 可以集成redis，将每个controller的执行时间追加到redis中，再用定时每周一次同步到库中
- }
-
-}
+//package com.panzhihua.service_community.config;
+//
+//import java.lang.reflect.Method;
+//import java.util.Arrays;
+//import java.util.List;
+//import java.util.Map;
+//import java.util.stream.Collectors;
+//import java.util.stream.IntStream;
+//
+//import javax.servlet.http.HttpServletRequest;
+//import javax.servlet.http.HttpServletResponse;
+//
+//import org.aspectj.lang.ProceedingJoinPoint;
+//import org.aspectj.lang.annotation.Around;
+//import org.aspectj.lang.annotation.Aspect;
+//import org.aspectj.lang.annotation.Pointcut;
+//import org.aspectj.lang.reflect.MethodSignature;
+//import org.slf4j.Logger;
+//import org.slf4j.LoggerFactory;
+//import org.springframework.core.LocalVariableTableParameterNameDiscoverer;
+//import org.springframework.stereotype.Component;
+//import org.springframework.util.ObjectUtils;
+//
+//import com.alibaba.fastjson.JSONObject;
+//import com.panzhihua.common.model.vos.R;
+//import com.panzhihua.common.utlis.DateUtils;
+//
+//import lombok.extern.slf4j.Slf4j;
+//
+///**
+// * 应用模块名称
+// * <p>
+// * 代码描述
+// * <p>
+// * 拦截controller，输出入参、响应内容和响应时间 Copyright: Copyright (C) 2021 XXX, Inc. All rights reserved.
+// * <p>
+// * Company: 成都呐喊信息技术有限公司
+// * <p>
+// *
+// * @author manailin
+// * @since 2021/8/24 15:30
+// */
+//@Slf4j
+//@Aspect
+//@Component
+//public class ParamOutAspect {
+//
+// /**
+// * 记录特定日志的声明
+// */
+// private final Logger slowClassAndMethodLog = LoggerFactory.getLogger("slowClassAndMethodLog");
+// /**
+// * 设定方法的执行时间限制毫秒数
+// */
+// private long maxReduceTime = 100;
+//
+// @Pointcut("execution(* com.panzhihua.service_community.api..*.*(..)) || execution (public * com.panzhihua.service_community.service..* (..))")
+// public void aspect() {}
+//
+// /**
+// * [方法描述] 环绕通知，拦截controller，输出请求参数、响应内容和响应时间
+// *
+// * @param joinPoint
+// * @return java.lang.Object
+// * @author manailin
+// * @date 2021/8/24 17:04
+// */
+// @Around("aspect()")
+// public Object processLog(ProceedingJoinPoint joinPoint) {
+// log.info("进入方法性能检查方法");
+// Method method = ((MethodSignature)joinPoint.getSignature()).getMethod();
+// String className = method.getDeclaringClass().getName();
+// // 获取方法名称
+// String methodName = method.getName();
+// // 获取参数名称
+// LocalVariableTableParameterNameDiscoverer paramNames = new LocalVariableTableParameterNameDiscoverer();
+// String[] params = paramNames.getParameterNames(method);
+// // 获取参数
+// Object[] args = joinPoint.getArgs();
+// // 过滤掉request和response,不能序列化
+// List<Object> filteredArgs = Arrays.stream(args)
+// .filter(arg -> (!(arg instanceof HttpServletRequest) && !(arg instanceof HttpServletResponse)))
+// .collect(Collectors.toList());
+// JSONObject rqsJson = new JSONObject();
+// rqsJson.put("rqsMethod", methodName);
+// rqsJson.put("rqsTime", DateUtils.getCurrentDateStr_MS());
+// if (ObjectUtils.isEmpty(filteredArgs)) {
+// rqsJson.put("rqsParams", null);
+// } else {
+// // 拼接请求参数
+// Map<String, Object> rqsParams = IntStream.range(0, filteredArgs.size()).boxed()
+// .collect(Collectors.toMap(j -> params[j], j -> filteredArgs.get(j)));
+// rqsJson.put("rqsParams", rqsParams);
+// }
+// log.info(className + ":" + methodName + "请求信息为：" + rqsJson.toJSONString());
+// Object resObj = null;
+// long startTime = System.currentTimeMillis();
+// try {
+// // 执行原方法
+// resObj = joinPoint.proceed(args);
+// } catch (Throwable e) {
+// log.error(className + ":" + methodName + "方法执行异常!", e);
+// // throw new ServiceException(methodName + "方法执行异常!");
+// }
+// long endTime = System.currentTimeMillis();
+// if (resObj != null) {
+// if (resObj instanceof R) {
+// // 输出响应信息
+// R resJson = (R)resObj;
+// // 打印耗时的信息
+// this.printExecTime(className , methodName,rqsJson,resJson, startTime, endTime);
+// return resJson;
+// } else {
+// return resObj;
+// }
+// } else {
+// return R.ok();
+// }
+// }
+//
+// /**
+// * [方法描述] 打印方法执行耗时的信息，如果超过了一定的时间，才打印
+// *
+// * @param methodName
+// * 执行方法名
+// * @param startTime
+// * 执行开始时间
+// * @param endTime
+// * 执行结束时间
+// * @author manailin
+// * @date 2021/8/24 17:05
+// */
+// private void printExecTime(String className,String methodName, JSONObject rqsJson,R resJson, long startTime, long endTime) {
+// long diffTime = endTime - startTime;
+// if (diffTime > maxReduceTime) {
+// slowClassAndMethodLog.info(className+":"+methodName + " 方法执行耗时：" + diffTime + " ms");
+// slowClassAndMethodLog.info(methodName + " 请求参数：" +rqsJson.toJSONString());
+// slowClassAndMethodLog.info(className + " 响应信息：" + JSONObject.toJSONString(resJson));
+// }
+// // TODO 可以集成redis，将每个controller的执行时间追加到redis中，再用定时每周一次同步到库中
+// }
+//
+//}
--
Gitblit v1.7.1