BookingHeChuan/Myshipping.Web.Core/Startup.cs

using Furion;
using Myshipping.Core;
using Myshipping.Core.Service;
using Microsoft.AspNetCore.Builder;
using Microsoft.AspNetCore.Hosting;
using Microsoft.AspNetCore.Http.Features;
using Microsoft.AspNetCore.Server.Kestrel.Core;
using Microsoft.Extensions.DependencyInjection;
using Microsoft.Extensions.Hosting;
using Microsoft.Extensions.Logging;
using System;
using System.Net;
using System.Net.Http;
using System.Text.Encodings.Web;
using System.Text.Json;
using System.Text.Json.Serialization;
using System.Text.Unicode;
using Yitter.IdGenerator;
using Furion.Templates;
using Furion.Logging;
using System.Collections.Generic;
using Newtonsoft.Json.Serialization;
using Newtonsoft.Json;
using Myshipping.Application.ConfigOption;
using Myshipping.Application.Event;
using Myshipping.Core.MQ;
using Myshipping.Application.MQ;

namespace Myshipping.Web.Core;

[AppStartup(9)]
public class Startup : AppStartup
{
    public void ConfigureServices(IServiceCollection services)
    {
        services.AddBStyle(m => m.UseDefault());
        services.AddConfigurableOptions<ConnectionStringsOptions>();
        services.AddConfigurableOptions<JWTSettingsOptions>();
        services.AddConfigurableOptions<CacheOptions>();
        services.AddConfigurableOptions<SnowIdOptions>();
        services.AddConfigurableOptions<SystemSettingsOptions>();
        services.AddConfigurableOptions<UploadFileOptions>();
        services.AddConfigurableOptions<OAuthOptions>();
        services.AddConfigurableOptions<EncryptKeyOptions>();
        services.AddConfigurableOptions<PrintTemplateOptions>();
        services.AddConfigurableOptions<BookingAttachOptions>();
        services.AddConfigurableOptions<TempFileOptions>();

        #region 上传文件大小限制
        long maxRequestBodySize = Convert.ToInt64(App.Configuration["MaxRequestBodySize"]);
        services.Configure<KestrelServerOptions>(options =>
        {
            options.Limits.MaxRequestBodySize = maxRequestBodySize;
        });
        services.Configure<IISServerOptions>(options =>
        {
            options.MaxRequestBodySize = maxRequestBodySize;
        });

        services.Configure<FormOptions>(o =>
        {
            o.MultipartBodyLengthLimit = maxRequestBodySize;
        });
        #endregion

        services.AddResponseCompression();

        services.SqlSugarScopeConfigure();

        services.AddJwt<JwtHandler>(enableGlobalAuthorize: true);

        services.AddCorsAccessor();

        services.Configure<FormOptions>(option =>
        {
            option.MultipartBodyLengthLimit = 20 * 1024 * 1024;
        });

        // 配置远程请求
        services.AddRemoteRequest(option =>
        {
            // 配置天气预报GZIP
            option.AddHttpClient("wthrcdn", c =>
            {
                c.BaseAddress = new Uri("http://wthrcdn.etouch.cn/");
            }).ConfigurePrimaryHttpMessageHandler(_ =>
                new HttpClientHandler { AutomaticDecompression = DecompressionMethods.GZip });
        });
        services.AddControllersWithViews()
                .AddMvcFilter<RequestActionFilter>()
                .AddMvcFilter<ApiUserFilter>()
                .AddMvcFilter<SqlSugarUnitOfWorkFilter>()
                .AddInjectWithUnifyResult<RestfulResultProvider>()
                .AddNewtonsoftJson(options =>
                {
                    // 首字母小写(驼峰样式)
                    options.SerializerSettings.ContractResolver = new CamelCasePropertyNamesContractResolver();
                    // 时间格式化
                    options.SerializerSettings.DateFormatString = "yyyy-MM-dd HH:mm:ss";
                    // 忽略循环引用
                    options.SerializerSettings.ReferenceLoopHandling = ReferenceLoopHandling.Ignore;
                    // 忽略空值
                    options.SerializerSettings.NullValueHandling = NullValueHandling.Ignore;
                });

        services.AddViewEngine();
        services.AddSignalR();

        // 设置雪花id的workerId，确保每个实例workerId都应不同
        var workerId = ushort.Parse(App.GetOptions<SnowIdOptions>().WorkerId);
        YitIdHelper.SetIdGenerator(new IdGeneratorOptions { WorkerId = workerId });

        // 开启自启动定时任务
        App.GetService<ISysTimerService>().StartTimerJob();

        // 获取运行类型
        var runType = App.GetConfig<string>("RunType");

        // 注册EventBus服务
        services.AddEventBus(builder =>
        {
            // 注册 Log 日志订阅者
            builder.AddSubscriber<LogEventSubscriber>();
            //钉钉消息
            builder.AddSubscriber<DingTalkSubscriber>();
            //发送订舱同步数据给客户订舱系统
            builder.AddSubscriber<BookingSyncSubscriber>();
            //日志压缩清理
            builder.AddSubscriber<LogZipClearSubscriber>();
            //公司及用户信息的同步
            builder.AddSubscriber<CompanyUserSyncSubscriber>();
            //运踪
            builder.AddSubscriber<BillTraceSubscriber>();
            //更新库存
            builder.AddSubscriber<BookingSlotStockSubscriber>();
            //重要提醒任务
            builder.AddSubscriber<CautionNoticeTaskSubscriber>();

            //客户订舱：消息推送
            if (runType is CommonConst.RUN_TYPE_CUST or CommonConst.RUN_TYPE_DJY)
            {
                builder.AddSubscriber<MessagePushSubscriber>();
            }

            //客户订舱：发送租户和用户数据到运营端往来单位
            if (runType is CommonConst.RUN_TYPE_CUST)
            {
                builder.AddSubscriber<SyncTenantUserToDjyCustomerSubscriber>();
            }

            //自用订舱：处理订舱自动化
            if (runType is CommonConst.RUN_TYPE_NORMAL)
            {
                builder.AddSubscriber<BookingAutoSubscriber>();
            }

            //扣费
            builder.AddSubscriber<BookingFeeSubscriber>();
        });

        // 客户订舱客户端模式 与 标准模式（自用）：订阅大简云公司用户信息同步
        if (runType is CommonConst.RUN_TYPE_CUST or CommonConst.RUN_TYPE_NORMAL)
        {
            // 公司员工变动消息队列服务
            services.AddHostedService<RecCompanyUserChangeService>();
        }

        //自用订舱：处理订舱自动化
        if (runType is CommonConst.RUN_TYPE_NORMAL)
        {
            // 订舱自动化消息队列服务
            services.AddHostedService<BookingAutoService>();
        }
    }

    public void Configure(IApplicationBuilder app, IWebHostEnvironment env)
    {
        app.UseMiddleware<ResponseTimeMiddleware>();
        if (env.IsDevelopment())
        {
            app.UseDeveloperExceptionPage();
        }
        else
        {
            app.UseExceptionHandler("/Home/Error");
            app.UseHsts();
        }

        // 添加状态码拦截中间件
        app.UseUnifyResultStatusCodes();

        //app.UseHttpsRedirection(); // 强制https
        app.UseStaticFiles();

        app.UseRouting();

        app.UseCorsAccessor();

        app.UseAuthentication();
        app.UseAuthorization();

        app.UseResponseCompression();

        app.UseInject(string.Empty);

        app.UseEndpoints(endpoints =>
        {
            endpoints.MapHub<ChatHub>("/hubs/chathub");
            endpoints.MapControllerRoute(
                name: "default",
                pattern: "{controller=Home}/{action=Index}/{id?}");
        });

    }


}