BeiJinSettleAccount/code/src/Modules/SettleAccount/host/SettleAccount.HttpApi.Host/Startup.cs

using System;
using System.Linq;
using System.Text.RegularExpressions;
using Coravel;
using Coravel.Invocable;
using Microsoft.AspNetCore.Builder;
using Microsoft.AspNetCore.Hosting;
using Microsoft.AspNetCore.Mvc.ApplicationModels;
using Microsoft.AspNetCore.Routing;
using Microsoft.AspNetCore.Server.Kestrel.Core;
using Microsoft.AspNetCore.StaticFiles;
using Microsoft.Extensions.DependencyInjection;
using Microsoft.Extensions.Logging;
using NUglify.Helpers;
using SettleAccount.Job.SignalR;
using Win.Sfs.SettleAccount.Entities.BQ;
using Win.Sfs.SettleAccount.Entities.BQ.Vmi;

namespace Win.Sfs.SettleAccount;

public class Startup
{
    public void ConfigureServices(IServiceCollection services)
    {
        services.AddSignalR(o => o.EnableDetailedErrors = true);
        AppDomain.CurrentDomain.GetAssemblies().SelectMany(o => o.GetTypes())
            .Where(o => o.IsClass && !o.IsAbstract && o.IsAssignableTo(typeof(IJobService)))
            .ForEach(o => services.AddTransient(o));
        services.AddScheduler();
        services.AddTransient<HBPOSeSyncAppService>();
        services.AddRouting(options => options.ConstraintMap["slugify"] = typeof(SlugifyParameterTransformer));
        services.AddMvc(options => options.Conventions.Add(new RouteTokenTransformerConvention(new SlugifyParameterTransformer())));
        services.AddApplication<SettleAccountHttpApiHostModule>();
        services.Configure<KestrelServerOptions>(options =>
        {
            // Set the limit to 256 MB
            options.Limits.MaxRequestBodySize = 268435456;
        });
        //上传文件大小限制IIS设置
        services.Configure<IISServerOptions>(options =>
        {
            options.MaxRequestBodySize = 268435456;
            options.AllowSynchronousIO = true;
        });
    }

    public void Configure(IApplicationBuilder app, IWebHostEnvironment env, ILoggerFactory loggerFactory)
    {
        app.UseRouting();
        app.UseEndpoints(endpoints => endpoints.MapHub<PageHub>("/api/hub"));
        app.ApplicationServices.UseScheduler(scheduler =>
        {
            scheduler.Schedule<HBPOSeSyncAppService>().EveryMinute();
            using var scope = app.ApplicationServices.CreateScope();
            var jobs = scope.ServiceProvider.GetService<SettleAccountDbContext>().Set<JobItem>().ToList();
            jobs?.ForEach(job =>
            {
                var jobId = job.Id;
                using var scope = app.ApplicationServices.CreateScope();
                var serviceType = AppDomain.CurrentDomain.GetAssemblies().SelectMany(a => a.GetTypes()).FirstOrDefault(o => o.FullName == job.Service);
                if (serviceType != null)
                {
                    if (scope.ServiceProvider.GetService(serviceType) is IJobService jobService)
                    {
                        scheduler.Schedule(() =>
                        {
                            using var scope = app.ApplicationServices.CreateScope();
                            var db = scope.ServiceProvider.GetService<SettleAccountDbContext>();
                            var jobItemRepository = db.Set<JobItem>();
                            var jobLogRepository = db.Set<JobLog>();
                            var jobItem = jobItemRepository.FirstOrDefault(o => o.Id == jobId);
                            if (!jobItem.IsDisabled)
                            {
                                jobItem.IsRunning = true;
                                db.SaveChanges();
                                var jobLog = new JobLog { JobId = jobId, Start = DateTime.Now };
                                try
                                {
                                    jobService.Invoke();
                                    jobLog.Success = true;
                                }
                                catch (Exception ex)
                                {
                                    Console.WriteLine(ex.ToString());
                                    jobLog.Exception = ex.ToString();
                                }
                                finally
                                {
                                    jobLog.End = DateTime.Now;
                                    jobLogRepository.Add(jobLog);
                                    jobItem.IsRunning = false;
                                    db.SaveChanges();
                                }
                            }
                        }).Cron(job.Cron);
                    }
                }
            });
        });
        var contentTypeProvider = new FileExtensionContentTypeProvider();
        contentTypeProvider.Mappings.Add(".mjs", "text/javascript");
        app.UseStaticFiles(new StaticFileOptions { ContentTypeProvider = contentTypeProvider });
        app.InitializeApplication();
    }

    public class SlugifyParameterTransformer : IOutboundParameterTransformer
    {
        public string TransformOutbound(object value)
        {
            if (value == null) { return null; }
            var str = value.ToString();
            if (string.IsNullOrEmpty(str)) { return null; }
            return Regex.Replace(str?.ToString(), "([a-z])([A-Z])", "$1-$2").ToLowerInvariant();
        }
    }
}