Win.Sfs.SmartSettlementSystem.PG/src/Modules/SettleAccount/src/SettleAccount.Job/Services/Report/UnSettledSumService.cs

using Magicodes.ExporterAndImporter.Core;
using Magicodes.ExporterAndImporter.Excel;
using Shouldly;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using TaskJob.EventArgs;
using TaskJob.Interfaces;
using Volo.Abp.BlobStoring;
using Volo.Abp.DependencyInjection;
using Volo.Abp.Uow;
using Win.Sfs.BaseData.ImportExcelCommon;
using Win.Sfs.SettleAccount;
using Win.Sfs.SettleAccount.Errors;
using Win.Sfs.SettleAccount.Repository.SettleAccountJob.Report;

namespace SettleAccount.Job.Services.Report
{
    public class UnSettledSum
    {
        [ExporterHeader(DisplayName = "版本")]
        public string 版本 { set; get; }

        [ExporterHeader(DisplayName = "库位 ")]
        public string 库位             {set;get;}
        [ExporterHeader(DisplayName = "物料组编码 ")]
        public string 物料组编码       {set;get;}
        [ExporterHeader(DisplayName = "物料组车型")]
        public string 物料组车型       {set;get;}
        [ExporterHeader(DisplayName = "物料号")]
        public string 物料号           {set;get;}
        [ExporterHeader(DisplayName = "物料描述")]
        public string 物料描述         {set;get;}
        //[ExporterHeader(DisplayName = "客户物料")]
        //public string 客户物料         {set;get;}
        [ExporterHeader(DisplayName = "WMS期初库存")]
        public string WMS期初库存      {set;get;}
        [ExporterHeader(DisplayName = "本月增加")]
        public string 本月增加         {set;get;}
        [ExporterHeader(DisplayName = "本月减少")]
        public string 本月减少         {set;get;}
        [ExporterHeader(DisplayName = "WMS期末库存")]
        public string WMS期末库存      {set;get;}
        [ExporterHeader(DisplayName = "SAS未结明细汇总")]
        public string SAS未结明细汇总  {set;get;}
        [ExporterHeader(DisplayName = "差异")]
        public string 差异 { set; get; }
    }

    public class UnSettledSumService : ITransientDependency, IExportJob
    {
        private readonly HQHSettledDetailDapperRepository _hqkanbanDapper;
        private readonly KanbanUnSettledDapperRepository _kanbanDapper;
        private readonly UnSettledDetailDapperRepository _dapper;
        private readonly WmsDapperRepository _wmsDapper;
        private readonly OutputService _outputService;
        private readonly ErpPartDapperRepository _erpDapper;
        private readonly SettleSparePartDapperReportRepository _sparepartdapper;
        private readonly ISettleAccountBranchEfCoreRepository<ErrorBill, Guid> _errorListRepository;
        private readonly IBlobContainer<MyFileContainer> _fileContainer;
        public UnSettledSumService(
         HQHSettledDetailDapperRepository hqkanbanDapper,
         KanbanUnSettledDapperRepository kanbanDapper,
         UnSettledDetailDapperRepository dapper,
            OutputService outputService,
            ErpPartDapperRepository erpDapper,
            WmsDapperRepository wmsDapper,
            SettleSparePartDapperReportRepository sparepartdapper,
               IBlobContainer<MyFileContainer> fileContainer,
               ISettleAccountBranchEfCoreRepository<ErrorBill, Guid> errorListRepository
            )
        {
            _wmsDapper = wmsDapper;
            _hqkanbanDapper = hqkanbanDapper;
            _kanbanDapper = kanbanDapper;
            _dapper = dapper;
            _outputService = outputService;
            _erpDapper = erpDapper;
            _sparepartdapper = sparepartdapper;
            _fileContainer = fileContainer; 
            _errorListRepository = errorListRepository;
        }
        [UnitOfWork(false)]
        public string ExportFile(Guid id, List<string> exportName, List<CustomCondition> p_list)
        {
         
            var _lsExport= GetReport(id,exportName,p_list);
            var _lsleft = GetLeftReport(id, exportName, p_list);

 


            //ExcelExporter _exporter = new ExcelExporter();//导出Excel
            //var result = _exporter.Append(_lsExport, "汇总核对表1")
            ////.SeparateBySheet()
            ////.Append(_lsleft, "汇总核对表2")
            //.ExportAppendDataAsByteArray();

            //result.ShouldNotBeNull();
            //_fileContainer.SaveAsync(String.Format("结算未结寄售核对表{0}.xlsx",Guid.NewGuid().ToString("N")), result.Result, true);



            var _first = exportName.FirstOrDefault();
            _outputService.Export<UnSettledSum>(id, _first, _lsExport);
            return id.ToString();


        }





        [UnitOfWork(false)]
        public List<UnSettledSum> GetFisSum(Guid id, List<string> exportName, List<CustomCondition> p_list)
        {
            var _first = exportName.FirstOrDefault();
            var version = p_list.Where(p => p.Name == "Version").FirstOrDefault().Value;
         
            var materailCode = p_list.Where(p => p.Name == "MaterialCode").FirstOrDefault().Value;
            var materialGroup = p_list.Where(p => p.Name == "MaterialGroup").FirstOrDefault().Value;
            //var sapcode = p_list.Where(p => p.Name == "SapMaterialCode").FirstOrDefault().Value;
            var begin = p_list.Where(p => p.Name == "Begin").FirstOrDefault().Value;
            var end = p_list.Where(p => p.Name == "End").FirstOrDefault().Value;
            //var kenncode = p_list.Where(p => p.Name == "KennCode").FirstOrDefault().Value;
            //var chassisNumber = p_list.Where(p => p.Name == "ChassisNumber").FirstOrDefault().Value;
            //var sapCode = p_list.Where(p => p.Name == "SapCode").FirstOrDefault().Value;
            //var cp7begin = p_list.Where(p => p.Name == "CP7Begin").FirstOrDefault().Value;
            //var cp7end = p_list.Where(p => p.Name == "CP7End").FirstOrDefault().Value;
            var datestr = version.Substring(0, 4) + "-" + version.Substring(4, 2) + "-01";
            var date = DateTime.Parse(datestr).AddMonths(1).AddDays(-1);
            var datetime = date.ToShortDateString() + " 23:59:59 ";

            var _list = _dapper.GetDiffReport(DateTime.Now.Year.ToString(), begin, datetime, "", version, materailCode, materialGroup, "");
            var _checkList = _errorListRepository.ToList();
            var query = from itm in _list
                        join itm1 in _checkList on new { ChassisNumber = itm.ChassisNumber, MaterialCode = itm.MaterialCode, WmsBillNum = itm.WmsBillNum }
equals new { ChassisNumber = itm1.BillNum, MaterialCode = itm1.MaterialCode, WmsBillNum = itm1.WmsBillNum } into temp1
                        from tm1 in temp1.DefaultIfEmpty()
                        where tm1 == null
                        select itm;
            _list = query.ToList();

            var _ls = _list.Where(p => p.Flag != "L").Where(p => p.ParentSapMaterialCode != p.SapMaterialCode).GroupBy(p => new { p.KENNCode, p.ChassisNumber, p.ParentSapMaterialCode }).Select(p => p.FirstOrDefault()).ToList();
            var _lst = _erpDapper.GetSapList(_ls, version, false);
            _lst.ForEach(p =>
            {

                p.Qty = 1;
                p.DiffAMT = Math.Round(p.Qty * p.Price, 2);
                p.DiffQty = 1;
            }
            );

            _list.AddRange(_lst);
            _list = _list.Where(p => p.SapMaterialCode == p.ParentSapMaterialCode).ToList();



            if (!string.IsNullOrEmpty(materialGroup))
            {
                var _groupList = materialGroup.Split(new char[] { ',' }).Distinct().ToList();
                if (_groupList.Count() > 0)
                {
                    _list = _list.Where(p => _groupList.Contains(p.MaterialGroup)).ToList();
                }
            }
            //if (!string.IsNullOrEmpty(kenncode))
            //{
            //    var _groupList = kenncode.Split(new char[] { '\n' }).Distinct().ToList();
            //    if (_groupList.Count() > 0)
            //    {
            //        _list = _list.Where(p => _groupList.Contains(p.KENNCode)).ToList();
            //    }
            //}
            //if (!string.IsNullOrEmpty(chassisNumber))
            //{
            //    var _groupList = chassisNumber.Split(new char[] { '\n' }).Distinct().ToList();
            //    if (_groupList.Count() > 0)
            //    {
            //        _list = _list.Where(p => _groupList.Contains(p.ChassisNumber)).ToList();
            //    }
            //}
            //if (!string.IsNullOrEmpty(sapCode))
            //{
            //    var _groupList = sapCode.Split(new char[] { '\n' }).Distinct().ToList();
            //    if (_groupList.Count() > 0)
            //    {
            //        _list = _list.Where(p => _groupList.Contains(p.SapMaterialCode)).ToList();
            //    }
            //}
            if (!string.IsNullOrEmpty(materailCode))
            {
                var _groupList = materailCode.Split(new char[] { '\n' }).Distinct().ToList();
                if (_groupList.Count() > 0)
                {
                    _list = _list.Where(p => _groupList.Contains(p.SapMaterialCode)).ToList();
                }
            }






            var _fislist =_list.GroupBy(p => new { p.SapMaterialCode, p.MaterialDesc, p.MaterialGroup, p.MaterialCode })
                .Select(p => new UnSettledSum
                {
                    库位 = "PLJS",
                    版本 = version,
                    物料号 = p.Key.SapMaterialCode,
                    //客户物料 = p.Key.MaterialCode,
                    物料描述 = p.Key.MaterialDesc,
                    物料组车型 = p.Key.MaterialGroup,
                    SAS未结明细汇总 = p.Sum(p => p.Qty).ToString()

                }).ToList();
            return _fislist;
        }

        /// <summary>
        /// 大众看板未结数据
        /// </summary>
        /// <param name="id"></param>
        /// <param name="exportName"></param>
        /// <param name="p_list"></param>
        /// <returns></returns>
        public List<UnSettledSum> GetKanbanSum(Guid id, List<string> exportName, List<CustomCondition> p_list)
        {
            var _filename = exportName.FirstOrDefault();
            var version = p_list.Where(p => p.Name == "Version").FirstOrDefault().Value;
            var begin = p_list.Where(p => p.Name == "Begin").FirstOrDefault().Value;
            var end = p_list.Where(p => p.Name == "End").FirstOrDefault().Value;
            var materailCode = p_list.Where(p => p.Name == "MaterialCode").FirstOrDefault().Value;
            var materialGroup = p_list.Where(p => p.Name == "MaterialGroup").FirstOrDefault().Value;
            //var sapCode = p_list.Where(p => p.Name == "SAPCode").FirstOrDefault().Value;
            //var iscontionversion = p_list.Where(p => p.Name == "IsContainVersion").FirstOrDefault().Value;
            var iscontionversion = "1";//不分版本，全查




            //var version = p_list.Where(p => p.Name == "Version").FirstOrDefault().Value;
            //var customerCode = p_list.Where(p => p.Name == "CustomerCode").FirstOrDefault().Value;
            //var materailCode = p_list.Where(p => p.Name == "MaterialCode").FirstOrDefault().Value;
            //var materialGroup = p_list.Where(p => p.Name == "MaterialGroup").FirstOrDefault().Value;
            //var sapcode = p_list.Where(p => p.Name == "SapMaterialCode").FirstOrDefault().Value;
            //var begin = p_list.Where(p => p.Name == "Begin").FirstOrDefault().Value;
            //var end = p_list.Where(p => p.Name == "End").FirstOrDefault().Value;
            //var kenncode = p_list.Where(p => p.Name == "KennCode").FirstOrDefault().Value;
            //var chassisNumber = p_list.Where(p => p.Name == "ChassisNumber").FirstOrDefault().Value;
            //var sapCode = p_list.Where(p => p.Name == "SapCode").FirstOrDefault().Value;
            var datestr = version.Substring(0, 4) + "-" + version.Substring(4, 2) + "-01";
            var date = DateTime.Parse(datestr).AddMonths(1).AddDays(-1);
            var datetime = date.ToShortDateString() + " 23:59:59 ";

            var _ls = _kanbanDapper.GetKanbanReportList(version, begin, datetime, iscontionversion);


            //if (!string.IsNullOrEmpty(sapCode))
            //{
            //    var _groupList = sapCode.Split(new char[] { '\n' }).Distinct().ToList();
            //    if (_groupList.Count() > 0)
            //    {
            //        _ls = _ls.Where(p => _groupList.Contains(p.SapCode)).ToList();
            //    }
            //}

            if (!string.IsNullOrEmpty(materailCode))
            {
                var _groupList = materailCode.Split(new char[] { '\n' }).Distinct().ToList();
                if (_groupList.Count() > 0)
                {
                    _ls = _ls.Where(p => _groupList.Contains(p.CustomerPartCode)).ToList();
                }
            }
            if (!string.IsNullOrEmpty(materialGroup))
            {
                var _groupList = materialGroup.Split(new char[] { ',' }).Distinct().ToList();
                if (_groupList.Count() > 0)
                {
                    _ls = _ls.Where(p => _groupList.Contains(p.MaterialGroup)).ToList();
                }
            }

            //应用屏蔽错误信息功能，将其屏蔽的信息从生成的列表中排除掉，20220629
            var _checkList = _errorListRepository.ToList();

            var query = from itm in _ls
                        join itm1 in _checkList on new { ChassisNumber = itm.Kanban, MaterialCode = itm.CustomerPartCode, WmsBillNum = itm.WmsBillNum }
            equals new { ChassisNumber = itm1.BillNum, MaterialCode = itm1.CustomerMaterialCode, WmsBillNum = itm1.WmsBillNum } into temp1
                        from tm1 in temp1.DefaultIfEmpty()
                        where tm1 == null
                        select itm;
            _ls = query.ToList();


            //DiffQty 为实际发货数量=发货数量-结算数量-退货数量 财务要求
            var kanbanList = _ls.GroupBy(p => new { p.SapCode, p.MaterialDesc, p.MaterialGroup, p.CustomerPartCode })
                   .Select(p => new UnSettledSum
                   {
                       库位 = "PLJS",
                       版本 = version,
                       物料号 = p.Key.SapCode,
                       //客户物料 = p.Key.CustomerPartCode,
                       物料描述 = p.Key.MaterialDesc,
                       物料组车型 = p.Key.MaterialGroup,
                       SAS未结明细汇总 = p.Sum(p => p.DiffQty).ToString()

                   }).ToList();



            return kanbanList;
        }


        /// <summary>
        /// 红旗看板未结明细
        /// </summary>
        /// <param name="id"></param>
        /// <param name="exportName"></param>
        /// <param name="p_list"></param>
        /// <returns></returns>
        public List<UnSettledSum> GetHQKanbanSum(Guid id, List<string> exportName, List<CustomCondition> p_list)
        {
            var _filename = exportName.FirstOrDefault();
            var version = p_list.Where(p => p.Name == "Version").FirstOrDefault().Value;
            var materialCode = p_list.Where(p => p.Name == "MaterialCode").FirstOrDefault().Value;
            //var kanban = p_list.Where(p => p.Name == "Kanban").FirstOrDefault().Value;
            var begin = p_list.Where(p => p.Name == "Begin").FirstOrDefault().Value;
            var end = p_list.Where(p => p.Name == "End").FirstOrDefault().Value;
            var materialGroup = p_list.Where(p => p.Name == "MaterialGroup").FirstOrDefault().Value;
            //var acceptNo = p_list.Where(p => p.Name == "AcceptNo").FirstOrDefault().Value;
            var sapCode = p_list.Where(p => p.Name == "SapCode").FirstOrDefault().Value;
            //var warehouseDesc = p_list.Where(p => p.Name == "WarehouseDesc").FirstOrDefault().Value;
            //var iscontionversion = p_list.Where(p => p.Name == "IsContainVersion").FirstOrDefault().Value;
            var iscontionversion = "1";//不分区间，全查
                                       //有发货无结算，单独拿出去，财务要求

            var datestr = version.Substring(0, 4) + "-" + version.Substring(4, 2) + "-01";
            var date = DateTime.Parse(datestr).AddMonths(1).AddDays(-1);
            var datetime = date.ToShortDateString() + " 23:59:59 ";

            var _ls = _hqkanbanDapper.GetReverseSettledDetailDiffReportList(version, materialCode, begin, datetime, materialGroup, iscontionversion);
            if (!string.IsNullOrEmpty(sapCode))
            {
                var _groupList = sapCode.Split(new char[] { '\n' }).Distinct().ToList();
                if (_groupList.Count() > 0)
                {
                    _ls = _ls.Where(p => _groupList.Contains(p.Sap编码)).ToList();
                }
            }

            //应用屏蔽错误信息功能，将其屏蔽的信息从生成的列表中排除掉，20220629
            var _checkList = _errorListRepository.ToList();

            var query = from itm in _ls
                        join itm1 in _checkList on new { ChassisNumber = itm.订货看板编号, MaterialCode = itm.客户物料号, WmsBillNum = itm.交货单号 }
            equals new { ChassisNumber = itm1.BillNum, MaterialCode = itm1.CustomerMaterialCode, WmsBillNum = itm1.WmsBillNum } into temp1
                        from tm1 in temp1.DefaultIfEmpty()
                        where tm1 == null
                        select itm;
            _ls = query.ToList();

            var kanbanList = _ls.GroupBy(p => new { p.Sap编码, p.零件中文名称, p.物料组, p.客户物料号 })
                   .Select(p => new UnSettledSum
                   {
                       库位="PLJS",
                       版本=version,
                       物料号 = p.Key.Sap编码,
                       //客户物料 = p.Key.客户物料号,
                       物料描述 = p.Key.零件中文名称,
                       物料组车型 = p.Key.物料组,
                       SAS未结明细汇总 = p.Sum(p => p.未结数量).ToString()

                   }).ToList();

            return kanbanList;
        }

        /// <summary>
        /// 大众备件未对
        /// </summary>
        /// <param name="id"></param>
        /// <param name="exportName"></param>
        /// <param name="p_list"></param>
        /// <returns></returns>
        public List<UnSettledSum> GetSparePartSum(Guid id, List<string> exportName, List<CustomCondition> p_list)
        {
            var fileName = exportName.FirstOrDefault();
            //var purchaseOrderNo = p_list.Where(p => p.Name == "PurchaseOrderNo").FirstOrDefault().Value;
            var version = p_list.Where(p => p.Name == "Version").FirstOrDefault().Value;
            var sapCode = p_list.Where(p => p.Name == "SapCode").FirstOrDefault().Value;
            var matialCode = p_list.Where(p => p.Name == "MaterialCode").FirstOrDefault().Value;
            var beginTime = p_list.Where(p => p.Name == "Begin").FirstOrDefault().Value;
            var endTime = p_list.Where(p => p.Name == "End").FirstOrDefault().Value;

            var datestr = version.Substring(0, 4) + "-" + version.Substring(4, 2) + "-01";
            var date = DateTime.Parse(datestr).AddMonths(1).AddDays(-1);
            var datetime = date.ToShortDateString() + " 23:59:59 ";

            //var _ls = _sparepartdapper.GetReverseWithCodeSettleSparePartReportList(purchaseOrderNo, version, sapCode, matialCode, beginTime, endTime);
            var _ls = _sparepartdapper.GetReverseWithCodeSettleSparePartReportList("", version, sapCode, matialCode, beginTime, datetime);
            if (!string.IsNullOrEmpty(sapCode))
            {
                var _groupList = sapCode.Split(new char[] { '\n' }).Distinct().ToList();
                if (_groupList.Count() > 0)
                {
                    _ls = _ls.Where(p => _groupList.Contains(p.SAP编码)).ToList();
                }
            }


            //应用屏蔽错误信息功能，将其屏蔽的信息从生成的列表中排除掉，20220629
            var _checkList = _errorListRepository.ToList();

            var query = from itm in _ls
                        join itm1 in _checkList on new { ChassisNumber = itm.采购订单号, MaterialCode = itm.物料代码, WmsBillNum = itm.交货单号 }
            equals new { ChassisNumber = itm1.BillNum, MaterialCode = itm1.CustomerMaterialCode, WmsBillNum = itm1.WmsBillNum } into temp1
                        from tm1 in temp1.DefaultIfEmpty()
                        where tm1 == null
                        select itm;
            _ls = query.ToList();


            //说明 为实际发货数量=发货数量-结算数量-退货数量 财务要求
            var kanbanList = _ls.GroupBy(p => new { p.SAP编码, p.物料描述, p.物料代码 })
                               .Select(p => new UnSettledSum
                               {
                                   库位 = "BJJS",
                                   版本 = version,
                                   物料号 = p.Key.SAP编码,
                                   //客户物料 = p.Key.物料代码,
                                   物料描述 = p.Key.物料描述,
                                   物料组车型 = string.Empty,
                                   SAS未结明细汇总 = p.Sum(p =>Convert.ToDecimal(p.实际发货数量)).ToString()

                               }).ToList();

            return kanbanList;
        }





        public List<UnSettledSum> GetReport(Guid id, List<string> exportName, List<CustomCondition> p_list)
        {
            var version = p_list.Where(p => p.Name == "Version").FirstOrDefault().Value;
            List<UnSettledSum> _ls = new List<UnSettledSum>();
           _ls.AddRange(GetFisSum(id, exportName, p_list));
            _ls.AddRange(GetHQKanbanSum(id, exportName, p_list));
            _ls.AddRange(GetKanbanSum(id, exportName, p_list));
            _ls.AddRange(GetSparePartSum(id, exportName, p_list));//大众备件未结



            var _lst = _wmsDapper.GetSalesStockSum(version);
            var query = from itm in _lst 
                        join itm1 in _ls
     on new { Version = itm.Version, PartCode = itm.PartCode.Trim(), LocCode= itm.LocCode.ToUpper()} equals new { Version = itm1.版本, PartCode = itm1.物料号.Trim(), LocCode = itm1.库位}
into temp
                        from tm in temp.DefaultIfEmpty()
                        select new UnSettledSum
                        {

                            版本 = itm.Version,
                            物料号 = itm.PartCode,
                            物料描述 = itm.PartDesc,
                            物料组编码= itm.PartGroup,
                            物料组车型 = itm.PartGroupDesc,
                            SAS未结明细汇总 = tm == null ? "0" : tm.SAS未结明细汇总,
                            WMS期初库存 = itm.StartQty.ToString(),
                            WMS期末库存 = itm.EndQty.ToString(),
                            库位 = itm.LocCode,
                            本月减少 = itm.OutQty.ToString(),
                            本月增加 = itm.InQty.ToString(),
                            差异= (itm.EndQty- decimal.Parse( tm == null ? "0" : tm.SAS未结明细汇总)).ToString()


                        };
            return query.ToList();
        }


        public List<UnSettledSum> GetLeftReport(Guid id, List<string> exportName, List<CustomCondition> p_list)
        {
            var version = p_list.Where(p => p.Name == "Version").FirstOrDefault().Value;
            List<UnSettledSum> _ls = new List<UnSettledSum>();
            _ls.AddRange(GetFisSum(id, exportName, p_list));
            _ls.AddRange(GetHQKanbanSum(id, exportName, p_list));
            _ls.AddRange(GetKanbanSum(id, exportName, p_list));
            _ls.AddRange(GetSparePartSum(id, exportName, p_list));//大众备件未结



            var _lst = _wmsDapper.GetSalesStockSum(version);
            var query = from itm in   _ls
                        join itm1 in _lst
     on new  { Version = itm.版本, PartCode = itm.物料号.Trim(), LocCode = itm.库位 } equals
            new { Version = itm1.Version, PartCode = itm1.PartCode.Trim(), LocCode = itm1.LocCode.ToUpper() } 
into temp
                        from tm in temp.DefaultIfEmpty()
                        select new UnSettledSum
                        {

                            版本 = itm.版本,
                            物料号 = itm.物料号,
                            物料描述 = itm.物料号,
                            物料组编码 = itm.物料组编码,
                            物料组车型 = itm.物料组车型,
                            SAS未结明细汇总 = tm == null ? "0" : tm.EndQty.ToString(),
                            WMS期初库存 = tm == null ? "0" : tm.StartQty.ToString(),
                            WMS期末库存 = tm == null ? "0" : tm.EndQty.ToString(),
                            库位 = itm.库位,
                            本月减少 = tm == null ? "0" : tm.OutQty.ToString(),
                            本月增加 = tm == null ? "0" : tm.InQty.ToString(),
                            差异 = ((tm == null ? 0 : tm.EndQty) - decimal.Parse(tm == null ? "0" : itm.SAS未结明细汇总)).ToString()


                        };
            return query.ToList();
        }






    }
}