|
|
using System;
|
|
|
using BP.En;
|
|
|
using BP.DA;
|
|
|
using System.Collections;
|
|
|
using System.Data;
|
|
|
using BP.Port;
|
|
|
using BP.Web;
|
|
|
using BP.Sys;
|
|
|
using BP.WF.Template;
|
|
|
using BP.WF.Data;
|
|
|
using System.Text;
|
|
|
using BP.Tools;
|
|
|
using BP.WF.Template.SFlow;
|
|
|
using BP.Difference;
|
|
|
using BP.DA;
|
|
|
using System.Runtime.CompilerServices;
|
|
|
using System.Threading;
|
|
|
using Newtonsoft.Json.Linq;
|
|
|
|
|
|
namespace BP.WF
|
|
|
{
|
|
|
/// <summary>
|
|
|
/// WorkNode的附加类: 2020年06月09号
|
|
|
/// 1， 因为worknode的类方法太多，为了能够更好的减轻代码逻辑.
|
|
|
/// 2. 一部分方法要移动到这里来.
|
|
|
/// </summary>
|
|
|
public class WorkNodePlus
|
|
|
{
|
|
|
public static void InitWorkerList_Ext(WorkNode currWN, WorkNode town, DataTable dt, int toNodeId,
|
|
|
DateTime dtOfShould, DateTime dtOfWarning, Int64 nextUsersFID, bool isFenLiuToSubThread, Int64 nextUsersWorkID)
|
|
|
{
|
|
|
/* 如果有多个人员，就要考虑接收人是否记忆属性的问题。 */
|
|
|
RememberMe rm = currWN.GetHisRememberMe(town.HisNode);
|
|
|
|
|
|
#region 是否需要清空记忆属性.
|
|
|
// 如果按照选择的人员处理，就设置它的记忆为空。2011-11-06 处理电厂需求 .
|
|
|
if (rm != null &&(town.HisNode.HisDeliveryWay == DeliveryWay.BySelected|| town.HisNode.ItIsRememberMe == false))
|
|
|
rm.Objs = "";
|
|
|
|
|
|
if (rm != null && currWN.HisNode.ItIsFL)
|
|
|
rm.Objs = "";
|
|
|
|
|
|
if (currWN.ItIsHaveSubThreadGroupMark == false && rm != null && rm.Objs != "")
|
|
|
{
|
|
|
/*检查接收人列表是否发生了变化,如果变化了，就要把有效的接收人清空，让其重新生成.*/
|
|
|
string emps = "@";
|
|
|
foreach (DataRow dr in dt.Rows)
|
|
|
emps += dr[0].ToString() + "@";
|
|
|
|
|
|
if (rm.Emps != emps)
|
|
|
{
|
|
|
// 列表发生了变化.
|
|
|
rm.Emps = emps;
|
|
|
rm.Objs = ""; //清空有效的接收人集合.
|
|
|
}
|
|
|
}
|
|
|
#endregion 是否需要清空记忆属性.
|
|
|
|
|
|
string myemps = "";
|
|
|
Emp emp = new Emp();
|
|
|
int idx = 0;
|
|
|
//INSERT INGORE INTO wf_generworklist (col1,col2) values (), (), ()
|
|
|
string sender = WebUser.No + "," + WebUser.Name;
|
|
|
string sqls = "";
|
|
|
//string sqls = "INSERT IGNORE INTO WF_GenerWorkerlist (WorkID,FK_Emp,FK_Node,Idx,AtPara,IsEnable) VALUES ";
|
|
|
Int64 workID = currWN.WorkID;
|
|
|
GenerWorkerList wl = new GenerWorkerList();
|
|
|
string workids = ",";
|
|
|
foreach (DataRow dr in dt.Rows)
|
|
|
{
|
|
|
string fk_emp = dr[0].ToString();
|
|
|
if (currWN.ItIsHaveSubThreadGroupMark == true)
|
|
|
{
|
|
|
/*如果有分组 Mark ,就不处理重复人员的问题.*/
|
|
|
}
|
|
|
else
|
|
|
{
|
|
|
// 处理人员重复的，不然会导致generworkerlist的pk错误。
|
|
|
if (myemps.IndexOf("@" + fk_emp + ",") != -1)
|
|
|
continue;
|
|
|
myemps += "@" + fk_emp + ",";
|
|
|
}
|
|
|
|
|
|
#region 增加存储的优先级，防止数据库根据FK_Emp的人员编码自动排序，导致查询的结果和接收人的先后顺序不一致
|
|
|
idx++;
|
|
|
wl.Idx = idx;
|
|
|
#endregion
|
|
|
|
|
|
#region 根据记忆是否设置该操作员可用与否。
|
|
|
if (rm != null)
|
|
|
{
|
|
|
if (rm.Objs == "")
|
|
|
{
|
|
|
/*如果是空的.*/
|
|
|
wl.ItIsEnable = true;
|
|
|
}
|
|
|
else
|
|
|
{
|
|
|
if (rm.Objs.Contains("@" + fk_emp + "@") == true)
|
|
|
wl.ItIsEnable = true; /* 如果包含，就说明他已经有了*/
|
|
|
else
|
|
|
wl.ItIsEnable = false;
|
|
|
}
|
|
|
}
|
|
|
else
|
|
|
{
|
|
|
wl.ItIsEnable = false;
|
|
|
}
|
|
|
#endregion 根据记忆是否设置该操作员可用与否。
|
|
|
|
|
|
wl.NodeID = toNodeId;
|
|
|
wl.EmpNo = fk_emp;
|
|
|
wl.FlowNo = town.HisNode.FlowNo;
|
|
|
if (currWN.ItIsHaveSubThreadGroupMark == true)
|
|
|
{
|
|
|
//设置分组信息.
|
|
|
object val = dr[2];
|
|
|
if (val == null)
|
|
|
throw new Exception(BP.WF.Glo.multilingual("@分组标志不能为空。", "WorkNode", "empty_group_tags", new string[0]));
|
|
|
|
|
|
if (DataType.IsNullOrEmpty(val.ToString()) == null)
|
|
|
throw new Exception(BP.WF.Glo.multilingual("@分组标志不能为空。", "WorkNode", "empty_group_tags", new string[0]));
|
|
|
|
|
|
wl.GroupMark = val.ToString();
|
|
|
if (dt.Columns.Count == 4 && town.HisNode.HisFormType == NodeFormType.SheetAutoTree)
|
|
|
{
|
|
|
wl.FrmIDs = dr[3].ToString();
|
|
|
if (DataType.IsNullOrEmpty(dr[3].ToString()))
|
|
|
throw new Exception(BP.WF.Glo.multilingual("@接收人数据源不正确,表单IDs不能为空。", "WorkNode", "invalid_receiver_data_source", new string[0]));
|
|
|
}
|
|
|
}
|
|
|
|
|
|
wl.FID = nextUsersFID;
|
|
|
if (isFenLiuToSubThread)
|
|
|
{
|
|
|
/* 说明这是分流点向下发送
|
|
|
* 在这里产生临时的workid.
|
|
|
*/
|
|
|
wl.WorkID = DBAccess.GenerOIDByGUID();
|
|
|
}
|
|
|
else
|
|
|
{
|
|
|
wl.WorkID = nextUsersWorkID;
|
|
|
}
|
|
|
string IsEnable = "1";
|
|
|
if (wl.ItIsEnable == false)
|
|
|
IsEnable = "0";
|
|
|
// sqls += " (" + wl.WorkID + ", '" + wl.EmpNo + "', " + wl.NodeID + ", " + wl.Idx + ", '"+wl.GetValByKey("AtPara")+"', "+ IsEnable + "),";
|
|
|
sqls += "INSERT INTO WF_GenerWorkerlist (WorkID,FK_Emp,FK_Node,Idx,AtPara,IsEnable,WhoExeIt) VALUES(" + wl.WorkID + ",'" + wl.EmpNo + "'," + wl.NodeID + "," + wl.Idx + ",'"+wl.GetValByKey("AtPara")+"',"+ IsEnable + ","+ town.HisNode.WhoExeIt+") ;";
|
|
|
if(workids.Contains(","+wl.WorkID + ",")==false)
|
|
|
workids += wl.WorkID + ",";
|
|
|
// wl.Insert();
|
|
|
//currWN.HisWorkerLists.AddEntity(wl);
|
|
|
} //结束循环.
|
|
|
|
|
|
#region 执行更新批量 sql.
|
|
|
DBAccess.RunSQL(sqls);
|
|
|
workids = workids.Substring(1);
|
|
|
if(DataType.IsNullOrEmpty(workids)==false)
|
|
|
workids = workids.Substring(0, workids.Length-1);
|
|
|
// 执行更新sql.
|
|
|
string sdt = "无";
|
|
|
if (town.HisNode.HisCHWay != CHWay.None)
|
|
|
sdt =DataType.SysDateTimeFormat(dtOfShould);
|
|
|
|
|
|
//更新基础数据.
|
|
|
string sql = "UPDATE WF_GenerWorkerlist SET Sender='" + sender + "',DTOfWarning='" + DataType.SysDateTimeFormat(dtOfWarning) + "' ";
|
|
|
sql += ",SDT='" + sdt + "'";
|
|
|
sql += ",RDT='" + DataType.CurrentDateTime + "'";
|
|
|
sql += ",FK_Flow='" + currWN.HisFlow.No + "'";
|
|
|
sql += ",FID='" + nextUsersFID + "'";
|
|
|
sql += ",NodeName='" + town.HisNode.Name + "'";
|
|
|
sql += ",IsEnable=1,IsRead=0,IsPass=0 ";
|
|
|
sql += " WHERE WorkID IN("+ workids+") AND FK_Node=" + toNodeId;
|
|
|
DBAccess.RunSQL(sql);
|
|
|
|
|
|
//关联更新人员的名称与部门编号，部门名称。 FK_EmpText,FK_Dept
|
|
|
string updateSQL = "";
|
|
|
switch (SystemConfig.AppCenterDBType)
|
|
|
{
|
|
|
case DBType.MSSQL:
|
|
|
case DBType.PostgreSQL:
|
|
|
case DBType.HGDB:
|
|
|
updateSQL = " UPDATE WF_GenerWorkerlist SET FK_Dept = Port_Emp.FK_Dept,EmpName =Port_Emp.Name FROM Port_Emp ";
|
|
|
updateSQL += " WHERE Port_Emp.No = WF_GenerWorkerlist.FK_Emp AND WorkID IN(" + workids + ") AND FK_Node = " + toNodeId;
|
|
|
break;
|
|
|
case DBType.Oracle:
|
|
|
updateSQL = "UPDATE WF_GenerWorkerlist E SET (FK_Dept,EmpName)=(SELECT U.FK_Dept,U.Name FROM Port_Emp U WHERE E.FK_Emp=U.No AND WorkID IN(" + workids + ") AND FK_Node =" + toNodeId+ ") WHERE WorkID IN(" + workids + ") AND FK_Node =" + toNodeId;
|
|
|
break;
|
|
|
default:
|
|
|
updateSQL = "UPDATE WF_GenerWorkerlist gl LEFT join Port_Emp emp on gl.FK_Emp = emp.No set gl.FK_Dept = emp.FK_Dept, gl.EmpName = emp.Name WHERE WorkID IN(" + workids + ") AND FK_Node = " + toNodeId;
|
|
|
break;
|
|
|
}
|
|
|
DBAccess.RunSQL(updateSQL);
|
|
|
|
|
|
//// 可以不删除.
|
|
|
string deleteSQL = "DELETE FROM WF_GenerWorkerlist WHERE FK_Emp IS NULL OR FK_Emp=''";
|
|
|
DBAccess.RunSQL(deleteSQL);
|
|
|
|
|
|
//查询出数据.
|
|
|
GenerWorkerLists gwls = new GenerWorkerLists();
|
|
|
QueryObject qo = new QueryObject(gwls);
|
|
|
qo.AddWhereIn("WorkID", "("+workids+")");
|
|
|
qo.addAnd();
|
|
|
qo.AddWhere("FK_Node", toNodeId);
|
|
|
qo.DoQuery();
|
|
|
|
|
|
currWN.HisWorkerLists = gwls;
|
|
|
#endregion 执行更新sql.
|
|
|
|
|
|
#region 执行对rm的更新。
|
|
|
if (rm != null)
|
|
|
{
|
|
|
string empExts = "";
|
|
|
string objs = "@"; // 有效的工作人员.
|
|
|
string objsExt = "@"; // 有效的工作人员.
|
|
|
foreach (GenerWorkerList mywl in currWN.HisWorkerLists)
|
|
|
{
|
|
|
if (mywl.ItIsEnable == false)
|
|
|
empExts += "<strike><font color=red>" + BP.WF.Glo.DealUserInfoShowModel(mywl.EmpNo, mywl.EmpName) + "</font></strike>、";
|
|
|
else
|
|
|
empExts += BP.WF.Glo.DealUserInfoShowModel(mywl.EmpNo, mywl.EmpName);
|
|
|
|
|
|
if (mywl.ItIsEnable == true)
|
|
|
{
|
|
|
objs += mywl.EmpNo + "@";
|
|
|
objsExt += BP.WF.Glo.DealUserInfoShowModel(mywl.EmpNo, mywl.EmpName);
|
|
|
}
|
|
|
}
|
|
|
rm.EmpsExt = empExts;
|
|
|
|
|
|
rm.Objs = objs;
|
|
|
rm.ObjsExt = objsExt;
|
|
|
currWN.HisRememberMe = rm;
|
|
|
}
|
|
|
#endregion 执行对rm的更新。
|
|
|
|
|
|
}
|
|
|
/// <summary>
|
|
|
/// 处理数据源.
|
|
|
/// </summary>
|
|
|
/// <param name="fl"></param>
|
|
|
/// <param name="nd"></param>
|
|
|
/// <param name="track"></param>
|
|
|
public static void AddNodeFrmTrackDB(Flow fl, Node nd, Track track, Work wk)
|
|
|
{
|
|
|
//流程是否启用了版本控制
|
|
|
if (fl.GetValBooleanByKey("IsEnableDBVer") == false)
|
|
|
return;
|
|
|
Paras ps = new Paras();
|
|
|
string dbstr = SystemConfig.AppCenterDBVarStr;
|
|
|
int ver = 1;
|
|
|
//如果是单个表单.
|
|
|
if (nd.HisFormType == NodeFormType.Develop
|
|
|
|| nd.HisFormType == NodeFormType.FoolTruck
|
|
|
|| nd.HisFormType == NodeFormType.ChapterFrm
|
|
|
|| nd.HisFormType == NodeFormType.FoolForm)
|
|
|
{
|
|
|
//接点表单保存NDXXRpt
|
|
|
string frmID = "ND" + Int32.Parse(fl.No) + "Rpt";
|
|
|
string dtlJson = AddNodeFrmDtlDB(nd.NodeID, track.WorkID, nd.NodeFrmID);
|
|
|
string athJson = AddNodeFrmAthDB(nd.NodeID, track.WorkID, nd.NodeFrmID);
|
|
|
//获取版本号
|
|
|
ps.SQL = "SELECT MAX(Ver) From Sys_FrmDBVer WHERE FrmID=" + dbstr + "FrmID AND RefPKVal=" + dbstr + "RefPKVal";
|
|
|
ps.Add("FrmID", frmID);
|
|
|
ps.Add("RefPKVal", track.WorkID);
|
|
|
ver = DBAccess.RunSQLReturnValInt(ps, 0);
|
|
|
ver = ver == 0 ? 1 : ver + 1;
|
|
|
BP.Sys.FrmDBVer.AddFrmDBTrack(ver, frmID, track.WorkID.ToString(), track.MyPK, wk.ToJson(), dtlJson, athJson, false);
|
|
|
return;
|
|
|
}
|
|
|
|
|
|
if (nd.HisFormType == NodeFormType.RefOneFrmTree)
|
|
|
{
|
|
|
FrmNode fn = new FrmNode(nd.NodeID, nd.NodeFrmID);
|
|
|
if (fn.FrmSln == FrmSln.Readonly)
|
|
|
return;
|
|
|
MapData md = nd.MapData;
|
|
|
//获取版本号
|
|
|
ps.SQL = "SELECT MAX(Ver) From Sys_FrmDBVer WHERE FrmID=" + dbstr + "FrmID AND RefPKVal=" + dbstr + "RefPKVal";
|
|
|
ps.Add("FrmID", md.No);
|
|
|
ps.Add("RefPKVal", track.WorkID);
|
|
|
ver = DBAccess.RunSQLReturnValInt(ps, 0);
|
|
|
ver = ver == 0 ? 1 : ver + 1;
|
|
|
|
|
|
if (md.HisFrmType == FrmType.ChapterFrm)
|
|
|
{
|
|
|
//获取字段
|
|
|
MapAttrs attrs = md.MapAttrs;
|
|
|
foreach (MapAttr attr in attrs)
|
|
|
{
|
|
|
if (attr.UIVisible == false)
|
|
|
continue;
|
|
|
BP.Sys.FrmDBVer.AddKeyOfEnDBTrack(ver, nd.NodeFrmID, track.WorkID.ToString(), track.MyPK, wk.GetValStringByKey(attr.KeyOfEn), attr.KeyOfEn);
|
|
|
}
|
|
|
string json = AddNodeFrmDtlDB(nd.NodeID, track.WorkID, nd.NodeFrmID);
|
|
|
string aths = AddNodeFrmAthDB(nd.NodeID, track.WorkID, nd.NodeFrmID);
|
|
|
BP.Sys.FrmDBVer.AddFrmDBTrack(ver, nd.NodeFrmID, track.WorkID.ToString(), track.MyPK, null, json, aths, true);
|
|
|
|
|
|
//获取控件类型是ChapterFrmLinkFrm的分组
|
|
|
GroupFields groups = new GroupFields();
|
|
|
groups.Retrieve(GroupFieldAttr.FrmID, md.No, GroupFieldAttr.CtrlType, "ChapterFrmLinkFrm");
|
|
|
foreach (GroupField group in groups)
|
|
|
{
|
|
|
//获取表单数据
|
|
|
GEEntity en = new GEEntity(group.CtrlID, track.WorkID);
|
|
|
json = AddNodeFrmDtlDB(nd.NodeID, track.WorkID, group.CtrlID);
|
|
|
aths = AddNodeFrmAthDB(nd.NodeID, track.WorkID, group.CtrlID);
|
|
|
if (en.Row.ContainsKey("RDT"))
|
|
|
en.SetValByKey("RDT", "");
|
|
|
BP.Sys.FrmDBVer.AddFrmDBTrack(ver, group.CtrlID, track.WorkID.ToString(), track.MyPK, en.ToJson(), json, aths, false);
|
|
|
}
|
|
|
|
|
|
return;
|
|
|
}
|
|
|
string dtlJson = AddNodeFrmDtlDB(nd.NodeID, track.WorkID, nd.NodeFrmID);
|
|
|
string athJson = AddNodeFrmAthDB(nd.NodeID, track.WorkID, nd.NodeFrmID);
|
|
|
BP.Sys.FrmDBVer.AddFrmDBTrack(ver, nd.NodeFrmID, track.WorkID.ToString(), track.MyPK, wk.ToJson(), dtlJson, athJson, false);
|
|
|
return;
|
|
|
}
|
|
|
|
|
|
//如果是多个表单.
|
|
|
if (nd.HisFormType == NodeFormType.SheetTree)
|
|
|
{
|
|
|
FrmNodes fns = new FrmNodes(fl.No, nd.NodeID);
|
|
|
|
|
|
foreach (FrmNode fn in fns)
|
|
|
{
|
|
|
if (fn.FrmSln == FrmSln.Readonly)
|
|
|
continue;
|
|
|
|
|
|
//如果是禁用的.
|
|
|
if (fn.FrmEnableRole == FrmEnableRole.Disable)
|
|
|
continue;
|
|
|
|
|
|
//如果是由参数启用的.
|
|
|
if (fn.FrmEnableRole == FrmEnableRole.WhenHaveFrmPara)
|
|
|
continue;
|
|
|
|
|
|
BP.Sys.GEEntity ge = new GEEntity(fn.FK_Frm);
|
|
|
ge.OID = track.WorkID;
|
|
|
if (ge.RetrieveFromDBSources() == 0)
|
|
|
continue;
|
|
|
//获取版本号
|
|
|
ps = new Paras();
|
|
|
ps.SQL = "SELECT MAX(Ver) From Sys_FrmDBVer WHERE FrmID=" + dbstr + "FrmID AND RefPKVal=" + dbstr + "RefPKVal";
|
|
|
ps.Add("FrmID", fn.FK_Frm);
|
|
|
ps.Add("RefPKVal", track.WorkID);
|
|
|
ver = DBAccess.RunSQLReturnValInt(ps, 0);
|
|
|
ver = ver == 0 ? 1 : ver + 1;
|
|
|
|
|
|
MapData md = new MapData(fn.FK_Frm);
|
|
|
if (md.HisFrmType == FrmType.ChapterFrm)
|
|
|
{
|
|
|
//获取字段
|
|
|
MapAttrs attrs = md.MapAttrs;
|
|
|
foreach (MapAttr attr in attrs)
|
|
|
{
|
|
|
if (attr.UIVisible == false)
|
|
|
continue;
|
|
|
BP.Sys.FrmDBVer.AddKeyOfEnDBTrack(ver, fn.FK_Frm, track.WorkID.ToString(), track.MyPK, ge.GetValStringByKey(attr.KeyOfEn), attr.KeyOfEn);
|
|
|
}
|
|
|
string json = AddNodeFrmDtlDB(nd.NodeID, track.WorkID, fn.FK_Frm);
|
|
|
string aths = AddNodeFrmAthDB(nd.NodeID, track.WorkID, fn.FK_Frm);
|
|
|
BP.Sys.FrmDBVer.AddFrmDBTrack(ver, fn.FK_Frm, track.WorkID.ToString(), track.MyPK, null, json, aths, true);
|
|
|
|
|
|
//获取控件类型是ChapterFrmLinkFrm的分组
|
|
|
GroupFields groups = new GroupFields();
|
|
|
groups.Retrieve(GroupFieldAttr.FrmID, md.No, GroupFieldAttr.CtrlType, "ChapterFrmLinkFrm");
|
|
|
foreach (GroupField group in groups)
|
|
|
{
|
|
|
//获取表单数据
|
|
|
GEEntity en = new GEEntity(group.CtrlID, track.WorkID);
|
|
|
json = AddNodeFrmDtlDB(nd.NodeID, track.WorkID, group.CtrlID);
|
|
|
aths = AddNodeFrmAthDB(nd.NodeID, track.WorkID, group.CtrlID);
|
|
|
if (en.Row.ContainsKey("RDT"))
|
|
|
en.SetValByKey("RDT", "");
|
|
|
BP.Sys.FrmDBVer.AddFrmDBTrack(ver, group.CtrlID, track.WorkID.ToString(), track.MyPK, en.ToJson(), json, aths, false);
|
|
|
}
|
|
|
|
|
|
return;
|
|
|
}
|
|
|
|
|
|
string dtlJson = AddNodeFrmDtlDB(nd.NodeID, track.WorkID, fn.FK_Frm);
|
|
|
string athJson = AddNodeFrmAthDB(nd.NodeID, track.WorkID, fn.FK_Frm);
|
|
|
BP.Sys.FrmDBVer.AddFrmDBTrack(ver, fn.FK_Frm, track.WorkID.ToString(), track.MyPK, ge.ToJson(), dtlJson, athJson, false);
|
|
|
}
|
|
|
return;
|
|
|
}
|
|
|
|
|
|
//if (fl.HisNodes)
|
|
|
// FrmDBVer.AddFrmDBTrack()
|
|
|
|
|
|
}
|
|
|
/// <summary>
|
|
|
/// 获取表单从表的数据集合
|
|
|
/// </summary>
|
|
|
/// <param name="nodeId"></param>
|
|
|
/// <param name="workID"></param>
|
|
|
/// <param name="frmID"></param>
|
|
|
/// <returns></returns>
|
|
|
public static string AddNodeFrmDtlDB(int nodeId, Int64 workID, string frmID)
|
|
|
{
|
|
|
MapData mapData = new MapData(frmID);
|
|
|
GenerWorkFlow gwf = new GenerWorkFlow(workID);
|
|
|
MapDtls dtls = new MapDtls();
|
|
|
dtls.Retrieve("FK_MapData", frmID, "FK_Node", 0);
|
|
|
DataSet ds = new DataSet();
|
|
|
DataTable dt = null;
|
|
|
foreach (MapDtl dtl in dtls)
|
|
|
{
|
|
|
string dtlRefPKVal = BP.WF.Dev2Interface.GetDtlRefPKVal(gwf.WorkID, gwf.PWorkID, gwf.FID, nodeId, dtl.FrmID, dtl);
|
|
|
dt = CCFormAPI.GetDtlInfo(dtl, null, dtlRefPKVal);
|
|
|
dt.TableName = dtl.PTable;
|
|
|
ds.Tables.Add(dt);
|
|
|
}
|
|
|
return BP.Tools.Json.ToJson(ds);
|
|
|
}
|
|
|
/// <summary>
|
|
|
/// 获取表单附件的数据集合
|
|
|
/// </summary>
|
|
|
/// <param name="nodeId"></param>
|
|
|
/// <param name="workID"></param>
|
|
|
/// <param name="frmID"></param>
|
|
|
/// <returns></returns>
|
|
|
public static string AddNodeFrmAthDB(int nodeId, Int64 workID, string frmID)
|
|
|
{
|
|
|
MapData mapData = new MapData(frmID);
|
|
|
GenerWorkFlow gwf = new GenerWorkFlow(workID);
|
|
|
FrmAttachments aths = new FrmAttachments();
|
|
|
aths.Retrieve("FK_MapData", frmID, "FK_Node", 0);
|
|
|
DataSet ds = new DataSet();
|
|
|
FrmAttachmentDBs dbs = null;
|
|
|
foreach (FrmAttachment ath in aths)
|
|
|
{
|
|
|
dbs = BP.WF.CCFormAPI.GenerFrmAttachmentDBs(ath, gwf.WorkID.ToString(),
|
|
|
ath.MyPK, gwf.WorkID, gwf.FID, gwf.PWorkID, true, nodeId, frmID);
|
|
|
|
|
|
ds.Tables.Add(dbs.ToDataTableField(ath.NoOfObj));
|
|
|
}
|
|
|
return BP.Tools.Json.ToJson(ds);
|
|
|
}
|
|
|
|
|
|
/// <summary>
|
|
|
/// 发送草稿实例 2020.10.27 fro 铁路局.
|
|
|
/// </summary>
|
|
|
public static void SendDraftSubFlow(WorkNode wn)
|
|
|
{
|
|
|
//如果不允许发送草稿子流程.
|
|
|
if (wn.HisNode.ItIsSendDraftSubFlow == false)
|
|
|
return;
|
|
|
|
|
|
//查询出来该流程实例下的所有草稿子流程.
|
|
|
GenerWorkFlows gwfs = new GenerWorkFlows();
|
|
|
gwfs.Retrieve(GenerWorkFlowAttr.PWorkID, wn.WorkID, GenerWorkFlowAttr.WFState, 1);
|
|
|
|
|
|
//子流程配置信息.
|
|
|
SubFlowHandGuide sf = null;
|
|
|
|
|
|
//开始发送子流程.
|
|
|
foreach (GenerWorkFlow gwfSubFlow in gwfs)
|
|
|
{
|
|
|
//获得配置信息.
|
|
|
if (sf == null || sf.FlowNo != gwfSubFlow.FlowNo)
|
|
|
{
|
|
|
string pkval = wn.HisGenerWorkFlow.FlowNo + "_" + gwfSubFlow.FlowNo + "_0";
|
|
|
sf = new SubFlowHandGuide();
|
|
|
sf.setMyPK(pkval);
|
|
|
sf.RetrieveFromDBSources();
|
|
|
}
|
|
|
|
|
|
//把草稿移交给当前人员. - 更新控制表.
|
|
|
gwfSubFlow.Starter = WebUser.No;
|
|
|
gwfSubFlow.StarterName = WebUser.Name;
|
|
|
gwfSubFlow.Update();
|
|
|
//把草稿移交给当前人员. - 更新工作人员列表.
|
|
|
DBAccess.RunSQL("UPDATE WF_GenerWorkerlist SET FK_Emp='" + WebUser.No + "',EmpName='" + BP.Web.WebUser.Name + "' WHERE WorkID=" + gwfSubFlow.WorkID);
|
|
|
//更新track表.
|
|
|
//DBAccess.RunSQL("UPDATE ND"+int.Parse(gwfSubFlow.FK_Flow) +"Track SET FK_Emp='" + WebUser.No + "',FK_EmpText='" + WebUser.Name + "' WHERE WorkID=" + gwfSubFlow.WorkID);
|
|
|
|
|
|
//启动子流程. 并把两个字段，写入子流程.
|
|
|
BP.WF.Dev2Interface.Node_SendWork(gwfSubFlow.FlowNo, gwfSubFlow.WorkID, null, null);
|
|
|
}
|
|
|
}
|
|
|
/// <summary>
|
|
|
/// 当要发送是检查流程是否可以允许发起.
|
|
|
/// </summary>
|
|
|
/// <param name="flow">流程</param>
|
|
|
/// <param name="wk">开始节点工作</param>
|
|
|
/// <returns></returns>
|
|
|
public static bool CheckIsCanStartFlow_SendStartFlow(Flow flow, Work wk)
|
|
|
{
|
|
|
StartLimitRole role = flow.StartLimitRole;
|
|
|
if (role == StartLimitRole.None)
|
|
|
return true;
|
|
|
|
|
|
string sql = "";
|
|
|
string ptable = flow.PTable;
|
|
|
|
|
|
if (role == StartLimitRole.ColNotExit)
|
|
|
{
|
|
|
/* 指定的列名集合不存在，才可以发起流程。*/
|
|
|
if (DataType.IsNullOrEmpty(flow.StartLimitPara) == true)
|
|
|
throw new Exception("err@流程发起限制规则出现错误,StartLimitRole.ColNotExit , 没有配置参数. ");
|
|
|
|
|
|
//求出原来的值.
|
|
|
string[] strs = flow.StartLimitPara.Split(',');
|
|
|
string val = "";
|
|
|
int paraLength = 0;
|
|
|
foreach (string str in strs)
|
|
|
{
|
|
|
if (string.IsNullOrEmpty(str) == true)
|
|
|
continue;
|
|
|
try
|
|
|
{
|
|
|
val += wk.GetValStringByKey(str);
|
|
|
paraLength++;
|
|
|
}
|
|
|
catch (Exception ex)
|
|
|
{
|
|
|
throw new Exception("@流程设计错误,您配置的检查参数(" + flow.StartLimitPara + "),中的列(" + str + ")已经不存在表单里.");
|
|
|
}
|
|
|
}
|
|
|
|
|
|
|
|
|
//找出已经发起的全部流程.
|
|
|
sql = "SELECT " + flow.StartLimitPara + " FROM " + ptable + " WHERE WFState NOT IN(0,1) AND FlowStarter='" + WebUser.No + "'";
|
|
|
DataTable dt = DBAccess.RunSQLReturnTable(sql);
|
|
|
foreach (DataRow dr in dt.Rows)
|
|
|
{
|
|
|
string v = "";
|
|
|
for (int i = 0; i < paraLength; i++)
|
|
|
v += dr[i];
|
|
|
if (v.Equals(val))
|
|
|
return false;
|
|
|
}
|
|
|
return true;
|
|
|
}
|
|
|
|
|
|
// 配置的sql,执行后,返回结果是 0 .
|
|
|
if (role == StartLimitRole.ResultIsZero)
|
|
|
{
|
|
|
sql = BP.WF.Glo.DealExp(flow.StartLimitPara, wk, null);
|
|
|
if (DBAccess.RunSQLReturnValInt(sql, 0) == 0)
|
|
|
return true;
|
|
|
else
|
|
|
return false;
|
|
|
}
|
|
|
|
|
|
// 配置的sql,执行后,返回结果是 <> 0 .
|
|
|
if (role == StartLimitRole.ResultIsNotZero)
|
|
|
{
|
|
|
sql = BP.WF.Glo.DealExp(flow.StartLimitPara, wk, null);
|
|
|
if (DBAccess.RunSQLReturnValInt(sql, 0) != 0)
|
|
|
return true;
|
|
|
else
|
|
|
return false;
|
|
|
}
|
|
|
|
|
|
//为子流程的时候，该子流程只能被调用一次.
|
|
|
if (role == StartLimitRole.OnlyOneSubFlow)
|
|
|
{
|
|
|
sql = "SELECT PWorkID FROM WF_GenerWorkFlow WHERE WorkID=" + wk.OID;
|
|
|
string pWorkidStr = DBAccess.RunSQLReturnStringIsNull(sql, "0");
|
|
|
if (pWorkidStr == "0")
|
|
|
return true;
|
|
|
|
|
|
sql = "SELECT Starter, RDT FROM WF_GenerWorkFlow WHERE PWorkID=" + pWorkidStr + " AND FK_Flow='" + flow.No + "'";
|
|
|
DataTable dt = DBAccess.RunSQLReturnTable(sql);
|
|
|
if (dt.Rows.Count == 0 || dt.Rows.Count == 1)
|
|
|
return true;
|
|
|
|
|
|
string starter = dt.Rows[0]["Starter"].ToString();
|
|
|
string rdt = dt.Rows[0]["RDT"].ToString();
|
|
|
|
|
|
throw new Exception(flow.StartLimitAlert + "@该子流程已经被[" + starter + "], 在[" + rdt + "]发起，系统只允许发起一次。");
|
|
|
}
|
|
|
|
|
|
return true;
|
|
|
}
|
|
|
/// <summary>
|
|
|
/// 开始执行数据同步,在流程运动的过程中，
|
|
|
/// 数据需要同步到不同的表里去.
|
|
|
/// </summary>
|
|
|
/// <param name="fl">流程</param>
|
|
|
/// <param name="gwf">实体</param>
|
|
|
/// <param name="rpt">实体</param>
|
|
|
public static void DTSData(Flow fl, GenerWorkFlow gwf, GERpt rpt, Node currNode, bool isStopFlow)
|
|
|
{
|
|
|
//判断同步类型.
|
|
|
if (fl.DTSWay == DataDTSWay.None)
|
|
|
return;
|
|
|
|
|
|
bool isActiveSave = false;
|
|
|
// 判断是否符合流程数据同步条件.
|
|
|
switch (fl.DTSTime)
|
|
|
{
|
|
|
case FlowDTSTime.AllNodeSend://所有节点发送后
|
|
|
isActiveSave = true;
|
|
|
break;
|
|
|
case FlowDTSTime.SpecNodeSend://指定节点发送后
|
|
|
if (fl.DTSSpecNodes.Contains(currNode.NodeID.ToString()) == true)
|
|
|
isActiveSave = true;
|
|
|
break;
|
|
|
case FlowDTSTime.WhenFlowOver://流程结束时
|
|
|
if (isStopFlow)
|
|
|
isActiveSave = true;
|
|
|
break;
|
|
|
default:
|
|
|
break;
|
|
|
}
|
|
|
if (isActiveSave == false)
|
|
|
return;
|
|
|
|
|
|
#region zqp, 编写同步的业务逻辑,执行错误就抛出异常.
|
|
|
if (fl.DTSWay == DataDTSWay.Syn)
|
|
|
{
|
|
|
//获取同步字段
|
|
|
string[] dtsArray = fl.DTSFields.Split('@');
|
|
|
//本系统字段
|
|
|
string lcAttrs = "";
|
|
|
//业务系统字段
|
|
|
string ywAttrs = "";
|
|
|
|
|
|
for (int i = 0; i < dtsArray.Length; i++)
|
|
|
{
|
|
|
//获取本系统字段
|
|
|
lcAttrs += dtsArray[i].Split('=')[0] + ",";
|
|
|
//获取业务系统字段
|
|
|
ywAttrs += dtsArray[i].Split('=')[1] + ",";
|
|
|
}
|
|
|
|
|
|
string[] lcArr = lcAttrs.TrimEnd(',').Split(',');//取出对应的主表字段
|
|
|
string[] ywArr = ywAttrs.TrimEnd(',').Split(',');//取出对应的业务表字段
|
|
|
|
|
|
//判断本系统表是否存在
|
|
|
string sql = "SELECT " + lcAttrs.TrimEnd(',') + " FROM " + fl.PTable.ToUpper() + " WHERE OID=" + rpt.OID;
|
|
|
DataTable lcDt = DBAccess.RunSQLReturnTable(sql);
|
|
|
if (lcDt.Rows.Count == 0)
|
|
|
throw new Exception("没有找到业务表数据.");
|
|
|
|
|
|
//获取配置的，要同步的业务表
|
|
|
BP.Sys.SFDBSrc src = new BP.Sys.SFDBSrc(fl.DTSDBSrc);
|
|
|
sql = "SELECT " + ywAttrs.TrimEnd(',') + " FROM " + fl.DTSBTable.ToUpper();
|
|
|
//获取业务表，是否有数据
|
|
|
DataTable ywDt = src.RunSQLReturnTable(sql);
|
|
|
|
|
|
//插入字段字符串
|
|
|
string values = "";
|
|
|
//更新字段字符串
|
|
|
string upVal = "";
|
|
|
|
|
|
//循环本系统表，组织同步语句
|
|
|
for (int i = 0; i < lcArr.Length; i++)
|
|
|
{
|
|
|
//系统类别
|
|
|
switch (src.DBSrcType)
|
|
|
{
|
|
|
case Sys.DBSrcType.local:
|
|
|
switch (BP.Difference.SystemConfig.AppCenterDBType)
|
|
|
{
|
|
|
case DBType.MSSQL:
|
|
|
break;
|
|
|
case DBType.Oracle:
|
|
|
case DBType.KingBaseR3:
|
|
|
case DBType.KingBaseR6:
|
|
|
//如果是时间类型，要进行转换
|
|
|
if (ywDt.Columns[ywArr[i]].DataType == typeof(DateTime))
|
|
|
{
|
|
|
if (!DataType.IsNullOrEmpty(lcDt.Rows[0][lcArr[i].ToString()].ToString()) && lcDt.Rows[0][lcArr[i].ToString()] != "@RDT")
|
|
|
values += "to_date('" + lcDt.Rows[0][lcArr[i].ToString()] + "','YYYY-MM-DD'),";
|
|
|
else
|
|
|
values += "'',";
|
|
|
continue;
|
|
|
}
|
|
|
values += "'" + lcDt.Rows[0][lcArr[i].ToString()] + "',";
|
|
|
upVal += upVal + ywArr[i] + "='" + lcDt.Rows[0][lcArr[i].ToString()] + "',";
|
|
|
break;
|
|
|
case DBType.MySQL:
|
|
|
break;
|
|
|
case DBType.Informix:
|
|
|
break;
|
|
|
default:
|
|
|
throw new Exception("没有涉及到的连接测试类型...");
|
|
|
}
|
|
|
break;
|
|
|
case Sys.DBSrcType.MSSQL:
|
|
|
break;
|
|
|
case Sys.DBSrcType.MySQL:
|
|
|
break;
|
|
|
case Sys.DBSrcType.Oracle:
|
|
|
case Sys.DBSrcType.KingBaseR3:
|
|
|
case Sys.DBSrcType.KingBaseR6:
|
|
|
//如果是时间类型，要进行转换
|
|
|
if (ywDt.Columns[ywArr[i]].DataType == typeof(DateTime))
|
|
|
{
|
|
|
if (!DataType.IsNullOrEmpty(lcDt.Rows[0][lcArr[i].ToString()].ToString()) && lcDt.Rows[0][lcArr[i].ToString()] != "@RDT")
|
|
|
values += "to_date('" + lcDt.Rows[0][lcArr[i].ToString()] + "','YYYY-MM-DD'),";
|
|
|
else
|
|
|
values += "'',";
|
|
|
continue;
|
|
|
}
|
|
|
values += "'" + lcDt.Rows[0][lcArr[i].ToString()] + "',";
|
|
|
upVal += upVal + ywArr[i] + "='" + lcDt.Rows[0][lcArr[i].ToString()] + "',";
|
|
|
continue;
|
|
|
default:
|
|
|
throw new Exception("暂时不支您所使用的数据库类型!");
|
|
|
}
|
|
|
values += "'" + lcDt.Rows[0][lcArr[i].ToString()] + "',";
|
|
|
|
|
|
}
|
|
|
|
|
|
values = values.Substring(0, values.Length - 1);
|
|
|
upVal = upVal.Substring(0, upVal.Length - 1);
|
|
|
|
|
|
//查询对应的业务表中是否存在这条记录
|
|
|
sql = "SELECT * FROM " + fl.DTSBTable.ToUpper() + " WHERE " + fl.DTSBTablePK + "='" + lcDt.Rows[0][fl.DTSBTablePK] + "'";
|
|
|
DataTable dt = src.RunSQLReturnTable(sql);
|
|
|
//如果存在，执行更新，如果不存在，执行插入
|
|
|
if (dt.Rows.Count > 0)
|
|
|
sql = "UPDATE " + fl.DTSBTable.ToUpper() + " SET " + upVal + " WHERE " + fl.DTSBTablePK + "='" + lcDt.Rows[0][fl.DTSBTablePK] + "'";
|
|
|
else
|
|
|
sql = "INSERT INTO " + fl.DTSBTable.ToUpper() + "(" + ywAttrs.TrimEnd(',') + ") VALUES(" + values + ")";
|
|
|
|
|
|
try
|
|
|
{
|
|
|
src.RunSQL(sql);
|
|
|
}
|
|
|
catch (Exception ex)
|
|
|
{
|
|
|
throw new Exception(ex.Message);
|
|
|
}
|
|
|
}
|
|
|
if (fl.DTSWay == DataDTSWay.WebAPI)
|
|
|
{
|
|
|
//推送的数据
|
|
|
string info = "{";
|
|
|
//推送的主表数据
|
|
|
string mainTable = "";
|
|
|
mainTable += "\"mainTable\":";
|
|
|
mainTable += "{";
|
|
|
MapAttrs mattrs = new MapAttrs(currNode.NodeFrmID);
|
|
|
foreach (MapAttr attr in mattrs)
|
|
|
{
|
|
|
if (attr.KeyOfEn.Equals("Title") || attr.KeyOfEn.Equals("BillNo"))
|
|
|
continue;
|
|
|
if (attr.KeyOfEn.Equals("AtPara") || attr.KeyOfEn.Equals("BillState"))
|
|
|
continue;
|
|
|
if (attr.KeyOfEn.Equals("RDT") || attr.KeyOfEn.Equals("OrgNo"))
|
|
|
continue;
|
|
|
if (attr.KeyOfEn.Equals("FK_Dept") || attr.KeyOfEn.Equals("FID"))
|
|
|
continue;
|
|
|
if (attr.KeyOfEn.Equals("Starter") || attr.KeyOfEn.Equals("StarterName"))
|
|
|
continue;
|
|
|
if (attr.KeyOfEn.Equals("OID") || attr.KeyOfEn.Equals("Rec"))
|
|
|
continue;
|
|
|
mainTable += "\"" + attr.KeyOfEn + "\":\"" + rpt.GetValStrByKey(attr.KeyOfEn) + "\",";
|
|
|
}
|
|
|
mainTable += "\"oid\":\"" + gwf.WorkID + "\"";
|
|
|
mainTable += "}";
|
|
|
|
|
|
//推送的从表数据
|
|
|
string dtls = "[";
|
|
|
string dtlData = "";
|
|
|
|
|
|
MapDtls mapDtls = new MapDtls();
|
|
|
mapDtls.Retrieve(MapDtlAttr.FK_MapData, currNode.NodeFrmID);
|
|
|
foreach (MapDtl dtl in mapDtls)
|
|
|
{
|
|
|
dtlData += "{";
|
|
|
dtlData += "\"dtlNo\":\"" + dtl.No + "\",";
|
|
|
//多个从表的数据
|
|
|
string dtlList = "[";
|
|
|
//每一行数据
|
|
|
string dtlOne = "";
|
|
|
//每一行的字段数据
|
|
|
string dtlKeys = "";
|
|
|
//从表附件
|
|
|
string dtlAths = "[";
|
|
|
string dtlAth = "";
|
|
|
|
|
|
MapAttrs dtlAttrs = new MapAttrs(dtl.No);
|
|
|
GEDtls geDtls = new GEDtls(dtl.No);
|
|
|
geDtls.Retrieve(GEDtlAttr.RefPK, gwf.WorkID);
|
|
|
foreach (GEDtl geDtl in geDtls)
|
|
|
{
|
|
|
dtlKeys = "{";
|
|
|
foreach (MapAttr attr in dtlAttrs)
|
|
|
{
|
|
|
if (attr.KeyOfEn.Equals("OID") || attr.KeyOfEn.Equals("RefPK"))
|
|
|
continue;
|
|
|
if (attr.KeyOfEn.Equals("FID") || attr.KeyOfEn.Equals("RDT"))
|
|
|
continue;
|
|
|
if (attr.KeyOfEn.Equals("Rec") || attr.KeyOfEn.Equals("AthNum"))
|
|
|
continue;
|
|
|
dtlKeys += "\"" + attr.KeyOfEn + "\":\"" + geDtl.GetValByKey(attr.KeyOfEn) + "\",";
|
|
|
}
|
|
|
if (!DataType.IsNullOrEmpty(dtlKeys))
|
|
|
dtlKeys = dtlKeys.Substring(0, dtlKeys.Length - 1);
|
|
|
dtlKeys += "}";
|
|
|
|
|
|
FrmAttachmentDBs attachmentDBs = new FrmAttachmentDBs();
|
|
|
attachmentDBs.Retrieve(FrmAttachmentDBAttr.FK_MapData, dtl.No, FrmAttachmentDBAttr.RefPKVal, geDtl.OID);
|
|
|
foreach (FrmAttachmentDB frmAttachmentDB in attachmentDBs)
|
|
|
{
|
|
|
dtlAth += "{";
|
|
|
dtlAth += "\"fileFullName\":\"" + frmAttachmentDB.FileFullName + "\",";
|
|
|
dtlAth += "\"fileName\":\"" + frmAttachmentDB.FileName + "\",";
|
|
|
dtlAth += "\"sort\":\"" + frmAttachmentDB.Sort + "\",";
|
|
|
dtlAth += "\"fileExts\":\"" + frmAttachmentDB.FileExts + "\",";
|
|
|
dtlAth += "\"rdt\":\"" + frmAttachmentDB.RDT + "\",";
|
|
|
dtlAth += "\"rec\":\"" + frmAttachmentDB.Rec + "\",";
|
|
|
dtlAth += "\"myPK\":\"" + frmAttachmentDB.MyPK + "\",";
|
|
|
dtlAth += "\"recName\":\"" + frmAttachmentDB.RecName + "\",";
|
|
|
dtlAth += "\"fk_dept\":\"" + frmAttachmentDB.DeptNo + "\",";
|
|
|
dtlAth += "\"fk_deptName\":\"" + frmAttachmentDB.DeptName + "\"";
|
|
|
dtlAth += "},";
|
|
|
}
|
|
|
if (!DataType.IsNullOrEmpty(dtlAth))
|
|
|
dtlAth = dtlAth.Substring(0, dtlAth.Length - 1);
|
|
|
dtlAth += "]";
|
|
|
dtlOne += "{";
|
|
|
dtlOne += "\"dtlData\":" + dtlKeys + ",";
|
|
|
dtlOne += "\"dtlAths\":[" + dtlAth + "";
|
|
|
dtlOne += "},";
|
|
|
}
|
|
|
if (!DataType.IsNullOrEmpty(dtlOne))
|
|
|
dtlOne = dtlOne.Substring(0, dtlOne.Length - 1);
|
|
|
dtlList += dtlOne;
|
|
|
dtlList += "]";
|
|
|
|
|
|
dtlData += "\"dtl\":" + dtlList + "";
|
|
|
dtlData += "},";
|
|
|
}
|
|
|
if (!DataType.IsNullOrEmpty(dtlData))
|
|
|
dtlData = dtlData.Substring(0, dtlData.Length - 1);
|
|
|
dtls += dtlData;
|
|
|
dtls += "]";
|
|
|
|
|
|
//附件数据
|
|
|
string aths = "[";
|
|
|
string ath = "";
|
|
|
|
|
|
FrmAttachments attachments = new FrmAttachments();
|
|
|
attachments.Retrieve(FrmAttachmentAttr.FK_MapData, currNode.NodeFrmID, FrmAttachmentAttr.FK_Node, 0);
|
|
|
foreach (FrmAttachment attachment in attachments)
|
|
|
{
|
|
|
FrmAttachmentDBs dbs = new FrmAttachmentDBs();
|
|
|
dbs.Retrieve(FrmAttachmentDBAttr.FK_FrmAttachment, attachment.MyPK, FrmAttachmentDBAttr.FK_MapData, currNode.NodeFrmID, FrmAttachmentDBAttr.RefPKVal, gwf.WorkID);
|
|
|
if (dbs.Count <= 0)
|
|
|
continue;
|
|
|
ath += "{";
|
|
|
ath += "\"attachmentid\":\"" + attachment.MyPK + "\",";
|
|
|
|
|
|
string athdb = "";
|
|
|
foreach (FrmAttachmentDB db in dbs)
|
|
|
{
|
|
|
athdb += "{";
|
|
|
athdb += "\"fileFullName\":\"" + db.FileFullName + "\",";
|
|
|
athdb += "\"fileName\":\"" + db.FileName + "\",";
|
|
|
athdb += "\"sort\":\"" + db.Sort + "\",";
|
|
|
athdb += "\"fileExts\":\"" + db.FileExts + "\",";
|
|
|
athdb += "\"rdt\":\"" + db.RDT + "\",";
|
|
|
athdb += "\"myPK\":\"" + db.MyPK + "\",";
|
|
|
athdb += "\"refPKVal\":\"" + db.RefPKVal + "\",";
|
|
|
athdb += "\"rec\":\"" + db.Rec + "\",";
|
|
|
athdb += "\"recName\":\"" + db.RecName + "\",";
|
|
|
athdb += "\"fk_dept\":\"" + db.DeptNo + "\",";
|
|
|
athdb += "\"fk_deptName\":\"" + db.DeptName + "\",";
|
|
|
athdb += "},";
|
|
|
}
|
|
|
if (!DataType.IsNullOrEmpty(athdb))
|
|
|
athdb = athdb.Substring(0, athdb.Length - 1);
|
|
|
ath += "\"athdb\":" + athdb + "";
|
|
|
ath += "},";
|
|
|
}
|
|
|
if (!DataType.IsNullOrEmpty(ath))
|
|
|
ath = ath.Substring(0, ath.Length - 1);
|
|
|
aths += ath;
|
|
|
aths += "]";
|
|
|
|
|
|
info += mainTable;
|
|
|
info += ",\"dtls\":" + dtls;
|
|
|
info += ",\"aths\":" + aths;
|
|
|
info += "}";
|
|
|
|
|
|
string apiUrl = fl.DTSWebAPI;
|
|
|
Hashtable headerMap = new Hashtable();
|
|
|
|
|
|
//设置返回值格式
|
|
|
headerMap.Add("Content-Type", "application/json");
|
|
|
//设置token，用于接口校验
|
|
|
headerMap.Add("Authorization", WebUser.Token);
|
|
|
//执行POST
|
|
|
string postData = BP.Tools.PubGlo.HttpPostConnect(apiUrl, headerMap, info.ToString());
|
|
|
JObject res = postData.ToJObject();
|
|
|
if (!res["code"].ToString().Equals("200"))
|
|
|
{
|
|
|
BP.DA.Log.DebugWriteInfo("同步失败:WebAPI请求地址：" + apiUrl + ",请求内容：" + postData);
|
|
|
BP.DA.Log.DebugWriteInfo("失败数据:" + info);
|
|
|
}
|
|
|
return;
|
|
|
|
|
|
}
|
|
|
#endregion zqp, 编写同步的业务逻辑,执行错误就抛出异常.
|
|
|
return;
|
|
|
}
|
|
|
/// <summary>
|
|
|
/// 处理协作模式下的删除规则
|
|
|
/// </summary>
|
|
|
/// <param name="nd">节点</param>
|
|
|
/// <param name="gwf"></param>
|
|
|
public static void GenerWorkerListDelRole(Node nd, GenerWorkFlow gwf)
|
|
|
{
|
|
|
if (nd.GenerWorkerListDelRole == 0)
|
|
|
return;
|
|
|
|
|
|
//按照部门删除,同部门下的人员+兼职部门.
|
|
|
if (nd.GenerWorkerListDelRole == 1 ||
|
|
|
nd.GenerWorkerListDelRole == 3 ||
|
|
|
nd.GenerWorkerListDelRole == 4)
|
|
|
{
|
|
|
//定义本部门的人员. 主部门+兼职部门.
|
|
|
string sqlUnion = "";
|
|
|
if (nd.GenerWorkerListDelRole == 1)
|
|
|
{
|
|
|
sqlUnion += " SELECT " + BP.Sys.Base.Glo.UserNoWhitOutAS + " as FK_Emp FROM Port_Emp WHERE FK_Dept='" + WebUser.DeptNo + "' ";
|
|
|
sqlUnion += " UNION ";
|
|
|
sqlUnion += " SELECT FK_Emp FROM Port_DeptEmp WHERE FK_Dept='" + WebUser.DeptNo + "'";
|
|
|
}
|
|
|
|
|
|
//主部门的人员.
|
|
|
if (nd.GenerWorkerListDelRole == 3)
|
|
|
{
|
|
|
sqlUnion += " SELECT " + BP.Sys.Base.Glo.UserNo + " FROM Port_Emp WHERE FK_Dept='" + WebUser.DeptNo + "' ";
|
|
|
}
|
|
|
|
|
|
//兼职部门的人员.
|
|
|
if (nd.GenerWorkerListDelRole == 4)
|
|
|
{
|
|
|
sqlUnion += " SELECT FK_Dept FROM Port_DeptEmp WHERE FK_Dept='" + WebUser.DeptNo + "'";
|
|
|
}
|
|
|
|
|
|
//获得要删除的人员.
|
|
|
string sql = " SELECT FK_Emp FROM WF_GenerWorkerlist WHERE ";
|
|
|
sql += " WorkID=" + gwf.WorkID + " AND FK_Node=" + gwf.NodeID + " AND IsPass=0 ";
|
|
|
sql += " AND FK_Emp IN (" + sqlUnion + ")";
|
|
|
|
|
|
//获得要删除的数据.
|
|
|
DataTable dt = DBAccess.RunSQLReturnTable(sql);
|
|
|
for (int i = 0; i < dt.Rows.Count; i++)
|
|
|
{
|
|
|
string empNo = dt.Rows[i][0].ToString();
|
|
|
if (empNo.Equals(WebUser.No) == true)
|
|
|
continue;
|
|
|
sql = "UPDATE WF_GenerWorkerlist SET IsPass=1 WHERE WorkID=" + gwf.WorkID + " AND FK_Node=" + gwf.NodeID + " AND FK_Emp='" + empNo + "'";
|
|
|
DBAccess.RunSQL(sql);
|
|
|
}
|
|
|
}
|
|
|
|
|
|
//按照角色删除,同角色的人员.
|
|
|
if (nd.GenerWorkerListDelRole == 2)
|
|
|
{
|
|
|
//1. 求出来: 当前人员的角色集合与节点角色集合的交集， 表示：当前人员用这些角色做了这个节点的事情.
|
|
|
//获得当前节点使用的岗位, 首先从临时的变量里找（动态的获取的）,没有就到 NodeStation 里找.
|
|
|
string temp = gwf.GetParaString("NodeStas" + gwf.NodeID, ""); //这个变量是上一个节点通过字段选择出来的.
|
|
|
string stasSQLIn = "";
|
|
|
if (DataType.IsNullOrEmpty(temp) == false)
|
|
|
{
|
|
|
stasSQLIn = DataType.DealFromatSQLWhereIn(temp);
|
|
|
}
|
|
|
else
|
|
|
{
|
|
|
DataTable dtStas = DBAccess.RunSQLReturnTable("SELECT FK_Station FROM WF_NodeStation WHERE FK_Node=" + nd.NodeID);
|
|
|
if (dtStas.Rows.Count == 0)
|
|
|
throw new Exception("err@执行按照岗位删除人员待办出现错误，没有找到节点" + nd.NodeID + "-" + nd.Name + ",绑定的岗位.");
|
|
|
|
|
|
string strs = "";
|
|
|
foreach (DataRow dr in dtStas.Rows)
|
|
|
{
|
|
|
strs += ",'" + dr[0].ToString() + "'";
|
|
|
}
|
|
|
stasSQLIn = strs.Substring(1);
|
|
|
}
|
|
|
if (DataType.IsNullOrEmpty(stasSQLIn) == true)
|
|
|
throw new Exception("err@没有找到当前节点使用的岗位集合.");
|
|
|
|
|
|
|
|
|
//求出来我使用的岗位集合.
|
|
|
string sqlGroupMy = ""; //我使用岗位.
|
|
|
sqlGroupMy = "SELECT FK_Station FROM Port_DeptEmpStation WHERE FK_Station IN (" + stasSQLIn + ") AND FK_Emp='" + BP.Web.WebUser.No + "'";
|
|
|
|
|
|
DataTable dtGroupMy = DBAccess.RunSQLReturnTable(sqlGroupMy);
|
|
|
|
|
|
string stasGroupMy = ""; //我使用的岗位.
|
|
|
foreach (DataRow dr in dtGroupMy.Rows)
|
|
|
stasGroupMy += ",'" + dr[0].ToString() + "'";
|
|
|
stasGroupMy = stasGroupMy.Substring(1);
|
|
|
|
|
|
|
|
|
//2. 遍历: 当前的操作员，一个个的判断是否可以删除.
|
|
|
GenerWorkerLists gwls = new GenerWorkerLists();
|
|
|
gwls.Retrieve(GenerWorkerListAttr.WorkID, gwf.WorkID, GenerWorkerListAttr.FK_Node, nd.NodeID);
|
|
|
|
|
|
foreach (GenerWorkerList item in gwls)
|
|
|
{
|
|
|
if (item.ItIsEnable == false)
|
|
|
continue;
|
|
|
if (item.EmpNo.Equals(BP.Web.WebUser.No) == true)
|
|
|
continue; //要把自己排除在外.
|
|
|
|
|
|
string sqlGroupUser = "SELECT FK_Station FROM Port_DeptEmpStation WHERE FK_Station IN (" + stasSQLIn + ") AND FK_Emp='" + item.EmpNo + "'";
|
|
|
DataTable dtGroupUser = DBAccess.RunSQLReturnTable(sqlGroupUser);
|
|
|
|
|
|
// 判断 sqlGroupMy >= sqlGroupUser 是否包含,如果包含，就是删除对象.
|
|
|
bool isCanDel = true;
|
|
|
foreach (DataRow dr in dtGroupUser.Rows)
|
|
|
{
|
|
|
string staNo = "'" + dr[0].ToString() + "'";
|
|
|
if (stasGroupMy.Contains(staNo) == false)
|
|
|
isCanDel = false;
|
|
|
}
|
|
|
|
|
|
//符合删除的条件.
|
|
|
if (isCanDel == true)
|
|
|
{
|
|
|
item.ItIsEnable = false;
|
|
|
item.PassInt = 1;
|
|
|
item.Update();
|
|
|
}
|
|
|
}
|
|
|
|
|
|
// 地瓜土豆问题.
|
|
|
#region 3 检查同角色的人员是否有交集: 潘茄的人,马铃薯的人，都分别审批了，需要删除 潘茄+马铃薯角色的人.
|
|
|
// 3.1 找出来处理人中，用到人角色集合， 就是说已经消耗掉的角色集合.
|
|
|
string sql = "SELECT B.FK_Station,A.FK_Emp FROM WF_GenerWorkerlist A, Port_DeptEmpStation B ";
|
|
|
sql += " WHERE A.FK_Emp=B.FK_Emp AND B.FK_Station IN (" + stasSQLIn + ") AND A.WorkID=" + gwf.WorkID + " AND A.FK_Node=" + nd.NodeID;
|
|
|
sql += " AND (A.IsPass=1 OR A.FK_Emp='" + BP.Web.WebUser.No + "') ";
|
|
|
|
|
|
DataTable dtStationsUsed = DBAccess.RunSQLReturnTable(sql);
|
|
|
string stasUseed = "";
|
|
|
foreach (DataRow dr in dtStationsUsed.Rows)
|
|
|
{
|
|
|
stasUseed += ",'" + dr[0].ToString() + "'";
|
|
|
}
|
|
|
|
|
|
// 3.2 扫描剩余的待办人员，这些待办的人员的使用的本节点的角色集合 是否 在消耗掉的角色集合中，如果有，就删除他的待办.
|
|
|
gwls = new GenerWorkerLists();
|
|
|
gwls.Retrieve("WorkID", gwf.WorkID, "IsPass", 0);
|
|
|
foreach (GenerWorkerList item in gwls)
|
|
|
{
|
|
|
if (item.EmpNo.Equals(WebUser.No) == true)
|
|
|
continue;
|
|
|
|
|
|
//未处理的人的角色集合.
|
|
|
string sqlGroupUser = "SELECT FK_Station FROM Port_DeptEmpStation A WHERE FK_Station IN (" + stasSQLIn + ") AND FK_Emp='" + item.EmpNo + "'";
|
|
|
DataTable dtGroupUser = DBAccess.RunSQLReturnTable(sqlGroupUser);
|
|
|
|
|
|
// 判断 sqlGroupMy >= sqlGroupUser 是否包含,如果包含，就是删除对象.
|
|
|
bool isCanDel = true;
|
|
|
foreach (DataRow dr in dtGroupUser.Rows)
|
|
|
{
|
|
|
string staNo = "'" + dr[0].ToString() + "'";
|
|
|
if (stasUseed.Contains(staNo) == false)
|
|
|
isCanDel = false;
|
|
|
}
|
|
|
|
|
|
//符合删除的条件.
|
|
|
if (isCanDel == true)
|
|
|
{
|
|
|
item.ItIsEnable = false;
|
|
|
item.PassInt = 1;
|
|
|
item.Update();
|
|
|
}
|
|
|
}
|
|
|
#endregion 检查同角色的人员是否有交集: 潘茄的人,马铃薯的人，都分别审批了，需要删除 潘茄+马铃薯角色的人.
|
|
|
|
|
|
/* 以下方法有问题.
|
|
|
NodeStations nss = new NodeStations();
|
|
|
nss.Retrieve(NodeStationAttr.FK_Node, gwf.NodeID);
|
|
|
if (nss.Count == 0)
|
|
|
throw new Exception("err@流程设计错误: 您设置了待办按照角色删除的规则,但是在当前节点上，您没有设置角色。");
|
|
|
//定义角色人员
|
|
|
string station = "SELECT FK_Station FROM Port_DeptEmpStation WHERE FK_Emp='" + WebUser.No + "'";
|
|
|
station = DBAccess.RunSQLReturnString(station);
|
|
|
string stationEmp = "SELECT FK_Emp FROM Port_DeptEmpStation WHERE FK_Station ='" + station + "'";
|
|
|
//获得要删除的人员.
|
|
|
string sql = " SELECT FK_Emp FROM WF_GenerWorkerlist WHERE ";
|
|
|
sql += " WorkID=" + gwf.WorkID + " AND FK_Node=" + gwf.NodeID + " AND IsPass=0 ";
|
|
|
sql += " AND FK_Emp IN (" + stationEmp + ")";
|
|
|
//获得要删除的数据.
|
|
|
|
|
|
DataTable dt = DBAccess.RunSQLReturnTable(sql);
|
|
|
for (int i = 0; i < dt.Rows.Count; i++)
|
|
|
{
|
|
|
string empNo = dt.Rows[i][0].ToString();
|
|
|
if (empNo == WebUser.No)
|
|
|
continue;
|
|
|
sql = "UPDATE WF_GenerWorkerlist SET IsPass=1 WHERE WorkID=" + gwf.WorkID + " AND FK_Node=" + gwf.NodeID + " AND FK_Emp='" + empNo + "'";
|
|
|
DBAccess.RunSQL(sql);
|
|
|
} */
|
|
|
}
|
|
|
}
|
|
|
/// <summary>
|
|
|
/// 处理发送返回，断头路节点.
|
|
|
/// </summary>
|
|
|
public static WorkNode IsSendBackNode(WorkNode wn)
|
|
|
{
|
|
|
if (wn.HisNode.ItIsSendBackNode == false)
|
|
|
return wn; //如果不是断头路节点，就让其返回.
|
|
|
if (wn.HisGenerWorkFlow.WFState == WFState.ReturnSta)
|
|
|
{
|
|
|
//是退回状态且原路返回的情况
|
|
|
string sql = "SELECT NDFrom, EmpFrom, EmpFromT ";
|
|
|
sql += " FROM ND"+Int32.Parse(wn.HisGenerWorkFlow.FlowNo)+"Track";
|
|
|
sql += " WHERE WorkID=" + wn.WorkID + " AND (ActionType=2 OR ActionType=201) ORDER BY RDT DESC";
|
|
|
DataTable mydt = DBAccess.RunSQLReturnTable(sql);
|
|
|
if (mydt.Rows.Count != 0 && wn.HisGenerWorkFlow.GetParaBoolen("IsBackTracking") == true)
|
|
|
{
|
|
|
wn.JumpToNode = new Node(int.Parse(mydt.Rows[0][0].ToString()));
|
|
|
wn.JumpToEmp = mydt.Rows[0][1].ToString();
|
|
|
return wn;
|
|
|
}
|
|
|
|
|
|
}
|
|
|
if (wn.HisNode.HisToNDNum != 0)
|
|
|
throw new Exception("err@流程设计错误:当前节点是发送自动返回节点，但是当前节点不能有到达的节点.");
|
|
|
|
|
|
if (wn.HisNode.HisRunModel != RunModel.Ordinary)
|
|
|
throw new Exception("err@流程设计错误:只能是线性节点才能设置[发送并返回]属性,当前节点是[" + wn.HisNode.HisRunModel.ToString() + "]");
|
|
|
|
|
|
//判断是否是最后一个人？
|
|
|
bool isLastOne = false;
|
|
|
GenerWorkerLists gwls = new GenerWorkerLists();
|
|
|
gwls.Retrieve(GenerWorkerListAttr.WorkID, wn.WorkID,
|
|
|
GenerWorkerListAttr.FK_Node, wn.HisNode.NodeID, GenerWorkerListAttr.IsPass, 0);
|
|
|
if (gwls.Count == 1)
|
|
|
isLastOne = true; //如果只有一个，本人就是lastOne.
|
|
|
|
|
|
//WorkNode wn= this.GetPreviousWorkNode();
|
|
|
//this.JumpToEmp = wn.HisWork.Rec; //对于绑定的表单有问题.
|
|
|
//this.JumpToNode = wn.HisNode;
|
|
|
|
|
|
if (isLastOne == true || wn.HisNode.TodolistModel == TodolistModel.QiangBan)
|
|
|
{
|
|
|
string ptable = "ND" + int.Parse(wn.HisFlow.No) + "Track";
|
|
|
|
|
|
string mysql = "";
|
|
|
if (wn.HisNode.ItIsSubThread == true)
|
|
|
mysql = "SELECT NDFrom,EmpFrom FROM " + ptable + " WHERE (WorkID =" + wn.WorkID + " AND FID=" + wn.HisGenerWorkFlow.FID + ") AND ActionType!= " + (int)ActionType.UnSend + " AND NDTo = " + wn.HisNode.NodeID + " AND(NDTo != NDFrom) AND NDFrom In(Select Node From WF_Direction Where ToNode=" + wn.HisNode.NodeID + " AND FK_Flow='" + wn.HisFlow.No + "') ORDER BY RDT DESC";
|
|
|
else
|
|
|
mysql = "SELECT NDFrom,EmpFrom FROM " + ptable + " WHERE WorkID =" + wn.WorkID + " AND ActionType!= " + (int)ActionType.UnSend + " AND NDTo = " + wn.HisNode.NodeID + " AND(NDTo != NDFrom) AND NDFrom In(Select Node From WF_Direction Where ToNode=" + wn.HisNode.NodeID + " AND FK_Flow='" + wn.HisFlow.No + "') ORDER BY RDT DESC";
|
|
|
|
|
|
DataTable mydt = DBAccess.RunSQLReturnTable(mysql);
|
|
|
if (mydt.Rows.Count == 0)
|
|
|
throw new Exception("系统错误，没有找到上一个节点.");
|
|
|
|
|
|
wn.JumpToEmp = mydt.Rows[0][1].ToString();
|
|
|
int priNodeID = int.Parse(mydt.Rows[0][0].ToString());
|
|
|
wn.JumpToNode = new Node(priNodeID);
|
|
|
|
|
|
//清除选择，防止在自动发送到该节点上来.
|
|
|
wn.HisGenerWorkFlow.Paras_ToNodes = "";
|
|
|
wn.HisGenerWorkFlow.DirectUpdate();
|
|
|
|
|
|
//清除上次发送的选择,不然下次还会自动发送到当前的节点上来.
|
|
|
mysql = "DELETE FROM WF_SelectAccper WHERE FK_Node=" + wn.JumpToNode.NodeID + " AND WorkID=" + wn.WorkID;
|
|
|
DBAccess.RunSQL(mysql);
|
|
|
}
|
|
|
return wn;
|
|
|
}
|
|
|
/// <summary>
|
|
|
/// 处理 askfor 状态
|
|
|
/// </summary>
|
|
|
/// <param name="wn"></param>
|
|
|
public static SendReturnObjs DealAskForState(WorkNode wn)
|
|
|
{
|
|
|
/*如果是加签状态, 就判断加签后，是否要返回给执行加签人.*/
|
|
|
GenerWorkerLists gwls = new GenerWorkerLists();
|
|
|
gwls.Retrieve(GenerWorkerListAttr.FK_Node, wn.HisNode.NodeID,
|
|
|
GenerWorkerListAttr.WorkID, wn.WorkID);
|
|
|
|
|
|
bool isDeal = false;
|
|
|
AskforHelpSta askForSta = AskforHelpSta.AfterDealSend;
|
|
|
foreach (GenerWorkerList item in gwls)
|
|
|
{
|
|
|
if (item.PassInt == (int)AskforHelpSta.AfterDealSend)
|
|
|
{
|
|
|
/*如果是加签后，直接发送就不处理了。*/
|
|
|
isDeal = true;
|
|
|
askForSta = AskforHelpSta.AfterDealSend;
|
|
|
|
|
|
// 更新workerlist, 设置所有人员的状态为已经处理的状态,让它走到下一步骤去.
|
|
|
DBAccess.RunSQL("UPDATE WF_GenerWorkerlist SET IsPass=1 WHERE FK_Node=" + wn.HisNode.NodeID + " AND WorkID=" + wn.WorkID);
|
|
|
|
|
|
//写入日志.
|
|
|
wn.AddToTrack(ActionType.ForwardAskfor, item.EmpNo, item.EmpName,
|
|
|
wn.HisNode.NodeID, wn.HisNode.Name, BP.WF.Glo.multilingual("加签后向下发送，直接发送给下一步处理人。", "WorkNode", "send_to_next"));
|
|
|
|
|
|
}
|
|
|
|
|
|
if (item.PassInt == (int)AskforHelpSta.AfterDealSendByWorker)
|
|
|
{
|
|
|
/*如果是加签后，在由我直接发送。*/
|
|
|
item.PassInt = 0;
|
|
|
|
|
|
isDeal = true;
|
|
|
askForSta = AskforHelpSta.AfterDealSendByWorker;
|
|
|
|
|
|
// 更新workerlist, 设置所有人员的状态为已经处理的状态.
|
|
|
DBAccess.RunSQL("UPDATE WF_GenerWorkerlist SET IsPass=1 WHERE FK_Node=" + wn.HisNode.NodeID + " AND WorkID=" + wn.WorkID);
|
|
|
|
|
|
// 把发起加签人员的状态更新过来，让他可见待办工作.
|
|
|
item.PassInt = 0;
|
|
|
item.Update();
|
|
|
|
|
|
// 更新流程状态.
|
|
|
wn.HisGenerWorkFlow.WFState = WFState.AskForReplay;
|
|
|
wn.HisGenerWorkFlow.Update();
|
|
|
|
|
|
//让加签人，设置成工作未读。
|
|
|
BP.WF.Dev2Interface.Node_SetWorkUnRead(wn.WorkID, item.EmpNo);
|
|
|
|
|
|
// 从临时变量里获取回复加签意见.
|
|
|
string replyInfo = wn.HisGenerWorkFlow.Paras_AskForReply;
|
|
|
|
|
|
////写入日志.
|
|
|
//this.AddToTrack(ActionType.ForwardAskfor, item.FK_Emp, item.FK_EmpText,
|
|
|
// this.HisNode.NodeID, this.HisNode.Name,
|
|
|
// "加签后向下发送，并转向加签人发起人（" + item.EmpNo + "，" + item.EmpName + "）。<br>意见:" + replyInfo);
|
|
|
|
|
|
//写入日志.
|
|
|
wn.AddToTrack(ActionType.ForwardAskfor, item.EmpNo, item.EmpName,
|
|
|
wn.HisNode.NodeID, wn.HisNode.Name, BP.WF.Glo.multilingual("回复意见:{0}.", "WorkNode", "reply_comments", replyInfo));
|
|
|
|
|
|
//加入系统变量。
|
|
|
wn.addMsg(SendReturnMsgFlag.VarToNodeID, wn.HisNode.NodeID.ToString(), SendReturnMsgType.SystemMsg);
|
|
|
wn.addMsg(SendReturnMsgFlag.VarToNodeName, wn.HisNode.Name, SendReturnMsgType.SystemMsg);
|
|
|
wn.addMsg(SendReturnMsgFlag.VarAcceptersID, item.EmpNo, SendReturnMsgType.SystemMsg);
|
|
|
wn.addMsg(SendReturnMsgFlag.VarAcceptersName, item.EmpName, SendReturnMsgType.SystemMsg);
|
|
|
|
|
|
//加入提示信息.
|
|
|
wn.addMsg(SendReturnMsgFlag.SendSuccessMsg, BP.WF.Glo.multilingual("已经转给加签的发起人({0},{1})", "WorkNode", "send_to_the_operator", item.EmpNo.ToString(), item.EmpName), SendReturnMsgType.Info);
|
|
|
|
|
|
//删除当前操作员临时增加的工作列表记录, 如果不删除就会导致第二次加签失败.
|
|
|
GenerWorkerList gwl = new GenerWorkerList();
|
|
|
gwl.Delete(GenerWorkerListAttr.FK_Node, wn.HisNode.NodeID,
|
|
|
GenerWorkerListAttr.WorkID, wn.WorkID, GenerWorkerListAttr.FK_Emp, wn.Execer);
|
|
|
|
|
|
//调用发送成功事件.
|
|
|
string sendSuccess = ExecEvent.DoNode(EventListNode.SendSuccess, wn);
|
|
|
wn.HisMsgObjs.AddMsg("info21", sendSuccess, sendSuccess, SendReturnMsgType.Info);
|
|
|
|
|
|
//执行时效考核.
|
|
|
Glo.InitCH(wn.HisFlow, wn.HisNode, wn.WorkID, 0, wn.HisGenerWorkFlow.Title);
|
|
|
|
|
|
//返回发送对象.
|
|
|
return wn.HisMsgObjs;
|
|
|
}
|
|
|
}
|
|
|
|
|
|
if (isDeal == false)
|
|
|
throw new Exception(BP.WF.Glo.multilingual("@流程引擎错误，不应该找不到加签的状态.", "WorkNode", "wf_eng_error_1"));
|
|
|
|
|
|
return null;
|
|
|
}
|
|
|
/// <summary>
|
|
|
/// 执行分河流状态
|
|
|
/// </summary>
|
|
|
/// <param name="wn"></param>
|
|
|
public static void DealHeLiuState(WorkNode wn)
|
|
|
{
|
|
|
/* 如果是合流点 检查当前是否是合流点如果是，则检查分流上的子线程是否完成。*/
|
|
|
/*检查是否有子线程没有结束*/
|
|
|
Paras ps = new Paras();
|
|
|
ps.SQL = "SELECT WorkID,FK_Emp,EmpName,NodeName FROM WF_GenerWorkerlist WHERE FID=" + ps.DBStr + "FID AND IsPass=0 AND IsEnable=1";
|
|
|
ps.Add(WorkAttr.FID, wn.WorkID);
|
|
|
|
|
|
DataTable dtWL = DBAccess.RunSQLReturnTable(ps);
|
|
|
string infoErr = "";
|
|
|
if (dtWL.Rows.Count != 0)
|
|
|
{
|
|
|
if (wn.HisNode.ThreadKillRole == ThreadKillRole.None
|
|
|
|| wn.HisNode.ThreadKillRole == ThreadKillRole.ByHand)
|
|
|
{
|
|
|
infoErr += BP.WF.Glo.multilingual("@您不能向下发送，有如下子线程没有完成。", "WorkNode", "cannot_send_to_next_1");
|
|
|
|
|
|
foreach (DataRow dr in dtWL.Rows)
|
|
|
{
|
|
|
string op = BP.WF.Glo.multilingual("@操作员编号:{0},{1}", "WorkNode", "current_operator", dr["FK_Emp"].ToString(), dr["EmpName"].ToString());
|
|
|
string nd = BP.WF.Glo.multilingual("停留节点:{0}.", "WorkNode", "current_node", dr["NodeName"].ToString());
|
|
|
//infoErr += "@操作员编号:" + dr["FK_Emp"] + "," + dr["FK_EmpText"] + ",停留节点:" + dr["NodeName"];
|
|
|
infoErr += op + ";" + nd;
|
|
|
}
|
|
|
|
|
|
if (wn.HisNode.ThreadKillRole == ThreadKillRole.ByHand)
|
|
|
infoErr += BP.WF.Glo.multilingual("@请通知他们处理完成,或者强制删除子流程您才能向下发送.", "WorkNode", "cannot_send_to_next_2");
|
|
|
|
|
|
else
|
|
|
infoErr += BP.WF.Glo.multilingual("@请通知他们处理完成,您才能向下发送.", "WorkNode", "cannot_send_to_next_3");
|
|
|
|
|
|
//抛出异常阻止它向下运动。
|
|
|
throw new Exception(infoErr);
|
|
|
}
|
|
|
|
|
|
if (wn.HisNode.ThreadKillRole == ThreadKillRole.ByAuto)
|
|
|
{
|
|
|
//删除每个子线程，然后向下运动。
|
|
|
foreach (DataRow dr in dtWL.Rows)
|
|
|
BP.WF.Dev2Interface.Flow_DeleteSubThread(Int64.Parse(dr[0].ToString()), BP.WF.Glo.multilingual("合流点发送时自动删除", "WorkNode", "auto_delete"));
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
|
|
|
/// <summary>
|
|
|
/// 子流程运行结束后
|
|
|
/// </summary>
|
|
|
/// <param name="wn"></param>
|
|
|
public static String SubFlowEvent(WorkNode wn)
|
|
|
{
|
|
|
GenerWorkFlow gwf = new GenerWorkFlow(wn.WorkID);
|
|
|
//判断是否是子流程
|
|
|
if (gwf.PWorkID == 0)
|
|
|
return "";
|
|
|
string msg = "";
|
|
|
//子流程运行到指定节点后父流程自动运行到下一个节点
|
|
|
if (gwf.WFState != WFState.Complete)
|
|
|
{
|
|
|
SubFlows subFlows = new SubFlows();
|
|
|
subFlows.Retrieve(SubFlowAttr.FK_Node, gwf.PNodeID, SubFlowAttr.SubFlowNo, wn.HisFlow.No);
|
|
|
if (subFlows.Count == 0)
|
|
|
return "";
|
|
|
SubFlow subFlow = subFlows[0] as SubFlow;
|
|
|
|
|
|
if (subFlow.SubFlowNodeID == 0 || wn.HisNode.NodeID != subFlow.SubFlowNodeID)
|
|
|
return "";
|
|
|
|
|
|
if (subFlow.ParentFlowSendNextStepRole == SubFlowRunModel.SpecifiedNodes)
|
|
|
{
|
|
|
//获取父流程实例信息
|
|
|
GenerWorkFlow pgwf = new GenerWorkFlow(gwf.PWorkID);
|
|
|
if (pgwf.NodeID == gwf.PNodeID)
|
|
|
{
|
|
|
SendReturnObjs returnObjs = BP.WF.Dev2Interface.Node_SendWork(gwf.PFlowNo, gwf.PWorkID);
|
|
|
msg = "父流程自动运行到下一个节点，" + returnObjs.ToMsgOfHtml();
|
|
|
|
|
|
}
|
|
|
return msg;
|
|
|
}
|
|
|
return "";
|
|
|
}
|
|
|
|
|
|
//子流程结束后父流程/同级子流程的处理
|
|
|
if (gwf.WFState == WFState.Complete)
|
|
|
{
|
|
|
//先判断当前流程是下级子流程还是同级子流程
|
|
|
Int64 slworkid = gwf.GetParaInt("SLWorkID");
|
|
|
SubFlows subFlows = new SubFlows();
|
|
|
SubFlow subFlow = null;
|
|
|
//下级子流程
|
|
|
if (slworkid == 0)
|
|
|
{
|
|
|
//判断子流程中的设置关系
|
|
|
subFlows.Retrieve(SubFlowAttr.FK_Node, gwf.PNodeID, SubFlowAttr.SubFlowNo, wn.HisFlow.No);
|
|
|
if (subFlows.Count == 0)
|
|
|
return "";
|
|
|
subFlow = subFlows[0] as SubFlow;
|
|
|
|
|
|
//把子流程的数据反填到父流程中
|
|
|
SubFlowOver_CopyDataToParantFlow(subFlow, wn.HisGenerWorkFlow.PWorkID, wn);
|
|
|
|
|
|
int pnodeId = gwf.PNodeID;
|
|
|
FrmSubFlow nd = new FrmSubFlow(pnodeId);
|
|
|
switch (nd.AllSubFlowOverRole)
|
|
|
{
|
|
|
case AllSubFlowOverRole.None: //父节点不设置所有子流程结束规则
|
|
|
//发送成功后显示父流程的待办
|
|
|
if (subFlow.SubFlowHidTodolist == true)
|
|
|
{
|
|
|
GenerWorkFlow pgwf = new GenerWorkFlow(gwf.PWorkID);
|
|
|
string mysql = "SELECT COUNT(WorkID) as Num FROM WF_GenerWorkFlow WHERE PWorkID=" + gwf.PWorkID + " AND FK_Flow='" + wn.HisFlow.No + "' AND WFState !=3 ";
|
|
|
if (DBAccess.RunSQLReturnValInt(mysql, 0) == 0)
|
|
|
{
|
|
|
DBAccess.RunSQL("UPDATE WF_GenerWorkerlist SET IsPass=0 Where WorkID=" + pgwf.WorkID + " AND FK_Node=" + pgwf.NodeID + " AND IsPass=100");
|
|
|
|
|
|
}
|
|
|
}
|
|
|
|
|
|
//单个子流程控制父流程运行到下一个节点
|
|
|
if (subFlow.ParentFlowSendNextStepRole == SubFlowRunModel.FlowOver)
|
|
|
msg = SubFlowOver_ParentFlowAutoSendNextSetp(false, wn.HisGenerWorkFlow.PWorkID, wn.HisGenerWorkFlow);
|
|
|
//单个子流程控制父流程结束
|
|
|
if (subFlow.ParentFlowOverRole == SubFlowRunModel.FlowOver)
|
|
|
msg = SubFlowOver_ParentFlowOver(false, wn.HisGenerWorkFlow.PWorkID);
|
|
|
break;
|
|
|
case AllSubFlowOverRole.SendParentFlowToNextStep://父流程设置所有子流程结束后，父流程运行到下一个节点
|
|
|
msg = SubFlowOver_ParentFlowAutoSendNextSetp(true, wn.HisGenerWorkFlow.PWorkID, wn.HisGenerWorkFlow);
|
|
|
break;
|
|
|
case AllSubFlowOverRole.OverParentFlow://父流程设置所有子流程结束后，父流程结束
|
|
|
msg = SubFlowOver_ParentFlowOver(true, wn.HisGenerWorkFlow.PWorkID);
|
|
|
break;
|
|
|
default: break;
|
|
|
|
|
|
}
|
|
|
|
|
|
return msg;
|
|
|
}
|
|
|
|
|
|
//同级子流程
|
|
|
string slFlowNo = gwf.GetParaString("SLFlowNo");
|
|
|
Int32 slNodeID = gwf.GetParaInt("SLNodeID");
|
|
|
subFlows.Retrieve(SubFlowAttr.FK_Node, slNodeID, SubFlowAttr.SubFlowNo, wn.HisFlow.No);
|
|
|
if (subFlows.Count == 0)
|
|
|
return "";
|
|
|
subFlow = subFlows[0] as SubFlow;
|
|
|
//子流程运行结束后父流程是否自动往下运行一步
|
|
|
msg = SubFlowOver_DealSLSubFlow(slworkid, subFlow, wn.HisGenerWorkFlow);
|
|
|
|
|
|
return msg;
|
|
|
}
|
|
|
return "";
|
|
|
|
|
|
}
|
|
|
/// <summary>
|
|
|
/// 子流程运行结束后把数据反填到父流程中
|
|
|
/// </summary>
|
|
|
/// <param name="subFlow"></param>
|
|
|
/// <param name="pworkid"></param>
|
|
|
/// <param name="wn"></param>
|
|
|
private static void SubFlowOver_CopyDataToParantFlow(SubFlow subFlow, Int64 pworkid, WorkNode wn)
|
|
|
{
|
|
|
//子流程结束后，数据不反填到父流程中
|
|
|
if (subFlow.BackCopyRole == BackCopyRole.None)
|
|
|
return;
|
|
|
Node nd = new Node(subFlow.NodeID);
|
|
|
Work pwk = nd.HisWork;
|
|
|
pwk.OID = pworkid;
|
|
|
pwk.RetrieveFromDBSources();
|
|
|
|
|
|
GERpt prpt = new BP.WF.GERpt("ND" + int.Parse(subFlow.FlowNo) + "Rpt");
|
|
|
prpt.OID = pworkid;
|
|
|
prpt.RetrieveFromDBSources();
|
|
|
|
|
|
|
|
|
//判断是否启用了数据字段反填规则
|
|
|
if (subFlow.BackCopyRole == BackCopyRole.AutoFieldMatch || subFlow.BackCopyRole == BackCopyRole.MixedMode)
|
|
|
{
|
|
|
//子流程数据拷贝到父流程中
|
|
|
pwk.Copy(wn.HisWork);
|
|
|
prpt.Copy(wn.HisWork);
|
|
|
}
|
|
|
// 子流程数据拷贝到父流程中
|
|
|
if ((subFlow.BackCopyRole == BackCopyRole.FollowSetFormat || subFlow.BackCopyRole == BackCopyRole.MixedMode)
|
|
|
&& DataType.IsNullOrEmpty(subFlow.ParentFlowCopyFields) == false)
|
|
|
{
|
|
|
Work wk = wn.HisWork;
|
|
|
Attrs attrs = wk.EnMap.Attrs;
|
|
|
//获取子流程的签批字段
|
|
|
string keyOfEns = "";
|
|
|
string keyVals = ""; //签批字段存储的值
|
|
|
foreach (Attr attr in attrs)
|
|
|
{
|
|
|
if (attr.UIContralType == UIContralType.SignCheck)
|
|
|
{
|
|
|
keyOfEns += attr.Field + ",";
|
|
|
continue;
|
|
|
}
|
|
|
|
|
|
}
|
|
|
|
|
|
//父流程把子流程不同字段进行匹配赋值
|
|
|
AtPara ap = new AtPara(subFlow.ParentFlowCopyFields);
|
|
|
foreach (String str in ap.HisHT.Keys)
|
|
|
{
|
|
|
Object val = ap.GetValStrByKey(str);
|
|
|
if (DataType.IsNullOrEmpty(val.ToString()) == true)
|
|
|
continue;
|
|
|
pwk.SetValByKey(val.ToString(), wk.GetValByKey(str));
|
|
|
prpt.SetValByKey(val.ToString(), wk.GetValByKey(str));
|
|
|
if (keyOfEns.Contains(str + ",") == true)
|
|
|
keyVals += wk.GetValByKey(str);
|
|
|
}
|
|
|
if (DataType.IsNullOrEmpty(keyVals) == false)
|
|
|
{
|
|
|
string trackPTable = "ND" + int.Parse(wn.HisFlow.No) + "Track";
|
|
|
//把子流程的签批字段对应的审核信息拷贝到父流程中
|
|
|
keyVals = keyVals.Substring(1);
|
|
|
string sql = "SELECT * FROM " + trackPTable + " WHERE ActionType=22 AND WorkID=" + wn.WorkID + " AND NDFrom IN(" + keyVals + ")";
|
|
|
DataTable dt = DBAccess.RunSQLReturnTable(sql);
|
|
|
Tracks tracks = new Tracks();
|
|
|
BP.En.QueryObject.InitEntitiesByDataTable(tracks, dt, null);
|
|
|
foreach (Track t in tracks)
|
|
|
{
|
|
|
|
|
|
t.WorkID = pwk.OID;
|
|
|
t.FID = pwk.FID;
|
|
|
t.FlowNo = subFlow.FlowNo;
|
|
|
t.HisActionType = ActionType.WorkCheck;
|
|
|
t.setMyPK(DBAccess.GenerOIDByGUID().ToString());
|
|
|
t.Insert();
|
|
|
}
|
|
|
}
|
|
|
|
|
|
}
|
|
|
pwk.Update();
|
|
|
prpt.Update();
|
|
|
|
|
|
}
|
|
|
/// <summary>
|
|
|
/// 子流程运行结束后，父流程自动运行到下一个节点
|
|
|
/// </summary>
|
|
|
/// <param name="isAllSubFlowOver"></param>
|
|
|
/// <param name="pworkid"></param>
|
|
|
/// <param name="gwf"></param>
|
|
|
/// <returns></returns>
|
|
|
/// <exception cref="Exception"></exception>
|
|
|
private static string SubFlowOver_ParentFlowAutoSendNextSetp(bool isAllSubFlowOver, Int64 pworkid, GenerWorkFlow gwf)
|
|
|
{
|
|
|
//所有子流程结束后，父流程自动运行到下一个节点
|
|
|
if (isAllSubFlowOver == true)
|
|
|
{
|
|
|
if (BP.WF.Dev2Interface.Flow_NumOfSubFlowRuning(pworkid) != 0)
|
|
|
return "";
|
|
|
}
|
|
|
|
|
|
#region 检查父流程是否符合自动运行到下一个节点的条件
|
|
|
GenerWorkFlow pgwf = new GenerWorkFlow();
|
|
|
pgwf.WorkID = pworkid;
|
|
|
if (pgwf.RetrieveFromDBSources() == 0)
|
|
|
return ""; // 父流程被删除了也不能执行。
|
|
|
|
|
|
if (pgwf.WFState == WFState.Complete)
|
|
|
return ""; //父流程已经完成也不能执行.
|
|
|
|
|
|
//检查父流程的当前停留的节点是否还是发起子流程的节点？
|
|
|
if (gwf.PNodeID != pgwf.NodeID)
|
|
|
return "";
|
|
|
#endregion 检查父流程是否符合自动运行到下一个节点的条件
|
|
|
|
|
|
//获得父流程.
|
|
|
string[] strs = pgwf.TodoEmps.Split(';');
|
|
|
strs = strs[0].Split(',');
|
|
|
string empNo = strs[0];
|
|
|
if (DataType.IsNullOrEmpty(empNo) == true)
|
|
|
throw new Exception("err@没有找到父流程的处理人.");
|
|
|
|
|
|
//当前登录用户.
|
|
|
string currUserNo = BP.Web.WebUser.No;
|
|
|
try
|
|
|
{
|
|
|
Emp emp = new Emp(empNo);
|
|
|
//让父流程的userNo登录.
|
|
|
BP.WF.Dev2Interface.Port_Login(emp.No);
|
|
|
SendReturnObjs objs = null;
|
|
|
try
|
|
|
{
|
|
|
objs = BP.WF.Dev2Interface.Node_SendWork(pgwf.FlowNo, pgwf.WorkID);
|
|
|
//切换到当前流程节点.
|
|
|
BP.WF.Dev2Interface.Port_Login(currUserNo);
|
|
|
}
|
|
|
catch (Exception ex)
|
|
|
{
|
|
|
BP.WF.Dev2Interface.Port_Login(currUserNo);
|
|
|
throw new Exception(ex.Message);
|
|
|
}
|
|
|
|
|
|
return "@成功让父流程运行到下一个节点." + objs.ToMsgOfHtml();
|
|
|
}
|
|
|
catch (Exception ex)
|
|
|
{
|
|
|
//切换到当前流程节点.
|
|
|
BP.WF.Dev2Interface.Port_Login(currUserNo);
|
|
|
string info = "这个错误";
|
|
|
if (ex.Message.Contains("WorkOpt/") == true)
|
|
|
{
|
|
|
info += "@流程设计错误:自动运行到的下一个节点的接收人规则是由上一个人员来选择的,导致到不能自动运行到下一步骤.";
|
|
|
return info;
|
|
|
}
|
|
|
|
|
|
return "@在最后一个子流程完成后，让父流程的节点自动发送时，出现错误:" + ex.Message;
|
|
|
}
|
|
|
}
|
|
|
/// <summary>
|
|
|
/// 子流程结束后，父流程自动结束
|
|
|
/// </summary>
|
|
|
/// <param name="isAllSubFlowOver"></param>
|
|
|
/// <param name="pworkid"></param>
|
|
|
/// <returns></returns>
|
|
|
public static string SubFlowOver_ParentFlowOver(bool isAllSubFlowOver, Int64 pworkid)
|
|
|
{
|
|
|
//所有子流程结束后，父流程自动结束
|
|
|
if (isAllSubFlowOver == true)
|
|
|
{
|
|
|
if (BP.WF.Dev2Interface.Flow_NumOfSubFlowRuning(pworkid) == 0)
|
|
|
return "";
|
|
|
}
|
|
|
GenerWorkFlow gwf = new GenerWorkFlow(pworkid);
|
|
|
if (gwf.WFState == WFState.Complete)
|
|
|
return "";
|
|
|
|
|
|
return BP.WF.Dev2Interface.Flow_DoFlowOver(gwf.WorkID, "父流程[" + gwf.FlowName + "],标题为[" + gwf.Title + "]成功结束");
|
|
|
}
|
|
|
/// <summary>
|
|
|
/// 子流程结束后，处理同级子流程
|
|
|
/// </summary>
|
|
|
/// <param name="slWorkID"></param>
|
|
|
/// <param name="subFlow"></param>
|
|
|
/// <param name="gwf"></param>
|
|
|
/// <returns></returns>
|
|
|
private static string SubFlowOver_DealSLSubFlow(Int64 slWorkID, SubFlow subFlow, GenerWorkFlow gwf)
|
|
|
{
|
|
|
if (subFlow.IsAutoSendSLSubFlowOver == 0)
|
|
|
return "";
|
|
|
string slFlowNo = gwf.GetParaString("SLFlowNo");
|
|
|
Int32 slNodeID = gwf.GetParaInt("SLNodeID");
|
|
|
Flow fl = new Flow(slFlowNo);
|
|
|
GenerWorkFlow subgwf = new GenerWorkFlow(slWorkID);
|
|
|
if (subFlow.IsAutoSendSLSubFlowOver == 1)
|
|
|
{
|
|
|
if (subgwf.NodeID != slNodeID)
|
|
|
return "";
|
|
|
|
|
|
//主流程自动运行到一下节点
|
|
|
SendReturnObjs returnObjs = BP.WF.Dev2Interface.Node_SendWork(slFlowNo, slWorkID);
|
|
|
string sendSuccess = "同级子流程[" + fl.Name + "]程自动运行到下一个节点，发送过程如下：\n @接收人" + returnObjs.VarAcceptersName + "\n @下一步[" + returnObjs.VarCurrNodeName + "]启动";
|
|
|
return sendSuccess;
|
|
|
}
|
|
|
//结束父流程
|
|
|
if (subFlow.IsAutoSendSLSubFlowOver == 2)
|
|
|
{
|
|
|
if (subgwf.WFState == WFState.Complete)
|
|
|
return "";
|
|
|
return BP.WF.Dev2Interface.Flow_DoFlowOver(slWorkID, "同级子流程流程[" + fl.Name + "],WorkID为[" + slWorkID + "]成功结束");
|
|
|
}
|
|
|
return "";
|
|
|
}
|
|
|
}
|
|
|
}
|