using Rhea.Common;
using Tiger.Model.Minsun;
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 Apache.NMS;
using System.Drawing.Drawing2D;
using Tiger.Model.Sharetronic.Shelf;
using Tiger.IBusiness;

namespace Tiger.Business.WMS.Transaction
{
    /// <summary>
    /// 生产领料事务
    /// </summary>
    public class ItemQuery : WMSTransactionBase, IItemQuery
    {
        public IItemQuery 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<V_WMS_ITEM> Vitem { get; set; } = new();
        public List<WMS_ITEM_POOL> CurPoolList => Suggests.Where(q => !q.poolItem.IsNullOrEmpty()).Select(q => q.poolItem).ToList();
        public Inventory CurInv { get; set; }
        public BIZ_ERP_PROD_OUT req { get; set; }
        public ReqType CurReqType { get; set; }
        public List<BIZ_ERP_PROD_OUT_DTL> dtls { get; set; } = new();
        public bool isExceed { get; set; }
        public ProductionPickToMes toMes { get; set; }
        public bool his_isComplete { get; set; }
        public bool isCutting { get; set; }
        public decimal cutQty { get; set; }

        public BIZ_WMS_TRANSFER transferH = null;
        public BIZ_WMS_TRANSFER cTransferH = null;
        public BIZ_WMS_TRANSFER_DTL transferDtl = null;
        public BIZ_WMS_TRANSFER_SN transferSn = null;
        #endregion

        #region Functions

        /// <summary>
        /// 物料汇总查询
        /// </summary>
        /// <param name="input"></param>
        /// <returns></returns>
        public QueryItemView QueryItemSum(QueryItemInput input)
        {
            var barcode = new Barcode(input.SN);
            var ItemCode = Biz.Db.Queryable<WMS_ITEM_PKG>().ByAuth(input.AuthOption).Where(q => q.SN == barcode.SN).First()?.ITEM_CODE ??
                                     (input.IsK.IsNullOrEmpty() ? input.SN : ((((bool)input.IsK && !barcode.ItemCode.IsNullOrEmpty(input.SN).StartsWith("K")) ? "K" : "") + barcode.ItemCode.IsNullOrEmpty(input.SN)));
            //Suggests[0].Item.ITEM_CODE = ItemCode;
            var itemInfo = Biz.Db.Queryable<BAS_ITEM>().Where(q => q.ITEM_CODE == ItemCode).First();
            if (!itemInfo.IsNullOrEmpty())
            {
                var sumInfo = Biz.Db.Queryable<V_WMS_ITEM>().Where(q => q.ITEM_CODE == ItemCode && q.STATUS == WMS_ITEM.STATUSs.InStore.GetValue())
                                  .ByAuth(input.AuthOption).GroupBy(q => new { q.WH_CODE, q.ITEM_CODE }).Select(q => new { WH_CODE = q.WH_CODE, SumQty = SqlFunc.AggregateSum(q.QTY) }).ToList();
                var items = Biz.Db.Queryable<V_WMS_ITEM>().Where(q => q.ITEM_CODE == ItemCode && q.STATUS == WMS_ITEM.STATUSs.InStore.GetValue())
                                  .ByAuth(input.AuthOption).ToList();
                QueryItemView view = new() {
                    ItemCode = ItemCode,
                    ItemName = itemInfo?.ITEM_NAME, 
                    SumInfo = $"{string.Join("\r\n", sumInfo.Select(q => $"{q.WH_CODE} 总库存: {(double)q.SumQty} 盘数:{items.Count}"))}" 
                };
                Vitem = items;
                return view;
            }
            else
            {
                throw new Exception("物料编码不存在");
            }
        }
        /// <summary>
        /// 物料汇总明细查询
        /// </summary>
        /// <param name="input"></param>
        /// <returns></returns>
        public ApiAction<PageAble<V_WMS_ITEM>> GetQueryItemSumDtl(BasePageInput input)
        {
            var action = new ApiAction<PageAble<V_WMS_ITEM>>();
            //var query = Biz.Db.Queryable<V_WMS_ITEM>().ByAuth(input.AuthOption).Where(q => q.ITEM_CODE == Vitem.Select(q=>q.ITEM_CODE).FirstOrDefault()&&q.STATUS==WMS_ITEM.STATUSs.InStore.GetValue()).OrderByDescending(o=>o.LOCATION_CODE).ToPage(input.pageIndex, input.pageSize);
            action.Data = new PageAble<V_WMS_ITEM>();
            action.Data.pageSize = input.pageSize;
            action.Data.pageIndex=input.pageIndex;
            action.Data.totals = Vitem.Count;
            action.Data.data = Vitem.Skip((input.pageIndex-1)*input.pageSize).Take(input.pageSize).ToList();
            //action.Data = query;
            return action;
        }

        /// <summary>
        /// 领料单推荐所有物料亮灯
        /// </summary>
        /// <param name="light"></param>
        /// <returns></returns>
        public async Task<ApiAction<ProdReqOutput>> LightAll(LightEntityInput light)
        {
            var action = new ApiAction<ProdReqOutput>();
            try
            {
                  light.Color= light.Color == LedColor.NoColor ? LedColor.Blue : light.Color;
                   var  list = Vitem.Where(q => q.SHELF_TYPE == WMS_SHELF.SHELF_TYPEs.Smart.GetValue() || q.SHELF_TYPE == WMS_SHELF.SHELF_TYPEs.QRCode.GetValue());
                    if (list.Any())
                    {
                    foreach (var item in Vitem.Select(s=>s.SHELF_CODE).Distinct())
                    {
                        await Share.Shelf.LightMulti(TransID, light.Color,item, list.Where(q=>q.SHELF_CODE==item).Select(x => x.LEDID).ToList());
                        action.LocaleMsg = Biz.L("亮灯成功，亮灯颜色[{0}]", light.Color.GetDesc()); 
                    }
                    }
                    else
                    {
                        action.LocaleMsg = Biz.L($"无需亮灯，推荐的物料不在智能货架上");
                    }
            }
            catch (Exception ex)
            {
                action.CatchExceptionWithLog(ex, $"亮灯异常");
            }
            return action;
        }


        /// <summary>
        /// 灭灯
        /// </summary>
        /// <returns></returns>
        public async Task<ApiAction> CloseLight()
        {
            var action = new ApiAction();
            try
            {
                //灭灯
                var list = Vitem.Where(q => q.SHELF_TYPE == WMS_SHELF.SHELF_TYPEs.Smart.GetValue() || q.SHELF_TYPE == WMS_SHELF.SHELF_TYPEs.QRCode.GetValue());
                if (list.Any())
                {
                    foreach (var item in Vitem.Select(s => s.SHELF_CODE).Distinct())
                    {
                        await Share.Shelf.DownMulti(TransID, item, list.Where(q => q.SHELF_CODE == item).Select(x => x.LEDID).ToList());
                        action.LocaleMsg = Biz.L("灭灯成功");
                    }
                }
            }
            catch (Exception ex)
            {
                action.CatchExceptionWithLog(ex, $"亮灯异常");
            }
            return action;
        }

        #endregion

        public override bool Close(bool needSaveHistoryLog = false)
        {
            needSaveHistoryLog = true;
            CloseLight().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
}