修复告警信息

This commit is contained in:
houwei 2024-06-28 16:40:19 +08:00
parent 3ea495b594
commit a3004e5462
8 changed files with 16 additions and 21 deletions

View File

@ -20,9 +20,7 @@ public class StpInterfaceImpl implements StpInterface {
return Collections.emptyList(); return Collections.emptyList();
}else{ }else{
List<String> list = new ArrayList<>(); List<String> list = new ArrayList<>();
currentUser.getAuthorities().forEach(item->{ currentUser.getAuthorities().forEach(item-> list.add(item.toString()));
list.add(item.toString());
});
return list; return list;
} }

View File

@ -4,6 +4,8 @@ package com.das.common.exceptions;
import com.das.common.result.IResultCode; import com.das.common.result.IResultCode;
import com.das.common.result.ResultCode; import com.das.common.result.ResultCode;
import java.io.Serial;
/** /**
* @author chenhaojie * @author chenhaojie
* @Description 自定义业务异常 * @Description 自定义业务异常
@ -11,7 +13,8 @@ import com.das.common.result.ResultCode;
*/ */
public class BusinessException extends RuntimeException { public class BusinessException extends RuntimeException {
private final long serialVersionUID = 1L; @Serial
private static final long serialVersionUID = 1L;
private int code = ResultCode.FAILURE.getCode(); private int code = ResultCode.FAILURE.getCode();

View File

@ -82,7 +82,7 @@ public class DecryptingOncePerRequestFilter extends OncePerRequestFilter {
@Override @Override
public ServletInputStream getInputStream() throws IOException { public ServletInputStream getInputStream() {
final ByteArrayInputStream byteArrayInputStream = new ByteArrayInputStream(bodyData.getBytes(StandardCharsets.UTF_8)); final ByteArrayInputStream byteArrayInputStream = new ByteArrayInputStream(bodyData.getBytes(StandardCharsets.UTF_8));
return new ServletInputStream() { return new ServletInputStream() {
@Override @Override
@ -101,7 +101,7 @@ public class DecryptingOncePerRequestFilter extends OncePerRequestFilter {
} }
@Override @Override
public int read() throws IOException { public int read() {
return byteArrayInputStream.read(); return byteArrayInputStream.read();
} }
}; };

View File

@ -22,12 +22,12 @@ public class RequestLogInterceptor implements HandlerInterceptor {
@Override @Override
public void postHandle(HttpServletRequest request, HttpServletResponse response, Object handler, ModelAndView modelAndView) throws Exception { public void postHandle(HttpServletRequest request, HttpServletResponse response, Object handler, ModelAndView modelAndView) {
} }
@Override @Override
public void afterCompletion(HttpServletRequest request, HttpServletResponse response, Object handler, Exception ex) throws Exception { public void afterCompletion(HttpServletRequest request, HttpServletResponse response, Object handler, Exception ex) {
String servletPath = request.getServletPath(); String servletPath = request.getServletPath();
log.info("preHandle 后置处理----------"); log.info("preHandle 后置处理----------");
@ -60,7 +60,7 @@ public class RequestLogInterceptor implements HandlerInterceptor {
} }
@Override @Override
public boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object handler) throws Exception { public boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object handler) {
String servletPath = request.getServletPath(); String servletPath = request.getServletPath();
// 生成RequestId // 生成RequestId
String requestId = this.getRequestId(); String requestId = this.getRequestId();

View File

@ -63,9 +63,7 @@ public class R<T> implements Serializable {
} }
public static boolean isSuccess(@Nullable R<?> result) { public static boolean isSuccess(@Nullable R<?> result) {
return Optional.ofNullable(result).map((x) -> { return Optional.ofNullable(result).map((x) -> ResultCode.SUCCESS.code == x.code).orElse(Boolean.FALSE);
return ResultCode.SUCCESS.code == x.code;
}).orElse(Boolean.FALSE);
} }
public static boolean isNotSuccess(@Nullable R<?> result) { public static boolean isNotSuccess(@Nullable R<?> result) {

View File

@ -806,10 +806,8 @@ public class AdminRedisTemplate {
* @return 添加成功的个数 * @return 添加成功的个数
*/ */
public Long zAdd(String key, Map<Object, Double> scoreMembers) { public Long zAdd(String key, Map<Object, Double> scoreMembers) {
Set<TypedTuple<Object>> tuples = new HashSet(); Set<TypedTuple<Object>> tuples = new HashSet<>();
scoreMembers.forEach((k, v) -> { scoreMembers.forEach((k, v) -> tuples.add(new DefaultTypedTuple(k, v)));
tuples.add(new DefaultTypedTuple(k, v));
});
return zSetOps.add(key, tuples); return zSetOps.add(key, tuples);
} }

View File

@ -6,7 +6,6 @@ import com.das.modules.auth.domain.dto.LoginDto;
import com.das.modules.auth.domain.dto.RefreshTokenDto; import com.das.modules.auth.domain.dto.RefreshTokenDto;
import com.das.modules.auth.domain.vo.LoginUserDetailsVo; import com.das.modules.auth.domain.vo.LoginUserDetailsVo;
import com.das.modules.auth.domain.vo.LoginVo; import com.das.modules.auth.domain.vo.LoginVo;
import com.fasterxml.jackson.core.JsonProcessingException;
import jakarta.servlet.http.HttpServletRequest; import jakarta.servlet.http.HttpServletRequest;
import jakarta.servlet.http.HttpServletResponse; import jakarta.servlet.http.HttpServletResponse;
@ -23,7 +22,7 @@ public interface LoginService {
* @param loginDto 登录请求 * @param loginDto 登录请求
* @return 登录成功 * @return 登录成功
*/ */
LoginUserDetailsVo login(LoginDto loginDto, HttpServletRequest request, HttpServletResponse response) throws JsonProcessingException; LoginUserDetailsVo login(LoginDto loginDto, HttpServletRequest request, HttpServletResponse response);
/** /**
* 退出登录 * 退出登录

View File

@ -54,7 +54,7 @@ public class SysMenuServiceImpl implements SysMenuService {
PageQuery pageQuery = new PageQuery(); PageQuery pageQuery = new PageQuery();
pageQuery.setPageNum(sysMenuQueryDto.getPageNum()); pageQuery.setPageNum(sysMenuQueryDto.getPageNum());
pageQuery.setPageSize(sysMenuQueryDto.getPageSize()); pageQuery.setPageSize(sysMenuQueryDto.getPageSize());
if(sysMenuQueryDto == null) { if(sysMenuQueryDto.getParentMenuId() == null) {
sysMenuQueryDto.setParentMenuId(0L); sysMenuQueryDto.setParentMenuId(0L);
} }
IPage<SysMenu> iPage = sysMenuMapper.queryMenuList(pageQuery.build(), sysMenuQueryDto); IPage<SysMenu> iPage = sysMenuMapper.queryMenuList(pageQuery.build(), sysMenuQueryDto);
@ -66,8 +66,7 @@ public class SysMenuServiceImpl implements SysMenuService {
if(sysMenuQueryDto.getRecursive()) { if(sysMenuQueryDto.getRecursive()) {
sysMenuQueryDto.setParentMenuId(0L); sysMenuQueryDto.setParentMenuId(0L);
} }
List<SysMenuVo> list = sysMenuMapper.queryAllMenuList(sysMenuQueryDto); return sysMenuMapper.queryAllMenuList(sysMenuQueryDto);
return list;
} }
@Override @Override