using System.Reflection; using System.Text.RegularExpressions; using JNPF.Common.CodeGenUpload; using JNPF.Common.Configuration; using JNPF.Common.Const; using JNPF.Common.Core.Manager; using JNPF.Common.Core.Manager.Files; using JNPF.Common.Dtos.VisualDev; using JNPF.Common.Enums; using JNPF.Common.Extension; using JNPF.Common.Helper; using JNPF.Common.Manager; using JNPF.Common.Models; using JNPF.Common.Models.NPOI; using JNPF.Common.Security; using JNPF.DataEncryption; using JNPF.DependencyInjection; using JNPF.FriendlyException; using JNPF.RemoteRequest.Extensions; using JNPF.Systems.Entitys.Model.DataInterFace; using JNPF.Systems.Entitys.Permission; using JNPF.Systems.Entitys.System; using JNPF.Systems.Interfaces.System; using JNPF.VisualDev; using JNPF.VisualDev.Engine; using JNPF.VisualDev.Engine.Core; using JNPF.WorkFlow.Interfaces.Service; using Mapster; using Newtonsoft.Json.Linq; using SqlSugar; using Yitter.IdGenerator; namespace JNPF.Common.CodeGen.ExportImport; /// /// 代码生成导出数据帮助类. /// public class ExportImportDataHelper : ITransient { /// /// 服务基础仓储. /// private readonly ISqlSugarRepository _repository; /// /// 用户管理器. /// private readonly IUserManager _userManager; /// /// 在线开发运行服务. /// private readonly RunService _runService; /// /// 单据. /// private readonly IBillRullService _billRuleService; /// /// 切库. /// private readonly IDataBaseManager _databaseService; /// /// 数据接口. /// private readonly IDataInterfaceService _dataInterfaceService; /// /// 缓存管理. /// private readonly ICacheManager _cacheManager; /// /// 工作流. /// private readonly IFlowTaskService _flowTaskService; /// /// 文件服务. /// private readonly IFileManager _fileManager; /// /// 客户端. /// private static SqlSugarScope? _sqlSugarClient; /// /// 构造函数. /// public ExportImportDataHelper( ISqlSugarRepository repositoryRepository, IUserManager userManager, RunService runService, IBillRullService billRuleService, IDataInterfaceService dataInterfaceService, IDataBaseManager databaseService, ICacheManager cacheManager, IFlowTaskService flowTaskService, IFileManager fileManager, ISqlSugarClient context) { _repository = repositoryRepository; _sqlSugarClient = (SqlSugarScope)context; _billRuleService = billRuleService; _databaseService = databaseService; _dataInterfaceService = dataInterfaceService; _runService = runService; _cacheManager = cacheManager; _flowTaskService = flowTaskService; _fileManager = fileManager; _userManager = userManager; } /// /// 组装导出带子表的数据,返回 第一个合并行标头,第二个导出数据. /// /// 导出选择列. /// 原数据集合. /// 模板信息. /// 第一行标头 , 导出数据. public static object[] GetCreateFirstColumnsHeader(List selectKey, List> realList, List paramsModels) { selectKey.ForEach(item => { realList.ForEach(it => { if (!it.ContainsKey(item)) it.Add(item, string.Empty); }); }); var newRealList = realList.Copy(); realList.ForEach(items => { var rowChildDatas = new Dictionary>>(); foreach (var item in items) { if (item.Value != null && item.Key.ToLower().Contains("tablefield") && (item.Value is List> || item.Value.GetType().Name.Equals("JArray"))) { var ctList = item.Value.ToObject>>(); rowChildDatas.Add(item.Key, ctList); } } var len = rowChildDatas.Select(x => x.Value.Count()).OrderByDescending(x => x).FirstOrDefault(); if (len != null && len > 0) { for (int i = 0; i < len; i++) { if (i == 0) { var newRealItem = newRealList.Find(x => x["id"].Equals(items["id"])); foreach (var cData in rowChildDatas) { var itemData = cData.Value.FirstOrDefault(); if (itemData != null) { foreach (var key in itemData) if (newRealItem.ContainsKey(cData.Key + "-" + key.Key)) newRealItem[cData.Key + "-" + key.Key] = key.Value; } } } else { var newRealItem = new Dictionary(); foreach (var it in items) { if (it.Key.Equals("id")) newRealItem.Add(it.Key, it.Value); else newRealItem.Add(it.Key, string.Empty); } foreach (var cData in rowChildDatas) { if (cData.Value.Count > i) { foreach (var it in cData.Value[i]) if (newRealItem.ContainsKey(cData.Key + "-" + it.Key)) newRealItem[cData.Key + "-" + it.Key] = it.Value; } } newRealList.Add(newRealItem); } } } }); var resultList = new List>(); newRealList.ForEach(newRealItem => { if (!resultList.Any(x => x["id"].Equals(newRealItem["id"]))) resultList.AddRange(newRealList.Where(x => x["id"].Equals(newRealItem["id"])).ToList()); }); var firstColumns = new Dictionary(); if (selectKey.Any(x => x.Contains("-") && x.ToLower().Contains("tablefield"))) { var empty = string.Empty; var keyList = selectKey.Select(x => x.Split("-").First()).Distinct().ToList(); var mainFieldIndex = 1; keyList.ForEach(item => { if (item.ToLower().Contains("tablefield")) { var title = paramsModels.FirstOrDefault(x => x.field.Contains(item))?.value.Split("-")[0]; firstColumns.Add(title + empty, selectKey.Count(x => x.Contains(item))); empty += " "; mainFieldIndex = 1; } else { if (mainFieldIndex == 1) empty += " "; if (!firstColumns.ContainsKey(empty)) firstColumns.Add(empty, mainFieldIndex); else firstColumns[empty] = mainFieldIndex; mainFieldIndex++; } }); } return new object[] { firstColumns, resultList }; } /// /// 数据导出通用. /// /// 导出文件名. /// selectKey. /// 用户ID. /// 数据集合. /// 参数. /// 是否分组表格. /// 是否行内编辑. /// public static dynamic GetDataExport(string fileName, string selectKey, string userId, List> realList, List paramList, bool isGroupTable = false, bool isInlineEditor = false) { switch (isInlineEditor) { case true: paramList.ForEach(item => { item.field = string.Format("{0}_name", item.field); }); break; } var res = GetCreateFirstColumnsHeader(selectKey.Split(',').ToList(), realList, paramList); var firstColumns = res.First().ToObject>(); var resultList = res.Last().ToObject>>(); List newSelectKey = selectKey.Split(',').ToList(); // 如果是 分组表格 类型 if (isGroupTable) { List>? newValueList = new List>(); realList.ForEach(item => { List>? tt = item["children"].ToJsonString().ToObject>>(); newValueList.AddRange(tt); }); realList = newValueList; } List newParamList = new List(); // 全部参数顺序 foreach (var item in firstColumns) { Regex re = new Regex(@"[\u4e00-\u9fa5]+"); switch (re.IsMatch(item.Key)) { case false: { var param = newSelectKey.GetRange(0, item.Value); newParamList.AddRange(paramList.FindAll(it => param.Contains(it.field))); newSelectKey.RemoveAll(it => newParamList.Select(it => it.field).ToList().Contains(it)); } break; default: var childTable = paramList.FindAll(it => it.value.Contains(item.Key.TrimEnd(' '))); childTable = childTable.FindAll(it => selectKey.Split(',').ToList().Contains(it.field)); newParamList.AddRange(childTable); newSelectKey.RemoveAll(it => newParamList.Select(it => it.field).ToList().Contains(it)); break; } } if (newParamList.Count > 0) newSelectKey = newParamList.Select(it => it.field).ToList(); try { List columnList = new List(); ExcelConfig excelconfig = new ExcelConfig(); excelconfig.FileName = string.Format("{0}.xls", fileName); excelconfig.HeadFont = "微软雅黑"; excelconfig.HeadPoint = 10; excelconfig.IsAllSizeColumn = true; excelconfig.ColumnModel = new List(); foreach (var item in newSelectKey) { ParamsModel isExist = new ParamsModel(); switch (isInlineEditor) { case true: isExist = paramList.Find(p => p.field.Equals(string.Format("{0}_name", item))); break; default: isExist = paramList.Find(p => p.field == item); break; } if (isExist != null) { excelconfig.ColumnModel.Add(new ExcelColumnModel() { Column = isExist.field, ExcelColumn = isExist.value }); columnList.Add(isExist.value); } } string? addPath = Path.Combine(FileVariable.TemporaryFilePath, excelconfig.FileName); var fs = (firstColumns == null || firstColumns.Count() < 1) ? ExcelExportHelper>.ExportMemoryStream(realList, excelconfig, columnList) : ExcelExportHelper>.ExportMemoryStream(realList, excelconfig, columnList, firstColumns); ExcelExportHelper>.Export(fs, addPath); var fName = userId + "|" + addPath + "|xls"; return new { name = excelconfig.FileName, url = "/api/File/Download?encryption=" + DESCEncryption.Encrypt(fName, "JNPF") }; } catch (Exception) { throw; } } /// /// 获取模板解析. /// public static List GetTemplateParsing(T entity) { List fieldList = new List(); foreach (PropertyInfo prop in entity.GetType().GetProperties(BindingFlags.Instance | BindingFlags.Public)) { FieldsModel field = new FieldsModel(); foreach (var att in prop.GetCustomAttributes(false)) { if (att is CodeGenUploadAttribute) { var configModel = new ConfigModel(); field.__vModel__ = (att as CodeGenUploadAttribute).__Model__; field.level = (att as CodeGenUploadAttribute).level; field.min = (att as CodeGenUploadAttribute).min == 0 ? null : (att as CodeGenUploadAttribute).min; field.max = (att as CodeGenUploadAttribute).max == 0 ? null : (att as CodeGenUploadAttribute).max; field.activeTxt = (att as CodeGenUploadAttribute).activeTxt; field.inactiveTxt = (att as CodeGenUploadAttribute).inactiveTxt; field.format = (att as CodeGenUploadAttribute).format; field.multiple = (att as CodeGenUploadAttribute).multiple; field.separator = (att as CodeGenUploadAttribute).separator; field.__slot__ = (att as CodeGenUploadAttribute).__slot__.Adapt(); field.props = (att as CodeGenUploadAttribute).props.Adapt(); field.options = (att as CodeGenUploadAttribute).options; field.propsValue = (att as CodeGenUploadAttribute).propsValue; field.relationField = (att as CodeGenUploadAttribute).relationField; field.modelId = (att as CodeGenUploadAttribute).modelId; field.interfaceId = (att as CodeGenUploadAttribute).interfaceId; field.selectType = (att as CodeGenUploadAttribute).selectType; field.ableDepIds = (att as CodeGenUploadAttribute).ableDepIds; field.ablePosIds = (att as CodeGenUploadAttribute).ablePosIds; field.ableUserIds = (att as CodeGenUploadAttribute).ableUserIds; field.ableRoleIds = (att as CodeGenUploadAttribute).ableRoleIds; field.ableGroupIds = (att as CodeGenUploadAttribute).ableGroupIds; field.ableIds = (att as CodeGenUploadAttribute).ableIds; field.relational = (att as CodeGenUploadAttribute).showField; configModel = (att as CodeGenUploadAttribute).__config__.Adapt(); configModel.label = string.Format("{0}({1})", configModel.label, field.__vModel__); field.__config__ = configModel; fieldList.Add(field); } } } return fieldList; } /// /// 获取数据转换模板解析. /// public static List GetDataConversionTemplateParsing(T entity) { List fieldList = new List(); foreach (PropertyInfo prop in entity.GetType().GetProperties(BindingFlags.Instance | BindingFlags.Public)) { FieldsModel field = new FieldsModel(); foreach (var att in prop.GetCustomAttributes(false)) { if (att is CodeGenUploadAttribute) { var configModel = new ConfigModel(); field.__vModel__ = (att as CodeGenUploadAttribute).__vModel__ ?? (att as CodeGenUploadAttribute).__Model__; field.level = (att as CodeGenUploadAttribute).level; field.min = (att as CodeGenUploadAttribute).min == 0 ? null : (att as CodeGenUploadAttribute).min; field.max = (att as CodeGenUploadAttribute).max == 0 ? null : (att as CodeGenUploadAttribute).max; field.activeTxt = (att as CodeGenUploadAttribute).activeTxt; field.inactiveTxt = (att as CodeGenUploadAttribute).inactiveTxt; field.format = (att as CodeGenUploadAttribute).format; field.multiple = (att as CodeGenUploadAttribute).multiple; field.separator = (att as CodeGenUploadAttribute).separator; field.__slot__ = (att as CodeGenUploadAttribute).__slot__.Adapt(); field.props = (att as CodeGenUploadAttribute).props.Adapt(); field.options = (att as CodeGenUploadAttribute).options; field.propsValue = (att as CodeGenUploadAttribute).propsValue; field.relationField = (att as CodeGenUploadAttribute).relationField; field.modelId = (att as CodeGenUploadAttribute).modelId; field.interfaceId = (att as CodeGenUploadAttribute).interfaceId; field.selectType = (att as CodeGenUploadAttribute).selectType; field.ableDepIds = (att as CodeGenUploadAttribute).ableDepIds; field.ablePosIds = (att as CodeGenUploadAttribute).ablePosIds; field.ableUserIds = (att as CodeGenUploadAttribute).ableUserIds; field.ableRoleIds = (att as CodeGenUploadAttribute).ableRoleIds; field.ableGroupIds = (att as CodeGenUploadAttribute).ableGroupIds; field.ableIds = (att as CodeGenUploadAttribute).ableIds; field.relational = (att as CodeGenUploadAttribute).showField; configModel = (att as CodeGenUploadAttribute).__config__.Adapt(); configModel.label = string.Format("{0}({1})", configModel.label, field.__vModel__); field.__config__ = configModel; fieldList.Add(field); } } } return fieldList; } /// /// 获取模板解析. /// public static List GetTemplateParsing(T entity, string tableName) { List fieldList = new List(); foreach (PropertyInfo prop in entity.GetType().GetProperties(BindingFlags.Instance | BindingFlags.Public)) { FieldsModel field = new FieldsModel(); foreach (var att in prop.GetCustomAttributes(false)) { if (att is CodeGenUploadAttribute) { var configModel = new ConfigModel(); field.__vModel__ = string.Format("jnpf_{0}_jnpf_{1}", tableName, (att as CodeGenUploadAttribute).__Model__); field.level = (att as CodeGenUploadAttribute).level; field.min = (att as CodeGenUploadAttribute).min == 0 ? null : (att as CodeGenUploadAttribute).min; field.max = (att as CodeGenUploadAttribute).max == 0 ? null : (att as CodeGenUploadAttribute).max; field.activeTxt = (att as CodeGenUploadAttribute).activeTxt; field.inactiveTxt = (att as CodeGenUploadAttribute).inactiveTxt; field.format = (att as CodeGenUploadAttribute).format; field.multiple = (att as CodeGenUploadAttribute).multiple; field.separator = (att as CodeGenUploadAttribute).separator; field.__slot__ = (att as CodeGenUploadAttribute).__slot__.Adapt(); field.props = (att as CodeGenUploadAttribute).props.Adapt(); field.options = (att as CodeGenUploadAttribute).options; field.propsValue = (att as CodeGenUploadAttribute).propsValue; field.relationField = (att as CodeGenUploadAttribute).relationField; field.modelId = (att as CodeGenUploadAttribute).modelId; field.interfaceId = (att as CodeGenUploadAttribute).interfaceId; field.selectType = (att as CodeGenUploadAttribute).selectType; field.ableDepIds = (att as CodeGenUploadAttribute).ableDepIds; field.ablePosIds = (att as CodeGenUploadAttribute).ablePosIds; field.ableUserIds = (att as CodeGenUploadAttribute).ableUserIds; field.ableRoleIds = (att as CodeGenUploadAttribute).ableRoleIds; field.ableGroupIds = (att as CodeGenUploadAttribute).ableGroupIds; field.ableIds = (att as CodeGenUploadAttribute).ableIds; field.relational = (att as CodeGenUploadAttribute).showField; configModel = (att as CodeGenUploadAttribute).__config__.Adapt(); configModel.label = string.Format("{0}({1})", configModel.label, field.__vModel__); field.__config__ = configModel; fieldList.Add(field); } } } return fieldList; } /// /// 获取数据转换模板解析. /// public static List GetDataConversionTemplateParsing(T entity, string tableName) { List fieldList = new List(); foreach (PropertyInfo prop in entity.GetType().GetProperties(BindingFlags.Instance | BindingFlags.Public)) { FieldsModel field = new FieldsModel(); foreach (var att in prop.GetCustomAttributes(false)) { if (att is CodeGenUploadAttribute) { var configModel = new ConfigModel(); field.__vModel__ = string.Format("jnpf_{0}_jnpf_{1}", tableName, (att as CodeGenUploadAttribute).__vModel__ ?? (att as CodeGenUploadAttribute).__Model__); field.level = (att as CodeGenUploadAttribute).level; field.min = (att as CodeGenUploadAttribute).min == 0 ? null : (att as CodeGenUploadAttribute).min; field.max = (att as CodeGenUploadAttribute).max == 0 ? null : (att as CodeGenUploadAttribute).max; field.activeTxt = (att as CodeGenUploadAttribute).activeTxt; field.inactiveTxt = (att as CodeGenUploadAttribute).inactiveTxt; field.format = (att as CodeGenUploadAttribute).format; field.multiple = (att as CodeGenUploadAttribute).multiple; field.separator = (att as CodeGenUploadAttribute).separator; field.__slot__ = (att as CodeGenUploadAttribute).__slot__.Adapt(); field.props = (att as CodeGenUploadAttribute).props.Adapt(); field.options = (att as CodeGenUploadAttribute).options; field.propsValue = (att as CodeGenUploadAttribute).propsValue; field.relationField = (att as CodeGenUploadAttribute).relationField; field.modelId = (att as CodeGenUploadAttribute).modelId; field.interfaceId = (att as CodeGenUploadAttribute).interfaceId; field.selectType = (att as CodeGenUploadAttribute).selectType; field.ableDepIds = (att as CodeGenUploadAttribute).ableDepIds; field.ablePosIds = (att as CodeGenUploadAttribute).ablePosIds; field.ableUserIds = (att as CodeGenUploadAttribute).ableUserIds; field.ableRoleIds = (att as CodeGenUploadAttribute).ableRoleIds; field.ableGroupIds = (att as CodeGenUploadAttribute).ableGroupIds; field.ableIds = (att as CodeGenUploadAttribute).ableIds; field.relational = (att as CodeGenUploadAttribute).showField; configModel = (att as CodeGenUploadAttribute).__config__.Adapt(); configModel.label = string.Format("{0}({1})", configModel.label, field.__vModel__); field.__config__ = configModel; fieldList.Add(field); } } } return fieldList; } /// /// 获取模板Excel头部. /// /// 对象. /// 实体. /// 1-主表,2-副表,3-子表. /// 替换内容. /// public static Dictionary GetTemplateHeader(T entity, int type, string replaceContent = default) { var dicItem = new Dictionary(); foreach (PropertyInfo prop in entity.GetType().GetProperties(BindingFlags.Instance | BindingFlags.Public).Where(p => p.GetCustomAttributes(typeof(CodeGenUploadAttribute), false).Length > 0)) { foreach (var att in prop.GetCustomAttributes(typeof(CodeGenUploadAttribute), false)) { string vModel = (att as CodeGenUploadAttribute).__Model__; CodeGenConfigModel congig = (att as CodeGenUploadAttribute).__config__.ToObject(); bool multiple = (bool)(att as CodeGenUploadAttribute)?.multiple; string format = (att as CodeGenUploadAttribute)?.format; int level = (int)(att as CodeGenUploadAttribute)?.level; var dic = CodeGenHelper.CodeGenTemplate(congig.jnpfKey, multiple, congig?.label, format, level); var title = string.Empty; switch (type) { case 2: title = string.Format("{0}(jnpf_{1}_jnpf_{2})", dic.Keys.FirstOrDefault(), replaceContent, vModel); break; case 3: title = string.Format("{0}({1}-{2})", dic.Keys.FirstOrDefault(), replaceContent, vModel); break; default: title = string.Format("{0}({1})", dic.Keys.FirstOrDefault(), vModel); break; } dicItem[title] = dic.Values.FirstOrDefault(); } } return dicItem; } /// /// 获取表数据关联. /// /// 实体信息. /// 表类型. /// 外键字段. /// 关联主表. /// 关联主键. /// public static DbTableRelationModel GetTableRelation(EntityInfo entityInfo, string type, string tableField = default, string relationTable = default, string relationField = default) { DbTableRelationModel model = new DbTableRelationModel(); model.typeId = type; model.table = entityInfo.DbTableName; model.tableName = entityInfo.TableDescription; model.tableKey = entityInfo.Columns.Find(it => it.IsPrimarykey).DbColumnName; model.relationTable = relationTable; model.tableField = tableField; model.relationField = relationField; return model; } /// /// 获取导入预览返回值. /// /// /// /// public async Task GetImportPreviewData(TemplateParsingBase tInfo, string fileName) { var resData = new List>(); var headerRow = new List(); var isChildTable = tInfo.selectKey.Any(x => tInfo.ChildTableFields.ContainsKey(x)); try { var FileEncode = tInfo.AllFieldsModel.Where(x => tInfo.selectKey.Contains(x.__vModel__)).ToList(); string? savePath = Path.Combine(FileVariable.TemporaryFilePath, fileName); // 得到数据 global::System.Data.DataTable? excelData = ExcelImportHelper.ToDataTable(savePath); if (isChildTable) excelData = ExcelImportHelper.ToDataTable(savePath, 0, 1); if (excelData.Columns.Count > tInfo.selectKey.Count) excelData.Columns.RemoveAt(tInfo.selectKey.Count); foreach (object? item in excelData.Columns) { excelData.Columns[item.ToString()].ColumnName = FileEncode.Where(x => x.__config__.label == item.ToString()).FirstOrDefault()?.__vModel__; } resData = excelData.ToObject>>(); if (resData.Any()) { if (isChildTable) { var hRow = resData[1].Copy(); foreach (var item in hRow) { if (item.Key.Contains("tableField") && item.Key.Contains("-")) { var childVModel = item.Key.Split("-").First(); if (!headerRow.Any(x => x.id.Equals(childVModel))) { var child = new List(); hRow.Where(x => x.Key.Contains(childVModel)).ToList().ForEach(x => { child.Add(new { id = x.Key.Replace(childVModel + "-", string.Empty), fullName = x.Value.ToString().Replace(string.Format("({0})", x.Key), string.Empty) }); }); headerRow.Add(new { id = childVModel, fullName = tInfo.AllFieldsModel.Find(x => x.__vModel__.Equals(childVModel)).__config__.label.Replace(string.Format("({0})", childVModel), string.Empty), children = child }); } } else { headerRow.Add(new { id = item.Key, fullName = item.Value.ToString().Replace(string.Format("({0})", item.Key), string.Empty) }); } } resData.Remove(resData.First()); resData.Remove(resData.First()); } else { foreach (var item in resData.First().Copy()) headerRow.Add(new { id = item.Key, fullName = item.Value.ToString().Replace(string.Format("({0})", item.Key), string.Empty) }); resData.Remove(resData.First()); } } } catch (Exception e) { throw Oops.Oh(ErrorCode.D1410); } try { // 带子表字段数据导入 if (isChildTable) { var newData = new List>(); var singleForm = tInfo.selectKey.Where(x => !x.Contains("tableField")).ToList(); var childTableVModel = tInfo.AllFieldsModel.Where(x => x.__config__.jnpfKey.Equals(JnpfKeyConst.TABLE)).Select(x => x.__vModel__).ToList(); resData.ForEach(dataItem => { var addItem = new Dictionary(); var isNextRow = false; singleForm.ForEach(item => { if (dataItem[item].IsNotEmptyOrNull()) isNextRow = true; }); // 单条数据 (多行子表数据合并) if (isNextRow) { singleForm.ForEach(item => addItem.Add(item, dataItem[item])); // 子表数据 childTableVModel.ForEach(item => { var childAddItem = new Dictionary(); tInfo.selectKey.Where(x => x.Contains(item) && x != item).ToList().ForEach(it => { childAddItem.Add(it.Replace(item + "-", string.Empty), dataItem[it]); }); addItem.Add(item, new List> { childAddItem }); }); newData.Add(addItem); } else { var item = newData.LastOrDefault(); if (item != null) { // 子表数据 childTableVModel.ForEach(citem => { var childAddItem = new Dictionary(); tInfo.selectKey.Where(x => x.Contains(citem)).ToList().ForEach(it => { if (dataItem.ContainsKey(it)) childAddItem.Add(it.Replace(citem + "-", string.Empty), dataItem[it]); }); if (!item.ContainsKey(citem)) { item.Add(citem, new List> { childAddItem }); } else { var childList = item[citem].ToObject>>(); childList.Add(childAddItem); item[citem] = childList; } }); } else { singleForm.ForEach(item => addItem.Add(item, dataItem[item])); // 子表数据 childTableVModel.ForEach(item => { var childAddItem = new Dictionary(); tInfo.selectKey.Where(x => x.Contains(item)).ToList().ForEach(it => { if (dataItem.ContainsKey(it)) childAddItem.Add(it.Replace(item + "-", string.Empty), dataItem[it]); }); addItem.Add(item, new List> { childAddItem }); }); newData.Add(addItem); } } }); resData = newData; } } catch { throw Oops.Oh(ErrorCode.D1412); } resData.ForEach(items => { foreach (var item in items) { var vmodel = tInfo.AllFieldsModel.FirstOrDefault(x => x.__vModel__.Equals(item.Key)); if (vmodel != null && vmodel.__config__.jnpfKey.Equals(JnpfKeyConst.DATE) && item.Value.IsNotEmptyOrNull()) items[item.Key] = item.Value + " "; } }); // 返回结果 return new { dataRow = resData, headerRow = headerRow }; } /// /// 导入数据. /// /// 模板信息. /// 数据集合. /// [成功列表,失败列表]. public async Task ImportMenuData(TemplateParsingBase tInfo, List> list) { List> userInputList = ImportFirstVerify(tInfo, list); List fieldsModelList = tInfo.AllFieldsModel.Where(x => tInfo.selectKey.Contains(x.__vModel__)).ToList(); var successList = new List>(); var errorsList = new List>(); // 捞取控件解析数据 var cData = await GetCDataList(tInfo.AllFieldsModel, new Dictionary>>()); var res = await ImportDataAssemble(fieldsModelList, userInputList, cData); res.Where(x => x.ContainsKey("errorsInfo")).ToList().ForEach(item => errorsList.Add(item)); res.Where(x => !x.ContainsKey("errorsInfo")).ToList().ForEach(item => successList.Add(item)); try { // 唯一验证已处理，入库前去掉. tInfo.AllFieldsModel.Where(x => x.__config__.jnpfKey.Equals(JnpfKeyConst.COMINPUT) && x.__config__.unique).ToList().ForEach(item => item.__config__.unique = false); _sqlSugarClient.BeginTran(); foreach (var item in successList) { if (item.ContainsKey("Update_MainTablePrimary_Id")) { string? mainId = item["Update_MainTablePrimary_Id"].ToString(); // modified by PhilPan 2023-04-12 提交和返回值不序列化 var haveTableSql = await _runService.GetUpdateSqlByTemplate(tInfo, new VisualDevModelDataUpInput() { data = item }, mainId); foreach (var it in haveTableSql) await _databaseService.ExecuteSql(tInfo.DbLink, it); // 修改功能数据 } else { if ((tInfo.visualDevEntity?.EnableFlow.Equals(1)).ParseToBool()) { var flowId = _repository.AsSugarClient().Queryable().First(x => x.Id.Equals(tInfo.visualDevEntity.Id)).FlowId; await _flowTaskService.Create(new Common.Models.WorkFlow.FlowTaskSubmitModel() { formData = item, flowId = flowId, flowUrgent = 1, status = 1 }); } else { string? mainId = YitIdHelper.NextId().ToString(); // modified by PhilPan 2023-04-12 提交和返回值不序列化 var haveTableSql = await _runService.GetCreateSqlByTemplate(tInfo, new VisualDevModelDataCrInput() { data = item }, mainId); // 主表自增长Id. if (haveTableSql.ContainsKey("MainTableReturnIdentity")) { mainId = haveTableSql["MainTableReturnIdentity"].First().First().Value.ToString(); haveTableSql.Remove("MainTableReturnIdentity"); } foreach (var it in haveTableSql) await _databaseService.ExecuteSql(tInfo.DbLink, it.Key, it.Value); // 新增功能数据 } } } _sqlSugarClient.CommitTran(); } catch (Exception e) { _sqlSugarClient.RollbackTran(); throw; } errorsList.ForEach(item => { if (item.ContainsKey("errorsInfo") && item["errorsInfo"].IsNotEmptyOrNull()) item["errorsInfo"] = item["errorsInfo"].ToString().TrimStart(',').TrimEnd(','); }); return new object[] { successList, errorsList }; } /// /// Excel 转输出 Model. /// /// 模板信息. /// 数据列表. /// 导出文件名称. /// 手动输入第一行（合并主表列和各个子表列）. /// dynamic. public async Task ExcelCreateModel(TemplateParsingBase tInfo, List> realList, string excelName = null, Dictionary firstColumns = null) { List templateList = new List(); List columnList = new List(); try { ExcelConfig excelconfig = new ExcelConfig(); excelconfig.FileName = (excelName.IsNullOrEmpty() ? YitIdHelper.NextId().ToString() : excelName) + ".xls"; excelconfig.HeadFont = "微软雅黑"; excelconfig.HeadPoint = 10; excelconfig.IsAllSizeColumn = true; excelconfig.ColumnModel = new List(); foreach (string? item in tInfo.selectKey) { var excelColumn = tInfo.AllFieldsModel.Find(t => t.__vModel__ == item); if (excelColumn != null) { excelconfig.ColumnModel.Add(new ExcelColumnModel() { Column = item, ExcelColumn = excelColumn.__config__.label }); columnList.Add(excelColumn.__config__.label); } } string? addPath = Path.Combine(FileVariable.TemporaryFilePath, excelconfig.FileName); var fs = firstColumns == null ? ExcelExportHelper>.ExportMemoryStream(realList, excelconfig, columnList) : ExcelExportHelper>.ExportMemoryStream(realList, excelconfig, columnList, firstColumns); var flag = await _fileManager.UploadFileByType(fs, FileVariable.TemporaryFilePath, excelconfig.FileName); if (flag) { fs.Flush(); fs.Close(); } var name = excelconfig.FileName; var url = "/api/file/Download?encryption=" + DESCEncryption.Encrypt(_userManager.UserId + "|" + excelconfig.FileName + "|" + addPath, "JNPF"); return new { name = name, url = url }; } catch (Exception) { throw; } } /// /// 导入功能数据初步验证. /// private List> ImportFirstVerify(TemplateParsingBase tInfo, List> list) { var errorKey = "errorsInfo"; var resList = new List>(); list.ForEach(item => { var addItem = item.Copy(); addItem.Add(errorKey, string.Empty); resList.Add(addItem); }); #region 验证必填控件 var childTableList = tInfo.AllFieldsModel.Where(x => x.__config__.jnpfKey.Equals(JnpfKeyConst.TABLE)).Select(x => x.__vModel__).ToList(); var requiredList = tInfo.AllFieldsModel.Where(x => x.__config__.required).ToList(); var VModelList = requiredList.Select(x => x.__vModel__).ToList(); if (VModelList.Any()) { var newResList = new List>(); resList.ForEach(items => { var newItems = items.Copy(); foreach (var item in items) { if (item.Value.IsNullOrEmpty() && VModelList.Contains(item.Key)) { var errorInfo = requiredList.Find(x => x.__vModel__.Equals(item.Key)).__config__.label + ": 值不能为空"; if (newItems.ContainsKey(errorKey)) newItems[errorKey] = newItems[errorKey] + "," + errorInfo; else newItems.Add(errorKey, errorInfo); } // 子表 if (childTableList.Contains(item.Key)) { item.Value.ToObject>>().ForEach(childItems => { foreach (var childItem in childItems) { if (childItem.Value.IsNullOrEmpty() && VModelList.Contains(item.Key + "-" + childItem.Key)) { var errorInfo = tInfo.AllFieldsModel.Find(x => x.__vModel__.Equals(item.Key)).__config__.children.Find(x => x.__vModel__.Equals(item.Key + "-" + childItem.Key)).__config__.label + ": 值不能为空"; if (newItems.ContainsKey(errorKey)) newItems[errorKey] = newItems[errorKey] + "," + errorInfo; else newItems.Add(errorKey, errorInfo); } } }); } } newResList.Add(newItems); }); resList = newResList; } #endregion #region 验证唯一 var uniqueList = tInfo.AllFieldsModel.Where(x => x.__config__.unique).ToList(); VModelList = uniqueList.Select(x => x.__vModel__).ToList(); if (uniqueList.Any()) { resList.ForEach(items => { foreach (var item in items) { if (VModelList.Contains(item.Key)) { var vlist = new List>(); resList.Where(x => x.ContainsKey(item.Key) && x.ContainsValue(item.Value)).ToList().ForEach(it => { foreach (var dic in it) { if (dic.Value != null && item.Value != null && dic.Key.Equals(item.Key) && dic.Value.Equals(item.Value)) { vlist.Add(it); break; } } }); if (vlist.Count > 1) { for (var i = 1; i < vlist.Count; i++) { var errorInfo = tInfo.AllFieldsModel.Find(x => x.__vModel__.Equals(item.Key)).__config__.label + ": 值不能重复"; items[errorKey] = items[errorKey] + "," + errorInfo; } } } // 子表 var updateItemCList = new List>(); var ctItemErrors = new List(); if (childTableList.Contains(item.Key)) { var itemCList = item.Value.ToObject>>(); itemCList.ForEach(childItems => { if (tInfo.dataType.Equals("2")) { foreach (var childItem in childItems) { var uniqueKey = item.Key + "-" + childItem.Key; if (VModelList.Contains(uniqueKey)) { var vlist = itemCList.Where(x => x.ContainsKey(childItem.Key) && x.ContainsValue(childItem.Value)).ToList(); if (!updateItemCList.Any(x => x.ContainsKey(childItem.Key) && x.ContainsValue(childItem.Value))) updateItemCList.Add(vlist.Last()); } } } else { foreach (var childItem in childItems) { var uniqueKey = item.Key + "-" + childItem.Key; if (VModelList.Contains(uniqueKey) && childItem.Value != null) { var vlist = itemCList.Where(x => x.ContainsKey(childItem.Key) && x.ContainsValue(childItem.Value)).ToList(); if (vlist.Count > 1) { for (var i = 1; i < vlist.Count; i++) { var errorTxt = tInfo.AllFieldsModel.Find(x => x.__vModel__.Equals(uniqueKey)).__config__.label + ": 值不能重复"; if (!ctItemErrors.Any(x => x.Equals(errorTxt))) ctItemErrors.Add(errorTxt); } } } } } }); } if (tInfo.dataType.Equals("2") && updateItemCList.Any()) items[item.Key] = updateItemCList; if (ctItemErrors.Any()) { items[errorKey] = items[errorKey].IsNullOrEmpty() ? string.Join(",", ctItemErrors) : items[errorKey] + "," + string.Join(",", ctItemErrors); } } }); // 表里的数据验证唯一 List? relationKey = new List(); List? auxiliaryFieldList = tInfo.AuxiliaryTableFieldsModelList.Select(x => x.__config__.tableName).Distinct().ToList(); auxiliaryFieldList.ForEach(tName => { string? tableField = tInfo.AllTable.Find(tf => tf.table == tName)?.tableField; relationKey.Add(tInfo.MainTableName + "." + tInfo.MainPrimary + "=" + tName + "." + tableField); }); resList.ForEach(allDataMap => { List? fieldList = new List(); var whereList = new List(); fieldList.Add(string.Format("{0}.{1}", tInfo.MainTableName, tInfo.MainPrimary)); tInfo.SingleFormData.Where(x => x.__config__.jnpfKey.Equals(JnpfKeyConst.COMINPUT) && x.__config__.unique).ToList().ForEach(item => { fieldList.Add(string.Format("{0}.{1} {2}", item.__config__.tableName, item.__vModel__.Split("_jnpf_").Last(), item.__vModel__)); if (allDataMap.ContainsKey(item.__vModel__) && allDataMap[item.__vModel__] != null) { whereList.Add(new ConditionalCollections() { ConditionalList = new List>() { new KeyValuePair(WhereType.Or, new ConditionalModel { FieldName = string.Format("{0}.{1}", item.__config__.tableName, item.__vModel__.Split("_jnpf_").Last()), ConditionalType =allDataMap.ContainsKey(item.__vModel__) ? ConditionalType.Equal: ConditionalType.IsNullOrEmpty, FieldValue = allDataMap.ContainsKey(item.__vModel__) ? allDataMap[item.__vModel__].ToString() : string.Empty, }) } }); } }); var itemWhere = _repository.AsSugarClient().SqlQueryable("@").Where(whereList).ToSqlString(); if (!itemWhere.Equals("@")) { var whereStrList = new List(); whereStrList.AddRange(relationKey); whereStrList.Add(itemWhere.Split("WHERE").Last()); var querStr = string.Format( "select {0} from {1} where {2}", string.Join(",", fieldList), auxiliaryFieldList.Any() ? tInfo.MainTableName + "," + string.Join(",", auxiliaryFieldList) : tInfo.MainTableName, string.Join(" and ", whereStrList)); // 多表， 联合查询 var res = _databaseService.GetInterFaceData(tInfo.DbLink, querStr, null).ToObject>>(); if (res.Any()) { var errorList = new List(); res.ForEach(items => { if (tInfo.dataType.Equals("2")) { if (items.Last().Value == null || items.Last().Value.Equals(allDataMap[items.Last().Key].ToString())) { if (!allDataMap.ContainsKey("Update_MainTablePrimary_Id")) allDataMap.Add("Update_MainTablePrimary_Id", items[tInfo.MainPrimary]); } } else { if (items.Last().Value == null || items.Last().Value.Equals(allDataMap[items.Last().Key].ToString())) { var errorInfo = tInfo.SingleFormData.First(x => x.__vModel__.Equals(items.Last().Key))?.__config__.label + ": 值不能重复"; if (allDataMap.ContainsKey(errorKey)) { if (!allDataMap[errorKey].ToString().Contains(errorInfo)) allDataMap[errorKey] = allDataMap[errorKey] + "," + errorInfo; } else { allDataMap.Add(errorKey, errorInfo); } } } }); } } }); } #endregion resList.ForEach(item => { if (item[errorKey].IsNullOrEmpty()) item.Remove(errorKey); }); return resList; } /// /// 获取模板控件解析数据. /// /// /// /// private async Task>>> GetCDataList(List listFieldsModel, Dictionary>> resData) { foreach (var item in listFieldsModel.Where(x => !x.__config__.jnpfKey.Equals(JnpfKeyConst.TABLE)).ToList()) { var addItem = new List>(); switch (item.__config__.jnpfKey) { case JnpfKeyConst.COMSELECT: { if (!resData.ContainsKey(JnpfKeyConst.COMSELECT)) { var dataList = await _repository.AsSugarClient().Queryable().Where(x => x.DeleteMark == null && x.EnabledMark == 1) .Select(x => new OrganizeEntity { Id = x.Id, OrganizeIdTree = x.OrganizeIdTree, FullName = x.FullName }).ToListAsync(); dataList.ForEach(item => { if (item.OrganizeIdTree.IsNullOrEmpty()) item.OrganizeIdTree = item.Id; var orgNameList = new List(); item.OrganizeIdTree.Split(",").ToList().ForEach(it => { var org = dataList.Find(x => x.Id == it); if (org != null) orgNameList.Add(org.FullName); }); Dictionary dictionary = new Dictionary(); dictionary.Add(item.OrganizeIdTree, string.Join("/", orgNameList)); addItem.Add(dictionary); }); resData.Add(JnpfKeyConst.COMSELECT, addItem); } } break; case JnpfKeyConst.ADDRESS: { string? addCacheKey = "Import_Address"; if (!resData.ContainsKey(JnpfKeyConst.ADDRESS)) { if (_cacheManager.Exists(addCacheKey)) { addItem = _cacheManager.Get(addCacheKey).ToObject>>(); resData.Add(JnpfKeyConst.ADDRESS, addItem); } else { var dataList = await _repository.AsSugarClient().Queryable().Select(x => new ProvinceEntity { Id = x.Id, ParentId = x.ParentId, Type = x.Type, FullName = x.FullName }).ToListAsync(); // 处理省市区树 dataList.Where(x => x.Type == "1").ToList().ForEach(item => { item.QuickQuery = item.FullName; item.Description = item.Id; Dictionary address = new Dictionary(); address.Add(item.Description, item.QuickQuery); addItem.Add(address); }); dataList.Where(x => x.Type == "2").ToList().ForEach(item => { item.QuickQuery = dataList.Find(x => x.Id == item.ParentId).QuickQuery + "/" + item.FullName; item.Description = dataList.Find(x => x.Id == item.ParentId).Description + "," + item.Id; Dictionary address = new Dictionary(); address.Add(item.Description, item.QuickQuery); addItem.Add(address); }); dataList.Where(x => x.Type == "3").ToList().ForEach(item => { item.QuickQuery = dataList.Find(x => x.Id == item.ParentId).QuickQuery + "/" + item.FullName; item.Description = dataList.Find(x => x.Id == item.ParentId).Description + "," + item.Id; Dictionary address = new Dictionary(); address.Add(item.Description, item.QuickQuery); addItem.Add(address); }); dataList.Where(x => x.Type == "4").ToList().ForEach(item => { ProvinceEntity? it = dataList.Find(x => x.Id == item.ParentId); if (it != null) { item.QuickQuery = it.QuickQuery + "/" + item.FullName; item.Description = it.Description + "," + item.Id; Dictionary address = new Dictionary(); address.Add(item.Description, item.QuickQuery); addItem.Add(address); } }); dataList.ForEach(it => { if (it.Description.IsNotEmptyOrNull()) { Dictionary dictionary = new Dictionary(); dictionary.Add(it.Description, it.QuickQuery); addItem.Add(dictionary); } }); var noTypeList = dataList.Where(x => x.Type.IsNullOrWhiteSpace()).ToList(); foreach (var it in noTypeList) { it.QuickQuery = GetAddressByPList(noTypeList, it); it.Description = GetAddressIdByPList(noTypeList, it); } foreach (var it in noTypeList) { Dictionary address = new Dictionary(); address.Add(it.Description, it.QuickQuery); addItem.Add(address); } _cacheManager.Set(addCacheKey, addItem, TimeSpan.FromDays(7)); // 缓存七天 resData.Add(JnpfKeyConst.ADDRESS, addItem); } } } break; case JnpfKeyConst.GROUPSELECT: { if (!resData.ContainsKey(JnpfKeyConst.GROUPSELECT)) { var dataList = await _repository.AsSugarClient().Queryable().Where(x => x.DeleteMark == null).Select(x => new GroupEntity() { Id = x.Id, EnCode = x.EnCode }).ToListAsync(); dataList.ForEach(item => { Dictionary dictionary = new Dictionary(); dictionary.Add(item.Id, item.EnCode); addItem.Add(dictionary); }); resData.Add(JnpfKeyConst.GROUPSELECT, addItem); } } break; case JnpfKeyConst.ROLESELECT: { if (!resData.ContainsKey(JnpfKeyConst.ROLESELECT)) { var dataList = await _repository.AsSugarClient().Queryable().Where(x => x.DeleteMark == null).Select(x => new RoleEntity() { Id = x.Id, EnCode = x.EnCode }).ToListAsync(); dataList.ForEach(item => { Dictionary dictionary = new Dictionary(); dictionary.Add(item.Id, item.EnCode); addItem.Add(dictionary); }); resData.Add(JnpfKeyConst.ROLESELECT, addItem); } } break; case JnpfKeyConst.SWITCH: { if (!resData.ContainsKey(item.__vModel__)) { Dictionary dictionary = new Dictionary(); dictionary.Add("1", item.activeTxt); addItem.Add(dictionary); Dictionary dictionary2 = new Dictionary(); dictionary2.Add("0", item.inactiveTxt); addItem.Add(dictionary2); resData.Add(item.__vModel__, addItem); } } break; case JnpfKeyConst.CHECKBOX: case JnpfKeyConst.SELECT: case JnpfKeyConst.RADIO: { if (!resData.ContainsKey(item.__vModel__)) { var propsValue = string.Empty; var propsLabel = string.Empty; var children = string.Empty; if (item.__config__.jnpfKey.Equals(JnpfKeyConst.TREESELECT) || item.__config__.jnpfKey.Equals(JnpfKeyConst.CASCADER)) { propsValue = item.props.props.value; propsLabel = item.props.props.label; children = item.props.props.children; } else { propsValue = item.__config__.props.value; propsLabel = item.__config__.props.label; children = item.__config__.props.children; } if (item.__config__.dataType.Equals("static")) { if (item.__slot__ != null && item.__slot__.options != null) { item.__slot__.options.ForEach(option => { Dictionary dictionary = new Dictionary(); dictionary.Add(option[propsValue.ToLower()].ToString(), option[propsLabel.ToLower()].ToString()); addItem.Add(dictionary); }); resData.Add(item.__vModel__, addItem); } } else if (item.__config__.dataType.Equals("dictionary")) { var dictionaryDataList = await _repository.AsSugarClient().Queryable((a, b) => new JoinQueryInfos(JoinType.Left, b.Id == a.DictionaryTypeId)) .WhereIF(item.__config__.dictionaryType.IsNotEmptyOrNull(), (a, b) => b.Id == item.__config__.dictionaryType || b.EnCode == item.__config__.dictionaryType) .Where(a => a.DeleteMark == null).Select(a => new { a.Id, a.EnCode, a.FullName }).ToListAsync(); foreach (var it in dictionaryDataList) { Dictionary dictionary = new Dictionary(); if (propsValue.Equals("id")) dictionary.Add(it.Id, it.FullName); if (propsValue.Equals("enCode")) dictionary.Add(it.EnCode, it.FullName); addItem.Add(dictionary); } resData.Add(item.__vModel__, addItem); } else if (item.__config__.dataType.Equals("dynamic")) { List> list = new List>(); // 获取远端数据 DataInterfaceEntity? dynamic = await _dataInterfaceService.GetInfo(item.__config__.propsUrl); if (dynamic == null) continue; switch (dynamic.DataType) { // SQL数据 case 1: { // 远端数据 配置参数 List? parameter = new List(); if (_userManager.ToKen != null) { var userInfo = await _userManager.GetUserInfo(); parameter.Add(new SugarParameter("@user", _userManager.UserId)); parameter.Add(new SugarParameter("@organization", _userManager?.User?.OrganizeId)); var subordinates = userInfo.subordinates.ToList(); subordinates.Add(_userManager.UserId); parameter.Add(new SugarParameter("@currentUsersAndSubordinates", subordinates)); var subsidiary = userInfo.subsidiary.ToList(); subsidiary.Add(_userManager.User.OrganizeId); parameter.Add(new SugarParameter("@currentOrganizationAndSuborganization", subsidiary)); var chargeorganization = userInfo.dataScope.Where(x => x.organizeId == userInfo.organizeId && x.Select).ToList().FirstOrDefault(); parameter.Add(new SugarParameter("@chargeorganization", chargeorganization?.organizeId)); subsidiary = userInfo.dataScope.Select(x => x.organizeId).Intersect(userInfo.subsidiary).ToList(); parameter.Add(new SugarParameter("@currentChargeorganizationAndSuborganization", subsidiary)); } DbLinkEntity? linkEntity = await _repository.AsSugarClient().Queryable().Where(m => m.Id == dynamic.DBLinkId && m.DeleteMark == null).FirstAsync(); if (linkEntity == null) linkEntity = _databaseService.GetTenantDbLink(_userManager.TenantId, _userManager.TenantDbName); _dataInterfaceService.ReplaceParameterValue(dynamic, new Dictionary()); System.Data.DataTable? dt = _databaseService.GetInterFaceData(linkEntity, dynamic.Query, parameter.ToArray()); List> dynamicDataList = dt.ToJsonString().ToObject>>(); foreach (Dictionary? it in dynamicDataList) { Dictionary dynamicDic = new Dictionary(); dynamicDic.Add(it[propsValue]?.ToString(), it[propsLabel]?.ToString()); list.Add(dynamicDic); } } break; // 静态数据 case 2: { foreach (var data in JValue.Parse(dynamic.Query)) { Dictionary dic = new Dictionary(); dic[data.Value(propsValue)] = data.Value(propsLabel); list.Add(dic); if (children != null && data.Value(children) != null && data.Value(children).ToString().IsNotEmptyOrNull()) list.AddRange(GetDynamicInfiniteData(data.Value(children).ToString(), item.__config__.props)); } } break; // Api数据 case 3: { // 获取远端数据 var dynamicList = await _dataInterfaceService.GetInfo(item.__config__.propsUrl); if (dynamicList == null) break; var redisName = CommonConst.VISUALDEV + _userManager.TenantId + "_" + item.__config__.jnpfKey + "_" + item.__config__.renderKey; switch (dynamicList.DataType) { case 1: // SQL数据 { _dataInterfaceService.ReplaceParameterValue(dynamicList, new Dictionary()); var pObj = await _dataInterfaceService.GetData(dynamicList); list = pObj.ToJsonString().ToObject>>(); } break; case 2: // 静态数据 { foreach (var data in JValue.Parse(dynamicList.Query)) { Dictionary dic = new Dictionary(); dic[propsValue] = data.Value(propsValue); dic[propsLabel] = data.Value(propsLabel); list.Add(dic); if (children != null && data.Value(children) != null && data.Value(children).ToString() != "") list.AddRange(GetDynamicInfiniteData(data.Value(children).ToString(), item.__config__.props)); } } break; case 3: // Api数据 { var result = await GetApiDataByTypePreview(dynamicList); // 请求接口 list = result.ContainsKey("list") ? result["list"].ToObject>>() : new List>(); } break; } } break; } resData.Add(item.__vModel__, list); } } } break; case JnpfKeyConst.TREESELECT: case JnpfKeyConst.CASCADER: { if (!resData.ContainsKey(item.__vModel__)) { if (item.__config__.dataType.Equals("static")) { if (item.options != null) resData.Add(item.__vModel__, GetStaticList(item)); } else if (item.__config__.dataType.Equals("dictionary")) { var dictionaryDataList = await _repository.AsSugarClient().Queryable((a, b) => new JoinQueryInfos(JoinType.Left, b.Id == a.DictionaryTypeId)) .WhereIF(item.__config__.dictionaryType.IsNotEmptyOrNull(), (a, b) => b.Id == item.__config__.dictionaryType || b.EnCode == item.__config__.dictionaryType) .Where(a => a.DeleteMark == null).Select(a => new { a.Id, a.EnCode, a.FullName }).ToListAsync(); foreach (var it in dictionaryDataList) { Dictionary dictionary = new Dictionary(); dictionary.Add(it.Id, it.FullName); dictionary.Add(it.EnCode, it.FullName); addItem.Add(dictionary); } resData.Add(item.__vModel__, addItem); } else if (item.__config__.dataType.Equals("dynamic")) { var propsValue = string.Empty; var propsLabel = string.Empty; var children = string.Empty; if (item.__config__.jnpfKey.Equals(JnpfKeyConst.TREESELECT) || item.__config__.jnpfKey.Equals(JnpfKeyConst.CASCADER)) { propsValue = item.props.props.value; propsLabel = item.props.props.label; children = item.props.props.children; } else { propsValue = item.__config__.props.value; propsLabel = item.__config__.props.label; children = item.__config__.props.children; } List> list = new List>(); // 获取远端数据 DataInterfaceEntity? dynamic = await _dataInterfaceService.GetInfo(item.__config__.propsUrl); if (dynamic == null) continue; switch (dynamic.DataType) { // SQL数据 case 1: { // 远端数据 配置参数 List? parameter = new List(); if (_userManager.ToKen != null) { var userInfo = await _userManager.GetUserInfo(); parameter.Add(new SugarParameter("@user", _userManager.UserId)); parameter.Add(new SugarParameter("@organization", _userManager?.User?.OrganizeId)); var subordinates = userInfo.subordinates.ToList(); subordinates.Add(_userManager.UserId); parameter.Add(new SugarParameter("@currentUsersAndSubordinates", subordinates)); var subsidiary = userInfo.subsidiary.ToList(); subsidiary.Add(_userManager.User.OrganizeId); parameter.Add(new SugarParameter("@currentOrganizationAndSuborganization", subsidiary)); var chargeorganization = userInfo.dataScope.Where(x => x.organizeId == userInfo.organizeId && x.Select).ToList().FirstOrDefault(); parameter.Add(new SugarParameter("@chargeorganization", chargeorganization?.organizeId)); subsidiary = userInfo.dataScope.Select(x => x.organizeId).Intersect(userInfo.subsidiary).ToList(); parameter.Add(new SugarParameter("@currentChargeorganizationAndSuborganization", subsidiary)); } DbLinkEntity? linkEntity = await _repository.AsSugarClient().Queryable().Where(m => m.Id == dynamic.DBLinkId && m.DeleteMark == null).FirstAsync(); if (linkEntity == null) linkEntity = _databaseService.GetTenantDbLink(_userManager.TenantId, _userManager.TenantDbName); _dataInterfaceService.ReplaceParameterValue(dynamic, new Dictionary()); System.Data.DataTable? dt = _databaseService.GetInterFaceData(linkEntity, dynamic.Query, parameter.ToArray()); List> dynamicDataList = dt.ToJsonString().ToObject>>(); foreach (Dictionary? it in dynamicDataList) { Dictionary dynamicDic = new Dictionary(); dynamicDic.Add(it[propsValue]?.ToString(), it[propsLabel]?.ToString()); list.Add(dynamicDic); } } break; // 静态数据 case 2: { foreach (var data in JValue.Parse(dynamic.Query)) { Dictionary dic = new Dictionary(); dic[data.Value(propsValue)] = data.Value(propsLabel); list.Add(dic); if (children != null && data.Value(children) != null && data.Value(children).ToString().IsNotEmptyOrNull()) list.AddRange(GetDynamicInfiniteData(data.Value(children).ToString(), item.props.props)); } } break; // Api数据 case 3: { // 获取远端数据 var dynamicList = await _dataInterfaceService.GetInfo(item.__config__.propsUrl); if (dynamicList == null) break; var redisName = CommonConst.VISUALDEV + _userManager.TenantId + "_" + item.__config__.jnpfKey + "_" + item.__config__.renderKey; switch (dynamicList.DataType) { case 1: // SQL数据 { _dataInterfaceService.ReplaceParameterValue(dynamicList, new Dictionary()); var pObj = await _dataInterfaceService.GetData(dynamicList); list = pObj.ToJsonString().ToObject>>(); } break; case 2: // 静态数据 { foreach (var data in JValue.Parse(dynamicList.Query)) { Dictionary dic = new Dictionary(); dic[propsValue] = data.Value(propsValue); dic[propsLabel] = data.Value(propsLabel); list.Add(dic); if (children != null && data.Value(children) != null && data.Value(children).ToString() != "") list.AddRange(GetDynamicInfiniteData(data.Value(children).ToString(), item.props.props)); } } break; case 3: // Api数据 { var result = await GetApiDataByTypePreview(dynamicList); // 请求接口 list = result.ContainsKey("list") ? result["list"].ToObject>>() : new List>(); } break; } } break; } resData.Add(item.__vModel__, list); } } } break; case JnpfKeyConst.POPUPTABLESELECT: { if (!resData.ContainsKey(item.__vModel__)) { var popDataList = await GetDynamicList(item); resData.Add(item.__vModel__, popDataList); } } break; case JnpfKeyConst.USERSELECT: { if (!resData.ContainsKey(item.__vModel__)) { if (item.selectType.Equals("all")) { var dataList = await _repository.AsSugarClient().Queryable().Where(x => x.DeleteMark == null).Select(x => new UserEntity() { Id = x.Id, Account = x.Account }).ToListAsync(); dataList.ForEach(item => { Dictionary dictionary = new Dictionary(); dictionary.Add(item.Id, item.Account); addItem.Add(dictionary); }); resData.Add(item.__vModel__, addItem); } else if (item.selectType.Equals("custom")) { var userIdList = await _repository.AsSugarClient().Queryable() .WhereIF(item.ableUserIds.Any(), x => item.ableUserIds.Contains(x.UserId) || item.ableDepIds.Contains(x.ObjectId) || item.ablePosIds.Contains(x.ObjectId) || item.ableRoleIds.Contains(x.ObjectId) || item.ableGroupIds.Contains(x.ObjectId)).Select(x => x.UserId).ToListAsync(); var dataList = await _repository.AsSugarClient().Queryable().Where(x => x.DeleteMark == null && userIdList.Contains(x.Id)) .Select(x => new UserEntity() { Id = x.Id, Account = x.Account }).ToListAsync(); dataList.ForEach(item => { Dictionary dictionary = new Dictionary(); dictionary.Add(item.Id, item.Account); if (!addItem.Any(x => x.ContainsKey(item.Id))) addItem.Add(dictionary); }); resData.Add(item.__vModel__, addItem); } } } break; case JnpfKeyConst.USERSSELECT: { if (!resData.ContainsKey(item.__vModel__)) { if (item.selectType.Equals("all")) { if (item.multiple) { (await _repository.AsSugarClient().Queryable().Where(x => x.DeleteMark == null).Select(x => new { x.Id, x.RealName, x.Account }).ToListAsync()).ForEach(item => { Dictionary user = new Dictionary(); user.Add(item.Id + "--user", item.RealName + "/" + item.Account); addItem.Add(user); }); var dataList = await _repository.AsSugarClient().Queryable().Where(x => x.DeleteMark == null) .Select(x => new OrganizeEntity { Id = x.Id, OrganizeIdTree = x.OrganizeIdTree, FullName = x.FullName, EnCode = x.EnCode }).ToListAsync(); dataList.ForEach(item => { Dictionary user = new Dictionary(); user.Add(item.Id + "--department", item.FullName + "/" + item.EnCode); addItem.Add(user); if (item.OrganizeIdTree.IsNullOrEmpty()) item.OrganizeIdTree = item.Id; var orgNameList = new List(); item.OrganizeIdTree.Split(",").ToList().ForEach(it => { var org = dataList.Find(x => x.Id == it); if (org != null) orgNameList.Add(org.FullName); }); Dictionary dictionary = new Dictionary(); dictionary.Add(item.Id + "--company", string.Join("/", orgNameList)); addItem.Add(dictionary); }); (await _repository.AsSugarClient().Queryable().Where(x => x.DeleteMark == null).Select(x => new { x.Id, x.FullName, x.EnCode }).ToListAsync()).ForEach(item => { Dictionary user = new Dictionary(); user.Add(item.Id + "--role", item.FullName + "/" + item.EnCode); addItem.Add(user); }); (await _repository.AsSugarClient().Queryable().Where(x => x.DeleteMark == null).Select(x => new { x.Id, x.FullName, x.EnCode }).ToListAsync()).ForEach(item => { Dictionary user = new Dictionary(); user.Add(item.Id + "--position", item.FullName + "/" + item.EnCode); addItem.Add(user); }); (await _repository.AsSugarClient().Queryable().Where(x => x.DeleteMark == null).Select(x => new { x.Id, x.FullName, x.EnCode }).ToListAsync()).ForEach(item => { Dictionary user = new Dictionary(); user.Add(item.Id + "--group", item.FullName + "/" + item.EnCode); addItem.Add(user); }); } else { var dataList = await _repository.AsSugarClient().Queryable().Where(x => x.DeleteMark == null).Select(x => new UserEntity() { Id = x.Id, Account = x.Account }).ToListAsync(); dataList.ForEach(item => { Dictionary dictionary = new Dictionary(); dictionary.Add(item.Id + "--user", item.Account); if (!addItem.Any(x => x.ContainsKey(item.Id))) addItem.Add(dictionary); }); } resData.Add(item.__vModel__, addItem); } else if (item.selectType.Equals("custom")) { if (item.ableIds.Any()) { var newAbleIds = new List(); item.ableIds.ForEach(x => newAbleIds.Add(x.Split("--").FirstOrDefault())); var userIdList = await _repository.AsSugarClient().Queryable().Where(x => newAbleIds.Contains(x.UserId) || newAbleIds.Contains(x.ObjectId)).Select(x => x.UserId).ToListAsync(); var dataList = await _repository.AsSugarClient().Queryable().Where(x => userIdList.Contains(x.Id)).Select(x => new UserEntity() { Id = x.Id, Account = x.Account }).ToListAsync(); dataList.ForEach(item => { Dictionary dictionary = new Dictionary(); dictionary.Add(item.Id + "--user", item.Account); if (!addItem.Any(x => x.ContainsKey(item.Id))) addItem.Add(dictionary); }); resData.Add(item.__vModel__, addItem); } } } } break; case JnpfKeyConst.DEPSELECT: { if (!resData.ContainsKey(item.__vModel__)) { if (item.selectType.Equals("all")) { var dataList = await _repository.AsSugarClient().Queryable().Where(x => x.DeleteMark == null && x.EnabledMark == 1).Select(x => new { x.Id, x.EnCode }).ToListAsync(); dataList.ForEach(item => { Dictionary dictionary = new Dictionary(); dictionary.Add(item.Id, item.EnCode); addItem.Add(dictionary); }); resData.Add(item.__vModel__, addItem); } else if (item.selectType.Equals("custom")) { if (item.ableDepIds.Any()) { var listQuery = new List>(); item.ableDepIds.ForEach(x => listQuery.Add(_repository.AsSugarClient().Queryable().Where(xx => xx.OrganizeIdTree.Contains(x)))); var dataList = await _repository.AsSugarClient().UnionAll(listQuery).Where(x => x.DeleteMark == null).Select(x => new { x.Id, x.EnCode }).ToListAsync(); dataList.ForEach(item => { Dictionary dictionary = new Dictionary(); dictionary.Add(item.Id, item.EnCode); if (!addItem.Any(x => x.ContainsKey(item.Id))) addItem.Add(dictionary); }); resData.Add(item.__vModel__, addItem); } } } } break; case JnpfKeyConst.POSSELECT: { if (!resData.ContainsKey(item.__vModel__)) { if (item.selectType.Equals("all")) { var dataList = await _repository.AsSugarClient().Queryable().Where(x => x.DeleteMark == null).Select(x => new PositionEntity() { Id = x.Id, EnCode = x.EnCode }).ToListAsync(); dataList.ForEach(item => { Dictionary dictionary = new Dictionary(); dictionary.Add(item.Id, item.EnCode); addItem.Add(dictionary); }); resData.Add(item.__vModel__, addItem); } else if (item.selectType.Equals("custom")) { if (item.ableDepIds.Any()) { var dataList = await _repository.AsSugarClient().Queryable().Where(x => x.DeleteMark == null && item.ableDepIds.Contains(x.OrganizeId)) .Select(x => new PositionEntity() { Id = x.Id, EnCode = x.EnCode }).ToListAsync(); dataList.ForEach(item => { Dictionary dictionary = new Dictionary(); dictionary.Add(item.Id, item.EnCode); addItem.Add(dictionary); }); resData.Add(item.__vModel__, addItem); } if (item.ablePosIds.Any()) { var dataList = await _repository.AsSugarClient().Queryable().Where(x => x.DeleteMark == null && item.ablePosIds.Contains(x.Id)) .Select(x => new PositionEntity() { Id = x.Id, EnCode = x.EnCode }).ToListAsync(); dataList.ForEach(item => { Dictionary dictionary = new Dictionary(); dictionary.Add(item.Id, item.EnCode); addItem.Add(dictionary); }); if (resData.ContainsKey(item.__vModel__)) { var newAddItem = new List>(); foreach (var it in addItem) { var tempIt = it.FirstOrDefault().Value; if (tempIt.IsNotEmptyOrNull() && !resData[item.__vModel__].Any(x => x.ContainsValue(tempIt))) newAddItem.Add(it); } resData[item.__vModel__].AddRange(newAddItem); } else resData.Add(item.__vModel__, addItem); } } } } break; } } listFieldsModel.Where(x => x.__config__.jnpfKey.Equals(JnpfKeyConst.TABLE)).ToList().ForEach(async item => { var res = await GetCDataList(item.__config__.children, resData); if (res.Any()) foreach (var it in res) if (!resData.ContainsKey(it.Key)) resData.Add(it.Key, it.Value); }); return resData; } /// /// 导入数据组装. /// /// 控件列表. /// 导入数据列表. /// 控件解析缓存数据. /// private async Task>> ImportDataAssemble(List fieldsModelList, List> dataList, Dictionary>> cDataList) { var errorKey = "errorsInfo"; UserEntity? userInfo = _userManager.User; var resList = new List>(); foreach (var dataItems in dataList) { var newDataItems = dataItems.Copy(); foreach (var item in dataItems) { var vModel = fieldsModelList.Find(x => x.__vModel__.Equals(item.Key)); if (vModel == null) continue; var dicList = new List>(); if (cDataList.ContainsKey(vModel.__config__.jnpfKey)) dicList = cDataList[vModel.__config__.jnpfKey]; if ((dicList == null || !dicList.Any()) && cDataList.ContainsKey(vModel.__vModel__)) dicList = cDataList[vModel.__vModel__]; switch (vModel.__config__.jnpfKey) { case JnpfKeyConst.DATE: try { if (item.Value.IsNotEmptyOrNull()) { var date = DateTime.Parse(item.Value.ToString()); newDataItems[item.Key] = date.ParseToUnixTime().ToString(); } } catch { var errorInfo = vModel.__config__.label + ": 日期格式错误"; if (newDataItems.ContainsKey(errorKey)) newDataItems[errorKey] = newDataItems[errorKey] + "," + errorInfo; else newDataItems.Add(errorKey, errorInfo); } break; case JnpfKeyConst.TIME: // 时间选择 try { if (item.Value.IsNotEmptyOrNull()) { var timeRange = item.Value.ToString(); string? udate = string.Format("{0:yyyy-MM-dd}", DateTime.MaxValue); DateTime.Parse(udate + " " + timeRange); newDataItems[item.Key] = item.Value.ToString(); } } catch { var errorInfo = vModel.__config__.label + ": 时间格式错误"; if (newDataItems.ContainsKey(errorKey)) newDataItems[errorKey] = newDataItems[errorKey] + "," + errorInfo; else newDataItems.Add(errorKey, errorInfo); } break; case JnpfKeyConst.COMSELECT: case JnpfKeyConst.ADDRESS: { if (item.Value.IsNotEmptyOrNull()) { if (vModel.multiple) { var addList = new List(); item.Value.ToString().Split(",").ToList().ForEach(it => { if (vModel.__config__.jnpfKey.Equals(JnpfKeyConst.COMSELECT) || (it.Count(x => x == '/') == vModel.level || (vModel.level == 3 && it.Count(x => x == '/') == 2 && it.Contains("市辖区")))) { if (dicList.Where(x => x.ContainsValue(it)).Any()) { var value = dicList.Where(x => x.ContainsValue(it)).FirstOrDefault().FirstOrDefault(); addList.Add(value.Key.Split(",").ToList()); } else { var errorInfo = vModel.__config__.label + ": 值无法匹配"; if (newDataItems.ContainsKey(errorKey)) newDataItems[errorKey] = newDataItems[errorKey] + "," + errorInfo; else newDataItems.Add(errorKey, errorInfo); } } else { var errorInfo = vModel.__config__.label + ": 值无法匹配"; if (newDataItems.ContainsKey(errorKey)) newDataItems[errorKey] = newDataItems[errorKey] + "," + errorInfo; else newDataItems.Add(errorKey, errorInfo); } }); newDataItems[item.Key] = addList; } else { if (vModel.__config__.jnpfKey.Equals(JnpfKeyConst.COMSELECT) || (item.Value?.ToString().Count(x => x == '/') == vModel.level || (vModel.level == 3 && item.Value.ToString().Count(x => x == '/') == 2 && item.Value.ToString().Contains("市辖区")))) { if (dicList.Where(x => x.ContainsValue(item.Value?.ToString())).Any()) { var value = dicList.Where(x => x.ContainsValue(item.Value?.ToString())).FirstOrDefault().FirstOrDefault(); newDataItems[item.Key] = value.Key.Split(",").ToList(); } else { var errorInfo = vModel.__config__.label + ": 值无法匹配"; if (newDataItems.ContainsKey(errorKey)) newDataItems[errorKey] = newDataItems[errorKey] + "," + errorInfo; else newDataItems.Add(errorKey, errorInfo); } } else { var errorInfo = vModel.__config__.label + ": 值无法匹配"; if (newDataItems.ContainsKey(errorKey)) newDataItems[errorKey] = newDataItems[errorKey] + "," + errorInfo; else newDataItems.Add(errorKey, errorInfo); } } } } break; case JnpfKeyConst.CHECKBOX: case JnpfKeyConst.SWITCH: case JnpfKeyConst.SELECT: case JnpfKeyConst.RADIO: { if (item.Value.IsNotEmptyOrNull()) { if (vModel.multiple || vModel.__config__.jnpfKey.Equals(JnpfKeyConst.CHECKBOX)) { var addList = new List(); item.Value.ToString().Split(",").ToList().ForEach(it => { if (dicList.Where(x => x.ContainsValue(it)).Any()) { if (dicList.Count(x => x.ContainsValue(it)) > 1) { var errorInfo = vModel.__config__.label + ": 存在多条值-无法匹配"; if (newDataItems.ContainsKey(errorKey)) newDataItems[errorKey] = newDataItems[errorKey] + "," + errorInfo; else newDataItems.Add(errorKey, errorInfo); } else { var value = dicList.Where(x => x.ContainsValue(it)).FirstOrDefault().FirstOrDefault(); addList.Add(value.Key); } } else { var errorInfo = vModel.__config__.label + ": 值无法匹配"; if (newDataItems.ContainsKey(errorKey)) newDataItems[errorKey] = newDataItems[errorKey] + "," + errorInfo; else newDataItems.Add(errorKey, errorInfo); } }); newDataItems[item.Key] = addList; } else { if (dicList.Where(x => x.ContainsValue(item.Value.ToString())).Any()) { if (dicList.Count(x => x.ContainsValue(item.Value.ToString())) > 1) { var errorInfo = vModel.__config__.label + ": 存在多条值-无法匹配"; if (newDataItems.ContainsKey(errorKey)) newDataItems[errorKey] = newDataItems[errorKey] + "," + errorInfo; else newDataItems.Add(errorKey, errorInfo); } else { var value = dicList.Where(x => x.ContainsValue(item.Value?.ToString())).FirstOrDefault().FirstOrDefault(); newDataItems[item.Key] = value.Key; } } else { var errorInfo = vModel.__config__.label + ": 值无法匹配"; if (newDataItems.ContainsKey(errorKey)) newDataItems[errorKey] = newDataItems[errorKey] + "," + errorInfo; else newDataItems.Add(errorKey, errorInfo); } } } } break; case JnpfKeyConst.DEPSELECT: case JnpfKeyConst.POSSELECT: case JnpfKeyConst.GROUPSELECT: case JnpfKeyConst.ROLESELECT: case JnpfKeyConst.USERSELECT: { if (item.Value.IsNotEmptyOrNull()) { if (vModel.multiple) { var addList = new List(); item.Value.ToString().Split(",").ToList().ForEach(it => { if (dicList.Where(x => x.ContainsValue(it.Split("/").Last())).Any()) { if (dicList.Count(x => x.ContainsValue(it.Split("/").Last())) > 1) { var errorInfo = vModel.__config__.label + ": 存在多条值-无法匹配"; if (newDataItems.ContainsKey(errorKey)) newDataItems[errorKey] = newDataItems[errorKey] + "," + errorInfo; else newDataItems.Add(errorKey, errorInfo); } else { var value = dicList.Where(x => x.ContainsValue(it.Split("/").Last())).FirstOrDefault().FirstOrDefault(); addList.Add(value.Key); } } else { var errorInfo = vModel.__config__.label + ": 值无法匹配"; if (newDataItems.ContainsKey(errorKey)) newDataItems[errorKey] = newDataItems[errorKey] + "," + errorInfo; else newDataItems.Add(errorKey, errorInfo); } }); newDataItems[item.Key] = addList; } else { if (dicList.Where(x => x.ContainsValue(item.Value.ToString().Split("/").Last())).Any()) { if (dicList.Count(x => x.ContainsValue(item.Value.ToString().Split("/").Last())) > 1) { var errorInfo = vModel.__config__.label + ": 存在多条值-无法匹配"; if (newDataItems.ContainsKey(errorKey)) newDataItems[errorKey] = newDataItems[errorKey] + "," + errorInfo; else newDataItems.Add(errorKey, errorInfo); } else { var value = dicList.Where(x => x.ContainsValue(item.Value?.ToString().Split("/").Last())).FirstOrDefault().FirstOrDefault(); newDataItems[item.Key] = value.Key; } } else { var errorInfo = vModel.__config__.label + ": 值无法匹配"; if (newDataItems.ContainsKey(errorKey)) newDataItems[errorKey] = newDataItems[errorKey] + "," + errorInfo; else newDataItems.Add(errorKey, errorInfo); } } } } break; case JnpfKeyConst.USERSSELECT: { if (item.Value.IsNotEmptyOrNull()) { if (vModel.multiple) { var addList = new List(); item.Value.ToString().Split(",").ToList().ForEach(it => { if (dicList.Where(x => x.ContainsValue(it)).Any()) { if (dicList.Count(x => x.ContainsValue(it)) > 1) { var errorInfo = vModel.__config__.label + ": 存在多条值-无法匹配"; if (newDataItems.ContainsKey(errorKey)) newDataItems[errorKey] = newDataItems[errorKey] + "," + errorInfo; else newDataItems.Add(errorKey, errorInfo); } else { var value = dicList.Where(x => x.ContainsValue(it)).FirstOrDefault().FirstOrDefault(); addList.Add(value.Key); } } else { if (dicList.Where(x => x.ContainsValue(it.Split("/").Last())).Any()) { if (dicList.Count(x => x.ContainsValue(it.Split("/").Last())) > 1) { var errorInfo = vModel.__config__.label + ": 存在多条值-无法匹配"; if (newDataItems.ContainsKey(errorKey)) newDataItems[errorKey] = newDataItems[errorKey] + "," + errorInfo; else newDataItems.Add(errorKey, errorInfo); } else { var value = dicList.Where(x => x.ContainsValue(it.Split("/").Last())).FirstOrDefault().FirstOrDefault(); addList.Add(value.Key); } } else { var errorInfo = vModel.__config__.label + ": 值无法匹配"; if (newDataItems.ContainsKey(errorKey)) newDataItems[errorKey] = newDataItems[errorKey] + "," + errorInfo; else newDataItems.Add(errorKey, errorInfo); } } }); newDataItems[item.Key] = addList; } else { if (dicList.Where(x => x.ContainsValue(item.Value.ToString())).Any()) { if (dicList.Count(x => x.ContainsValue(item.Value.ToString())) > 1) { var errorInfo = vModel.__config__.label + ": 存在多条值-无法匹配"; if (newDataItems.ContainsKey(errorKey)) newDataItems[errorKey] = newDataItems[errorKey] + "," + errorInfo; else newDataItems.Add(errorKey, errorInfo); } else { var value = dicList.Where(x => x.ContainsValue(item.Value?.ToString())).FirstOrDefault().FirstOrDefault(); newDataItems[item.Key] = value.Key; } } else { if (dicList.Where(x => x.ContainsValue(item.Value.ToString().Split("/").Last())).Any()) { if (dicList.Count(x => x.ContainsValue(item.Value.ToString().Split("/").Last())) > 1) { var errorInfo = vModel.__config__.label + ": 存在多条值-无法匹配"; if (newDataItems.ContainsKey(errorKey)) newDataItems[errorKey] = newDataItems[errorKey] + "," + errorInfo; else newDataItems.Add(errorKey, errorInfo); } else { var value = dicList.Where(x => x.ContainsValue(item.Value?.ToString().Split("/").Last())).FirstOrDefault().FirstOrDefault(); newDataItems[item.Key] = value.Key; } } else { var errorInfo = vModel.__config__.label + ": 值无法匹配"; if (newDataItems.ContainsKey(errorKey)) newDataItems[errorKey] = newDataItems[errorKey] + "," + errorInfo; else newDataItems.Add(errorKey, errorInfo); } } } } } break; case JnpfKeyConst.TREESELECT: { if (item.Value.IsNotEmptyOrNull()) { if (vModel.multiple) { var addList = new List(); item.Value.ToString().Split(",").ToList().ForEach(it => { if (dicList.Where(x => x.ContainsValue(it)).Any()) { if (dicList.Count(x => x.ContainsValue(it)) > 1) { var errorInfo = vModel.__config__.label + ": 存在多条值-无法匹配"; if (newDataItems.ContainsKey(errorKey)) newDataItems[errorKey] = newDataItems[errorKey] + "," + errorInfo; else newDataItems.Add(errorKey, errorInfo); } else { var value = dicList.Where(x => x.ContainsValue(it)).FirstOrDefault().FirstOrDefault(); addList.Add(value.Key); } } else { var errorInfo = vModel.__config__.label + ": 值无法匹配"; if (newDataItems.ContainsKey(errorKey)) newDataItems[errorKey] = newDataItems[errorKey] + "," + errorInfo; else newDataItems.Add(errorKey, errorInfo); } }); newDataItems[item.Key] = addList; } else { if (dicList.Where(x => x.ContainsValue(item.Value.ToString())).Any()) { if (dicList.Count(x => x.ContainsValue(item.Value.ToString())) > 1) { var errorInfo = vModel.__config__.label + ": 存在多条值-无法匹配"; if (newDataItems.ContainsKey(errorKey)) newDataItems[errorKey] = newDataItems[errorKey] + "," + errorInfo; else newDataItems.Add(errorKey, errorInfo); } else { var value = dicList.Where(x => x.ContainsValue(item.Value?.ToString())).FirstOrDefault().FirstOrDefault(); newDataItems[item.Key] = value.Key; } } else { var errorInfo = vModel.__config__.label + ": 值无法匹配"; if (newDataItems.ContainsKey(errorKey)) newDataItems[errorKey] = newDataItems[errorKey] + "," + errorInfo; else newDataItems.Add(errorKey, errorInfo); } } } } break; case JnpfKeyConst.CASCADER: { if (item.Value.IsNotEmptyOrNull()) { if (vModel.props.props.multiple) { var addsList = new List(); item.Value.ToString().Split(",").ToList().ForEach(its => { var txtList = its.Split(vModel.separator).ToList(); var add = new List(); txtList.ForEach(it => { if (dicList.Where(x => x.ContainsValue(it)).Any()) { if (dicList.Count(x => x.ContainsValue(it)) > 1) { var errorInfo = vModel.__config__.label + ": 存在多条值-无法匹配"; if (newDataItems.ContainsKey(errorKey)) newDataItems[errorKey] = newDataItems[errorKey] + "," + errorInfo; else newDataItems.Add(errorKey, errorInfo); } else { var value = dicList.Where(x => x.ContainsValue(it)).FirstOrDefault().FirstOrDefault(); add.Add(value.Key); } } else { var errorInfo = vModel.__config__.label + ": 值无法匹配"; if (newDataItems.ContainsKey(errorKey)) newDataItems[errorKey] = newDataItems[errorKey] + "," + errorInfo; else newDataItems.Add(errorKey, errorInfo); } }); addsList.Add(add); }); newDataItems[item.Key] = addsList; } else { var txtList = item.Value.ToString().Split(vModel.separator).ToList(); var addList = new List(); txtList.ForEach(it => { if (dicList.Where(x => x.ContainsValue(it)).Any()) { if (dicList.Count(x => x.ContainsValue(it)) > 1) { var errorInfo = vModel.__config__.label + ": 存在多条值-无法匹配"; if (newDataItems.ContainsKey(errorKey)) newDataItems[errorKey] = newDataItems[errorKey] + "," + errorInfo; else newDataItems.Add(errorKey, errorInfo); } else { var value = dicList.Where(x => x.ContainsValue(it)).FirstOrDefault().FirstOrDefault(); addList.Add(value.Key); } } else { var errorInfo = vModel.__config__.label + ": 值无法匹配"; if (newDataItems.ContainsKey(errorKey)) newDataItems[errorKey] = newDataItems[errorKey] + "," + errorInfo; else newDataItems.Add(errorKey, errorInfo); } }); newDataItems[item.Key] = addList; } } } break; case JnpfKeyConst.TABLE: { if (item.Value != null) { var valueList = item.Value.ToObject>>(); var newValueList = new List>(); valueList.ForEach(it => { var addValue = new Dictionary(); foreach (var value in it) addValue.Add(vModel.__vModel__ + "-" + value.Key, value.Value); newValueList.Add(addValue); }); var res = await ImportDataAssemble(vModel.__config__.children, newValueList, cDataList); if (res.Any(x => x.ContainsKey(errorKey))) { if (newDataItems.ContainsKey(errorKey)) newDataItems[errorKey] = newDataItems[errorKey] + "," + res.FirstOrDefault(x => x.ContainsKey(errorKey))[errorKey].ToString(); else newDataItems.Add(errorKey, res.FirstOrDefault(x => x.ContainsKey(errorKey))[errorKey].ToString()); res.Remove(res.FirstOrDefault(x => x.ContainsKey(errorKey))); } var result = new List>(); res.ForEach(it => { var addValue = new Dictionary(); foreach (var value in it) addValue.Add(value.Key.Replace(vModel.__vModel__ + "-", string.Empty), value.Value); result.Add(addValue); }); newDataItems[item.Key] = result; } } break; case JnpfKeyConst.RATE: if (item.Value.IsNotEmptyOrNull()) { try { var value = int.Parse(item.Value.ToString()); if (vModel.max != null) { if (vModel.max < value) { var errorInfo = vModel.__config__.label + ": 评分超过设置的最大值"; if (newDataItems.ContainsKey(errorKey)) newDataItems[errorKey] = newDataItems[errorKey] + "," + errorInfo; else newDataItems.Add(errorKey, errorInfo); } } } catch { var errorInfo = vModel.__config__.label + ": 评分格式错误"; if (newDataItems.ContainsKey(errorKey)) newDataItems[errorKey] = newDataItems[errorKey] + "," + errorInfo; else newDataItems.Add(errorKey, errorInfo); } } break; case JnpfKeyConst.SLIDER: if (item.Value.IsNotEmptyOrNull()) { try { var value = int.Parse(item.Value.ToString()); if (vModel.max != null) { if (vModel.max < value) { var errorInfo = vModel.__config__.label + ": 滑块超过设置的最大值"; if (newDataItems.ContainsKey(errorKey)) newDataItems[errorKey] = newDataItems[errorKey] + "," + errorInfo; else newDataItems.Add(errorKey, errorInfo); } } if (vModel.min != null) { if (vModel.min > value) { var errorInfo = vModel.__config__.label + ": 滑块超过设置的最小值"; if (newDataItems.ContainsKey(errorKey)) newDataItems[errorKey] = newDataItems[errorKey] + "," + errorInfo; else newDataItems.Add(errorKey, errorInfo); } } } catch { var errorInfo = vModel.__config__.label + ": 滑块格式错误"; if (newDataItems.ContainsKey(errorKey)) newDataItems[errorKey] = newDataItems[errorKey] + "," + errorInfo; else newDataItems.Add(errorKey, errorInfo); } } break; case JnpfKeyConst.NUMINPUT: if (item.Value.IsNotEmptyOrNull()) { try { var value = int.Parse(item.Value.ToString()); if (vModel.max != null) { if (vModel.max < value) { var errorInfo = vModel.__config__.label + ": 数字输入超过设置的最大值"; if (newDataItems.ContainsKey(errorKey)) newDataItems[errorKey] = newDataItems[errorKey] + "," + errorInfo; else newDataItems.Add(errorKey, errorInfo); } } if (vModel.min != null) { if (vModel.min > value) { var errorInfo = vModel.__config__.label + ": 数字输入超过设置的最小值"; if (newDataItems.ContainsKey(errorKey)) newDataItems[errorKey] = newDataItems[errorKey] + "," + errorInfo; else newDataItems.Add(errorKey, errorInfo); } } } catch { var errorInfo = vModel.__config__.label + ": 数字输入格式错误"; if (newDataItems.ContainsKey(errorKey)) newDataItems[errorKey] = newDataItems[errorKey] + "," + errorInfo; else newDataItems.Add(errorKey, errorInfo); } } break; } } // 系统自动生成控件 foreach (var item in dataItems) { if (newDataItems.ContainsKey(errorKey)) continue; // 如果存在错误信息 则 不生成 var vModel = fieldsModelList.Find(x => x.__vModel__.Equals(item.Key)); if (vModel == null) continue; switch (vModel.__config__.jnpfKey) { case JnpfKeyConst.BILLRULE: string billNumber = await _billRuleService.GetBillNumber(vModel.__config__.rule); if (!"单据规则不存在".Equals(billNumber)) newDataItems[item.Key] = billNumber; else newDataItems[item.Key] = string.Empty; break; case JnpfKeyConst.MODIFYUSER: newDataItems[item.Key] = string.Empty; break; case JnpfKeyConst.CREATEUSER: newDataItems[item.Key] = userInfo.Id; break; case JnpfKeyConst.MODIFYTIME: newDataItems[item.Key] = string.Empty; break; case JnpfKeyConst.CREATETIME: newDataItems[item.Key] = string.Format("{0:yyyy-MM-dd HH:mm:ss}", DateTime.Now); break; case JnpfKeyConst.CURRPOSITION: string? pid = await _repository.AsSugarClient().Queryable((a, b) => new JoinQueryInfos(JoinType.Left, b.Id == a.PositionId)) .Where((a, b) => a.Id == userInfo.Id && a.DeleteMark == null).Select((a, b) => a.PositionId).FirstAsync(); if (pid.IsNotEmptyOrNull()) newDataItems[item.Key] = pid; else newDataItems[item.Key] = string.Empty; break; case JnpfKeyConst.CURRORGANIZE: if (userInfo.OrganizeId != null) newDataItems[item.Key] = userInfo.OrganizeId; else newDataItems[item.Key] = string.Empty; break; } } if (newDataItems.ContainsKey(errorKey)) { if (dataItems.ContainsKey(errorKey)) dataItems[errorKey] = newDataItems[errorKey].ToString(); else dataItems.Add(errorKey, newDataItems[errorKey]); resList.Add(dataItems); } else { resList.Add(newDataItems); } } return resList; } /// /// 处理静态数据. /// /// /// private List> GetStaticList(FieldsModel model) { PropsBeanModel? props = model.props.props; List? optionList = GetTreeOptions(model.options, props); List> list = new List>(); foreach (OptionsModel? item in optionList) { Dictionary option = new Dictionary(); option.Add(item.value, item.label); list.Add(option); } return list; } /// /// options无限级. /// /// private List GetTreeOptions(List model, PropsBeanModel props) { List options = new List(); foreach (object? item in model) { OptionsModel option = new OptionsModel(); Dictionary? dicObject = item.ToJsonString().ToObject>(); option.label = dicObject[props.label].ToString(); option.value = dicObject[props.value].ToString(); if (dicObject.ContainsKey(props.children)) { List? children = dicObject[props.children].ToJsonString().ToObject>(); options.AddRange(GetTreeOptions(children, props)); } options.Add(option); } return options; } /// /// 获取动态无限级数据. /// /// /// /// private List> GetDynamicInfiniteData(string data, PropsBeanModel props) { List> list = new List>(); string? value = props.value; string? label = props.label; string? children = props.children; foreach (JToken? info in JToken.Parse(data)) { Dictionary dic = new Dictionary(); dic[info.Value(value)] = info.Value(label); list.Add(dic); if (info.Value(children) != null && info.Value(children).ToString() != string.Empty) list.AddRange(GetDynamicInfiniteData(info.Value(children).ToString(), props)); } return list; } /// /// 处理远端数据. /// /// /// private async Task>> GetDynamicList(FieldsModel model) { List> list = new List>(); // 获取远端数据 DataInterfaceEntity? dynamic = await _dataInterfaceService.GetInfo(model.__config__.propsUrl); if (dynamic == null) return list; var propsValue = string.Empty; var propsLabel = string.Empty; var children = string.Empty; if (model.__config__.jnpfKey.Equals(JnpfKeyConst.TREESELECT) || model.__config__.jnpfKey.Equals(JnpfKeyConst.CASCADER)) { propsValue = model.props.props.value; propsLabel = model.props.props.label; children = model.props.props.children; } else { propsValue = model.__config__.props.value; propsLabel = model.__config__.props.label; children = model.__config__.props.children; } switch (dynamic.DataType) { // SQL数据 case 1: { // 远端数据 配置参数 List? parameter = new List(); if (_userManager.ToKen != null) { var userInfo = await _userManager.GetUserInfo(); parameter.Add(new SugarParameter("@user", _userManager.UserId)); parameter.Add(new SugarParameter("@organization", _userManager?.User?.OrganizeId)); var subordinates = userInfo.subordinates.ToList(); subordinates.Add(_userManager.UserId); parameter.Add(new SugarParameter("@currentUsersAndSubordinates", subordinates)); var subsidiary = userInfo.subsidiary.ToList(); subsidiary.Add(_userManager.User.OrganizeId); parameter.Add(new SugarParameter("@currentOrganizationAndSuborganization", subsidiary)); var chargeorganization = userInfo.dataScope.Where(x => x.organizeId == userInfo.organizeId && x.Select).ToList().FirstOrDefault(); parameter.Add(new SugarParameter("@chargeorganization", chargeorganization?.organizeId)); subsidiary = userInfo.dataScope.Select(x => x.organizeId).Intersect(userInfo.subsidiary).ToList(); parameter.Add(new SugarParameter("@currentChargeorganizationAndSuborganization", subsidiary)); } DbLinkEntity? linkEntity = await _repository.AsSugarClient().Queryable().Where(m => m.Id == dynamic.DBLinkId && m.DeleteMark == null).FirstAsync(); if (linkEntity == null) linkEntity = _databaseService.GetTenantDbLink(_userManager.TenantId, _userManager.TenantDbName); _dataInterfaceService.ReplaceParameterValue(dynamic, new Dictionary()); System.Data.DataTable? dt = _databaseService.GetInterFaceData(linkEntity, dynamic.Query, parameter.ToArray()); List> dynamicDataList = dt.ToJsonString().ToObject>>(); foreach (Dictionary? item in dynamicDataList) { Dictionary dynamicDic = new Dictionary(); dynamicDic.Add(item[propsValue]?.ToString(), item[propsLabel]?.ToString()); list.Add(dynamicDic); } } break; // 静态数据 case 2: { foreach (var data in JValue.Parse(dynamic.Query)) { Dictionary dic = new Dictionary(); dic[data.Value(propsValue)] = data.Value(propsLabel); list.Add(dic); if (data.Value(children) != null && data.Value(children).ToString().IsNotEmptyOrNull()) list.AddRange(GetDynamicInfiniteData(data.Value(children).ToString(), model.props.props)); } } break; // Api数据 case 3: { // 获取远端数据 var dynamicList = await _dataInterfaceService.GetInfo(model.__config__.propsUrl); if (dynamicList == null) break; switch (dynamicList.DataType) { case 1: // SQL数据 { _dataInterfaceService.ReplaceParameterValue(dynamicList, new Dictionary()); var pObj = await _dataInterfaceService.GetData(dynamicList); list = pObj.ToJsonString().ToObject>>(); } break; case 2: // 静态数据 { foreach (var data in JValue.Parse(dynamicList.Query)) { Dictionary dic = new Dictionary(); dic[propsValue] = data.Value(propsValue); dic[propsLabel] = data.Value(propsLabel); list.Add(dic); if (data.Value(children) != null && data.Value(children).ToString() != "") list.AddRange(GetDynamicInfiniteData(data.Value(children).ToString(), model.props.props)); } } break; case 3: // Api数据 { var result = await GetApiDataByTypePreview(dynamicList); // 请求接口 list = result.ContainsKey("list") ? result["list"].ToObject>>() : new List>(); } break; } } break; } return list; } /// /// 根据不同规则请求接口(预览). /// /// /// private async Task GetApiDataByTypePreview(DataInterfaceEntity entity) { var result = new JObject(); var parameters = entity.RequestParameters.ToObject>(); var parametersHerader = entity.RequestHeaders.ToObject>(); var dic = new Dictionary(); var dicHerader = new Dictionary(); 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; } switch (entity.RequestMethod) { case "6": result = (await entity.Path.SetHeaders(dicHerader).SetQueries(dic).GetAsStringAsync()).ToObject(); break; case "7": result = (await entity.Path.SetHeaders(dicHerader).SetBody(dic).PostAsStringAsync()).ToObject(); break; } return result; } /// /// 递归获取手动添加的省市区,名称处理成树形结构. /// /// private string GetAddressByPList(List addressEntityList, ProvinceEntity pEntity) { if (pEntity.ParentId == null || pEntity.ParentId.Equals("-1")) { return pEntity.FullName; } else { var pItem = addressEntityList.Find(x => x.Id == pEntity.ParentId); if (pItem != null) pEntity.QuickQuery = GetAddressByPList(addressEntityList, pItem) + "/" + pEntity.FullName; else pEntity.QuickQuery = pEntity.FullName; return pEntity.QuickQuery; } } /// /// 递归获取手动添加的省市区,Id处理成树形结构. /// /// private string GetAddressIdByPList(List addressEntityList, ProvinceEntity pEntity) { if (pEntity.ParentId == null || pEntity.ParentId.Equals("-1")) { return pEntity.Id; } else { var pItem = addressEntityList.Find(x => x.Id == pEntity.ParentId); if (pItem != null) pEntity.Id = GetAddressIdByPList(addressEntityList, pItem) + "," + pEntity.Id; else pEntity.Id = pEntity.Id; return pEntity.Id; } } }