Selaa lähdekoodia

修改省重派查询bug

tangjiang 1 kuukausi sitten
vanhempi
commit
292c0bb3e9

+ 4 - 0
src/Hotline.Api/Controllers/TestController.cs

@@ -256,6 +256,10 @@ ICallApplication callApplication,
     [AllowAnonymous]
     public async Task<ThirdPhoneOutDto> GetPhoneNumberTest()
     {
+        var order = await _orderRepository.Queryable().Includes(d => d.Workflow).FirstAsync(d => d.ReceiveProvinceNo == "");
+
+        var order1 = await _orderRepository.Queryable().Includes(d => d.Workflow).FirstAsync(d => d.ReceiveProvinceNo =="20202020202020");
+        var order2 = await _orderRepository.Queryable().Includes(d => d.Workflow).FirstAsync(d => d.ReceiveProvinceNo == "ZMHD995100002024111101317");
 
         var inDto = new ThirdTokenDto
         {

+ 9 - 9
src/Hotline.Application/Orders/OrderApplication.cs

@@ -224,7 +224,7 @@ public class OrderApplication : IOrderApplication, IScopeDependency
         _sessionContextManager = sessionContextManager;
         _orderVisitApplication = orderVisitApplication;
         _roleRepository = roleRepository;
-	}
+    }
 
     /// <summary>
     /// 更新工单办理期满时间(延期调用,其他不调用)
@@ -3485,27 +3485,27 @@ public class OrderApplication : IOrderApplication, IScopeDependency
         var orderSecondaries = await _orderSecondaryHandlingRepository.Queryable()
             .Where(x => x.OrderId == order.Id && x.State == ESecondaryHandlingState.Apply).ToListAsync(cancellationToken);
 
-        if (screen.Any())
+        if (screen != null && screen.Any())
         {
             await _orderScreenRepository.RemoveRangeAsync(screen, false, cancellationToken);
         }
 
-        if (sendBackAudit.Any())
+        if (sendBackAudit != null && sendBackAudit.Any())
         {
             await _orderSendBackAuditRepository.RemoveRangeAsync(sendBackAudit, false, cancellationToken);
         }
 
-        if (orderDelay.Any())
+        if (orderDelay != null && orderDelay.Any())
         {
             await _orderDelayRepository.RemoveRangeAsync(orderDelay, false, cancellationToken);
         }
 
-        if (orderSecondaries.Any())
+        if (orderSecondaries != null && orderSecondaries.Any())
         {
             await _orderSecondaryHandlingRepository.RemoveRangeAsync(orderSecondaries, false, cancellationToken);
         }
 
-        if (order.Workflow.IsInCountersign)
+        if (order.Workflow != null && order.Workflow.IsInCountersign)
         {
             var workflowStep = await _workflowStepRepository.Queryable().Where(x => x.Id == order.Workflow.TopCountersignStepId)
                 .FirstAsync(cancellationToken);
@@ -4339,8 +4339,8 @@ public class OrderApplication : IOrderApplication, IScopeDependency
 
         var orderExtension = await _orderDomainService.GetOrderExtensionsAsync(dto.ReceiveProvinceNo, cancellationToken);
 
-        var order = await _orderRepository.GetAsync(d => d.ReceiveProvinceNo == dto.ReceiveProvinceNo, cancellationToken);
-
+        //  var order = await _orderRepository.GetAsync(d => d.ReceiveProvinceNo == dto.ReceiveProvinceNo, cancellationToken);
+        var order = await _orderRepository.Queryable().Includes(d => d.Workflow).FirstAsync(d => d.ReceiveProvinceNo == dto.ReceiveProvinceNo);
         //处理省下行数据,热点名称为空
         if (!string.IsNullOrEmpty(dto.HotspotId) && string.IsNullOrEmpty(dto.HotspotName))
         {
@@ -5394,7 +5394,7 @@ public class OrderApplication : IOrderApplication, IScopeDependency
             }
             else if (newStep.FlowAssignType == EFlowAssignType.Role && !string.IsNullOrEmpty(newStep.RoleId))
             {
-                var role = await _roleRepository.Queryable().Includes(x=> x.Accounts).FirstAsync(x => x.Name == newStep.RoleId, cancellationToken);
+                var role = await _roleRepository.Queryable().Includes(x => x.Accounts).FirstAsync(x => x.Name == newStep.RoleId, cancellationToken);
                 foreach (var user in role.Accounts)
                 {
                     await _circularRecordDomainService.OrderSendBackCircularMessage(user.Id, user.Name, order, cancellationToken);

+ 2 - 1
src/Hotline.Application/Subscribers/DatasharingSubscriber.cs

@@ -248,7 +248,8 @@ namespace Hotline.Application.Subscribers
         [CapSubscribe(Hotline.Share.Mq.EventNames.SharingOrderRevoke)]
         public async Task RecCancelOrderAsync(CancelOrderDto dto, CancellationToken cancellationToken)
         {
-            var order = await _orderRepository.GetAsync(p => p.ReceiveProvinceNo == dto.ProvinceNo, cancellationToken);
+            //  var order = await _orderRepository.GetAsync(p => p.ReceiveProvinceNo == dto.ProvinceNo, cancellationToken);
+            var order = await _orderRepository.Queryable().Includes(d => d.Workflow).FirstAsync(p => p.ReceiveProvinceNo == dto.ProvinceNo);
             if (order is null)
                 throw new UserFriendlyException("未查询到工单");