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

fix：【【轨迹订单】批量新增轨迹明细，创建人异常为空】https://www.tapd.cn/60863849/bugtrace/bugs/view?bug_id=1160863849001031517

Browse Source
This commit is contained in:
李鹏军 2024-03-27 09:19:45 +08:00
parent 7b20e7a939
commit a663894bcc
2 changed files with 11 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
src/SJZY.Track.Application.Contract/Events/TrackDeleteEvent.cs
View File

@ -22,6 +22,11 @@ public class TrackDeleteEvent
/// </summary> /// </summary>
public int UpSubSystemId { get; set; } public int UpSubSystemId { get; set; }
/// <summary>
/// 操作人
/// </summary>
public string? OperationMan { get; set; }
/// <summary> /// <summary>
/// 已经处理过的订单 /// 已经处理过的订单
/// </summary> /// </summary>

8
src/SJZY.Track.Application/Services/ProvideServices/TrackService.cs
View File

@ -80,7 +80,7 @@ public partial class TrackService : ApplicationService, ITrackService
var orders = await _orderRepository.GetListAsync(x => var orders = await _orderRepository.GetListAsync(x =>
x.OrderType == input.OrderType && input.OrderNos.Contains(x.OrderNo), x => new x.OrderType == input.OrderType && input.OrderNos.Contains(x.OrderNo), x => new
{ {
x.Id, x.OrderNo, x.SubSystemId, x.LatestPushTrackContentId, x.CustomId x.Id, x.OrderNo, x.SubSystemId, x.LatestPushTrackContentId, x.CustomId, x.IsCompleted
}); });
foreach (var order in orders) foreach (var order in orders)
@ -98,7 +98,9 @@ public partial class TrackService : ApplicationService, ITrackService
OrderId = order.Id, OrderId = order.Id,
SubSystemId = order.SubSystemId, SubSystemId = order.SubSystemId,
LatestPushTrackContentId = order.LatestPushTrackContentId, LatestPushTrackContentId = order.LatestPushTrackContentId,
CustomId = order.CustomId CustomId = order.CustomId,
IsCompleted = order.IsCompleted,
OperationMan = CurrentUserRequest.CurrentUser.Name
}; };
await _capPublisher.PublishAsync(GlobalConst.TrackUpsertSubscribe, @event); await _capPublisher.PublishAsync(GlobalConst.TrackUpsertSubscribe, @event);
} }
@ -138,6 +140,7 @@ public partial class TrackService : ApplicationService, ITrackService
OrderId = order.Id, OrderId = order.Id,
TrackCodes = codes.Select(x => x.TrackCode).ToList(), TrackCodes = codes.Select(x => x.TrackCode).ToList(),
SubSystemId = order.SubSystemId, SubSystemId = order.SubSystemId,
OperationMan = CurrentUserRequest.CurrentUser.Name
}; };
await _capPublisher.PublishAsync(GlobalConst.TrackDeleteSubscribe, @event); await _capPublisher.PublishAsync(GlobalConst.TrackDeleteSubscribe, @event);
@ -177,6 +180,7 @@ public partial class TrackService : ApplicationService, ITrackService
OrderId = group.Key, OrderId = group.Key,
TrackCodes = codes.Select(x => x.TrackCode).ToList(), TrackCodes = codes.Select(x => x.TrackCode).ToList(),
SubSystemId = orders.First(x => x.Id == group.Key).SubSystemId, SubSystemId = orders.First(x => x.Id == group.Key).SubSystemId,
OperationMan = CurrentUserRequest.CurrentUser.Name
}; };
await _capPublisher.PublishAsync(GlobalConst.TrackDeleteSubscribe, @event); await _capPublisher.PublishAsync(GlobalConst.TrackDeleteSubscribe, @event);
} }