using Rhea.Common;
using Tiger.Model;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading;
using System.Threading.Tasks;
using System.IO;
using Newtonsoft.Json;
using Tiger.IBusiness;

namespace Tiger.Business
{
    /// <summary>
    /// 事务基类
    /// </summary>
    public abstract class TransactionBase : IDisposable, ITransaction
    {
        /// <summary>
        /// 事务基类
        /// </summary>
        public TransactionBase()
        {
        }
        /// <summary>
        /// 事务ID
        /// </summary>
        public string TransID { get; set; }
        /// <summary>
        /// Api Host
        /// </summary>
        public string ApiHost { get; set; }
        /// <summary>
        /// Remote Address
        /// </summary>
        public string RemoteAddress { get; set; }
        /// <summary>
        /// 事务锁
        /// </summary>
        public object TransLock { get; } = new object();
        /// <summary>
        /// ApiAction历史记录
        /// </summary>
        protected Dictionary<string, ActionHistory> ActionHistoryList = new Dictionary<string, ActionHistory>();
        /// <summary>
        /// 最后操作的时间
        /// </summary>
        public DateTime LastActionTime { get; set; }
        /// <summary>
        /// 事务是否完成
        /// </summary>
        public bool IsFinished { get; set; }

        /// <summary>
        /// 添加一个ApiAction的历史记录
        /// </summary>
        /// <typeparam name="T"></typeparam>
        /// <param name="request"></param>
        /// <param name="action"></param>
        public virtual void AddHistory<T>(Microsoft.AspNetCore.Http.HttpRequest request, ApiAction<T> action)
        {
            try
            {
                ActionHistoryList.Add($"{request.HttpContext.TraceIdentifier} at {action.Timestamp:yyyy/MM/dd HH:mm:ss.fff}: {request.Path}", action.History());
            }
            catch (System.Exception ex)
            {
                Logger.Default.Fatal(ex, "添加ApiAction历史记录异常");
            }
            LastActionTime = DateTime.Now;
        }

        /// <summary>
        /// 保存ApiAction的历史记录到文件
        /// </summary>
        public virtual void SaveHistory()
        {
            DirectoryInfo di = new DirectoryInfo(AppDomain.CurrentDomain.BaseDirectory + "\\Logs\\Transaction");
            if (!di.Exists)
            {
                di.Create();
            }
            var log = new FileInfo(di.FullName + @$"\{this.TransID}.log");
            File.AppendAllText(log.FullName, "{");
            File.AppendAllText(log.FullName, "\"Transaction Data\":");
            File.AppendAllText(log.FullName, JsonConvert.SerializeObject(this) + "\r\n");
            File.AppendAllText(log.FullName, ",\"Transaction History\":");
            File.AppendAllText(log.FullName, JsonConvert.SerializeObject(ActionHistoryList) + "\r\n");
            File.AppendAllText(log.FullName, "}\r\n");
        }

        /// <summary>
        /// 关闭事务
        /// </summary>
        /// <param name="needSaveHistoryLog"></param>
        /// <returns></returns>
        public virtual bool Close(bool needSaveHistoryLog = false)
        {
            if (needSaveHistoryLog)
            {
                SaveHistory();
            }
            Dispose();
            return true;
        }

        public virtual void Dispose()
        {
            BizContext.TransactionDic.Remove(TransID);
        }
    }
}