using WIDESEAWCS_S7Simulator.Core.Interfaces;
|
using WIDESEAWCS_S7Simulator.Core.Manager;
|
using WIDESEAWCS_S7Simulator.Core.Persistence;
|
using WIDESEAWCS_S7Simulator.Core.Memory;
|
using WIDESEAWCS_S7Simulator.Core.Entities;
|
using System.Text.Json.Serialization;
|
using WIDESEAWCS_S7Simulator.Application.Protocol;
|
using WIDESEAWCS_S7Simulator.Application;
|
using Microsoft.Extensions.Options;
|
using WIDESEAWCS_S7Simulator.Server.Services;
|
|
var builder = WebApplication.CreateBuilder(args);
|
|
// Add services to the container.
|
|
// 添加 CORS 支持（允许前后端分离）
|
builder.Services.AddCors(options =>
|
{
|
options.AddPolicy("AllowAll", policy =>
|
{
|
policy.WithOrigins("http://localhost:3000", "http://localhost:5173", "http://localhost:5174", "http://localhost:3001")
|
.AllowAnyMethod()
|
.AllowAnyHeader()
|
.AllowCredentials();
|
});
|
});
|
|
builder.Services.AddControllers(options =>
|
{
|
// 禁用隐式 [Required] 验证
|
options.SuppressImplicitRequiredAttributeForNonNullableReferenceTypes = true;
|
})
|
.AddJsonOptions(options =>
|
{
|
options.JsonSerializerOptions.PropertyNamingPolicy = System.Text.Json.JsonNamingPolicy.CamelCase;
|
options.JsonSerializerOptions.Converters.Add(new JsonStringEnumConverter());
|
});
|
// Learn more about configuring Swagger/OpenAPI at https://aka.ms/aspnetcore/swashbuckle
|
builder.Services.AddEndpointsApiExplorer();
|
builder.Services.AddSwaggerGen();
|
|
// Register core services
|
builder.Services.AddSingleton<ISimulatorInstanceManager, SimulatorInstanceManager>();
|
|
// WCS 数据库配置
|
builder.Services.Configure<WcsDbOptions>(builder.Configuration.GetSection(WcsDbOptions.SectionName));
|
builder.Services.AddSingleton<DatabaseDeviceService>();
|
builder.Services.AddSingleton<InstanceSyncService>();
|
|
// Get content root path for data directory
|
var contentRoot = builder.Environment.ContentRootPath;
|
var dataPath = Path.Combine(contentRoot, "Data");
|
|
builder.Services.AddSingleton<IPersistenceService>(sp => new FilePersistenceService(dataPath));
|
builder.Services.AddSingleton<IProtocolTemplateService>(sp => new FileProtocolTemplateService(dataPath));
|
builder.Services.AddSingleton<IRobotClientManager, RobotClientManager>();
|
builder.Services.Configure<ProtocolMonitoringOptions>(builder.Configuration.GetSection("ProtocolMonitoring"));
|
builder.Services.AddSingleton<MirrorAckProtocolHandler>();
|
builder.Services.AddSingleton<IDeviceProtocolHandler, WcsLineProtocolHandler>();
|
builder.Services.AddSingleton<IDeviceProtocolHandler, PlcLinkStackerProtocolHandler>();
|
builder.Services.AddSingleton<IDeviceProtocolHandler, StackerInteractionProtocolHandler>();
|
builder.Services.AddHostedService<ProtocolMonitoringHostedService>();
|
builder.Services.AddSingleton<IMemoryStore>(sp =>
|
{
|
var config = new MemoryRegionConfig();
|
return new MemoryStore(config);
|
});
|
|
var app = builder.Build();
|
|
// Configure the HTTP request pipeline.
|
if (app.Environment.IsDevelopment())
|
{
|
app.UseSwagger();
|
app.UseSwaggerUI();
|
}
|
|
app.UseHttpsRedirection();
|
|
app.UseCors("AllowAll"); // 启用 CORS
|
|
app.UseAuthorization();
|
|
app.MapControllers();
|
|
// 启动时加载已保存的实例（不自动启动）
|
var instanceManager = app.Services.GetRequiredService<ISimulatorInstanceManager>();
|
var syncService = app.Services.GetRequiredService<InstanceSyncService>();
|
_ = Task.Run(async () =>
|
{
|
try
|
{
|
// 先加载已保存的实例
|
await instanceManager.LoadSavedInstancesAsync(autoStart: false);
|
Console.WriteLine($"Loaded {instanceManager.GetAllInstances().Count()} saved instances.");
|
|
// 如果启用了 WCS 数据库同步，则执行同步
|
var wcsDbOptions = app.Services.GetRequiredService<IOptions<WcsDbOptions>>().Value;
|
if (wcsDbOptions.Enabled)
|
{
|
await syncService.SyncInstancesAsync();
|
Console.WriteLine($"WCS DB sync completed. Last sync: {syncService.LastSyncTime}");
|
}
|
}
|
catch (Exception ex)
|
{
|
Console.WriteLine($"Error during startup: {ex.Message}");
|
}
|
});
|
|
app.Run();
|
