blue
2 years ago
committed by
Gitee
No known key found for this signature in database
GPG Key ID: 173E9B9CA92EEF8F
3 changed files with
3 additions and
4 deletions
-
im-platform/src/main/java/com/bx/implatform/config/MvcConfig.java
-
im-platform/src/main/java/com/bx/implatform/listener/PrivateMessageListener.java
-
im-platform/src/main/java/com/bx/implatform/service/impl/PrivateMessageServiceImpl.java
|
|
|
@ -20,7 +20,8 @@ public class MvcConfig implements WebMvcConfigurer { |
|
|
|
@Override |
|
|
|
public void addInterceptors(InterceptorRegistry registry) { |
|
|
|
registry.addInterceptor(xssInterceptor) |
|
|
|
.addPathPatterns("/**"); |
|
|
|
.addPathPatterns("/**") |
|
|
|
.excludePathPatterns("/error"); |
|
|
|
registry.addInterceptor(authInterceptor) |
|
|
|
.addPathPatterns("/**") |
|
|
|
.excludePathPatterns("/login", "/logout", "/register", "/refreshToken", |
|
|
|
|
|
|
|
@ -22,11 +22,9 @@ import java.util.Set; |
|
|
|
@Slf4j |
|
|
|
@IMListener(type = IMListenerType.PRIVATE_MESSAGE) |
|
|
|
public class PrivateMessageListener implements MessageListener<PrivateMessageVO> { |
|
|
|
|
|
|
|
@Lazy |
|
|
|
@Autowired |
|
|
|
private IPrivateMessageService privateMessageService; |
|
|
|
|
|
|
|
@Override |
|
|
|
public void process(List<IMSendResult<PrivateMessageVO>> results) { |
|
|
|
Set<Long> messageIds = new HashSet<>(); |
|
|
|
@ -47,5 +45,4 @@ public class PrivateMessageListener implements MessageListener<PrivateMessageVO> |
|
|
|
privateMessageService.update(updateWrapper); |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
@ -207,6 +207,7 @@ public class PrivateMessageServiceImpl extends ServiceImpl<PrivateMessageMapper, |
|
|
|
LambdaQueryWrapper<PrivateMessage> wrapper = Wrappers.lambdaQuery(); |
|
|
|
wrapper.eq(PrivateMessage::getSendId, session.getUserId()) |
|
|
|
.eq(PrivateMessage::getRecvId, friendId) |
|
|
|
.eq(PrivateMessage::getStatus, MessageStatus.READED.code()) |
|
|
|
.orderByDesc(PrivateMessage::getId) |
|
|
|
.select(PrivateMessage::getId) |
|
|
|
.last("limit 1"); |
|
|
|
|