flowprocess.cs

动易SiteFactory&#8482 网上商店系统1.0源代码

namespace PowerEasy.SqlServerDal.WorkFlows
{
    using PowerEasy.Common;
    using PowerEasy.IDal.WorkFlow;
    using PowerEasy.Model.UserManage;
    using PowerEasy.Model.WorkFlow;
    using PowerEasy.SqlServerDal;
    using System;
    using System.Collections.Generic;
    using System.Data;
    using System.Text;

    public sealed class FlowProcess : IFlowProcess
    {
        public bool Add(FlowProcessInfo flowProcessInfo)
        {
            Parameters parms = new Parameters();
            flowProcessInfo.ProcessId = GetMaxProcessId() + 1;
            GetParameters(flowProcessInfo, parms);
            string strSql = "INSERT INTO PE_FlowProcess(ProcessID,FlowID,ProcessName,Description,PassActionName,PassActionStatus,RejectActionName,RejectActionStatus)VALUES(@ProcessId,@FlowId,@ProcessName,@Description,@PassActionName,@PassActionStatus,@RejectActionName,@RejectActionStatus)";
            return DBHelper.ExecuteSql(strSql, parms);
        }

        public bool AddRoleToProcessRoles(int flowId, int processId, int roleId)
        {
            Parameters cmdParams = new Parameters();
            cmdParams.AddInParameter("@FlowID", DbType.Int32, flowId);
            cmdParams.AddInParameter("@ProcessID", DbType.Int32, processId);
            cmdParams.AddInParameter("@RoleId", DbType.Int32, roleId);
            string strSql = "INSERT INTO PE_Process_Roles(FlowID,ProcessID,RoleId)VALUES(@FlowID,@ProcessID,@RoleId)";
            return DBHelper.ExecuteSql(strSql, cmdParams);
        }

        public bool AddStatusCodeToProcessStatusCode(int flowId, int processId, int statusCode)
        {
            Parameters cmdParams = new Parameters();
            cmdParams.AddInParameter("@FlowID", DbType.Int32, flowId);
            cmdParams.AddInParameter("@ProcessID", DbType.Int32, processId);
            cmdParams.AddInParameter("@StatusCode", DbType.Int32, statusCode);
            string strSql = "INSERT INTO PE_ProcessStatusCode(FlowID,ProcessID,StatusCode)VALUES(@FlowID,@ProcessID,@StatusCode)";
            return DBHelper.ExecuteSql(strSql, cmdParams);
        }

        public bool Delete(int flowId)
        {
            Parameters cmdParams = new Parameters();
            cmdParams.AddInParameter("@FlowID", DbType.Int32, flowId);
            string strSql = "DELETE FROM PE_FlowProcess WHERE FlowID=@FlowID";
            return DBHelper.ExecuteSql(strSql, cmdParams);
        }

        public bool Delete(int flowId, int processId)
        {
            Parameters cmdParams = new Parameters();
            cmdParams.AddInParameter("@FlowID", DbType.Int32, flowId);
            cmdParams.AddInParameter("@ProcessID", DbType.Int32, processId);
            string strSql = "DELETE FROM PE_FlowProcess WHERE FlowID=@FlowID AND ProcessID =@ProcessID";
            return DBHelper.ExecuteSql(strSql, cmdParams);
        }

        public bool DeleteRoleInProcessRole(int groupId)
        {
            Parameters cmdParams = new Parameters();
            cmdParams.AddInParameter("@RoleId", DbType.Int32, groupId);
            string strSql = "DELETE FROM PE_Process_Roles WHERE RoleId=@RoleId";
            return DBHelper.ExecuteSql(strSql, cmdParams);
        }

        public bool DeleteRoleInProcessRole(int flowId, int processId)
        {
            Parameters cmdParams = new Parameters();
            cmdParams.AddInParameter("@FlowID", DbType.Int32, flowId);
            cmdParams.AddInParameter("@ProcessID", DbType.Int32, processId);
            string strSql = "DELETE FROM PE_Process_Roles WHERE FlowID=@FlowID AND ProcessID=@ProcessID";
            return DBHelper.ExecuteSql(strSql, cmdParams);
        }

        public bool DeleteStatusCodeInProcessStatusCode(int statusCode)
        {
            Parameters cmdParams = new Parameters();
            cmdParams.AddInParameter("@StatusCode", DbType.Int32, statusCode);
            string strSql = "DELETE FROM PE_ProcessStatusCode WHERE StatusCode=@StatusCode";
            return DBHelper.ExecuteSql(strSql, cmdParams);
        }

        public bool DeleteStatusCodeInProcessStatusCode(int flowId, int processId)
        {
            Parameters cmdParams = new Parameters();
            cmdParams.AddInParameter("@FlowID", DbType.Int32, flowId);
            cmdParams.AddInParameter("@ProcessID", DbType.Int32, processId);
            string strSql = "DELETE FROM PE_ProcessStatusCode WHERE FlowID=@FlowID AND ProcessID=@ProcessID";
            return DBHelper.ExecuteSql(strSql, cmdParams);
        }

        public bool DeleteWorkFlowInProcessRole(int flowId)
        {
            Parameters cmdParams = new Parameters();
            cmdParams.AddInParameter("@FlowID", DbType.Int32, flowId);
            string strSql = "DELETE FROM PE_Process_Roles WHERE FlowID=@FlowID";
            return DBHelper.ExecuteSql(strSql, cmdParams);
        }

        public bool DeleteWorkFlowInProcessStatusCode(int flowId)
        {
            Parameters cmdParams = new Parameters();
            cmdParams.AddInParameter("@FlowID", DbType.Int32, flowId);
            string strSql = "DELETE FROM PE_ProcessStatusCode WHERE FlowID=@FlowID";
            return DBHelper.ExecuteSql(strSql, cmdParams);
        }

        public bool ExistFlowProcess(int flowId, string processName)
        {
            Parameters cmdParams = new Parameters();
            cmdParams.AddInParameter("@FlowId", DbType.Int32, flowId);
            cmdParams.AddInParameter("@ProcessName", DbType.String, processName);
            string strSql = "SELECT COUNT(*) FROM PE_FlowProcess WHERE FlowID=@FlowID AND ProcessName=@ProcessName";
            return DBHelper.ExistsSql(strSql, cmdParams);
        }

        public bool ExistRoleInProcessRole(int groupId)
        {
            Parameters cmdParams = new Parameters();
            cmdParams.AddInParameter("@RoleId", DbType.Int32, groupId);
            string strSql = "SELECT COUNT(*) FROM PE_Process_Roles WHERE RoleId=@RoleId";
            return DBHelper.ExistsSql(strSql, cmdParams);
        }

        public bool ExistRoleInProcessRole(int flowId, int processId)
        {
            Parameters cmdParams = new Parameters();
            cmdParams.AddInParameter("@FlowID", DbType.Int32, flowId);
            cmdParams.AddInParameter("@ProcessID", DbType.Int32, processId);
            string strSql = "SELECT COUNT(*) FROM PE_Process_Roles WHERE FlowID=@FlowID AND ProcessID=@ProcessID";
            return DBHelper.ExistsSql(strSql, cmdParams);
        }

        public bool ExistStatusCodeInProcessStatusCode(int statusCode)
        {
            Parameters cmdParams = new Parameters();
            cmdParams.AddInParameter("@StatusCode", DbType.Int32, statusCode);
            string strSql = "SELECT COUNT(*) FROM PE_ProcessStatusCode WHERE StatusCode=@StatusCode";
            return DBHelper.ExistsSql(strSql, cmdParams);
        }

        public bool ExistStatusCodeInProcessStatusCode(int flowId, int processId)
        {
            Parameters cmdParams = new Parameters();
            cmdParams.AddInParameter("@FlowID", DbType.Int32, flowId);
            cmdParams.AddInParameter("@ProcessID", DbType.Int32, processId);
            string strSql = "SELECT COUNT(*) FROM PE_ProcessStatusCode WHERE FlowID=@FlowID AND ProcessID=@ProcessID";
            return DBHelper.ExistsSql(strSql, cmdParams);
        }

        public bool ExistWorkFlowInFlowProcess(int flowId)
        {
            Parameters cmdParams = new Parameters();
            cmdParams.AddInParameter("@FlowID", DbType.Int32, flowId);
            string strSql = "SELECT COUNT(*) FROM PE_FlowProcess WHERE FlowID=@FlowID";
            return DBHelper.ExistsSql(strSql, cmdParams);
        }

        public bool ExistWorkFlowInProcessRole(int flowId)
        {
            Parameters cmdParams = new Parameters();
            cmdParams.AddInParameter("@FlowID", DbType.Int32, flowId);
            string strSql = "SELECT COUNT(*) FROM PE_Process_Roles WHERE FlowID=@FlowID";
            return DBHelper.ExistsSql(strSql, cmdParams);
        }

        public bool ExistWorkFlowInProcessStatusCode(int flowId)
        {
            Parameters cmdParams = new Parameters();
            cmdParams.AddInParameter("@FlowID", DbType.Int32, flowId);
            string strSql = "SELECT COUNT(*) FROM PE_ProcessStatusCode WHERE FlowID=@FlowID";
            return DBHelper.ExistsSql(strSql, cmdParams);
        }

        private static void FlowProcessFromrdr(FlowProcessInfo flowProcessInfo, NullableDataReader rdr)
        {
            flowProcessInfo.ProcessId = rdr.GetInt32("ProcessID");
            flowProcessInfo.FlowId = rdr.GetInt32("FlowID");
            flowProcessInfo.ProcessName = rdr.GetString("ProcessName");
            flowProcessInfo.Description = rdr.GetString("Description");
            flowProcessInfo.PassActionName = rdr.GetString("PassActionName");
            flowProcessInfo.PassActionStatus = rdr.GetInt32("PassActionStatus");
            flowProcessInfo.RejectActionName = rdr.GetString("RejectActionName");
            flowProcessInfo.RejectActionStatus = rdr.GetInt32("RejectActionStatus");
        }

        private static FlowProcessInfo FlowProcessInfoFromrdataReader(NullableDataReader rdr)
        {
            FlowProcessInfo info = new FlowProcessInfo();
            info.ProcessId = rdr.GetInt32("ProcessId");
            info.FlowId = rdr.GetInt32("FlowId");
            info.ProcessName = rdr.GetString("ProcessName");
            info.Description = rdr.GetString("Description");