using SqlSugar;
using WMS.BZModels;
using WMS.Info;
using wms.sqlsugar.model.sx;
using WMS.BZSqlSugar;
using WMS.BZModels.Dto.SX.TaskDtos;

namespace WMS.BZServices.SX
{
    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(1));
            //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(1));
            //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;
        }
    }
}