src/ZKEACMS/DataArchived/DataArchivedService.cs

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

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

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

using System;
using System.IO;
using System.Linq;
using Easy;
using Easy.Extend;
using Easy.RepositoryPattern;
using Microsoft.EntityFrameworkCore;
using Newtonsoft.Json;

namespace ZKEACMS.DataArchived
{
    public class DataArchivedService : ServiceBase<DataArchived, CMSDbContext>, IDataArchivedService
    {
        private const string ArchiveLock = "ArchiveLock";

        public DataArchivedService(IApplicationContext applicationContext, CMSDbContext dbContext) : base(applicationContext, dbContext)
        {
        }

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

        public JsonConverter[] JsonConverters { get; set; }

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

        public override DataArchived Get(params object[] primaryKey)
        {
            string key = primaryKey[0].ToString();
            return Get().FirstOrDefault(m => m.ID == key);
        }

        public override ServiceResult<DataArchived> Add(DataArchived item)
        {
            lock (ArchiveLock)
            {
                Remove(item.ID);
                return base.Add(item);
            }

        }

        public T Get<T>(string key, Func<T> fun) where T : class
        {
            var archived = Get(key);
            T result = null;
            if (archived != null && archived.Data.IsNotNullAndWhiteSpace())
            {
                result = Deserialize<T>(archived.Data);
            }
            if (result == null)
            {
                result = fun();
                Add(new DataArchived { ID = key, Data = Serialize(result) });