using System;
using System.Threading.Tasks;
using Microsoft.AspNetCore.Cors;
using Microsoft.AspNetCore.Mvc;
using System.IO;
using System.Reflection;
using Rhea.Common;
using Tiger.IBusiness;
using System.Threading;
using System.Linq;
using Tiger.Model;
using System.Xml.Linq;
using System.ComponentModel;

namespace Tiger.Api.Controllers.Base
{
    /// <summary>
    /// Api系统服务
    /// </summary>
    [EnableCors("Any")]
    [ApiController]
    public partial class SystemController : ControllerBase
    {
        /// <summary>
        /// 获取Api的电脑时间
        /// </summary>
        /// <returns></returns>
        [HttpGet]
        [Route("System/Base/[action]")]
        public IActionResult GetApiTimeAsync()
        {
            return Ok(DateTime.Now.ToString("yyyy/MM/dd HH:mm:ss.fff"));
        }

        /// <summary>
        /// 获取Api版本
        /// </summary>
        /// <returns></returns>
        [HttpGet]
        [Route("System/Base/[action]")]
        public IActionResult GetVersion()
        {
            return Ok(Assembly.GetExecutingAssembly().GetName().Version.ToString());
        }

        /// <summary>
        /// 获取Api公司
        /// </summary>
        /// <returns></returns>
        [HttpGet]
        [Route("System/Base/[action]")]
        public IActionResult GetCompany()
        {
            return Ok((Attribute.GetCustomAttribute(Assembly.GetExecutingAssembly(), typeof(AssemblyCompanyAttribute)) as AssemblyCompanyAttribute).Company);
        }

        /// <summary>
        /// 获取Api版权
        /// </summary>
        /// <returns></returns>
        [HttpGet]
        [Route("System/Base/[action]")]
        public IActionResult GetCopyright()
        {
            return Ok((Attribute.GetCustomAttribute(Assembly.GetExecutingAssembly(), typeof(AssemblyCopyrightAttribute)) as AssemblyCopyrightAttribute).Copyright);
        }

        /// <summary>
        /// 获取Api说明
        /// </summary>
        /// <returns></returns>
        [HttpGet]
        [Route("System/Base/[action]")]
        public IActionResult GetDescription()
        {
            return Ok((Attribute.GetCustomAttribute(Assembly.GetExecutingAssembly(), typeof(AssemblyDescriptionAttribute)) as AssemblyDescriptionAttribute).Description);
        }

        /// <summary>
        /// 获取Api产品
        /// </summary>
        /// <returns></returns>
        [HttpGet]
        [Route("System/Base/[action]")]
        public IActionResult GetProduct()
        {
            return Ok((Attribute.GetCustomAttribute(Assembly.GetExecutingAssembly(), typeof(AssemblyProductAttribute)) as AssemblyProductAttribute).Product);
        }

        /// <summary>
        /// 获取Api产品
        /// </summary>
        /// <returns></returns>
        [HttpGet]
        [Route("System/Base/[action]")]
        public IActionResult GetMachineCode()
        {
            return Ok(DI.Resolve<IBizContext>().GetMachineCode());
        }

        /// <summary>
        /// 获取Api产品
        /// </summary>
        /// <returns></returns>
        [HttpGet]
        [Route("System/Entitys/Get")]
        public IActionResult GetEntitys(string? Namespace, string? StartWith)
        {
            Assembly assembly = Assembly.Load("Tiger.Model");
            Type[] types = assembly.GetTypes();
            var entitys = types.Where(q => q.IsClass && q.GetInterfaces().Contains(typeof(Model.iEntity)) //&& q.Namespace != "Tiger.Model.Minsun"
                                                       && (Namespace.IsNullOrEmpty() || q.Namespace == Namespace) 
                                                       && (StartWith.IsNullOrEmpty() || q.Name.StartsWith(StartWith))
                                                       && !q.GetCustomAttributes(typeof(EntityBase), false).Any()).ToList();
            var data = new
            {
                Total = entitys.Count,
                Data = entitys.Select(q => new
                {
                    q.FullName,
                    q.Namespace,
                    q.Name,
                    DisplayName = (q.GetCustomAttribute(typeof(DisplayNameAttribute)) as DisplayNameAttribute)?.DisplayName,
                    Properties = q.GetProperties().Select(p => new { 
                        p.Name, 
                        DisplayName = (p.GetCustomAttribute(typeof(DisplayNameAttribute)) as DisplayNameAttribute)?.DisplayName,
                        Type = p.PropertyType.Name }).ToList()
                })
            };
            return Ok(data);
        }

        /// <summary>
        /// GetCertification(ApiAction)
        /// 在注册表HKEY_LOCAL_MACHINE\SOFTWARE\TigerClouds节点中读取密钥证书
        /// </summary>
        /// <param name="action"></param>
        /// <returns></returns>
        [HttpPost]
        [Route("System/Authorization/[action]")]
        public IActionResult GetCertification([FromBody] ApiAction action)
        {
            ApiAction response;
            try
            {
                var cer = DI.Resolve<IBizContext>().GetTigerActive().GetCertification();
                response = action.GetResponse(new ApiAction(cer.IsNullOrEmpty() ? "未找到密钥证书" : "获取密钥证书成功", cer));
            }
            catch (System.Exception ex)
            {
                response = action.GetResponse().CatchExceptionWithLog(ex, "获取密钥证书异常", null);
            }
            return Ok(response);
        }

        /// <summary>
        /// SetCertification(ApiAction(Data:key))
        /// 在注册表HKEY_LOCAL_MACHINE\SOFTWARE\TigerClouds节点中写入密钥证书
        /// </summary>
        /// <param name="action"></param>
        /// <returns></returns>
        [HttpPost]
        [Route("System/Authorization/[action]")]
        public IActionResult SetCertification([FromBody] ApiAction action)
        {
            ApiAction response;
            try
            {
                DI.Resolve<IBizContext>().GetTigerActive().SetCertification(action.Data?.ToString());
                response = action.GetResponse(new ApiAction("写入密钥证书成功"));
            }
            catch (System.Exception ex)
            {
                response = action.GetResponse().CatchExceptionWithLog(ex, "写入密钥证书异常", null);
            }
            return Ok(response);
        }

        /// <summary>
        /// GetActivationCode(ApiAction)
        /// 在注册表HKEY_LOCAL_MACHINE\SOFTWARE\TigerClouds节点中读取激活码
        /// </summary>
        /// <param name="action"></param>
        /// <returns></returns>
        [HttpPost]
        [Route("System/Authorization/[action]")]
        public IActionResult GetActivationCode([FromBody] ApiAction action)
        {
            ApiAction response;
            try
            {
                var cer = DI.Resolve<IBizContext>().GetTigerActive().GetActivationCode();
                response = action.GetResponse(new ApiAction(cer.IsNullOrEmpty() ? "未找到激活码" : "获取激活码成功", cer));
            }
            catch (System.Exception ex)
            {
                response = action.GetResponse().CatchExceptionWithLog(ex, "获取激活码异常", null);
            }
            return Ok(response);
        }

        /// <summary>
        /// SetActivationCode(ApiAction(Data:code))
        /// 在注册表HKEY_LOCAL_MACHINE\SOFTWARE\TigerClouds节点中写入激活码
        /// </summary>
        /// <param name="action"></param>
        /// <returns></returns>
        [HttpPost]
        [Route("System/Authorization/[action]")]
        public IActionResult SetActivationCode([FromBody] ApiAction action)
        {
            ApiAction response;
            try
            {
                DI.Resolve<IBizContext>().GetTigerActive().SetActivationCode(action.Data?.ToString());
                response = action.GetResponse(new ApiAction("写入激活码成功"));
            }
            catch (System.Exception ex)
            {
                response = action.GetResponse().CatchExceptionWithLog(ex, "写入激活码异常", null);
            }
            return Ok(response);
        }

        /// <summary>
        /// GetCurLicense(ApiAction)
        /// 获取许可信息
        /// </summary>
        /// <param name="action"></param>
        /// <returns></returns>
        [HttpPost]
        [Route("System/Authorization/[action]")]
        public IActionResult GetCurLicense([FromBody] ApiAction action)
        {
            ApiAction response;
            try
            {
                response = action.GetResponse("获取许可信息成功", data: DI.Resolve<IBizContext>().GetTigerActive().GetCurLicense());
            }
            catch (System.Exception ex)
            {
                response = action.GetResponse().CatchExceptionWithLog(ex, "获取许可信息异常", null);
            }
            return Ok(response);
        }

        /// <summary>
        /// Active(ApiAction(Data:activationCode))
        /// 激活Api
        /// </summary>
        /// <param name="action"></param>
        /// <returns></returns>
        [HttpPost]
        [Route("System/Authorization/[action]")]
        public IActionResult Active([FromBody] ApiAction action)
        {
            ApiAction response;
            try
            {
                response = action.GetResponse(DI.Resolve<IBizContext>().GetTigerActive().Active(action.Data?.ToString()));
            }
            catch (System.Exception ex)
            {
                response = action.GetResponse().CatchExceptionWithLog(ex, "激活Api异常");
            }
            return Ok(response);
        }

        /// <summary>
        /// Verify(ApiAction)
        /// 验证Api是否已激活
        /// </summary>
        /// <param name="action"></param>
        /// <returns></returns>
        [HttpPost]
        [Route("System/Authorization/[action]")]
        public IActionResult Verify([FromBody] ApiAction action)
        {
            ApiAction response;
            try
            {
                response = action.GetResponse(DI.Resolve<IBizContext>().GetTigerActive().Verify());
            }
            catch (System.Exception ex)
            {
                response = action.GetResponse().CatchExceptionWithLog(ex, "验证Api是否已激活异常");
            }
            return Ok(response);
        }

        #region Function
        /// <summary>
        /// 获取到文件流结果
        /// </summary>
        /// <param name="fileInfo">FileInfo文件</param>
        /// <returns>返回FileStreamResult</returns>
        private async Task<IActionResult> GetFileStreamResultAsync(FileInfo fileInfo)
        {
            if (fileInfo == null) return NotFound();

            var memoryStream = new MemoryStream();
            using (var stream = new FileStream(fileInfo.FullName, FileMode.Open))
            {
                await stream.CopyToAsync(memoryStream);
            }
            memoryStream.Seek(0, SeekOrigin.Begin);

            //文件名必须编码，否则会有特殊字符(如中文)无法在此下载。
            string encodeFilename = System.Net.WebUtility.UrlEncode(fileInfo.Name);
            Response.Headers.Add("Content-Disposition", "attachment; filename=" + encodeFilename);
            return new FileStreamResult(memoryStream, "application/octet-stream");//文件流方式，指定文件流对应的ContenType。
        }

        /// <summary>
        /// 获取到文件流结果
        /// </summary>
        /// <param name="fileInfo">FileInfo文件</param>
        /// <returns>返回FileStreamResult</returns>
        private IActionResult GetFileStreamResult(FileInfo fileInfo)
        {
            if (fileInfo == null) return NotFound();

            var memoryStream = new MemoryStream();
            using (var stream = new FileStream(fileInfo.FullName, FileMode.Open))
            {
                stream.CopyTo(memoryStream);
            }
            memoryStream.Seek(0, SeekOrigin.Begin);

            //文件名必须编码，否则会有特殊字符(如中文)无法在此下载。
            string encodeFilename = System.Net.WebUtility.UrlEncode(fileInfo.Name);
            Response.Headers.Add("Content-Disposition", "attachment; filename=" + encodeFilename);
            return new FileStreamResult(memoryStream, "application/octet-stream");//文件流方式，指定文件流对应的ContenType。
        }

        /// <summary>
        /// 分段下载数据
        /// </summary>
        /// <param name="fileInfo">FileInfo文件</param>
        /// <returns>返回响应结果</returns>
        private async Task<IActionResult> SegmentDownloadFileAsync(FileInfo fileInfo)
        {
            if (fileInfo == null) return NotFound();

            int index = 0;

            using (FileStream fs = new FileStream(fileInfo.FullName, FileMode.Open))
            {
                if (fs.Length <= 0)
                {
                    return Ok(new { code = -1, msg = "文件尚未处理" });
                }
                int shardSize = 1 * 1024 * 1024;//一次1M
                int count = (int)(fs.Length / shardSize);

                if ((fs.Length % shardSize) > 0)
                {
                    count += 1;
                }
                if (index > count - 1)
                {
                    return Ok(new { code = -1, msg = "无效的下标" });
                }

                fs.Seek(index * shardSize, SeekOrigin.Begin);

                if (index == count - 1)
                {
                    //最后一片 = 总长 - (每次片段大小 * 已下载片段个数)
                    shardSize = (int)(fs.Length - (shardSize * index));
                }
                byte[] datas = new byte[shardSize];
                await fs.ReadAsync(datas.AsMemory(0, datas.Length));

                return File(datas, "application/octet-stream");
            }
        }

        /// <summary>
        /// 分段下载数据
        /// </summary>
        /// <param name="fileInfo">FileInfo文件</param>
        /// <returns>返回响应结果</returns>
        private IActionResult SegmentDownloadFile(FileInfo fileInfo)
        {
            if (fileInfo == null) return NotFound();

            int index = 0;

            using (FileStream fs = new FileStream(fileInfo.FullName, FileMode.Open))
            {
                if (fs.Length <= 0)
                {
                    return Ok(new { code = -1, msg = "文件尚未处理" });
                }
                int shardSize = 1 * 1024 * 1024;//一次1M
                int count = (int)(fs.Length / shardSize);

                if ((fs.Length % shardSize) > 0)
                {
                    count += 1;
                }
                if (index > count - 1)
                {
                    return Ok(new { code = -1, msg = "无效的下标" });
                }

                fs.Seek(index * shardSize, SeekOrigin.Begin);

                if (index == count - 1)
                {
                    //最后一片 = 总长 - (每次片段大小 * 已下载片段个数)
                    shardSize = (int)(fs.Length - (shardSize * index));
                }
                byte[] datas = new byte[shardSize];
                fs.Read(datas, 0, datas.Length);

                return File(datas, "application/octet-stream");
            }
        }
        #endregion

    }//endClass
}