using Microsoft.AspNetCore.Authorization;
using Microsoft.AspNetCore.Mvc;
using RYB_PTL_API;
using System.Collections.Generic;
using System.Linq;
using WIDESEAWCS_DTO;
using WIDESEAWCS_DTO.TaskInfo;
using WIDESEAWCS_ITaskInfoService;

namespace WIDESEAWCS_Server.Controllers
{
    [Route("PTL")]
    [ApiController]
    public class PTLAPIController : ControllerBase
    {
        private readonly ITaskService _taskService;
        private bool _eventSubscribed = false;

        public PTLAPIController(ITaskService taskService)
        {
            _taskService = taskService;
            SubscribeEvent();
        }

        /// <summary>
        /// 订阅PTL事件
        /// </summary>
        private void SubscribeEvent()
        {
            if (!_eventSubscribed)
            {
                RYB_PTL.UserResultAvailable += new RYB_PTL.UserResultAvailableEventHandler(RYB_PTL_UserResultAvailable);
                _eventSubscribed = true;
            }
        }
        
        /// <summary>
        /// 取消订阅PTL事件
        /// </summary>
        private void UnsubscribeEvent()
        {
            if (_eventSubscribed)
            {
                RYB_PTL.UserResultAvailable -= new RYB_PTL.UserResultAvailableEventHandler(RYB_PTL_UserResultAvailable);
                _eventSubscribed = false;
            }
        }
        /// <summary>
        /// PTL回调事件处理（只处理手拍事件）
        /// </summary>
        private void RYB_PTL_UserResultAvailable(RYB_PTL.RtnValueStruct rs)
        {
            try
            {
                if (rs.KeyCode == null)
                {
                    return;
                }
                // 构建回调数据
                var pTLCallBackDTO = new PTLCallBackDTO
                {
                    sIp = rs.Ip,
                    sTagID = rs.Tagid,
                    sValue = rs.Number,
                    sKeyCode = rs.KeyCode,
                    sLocator = rs.Locator
                };

                // 根据业务需要构建任务信息
                var taskBackLight = new TaskBackLight()
                {
                    TagNo = "B1", 
                    TagCode = pTLCallBackDTO.sLocator,
                };

                // 调用服务处理手拍事件
                _taskService.WMSLightBack(new List<TaskBackLight> { taskBackLight });
                UnsubscribeEvent();
            }
            catch (Exception ex)
            {
                // 记录日志或处理异常
                Console.WriteLine($"处理PTL手拍回调时出错: {ex.Message}");
            }
        }
        /// <summary>
        /// 播种墙下发(一期)
        /// </summary>
        [HttpPost, Route("RYB_PTL_CloseDigit5"), AllowAnonymous]
        public EPLightContent RYB_PTL_CloseDigit5([FromBody] CloseDigit5DTO request)
        {
            var content = new EPLightContent();
            try
            {
                bool isConnected = RYB_PTL.RYB_PTL_DspDigit5(
                    request.sIP,
                    request.sTagID,
                    request.iNum,
                    request.iMode,
                    request.iColorIndex);
            }
            catch (Exception ex)
            {
                return content.Error(ex.Message);
            }
            return content;
        }
        /// <summary>
        /// 回调上传
        /// </summary>
        /// <returns></returns>
        [HttpPost, Route("RYB_PTL_UserResultAvailable"), AllowAnonymous]
        public EPLightContent? RYB_PTL_UserResultAvailable([FromBody] List<PTLCallBackDTO> pTLCallBackDTOs)
        {
            EPLightContent content = new EPLightContent();
            try
            {
                if (pTLCallBackDTOs == null)
                {
                    return content.Error("传入不能为空");
                }

                List<TaskBackLight> taskBackLights = pTLCallBackDTOs.Select(x => new TaskBackLight()
                {
                    TagNo = "B1",
                    TagCode = x.sLocator,
                }).ToList();
                content = _taskService.WMSLightBack(taskBackLights);
            }
            catch (Exception ex)
            {
                content.Error(ex.Message);
            }
            return content;
        }

        /// <summary>
        /// 播种墙初始化(一期)
        /// </summary>
        /// <returns></returns>
        [HttpPost, Route("RYB_PTL_Connect"), AllowAnonymous]
        public EPLightContent RYB_PTL_Connect([FromBody] ConnectDTO request)
        {
            EPLightContent content = new EPLightContent();
            try
            {
                //RYB_PTL.UserResultAvailable += new RYB_PTL.UserResultAvailableEventHandler(RYB_PTL_UserResultAvailable);
                bool isCfg = RYB_PTL.RYB_PTL_InitialConfiguration(new string[,] { { "11.2.30.252", "0001-0016" },{ "11.2.30.252", "1-16" } });
                bool isConnected = RYB_PTL.RYB_PTL_Connect(request.sIp, request.iPort);
            }
            catch (Exception ex)
            {
                content.Error(ex.Message);
            }
            return content;
        }

        /// <summary>
        /// 播种墙结束作业(一期)
        /// </summary>
        /// <returns></returns>
        [HttpPost, Route("RYB_PTL_Disconnect"), AllowAnonymous]
        public EPLightContent RYB_PTL_Disconnect()
        {
            EPLightContent content = new EPLightContent();
            try
            {
                bool isDisconnected = RYB_PTL.RYB_PTL_Disconnect();
            }
            catch (Exception ex)
            {
                content.Error(ex.Message);
            }
            return content;
        }

        /// <summary>
        /// 资源释放（标记为不暴露给Swagger）
        /// </summary>
        [ApiExplorerSettings(IgnoreApi = true)]
        public void Dispose()
        {
            UnsubscribeEvent();
        }
    }
}