src/SSCMS.Core/Services/CreateManager.cs

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

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

using System.Threading.Tasks;
using SSCMS.Dto;
using SSCMS.Enums;
using SSCMS.Repositories;
using SSCMS.Services;
using SSCMS.Utils;

namespace SSCMS.Core.Services
{
    public partial class CreateManager : ICreateManager
    {
        private readonly IPathManager _pathManager;
        private readonly IParseManager _parseManager;
        private readonly ITaskManager _taskManager;
        private readonly IChannelRepository _channelRepository;
        private readonly IContentRepository _contentRepository;
        private readonly ISiteRepository _siteRepository;
        private readonly ISpecialRepository _specialRepository;
        private readonly ITemplateRepository _templateRepository;

        public CreateManager(IPathManager pathManager, IParseManager parseManager, ITaskManager taskManager, IChannelRepository channelRepository, IContentRepository contentRepository, ISiteRepository siteRepository, ISpecialRepository specialRepository, ITemplateRepository templateRepository)
        {
            _pathManager = pathManager;
            _parseManager = parseManager;
            _taskManager = taskManager;
            _channelRepository = channelRepository;
            _contentRepository = contentRepository;
            _siteRepository = siteRepository;
            _specialRepository = specialRepository;
            _templateRepository = templateRepository;
        }

        public async Task CreateByAllAsync(int siteId)
        {
            ClearAllTask(siteId);

            var channelIdList = await _channelRepository.GetChannelIdsAsync(siteId);
            foreach (var channelId in channelIdList)
            {
                await CreateChannelAsync(siteId, channelId);
            }

            foreach (var channelId in channelIdList)
            {
                await CreateAllContentAsync(siteId, channelId);
            }

            foreach (var specialId in await _specialRepository.GetAllSpecialIdsAsync(siteId))
            {
                await CreateSpecialAsync(siteId, specialId);
            }

            foreach (var fileTemplateId in await _templateRepository.GetAllFileTemplateIdsAsync(siteId))
            {
                await CreateFileAsync(siteId, fileTemplateId);
            }
        }

        public async Task CreateByTemplateAsync(int siteId, int templateId)
        {