using System.Data;
using System.Diagnostics;
using System.Security.Cryptography;
using System.Text;
using System.Text.Json.Nodes;
using System.Text.RegularExpressions;
using System.Web;
using JNPF.Common.Configuration;
using JNPF.Common.Const;
using JNPF.Common.Core.Manager;
using JNPF.Common.Core.Manager.Files;
using JNPF.Common.Dtos.OAuth;
using JNPF.Common.Dtos.VisualDev;
using JNPF.Common.Enums;
using JNPF.Common.Extension;
using JNPF.Common.Filter;
using JNPF.Common.Manager;
using JNPF.Common.Models;
using JNPF.Common.Net;
using JNPF.Common.Security;
using JNPF.DatabaseAccessor;
using JNPF.DependencyInjection;
using JNPF.DynamicApiController;
using JNPF.Extras.DatabaseAccessor.SqlSugar.Models;
using JNPF.Extras.Thirdparty.JSEngine;
using JNPF.FriendlyException;
using JNPF.LinqBuilder;
using JNPF.Logging.Attributes;
using JNPF.RemoteRequest.Extensions;
using JNPF.SensitiveDetection;
using JNPF.Systems.Entitys.Dto.DataInterFace;
using JNPF.Systems.Entitys.Dto.System.DataInterFace;
using JNPF.Systems.Entitys.Model.DataInterFace;
using JNPF.Systems.Entitys.Permission;
using JNPF.Systems.Entitys.System;
using JNPF.Systems.Interfaces.System;
using JNPF.UnifyResult;
using Mapster;
using Microsoft.AspNetCore.Authorization;
using Microsoft.AspNetCore.Http;
using Microsoft.AspNetCore.Mvc;
using Newtonsoft.Json;
using Newtonsoft.Json.Linq;
using SqlSugar;
using JNPF.Common.Filter;

namespace JNPF.Systems;

/// <summary>
/// 数据接口
/// 版 本：V3.2
/// 版 权：引迈信息技术有限公司（https://www.jnpfsoft.com）
/// 作 者：JNPF开发平台组
/// 日 期：2021-06-01.
/// </summary>
[ApiDescriptionSettings(Tag = "System", Name = "DataInterface", Order = 204)]
[Route("api/system/[controller]")]
public class DataInterfaceService : IDataInterfaceService, IDynamicApiController, ITransient
{
    /// <summary>
    /// 服务基础仓储.
    /// </summary>
    private readonly ISqlSugarRepository<DataInterfaceEntity> _repository;

    /// <summary>
    /// 数据字典服务.
    /// </summary>
    private readonly IDictionaryDataService _dictionaryDataService;

    /// <summary>
    /// 脱敏词汇提供器.
    /// </summary>
    private readonly ISensitiveDetectionProvider _sensitiveDetectionProvider;

    /// <summary>
    /// 数据库管理.
    /// </summary>
    private readonly IDataBaseManager _dataBaseManager;

    /// <summary>
    /// 用户管理.
    /// </summary>
    private readonly IUserManager _userManager;

    /// <summary>
    /// 缓存管理.
    /// </summary>
    private readonly ICacheManager _cacheManager;

    /// <summary>
    /// 文件服务.
    /// </summary>
    private readonly IFileManager _fileManager;

    /// <summary>
    /// 初始化 SqlSugar 客户端.
    /// </summary>
    private readonly SqlSugarScope _sqlSugarClient;

    /// <summary>
    /// 数据库上下文ID.
    /// </summary>
    private string _configId = App.Configuration["ConnectionStrings:ConfigId"];

    /// <summary>
    /// 数据库名称.
    /// </summary>
    private string _dbName = App.Configuration["ConnectionStrings:DBName"];

    /// <summary>
    /// 初始化一个<see cref="DataInterfaceService"/>类型的新实例.
    /// </summary>
    public DataInterfaceService(
        ISqlSugarRepository<DataInterfaceEntity> repository,
        IDictionaryDataService dictionaryDataService,
        IDataBaseManager dataBaseManager,
        IUserManager userManager,
        ICacheManager cacheManager,
        IFileManager fileManager,
        ISensitiveDetectionProvider sensitiveDetectionProvider,
        ISqlSugarClient context)
    {
        _sensitiveDetectionProvider = sensitiveDetectionProvider;
        _repository = repository;
        _dictionaryDataService = dictionaryDataService;
        _fileManager = fileManager;
        _dataBaseManager = dataBaseManager;
        _cacheManager = cacheManager;
        _userManager = userManager;
        _sqlSugarClient = (SqlSugarScope)context;
    }

    #region Get

    /// <summary>
    /// 获取接口列表(分页).
    /// </summary>
    /// <param name="input">参数.</param>
    /// <returns></returns>
    [HttpGet("")]
    public async Task<dynamic> GetList([FromQuery] DataInterfaceListQuery input)
    {
        var list = await _repository.AsSugarClient().Queryable<DataInterfaceEntity, UserEntity>((a, b) => new JoinQueryInfos(JoinType.Left, b.Id == a.CreatorUserId))
            .Where(a => a.DeleteMark == null)
            .WhereIF(!string.IsNullOrEmpty(input.categoryId), a => a.CategoryId == input.categoryId)
            .WhereIF(!string.IsNullOrEmpty(input.keyword), a => a.FullName.Contains(input.keyword) || a.EnCode.Contains(input.keyword))
            .OrderBy(a => a.SortCode).OrderBy(a => a.CreatorTime, OrderByType.Desc)
            .Select((a, b) => new DataInterfaceListOutput
            {
                id = a.Id,
                categoryId = a.CategoryId,
                creatorTime = a.CreatorTime,
                creatorUser = SqlFunc.MergeString(b.RealName, "/", b.Account),
                dataType = a.DataType,
                dbLinkId = a.DBLinkId,
                description = a.Description,
                enCode = a.EnCode,
                fullName = a.FullName,
                enabledMark = a.EnabledMark,
                path = a.Path,
                query = a.Query,
                requestMethod = SqlFunc.IF(a.RequestMethod.Equals("1")).Return("新增").ElseIF(a.RequestMethod.Equals("2")).Return("修改")
                .ElseIF(a.RequestMethod.Equals("3")).Return("查询").ElseIF(a.RequestMethod.Equals("4")).Return("删除")
                .ElseIF(a.RequestMethod.Equals("5")).Return("存储过程").ElseIF(a.RequestMethod.Equals("6")).Return("Get")
                .End("Post"),
                requestParameters = a.RequestParameters,
                responseType = a.ResponseType,
                sortCode = a.SortCode,
                checkType = a.CheckType,
                tenantId = _userManager.TenantId
            }).ToPagedListAsync(input.currentPage, input.pageSize);
        return PageResult<DataInterfaceListOutput>.SqlSugarPageResult(list);
    }

    /// <summary>
    /// 获取接口列表(分页).
    /// </summary>
    /// <param name="input">参数.</param>
    /// <returns></returns>
    [HttpGet("getList")]
    public async Task<dynamic> getList([FromQuery] DataInterfaceListQuery input)
    {
        var list = await _repository.AsSugarClient().Queryable<DataInterfaceEntity, UserEntity>((a, b) => new JoinQueryInfos(JoinType.Left, b.Id == a.CreatorUserId))
            .Where(a => a.DeleteMark == null)
            .WhereIF(!string.IsNullOrEmpty(input.categoryId), a => a.CategoryId == input.categoryId)
            .WhereIF(!string.IsNullOrEmpty(input.dataType), a => a.DataType.ToString() == input.dataType)
            .WhereIF(!string.IsNullOrEmpty(input.keyword), a => a.FullName.Contains(input.keyword) || a.EnCode.Contains(input.keyword))
            .OrderBy(a => a.SortCode).OrderBy(a => a.CreatorTime, OrderByType.Desc)
            .Select((a, b) => new DateInterfaceGetListOutput
            {
                id = a.Id,
                categoryId = a.CategoryId,
                creatorTime = a.CreatorTime,
                creatorUser = SqlFunc.MergeString(b.RealName, "/", b.Account),
                _dataType = a.DataType,
                dbLinkId = a.DBLinkId,
                description = a.Description,
                enCode = a.EnCode,
                fullName = a.FullName,
                enabledMark = a.EnabledMark,
                path = a.Path,
                query = a.Query,
                requestMethod = SqlFunc.IF(a.RequestMethod.Equals("1")).Return("新增").ElseIF(a.RequestMethod.Equals("2")).Return("修改")
                .ElseIF(a.RequestMethod.Equals("3")).Return("查询").ElseIF(a.RequestMethod.Equals("4")).Return("删除")
                .ElseIF(a.RequestMethod.Equals("5")).Return("存储过程").ElseIF(a.RequestMethod.Equals("6")).Return("Get")
                .End("Post"),
                requestParameters = a.RequestParameters,
                responseType = a.ResponseType,
                sortCode = a.SortCode,
                checkType = a.CheckType,
                tenantId = _userManager.TenantId
            }).ToPagedListAsync(input.currentPage, input.pageSize);
        return PageResult<DateInterfaceGetListOutput>.SqlSugarPageResult(list);
    }

    /// <summary>
    /// 获取接口列表下拉框.
    /// </summary>
    /// <returns></returns>
    [HttpGet("Selector")]
    public async Task<dynamic> GetSelector()
    {
        List<DataInterfaceSelectorOutput> tree = new List<DataInterfaceSelectorOutput>();
        foreach (var entity in await _repository.AsQueryable().Where(x => x.DeleteMark == null && x.EnabledMark == 1).OrderBy(x => x.SortCode).ToListAsync())
        {
            var dictionaryDataEntity = await _dictionaryDataService.GetInfo(entity.CategoryId);
            if (dictionaryDataEntity != null && tree.Where(t => t.id == entity.CategoryId).Count() == 0)
            {
                DataInterfaceSelectorOutput firstModel = dictionaryDataEntity.Adapt<DataInterfaceSelectorOutput>();
                firstModel.categoryId = "0";
                DataInterfaceSelectorOutput treeModel = entity.Adapt<DataInterfaceSelectorOutput>();
                treeModel.categoryId = "1";
                treeModel.parentId = dictionaryDataEntity.Id;
                firstModel.children.Add(treeModel);
                tree.Add(firstModel);
            }
            else
            {
                DataInterfaceSelectorOutput treeModel = entity.Adapt<DataInterfaceSelectorOutput>();
                treeModel.categoryId = "1";
                treeModel.parentId = entity.CategoryId;
                var parent = tree.Where(t => t.id == entity.CategoryId).FirstOrDefault();
                if (parent != null)
                {
                    parent.children.Add(treeModel);
                }
            }
        }

        return tree.OrderBy(x => x.sortCode).ToList();
    }

    /// <summary>
    /// 获取接口数据.
    /// </summary>
    /// <returns></returns>
    [HttpGet("{id}")]
    public async Task<dynamic> GetInfo_Api(string id)
    {
        return (await GetInfo(id)).Adapt<DataInterfaceInfoOutput>();
    }

    /// <summary>
    /// 获取预览参数.
    /// </summary>
    /// <param name="id"></param>
    /// <returns></returns>
    [HttpGet("GetParam/{id}")]
    [UnitOfWork]
    public async Task<dynamic> GetParam(string id)
    {
        var info = await GetInfo(id);
        if (info.IsNotEmptyOrNull() && info.RequestParameters.IsNotEmptyOrNull())
        {
            return info.RequestParameters.ToList<DataInterfaceReqParameter>();
        }
        else
        {
            return new List<DataInterfaceReqParameter>();
        }
    }

    /// <summary>
    /// 访问接口 选中 回写.
    /// </summary>
    /// <returns></returns>
    [AllowAnonymous]
    [IgnoreLog]
    [HttpGet("{id}/Action/Info")]
    public async Task<dynamic> ActionsResponseInfo(string id, [FromQuery] string tenantId, [FromQuery] VisualDevDataFieldDataListInput input)
    {
        return await GetResponseByType(id, 1, tenantId, input);
    }

    /// <summary>
    /// 导出.
    /// </summary>
    /// <param name="id"></param>
    /// <returns></returns>
    [HttpGet("{id}/Action/Export")]
    public async Task<dynamic> ActionsExport(string id)
    {
        var data = await GetInfo(id);
        var jsonStr = data.ToJsonString();
        return await _fileManager.Export(jsonStr, data.FullName, ExportFileType.bd);
    }

    #endregion

    #region Post

    /// <summary>
    /// 预览接口.
    /// </summary>
    /// <param name="id"></param>
    /// <returns></returns>
    [HttpPost("{id}/Actions/Preview")]
    [UnitOfWork]
    public async Task<dynamic> Preview(string id, [FromBody] DataInterfacePreviewInput input)
    {
        _configId = _userManager.TenantId;
        _dbName = _userManager.TenantDbName;
        object output = null;
        var info = await GetInfo(id);
        var dicParameters = new Dictionary<string, string>();
        if (input.paramList.IsNotEmptyOrNull() && input.paramList.Count > 0)
        {
            dicParameters = input.paramList.ToDictionary(x => x.field, y => y.defaultValue);
        }
        if (!string.IsNullOrEmpty(info.Path) && !info.Path.StartsWith("http"))
        {
            info.Path = $"{App.HttpContext.Request.Scheme}://{App.HttpContext.Request.Host}{info.Path}";
        }
        VerifyRequired(info, dicParameters);
        ReplaceParameterValue(info, dicParameters);
        if (info?.DataType == 1)
        {
            output = await GetData(info);
        }
        else if (info?.DataType == 2)
        {
            output = info.Query.ToObject<object>();
        }
        else
        {
            output = await GetApiDataByTypePreview(info);
        }
        if (info is null || info.DataProcessing.IsNullOrEmpty())
        {
            return output;
        }
        else
        {
            string sheetData = Regex.Match(info.DataProcessing, @"\{(.*)\}", RegexOptions.Singleline).Groups[1].Value;
            var scriptStr = "var result = function(data){data = JSON.parse(data);" + sheetData + "}";
            return JsEngineUtil.CallFunction(scriptStr, output.ToJsonString(CommonConst.options));//此处时间非时间戳
        }
    }
    
    /// <summary>
    /// 不走js脚本
    /// </summary>
    /// <param name="id"></param>
    /// <param name="input"></param>
    /// <returns></returns>
    public async Task<dynamic> PreviewWithOutJs(string id, [FromBody] DataInterfacePreviewInput input)
    {
        _configId = _userManager.TenantId;
        _dbName = _userManager.TenantDbName;
        object output = null;
        var info = await GetInfo(id);
        var dicParameters = new Dictionary<string, string>();
        if (input.paramList.IsNotEmptyOrNull() && input.paramList.Count > 0)
        {
            dicParameters = input.paramList.ToDictionary(x => x.field, y => y.defaultValue);
        }
        if (!string.IsNullOrEmpty(info.Path) && !info.Path.StartsWith("http"))
        {
            info.Path = $"{App.HttpContext.Request.Scheme}://{App.HttpContext.Request.Host}{info.Path}";
        }
        VerifyRequired(info, dicParameters);
        ReplaceParameterValue(info, dicParameters);
        if (info?.DataType == 1)
        {
            output = await GetData(info);
        }
        else if (info?.DataType == 2)
        {
            output = info.Query.ToObject<object>();
        }
        else
        {
            output = await GetApiDataByTypePreview(info);
        }
        if (info is null || info.DataProcessing.IsNullOrEmpty())
        {
            return output;
        }
        else
        {
            return output.ToJsonString(CommonConst.options);
        }
    }

    /// <summary>
    /// 访问接口 选中 回写.
    /// </summary>
    /// <returns></returns>
    [AllowAnonymous]
    [IgnoreLog]
    [HttpPost("{id}/Action/InfoByIds")]
    public async Task<dynamic> ActionsResponseInfoNew(string id, [FromBody] VisualDevDataFieldDataListInput input)
    {
        return await GetResponseByType(id, 1, string.Empty, input);
    }

    /// <summary>
    /// 访问接口 分页.
    /// </summary>
    /// <returns></returns>
    [AllowAnonymous]
    [IgnoreLog]
    [HttpPost("{id}/Action/List")]
    public async Task<dynamic> ActionsResponseList(string id, [FromBody] VisualDevDataFieldDataListInput input)
    {
        return await GetResponseByType(id, 0, string.Empty, input);
    }

    /// <summary>
    /// 外部访问接口.
    /// </summary>
    /// <param name="id"></param>
    /// <param name="tenantId">有值则为地址请求，没有则是内部请求.</param>
    /// <returns></returns>
    [AllowAnonymous]
    [IgnoreLog]
    [HttpPost("{id}/Actions/Response")]
    [UnitOfWork]
    public async Task<dynamic> ActionsResponse(string id, [FromQuery] string tenantId, [FromBody] Dictionary<string, string> dic)
    {
        return await InterfaceVerify(id, tenantId, dic);
    }

    /// <summary>
    /// 添加接口.
    /// </summary>
    /// <param name="input">参数.</param>
    /// <returns></returns>
    [HttpPost("")]
    public async Task Create([FromBody] DataInterfaceCrInput input)
    {
        var entity = input.Adapt<DataInterfaceEntity>();
        var isOk = await _repository.AsInsertable(entity).IgnoreColumns(ignoreNullColumn: true).CallEntityMethod(m => m.Creator()).ExecuteCommandAsync();
        if (isOk < 1)
            throw Oops.Oh(ErrorCode.COM1000);
    }

    /// <summary>
    /// 修改接口.
    /// </summary>
    /// <param name="id">主键id.</param>
    /// <param name="input">参数.</param>
    /// <returns></returns>
    [HttpPut("{id}")]
    public async Task Update(string id, [FromBody] DataInterfaceUpInput input)
    {
        var entity = input.Adapt<DataInterfaceEntity>();
        var isOk = await _repository.AsUpdateable(entity).IgnoreColumns(ignoreAllNullColumns: true).CallEntityMethod(m => m.LastModify()).ExecuteCommandHasChangeAsync();
        if (!isOk)
            throw Oops.Oh(ErrorCode.COM1001);
    }

    /// <summary>
    /// 删除接口.
    /// </summary>
    /// <param name="id">主键id.</param>
    /// <returns></returns>
    [HttpDelete("{id}")]
    public async Task Delete_Api(string id)
    {
        var isOk = await _repository.AsUpdateable().SetColumns(it => new DataInterfaceEntity()
        {
            DeleteMark = 1,
            DeleteTime = DateTime.Now,
            DeleteUserId = _userManager.UserId
        }).Where(it => it.Id == id).ExecuteCommandHasChangeAsync();
        if (!isOk)
            throw Oops.Oh(ErrorCode.COM1002);
    }

    /// <summary>
    /// 更新接口状态.
    /// </summary>
    /// <param name="id">主键id.</param>
    /// <returns></returns>
    [HttpPut("{id}/Actions/State")]
    public async Task UpdateState(string id)
    {
        var isOk = await _repository.AsUpdateable().SetColumns(it => new DataInterfaceEntity()
        {
            EnabledMark = SqlFunc.IIF(it.EnabledMark == 1, 0, 1),
            LastModifyTime = DateTime.Now,
            LastModifyUserId = _userManager.UserId
        }).Where(it => it.Id == id).ExecuteCommandHasChangeAsync();
        if (!isOk)
            throw Oops.Oh(ErrorCode.COM1003);
    }

    /// <summary>
    /// 导入.
    /// </summary>
    /// <param name="file"></param>
    /// <returns></returns>
    [HttpPost("Action/Import")]
    public async Task ActionsImport(IFormFile file)
    {
        var fileType = Path.GetExtension(file.FileName).Replace(".", string.Empty);
        if (!fileType.ToLower().Equals(ExportFileType.bd.ToString()))
            throw Oops.Oh(ErrorCode.D3006);
        var josn = _fileManager.Import(file);
        var data = josn.ToObject<DataInterfaceEntity>();
        if (data == null)
            throw Oops.Oh(ErrorCode.D3006);
        var isOk = await _repository.AsSugarClient().Storageable(data).ExecuteCommandAsync();
        if (isOk < 1)
            throw Oops.Oh(ErrorCode.D3008);
    }

    /// <summary>
    /// 外部接口授权码.
    /// </summary>
    /// <param name="appId"></param>
    /// <param name="intefaceId"></param>
    /// <param name="dic"></param>
    /// <returns></returns>
    [AllowAnonymous]
    [IgnoreLog]
    [HttpPost("Actions/GetAuth")]
    public async Task<dynamic> GetAuthorization([FromQuery] string appId, [FromQuery] string tenantId, [FromQuery] string intefaceId, [FromBody] Dictionary<string, string> dic)
    {
        if (KeyVariable.MultiTenancy)
        {
            tenantId = tenantId.IsNullOrEmpty() ? _userManager.TenantId : tenantId;
            var interFace = App.Configuration["Tenant:MultiTenancyDBInterFace"] + tenantId;
            var response = await interFace.GetAsStringAsync();
            var result = response.ToObject<RESTfulResult<TenantInterFaceOutput>>();
            if (result.code != 200)
                throw Oops.Oh(result.msg);
            else if (result.data.dotnet == null)
                throw Oops.Oh(ErrorCode.D1025);
            if (!_sqlSugarClient.IsAnyConnection(tenantId))
            {
                _sqlSugarClient.AddConnection(new ConnectionConfig()
                {
                    DbType = (SqlSugar.DbType)Enum.Parse(typeof(SqlSugar.DbType), App.Configuration["ConnectionStrings:DBType"]),
                    ConfigId = tenantId, // 设置库的唯一标识
                    IsAutoCloseConnection = true,
                    ConnectionString = string.Format($"{App.Configuration["ConnectionStrings:DefaultConnection"]}", result.data.dotnet)
                });
            }
            if (!"default".Equals(tenantId) && KeyVariable.MultiTenancyType.Equals("COLUMN"))
            {
                _sqlSugarClient.QueryFilter.AddTableFilter<ITenantFilter>(it => it.TenantId == tenantId);
            }
            else
            {
                _sqlSugarClient.ChangeDatabase(tenantId);
            }
        }
        var interfaceOauthEntity = await _sqlSugarClient.Queryable<InterfaceOauthEntity>().FirstAsync(x => x.AppId == appId && x.DeleteMark == null && x.EnabledMark == 1);
        if (interfaceOauthEntity == null) return null;
        var ymDate = DateTime.Now.ParseToUnixTime().ToString();
        var authorization = GetVerifySignature(interfaceOauthEntity, intefaceId, ymDate);
        return new
        {
            YmDate = ymDate,
            Authorization = authorization,
        };
    }

    /// <summary>
    /// 复制.
    /// </summary>
    /// <param name="id">主键值.</param>
    /// <returns></returns>
    [HttpPost("{id}/Actions/Copy")]
    public async Task ActionsCopy(string id)
    {
        var entity = await _repository.GetFirstAsync(x => x.Id == id && x.DeleteMark == null);
        if (entity == null)
            throw Oops.Oh(ErrorCode.COM1005);
        var random = RandomExtensions.NextLetterAndNumberString(new Random(), 5).ToLower();
        entity.FullName = string.Format("{0}.副本{1}", entity.FullName, random);
        entity.EnCode = string.Format("{0}{1}", entity.EnCode, random);
        if (entity.FullName.Length >= 50 || entity.EnCode.Length >= 50)
            throw Oops.Oh(ErrorCode.COM1009);
        entity.EnabledMark = 0;
        var isOk = await _repository.AsInsertable(entity).IgnoreColumns(ignoreNullColumn: true).CallEntityMethod(m => m.Creator()).ExecuteCommandAsync();
        if (isOk < 1)
            throw Oops.Oh(ErrorCode.COM1000);
    }

    /// <summary>
    /// 预览接口字段.
    /// </summary>
    /// <param name="id"></param>
    /// <returns></returns>
    [HttpPost("{id}/Actions/GetFields")]
    [UnitOfWork]
    public async Task<dynamic> GetFields(string id, [FromBody] DataInterfacePreviewInput input)
    {
        try
        {
            //modifyby zhoukeda 20230803
            var result = await Preview(id, input);
            //if (result is Microsoft.ClearScript.V8.V8ScriptItem.V8Array)
            if (result.ToString()=="Microsoft.ClearScript.V8.V8ScriptItem+V8Array")
            {
                List<Dictionary<string, Object>> list = JsonConvert.DeserializeObject<List<Dictionary<string, object>>>(JsonConvert.SerializeObject(result));
                return list.FirstOrDefault()?.Keys.ToList() ?? Enumerable.Empty<string>();
            }
            else if (result.ToString() == "Microsoft.ClearScript.V8.V8ScriptItem")
            {
                PageResult<Dictionary<string, object>> page = JsonConvert.DeserializeObject<PageResult<Dictionary<string, object>>>(JsonConvert.SerializeObject(result));
                return page.list.FirstOrDefault()?.Keys.ToList() ?? Enumerable.Empty<string>();
            }
            if (result is DataTable)
            {
                List<Dictionary<string, Object>> list = JsonConvert.DeserializeObject<List<Dictionary<string, object>>>(JsonConvert.SerializeObject(result));
                return list.FirstOrDefault()?.Keys.ToList() ?? Enumerable.Empty<string>();
            }
            else
            {
                return Enumerable.Empty<string>();
            }
        }
        catch (Exception e)
        {
            throw Oops.Oh(ErrorCode.COM1020);
        }
    }
    #endregion

    #region PublicMethod

    /// <summary>
    /// 信息.
    /// </summary>
    /// <param name="id">主键id.</param>
    /// <returns></returns>
    [NonAction]
    public async Task<DataInterfaceEntity> GetInfo(string id)
    {
        return await _repository.GetFirstAsync(x => x.Id == id && x.DeleteMark == null);
    }

    /// <summary>
    /// 查询.
    /// </summary>
    /// <param name="entity"></param>
    /// <returns></returns>
    [NonAction]
    public async Task<DataTable> GetData(DataInterfaceEntity entity)
    {
        return await connection(entity.DBLinkId, entity.Query, entity.RequestMethod);
    }

    /// <summary>
    /// 根据不同类型请求接口.
    /// </summary>
    /// <param name="id"></param>
    /// <param name="type">0 ： 分页 1 ：详情 2：数据视图 ，其他 原始.</param>
    /// <param name="tenantId"></param>
    /// <param name="input"></param>
    /// <returns></returns>
    [NonAction]
    public async Task<object> GetResponseByType(string id, int type, string tenantId, VisualDevDataFieldDataListInput input = null, Dictionary<string, string> dicParameters = null)
    {
        try
        {
            if (KeyVariable.MultiTenancy)
            {
                tenantId = tenantId.IsNullOrEmpty() ? _userManager.TenantId : tenantId;
                var interFace = App.Configuration["Tenant:MultiTenancyDBInterFace"] + tenantId;
                var response = await interFace.GetAsStringAsync();
                var result = response.ToObject<RESTfulResult<TenantInterFaceOutput>>();
                if (result.code != 200)
                    throw Oops.Oh(result.msg);
                else if (result.data.dotnet == null)
                    throw Oops.Oh(ErrorCode.D1025);
                if (!_sqlSugarClient.IsAnyConnection(tenantId))
                {
                    _sqlSugarClient.AddConnection(new ConnectionConfig()
                    {
                        DbType = (SqlSugar.DbType)Enum.Parse(typeof(SqlSugar.DbType), App.Configuration["ConnectionStrings:DBType"]),
                        ConfigId = tenantId, // 设置库的唯一标识
                        IsAutoCloseConnection = true,
                        ConnectionString = string.Format($"{App.Configuration["ConnectionStrings:DefaultConnection"]}", result.data.dotnet)
                    });
                }

                if (!"default".Equals(tenantId) && KeyVariable.MultiTenancyType.Equals("COLUMN"))
                {
                    _sqlSugarClient.QueryFilter.AddTableFilter<ITenantFilter>(it => it.TenantId == tenantId);
                }
                else
                {
                    _sqlSugarClient.ChangeDatabase(tenantId);
                }
                _configId = tenantId;
                _dbName = result.data.dotnet;
            }

            var data = await _sqlSugarClient.CopyNew().Queryable<DataInterfaceEntity>().FirstAsync(x => x.Id == id && x.DeleteMark == null);
            if (data == null)
                throw Oops.Oh(ErrorCode.COM1005);

            // 远端数据（sql过滤）
            if (input.IsNotEmptyOrNull())
            {
                if (type == 2 && !2.Equals(data.DataType) && (input.queryJson.IsNotEmptyOrNull() || input.sidx.IsNotEmptyOrNull()))
                {
                    if (input.queryJson.IsNotEmptyOrNull())
                    {
                        var sqlFields = input.queryJson.ToObject<Dictionary<string, string>>();
                        var whereList = new List<string>();
                        foreach (var item in sqlFields)
                        {
                            if (item.Key.Contains("jnpf_searchType_equals_")) whereList.Add(string.Format("{0} = '{1}' ", item.Key.Replace("jnpf_searchType_equals_", string.Empty), item.Value));
                            else whereList.Add(string.Format("{0} like '%{1}%' ", item.Key, item.Value));
                        }
                        data.Query = string.Format("select * from ({0}) t where {1} ", data.Query.TrimEnd(';'), string.Join(" and ", whereList));
                    }
                    if (input.sidx.IsNotEmptyOrNull()) data.Query = string.Format("{0} order by {1} {2}", data.Query.TrimEnd(';'), input.sidx, input.sort);
                }
                else
                {
                    var columnList = new List<string>();
                    if (input.keyword.IsNotEmptyOrNull())
                        input.columnOptions.Split(",").ToList().ForEach(x => columnList.Add(string.Format("{0} like '%{1}%'", x, input.keyword)));

                    if (columnList.Any() && !string.IsNullOrWhiteSpace(input.keyword))
                        data.Query = string.Format("select * from ({0}) t where {1} ", data.Query.TrimEnd(';'), string.Join(" or ", columnList));
                    else if (!string.IsNullOrWhiteSpace(input.relationField) && !string.IsNullOrWhiteSpace(input.keyword))
                        data.Query = string.Format("select * from ({0}) t where {1} like '%{2}%' ", data.Query.TrimEnd(';'), input.relationField, input.keyword);

                    if (!string.IsNullOrWhiteSpace(input.propsValue) && !string.IsNullOrWhiteSpace(input.id))
                        data.Query = string.Format("select * from ({0}) t where {1} = '{2}' ", data.Query.TrimEnd(';'), input.propsValue, input.id);
                    if (!string.IsNullOrWhiteSpace(input.propsValue) && input.ids.Any())
                        data.Query = string.Format("select * from ({0}) t where {1} in ('{2}') ", data.Query.TrimEnd(';'), input.propsValue, string.Join("','", input.ids));
                    if (input.columnOptions.IsNotEmptyOrNull() && !string.IsNullOrWhiteSpace(input.keyword))
                    {
                        var whereStr = new List<string>();
                        input.columnOptions.Split(",").ToList().ForEach(item => whereStr.Add(string.Format(" {0} like '%{1}%' ", item, input.keyword)));
                        data.Query = string.Format("select * from ({0}) t where {1} ", data.Query.TrimEnd(';'), string.Join(" or ", whereStr));
                    }
                }
                if (input.paramList.IsNotEmptyOrNull() && input.paramList.Count > 0)
                {
                    dicParameters = input.paramList.ToDictionary(x => x.field, y => y.defaultValue);
                }
            }

            if (dicParameters.IsNullOrEmpty())
                dicParameters = new Dictionary<string, string>();
            ReplaceParameterValue(data, dicParameters);
            object output = null;
            #region 调用接口

            if (1.Equals(data.DataType))
            {
                var resTable = await GetData(data);
                if (type == 0 || type == 2)
                {
                    // 分页
                    var dt = GetPageToDataTable(resTable, input.currentPage, input.pageSize);
                    output = new
                    {
                        pagination = new PageResult()
                        {
                            currentPage = input.currentPage,
                            pageSize = input.pageSize,
                            total = resTable.Rows.Count
                        },
                        list = dt.ToObject<List<Dictionary<string, object>>>(),
                    };
                }
                else if (type == 1)
                {
                    if (input.ids.Any())
                    {
                        output = resTable.ToObject<List<Dictionary<string, object>>>();
                    }
                    else
                    {
                        output = resTable.ToObject<List<Dictionary<string, object>>>().FirstOrDefault();
                    }
                }
                else
                {
                    output = resTable;
                }

            }
            else if (2.Equals(data.DataType))
            {

                output = data.Query.ToObject<object>();
            }
            else
            {
                var result = await GetApiDataByTypePreview(data);
                var resList = result != null && result.ContainsKey("list") ? result["list"].ToObject<List<Dictionary<string, string>>>() : new List<Dictionary<string, string>>();
                if (type == 0)
                {
                    //if (input.columnOptions.IsNotEmptyOrNull())
                    //{
                    //    var columList = input.columnOptions.Split(",").ToList();
                    //    resList.ForEach(item =>
                    //    {
                    //        item.Where(x => !columList.Contains(x.Key)).ToList().ForEach(it => item.Remove(it.Key));
                    //    });
                    //}
                    resList = resList.FindAll(x => x.Where(xx => xx.Value != null && xx.Value.Contains(input.keyword)).Any());
                    output = new
                    {
                        pagination = new PageResult()
                        {
                            currentPage = input.currentPage,
                            pageSize = input.pageSize,
                            total = resList.Count
                        },
                        list = resList.Skip((input.currentPage - 1) * input.pageSize).Take(input.pageSize).ToList(),
                    };
                }
                else if (type == 1)
                {
                    if (input.id != null)
                    {
                        return resList.Find(x => x.ContainsKey(input.propsValue) && x.ContainsValue(input.id));
                    }
                    else if (input.id == null && input.ids.Count > 0)
                    {
                        return resList.FindAll(x => x.ContainsKey(input.propsValue) && x.Any(it => input.ids.Contains(it.Value)));
                    }
                }
                else if (type == 2)
                {
                    if (input.queryJson.IsNotEmptyOrNull() || input.sidx.IsNotEmptyOrNull())
                    {
                        if (input.queryJson.IsNotEmptyOrNull())
                        {
                            var querList = input.queryJson.ToObject<Dictionary<string, string>>();
                            foreach (var item in querList)
                            {
                                if (item.Key.Contains("jnpf_searchType_equals_")) resList = resList.Where(x => x[item.Key.Replace("jnpf_searchType_equals_", "")].Equals(item.Value)).ToList();
                                else resList = resList.Where(x => x[item.Key].Contains(item.Value)).ToList();
                            }
                        }
                        if (input.sidx.IsNotEmptyOrNull())
                        {
                            if (input.sort.Equals("desc")) resList = resList.OrderBy(x => x[input.sidx]).ToList();
                            else resList = resList.OrderByDescending(x => x[input.sidx]).ToList();
                        }
                        output = new
                        {
                            pagination = new PageResult()
                            {
                                currentPage = input.currentPage,
                                pageSize = input.pageSize,
                                total = resList.Count
                            },
                            list = resList.Skip((input.currentPage - 1) * input.pageSize).Take(input.pageSize).ToList(),
                        };
                    }
                    else
                    {
                        output = new
                        {
                            pagination = new PageResult()
                            {
                                currentPage = input.currentPage,
                                pageSize = input.pageSize,
                                total = resList.Count
                            },
                            list = resList.Skip((input.currentPage - 1) * input.pageSize).Take(input.pageSize).ToList(),
                        };
                    }
                }
                else
                {
                    output = result;
                }
            }
            #endregion

            return output;
        }
        catch (Exception e)
        {
            return new List<object>();
        }
    }

    /// <summary>
    /// 处理远端数据.
    /// </summary>
    /// <param name="propsUrl">远端数据ID.</param>
    /// <param name="value">指定选项标签为选项对象的某个属性值.</param>
    /// <param name="label">指定选项的值为选项对象的某个属性值.</param>
    /// <param name="children">指定选项的子选项为选项对象的某个属性值.</param>
    /// <returns></returns>
    [NonAction]
    public async Task<List<StaticDataModel>> GetDynamicList(string propsUrl, string value, string label, string children)
    {
        List<StaticDataModel> list = new List<StaticDataModel>();

        // 获取远端数据
        DataInterfaceEntity? dynamic = await _repository.AsQueryable().Where(x => x.Id == propsUrl && x.DeleteMark == null).FirstAsync();
        if (dynamic == null) return list;

        list = await GetDynamicDataCache(dynamic.Id);

        if (list == null || list.Count == 0)
        {
            list = new List<StaticDataModel>();
            // 远端数据 配置参数
            List<SugarParameter>? parameter = new List<SugarParameter>();

            // 未数据处理
            var resList = string.Empty;

            // 数据处理结果
            var dataProcessingResults = string.Empty;
            // 获取数据
            switch (dynamic.DataType)
            {
                // SQL数据
                case 1:
                    {

                        DbLinkEntity? linkEntity = await _repository.AsSugarClient().Queryable<DbLinkEntity>().Where(m => m.Id == dynamic.DBLinkId && m.DeleteMark == null).FirstAsync();
                        if (linkEntity == null) linkEntity = _dataBaseManager.GetTenantDbLink(_userManager.TenantId, _userManager.TenantDbName);
                        ReplaceParameterValue(dynamic, new Dictionary<string, string>());
                        var sql = await GetSqlParameter(dynamic.Query, parameter);
                        DataTable? dt = _dataBaseManager.GetInterFaceData(linkEntity, sql, parameter.ToArray());
                        resList = dt.ToJsonString();
                    }

                    break;

                // 静态数据
                case 2:
                    {
                        resList = JValue.Parse(dynamic.Query).ToJsonString();
                    }

                    break;

                // Api数据
                case 3:
                    {
                        var result = await GetApiDataByTypePreview(dynamic);
                        resList = result.ToJsonString();
                    }

                    break;
            }
            // 处理数据
            switch (dynamic.DataType)
            {
                // SQL数据
                case 1:
                // Api数据
                case 3:
                    if (!dynamic.DataProcessing.IsNullOrEmpty())
                    {
                        string sheetData = Regex.Match(dynamic.DataProcessing, @"\{(.*)\}", RegexOptions.Singleline).Groups[1].Value;
                        var scriptStr = "var result = function(data){data = JSON.parse(data);" + sheetData + "}";
                        try
                        {
                            dataProcessingResults = JsEngineUtil.CallFunction(scriptStr, resList).ToJsonString();
                        }
                        catch (Exception)
                        {
                            dataProcessingResults = string.Empty;
                        }
                    }
                    else
                    {
                        dataProcessingResults = resList;
                    }
                    break;
                // 静态数据
                case 2:
                    dataProcessingResults = resList;
                    break;
            }
            if (!dataProcessingResults.IsNullOrEmpty())
            {
                foreach (JToken? item in JToken.Parse(dataProcessingResults))
                {
                    StaticDataModel dynamicDic = new StaticDataModel()
                    {
                        id = item.Value<string>(value),
                        fullName = item.Value<string>(label)
                    };
                    list.Add(dynamicDic);

                    // 为避免子级有数据.
                    if (item.Value<object>(children) != null && item.Value<object>(children).ToString().IsNotEmptyOrNull())
                        list.AddRange(GetDynamicInfiniteData(item.Value<object>(children).ToString(), value, label, children));
                }
                await SetDynamicDataCache(dynamic.Id, list);
            }
        }
        return list;
    }

    #endregion

    #region PrivateMethod

    /// <summary>
    /// 获取动态无限级数据.
    /// </summary>
    /// <param name="data"></param>
    /// <param name="value">指定选项标签为选项对象的某个属性值.</param>
    /// <param name="label">指定选项的值为选项对象的某个属性值.</param>
    /// <param name="children">指定选项的子选项为选项对象的某个属性值.</param>
    /// <returns></returns>
    private List<StaticDataModel> GetDynamicInfiniteData(string data, string value, string label, string children)
    {
        List<StaticDataModel> list = new List<StaticDataModel>();
        foreach (JToken? info in JToken.Parse(data))
        {
            StaticDataModel dic = new StaticDataModel()
            {
                id = info.Value<string>(value),
                fullName = info.Value<string>(label)
            };
            list.Add(dic);
            if (info.Value<object>(children) != null && info.Value<object>(children).ToString() != string.Empty)
                list.AddRange(GetDynamicInfiniteData(info.Value<object>(children).ToString(), value, label, children));
        }

        return list;
    }

    /// <summary>
    /// 通过连接执行sql.
    /// </summary>
    /// <returns></returns>
    private async Task<DataTable> connection(string dbLinkId, string sql, string reqMethod)
    {
        var link = new DbLinkEntity();
        if (!_sqlSugarClient.AsTenant().IsAnyConnection(_configId))
        {
            link = await _sqlSugarClient.CopyNew().Queryable<DbLinkEntity>().FirstAsync(x => x.Id == dbLinkId && x.DeleteMark == null);
        }
        else
        {
            link = await _repository.AsSugarClient().CopyNew().Queryable<DbLinkEntity>().FirstAsync(x => x.Id == dbLinkId && x.DeleteMark == null);
        }

        var tenantLink = link ?? await GetTenantDbLink();
        var parameter = new List<SugarParameter>();
        sql = await GetSqlParameter(sql, parameter);
        if (reqMethod.Equals("3"))
        {
            return _dataBaseManager.GetInterFaceDataCopyNew(tenantLink, sql, parameter.ToArray());
        }
        else
        {
            _dataBaseManager.ExecuteCommand(tenantLink, sql, parameter.ToArray());
            return new DataTable();
        }
    }

    /// <summary>
    /// 根据不同规则请求接口(预览).
    /// </summary>
    /// <param name="entity"></param>
    /// <returns></returns>
    private async Task<JObject> GetApiDataByTypePreview(DataInterfaceEntity entity)
    {
        var result = new JObject();
        var parameters = entity?.RequestParameters.ToObject<List<DataInterfaceReqParameter>>() ?? new List<DataInterfaceReqParameter>();
        var parametersHerader = entity?.RequestHeaders.ToObject<List<DataInterfaceReqParameter>>() ?? new List<DataInterfaceReqParameter>();
        var dic = new Dictionary<string, object>();
        var dicHerader = new Dictionary<string, object>();
        dicHerader.Add("JNPF_API", true);
        if (_userManager.ToKen != null && !_userManager.ToKen.Contains("::"))
            dicHerader.Add("Authorization", _userManager.ToKen);
        foreach (var key in parameters)
        {
            dic.Add(key.field, key.defaultValue);
        }

        foreach (var key in parametersHerader)
        {
            dicHerader[key.field] = key.defaultValue;
        }

        try
        {
            string tempPath = entity.Path;
            if (!string.IsNullOrEmpty(tempPath) && !tempPath.StartsWith("http"))
            {
                tempPath = $"{App.HttpContext.Request.Scheme}://{App.HttpContext.Request.Host}{tempPath}";
            }
            switch (entity.RequestMethod)
            {
                case "6":
                    result = (await tempPath.SetHeaders(dicHerader).SetQueries(dic).GetAsStringAsync()).ToObject<JObject>();
                    break;
                case "7":
                    result = (await tempPath.SetHeaders(dicHerader).SetBody(dic).PostAsStringAsync()).ToObject<JObject>();
                    break;
            }
        }
        catch (Exception e)
        {
            throw Oops.Oh(ErrorCode.COM1018);
        }
        return result.ContainsKey("data") && result["data"].IsNotEmptyOrNull() ? result["data"].ToObject<JObject>() : result;
    }

    /// <summary>
    /// DataTable 数据分页.
    /// </summary>
    /// <param name="dt">数据源.</param>
    /// <param name="PageIndex">第几页.</param>
    /// <param name="PageSize">每页多少条.</param>
    /// <returns></returns>
    public static DataTable GetPageToDataTable(DataTable dt, int PageIndex, int PageSize)
    {
        if (PageIndex == 0)
            return dt; // 0页代表每页数据，直接返回

        if (dt == null)
        {
            return new DataTable();
        }

        DataTable newdt = dt.Copy();
        newdt.Clear(); // copy dt的框架

        int rowbegin = (PageIndex - 1) * PageSize;
        int rowend = PageIndex * PageSize; // 要展示的数据条数

        if (rowbegin >= dt.Rows.Count)
            return dt; // 源数据记录数小于等于要显示的记录，直接返回dt

        if (rowend > dt.Rows.Count)
            rowend = dt.Rows.Count;
        for (int i = rowbegin; i <= rowend - 1; i++)
        {
            DataRow newdr = newdt.NewRow();
            DataRow dr = dt.Rows[i];
            foreach (DataColumn column in dt.Columns)
            {
                newdr[column.ColumnName] = dr[column.ColumnName];
            }

            newdt.Rows.Add(newdr);
        }

        return newdt;
    }

    /// <summary>
    /// 获取多租户Link.
    /// </summary>
    /// <returns></returns>
    [NonAction]
    public async Task<DbLinkEntity> GetTenantDbLink()
    {
        return new DbLinkEntity
        {
            Id = _configId,
            ServiceName = _dbName,
            DbType = App.Configuration["ConnectionStrings:DBType"],
            Host = App.Configuration["ConnectionStrings:Host"],
            Port = App.Configuration["ConnectionStrings:Port"].ParseToInt(),
            UserName = App.Configuration["ConnectionStrings:UserName"],
            Password = App.Configuration["ConnectionStrings:Password"]
        };
    }

    /// <summary>
    /// 替换参数默认值.
    /// </summary>
    /// <param name="entity"></param>
    /// <param name="dic"></param>
    [NonAction]
    public void ReplaceParameterValue(DataInterfaceEntity entity, Dictionary<string, string> dic)
    {
        if (dic.IsNotEmptyOrNull() && entity.IsNotEmptyOrNull() && entity.RequestParameters.IsNotEmptyOrNull())
        {
            var parameterList = entity.RequestParameters.ToList<DataInterfaceReqParameter>();
            foreach (var item in parameterList)
            {
                if (dic.Keys.Contains(item.field))
                    item.defaultValue = HttpUtility.UrlDecode(dic[item.field], Encoding.UTF8); // 对参数解码
                if (entity.DataType == 1)
                {
                    // 将开头和结尾的空格去掉
                    item.defaultValue = item.defaultValue?.Trim();

                    // 将逗号替换成一个单引号、逗号、单引号
                    item.defaultValue = item.defaultValue?.Replace(",", "','");
                    entity.Query = entity.Query?.Replace("{" + item.field + "}", item.defaultValue); //自动加引号去掉 modify by ly on 20230515
                }
                else
                    entity.Query = entity.Query?.Replace("{" + item.field + "}", item.defaultValue);
            }

            entity.RequestParameters = parameterList.ToJsonString();
        }
    }

    /// <summary>
    /// 获取sql系统变量参数.
    /// </summary>
    /// <param name="sql"></param>
    /// <param name="sugarParameters"></param>
    private async Task<string> GetSqlParameter(string sql, List<SugarParameter> sugarParameters)
    {
        if (_userManager.ToKen != null)
        {
            var userInfo = await _userManager.GetUserInfo();
            if (sql.Contains("@currentUsersAndSubordinates"))
            {
                var subordinates = userInfo.subordinates.ToList();
                subordinates.Add(_userManager.UserId);
                sugarParameters.Add(new SugarParameter("@currentUsersAndSubordinates", subordinates));
            }
            if (sql.Contains("@organization"))
            {
                sugarParameters.Add(new SugarParameter("@organization", _userManager?.User?.OrganizeId));
            }
            if (sql.Contains("@currentOrganizationAndSuborganization"))
            {
                var subsidiary = userInfo.subsidiary.ToList();
                subsidiary.Add(_userManager.User.OrganizeId);
                sugarParameters.Add(new SugarParameter("@currentOrganizationAndSuborganization", subsidiary));
            }
            if (sql.Contains("@chargeorganization"))
            {
                var chargeorganization = userInfo.dataScope.Where(x => x.organizeId == userInfo.organizeId && x.Select).ToList().FirstOrDefault();
                sugarParameters.Add(new SugarParameter("@chargeorganization", chargeorganization?.organizeId));
            }
            if (sql.Contains("@currentChargeorganizationAndSuborganization"))
            {
                var subsidiary = userInfo.dataScope.Select(x => x.organizeId).Intersect(userInfo.subsidiary).ToList();
                sugarParameters.Add(new SugarParameter("@currentChargeorganizationAndSuborganization", subsidiary));
            }
            if (sql.Contains("@user"))
            {
                sql = sql.Replace("@user", "'" + _userManager.UserId + "'"); // orcale关键字处理
            }
        }
        return sql;
    }

    /// <summary>
    /// 验证必填参数.
    /// </summary>
    /// <param name="entity"></param>
    /// <param name="dataInterfaceReqParameters"></param>
    private void VerifyRequired(DataInterfaceEntity entity, Dictionary<string, string> dicParams)
    {
        try
        {
            if (entity.IsNotEmptyOrNull() && entity.RequestParameters.IsNotEmptyOrNull() && !entity.RequestParameters.Equals("[]"))
            {
                var reqParams = entity.RequestParameters.ToList<DataInterfaceReqParameter>();
                if (reqParams.Count > 0)
                {
                    // 必填参数
                    var requiredParams = reqParams.Where(x => x.required == "1").ToList();
                    if (requiredParams.Any() && (dicParams.IsNullOrEmpty() || dicParams.Keys.Count == 0))
                        throw Oops.Oh(ErrorCode.xg1003);
                    foreach (var item in requiredParams)
                    {
                        if (dicParams.ContainsKey(item.field))
                        {
                            switch (item.dataType)
                            {
                                case "varchar":
                                    if (dicParams[item.field].IsNullOrEmpty())
                                    {
                                        throw Oops.Oh(item.field + "不能为空");
                                    }
                                    break;
                                case "int":
                                    dicParams[item.field].ParseToInt();
                                    break;
                                case "datetime":
                                    dicParams[item.field].ParseToDateTime();
                                    break;
                                case "decimal":
                                    dicParams[item.field].ParseToDecimal();
                                    break;
                            }
                        }
                        else
                        {
                            throw Oops.Oh(item.field + "不能为空");
                        }
                    }
                }
            }
        }
        catch (AppFriendlyException ex)
        {
            throw Oops.Oh(ErrorCode.xg1003);
        }
    }

    /// <summary>
    /// 外部接口验证并请求.
    /// </summary>
    /// <param name="id"></param>
    /// <param name="tenantId"></param>
    /// <param name="dic"></param>
    /// <returns></returns>
    private async Task<dynamic> InterfaceVerify(string id, string tenantId, Dictionary<string, string> dic)
    {
        UserAgent userAgent = new UserAgent(App.HttpContext);
        var authorization = App.HttpContext.Request.Headers["Authorization"].ToString();
        if (authorization.IsNullOrEmpty())
            throw Oops.Oh(ErrorCode.IO0001);
        var ymDate = App.HttpContext.Request.Headers["YmDate"].ToString();
        if (ymDate.IsNullOrEmpty())
            throw Oops.Oh(ErrorCode.IO0002);
        var appId = authorization.Split("::")[0];
        var appSecret = authorization.Split("::")[1];
        if (KeyVariable.MultiTenancy)
        {
            tenantId = tenantId.IsNullOrEmpty() ? _userManager.TenantId : tenantId;
            var interFace = App.Configuration["Tenant:MultiTenancyDBInterFace"] + tenantId;
            var response = await interFace.GetAsStringAsync();
            var result = response.ToObject<RESTfulResult<TenantInterFaceOutput>>();
            if (result.code != 200)
                throw Oops.Oh(result.msg);
            else if (result.data.dotnet == null)
                throw Oops.Oh(ErrorCode.D1025);
            if (!_sqlSugarClient.IsAnyConnection(tenantId))
            {
                _sqlSugarClient.AddConnection(new ConnectionConfig()
                {
                    DbType = (SqlSugar.DbType)Enum.Parse(typeof(SqlSugar.DbType), App.Configuration["ConnectionStrings:DBType"]),
                    ConfigId = tenantId, // 设置库的唯一标识
                    IsAutoCloseConnection = true,
                    ConnectionString = string.Format($"{App.Configuration["ConnectionStrings:DefaultConnection"]}", result.data.dotnet)
                });
            }

            if (!"default".Equals(tenantId) && KeyVariable.MultiTenancyType.Equals("COLUMN"))
            {
                _sqlSugarClient.QueryFilter.AddTableFilter<ITenantFilter>(it => it.TenantId == tenantId);
            }
            else
            {
                _sqlSugarClient.ChangeDatabase(tenantId);
            }
            _configId = tenantId;
            _dbName = result.data.dotnet;
        }
        var interfaceEntity = await _sqlSugarClient.Queryable<InterfaceOauthEntity>().FirstAsync(x => x.AppId == appId && x.DeleteMark == null && x.EnabledMark == 1);
        if (interfaceEntity.IsNullOrEmpty() || interfaceEntity.DataInterfaceIds.IsNullOrEmpty() || !interfaceEntity.DataInterfaceIds.Contains(id))
            throw Oops.Oh(ErrorCode.IO0003);
        if (interfaceEntity.WhiteList.IsNotEmptyOrNull())
        {
            var ipList = interfaceEntity.WhiteList.Split(",").ToList();
            if (!ipList.Contains(App.HttpContext.GetLocalIpAddressToIPv4()))
                throw Oops.Oh(ErrorCode.D9002);
        }
        if (interfaceEntity.UsefulLife.IsNotEmptyOrNull() && interfaceEntity.UsefulLife < DateTime.Now)
            throw Oops.Oh(ErrorCode.IO0004);
        if (interfaceEntity.VerifySignature == 1)
        {
            if (DateTime.Now > ymDate.TimeStampToDateTime().AddMinutes(1))
                throw Oops.Oh(ErrorCode.IO0004);
            var signature = GetVerifySignature(interfaceEntity, id, ymDate);
            if (authorization != signature)
                throw Oops.Oh(ErrorCode.IO0003);
        }
        else
        {
            if (interfaceEntity.AppSecret != appSecret)
                throw Oops.Oh(ErrorCode.IO0003);
        }

        var sw = new Stopwatch();
        sw.Start();
        object output = null;
        var info = await GetInfo(id);
        if (info != null && info.EnabledMark == 0)
            throw Oops.Oh(ErrorCode.IO0003);
        VerifyRequired(info, dic);
        ReplaceParameterValue(info, dic);
        if (info.DataType == 1)
        {
            var link = new DbLinkEntity();
            if (!_sqlSugarClient.AsTenant().IsAnyConnection(_configId))
            {
                link = await _sqlSugarClient.Queryable<DbLinkEntity>().FirstAsync(x => x.Id == info.DBLinkId && x.DeleteMark == null);
            }
            else
            {
                link = await _repository.AsSugarClient().Queryable<DbLinkEntity>().FirstAsync(x => x.Id == info.DBLinkId && x.DeleteMark == null);
            }

            var tenantLink = link ?? await GetTenantDbLink();
            output = _dataBaseManager.GetInterFaceData(tenantLink, info.Query);
        }
        else if (info.DataType == 2)
        {
            output = info.Query.ToObject<object>();
        }
        else
        {
            output = await GetApiDataByTypePreview(info);
        }
        if (info.DataProcessing.IsNotEmptyOrNull())
        {
            string sheetData = Regex.Match(info.DataProcessing, @"\{(.*)\}", RegexOptions.Singleline).Groups[1].Value;
            var scriptStr = "var result = function(data){data = JSON.parse(data);" + sheetData + "}";
            output = JsEngineUtil.CallFunction(scriptStr, output.ToJsonString());
        }
        sw.Stop();

        #region 插入日志

        if (App.HttpContext.IsNotEmptyOrNull())
        {
            var httpContext = App.HttpContext;
            var headers = httpContext.Request.Headers;
            var log = new DataInterfaceLogEntity()
            {
                Id = SnowflakeIdHelper.NextId(),
                OauthAppId = appId,
                InvokId = id,
                InvokTime = DateTime.Now,
                InvokIp = httpContext.GetLocalIpAddressToIPv4(),
                InvokDevice = string.Format("{0}-{1}", userAgent.OS.ToString(), userAgent.RawValue),
                InvokWasteTime = (int)sw.ElapsedMilliseconds,
                InvokType = httpContext.Request.Method
            };
            await _sqlSugarClient.Insertable(log).ExecuteCommandAsync();
        }

        #endregion

        return output;
    }

    /// <summary>
    /// HMACSHA256加密.
    /// </summary>
    /// <param name="entity"></param>
    /// <param name="interfaceId"></param>
    /// <param name="ymDate"></param>
    /// <returns></returns>
    private string GetVerifySignature(InterfaceOauthEntity entity, string interfaceId, string ymDate)
    {
        string secret = entity.AppSecret;
        string method = "POST";
        string urlPath = string.Format("/dev/api/system/DataInterface/{0}/Actions/Response", interfaceId);
        string YmDate = ymDate;
        string host = App.HttpContext.Request.Host.ToString();
        string source = new StringBuilder().Append(method).Append('\n').Append(urlPath).Append('\n')
                .Append(YmDate).Append('\n').Append(host).ToString();
        using (var hmac = new HMACSHA256(secret.ToBase64String().ToBytes()))
        {
            byte[] hashmessage = hmac.ComputeHash(source.ToBytes(Encoding.UTF8));
            var signature = hashmessage.ToHexString();
            return entity.AppId + "::" + signature;
        }
    }

    /// <summary>
    /// 获取代码生成远端数据缓存.
    /// </summary>
    /// <param name="dynamicId">远端数据ID.</param>
    /// <returns></returns>
    private async Task<List<StaticDataModel>> GetDynamicDataCache(string dynamicId)
    {
        string cacheKey = string.Format("{0}{1}_{2}", CommonConst.CodeGenDynamic, _userManager.ConnectionConfig.ConfigId, dynamicId);
        return await _cacheManager.GetAsync<List<StaticDataModel>>(cacheKey);
    }

    /// <summary>
    /// 保存代码生成远端数据缓存.
    /// </summary>
    /// <param name="dynamicId">远端数据ID.</param>
    /// <param name="list">在线用户列表.</param>
    /// <returns></returns>
    private async Task<bool> SetDynamicDataCache(string dynamicId, List<StaticDataModel> list)
    {
        string cacheKey = string.Format("{0}{1}_{2}", CommonConst.CodeGenDynamic, _userManager.ConnectionConfig.ConfigId, dynamicId);
        return await _cacheManager.SetAsync(cacheKey, list, TimeSpan.FromMinutes(3));
    }

    #endregion
}