using CommonHelper;
using GasolineBlend.DAL;
using GasolineBlend.Entity;
using Microsoft.Office.Interop.Word;
using Newtonsoft.Json;
using Newtonsoft.Json.Linq;
using NPOI.SS.Formula.Functions;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Net.Http;
using System.Net.Http.Headers;
using System.Text;
using System.Text.RegularExpressions;
using System.Threading.Tasks;
using static GasolineBlend.Entity.SubsidyDataPage;
using RegexMatch = System.Text.RegularExpressions.Match;
using NPOIMatch = NPOI.SS.Formula.Functions.Match;
using static GasolineBlend.Entity.CozePage;
namespace GasolineBlend.BLL
{
    public class SubsidyDataBLL
    {
        private SubsidyDataDAL _sub = new SubsidyDataDAL();
        private SubsidyInquiryRecordDAL _sir = new SubsidyInquiryRecordDAL();
        private OrderDataDAL _acc = new OrderDataDAL();
        /// <summary>
        /// 获取用益信托网记录数据
        /// </summary>
        /// <returns></returns>
        public PaginatedResult<SubsidyDataPage> GetSubsidyDataList(int PageNumber, int PageSize, string Keyword, string CompanyName)
        {
            // 设置API的URL  
            string apiUrl = "http://open.api.tianyancha.com/services/open/ic/baseinfoV3/2.0";
            // 设置授权令牌  
            string authToken = "5d4c3939-53bb-422f-8ab6-91865b958e3a";
            // 设置请求的JSON内容  
            string Region = "";
            string City = "";
            // 创建HttpClient实例
            using (var client = new HttpClient())
            {
                // 添加Authorization头部
                client.DefaultRequestHeaders.Authorization = new AuthenticationHeaderValue(authToken);

                // 添加keyword参数到查询字符串
                var queryString = $"?keyword={Uri.EscapeDataString(CompanyName)}";

                // 构建完整的URL
                string fullUrl = apiUrl + queryString;

                try
                {
                    // 发送GET请求
                    HttpResponseMessage response = client.GetAsync(fullUrl).Result;

                    // 确保响应状态为成功
                    response.EnsureSuccessStatusCode();

                    // 读取响应内容
                    string responseBody = response.Content.ReadAsStringAsync().Result;
                    // 将JSON字符串反序列化为JObject
                    JObject jsonData = JObject.Parse(responseBody);
                    if ((int)jsonData["error_code"] != 0) {

                        return null;
                    }
                    // 访问嵌套的JSON属性
                    City = (string)jsonData["result"]["city"];
                    Region = (string)jsonData["result"]["district"];
                }
                catch (HttpRequestException e)
                {
                    LogHelper.Write(Level.Error, "获取政策列表数据 GetSubsidyDataListAPi查询", e, OperatorProvider.Instance.Current == null ? "GuestEx" : OperatorProvider.Instance.Current.LoginName);
                }
            }
            string Province = _sub.GetProvince(City, Region);
            int totalCount = _sub.GetSubsidyDataCount(Keyword, City, Region, Province);
            int totalPage = (int)Math.Ceiling((double)totalCount / PageSize);
            List<SubsidyDataPage> totalData = _sub.GetSubsidyDataList(PageNumber, PageSize, Keyword, City, Region, Province);
            return new PaginatedResult<SubsidyDataPage>(totalData, totalCount, totalPage);
        }



        public List<SubsidyDataPage> GetSubsidyDataFilter(string Keyword, string CompanyName)
        {
            // 设置API的URL  
            string apiUrl = "http://open.api.tianyancha.com/services/open/ic/baseinfoV3/2.0";
            // 设置授权令牌  
            string authToken = "5d4c3939-53bb-422f-8ab6-91865b958e3a";
            // 设置请求的JSON内容  
            string Region = "";
            string City = "";
            // 创建HttpClient实例
            using (var client = new HttpClient())
            {
                // 添加Authorization头部
                client.DefaultRequestHeaders.Authorization = new AuthenticationHeaderValue(authToken);

                // 添加keyword参数到查询字符串
                var queryString = $"?keyword={Uri.EscapeDataString(CompanyName)}";

                // 构建完整的URL
                string fullUrl = apiUrl + queryString;

                try
                {
                    // 发送GET请求
                    HttpResponseMessage response = client.GetAsync(fullUrl).Result;

                    // 确保响应状态为成功
                    response.EnsureSuccessStatusCode();

                    // 读取响应内容
                    string responseBody = response.Content.ReadAsStringAsync().Result;
                    // 将JSON字符串反序列化为JObject
                    JObject jsonData = JObject.Parse(responseBody);
                    if ((int)jsonData["error_code"] != 0)
                    {

                        return null;
                    }
                    // 访问嵌套的JSON属性
                    City = (string)jsonData["result"]["city"];
                    Region = (string)jsonData["result"]["district"];
                }
                catch (HttpRequestException e)
                {
                    LogHelper.Write(Level.Error, "获取政策列表数据 GetSubsidyDataListAPi查询", e, OperatorProvider.Instance.Current == null ? "GuestEx" : OperatorProvider.Instance.Current.LoginName);
                }
            }
            string Province = _sub.GetProvince(City, Region);
            List<SubsidyDataPage> totalData = _sub.GetSubsidyDataFilter( Keyword, City, Region, Province);
            return totalData;
        }
        //public string GetMoonshot(string CompanyName)
        //{
        //    string _apiKey = "sk-Lec41LGc7aV8KdFzOCiJQIM9A8bsbBk5KumvqBSyfeW9EXec"; // 替换为你的API密钥
        //    string _baseUrl = "https://api.moonshot.cn/v1"; // 确保URL是正确的
        //    string model = "moonshot-v1-32k";
        //    string systemMessage = "你是 Kimi，由 Moonshot AI 提供的人工智能助手，你更擅长中文和英文的对话。你会为用户提供安全，有帮助，准确的回答。同时，你会拒绝一切涉及恐怖主义，种族歧视，黄色暴力等问题的回答。Moonshot AI 为专有名词，不可翻译成其他语言。";
        //    string userMessage = $"{CompanyName}获得了哪些荣誉与资质？请列举一下，以Json格式输出。";
        //    double temperature = 0.3;


        //    var messages = new[]
        //    {
        //    new { role = "system", content = systemMessage },
        //    new { role = "user", content = userMessage }
        //};

        //    var requestContent = new
        //    {
        //        model = model,
        //        messages = messages,
        //        temperature = temperature
        //    };

        //    var json = JsonConvert.SerializeObject(requestContent);
        //    var httpContent = new StringContent(json, Encoding.UTF8, "application/json");

        //    using (var client = new HttpClient())
        //    {
        //        try
        //        {
        //            // 添加API密钥到请求头
        //            client.DefaultRequestHeaders.Add("Authorization", $"Bearer {_apiKey}");

        //            // 发送POST请求
        //            HttpResponseMessage response = client.PostAsync(_baseUrl + "/chat/completions", httpContent).Result;

        //            if (response.IsSuccessStatusCode)
        //            {
        //                string responseContent = response.Content.ReadAsStringAsync().Result;
        //                var completion = JsonConvert.DeserializeObject<dynamic>(responseContent);
        //                return completion.choices[0].message.content.ToString();
        //            }
        //            else
        //            {
        //                return $"Error: {response.StatusCode}";
        //            }
        //        }
        //        catch (Exception e)
        //        {
        //            return $"Exception caught: {e.Message}";
        //        }
        //    }
        //}

        public CozeResult<CozePage> GetPolicyApplied(string CompanyName)
        {
            try
            {
                // 设置API的URL
                string apiUrl = "https://api.coze.cn/v1/workflow/run";
                // 设置授权令牌
                string bearerToken = "pat_58jGFdi1EjYOZnLCJRe162Mq3E9Xary8gyXzTDKEvUn3wqXNi9WzGktFgHPK1oUa";
                // 设置请求的JSON内容
                string jsonContent = $@"{{
            ""workflow_id"": ""7427036924374892570"",
            ""parameters"": {{
            ""BOT_USER_INPUT"": """",
            ""keyword"": ""{CompanyName}获得了哪些荣誉与资质与公司成立日期""
        }}
    }}";

                using (HttpClient client = new HttpClient())
                {
                    HttpRequestMessage request = new HttpRequestMessage(HttpMethod.Post, apiUrl)
                    {
                        Content = new StringContent(jsonContent, Encoding.UTF8, "application/json")
                    };

                    request.Headers.Authorization = new System.Net.Http.Headers.AuthenticationHeaderValue("Bearer", bearerToken);

                    // 使用Task.Run来运行异步操作，并使用.Result获取结果
                    HttpResponseMessage response = System.Threading.Tasks.Task.Run(() => client.SendAsync(request)).Result;

                    if (response.IsSuccessStatusCode)
                    {

                        // 读取响应内容
                        string responseContent = System.Threading.Tasks.Task.Run(() => response.Content.ReadAsStringAsync()).Result;

                        // 解析JSON字符串
                        var rootObject = JObject.Parse(responseContent);
                        var codeToken = rootObject["code"].ToString();
                        int codeValue = int.Parse(codeToken);
                        if (codeValue != 0 )
                        {
                            var Serror = "[{ \"id\": -2, \"name\": -2, \"date\": -2}]";
                            var Jerror = JArray.Parse(Serror);
                            var Terror = Jerror.ToObject<List<CozePage>>();
                            var Error = new CozeResult<CozePage>(Terror);
                            return Error;
                        }
                        var data = rootObject["data"].ToString();

                        // 解析data字段中的JSON字符串
                        var dataObject = JObject.Parse(data);

                        // 提取output字段
                        var output = dataObject["output"];
                        // 修正JSON字符串中的属性分隔符
                        var outputJson = output.ToString().Replace("：", ":");
                        // 修正JSON字符串中的属性分隔符
                        outputJson = outputJson.ToString().Replace("，", ",");
                        if (outputJson == "-1")
                        {
                            return null;
                        }
                        // 解析output字段中的JSON数组字符串
                        var outputArray = JArray.Parse(outputJson);

                        // 将JArray转换为CozePage对象列表
                        var cozePages = outputArray.ToObject<List<CozePage>>();

                        // 创建CozeResult<CozePage>实例
                        var cozeResult = new CozeResult<CozePage>(cozePages);

                        return cozeResult;
                    }
                    else
                    {
                        Console.WriteLine("请求失败，状态码：" + response.StatusCode);
                        return null;
                    }
                }
            }
            catch (Exception ex)
            {
                Console.WriteLine("请求过程中发生错误：" + ex.Message);
                return null;
            }
        }

        public string GetPolicyAnswer(int UserId, string CompanyName)
        {
                try
                {
                 int IsVIP = _acc.GetIsPolicyVIPList(UserId);
                 int Count = _sir.GetSubsidyInquiryRecordToDayCount(UserId);
                    if (Count>= IsVIP) {
                        Console.WriteLine("今日政策洞察额度已经用完，如有需要请联系管理员!");
                        return "-1";
                    }
                //coze
                //                // 设置API的URL
                //                string apiUrl = "https://api.coze.cn/v1/workflow/run";
                //                // 设置授权令牌
                //                string bearerToken = "pat_58jGFdi1EjYOZnLCJRe162Mq3E9Xary8gyXzTDKEvUn3wqXNi9WzGktFgHPK1oUa";
                //                // 设置请求的JSON内容
                //                string jsonContent = $@"{{
                //        ""workflow_id"": ""7427048743201832975"",
                //        ""parameters"": {{
                //        ""BOT_USER_INPUT"": """",
                //        ""keyword"": ""{CompanyName}能申请哪些政策""
                //    }}
                //}}";
                //dify
                // 设置API的URL
                string apiUrl = "http://14.103.174.44/v1/workflows/run";
                // 设置授权令牌
                string bearerToken = "app-KTUm354NyhAylEhQGk7I7W2l";
                // 设置请求的JSON内容
                string jsonContent = $@"{{
            ""user"": ""rensofter"",
            ""response_mode"": ""blocking"",
            ""inputs"": {{
            ""company"": ""{CompanyName}""
                  }}
             }}";

                using (HttpClient client = new HttpClient())
                    {
                        HttpRequestMessage request = new HttpRequestMessage(HttpMethod.Post, apiUrl)
                        {
                            Content = new StringContent(jsonContent, Encoding.UTF8, "application/json")
                        };

                        request.Headers.Authorization = new System.Net.Http.Headers.AuthenticationHeaderValue("Bearer", bearerToken);

                        // 使用Task.Run来运行异步操作，并使用.Result获取结果
                        HttpResponseMessage response = System.Threading.Tasks.Task.Run(() => client.SendAsync(request)).Result;

                        if (response.IsSuccessStatusCode)
                        {
                            string responseContent = System.Threading.Tasks.Task.Run(() => response.Content.ReadAsStringAsync()).Result;

                            // 解析JSON字符串
                            var rootObject = JObject.Parse(responseContent);

                            // 提取data字段
                            var data = rootObject["data"].ToString();

                            // 解析data字段中的JSON字符串
                            var dataObject = JObject.Parse(data);

                            // 提取output字段
                            string outputs = dataObject["outputs"].ToString();
                        // 解析data字段中的JSON字符串
                        var datatxt = JObject.Parse(outputs);
                        // 提取output字段
                        string text = datatxt["data"].ToString();


                        bool isInsert = _sir.AddSubsidyInquiryRecordData(UserId, CompanyName, text);
                            if (!isInsert&& data == null)
                            {
                                Console.WriteLine("请求失败");
                                return null;
                            }
                            return text;
                        }
                        else
                        {
                            Console.WriteLine("请求失败，状态码：" + response.StatusCode);
                            return null;
                        }
                    }
                }
                catch (Exception ex)
                {
                    Console.WriteLine("请求过程中发生错误：" + ex.Message);
                    return null;
                }
        
        }
    }
}