using SqlSugar;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using WMS.BZModels;
using WMS.Info;
using wms.sqlsugar.model.pt;
using WMS.BZSqlSugar;
using WMS.Util;
using WMS.BZModels.Dto.PT.TaskDtos;

namespace WMS.BZServices.PT
{
    public class AgvTaskInfoService
    {
        private readonly Repository<WCS_AgvTaskInfo> _agvtaskoldrepository;

        public AgvTaskInfoService(Repository<WCS_AgvTaskInfo> agvtaskoldrepository)
        {
            _agvtaskoldrepository = agvtaskoldrepository;
        }

        public PagedInfo<AgvTaskoldDto> GetPageList(Pagination pagination, AgvTaskoldQueryDto agvTaskoldQueryDto)
        {
            var predicate = Expressionable.Create<WCS_AgvTaskInfo>();
            predicate = predicate.AndIF(!string.IsNullOrEmpty(agvTaskoldQueryDto?.KeyWord), m => m.ID.ToString().Contains(agvTaskoldQueryDto.KeyWord) || m.AgvID.Contains(agvTaskoldQueryDto.KeyWord)
            || m.Station.Contains(agvTaskoldQueryDto.KeyWord) || m.Position.Contains(agvTaskoldQueryDto.KeyWord));
            predicate = predicate.AndIF(!string.IsNullOrEmpty(agvTaskoldQueryDto?.ID), m => m.ID.ToString().Contains(agvTaskoldQueryDto.ID));
            predicate = predicate.AndIF(!string.IsNullOrEmpty(agvTaskoldQueryDto?.AgvID), m => m.AgvID.Contains(agvTaskoldQueryDto.AgvID));
            predicate = predicate.AndIF(!string.IsNullOrEmpty(agvTaskoldQueryDto?.Station), m => m.Station.Contains(agvTaskoldQueryDto.Station));
            predicate = predicate.AndIF(!string.IsNullOrEmpty(agvTaskoldQueryDto?.Position), m => m.Position.Contains(agvTaskoldQueryDto.Position));
            predicate = predicate.AndIF(!string.IsNullOrEmpty(agvTaskoldQueryDto?.TaskType), m => m.TaskType.Equals(agvTaskoldQueryDto.TaskType));
            predicate = predicate.AndIF(!string.IsNullOrEmpty(agvTaskoldQueryDto?.AgvStatus), m => m.AgvStatus.Equals(agvTaskoldQueryDto.AgvStatus));
            predicate = predicate.AndIF(!string.IsNullOrEmpty(agvTaskoldQueryDto?.Status), m => m.Status.Equals(agvTaskoldQueryDto.Status));
            predicate = predicate.And(p => p.Status < 99);
            var query = _agvtaskoldrepository.Queryable().Where(predicate.ToExpression()).SplitTable(p => p.Take(3));
            //if (agvTaskoldQueryDto != null && agvTaskoldQueryDto.AddTimeFrom.HasValue)
            //{
            //    var endtime = DateTime.Now;
            //    if (agvTaskoldQueryDto.AddTimeTo.HasValue)
            //    {
            //        endtime = agvTaskoldQueryDto.AddTimeTo.Value;
            //    }
            //    query = _agvtaskoldrepository.Queryable().Where(predicate.ToExpression()).SplitTable(AgvTaskoldQueryDto.AddTimeFrom.Value, endtime);
            //}
            var list = query.ToPage<WCS_AgvTaskInfo, AgvTaskoldDto>(pagination);

            return list;
        }
        public PagedInfo<AgvTaskoldDto> GetPageList1(Pagination pagination, AgvTaskoldQueryDto agvTaskoldQueryDto)
        {
            var predicate = Expressionable.Create<WCS_AgvTaskInfo>();
            predicate = predicate.AndIF(!string.IsNullOrEmpty(agvTaskoldQueryDto?.KeyWord), m => m.ID.ToString().Contains(agvTaskoldQueryDto.KeyWord) || m.AgvID.Contains(agvTaskoldQueryDto.KeyWord)
            || m.Station.Contains(agvTaskoldQueryDto.KeyWord) || m.Position.Contains(agvTaskoldQueryDto.KeyWord));
            predicate = predicate.AndIF(!string.IsNullOrEmpty(agvTaskoldQueryDto?.ID), m => m.ID.ToString().Contains(agvTaskoldQueryDto.ID));
            predicate = predicate.AndIF(!string.IsNullOrEmpty(agvTaskoldQueryDto?.AgvID), m => m.AgvID.Contains(agvTaskoldQueryDto.AgvID));
            predicate = predicate.AndIF(!string.IsNullOrEmpty(agvTaskoldQueryDto?.Station), m => m.Station.Contains(agvTaskoldQueryDto.Station));
            predicate = predicate.AndIF(!string.IsNullOrEmpty(agvTaskoldQueryDto?.Position), m => m.Position.Contains(agvTaskoldQueryDto.Position));
            predicate = predicate.AndIF(!string.IsNullOrEmpty(agvTaskoldQueryDto?.TaskType), m => m.TaskType.Equals(agvTaskoldQueryDto.TaskType));
            predicate = predicate.AndIF(!string.IsNullOrEmpty(agvTaskoldQueryDto?.AgvStatus), m => m.AgvStatus.Equals(agvTaskoldQueryDto.AgvStatus));
            predicate = predicate.AndIF(!string.IsNullOrEmpty(agvTaskoldQueryDto?.Status), m => m.Status.Equals(agvTaskoldQueryDto.Status));
            predicate = predicate.And(p => p.Status >= 99);
            var query = _agvtaskoldrepository.Queryable().Where(predicate.ToExpression()).SplitTable(p => p.Take(2));
            //if (agvTaskoldQueryDto != null && agvTaskoldQueryDto.AddTimeFrom.HasValue)
            //{
            //    var endtime = DateTime.Now;
            //    if (agvTaskoldQueryDto.AddTimeTo.HasValue)
            //    {
            //        endtime = agvTaskoldQueryDto.AddTimeTo.Value;
            //    }
            //    query = _agvtaskoldrepository.Queryable().Where(predicate.ToExpression()).SplitTable(AgvTaskoldQueryDto.AddTimeFrom.Value, endtime);
            //}
            var list = query.ToPage<WCS_AgvTaskInfo, AgvTaskoldDto>(pagination);

            return list;
        }


        public int GetTaskUnFinishCount()
        {
            var predicate = Expressionable.Create<WCS_AgvTaskInfo>();
            predicate = predicate.And(m => m.Status < (int)BZModels.TaskStatus.Finish);
            var count = _agvtaskoldrepository.Queryable().Where(predicate.ToExpression()).SplitTable(tabs => tabs.Take(3)).Count();
            return count;
        }

        public bool HandleTask(LoginUserInfo loginUser, string keyValue)
        {
            var agv = _agvtaskoldrepository.Queryable().SplitTable(tabs => tabs.Take(3)).First(o => o.ID.Equals(keyValue));
            if (agv == null)
            {
                throw BZSysExCore.ThrowFailException("没有数据。");
            }
            //agv.Status = (int)AGVTaskStatus.MissionCompleted;
            agv.AgvStatus = (int)AGVTaskStatus.MissionCompleted;
            agv.EditTime = DateTime.Now;
            agv.EditWho = "手动完成";
            var result = _agvtaskoldrepository.AsUpdateable(agv).UpdateColumns(o => new { o.Status, o.AgvStatus, o.EditTime, o.EditWho }).SplitTable(p => p.Take(3)).ExecuteCommand();
            return result > 0;


        }
    }
}