using System;
using System.Collections.Generic;
using System.Data;
using System.Text;
using BP.GPM;
using BP.En;
using BP.DA;
using BP.Web;
using BP.Port;
using BP.Sys;
using System.Collections;

namespace BP.WF.Template
{
    /// <summary>
    /// 找人规则
    /// </summary>
    public class FindWorker
    {
        #region 变量
        public WorkNode town = null;
        public WorkNode currWn = null;
        public Flow fl = null;
        string dbStr = BP.Difference.SystemConfig.AppCenterDBVarStr;
        public Paras ps = null;
        string JumpToEmp = null;
        int JumpToNode = 0;
        Int64 WorkID = 0;
        #endregion 变量

        public FindWorker()
        {

        }
        public DataTable FindByWorkFlowModel()
        {
            this.town = town;

            Node toNode = town.HisNode;

            DataTable dt = new DataTable();
            dt.Columns.Add("No", typeof(string));
            string sql;
            string FK_Emp;

            // 如果执行了两次发送，那前一次的轨迹就需要被删除,这里是为了避免错误。
            ps = new Paras();
            ps.Add("WorkID", this.WorkID);
            ps.Add("FK_Node", town.HisNode.NodeID);
            ps.SQL = "DELETE FROM WF_GenerWorkerlist WHERE WorkID=" + dbStr + "WorkID AND FK_Node =" + dbStr + "FK_Node";
            DBAccess.RunSQL(ps);

            // 如果指定特定的人员处理。
            if (DataType.IsNullOrEmpty(JumpToEmp) == false)
            {
                string[] myEmpStrs = JumpToEmp.Split(',');
                foreach (string emp in myEmpStrs)
                {
                    if (DataType.IsNullOrEmpty(emp))
                        continue;
                    DataRow dr = dt.NewRow();
                    dr[0] = emp;
                    dt.Rows.Add(dr);
                }
                return dt;
            }

            // 按上一节点发送人处理。
            if (town.HisNode.HisDeliveryWay == DeliveryWay.ByPreviousNodeEmp)
            {
                DataRow dr = dt.NewRow();
                dr[0] = BP.Web.WebUser.No;
                dt.Rows.Add(dr);
                return dt;
            }

            //首先判断是否配置了获取下一步接受人员的sql.
            if (town.HisNode.HisDeliveryWay == DeliveryWay.BySQL
                || town.HisNode.HisDeliveryWay == DeliveryWay.BySQLTemplate
                || town.HisNode.HisDeliveryWay == DeliveryWay.BySQLAsSubThreadEmpsAndData)
            {

                if (town.HisNode.HisDeliveryWay == DeliveryWay.BySQLTemplate)
                {
                    SQLTemplate st = new SQLTemplate(town.HisNode.DeliveryParas);
                    sql = st.Docs;
                }
                else
                {
                    if (town.HisNode.DeliveryParas.Length < 4)
                        throw new Exception("@您设置的当前节点按照SQL，决定下一步的接受人员，但是你没有设置SQL.");
                    sql = town.HisNode.DeliveryParas;
                    sql = sql.Clone().ToString();
                }


                //特殊的变量.
                sql = sql.Replace("@FK_Node", this.town.HisNode.NodeID.ToString());
                sql = sql.Replace("@NodeID", this.town.HisNode.NodeID.ToString());

                sql = sql.Replace("@WorkID", this.currWn.HisWork.OID.ToString());
                sql = sql.Replace("@FID", this.currWn.HisWork.FID.ToString());


                if (this.town.HisNode.FormType == NodeFormType.RefOneFrmTree)
                {
                    GEEntity en = new GEEntity(this.town.HisNode.NodeFrmID, this.currWn.HisWork.OID);
                    sql = BP.WF.Glo.DealExp(sql, en, null);
                }
                else
                    sql = BP.WF.Glo.DealExp(sql, this.currWn.rptGe, null);


                if (sql.Contains("@GuestUser.No"))
                    sql = sql.Replace("@GuestUser.No", GuestUser.No);

                if (sql.Contains("@GuestUser.Name"))
                    sql = sql.Replace("@GuestUser.Name", GuestUser.Name);

                dt = DBAccess.RunSQLReturnTable(sql);
                if (dt.Rows.Count == 0 && town.HisNode.HisWhenNoWorker == false)
                    throw new Exception("@没有找到可接受的工作人员。@技术信息：执行的SQL没有发现人员:" + sql);
                return dt;
            }

            #region 按绑定部门计算,该部门一人处理标识该工作结束(子线程)..
            if (town.HisNode.HisDeliveryWay == DeliveryWay.BySetDeptAsSubthread)
            {
                if (this.town.HisNode.IsSubThread == false)
                    throw new Exception("@您设置的节点接收人方式为：按绑定部门计算,该部门一人处理标识该工作结束(子线程)，但是当前节点非子线程节点。");

                sql = "SELECT " + BP.Sys.Base.Glo.UserNo + ", Name,FK_Dept AS GroupMark FROM Port_Emp WHERE FK_Dept IN (SELECT FK_Dept FROM WF_NodeDept WHERE FK_Node=" + town.HisNode.NodeID + ")";
                dt = DBAccess.RunSQLReturnTable(sql);
                if (dt.Rows.Count == 0 && town.HisNode.HisWhenNoWorker == false)
                    throw new Exception("@没有找到可接受的工作人员,接受人方式为, ‘按绑定部门计算,该部门一人处理标识该工作结束(子线程)’ @技术信息：执行的SQL没有发现人员:" + sql);
                return dt;
            }
            #endregion 按绑定部门计算,该部门一人处理标识该工作结束(子线程)..

            #region 按照明细表,作为子线程的接收人.
            if (town.HisNode.HisDeliveryWay == DeliveryWay.ByDtlAsSubThreadEmps)
            {
                if (this.town.HisNode.IsSubThread == false)
                    throw new Exception("@您设置的节点接收人方式为：以分流点表单的明细表数据源确定子线程的接收人，但是当前节点非子线程节点。");

                this.currWn.HisNode.WorkID = this.WorkID; //为获取表单ID ( NodeFrmID )提供参数.
                BP.Sys.MapDtls dtls = new BP.Sys.MapDtls(this.currWn.HisNode.NodeFrmID);
                string msg = null;
                foreach (BP.Sys.MapDtl dtl in dtls)
                {
                    try
                    {
                        string empFild = town.HisNode.DeliveryParas;
                        if (DataType.IsNullOrEmpty(empFild))
                            empFild = " UserNo ";

                        ps = new Paras();
                        ps.SQL = "SELECT " + empFild + ", * FROM " + dtl.PTable + " WHERE RefPK=" + dbStr + "OID ORDER BY OID";
                        if (BP.Difference.SystemConfig.AppCenterDBType == DBType.MySQL)
                            ps.SQL = "SELECT " + empFild + ", A.* FROM " + dtl.PTable + " A WHERE RefPK=" + dbStr + "OID ORDER BY OID";
                        ps.Add("OID", this.WorkID);
                        dt = DBAccess.RunSQLReturnTable(ps);
                        if (dt.Rows.Count == 0 && town.HisNode.HisWhenNoWorker == false)
                            throw new Exception("@流程设计错误，到达的节点（" + town.HisNode.Name + "）在指定的节点中没有数据，无法找到子线程的工作人员。");
                        return dt;
                    }
                    catch (Exception ex)
                    {
                        msg += ex.Message;
                        //if (dtls.Count == 1)
                        //    throw new Exception("@估计是流程设计错误,没有在分流节点的明细表中设置");
                    }
                }
                throw new Exception("@没有找到分流节点的明细表作为子线程的发起的数据源，流程设计错误，请确认分流节点表单中的明细表是否有UserNo约定的系统字段。" + msg);
            }
            #endregion 按照明细表,作为子线程的接收人.

            #region 按节点绑定的人员处理.
            if (town.HisNode.HisDeliveryWay == DeliveryWay.ByBindEmp)
            {
                ps = new Paras();
                ps.Add("FK_Node", town.HisNode.NodeID);
                ps.SQL = "SELECT FK_Emp FROM WF_NodeEmp WHERE FK_Node=" + dbStr + "FK_Node ORDER BY FK_Emp";
                dt = DBAccess.RunSQLReturnTable(ps);
                if (dt.Rows.Count == 0)
                    throw new Exception("@流程设计错误:下一个节点(" + town.HisNode.Name + ")没有绑定工作人员 . ");
                return dt;
            }
            #endregion 按节点绑定的人员处理.

            string empNo = WebUser.No;
            string empDept = WebUser.FK_Dept;

            #region 找指定节点的人员直属领导 .
            if (town.HisNode.HisDeliveryWay == DeliveryWay.ByEmpLeader)
            {
                //查找指定节点的人员， 如果没有节点，就是当前的节点.
                string para = town.HisNode.DeliveryParas;
                if (DataType.IsNullOrEmpty(para) == true)
                    para = this.currWn.HisNode.NodeID.ToString();

                //throw new Exception("err@配置错误，当前节点是找指定节点的直属领导，但是您没有设置指定的节点ID.");

                string[] strs = para.Split(',');
                foreach (string str in strs)
                {
                    if (DataType.IsNullOrEmpty(str) == true)
                        continue;

                    ps = new Paras();
                    ps.SQL = "SELECT FK_Emp FROM WF_GenerWorkerlist WHERE WorkID=" + dbStr + "OID AND FK_Node=" + dbStr + "FK_Node ";
                    ps.Add("OID", this.WorkID);
                    ps.Add("FK_Node", int.Parse(str));
                    dt = DBAccess.RunSQLReturnTable(ps);
                    if (dt.Rows.Count != 1)
                        continue;

                    empNo = dt.Rows[0][0].ToString();

                    //查找人员的直属leader
                    sql = "";
                    if (BP.Difference.SystemConfig.CCBPMRunModel == CCBPMRunModel.Single)
                        sql = "SELECT Leader,FK_Dept FROM Port_Emp WHERE No='" + empNo + "'";
                    else
                        sql = "SELECT Leader,FK_Dept FROM Port_Emp WHERE No='" + BP.Web.WebUser.OrgNo + "_" + empNo + "'";

                    DataTable dtEmp = DBAccess.RunSQLReturnTable(sql);

                    //查找他的leader, 如果没有就找部门领导.
                    string leader = dtEmp.Rows[0][0] as string;
                    string deptNo = dtEmp.Rows[0][1] as string;
                    if (leader == null)
                    {
                        sql = "SELECT Leader FROM Port_Dept WHERE No='" + deptNo + "'";
                        leader = DBAccess.RunSQLReturnStringIsNull(sql, null);
                        if (leader == null)
                            throw new Exception("@流程设计错误:下一个节点(" + town.HisNode.Name + ")设置的按照直属领导计算，没有维护(" + WebUser.No + "," + BP.Web.WebUser.Name + ")的直属领导 . ");
                    }
                    dt = DBAccess.RunSQLReturnTable(sql);
                    return dt;
                }
            }
            #endregion .按照部门负责人计算

            #region 按照部门负责人计算. 
            if (town.HisNode.HisDeliveryWay == DeliveryWay.ByDeptLeader)
                return ByDeptLeader();

            #endregion .按照部门负责人计算

            #region 按照部门分管领导计算.
            if (town.HisNode.HisDeliveryWay == DeliveryWay.ByDeptShipLeader)
                return ByDeptShipLeader();

            #endregion .按照部门负责人计算

            #region 按照选择的人员处理。
            if (town.HisNode.HisDeliveryWay == DeliveryWay.BySelected || town.HisNode.HisDeliveryWay == DeliveryWay.BySelectedForPrj
                || town.HisNode.HisDeliveryWay == DeliveryWay.ByFEE)
            {
                ps = new Paras();
                ps.Add("FK_Node", this.town.HisNode.NodeID);
                ps.Add("WorkID", this.currWn.HisWork.OID);
                ps.SQL = "SELECT FK_Emp FROM WF_SelectAccper WHERE FK_Node=" + dbStr + "FK_Node AND WorkID=" + dbStr + "WorkID AND AccType=0 ORDER BY IDX";
                dt = DBAccess.RunSQLReturnTable(ps);
                if (dt.Rows.Count == 0)
                {
                    /*从上次发送设置的地方查询. */
                    SelectAccpers sas = new SelectAccpers();
                    int i = sas.QueryAccepterPriSetting(this.town.HisNode.NodeID);
                    if (i == 0)
                    {
                        if (town.HisNode.HisDeliveryWay == DeliveryWay.BySelected
                            || town.HisNode.HisDeliveryWay == DeliveryWay.BySelectedForPrj)
                        {
                            Node currNode = this.currWn.HisNode;
                            if (toNode.IsResetAccepter == false && toNode.HisToNDs.Contains("@" + currNode.NodeID) == true && currNode.HisToNDs.Contains("@" + toNode.NodeID) == true)
                            {
                                sql = "SELECT EmpFrom From ND" + Int32.Parse(toNode.FK_Flow) + "Track WHERE WorkID=" + this.WorkID + " AND NDFrom=" + toNode.NodeID + " AND NDTo=" + currNode.NodeID + " AND ActionType IN(0,1,6,7,11)";
                                DataTable dtt = DBAccess.RunSQLReturnTable(sql);
                                if (dtt.Rows.Count > 0)
                                {
                                    foreach (DataRow drr in dtt.Rows)
                                    {
                                        DataRow dr = dt.NewRow();
                                        dr[0] = drr[0].ToString();
                                        dt.Rows.Add(dr);
                                    }
                                    return dt;
                                }
                            }
                            Selector select = new Selector(toNode.NodeID);
                            if (select.SelectorModel == SelectorModel.GenerUserSelecter)
                                throw new Exception("url@./WorkOpt/AccepterOfGener.htm?FK_Flow=" + toNode.FK_Flow + "&FK_Node=" + this.currWn.HisNode.NodeID + "&ToNode=" + toNode.NodeID + "&WorkID=" + this.WorkID + "&PageName=AccepterOfGener");
                            else
                                throw new Exception("url@./WorkOpt/Accepter.htm?FK_Flow=" + toNode.FK_Flow + "&FK_Node=" + this.currWn.HisNode.NodeID + "&ToNode=" + toNode.NodeID + "&WorkID=" + this.WorkID + "PageName=Accepter");
                        }
                        else
                        {
                            throw new Exception("@流程设计错误，请重写FEE，然后为节点(" + town.HisNode.Name + ")设置接受人员，详细请参考cc流程设计手册。");
                        }
                    }

                    //插入里面.
                    foreach (SelectAccper item in sas)
                    {
                        DataRow dr = dt.NewRow();
                        dr[0] = item.FK_Emp;
                        dt.Rows.Add(dr);
                    }
                    return dt;
                }
                return dt;
            }
            #endregion 按照选择的人员处理。

            #region 按照指定节点的处理人计算。
            if (town.HisNode.HisDeliveryWay == DeliveryWay.BySpecNodeEmp
                || town.HisNode.HisDeliveryWay == DeliveryWay.ByStarter)
            {
                /* 按指定节点的人员计算 */
                string strs = town.HisNode.DeliveryParas;
                if (town.HisNode.HisDeliveryWay == DeliveryWay.ByStarter)
                {
                    Int64 myworkid = this.currWn.WorkID;
                    if (this.currWn.HisWork.FID != 0)
                        myworkid = this.currWn.HisWork.FID;
                    dt = DBAccess.RunSQLReturnTable("SELECT Starter as No, StarterName as Name FROM WF_GenerWorkFlow WHERE WorkID=" + myworkid);
                    if (dt.Rows.Count == 1)
                        return dt;

                    /* 有可能当前节点就是第一个节点，那个时间还没有初始化数据，就返回当前人. */
                    if (this.currWn.HisNode.IsStartNode)
                    {
                        DataRow dr = dt.NewRow();
                        dr[0] = BP.Web.WebUser.No;
                        dt.Rows.Add(dr);
                        return dt;
                    }

                    if (dt.Rows.Count == 0 && town.HisNode.HisWhenNoWorker == false)
                        throw new Exception("@流程设计错误，到达的节点（" + town.HisNode.Name + "）无法找到开始节点的工作人员。");
                    else
                        return dt;

                }

                // 首先从本流程里去找。
                strs = strs.Replace(";", ",");
                string[] ndStrs = strs.Split(',');
                foreach (string nd in ndStrs)
                {
                    if (DataType.IsNullOrEmpty(nd))
                        continue;

                    if (DataType.IsNumStr(nd) == false)
                        throw new Exception("流程设计错误:您设置的节点(" + town.HisNode.Name + ")的接收方式为按指定的节点角色投递，但是您没有在访问规则设置中设置节点编号。");

                    ps = new Paras();
                    string workSQL = "";
                    //获取指定节点的信息
                    Node specNode = new Node(nd);
                    //指定节点是子线程
                    if (specNode.IsSubThread == true)
                    {
                        if (this.currWn.HisNode.IsSubThread == true)
                            workSQL = "FID=" + this.currWn.HisWork.FID;
                        else
                            workSQL = "FID=" + this.WorkID;
                    }
                    else
                    {
                        if (this.currWn.HisNode.IsSubThread == true)
                            workSQL = "WorkID=" + this.currWn.HisWork.FID;
                        else
                            workSQL = "WorkID=" + this.WorkID;

                    }

                    ps.SQL = "SELECT DISTINCT(FK_Emp) FROM WF_GenerWorkerlist WHERE " + workSQL + " AND FK_Node=" + dbStr + "FK_Node AND IsEnable=1 ";
                    ps.Add("FK_Node", int.Parse(nd));

                    DataTable dt_ND = DBAccess.RunSQLReturnTable(ps);
                    //添加到结果表
                    if (dt_ND.Rows.Count != 0)
                    {
                        foreach (DataRow row in dt_ND.Rows)
                        {
                            DataRow dr = dt.NewRow();
                            dr[0] = row[0].ToString();
                            dt.Rows.Add(dr);
                        }
                        //此节点已找到数据则不向下找，继续下个节点
                        continue;
                    }

                    //就要到轨迹表里查,因为有可能是跳过的节点.
                    ps = new Paras();
                    ps.SQL = "SELECT DISTINCT(" + TrackAttr.EmpFrom + ") FROM ND" + int.Parse(fl.No) + "Track WHERE"
                        + " (ActionType=" + dbStr + "ActionType1 OR ActionType=" + dbStr + "ActionType2 OR ActionType=" + dbStr + "ActionType3"
                        + "  OR ActionType=" + dbStr + "ActionType4 OR ActionType=" + dbStr + "ActionType5 OR ActionType=" + dbStr + "ActionType6)"
                        + "   AND NDFrom=" + dbStr + "NDFrom AND " + workSQL;
                    ps.Add("ActionType1", (int)ActionType.Skip);
                    ps.Add("ActionType2", (int)ActionType.Forward);
                    ps.Add("ActionType3", (int)ActionType.ForwardFL);
                    ps.Add("ActionType4", (int)ActionType.ForwardHL);
                    ps.Add("ActionType5", (int)ActionType.SubThreadForward);
                    ps.Add("ActionType6", (int)ActionType.Start);
                    ps.Add("NDFrom", int.Parse(nd));

                    dt_ND = DBAccess.RunSQLReturnTable(ps);
                    if (dt_ND.Rows.Count != 0)
                    {
                        foreach (DataRow row in dt_ND.Rows)
                        {
                            DataRow dr = dt.NewRow();
                            dr[0] = row[0].ToString();
                            dt.Rows.Add(dr);
                        }
                        continue;
                    }

                    //从Selector中查找
                    ps = new Paras();
                    ps.SQL = "SELECT DISTINCT(FK_Emp) FROM WF_SelectAccper WHERE FK_Node=" + dbStr + "FK_Node AND " + workSQL;
                    ps.Add("FK_Node", int.Parse(nd));


                    dt_ND = DBAccess.RunSQLReturnTable(ps);
                    //添加到结果表
                    if (dt_ND.Rows.Count != 0)
                    {
                        foreach (DataRow row in dt_ND.Rows)
                        {
                            DataRow dr = dt.NewRow();
                            dr[0] = row[0].ToString();
                            dt.Rows.Add(dr);
                        }
                        //此节点已找到数据则不向下找，继续下个节点
                        continue;
                    }


                }

                //本流程里没有有可能该节点是配置的父流程节点,也就是说子流程的一个节点与父流程指定的节点的工作人员一致.
                GenerWorkFlow gwf = new GenerWorkFlow(this.WorkID);
                if (gwf.PWorkID != 0)
                {
                    foreach (string pnodeiD in ndStrs)
                    {
                        if (DataType.IsNullOrEmpty(pnodeiD))
                            continue;

                        Node nd = new Node(int.Parse(pnodeiD));
                        if (nd.FK_Flow != gwf.PFlowNo)
                            continue; // 如果不是父流程的节点，就不执行.

                        ps = new Paras();
                        ps.SQL = "SELECT FK_Emp FROM WF_GenerWorkerlist WHERE WorkID=" + dbStr + "OID AND FK_Node=" + dbStr + "FK_Node AND IsPass=1 AND IsEnable=1 ";
                        ps.Add("FK_Node", nd.NodeID);
                        if (this.currWn.HisNode.IsSubThread == true)
                            ps.Add("OID", gwf.PFID);
                        else
                            ps.Add("OID", gwf.PWorkID);

                        DataTable dt_PWork = DBAccess.RunSQLReturnTable(ps);
                        if (dt_PWork.Rows.Count != 0)
                        {
                            foreach (DataRow row in dt_PWork.Rows)
                            {
                                DataRow dr = dt.NewRow();
                                dr[0] = row[0].ToString();
                                dt.Rows.Add(dr);
                            }
                            //此节点已找到数据则不向下找，继续下个节点
                            continue;
                        }

                        //就要到轨迹表里查,因为有可能是跳过的节点.
                        ps = new Paras();
                        ps.SQL = "SELECT " + TrackAttr.EmpFrom + " FROM ND" + int.Parse(fl.No) + "Track WHERE (ActionType=" + dbStr + "ActionType1 OR ActionType=" + dbStr + "ActionType2 OR ActionType=" + dbStr + "ActionType3 OR ActionType=" + dbStr + "ActionType4 OR ActionType=" + dbStr + "ActionType5) AND NDFrom=" + dbStr + "NDFrom AND WorkID=" + dbStr + "WorkID";
                        ps.Add("ActionType1", (int)ActionType.Start);
                        ps.Add("ActionType2", (int)ActionType.Forward);
                        ps.Add("ActionType3", (int)ActionType.ForwardFL);
                        ps.Add("ActionType4", (int)ActionType.ForwardHL);
                        ps.Add("ActionType5", (int)ActionType.Skip);

                        ps.Add("NDFrom", nd.NodeID);

                        if (this.currWn.HisNode.IsSubThread == true)
                            ps.Add("WorkID", gwf.PFID);
                        else
                            ps.Add("WorkID", gwf.PWorkID);

                        dt_PWork = DBAccess.RunSQLReturnTable(ps);
                        if (dt_PWork.Rows.Count != 0)
                        {
                            foreach (DataRow row in dt_PWork.Rows)
                            {
                                DataRow dr = dt.NewRow();
                                dr[0] = row[0].ToString();
                                dt.Rows.Add(dr);
                            }
                        }
                    }
                }
                //返回指定节点的处理人
                if (dt.Rows.Count != 0)
                    return dt;

                throw new Exception("@流程设计错误，到达的节点（" + town.HisNode.Name + "）在指定的节点(" + strs + ")中没有数据，无法找到工作的人员。 @技术信息如下: 投递方式:BySpecNodeEmp sql=" + ps.SQLNoPara);
            }
            #endregion 按照节点绑定的人员处理。

            #region 按照上一个节点表单指定字段的人员处理。
            if (town.HisNode.HisDeliveryWay == DeliveryWay.ByPreviousNodeFormEmpsField)
            {
                // 为河南安防增加接受人规则按从表获取. 
                int A5DataFrom = town.HisNode.GetParaInt("A5DataFrom");
                // 检查接受人员规则,是否符合设计要求.
                string specEmpFields = town.HisNode.DeliveryParas;
                if (DataType.IsNullOrEmpty(specEmpFields))
                    specEmpFields = "SysSendEmps";

                string emps = "";
                DataTable dtVals = null;

                #region 0.按主表的字段计算.
                if (A5DataFrom == 0)
                {
                    if (this.currWn.rptGe.EnMap.Attrs.Contains(specEmpFields) == false)
                        throw new Exception("@您设置的接受人规则是按照表单指定的字段，决定下一步的接受人员，该字段{" + specEmpFields + "}已经删除或者丢失。");

                    //获得数据.
                    dt = BP.WF.CCFormAPI.GenerPopData2022(this.WorkID.ToString(), specEmpFields);
                    if (dt.Rows.Count == 0 && town.HisNode.HisWhenNoWorker == false)
                        throw new Exception("@没有在字段[ " + specEmpFields + " ]中指定接受人，工作无法向下发送。");
                    return dt;
                }
                #endregion 按主表的字段计算.

                #region 1.按从表的字段计算.
                string dtlID = this.town.HisNode.GetParaString("A5DataDtl");
                if (dtlID != null)
                    throw new Exception("@到达节点[" + this.town.HisNode.Name + "]的接受人规则是按照从表的字段计算，但是您没有配置从表的字段");

                MapDtl dtl = new MapDtl();
                dtl.No = dtlID;
                if (dtl.RetrieveFromDBSources() == 0)
                    throw new Exception("@到达节点[" + this.town.HisNode.Name + "]的接受人规则是按照从表的字段计算，从表[" + dtlID + "]被删除.");


                MapAttrs dtlAttrs = new MapAttrs();
                dtlAttrs.Retrieve("FK_MapData", dtlID);

                if (dtlAttrs.GetCountByKey("KeyOfEn", specEmpFields) == 0)
                    throw new Exception("@到达节点[" + this.town.HisNode.Name + "]的接受人规则是按照从表的字段计算，从表[" + dtlID + "]的字段[" + specEmpFields + "]，被删除.");

                //获得数据.
                dt = BP.WF.CCFormAPI.GenerPopData2022(this.WorkID.ToString(), specEmpFields);
                if (dt.Rows.Count == 0 && town.HisNode.HisWhenNoWorker == false)
                    throw new Exception("@没有在字段[ " + specEmpFields + " ]中指定接受人，工作无法向下发送。");
                #endregion 按从表的字段计算.
            }
            #endregion 按照上一个节点表单指定字段的人员处理。

            #region 绑定字典表。
            if (town.HisNode.HisDeliveryWay == DeliveryWay.BySFTable)
            {
                String pkval = town.HisNode.DeliveryParas;
                SFTable table = new SFTable(pkval);
                DataTable mydtTable = table.GenerHisDataTable(this.currWn.rptGe.Row);
                return mydtTable;
            }
            #endregion 绑定字典表。


            #region 按照上一个节点表单指定字段的 【部门】处理。
            if (town.HisNode.HisDeliveryWay == DeliveryWay.ByPreviousNodeFormDepts)
            {
                // 检查接受人员规则,是否符合设计要求.
                String specEmpFields = town.HisNode.DeliveryParas;
                if (DataType.IsNullOrEmpty(specEmpFields) == true)
                    throw new Exception("@您设置的接受人规则是按照表单指定的字段是部门，但是没有选择表单字段");
                if (this.currWn.rptGe.EnMap.Attrs.Contains(specEmpFields) == false)
                    throw new Exception("@您设置的接受人规则是按照表单指定的部门字段，决定下一步的接受人员，该字段{" + specEmpFields + "}已经删除或者丢失。");

                //判断该字段是否启用了pop返回值？
                sql = "SELECT  Tag1 AS VAL FROM Sys_FrmEleDB WHERE RefPKVal=" + this.WorkID + " AND EleID='" + specEmpFields + "'";
                String depts = "";
                DataTable dtVals = DBAccess.RunSQLReturnTable(sql);

                //获取接受人并格式化接受人,
                if (dtVals.Rows.Count > 0)
                {
                    foreach (DataRow dr in dtVals.Rows)
                    {
                        depts += dr[0].ToString() + ",";
                    }
                }
                else
                {
                    depts = this.currWn.rptGe.GetValStringByKey(specEmpFields);
                }


                depts = depts.Replace(" ", ""); //去掉空格.
                if (depts.EndsWith(","))
                    depts = depts.Substring(0, depts.Length - 1);
                if (DataType.IsNullOrEmpty(depts) == false)
                {
                    depts = "'" + depts.Replace(",", "','") + "'";
                }

                if (DataType.IsNullOrEmpty(depts) == true)
                    throw new Exception("@您设置的接受人规则是按照表单指定的部门字段，没有选择部门");
                //获取人员
                sql = "SELECT DISTINCT(FK_Emp) From Port_DeptEmp WHERE FK_Dept IN(" + depts + ")";
                DataTable dtt = DBAccess.RunSQLReturnTable(sql);
                if (dtt.Rows.Count == 0)
                    throw new Exception("@您设置的接受人规则是按照表单指定的部门字段，填写的部门中不存在人员");
                return dtt;
            }
            #endregion 按照上一个节点表单指定字段的 【部门】处理。

            #region 按照上一个节点表单指定字段的 【角色】处理。
            if (town.HisNode.HisDeliveryWay == DeliveryWay.ByPreviousNodeFormStationsAI
            || town.HisNode.HisDeliveryWay == DeliveryWay.ByPreviousNodeFormStationsOnly)
            {
                // 检查接受人员规则,是否符合设计要求.
                string specEmpFields = town.HisNode.DeliveryParas;
                if (DataType.IsNullOrEmpty(specEmpFields))
                    specEmpFields = "SysSendEmps";

                if (this.currWn.rptGe.EnMap.Attrs.Contains(specEmpFields) == false)
                    throw new Exception("@您设置的接受人规则是按照表单指定的角色字段，决定下一步的接受人员，该字段{" + specEmpFields + "}已经删除或者丢失。");

                //判断该字段是否启用了pop返回值？
                sql = "SELECT  Tag1 AS VAL FROM Sys_FrmEleDB WHERE RefPKVal=" + this.WorkID + " AND EleID='" + specEmpFields + "'";
                string emps = "";
                DataTable dtVals = DBAccess.RunSQLReturnTable(sql);

                //获得角色信息.
                string stas = "";

                //获取接受人并格式化接受人, 
                if (dtVals.Rows.Count > 0)
                {
                    foreach (DataRow dr in dtVals.Rows)
                        emps += dr[0].ToString() + ",";
                }
                else
                {
                    emps = this.currWn.rptGe.GetValStringByKey(specEmpFields);
                }
                emps = emps.Replace(" ", ""); //去掉空格.
                if (emps.Contains(",") && emps.Contains(";"))
                {
                    /*如果包含,; 例如 zhangsan,张三;lisi,李四;*/
                    string[] myemps1 = emps.Split(';');
                    foreach (string str in myemps1)
                    {
                        if (DataType.IsNullOrEmpty(str))
                            continue;

                        string[] ss = str.Split(',');
                        stas += "," + ss[0];

                        //DataRow dr = dt.NewRow();
                        // = ss[0];
                        //dt.Rows.Add(dr);
                    }
                    if (dt.Rows.Count == 0 && town.HisNode.HisWhenNoWorker == false)
                        throw new Exception("@输入的接受人员角色信息错误;[" + emps + "]。");
                    else
                        return dt;
                }
                else
                {
                    emps = emps.Replace(";", ",");
                    emps = emps.Replace("；", ",");
                    emps = emps.Replace("，", ",");
                    emps = emps.Replace("、", ",");
                    emps = emps.Replace("@", ",");

                    if (DataType.IsNullOrEmpty(emps) && town.HisNode.HisWhenNoWorker == false)
                        throw new Exception("@没有在字段[" + this.currWn.HisWork.EnMap.Attrs.GetAttrByKey(specEmpFields).Desc + "]中指定接受人，工作无法向下发送。");

                    // 把它加入接受人员列表中.
                    string[] myemps = emps.Split(',');


                    int nodeID = town.HisNode.NodeID;
                    //NodeStation ns = new NodeStation();
                    //ns.Delete(NodeStationAttr.FK_Node, nodeID);

                    foreach (string s in myemps)
                    {
                        if (DataType.IsNullOrEmpty(s))
                            continue;
                        stas += "," + s;
                    }
                }

                if (DataType.IsNullOrEmpty(stas) == true)
                    throw new Exception("err@按照上一个节点表单指定字段的,没有找到选择的岗位信息.");

                //根据角色：集合获取信息.
                stas = stas.Substring(1);

                //把这次的岗位s存储到临时变量,以方便用到下一个节点多人处理规则，按岗位删除时用到。
                this.currWn.HisGenerWorkFlow.SetPara("NodeStas" + town.HisNode.NodeID, stas);


                // 仅按角色计算.  以下都有要重写.
                if (toNode.HisDeliveryWay == DeliveryWay.ByPreviousNodeFormStationsOnly)
                {
                    dt = WorkFlowBuessRole.FindWorker_GetEmpsByStations(stas);
                    if (dt.Rows.Count == 0 && toNode.HisWhenNoWorker == false)
                        throw new Exception("err@按照字段角色(仅按角色计算)找接受人错误,当前部门下没有您选择的角色人员.");

                    return dt;
                }

                #region 按角色智能计算, 还是集合模式.
                if (toNode.DeliveryStationReqEmpsWay == 0)
                {
                    string deptNo = BP.Web.WebUser.FK_Dept;
                    dt = WorkFlowBuessRole.FindWorker_GetEmpsByDeptAI(stas, deptNo);
                    if (dt.Rows.Count == 0 && toNode.HisWhenNoWorker == false)
                        throw new Exception("err@按照字段角色(智能)找接受人错误,当前部门与父级部门下没有您选择的角色人员.");
                    return dt;
                }
                #endregion 按角色智能计算, 要判断切片模式,还是集合模式.

                #region 按角色智能计算, 切片模式. 需要对每个角色都要找到接受人，然后把这些接受人累加起来.
                if (toNode.DeliveryStationReqEmpsWay == 1 || toNode.DeliveryStationReqEmpsWay == 2)
                {
                    string deptNo = BP.Web.WebUser.FK_Dept;
                    string[] temps = stas.Split(',');
                    foreach (string str in temps)
                    {
                        //求一个角色下的人员.
                        DataTable mydt1 = WorkFlowBuessRole.FindWorker_GetEmpsByDeptAI(str, deptNo);

                        //如果是严谨模式.
                        if (toNode.DeliveryStationReqEmpsWay == 1 && mydt1.Rows.Count == 0)
                        {
                            Station st = new Station(str);
                            throw new Exception("@角色[" + st.Name + "]下，没有找到人不能发送下去，请检查组织结构是否完整。");
                        }

                        //累加.
                        foreach (DataRow dr in mydt1.Rows)
                        {
                            DataRow mydr = dt.NewRow();
                            mydr[0] = dr[0].ToString();
                            dt.Rows.Add(mydr);
                        }
                    }
                }
                #endregion 按角色智能计算, 切片模式.

                return dt;
            }
            #endregion 按照上一个节点表单指定字段的[角色]人员处理.

            #region 为省立医院增加，按照指定的部门范围内的角色计算..
            if (town.HisNode.HisDeliveryWay == DeliveryWay.FindSpecDeptEmpsInStationlist)
            {
                //sql = "SELECT pdes.FK_Emp AS No"
                //      + " FROM   Port_DeptEmpStation pdes"
                //      + " INNER JOIN WF_NodeDept wnd ON wnd.FK_Dept = pdes.FK_Dept"
                //      + " AND wnd.FK_Node = " + town.HisNode.NodeID
                //      + " INNER JOIN WF_NodeStation wns ON  wns.FK_Station = pdes.FK_Station"
                //      + " AND wns.FK_Node =" + town.HisNode.NodeID
                //      + " ORDER BY pdes.FK_Emp";

                sql = "SELECT A.FK_Emp FROM Port_DeptEmpStation A WHERE A.FK_DEPT ='" + BP.Web.WebUser.FK_Dept + "' AND A.FK_Station in(";
                sql += "select FK_Station from WF_NodeStation where FK_node=" + town.HisNode.NodeID + ")";

                dt = DBAccess.RunSQLReturnTable(sql);

                if (dt.Rows.Count > 0)
                    return dt;
                else
                {
                    if (this.town.HisNode.HisWhenNoWorker == false)
                        throw new Exception("@节点访问规则(" + town.HisNode.HisDeliveryWay.ToString() + ")错误:节点(" + town.HisNode.NodeID + "," + town.HisNode.Name + "), 按照角色与部门的交集确定接受人的范围错误，没有找到人员:SQL=" + sql);
                    else
                        return dt;
                }
            }
            #endregion 按部门与角色的交集计算.

            #region 按部门与角色的交集计算.
            if (town.HisNode.HisDeliveryWay == DeliveryWay.ByDeptAndStation)
            {
                //added by liuxc,2015.6.29.

                sql = "SELECT pdes.FK_Emp AS No"
                     + " FROM   Port_DeptEmpStation pdes"
                     + " INNER JOIN WF_NodeDept wnd ON wnd.FK_Dept = pdes.FK_Dept"
                     + " AND wnd.FK_Node = " + town.HisNode.NodeID
                     + " INNER JOIN WF_NodeStation wns ON  wns.FK_Station = pdes.FK_Station"
                     + " AND wns.FK_Node =" + town.HisNode.NodeID
                     + " ORDER BY pdes.FK_Emp";


                dt = DBAccess.RunSQLReturnTable(sql);

                if (dt.Rows.Count > 0)
                    return dt;
                else
                {
                    if (this.town.HisNode.HisWhenNoWorker == false)
                        throw new Exception("@节点访问规则(" + town.HisNode.HisDeliveryWay.ToString() + ")错误:节点(" + town.HisNode.NodeID + "," + town.HisNode.Name + "), 按照角色与部门的交集确定接受人的范围错误，没有找到人员:SQL=" + sql);
                    else
                        return dt;
                }
            }
            #endregion 按部门与角色的交集计算.

            #region 判断节点部门里面是否设置了部门，如果设置了就按照它的部门处理。
            if (town.HisNode.HisDeliveryWay == DeliveryWay.ByDept)
            {
                ps = new Paras();
                ps.Add("FK_Node", this.town.HisNode.NodeID);
                ps.SQL = "SELECT A.No,A.Name FROM Port_Emp A,Port_DeptEmp B WHERE A.No=B.FK_Emp AND B.FK_Dept IN(SELECT FK_dept FROM WF_NodeDept WHERE FK_Node =" + dbStr + "FK_Node)";
                dt = DBAccess.RunSQLReturnTable(ps);
                if (dt.Rows.Count == 0)
                {
                    throw new Exception("err@按照 [按绑定的部门计算] 计算接收人的时候出现错误，没有找到人，请检查节点绑定的部门下的人员.");
                }
                return dt;
            }
            #endregion 判断节点部门里面是否设置了部门，如果设置了，就按照它的部门处理。

            #region 用户组 计算 
            if (town.HisNode.HisDeliveryWay == DeliveryWay.ByTeamOnly)
            {
                ps = new Paras();
                sql = "SELECT A.FK_Emp FROM Port_TeamEmp A, WF_NodeTeam B WHERE A.FK_Team=B.FK_Team AND B.FK_Node=" + town.HisNode.NodeID;
                dt = DBAccess.RunSQLReturnTable(sql);
                if (dt.Rows.Count > 0)
                    return dt;

                if (this.town.HisNode.HisWhenNoWorker == false)
                    throw new Exception("@节点访问规则错误:节点(" + town.HisNode.NodeID + "," + town.HisNode.Name + "), 仅按用户组计算，没有找到人员:SQL=" + sql);
                else
                    return dt;  //可能处理跳转,在没有处理人的情况下.
            }
            if (town.HisNode.HisDeliveryWay == DeliveryWay.ByTeamOrgOnly)
            {
                sql = "SELECT DISTINCT A.FK_Emp FROM Port_TeamEmp A, WF_NodeTeam B  WHERE A.FK_Team=B.FK_Team AND B.FK_Node=" + toNode.NodeID;
                dt = DBAccess.RunSQLReturnTable(sql);
                if (dt.Rows.Count > 0)
                    return dt;

                if (this.town.HisNode.HisWhenNoWorker == false)
                    throw new Exception("@节点访问规则错误:节点(" + town.HisNode.NodeID + "," + town.HisNode.Name + "), 仅按用户组计算，没有找到人员:SQL=" + sql);

                return dt;  //可能处理跳转,在没有处理人的情况下.
            }

            if (town.HisNode.HisDeliveryWay == DeliveryWay.ByTeamDeptOnly)
            {
                sql = "SELECT DISTINCT A.FK_Emp FROM Port_TeamEmp A, WF_NodeTeam B, Port_DeptEmp C WHERE A.FK_Emp=C.FK_Emp AND A.FK_Team=B.FK_Team AND B.FK_Node=" + toNode.NodeID + " AND C.FK_Dept='" + BP.Web.WebUser.FK_Dept + "'";
                dt = DBAccess.RunSQLReturnTable(sql);
                if (dt.Rows.Count > 0)
                    return dt;

                if (this.town.HisNode.HisWhenNoWorker == false)
                    throw new Exception("@节点访问规则错误 ByTeamDeptOnly :节点(" + town.HisNode.NodeID + "," + town.HisNode.Name + "), 仅按用户组计算，没有找到人员:SQL=" + sql);

                return dt;  //可能处理跳转,在没有处理人的情况下.
            }
            #endregion

            #region 56.按照指定的部门集合与节点设置角色交集计算.
            if (town.HisNode.HisDeliveryWay == DeliveryWay.ByStationSpecDepts)
            {
                Node nd = town.HisNode;
                string sqlDepts = nd.ARDeptModelDeptsSQL(this.town.WorkID); // 获得部门的sqls.
                DataTable dtDepts = DBAccess.RunSQLReturnTable(sqlDepts);
                int dgModel = nd.GetParaInt("DGModel56");
                if (dtDepts.Rows.Count == 1)
                {
                    //如果只有一个部门.
                    string deptNo = dtDepts.Rows[0][0].ToString();

                    #region 判断递归模式. 0=递归并累加,递归到根节点,并把找到的人累加起来.
                    if (dgModel == 0)
                    {
                        DataTable dtEmps = new DataTable(); //定义容器.
                        dtEmps.Columns.Add("EmpNo");
                        while (true)
                        {
                            string mysql = " SELECT FK_Emp FROM Port_DeptEmpStation A,WF_NodeStation B WHERE A.FK_Station=B.FK_Station AND B.FK_Node=" + nd.NodeID + " AND A.FK_Dept='" + deptNo + "'";
                            dt = DBAccess.RunSQLReturnTable(mysql);
                            //插入里面去.
                            foreach (DataRow dr in dt.Rows)
                            {
                                DataRow mydr = dtEmps.NewRow();
                                mydr[0] = dr[0];
                                dtEmps.Rows.Add(mydr);
                            }
                            //找到上一级部门.
                            deptNo = DBAccess.RunSQLReturnStringIsNull("SELECT ParentNo FROM Port_Dept WHERE No='" + deptNo + "'", null).ToString();
                            if (deptNo == null || deptNo.Equals("0") == true)
                                break;
                            continue;
                        }

                        //判断是否有此数据.
                        if (dtEmps.Rows.Count==0)
                            throw new Exception("err@到达节点[" + this.town.HisNode.Name + "],接受人规则是[按照指定的部门集合与节点设置角色交集计算],没有获得接受人.");
                        return dtEmps;
                    }
                    #endregion 判断递归模式. 0=递归并累加,递归到根节点,并把找到的人累加起来.

                    #region 判断递归模式. 1=递归不累加,向根节点递归,如果找到人,就不在递归了.
                    if (dgModel == 1)
                    {
                        while (true)
                        {
                            string mysql = " SELECT FK_Emp FROM Port_DeptEmpStation A,WF_NodeStation B WHERE A.FK_Station=B.FK_Station AND B.FK_Node=" + nd.NodeID + " AND A.FK_Dept='" + deptNo + "'";
                            dt = DBAccess.RunSQLReturnTable(mysql);
                            if (dt.Rows.Count == 0)
                            {
                                deptNo = DBAccess.RunSQLReturnStringIsNull("SELECT ParentNo FROM Port_Dept WHERE No='" + deptNo + "'", null).ToString();
                                if (deptNo == null || deptNo.Equals("0") == true)
                                    throw new Exception("err@到达节点[" + this.town.HisNode.Name + "],接受人规则是[按照指定的部门集合与节点设置角色交集计算],没有获得接受人.");
                                continue;
                            }
                            return dt;
                        }
                    }
                    #endregion 判断递归模式.1=递归不累加,向根节点递归,如果找到人,就不在递归了.

                    #region 判断递归模式. 2=不递归, 仅仅按照指定的部门寻找.
                    if (dgModel == 2)
                    {
                        string mysql = " SELECT FK_Emp FROM Port_DeptEmpStation A,WF_NodeStation B WHERE A.FK_Station=B.FK_Station AND B.FK_Node=" + nd.NodeID + " AND A.FK_Dept='" + deptNo + "'";
                        dt = DBAccess.RunSQLReturnTable(mysql);
                        if (dt.Rows.Count == 0)
                            throw new Exception("err@到达节点[" + this.town.HisNode.Name + "],接受人规则是[按照指定的部门集合与节点设置角色交集计算],没有获得接受人.");
                        return dt;
                    }
                    #endregion 判断递归模式.2=不递归, 仅仅按照指定的部门寻找.
                }

                string sqlStations = "SELECT FK_Station FROM WF_NodeStation WHERE FK_Node=" + nd.NodeID;
                //获得两个的交集.
                string mysql1 = " SELECT FK_Emp FROM Port_DeptEmpStation WHERE FK_Station IN(" + sqlStations + ") AND FK_Dept IN (" + sqlDepts + ")";
                dt = DBAccess.RunSQLReturnTable(mysql1);
                if (dt.Rows.Count == 0)
                    throw new Exception("err@到达节点[" + this.town.HisNode.Name + "],接受人规则是[按照指定的部门集合与节点设置角色交集计算],没有获得接受人.");
                return dt;
            }
            #endregion 按照指定的角色集合与部门的交集计算


            #region 57. 按照指定的角色集合与节点设置部门交集计算.
            if (town.HisNode.HisDeliveryWay == DeliveryWay.ByStationSpecStas)
            {
                Node nd = town.HisNode;
                string sqlStations = nd.ARStaModelStasSQL(this.town.WorkID); //获得部门的sqls.
                string sqlDepts = "SELECT FK_Dept FROM WF_NodeDept WHERE FK_Node=" + nd.NodeID;
                DataTable dtDepts = DBAccess.RunSQLReturnTable(sqlDepts);
                if (dtDepts.Rows.Count == 1)
                {
                    //如果只有一个部门.
                    string deptNo = dtDepts.Rows[0][0].ToString();
                    while (true)
                    {
                        string mysql = "SELECT FK_Emp FROM Port_DeptEmpStation A WHERE FK_Station IN ("+ sqlStations + ")  FK_Dept='" + deptNo + "'";
                        dt = DBAccess.RunSQLReturnTable(mysql);
                        if (dt.Rows.Count == 0)
                        {
                            deptNo = DBAccess.RunSQLReturnStringIsNull("SELECT ParentNo FROM Port_Dept WHERE No='" + deptNo + "'",null).ToString();
                            if (deptNo==null || deptNo.Equals("0") == true)
                                throw new Exception("err@到达节点[" + this.town.HisNode.Name + "],接受人规则是[按照指定的角色集合与节点设置部门交集计算],没有获得接受人." );
                            continue;
                        }
                        return dt;
                    }
                }

                //获得两个的交集.
                string mysql1 = " SELECT FK_Emp FROM Port_DeptEmpStation WHERE FK_Station IN(" + sqlStations + ") AND FK_Dept IN (" + sqlDepts + ")";
                dt = DBAccess.RunSQLReturnTable(mysql1);
                if (dt.Rows.Count == 0)
                    throw new Exception("err@到达节点[" + this.town.HisNode.Name + "],接受人规则是[按照指定的角色集合与节点设置部门交集计算],没有获得接受人.");
                return dt;
            }
            #endregion 按照指定的部门集合与岗位的交集计算

         


            #region 仅按角色计算
            if (town.HisNode.HisDeliveryWay == DeliveryWay.ByStationOnly)
            {
                ps = new Paras();
                if (BP.Difference.SystemConfig.CCBPMRunModel == CCBPMRunModel.SAAS)
                {
                    //2020-4-25 按照角色倒序排序 修改原因队列模式时，下级角色处理后发给上级角色， 角色越高数值越小
                    sql = "SELECT A.FK_Emp FROM Port_DeptEmpStation A, WF_NodeStation B WHERE A.FK_Station=B.FK_Station AND A.OrgNo=" + dbStr + "OrgNo AND B.FK_Node=" + dbStr + "FK_Node ORDER BY A.FK_Station desc";
                    ps.Add("OrgNo", BP.Web.WebUser.OrgNo);
                    ps.Add("FK_Node", town.HisNode.NodeID);
                    ps.SQL = sql;
                    dt = DBAccess.RunSQLReturnTable(ps);
                }
                else
                {
                    //2020-4-25 按照角色倒序排序 修改原因队列模式时，下级角色处理后发给上级角色， 角色越高数值越小
                    sql = "SELECT A.FK_Emp FROM Port_DeptEmpStation A, WF_NodeStation B WHERE A.FK_Station=B.FK_Station AND B.FK_Node=" + dbStr + "FK_Node ORDER BY A.FK_Station desc";
                    ps.Add("FK_Node", town.HisNode.NodeID);
                    ps.SQL = sql;
                    dt = DBAccess.RunSQLReturnTable(ps);
                }
                if (dt.Rows.Count > 0)
                    return dt;

                if (this.town.HisNode.HisWhenNoWorker == false)
                {
                    //   throw new Exception("@节点访问规则错误:节点(" + town.HisNode.NodeID + "," + town.HisNode.Name + "), 仅按角色计算，没有找到人员:SQL=" + ps.SQLNoPara);
                    throw new Exception("@节点访问规则错误:流程[" + town.HisNode.FlowName + "]节点[" + town.HisNode.NodeID + "," + town.HisNode.Name + "], 仅按角色计算，没有找到人员。");
                }

                return dt;  //可能处理跳转,在没有处理人的情况下.
            }
            #endregion

            #region 按配置的人员路由表计算
            if (town.HisNode.HisDeliveryWay == DeliveryWay.ByFromEmpToEmp)
            {
                string[] fromto = town.HisNode.DeliveryParas.Split('@');

                string defUser = "";

                foreach (string str in fromto)
                {
                    string[] kv = str.Split(',');

                    if (kv[0].Equals("Defalut") == true)
                    {
                        defUser = kv[1];
                        continue;
                    }

                    if (kv[0] == WebUser.No)
                    {
                        string empTo = kv[1];
                        //BP.Port.Emp emp = new BP.Port.Emp(empTo);
                        DataRow dr = dt.NewRow();
                        dr[0] = empTo;
                        //  dr[1] = emp.Name;
                        dt.Rows.Add(dr);
                        return dt;
                    }
                }

                if (DataType.IsNullOrEmpty(defUser) == false)
                {
                    string empTo = defUser;
                    DataRow dr = dt.NewRow();
                    dr[0] = empTo;
                    dt.Rows.Add(dr);
                    return dt;
                }

                throw new Exception("@接收人规则是按照人员路由表设置的，但是系统管理员没有为您配置路由,当前节点;" + town.HisNode.Name);
            }
            #endregion

            /*#region 按角色计算(以部门集合为纬度).
            if (town.HisNode.HisDeliveryWay == DeliveryWay.ByStationAndEmpDept)
            {
                *//* 考虑当前操作人员的部门, 如果本部门没有这个角色就不向上寻找. *//*

                if (BP.Difference.SystemConfig.CCBPMRunModel == CCBPMRunModel.SAAS)
                {
                    ps = new Paras();
                    ps.SQL = "SELECT UserID as No,Name FROM Port_Emp WHERE UserID=" + dbStr + "FK_Emp AND OrgNo=" + dbStr + "OrgNo ";
                    ps.Add("FK_Emp", WebUser.No);
                    ps.Add("OrgNo", WebUser.OrgNo);

                    dt = DBAccess.RunSQLReturnTable(ps);
                }
                else
                {
                    ps = new Paras();
                    ps.SQL = "SELECT No,Name FROM Port_Emp WHERE No=" + dbStr + "FK_Emp ";
                    ps.Add("FK_Emp", WebUser.No);
                    dt = DBAccess.RunSQLReturnTable(ps);

                }

                if (dt.Rows.Count > 0)
                    return dt;
                else
                {
                    if (this.town.HisNode.HisWhenNoWorker == false)
                        throw new Exception("@节点访问规则(" + town.HisNode.HisDeliveryWay.ToString() + ")错误:节点(" + town.HisNode.NodeID + "," + town.HisNode.Name + "), 按角色计算(以部门集合为纬度)。技术信息,执行的SQL=" + ps.SQLNoPara);
                    else
                        return dt; //可能处理跳转,在没有处理人的情况下.
                }
            }
            #endregion*/

            #region 按照自定义的URL来计算 
            if (town.HisNode.HisDeliveryWay == DeliveryWay.BySelfUrl)
            {
                ps = new Paras();
                ps.Add("FK_Node", this.town.HisNode.NodeID);
                ps.Add("WorkID", this.currWn.HisWork.OID);
                ps.SQL = "SELECT FK_Emp FROM WF_SelectAccper WHERE FK_Node=" + dbStr + "FK_Node AND WorkID=" + dbStr + "WorkID AND AccType=0 ORDER BY IDX";
                dt = DBAccess.RunSQLReturnTable(ps);
                if (dt.Rows.Count == 0)
                {
                    /*从上次发送设置的地方查询. */
                    SelectAccpers sas = new SelectAccpers();
                    int i = sas.QueryAccepterPriSetting(this.town.HisNode.NodeID);
                    if (i == 0)
                    {
                        GenerWorkFlow gwf = new GenerWorkFlow(this.WorkID);
                        if (DataType.IsNullOrEmpty(toNode.DeliveryParas) == true)
                            throw new Exception("节点" + toNode.NodeID + "_" + toNode.Name + "设置的接收人规则是自定义的URL,现在未获取到设置的信息");
                        else
                            throw new Exception("BySelfUrl@" + toNode.DeliveryParas + "?FK_Flow=" + toNode.FK_Flow + "&FK_Node=" + this.currWn.HisNode.NodeID + "&ToNode=" + toNode.NodeID + "&WorkID=" + this.WorkID + "&PWorkID=" + gwf.PWorkID + "&FID=" + gwf.FID);
                    }

                    //插入里面.
                    foreach (SelectAccper item in sas)
                    {
                        DataRow dr = dt.NewRow();
                        dr[0] = item.FK_Emp;
                        dt.Rows.Add(dr);
                    }
                    return dt;
                }
                return dt;
            }
            #endregion 按照自定义的URL来计算

            #region 按照设置的WebAPI接口获取的数据计算 - 新版本.
            if (town.HisNode.HisDeliveryWay == DeliveryWay.ByAPIUrl)
            {
                //组织参数.
                string paras = "@WorkID=" + this.WorkID + "@OID=" + this.WorkID;

                var part = new Part("AR" + this.town.HisNode.NodeID);
                string strs = part.ARWebApi(paras);
                if (strs.Equals("err@") == true)
                    throw new Exception(strs);

                strs = strs.Replace("，", ",");
                strs = strs.Replace(";", ",");
                strs = strs.Replace("；", ",");

                string[] mystars = strs.Split(',');

                foreach (string str in mystars)
                {
                    DataRow dr = dt.NewRow();
                    dr["No"] = str;
                    dt.Rows.Add(dr);
                }
                return dt;
            }
            #endregion 按照设置的WebAPI接口获取的数据计算

            #region 按照设置的WebAPI接口获取的数据计算(旧版本)
            if (town.HisNode.HisDeliveryWay == DeliveryWay.ByAPIUrl && 1 == 2)
            {
                //返回值
                string postData = "";
                //用户输入的webAPI地址
                string apiUrl = town.HisNode.DeliveryParas;
                if (apiUrl.Contains("@WebApiHost"))//可以替换配置文件中配置的webapi地址
                    apiUrl = apiUrl.Replace("@WebApiHost", BP.Difference.SystemConfig.AppSettings["WebApiHost"]);
                //如果有参数
                if (apiUrl.Contains("?"))
                {
                    //api接口地址
                    string apiHost = apiUrl.Split('?')[0];
                    //api参数
                    string apiParams = apiUrl.Split('?')[1];
                    //参数替换
                    apiParams = BP.WF.Glo.DealExp(apiParams, town.HisWork);
                    Hashtable bodyJson = new Hashtable();
                    if (apiParams.Contains("&"))
                    {
                        String[] bodyParams = apiParams.Split('&');
                        foreach (String item in bodyParams)
                        {
                            String[] keyVals = item.Split('=');
                            bodyJson.Add(keyVals[0], keyVals[1]);
                        }
                    }
                    else
                    {
                        String[] keyVals = apiParams.Split('=');
                        bodyJson.Add(keyVals[0], keyVals[1]);
                    }

                    //执行POST
                    postData = BP.Tools.PubGlo.HttpPostConnect(apiHost, BP.Tools.Json.ToJson(bodyJson),"POST",true);

                    if (postData == "[]" || postData == "" || postData == null)
                        throw new Exception("节点" + town.HisNode.NodeID + "_" + town.HisNode.Name + "设置的WebAPI接口返回的数据出错，请检查接口返回值。");

                    dt = BP.Tools.Json.ToDataTable(postData);
                    return dt;
                }
                else
                {//如果没有参数
                    postData = BP.Tools.PubGlo.HttpPostConnect(apiUrl, "", "GET");
                    if (postData == "[]" || postData == "" || postData == null)
                        throw new Exception("节点" + town.HisNode.NodeID + "_" + town.HisNode.Name + "设置的WebAPI接口返回的数据出错，请检查接口返回值。");

                    dt = BP.Tools.Json.ToDataTable(postData);
                    return dt;
                }
            }
            #endregion 按照设置的WebAPI接口获取的数据计算

            #region 按照组织模式人员选择器
            if (town.HisNode.HisDeliveryWay == DeliveryWay.BySelectedEmpsOrgModel)
            {
                ps = new Paras();
                ps.Add("FK_Node", this.town.HisNode.NodeID);
                ps.Add("WorkID", this.currWn.HisWork.OID);
                ps.SQL = "SELECT FK_Emp FROM WF_SelectAccper WHERE FK_Node=" + dbStr + "FK_Node AND WorkID=" + dbStr + "WorkID AND AccType=0 ORDER BY IDX";
                dt = DBAccess.RunSQLReturnTable(ps);
                if (dt.Rows.Count == 0)
                {
                    /*从上次发送设置的地方查询. */
                    SelectAccpers sas = new SelectAccpers();
                    int i = sas.QueryAccepterPriSetting(this.town.HisNode.NodeID);
                    if (i == 0)
                    {
                        throw new Exception("url@./WorkOpt/AccepterOfOrg.htm?FK_Flow=" + toNode.FK_Flow + "&FK_Node=" + this.currWn.HisNode.NodeID + "&ToNode=" + toNode.NodeID + "&WorkID=" + this.WorkID);
                    }

                    //插入里面.
                    foreach (SelectAccper item in sas)
                    {
                        DataRow dr = dt.NewRow();
                        dr[0] = item.FK_Emp;
                        dt.Rows.Add(dr);
                    }
                    return dt;
                }
                return dt;
            }
            #endregion 按照组织模式人员选择器
            #region 选择其他组织的联络员
            if (town.HisNode.HisDeliveryWay == DeliveryWay.BySelectEmpByOfficer)
            {
                ps = new Paras();
                ps.Add("FK_Node", this.town.HisNode.NodeID);
                ps.Add("WorkID", this.currWn.HisWork.OID);
                ps.SQL = "SELECT FK_Emp FROM WF_SelectAccper WHERE FK_Node=" + dbStr + "FK_Node AND WorkID=" + dbStr + "WorkID AND AccType=0 ORDER BY IDX";
                dt = DBAccess.RunSQLReturnTable(ps);
                if (dt.Rows.Count == 0)
                {
                    /*从上次发送设置的地方查询. */
                    SelectAccpers sas = new SelectAccpers();
                    int i = sas.QueryAccepterPriSetting(this.town.HisNode.NodeID);
                    if (i == 0)
                    {
                        throw new Exception("url@./WorkOpt/AccepterOfOfficer.htm?FK_Flow=" + toNode.FK_Flow + "&FK_Node=" + this.currWn.HisNode.NodeID + "&ToNode=" + toNode.NodeID + "&WorkID=" + this.WorkID);
                    }

                    //插入里面.
                    foreach (SelectAccper item in sas)
                    {
                        DataRow dr = dt.NewRow();
                        dr[0] = item.FK_Emp;
                        dt.Rows.Add(dr);
                    }
                    return dt;
                }
                return dt;
            }
            #endregion 选择其他组织的联络员

            #region 发送人的上级部门的负责人: 2022.2.20 benjing. by zhoupeng  
            if (town.HisNode.HisDeliveryWay == DeliveryWay.BySenderParentDeptLeader)
            {
                string deptNo = BP.Web.WebUser.DeptParentNo;
                sql = "SELECT A.No,A.Name FROM Port_Emp A, Port_Dept B WHERE A.No=B.Leader AND B.No='" + deptNo + "'";
                dt = DBAccess.RunSQLReturnTable(sql);
                string leaderNo = null;
                if (dt.Rows.Count == 1)
                {
                    leaderNo = dt.Rows[0][0] as string;
                    //如果领导是当前操作员，就让其找上一级的部门领导。
                    if (leaderNo != null && WebUser.No.Equals(leaderNo) == true)
                        leaderNo = null;
                }

                if (dt.Rows.Count == 0 || BP.DA.DataType.IsNullOrEmpty(leaderNo) == true)
                {
                    //如果没有找到,就到父节点去找.
                    BP.Port.Dept pDept = new BP.Port.Dept(deptNo);
                    sql = "SELECT A.No,A.Name FROM Port_Emp A, Port_Dept B WHERE A.No=B.Leader AND B.No='" + pDept.No + "'";
                    dt = DBAccess.RunSQLReturnTable(sql);
                    return dt;
                    // throw new Exception("err@按照 [发送人的上级部门的负责人] 计算接收人的时候出现错误，您没有维护部门[" + pDept.Name + "]的部门负责人.");
                }
                return dt;
            }
            #endregion 发送人的上级部门的负责人 2022.2.20 benjing.

            #region 发送人上级部门指定的角色 2022.2.20 beijing. by zhoupeng  
            if (town.HisNode.HisDeliveryWay == DeliveryWay.BySenderParentDeptStations)
            {
                //当前人员身份 sf
                Hashtable sf = GetEmpDeptBySFModel();
                empDept = sf["DeptNo"].ToString();
                empNo = sf["EmpNo"].ToString();

                BP.Port.Dept dept = new BP.Port.Dept(empDept);
                string deptNo = dept.ParentNo;

                sql = "SELECT A.FK_Emp,FK_Dept FROM Port_DeptEmpStation A, WF_NodeStation B WHERE A.FK_Station=B.FK_Station AND B.FK_Node=" + town.HisNode.NodeID + " AND A.FK_Dept='" + deptNo + "'";
                dt = DBAccess.RunSQLReturnTable(sql);
                /*if (dt.Rows.Count == 0)
                {
                    BP.Port.Dept pDept = new BP.Port.Dept(deptNo);
                    throw new Exception("err@按照 [发送人上级部门指定的角色] 计算接收人的时候出现错误，没有找到人，请检查节点绑定的角色以及该部门【" + pDept.Name + "】下的人员设置的角色.");
                }*/
                return dt;
            }
            #endregion 发送人的上级部门的负责人 2022.2.20 beijing.  

            #region 最后判断 - 按照角色来执行。
            //从历史数据中获取接收人 2022-03-25这块代码注释，需要查询本部门的角色
            //if (this.currWn.HisNode.IsStartNode == false)
            //{
            //    ps = new Paras();

            //    如果当前的节点不是开始节点， 从轨迹里面查询。
            //    sql = "SELECT DISTINCT FK_Emp  FROM Port_DeptEmpStation WHERE FK_Station IN "
            //       + "(SELECT FK_Station FROM WF_NodeStation WHERE FK_Node=" + town.HisNode.NodeID + ") "
            //       + "AND FK_Emp IN (SELECT FK_Emp FROM WF_GenerWorkerlist WHERE WorkID=" + dbStr + "WorkID AND FK_Node IN (" + DataType.PraseAtToInSql(town.HisNode.GroupStaNDs, true) + ") )";

            //    sql += " ORDER BY FK_Emp ";

            //    ps.SQL = sql;
            //    ps.Add("WorkID", this.WorkID);
            //    dt = DBAccess.RunSQLReturnTable(ps);
            //    如果能够找到.
            //    if (dt.Rows.Count >= 1)
            //        return dt;
            //}



            /* 如果执行节点 与 接受节点角色集合一致 */
            string currGroupStaNDs = this.currWn.HisNode.GroupStaNDs;
            string toNodeTeamStaNDs = town.HisNode.GroupStaNDs;

            if (DataType.IsNullOrEmpty(currGroupStaNDs) == false && currGroupStaNDs.Equals(toNodeTeamStaNDs) == true && this.currWn.HisNode.GetParaInt("ShenFenModel") == 0 && town.HisNode.GetParaInt("ShenFenModel") == 0)
            {
                /* 说明，就把当前人员做为下一个节点处理人。*/
                DataRow dr = dt.NewRow();
                if (dt.Columns.Count == 0)
                    dt.Columns.Add("No");

                dr[0] = WebUser.No;
                dt.Rows.Add(dr);
                return dt;
            }

            //获取当前人员信息的
            Hashtable ht = GetEmpDeptBySFModel();
            empDept = ht["DeptNo"].ToString();
            empNo = ht["EmpNo"].ToString();

            /* 如果执行节点 与 接受节点角色集合不一致 */
            if ((DataType.IsNullOrEmpty(toNodeTeamStaNDs) == true && DataType.IsNullOrEmpty(currGroupStaNDs) == true)
                || currGroupStaNDs.Equals(toNodeTeamStaNDs) == false)
            {
                /* 没有查询到的情况下, 先按照本部门计算。添加FK_Dept*/


                sql = "SELECT FK_Emp as No,FK_Dept FROM Port_DeptEmpStation A, WF_NodeStation B         WHERE A.FK_Station=B.FK_Station AND B.FK_Node=" + dbStr + "FK_Node AND A.FK_Dept=" + dbStr + "FK_Dept";
                ps = new Paras();
                ps.SQL = sql;
                ps.Add("FK_Node", town.HisNode.NodeID);
                ps.Add("FK_Dept", empDept);

                dt = DBAccess.RunSQLReturnTable(ps);
                if (dt.Rows.Count == 0)
                {
                    NodeStations nextStations = town.HisNode.NodeStations;
                    if (nextStations.Count == 0)
                        throw new Exception("@节点没有角色:" + town.HisNode.NodeID + "  " + town.HisNode.Name);
                }
                else
                {
                    bool isInit = false;
                    foreach (DataRow dr in dt.Rows)
                    {
                        if (dr[0].ToString() == BP.Web.WebUser.No)
                        {
                            /* 如果角色分组不一样，并且结果集合里还有当前的人员，就说明了出现了当前操作员，拥有本节点上的角色也拥有下一个节点的工作角色
                             导致：节点的分组不同，传递到同一个人身上。 */
                            isInit = true;
                        }
                    }

#warning edit by peng, 用来确定不同角色集合的传递包含同一个人的处理方式。

                    //  if (isInit == false || isInit == true)
                    return dt;
                }
            }

            /*这里去掉了向下级别寻找的算法. */


            /* 没有查询到的情况下, 按照最大匹配数 提高一个级别计算，递归算法未完成。
             * 因为:以上已经做的角色的判断，就没有必要在判断其它类型的节点处理了。
             * */

            string nowDeptID = empDept.Clone() as string;

            //第1步:直线父级寻找.
            while (true)
            {
                BP.Port.Dept myDept = new BP.Port.Dept(nowDeptID);
                nowDeptID = myDept.ParentNo;
                if (nowDeptID == "-1" || nowDeptID.ToString() == "0")
                {
                    break; /*一直找到了最高级仍然没有发现，就跳出来循环从当前操作员人部门向下找。*/
                    throw new Exception("@按角色计算没有找到(" + town.HisNode.Name + ")接受人.");
                }

                //检查指定的父部门下面是否有该人员.
                DataTable mydtTemp = this.Func_GenerWorkerList_SpecDept(nowDeptID, empNo);
                if (mydtTemp.Rows.Count != 0)
                    return mydtTemp;

                continue;
            }

            //第2步：父级的平级.如果是0查找，1不查找父级的平级
            int StationFindWay = town.HisNode.GetParaInt("StationFindWay");
            if (StationFindWay == 0)
            {
                nowDeptID = empDept.Clone() as string;
                while (true)
                {
                    BP.Port.Dept myDept = new BP.Port.Dept(nowDeptID);
                    nowDeptID = myDept.ParentNo;
                    if (nowDeptID == "-1" || nowDeptID.ToString() == "0")
                    {
                        break; /*一直找到了最高级仍然没有发现，就跳出来循环从当前操作员人部门向下找。*/
                        throw new Exception("@按角色计算没有找到(" + town.HisNode.Name + ")接受人.");
                    }

                    //该部门下的所有子部门是否有人员.
                    DataTable mydtTemp = Func_GenerWorkerList_SpecDept_SameLevel(nowDeptID, empNo);
                    if (mydtTemp.Rows.Count != 0)
                        return mydtTemp;
                    continue;
                }
            }

            /*如果向上找没有找到，就考虑从本级部门上向下找。只找一级下级的平级 */
            nowDeptID = empDept.Clone() as string;

            //递归出来子部门下有该角色的人员 返回数据添加FK_Dept
            DataTable mydt = Func_GenerWorkerList_SpecDept_SameLevel(nowDeptID, empNo);

            if ((mydt == null || mydt.Rows.Count == 0) && this.town.HisNode.HisWhenNoWorker == false)
            {
                //如果递归没有找到人,就全局搜索角色.
                sql = "SELECT A.FK_Emp,FK_Dept FROM  Port_DeptEmpStation A, WF_NodeStation B WHERE A.FK_Station=B.FK_Station AND B.FK_Node=" + dbStr + "FK_Node ORDER BY A.FK_Emp";
                ps = new Paras();
                ps.Add("FK_Node", town.HisNode.NodeID);
                ps.SQL = sql;
                dt = DBAccess.RunSQLReturnTable(ps);

                if (dt.Rows.Count > 0)
                    return dt;
                if (this.town.HisNode.HisWhenNoWorker == false)
                    throw new Exception("@按角色智能计算没有找到(" + town.HisNode.Name + ")接受人 @当前工作人员:" + WebUser.No + ",名称:" + WebUser.Name + " , 部门编号:" + WebUser.FK_Dept + " 部门名称：" + WebUser.FK_DeptName);

                if (dt.Rows.Count == 0)
                {
                    mydt = new DataTable();
                    mydt.Columns.Add(new DataColumn("No", typeof(string)));
                    mydt.Columns.Add(new DataColumn("Name", typeof(string)));
                }
            }

            return mydt;
            #endregion  按照角色来执行。
        }

        private Hashtable GetEmpDeptBySFModel()
        {
            Node nd = town.HisNode;
            Hashtable ht = new Hashtable();
            //身份模式.
            var sfModel = nd.GetParaInt("ShenFenModel");

            //身份参数.
            var sfVal = nd.GetParaString("ShenFenVal");

            //按照当前节点的身份计算
            if (sfModel == 0)
            {
                ht.Add("EmpNo", WebUser.No);
                ht.Add("DeptNo", WebUser.FK_Dept);
                return ht;
            }
            //按照指定节点的身份计算.
            if (sfModel == 1)
            {
                if (DataType.IsNullOrEmpty(sfVal))
                    sfVal = currWn.HisNode.NodeID.ToString();

                Paras ps = new Paras();
                ps.SQL = "SELECT FK_Emp,FK_Dept FROM WF_GenerWorkerlist WHERE WorkID=" + dbStr + "OID AND FK_Node=" + dbStr + "FK_Node Order By RDT DESC";
                ps.Add("OID", this.WorkID);
                ps.Add("FK_Node", int.Parse(sfVal));

                DataTable dt = DBAccess.RunSQLReturnTable(ps);
                if (dt.Rows.Count == 0)
                    throw new Exception("err@不符合常理，没有找到数据，到达节点[" + this.town.HisNode.NodeID + "," + town.HisNode.Name + "]");
                ht.Add("EmpNo", dt.Rows[0][0].ToString());
                ht.Add("DeptNo", dt.Rows[0][1].ToString());
            }

            //按照 字段的值的人员编号作为身份计算.
            if (sfModel == 2)
            {
                if (DataType.IsNullOrEmpty(sfVal) == true)
                    throw new Exception("err@流程模板配置错误，到达节点[" + this.town.HisNode.NodeID + "," + town.HisNode.Name + "]根据字段值作为人员编号，没有配置字段值:" + sfVal);
                //获得字段的值.
                string empNo = "";
                if (currWn.HisNode.HisFormType == NodeFormType.RefOneFrmTree)
                    empNo = currWn.HisWork.GetValStrByKey(sfVal);
                else
                    empNo = currWn.rptGe.GetValStrByKey(sfVal);
                BP.Port.Emp emp = new BP.Port.Emp();
                emp.UserID = empNo;
                if (emp.RetrieveFromDBSources() == 0)
                    throw new Exception("err@根据字段值:" + sfVal + "在Port_Emp中没有找到人员信息");
                ht.Add("EmpNo", emp.No);
                ht.Add("DeptNo", emp.FK_Dept);
            }
            return ht;
        }
        /// <summary>
        /// 找部门的领导
        /// </summary>
        /// <returns></returns>
        private DataTable ByDeptLeader()
        {

            Node nd = town.HisNode;

            //身份模式.
            var sfModel = nd.GetParaInt("ShenFenModel");

            //身份参数.
            var sfVal = nd.GetParaString("ShenFenVal");

            //按照当前节点的身份计算.
            if (sfModel == 0)
                return ByDeptLeader_Nodes(currWn.HisNode.NodeID.ToString());

            //按照指定节点的身份计算.
            if (sfModel == 1)
                return ByDeptLeader_Nodes(sfVal);

            //按照 字段的值的人员编号作为身份计算.
            if (sfModel == 2)
            {
                //获得字段的值.
                string empNo = "";
                if (currWn.HisNode.HisFormType == NodeFormType.RefOneFrmTree)
                    empNo = currWn.HisWork.GetValStrByKey(sfVal);
                else
                    empNo = currWn.rptGe.GetValStrByKey(sfVal);
                BP.Port.Emp emp = new BP.Port.Emp();
                emp.UserID = empNo;
                if (emp.RetrieveFromDBSources() == 0)
                {
                    throw new Exception("err@根据字段值:" + sfVal + "在Port_Emp中没有找到人员信息");
                }
                return ByDeptLeader_Fields(emp.No, emp.FK_Dept);
            }

            throw new Exception("err@没有判断的身份模式.");
        }
        /// <summary>
        /// 找部门的分管领导
        /// </summary>
        /// <returns></returns>
        private DataTable ByDeptShipLeader()
        {

            Node nd = town.HisNode;

            //身份模式.
            var sfModel = nd.GetParaInt("ShenFenModel");

            //身份参数.
            var sfVal = nd.GetParaString("ShenFenVal");

            //按照当前节点的身份计算
            if (sfModel == 0)
                return ByDeptShipLeader_Nodes(currWn.HisNode.NodeID.ToString());

            //按照指定节点的身份计算.
            if (sfModel == 1)
                return ByDeptShipLeader_Nodes(sfVal);

            //按照 字段的值的人员编号作为身份计算.
            if (sfModel == 2)
            {
                //获得字段的值.
                string empNo = "";
                if (currWn.HisNode.HisFormType == NodeFormType.RefOneFrmTree)
                    empNo = currWn.HisWork.GetValStrByKey(sfVal);
                else
                    empNo = currWn.rptGe.GetValStrByKey(sfVal);
                BP.Port.Emp emp = new BP.Port.Emp();
                emp.UserID = empNo;
                if (emp.RetrieveFromDBSources() == 0)
                {
                    throw new Exception("err@根据字段值:" + sfVal + "在Port_Emp中没有找到人员信息");
                }
                return ByDeptShipLeader_Fields(emp.No, emp.FK_Dept);
            }

            throw new Exception("err@没有判断的身份模式.");
        }
        private DataTable ByDeptLeader_Nodes(string nodes)
        {
            DataTable dt = null;
            //查找指定节点的人员， 如果没有节点，就是当前的节点.
            if (DataType.IsNullOrEmpty(nodes) == true)
                nodes = this.currWn.HisNode.NodeID.ToString();

            Paras ps = new Paras();
            ps.SQL = "SELECT FK_Emp,FK_Dept FROM WF_GenerWorkerlist WHERE WorkID=" + dbStr + "OID AND FK_Node=" + dbStr + "FK_Node Order By RDT DESC";
            ps.Add("OID", this.WorkID);
            ps.Add("FK_Node", int.Parse(nodes));

            dt = DBAccess.RunSQLReturnTable(ps);
            if (dt.Rows.Count == 0)
                throw new Exception("err@不符合常理，没有找到数据");
            string empNo = dt.Rows[0][0].ToString();
            string deptNo = dt.Rows[0][1].ToString();
            return ByDeptLeader_Fields(empNo, deptNo);
        }
        private DataTable ByDeptShipLeader_Nodes(string nodes)
        {
            DataTable dt = null;
            //查找指定节点的人员， 如果没有节点，就是当前的节点.
            if (DataType.IsNullOrEmpty(nodes) == true)
                nodes = this.currWn.HisNode.NodeID.ToString();

            Paras ps = new Paras();
            ps.SQL = "SELECT FK_Emp,FK_Dept FROM WF_GenerWorkerlist WHERE WorkID=" + dbStr + "OID AND FK_Node=" + dbStr + "FK_Node Order By RDT DESC";
            ps.Add("OID", this.WorkID);
            ps.Add("FK_Node", int.Parse(nodes));

            dt = DBAccess.RunSQLReturnTable(ps);
            if (dt.Rows.Count == 0)
                throw new Exception("err@不符合常理，没有找到数据");
            string empNo = dt.Rows[0][0].ToString();
            string deptNo = dt.Rows[0][1].ToString();
            return ByDeptShipLeader_Fields(empNo, deptNo);
        }
        private DataTable ByDeptLeader_Fields(string empNo, string empDept)
        {
            string sql = "SELECT Leader FROM Port_Dept WHERE No='" + empDept + "'";
            string myEmpNo = DBAccess.RunSQLReturnStringIsNull(sql, null);

            if (DataType.IsNullOrEmpty(myEmpNo) == true)
            {
                //如果部门的负责人为空，则查找Port_Emp中的Learder信息
                if (BP.Difference.SystemConfig.CCBPMRunModel == CCBPMRunModel.SAAS)
                    sql = "SELECT Leader FROM Port_Emp WHERE UserID='" + empNo + "' AND OrgNo='" + WebUser.OrgNo + "'";
                else
                    sql = "SELECT Leader FROM Port_Emp WHERE No='" + empNo + "'";

                myEmpNo = DBAccess.RunSQLReturnStringIsNull(sql, null);
                if (DataType.IsNullOrEmpty(myEmpNo) == true)
                {
                    Dept mydept = new Dept(empDept);
                    throw new Exception("@流程设计错误:下一个节点(" + town.HisNode.Name + ")设置的按照部门负责人计算，当前您的部门(" + mydept.No + "," + mydept.Name + ")没有维护负责人 . ");
                }
            }

            //如果有这个人,并且是当前人员，说明他本身就是经理或者部门负责人.
            if (myEmpNo.Equals(empNo) == true)
            {
                sql = "SELECT Leader FROM Port_Dept WHERE No=(SELECT PARENTNO FROM PORT_DEPT WHERE NO='" + empDept + "')";
                myEmpNo = DBAccess.RunSQLReturnStringIsNull(sql, null);
                if (DataType.IsNullOrEmpty(myEmpNo) == true)
                {
                    Dept mydept = new Dept(empDept);
                    throw new Exception("@流程设计错误:下一个节点(" + town.HisNode.Name + ")设置的按照部门负责人计算，当前您的部门(" + mydept.Name + ")上级没有维护负责人 . ");
                }
            }
            return DBAccess.RunSQLReturnTable(sql);
        }
        private DataTable ByDeptShipLeader_Fields(string empNo, string empDept)
        {
            BP.Port.Dept mydept = new BP.Port.Dept(empDept);
            Paras ps = new Paras();
            ps.Add("No", empDept);
            ps.SQL = "SELECT ShipLeader FROM Port_Dept WHERE No='" + empDept + "'";

            DataTable dt = DBAccess.RunSQLReturnTable(ps);
            if (dt.Rows.Count != 0 && dt.Rows[0][0] != null && DataType.IsNullOrEmpty(dt.Rows[0][0].ToString()) == true)
            {
                //如果部门的负责人为空，则查找Port_Emp中的Learder信息
                ps.Clear();
                if (BP.Difference.SystemConfig.CCBPMRunModel == CCBPMRunModel.SAAS)
                    ps.SQL = "SELECT ShipLeader FROM Port_Emp WHERE UserID='" + empNo + "' AND OrgNo='" + WebUser.OrgNo + "'";
                else
                    ps.SQL = "SELECT ShipLeader FROM Port_Emp WHERE No='" + empNo + "'";

                dt = DBAccess.RunSQLReturnTable(ps);
                if (dt.Rows.Count != 0 && dt.Rows[0][0] != null && DataType.IsNullOrEmpty(dt.Rows[0][0].ToString()) == true)
                    throw new Exception("@流程设计错误:下一个节点(" + town.HisNode.Name + ")设置的按照部门负责人计算，当前您的部门(" + mydept.No + "," + mydept.Name + ")没有维护负责人 . ");
            }

            //如果有这个人,并且是当前人员，说明他本身就是经理或者部门负责人.
            if (dt.Rows[0][0].ToString().Equals(empNo) == true)
            {
                ps.SQL = "SELECT ShipLeader FROM Port_Dept WHERE No=(SELECT PARENTNO FROM PORT_DEPT WHERE NO='" + empDept + "')";
                dt = DBAccess.RunSQLReturnTable(ps);
                if (dt.Rows.Count == 0)
                    throw new Exception("@流程设计错误:下一个节点(" + town.HisNode.Name + ")设置的按照部门负责人计算，当前您的部门(" + mydept.Name + ")上级没有维护负责人 . ");
            }
            return dt;
        }
        /// <summary>
        /// 获得指定部门下是否有该角色的人员.
        /// </summary>
        /// <param name="deptNo">部门编号</param>
        /// <param name="empNo">人员编号</param>
        /// <returns></returns>
        public DataTable Func_GenerWorkerList_SpecDept(string deptNo, string empNo)
        {
            string sql;

            Paras ps = new Paras();
            if (this.town.HisNode.IsExpSender == true)
            {
                /* 不允许包含当前处理人. */
                sql = "SELECT FK_Emp as No FROM Port_DeptEmpStation A, WF_NodeStation B WHERE A.FK_Station=B.FK_Station AND B.FK_Node=" + dbStr + "FK_Node AND A.FK_Dept=" + dbStr + "FK_Dept AND A.FK_Emp!=" + dbStr + "FK_Emp";

                ps.SQL = sql;
                ps.Add("FK_Node", town.HisNode.NodeID);
                ps.Add("FK_Dept", deptNo);
                ps.Add("FK_Emp", empNo);
            }
            else
            {
                sql = "SELECT FK_Emp as No FROM Port_DeptEmpStation A, WF_NodeStation B WHERE A.FK_Station=B.FK_Station AND B.FK_Node=" + dbStr + "FK_Node AND A.FK_Dept=" + dbStr + "FK_Dept";

                ps.SQL = sql;
                ps.Add("FK_Node", town.HisNode.NodeID);
                ps.Add("FK_Dept", deptNo);
            }

            DataTable dt = DBAccess.RunSQLReturnTable(ps);
            return dt;
        }
        /// <summary>
        /// 获得本部门的人员
        /// </summary>
        /// <param name="deptNo"></param>
        /// <param name="emp1"></param>
        /// <returns></returns>
        public DataTable Func_GenerWorkerList_SpecDept_SameLevel(string deptNo, string empNo)
        {
            string sql;

            Paras ps = new Paras();
            if (this.town.HisNode.IsExpSender == true)
            {
                /* 不允许包含当前处理人. */
                sql = "SELECT FK_Emp as No FROM Port_DeptEmpStation A, WF_NodeStation B, Port_Dept C WHERE A.FK_Dept=C.No AND A.FK_Station=B.FK_Station AND B.FK_Node=" + dbStr + "FK_Node AND C.ParentNo=" + dbStr + "FK_Dept AND A.FK_Emp!=" + dbStr + "FK_Emp";

                ps.SQL = sql;
                ps.Add("FK_Node", town.HisNode.NodeID);
                ps.Add("FK_Dept", deptNo);
                ps.Add("FK_Emp", empNo);
            }
            else
            {
                sql = "SELECT FK_Emp as No FROM Port_DeptEmpStation A, WF_NodeStation B, Port_Dept C  WHERE A.FK_Dept=C.No AND A.FK_Station=B.FK_Station AND B.FK_Node=" + dbStr + "FK_Node AND C.ParentNo=" + dbStr + "FK_Dept";
                ps.SQL = sql;
                ps.Add("FK_Node", town.HisNode.NodeID);
                ps.Add("FK_Dept", deptNo);
            }

            DataTable dt = DBAccess.RunSQLReturnTable(ps);
            return dt;
        }
        /// <summary>
        /// 执行找人
        /// </summary>
        /// <returns></returns>
        public DataTable DoIt(Flow fl, WorkNode currWn, WorkNode toWn)
        {
            // 给变量赋值.
            this.fl = fl;
            this.currWn = currWn;
            this.town = toWn;
            this.WorkID = currWn.WorkID;

            if (this.town.HisNode.IsGuestNode)
            {
                /*到达的节点是客户参与的节点. add by zhoupeng 2016.5.11*/
                DataTable mydt = new DataTable();
                mydt.Columns.Add("No", typeof(string));
                mydt.Columns.Add("Name", typeof(string));

                DataRow dr = mydt.NewRow();
                dr["No"] = "Guest";
                dr["Name"] = "外部用户";
                mydt.Rows.Add(dr);
                return mydt;
            }

            //如果到达的节点是按照workflow的模式。
            if (toWn.HisNode.HisDeliveryWay != DeliveryWay.ByCCFlowBPM)
            {
                DataTable re_dt = this.FindByWorkFlowModel();
                if (re_dt.Rows.Count == 1)
                    return re_dt; //如果只有一个人，就直接返回，就不处理了。

                #region 根据配置追加接收人 by dgq 2015.5.18

                string paras = this.town.HisNode.DeliveryParas;
                if (paras.Contains("@Spec"))
                {
                    //如果返回null ,则创建表
                    if (re_dt == null)
                    {
                        re_dt = new DataTable();
                        re_dt.Columns.Add("No", typeof(string));
                    }

                    //获取配置规则
                    string[] reWays = this.town.HisNode.DeliveryParas.Split('@');
                    foreach (string reWay in reWays)
                    {
                        if (DataType.IsNullOrEmpty(reWay))
                            continue;
                        string[] specItems = reWay.Split('=');
                        //配置规则错误
                        if (specItems.Length != 2)
                            continue;
                        //规则名称，SpecStations、SpecEmps
                        string specName = specItems[0];
                        //规则内容
                        string specContent = specItems[1];
                        switch (specName)
                        {
                            case "SpecStations"://按角色
                                string[] stations = specContent.Split(',');
                                foreach (string station in stations)
                                {
                                    if (DataType.IsNullOrEmpty(station))
                                        continue;

                                    //获取角色下的人员
                                    string sql = "";
                                    if (BP.Difference.SystemConfig.CCBPMRunModel == CCBPMRunModel.Single)
                                        sql = "SELECT FK_Emp FROM Port_DeptEmpStation WHERE FK_Station='" + station + "'";
                                    else
                                    {
                                        sql = "SELECT FK_Emp FROM Port_DeptEmpStation WHERE FK_Station='" + station + "' AND OrgNo='" + BP.Web.WebUser.OrgNo + "'";
                                    }

                                    DataTable dt_Emps = DBAccess.RunSQLReturnTable(sql);
                                    foreach (DataRow empRow in dt_Emps.Rows)
                                    {
                                        //排除为空编号
                                        if (empRow[0] == null || DataType.IsNullOrEmpty(empRow[0].ToString()))
                                            continue;

                                        DataRow dr = re_dt.NewRow();
                                        dr[0] = empRow[0];
                                        re_dt.Rows.Add(dr);
                                    }
                                }
                                break;
                            case "SpecEmps"://按人员编号
                                string[] myEmpStrs = specContent.Split(',');
                                foreach (string emp in myEmpStrs)
                                {
                                    //排除为空编号
                                    if (DataType.IsNullOrEmpty(emp))
                                        continue;

                                    DataRow dr = re_dt.NewRow();
                                    dr[0] = emp;
                                    re_dt.Rows.Add(dr);
                                }
                                break;
                        }
                    }
                }
                #endregion

                //本节点接收人不允许包含上一步发送人 。
                if (this.town.HisNode.IsExpSender == true && re_dt.Rows.Count >= 2)
                {
                    /*
                     * 排除了接受人分组的情况, 因为如果有了分组，就破坏了分组的结构了.
                     * 
                     */
                    //复制表结构
                    DataTable dt = re_dt.Clone();
                    foreach (DataRow row in re_dt.Rows)
                    {
                        //排除当前登录人
                        if (row[0].ToString() == WebUser.No)
                            continue;

                        DataRow dr = dt.NewRow();
                        dr[0] = row[0];

                        if (row.Table.Columns.Count == 2)
                            dr[1] = row[1];

                        dt.Rows.Add(dr);
                    }
                    return dt;
                }
                return re_dt;
            }

            //没有找到人的情况，就返回空.
            return null;
        }


    }
}