scriptoriumadmin/skillhub
1
0
Fork 0
mirror of https://github.com/iflytek/skillhub.git synced 2026-08-28 11:25:00 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 3

feat(subscription): add increment/decrement subscription count methods

Browse source
This commit is contained in:
dongmucat 2026-04-27 16:46:34 +08:00
parent 79f1aa4db1
commit 9d4422cd6c
3 changed files with 22 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
server/skillhub-domain/src/main/java/com/iflytek/skillhub/domain/skill/SkillRepository.java
View file

@ -22,6 +22,8 @@ public interface SkillRepository {
List<Skill> findByOwnerId(String ownerId);
Page<Skill> findByOwnerId(String ownerId, Pageable pageable);
void incrementDownloadCount(Long skillId);
void incrementSubscriptionCount(Long skillId);
void decrementSubscriptionCount(Long skillId);
List<Skill> findBySlug(String slug);
List<Skill> findByNamespaceSlugAndSlug(String namespaceSlug, String slug);
}

10
server/skillhub-infra/src/main/java/com/iflytek/skillhub/infra/jpa/JpaSkillRepositoryAdapter.java
View file

@ -87,6 +87,16 @@ public class JpaSkillRepositoryAdapter implements SkillRepository {
delegate.incrementDownloadCount(skillId);
}
@Override
public void incrementSubscriptionCount(Long skillId) {
delegate.incrementSubscriptionCount(skillId);
}
@Override
public void decrementSubscriptionCount(Long skillId) {
delegate.decrementSubscriptionCount(skillId);
}
@Override
public List<Skill> findBySlug(String slug) {
return delegate.findBySlug(slug);

10
server/skillhub-infra/src/main/java/com/iflytek/skillhub/infra/jpa/SkillJpaRepository.java
View file

@ -44,6 +44,16 @@ public interface SkillJpaRepository extends JpaRepository<Skill, Long>, SkillRep
@Query("UPDATE Skill s SET s.downloadCount = s.downloadCount + 1 WHERE s.id = :skillId")
void incrementDownloadCount(@Param("skillId") Long skillId);
@Modifying
@Transactional
@Query("UPDATE Skill s SET s.subscriptionCount = s.subscriptionCount + 1 WHERE s.id = :skillId")
void incrementSubscriptionCount(@Param("skillId") Long skillId);
@Modifying
@Transactional
@Query("UPDATE Skill s SET s.subscriptionCount = CASE WHEN s.subscriptionCount > 0 THEN s.subscriptionCount - 1 ELSE 0 END WHERE s.id = :skillId")
void decrementSubscriptionCount(@Param("skillId") Long skillId);
List<Skill> findBySlug(String slug);
@Query("SELECT s FROM Skill s JOIN Namespace n ON s.namespaceId = n.id WHERE n.slug = :namespaceSlug AND s.slug = :slug")