using JNPF.Common.Core.Manager;
using JNPF.Common.Dtos.VisualDev;
using JNPF.Common.Extension;
using JNPF.Common.Security;
using JNPF.EventBus;
using JNPF.FriendlyException;
using JNPF.Systems.Interfaces.System;
using JNPF.VisualDev;
using JNPF.VisualDev.Interfaces;
using Mapster;
using Newtonsoft.Json.Linq;
using SqlSugar;
using Tnb.BasicData.Entities;
using Tnb.Common.Utils;
using Tnb.WarehouseMgr.Entities;
using Tnb.WarehouseMgr.Entities.Attributes;
using Tnb.WarehouseMgr.Entities.Consts;
using Tnb.WarehouseMgr.Entities.Dto;
using Tnb.WarehouseMgr.Entities.Enums;
using Tnb.WarehouseMgr.Interfaces;

namespace Tnb.WarehouseMgr
{
    /// <summary>
    /// PDA一般入库
    /// </summary>
    [OverideVisualDev(ModuleConsts.MODULE_WMSINSTOCKPDA_ID)]
    [ServiceModule(BizTypeId)]
    public class WmsPDAInStockService : BaseWareHouseService, IPdaStroage
    {
        private const string BizTypeId = "26191496816421";
        private readonly ISqlSugarClient _db;
        private readonly IRunService _runService;
        private readonly IVisualDevService _visualDevService;
        private readonly IWareHouseService _wareHouseService;
        private readonly IBillRullService _billRullService;
        private readonly IUserManager _userManager;

        public WmsPDAInStockService(
            ISqlSugarRepository<WmsCarryH> repository,
            IRunService runService,
            IVisualDevService visualDevService,
            IWareHouseService wareHouseService,
            IUserManager userManager,
            IBillRullService billRullService,
            IEventPublisher eventPublisher
            )
        {
            _db = repository.AsSugarClient();
            _runService = runService;
            _visualDevService = visualDevService;
            _wareHouseService = wareHouseService;
            _userManager = userManager;
            _billRullService = billRullService;

            OverideFuncs.CreateAsync = ScanCodeInStock;
        }

        /// <summary>
        /// 扫码入库功能
        /// </summary>
        /// <param name="input"></param>
        /// <returns></returns>
        //[HttpPost]
        private async Task<dynamic> ScanCodeInStock(VisualDevModelDataCrInput input)
        {
            try
            {
                await _db.Ado.BeginTranAsync();

                JArray? jArr = null;
                if (input.data.ContainsKey("tablefield115"))
                {
                    jArr = JArray.Parse(input.data["tablefield115"].ToString()!);

                }
                //入库取终点 //出库起点
                InStockStrategyQuery inStockStrategyInput = new() { warehouse_id = input.data[nameof(InStockStrategyQuery.warehouse_id)].ToString()!, Size = 1 };
                List<BasLocation> endLocations = await _wareHouseService.InStockStrategy(inStockStrategyInput);
                WmsPointH sPoint = null!;
                WmsPointH ePoint = null!;
                if (input.data.ContainsKey(nameof(WmsHandleH.startlocation_id)))
                {
                    sPoint = await _db.Queryable<WmsPointH>().FirstAsync(it => it.location_id == input.data[nameof(WmsHandleH.startlocation_id)].ToString());
                }
                if (endLocations?.Count > 0)
                {
                    WmsCarryH carry = await _db.Queryable<WmsCarryH>().SingleAsync(it => it.id == input.data[nameof(WmsCarryD.carry_id)].ToString());
                    BasLocation loc = await _db.Queryable<BasLocation>().SingleAsync(it => it.id == endLocations[0].id);
                    bool isMatch = await IsCarryAndLocationMatchByCarryStd(carry, loc);
                    if (!isMatch)
                    {
                        throw new AppFriendlyException("库位与载具规格不匹配", 500);
                    }

                    ePoint = await _db.Queryable<WmsPointH>().FirstAsync(it => it.location_id == endLocations[0].id);
                }

                if (sPoint != null && ePoint != null)
                {
                    List<WmsPointH> points = new List<WmsPointH>();
                    if (sPoint.area_code != ePoint.area_code)
                    {
                        points = await _wareHouseService.PathAlgorithms(sPoint.id, ePoint.id);
                        if (points.Count <= 2)
                        {
                            throw new AppFriendlyException($"sPoint {sPoint.point_code} ePoint{ePoint.point_code}该路径不存在", 500);
                        }
                    }
                    else
                    {
                        points.Add(sPoint);
                        points.Add(ePoint);
                    }

                    if (points?.Count > 0)
                    {
                        List<WmsPretaskH> preTasks = points.Where(it => !it.location_id.IsNullOrEmpty()).GroupBy(g => g.area_code).Select(it =>
                        {
                            WmsPointH? sPoint = it.FirstOrDefault();
                            WmsPointH? ePoint = it.LastOrDefault();

                            WmsPretaskH preTask = new()
                            {
                                org_id = _userManager.User.OrganizeId,
                                startlocation_id = sPoint?.location_id ?? "",
                                startlocation_code = sPoint?.location_code ?? "",
                                endlocation_id = ePoint?.location_id ?? "",
                                endlocation_code = ePoint?.location_code ?? "",
                                start_floor = sPoint?.floor.ToString(),
                                end_floor = ePoint?.floor.ToString(),
                                startpoint_id = sPoint?.id!,
                                startpoint_code = sPoint?.point_code!,
                                endpoint_id = ePoint?.id!,
                                endpoint_code = ePoint?.point_code!,
                                bill_code = _billRullService.GetBillNumber(WmsWareHouseConst.WMS_PRETASK_H_ENCODE).GetAwaiter().GetResult(),
                                status = WmsWareHouseConst.PRETASK_BILL_STATUS_DXF_ID,
                                biz_type = input.data[nameof(WmsPretaskH.biz_type)]?.ToString() ?? "",
                                task_type = WmsWareHouseConst.WMS_PRETASK_INSTOCK_TYPE_ID,
                                carry_id = input.data[nameof(preTask.carry_id)]?.ToString() ?? "",
                                carry_code = input.data[nameof(preTask.carry_code)]?.ToString() ?? "",
                                area_id = sPoint?.area_id ?? "",
                                area_code = it.Key,
                                require_id = input.data[nameof(WmsHandleH.require_id)].ToString(),
                                require_code = input.data[nameof(WmsHandleH.require_code)]?.ToString(),
                                create_id = _userManager.UserId,
                                create_time = DateTime.Now,
                                source_id = input.data[nameof(WmsKittingInstock.source_id)].ToString(),
                                source_code = input.data[nameof(WmsKittingInstock.source_code)].ToString()
                            };

                            return preTask;
                        }).ToList();
                        //生成预任务条码信息
                        List<WmsPretaskCode> pretaskCodes = new();
                        foreach (WmsPretaskH? pt in preTasks)
                        {
                            if (jArr?.Children().Count() > 0)
                            {
                                foreach (JToken jo in jArr.Children())
                                {
                                    WmsPretaskCode ptc = pt.Adapt<WmsPretaskCode>();
                                    ptc.id = SnowflakeIdHelper.NextId();
                                    ptc.bill_id = pt.id;
                                    ptc.material_id = jo.Value<string>(nameof(WmsPretaskCode.material_id))!;
                                    ptc.material_code = jo.Value<string>(nameof(WmsPretaskCode.material_code))!;
                                    ptc.barcode = jo.Value<string>(nameof(WmsPretaskCode.barcode))!;
                                    ptc.codeqty = jo.Value<int>(nameof(WmsPretaskCode.codeqty));
                                    ptc.unit_id = jo.Value<string>(nameof(WmsPretaskCode.unit_id))!;
                                    ptc.code_batch = jo.Value<string>(nameof(WmsPretaskCode.code_batch));
                                    ptc.material_specification = jo.Value<string>(nameof(WmsPretaskCode.material_specification))!;
                                    ptc.container_no = jo.Value<string>(nameof(WmsPretaskCode.container_no));
                                    pretaskCodes.Add(ptc);
                                }
                            }
                        }

                        //生成预任务，同时如果包含条码信息同时插入条码记录
                        bool isOk = await _wareHouseService.GenPreTask(preTasks, pretaskCodes);
                        if (isOk)
                        {
                            string requireIdField = "require_id";

                            GenPreTaskUpInput preTaskUpInput = new()
                            {
                                RquireId = input.data[nameof(WmsHandleH.require_id)].ToString()!,
                                CarryId = input.data[nameof(WmsCarryD.carry_id)]?.ToString()!,
                                CarryStartLocationId = points.FirstOrDefault()!.location_id!,
                                CarryStartLocationCode = points.FirstOrDefault()!.location_code!,
                                LocationIds = points.Select(x => x.location_id).ToList()!
                            };
                            if (input.data.ContainsKey(requireIdField) && input.data[requireIdField].IsNotEmptyOrNull())
                            {
                                //创建预任务操作记录
                                string operBillId = string.Empty;
                                WmsInstockH instockH = await _db.Queryable<WmsInstockH>().FirstAsync(it => it.id == input.data[requireIdField].ToString());
                                if (instockH != null)
                                {
                                    WmsHandleH handleH = instockH.Adapt<WmsHandleH>();
                                    operBillId = handleH.id = SnowflakeIdHelper.NextId();
                                    handleH.startlocation_id = input.data[nameof(WmsHandleH.startlocation_id)]?.ToString()!;
                                    handleH.carry_id = input.data[nameof(WmsHandleH.carry_id)]?.ToString()!;
                                    handleH.carry_code = input.data[nameof(WmsHandleH.carry_code)]?.ToString()!;
                                    preTaskUpInput.PreTaskRecord = handleH;
                                }
                                //创建预任务条码操作记录
                                jArr = JArray.Parse(input.data["tablefield115"].ToString()!);
                                if (jArr?.Children().Count() > 0)
                                {
                                    foreach (JToken jo in jArr.Children())
                                    {
                                        string? materialId = jo.Value<string>(nameof(WmsHandleCode.material_id));
                                        WmsHandleCode handleCode = new()
                                        {
                                            org_id = _userManager.User.OrganizeId,
                                            bill_id = operBillId,
                                            material_id = materialId!,
                                            material_code = jo.Value<string>(nameof(WmsHandleCode.material_code))!,
                                            barcode = jo.Value<string>(nameof(WmsHandleCode.barcode))!,
                                            code_batch = jo.Value<string>(nameof(WmsHandleCode.code_batch)),
                                            material_specification = jo.Value<string>(nameof(WmsPretaskCode.material_specification))!,
                                            container_no = jo.Value<string>(nameof(WmsPretaskCode.container_no)),
                                            codeqty = jo.Value<int>(nameof(WmsHandleCode.codeqty)),
                                            unit_id = _db.Queryable<BasMaterial>().Single(it => it.id == materialId).unit_id,
                                            create_id = _userManager.UserId,
                                            create_time = DateTime.Now
                                        };
                                        preTaskUpInput.PreTaskHandleCodes.Add(handleCode);
                                    }
                                }
                                //生成载具条码记录
                                List<WmsCarryCode> carryCodes = preTaskUpInput.PreTaskHandleCodes.Adapt<List<WmsCarryCode>>();

                                carryCodes.ForEach(x =>
                                {
                                    x.id = SnowflakeIdHelper.NextId();
                                    x.is_out = 0;
                                    x.carry_id = input.data[nameof(WmsCarryCode.carry_id)]?.ToString()!;
                                    x.warehouse_id = input.data[nameof(InStockStrategyQuery.warehouse_id)].ToString();
                                });
                                //生成入库申请条码
                                List<WmsInstockD> instockDetails = await _db.Queryable<WmsInstockD>()
                                      .Where(b => b.bill_id == input.data[requireIdField].ToString())
                                      .ToListAsync();


                                List<WmsInstockCode> items = instockDetails.Adapt<List<WmsInstockCode>>();
                                //items.ForEach(it => it.org_id = _userManager.User.OrganizeId);
                                List<WmsInstockCode> instockCOdes = new();
                                if (input.data.ContainsKey("tablefield115"))
                                {
                                    jArr = JArray.Parse(input.data["tablefield115"].ToString()!);
                                    if (jArr?.Children().Count() > 0)
                                    {
                                        foreach (JToken jo in jArr.Children())
                                        {
                                            string? materialCode = jo.Value<string>(nameof(WmsInstockCode.material_code));
                                            string? codeBatch = jo.Value<string>(nameof(WmsInstockCode.code_batch));
                                            WmsInstockCode? b = items.Find(x => x.material_code == materialCode && x.code_batch == codeBatch);
                                            if (b != null)
                                            {
                                                WmsInstockCode c = DeepCopyHelper<WmsInstockCode>.DeepCopy(b);
                                                c.id = SnowflakeIdHelper.NextId();
                                                c.bill_d_id = b.id;
                                                c.barcode = jo.Value<string>(nameof(WmsInstockCode.barcode))!;
                                                c.codeqty = jo.Value<int>(nameof(WmsInstockCode.codeqty));
                                                instockCOdes.Add(c);
                                            }
                                        }
                                    }
                                    string orgId = _userManager.User.OrganizeId;
                                    _ = await _db.Insertable(instockCOdes).CallEntityMethod(it => it.Create(orgId)).ExecuteCommandAsync();
                                    _ = await _db.Updateable<WmsTempCode>().SetColumns(it => new WmsTempCode { is_end = 1 }).Where(it => instockCOdes.Select(x => x.barcode).Contains(it.barcode)).ExecuteCommandAsync();
                                }
                                _ = await _db.Insertable(carryCodes).ExecuteCommandAsync();
                                // 更新临时条码表 状态is_end
                                await _wareHouseService.GenInStockTaskHandleAfter(preTaskUpInput,
                                    it => new WmsCarryH { carry_code = input.data[nameof(WmsCarryH.carry_code)].ToString()!, is_lock = 1, carry_status = ((int)EnumCarryStatus.占用).ToString(), location_id = preTaskUpInput.CarryStartLocationId, location_code = preTaskUpInput.CarryStartLocationCode, source_id = input.data[nameof(WmsOutstockH.source_id)].ToString(), source_code = input.data[nameof(WmsOutstockH.source_code)].ToString() },
                                    it => new BasLocation { is_lock = 1 });
                                if (instockCOdes?.Count > 0)
                                {
                                    _ = await _db.Updateable<WmsInstockD>().SetColumns(it => new WmsInstockD { line_status = WmsWareHouseConst.BILLSTATUS_ON_ID }).Where(it => instockCOdes.Select(x => x.bill_d_id).Contains(it.id)).ExecuteCommandAsync();
                                    _ = await _db.Updateable<WmsInstockH>().SetColumns(it => new WmsInstockH { status = WmsWareHouseConst.BILLSTATUS_ON_ID }).Where(it => it.id == input.data[nameof(WmsHandleH.require_id)].ToString()).ExecuteCommandAsync();
                                }
                            }
                        }
                    }
                }

                await _db.Ado.CommitTranAsync();
            }
            catch (Exception)
            {
                await _db.Ado.RollbackTranAsync();
                throw;
            }
            finally
            {
                await InvokeGenPretaskExcute();
            }
            return Task.FromResult(true);
        }

        public override async Task ModifyAsync(WareHouseUpInput input)
        {
            if (input == null)
            {
                throw new ArgumentNullException("input");
            }
            //更具distaskCode的barcode 更新  instockcode 的 is_end 为 1 
            try
            {
                await _db.Ado.BeginTranAsync();

                if (input.distaskCodes?.Count > 0)
                {
                    IEnumerable<string> barCodes = input.distaskCodes.Select(x => x.barcode);
                    _ = await _db.Updateable<WmsInstockCode>().SetColumns(it => new WmsInstockCode { is_end = 1 }).Where(it => barCodes.Contains(it.barcode)).ExecuteCommandAsync();
                    var instockCodes = await _db.Queryable<WmsInstockCode>().Where(it => barCodes.Contains(it.barcode)).Select(it => new
                    {
                        id = it.bill_d_id,
                        barcode_qty = it.codeqty,
                    }).ToListAsync();
                    Dictionary<string, List<decimal>> dic = instockCodes.GroupBy(g => g.id).ToDictionary(x => x.Key, x => x.Select(d => d.barcode_qty).ToList());
                    List<string> ids = instockCodes.Select(it => it.id).ToList();
                    List<WmsInstockD> instockDetails = await _db.Queryable<WmsInstockD>().Where(it => ids.Contains(it.id)).ToListAsync();

                    foreach (WmsInstockD item in instockDetails)
                    {
                        if (dic.ContainsKey(item.id))
                        {
                            item.qty += dic[item.id].Sum(x => x);
                            if (item.qty >= item.pr_qty)
                            {
                                item.line_status = WmsWareHouseConst.BILLSTATUS_COMPLETE_ID;
                            }
                        }
                    }
                    _ = await _db.Updateable(instockDetails).ExecuteCommandAsync();
                    List<WmsInstockD> allInstockDetails = await _db.Queryable<WmsInstockD>().Where(it => it.bill_id == input.requireId).ToListAsync();
                    if (allInstockDetails.All(x => x.line_status == WmsWareHouseConst.BILLSTATUS_COMPLETE_ID))
                    {
                        _ = await _db.Updateable<WmsInstockH>().SetColumns(it => new WmsInstockH { status = WmsWareHouseConst.BILLSTATUS_COMPLETE_ID }).Where(it => it.id == input.requireId).ExecuteCommandAsync();
                        //如果是自动单据，需要回更上层系统
                    }
                }

                await _db.Ado.CommitTranAsync();
            }
            catch (Exception)
            {
                await _db.Ado.RollbackTranAsync();
                throw;
            }
        }
    }
}