using System;
using SqlSugar;
using Infrastructure.Attribute;
using Infrastructure.Extensions;
using DOAN.Model;
using DOAN.Model.Dto;
using DOAN.Repository;

using System.Linq;
using DOAN.Model.Mobile.Dto;
using DOAN.Infrastructure;
using DOAN.Model.MES.base_;
using DOAN.Model.MES.mm;
using NPOI.SS.UserModel;
using MathNet.Numerics.Distributions;
using Microsoft.AspNetCore.Http.HttpResults;
using DOAN.Service.MES.quality.IPQC.IService;
using DOAN.Model.MES.quality.IPQC.Dto;
using DOAN.Model.MES.quality.IPQC;

namespace DOAN.Service.MES.quality.IPQC
{
    /// <summary>
    /// 缺陷收集Service业务层处理
    /// </summary>
    [AppService(ServiceType = typeof(IQcDefectCollectionService), ServiceLifetime = LifeTime.Transient)]
    public class QcDefectCollectionService : BaseService<QcDefectCollection>, IQcDefectCollectionService
    {
        /// <summary>
        /// 生成指定产线和日期的 缺陷收集计划
        /// </summary>
        /// <param name="line_code"></param>
        /// <param name="dateTime"></param>
        /// <returns></returns>
        public bool GenerateDefectConllectionPlan(string line_code, DateTime dateTime, string CreatedBy)
        {
            bool isGenerate = Context.Queryable<QcDefectCollection>().Where(it => it.LineCode == line_code).Where(it => it.DateTime == dateTime).Any();
            if (isGenerate) { return false; }
            List<QcDefectCollection> qcDefectCollections = new List<QcDefectCollection>();
            //1  查询  产线物料需求计划
            List<MmRequirePlanByline> MmPreparationTaskLineList = Context.Queryable<MmRequirePlanByline>().Where(it => it.LineCode == line_code)
                 .Where(it => it.RequireDate == dateTime).ToList();
            //2  算出每个物料实际派发数量
            var ActualDistributionQuantityOfMaterials = Context.Queryable<MmPreparationTaskLine>()
                .LeftJoin<MmTaskMaterialInfoByLine>((t, i) => t.TaskCode == i.FkTaskCode)
                .Where((t, i) => t.LineCode == line_code && t.TaskDate == dateTime)
                .GroupBy((t, i) => i.MaterialCode)
                .Select((t, i) => new
                {
                    i.MaterialCode,
                    ActualNum = SqlFunc.AggregateSum(i.Quantity)
                }).ToList();

            foreach (var item in MmPreparationTaskLineList)
            {
                QcDefectCollection qcDefect = new QcDefectCollection();
                qcDefect.Id = XueHua;
                qcDefect.LineCode = line_code;
                qcDefect.DateTime = dateTime;
                qcDefect.MaterialCode = item.MaterialCode;
                qcDefect.MaterialName = item.MaterialName;
                var itemm = ActualDistributionQuantityOfMaterials.Where(it => it.MaterialCode == item.MaterialCode).FirstOrDefault();
                qcDefect.Specification = item.Specification;
                qcDefect.Unit = item.Unit;
                qcDefect.PlanNum = item.RequireNum;
                qcDefect.ActualNum = itemm?.ActualNum ?? 0;
                qcDefect.CreatedTime = item.CreatedTime;
                qcDefect.CreatedBy = CreatedBy;
                qcDefectCollections.Add(qcDefect);

            }


            int result = Context.Insertable(qcDefectCollections).ExecuteCommand();
            if (result > 1)
            {
                return true;
            }
            else
            {
                return false;
            }

        }


        /// <summary>
        /// 查询缺陷收集列表
        /// </summary>
        /// <param name="parm"></param>
        /// <returns></returns>
        public PagedInfo<QcDefectCollectionDto> GetList(QcDefectCollectionQueryDto parm)
        {
            parm.DateTime = ConvertDateTime.ConvertLocalDate(parm.DateTime ?? DateTime.MinValue);
            var predicate = Expressionable.Create<QcDefectCollection>()
                .AndIF(!string.IsNullOrEmpty(parm.MaterialCode), it => it.MaterialCode.Contains(parm.MaterialCode))
                .AndIF(!string.IsNullOrEmpty(parm.MaterialName), it => it.MaterialName.Contains(parm.MaterialName))
                .AndIF(!string.IsNullOrEmpty(parm.LineCode), it => it.LineCode.Contains(parm.LineCode))
                .AndIF(parm.DateTime != null && parm.DateTime > DateTime.MinValue.AddYears(1), it => it.DateTime == parm.DateTime)
                .AndIF(parm.Tqm != null, it => it.Tqm == parm.Tqm)
                .AndIF(parm.Type != null, it => it.Type == parm.Type)
              
                ;

            var response = Queryable()
                .Where(predicate.ToExpression())
                .OrderBy(it => it.MaterialCode)
                .ToPage<QcDefectCollection, QcDefectCollectionDto>(parm);

            return response;
        }


        /// <summary>
        /// 获取详情
        /// </summary>
        /// <param name="Id"></param>
        /// <returns></returns>
        public QcDefectCollection GetInfo(string Id)
        {
            var response = Queryable()
                .Where(x => x.Id == Id)
                .First();

            return response;
        }

        /// <summary>
        /// 添加缺陷收集
        /// </summary>
        /// <param name="model"></param>
        /// <returns></returns>
        public QcDefectCollection AddQcDefectCollection(QcDefectCollection model)
        {
            model.Id = XueHua;
            return Context.Insertable(model).ExecuteReturnEntity();
        }


        public bool CopySameMaterial(string id)
        {
            QcDefectCollection qcDefect = Context.Queryable<QcDefectCollection>().Where(it => it.Id == id).First();
            QcDefectCollection newqcDefect = new QcDefectCollection();
            newqcDefect.Id = XueHua;
            newqcDefect.LineCode = qcDefect.LineCode;
            newqcDefect.DateTime = qcDefect.DateTime;
            newqcDefect.MaterialCode = qcDefect.MaterialCode;
            newqcDefect.MaterialName = qcDefect.MaterialName;
            newqcDefect.Unit = qcDefect.Unit;
            newqcDefect.Specification = qcDefect.Specification;
            newqcDefect.PlanNum = qcDefect.PlanNum;
            newqcDefect.ActualNum = qcDefect.ActualNum;
            newqcDefect.CreatedBy = qcDefect.CreatedBy;
            newqcDefect.CreatedTime = DateTime.Now;
            int result = Context.Insertable(newqcDefect).ExecuteCommand();
            if (result == 0)
            {
                return false;
            }
            else
            {
                return true;
            }

        }

        /// <summary>
        /// 修改缺陷收集
        /// </summary>
        /// <param name="model"></param>
        /// <returns></returns>
        public int UpdateQcDefectCollection(QcDefectCollection model)
        {
            //var response = Update(w => w.Id == model.Id, it => new QcDefectCollection()
            //{
            //    MaterialCode = model.MaterialCode,
            //    MaterialName = model.MaterialName,
            //    BatchNumber = model.BatchNumber,
            //    Unit = model.Unit,
            //    Quantity = model.Quantity,
            //    DateTime = model.DateTime,
            //    GroupCode = model.GroupCode,
            //    LineCode = model.LineCode,
            //    ProcessName = model.ProcessName,
            //    Superintendent = model.Superintendent,
            //    DefectDescription = model.DefectDescription,
            //    Tqm = model.Tqm,
            //    Remark = model.Remark,
            //    CreatedBy = model.CreatedBy,
            //    CreatedTime = model.CreatedTime,
            //    UpdatedBy = model.UpdatedBy,
            //    UpdatedTime = model.UpdatedTime,
            //});
            //return response;
            return Update(model, true);
        }

        public List<BaseWorkRoute> GetAllLines()
        {
            return Context.Queryable<BaseWorkRoute>().Where(it => it.Status == 1).ToList();
        }


        public List<BaseSupplier> GetAllSuppliers(string supplier_str)
        {
           return Context.Queryable<BaseSupplier>()
                .WhereIF(!string.IsNullOrEmpty(supplier_str),it=>it.SupplierNo.Contains(supplier_str)||it.SupplierName.Contains(supplier_str))
                .Where(it=>it.Status == 1).Take(40).ToList();
        }
    }
}