questionallot.cs

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

namespace PowerEasy.SqlServerDal.Crm
{
    using Microsoft.Practices.EnterpriseLibrary.Data;
    using PowerEasy.IDal.Crm;
    using PowerEasy.Model.Crm;
    using PowerEasy.SqlServerDal;
    using System;
    using System.Collections.Generic;
    using System.Data;
    using System.Data.Common;

    public class QuestionAllot : IQuestionAllot
    {
        private int m_Total;

        public bool Add(int typeId, int adminId)
        {
            Parameters cmdParams = new Parameters();
            cmdParams.AddInParameter("@TypeID", DbType.Int32, typeId);
            cmdParams.AddInParameter("@AdminID", DbType.Int32, adminId);
            return DBHelper.ExecuteSql("IF not Exists(Select * from [PE_QuestionType_Admin] where TypeID=@TypeID and AdminID=@AdminID) INSERT INTO [PE_QuestionType_Admin]([TypeID],[AdminID]) VALUES(@TypeID,@AdminID)", cmdParams);
        }

        public bool Delete(string adminIdlist)
        {
            return DBHelper.ExecuteSql("Delete PE_QuestionType_Admin Where AdminID In (" + adminIdlist + ")");
        }

        public bool Delete(int typeId, int adminId)
        {
            Parameters cmdParams = new Parameters();
            cmdParams.AddInParameter("@TypeID", DbType.Int32, typeId);
            cmdParams.AddInParameter("@AdminID", DbType.Int32, adminId);
            return DBHelper.ExecuteSql("Delete PE_QuestionType_Admin Where TypeID=@TypeID And AdminID=@AdminID", cmdParams);
        }

        private static QuestionAllotInfo GetInfoFormReader(NullableDataReader rdr)
        {
            QuestionAllotInfo info = new QuestionAllotInfo();
            info.TypeId = rdr.GetInt32("TypeID");
            info.TypeName = rdr.GetString("TypeName");
            info.AdminId = rdr.GetInt32("AdminID");
            info.AdminName = rdr.GetString("AdminName");
            return info;
        }

        public IList<QuestionAllotInfo> GetList(int startRowIndexId, int maxNumberRows)
        {
            Database database = DatabaseFactory.CreateDatabase();
            DbCommand storedProcCommand = database.GetStoredProcCommand("PR_Common_GetList");
            string str = "PE_QuestionType_Admin Q inner join PE_QuestionType T on Q.TypeID=T.TypeID inner join PE_Admin A on Q.AdminID=A.AdminID";
            database.AddInParameter(storedProcCommand, "@StartRows", DbType.Int32, startRowIndexId);
            database.AddInParameter(storedProcCommand, "@PageSize", DbType.Int32, maxNumberRows);
            database.AddInParameter(storedProcCommand, "@SortColumn", DbType.String, "Q.AdminID");
            database.AddInParameter(storedProcCommand, "@StrColumn", DbType.String, "Q.TypeID,T.TypeName,Q.AdminID,A.AdminName");
            database.AddInParameter(storedProcCommand, "@Sorts", DbType.String, "DESC");
            database.AddInParameter(storedProcCommand, "@TableName", DbType.String, str);
            database.AddOutParameter(storedProcCommand, "@Total", DbType.Int32, 10);
            database.AddInParameter(storedProcCommand, "@Filter", DbType.String, "");
            IList<QuestionAllotInfo> list = new List<QuestionAllotInfo>();
            using (NullableDataReader reader = new NullableDataReader(database.ExecuteReader(storedProcCommand)))
            {
                while (reader.Read())
                {
                    list.Add(GetInfoFormReader(reader));
                }
            }
            this.m_Total = (int) database.GetParameterValue(storedProcCommand, "@Total");
            return list;
        }

        public IList<QuestionAllotInfo> GetListByAdminId(int adminId)
        {
            IList<QuestionAllotInfo> list = new List<QuestionAllotInfo>();
            using (NullableDataReader reader = DBHelper.ExecuteReaderSql("select Q.TypeID,T.TypeName,Q.AdminID,A.AdminName from PE_QuestionType_Admin Q inner join PE_QuestionType T on Q.TypeID=T.TypeID inner join PE_Admin A on Q.AdminID=A.AdminID Where Q.AdminID=@AdminID Order by Q.TypeID DESC,Q.AdminID DESC", new Parameters("@AdminID", DbType.Int32, adminId)))
            {
                while (reader.Read())
                {
                    list.Add(GetInfoFormReader(reader));
                }
            }
            return list;
        }

        public int GetTotal()
        {
            return this.m_Total;
        }
    }
}