append
This commit is contained in:
parent
f5b87695d9
commit
7e1932bf20
@ -19,7 +19,7 @@ public class TrackChangeAfterUpdateOrderEventHandler : ITransientDependency, ICa
|
|||||||
|
|
||||||
[UnitOfWork]
|
[UnitOfWork]
|
||||||
[CapSubscribe(GlobalConst.TrackChangeAfterUpdateOrderSubscribe)]
|
[CapSubscribe(GlobalConst.TrackChangeAfterUpdateOrderSubscribe)]
|
||||||
public async Task ConsumerAsync(TrackChangeAfterUpdateOrderEvent @event)
|
public virtual async Task ConsumerAsync(TrackChangeAfterUpdateOrderEvent @event)
|
||||||
{
|
{
|
||||||
var orders = await GetOrdersAsync(@event.OrderIds);
|
var orders = await GetOrdersAsync(@event.OrderIds);
|
||||||
|
|
||||||
|
|||||||
@ -44,7 +44,7 @@ public class TrackDeleteEventHandler : ITransientDependency, ICapSubscribe
|
|||||||
|
|
||||||
[UnitOfWork]
|
[UnitOfWork]
|
||||||
[CapSubscribe(GlobalConst.TrackDeleteSubscribe, Group = GlobalConst.TrackDeleteSubscribe)]
|
[CapSubscribe(GlobalConst.TrackDeleteSubscribe, Group = GlobalConst.TrackDeleteSubscribe)]
|
||||||
public async Task ConsumerAsync(TrackDeleteEvent @event)
|
public virtual async Task ConsumerAsync(TrackDeleteEvent @event)
|
||||||
{
|
{
|
||||||
if (!CanDelete(@event)) return;
|
if (!CanDelete(@event)) return;
|
||||||
|
|
||||||
|
|||||||
@ -53,7 +53,7 @@ public class TrackPushEventHandler : ITransientDependency, ICapSubscribe
|
|||||||
[UnitOfWork]
|
[UnitOfWork]
|
||||||
[CapSubscribe(GlobalConst.TrackPushSubscribe, Group = GlobalConst.TrackPushSubscribe)]
|
[CapSubscribe(GlobalConst.TrackPushSubscribe, Group = GlobalConst.TrackPushSubscribe)]
|
||||||
[CapSubscribe(GlobalConst.TrackManualPushSubscribe, Group = GlobalConst.TrackPushSubscribe)]
|
[CapSubscribe(GlobalConst.TrackManualPushSubscribe, Group = GlobalConst.TrackPushSubscribe)]
|
||||||
public async Task ConsumerAsync(TrackPushEvent @event)
|
public virtual async Task ConsumerAsync(TrackPushEvent @event)
|
||||||
{
|
{
|
||||||
// 应用+客户id找推送映射配置
|
// 应用+客户id找推送映射配置
|
||||||
var pushConfigs = await _trackPushCacheService.GetPushContentConfigsAsync(@event.AppKey, @event.Customer);
|
var pushConfigs = await _trackPushCacheService.GetPushContentConfigsAsync(@event.AppKey, @event.Customer);
|
||||||
|
|||||||
@ -47,7 +47,7 @@ public class TrackUpsertEventHandler : ITransientDependency, ICapSubscribe
|
|||||||
[UnitOfWork]
|
[UnitOfWork]
|
||||||
[CapSubscribe(GlobalConst.TrackUpsertSubscribe, Group = GlobalConst.TrackUpsertSubscribe)]
|
[CapSubscribe(GlobalConst.TrackUpsertSubscribe, Group = GlobalConst.TrackUpsertSubscribe)]
|
||||||
[CapSubscribe(GlobalConst.TrackUpsertForRefreshSubscribe, Group = GlobalConst.TrackUpsertForRefreshSubscribe)]
|
[CapSubscribe(GlobalConst.TrackUpsertForRefreshSubscribe, Group = GlobalConst.TrackUpsertForRefreshSubscribe)]
|
||||||
public async Task ConsumerAsync(TrackUpsertEvent @event)
|
public virtual async Task ConsumerAsync(TrackUpsertEvent @event)
|
||||||
{
|
{
|
||||||
if (!CanDelete(@event)) return;
|
if (!CanDelete(@event)) return;
|
||||||
|
|
||||||
|
|||||||
Loading…
Reference in New Issue
Block a user