Feature_Directory #90

Merged
vikas.nale merged 501 commits from Feature_Directory into main 2025-06-10 14:44:36 +00:00
3 changed files with 67 additions and 2 deletions
Showing only changes of commit 49ddd3ec45 - Show all commits

View File

@ -2,7 +2,7 @@
{
public class CreateBucketDto
{
public string name { get; set; } = string.Empty;
public string description { get; set; } = string.Empty;
public string Name { get; set; } = string.Empty;
public string Description { get; set; } = string.Empty;
}
}

View File

@ -89,5 +89,33 @@ namespace Marco.Pms.Services.Controllers
var response = await _directoryHelper.GetBucketList();
return Ok(response);
}
[HttpPost("bucket")]
public async Task<IActionResult> CreateBucket(CreateBucketDto bucketDto)
{
if (!ModelState.IsValid)
{
var errors = ModelState.Values
.SelectMany(v => v.Errors)
.Select(e => e.ErrorMessage)
.ToList();
_logger.LogError("User sent Invalid Date while marking attendance");
return BadRequest(ApiResponse<object>.ErrorResponse("Invalid data", errors, 400));
}
var response = await _directoryHelper.CreateBucket(bucketDto);
if (response.StatusCode == 200)
{
return Ok(response);
}
else if (response.StatusCode == 409)
{
return Conflict(response);
}
else
{
return BadRequest(response);
}
}
}
}

View File

@ -455,5 +455,42 @@ namespace Marco.Pms.Services.Helpers
_logger.LogInfo("{count} Buckets are fetched by Employee with ID {LoggedInEmployeeId}", bucketVMs.Count, LoggedInEmployee.Id);
return ApiResponse<object>.SuccessResponse(bucketVMs, System.String.Format("{0} buckets fetched successfully", bucketVMs.Count), 200);
}
public async Task<ApiResponse<object>> CreateBucket(CreateBucketDto bucketDto)
{
Guid tenantId = _userHelper.GetTenantId();
var LoggedInEmployee = await _userHelper.GetCurrentEmployeeAsync();
if (bucketDto != null)
{
var existingBucket = await _context.Buckets.FirstOrDefaultAsync(b => b.Name == bucketDto.Name);
if (existingBucket != null)
{
_logger.LogWarning("Employee ID {LoggedInEmployeeId} attempted to create an existing bucket.", LoggedInEmployee.Id);
return ApiResponse<object>.ErrorResponse("Bucket already existed", "Bucket already existed", 409);
}
Bucket bucket = new Bucket
{
Name = bucketDto.Name,
Description = bucketDto.Description,
TenantId = tenantId
};
_context.Buckets.Add(bucket);
EmployeeBucketMapping employeeBucket = new EmployeeBucketMapping
{
EmployeeId = LoggedInEmployee.Id,
BucketId = bucket.Id
};
_context.EmployeeBucketMappings.Add(employeeBucket);
await _context.SaveChangesAsync();
BucketVM bucketVM = bucket.ToBucketVMFromBucket();
_logger.LogInfo("Employee Id {LoggedInEmployeeId} creayted new bucket {BucketId}", LoggedInEmployee.Id, bucket.Id);
return ApiResponse<object>.SuccessResponse(bucketVM, "Bucket Created SuccessFully", 200);
}
_logger.LogWarning("Employee with ID {LoggedInEmployeeId} sended empty payload", LoggedInEmployee.Id);
return ApiResponse<object>.ErrorResponse("User Send empty Payload", "User Send empty Payload", 400);
}
}
}