292 lines
13 KiB
C#
292 lines
13 KiB
C#
using CPRNIMS.Domain.Contracts.Inventory;
|
|
using CPRNIMS.Infrastructure.Database;
|
|
using CPRNIMS.Infrastructure.Dto.Inventory.Reports;
|
|
using Microsoft.Data.SqlClient;
|
|
using Microsoft.EntityFrameworkCore;
|
|
|
|
namespace CPRNIMS.Domain.Services.Inventory
|
|
{
|
|
public class InventoryReports : IInventoryReports
|
|
{
|
|
private readonly NonInventoryDbContext _db;
|
|
public InventoryReports(NonInventoryDbContext db) => _db = db;
|
|
|
|
public async Task<RISReportDto> GetRISReportAsync(DateTime dateFrom, DateTime dateTo, CancellationToken ct,
|
|
int? departmentId = null, string? userName = "")
|
|
{
|
|
var endDate = dateTo.Date.AddDays(1);
|
|
|
|
var allowedAllDeptUsers = new[] { "LSKRISUR24", "LSCYNDIZ25", "LSJONTAN25", "LHRIOCAS24" };
|
|
bool seeAllDepartments = !string.IsNullOrWhiteSpace(userName)
|
|
&& allowedAllDeptUsers.Contains(userName, StringComparer.OrdinalIgnoreCase);
|
|
|
|
var dateToInclusive = dateTo.AddDays(1);
|
|
|
|
var query = _db.RIS
|
|
.Include(r => r.Discipline)
|
|
.Include(r => r.Inventory)
|
|
.Include(r => r.MaterialReturns)
|
|
.Where(r => r.CreatedDate >= dateFrom && r.CreatedDate < dateToInclusive);
|
|
|
|
if (departmentId.HasValue && !seeAllDepartments)
|
|
{
|
|
query = query.Where(m =>
|
|
m.Inventory.User != null &&
|
|
m.Inventory.User.DepartmentId == departmentId.Value);
|
|
}
|
|
|
|
var rows = await query
|
|
.OrderByDescending(r => r.CreatedDate)
|
|
.Select(r => new RISReportRow
|
|
{
|
|
RISNo = r.RISNo,
|
|
CreatedDate = r.CreatedDate,
|
|
ItemName = r.PRDetail != null ? r.PRDetail.ItemName : "—",
|
|
ItemNo = r.Inventory.ItemNo,
|
|
DisciplineName = r.Discipline.DisciplineName,
|
|
ProjectName = r.ProjectCodes.ProjectName,
|
|
QtyIssued = r.QtyIssued,
|
|
TotalReturned = r.MaterialReturns
|
|
.Where(m => m.Status != 2)
|
|
.Sum(m => (int?)m.QtyReturned) ?? 0,
|
|
Status = r.Status,
|
|
StatusLabel = r.Status == 0 ? "Draft"
|
|
: r.Status == 1 ? "Approved"
|
|
: "Cancelled"
|
|
})
|
|
.ToListAsync(ct);
|
|
|
|
foreach (var row in rows)
|
|
row.NetIssued = row.QtyIssued - row.TotalReturned;
|
|
|
|
var summary = new RISReportSummary
|
|
{
|
|
TotalRIS = rows.Count,
|
|
TotalApproved = rows.Count(r => r.Status == 1),
|
|
TotalPending = rows.Count(r => r.Status == 0),
|
|
TotalCancelled = rows.Count(r => r.Status == 2),
|
|
TotalQtyIssued = rows.Sum(r => r.QtyIssued),
|
|
TotalQtyReturned = rows.Sum(r => r.TotalReturned),
|
|
TotalNetIssued = rows.Sum(r => r.NetIssued),
|
|
ApprovalRatePct = rows.Count > 0
|
|
? Math.Round(rows.Count(r => r.Status == 1) * 100m / rows.Count, 1)
|
|
: 0
|
|
};
|
|
|
|
var byDiscipline = rows
|
|
.GroupBy(r => r.DisciplineName)
|
|
.Select(g => new DisciplineCount { DisciplineName = g.Key, Count = g.Count() })
|
|
.OrderByDescending(d => d.Count)
|
|
.ToList();
|
|
|
|
var topRecipients = rows
|
|
.GroupBy(r => r.ProjectName)
|
|
.Select(g => new TopRecipient
|
|
{
|
|
IssuedTo = g.Key,
|
|
SlipCount = g.Count(),
|
|
TotalQty = g.Sum(r => r.QtyIssued)
|
|
})
|
|
.OrderByDescending(t => t.TotalQty)
|
|
.Take(5)
|
|
.ToList();
|
|
|
|
return new RISReportDto
|
|
{
|
|
ReportNo = $"RPT-RIS-{DateTime.Now:yyyyMM}-{Random.Shared.Next(1, 999):D3}",
|
|
DateFrom = dateFrom,
|
|
DateTo = dateTo,
|
|
Summary = summary,
|
|
Rows = rows,
|
|
ByDiscipline = byDiscipline,
|
|
TopRecipients = topRecipients
|
|
};
|
|
}
|
|
|
|
public async Task<MRSReportDto> GetMRSReportAsync(DateTime dateFrom, DateTime dateTo, CancellationToken ct,
|
|
int? departmentId = null, string? userName = "")
|
|
{
|
|
var endDate = dateTo.Date.AddDays(1);
|
|
|
|
var allowedAllDeptUsers = new[] { "LSKRISUR24", "LSCYNDIZ25", "LSJONTAN25", "LHRIOCAS24" };
|
|
bool seeAllDepartments = !string.IsNullOrWhiteSpace(userName)
|
|
&& allowedAllDeptUsers.Contains(userName, StringComparer.OrdinalIgnoreCase);
|
|
|
|
var query = _db.MRS
|
|
.Include(m => m.RIS)
|
|
.Include(m => m.Inventory)
|
|
.ThenInclude(i => i.User)
|
|
.Where(m => m.CreatedDate >= dateFrom &&
|
|
m.CreatedDate < endDate);
|
|
|
|
if (departmentId.HasValue && !seeAllDepartments)
|
|
{
|
|
query = query.Where(m =>
|
|
m.Inventory.User != null &&
|
|
m.Inventory.User.DepartmentId == departmentId.Value);
|
|
}
|
|
|
|
var rows = await query
|
|
.OrderByDescending(m => m.CreatedDate)
|
|
.Select(m => new MRSReportRow
|
|
{
|
|
MRSNo = m.MRSNo,
|
|
CreatedDate = m.CreatedDate,
|
|
RISNo = m.RIS.RISNo,
|
|
ItemName = m.RIS.PRDetail != null ? m.RIS.PRDetail.ItemName : "—",
|
|
ReturnedBy = m.ReturnedBy,
|
|
QtyReturned = m.QtyReturned,
|
|
Condition = m.Condition ?? "Good",
|
|
Status = m.Status,
|
|
StatusLabel = m.Status == 0 ? "Draft"
|
|
: m.Status == 1 ? "Approved"
|
|
: "Cancelled"
|
|
})
|
|
.ToListAsync(ct);
|
|
|
|
// Total RIS qty issued in the same period (for the comparison panel)
|
|
var totalRISQty = await _db.RIS
|
|
.Where(r => r.CreatedDate >= dateFrom && r.CreatedDate < endDate
|
|
&& r.Status != 2)
|
|
.SumAsync(r => (int?)r.QtyIssued, ct) ?? 0;
|
|
|
|
var totalReturned = rows.Where(r => r.Status != 2).Sum(r => r.QtyReturned);
|
|
var goodCount = rows.Count(r => r.Condition == "Good");
|
|
|
|
var summary = new MRSReportSummary
|
|
{
|
|
TotalMRS = rows.Count,
|
|
TotalQtyReturned = totalReturned,
|
|
TotalQtyIssuedRIS = totalRISQty,
|
|
NetQtyConsumed = totalRISQty - totalReturned,
|
|
ReturnRatePct = totalRISQty > 0
|
|
? Math.Round(totalReturned * 100m / totalRISQty, 1)
|
|
: 0,
|
|
GoodConditionPct = rows.Count > 0
|
|
? Math.Round(goodCount * 100m / rows.Count, 1)
|
|
: 0
|
|
};
|
|
|
|
var byCondition = rows
|
|
.Where(r => r.Status != 2)
|
|
.GroupBy(r => r.Condition)
|
|
.Select(g => new ConditionTotal { Condition = g.Key, TotalQty = g.Sum(r => r.QtyReturned) })
|
|
.OrderByDescending(c => c.TotalQty)
|
|
.ToList();
|
|
|
|
return new MRSReportDto
|
|
{
|
|
ReportNo = $"RPT-MRS-{DateTime.Now:yyyyMM}-{Random.Shared.Next(1, 999):D3}",
|
|
DateFrom = dateFrom,
|
|
DateTo = dateTo,
|
|
Summary = summary,
|
|
Rows = rows,
|
|
ByCondition = byCondition
|
|
};
|
|
}
|
|
|
|
public async Task<InventoryReportDto> GetInventoryReportAsync(DateTime dateFrom, DateTime dateTo, CancellationToken ct,
|
|
int? departmentId = null, string? userName = "")
|
|
{
|
|
var allowedAllDeptUsers = new[] { "LSKRISUR24", "LSCYNDIZ25", "LSJONTAN25", "LHRIOCAS24" };
|
|
bool seeAllDepartments = !string.IsNullOrWhiteSpace(userName)
|
|
&& allowedAllDeptUsers.Contains(userName, StringComparer.OrdinalIgnoreCase);
|
|
|
|
var dto = new InventoryReportDto
|
|
{
|
|
ReportNo = $"RPT-INV-{DateTime.Now:yyyyMM}-{Random.Shared.Next(1, 999):D3}",
|
|
AsOf = dateTo.Date,
|
|
Rows = new List<InventoryReportRow>(),
|
|
ByCategory = new List<CategoryStockLevel>(),
|
|
Alerts = new List<InventoryAlert>(),
|
|
Summary = new InventoryReportSummary()
|
|
};
|
|
|
|
var conn = _db.Database.GetDbConnection();
|
|
await using var cmd = conn.CreateCommand();
|
|
cmd.CommandText = "dbo.GetInventoryReport";
|
|
cmd.CommandType = System.Data.CommandType.StoredProcedure;
|
|
|
|
cmd.Parameters.Add(new SqlParameter("@DateFrom", dateFrom));
|
|
cmd.Parameters.Add(new SqlParameter("@DateTo", dateTo));
|
|
cmd.Parameters.Add(new SqlParameter("@DepartmentId", (object?)departmentId ?? DBNull.Value));
|
|
cmd.Parameters.Add(new SqlParameter("@SeeAllDepartments", seeAllDepartments ? 1 : 0));
|
|
|
|
if (conn.State != System.Data.ConnectionState.Open)
|
|
await conn.OpenAsync(ct);
|
|
|
|
try
|
|
{
|
|
await using var reader = await cmd.ExecuteReaderAsync(ct);
|
|
|
|
// 1: detail rows
|
|
while (await reader.ReadAsync(ct))
|
|
{
|
|
dto.Rows.Add(new InventoryReportRow
|
|
{
|
|
ItemName = reader.GetString(reader.GetOrdinal("ItemName")),
|
|
ItemNo = reader.GetInt64(reader.GetOrdinal("ItemNo")),
|
|
ItemCategoryName = reader.GetString(reader.GetOrdinal("ItemCategoryName")),
|
|
LotNo = reader.IsDBNull(reader.GetOrdinal("LotNo"))
|
|
? null : reader.GetString(reader.GetOrdinal("LotNo")),
|
|
QtyIn = reader.GetDecimal(reader.GetOrdinal("QtyIn")),
|
|
QtyOut = reader.GetDecimal(reader.GetOrdinal("QtyOut")),
|
|
QtyOnHand = reader.GetDecimal(reader.GetOrdinal("QtyOnHand")),
|
|
UnitPrice = reader.GetDecimal(reader.GetOrdinal("UnitPrice")),
|
|
StockPct = reader.GetInt32(reader.GetOrdinal("StockPct"))
|
|
});
|
|
}
|
|
|
|
// 2: summary
|
|
if (await reader.NextResultAsync(ct) && await reader.ReadAsync(ct))
|
|
{
|
|
dto.Summary = new InventoryReportSummary
|
|
{
|
|
TotalSKUs = reader.GetInt32(reader.GetOrdinal("TotalSKUs")),
|
|
TotalOnHand = reader.GetDecimal(reader.GetOrdinal("TotalOnHand")),
|
|
TotalQtyIn = reader.GetDecimal(reader.GetOrdinal("TotalQtyIn")),
|
|
TotalQtyOut = reader.GetDecimal(reader.GetOrdinal("TotalQtyOut")),
|
|
TotalValue = reader.GetDecimal(reader.GetOrdinal("TotalValue")),
|
|
LowStockCount = reader.GetInt32(reader.GetOrdinal("LowStockCount")),
|
|
OutOfStockCount = reader.GetInt32(reader.GetOrdinal("OutOfStockCount"))
|
|
};
|
|
}
|
|
|
|
// 3: by category
|
|
if (await reader.NextResultAsync(ct))
|
|
{
|
|
while (await reader.ReadAsync(ct))
|
|
{
|
|
dto.ByCategory.Add(new CategoryStockLevel
|
|
{
|
|
CategoryName = reader.GetString(reader.GetOrdinal("CategoryName")),
|
|
AvgStockPct = reader.GetInt32(reader.GetOrdinal("AvgStockPct"))
|
|
});
|
|
}
|
|
}
|
|
|
|
// 4: alerts
|
|
if (await reader.NextResultAsync(ct))
|
|
{
|
|
while (await reader.ReadAsync(ct))
|
|
{
|
|
dto.Alerts.Add(new InventoryAlert
|
|
{
|
|
ItemName = reader.GetString(reader.GetOrdinal("ItemName")),
|
|
QtyOnHand = reader.GetDecimal(reader.GetOrdinal("QtyOnHand")),
|
|
Severity = reader.GetString(reader.GetOrdinal("Severity"))
|
|
});
|
|
}
|
|
}
|
|
}
|
|
finally
|
|
{
|
|
if (conn.State == System.Data.ConnectionState.Open)
|
|
await conn.CloseAsync();
|
|
}
|
|
|
|
return dto;
|
|
}
|
|
}
|
|
}
|