track/src/SJZY.Track.Application/SjzyTrackApplicationModule.cs

using BSI.Stack.Rabbit;
using DotNetCore.CAP;
using DotNetCore.CAP.Internal;
using Microsoft.Extensions.Configuration;
using RabbitMQ.Client;
using Savorboard.CAP.InMemoryMessageQueue;
using SJZY.Expand.ABP.Core.Localization;
using SJZY.Expand.ABP.Core.Logger;
using SJZY.Expand.ABP.Core.PublicMethords;
using SJZY.InterfaceRelay.Application.Contracts;
using SJZY.Track.Application.CAP;
using SJZY.Track.Application.Contract;
using SJZY.Track.Application.Localization;
using SJZY.Track.Domain.Consts;
using SJZY.UserCenter.Contracts;
using SJZY.UserCenter.SharedModel;
using SJZY.UserCenter.SharedModel.Pub;
using Volo.Abp.AspNetCore.Mvc;
using Volo.Abp.AutoMapper;
using Volo.Abp.FluentValidation;
using Volo.Abp.Http.Client;
using Volo.Abp.Localization;
using Volo.Abp.Modularity;
using Volo.Abp.VirtualFileSystem;

namespace SJZY.Track.Application;

[DependsOn(
    typeof(AbpAutoMapperModule),
    typeof(AbpFluentValidationModule),
    typeof(AbpLocalizationModule),
    typeof(AbpVirtualFileSystemModule),
    typeof(AbpHttpClientModule),
    typeof(SjzyUserCenterHttpApiModule),
    typeof(SJZYInterfaceRelayApplicationContractsModule),
    typeof(SjzyTrackDomainModule),
    typeof(SjzyTrackApplicationContractModule)
)]
public class SjzyTrackApplicationModule : AbpModule
{
    public override void ConfigureServices(ServiceConfigurationContext context)
    {
        var configuration = context.Services.GetConfiguration();
        Configure<AbpAutoMapperOptions>(options => { options.AddMaps<SjzyTrackApplicationModule>(true); });

        Configure<AbpAspNetCoreMvcOptions>(options =>
        {
            options.ConventionalControllers.Create(typeof(SjzyTrackApplicationModule).Assembly); //创建动态api
        });

        //添加虚拟文件系统
        Configure<AbpVirtualFileSystemOptions>(options =>
        {
            options.FileSets.AddEmbedded<SjzyTrackApplicationModule>("SJZY.Track.Application");
        });

        //添加多语言
        var languageConfig = configuration.GetSection("Language");
        Configure<AbpLocalizationOptions>(options =>
        {
            options.Resources
                .Add<TrackLocalizationResource>("zh")
                .AddBaseTypes(typeof(SjzyBasicLocalization))
                .AddRedisResource(languageConfig)
                .AddVirtualJson("/Localization/Resources");
        });
        //授权拦截提示
        context.Services.Configure<MvcOptions>(options => { options.Filters.Add(new ApiAsyncAuthorizationFilter()); });

        //用户中心
        context.Services.AddHttpClientProxies(typeof(SjzyUserCenterHttpApiModule).Assembly, "UserCenter", false);
        context.Services.AddHttpClient("InterfaceForward").AddHttpMessageHandler<InterfaceForwardHeaderHandler>();
        context.Services.AddHttpClientProxies(typeof(SJZYInterfaceRelayApplicationContractsModule).Assembly,
            "InterfaceForward", false
        );

        //CAP
        context.Services.AddSingleton<ISubscribeExecutor, MySubscribeExecutor>();
        context.Services.AddCapTableNameService();
        context.Services.AddCap(options =>
        {
#if DEBUG
            options.UseInMemoryStorage();
            options.UseInMemoryMessageQueue();
#else
            options.UseMySql(configuration["ConnectionStrings:DefaultConnection"]!);
            options.UseRabbitMQ(configure =>
            {
                configure.HostName = configuration["RabbitMQ:HostName"]!;
                configure.UserName = configuration["RabbitMQ:UserName"]!;
                configure.Password = configuration["RabbitMQ:Password"]!;
                configure.Port = configuration.GetValue<int>("RabbitMQ:Port");
                configure.BasicQosOptions =
                    new RabbitMQOptions.BasicQos(configuration.GetValue<ushort>("CAP:PrefetchCount"));
            });
#endif
            options.FailedRetryInterval = configuration.GetValue<int>("CAP:FailedRetryInterval");
            options.FailedRetryCount = configuration.GetValue<int>("CAP:FailedRetryCount");
            options.SucceedMessageExpiredAfter = configuration.GetValue<int>("CAP:SucceedMessageExpiredAfter");
            options.FallbackWindowLookbackSeconds =
                configuration.GetValue<int>("CAP:FallbackWindowLookbackSeconds");

            options.UseDashboard(dashboardOptions =>
            {
                dashboardOptions.PathBase = System.Diagnostics.Debugger.IsAttached
                    ? ""
                    : configuration["Swagger:JsonUrlPrefix"]!;
            });
            options.FailedThresholdCallback = faileCalback =>
            {
                try
                {
                    LogHelper.Error($@"
    |-CAP失败回调事件：
    |-处理类型：{(faileCalback.MessageType == DotNetCore.CAP.Messages.MessageType.Subscribe ? "消费消息达到最大重试次数，需要开发人员介入" : "生产消息推送失败")}
    |-头部信息：{faileCalback.Message.Headers.ToJson()}");
                }
                catch (Exception ex)
                {
                    LogHelper.Error("【严重】CAP失败回调事件发生未处理异常" + ex);
                }
            };
        }).AddSubscribeFilter<CapFilter>();


        context.Services.AddRabbitBoot(options =>
        {
            options.ConnectionString =
                $"amqp://{configuration["RabbitMQ:UserName"]}:{configuration["RabbitMQ:Password"]}@{configuration["RabbitMQ:HostName"]}:{configuration["RabbitMQ:Port"]}";
            options.PoolSize = configuration.GetValue<int>("RabbitMQ:PoolSize");
            options.Consumes = new List<ConsumeOptions>
            {
                new()
                {
                    Queue = GlobalConst.TrackRefreshSubscribe,
                    FetchCount = configuration.GetValue<ushort>("RabbitMQ:TrackRefreshFetchCount"),
                    FailedRequeue = false,
                    Declaration = o =>
                    {
                        o.ExchangeDeclare(GlobalConst.InterfaceRelayExchange, ExchangeType.Direct, true);
                        o.QueueDeclare(GlobalConst.TrackRefreshSubscribe, true);
                        o.QueueBind(GlobalConst.TrackRefreshSubscribe, GlobalConst.InterfaceRelayExchange,
                            GlobalConst.TrackRefreshSubscribe);
                    }
                }
            };
        }, typeof(SjzyTrackApplicationModule).Assembly);
    }

    public override void PreConfigureServices(ServiceConfigurationContext context)
    {
        PreConfigure<AbpHttpClientBuilderOptions>(options =>
        {
            options.ProxyClientActions.Add((_, _, httpClient) =>
            {
                //如果设置Token，前端需要传入Token 否则引发异常
                httpClient.SetTokenHeader();
                httpClient.Timeout = TimeSpan.FromMinutes(3);
            });
        });
    }
}