using Consul;
using FlexJobApi.Core;
using FlexJobApi.Core.Jobs;
using Furion;
using Furion.EventBus;
using Furion.Schedule;
using MediatR;
using Microsoft.AspNetCore.Builder;
using Microsoft.AspNetCore.Hosting;
using Microsoft.Extensions.DependencyInjection;
using Microsoft.Extensions.Hosting;
using Newtonsoft.Json.Converters;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace FlexJobApi.Web.Entry
{
    [AppStartup(2)]
    public class Startup : AppStartup
    {
        public void ConfigureServices(IServiceCollection services)
        {
            services.AddHealthChecks();

            services.AddConfigurableOptions<WxmpOptions>();
            services.AddConfigurableOptions<AlipayOptions>();
            services.AddConfigurableOptions<AliyunOptions>();
            services.AddConfigurableOptions<BaiduOptions>();

            services.AddComponent<LogServiceComponent>();

            services.AddComponent<ConsulServiceComponent>();

            services.AddComponent<EventBusServiceComponent>();

            services.AddComponent<DistributedCacheServiceComponent>();

            services.AddHttpRemote(); 
            services.AddSingleton<AlipayUtils>();
            services.AddSingleton<AliyunSmsUtils>(); 
            services.AddSingleton<WxmpUtils>();
            services.AddScoped<SmsUtils>();

            services.AddMediatR(cfg => cfg.RegisterServicesFromAssemblies(App.Assemblies.ToArray()));

            services.AddHostedService<XmlDocBuildHostedService>();

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

            services.AddCorsAccessor();

            services.AddHostedService<BuildDynamicControllersHostedService>();

            services.AddSchedule(options =>
            {
                options.BuildSqlType = SqlTypes.SqlServer;
                options.JobDetail.LogEnabled = true;
                //options.AddPersistence<DbJobPersistence>();
                options.AddJob<CalcTaskSatusByDateJob>(Triggers.Hourly());
                options.AddJob<CalcUserAgeByIdCardJob>(Triggers.Daily());
                options.AddJob<RefreshEnterpriseWalletStatusJob>(Triggers.PeriodMinutes(5));
                options.AddJob<RefreshEnterpriseWalletTransactionStatusJob>(Triggers.PeriodMinutes(5));
                options.AddJob<CompleteTaskSettlementT1Job>(Triggers.PeriodMinutes(5));
            });

            services.AddSpecificationDocuments(options =>
            {
                options.OperationFilter<CustomOperationIdFilter>();
                options.SchemaFilter<EnumSchemaFilter>();
            });
            services.AddSwaggerGenNewtonsoftSupport();

            services.AddMvcFilter<ResourceActionFilter>();

            services.AddControllers()
                    .AddNewtonsoftJson(options =>
                    {
                        options.SerializerSettings.Converters.Add(new EmptyStringToNullConverter());
                        //options.SerializerSettings.Converters.Add(new StringEnumConverter());
                    })
                    .AddFriendlyException()
                    .AddDataValidation()
                    .AddInjectWithUnifyResult<FriendlyResultProvider>();

        }

        public void Configure(IApplicationBuilder app, IWebHostEnvironment env, IHostApplicationLifetime lifetime)
        {
            // 解析事件总线发布服务
            var eventPublisher = app.ApplicationServices.GetRequiredService<IEventPublisher>();

            // 订阅
            eventPublisher.OnExecuted += (sender, args) =>
            {
                Console.WriteLine($"事件 {args.Source.EventId} 执行状态：{args.Status}，异常：{args.Exception}，执行结果：{args.Result}");
            };

            if (env.IsDevelopment())
            {
                app.UseDeveloperExceptionPage();
            }

            app.UseUnifyResultStatusCodes();

            //app.UseHttpsRedirection();

            app.UseRouting();

            app.UseCorsAccessor();

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

            app.UseInject(string.Empty);

            app.UseStaticFiles();
            app.UseScheduleUI();

            app.UseSpecificationDocuments();

            app.UseEndpoints(endpoints =>
            {
                endpoints.MapControllers();
                endpoints.MapHealthChecks("/healthz");
            });

            app.UseComponent<ConsulApplicationComponent>(env);

            //lifetime.ApplicationStarted.Register(async () =>
            //{
            //    await ResourceUtils.BuildDynamicControllersAsync();
            //});
        }
    }
}