6_2_站内信

Posted 2020-09-15 noaman_wgs

tags:

篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了6_2_站内信相关的知识，希望对你有一定的参考价值。

站内信

一需求描述

站内信是当前用户与所有用户间对话的一个功能。

站内信模块需实现三个功能：

1. 互相发送站内信(写出接口，没有单独页面，用@ResponseBody直接在Postman进行验证)；

2. 显示当前用户的所有站内信(与多个用户间)；

3. 显示当前用户与某个指定用户间的对话消息。

二具体实现

实现流程：DB>Model>Dao>Service>Controller>html

1.DB创建表Message

 1 DROP TABLE IF EXISTS `message`;
 2 CREATE TABLE `message`(
 3   `id` INT NOT NULL AUTO_INCREMENT,
 4    `from_id` INT NOT NULL,
 5    `to_id` INT NOT NULL ,
 6     `content` TEXT NOT NULL ,
 7     `created_date` DATETIME NOT NULL ,
 8     `has_read` INT NULL ,
 9     `conversation_id` VARCHAR(45) NOT NULL ,
10     PRIMARY KEY (`id`),
11      INDEX `conversation_index` (`conversation_id` ASC),
12     INDEX `created_date` (`created_date` ASC)
13 ) ENGINE = InnoDB DEFAULT CHARACTER SET = utf8;

View Code

2. Model:

package com.nowcoder.model;

import org.springframework.stereotype.Component;

import java.util.Date;

/**
 * Created by Administrator on 2017/4/29.
 */
@Component
public class Message {
    private int id;
    private int fromId;
    private int toId;
    private String content;
    private Date createdDate;
    private int hasRead;
    private String conversationId;

    public int getId() {
        return id;
    }

    public void setId(int id) {
        this.id = id;
    }

    public int getFromId() {
        return fromId;
    }

    public void setFromId(int fromId) {
        this.fromId = fromId;
    }

    public int getToId() {
        return toId;
    }

    public void setToId(int toId) {
        this.toId = toId;
    }

    public String getContent() {
        return content;
    }

    public void setContent(String content) {
        this.content = content;
    }

    public Date getCreatedDate() {
        return createdDate;
    }

    public void setCreatedDate(Date createdDate) {
        this.createdDate = createdDate;
    }

    public int getHasRead() {
        return hasRead;
    }

    public void setHasRead(int hasRead) {
        this.hasRead = hasRead;
    }

    public String getConversationId() {
        return conversationId;
    }

    public void setConversationId(String conversationId) {
        this.conversationId = conversationId;
    }
}

View Code

3. Dao:

int addMessage(Message message);发送站内信

List<Message> getConversationDetail(@Param("conversationId") String conversationId,
                                    @Param("offset") int offset,
                                    @Param("limit") int limit);                     ： 获取与某个具体用户的站内信

List<Message> getConversationList(@Param("userId") int userId,
                                  @Param("offset") int offset,
                                  @Param("limit") int limit);                       ： 获取站内信列表

int getConvesationUnreadCount(@Param("userId") int userId,
                              @Param("conversationId") String conversationId);       ：统计未读信息

package com.nowcoder.dao;

import com.nowcoder.model.Message;
import org.apache.ibatis.annotations.Insert;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Param;
import org.apache.ibatis.annotations.Select;
import org.springframework.web.bind.annotation.RequestParam;

import java.util.List;

/**
 * Created by Administrator on 2017/4/29.
 */
@Mapper
public interface MessageDao {

    String TABLE_NAME = "message";
    String INSERT_FIELDS = "from_id, to_id, content, created_date, has_read, conversation_id";
    String SELECT_FIELDS = "id," + INSERT_FIELDS;

    @Insert({"insert into", TABLE_NAME, "(", INSERT_FIELDS, ") " +
            " values(#{fromId}, #{toId}, #{content}, #{createdDate}, #{hasRead}, #{conversationId})"})
    int addMessage(Message message);

    @Select({"select ", SELECT_FIELDS, " from ", TABLE_NAME,
            " where conversation_id=#{conversationId} order by id desc limit #{offset}, #{limit}"})
    List<Message> getConversationDetail(@Param("conversationId") String conversationId,
                                        @Param("offset") int offset,
                                        @Param("limit") int limit);

    @Select({"select", INSERT_FIELDS, " ,count(conversation_id) AS id from (select * from ",TABLE_NAME,
             " where from_id=#{userId} or to_id=#{userId} order by id desc) tt group by conversation_id " +
                     " order by created_date limit #{offset}, #{limit}"})
    List<Message> getConversationList(@Param("userId") int userId,
                                      @Param("offset") int offset,
                                      @Param("limit") int limit);

    /**
     * 获取当前用户与指定用户间(conversationId)的对应未读信息
     * @param userId
     * @return
     */
    @Select({"select count(has_read) from ", TABLE_NAME, " where has_read=0 and to_id=#{userId} and conversation_id=#{conversationId}"})
    int getConvesationUnreadCount(@Param("userId") int userId,
                                  @Param("conversationId") String conversationId);


}

View Code

4.Service:

package com.nowcoder.service;

import com.nowcoder.dao.MessageDao;
import com.nowcoder.model.Message;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.util.List;

/**
 * Created by Administrator on 2017/4/29.
 */
@Service
public class MessageService {

    @Autowired
    MessageDao messageDao;

    /**
     * 用户之间发送信息
     * @param message
     * @return
     */
    public int addMessage(Message message){
        return messageDao.addMessage(message);
    }

    public List<Message> getConversationDetail(String conversationId, int offset, int limit){
        return messageDao.getConversationDetail(conversationId, offset, limit);
    }

    public List<Message> getConversationList(int userId, int offset, int limit){
        return messageDao.getConversationList(userId, offset, limit);
    }

    /**
     * 获取当前用户与指定用户间(conversationId)的对应未读信息
     * @param userId
     * @return
     */
    public int getConvesationUnreadCount(int userId, String conversationId){
        return messageDao.getConvesationUnreadCount(userId, conversationId);
    }



}

View Code

5. Controller: MessageController

(1)发送信息：

    /**
     * 发送信息
     * 发送那一方的id +  收到信息的那一方 id =  会话conversationId
     *          ： 即a发送给b 和 b 发送给a  的消息在a,b之间的站内信中心都能看见
     * @param fromId 发送那一方的id
     * @param toId 收到信息的那一方id
     * @param content
     * @return
     */
    @RequestMapping(path = {"/msg/addMsg/"}, method = RequestMethod.POST)
    @ResponseBody
    public String addMessage(@RequestParam("fromId") int fromId,
                             @RequestParam("toId") int toId,
                             @RequestParam("content") String content){
        try {
            Message message = new Message();
            message.setFromId(fromId);
            message.setToId(toId);
            message.setContent(content);
            message.setCreatedDate(new Date());
            message.setHasRead(0);// 0 代表未读 1 代表已读
            message.setConversationId(fromId < toId ? String.format("%d_%d", fromId, toId) : String.format("%d_%d", toId, fromId));

            messageService.addMessage(message);
            return ToutiaoUtil.getJSONString(0);
        }catch (Exception e){
            logger.error("私信发送失败" + e.getMessage());
            return  ToutiaoUtil.getJSONString(1, "私信发送失败!");
        }

    }

(2)获取当前用户站内信列表：

/**
     * 当前用户的所有站内信，包括与所有用户的信息
     * @param model
     * @return
     */
    @RequestMapping(path = {"/msg/list"}, method = {RequestMethod.GET})
    public String conversationList(Model model){

        try{
            int localUserId = hostHolder.getUser().getId();
            List<Message> conversationListList =
                    messageService.getConversationList(localUserId, 0, 20);
            List<ViewObject> conversationVOs = new ArrayList<>();
            for(Message msg : conversationListList){

                ViewObject vo = new ViewObject();
                vo.set("conversation", msg);

                //获取与当前用户对话的user信息
                //如果是我方发送(msg.getFromId() == localUserId)，则user.id为消息发送的toId
                //如果不是我方发送(即我方为接收方)，则user.id 为消息发送的fromId
                int targetId = (msg.getFromId() == localUserId) ? msg.getToId() : msg.getFromId();
                User user = userService.getUser(targetId);
                vo.set("user", user);

                int unread = messageService.getConvesationUnreadCount(localUserId, msg.getConversationId());
                vo.set("unread", unread);

                conversationVOs.add(vo);
            }
            model.addAttribute("conversations", conversationVOs);
        }catch (Exception e){
            logger.error("获取站内信列表失败! " + e.getMessage());
        }
        return "letter";
    }

（3）获取与指定用户间的站内信：

    /**
     * 当前用户与指定用户间的对话消息；
     * @param model
     * @param conversationId 与指定用户对话的id
     * @return
     */
    @RequestMapping(path = {"/msg/detail"}, method = {RequestMethod.GET})
        public String conversationDetail(Model model, @RequestParam("conversationId") String conversationId){

        try{
            //当前用户与多个用户的所有的站内信
            List<Message> conversationList = messageService.getConversationDetail(conversationId, 0 ,10);
            List<ViewObject> messages = new ArrayList<>();
            for(Message msg : conversationList){
                ViewObject vo = new ViewObject();
                vo.set("message", msg);

                //获取当前用户收到信息方的user(即获取我方收到所有信息对应的用户)
                User user = userService.getUser(msg.getFromId());
                if(user == null){
                    continue;
                }
                vo.set("headUrl", user.getHeadUrl());
                vo.set("userId", user.getId());
                messages.add(vo);
            }
            model.addAttribute("messages", messages);
        }catch (Exception e){
            logger.error("获取与用户的对话消息失败 !" + e.getMessage());
        }
        return "letterDetail";

    }

Controller所有的code:

package com.nowcoder.controller;

import com.nowcoder.model.HostHolder;
import com.nowcoder.model.Message;
import com.nowcoder.model.User;
import com.nowcoder.model.ViewObject;
import com.nowcoder.service.MessageService;
import com.nowcoder.service.UserService;
import com.nowcoder.util.ToutiaoUtil;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.ui.Model;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.ResponseBody;

import java.util.ArrayList;
import java.util.Date;
import java.util.List;

/**
 * Created by Administrator on 2017/4/29.
 */
@Controller
public class MessageController {

    private static final Logger logger = LoggerFactory.getLogger(MessageController.class);

    @Autowired
    MessageService messageService;
    @Autowired
    UserService userService;
    @Autowired
    HostHolder hostHolder;

    /**
     * 当前用户的所有站内信，包括与所有用户的信息
     * @param model
     * @return
     */
    @RequestMapping(path = {"/msg/list"}, method = {RequestMethod.GET})
    public String conversationList(Model model){

        try{
            int localUserId = hostHolder.getUser().getId();
            List<Message> conversationListList =
                    messageService.getConversationList(localUserId, 0, 20);
            List<ViewObject> conversationVOs = new ArrayList<>();
            for(Message msg : conversationListList){

                ViewObject vo = new ViewObject();
                vo.set("conversation", msg);

                //获取与当前用户对话的user信息
                //如果是我方发送(msg.getFromId() == localUserId)，则user.id为消息发送的toId
                //如果不是我方发送(即我方为接收方)，则user.id 为消息发送的fromId
                int targetId = (msg.getFromId() == localUserId) ? msg.getToId() : msg.getFromId();
                User user = userService.getUser(targetId);
                vo.set("user", user);

                int unread = messageService.getConvesationUnreadCount(localUserId, msg.getConversationId());
                vo.set("unread", unread);

                conversationVOs.add(vo);
            }
            model.addAttribute("conversations", conversationVOs);
        }catch (Exception e){
            logger.error("获取站内信列表失败! " + e.getMessage());
        }
        return "letter";
    }
    /**
     * 当前用户与指定用户间的对话消息；
     * @param model
     * @param conversationId 与指定用户对话的id
     * @return
     */
    @RequestMapping(path = {"/msg/detail"}, method = {RequestMethod.GET})
        public String conversationDetail(Model model, @RequestParam("conversationId") String conversationId){

        try{
            //当前用户与多个用户的所有的站内信
            List<Message> conversationList = messageService.getConversationDetail(conversationId, 0 ,10);
            List<ViewObject> messages = new ArrayList<>();
            for(Message msg : conversationList){
                ViewObject vo = new ViewObject();
                vo.set("message", msg);

                //获取当前用户收到信息方的user(即获取我方收到所有信息对应的用户)
                User user = userService.getUser(msg.getFromId());
                if(user == null){
                    continue;
                }
                vo.set("headUrl", user.getHeadUrl());
                vo.set("userId", user.getId());
                messages.add(vo);
            }
            model.addAttribute("messages", messages);
        }catch (Exception e){
            logger.error("获取与用户的对话消息失败 !" + e.getMessage());
        }
        return "letterDetail";

    }

    /**
     * 发送信息
     * 发送那一方的id +  收到信息的那一方 id =  会话conversationId
     *          ： 即a发送给b 和 b 发送给a  的消息在a,b之间的站内信中心都能看见
     * @param fromId 发送那一方的id
     * @param toId 收到信息的那一方id
     * @param content
     * @return
     */
    @RequestMapping(path = {"/msg/addMsg/"}, method = RequestMethod.POST)
    @ResponseBody
    public String addMessage(@RequestParam("fromId") int fromId,
                             @RequestParam("toId") int toId,
                             @RequestParam("content") String content){
        try {
            Message message = new Message();
            message.setFromId(fromId);
            message.setToId(toId);
            message.setContent(content);
            message.setCreatedDate(new Date());
            message.setHasRead(0);// 0 代表未读 1 代表已读
            message.setConversationId(fromId < toId ? String.format("%d_%d", fromId, toId) : String.format("%d_%d", toId, fromId));

            messageService.addMessage(message);
            return ToutiaoUtil.getJSONString(0);
        }catch (Exception e){
            logger.error("私信发送失败" + e.getMessage());
            return  ToutiaoUtil.getJSONString(1, "私信发送失败!");
        }

    }

}

View Code

对应HTML:

所有站内信letter.html:

#parse("header.html")
    <div id="main">
        <div class="container">
            <ul class="letter-list">
                #foreach($conversation in $conversations)
                <li id="conversation-item-10005_622873">
                    <a class="letter-link" href="/msg/detail?conversationId=$!{conversation.conversation.conversationId}"></a>
                    <div class="letter-info">
                        <span class="l-time">$!date.format(\'yyyy-MM-dd HH:mm:ss\', $!{conversation.conversation.createdDate})</span>
                        <div class="l-operate-bar">
                            <a href="javascript:void(0);" class="sns-action-del" data-id="10005_622873">
                            删除
                            </a>
                            <a href="/msg/detail?conversationId=$!{conversation.conversation.conversationId}">
                                共$!{conversation.conversation.id}条会话
                            </a>
                        </div>
                    </div>
                    <div class="chat-headbox">
                        <span class="msg-num">
                            $!{conversation.unread}
                        </span>
                        <a class="list-head" href="/user/$!{conversation.user.id}">
                            <img alt="头像" src="$!{conversation.user.headUrl}">
                        </a>
                    </div>
                    <div class="letter-detail">
                        <a title="$!{conversation.user.name}" class="letter-name level-color-1">
                            $!{conversation.user.name}
                        </a>
                        <p class="letter-brief">
                            <a href="/msg/detail?conversationId=$!{conversation.conversation.conversationId}">
                                $!{conversation.conversation.content}
                            </a>
                        </p>
                    </div>
                </li>
                #end
            </ul>

        </div>
        <script type="text/javascript">
          $(function(){

            // If really is weixin
            $(document).on(\'WeixinJSBridgeReady\', function() {

              $(\'.weixin-qrcode-dropdown\').show();

              var options = {
                "img_url": "",
                "link": "http://nowcoder.com/j/wt2rwy",
                "desc": "",
                "title": "读《Web 全栈工程师的自我修养》"
              };

              WeixinJSBridge.on(\'menu:share:appmessage\', function (argv){
                WeixinJSBridge.invoke(\'sendAppMessage\', options, function (res) {
                  // _report(\'send_msg\', res.err_msg)
                });
              });

              WeixinJSBridge.on(\'menu:share:timeline\', function (argv) {
                WeixinJSBridge.invoke(\'shareTimeline\', options, function (res) {
                  // _report(\'send_msg\', res.err_msg)
                });
              });

              // $(window).on(\'touchmove scroll\', function() {
              //   if ((window.innerHeight + window.scrollY) >= document.body.offsetHeight) {
              //     $(\'div.backdrop\').show();
              //     $(\'div.share-help\').show();
              //   } else {
              //     $(\'div.backdrop\').hide();
              //     $(\'div.share-h以上是关于6_2_站内信的主要内容，如果未能解决你的问题，请参考以下文章 
 站内信
 新增站内信功能，支持通过VS Code直连Linux-SSH协议资产，JumpServer堡垒机v2.11.0发布
 新增站内信功能，支持通过VS Code直连Linux-SSH协议资产，JumpServer堡垒机v2.11.0发布
 实现站内信和评论服务
 视频学习笔录---ThinkPHP---thinkphp完善站内信功能
 php设计模式-桥接模式