yudao
/
spring-cloud
mirror of https://gitee.com/zhijiantianya/yudao-cloud.git
3
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

🐛 Websocket 断开时，未删除会话缓存 bug

pull/87/MERGE
YunaiV 2023-12-29 12:43:53 +08:00
parent 4e2630ef14
commit a7e7631ce8
2 changed files with 15 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

28
yudao-framework/yudao-spring-boot-starter-mybatis/src/main/java/cn/iocoder/yudao/framework/mybatis/core/mapper/BaseMapperX.java
View File

@ -121,8 +121,8 @@ public interface BaseMapperX<T> extends MPJBaseMapper<T> {
* *
* @param entities 实体们 * @param entities 实体们
*/ */
default void insertBatch(Collection<T> entities) { default Boolean insertBatch(Collection<T> entities) {
Db.saveBatch(entities); return Db.saveBatch(entities);
} }
/** /**
@ -131,28 +131,28 @@ public interface BaseMapperX<T> extends MPJBaseMapper<T> {
* @param entities 实体们 * @param entities 实体们
* @param size 插入数量 Db.saveBatch 默认为 1000 * @param size 插入数量 Db.saveBatch 默认为 1000
*/ */
default void insertBatch(Collection<T> entities, int size) { default Boolean insertBatch(Collection<T> entities, int size) {
Db.saveBatch(entities, size); return Db.saveBatch(entities, size);
} }
default void updateBatch(T update) { default int updateBatch(T update) {
update(update, new QueryWrapper<>()); return update(update, new QueryWrapper<>());
} }
default void updateBatch(Collection<T> entities) { default Boolean updateBatch(Collection<T> entities) {
Db.updateBatchById(entities); return Db.updateBatchById(entities);
} }
default void updateBatch(Collection<T> entities, int size) { default Boolean updateBatch(Collection<T> entities, int size) {
Db.updateBatchById(entities, size); return Db.updateBatchById(entities, size);
} }
default void insertOrUpdate(T entity) { default Boolean insertOrUpdate(T entity) {
Db.saveOrUpdate(entity); return Db.saveOrUpdate(entity);
} }
default void insertOrUpdateBatch(Collection<T> collection) { default Boolean insertOrUpdateBatch(Collection<T> collection) {
Db.saveOrUpdateBatch(collection); return Db.saveOrUpdateBatch(collection);
} }
default int delete(String field, String value) { default int delete(String field, String value) {

2
yudao-framework/yudao-spring-boot-starter-websocket/src/main/java/cn/iocoder/yudao/framework/websocket/core/session/WebSocketSessionManagerImpl.java
View File

@ -66,7 +66,7 @@ public class WebSocketSessionManagerImpl implements WebSocketSessionManager {
@Override @Override
public void removeSession(WebSocketSession session) { public void removeSession(WebSocketSession session) {
// 移除从 idSessions 中 // 移除从 idSessions 中
idSessions.remove(session.getId(), session); idSessions.remove(session.getId());
// 移除从 idSessions 中 // 移除从 idSessions 中
LoginUser user = WebSocketFrameworkUtils.getLoginUser(session); LoginUser user = WebSocketFrameworkUtils.getLoginUser(session);
if (user == null) { if (user == null) {