428 lines
19 KiB
C#
428 lines
19 KiB
C#
using APT.BaseData.Domain.Enums;
|
||
using APT.BaseData.Domain.IServices;
|
||
using APT.Infrastructure.Core;
|
||
using APT.BaseData.Domain.ApiModel.EX;
|
||
using APT.BaseData.Domain.ApiModel.FM;
|
||
using APT.BaseData.Domain.IServices.FM;
|
||
using Microsoft.AspNetCore.Mvc;
|
||
using System;
|
||
using System.Collections.Generic;
|
||
using System.ComponentModel;
|
||
using System.Linq;
|
||
using System.Linq.Expressions;
|
||
using System.Reflection;
|
||
using System.Text;
|
||
using APT.BaseData.Domain.Enums.PF;
|
||
using APT.BaseData.Domain.Entities;
|
||
using APT.Utility;
|
||
using APT.Infrastructure.Api;
|
||
|
||
namespace APT.PF.WebApi.Controllers.Api.EX
|
||
{
|
||
[Route("api/PF/Extend")]
|
||
public class ExtendController : CommonApiController
|
||
{
|
||
/// <summary>
|
||
/// 根据ID获得实体数据
|
||
/// </summary>
|
||
/// <param name="name"></param>
|
||
/// <returns></returns>
|
||
[HttpGet, Route("Enum")]
|
||
public JsonActionResult<string> Enum(string name)
|
||
{
|
||
return SafeExecute<string>(() =>
|
||
{
|
||
return APT.Utility.DataHelper.EnumToString(name);
|
||
});
|
||
}
|
||
|
||
/// <summary>
|
||
/// 根据枚举名称 获取 某个枚举
|
||
/// </summary>
|
||
/// <param name="name"></param>
|
||
/// <returns></returns>
|
||
[HttpGet, Route("GetEnum")]
|
||
public JsonActionResult<dynamic> GetEnum(string name)
|
||
{
|
||
return SafeExecute<dynamic>(() =>
|
||
{
|
||
return APT.Utility.DataHelper.GetEnum(name);
|
||
});
|
||
}
|
||
|
||
/// <summary>
|
||
/// 获取所有枚举信息
|
||
/// </summary>
|
||
/// <returns></returns>
|
||
[HttpGet, Route("GetAllEnum")]
|
||
public JsonActionResult<IEnumerable<APT.Utility.EnumInfo>> GetAllEnum()
|
||
{
|
||
return SafeExecute<IEnumerable<APT.Utility.EnumInfo>>(() =>
|
||
{
|
||
return APT.Utility.DataHelper.GetAllEnums();
|
||
});
|
||
}
|
||
|
||
[HttpPost, Route("EntityOrderPaged")]
|
||
public PagedActionResult<EntityModel> EntityOrderPaged([FromBody] KeywordPageFilter pageFilter)
|
||
{
|
||
return SafeGetPagedData<EntityModel>(ret =>
|
||
{
|
||
var formService = APT.Infrastructure.Api.ServiceLocator.Instance.GetService<IPFFormService>();
|
||
var files = System.IO.Directory.GetFiles(System.AppContext.BaseDirectory, "*.Domain.dll");
|
||
var tempFiles = System.IO.Directory.GetFiles(System.AppContext.BaseDirectory, "APT.Infrastructure.Core.dll");
|
||
if (files == null)
|
||
files = tempFiles;
|
||
else if (tempFiles != null)
|
||
{
|
||
var temps = files.ToList();
|
||
temps.AddRange(tempFiles);
|
||
files = temps.ToArray();
|
||
}
|
||
if (files == null || !files.Any()) return;
|
||
List<EntityModel> list = new List<EntityModel>();
|
||
foreach (var file in files)
|
||
{
|
||
var assembly = Assembly.LoadFrom(file);
|
||
if (assembly == null) continue;
|
||
foreach (var t in assembly.ExportedTypes)
|
||
{
|
||
var baseType = t.BaseType;
|
||
if (baseType == typeof(MesEntityBase) || baseType == typeof(MesTreeEntityBase))
|
||
{
|
||
EntityModel entityModel = new EntityModel();
|
||
string entityName = t.Name;
|
||
entityModel.EntityName = entityName;
|
||
entityModel.Label = t.Name;
|
||
|
||
var attrs = t.GetCustomAttributes(typeof(DescriptionAttribute), false);
|
||
if (attrs != null && attrs.Any())
|
||
{
|
||
var descAttr = attrs[0] as DescriptionAttribute;
|
||
entityModel.Label = descAttr.Description;
|
||
}
|
||
#region 设置模块
|
||
entityModel.ModuleType = (int)formService.GetModelTypeByName(entityName);
|
||
#endregion
|
||
|
||
list.Add(entityModel);
|
||
}
|
||
}
|
||
}
|
||
Expression<Func<EntityModel, bool>> predicate = t => true;
|
||
predicate = predicate.And(FilterHelper.GetExpression<EntityModel>(pageFilter.FilterGroup, null));
|
||
list = list.Where(predicate.Compile()).OrderBy(t => t.EntityName).ToList();
|
||
ret.TotalCount = list.Count;
|
||
ret.Data = list.Skip(pageFilter.Start).Take(pageFilter.Limit).ToArray();
|
||
});
|
||
}
|
||
|
||
|
||
[HttpPost, Route("EntityFieldOrderPaged")]
|
||
public PagedActionResult<EntityFieldModel> EntityFieldOrderPaged([FromBody] KeywordPageFilter pageFilter)
|
||
{
|
||
return SafeGetPagedData<EntityFieldModel>(ret =>
|
||
{
|
||
var list = GetTableField(pageFilter);
|
||
ret.TotalCount = list.Count;
|
||
ret.Data = list.Skip(pageFilter.Start).Take(pageFilter.Limit).ToArray();
|
||
});
|
||
}
|
||
private List<EntityFieldModel> GetTableField(KeywordPageFilter pageFilter, string parentName = "")
|
||
{
|
||
List<EntityFieldModel> list = new List<EntityFieldModel>();
|
||
if (string.IsNullOrEmpty(pageFilter.Keyword)) return list;
|
||
var entityType = APT.Utility.DataHelper.GetTypeByEntityName(pageFilter.Keyword);
|
||
if (entityType == null) return list;
|
||
foreach (var property in entityType.GetProperties())
|
||
{
|
||
var propertyType = property.PropertyType;
|
||
EntityFieldModel entityField = new EntityFieldModel();
|
||
entityField.ID = property.Name + "." + propertyType.Name;
|
||
entityField.Field = property.Name;
|
||
entityField.NavField = property.Name;
|
||
if (!string.IsNullOrEmpty(parentName))
|
||
{
|
||
entityField.ID = parentName + "." + entityField.ID;
|
||
entityField.NavField = parentName + "." + entityField.NavField;
|
||
}
|
||
entityField.FieldTypeName = propertyType.Name;
|
||
entityField.Label = entityField.Field;
|
||
var attrs = property.GetCustomAttributes(typeof(DescriptionAttribute), false);
|
||
if (attrs != null && attrs.Any())
|
||
{
|
||
var descAttr = attrs[0] as DescriptionAttribute;
|
||
entityField.Label = descAttr.Description;
|
||
}
|
||
if (entityField.Field.StartsWith("VIR_", StringComparison.OrdinalIgnoreCase) ||
|
||
entityField.Field.StartsWith("VIRTUAL_", StringComparison.OrdinalIgnoreCase) ||
|
||
entityField.Field.ToUpper() != entityField.Field)
|
||
entityField.FieldType = (int)EntityFieldTypeEnum.虚字段;
|
||
|
||
//判断是否为泛型
|
||
if (propertyType.IsGenericType)
|
||
{
|
||
#region 泛型类型
|
||
var types = propertyType.GetGenericArguments();
|
||
Type realType = null;
|
||
if (types != null && types.Any())
|
||
realType = types[0];
|
||
var genericType = propertyType.GetGenericTypeDefinition();
|
||
var genericTypeName = genericType.Name.Substring(0, genericType.Name.Length - 2);
|
||
if (genericTypeName.Contains("Nullable"))
|
||
entityField.FieldTypeName = realType.Name + " ?";
|
||
else
|
||
entityField.FieldTypeName = genericTypeName + "<" + realType.Name + ">";
|
||
if (realType.IsClass)
|
||
{
|
||
var baseType = realType.BaseType;
|
||
if (baseType == typeof(MesEntityBase) || baseType == typeof(MesTreeEntityBase))
|
||
{
|
||
entityField.FieldEntityName = realType.Name;
|
||
entityField.FieldType = (int)EntityFieldTypeEnum.导航字段;
|
||
}
|
||
}
|
||
#endregion
|
||
}
|
||
else if (propertyType.IsClass) //如果属性类型为Class并且继承至系统基类 则为导航属性
|
||
{
|
||
var baseType = propertyType.BaseType;
|
||
if (baseType == typeof(MesEntityBase) || baseType == typeof(MesTreeEntityBase))
|
||
{
|
||
entityField.FieldEntityName = propertyType.Name;
|
||
entityField.FieldType = (int)EntityFieldTypeEnum.导航字段;
|
||
}
|
||
}
|
||
|
||
|
||
#region 添加字段额外信息
|
||
StringBuilder stringBuilder = new StringBuilder();
|
||
attrs = property.GetCustomAttributes(typeof(EnumNameAttribute), false);
|
||
if (attrs != null && attrs.Any())
|
||
{
|
||
var enumAttr = attrs[0] as EnumNameAttribute;
|
||
stringBuilder.Append("枚举:" + enumAttr.EnumName);
|
||
stringBuilder.Append(";");
|
||
}
|
||
attrs = property.GetCustomAttributes(typeof(CUniqueAttribute), false);
|
||
if (attrs != null && attrs.Any())
|
||
{
|
||
stringBuilder.Append("字段唯一");
|
||
stringBuilder.Append(";");
|
||
}
|
||
attrs = property.GetCustomAttributes(typeof(CodeRuleAttribute), false);
|
||
if (attrs != null && attrs.Any())
|
||
{
|
||
var codeRuleAttr = attrs[0] as CodeRuleAttribute;
|
||
if (codeRuleAttr.CodeRuleTypes != null && codeRuleAttr.CodeRuleTypes.Any())
|
||
{
|
||
stringBuilder.Append("编码类型:");
|
||
foreach (var ct in codeRuleAttr.CodeRuleTypes)
|
||
stringBuilder.Append(System.Enum.GetName(typeof(PFCodeRuleType), ct) + "(" + ct + "),");
|
||
stringBuilder.Append(";");
|
||
}
|
||
}
|
||
if (stringBuilder.Length > 0)
|
||
{
|
||
stringBuilder.Length--;
|
||
entityField.FieldInfo = stringBuilder.ToString();
|
||
}
|
||
#endregion
|
||
|
||
|
||
list.Add(entityField);
|
||
}
|
||
Expression<Func<EntityFieldModel, bool>> predicate = t => true;
|
||
predicate = predicate.And(FilterHelper.GetExpression<EntityFieldModel>(pageFilter.FilterGroup, null));
|
||
list = list.Where(predicate.Compile()).OrderBy(t => t.Field).ToList();
|
||
return list;
|
||
}
|
||
|
||
|
||
[HttpPost, Route("TreeEntityField")]
|
||
public PagedActionResult<EntityFieldModel> TreeEntityField([FromBody] KeywordPageFilter pageFilter)
|
||
{
|
||
|
||
return SafeGetPagedData<EntityFieldModel>((result) =>
|
||
{
|
||
|
||
List<EntityFieldModel> list = new List<EntityFieldModel>();
|
||
//var filedType = (int)PFFieldTypeEnum.表字段;
|
||
//if (!string.IsNullOrEmpty(pageFilter.Parameter1))
|
||
// filedType = int.Parse(pageFilter.Parameter1);
|
||
//if (string.IsNullOrEmpty(pageFilter.Keyword))
|
||
// return list;
|
||
//if (filedType == (int)PFFieldTypeEnum.表字段)
|
||
//{
|
||
// var parentField = pageFilter.FilterGroup.Rules.FirstOrDefault(x => x.Field == "PARENT_ID");
|
||
// var parentName = "";
|
||
// if (parentField == null)
|
||
// {
|
||
// var form = this.GetEntityByRedis<T_PF_FORM>(pageFilter.Keyword, pageFilter.GetOrgId());
|
||
// if (form == null)
|
||
// this.ThrowError("020015");
|
||
// if (string.IsNullOrEmpty(form.TABLE_NAME))
|
||
// this.ThrowError("020016");
|
||
// pageFilter.Keyword = form.TABLE_NAME;
|
||
// }
|
||
// else
|
||
// {
|
||
// var infos = parentField.Value.ToString().Split(new char[] { '.' });
|
||
// pageFilter.Keyword = infos[infos.Length - 1];
|
||
// parentName = string.Join('.', infos.Take(infos.Length - 1));
|
||
// parentName = parentName.Trim('.');
|
||
// pageFilter.FilterGroup.Rules.Clear();
|
||
// }
|
||
// var pagelist = GetTableField(pageFilter, parentName);
|
||
// foreach (var d in pagelist)
|
||
// {
|
||
// var treeNode = new TreeNode<EntityFieldModel>();
|
||
// treeNode.Node = d;
|
||
// treeNode.IsLeaf = true;
|
||
// treeNode.Level = 0;
|
||
// if (d.FieldType == (int)EntityFieldTypeEnum.导航字段|| d.FieldType == (int)EntityFieldTypeEnum.虚字段)
|
||
// {
|
||
// treeNode.IsLeaf = false;
|
||
// }
|
||
// list.Add(treeNode);
|
||
// }
|
||
//}
|
||
//else
|
||
//{
|
||
Dictionary<string, string> dicTree = new Dictionary<string, string>();
|
||
dicTree.Add("层级", "Level");
|
||
dicTree.Add("是否叶子", "IsLeaf");
|
||
foreach (var key in dicTree.Keys)
|
||
{
|
||
var model = new EntityFieldModel()
|
||
{
|
||
NavField = dicTree[key],
|
||
Label = key,
|
||
FIELD_TYPE = (int)PFFieldTypeEnum.树字段,
|
||
ID = Guid.NewGuid().ToString(),
|
||
};
|
||
list.Add(model);
|
||
}
|
||
//}
|
||
result.Data = list.Skip(pageFilter.Start).Take(pageFilter.Limit);
|
||
result.TotalCount = list.Count;
|
||
});
|
||
|
||
|
||
}
|
||
|
||
[HttpPost, Route("EntityField")]
|
||
public JsonActionResult<IEnumerable<TreeNode<EntityFieldModel>>> EntityField([FromBody] KeywordPageFilter pageFilter)
|
||
{
|
||
|
||
return SafeExecute<IEnumerable<TreeNode<EntityFieldModel>>>(() =>
|
||
{
|
||
|
||
List<TreeNode<EntityFieldModel>> list = new List<TreeNode<EntityFieldModel>>();
|
||
//var filedType = (int)PFFieldTypeEnum.表字段;
|
||
//if (!string.IsNullOrEmpty(pageFilter.Parameter1))
|
||
// filedType = int.Parse(pageFilter.Parameter1);
|
||
if (string.IsNullOrEmpty(pageFilter.Keyword))
|
||
return list;
|
||
//if (filedType == (int)PFFieldTypeEnum.表字段)
|
||
//{
|
||
//导航属性格式：Nav_Appliance.T_BD_APPLIANCE ，字段名称+.+字段累类型
|
||
var parentField = pageFilter.FilterGroup.Rules.FirstOrDefault(x => x.Field == "PARENT_ID");
|
||
var parentName = "";
|
||
if (parentField == null)
|
||
{
|
||
var form = this.GetEntityByRedis<T_PF_FORM>(pageFilter.Keyword, pageFilter.GetOrgId());
|
||
if (form == null)
|
||
this.ThrowError("020015");
|
||
if (string.IsNullOrEmpty(form.TABLE_NAME))
|
||
this.ThrowError("020016");
|
||
pageFilter.Keyword = form.TABLE_NAME;
|
||
}
|
||
else
|
||
{
|
||
var infos = parentField.Value.ToString().Split(new char[] { '.' });
|
||
pageFilter.Keyword = infos[infos.Length - 1];
|
||
parentName = string.Join('.', infos.Take(infos.Length - 1));
|
||
parentName = parentName.Trim('.');
|
||
pageFilter.FilterGroup.Rules.Clear();
|
||
}
|
||
var pagelist = GetTableField(pageFilter, parentName);
|
||
foreach (var d in pagelist)
|
||
{
|
||
d.FIELD_TYPE = (int)PFFieldTypeEnum.表字段;
|
||
var treeNode = new TreeNode<EntityFieldModel>();
|
||
treeNode.Node = d;
|
||
treeNode.IsLeaf = true;
|
||
treeNode.Level = 0;
|
||
if (d.FieldType == (int)EntityFieldTypeEnum.导航字段 || d.FieldType == (int)EntityFieldTypeEnum.虚字段)
|
||
{
|
||
treeNode.IsLeaf = false;
|
||
}
|
||
list.Add(treeNode);
|
||
}
|
||
|
||
//}
|
||
//else
|
||
//{
|
||
// Dictionary<string, string> dicTree = new Dictionary<string, string>();
|
||
// dicTree.Add("层级", "Level");
|
||
// dicTree.Add("是否叶子", "IsLeaf");
|
||
// foreach (var key in dicTree.Keys)
|
||
// {
|
||
// var model = new EntityFieldModel()
|
||
// {
|
||
// NavField = dicTree[key],
|
||
// Label = key,
|
||
// };
|
||
// var treeNode = new TreeNode<EntityFieldModel>();
|
||
// treeNode.Node = model;
|
||
// treeNode.IsLeaf = true;
|
||
// treeNode.Level = 0;
|
||
// list.Add(treeNode);
|
||
// }
|
||
//}
|
||
return list;
|
||
});
|
||
|
||
|
||
}
|
||
/// <summary>
|
||
/// 向web客户端发送消息
|
||
/// </summary>
|
||
/// <param name="model"></param>
|
||
/// <returns></returns>
|
||
[HttpPost, Route("SendInfo")]
|
||
public JsonActionResult<bool> SendInfo([FromBody] SendNotificationModel model)
|
||
{
|
||
return SafeExecute<bool>(() =>
|
||
{
|
||
List<WebSocketClientInfo> clientInfos = null;
|
||
if (model.UserId != null)
|
||
clientInfos = WebSocketServiceHelper.ClintInfos.Where(t => t.UserId == model.UserId).ToList();
|
||
var notificatoinService = APT.Infrastructure.Api.ServiceLocator.Instance.GetService<IFMNotificatoinService>();
|
||
notificatoinService.SendNotification(model, clientInfos);
|
||
return true;
|
||
});
|
||
}
|
||
|
||
/// <summary>
|
||
/// 向web客户端发送报警消息
|
||
/// </summary>
|
||
/// <param name="model"></param>
|
||
/// <returns></returns>
|
||
[HttpPost, Route("SendAlarmInfo")]
|
||
public JsonActionResult<bool> SendAlarmInfo([FromBody] SendNotificationModel model)
|
||
{
|
||
return SafeExecute<bool>(() =>
|
||
{
|
||
List<WebSocketClientInfo> clientInfos = null;
|
||
if (model.UserIds.Count > 0)
|
||
clientInfos = WebSocketServiceHelper.ClintInfos.Where(t => model.UserIds.Contains(t.UserId ?? Guid.Empty)).Distinct(x=>x.UserId).ToList();
|
||
var notificatoinService = ServiceLocator.Instance.GetService<IFMNotificatoinService>();
|
||
notificatoinService.SendAlarmNotification(model, clientInfos);
|
||
return true;
|
||
});
|
||
}
|
||
}
|
||
}
|