tangjiang 8 months ago
parent
commit
bbb5e7c39b

+ 6 - 0
src/DataSharing.Application/Receivers/IYjgljReceiver.cs

@@ -0,0 +1,6 @@
+namespace DataSharing.Application.Receivers
+{
+    public interface IYjgljReceiver
+    {
+    }
+}

+ 1 - 2
src/DataSharing.Application/Receivers/YjgljReceiver.cs

@@ -5,11 +5,10 @@ using Hotline.Share.Dtos.ContingencyManagement;
 using MapsterMapper;
 using Microsoft.Extensions.Logging;
 using SqlSugar;
-using XF.Domain.Dependency;
 
 namespace DataSharing.Application.Receivers
 {
-    public class YjgljReceiver : ICapSubscribe, IScopeDependency
+    public class YjgljReceiver : IYjgljReceiver, ICapSubscribe
     {
         private readonly IMapper _mapper;
         private readonly ILogger<YjgljReceiver> _logger;

+ 8 - 3
src/DataSharing.Host/StartupExtensions.cs

@@ -1,4 +1,5 @@
-using DataSharing.CityStateDataExchange;
+using DataSharing.Application.Receivers;
+using DataSharing.CityStateDataExchange;
 using DataSharing.Police110;
 using DataSharing.Police110.DaoShu110;
 using DataSharing.Police110.DCJT110;
@@ -50,9 +51,13 @@ internal static class StartupExtensions
             services.AddScoped<IZzptService, ZzptService>();//综治平台
             services.AddScoped<ICityStateDataExchangeService, CityStateDataExchangeService>();//市州互转
 
-            //应急管理局业务
-            if (sharingConfig.CityYiBin.YingJiGuanLiJu != null && sharingConfig.CityYiBin.YingJiGuanLiJu.DbConnectionString != null)
+            ////应急管理局业务
+            if (sharingConfig.CityYiBin.YingJiGuanLiJu != null &&
+                sharingConfig.CityYiBin.YingJiGuanLiJu.DbConnectionString != null)
+            {
                 services.AddYingJiDb(sharingConfig.CityYiBin.YingJiGuanLiJu);
+                services.AddScoped<IYjgljReceiver, YjgljReceiver>();
+            }
         }
         else if (sharingConfig != null && sharingConfig.CityCode == ConfigurationConsts.ZiGong)//自贡
         {