Просмотр исходного кода

Merge branch 'test' into lib/test

libin 1 неделя назад
Родитель
Сommit
4f82dfd664

+ 1 - 1
src/Hotline.Api/StartupExtensions.cs

@@ -200,7 +200,7 @@ internal static class StartupExtensions
             .AddValidatorsFromAssembly(typeof(ValidatorExtensions).Assembly);
 
         //mq
-        services.AddMq(configuration);
+        services.AddMq(()=>configuration.GetSection(nameof(MqConfiguration)).Get<MqConfiguration>());
 
         //job
         services.RegisterJob(appConfiguration);

+ 1 - 0
src/Hotline.Api/config/appsettings.Development.json

@@ -120,6 +120,7 @@
   "MqConfiguration": {
     "DbConnectionString": "PORT=5432;DATABASE=fwmq;HOST=110.188.24.182;PASSWORD=fengwo11!!;USER ID=dev;",
     "UseDashBoard": true,
+    "FailedRetryCount": 5,
     "RabbitMq": {
       "UserName": "dev",
       "Password": "123456",

+ 5 - 5
src/Hotline.Application/JudicialManagement/EnforcementApplication.cs

@@ -23,7 +23,7 @@ namespace Hotline.Application.JudicialManagement
         private readonly IRepository<JudicialManagementOrders> _judicialManagementOrdersRepository;
         private readonly IMapper _mapper;
         private readonly ISessionContext _sessionContext;
-        private readonly IRepository<LawEnforcementAgencies> _lawEnforcementAgenciesRepository;
+        private readonly IRepository<EnforcementOrdersHandler> _enforcementOrdersHandlerRepository;
 
         /// <summary>
         /// 
@@ -37,12 +37,12 @@ namespace Hotline.Application.JudicialManagement
            IRepository<JudicialManagementOrders> judicialManagementOrdersRepository,
            IMapper mapper,
            ISessionContext sessionContext,
-           IRepository<LawEnforcementAgencies> lawEnforcementAgenciesRepository)
+           IRepository<EnforcementOrdersHandler> enforcementOrdersHandlerRepository)
         {
             _judicialManagementOrdersRepository = judicialManagementOrdersRepository;
             _mapper = mapper;
             _sessionContext = sessionContext;
-            _lawEnforcementAgenciesRepository = lawEnforcementAgenciesRepository;
+            _enforcementOrdersHandlerRepository = enforcementOrdersHandlerRepository;
         }
 
         /// <summary>
@@ -145,7 +145,7 @@ namespace Hotline.Application.JudicialManagement
         /// <returns></returns>
         public ISugarQueryable<EmDepartmentalProcessingStatisticsDto> GetDepartmentalProcessingStatisticsAsync(DateTime StartTime, DateTime EndTime)
         {
-            return _lawEnforcementAgenciesRepository.Queryable()
+            return _enforcementOrdersHandlerRepository.Queryable()
                    .LeftJoin<JudicialManagementOrders>((h, o) => h.OrderId == o.Id)
                    .Where((h, o) => o.CreationTime >= StartTime && o.CreationTime <= EndTime && o.IsItCounted == true)
                     .GroupBy((h, o) => new
@@ -172,7 +172,7 @@ namespace Hotline.Application.JudicialManagement
         /// <returns></returns>
         public ISugarQueryable<EnforcementOrderListDto> GetDepartmentalProcessingStatisticsOrderListAsync(QueryDepartmentalProcessingStatisticsDto dto)
         {
-            return _lawEnforcementAgenciesRepository.Queryable()
+            return _enforcementOrdersHandlerRepository.Queryable()
                  .LeftJoin<JudicialManagementOrders>((x, o) => x.OrderId == o.Id)
                  .Where((x, o) => o.CreationTime >= dto.StartTime && o.CreationTime <= dto.EndTime && o.Id != null && o.IsItCounted == true)
                  .WhereIF(!string.IsNullOrEmpty(dto.OrgCode) && dto.OrgCode == "001", (x, o) => x.OrgCode == dto.OrgCode)

+ 1 - 1
src/Hotline.Application/OrderApp/OrderApplication.cs

@@ -1904,7 +1904,7 @@ public class OrderApplication : IOrderApplication, IScopeDependency
                                                                                                //.WhereIF(!string.IsNullOrEmpty(dto.OrderTagCode), d => d.OrderTagCode == dto.OrderTagCode)// 工单标签
                 .WhereIF(!string.IsNullOrEmpty(dto.OrderTagCode), d => d.OrderTags.Any(ot => ot.DicDataValue == dto.OrderTagCode)) //工单标签
                 .WhereIF(!string.IsNullOrEmpty(dto.FocusOnEvents),
-                    d => d.FocusOnEvents.Contains(dto.FocusOnEvents)) //!string.IsNullOrEmpty(d.FocusOnEvents) && SqlFunc.SplitIn(d.FocusOnEvents, dto.FocusOnEvents))
+                    d => d.FocusOnEvents.Contains(dto.FocusOnEvents) && !d.FocusOnEvents.Contains("99")) //!string.IsNullOrEmpty(d.FocusOnEvents) && SqlFunc.SplitIn(d.FocusOnEvents, dto.FocusOnEvents))
                 .OrderByIF(string.IsNullOrEmpty(dto.SortField), d => d.CreationTime, OrderByType.Desc) //默认排序时间为创建时间
                 .OrderByIF(dto is { SortField: "no", SortRule: 0 }, d => d.No, OrderByType.Asc) //工单编号升序
                 .OrderByIF(dto is { SortField: "no", SortRule: 1 }, d => d.No, OrderByType.Desc) //工单编号降序

+ 1 - 1
src/Hotline/Hotline.csproj

@@ -15,7 +15,7 @@
     <PackageReference Include="Portable.BouncyCastle" Version="1.9.0" />
     <PackageReference Include="RestSharp" Version="110.2.0" />
     <PackageReference Include="SSH.NET" Version="2024.2.0" />
-    <PackageReference Include="XF.Utility.MQ" Version="1.0.9" />
+    <PackageReference Include="XF.Utility.MQ" Version="1.0.10" />
     <PackageReference Include="FluentValidation" Version="11.10.0" />
   </ItemGroup>