Browse Source

启动心跳

master
mahao 1 year ago
parent
commit
d5a84c0d9c
  1. 1
      code/src/Modules/SettleAccount/src/SettleAccount.Application/Entities/BQ/JobHostdService.cs

1
code/src/Modules/SettleAccount/src/SettleAccount.Application/Entities/BQ/JobHostdService.cs

@ -98,6 +98,7 @@ public class JobHostdService : BackgroundService, IApplicationService
try try
{ {
timer.Elapsed += (s, e) => JobItemHeartBeat(job.Id); timer.Elapsed += (s, e) => JobItemHeartBeat(job.Id);
timer.Start();
scope.ServiceProvider.GetRequiredService<IHubContext<PageHub>>().Clients.All.ServerToClient("JobItem", "refresh", ""); scope.ServiceProvider.GetRequiredService<IHubContext<PageHub>>().Clients.All.ServerToClient("JobItem", "refresh", "");
await jobService.Invoke(scope.ServiceProvider).ConfigureAwait(false); await jobService.Invoke(scope.ServiceProvider).ConfigureAwait(false);
this.JobItemSuccess(job.Id, jobLogId.Value); this.JobItemSuccess(job.Id, jobLogId.Value);

Loading…
Cancel
Save