using HslCommunication;
using HslCommunication.WebSocket;
using Newtonsoft.Json;
using Newtonsoft.Json.Linq;
using OfficeOpenXml.FormulaParsing.Excel.Functions.Information;
using Quartz;
using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using WIDESEAWCS_Common;
using WIDESEAWCS_Common.TaskEnum;
using WIDESEAWCS_Core;
using WIDESEAWCS_Core.Helper;
using WIDESEAWCS_DTO.AGV;
using WIDESEAWCS_DTO.TaskInfo;
using WIDESEAWCS_DTO.WMS;
using WIDESEAWCS_ISystemServices;
using WIDESEAWCS_ITaskInfoRepository;
using WIDESEAWCS_ITaskInfoService;
using WIDESEAWCS_Model.Models;
using WIDESEAWCS_QuartzJob;
using WIDESEAWCS_TaskInfoRepository;
using WIDESEAWCS_Tasks.ConveyorLineJob;

namespace WIDESEAWCS_Tasks
{
    [DisallowConcurrentExecution]
    public class CommonAGVJob : JobBase, IJob
    {
        private readonly ITaskRepository _taskRepository;
        private readonly ITaskService _taskService;
        private readonly ISys_ConfigService _sys_ConfigService;
        public CommonAGVJob(ITaskRepository taskRepository, ITaskService taskService, ISys_ConfigService configService)
        {
            _taskRepository = taskRepository;
            _taskService = taskService;
            _sys_ConfigService = configService;
        }

        public Task Execute(IJobExecutionContext context)
        {
            var tasks = _taskRepository.QueryData(x => x.TaskState == (int)TaskInStatusEnum.InNew || x.TaskState == (int)TaskOutStatusEnum.OutNew).ToList();
            foreach (var item in tasks)
            {
                TaskModel taskModel = new TaskModel()
                {
                    taskType = item.TaskType.GetTaskTypeGroup() == TaskTypeGroup.InboundGroup ? "putaway" : "carry",
                    taskGroupCode = "taskGroupCode-001",
                    groupPriority = 0,
                    tasks = new List<TasksType>
                        {
                                new()
                                {
                                    taskCode="KH"+item.TaskNum.ToString(),
                                    taskPriority=0,
                                    taskDescribe = new TaskDescribeType
                                    {
                                        containerCode = item.PalletCode,
                                        containerType = "CT_KUBOT_STANDARD",
                                        fromLocationCode =  item.SourceAddress,
                                        toStationCode = "",
                                        toLocationCode = item.TargetAddress,
                                        deadline = 0,
                                    }
                                }
                        }
                };
                var wmsIpAddress = GetIpAddress(SysConfigKeyConst.ESSIP_BASE, SysConfigKeyConst.SendTask);
                var result = HttpHelper.PostAsync(wmsIpAddress, taskModel.ToJsonString()).Result;
                var response = JsonConvert.DeserializeObject<Response>(result);
                if (response != null && response.Msg == "success")
                {
                    //item.TaskState = item.TaskType.GetTaskTypeGroup() == TaskTypeGroup.InboundGroup ? (int)TaskInStatusEnum.HasSend : (int)TaskOutStatusEnum.HasSend;
                    //_taskRepository.Db.Updateable(item).ExecuteCommandAsync();
                    _taskService.UpdateTaskStatusToNext(item.TaskNum);
                }
            }
            return Task.CompletedTask;
        }

        private string GetIpAddress(string baseIp, string name)
        {
            var configz = _sys_ConfigService.GetConfigsByCategory(CateGoryConst.CONFIG_SYS_IPAddress);
            var wcsBasez = configz.Where(x => x.ConfigKey == baseIp).FirstOrDefault()?.ConfigValue;
            var address = configz.Where(x => x.ConfigKey == name).FirstOrDefault()?.ConfigValue;
            if (wcsBasez == null || address == null)
            {
                throw new InvalidOperationException("WMS IP 未配置");
            }
            return wcsBasez + address;
        }
    }
}