|
|
using System;
|
|
|
using System.Collections.Generic;
|
|
|
using System.IO;
|
|
|
using BP.DA;
|
|
|
using BP.Sys;
|
|
|
using BP.Web;
|
|
|
using BP.Port;
|
|
|
using System.Data;
|
|
|
using BP.WF;
|
|
|
using BP.En;
|
|
|
using BP.WF.Template;
|
|
|
using BP.Difference;
|
|
|
using BP.WF.Template.SFlow;
|
|
|
using BP.WF.Template.CCEn;
|
|
|
using BP.WF.Template.Frm;
|
|
|
using System.Collections.Concurrent;
|
|
|
using System.Threading;
|
|
|
using System.Web;
|
|
|
|
|
|
namespace BP.WF.Template
|
|
|
{
|
|
|
/// <summary>
|
|
|
/// 流程模版的操作
|
|
|
/// </summary>
|
|
|
public class TemplateGlo
|
|
|
{
|
|
|
/// <summary>
|
|
|
/// 装载流程模板
|
|
|
/// </summary>
|
|
|
/// <param name="fk_flowSort">流程类别</param>
|
|
|
/// <param name="path">流程名称</param>
|
|
|
/// <returns></returns>
|
|
|
public static Flow LoadFlowTemplate(string fk_flowSort, string path, ImpFlowTempleteModel model, string SpecialFlowNo = "", string flowName = null)
|
|
|
{
|
|
|
FileInfo info = new FileInfo(path);
|
|
|
DataSet ds = new DataSet();
|
|
|
try
|
|
|
{
|
|
|
ds.ReadXml(path);
|
|
|
}
|
|
|
catch (Exception ex)
|
|
|
{
|
|
|
throw new Exception("@导入流程路径:" + path + "出错：" + ex.Message);
|
|
|
}
|
|
|
|
|
|
|
|
|
if (ds.Tables.Contains("WF_Flow") == false)
|
|
|
throw new Exception("err@导入错误，非流程模版文件" + path + "。");
|
|
|
|
|
|
DataTable dtFlow = ds.Tables["WF_Flow"];
|
|
|
Flow fl = new Flow();
|
|
|
string oldFlowNo = dtFlow.Rows[0]["No"].ToString();
|
|
|
string oldFlowName = dtFlow.Rows[0]["Name"].ToString();
|
|
|
|
|
|
int oldFlowID = int.Parse(oldFlowNo);
|
|
|
int iOldFlowLength = oldFlowID.ToString().Length;
|
|
|
string timeKey = DateTime.Now.ToString("yyMMddhhmmss");
|
|
|
|
|
|
#region 根据不同的流程模式，设置生成不同的流程编号.
|
|
|
switch (model)
|
|
|
{
|
|
|
case ImpFlowTempleteModel.AsNewFlow: /*做为一个新流程. */
|
|
|
fl.No = fl.GenerNewNo;
|
|
|
fl.DoDelData();
|
|
|
fl.DoDelete(); /*删除可能存在的垃圾.*/
|
|
|
fl.Insert();
|
|
|
break;
|
|
|
case ImpFlowTempleteModel.AsTempleteFlowNo: /*用流程模版中的编号*/
|
|
|
fl.No = oldFlowNo;
|
|
|
if (fl.IsExits)
|
|
|
throw new Exception("导入错误:流程模版(" + oldFlowName + ")中的编号(" + oldFlowNo + ")在系统中已经存在,流程名称为:" + dtFlow.Rows[0]["name"].ToString());
|
|
|
else
|
|
|
{
|
|
|
fl.No = oldFlowNo;
|
|
|
fl.DoDelData();
|
|
|
fl.DoDelete(); /*删除可能存在的垃圾.*/
|
|
|
fl.Insert();
|
|
|
|
|
|
}
|
|
|
break;
|
|
|
case ImpFlowTempleteModel.OvrewaiteCurrFlowNo: /*覆盖当前的流程.*/
|
|
|
fl.No = oldFlowNo;
|
|
|
fl.DoDelData();
|
|
|
fl.DoDelete(); /*删除可能存在的垃圾.*/
|
|
|
fl.Insert();
|
|
|
break;
|
|
|
case ImpFlowTempleteModel.AsSpecFlowNo:
|
|
|
if (SpecialFlowNo.Length <= 0)
|
|
|
throw new Exception("@您是按照指定的流程编号导入的，但是您没有传入正确的流程编号。");
|
|
|
|
|
|
fl.No = SpecialFlowNo.ToString();
|
|
|
fl.DoDelData();
|
|
|
fl.DoDelete(); /*删除可能存在的垃圾.*/
|
|
|
fl.Insert();
|
|
|
break;
|
|
|
default:
|
|
|
throw new Exception("@没有判断");
|
|
|
}
|
|
|
#endregion 根据不同的流程模式，设置生成不同的流程编号.
|
|
|
|
|
|
// string timeKey = fl.No;
|
|
|
int idx = 0;
|
|
|
string infoErr = "";
|
|
|
string infoTable = "";
|
|
|
int flowID = int.Parse(fl.No);
|
|
|
|
|
|
#region 处理流程表数据
|
|
|
foreach (DataColumn dc in dtFlow.Columns)
|
|
|
{
|
|
|
string val = dtFlow.Rows[0][dc.ColumnName] as string;
|
|
|
switch (dc.ColumnName.ToLower())
|
|
|
{
|
|
|
case "no":
|
|
|
case "fk_flowsort":
|
|
|
continue;
|
|
|
case "name":
|
|
|
// val = "复制:" + val + "_" + DateTime.Now.ToString("MM月dd日HH时mm分");
|
|
|
break;
|
|
|
default:
|
|
|
break;
|
|
|
}
|
|
|
fl.SetValByKey(dc.ColumnName, val);
|
|
|
}
|
|
|
fl.FK_FlowSort = fk_flowSort;
|
|
|
if (DBAccess.IsExitsObject(fl.PTable) == true)
|
|
|
{
|
|
|
fl.PTable = null;
|
|
|
}
|
|
|
//修改成当前登陆人所在的组织
|
|
|
fl.OrgNo = WebUser.OrgNo;
|
|
|
if (DataType.IsNullOrEmpty(flowName) == false)
|
|
|
fl.Name = flowName;
|
|
|
fl.Update();
|
|
|
//判断该流程是否是公文流程，存在BuessFields、FlowBuessType、FK_DocType=01
|
|
|
Attrs attrs = fl.EnMap.Attrs;
|
|
|
if (attrs.Contains("FlowBuessType") == true)
|
|
|
{
|
|
|
DBAccess.RunSQL("UPDATE WF_Flow Set BuessFields='" + fl.GetParaString("BuessFields") + "', FlowBuessType=" + fl.GetParaInt("FlowBuessType") + " ,FK_DocType='" + fl.GetParaString("FK_DocType") + "'");
|
|
|
}
|
|
|
|
|
|
#endregion 处理流程表数据
|
|
|
|
|
|
#region 处理OID 插入重复的问题 Sys_GroupField, Sys_MapAttr.
|
|
|
DataTable mydtGF = ds.Tables["Sys_GroupField"];
|
|
|
DataTable myDTAttr = ds.Tables["Sys_MapAttr"];
|
|
|
DataTable myDTAth = ds.Tables["Sys_FrmAttachment"];
|
|
|
DataTable myDTDtl = ds.Tables["Sys_MapDtl"];
|
|
|
DataTable myDFrm = ds.Tables["Sys_MapFrame"];
|
|
|
|
|
|
foreach (DataRow dr in mydtGF.Rows)
|
|
|
{
|
|
|
Sys.GroupField gf = new Sys.GroupField();
|
|
|
foreach (DataColumn dc in mydtGF.Columns)
|
|
|
{
|
|
|
string val = dr[dc.ColumnName] as string;
|
|
|
if (val == null)
|
|
|
continue;
|
|
|
switch (dc.ColumnName.ToLower())
|
|
|
{
|
|
|
case "enname":
|
|
|
case "keyofen":
|
|
|
case "ctrlid": //升级傻瓜表单的时候,新增加的字段 add by zhoupeng 2016.11.21
|
|
|
case "frmid": //升级傻瓜表单的时候,新增加的字段 add by zhoupeng 2016.11.21
|
|
|
val = val.Replace("ND" + oldFlowID, "ND" + flowID);
|
|
|
break;
|
|
|
default:
|
|
|
break;
|
|
|
}
|
|
|
gf.SetValByKey(dc.ColumnName, val);
|
|
|
}
|
|
|
int oldID = gf.OID;
|
|
|
gf.OID = DBAccess.GenerOID();
|
|
|
gf.DirectInsert();
|
|
|
dr["OID"] = gf.OID; //给他一个新的OID.
|
|
|
|
|
|
// 属性。
|
|
|
if (myDTAttr != null && myDTAttr.Columns.Contains("GroupID"))
|
|
|
{
|
|
|
foreach (DataRow dr1 in myDTAttr.Rows)
|
|
|
{
|
|
|
if (dr1["GroupID"] == null)
|
|
|
dr1["GroupID"] = 0;
|
|
|
|
|
|
if (dr1["GroupID"].ToString().Equals(oldID.ToString()))
|
|
|
dr1["GroupID"] = gf.OID;
|
|
|
}
|
|
|
}
|
|
|
|
|
|
// 附件。
|
|
|
if (myDTAth != null && myDTAth.Columns.Contains("GroupID"))
|
|
|
{
|
|
|
foreach (DataRow dr1 in myDTAth.Rows)
|
|
|
{
|
|
|
if (dr1["GroupID"] == null)
|
|
|
dr1["GroupID"] = 0;
|
|
|
|
|
|
if (dr1["GroupID"].ToString().Equals(oldID.ToString()))
|
|
|
dr1["GroupID"] = gf.OID;
|
|
|
}
|
|
|
}
|
|
|
|
|
|
if (myDTDtl != null && myDTDtl.Columns.Contains("GroupID"))
|
|
|
{
|
|
|
// 从表。
|
|
|
foreach (DataRow dr1 in myDTDtl.Rows)
|
|
|
{
|
|
|
if (dr1["GroupID"] == null)
|
|
|
dr1["GroupID"] = 0;
|
|
|
|
|
|
if (dr1["GroupID"].ToString().Equals(oldID.ToString()))
|
|
|
dr1["GroupID"] = gf.OID;
|
|
|
}
|
|
|
}
|
|
|
|
|
|
// frm.
|
|
|
if (myDFrm != null && myDFrm.Columns.Contains("GroupID"))
|
|
|
{
|
|
|
foreach (DataRow dr1 in myDFrm.Rows)
|
|
|
{
|
|
|
if (dr1["GroupID"] == null)
|
|
|
dr1["GroupID"] = 0;
|
|
|
|
|
|
if (dr1["GroupID"].ToString().Equals(oldID.ToString()))
|
|
|
dr1["GroupID"] = gf.OID;
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
#endregion 处理OID 插入重复的问题。 Sys_GroupField ， Sys_MapAttr.
|
|
|
|
|
|
int timeKeyIdx = 0;
|
|
|
foreach (DataTable dt in ds.Tables)
|
|
|
{
|
|
|
timeKeyIdx++;
|
|
|
timeKey = timeKey + timeKeyIdx.ToString();
|
|
|
|
|
|
infoTable = "@导入:" + dt.TableName + " 出现异常。";
|
|
|
switch (dt.TableName)
|
|
|
{
|
|
|
case "WF_Flow": //模版文件。
|
|
|
continue;
|
|
|
case "WF_NodeSubFlow": //延续子流程.
|
|
|
foreach (DataRow dr in dt.Rows)
|
|
|
{
|
|
|
SubFlow yg = new SubFlow();
|
|
|
foreach (DataColumn dc in dt.Columns)
|
|
|
{
|
|
|
string val = dr[dc.ColumnName] as string;
|
|
|
if (val == null)
|
|
|
continue;
|
|
|
switch (dc.ColumnName.ToLower())
|
|
|
{
|
|
|
case "tonodeid":
|
|
|
case "fk_node":
|
|
|
case "nodeid":
|
|
|
if (val.Length < iOldFlowLength)
|
|
|
{
|
|
|
//节点编号长度小于流程编号长度则为异常数据，异常数据不进行处理
|
|
|
throw new Exception("@导入模板名称：" + oldFlowName + "；节点WF_NodeSubFlow下FK_Node值错误:" + val);
|
|
|
}
|
|
|
val = flowID + val.Substring(iOldFlowLength);
|
|
|
break;
|
|
|
case "fk_flow":
|
|
|
val = fl.No;
|
|
|
break;
|
|
|
default:
|
|
|
val = val.Replace("ND" + oldFlowID, "ND" + flowID);
|
|
|
break;
|
|
|
}
|
|
|
yg.SetValByKey(dc.ColumnName, val);
|
|
|
}
|
|
|
yg.Insert();
|
|
|
}
|
|
|
continue;
|
|
|
case "WF_FlowForm": //独立表单。 add 2013-12-03
|
|
|
//foreach (DataRow dr in dt.Rows)
|
|
|
//{
|
|
|
// FlowForm cd = new FlowForm();
|
|
|
// foreach (DataColumn dc in dt.Columns)
|
|
|
// {
|
|
|
// string val = dr[dc.ColumnName] as string;
|
|
|
// if (val == null)
|
|
|
// continue;
|
|
|
// switch (dc.ColumnName.ToLower())
|
|
|
// {
|
|
|
// case "fk_flow":
|
|
|
// val = fl.No;
|
|
|
// break;
|
|
|
// default:
|
|
|
// val = val.Replace("ND" + oldFlowID, "ND" + flowID);
|
|
|
// break;
|
|
|
// }
|
|
|
// cd.SetValByKey(dc.ColumnName, val);
|
|
|
// }
|
|
|
// cd.Insert();
|
|
|
//}
|
|
|
break;
|
|
|
case "WF_NodeForm": //节点表单权限。 2013-12-03
|
|
|
foreach (DataRow dr in dt.Rows)
|
|
|
{
|
|
|
NodeToolbar cd = new NodeToolbar();
|
|
|
foreach (DataColumn dc in dt.Columns)
|
|
|
{
|
|
|
string val = dr[dc.ColumnName] as string;
|
|
|
if (val == null)
|
|
|
continue;
|
|
|
switch (dc.ColumnName.ToLower())
|
|
|
{
|
|
|
case "tonodeid":
|
|
|
case "fk_node":
|
|
|
case "nodeid":
|
|
|
if (val.Length < iOldFlowLength)
|
|
|
{
|
|
|
//节点编号长度小于流程编号长度则为异常数据，异常数据不进行处理
|
|
|
throw new Exception("@导入模板名称：" + oldFlowName + "；节点WF_NodeForm下FK_Node值错误:" + val);
|
|
|
}
|
|
|
val = flowID + val.Substring(iOldFlowLength);
|
|
|
break;
|
|
|
case "fk_flow":
|
|
|
val = fl.No;
|
|
|
break;
|
|
|
default:
|
|
|
val = val.Replace("ND" + oldFlowID, "ND" + flowID);
|
|
|
break;
|
|
|
}
|
|
|
cd.SetValByKey(dc.ColumnName, val);
|
|
|
}
|
|
|
cd.Insert();
|
|
|
}
|
|
|
break;
|
|
|
case "Sys_FrmSln": //表单字段权限。 2013-12-03
|
|
|
foreach (DataRow dr in dt.Rows)
|
|
|
{
|
|
|
FrmField cd = new FrmField();
|
|
|
foreach (DataColumn dc in dt.Columns)
|
|
|
{
|
|
|
string val = dr[dc.ColumnName] as string;
|
|
|
if (val == null)
|
|
|
continue;
|
|
|
switch (dc.ColumnName.ToLower())
|
|
|
{
|
|
|
case "tonodeid":
|
|
|
case "fk_node":
|
|
|
case "nodeid":
|
|
|
if (val.Length < iOldFlowLength)
|
|
|
{
|
|
|
//节点编号长度小于流程编号长度则为异常数据，异常数据不进行处理
|
|
|
throw new Exception("@导入模板名称：" + oldFlowName + "；节点Sys_FrmSln下FK_Node值错误:" + val);
|
|
|
}
|
|
|
val = flowID + val.Substring(iOldFlowLength);
|
|
|
break;
|
|
|
case "fk_flow":
|
|
|
val = fl.No;
|
|
|
break;
|
|
|
default:
|
|
|
val = val.Replace("ND" + oldFlowID, "ND" + flowID);
|
|
|
break;
|
|
|
}
|
|
|
cd.SetValByKey(dc.ColumnName, val);
|
|
|
}
|
|
|
cd.Insert();
|
|
|
}
|
|
|
break;
|
|
|
case "WF_NodeToolbar": //工具栏。
|
|
|
foreach (DataRow dr in dt.Rows)
|
|
|
{
|
|
|
NodeToolbar cd = new NodeToolbar();
|
|
|
foreach (DataColumn dc in dt.Columns)
|
|
|
{
|
|
|
string val = dr[dc.ColumnName] as string;
|
|
|
if (val == null)
|
|
|
continue;
|
|
|
switch (dc.ColumnName.ToLower())
|
|
|
{
|
|
|
case "tonodeid":
|
|
|
case "fk_node":
|
|
|
case "nodeid":
|
|
|
if (val.Length < iOldFlowLength)
|
|
|
{
|
|
|
//节点编号长度小于流程编号长度则为异常数据，异常数据不进行处理
|
|
|
throw new Exception("@导入模板名称：" + oldFlowName + "；节点WF_NodeToolbar下FK_Node值错误:" + val);
|
|
|
}
|
|
|
val = flowID + val.Substring(iOldFlowLength);
|
|
|
break;
|
|
|
case "fk_flow":
|
|
|
val = fl.No;
|
|
|
break;
|
|
|
default:
|
|
|
val = val.Replace("ND" + oldFlowID, "ND" + flowID);
|
|
|
break;
|
|
|
}
|
|
|
cd.SetValByKey(dc.ColumnName, val);
|
|
|
}
|
|
|
cd.OID = DBAccess.GenerOID();
|
|
|
cd.DirectInsert();
|
|
|
}
|
|
|
break;
|
|
|
case "Sys_FrmPrintTemplate":
|
|
|
foreach (DataRow dr in dt.Rows)
|
|
|
{
|
|
|
FrmPrintTemplate bt = new FrmPrintTemplate();
|
|
|
foreach (DataColumn dc in dt.Columns)
|
|
|
{
|
|
|
string val = dr[dc.ColumnName] as string;
|
|
|
if (val == null)
|
|
|
continue;
|
|
|
switch (dc.ColumnName.ToLower())
|
|
|
{
|
|
|
case "fk_flow":
|
|
|
val = flowID.ToString();
|
|
|
break;
|
|
|
case "nodeid":
|
|
|
case "fk_node":
|
|
|
if (val.Length < iOldFlowLength)
|
|
|
{
|
|
|
//节点编号长度小于流程编号长度则为异常数据，异常数据不进行处理
|
|
|
throw new Exception("@导入模板名称：" + oldFlowName + "；节点Sys_FrmPrintTemplate下FK_Node值错误:" + val);
|
|
|
}
|
|
|
val = flowID + val.Substring(iOldFlowLength);
|
|
|
break;
|
|
|
default:
|
|
|
break;
|
|
|
}
|
|
|
bt.SetValByKey(dc.ColumnName, val);
|
|
|
}
|
|
|
|
|
|
bt.MyPK = DBAccess.GenerGUID();
|
|
|
|
|
|
try
|
|
|
{
|
|
|
File.Copy(info.DirectoryName + "/" + bt.MyPK + ".rtf", BP.Difference.SystemConfig.PathOfWebApp + @"/DataUser/CyclostyleFile/" + bt.MyPK + ".rtf", true);
|
|
|
}
|
|
|
catch (Exception ex)
|
|
|
{
|
|
|
// infoErr += "@恢复单据模板时出现错误：" + ex.Message + ",有可能是您在复制流程模板时没有复制同目录下的单据模板文件。";
|
|
|
}
|
|
|
bt.Insert();
|
|
|
}
|
|
|
break;
|
|
|
case "WF_FrmNode": //Conds.xml。
|
|
|
DBAccess.RunSQL("DELETE FROM WF_FrmNode WHERE FK_Flow='" + fl.No + "'");
|
|
|
foreach (DataRow dr in dt.Rows)
|
|
|
{
|
|
|
FrmNode fn = new FrmNode();
|
|
|
fn.FK_Flow = fl.No;
|
|
|
foreach (DataColumn dc in dt.Columns)
|
|
|
{
|
|
|
string val = dr[dc.ColumnName] as string;
|
|
|
if (val == null)
|
|
|
continue;
|
|
|
switch (dc.ColumnName.ToLower())
|
|
|
{
|
|
|
case "fk_node":
|
|
|
if (val.Length < iOldFlowLength)
|
|
|
{
|
|
|
//节点编号长度小于流程编号长度则为异常数据，异常数据不进行处理
|
|
|
throw new Exception("@导入模板名称：" + oldFlowName + "；节点WF_FrmNode下FK_Node值错误:" + val);
|
|
|
}
|
|
|
val = flowID + val.Substring(iOldFlowLength);
|
|
|
break;
|
|
|
case "fk_flow":
|
|
|
val = fl.No;
|
|
|
break;
|
|
|
default:
|
|
|
break;
|
|
|
}
|
|
|
fn.SetValByKey(dc.ColumnName, val);
|
|
|
}
|
|
|
// 开始插入。
|
|
|
fn.setMyPK(fn.FK_Frm + "_" + fn.FK_Node);
|
|
|
fn.Insert();
|
|
|
}
|
|
|
break;
|
|
|
case "WF_Cond": //Conds.xml。
|
|
|
foreach (DataRow dr in dt.Rows)
|
|
|
{
|
|
|
Cond cd = new Cond();
|
|
|
cd.FK_Flow = fl.No;
|
|
|
foreach (DataColumn dc in dt.Columns)
|
|
|
{
|
|
|
string val = dr[dc.ColumnName] as string;
|
|
|
if (val == null)
|
|
|
continue;
|
|
|
|
|
|
switch (dc.ColumnName.ToLower())
|
|
|
{
|
|
|
case "tonodeid":
|
|
|
case "fk_node":
|
|
|
case "nodeid":
|
|
|
if (val.Length < iOldFlowLength)
|
|
|
{
|
|
|
//节点编号长度小于流程编号长度则为异常数据，异常数据不进行处理
|
|
|
throw new Exception("@导入模板名称：" + oldFlowName + "；节点WF_Cond下FK_Node值错误:" + val);
|
|
|
}
|
|
|
val = flowID + val.Substring(iOldFlowLength);
|
|
|
break;
|
|
|
case "fk_flow":
|
|
|
val = fl.No;
|
|
|
break;
|
|
|
default:
|
|
|
val = val.Replace("ND" + oldFlowID, "ND" + flowID);
|
|
|
break;
|
|
|
}
|
|
|
cd.SetValByKey(dc.ColumnName, val);
|
|
|
}
|
|
|
|
|
|
cd.FK_Flow = fl.No;
|
|
|
cd.setMyPK(BP.DA.DBAccess.GenerGUID());
|
|
|
cd.DirectInsert();
|
|
|
}
|
|
|
break;
|
|
|
case "WF_CCDept"://抄送到部门。
|
|
|
foreach (DataRow dr in dt.Rows)
|
|
|
{
|
|
|
CCDept cd = new CCDept();
|
|
|
foreach (DataColumn dc in dt.Columns)
|
|
|
{
|
|
|
string val = dr[dc.ColumnName] as string;
|
|
|
if (val == null)
|
|
|
continue;
|
|
|
switch (dc.ColumnName.ToLower())
|
|
|
{
|
|
|
case "fk_node":
|
|
|
if (val.Length < iOldFlowLength)
|
|
|
{
|
|
|
//节点编号长度小于流程编号长度则为异常数据，异常数据不进行处理
|
|
|
throw new Exception("@导入模板名称：" + oldFlowName + "；节点WF_CCDept下FK_Node值错误:" + val);
|
|
|
}
|
|
|
val = flowID + val.Substring(iOldFlowLength);
|
|
|
break;
|
|
|
default:
|
|
|
break;
|
|
|
}
|
|
|
cd.SetValByKey(dc.ColumnName, val);
|
|
|
}
|
|
|
|
|
|
//开始插入。
|
|
|
try
|
|
|
{
|
|
|
cd.Insert();
|
|
|
}
|
|
|
catch
|
|
|
{
|
|
|
cd.Update();
|
|
|
}
|
|
|
}
|
|
|
break;
|
|
|
|
|
|
case "WF_NodeReturn"://可退回的节点。
|
|
|
foreach (DataRow dr in dt.Rows)
|
|
|
{
|
|
|
NodeReturn cd = new NodeReturn();
|
|
|
foreach (DataColumn dc in dt.Columns)
|
|
|
{
|
|
|
string val = dr[dc.ColumnName] as string;
|
|
|
if (val == null)
|
|
|
continue;
|
|
|
switch (dc.ColumnName.ToLower())
|
|
|
{
|
|
|
case "fk_node":
|
|
|
case "returnto":
|
|
|
if (val.Length < iOldFlowLength)
|
|
|
{
|
|
|
//节点编号长度小于流程编号长度则为异常数据，异常数据不进行处理
|
|
|
throw new Exception("@导入模板名称：" + oldFlowName + "；节点WF_NodeReturn下FK_Node值错误:" + val);
|
|
|
}
|
|
|
val = flowID + val.Substring(iOldFlowLength);
|
|
|
break;
|
|
|
default:
|
|
|
break;
|
|
|
}
|
|
|
cd.SetValByKey(dc.ColumnName, val);
|
|
|
}
|
|
|
|
|
|
//开始插入。
|
|
|
try
|
|
|
{
|
|
|
cd.Insert();
|
|
|
}
|
|
|
catch
|
|
|
{
|
|
|
cd.Update();
|
|
|
}
|
|
|
}
|
|
|
break;
|
|
|
case "WF_Direction": //方向。
|
|
|
foreach (DataRow dr in dt.Rows)
|
|
|
{
|
|
|
Direction dir = new Direction();
|
|
|
foreach (DataColumn dc in dt.Columns)
|
|
|
{
|
|
|
string val = dr[dc.ColumnName] as string;
|
|
|
if (val == null)
|
|
|
continue;
|
|
|
switch (dc.ColumnName.ToLower())
|
|
|
{
|
|
|
case "node":
|
|
|
case "tonode":
|
|
|
if (val.Length < iOldFlowLength)
|
|
|
{
|
|
|
//节点编号长度小于流程编号长度则为异常数据，异常数据不进行处理
|
|
|
throw new Exception("@导入模板名称：" + oldFlowName + "；节点WF_Direction下FK_Node值错误:" + val);
|
|
|
}
|
|
|
val = flowID + val.Substring(iOldFlowLength);
|
|
|
break;
|
|
|
default:
|
|
|
break;
|
|
|
}
|
|
|
dir.SetValByKey(dc.ColumnName, val);
|
|
|
}
|
|
|
dir.FK_Flow = fl.No;
|
|
|
dir.Insert();
|
|
|
}
|
|
|
break;
|
|
|
case "WF_LabNote": //LabNotes.xml。
|
|
|
idx = 0;
|
|
|
foreach (DataRow dr in dt.Rows)
|
|
|
{
|
|
|
LabNote ln = new LabNote();
|
|
|
foreach (DataColumn dc in dt.Columns)
|
|
|
{
|
|
|
string val = dr[dc.ColumnName] as string;
|
|
|
if (val == null)
|
|
|
continue;
|
|
|
ln.SetValByKey(dc.ColumnName, val);
|
|
|
}
|
|
|
idx++;
|
|
|
ln.FK_Flow = fl.No;
|
|
|
ln.setMyPK(DBAccess.GenerGUID());
|
|
|
ln.DirectInsert();
|
|
|
}
|
|
|
break;
|
|
|
case "WF_NodeDept": //FAppSets.xml。
|
|
|
foreach (DataRow dr in dt.Rows)
|
|
|
{
|
|
|
NodeDept dp = new NodeDept();
|
|
|
foreach (DataColumn dc in dt.Columns)
|
|
|
{
|
|
|
string val = dr[dc.ColumnName] as string;
|
|
|
if (val == null)
|
|
|
continue;
|
|
|
switch (dc.ColumnName.ToLower())
|
|
|
{
|
|
|
case "fk_node":
|
|
|
if (val.Length < iOldFlowLength)
|
|
|
{
|
|
|
//节点编号长度小于流程编号长度则为异常数据，异常数据不进行处理
|
|
|
throw new Exception("@导入模板名称：" + oldFlowName + "；节点WF_NodeDept下FK_Node值错误:" + val);
|
|
|
}
|
|
|
val = flowID + val.Substring(iOldFlowLength);
|
|
|
break;
|
|
|
default:
|
|
|
break;
|
|
|
}
|
|
|
dp.SetValByKey(dc.ColumnName, val);
|
|
|
}
|
|
|
try
|
|
|
{
|
|
|
//如果部门不属于本组织的，就要删除.
|
|
|
if (Glo.CCBPMRunModel != CCBPMRunModel.Single)
|
|
|
{
|
|
|
BP.WF.Port.Admin2Group.Dept dept = new BP.WF.Port.Admin2Group.Dept(dp.FK_Dept);
|
|
|
if (dept.OrgNo.Equals(WebUser.OrgNo) == false)
|
|
|
continue;
|
|
|
}
|
|
|
dp.Insert();
|
|
|
}
|
|
|
catch (Exception ex)
|
|
|
{
|
|
|
}
|
|
|
}
|
|
|
break;
|
|
|
case "WF_Node": //导入节点信息.
|
|
|
foreach (DataRow dr in dt.Rows)
|
|
|
{
|
|
|
BP.WF.Template.NodeExt nd = new BP.WF.Template.NodeExt();
|
|
|
BP.WF.Template.CCEn.CC cc = new CC(); //抄送相关的信息.
|
|
|
BP.WF.Template.NodeWorkCheck fwc = new NodeWorkCheck();
|
|
|
|
|
|
foreach (DataColumn dc in dt.Columns)
|
|
|
{
|
|
|
string val = dr[dc.ColumnName] as string;
|
|
|
if (val == null) continue;
|
|
|
|
|
|
switch (dc.ColumnName.ToLower())
|
|
|
{
|
|
|
case "nodeid":
|
|
|
if (val.Length < iOldFlowLength)
|
|
|
{
|
|
|
//节点编号长度小于流程编号长度则为异常数据，异常数据不进行处理
|
|
|
throw new Exception("@导入模板名称：" + oldFlowName + "；节点WF_Node下nodeid值错误:" + val);
|
|
|
}
|
|
|
val = flowID + val.Substring(iOldFlowLength);
|
|
|
break;
|
|
|
case "fk_flow":
|
|
|
case "fk_flowsort":
|
|
|
continue;
|
|
|
case "showsheets":
|
|
|
case "histonds":
|
|
|
case "groupstands": //去除不必要的替换
|
|
|
string key = "@" + flowID;
|
|
|
val = val.Replace(key, "@");
|
|
|
break;
|
|
|
default:
|
|
|
break;
|
|
|
}
|
|
|
nd.SetValByKey(dc.ColumnName, val);
|
|
|
cc.SetValByKey(dc.ColumnName, val);
|
|
|
fwc.SetValByKey(dc.ColumnName, val);
|
|
|
}
|
|
|
|
|
|
nd.FK_Flow = fl.No;
|
|
|
nd.FlowName = fl.Name;
|
|
|
try
|
|
|
{
|
|
|
|
|
|
if (nd.EnMap.Attrs.Contains("OfficePrintEnable"))
|
|
|
{
|
|
|
if (nd.GetValStringByKey("OfficePrintEnable") == "打印")
|
|
|
nd.SetValByKey("OfficePrintEnable", 0);
|
|
|
}
|
|
|
|
|
|
try
|
|
|
{
|
|
|
nd.DirectInsert();
|
|
|
}
|
|
|
catch (Exception ex)
|
|
|
{
|
|
|
// var i2 = 11;
|
|
|
}
|
|
|
|
|
|
//把抄送的信息也导入里面去.
|
|
|
cc.DirectUpdate();
|
|
|
fwc.FWCVer = 1; //设置为2019版本. 2018版是1个节点1个人,仅仅显示1个意见.
|
|
|
fwc.DirectUpdate();
|
|
|
DBAccess.RunSQL("DELETE FROM Sys_MapAttr WHERE FK_MapData='ND" + nd.NodeID + "'");
|
|
|
}
|
|
|
catch (Exception ex)
|
|
|
{
|
|
|
cc.CheckPhysicsTable();
|
|
|
fwc.CheckPhysicsTable();
|
|
|
|
|
|
throw new Exception("@导入节点:FlowName:" + nd.FlowName + " nodeID: " + nd.NodeID + " , " + nd.Name + " 错误:" + ex.Message);
|
|
|
}
|
|
|
|
|
|
}
|
|
|
|
|
|
// 执行update 触发其他的业务逻辑。
|
|
|
foreach (DataRow dr in dt.Rows)
|
|
|
{
|
|
|
Node nd = new Node();
|
|
|
nd.NodeID = int.Parse(dr[NodeAttr.NodeID].ToString());
|
|
|
nd.RetrieveFromDBSources();
|
|
|
nd.FK_Flow = fl.No;
|
|
|
//获取表单类别
|
|
|
string formType = dr[NodeAttr.FormType].ToString();
|
|
|
foreach (DataColumn dc in dt.Columns)
|
|
|
{
|
|
|
string val = dr[dc.ColumnName] as string;
|
|
|
if (val == null)
|
|
|
continue;
|
|
|
switch (dc.ColumnName.ToLower())
|
|
|
{
|
|
|
case "nodefrmid":
|
|
|
//绑定表单库的表单11不需要替换表单编号
|
|
|
if (formType.Equals("11") == false)
|
|
|
{
|
|
|
int iFormTypeLength = iOldFlowLength + 2;
|
|
|
if (val.Length > iFormTypeLength)
|
|
|
{
|
|
|
val = "ND" + flowID + val.Substring(iFormTypeLength);
|
|
|
}
|
|
|
}
|
|
|
break;
|
|
|
case "nodeid":
|
|
|
if (val.Length < iOldFlowLength)
|
|
|
{
|
|
|
//节点编号长度小于流程编号长度则为异常数据，异常数据不进行处理
|
|
|
throw new Exception("@导入模板名称：" + oldFlowName + "；节点WF_Node下FK_Node值错误:" + val);
|
|
|
}
|
|
|
val = flowID + val.Substring(iOldFlowLength);
|
|
|
break;
|
|
|
case "fk_flow":
|
|
|
case "fk_flowsort":
|
|
|
continue;
|
|
|
case "showsheets":
|
|
|
case "histonds":
|
|
|
case "groupstands": //修复替换
|
|
|
string key = "@" + flowID;
|
|
|
val = val.Replace(key, "@");
|
|
|
break;
|
|
|
default:
|
|
|
break;
|
|
|
}
|
|
|
nd.SetValByKey(dc.ColumnName, val);
|
|
|
}
|
|
|
nd.FK_Flow = fl.No;
|
|
|
nd.FlowName = fl.Name;
|
|
|
nd.DirectUpdate();
|
|
|
}
|
|
|
|
|
|
//更新 GroupStaNDs . HisToND
|
|
|
string sql = "UPDATE WF_Node SET GroupStaNDs=Replace(GroupStaNDs,'@" + int.Parse(oldFlowNo) + "','@" + int.Parse(fl.No) + "'), HisToNDs=Replace(HisToNDs,'@" + int.Parse(oldFlowNo) + "','@" + int.Parse(fl.No) + "') WHERE FK_Flow='" + fl.No + "'";
|
|
|
DBAccess.RunSQL(sql);
|
|
|
break;
|
|
|
case "WF_NodeExt":
|
|
|
foreach (DataRow dr in dt.Rows)
|
|
|
{
|
|
|
BP.WF.Template.NodeExt nd = new BP.WF.Template.NodeExt();
|
|
|
nd.NodeID = int.Parse(flowID + dr[NodeAttr.NodeID].ToString().Substring(iOldFlowLength));
|
|
|
nd.RetrieveFromDBSources();
|
|
|
foreach (DataColumn dc in dt.Columns)
|
|
|
{
|
|
|
string val = dr[dc.ColumnName] as string;
|
|
|
switch (dc.ColumnName.ToLower())
|
|
|
{
|
|
|
case "nodeid":
|
|
|
if (val.Length < iOldFlowLength)
|
|
|
{
|
|
|
//节点编号长度小于流程编号长度则为异常数据，异常数据不进行处理
|
|
|
throw new Exception("@导入模板名称：" + oldFlowName + "；节点WF_Node下nodeid值错误:" + val);
|
|
|
}
|
|
|
val = flowID + val.Substring(iOldFlowLength);
|
|
|
break;
|
|
|
case "fk_flow":
|
|
|
case "fk_flowsort":
|
|
|
continue;
|
|
|
case "showsheets":
|
|
|
case "histonds":
|
|
|
case "groupstands": //去除不必要的替换
|
|
|
string key = "@" + flowID;
|
|
|
val = val.Replace(key, "@");
|
|
|
break;
|
|
|
default:
|
|
|
break;
|
|
|
}
|
|
|
nd.SetValByKey(dc.ColumnName, val);
|
|
|
}
|
|
|
nd.FK_Flow = fl.No;
|
|
|
nd.DirectUpdate();
|
|
|
}
|
|
|
break;
|
|
|
case "WF_Selector":
|
|
|
foreach (DataRow dr in dt.Rows)
|
|
|
{
|
|
|
Selector selector = new Selector();
|
|
|
foreach (DataColumn dc in dt.Columns)
|
|
|
{
|
|
|
|
|
|
string val = dr[dc.ColumnName] as string;
|
|
|
if (val == null)
|
|
|
continue;
|
|
|
|
|
|
if (dc.ColumnName.ToLower().Equals("nodeid"))
|
|
|
{
|
|
|
if (val.Length < iOldFlowLength)
|
|
|
{
|
|
|
// 节点编号长度小于流程编号长度则为异常数据，异常数据不进行处理
|
|
|
throw new Exception("@导入模板名称：" + oldFlowName + "；节点WF_Node下FK_Node值错误:" + val);
|
|
|
}
|
|
|
val = flowID + val.Substring(iOldFlowLength);
|
|
|
}
|
|
|
|
|
|
selector.SetValByKey(dc.ColumnName, val);
|
|
|
}
|
|
|
selector.DirectUpdate();
|
|
|
}
|
|
|
break;
|
|
|
case "WF_NodeStation": //FAppSets.xml。
|
|
|
DBAccess.RunSQL("DELETE FROM WF_NodeStation WHERE FK_Node IN (SELECT NodeID FROM WF_Node WHERE FK_Flow='" + fl.No + "')");
|
|
|
foreach (DataRow dr in dt.Rows)
|
|
|
{
|
|
|
NodeStation ns = new NodeStation();
|
|
|
foreach (DataColumn dc in dt.Columns)
|
|
|
{
|
|
|
string val = dr[dc.ColumnName] as string;
|
|
|
if (val == null)
|
|
|
continue;
|
|
|
|
|
|
switch (dc.ColumnName.ToLower())
|
|
|
{
|
|
|
case "fk_node":
|
|
|
if (val.Length < iOldFlowLength)
|
|
|
{
|
|
|
//节点编号长度小于流程编号长度则为异常数据，异常数据不进行处理
|
|
|
throw new Exception("@导入模板名称：" + oldFlowName + "；节点WF_NodeStation下FK_Node值错误:" + val);
|
|
|
}
|
|
|
val = flowID + val.Substring(iOldFlowLength);
|
|
|
break;
|
|
|
default:
|
|
|
break;
|
|
|
}
|
|
|
ns.SetValByKey(dc.ColumnName, val);
|
|
|
}
|
|
|
ns.Insert();
|
|
|
}
|
|
|
break;
|
|
|
case "Sys_Enum": //RptEmps.xml。
|
|
|
case "Sys_Enums":
|
|
|
foreach (DataRow dr in dt.Rows)
|
|
|
{
|
|
|
SysEnum se = new Sys.SysEnum();
|
|
|
foreach (DataColumn dc in dt.Columns)
|
|
|
{
|
|
|
string val = dr[dc.ColumnName] as string;
|
|
|
switch (dc.ColumnName.ToLower())
|
|
|
{
|
|
|
case "fk_node":
|
|
|
break;
|
|
|
default:
|
|
|
break;
|
|
|
}
|
|
|
se.SetValByKey(dc.ColumnName, val);
|
|
|
}
|
|
|
// se.setMyPK(se.EnumKey + "_" + se.Lang + "_" + se.IntKey;
|
|
|
|
|
|
//设置orgNo.
|
|
|
se.OrgNo = WebUser.OrgNo;
|
|
|
se.ResetPK();
|
|
|
|
|
|
if (se.IsExits == true)
|
|
|
continue;
|
|
|
se.Insert();
|
|
|
}
|
|
|
break;
|
|
|
case "Sys_EnumMain": //RptEmps.xml。
|
|
|
foreach (DataRow dr in dt.Rows)
|
|
|
{
|
|
|
SysEnumMain sem = new Sys.SysEnumMain();
|
|
|
foreach (DataColumn dc in dt.Columns)
|
|
|
{
|
|
|
string val = dr[dc.ColumnName] as string;
|
|
|
if (val == null)
|
|
|
continue;
|
|
|
sem.SetValByKey(dc.ColumnName, val);
|
|
|
}
|
|
|
if (sem.IsExits)
|
|
|
continue;
|
|
|
sem.Insert();
|
|
|
}
|
|
|
break;
|
|
|
case "Sys_MapAttr": //RptEmps.xml。
|
|
|
foreach (DataRow dr in dt.Rows)
|
|
|
{
|
|
|
MapAttr ma = new Sys.MapAttr();
|
|
|
foreach (DataColumn dc in dt.Columns)
|
|
|
{
|
|
|
string val = dr[dc.ColumnName] as string;
|
|
|
switch (dc.ColumnName.ToLower())
|
|
|
{
|
|
|
case "fk_mapdata":
|
|
|
case "keyofen":
|
|
|
case "autofulldoc":
|
|
|
if (val == null)
|
|
|
continue;
|
|
|
val = val.Replace("ND" + oldFlowID, "ND" + flowID);
|
|
|
break;
|
|
|
default:
|
|
|
break;
|
|
|
}
|
|
|
ma.SetValByKey(dc.ColumnName, val);
|
|
|
}
|
|
|
bool b = ma.IsExit(BP.Sys.MapAttrAttr.FK_MapData, ma.FK_MapData,
|
|
|
MapAttrAttr.KeyOfEn, ma.KeyOfEn);
|
|
|
|
|
|
ma.setMyPK(ma.FK_MapData + "_" + ma.KeyOfEn);
|
|
|
if (b == true)
|
|
|
ma.DirectUpdate();
|
|
|
else
|
|
|
ma.DirectInsert();
|
|
|
}
|
|
|
break;
|
|
|
case "Sys_MapData": //RptEmps.xml。
|
|
|
foreach (DataRow dr in dt.Rows)
|
|
|
{
|
|
|
MapData md = new Sys.MapData();
|
|
|
string htmlCode = "";
|
|
|
foreach (DataColumn dc in dt.Columns)
|
|
|
{
|
|
|
if (dc.ColumnName == "HtmlTemplateFile")
|
|
|
{
|
|
|
htmlCode = dr[dc.ColumnName] as string;
|
|
|
continue;
|
|
|
}
|
|
|
|
|
|
string val = dr[dc.ColumnName] as string;
|
|
|
if (val == null)
|
|
|
continue;
|
|
|
|
|
|
val = val.Replace("ND" + oldFlowID, "ND" + int.Parse(fl.No));
|
|
|
md.SetValByKey(dc.ColumnName, val);
|
|
|
}
|
|
|
md.Save();
|
|
|
|
|
|
//如果是开发者表单，赋值HtmlTemplateFile数据库的值并保存到DataUser下
|
|
|
if (md.HisFrmType == FrmType.Develop)
|
|
|
{
|
|
|
//string htmlCode = DBAccess.GetBigTextFromDB("Sys_MapData", "No", "ND" + oldFlowID, "HtmlTemplateFile");
|
|
|
if (DataType.IsNullOrEmpty(htmlCode) == false)
|
|
|
{
|
|
|
htmlCode = htmlCode.Replace("ND" + oldFlowID, "ND" + int.Parse(fl.No));
|
|
|
//保存到数据库，存储html文件
|
|
|
//保存到DataUser/CCForm/HtmlTemplateFile/文件夹下
|
|
|
string filePath = BP.Difference.SystemConfig.PathOfDataUser + "CCForm/HtmlTemplateFile/";
|
|
|
if (Directory.Exists(filePath) == false)
|
|
|
Directory.CreateDirectory(filePath);
|
|
|
filePath = filePath + md.No + ".htm";
|
|
|
//写入到html 中
|
|
|
DataType.WriteFile(filePath, htmlCode);
|
|
|
// HtmlTemplateFile 保存到数据库中
|
|
|
DBAccess.SaveBigTextToDB(htmlCode, "Sys_MapData", "No", md.No, "HtmlTemplateFile");
|
|
|
}
|
|
|
else
|
|
|
{
|
|
|
//如果htmlCode是空的需要删除当前节点的html文件
|
|
|
string filePath = BP.Difference.SystemConfig.PathOfDataUser + "CCForm/HtmlTemplateFile/" + md.No + ".htm";
|
|
|
if (File.Exists(filePath) == true)
|
|
|
File.Delete(filePath);
|
|
|
DBAccess.SaveBigTextToDB("", "Sys_MapData", "No", md.No, "HtmlTemplateFile");
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
|
|
|
break;
|
|
|
case "Sys_MapDtl": //RptEmps.xml。
|
|
|
foreach (DataRow dr in dt.Rows)
|
|
|
{
|
|
|
MapDtl md = new Sys.MapDtl();
|
|
|
foreach (DataColumn dc in dt.Columns)
|
|
|
{
|
|
|
string val = dr[dc.ColumnName] as string;
|
|
|
if (val == null)
|
|
|
continue;
|
|
|
|
|
|
val = val.Replace("ND" + oldFlowID, "ND" + flowID);
|
|
|
md.SetValByKey(dc.ColumnName, val);
|
|
|
}
|
|
|
md.Save();
|
|
|
md.IntMapAttrs(); //初始化他的字段属性.
|
|
|
}
|
|
|
break;
|
|
|
case "Sys_MapExt":
|
|
|
foreach (DataRow dr in dt.Rows)
|
|
|
{
|
|
|
MapExt md = new Sys.MapExt();
|
|
|
foreach (DataColumn dc in dt.Columns)
|
|
|
{
|
|
|
string val = dr[dc.ColumnName] as string;
|
|
|
if (val == null)
|
|
|
continue;
|
|
|
|
|
|
val = val.Replace("ND" + oldFlowID, "ND" + flowID);
|
|
|
md.SetValByKey(dc.ColumnName, val);
|
|
|
}
|
|
|
|
|
|
//调整他的PK.
|
|
|
//md.InitPK();
|
|
|
md.Save(); //执行保存.
|
|
|
}
|
|
|
break;
|
|
|
case "Sys_FrmImg":
|
|
|
idx = 0;
|
|
|
timeKey = DateTime.Now.ToString("yyyyMMddHHmmss");
|
|
|
foreach (DataRow dr in dt.Rows)
|
|
|
{
|
|
|
idx++;
|
|
|
FrmImg en = new FrmImg();
|
|
|
foreach (DataColumn dc in dt.Columns)
|
|
|
{
|
|
|
string val = dr[dc.ColumnName] as string;
|
|
|
if (val == null)
|
|
|
continue;
|
|
|
val = val.Replace("ND" + oldFlowID, "ND" + flowID);
|
|
|
en.SetValByKey(dc.ColumnName, val);
|
|
|
}
|
|
|
|
|
|
//设置主键.
|
|
|
en.setMyPK(en.FK_MapData + "_" + en.KeyOfEn);
|
|
|
en.Save(); //执行保存.
|
|
|
}
|
|
|
break;
|
|
|
case "Sys_FrmImgAth": //图片附件.
|
|
|
idx = 0;
|
|
|
timeKey = DateTime.Now.ToString("yyyyMMddHHmmss");
|
|
|
foreach (DataRow dr in dt.Rows)
|
|
|
{
|
|
|
idx++;
|
|
|
FrmImgAth en = new FrmImgAth();
|
|
|
foreach (DataColumn dc in dt.Columns)
|
|
|
{
|
|
|
string val = dr[dc.ColumnName] as string;
|
|
|
if (val == null)
|
|
|
continue;
|
|
|
val = val.Replace("ND" + oldFlowID, "ND" + flowID);
|
|
|
en.SetValByKey(dc.ColumnName, val);
|
|
|
}
|
|
|
en.setMyPK(en.FK_MapData + "_" + en.CtrlID);
|
|
|
en.Save();
|
|
|
// en.setMyPK(Guid.NewGuid().ToString());
|
|
|
}
|
|
|
break;
|
|
|
case "Sys_FrmAttachment":
|
|
|
idx = 0;
|
|
|
foreach (DataRow dr in dt.Rows)
|
|
|
{
|
|
|
idx++;
|
|
|
FrmAttachment en = new FrmAttachment();
|
|
|
foreach (DataColumn dc in dt.Columns)
|
|
|
{
|
|
|
string val = dr[dc.ColumnName] as string;
|
|
|
if (val == null)
|
|
|
continue;
|
|
|
|
|
|
val = val.Replace("ND" + oldFlowID, "ND" + flowID);
|
|
|
en.SetValByKey(dc.ColumnName, val);
|
|
|
}
|
|
|
|
|
|
en.setMyPK(en.FK_MapData + "_" + en.NoOfObj);
|
|
|
en.Save();
|
|
|
}
|
|
|
break;
|
|
|
case "Sys_FrmEvent": //事件.
|
|
|
idx = 0;
|
|
|
foreach (DataRow dr in dt.Rows)
|
|
|
{
|
|
|
idx++;
|
|
|
FrmEvent en = new FrmEvent();
|
|
|
foreach (DataColumn dc in dt.Columns)
|
|
|
{
|
|
|
string val = dr[dc.ColumnName] as string;
|
|
|
if (val == null)
|
|
|
continue;
|
|
|
|
|
|
switch (dc.ColumnName.ToLower())
|
|
|
{
|
|
|
case "fk_node":
|
|
|
if (val.Equals("0") == false)
|
|
|
{
|
|
|
if (val.Length < iOldFlowLength)
|
|
|
{
|
|
|
//节点编号长度小于流程编号长度则为异常数据，异常数据不进行处理
|
|
|
throw new Exception("@导入模板名称：" + oldFlowName + "；节点Sys_FrmEvent下FK_Node值错误:" + val);
|
|
|
}
|
|
|
val = flowID + val.Substring(iOldFlowLength);
|
|
|
}
|
|
|
break;
|
|
|
case "fk_flow":
|
|
|
val = fl.No;
|
|
|
break;
|
|
|
default:
|
|
|
val = val.Replace("ND" + oldFlowID, "ND" + flowID);
|
|
|
break;
|
|
|
}
|
|
|
|
|
|
en.SetValByKey(dc.ColumnName, val);
|
|
|
}
|
|
|
|
|
|
//解决保存错误问题.
|
|
|
en.setMyPK(DBAccess.GenerGUID());
|
|
|
en.Insert();
|
|
|
}
|
|
|
break;
|
|
|
case "Sys_FrmRB": //Sys_FrmRB.
|
|
|
idx = 0;
|
|
|
foreach (DataRow dr in dt.Rows)
|
|
|
{
|
|
|
idx++;
|
|
|
FrmRB en = new FrmRB();
|
|
|
foreach (DataColumn dc in dt.Columns)
|
|
|
{
|
|
|
string val = dr[dc.ColumnName] as string;
|
|
|
if (val == null)
|
|
|
continue;
|
|
|
|
|
|
val = val.Replace("ND" + oldFlowID, "ND" + flowID);
|
|
|
en.SetValByKey(dc.ColumnName, val);
|
|
|
}
|
|
|
en.Insert();
|
|
|
}
|
|
|
break;
|
|
|
case "Sys_MapFrame":
|
|
|
idx = 0;
|
|
|
foreach (DataRow dr in dt.Rows)
|
|
|
{
|
|
|
idx++;
|
|
|
MapFrame en = new MapFrame();
|
|
|
foreach (DataColumn dc in dt.Columns)
|
|
|
{
|
|
|
object val = dr[dc.ColumnName] as object;
|
|
|
if (val == null)
|
|
|
continue;
|
|
|
|
|
|
|
|
|
en.SetValByKey(dc.ColumnName, val.ToString().Replace("ND" + oldFlowID, "ND" + flowID));
|
|
|
}
|
|
|
en.DirectInsert();
|
|
|
}
|
|
|
break;
|
|
|
case "WF_NodeEmp": //FAppSets.xml。
|
|
|
foreach (DataRow dr in dt.Rows)
|
|
|
{
|
|
|
NodeEmp ne = new NodeEmp();
|
|
|
foreach (DataColumn dc in dt.Columns)
|
|
|
{
|
|
|
string val = dr[dc.ColumnName] as string;
|
|
|
if (val == null)
|
|
|
continue;
|
|
|
|
|
|
switch (dc.ColumnName.ToLower())
|
|
|
{
|
|
|
case "fk_node":
|
|
|
if (val.Length < iOldFlowLength)
|
|
|
{
|
|
|
//节点编号长度小于流程编号长度则为异常数据，异常数据不进行处理
|
|
|
throw new Exception("@导入模板名称：" + oldFlowName + "；节点WF_NodeEmp下FK_Node值错误:" + val);
|
|
|
}
|
|
|
val = flowID + val.Substring(iOldFlowLength);
|
|
|
break;
|
|
|
default:
|
|
|
break;
|
|
|
}
|
|
|
ne.SetValByKey(dc.ColumnName, val);
|
|
|
}
|
|
|
ne.Insert();
|
|
|
}
|
|
|
break;
|
|
|
case "Sys_GroupField":
|
|
|
//foreach (DataRow dr in dt.Rows)
|
|
|
//{
|
|
|
// GroupField gf = new Sys.GroupField();
|
|
|
// foreach (DataColumn dc in dt.Columns)
|
|
|
// {
|
|
|
// string val = dr[dc.ColumnName] as string;
|
|
|
// if (val == null)
|
|
|
// continue;
|
|
|
// switch (dc.ColumnName.ToLower())
|
|
|
// {
|
|
|
// case "enname":
|
|
|
// case "keyofen":
|
|
|
// case "ctrlid": //升级傻瓜表单的时候,新增加的字段 add by zhoupeng 2016.11.21
|
|
|
// case "frmid": //升级傻瓜表单的时候,新增加的字段 add by zhoupeng 2016.11.21
|
|
|
// val = val.Replace("ND" + oldFlowID, "ND" + flowID);
|
|
|
// break;
|
|
|
// default:
|
|
|
// break;
|
|
|
// }
|
|
|
// gf.SetValByKey(dc.ColumnName, val);
|
|
|
// }
|
|
|
// gf.InsertAsOID(gf.OID);
|
|
|
//}
|
|
|
break;
|
|
|
case "WF_NodeCC":
|
|
|
foreach (DataRow dr in dt.Rows)
|
|
|
{
|
|
|
CC cc = new CC();
|
|
|
cc.NodeID = int.Parse(flowID + dr[NodeAttr.NodeID].ToString().Substring(iOldFlowLength));
|
|
|
cc.RetrieveFromDBSources();
|
|
|
foreach (DataColumn dc in dt.Columns)
|
|
|
{
|
|
|
|
|
|
string val = dr[dc.ColumnName] as string;
|
|
|
if (val == null)
|
|
|
continue;
|
|
|
|
|
|
if (dc.ColumnName.ToLower().Equals("nodeid"))
|
|
|
{
|
|
|
if (val.Length < iOldFlowLength)
|
|
|
{
|
|
|
// 节点编号长度小于流程编号长度则为异常数据，异常数据不进行处理
|
|
|
throw new Exception("@导入模板名称：" + oldFlowName + "；节点WF_Node下FK_Node值错误:" + val);
|
|
|
}
|
|
|
val = flowID + val.Substring(iOldFlowLength);
|
|
|
}
|
|
|
|
|
|
cc.SetValByKey(dc.ColumnName, val);
|
|
|
}
|
|
|
cc.SetValByKey("FK_Flow", fl.No);
|
|
|
cc.DirectUpdate();
|
|
|
}
|
|
|
break;
|
|
|
case "WF_CCEmp": // 抄送.
|
|
|
foreach (DataRow dr in dt.Rows)
|
|
|
{
|
|
|
CCEmp ne = new CCEmp();
|
|
|
foreach (DataColumn dc in dt.Columns)
|
|
|
{
|
|
|
string val = dr[dc.ColumnName] as string;
|
|
|
if (val == null)
|
|
|
continue;
|
|
|
|
|
|
switch (dc.ColumnName.ToLower())
|
|
|
{
|
|
|
case "fk_node":
|
|
|
if (val.Length < iOldFlowLength)
|
|
|
{
|
|
|
//节点编号长度小于流程编号长度则为异常数据，异常数据不进行处理
|
|
|
throw new Exception("@导入模板名称：" + oldFlowName + "；节点WF_CCEmp下FK_Node值错误:" + val);
|
|
|
}
|
|
|
val = flowID + val.Substring(iOldFlowLength);
|
|
|
break;
|
|
|
default:
|
|
|
break;
|
|
|
}
|
|
|
ne.SetValByKey(dc.ColumnName, val);
|
|
|
}
|
|
|
ne.Insert();
|
|
|
}
|
|
|
break;
|
|
|
case "WF_CCStation": // 抄送.
|
|
|
string mysql = " DELETE FROM WF_CCStation WHERE FK_Node IN (SELECT NodeID FROM WF_Node WHERE FK_Flow='" + flowID + "')";
|
|
|
DBAccess.RunSQL(mysql);
|
|
|
foreach (DataRow dr in dt.Rows)
|
|
|
{
|
|
|
CCStation ne = new CCStation();
|
|
|
foreach (DataColumn dc in dt.Columns)
|
|
|
{
|
|
|
string val = dr[dc.ColumnName] as string;
|
|
|
if (val == null)
|
|
|
continue;
|
|
|
|
|
|
switch (dc.ColumnName.ToLower())
|
|
|
{
|
|
|
case "fk_node":
|
|
|
if (val.Length < iOldFlowLength)
|
|
|
{
|
|
|
//节点编号长度小于流程编号长度则为异常数据，异常数据不进行处理
|
|
|
throw new Exception("@导入模板名称：" + oldFlowName + "；节点WF_CCStation下FK_Node值错误:" + val);
|
|
|
}
|
|
|
val = flowID + val.Substring(iOldFlowLength);
|
|
|
break;
|
|
|
default:
|
|
|
break;
|
|
|
}
|
|
|
ne.SetValByKey(dc.ColumnName, val);
|
|
|
}
|
|
|
ne.Save();
|
|
|
}
|
|
|
break;
|
|
|
default:
|
|
|
// infoErr += "Error:" + dt.TableName;
|
|
|
break;
|
|
|
// throw new Exception("@unhandle named " + dt.TableName);
|
|
|
}
|
|
|
}
|
|
|
|
|
|
#region 处理数据完整性。
|
|
|
|
|
|
|
|
|
//DBAccess.RunSQL("UPDATE WF_Cond SET FK_Node=NodeID WHERE FK_Node=0");
|
|
|
//DBAccess.RunSQL("UPDATE WF_Cond SET ToNodeID=NodeID WHERE ToNodeID=0");
|
|
|
// DBAccess.RunSQL("DELETE FROM WF_Cond WHERE NodeID NOT IN (SELECT NodeID FROM WF_Node)");
|
|
|
// DBAccess.RunSQL("DELETE FROM WF_Cond WHERE ToNodeID NOT IN (SELECT NodeID FROM WF_Node) ");
|
|
|
// DBAccess.RunSQL("DELETE FROM WF_Cond WHERE FK_Node NOT IN (SELECT NodeID FROM WF_Node) AND FK_Node > 0");
|
|
|
|
|
|
//处理分组错误.
|
|
|
Nodes nds = new Nodes(fl.No);
|
|
|
foreach (Node nd in nds)
|
|
|
{
|
|
|
MapFrmFool cols = new MapFrmFool("ND" + nd.NodeID);
|
|
|
cols.DoCheckFixFrmForUpdateVer();
|
|
|
}
|
|
|
#endregion
|
|
|
|
|
|
//处理OrgNo 的导入问题.
|
|
|
if (Glo.CCBPMRunModel != CCBPMRunModel.Single)
|
|
|
{
|
|
|
fl.RetrieveFromDBSources();
|
|
|
fl.OrgNo = BP.Web.WebUser.OrgNo;
|
|
|
fl.DirectUpdate();
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
if (infoErr == "")
|
|
|
{
|
|
|
infoTable = "";
|
|
|
|
|
|
|
|
|
//写入日志.
|
|
|
BP.Sys.Base.Glo.WriteUserLog("导入流程模板：" + fl.Name + " - " + fl.No);
|
|
|
|
|
|
//创建track.
|
|
|
Track.CreateOrRepairTrackTable(fl.No);
|
|
|
return fl; // "完全成功。";
|
|
|
}
|
|
|
|
|
|
infoErr = "@执行期间出现如下非致命的错误：\t\r" + infoErr + "@ " + infoTable;
|
|
|
throw new Exception(infoErr);
|
|
|
}
|
|
|
|
|
|
public static Node NewNode(string flowNo, int x, int y, string icon = null, int runModel = 0)
|
|
|
{
|
|
|
Flow flow = new Flow(flowNo);
|
|
|
|
|
|
Node nd = new Node();
|
|
|
int idx = DBAccess.RunSQLReturnValInt("SELECT COUNT(NodeID) FROM WF_Node WHERE FK_Flow='" + flowNo + "'", 0);
|
|
|
if (idx == 0)
|
|
|
idx++;
|
|
|
|
|
|
var nodeID = 0;
|
|
|
//设置节点ID.
|
|
|
while (true)
|
|
|
{
|
|
|
string strID = flowNo + idx.ToString().PadLeft(2, '0');
|
|
|
nd.NodeID = int.Parse(strID);
|
|
|
if (nd.IsExits == false)
|
|
|
break;
|
|
|
idx++;
|
|
|
}
|
|
|
|
|
|
if (nd.NodeID > int.Parse(flowNo + "99"))
|
|
|
throw new Exception("流程最大节点编号不可以超过100");
|
|
|
|
|
|
nodeID = nd.NodeID;
|
|
|
|
|
|
//增加了两个默认值值 . 2016.11.15. 目的是让创建的节点，就可以使用.
|
|
|
nd.CondModel = DirCondModel.ByDDLSelected; //默认的发送方向.
|
|
|
nd.HisDeliveryWay = DeliveryWay.BySelected; //上一步发送人来选择.
|
|
|
nd.FormType = NodeFormType.FoolForm; //设置为傻瓜表单.
|
|
|
|
|
|
//如果是极简模式.
|
|
|
if (flow.FlowDevModel == FlowDevModel.JiJian)
|
|
|
{
|
|
|
nd.FormType = NodeFormType.FoolForm; //设置为傻瓜表单.
|
|
|
nd.NodeFrmID = "ND" + int.Parse(flow.No) + "01";
|
|
|
nd.FrmWorkCheckSta = FrmWorkCheckSta.Enable;
|
|
|
nd.DirectUpdate();
|
|
|
FrmNode fn = new FrmNode();
|
|
|
fn.FK_Frm = nd.NodeFrmID;
|
|
|
fn.IsEnableFWC = FrmWorkCheckSta.Enable;
|
|
|
fn.FK_Node = nd.NodeID;
|
|
|
fn.FK_Flow = flowNo;
|
|
|
fn.FrmSln = FrmSln.Readonly;
|
|
|
fn.setMyPK(fn.FK_Frm + "_" + fn.FK_Node + "_" + fn.FK_Flow);
|
|
|
//执行保存.
|
|
|
fn.Save();
|
|
|
MapData md = new MapData(nd.NodeFrmID);
|
|
|
md.HisFrmType = FrmType.FoolForm;
|
|
|
md.Update();
|
|
|
}
|
|
|
|
|
|
//如果是累加.
|
|
|
if (flow.FlowDevModel == FlowDevModel.FoolTruck)
|
|
|
{
|
|
|
nd.FormType = NodeFormType.FoolTruck; //设置为傻瓜表单.
|
|
|
nd.NodeFrmID = "ND" + nodeID;
|
|
|
nd.FrmWorkCheckSta = FrmWorkCheckSta.Disable;
|
|
|
nd.DirectUpdate();
|
|
|
}
|
|
|
|
|
|
//如果是绑定表单库的表单
|
|
|
if (flow.FlowDevModel == FlowDevModel.RefOneFrmTree)
|
|
|
{
|
|
|
nd.FormType = NodeFormType.RefOneFrmTree; //设置为傻瓜表单.
|
|
|
nd.NodeFrmID = flow.FrmUrl;
|
|
|
nd.FrmWorkCheckSta = FrmWorkCheckSta.Enable;
|
|
|
nd.DirectUpdate();
|
|
|
FrmNode fn = new FrmNode();
|
|
|
fn.FK_Frm = nd.NodeFrmID;
|
|
|
fn.IsEnableFWC = FrmWorkCheckSta.Enable;
|
|
|
fn.FK_Node = nd.NodeID;
|
|
|
fn.FK_Flow = flowNo;
|
|
|
fn.FrmSln = FrmSln.Readonly;
|
|
|
fn.setMyPK(fn.FK_Frm + "_" + fn.FK_Node + "_" + fn.FK_Flow);
|
|
|
//执行保存.
|
|
|
fn.Save();
|
|
|
|
|
|
}
|
|
|
//如果是Self类型的表单的类型
|
|
|
if (flow.FlowDevModel == FlowDevModel.SDKFrmSelfPK || flow.FlowDevModel == FlowDevModel.SDKFrmWorkID)
|
|
|
{
|
|
|
nd.HisFormType = NodeFormType.SDKForm;
|
|
|
nd.FormUrl = flow.FrmUrl;
|
|
|
nd.DirectUpdate();
|
|
|
}
|
|
|
|
|
|
//如果是Self类型的表单的类型
|
|
|
if (flow.FlowDevModel == FlowDevModel.SelfFrm)
|
|
|
{
|
|
|
nd.HisFormType = NodeFormType.SelfForm;
|
|
|
nd.FormUrl = flow.FrmUrl;
|
|
|
nd.DirectUpdate();
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
nd.FK_Flow = flowNo;
|
|
|
nd.Insert();
|
|
|
|
|
|
//为创建节点设置默认值 部分方法
|
|
|
string file = BP.Difference.SystemConfig.PathOfDataUser + "XML/DefaultNewNodeAttr.xml";
|
|
|
DataSet ds = new DataSet();
|
|
|
|
|
|
if (1 == 2 && System.IO.File.Exists(file) == true)
|
|
|
{
|
|
|
ds.ReadXml(file);
|
|
|
|
|
|
NodeExt ndExt = new NodeExt(nd.NodeID);
|
|
|
DataTable dt = ds.Tables[0];
|
|
|
foreach (DataColumn dc in dt.Columns)
|
|
|
{
|
|
|
nd.SetValByKey(dc.ColumnName, dt.Rows[0][dc.ColumnName]);
|
|
|
ndExt.SetValByKey(dc.ColumnName, dt.Rows[0][dc.ColumnName]);
|
|
|
}
|
|
|
|
|
|
ndExt.FK_Flow = flowNo;
|
|
|
ndExt.NodeID = nodeID;
|
|
|
ndExt.DirectUpdate();
|
|
|
}
|
|
|
nd.FWCVer = 1; //设置为2019版本. 2018版是1个节点1个人,仅仅显示1个意见.
|
|
|
nd.NodeID = nodeID;
|
|
|
nd.HisDeliveryWay = DeliveryWay.BySelected;
|
|
|
nd.X = x;
|
|
|
nd.Y = y;
|
|
|
nd.Icon = icon;
|
|
|
nd.Step = idx;
|
|
|
|
|
|
//节点类型.
|
|
|
nd.HisNodeWorkType = NodeWorkType.Work;
|
|
|
nd.Name = "New Node " + idx;
|
|
|
nd.HisNodePosType = NodePosType.Mid;
|
|
|
nd.FK_Flow = flow.No;
|
|
|
nd.FlowName = flow.Name;
|
|
|
|
|
|
//设置审核意见的默认值.
|
|
|
nd.SetValByKey(NodeWorkCheckAttr.FWCDefInfo,
|
|
|
BP.WF.Glo.DefVal_WF_Node_FWCDefInfo);
|
|
|
|
|
|
//设置节点类型.
|
|
|
nd.HisRunModel = (RunModel)runModel;
|
|
|
|
|
|
|
|
|
nd.Update(); //执行更新.
|
|
|
nd.CreateMap();
|
|
|
|
|
|
//通用的人员选择器.
|
|
|
BP.WF.Template.Selector select = new Selector(nd.NodeID);
|
|
|
select.SelectorModel = SelectorModel.GenerUserSelecter;
|
|
|
select.Update();
|
|
|
|
|
|
//设置默认值。
|
|
|
int state = 0;
|
|
|
if (flow.FlowDevModel == FlowDevModel.JiJian)
|
|
|
state = 1;
|
|
|
|
|
|
//设置审核组件的高度.
|
|
|
DBAccess.RunSQL("UPDATE WF_Node SET FWC_H=300,FTC_H=300," + NodeAttr.FWCSta + "=" + state + " WHERE NodeID='" + nd.NodeID + "'");
|
|
|
|
|
|
//创建默认的推送消息.
|
|
|
CreatePushMsg(nd);
|
|
|
|
|
|
//写入日志.
|
|
|
BP.Sys.Base.Glo.WriteUserLog("创建节点：" + nd.Name + " - " + nd.NodeID);
|
|
|
return nd;
|
|
|
}
|
|
|
private static void CreatePushMsg(Node nd)
|
|
|
{
|
|
|
/*创建发送短消息,为默认的消息.*/
|
|
|
BP.WF.Template.PushMsg pm = new BP.WF.Template.PushMsg();
|
|
|
int i = pm.Retrieve(PushMsgAttr.FK_Event, EventListNode.SendSuccess,
|
|
|
PushMsgAttr.FK_Node, nd.NodeID, PushMsgAttr.FK_Flow, nd.FK_Flow);
|
|
|
if (i == 0)
|
|
|
{
|
|
|
pm.FK_Event = EventListNode.SendSuccess;
|
|
|
pm.FK_Node = nd.NodeID;
|
|
|
pm.FK_Flow = nd.FK_Flow;
|
|
|
|
|
|
pm.SMSPushWay = 1; // 发送短消息.
|
|
|
pm.SMSPushModel = "Email";
|
|
|
pm.setMyPK(DBAccess.GenerGUID());
|
|
|
pm.Insert();
|
|
|
}
|
|
|
|
|
|
//设置退回消息提醒.
|
|
|
i = pm.Retrieve(PushMsgAttr.FK_Event, EventListNode.ReturnAfter,
|
|
|
PushMsgAttr.FK_Node, nd.NodeID, PushMsgAttr.FK_Flow, nd.FK_Flow);
|
|
|
if (i == 0)
|
|
|
{
|
|
|
pm.FK_Event = EventListNode.ReturnAfter;
|
|
|
pm.FK_Node = nd.NodeID;
|
|
|
pm.FK_Flow = nd.FK_Flow;
|
|
|
|
|
|
pm.SMSPushWay = 1; // 发送短消息.
|
|
|
pm.MailPushWay = 0; //不发送邮件消息.
|
|
|
pm.setMyPK(DBAccess.GenerGUID());
|
|
|
pm.Insert();
|
|
|
}
|
|
|
}
|
|
|
|
|
|
/// <summary>
|
|
|
/// 检查当前人员是否有修改该流程模版的权限.
|
|
|
/// </summary>
|
|
|
/// <param name="flowNo"></param>
|
|
|
/// <returns></returns>
|
|
|
public static bool CheckPower(string flowNo)
|
|
|
{
|
|
|
if (BP.Difference.SystemConfig.CCBPMRunModel != CCBPMRunModel.GroupInc)
|
|
|
return true;
|
|
|
|
|
|
return true;
|
|
|
|
|
|
if (BP.Web.WebUser.No.Equals("admin") == true)
|
|
|
return true;
|
|
|
|
|
|
string sql = "SELECT DesignerNo FROM WF_Flow WHERE No='" + flowNo + "'";
|
|
|
string empNo = DBAccess.RunSQLReturnStringIsNull(sql, null);
|
|
|
if (DataType.IsNullOrEmpty(empNo) == true)
|
|
|
return true;
|
|
|
|
|
|
if (empNo.Equals(BP.Web.WebUser.No) == false)
|
|
|
throw new Exception("err@您没有权限对该流程修改.");
|
|
|
|
|
|
return true;
|
|
|
}
|
|
|
/// <summary>
|
|
|
/// 创建流程.
|
|
|
/// </summary>
|
|
|
/// <param name="flowSort"></param>
|
|
|
/// <param name="filePath"></param>
|
|
|
/// <returns></returns>
|
|
|
/// <exception cref="Exception"></exception>
|
|
|
private static SemaphoreSlim _semaphore = new SemaphoreSlim(20); // 信号量
|
|
|
public static Flow NewFlowByBPMN(string flowSort, string filePath)
|
|
|
{
|
|
|
#region 0. 读取文件.
|
|
|
DataSet ds = new DataSet();
|
|
|
ds.ReadXml(filePath);
|
|
|
// 读取流程属性
|
|
|
DataTable dtFlow = ds.Tables["process"];
|
|
|
// 读取节点
|
|
|
DataTable dtNode = ds.Tables["userTask"];
|
|
|
// 读取方法条件
|
|
|
DataTable dtDirs = ds.Tables["sequenceFlow"];
|
|
|
// 图形数据
|
|
|
DataTable dtShapes = ds.Tables["BPMNShape"];
|
|
|
// 图形坐标
|
|
|
DataTable dtPositions = ds.Tables["Bounds"];
|
|
|
|
|
|
HttpContext ctx = HttpContextHelper.Current;
|
|
|
|
|
|
//只支持单个流程的导入
|
|
|
DataRow drFlow = ds.Tables["process"].Rows[0];
|
|
|
|
|
|
string flowName = drFlow["name"].ToString(); //获得流程名称
|
|
|
string flowMark = drFlow["id"].ToString(); //获得流程标记.
|
|
|
Flow fl = new Flow();
|
|
|
fl.FlowMark = flowMark;
|
|
|
if (fl.RetrieveFromDBSources() == 1)
|
|
|
throw new Exception("err@该流程[" + flowMark + "]已经导入,如果您要导入，请您修改模板的流程标记.");
|
|
|
#endregion 检查完整性.
|
|
|
|
|
|
#region 1. 创建空白的模板做准备..
|
|
|
string sortNo = "001"; //放入的流程目录.
|
|
|
string flowNo = BP.WF.Template.TemplateGlo.NewFlowTemplate(sortNo, flowName, DataStoreModel.ByCCFlow, null, null);
|
|
|
|
|
|
fl.No = flowNo;
|
|
|
fl.RetrieveFromDBSources();
|
|
|
fl.FlowMark = flowMark; //更新标记.
|
|
|
fl.FK_FlowSort = flowSort; //更新流程目录
|
|
|
fl.Update();
|
|
|
|
|
|
//删除第2个节点信息.
|
|
|
Node nd = new Node();
|
|
|
nd.NodeID = int.Parse(flowNo + "02");
|
|
|
nd.Delete(); //删除节点.
|
|
|
BP.WF.Template.Directions dir = new Directions();
|
|
|
dir.Delete(DirectionAttr.FK_Flow, flowNo);
|
|
|
//Node nd = new Node();
|
|
|
//string flowNo = "028";
|
|
|
#endregion 0. 检查完整性.
|
|
|
|
|
|
#region 2. 生成节点.
|
|
|
// Step1: 遍历节点, 并生成节点.
|
|
|
// ccflow 节点是以01开头的
|
|
|
ConcurrentDictionary<string, int> relations = new ConcurrentDictionary<string, int>(); // 保存节点id 对应 关系
|
|
|
ConcurrentDictionary<int, string> nodeUserTaskID = new ConcurrentDictionary<int, string>(); // 保存节点id与userTaskID 对应 关系
|
|
|
ConcurrentBag<Node> flowNodes = new ConcurrentBag<Node>();
|
|
|
CountdownEvent cdEvent = new CountdownEvent(dtNode.Rows.Count);
|
|
|
for (int i = 0; i < dtNode.Rows.Count; i++)
|
|
|
{
|
|
|
int temp = i + 1;
|
|
|
string nodeSuffix = "";
|
|
|
if(temp < 10)
|
|
|
{
|
|
|
nodeSuffix = "0" + temp;
|
|
|
}else
|
|
|
{
|
|
|
nodeSuffix = temp.ToString();
|
|
|
}
|
|
|
DataRow dr = dtNode.Rows[i];
|
|
|
//ThreadPool.QueueUserWorkItem(_ =>
|
|
|
//{
|
|
|
// _semaphore.Wait();
|
|
|
// try
|
|
|
// {
|
|
|
HttpContext.Current = ctx;
|
|
|
#region 获得节点信息.
|
|
|
string userTaskID = dr["id"] as string;
|
|
|
if (i == 0)
|
|
|
nd = new Node(int.Parse(flowNo + "01")); //开始节点.
|
|
|
else
|
|
|
nd = TemplateGlo.NewNode(flowNo, 100, 100);
|
|
|
//nd = new Node(int.Parse(flowNo + nodeSuffix));
|
|
|
// 找到图形信息
|
|
|
int shapeID = -1;
|
|
|
foreach (DataRow row in dtShapes.Rows)
|
|
|
{
|
|
|
string bpmnElement = (string)row["bpmnElement"];
|
|
|
if (bpmnElement == userTaskID)
|
|
|
{
|
|
|
shapeID = (int)row["BPMNShape_Id"];
|
|
|
break;
|
|
|
}
|
|
|
}
|
|
|
if (shapeID == -1)
|
|
|
{
|
|
|
BP.DA.Log.DebugWriteError("解析BPMN出现异常数据, 存在多个节点为[" + userTaskID + "]的数据");
|
|
|
continue;
|
|
|
}
|
|
|
bool hasPostion = false;
|
|
|
// 找到坐标
|
|
|
foreach (DataRow row in dtPositions.Rows)
|
|
|
{
|
|
|
int bpmnShapeId = (int)row["BPMNShape_Id"];
|
|
|
if (bpmnShapeId == shapeID)
|
|
|
{
|
|
|
nd.X = (int)float.Parse(row["x"] as string);
|
|
|
nd.Y = (int)float.Parse(row["y"] as string);
|
|
|
hasPostion = true;
|
|
|
break;
|
|
|
}
|
|
|
}
|
|
|
if (!hasPostion)
|
|
|
{
|
|
|
nd.X = 100;
|
|
|
nd.Y = 100;
|
|
|
}
|
|
|
List<string> lines = new List<string>();
|
|
|
// 找到所有以他为起点的连接线
|
|
|
foreach (DataRow row in dtDirs.Rows)
|
|
|
{
|
|
|
string sourceRef = (string)row["sourceRef"];
|
|
|
if (sourceRef == userTaskID)
|
|
|
{
|
|
|
lines.Add(row["targetRef"] as string);
|
|
|
}
|
|
|
}
|
|
|
nd.Name = dr["name"] as string;
|
|
|
nd.Mark = String.Join(",", lines.ToArray());
|
|
|
nd.Update(); //更新节点信息.
|
|
|
|
|
|
relations.TryAdd(userTaskID, nd.NodeID); // 保存关系
|
|
|
nodeUserTaskID.TryAdd(nd.NodeID, userTaskID); // 保存关系
|
|
|
flowNodes.Add(nd); // 保存节点
|
|
|
#endregion 获得节点信息.
|
|
|
// }
|
|
|
// finally
|
|
|
// {
|
|
|
// cdEvent.Signal();
|
|
|
// _semaphore.Release();
|
|
|
// }
|
|
|
//});
|
|
|
}
|
|
|
//cdEvent.Wait();
|
|
|
#endregion 2. 生成节点.
|
|
|
|
|
|
#region 3. 生成链接线.
|
|
|
// 插入连接线，经过上面的流程后才知道对应关系
|
|
|
foreach(Node node in flowNodes)
|
|
|
{
|
|
|
try
|
|
|
{
|
|
|
string[] toUserTasks = node.Mark.Split(',');
|
|
|
node.Mark = nodeUserTaskID[node.NodeID];
|
|
|
node.Update();
|
|
|
foreach (string toUserTask in toUserTasks)
|
|
|
{
|
|
|
int toNodeId = relations[toUserTask];
|
|
|
//生成方向.
|
|
|
Direction mydir = new Direction();
|
|
|
mydir.FK_Flow = flowNo;
|
|
|
mydir.Node = node.NodeID;
|
|
|
mydir.ToNode = toNodeId;
|
|
|
mydir.Insert(); //自动生成主键.
|
|
|
}
|
|
|
|
|
|
}
|
|
|
catch (Exception ex)
|
|
|
{
|
|
|
BP.DA.Log.DebugWriteError("解析BPMN-创建连接线失败：nodeId=" + node.NodeID + ", Mark = " + node.Mark);
|
|
|
continue;
|
|
|
}
|
|
|
|
|
|
}
|
|
|
// Step2: 遍历节点, 生成连接线.
|
|
|
//Nodes nds = new Nodes();
|
|
|
//nds.RetrieveAll();
|
|
|
//foreach (Node node in nds)
|
|
|
//{
|
|
|
// string userTaskID = node.Mark; //当前节点,
|
|
|
|
|
|
// //获得到达节点的ID.
|
|
|
// string[] toTaskIDs = "ssss".Split();
|
|
|
// foreach (string taskID in toTaskIDs)
|
|
|
// {
|
|
|
// //查询出来，到达的节点ID.
|
|
|
// Node tond = new Node();
|
|
|
// tond.Retrieve(NodeAttr.Mark, taskID);
|
|
|
|
|
|
// //生成方向.
|
|
|
// Direction mydir = new Direction();
|
|
|
// mydir.FK_Flow = flowNo;
|
|
|
// mydir.Node = node.NodeID;
|
|
|
// mydir.ToNode = nd.NodeID;
|
|
|
// mydir.Insert(); //自动生成主键.
|
|
|
// }
|
|
|
|
|
|
// //检查方向条件.
|
|
|
// string[] conds = "ssss".Split();
|
|
|
// foreach (string cond in conds)
|
|
|
// {
|
|
|
// Cond mycond = new Cond();
|
|
|
// }
|
|
|
//}
|
|
|
#endregion 3. 生成链接线.
|
|
|
|
|
|
return fl;
|
|
|
}
|
|
|
|
|
|
/// <summary>
|
|
|
/// 创建一个流程模版
|
|
|
/// </summary>
|
|
|
/// <param name="flowSort">流程类别</param>
|
|
|
/// <param name="flowName">名称</param>
|
|
|
/// <param name="dsm">存储方式</param>
|
|
|
/// <param name="ptable">物理量</param>
|
|
|
/// <param name="flowMark">标记</param>
|
|
|
/// <returns>创建的流程编号</returns>
|
|
|
public static string NewFlowTemplate(string flowSort, string flowName, BP.WF.Template.DataStoreModel dsm,
|
|
|
string ptable, string flowMark)
|
|
|
{
|
|
|
//定义一个变量.
|
|
|
Flow flow = new Flow();
|
|
|
try
|
|
|
{
|
|
|
//检查参数的完整性.
|
|
|
if (DataType.IsNullOrEmpty(ptable) == false && ptable.Length >= 1)
|
|
|
{
|
|
|
string c = ptable.Substring(0, 1);
|
|
|
if (DataType.IsNumStr(c) == true)
|
|
|
throw new Exception("@非法的流程数据表(" + ptable + "),它会导致ccflow不能创建该表.");
|
|
|
}
|
|
|
|
|
|
flow.PTable = ptable;
|
|
|
flow.FK_FlowSort = flowSort;
|
|
|
flow.FlowMark = flowMark;
|
|
|
|
|
|
if (DataType.IsNullOrEmpty(flowMark) == false)
|
|
|
{
|
|
|
if (flow.IsExit(FlowAttr.FlowMark, flowMark))
|
|
|
throw new Exception("@该流程标示:" + flowMark + "已经存在于系统中.");
|
|
|
}
|
|
|
|
|
|
/*给初始值*/
|
|
|
//this.Paras = "@StartNodeX=10@StartNodeY=15@EndNodeX=40@EndNodeY=10";
|
|
|
flow.Paras = "@StartNodeX=200@StartNodeY=50@EndNodeX=200@EndNodeY=350";
|
|
|
|
|
|
flow.No = flow.GenerNewNoByKey(FlowAttr.No);
|
|
|
flow.Name = flowName;
|
|
|
if (string.IsNullOrWhiteSpace(flow.Name))
|
|
|
flow.Name = "新建流程" + flow.No; //新建流程.
|
|
|
|
|
|
//if (flow.IsExits == true)
|
|
|
// throw new Exception("err@系统出现自动生成的流程编号重复.");
|
|
|
|
|
|
if (Glo.CCBPMRunModel != CCBPMRunModel.Single)
|
|
|
flow.OrgNo = WebUser.OrgNo; //隶属组织
|
|
|
|
|
|
flow.PTable = "ND" + int.Parse(flow.No) + "Rpt";
|
|
|
|
|
|
// 设置创建人，创建日期.
|
|
|
flow.SetValByKey(FlowAttr.CreateDate, DataType.CurrentDateTime);
|
|
|
flow.SetValByKey(FlowAttr.Creater, BP.Web.WebUser.No);
|
|
|
flow.SetValByKey("Icon", "icon-people");
|
|
|
|
|
|
//flow.TitleRole
|
|
|
flow.Insert();
|
|
|
|
|
|
////如果是集团模式下.
|
|
|
//if (Glo.CCBPMRunModel == CCBPMRunModel.GroupInc)
|
|
|
//{
|
|
|
// // 记录创建人.
|
|
|
// FlowExt fe = new FlowExt(flow.No);
|
|
|
// fe.DesignerNo = BP.Web.WebUser.No;
|
|
|
// fe.DesignerName = BP.Web.WebUser.Name;
|
|
|
// fe.DesignTime = DataType.CurrentDateTime;
|
|
|
// fe.DirectUpdate();
|
|
|
//}
|
|
|
|
|
|
BP.WF.Node nd = new BP.WF.Node();
|
|
|
nd.NodeID = int.Parse(flow.No + "01");
|
|
|
nd.Name = "Start Node";// "开始节点";
|
|
|
nd.Step = 1;
|
|
|
nd.FK_Flow = flow.No;
|
|
|
nd.FlowName = flow.Name;
|
|
|
nd.HisNodePosType = NodePosType.Start;
|
|
|
nd.HisNodeWorkType = NodeWorkType.StartWork;
|
|
|
nd.X = 200;
|
|
|
nd.Y = 150;
|
|
|
nd.NodePosType = NodePosType.Start;
|
|
|
nd.HisReturnRole = ReturnRole.CanNotReturn; //不能退回. @hongyan.
|
|
|
nd.Icon = "前台";
|
|
|
|
|
|
//增加了两个默认值值 . 2016.11.15. 目的是让创建的节点，就可以使用.
|
|
|
nd.CondModel = DirCondModel.ByDDLSelected; //默认的发送方向.
|
|
|
nd.HisDeliveryWay = DeliveryWay.BySelected; //上一步发送人来选择.
|
|
|
nd.FormType = NodeFormType.FoolForm; //设置为傻瓜表单.
|
|
|
|
|
|
//如果是集团模式.
|
|
|
if (Glo.CCBPMRunModel == CCBPMRunModel.GroupInc)
|
|
|
{
|
|
|
if (DataType.IsNullOrEmpty(WebUser.OrgNo) == true)
|
|
|
throw new Exception("err@登录信息丢失了组织信息,请重新登录.");
|
|
|
|
|
|
nd.HisDeliveryWay = DeliveryWay.BySelectedOrgs;
|
|
|
|
|
|
//把本组织加入进去.
|
|
|
FlowOrg fo = new FlowOrg();
|
|
|
fo.Delete(FlowOrgAttr.FlowNo, nd.FK_Flow);
|
|
|
fo.FlowNo = nd.FK_Flow;
|
|
|
fo.OrgNo = WebUser.OrgNo;
|
|
|
fo.Insert();
|
|
|
}
|
|
|
|
|
|
nd.Insert();
|
|
|
nd.CreateMap();
|
|
|
|
|
|
//为开始节点增加一个删除按钮.
|
|
|
string sql = "UPDATE WF_Node SET DelEnable=1 WHERE NodeID=" + nd.NodeID;
|
|
|
DBAccess.RunSQL(sql);
|
|
|
|
|
|
//nd.HisWork.CheckPhysicsTable(); 去掉，检查的时候会执行.
|
|
|
CreatePushMsg(nd);
|
|
|
|
|
|
//通用的人员选择器.
|
|
|
BP.WF.Template.Selector select = new Selector(nd.NodeID);
|
|
|
select.SelectorModel = SelectorModel.GenerUserSelecter;
|
|
|
select.Update();
|
|
|
|
|
|
nd = new BP.WF.Node();
|
|
|
|
|
|
//为创建节点设置默认值
|
|
|
string fileNewNode = BP.Difference.SystemConfig.PathOfDataUser + "XML/DefaultNewNodeAttr.xml";
|
|
|
if (System.IO.File.Exists(fileNewNode) == true && 1 == 2)
|
|
|
{
|
|
|
DataSet myds = new DataSet();
|
|
|
myds.ReadXml(fileNewNode);
|
|
|
DataTable dt = myds.Tables[0];
|
|
|
foreach (DataColumn dc in dt.Columns)
|
|
|
{
|
|
|
nd.SetValByKey(dc.ColumnName, dt.Rows[0][dc.ColumnName]);
|
|
|
}
|
|
|
}
|
|
|
else
|
|
|
{
|
|
|
nd.HisNodePosType = NodePosType.Mid;
|
|
|
nd.HisNodeWorkType = NodeWorkType.Work;
|
|
|
nd.X = 200;
|
|
|
nd.Y = 250;
|
|
|
nd.Icon = "审核";
|
|
|
nd.NodePosType = NodePosType.End;
|
|
|
|
|
|
//增加了两个默认值值 . 2016.11.15. 目的是让创建的节点，就可以使用.
|
|
|
nd.CondModel = DirCondModel.ByDDLSelected; //默认的发送方向.
|
|
|
nd.HisDeliveryWay = DeliveryWay.BySelected; //上一步发送人来选择.
|
|
|
nd.FormType = NodeFormType.FoolForm; //设置为傻瓜表单.
|
|
|
}
|
|
|
|
|
|
nd.NodeID = int.Parse(flow.No + "02");
|
|
|
nd.Name = "Node 2"; // "结束节点";
|
|
|
nd.Step = 2;
|
|
|
nd.FK_Flow = flow.No;
|
|
|
nd.FlowName = flow.Name;
|
|
|
nd.HisDeliveryWay = DeliveryWay.BySelected; //上一步发送人来选择.
|
|
|
nd.FormType = NodeFormType.FoolForm; //设置为傻瓜表单.
|
|
|
nd.CondModel = DirCondModel.ByDDLSelected;
|
|
|
|
|
|
nd.X = 200;
|
|
|
nd.Y = 250;
|
|
|
|
|
|
//设置审核意见的默认值.
|
|
|
nd.SetValByKey(NodeWorkCheckAttr.FWCDefInfo, BP.WF.Glo.DefVal_WF_Node_FWCDefInfo);
|
|
|
|
|
|
nd.Insert();
|
|
|
nd.CreateMap();
|
|
|
//nd.HisWork.CheckPhysicsTable(); //去掉，检查的时候会执行.
|
|
|
CreatePushMsg(nd);
|
|
|
|
|
|
//通用的人员选择器.
|
|
|
select = new Selector(nd.NodeID);
|
|
|
select.SelectorModel = SelectorModel.GenerUserSelecter;
|
|
|
select.Update();
|
|
|
|
|
|
BP.Sys.MapData md = new BP.Sys.MapData();
|
|
|
md.No = "ND" + int.Parse(flow.No) + "Rpt";
|
|
|
md.Name = flow.Name;
|
|
|
md.Save();
|
|
|
|
|
|
// 装载模版.
|
|
|
string file = BP.Difference.SystemConfig.PathOfDataUser + "XML/TempleteSheetOfStartNode.xml";
|
|
|
if (System.IO.File.Exists(file) == true && 1 == 2)
|
|
|
{
|
|
|
//throw new Exception("@开始节点表单模版丢失" + file);
|
|
|
/*如果存在开始节点表单模版*/
|
|
|
DataSet ds = new DataSet();
|
|
|
ds.ReadXml(file);
|
|
|
|
|
|
string nodeID = "ND" + int.Parse(flow.No + "01");
|
|
|
BP.Sys.MapData.ImpMapData(nodeID, ds);
|
|
|
}
|
|
|
|
|
|
//加载默认字段.
|
|
|
if (1 == 1)
|
|
|
{
|
|
|
string frmID = "ND" + int.Parse(flow.No + "01");
|
|
|
|
|
|
MapAttr attr = new MapAttr();
|
|
|
attr.setMyPK(frmID + "_SQR");
|
|
|
attr.setName("申请人");
|
|
|
attr.setKeyOfEn("SQR");
|
|
|
attr.setDefValReal("@WebUser.Name");
|
|
|
attr.setUIVisible(true);
|
|
|
attr.setUIIsEnable(false);
|
|
|
attr.setFK_MapData(frmID);
|
|
|
attr.ColSpan = 1;
|
|
|
attr.Insert();
|
|
|
|
|
|
attr = new MapAttr();
|
|
|
attr.setMyPK(frmID + "_SQDT");
|
|
|
attr.setName("申请日期");
|
|
|
attr.setKeyOfEn("SQRQ");
|
|
|
attr.setDefValReal("@RDT");
|
|
|
attr.setUIVisible(true);
|
|
|
attr.setUIIsEnable(false);
|
|
|
attr.setFK_MapData(frmID);
|
|
|
attr.MyDataType = DataType.AppDateTime;
|
|
|
attr.ColSpan = 1;
|
|
|
attr.Insert();
|
|
|
|
|
|
attr = new MapAttr();
|
|
|
attr.setMyPK(frmID + "_SQDept");
|
|
|
attr.setName("申请人部门");
|
|
|
attr.setKeyOfEn("SQDept");
|
|
|
attr.setDefValReal("@WebUser.FK_DeptName");
|
|
|
attr.setUIVisible(true);
|
|
|
attr.setUIIsEnable(false);
|
|
|
attr.setFK_MapData(frmID);
|
|
|
attr.ColSpan = 3;
|
|
|
attr.Insert();
|
|
|
}
|
|
|
|
|
|
//创建track.
|
|
|
Track.CreateOrRepairTrackTable(flow.No);
|
|
|
|
|
|
}
|
|
|
catch (Exception ex)
|
|
|
{
|
|
|
///删除垃圾数据.
|
|
|
flow.DoDelete();
|
|
|
//提示错误.
|
|
|
throw new Exception("err@创建流程错误:" + ex.Message);
|
|
|
}
|
|
|
|
|
|
//FlowExt flowExt = new FlowExt(flow.No);
|
|
|
//flowExt.DesignerNo = BP.Web.WebUser.No;
|
|
|
//flowExt.DesignerName = BP.Web.WebUser.Name;
|
|
|
//flowExt.DesignTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");
|
|
|
//flowExt.DirectSave();
|
|
|
|
|
|
//创建连线
|
|
|
Direction drToNode = new Direction();
|
|
|
drToNode.FK_Flow = flow.No;
|
|
|
drToNode.Node = int.Parse(int.Parse(flow.No) + "01");
|
|
|
drToNode.ToNode = int.Parse(int.Parse(flow.No) + "02");
|
|
|
drToNode.Save();
|
|
|
|
|
|
//增加方向.
|
|
|
Node mynd = new Node(drToNode.Node);
|
|
|
mynd.HisToNDs = drToNode.ToNode.ToString();
|
|
|
mynd.Update();
|
|
|
|
|
|
//设置流程的默认值.
|
|
|
foreach (string key in SystemConfig.AppSettings.AllKeys)
|
|
|
{
|
|
|
if (key.Contains("NewFlowDefVal") == false)
|
|
|
continue;
|
|
|
|
|
|
string val = BP.Difference.SystemConfig.AppSettings[key];
|
|
|
//设置值.
|
|
|
flow.SetValByKey(key.Replace("NewFlowDefVal_", ""), val);
|
|
|
}
|
|
|
//执行一次流程检查, 为了节省效率，把检查去掉了.
|
|
|
flow.DoCheck();
|
|
|
|
|
|
//写入日志.
|
|
|
BP.Sys.Base.Glo.WriteUserLog("创建流程：" + flow.Name + " - " + flow.No);
|
|
|
|
|
|
return flow.No;
|
|
|
}
|
|
|
/// <summary>
|
|
|
/// 删除节点.
|
|
|
/// </summary>
|
|
|
/// <param name="nodeid"></param>
|
|
|
public static void DeleteNode(int nodeid)
|
|
|
{
|
|
|
BP.WF.Node nd = new BP.WF.Node(nodeid);
|
|
|
nd.Delete();
|
|
|
}
|
|
|
}
|
|
|
}
|