在线客服bug

CallCenterCommon/CallCenter.WebChatServer/ChatServer.cs

@@ -132,9 +132,24 @@ namespace CallCenter.WebChatServer
                                 code = cs.GetCode();
                             }
                             msg.code = code;
-                            var cususer = cs.GetCusUser(code);//获取是否存在此客户
-                            if (cususer != null)
+
+                            var cusconn = Customers.Where(p => p.Code == code).FirstOrDefault();
+                            if (cusconn == null)
                             {
+                                var cususer = cs.GetCusUser(code);//获取是否存在此客户
+                                if (cususer == null)
+                                {
+                                    ChatSql.T_Chat_User user = new ChatSql.T_Chat_User();
+                                    user.F_OpenId = code;
+                                    user.F_Account = code;
+                                    user.F_Type = 1;
+                                    user.F_State = 0;
+                                    user.F_IsDelete = 0;
+                                    user.F_CreateTime = DateTime.Now;
+                                    user.F_Id = cs.AddUser(user);
+                                    cususer = user;
+                                }
+
                                 if (string.IsNullOrEmpty(cususer.F_Name))
                                 {
                                     cususer.F_Name = ConfigurationManager.AppSettings["anyname"];
@@ -148,86 +163,92 @@ namespace CallCenter.WebChatServer
 
                                 cus.Name = cususer.F_Name;
                                 cus.HeadImgUrl = cususer.F_HeadImgUrl;
-                            }
-
-                            msg.name = cus.Name;
-                            msg.headimgurl = cus.HeadImgUrl;
 
-                            cus.SessionID = session.SessionID;
-                            cus.Code = code;
-                            cus.IsSend = 0;
+                                msg.name = cus.Name;
+                                msg.headimgurl = cus.HeadImgUrl;
 
+                                cus.SessionID = session.SessionID;
+                                cus.Code = code;
+                                cus.IsSend = 0;
 
-                            //if (Servicers.Count <= 0)
-                            //{
-                            //    ChatClass.Message newmsg = new ChatClass.Message();
-                            //    newmsg.action = "ServicersAllOff";
-                            //    newmsg.msg = ConfigurationManager.AppSettings["busy"];
-                            //    session.Send(JsonConvert.SerializeObject(newmsg));//向客户发送客服不在线
-                            //}
 
-                            if (Servicers.Count > 0)
-                            {
-                                cus.ServicerSessionID = SplitCustomer(cus);
-                            }
+                                //if (Servicers.Count <= 0)
+                                //{
+                                //    ChatClass.Message newmsg = new ChatClass.Message();
+                                //    newmsg.action = "ServicersAllOff";
+                                //    newmsg.msg = ConfigurationManager.AppSettings["busy"];
+                                //    session.Send(JsonConvert.SerializeObject(newmsg));//向客户发送客服不在线
+                                //}
 
-                            
+                                if (Servicers.Count > 0)
+                                {
+                                    cus.ServicerSessionID = SplitCustomer(cus);
+                                }
 
-                            ChatSql.T_Chat_IPList ipmodel = new ChatSql.T_Chat_IPList();
-                            ipmodel = cs.GetIPInfo(ip, code);
-                            if (ipmodel == null)
-                            {
-                                #region ip记录
-                                ipmodel = new ChatSql.T_Chat_IPList();
 
-                                string ipinfojson = ChatCommon.HttpGet(ConfigurationManager.AppSettings["ipurl"] + "?ip=" + ip);
-                                var ipinfos = JsonConvert.DeserializeObject<JObject>(ipinfojson);
-                                var ipinfo = JsonConvert.DeserializeObject<JObject>(ipinfos["data"].ToString());
 
-                                ipmodel.F_IP = ip;
-                                ipmodel.F_OpenId = cus.Code;
-                                ipmodel.F_Type = 2;
-                                ipmodel.F_Country = ipinfo["country"].ToString();
-                                ipmodel.F_CountryCode = ipinfo["country_id"].ToString();
-                                ipmodel.F_Area = ipinfo["area"].ToString();
-                                ipmodel.F_AreaCode = ipinfo["area_id"].ToString();
-                                ipmodel.F_Region = ipinfo["region"].ToString();
-                                ipmodel.F_RegionCode = ipinfo["region_id"].ToString();
-                                ipmodel.F_City = ipinfo["city"].ToString();
-                                ipmodel.F_CityCode = ipinfo["city_id"].ToString();
-                                ipmodel.F_County = ipinfo["county"].ToString();
-                                ipmodel.F_CountyCode = ipinfo["county_id"].ToString();
-                                ipmodel.F_ISP = ipinfo["isp"].ToString();
-                                ipmodel.F_ISPCode = ipinfo["isp_id"].ToString();
-                                ipmodel.F_CreateTime = DateTime.Now;
-
-                                cs.AddIP(ipmodel);
-                                #endregion
-                            }
+                                ChatSql.T_Chat_IPList ipmodel = new ChatSql.T_Chat_IPList();
+                                ipmodel = cs.GetIPInfo(ip, code);
+                                if (ipmodel == null)
+                                {
+                                    #region ip记录
+                                    ipmodel = new ChatSql.T_Chat_IPList();
+
+                                    string ipinfojson = ChatCommon.HttpGet(ConfigurationManager.AppSettings["ipurl"] + "?ip=" + ip);
+                                    var ipinfos = JsonConvert.DeserializeObject<JObject>(ipinfojson);
+                                    var ipinfo = JsonConvert.DeserializeObject<JObject>(ipinfos["data"].ToString());
+
+                                    ipmodel.F_IP = ip;
+                                    ipmodel.F_OpenId = cus.Code;
+                                    ipmodel.F_Type = 2;
+                                    ipmodel.F_Country = ipinfo["country"].ToString();
+                                    ipmodel.F_CountryCode = ipinfo["country_id"].ToString();
+                                    ipmodel.F_Area = ipinfo["area"].ToString();
+                                    ipmodel.F_AreaCode = ipinfo["area_id"].ToString();
+                                    ipmodel.F_Region = ipinfo["region"].ToString();
+                                    ipmodel.F_RegionCode = ipinfo["region_id"].ToString();
+                                    ipmodel.F_City = ipinfo["city"].ToString();
+                                    ipmodel.F_CityCode = ipinfo["city_id"].ToString();
+                                    ipmodel.F_County = ipinfo["county"].ToString();
+                                    ipmodel.F_CountyCode = ipinfo["county_id"].ToString();
+                                    ipmodel.F_ISP = ipinfo["isp"].ToString();
+                                    ipmodel.F_ISPCode = ipinfo["isp_id"].ToString();
+                                    ipmodel.F_CreateTime = DateTime.Now;
+
+                                    cs.AddIP(ipmodel);
+                                    #endregion
+                                }
 
-                            msg.data = ipmodel;
+                                msg.data = ipmodel;
 
-                            #region 签入时间
-                            ChatSql.T_Chat_InOut inoutmodel = new ChatSql.T_Chat_InOut();
-                            inoutmodel.F_OpenId = cus.Code;
-                            inoutmodel.F_IP = ip;
-                            inoutmodel.F_Type = 2;
-                            inoutmodel.F_InTime = DateTime.Now;
+                                #region 签入时间
+                                ChatSql.T_Chat_InOut inoutmodel = new ChatSql.T_Chat_InOut();
+                                inoutmodel.F_OpenId = cus.Code;
+                                inoutmodel.F_IP = ip;
+                                inoutmodel.F_Type = 2;
+                                inoutmodel.F_InTime = DateTime.Now;
 
-                            cs.AddInOut(inoutmodel);
-                            #endregion
+                                cs.AddInOut(inoutmodel);
+                                #endregion
 
-                            cus.IPData = ipmodel;
-                            Customers.Add(cus);//将客户新增到在线客户列表
-
-                            ChatClass.Message serntcmsg = new ChatClass.Message();
-                            serntcmsg.action = "serreceive";
-                            serntcmsg.msg = cus.Name + " 上线";
-                            serntcmsg.code = cus.Code;
-                            serntcmsg.name = cus.Name;
-                            serntcmsg.data = ipmodel;
-                            serntcmsg.state = 0;
-                            SendMsgToRemotePoint(cus.ServicerSessionID, JsonConvert.SerializeObject(serntcmsg));
+                                cus.IPData = ipmodel;
+                                Customers.Add(cus);//将客户新增到在线客户列表
+
+                                ChatClass.Message serntcmsg = new ChatClass.Message();
+                                serntcmsg.action = "serreceive";
+                                serntcmsg.msg = cus.Name + " 上线";
+                                serntcmsg.code = cus.Code;
+                                serntcmsg.name = cus.Name;
+                                serntcmsg.data = ipmodel;
+                                serntcmsg.state = 0;
+                                SendMsgToRemotePoint(cus.ServicerSessionID, JsonConvert.SerializeObject(serntcmsg));
+                            }
+                            else
+                            {
+                                msg.code = "";
+                                msg.state = 0;
+                                msg.msg = "请不要打开多个聊天窗口";
+                            }
                         }
                         else
                         {
@@ -241,56 +262,63 @@ namespace CallCenter.WebChatServer
                         if (!cs.IsBlack(ip))
                         {
                             var cussend = Customers.Where(p => p.SessionID == session.SessionID).FirstOrDefault();
-
-                            if (Servicers.Count <= 0)
+                            if (cussend != null)
                             {
-                                cussend.IsSend = 1;
-
-                                msg.state = 0;
-                                msg.msg = ConfigurationManager.AppSettings["busy"];
-                            }
-                            else
-                            {
-                                if (string.IsNullOrEmpty(cussend.ServicerSessionID))
+                                if (Servicers.Count <= 0)
                                 {
-                                    cussend.ServicerSessionID = SplitCustomer(cussend);
-                                }
-                                ChatClass.Message serrecmsg = new ChatClass.Message();
-                                serrecmsg.action = "serreceive";
-                                serrecmsg.msg = msg.msg;
-                                serrecmsg.code = cussend.Code;
-                                serrecmsg.name = cussend.Name;
-                                serrecmsg.headimgurl = cussend.HeadImgUrl;
-                                serrecmsg.state = 1;
-                                if (SendMsgToRemotePoint(cussend.ServicerSessionID, JsonConvert.SerializeObject(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;
-
-                                    cs.AddMsg(cusmsg);
+                                    cussend.IsSend = 1;
+
+                                    msg.state = 0;
+                                    msg.msg = ConfigurationManager.AppSettings["busy"];
                                 }
                                 else
                                 {
-                                    //ChatClass.Message newmsg = new ChatClass.Message();
-                                    //newmsg.action = "CusSendError";
-                                    //newmsg.msg = "发送失败";
-                                    //session.Send(JsonConvert.SerializeObject(newmsg));
-
-                                    msg.state = 0;
-                                    msg.msg = "发送失败";
+                                    if (string.IsNullOrEmpty(cussend.ServicerSessionID))
+                                    {
+                                        cussend.ServicerSessionID = SplitCustomer(cussend);
+                                    }
+                                    ChatClass.Message serrecmsg = new ChatClass.Message();
+                                    serrecmsg.action = "serreceive";
+                                    serrecmsg.msg = msg.msg;
+                                    serrecmsg.code = cussend.Code;
+                                    serrecmsg.name = cussend.Name;
+                                    serrecmsg.headimgurl = cussend.HeadImgUrl;
+                                    serrecmsg.state = 1;
+                                    if (SendMsgToRemotePoint(cussend.ServicerSessionID, JsonConvert.SerializeObject(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;
+
+                                        cs.AddMsg(cusmsg);
+                                    }
+                                    else
+                                    {
+                                        //ChatClass.Message newmsg = new ChatClass.Message();
+                                        //newmsg.action = "CusSendError";
+                                        //newmsg.msg = "发送失败";
+                                        //session.Send(JsonConvert.SerializeObject(newmsg));
+
+                                        msg.state = 0;
+                                        msg.msg = "发送失败";
+                                    }
                                 }
                             }
+                            else
+                            {
+                                msg.state = 0;
+                                msg.msg = "发送失败";
+                            }
                         }
                         else
                         {

CallCenterCommon/CallCenter.WebChatServer/Program.cs

@@ -41,7 +41,7 @@ namespace CallCenter.WebChatServer
                             foreach (var cus in sr.Customers)
                             {
                                 var ser = sr.Servicers.Where(p => p.SessionID == cus.ServicerSessionID).FirstOrDefault();
-                                Console.WriteLine(cus.Name + "--" + (ser == null ? "未分配" : ser.Name + "(" + ser.Code + ")"));
+                                Console.WriteLine(cus.Name + "(" + cus.Code + ")--" + (ser == null ? "未分配" : ser.Name + "(" + ser.Code + ")"));
                             }
                             break;
                         case "4":