diff --git a/novalon-manage-api/manage-sys/src/main/java/cn/novalon/manage/sys/infrastructure/db/dao/SysNoticeDao.java b/novalon-manage-api/manage-sys/src/main/java/cn/novalon/manage/sys/infrastructure/db/dao/SysNoticeDao.java index 3a9771c..47ab7b4 100644 --- a/novalon-manage-api/manage-sys/src/main/java/cn/novalon/manage/sys/infrastructure/db/dao/SysNoticeDao.java +++ b/novalon-manage-api/manage-sys/src/main/java/cn/novalon/manage/sys/infrastructure/db/dao/SysNoticeDao.java @@ -1,6 +1,7 @@ package cn.novalon.manage.sys.infrastructure.db.dao; import cn.novalon.manage.sys.infrastructure.db.entity.SysNoticeEntity; +import org.springframework.data.domain.Sort; import org.springframework.data.r2dbc.repository.R2dbcRepository; import org.springframework.stereotype.Repository; import reactor.core.publisher.Flux; @@ -11,7 +12,13 @@ public interface SysNoticeDao extends R2dbcRepository { Flux findByStatusAndDeletedAtIsNull(String status); + Flux findByStatusAndDeletedAtIsNull(String status, Sort sort); + Flux findByDeletedAtIsNull(); + Flux findByDeletedAtIsNull(Sort sort); + + Mono countByDeletedAtIsNull(); + Mono deleteByIdAndDeletedAtIsNull(Long id); } diff --git a/novalon-manage-api/manage-sys/src/main/java/cn/novalon/manage/sys/infrastructure/db/repository/SysNoticeRepository.java b/novalon-manage-api/manage-sys/src/main/java/cn/novalon/manage/sys/infrastructure/db/repository/SysNoticeRepository.java new file mode 100644 index 0000000..3e18aa0 --- /dev/null +++ b/novalon-manage-api/manage-sys/src/main/java/cn/novalon/manage/sys/infrastructure/db/repository/SysNoticeRepository.java @@ -0,0 +1,86 @@ +package cn.novalon.manage.sys.infrastructure.db.repository; + +import cn.novalon.manage.sys.core.domain.SysNotice; +import cn.novalon.manage.sys.infrastructure.db.converter.SysNoticeConverter; +import cn.novalon.manage.sys.infrastructure.db.dao.SysNoticeDao; +import cn.novalon.manage.sys.infrastructure.db.entity.SysNoticeEntity; +import org.springframework.data.domain.Sort; +import org.springframework.stereotype.Repository; +import reactor.core.publisher.Flux; +import reactor.core.publisher.Mono; + +import java.time.LocalDateTime; + +@Repository +public class SysNoticeRepository { + + private final SysNoticeDao dao; + private final SysNoticeConverter converter; + + public SysNoticeRepository(SysNoticeDao dao, SysNoticeConverter converter) { + this.dao = dao; + this.converter = converter; + } + + public Mono findById(Long id) { + return dao.findById(id) + .filter(entity -> entity.getDeletedAt() == null) + .map(converter::toDomain); + } + + public Mono save(SysNotice sysNotice) { + return dao.save(converter.toEntity(sysNotice)) + .map(converter::toDomain); + } + + public Mono deleteById(Long id) { + return dao.findById(id) + .flatMap(entity -> { + entity.setDeletedAt(LocalDateTime.now()); + return dao.save(entity); + }) + .then(); + } + + public Flux findByStatus(String status) { + return dao.findByStatusAndDeletedAtIsNull(status) + .map(converter::toDomain); + } + + public Flux findByStatus(String status, Sort sort) { + return dao.findByStatusAndDeletedAtIsNull(status, sort) + .map(converter::toDomain); + } + + public Flux findAll() { + return dao.findByDeletedAtIsNull() + .map(converter::toDomain); + } + + public Flux findAll(Sort sort) { + return dao.findByDeletedAtIsNull(sort) + .map(converter::toDomain); + } + + public Mono count() { + return dao.countByDeletedAtIsNull(); + } + + public Mono logicalDeleteById(Long id) { + return dao.findById(id) + .flatMap(entity -> { + entity.setDeletedAt(LocalDateTime.now()); + return dao.save(entity); + }) + .then(); + } + + public Mono restoreById(Long id) { + return dao.findById(id) + .flatMap(entity -> { + entity.setDeletedAt(null); + return dao.save(entity); + }) + .then(); + } +}