80 lines
3.2 KiB
C#
80 lines
3.2 KiB
C#
namespace TaxBaik.Infrastructure.Repositories;
|
|
|
|
using Dapper;
|
|
using TaxBaik.Domain.Entities;
|
|
using TaxBaik.Domain.Interfaces;
|
|
|
|
public class InquiryRepository(IDbConnectionFactory connectionFactory) : BaseRepository(connectionFactory), IInquiryRepository
|
|
{
|
|
public async Task<int> CreateAsync(Inquiry inquiry, CancellationToken cancellationToken = default)
|
|
{
|
|
using var conn = Conn();
|
|
return await conn.QueryFirstAsync<int>(
|
|
@"INSERT INTO inquiries (name, phone, email, service_type, message, status, ip_address, created_at)
|
|
VALUES (@Name, @Phone, @Email, @ServiceType, @Message, @Status, @IpAddress, NOW())
|
|
RETURNING id",
|
|
inquiry);
|
|
}
|
|
|
|
public async Task<Inquiry?> GetByIdAsync(int id, CancellationToken cancellationToken = default)
|
|
{
|
|
using var conn = Conn();
|
|
return await conn.QueryFirstOrDefaultAsync<Inquiry>(
|
|
"SELECT id, name, phone, email, service_type, message, status, ip_address, created_at FROM inquiries WHERE id = @Id",
|
|
new { Id = id });
|
|
}
|
|
|
|
public async Task<(IEnumerable<Inquiry> Items, int Total)> GetPagedAsync(
|
|
int page, int pageSize, string? status = null, CancellationToken cancellationToken = default)
|
|
{
|
|
using var conn = Conn();
|
|
var offset = (page - 1) * pageSize;
|
|
|
|
using var reader = await conn.QueryMultipleAsync(
|
|
@"SELECT id, name, phone, email, service_type, message, status, ip_address, created_at
|
|
FROM inquiries
|
|
WHERE @Status::text IS NULL OR status = @Status
|
|
ORDER BY created_at DESC
|
|
LIMIT @PageSize OFFSET @Offset;
|
|
|
|
SELECT COUNT(*) FROM inquiries
|
|
WHERE @Status::text IS NULL OR status = @Status;",
|
|
new { Status = status, PageSize = pageSize, Offset = offset });
|
|
|
|
var items = (await reader.ReadAsync<Inquiry>()).ToList();
|
|
var total = await reader.ReadFirstAsync<int>();
|
|
|
|
return (items, total);
|
|
}
|
|
|
|
public async Task<int> CountAsync(CancellationToken cancellationToken = default)
|
|
{
|
|
using var conn = Conn();
|
|
return await conn.ExecuteScalarAsync<int>("SELECT COUNT(*) FROM inquiries");
|
|
}
|
|
|
|
public async Task<int> CountThisMonthAsync(CancellationToken cancellationToken = default)
|
|
{
|
|
using var conn = Conn();
|
|
return await conn.ExecuteScalarAsync<int>(
|
|
@"SELECT COUNT(*)
|
|
FROM inquiries
|
|
WHERE created_at >= date_trunc('month', NOW())
|
|
AND created_at < date_trunc('month', NOW()) + INTERVAL '1 month'");
|
|
}
|
|
|
|
public async Task<int> CountByStatusAsync(string status, CancellationToken cancellationToken = default)
|
|
{
|
|
using var conn = Conn();
|
|
return await conn.ExecuteScalarAsync<int>(
|
|
"SELECT COUNT(*) FROM inquiries WHERE status = @Status",
|
|
new { Status = status });
|
|
}
|
|
|
|
public async Task UpdateStatusAsync(int id, string status, CancellationToken cancellationToken = default)
|
|
{
|
|
using var conn = Conn();
|
|
await conn.ExecuteAsync("UPDATE inquiries SET status = @Status WHERE id = @Id", new { Id = id, Status = status });
|
|
}
|
|
}
|