src/ZKEACMS/Widget/SimpleWidgetService.cs

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

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

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

using System;
using System.Collections.Generic;
using System.Linq;
using System.Threading.Tasks;
using System.Linq.Expressions;
using Easy.RepositoryPattern;
using Easy;
using Microsoft.EntityFrameworkCore;
using Easy.Serializer;

namespace ZKEACMS.Widget
{
    public abstract class SimpleWidgetService<T> : WidgetService<T> where T : SimpleWidgetBase, new()
    {
        public SimpleWidgetService(IWidgetBasePartService widgetBasePartService, IApplicationContext applicationContext, CMSDbContext dbContext) :
            base(widgetBasePartService, applicationContext, dbContext)
        {
        }

        public override DbSet<T> CurrentDbSet => throw new NotImplementedException();
        public override T Get(params object[] primaryKeys)
        {
            var item = WidgetBasePartService.Get(primaryKeys);
            return item.CopyTo(JsonConverter.Deserialize<T>(item.ExtendData ?? "{}")) as T;
        }
        public override ServiceResult<T> Add(T item)
        {
            item.ID = Guid.NewGuid().ToString("N");
            item.ExtendData = JsonConverter.Serialize(item);
            WidgetBasePartService.Add(item.ToWidgetBasePart());
            return new ServiceResult<T>();
        }
        public override ServiceResult<T> AddRange(params T[] items)
        {
            foreach (var item in items)
            {
                item.ExtendData = JsonConverter.Serialize(item);
            }
            WidgetBasePartService.AddRange(items.Select(m => m.ToWidgetBasePart()).ToArray());
            return new ServiceResult<T>();
        }
        public override ServiceResult<T> Update(T item)
        {
            item.ExtendData = JsonConverter.Serialize(item);
            var basePart = WidgetBasePartService.Get(item.ID);
            item.CopyTo(basePart);
            WidgetBasePartService.Update(basePart);
            return new ServiceResult<T>();
        }
        public override ServiceResult<T> UpdateRange(params T[] items)
        {
            foreach (var item in items)
            {
                item.ExtendData = JsonConverter.Serialize(item);
            }
            var ids = items.Select(m => m.ID).ToArray();