using Model.InterFaceModel;
using Model.ModelDto.BllAsnDto;
using Model.ModelVm.BllAsnVm;
using SqlSugar;
using System;
using System.Collections.Generic;
using System.Text;
using WMS.BLL.LogServer;
using WMS.DAL;
using WMS.Entity.BllAsnEntity;
using WMS.Entity.Context;
using WMS.Entity.SysEntity;
using WMS.IBLL.IBllAsnServer;

namespace WMS.BLL.BllAsnServer
{
    public class ProcurePlanServer : DbHelper<BllProcurePlanNotice>, IProcurePlanServer
    {
        #region 依赖注入 
        private static readonly SqlSugarScope Db = DataContext.Db;

        public ProcurePlanServer() : base(Db)
        {
        }
        #endregion

        /// <summary>
        /// 获取采购单信息
        /// </summary>
        /// <param name="model"></param>
        /// <param name="count"></param>
        /// <returns></returns>
        public List<ProcurePlanNoticeDto> GetProcurePlanNoticeList(ProcurePlanNoticeVm model, out int count)
        {
            string sqlString = string.Empty;
            string sqlCount = string.Empty;
            string sqlPub = string.Empty;
            try
            {
                sqlCount += "SELECT DISTINCT COUNT(tb1.ID) FROM BllProcurePlanNotice AS tb1 ";
                sqlString += "SELECT DISTINCT tb1.*,tb3.RealName as CreateUserName,tb4.RealName as UpdateUserName FROM BllProcurePlanNotice AS tb1 ";
                sqlPub += "LEFT JOIN BllProcurePlanNoticeDetail AS tb2 ON tb1.Id = tb2.ParentId ";
                sqlPub += "LEFT JOIN SysUserInfor AS tb3 ON tb1.CreateUser = tb3.Id ";
                sqlPub += "LEFT JOIN SysUserInfor AS tb4 ON tb1.UpdateUser = tb4.Id ";
                sqlPub += $"WHERE tb1.IsDel = '0' ";
                sqlPub += $"AND tb2.SkuNo LIKE '%{model.SkuNo}%' AND tb2.SkuName LIKE '%{model.SkuName}%' ";
                sqlPub += $"AND tb2.CustomerName  LIKE '%{model.CustomerName}%' ";
                if (!string.IsNullOrEmpty(model.Status))
                {
                    sqlPub += $"AND tb1.Status = '{model.Status}' ";
                }
                if (!string.IsNullOrEmpty(model.StartTime))
                {
                    sqlPub += $"AND tb1.CreateTime >= '{model.StartTime}' ";
                }
                if (!string.IsNullOrEmpty(model.EndTime))
                {
                    sqlPub += $"AND tb1.CreateTime <= '{model.EndTime}' ";
                }
                sqlCount += sqlPub;
                sqlPub += " order by tb1.Id desc ";
                if (model.Page == 0)
                {
                    model.Page = 1;
                }
                sqlString += sqlPub + $" offset {((model.Page - 1) * model.Limit)} rows fetch next {model.Limit} rows only;";

                var com = new Common();
                count = com.GetRowCount(sqlCount);

                var modelList = Db.Ado.SqlQuery<ProcurePlanNoticeDto>(sqlString);

                return modelList;
            }
            catch (Exception ex)
            {
                throw ex;
            }
        }
        /// <summary>
        /// 获取采购单明细信息
        /// </summary>
        /// <param name="model"></param>
        /// <param name="count"></param>
        /// <returns></returns>
        public List<ProcurePlanNoticeDetailDto> GetProcurePlanNoticeDetailList(ProcurePlanNoticeDetailVm model, out int count)
        {
            string sqlString = string.Empty;
            string sqlCount = string.Empty;
            int rowCount = 1;
            try
            {
                if (model.Page == 0)
                {
                    model.Page = 1;
                }
                sqlCount += $"SELECT COUNT(ID) FROM BllProcurePlanNoticeDetail where ParentId = '{model.ParentId}' and IsDel = '0';";
                var com = new Common();
                count = com.GetRowCount(sqlCount);
                if (count != 0)
                {
                    rowCount = count;
                }

                sqlString += "SELECT DISTINCT tb1.*,tb3.RealName as CreateUserName, ";
                sqlString += "tb4.RealName as UpdateUserName,isnull(tb6.UnitName,tb5.UnitNo) as UnitName,tb7.PackagName ";
                sqlString += "FROM BllProcurePlanNoticeDetail AS tb1 ";
                sqlString += "LEFT JOIN SysUserInfor AS tb3 ON tb1.CreateUser = tb3.Id ";
                sqlString += "LEFT JOIN SysUserInfor AS tb4 ON tb1.UpdateUser = tb4.Id ";
                sqlString += "LEFT JOIN SysMaterials AS tb5 on tb1.SkuNo = tb5.SkuNo ";
                sqlString += "LEFT JOIN SysUnit AS tb6 on tb5.UnitNo = tb6.UnitNo ";
                sqlString += "LEFT JOIN SysPackag AS tb7 on tb1.PackagNo = tb7.PackagNo ";
                sqlString += $"WHERE tb1.ParentId = '{model.ParentId}' AND tb1.IsDel = '0' order by tb1.SkuNo desc ";
                sqlString += $"offset {((model.Page - 1) * model.Limit)} rows fetch next {rowCount} rows only;";

                var modelList = Db.Ado.SqlQuery<ProcurePlanNoticeDetailDto>(sqlString);

                return modelList;
            }
            catch (Exception ex)
            {
                throw ex;
            }
        }
        /// <summary>
        /// 通过采购单生成入库单据
        /// </summary>
        /// <param name="planDetailId"></param>
        /// <param name="userId"></param>
        public void CreateAsnByProcurePlan(int planDetailId,int userId)
        {
            try
            {
                //采购单明细
                var planDetail= Db.Queryable<BllProcurePlanNoticeDetail>().First(it => it.Id == planDetailId && it.IsDel == "0");
                if (planDetail == null)
                {
                    throw new Exception("未查询到采购单据明细信息");
                }
                //采购总单信息
                var planOrd = Db.Queryable<BllProcurePlanNotice>().First(it => it.Id == planDetail.ParentId && it.IsDel == "0");
                if (planOrd == null)
                {
                    throw new Exception("未查询到采购单据总单信息");
                }
                if (planOrd.Status == "3")
                {
                    throw new Exception("采购单据总单已关单");
                }

                // 根据客户编号获取客户名称
                var CustomerModel = Db.Queryable<SysCustomer>().First(it => it.CustomerNo == planDetail.CustomerNo && it.IsDel == "0");
                if (CustomerModel == null)
                {
                    throw new Exception("客户编号不存在!");
                }
                // 入库总表信息
                string asnNo = new Common().GetMaxNo("ASN");
                var asnModel = new BllArrivalNotice()
                {
                    ASNNo = asnNo,
                    Status = "0",//执行状态，0：等待执行
                    Type = "1",//单据类型，1：采购入库
                    Origin = "采购单",
                    CustomerNo = CustomerModel.CustomerNo,
                    CustomerName = CustomerModel.CustomerName,
                    OrderCode = planOrd.OrderCode,
                    CreateUser = userId
                };               
                // 获取物料详细信息
                var skuModel = Db.Queryable<SysMaterials>().First(it => it.SkuNo == planDetail.SkuNo && it.IsDel == "0");
                if (skuModel == null)
                {
                    throw new Exception("不存在当前物料信息!");
                }
                // 验证包装信息是否存在
                var packagModel = Db.Queryable<SysPackag>().First(it => it.PackagNo == planDetail.PackagNo && it.IsDel == "0");
                if (packagModel == null)
                {
                    throw new Exception("不存在当前包装信息!");
                }
                //入库单明细
                var detailModel = new BllArrivalNoticeDetail()
                {
                    ASNNo = asnNo,
                    SkuNo = skuModel.SkuNo,
                    SkuName = skuModel.SkuName,
                    Standard = skuModel.Standard,
                    LotNo = "",
                    LotText = "",
                    Qty = 0,
                    FactQty = 0,
                    CompleteQty = 0,
                    PackagNo = packagModel.PackagNo,
                    SupplierLot = "",
                    Status = "0",
                    IsSampling = "0",
                    InspectStatus = "0",
                    OrderDetailCode = planDetail.OrderDetailCode,
                    CreateUser = userId
                };

                //开启事务
                Db.BeginTran();

                // 插入入库单总表
                Db.Insertable(asnModel).ExecuteCommand();
                // 插入入库单明细
                Db.Insertable(detailModel).ExecuteCommand();

                //添加操作日志
                new OperationASNServer().AddLogOperationAsn("入库作业", "入库单据", asnNo, "添加", $"在采购单页面添加了单据号为{asnNo}的单据信息", userId);

                //提交事务
                Db.CommitTran();
            }
            catch (Exception ex)
            {
                Db.RollbackTran();
                throw new Exception(ex.Message);
            }
        }

        /// <summary>
        /// 关闭采购单据
        /// </summary>
        /// <param name="Id"></param>
        /// <param name="userId"></param>
        public void CloseProcurePlan(int Id,int userId)
        {
            try
            {
                //采购总单信息
                var planOrd = Db.Queryable<BllProcurePlanNotice>().First(it => it.Id == Id && it.IsDel == "0" && it.Status == "2");
                if (planOrd == null)
                {
                    throw new Exception("未查询到采购单据总单信息");
                }
                //开启事务
                Db.BeginTran();

                planOrd.Status = "3";
                planOrd.UpdateUser = userId;
                planOrd.UpdateTime = DateTime.Now;
                //更新采购单状态
                Db.Updateable(planOrd).ExecuteCommand();

                //添加操作日志
                new OperationASNServer().AddLogOperationAsn("入库作业", "入库单据", planOrd.OrderCode, "关单", $"关闭了采购单据号为{planOrd.OrderCode}的采购单据信息", userId);

                //提交事务
                Db.CommitTran();
            }
            catch (Exception ex)
            {
                Db.RollbackTran();
                throw new Exception(ex.Message);
            }
        }

        #region 接口方法
        /// <summary>
        /// 上游系统下发创建采购单
        /// </summary>
        /// <param name="model"></param>
        /// <returns></returns>
        public ErpModel CreateProcurePlan(ProcurePlanInfo model)
        {
            try
            {
                var resultModel = new ErpModel() { Success = -1, Message = "" };
               
                if (string.IsNullOrEmpty(model.OrderCode))
                {
                    resultModel.Message = "上游系统单号不可为空!";
                    return resultModel;
                }
                if (model.ProcurePlanDetails.Count <= 0)
                {
                    resultModel.Message = "采购单明细不可为空!";
                    return resultModel;
                }

                //开启事务
                Db.BeginTran();

                // 采购单总表信息
                var planModel = new BllProcurePlanNotice()
                {
                    Status = "0",                   
                    OrderCode = model.OrderCode,
                };
                // 插入采购单总表
                int parentId = Db.Insertable(planModel).ExecuteReturnIdentity();

                // 采购单明细表信息
                List<BllProcurePlanNoticeDetail> detailModels = new List<BllProcurePlanNoticeDetail>();
                foreach (ProcurePlanDetail asnDetailModel in model.ProcurePlanDetails)
                {
                    if (string.IsNullOrEmpty(asnDetailModel.SkuNo))
                    {
                        resultModel.Message = "物料编码不可为空!";
                        return resultModel;
                    }
                    if (asnDetailModel.Qty <= 0)
                    {
                        resultModel.Message = "数量不能为空!";
                        return resultModel;
                    }
                    if (string.IsNullOrEmpty(asnDetailModel.Customer))
                    {
                        resultModel.Message = "供应商不可为空!";
                        return resultModel;
                    }

                    // 获取物料详细信息
                    var skuModel = Db.Queryable<SysMaterials>().First(it => it.SkuNo == asnDetailModel.SkuNo && it.IsDel == "0");
                    if (skuModel == null)
                    {
                        resultModel.Message = "不存在当前物料信息!";
                        return resultModel;
                    }

                    // 根据客户编号获取客户名称
                    var CustomerModel = Db.Queryable<SysCustomer>().First(it => it.CustomerNo == asnDetailModel.Customer && it.IsDel == "0");
                    if (CustomerModel == null)
                    {
                        resultModel.Message = "供应商编号不存在!";
                        return resultModel;
                    }

                    //采购单明细信息
                    var detailModel = new BllProcurePlanNoticeDetail()
                    {
                        ParentId = parentId,
                        OrderDetailCode= asnDetailModel.OrderDetailCode,
                        SkuNo = asnDetailModel.SkuNo,
                        SkuName = skuModel.SkuName,
                        Standard = skuModel.Standard,
                        Qty = (decimal)asnDetailModel.Qty,
                        CompleteQty=0,
                        PackagNo = skuModel.PackagNo,
                        Status = "0",
                        CustomerNo = asnDetailModel.Customer,
                        CustomerName = CustomerModel.CustomerName,
                        CreateUser = 0
                    };
                    detailModels.Add(detailModel);

                    #region 入库单
                    // 入库总表信息
                    string asnNo = new Common().GetMaxNo("ASN");
                    var asnModel = new BllArrivalNotice()
                    {
                        ASNNo = asnNo,
                        Status = "0",//执行状态，0：等待执行
                        Type = "1",//单据类型，1：采购入库
                        Origin = "采购单",
                        CustomerNo = CustomerModel.CustomerNo,
                        CustomerName = CustomerModel.CustomerName,
                        OrderCode = model.OrderCode,
                        CreateUser = 0
                    };
                    // 插入入库总表信息
                    Db.Insertable(asnModel).ExecuteCommand();
                    //入库单明细
                    var arrDetailModel = new BllArrivalNoticeDetail()
                    {
                        ASNNo = asnNo,
                        SkuNo = skuModel.SkuNo,
                        SkuName = skuModel.SkuName,
                        Standard = skuModel.Standard,
                        LotNo = "",
                        LotText = "",
                        Qty = 0,
                        FactQty=0,
                        CompleteQty=0,
                        PackagNo = skuModel.PackagNo,
                        SupplierLot = "",
                        Status = "0",
                        IsSampling = "0",
                        InspectStatus = "0",
                        OrderDetailCode = asnDetailModel.OrderDetailCode,
                        CreateUser = 0
                    };
                    // 插入入库总表信息
                    Db.Insertable(arrDetailModel).ExecuteCommand();
                    #endregion

                }
                // 插入采购单明细表
                Db.Insertable(detailModels).ExecuteCommand();
                Db.CommitTran();

                resultModel.Success = 0;
                resultModel.Message = "成功";
                return resultModel;
            }
            catch (Exception ex)
            {
                Db.RollbackTran();
                throw ex;
            }
        }

        #endregion
    }
}