飞书

codegit/CallCenterApi/CallCenterApi.Interface/CallCenterApi.Interface/Configs/system.config

@@ -53,4 +53,9 @@
   <add key="AccessKeyID" value="LTAI5t74YpfDp5ULqyR78bPy" />
   <!-- 设置归属地查询AccessKeySecret -->
   <add key="AccessKeySecret" value="elRaejiGbEEp3SMy9uNNR2QkLd9ZjF" />
+
+ 
+  <add key="FeiShui_AppId" value="cli_a7242e417af7900c" />
+  
+  <add key="FeiShui_AppSecret" value="QJIWfIUKJjVLZgEl5JqxoguOYlnCphV5" />
 </appSettings>

codegit/CallCenterApi/CallCenterApi.Interface/CallCenterApi.Interface/Controllers/HomeController.cs

@@ -207,7 +207,17 @@ namespace CallCenterApi.Interface.Controllers
         {
             return "sss  " + name + pass;
         }
+        public ActionResult SendMessage(string mobile,string msg)
+        {
+            var result= FeiShuiHelper.SendMsg(mobile, msg);
+            return Content(result);
+        }
 
+        public ActionResult GetMobile(string code)
+        {
+            var result = FeiShuiHelper.GetUser(code);
+            return Content(result);
+        }
         /// <summary>
         /// 抛出HTTP 500
         /// </summary>

codegit/CallCenterApi/CallCenterApi.Interface/CallCenterApi.Interface/Controllers/Login/LoginController.cs

@@ -96,7 +96,78 @@ namespace CallCenterApi.Interface.Controllers
                 return Error("授权过期，请联系系统厂家。");
             }
         }
-      
+
+        //飞书免登陆
+        public ActionResult FeiShuilogin(string code)
+        {
+            var model = FeiShuiHelper.GetUser(code);
+            if (model!=null&&model.Length>=11)
+            {
+                model = model.Substring(model.Length - 11); ;
+            }
+             var  mdoel = new BLL.T_Sys_UserAccount().GetModelList($"F_Mobile='{model}' and  F_DeleteFlag=0");
+
+                if (mdoel != null&& mdoel.Count>0)
+                {
+                  var loginUser = mdoel.FirstOrDefault();
+                    string deptcode = "";
+                    Model.T_Sys_Department deptModel = new BLL.T_Sys_Department().GetModel(loginUser.F_DeptId);
+                    if (deptModel != null)
+                    {
+                        deptcode = deptModel.F_DeptCode;
+                    }
+                    //写入登录日志
+                    new CallCenterApi.BLL.T_Sys_LoginLogs().Add(new Model.T_Sys_LoginLogs()
+                    {
+                        F_LoginName = loginUser.F_UserName,
+                        F_LoginId = loginUser.F_UserId,
+                        F_Result = "登录成功",
+                        F_LoginIP = Common.DTRequest.GetIP(),
+                        F_Hostname = Common.DTRequest.GetIP(),
+                        F_LoginDate = DateTime.Now,
+                        F_Remark = "",
+                        F_State = 0
+                    });
+                    Cache.Models.CurrentUserInfo currentUserInfo = new Cache.Models.CurrentUserInfo()
+                    {
+                        F_UserId = loginUser.F_UserId,
+                        F_UserName = loginUser.F_UserName,
+                        F_UserCode = loginUser.F_UserCode,
+                        F_GroupId = loginUser.F_GroupId,
+                        F_RoleId = loginUser.F_RoleId,
+                        F_SeartGroupID = loginUser.F_SeartGroupID,
+                        F_WorkNumber = loginUser.F_WorkNumber,
+                        F_DeptId = loginUser.F_DeptId,
+                        F_DeptCode = deptcode
+                    };
+                    var token = FormsPrincipal<Cache.Models.CurrentUserInfo>.GetCookieValue(currentUserInfo.F_UserCode, currentUserInfo);
+
+                    //放入redis缓存
+                    RedisHelper.StringSet(token, currentUserInfo.ToJson(), new TimeSpan(24, 0, 0));
+
+                    return Success("登录成功", new
+                    {
+                        token = token
+                    });
+                }
+                else
+                {
+                    int rr = new BLL.T_Sys_LoginLogs().Add(new Model.T_Sys_LoginLogs()
+                    {
+                        F_LoginName = "飞书登录",
+                        F_LoginId = -1,
+                        F_Result = "登录失败：Code-" + code  + ";" ,
+                        F_LoginIP = Common.DTRequest.GetIP(),
+                        F_Hostname = Common.DTRequest.GetIP(),
+                        F_LoginDate = DateTime.Now,
+                        F_Remark = "",
+                        F_State = 0
+                    });
+                    return Error("用户不存在，请重新登录");
+                }
+
+        }
+
         public ActionResult Logout(string token = "")
         {
             int userId = CurrentUser.UserData.F_UserId;

codegit/CallCenterCommon/CallCenter.Utility/CallCenter.Utility.csproj

@@ -77,6 +77,7 @@
     <Compile Include="DirFileHelper.cs" />
     <Compile Include="EncryptHelper.cs" />
     <Compile Include="Extend\ExtLinq.cs" />
+    <Compile Include="FeiShuiHelper.cs" />
     <Compile Include="FileUp.cs" />
     <Compile Include="Linq\PredicateExtensionses.cs" />
     <Compile Include="NPOI\Ification.cs" />

codegit/CallCenterCommon/CallCenter.Utility/FeiShuiHelper.cs

@@ -0,0 +1,358 @@
+using Newtonsoft.Json;
+using System;
+using System.Collections.Generic;
+using System.IO;
+using System.Linq;
+using System.Net;
+using System.Net.Http;
+using System.Net.Http.Headers;
+using System.Text;
+
+namespace CallCenter.Utility
+{
+    public  class FeiShuiHelper
+    {
+        static  string app_id = Configs.GetValue("FeiShui_AppId");
+        static  string app_secret = Configs.GetValue("FeiShui_AppSecret");
+        //获取tenant_access_token
+        private static string GetTenantAccessToken()
+        {
+            string result = string.Empty;
+            var param = new
+            {
+                app_id = app_id,
+                app_secret = app_secret,
+               
+            };
+            var strresult = HttpMethods.HttpPost("https://open.feishu.cn/open-apis/auth/v3/tenant_access_token/internal", param.ToJson(),"application/json; charset=utf-8");
+            if (!string.IsNullOrEmpty(strresult))
+            {
+                var resultobj = strresult.ToJObject();
+                if (resultobj["code"].ToString() != "0")
+                {
+                    LogFactory.GetLogger("tenant_access_token").Error(strresult);
+                    result = resultobj["msg"].ToString();
+                }
+                else
+                {
+                    result = resultobj["tenant_access_token"].ToString();
+                }
+            }
+            return result;
+        }
+        //获取user_access_token
+        private static string GetUserAccessToken(string code)
+        {
+            string result = string.Empty;
+            var param = new
+            {
+                grant_type = "authorization_code",
+                client_id = app_id,
+                client_secret=app_secret,
+                code= code
+
+            };
+            var strresult = HttpMethods.HttpPost("https://open.feishu.cn/open-apis/authen/v2/oauth/token", param.ToJson(), "application/json; charset=utf-8");
+            if (!string.IsNullOrEmpty(strresult))
+            {
+                var resultobj = strresult.ToJObject();
+                if (resultobj["code"].ToString() != "0")
+                {
+                    LogFactory.GetLogger("error").Error(strresult);
+                    result = resultobj["error"].ToString();
+                }
+                else
+                {
+                    result = resultobj["access_token"].ToString();
+                }
+            }
+            return result;
+        }
+        //通过手机号获取用户id
+        private static string GetUserid(string mobile)
+        {
+            string result = string.Empty;
+
+            //Dictionary<string, object> param = new Dictionary<string, object>();
+            //param.Add("mobiles", new string[] { mobile });
+            //param.Add("include_resigned", true);
+            
+            var postData = new { mobiles = new string[] { mobile }, include_resigned = true };
+            var strresult = SendPostRequest
+         ("https://open.feishu.cn/open-apis/contact/v3/users/batch_get_id?user_id_type=user_id", postData);
+            if (!string.IsNullOrEmpty(strresult))
+            {
+                generalResult<userslist> resultobj = JsonConvert.
+                    DeserializeObject<generalResult<userslist>>(strresult);
+                if (resultobj.code != "0")
+                {
+                    LogFactory.GetLogger("GetUserid").Error(resultobj.msg);
+                    result = resultobj.msg;
+                }
+                else
+                {
+                   if (resultobj.data!=null&& resultobj.data.user_list.Count>0)
+                    result = resultobj.data.user_list[0].user_id;
+                }
+            }
+            return result;
+        }
+        //发送消息
+        public static string SendMsg(string mobile,string msg)
+        {
+            string userid = GetUserid(mobile);
+            if (string.IsNullOrEmpty(mobile))
+                return "";
+            Guid guid = Guid.NewGuid();
+            string uuid = guid.ToString();
+            string result = string.Empty;
+            //Dictionary<string, object> param = new Dictionary<string, object>();
+            //param.Add("receive_id", userid);
+            //param.Add("msg_type", "text");
+            //param.Add( "content", "{\"text\":\"" + msg + "\"}");
+            //param.Add("uuid", uuid);
+
+            var postData = new { receive_id = userid, msg_type = "post",
+                content = "{\"zh_cn\":{\"title\":\""+ msg + "\",\"content\":[[{\"tag\":\"text\",\"text\":\"地址 :\"},{\"tag\":\"a\",\"href\":\"http://www.feishu.cn\",\"text\":\"超链接\"}]]}}",
+                uuid = uuid,
+            };
+            var strresult = SendPostRequest
+         ("https://open.feishu.cn/open-apis/im/v1/messages?receive_id_type=user_id", postData);
+            if (!string.IsNullOrEmpty(strresult))
+            {
+                var resultobj = strresult.ToJObject();
+                if (resultobj["code"].ToString() != "0")
+                {
+                    LogFactory.GetLogger("SendMsg").Error(strresult);
+                    result = resultobj["msg"].ToString();
+                }
+                else
+                {
+                    result =  resultobj.ToJson() ;
+                }
+            }
+            return result;
+        }
+
+        //获取单个用户
+        public static string GetUser(string code)
+        {
+            string token = GetUserAccessToken(code);
+           
+            Guid guid = Guid.NewGuid();
+            string uuid = guid.ToString();
+            string result = string.Empty;
+            var strresult = SendGetRequest("https://open.feishu.cn/open-apis/authen/v1/user_info",token);
+            if (!string.IsNullOrEmpty(strresult))
+            {
+                generalResult<user> resultobj = JsonConvert.DeserializeObject<generalResult<user>>(strresult);
+                if (resultobj.code != "0")
+                {
+                    LogFactory.GetLogger("GetUser").Error(resultobj.msg);
+                    result = resultobj.msg;
+                }
+                else
+                {
+                    if (resultobj.data != null )
+                        result = resultobj.data.mobile;
+                }
+            }
+            return result;
+        }
+        public static string SendGetRequest(string url, string authToken)
+        {
+            // 创建请求对象
+            HttpWebRequest request = (HttpWebRequest)WebRequest.Create(url);
+            request.Method = "GET";
+            request.ContentType = "application/json; charset=utf-8"; // 设置 Content-Type
+            request.Headers.Add("Authorization", $"Bearer {authToken}");
+
+            // 如果需要忽略 SSL 证书验证（仅测试环境使用）
+            // ServicePointManager.ServerCertificateValidationCallback += 
+            //     (sender, certificate, chain, sslPolicyErrors) => true;
+
+            try
+            {
+                // 获取响应
+                using (HttpWebResponse response = (HttpWebResponse)request.GetResponse())
+                using (StreamReader reader = new StreamReader(response.GetResponseStream(), Encoding.UTF8))
+                {
+                    return reader.ReadToEnd();
+                }
+            }
+            catch (WebException ex)
+            {
+                // 处理错误响应
+                if (ex.Response is HttpWebResponse errorResponse)
+                {
+                    using (Stream errorStream = errorResponse.GetResponseStream())
+                    using (StreamReader reader = new StreamReader(errorStream, Encoding.UTF8))
+                    {
+                        string errorContent = reader.ReadToEnd();
+                        throw new Exception($"HTTP Error {(int)errorResponse.StatusCode}: {errorContent}");
+                    }
+                }
+                throw;
+            }
+        }
+    
+    public static string HttpGet(string url, string token)
+        {
+            ServicePointManager.Expect100Continue = true;
+            ServicePointManager.SecurityProtocol = SecurityProtocolType.Tls12 | SecurityProtocolType.Tls11 | SecurityProtocolType.Tls;
+            ServicePointManager.ServerCertificateValidationCallback = (sender, certificate, chain, errors) => true;
+            HttpClient client = new HttpClient();
+            client.DefaultRequestHeaders.Accept.Add(new MediaTypeWithQualityHeaderValue("application/json; charset=utf-8"));
+            client.DefaultRequestHeaders.Authorization = new
+                AuthenticationHeaderValue
+                ("Bearer", token);
+            var result = client.GetAsync(url).Result.Content.ReadAsStringAsync().Result;
+
+            return result;
+        }
+        public static string SendPostRequest(string url, object data)
+        {
+            string authToken = GetTenantAccessToken();
+            // 创建请求对象
+            HttpWebRequest request = (HttpWebRequest)WebRequest.Create(url);
+            request.Method = "POST";
+            request.ContentType = "application/json; charset=utf-8";
+
+            // 添加 Authorization 头
+            request.Headers.Add("Authorization", $"Bearer {authToken}");
+
+            // 如果需要忽略 SSL 证书验证（仅测试环境使用）
+            // ServicePointManager.ServerCertificateValidationCallback += 
+            //     (sender, certificate, chain, sslPolicyErrors) => true;
+
+            try
+            {
+                // 序列化数据为 JSON
+                string json = JsonConvert.SerializeObject(data);
+                byte[] postData = Encoding.UTF8.GetBytes(json);
+
+                // 写入请求体
+                request.ContentLength = postData.Length;
+                using (Stream stream = request.GetRequestStream())
+                {
+                    stream.Write(postData, 0, postData.Length);
+                }
+
+                // 获取响应
+                using (HttpWebResponse response = (HttpWebResponse)request.GetResponse())
+                using (StreamReader reader = new StreamReader(response.GetResponseStream(), Encoding.UTF8))
+                {
+                    return reader.ReadToEnd();
+                }
+            }
+            catch (WebException ex)
+            {
+                // 处理错误响应
+                if (ex.Response is HttpWebResponse errorResponse)
+                {
+                    using (Stream errorStream = errorResponse.GetResponseStream())
+                    using (StreamReader reader = new StreamReader(errorStream, Encoding.UTF8))
+                    {
+                        string errorContent = reader.ReadToEnd();
+                        throw new Exception($"HTTP Error {(int)errorResponse.StatusCode}: {errorContent}");
+                    }
+                }
+                throw;
+            }
+        }
+    
+    public static string HttpPost(string url, Dictionary<string, object> dic)
+        {
+            string result = ""; string token = GetTenantAccessToken();
+            try
+            {
+                // 创建 HttpWebRequest 对象
+                HttpWebRequest request = (HttpWebRequest)WebRequest.Create(url);
+                // 设置请求方法为 POST
+                request.Method = "POST";
+                // 设置 Content-Type
+                request.ContentType = "application/json; charset=utf-8";
+                // 设置 Authorization 头部
+                request.Headers.Add("Authorization", token);
+                var d = JsonConvert.SerializeObject(dic);
+                // 将请求体数据转换为字节数组
+                byte[] requestBodyBytes = Encoding.UTF8.GetBytes(d);
+                // 设置请求体的长度
+                request.ContentLength = requestBodyBytes.Length;
+
+                // 获取请求流
+                using (Stream requestStream = request.GetRequestStream())
+                {
+                    // 将请求体数据写入请求流
+                    requestStream.Write(requestBodyBytes, 0, requestBodyBytes.Length);
+                }
+
+                // 发送请求并获取响应
+                using (HttpWebResponse response = (HttpWebResponse)request.GetResponse())
+                {
+                    // 检查响应状态码
+                    if (response.StatusCode == HttpStatusCode.OK)
+                    {
+                        // 获取响应流
+                        using (Stream responseStream = response.GetResponseStream())
+                        {
+                            if (responseStream != null)
+                            {
+                                // 创建 StreamReader 用于读取响应流
+                                using (StreamReader reader = new StreamReader(responseStream, Encoding.UTF8))
+                                {
+                                    // 读取响应内容
+                                    string responseBody = reader.ReadToEnd();
+                                    Console.WriteLine("请求成功，响应内容：");
+                                    return responseBody;
+                                }
+                            }
+                        }
+                    }
+                    else
+                    {
+                        return $"请求失败，状态码：{response.StatusCode}";
+                    }
+                }
+            }
+            catch (WebException ex)
+            {
+                if (ex.Status == WebExceptionStatus.ProtocolError)
+                {
+                    HttpWebResponse errorResponse = (HttpWebResponse)ex.Response;
+                    return $"请求失败，状态码：{errorResponse.StatusCode}";
+                }
+                else
+                {
+                    return $"发生网络异常：{ex.Message}";
+                    
+                }
+            }
+            catch (Exception ex)
+            {
+                return $"发生异常：{ex.Message}";
+            }
+
+            return result;
+        }
+        private class generalResult<T> where T : class
+        {
+            public string code { get; set; }
+            public string msg { get; set; }
+            public T data { get; set; }
+        }
+        private class userlist
+        {
+            public string user_id { get; set; }
+        }
+        private class userslist
+        {
+            public List<userlist> user_list { get; set; }
+        }
+        private class user
+        {
+            public string mobile { get; set; }
+        }
+        
+    }
+}

codegit/CallCenterCommon/CallCenter.Utility/Http/HttpMethods.cs

@@ -19,7 +19,8 @@ namespace CallCenter.Utility
         /// <param name="url">URL.</param>
         /// <param name="param">POST的数据</param>
         /// <returns></returns>
-        public static string HttpPost(string url, string param = null)
+        public static string HttpPost(string url, string param = null, string contentType = "application/x-www-form-urlencoded"
+            )
         {
             HttpWebRequest request;
 
@@ -35,20 +36,21 @@ namespace CallCenter.Utility
                 request = WebRequest.Create(url) as HttpWebRequest;
             }
 
+
             request.Method = "POST";
-            request.ContentType = "application/x-www-form-urlencoded";
+            request.ContentType = contentType;
             request.Accept = "*/*";
             request.Timeout = 15000;
             request.AllowAutoRedirect = false;
 
-
-
             StreamWriter requestStream = null;
             WebResponse response = null;
             string responseStr = null;
 
             try
             {
+                LogFactory.GetLogger("HttpPost").Debug(url + "\r\n" + param + "\r\n");
+
                 requestStream = new StreamWriter(request.GetRequestStream());
                 requestStream.Write(param);
                 requestStream.Close();
@@ -60,10 +62,12 @@ namespace CallCenter.Utility
                     responseStr = reader.ReadToEnd();
                     reader.Close();
                 }
+
+                LogFactory.GetLogger("HttpPost").Debug(url + "\r\n" + param + "\r\n" + responseStr);
             }
-            catch (Exception)
+            catch (Exception ex)
             {
-                throw;
+                LogFactory.GetLogger("HttpPost").Error(url + "\r\n" + param + "\r\n" + ex.ToJson() + responseStr);
             }
             finally
             {
@@ -80,6 +84,9 @@ namespace CallCenter.Utility
         {
             return true; //总是接受  
         }
+
+
+       
         public static string BuildRequest(string strUrl, Dictionary<string, string> dicPara, string fileName)
         {
             string contentType = "image/jpeg";

codegit/CallCenterCommon/CallCenter.Utility/ImageUpload.cs

@@ -682,8 +682,9 @@ namespace CallCenter.Utility
                 _Error = 0;
                 return;
             }
-            catch
+            catch(Exception E)
             {
+                LogFactory.GetLogger("").Error(E.ToJson());
                 _Error = 4;
                 return;
             }