ideship/track
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

推拉定时任务

Browse Source
This commit is contained in:
李鹏军 2024-03-21 14:50:04 +08:00
parent 4b189b378d
commit 7f0f11d0a3
2 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/SJZY.Track.Application/Services/ProvideServices/TrackPullService.cs
View File

@ -102,7 +102,7 @@ public class TrackPullService : ApplicationService
GlobalConst.TrackRefreshSubscribe, JsonConvert.SerializeObject(group.Key)); GlobalConst.TrackRefreshSubscribe, JsonConvert.SerializeObject(group.Key));
} }
await RedisHelper.Client.SetExAsync(redisKey, config.PullInterval * 60, 1); await RedisHelper.Client.SetExAsync(redisKey, config.PullInterval * 60, orders.Count);
} }

2
src/SJZY.Track.Application/Services/ProvideServices/TrackPushService.cs
View File

@ -1,4 +1,5 @@
using DotNetCore.CAP; using DotNetCore.CAP;
using Microsoft.AspNetCore.Authorization;
using SJZY.Track.Application.Contract.Dtos.ProvideServices; using SJZY.Track.Application.Contract.Dtos.ProvideServices;
using SJZY.Track.Application.Contract.Events; using SJZY.Track.Application.Contract.Events;
using SJZY.Track.Application.Contract.Services; using SJZY.Track.Application.Contract.Services;
@ -107,6 +108,7 @@ public class TrackPushService : ApplicationService
/// 定时任务推送预警（》12小时没有推送的） /// 定时任务推送预警（》12小时没有推送的）
/// </summary> /// </summary>
/// <returns></returns> /// <returns></returns>
[AllowAnonymous]
[HttpPost("Track/PushWarnForTask")] [HttpPost("Track/PushWarnForTask")]
public async Task<string> PushWarnForTaskAsync() public async Task<string> PushWarnForTaskAsync()
{ {