Parcourir la source

feature: 自贡补偿推送通话记录

xf il y a 6 mois
Parent
commit
b39c042e59
1 fichiers modifiés avec 8 ajouts et 6 suppressions
  1. 8 6
      src/Hotline.Application/Subscribers/DatasharingSubscriber.cs

+ 8 - 6
src/Hotline.Application/Subscribers/DatasharingSubscriber.cs

@@ -1145,15 +1145,17 @@ namespace Hotline.Application.Subscribers
                 {
                     var query = await _orderRepository.Queryable()
                         .LeftJoin<CallNative>((o, c) => o.CallId == c.Id)
-                        .Where((o, c) => !SqlFunc.IsNullOrEmpty(o.CallId) && c != null && callIds.Contains(o.CallId))
+                        .Where((o, c) => !SqlFunc.IsNullOrEmpty(o.CallId) && callIds.Contains(o.CallId))
                         .Select((o, c) => new { Order = o, Call = c })
                         .ToListAsync(cancellationToken);
                     if (!query.Any()) return;
-                    var orderCalls = query.Select((o, c) => new PublishCallRecrodDto
-                    {
-                        Order = _mapper.Map<OrderDto>(o),
-                        TrCallRecordDto = _mapper.Map<TrCallDto>(c)
-                    }).ToList();
+                    var orderCalls = query
+                        .Where(d=>!SqlFunc.IsNullOrEmpty(d.Call.Id))
+                        .Select(d => new PublishCallRecrodDto
+                        {
+                            Order = _mapper.Map<OrderDto>(d.Order),
+                            TrCallRecordDto = _mapper.Map<TrCallDto>(d.Call)
+                        }).ToList();
 
                     foreach (var orderCall in orderCalls)
                     {