491 lines
19 KiB
C#
491 lines
19 KiB
C#
using Infrastructure;
|
|
using Infrastructure.Attribute;
|
|
using Infrastructure.Extensions;
|
|
using Mapster;
|
|
using DOAN.Common;
|
|
using DOAN.Model.Content;
|
|
using DOAN.Model.Content.Dto;
|
|
using DOAN.Model.Enum;
|
|
using DOAN.Model.System;
|
|
using DOAN.Repository;
|
|
using DOAN.Service.Content.IService;
|
|
using DOAN.ServiceCore.Services;
|
|
|
|
namespace DOAN.Service.Content
|
|
{
|
|
/// <summary>
|
|
///
|
|
/// </summary>
|
|
[AppService(ServiceType = typeof(IArticleService), ServiceLifetime = LifeTime.Transient)]
|
|
public class ArticleService : BaseService<Article>, IArticleService
|
|
{
|
|
private readonly IArticleCategoryService _categoryService;
|
|
private readonly IArticleTopicService _topicService;
|
|
private readonly ISysConfigService _sysConfigService;
|
|
private readonly ISysUserMsgService _userMsgService;
|
|
|
|
/// <summary>
|
|
///
|
|
/// </summary>
|
|
/// <param name="categoryService"></param>
|
|
/// <param name="topicService"></param>
|
|
/// <param name="sysConfigService"></param>
|
|
/// <param name="userMsgService"></param>
|
|
public ArticleService(
|
|
IArticleCategoryService categoryService,
|
|
IArticleTopicService topicService,
|
|
ISysConfigService sysConfigService,
|
|
ISysUserMsgService userMsgService)
|
|
{
|
|
_categoryService = categoryService;
|
|
_topicService = topicService;
|
|
_sysConfigService = sysConfigService;
|
|
_userMsgService = userMsgService;
|
|
}
|
|
|
|
/// <summary>
|
|
/// 查询文章管理列表
|
|
/// </summary>
|
|
/// <param name="parm"></param>
|
|
/// <returns></returns>
|
|
public PagedInfo<ArticleDto> GetList(ArticleQueryDto parm)
|
|
{
|
|
var predicate = Expressionable.Create<Article>();
|
|
|
|
predicate = predicate.AndIF(!string.IsNullOrEmpty(parm.Title), m => m.Title.Contains(parm.Title));
|
|
predicate = predicate.AndIF(!string.IsNullOrEmpty(parm.AbstractText), m => m.AbstractText.Contains(parm.AbstractText));
|
|
predicate = predicate.AndIF(!string.IsNullOrEmpty(parm.Status), m => m.Status == parm.Status);
|
|
predicate = predicate.AndIF(parm.IsPublic != null, m => m.IsPublic == parm.IsPublic);
|
|
predicate = predicate.AndIF(parm.IsTop != null, m => m.IsTop == parm.IsTop);
|
|
predicate = predicate.AndIF(parm.ArticleType != null, m => (int)m.ArticleType == parm.ArticleType);
|
|
predicate = predicate.AndIF(parm.TopicId != null, m => m.TopicId == parm.TopicId);
|
|
predicate = predicate.AndIF(parm.AuditStatus != null, m => m.AuditStatus == parm.AuditStatus);
|
|
|
|
if (parm.CategoryId != null)
|
|
{
|
|
var allChildCategory = Context.Queryable<ArticleCategory>()
|
|
.ToChildList(m => m.ParentId, parm.CategoryId);
|
|
var categoryIdList = allChildCategory.Select(x => x.CategoryId).ToArray();
|
|
predicate = predicate.And(m => categoryIdList.Contains(m.CategoryId));
|
|
}
|
|
|
|
var response = Queryable()
|
|
.WithCache(60 * 24)
|
|
.IgnoreColumns(x => new { x.Content })
|
|
.Includes(x => x.ArticleCategoryNav) //填充子对象
|
|
.Where(predicate.ToExpression())
|
|
//.OrderBy(x => x.CreateTime, OrderByType.Desc)
|
|
.ToPage<Article, ArticleDto>(parm);
|
|
|
|
return response;
|
|
}
|
|
|
|
/// <summary>
|
|
/// 前台查询文章列表
|
|
/// </summary>
|
|
/// <param name="parm"></param>
|
|
/// <returns></returns>
|
|
public PagedInfo<ArticleDto> GetArticleList(ArticleQueryDto parm)
|
|
{
|
|
var predicate = Expressionable.Create<Article>();
|
|
predicate = predicate.And(m => m.Status == "1");
|
|
predicate = predicate.And(m => m.IsPublic == 1);
|
|
predicate = predicate.And(m => m.AuditStatus == AuditStatusEnum.Passed);
|
|
predicate = predicate.And(m => m.ArticleType == ArticleTypeEnum.Article);
|
|
//predicate = predicate.AndIF(!string.IsNullOrEmpty(parm.Title), m => m.Title.Contains(parm.Title));
|
|
predicate = predicate.AndIF(parm.TopicId != null, m => m.TopicId == parm.TopicId);
|
|
|
|
if (parm.CategoryId != null)
|
|
{
|
|
var allChildCategory = Context.Queryable<ArticleCategory>()
|
|
.ToChildList(m => m.ParentId, parm.CategoryId);
|
|
var categoryIdList = allChildCategory.Select(x => x.CategoryId).ToArray();
|
|
predicate = predicate.And(m => categoryIdList.Contains(m.CategoryId));
|
|
}
|
|
|
|
var response = Queryable()
|
|
.WithCache(60 * 30)
|
|
.Includes(x => x.ArticleCategoryNav)
|
|
.LeftJoin<SysUser>((m, u) => m.UserId == u.UserId).Filter(null, true)
|
|
.Where(predicate.ToExpression())
|
|
.OrderByDescending(m => m.Cid)
|
|
.Select((m, u) => new ArticleDto()
|
|
{
|
|
User = new ArticleUser()
|
|
{
|
|
Avatar = u.Avatar,
|
|
NickName = u.NickName,
|
|
Sex = u.Sex,
|
|
},
|
|
Content = string.Empty,
|
|
UserIP = string.Empty,
|
|
CategoryNav = m.ArticleCategoryNav.Adapt<ArticleCategoryDto>()
|
|
}, true)
|
|
.ToPage(parm);
|
|
|
|
if (parm.UserId > 0)
|
|
{
|
|
Context.ThenMapper(response.Result, item =>
|
|
{
|
|
item.IsPraise = Context.Queryable<ArticlePraise>()
|
|
.Where(f => f.UserId == parm.UserId && f.IsDelete == 0)
|
|
.SetContext(scl => scl.ArticleId, () => item.Cid, item).Any() ? 1 : 0;
|
|
});
|
|
}
|
|
|
|
return response;
|
|
}
|
|
|
|
/// <summary>
|
|
/// 前台查询动态列表
|
|
/// </summary>
|
|
/// <param name="parm"></param>
|
|
/// <returns></returns>
|
|
public PagedInfo<ArticleDto> GetMonentList(ArticleQueryDto parm)
|
|
{
|
|
var predicate = Expressionable.Create<Article>();
|
|
predicate = predicate.And(m => m.Status == "1");
|
|
predicate = predicate.And(m => m.IsPublic == 1);
|
|
predicate = predicate.And(m => m.ArticleType == ArticleTypeEnum.Monent);
|
|
predicate = predicate.And(m => m.AuditStatus == AuditStatusEnum.Passed);
|
|
predicate = predicate.AndIF(parm.TopicId != null, m => m.TopicId == parm.TopicId);
|
|
predicate = predicate.AndIF(parm.CategoryId != null, m => m.CategoryId == parm.CategoryId);
|
|
|
|
var response = Queryable()
|
|
.Includes(x => x.ArticleCategoryNav) //填充子对象
|
|
.LeftJoin<SysUser>((m, u) => m.UserId == u.UserId).Filter(null, true)
|
|
.Where(predicate.ToExpression())
|
|
.OrderByIF(parm.OrderBy == 1, m => new { m.PraiseNum, m.CommentNum }, OrderByType.Desc)
|
|
.OrderByIF(parm.OrderBy == 2, m => new { m.Cid }, OrderByType.Desc)
|
|
.OrderBy(m => m.Cid, OrderByType.Desc)
|
|
.Select((m, u) => new ArticleDto()
|
|
{
|
|
User = new ArticleUser()
|
|
{
|
|
Avatar = u.Avatar,
|
|
NickName = u.NickName,
|
|
Sex = u.Sex,
|
|
},
|
|
CategoryNav = m.ArticleCategoryNav.Adapt<ArticleCategoryDto>()
|
|
}, true)
|
|
.ToPage(parm);
|
|
|
|
if (parm.UserId > 0)
|
|
{
|
|
Context.ThenMapper(response.Result, item =>
|
|
{
|
|
item.IsPraise = Context.Queryable<ArticlePraise>()
|
|
.Where(f => f.UserId == parm.UserId && f.IsDelete == 0)
|
|
.SetContext(scl => scl.ArticleId, () => item.Cid, item).Any() ? 1 : 0;
|
|
});
|
|
}
|
|
|
|
return response;
|
|
}
|
|
/// <summary>
|
|
/// 前台查询关注动态列表
|
|
/// </summary>
|
|
/// <param name="parm"></param>
|
|
/// <returns></returns>
|
|
public PagedInfo<ArticleDto> GetFollowMonentList(ArticleQueryDto parm)
|
|
{
|
|
var predicate = Expressionable.Create<Article>();
|
|
predicate = predicate.And(m => m.Status == "1");
|
|
predicate = predicate.And(m => m.IsPublic == 1);
|
|
predicate = predicate.And(m => m.ArticleType == ArticleTypeEnum.Monent);
|
|
predicate = predicate.AndIF(parm.TopicId != null, m => m.TopicId == parm.TopicId);
|
|
predicate = predicate.AndIF(parm.CategoryId != null, m => m.CategoryId == parm.CategoryId);
|
|
|
|
|
|
return new PagedInfo<ArticleDto>() { };
|
|
}
|
|
/// <summary>
|
|
/// 查询我的文章列表
|
|
/// </summary>
|
|
/// <param name="parm"></param>
|
|
/// <returns></returns>
|
|
public PagedInfo<ArticleDto> GetMyList(ArticleQueryDto parm)
|
|
{
|
|
var predicate = Expressionable.Create<Article>();
|
|
|
|
predicate = predicate.AndIF(!string.IsNullOrEmpty(parm.Title), m => m.Title.Contains(parm.Title));
|
|
predicate = predicate.AndIF(!string.IsNullOrEmpty(parm.Status), m => m.Status == parm.Status);
|
|
predicate = predicate.AndIF(parm.BeginTime != null, m => m.CreateTime >= parm.BeginTime);
|
|
predicate = predicate.AndIF(parm.EndTime != null, m => m.CreateTime <= parm.EndTime);
|
|
predicate = predicate.And(m => m.UserId == parm.UserId);
|
|
predicate = predicate.AndIF(parm.ArticleType != null, m => (int)m.ArticleType == parm.ArticleType);
|
|
predicate = predicate.AndIF(parm.TabId == 2, m => m.IsPublic == 0 && m.UserId == parm.UserId);
|
|
|
|
var response = Queryable()
|
|
//.IgnoreColumns(x => new { x.Content })
|
|
.Includes(x => x.ArticleCategoryNav)
|
|
.Where(predicate.ToExpression())
|
|
.OrderByIF(parm.TabId == 3, m => new { m.IsTop, m.PraiseNum }, OrderByType.Desc)
|
|
.OrderByDescending(m => new { m.IsTop, m.Cid })
|
|
.Select((x) => new ArticleDto()
|
|
{
|
|
Content = x.ArticleType == 0 ? string.Empty : x.Content,
|
|
}, true)
|
|
.ToPage(parm);
|
|
|
|
return response;
|
|
}
|
|
|
|
/// <summary>
|
|
/// 修改文章管理
|
|
/// </summary>
|
|
/// <param name="model"></param>
|
|
/// <returns></returns>
|
|
public int UpdateArticle(Article model)
|
|
{
|
|
var response = Update(w => w.Cid == model.Cid, it => new Article()
|
|
{
|
|
Title = model.Title,
|
|
Content = model.Content,
|
|
Status = model.Status,
|
|
Tags = model.Tags,
|
|
UpdateTime = DateTime.Now,
|
|
CoverUrl = model.CoverUrl,
|
|
CategoryId = model.CategoryId,
|
|
IsPublic = model.IsPublic,
|
|
AbstractText = model.AbstractText,
|
|
});
|
|
return response;
|
|
}
|
|
|
|
/// <summary>
|
|
/// 置顶文章
|
|
/// </summary>
|
|
/// <param name="model"></param>
|
|
/// <returns></returns>
|
|
public int TopArticle(Article model)
|
|
{
|
|
var response = Update(w => w.Cid == model.Cid, it => new Article()
|
|
{
|
|
IsTop = model.IsTop,
|
|
});
|
|
return response;
|
|
}
|
|
|
|
/// <summary>
|
|
/// 评论权限
|
|
/// </summary>
|
|
/// <param name="model"></param>
|
|
/// <returns></returns>
|
|
public int ChangeComment(Article model)
|
|
{
|
|
var response = Update(w => w.Cid == model.Cid, it => new Article()
|
|
{
|
|
CommentSwitch = model.CommentSwitch,
|
|
});
|
|
return response;
|
|
}
|
|
|
|
/// <summary>
|
|
/// 是否公开
|
|
/// </summary>
|
|
/// <param name="model"></param>
|
|
/// <returns></returns>
|
|
public int ChangeArticlePublic(Article model)
|
|
{
|
|
var response = Update(w => w.Cid == model.Cid, it => new Article()
|
|
{
|
|
IsPublic = model.IsPublic,
|
|
});
|
|
return response;
|
|
}
|
|
|
|
/// <summary>
|
|
/// 修改文章访问量
|
|
/// </summary>
|
|
/// <param name="cid"></param>
|
|
/// <returns></returns>
|
|
public int UpdateArticleHit(long cid)
|
|
{
|
|
var response = Update(w => w.Cid == cid, it => new Article() { Hits = it.Hits + 1 });
|
|
return response;
|
|
}
|
|
|
|
/// <summary>
|
|
/// 点赞
|
|
/// </summary>
|
|
/// <param name="cid"></param>
|
|
/// <returns></returns>
|
|
public int PraiseArticle(long cid)
|
|
{
|
|
return Update(w => w.Cid == cid, it => new Article() { PraiseNum = it.PraiseNum + 1 });
|
|
}
|
|
public int CancelPraise(long cid)
|
|
{
|
|
return Update(w => w.Cid == cid, it => new Article() { PraiseNum = it.PraiseNum - 1 });
|
|
}
|
|
|
|
public Article PublishArticle(Article article)
|
|
{
|
|
throw new NotImplementedException();
|
|
}
|
|
|
|
/// <summary>
|
|
/// 发布动态
|
|
/// </summary>
|
|
/// <param name="article"></param>
|
|
/// <returns></returns>
|
|
public Article PublishMonent(Article article)
|
|
{
|
|
var httpContext = App.HttpContext;
|
|
article.ArticleType = ArticleTypeEnum.Monent;
|
|
article.AuthorName = HttpContextExtension.GetName(httpContext);
|
|
article.UserId = HttpContextExtension.GetUId(httpContext);
|
|
article.UserIP = HttpContextExtension.GetClientUserIp(httpContext);
|
|
article.Location = HttpContextExtension.GetIpInfo(article.UserIP);
|
|
article.AuditStatus = AuditStatusEnum.Passed;
|
|
|
|
article = InsertReturnEntity(article);
|
|
//跟新话题加入数
|
|
if (article.Cid > 0 && article.TopicId > 0)
|
|
{
|
|
_topicService.Update(w => w.TopicId == article.TopicId, it => new ArticleTopic() { JoinNum = it.JoinNum + 1 });
|
|
}
|
|
//更新圈子加入数
|
|
if (article.Cid > 0 && article.CategoryId > 0)
|
|
{
|
|
_categoryService.Update(w => w.CategoryId == article.CategoryId, it => new ArticleCategory() { JoinNum = it.JoinNum + 1 });
|
|
}
|
|
return article;
|
|
}
|
|
|
|
/// <summary>
|
|
/// 获取文章详情
|
|
/// </summary>
|
|
/// <param name="cid">内容id</param>
|
|
/// <param name="userId">当前用户id</param>
|
|
/// <returns></returns>
|
|
/// <exception cref="CustomException"></exception>
|
|
public ArticleDto GetArticle(long cid, long userId)
|
|
{
|
|
var response = GetId(cid);
|
|
var model = response.Adapt<ArticleDto>() ?? throw new CustomException(ResultCode.FAIL, "内容不存在");
|
|
if (model.IsPublic == 0 && userId != model.UserId)
|
|
{
|
|
throw new CustomException(ResultCode.CUSTOM_ERROR, "访问失败");
|
|
}
|
|
if (model != null)
|
|
{
|
|
model.CategoryNav = _categoryService.GetById(model.CategoryId).Adapt<ArticleCategoryDto>();
|
|
}
|
|
|
|
var webContext = App.HttpContext;
|
|
var CK = "ARTICLE_DETAILS_" + userId + HttpContextExtension.GetClientUserIp(webContext);
|
|
if (!CacheHelper.Exists(CK))
|
|
{
|
|
UpdateArticleHit(cid);
|
|
var userIP = HttpContextExtension.GetClientUserIp(webContext);
|
|
var location = HttpContextExtension.GetIpInfo(userIP);
|
|
itenant.InsertableWithAttr(new ArticleBrowsingLog()
|
|
{
|
|
ArticleId = cid,
|
|
UserId = userId,
|
|
Location = location,
|
|
UserIP = userIP,
|
|
AddTime = DateTime.Now,
|
|
}).ExecuteReturnSnowflakeId();
|
|
}
|
|
CacheHelper.SetCache(CK, 1, 10);
|
|
if (userId > 0)
|
|
{
|
|
model.IsPraise = Context.Queryable<ArticlePraise>()
|
|
.Where(f => f.UserId == userId && f.ArticleId == cid && f.IsDelete == 0)
|
|
.Any() ? 1 : 0;
|
|
}
|
|
|
|
return model;
|
|
}
|
|
|
|
/// <summary>
|
|
/// 审核通过
|
|
/// </summary>
|
|
/// <param name="idsArr"></param>
|
|
/// <returns></returns>
|
|
public int Passed(long[] idsArr)
|
|
{
|
|
int result = 0;
|
|
List<Article> monents = new();
|
|
foreach (var item in idsArr)
|
|
{
|
|
var model = GetFirst(x => x.Cid == item && x.AuditStatus == 0);
|
|
if (model == null) continue;
|
|
|
|
//model.Auditor = HttpContext.GetName();
|
|
model.AuditStatus = AuditStatusEnum.Passed;
|
|
var response = Update(w => w.Cid == model.Cid, it => new Article()
|
|
{
|
|
AuditStatus = model.AuditStatus,
|
|
//Auditor = model.Auditor,
|
|
});
|
|
result += response;
|
|
monents.Add(model);
|
|
}
|
|
var data = from a in monents
|
|
group a by new { a.UserId } into grp
|
|
select new
|
|
{
|
|
userid = grp.Key.UserId,
|
|
num = grp.Count()
|
|
};
|
|
foreach (var item in data)
|
|
{
|
|
_userMsgService.AddSysUserMsg(item.userid, "您发布的内容已通过审核", UserMsgType.SYSTEM);
|
|
}
|
|
|
|
return result;
|
|
}
|
|
|
|
/// <summary>
|
|
/// 审核不通过
|
|
/// </summary>
|
|
/// <param name="reason"></param>
|
|
/// <param name="idsArr"></param>
|
|
/// <returns></returns>
|
|
public int Reject(string reason, long[] idsArr)
|
|
{
|
|
int result = 0;
|
|
List<Article> monents = new();
|
|
foreach (var item in idsArr)
|
|
{
|
|
var model = GetFirst(x => x.Cid == item && x.AuditStatus == 0);
|
|
if (model == null) continue;
|
|
|
|
//model.Auditor = HttpContext.GetName();
|
|
model.AuditStatus = AuditStatusEnum.Reject;
|
|
var response = Update(w => w.Cid == model.Cid, it => new Article()
|
|
{
|
|
AuditStatus = model.AuditStatus,
|
|
//Auditor = model.Auditor,
|
|
});
|
|
result += response;
|
|
monents.Add(model);
|
|
}
|
|
var data = from a in monents
|
|
group a by new { a.UserId } into grp
|
|
select new
|
|
{
|
|
userid = grp.Key.UserId,
|
|
num = grp.Count()
|
|
};
|
|
foreach (var item in data)
|
|
{
|
|
//Console.WriteLine(item.useridx +"," + item.num);
|
|
string content = $"您发布的内容未通过审核。";
|
|
if (!string.IsNullOrEmpty(reason))
|
|
{
|
|
content += $"原因：{reason}";
|
|
}
|
|
_userMsgService.AddSysUserMsg(item.userid, content, UserMsgType.SYSTEM);
|
|
}
|
|
|
|
return result;
|
|
}
|
|
|
|
}
|
|
}
|