namespace APIJSON.NET
{
using APIJSON.NET.Services;
using Microsoft.Extensions.Options;
using Newtonsoft.Json.Linq;
using SqlSugar;
using System;
using System.Collections.Generic;
using System.Dynamic;
using System.Linq;
using AspectCore.Extensions.Reflection;
using System.Text.RegularExpressions;
public class SelectTable
{
private readonly IIdentityService _identitySvc;
private readonly ITableMapper _tableMapper;
private readonly DbContext db;
public SelectTable(IIdentityService identityService, ITableMapper tableMapper, DbContext _db)
{
_identitySvc = identityService;
_tableMapper = tableMapper;
db = _db;
}
///
/// 判断表名是否正确
///
///
///
public bool IsTable(string table)
{
return db.Db.DbMaintenance.GetTableInfoList().Any(it => it.Name.Equals(table, StringComparison.CurrentCultureIgnoreCase));
}
///
/// 判断表的列名是否正确
///
///
///
///
public bool IsCol(string table, string col)
{
return db.Db.DbMaintenance.GetColumnInfosByTableName(table).Any(it => it.DbColumnName.Equals(col, StringComparison.CurrentCultureIgnoreCase));
}
///
/// 动态调用方法
///
///
///
///
///
public object ExecFunc(string funcname,object[] param, Type[] types)
{
var method = typeof(FuncList).GetMethod(funcname);
var reflector = method.GetReflector();
var result = reflector.Invoke(new FuncList(), param);
return result;
}
public (dynamic,int) GetTableData(string subtable, int page, int count, string json, JObject dd)
{
var role = _identitySvc.GetSelectRole(subtable);
if (!role.Item1)//没有权限返回异常
{
throw new Exception(role.Item2);
}
string selectrole = role.Item2;
subtable = _tableMapper.GetTableName(subtable);
JObject values = JObject.Parse(json);
page = values["page"] == null ? page : int.Parse(values["page"].ToString());
count = values["count"] == null ? count : int.Parse(values["count"].ToString());
values.Remove("page");
values.Remove("count");
var tb = sugarQueryable(subtable, selectrole, values, dd);
if (count > 0)
{
int total = 0;
return (tb.ToPageList(page, count,ref total),total);
}
else
{
return (tb.ToList(),tb.Count());
}
}
public dynamic GetFirstData(string subtable, string json, JObject dd)
{
var role = _identitySvc.GetSelectRole(subtable);
if (!role.Item1)//没有权限返回异常
{
throw new Exception(role.Item2);
}
string selectrole = role.Item2;
subtable = _tableMapper.GetTableName(subtable);
JObject values = JObject.Parse(json);
values.Remove("page");
values.Remove("count");
var tb = sugarQueryable(subtable, selectrole, values, dd).First();
var dic = (IDictionary)tb;
foreach (var item in values.Properties().Where(it => it.Name.EndsWith("()")))
{
if (item.Value.IsValue())
{
string func = item.Value.ToString().Substring(0, item.Value.ToString().IndexOf("("));
string param = item.Value.ToString().Substring(item.Value.ToString().IndexOf("(") + 1).TrimEnd(')') ;
var types = new List();
var paramss = new List