ifritechnologies/pfm
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Added budget update

Browse Source 
Added portfolio and programme value calculator endpoints
This commit is contained in:
hermes
2026-09-26 15:14:29 +02:00
parent 6be74e9a24
commit ed6e57ffa9
16 changed files with 2729 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
PostFundManagement.Application/Services/Governance/GovernanceCacheService.cs
+52
View File
@@ -355,4 +355,56 @@ public sealed class GovernanceCacheService(GovernanceService service, IDistribut
return Result.Ok(cached.FromJson<Portfolio[]>());
}));
public async Task<Result<decimal>> GetProgrammeValueAsync(string programmeIdHash, CancellationToken cancellationToken = default) =>
await Result.Try((Func<Task<Result<decimal>>>)(async () =>
{
if (!await featureManager.IsEnabledAsync(ServiceCachingFeature))
return await service.GetProgrammeValueAsync(programmeIdHash, cancellationToken);
var cacheKey = HashService.ToMd5Hash($"getprogrammevalue-{programmeIdHash}").Value;
var cached = await cache.GetStringAsync(cacheKey, cancellationToken);
if (string.IsNullOrWhiteSpace(cached))
{
var result = await service.GetProgrammeValueAsync(programmeIdHash, cancellationToken);
if (result.IsFailed) return result;
await cache.SetStringAsync(cacheKey, result.Value.ToString(), cacheOptions, cancellationToken);
return result.Value;
}
decimal.TryParse(cached, CultureInfo.InvariantCulture, out var value);
return Result.Ok(value);
}));
public async Task<Result<decimal>> GetPorfolioValueAsync(string portfolioIdHash, CancellationToken cancellationToken = default) =>
await Result.Try((Func<Task<Result<decimal>>>)(async () =>
{
if (!await featureManager.IsEnabledAsync(ServiceCachingFeature))
return await service.GetPorfolioValueAsync(portfolioIdHash, cancellationToken);
var cacheKey = HashService.ToMd5Hash($"getportfoliovalue-{portfolioIdHash}").Value;
var cached = await cache.GetStringAsync(cacheKey, cancellationToken);
if (string.IsNullOrWhiteSpace(cached))
{
var result = await service.GetPorfolioValueAsync(portfolioIdHash, cancellationToken);
if (result.IsFailed) return result;
await cache.SetStringAsync(cacheKey, result.Value.ToString(), cacheOptions, cancellationToken);
return result.Value;
}
decimal.TryParse(cached, CultureInfo.InvariantCulture, out var value);
return Result.Ok(value);
}));
}
PostFundManagement.Application/Services/Governance/GovernanceService.cs
+42
View File
@@ -485,4 +485,46 @@ public sealed class GovernanceService(IDbContextFactory<ApplicationDbContext> co
return Result.Ok(portfolios.Select(p => p.Map()).ToArray());
}));
public async Task<Result<decimal>> GetProgrammeValueAsync(string programmeIdHash, CancellationToken cancellationToken = default) =>
await Result.Try((Func<Task<Result<decimal>>>)(async () =>
{
var decodeResult = hashService.DecodeLongIdHash(programmeIdHash);
if (decodeResult.IsFailed)
return Result.Fail(IdDecodeError.Create()
.CausedBy(decodeResult.Errors));
await using var context = await contextFactory.CreateDbContextAsync(cancellationToken);
var value = await context.Budgets.AsNoTracking()
.Include(i => i.Project!.Programme)
.Where(v => v.Project!.Programme!.Id == decodeResult.Value &&
v.Project.Programme.Status == ApprovalStatus.Approved &&
v.Status == ApprovalStatus.Approved)
.SumAsync(v => v.Amount, cancellationToken);
return Result.Ok(value);
}));
public async Task<Result<decimal>> GetPorfolioValueAsync(string portfolioIdHash, CancellationToken cancellationToken = default) =>
await Result.Try((Func<Task<Result<decimal>>>)(async () =>
{
var decodeResult = hashService.DecodeLongIdHash(portfolioIdHash);
if (decodeResult.IsFailed)
return Result.Fail(IdDecodeError.Create()
.CausedBy(decodeResult.Errors));
await using var context = await contextFactory.CreateDbContextAsync(cancellationToken);
var value = await context.Budgets
.Include(i => i.Project!.Programme!.Portfolio)
.Where(v => v.Project!.Programme!.Portfolio!.Id == decodeResult.Value &&
v.Project.Programme.Status == ApprovalStatus.Approved &&
v.Status == ApprovalStatus.Approved)
.SumAsync(v => v.Amount, cancellationToken);
return Result.Ok(value);
}));
}