using System;
using System.Linq;
using System.Threading.Tasks;
using System.Collections.Generic;
using HT.Cloud.Code;
using SqlSugar;
using HT.Cloud.DataBase;
using HT.Cloud.Domain.SystemManage;
using HT.Cloud.Code.Model;
using System.Globalization;
//using NetTaste;

namespace HT.Cloud.Service.SystemManage
{
	/// <summary>
	/// 创 建：超级管理员
	/// 日 期：2022-10-06 11:25
	/// 描 述：条码规则服务类
	/// </summary>
	public class CoderuleService : BaseService<CoderuleEntity>, IDenpendency
    {
        public CoderuleService(ISqlSugarClient context) : base(context)
        {
        }
        #region 获取数据
        public async Task<List<CoderuleEntity>> GetList(string keyword = "")
        {
            var data = GetQuery();
            if (!string.IsNullOrEmpty(keyword))
            {
                data = data.Where(a => a.F_RuleName.Contains(keyword));
            }
            return await data.OrderBy(a => a.F_Id , OrderByType.Desc).ToListAsync();
        }

        public async Task<List<CoderuleEntity>> GetLookList(string keyword = "")
        {
            var query = GetQuery();
            if (!string.IsNullOrEmpty(keyword))
            {
                //此处需修改
                query = query.Where(a => a.F_RuleName.Contains(keyword));
            }
            //权限过滤
            query = GetDataPrivilege("a", query: query);
             return await query.OrderBy(a => a.F_Id , OrderByType.Desc).ToListAsync();
        }

        public async Task<List<CoderuleEntity>> GetLookList(SoulPage<CoderuleEntity> pagination,string keyword = "",string id="")
        {
			//反格式化显示只能用"等于"，其他不支持
			Dictionary<string, Dictionary<string, string>> dic = new Dictionary<string, Dictionary<string, string>>();
			Dictionary<string, string> enabledTemp = new Dictionary<string, string>();
			enabledTemp.Add("1", "有效");
			enabledTemp.Add("0", "无效");
			dic.Add("F_EnabledMark", enabledTemp);
			var setList = await GlobalContext.GetService<ItemsDataService>().GetItemList("RuleReset");
			Dictionary<string, string> resetTemp = new Dictionary<string, string>();
			foreach (var item in setList)
			{
				resetTemp.Add(item.F_ItemCode, item.F_ItemName);
			}
			dic.Add("F_Reset", resetTemp);
			var printList = await GlobalContext.GetService<ItemsDataService>().GetItemList("PrintType");
			Dictionary<string, string> printTemp = new Dictionary<string, string>();
			foreach (var item in printList)
			{
				printTemp.Add(item.F_ItemCode, item.F_ItemName);
			}
			dic.Add("F_PrintType", printTemp);
			pagination = ChangeSoulData(dic, pagination);
			var query = GetQuery();
            if (!string.IsNullOrEmpty(keyword))
            {
                query = query.Where(a => a.F_RuleName.Contains(keyword));
            }
            if(!string.IsNullOrEmpty(id))
            {
                query = query.Where(a => a.F_Id == id);
            }
            //权限过滤
            query = GetDataPrivilege("a", query: query);
            return  await query.ToPageListAsync(pagination);
        }

        public async Task<CoderuleEntity> GetForm(string keyValue)
        {
			var data = await GetQuery().FirstAsync(a => a.F_Id == keyValue);
			return data;
        }
		private ISugarQueryable<CoderuleEntity> GetQuery()
		{
			var query = repository.IQueryable()
                .InnerJoin<TemplateEntity>((a,b)=>a.F_TemplateId == b.F_Id)
				.Select((a, b) => new CoderuleEntity
				{
					F_Id=a.F_Id.SelectAll(),
                    F_TemplateName = b.F_TemplateName,
                    F_PrintType = b.F_PrintType,
                    F_Batch=b.F_Batch
				}).MergeTable().Where(a => a.F_DeleteMark == false);
			return query;
		}
		public async Task<CoderuleEntity> GetLookForm(string keyValue)
		{
            var data = await GetQuery().FirstAsync(a => a.F_Id == keyValue);
			return GetFieldsFilterData(data);
		}
		#endregion


		#region 提交数据
		public async Task SubmitForm(CoderuleEntity entity, string keyValue)
        {
            if(string.IsNullOrEmpty(keyValue))
            {
                entity.F_DeleteMark = false;
                entity.Create();
                await repository.Insert(entity);
            }
            else
            {
                entity.Modify(keyValue); 
                await repository.Update(entity);
            }
        }

        public async Task DeleteForm(string keyValue)
        {
            var ids = keyValue.Split(',');
            await repository.Delete(a => ids.Contains(a.F_Id.ToString()));
        }
		/// <summary>
		/// 计算编码规则生成流水号<para>注意：此编码规则只支持单个流水号</para>
		/// </summary>
		/// <param name="ruleName">规则名称</param>
		/// <param name="count">生成数量</param>
		/// <param name="preview">是否预览,预览不新增条码不操作Redis zincr</param>
		/// <param name="replaceList">通配符替换列表</param>
		/// <returns></returns>
		public async Task<List<string>> GetBillNumber(
			string ruleName,
			int count,
			bool preview = false,
			List<string> replaceList = null)
		{
			var now = DateTime.Now;
			var rule = await repository.Db.Queryable<CoderuleEntity>().FirstAsync(a => a.F_RuleName == ruleName);
			var resetRule = "NoReset";
			switch (rule.F_Reset)
			{
				//By 年 月 日
				case "yyyy":
				case "yyyy-MM":
				case "yyyy-MM-dd":
					resetRule = DateTime.Now.ToString(rule.F_Reset); break;
				//By 周
				case "yyyy-MM-WW":
					var gc = new GregorianCalendar();
					var thisWeek = gc.GetWeekOfYear(now, CalendarWeekRule.FirstDay, DayOfWeek.Sunday);
					resetRule = DateTime.Now.ToString("yyyy") + "W" + thisWeek; break;
				default:
					break;
			}
			var codeRuleFormatList = rule.F_RuleJson.ToObject<List<CodeRuleFormatEntity>>();
			//格式化
			var format = string.Empty;
			var reset = string.Empty;
			//流水号长度
			int flowNumberLength = 5;
			//流水号初始值
			int initVal = 0;
			//流水号最大值
			int? maxVal = null;
			//默认10进制
			int toBase = 10;
			//步长
			decimal increment = 1;

			string diyCode = string.Empty;

			char replaceChar = '*';

			List<string> list = new List<string>();

			codeRuleFormatList.ForEach(item =>
			{
				//编码前缀类型 1 - 固定参数 2 - 日期 3 - 年 4 - 月 5 - 日 6 - 周别 7 - 周几 8 - 小时 9 - 上午下午 10 - 班别 11 - 流水号 12 - 自定义
				switch (item.FormatType)
				{
					//固定参数
					case 1:
						format += item.FormatString;
						break;
					//日期
					case 2:
						format += now.ToString(item.FormatString);
						break;
					//年
					case 3:
						var ye = now.ToString("yyyy");
						//判断是否有自定义
						if (!string.IsNullOrEmpty(item.FormatString))
						{
							var yl = item.FormatString.Length;//yyyy 还是yy 还是y 
							if (yl <= 4)
								ye = ye.Substring(4 - yl, yl);
						}
						format += ye;
						break;
					//月
					case 4:
						var m = item.DiyDate[now.Month - 1];
						format += m;
						break;
					//日
					case 5:
						var d = item.DiyDate[now.Day - 1];
						format += d;
						break;
					//周别 （本年的第几周）
					case 6:
						var gc = new GregorianCalendar();
						var thisWeek = gc.GetWeekOfYear(now, CalendarWeekRule.FirstDay,DayOfWeek.Sunday);
						var y = item.DiyDate[thisWeek - 1];
						format += y;
						break;
					//周几  (按照周一是第一天算)
					case 7:
						var wk = now.DayOfWeek.ToInt();
						if (wk == 0)
							wk = 6;
						else
							wk -= 1;
						var w = item.DiyDate[wk];
						format += w;
						break;
					case 8:
						var h = now.ToString(item.FormatString);
						format += h;
						break;
					case 9:
						var ch = now.Hour;
						format += ch < 12? item.DiyDate[0] : item.DiyDate[1];
						break;
					//班别
					case 10:
						string csstr = "";
						foreach (var cs in item.DiyDate)
						{
							var strs = cs.Split(".");
							var times = strs[1].Split("-");
							if (int.Parse(times[0].Split(":")[0]) < int.Parse(times[1].Split(":")[0]))
							{
								//开始时间
								var startTime = DateTime.Parse($"{now:yyyy/MM/dd} {times[0]}");
								//结束时间
								var endTime = DateTime.Parse($"{now:yyyy/MM/dd} {times[1]}");
								if (DateTime.Now>=startTime && DateTime.Now < endTime)
								{
									csstr = strs[0];
									break;
								}
							}
							else
							{
								//开始时间
								var startTime = DateTime.Parse($"{now:yyyy/MM/dd} {times[0]}");
								//结束时间
								var endTime = DateTime.Parse($"{now:yyyy/MM/dd} {times[1]}").AddDays(1);
								if (DateTime.Now >= startTime && DateTime.Now < endTime)
								{
									csstr = strs[0];
									break;
								}
							}
						}
						format += csstr;
						break;
					//流水
					case 11:
						initVal = item.InitValue.Value;
						maxVal = item.MaxValue;
						flowNumberLength = item.FormatString.Length;
						toBase = item.ToBase;
						format += "^_^";
						increment = item.Increment.Value;
						break;
					//自定义方法
					case 12:
						//反射执行方法获取参数
						var udf =((Task<string>)this.GetType().GetMethod(item.FormatString, new Type[] { }).Invoke(this, new object[] { ruleName })).GetAwaiter().GetResult();
						format += udf;
						break;
					//通配符
					case 13:
						//如果作为检查流水号的长度的条件，则最后一个通配符是00,2位，那么流水号是4位，就会有问题  2 != 4 
						replaceChar = item.FormatString.FirstOrDefault();
						var tempstr = "".PadLeft(item.FormatString.Length, replaceChar);
						format += tempstr;
						break;
					default:
						break;
				}
			});

			//判断编码格式是否有效
			if (!string.IsNullOrEmpty(format))
			{
				for (int i = 0; i < count; i++)
				{
					var score = 0M;
					var scoreString = string.Empty;
					//预览
					if (!preview)
					{
						if (GlobalContext.SystemConfig.CacheProvider == Define.CACHEPROVIDER_REDIS)
						{
							score = await BaseHelper.ZIncrByAsync(GlobalContext.SystemConfig.ProjectPrefix + $"_BillNumber:{ruleName}", resetRule, increment);
						}
						else
						{
							var rulelog = await repository.Db.Queryable<CoderulelogEntity>().FirstAsync(a => a.F_Key == GlobalContext.SystemConfig.ProjectPrefix + $"_BillNumber:{ruleName}" && a.F_Value == resetRule);
							if (rulelog == null)
							{
								rulelog = new CoderulelogEntity();
								rulelog.F_Id = Utils.GetGuid();
								rulelog.F_Key = GlobalContext.SystemConfig.ProjectPrefix + $"_BillNumber:{ruleName}";
								rulelog.F_Value = resetRule;
								rulelog.F_Score = (int)increment;
								rulelog.F_RuleId = rule.F_Id;
								await repository.Db.Insertable(rulelog).ExecuteCommandAsync();
							}
							else
							{
								await repository.Db.Updateable<CoderulelogEntity>(a => new CoderulelogEntity
								{
									F_Score = a.F_Score + (int)increment
								}).Where(a => a.F_Id == rulelog.F_Id).ExecuteCommandAsync();
							}
						}
					}
					else
					{
						if (GlobalContext.SystemConfig.CacheProvider == Define.CACHEPROVIDER_REDIS)
						{
							score = await BaseHelper.ZScoreAsync(GlobalContext.SystemConfig.ProjectPrefix + $"_BillNumber:{ruleName}", resetRule)??0;
							score += increment;
						}
						else
						{
							var rulelog = await repository.Db.Queryable<CoderulelogEntity>().FirstAsync(a => a.F_Key == GlobalContext.SystemConfig.ProjectPrefix + $"_BillNumber:{ruleName}" && a.F_Value == resetRule);
							if (rulelog == null)
							{
								score += increment;
							}
							else
							{
								score = (rulelog.F_Score??0) + increment;
							}
						}
					}
					//10进制流水号
					var flowNumber = score + initVal;

					//判断流水号是否超过流水号设定的最大值
					if (maxVal > 0 && flowNumber > maxVal)
						throw new Exception($"Morethan the flownumber settinged max value:{maxVal} and now value:{flowNumber}");

					//默认10进制
					scoreString = flowNumber.ToString();

					if (toBase != 10)
						scoreString = scoreString.ToLong().ToBase(toBase);

					//^_^是代表可以任意位置流水号
					var flow = scoreString.PadLeft(flowNumberLength, '0');
					if (flow.Length != flowNumberLength)
					{
						throw new Exception($"bill encode ({ruleName})settinged error,FlowLength,current:[{flow.Length}],setting:[{flowNumberLength}]");
					}
					var v = format.Replace("^_^", flow);
					if (replaceList!=null&&replaceList.Count>0)
						foreach (var item in replaceList)
						{
							var temp = "".PadLeft(item.Length, replaceChar);
							v = v.ReplaceFrist(temp, item);
						}
					list.Add(v);
				}
			}

			return list;
		}
		public async Task<Dictionary<string,string>> GetPrintJson(string code,string templateId)
		{
			var template = await repository.Db.Queryable<TemplateEntity>().FirstAsync(a => a.F_Id == templateId);
			List<SugarParameter> list = new List<SugarParameter>();
			list.Add(new SugarParameter("rulecode", code));
			if (!string.IsNullOrEmpty(template.F_TemplateSqlParm))
			{
				var dic = template.F_TemplateSqlParm.ToObject<Dictionary<string, object>>();
				foreach (var item in dic)
				{
					list.Add(new SugarParameter(item.Key, item.Value));
				}
			}
			var printResult = string.IsNullOrEmpty(template.F_TemplateSql) ? null : await repository.Db.Ado.SqlQueryAsync<dynamic>(template.F_TemplateSql, list);
			if (printResult!=null && printResult.Count>0)
			{
				var printData = (printResult[0] as IDictionary<string, object>)?.ToDictionary(k => k.Key.ToLower(), v => v.Value?.ToString());
				printData.Add("rulecode", code);
				return printData;
			}
			else
			{
				var printData = new Dictionary<string, string>();
				printData.Add("rulecode", code);
				return printData;
			}
		}
		public async Task<List<PrintEntity>> CreateForm(string keyValue, int count = 1, bool needPrint = false)
		{
            var list = new List<PrintEntity>();
			var rule = await repository.Db.Queryable<CoderuleEntity>().FirstAsync(a => a.F_Id == keyValue);
			var template = await repository.Db.Queryable<TemplateEntity>().FirstAsync(a => a.F_Id == rule.F_TemplateId);
			var logs = new List<CodegeneratelogEntity>();
			var codes = await GetBillNumber(rule.F_RuleName, count);
			if (template.F_Batch == true)
			{
				PrintEntity entity = new PrintEntity();
				entity.data = new PrintDetail();
				entity.data.printIniInfo = new PrintInitInfo();
				entity.data.printIniInfo.printType = template.F_PrintType;
				entity.data.printIniInfo.isBatch = template.F_Batch;
				entity.data.printIniInfo.realName = template.F_TemplateName;
				entity.data.printIniInfo.filePath = (GlobalContext.HttpContext.Request.IsHttps ? "https://" : "http://") + GlobalContext.HttpContext.Request.Host + template.F_TemplateFile;
				entity.requestId = Utils.GetGuid();
				var listJson = new List<Dictionary<string, string>>();
				for (int i = 0; i < count; i++)
				{
					var log = new CodegeneratelogEntity();
					log.Create();
					log.F_Code = codes[i];
					log.F_PrintCount = needPrint ? 1 : 0;
					log.F_RuleId = rule.F_Id;
					log.F_RuleName = rule.F_RuleName;
					log.F_EnabledMark = true;
					log.F_DeleteMark = false;
					var printJson = await GetPrintJson(log.F_Code, template.F_Id);
					log.F_PrintJson = printJson.ToJson();
					logs.Add(log);
					listJson.Add(printJson);
				}
				entity.data.data = listJson;
				list.Add(entity);
			}
			else
			{
				for (int i = 0; i < count; i++)
				{
					var log = new CodegeneratelogEntity();
					log.Create();
					log.F_Code = codes[i];
					log.F_PrintCount = needPrint ? 1 : 0;
					log.F_RuleId = rule.F_Id;
					log.F_RuleName = rule.F_RuleName;
					log.F_EnabledMark = true;
					log.F_DeleteMark = false;
					var printJson = await GetPrintJson(log.F_Code, template.F_Id);
					log.F_PrintJson = printJson.ToJson();
					logs.Add(log);
					PrintEntity entity = new PrintEntity();
					entity.data = new PrintDetail();
					entity.data.printIniInfo = new PrintInitInfo();
					entity.data.printIniInfo.printType = template.F_PrintType;
					entity.data.printIniInfo.isBatch = template.F_Batch;
					entity.data.printIniInfo.realName = template.F_TemplateName;
					entity.data.printIniInfo.filePath = (GlobalContext.HttpContext.Request.IsHttps ? "https://" : "http://") + GlobalContext.HttpContext.Request.Host + template.F_TemplateFile;
					entity.requestId = Utils.GetGuid();
					entity.data.data = printJson;
					list.Add(entity);
				}
			}
			//新增log
			await repository.Db.Insertable(logs).ExecuteCommandAsync();
			return list;
		}
		#endregion

	}
}