55128.cn_kjh.55128.cn_m.55128.cn/CP55128/CB.Data.SqlServer/SpecialColumn/ArticleManage.cs

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using CB.Interface.Infrastructure;
using CB.Entity;
using System.Data.Common;
using System.Data;
using CB.Common;

namespace CB.Data.SqlServer
{
    public class ArticleManage : Repository<ArticleInfo>, IArticleService
    {
        public ArticleManage(string interfaceId)
            : base(interfaceId)
        {
        }
        public override bool Save(ArticleInfo entity)
        {
            throw new NotImplementedException();
        }

        public override bool Update(ArticleInfo entity)
        {
            throw new NotImplementedException();
        }

        public override bool Delete(int Id)
        {
            throw new NotImplementedException();
        }

        public override ArticleInfo Get<TKey>(TKey key)
        {
            ArticleInfo entity = null;
            DbParameter[] para = 
            {
                DbHelper.MakeInParam(InterfaceId,"@id",(DbType)SqlDbType.Int,4,key)
            };
            using (IDataReader reader = DbHelper.ExecuteReader(InterfaceId, CommandType.StoredProcedure, "uzt_Article_select", para))
            {
                if (reader.Read())
                {
                    entity = new ArticleInfo()
                    {
                        Id = TypeConverter.ObjectToInt(reader["Id"]),
                        Title = reader["Title"].ToString().Trim(),
                        Cid = TypeConverter.ObjectToInt(reader["Cid"]),
                        TagId = TypeConverter.ObjectToInt(reader["TagId"]),
                        ShortDetail = reader["ShortDetail"].ToString().Trim(),
                        Addtime = TypeConverter.ObjectToDateTime(reader["Addtime"], DateTime.MinValue)
                    };
                    if (reader.NextResult() && reader.Read())
                    {
                        entity.Detail = reader["Detail"].ToString().Trim();
                        entity.EditId = TypeConverter.ObjectToInt(reader["EditId"]);
                        entity.Editor = reader["Editor"].ToString();
                    }
                }
            }
            return entity;
        }

        public override IList<ArticleInfo> ToList()
        {
            throw new NotImplementedException();
        }

        public override IList<ArticleInfo> ToList(ArticleInfo entity)
        {
            throw new NotImplementedException();
        }

        public override IList<ArticleInfo> ToPaging(ArticleInfo entity, int pageSize, int pageIndex, out int recordCount)
        {
            string where = "1=1";
            if (null != entity)
            {
                if (0 < entity.Cid)
                {
                    where += " AND [Cid]=" + entity.Cid;
                }
                if (0 < entity.TagId)
                {
                    where += " AND [TagId]=" + entity.TagId;
                }
            }
            recordCount = 0;
            string field = "[Id],[Title],[Cid],[TagId],[ShortDetail],[Addtime]"
                , orderField = "[Id] DESC"
                , tableName = "[ZT_Article]";
            DbParameter[] para = 
            {
                DbHelper.MakeInParam(InterfaceId,"@pageSize",(DbType)SqlDbType.Int,4,pageSize),
                DbHelper.MakeInParam(InterfaceId,"@page",(DbType)SqlDbType.Int,4,pageIndex),
                DbHelper.MakeInParam(InterfaceId,"@tableName",(DbType)SqlDbType.NVarChar,500,tableName),
                DbHelper.MakeInParam(InterfaceId,"@field",(DbType)SqlDbType.NVarChar,1000,field),
                DbHelper.MakeInParam(InterfaceId,"@orderField",(DbType)SqlDbType.NVarChar,50,orderField),
                DbHelper.MakeInParam(InterfaceId,"@where",(DbType)SqlDbType.NVarChar,2000,where)
            };
            IList<ArticleInfo> list = new List<ArticleInfo>();
            using (IDataReader reader = DbHelper.ExecuteReader(InterfaceId, CommandType.StoredProcedure, "usp_st_page", para))
            {
                while (reader.Read())
                {
                    list.Add(new ArticleInfo()
                    {
                        Id = TypeConverter.ObjectToInt(reader["Id"]),
                        Title = reader["Title"].ToString().Trim(),
                        Cid = TypeConverter.ObjectToInt(reader["Cid"]),
                        TagId = TypeConverter.ObjectToInt(reader["TagId"]),
                        ShortDetail = reader["ShortDetail"].ToString().Trim(),
                        Addtime = TypeConverter.ObjectToDateTime(reader["Addtime"], DateTime.MinValue)
                    });
                }
                if (reader.NextResult() && reader.Read())
                {
                    recordCount = reader.GetInt32(0);
                }
                reader.Dispose();
            }
            return list;
        }
    }
}