AiDOPWarehouse/server/Plugins/Admin.NET.Plugin.AiDOP/Startup.cs

using System.Diagnostics;
using Admin.NET.Plugin.AiDOP.ChatBI;
using Admin.NET.Plugin.AiDOP.Entity;
using Admin.NET.Plugin.AiDOP.Entity.S0.Manufacturing;
using Admin.NET.Plugin.AiDOP.Entity.S0.Quality;
using Admin.NET.Plugin.AiDOP.Entity.S0.Sales;
using Admin.NET.Plugin.AiDOP.Entity.S0.Supply;
using Admin.NET.Plugin.AiDOP.Entity.S8;
using Admin.NET.Plugin.AiDOP.Entity.S8.OrderFlow;
using Admin.NET.Plugin.AiDOP.Order;
using Admin.NET.Plugin.AiDOP.DataPlatform.Executors;
using Admin.NET.Plugin.AiDOP.DataPlatform.HotWatch;
using Admin.NET.Plugin.AiDOP.Entity.DataPlatform;
using Admin.NET.Plugin.AiDOP.Infrastructure;
using Admin.NET.Plugin.AiDOP.MaterialWarehouse;
using Admin.NET.Plugin.AiDOP.WorkOrder;
using Microsoft.AspNetCore.Builder;
using Microsoft.AspNetCore.Hosting;
using Microsoft.AspNetCore.Mvc;
using Microsoft.Extensions.DependencyInjection;
using Microsoft.Extensions.Hosting;
using SqlSugar;

namespace Admin.NET.Plugin.AiDOP;

/// <summary>
/// AiDOP 插件启动配置（按需扩展 DI）
/// </summary>
[AppStartup(900)]
public class Startup : AppStartup
{
    public void ConfigureServices(IServiceCollection services)
    {
        services.AddHttpClient();
        services.AddHttpClient("AidopChatBI.DeepSeek");
        services.AddScoped<DeepSeekChatClient>();
        services.AddScoped<ChatBIService>();
        services.AddConfigurableOptions<S8ActiveFlowWatchOptions>();
        services.AddConfigurableOptions<S8MasterDataOptions>();
        services.AddConfigurableOptions<AidopPickBillOptions>();
        services.AddConfigurableOptions<AidopStockOptions>();
        services.AddConfigurableOptions<AidopInventoryOptions>();
        services.AddTransient<IInventoryBalanceReader, InventoryBalanceReader>();
        services.AddTransient<IInventoryTransactionReader, StdInventoryTransactionReader>();
        // WP9：IPickBillCreator 唯一实现为 Facade（避免 Local/Mes 多实现竞注）
        services.AddTransient<IPickBillCreator, PickBillCreatorFacade>();
        services.AddScoped<AdoS0ExceptionFilter>();
        services.AddScoped<AdoS0ResultFilter>();
        services.AddScoped<AdoS0ReferenceChecker>();
        services.Configure<MvcOptions>(options =>
        {
            options.Filters.AddService<AdoS0ExceptionFilter>();
            options.Filters.AddService<AdoS0ResultFilter>();
        });
        // MDP 出站事件驱动：入队 Pulse → 立即推送；Period Job 仅兜底
        services.AddHostedService<MdpOutboxPushWorker>();
        services.AddHostedService<MdpHotWatchWorker>();
        services.AddHostedService<Admin.NET.Plugin.AiDOP.DataPlatform.S1Refresh.S1DashboardRebuildWorker>();
        services.AddHostedService<Admin.NET.Plugin.AiDOP.DataPlatform.MdpRebuild.ModuleRebuildWorker>();
        services.AddSingleton<Admin.NET.Plugin.AiDOP.DataPlatform.MdpRebuild.IModuleRebuildCapability, Admin.NET.Plugin.AiDOP.DataPlatform.MdpRebuild.ModuleRebuildCapability>();
        services.AddTransient<Admin.NET.Plugin.AiDOP.DataPlatform.MdpRebuild.IModuleRebuildJobStore, Admin.NET.Plugin.AiDOP.DataPlatform.MdpRebuild.ModuleRebuildJobStore>();
        services.AddTransient<Admin.NET.Plugin.AiDOP.DataPlatform.MdpRebuild.IModuleRebuildLock, Admin.NET.Plugin.AiDOP.DataPlatform.MdpRebuild.ModuleRebuildLock>();
        services.AddTransient<Admin.NET.Plugin.AiDOP.DataPlatform.MdpRebuild.IModuleRebuildHandler, Admin.NET.Plugin.AiDOP.DataPlatform.MdpRebuild.S1ModuleRebuildHandler>();
        services.AddTransient<Admin.NET.Plugin.AiDOP.DataPlatform.MdpRebuild.IModuleRebuildHandler, Admin.NET.Plugin.AiDOP.DataPlatform.MdpRebuild.S2ModuleRebuildHandler>();
        services.AddTransient<Admin.NET.Plugin.AiDOP.DataPlatform.MdpRebuild.IModuleRebuildHandler, Admin.NET.Plugin.AiDOP.DataPlatform.MdpRebuild.S3ModuleRebuildHandler>();
        services.AddTransient<Admin.NET.Plugin.AiDOP.DataPlatform.MdpRebuild.IModuleRebuildHandler, Admin.NET.Plugin.AiDOP.DataPlatform.MdpRebuild.S4ModuleRebuildHandler>();
        services.AddTransient<Admin.NET.Plugin.AiDOP.DataPlatform.MdpRebuild.IModuleRebuildHandler, Admin.NET.Plugin.AiDOP.DataPlatform.MdpRebuild.S5ModuleRebuildHandler>();
        services.AddTransient<Admin.NET.Plugin.AiDOP.DataPlatform.MdpRebuild.IModuleRebuildHandler, Admin.NET.Plugin.AiDOP.DataPlatform.MdpRebuild.S6ModuleRebuildHandler>();
        services.AddTransient<Admin.NET.Plugin.AiDOP.DataPlatform.MdpRebuild.IModuleRebuildHandler, Admin.NET.Plugin.AiDOP.DataPlatform.MdpRebuild.S7ModuleRebuildHandler>();

        // S8-DATASET-FOUNDATION-HARDENING-2：S8 取数底座的接口映射显式注册
        // （与上方 IModuleRebuildLock 同一先例：本项目不依赖 ITransient 自动按接口注册）。
        services.AddTransient<Admin.NET.Plugin.AiDOP.Service.S8.Rules.DataAccess.IS8DatasetCatalog, Admin.NET.Plugin.AiDOP.Service.S8.Rules.DataAccess.S8DatasetCatalog>();
        // S8-STANDARD-DATASET-HARD-CUTOVER-1：IS8LegacySqlDataProvider 及其实现已物理删除。

        // S8-RULE01-PURCHASE-DELIVERY-A：接入第一个真实业务数据集 PURCHASE_DELIVERY。
        // Catalog 有定义 + Registry 有实现，Enable Gate 才判 READY：
        //   缺定义 → 规则连保存都过不了（dataset_not_defined）；
        //   缺实现 → 可存草稿但不可启用（dataset_provider_not_registered）。
        // 两个接口都必须显式注册（同上，不依赖 ITransient 自动按接口注册）。
        services.AddTransient<Admin.NET.Plugin.AiDOP.Service.S8.Rules.DataAccess.IS8DatasetDefinitionSource, Admin.NET.Plugin.AiDOP.Service.S8.Rules.DataAccess.Providers.S8BusinessDatasetDefinitions>();
        services.AddTransient<Admin.NET.Plugin.AiDOP.Service.S8.Rules.DataAccess.IS8MonitoringDataProvider, Admin.NET.Plugin.AiDOP.Service.S8.Rules.DataAccess.Providers.S8PurchaseDeliveryDataProvider>();
    }

    /// <summary>
    /// 开发环境下为 Demo 表执行 CodeFirst（表已存在则跳过变更，行为取决于 SqlSugar 配置）。
    /// </summary>
    public void Configure(IApplicationBuilder app, IWebHostEnvironment env)
    {
        try
        {
            AidopMenuLinkSync.EnsureLinked(app.ApplicationServices);
        }
        catch (Exception ex)
        {
            Trace.TraceWarning("Ai-DOP AidopMenuLinkSync: " + ex);
        }

        try
        {
            using var scopeS4 = app.ApplicationServices.CreateScope();
            var dbS4 = scopeS4.ServiceProvider.GetRequiredService<ISqlSugarClient>();
            dbS4.CodeFirst.InitTables(
                typeof(AdoSmartOpsLayoutItem),
                typeof(AdoSmartOpsHomeModule),
                typeof(AdoSmartOpsKpiMaster),
                typeof(AdoSmartOpsDashboardPageConfig),
                typeof(AdoSmartOpsDashboardWidget),
                typeof(AdoSmartOpsImprovementPlan),
                typeof(AdoMdpHotWatch),
                typeof(Admin.NET.Plugin.AiDOP.Entity.SmartOps.AdoS1DashboardRebuildJob),
                typeof(Admin.NET.Plugin.AiDOP.Entity.SmartOps.AdoModuleDashboardRebuildJob),
                typeof(Admin.NET.Plugin.AiDOP.Entity.SmartOps.AdoMdpRebuildLock),
                typeof(AdoTenantMenuSuppression));

            AidopTenantMigration.MigrateOldTenantId(dbS4);
            AidopKpiMasterSeed.EnsureSeed(dbS4);
            AidopKpiMasterSeed.EnsureSeed(dbS4, 1300000000888);
            var kpiTenantIds = dbS4.Queryable<AdoSmartOpsKpiMaster>()
                .Select(x => x.TenantId)
                .Distinct()
                .ToList();
            foreach (var tenantId in kpiTenantIds.Where(x => x > 0))
                AidopKpiMasterSeed.EnsureSeed(dbS4, tenantId!.Value);
            AidopImprovementApprovalSeed.EnsureSeed(dbS4);
            Admin.NET.Plugin.AiDOP.Infrastructure.IqcInspBillFlowSeed.EnsureSeed(dbS4);
            Admin.NET.Plugin.AiDOP.Infrastructure.IpqcInspectionFlowSeed.EnsureSeed(dbS4);
            Admin.NET.Plugin.AiDOP.Infrastructure.S6ProcessInspectionFlowSeed.EnsureSeed(dbS4);
            Admin.NET.Plugin.AiDOP.Infrastructure.FqcInspBillFlowSeed.EnsureSeed(dbS4);
        }
        catch (Exception ex)
        {
            Trace.TraceWarning("Ai-DOP CodeFirst/S4 seed: " + ex);
        }

        if (!env.IsDevelopment())
            return;

        // 客户/物料/优先级等；远端若已是遗留表（已有主键），CodeFirst 会报 Multiple primary key，不可让启动失败。
        try
        {
            using var scope = app.ApplicationServices.CreateScope();
            var db = scope.ServiceProvider.GetRequiredService<ISqlSugarClient>();
            db.CodeFirst.InitTables(
                typeof(AdoS0CustMaster),
                typeof(AdoS0ItemMaster),
                typeof(AdoS0ItemSubstituteDetail),
                typeof(AdoS0PriorityCode),
                typeof(AdoS0ProductStructureOp),
                typeof(AdoS0StdOpMaster),
                typeof(AdoS0LineMaster),
                typeof(AdoS0MfgRoutingOpDetail),
                typeof(AdoS0MfgPersonSkillAssignment),
                typeof(AdoS0MfgWorkOrderControl),
                typeof(AdoS0MfgPersonSkill),
                typeof(AdoS0MfgLinePost),
                typeof(AdoS0MfgWorkCenter),
                typeof(AdoS0MfgLineMaterial),
                typeof(AdoS0ProcessFlowCard),
                typeof(AdoS0OrderScheduleCycle),
                typeof(AdoS0MfgElementParam),
                typeof(AdoS0MfgMaterialProcessElement),
                typeof(AdoS0MfgPreprocessElement),
                typeof(AdoS0MfgPreprocessElementParam),
                typeof(AdoS0ImageType),
                typeof(AdoS0QualitySegmentImage),
                typeof(AdoS0QmsQualityBaseType),
                typeof(AdoS0QmsFqcInspectionSpec),
                typeof(AdoS0QmsFqcInspectionSpecEntry),
                typeof(AdoS0QmsOqcInspectionSpec),
                typeof(AdoS0QmsOqcInspectionSpecEntry),
                typeof(AdoS0CategoryLeadTime),
                typeof(AdoS0MaterialPlanCycle),
                typeof(AdoS0SrmPurchase),
                typeof(AdoS8Exception),
                typeof(AdoS8ExceptionTimeline),
                typeof(AdoS8DecisionRecord),
                typeof(AdoS8Evidence),
                // S8-STANDARD-DATASET-HARD-CUTOVER-1：AdoS8AlertRule 已物理删除
                // （运行时权威一直是 AdoS8WatchRule；该表零 Runtime Consumer）。
                typeof(AdoS8SceneConfig),
                typeof(AdoS8NotificationLayer),
                typeof(AdoS8WatchRule),
                typeof(AdoS8RolePermissionConfig),
                typeof(AdoS8NotificationLog),
                typeof(AdoS8DashboardCellConfig),
                typeof(AdoS8ExceptionType),
                typeof(AdoS8DetectionLog),
                typeof(AdoS8RuleDetectionState),
                typeof(AdoS8Dimension),
                typeof(AdoS8DimensionNode),
                typeof(AdoS8ConfigDraft),
                typeof(AdoS8MonitorObject),
                typeof(AdoS8MonitorMetric),
                typeof(AdoS8OrderFlowOrder),
                typeof(AdoS8OrderFlowStage),
                typeof(AdoS8OrderFlowSnapshot),
                typeof(AdoS8OrderFlowSubstep),
                typeof(AdoS8OrderFlowSubstepUnit),
                typeof(AdoS8OrderFlowProcurementPivot),
                typeof(ContractReview),
                typeof(ContractReviewFlow),
                typeof(ProductDesign),
                typeof(ProductDesignBom),
                typeof(ProductDesignRouting)
            );
            AidopDimensionSeed.EnsureSeed(db);
            AidopMonitorDictionarySeed.EnsureSeed(db);
        }
        catch (Exception ex)
        {
            Trace.TraceWarning("Ai-DOP Development CodeFirst (S0/S8/Order demo tables): " + ex);
        }
    }
}