option:优化选项设置为可选项

This commit is contained in:
hardstylewyl 2025-05-13 17:12:09 +08:00
parent a8bbce208f
commit 1dfe434aee
5 changed files with 43 additions and 1 deletions

View File

@ -2,10 +2,16 @@ using SJZY.Expand.ABP.Core.Configuration;
using SJZY.Expand.ABP.Core.Configuration.AutoRegistOptions;
using SJZY.Expand.ABP.Core.Logger;
using SJZY.Track.Api;
using SJZY.Track.Application;
try
{
var builder = WebApplication.CreateBuilder(args);
if (args.Length > 0)
{
_BUGOptions.EnablePref = "on".Equals(args[0]);
Console.WriteLine($"是否启动优化模式:{_BUGOptions.EnablePref}");
}
builder
.AddConfigurationContainer()
.AddOptionsFromConfiguration()

View File

@ -371,6 +371,15 @@ public class TrackDeleteEventHandler : ITransientDependency, ICapSubscribe
private void WarningCalc_DeletedTrack(List<TrackDetailsIndex> delTracks)
{
if (_BUGOptions.EnablePref)
{
var scope = _serviceProvider.CreateScope();
var _warningSignalPublisher = scope.ServiceProvider.GetRequiredService<WarningSignalPublisher>();
_warningSignalPublisher.PublishWarningSignal(WarningSignalType.轨迹删除, delTracks);
scope.Dispose();
return;
}
//_warningSignalPublisher.PublishWarningSignal(WarningSignalType.轨迹删除, delTracks);
var signals = WarningSignal.FromTrack(delTracks, WarningSignalType.轨迹删除);

View File

@ -26,7 +26,9 @@ public class TrackUpsertEventHandler : ITransientDependency, ICapSubscribe
private readonly ITrackDetailsEsRepository _trackDetailsEsRepository;
private readonly IBroadcastingService _broadcastingService;
private readonly ILogger<TrackUpsertEventHandler> _logger;
private readonly IOrderOperationRecordEsRepository _orderOperationRecordEsRepository;
//private readonly WarningSignalPublisher _warningSignalPublisher;
private readonly IServiceProvider _serviceProvider;
@ -516,6 +518,15 @@ public class TrackUpsertEventHandler : ITransientDependency, ICapSubscribe
private void WarningCalc_AddedTrack(List<TrackDetailsIndex> tracks)
{
if (_BUGOptions.EnablePref)
{
var scope = _serviceProvider.CreateScope();
var _warningSignalPublisher = scope.ServiceProvider.GetRequiredService<WarningSignalPublisher>();
_warningSignalPublisher.PublishWarningSignal(WarningSignalType.轨迹新增, tracks);
scope.Dispose();
return;
}
//_warningSignalPublisher.PublishWarningSignal(WarningSignalType.轨迹新增, tracks);
var signals = WarningSignal.FromTrack(tracks, WarningSignalType.轨迹新增);
_ = Task.Run(async () =>
@ -544,6 +555,15 @@ public class TrackUpsertEventHandler : ITransientDependency, ICapSubscribe
private void WarningCalc_UpdatedTrack(List<TrackDetailsIndex> tracks)
{
if (_BUGOptions.EnablePref)
{
var scope = _serviceProvider.CreateScope();
var _warningSignalPublisher = scope.ServiceProvider.GetRequiredService<WarningSignalPublisher>();
_warningSignalPublisher.PublishWarningSignal(WarningSignalType.轨迹更新, tracks);
scope.Dispose();
return;
}
//_warningSignalPublisher.PublishWarningSignal(WarningSignalType.轨迹更新, tracks);
var signals = WarningSignal.FromTrack(tracks, WarningSignalType.轨迹更新);

View File

@ -200,7 +200,8 @@ public class SjzyTrackApplicationModule : AbpModule
$",abortConnect=false";
// 注册预警计算服务
//context.Services.AddWarningCalcServices(configuration);
if (_BUGOptions.EnablePref)
context.Services.AddWarningCalcServices(configuration);
// 注册预警任务后台服务
context.Services.AddHostedService<WarningTaskComponentBackgroundService>();

View File

@ -0,0 +1,6 @@
namespace SJZY.Track.Application;
public static class _BUGOptions
{
public static bool EnablePref = false;
}