tnb.server/system/Tnb.Systems/System/ModuleDataAuthorizeLinkService.cs

using JNPF.Common.Core.Manager;
using JNPF.Common.Dtos.DataBase;
using JNPF.Common.Enums;
using JNPF.Common.Extension;
using JNPF.Common.Filter;
using JNPF.Common.Security;
using JNPF.DependencyInjection;
using JNPF.DynamicApiController;
using JNPF.FriendlyException;
using JNPF.Systems.Entitys.Dto.System.ModuleDataAuthorizeLink;
using JNPF.Systems.Entitys.System;
using JNPF.VisualDev.Engine.Core;
using JNPF.VisualDev.Entitys;
using Mapster;
using Microsoft.AspNetCore.Mvc;
using Newtonsoft.Json.Linq;
using SqlSugar;

namespace JNPF.Systems;

/// <summary>
/// 数据权限连接管理
/// 版 本：V3.2
/// 版 权：拓通智联科技有限公司（http://www.tuotong-tech.com）
/// 日 期：2021-06-01.
/// </summary>
[ApiDescriptionSettings(Tag = "System", Name = "ModuleDataAuthorizeLink", Order = 214)]
[Route("api/system/[controller]")]
public class ModuleDataAuthorizeLinkService : IDynamicApiController, ITransient
{
    /// <summary>
    /// 服务基础仓储.
    /// </summary>
    private readonly ISqlSugarRepository<ModuleDataAuthorizeLinkEntity> _repository;

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

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

    /// <summary>
    /// 初始化一个<see cref="ModuleDataAuthorizeSchemeService"/>类型的新实例.
    /// </summary>
    public ModuleDataAuthorizeLinkService(
        ISqlSugarRepository<ModuleDataAuthorizeLinkEntity> repository,
        IDataBaseManager dataBaseManager,
        IUserManager userManager)
    {
        _repository = repository;
        _dataBaseManager = dataBaseManager;
        _userManager = userManager;
    }

    #region GET

    /// <summary>
    /// 代码生成字段列表.
    /// </summary>
    /// <param name="linkId">连接id.</param>
    /// <param name="tableName">表名.</param>
    /// <param name="input">分页参数.</param>
    /// <returns></returns>
    [HttpGet("{linkId}/Tables/{tableName}/Fields/{menuType}/{dataType}")]
    public async Task<dynamic> GetList(string linkId, string tableName, string menuType, string dataType, [FromQuery] PageInputBase input)
    {
        var link = await _repository.AsSugarClient().Queryable<DbLinkEntity>().FirstAsync(x => x.Id == linkId && x.DeleteMark == null);
        if (string.IsNullOrEmpty(tableName)) return new PageResult();
        var tenantLink = link ?? _dataBaseManager.GetTenantDbLink(_userManager.TenantId, _userManager.TenantDbName);
        var data = _dataBaseManager.GetFieldList(tenantLink, tableName).Adapt<List<TableFieldOutput>>();
        if (input.keyword.IsNotEmptyOrNull())
            data = data.FindAll(a => a.field.Contains(input.keyword) || (a.fieldName.IsNotEmptyOrNull() && a.fieldName.Contains(input.keyword))).ToList();
        if (menuType == "2" && dataType != "3")
        {
            data.ForEach(item =>
            {
                item.field = item.field.ReplaceRegex("^f_", string.Empty).ParseToPascalCase().ToLowerCase();
            });
        }
        var pageList = new SqlSugarPagedList<TableFieldOutput>()
        {
            list = data.Skip((input.currentPage - 1) * input.pageSize).Take(input.pageSize).ToList(),
            pagination = new Pagination()
            {
                CurrentPage = input.currentPage,
                PageSize = input.pageSize,
                Total = data.Count
            }
        };
        return PageResult<TableFieldOutput>.SqlSugarPageResult(pageList);
    }

    /// <summary>
    /// 信息.
    /// </summary>
    /// <param name="menudId"></param>
    /// <param name="type"></param>
    /// <returns></returns>
    [HttpGet("getInfo/{menudId}/{type}")]
    public async Task<dynamic> GetInfo_Api(string menudId, string type)
    {
        var data = await _repository.GetFirstAsync(x => x.ModuleId == menudId && x.Type == type);
        return data.Adapt<ModuleDataAuthorizeLinkInfoOutput>();
    }

    /// <summary>
    /// 获取表名列表.
    /// </summary>
    /// <param name="menudId"></param>
    /// <param name="type"></param>
    /// <returns></returns>
    [HttpGet("getVisualTables/{menuId}/{type}")]
    public async Task<dynamic> GetVisualTables(string menuId, string type)
    {
        var tableOutput = new ModuleDataAuthorizeLinkTableOutput();
        var moduleEntity = await _repository.AsSugarClient().Queryable<ModuleEntity>().FirstAsync(x => x.Id == menuId && x.DeleteMark == null);
        if (moduleEntity.Type == 3)
        {
            var visualDevId = moduleEntity.PropertyJson.ToObject<JObject>()["moduleId"].ToString();
            var visualDevEntity = await _repository.AsSugarClient().Queryable<VisualDevEntity>().FirstAsync(x => x.Id == visualDevId && x.DeleteMark == null);
            var tInfo = new TemplateParsingBase(visualDevEntity);
            tableOutput.linkId = visualDevEntity.DbLinkId;
            tableOutput.linkTables = tInfo.AllTable.Select(x => x.table).ToList();
        }

        if (moduleEntity.Type == 2)
        {
            var data = await _repository.GetFirstAsync(x => x.ModuleId == menuId && x.Type == type);
            if (data.IsNotEmptyOrNull())
            {
                tableOutput.linkId = data.LinkId;
                tableOutput.linkTables = data.LinkTables.Split(",").ToList();
            }
        }


        return tableOutput;
    }
    #endregion

    #region POST

    /// <summary>
    /// 保存数据.
    /// </summary>
    /// <param name="id">主键值.</param>
    /// <returns></returns>
    [HttpPost("saveLinkData")]
    public async Task SaveLinkData([FromBody] ModuleDataAuthorizeLinkInfoOutput input)
    {
        await _repository.DeleteAsync(x => x.ModuleId == input.moduleId && x.Type == input.dataType);
        var entity = input.Adapt<ModuleDataAuthorizeLinkEntity>();
        entity.Id = SnowflakeIdHelper.NextId();
        entity.Type = input.dataType;
        var isOk = await _repository.AsInsertable(entity).IgnoreColumns(ignoreNullColumn: true).ExecuteCommandAsync();
        if (isOk < 1)
            throw Oops.Oh(ErrorCode.COM1000);
    }
    #endregion
}