Merge branch 'test' into test_20250318tj

src/Hotline.Api/Controllers/AiController.cs

@@ -4,7 +4,6 @@ using DotNetCore.CAP;
 using Hotline.Ai.CallOut;
 using Hotline.Ai.Jths;
 using Hotline.Ai.Visit;
-using Hotline.Application.Orders;
 using Hotline.Application.Quality;
 using Hotline.Caching.Interfaces;
 using Hotline.Caching.Services;
@@ -28,6 +27,7 @@ using Org.BouncyCastle.Utilities;
 using SqlSugar;
 using System.Runtime.CompilerServices;
 using System.Threading;
+using Hotline.Application.OrderApp;
 using XF.Domain.Authentications;
 using XF.Domain.Constants;
 using XF.Domain.Exceptions;

src/Hotline.Api/Controllers/Bi/BiOrderController.cs

@@ -1,7 +1,6 @@
 using Amazon.Runtime.Internal.Transform;
 using Hotline.Application.ExportExcel;
 using Hotline.Application.FlowEngine;
-using Hotline.Application.Orders;
 using Hotline.Application.StatisticalReport;
 using Hotline.Application.Systems;
 using Hotline.Caching.Interfaces;
@@ -48,6 +47,7 @@ using Hotline.Share.Dtos.File;
 using Hotline.File;
 using Hotline.KnowledgeBase;
 using DocumentFormat.OpenXml.Vml.Spreadsheet;
+using Hotline.Application.OrderApp;
 using Hotline.Share.Tools;
 using MediatR;
 using static Hotline.AppDefaults;
@@ -3181,7 +3181,7 @@ namespace Hotline.Api.Controllers.Bi
 
 
         /// <summary>
-        /// 部门受理类型统计（宜宾原始功能）
+        /// 部门受理类型统计（宜宾功能）
         /// </summary>
         /// <param name="dto"></param>
         /// <returns></returns>
@@ -3301,6 +3301,192 @@ namespace Hotline.Api.Controllers.Bi
             return new { DataList = items, CountySumModel = countySumModel, CitySumModel = citySumModel, SumModel = sumModel };
         }
 
+        /// <summary>
+        /// 部门受理类型统计（宜宾功能）---导出
+        /// </summary>
+        /// <param name="dto"></param>
+        /// <returns></returns>
+        [HttpPost("department_acceptance_type_statistics_export_v1")]
+        public async Task<FileStreamResult> ExportDepartmentAcceptanceTypeStatisticsV1([FromBody] ExportExcelDto<DepartmentKeyWordRequest> dto)
+        {
+            var query = _orderReportApplication.DepartmentAcceptanceTypeStatisticsV1(dto.QueryDto);
+            List<DepartmentAcceptanceTypeStatisticsV1Dto> list;
+            if (dto.IsExportAll)
+            {
+                list = await query.ToListAsync(HttpContext.RequestAborted);
+            }
+            else
+            {
+                var (_, items) = await query.ToPagedListAsync(dto.QueryDto, HttpContext.RequestAborted);
+                list = items;
+            }
+
+            list.Add(new DepartmentAcceptanceTypeStatisticsV1Dto
+            {
+                OrgName = "区县合计",
+                OrgCode = "",
+                OrgTypeText = "",
+                ZxAllCount = list.Where(x => x.OrgType == EOrgType.County).Sum(p => p.ZxAllCount),
+                ZxAcceptanceTypeCode = "10",
+
+                JyAllCount = list.Where(x => x.OrgType == EOrgType.County).Sum(p => p.JyAllCount),
+                JyAcceptanceTypeCode = "15",
+
+                QzAllCount = list.Where(x => x.OrgType == EOrgType.County).Sum(p => p.QzAllCount),
+                QzAcceptanceTypeCode = "20",
+
+                ByAllCount = list.Where(x => x.OrgType == EOrgType.County).Sum(p => p.ByAllCount),
+                ByAcceptanceTypeCode = "25",
+
+                JbAllCount = list.Where(x => x.OrgType == EOrgType.County).Sum(p => p.JbAllCount),
+                JbAcceptanceTypeCode = "30",
+
+                TsAllCount = list.Where(x => x.OrgType == EOrgType.County).Sum(p => p.TsAllCount),
+                TsAcceptanceTypeCode = "35",
+
+                QtAllCount = list.Where(x => x.OrgType == EOrgType.County).Sum(p => p.QtAllCount),
+                QtAcceptanceTypeCode = "40",
+
+                YjAllCount = list.Where(x => x.OrgType == EOrgType.County).Sum(p => p.YjAllCount),
+                YjAcceptanceTypeCode = "1",
+
+                HmAllCount = list.Where(x => x.OrgType == EOrgType.County).Sum(p => p.HmAllCount),
+                HmAcceptanceTypeCode = "2",
+
+                DqAllCount = list.Where(x => x.OrgType == EOrgType.County).Sum(p => p.DqAllCount),
+                DqAcceptanceTypeCode = "3"
+            });
+
+            list.Add(new DepartmentAcceptanceTypeStatisticsV1Dto
+            {
+                OrgName = "市直合计",
+                OrgCode = "",
+                OrgTypeText = "",
+                ZxAllCount = list.Where(x => x.OrgType == EOrgType.City && x.OrgCode != "001").Sum(p => p.ZxAllCount),
+                ZxAcceptanceTypeCode = "10",
+
+                JyAllCount = list.Where(x => x.OrgType == EOrgType.City && x.OrgCode != "001").Sum(p => p.JyAllCount),
+                JyAcceptanceTypeCode = "15",
+
+                QzAllCount = list.Where(x => x.OrgType == EOrgType.City && x.OrgCode != "001").Sum(p => p.QzAllCount),
+                QzAcceptanceTypeCode = "20",
+
+                ByAllCount = list.Where(x => x.OrgType == EOrgType.City && x.OrgCode != "001").Sum(p => p.ByAllCount),
+                ByAcceptanceTypeCode = "25",
+
+                JbAllCount = list.Where(x => x.OrgType == EOrgType.City && x.OrgCode != "001").Sum(p => p.JbAllCount),
+                JbAcceptanceTypeCode = "30",
+
+                TsAllCount = list.Where(x => x.OrgType == EOrgType.City && x.OrgCode != "001").Sum(p => p.TsAllCount),
+                TsAcceptanceTypeCode = "35",
+
+                QtAllCount = list.Where(x => x.OrgType == EOrgType.City && x.OrgCode != "001").Sum(p => p.QtAllCount),
+                QtAcceptanceTypeCode = "40",
+
+                YjAllCount = list.Where(x => x.OrgType == EOrgType.City && x.OrgCode != "001").Sum(p => p.YjAllCount),
+                YjAcceptanceTypeCode = "1",
+
+                HmAllCount = list.Where(x => x.OrgType == EOrgType.City && x.OrgCode != "001").Sum(p => p.HmAllCount),
+                HmAcceptanceTypeCode = "2",
+
+                DqAllCount = list.Where(x => x.OrgType == EOrgType.City && x.OrgCode != "001").Sum(p => p.DqAllCount),
+                DqAcceptanceTypeCode = "3"
+            });
+
+            list.Add(new DepartmentAcceptanceTypeStatisticsV1Dto
+            {
+                OrgName = "总计",
+                OrgCode = "",
+                OrgTypeText = "",
+                ZxAllCount = list.Sum(p => p.ZxAllCount),
+                ZxAcceptanceTypeCode = "10",
+
+                JyAllCount = list.Sum(p => p.JyAllCount),
+                JyAcceptanceTypeCode = "15",
+
+                QzAllCount = list.Sum(p => p.QzAllCount),
+                QzAcceptanceTypeCode = "20",
+
+                ByAllCount = list.Sum(p => p.ByAllCount),
+                ByAcceptanceTypeCode = "25",
+
+                JbAllCount = list.Sum(p => p.JbAllCount),
+                JbAcceptanceTypeCode = "30",
+
+                TsAllCount = list.Sum(p => p.TsAllCount),
+                TsAcceptanceTypeCode = "35",
+
+                QtAllCount = list.Sum(p => p.QtAllCount),
+                QtAcceptanceTypeCode = "40",
+
+                YjAllCount = list.Sum(p => p.YjAllCount),
+                YjAcceptanceTypeCode = "1",
+
+                HmAllCount = list.Sum(p => p.HmAllCount),
+                HmAcceptanceTypeCode = "2",
+
+                DqAllCount = list.Sum(p => p.DqAllCount),
+                DqAcceptanceTypeCode = "3"
+            });
+
+            var orderDtos = _mapper.Map<ICollection<DepartmentAcceptanceTypeStatisticsV1Dto>>(list);
+            dynamic? dynamicClass = DynamicClassHelper.CreateDynamicClass<DepartmentAcceptanceTypeStatisticsV1Dto>(dto.ColumnInfos);
+            var dtos = orderDtos
+                .Select(stu => _mapper.Map(stu, typeof(DepartmentAcceptanceTypeStatisticsV1Dto), dynamicClass))
+                .Cast<object>()
+                .ToList();
+
+            var stream = ExcelHelper.CreateStream(dtos);
+
+            return ExcelStreamResult(stream, "部门受理类型统计数据");
+        }
+
+        /// <summary>
+        /// 部门受理类型统计（宜宾功能）--明细列表
+        /// </summary>
+        /// <param name="dto"></param>
+        /// <returns></returns>
+        [HttpGet("department_acceptance_type_order_list_v1")]
+        public async Task<PagedDto<OrderDto>> DepartmentAcceptanceTypeOrderListV1([FromQuery] DepartmentKeyWordRequest dto)
+        {
+            var (total, items) = await _orderReportApplication.DepartmentAcceptanceTypeOrderListV1(dto)
+                .ToPagedListAsync(dto, HttpContext.RequestAborted);
+            return new PagedDto<OrderDto>(total, _mapper.Map<IReadOnlyList<OrderDto>>(items));
+        }
+
+        /// <summary>
+        /// 部门受理类型统计（宜宾功能）--明细列表---导出
+        /// </summary>
+        /// <param name="dto"></param>
+        /// <returns></returns>
+        [HttpPost("department_acceptance_type_order_list_export_v1")]
+        public async Task<FileStreamResult> ExportDepartmentAcceptanceTypeOrderListV1([FromBody] ExportExcelDto<DepartmentKeyWordRequest> dto)
+        {
+            var query = _orderReportApplication.DepartmentAcceptanceTypeOrderListV1(dto.QueryDto);
+            List<Order> list;
+            if (dto.IsExportAll)
+            {
+                list = await query.ToListAsync(HttpContext.RequestAborted);
+            }
+            else
+            {
+                var (_, items) = await query.ToPagedListAsync(dto.QueryDto, HttpContext.RequestAborted);
+                list = items;
+            }
+
+            var orderDtos = _mapper.Map<ICollection<OrderDto>>(list);
+
+            dynamic? dynamicClass = DynamicClassHelper.CreateDynamicClass<OrderDto>(dto.ColumnInfos);
+
+            var dtos = orderDtos
+                .Select(stu => _mapper.Map(stu, typeof(OrderDto), dynamicClass))
+                .Cast<object>()
+                .ToList();
+
+            var stream = ExcelHelper.CreateStream(dtos);
+
+            return ExcelStreamResult(stream, "部门受理类型统计数据");
+        }
 
         /// <summary>
         /// 部门办件统计表

src/Hotline.Api/Controllers/Bigscreen/SeatController.cs

@@ -3,6 +3,7 @@ using Hotline.Caching.Interfaces;
 using Hotline.CallCenter.Tels;
 using Hotline.CallCenter.Tels.CallTelDomain;
 using Hotline.Settings;
+using Hotline.Share.Dtos.CallCenter;
 using Hotline.Share.Dtos.TrCallCenter;
 using Mapster;
 using Microsoft.AspNetCore.Authorization;
@@ -61,5 +62,30 @@ namespace Hotline.Api.Controllers.Bigscreen
             });
             return list;
         }
+
+        /// <summary>
+        /// 获取监听分机
+        /// </summary>
+        /// <returns></returns>
+        [AllowAnonymous]
+        [HttpGet("query-listentels-xingtang")]
+        public async Task<List<TelOutDto>> GetListenTelsXT()
+        {
+            var listenTels = _systemSettingCacheManager.GetSetting(SettingConstants.ListenTels)?.SettingValue;
+            var callOuttQueueId = _systemSettingCacheManager.GetSetting(SettingConstants.CallOutQueueId)?.SettingValue;
+            List<TelOutDto> list = [];
+            if (listenTels != null && callOuttQueueId != null)
+            {
+                foreach (var item in listenTels)
+                {
+                    list.Add(new TelOutDto()
+                    {
+                        Queue = callOuttQueueId[0],
+                        TelNo = item
+                    });
+                }
+            }
+            return list;
+        }
     }
 }

src/Hotline.Api/Controllers/CallController.cs

@@ -92,6 +92,7 @@ namespace Hotline.Api.Controllers
         /// 签入
         /// </summary>
         [HttpPost("signin")]
+        [LogFilter("分机签入")]
         public Task<TrOnDutyResponseDto> SignIn([FromBody] SignInDto dto)
             => _callApplication.SignInAsync(dto, HttpContext.RequestAborted);
 
@@ -99,6 +100,7 @@ namespace Hotline.Api.Controllers
         /// 签出
         /// </summary>
         [HttpPost("signout")]
+        [LogFilter("分机签出")]
         public Task SignOut()
             => _callApplication.SingOutAsync(HttpContext.RequestAborted);
 
@@ -106,6 +108,7 @@ namespace Hotline.Api.Controllers
         /// 签出
         /// </summary>
         [HttpPost("signout/{telNo}")]
+        [LogFilter("分机签出")]
         public Task SignOut(string telNo)
             => _callApplication.SingOutAsync(telNo, HttpContext.RequestAborted);
 

src/Hotline.Api/Controllers/FwThirdController.cs

@@ -1,7 +1,7 @@
 using DocumentFormat.OpenXml.Office.CoverPageProps;
 using Hotline.Application.Bulletin;
 using Hotline.Application.Identity;
-using Hotline.Application.Orders;
+using Hotline.Application.OrderApp;
 using Hotline.Article;
 using Hotline.Caching.Interfaces;
 using Hotline.Configurations;

src/Hotline.Api/Controllers/IPPbxController.cs

@@ -382,6 +382,7 @@ namespace Hotline.Api.Controllers
         /// </summary>
         /// <returns></returns>
         [HttpPost("rest")]
+        [LogFilter("分机小休")]
         public async Task Rest([FromBody] TrRestDto dto)
         {
             var work = _userCacheManager.GetWorkByUser(_sessionContext.RequiredUserId);
@@ -404,6 +405,7 @@ namespace Hotline.Api.Controllers
         /// </summary>
         /// <returns></returns>
         [HttpPost("unrest")]
+        [LogFilter("分机取消小休")]
         public async Task UnRest()
         {
             var work = _userCacheManager.GetWorkByUser(_sessionContext.RequiredUserId);

src/Hotline.Api/Controllers/IdentityController.cs

@@ -157,6 +157,7 @@ jxrWXHbT1FB6DqkdOnBbQqS1Azqz5HxLlSyEK3F60e3SgB5iZsDZ
             MenuLogoImageMini = menuLogoImageMini,
             IsLoginMessageCode = IsLoginMessageCode,
             AppScope = _appOptions.Value.AppScope,
+            CallCenterSocketUrl = _systemSettingCacheManager.GetSetting(SettingConstants.CallCenterSocketUrl).SettingValue?.FirstOrDefault(),
         };
     }
 

src/Hotline.Api/Controllers/OrderApi/OrderCarbonCopyController.cs

@@ -1,4 +1,4 @@
-using Hotline.Application.Orders;
+using Hotline.Application.OrderApp;
 using Hotline.Caching.Interfaces;
 using Hotline.Repository.SqlSugar.Extensions;
 using Hotline.Settings;

src/Hotline.Api/Controllers/OrderController.cs

@@ -5,7 +5,6 @@ using Hotline.Api.Filter;
 using Hotline.Application.CallCenter;
 using Hotline.Application.ExportExcel;
 using Hotline.Application.FlowEngine;
-using Hotline.Application.Orders;
 using Hotline.Application.Quality;
 using Hotline.Application.Snapshot;
 using Hotline.Application.Systems;
@@ -76,6 +75,7 @@ using SqlSugar;
 using System.Text;
 using System.Text.Json;
 using System.Threading;
+using Hotline.Application.OrderApp;
 using XF.Domain.Authentications;
 using XF.Domain.Cache;
 using XF.Domain.Exceptions;
@@ -6607,7 +6607,7 @@ public class OrderController : BaseController
                 //})
                 //    .Where(o => o.Id == order.Id).ExecuteCommandAsync(HttpContext.RequestAborted);
 
-                if (expiredTime?.ExpiredTime > order.ExpiredTime)
+                if ((expiredTime?.ExpiredTime > order.ExpiredTime ) || _appOptions.Value.IsLuZhou)
                 {
                     order.ExpiredTime = expiredTime.ExpiredTime;
                     order.NearlyExpiredTime = expiredTime.NearlyExpiredTime;

src/Hotline.Api/Controllers/OrderTerminateController.cs

@@ -22,9 +22,9 @@ using XF.Utility.EnumExtensions;
 using MapsterMapper;
 using Hotline.File;
 using Hotline.Application.FlowEngine;
+using Hotline.Application.OrderApp;
 using Hotline.FlowEngine.Workflows;
 using Hotline.Repository.SqlSugar.Extensions;
-using Hotline.Application.Orders;
 using Hotline.Share.Dtos.FlowEngine.Workflow;
 using Hotline.Share.Requests;
 using Hotline.Tools;

src/Hotline.Api/Controllers/Snapshot/SnapshotController.cs

@@ -1,7 +1,6 @@
 using AngleSharp.Dom;
 using Fw.Utility.UnifyResponse;
 using Hotline.Api.Filter;
-using Hotline.Application.Orders;
 using Hotline.Application.Snapshot;
 using Hotline.Caching.Interfaces;
 using Hotline.File;

src/Hotline.Api/Controllers/Snapshot/SnapshotOrderController.cs

@@ -1,6 +1,5 @@
 using Amazon.Runtime.Internal.Transform;
 using Hotline.Application.FlowEngine;
-using Hotline.Application.Orders;
 using Hotline.Application.Snapshot;
 using Hotline.Caching.Interfaces;
 using Hotline.Caching.Services;
@@ -24,6 +23,7 @@ using Microsoft.AspNetCore.Mvc;
 using Microsoft.Extensions.Options;
 using System.ComponentModel;
 using System.Text;
+using Hotline.Application.OrderApp;
 using XF.Domain.Authentications;
 using XF.Domain.Exceptions;
 using XF.Domain.Repository;

src/Hotline.Api/Controllers/TestController.cs

@@ -4,7 +4,6 @@ using Hotline.Application.CallCenter;
 using Hotline.Application.ExportExcel;
 using Hotline.Application.FlowEngine;
 using Hotline.Application.JudicialManagement;
-using Hotline.Application.Orders;
 using Hotline.Application.Quality;
 using Hotline.Application.StatisticalReport;
 using Hotline.Caching.Interfaces;
@@ -54,6 +53,7 @@ using NETCore.Encrypt;
 using Senparc.Weixin.MP.AdvancedAPIs.MerChant;
 using SqlSugar;
 using System.Threading;
+using Hotline.Application.OrderApp;
 using XC.RSAUtil;
 using XF.Domain.Authentications;
 using XF.Domain.Cache;

src/Hotline.Api/Controllers/WebPortalController.cs

@@ -1,6 +1,6 @@
 using DocumentFormat.OpenXml.Spreadsheet;
 using Hotline.Application.Bulletin;
-using Hotline.Application.Orders;
+using Hotline.Application.OrderApp;
 using Hotline.Article;
 using Hotline.Caching.Interfaces;
 using Hotline.Configurations;

src/Hotline.Api/StartupHelper.cs

@@ -4,7 +4,6 @@ using System.Reflection;
 using System.Text;
 using Hotline.Application;
 using Hotline.Application.Jobs;
-using Hotline.Application.Orders;
 using Hotline.CallCenter.Configs;
 using Hotline.Configurations;
 using Hotline.DI;

src/Hotline.Application/Handlers/FlowEngine/WorkflowEndHandler.cs

@@ -1,6 +1,6 @@
 using DotNetCore.CAP;
 using Hotline.Application.CallCenter;
-using Hotline.Application.Orders;
+using Hotline.Application.OrderApp;
 using Hotline.Caching.Interfaces;
 using Hotline.CallCenter.Tels;
 using Hotline.Configurations;

src/Hotline.Application/Orders/AiOrderVisitApplication.cs → src/Hotline.Application/OrderApp/AiOrderVisitApplication.cs

@@ -1,17 +1,10 @@
 using Hotline.Orders;
-using Hotline.Share.Dtos;
 using Hotline.Share.Dtos.Ai;
-using Microsoft.AspNetCore.Http;
 using SqlSugar;
-using System;
-using System.Collections.Generic;
-using System.Linq;
-using System.Text;
-using System.Threading.Tasks;
 using XF.Domain.Dependency;
 using XF.Domain.Repository;
 
-namespace Hotline.Application.Orders
+namespace Hotline.Application.OrderApp
 {
     public class AiOrderVisitApplication : IAiOrderVisitApplication, IScopeDependency
     {

src/Hotline.Application/Orders/Handlers/OrderHandler/AddOrderPushMessageNotifyHandler.cs → src/Hotline.Application/OrderApp/Handlers/OrderHandler/AddOrderPushMessageNotifyHandler.cs

@@ -6,7 +6,7 @@ using Hotline.Share.Enums.Push;
 using MediatR;
 using Microsoft.Extensions.Logging;
 
-namespace Hotline.Application.Orders.Handlers.OrderHandler
+namespace Hotline.Application.OrderApp.Handlers.OrderHandler
 {
     /// <summary>
     /// 新增工单发送短信

src/Hotline.Application/Orders/Handlers/OrderHandler/GetOrderDetailNotifyHandler.cs → src/Hotline.Application/OrderApp/Handlers/OrderHandler/GetOrderDetailNotifyHandler.cs

@@ -2,7 +2,7 @@
 using Hotline.Orders.Notifications;
 using MediatR;
 
-namespace Hotline.Application.Orders.Handlers.OrderHandler
+namespace Hotline.Application.OrderApp.Handlers.OrderHandler
 {
     public class GetOrderDetailNotifyHandler : INotificationHandler<GetOrderDetailNotify>
     {

src/Hotline.Application/Orders/Handlers/OrderHandler/OrderRelateCallHandler.cs → src/Hotline.Application/OrderApp/Handlers/OrderHandler/OrderRelateCallHandler.cs

@@ -4,7 +4,7 @@ using Hotline.Share.Dtos.Order;
 using Hotline.Share.Mq;
 using XF.Domain.Dependency;
 
-namespace Hotline.Application.Orders.Handlers.OrderHandler
+namespace Hotline.Application.OrderApp.Handlers.OrderHandler
 {
     public class OrderRelateCallHandler : ICapSubscribe, ITransientDependency
     {

src/Hotline.Application/Orders/Handlers/OrderHandler/OrderVisitSmsHandler.cs → src/Hotline.Application/OrderApp/Handlers/OrderHandler/OrderVisitSmsHandler.cs

@@ -9,7 +9,7 @@ using MediatR;
 using XF.Domain.Dependency;
 using XF.Domain.Repository;
 
-namespace Hotline.Application.Orders.Handlers.OrderHandler;
+namespace Hotline.Application.OrderApp.Handlers.OrderHandler;
 public class OrderVisitSmsHandler : INotificationHandler<ReceiveMessageNotify>
 {
     private readonly IOrderVisitDomainService _orderVisitDomainService;

src/Hotline.Application/Orders/Handlers/OrderHandler/TranspondCityNotifyHandler.cs → src/Hotline.Application/OrderApp/Handlers/OrderHandler/TranspondCityNotifyHandler.cs

@@ -9,7 +9,7 @@ using MediatR;
 using Microsoft.Extensions.Logging;
 using XF.Domain.Repository;
 
-namespace Hotline.Application.Orders.Handlers.OrderHandler
+namespace Hotline.Application.OrderApp.Handlers.OrderHandler
 {
     // [Injection(AppScopes = EAppScope.YiBin)]
     public class TranspondCityNotifyHandler : INotificationHandler<OrderStartWorkflowNotify>

src/Hotline.Application/Orders/Handlers/OrderHandler/UpdateOrderPushMessageNotifyHandler.cs → src/Hotline.Application/OrderApp/Handlers/OrderHandler/UpdateOrderPushMessageNotifyHandler.cs

@@ -6,7 +6,7 @@ using Hotline.Share.Enums.Push;
 using MediatR;
 using Microsoft.Extensions.Logging;
 
-namespace Hotline.Application.Orders.Handlers.OrderHandler
+namespace Hotline.Application.OrderApp.Handlers.OrderHandler
 {
     public class UpdateOrderPushMessageNotifyHandler : INotificationHandler<UpdateOrderNotify>
     {

src/Hotline.Application/Orders/Handlers/OrderScreenHandler/OrderScreenEndWorkflowHandler.cs → src/Hotline.Application/OrderApp/Handlers/OrderScreenHandler/OrderScreenEndWorkflowHandler.cs

@@ -16,7 +16,7 @@ using Microsoft.Extensions.Options;
 using XF.Domain.Authentications;
 using XF.Domain.Repository;
 
-namespace Hotline.Application.Orders.Handlers.OrderScreenHandler;
+namespace Hotline.Application.OrderApp.Handlers.OrderScreenHandler;
 public class OrderScreenEndWorkflowHandler : INotificationHandler<EndWorkflowNotify>
 {
     private readonly IOrderRepository _orderRepository;

src/Hotline.Application/Orders/Handlers/OrderScreenHandler/OrderScreenNextWorkflowHandler.cs → src/Hotline.Application/OrderApp/Handlers/OrderScreenHandler/OrderScreenNextWorkflowHandler.cs

@@ -9,13 +9,12 @@ using Hotline.Share.Enums.Order;
 using Hotline.Share.Mq;
 using MapsterMapper;
 using MediatR;
-using Microsoft.AspNetCore.Http;
 using Microsoft.Extensions.Options;
 using XF.Domain.Authentications;
 using XF.Domain.Extensions;
 using XF.Domain.Repository;
 
-namespace Hotline.Application.Orders.Handlers.OrderScreenHandler;
+namespace Hotline.Application.OrderApp.Handlers.OrderScreenHandler;
 public class OrderScreenNextWorkflowHandler : INotificationHandler<NextStepNotify>
 {
     private readonly ICapPublisher _capPublisher;

src/Hotline.Application/Orders/Handlers/OrderScreenHandler/OrderScreenStartWorkflowHandler.cs → src/Hotline.Application/OrderApp/Handlers/OrderScreenHandler/OrderScreenStartWorkflowHandler.cs

@@ -3,7 +3,7 @@ using Hotline.FlowEngine.WorkflowModules;
 using Hotline.Orders;
 using MediatR;
 
-namespace Hotline.Application.Orders.Handlers.OrderScreenHandler;
+namespace Hotline.Application.OrderApp.Handlers.OrderScreenHandler;
 
 public class OrderScreenStartWorkflowHandler : INotificationHandler<StartWorkflowNotify>
 {

src/Hotline.Application/Orders/Handlers/SnapshotHandler/GuiderSystemTimeoutHandler.cs → src/Hotline.Application/OrderApp/Handlers/SnapshotHandler/GuiderSystemTimeoutHandler.cs

@@ -4,7 +4,7 @@ using Hotline.Share.Tools;
 using Hotline.Snapshot.Notifications;
 using MediatR;
 
-namespace Hotline.Application.Orders.Handlers.SnapshotHandler
+namespace Hotline.Application.OrderApp.Handlers.SnapshotHandler
 {
     /// <summary>
     /// 需求：坐席派给网格员的安全隐患工单若未推送成功超过4小时或者网格员超过4小时没回复，则自动流转到标注节点待标注列表

src/Hotline.Application/Orders/IAiOrderVisitApplication.cs → src/Hotline.Application/OrderApp/IAiOrderVisitApplication.cs

@@ -1,13 +1,8 @@
 using Hotline.Orders;
 using Hotline.Share.Dtos.Ai;
 using SqlSugar;
-using System;
-using System.Collections.Generic;
-using System.Linq;
-using System.Text;
-using System.Threading.Tasks;
 
-namespace Hotline.Application.Orders
+namespace Hotline.Application.OrderApp
 {
     public interface IAiOrderVisitApplication
     {

src/Hotline.Application/Orders/IOrderAnalysisApplication.cs → src/Hotline.Application/OrderApp/IOrderAnalysisApplication.cs

@@ -1,13 +1,8 @@
-using Hotline.Share.Dtos.Order;
+using Hotline.Orders;
+using Hotline.Share.Dtos.Order;
 using SqlSugar;
-using System;
-using System.Collections.Generic;
-using System.Linq;
-using System.Text;
-using System.Threading.Tasks;
-using Hotline.Orders;
 
-namespace Hotline.Application.Orders
+namespace Hotline.Application.OrderApp
 {
 	public interface IOrderAnalysisApplication
 	{

src/Hotline.Application/Orders/IOrderApplication.cs → src/Hotline.Application/OrderApp/IOrderApplication.cs

@@ -2,24 +2,19 @@
 using Hotline.FlowEngine.Definitions;
 using Hotline.FlowEngine.Workflows;
 using Hotline.Orders;
-using Hotline.Repository.SqlSugar.Orders;
 using Hotline.Settings;
 using Hotline.Share.Dtos;
 using Hotline.Share.Dtos.DataSharing.PusherHotlineDto;
-using Hotline.Share.Dtos.FlowEngine;
 using Hotline.Share.Dtos.FlowEngine.Workflow;
 using Hotline.Share.Dtos.Order;
 using Hotline.Share.Dtos.Order.Publish;
-using Hotline.Share.Enums.FlowEngine;
-using Hotline.Share.Enums.Order;
 using Hotline.Share.Enums.Settings;
 using Hotline.Share.Requests;
 using Hotline.Users;
 using SqlSugar;
-using XF.Domain.Authentications;
 using XF.Domain.Exceptions;
 
-namespace Hotline.Application.Orders
+namespace Hotline.Application.OrderApp
 {
     public interface IOrderApplication
     {

src/Hotline.Application/Orders/IOrderCarbonCopyApplication.cs → src/Hotline.Application/OrderApp/IOrderCarbonCopyApplication.cs

@@ -1,13 +1,8 @@
-using System;
-using System.Collections.Generic;
-using System.Linq;
-using System.Text;
-using System.Threading.Tasks;
-using Hotline.Orders;
+using Hotline.Orders;
 using Hotline.Share.Dtos.Order.CarbonCopy;
 using SqlSugar;
 
-namespace Hotline.Application.Orders
+namespace Hotline.Application.OrderApp
 {
     public interface IOrderCarbonCopyApplication
     {

src/Hotline.Application/Orders/IOrderSecondaryHandlingApplication.cs → src/Hotline.Application/OrderApp/IOrderSecondaryHandlingApplication.cs

@@ -2,13 +2,8 @@
 using Hotline.Share.Dtos.Order;
 using Hotline.Share.Requests;
 using SqlSugar;
-using System;
-using System.Collections.Generic;
-using System.Linq;
-using System.Text;
-using System.Threading.Tasks;
 
-namespace Hotline.Application.Orders
+namespace Hotline.Application.OrderApp
 {
 	public interface IOrderSecondaryHandlingApplication
 	{

src/Hotline.Application/Orders/IOrderSendBackAuditApplication.cs → src/Hotline.Application/OrderApp/IOrderSendBackAuditApplication.cs

@@ -1,13 +1,8 @@
 using Hotline.Orders;
 using Hotline.Share.Dtos.Order;
 using SqlSugar;
-using System;
-using System.Collections.Generic;
-using System.Linq;
-using System.Text;
-using System.Threading.Tasks;
 
-namespace Hotline.Application.Orders
+namespace Hotline.Application.OrderApp
 {
 	public interface IOrderSendBackAuditApplication
 	{

src/Hotline.Application/Orders/IOrderVisitApplication.cs → src/Hotline.Application/OrderApp/IOrderVisitApplication.cs

@@ -1,6 +1,6 @@
 using Hotline.Share.Dtos.Order;
 
-namespace Hotline.Application.Orders;
+namespace Hotline.Application.OrderApp;
 
 public interface IOrderVisitApplication
 {

src/Hotline.Application/Orders/OrderAnalysisApplication.cs → src/Hotline.Application/OrderApp/OrderAnalysisApplication.cs

@@ -1,23 +1,15 @@
 using Hotline.Orders;
 using Hotline.Settings;
 using Hotline.Share.Dtos.Order;
+using Hotline.Share.Enums.Order;
 using MapsterMapper;
-using NPOI.SS.Formula.Functions;
 using SqlSugar;
-using System;
-using System.Collections.Generic;
-using System.Linq;
-using System.Net;
-using System.Text;
-using System.Threading.Tasks;
-using Hotline.Share.Enums.Order;
 using XF.Domain.Dependency;
 using XF.Domain.Exceptions;
 using XF.Domain.Repository;
 using XF.Utility.SequentialId;
-using static Hotline.AppDefaults;
 
-namespace Hotline.Application.Orders
+namespace Hotline.Application.OrderApp
 {
 	public class OrderAnalysisApplication : IOrderAnalysisApplication, IScopeDependency
 	{

src/Hotline.Application/Orders/OrderApplication.cs → src/Hotline.Application/OrderApp/OrderApplication.cs

@@ -1,11 +1,20 @@
-using DotNetCore.CAP;
+using System.Data;
+using System.Dynamic;
+using DotNetCore.CAP;
+using ExtendedNumerics.Exceptions;
+using FluentValidation;
+using Hotline.Application.FlowEngine;
 using Hotline.Application.Quality;
+using Hotline.Article;
 using Hotline.Authentications;
 using Hotline.Caching.Interfaces;
 using Hotline.Configurations;
 using Hotline.File;
+using Hotline.FlowEngine.Definitions;
+using Hotline.FlowEngine.Notifications;
 using Hotline.FlowEngine.WorkflowModules;
 using Hotline.FlowEngine.Workflows;
+using Hotline.Identity.Roles;
 using Hotline.KnowledgeBase;
 using Hotline.Orders;
 using Hotline.OrderTranspond;
@@ -21,6 +30,7 @@ using Hotline.Share.Dtos;
 using Hotline.Share.Dtos.DataSharing.PusherHotlineDto;
 using Hotline.Share.Dtos.File;
 using Hotline.Share.Dtos.FlowEngine;
+using Hotline.Share.Dtos.FlowEngine.Workflow;
 using Hotline.Share.Dtos.Order;
 using Hotline.Share.Dtos.Order.Publish;
 using Hotline.Share.Dtos.Push;
@@ -35,39 +45,20 @@ using Hotline.Share.Requests;
 using Hotline.Statistics;
 using Hotline.Tools;
 using Hotline.Users;
+using Hotline.Validators.FlowEngine;
 using Mapster;
 using MapsterMapper;
 using MediatR;
-using Microsoft.AspNetCore.Http;
-using Microsoft.AspNetCore.Mvc;
 using Microsoft.Extensions.Options;
 using PanGu;
 using SqlSugar;
-using System.Data;
-using System.Dynamic;
-using ExtendedNumerics.Exceptions;
-using FluentValidation;
-using Hotline.FlowEngine.Definitions;
-using Hotline.FlowEngine.Notifications;
-using Hotline.Share.Dtos.FlowEngine.Workflow;
-using Hotline.Validators.FlowEngine;
 using XF.Domain.Authentications;
 using XF.Domain.Dependency;
-using XF.Domain.Entities;
 using XF.Domain.Exceptions;
 using XF.Domain.Repository;
 using WordInfo = PanGu.WordInfo;
-using Hotline.Repository.SqlSugar.Orders;
-using Quartz.Simpl;
-using J2N.Text;
-using Hotline.Application.FlowEngine;
-using Hotline.Article;
-using Hotline.Share.Dtos.CallCenter;
-using DocumentFormat.OpenXml.Bibliography;
-using Hotline.Identity.Accounts;
-using Hotline.Identity.Roles;
 
-namespace Hotline.Application.Orders;
+namespace Hotline.Application.OrderApp;
 
 public class OrderApplication : IOrderApplication, IScopeDependency
 {

src/Hotline.Application/Orders/OrderCarbonCopyApplication.cs → src/Hotline.Application/OrderApp/OrderCarbonCopyApplication.cs

@@ -5,7 +5,7 @@ using XF.Domain.Authentications;
 using XF.Domain.Dependency;
 using XF.Domain.Repository;
 
-namespace Hotline.Application.Orders;
+namespace Hotline.Application.OrderApp;
 
 public class OrderCarbonCopyApplication : IOrderCarbonCopyApplication, IScopeDependency
 {

src/Hotline.Application/Orders/OrderSecondaryHandlingApplication.cs → src/Hotline.Application/OrderApp/OrderSecondaryHandlingApplication.cs

@@ -1,39 +1,28 @@
 using DotNetCore.CAP;
+using FluentValidation;
 using Hotline.Application.FlowEngine;
+using Hotline.Configurations;
 using Hotline.File;
 using Hotline.FlowEngine.Workflows;
 using Hotline.Orders;
-using Hotline.Repository.SqlSugar.Orders;
+using Hotline.Settings;
+using Hotline.Settings.TimeLimitDomain;
 using Hotline.Settings.TimeLimits;
-using Hotline.Share.Dtos;
-using Hotline.Share.Dtos.FlowEngine;
+using Hotline.Share.Dtos.FlowEngine.Workflow;
 using Hotline.Share.Dtos.Order;
+using Hotline.Share.Enums.FlowEngine;
 using Hotline.Share.Enums.Order;
+using Hotline.Share.Requests;
+using Hotline.Validators.FlowEngine;
 using MapsterMapper;
-using Microsoft.AspNetCore.Http;
-using Microsoft.AspNetCore.Mvc;
+using Microsoft.Extensions.Options;
 using SqlSugar;
-using System.Threading;
-using Hotline.Configurations;
-using Hotline.FlowEngine;
-using Hotline.Repository.SqlSugar.Extensions;
 using XF.Domain.Authentications;
 using XF.Domain.Dependency;
 using XF.Domain.Exceptions;
 using XF.Domain.Repository;
-using Hotline.Share.Requests;
-using Hotline.Settings;
-using Novacode;
-using Hotline.Share.Enums.FlowEngine;
-using Hotline.Settings.TimeLimitDomain;
-using Microsoft.Extensions.Options;
-using DocumentFormat.OpenXml.Office2010.Excel;
-using Hotline.Share.Dtos.FlowEngine.Workflow;
-using Hotline.Validators.FlowEngine;
-using FluentValidation;
-using Hotline.Authentications;
 
-namespace Hotline.Application.Orders
+namespace Hotline.Application.OrderApp
 {
     public class OrderSecondaryHandlingApplication : IOrderSecondaryHandlingApplication, IScopeDependency
     {

src/Hotline.Application/Orders/OrderSendBackAuditApplication.cs → src/Hotline.Application/OrderApp/OrderSendBackAuditApplication.cs

@@ -1,7 +1,5 @@
 using Hotline.Orders;
 using Hotline.SeedData;
-using Hotline.Share.Dtos;
-using Hotline.Share.Dtos.Bi;
 using Hotline.Share.Dtos.Order;
 using Hotline.Share.Enums.Order;
 using SqlSugar;
@@ -9,7 +7,7 @@ using XF.Domain.Authentications;
 using XF.Domain.Dependency;
 using XF.Domain.Repository;
 
-namespace Hotline.Application.Orders
+namespace Hotline.Application.OrderApp
 {
     public class OrderSendBackAuditApplication : IOrderSendBackAuditApplication, IScopeDependency
     {

src/Hotline.Application/Orders/OrderVisitApplication.cs → src/Hotline.Application/OrderApp/OrderVisitApplication.cs

@@ -9,8 +9,7 @@ using SqlSugar;
 using XF.Domain.Dependency;
 using XF.Domain.Repository;
 
-
-namespace Hotline.Application.Orders;
+namespace Hotline.Application.OrderApp;
 
 /// <summary>
 /// 回访服务

src/Hotline.Application/Snapshot/Notifications/SnapshotHandler.cs

@@ -21,7 +21,7 @@ using System.Collections.Generic;
 using System.Linq;
 using System.Text;
 using System.Threading.Tasks;
-using Hotline.Application.Orders;
+using Hotline.Application.OrderApp;
 using Hotline.FlowEngine.Workflows;
 using XF.Domain.Dependency;
 using XF.Domain.Exceptions;

src/Hotline.Application/SpecialNumber/SpecialNumberApplication.cs

@@ -51,6 +51,7 @@ namespace Hotline.Application.SpecialNumber
                 .WhereIF(dto.CreationTimeEnd.HasValue, x => x.CreationTime <= dto.CreationTimeEnd)
                 .OrderByIF(dto is { SortField: "creationTime", SortRule: 0 }, x => x.CreationTime, OrderByType.Asc)  //创建时间升序
                 .OrderByIF(dto is { SortField: "creationTime", SortRule: 1 }, x => x.CreationTime, OrderByType.Desc) //创建时间降序
+                .OrderByIF(string.IsNullOrEmpty(dto.SortField), x => x.CreationTime, OrderByType.Desc) //创建时间降序
                 .ToPagedListAsync(dto.PageIndex, dto.PageSize, cancellationToken);
             return (total, _mapper.Map<IList<SpecialNumberInfoDto>>(temp));
             //return (total, temp);

src/Hotline.Application/StatisticalReport/IOrderReportApplication.cs

@@ -131,6 +131,13 @@ namespace Hotline.Application.StatisticalReport
         /// <returns></returns>
         ISugarQueryable<Order> DepartmentAcceptanceTypeOrderList(DepartmentKeyWordRequest dto);
 
+        /// <summary>
+        /// 部门受理类型统计--明细列表
+        /// </summary>
+        /// <param name="dto"></param>
+        /// <returns></returns>
+        ISugarQueryable<Order> DepartmentAcceptanceTypeOrderListV1(DepartmentKeyWordRequest dto);
+
 
         /// <summary>
         /// 受理类型统计

src/Hotline.Application/StatisticalReport/OrderReportApplication.cs

@@ -1,5 +1,4 @@
-using Hotline.Application.Orders;
-using Hotline.Caching.Interfaces;
+using Hotline.Caching.Interfaces;
 using Hotline.CallCenter.Calls;
 using Hotline.FlowEngine.WorkflowModules;
 using Hotline.FlowEngine.Workflows;
@@ -2307,7 +2306,7 @@ namespace Hotline.Application.StatisticalReport
         }
 
         /// <summary>
-        /// 部门受理类型统计周期（宜宾原始）
+        /// 部门受理类型统计周期（宜宾功能）
         /// </summary>
         /// <param name="dto"></param>
         /// <returns></returns>
@@ -2316,32 +2315,49 @@ namespace Hotline.Application.StatisticalReport
             var IsCenter = _sessionContext.OrgIsCenter;
             var centerOrgName = _systemSettingCacheManager.GetSetting(SettingConstants.CenterOrgName)?.SettingValue[0];
 
+            int endIndex = 6;
+
+            if (!IsCenter && string.IsNullOrEmpty(dto.OrgCode))
+            {
+                dto.OrgCode = _sessionContext.OrgId;
+            }
+
+            if (!string.IsNullOrEmpty(dto.OrgCode))
+            {
+                switch (dto.OrgCode.Length)
+                {
+                    case 6: endIndex = 9; break;
+                    case 9: endIndex = 12; break;
+                    case 12: endIndex = 15; break;
+                }
+            }
 
             var orderData = _orderRepository.Queryable()
               .WhereIF(dto.StartTime.HasValue, it => it.StartTime >= dto.StartTime)
               .WhereIF(dto.EndTime.HasValue, it => it.StartTime <= dto.EndTime)
               .WhereIF(dto.TypeId != null && dto.TypeId == 1, it => it.IdentityType == EIdentityType.Citizen)
               .WhereIF(dto.TypeId != null && dto.TypeId == 2, it => it.IdentityType == EIdentityType.Enterprise)
+              .WhereIF(!string.IsNullOrEmpty(dto.OrgCode), it => it.ActualHandleOrgCode.StartsWith(dto.OrgCode))
               .Select(it => new
               {
-                  OrgCode = string.IsNullOrEmpty(dto.OrgCode) ? it.ActualHandleOrgCode.Substring(0, 6) : it.ActualHandleOrgCode.Substring(0, _sessionContext.RequiredOrgId.Length + 3),
+                  OrgCode = it.ActualHandleOrgCode.Substring(0, endIndex),
                   AcceptTypeCode = it.AcceptTypeCode
               })
               .MergeTable()
-
-              //.WhereIF(!IsCenter, p => p.OrgCode.StartsWith(_sessionContext.RequiredOrgId))
-
-              .LeftJoin<SystemOrganize>((it, o) => it.OrgCode == o.Id)
+              .LeftJoin<SystemOrganize>((it, o) => o.Id == it.OrgCode)
               .GroupBy((it, o) => new
               {
-                  it.OrgCode,
+                  o.Id,
                   o.Name,
                   o.OrgType
               })
+              .WhereIF(dto.OrgType == 1, (it, o) => o.OrgType != EOrgType.County)
+              .WhereIF(dto.OrgType == 2, (it, o) => o.OrgType == EOrgType.County)
+              .WhereIF(!string.IsNullOrEmpty(dto.OrgName), (it, o) => o.Name.StartsWith(dto.OrgName))
               .Select((it, o) => new DepartmentAcceptanceTypeStatisticsV1Dto
               {
-                  OrgName = it.OrgCode == "001" ? centerOrgName : o.Name,
-                  OrgCode = it.OrgCode,
+                  OrgName = o.Id == "001" ? centerOrgName : o.Name,
+                  OrgCode = o.Id,
                   OrgType = o.OrgType,
                   OrgTypeText = o.OrgType == EOrgType.County ? "区县部门" : "市直部门",
                   ZxAllCount = SqlFunc.AggregateSum(SqlFunc.IIF(it.AcceptTypeCode == "10", 1, 0)),
@@ -2374,9 +2390,32 @@ namespace Hotline.Application.StatisticalReport
                   DqAllCount = SqlFunc.AggregateSum(SqlFunc.IIF(it.AcceptTypeCode == "3", 1, 0)),
                   DqAcceptanceTypeCode = "3"
               }).MergeTable();
+
             return orderData;
         }
 
+        /// <summary>
+        /// 部门受理类型统计（宜宾功能）--明细列表
+        /// </summary>
+        /// <param name="dto"></param>
+        /// <returns></returns>
+        public ISugarQueryable<Order> DepartmentAcceptanceTypeOrderListV1(DepartmentKeyWordRequest dto)
+        {
+            return _orderRepository.Queryable()
+                 .WhereIF(dto.StartTime.HasValue, x => x.StartTime >= dto.StartTime)
+                 .WhereIF(dto.EndTime.HasValue, x => x.StartTime <= dto.EndTime)
+                 .WhereIF(dto.TypeId != null && dto.TypeId == 1, x => x.IdentityType == EIdentityType.Citizen)
+                 .WhereIF(dto.TypeId != null && dto.TypeId == 2, x => x.IdentityType == EIdentityType.Enterprise)
+                 .WhereIF(!string.IsNullOrEmpty(dto.AcceptTypeCode), x => x.AcceptTypeCode == dto.AcceptTypeCode)
+                 .WhereIF(!string.IsNullOrEmpty(dto.OrgCode) && dto.OrgCode == "001", x => x.ActualHandleOrgCode == dto.OrgCode)
+                 .WhereIF(!string.IsNullOrEmpty(dto.OrgCode) && dto.OrgCode != "001" && _sessionContext.RequiredOrgId != dto.OrgCode, x => x.ActualHandleOrgCode.StartsWith(dto.OrgCode))
+                 .WhereIF(!string.IsNullOrEmpty(dto.OrgCode) && dto.OrgCode != "001" && _sessionContext.RequiredOrgId == dto.OrgCode, x => x.ActualHandleOrgCode == dto.OrgCode)
+                 .MergeTable()
+                 .LeftJoin<SystemOrganize>((x, o) => x.ActualHandleOrgCode == o.Id)
+                 .WhereIF(dto.OrgType == 1, (x, o) => o.OrgType != EOrgType.County)
+                 .WhereIF(dto.OrgType == 2, (x, o) => o.OrgType == EOrgType.County)
+                 .OrderByDescending(x => x.CreationTime);
+        }
 
         /// <summary>
         /// 受理类型统计

src/Hotline.Application/Subscribers/DatasharingSubscriber.cs

@@ -2,7 +2,7 @@
 using FluentValidation;
 using Hotline.Application.CallCenter;
 using Hotline.Application.FlowEngine;
-using Hotline.Application.Orders;
+using Hotline.Application.OrderApp;
 using Hotline.Authentications;
 using Hotline.Caching.Interfaces;
 using Hotline.Caching.Services;
@@ -665,7 +665,8 @@ namespace Hotline.Application.Subscribers
                             }
 
                             orderVisit.OrderVisitDetails[i].VisitContent = dto.VisitContent;
-                        }
+							orderVisit.OrderVisitDetails[i].ScreenByEndTime = await _orderDomainService.GetScreenByEndTime();
+						}
 
                         await _orderVisitedDetailRepository.UpdateRangeAsync(orderVisit.OrderVisitDetails, cancellationToken);
                         //工单
@@ -759,9 +760,9 @@ namespace Hotline.Application.Subscribers
                     orgDetail.VisitOrgCode = order.ActualHandleOrgCode;
                     orgDetail.VisitOrgName = order.ActualHandleOrgName;
                     orgDetail.VisitTarget = EVisitTarget.Org;
+					orgDetail.ScreenByEndTime = await _orderDomainService.GetScreenByEndTime();
 
-
-                    orgDetail.OrgProcessingResults = satisfy;
+					orgDetail.OrgProcessingResults = satisfy;
 
                     visitedDetail.Add(orgDetail);
                     //TODO 自贡办件态度

src/Hotline.Application/Subscribers/InternalCapSubscriber.cs

@@ -1,5 +1,5 @@
 using DotNetCore.CAP;
-using Hotline.Application.Orders;
+using Hotline.Application.OrderApp;
 using Hotline.Caching.Interfaces;
 using Hotline.Configurations;
 using Hotline.FlowEngine.Workflows;

src/Hotline.Share/Dtos/Order/OrderVisitDto.cs

@@ -778,7 +778,7 @@ namespace Hotline.Share.Dtos.Order
 
         public string? EmployeeName { get; set; }
 
-        public string CreationTime { get; set; }
+        public DateTime CreationTime { get; set; }
 
         /// <summary>
         /// 是否接通

src/Hotline.Share/Requests/DepartmentKeyWordRequest.cs

@@ -1,4 +1,6 @@
-namespace Hotline.Share.Requests
+using Hotline.Settings;
+
+namespace Hotline.Share.Requests
 {
     public record DepartmentKeyWordRequest : PagedRequest
     {
@@ -36,5 +38,15 @@
         /// 1：受理时间 2：办结时间  默认：2
         /// </summary>
         public int TimeType { get; set; } = 2;
+
+        /// <summary>
+        /// 部门类型 1市直部门 2区县部门
+        /// </summary>
+        public int OrgType { get; set; }
+
+        /// <summary>
+        /// 部门名称
+        /// </summary>
+        public string OrgName { get; set; }
     }
 }

src/Hotline/FlowEngine/Workflows/WorkflowDomainService.cs

@@ -284,7 +284,7 @@ namespace Hotline.FlowEngine.Workflows
         /// workflow, currentStep, nextStepDefine, nextSteps
         /// </summary>
         public async Task<(Workflow, WorkflowStep, StepDefine, List<WorkflowStep>)> NextAsync(
-            NextWorkflowDto dto, 
+            NextWorkflowDto dto,
             EHandleMode handleMode = EHandleMode.Normal,
             DateTime? expiredTime = null, bool isAutoFillSummaryOpinion = false,
             Action<Workflow, WorkflowStep, StepDefine>? currentStepConfig = null,
@@ -623,8 +623,8 @@ namespace Hotline.FlowEngine.Workflows
             nextDto.WorkflowId = workflow.Id;
             nextDto.StepId = startStep.Id;
             var (_, _, _, nextSteps) =
-                await NextAsync(nextDto, 
-                    expiredTime: expiredTime, 
+                await NextAsync(nextDto,
+                    expiredTime: expiredTime,
                     isAutoFillSummaryOpinion: true,
                     newStepConfig: newStepConfig, cancellationToken: cancellationToken);
             return nextSteps;
@@ -991,13 +991,13 @@ namespace Hotline.FlowEngine.Workflows
             var newPrevStep = DuplicateStep(workflow, prevStepDefine, prevStep, EWorkflowTraceType.Previous, dto.ExpiredTime);
             newPrevStep.Assign(prevStep, EFlowAssignType.User);
 
-			////甄别退回到最开始节点到部门 todo 重构放在调用处判断  
-			//if (workflow.FlowType == EFlowType.Review && workflow.ModuleCode == WorkflowModuleConsts.OrderScreen)
-			//{
-			//	newPrevStep.FlowAssignType = newPrevStep.StepType == EStepType.Start ? EFlowAssignType.Org : prevStep.FlowAssignType;
-			//}
+            ////甄别退回到最开始节点到部门 todo 重构放在调用处判断  
+            //if (workflow.FlowType == EFlowType.Review && workflow.ModuleCode == WorkflowModuleConsts.OrderScreen)
+            //{
+            //	newPrevStep.FlowAssignType = newPrevStep.StepType == EStepType.Start ? EFlowAssignType.Org : prevStep.FlowAssignType;
+            //}
 
-			if (dto.Handler != null)
+            if (dto.Handler != null)
                 newPrevStep.Assign(dto.Handler);
 
             //await Task.Run(() => newStepConfig?.Invoke(workflow, currentStep, prevStepDefine, prevStep, newPrevStep), cancellationToken);
@@ -1051,10 +1051,10 @@ namespace Hotline.FlowEngine.Workflows
         /// <summary>
         /// 退回
         /// </summary>
-        public async Task<(Workflow workflow, WorkflowStep currentStep, StepDefine prevDefine, 
-                WorkflowStep prevStep, WorkflowStep newStep, EFlowDirection flowDirection)> 
-            PreviousAsync(PreviousWorkflowDto dto, 
-                EHandleMode handleMode = EHandleMode.Previous, 
+        public async Task<(Workflow workflow, WorkflowStep currentStep, StepDefine prevDefine,
+                WorkflowStep prevStep, WorkflowStep newStep, EFlowDirection flowDirection)>
+            PreviousAsync(PreviousWorkflowDto dto,
+                EHandleMode handleMode = EHandleMode.Previous,
                 Action<Workflow, WorkflowStep, StepDefine, WorkflowStep, WorkflowStep>? newStepConfig = null,
             CancellationToken cancellationToken = default)
         {
@@ -1402,11 +1402,12 @@ namespace Hotline.FlowEngine.Workflows
         public StepAssignInfo GetSummaryTargetFlowStepHandler(Workflow workflow, string summaryTargetStepCode)
         {
             //根据汇总对象id找到被汇总节点
-            var summaryTargetStep = workflow.Steps.FirstOrDefault(d =>
+            var summaryTargetStep = workflow.Steps.Where(d =>
                 d.StepType == EStepType.Normal &&
                 d.Code == summaryTargetStepCode &&
                 d.Status == EWorkflowStepStatus.Handled &&
-                d.IsOrigin);
+                d.IsOrigin)
+                .MaxBy(d => d.CreationTime);
             if (summaryTargetStep is null)
                 throw UserFriendlyException.SameMessage("未查询到汇总对象节点");
 

test/Hotline.Tests/Application/OrderApplicationTest.cs

@@ -1,4 +1,4 @@
-using Hotline.Application.Orders;
+using Hotline.Application.OrderApp;
 using Hotline.Caching.Interfaces;
 using Hotline.Orders;
 using Hotline.Push.FWMessage;

test/Hotline.Tests/Application/OrderVisitApplicationTest.cs

@@ -1,4 +1,4 @@
-using Hotline.Application.Orders;
+using Hotline.Application.OrderApp;
 using Hotline.Share.Dtos.Order;
 using Hotline.Share.Tools;
 using Shouldly;