请求聊天总数 设置已读改为websocket模式

This commit is contained in:
wxl 2025-01-12 21:10:18 +08:00
parent d12e4abdfb
commit 4c0c2f5ef0
4 changed files with 5 additions and 1672 deletions

View File

@ -3,6 +3,7 @@ package com.dd.admin.business.webSocket.handler;
import com.dd.admin.business.chat.service.ChatService; import com.dd.admin.business.chat.service.ChatService;
import com.dd.admin.business.webSocket.MsgHandlerInterface; import com.dd.admin.business.webSocket.MsgHandlerInterface;
import com.dd.admin.business.webSocket.util.TioUtil; import com.dd.admin.business.webSocket.util.TioUtil;
import io.swagger.annotations.ApiModel;
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.stereotype.Service; import org.springframework.stereotype.Service;
@ -13,7 +14,8 @@ import java.util.Map;
@Slf4j @Slf4j
@Service("8") @Service("8")
public class GetReadCoutMessageHandler implements MsgHandlerInterface { @ApiModel("获取未读总数Handler")
public class GetReadCountMessageHandler implements MsgHandlerInterface {
@Autowired @Autowired
ChatService chatService; ChatService chatService;
@Override @Override

View File

@ -3,6 +3,7 @@ package com.dd.admin.business.webSocket.handler;
import com.dd.admin.business.chat.service.ChatService; import com.dd.admin.business.chat.service.ChatService;
import com.dd.admin.business.webSocket.MsgHandlerInterface; import com.dd.admin.business.webSocket.MsgHandlerInterface;
import com.dd.admin.business.webSocket.util.TioUtil; import com.dd.admin.business.webSocket.util.TioUtil;
import io.swagger.annotations.ApiModel;
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.stereotype.Component; import org.springframework.stereotype.Component;
@ -14,6 +15,7 @@ import java.util.Map;
@Slf4j @Slf4j
@Service("7") @Service("7")
@ApiModel("读取消息Handler")
public class ReadMessageHandler implements MsgHandlerInterface { public class ReadMessageHandler implements MsgHandlerInterface {
@Autowired @Autowired
ChatService chatService; ChatService chatService;

View File

File diff suppressed because one or more lines are too long