using Newtonsoft.Json.Linq;
using Rhea.Common;
using SqlSugar;
using System;
using System.Collections.Generic;
using System.ComponentModel.DataAnnotations;
using System.Data;
using System.Data.Entity;
using System.Linq;
using System.Text;
using System.Threading;
using System.Threading.Tasks;
using Tiger.IBusiness;
using Tiger.Model;

namespace Tiger.Business.DbCache
{
    /// <summary>
    /// 条码规则数据库数据缓存
    /// </summary>
    public class CodeRuleCache : ICodeRuleCache
    {
        #region Variables
        private WhileThread AutoUpdateThread;
        private DateTime LastUpdateTime = DateTime.MinValue;
        #endregion

        #region Propertys
        public string Id { get; set; } = Guid.NewGuid().ToString("N");
        public string Tag { get; set; } = "CodeRuleCache";
        public string Name { get; set; } = "CodeRuleCache";
        public bool IsRunning { get; set; }
        private List<BAS_CODE_RULE> _Rules = new();
        public List<BAS_CODE_RULE> Rules { get { Update(); return _Rules; } set => _Rules = value; }
        public BAS_CODE_RULE this[string ruleCode] { get { Update(); return _Rules.FirstOrDefault(q => q.RULE_CODE == ruleCode); } }
        #endregion

        #region Functions
        /// <summary>
        /// 启动自动更新缓存
        /// </summary>
        public void Start()
        {
            try
            {
                AutoUpdateThread = new(AutoUpdate);
                AutoUpdateThread.Start();
                Logger.Default.Info("Start CodeRule Cache Auto Update Thread");
            }
            catch (System.Exception ex)
            {
                Logger.Default.Fatal(ex, "Start CodeRule Cache Auto Update Thread Exception");
            }
        }

        /// <summary>
        /// 关闭自动更新缓存
        /// </summary>
        public void Stop()
        {
            try
            {
                AutoUpdateThread?.Stop();
                Logger.Console.Info("Stop CodeRule Cache Auto Update Thread");
            }
            catch (System.Exception ex)
            {
                Logger.Console.Fatal(ex, "Stop CodeRule Cache Auto Update Thread Exception");
            }
        }

        /// <summary>
        /// 更新数据缓存
        /// </summary>
        public void Update()
        {
            var lastUpdate = Biz.Db.Queryable<BAS_CODE_DTL>().Max(q => q.UPDATE_TIME);
            if (LastUpdateTime < lastUpdate)
            {
                _Rules = Biz.Db.Queryable<BAS_CODE_RULE>().IncludesAllFirstLayer().ToList();
                LastUpdateTime = lastUpdate;
                Logger.Console.Info($"Get CodeRule successful, total {Rules.Count}, last update time is {LastUpdateTime:yyyy-MM-dd HH:mm:ss}");
            }
        }

        /// <summary>
        /// 自动更新
        /// </summary>
        private void AutoUpdate()
        {
            try
            {
                Update();
            }
            catch (System.Exception ex)
            {
                Logger.Console.Fatal(ex, "CodeRule Cache Auto Update Exception");
                LastUpdateTime = DateTime.MinValue;
            }

            //休眠30分钟
            Thread.Sleep(30 * 60 * 1000);//
        }

        /// <summary>
        /// 使用指定规则验证传入编码
        /// </summary>
        /// <param name="code">需要验证的条码</param>
        /// <param name="rule">指定用于验证的条码规则</param>
        /// <returns>Result.Data is RuleVerifier</returns>
        public Result Verify(string code, BAS_CODE_RULE rule)
        {
            Result result = new(Result.Flags.Success);
            try
            {
                var rv = new RuleVerifier(rule);
                rv.Verify(code);
                result.Flag = rv.IsMatch ? Result.Flags.Success : Result.Flags.Failed;
                result.Data = rv;
            }
            catch (System.Exception ex)
            {
                result.CatchExceptionWithLog(ex, Biz.L("BAS.CodeRule.VerifyException", code));
            }
            return result;
        }

        /// <summary>
        /// 使用符合传入条件的规则验证传入编码
        /// </summary>
        /// <param name="code">需要验证的条码</param>
        /// <param name="predicate">用于验证条码规则的过滤条件</param>
        /// <returns>Result.Data is List&lt;RuleVerifier></returns>
        public Result Verify(string code, Func<BAS_CODE_RULE, bool> predicate = null)
        {
            Result result = new(Result.Flags.Success);
            try
            {
                var cv = new CodeVerifier(code, predicate);
                cv.DoVerify();
                result.Flag = cv.IsMatch ? Result.Flags.Success : Result.Flags.Failed;
                result.Data = cv.Matches;
            }
            catch (System.Exception ex)
            {
                result.CatchExceptionWithLog(ex, Biz.L("BAS.CodeRule.VerifyException", code));
            }
            return result;
        }

        /// <summary>
        /// 条码流水码取号
        /// </summary>
        /// <param name="key"></param>
        /// <param name="rule"></param>
        /// <param name="hisID">取号的流水号生成历史ID</param>
        /// <param name="isTry">是否尝试取号，不保存到数据库</param>
        /// <returns></returns>
        private int FetchSerialNo(string key, BAS_CODE_DTL rule, string hisID, bool isTry = false)
        {
            var db = Biz.Db;
            var failCount = 0;
            while (true)
            {
                try
                {
                    var next = 0;
                    db.BeginTran();
                    //查询条件记录后加行等待锁
                    var serialGen = db.Queryable<BAS_CODE_GEN>().TranLock(DbLockType.Wait).Where(q => q.RULE_DTL_ID == rule.ID && q.SERIAL_KEY == key).First();
                    if (serialGen.IsNullOrEmpty())
                    {
                        serialGen = new()
                        {
                            RULE_ID = rule.RULE_ID,
                            RULE_DTL_ID = rule.ID,
                            SERIAL_KEY = key,
                            SERIAL_DATE = DateTime.Now,
                            SERIAL_VALUE = rule.SERIAL_MIN,
                            LAST_GEN_DATE = DateTime.Now,
                            LAST_HIS_ID = hisID,
                        };
                        if (!isTry)
                        {
                            db.Insertable(serialGen).ExecuteCommand();
                        }
                        next = serialGen.SERIAL_VALUE;
                        //Console.WriteLine($"{hisID}: {DateTime.Now:HH:mm:ss.fff} > 第一次取号成功[{next}]，休息5000ms");
                        //Thread.Sleep(5000);
                    }
                    else
                    {
                        //流水号重置
                        switch (rule.SERIAL_RESET.GetEnum<BAS_CODE_DTL.SERIAL_RESETs>())
                        {
                            case BAS_CODE_DTL.SERIAL_RESETs.Default:
                                if (serialGen.SERIAL_VALUE + 1 > rule.SERIAL_MAX)
                                {
                                    serialGen.SERIAL_VALUE = rule.SERIAL_MIN - 1;
                                    serialGen.SERIAL_DATE = DateTime.Now;
                                }
                                break;
                            case BAS_CODE_DTL.SERIAL_RESETs.Year:
                                if (serialGen.SERIAL_DATE.Year != DateTime.Now.Year)
                                {
                                    serialGen.SERIAL_VALUE = rule.SERIAL_MIN - 1;
                                    serialGen.SERIAL_DATE = DateTime.Now;
                                }
                                break;
                            case BAS_CODE_DTL.SERIAL_RESETs.Month:
                                if (serialGen.SERIAL_DATE.Month != DateTime.Now.Month)
                                {
                                    serialGen.SERIAL_VALUE = rule.SERIAL_MIN - 1;
                                    serialGen.SERIAL_DATE = DateTime.Now;
                                }
                                break;
                            case BAS_CODE_DTL.SERIAL_RESETs.Week:
                                if ((serialGen.SERIAL_DATE.Date.DayOfWeek.GetValue() > 0 && DateTime.Now.Date.DayOfWeek.GetValue() == 0)
                                    || (DateTime.Now.Date - serialGen.SERIAL_DATE.Date).TotalDays >= 7)
                                {
                                    serialGen.SERIAL_VALUE = rule.SERIAL_MIN - 1;
                                    serialGen.SERIAL_DATE = DateTime.Now;
                                }
                                break;
                            case BAS_CODE_DTL.SERIAL_RESETs.Day:
                                if (serialGen.SERIAL_DATE.Date != DateTime.Now.Date)
                                {
                                    serialGen.SERIAL_VALUE = rule.SERIAL_MIN - 1;
                                    serialGen.SERIAL_DATE = DateTime.Now;
                                }
                                break;
                            case BAS_CODE_DTL.SERIAL_RESETs.NotReset:
                                break;
                        }
                        //流水号取号
                        if (serialGen.SERIAL_VALUE + 1 <= rule.SERIAL_MAX)
                        {
                            serialGen.SERIAL_VALUE++;
                            serialGen.LAST_GEN_DATE = DateTime.Now;
                            serialGen.LAST_HIS_ID = hisID;
                        }
                        else
                        {
                            throw new Exception($"The serial number has reached its max value[{rule.SERIAL_MAX}], waiting for reset");
                        }

                        if (!isTry)
                        {
                            db.Updateable(serialGen, "system").UpdateColumns(q => new { q.SERIAL_VALUE, q.SERIAL_DATE, q.LAST_GEN_DATE, q.LAST_HIS_ID }).ExecuteCommand();
                        }
                        next = serialGen.SERIAL_VALUE;
                        //Debug.WriteLine($"{hisID}: {DateTime.Now:HH:mm:ss.fff} > 继续取号成功[{next}]，休息1000ms");
                        //Thread.Sleep(1000);
                    }
                    db.CommitTran();
                    return next;
                }
                catch (Exception ex)
                {
                    db.RollbackTran();
                    //Debug.WriteLine($"{hisID}: {DateTime.Now:HH:mm:ss.fff} > 第{failCount + 1}次尝试取号异常：{ex.Message}");
                    if (++failCount >= 10)
                    {
                        throw;
                    }
                    Thread.Sleep(500);
                }
            }
        }

        /// <summary>
        /// 生成条码
        /// </summary>
        /// <param name="ruleCode"></param>
        /// <param name="args"></param>
        /// <returns></returns>
        public Result Generate(string ruleCode, params object?[] args)
        {
            Result result = new(Result.Flags.Success);
            try
            {
                var rule = Biz.Db.Queryable<BAS_CODE_RULE>().Where(q => q.RULE_CODE == ruleCode).IncludesAllFirstLayer().First();
                if (rule.IsNullOrEmpty())
                {
                    result.Flag = Result.Flags.Failed;
                    result.LocaleMsg = new("BAS.CodeRule.GenerateFailed.NotFound", ruleCode, string.Join(", ", args));
                }
                else
                {
                    var argsIndex = 0;
                    var his = new BAS_CODE_HIS();
                    foreach (var item in rule.Details.OrderBy(q => q.RULE_SEQ))
                    {
                        switch (item.DATA_TYPE.GetEnum<BAS_CODE_DTL.DATA_TYPEs>())
                        {
                            case BAS_CODE_DTL.DATA_TYPEs.Character:
                            case BAS_CODE_DTL.DATA_TYPEs.Numeric:
                            case BAS_CODE_DTL.DATA_TYPEs.FixedCode:
                            case BAS_CODE_DTL.DATA_TYPEs.DbCheck:
                            case BAS_CODE_DTL.DATA_TYPEs.NoCheck:
                                if (argsIndex >= args.Length)
                                {
                                    result.Flag = Result.Flags.Failed;
                                    result.LocaleMsg = new("BAS.CodeRule.GenerateFailed.NotEnoughArgs", ruleCode, string.Join(", ", args), item.RULE_SEQ);
                                    return result;
                                }
                                var value = args[argsIndex++].ToString();//.Substring(0, item.CHECK_LENGTH);
                                if (item.Regex.IsMatch(value) && RuleVerifier.CheckDB(value, item))
                                {
                                    for (int i = 0; i < item.REPEAT_TIMES; i++)
                                    {
                                        item.CodeValue += value;
                                    }
                                }
                                else
                                {
                                    result.Flag = Result.Flags.Failed;
                                    result.LocaleMsg = new("BAS.CodeRule.GenerateFailed.NotPassValidation", ruleCode, string.Join(", ", args), value, item.RULE_SEQ);
                                    return result;
                                }
                                break;
                            case BAS_CODE_DTL.DATA_TYPEs.DateCode:
                            case BAS_CODE_DTL.DATA_TYPEs.TimeCode:
                                value = "";
                                switch (item.DATA_CASE)
                                {
                                    case "yyyy":
                                    case "yy":
                                    case "dd":
                                    case "ss":
                                    case "fff":
                                        value = DateTime.Now.ToString(item.DATA_CASE);
                                        break;
                                    case "q":
                                        value = Math.Ceiling(DateTime.Now.Month * 1.0 / 3).ToString();
                                        break;
                                    case "hh":
                                    case "mm":
                                        value = DateTime.Now.ToString(item.DATA_CASE.ToUpper());
                                        break;
                                    case "m":
                                        var month = DateTime.Now.Month;
                                        value = month == 10 ? "A" : (month == 11 ? "B" : (month == 12 ? "C" : DateTime.Now.Month.ToString()));
                                        break;
                                    case "ww":
                                        value = Math.Ceiling((DateTime.Now.DayOfYear + new DateTime(DateTime.Now.Year, 1, 1).DayOfWeek.ToInt32()) * 1.0 / 7).ToString("00");
                                        break;
                                    case "dy":
                                        value = DateTime.Now.DayOfWeek.ToInt32().ToString();
                                        break;
                                    case "mi":
                                        value = DateTime.Now.ToString("mm");
                                        break;
                                }
                                for (int i = 0; i < item.REPEAT_TIMES; i++)
                                {
                                    item.CodeValue += value;
                                }
                                break;
                        }
                    }
                    //流水号生成
                    var serialRules = rule.Details.Where(q => q.DATA_TYPE == BAS_CODE_DTL.DATA_TYPEs.SerialCode.GetValue()).OrderBy(q => q.RULE_SEQ);
                    var serialKey = string.Join("|", rule.Details.Where(q => q.DATA_TYPE == BAS_CODE_DTL.DATA_TYPEs.DbCheck.GetValue()).Select(q => q.CodeValue));
                    foreach (var item in serialRules)
                    {
                        var serialGen = FetchSerialNo(serialKey, item, his.ID);
                        var value = serialGen.ToString().PadLeft(item.CHECK_LENGTH, '0');
                        for (int i = 0; i < item.REPEAT_TIMES; i++)
                        {
                            item.CodeValue += value;
                        }
                    }

                    his.RULE_ID = rule.ID;
                    his.GEN_CODE = string.Concat(rule.Details.OrderBy(q => q.RULE_SEQ).Select(q => q.CodeValue));
                    his.GEN_DATE = DateTime.Now;
                    try
                    {
                    	Biz.Db.Insertable(his).ExecuteCommand();
                    }
                    catch (System.Exception ex)
                    {
                        throw new DataException(his.GEN_CODE, ex);
                    }
                    result.Data = his.GEN_CODE;
                }
            }
            catch (DataException ex)
            {
                result.CatchExceptionWithLog(ex.InnerException, Biz.L("BAS.CodeRule.GenerateSnHisException", ruleCode, ex.Message));
            }
            catch (System.Exception ex)
            {
                result.CatchExceptionWithLog(ex, Biz.L("BAS.CodeRule.GenerateException", ruleCode, string.Join(", ", args)));
            }
            return result;
        }

        /// <summary>
        /// 尝试生成条码，不保存到数据库
        /// </summary>
        /// <param name="ruleCode"></param>
        /// <param name="args"></param>
        /// <returns></returns>
        public Result TryGenerate(string ruleCode, params object?[] args)
        {
            Result result = new(Result.Flags.Success);
            try
            {
                var rule = Biz.Db.Queryable<BAS_CODE_RULE>().Where(q => q.RULE_CODE == ruleCode).IncludesAllFirstLayer().First();
                if (rule.IsNullOrEmpty())
                {
                    result.Flag = Result.Flags.Failed;
                    result.LocaleMsg = new("BAS.CodeRule.GenerateFailed.NotFound", ruleCode, string.Join(", ", args));
                }
                else
                {
                    var his = new BAS_CODE_HIS();
                    var argsIndex = 0;
                    foreach (var item in rule.Details.OrderBy(q => q.RULE_SEQ))
                    {
                        switch (item.DATA_TYPE.GetEnum<BAS_CODE_DTL.DATA_TYPEs>())
                        {
                            case BAS_CODE_DTL.DATA_TYPEs.Character:
                            case BAS_CODE_DTL.DATA_TYPEs.Numeric:
                            case BAS_CODE_DTL.DATA_TYPEs.FixedCode:
                            case BAS_CODE_DTL.DATA_TYPEs.DbCheck:
                            case BAS_CODE_DTL.DATA_TYPEs.NoCheck:
                                if (argsIndex >= args.Length)
                                {
                                    result.Flag = Result.Flags.Failed;
                                    result.LocaleMsg = new("BAS.CodeRule.GenerateFailed.NotEnoughArgs", ruleCode, string.Join(", ", args), item.RULE_SEQ);
                                    return result;
                                }
                                var value = args[argsIndex++].ToString();//.Substring(0, item.CHECK_LENGTH);
                                if (item.Regex.IsMatch(value) && RuleVerifier.CheckDB(value, item))
                                {
                                    for (int i = 0; i < item.REPEAT_TIMES; i++)
                                    {
                                        item.CodeValue += value;
                                    }
                                }
                                else
                                {
                                    result.Flag = Result.Flags.Failed;
                                    result.LocaleMsg = new("BAS.CodeRule.GenerateFailed.NotPassValidation", ruleCode, string.Join(", ", args), value, item.RULE_SEQ);
                                    return result;
                                }
                                break;
                            case BAS_CODE_DTL.DATA_TYPEs.DateCode:
                            case BAS_CODE_DTL.DATA_TYPEs.TimeCode:
                                value = "";
                                switch (item.DATA_CASE)
                                {
                                    case "yyyy":
                                    case "yy":
                                    case "dd":
                                    case "ss":
                                    case "fff":
                                        value = DateTime.Now.ToString(item.DATA_CASE);
                                        break;
                                    case "q":
                                        value = Math.Ceiling(DateTime.Now.Month * 1.0 / 3).ToString();
                                        break;
                                    case "hh":
                                    case "mm":
                                        value = DateTime.Now.ToString(item.DATA_CASE.ToUpper());
                                        break;
                                    case "m":
                                        var month = DateTime.Now.Month;
                                        value = month == 10 ? "A" : (month == 11 ? "B" : (month == 12 ? "C" : DateTime.Now.Month.ToString()));
                                        break;
                                    case "ww":
                                        value = Math.Ceiling((DateTime.Now.DayOfYear + new DateTime(DateTime.Now.Year, 1, 1).DayOfWeek.ToInt32()) * 1.0 / 7).ToString("00");
                                        break;
                                    case "dy":
                                        value = DateTime.Now.DayOfWeek.ToInt32().ToString();
                                        break;
                                    case "mi":
                                        value = DateTime.Now.ToString("mm");
                                        break;
                                }
                                for (int i = 0; i < item.REPEAT_TIMES; i++)
                                {
                                    item.CodeValue += value;
                                }
                                break;
                        }
                    }
                    //流水号生成
                    var serialRules = rule.Details.Where(q => q.DATA_TYPE == BAS_CODE_DTL.DATA_TYPEs.SerialCode.GetValue()).OrderBy(q => q.RULE_SEQ);
                    var serialKey = string.Join("|", rule.Details.Where(q => q.DATA_TYPE == BAS_CODE_DTL.DATA_TYPEs.DbCheck.GetValue()).Select(q => q.CodeValue));
                    foreach (var item in serialRules)
                    {
                        var serialGen = FetchSerialNo(serialKey, item, his.ID, true);
                        var value = serialGen.ToString().PadLeft(item.CHECK_LENGTH, '0');
                        for (int i = 0; i < item.REPEAT_TIMES; i++)
                        {
                            item.CodeValue += value;
                        }
                    }

                    his.RULE_ID = rule.ID;
                    his.GEN_CODE = string.Concat(rule.Details.OrderBy(q => q.RULE_SEQ).Select(q => q.CodeValue));
                    his.GEN_DATE = DateTime.Now;
                    result.Data = his.GEN_CODE;
                }
            }
            catch (System.Exception ex)
            {
                result.CatchExceptionWithLog(ex, Biz.L("BAS.CodeRule.GenerateException", ruleCode, string.Join(", ", args)));
            }
            return result;
        }
        #endregion
    }
}