admin/marco.pms.api
1
0
Fork 0
Code Issues Pull Requests 3 Actions Packages Projects Releases Wiki Activity

Removed commented code from project Cache

Browse Source
This commit is contained in:
ashutosh.nehete 2025-07-17 17:16:16 +05:30
parent 7c8a80addc
commit 5e84ee9345
2 changed files with 10 additions and 41 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

46
Marco.Pms.CacheHelper/ProjectCache.cs
View File

@ -23,6 +23,8 @@ namespace Marco.Pms.CacheHelper
_taskCollection = mongoDB.GetCollection<WorkItemMongoDB>("WorkItemDetails");
}
#region=================================================================== Project Cache Helper ===================================================================
public async Task AddProjectDetailsToCache(ProjectMongoDB projectDetails)
{
await _projectCollection.InsertOneAsync(projectDetails);
@ -36,7 +38,6 @@ namespace Marco.Pms.CacheHelper
await _projectCollection.Indexes.CreateOneAsync(indexModel);
}
// The method should focus only on inserting data.
public async Task AddProjectDetailsListToCache(List<ProjectMongoDB> projectDetailsList)
{
// 1. Add a guard clause to avoid an unnecessary database call for an empty list.
@ -49,7 +50,6 @@ namespace Marco.Pms.CacheHelper
await _projectCollection.InsertManyAsync(projectDetailsList);
await InitializeCollectionAsync();
}
// A private method to handle the one-time setup of the collection's indexes.
private async Task InitializeCollectionAsync()
{
// 1. Define the TTL (Time-To-Live) index on the 'ExpireAt' field.
@ -135,7 +135,9 @@ namespace Marco.Pms.CacheHelper
return result.DeletedCount > 0;
}
// ------------------------------------------------------- Project InfraStructure -------------------------------------------------------
#endregion
#region=================================================================== Project infrastructure Cache Helper ===================================================================
public async Task AddBuildngInfraToCache(Guid projectId, Building? building, Floor? floor, WorkArea? workArea, Guid? buildingId)
{
@ -161,11 +163,8 @@ namespace Marco.Pms.CacheHelper
if (result.MatchedCount == 0)
{
//_logger.LogWarning("Project not found while adding building. ProjectId: {ProjectId}", projectId);
return;
}
//_logger.LogInfo("Building {BuildingId} added to project {ProjectId}", building.Id, projectId);
return;
}
@ -191,11 +190,8 @@ namespace Marco.Pms.CacheHelper
if (result.MatchedCount == 0)
{
//_logger.LogWarning("Project or building not found while adding floor. ProjectId: {ProjectId}, BuildingId: {BuildingId}", projectId, floor.BuildingId);
return;
}
//_logger.LogInfo("Floor {FloorId} added to building {BuildingId} in project {ProjectId}", floor.Id, floor.BuildingId, projectId);
return;
}
@ -225,16 +221,10 @@ namespace Marco.Pms.CacheHelper
if (result.MatchedCount == 0)
{
//_logger.LogWarning("Project or nested structure not found while adding work area. ProjectId: {ProjectId}, BuildingId: {BuildingId}, FloorId: {FloorId}", projectId, buildingId, workArea.FloorId);
return;
}
//_logger.LogInfo("WorkArea {WorkAreaId} added to floor {FloorId} in building {BuildingId}, ProjectId: {ProjectId}", workArea.Id, workArea.FloorId, buildingId, projectId);
return;
}
// Fallback case when no valid data was passed
//_logger.LogWarning("No valid infra data provided to add for ProjectId: {ProjectId}", projectId);
}
public async Task<bool> UpdateBuildngInfraToCache(Guid projectId, Building? building, Floor? floor, WorkArea? workArea, Guid? buildingId)
{
@ -257,11 +247,9 @@ namespace Marco.Pms.CacheHelper
if (result.MatchedCount == 0)
{
//_logger.LogWarning("Update failed: Project or Building not found. ProjectId: {ProjectId}, BuildingId: {BuildingId}", projectId, building.Id);
return false;
}
//_logger.LogInfo("Building {BuildingId} updated successfully in project {ProjectId}", building.Id, projectId);
return true;
}
@ -282,11 +270,8 @@ namespace Marco.Pms.CacheHelper
if (result.MatchedCount == 0)
{
//_logger.LogWarning("Update failed: Project or Floor not found. ProjectId: {ProjectId}, BuildingId: {BuildingId}, FloorId: {FloorId}", projectId, floor.BuildingId, floor.Id);
return false;
}
//_logger.LogInfo("Floor {FloorId} updated successfully in Building {BuildingId}, ProjectId: {ProjectId}", floor.Id, floor.BuildingId, projectId);
return true;
}
@ -308,17 +293,10 @@ namespace Marco.Pms.CacheHelper
if (result.MatchedCount == 0)
{
//_logger.LogWarning("Update failed: Project or WorkArea not found. ProjectId: {ProjectId}, BuildingId: {BuildingId}, FloorId: {FloorId}, WorkAreaId: {WorkAreaId}",
//projectId, buildingId, workArea.FloorId, workArea.Id);
return false;
}
//_logger.LogInfo("WorkArea {WorkAreaId} updated successfully in Floor {FloorId}, Building {BuildingId}, ProjectId: {ProjectId}",
//workArea.Id, workArea.FloorId, buildingId, projectId);
return true;
}
//_logger.LogWarning("No update performed. Missing or invalid data for ProjectId: {ProjectId}", projectId);
return false;
}
public async Task<List<BuildingMongoDB>?> GetBuildingInfraFromCache(Guid projectId)
@ -333,15 +311,6 @@ namespace Marco.Pms.CacheHelper
.Project(p => p.Buildings)
.FirstOrDefaultAsync();
//if (buildings == null)
//{
// _logger.LogWarning("No building infrastructure found for ProjectId: {ProjectId}", projectId);
//}
//else
//{
// _logger.LogInfo("Fetched {Count} buildings for ProjectId: {ProjectId}", buildings.Count, projectId);
//}
return buildings;
}
public async Task UpdatePlannedAndCompleteWorksInBuildingFromCache(Guid workAreaId, double plannedWork, double completedWork)
@ -431,8 +400,9 @@ namespace Marco.Pms.CacheHelper
return result;
}
#endregion
// ------------------------------------------------------- WorkItem -------------------------------------------------------
#region=================================================================== WorkItem Cache Helper ===================================================================
public async Task<List<WorkItemMongoDB>> GetWorkItemsByWorkAreaIdsFromCache(List<Guid> workAreaIds)
{
@ -517,5 +487,7 @@ namespace Marco.Pms.CacheHelper
var result = await _taskCollection.DeleteOneAsync(filter);
return result.DeletedCount > 0;
}
#endregion
}
}

5
Marco.Pms.CacheHelper/ReportCache.cs
View File

@ -1,4 +1,3 @@
using Marco.Pms.DataAccess.Data;
using Marco.Pms.Model.MongoDBModels;
using Microsoft.Extensions.Configuration;
using MongoDB.Driver;
@ -7,12 +6,10 @@ namespace Marco.Pms.CacheHelper
{
public class ReportCache
{
private readonly ApplicationDbContext _context;
private readonly IMongoCollection<ProjectReportEmailMongoDB> _projectReportCollection;
public ReportCache(ApplicationDbContext context, IConfiguration configuration)
public ReportCache(IConfiguration configuration)
{
var connectionString = configuration["MongoDB:ConnectionString"];
_context = context;
var mongoUrl = new MongoUrl(connectionString);
var client = new MongoClient(mongoUrl); // Your MongoDB connection string
var mongoDB = client.GetDatabase(mongoUrl.DatabaseName); // Your MongoDB Database name