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 { ///

/// 流程模版的操作 ///

public class TemplateGlo { ///

/// 装载流程模板 ///

/// 流程类别 /// 流程名称 /// 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 NewCond(string flowNo, int x, int y) { 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"); nd.Name = "条件"+ nd.NodeID; nd.FK_Flow = flowNo; nd.HisNodeType = NodeType.RouteNode; //路由节点. nd.Insert(); return nd; } 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(); } } ///

/// 检查当前人员是否有修改该流程模版的权限. ///

/// /// 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; } ///

/// 创建流程. ///

/// /// /// /// 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 relations = new ConcurrentDictionary(); // 保存节点id 对应关系 ConcurrentDictionary nodeUserTaskID = new ConcurrentDictionary(); // 保存节点id与userTaskID 对应关系 ConcurrentBag flowNodes = new ConcurrentBag(); 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 lines = new List(); // 找到所有以他为起点的连接线 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; } ///

/// 创建一个流程模版 ///

/// 流程类别 /// 名称 /// 存储方式 /// 物理量 /// 标记 /// 创建的流程编号 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; } ///

/// 删除节点. ///

/// public static void DeleteNode(int nodeid) { BP.WF.Node nd = new BP.WF.Node(nodeid); nd.Delete(); } } }