src/ZKEACMS/Setting/ApplicationSettingService.cs

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

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

/* http://www.zkea.net/ 
 * Copyright (c) ZKEASOFT. All rights reserved. 
 * http://www.zkea.net/licenses */

using System;
using System.Collections.Concurrent;
using System.Linq;
using Easy;
using Easy.Cache;
using Easy.Constant;
using Easy.Extend;
using Easy.RepositoryPattern;
using Microsoft.EntityFrameworkCore;
using ZKEACMS.DataArchived;

namespace ZKEACMS.Setting
{
    public class ApplicationSettingService : ServiceBase<ApplicationSetting, CMSDbContext>, IApplicationSettingService
    {
        private readonly IDataArchivedService _dataArchivedService;
        private readonly ConcurrentDictionary<string, object> _settingCache;
        private const string ApplicationSetting = "ApplicationSetting";
        public ApplicationSettingService(IApplicationContext applicationContext,
            IDataArchivedService dataArchivedService,
            ICacheManager<ConcurrentDictionary<string, object>> cacheManager,
            CMSDbContext dbContext) : base(applicationContext, dbContext)
        {
            _dataArchivedService = dataArchivedService;
            _settingCache = cacheManager.GetOrAdd(ApplicationSetting, new ConcurrentDictionary<string, object>());
        }

        public override DbSet<ApplicationSetting> CurrentDbSet => DbContext.ApplicationSetting;

        public override IQueryable<ApplicationSetting> Get()
        {
            return CurrentDbSet.AsNoTracking();
        }

        public override ServiceResult<ApplicationSetting> Add(ApplicationSetting item)
        {
            lock (ApplicationSetting)
            {
                if (base.Get(item.SettingKey) == null)
                {
                    _settingCache.TryAdd(item.SettingKey, item);
                    return base.Add(item);
                }
                var result = new ServiceResult<ApplicationSetting>();
                result.RuleViolations.Add(new RuleViolation("SettingKey", ApplicationContext.GetService<ILocalize>().Get("The setting key is already exists")));
                return result;
            }

        }
        public override ApplicationSetting Get(params object[] primaryKey)
        {
            if (_settingCache.TryGetValue(primaryKey[0].ToString(), out object value))
            {
                return value as ApplicationSetting;
            }
            var entity = base.Get(primaryKey);