diff --git a/SPMS.Domain/Interfaces/IAdminRepository.cs b/SPMS.Domain/Interfaces/IAdminRepository.cs
new file mode 100644
index 0000000..efe572b
--- /dev/null
+++ b/SPMS.Domain/Interfaces/IAdminRepository.cs
@@ -0,0 +1,10 @@
+using SPMS.Domain.Entities;
+
+namespace SPMS.Domain.Interfaces;
+
+public interface IAdminRepository : IRepository<Admin>
+{
+    Task<Admin?> GetByEmailAsync(string email);
+    Task<Admin?> GetByAdminCodeAsync(string adminCode);
+    Task<bool> EmailExistsAsync(string email, long? excludeId = null);
+}
diff --git a/SPMS.Domain/Interfaces/IDeviceRepository.cs b/SPMS.Domain/Interfaces/IDeviceRepository.cs
new file mode 100644
index 0000000..dfa8a24
--- /dev/null
+++ b/SPMS.Domain/Interfaces/IDeviceRepository.cs
@@ -0,0 +1,11 @@
+using SPMS.Domain.Entities;
+using SPMS.Domain.Enums;
+
+namespace SPMS.Domain.Interfaces;
+
+public interface IDeviceRepository : IRepository<Device>
+{
+    Task<Device?> GetByServiceAndTokenAsync(long serviceId, string deviceToken);
+    Task<int> GetActiveCountByServiceAsync(long serviceId);
+    Task<IReadOnlyList<Device>> GetByPlatformAsync(long serviceId, Platform platform);
+}
diff --git a/SPMS.Domain/Interfaces/IFileRepository.cs b/SPMS.Domain/Interfaces/IFileRepository.cs
new file mode 100644
index 0000000..24d565a
--- /dev/null
+++ b/SPMS.Domain/Interfaces/IFileRepository.cs
@@ -0,0 +1,9 @@
+using SPMS.Domain.Entities;
+
+namespace SPMS.Domain.Interfaces;
+
+public interface IFileRepository : IRepository<FileEntity>
+{
+    Task<FileEntity?> GetByFileNameAsync(long serviceId, string fileName);
+    Task<bool> FileExistsAsync(long serviceId, string fileName);
+}
diff --git a/SPMS.Domain/Interfaces/IMessageRepository.cs b/SPMS.Domain/Interfaces/IMessageRepository.cs
new file mode 100644
index 0000000..39781ae
--- /dev/null
+++ b/SPMS.Domain/Interfaces/IMessageRepository.cs
@@ -0,0 +1,8 @@
+using SPMS.Domain.Entities;
+
+namespace SPMS.Domain.Interfaces;
+
+public interface IMessageRepository : IRepository<Message>
+{
+    Task<Message?> GetByMessageCodeAsync(string messageCode);
+}
diff --git a/SPMS.Domain/Interfaces/IPushLogRepository.cs b/SPMS.Domain/Interfaces/IPushLogRepository.cs
new file mode 100644
index 0000000..b76e021
--- /dev/null
+++ b/SPMS.Domain/Interfaces/IPushLogRepository.cs
@@ -0,0 +1,13 @@
+using SPMS.Domain.Entities;
+using SPMS.Domain.Enums;
+
+namespace SPMS.Domain.Interfaces;
+
+public interface IPushLogRepository : IRepository<PushSendLog>
+{
+    Task<(IReadOnlyList<PushSendLog> Items, int TotalCount)> GetByMessageIdAsync(
+        long messageId, int page, int size, PushResult? status = null);
+    Task<IReadOnlyList<PushSendLog>> GetFailedByMessageIdAsync(long messageId);
+    Task AddBatchAsync(IEnumerable<PushSendLog> logs);
+    Task<int> GetCountByStatusAsync(long serviceId, long messageId, PushResult status);
+}
diff --git a/SPMS.Domain/Interfaces/IRepository.cs b/SPMS.Domain/Interfaces/IRepository.cs
new file mode 100644
index 0000000..6b1797c
--- /dev/null
+++ b/SPMS.Domain/Interfaces/IRepository.cs
@@ -0,0 +1,21 @@
+using System.Linq.Expressions;
+using SPMS.Domain.Entities;
+
+namespace SPMS.Domain.Interfaces;
+
+public interface IRepository<T> where T : BaseEntity
+{
+    Task<T?> GetByIdAsync(long id);
+    Task<IReadOnlyList<T>> GetAllAsync();
+    Task<IReadOnlyList<T>> FindAsync(Expression<Func<T, bool>> predicate);
+    Task<(IReadOnlyList<T> Items, int TotalCount)> GetPagedAsync(
+        int page, int size,
+        Expression<Func<T, bool>>? predicate = null,
+        Expression<Func<T, object>>? orderBy = null,
+        bool descending = true);
+    Task<int> CountAsync(Expression<Func<T, bool>>? predicate = null);
+    Task<bool> ExistsAsync(Expression<Func<T, bool>> predicate);
+    Task AddAsync(T entity);
+    void Update(T entity);
+    void Delete(T entity);
+}
diff --git a/SPMS.Domain/Interfaces/IServiceRepository.cs b/SPMS.Domain/Interfaces/IServiceRepository.cs
new file mode 100644
index 0000000..795dce8
--- /dev/null
+++ b/SPMS.Domain/Interfaces/IServiceRepository.cs
@@ -0,0 +1,12 @@
+using SPMS.Domain.Entities;
+using SPMS.Domain.Enums;
+
+namespace SPMS.Domain.Interfaces;
+
+public interface IServiceRepository : IRepository<Service>
+{
+    Task<Service?> GetByServiceCodeAsync(string serviceCode);
+    Task<Service?> GetByApiKeyAsync(string apiKey);
+    Task<Service?> GetByIdWithIpsAsync(long id);
+    Task<IReadOnlyList<Service>> GetByStatusAsync(ServiceStatus status);
+}
diff --git a/SPMS.Domain/Interfaces/IStatRepository.cs b/SPMS.Domain/Interfaces/IStatRepository.cs
new file mode 100644
index 0000000..df61ec6
--- /dev/null
+++ b/SPMS.Domain/Interfaces/IStatRepository.cs
@@ -0,0 +1,10 @@
+using SPMS.Domain.Entities;
+
+namespace SPMS.Domain.Interfaces;
+
+public interface IStatRepository : IRepository<DailyStat>
+{
+    Task<DailyStat?> GetByServiceAndDateAsync(long serviceId, DateOnly date);
+    Task<IReadOnlyList<DailyStat>> GetByDateRangeAsync(
+        long serviceId, DateOnly startDate, DateOnly endDate);
+}
diff --git a/SPMS.Domain/Interfaces/IUnitOfWork.cs b/SPMS.Domain/Interfaces/IUnitOfWork.cs
new file mode 100644
index 0000000..bd909ca
--- /dev/null
+++ b/SPMS.Domain/Interfaces/IUnitOfWork.cs
@@ -0,0 +1,9 @@
+namespace SPMS.Domain.Interfaces;
+
+public interface IUnitOfWork : IDisposable
+{
+    Task<int> SaveChangesAsync(CancellationToken cancellationToken = default);
+    Task<IDisposable> BeginTransactionAsync(CancellationToken cancellationToken = default);
+    Task CommitTransactionAsync(CancellationToken cancellationToken = default);
+    Task RollbackTransactionAsync(CancellationToken cancellationToken = default);
+}