comment.cs

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

                    break;
            }
            return this.GetList(startRowIndexId, maxNumberRows, "ASC", builder.ToString());
        }

        public IList<CommentInfo> GetList(int startRowIndexId, int maxNumberRows, string sorts, string filter)
        {
            Database database = DatabaseFactory.CreateDatabase();
            DbCommand storedProcCommand = database.GetStoredProcCommand("PR_Shop_Statistics_GetList");
            database.AddInParameter(storedProcCommand, "@StartRows", DbType.Int32, startRowIndexId);
            database.AddInParameter(storedProcCommand, "@PageSize", DbType.Int32, maxNumberRows);
            database.AddInParameter(storedProcCommand, "@SortColumn", DbType.String, "GeneralId");
            database.AddInParameter(storedProcCommand, "@StrColumn", DbType.String, "*");
            database.AddInParameter(storedProcCommand, "@Sorts", DbType.String, sorts);
            database.AddInParameter(storedProcCommand, "@TableName", DbType.String, "PE_Comment LEFT JOIN PE_Users ON PE_Comment.UserName=PE_Users.UserName");
            database.AddInParameter(storedProcCommand, "@Filter", DbType.String, filter);
            database.AddInParameter(storedProcCommand, "@ID", DbType.String, "CommentId");
            database.AddInParameter(storedProcCommand, "@Group", DbType.String, " ");
            database.AddOutParameter(storedProcCommand, "@Total", DbType.Int32, maxNumberRows);
            List<CommentInfo> list = new List<CommentInfo>();
            using (NullableDataReader reader = new NullableDataReader(database.ExecuteReader(storedProcCommand)))
            {
                while (reader.Read())
                {
                    list.Add(CommentInfoAndUserInfoFromDataReader(reader));
                }
            }
            this.m_TotalOfCommentInfo = (int) database.GetParameterValue(storedProcCommand, "@Total");
            return list;
        }

        public IList<CommentInfo> GetListByNodeId(int startRowIndexId, int maxNumberRows, int nodeId, int type)
        {
            StringBuilder builder = new StringBuilder();
            if (nodeId != 0)
            {
                builder.Append(" PE_Comment.NodeId=" + nodeId.ToString() + " ");
            }
            if (builder.Length > 0)
            {
                builder.Append(" AND ");
            }
            switch (type)
            {
                case 0:
                    builder.Append(" 1=1 ");
                    break;

                case 1:
                    builder.Append(" PE_Comment.Status=1 ");
                    break;

                case 2:
                    builder.Append(" PE_Comment.Status=0 ");
                    break;
            }
            return this.GetList(startRowIndexId, maxNumberRows, "DESC", builder.ToString());
        }

        private static void GetParameters(CommentInfo commentInfo, Parameters parms)
        {
            parms.AddInParameter("@CommentId", DbType.Int32, commentInfo.CommentId);
            parms.AddInParameter("@GeneralId", DbType.Int32, commentInfo.GeneralId);
            parms.AddInParameter("@TopicId", DbType.Int32, commentInfo.TopicId);
            parms.AddInParameter("@NodeId", DbType.Int32, commentInfo.NodeId);
            parms.AddInParameter("@CommentTitle", DbType.String, commentInfo.CommentTitle);
            parms.AddInParameter("@Content", DbType.String, commentInfo.Content);
            parms.AddInParameter("@UpdateDateTime", DbType.DateTime, commentInfo.UpdateDateTime);
            parms.AddInParameter("@Position", DbType.Int32, commentInfo.Position);
            parms.AddInParameter("@Score", DbType.Int32, commentInfo.Score);
            parms.AddInParameter("@Status", DbType.Boolean, commentInfo.Status);
            parms.AddInParameter("@Ip", DbType.String, commentInfo.IP);
            parms.AddInParameter("@IsPrivate", DbType.Boolean, commentInfo.IsPrivate);
            parms.AddInParameter("@UserName", DbType.String, commentInfo.UserName);
            parms.AddInParameter("@Face", DbType.String, commentInfo.Face);
            parms.AddInParameter("@Email", DbType.String, commentInfo.Email);
            parms.AddInParameter("@ReplyUserName", DbType.String, commentInfo.ReplyUserName);
        }

        public int GetTotalOfCommentInfo()
        {
            return this.m_TotalOfCommentInfo;
        }

        public IList<CommentInfo> GetUserCommentList(int startRowIndexId, int maxNumberRows, int nodeId, string userName)
        {
            StringBuilder builder = new StringBuilder();
            if (nodeId != 0)
            {
                builder.Append(" PE_Comment.NodeId=" + nodeId.ToString() + " ");
            }
            if (builder.Length > 0)
            {
                builder.Append(" AND ");
            }
            builder.Append(" PE_Users.UserName = '" + userName + "'");
            Database database = DatabaseFactory.CreateDatabase();
            DbCommand storedProcCommand = database.GetStoredProcCommand("PR_Shop_Statistics_GetList");
            database.AddInParameter(storedProcCommand, "@StartRows", DbType.Int32, startRowIndexId);
            database.AddInParameter(storedProcCommand, "@PageSize", DbType.Int32, maxNumberRows);
            database.AddInParameter(storedProcCommand, "@SortColumn", DbType.String, "GeneralId");
            database.AddInParameter(storedProcCommand, "@StrColumn", DbType.String, "*");
            database.AddInParameter(storedProcCommand, "@Sorts", DbType.String, "DESC");
            database.AddInParameter(storedProcCommand, "@TableName", DbType.String, "PE_Comment LEFT JOIN PE_Users ON PE_Comment.UserName=PE_Users.UserName");
            database.AddInParameter(storedProcCommand, "@Filter", DbType.String, builder.ToString());
            database.AddInParameter(storedProcCommand, "@ID", DbType.String, "CommentId");
            database.AddInParameter(storedProcCommand, "@Group", DbType.String, " ");
            database.AddOutParameter(storedProcCommand, "@Total", DbType.Int32, maxNumberRows);
            List<CommentInfo> list = new List<CommentInfo>();
            using (NullableDataReader reader = new NullableDataReader(database.ExecuteReader(storedProcCommand)))
            {
                while (reader.Read())
                {
                    list.Add(CommentInfoAndUserInfoFromDataReader(reader));
                }
            }
            this.m_TotalOfCommentInfo = (int) database.GetParameterValue(storedProcCommand, "@Total");
            return list;
        }

        public int MaxCommentId()
        {
            return DBHelper.GetMaxId("PE_Comment", "CommentId");
        }

        public int ScoreCount(int generalId)
        {
            Parameters cmdParams = new Parameters();
            cmdParams.AddInParameter("@GeneralId", DbType.Int32, generalId);
            int num = 0;
            using (NullableDataReader reader = DBHelper.ExecuteReaderSql("SELECT Score FROM PE_Comment WHERE GeneralId=@GeneralId", cmdParams))
            {
                while (reader.Read())
                {
                    num += reader.GetInt32("Score");
                }
            }
            return num;
        }

        public bool SetStatus(int commentId, bool status)
        {
            Parameters cmdParams = new Parameters();
            cmdParams.AddInParameter("@CommentId", DbType.Int32, commentId);
            cmdParams.AddInParameter("@Status", DbType.Boolean, status);
            return DBHelper.ExecuteSql("UPDATE PE_Comment SET Status=@Status WHERE CommentId=@CommentId", cmdParams);
        }

        public bool Update(CommentInfo commentInfo)
        {
            Parameters parms = new Parameters();
            GetParameters(commentInfo, parms);
            parms.AddInParameter("@Reply", DbType.String, commentInfo.Reply);
            parms.AddInParameter("@ReplyAdmin", DbType.String, commentInfo.ReplyAdmin);
            parms.AddInParameter("@ReplyDateTime", DbType.DateTime, commentInfo.ReplyDateTime);
            parms.AddInParameter("@ReplyIsPrivate", DbType.Boolean, commentInfo.ReplyIsPrivate);
            return DBHelper.ExecuteSql("UPDATE PE_Comment SET CommentId=@CommentId,GeneralId=@GeneralId,TopicId=@TopicId,NodeId=@NodeId,CommentTitle=@CommentTitle,Email = @Email,Content=@Content,UpdateDateTime=@UpdateDateTime,Position=@Position,Score=@Score,Status=@Status,Ip=@Ip,IsPrivate=@IsPrivate,UserName=@UserName,Face=@Face,Reply=@Reply,ReplyAdmin=@ReplyAdmin,ReplyDateTime=@ReplyDateTime,ReplyIsPrivate=@ReplyIsPrivate,ReplyUserName=@ReplyUserName WHERE CommentId=@CommentId", parms);
        }
    }
}