using Rhea.Common;
using Microsoft.AspNetCore.Http;
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.IBusiness;

namespace Tiger.Business.WMS.Transaction
{
    /// <summary>
    /// 客供料入库清点事务
    /// </summary>
    public class OutNoBillcode : WMSTransactionBase, IOutNoBillcode
    {
        public IOutNoBillcode Init(string id, string userCode, string apiHost, string orgCode)
        {
            TransID = id;
            UserCode = userCode;
            ApiHost = apiHost;
            OrgCode = orgCode;
            Result ruleResult = Biz.CodeRule["NB001"].Generate("NB");  //iWMS.GetBillNoByType("CI");
            if (!ruleResult.IsSuccessed)
            {
                throw new Exception(ruleResult.ExceptionMsg.Message);
            }
            BillCode = ruleResult.Data.ToString();
            NoBillcodeHeader = new()
            {
                CREATE_TIME = DateTime.Now,
                CREATE_USER = userCode,
                UPDATE_USER = userCode,
                BILLCODE = BillCode,
                AUTH_ORG = orgCode,
                STATUS = BIZ_ERP_OTH_OUT.STATUSs.WORKING.GetValue()
            };
            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 RackCode { get; set; }
        public string WarehouseCode { get; set; }
        public string WarehouseName { get; set; }
        /// <summary>
        /// 单据代码
        /// </summary>
        public string BillCode { get; set; }
        public Inventory CurInv { get; set; }
        public BIZ_ERP_OTH_OUT NoBillcodeHeader { get; set; }
        public List<BIZ_ERP_OTH_OUT_DTL> NoBillcodeDtl { get; set; }//单据明细
        //public List<BIZ_ERP_OTH_OUT_SN> NoBillcodeSN { get; set; }//单据扫描的条码进行保存
        public string OrgCode { get; set; }
        public WMS_SHELF Shelf { get; set; }

        public Model.Minsun.CustomerSupplyPuton CustomerSupplyPuton { get; set; }
        #endregion

        #region Functions
        /// <summary>
        /// 扫描物料并复核，如果物料已经完成移库则货架上亮灯提醒储位
        /// </summary>
        public async Task<ApiAction<NoWorkOrderOutput>> ScanItem(BaseInput input)
        {
            var action = new ApiAction<NoWorkOrderOutput>();
            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;
                }
                //创建单据
                NoBillcodeHeader.STATUS = BIZ_ERP_OTH_OUT.STATUSs.COMPLETE.GetValue();//扫完单据就为完成
                BIZ_ERP_OTH_OUT_SN NoBillcodeSn = new()
                {
                    CREATE_USER = input.AuthOption.UserId,
                    CREATE_TIME = DateTime.Now,
                    AUTH_ORG = input.AuthOption.OrgCode,
                    ORDER_NO = BillCode,
                    SN = CurInv.SN,
                    META_SN = CurInv.Barcode.MetaSn,
                    ITEM_CODE = CurInv.ItemInfo.ITEM_CODE,
                    STATUS = WMS_ITEM.STATUSs.OffShelf.GetValue(),
                    LOCATION_CODE=CurInv.Location.LOCATION_CODE,
                    ERP_WH=CurInv.Warehouse.WH_CODE,
                    ALLOC_QTY=CurInv.CurPkg.QTY,
                    LOAD_SEQ=0,
                    NEED_CUTTING="N"
                };
                NoBillcodeDtl = new List<BIZ_ERP_OTH_OUT_DTL>();
                //首次直接新增数据
                if (NoBillcodeDtl.Count > 0)
                {
                   //查询这个料号是否存在明细，存在就修改数量，不存在添加一条新数据
                   var noBillcode = NoBillcodeDtl.Where(q => q.ITEM_CODE == CurInv.ItemInfo.ITEM_CODE).FirstOrDefault();
                   if (noBillcode.IsNullOrEmpty()) 
                   {
                        BIZ_ERP_OTH_OUT_DTL dtl = new()
                        {
                            CREATE_USER = input.AuthOption.UserId,
                            CREATE_TIME = DateTime.Now,
                            AUTH_ORG = input.AuthOption.OrgCode,
                            BILLCODE = BillCode,
                            BILLLINE=(int.Parse(NoBillcodeDtl.Max(q => q.BILLLINE))+1).ToString(),
                            LINESTATUS=BIZ_ERP_OTH_OUT.STATUSs.COMPLETE.GetValue(),
                            ITEM_CODE=CurInv.ItemInfo.ITEM_CODE,
                            UNITCODE=CurInv.CurPkg.UNIT,
                            PRQTY=CurInv.CurPkg.QTY,
                            QTY=CurInv.CurPkg.QTY,
                            WAREHOUSECODE=CurInv.Warehouse.WH_CODE
                        };
                        NoBillcodeDtl.Add(dtl);
                   }
                   else
                   {
                        noBillcode.QTY += CurInv.CurPkg.QTY;
                   }
                }
                else
                {
                    BIZ_ERP_OTH_OUT_DTL dtl = new() 
                    {
                        CREATE_USER = input.AuthOption.UserId,
                        CREATE_TIME = DateTime.Now,
                        AUTH_ORG = input.AuthOption.OrgCode,
                        BILLCODE = BillCode,
                        BILLLINE = "1",
                        LINESTATUS = BIZ_ERP_OTH_OUT.STATUSs.COMPLETE.GetValue(),
                        ITEM_CODE = CurInv.ItemInfo.ITEM_CODE,
                        UNITCODE = CurInv.CurPkg.UNIT,
                        PRQTY = CurInv.CurPkg.QTY,
                        QTY = CurInv.CurPkg.QTY,
                        WAREHOUSECODE = CurInv.Warehouse.WH_CODE
                    };
                    NoBillcodeDtl.Add(dtl);
                }
                //处理库存和包装
                CurInv.CurPkg.REGION_ID = "";
                CurInv.CurPkg.SHELF_ID = "";
                CurInv.CurPkg.LOCATION_ID = "";
                CurInv.Items[0].REGION_ID = "";
                CurInv.Items[0].SHELF_ID = "";
                CurInv.Items[0].LOCATION_ID = "";
                CurInv.Items[0].TRANS_CODE = "No Billcode Out";
                CurInv.Items[0].TRANS_NO = BillCode;
                CurInv.Items[0].STATUS = WMS_ITEM.STATUSs.OffShelf.GetValue();
                WMS_ITEM_HIS his = new WMS_ITEM_HIS(CurInv.Items[0], $"无工单出库");

                CurInv.History.Add(his);
                //灭灯
                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);
                }
                action.Message = "无工单出库成功";
                //保存数据库
                var db = Business.Biz.Db;
                var dbTran = db.UseTran(() =>
                {
                    //出库
                   
                    db.Updateable(CurInv.Items, UserCode).ExecuteCommand();
                    db.Updateable(CurInv.CurPkg, UserCode).ExecuteCommand();
                    db.Insertable(CurInv.History, UserCode).ExecuteCommand();

                    db.Insertable(NoBillcodeHeader, UserCode).ExecuteCommand();
                    db.Insertable(NoBillcodeDtl, UserCode).ExecuteCommand();
                    db.Insertable(NoBillcodeSn, UserCode).ExecuteCommand();


                });
                if (!dbTran.IsSuccess)
                {
                    throw dbTran.ErrorException;
                }

                action.Data = new NoWorkOrderOutput()
                {
                    SN = CurInv.SN,
                    ItemCode = CurInv.ItemInfo.ITEM_CODE,
                    MaterialName=CurInv.ItemInfo.ITEM_NAME,
                    Qty = CurInv.CurPkg.QTY,
                    //CutQty = CurInv.CurPkg.QTY - cutQty,
                    //isCutting = _isCutting,
                    //isExceed = _isExceed,
                    ReqNo = BillCode,
                    Unit=CurInv.CurPkg.UNIT,
                    regionCode = CurInv.Region.REGION_CODE,
                    locationCode = CurInv.Location?.LOCATION_CODE,
                    DateCode = CurInv.Items[0].PROD_DATE,
                    ScanAfCut = CurInv.Warehouse.SCAN_AF_CUT
                };
            }
            catch (Exception ex)
            {
                action.CatchExceptionWithLog(ex, $"扫描物料[{input.SN}]复核异常");
            }
            return action;
        }

        /// <summary>
        /// 扫描货架或者储位
        /// </summary>
        public async Task<ApiAction<Model.Minsun.CustomerSupplyPuton>> ScanShelf(string Code)
        {
            var action = new ApiAction<Model.Minsun.CustomerSupplyPuton>();
            try
            {
                if (Code.IsNullOrEmpty())
                {
                    action.IsSuccessed = false;
                    action.LocaleMsg = Biz.L("WMS.CustSupChk.ScanItem.ShelfCanNotEmpty");
                    return action;
                }

                CustomerSupplyPuton = new Model.Minsun.CustomerSupplyPuton();

                // 查询货架信息
                var whUnit = await Biz.Db.Queryable<V_WH_UNIT>().Where(t => t.SHELF_CODE.ToUpper() == Code.ToUpper() && t.AUTH_ORG == OrgCode).IncludesAllFirstLayer().FirstAsync();

                // 扫描货架代码，且为智能货架
                if (whUnit != null && whUnit.SHELF_TYPE == WMS_SHELF.SHELF_TYPEs.Smart.GetValue())
                {
                    WarehouseName = whUnit.WH_NAME;
                    CustomerSupplyPuton.WarehouseCode = whUnit.WH_CODE;
                    CustomerSupplyPuton.RackCode = whUnit.SHELF_CODE;
                    CustomerSupplyPuton.ShelfType = whUnit.SHELF_TYPE;
                    CustomerSupplyPuton.IsSmartRack = true;
                    Shelf = whUnit.Shelf;
                }
                // 扫描库位代码
                else
                {
                    var nLocation = await Biz.Db.Queryable<V_WH_UNIT>().Where(t => t.LOCATION_CODE.ToUpper() == Code.ToUpper() && t.AUTH_ORG == OrgCode).FirstAsync();
                    WarehouseName = nLocation.WH_NAME;
                    if (nLocation == null)
                    {
                        action.IsSuccessed = false;
                        action.LocaleMsg = Biz.L("WMS.CustSupChk.ScanItem.NotExist", Code);
                        return action;
                    }

                    if (nLocation.IS_ACTIVE == "N")
                    {
                        action.IsSuccessed = false;
                        action.LocaleMsg = Biz.L("WMS.CustSupChk.ScanItem.ShelfOrLocationDisabled");
                        return action;
                    }
                    if (nLocation.SHELF_TYPE == WMS_SHELF.SHELF_TYPEs.Smart.GetValue() || nLocation.SHELF_TYPE == WMS_SHELF.SHELF_TYPEs.QRCode.GetValue())
                    {
                        var locationData = Biz.Db.Queryable<WMS_ITEM>().Where(q => q.LOCATION_ID == nLocation.LOCATION_ID && q.AUTH_ORG == OrgCode).First();
                        if (!locationData.IsNullOrEmpty())
                        {
                            action.IsSuccessed = false;
                            action.LocaleMsg = Biz.L($"系统当前库位存在料盘，请检查系统库存信息");
                            return action;

                        }
                    }

                    CustomerSupplyPuton.LocationCode = nLocation.LOCATION_CODE;
                    CustomerSupplyPuton.WarehouseCode = nLocation.WH_CODE;
                    //CustomerSupplyPuton.Capacity = nLocation.MAXSIZE - nUsedCapacity;
                    //CustomerSupplyPuton.LotCount = nLocation.LOTCOUNT;
                    //CustomerSupplyPuton.MaxSize = nLocation.MAXSIZE;
                    CustomerSupplyPuton.IsSmartRack = false;
                    CustomerSupplyPuton.RackCode = nLocation.SHELF_CODE;
                }

                WarehouseCode = CustomerSupplyPuton.WarehouseCode;
                RackCode = CustomerSupplyPuton.RackCode;
                CustomerSupplyPuton.IsScanShelf = true;
                action.LocaleMsg = Biz.L("扫描货架或储位成功");
                action.Data = CustomerSupplyPuton;
            }
            catch (Exception ex)
            {
                //取消当前操作

                action.CatchExceptionWithLog(ex, $"扫描货架或者储位[{Code}]异常");
            }
            return action;
        }

        #endregion

        public override bool Close(bool needSaveHistoryLog = false)
        {
            this.IsFinished = true;
            return IsFinished ? base.Close(needSaveHistoryLog) : IsFinished;
        }

    }//endClass
}