using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using Aop.Api.Domain;
using JNPF.Common.Core.Manager;
using JNPF.Common.Enums;
using JNPF.Common.Extension;
using JNPF.Common.Security;
using JNPF.FriendlyException;
using JNPF.Systems.Interfaces.System;
using Mapster;
using Microsoft.AspNetCore.Mvc;
using SqlSugar;
using Tnb.BasicData.Entities;
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>
    /// 齐套出库服务类
    /// </summary>
    [ServiceModule(BizTypeId)]
    public class WmskittingOutService : BaseWareHouseService, IWmskittingOutService
    {
        private readonly ISqlSugarClient _db;
        private readonly IWareHouseService _warehouseService;
        private readonly IUserManager _userManager;
        private readonly IBillRullService _billRullService;
        private readonly IWmsCarryService _carryService;
        private const string BizTypeId = "26169472620837";
        public WmskittingOutService(ISqlSugarRepository<WmsKittingoutH> repository, IWareHouseService warehouseService, IUserManager userManager, IBillRullService billRullService, IWmsCarryService carryService)
        {
            _db = repository.AsSugarClient();
            _warehouseService = warehouseService;
            _userManager = userManager;
            _billRullService = billRullService;
            _carryService = carryService;
        }
        /// <summary>
        /// 齐套出库（新增状态）
        /// </summary>
        /// <returns></returns>
        [HttpPost]
        public async Task KittingOutByAdd()
        {
            try
            {
                await _db.Ado.BeginTranAsync();

                var kittingOuts = await _db.Queryable<WmsKittingoutH>()
                         .Where(a => a.status == WmsWareHouseConst.BILLSTATUS_ADD_ID)
                         .OrderBy(a => a.seq)
                         .ToListAsync();
                // 是否有已呼叫的齐套出库任务
                // var set = true ;  如果有  把set修改为false
                var items = await _db.Queryable<WmsKittingoutH>().Where(it => it.status == WmsWareHouseConst.BILLSTATUS_CALLED_ID).ToListAsync();
                var isCalled = items?.Count > 0;
                if (kittingOuts?.Count > 0)
                {
                    foreach (var ko in kittingOuts)
                    {
                        var carrys = await _db.Queryable<WmsCarryH>().Where(it => it.collocation_scheme_id == ko.collocation_scheme_id && it.is_lock == 0).ToListAsync();
                        if (carrys?.Count > 0)
                        {
                            var firstCarry = carrys.FirstOrDefault();
                            GenPreTaskUpInput genPreTaskInput = new() { CarryId = firstCarry.id };
                            await _warehouseService.GenInStockTaskHandleAfter(genPreTaskInput, it => new WmsCarryH { is_lock = 1 }, null!);
                            ko.status = WmsWareHouseConst.BILLSTATUS_TOBESHIPPED_ID;
                            ko.carry_id = firstCarry.id;
                            ko.carry_code = firstCarry.carry_code;
                            await _db.Updateable(ko).UpdateColumns(it => new { it.status, it.carry_id, it.carry_code }).ExecuteCommandAsync();
                        }
                        else
                        {
                            //if(false) 跳出  插入完一次齐套分拣  set 改为false
                            if (!isCalled)
                            {
                                var setSortingH = ko.Adapt<WmsSetsortingH>();
                                setSortingH.warehouse_id = WmsWareHouseConst.WAREHOUSE_ZC_ID;
                                setSortingH.id = SnowflakeIdHelper.NextId();
                                setSortingH.kittingout_id = ko.id;
                                setSortingH.seq = ko.seq;
                                setSortingH.org_id = _userManager.User.OrganizeId;
                                setSortingH.create_id = _userManager.UserId;
                                setSortingH.create_time = DateTime.Now;
                                await _db.Insertable(setSortingH).ExecuteCommandAsync();

                                var kittingOutDetails = await _db.Queryable<WmsKittingoutD>().Where(it => it.bill_id == ko.id).ToListAsync();
                                var setSortDetails = kittingOutDetails.Adapt<List<WmsSetsortingD>>();
                                setSortDetails.ForEach(x =>
                                {
                                    x.id = SnowflakeIdHelper.NextId();
                                    x.bill_id = setSortingH.id;
                                    x.warehouse_id = setSortingH.warehouse_id;
                                    x.org_id = _userManager.User.OrganizeId;
                                    x.create_id = _userManager.UserId;
                                    x.create_time = DateTime.Now;
                                });
                                await _db.Insertable(setSortDetails).ExecuteCommandAsync();
                                ko.status = WmsWareHouseConst.BILLSTATUS_CALLED_ID;
                                await _db.Updateable(ko).UpdateColumns(it => it.status).ExecuteCommandAsync();
                                isCalled = true;
                            }
                        }
                    }
                }

                await _db.Ado.CommitTranAsync();
            }
            catch (Exception)
            {
                await _db.Ado.RollbackTranAsync();
                throw;
            }
        }
        /// <summary>
        /// 齐套出库，（待配送状态）
        /// </summary>
        /// <returns></returns>
        [HttpPost]
        public async Task KittingOutByIsToBeShipped()
        {

            var kittingOuts = await _db.Queryable<WmsKittingoutH>()
                         .Where(a => a.status == WmsWareHouseConst.BILLSTATUS_TOBESHIPPED_ID)
                         .OrderBy(a => a.seq)
                         .ToListAsync();
            if (kittingOuts?.Count > 0)
            {
                var grpList = kittingOuts.GroupBy(g => g.location_id).ToList();
                foreach (var koGrp in grpList)
                {
                    var locs = await _db.Queryable<BasLocation>().Where(it => it.id == koGrp.Key && it.is_use == (int)EnumCarryStatus.空闲 && it.is_lock == 0).ToListAsync();
                    if (locs?.Count > 0)
                    {

                        var arr = koGrp.ToArray();
                        var ko = arr[^arr.Length];
                        var carry = await _db.Queryable<WmsCarryH>().SingleAsync(it => it.id == ko.carry_id);
                        if (carry != null)
                        {
                            WmsPointH sPoint = await _db.Queryable<WmsPointH>().FirstAsync(it => it.location_id == carry.location_id);
                            WmsPointH ePoint = await _db.Queryable<WmsPointH>().FirstAsync(it => it.location_id == ko.location_id);
                            if (sPoint != null && ePoint != null)
                            {
                                var points = await _warehouseService.PathAlgorithms(sPoint.id, ePoint.id);
                                if (points?.Count > 0)
                                {
                                    if (points.Count <= 2) throw new AppFriendlyException("该路径不存在", 500);
                                    var preTasks = points.Where(it => !it.location_id.IsNullOrEmpty()).GroupBy(g => g.area_code).Select(it =>
                                    {
                                        var sPoint = it.FirstOrDefault();
                                        var ePoint = it.LastOrDefault();

                                        WmsPretaskH preTask = new();
                                        preTask.org_id = _userManager.User.OrganizeId;
                                        preTask.startlocation_id = sPoint?.location_id;
                                        preTask.startlocation_code = sPoint?.location_code;
                                        preTask.endlocation_id = ePoint?.location_id;
                                        preTask.endlocation_code = ePoint?.location_code;
                                        preTask.start_floor = sPoint?.floor.ToString();
                                        preTask.end_floor = ePoint?.floor.ToString();
                                        preTask.bill_code = _billRullService.GetBillNumber(WmsWareHouseConst.WMS_PRETASK_H_ENCODE).GetAwaiter().GetResult();
                                        preTask.status = WmsWareHouseConst.PRETASK_BILL_STATUS_DXF_ID;
                                        preTask.biz_type = ko.biz_type;
                                        preTask.task_type = WmsWareHouseConst.WMS_PRETASK_INSTOCK_TYPE_ID;
                                        preTask.carry_id = ko.carry_id;
                                        preTask.carry_code = ko.carry_code;
                                        preTask.area_id = sPoint?.area_id;
                                        preTask.area_code = it.Key;
                                        preTask.require_id = ko.id;
                                        preTask.require_code = ko.bill_code;
                                        preTask.create_id = _userManager.UserId;
                                        preTask.create_time = DateTime.Now;
                                        return preTask;
                                    }).ToList();
                                    await _warehouseService.GenPreTask(preTasks, null!);
                                    var subCarrys = await _db.Queryable<WmsCarryD>().Where(it => it.carry_id == ko.carry_id).ToListAsync();
                                    var carryIds = subCarrys.Select(x => x.carry_id).Concat(new[] { ko.carry_id }).Distinct().ToList();
                                    GenPreTaskUpInput genPreTaskInput = new() { CarryIds = carryIds, LocationIds = new List<string> { carry.location_id, ko.location_id } };
                                    await _warehouseService.GenInStockTaskHandleAfter(genPreTaskInput, it => new WmsCarryH { is_lock = 1, carry_status = ((int)EnumCarryStatus.齐套).ToString() }, it => new BasLocation { is_lock = 1 });

                                }
                            }
                        }
                    }
                }
            }
        }

        public override async Task ModifyAsync(WareHouseUpInput input)
        {
            if (input == null) throw new ArgumentNullException(nameof(input));
            try
            {
                await _db.Ado.BeginTranAsync();

                var carryId = input.carryIds[^input.carryIds.Count];
                var carry = await _db.Queryable<WmsCarryH>().SingleAsync(it => it.id == carryId);

                var kods = await _db.Queryable<WmsKittingoutD>().Where(it => it.bill_id == input.requireId).ToListAsync();
                //当前载具对应的所有条码插入
                var carryCodes = await _db.Queryable<WmsCarryCode>().Where(it => it.carry_id == carryId).ToListAsync();
                var kittingoutCodes = carryCodes.Adapt<List<WmsKittingoutCode>>();
                kittingoutCodes.ForEach(x =>
                {
                    var billDId = kods?.Find(xx => xx.material_id == x.material_id && xx.code_batch == x.code_batch)?.id;
                    if (billDId.IsNullOrEmpty())
                    {
                        billDId = kods?.Find(xx => xx.material_id == x.material_id)?.id;
                    }
                    x.id = SnowflakeIdHelper.NextId();
                    x.bill_id = input.requireId;
                    x.bill_d_id = billDId;
                    x.org_id = _userManager.User.OrganizeId;
                    x.create_id = _userManager.UserId;
                    x.create_time = DateTime.Now;
                });
                var row = await _db.Insertable(kittingoutCodes).ExecuteCommandAsync();
                var detailIds = kittingoutCodes.Select(x => x.bill_d_id).ToList();
                var curKittingoutDetails = kods.FindAll(x => detailIds.Contains(x.id));
                var dic = kittingoutCodes.GroupBy(g => g.bill_d_id).ToDictionary(x => x.Key, x => x.Select(x => x.codeqty).ToList());
                foreach (var kod in curKittingoutDetails)
                {
                    if (dic.ContainsKey(kod.id))
                    {
                        kod.qty += dic[kod.id].Sum(d => d);
                        if (kod.qty >= kod.pr_qty)
                        {
                            kod.line_status = WmsWareHouseConst.BILLSTATUS_COMPLETE_ID;
                        }
                        else
                        {
                            kod.line_status = WmsWareHouseConst.BILLSTATUS_ON_ID;
                        }
                    }
                }
                await _db.Updateable(curKittingoutDetails).ExecuteCommandAsync();
                var isOk = await _db.Updateable<WmsKittingoutH>().SetColumns(it => new WmsKittingoutH { status = WmsWareHouseConst.BILLSTATUS_COMPLETE_ID }).Where(it => it.id == input.requireId).ExecuteCommandHasChangeAsync();
                //if (carry != null)
                //{
                //    row = await _carryService.UpdateNullCarry(carry);
                //    isOk = row > 0;
                //}
                //判断当前载具是否为料架，如果是料架 清空所有料架/料箱数据，
                if (carry.carrystd_id == WmsWareHouseConst.CARRY_LJSTD_ID)
                {
                    var carryds = await _db.Queryable<WmsCarryD>().Where(it => it.id == carryId).ToListAsync();
                    var mids = carryds.Select(x => x.membercarry_id).ToList();
                    var carrys = await _db.Queryable<WmsCarryH>().Where(it => mids.Contains(it.id)).ToListAsync();
                    carrys.Add(carry);
                    if (carrys?.Count > 0)
                    {
                        var tasks = new List<Task<int>>();
                        foreach (var carryIt in carrys)
                        {
                            tasks.Add(_carryService.UpdateNullCarry(carryIt));
                        }
                        await Task.WhenAll(tasks);
                    }
                }
                if (!isOk) throw Oops.Oh(ErrorCode.COM1001);

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

    }

}