using Furion.DatabaseAccessor;
using Furion.DependencyInjection;
using Furion.DynamicApiController;
using Furion.Extensions;
using iWare.Wms.Core;
using iWare.Wms.Core.Enum;
using Microsoft.AspNetCore.Authorization;
using Microsoft.AspNetCore.Mvc;
using Microsoft.EntityFrameworkCore;
using StackExchange.Redis;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Xml.Linq;

namespace iWare.Wms.Application.Service.Wmsjob.AgvTask
{
    /// <summary>
    /// AGV访问接口
    /// </summary>
    [ApiDescriptionSettings("仓库作业", Name = "AgvCallback", Order = 100)]
    [Route("api/agv/[Controller]")]
    public class AgvCallbackService : IDynamicApiController, ITransient
    {
        private readonly IRepository<WareTask, MasterDbContextLocator> _wareTask;
        private readonly IRepository<WareTaskSub, MasterDbContextLocator> _wareTaskSub;
        private readonly IRepository<WareDeviceWarning, MasterDbContextLocator> _wareDeviceWarning;
        private readonly IRepository<WareTaskBak, MasterDbContextLocator> _wareTaskBak;
        private readonly IRepository<WareTaskSubBak, MasterDbContextLocator> _wareTaskSubBak;

        public AgvCallbackService(
            IRepository<WareTask, MasterDbContextLocator> wareTask,
            IRepository<WareTaskSub, MasterDbContextLocator> wareTaskSub,
            IRepository<WareDeviceWarning, MasterDbContextLocator> wareDeviceWarning,
            IRepository<WareTaskBak, MasterDbContextLocator> wareTaskBak,
            IRepository<WareTaskSubBak, MasterDbContextLocator> wareTaskSubBak
       )
        {
            _wareTask = wareTask;
            _wareDeviceWarning = wareDeviceWarning;
            _wareTaskSub = wareTaskSub;
            _wareTaskBak = wareTaskBak;
            _wareTaskSubBak = wareTaskSubBak;
        }

        /// <summary>
        /// 分页查询任务管理
        /// </summary>
        /// <param name="input"></param>
        /// <returns></returns>
        [HttpPost("agvCallback")]
        [AllowAnonymous]
        public async Task<AgvCommonResponseDto> Method([FromBody] AgvCallbackInput input)
        {
            AgvCommonResponseDto agvCommonResponseDto = new AgvCommonResponseDto()
            {
                code = "0",
                message = "成功",
                reqCode = input.reqCode
            };
            List<WareTask> wareTasks = new List<WareTask>();
            List<WareTaskBak> wareTaskBaks = new List<WareTaskBak>();
            var taskSub = await _wareTaskSub.Where(u => u.AgvTaskCode == input.taskCode).FirstOrDefaultAsync();

            if (taskSub == null)
            {
                if (input.method == "end")
                {
                    var taskSubbak = await _wareTaskSubBak.DetachedEntities.Where(u => u.AgvTaskCode == input.taskCode).FirstOrDefaultAsync();
                    if (taskSubbak != null)
                    {
                        var taskbak = await _wareTaskBak.Where(u => u.Id == taskSubbak.TaskId).FirstOrDefaultAsync();
                        if (taskbak != null)
                        {
                            taskbak.FinishedTime = DateTimeOffset.Now;
                            wareTaskBaks.Add(taskbak);
                        }
                    }
                }
                return agvCommonResponseDto;
            }
            switch (input.method)
            {
                case "start":
                    taskSub.TaskState = (int)SubTaskStateEnum.执行中;
                    taskSub.AgvCode = input.robotCode;
                    taskSub.AgvTaskCode = input.taskCode;
                    var task = await _wareTask.Where(u => u.Id == taskSub.TaskId).FirstOrDefaultAsync();
                    if (task != null)
                    {
                        task.AgvCode = input.robotCode;
                        wareTasks.Add(task);
                    }
                    break;
                case "outbin":
                    taskSub.TaskState = (int)SubTaskStateEnum.离开储位;
                    var task1 = await _wareTask.Where(u => u.Id == taskSub.TaskId).FirstOrDefaultAsync();
                    if (task1 != null)
                    {
                        task1.AgvCode = input.robotCode;
                        wareTasks.Add(task1);
                    }
                    break;
                case "applyIn":
                    taskSub.TaskState = (int)SubTaskStateEnum.请求进;
                    var task2 = await _wareTask.Where(u => u.Id == taskSub.TaskId).FirstOrDefaultAsync();
                    if (task2 != null)
                    {
                        task2.AgvCode = input.robotCode;
                        wareTasks.Add(task2);
                    }
                    break;
                case "arrived":
                    taskSub.TaskState = (int)SubTaskStateEnum.进到位;
                    break;
                case "applyOut":
                    taskSub.TaskState = (int)SubTaskStateEnum.请求出;
                    break;
                case "出到位":
                    taskSub.TaskState = (int)SubTaskStateEnum.出到位;
                    break;
                case "release":
                    taskSub.TaskState = (int)SubTaskStateEnum.离开;
                    break;
                case "end":
                    taskSub.TaskState = (int)SubTaskStateEnum.已完成;
                    var isExist = _wareTaskSub.Any(u => u.TaskId == taskSub.TaskId && u.TaskState != (int)SubTaskStateEnum.已完成 && u.Id != taskSub.Id);
                    if (!isExist)
                    {
                        var maintask = _wareTask.Where(u => u.Id == taskSub.TaskId).FirstOrDefault();
                        if (maintask != null)
                        {
                            maintask.TaskState = TaskStateEnum.已完成;
                            wareTasks.Add(maintask);
                        }
                    }
                    break;
                case "cancel":
                    taskSub.TaskState = (int)SubTaskStateEnum.已取消;
                    break;
            }

            using (var tran = await _wareTaskSub.Database.BeginTransactionAsync())
            {
                try
                {
                    await _wareTaskSub.UpdateAsync(taskSub);
                    if (wareTasks != null && wareTasks.Count != 0)
                    {
                        await _wareTask.UpdateAsync(wareTasks);
                    }
                    if (wareTaskBaks != null && wareTaskBaks.Count > 0)
                    {
                        await _wareTaskBak.UpdateAsync(wareTaskBaks);
                    }
                    await tran.CommitAsync();
                }
                catch
                {
                    await tran.RollbackAsync();
                }
            }
            return agvCommonResponseDto;
        }

        /// <summary>
        /// 分页查询任务管理
        /// </summary>
        /// <param name="input"></param>
        /// <returns></returns>
        [HttpPost("agvCallbackService/warnCallback")]
        [AllowAnonymous]
        public async Task<AgvCommonResponseDto> WarnMethod([FromBody] AgvWarnCallbackDto input)
        {
            AgvCommonResponseDto agvCommonResponseDto = new AgvCommonResponseDto()
            {
                code = "0",
                message = "成功",
                reqCode = input.reqCode
            };
            List<WareDeviceWarning> update = new List<WareDeviceWarning>();
            List<WareDeviceWarning> insert = new List<WareDeviceWarning>();
            //查询当前所有AGV报警
            var warnlist = await _wareDeviceWarning.Where(u => u.DeviceCode == "1099" && u.Status == 0).ToListAsync();
            var strlist = input.data.Select(u => u.warnContent).ToList();
            var strlist2 = warnlist.Select(u => u.WarningContent).ToList();
            var nowDate = DateTime.Now;
            var msg = "";
            foreach (var item in warnlist)
            {
                if (!strlist.Contains(item.WarningContent))//不包含，结束报警
                {
                    item.UpdatedTime = nowDate;
                    item.UpdatedUserName = "WMS";
                    item.Status = 1; //状态（0：新建 1：已处理）
                    item.StatusName = "已处理";
                    item.CloseContent = "WMS关闭";
                    item.FinishTime = nowDate;
                    item.OperationRemark = "关闭报警";
                    GetTimeDiffer(item.CreatedTime.ConvertToDateTime(), nowDate, ref msg);
                    item.DurationTime = msg;
                    update.Add(item);
                }
                else//包含，更新报警时间
                {
                    item.UpdatedTime = nowDate;
                    update.Add(item);
                }
            }
            foreach (var item in input.data)
            {
                if (!strlist2.Contains(item.warnContent))
                {
                    WareDeviceWarning request = new WareDeviceWarning();
                    request.DeviceCode = "1099";
                    request.DeviceName = "AGV";

                    request.DeviceType = 3;
                    request.DeviceTypeName = "AGV";

                    request.WarningDbAddress = item.robotCode;
                    request.WarningCode = item.taskCode;
                    request.WarningContent = item.warnContent;
                    request.WarningTime = item.beginTime;
                    //状态（0：新建 1：已处理）
                    request.Status = 0;
                    request.StatusName = "新建";
                    request.UpdatedTime = nowDate;
                    request.CreatedTime = nowDate;
                    request.CreatedUserName = "WMS";
                    request.OperationRemark = "添加";
                    insert.Add(request);
                }
            }

            using (var tran = await _wareTaskSub.Database.BeginTransactionAsync())
            {
                try
                {
                    if (update != null && update.Count != 0)
                    {
                        await _wareDeviceWarning.UpdateAsync(update);
                    }
                    if (insert != null && insert.Count > 0)
                    {
                        await _wareDeviceWarning.InsertAsync(insert);
                    }
                    await tran.CommitAsync();
                }
                catch
                {
                    await tran.RollbackAsync();
                }
            }
            return agvCommonResponseDto;
        }

        [NonAction]
        public static int GetTimeDiffer(DateTime? startTime, DateTime? endTime, ref string msg)
        {
            if (startTime == null || endTime == null)
            {
                return 0;
            }
            TimeSpan ts = ((DateTime)endTime - (DateTime)startTime);
            msg = "";
            if (ts.Days != 0)
            {
                msg += ts.Days + "天";
            }
            if (ts.Hours != 0)
            {
                msg += ts.Hours + "小时";
            }
            if (ts.Minutes != 0)
            {
                msg += ts.Minutes + "分钟";
            }
            if (ts.Seconds != 0)
            {
                msg += ts.Seconds + "秒";
            }
            return (int)ts.TotalSeconds;
        }
    }
}