using LogLibrary.Log;
using OfficeOpenXml.FormulaParsing.Excel.Functions.Text;
using System;
using System.Collections;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using WIDESEA_DTO.AGV;
using WIDESEA_IServices;
using WIDESEA_IStorageBasicRepository;
using WIDESEA_IStorageSocketServices;
using WIDESEA_IStorageTaskRepository;
using WIDESEA_IStorageTaskServices;
using WIDESEA_IStoragIntegrationServices;
using WIDESEA_Model.Models.AGV;
using WIDESEA_Repository;
using WIDESEA_StorageSocketServices;
using WIDESEAWCS_BasicInfoRepository;
using WIDESEAWCS_Model.Models;
using static WIDESEAWCS_BasicInfoService.Dt_StationManagerService;

namespace WIDESEA_StoragIntegrationServices
{
    public partial class AGVService : IAGVService
    {
        private readonly ILocationInfoRepository _locationRepository;
        private readonly IDt_TaskRepository BaseDal;
        private readonly IDt_TaskService _taskService;
        private readonly IStockInfoRepository _stockInfoRepository;
        private readonly ISys_ConfigService _configService;
        private readonly IDt_StationManagerRepository _stationManagerRepository;
        private readonly LogFactory LogFactory = new LogFactory();
        public SocketClientService _Socket { get; set; }
        private readonly IMapper _mapper;
        private readonly IDt_DeviceInfoRepository _deviceInfoRepository;
        private readonly IDt_HandAutomaticRepository _handAutomaticRepository;

        public AGVService(ILocationInfoRepository locationRepository, IDt_TaskRepository taskRepository, IStockInfoRepository stockInfoRepository, ISys_ConfigService configService, IDt_StationManagerRepository stationManagerRepository, IDt_DeviceInfoRepository deviceInfoRepository, IMapper mapper, SocketClientService socketClientService, IDt_TaskService taskService, IDt_HandAutomaticRepository handAutomaticRepository)
        {
            _locationRepository = locationRepository;
            BaseDal = taskRepository;
            _stockInfoRepository = stockInfoRepository;
            _configService = configService;
            _stationManagerRepository = stationManagerRepository;
            _deviceInfoRepository = deviceInfoRepository;
            _mapper = mapper;
            _Socket = socketClientService;
            _taskService = taskService;
            _handAutomaticRepository = handAutomaticRepository;
        }
        #region 外部接口方法

        /// <summary>
        /// 请求入库任务
        /// </summary>
        /// <param name="PallteCode"></param>
        /// <param name="SourceAddress"></param>
        /// <returns></returns>
        public WebResponseContent RequestInTask(AGVDTO aGVDTO)
        {
            WebResponseContent content = new WebResponseContent();
            try
            {
                var HandAutomatic = _handAutomaticRepository.QueryFirst(x => true && x.HandAutomatic == "Automatic");
                if (HandAutomatic == null)
                {
                    return content.Error("当前不是自动模式不可下发任务");
                }
                Dt_StationManager Instation = _stationManagerRepository.QueryFirst(x => x.stationName == aGVDTO.SourceAddress && x.stationType == 1);
                List<Dt_StationManager> Outstation = _stationManagerRepository.QueryData(x => x.stationType == 2).ToList();
                if (Instation == null)
                {
                    return content.Error("未找到入库站台信息");
                }
                Dt_Task task = BaseDal.QueryFirst(x => x.PalletCode == aGVDTO.PalletCode);
                if (task != null)
                {
                    return content.Error("该托盘已存在任务");
                }
                //StationStatus stationOut = _Socket.GetStationStatus("B001");
                List<OutStationStatus> outStationStatus = new List<OutStationStatus>();
                //List<OutStationStatus> outStationStatus = _Socket.GetOutStationStatus(stationOut);
                #region
                var taskOutStationO = BaseDal.QueryFirst(x => x.SourceAddress == "B001::1" || x.TargetAddress == "B001::1");
                var taskOutStationT = BaseDal.QueryFirst(x => x.SourceAddress == "B001::2" || x.TargetAddress == "B001::2");
                outStationStatus.Add(new OutStationStatus()
                {
                    StationName = "04",
                    StationEnable = aGVDTO.WorkstationO == "1" ? "0" : "1",
                    IsDistributionTask = taskOutStationO == null ? "0" : "1",
                    Spare1 = "00"
                });
                outStationStatus.Add(new OutStationStatus()
                {
                    StationName = "03",
                    StationEnable = aGVDTO.WorkstationT == "1" ? "0" : "1",
                    IsDistributionTask = taskOutStationT == null ? "0" : "1",
                    Spare1 = "00",

                });
                #endregion
                AGVStatusRespone status = _Socket.GetAGVStatus();
                HOSTAGVStatus AgvStatus = new HOSTAGVStatus()
                {
                    RuntimeStatus = _Socket.CapitalizeFirstLetter(status.RuntimeStatus),
                    AutoStatus = status.AutoStatus == "MaintenanceMode" ? "1" : "0",
                    Ready = status.AutoStatus == "MaintenanceMode" ? "0" : "1",
                };
                InStationStatus inStationStatus = new InStationStatus()
                {
                    StationName = Instation.HostName,
                    StationEnable = "0",
                    IsDistributionTask = "0",
                    PallteCode = aGVDTO.PalletCode,
                };
                _Socket.DeviceRequestInbound(AgvStatus, outStationStatus, inStationStatus);

                LogFactory.GetLog("入库请求").InfoFormat(true, $"请求参数：{JsonConvert.SerializeObject(aGVDTO)}", "");
                return content.OK("已下发入库任务");
            }
            catch (Exception ex)
            {
                return content.Error(ex.Message);
            }


        }

        public WebResponseContent ReceiveAGVRuntimeStatus(AGVStatus Status)
        {
            WebResponseContent content = new WebResponseContent();
            try
            {
                var HandAutomatic = _handAutomaticRepository.QueryFirst(x => true && x.HandAutomatic == "Automatic");
                if (HandAutomatic == null)
                {
                    _Socket.DeviceAutoStatusReport("1");
                    return content.OK();
                }
                Dt_DeviceInfo device = _deviceInfoRepository.QueryFirst(x => x.DeviceName == Status.AGVName);
                if (device != null)
                {
                    if (device.RuntimeStatus != Status.RuntimeStatus)
                    {
                        device.RuntimeStatus = Status.RuntimeStatus;
                        device.AutoStatus = Status.AutoStatus;
                        _deviceInfoRepository.UpdateData(device);
                        switch (Status.RuntimeStatus)
                        {
                            case "Run":
                                //运行
                                _Socket.DeviceStateReport("R");
                                Thread.Sleep(1000);
                                _Socket.JobReady("0");
                                break;
                            case "Idle":
                                //空闲
                                _Socket.DeviceStateReport("I");
                                _Socket.JobReady("1");
                                break;
                            case "Trouble":
                                //故障
                                _Socket.DeviceStateReport("T");
                                Thread.Sleep(1000);
                                _Socket.JobReady("0");
                                break;
                            case "Pause":
                                //暂停
                                _Socket.DeviceStateReport("S");
                                Thread.Sleep(1000);
                                _Socket.JobReady("0");
                                break;
                            case "Charge":
                                //充电
                                _Socket.DeviceStateReport("C");
                                Thread.Sleep(1000);
                                _Socket.JobReady("0");
                                break;
                            case "PowerOn":
                                //开机
                                _Socket.DeviceStateReport("P");
                                Thread.Sleep(1000);
                                _Socket.JobReady("0");
                                break;
                            case "PowerOFF":
                                //关机
                                _Socket.DeviceStateReport("O");
                                Thread.Sleep(1000);
                                _Socket.JobReady("0");
                                break;
                            default: break;
                        }
                    }
                    if (device.AutoStatus != Status.AutoStatus)
                    {
                        device.RuntimeStatus = Status.RuntimeStatus;
                        device.AutoStatus = Status.AutoStatus;
                        _deviceInfoRepository.UpdateData(device);
                        switch (Status.AutoStatus)
                        {
                            case "MaintenanceMode":
                                //手动
                                _Socket.DeviceAutoStatusReport("1");
                                Thread.Sleep(500);
                                break;
                            case "ControlMode":
                                //自动
                                _Socket.DeviceAutoStatusReport("0");
                                Thread.Sleep(500);
                                break;
                            default: break;
                        }
                    }
                }
                else
                {
                    Dt_DeviceInfo deviceInfo = new Dt_DeviceInfo()
                    {
                        DeviceName = Status.AGVName,
                        RuntimeStatus = Status.RuntimeStatus,
                        AutoStatus = Status.AutoStatus,
                    };
                    _deviceInfoRepository.AddData(deviceInfo);
                }

                LogFactory.GetLog("AGV状态变更").InfoFormat(true, $"请求参数：{JsonConvert.SerializeObject(Status)}", "");
                return content.OK();
            }
            catch (Exception ex)
            {
                return content.Error(ex.Message);
            }
        }


        public WebResponseContent AGVStartOrEndJob(AGVDTO aGVDTO)
        {
            WebResponseContent content = new WebResponseContent();
            try
            {
                Dt_Task task = BaseDal.QueryFirst(x => x.TaskNum == aGVDTO.TaskNum);
                if (task != null)
                {
                    if (task.Roadway == "PDA")
                    {
                        LogFactory.GetLog("AGV动作状态变更PDA任务").InfoFormat(true, $"请求参数：{JsonConvert.SerializeObject(aGVDTO)}", "");
                        if (aGVDTO.Status == "Start")
                        {
                            _taskService.TaskStatus(task);
                            return content.OK();
                        }
                        else if (aGVDTO.Status == "Unload")
                        {
                            return _taskService.TaskComplete(task.TaskNum);
                        }
                        else
                        {
                            return content.OK();
                        }
                    }
                    else
                    {
                        switch (task.TaskType)
                        {
                            case (int)TaskInboundTypeEnum.Inbound:
                                //入库
                                var station = _stationManagerRepository.QueryFirst(x => x.stationName == task.SourceAddress);
                                if (aGVDTO.Status == "Start")
                                {
                                    _Socket.JobStartOrEnd(aGVDTO.Status.Substring(0, 1), "0000" + station.HostName, task.TargetAddress, "I", task.PalletCode);
                                    task.TaskState = (int)TaskInStatusEnum.AGV_InExecuting;
                                }
                                else if (aGVDTO.Status == "Loadel")
                                {
                                    _Socket.PalletActionReport(aGVDTO.Status.Substring(0, 1), "0000" + station.HostName, task.TargetAddress, "I", task.PalletCode);
                                }
                                else
                                {
                                    _Socket.PalletActionReport(aGVDTO.Status.Substring(0, 1), "0000" + station.HostName, task.TargetAddress, "I", task.PalletCode);
                                    Thread.Sleep(2000);
                                    _Socket.PalletActionReport("0000" + station.HostName, task.TargetAddress, "I", task.PalletCode);
                                    task.TaskState = (int)TaskInStatusEnum.AGV_InFinish;
                                    _taskService.CompleteInboundTask(task);
                                }
                                break;
                            case (int)TaskOutboundTypeEnum.Outbound:
                                //出库
                                var stationOut = _stationManagerRepository.QueryFirst(x => x.stationName == task.TargetAddress);
                                if (aGVDTO.Status == "Start")
                                {
                                    _Socket.JobStartOrEnd(aGVDTO.Status.Substring(0, 1), task.SourceAddress, "0000" + stationOut.HostName, "O", task.PalletCode);
                                    task.TaskState = (int)TaskOutStatusEnum.AGV_OutExecuting;
                                }
                                else if (aGVDTO.Status == "Loadel")
                                {
                                    _Socket.PalletActionReport(aGVDTO.Status.Substring(0, 1), task.SourceAddress, "0000" + stationOut.HostName, "O", task.PalletCode);
                                }
                                else
                                {
                                    _Socket.PalletActionReport(aGVDTO.Status.Substring(0, 1), task.SourceAddress, "0000" + stationOut.HostName, "O", task.PalletCode);
                                    Thread.Sleep(2000);
                                    _Socket.PalletActionReport(task.SourceAddress, "0000" + stationOut.HostName, "O", task.PalletCode);
                                    task.TaskState = (int)TaskOutStatusEnum.AGV_OutFinish;
                                    _taskService.CompleteOutboundTask(task);
                                }
                                break;
                            case (int)TaskRelocationTypeEnum.Relocation:
                                if (aGVDTO.Status == "Start")
                                {
                                    _Socket.JobStartOrEnd(aGVDTO.Status.Substring(0, 1), task.SourceAddress, task.TargetAddress, "R", task.PalletCode);
                                    task.TaskState = (int)TaskRelocationStatusEnum.AGV_RelocationExecuting;
                                }
                                else if (aGVDTO.Status == "Loadel")
                                {
                                    _Socket.PalletActionReport(aGVDTO.Status.Substring(0, 1), task.SourceAddress, task.TargetAddress, "R", task.PalletCode);
                                }
                                else
                                {
                                    _Socket.PalletActionReport(aGVDTO.Status.Substring(0, 1), task.SourceAddress, task.TargetAddress, "R", task.PalletCode);
                                    Thread.Sleep(2000);
                                    _Socket.PalletActionReport(task.SourceAddress, task.TargetAddress, "R", task.PalletCode);
                                    task.TaskState = (int)TaskRelocationStatusEnum.AGV_RelocationFinish;
                                    _taskService.CompleteRelocationboundTask(task);
                                }
                                break;
                            case (int)TaskStationTypeEnum.StationToStation:
                                var stationIn = _stationManagerRepository.QueryFirst(x => x.stationName == task.SourceAddress);
                                var stationout = _stationManagerRepository.QueryFirst(x => x.stationName == task.TargetAddress);
                                if (aGVDTO.Status == "Start")
                                {
                                    _Socket.JobStartOrEnd(aGVDTO.Status.Substring(0, 1), "0000" + stationIn.HostName, "0000" + stationout.HostName, "S", task.PalletCode);
                                    task.TaskState = (int)TaskOutStatusEnum.AGV_OutExecuting;
                                }
                                else if (aGVDTO.Status == "Loadel")
                                {
                                    _Socket.PalletActionReport(aGVDTO.Status.Substring(0, 1), "0000" + stationIn.HostName, "0000" + stationout.HostName, "S", task.PalletCode);
                                }
                                else
                                {
                                    _Socket.PalletActionReport(aGVDTO.Status.Substring(0, 1), "0000" + stationIn.HostName, "0000" + stationout.HostName, "S", task.PalletCode);
                                    Thread.Sleep(2000);
                                    _Socket.PalletActionReport("0000" + stationIn.HostName, "0000" + stationout.HostName, "S", task.PalletCode);
                                    task.TaskState = (int)TaskOutStatusEnum.AGV_OutFinish;
                                    _taskService.TaskMoveHty(task);
                                }
                                break;
                            default: break;
                        }
                        BaseDal.Update(task);
                        LogFactory.GetLog("AGV动作状态变更").InfoFormat(true, $"请求参数：{JsonConvert.SerializeObject(aGVDTO)}", "");
                        return content.OK();
                    }     
                }
                else
                {
                    return content.Error("未找到任务!");
                }
            }
            catch (Exception ex)
            {
                return content.Error(ex.Message);
            }
        }


        public WebResponseContent DeviceErrorResponse(AGVDTO aGVDTO)
        {
            WebResponseContent content = new WebResponseContent();
            try
            {
                var task = BaseDal.QueryFirst(x => x.TaskNum == aGVDTO.TaskNum);
                if (task != null)
                {
                    switch (aGVDTO.Message)
                    {
                        case "RepeatInbound":

                            break;
                        case "EmptyOutbound":

                            break;
                        default: break;
                    }
                }
                return content.OK();
            }
            catch (Exception ex)
            {
                return content.Error(ex.Message);
            }
        }
        #endregion 外部接口方法
    }
}