open-source/MallChat
1
0
Fork 0
mirror of https://github.com/zongzibinbin/MallChat.git synced 2026-03-19 09:53:45 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix:优化

Browse Source
This commit is contained in:
zhongzb
2023-10-16 21:07:17 +08:00
parent 51aa919637
commit 83394a8f35
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
mallchat-chat-server/src/main/java/com/abin/mallchat/common/common/event/listener/MessageMarkListener.java
View File

@@ -10,8 +10,8 @@ import com.abin.mallchat.common.common.domain.enums.IdempotentEnum;
import com.abin.mallchat.common.common.event.MessageMarkEvent; import com.abin.mallchat.common.common.event.MessageMarkEvent;
import com.abin.mallchat.common.user.domain.enums.ItemEnum; import com.abin.mallchat.common.user.domain.enums.ItemEnum;
import com.abin.mallchat.common.user.service.IUserBackpackService; import com.abin.mallchat.common.user.service.IUserBackpackService;
import com.abin.mallchat.common.user.service.WebSocketService;
import com.abin.mallchat.common.user.service.adapter.WSAdapter; import com.abin.mallchat.common.user.service.adapter.WSAdapter;
import com.abin.mallchat.common.user.service.impl.PushService;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Async; import org.springframework.scheduling.annotation.Async;
@@ -35,7 +35,7 @@ public class MessageMarkListener {
@Autowired @Autowired
private IUserBackpackService iUserBackpackService; private IUserBackpackService iUserBackpackService;
@Autowired @Autowired
private WebSocketService webSocketService; private PushService pushService;
@Async @Async
@TransactionalEventListener(classes = MessageMarkEvent.class, fallbackExecution = true) @TransactionalEventListener(classes = MessageMarkEvent.class, fallbackExecution = true)
@@ -61,7 +61,7 @@ public class MessageMarkListener {
public void notifyAll(MessageMarkEvent event) {//后续可做合并查询，目前异步影响不大 public void notifyAll(MessageMarkEvent event) {//后续可做合并查询，目前异步影响不大
ChatMessageMarkDTO dto = event.getDto(); ChatMessageMarkDTO dto = event.getDto();
Integer markCount = messageMarkDao.getMarkCount(dto.getMsgId(), dto.getMarkType()); Integer markCount = messageMarkDao.getMarkCount(dto.getMsgId(), dto.getMarkType());
webSocketService.sendToAllOnline(WSAdapter.buildMsgMarkSend(dto, markCount), dto.getUid()); pushService.sendPushMsg(WSAdapter.buildMsgMarkSend(dto, markCount));
} }
} }