DAYE_RDMS_CCFLOW/CCFlow/Components/BP.WF/WF/ShiftWork.cs

using System;
using System.Collections.Generic;
using BP.Sys;
using BP.Web;
using BP.Port;
using BP.DA;
using BP.WF.Template;
using System.Data;

namespace BP.WF
{
    public class ShiftWork
    {
        /// <summary>
        /// 工作移交
        /// </summary>
        /// <param name="workID">工作ID</param>
        /// <param name="toEmp">要移交的人</param>
        /// <param name="msg">移交信息</param>
        /// <returns>执行结果</returns>
        public static string Node_Shift_ToEmp(Int64 workID, string toEmp, string msg)
        {
            if (toEmp.Equals(WebUser.No) == true)
                throw new Exception("err@您不能移交给您自己。");

            GenerWorkFlow gwf = new GenerWorkFlow(workID);
            if (gwf.WFSta == WFSta.Complete)
                throw new Exception("err@流程已经完成，您不能执行移交了。");

            int i = 0;
            //人员.
            Emp emp = new Emp(toEmp);
            Node nd = new Node(gwf.NodeID);
            Work work = nd.HisWork;
            work.OID = workID;
            work.RetrieveFromDBSources();
            DateTime dtOfShould = DateTime.Now;

            if (nd.HisCHWay == CHWay.ByTime)
            {
                //按天、小时考核
                if (nd.GetParaInt("CHWayOfTimeRole") == 0)
                {
                    //增加天数. 考虑到了节假日. 
                    //判断是修改了节点期限的天数
                    int timeLimit = nd.TimeLimit;
                    dtOfShould = Glo.AddDayHoursSpan(DateTime.Now, timeLimit,
                    nd.TimeLimitHH, nd.TimeLimitMM, nd.TWay);
                }
                //按照节点字段设置
                if (nd.GetParaInt("CHWayOfTimeRole") == 1)
                {
                    //获取设置的字段、
                    string keyOfEn = nd.GetParaString("CHWayOfTimeRoleField");
                    if (DataType.IsNullOrEmpty(keyOfEn) == true)
                        nd.HisCHWay = CHWay.None;
                    else
                        dtOfShould = DataType.ParseSysDateTime2DateTime(work.GetValByKey(keyOfEn).ToString());

                }
                
            }
            string sdt = "";
            if (nd.HisCHWay == CHWay.None)
                sdt = "无";
            else
                sdt = DataType.SysDateTimeFormat(dtOfShould);
            //检查被移交人是否在当前的待办列表里否？
            GenerWorkerList gwl = new GenerWorkerList();
            i = gwl.Retrieve(GenerWorkerListAttr.FK_Emp, emp.UserID,
                GenerWorkerListAttr.FK_Node, nd.NodeID,
                GenerWorkerListAttr.WorkID, workID);
            if (i == 1)
                return "err@移交失败，您所移交的人员(" + emp.UserID + " " + emp.Name + ")已经在代办列表里.";

            if (nd.TodolistModel == TodolistModel.Order
                || nd.TodolistModel == TodolistModel.Teamup
                || nd.TodolistModel == TodolistModel.TeamupGroupLeader)
            {
                /*如果是队列模式，或者是协作模式, 就直接把自己的gwl 信息更新到被移交人身上. */
                //把自己的待办更新到被移交人身上.
                string sql = "UPDATE WF_GenerWorkerlist SET IsRead=0, FK_Emp='" + emp.UserID + "', EmpName='" + emp.Name + "' WHERE FK_Emp='" + WebUser.No + "' AND FK_Node=" + gwf.NodeID + " AND WorkID=" + workID;
                int myNum = DBAccess.RunSQL(sql);

                #region 判断是否是,admin的移交.
                if (myNum == 0)
                {
                    //说明移交人是 admin，执行的.
                    GenerWorkerLists mygwls = new GenerWorkerLists();
                    mygwls.Retrieve(GenerWorkerListAttr.WorkID, workID,
                        GenerWorkerListAttr.FK_Node, gwf.NodeID);
                    if (mygwls.Count == 0)
                        throw new Exception("err@系统错误，没有找到待办.");

                    //把他们都删除掉.
                    mygwls.Delete(GenerWorkerListAttr.WorkID, workID,
                        GenerWorkerListAttr.FK_Node, gwf.NodeID);

                    //取出来第1个，把人员信息改变掉.
                    foreach (GenerWorkerList item in mygwls)
                    {
                        item.EmpNo = WebUser.No;
                        item.EmpName = WebUser.Name;

                        item.DeptNo = WebUser.DeptNo;
                        item.DeptName = WebUser.DeptName;

                        item.ItIsRead = false;
                        item.SDT = sdt;
                        item.Insert(); //执行插入.
                        break;
                    }
                }
                #endregion 判断是否是,admin的移交.


                //移交后写入最新待办，被移交人@BKGY
                sql = "";
                sql = "INSERT INTO WEB_SOCKET (ID,USER_NO,EmpWorksNums,Flag,WorkID) ";
                sql += "VALUES(S_WEB_SOCKET.NEXTVAL,'" + emp.No + "','" + BP.WF.Dev2Interface.EmpWorksNums(emp.UserID) + "','0',"+ workID + ")";
                DBAccess.RunSQL(sql);

                //移交后写入最新待办，移交人@BKGY
                sql = "";
                sql = "INSERT INTO WEB_SOCKET (ID,USER_NO,EmpWorksNums,Flag,WorkID) ";
                sql += "VALUES(S_WEB_SOCKET.NEXTVAL,'" + WebUser.No + "','" + BP.WF.Dev2Interface.Todolist_EmpWorks + "','0',"+ workID + ")";
                DBAccess.RunSQL(sql);
                //记录日志.
                Glo.AddToTrack(ActionType.Shift, nd.FlowNo, workID, gwf.FID, nd.NodeID, nd.Name,
                    WebUser.No, WebUser.Name, nd.NodeID, nd.Name, toEmp, emp.Name, msg, null);

                //移交后事件
                string atPara1 = "@SendToEmpIDs=" + emp.UserID;
                string info = "@" + ExecEvent.DoNode(EventListNode.ShitAfter, nd, work, null, atPara1);
                if (info == null || info.Equals("@null")) info = "";
                //处理移交后发送的消息事件,发送消息.
                PushMsgs pms1 = new PushMsgs();
                pms1.Retrieve(PushMsgAttr.NodeID, nd.NodeID, PushMsgAttr.EventNo, EventListNode.ShitAfter);
                foreach (PushMsg pm in pms1)
                    pm.DoSendMessage(nd, nd.HisWork, null, null, null, emp.UserID);

                gwf.WFState = WFState.Shift;
                gwf.TodoEmpsNum = 1;
                gwf.TodoEmps = emp.UserID + "," + emp.Name + ";";
                gwf.Update();
                return "移交成功." + info;
            }

            //非协作模式.
            gwl = new GenerWorkerList();
            i = gwl.Retrieve(GenerWorkerListAttr.FK_Node, gwf.NodeID, GenerWorkerListAttr.WorkID, gwf.WorkID);
            if (i == 1) {
                string sql = "UPDATE WF_GenerWorkerlist SET IsRead=0, FK_Emp='" + emp.UserID + "', EmpName='" + emp.Name + "' WHERE FK_Emp='" + gwl.EmpNo + "' AND FK_Node=" + gwf.NodeID + " AND WorkID=" + workID;
                DBAccess.RunSQL(sql);
            } else {
                gwl.Delete(GenerWorkerListAttr.WorkID, gwf.WorkID, GenerWorkerListAttr.FK_Node, gwf.NodeID);
                gwl.EmpNo = emp.UserID;
                gwl.EmpName = emp.Name;
                gwl.ItIsEnable = true;
                gwl.ItIsRead = false;
                gwl.SDT = sdt;
                gwl.Insert();
            }
            gwf.WFState = WFState.Shift;
            gwf.TodoEmpsNum = 1;
            gwf.TodoEmps = gwf.TodoEmps.Replace(WebUser.No + "," + WebUser.Name + ";", "") + emp.UserID + "," + emp.Name + ";";
            gwf.Update();

            //记录日志.
            Glo.AddToTrack(ActionType.Shift, nd.FlowNo, workID, gwf.FID, nd.NodeID, nd.Name,
                WebUser.No, WebUser.Name, nd.NodeID, nd.Name, toEmp, emp.Name, msg, null);

            string inf1o = "@工作移交成功。@您已经成功的把工作移交给：" + emp.UserID + " , " + emp.Name;
            //移交后事件
            string atPara = "@SendToEmpIDs=" + emp.UserID;
            WorkNode wn = new WorkNode(work, nd);
            inf1o += "@" + ExecEvent.DoNode(EventListNode.ShitAfter, wn, null, atPara);
            return inf1o;
        }
        /// <summary>
        /// 工作移交
        /// </summary>
        /// <param name="workID">工作ID</param>
        /// <param name="toEmps">要移交的多个人,比如:zhangsan,lisi</param>
        /// <param name="msg"></param>
        /// <returns>执行信息.err@说明执行错误.</returns>
        public static string Node_Shift_ToEmps(Int64 workID, string toEmps, string msg)
        {
            if (toEmps.Equals(WebUser.No) == true)
                throw new Exception("err@您不能移交给您自己。");

            GenerWorkFlow gwf = new GenerWorkFlow(workID);
            if (gwf.WFSta == WFSta.Complete)
                throw new Exception("err@流程已经完成，您不能执行移交了。");

            //定义变量,查询出来当前的人员列表.
            GenerWorkerLists gwls = new GenerWorkerLists();
            gwls.Retrieve(GenerWorkerListAttr.FK_Node, gwf.NodeID,
                        GenerWorkerListAttr.WorkID, workID);
            //定义变量.
            GenerWorkerList gwl = new GenerWorkerList();

            int i = 0;
            //人员.
            Node nd = new Node(gwf.NodeID);
            Work work = nd.HisWork;
            work.OID = workID;
            work.RetrieveFromDBSources();
            DateTime dtOfShould = DateTime.Now;

            if (nd.HisCHWay == CHWay.ByTime)
            {
                //按天、小时考核
                if (nd.GetParaInt("CHWayOfTimeRole") == 0)
                {
                    //增加天数. 考虑到了节假日. 
                    //判断是修改了节点期限的天数
                    int timeLimit = nd.TimeLimit;
                    dtOfShould = Glo.AddDayHoursSpan(DateTime.Now, timeLimit,
                    nd.TimeLimitHH, nd.TimeLimitMM, nd.TWay);
                }
                //按照节点字段设置
                if (nd.GetParaInt("CHWayOfTimeRole") == 1)
                {
                    //获取设置的字段、
                    string keyOfEn = nd.GetParaString("CHWayOfTimeRoleField");
                    if (DataType.IsNullOrEmpty(keyOfEn) == true)
                        nd.HisCHWay = CHWay.None;
                    else
                        dtOfShould = DataType.ParseSysDateTime2DateTime(work.GetValByKey(keyOfEn).ToString());

                }

            }
            string sdt = "";
            if (nd.HisCHWay == CHWay.None)
                sdt = "无";
            else
                sdt = DataType.SysDateTimeFormat(dtOfShould);
            string info = null;
            string[] strs = toEmps.Split(',');
            string empNames = "";
            foreach (string toEmp in strs)
            {
                Emp emp = new Emp(toEmp);
                if (nd.TodolistModel == TodolistModel.Order
                    || nd.TodolistModel == TodolistModel.Teamup
                    || nd.TodolistModel == TodolistModel.TeamupGroupLeader)
                {
                    /*如果是队列模式，或者是协作模式, 就直接把自己的gwl 信息更新到被移交人身上. */

                    //检查被移交人是否在当前的待办列表里否？
                    i = gwl.Retrieve(GenerWorkerListAttr.FK_Emp, emp.UserID,
                        GenerWorkerListAttr.FK_Node, nd.NodeID,
                        GenerWorkerListAttr.WorkID, workID);
                    if (i == 1)
                    {
                        info += "err@移交失败，您所移交的人员(" + emp.UserID + " " + emp.Name + ")已经在代办列表里.";
                        continue;
                    }

                    if (i == 0)
                        return "";

                    //写入移交数据.
                    gwl = (GenerWorkerList)gwls[0];
                    gwl.EmpNo = emp.UserID;
                    gwl.EmpName = emp.Name;
                    gwl.PassInt = 0;
                    gwl.SDT = sdt;
                    gwl.Insert();

                    //记录日志.
                    Glo.AddToTrack(ActionType.Shift, nd.FlowNo, workID, gwf.FID, nd.NodeID, nd.Name,
                        WebUser.No, WebUser.Name, nd.NodeID, nd.Name, toEmp, emp.Name, msg, null);

                    //移交后事件
                    string atPara1 = "@SendToEmpIDs=" + emp.UserID;
                    info += "@" + ExecEvent.DoNode(EventListNode.ShitAfter, nd, work, null, atPara1);

                    //移交后写入最新待办  被移交人@BKGY
                    string sql2 = "";
                    sql2 = "INSERT INTO WEB_SOCKET (ID,USER_NO,EmpWorksNums,Flag,WorkID) ";
                    sql2 += "VALUES(S_WEB_SOCKET.NEXTVAL,'" + emp.UserID + "','" + BP.WF.Dev2Interface.EmpWorksNums(emp.UserID) + "','0',"+ workID + ")";
                    DBAccess.RunSQL(sql2);

                    //处理移交后发送的消息事件,发送消息.
                    PushMsgs pms1 = new PushMsgs();
                    pms1.Retrieve(PushMsgAttr.NodeID, nd.NodeID, PushMsgAttr.EventNo, EventListNode.ShitAfter);
                    foreach (PushMsg pm in pms1)
                        pm.DoSendMessage(nd, nd.HisWork, null, null, null, emp.UserID);

                    info += "info@成功移交给:" + emp.UserID + "," + emp.Name;
                    continue;
                }

                //非协作模式.
                //写入移交数据.
                gwl = (GenerWorkerList)gwls[0];
                gwl.EmpNo = emp.UserID;
                gwl.EmpName = emp.Name;
                gwl.PassInt = 0;
                gwl.SDT = sdt;
                gwl.Insert();
            }

            //重新查询.
            gwls.Retrieve(GenerWorkerListAttr.FK_Node, gwf.NodeID,
                      GenerWorkerListAttr.WorkID, workID);

            //工作处理人员.
            string todoEmps = "";
            foreach (GenerWorkerList mygwl in gwls)
            {
                todoEmps += mygwl.EmpNo + "," + mygwl.EmpName + ";";
            }

            //更新主表信息.
            gwf.WFState = WFState.Shift;
            gwf.TodoEmpsNum = gwls.Count;
            gwf.TodoEmps = todoEmps; //处理人员.
            gwf.Update();

            //删除自己的待办.
            DBAccess.RunSQL("DELETE FROM WF_GenerWorkerList WHERE WorkID=" + gwf.WorkID + " AND FK_Node=" + gwf.NodeID + " AND FK_Emp='" + WebUser.No + "'");

            //记录日志.
            Glo.AddToTrack(ActionType.Shift, nd.FlowNo, workID, gwf.FID, nd.NodeID, nd.Name,
                WebUser.No, WebUser.Name, nd.NodeID, nd.Name, toEmps, "移交给多个人", msg, null);

            //移交后写入最新待办  移交人@BKGY
            string sql = "";
            sql = "INSERT INTO WEB_SOCKET (ID,USER_NO,EmpWorksNums,Flag,WorkID) ";
            sql += "VALUES(S_WEB_SOCKET.NEXTVAL,'" + WebUser.No + "','" + BP.WF.Dev2Interface.Todolist_EmpWorks + "','0',"+ workID + ")";
            DBAccess.RunSQL(sql);

            //移交后事件.
            string atPara = "@SendToEmpIDs=" + toEmps;
            WorkNode wn = new WorkNode(work, nd);
            info += "@" + ExecEvent.DoNode(EventListNode.ShitAfter, wn, null, atPara);
            return info;
        }
        /// <summary>
        /// 撤消移交
        /// </summary>
        /// <returns></returns>
        public static string DoUnShift(Int64 workid)
        {

            GenerWorkFlow gwf = new GenerWorkFlow(workid);
            GenerWorkerLists wls = new GenerWorkerLists();
            wls.Retrieve(GenerWorkerListAttr.WorkID, workid, GenerWorkerListAttr.FK_Node, gwf.NodeID);
            if (wls.Count == 0)
                return "移交失败没有当前的工作。";

            Node nd = new Node(gwf.NodeID);
            Work wk1 = nd.HisWork;
            wk1.OID = workid;
            wk1.Retrieve();

            // 记录日志.
            WorkNode wn = new WorkNode(wk1, nd);
            wn.AddToTrack(ActionType.UnShift, WebUser.No, WebUser.Name, nd.NodeID, nd.Name, "撤消移交");

            //删除撤销信息.
            //DBAccess.RunSQL("DELETE FROM WF_ShiftWork WHERE WorkID=" + workid + " AND FK_Node=" + gwf.NodeID);
            string sql = "";
            //更新流程主表字段信息
            gwf.WFState = WFState.Runing;
            if (wls.Count == 1)
            {
                GenerWorkerList wl = (GenerWorkerList)wls[0];
                sql = "UPDATE WF_GenerWorkerList SET " +
                    "FK_Emp = '" + WebUser.No + "', " +
                    "EmpName = '" + WebUser.Name + "', " +
                    "IsEnable = 1, " +
                    "IsPass = 0 " +
                    " WHERE WorkID = " + workid + " AND FK_Emp = '" + wl.EmpNo + "' AND FK_Node = " + gwf.NodeID;
                DBAccess.RunSQL(sql);
                gwf.TodoEmps = WebUser.No + "," + WebUser.Name + ";";
                gwf.Update();
                return "@撤消移交成功。";
            }

            GenerWorkerList mywl = null;
            //获取移交的人员信息
            string trackTable = "ND" + Int32.Parse(gwf.FlowNo) + "Track";
            sql = "SELECT EmpTo From " + trackTable + " WHERE ActionType=3 AND WorkID=" + gwf.WorkID + " AND NDFrom=" + gwf.NodeID + " AND EmpFrom='" + WebUser.No + "'";
            DataTable dt = DBAccess.RunSQLReturnTable(sql);
            foreach (DataRow dr in dt.Rows)
            {
                foreach (GenerWorkerList wl in wls)
                {
                    if (wl.EmpNo.Equals(WebUser.No))
                    {
                        mywl = wl;
                        wl.Delete();
                        continue;
                    }
                    if (wl.EmpNo.Equals(dr[0].ToString()))
                    {
                        mywl = wl;
                        wl.Delete();
                        gwf.TodoEmps = gwf.TodoEmps.Replace(wl.EmpNo + "," + wl.EmpName + ";", "");
                        break;
                    }
                }
            }
            if (mywl == null)
                return "err@撤消移交失败，没有找到移交人的待办";
            gwf.TodoEmps += WebUser.No + "," + WebUser.Name + ";";
            gwf.Update();
            GenerWorkerList wkNew = new GenerWorkerList();
            wkNew.Copy(mywl);
            wkNew.EmpNo = WebUser.No;
            wkNew.EmpName = WebUser.Name;
            wkNew.ItIsEnable = true;
            wkNew.ItIsPass = false;
            wkNew.Insert();
            return "@撤消移交成功";
        }
    }
}