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

feat: 解决接口Track/PushWarnForTask的锁长时间占领的问题

Browse Source
This commit is contained in:
钟喜旺 2024-07-31 16:34:29 +08:00
parent 6b43722fa6
commit 010408985e
3 changed files with 19 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -92,9 +92,21 @@ public class TrackPushService : ApplicationService
[HttpPost("Track/PushWarnForTask")] [HttpPost("Track/PushWarnForTask")]
public async Task<string> PushWarnForTaskAsync() public async Task<string> PushWarnForTaskAsync()
{ {
// todo：订单数据上来后一次性update是否会引发长时间X独占？ int total = 0, pageSize = 1000,waitTime = 1000;
var count = await _orderRepository.PushWarnOrdersAsync(); var dateTimes = Enumerable.Range(1, 12).Select(val => DateTime.Now.AddHours(-val)).ToList();
return $"本次预警扫描了：{count}个订单";
foreach (var dateTime in dateTimes)
{
var rows = 0;
do
{
rows = await _orderRepository.PushWarnOrdersAsync(pageSize,dateTime);
total+=rows;
await Task.Delay(waitTime);
}while (rows!= pageSize);
}
return $"本次预警扫描了：{total}个订单";
} }
/// <summary> /// <summary>

2
src/SJZY.Track.Domain/Aggregates/OrderAggregate/IOrderRepository.cs
View File

@ -29,7 +29,7 @@ public interface IOrderRepository : IBasicRepository<OrderEntity>
/// 更新推送预警单 /// 更新推送预警单
/// </summary> /// </summary>
/// <returns></returns> /// <returns></returns>
Task<int> PushWarnOrdersAsync(); Task<int> PushWarnOrdersAsync(int pageSize,DateTime createTime);
/// <summary> /// <summary>
/// 更新缺失标记，时区缺失和发生地缺失标记，1表示时区，2表示发生地，3表示两种 /// 更新缺失标记，时区缺失和发生地缺失标记，1表示时区，2表示发生地，3表示两种

6
src/SJZY.Track.Repository/Repositories/OrderRepository.cs
View File

@ -61,7 +61,7 @@ public class OrderRepository : BasicRepository<OrderEntity>, IOrderRepository, I
tran.Complete(); tran.Complete();
} }
public async Task<int> PushWarnOrdersAsync() public async Task<int> PushWarnOrdersAsync(int pageSize, DateTime createTime)
{ {
return await Context.Ado.ExecuteCommandAsync(@"UPDATE `t_track_push_config` `a` return await Context.Ado.ExecuteCommandAsync(@"UPDATE `t_track_push_config` `a`
LEFT JOIN `t_order` `b` ON `a`.`SubSystemId` = `b`.`SubSystemId` AND `a`.`CustomId` = `b`.`CustomId` LEFT JOIN `t_order` `b` ON `a`.`SubSystemId` = `b`.`SubSystemId` AND `a`.`CustomId` = `b`.`CustomId`
@ -69,8 +69,8 @@ SET `b`.`QuestionType` = CASE
WHEN `b`.`LatestPushTime` IS NULL THEN 2 WHEN `b`.`LatestPushTime` IS NULL THEN 2
WHEN `b`.`LatestPushTime` < DATE_SUB(NOW(), INTERVAL 12 HOUR) THEN 2 WHEN `b`.`LatestPushTime` < DATE_SUB(NOW(), INTERVAL 12 HOUR) THEN 2
ELSE 0 END ELSE 0 END
WHERE `b`.`IsCompleted` = 0 AND `b`.`QuestionType` != 1 AND `b`.`CreateTime` < DATE_SUB(NOW(), INTERVAL 12 HOUR) WHERE `b`.`IsCompleted` = 0 AND `b`.`QuestionType` != 1 AND `b`.`CreateTime` < @createTime
AND `a`.`IsDeleted` = 0 AND `b`.`IsDeleted` = 0;"); AND `a`.`IsDeleted` = 0 AND `b`.`IsDeleted` = 0 limit @pageSize", new { pageSize,createTime });
} }
#region 订单关联 #region 订单关联