using JNPF.Common.Core.Manager;
using JNPF.Common.Models;
@if(Model.IsExport)
{
@:using JNPF.ClayObject;
}
@if(Model.IsImportData || Model.IsExport)
{
@:using JNPF.Common.Models.NPOI;
}
@if(Model.IsImportData)
{
@:using JNPF.Common.CodeGen.ExportImport;
@:using JNPF.Common.Core.Manager.Files;
@:using JNPF.Common.Dtos;
}
using JNPF.Common.CodeGen.DataParsing;
using JNPF.Common.Manager;
using JNPF.Common.Const;
using JNPF.Common.Enums;
using JNPF.Common.Extension;
using JNPF.Common.Filter;
using JNPF.Common.Security;
using JNPF.DatabaseAccessor;
using JNPF.DependencyInjection;
using JNPF.DynamicApiController;
using JNPF.FriendlyException;
using JNPF.Systems.Entitys.System;
using JNPF.Systems.Entitys.Permission;
using JNPF.Systems.Interfaces.System;
@if(Model.IsImportData)
{
@:using JNPF.VisualDev.Engine;
@:using JNPF.VisualDev.Engine.Core;
@:using Microsoft.AspNetCore.Http;
}
using JNPF.@(Model.NameSpace).Entitys.Dto.@Model.ClassName;
@foreach(var table in Model.TableRelations)
{
@*循环出子表的命名空间*@
@:using JNPF.@(Model.NameSpace).Entitys.Dto.@(table.ClassName);
}
using JNPF.@(Model.NameSpace).Entitys;
using JNPF.@(Model.NameSpace).Interfaces;
@if(Model.EnableFlow)
{
@:using JNPF.WorkFlow.Entitys.Entity;
}
using Mapster;
using Microsoft.AspNetCore.Mvc;
using SqlSugar;
namespace JNPF.@(Model.NameSpace);
///
/// 业务实现:@(Model.BusName).
///
[ApiDescriptionSettings(Tag = "@(Model.Type == 3 ? Model.NameSpace + "Form" : Model.NameSpace)", Name = "@Model.ClassName", Order = 200)]
[Route("api/@(Model.Type == 3 ? Model.NameSpace+ "/Form" : Model.NameSpace)/[controller]")]
public class @(Model.ClassName)Service : I@(Model.ClassName)Service, IDynamicApiController, ITransient
{
///
/// 服务基础仓储.
///
private readonly ISqlSugarRepository<@(Model.ClassName)Entity> _repository;
@if(Model.IsBillRule)
{
@:
@:///
@:/// 单据规则服务.
@:///
@:private readonly IBillRullService _billRullService;
}
@if(Model.DbLinkId != "0" || Model.IsImportData)
{
@:
@:///
@:/// 数据库管理.
@:///
@:private readonly IDataBaseManager _dataBaseManager;
}
///
/// 数据接口服务.
///
private readonly IDataInterfaceService _dataInterfaceService;
///
/// 缓存管理.
///
private readonly ICacheManager _cacheManager;
///
/// 通用数据解析.
///
private readonly ControlParsing _controlParsing;
///
/// 用户管理.
///
private readonly IUserManager _userManager;
@if(Model.IsImportData)
{
@:
@:///
@:/// 代码生成导出数据帮助类.
@:///
@:private readonly ExportImportDataHelper _exportImportDataHelper;
@:
@:///
@:/// 文件服务.
@:///
@:private readonly IFileManager _fileManager;
}
@if(Model.DbLinkId != "0")
{
@:
@:///
@:/// 客户端.
@:///
@:private static SqlSugarScope? _sqlSugarClient;
}
@if(Model.IsImportData || Model.IsExport)
{
@:
@:///
@:/// 导出字段.
@:///
@:private readonly List paramList = "[@(Model.ExportField)]".ToList();
}
@if(Model.IsImportData)
{
@:
@{var importField = 0;}
@:///
@:/// 导入字段.
@:///
@:private readonly List childParanList = "[@foreach(var table in Model.TableRelations){@if(table.IsImportData){@(importField == 0 ? "": ", ")@("{\\\"value\\\":\\\"" + table.ControlTableComment + "\\\",\\\"field\\\":\\\""+ table.ControlModel +"\\\"}")importField++;}}]".ToList();
@:
@{importField = 0;}
@:///
@:/// 导入字段.
@:///
@:private readonly string[] uploaderKey = new string[] {@foreach(var table in Model.TableField){@if(table.IsImportField){@(importField==0 ? "\"" + table.OriginalColumnName + "\"" : ", \"" + table.OriginalColumnName + "\"") importField++;}}@foreach(var table in Model.TableRelations){@if(table.IsImportData){@(", \""+ table.ControlModel + "\"")@foreach(var column in table.ChilderColumnConfigList){@if(column.IsImportField){@(", \""+ table.ControlModel + "-" + column.OriginalColumnName + "\"")}}}} };
}
///
/// 初始化一个类型的新实例.
///
public @(Model.ClassName)Service(
ISqlSugarRepository<@(Model.ClassName)Entity> repository,
@if(Model.IsBillRule)
{
@:IBillRullService billRullService,
}
IDataInterfaceService dataInterfaceService,
@if(Model.DbLinkId != "0" || Model.IsImportData)
{
@:IDataBaseManager dataBaseManager,
}
@if(Model.DbLinkId != "0"){
@:ISqlSugarClient context,
}
@if(Model.IsImportData){
@:ExportImportDataHelper exportImportDataHelper,
@:IFileManager fileManager,
}
ICacheManager cacheManager,
ControlParsing controlParsing,
IUserManager userManager)
{
_repository = repository;
@if(Model.IsBillRule)
{
@:_billRullService = billRullService;
}
@if(Model.DbLinkId != "0" || Model.IsImportData)
{
@:_dataBaseManager = dataBaseManager;
}
@if(Model.DbLinkId != "0")
{
@:_sqlSugarClient = (SqlSugarScope)context;
}
@if(Model.IsImportData)
{
@:_exportImportDataHelper = exportImportDataHelper;
@:_fileManager = fileManager;
}
_dataInterfaceService = dataInterfaceService;
_cacheManager = cacheManager;
_controlParsing = controlParsing;
_userManager = userManager;
}
@foreach(var item in Model.Function)
{
@switch(item.FullName)
{
@*信息方法*@
case "info":
@:
@:///
@:/// 获取@(Model.BusName).
@:///
@:/// 主键值.
@:///
@:[HttpGet("{id}")]
@:public async Task GetInfo(@(Model.PrimaryKeyPolicy == 1 ? "string" : Model.EnableFlow ? "string" : "long") id)
@:{
@if(Model.DbLinkId != "0")
{
@:var dbLink = await _repository.AsSugarClient().Queryable().FirstAsync(it => it.Id.Equals("@(Model.DbLinkId)"));
@:_sqlSugarClient = _dataBaseManager.ChangeDataBase(dbLink);
@:
}
@:var data = (await @(Model.DbLinkId != "0" ? "_sqlSugarClient.Queryable<" + Model.ClassName + "Entity>()" : "_repository.AsQueryable()")
@if(Model.IsSystemControl)
{
@:.Select(it => new @(Model.ClassName)Entity
@:{
@*循环展示字段*@
@foreach (var column in Model.TableField){
@if (column.PrimaryKey){
@:@(column.ColumnName) = it.@column.ColumnName,
}else if(column.jnpfKey != null){
@switch(column.jnpfKey)
{
case "modifyUser":
case "createUser":
@:@(column.ColumnName) = SqlFunc.Subqueryable()@(Model.DbLinkId != "0" ? ".AS(\"db_" + Model.ConfigId + "." + Model.DBName + ".dbo.BASE_USER\")" : "").Where(u => u.Id.Equals(it.@(column.ColumnName))).Select(u => SqlFunc.MergeString(u.RealName, "/", u.Account)),
break;
case "currOrganize":
@:@(column.ColumnName) = SqlFunc.Subqueryable()@(Model.DbLinkId != "0" ? ".AS(\"db_" + Model.ConfigId + "." + Model.DBName + ".dbo.BASE_ORGANIZE\")" : "").Where(o => o.Id.Equals(it.@(column.ColumnName))).Select(o => o.FullName),
break;
case "currPosition":
@:@(column.ColumnName) = SqlFunc.Subqueryable()@(Model.DbLinkId != "0" ? ".AS(\"db_" + Model.ConfigId + "." + Model.DBName + ".dbo.BASE_POSITION\")" : "").Where(p => p.Id.Equals(it.@(column.ColumnName))).Select(p => p.FullName),
break;
default:
@:@(column.ColumnName) = it.@column.ColumnName,
break;
}
}
}
@if(Model.ConcurrencyLock)
{
@:Version = it.Version,
}
@:})
}
@:.Where(it => it.@(Model.EnableFlow && Model.PrimaryKeyPolicy == 2 ? "FlowTaskId" : Model.PrimaryKey).Equals(id)).ToListAsync()).Adapt>();
@:
@:await @(Model.DbLinkId != "0" ? "_sqlSugarClient" : "_repository.AsSugarClient()").ThenMapperAsync(data, async item =>
@:{
@foreach(var table in Model.TableRelations)
{
@:item.@table.ControlModel = (await @(Model.DbLinkId != "0" ? "_sqlSugarClient" : "_repository.AsSugarClient()").Queryable<@(table.ClassName)Entity>().SetContextAsync(scl => scl.@(table.TableField), () => item.@(table.LowerRelationField), item)).Adapt>();
}
@:});
@:
@:return data.FirstOrDefault();
@:}
break;
@*流程保存*@
case "save":
@:
@:///
@:/// 保存.
@:///
@:/// 主键值.
@:/// 表单数据.
@:///
@:[HttpPost("{id}")]
@:public async Task Save(string id, [FromBody] @(Model.ClassName)CrInput input)
@:{
@*跨库*@
@if(Model.DbLinkId != "0")
{
@:var dbLink = await _repository.AsSugarClient().Queryable().FirstAsync(it => it.Id.Equals("@(Model.DbLinkId)"));
@:_sqlSugarClient = _dataBaseManager.ChangeDataBase(dbLink);
@:
}
@:var entity = input.Adapt<@(Model.ClassName)Entity>();
@:entity.@(Model.PrimaryKeyPolicy == 1 ? Model.PrimaryKey : "FlowTaskId") = id;
@:if (await @(Model.DbLinkId != "0" ? "_sqlSugarClient.Queryable<" + Model.ClassName + "Entity>()." : "_repository.Is")AnyAsync(it => it.@(Model.PrimaryKeyPolicy == 1 ? Model.PrimaryKey : "FlowTaskId").Equals(id)@(Model.PrimaryKeyPolicy == 2 ? " || it." + Model.PrimaryKey + ".Equals(id)" : "")))
@:{
@if(Model.PrimaryKeyPolicy == 2)
{
@:entity.Id = (await @(Model.DbLinkId != "0" ? "_sqlSugarClient.Queryable<" + Model.ClassName + "Entity>()." : "_repository.Get")FirstAsync(it=> it.FlowTaskId.Equals(entity.FlowTaskId)@(Model.PrimaryKeyPolicy == 2 ? " || it." + Model.PrimaryKey + ".Equals(entity.FlowTaskId)" : ""))).Id;
}
@{ GetAndModifyDataMethodTemplate(); }
@:}
@:else
@:{
@{ GetTheNewDataMethodTemplate(); }
@:}
@:}
break;
@*新增*@
case "add":
@:
@:///
@:/// 新建@(Model.BusName).
@:///
@:/// 参数.
@:///
@:[HttpPost("")]
@:[UnitOfWork]
@:public async Task Create([FromBody] @(Model.ClassName)CrInput input)
@:{
@*跨库*@
@if(Model.DbLinkId != "0")
{
@:var dbLink = await _repository.AsSugarClient().Queryable().FirstAsync(it => it.Id.Equals("@(Model.DbLinkId)"));
@:_sqlSugarClient = _dataBaseManager.ChangeDataBase(dbLink);
@:
}
@:var entity = input.Adapt<@(Model.ClassName)Entity>();
@if(Model.PrimaryKeyPolicy == 1)
{
@:entity.@(Model.PrimaryKey) = SnowflakeIdHelper.NextId();
}
@{ GetTheNewDataMethodTemplate(); }
@:}
break;
@*编辑*@
case "edit":
@:
@:///
@:/// 更新@(Model.BusName).
@:///
@:/// 主键值.
@:/// 参数.
@:///
@:[HttpPut("{id}")]
@:[UnitOfWork]
@:public async Task Update(@(Model.PrimaryKeyPolicy == 1 ? "string" : "long") id, [FromBody] @(Model.ClassName)UpInput input)
@:{
@*跨库*@
@if(Model.DbLinkId != "0")
{
@:var dbLink = await _repository.AsSugarClient().Queryable().FirstAsync(it => it.Id.Equals("@(Model.DbLinkId)"));
@:_sqlSugarClient = _dataBaseManager.ChangeDataBase(dbLink);
@:
}
@:var entity = input.Adapt<@(Model.ClassName)Entity>();
@{ GetAndModifyDataMethodTemplate(); }
@:}
break;
@*删除*@
case "remove":
@:
@:///
@:/// 删除@(Model.BusName).
@:///
@:///
@:[HttpDelete("{id}")]
@:[UnitOfWork]
@:public async Task Delete(@(Model.PrimaryKeyPolicy == 1 ? "string" : "long") id)
@:{
@*跨库*@
@if(Model.DbLinkId != "0")
{
@:var dbLink = await _repository.AsSugarClient().Queryable().FirstAsync(it => it.Id.Equals("@(Model.DbLinkId)"));
@:_sqlSugarClient = _dataBaseManager.ChangeDataBase(dbLink);
@:
}
@:if(!await @(Model.DbLinkId != "0" ? "_sqlSugarClient.Queryable<" + Model.ClassName + "Entity>()." : "_repository.Is")AnyAsync(it => it.@(Model.PrimaryKey) == id))
@:{
@:throw Oops.Oh(ErrorCode.COM1005);
@:}
@:
@:var entity = await @(Model.DbLinkId != "0" ? "_sqlSugarClient.Queryable<" + Model.ClassName + "Entity>()." : "_repository.Get")FirstAsync(it => it.@(Model.PrimaryKey).Equals(id));
@:await @(Model.DbLinkId != "0" ? "_sqlSugarClient.Deleteable<" + Model.ClassName + "Entity>()" : "_repository.AsDeleteable()").Where(it => it.@(Model.PrimaryKey).Equals(id)).ExecuteCommandAsync();
@foreach(var table in Model.TableRelations)
{
@:
@:// 清空@(table.TableComment)表数据
@:await @(Model.DbLinkId != "0" ? "_sqlSugarClient" : "_repository.AsSugarClient()").Deleteable<@(table.ClassName)Entity>().Where(it => it.@(table.TableField).Equals(entity.@(table.RelationField))).ExecuteCommandAsync();
}
@:}
break;
@*分页列表*@
case "page":
@:
@:///
@:/// 获取@(Model.BusName)列表.
@:///
@:/// 请求参数.
@:///
@if(item.IsInterface)
{
@:[HttpPost("List")]
}
@:@(item.IsInterface ? "public" : "private") async Task GetList(@(item.IsInterface ? "[FromBody] " : "")@(Model.ClassName)ListQueryInput input)
@:{
@if(Model.DbLinkId != "0")
{
@:var dbLink = await _repository.AsSugarClient().Queryable().FirstAsync(it => it.Id.Equals("@(Model.DbLinkId)"));
@:_sqlSugarClient = _dataBaseManager.ChangeDataBase(dbLink);
@:
}
@if(Model.UseDataPermission)
{
@:var authorizeWhere = new List();
@foreach(var table in Model.TableRelations)
{
@:var @(table.LowerClassName)AuthorizeWhere = new List();
}
@:
@:// 数据权限过滤
@:if (_userManager.User.IsAdministrator == 0)
@:{
@:var allAuthorizeWhere = await _userManager.GetCodeGenAuthorizeModuleResource<@(Model.ClassName)ListOutput>(input.menuId, "@(Model.OriginalPrimaryKey)", _userManager.UserOrigin.Equals("pc") ? @(Model.PcUseDataPermission) : @(Model.AppUseDataPermission));
@:authorizeWhere = allAuthorizeWhere.Find(it => it.FieldRule == 0)?.conditionalModel;
@foreach(var table in Model.TableRelations)
{
@:@(table.LowerClassName)AuthorizeWhere = allAuthorizeWhere.Find(it => it.FieldRule == 2 && it.TableName.Equals("@(table.OriginalTableName)"))?.conditionalModel;
}
@:}
@:
}
@if(Model.HasSuperQuery)
{
@:var entityInfo = @(Model.DbLinkId != "0" ? "_sqlSugarClient" : "_repository.AsSugarClient()").EntityMaintenance.GetEntityInfo<@(Model.ClassName)Entity>();
@:input.sidx = CodeGenHelper.GetSortRealField(input.sidx, string.Empty, entityInfo, 0);
@:var superQuery = SuperQueryHelper.GetSuperQueryInput(input.superQueryJson, string.Empty, entityInfo, 0);
@:List mainConditionalModel = SuperQueryHelper.GetSuperQueryJson(superQuery);
@:
@foreach(var table in Model.TableRelations)
{
@:entityInfo = @(Model.DbLinkId != "0" ? "_sqlSugarClient" : "_repository.AsSugarClient()").EntityMaintenance.GetEntityInfo<@(table.ClassName)Entity>();
@:superQuery = SuperQueryHelper.GetSuperQueryInput(input.superQueryJson, "@(table.ControlModel)-", entityInfo, 1);
@:List @(table.LowerClassName)ConditionalModel = SuperQueryHelper.GetSuperQueryJson(superQuery);
@:
}
}
@{ GetPrimaryTableQueryFieldTemplate(); }@*主表查询字段*@
@{ GetSubTableQueryFieldTemplate(); }@*子表查询字段*@
@:var data = await @(Model.DbLinkId != "0" ? "_sqlSugarClient.Queryable<" + Model.ClassName + "Entity>()" : "_repository.AsQueryable()")
@{ GetSubTableNavigationQueryConfigurationTemplate(); }@*子表导航查询配置*@
@{ GetPrimaryTableQueryCriteriaTemplate(); }@*主表查询条件*@
@{ GetSubTableQueryCriteriaTemplate();}@*子表查询条件*@
@if(Model.UseDataPermission)
{
@:.Where(authorizeWhere)
@foreach(var table in Model.TableRelations)
{
@:.WhereIF(@(table.LowerClassName)AuthorizeWhere?.Count > 0, it => it.@(table.ClassName)List.Any(@(table.LowerClassName)AuthorizeWhere))
}
}
@if(Model.HasSuperQuery)
{
@:.Where(mainConditionalModel)
@foreach(var table in Model.TableRelations)
{
@:.WhereIF(@(table.LowerClassName)ConditionalModel.Count > 0, it => it.@(table.ClassName)List.Any(@(table.LowerClassName)ConditionalModel))
}
}
@:.OrderByIF(string.IsNullOrEmpty(input.sidx), it => it.@(Model.PrimaryKey)).OrderByIF(!string.IsNullOrEmpty(input.sidx), input.sidx + " " + input.sort)
@:.ToPagedListAsync(input.currentPage, input.pageSize, it => new @(Model.ClassName)ListOutput
@:{
@{ GetTheListDisplayFieldTemplate(); }@*主子模式列表展示字段*@
@:});
@:
@:var inlineEditorList = data.list.Adapt>();
@:
@{ GetMasterTableListDataConversionTemplate(); }@*主表列表数据转换*@
@if(Model.IsChildIndexShow)
{
@:
@:if (!_userManager.UserOrigin.Equals("pc"))
@:{
@{ GetSubTableListDataConversionTemplate(); }@*子表列表数据转换*@
@:}
@:else
@:{
@:foreach (var item in inlineEditorList)
@:{
@foreach (var table in Model.TableRelations)
{
@:item.@(@table.ControlModel) = new List<@(@table.ClassName)ListOutput>();
}
@:}
@:}
}
@if(Model.ParsJnpfKeyConstList.Count>0)
{
@:var resData = inlineEditorList.ToObject>>(CommonConst.options);
@foreach (var jnpfKeyConst in Model.ParsJnpfKeyConstList)
{
@:resData = await _controlParsing.GetParsDataList(resData,"@(jnpfKeyConst[1])","@(jnpfKeyConst[0])",_userManager.TenantId);
}
@:inlineEditorList = resData.ToObject>(CommonConst.options);
}
@:
@:return PageResult<@(@Model.ClassName)InlineEditorOutput>.SqlSugarPageResult(new SqlSugarPagedList<@(@Model.ClassName)InlineEditorOutput>
@:{
@:pagination = data.pagination,
@:list = inlineEditorList
@:});
@:}
break;
case "noPage":
@:
@:///
@:/// 获取@(Model.BusName)无分页列表.
@:///
@:/// 请求参数.
@:///
@if(item.IsInterface)
{
@:[HttpPost("List")]
}
@:@(item.IsInterface ? "public" : "private") async Task GetNoPagingList(@(item.IsInterface ? "[FromBody] " : "")@(Model.ClassName)ListQueryInput input)
@:{
@if(Model.DbLinkId != "0")
{
@:var dbLink = await _repository.AsSugarClient().Queryable().FirstAsync(it => it.Id.Equals("@(Model.DbLinkId)"));
@:_sqlSugarClient = _dataBaseManager.ChangeDataBase(dbLink);
@:
}
@if(Model.UseDataPermission)
{
@:var authorizeWhere = new List();
@foreach(var table in Model.TableRelations)
{
@:var @(table.LowerClassName)AuthorizeWhere = new List();
}
@:
@:// 数据权限过滤
@:if (_userManager.User.IsAdministrator == 0)
@:{
@:var allAuthorizeWhere = await _userManager.GetCodeGenAuthorizeModuleResource<@(Model.ClassName)ListOutput>(input.menuId, "@(Model.OriginalPrimaryKey)", _userManager.UserOrigin.Equals("pc") ? @(Model.PcUseDataPermission) : @(Model.AppUseDataPermission));
@:authorizeWhere = allAuthorizeWhere.Find(it => it.FieldRule == 0)?.conditionalModel;
@foreach(var table in Model.TableRelations)
{
@:@(table.LowerClassName)AuthorizeWhere = allAuthorizeWhere.Find(it => it.FieldRule == 2 && it.TableName.Equals("@(table.OriginalTableName)"))?.conditionalModel;
}
@:}
@:
}
@if(Model.HasSuperQuery)
{
@:var entityInfo = @(Model.DbLinkId != "0" ? "_sqlSugarClient" : "_repository.AsSugarClient()").EntityMaintenance.GetEntityInfo<@(Model.ClassName)Entity>();
@:input.sidx = CodeGenHelper.GetSortRealField(input.sidx, string.Empty, entityInfo, 0);
@:var superQuery = SuperQueryHelper.GetSuperQueryInput(input.superQueryJson, string.Empty, entityInfo, 0);
@:List mainConditionalModel = SuperQueryHelper.GetSuperQueryJson(superQuery);
@:
@foreach(var table in Model.TableRelations)
{
@:entityInfo = @(Model.DbLinkId != "0" ? "_sqlSugarClient" : "_repository.AsSugarClient()").EntityMaintenance.GetEntityInfo<@(table.ClassName)Entity>();
@:superQuery = SuperQueryHelper.GetSuperQueryInput(input.superQueryJson, "@(table.ControlModel)-", entityInfo, 1);
@:List @(table.LowerClassName)ConditionalModel = SuperQueryHelper.GetSuperQueryJson(superQuery);
@:
}
}
@:
@{ GetPrimaryTableQueryFieldTemplate(); }@*主表查询字段*@
@{ GetSubTableQueryFieldTemplate(); }@*子表查询字段*@
@:
@:var list = await @(Model.DbLinkId != "0" ? "_sqlSugarClient.Queryable<" + Model.ClassName + "Entity>()" : "_repository.AsQueryable()")
@{ GetSubTableNavigationQueryConfigurationTemplate(); }@*子表导航查询配置*@
@{ GetPrimaryTableQueryCriteriaTemplate(); }@*主表查询条件*@
@{ GetSubTableQueryCriteriaTemplate();}@*子表查询条件*@
@if(Model.UseDataPermission)
{
@:.Where(authorizeWhere)
@foreach(var table in Model.TableRelations)
{
@:.WhereIF(@(table.LowerClassName)AuthorizeWhere?.Count > 0, it => it.@(table.ClassName)List.Any(@(table.LowerClassName)AuthorizeWhere))
}
}
@if(Model.HasSuperQuery)
{
@:.Where(mainConditionalModel)
@foreach(var table in Model.TableRelations)
{
@:.WhereIF(@(table.LowerClassName)ConditionalModel.Count > 0, it => it.@(table.ClassName)List.Any(@(table.LowerClassName)ConditionalModel))
}
}
@:.OrderByIF(string.IsNullOrEmpty(input.sidx), it => it.@(Model.PrimaryKey)).OrderByIF(!string.IsNullOrEmpty(input.sidx), input.sidx + " " + input.sort)
@:.ToListAsync(it => new @(Model.ClassName)ListOutput
@:{
@{ GetTheListDisplayFieldTemplate(); }@*主子模式列表展示字段*@
@:});
@:
@:var inlineEditorList = list.Adapt>();
@:
@{ GetMasterTableListDataConversionTemplate(); }@*主表列表数据转换*@
@if(Model.IsChildIndexShow)
{
@:
@:if (!_userManager.UserOrigin.Equals("pc"))
@:{
@{ GetSubTableListDataConversionTemplate(); }@*子表列表数据转换*@
@:}
@:else
@:{
@:foreach (var item in inlineEditorList)
@:{
@foreach (var table in Model.TableRelations)
{
@:item.@(@table.ControlModel) = new List<@(@table.ClassName)ListOutput>();
}
@:}
@:}
}
@if(Model.ParsJnpfKeyConstList.Count > 0)
{
@:
@:var resData = inlineEditorList.ToObject>>(CommonConst.options);
@foreach (var jnpfKeyConst in Model.ParsJnpfKeyConstList)
{
@:resData = await _controlParsing.GetParsDataList(resData,"@(jnpfKeyConst[1])","@(jnpfKeyConst[0])",_userManager.TenantId);
}
@:
@:inlineEditorList = resData.ToObject>(CommonConst.options);
}
@:
@:return inlineEditorList;
@:}
break;
@*导出*@
case "download":
@:
@:///
@:/// 导出@(Model.BusName).
@:///
@:/// 请求参数.
@:///
@:[HttpGet("Actions/Export")]
@:public async Task Export([FromQuery] @(Model.ClassName)ListQueryInput input)
@:{
@if(Model.IndexDataType == 3)
{
@:var exportData = new List>();
@:if (input.dataType == 0)
@:exportData = await GetList(input);
@:else
@:exportData = await GetNoPagingList(input);
}else{
@:var exportData = new List<@(Model.ClassName)ListOutput>();
@:if (input.dataType == 0)
@:exportData = Clay.Object(await GetList(input)).Solidify>().list;
@:else
@:exportData = await GetNoPagingList(input);
}
@:var excelName = "@(Model.FullName)";
@:_cacheManager.Set(excelName + ".xls", string.Empty);
@:return CodeGenExportDataHelper.GetDataExport(excelName, input.selectKey, _userManager.UserId,exportData.ToObject>>(), paramList, @((Model.IndexDataType == 3).ToString().ToLower()));
@:}
break;
@*批量删除*@
case "batchRemove":
@:
@:///
@:/// 批量删除@(Model.BusName).
@:///
@:/// 主键数组.
@:///
@:[HttpPost("batchRemove")]
@:[UnitOfWork]
@:public async Task BatchRemove([FromBody] List<@(Model.PrimaryKeyPolicy == 1 ? "string" : "long")> ids)
@:{
@*跨库*@
@if(Model.DbLinkId != "0")
{
@:var dbLink = await _repository.AsSugarClient().Queryable().FirstAsync(it => it.Id.Equals("@(Model.DbLinkId)"));
@:_sqlSugarClient = _dataBaseManager.ChangeDataBase(dbLink);
@:
}
@if(Model.EnableFlow)
{
@:var idList = await @(Model.DbLinkId != "0" ? "_sqlSugarClient.Queryable<" + Model.ClassName + "Entity>()" : "_repository.AsQueryable()").Where(it => ids.Contains(it.@(Model.PrimaryKey))).Select(it => it.@(Model.PrimaryKeyPolicy == 1 ? Model.PrimaryKey : "FlowTaskId")).ToListAsync();
@:
@:// 取差集
@:idList = idList.Except(await GetAllowDeleteFlowTaskList(idList)).ToList();
@:
@:var entitys = await @(Model.DbLinkId != "0" ? "_sqlSugarClient.Queryable<" + Model.ClassName + "Entity>()" : "_repository.AsQueryable()").In(it => it.@(Model.PrimaryKeyPolicy == 1 ? @Model.PrimaryKey : "FlowTaskId"), idList).ToListAsync();
}else{
@:var entitys = await @(Model.DbLinkId != "0" ? "_sqlSugarClient.Queryable<" + Model.ClassName + "Entity>()" : "_repository.AsQueryable()").In(it => it.@(Model.PrimaryKey), ids).ToListAsync();
}
@:if (entitys.Count > 0)
@:{
@:// 批量删除@(Model.BusName)
@if(Model.EnableFlow)
{
@:await @(Model.DbLinkId != "0" ? "_sqlSugarClient.Deleteable<" + Model.ClassName + "Entity>()" : "_repository.AsDeleteable()").In(it => it.@(Model.PrimaryKey), entitys.Select(s => s.@(Model.PrimaryKey)).ToList()).ExecuteCommandAsync();
}else{
@:await @(Model.DbLinkId != "0" ? "_sqlSugarClient.Deleteable<" + Model.ClassName + "Entity>()" : "_repository.AsDeleteable()").In(it => it.@(Model.PrimaryKey), ids).ExecuteCommandAsync();
}
@foreach(var table in Model.TableRelations)
{
@:
@:// 清空@(table.TableComment)表数据
@:await @(Model.DbLinkId != "0" ? "_sqlSugarClient" : "_repository.AsSugarClient()").Deleteable<@(table.ClassName)Entity>().In(u => u.@(table.TableField), entitys.Select(s => s.@(table.RelationField)).ToArray()).ExecuteCommandAsync();
}
@if(Model.EnableFlow)
{
@:
@:await _repository.AsSugarClient().Updateable().SetColumns(it => new FlowTaskEntity()
@:{
@:DeleteMark = 1,
@:DeleteUserId = _userManager.UserId,
@:DeleteTime = SqlFunc.GetDate()
@:}).Where(it => idList.Contains(it.Id)).ExecuteCommandAsync();
}
@:}
@:}
@if(Model.EnableFlow)
{
@:
@:///
@:/// 获取不允许删除任务列表.
@:///
@:/// id数组
@:///
@:private async Task> GetAllowDeleteFlowTaskList(List ids)
@:{
@:return await _repository.AsSugarClient().Queryable().Where(it => ids.Contains(it.ProcessId)).Where(it => !it.Status.Equals(0)).Where(it=> !it.Status.Equals(4)).Select(f => f.ProcessId).ToListAsync();
@:}
}
break;
@*详情*@
case "detail":
@:
@:///
@:/// @(Model.BusName)详情.
@:///
@:/// 主键值.
@:///
@:[HttpGet("Detail/{id}")]
@:public async Task GetDetails(@(Model.PrimaryKeyPolicy == 1 ? "string" : "long") id)
@:{
@if(Model.DbLinkId != "0")
{
@:var dbLink = await _repository.AsSugarClient().Queryable().FirstAsync(it => it.Id.Equals("@(Model.DbLinkId)"));
@:_sqlSugarClient = _dataBaseManager.ChangeDataBase(dbLink);
@:
}
@:var data = (await @(Model.DbLinkId != "0" ? "_sqlSugarClient.Queryable<" + Model.ClassName + "Entity>()" : "_repository.AsQueryable()")
@:.Where(a => a.@(Model.PrimaryKey) == id)
@:.Select(it => new @(Model.ClassName)Entity
@:{
@*循环展示字段*@
@foreach (var column in Model.TableField){
@if (column.PrimaryKey){
@:@(column.ColumnName) = it.@column.ColumnName,
}else if(column.jnpfKey != null){
@switch(column.jnpfKey)
{
case "modifyUser":
case "createUser":
@:@(column.ColumnName) = SqlFunc.Subqueryable()@(Model.DbLinkId != "0" ? ".AS(\"db_" + Model.ConfigId + "." + Model.DBName + ".dbo.BASE_USER\")" : "").Where(u => u.Id.Equals(it.@(column.ColumnName))).Select(u => SqlFunc.MergeString(u.RealName, "/", u.Account)),
break;
case "currOrganize":
@:@(column.ColumnName) = SqlFunc.Subqueryable()@(Model.DbLinkId != "0" ? ".AS(\"db_" + Model.ConfigId + "." + Model.DBName + ".dbo.BASE_ORGANIZE\")" : "").Where(o => o.Id.Equals(it.@(column.ColumnName))).Select(o => o.FullName),
break;
case "currPosition":
@:@(column.ColumnName) = SqlFunc.Subqueryable()@(Model.DbLinkId != "0" ? ".AS(\"db_" + Model.ConfigId + "." + Model.DBName + ".dbo.BASE_POSITION\")" : "").Where(p => p.Id.Equals(it.@(column.ColumnName))).Select(p => p.FullName),
break;
case "switch":
@:@(column.ColumnName) = SqlFunc.IIF(it.@(column.ColumnName) == 0, "@(column.InactiveTxt)", "@(column.ActiveTxt)"),
break;
default:
@:@(column.ColumnName) = it.@column.ColumnName@(column.NetType == "int" ? ".ToString()" : ""),
break;
}
}
}
@:}).ToListAsync()).Adapt>();
@:
@:await @(Model.DbLinkId != "0" ? "_sqlSugarClient" : "_repository.AsSugarClient()").ThenMapperAsync(data, async item =>
@:{
@foreach(var table in Model.TableRelations)
{
@:item.@(table.ControlModel) = (await @(Model.DbLinkId != "0" ? "_sqlSugarClient" : "_repository.AsSugarClient()").Queryable<@(table.ClassName)Entity>().SetContextAsync(scl => scl.@(table.TableField), () => item.@(table.LowerRelationField), item)).Adapt>();
}
@:});
@:
@if(Model.IsConversion)
{
@:await _repository.AsSugarClient().ThenMapperAsync(data, async item =>
@:{
@foreach (var column in Model.TableField)
{
@{var dataCount = column.StaticData != null ? column.StaticData.Count : 0;}
@if(column.IsConversion)
{
@switch(column.jnpfKey)
{
case "select":
@:// @column.ColumnComment
@switch(column.ControlsDataType)
{
case "static":
@:var @(column.LowerColumnName)Data = "[@foreach(var data in column.StaticData){@("{\\\"id\\\":\\\"" + @data.id + "\\\",\\\"fullName\\\":\\\""+ @data.fullName + "\\\"}")@(dataCount == 1 ? "" : ",")dataCount--;}]".ToObject>();
@:if(item.@(column.LowerColumnName) != null)
@:{
@if(!column.IsMultiple)
{
@:item.@(column.LowerColumnName) = @(column.LowerColumnName)Data.Find(it => item.@(column.LowerColumnName).Equals(it.id))?.fullName;
}else{
@:var @(column.LowerColumnName + @column.upperJnpfKey) = item.@(column.LowerColumnName).ToObject>();
@:item.@(column.LowerColumnName) = string.Join(",", @(column.LowerColumnName)Data.FindAll(it => @(column.LowerColumnName + @column.upperJnpfKey).Contains(it.id)).Select(it => it.fullName));
}
@:}
break;
case "dictionary":
@:if(item.@(column.LowerColumnName) != null)
@:{
@if(!column.IsMultiple)
{
@:item.@(column.LowerColumnName) = await _repository.AsSugarClient().Queryable().Where(it => it.@(column.Value == "id" ? "Id" : "EnCode").Equals(item.@(column.LowerColumnName)) && it.DictionaryTypeId.Equals("@(column.propsUrl)")).Select(it => it.FullName).FirstAsync();
}else{
@:var @(column.LowerColumnName + @column.upperJnpfKey) = item.@(column.LowerColumnName).ToObject>();
@:item.@(column.LowerColumnName) = string.Join(",", await _repository.AsSugarClient().Queryable().Where(it => @(column.LowerColumnName + @column.upperJnpfKey).Contains(it.@(column.Value == "id" ? "Id" : "EnCode")) && it.DictionaryTypeId.Equals("@(column.propsUrl)")).Select(it => it.FullName).ToListAsync());
}
@:}
break;
case "dynamic":
@:var @(column.LowerColumnName)Data = await _dataInterfaceService.GetDynamicList("@(column.propsUrl)", "@(column.Value)", "@(column.Label)", "");
@:if(item.@(column.LowerColumnName) != null)
@:{
@if(!column.IsMultiple)
{
@:item.@(column.LowerColumnName) = @(column.LowerColumnName)Data.Find(it => it.id.Equals(item.@(column.LowerColumnName)))?.fullName;
}else{
@:var @(column.LowerColumnName + @column.upperJnpfKey) = item.@(column.LowerColumnName).ToObject>();
@:item.@(column.LowerColumnName) = string.Join(",", @(column.LowerColumnName)Data.FindAll(it => @(column.LowerColumnName + @column.upperJnpfKey).Contains(it.id)).Select(it => it.fullName));
}
@:}
break;
}
@:
break;
case "checkbox":
@:// @column.ColumnComment
@switch(column.ControlsDataType)
{
case "static":
@:var @(column.LowerColumnName)Data = "[@foreach(var data in column.StaticData){@("{\\\"id\\\":\\\"" + @data.id + "\\\",\\\"fullName\\\":\\\""+ @data.fullName + "\\\"}")@(dataCount == 1 ? "" : ",")dataCount--;}]".ToObject>();
@:if(item.@(column.LowerColumnName) != null)
@:{
@:var @(column.LowerColumnName + @column.upperJnpfKey) = item.@(column.LowerColumnName).ToObject>();
@:item.@(column.LowerColumnName) = string.Join(",", @(column.LowerColumnName)Data.FindAll(it => @(column.LowerColumnName + @column.upperJnpfKey).Contains(it.id)).Select(it => it.fullName));
@:}
break;
case "dictionary":
@:if(item.@(column.LowerColumnName) != null)
@:{
@:var @(column.LowerColumnName + @column.upperJnpfKey) = item.@(column.LowerColumnName).ToObject>();
@:item.@(column.LowerColumnName) = string.Join(",", await _repository.AsSugarClient().Queryable().Where(it => @(column.LowerColumnName + @column.upperJnpfKey).Contains(it.@(column.Value == "id" ? "Id" : "EnCode")) && it.DictionaryTypeId.Equals("@(column.propsUrl)")).Select(it => it.FullName).ToListAsync());
@:}
break;
case "dynamic":
@:var @(column.LowerColumnName)Data = await _dataInterfaceService.GetDynamicList("@(column.propsUrl)", "@(column.Value)", "@(column.Label)", "");
@:if(item.@(column.LowerColumnName) != null)
@:{
@:var @(column.LowerColumnName + @column.upperJnpfKey) = item.@(column.LowerColumnName).ToObject>();
@:item.@(column.LowerColumnName) = string.Join(",", @(column.LowerColumnName)Data.FindAll(it => @(column.LowerColumnName + @column.upperJnpfKey).Contains(it.id)).Select(it => it.fullName));
@:}
break;
}
@:
break;
case "radio":
@:// @column.ColumnComment
@switch(column.ControlsDataType)
{
case "dictionary":
@:if(item.@(column.LowerColumnName) != null)
@:{
@:@(column.LowerColumnName) = (await _repository.AsSugarClient().Queryable().FirstAsync(dic => dic.@(column.Value == "id" ? "Id" : "EnCode").Equals(item.@(column.LowerColumnName)) && dic.DictionaryTypeId.Equals("@(column.propsUrl)")))?.FullName;
@:}
break;
case "static":
@:var @(column.LowerColumnName)Data = "[@foreach(var data in column.StaticData){@("{\\\"id\\\":\\\"" + @data.id + "\\\",\\\"fullName\\\":\\\""+ @data.fullName + "\\\"}")@(dataCount == 1 ? "" : ",")dataCount--;}]".ToObject>();
@:if(item.@(column.LowerColumnName) != null)
@:{
@:item.@(column.LowerColumnName) = @(column.LowerColumnName)Data.Find(it => item.@(column.LowerColumnName).Equals(it.id))?.fullName;
@:}
break;
case "dynamic":
@:var @(column.LowerColumnName)Data = await _dataInterfaceService.GetDynamicList("@(column.propsUrl)", "@(column.Value)", "@(column.Label)", "@(column.Children)");
@:if(item.@(column.LowerColumnName) != null)
@:{
@:item.@(column.LowerColumnName) = string.Join(",", @(column.LowerColumnName)Data.Find(it => it.id.Equals(item.@(column.LowerColumnName)))?.fullName);
@:}
break;
}
@:
break;
case "cascader":
@:// @column.ColumnComment
@switch(column.ControlsDataType)
{
case "static":
@:var @(column.LowerColumnName)Data = "[@foreach(var data in column.StaticData){@("{\\\"id\\\":\\\"" + @data.id + "\\\",\\\"fullName\\\":\\\""+ @data.fullName + "\\\"}")@(dataCount == 1 ? "" : ",")dataCount--;}]".ToObject>();
@:if(item.@(column.LowerColumnName) != null)
@:{
@if(!column.IsMultiple)
{
@:var @(column.LowerColumnName + @column.upperJnpfKey) = item.@(column.LowerColumnName).ToObject>();
@:item.@(column.LowerColumnName) = string.Join("@(column.Separator)", @(column.LowerColumnName)Data.FindAll(it => @(column.LowerColumnName + @column.upperJnpfKey).Contains(it.id)).Select(s => s.fullName));
}else{
@:var @(column.LowerColumnName + @column.upperJnpfKey) = item.@(column.LowerColumnName).ToObject>>();
@:var @(column.LowerColumnName)Excessive = new List();
@:foreach (var @(column.LowerColumnName) in @(column.LowerColumnName + @column.upperJnpfKey))
@:{
@:@(column.LowerColumnName)Excessive.Add(string.Join("@(column.Separator)", @(column.LowerColumnName)Data.FindAll(it => @(column.LowerColumnName).Contains(it.id)).Select(s => s.fullName)));
@:}
@:
@:item.@(column.LowerColumnName) = string.Join(",", @(column.LowerColumnName)Excessive);
}
@:}
break;
case "dictionary":
@:if(item.@(column.LowerColumnName) != null)
@:{
@if(!column.IsMultiple)
{
@:var @(column.LowerColumnName + @column.upperJnpfKey) = item.@(column.LowerColumnName).ToObject>();
@:item.@(column.LowerColumnName) = string.Join("@(column.Separator)", await _repository.AsSugarClient().Queryable().Where(it => @(column.LowerColumnName + @column.upperJnpfKey).Contains(it.@(column.Value == "id" ? "Id" : "EnCode")) && it.DictionaryTypeId.Equals("@(column.propsUrl)")).Select(it => it.FullName).ToListAsync());
}else{
@:var @(column.LowerColumnName + @column.upperJnpfKey) = item.@(column.LowerColumnName).ToObject>>();
@:var @(column.LowerColumnName)Excessive = new List();
@:foreach (var @(column.LowerColumnName) in @(column.LowerColumnName + @column.upperJnpfKey))
@:{
@:@(column.LowerColumnName)Excessive.Add(string.Join("@(column.Separator)", await _repository.AsSugarClient().Queryable().Where(it => @(column.LowerColumnName).Contains(it.@(column.Value == "id" ? "Id" : "EnCode")) && it.DictionaryTypeId.Equals("@(column.propsUrl)")).Select(it => it.FullName).ToListAsync()));
@:}
@:
@:item.@(column.LowerColumnName) = string.Join(",", @(column.LowerColumnName)Excessive);
}
@:}
break;
case "dynamic":
@:var @(column.LowerColumnName)Data = await _dataInterfaceService.GetDynamicList("@(column.propsUrl)", "@(column.Value)", "@(column.Label)", "@(column.Children)");
@:if(item.@(column.LowerColumnName) != null)
@:{
@if(!column.IsMultiple)
{
@:var @(column.LowerColumnName + @column.upperJnpfKey) = item.@(column.LowerColumnName).ToObject>();
@:item.@(column.LowerColumnName) = string.Join("@(column.Separator)", @(column.LowerColumnName)Data.FindAll(it => @(column.LowerColumnName + @column.upperJnpfKey).Contains(it.id)).Select(it => it.fullName));
}else{
@:var @(column.LowerColumnName + @column.upperJnpfKey) = item.@(column.LowerColumnName).ToObject>>();
@:var @(column.LowerColumnName)Excessive = new List();
@:foreach (var @(column.LowerColumnName) in @(column.LowerColumnName + @column.upperJnpfKey))
@:{
@:@(column.LowerColumnName)Excessive.Add(string.Join("@(column.Separator)", @(column.LowerColumnName)Data.FindAll(it => @(column.LowerColumnName).Contains(it.id)).Select(it => it.fullName)));
@:}
@:
@:item.@(column.LowerColumnName) = string.Join(",", @(column.LowerColumnName)Excessive);
}
@:}
break;
}
@:
break;
case "comSelect":
@:// @column.ColumnComment
@:if(item.@(column.LowerColumnName) != null)
@:{
@if(!column.IsMultiple)
{
@:var @(column.LowerColumnName + @column.upperJnpfKey) = item.@(column.LowerColumnName).ToObject>();
@:item.@(column.LowerColumnName) = string.Join("/", await _repository.AsSugarClient().Queryable().Where(it => @(column.LowerColumnName + @column.upperJnpfKey).Contains(it.Id)).Select(it => it.FullName).ToListAsync());
}else{
@:var @(column.LowerColumnName + @column.upperJnpfKey) = item.@(column.LowerColumnName).ToObject>>();
@:var @(column.LowerColumnName)Excessive = new List();
@:foreach (var @(column.LowerColumnName) in @(column.LowerColumnName + @column.upperJnpfKey))
@:{
@:@(column.LowerColumnName)Excessive.Add(string.Join("/", await _repository.AsSugarClient().Queryable().Where(it => @(column.LowerColumnName).Contains(it.Id)).Select(it => it.FullName).ToListAsync()));
@:}
@:
@:item.@(column.LowerColumnName) = string.Join(",", @(column.LowerColumnName)Excessive);
}
@:}
@:
break;
case "depSelect":
@:// @column.ColumnComment
@:if(item.@(column.LowerColumnName) != null)
@:{
@if(!column.IsMultiple)
{
@:item.@(column.LowerColumnName) = (await _repository.AsSugarClient().Queryable().FirstAsync(it => it.Id.Equals(item.@(column.LowerColumnName))))?.FullName;
}else{
@:var @(column.LowerColumnName + @column.upperJnpfKey) = item.@(column.LowerColumnName).ToObject>();
@:item.@(column.LowerColumnName) = string.Join(",", await _repository.AsSugarClient().Queryable().Where(it => @(column.LowerColumnName + @column.upperJnpfKey).Contains(it.Id)).Select(it => it.FullName).ToListAsync());
}
@:}
@:
break;
case "posSelect":
@:// @column.ColumnComment
@:if(item.@(column.LowerColumnName) != null)
@:{
@if(!column.IsMultiple)
{
@:item.@(column.LowerColumnName) = (await _repository.AsSugarClient().Queryable().FirstAsync(a => a.Id.Equals(item.@(column.LowerColumnName))))?.FullName;
}else{
@:var @(column.LowerColumnName + @column.upperJnpfKey) = item.@(column.LowerColumnName).ToObject>();
@:item.@(column.LowerColumnName) = string.Join(",", await _repository.AsSugarClient().Queryable().Where(it => @(column.LowerColumnName + @column.upperJnpfKey).Contains(it.Id)).Select(it => it.FullName).ToListAsync());
}
@:}
@:
break;
case "userSelect":
@:// @column.ColumnComment
@:if(item.@(column.LowerColumnName) != null)
@:{
@if(!column.IsMultiple)
{
@:item.@(column.LowerColumnName) = (await _repository.AsSugarClient().Queryable().FirstAsync(it => it.Id.Equals(item.@(column.LowerColumnName))))?.RealName;
}else{
@:var @(column.LowerColumnName + @column.upperJnpfKey) = item.@(column.LowerColumnName).ToObject>();
@:item.@(column.LowerColumnName) = string.Join(",", await _repository.AsSugarClient().Queryable().Where(it => @(column.LowerColumnName + @column.upperJnpfKey).Contains(it.Id)).Select(it => it.RealName).ToListAsync());
}
@:}
@:
break;
case "roleSelect":
@:// @column.ColumnComment
@:if(item.@(column.LowerColumnName) != null)
@:{
@if(!column.IsMultiple)
{
@:item.@(column.LowerColumnName) = (await _repository.AsSugarClient().Queryable().FirstAsync(it => it.Id.Equals(item.@(column.LowerColumnName))))?.FullName;
}else{
@:var @(column.LowerColumnName + @column.upperJnpfKey) = item.@(column.LowerColumnName).ToObject>();
@:item.@(column.LowerColumnName) = string.Join(",", await _repository.AsSugarClient().Queryable().Where(it => @(column.LowerColumnName + @column.upperJnpfKey).Contains(it.Id)).Select(it => it.FullName).ToListAsync());
}
@:}
@:
break;
case "groupSelect":
@:// @column.ColumnComment
@:if(item.@(column.LowerColumnName) != null)
@:{
@if(!column.IsMultiple)
{
@:item.@(column.LowerColumnName) = (await _repository.AsSugarClient().Queryable().FirstAsync(it => it.Id.Equals(item.@(column.LowerColumnName))))?.FullName;
}else{
@:var @(column.LowerColumnName + @column.upperJnpfKey) = item.@(column.LowerColumnName).ToObject>();
@:item.@(column.LowerColumnName) = string.Join(",", await _repository.AsSugarClient().Queryable().Where(it => @(column.LowerColumnName + @column.upperJnpfKey).Contains(it.Id)).Select(it => it.FullName).ToListAsync());
}
@:}
@:
break;
case "treeSelect":
@:// @column.ColumnComment
@switch(column.ControlsDataType)
{
case "static":
@:var @(column.LowerColumnName)Data = "[@foreach(var data in column.StaticData){@("{\\\"id\\\":\\\"" + @data.id + "\\\",\\\"fullName\\\":\\\""+ @data.fullName + "\\\"}")@(dataCount == 1 ? "" : ",")dataCount--;}]".ToObject>();
@:if(item.@(column.LowerColumnName) != null)
@:{
@if(!column.IsMultiple)
{
@:item.@(column.LowerColumnName) = @(column.LowerColumnName)Data.Find(it => it.id.Equals(item.@(column.LowerColumnName)))?.fullName;
}else{
@:var @(column.LowerColumnName + @column.upperJnpfKey) = item.@(column.LowerColumnName).ToObject>();
@:item.@(column.LowerColumnName) = string.Join(",", @(column.LowerColumnName)Data.FindAll(it => @(column.LowerColumnName + @column.upperJnpfKey).Contains(it.id)).Select(it => it.fullName));
}
@:}
break;
case "dictionary":
@:if(item.@(column.LowerColumnName) != null)
@:{
@if(!column.IsMultiple)
{
@:item.@(column.LowerColumnName) = (await _repository.AsSugarClient().Queryable().FirstAsync(it => it.@(column.Value == "id" ? "Id" : "EnCode").Equals(item.@(column.LowerColumnName)) && it.DictionaryTypeId.Equals("@(column.propsUrl)")))?.FullName;
}else{
@:var @(column.LowerColumnName + @column.upperJnpfKey) = item.@(column.LowerColumnName).ToObject>();
@:item.@(column.LowerColumnName) = string.Join(",", await _repository.AsSugarClient().Queryable().Where(it => @(column.LowerColumnName + @column.upperJnpfKey).Contains(it.@(column.Value == "id" ? "Id" : "EnCode")) && it.DictionaryTypeId.Equals("@(column.propsUrl)")).Select(it => it.FullName).ToListAsync());
}
@:}
break;
case "dynamic":
@:var @(column.LowerColumnName)Data = await _dataInterfaceService.GetDynamicList("@(column.propsUrl)", "@(column.Value)", "@(column.Label)", "@(column.Children)");
@:if(item.@(column.LowerColumnName) != null)
@:{
@if(!column.IsMultiple)
{
@:item.@(column.LowerColumnName) = @(column.LowerColumnName)Data.Find(it => it.id.Equals(item.@(column.LowerColumnName)))?.fullName;
}else{
@:var @(column.LowerColumnName + @column.upperJnpfKey) = item.@(column.LowerColumnName).ToObject>();
@:item.@(column.LowerColumnName) = string.Join(",", @(column.LowerColumnName)Data.FindAll(it => @(column.LowerColumnName + @column.upperJnpfKey).Contains(it.id)).Select(it => it.fullName));
}
@:}
break;
}
@:
break;
case "address":
@:// @column.ColumnComment
@:if(item.@(column.LowerColumnName) != null)
@:{
@if(!column.IsMultiple)
{
@:var @(column.LowerColumnName + @column.upperJnpfKey) = item.@(column.LowerColumnName).ToObject>();
@:item.@(column.LowerColumnName) = string.Join("/", await _repository.AsSugarClient().Queryable().Where(it => @(column.LowerColumnName + @column.upperJnpfKey).Contains(it.Id)).Select(it => it.FullName).ToListAsync());
}else{
@:var @(column.LowerColumnName + @column.upperJnpfKey) = item.@(column.LowerColumnName).ToObject>>();
@:var @(column.LowerColumnName)Excessive = new List();
@:foreach (var @(column.LowerColumnName) in @(column.LowerColumnName + @column.upperJnpfKey))
@:{
@:@(column.LowerColumnName)Excessive.Add(string.Join("/", await _repository.AsSugarClient().Queryable().Where(it => @(column.LowerColumnName).Contains(it.Id)).Select(it => it.FullName).ToListAsync()));
@:}
@:
@:item.@(column.LowerColumnName) = string.Join(",", @(column.LowerColumnName)Excessive);
}
@:}
@:
break;
case "popupTableSelect":
@:// @column.ColumnComment
@:var @(column.LowerColumnName)Data = await _dataInterfaceService.GetDynamicList("@(column.propsUrl)", "@(column.Value)", "@(column.Label)", "@(column.Children)");
@:if(item.@(column.LowerColumnName) != null)
@:{
@if(!column.IsMultiple)
{
@:item.@(column.LowerColumnName) = @(column.LowerColumnName)Data.Find(it => it.id.Equals(item.@(column.LowerColumnName)))?.fullName;
}else{
@:var @(column.LowerColumnName + @column.upperJnpfKey) = item.@(column.LowerColumnName).ToObject>();
@:item.@(column.LowerColumnName) = string.Join(",", @(column.LowerColumnName)Data.FindAll(it => @(column.LowerColumnName + @column.upperJnpfKey).Contains(it.id)).Select(it => it.fullName));
}
@:}
@:
break;
}
}
}
@:});
}
@:
@foreach (var table in Model.TableRelations)
{
@if(table.IsConversion)
{
@:await _repository.AsSugarClient().ThenMapperAsync(data.SelectMany(it => it.@(table.ControlModel)), async @(table.LowerClassName) =>
@:{
@foreach(var column in table.ChilderColumnConfigList)
{
@{var dataCount = column.StaticData != null ? column.StaticData.Count : 0;}
@if(column.IsConversion)
{
@switch(column.jnpfKey)
{
case "select":
@:// @column.ColumnComment
@switch(column.ControlsDataType)
{
case "static":
@:var @(column.LowerColumnName)Data = "[@foreach(var data in column.StaticData){@("{\\\"id\\\":\\\"" + @data.id + "\\\",\\\"fullName\\\":\\\""+ @data.fullName + "\\\"}")@(dataCount == 1 ? "" : ",")dataCount--;}]".ToObject>();
@:if(@(table.LowerClassName).@(column.LowerColumnName) != null)
@:{
@if(!column.IsMultiple)
{
@:@(table.LowerClassName).@(column.LowerColumnName) = @(column.LowerColumnName)Data.Find(it => @(table.LowerClassName).@(column.LowerColumnName).Equals(it.id))?.fullName;
}else{
@:var @(column.LowerColumnName + @column.upperJnpfKey) = @(table.LowerClassName).@(column.LowerColumnName).ToObject>();
@:@(table.LowerClassName).@(column.LowerColumnName) = string.Join(",", @(column.LowerColumnName)Data.FindAll(it => @(column.LowerColumnName + @column.upperJnpfKey).Contains(it.id)).Select(it => it.fullName).FirstAsync();
}
@:}
break;
case "dictionary":
@:if(@(table.LowerClassName).@(column.LowerColumnName) != null)
@:{
@if(!column.IsMultiple)
{
@:@(table.LowerClassName).@(column.LowerColumnName) = await _repository.AsSugarClient().Queryable().Where(it => it.@(column.Value == "id" ? "Id" : "EnCode").Equals(@(table.LowerClassName).@(column.LowerColumnName)) && it.DictionaryTypeId.Equals("@(column.propsUrl)")).Select(it => it.FullName));
}else{
@:var @(column.LowerColumnName + @column.upperJnpfKey) = @(table.LowerClassName).@(column.LowerColumnName).ToObject>();
@:@(table.LowerClassName).@(column.LowerColumnName) = string.Join(",", await _repository.AsSugarClient().Queryable().Where(it => @(column.LowerColumnName + @column.upperJnpfKey).Contains(it.@(column.Value == "id" ? "Id" : "EnCode")) && it.DictionaryTypeId.Equals("@(column.propsUrl)")).Select(it => it.FullName).ToListAsync());
}
@:}
break;
case "dynamic":
@:var @(column.LowerColumnName)Data = await _dataInterfaceService.GetDynamicList("@(column.propsUrl)", "@(column.Value)", "@(column.Label)", "");
@:if(@(table.LowerClassName).@(column.LowerColumnName) != null)
@:{
@if(!column.IsMultiple)
{
@:@(table.LowerClassName).@(column.LowerColumnName) = @(column.LowerColumnName)Data.Find(it => it.id.Equals(@(table.LowerClassName).@(column.LowerColumnName)))?.fullName;
}else{
@:var @(column.LowerColumnName + @column.upperJnpfKey) = @(table.LowerClassName).@(column.LowerColumnName).ToObject>();
@:@(table.LowerClassName).@(column.LowerColumnName) = string.Join(",", @(column.LowerColumnName)Data.FindAll(it => @(column.LowerColumnName + @column.upperJnpfKey).Contains(it.id)).Select(it => it.fullName));
}
@:}
break;
}
@:
break;
case "checkbox":
@:// @column.ColumnComment
@switch(column.ControlsDataType)
{
case "static":
@:var @(column.LowerColumnName)Data = "[@foreach(var data in column.StaticData){@("{\\\"id\\\":\\\"" + @data.id + "\\\",\\\"fullName\\\":\\\""+ @data.fullName + "\\\"}")@(dataCount == 1 ? "" : ",")dataCount--;}]".ToObject>();
@:if(@(table.LowerClassName).@(column.LowerColumnName) != null)
@:{
@:var @(column.LowerColumnName + @column.upperJnpfKey) = @(table.LowerClassName).@(column.LowerColumnName).ToObject>();
@:@(table.LowerClassName).@(column.LowerColumnName) = string.Join(",", @(column.LowerColumnName)Data.FindAll(it => @(column.LowerColumnName + @column.upperJnpfKey).Contains(it.id)).Select(it => it.fullName));
@:}
break;
case "dictionary":
@:if(@(table.LowerClassName).@(column.LowerColumnName) != null)
@:{
@:var @(column.LowerColumnName + @column.upperJnpfKey) = @(table.LowerClassName).@(column.LowerColumnName).ToObject>();
@:@(table.LowerClassName).@(column.LowerColumnName) = string.Join(",", await _repository.AsSugarClient().Queryable().Where(it => @(column.LowerColumnName + @column.upperJnpfKey).Contains(it.@(column.Value == "id" ? "Id" : "EnCode")) && it.DictionaryTypeId.Equals("@(column.propsUrl)")).Select(it => it.FullName).ToListAsync());
@:}
break;
case "dynamic":
@:var @(column.LowerColumnName)Data = await _dataInterfaceService.GetDynamicList("@(column.propsUrl)", "@(column.Value)", "@(column.Label)", "");
@:if(@(table.LowerClassName).@(column.LowerColumnName) != null)
@:{
@:var @(column.LowerColumnName + @column.upperJnpfKey) = @(table.LowerClassName).@(column.LowerColumnName).ToObject>();
@:@(table.LowerClassName).@(column.LowerColumnName) = string.Join(",", @(column.LowerColumnName)Data.FindAll(it => @(column.LowerColumnName + @column.upperJnpfKey).Contains(it.id)).Select(it => it.fullName));
@:}
break;
}
@:
break;
case "radio":
@:// @column.ColumnComment
@switch(column.ControlsDataType)
{
case "dictionary":
@:if(@(table.LowerClassName).@(column.LowerColumnName) != null)
@:{
@:@(column.LowerColumnName) = (await _repository.AsSugarClient().Queryable().FirstAsync(dic => dic.@(column.Value == "id" ? "Id" : "EnCode").Equals(@(table.LowerClassName).@(column.LowerColumnName)) && dic.DictionaryTypeId.Equals("@(column.propsUrl)")))?.FullName;
@:}
break;
case "static":
@:var @(column.LowerColumnName)Data = "[@foreach(var data in column.StaticData){@("{\\\"id\\\":\\\"" + @data.id + "\\\",\\\"fullName\\\":\\\""+ @data.fullName + "\\\"}")@(dataCount == 1 ? "" : ",")dataCount--;}]".ToObject>();
@:if(@(table.LowerClassName).@(column.LowerColumnName) != null)
@:{
@:@(table.LowerClassName).@(column.LowerColumnName) = @(column.LowerColumnName)Data.Find(it => @(table.LowerClassName).@(column.LowerColumnName).Equals(it.id))?.fullName;
@:}
break;
case "dynamic":
@:var @(column.LowerColumnName)Data = await _dataInterfaceService.GetDynamicList("@(column.propsUrl)", "@(column.Value)", "@(column.Label)", "@(column.Children)");
@:if(@(table.LowerClassName).@(column.LowerColumnName) != null)
@:{
@:@(table.LowerClassName).@(column.LowerColumnName) = string.Join(",", @(column.LowerColumnName)Data.Find(it => it.id.Equals(@(table.LowerClassName).@(column.LowerColumnName)))?.fullName);
@:}
break;
}
@:
break;
case "cascader":
@:// @column.ColumnComment
@switch(column.ControlsDataType)
{
case "static":
@:var @(column.LowerColumnName)Data = "[@foreach(var data in column.StaticData){@("{\\\"id\\\":\\\"" + @data.id + "\\\",\\\"fullName\\\":\\\""+ @data.fullName + "\\\"}")@(dataCount == 1 ? "" : ",")dataCount--;}]".ToObject>();
@:if(@(table.LowerClassName).@(column.LowerColumnName) != null)
@:{
@if(!column.IsMultiple)
{
@:var @(column.LowerColumnName + @column.upperJnpfKey) = @(table.LowerClassName).@(column.LowerColumnName).ToObject>();
@:@(table.LowerClassName).@(column.LowerColumnName) = string.Join("@(column.Separator)", @(column.LowerColumnName)Data.FindAll(it => @(column.LowerColumnName + @column.upperJnpfKey).Contains(it.id)).Select(it => it.fullName));
}else{
@:var @(column.LowerColumnName + @column.upperJnpfKey) = @(table.LowerClassName).@(column.LowerColumnName).ToObject>>();
@:var @(column.LowerColumnName)Excessive = new List();
@:foreach (var @(column.LowerColumnName) in @(column.LowerColumnName + @column.upperJnpfKey))
@:{
@:@(column.LowerColumnName)Excessive.Add(string.Join("@(column.Separator)", @(column.LowerColumnName)Data.FindAll(it => @(column.LowerColumnName).Contains(it.id)).Select(it => it.fullName)));
@:}
@:
@:@(table.LowerClassName).@(column.LowerColumnName) = string.Join(",", @(column.LowerColumnName)Excessive);
}
@:}
break;
case "dictionary":
@:if(@(table.LowerClassName).@(column.LowerColumnName) != null)
@:{
@if(!column.IsMultiple)
{
@:var @(column.LowerColumnName + @column.upperJnpfKey) = @(table.LowerClassName).@(column.LowerColumnName).ToObject>();
@:@(table.LowerClassName).@(column.LowerColumnName) = string.Join("@(column.Separator)", await _repository.AsSugarClient().Queryable().Where(it => @(column.LowerColumnName + @column.upperJnpfKey).Contains(it.@(column.Value == "id" ? "Id" : "EnCode")) && it.DictionaryTypeId.Equals("@(column.propsUrl)")).Select( => it.FullName).ToListAsync());
}else{
@:var @(column.LowerColumnName + @column.upperJnpfKey) = @(table.LowerClassName).@(column.LowerColumnName).ToObject>>();
@:var @(column.LowerColumnName)Excessive = new List();
@:foreach (var @(column.LowerColumnName) in @(column.LowerColumnName + @column.upperJnpfKey))
@:{
@:@(column.LowerColumnName)Excessive.Add(string.Join("@(column.Separator)", await _repository.AsSugarClient().Queryable().Where(it => @(column.LowerColumnName).Contains(it.@(column.Value == "id" ? "Id" : "EnCode")) && it.DictionaryTypeId.Equals("@(column.propsUrl)")).Select(it => it.FullName).ToListAsync()));
@:}
@:
@:@(table.LowerClassName).@(column.LowerColumnName) = string.Join(",", @(column.LowerColumnName)Excessive);
}
@:}
break;
case "dynamic":
@:var @(column.LowerColumnName)Data = await _dataInterfaceService.GetDynamicList("@(column.propsUrl)", "@(column.Value)", "@(column.Label)", "@(column.Children)");
@:if(@(table.LowerClassName).@(column.LowerColumnName) != null)
@:{
@if(!column.IsMultiple)
{
@:var @(column.LowerColumnName + @column.upperJnpfKey) = @(table.LowerClassName).@(column.LowerColumnName).ToObject>();
@:@(table.LowerClassName).@(column.LowerColumnName) = string.Join("@(column.Separator)", @(column.LowerColumnName)Data.FindAll(it => @(column.LowerColumnName + @column.upperJnpfKey).Contains(it.id)).Select(it => it.fullName));
}else{
@:var @(column.LowerColumnName + @column.upperJnpfKey) = @(table.LowerClassName).@(column.LowerColumnName).ToObject>>();
@:var @(column.LowerColumnName)Excessive = new List();
@:foreach (var @(column.LowerColumnName) in @(column.LowerColumnName + @column.upperJnpfKey))
@:{
@:@(column.LowerColumnName)Excessive.Add(string.Join("@(column.Separator)", @(column.LowerColumnName)Data.FindAll(it => @(column.LowerColumnName).Contains(it.id)).Select(it=> it.fullName)));
@:}
@:
@:@(table.LowerClassName).@(column.LowerColumnName) = string.Join(",", @(column.LowerColumnName)Excessive);
}
@:}
break;
}
@:
break;
case "comSelect":
@:// @column.ColumnComment
@:if(@(table.LowerClassName).@(column.LowerColumnName) != null)
@:{
@if(!column.IsMultiple)
{
@:var @(column.LowerColumnName + @column.upperJnpfKey) = @(table.LowerClassName).@(column.LowerColumnName).ToObject>();
@:@(table.LowerClassName).@(column.LowerColumnName) = string.Join("/", await _repository.AsSugarClient().Queryable().Where(it => @(column.LowerColumnName + @column.upperJnpfKey).Contains(it.Id)).Select(a => a.FullName).ToListAsync());
}else{
@:var @(column.LowerColumnName + @column.upperJnpfKey) = @(table.LowerClassName).@(column.LowerColumnName).ToObject>>();
@:var @(column.LowerColumnName)Excessive = new List();
@:foreach (var @(column.LowerColumnName) in @(column.LowerColumnName + @column.upperJnpfKey))
@:{
@:@(column.LowerColumnName)Excessive.Add(string.Join("/", await _repository.AsSugarClient().Queryable().Where(it => @(column.LowerColumnName).Contains(it.Id)).Select(a => a.FullName).ToListAsync()));
@:}
@:
@:@(table.LowerClassName).@(column.LowerColumnName) = string.Join(",", @(column.LowerColumnName)Excessive);
}
@:}
@:
break;
case "depSelect":
@:// @column.ColumnComment
@:if(@(table.LowerClassName).@(column.LowerColumnName) != null)
@:{
@if(!column.IsMultiple)
{
@:@(table.LowerClassName).@(column.LowerColumnName) = (await _repository.AsSugarClient().Queryable().FirstAsync(it => it.Id.Equals(@(table.LowerClassName).@(column.LowerColumnName))))?.FullName;
}else{
@:var @(column.LowerColumnName + @column.upperJnpfKey) = @(table.LowerClassName).@(column.LowerColumnName).ToObject>();
@:@(table.LowerClassName).@(column.LowerColumnName) = string.Join(",", await _repository.AsSugarClient().Queryable().Where(it => @(column.LowerColumnName + @column.upperJnpfKey).Contains(it.Id)).Select(it => it.FullName).ToListAsync());
}
@:}
@:
break;
case "posSelect":
@:// @column.ColumnComment
@:if(@(table.LowerClassName).@(column.LowerColumnName) != null)
@:{
@if(!column.IsMultiple)
{
@:@(table.LowerClassName).@(column.LowerColumnName) = (await _repository.AsSugarClient().Queryable().FirstAsync(a => a.Id.Equals(@(table.LowerClassName).@(column.LowerColumnName))))?.FullName;
}else{
@:var @(column.LowerColumnName + @column.upperJnpfKey) = @(table.LowerClassName).@(column.LowerColumnName).ToObject>();
@:@(table.LowerClassName).@(column.LowerColumnName) = string.Join(",", await _repository.AsSugarClient().Queryable().Where(it => @(column.LowerColumnName + @column.upperJnpfKey).Contains(it.Id)).Select(it => it.FullName).ToListAsync());
}
@:}
@:
break;
case "userSelect":
@:// @column.ColumnComment
@:if(@(table.LowerClassName).@(column.LowerColumnName) != null)
@:{
@if(!column.IsMultiple)
{
@:@(table.LowerClassName).@(column.LowerColumnName) = (await _repository.AsSugarClient().Queryable().FirstAsync(it => it.Id.Equals(@(table.LowerClassName).@(column.LowerColumnName))))?.RealName;
}else{
@:var @(column.LowerColumnName + @column.upperJnpfKey) = @(table.LowerClassName).@(column.LowerColumnName).ToObject>();
@:@(table.LowerClassName).@(column.LowerColumnName) = string.Join(",", await _repository.AsSugarClient().Queryable().Where(it => @(column.LowerColumnName + @column.upperJnpfKey).Contains(it.Id)).Select(it => it.RealName).ToListAsync());
}
@:}
@:
break;
case "roleSelect":
@:// @column.ColumnComment
@:if(@(table.LowerClassName).@(column.LowerColumnName) != null)
@:{
@if(!column.IsMultiple)
{
@:@(table.LowerClassName).@(column.LowerColumnName) = (await _repository.AsSugarClient().Queryable().FirstAsync(it => it.Id.Equals(@(table.LowerClassName).@(column.LowerColumnName))))?.FullName;
}else{
@:var @(column.LowerColumnName + @column.upperJnpfKey) = @(table.LowerClassName).@(column.LowerColumnName).ToObject>();
@:@(table.LowerClassName).@(column.LowerColumnName) = string.Join(",", await _repository.AsSugarClient().Queryable().Where(it => @(column.LowerColumnName + @column.upperJnpfKey).Contains(it.Id)).Select(it => it.FullName).ToListAsync());
}
@:}
@:
break;
case "groupSelect":
@:// @column.ColumnComment
@:if(@(table.LowerClassName).@(column.LowerColumnName) != null)
@:{
@if(!column.IsMultiple)
{
@:@(table.LowerClassName).@(column.LowerColumnName) = (await _repository.AsSugarClient().Queryable().FirstAsync(it => it.Id.Equals(@(table.LowerClassName).@(column.LowerColumnName))))?.FullName;
}else{
@:var @(column.LowerColumnName + @column.upperJnpfKey) = @(table.LowerClassName).@(column.LowerColumnName).ToObject>();
@:@(table.LowerClassName).@(column.LowerColumnName) = string.Join(",", await _repository.AsSugarClient().Queryable().Where(it => @(column.LowerColumnName + @column.upperJnpfKey).Contains(it.Id)).Select(it => it.FullName).ToListAsync());
}
@:}
@:
break;
case "treeSelect":
@:// @column.ColumnComment
@switch(column.ControlsDataType)
{
case "static":
@:var @(column.LowerColumnName)Data = "[@foreach(var data in column.StaticData){@("{\\\"id\\\":\\\"" + @data.id + "\\\",\\\"fullName\\\":\\\""+ @data.fullName + "\\\"}")@(dataCount == 1 ? "" : ",")dataCount--;}]".ToObject>();
@:if(@(table.LowerClassName).@(column.LowerColumnName) != null)
@:{
@if(!column.IsMultiple)
{
@:@(table.LowerClassName).@(column.LowerColumnName) = @(column.LowerColumnName)Data.Find(it => it.id.Equals(@(table.LowerClassName).@(column.LowerColumnName)))?.fullName;
}else{
@:var @(column.LowerColumnName + @column.upperJnpfKey) = @(table.LowerClassName).@(column.LowerColumnName).ToObject>();
@:@(table.LowerClassName).@(column.LowerColumnName) = string.Join(",", @(column.LowerColumnName)Data.FindAll(it => @(column.LowerColumnName + @column.upperJnpfKey).Contains(it.id)).Select(it => it.fullName));
}
@:}
break;
case "dictionary":
@:if(@(table.LowerClassName).@(column.LowerColumnName) != null)
@:{
@if(!column.IsMultiple)
{
@:@(table.LowerClassName).@(column.LowerColumnName) = (await _repository.AsSugarClient().Queryable().FirstAsync(it => it.@(column.Value == "id" ? "Id" : "EnCode").Equals(@(table.LowerClassName).@(column.LowerColumnName)) && it.DictionaryTypeId.Equals("@(column.propsUrl)")))?.FullName;
}else{
@:var @(column.LowerColumnName + @column.upperJnpfKey) = @(table.LowerClassName).@(column.LowerColumnName).ToObject>();
@:@(table.LowerClassName).@(column.LowerColumnName) = string.Join(",", await _repository.AsSugarClient().Queryable().Where(it => @(column.LowerColumnName + @column.upperJnpfKey).Contains(it.@(column.Value == "id" ? "Id" : "EnCode")) && it.DictionaryTypeId.Equals("@(column.propsUrl)")).Select(it => it.FullName).ToListAsync());
}
@:}
break;
case "dynamic":
@:var @(column.LowerColumnName)Data = await _dataInterfaceService.GetDynamicList("@(column.propsUrl)", "@(column.Value)", "@(column.Label)", "@(column.Children)");
@:if(@(table.LowerClassName).@(column.LowerColumnName) != null)
@:{
@if(!column.IsMultiple)
{
@:@(table.LowerClassName).@(column.LowerColumnName) = @(column.LowerColumnName)Data.Find(it => it.id.Equals(@(table.LowerClassName).@(column.LowerColumnName)))?.fullName;
}else{
@:var @(column.LowerColumnName + @column.upperJnpfKey) = @(table.LowerClassName).@(column.LowerColumnName).ToObject>();
@:@(table.LowerClassName).@(column.LowerColumnName) = string.Join(",", @(column.LowerColumnName)Data.FindAll(it => @(column.LowerColumnName + @column.upperJnpfKey).Contains(it.id)).Select(it => it.fullName));
}
@:}
break;
}
@:
break;
case "address":
@:// @column.ColumnComment
@:if(@(table.LowerClassName).@(column.LowerColumnName) != null)
@:{
@if(!column.IsMultiple)
{
@:var @(column.LowerColumnName + @column.upperJnpfKey) = @(table.LowerClassName).@(column.LowerColumnName).ToObject>();
@:@(table.LowerClassName).@(column.LowerColumnName) = string.Join("/", await _repository.AsSugarClient().Queryable().Where(a => @(column.LowerColumnName + @column.upperJnpfKey).Contains(a.Id)).Select(it => it.FullName).ToListAsync());
}else{
@:var @(column.LowerColumnName + @column.upperJnpfKey) = @(table.LowerClassName).@(column.LowerColumnName).ToObject>>();
@:var @(column.LowerColumnName)Excessive = new List();
@:foreach (var @(column.LowerColumnName) in @(column.LowerColumnName + @column.upperJnpfKey))
@:{
@:@(column.LowerColumnName)Excessive.Add(string.Join("/", await _repository.AsSugarClient().Queryable().Where(a => @(column.LowerColumnName).Contains(a.Id)).Select(it => it.FullName).ToListAsync()));
@:}
@:
@:@(table.LowerClassName).@(column.LowerColumnName) = string.Join(",", @(column.LowerColumnName)Excessive);
}
@:}
@:
break;
case "popupTableSelect":
@:// @column.ColumnComment
@:var @(column.LowerColumnName)Data = await _dataInterfaceService.GetDynamicList("@(column.propsUrl)", "@(column.Value)", "@(column.Label)", "@(column.Children)");
@:if(@(table.LowerClassName).@(column.LowerColumnName) != null)
@:{
@if(!column.IsMultiple)
{
@:@(table.LowerClassName).@(column.LowerColumnName) = @(column.LowerColumnName)Data.Find(it => it.id.Equals(@(table.LowerClassName).@(column.LowerColumnName)))?.fullName;
}else{
@:var @(column.LowerColumnName + @column.upperJnpfKey) = @(table.LowerClassName).@(column.LowerColumnName).ToObject>();
@:@(table.LowerClassName).@(column.LowerColumnName) = string.Join(",", @(column.LowerColumnName)Data.FindAll(it => @(column.LowerColumnName + @column.upperJnpfKey).Contains(it.id)).Select(it => it.fullName));
}
@:}
@:
break;
}
}
}
@:});
}
@:
}
@if(Model.ParsJnpfKeyConstListDetails.Count > 0)
{
@:var resData = data.ToObject>>();
@foreach (var jnpfKeyConst in Model.ParsJnpfKeyConstListDetails)
{
@:resData = await _controlParsing.GetParsDataList(resData,"@(jnpfKeyConst[1])","@(jnpfKeyConst[0])",_userManager.TenantId);
}
@:data = resData.ToObject>();
}
@:return data.FirstOrDefault();
@:}
break;
@*导入*@
case "upload":
@:
@:///
@:/// 下载模板.
@:///
@:///
@:[HttpGet("TemplateDownload")]
@:public async Task TemplateDownload()
@:{
@:List>? dataList = new List>();
@:
@:// 赋予默认值
@:var dicItem = ExportImportDataHelper.GetTemplateHeader<@(Model.ClassName)Entity>(new @(Model.ClassName)Entity(), 1);
@foreach (var table in Model.TableRelations)
{
@if(table.IsImportData)
{
@:var @table.ControlModel = ExportImportDataHelper.GetTemplateHeader<@(table.ClassName)Entity>(new @(table.ClassName)Entity(), 3, "@(table.ControlModel)");
}
}
@:
@:dicItem.Add("id", "id");
@{var tableName = 0;}
@foreach (var table in Model.TableRelations)
{
@if(table.IsImportData)
{
@:var table@(table.TableNo) = @(tableName == 0 ? "dicItem" : "table" + tableName).Concat(@(table.ControlModel)).ToDictionary(k => k.Key, v => v.Value);
tableName++;
if(tableName > 0)
{
tableName = table.TableNo;
}
}
}
@:dataList.Add(table@(tableName));
@:
@:var excelName = string.Format("{0} 导入模板_{1}", "@(Model.FullName)", SnowflakeIdHelper.NextId());
@:_cacheManager.Set(excelName + ".xls", string.Empty);
@:return CodeGenExportDataHelper.GetTemplateExport(excelName, string.Join(",", uploaderKey), _userManager.UserId, dataList, childParanList);
@:}
@:
@:///
@:/// Excel导入.
@:///
@:///
@:///
@:[HttpPost("Uploader")]
@:public async Task Uploader(IFormFile file)
@:{
@:var _filePath = _fileManager.GetPathByType(string.Empty);
@:var _fileName = DateTime.Now.ToString("yyyyMMdd") + "_" + SnowflakeIdHelper.NextId() + Path.GetExtension(file.FileName);
@:var stream = file.OpenReadStream();
@:await _fileManager.UploadFileByType(stream, _filePath, _fileName);
@:return new { name = _fileName, url = string.Format("/api/File/Image/{0}/{1}", string.Empty, _fileName) };
@:}
@:
@:///
@:/// 导入预览.
@:///
@:///
@:[HttpGet("ImportPreview")]
@:public async Task ImportPreview(string fileName)
@:{
@:List fieldList = new List();
@:fieldList.AddRange(ExportImportDataHelper.GetTemplateParsing<@(Model.ClassName)Entity>(new @(Model.ClassName)Entity()));
@foreach (var table in Model.TableRelations)
{
@if(table.IsImportData)
{
@:ConfigModel @(table.ControlModel)Config = new ConfigModel
@:{
@:tableName = "@(table.OriginalTableName)",
@:jnpfKey = JnpfKeyConst.TABLE,
@:label = "@(table.ControlTableComment)",
@:children = ExportImportDataHelper.GetTemplateParsing<@(table.ClassName)Entity>(new @(table.ClassName)Entity())
@:};
@:FieldsModel @(table.ControlModel) = new FieldsModel()
@:{
@:__config__ = @(table.ControlModel)Config,
@:__vModel__ = "@(table.ControlModel)"
@:};
@:fieldList.Add(@(table.ControlModel));
@:
}
}
@:var entityInfo = _repository.AsSugarClient().EntityMaintenance.GetEntityInfo<@(Model.ClassName)Entity>();
@:List tables = new List() { ExportImportDataHelper.GetTableRelation(entityInfo, "1") };
@foreach (var table in Model.TableRelations)
{
@if(table.IsImportData)
{
@:entityInfo = _repository.AsSugarClient().EntityMaintenance.GetEntityInfo<@(table.ClassName)Entity>();
@:tables.Add(ExportImportDataHelper.GetTableRelation(entityInfo, "0", "@(table.OriginalTableField)", "@(table.RelationTable)", "@(table.OriginalRelationField)"));
}
}
@:DbLinkEntity link = _dataBaseManager.GetTenantDbLink(_userManager.TenantId, _userManager.TenantDbName); // 当前数据库连接
@:var tInfo = new TemplateParsingBase(link, fieldList, tables, "@(Model.OriginalPrimaryKey)", @(Model.WebType), @(Model.PrimaryKeyPolicy), uploaderKey.ToList(), "@(Model.ImportDataType)");
@:return await _exportImportDataHelper.GetImportPreviewData(tInfo, fileName);
@:}
@:
@:///
@:/// 导入数据.
@:///
@:///
@:///
@:[HttpPost("ImportData")]
@:[UnitOfWork]
@:public async Task ImportData([FromBody] DataImportInput input)
@:{
@:List fieldList = new List();
@:fieldList.AddRange(ExportImportDataHelper.GetTemplateParsing<@(Model.ClassName)Entity>(new @(Model.ClassName)Entity()));
@foreach (var table in Model.TableRelations)
{
@if(table.IsImportData)
{
@:ConfigModel @(table.ControlModel)Config = new ConfigModel
@:{
@:tableName = "@(table.OriginalTableName)",
@:jnpfKey = JnpfKeyConst.TABLE,
@:label = "@(table.ControlTableComment)",
@:children = ExportImportDataHelper.GetTemplateParsing<@(table.ClassName)Entity>(new @(table.ClassName)Entity())
@:};
@:FieldsModel @(table.ControlModel) = new FieldsModel()
@:{
@:__config__ = @(table.ControlModel)Config,
@:__vModel__ = "@(table.ControlModel)"
@:};
@:fieldList.Add(@(table.ControlModel));
@:
}
}
@:var entityInfo = _repository.AsSugarClient().EntityMaintenance.GetEntityInfo<@(Model.ClassName)Entity>();
@:List tables = new List() { ExportImportDataHelper.GetTableRelation(entityInfo, "1") };
@foreach (var table in Model.TableRelations)
{
@if(table.IsImportData)
{
@:entityInfo = _repository.AsSugarClient().EntityMaintenance.GetEntityInfo<@(table.ClassName)Entity>();
@:tables.Add(ExportImportDataHelper.GetTableRelation(entityInfo, "0", "@(table.OriginalTableField)", "@(table.RelationTable)", "@(table.OriginalRelationField)"));
}
}
@:DbLinkEntity link = _dataBaseManager.GetTenantDbLink(_userManager.TenantId, _userManager.TenantDbName); // 当前数据库连接
@:var tInfo = new TemplateParsingBase(link, fieldList, tables, "@(Model.OriginalPrimaryKey)", @(Model.WebType), @(Model.PrimaryKeyPolicy), uploaderKey.ToList(), "@(Model.ImportDataType)"@(Model.EnableFlow ? ", 1" : ""));
@:
@:object[]? res = await _exportImportDataHelper.ImportMenuData(tInfo, input.list);
@:var addlist = res.First() as List>;
@:var errorlist = res.Last() as List>;
@:var result = new DataImportOutput()
@:{
@:snum = addlist.Count,
@:fnum = errorlist.Count,
@:failResult = errorlist,
@:resultType = errorlist.Count < 1 ? 0 : 1
@:};
@:
@:return result;
@:}
@:
@:///
@:/// 导入数据的错误报告.
@:///
@:///
@:///
@:[HttpPost("ImportExceptionData")]
@:[UnitOfWork]
@:public async Task ExportExceptionData([FromBody] DataImportInput list)
@:{
@:List fieldList = new List();
@:fieldList.AddRange(ExportImportDataHelper.GetTemplateParsing<@(Model.ClassName)Entity>(new @(Model.ClassName)Entity()));
@foreach (var table in Model.TableRelations)
{
@if(table.IsImportData)
{
@:ConfigModel @(table.ControlModel)Config = new ConfigModel
@:{
@:tableName = "@(table.OriginalTableName)",
@:jnpfKey = JnpfKeyConst.TABLE,
@:label = "@(table.ControlTableComment)",
@:children = ExportImportDataHelper.GetTemplateParsing<@(table.ClassName)Entity>(new @(table.ClassName)Entity())
@:};
@:FieldsModel @(table.ControlModel) = new FieldsModel()
@:{
@:__config__ = @(table.ControlModel)Config,
@:__vModel__ = "@(table.ControlModel)"
@:};
@:fieldList.Add(@(table.ControlModel));
@:
}
}
@:var entityInfo = _repository.AsSugarClient().EntityMaintenance.GetEntityInfo<@(Model.ClassName)Entity>();
@:List tables = new List() { ExportImportDataHelper.GetTableRelation(entityInfo, "1") };
@foreach (var table in Model.TableRelations)
{
@if(table.IsImportData)
{
@:entityInfo = _repository.AsSugarClient().EntityMaintenance.GetEntityInfo<@(table.ClassName)Entity>();
@:tables.Add(ExportImportDataHelper.GetTableRelation(entityInfo, "0", "@(table.OriginalTableField)", "@(table.RelationTable)", "@(table.OriginalRelationField)"));
}
}
@:DbLinkEntity link = _dataBaseManager.GetTenantDbLink(_userManager.TenantId, _userManager.TenantDbName); // 当前数据库连接
@:var tInfo = new TemplateParsingBase(link, fieldList, tables, "@(Model.OriginalPrimaryKey)", @(Model.WebType), @(Model.PrimaryKeyPolicy), uploaderKey.ToList(), "@(Model.ImportDataType)");
@:
@:// 错误数据
@:tInfo.selectKey.Add("errorsInfo");
@:tInfo.AllFieldsModel.Add(new FieldsModel() { __vModel__ = "errorsInfo", __config__ = new ConfigModel() { label = "异常原因" } });
@:for (var i = 0; i < list.list.Count(); i++) list.list[i].Add("id", i);
@:
@:var result = ExportImportDataHelper.GetCreateFirstColumnsHeader(tInfo.selectKey, list.list, childParanList);
@:var firstColumns = result.First().ToObject>();
@:var resultList = result.Last().ToObject>>();
@:_cacheManager.Set(string.Format("{0} 导入错误报告.xls", tInfo.FullName), string.Empty);
@:return firstColumns.Any()
@:? await _exportImportDataHelper.ExcelCreateModel(tInfo, resultList, string.Format("{0} 导入错误报告", tInfo.FullName), firstColumns)
@:: await _exportImportDataHelper.ExcelCreateModel(tInfo, resultList, string.Format("{0} 导入错误报告", tInfo.FullName));
@:}
break;
}
}
}
@{
@*获取主表查询字段模板*@
void GetPrimaryTableQueryFieldTemplate()
{
@foreach(var table in Model.TableField)
{
@*是查询条件*@
@if(table.QueryWhether)
{
@switch(table.QueryType)
{
case 1:
@switch(table.jnpfKey)
{
case "cascader":
case "address":
case "comSelect":
case "currOrganize":
@:var @(table.LowerColumnName) = input.@(table.LowerColumnName)?.Split(',').ToList().Last();
break;
default:
@if(table.IsMultiple)
{
@:var @(table.LowerColumnName) = input.@(table.LowerColumnName)?.Split(',').ToList().Last();
}
break;
}
break;
case 3:
@switch(table.jnpfKey)
{
case "time":
@:List query@(table.ColumnName) = input.@(table.LowerColumnName)?.Split(',').ToObject>();
@:var start@(table.ColumnName) = query@(table.ColumnName)?.First();
@:var end@(table.ColumnName) = query@(table.ColumnName)?.Last();
break;
case "numInput":
case "calculate":
@:List