using JNPF;
using JNPF.Common.Core.Manager;
using JNPF.Common.Extension;
using JNPF.Common.Filter;
using JNPF.Common.Security;
using JNPF.DependencyInjection;
using JNPF.DynamicApiController;
using JNPF.Extras.CollectiveOAuth.Models;
using JNPF.Extras.CollectiveOAuth.Utils;
using JNPF.FriendlyException;
using JNPF.Logging;
using JNPF.Systems.Entitys.Permission;
using JNPF.Systems.Entitys.System;
using JNPF.Systems.Interfaces.System;
using JNPF.VisualDev;
using JNPF.VisualDev.Entitys.Dto.VisualDevModelData;
using JNPF.VisualDev.Interfaces;
using Microsoft.AspNetCore.Mvc;
using Newtonsoft.Json;
using SqlSugar;
using Tnb.BasicData;
using Tnb.BasicData.Entities;
using Tnb.EquipMgr.Entities;
using Tnb.ProductionMgr.Entities;
using Tnb.ProductionMgr.Entities.Dto;
using Tnb.ProductionMgr.Entities.Dto.PrdManage;
using Tnb.ProductionMgr.Entities.Enums;
using Tnb.ProductionMgr.Interfaces;
using AuthResponse = JNPF.Extras.CollectiveOAuth.Models.AuthResponse;
using StringExtensions = JNPF.Common.Extension.StringExtensions;

namespace Tnb.ProductionMgr
{
    /// <summary>
    /// 生产计划管理
    /// </summary>
    [ApiDescriptionSettings(Tag = ModuleConst.Tag, Area = ModuleConst.Area, Order = 700)]
    [Route("api/[area]/[controller]/[action]")]
    [OverideVisualDev(ModuleId)]
    public class PrdMoService : IOverideVisualDevService, IPrdMoService, IDynamicApiController, ITransient
    {
        // private const string ModuleId = "25018860321301";
        private const string ModuleId = "26900026924053";
        private readonly ISqlSugarRepository<PrdMo> _repository;
        private readonly IDataBaseManager _dataBaseManager;
        private readonly IUserManager _userManager;
        private readonly IDictionaryDataService _dictionaryDataService;
        private readonly IRunService _runService;
        private readonly IVisualDevService _visualDevService;
        private readonly ISqlSugarClient _db;

        public OverideVisualDevFunc OverideFuncs { get; } = new OverideVisualDevFunc();

        public PrdMoService(
            ISqlSugarRepository<PrdMo> repository,
            IDataBaseManager dataBaseManager,
            IUserManager userManager,
            IDictionaryDataService dictionaryDataService,
            IRunService runService,
            IVisualDevService visualDevService
            )
        {
            _repository = repository;
            _dataBaseManager = dataBaseManager;
            _userManager = userManager;
            _dictionaryDataService = dictionaryDataService;
            _runService = runService;
            _visualDevService = visualDevService;
            _db = _repository.AsSugarClient();
            OverideFuncs.GetListAsync = GetList;
        }

        // private async Task<dynamic> GetList(VisualDevModelListQueryInput input)
        // {
        //     var db = _repository.AsSugarClient();
        //     VisualDevEntity? templateEntity = await _visualDevService.GetInfoById(ModuleId, true);
        //     var data = await _runService.GetListResult(templateEntity, input);
        //     if (data?.list?.Count > 0)
        //     {
        //         foreach (var row in data.list)
        //         {
        //             var dic = row.ToDictionary(x => x.Key, x => x.Value);
        //             var pkName = "material_id_id";
        //             if (dic.ContainsKey(pkName))
        //             {
        //                 var materialId = dic[pkName]?.ToString();
        //                 var material = await db.Queryable<BasMaterial>().FirstAsync(it => it.id == materialId);
        //                 if (material != null)
        //                 {
        //                     row.Add("material_name", material.name);
        //                     row.Add($"material_attribute", material.attribute);
        //                     if (dic.ContainsKey("material_id"))
        //                     {
        //                         row["material_id"] = material.code + "/" + material.name;
        //                     }
        //                 }
        //
        //                 if (dic.ContainsKey("unit_id"))
        //                 {
        //                     string unitId = dic["unit_id"]?.ToString() ?? "";
        //                     var unit = await db.Queryable<DictionaryDataEntity>().SingleAsync(x => x.Id == unitId);
        //                     row["unit_id"] = unit?.FullName ?? "";
        //                 }
        //             }
        //         }
        //     }
        //     return data!;
        // }
        
        private async Task<dynamic> GetList(VisualDevModelListQueryInput input)
        {
            var db = _repository.AsSugarClient();
            Dictionary<string, string> queryJson = !string.IsNullOrEmpty(input.queryJson) ? Newtonsoft.Json.JsonConvert.DeserializeObject<Dictionary<string, string>>(input.queryJson) : new Dictionary<string, string>();
            string moCode = queryJson.ContainsKey("mo_code") ? queryJson["mo_code"].ToString() : "";
            string moStatus = queryJson.ContainsKey("mo_status") ? queryJson["mo_status"].ToString() : "";
            string combineMoCode = queryJson.ContainsKey("combine_mo_code") ? queryJson["combine_mo_code"].ToString() : "";
            var result = await db.Queryable<PrdMo>()
                .LeftJoin<BasMaterial>((a, b) => a.material_id == b.id)
                .LeftJoin<DictionaryTypeEntity>((a, b, c) => c.EnCode == DictConst.MeasurementUnit)
                .LeftJoin<DictionaryDataEntity>((a, b, c, d) => c.Id == d.DictionaryTypeId && a.unit_id == d.Id)
                .LeftJoin<DictionaryDataEntity>((a, b, c, d, e) => a.mo_status == e.Id)
                .LeftJoin<DictionaryDataEntity>((a, b, c, d, e,f) => a.mo_type==f.Id)
                .WhereIF(!string.IsNullOrEmpty(moCode), (a, b, c, d, e) => a.mo_code.Contains(moCode))
                .WhereIF(!string.IsNullOrEmpty(combineMoCode),
                    (a, b, c, d, e) => a.combine_mo_code.Contains(combineMoCode))
                .WhereIF(!string.IsNullOrEmpty(moStatus), (a, b, c, d, e) => a.mo_status == moStatus)
                .Where(a=>SqlFunc.IsNullOrEmpty(a.parent_id))
                .OrderByDescending(a=>a.create_time)
                .Select((a, b, c, d, e,f) => new PrdMoListOuput
                {
                    id = a.id,
                    mo_type = f.FullName,
                    mo_source = a.mo_source=="1" ? "ERP同步" : "新建/导入",
                    mo_code = a.mo_code,
                    plan_start_date = a.plan_start_date==null ? "" : a.plan_start_date.Value.ToString("yyyy-MM-dd"),
                    plan_end_date = a.plan_end_date==null ? "" : a.plan_end_date.Value.ToString("yyyy-MM-dd"),
                    material_id = b.code+"/"+b.name,
                    material_id_id = b.id,
                    plan_qty = a.plan_qty,
                    unit_id = d.FullName,
                    mo_status = e.FullName,
                    remark = a.remark,
                    children = SqlFunc.Subqueryable<PrdMo>()
                        .LeftJoin<BasMaterial>((aa, bb) => aa.material_id == bb.id)
                        .LeftJoin<DictionaryTypeEntity>((aa, bb, cc) => cc.EnCode == DictConst.MeasurementUnit)
                        .LeftJoin<DictionaryDataEntity>((aa, bb, cc, dd) => cc.Id == dd.DictionaryTypeId && aa.unit_id == dd.Id)
                        .LeftJoin<DictionaryDataEntity>((aa, bb, cc, dd, ee) => aa.mo_status == ee.Id)
                        .LeftJoin<DictionaryDataEntity>((aa, bb, cc, dd, ee,ff) => aa.mo_type==ff.Id)
                        .Where(aa=>aa.parent_id==a.id)
                        .ToList((aa,bb,cc,dd,ee,ff)=>new PrdMoListOuput
                        {
                            id = aa.id,
                            mo_type = ff.FullName,
                            mo_source = aa.mo_source=="1" ? "ERP同步" : "新建/导入",
                            mo_code = aa.mo_code,
                            plan_start_date = aa.plan_start_date==null ? "" : aa.plan_start_date.Value.ToString("yyyy-MM-dd"),
                            plan_end_date = aa.plan_end_date==null ? "" : aa.plan_end_date.Value.ToString("yyyy-MM-dd"),
                            material_id = bb.code+"/"+bb.name,
                            material_id_id = bb.id,
                            plan_qty = aa.plan_qty,
                            unit_id = dd.FullName,
                            mo_status = ee.FullName,
                            remark = aa.remark,
                        })
                }).ToPagedListAsync(input.currentPage, int.MaxValue);
            return PageResult<PrdMoListOuput>.SqlSugarPageResult(result);
        }


        #region Get


        /// <summary>
        /// 获取自建报废记录
        /// </summary>
        /// <param name="icmoCode"></param>
        /// <returns></returns>
        [HttpGet("{icmoCode}")]
        public async Task<dynamic> GetReportRecord(string icmoCode)
        {
            var db = _repository.AsSugarClient();
            var output = new PrdMoTaskDefectOutput();
            //output.mo_task_code = icmoCode;
            //var scrap = (await db.Queryable<PrdScrapped>().FirstAsync(it => it.icmo_code == icmoCode));
            //output.items = new List<CategoryItem>();
            //var categorys = await db.Queryable<PrdScrappedDefectiveCagetory>().Where(it => it.icmo_code == icmoCode).ToListAsync();
            //foreach (var category in categorys)
            //{
            //    var categoryItem = category.Adapt<SelfTestScrappedOutputItem>();
            //    categoryItem.items = new List<PrdScrappedDefectiveItem>();
            //    var items = await db.Queryable<PrdScrappedDefectiveItem>().Where(it => it.defective_cagetory_id == category.id).ToListAsync();
            //    categoryItem.items.AddRange(items);
            //    output.categoryItems.Add(categoryItem);
            //}
            return output;
        }

        #endregion

        #region Post

        /// <summary>
        /// 生产工单创建-生产工单下发
        /// </summary>
        /// <param name="input">生产工单下发输入参数</param>
        /// <returns></returns>
        [HttpPut]
        public async Task<dynamic> WorkOrderIssue(MoCrInput input)
        {
            if (input is null)
            {
                throw new ArgumentNullException(nameof(input));
            }
            if (StringExtensions.IsNullOrWhiteSpace(input.Behavior))
            {
                throw new ArgumentException($"{nameof(input.Behavior)},not be null or empty");
            }

            var db = _repository.AsSugarClient();
            //获取同组工单的Id，一起下发
            var combineMoCodes = await db.Queryable<PrdMo>().Where(it => input.WorkOrderIds.Contains(it.id)).Select(it => it.combine_mo_code).ToListAsync();
            if (combineMoCodes?.Count > 0)
            {
                var moIds = await db.Queryable<PrdMo>().Where(it => combineMoCodes.Contains(it.combine_mo_code) && !input.WorkOrderIds.Contains(it.id)).Select(it => it.id).ToListAsync();
                input.WorkOrderIds = input.WorkOrderIds.Concat(moIds).ToList();
            }

            string getMoStatus(MoBehavior behavior)
            {
                string status = "";
                switch (behavior)
                {
                    case MoBehavior.Release:
                        status = DictConst.IssueId;
                        break;
                    case MoBehavior.Closed:
                        status = DictConst.MoCloseId;
                        break;
                }
                return status!;
            }
            var behavior = input.Behavior.ToEnum<MoBehavior>();
            var status = getMoStatus(behavior);
            var row = await db.Updateable<PrdMo>()
                       .SetColumns(it => new PrdMo { mo_status = status })
                       .Where(it => input.WorkOrderIds.Contains(it.id))
                       .ExecuteCommandAsync();
            return (row > 0);
        }
        // /// <summary>
        // /// 关联同组工单
        // /// </summary>
        // /// <param name="input">关联同组工单输入参数</param>
        // /// <returns></returns>
        // [HttpPost]
        // public async Task<dynamic> RelevancySameGroupMo(MoCrInput input)
        // {
        //     (bool executeRes, string errMsg) multi = (true, "");
        //     var list = await _repository.AsSugarClient().Queryable<PrdMo>()
        //                                                 .InnerJoin<ToolMolds>((a, b) => a.material_id == b.material_id)
        //                                                 .Where((a, b) => input.WorkOrderIds.Contains(a.id))
        //                                                 .Select((a, b) => new
        //                                                 {
        //                                                     planDate = a.plan_start_date,
        //                                                     mold_code = b.mold_code,
        //                                                 }).ToListAsync();
        //     var planDateAll = true;
        //     var moldIdAll = true;
        //     if (list?.Count > 0)
        //     {
        //         var planDate = list.FirstOrDefault()?.planDate;
        //         var moldCode = list.FirstOrDefault()?.mold_code;
        //
        //         planDateAll = list.Skip(1).All(x => x.planDate == planDate);
        //         moldIdAll = list.Skip(1).All(x => x.mold_code == moldCode);
        //         if (planDateAll && moldIdAll)
        //         {
        //             var groupId = SnowflakeIdHelper.NextId();
        //             multi.executeRes = await _repository.AsSugarClient().Updateable<PrdMo>()
        //                                                    .SetColumns(c => new PrdMo { combine_mo_code = groupId })
        //                                                    .Where(it => input.WorkOrderIds.Contains(it.id))
        //                                                    .ExecuteCommandHasChangeAsync();
        //         }
        //         else
        //         {
        //             multi.executeRes = false;
        //             if (!planDateAll)
        //             {
        //                 throw new AppFriendlyException("计划开始日期不一致", null);
        //             }
        //             if (!moldIdAll)
        //             {
        //                 throw new AppFriendlyException("未关联到同一模具下", null);
        //             }
        //         }
        //     }
        //     return multi;
        // }
        
        /// <summary>
        /// 关联同组工单
        /// </summary>
        /// <param name="input">关联同组工单输入参数</param>
        /// <returns></returns>
        [HttpPost]
        public async Task<dynamic> RelevancySameGroupMo(MoCrInput input)
        {
            (bool executeRes, string errMsg) multi = (true, "");
            var list = await _repository.AsSugarClient().Queryable<PrdMo>()
                                                        .LeftJoin<ToolMoldsMaterial>((a, b) => a.material_id == b.material_id)
                                                        .LeftJoin<ToolMolds>((a,b,c)=>b.mold_id==c.id)
                                                        .Where((a, b,c) => input.WorkOrderIds.Contains(a.id))
                                                        .Select((a, b,c) => new
                                                        {
                                                            planDate = a.plan_start_date,
                                                            mold_code = c.mold_code,
                                                        }).ToListAsync();
            var planDateAll = true;
            var moldIdAll = true;
            if (list?.Count > 0)
            {
                var planDate = list.FirstOrDefault()?.planDate;
                var moldCode = list.FirstOrDefault()?.mold_code;

                planDateAll = list.All(x => x.planDate == planDate);
                moldIdAll = moldCode != null && list.All(x => x.mold_code == moldCode);
                if (planDateAll && moldIdAll)
                {
                    var groupId = SnowflakeIdHelper.NextId();
                    multi.executeRes = await _repository.AsSugarClient().Updateable<PrdMo>()
                                                           .SetColumns(c => new PrdMo { combine_mo_code = groupId })
                                                           .Where(it => input.WorkOrderIds.Contains(it.id))
                                                           .ExecuteCommandHasChangeAsync();
                }
                else
                {
                    multi.executeRes = false;
                    if (!planDateAll)
                    {
                        throw Oops.Bah("计划开始日期不一致");
                    }
                    if (!moldIdAll)
                    {
                        throw Oops.Bah("未关联到同一模具下");
                    }
                }
            }
            return multi;
        }

        /// <summary>
        /// 取消关联
        /// </summary>
        /// <param name="input">取消关联输入参数</param>
        /// <returns></returns>
        [HttpPost]
        public async Task<dynamic> CanelRelevancy(MoCrInput input)
        {
            return await _repository.AsSugarClient().Updateable<PrdMo>()
                                                    .SetColumns(c => new PrdMo { combine_mo_code = "" })
                                                    .Where(it => input.WorkOrderIds.Contains(it.id))
                                                    .ExecuteCommandHasChangeAsync();
        }

        

        #endregion

        #region 正向工单追溯相关

        /// <summary>
        /// 工单追溯一级列表
        /// </summary>
        /// <param name="input"></param>
        /// <returns></returns>
        [HttpPost]
        public async Task<dynamic> PrdMoFromOneList(PrdMoFromQueryInput input)
        {
            List<string> ids = new List<string>();
            List<string> ids1 = new List<string>();
            List<string> ids2 = new List<string>();
            if (!string.IsNullOrEmpty(input.mo_task_code))
            {
                ids1 = await _db.Queryable<PrdMoTask>().Where(x => x.mo_task_code.Contains(x.mo_task_code)).Select(x => x.mo_id).ToListAsync();
                ids = ids1;
            }
            if (!string.IsNullOrEmpty(input.barcode))
            {
                ids2 = await _db.Queryable<PrdReport>()
                    .LeftJoin<PrdMoTask>((a,b)=>a.mo_task_id==b.id)
                    .Where((a,b) => a.barcode.Contains(input.barcode)).Select((a,b) => b.mo_id).ToListAsync();
                ids = ids2;
            }

            if (!string.IsNullOrEmpty(input.mo_task_code) && !string.IsNullOrEmpty(input.barcode))
            {
                ids = ids1.Intersect(ids2).ToList();
            }
            
            var result = await _db.Queryable<PrdMo>()
                .LeftJoin<BasMaterial>((a, b) => a.material_id == b.id)
                .WhereIF(!string.IsNullOrEmpty(input.mo_code),(a,b)=>a.mo_code.Contains(input.mo_code))
                .WhereIF(ids!=null && ids.Count>0,(a,b)=>ids.Contains(a.id))
                .Select((a, b) =>
                new PrdMoFromOneListOutput
                {
                    id = a.id,
                    mo_code = a.mo_code,
                    material_id = a.material_id,
                    type = (a.mo_type==DictConst.PrdMoTypeZS || a.mo_type==DictConst.PrdMoTypeJC ) ? 1 : 2,
                    material_code = b.code,
                    material_name = b.name,
                    material_standard = b.material_standard,
                    act_start_date = a.act_start_date==null ? "" : a.act_start_date.Value.ToString("yyyy-MM-dd HH:mm:ss"),
                    act_end_date = a.act_end_date==null ? "" : a.act_end_date.Value.ToString("yyyy-MM-dd HH:mm:ss")
                }).ToPagedListAsync(input.currentPage, input.pageSize);
            return PageResult<PrdMoFromOneListOutput>.SqlSugarPageResult(result);
        }
        
        /// <summary>
        /// 工单追溯二级列表
        /// </summary>
        /// <param name="input"></param>
        /// <returns></returns>
        [HttpPost]
        public async Task<dynamic> PrdMoFromTwoList(PrdMoFromTwoQueryInput prdMoFromTwoQueryInput)
        {
            string mo_id = prdMoFromTwoQueryInput.mo_id ?? "";
            string mo_task_code = prdMoFromTwoQueryInput.mo_task_code ?? "";
            string barcode = prdMoFromTwoQueryInput.barcode ?? "";
            List<string> ids = new List<string>();
            if (!string.IsNullOrEmpty(barcode))
            {
                ids = await _db.Queryable<PrdReport>().Where(x => x.barcode.Contains(barcode)).Select(x=>x.mo_task_id).ToListAsync();
            }
            
            PrdMo prdMo = await _repository.GetSingleAsync(x => x.id == mo_id);
            if (prdMo.mo_type is DictConst.PrdMoTypeZS or DictConst.PrdMoTypeJC)
            {
                return await _db.Queryable<PrdMoTask>()
                    .LeftJoin<BasMaterial>((a, b) => a.material_id == b.id)
                    .LeftJoin<OrganizeRelationEntity>((a,b,c)=>a.eqp_id==c.ObjectId && c.ObjectType=="Eqp")
                    .LeftJoin<OrganizeEntity>((a,b,c,d)=>c.OrganizeId==d.Id)
                    .LeftJoin<OrganizeEntity>((a,b,c,d,e)=>d.OrganizeIdTree.Contains(e.Id) && e.Category==DictConst.RegionCategoryWorkshopCode)
                    .LeftJoin<EqpEquipment>((a,b,c,d,e,f)=>a.eqp_id==f.id)
                    .WhereIF(!string.IsNullOrEmpty(mo_id),(a,b,c,d)=>a.mo_id==mo_id)
                    .WhereIF(!string.IsNullOrEmpty(mo_task_code),(a,b,c,d)=>a.mo_task_code==mo_task_code)
                    .WhereIF(ids!=null && ids.Count>0,(a,b,c,d)=>ids.Contains(a.id))
                    .Select((a, b, c, d,e,f) =>
                        new PrdMoFromTwoListOutput
                        {
                            id = a.id,
                            mo_task_code = a.mo_task_code,
                            material_id = a.material_id,
                            material_code = b.code,
                            material_name = b.name,
                            material_standard = b.material_standard,
                            act_start_date = a.act_start_date == null ? "" : a.act_start_date.Value.ToString("yyyy-MM-dd HH:mm:ss"),
                            act_end_date = a.act_end_date == null ? "" : a.act_end_date.Value.ToString("yyyy-MM-dd HH:mm:ss"),
                            workshop_name = e.FullName,
                            station_name = d.FullName,
                            equip_code = f.code
                        }).ToListAsync();
            }
            else
            {
                return await _db.Queryable<PrdMoTask>()
                    .LeftJoin<BasMaterial>((a, b) => a.material_id == b.id)
                    .LeftJoin<OrganizeEntity>((a, b, c) => a.workline_id == c.Id)
                    .LeftJoin<BasMbom>((a, b, c, d) => a.bom_id == d.id)
                    .WhereIF(!string.IsNullOrEmpty(mo_id),(a,b,c,d)=>a.mo_id==mo_id)
                    .WhereIF(!string.IsNullOrEmpty(mo_task_code),(a,b,c,d)=>a.mo_task_code.Contains(mo_task_code))
                    .WhereIF(ids!=null && ids.Count>0,(a,b,c,d)=>ids.Contains(a.id))
                    .Select((a, b, c, d) =>
                        new PrdMoFromTwoListOutput
                        {
                            id = a.id,
                            mo_task_code = a.mo_task_code,
                            material_id = a.material_id,
                            material_code = b.code,
                            material_name = b.name,
                            material_standard = b.material_standard,
                            act_start_date = a.act_start_date == null ? "" : a.act_start_date.Value.ToString("yyyy-MM-dd HH:mm:ss"),
                            act_end_date = a.act_end_date == null ? "" : a.act_end_date.Value.ToString("yyyy-MM-dd HH:mm:ss"),
                            workline_name = c.FullName,
                            mbom_version = d.version
                        }).ToListAsync();
            }
            
        }
        
        /// <summary>
        /// 工单追溯三级级列表
        /// </summary>
        /// <param name="input"></param>
        /// <returns></returns>
        [HttpPost]
        public async Task<dynamic> PrdMoFromThreeList(PrdMoFromThreeQueryInput prdMoFromThreeQueryInput)
        {
            string mo_task_id = prdMoFromThreeQueryInput.mo_task_id ?? "";
            string mo_task_code = prdMoFromThreeQueryInput.mo_task_code ?? "";
            string barcode = prdMoFromThreeQueryInput.barcode ?? "";
            List<string> ids = new List<string>();
            if (!string.IsNullOrEmpty(barcode))
            {
                ids = await _db.Queryable<PrdReport>().Where(x => x.barcode.Contains(barcode)).Select(x=>x.mo_task_id).ToListAsync();
            }
            
            PrdMoTask prdMoTask = await _db.Queryable<PrdMoTask>().SingleAsync(x => x.id == mo_task_id);
            List<BasProcessStation> processStations = await _db.Queryable<BasProcessStation>().Where(x=>x.process_id==prdMoTask.process_id).ToListAsync();
            List<string> orgIds = processStations.Select(x => x.id).ToList();
            List<OrganizeEntity> orgs = await _db.Queryable<OrganizeEntity>().Where(x=>x.Category==DictConst.RegionCategoryStationCode && x.DeleteMark==null).ToListAsync();
            return await _db.Queryable<PrdMoTask>()
                .LeftJoin<BasMaterial>((a, b) => a.material_id == b.id)
                .LeftJoin<BasProcess>((a,b,c)=>a.process_id==c.id)
                .WhereIF(!string.IsNullOrEmpty(mo_task_id),(a,b,c)=>a.id==mo_task_id)
                .WhereIF(!string.IsNullOrEmpty(mo_task_code),(a,b,c)=>a.mo_task_code.Contains(mo_task_code))
                .WhereIF(ids!=null && ids.Count>0,(a,b,c)=>ids.Contains(a.id))
                .Select((a, b, c) =>
                    new PrdMoFromThreeListOutput
                    {
                        id = a.id,
                        mo_task_code = a.mo_task_code,
                        material_id = a.material_id,
                        material_code = b.code,
                        workline_id = a.workline_id,
                        material_name = b.name,
                        process_id = a.process_id,
                        process_name = c.process_name,
                    }).Mapper(x =>
                {
                    List<string> orgId1 = orgs.Where(y => y.OrganizeIdTree.Contains(x.workline_id)).Select(y=>y.Id).ToList();
                    string station_id = orgIds.Intersect(orgId1)?.FirstOrDefault();
                    if (!string.IsNullOrEmpty(station_id))
                    {
                        x.station_name = orgs.FirstOrDefault(y => y.Id == station_id)?.FullName;
                    }
                }).ToListAsync();
            
        }
        
        /// <summary>
        /// 工单追溯人列表
        /// </summary>
        /// <param name="input"></param>
        /// <returns></returns>
        [HttpPost]
        public async Task<dynamic> PrdMoFromManList(PrdMoFromTabQueryInput prdMoFromTabQueryInput)
        {
            string mo_task_id = prdMoFromTabQueryInput.mo_task_id ?? "";
            string barcode = prdMoFromTabQueryInput.barcode ?? "";
            List<string> ids = new List<string>();
            if (!string.IsNullOrEmpty(barcode))
            {
                ids = await _db.Queryable<PrdReport>().Where(x => x.barcode.Contains(barcode)).Select(x=>x.mo_task_id).ToListAsync();
            }

            return await _db.Queryable<PrdReport>()
                .LeftJoin<UserEntity>((a, b) => a.create_id == b.Id)
                .WhereIF(!string.IsNullOrEmpty(mo_task_id), (a, b) => a.mo_task_id == mo_task_id)
                // .WhereIF(ids!=null && ids.Count>0,(a,b)=>ids.Contains(a.mo_task_id))
                .WhereIF(!string.IsNullOrEmpty(barcode),(a,b)=>a.barcode.Contains(barcode))
                .GroupBy((a,b)=>new {a.create_id,employee_name = b.RealName})
                .Select((a, b) => new PrdMoFromManListOutput()
                {
                    // id = a.id,
                    employee_name = b.RealName,
                    start_time = SqlFunc.AggregateMin(a.create_time),
                    end_time = SqlFunc.AggregateMax(a.create_time)
                }).Mapper(x =>
                {
                    x.work_time = (x.start_time == null ? "" : x.start_time.Value.ToString("yyyy-MM-dd HH:mm:ss")) + "~" + (x.end_time == null ? "" : x.end_time.Value.ToString("yyyy-MM-dd HH:mm:ss"));
                })
                .ToListAsync();
        }
        
        /// <summary>
        /// 工单追溯机列表
        /// </summary>
        /// <param name="input"></param>
        /// <returns></returns>
        [HttpPost]
        public async Task<dynamic> PrdMoFromEquipList(PrdMoFromTabQueryInput prdMoFromTabQueryInput)
        {
            string mo_task_id = prdMoFromTabQueryInput.mo_task_id ?? "";
            string barcode = prdMoFromTabQueryInput.barcode ?? "";
            List<string> ids = new List<string>();
            if (!string.IsNullOrEmpty(barcode))
            {
                ids = await _db.Queryable<PrdReport>().Where(x => x.barcode.Contains(barcode)).Select(x=>x.mo_task_id).ToListAsync();
            }

            return await _db.Queryable<PrdMoTask>()
                .LeftJoin<EqpEquipment>((a, b) => a.eqp_id == b.id)
                .LeftJoin<ToolMolds>((a,b,c)=>a.mold_id==c.id)
                .WhereIF(!string.IsNullOrEmpty(mo_task_id), (a, b) => a.id == mo_task_id)
                .WhereIF(ids!=null && ids.Count>0,(a,b)=>ids.Contains(a.id))
                .Select((a, b,c) => new PrdMoFromEquipListOutput()
                {
                    equip_code = b.code,
                    mold_code = b.code,
                }).ToListAsync();
        }
        
        /// <summary>
        /// 工单追溯料列表
        /// </summary>
        /// <param name="input"></param>
        /// <returns></returns>
        [HttpPost]
        public async Task<dynamic> PrdMoFromMaterialList(PrdMoFromTabQueryInput prdMoFromTabQueryInput)
        {
            string mo_task_id = prdMoFromTabQueryInput.mo_task_id ?? "";
            string barcode = prdMoFromTabQueryInput.barcode ?? "";
            List<string> ids = new List<string>();
            if (!string.IsNullOrEmpty(barcode))
            {
                ids = await _db.Queryable<PrdReport>().Where(x => x.barcode.Contains(barcode)).Select(x=>x.mo_task_id).ToListAsync();
            }
            PrdMoTask prdMoTask = await _db.Queryable<PrdMoTask>().SingleAsync(x => x.id == mo_task_id);
            PrdMo prdMo = await _db.Queryable<PrdMo>().SingleAsync(x => x.id == prdMoTask.mo_id);
            /*
             * 注塑投料记录 1产出物料二维码为精确搜索
             * 2 不填产出物料二维码 则投入物料列表不计算批次等
             * 3 物料二维码为精确搜索时 按照先进先出的规则计算投入物料
             * 4 组装包装可投入物料组成 1)直接从生产线上流转下来的物料 2)投入的物料
             */
            if (string.IsNullOrEmpty(barcode))
            {
                if (prdMoTask.schedule_type == 1)
                {
                    return await _db.Queryable<BasEbomH>()
                        .LeftJoin<BasEbomD>((a,b)=>a.id==b.ebom_id)
                        .LeftJoin<BasMaterial>((a,b,c)=>b.material_id==c.id)
                        .Where((a,b,c)=>a.id==prdMoTask.ebom_id)
                        .Select((a,b,c)=>new PrdMoFromMaterialListOutput()
                        {
                            material_code = c.code,
                            material_name = c.name,
                        }).ToListAsync();
                }
                else
                {
                    return await _db.Queryable<BasMbomInput>()
                        .LeftJoin<BasMaterial>((a,b)=>a.material_id==b.id)
                        .Where((a,b)=>a.mbom_id==prdMoTask.bom_id)
                        .Select((a,b)=>new PrdMoFromMaterialListOutput()
                        {
                            material_code = b.code,
                            material_name = b.name,
                        }).ToListAsync();
                }
            }
            else
            {
                PrdReport prdReport = await _db.Queryable<PrdReport>().Where(x => x.barcode == barcode).FirstAsync();
                List<PrdReport> prdReports = await _db.Queryable<PrdReport>().Where(x=>x.create_time<=prdReport.create_time && x.barcode!=barcode && x.mo_task_id==mo_task_id).ToListAsync();
                int? beforeReportNum = prdReports.Sum(x => x.reported_qty);
                List<string> prdFeedingIds = new List<string>();
                if (prdMoTask.schedule_type == 1)
                {
                    BasEbomH basEbomH = await _db.Queryable<BasEbomH>().SingleAsync(x => x.id == prdMoTask.ebom_id);
                    List<BasEbomD> basEbomDs = await _db.Queryable<BasEbomD>().Where(x => x.ebom_id == prdMoTask.ebom_id).ToListAsync();

                    foreach (var item in basEbomDs)
                    {
                        decimal? num1 = beforeReportNum / basEbomH.quantity * item.quantity;
                        List<PrdFeedingD> prdFeedingDs = await _db.Queryable<PrdFeedingD>()
                            .LeftJoin<PrdFeedingH>((a, b) => a.feeding_id == b.id)
                            .Where((a, b) => a.material_id == item.material_id && b.mo_task_id == mo_task_id)
                            .OrderBy((a,b)=>b.create_time)
                            .Select((a, b) => a).ToListAsync();
                        decimal sum1 = 0;
                        decimal sum2 = 0;
                        foreach (var prdFeedingD in prdFeedingDs)
                        {
                            if (sum1 <= num1)
                            {
                                sum1 += prdFeedingD.num;
                            }
                            else
                            {
                                decimal? num2 = prdReport.reported_qty / basEbomH.quantity * item.quantity;
                                if (sum2 <= num2)
                                {
                                    prdFeedingIds.Add(item.id);
                                }
                                else
                                {
                                    break;
                                }
                            }
                        }
                    }
                    
                    return await _db.Queryable<PrdFeedingD>()
                        .LeftJoin<BasMaterial>((a, b) => a.material_id == b.id)
                        .LeftJoin<PrdMaterialReceiptD>((a, b, c) => a.material_receipt_detail_id == c.id)
                        .LeftJoin<BasSupplier>((a, b, c, d) => c.supplier_id == d.id)
                        .LeftJoin<PrdFeedingH>((a, b, c, d, e) => a.feeding_id == e.id)
                        .WhereIF(prdFeedingIds != null && prdFeedingIds.Count > 0, (a, b, c, d, e) => prdFeedingIds.Contains(a.id))
                        .Select((a, b, c, d, e) => new PrdMoFromMaterialListOutput()
                        {
                            material_code = b.code,
                            material_name = b.name,
                            batch = a.batch,
                            supplier_name = d.supplier_name,
                            check_conclusion = c.check_conclusion,
                            instock_time = c.instock_time.ToString("yyyy-MM-dd HH:mm:ss"),
                            feeding_time = e.create_time == null ? "" : e.create_time.Value.ToString("yyyy-MM-dd HH:mm:ss"),
                        }).ToListAsync();
                    
                }
                else
                {
                    List<BasMbomInput> basMbomInputs = await _db.Queryable<BasMbomInput>().Where(x=>x.mbom_process_id==prdMoTask.mbom_process_id).ToListAsync();
                    BasMbom basMbom = await _db.Queryable<BasMbom>().SingleAsync(x => x.id == prdMoTask.bom_id);
                    BasMbomProcess basMbomProcess = await _db.Queryable<BasMbomProcess>().SingleAsync(x => x.id == prdMoTask.mbom_process_id);
                    List<string> lastPrdReportIds = new List<string>();
                    foreach (var item in basMbomInputs)
                    {
                        BasMbomOutput basMbomOutput = await  _db.Queryable<BasMbomOutput>().Where(x=>x.mbom_process_id==basMbomProcess.id && x.material_id==prdMoTask.material_id).FirstAsync();
                        if (basMbomOutput == null) break; 
                        decimal? num1 = beforeReportNum / Convert.ToDecimal(basMbomOutput.num) * item.num;
                        List<PrdFeedingD> prdFeedingDs = await _db.Queryable<PrdFeedingD>()
                            .LeftJoin<PrdFeedingH>((a, b) => a.feeding_id == b.id)
                            .Where((a, b) => a.material_id == item.material_id && b.mo_task_id == mo_task_id)
                            .OrderBy((a,b)=>b.create_time)
                            .Select((a, b) => a).ToListAsync();
                        
                        if (prdFeedingDs == null || prdFeedingDs.Count <= 0)
                        {
                            if (string.IsNullOrEmpty(basMbomProcess.last_process_no)) continue;
                            
                            List<BasMbomProcess> lastBasMbomProcesses = await _db.Queryable<BasMbomProcess>().Where(x=>x.no==basMbomProcess.last_process_no && x.mbom_id==prdMoTask.bom_id).ToListAsync();
                            foreach (var lastBasMbomProcess in lastBasMbomProcesses)
                            {
                                List<PrdReport> lastPrdReports = await _db.Queryable<PrdReport>()
                                    .Where(x=>x.mbom_process_id==lastBasMbomProcess.id && x.material_id==item.material_id)
                                    .OrderBy(x=>x.create_time)
                                    .ToListAsync();
                                if (lastPrdReports == null || lastPrdReports.Count <= 0) continue;
                                
                                PrdMoTask lastPrdMoTask = await _db.Queryable<PrdMoTask>().FirstAsync(x=>x.mo_id==prdMo.id && x.mbom_process_id==lastBasMbomProcess.id);
                                
                                decimal sum1 = 0;
                                decimal sum2 = 0;
                                foreach (var lastPrdReport in lastPrdReports)
                                {
                                    if (sum1 <= num1)
                                    {
                                        sum1 += lastPrdReport.reported_qty ?? 0;
                                    }
                                    else
                                    {
                                        decimal? num2 = lastPrdReport.reported_qty / Convert.ToDecimal(basMbomOutput.num) * item.num;
                                        if (sum2 <= num2)
                                        {
                                            lastPrdReportIds.Add(lastPrdReport.id);
                                        }
                                        else
                                        {
                                            break;
                                        }
                                    }
                                }
                                
                            }
                            

                        }
                        else
                        {
                            decimal sum1 = 0;
                            decimal sum2 = 0;
                            foreach (var prdFeedingD in prdFeedingDs)
                            {
                                if (sum1 <= num1)
                                {
                                    sum1 += prdFeedingD.num;
                                }
                                else
                                {
                                    decimal? num2 = prdReport.reported_qty / Convert.ToDecimal(basMbomOutput.num) * item.num;
                                    if (sum2 <= num2)
                                    {
                                        prdFeedingIds.Add(item.id);
                                    }
                                    else
                                    {
                                        break;
                                    }
                                }
                            }
                        }
                    }
                    
                    var queryable1 = _db.Queryable<PrdFeedingD>()
                        .LeftJoin<BasMaterial>((a, b) => a.material_id == b.id)
                        .LeftJoin<PrdMaterialReceiptD>((a, b, c) => a.material_receipt_detail_id == c.id)
                        .LeftJoin<BasSupplier>((a, b, c, d) => c.supplier_id == d.id)
                        .LeftJoin<PrdFeedingH>((a, b, c, d, e) => a.feeding_id == e.id)
                        .WhereIF(!string.IsNullOrEmpty(mo_task_id), (a, b, c, d, e) => e.mo_task_id == mo_task_id)
                        .WhereIF(prdFeedingIds != null && prdFeedingIds.Count > 0, (a, b, c, d, e) => prdFeedingIds.Contains(a.id))
                        .Select((a, b, c, d, e) => new PrdMoFromMaterialListOutput()
                        {
                            material_code = b.code,
                            material_name = b.name,
                            batch = a.batch,
                            supplier_name = d.supplier_name,
                            check_conclusion = c.check_conclusion,
                            instock_time = c.instock_time.ToString("yyyy-MM-dd HH:mm:ss"),
                            feeding_time = e.create_time == null ? "" : e.create_time.Value.ToString("yyyy-MM-dd HH:mm:ss"),
                        });

                    if (lastPrdReportIds != null && lastPrdReportIds.Count > 0)
                    {
                        var queryable2 = _db.Queryable<PrdReport>()
                            .LeftJoin<BasMaterial>((a, b) => a.material_id == b.id)
                            .Where((a, b) => lastPrdReportIds.Contains(a.id))
                            .Select((a, b) => new PrdMoFromMaterialListOutput()
                            {
                                material_code = b.code,
                                material_name = b.name,
                                batch = a.batch,
                                supplier_name = "自制"
                            });

                        return await _db.UnionAll(queryable1, queryable2).ToListAsync();
                    }
                    else
                    {
                        return await queryable1.ToListAsync();
                    }
                    
                }
            }
            
        }

        #endregion
        
        #region 反向工单追溯相关

        /// <summary>
        /// 物料反向追溯物料信息
        /// </summary>
        /// <param name="dic"></param>
        /// <returns></returns>
        [HttpPost]
        public async Task<dynamic> PrdMoReverseFromMaterialInfo(PrdMoReverseFromQueryInput prdMoReverseFromQueryInput)
        {
            string barcode = prdMoReverseFromQueryInput.barcode ?? "";
            string domain = (App.HttpContext.Request.IsHttps ? "https://" : "http://") + App.HttpContext.Request.Host;
            Dictionary<string, object> header = new Dictionary<string, object>()
            {
                ["Authorization"] = App.HttpContext.Request.Headers["Authorization"]
            };
            Dictionary<string, object> postData = new Dictionary<string, object>()
            {
                ["org_id"] = _userManager.GetUserInfo().Result.organizeId,
                ["barcode"] = new List<string>() { barcode },
                ["currentPage"] = 1,
                ["pageSize"] = int.MaxValue,
            };
            var sendResult = HttpUtils.RequestPost(domain + WebApiConst.MES_FETCH_IN_OUT_STOCK_INFO_BY_BAR_CODE,JsonConvert.SerializeObject(postData),header);
            Log.Information(sendResult);

            AuthResponse authResponse = JsonConvert.DeserializeObject<AuthResponse>(sendResult);
            if (authResponse.code != 200)
            {
                throw Oops.Bah(authResponse.msg);
            }
            else
            {
                PageResult<PrdMoReverseFromMaterialoutput> output = JsonConvert.DeserializeObject<PageResult<PrdMoReverseFromMaterialoutput>>(authResponse.data.ToString(),new Tnb.Common.Utils.DateTimeJsonConverter());
                if (output.list != null && output.list.Count > 0)
                {
                    BasMaterial basMaterial = await _db.Queryable<BasMaterial>().SingleAsync(x=>x.id==output.list[0].material_id);
                    BasSupplier basSupplier = await _db.Queryable<BasSupplier>().SingleAsync(x=>x.id==output.list[0].supplier_id);
                    DictionaryDataEntity unit = await _db.Queryable<DictionaryTypeEntity>()
                        .LeftJoin<DictionaryDataEntity>((a,b)=>a.Id==b.DictionaryTypeId)
                        .Where((a,b)=>a.EnCode==DictConst.MeasurementUnit && b.EnCode==output.list[0].unit_id)
                        .Select((a,b)=>b)
                        .FirstAsync();
                    output.list[0].feeding_num = await _db.Queryable<PrdMaterialReceiptD>()
                        .LeftJoin<PrdFeedingD>((a, b) => a.id == b.material_receipt_detail_id)
                        .Where((a, b) => a.barcode == barcode).SumAsync((a, b) => b.num);
                    output.list[0].material_name = basMaterial.name;
                    output.list[0].material_standard = basMaterial.material_standard;
                    output.list[0].supplier_name = basSupplier?.supplier_name ?? "";
                    output.list[0].unit_name = unit?.FullName ?? "";
                    
                    return output.list[0];
                }       
            }

            return Array.Empty<string>();

        }
        
        /// <summary>
        /// 物料反向追溯投料信息
        /// </summary>
        /// <param name="dic"></param>
        /// <returns></returns>
        [HttpPost]
        public async Task<dynamic> PrdMoReverseFromFeedingInfo(PrdMoReverseFromQueryInput prdMoReverseFromQueryInput)
        {
            string barcode = prdMoReverseFromQueryInput.barcode ?? "";
            List<string> ids = await _db.Queryable<PrdMaterialReceiptD>()
                .LeftJoin<PrdFeedingD>((a, b) => a.id == b.material_receipt_detail_id)
                .LeftJoin<PrdFeedingH>((a, b, c) => b.feeding_id == c.id)
                .Where(a => a.barcode == barcode)
                .Select((a, b, c) => c.mo_task_id).ToListAsync();

            var result = await _db.Queryable<PrdMoTask>()
                .LeftJoin<PrdMo>((a, b) => a.mo_id == b.id)
                .LeftJoin<BasMaterial>((a, b, c) => a.material_id == c.id)
                .Where((a, b, c) => ids.Contains(a.id))
                .Select((a, b, c) => new PrdMoReverseFromFeedingOutput
                {
                    mo_task_id = a.id,
                    mo_task_code = a.mo_task_code,
                    mo_code = b.mo_code,
                    material_code = c.code,
                    material_name = c.name,
                    material_standard = c.material_standard,
                    children = SqlFunc.Subqueryable<PrdFeedingD>()
                        .LeftJoin<PrdFeedingH>((x, y) => x.feeding_id == y.id)
                        .LeftJoin<UserEntity>((x, y, z) => y.create_id == z.Id)
                        .LeftJoin<OrganizeEntity>((x, y, z, org) => y.station_id == org.Id)
                        .LeftJoin<BasProcess>((x, y, z, org, process) => y.process_id == process.id)
                        .LeftJoin<PrdMaterialReceiptD>((x, y, z, org, process, mp) =>
                            x.material_receipt_detail_id == mp.id)
                        .Where((x, y, z) => y.mo_task_id == a.id).ToList((x, y, z, org, process, mp) =>
                            new PrdMoReverseFromFeedingDetailOutput
                            {
                                feeding_detail_id = x.id,
                                feeding_time = y.create_time == null
                                    ? ""
                                    : y.create_time.Value.ToString("yyyy-MM-dd HH:mm:ss"),
                                num = x.num,
                                check_conclusion = mp.check_conclusion,
                                feeding_name = z.RealName,
                                station_name = org.FullName,
                                process_name = process.process_name
                            }),
                }).ToListAsync();
            return result;
            // return PageResult<PrdMoReverseFromFeedingOutput>.SqlSugarPageResult(result);
        }
        
        /// <summary>
        /// 物料反向追溯产出信息
        /// </summary>
        /// <param name="dic"></param>
        /// <returns></returns>
        [HttpPost]
        public async Task<dynamic> PrdMoReverseFromOutInfo(PrdMoReverseFromOutInfoQueryInput prdMoReverseFromOutInfoQueryInput)
        {
            string feeding_detail_id = prdMoReverseFromOutInfoQueryInput.feeding_detail_id ?? "";
            PrdFeedingD prdFeedingD = await _db.Queryable<PrdFeedingD>().FirstAsync(x => x.id == feeding_detail_id);
            if(prdFeedingD.use_num<=0) return Array.Empty<string>();
            PrdFeedingH prdFeedingH = await _db.Queryable<PrdFeedingH>().FirstAsync(x => x.id == prdFeedingD.feeding_id);
            PrdMoTask prdMoTask = await _db.Queryable<PrdMoTask>().FirstAsync(x => x.id == prdFeedingH.mo_task_id);
            List<PrdFeedingD> prdFeedingDs = await _db.Queryable<PrdFeedingD>()
                .LeftJoin<PrdFeedingH>((a, b) => a.feeding_id == b.id)
                .Where((a, b) => a.material_id == prdFeedingD.material_id && b.mo_task_id == prdFeedingH.mo_task_id && b.create_time<=prdFeedingH.create_time && a.id!=prdFeedingD.id)
                .Select((a, b) => a).ToListAsync();
            decimal beforeIn = prdFeedingDs.Sum(x => x.num);
            List<string> reportIds = new List<string>();
            if (prdMoTask.schedule_type == 1)
            {
                BasEbomH basEbomH = await _db.Queryable<BasEbomH>().SingleAsync(x => x.id == prdMoTask.ebom_id);
                List<BasEbomD> basEbomDs = await _db.Queryable<BasEbomD>().Where(x => x.ebom_id == prdMoTask.ebom_id).ToListAsync();
                BasEbomD basEbomD = basEbomDs.Where(x => x.material_id == prdFeedingD.material_id).FirstOrDefault();
                if (basEbomD != null)
                {
                    List<PrdReport> prdReports = await _db.Queryable<PrdReport>().Where(x => x.mo_task_id == prdMoTask.id).OrderBy(x=>x.create_time).ToListAsync();
                    if (prdReports != null && prdReports.Count > 0)
                    {
                        bool flag = true;
                        decimal residueNeed = 0;
                        foreach (var prdReport in prdReports)
                        {
                            var needNum = (prdReport.reported_qty ?? 0) / basEbomH.quantity * basEbomD.quantity;
                            if (beforeIn - needNum >= 0)
                            {
                                beforeIn -= needNum;
                            }
                            else
                            {
                                if (flag)
                                {
                                    if (prdFeedingD.num > needNum - beforeIn)
                                    {
                                        residueNeed = prdFeedingD.num - (needNum - beforeIn);
                                        reportIds.Add(prdReport.id);
                                    }
                                    else
                                    {
                                        reportIds.Add(prdReport.id);
                                        break;
                                    }
                                    
                                    flag = false;
                                    continue;

                                }

                                if (residueNeed - needNum > 0)
                                {
                                    residueNeed -= needNum;
                                    reportIds.Add(prdReport.id);
                                }else
                                {
                                    reportIds.Add(prdReport.id);
                                    break;
                                }
                            }
                        }
                    }
                    else
                    {
                        return Array.Empty<string>();
                    }
                }
                else
                {
                    return Array.Empty<string>();
                }
                
             }
            else
            {
                List<PrdReport> prdReports = await _db.Queryable<PrdMoTask>()
                    .LeftJoin<BasMbomProcess>((a, b) => a.mbom_process_id == b.id)
                    .LeftJoin<PrdReport>((a, b, c) => a.id == c.mo_task_id)
                    .Where((a, b, c) => a.mo_id == prdMoTask.mo_id && b.next_process_no == null)
                    .OrderBy((a,b,c)=>c.create_time)
                    .Select((a, b, c) => c).ToListAsync();

                if (prdReports != null && prdReports.Count > 0)
                {
                    List<string> mbomProcesssIds = new List<string>(){prdMoTask.mbom_process_id};
                    BasMbomProcess startMbomProcess = await _db.Queryable<BasMbomProcess>().Where(x=>x.id==prdMoTask.mbom_process_id).FirstAsync();
                    List<BasMbomProcess> allMbomProcesses = await _db.Queryable<BasMbomProcess>().Where(x=>x.mbom_id==prdMoTask.bom_id).ToListAsync();
                    string startNo = startMbomProcess.next_process_no;
                    if (!string.IsNullOrEmpty(startNo))
                    {
                        while (true)
                        {
                            BasMbomProcess nextMbomProcess =  allMbomProcesses.FirstOrDefault(x=>x.no==startNo);

                            if (nextMbomProcess==null || nextMbomProcess.no==null)
                            {
                                break;
                            }
                            else
                            {
                                startNo = nextMbomProcess.next_process_no;
                                mbomProcesssIds.Add(nextMbomProcess.id);
                            }
                        }
                    }
                    else
                    {
                        if (!prdMoTask.mbom_process_id.Contains(prdMoTask.mbom_process_id))
                        {
                            mbomProcesssIds.Add(startMbomProcess.id);
                        }
                    }

                    List<BasMbomOutput> outputList = await _db.Queryable<BasMbomProcess>()
                        .LeftJoin<BasMbomOutput>((a, b) => a.id == b.mbom_process_id)
                        .Where((a, b) => mbomProcesssIds.Contains(a.id))
                        .Select((a,b)=>b).ToListAsync();
                    
                    List<BasMbomInput> inputList = await _db.Queryable<BasMbomProcess>()
                        .LeftJoin<BasMbomInput>((a, b) => a.id == b.mbom_process_id)
                        .Where((a, b) => mbomProcesssIds.Contains(a.id))
                        .Select((a,b)=>b).ToListAsync();

                    decimal? needNum = 1;//一个最终物料需要本任务单投入物料的数量
                    string tempMaterialId = outputList.FirstOrDefault(x=>x.mbom_process_id==mbomProcesssIds[mbomProcesssIds.Count-1])?.material_id;
                    for (int i = mbomProcesssIds.Count - 1; i > 0;i--)
                    {

                        List<BasMbomInput> inputs = inputList.Where(x => x.mbom_process_id == mbomProcesssIds[i]).ToList();
                        BasMbomOutput output = outputList.FirstOrDefault(x => x.mbom_process_id == mbomProcesssIds[i] && x.material_id==tempMaterialId);
                        List<string> inputMaterialIds = inputs.Select(x => x.material_id).ToList();
                        List<BasMbomOutput> lastOutputs = outputList.Where(x=>x.mbom_process_id==mbomProcesssIds[i-1]).ToList();
                        decimal? inputNum =  inputs.FirstOrDefault(x => inputMaterialIds.Contains(x.material_id))?.num;
                        if (inputNum == null)
                        {
                            throw new Exception("生产bom投入产出物料配置错误");
                        }
                        else
                        {
                            tempMaterialId = inputs.FirstOrDefault(x => inputMaterialIds.Contains(x.material_id))?.material_id;
                            needNum = needNum / Convert.ToDecimal(output.num) * inputNum;
                        }
                    }

                    bool flag = true;
                    decimal residueNeed = 0;
                    foreach (var prdReport in prdReports)
                    {
                        decimal needNumTotal = prdReport.reported_qty * needNum ?? 0;
                        if (beforeIn - needNumTotal >= 0)
                        {
                            beforeIn -= needNumTotal;
                        }
                        else
                        {
                            if (flag)
                            {
                                if (prdFeedingD.num > needNumTotal - beforeIn)
                                {
                                    residueNeed = prdFeedingD.num - (needNumTotal - beforeIn);
                                    reportIds.Add(prdReport.id);
                                }
                                else
                                {
                                    reportIds.Add(prdReport.id);
                                    break;
                                }
                                    
                                flag = false;
                                continue;

                            }

                            if (residueNeed - needNumTotal > 0)
                            {
                                residueNeed -= needNumTotal;
                                reportIds.Add(prdReport.id);
                            }else
                            {
                                reportIds.Add(prdReport.id);
                                break;
                            }
                        }
                    }
                    
                    
                    
                }
                else
                {
                    return Array.Empty<string>();
                }
            }
            
            List<string> barCodes = await _db.Queryable<PrdReport>().Where(x=>reportIds.Contains(x.id)).Select(x=>x.barcode).ToListAsync();
                
            string domain = (App.HttpContext.Request.IsHttps ? "https://" : "http://") + App.HttpContext.Request.Host;
            Dictionary<string, object> header = new Dictionary<string, object>()
            {
                ["Authorization"] = App.HttpContext.Request.Headers["Authorization"]
            };
            Dictionary<string, object> postData = new Dictionary<string, object>()
            {
                ["org_id"] = _userManager.GetUserInfo().Result.organizeId,
                ["barcode"] = barCodes,
                ["currentPage"] = 1,
                ["pageSize"] = int.MaxValue,
            };
            var sendResult = HttpUtils.RequestPost(domain + WebApiConst.MES_FETCH_IN_OUT_STOCK_INFO_BY_BAR_CODE,JsonConvert.SerializeObject(postData),header);
            Log.Information(sendResult);

            AuthResponse authResponse = JsonConvert.DeserializeObject<AuthResponse>(sendResult);
            if (authResponse.code != 200)
            {
                throw Oops.Bah(authResponse.msg);
            }
            else
            {
                BasMaterial basMaterial = await _db.Queryable<BasMaterial>().FirstAsync(x => x.id == prdMoTask.material_id);
                PageResult<PrdMoReverseFromOutput> output = JsonConvert.DeserializeObject<PageResult<PrdMoReverseFromOutput>>(authResponse.data.ToString(),new Tnb.Common.Utils.DateTimeJsonConverter());
                if (output.list != null && output.list.Count > 0)
                {
                    foreach (var item in output.list)
                    {
                        item.material_name = basMaterial.name;
                    }
                }

                return output.list;
            }
        }
        
        #endregion
    }
}