fix:修复因使用Task.Run丢失的预警处理异常上报
This commit is contained in:
parent
be25b8e10d
commit
c163a3bcc7
@ -129,6 +129,10 @@ public class TrackChangeAfterUpdateOrderEventHandler : ITransientDependency, ICa
|
|||||||
var handler = scope.ServiceProvider.GetRequiredService<IOrderWarningHandler>();
|
var handler = scope.ServiceProvider.GetRequiredService<IOrderWarningHandler>();
|
||||||
await handler.HandleOrderDeletedOrCompletedAsync(order);
|
await handler.HandleOrderDeletedOrCompletedAsync(order);
|
||||||
}
|
}
|
||||||
|
catch (Exception ex)
|
||||||
|
{
|
||||||
|
LogHelper.Error(ex);
|
||||||
|
}
|
||||||
finally
|
finally
|
||||||
{
|
{
|
||||||
scope.Dispose();
|
scope.Dispose();
|
||||||
|
|||||||
@ -383,6 +383,10 @@ public class TrackDeleteEventHandler : ITransientDependency, ICapSubscribe
|
|||||||
await handler2.TrackDeletedHandleAsync(signals);
|
await handler2.TrackDeletedHandleAsync(signals);
|
||||||
await handler3.TrackUpdatedOrDeletedHandleAsync(signals);
|
await handler3.TrackUpdatedOrDeletedHandleAsync(signals);
|
||||||
}
|
}
|
||||||
|
catch (Exception ex)
|
||||||
|
{
|
||||||
|
LogHelper.Error(ex);
|
||||||
|
}
|
||||||
finally
|
finally
|
||||||
{
|
{
|
||||||
await scope.DisposeAsync();
|
await scope.DisposeAsync();
|
||||||
|
|||||||
@ -525,6 +525,10 @@ public class TrackUpsertEventHandler : ITransientDependency, ICapSubscribe
|
|||||||
await handler.TrackAddedHandleAsync(signals);
|
await handler.TrackAddedHandleAsync(signals);
|
||||||
await handler2.TrackAddedOrUpdatedHandleAsync(signals);
|
await handler2.TrackAddedOrUpdatedHandleAsync(signals);
|
||||||
}
|
}
|
||||||
|
catch (Exception ex)
|
||||||
|
{
|
||||||
|
LogHelper.Error(ex);
|
||||||
|
}
|
||||||
finally
|
finally
|
||||||
{
|
{
|
||||||
await scope.DisposeAsync();
|
await scope.DisposeAsync();
|
||||||
@ -549,6 +553,10 @@ public class TrackUpsertEventHandler : ITransientDependency, ICapSubscribe
|
|||||||
await handler.TrackAddedOrUpdatedHandleAsync(signals);
|
await handler.TrackAddedOrUpdatedHandleAsync(signals);
|
||||||
await handler2.TrackUpdatedOrDeletedHandleAsync(signals);
|
await handler2.TrackUpdatedOrDeletedHandleAsync(signals);
|
||||||
}
|
}
|
||||||
|
catch (Exception ex)
|
||||||
|
{
|
||||||
|
LogHelper.Error(ex);
|
||||||
|
}
|
||||||
finally
|
finally
|
||||||
{
|
{
|
||||||
await scope.DisposeAsync();
|
await scope.DisposeAsync();
|
||||||
|
|||||||
@ -1,4 +1,5 @@
|
|||||||
using DotNetCore.CAP;
|
using DotNetCore.CAP;
|
||||||
|
using SJZY.Expand.ABP.Core.Logger;
|
||||||
using SJZY.Expand.ABP.Core.PublicMethords;
|
using SJZY.Expand.ABP.Core.PublicMethords;
|
||||||
using SJZY.Track.Application.Contract.Dtos.ProvideServices;
|
using SJZY.Track.Application.Contract.Dtos.ProvideServices;
|
||||||
using SJZY.Track.Application.Contract.Services.ProvideServices;
|
using SJZY.Track.Application.Contract.Services.ProvideServices;
|
||||||
@ -206,6 +207,10 @@ public partial class OrderService : ApplicationService, IOrderService
|
|||||||
var handler = scope.ServiceProvider.GetRequiredService<IOrderWarningHandler>();
|
var handler = scope.ServiceProvider.GetRequiredService<IOrderWarningHandler>();
|
||||||
await handler.HandleOrderDeletedOrCompletedAsync(order);
|
await handler.HandleOrderDeletedOrCompletedAsync(order);
|
||||||
}
|
}
|
||||||
|
catch (Exception ex)
|
||||||
|
{
|
||||||
|
LogHelper.Error(ex);
|
||||||
|
}
|
||||||
finally
|
finally
|
||||||
{
|
{
|
||||||
await scope.DisposeAsync();
|
await scope.DisposeAsync();
|
||||||
|
|||||||
@ -1,4 +1,5 @@
|
|||||||
using System.Linq.Expressions;
|
using System.Linq.Expressions;
|
||||||
|
using SJZY.Expand.ABP.Core.Logger;
|
||||||
using SJZY.Expand.AliyunOSS;
|
using SJZY.Expand.AliyunOSS;
|
||||||
using SJZY.Track.Application.Contract.Dtos.ProvideServices;
|
using SJZY.Track.Application.Contract.Dtos.ProvideServices;
|
||||||
using SJZY.Track.Application.Contract.Dtos.TrackOrder;
|
using SJZY.Track.Application.Contract.Dtos.TrackOrder;
|
||||||
@ -365,6 +366,10 @@ public class TrackOrderService : ApplicationService
|
|||||||
var handler = scope.ServiceProvider.GetRequiredService<IOrderWarningHandler>();
|
var handler = scope.ServiceProvider.GetRequiredService<IOrderWarningHandler>();
|
||||||
await handler.HandleOrderDeletedOrCompletedAsync(order);
|
await handler.HandleOrderDeletedOrCompletedAsync(order);
|
||||||
}
|
}
|
||||||
|
catch (Exception ex)
|
||||||
|
{
|
||||||
|
LogHelper.Error(ex);
|
||||||
|
}
|
||||||
finally
|
finally
|
||||||
{
|
{
|
||||||
await scope.DisposeAsync();
|
await scope.DisposeAsync();
|
||||||
|
|||||||
@ -1,6 +1,7 @@
|
|||||||
using System.Linq.Expressions;
|
using System.Linq.Expressions;
|
||||||
using Microsoft.Extensions.Localization;
|
using Microsoft.Extensions.Localization;
|
||||||
using SJZY.Expand.ABP.Core.Localization;
|
using SJZY.Expand.ABP.Core.Localization;
|
||||||
|
using SJZY.Expand.ABP.Core.Logger;
|
||||||
using SJZY.Expand.ABP.Core.PublicMethords;
|
using SJZY.Expand.ABP.Core.PublicMethords;
|
||||||
using SJZY.Track.Application.Contract.Dtos.TrackPush;
|
using SJZY.Track.Application.Contract.Dtos.TrackPush;
|
||||||
using SJZY.Track.Application.Contract.Services;
|
using SJZY.Track.Application.Contract.Services;
|
||||||
@ -8,7 +9,6 @@ using SJZY.Track.Application.Localization;
|
|||||||
using SJZY.Track.Application.Services.Warning.Handlers;
|
using SJZY.Track.Application.Services.Warning.Handlers;
|
||||||
using SJZY.Track.Domain.Aggregates.OrderAggregate;
|
using SJZY.Track.Domain.Aggregates.OrderAggregate;
|
||||||
using SJZY.Track.Domain.Aggregates.TrackPushAggregate;
|
using SJZY.Track.Domain.Aggregates.TrackPushAggregate;
|
||||||
using SJZY.Track.Domain.Aggregates.WarningAggregate.Signals;
|
|
||||||
using SJZY.Track.Domain.Dtos.Common;
|
using SJZY.Track.Domain.Dtos.Common;
|
||||||
using SJZY.Track.Domain.Dtos.TrackPush;
|
using SJZY.Track.Domain.Dtos.TrackPush;
|
||||||
using Volo.Abp.DependencyInjection;
|
using Volo.Abp.DependencyInjection;
|
||||||
@ -331,6 +331,10 @@ public class TrackPushService : ApplicationService, ISingletonDependency
|
|||||||
var handler = scope.ServiceProvider.GetRequiredService<IReturnWarningHandler>();
|
var handler = scope.ServiceProvider.GetRequiredService<IReturnWarningHandler>();
|
||||||
await handler.PushConfigChangedHandleAsync(pushConfig, contentConfigEntity);
|
await handler.PushConfigChangedHandleAsync(pushConfig, contentConfigEntity);
|
||||||
}
|
}
|
||||||
|
catch (Exception ex)
|
||||||
|
{
|
||||||
|
LogHelper.Error(ex);
|
||||||
|
}
|
||||||
finally
|
finally
|
||||||
{
|
{
|
||||||
scope.Dispose();
|
scope.Dispose();
|
||||||
|
|||||||
Loading…
Reference in New Issue
Block a user