Skip to content

Commit

Permalink
feat: temp deploy version
Browse files Browse the repository at this point in the history
  • Loading branch information
ohksj77 committed Oct 3, 2024
1 parent 21e5420 commit 49addc2
Show file tree
Hide file tree
Showing 3 changed files with 24 additions and 19 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -7,13 +7,16 @@
import com.dragonguard.backend.domain.member.entity.Member;
import com.querydsl.jpa.JPAExpressions;
import com.querydsl.jpa.impl.JPAQueryFactory;
import java.util.List;
import java.util.Optional;
import java.util.UUID;

import lombok.RequiredArgsConstructor;

import org.springframework.data.domain.Pageable;
import org.springframework.stereotype.Repository;

import java.util.List;
import java.util.Optional;
import java.util.UUID;

/**
* @author 김승진
* @description 멤버 DB 조회 접근에 대한 구현체
Expand All @@ -31,7 +34,6 @@ public List<MemberRankResponse> findRanking(final Pageable pageable) {
return jpaQueryFactory
.select(qDtoFactory.qMemberRankResponse())
.from(member)
.where(member.walletAddress.isNotNull())
.offset(pageable.getOffset())
.limit(pageable.getPageSize())
.orderBy(memberOrderConverter.convert(pageable.getSort()))
Expand All @@ -43,13 +45,20 @@ public Integer findRankingById(final UUID id) {
return jpaQueryFactory
.selectFrom(member)
.where(
member.walletAddress
.isNotNull()
.and(
member.sumOfTokens.gt(
JPAExpressions.select(member.sumOfTokens)
.from(member)
.where(member.id.eq(id)))))
member.sumOfCommits
.add(member.sumOfCodeReviews)
.add(member.sumOfIssues)
.add(member.sumOfPullRequests)
.gt(
JPAExpressions.select(
member.sumOfCommits
.add(
member.sumOfCodeReviews)
.add(member.sumOfIssues)
.add(
member.sumOfPullRequests))
.from(member)
.where(member.id.eq(id))))
.fetch()
.size()
+ 1;
Expand All @@ -62,9 +71,9 @@ public List<MemberRankResponse> findRankingByOrganization(
.select(qDtoFactory.qMemberRankResponse())
.from(member)
.where(
member.walletAddress
.isNotNull()
.and(member.organization.id.eq(organizationId))
member.organization
.id
.eq(organizationId)
.and(member.authStep.eq(AuthStep.ALL)))
.offset(pageable.getOffset())
.limit(pageable.getPageSize())
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -109,9 +109,7 @@ private MemberResponse getMemberResponse(final Member member) {

@Transactional(readOnly = true)
public List<MemberRankResponse> findMemberRanking(final Pageable pageable) {
final int pageSize = pageable.getPageSize();
final int offset = pageable.getPageNumber() * pageSize;
return redisRankingUtils.getTopUsers(offset, offset + pageSize);
return memberRepository.findRanking(pageable);
}

public void updateWalletAddress(final WalletRequest walletRequest) {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -39,11 +39,9 @@ public void saveContribution(

if (existsByMemberAndYear(member, year)) {
updateAndSendTransaction(member, contributionNum, year, blockchain, contributeType);
redisRankingUtils.addUserScore(member);
return;
}
contributionRepository.save(commitMapper.toEntity(member, contributionNum, year));
redisRankingUtils.addUserScore(member);
sendTransaction(member, contributionNum.longValue(), blockchain, contributeType);
}

Expand Down

0 comments on commit 49addc2

Please sign in to comment.