Merge branch 'S07' into test

This commit is contained in:
hardstylewyl 2025-03-21 16:35:09 +08:00
commit 7794113a3a
2 changed files with 9 additions and 2 deletions

View File

@ -22,13 +22,15 @@ public class _TransportDetailsGenerateService : ApplicationService
} }
/// <summary> /// <summary>
/// 运输预警明细生成任务执行,立即执行不考虑计划时机 /// 运输预警明细生成任务立即执行,不考虑计划执行时间,执行完成任务会关闭
///
/// </summary> /// </summary>
[HttpGet("TransportWarningDetailsGenerate_ScanAndExec")] [HttpGet("TransportWarningDetailsGenerate_ScanAndExec")]
public async Task TransportWarningDetailsGenerate_ScanAndExec() public async Task TransportWarningDetailsGenerate_ScanAndExec()
{ {
var tasks = await _warningTaskRepository.GetTransportWarningDetailsGenerateTaskAsync(x => !x.IsClosed); var tasks = await _warningTaskRepository.GetTransportWarningDetailsGenerateTaskAsync(x => !x.IsClosed);
var taskIds = tasks.Select(x => x.Id).ToHashSet();
await _warningTaskRepository.CloseTransportWarningDetailsGenerateTaskAsync(x => !x.IsClosed && taskIds.Contains(x.Id));
await _transportWarningHandler.HandleWarningDetailsGenerateTask(tasks); await _transportWarningHandler.HandleWarningDetailsGenerateTask(tasks);
} }

View File

@ -30,6 +30,11 @@ public class _MockReturnWarningService : ApplicationService
/// <summary>
/// 模拟接口通回调
/// </summary>
/// <param name="input"></param>
/// <returns></returns>
[HttpPost("MockReturn")] [HttpPost("MockReturn")]
public async Task<string> MockReturn(MockReturnInput input) public async Task<string> MockReturn(MockReturnInput input)
{ {