using Rhea.Common;
using SqlSugar;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using Tiger.IBusiness;
using Tiger.Model;
using Tiger.Model.Entitys.MES.Position;
using static IronPython.Modules._ast;

namespace Tiger.Business.WMS.Transaction
{
    /// <summary>
    /// 仓库作业任务，包括清点、上架、下架、移库、盘点等
    /// </summary>
    public class WmsTask : WMSTransactionBase, IWmsTask
    {
        #region Propertys & Variables
        public string UserCode { get; set; }
        public string OrgCode { get; set; }
        private DbClient _MainDB;
        public DbClient MainDB => _MainDB;
        private DbClient CommitDB;
        public Inventory CurInvItem { get; set; }
        public ScanShelfInfo CurScanShelf { get; set; }
        /// <summary>
        /// 跟客户端通讯时的指令，有具体功能定义，默认为Normal
        /// </summary>
        public string Command { get; set; } = "Normal";
        /// <summary>
        /// 是否需要临时存储数据库提交操作，待需要的时候再提交
        /// </summary>
        public bool NeedTemporaryStoreDBCommitAction { get; set; } = false;
        protected Dictionary<string, List<Action>> DBCommitList { get; set; } = new();
        #endregion Propertys & Variables

        #region Functions
        public IWmsTask Init(string id, string userCode, string apiHost, string orgCode)
        {
            TransID = id;
            UserCode = userCode;
            ApiHost = apiHost;
            OrgCode = orgCode;
            _MainDB = Biz.Db;

            return this;
        }

        /// <summary>
        /// 获取提交数据的DbClient对象
        /// </summary>
        /// <returns></returns>
        public DbClient GetCommitDB()
        {
            return CommitDB ??= Biz.Db;
        }

        /// <summary>
        /// 增加暂存的数据库操作
        /// </summary>
        /// <param name="groupName">暂存的分组</param>
        /// <param name="action">暂存的数据库操作</param>
        public void AddCommitAction(string group, Action action)
        {
            //增加附加的保存内容
            if (!action.IsNullOrEmpty())
            {
                if (!DBCommitList.ContainsKey(group))
                {
                    DBCommitList.Add(group, new List<Action>());
                }
                var commitList = DBCommitList[group];
                commitList.Add(action);
            }
        }

        /// <summary>
        /// 暂存的数据库操作提交到数据库
        /// </summary>
        /// <param name="appendToSave">附加的保存内容</param>
        public void SaveCommitListToDB(Action appendToSave = null)
        {
            //增加附加的保存内容
            if (!appendToSave.IsNullOrEmpty())
            {
                if (!DBCommitList.ContainsKey("AppendSaveAction"))
                {
                    DBCommitList.Add("AppendSaveAction", new List<Action>());
                }
                var appendList = DBCommitList["AppendSaveAction"];
                appendList.Add(appendToSave);
            }

            //如果不需要临时存储数据库提交操作，则把提交操作列表提交到数据库
            if (!NeedTemporaryStoreDBCommitAction)
            {
                //恢复临时存储标记为false
                NeedTemporaryStoreDBCommitAction = false;

                var dbTran = GetCommitDB().UseTran(() =>
                {
                    //在同一个事务中保存所有工步的数据
                    foreach (var wipSn in DBCommitList.Keys.Where(q => q != "AppendSaveAction"))
                    {
                        foreach (var action in DBCommitList[wipSn])
                        {
                            action.Invoke();
                        }
                    }
                    //附加的保存内容
                    if (DBCommitList.ContainsKey("AppendSaveAction"))
                    {
                        foreach (var action in DBCommitList["AppendSaveAction"])
                        {
                            action.Invoke();
                        }
                    }
                });  
                //保存成功则清空提交操作列表
                DBCommitList.Clear();
                if (!dbTran.IsSuccess)
                {
                    //抛出异常
                    throw dbTran.ErrorException;
                }
            }
        }

        /// <summary>
        /// 获取条码库存信息，包括仓库，储区，货架，储位，父条码，包装明细等
        /// </summary>
        /// <param name="sn">查询的条码</param>
        /// <param name="option">授权查询选项</param>
        /// <param name="doUnPack">是否同时执行拆包操作，解除与父条码之间的包装关系</param>
        /// <returns></returns>
        public Result<IInventory> GetInventory(string sn, AuthOption option, bool doUnPack)
        {
            var result = new Result<IInventory>(Result.Flags.Success);
            try
            {
                var inv = new Inventory();
                Barcode barcode = new Barcode(sn);
                if (sn.IsNullOrEmpty())
                {
                    result.Flag = Result.Flags.Failed;
                    result.LocaleMsg = new("WMS.WmsItem.Barcode.EmptyFailure");
                }
                else if (barcode.IsException)
                {
                    throw barcode.AnalyseException;
                }
                //非法条码
                else if (!barcode.IsRegular)
                {
                    result.Flag = Result.Flags.Failed;
                    result.LocaleMsg = new("WMS.WmsItem.Barcode.IllegalFailure");
                }
                //else if (barcode.Qty <= 0)
                //{
                //    result.Flag = Result.Flags.Failed;
                //    result.LocaleMsg = new("数量不能小于等于零，请检查二维码！");
                //}
                else
                {
                    var query = Biz.Db.Queryable<WMS_ITEM_PKG>().ByAuth(option).Where(q => q.SN == barcode.SN).IncludesAllFirstLayer().First();
                    //var query = Biz.Db.Queryable<WMS_ITEM_PKG>().Where(q => q.SN == barcode.SN).IncludesAllFirstLayer().First();//.ByAuth(option)

                    //包装表中找到条码
                    if (!query.IsNullOrEmpty())// && query.QTY > 0)
                    {
                        inv.SN = barcode.SN;
                        inv.Barcode = barcode;
                        inv.ExtInfo = query.ExtInfo;
                        inv.ItemInfo = query.ItemInfo;
                        inv.Warehouse = query.Warehouse;
                        inv.Region = query.Region;
                        inv.Shelf = query.Shelf;
                        inv.Location = query.Location;
                        inv.Packages = Biz.Db.Ado.UseStoredProcedure().SqlQuery<WMS_ITEM_PKG>("sp_wms_get_item_pkg", new SugarParameter("root", barcode.SN));
                        inv.Items = Biz.Db.Ado.UseStoredProcedure().SqlQuery<WMS_ITEM>("sp_wms_get_items", new SugarParameter("root", barcode.SN));
                        inv.ItemsExt = Biz.Db.Queryable<WMS_ITEM_EXT>().Where(q => inv.Items.Any(s => s.SN == q.SN)).ToList();
                        //var data = inv.Items.Select(i => i.SN).ToList().Except(inv.ItemsExt.Select(i => i.SN).ToList());
                        var data = inv.Items.Where(q => !inv.ItemsExt.Any(s => s.SN == q.SN)).ToList();
                        if (data.Count > 0)
                        {
                            foreach (var item in data)
                            {
                                inv.ItemsExt.Add(new()
                                {
                                    SN = item.SN,
                                    META_SN = barcode.MetaSn,
                                    QR_CODE = barcode.MetaSn
                                });
                            }
                        }
                        result.LocaleMsg = new($"WMS.WmsItem.Barcode.Get{(doUnPack ? "UnPack" : "")}Success", barcode.SN, query.Parent?.SN);
                        if (!query.Parent.IsNullOrEmpty() && doUnPack && query.Parent.SN != query.SN)
                        {
                            inv.ParentPkg = null;
                            //保存数据到数据库
                            var db = Biz.Db;
                            var dbTran = db.UseTran(() =>
                            {
                                var unPackQty = inv.Items.Sum(q => q.QTY);
                                db.Updateable<WMS_ITEM_PKG>().SetColumns(q => q.PARENT_SN == null).Where(q => q.ID == query.ID).ExecuteCommand();
                                db.Updateable<WMS_ITEM_PKG>().SetColumns(q => q.QTY == q.QTY - unPackQty).Where(q => q.ID == query.Parent.ID).ExecuteCommand();
                                if (!Biz.Db.Queryable<WMS_ITEM_PKG>().Any(q => q.PARENT_SN == query.PARENT_SN && q.SN != query.SN))
                                {
                                    db.Deleteable(query.Parent);
                                }
                            });
                            if (!dbTran.IsSuccess)
                            {
                                throw dbTran.ErrorException;
                            }
                        }
                        else
                        {
                            inv.ParentPkg = query.Parent;
                        }
                    }
                    else
                    {
                        inv.SN = barcode.SN;
                        inv.Barcode = barcode;
                        inv.ItemInfo = Biz.Db.Queryable<BAS_ITEM>().Where(q => q.ITEM_CODE == barcode.ItemCode).First();
                        result.LocaleMsg = new($"WMS.WmsItem.Barcode.NotFound", barcode.SN);
                    }
                }
                result.Data = inv;
            }
            catch (Exception ex)
            {
                result.CatchExceptionWithLog(ex, Biz.L("WMS.WmsItem.Barcode.GetException", sn));
            }
            return result;
        }

        /// <summary>
        /// 上架
        /// </summary>
        /// <param name="inventory">要上架的库存对象</param>
        /// <param name="option">授权查询选项</param>
        /// <param name="targetLocation">要上架的储位代码</param>
        /// <param name="isTransfer">是否移库操作</param>
        /// <returns></returns>
        public Result PutOn(AuthOption option, string targetLocation)
        {
            var result = new Result(Result.Flags.Success);
            try
            {
                var location = Biz.Db.Queryable<V_WH_UNIT>().Where(q => q.LOCATION_CODE == targetLocation && q.AUTH_ORG == option.CurOrg).IncludesAllFirstLayer().First();
                if (!location.IsNullOrEmpty())
                {
                    var isTransfer = CurInvItem?.Location?.LOCATION_CODE != location.LOCATION_CODE;
                    foreach (var item in CurInvItem.Items)
                    {
                        item.STATUS = WMS_ITEM.STATUSs.InStore.GetValue();
                        item.LOTNO = item.LOTNO.IsNullOrEmpty(new Barcode(item.SN).LotNo);
                        item.SUPP_LOTNO = CurInvItem.Barcode.LotNo;
                        item.FIRST_IN_DATE = item.FIRST_IN_DATE <= DateTime.MinValue ? DateTime.Now : item.FIRST_IN_DATE;
                        item.PROD_DATE = item.PROD_DATE <= DateTime.MinValue ? item.FIRST_IN_DATE : item.PROD_DATE;
                        item.WH_ID = location.WH_ID;
                        item.REGION_ID = location.REGION_ID;
                        item.SHELF_ID = location.SHELF_ID;
                        item.LOCATION_ID = location.LOCATION_ID;
                        CurInvItem.History.Add(new WMS_ITEM_HIS(item, $"条码[{CurInvItem.SN}]{(isTransfer ? $"从储位[{CurInvItem?.Location?.LOCATION_CODE}]移库" : "上架")}到储位[{location.LOCATION_CODE}]成功{(isTransfer ? "" : $"，操作单据[{item.TRANS_NO}]")}"));
                    }
                    foreach (var item in CurInvItem.Packages)
                    {
                        item.WH_ID = location.WH_ID;
                        item.REGION_ID = location.REGION_ID;
                        item.SHELF_ID = location.SHELF_ID;
                        item.LOCATION_ID = location.LOCATION_ID;
                    }
                    foreach (var item in CurInvItem.ItemsExt)
                    {
                        item.AUTH_ORG = option.OrgCode;
                        item.SN = CurInvItem.Barcode.SN;
                    }
                    //更新储存信息
                    CurInvItem.Warehouse = location.Warehouse;
                    CurInvItem.Region = location.Region;
                    CurInvItem.Shelf = location.Shelf;
                    CurInvItem.Location = location.Location;

                    //创建变量克隆对象用于传入DBSubmitAction中保存当前需要暂存的数据值
                    var _Items = CurInvItem.Items.Clone();
                    var _Packages = CurInvItem.Packages.Clone();
                    var _History = CurInvItem.History.Clone();
                    var _ItemsExt = CurInvItem.ItemsExt.Clone();
                    AddCommitAction("PutOn", () =>
                    {
                        //使用统一的事务DB对象
                        var db = GetCommitDB();
                        //数据保存逻辑
                        db.Storageable(_Items, UserCode).ExecuteCommand();
                        db.Storageable(_Packages, UserCode).ExecuteCommand();
                        db.Insertable(_History, UserCode).ExecuteCommand();
                        var x = db.Storageable(_ItemsExt, UserCode).ToStorage();
                        x.AsInsertable.ExecuteCommand();//不存在插入
                        x.AsUpdateable.ExecuteCommand();//存在更新
                    });
                }
                else
                {
                    result.Flag = Result.Flags.Failed;
                    result.LocaleMsg = new("WMS.WmsItem.PutOn.LocationNotExists", targetLocation);
                }
            }
            catch (Exception ex)
            {
                result.CatchExceptionWithLog(ex, Biz.L("WMS.WmsItem.PutOn.Exception", CurInvItem.SN, targetLocation));
            }
            return result;
        }

        /// <summary>
        /// 下架物料推荐，返回固定个数的最小包装物料库存列表
        /// </summary>
        /// <param name="order">领料单号</param>
        /// <param name="itemCode">物料编码</param>
        /// <param name="erpWH">物料的ERP库位</param>
        /// <param name="whID">物料所在的仓库编码</param>
        /// <param name="regionID">物料所在的储区编码</param>
        /// <param name="shelfID">物料所在的货架编码</param>
        /// <param name="option">授权查询选项</param>
        /// <param name="returnCount">返回的最小包装物料个数，默认返回1个</param>
        /// <returns></returns>
        public Result<List<SuggestItem>> Suggest(string order, string itemCode, string erpWH, string whID, string regionID, string shelfID, AuthOption option, int returnCount = 1)
        {
            var result = new Result<List<SuggestItem>>(Result.Flags.Success, new List<SuggestItem>()) { LocaleMsg = new("WMS.WmsItem.Suggest.Success") };
            try
            {
                var items = Biz.Db.Queryable<WMS_ITEM, WMS_ITEM_POOL, WMS_WAREHOUSE, WMS_REGION, WMS_SHELF, WMS_LOCATION>((q, p, w, r, s, l) => new JoinQueryInfos(
                                                                JoinType.Left, q.SN == p.SN,
                                                                JoinType.Left, q.WH_ID == w.ID,
                                                                JoinType.Left, q.REGION_ID == r.ID,
                                                                JoinType.Left, q.SHELF_ID == s.ID,
                                                                JoinType.Left, q.LOCATION_ID == l.ID))
                                             //检查用户权限
                                             .ByAuth(option)
                                            //允许使用已经分配到库存池中的物料
                                            .Where((q, p, w, r, s, l) => SqlFunc.IsNullOrEmpty(p.ID) || (!SqlFunc.IsNullOrEmpty(order) && p.STATUS <= WMS_ITEM_POOL.STATUSs.WaitPick.GetValue() && p.TRANS_NO == order))
                                            //只允许未锁定的
                                            .Where((q, p, w, r, s, l) => q.IS_LOCKED == "N")
                                            //只允许物料状态是在库的
                                            .Where((q, p, w, r, s, l) => q.STATUS == WMS_ITEM.STATUSs.InStore.GetValue())
                                            //如果有传入料号，则只允该料号的物料
                                            .WhereIF(!itemCode.IsNullOrEmpty(), (q, p, w, r, s, l) => q.ITEM_CODE == itemCode)
                                            //如果有传入库位，则只允该库位中的物料
                                            .WhereIF(!erpWH.IsNullOrEmpty(), (q, p, w, r, s, l) => q.ERP_WH == erpWH && q.AUTH_ORG == option.CurOrg)
                                            //如果有传入仓库，则只允该仓库的物料
                                            .WhereIF(!whID.IsNullOrEmpty(), (q, p, w, r, s, l) => q.WH_ID == whID && q.AUTH_ORG == option.CurOrg)
                                            //如果有传入储区，则只允该储区的物料
                                            .WhereIF(!regionID.IsNullOrEmpty(), (q, p, w, r, s, l) => q.REGION_ID == regionID && q.AUTH_ORG == option.CurOrg)
                                            //如果有传入货架，则只允该货架的物料
                                            .WhereIF(!shelfID.IsNullOrEmpty(), (q, p, w, r, s, l) => q.SHELF_ID == shelfID && q.AUTH_ORG == option.CurOrg)
                                            //优先使用库存池中的物料
                                            .OrderBy((q, p, w, r, s, l) => SqlFunc.IsNullOrEmpty(p.ID))
                                            //优先使用尾数物料(截料或者退料之后的物料)
                                            .OrderByDescending((q, p, w, r, s, l) => q.SN.Contains("_C") || q.SN.Contains("_T"))
                                            //按生产日期先进先出，再按物料数量从小到大，最后按条码排序
                                            .OrderBy((q, p, w, r, s, l) => q.PROD_DATE).OrderBy(q => q.QTY).OrderBy(q => q.SN)
                                            .Select((q, p, w, r, s, l) => new SuggestItem
                                            {
                                                Item = q,
                                                poolItem = null,
                                                Warehouse = w,
                                                Region = r,
                                                Shelf = s,
                                                Location = l,
                                            })
                                            //检查用户权限
                                            .Take(returnCount).ToList();
                //foreach (var item in items)
                //{
                //    var inv = Get(item.SN, option, false);
                //    if (inv.IsSuccessed)
                //    {
                //        result.Data.Add(inv.Data);
                //    }
                //}
                result.Data = items;
                var totalQty = result.Data.Sum(q => q.Item.QTY);
                var total = result.Data.Count;
                if (0 <= total && total < returnCount)
                {
                    result.Flag = Result.Flags.Warning;
                    result.LocaleMsg = new("WMS.WmsItem.Suggest.Warning", total);
                }
                //if (total == 0)
                //{
                //    result.Flag = Result.Flags.Failed;
                //    result.LocaleMsg = new("WMS.WmsItem.Suggest.Failed");
                //}
            }
            catch (Exception ex)
            {
                result.CatchExceptionWithLog(ex, Biz.L("WMS.WmsItem.Suggest.Exception"));
            }
            return result;
        }

        /// <summary>
        /// 下架物料推荐，按需求数量返回满足需求的物料库存列表
        /// </summary>
        /// <param name="order">领料单号</param>
        /// <param name="itemCode">物料编码</param>
        /// <param name="erpWH">物料的ERP库位</param>
        /// <param name="whID">物料所在的仓库编码</param>
        /// <param name="regionID">物料所在的储区编码</param>
        /// <param name="shelfID">物料所在的货架编码</param>
        /// <param name="option">授权查询选项</param>
        /// <param name="reqQty">需求数量，会返回满足需求的物料个数</param>
        /// <returns></returns>
        public Result<List<SuggestItem>> Suggest(string order, string itemCode, string erpWH, string whID, string regionID, string shelfID, AuthOption option, double reqQty)
        {
            var result = new Result<List<SuggestItem>>(Result.Flags.Success, new List<SuggestItem>()) { LocaleMsg = new("WMS.WmsItem.Suggest.Success") };
            try
            {
                var takeCount = 0;
                var checkSum = 0.0;
                var checkCount = 0;
                do
                {
                    takeCount += 50;
                    var check = Biz.Db.Queryable<WMS_ITEM, WMS_ITEM_POOL, WMS_WAREHOUSE, WMS_REGION, WMS_SHELF, WMS_LOCATION>((q, p, w, r, s, l) => new JoinQueryInfos(
                                                                JoinType.Left, q.SN == p.SN,
                                                                JoinType.Left, q.WH_ID == w.ID,
                                                                JoinType.Left, q.REGION_ID == r.ID,
                                                                JoinType.Left, q.SHELF_ID == s.ID,
                                                                JoinType.Left, q.LOCATION_ID == l.ID))
                                             //检查用户权限
                                             .ByAuth(option)
                                            //允许使用已经分配到库存池中的物料
                                            .Where((q, p, w, r, s, l) => SqlFunc.IsNullOrEmpty(p.ID) || (!SqlFunc.IsNullOrEmpty(order) && p.STATUS <= WMS_ITEM_POOL.STATUSs.WaitPick.GetValue() && p.TRANS_NO == order))
                                            //只允许未锁定的
                                            .Where((q, p, w, r, s, l) => q.IS_LOCKED == "N")
                                            //只允许物料状态是在库的
                                            .Where((q, p, w, r, s, l) => q.STATUS == WMS_ITEM.STATUSs.InStore.GetValue())
                                            //如果有传入料号，则只允该料号的物料
                                            .WhereIF(!itemCode.IsNullOrEmpty(), (q, p, w, r, s, l) => q.ITEM_CODE == itemCode)
                                            //如果有传入库位，则只允该库位中的物料
                                            .WhereIF(!erpWH.IsNullOrEmpty(), (q, p, w, r, s, l) => q.ERP_WH == erpWH && q.AUTH_ORG == option.CurOrg)
                                            //如果有传入仓库，则只允该仓库的物料
                                            .WhereIF(!whID.IsNullOrEmpty(), (q, p, w, r, s, l) => q.WH_ID == whID && q.AUTH_ORG == option.CurOrg)
                                            //如果有传入储区，则只允该储区的物料
                                            .WhereIF(!regionID.IsNullOrEmpty(), (q, p, w, r, s, l) => q.REGION_ID == regionID && q.AUTH_ORG == option.CurOrg)
                                            //如果有传入货架，则只允该货架的物料
                                            .WhereIF(!shelfID.IsNullOrEmpty(), (q, p, w, r, s, l) => q.SHELF_ID == shelfID && q.AUTH_ORG == option.CurOrg)
                                            //优先使用库存池中的物料
                                            .OrderBy((q, p, w, r, s, l) => SqlFunc.IsNullOrEmpty(p.ID))
                                            //优先使用尾数物料(截料或者退料之后的物料)
                                            .OrderByDescending((q, p, w, r, s, l) => q.SN.Contains("_C") || q.SN.Contains("_T"))
                                            //按生产日期先进先出，再按物料数量从小到大，最后按条码排序
                                            .OrderBy((q, p, w, r, s, l) => q.PROD_DATE).OrderBy(q => q.QTY).OrderBy(q => q.SN)
                                            .Select((q, p, w, r, s, l) => new
                                            {
                                                ItemCode = q.ITEM_CODE,
                                                Sn = q.SN,
                                                Qty = q.QTY
                                            })
                                            .Take(takeCount)
                                            .MergeTable()
                                            .GroupBy(t => t.ItemCode)
                                            .Select(t => new
                                            {
                                                Count = SqlFunc.AggregateCount(t.Sn),
                                                Sum = SqlFunc.AggregateSum(t.Qty),
                                            }).First();
                    if (!check.IsNullOrEmpty())
                    {
                        checkSum = check.Sum;
                        checkCount = check.Count;
                    }
                    else
                    {
                        checkSum = 0;
                        checkCount = 0;
                    }
                } while (checkSum < reqQty && checkCount >= takeCount);

                var items = Biz.Db.Queryable<WMS_ITEM, WMS_ITEM_POOL, WMS_WAREHOUSE, WMS_REGION, WMS_SHELF, WMS_LOCATION>((q, p, w, r, s, l) => new JoinQueryInfos(
                                                                JoinType.Left, q.SN == p.SN,
                                                                JoinType.Left, q.WH_ID == w.ID,
                                                                JoinType.Left, q.REGION_ID == r.ID,
                                                                JoinType.Left, q.SHELF_ID == s.ID,
                                                                JoinType.Left, q.LOCATION_ID == l.ID))
                                             //检查用户权限
                                             .ByAuth(option)
                                            //允许使用已经分配到库存池中的物料
                                            .Where((q, p, w, r, s, l) => SqlFunc.IsNullOrEmpty(p.ID) || (!SqlFunc.IsNullOrEmpty(order) && p.STATUS <= WMS_ITEM_POOL.STATUSs.WaitPick.GetValue() && p.TRANS_NO == order))
                                            //只允许未锁定的
                                            .Where((q, p, w, r, s, l) => q.IS_LOCKED == "N")
                                            //只允许物料状态是在库的
                                            .Where((q, p, w, r, s, l) => q.STATUS == WMS_ITEM.STATUSs.InStore.GetValue())
                                            //如果有传入料号，则只允该料号的物料
                                            .WhereIF(!itemCode.IsNullOrEmpty(), (q, p, w, r, s, l) => q.ITEM_CODE == itemCode)
                                            //如果有传入库位，则只允该库位中的物料
                                            .WhereIF(!erpWH.IsNullOrEmpty(), (q, p, w, r, s, l) => q.ERP_WH == erpWH && q.AUTH_ORG == option.CurOrg)
                                            //如果有传入仓库，则只允该仓库的物料
                                            .WhereIF(!whID.IsNullOrEmpty(), (q, p, w, r, s, l) => q.WH_ID == whID && q.AUTH_ORG == option.CurOrg)
                                            //如果有传入储区，则只允该储区的物料
                                            .WhereIF(!regionID.IsNullOrEmpty(), (q, p, w, r, s, l) => q.REGION_ID == regionID && q.AUTH_ORG == option.CurOrg)
                                            //如果有传入货架，则只允该货架的物料
                                            .WhereIF(!shelfID.IsNullOrEmpty(), (q, p, w, r, s, l) => q.SHELF_ID == shelfID && q.AUTH_ORG == option.CurOrg)
                                            //优先使用库存池中的物料
                                            .OrderBy((q, p, w, r, s, l) => SqlFunc.IsNullOrEmpty(p.ID))
                                            //优先使用尾数物料(截料或者退料之后的物料)
                                            .OrderByDescending((q, p, w, r, s, l) => q.SN.Contains("_C") || q.SN.Contains("_T"))
                                            //按生产日期先进先出，再按物料数量从小到大，最后按条码排序
                                            .OrderBy((q, p, w, r, s, l) => q.PROD_DATE).OrderBy(q => q.QTY).OrderBy(q => q.SN)
                                            .Select((q, p, w, r, s, l) => new SuggestItem
                                            {
                                                Item = q,
                                                poolItem = null,
                                                Warehouse = w,
                                                Region = r,
                                                Shelf = s,
                                                Location = l,
                                            })
                                            .Take(takeCount).ToList();
                var curQty = 0.0;
                foreach (var item in items)
                {
                    result.Data.Add(item);
                    curQty += item.Item.QTY;
                    if (curQty >= reqQty)
                    {
                        break;
                    }
                }

                var totalQty = result.Data.Sum(q => q.Item.QTY);
                var total = result.Data.Count;
                if (0 <= totalQty && totalQty < reqQty)
                {
                    result.Flag = Result.Flags.Warning;
                    result.LocaleMsg = new("WMS.WmsItem.Suggest.Warning", totalQty);
                }
                //if (totalQty == 0)
                //{
                //    result.Flag = Result.Flags.Failed;
                //    result.LocaleMsg = new("WMS.WmsItem.Suggest.Failed");
                //}
            }
            catch (Exception ex)
            {
                result.CatchExceptionWithLog(ex, Biz.L("WMS.WmsItem.Suggest.Exception"));
            }
            return result;
        }

        /// <summary>
        /// 下架
        /// </summary>
        /// <param name="option">授权查询选项</param>
        /// <param name="status">下架后状态</param>
        /// <param name="clearLocation">是否清理储区货架储位信息</param>
        /// <returns></returns>
        public Result TakeDown(AuthOption option, WMS_ITEM.STATUSs status)
        {
            return TakeDown(CurInvItem.Items.ToDictionary(k => k.SN, v => v.QTY), option, status);
        }

        /// <summary>
        /// 下架
        /// </summary>
        /// <param name="qtyList">要下架的最小包装数量字典，key：sn，value：qty</param>
        /// <param name="option">授权查询选项</param>
        /// <param name="status">下架后状态</param>
        /// <returns></returns>
        public Result TakeDown(Dictionary<string, double> qtyList, AuthOption option, WMS_ITEM.STATUSs status)
        {
            var result = new Result(Result.Flags.Success);
            try
            {
                //如果要下架的数量字典为空则认为是全部下架
                qtyList = qtyList.IsNullOrEmpty(CurInvItem.Items.ToDictionary(k => k.SN, v => v.QTY));

                foreach (var item in CurInvItem.Items)
                {
                    if (qtyList.ContainsKey(item.SN) && qtyList[item.SN] > 0)
                    {
                        var downQty = qtyList[item.SN];
                        if (item.QTY > downQty)
                        {
                            item.QTY -= downQty;
                            var pkg = CurInvItem.Packages.First(q => q.SN == item.SN);
                            pkg.QTY = item.QTY;
                        }
                        else
                        {
                            item.STATUS = status.GetValue();
                            item.CARTON_NO = null;
                            item.PALLET_NO = null;
                            var pkg = CurInvItem.Packages.First(q => q.SN == item.SN);
                            pkg.PARENT_SN = null;
                            pkg.Parent = null;
                            //如果下架数量等于库存数量则清理储区货架储位信息，否则保留仓库信息
                            //item.WH_ID = null;
                            item.REGION_ID = null;
                            item.SHELF_ID = null;
                            item.LOCATION_ID = null;
                            //pkg.WH_ID = null;
                            pkg.REGION_ID = null;
                            pkg.SHELF_ID = null;
                            pkg.LOCATION_ID = null;
                        }
                        CurInvItem.History.Add(new WMS_ITEM_HIS(item, $"条码[{CurInvItem.SN}]从储位[{CurInvItem?.Location?.LOCATION_CODE}]下架数量[{downQty}]成功，状态[{item.STATUS.GetEnumDesc<WMS_ITEM.STATUSs>()}]，操作单据[{item.TRANS_NO}]"));
                    }
                }
                CurInvItem.Packages = WMS_ITEM_PKG.UpdateQty(CurInvItem.Packages);

                //创建变量克隆对象用于传入DBSubmitAction中保存当前需要暂存的数据值
                var _Items = CurInvItem.Items.Clone();
                var _Packages = CurInvItem.Packages.Clone();
                var _History = CurInvItem.History.Clone();
                AddCommitAction("TakeDown", () =>
                {
                    //使用统一的事务DB对象
                    var db = GetCommitDB();
                    //数据保存逻辑
                    db.Updateable(_Items, UserCode).ExecuteCommand();
                    db.Insertable(_History, UserCode).ExecuteCommand();
                    db.Updateable(_Packages, UserCode).ExecuteCommand();
                });
            }
            catch (Exception ex)
            {
                result.CatchExceptionWithLog(ex, Biz.L("WMS.WmsItem.TakeDown.Exception", CurInvItem.SN, CurInvItem?.Location?.LOCATION_CODE));
            }
            return result;
        }

        /// <summary>
        /// 备料下架
        /// </summary>
        /// <param name="qtyList">要下架的最小包装数量字典，key：sn，value：qty</param>
        /// <param name="option">授权查询选项</param>
        /// <param name="status">下架后状态</param>
        /// <returns></returns>
        public Result TakeDown(List<BIZ_WMS_PREP_SN> snList, AuthOption option, WMS_ITEM.STATUSs status)
        {
            var result = new Result(Result.Flags.Success);
            try
            {
                foreach (var item in CurInvItem.Items)
                {
                    var sn = snList.First(q => q.SN == item.SN);
                    var pkg = CurInvItem.Packages.First(q => q.SN == item.SN);
                    //前端返回Y认为是截料发料，N认为是整盘发料
                    if (sn.QTY > sn.QTY_DLVY && sn.NEED_CUTTING == "Y")
                    {
                        CurInvItem.History.Add(new WMS_ITEM_HIS(item, $"条码[{item.SN}]截料发料，截料发出条码[{sn.DeliverySN}]数量[{sn.QTY_DLVY}]，保留在库条码[{sn.ReserveSN}]数量[{sn.QTY - sn.QTY_DLVY}]，操作单据[{item.TRANS_NO}]"));

                        item.SN = sn.ReserveSN;
                        item.QTY = sn.QTY - sn.QTY_DLVY;
                        pkg.SN = sn.ReserveSN;
                        pkg.QTY = sn.QTY - sn.QTY_DLVY;
                        CurInvItem.History.Add(new WMS_ITEM_HIS(item, $"条码[{item.SN}]截料发料后保留在库，原条码[{sn.SN}]数量[{sn.QTY}]，操作单据[{item.TRANS_NO}]"));

                        //创建截料发出的物料信息
                        var newItem = item.Clone();
                        newItem.ID = Guid.NewGuid().ToString();
                        newItem.SN = sn.DeliverySN;
                        newItem.STATUS = status.GetValue();
                        newItem.QTY = sn.QTY_DLVY;
                        newItem.CARTON_NO = null;
                        newItem.PALLET_NO = null;
                        newItem.REGION_ID = null;
                        newItem.SHELF_ID = null;
                        newItem.LOCATION_ID = null;
                        WMS_ITEM_HIS his = new(newItem, $"条码[{newItem.SN}]从储位[{CurInvItem?.Location?.LOCATION_CODE}]截料发料成功，发出数量[{newItem.QTY}]，状态[{newItem.STATUS.GetEnumDesc<WMS_ITEM.STATUSs>()}]，原条码[{sn.SN}]数量[{sn.QTY}]，操作单据[{item.TRANS_NO}]");

                        var newPkg = pkg.Clone();
                        newPkg.ID = Guid.NewGuid().ToString();
                        newPkg.PARENT_SN = null;
                        newPkg.Parent = null;
                        newPkg.REGION_ID = null;
                        newPkg.SHELF_ID = null;
                        newPkg.LOCATION_ID = null;

                        CurInvItem.ItemsExt.Add(new()
                        {
                            SN = newItem.SN,
                            META_SN = newItem.SN,
                        });

                        CurInvItem.Items.Add(newItem);
                        CurInvItem.History.Add(his);
                        CurInvItem.Packages.Add(newPkg);
                    }
                    else
                    {
                        item.STATUS = status.GetValue();
                        item.CARTON_NO = null;
                        item.PALLET_NO = null;
                        pkg.PARENT_SN = null;
                        pkg.Parent = null;
                        //如果下架数量等于库存数量则清理储区货架储位信息，否则保留仓库信息
                        //item.WH_ID = null;
                        item.REGION_ID = null;
                        item.SHELF_ID = null;
                        item.LOCATION_ID = null;
                        //pkg.WH_ID = null;
                        pkg.REGION_ID = null;
                        pkg.SHELF_ID = null;
                        pkg.LOCATION_ID = null;
                        CurInvItem.History.Add(new WMS_ITEM_HIS(item, $"条码[{CurInvItem.SN}]从储位[{CurInvItem?.Location?.LOCATION_CODE}]发料下架成功，状态[{item.STATUS.GetEnumDesc<WMS_ITEM.STATUSs>()}]，操作单据[{item.TRANS_NO}]"));
                    }
                }
                CurInvItem.Packages = WMS_ITEM_PKG.UpdateQty(CurInvItem.Packages);

                //创建变量克隆对象用于传入DBSubmitAction中保存当前需要暂存的数据值
                var _Items = CurInvItem.Items.Clone();
                var _Packages = CurInvItem.Packages.Clone();
                var _History = CurInvItem.History.Clone();
                var _ItemsExt = CurInvItem.ItemsExt.Clone();
                AddCommitAction("TakeDown", () =>
                {
                    //使用统一的事务DB对象
                    var db = GetCommitDB();
                    //数据保存逻辑
                    db.Storageable(_Items, UserCode).ExecuteCommand();
                    db.Insertable(_History, UserCode).ExecuteCommand();
                    db.Storageable(_Packages, UserCode).ExecuteCommand();
                    db.Storageable(_ItemsExt, UserCode).ToStorage().AsInsertable.ExecuteCommand();
                });
            }
            catch (Exception ex)
            {
                result.CatchExceptionWithLog(ex, Biz.L("WMS.WmsItem.TakeDown.Exception", CurInvItem.SN, CurInvItem?.Location?.LOCATION_CODE));
            }
            return result;
        }

        /// <summary>
        /// 设置当前条码的工序信息
        /// </summary>
        public ApiAction<ScanOutput> SetOutPutMqttMsg(ApiAction<ScanOutput> action, string locale = null)
        {
            MQTT.Message msg = new()
            {
                IsSuccessed = action.IsSuccessed,
                Content = Biz.T(action.LocaleMsg, locale),
            };
            switch (action.Status)
            {
                case ApiAction.StatusCodes.Success:
                    msg.Voice = MQTT.Voice.Success;
                    msg.Color = "#FF1E90FF";
                    break;
                case ApiAction.StatusCodes.Warning:
                    msg.Voice = MQTT.Voice.Warning;
                    msg.Color = "#FFB8860B";
                    break;
                case ApiAction.StatusCodes.Error:
                case ApiAction.StatusCodes.Failed:
                    msg.Voice = MQTT.Voice.Fail;
                    msg.Color = "#FFFF0000";
                    break;
                case ApiAction.StatusCodes.Exception:
                    msg.Voice = MQTT.Voice.Fail;
                    msg.Color = "#FF8B0000";
                    break;
                case ApiAction.StatusCodes.Normal:
                case ApiAction.StatusCodes.NeedConfrim:
                case ApiAction.StatusCodes.Confrimed:
                default:
                    msg.Voice = MQTT.Voice.Silent;
                    msg.Color = "#FF000000";
                    break;
            }
            if (action.IsSuccessed)
            {
                msg.Voice = MQTT.Voice.Pass;
                msg.Color = "#FF228B22";
            }
            else if (!action.IsSuccessed)
            {
                msg.Voice = MQTT.Voice.Fail;
                msg.Color = "#FFFF0000";
            }
            else
            {
                msg.Voice = MQTT.Voice.Silent;
                msg.Color = "#FF000000";
            }
            action.Data.MqttMsg = msg;
            return action;
        }
        #endregion Functions

        /// <summary>
        /// 重置本次扫码信息
        /// </summary>
        public virtual void ResetScan()
        {
            //清理暂存数据提交操作
            DBCommitList.Clear();
        }

        public override bool Close(bool needSaveHistoryLog = false)
        {
            //needSaveHistoryLog = true;
            //保存操作日志

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