src/DataSharing.Application/Receivers/YiBin/YjgljReceiver.cs

@@ -3,7 +3,9 @@ using DataSharing.Repository;
 using DotNetCore.CAP;
 using Hotline.Share.Dtos.ContingencyManagement;
 using MapsterMapper;
+using Microsoft.Extensions.DependencyInjection;
 using Microsoft.Extensions.Logging;
+using Novacode;
 using SqlSugar;
 
 namespace DataSharing.Application.Receivers.YiBin
@@ -16,11 +18,14 @@ namespace DataSharing.Application.Receivers.YiBin
 
         public YjgljReceiver(IMapper mapper,
             ILogger<YjgljReceiver> logger,
-            ISugarUnitOfWork<ContingencyManagementDbContext> uow)
+          IServiceProvider serviceProvider,
+          ISharingConfigurationManager sharingConfigurationManager)
         {
             _mapper = mapper;
             _logger = logger;
-            _db = uow.Db;
+            //_db = uow.Db;
+            if (sharingConfigurationManager.IsCity(""))
+                _db = serviceProvider.GetRequiredService<ISugarUnitOfWork<ContingencyManagementDbContext>>().Db;
         }
 
         /// <summary>

src/DataSharing.Host/StartupExtensions.cs

@@ -49,20 +49,20 @@ internal static class StartupExtensions
             services.AddScoped<IPoliceService, DaoShuService>();//110
             services.AddScoped<IEnterpriseService, EnterpriseService>();//企业专班
             services.AddScoped<IZzptService, ZzptService>();//综治平台
-            services.AddScoped<ICityStateDataExchangeService, CityStateDataExchangeService>();//市州互转
+            //services.AddScoped<ICityStateDataExchangeService, CityStateDataExchangeService>();//市州互转
 
             ////应急管理局业务
             if (sharingConfig.CityYiBin.YingJiGuanLiJu != null && sharingConfig.CityYiBin.YingJiGuanLiJu.DbConnectionString != null)
             {
                 services.AddYingJiDb(sharingConfig.CityYiBin.YingJiGuanLiJu);
-                services.AddScoped<IYjgljReceiver, YjgljReceiver>();
+                //services.AddScoped<IYjgljReceiver, YjgljReceiver>();
             }
         }
         else if (sharingConfig != null && sharingConfig.CityCode == ConfigurationConsts.ZiGong)//自贡
         {
             services.AddScoped<ISendTaskDataService, DataSharing.ZiGong.ZiGongSendTaskDataService>();
             services.AddScoped<IPoliceService, DcjtService>();//110
-            services.AddScoped<ICityStateDataExchangeService, CityStateDataExchangeService>();//市州互转
+            //services.AddScoped<ICityStateDataExchangeService, CityStateDataExchangeService>();//市州互转
         }
 
         services