using AKSWebBrowser.Commen;
using Newtonsoft.Json.Linq;
using Newtonsoft.Json;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Net.WebSockets;
using System.Text;
using System.Threading;
using System.Threading.Tasks;
using System.Net.Sockets;
using System.Timers;
using CPF.Mac.Foundation;
using CPF.Windows;

namespace AksWebBrowser.Common
{
    public class WebSocketClientWithHeartbeat
    {
        private readonly string _serverUri;
        private readonly ClientWebSocket _webSocket = new ClientWebSocket();
        public string funName = string.Empty;
        //开启定时
        System.Timers.Timer timer = new System.Timers.Timer(30000);
        public WebSocketClientWithHeartbeat()
        {
            try
            {
                _serverUri = Parame.smWebsocket;
                _webSocket.ConnectAsync(new Uri(_serverUri), CancellationToken.None);
                Task.WhenAll(ReceiveMessages(), SendHeartbeats());
            }
            catch (Exception ex)
            {
                Log.Error("连接双目webSocket" + ex.Message);
            }
        }

        /// <summary>
        /// 接收消息
        /// </summary>
        /// <returns></returns>
        private async Task ReceiveMessages()
        {
            while (_webSocket.State == WebSocketState.Open)
            {
                try
                {
                    var buffer = new byte[1024 * 1024 * 5];
                    var result = await _webSocket.ReceiveAsync(new ArraySegment<byte>(buffer), CancellationToken.None);
                    if (result.MessageType == WebSocketMessageType.Close)
                    {
                        // 关闭处理逻辑
                        await _webSocket.CloseAsync(WebSocketCloseStatus.NormalClosure, string.Empty, CancellationToken.None);
                    }
                    else
                    {
                        // 处理接收到的消息逻辑
                        string body = System.Text.Encoding.UTF8.GetString(buffer, 0, result.Count);
                        if (!string.IsNullOrEmpty(body))
                        {
                            JObject jo = (JObject)JsonConvert.DeserializeObject(body);
                            string functionName = jo["functionName"].ToString();
                            if (functionName == "LiveDetectResult")
                            {
                                string status = string.Empty;
                                if (body.Contains("success"))
                                {
                                    status = jo["success"].ToString();
                                }
                                if (string.IsNullOrEmpty(status))
                                {
                                    string nEventId = jo["nEventId"].ToString();
                                    if (nEventId == "100")
                                    {
                                        string results = Parame.ImgBase64;
                                        if (!string.IsNullOrEmpty(results))
                                        {
                                            JObject jo1 = (JObject)JsonConvert.DeserializeObject(results);
                                            string data = jo1["data"].ToString();
                                            jo1 = (JObject)JsonConvert.DeserializeObject(data);
                                            string data2 = jo1["Data"].ToString();
                                            jo1 = (JObject)JsonConvert.DeserializeObject(data2);
                                            string ImageBase64 = jo1["ImageBase64"].ToString();
                                            //var faceA = "/data/home/aks/aks/wwwroot/TmpFile/faceA.jpg";
                                            //var faceB = "/data/home/aks/aks/wwwroot/TmpFile/faceB.jpg";
                                            string faceA = Utils.Base64ByImagesPath(ImageBase64.Replace("data:image/jpg;base64,", ""), "");
                                            string faceB = Utils.Base64ByImagesPath(jo["ImgBase64"].ToString(), "faceB");
                                            var mode2 = new
                                            {
                                                function = "CF_FaceCompare",
                                                filePathA = faceA,
                                                filePathB = faceB
                                            };
                                            timer.Stop();
                                            //开始人脸比对
                                            Send(JsonConvert.SerializeObject(mode2), "CF_FaceCompare");
                                        }
                                        else
                                        {
                                            timer.Stop();
                                            results = "{\"timestamp\":\"" + Utils.GetTimestamp() + "\",\"keycode\":\"" + "aks100101" + "\",\"message\":\"fali\",\"code\":\"400\",\"status\":false,\"data\":\"" + "人证合一验证失败." + "\"}";
                                            Parame.socket.Send(results);
                                        }

                                    }
                                }
                            }
                            else if (functionName == "CF_FaceCompare")
                            {
                                //停止活检
                                Send("{\"function\":\"CF_StopLiveDetect\"}", "CF_StopLiveDetect");
                                //关闭摄像头
                                Send("{\"function\":\"CF_CloseCamera\"}", "CF_CloseCamera");
                                string status = jo["success"].ToString();
                                string results = string.Empty;
                                if (status == "0")
                                {
                                    results = Parame.ImgBase64;
                                }
                                else
                                {
                                    results = "{\"timestamp\":\"" + Utils.GetTimestamp() + "\",\"keycode\":\"" + "aks100101" + "\",\"message\":\"fali\",\"code\":\"400\",\"status\":false,\"data\":\"" + "人证合一验证失败." + "\"}";
                                }
                                timer.Stop();
                                Parame.socket.Send(results);
                            }
                        }
                    }
                }
                catch (Exception ex)
                {
                    Log.Error("接收消息双目websockt" + ex.Message);
                }
            }
        }

        /// <summary>
        /// 发送心跳
        /// </summary>
        /// <returns></returns>
        private async Task SendHeartbeats()
        {
            while (_webSocket.State == WebSocketState.Open)
            {
                try
                {
                    // 心跳消息逻辑
                    var heartbeat = "{\"function\":\"Heartbeat\"}";
                    var sendBuffer = System.Text.Encoding.UTF8.GetBytes(heartbeat);
                    await _webSocket.SendAsync(new ArraySegment<byte>(sendBuffer), WebSocketMessageType.Text, true, CancellationToken.None);
                    await Task.Delay(TimeSpan.FromSeconds(6), CancellationToken.None); //根据需要设置心跳间隔
                }
                catch (Exception ex)
                {
                    Log.Error("心跳消息逻辑双目websockt" + ex.Message);
                }
            }
        }

        /// <summary>
        /// 推送消息到双目websockt
        /// </summary>
        /// <param name="message"></param>
        /// <returns></returns>
        public async Task Send(string message, string _funName)
        {
            try
            {
                funName = _funName;
                Parame.messageData = string.Empty;
                if (_webSocket.State == WebSocketState.Open)
                {
                    // 发送消息到服务器
                    var buffer = System.Text.Encoding.UTF8.GetBytes(message);
                    await _webSocket.SendAsync(new ArraySegment<byte>(buffer), WebSocketMessageType.Text, true, CancellationToken.None);
                }
                if (_funName== "CF_StartLiveDetect")
                {
                    timer.Elapsed += OnTimedEvent;
                    timer.Enabled = true;//启动定时器
                }
            }
            catch (Exception ex)
            {
                Log.Error("推送消息到双目websockt" + ex.Message);
            }
        }



        //打开串口
        private void OnTimedEvent(Object source, ElapsedEventArgs e)
        {
            try
            {
                timer.Stop();
                //停止活检
                Send("{\"function\":\"CF_StopLiveDetect\"}", "CF_StopLiveDetect");
                //关闭摄像头
                Send("{\"function\":\"CF_CloseCamera\"}", "CF_CloseCamera");
                string results = "{\"timestamp\":\"" + Utils.GetTimestamp() + "\",\"keycode\":\"" + "aks100101" + "\",\"message\":\"fali\",\"code\":\"400\",\"status\":false,\"data\":\"" + "活体检测超时." + "\"}";
                Parame.socket.Send(results);
            }
            catch {  }
            finally { }
        }

        /// <summary>
        /// 关闭双目websockt
        /// </summary>
        /// <returns></returns>
        public async Task Close()
        {
            try
            {
                if (_webSocket.State == WebSocketState.Open)
                {
                    await _webSocket.CloseAsync(WebSocketCloseStatus.NormalClosure, string.Empty, CancellationToken.None);
                }
            }
            catch (Exception ex)
            {
                Log.Error("关闭双目websockt" + ex.Message);
            }
        }
    }
}