using Admin.NET.Core.TaskModule.Enum;
using iWareSql.MyDbContext;
using System;
using System.Collections.Generic;
using System.Linq;

namespace iWareSql.DataAccess
{
    public class TaskHandler
    {
        /// <summary>
        /// 查找该库位是否存在 未结束的任务
        /// </summary>
        /// <param name="dbContext"></param>
        /// <param name="location"></param>
        /// <returns></returns>
        public static ware_task IsExistNoFinishedTask(MyDbContext.MyDbContext dbContext, string location)
        {
            var ware_Tasks = dbContext.ware_task
                .Where(CommonFilterExpressionForNoFinishAndNoCancel())
                .Where(x => (x.IsDeleted == null || x.IsDeleted == false)
            && (x.FromLocationCode == location || x.ToLocationCode == location)
             ).FirstOrDefault();
            return ware_Tasks;
        }

        /// <summary>
        /// 获取当前未结束的任务的站点集合（包括起点和终点）
        /// </summary>
        /// <param name="dbContext"></param>
        /// <returns></returns>
        public static List<string> GetLocationListByNoFinishedTask(MyDbContext.MyDbContext dbContext)
        {
            List<string> locationList = new List<string>();
            var ware_Tasks = dbContext.ware_task
                .Where(CommonFilterExpressionForNoFinishAndNoCancel())
                .Where(x =>
              x.AreaType == (int)AreaTypeEnum.立体库
            && (x.IsDeleted == null || x.IsDeleted == false)).ToList();
            locationList.AddRange(ware_Tasks.Select(x => x.FromLocationCode).ToList());
            locationList.AddRange(ware_Tasks.Select(x => x.ToLocationCode).ToList());
            return locationList;
        }

        /// <summary>
        /// 某巷道 是否存在 未结束，但是已下发WCS  的任务
        /// </summary>
        /// <param name="repository"></param>
        /// <param name="locationCode"></param>
        /// <returns></returns>
        public static ware_task IsExistNoFinishedAndHasIssueWCSTaskByLane(MyDbContext.MyDbContext dbContext, int lane)
        {
            var ware_Tasks = dbContext.ware_task
                .Where(CommonFilterExpressionForNoFinishAndNoCancel())
                .Where(x =>
              x.State == 1
             && x.Lane == lane
             && x.AreaType == (int)AreaTypeEnum.立体库
             && (x.IsDeleted == null || x.IsDeleted == false)
            ).FirstOrDefault();
            return ware_Tasks;
        }



        /// <summary>
        /// 更新任务表的任务消息
        /// </summary>
        /// <param name="taskId"></param>
        /// <param name="errMsg"></param>
        public static void UpdateTaskMsg(long taskId, string errMsg)
        {
            using (MyDbContext.MyDbContext dbContext = new MyDbContext.MyDbContext())
            {
                var singleTask = dbContext.ware_task.Where(x => x.Id == taskId).FirstOrDefault();
                
                singleTask.UpdatedTime = DateTime.Now;

                dbContext.SaveChanges();
            }
        }


        /// <summary>
        /// 获取 任务 不是 已完成，并且不是 已取消 的任务筛选条件
        /// </summary>
        /// <returns></returns>
        public static Func<ware_task, bool> CommonFilterExpressionForNoFinishAndNoCancel()
        {
            Func<ware_task, bool> predicate = m =>
              (m.TaskState != Convert.ToInt32(WareTaskStateEnum.已完成)
               && m.TaskState != Convert.ToInt32(WareTaskStateEnum.已取消)
              )
             ;
            return predicate;
        }

        /// <summary>
        /// 获取 任务 不是 已完成，并且不是 已取消 ，并且是 已暂停的 的任务筛选条件
        /// </summary>
        /// <returns></returns>
        public static Func<ware_task, bool> CommonFilterExpressionForNoFinishAndNoCancelAndNoStop()
        {
            Func<ware_task, bool> predicate = m =>
              (m.TaskState != Convert.ToInt32(WareTaskStateEnum.已完成)
               && m.TaskState != Convert.ToInt32(WareTaskStateEnum.已取消)
               && m.TaskState != Convert.ToInt32(WareTaskStateEnum.已暂停)
              )
             ;
            return predicate;
        }
    }
}