using System;
using System.Collections.Generic;
using System.Linq;
using System.Linq.Expressions;
using System.Text;
using System.Threading.Tasks;
using Dm;
using Model.ModelDto.BllSoDto;
using Model.ModelVm.BllSoVm;
using SqlSugar;
using WMS.BLL.LogServer;
using WMS.DAL;
using WMS.Entity.BllSoEntity;
using WMS.Entity.Context;
using WMS.Entity.DataEntity;
using WMS.Entity.SysEntity;
using WMS.IBLL.IBllSoServer;

namespace WMS.BLL.BllSoServer
{
    public class ExportNoticeDetailServer: DbHelper<BllExportNoticeDetail>,IExportNoticeDetailServer
    {
        private static readonly SqlSugarScope Db = DataContext.Db;
        public ExportNoticeDetailServer():base(Db)
        {
        }
        public async Task<List<ExportNoticeDetailDto>> GetExportNoticeDetailList(GetExportNoticeDetailVm model, RefAsync<int> count)
        {
            if (string.IsNullOrWhiteSpace(model.SoNo))
            {
                throw new Exception("出库单号为空");
            }
            var notice = DataContext.Db.Queryable<BllExportNotice>().Where(m => m.IsDel == "0" && m.SONo == model.SoNo).ToList().FirstOrDefault();
            if (notice == null)
            {
                throw new Exception("出库单号为空");
            }

            var data = await GetAllWhereAsync(a => a.SONo == model.SoNo)
                .LeftJoin<SysPackag>((a, b) => a.PackagNo == b.PackagNo)
                .LeftJoin<SysUserInfor>((a, b, c) => a.CreateUser == c.Id)
                .LeftJoin<SysUserInfor>((a, b, c, d) => a.UpdateUser == d.Id)
                .Select((a, b, c, d) => new ExportNoticeDetailDto()
                {
                    Id = a.Id,
                    Status = a.Status,
                    Origin = notice.Origin,
                    SONo = a.SONo,
                    SkuNo = a.SkuNo,
                    SkuName = a.SkuName,
                    Standard = a.Standard,
                    LotNo = a.LotNo,
                    LotText = a.LotText,
                    Qty = a.Qty,
                    AllotQty = a.AllotQty,
                    FactQty = a.FactQty,
                    CompleteQty = a.CompleteQty,
                    PackagNo = a.PackagNo,
                    PackagName = b.PackagName,
                    Price = a.Price,
                    Money = a.Money,
                    IsBale = a.IsBale,
                    IsBelt = a.IsBelt,
                    SupplierLot = a.SupplierLot,
                    IsWave = a.IsWave,
                    WaveNo = a.WaveNo,
                    IsMixBox = a.IsMixBox,

                    CreateUserName = c.RealName,
                    UpdateUserName = d.RealName,
                    CreateTime = a.CreateTime,
                    UpdateTime = a.UpdateTime
                }).ToPageListAsync(model.Page, model.Limit, count);

            return data;
        }

        public bool DelExportNoticeDetail(int id, int userId)
        {
            try
            { 
                //出库单明细
                var noticeDetail = Db.Queryable<BllExportNoticeDetail>().Where(m => m.IsDel == "0" && m.Id == id).ToList().FirstOrDefault();
                //出库单明细                
                var notice = Db.Queryable<BllExportNotice>().Where(m => m.IsDel == "0" && m.SONo == noticeDetail.SONo).ToList().FirstOrDefault();

                if (noticeDetail == null)
                {
                    throw  new Exception("未查询到出库单明细信息");
                }
                if (notice == null)
                {
                    throw new Exception("未查询到出库单信息");
                }
                if (notice.Status != "0")
                {
                    throw new Exception("当前出库单状态不是等待执行，不能删除");
                }
                if (noticeDetail.AllotQty > 0)
                {
                    throw new Exception("当前出库单明细已被分配，不能删除");
                }

                var count = Db.Queryable<BllExportNoticeDetail>().Count(d => d.SONo == noticeDetail.SONo && d.IsDel == "0" && d.Id != noticeDetail.Id);
                Db.BeginTran();//开启事务
                try
                {
                    var stock = Db.Queryable<DataStock>().Where(s => s.SkuNo == noticeDetail.SkuNo).ToList();
                    if (!string.IsNullOrWhiteSpace(noticeDetail.LotNo))
                    {
                        stock = stock.Where(s => s.LotNo == noticeDetail.LotNo).ToList();
                    }
                    else
                    {
                        stock = stock.Where(s => string.IsNullOrWhiteSpace(s.LotNo)).ToList();
                    }

                    var sd = stock.FirstOrDefault();
                    if (sd == null)
                    {
                        throw new Exception($"未找到物料{noticeDetail.SkuNo}、批次{noticeDetail.LotNo} 的库存信息");
                    }
                    sd.LockQty -= noticeDetail.Qty;
                    noticeDetail.IsDel = "1";
                    noticeDetail.UpdateUser = userId;
                    noticeDetail.UpdateTime = DateTime.Now;
                    var n = 0;
                    var j = 0;
                    if (count < 1)
                    {
                        notice.IsDel = "1";
                        notice.UpdateUser = userId;
                        notice.UpdateTime = DateTime.Now;

                        n = Db.Updateable(notice).ExecuteCommand();
                        j = 1;
                    } 
                    var m = Db.Updateable(sd).UpdateColumns(it => new { it.LockQty }).ExecuteCommand();

                    var i = Db.Updateable(noticeDetail).ExecuteCommand();

                    //添加操作日志记录
                    var k = new OperationSOServer().AddLogOperationSo("出库作业", "出库单据", notice.SONo, "删除", $"删除了单据号为{notice.SONo}、物料为{noticeDetail.SkuNo}、批次号为{noticeDetail.LotNo}的单据明细信息", userId);

                    if (j>0)
                    {
                        if (n > 0 && m > 0 && i > 0 && k)
                        {
                            Db.CommitTran();
                            return true;
                        }
                    }
                    else
                    {
                        if ( m > 0 && i > 0 && k)
                        {
                            Db.CommitTran();
                            return true;
                        }
                    }
                    
                    Db.RollbackTran();
                    return false;
                }
                catch (Exception e)
                {
                    Db.RollbackTran();
                    throw new Exception(e.Message);
                }

            }
            catch (Exception e)
            {
                throw new Exception("删除出库单明细失败："+e.Message);
            }
        }

        #region 数据归档
        /// <summary>
        /// 查询出库单明细信息
        /// </summary>
        /// <param name="soNo"></param>
        /// <param name="page"></param>
        /// <param name="limit"></param>
        /// <param name="count"></param>
        /// <returns></returns>
        public List<ExportNoticeDetailDto> GetArchivingExportNoticeDetailList(string soNo, int page, int limit, out int count)
        {
            string sqlString = string.Empty;
            string sqlCount = string.Empty;
            string sqlPub = string.Empty;
            try
            {
                if (string.IsNullOrWhiteSpace(soNo))
                {
                    throw new Exception("出库单号为空");
                }
                var notice = DataContext.Db.Queryable<BllExportNotice>().Where(m => m.IsDel == "0" && m.SONo == soNo).ToList().FirstOrDefault();
                if (notice == null)
                {
                    throw new Exception("此出库单号不存在");
                }

                sqlCount += "SELECT DISTINCT COUNT(tb1.ID) FROM BllExportNoticeDetail AS tb1 ";

                sqlString += "SELECT DISTINCT tb1.Id,tb1.SONo,tb1.Status,tb1.Origin,tb1.LotNo,tb1.CompleteQty,tb1.PackagNo,tb2.PackagName ";
                sqlString += "tb1.LotText,tb1.SupplierLot,tb1.SkuNo,tb1.SkuName,tb1.Standard,tb1.IsWave,tb1.WaveNo,tb1.Price,tb1.Money,";
                sqlString += "tb1.Qty,tb1.AllotQty,tb1.FactQty,tb1.IsBale,tb1.IsBelt,";
                sqlString += "tb3.RealName as CreateUserName,tb4.RealName as UpdateUserName,tb1.CreateTime,tb1.UpdateTime ";
                sqlString += " FROM BllExportNoticeDetail AS tb1 ";

                sqlPub += "LEFT JOIN SysPackag AS tb2 ON tb1.PackagNo = tb2.PackagNo ";
                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.SONo = '{soNo}' ";
                sqlCount += sqlPub + "AND tb1.IsDel = '0' ";
                sqlPub += "AND tb1.IsDel = '0' order by tb1.CreateTime desc ";


                if (page == 0)
                {
                    page = 1;
                }
                sqlString += sqlPub + $" offset {((page - 1) * limit)} rows fetch next {limit} rows only;";

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

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

                return modelList;
            }
            catch (Exception ex)
            {
                throw ex;
            }
        }
        #endregion
    }
}