xiugai

src/DataSharing/Province/ProvinceService.cs

@@ -1,4 +1,5 @@
 using DataSharing.HotlineWeb;
+using DataSharing.Province.SendTask.SubmitCaseRecord;
 using DataSharing.RawData;
 using DataSharing.SendTask;
 using DataSharing.Share.Consts;
@@ -59,7 +60,8 @@ namespace DataSharing.Province
         private readonly ISharingConfigurationManager _sharingConfigurationManager;
         private readonly IInitPushDataService _initPushDataService;
         private readonly IRepository<DsGetCaseMaterialInfo> _getCaseMaterialInfoRepository;
-        private readonly IRepository<ConfigurationInformation> _configurationInformationRepository;
+        private readonly IRepository<ConfigurationInformation> _configurationInformationRepository; 
+        private readonly IRepository<DsSendTaskSubmitCaseRecord> _sendTaskSubmitCaseRecordRepository;
 
         /// <summary>
         /// 
@@ -98,7 +100,8 @@ namespace DataSharing.Province
              ISharingConfigurationManager sharingConfigurationManager,
              IInitPushDataService initPushDataService,
              IRepository<DsGetCaseMaterialInfo> getCaseMaterialInfoRepository,
-             IRepository<ConfigurationInformation> configurationInformationRepository)
+             IRepository<ConfigurationInformation> configurationInformationRepository,
+             IRepository<DsSendTaskSubmitCaseRecord> sendTaskSubmitCaseRecordRepository)
         {
             _mapper = mapper;
             _logger = logger;
@@ -118,6 +121,7 @@ namespace DataSharing.Province
             _initPushDataService = initPushDataService;
             _getCaseMaterialInfoRepository = getCaseMaterialInfoRepository;
             _configurationInformationRepository = configurationInformationRepository;
+            _sendTaskSubmitCaseRecordRepository = sendTaskSubmitCaseRecordRepository;
         }
         #endregion
 
@@ -680,7 +684,7 @@ namespace DataSharing.Province
             if (dto.TrCallRecordDto is not null)
             {
                 //如果推送工单的时候判断通话记录是否是未接，并且是否已经上传，如果没有咋补再次推送通话记录
-                var tellCall = await _dsTelCallRepository.AnyAsync(p => p.CallId == dto.TrCallRecordDto.OtherAccept, cancellationToken);
+                var tellCall = await _sendTaskSubmitCaseRecordRepository.AnyAsync(p => p.CallId == dto.TrCallRecordDto.OtherAccept, cancellationToken);
                 if (dto.TrCallRecordDto.OnState == EOnState.NoOn && !tellCall)
                     return;
 
@@ -887,7 +891,7 @@ namespace DataSharing.Province
         public async Task SubmitCaseRecordOrderAsync(PublishCallRecrodDto dto, CancellationToken cancellationToken)
         {
             //如果推送工单的时候判断通话记录是否是未接，并且是否已经上传，如果没有咋补再次推送通话记录
-            var tellCall = await _dsTelCallRepository.AnyAsync(p => p.CallId == dto.TrCallRecordDto.OtherAccept, cancellationToken);
+            var tellCall = await _sendTaskSubmitCaseRecordRepository.AnyAsync(p => p.CallId == dto.TrCallRecordDto.OtherAccept, cancellationToken);
             if (dto.TrCallRecordDto.OnState == EOnState.NoOn && !tellCall)
                 return;