admin/Backend-Api
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

enable real-time status updates via SignalR in contract processing methods

Browse Source
This commit is contained in:
mahan
2025-11-22 12:45:01 +03:30
parent 6102ec3be8
commit de37555db9
1 changed files with 7 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
CompanyManagment.EFCore/Repository/InstitutionContractRepository.cs
View File

@@ -65,6 +65,7 @@ public class InstitutionContractRepository : RepositoryBase<long, InstitutionCon
private readonly ISmsResultRepository _smsResultRepository;
private readonly IFinancialTransactionRepository _financialTransactionRepository;
private readonly IFinancialStatmentRepository _financialStatmentRepository;
private readonly IHubContext<SendSmsHub> _hubContext;
private readonly InstitutionContratVerificationParty _firstParty = new()
{
@@ -78,8 +79,7 @@ public class InstitutionContractRepository : RepositoryBase<long, InstitutionCon
public InstitutionContractRepository(CompanyContext context, IEmployerRepository employerRepository,
IWorkshopRepository workshopRepository, IMongoDatabase database,
IPlanPercentageRepository planPercentageRepository, ISmsService smsService, ISmsResultRepository smsResultRepository, IFinancialTransactionRepository financialTransactionRepository,
IFinancialStatmentRepository financialStatmentRepository) : base(context)
IPlanPercentageRepository planPercentageRepository, ISmsService smsService, ISmsResultRepository smsResultRepository, IFinancialTransactionRepository financialTransactionRepository, IFinancialStatmentRepository financialStatmentRepository, IHubContext<SendSmsHub> hubContext) : base(context)
{
_context = context;
_employerRepository = employerRepository;
@@ -89,6 +89,7 @@ public class InstitutionContractRepository : RepositoryBase<long, InstitutionCon
_smsResultRepository = smsResultRepository;
_financialTransactionRepository = financialTransactionRepository;
_financialStatmentRepository = financialStatmentRepository;
_hubContext = hubContext;
_institutionExtensionTemp =
database.GetCollection<InstitutionContractExtensionTemp>("InstitutionContractExtensionTemp");
_institutionAmendmentTemp =
@@ -3919,8 +3920,8 @@ public class InstitutionContractRepository : RepositoryBase<long, InstitutionCon
}
Thread.Sleep(600);
var percent = (successProcess / (double)countList) * 100;
//await _hubContext.Clients.Group(SendSmsHub.GetGroupName(10))
//.SendAsync("showStatus", (int)percent);
await _hubContext.Clients.Group(SendSmsHub.GetGroupName(10))
.SendAsync("showStatus", (int)percent);
successProcess += 1;
}
@@ -3999,8 +4000,8 @@ public class InstitutionContractRepository : RepositoryBase<long, InstitutionCon
}
var percent =(successProcess / (double)countList) * 100;
//await _hubContext.Clients.Group(SendSmsHub.GetGroupName(7))
// .SendAsync("showStatus", (int)percent);
await _hubContext.Clients.Group(SendSmsHub.GetGroupName(7))
.SendAsync("showStatus", (int)percent);
successProcess += 1;