分词管理，智能关键词，智能回复，发送人图标

CallCenterApi/CallCenterApi.DAL/T_Chat_IM_ReplyList.cs

@@ -50,12 +50,13 @@ namespace CallCenterApi.DAL
         {
             StringBuilder strSql = new StringBuilder();
             strSql.Append("insert into T_Chat_IM_ReplyList(");
-            strSql.Append("F_ReplyContent,F_UseNum,F_CollectionNum,F_CreateBy,F_CreateTime,F_IsDelete,F_DeleteBy,F_DeleteTime)");
+            strSql.Append("F_ReplyContent,F_ClassId,F_UseNum,F_CollectionNum,F_CreateBy,F_CreateTime,F_IsDelete,F_DeleteBy,F_DeleteTime)");
             strSql.Append(" values (");
-            strSql.Append("@F_ReplyContent,@F_UseNum,@F_CollectionNum,@F_CreateBy,@F_CreateTime,@F_IsDelete,@F_DeleteBy,@F_DeleteTime)");
+            strSql.Append("@F_ReplyContent,@F_ClassId,@F_UseNum,@F_CollectionNum,@F_CreateBy,@F_CreateTime,@F_IsDelete,@F_DeleteBy,@F_DeleteTime)");
             strSql.Append(";select @@IDENTITY");
             SqlParameter[] parameters = {
                     new SqlParameter("@F_ReplyContent", SqlDbType.NVarChar,500),
+                    new SqlParameter("@F_ClassId", SqlDbType.Int,4),
                     new SqlParameter("@F_UseNum", SqlDbType.Int,4),
                     new SqlParameter("@F_CollectionNum", SqlDbType.Int,4),
                     new SqlParameter("@F_CreateBy", SqlDbType.VarChar,50),
@@ -64,13 +65,14 @@ namespace CallCenterApi.DAL
                     new SqlParameter("@F_DeleteBy", SqlDbType.VarChar,50),
                     new SqlParameter("@F_DeleteTime", SqlDbType.DateTime)};
             parameters[0].Value = model.F_ReplyContent;
-            parameters[1].Value = model.F_UseNum;
-            parameters[2].Value = model.F_CollectionNum;
-            parameters[3].Value = model.F_CreateBy;
-            parameters[4].Value = model.F_CreateTime;
-            parameters[5].Value = model.F_IsDelete;
-            parameters[6].Value = model.F_DeleteBy;
-            parameters[7].Value = model.F_DeleteTime;
+            parameters[1].Value = model.F_ClassId;
+            parameters[3].Value = model.F_UseNum;
+            parameters[4].Value = model.F_CollectionNum;
+            parameters[5].Value = model.F_CreateBy;
+            parameters[6].Value = model.F_CreateTime;
+            parameters[7].Value = model.F_IsDelete;
+            parameters[8].Value = model.F_DeleteBy;
+            parameters[9].Value = model.F_DeleteTime;
 
             object obj = DbHelperSQL.GetSingle(strSql.ToString(), parameters);
             if (obj == null)
@@ -90,6 +92,7 @@ namespace CallCenterApi.DAL
             StringBuilder strSql = new StringBuilder();
             strSql.Append("update T_Chat_IM_ReplyList set ");
             strSql.Append("F_ReplyContent=@F_ReplyContent,");
+            strSql.Append("F_ClassId=@F_ClassId,");
             strSql.Append("F_UseNum=@F_UseNum,");
             strSql.Append("F_CollectionNum=@F_CollectionNum,");
             strSql.Append("F_CreateBy=@F_CreateBy,");
@@ -101,6 +104,7 @@ namespace CallCenterApi.DAL
             SqlParameter[] parameters = {
                     new SqlParameter("@F_ReplyContent", SqlDbType.NVarChar,500),
                     new SqlParameter("@F_UseNum", SqlDbType.Int,4),
+                    new SqlParameter("@F_ClassId", SqlDbType.Int,4),
                     new SqlParameter("@F_CollectionNum", SqlDbType.Int,4),
                     new SqlParameter("@F_CreateBy", SqlDbType.VarChar,50),
                     new SqlParameter("@F_CreateTime", SqlDbType.DateTime),
@@ -109,14 +113,15 @@ namespace CallCenterApi.DAL
                     new SqlParameter("@F_DeleteTime", SqlDbType.DateTime),
                     new SqlParameter("@F_Id", SqlDbType.Int,4)};
             parameters[0].Value = model.F_ReplyContent;
-            parameters[1].Value = model.F_UseNum;
-            parameters[2].Value = model.F_CollectionNum;
-            parameters[3].Value = model.F_CreateBy;
-            parameters[4].Value = model.F_CreateTime;
-            parameters[5].Value = model.F_IsDelete;
-            parameters[6].Value = model.F_DeleteBy;
-            parameters[7].Value = model.F_DeleteTime;
-            parameters[8].Value = model.F_Id;
+            parameters[1].Value = model.F_ClassId;
+            parameters[2].Value = model.F_UseNum;
+            parameters[3].Value = model.F_CollectionNum;
+            parameters[4].Value = model.F_CreateBy;
+            parameters[5].Value = model.F_CreateTime;
+            parameters[6].Value = model.F_IsDelete;
+            parameters[7].Value = model.F_DeleteBy;
+            parameters[8].Value = model.F_DeleteTime;
+            parameters[9].Value = model.F_Id;
 
             int rows = DbHelperSQL.ExecuteSql(strSql.ToString(), parameters);
             if (rows > 0)
@@ -180,7 +185,7 @@ namespace CallCenterApi.DAL
         {
 
             StringBuilder strSql = new StringBuilder();
-            strSql.Append("select  top 1 F_Id,F_ReplyContent,F_UseNum,F_CollectionNum,F_CreateBy,F_CreateTime,F_IsDelete,F_DeleteBy,F_DeleteTime from T_Chat_IM_ReplyList ");
+            strSql.Append("select  top 1 F_Id,F_ReplyContent,F_ClassId,F_UseNum,F_CollectionNum,F_CreateBy,F_CreateTime,F_IsDelete,F_DeleteBy,F_DeleteTime from T_Chat_IM_ReplyList ");
             strSql.Append(" where F_Id=@F_Id");
             SqlParameter[] parameters = {
                     new SqlParameter("@F_Id", SqlDbType.Int,4)
@@ -216,6 +221,10 @@ namespace CallCenterApi.DAL
                 {
                     model.F_ReplyContent = row["F_ReplyContent"].ToString();
                 }
+                if (row["F_ClassId"] != null && row["F_ClassId"].ToString() != "")
+                {
+                    model.F_ClassId = int.Parse(row["F_ClassId"].ToString());
+                }
                 if (row["F_UseNum"] != null && row["F_UseNum"].ToString() != "")
                 {
                     model.F_UseNum = int.Parse(row["F_UseNum"].ToString());
@@ -254,7 +263,7 @@ namespace CallCenterApi.DAL
         public DataSet GetList(string strWhere)
         {
             StringBuilder strSql = new StringBuilder();
-            strSql.Append("select F_Id,F_ReplyContent,F_UseNum,F_CollectionNum,F_CreateBy,F_CreateTime,F_IsDelete,F_DeleteBy,F_DeleteTime ");
+            strSql.Append("select F_Id,F_ReplyContent,F_ClassId,F_UseNum,F_CollectionNum,F_CreateBy,F_CreateTime,F_IsDelete,F_DeleteBy,F_DeleteTime ");
             strSql.Append(" FROM T_Chat_IM_ReplyList ");
             if (strWhere.Trim() != "")
             {
@@ -274,7 +283,7 @@ namespace CallCenterApi.DAL
             {
                 strSql.Append(" top " + Top.ToString());
             }
-            strSql.Append(" F_Id,F_ReplyContent,F_UseNum,F_CollectionNum,F_CreateBy,F_CreateTime,F_IsDelete,F_DeleteBy,F_DeleteTime ");
+            strSql.Append(" F_Id,F_ReplyContent,F_ClassId,F_UseNum,F_CollectionNum,F_CreateBy,F_CreateTime,F_IsDelete,F_DeleteBy,F_DeleteTime ");
             strSql.Append(" FROM T_Chat_IM_ReplyList ");
             if (strWhere.Trim() != "")
             {

CallCenterApi/CallCenterApi.DAL/T_Chat_Message.cs

@@ -38,15 +38,16 @@ namespace CallCenterApi.DAL
         {
             StringBuilder strSql = new StringBuilder();
             strSql.Append("insert into T_Chat_Message(");
-            strSql.Append("F_FromUser,F_ToUser,F_Message,F_File,F_IP,F_SourceType,F_MessageType,F_State,F_CreateUser,F_CreateTime,F_IsDelete,F_DeleteUser,F_DeleteTime)");
+            strSql.Append("F_FromUser,F_ToUser,F_Message,F_File,F_HumanClass,F_IP,F_SourceType,F_MessageType,F_State,F_CreateUser,F_CreateTime,F_IsDelete,F_DeleteUser,F_DeleteTime)");
             strSql.Append(" values (");
-            strSql.Append("@F_FromUser,@F_ToUser,@F_Message,@F_File,@F_IP,@F_SourceType,@F_MessageType,@F_State,@F_CreateUser,@F_CreateTime,@F_IsDelete,@F_DeleteUser,@F_DeleteTime)");
+            strSql.Append("@F_FromUser,@F_ToUser,@F_Message,@F_File,@F_HumanClass,@F_IP,@F_SourceType,@F_MessageType,@F_State,@F_CreateUser,@F_CreateTime,@F_IsDelete,@F_DeleteUser,@F_DeleteTime)");
             strSql.Append(";select @@IDENTITY");
             SqlParameter[] parameters = {
                     new SqlParameter("@F_FromUser", SqlDbType.VarChar,500),
                     new SqlParameter("@F_ToUser", SqlDbType.VarChar,500),
                     new SqlParameter("@F_Message", SqlDbType.NVarChar,-1),
                     new SqlParameter("@F_File", SqlDbType.VarChar,-1),
+                    new SqlParameter("@F_HumanClass", SqlDbType.Int,4),
                     new SqlParameter("@F_IP", SqlDbType.VarChar,50),
                     new SqlParameter("@F_SourceType", SqlDbType.Int,4),
                     new SqlParameter("@F_MessageType", SqlDbType.Int,4),
@@ -60,15 +61,16 @@ namespace CallCenterApi.DAL
             parameters[1].Value = model.F_ToUser;
             parameters[2].Value = model.F_Message;
             parameters[3].Value = model.F_File;
-            parameters[4].Value = model.F_IP;
-            parameters[5].Value = model.F_SourceType;
-            parameters[6].Value = model.F_MessageType;
-            parameters[7].Value = model.F_State;
-            parameters[8].Value = model.F_CreateUser;
-            parameters[9].Value = model.F_CreateTime;
-            parameters[10].Value = model.F_IsDelete;
-            parameters[11].Value = model.F_DeleteUser;
-            parameters[12].Value = model.F_DeleteTime;
+            parameters[4].Value = model.F_HumanClass;
+            parameters[5].Value = model.F_IP;
+            parameters[6].Value = model.F_SourceType;
+            parameters[7].Value = model.F_MessageType;
+            parameters[8].Value = model.F_State;
+            parameters[9].Value = model.F_CreateUser;
+            parameters[10].Value = model.F_CreateTime;
+            parameters[11].Value = model.F_IsDelete;
+            parameters[12].Value = model.F_DeleteUser;
+            parameters[13].Value = model.F_DeleteTime;
 
             object obj = DbHelperSQL.GetSingle(strSql.ToString(), parameters);
             if (obj == null)
@@ -91,6 +93,7 @@ namespace CallCenterApi.DAL
             strSql.Append("F_ToUser=@F_ToUser,");
             strSql.Append("F_Message=@F_Message,");
             strSql.Append("F_File=@F_File,");
+            strSql.Append("F_HumanClass=@F_HumanClass,");
             strSql.Append("F_IP=@F_IP,");
             strSql.Append("F_SourceType=@F_SourceType,");
             strSql.Append("F_MessageType=@F_MessageType,");
@@ -106,6 +109,7 @@ namespace CallCenterApi.DAL
                     new SqlParameter("@F_ToUser", SqlDbType.VarChar,500),
                     new SqlParameter("@F_Message", SqlDbType.NVarChar,-1),
                     new SqlParameter("@F_File", SqlDbType.VarChar,-1),
+                    new SqlParameter("@F_HumanClass", SqlDbType.Int,4),
                     new SqlParameter("@F_IP", SqlDbType.VarChar,50),
                     new SqlParameter("@F_SourceType", SqlDbType.Int,4),
                     new SqlParameter("@F_MessageType", SqlDbType.Int,4),
@@ -120,16 +124,17 @@ namespace CallCenterApi.DAL
             parameters[1].Value = model.F_ToUser;
             parameters[2].Value = model.F_Message;
             parameters[3].Value = model.F_File;
-            parameters[4].Value = model.F_IP;
-            parameters[5].Value = model.F_SourceType;
-            parameters[6].Value = model.F_MessageType;
-            parameters[7].Value = model.F_State;
-            parameters[8].Value = model.F_CreateUser;
-            parameters[9].Value = model.F_CreateTime;
-            parameters[10].Value = model.F_IsDelete;
-            parameters[11].Value = model.F_DeleteUser;
-            parameters[12].Value = model.F_DeleteTime;
-            parameters[13].Value = model.F_Id;
+            parameters[4].Value = model.F_HumanClass;
+            parameters[5].Value = model.F_IP;
+            parameters[6].Value = model.F_SourceType;
+            parameters[7].Value = model.F_MessageType;
+            parameters[8].Value = model.F_State;
+            parameters[9].Value = model.F_CreateUser;
+            parameters[10].Value = model.F_CreateTime;
+            parameters[11].Value = model.F_IsDelete;
+            parameters[12].Value = model.F_DeleteUser;
+            parameters[13].Value = model.F_DeleteTime;
+            parameters[14].Value = model.F_Id;
 
             int rows = DbHelperSQL.ExecuteSql(strSql.ToString(), parameters);
             if (rows > 0)
@@ -193,7 +198,7 @@ namespace CallCenterApi.DAL
         {
 
             StringBuilder strSql = new StringBuilder();
-            strSql.Append("select  top 1 F_Id,F_FromUser,F_ToUser,F_Message,F_File,F_IP,F_SourceType,F_MessageType,F_State,F_CreateUser,F_CreateTime,F_IsDelete,F_DeleteUser,F_DeleteTime from T_Chat_Message ");
+            strSql.Append("select  top 1 F_Id,F_FromUser,F_ToUser,F_Message,F_File,F_HumanClass,F_IP,F_SourceType,F_MessageType,F_State,F_CreateUser,F_CreateTime,F_IsDelete,F_DeleteUser,F_DeleteTime from T_Chat_Message ");
             strSql.Append(" where F_Id=@F_Id");
             SqlParameter[] parameters = {
                     new SqlParameter("@F_Id", SqlDbType.BigInt)
@@ -241,6 +246,10 @@ namespace CallCenterApi.DAL
                 {
                     model.F_File = row["F_File"].ToString();
                 }
+                if (row["F_HumanClass"] != null && row["F_HumanClass"].ToString() != "")
+                {
+                    model.F_HumanClass = int.Parse(row["F_HumanClass"].ToString());
+                }
                 if (row["F_IP"] != null)
                 {
                     model.F_IP = row["F_IP"].ToString();
@@ -287,7 +296,7 @@ namespace CallCenterApi.DAL
         public DataSet GetList(string strWhere)
         {
             StringBuilder strSql = new StringBuilder();
-            strSql.Append("select F_Id,F_FromUser,F_ToUser,F_Message,F_File,F_IP,F_SourceType,F_MessageType,F_State,F_CreateUser,F_CreateTime,F_IsDelete,F_DeleteUser,F_DeleteTime ");
+            strSql.Append("select F_Id,F_FromUser,F_ToUser,F_Message,F_File,F_HumanClass,F_IP,F_SourceType,F_MessageType,F_State,F_CreateUser,F_CreateTime,F_IsDelete,F_DeleteUser,F_DeleteTime ");
             strSql.Append(" FROM T_Chat_Message ");
             if (strWhere.Trim() != "")
             {
@@ -307,7 +316,7 @@ namespace CallCenterApi.DAL
             {
                 strSql.Append(" top " + Top.ToString());
             }
-            strSql.Append(" F_Id,F_FromUser,F_ToUser,F_Message,F_File,F_IP,F_SourceType,F_MessageType,F_State,F_CreateUser,F_CreateTime,F_IsDelete,F_DeleteUser,F_DeleteTime ");
+            strSql.Append(" F_Id,F_FromUser,F_ToUser,F_Message,F_File,F_HumanClass,F_IP,F_SourceType,F_MessageType,F_State,F_CreateUser,F_CreateTime,F_IsDelete,F_DeleteUser,F_DeleteTime ");
             strSql.Append(" FROM T_Chat_Message ");
             if (strWhere.Trim() != "")
             {

CallCenterApi/CallCenterApi.Model/T_Chat_IM_ReplyList.cs

@@ -16,6 +16,7 @@ namespace CallCenterApi.Model
         { }
         #region Model
         private int _f_id;
+        private int? _f_classid;
         private string _f_replycontent;
         private int? _f_usenum;
         private int? _f_collectionnum;
@@ -32,6 +33,15 @@ namespace CallCenterApi.Model
             set { _f_id = value; }
             get { return _f_id; }
         }
+
+        /// <summary>
+        /// 分类
+        /// </summary>
+        public int? F_ClassId
+        {
+            set { _f_classid = value; }
+            get { return _f_classid; }
+        }
         /// <summary>
         /// 回复内容
         /// </summary>

CallCenterApi/CallCenterApi.Model/T_Chat_Message.cs

@@ -15,6 +15,7 @@ namespace CallCenterApi.Model
         private string _f_touser;
         private string _f_message;
         private string _f_file;
+        private int? _f_humanclass;
         private string _f_ip;
         private int? _f_sourcetype;
         private int? _f_messagetype;
@@ -65,6 +66,14 @@ namespace CallCenterApi.Model
             get { return _f_file; }
         }
         /// <summary>
+        /// 发送人（判断图像 0不知 1客服 2客户 3机器人）
+        /// </summary>
+        public int? F_HumanClass
+        {
+            set { _f_humanclass = value; }
+            get { return _f_humanclass; }
+        }
+        /// <summary>
         /// IP
         /// </summary>
         public string F_IP

CallCenterCommon/CallCenter.WebChatServer/App.config

@@ -20,9 +20,14 @@
     <add key="busy" value="客服不在线，请稍后咨询！"/>
     <!--客户ip是黑名单-->
     <add key="black" value="当前状态异常，请电话联系！"/>
+    
+    <!--提示欢迎词（默认）-->
+    <add key="welcome" value="你好，见到你很开心"/>
+    <!--提示欢迎词时间间隔(秒)-->
+    <add key="welcome_maxtime" value="60"/>
 
-    <!--IP获取地址url-->
-    <add key="ipurl" value="http://ip.taobao.com/service/getIpInfo2.php"/>
+    <!--IP获取地址url 没有用-->
+    <!--<add key="ipurl" value="http://ip.taobao.com/service/getIpInfo2.php"/>-->
   </appSettings>
 
   <connectionStrings>

CallCenterCommon/CallCenter.WebChatServer/CallCenter.WebChatServer.csproj

@@ -85,6 +85,7 @@
     <Reference Include="System" />
     <Reference Include="System.Configuration" />
     <Reference Include="System.Core" />
+    <Reference Include="System.Web" />
     <Reference Include="System.Xml.Linq" />
     <Reference Include="System.Data.DataSetExtensions" />
     <Reference Include="Microsoft.CSharp" />
@@ -99,6 +100,7 @@
     <Compile Include="ChatSql.cs" />
     <Compile Include="Program.cs" />
     <Compile Include="Properties\AssemblyInfo.cs" />
+    <Compile Include="KeywordSpliter.cs" />
   </ItemGroup>
   <ItemGroup>
     <None Include="App.config">

CallCenterCommon/CallCenter.WebChatServer/ChatClass.cs

@@ -45,7 +45,14 @@ namespace CallCenter.WebChatServer
             public string code { get; set; }
             public string name { get; set; }
             public string headimgurl { get; set; }
+            /// <summary>
+            /// 发送人（判断图像 0不知 1客服 2客户 3机器人）
+            /// </summary>
+            public int humanclass { get; set; } = 0;
             public object data { get; set; }
+            /// <summary>
+            /// 状态（1右边，0中间）
+            /// </summary>
             public int state { get; set; }
             public string time { get; set; }
         }

CallCenterCommon/CallCenter.WebChatServer/ChatServer.cs

@@ -10,20 +10,24 @@ using SuperWebSocket;
 using SuperSocket.SocketBase.Config;
 using Newtonsoft.Json;
 using Newtonsoft.Json.Linq;
+using System.Threading;
 
 namespace CallCenter.WebChatServer
 {
     public class ChatServer
     {
         WebSocketServer server = new WebSocketServer();
-        ChatSql cs = new ChatSql();
+        public ChatSql cs = new ChatSql();
         public List<ChatClass.Servicer> Servicers = new List<ChatClass.Servicer>();
         public List<ChatClass.Customer> Customers = new List<ChatClass.Customer>();
+        private List<ChatSql.T_Chat_Message> Messages = new List<ChatSql.T_Chat_Message>();
 
         public ChatServer()
         {
         }
 
+        #region 服务初始化管理
+
         /// <summary>
         /// 初始化服务
         /// </summary>
@@ -96,7 +100,7 @@ namespace CallCenter.WebChatServer
         }
 
         /// <summary>
-        /// 关闭服务
+        /// 获取服务状态
         /// </summary>
         /// <returns></returns>
         public ServerState State()
@@ -104,6 +108,8 @@ namespace CallCenter.WebChatServer
             return server.State;
         }
 
+        #endregion
+
         /// <summary>
         /// 接收到消息
         /// </summary>
@@ -116,6 +122,8 @@ namespace CallCenter.WebChatServer
                 var ip = session.RemoteEndPoint.Address.ToString();
                 ChatClass.Message msg = JsonConvert.DeserializeObject<ChatClass.Message>(value);
                 msg.state = 1;
+                msg.humanclass = 0;
+
                 switch (msg.action.ToLower())
                 {
                     case "cusconn":
@@ -182,6 +190,7 @@ namespace CallCenter.WebChatServer
 
                                 if (Servicers.Count > 0)
                                 {
+                                    // 分配客户给客服
                                     cus.ServicerSessionID = SplitCustomer(cus);
                                 }
 
@@ -239,9 +248,53 @@ namespace CallCenter.WebChatServer
                                 serntcmsg.msg = cus.Name + " 上线";
                                 serntcmsg.code = cus.Code;
                                 serntcmsg.name = cus.Name;
+                                //serntcmsg.humanclass = 0;
                                 serntcmsg.data = ipmodel;
                                 serntcmsg.state = 0;
                                 SendMsgToRemotePoint(cus.ServicerSessionID, serntcmsg);
+
+                                #region 发送消息到 - 欢迎词 IM
+                                bool b_cus = false;
+                                int maxTime = int.Parse(ConfigurationManager.AppSettings["welcome_maxtime"]);
+                                string welcome = ConfigurationManager.AppSettings["welcome"];
+                                string MaxDate = cs.GetMessageDateByCode(cus.Code);
+                                DateTime NowDate = DateTime.Now;
+                                if (string.IsNullOrEmpty(MaxDate))
+                                    b_cus = true;
+                                else
+                                    b_cus = (Convert.ToDateTime(MaxDate)).AddSeconds(maxTime) < NowDate;
+                                if (b_cus)
+                                {
+                                    var sersend = Servicers.Where(p => p.SessionID == cus.ServicerSessionID).FirstOrDefault();
+                                    // 欢迎词2
+                                    string welcome_Content = cs.GetReplyContenByCId(2);
+                                    //serntcmsg.action = "cusreceive";
+                                    //serntcmsg.msg = "你好，有什么可以帮你的吗？";
+                                    //serntcmsg.code = sersend.Code;  // sersend != null ? sersend.Code : "";
+                                    //serntcmsg.name = sersend.Name;  // sersend != null ? sersend.Name : "";
+                                    //serntcmsg.headimgurl = sersend != null ? sersend.HeadImgUrl : "";
+                                    //serntcmsg.data = "";
+                                    //serntcmsg.state = 0;
+                                    //SendMsgToRemotePoint(cus.SessionID, serntcmsg);
+
+                                    ChatSql.T_Chat_Message sermsg = new ChatSql.T_Chat_Message();
+                                    sermsg.F_FromUser = sersend == null ? "" : sersend.Code;
+                                    sermsg.F_ToUser = cus.Code;
+                                    sermsg.F_Message = string.IsNullOrEmpty(welcome_Content) ? welcome : welcome_Content;     //"你好，有什么可以帮你的吗？";
+                                    sermsg.F_HumanClass = 3;
+                                    sermsg.F_IP = ip;
+                                    sermsg.F_SourceType = 1;
+                                    sermsg.F_MessageType = 1;
+                                    sermsg.F_State = 0;
+                                    sermsg.F_IsDelete = 0;
+                                    sermsg.F_CreateTime = DateTime.Now;
+                                    sermsg.F_CreateUser = sersend == null ? "" : sersend.Code;
+
+                                    cs.AddMsg(sermsg);
+                                }
+
+
+                                #endregion
                             }
                             else
                             {
@@ -249,6 +302,7 @@ namespace CallCenter.WebChatServer
                                 msg.state = 0;
                                 msg.msg = "请不要打开多个聊天窗口";
                             }
+
                         }
                         else
                         {
@@ -262,19 +316,81 @@ namespace CallCenter.WebChatServer
                         if (!cs.IsBlack(ip))
                         {
                             var cussend = Customers.Where(p => p.SessionID == session.SessionID).FirstOrDefault();
+                            //var serreceive = new ChatClass.Servicer();
                             if (cussend != null)
                             {
+                                #region 客服发送消息 - 智能机器人IM（客服在线和不在线都要发送和保存）1
+                                msg.time = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");
+                                msg.humanclass = 2;
+                                session.Send(JsonConvert.SerializeObject(msg));
+
+                                #region 客服不在线是发送
+                                ChatSql.T_Chat_Message cusmsg = new ChatSql.T_Chat_Message();
+                                cusmsg.F_FromUser = cussend.Code;  //msg.code
+                                //cusmsg.F_ToUser = "";
+                                cusmsg.F_Message = msg.msg;  // "智能机器人IM，能查到很多信息"
+                                cusmsg.F_HumanClass = 2;
+                                cusmsg.F_IP = ip;
+                                cusmsg.F_HumanClass = 2;
+                                cusmsg.F_SourceType = 1;
+                                cusmsg.F_MessageType = 1;
+                                cusmsg.F_State = 0;
+                                cusmsg.F_IsDelete = 0;
+                                cusmsg.F_CreateTime = DateTime.Now;
+                                cusmsg.F_CreateUser = msg.code;
+                                //cs.AddMsg(cusmsg);
+                                #endregion
+
+                                #endregion
+
+
                                 if (Servicers.Count <= 0)
                                 {
                                     cussend.IsSend = 1;
 
-                                    msg.state = 0;
-                                    msg.msg = ConfigurationManager.AppSettings["busy"];
+                                    //msg.state = 0;
+                                    //msg.msg = ConfigurationManager.AppSettings["busy"];
+
+                                    #region 发送消息->客户 - 智能机器人IM（客服都不在线时发送）                                    
+                                    cusmsg.F_ToUser = "";   //客服都不在线
+                                    cs.AddMsg(cusmsg);
+
+                                    // 客服不在线时，启动 智能机器人IM
+                                    string strContent = cs.GetSmartRobotByKey(msg.msg);
+                                    if (string.IsNullOrEmpty(strContent))
+                                        strContent = "抱歉，我已经很努力了，请试试其他信息吧";
+                                    Thread.Sleep(500);
+                                    ChatClass.Message cusrecmsg = new ChatClass.Message();
+                                    cusrecmsg.action = "cusreceive";
+                                    cusrecmsg.msg = strContent; // "智能机器人IM，能查到很多信息"
+                                    cusrecmsg.humanclass = 3;
+                                    cusrecmsg.code = cussend.Code;
+                                    cusrecmsg.name = cussend.Name;
+                                    cusrecmsg.headimgurl = cussend.HeadImgUrl;
+                                    cusrecmsg.state = 0;
+                                    if (SendMsgToRemotePoint(cussend.SessionID, cusrecmsg))
+                                    {
+                                        ChatSql.T_Chat_Message sermsg = new ChatSql.T_Chat_Message();
+                                        sermsg.F_FromUser = ""; // serreceive.Code;
+                                        sermsg.F_ToUser = cussend.Code;
+                                        sermsg.F_Message = strContent;  // "智能机器人IM，能查到很多信息"
+                                        sermsg.F_HumanClass = 3;
+                                        sermsg.F_IP = ip;
+                                        sermsg.F_SourceType = 1;
+                                        sermsg.F_MessageType = 1;
+                                        sermsg.F_State = 0;
+                                        sermsg.F_IsDelete = 0;
+                                        sermsg.F_CreateTime = DateTime.Now;
+                                        sermsg.F_CreateUser = cussend.Code;
+                                        cs.AddMsg(sermsg);
+                                    }
+                                    #endregion
                                 }
                                 else
                                 {
                                     if (string.IsNullOrEmpty(cussend.ServicerSessionID))
                                     {
+                                        // 分配客户给客服
                                         cussend.ServicerSessionID = SplitCustomer(cussend);
                                     }
                                     ChatClass.Message serrecmsg = new ChatClass.Message();
@@ -283,24 +399,29 @@ namespace CallCenter.WebChatServer
                                     serrecmsg.code = cussend.Code;
                                     serrecmsg.name = cussend.Name;
                                     serrecmsg.headimgurl = cussend.HeadImgUrl;
+                                    serrecmsg.humanclass = 2;
                                     serrecmsg.state = 1;
+
                                     if (SendMsgToRemotePoint(cussend.ServicerSessionID, serrecmsg))
                                     {
-                                        var serreceive = Servicers.Where(p => p.SessionID == cussend.ServicerSessionID).FirstOrDefault();
 
-                                        ChatSql.T_Chat_Message cusmsg = new ChatSql.T_Chat_Message();
-                                        cusmsg.F_FromUser = cussend.Code;
-                                        cusmsg.F_ToUser = serreceive.Code;
-                                        cusmsg.F_Message = msg.msg;
-                                        cusmsg.F_IP = ip;
-                                        cusmsg.F_SourceType = 1;
-                                        cusmsg.F_MessageType = 1;
-                                        cusmsg.F_State = 0;
-                                        cusmsg.F_IsDelete = 0;
-                                        cusmsg.F_CreateTime = DateTime.Now;
-                                        cusmsg.F_CreateUser = serreceive.Code;
+                                        var serreceive = Servicers.Where(p => p.SessionID == cussend.ServicerSessionID).FirstOrDefault();
 
+                                        cusmsg.F_ToUser = serreceive.Code;  //客服都在线
                                         cs.AddMsg(cusmsg);
+
+                                        //ChatSql.T_Chat_Message cusmsg = new ChatSql.T_Chat_Message();
+                                        //cusmsg.F_FromUser = cussend.Code;
+                                        //cusmsg.F_ToUser = serreceive.Code;
+                                        //cusmsg.F_Message = msg.msg;
+                                        //cusmsg.F_IP = ip;
+                                        //cusmsg.F_SourceType = 1;
+                                        //cusmsg.F_MessageType = 1;
+                                        //cusmsg.F_State = 0;
+                                        //cusmsg.F_IsDelete = 0;
+                                        //cusmsg.F_CreateTime = DateTime.Now;
+                                        //cusmsg.F_CreateUser = serreceive.Code;
+                                        //cs.AddMsg(cusmsg);                                        
                                     }
                                     else
                                     {
@@ -312,6 +433,7 @@ namespace CallCenter.WebChatServer
                                         msg.state = 0;
                                         msg.msg = "发送失败";
                                     }
+                                    
                                 }
                             }
                             else
@@ -446,6 +568,7 @@ namespace CallCenter.WebChatServer
                             recmsg.code = sersend.Code;
                             recmsg.name = sersend.Name;
                             recmsg.headimgurl = sersend.HeadImgUrl;
+                            recmsg.humanclass = 1;
 
                             if (SendMsgToRemotePoint(cusreceive.SessionID, recmsg))
                             {
@@ -453,6 +576,7 @@ namespace CallCenter.WebChatServer
                                 sermsg.F_FromUser = sersend.Code;
                                 sermsg.F_ToUser = cusreceive.Code;
                                 sermsg.F_Message = msg.msg;
+                                sermsg.F_HumanClass = 1;
                                 sermsg.F_IP = ip;
                                 sermsg.F_SourceType = 1;
                                 sermsg.F_MessageType = 1;
@@ -462,6 +586,35 @@ namespace CallCenter.WebChatServer
                                 sermsg.F_CreateUser = sersend.Code;
 
                                 cs.AddMsg(sermsg);
+
+                                #region 发送消息到 - 智能机器人IM
+
+                                //ChatClass.Message cusrecmsg = new ChatClass.Message();
+                                //cusrecmsg.action = "cusreceive";
+                                //cusrecmsg.msg = "智能机器人IM，能查到很多信息222";
+                                //cusrecmsg.code = sersend.Code;
+                                //cusrecmsg.name = sersend.Name;
+                                //cusrecmsg.headimgurl = sersend.HeadImgUrl;
+                                //cusrecmsg.state = 0;
+                                //if (SendMsgToRemotePoint(cusreceive.SessionID, cusrecmsg))
+                                //{
+                                //    //var cussend = Customers.Where(p => p.SessionID == cussend.SessionID).FirstOrDefault();
+
+                                //    ChatSql.T_Chat_Message sermsg1 = new ChatSql.T_Chat_Message();
+                                //    sermsg1.F_FromUser = sersend.Code;
+                                //    sermsg1.F_ToUser = cusreceive.Code;
+                                //    sermsg1.F_Message = "智能机器人IM，能查到很多信息222";
+                                //    sermsg1.F_IP = ip;
+                                //    sermsg1.F_SourceType = 1;
+                                //    sermsg1.F_MessageType = 1;
+                                //    sermsg1.F_State = 0;
+                                //    sermsg1.F_IsDelete = 0;
+                                //    sermsg1.F_CreateTime = DateTime.Now;
+                                //    sermsg1.F_CreateUser = sersend.Code;
+
+                                //    cs.AddMsg(sermsg);
+                                //}
+                                #endregion
                             }
                             else
                             {
@@ -501,6 +654,7 @@ namespace CallCenter.WebChatServer
                             recmsg.code = cuss.Code;
                             recmsg.name = cuss.Name;
                             recmsg.headimgurl = cuss.HeadImgUrl;
+                            recmsg.humanclass = 1;
                             recmsg.state = 0;
 
                             if (SendMsgToRemotePoint(cuss.SessionID, recmsg))
@@ -539,6 +693,7 @@ namespace CallCenter.WebChatServer
                             recmsg.code = sers.Code;
                             recmsg.name = sers.Name;
                             recmsg.headimgurl = sers.HeadImgUrl;
+                            recmsg.humanclass = 2;
                             recmsg.state = 0;
 
                             if (SendMsgToRemotePoint(sers.SessionID, recmsg))
@@ -593,6 +748,7 @@ namespace CallCenter.WebChatServer
                             newmsg.msg = yser.Name + " 转移给你 " + scus.Name;
                             newmsg.code = scus.Code;
                             newmsg.name = scus.Name;
+                            newmsg.humanclass = 2;
                             newmsg.state = 0;
                             SendMsgToRemotePoint(scus.ServicerSessionID, newmsg);//向客服发送客户转移通知
                         }
@@ -612,19 +768,19 @@ namespace CallCenter.WebChatServer
                         break;
 
                 }
-                if (msg.action.ToLower() != "serconn")
+                if (msg.action.ToLower() != "serconn" && msg.action.ToLower() != "cussend")
                 {
                     msg.time = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");
                     session.Send(JsonConvert.SerializeObject(msg));
                 }
             }
-            catch
+            catch(Exception ex)
             {
                 try
                 {
                     ChatClass.Message msg = JsonConvert.DeserializeObject<ChatClass.Message>(value);
                     msg.state = 0;
-                    msg.msg = "操作失败";
+                    msg.msg = "操作失败:"+ ex.Message;
                     msg.time = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");
                     session.Send(JsonConvert.SerializeObject(msg));
                 }
@@ -654,6 +810,7 @@ namespace CallCenter.WebChatServer
                 msg.name = ses.Name;
                 msg.state = 0;
                 msg.msg = ses.Name+" 下线";
+                //msg.humanclass = 0;
                 SendMsgToRemotePoint(ses.ServicerSessionID, msg);
 
                 cs.UpdateOutTime(ses.Code);
@@ -679,6 +836,7 @@ namespace CallCenter.WebChatServer
                             newmsg.msg = ses1.Name + " 下线，" + cus.Name + " 转移给你";
                             newmsg.code = cus.Code;
                             newmsg.name = cus.Name;
+                            //newmsg.humanclass = 0;
                             newmsg.state = 0;
                             SendMsgToRemotePoint(cus.ServicerSessionID, newmsg);//向客服发送客户转移通知
                         }

CallCenterCommon/CallCenter.WebChatServer/ChatSql.cs

@@ -135,15 +135,16 @@ namespace CallCenter.WebChatServer
         {
             StringBuilder strSql = new StringBuilder();
             strSql.Append("insert into T_Chat_Message(");
-            strSql.Append("F_FromUser,F_ToUser,F_Message,F_File,F_IP,F_SourceType,F_MessageType,F_State,F_CreateUser,F_CreateTime,F_IsDelete,F_DeleteUser,F_DeleteTime)");
+            strSql.Append("F_FromUser,F_ToUser,F_Message,F_File,F_HumanClass,F_IP,F_SourceType,F_MessageType,F_State,F_CreateUser,F_CreateTime,F_IsDelete,F_DeleteUser,F_DeleteTime)");
             strSql.Append(" values (");
-            strSql.Append("@F_FromUser,@F_ToUser,@F_Message,@F_File,@F_IP,@F_SourceType,@F_MessageType,@F_State,@F_CreateUser,@F_CreateTime,@F_IsDelete,@F_DeleteUser,@F_DeleteTime)");
+            strSql.Append("@F_FromUser,@F_ToUser,@F_Message,@F_File,@F_HumanClass,@F_IP,@F_SourceType,@F_MessageType,@F_State,@F_CreateUser,@F_CreateTime,@F_IsDelete,@F_DeleteUser,@F_DeleteTime)");
             strSql.Append(";select @@IDENTITY");
             SqlParameter[] parameters = {
                     new SqlParameter("@F_FromUser", SqlDbType.VarChar,500),
                     new SqlParameter("@F_ToUser", SqlDbType.VarChar,500),
                     new SqlParameter("@F_Message", SqlDbType.NVarChar,-1),
                     new SqlParameter("@F_File", SqlDbType.VarChar,-1),
+                    new SqlParameter("@F_HumanClass", SqlDbType.Int,4),
                     new SqlParameter("@F_IP", SqlDbType.VarChar,50),
                     new SqlParameter("@F_SourceType", SqlDbType.Int,4),
                     new SqlParameter("@F_MessageType", SqlDbType.Int,4),
@@ -157,15 +158,16 @@ namespace CallCenter.WebChatServer
             parameters[1].Value = model.F_ToUser;
             parameters[2].Value = model.F_Message;
             parameters[3].Value = model.F_File;
-            parameters[4].Value = model.F_IP;
-            parameters[5].Value = model.F_SourceType;
-            parameters[6].Value = model.F_MessageType;
-            parameters[7].Value = model.F_State;
-            parameters[8].Value = model.F_CreateUser;
-            parameters[9].Value = model.F_CreateTime;
-            parameters[10].Value = model.F_IsDelete;
-            parameters[11].Value = model.F_DeleteUser;
-            parameters[12].Value = model.F_DeleteTime;
+            parameters[4].Value = model.F_HumanClass;
+            parameters[5].Value = model.F_IP;
+            parameters[6].Value = model.F_SourceType;
+            parameters[7].Value = model.F_MessageType;
+            parameters[8].Value = model.F_State;
+            parameters[9].Value = model.F_CreateUser;
+            parameters[10].Value = model.F_CreateTime;
+            parameters[11].Value = model.F_IsDelete;
+            parameters[12].Value = model.F_DeleteUser;
+            parameters[13].Value = model.F_DeleteTime;
 
             object obj = DbHelperSQL.GetSingle(strSql.ToString(), parameters);
             if (obj == null)
@@ -353,6 +355,20 @@ namespace CallCenter.WebChatServer
         }
 
         /// <summary>
+        /// 获取最近记录的时间
+        /// </summary>
+        /// <returns></returns>
+        public string GetMessageDateByCode(string code)
+        {
+            string sql = "select MAX(F_CreateTime) from T_Chat_Message where (F_FromUser='" + code + "' or F_ToUser='" + code + "')";
+            object obj = DbHelperSQL.GetSingle(sql);
+            if (obj == null)
+                return "";
+            else
+                return obj.ToString();
+        }
+
+        /// <summary>
         /// 获取客户信息
         /// </summary>
         /// <returns></returns>
@@ -533,7 +549,7 @@ namespace CallCenter.WebChatServer
         public string GetUserName(string usercode)
         {
             string sql = "select F_UserName  from T_Sys_UserAccount where F_UserCode='" + usercode + "'";
-            string name = DbHelperSQL.GetSingle(sql).ToString();
+            string name = DbHelperSQL.GetSingle(sql).ToString();           
             return name;
         }
 
@@ -599,6 +615,60 @@ namespace CallCenter.WebChatServer
             }
         }
 
+        #region 快速回复 - 例如：欢迎词，结束语，常用语等
+
+        /// <summary>
+        /// 获取最近记录的时间
+        /// </summary>
+        /// <returns></returns>
+        public string GetReplyContenByCId(int classid)
+        {
+            string sql = "SELECT TOP 1 F_ReplyContent FROM dbo.T_Chat_IM_ReplyList WHERE  F_IsDelete = 0 AND F_ClassId=" + classid + " ";
+            object obj = DbHelperSQL.GetSingle(sql);
+            if (obj == null)
+                return "";
+            else
+                return obj.ToString();
+        }
+        #endregion
+
+        #region 智能机器人 - 关键词
+
+        /// <summary>
+        /// 获取最近记录的时间
+        /// </summary>
+        /// <returns></returns>
+        public string GetSmartRobotByKey(string keyword)
+        {
+            string keyWords = KeywordSpliter.DoGetKeyword(keyword);
+            string[] sArrayKey = keyWords.Trim().Split(',');
+            string sqlStr = "";
+            object obj = null;
+
+            foreach (string key in sArrayKey)
+            {
+                if (key.Trim() != "")
+                    sqlStr += " or F_KeyWord like '%" + key + "%'";
+            }
+            if (!string.IsNullOrEmpty(sqlStr))
+            {
+                // 去掉前面的or，且拼接（)
+                StringBuilder sb = new StringBuilder(sqlStr);
+                sb.Replace(" or ", " AND (", 0, 4);
+                sqlStr = sb.ToString();
+                sqlStr += ")";
+                string sql = "SELECT TOP 1 F_Content FROM dbo.T_Chat_IM_SmartRobot WHERE 1=1 AND F_IsDelete = 0 AND F_State = 1 " + sqlStr + " ";
+                obj = DbHelperSQL.GetSingle(sql);
+            }            
+            if (obj == null)
+                return "";
+            else
+                return obj.ToString();
+        }
+        #endregion
+
+        #region 对象 类
+
         /// <summary>
         /// 客户类
         /// </summary>
@@ -760,6 +830,7 @@ namespace CallCenter.WebChatServer
             private string _f_message;
             private string _f_file;
             private string _f_ip;
+            private int? _f_humanclass = 0;
             private int? _f_sourcetype;
             private int? _f_messagetype;
             private int? _f_state;
@@ -809,6 +880,14 @@ namespace CallCenter.WebChatServer
                 get { return _f_file; }
             }
             /// <summary>
+            /// 发送人（判断图像 0不知 1客服 2客户 3机器人）
+            /// </summary>
+            public int? F_HumanClass
+            {
+                set { _f_humanclass = value; }
+                get { return _f_humanclass; }
+            }
+            /// <summary>
             /// IP
             /// </summary>
             public string F_IP
@@ -825,7 +904,7 @@ namespace CallCenter.WebChatServer
                 get { return _f_sourcetype; }
             }
             /// <summary>
-            /// 消息类型
+            /// 消息类型(1文字消息，2列表消息，3图片/视频/语音)
             /// </summary>
             public int? F_MessageType
             {
@@ -1104,7 +1183,7 @@ namespace CallCenter.WebChatServer
                 get { return _f_outtime; }
             }
             /// <summary>
-            /// 
+            /// 用户类型（1客服，2游客）
             /// </summary>
             public int? F_Type
             {
@@ -1114,5 +1193,7 @@ namespace CallCenter.WebChatServer
             #endregion Model
 
         }
+        #endregion
+
     }
 }

CallCenterCommon/CallCenter.WebChatServer/KeywordSpliter.cs

@@ -0,0 +1,392 @@
+using System;
+using System.Collections;
+using System.Collections.Generic;
+using System.IO;
+using System.Linq;
+using System.Text;
+using System.Text.RegularExpressions;
+using System.Threading.Tasks;
+
+namespace CallCenter.WebChatServer
+{
+    public class KeywordSpliter
+    {
+        #region 属性
+        private static string _SplitChar = " ";//分隔符
+
+        //用于移除停止词
+        private readonly static string[] _StopWordsList = new string[] { "的", "我们", "要", "自己", "之", "将", "“", "”", "，", "（", "）", "后", "应", "到", "某", "后", "个", "是", "位", "新", "一", "两", "在", "中", "或", "有", "更", "好" };
+        #endregion
+
+        //加载keywords_default.dic文本文件数据缓存
+        private static SortedList _KeywordsCacheDefault = null;
+
+        //加载keywords_baidu.dic文本文件数据缓存,自定义dic文件(百度关键词，或自定义关键词)
+        private static SortedList _KeywordsCacheBaidu = null;
+
+        /// <summary>
+        /// 得到分词关键字，以逗号隔开
+        /// </summary>
+        /// <param name="keyText"></param>
+        /// <returns></returns>
+        public static string DoGetKeyword(string keyText)
+        {
+            if (String.IsNullOrEmpty(keyText)) return "";
+
+            LoadDict();
+            LoadDictBaidu();
+
+            #region 默认词库分词
+            StringBuilder sb = new StringBuilder();
+            ArrayList _key = SplitToList(keyText);
+            Dictionary<string, int> distinctDict = SortByDuplicateCount(_key);
+            foreach (KeyValuePair<string, int> pair in distinctDict)
+            {
+                sb.Append(pair.Key + ",");
+            }
+            #endregion
+
+            #region 添加百度关键词，或自定义关键词
+            //若是单个长词关键词, 添加百度关键词，或自定义关键词
+            //bool baidu = _KeywordsCacheBaidu.ContainsKey(keyText);
+            if (!distinctDict.ContainsKey(keyText) && _KeywordsCacheBaidu.ContainsKey(keyText))
+            {
+                sb.Insert(0, keyText + ",");//前置关键词，seo较好
+            }
+            else //枚举自定义词库
+            {
+                string value;
+                foreach (DictionaryEntry key in _KeywordsCacheBaidu)
+                {
+                    value = key.Value.ToString();
+                    if (keyText.IndexOf(value) >= 0 && !distinctDict.ContainsKey(value))
+                        sb.Insert(0, value + ",");//前置关键词，seo较好
+                }
+            }
+            #endregion
+
+            return sb.ToString();
+        }
+
+        //
+        #region 读取文本
+
+        private static SortedList LoadDictFile(string FilePath)
+        {
+            Encoding encoding = Encoding.GetEncoding("utf-8");
+            SortedList arrText = new SortedList();
+            //
+            try
+            {
+                if (!File.Exists(FilePath))
+                {
+                    arrText.Add("0", "文件" + FilePath + "不存在...");
+                }
+                else
+                {
+                    StreamReader objReader = new StreamReader(FilePath, encoding);
+                    string sLine = "";
+                    while (sLine != null)
+                    {
+                        sLine = objReader.ReadLine();
+                        if (!String.IsNullOrEmpty(sLine))
+                            arrText.Add(sLine, sLine);
+                    }
+
+                    objReader.Close();
+                    objReader.Dispose();
+                }
+            }
+            catch (Exception ex)
+            {
+            }
+
+            return arrText;
+        }
+
+
+        #endregion
+
+        #region 载入词典
+
+        /// <summary>
+        /// 加载字典文件，并缓存到变量
+        /// </summary>
+        /// <returns></returns>
+        private static SortedList LoadDict()
+        {
+            string filePath = GetPhysicalFilePath("keywords_default.dic");
+            if (_KeywordsCacheDefault == null) _KeywordsCacheDefault = LoadDictFile(filePath);
+            return _KeywordsCacheDefault;
+        }
+
+        private static SortedList LoadDictBaidu()
+        {
+            string filePath = GetPhysicalFilePath("keywords_baidu.dic");
+            if (_KeywordsCacheBaidu == null) _KeywordsCacheBaidu = LoadDictFile(filePath);
+            return _KeywordsCacheBaidu;
+        }
+
+        /// <summary>
+        /// 获取物理文件路径
+        /// </summary>
+        /// <param name="dictFileName">文件名，如：keywords_baidu.dic</param>
+        /// <returns></returns>
+        /// <returns></returns>
+        private static string GetPhysicalFilePath(string dictFileName)
+        {
+            //判断是Web服务器环境
+            if (System.Web.HttpContext.Current != null)
+            {
+                string filePath = System.Web.HttpContext.Current.Server.MapPath("~/bin/" + dictFileName);
+                return filePath;
+            }
+            else//其他环境，Winform环境
+            {
+                string dir = Path.GetDirectoryName(typeof(KeywordSpliter).Assembly.Location);
+                string filePath = Path.Combine(dir, dictFileName);
+                return filePath;
+            }
+        }
+
+        #endregion
+
+        //
+        #region 正则检测
+        private static bool IsMatch(string str, string reg)
+        {
+            return new Regex(reg).IsMatch(str);
+        }
+        #endregion
+        //
+        #region 首先格式化字符串(粗分)
+        private static string FormatStr(string val)
+        {
+            string result = "";
+            if (val == null || val == "")
+                return "";
+            //
+            char[] CharList = val.ToCharArray();
+            //
+            string Spc = _SplitChar;//分隔符
+            int StrLen = CharList.Length;
+            int CharType = 0; //0-空白 1-英文 2-中文 3-符号
+                              //
+            for (int i = 0; i < StrLen; i++)
+            {
+                string StrList = CharList[i].ToString();
+                if (StrList == null || StrList == "")
+                    continue;
+                //
+                if (CharList[i] < 0x81)
+                {
+                    #region
+                    if (CharList[i] < 33)
+                    {
+                        if (CharType != 0 && StrList != "\n" && StrList != "\r")
+                        {
+                            result += " ";
+                            CharType = 0;
+                        }
+                        continue;
+                    }
+                    else if (IsMatch(StrList, "[^0-9a-zA-Z@\\.%#:/\\&_-]"))//排除这些字符
+                    {
+                        if (CharType == 0)
+                            result += StrList;
+                        else
+                            result += Spc + StrList;
+                        CharType = 3;
+                    }
+                    else
+                    {
+                        if (CharType == 2 || CharType == 3)
+                        {
+                            result += Spc + StrList;
+                            CharType = 1;
+                        }
+                        else
+                        {
+                            if (IsMatch(StrList, "[@%#:]"))
+                            {
+                                result += StrList;
+                                CharType = 3;
+                            }
+                            else
+                            {
+                                result += StrList;
+                                CharType = 1;
+                            }//end if No.4
+                        }//end if No.3
+                    }//end if No.2
+                    #endregion
+                }//if No.1
+                else
+                {
+                    //如果上一个字符为非中文和非空格，则加一个空格
+                    if (CharType != 0 && CharType != 2)
+                        result += Spc;
+                    //如果是中文标点符号
+                    if (!IsMatch(StrList, "^[\u4e00-\u9fa5]+$"))
+                    {
+                        if (CharType != 0)
+                            result += Spc + StrList;
+                        else
+                            result += StrList;
+                        CharType = 3;
+                    }
+                    else //中文
+                    {
+                        result += StrList;
+                        CharType = 2;
+                    }
+                }
+                //end if No.1
+
+            }//exit for
+             //
+            return result;
+        }
+        #endregion
+        //
+        #region 分词
+        /// <summary>
+        /// 分词
+        /// </summary>
+        /// <param name="key">关键词</param>
+        /// <returns></returns>
+        private static ArrayList StringSpliter(string[] key)
+        {
+            ArrayList List = new ArrayList();
+            try
+            {
+                SortedList dict = LoadDict();//载入词典
+                                             //
+                for (int i = 0; i < key.Length; i++)
+                {
+                    if (IsMatch(key[i], @"^(?!^\.$)([a-zA-Z0-9\.\u4e00-\u9fa5]+)$")) //中文、英文、数字
+                    {
+                        if (IsMatch(key[i], "^[\u4e00-\u9fa5]+$"))//如果是纯中文
+                        {
+                            int keyLen = key[i].Length;
+                            if (keyLen < 2)
+                                continue;
+                            else if (keyLen <= 7)
+                                List.Add(key[i]);
+                            //
+                            //开始分词
+                            for (int x = 0; x < keyLen; x++)
+                            {
+                                //x：起始位置//y：结束位置
+                                for (int y = x; y < keyLen; y++)
+                                {
+                                    string val = key[i].Substring(x, keyLen - y);
+                                    if (val == null || val.Length < 2)
+                                        break;
+                                    else if (val.Length > 10)
+                                        continue;
+                                    if (dict.Contains(val))
+                                        List.Add(val);
+                                }
+                                //
+                            }
+                            //
+                        }
+                        else if (!IsMatch(key[i], @"^(\.*)$"))//不全是小数点
+                        {
+                            List.Add(key[i]);
+                        }
+                    }
+                }
+            }
+            catch (Exception ex)
+            {
+
+            }
+            return List;
+        }
+        #endregion
+
+        #region 得到分词结果
+
+        /// <summary>
+        /// 得到分词结果
+        /// </summary>
+        /// <param name="keyText"></param>
+        /// <returns></returns>
+        private static ArrayList SplitToList(string keyText)
+        {
+            ArrayList KeyList = StringSpliter(FormatStr(keyText).Split(_SplitChar.ToCharArray()));
+
+            //去掉没用的词
+            for (int i = 0; i < KeyList.Count; i++)
+            {
+                if (IsStopword(KeyList[i].ToString()))
+                {
+                    KeyList.RemoveAt(i);
+                }
+            }
+
+            return KeyList;
+        }
+
+        /// <summary>
+        /// 把一个集合按重复次数排序
+        /// </summary>
+        /// <param name="inputList"></param>
+        /// <returns></returns>
+        private static Dictionary<string, int> SortByDuplicateCount(ArrayList inputList)
+        {
+            //用于计算每个元素出现的次数，key是元素，value是出现次数
+            Dictionary<string, int> distinctDict = new Dictionary<string, int>();
+            for (int i = 0; i < inputList.Count; i++)
+            {
+
+                //这里没用trygetvalue，会计算两次hash
+                if (distinctDict.ContainsKey(inputList[i].ToString()))
+                    distinctDict[inputList[i].ToString()]++;
+                else
+                    distinctDict.Add(inputList[i].ToString(), 1);
+            }
+
+            Dictionary<string, int> sortByValueDict = GetSortByValueDict(distinctDict);
+            return sortByValueDict;
+        }
+
+        /// <summary>
+        /// 把一个字典value的顺序排序
+        /// </summary>
+        /// <typeparam name="K"></typeparam>
+        /// <typeparam name="V"></typeparam>
+        /// <param name="distinctDict"></param>
+        /// <returns></returns>
+        private static Dictionary<K, V> GetSortByValueDict<K, V>(IDictionary<K, V> distinctDict)
+        {
+            //用于给tempDict.Values排序的临时数组
+            V[] tempSortList = new V[distinctDict.Count];
+            distinctDict.Values.CopyTo(tempSortList, 0);
+            Array.Sort(tempSortList); //给数据排序
+            Array.Reverse(tempSortList);//反转
+
+            //用于保存按value排序的字典
+            Dictionary<K, V> sortByValueDict = new Dictionary<K, V>(distinctDict.Count);
+            for (int i = 0; i < tempSortList.Length; i++)
+            {
+                foreach (KeyValuePair<K, V> pair in distinctDict)
+                {
+                    //比较两个泛型是否相当要用Equals，不能用==操作符
+                    if (pair.Value.Equals(tempSortList[i]) && !sortByValueDict.ContainsKey(pair.Key))
+                        sortByValueDict.Add(pair.Key, pair.Value);
+                }
+            }
+            return sortByValueDict;
+        }
+
+        #endregion
+
+        private static bool IsStopword(string str)
+        {
+            return _StopWordsList.Contains(str);
+        }
+    }
+}

CallCenterCommon/CallCenter.WebChatServer/Program.cs

@@ -10,8 +10,12 @@ namespace CallCenter.WebChatServer
     {
         static void Main(string[] args)
         {
-            ChatServer sr = new ChatServer();
+            ////测试案例 - 关键词
+            //string strContent = new ChatSql().GetSmartRobotByKey("商丘是国家历史文化名城");
+            //Console.WriteLine(strContent + "\r\n");
+            //Console.ReadKey();
 
+            ChatServer sr = new ChatServer();
             if (sr.Setup())
             {
                 bind();

CallCenterCommon/CallCenter.WebChatServer/bin/Debug/keywords_baidu.dic

@@ -0,0 +1,13 @@
+你好
+物业
+快速
+开发
+系统
+新闻
+呼叫系统
+呼叫
+简介
+支付
+产品
+公司
+地址

CallCenterCommon/CallCenter.WebChatServer/bin/keywords_baidu.dic

@@ -0,0 +1,5 @@
+你好
+物业
+快速
+开发
+系统

项目其他/sql/T_Chat_IM_ReplyList.sql

@@ -15,6 +15,7 @@ GO
 
 CREATE TABLE [dbo].[T_Chat_IM_ReplyList](
 	[F_Id] [int] IDENTITY(1,1) NOT NULL,
+	[F_ClassId] [int] NULL,
 	[F_ReplyContent] [nvarchar](500) NOT NULL,
 	[F_UseNum] [int] NULL,
 	[F_CollectionNum] [int] NULL,
@@ -37,6 +38,9 @@ GO
 EXEC sys.sp_addextendedproperty @name=N'MS_Description', @value=N'id' , @level0type=N'SCHEMA',@level0name=N'dbo', @level1type=N'TABLE',@level1name=N'T_Chat_IM_ReplyList', @level2type=N'COLUMN',@level2name=N'F_Id'
 GO
 
+EXEC sys.sp_addextendedproperty @name=N'MS_Description', @value=N'·ÖÀà' , @level0type=N'SCHEMA',@level0name=N'dbo', @level1type=N'TABLE',@level1name=N'T_Chat_IM_ReplyList', @level2type=N'COLUMN',@level2name=N'F_ClassId'
+GO
+
 EXEC sys.sp_addextendedproperty @name=N'MS_Description', @value=N'»Ø¸´ÄÚÈÝ' , @level0type=N'SCHEMA',@level0name=N'dbo', @level1type=N'TABLE',@level1name=N'T_Chat_IM_ReplyList', @level2type=N'COLUMN',@level2name=N'F_ReplyContent'
 GO
 

项目其他/sql/T_Chat_Message.sql

@@ -1,7 +1,7 @@
 USE [IM12345]
 GO
 
-/****** Object:  Table [dbo].[T_Chat_Message]    Script Date: 03/05/2020 12:36:28 ******/
+/****** Object:  Table [dbo].[T_Chat_Message]    Script Date: 03/11/2020 10:51:23 ******/
 SET ANSI_NULLS ON
 GO
 
@@ -26,6 +26,7 @@ CREATE TABLE [dbo].[T_Chat_Message](
 	[F_IsDelete] [int] NULL,
 	[F_DeleteUser] [varchar](50) NULL,
 	[F_DeleteTime] [datetime] NULL,
+	[F_HumanClass] [int] NULL,
 PRIMARY KEY CLUSTERED 
 (
 	[F_Id] ASC
@@ -61,4 +62,7 @@ GO
 EXEC sys.sp_addextendedproperty @name=N'MS_Description', @value=N'状态' , @level0type=N'SCHEMA',@level0name=N'dbo', @level1type=N'TABLE',@level1name=N'T_Chat_Message', @level2type=N'COLUMN',@level2name=N'F_State'
 GO
 
+EXEC sys.sp_addextendedproperty @name=N'MS_Description', @value=N'发送人（判断图像 0不知 1客服 2客户 3机器人）' , @level0type=N'SCHEMA',@level0name=N'dbo', @level1type=N'TABLE',@level1name=N'T_Chat_Message', @level2type=N'COLUMN',@level2name=N'F_HumanClass'
+GO
+