using CoreCms.Net.Configuration;
using CoreCms.Net.IRepository.UnitOfWork;
using CoreCms.Net.IServices;
using CoreCms.Net.IServices.CYOAServices;
using CoreCms.Net.Loging;
using EC_SeckillInfo;
using Essensoft.Paylink.Alipay.Notify;
using InitQ.Abstractions;
using InitQ.Attributes;
using Newtonsoft.Json;
using Newtonsoft.Json.Linq;
using NPOI.HSSF.Record;
using SqlSugar;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Net.Http;
using System.Text;
using System.Text.Json;
using System.Threading.Tasks;

namespace CoreCms.Net.RedisMQ
{
    public class CyPlanOderMq: IRedisSubscribe
    {
        private readonly ISqlSugarClient _CyDbClient;
        private readonly IUnitOfWork _UnitOfWork;
        private readonly IApiService _ApiService;
      
        public CyPlanOderMq(IUnitOfWork UnitOfWork,IApiService apiService)
        {
             _UnitOfWork = UnitOfWork;
            _CyDbClient = UnitOfWork.GetDbClient().GetConnection(AppSettingsConstVars.CYDbDbID);
            _ApiService = apiService;
         
        }
        /// <summary>
        /// 处理队列
        /// </summary>
        /// <param name="DeliverOrderTarcks"></param>
        /// <returns></returns>
        [Subscribe(RedisMessageQueueKey.CyDeliverOrderTarcks)]
        private async Task Set(string DeliverOrderTarcks)
        {
            var notify = JsonConvert.DeserializeObject<TracksDto>(DeliverOrderTarcks);
            if(notify != null)
            {
             var lisrId=   await  _CyDbClient.Queryable<CoreDeliverOrder>().Where(x => x.OrderState == CoreDeliverOrderType.Start&&x.DeliveryMoble== notify.Moble).Select(x=>x.id).ToListAsync();

                if(lisrId != null&&lisrId.Count>0)
                {
                    var tarklist = new List< CoreDeliveryOrderTracks>();
                    //需要写入
                     foreach(var item in lisrId)
                    {
                        tarklist.Add(new CoreDeliveryOrderTracks
                        {
                            CreateBy = notify.Moble,
                            CreateTime = notify.CreateTime,
                            Latitude = notify.Latitude,
                            Longitude = notify.Longitude,
                            id= Guid.NewGuid(),
                            OrderID=item,
                        });
                        
                    }
                   await  _CyDbClient.Insertable(tarklist).ExecuteCommandAsync();
                }

            }
        }

        /// <summary>
        /// 调用计算结余接口
        /// </summary>
        /// <param name="msgID"></param>
        /// <returns></returns>
        [Subscribe(RedisMessageQueueKey.CyDeliverOAjisuanjine)]
        private async Task CyDeliverOAjisuanjine(string msgID)
        {
            // 创建 HttpClient 实例
            using (var client = new HttpClient())
            {
                // 设置请求 URL
                string url = $"{AppSettingsConstVars.CYOAHttps}/Pages/business/jisuanjine.aspx?tmp={new Random().Next()}&Target=jisuanorderJine&OrderId={msgID}";

                // 设置请求头
                client.DefaultRequestHeaders.Add("Cookie", "ASP.NET_SessionId=d2u3uyhydzml21wnlcir1dh0");

                // 创建 HTTP POST 请求
                var request = new HttpRequestMessage(HttpMethod.Post, url);


                // 发送请求并获取响应
                try
                {
                    using (var response = await client.SendAsync(request))
                    {
                        // 确保请求成功
                        response.EnsureSuccessStatusCode();

                        try
                        {
                            // 读取响应内容
                            string responseBody = await response.Content.ReadAsStringAsync();

                            try
                            {
                                JObject jsonObject = JObject.Parse(responseBody.ToLower());

                                if ("True" == (string)jsonObject["status"])
                                {
                                    return;
                                }
                                else
                                {
                                    NLogUtil.WriteAll(NLog.LogLevel.Error, LogType.PcWeb, "调用CYOA后台返回错误", JsonConvert.SerializeObject(new { url, responseBody }));
                                }
                            }
                            catch (Exception e)
                            {

                                NLogUtil.WriteAll(NLog.LogLevel.Error, LogType.PcWeb, "调用CYOA后台返回错误", JsonConvert.SerializeObject(new { url, responseBody }));
                            }

                        }
                        catch (Exception e)
                        {

                            NLogUtil.WriteAll(NLog.LogLevel.Error, LogType.PcWeb, "调用CYOA后台链接错误", JsonConvert.SerializeObject(new { url, e.Message, e.StackTrace }));
                        }

                    }
                }
                catch (Exception e)
                {

                    NLogUtil.WriteAll(NLog.LogLevel.Error, LogType.PcWeb, "调用CYOA后台链接错误", JsonConvert.SerializeObject(new { url, e.Message, e.StackTrace }));
                }
                
            }
        }
    }
}