using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using IStation.Untity;
using SuperSocket;
using static Org.BouncyCastle.Math.EC.ECCurve;

namespace IStation.Server
{
    /// <summary>
    /// 接收信息辅助类
    /// </summary>
    internal class PackageHandleHelper
    {
        public static List<Model.DataDockingConfigureExSocket> ConfigureList { get; set; }

        //接收数据
        public async ValueTask Handle(IAppSession session, PackageInfo requestInfo)
        {
            await Task.Run(() =>
            {
                var mySession = (MySession)session;
                if (ConfigureList == null || ConfigureList.Count < 1)
                {
                    LogHelper.Info("Socket数据对接任务中，未检索到采用Socket方式的数据对接配置！");
                    return;
                }

                var message_str = BytesTransfer.ToString(requestInfo.Body);
                var message_bts = BitTransfer.ToString(requestInfo.Body);
                LogHelper.Info($"Socket数据对接服务端口:{session.Server.Options.Listeners.First().Port}，接收到数据：{message_bts}！");

                bool reslut = false;
                foreach (var config in ConfigureList)
                {
                    var customDataDocking = DataDockingSocketFactory.CreateSocket<IDataDockingSocket.IHandleHelper>(config.ConfigureParas.DependencyFile);
                    if (customDataDocking.Valid(requestInfo.Body))
                    {
                        LogHelper.Info($"Socket数据对接中,{config.Name}，接收到数据：{message_bts}");
                        customDataDocking.HandleData(mySession, requestInfo.Body, config.Mappers, (receive_list) =>
                        {
                            if (receive_list == null || receive_list.Count < 1)
                            {
                                LogHelper.Info($"Socket数据对接中，注册码:{config.Name},获取测点记录失败！");
                                return;
                            }
                            var queue = new RabbitMqQueueHelper();
                            queue.Push(ConfigHelper.QueueName, new Model.MonitorDataDockingCorpRecord()
                            {
                                CorpID = config.CorpID,
                                ConfigureID = config.ID,
                                Records = receive_list
                            });
                            LogHelper.Info($"Socket数据对接中:{config.Name}，成功推入通道{receive_list.Count()}条数据！");
                        });
                        return;
                    }
                }

                if (!reslut)
                {
                    LogHelper.Info($"自定义Socket数据对接任务中,端口：{mySession.Server.Options.Listeners.First().Port},收到一条无法识别的消息：{message_str}");
                }

            });

        }


    }
}