You cannot select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.

409 lines
15 KiB
Plaintext

11 months ago
using System;
using System.CodeDom;
using System.CodeDom.Compiler;
using System.Data;
using System.Data.SqlClient;
using System.Collections;
using System.IO;
using System.Net;
using System.Xml;
using BP.DA;
using BP.En;
using Microsoft.CSharp;
using BP.Web;
using BP.Difference;
using Newtonsoft.Json.Linq;
namespace BP.Sys
{
/// <summary>
/// 用户自定义表
/// </summary>
public class SFProcedure : EntityNoName
{
public string FK_SFDBSrc
{
get
{
return this.GetValStringByKey("FK_SFDBSrc");
}
}
public string SelectStatement
{
get
{
return this.GetValStringByKey("SelectStatement");
}
}
#region 数据源属性.
/// <summary>
/// 获得外部数据表
/// </summary>
public DataTable GenerHisDataTable(Hashtable ht = null)
{
//创建数据源.
SFDBSrc src = new SFDBSrc(this.FK_SFDBSrc);
#region WebApi接口
if (src.DBSrcType.Equals("WebApi") == true)
{
//执行POST
string post = this.GetValStringByKey("RequestMethod");
// return BP.Tools.PubGlo.HttpPostConnect_Data(this.FK_SFDBSrc, this.SelectStatement, ht, this.GetValStringByKey("RequestMethod"));
string postData = BP.Tools.PubGlo.HttpPostConnect_Data(this.FK_SFDBSrc, this.SelectStatement, ht, post);
string jsonNode = this.GetValStringByKey("JsonNode"); //json的节点.
JArray jArr = new JArray();
try
{
JObject json = JObject.Parse(postData);
if (!DataType.IsNullOrEmpty(jsonNode))
jArr = (JArray)(json.GetValue(jsonNode));
else
jArr = JArray.Parse(postData);
}
catch (Exception ex)
{
throw new Exception("err@转化JSON出现错误Data=【" + postData + "】" + ex.Message);
}
return BP.Tools.Json.ToDataTable(jArr.ToString());
}
#endregion WebApi接口
#region SQL接口
string runObj = this.SelectStatement;
if (DataType.IsNullOrEmpty(runObj))
throw new Exception("@外键类型SQL配置错误," + this.No + " " + this.Name + " 是一个(SQL)类型(" + this.GetValStrByKey("SrcType") + ")但是没有配置sql.");
if (runObj == null)
runObj = string.Empty;
runObj = runObj.Replace("~", "'");
runObj = runObj.Replace("/#", "+"); //为什么?
runObj = runObj.Replace("/$", "-"); //为什么?
if (runObj.Contains("@WebUser.No"))
runObj = runObj.Replace("@WebUser.No", BP.Web.WebUser.No);
if (runObj.Contains("@WebUser.Name"))
runObj = runObj.Replace("@WebUser.Name", BP.Web.WebUser.Name);
if (runObj.Contains("@WebUser.FK_DeptName"))
runObj = runObj.Replace("@WebUser.FK_DeptName", BP.Web.WebUser.FK_DeptName);
if (runObj.Contains("@WebUser.FK_Dept"))
runObj = runObj.Replace("@WebUser.FK_Dept", BP.Web.WebUser.FK_Dept);
if (runObj.Contains("@") == true && ht != null)
{
foreach (string key in ht.Keys)
{
//值为空或者null不替换
if (ht[key] == null || ht[key].Equals("") == true)
continue;
if (runObj.Contains("@" + key))
runObj = runObj.Replace("@" + key, ht[key].ToString());
//不包含@则返回SQL语句
if (runObj.Contains("@") == false)
break;
}
}
if (runObj.Contains("@") && BP.Difference.SystemConfig.IsBSsystem == true)
{
/*如果是bs*/
foreach (string key in HttpContextHelper.RequestParamKeys)
{
if (string.IsNullOrEmpty(key))
continue;
runObj = runObj.Replace("@" + key, HttpContextHelper.RequestParams(key));
}
}
if (runObj.Contains("@") == true)
throw new Exception("@外键类型SQL错误," + runObj + "部分过程条件没有被替换.");
DataTable dt = null;
try
{
dt = src.RunSQLReturnTable(runObj);
}
catch (Exception ex)
{
throw new Exception("err@获得SFProcedure(" + this.No + "," + this.Name + ")出现错误:SQL[" + runObj + "],数据库异常信息:" + ex.Message);
}
if (SystemConfig.AppCenterDBFieldCaseModel != FieldCaseModel.None)
{
dt.Columns[0].ColumnName = "No";
dt.Columns[1].ColumnName = "Name";
if (dt.Columns.Count == 3)
dt.Columns[2].ColumnName = "ParentNo";
}
return dt;
#endregion SQL接口
}
#endregion
#region 构造方法
public override UAC HisUAC
{
get
{
UAC uac = new UAC();
uac.Readonly();
return uac;
}
}
/// <summary>
/// 用户自定义表
/// </summary>
public SFProcedure()
{
}
public SFProcedure(string no)
{
this.No = no;
this.Retrieve();
}
/// <summary>
/// EnMap
/// </summary>
public override Map EnMap
{
get
{
if (this._enMap != null)
return this._enMap;
Map map = new Map("Sys_SFProcedure", "过程");
map.AddTBStringPK(SFTableAttr.No, null, "表英文名称", true, false, 1, 200, 20);
map.AddTBString(SFTableAttr.Name, null, "表中文名称", true, false, 0, 200, 20);
map.AddDDLEntities(SFTableAttr.FK_SFDBSrc, "local", "数据源", new BP.Sys.SFDBSrcs(), true);
map.AddTBString("ConnString", null, "ConnString", true, false, 0, 200, 150, true);
map.AddDDLSysEnum("IsPara", 0, "参数个数", true, true, "IsPara", "@0=无参数@1=有参数");
map.AddTBString("ExpDoc", null, "表达式内容", true, false, 0, 1000, 600, true);
map.AddTBString("ExpNote", null, "表达式说明", true, false, 0, 1000, 600, true);
map.AddDDLStringEnum("RequestMethod", "Get", "请求模式", "@Get=Get@POST=POST", true);
map.AddTBStringDoc("ColumnsRemark", "", "格式备注", true, false, true);
// 创建信息
map.AddGroupAttr("创建信息");
map.AddTBString("Remark", null, "备注", true, false, 0, 100, 20, true);
map.AddTBDateTime("RDT", null, "创建日期", true, true);
map.AddTBString("OrgNo", null, "组织编号", true, true, 0, 100, 20);
map.AddTBAtParas();
//查找.
map.AddSearchAttr(SFTableAttr.FK_SFDBSrc);
this._enMap = map;
return this._enMap;
}
}
#endregion
/// <summary>
/// 执行SQL
/// </summary>
/// <param name="paras">参数</param>
/// <returns>返回执行结果</returns>
public string ExecSQL(Hashtable ht, SFDBSrc src)
{
string sql = this.SelectStatement;
try
{
sql = Glo.DealExp(sql, ht); //处理sql.
var num = src.RunSQL(sql);
if (num == 0)
return "执行失败:" + this.GetValStrByKey("MsgOfErr") + "返回结果为0";
return "执行成功:" + this.GetValStrByKey("MsgOfOK") + ",返回结果为" + num;
}
catch (Exception ex)
{
return "执行错误:" + this.GetValStrByKey("MsgOfErr") + "请检查配置的SQL是否正确:[" + sql + "]";
}
}
public string Exec(string paras)
{
SFDBSrc src = new SFDBSrc();
src.No = this.FK_SFDBSrc;
src.RetrieveFromDBSources();
Hashtable ht = DataType.ParseParasToHT(paras);
if (src.DBSrcType.Equals("WebApi") == true)
return ExecWebApi(ht, src);
return ExecSQL(ht, src);
}
public string ExecWebApi(Hashtable ht, SFDBSrc src)
{
try
{
string postData = SFTable.Data_WebApi(ht, this.GetValStringByKey("RequestMethod"), this.FK_SFDBSrc, this.SelectStatement);
return "" + this.GetValByKey("MsgOfOK") + " -:" + postData;
}
catch (Exception ex)
{
return "err@[" + this.GetValByKey("MsgOfErr") + "]:失败信息" + ex.Message;
}
//// 需要替换的参数
//string fieldNo = this.GetValStringByKey("FieldNo");
//if (DataType.IsNullOrEmpty(fieldNo))
// fieldNo = "No";
//string fieldName = this.GetValStringByKey("FieldName");
//if (DataType.IsNullOrEmpty(fieldName))
// fieldName = "Name";
//string fieldParentNo = this.GetValStringByKey("FieldParentNo");
//if (DataType.IsNullOrEmpty(fieldParentNo))
// fieldParentNo = "ParentNo";
//// 根节点
//string jsonNode = this.GetValStringByKey("JsonNode");
//JToken jToken = JToken.Parse(postData);
//// 如果是JSON数组
//if (jToken.Type == JTokenType.Array)
//{
// // 新的对象,用来删除原对象无用字段
// JArray newJsonArr = new JArray();
// JArray arr = (JArray)jToken;
// JObject firstItem = (JObject)arr[0];
// checkJsonField(firstItem, fieldNo, fieldName, fieldParentNo);
// foreach (JObject obj in arr)
// {
// newJsonArr.Add(getJSONByTargetName(obj, fieldNo, fieldName, fieldParentNo));
// }
// return BP.Tools.Json.ConvertToDataTable(newJsonArr);
//}
//// 如果是JSON对象
//if (jToken.Type == JTokenType.Object)
//{
// JObject jsonItem = (JObject)jToken;
// // 判断是不是有根节点
// // 如果有
// if (!DataType.IsNullOrEmpty(jsonNode) && jsonItem.ContainsKey(jsonNode))
// {
// // 新的对象,用来删除原对象无用字段
// JArray newJsonArr = new JArray();
// JToken jToken1 = jsonItem[jsonNode];
// // 判断当前是不是数组或者
// if (jToken1.Type == JTokenType.Array)
// {
// JObject firstItem = (JObject)jToken1[0];
// checkJsonField(firstItem, fieldNo, fieldName, fieldParentNo);
// foreach (JObject obj in jToken1)
// {
// newJsonArr.Add(getJSONByTargetName(obj, fieldNo, fieldName, fieldParentNo));
// }
// return BP.Tools.Json.ToDataTable(newJsonArr.ToString());
// }
// if (jToken1.Type == JTokenType.Object)
// {
// JObject targetObj = (JObject)jToken;
// checkJsonField(targetObj, fieldNo, fieldName, fieldParentNo);
// JObject itemOfRootNode = getJSONByTargetName(targetObj, fieldNo, fieldName, fieldParentNo);
// return BP.Tools.Json.ToDataTable(itemOfRootNode.ToString());
// }
// throw new Exception("指定的RootNode下不是JSON数组 或 JSON对象");
// }
// // 如果没有配置rootNode检查他本身有没有所需属性
// JObject currObj = (JObject)jToken;
// checkJsonField(currObj, fieldNo, fieldName, fieldParentNo);
// JObject itemOfResponse = getJSONByTargetName(currObj, fieldNo, fieldName, fieldParentNo);
// return BP.Tools.Json.ToDataTable(itemOfResponse.ToString());
//}
//throw new Exception("Web_API 没有正确返回JSON字符串");
}
/// <summary>
/// 检查是否有依赖的引用?
/// </summary>
/// <returns></returns>
public string IsCanDelete()
{
MapAttrs mattrs = new MapAttrs();
mattrs.Retrieve(MapAttrAttr.UIBindKey, this.No);
if (mattrs.Count != 0)
{
string err = "";
foreach (MapAttr item in mattrs)
err += " @ " + item.MyPK + " " + item.Name;
return "err@如下实体字段在引用:" + err + "。您不能删除该表。";
}
return null;
}
protected override bool beforeDelete()
{
string delMsg = this.IsCanDelete();
if (delMsg != null)
throw new Exception(delMsg);
return base.beforeDelete();
}
}
/// <summary>
/// 用户自定义表s
/// </summary>
public class SFProcedures : EntitiesNoName
{
#region 构造
/// <summary>
/// 用户自定义表s
/// </summary>
public SFProcedures()
{
}
/// <summary>
/// 得到它的 Entity
/// </summary>
public override Entity GetNewEntity
{
get
{
return new SFProcedure();
}
}
/// <summary>
/// 重写过程全部的方法
/// </summary>
/// <returns></returns>
public override int RetrieveAll()
{
if (SystemConfig.CCBPMRunModel == CCBPMRunModel.Single)
return base.RetrieveAll("RDT");
return this.Retrieve("OrgNo", WebUser.OrgNo, "RDT");
}
#endregion
#region 为了适应自动翻译成java的需要,把实体转换成List.
/// <summary>
/// 转化成 java list,C#不能调用.
/// </summary>
/// <returns>List</returns>
public System.Collections.Generic.IList<SFProcedure> ToJavaList()
{
return (System.Collections.Generic.IList<SFProcedure>)this;
}
/// <summary>
/// 转化成list
/// </summary>
/// <returns>List</returns>
public System.Collections.Generic.List<SFProcedure> Tolist()
{
System.Collections.Generic.List<SFProcedure> list = new System.Collections.Generic.List<SFProcedure>();
for (int i = 0; i < this.Count; i++)
{
list.Add((SFProcedure)this[i]);
}
return list;
}
#endregion 为了适应自动翻译成java的需要,把实体转换成List.
}
}