using Quartz;
|
using WIDESEAWCS_Core.Caches;
|
using WIDESEAWCS_IBasicInfoRepository;
|
using WIDESEAWCS_ISystemServices;
|
using WIDESEAWCS_ITaskInfoRepository;
|
using WIDESEAWCS_ITaskInfoService;
|
using WIDESEAWCS_Model.Models;
|
using WIDESEAWCS_QuartzJob;
|
using WIDESEAWCS_QuartzJob.Service;
|
using WIDESEAWCS_SignalR;
|
|
namespace WIDESEAWCS_Tasks
|
{
|
[DisallowConcurrentExecution]
|
public class CommonAfterOtherDevicesJob : JobBase, IJob
|
{
|
private readonly ITaskService _taskService;
|
private readonly ITaskExecuteDetailService _taskExecuteDetailService;
|
private readonly ITaskRepository _taskRepository;
|
private readonly IRouterService _routerService;
|
private readonly ICacheService _cacheService;
|
private readonly INoticeService _noticeService;
|
private readonly IDt_StationManagerRepository _stationManagerRepository;
|
private readonly ITask_HtyRepository _task_htyRepository;
|
private readonly ISys_ConfigService _sys_ConfigService;
|
private static List<string>? userTokenIds;
|
private static List<int>? userIds;
|
|
public CommonAfterOtherDevicesJob(ITaskService taskService, ITaskExecuteDetailService taskExecuteDetailService, ITaskRepository taskRepository, IRouterService routerService, ICacheService cacheService, INoticeService noticeService, IDt_StationManagerRepository stationManagerRepository, ITask_HtyRepository task_htyRepository, ISys_ConfigService sys_ConfigService)
|
{
|
_taskService = taskService;
|
_taskExecuteDetailService = taskExecuteDetailService;
|
_taskRepository = taskRepository;
|
_routerService = routerService;
|
_cacheService = cacheService;
|
_noticeService = noticeService;
|
_stationManagerRepository = stationManagerRepository;
|
_task_htyRepository = task_htyRepository;
|
_sys_ConfigService = sys_ConfigService;
|
}
|
|
public Task Execute(IJobExecutionContext context)
|
{
|
try
|
{
|
AfterOtherDevice afterOtherDevice = (AfterOtherDevice)context.JobDetail.JobDataMap.Get("JobParams");
|
List<Dt_StationManager> stationManagers = _stationManagerRepository.QueryData(x=>x.stationDeviceCode.Contains(""));
|
|
}
|
catch (Exception ex)
|
{
|
WriteError("CommonOtherDevicesJob", "test", ex);
|
}
|
return Task.CompletedTask;
|
}
|
}
|
}
|
