Merge remote-tracking branch 'origin/dev' into dev
commit
fac7387ab8
|
|
@ -16,15 +16,12 @@ import org.springframework.core.task.VirtualThreadTaskExecutor;
|
||||||
@AutoConfiguration
|
@AutoConfiguration
|
||||||
public class UndertowConfig implements WebServerFactoryCustomizer<UndertowServletWebServerFactory> {
|
public class UndertowConfig implements WebServerFactoryCustomizer<UndertowServletWebServerFactory> {
|
||||||
|
|
||||||
/**
|
|
||||||
* 设置 Undertow 的 websocket 缓冲池
|
|
||||||
*/
|
|
||||||
@Override
|
@Override
|
||||||
public void customize(UndertowServletWebServerFactory factory) {
|
public void customize(UndertowServletWebServerFactory factory) {
|
||||||
// 默认不直接分配内存 如果项目中使用了 websocket 建议直接分配
|
// 默认不直接分配内存 如果项目中使用了 websocket 建议直接分配
|
||||||
factory.addDeploymentInfoCustomizers(deploymentInfo -> {
|
factory.addDeploymentInfoCustomizers(deploymentInfo -> {
|
||||||
WebSocketDeploymentInfo webSocketDeploymentInfo = new WebSocketDeploymentInfo();
|
WebSocketDeploymentInfo webSocketDeploymentInfo = new WebSocketDeploymentInfo();
|
||||||
webSocketDeploymentInfo.setBuffers(new DefaultByteBufferPool(false, 512));
|
webSocketDeploymentInfo.setBuffers(new DefaultByteBufferPool(true, 1024));
|
||||||
deploymentInfo.addServletContextAttribute("io.undertow.websockets.jsr.WebSocketDeploymentInfo", webSocketDeploymentInfo);
|
deploymentInfo.addServletContextAttribute("io.undertow.websockets.jsr.WebSocketDeploymentInfo", webSocketDeploymentInfo);
|
||||||
// 使用虚拟线程
|
// 使用虚拟线程
|
||||||
if (SpringUtils.isVirtual()) {
|
if (SpringUtils.isVirtual()) {
|
||||||
|
|
|
||||||
|
|
@ -1,5 +1,6 @@
|
||||||
package org.dromara.common.websocket.interceptor;
|
package org.dromara.common.websocket.interceptor;
|
||||||
|
|
||||||
|
import cn.dev33.satoken.exception.NotLoginException;
|
||||||
import lombok.extern.slf4j.Slf4j;
|
import lombok.extern.slf4j.Slf4j;
|
||||||
import org.dromara.common.satoken.utils.LoginHelper;
|
import org.dromara.common.satoken.utils.LoginHelper;
|
||||||
import org.dromara.system.api.model.LoginUser;
|
import org.dromara.system.api.model.LoginUser;
|
||||||
|
|
@ -31,9 +32,14 @@ public class PlusWebSocketInterceptor implements HandshakeInterceptor {
|
||||||
*/
|
*/
|
||||||
@Override
|
@Override
|
||||||
public boolean beforeHandshake(ServerHttpRequest request, ServerHttpResponse response, WebSocketHandler wsHandler, Map<String, Object> attributes) {
|
public boolean beforeHandshake(ServerHttpRequest request, ServerHttpResponse response, WebSocketHandler wsHandler, Map<String, Object> attributes) {
|
||||||
LoginUser loginUser = LoginHelper.getLoginUser();
|
try {
|
||||||
attributes.put(LOGIN_USER_KEY, loginUser);
|
LoginUser loginUser = LoginHelper.getLoginUser();
|
||||||
return true;
|
attributes.put(LOGIN_USER_KEY, loginUser);
|
||||||
|
return true;
|
||||||
|
} catch (NotLoginException e) {
|
||||||
|
log.error("WebSocket 认证失败'{}',无法访问系统资源", e.getMessage());
|
||||||
|
return false;
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
|
|
|
||||||
|
|
@ -75,8 +75,6 @@ public class SysDeptController extends BaseController {
|
||||||
public R<Void> add(@Validated @RequestBody SysDeptBo dept) {
|
public R<Void> add(@Validated @RequestBody SysDeptBo dept) {
|
||||||
if (!deptService.checkDeptNameUnique(dept)) {
|
if (!deptService.checkDeptNameUnique(dept)) {
|
||||||
return R.fail("新增部门'" + dept.getDeptName() + "'失败,部门名称已存在");
|
return R.fail("新增部门'" + dept.getDeptName() + "'失败,部门名称已存在");
|
||||||
} else if (StringUtils.isNotBlank(dept.getDeptCategory()) && !deptService.checkDeptCategoryUnique(dept)) {
|
|
||||||
return R.fail("新增部门'" + dept.getDeptName() + "'失败,部门类别编码已存在");
|
|
||||||
}
|
}
|
||||||
return toAjax(deptService.insertDept(dept));
|
return toAjax(deptService.insertDept(dept));
|
||||||
}
|
}
|
||||||
|
|
@ -92,8 +90,6 @@ public class SysDeptController extends BaseController {
|
||||||
deptService.checkDeptDataScope(deptId);
|
deptService.checkDeptDataScope(deptId);
|
||||||
if (!deptService.checkDeptNameUnique(dept)) {
|
if (!deptService.checkDeptNameUnique(dept)) {
|
||||||
return R.fail("修改部门'" + dept.getDeptName() + "'失败,部门名称已存在");
|
return R.fail("修改部门'" + dept.getDeptName() + "'失败,部门名称已存在");
|
||||||
} else if (StringUtils.isNotBlank(dept.getDeptCategory()) && !deptService.checkDeptCategoryUnique(dept)) {
|
|
||||||
return R.fail("修改部门'" + dept.getDeptName() + "'失败,部门类别编码已存在");
|
|
||||||
} else if (dept.getParentId().equals(deptId)) {
|
} else if (dept.getParentId().equals(deptId)) {
|
||||||
return R.fail("修改部门'" + dept.getDeptName() + "'失败,上级部门不能是自己");
|
return R.fail("修改部门'" + dept.getDeptName() + "'失败,上级部门不能是自己");
|
||||||
} else if (StringUtils.equals(UserConstants.DEPT_DISABLE, dept.getStatus())) {
|
} else if (StringUtils.equals(UserConstants.DEPT_DISABLE, dept.getStatus())) {
|
||||||
|
|
|
||||||
|
|
@ -100,13 +100,6 @@ public interface ISysDeptService {
|
||||||
*/
|
*/
|
||||||
boolean checkDeptNameUnique(SysDeptBo dept);
|
boolean checkDeptNameUnique(SysDeptBo dept);
|
||||||
|
|
||||||
/**
|
|
||||||
* 校验部门类别编码是否唯一
|
|
||||||
*
|
|
||||||
* @param dept 部门信息
|
|
||||||
* @return 结果
|
|
||||||
*/
|
|
||||||
boolean checkDeptCategoryUnique(SysDeptBo dept);
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 校验部门是否有数据权限
|
* 校验部门是否有数据权限
|
||||||
|
|
|
||||||
|
|
@ -223,20 +223,6 @@ public class SysDeptServiceImpl implements ISysDeptService {
|
||||||
return !exist;
|
return !exist;
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
|
||||||
* 校验部门类别编码是否唯一
|
|
||||||
*
|
|
||||||
* @param dept 部门信息
|
|
||||||
* @return 结果
|
|
||||||
*/
|
|
||||||
@Override
|
|
||||||
public boolean checkDeptCategoryUnique(SysDeptBo dept) {
|
|
||||||
boolean exist = baseMapper.exists(new LambdaQueryWrapper<SysDept>()
|
|
||||||
.eq(SysDept::getDeptCategory, dept.getDeptCategory())
|
|
||||||
.ne(ObjectUtil.isNotNull(dept.getDeptId()), SysDept::getDeptId, dept.getDeptId()));
|
|
||||||
return !exist;
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 校验部门是否有数据权限
|
* 校验部门是否有数据权限
|
||||||
*
|
*
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue