47 lines
1.3 KiB
C#
47 lines
1.3 KiB
C#
using JNPF.Common.Configuration;
|
|
using JNPF.DependencyInjection;
|
|
using JNPF.EventBus;
|
|
using JNPF.TaskScheduler.Entitys;
|
|
using SqlSugar;
|
|
using Tnb.Common.Core.EventBus.Constants;
|
|
using Tnb.Common.Core.EventBus.Sources;
|
|
using Tnb.WarehouseMgr.Interfaces;
|
|
|
|
namespace Tnb.WarehouseMgr.EventSubscribers;
|
|
|
|
/// <summary>
|
|
/// 任务事件订阅.
|
|
/// </summary>
|
|
public class TaskStatusChangeSubscriber : IEventSubscriber, ISingleton
|
|
{
|
|
/// <summary>
|
|
/// 初始化客户端.
|
|
/// </summary>
|
|
//private static SqlSugarScope? _sqlSugarClient;
|
|
private readonly IWareHouseService _wareHouseService;
|
|
/// <summary>
|
|
/// 构造函数.
|
|
/// </summary>
|
|
public TaskStatusChangeSubscriber(IWareHouseService wareHouseService)
|
|
{
|
|
_wareHouseService = wareHouseService;
|
|
}
|
|
|
|
/// <summary>
|
|
/// 创建任务日记.
|
|
/// </summary>
|
|
/// <param name="context"></param>
|
|
/// <returns></returns>
|
|
[EventSubscribe(EventSubscribeEventConsts.TASKSTATUSCHANGE_EVENTID)]
|
|
public async Task Excute(EventHandlerExecutingContext context)
|
|
{
|
|
var tscSource = (TaskStatusChangeSource)context.Source;
|
|
switch (tscSource.Payload)
|
|
{
|
|
case nameof(_wareHouseService.GenTaskExecute):
|
|
await _wareHouseService.GenTaskExecute();
|
|
break;
|
|
}
|
|
|
|
}
|
|
} |