Yi.Admin/Yi.Framework.Net6/Yi.Framework.WebCore/AutoFacExtend/CustomAutofacModule.cs

using Autofac;
using Autofac.Extras.DynamicProxy;
using Castle.DynamicProxy;
using Microsoft.AspNetCore.Http;
using Microsoft.AspNetCore.Mvc.ApplicationParts;
using Microsoft.AspNetCore.Mvc.Controllers;
using Microsoft.EntityFrameworkCore;
using System;
using System.Collections.Generic;
using System.IO;
using System.Linq;
using System.Reflection;
using System.Threading.Tasks;
using Yi.Framework.Common.Abstract;
using Yi.Framework.Core.Cache.Aop;
using Yi.Framework.Interface;
using Yi.Framework.Job;
using Yi.Framework.Repository;
using Yi.Framework.Service;
using Yi.Framework.WebCore.AutoFacExtend;
using Yi.Framework.WebCore.CommonExtend;
using Yi.Framework.WebCore.Impl;
using Module = Autofac.Module;

namespace Yi.Framework.WebCore.AutoFacExtend
{
    public class CustomAutofacModule : Module
    {
        private Assembly GetDll(string ass)
        {
            var basePath = AppContext.BaseDirectory;
            var servicesDllFile = Path.Combine(basePath, ass);
            if (!(File.Exists(servicesDllFile)))
            {
                var msg = "service.dll 丢失，请编译后重新生成。";
                throw new Exception(msg);
            }
            return Assembly.LoadFrom(servicesDllFile); ;
        }

        protected override void Load(ContainerBuilder containerBuilder)
        {

            //containerBuilder.RegisterType<DbContextFactory>().As<IDbContextFactory>().InstancePerDependency().EnableInterfaceInterceptors();

            containerBuilder.RegisterType<HttpContextAccessor>().As<IHttpContextAccessor>().SingleInstance();

            var cacheType = new List<Type>();

            //containerBuilder.RegisterGeneric(typeof(Repository<>)).As(typeof(IRepository<>)).InstancePerLifetimeScope();
            //containerBuilder.RegisterGeneric(typeof(BaseService<>)).As(typeof(IBaseService<>)).InstancePerLifetimeScope();
            ///反射注入服务层及接口层     
            var assemblysServices = GetDll("Yi.Framework.Service.dll");
            var regContainerBuilder = containerBuilder.RegisterAssemblyTypes(assemblysServices).PropertiesAutowired(new AutowiredPropertySelector())
                        .AsImplementedInterfaces()
                        .InstancePerLifetimeScope()
                        .EnableInterfaceInterceptors();

            if (Appsettings.appBool("CacheAOP_Enabled"))
            {
                var cacheSelect = Appsettings.app("CacheSelect");

                switch (cacheSelect)
                {
                    case "Redis":
                        containerBuilder.RegisterType<RedisCacheAOP>();
                        cacheType.Add(typeof(RedisCacheAOP));
                        break;
                    case "MemoryCache":
                        containerBuilder.RegisterType<MemoryCacheAOP>();
                        cacheType.Add(typeof(MemoryCacheAOP));
                        break;
                    default: throw new ArgumentException("CacheSelect配置填的是什么东西？俺不认得");
                }
                regContainerBuilder.InterceptedBy(cacheType.ToArray());
            }
                     
            //开启工作单元拦截
            //.InterceptedBy(typeof(UnitOfWorkInterceptor));

            ///反射注册任务调度层
            var assemblysJob = GetDll("Yi.Framework.Job.dll");
            containerBuilder.RegisterAssemblyTypes(assemblysJob)
                     .InstancePerDependency();



            containerBuilder.Register(c => new CustomAutofacAop());//AOP注册

            //containerBuilder.RegisterType<A>().As<IA>().EnableInterfaceInterceptors();开启Aop

            //将数据库对象注入
            //containerBuilder.RegisterType<DataContext>().As<DbContext>().InstancePerLifetimeScope().EnableInterfaceInterceptors();

            //containerBuilder.RegisterGeneric(typeof(BaseService<>)).As(typeof(IBaseService<>)).InstancePerDependency().EnableInterfaceInterceptors();


        }

    }
}


public interface IAutofacTest
{
    void Show(int id, string name);
}

[Intercept(typeof(CustomAutofacAop))]
public class AutofacTest : IAutofacTest
{
    public void Show(int id, string name)
    {
        Console.WriteLine($"This is {id} _ {name}");
    }
}