|
@@ -5,10 +5,7 @@ import org.apache.commons.collections4.CollectionUtils;
|
|
import org.jim.common.ImAio;
|
|
import org.jim.common.ImAio;
|
|
import org.jim.common.ImConst;
|
|
import org.jim.common.ImConst;
|
|
import org.jim.common.ImPacket;
|
|
import org.jim.common.ImPacket;
|
|
-import org.jim.common.packets.ChatBody;
|
|
|
|
-import org.jim.common.packets.ChatType;
|
|
|
|
-import org.jim.common.packets.Command;
|
|
|
|
-import org.jim.common.packets.RespBody;
|
|
|
|
|
|
+import org.jim.common.packets.*;
|
|
import org.jim.common.utils.ChatKit;
|
|
import org.jim.common.utils.ChatKit;
|
|
import org.jim.server.command.AbstractCmdHandler;
|
|
import org.jim.server.command.AbstractCmdHandler;
|
|
import org.jim.server.command.handler.processor.chat.ChatCmdProcessor;
|
|
import org.jim.server.command.handler.processor.chat.ChatCmdProcessor;
|
|
@@ -73,6 +70,11 @@ public class ChatReqHandler extends AbstractCmdHandler {
|
|
msgQueueRunnable.addMsg(packet);
|
|
msgQueueRunnable.addMsg(packet);
|
|
msgQueueRunnable.getExecutor().execute(msgQueueRunnable);
|
|
msgQueueRunnable.getExecutor().execute(msgQueueRunnable);
|
|
}
|
|
}
|
|
|
|
+ User user = ImAio.getUser(chatBody.getFrom());
|
|
|
|
+ if (user != null){
|
|
|
|
+ chatBody.setAvatar(user.getAvatar());
|
|
|
|
+ chatBody.setNick(user.getNick());
|
|
|
|
+ }
|
|
ImPacket chatPacket = new ImPacket(Command.COMMAND_CHAT_REQ,new RespBody(Command.COMMAND_CHAT_REQ,chatBody).toByte());
|
|
ImPacket chatPacket = new ImPacket(Command.COMMAND_CHAT_REQ,new RespBody(Command.COMMAND_CHAT_REQ,chatBody).toByte());
|
|
//设置同步序列号;
|
|
//设置同步序列号;
|
|
chatPacket.setSynSeq(packet.getSynSeq());
|
|
chatPacket.setSynSeq(packet.getSynSeq());
|