using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using IStation.Untity;
using SuperSocket;

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}！");

                var configure = string.IsNullOrEmpty(mySession.RegisterCode) ? ConfigureList.Find(x => x.ConfigureParas.RegisterCode == message_str)
                    : ConfigureList.Find(x => x.ConfigureParas.RegisterCode == mySession.RegisterCode);
                if (configure == null)
                {
                    LogHelper.Info($"Socket数据对接任务中,端口：{mySession.Server.Options.Listeners.First().Port},收到一条无法识别的消息：{message_str}");
                    return;
                }

                //session初始化
                mySession.SessionName = configure.Name;
                mySession.RegisterCode = configure.ConfigureParas.RegisterCode;
                mySession.Heartbeat = configure.ConfigureParas.Heartbeat;

                //创建对接对象
                var dataDocking = DataDockingSocketFactory.CreateSocket<IDataDockingSocket.IHandleHelper>(configure.ConfigureParas.DependencyFile);
                if (dataDocking == null)
                {
                    LogHelper.Info($"Socket数据对接中,{configure.Name},创建数据对接对象失败！");
                    return;
                }
                if (message_str == mySession.RegisterCode)
                {
                    LogHelper.Info($"Socket数据对接中,{configure.Name},接收到注册码：{message_str}");
                    dataDocking.HandleRegisterCode(mySession);
                }
                else if (message_str == mySession.Heartbeat)
                {
                    LogHelper.Info($"Socket数据对接中,{configure.Name},接收到心跳包：{message_str}");
                    dataDocking.HandleHeartbeat(mySession);
                }
                else
                {
                    LogHelper.Info($"Socket数据对接中,{configure.Name}，接收到数据：{message_bts}");
                    dataDocking.HandleData(mySession, requestInfo.Body, configure.Mappers, (receive_list) =>
                    {
                        if (receive_list == null || receive_list.Count < 1)
                        {
                            LogHelper.Info($"Socket数据对接中，注册码:{configure.Name},获取测点记录失败！");
                            return;
                        }
                        var queue = new RabbitMqQueueHelper();
                        queue.Push(ConfigHelper.QueueName, new Model.MonitorDataDockingCorpRecord()
                        {
                            CorpID = configure.CorpID,
                            ConfigureID = configure.ID,
                            Records = receive_list
                        });
                        LogHelper.Info($"Socket数据对接中:{configure.Name}，成功推入通道{receive_list.Count()}条数据！");
                    });
                }


            });


        }


    }
}