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.Expand.AliyunOSS;
using SJZY.InterfaceRelay.Application.Contracts;
using SJZY.Track.Application.CAP;
using SJZY.Track.Application.Contract;
using SJZY.Track.Application.Localization;
using SJZY.Track.Application.Options;
using SJZY.Track.Application.Track2InterfaceRelay;
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.Configure<Track2InterfaceRelayOptions>(configuration.GetSection("Track2InterfaceRelay"));
        context.Services.AddHttpClient("InterfaceForward")
            .AddHttpMessageHandler<Track2InterfaceRelayHttpMessageHandler>();
        context.Services.AddHttpClientProxies(typeof(SJZYInterfaceRelayApplicationContractsModule).Assembly,
            "InterfaceForward", false
        );

        //CAP
        context.Services.AddSingleton<ISubscribeExecutor, MySubscribeExecutor>();
        context.Services.AddCapTableNameService();
        if (!System.Diagnostics.Debugger.IsAttached)
        {
            context.Services.AddCap(options =>
            {
                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"));
                });
                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>();
        }
        else
        {
            //是本地调试环境，用内存存储和内存队列
            context.Services.AddCap(capOptions =>
            {
                capOptions.UseInMemoryStorage();
                capOptions.UseInMemoryMessageQueue();
                capOptions.UseDashboard();
            }).AddSubscribeFilter<CapFilter>();
            Console.WriteLine("-- 当前为VS本地环境，用内存存储和内存队列");
        }


        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.Declarations = new List<Action<IDeclaration>>()
            {
                o => o.ExchangeDeclare(GlobalConst.TrackChangeExchange, ExchangeType.Topic, true),
                o => o.ExchangeDeclare(GlobalConst.TrackPushExchange, ExchangeType.Topic, true)
            };
            options.Consumes = new List<ConsumeOptions>
            {
                new()
                {
                    Queue = GlobalConst.TrackRefreshSubscribe,
                    FetchCount = configuration.GetValue<ushort>("TrackApp: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);
                    }
                },
                new()
                {
                    Queue = GlobalConst.TrackPushCompletedSubscribe,
                    FetchCount = configuration.GetValue<ushort>("TrackApp:TrackRefreshFetchCount"),
                    FailedRequeue = false,
                    Declaration = o =>
                    {
                        o.ExchangeDeclare(GlobalConst.InterfaceRelayExchange, ExchangeType.Direct, true);
                        o.QueueDeclare(GlobalConst.TrackPushCompletedSubscribe, true);
                        o.QueueBind(GlobalConst.TrackPushCompletedSubscribe, GlobalConst.InterfaceRelayExchange,
                            GlobalConst.TrackPushCompletedSubscribe);
                    }
                }
            };
        }, typeof(SjzyTrackApplicationModule).Assembly);

        context.Services.Configure<TrackAppOptions>(configuration.GetSection("TrackApp"));
        context.Services.Configure<InterfaceRelayParamsConfigOptions>(
            configuration.GetSection("InterfaceRelayParamsConfig"));

        //注册阿里云OSS服务
        context.Services.AddAliOSS(option =>
        {
            option.AccessKeyId = configuration["OSS:AccessKeyId"];
            option.AccessKeySecret = configuration["OSS:AccessKeySecret"];
            option.Endpoint = configuration["OSS:Endpoint"];
            option.BucketName = configuration["OSS:BucketName"];
            option.ReturnHttpsUrl = true;
        });
    }

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