namespace LayIM.Model
{public enum CSMessageType{System = 1,//系统消息，出错，参数错误等消息Custom = 2 //普通消息，对话，或者群组消息
    }
}

namespace LayIM.Model
{public class CSChatMessage{public CSChatMessage() {addtime = DateTime.Now.ToString("HH:mm:ss");}/// <summary>/// 消息来源/// </summary>public CSUser fromuser { get; set; }public CSUser touser { get; set; }/// <summary>/// 消息内容/// </summary>public string msg { get; set; }/// <summary>/// 消息发送时间/// </summary>public string addtime { get; set; }/// <summary>/// 消息类型/// </summary>public CSMessageType msgtype { get; set; }public object other { get; set; }}
}

namespace LayIM.Model
{public class SingalRUser{protected string _groupName { get; set; }private string _connectionId { get; set; }/// <summary>/// 用户当前所在组/// </summary>public string groupname{get{return this._groupName;}}/// <summary>/// 用户当前所在connectionid/// </summary>public string connectionid{get{return this._connectionId;}}public SingalRUser(string groupName, string connectionId){_groupName = groupName;_connectionId = connectionId;}public SingalRUser() { }}/// <summary>/// 用户Model/// </summary>public class CSUser : SingalRUser{public CSUser(string groupName, string connectionId) :base(groupName, connectionId){}/// <summary>/// 用户id/// </summary>public int userid { get; set; }/// <summary>/// 用户昵称/// </summary>public string username { get; set; }/// <summary>/// 用户头像/// </summary>public string photo { get; set; }}
}

    /// <summary>/// 根据两个用户ID得到对应的组织名称/// </summary>/// <param name="sendid">发送人（主动联系人）</param>/// <param name="receiveid">接收人（被动联系人）</param>/// <returns></returns>public static string GetGroupName(string sendid, string receiveid){/*排序的目的就是为了保证，无论谁连接服务器，都能得到正确的组织ID*/int compareResult = string.Compare(sendid, receiveid);if (compareResult > 0) {//重新排序 如果sendid>receiveidreturn string.Format("G{0}{1}", receiveid, sendid);}return string.Format("G{0}{1}", sendid, receiveid);}

/// <summary>/// 人对人聊天 连接服务器/// </summary>/// <param name="sendid">发送人</param>/// <param name="receiveid">接收人</param>/// <returns></returns>public Task ClientToClient(string sendid, string receiveid){if (sendid == null || receiveid == null) { throw new ArgumentNullException("sendid or receiveid can't be null"); }//获取组名string groupName = MessageUtils.GetGroupName(sendid, receiveid);//将当前用户添加到此组织内
            Groups.Add(CurrentUserConnectionId, groupName);//构建系统连接成功消息var msg = MessageUtils.GetSystemMessage(groupName, MessageConfig.ClientToClientConnectedSucceed, new { currentid = sendid, receiveid = receiveid });//将消息推送到当前组 （A和B聊天的组） 同样调用receiveMessage方法return Clients.Caller.receiveMessage(msg);}

 //弹出聊天窗config.chatings = 0;node.list.on('click', '.xxim_childnode', function () {var othis = $(this);//当前登录用户idvar currentid = config.user.id;//取得被点击的用户idvar receiveid = othis.data('id');//调用signalR封装的方法，连接服务器，将发送人id，接收人id传给后台，当前用户加入组
            csClient.server.ctoc(currentid, receiveid);xxim.popchatbox(othis);});

 ctoc: function (sid, rid) {//调用hub的clientToClient方法if (!chat.isConnected(rid)) {//如果没有连接过，进行连接console.log("用户 " + rid + "没有连接过...");_this.proxy.proxyCS.server.clientToClient(sid, rid);} else {console.log("用户 " + rid + "已经连接过了，不需要连接了...");}},

/// <summary>/// 发送消息 ，服务器接收的是CSChatMessage实体，他包含发送人，接收人，消息内容等信息/// </summary>/// <param name="msg"></param>/// <returns></returns>
        public Task ClientSendMsgToClient(CSChatMessage msg){var groupName = MessageUtils.GetGroupName(msg.fromuser.userid.ToString(), msg.touser.userid.ToString());/*中间处理一下消息直接转发给（A,B所在组织，即聊天窗口）*/msg.msgtype = CSMessageType.Custom;//消息类型为普通消息return Clients.Group(groupName).receiveMessage(msg);}

   handleCustomMsg: function (result) {var log = {};//接收人var keys = 'one' + result.touser.userid;//发送人var keys1 = 'one' + result.fromuser.userid;//这里一定要注意，这个keys是会变的，也就是说，如果只取一个的话，会造成 log.imarea[0]为undefined的情况，至于为什么会变，看看代码好好思考一下吧log.imarea = $('#layim_area' + keys);//layim_areaone0if (!log.imarea.length) {log.imarea = $('#layim_area' + keys1);//layim_areaone0
            }//拼接html模板log.html = function (param, type) {return '<li class="' + (type === 'me' ? 'layim_chateme' : '') + '">'+ '<div class="layim_chatuser">'+ function () {if (type === 'me') {return '<span class="layim_chattime">' + param.time + '</span>'+ '<span class="layim_chatname">' + param.name + '</span>'+ '<img src="' + param.face + '" >';} else {return '<img src="' + param.face + '" >'+ '<span class="layim_chatname">' + param.name + '</span>'+ '<span class="layim_chattime">' + param.time + '</span>';}}()+ '</div>'+ '<div class="layim_chatsay">' + param.content + '<em class="layim_zero"></em></div>'+ '</li>';};//上述代码还是layim里的代码，只不过拼接html的时候，参数采用signalR返回的参数var type = result.fromuser.userid == currentUser.id ? "me" : "";//如果发送人的id==当前用户的id，那么这条消息类型为me//拼接html 直接调用layim里的代码
            log.imarea.append(log.html({time: result.addtime,name: result.fromuser.username,face: result.fromuser.photo,content: result.msg}, type));//滚动条处理log.imarea.scrollTop(log.imarea[0].scrollHeight);},

 /*获取随机一个用户当用户第一次登陆就获取，然后存到本地localStorage中模拟用户，之后再登录就直接从缓存里面取*/function getRandomUser() {var userKey = "SIGNALR_USER";var user = local.get(userKey);if (user) { return JSON.parse(user);}var userids = [];var usernames = ["痴玉", "书筠", "诗冬", "飞枫", "盼玉", "靖菡", "宛雁", "之卉", "凡晴", "书枫", "沛梦"];var userphotos = [];//添加id，用户头像数组for (var i = 0; i < 9; i++) {userids.push(10000 + i);userphotos.push("/photos/00" + i.toString() + ".jpg");}//取一个random值，自动生成当前用户var random = Math.random().toString().substr(3, 1);if (random > 8) { random = 8; }var user = {name: usernames[random],photo: userphotos[random],id:userids[random]};local.set(userKey, JSON.stringify(user));return user;}/*本地存储*/var local = {get: function (key) {return localStorage.getItem(key);},set: function (key, value) {localStorage.setItem(key, value);}}