using Rhea.Common;
using Tiger.IBusiness;
using SqlSugar;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Linq.Expressions;
using System.Text;
using System.Threading;
using System.Threading.Tasks;
using Tiger.Model;
using Tiger.Model.Sharetronic.Shelf;
using System.ComponentModel;
using Tiger.Model.Entitys.MES.U9C;
using ProdInBatch = Tiger.Model.ProdInBatch;
using Org.BouncyCastle.Ocsp;
using Tiger.Model.Entitys.MES.BizPrintInstoreDoc;
using System.Drawing.Printing;
using Tiger.Model.Entitys.MES.Position;

namespace Tiger.Business.MES.Transaction
{
    /// <summary>
    /// 入库单事务
    /// </summary>
    public class InStoreOrderNo : MESTransactionBase, IInStoreOrderNo
    {
        private readonly IMES_U9C _IMES_U9C = DI.Resolve<IMES_U9C>();
        private readonly IBIZ_MES_WO _IBIZ_MES_WO = DI.Resolve<IBIZ_MES_WO>();
        public IInStoreOrderNo Init(string id, string apiHost, InstoreDocInput input)
        {
            TransID = id;
            UserCode = input.UserCode;
            ApiHost = apiHost;
            OrgCode = input.OrgCode;
            pageSize = input.pageSize;
            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 string CurSN { get; set; }
        public int pageSize { get; set; }
        public RcvRptDocCreateInput RcvRptInput { get; set; } = new RcvRptDocCreateInput();
        public List<ProdInBatch> ProdInBatchs { get; set; } = new List<ProdInBatch>();
        public List<BIZ_ERP_PROD_IN_BTH> ErpProdInBths { get; set; } = new List<BIZ_ERP_PROD_IN_BTH>();
        /// <summary>
        /// 扫描列表 
        /// </summary>
        public List<InStoreScanInfo> InStoreScanInfos { get; set; } = new List<InStoreScanInfo>();
        public List<BIZ_ERP_PROD_IN_SN> ErpProdInSns { get; set; } = new List<BIZ_ERP_PROD_IN_SN>();

        #endregion Propertys & Variables

        #region Functions

        /// <summary>
        /// 扫描条码
        /// </summary>
        /// <param name="code"></param>
        /// <returns></returns>
        public async Task<ApiAction<InStoreInfos>> Submit(string code)
        {
            var action = new ApiAction<InStoreInfos>();
            try
            {
                if (code.IsNullOrEmpty())
                {
                    action.IsSuccessed = false;
                    action.LocaleMsg = Biz.L($"条码不能为空");
                    return action;
                }
                var apiAction = await _IBIZ_MES_WO.GetErpProdInBth(code);
                if (!apiAction.IsSuccessed)
                {
                    return action;
                }
                CurSN = code.Split('|')[0];
                InStoreInfo Info = apiAction.Data;
                //要存入的批次入库单数据 
                int n = InStoreScanInfos.Where(q => q.WORK_ORDER == Info.ErpProdInBth.WORK_ORDER).Count();
                if (!ErpProdInBths.Any(q => q.WORK_ORDER == Info.ErpProdInBth.WORK_ORDER))
                {
                    Info.ErpProdInBth.AUTH_ORG = OrgCode;
                    Info.ErpProdInBth.CREATE_USER = UserCode;
                    Info.ErpProdInBth.CREATE_TIME = DateTime.Now;
                    Info.ErpProdInBth.SCANED_DATE = DateTime.Now;
                    Info.ErpProdInBth.HANDLED_DATE = DateTime.Now;
                    Info.ErpProdInBth.IS_SCANED = "Y";
                    Info.ErpProdInBth.ORDER_NO = UserCode;
                    Info.ErpProdInBth.IS_HANDLED = "N";
                    Info.ErpProdInBth.CartonQty = n == 0 ? 1 : n;
                    ErpProdInBths.Add(Info.ErpProdInBth);
                }
                else
                {
                    if (!InStoreScanInfos.Any(q => q.WORK_ORDER == Info?.ErpProdInBth.WORK_ORDER && q.SN == CurSN))
                    {
                        var erpbth = ErpProdInBths.Where(q => q.WORK_ORDER == Info.ErpProdInBth.WORK_ORDER).FirstOrDefault();
                        if (!erpbth.IsNullOrEmpty())
                        {
                            erpbth.SCAN_QTY += Info.InStoreScanInfo.SCAN_QTY.ToDouble();
                            Info.ErpProdInBth.CartonQty++;
                        }
                    }
                }

                //生成打印实体
                if (RcvRptInput.PrintJsons.Count == 0)
                {
                    RcvRptInput.PrintJsons.Add(new()
                    {
                        ID = Guid.NewGuid().ToString("N"),
                        Items = new() {
                            Info.ErpProdInBth
                        }
                    });
                }
                else
                {
                    //拼分页
                    bool isAdded = false;
                    foreach (var item in RcvRptInput.PrintJsons)
                    {
                        if (!item.Items.Any(q => q.WORK_ORDER == Info.ErpProdInBth.WORK_ORDER))
                        {
                            if (item.Items.Count < pageSize)
                            {
                                item.Items.Add(Info.ErpProdInBth);
                                isAdded = true;
                            }
                        }
                        else
                        {
                            isAdded = true;
                        }
                    }
                    if (isAdded)
                    {
                        RcvRptInput.PrintJsons.Add(new()
                        {
                            ID = Guid.NewGuid().ToString("N"),
                            Items = new() {
                            Info.ErpProdInBth
                        }
                        });
                    }
                }

                //暂存扫码数据
                if (!InStoreScanInfos.Any(q => q.WORK_ORDER == Info?.ErpProdInBth.WORK_ORDER && q.SN == CurSN))
                {
                    InStoreScanInfos.Add(Info.InStoreScanInfo);
                }
                var wipPkgs = Biz.Db.Ado.UseStoredProcedure().SqlQuery<MES_WIP_PKG>("SP_MES_GET_ITEM_PKG", new SugarParameter("root", CurSN));
                int maxLevel = wipPkgs.Max(p => p.LEVEL);
                foreach (var item in wipPkgs.Where(q=> q.LEVEL == maxLevel))
                {
                    var scanResult = new BIZ_ERP_PROD_IN_SN
                    {
                        ID = Guid.NewGuid().ToString(),
                        CARTONNO = CurSN,
                        SN = item.SN,
                        BUSINESSCODE = UserCode,
                        ITEM_CODE = item.ITEM_CODE,
                        Qty = item.QTY.ToDecimal(),
                        SOURCECODE = Info?.ErpProdInBth.WORK_ORDER,
                        STATUS = WMS_ITEM.STATUSs.Counted.GetValue(),
                        CREATE_USER = UserCode,
                        CREATE_TIME = DateTime.Now,
                        UPDATE_USER = UserCode,
                        UPDATE_TIME = DateTime.Now,
                    };
                    ErpProdInSns.Add(scanResult);
                }

                //保存数据库
                var db = Business.Biz.Db;
                var dbTran = db.UseTran(() =>
                {
                    var x = db.Storageable(ErpProdInBths, $"InStoreOrderNo_{UserCode}")
                             .WhereColumns(t => new { t.ORDER_NO, t.WORK_ORDER, t.GHOST_ROW })
                             .ToStorage();
                    x.AsInsertable.ExecuteCommand();
                    x.AsUpdateable.IgnoreColumns(x => x.ID).ExecuteCommand();

                    var s = db.Storageable(ErpProdInSns, $"InStoreOrderNo_{UserCode}")
                                .WhereColumns(t => new { t.CARTONNO, t.SN, t.GHOST_ROW })
                                .ToStorage();
                    s.AsInsertable.ExecuteCommand();
                    s.AsUpdateable.IgnoreColumns(x => x.ID).ExecuteCommand();
                });
                if (!dbTran.IsSuccess)
                {
                    Logger.Default.Fatal(dbTran.ErrorException, "Database transaction save exception");
                    this.Close(!dbTran.IsSuccess);
                    throw dbTran.ErrorException;
                }
                action.Data = new() { 
                    ErpProdInBths = ErpProdInBths,
                    InStoreScanInfos = InStoreScanInfos,
                };
            }
            catch (Exception ex)
            {
                action.CatchExceptionWithLog(ex, $"扫描条码[{code}]复核异常");
            }
            return action;
        }

        /// <summary>
        /// 调用U9C接口生成入库单
        /// </summary>
        /// <param name="code"></param>
        /// <returns></returns>
        public async Task<ApiAction<RcvRptDocCreateInput>> GenerateInStoreOrder(RcvRptDocCreateInput input)
        {
            var action = new ApiAction<RcvRptDocCreateInput>();
            try
            {
                //input.RcvRptDocBases = new()
                //{
                //    new(){
                //    WorkOrder = item.WORK_ORDER,
                //    ItemCode = item.ITEM_CODE,
                //    WhCode = "10105",
                //    PkgQty = item.SCAN_QTY,
                //    CompleteQty = item.SCAN_QTY,
                //    OutputType = 0,
                //    StorageType = 4,
                //    DocState = 1,
                //    Status = "N"
                //    }
                //};
                action = await _IMES_U9C.RcvRptDocCreate(input);

                //保存数据库
                var db = Business.Biz.Db;
                var dbTran = db.UseTran(() =>
                {
                    //var x = db.Storageable(ErpProdInBths, $"InStoreOrderNo_{UserCode}")
                    //         .WhereColumns(t => new { t.ORDER_NO, t.WORK_ORDER, t.GHOST_ROW })
                    //         .ToStorage();
                    //x.AsInsertable.ExecuteCommand();
                    //x.AsUpdateable.IgnoreColumns(x => x.ID).ExecuteCommand();

                    //var s = db.Storageable(ErpProdInSns, $"InStoreOrderNo_{UserCode}")
                    //            .WhereColumns(t => new { t.CARTONNO, t.SN, t.GHOST_ROW })
                    //            .ToStorage();
                    //s.AsInsertable.ExecuteCommand();
                    //s.AsUpdateable.IgnoreColumns(x => x.ID).ExecuteCommand();
                });
                if (!dbTran.IsSuccess)
                {
                    Logger.Default.Fatal(dbTran.ErrorException, "Database transaction save exception");
                    this.Close(!dbTran.IsSuccess);
                    throw dbTran.ErrorException;
                }

            }
            catch (Exception ex)
            {
                action.CatchExceptionWithLog(ex, $"调用U9C接口生成入库单异常");
            }
            return action;
        }

        /// <summary>
        /// 查询对应的条码
        /// </summary>
        /// <returns></returns>
        public async Task<ApiAction<RcvRptDocCreateInput>> GetScannedBarcodes()
        {
            var action = new ApiAction<RcvRptDocCreateInput>();
            try
            {
                //var query = await Biz.Db.Queryable<BIZ_ERP_RECEIPT_SN, BAS_ITEM>((t, m) =>
                //                        new JoinQueryInfos(
                //                            JoinType.Left, t.ITEM_CODE == m.ITEM_CODE
                //                            ))
                //    .Where((t, m) => t.CREATE_USER == UserCode
                //        //&& t.WAREHOUSECODE.ToUpper() == WarehouseCode.ToUpper()
                //        && t.STATUS == WMS_ITEM.STATUSs.Counted.GetValue()
                //        && t.ITEM_CODE.ToUpper() == MaterialCode.ToUpper()
                //        && t.BILLCODE == UserCode
                //        && t.AUTH_ORG == OrgCode)
                //    .Select((t, m) => new Model.Minsun.CustSupplyCheckDetail
                //    {
                //        Barcode = t.SN,
                //        BarcodeQty = t.SCANQTY,
                //        Unit = m.UNIT
                //    })
                //    .ToListAsync();
            }
            catch (Exception ex)
            {
                action.CatchExceptionWithLog(ex, $"查询对应的条码异常");
            }
            return action;
        }

        #endregion Functions

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

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