Hidistro.SqlDal/Weibo/ArticleDao.cs

这里只显示每个文件的开头 60 行。登录后可以解锁完整代码。

微信扫码关注公众号，代码整理好后第一时间通知你。

namespace Hidistro.SqlDal.Weibo
{
    using Hidistro.Core;
    using Hidistro.Core.Entities;
    using Hidistro.Entities;
    using Hidistro.Entities.Weibo;
    using Microsoft.Practices.EnterpriseLibrary.Data;
    using System;
    using System.Collections.Generic;
    using System.Data;
    using System.Data.Common;
    using System.Text;

    public class ArticleDao
    {
        private string articledetailUrl = ("http://" + Globals.DomainName + Globals.ApplicationPath + "/vshop/ArticleDetail.aspx?$1");
        private Database database = DatabaseFactory.CreateDatabase();

        public int AddMultiArticle(ArticleInfo article)
        {
            int num;
            StringBuilder builder = new StringBuilder();
            builder.Append("INSERT INTO vshop_Article(").Append("Title,ArticleType,LinkType,Content,ImageUrl,Url,Memo,PubTime,IsShare)").Append(" VALUES (@Title,@ArticleType,@LinkType,@Content,@ImageUrl,@Url,@Memo,@PubTime,@IsShare);select @@identity");
            DbCommand sqlStringCommand = this.database.GetSqlStringCommand(builder.ToString());
            this.database.AddInParameter(sqlStringCommand, "Title", DbType.String, article.Title);
            this.database.AddInParameter(sqlStringCommand, "ArticleType", DbType.Int32, article.ArticleType);
            this.database.AddInParameter(sqlStringCommand, "LinkType", DbType.Int32, article.LinkType);
            this.database.AddInParameter(sqlStringCommand, "Content", DbType.String, article.Content);
            this.database.AddInParameter(sqlStringCommand, "ImageUrl", DbType.String, article.ImageUrl);
            this.database.AddInParameter(sqlStringCommand, "Url", DbType.String, article.Url);
            this.database.AddInParameter(sqlStringCommand, "Memo", DbType.String, article.Memo);
            this.database.AddInParameter(sqlStringCommand, "PubTime", DbType.DateTime, DateTime.Now);
            this.database.AddInParameter(sqlStringCommand, "IsShare", DbType.Boolean, article.IsShare);
            if (int.TryParse(this.database.ExecuteScalar(sqlStringCommand).ToString(), out num))
            {
                string str;
                if (article.LinkType == LinkType.ArticleDetail)
                {
                    str = "update vshop_Article set Url=@Url where ArticleId=@ArticleId";
                    sqlStringCommand = this.database.GetSqlStringCommand(str);
                    article.ArticleId = num;
                    article.Url = this.articledetailUrl.Replace("$1", "sid=" + article.ArticleId.ToString());
                    this.database.AddInParameter(sqlStringCommand, "Url", DbType.String, article.Url);
                    this.database.AddInParameter(sqlStringCommand, "ArticleId", DbType.Int32, article.ArticleId);
                    this.database.ExecuteNonQuery(sqlStringCommand);
                }
                foreach (ArticleItemsInfo info in article.ItemsInfo)
                {
                    builder = new StringBuilder();
                    builder.Append("insert into vshop_ArticleItems(");
                    builder.Append("ArticleId,Title,Content,ImageUrl,Url,LinkType)");
                    builder.Append(" values (");
                    builder.Append("@ArticleId,@Title,@Content,@ImageUrl,@Url,@LinkType);select @@identity");
                    sqlStringCommand = this.database.GetSqlStringCommand(builder.ToString());
                    this.database.AddInParameter(sqlStringCommand, "ArticleId", DbType.Int32, num);
                    this.database.AddInParameter(sqlStringCommand, "Title", DbType.String, info.Title);
                    this.database.AddInParameter(sqlStringCommand, "Content", DbType.String, info.Content);
                    this.database.AddInParameter(sqlStringCommand, "ImageUrl", DbType.String, info.ImageUrl);
                    this.database.AddInParameter(sqlStringCommand, "Url", DbType.String, info.Url);
                    this.database.AddInParameter(sqlStringCommand, "LinkType", DbType.Int32, info.LinkType);