记录日志

src/Hotline.Api/config/appsettings.Test.json

@@ -9,6 +9,16 @@
         "Password": "fengwo123!$!$",
         "Database": 2 //hotline:3, dev:5, test:2, demo:4
     },
+    "MqConfiguration": {
+        "DbConnectionString": "PORT=5432;DATABASE=fwmq;HOST=110.188.24.182;PASSWORD=fengwo11!!;USER ID=dev;",
+        "UseDashBoard": true,
+        "RabbitMq": {
+            "UserName": "dev",
+            "Password": "123456",
+            "HostName": "110.188.24.182",
+            "VirtualHost": "fwt-test"
+        }
+    },
     "SenparcWeixinSetting": {
         "IsDebug": true,
 

src/Hotline.Application/Snapshot/SnapshotApplicationBase.cs

@@ -38,6 +38,8 @@ using Hotline.Snapshot.IRepository;
 using Hotline.Share.Enums.CallCenter;
 using Hotline.Repository.SqlSugar.Snapshot;
 using Hotline.Settings.Hotspots;
+using Microsoft.Extensions.Options;
+using XF.Utility.MQ;
 
 namespace Hotline.Application.Snapshot;
 
@@ -82,8 +84,9 @@ public abstract class SnapshotApplicationBase
     private readonly IInviteCodeRepository _inviteCodeRepository;
     private readonly ICitizenRepository _citizenRepository;
     private readonly ISnapshotPointsRecordRepository _pointsRecordRepository;
+    private readonly IOptionsSnapshot<MqConfiguration> _mqConfiguration;
 
-    public SnapshotApplicationBase(IThirdIdentiyService thirdLoginService, IIndustryRepository industryRepository, ISnapshotBulletinRepository bulletinRepository, ISessionContext sessionContext, IRepository<RedPackRecord> redPackRecordRepository, IRepository<Order> orderRepository, IThirdAccountRepository thirdAccountRepository, IOrderSnapshotRepository orderSnapshotRepository, ISystemSettingCacheManager systemSettingCacheManager, ISystemAreaDomainService systemAreaDomainService, IFileRepository fileRepository, ISystemDicDataCacheManager systemDicDataCacheManager, ISnapshotOrderPublishRepository snapshotOrderPublishRepository, IRepository<WorkflowTrace> workflowTraceRepository, IPractitionerRepository practitionerRepository, IRepository<SystemArea> systemAreaRepository, IVolunteerRepository volunteerRepository, IVolunteerReportRepository volunteerReportRepository, ISystemLogRepository systemLog, IGuiderSystemService guiderSystemService, ICapPublisher capPublisher, Publisher publisher, IFileDomainService fileDomainService, ICommunityInfoRepository communityInfoRepository, IRedPackAuditRepository redPackAuditRepository, IOrderVisitRepository orderVisitRepository, IOrderVisitDetailRepository orderVisitDetailRepository, IRedPackGuiderAuditRepository redPackGuiderAuditRepository, IInviteCodeRecordRepository inviteCodeRecordRepository, IInviteCodeRepository inviteCodeRepository, ICitizenRepository citizenRepository, ISnapshotPointsRecordRepository snapshotPointsRecordRepository)
+    public SnapshotApplicationBase(IThirdIdentiyService thirdLoginService, IIndustryRepository industryRepository, ISnapshotBulletinRepository bulletinRepository, ISessionContext sessionContext, IRepository<RedPackRecord> redPackRecordRepository, IRepository<Order> orderRepository, IThirdAccountRepository thirdAccountRepository, IOrderSnapshotRepository orderSnapshotRepository, ISystemSettingCacheManager systemSettingCacheManager, ISystemAreaDomainService systemAreaDomainService, IFileRepository fileRepository, ISystemDicDataCacheManager systemDicDataCacheManager, ISnapshotOrderPublishRepository snapshotOrderPublishRepository, IRepository<WorkflowTrace> workflowTraceRepository, IPractitionerRepository practitionerRepository, IRepository<SystemArea> systemAreaRepository, IVolunteerRepository volunteerRepository, IVolunteerReportRepository volunteerReportRepository, ISystemLogRepository systemLog, IGuiderSystemService guiderSystemService, ICapPublisher capPublisher, Publisher publisher, IFileDomainService fileDomainService, ICommunityInfoRepository communityInfoRepository, IRedPackAuditRepository redPackAuditRepository, IOrderVisitRepository orderVisitRepository, IOrderVisitDetailRepository orderVisitDetailRepository, IRedPackGuiderAuditRepository redPackGuiderAuditRepository, IInviteCodeRecordRepository inviteCodeRecordRepository, IInviteCodeRepository inviteCodeRepository, ICitizenRepository citizenRepository, ISnapshotPointsRecordRepository snapshotPointsRecordRepository, IOptionsSnapshot<MqConfiguration> mqConfiguration)
     {
         _thirdLoginService = thirdLoginService;
         _industryRepository = industryRepository;
@@ -117,6 +120,7 @@ public abstract class SnapshotApplicationBase
         _inviteCodeRepository = inviteCodeRepository;
         _citizenRepository = citizenRepository;
         _pointsRecordRepository = snapshotPointsRecordRepository;
+        _mqConfiguration = mqConfiguration;
     }
 
     #region 小程序
@@ -656,7 +660,7 @@ public abstract class SnapshotApplicationBase
     public async Task GuiderSystemReplyDelayAsync(string orderId, CancellationToken cancellationToken)
     {
         var orderSnapshot = await _orderSnapshotRepository.GetAsync(orderId)
-            ?? throw new UserFriendlyException($"orderId:{orderId} order_snapshot 不存在该数据");
+            ?? throw new UserFriendlyException($"orderId:{orderId} order_snapshot {_mqConfiguration.Value.RabbitMq.VirtualHost} 不存在该数据");
         if (orderSnapshot.IsDeal != null && orderSnapshot.IsDeal == true)
             return;
         // 网格员未回复, 推送事件