用户名优化

mallchat-custom-server/src/main/java/com/abin/mallchat/custom/chat/service/impl/ChatServiceImpl.java

@@ -179,6 +179,7 @@ public class ChatServiceImpl implements ChatService {
                     .status(transformAct(request.getActType()))
                     .build();
             messageMarkDao.updateById(update);
+            return;
         }
         //没标记过消息，插入一条新消息
         MessageMark insert = MessageMark.builder()

mallchat-custom-server/src/main/java/com/abin/mallchat/custom/user/service/handler/MsgHandler.java

@@ -7,6 +7,7 @@ import me.chanjar.weixin.common.session.WxSessionManager;
 import me.chanjar.weixin.mp.api.WxMpService;
 import me.chanjar.weixin.mp.bean.message.WxMpXmlMessage;
 import me.chanjar.weixin.mp.bean.message.WxMpXmlOutMessage;
+import me.chanjar.weixin.mp.bean.message.WxMpXmlOutTextMessage;
 import org.apache.commons.lang3.StringUtils;
 import org.springframework.stereotype.Component;
 
@@ -24,7 +25,9 @@ public class MsgHandler extends AbstractHandler {
     public WxMpXmlOutMessage handle(WxMpXmlMessage wxMessage,
                                     Map<String, Object> context, WxMpService weixinService,
                                     WxSessionManager sessionManager) {
-
+        if (true) {
+            return WxMpXmlOutMessage.TEXT().build();
+        }
         if (!wxMessage.getMsgType().equals(XmlMsgType.EVENT)) {
             //可以选择将消息保存到本地
         }
@@ -32,11 +35,11 @@ public class MsgHandler extends AbstractHandler {
         //当用户输入关键词如“你好”，“客服”等，并且有客服在线时，把消息转发给在线客服
         try {
             if (StringUtils.startsWithAny(wxMessage.getContent(), "你好", "客服")
-                && weixinService.getKefuService().kfOnlineList()
-                .getKfOnlineList().size() > 0) {
+                    && weixinService.getKefuService().kfOnlineList()
+                    .getKfOnlineList().size() > 0) {
                 return WxMpXmlOutMessage.TRANSFER_CUSTOMER_SERVICE()
-                    .fromUser(wxMessage.getToUser())
-                    .toUser(wxMessage.getFromUser()).build();
+                        .fromUser(wxMessage.getToUser())
+                        .toUser(wxMessage.getFromUser()).build();
             }
         } catch (WxErrorException e) {
             e.printStackTrace();

mallchat-custom-server/src/main/java/com/abin/mallchat/custom/user/websocket/NettyWebSocketServer.java

@@ -78,6 +78,7 @@ public class NettyWebSocketServer {
                          *  2. 这就是为什么当浏览器发送大量数据时，就会发出多次 http请求的原因
                          */
                         pipeline.addLast(new HttpObjectAggregator(8192));
+                        //保存用户ip
                         pipeline.addLast(new HttpHeadersHandler());
                         /**
                          * 说明：