using Newtonsoft.Json;
using Rhea.Common;
using SqlSugar;
using System;
using System.Collections.Generic;
using Tiger.IBusiness;
using System.Linq;
using System.Linq.Expressions;
using System.Security.Policy;
using System.Text;
using System.Threading;
using System.Threading.Tasks;
using Tiger.Model;
using Tiger.Model.Sharetronic.Shelf;

namespace Tiger.Business.WMS.Transaction
{
    /// <summary>
    /// 生产领料事务
    /// </summary>
    public class OutOther : WMSTransactionBase, IOutOther
    {
        public IOutOther Init(string id, string userCode, string apiHost, string orgCode)
        {
            TransID = id;
            UserCode = userCode;
            ApiHost = apiHost;
            OrgCode = orgCode;
            Logger.Console.Info($"Start {this.GetType().Name} Transaction[ID: {TransID}]");
            return this;
        }

        #region Propertys & Variables
        public string UserCode { get; set; }
        public long UserId { get; set; }
        public string OrgCode { get; set; }
        public List<SuggestItem> Suggests { get; set; } = new();
        public List<WMS_ITEM_POOL> CurPoolList => Suggests.Where(q => !q.poolItem.IsNullOrEmpty()).Select(q => q.poolItem).ToList();
        public List<WMS_LOCATION> LocationHis { get; set; } = new();
        public Inventory CurInv { get; set; }
        public BIZ_ERP_OTH_OUT req { get; set; }
        public bool isExceed { get; set; }
        public bool isCutting { get; set; }
        public decimal cutQty { get; set; }
        public string QrCode { get; set; }
        public List<BIZ_ERP_OTH_OUT_DTL> dtls { get; set; } = new();
        #endregion

        #region Functions
        /// <summary>
        /// 获取其他出库单列表
        /// </summary>
        /// <param name="pageIndex"></param>
        /// <param name="pageSize"></param>
        /// <param name="orgcode"></param>
        /// <param name="billcode"></param>
        /// <returns></returns>
        public ApiAction<PageAble<BIZ_ERP_OTH_OUT>> GetOutOtherHeaders(int pageIndex, int pageSize, string orgcode, string billcode)
        {
            var action = new ApiAction<PageAble<BIZ_ERP_OTH_OUT>>();
            var query = Biz.Db.Queryable<BIZ_ERP_OTH_OUT>().Where(x =>
                    (x.STATUS == BIZ_ERP_OTH_OUT.STATUSs.INIT.GetValue()
                    || x.STATUS == BIZ_ERP_OTH_OUT.STATUSs.WORKING.GetValue())
                    && x.AUTH_ORG == orgcode)
                .WhereIF(!billcode.IsNullOrEmpty(), x => x.BILLCODE.Contains(billcode))
                .OrderByDescending(x => x.UPDATE_TIME.ToString("yyyy-MM-dd"))
                .OrderBy(x => x.CREATE_TIME)
                .ToPage(pageIndex, pageSize);

            action.Data = query;
            return action;
        }

        /// <summary>
        /// 其他出库单选择事件
        /// </summary>
        /// <param name="input"></param>
        /// <returns></returns>
        public async Task<ApiAction<OutOtherOutput>> SelectOrder(OutOtherInput input)
        {
            var action = new ApiAction<OutOtherOutput>();
            try
            {
                req = await Biz.Db.Queryable<BIZ_ERP_OTH_OUT>().Where(x => x.BILLCODE == input.ReqNo).Includes(q => q.DtlsWithGhost, d => d.ItemInfo).IncludesAllFirstLayer().FirstAsync();
                //验证明细是否正确
                if (!req.Dtls.Any())
                {
                    action.IsSuccessed = false;
                    action.LocaleMsg = new("WMS.ProdMReq.SelectOrder.DtlsException", input.ReqNo);
                    return action;
                }

                //action.LocaleMsg = Biz.L($"选择领料单完成");
                //action = await LightAll(new() { AuthOption = input.AuthOption, ReqType = ReqType.IsWhole, Color = LedColor.Blue });
            }
            catch (Exception ex)
            {
                action.CatchExceptionWithLog(ex, $"其他出库单选择异常");
            }
            return action;
        }

        /// <summary>
        /// 其他出库单推荐所有物料亮灯
        /// </summary>
        /// <param name="light"></param>
        /// <returns></returns>
        public async Task<ApiAction<OutOtherOutput>> LightAll(LightEntityInput light)
        {
            var action = new ApiAction<OutOtherOutput>();
            try
            {
                var list = Suggests.WhereIF(!light.ItemCode.IsNullOrEmpty(), q => q.Item.ITEM_CODE == light.ItemCode);
                if (list.Any())
                {
                    list = list.Where(q => q.Shelf.SHELF_TYPE == WMS_SHELF.SHELF_TYPEs.Smart.GetValue() || q.Shelf.SHELF_TYPE == WMS_SHELF.SHELF_TYPEs.QRCode.GetValue());
                    if (list.Any())
                    {
                        list = list.Where(q => q.poolItem.STATUS < WMS_ITEM_POOL.STATUSs.WaitSend.GetValue());
                        if (list.Any())
                        {
                            var locs = list.Select(x => x.Location.AddShelf(x.Shelf)).ToList();
                            LocationHis.AddRange(locs);
                            //亮灯前先灭一遍
                            foreach (var shelf in list.Select(q => q.Shelf))
                            {
                                await Share.Shelf.DownAll(shelf);
                            }
                            await Share.Shelf.LightMulti(TransID, light.Color, locs);
                            action.Data = new OutOtherOutput()
                            {
                                ReqNo = req.BILLCODE,
                            };
                            action.LocaleMsg = Biz.L("亮灯成功，亮灯颜色[{0}]", light.Color.GetDesc());
                        }
                        else
                        {
                            action.LocaleMsg = Biz.L($"无需亮灯，推荐的物料已全部下架");
                        }
                    }
                    else
                    {
                        action.LocaleMsg = Biz.L($"无需亮灯，推荐的物料不在智能货架上");
                    }
                }
                else
                {
                    action.IsSuccessed = false;
                    action.LocaleMsg = Biz.L($"亮灯失败，未找到推荐下架的物料");
                }
            }
            catch (Exception ex)
            {
                action.CatchExceptionWithLog(ex, $"亮灯异常");
            }
            return action;
        }

        /// <summary>
        /// 其他出库单发料明细
        /// </summary>
        /// <returns></returns>
        public async Task<ApiAction> OutOtherDtl(OutOthDtlInput input)
        {
            var action = new ApiAction();
            try
            {
                if (!req.IsNullOrEmpty())
                {
                    var dtls = req.Dtls.GroupBy(x => new { x.BILLLINE, x.ITEM_CODE, x.ItemInfo.ITEM_NAME }).Select(x => new OutOtherDtl() { BillCode = req.BILLCODE, BillLine = x.Key.BILLLINE.ToInt32(), ItemCode = x.Key.ITEM_CODE, ItemName = x.Key.ITEM_NAME, Status = "", Items = new List<OutOtherDtlItem>() }).ToList();

                    foreach (var d in dtls)
                    {
                        d.Items = Suggests.Where(x => x.Item.ITEM_CODE == d.ItemCode).Select(x => new OutOtherDtlItem { WHCode = x.Warehouse.WH_CODE, LocationCode = x.Location.LOCATION_CODE, SN = x.Item.SN, QTY = x.Item.QTY }).ToList();
                        double _total = (double)req.Dtls.Where(x => x.ITEM_CODE == d.ItemCode).Sum(x => x.PRQTY);
                        d.Status = $"{(double)req.Dtls.Where(x => x.ITEM_CODE == d.ItemCode).Sum(x => x.QTY)} / {_total} {Suggests.FirstOrDefault()?.Item?.UNIT} (还需{_total- (double)req.Dtls.Where(x => x.ITEM_CODE == d.ItemCode).Sum(x => x.QTY)}个)";
                    }

                    if (input.IsItemCodeList)
                    {
                        var ooDtls = dtls.WhereIF(!input.Code.IsNullOrEmpty(), q => q.ItemCode.Contains(input.Code)).OrderBy(q => q.BillLine);
                        List<OutOtherDtl> ooDtl = ooDtls.Skip((input.pageIndex - 1) * input.pageSize).Take(input.pageSize).ToList();
                        action.Data = new BasePageOutput<OutOtherDtl>()
                        {
                            data = ooDtl,
                            total = ooDtls.Count(),
                        };
                    }
                    else
                    {
                        var DtlItems = dtls.Where(x => x.ItemCode == input.Code).FirstOrDefault().Items.OrderBy(q => q.SN);
                        List<OutOtherDtlItem> DtlItem = DtlItems.Skip((input.pageIndex - 1) * input.pageSize).Take(input.pageSize).ToList();
                        action.Data = new BasePageOutput<OutOtherDtlItem>()
                        {
                            data = DtlItem,
                            total = DtlItems.Count(),
                        };
                    }
                }
            }
            catch (Exception ex)
            {
                action.CatchExceptionWithLog(ex, $"获取其他出库单明细异常");
            }

            return action;
        }

        /// <summary>
        /// 生成推荐物料
        /// </summary>
        /// <param name="input"></param>
        /// <returns></returns>
        public async Task<ApiAction<OutOtherOutput>> GenerateSuggests(BaseCodeInput input)
        {
            var action = new ApiAction<OutOtherOutput>();
            try
            {
                if (!input.Code.IsNullOrEmpty())
                {
                    Biz.Db.Deleteable<WMS_ITEM_POOL>().Where(q => CurPoolList.Select(q => q.SN).Contains(q.SN)).ExecuteCommand();
                    //如果上一次推荐有数据，则先灭掉亮的灯
                    if (Suggests.Any())
                    {
                        await CloseLight(LocationHis);
                    }

                    var begin = DateTime.Now;
                    var ElapsedTime = 0.0;
                    //Debug.WriteLine($"Async suggest begin at {begin:T}");
                    var sumDtls = req.Dtls.Where(q => q.LINESTATUS != BIZ_ERP_OTH_OUT.STATUSs.COMPLETE.GetValue())
                        .GroupBy(x => new { x.ITEM_CODE }).Select(x => new { ItemCode = x.Key.ITEM_CODE.ToString(), actQty = x.Sum(t => t.PRQTY - t.QTY), lockObj = new object() });
                    var dic = sumDtls.Where(q => q.ItemCode == input.Code).ToDictionary(k => k, v => new Result<List<SuggestItem>>());
                    foreach (var item in dic)
                    {
                        var key = item.Key;
                        Work.DoAsync(() =>
                        {
                            lock (item.Key.lockObj)
                            {
                                dic[item.Key] = WMS_ITEM_Biz.WmsItem.Suggest(req.BILLCODE, item.Key.ItemCode, req.Dtls.Where(q=>q.ITEM_CODE==item.Key.ItemCode).Select(s=>s.WAREHOUSECODE).FirstOrDefault(), null, null, null, input.AuthOption, item.Key.actQty);
                            }
                        });
                    }
                    while (dic.Any() && dic.Any(q => q.Value.IsNormal)) ;
                    ElapsedTime = (DateTime.Now - begin).TotalSeconds;
                    //Debug.WriteLine($"Async suggest end, elapsed total {ElapsedTime} seconds");
                    if (dic.Any(q => q.Value.IsException))
                    {
                        action.IsSuccessed = false;
                        action.LocaleMsg = dic.Where(q => q.Value.IsException).Select(q => q.Value.LocaleMsg).First();
                        return action;
                    }
                    if (dic.Any(q => q.Value.IsWarning))
                    {
                        action.IsSuccessed = false;
                        action.LocaleMsg = new("WMS.WmsItem.Suggest.Warning", string.Join(", ", dic.Where(q => q.Value.IsWarning).Select(q => q.Key.ItemCode)));
                    }
                    Suggests.Clear();
                    dic.Select(x => x.Value.Data).ToList().ForEach((item) =>
                    {
                        Suggests.AddRange(item);
                    });
                    Suggests.ForEach((inv) =>
                    {
                        var actQty = sumDtls.Where(x => x.ItemCode == inv.Item.ITEM_CODE).Select(x => x.actQty).First();
                        if (actQty > 0)
                        {
                            inv.poolItem = inv.Item.GetPoolItem(input.AuthOption.OrgCode, nameof(req), req.BILLCODE, null, actQty, false);
                        }
                        else
                        {
                            inv.poolItem = null;
                        }
                    });
                    Suggests.RemoveAll(q => q.poolItem.IsNullOrEmpty());

                    //保存物料池到数据库
                    var db = Biz.Db;
                    var dbTran = db.UseTran(() =>
                    {
                        db.Deleteable<WMS_ITEM_POOL>().Where(q => q.TRANS_CODE == req.BILLCODE).ExecuteCommand();
                        db.Insertable(CurPoolList).ExecuteCommand();
                    });
                    if (!dbTran.IsSuccess)
                    {
                        throw dbTran.ErrorException;
                    }
                    action = await LightAll(new() { AuthOption = input.AuthOption, ReqType = ReqType.IsWhole, Color = LedColor.Blue,ItemCode = input.Code });
                }
            }
            catch (Exception ex)
            {
                action.CatchExceptionWithLog(ex, $"其他出库单选择异常");
            }
            return action;
        }

        /// <summary>
        /// 发料明细提示信息
        /// </summary>
        /// <returns></returns>
        public async Task<ApiAction> GetItemTips(string itemcode)
        {
            var action = new ApiAction();
            try
            {
                action.Data = $"物料{itemcode}：已下架[{(double)req.Dtls.Where(x => x.ITEM_CODE == itemcode).Sum(x => x.QTY)}]，共{(double)req.Dtls.Where(x => x.ITEM_CODE == itemcode).Sum(x => x.PRQTY)} {Suggests.FirstOrDefault()?.Item?.UNIT}";
            }
            catch (Exception ex)
            {
                action.CatchExceptionWithLog(ex, $"获取发料明细提示信息异常");
            }
            return action;
        }

        /// <summary>
        /// 灭灯
        /// </summary>
        /// <returns></returns>
        public async Task<ApiAction> CloseLight(List<WMS_LOCATION> locations = null)
        {
            var action = new ApiAction();
            try
            {
                if (locations != null)
                {
                    foreach (var shelf in locations.Select(q => q.Shelf))
                    {
                        await Share.Shelf.DownAll(shelf);
                    }
                }
                //灭灯
                await Share.Shelf.DownMulti(TransID, locations.IsNullOrEmpty(Suggests.Where(q => q.Shelf.SHELF_TYPE == WMS_SHELF.SHELF_TYPEs.Smart.GetValue() || q.Shelf.SHELF_TYPE == WMS_SHELF.SHELF_TYPEs.QRCode.GetValue())
                    .Select(x => x.Location).ToList()));
                action.LocaleMsg = Biz.L($"灭灯成功");
            }
            catch (Exception ex)
            {
                action.CatchExceptionWithLog(ex, $"灭灯异常");
            }
            return action;
        }

        /// <summary>
        /// 扫描物料领料下架
        /// </summary>
        /// <param name="input"></param>
        /// <returns></returns>
        public async Task<ApiAction<OutOtherOutput>> ScanItem(BaseInput input)
        {
            var action = new ApiAction<OutOtherOutput>();
            try
            {
                if (input.SN.IsNullOrEmpty())
                {
                    action.IsSuccessed = false;
                    action.LocaleMsg = Biz.L("条码不能为空");
                    return action;
                }

                //解析条码
                Result<Inventory> result = WMS_ITEM_Biz.WmsItem.Get(input.SN, input.AuthOption, true);
                if (!result.IsSuccessed)
                {
                    action.IsSuccessed = false;
                    action.LocaleMsg = result.LocaleMsg;
                    return action;
                }
                CurInv = result.Data;

                //验证条码是否正确
                if (!CurInv.isNormalStatus || CurInv.Status != WMS_ITEM.STATUSs.InStore)
                {
                    action.IsSuccessed = false;
                    action.LocaleMsg = Biz.L("WMS.ProdMReq.ScanItem.StatusException", string.Join(',', CurInv.StatusList.Select(x => x.GetDesc())));
                    return action;
                }
                //储位验证
                if (CurInv.Location.IsNullOrEmpty())
                {
                    action.IsSuccessed = false;
                    action.LocaleMsg = Biz.L("WMS.ProdMReq.ScanItem.LocationIsNull", CurInv.CurPkg.SN, CurInv.CurPkg.LOCATION_ID);
                    return action;
                }

                //物料验证
                if (CurInv.ItemInfo.IsNullOrEmpty() || CurInv.ItemInfo.IS_ACTIVE == "N")
                {
                    action.IsSuccessed = false;
                    action.LocaleMsg = Biz.L("WMS.ProdMReq.ScanItem.ItemCodeNotExistsOrNotActive", CurInv.ItemInfo.ITEM_CODE.IsNullOrEmpty(CurInv.Barcode.ItemCode));
                    return action;
                }

                //仓库卡控
                if (!req.Dtls.Any(q => q.ITEM_CODE == CurInv.ItemInfo.ITEM_CODE && q.WAREHOUSECODE == CurInv.Warehouse.WH_CODE))
                {
                    action.IsSuccessed = false;
                    action.LocaleMsg = Biz.L($"条码[{CurInv.Barcode.SN}]的料号或者仓库跟单据[{req.BILLCODE}]上的不一致");
                    return action;
                }

                QrCode = input.SN;

                //1.判断FIFO
                //if (Suggests.Where(x => Barcode.IsReprint(x.Item.SN) && x.Item.ITEM_CODE == CurInv.ItemInfo.ITEM_CODE).Any() && !CurInv.Barcode.IsReprintSn)
                //{
                //    action.IsSuccessed = false;
                //    action.LocaleMsg = Biz.L("需要先出拆包的物料");
                //    return action;
                //}
                var MaxDC = CurPoolList.Any(x => x.ITEM_CODE == CurInv.ItemInfo.ITEM_CODE) ? CurPoolList.Where(x => x.ITEM_CODE == CurInv.ItemInfo.ITEM_CODE).Max(t => t.PROD_DATE) : DateTime.MinValue;
                //判断系统参数是否设置先进先出
                if (Biz.SysParam["YesOrNo"].PARAM_VALUE == "Y")
                {
                    if (CurInv.Items.Max(x => x.PROD_DATE).Date > MaxDC.Date)
                    {
                        action.IsSuccessed = false;
                        action.LocaleMsg = Biz.L("必需先进先出", CurInv.Items.Max(x => x.PROD_DATE).Date, MaxDC.Date);
                        return action;
                    }
                }
                //判断物料是否在超期日期范围内
                //if (CurInv.ItemInfo.VALIDITY_DAYS > 0)
                //{
                //    var time = DateTime.Now;
                //    if (CurInv.Items.Count() > 0)
                //    {
                //        foreach (var item in CurInv.Items)
                //        {
                //            //判断是否有生产日期
                //            if (!item.PROD_DATE.IsNullOrEmpty() && item.PROD_DATE.ToString() != "1900/1/1 0:00:00")
                //            {
                //                var t = time - item.PROD_DATE;
                //                decimal timeDifference = (decimal)t.TotalDays;
                //                if (timeDifference > CurInv.ItemInfo.VALIDITY_DAYS)
                //                {
                //                    action.IsSuccessed = false;
                //                    action.LocaleMsg = Biz.L("产品超出有效期范围", timeDifference);
                //                    return action;
                //                }
                //            }
                //            //否则以首次入库时间
                //            else if (!item.FIRST_IN_DATE.IsNullOrEmpty() && item.FIRST_IN_DATE.ToString() != "1900/1/1 0:00:00")
                //            {
                //                var t = time - item.PROD_DATE;
                //                decimal timeDifference = (decimal)t.TotalDays;
                //                if (timeDifference > CurInv.ItemInfo.VALIDITY_DAYS)
                //                {
                //                    action.IsSuccessed = false;
                //                    action.LocaleMsg = Biz.L("产品超出有效期范围", timeDifference);
                //                    return action;
                //                }
                //            }


                //        }
                //    }
                //}


                //2.是否超发
                isExceed = false;
                req = await Biz.Db.Queryable<BIZ_ERP_OTH_OUT>().Where(x => x.BILLCODE == req.BILLCODE).Includes(q => q.DtlsWithGhost, d => d.ItemInfo).IncludesAllFirstLayer().FirstAsync();
                dtls = req.Dtls.Where(x => x.ITEM_CODE == CurInv.ItemInfo.ITEM_CODE).ToList();
                if (dtls.IsNullOrEmpty())
                {
                    action.IsSuccessed = false;
                    action.LocaleMsg = Biz.L("其他出库单明细没有这个物料");
                    return action;
                }
                //如果是首套或者Agv叫料只能发一盘
                if (dtls.Where(x=>x.LINESTATUS == BIZ_ERP_OTH_OUT.STATUSs.COMPLETE.GetValue()).Count() == dtls.Count)
                {
                    action.IsSuccessed = false;
                    action.LocaleMsg = Biz.L("料已经发完");
                    return action;
                }
                var actQty = dtls.Sum(x => x.QTY > x.PRQTY ? 0 : x.PRQTY - x.QTY);
                cutQty = 0;
                if (actQty < CurInv.CurPkg.QTY)
                {
                    isExceed = true;
                    cutQty = CurInv.CurPkg.QTY - actQty;
                }


                //3.是否截料，不允许超发的物料，所有的单别都需要做拆包处理，自动调用拆包，允许超发的物料，单别5408或者5409的要拆包
                isCutting = false;
                decimal curQty = CurInv.CurPkg.QTY;
                foreach (var d in dtls)
                {
                    var actPrQty = d.PRQTY - d.QTY;
                    if (actPrQty > 0 && curQty > 0)
                    {
                        if (actPrQty >= curQty)
                        {
                            d.QTY += curQty;
                            curQty = 0;
                        }
                        else
                        {
                            d.QTY = d.PRQTY;
                            curQty -= actPrQty;
                        }
                        d.LINESTATUS = d.QTY >= d.PRQTY ? BIZ_ERP_OTH_OUT.STATUSs.COMPLETE.GetValue() : BIZ_ERP_OTH_OUT.STATUSs.WORKING.GetValue();
                        //d.WAREHOUSECODE = CurInv.Warehouse.WH_CODE;
                    }
                }
                if (isExceed)
                {
                    if (CurInv.ItemInfo.DLVY_TYPE == BAS_ITEM.DLVY_TYPEs.ByDemand.GetValue()  || req.BILLCODE.Substring(2, 4) == "5408" || req.BILLCODE.Substring(2, 4) == "5409")
                    {
                        isCutting = true;
                        isExceed = false;
                        if (CurInv.Items.Count > 1)
                        {
                            action.IsSuccessed = false;
                            action.LocaleMsg = Biz.L("扫描的条码不是最小包装，不能拆包！");
                            return action;
                        }
                    }
                    else
                    {
                        //最大数量明细行用于调拨，该行发料数量加上应截料数量
                        var tfdtl = dtls.OrderBy(q => q.BILLLINE.ToDecimal()).Last();
                        tfdtl.QTY += cutQty;
                    }
                }
                //增加储位操作历史
                if (!LocationHis.Any(q => q.SHELF_ID == CurInv.Location.SHELF_ID && q.LOCATION_CODE == CurInv.Location.LOCATION_CODE))
                {
                    LocationHis.Add(CurInv.Location);
                }

                action.Data = new OutOtherOutput()
                {
                    SN = CurInv.SN,
                    ItemCode = CurInv.ItemInfo.ITEM_CODE,
                    Qty = CurInv.CurPkg.QTY,
                    CutQty = CurInv.CurPkg.QTY - cutQty,
                    isCutting = isCutting,
                    isExceed = isExceed,
                    ReqNo = req.BILLCODE,
                    regionCode = CurInv.Region.REGION_CODE,
                    locationCode = CurInv.Location?.LOCATION_CODE,
                    Status = (await GetItemTips(CurInv.ItemInfo.ITEM_CODE)).Data?.ToString()
                };
            }
            catch (Exception ex)
            {
                action.CatchExceptionWithLog(ex, $"扫描物料[{input.SN}]复核异常");
            }
            return action;
        }

        /// <summary>
        /// 确认超发后或者需要截料的
        /// </summary>
        /// <param name="input"></param>
        /// <returns></returns>
        public async Task<ApiAction<OutOtherOutput>> ConfirmExceed(OutOtherInput input)
        {
            var action = new ApiAction<OutOtherOutput>();
            try
            {

                //灭灯
                if (CurInv.Shelf.SHELF_TYPE == WMS_SHELF.SHELF_TYPEs.Smart.GetValue() || CurInv.Shelf.SHELF_TYPE == WMS_SHELF.SHELF_TYPEs.QRCode.GetValue())
                {
                    await Share.Shelf.DownSingle(TransID, CurInv.Location);
                }
                Suggests.Where(q => CurInv.Items.Select(x => x.SN).Contains(q.Item.SN)).ToList().ForEach((i) => { i.poolItem.STATUS = WMS_ITEM_POOL.STATUSs.WaitSend.GetValue(); });

                var reqSn = new BIZ_ERP_OTH_OUT_SN()
                {
                    AUTH_ORG = OrgCode,
                    ORDER_NO = req.BILLCODE,
                    SN = CurInv.CurPkg.SN,
                    ITEM_CODE = CurInv.ItemInfo.ITEM_CODE,
                    QTY = CurInv.CurPkg.QTY,
                    META_SN = CurInv.Barcode.MetaSn,
                    STATUS = WMS_ITEM.STATUSs.Sended.GetValue(),
                    LOCATION_CODE = CurInv.Location?.LOCATION_CODE,
                    ERP_WH = CurInv.Warehouse.WH_CODE,
                    ALLOC_QTY = CurInv.CurPkg.QTY - cutQty,
                    NEED_CUTTING = isCutting ? "Y" : "N",
                };

                //4.更新业务单据，BIZ_ERP_OTH_OUT、BIZ_ERP_OTH_OUT_DTL、BIZ_ERP_OTH_OUT_SN 判断明细行状态是否完成
                //detail未完成的行数
                var isComplete = !req.Dtls.Any(x => x.LINESTATUS != BIZ_ERP_OTH_OUT.STATUSs.COMPLETE.GetValue() && x.PRQTY > 0);
                if (isComplete)
                {
                    //detail全部完成了
                    req.STATUS = BIZ_ERP_OTH_OUT.STATUSs.COMPLETE.GetValue();
                }
                else
                {
                    req.STATUS = BIZ_ERP_OTH_OUT.STATUSs.WORKING.GetValue();
                }

                //5.出库下架
                foreach (var item in CurInv.Items)
                {
                    item.TRANS_CODE = nameof(BIZ_ERP_OTH_OUT);
                    item.TRANS_NO = req.BILLCODE;
                    item.TRANS_LINE = string.Join(",", dtls.Select(x => x.BILLLINE));
                }
                Result<TakeDownInfo> downResult = WMS_ITEM_Biz.WmsItem.TakeDown(CurInv, input.AuthOption, WMS_ITEM.STATUSs.Sended, !isCutting);
                if (!downResult.IsSuccessed)
                {
                    action.IsSuccessed = false;
                    action.LocaleMsg = downResult.LocaleMsg;
                    return action;
                }
                TakeDownInfo downInfo = downResult.Data;
                //物料池中删除已下架物料
                var poolItems = CurPoolList.Where(q => downInfo.Items.Select(x => x.SN).Contains(q.SN)).ToList();

                //5.保存数据库
                var db = Business.Biz.Db;
                var dbTran = db.UseTran(() =>
                {
                    //入库
                    db.Updateable(downInfo.Items, UserCode).ExecuteCommand();
                    db.Insertable(downInfo.History, UserCode).ExecuteCommand();
                    db.Updateable(downInfo.Packages, UserCode).ExecuteCommand();
                    db.Deleteable(poolItems).ExecuteCommand();
                    db.Updateable(req, UserCode).ExecuteCommand();
                    db.Updateable(dtls, UserCode).ExecuteCommand();
                    if (reqSn != null)
                    {
                        db.Insertable(reqSn, UserCode).ExecuteCommand();
                    }
                });
                if (!dbTran.IsSuccess)
                {
                    Logger.Default.Fatal(dbTran.ErrorException, "Database transaction save exception");
                    this.Close(!dbTran.IsSuccess);
                    throw dbTran.ErrorException;
                }

                action.LocaleMsg = Biz.L($"其他出库完成，料号：[{CurInv.ItemInfo.ITEM_CODE}]，状态:{req.STATUS.GetEnumDesc<BIZ_WMS_TRANSFER.STATUSs>()}");
                action.Data = new OutOtherOutput()
                {
                    SN = CurInv.SN,
                    ItemCode = CurInv.ItemInfo.ITEM_CODE,
                    Qty = CurInv.CurPkg.QTY,
                    CutQty = CurInv.CurPkg.QTY - cutQty,
                    isCutting = isCutting,
                    isExceed = isExceed,
                    ReqNo = req.BILLCODE,
                    regionCode = CurInv.Region.REGION_CODE,
                    locationCode = CurInv.Location?.LOCATION_CODE,
                    Status = (await GetItemTips(CurInv.ItemInfo.ITEM_CODE)).Data?.ToString()
                };
            }
            catch (Exception ex)
            {
                action.CatchExceptionWithLog(ex, $"亮灯异常");
            }
            return action;
        }

        /// <summary>
        /// 添加一个ApiAction的历史记录
        /// </summary>
        /// <param name="action"></param>
        public override void AddHistory<T>(Microsoft.AspNetCore.Http.HttpRequest request, ApiAction<T> action)
        {
            var his = action.History();
            his.TraceDic.Add("CurInv", CurInv);
            his.TraceDic.Add("req", req);
            his.TraceDic.Add("CurPoolList", CurPoolList);
            ActionHistoryList.Add($"{request.HttpContext.TraceIdentifier} at {action.Timestamp:yyyy/MM/dd HH:mm:ss.fff}: {request.Path}", his);
            LastActionTime = DateTime.Now;
        }

        #endregion

        public override bool Close(bool needSaveHistoryLog = false)
        {
            //needSaveHistoryLog = true;
            CloseLight(LocationHis).Wait();
            if (!(req?.BILLCODE ?? "").IsNullOrEmpty())
            {
                Biz.Db.Deleteable<WMS_ITEM_POOL>().Where(x => x.TRANS_NO == req.BILLCODE).ExecuteCommand();
            }
            Biz.Db.Deleteable<WMS_ITEM_POOL>().Where(q => CurPoolList.Select(q => q.SN).Contains(q.SN)).ExecuteCommand();
            //保存操作日志

            this.IsFinished = true;
            return IsFinished ? base.Close(needSaveHistoryLog) : IsFinished;
        }

    }//endClass
}