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

change：推送异常处理逻辑

Browse Source
This commit is contained in:
李鹏军 2024-04-03 09:13:47 +08:00
parent fefbe18497
commit 4a759333ca
1 changed files with 15 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
src/SJZY.Track.Application/EventHandlers/TrackPushEventHandler.cs
View File

@ -39,9 +39,7 @@ public class TrackPushEventHandler : ITransientDependency, ICapSubscribe
{ {
x.SubSystemId, x.LatestPushTrackCode, x.QuestionType, x.CustomId x.SubSystemId, x.LatestPushTrackCode, x.QuestionType, x.CustomId
}); });
if (order == null || order.QuestionType == (int)TrackProblemType.Error) return; // 是否通知？ if (order == null) return;
TrackPushContentConfigDto? config;
var log = new TrackPushRecordIndex var log = new TrackPushRecordIndex
{ {
@ -58,6 +56,8 @@ public class TrackPushEventHandler : ITransientDependency, ICapSubscribe
CreateTime = DateTime.Now CreateTime = DateTime.Now
}; };
TrackPushContentConfigDto? config = null;
switch (@event.OptionType) switch (@event.OptionType)
{ {
case OptionType.无: case OptionType.无:
@ -65,9 +65,12 @@ public class TrackPushEventHandler : ITransientDependency, ICapSubscribe
case OptionType.新增: case OptionType.新增:
if (@event.OperationMan == null) if (@event.OperationMan == null)
{ {
// 推送新增，需要根据上一次的推送 推断 本次推送 是否可行 if (order.QuestionType != (int)TrackProblemType.Error)
config = await _trackPushCacheService.IsValidPushAsync(order.SubSystemId, order.CustomId, {
order.LatestPushTrackCode, @event.TrackCode); // 推送新增，需要根据上一次的推送 推断 本次推送 是否可行
config = await _trackPushCacheService.IsValidPushAsync(order.SubSystemId, order.CustomId,
order.LatestPushTrackCode, @event.TrackCode);
}
} }
else else
{ {
@ -132,12 +135,17 @@ public class TrackPushEventHandler : ITransientDependency, ICapSubscribe
// tips：只有新增会影响推送进度？ // tips：只有新增会影响推送进度？
order.LatestPushTrackCode = dto.TrackCode; order.LatestPushTrackCode = dto.TrackCode;
order.LatestPushTime = DateTime.Now; order.LatestPushTime = DateTime.Now;
await _orderRepository.UpdateColumnAsync(order, x => new
{
x.LatestPushTrackCode, x.LatestPushTime, x.QuestionType, x.LatestPushError
});
return;
} }
} }
await _orderRepository.UpdateColumnAsync(order, x => new await _orderRepository.UpdateColumnAsync(order, x => new
{ {
x.LatestPushTrackCode, x.QuestionType, x.LatestPushError, x.LatestPushTime x.QuestionType, x.LatestPushError
}); });
} }