Compare commits
5
Commits
NCBACK-36_1
..
NC_YA
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
4ee7e439c0 | ||
|
|
503463e1d0 | ||
|
|
5f61c82dee | ||
|
|
2139ca0e8c | ||
|
|
01332c7db5 |
@@ -63,8 +63,6 @@ dependencies {
|
|||||||
|
|
||||||
implementation group: 'com.squareup.okhttp3', name: 'okhttp', version: '4.12.0'
|
implementation group: 'com.squareup.okhttp3', name: 'okhttp', version: '4.12.0'
|
||||||
|
|
||||||
implementation project(':referral')
|
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
tasks.named('test') {
|
tasks.named('test') {
|
||||||
|
|||||||
@@ -0,0 +1,73 @@
|
|||||||
|
version: '3.9'
|
||||||
|
|
||||||
|
services:
|
||||||
|
storage:
|
||||||
|
image: alpine:latest
|
||||||
|
container_name: file-storage-local
|
||||||
|
networks:
|
||||||
|
- app-network-local
|
||||||
|
volumes:
|
||||||
|
- uploads_data_local:/storage:rw
|
||||||
|
command: tail -f /dev/null
|
||||||
|
restart: unless-stopped
|
||||||
|
|
||||||
|
db:
|
||||||
|
image: postgres:17.7
|
||||||
|
restart: always
|
||||||
|
environment:
|
||||||
|
POSTGRES_DB: no_copy_
|
||||||
|
POSTGRES_USER: postgres
|
||||||
|
POSTGRES_PASSWORD: postgres
|
||||||
|
POSTGRES_SHARED_BUFFERS: 512MB
|
||||||
|
POSTGRES_EFFECTIVE_CACHE_SIZE: 1536MB
|
||||||
|
ports:
|
||||||
|
- "54320:5432"
|
||||||
|
volumes:
|
||||||
|
- pgdata_local:/var/lib/postgresql/data
|
||||||
|
- ./init-scripts:/docker-entrypoint-initdb.d:ro
|
||||||
|
container_name: postgres-local
|
||||||
|
networks:
|
||||||
|
app-network-local:
|
||||||
|
aliases:
|
||||||
|
- database
|
||||||
|
|
||||||
|
app:
|
||||||
|
build: .
|
||||||
|
container_name: app-backend-local
|
||||||
|
environment:
|
||||||
|
JAVA_TOOL_OPTIONS: "-Xmx2g -Xms1g"
|
||||||
|
FILE_STORAGE_PATH: /data/uploads
|
||||||
|
POSTGRES_DB: no_copy_
|
||||||
|
POSTGRES_USER: postgres
|
||||||
|
POSTGRES_PASSWORD: postgres
|
||||||
|
POSTGRES_PORT: 5432
|
||||||
|
POSTGRES_HOST: db
|
||||||
|
# Используем local профиль
|
||||||
|
SPRING_PROFILES_ACTIVE: local
|
||||||
|
YANDEX_API_KEY: AQVNyaVaUmgUb1GMCtf5zSEqFxy0woXrcMOOB43q
|
||||||
|
YANDEX_FOLDER_ID: b1gokpdbm6qfpsou8pcd
|
||||||
|
YANDEX_SEARCH_URL: "https://searchapi.api.cloud.yandex.net/v2/image/search_by_image"
|
||||||
|
depends_on:
|
||||||
|
- db
|
||||||
|
ports:
|
||||||
|
- "8080:8080"
|
||||||
|
networks:
|
||||||
|
app-network-local:
|
||||||
|
aliases:
|
||||||
|
- app
|
||||||
|
- backend
|
||||||
|
volumes:
|
||||||
|
- uploads_data_local:/data/uploads:rw
|
||||||
|
healthcheck:
|
||||||
|
test: [ "CMD", "curl", "-f", "http://localhost:8080/actuator/health" ]
|
||||||
|
interval: 30s
|
||||||
|
timeout: 10s
|
||||||
|
retries: 3
|
||||||
|
|
||||||
|
volumes:
|
||||||
|
pgdata_local:
|
||||||
|
uploads_data_local:
|
||||||
|
|
||||||
|
networks:
|
||||||
|
app-network-local:
|
||||||
|
driver: bridge
|
||||||
@@ -0,0 +1,49 @@
|
|||||||
|
version: '3.9'
|
||||||
|
|
||||||
|
services:
|
||||||
|
storage:
|
||||||
|
image: alpine:latest
|
||||||
|
container_name: file-storage
|
||||||
|
networks:
|
||||||
|
- app-network
|
||||||
|
volumes:
|
||||||
|
- uploads_data:/storage:rw
|
||||||
|
command: tail -f /dev/null
|
||||||
|
restart: unless-stopped
|
||||||
|
|
||||||
|
app:
|
||||||
|
build: .
|
||||||
|
container_name: app-backend
|
||||||
|
environment:
|
||||||
|
JAVA_TOOL_OPTIONS: "-Xmx2g -Xms1g"
|
||||||
|
FILE_STORAGE_PATH: /data/uploads
|
||||||
|
# Данные для Yandex Cloud БД
|
||||||
|
YC_DB_USER: ${YC_DB_USER}
|
||||||
|
YC_DB_PASSWORD: ${YC_DB_PASSWORD}
|
||||||
|
# Используем prod профиль
|
||||||
|
SPRING_PROFILES_ACTIVE: prod
|
||||||
|
YANDEX_API_KEY: AQVNyaVaUmgUb1GMCtf5zSEqFxy0woXrcMOOB43q
|
||||||
|
YANDEX_FOLDER_ID: b1gokpdbm6qfpsou8pcd
|
||||||
|
YANDEX_SEARCH_URL: "https://searchapi.api.cloud.yandex.net/v2/image/search_by_image"
|
||||||
|
ports:
|
||||||
|
- "80:8080"
|
||||||
|
networks:
|
||||||
|
app-network:
|
||||||
|
aliases:
|
||||||
|
- app
|
||||||
|
- backend
|
||||||
|
volumes:
|
||||||
|
- uploads_data:/data/uploads:rw
|
||||||
|
healthcheck:
|
||||||
|
test: [ "CMD", "curl", "-f", "http://localhost:8080/actuator/health" ]
|
||||||
|
interval: 30s
|
||||||
|
timeout: 10s
|
||||||
|
retries: 3
|
||||||
|
|
||||||
|
volumes:
|
||||||
|
uploads_data:
|
||||||
|
|
||||||
|
networks:
|
||||||
|
app-network:
|
||||||
|
external: true
|
||||||
|
driver: bridge
|
||||||
@@ -2,9 +2,9 @@ package ru.soune
|
|||||||
|
|
||||||
interface Referral {
|
interface Referral {
|
||||||
|
|
||||||
val userId: Long
|
val userId: String
|
||||||
val referralLink: String
|
val referralLink: String
|
||||||
val inviter: Long?
|
val inviter: String?
|
||||||
val currentLevel: String
|
val currentLevel: String
|
||||||
val totalIncome: Int
|
val totalIncome: Int
|
||||||
val availableIncome: Int
|
val availableIncome: Int
|
||||||
|
|||||||
@@ -2,32 +2,32 @@ package ru.soune
|
|||||||
|
|
||||||
interface ReferralRepo {
|
interface ReferralRepo {
|
||||||
|
|
||||||
fun getUserReferralLink(userId: Long): String
|
fun getUserReferralLink(userId: String): String
|
||||||
|
|
||||||
fun getUserIdByLink(link: String): Long?
|
fun getUserIdByLink(link: String): String
|
||||||
|
|
||||||
fun getInviterIdForUser(userId: Long): Long?
|
fun getInviterIdForUser(userId: String): String?
|
||||||
|
|
||||||
fun getReferralLevelForUser(userId: Long): String
|
fun getReferralLevelForUser(userId: String): String
|
||||||
|
|
||||||
fun getReferralByUserId(userId: Long): Referral
|
fun getReferralByUserId(userId: String): Referral
|
||||||
|
|
||||||
fun getReferralInvitees(userId: Long, pageSize: Int, pageNumber: Int): List<ReferralInvitee>
|
fun getReferralInvitees(userId: String, pageSize: Int, pageNumber: Int): List<ReferralInvitee>
|
||||||
|
|
||||||
// создаем новую запись в БД
|
// создаем новую запись в БД
|
||||||
fun createReferralEntity(entity: Referral)
|
fun createReferralEntity(entity: Referral)
|
||||||
|
|
||||||
// прибавить к totalIncome и availableIncome значение transferAmount
|
// прибавить к totalIncome и availableIncome значение transferAmount
|
||||||
fun increaseIncome(userId: Long, transferAmount: Int)
|
fun increaseIncome(userId: String, transferAmount: Int)
|
||||||
|
|
||||||
// установить active в true
|
// установить active в true
|
||||||
fun activateUser(userId: Long): Boolean
|
fun activateUser(userId: String): Boolean
|
||||||
|
|
||||||
// посчитать записи, у которых inviter == userId и active == true
|
// посчитать записи, у которых inviter == userId и active == true
|
||||||
fun getActiveInviteeForUser(userId: Long): Int
|
fun getActiveInviteeForUser(userId: String): Int
|
||||||
|
|
||||||
// посчитать записи, у которых inviter == userId
|
// посчитать записи, у которых inviter == userId
|
||||||
fun getTotalInviteeForUser(userId: Long): Int
|
fun getTotalInviteeForUser(userId: String): Int
|
||||||
|
|
||||||
fun upgradeReferralLevelForUser(userId: Long, newLevelId: String)
|
fun upgradeReferralLevelForUser(userId: String, newLevelId: String)
|
||||||
}
|
}
|
||||||
@@ -5,7 +5,7 @@ class ReferralService(
|
|||||||
private val referralRepo: ReferralRepo,
|
private val referralRepo: ReferralRepo,
|
||||||
) {
|
) {
|
||||||
|
|
||||||
fun onRegister(userId: Long, inviterReferralLink: String?) {
|
fun onRegister(userId: String, inviterReferralLink: String?) {
|
||||||
val initialReferralLevel = referralLevelProvider.getInitialReferralLevelId()
|
val initialReferralLevel = referralLevelProvider.getInitialReferralLevelId()
|
||||||
val referralLink = referralRepo.getUserReferralLink(userId)
|
val referralLink = referralRepo.getUserReferralLink(userId)
|
||||||
val inviter = inviterReferralLink?.let(referralRepo::getUserIdByLink)
|
val inviter = inviterReferralLink?.let(referralRepo::getUserIdByLink)
|
||||||
@@ -24,7 +24,7 @@ class ReferralService(
|
|||||||
referralRepo.createReferralEntity(referral)
|
referralRepo.createReferralEntity(referral)
|
||||||
}
|
}
|
||||||
|
|
||||||
fun onUserAccountRefill(userId: Long, transferAmount: Int) {
|
fun onUserAccountRefill(userId: String, transferAmount: Int) {
|
||||||
val wasActivated = referralRepo.activateUser(userId)
|
val wasActivated = referralRepo.activateUser(userId)
|
||||||
val inviterId = referralRepo.getInviterIdForUser(userId) ?: return
|
val inviterId = referralRepo.getInviterIdForUser(userId) ?: return
|
||||||
val currentInviterLevel = referralRepo.getReferralLevelForUser(inviterId)
|
val currentInviterLevel = referralRepo.getReferralLevelForUser(inviterId)
|
||||||
@@ -47,11 +47,11 @@ class ReferralService(
|
|||||||
referralLevelProvider.getAvailableReferralLevels()
|
referralLevelProvider.getAvailableReferralLevels()
|
||||||
|
|
||||||
|
|
||||||
fun getReferralLevelForUser(userId: Long): ReferralLevel =
|
fun getReferralLevelForUser(userId: String): ReferralLevel =
|
||||||
referralRepo.getReferralLevelForUser(userId)
|
referralRepo.getReferralLevelForUser(userId)
|
||||||
.let { referralLevelProvider.getReferralLevelById(it) }
|
.let { referralLevelProvider.getReferralLevelById(it) }
|
||||||
|
|
||||||
fun getReferralStatForUser(userId: Long): ReferralStat {
|
fun getReferralStatForUser(userId: String): ReferralStat {
|
||||||
var referral = referralRepo.getReferralByUserId(userId)
|
var referral = referralRepo.getReferralByUserId(userId)
|
||||||
return ReferralStat(
|
return ReferralStat(
|
||||||
totalInvitee = referralRepo.getTotalInviteeForUser(userId),
|
totalInvitee = referralRepo.getTotalInviteeForUser(userId),
|
||||||
@@ -59,10 +59,9 @@ class ReferralService(
|
|||||||
totalIncome = referral.totalIncome,
|
totalIncome = referral.totalIncome,
|
||||||
availableIncome = referral.availableIncome,
|
availableIncome = referral.availableIncome,
|
||||||
holdBalance = referral.holdBalance,
|
holdBalance = referral.holdBalance,
|
||||||
referralLink = referral.referralLink
|
|
||||||
)
|
)
|
||||||
}
|
}
|
||||||
|
|
||||||
fun getInviteeForUser(userId: Long, pageSize: Int, pageNumber: Int): List<ReferralInvitee> =
|
fun getInviteeForUser(userId: String, pageSize: Int, pageNumber: Int): List<ReferralInvitee> =
|
||||||
referralRepo.getReferralInvitees(userId, pageSize, pageNumber)
|
referralRepo.getReferralInvitees(userId, pageSize, pageNumber)
|
||||||
}
|
}
|
||||||
@@ -6,5 +6,4 @@ data class ReferralStat(
|
|||||||
val totalIncome: Int,
|
val totalIncome: Int,
|
||||||
val availableIncome: Int,
|
val availableIncome: Int,
|
||||||
val holdBalance: Int,
|
val holdBalance: Int,
|
||||||
val referralLink: String,
|
|
||||||
)
|
)
|
||||||
@@ -22,8 +22,7 @@ public class HandlerConfig {
|
|||||||
AuthRequestHandler authRequestHandler,
|
AuthRequestHandler authRequestHandler,
|
||||||
CompanyHandler companyHandler,
|
CompanyHandler companyHandler,
|
||||||
TariffHandler tariffHandler,
|
TariffHandler tariffHandler,
|
||||||
TariffInfoHandler tariffInfoHandler,
|
TariffInfoHandler tariffInfoHandler
|
||||||
ReferralHandler referralHandler
|
|
||||||
) {
|
) {
|
||||||
Map<Integer, RequestHandler> map = new HashMap<>();
|
Map<Integer, RequestHandler> map = new HashMap<>();
|
||||||
map.put(20001, login);
|
map.put(20001, login);
|
||||||
@@ -37,7 +36,6 @@ public class HandlerConfig {
|
|||||||
map.put(30000, companyHandler);
|
map.put(30000, companyHandler);
|
||||||
map.put(30001, tariffHandler);
|
map.put(30001, tariffHandler);
|
||||||
map.put(30002, tariffInfoHandler);
|
map.put(30002, tariffInfoHandler);
|
||||||
map.put(30003, referralHandler);
|
|
||||||
|
|
||||||
return map;
|
return map;
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -1,16 +0,0 @@
|
|||||||
package ru.soune.nocopy.configuration;
|
|
||||||
|
|
||||||
import org.springframework.context.annotation.Bean;
|
|
||||||
import org.springframework.context.annotation.Configuration;
|
|
||||||
import ru.soune.ReferralLevelProvider;
|
|
||||||
import ru.soune.ReferralRepo;
|
|
||||||
import ru.soune.ReferralService;
|
|
||||||
|
|
||||||
@Configuration
|
|
||||||
public class ReferralConfig {
|
|
||||||
|
|
||||||
@Bean
|
|
||||||
public ReferralService referralService(ReferralLevelProvider referralLevelProvider, ReferralRepo referralRepo) {
|
|
||||||
return new ReferralService(referralLevelProvider, referralRepo);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
@@ -1,18 +0,0 @@
|
|||||||
package ru.soune.nocopy.dto.referral;
|
|
||||||
|
|
||||||
import lombok.AllArgsConstructor;
|
|
||||||
import lombok.Builder;
|
|
||||||
import lombok.Data;
|
|
||||||
import lombok.NoArgsConstructor;
|
|
||||||
|
|
||||||
@Data
|
|
||||||
@AllArgsConstructor
|
|
||||||
@NoArgsConstructor
|
|
||||||
@Builder
|
|
||||||
public class ReferralRequest {
|
|
||||||
private String token;
|
|
||||||
private Integer amount;
|
|
||||||
private Integer pageSize;
|
|
||||||
private Integer pageNumber;
|
|
||||||
private String action;
|
|
||||||
}
|
|
||||||
@@ -29,6 +29,4 @@ public class RegRequest {
|
|||||||
private String password;
|
private String password;
|
||||||
|
|
||||||
private String authToken;
|
private String authToken;
|
||||||
|
|
||||||
private String referralLink;
|
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -1,37 +0,0 @@
|
|||||||
package ru.soune.nocopy.entity.referral;
|
|
||||||
|
|
||||||
|
|
||||||
import jakarta.persistence.*;
|
|
||||||
import lombok.Data;
|
|
||||||
import org.springframework.data.annotation.CreatedDate;
|
|
||||||
import java.time.LocalDateTime;
|
|
||||||
|
|
||||||
@Entity
|
|
||||||
@Table(name = "referrals")
|
|
||||||
@Data
|
|
||||||
public class Referral {
|
|
||||||
@Id
|
|
||||||
private Long userId;
|
|
||||||
|
|
||||||
@Column(name = "referral_link", unique = true, nullable = false)
|
|
||||||
private String referralLink;
|
|
||||||
|
|
||||||
@Column(name = "inviter_id")
|
|
||||||
private Long inviterId;
|
|
||||||
|
|
||||||
@Column(name = "level_id")
|
|
||||||
private String levelId = "bronze";
|
|
||||||
|
|
||||||
@Column(name = "total_income")
|
|
||||||
private int totalIncome = 0;
|
|
||||||
|
|
||||||
@Column(name = "is_active")
|
|
||||||
private boolean isActive = false;
|
|
||||||
|
|
||||||
@CreatedDate
|
|
||||||
@Column(name = "created_at", updatable = false, nullable = false)
|
|
||||||
private LocalDateTime createdAt = LocalDateTime.now();
|
|
||||||
|
|
||||||
@Column(name = "hold_balance")
|
|
||||||
private int holdBalance = 0;
|
|
||||||
}
|
|
||||||
@@ -1,21 +0,0 @@
|
|||||||
package ru.soune.nocopy.entity.referral;
|
|
||||||
|
|
||||||
import jakarta.persistence.*;
|
|
||||||
import lombok.Data;
|
|
||||||
|
|
||||||
@Entity
|
|
||||||
@Table(name = "referral_levels")
|
|
||||||
@Data
|
|
||||||
public class ReferralLevelEntity {
|
|
||||||
@Id
|
|
||||||
private String id;
|
|
||||||
|
|
||||||
@Column(nullable = false)
|
|
||||||
private String name;
|
|
||||||
|
|
||||||
@Column(name = "min_invitees")
|
|
||||||
private int minInvitees;
|
|
||||||
|
|
||||||
@Column(name = "reward_percentage")
|
|
||||||
private int rewardPercentage;
|
|
||||||
}
|
|
||||||
@@ -1,90 +0,0 @@
|
|||||||
package ru.soune.nocopy.handler;
|
|
||||||
|
|
||||||
import com.fasterxml.jackson.databind.ObjectMapper;
|
|
||||||
import lombok.RequiredArgsConstructor;
|
|
||||||
import org.springframework.stereotype.Component;
|
|
||||||
import ru.soune.ReferralInvitee;
|
|
||||||
import ru.soune.ReferralLevel;
|
|
||||||
import ru.soune.ReferralService;
|
|
||||||
import ru.soune.ReferralStat;
|
|
||||||
import ru.soune.nocopy.dto.BaseRequest;
|
|
||||||
import ru.soune.nocopy.dto.BaseResponse;
|
|
||||||
import ru.soune.nocopy.dto.MessageCode;
|
|
||||||
import ru.soune.nocopy.dto.referral.ReferralRequest;
|
|
||||||
import ru.soune.nocopy.entity.user.AuthToken;
|
|
||||||
import ru.soune.nocopy.repository.AuthTokenRepository;
|
|
||||||
|
|
||||||
import java.util.List;
|
|
||||||
import java.util.Map;
|
|
||||||
|
|
||||||
|
|
||||||
@Component
|
|
||||||
@RequiredArgsConstructor
|
|
||||||
public class ReferralHandler implements RequestHandler {
|
|
||||||
|
|
||||||
private final ReferralService referralService;
|
|
||||||
|
|
||||||
private final AuthTokenRepository authTokenRepository;
|
|
||||||
|
|
||||||
private final ObjectMapper mapper = new ObjectMapper();
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public BaseResponse handle(BaseRequest request) throws Exception {
|
|
||||||
ReferralRequest referralRequest = mapper.convertValue(request.getMessageBody(), ReferralRequest.class);
|
|
||||||
String action = referralRequest.getAction();
|
|
||||||
String token = referralRequest.getToken();
|
|
||||||
AuthToken authToken = authTokenRepository.findByToken(token).orElseThrow();
|
|
||||||
|
|
||||||
switch (action) {
|
|
||||||
case "refill":
|
|
||||||
return handleRefill(request, authToken.getUser().getId(), referralRequest.getAmount());
|
|
||||||
case "levels":
|
|
||||||
return handleReferralLevels(request);
|
|
||||||
case "level":
|
|
||||||
return handleUserLevel(request, authToken.getUser().getId());
|
|
||||||
case "userStats" :
|
|
||||||
return handleUserStats(request, authToken.getUser().getId());
|
|
||||||
case "invitees":
|
|
||||||
return handleInvitees(referralRequest, request, authToken.getUser().getId());
|
|
||||||
}
|
|
||||||
|
|
||||||
return null;
|
|
||||||
}
|
|
||||||
|
|
||||||
private BaseResponse handleRefill(BaseRequest request, Long userId, Integer amount) {
|
|
||||||
referralService.onUserAccountRefill(userId, amount);
|
|
||||||
|
|
||||||
return new BaseResponse(request.getMsgId(), MessageCode.SUCCESS.getCode(),
|
|
||||||
MessageCode.SUCCESS.getDescription(), Map.of("account", "refill"));
|
|
||||||
}
|
|
||||||
|
|
||||||
private BaseResponse handleReferralLevels(BaseRequest request) {
|
|
||||||
List<ReferralLevel> referralLevels = referralService.getReferralLevels();
|
|
||||||
|
|
||||||
return new BaseResponse(request.getMsgId(), MessageCode.SUCCESS.getCode(),
|
|
||||||
MessageCode.SUCCESS.getDescription(), referralLevels);
|
|
||||||
|
|
||||||
}
|
|
||||||
|
|
||||||
private BaseResponse handleUserLevel(BaseRequest request, Long userId) {
|
|
||||||
ReferralLevel referralLevelForUser = referralService.getReferralLevelForUser(userId);
|
|
||||||
|
|
||||||
return new BaseResponse(request.getMsgId(), MessageCode.SUCCESS.getCode(),
|
|
||||||
MessageCode.SUCCESS.getDescription(), referralLevelForUser);
|
|
||||||
}
|
|
||||||
|
|
||||||
private BaseResponse handleUserStats(BaseRequest request, Long userId) {
|
|
||||||
ReferralStat referralStatForUser = referralService.getReferralStatForUser(userId);
|
|
||||||
|
|
||||||
return new BaseResponse(request.getMsgId(), MessageCode.SUCCESS.getCode(),
|
|
||||||
MessageCode.SUCCESS.getDescription(), referralStatForUser);
|
|
||||||
}
|
|
||||||
|
|
||||||
private BaseResponse handleInvitees(ReferralRequest referralRequest, BaseRequest request, Long userId) {
|
|
||||||
List<ReferralInvitee> inviteeForUser = referralService.getInviteeForUser(userId, referralRequest.getPageSize(),
|
|
||||||
referralRequest.getPageNumber());
|
|
||||||
|
|
||||||
return new BaseResponse(request.getMsgId(), MessageCode.SUCCESS.getCode(),
|
|
||||||
MessageCode.SUCCESS.getDescription(), inviteeForUser);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
@@ -6,7 +6,6 @@ import lombok.extern.slf4j.Slf4j;
|
|||||||
import org.springframework.stereotype.Component;
|
import org.springframework.stereotype.Component;
|
||||||
import org.springframework.validation.BeanPropertyBindingResult;
|
import org.springframework.validation.BeanPropertyBindingResult;
|
||||||
import org.springframework.validation.BindingResult;
|
import org.springframework.validation.BindingResult;
|
||||||
import ru.soune.ReferralService;
|
|
||||||
import ru.soune.nocopy.dto.*;
|
import ru.soune.nocopy.dto.*;
|
||||||
import ru.soune.nocopy.dto.register.RegAnswer;
|
import ru.soune.nocopy.dto.register.RegAnswer;
|
||||||
import ru.soune.nocopy.dto.register.RegRequest;
|
import ru.soune.nocopy.dto.register.RegRequest;
|
||||||
@@ -35,8 +34,6 @@ public class RegRequestHandler implements RequestHandler {
|
|||||||
|
|
||||||
private final EmailService emailService;
|
private final EmailService emailService;
|
||||||
|
|
||||||
private final ReferralService referralService;
|
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public BaseResponse handle(BaseRequest request) throws ValidationException {
|
public BaseResponse handle(BaseRequest request) throws ValidationException {
|
||||||
RegRequest regRequest = objectMapper.convertValue(request.getMessageBody(), RegRequest.class);
|
RegRequest regRequest = objectMapper.convertValue(request.getMessageBody(), RegRequest.class);
|
||||||
@@ -85,8 +82,6 @@ public class RegRequestHandler implements RequestHandler {
|
|||||||
regAnswer.setVerified(true);
|
regAnswer.setVerified(true);
|
||||||
regAnswer.setActive(true);
|
regAnswer.setActive(true);
|
||||||
|
|
||||||
referralService.onRegister(authToken.getUser().getId(), regRequest.getReferralLink());
|
|
||||||
|
|
||||||
return new BaseResponse(request.getMsgId(), MessageCode.SUCCESS.getCode(),
|
return new BaseResponse(request.getMsgId(), MessageCode.SUCCESS.getCode(),
|
||||||
MessageCode.SUCCESS.getDescription(), regAnswer);
|
MessageCode.SUCCESS.getDescription(), regAnswer);
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -1,40 +0,0 @@
|
|||||||
package ru.soune.nocopy.repository;
|
|
||||||
|
|
||||||
import org.springframework.data.domain.Pageable;
|
|
||||||
import org.springframework.data.jpa.repository.JpaRepository;
|
|
||||||
import org.springframework.data.jpa.repository.Modifying;
|
|
||||||
import org.springframework.data.jpa.repository.Query;
|
|
||||||
import org.springframework.data.repository.query.Param;
|
|
||||||
import org.springframework.stereotype.Repository;
|
|
||||||
import ru.soune.nocopy.entity.referral.Referral;
|
|
||||||
import java.util.List;
|
|
||||||
|
|
||||||
@Repository
|
|
||||||
public interface ReferralJpaRepository extends JpaRepository<Referral, Long> {
|
|
||||||
Referral findByReferralLink(String link);
|
|
||||||
|
|
||||||
Referral findByUserId(Long userId);
|
|
||||||
|
|
||||||
List<Referral> findByInviterId(Long inviterId);
|
|
||||||
|
|
||||||
@Query("SELECT r FROM Referral r WHERE r.inviterId = :userId AND r.isActive = true")
|
|
||||||
List<Referral> findByInviterId(Long inviterId, Pageable pageable);
|
|
||||||
|
|
||||||
@Modifying
|
|
||||||
@Query("UPDATE Referral r SET r.totalIncome = r.totalIncome + :amount WHERE r.userId = :userId")
|
|
||||||
void increaseIncome(@Param("userId") Long userId, @Param("amount") int amount);
|
|
||||||
|
|
||||||
@Modifying
|
|
||||||
@Query("UPDATE Referral r SET r.levelId = :newLevelId WHERE r.userId = :userId")
|
|
||||||
void updateLevel(@Param("userId") Long userId, @Param("newLevelId") String newLevelId);
|
|
||||||
|
|
||||||
@Modifying
|
|
||||||
@Query("UPDATE Referral r SET r.isActive = true WHERE r.userId = :userId")
|
|
||||||
void activateUser(@Param("userId") Long userId);
|
|
||||||
|
|
||||||
@Query("SELECT COUNT(r) FROM Referral r WHERE r.inviterId = :userId AND r.isActive = true")
|
|
||||||
int countActiveInvitees(@Param("userId") Long userId);
|
|
||||||
|
|
||||||
@Query("SELECT COUNT(r) FROM Referral r WHERE r.inviterId = :userId")
|
|
||||||
int countTotalInvitees(@Param("userId") Long userId);
|
|
||||||
}
|
|
||||||
@@ -1,13 +0,0 @@
|
|||||||
package ru.soune.nocopy.repository;
|
|
||||||
|
|
||||||
import org.springframework.data.jpa.repository.JpaRepository;
|
|
||||||
import org.springframework.stereotype.Repository;
|
|
||||||
import ru.soune.nocopy.entity.referral.ReferralLevelEntity;
|
|
||||||
|
|
||||||
import java.util.List;
|
|
||||||
|
|
||||||
@Repository
|
|
||||||
public interface ReferralLevelRepository extends JpaRepository<ReferralLevelEntity, Long> {
|
|
||||||
List<ReferralLevelEntity> findAllByOrderByMinInviteesAsc();
|
|
||||||
ReferralLevelEntity findById(String id);
|
|
||||||
}
|
|
||||||
@@ -1,83 +0,0 @@
|
|||||||
package ru.soune.nocopy.service.referral;
|
|
||||||
|
|
||||||
import lombok.RequiredArgsConstructor;
|
|
||||||
import org.springframework.stereotype.Component;
|
|
||||||
import ru.soune.ReferralLevel;
|
|
||||||
import ru.soune.ReferralLevelProvider;
|
|
||||||
import ru.soune.nocopy.entity.referral.ReferralLevelEntity;
|
|
||||||
import ru.soune.nocopy.repository.ReferralLevelRepository;
|
|
||||||
|
|
||||||
|
|
||||||
import java.util.List;
|
|
||||||
import java.util.stream.Collectors;
|
|
||||||
|
|
||||||
@Component
|
|
||||||
@RequiredArgsConstructor
|
|
||||||
public class ReferralLevelProviderImpl implements ReferralLevelProvider {
|
|
||||||
|
|
||||||
private final ReferralLevelRepository referralLevelRepository;
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public List<ReferralLevel> getAvailableReferralLevels() {
|
|
||||||
List<ReferralLevelEntity> entities = referralLevelRepository.findAll();
|
|
||||||
|
|
||||||
return entities.stream()
|
|
||||||
.map(this::createReferralLevel)
|
|
||||||
.collect(Collectors.toList());
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public String getInitialReferralLevelId() {
|
|
||||||
return "bronze";
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public ReferralLevel getReferralLevelById(String levelId) {
|
|
||||||
return createReferralLevel(referralLevelRepository.findById(levelId));
|
|
||||||
}
|
|
||||||
|
|
||||||
private ReferralLevel createReferralLevel(ReferralLevelEntity entity) {
|
|
||||||
return new ReferralLevel() {
|
|
||||||
@Override
|
|
||||||
public String getId() {
|
|
||||||
return entity.getId();
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public String getName() {
|
|
||||||
return entity.getName();
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public int getShare() {
|
|
||||||
return entity.getRewardPercentage();
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public int getMinInvitee() {
|
|
||||||
return entity.getMinInvitees();
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public int getMaxInvitee() {
|
|
||||||
switch (entity.getId()) {
|
|
||||||
case "bronze": return 9;
|
|
||||||
case "silver": return 49;
|
|
||||||
case "gold": return 99;
|
|
||||||
case "platinum": return Integer.MAX_VALUE;
|
|
||||||
default: return Integer.MAX_VALUE;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public String getNext() {
|
|
||||||
switch (entity.getId()) {
|
|
||||||
case "bronze": return "silver";
|
|
||||||
case "silver": return "gold";
|
|
||||||
case "gold": return "platinum";
|
|
||||||
default: return null;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
};
|
|
||||||
}
|
|
||||||
}
|
|
||||||
@@ -1,221 +0,0 @@
|
|||||||
package ru.soune.nocopy.service.referral;
|
|
||||||
|
|
||||||
import lombok.RequiredArgsConstructor;
|
|
||||||
import lombok.extern.slf4j.Slf4j;
|
|
||||||
import org.jetbrains.annotations.NotNull;
|
|
||||||
import org.jetbrains.annotations.Nullable;
|
|
||||||
import org.springframework.data.domain.PageRequest;
|
|
||||||
import org.springframework.data.domain.Pageable;
|
|
||||||
import org.springframework.stereotype.Repository;
|
|
||||||
import org.springframework.transaction.annotation.Transactional;
|
|
||||||
import ru.soune.Referral;
|
|
||||||
import ru.soune.ReferralInvitee;
|
|
||||||
import ru.soune.ReferralRepo;
|
|
||||||
import ru.soune.nocopy.entity.user.User;
|
|
||||||
import ru.soune.nocopy.repository.ReferralJpaRepository;
|
|
||||||
import ru.soune.nocopy.repository.UserRepository;
|
|
||||||
|
|
||||||
|
|
||||||
import java.lang.reflect.Constructor;
|
|
||||||
import java.util.ArrayList;
|
|
||||||
import java.util.List;
|
|
||||||
import java.util.UUID;
|
|
||||||
|
|
||||||
@Repository
|
|
||||||
@RequiredArgsConstructor
|
|
||||||
@Slf4j
|
|
||||||
@Transactional
|
|
||||||
public class ReferralRepoImpl implements ReferralRepo {
|
|
||||||
|
|
||||||
private final ReferralJpaRepository referralRepository;
|
|
||||||
|
|
||||||
private final UserRepository userRepository;
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public @NotNull String getUserReferralLink(long userId) {
|
|
||||||
ru.soune.nocopy.entity.referral.Referral referral =
|
|
||||||
referralRepository.findByUserId(userId);
|
|
||||||
|
|
||||||
if (referral != null && referral.getReferralLink() != null &&
|
|
||||||
!referral.getReferralLink().isEmpty()) {
|
|
||||||
return referral.getReferralLink();
|
|
||||||
}
|
|
||||||
|
|
||||||
String newLink = "ref-" + userId + "-" + UUID.randomUUID().toString().substring(0, 8);
|
|
||||||
|
|
||||||
if (referral == null) {
|
|
||||||
referral = new ru.soune.nocopy.entity.referral.Referral();
|
|
||||||
referral.setUserId(userId);
|
|
||||||
referral.setLevelId("bronze");
|
|
||||||
referral.setActive(false);
|
|
||||||
}
|
|
||||||
|
|
||||||
referral.setReferralLink(newLink);
|
|
||||||
|
|
||||||
referralRepository.save(referral);
|
|
||||||
|
|
||||||
return newLink;
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public @NotNull Long getUserIdByLink(@NotNull String link) {
|
|
||||||
ru.soune.nocopy.entity.referral.Referral referral = referralRepository.findByReferralLink(link);
|
|
||||||
return referral != null ? referral.getUserId() : 0L;
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public @Nullable Long getInviterIdForUser(long userId) {
|
|
||||||
ru.soune.nocopy.entity.referral.Referral referral = referralRepository.findByUserId(userId);
|
|
||||||
return referral != null ? referral.getInviterId() : 0L;
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public @NotNull String getReferralLevelForUser(long userId) {
|
|
||||||
ru.soune.nocopy.entity.referral.Referral referral = referralRepository.findByUserId(userId);
|
|
||||||
return referral != null ? referral.getLevelId() : "";
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public @NotNull Referral getReferralByUserId(long userId) {
|
|
||||||
ru.soune.nocopy.entity.referral.Referral entity = referralRepository.findByUserId(userId);
|
|
||||||
|
|
||||||
if (entity == null) {
|
|
||||||
return createDefaultReferral(userId);
|
|
||||||
}
|
|
||||||
|
|
||||||
return new Referral() {
|
|
||||||
@Override
|
|
||||||
public long getUserId() { return entity.getUserId(); }
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public String getReferralLink() { return entity.getReferralLink(); }
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public Long getInviter() {
|
|
||||||
return entity.getInviterId() != null ? entity.getInviterId() : 0L;
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public String getCurrentLevel() { return entity.getLevelId(); }
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public int getTotalIncome() { return entity.getTotalIncome(); }
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public int getAvailableIncome() {
|
|
||||||
Integer holdBalance = entity.getHoldBalance();
|
|
||||||
return entity.getTotalIncome() - (holdBalance != null ? holdBalance : 0);
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public int getHoldBalance() {
|
|
||||||
Integer holdBalance = entity.getHoldBalance();
|
|
||||||
return holdBalance != null ? holdBalance : 0;
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public boolean getActive() { return entity.isActive(); }
|
|
||||||
};
|
|
||||||
}
|
|
||||||
|
|
||||||
private Referral createDefaultReferral(long userId) {
|
|
||||||
return new Referral() {
|
|
||||||
@Override
|
|
||||||
public long getUserId() { return userId; }
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public String getReferralLink() { return ""; }
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public Long getInviter() { return 0L; }
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public String getCurrentLevel() { return "bronze"; }
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public int getTotalIncome() { return 0; }
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public int getAvailableIncome() { return 0; }
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public int getHoldBalance() { return 0; }
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public boolean getActive() { return false; }
|
|
||||||
};
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public @NotNull List<ReferralInvitee> getReferralInvitees(long userId, int pageSize, int pageNumber) {
|
|
||||||
Pageable pageable = PageRequest.of(pageNumber, pageSize);
|
|
||||||
List<ru.soune.nocopy.entity.referral.Referral> referrals = referralRepository.findByInviterId(userId, pageable);
|
|
||||||
|
|
||||||
List<ReferralInvitee> result = new ArrayList<>();
|
|
||||||
|
|
||||||
for (ru.soune.nocopy.entity.referral.Referral referral : referrals) {
|
|
||||||
User user = userRepository.findById(referral.getUserId()).orElse(null);
|
|
||||||
|
|
||||||
String email = user != null ? user.getEmail() : "";
|
|
||||||
boolean isActive = referral.isActive();
|
|
||||||
String regDate = referral.getCreatedAt() != null ?
|
|
||||||
referral.getCreatedAt().toString() : "";
|
|
||||||
|
|
||||||
try {
|
|
||||||
Constructor<ReferralInvitee> constructor = ReferralInvitee.class.getDeclaredConstructor(
|
|
||||||
String.class, boolean.class, String.class
|
|
||||||
);
|
|
||||||
ReferralInvitee invitee = constructor.newInstance(email, isActive, regDate);
|
|
||||||
result.add(invitee);
|
|
||||||
} catch (Exception e) {
|
|
||||||
e.printStackTrace();
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
return result;
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public void createReferralEntity(@NotNull Referral entity) {
|
|
||||||
ru.soune.nocopy.entity.referral.Referral referral = new ru.soune.nocopy.entity.referral.Referral();
|
|
||||||
referral.setUserId(entity.getUserId());
|
|
||||||
referral.setReferralLink(entity.getReferralLink());
|
|
||||||
referral.setInviterId(entity.getInviter());
|
|
||||||
referral.setLevelId(entity.getCurrentLevel());
|
|
||||||
referral.setTotalIncome(entity.getTotalIncome());
|
|
||||||
referral.setHoldBalance(entity.getHoldBalance());
|
|
||||||
referral.setActive(entity.getActive());
|
|
||||||
|
|
||||||
referralRepository.save(referral);
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public void increaseIncome(long userId, int transferAmount) {
|
|
||||||
referralRepository.increaseIncome(userId, transferAmount);
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public boolean activateUser(long userId) {
|
|
||||||
try {
|
|
||||||
referralRepository.activateUser(userId);
|
|
||||||
return true;
|
|
||||||
} catch (Exception e) {
|
|
||||||
return false;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public int getActiveInviteeForUser(long userId) {
|
|
||||||
return referralRepository.countActiveInvitees(userId);
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public int getTotalInviteeForUser(long userId) {
|
|
||||||
return referralRepository.countTotalInvitees(userId);
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public void upgradeReferralLevelForUser(long userId, @NotNull String newLevelId) {
|
|
||||||
referralRepository.updateLevel(userId, newLevelId);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
@@ -1,2 +0,0 @@
|
|||||||
server:
|
|
||||||
baseurl: "http://localhost"
|
|
||||||
@@ -1,2 +0,0 @@
|
|||||||
server:
|
|
||||||
baseurl: "http://92.242.61.23"
|
|
||||||
@@ -0,0 +1,24 @@
|
|||||||
|
spring:
|
||||||
|
datasource:
|
||||||
|
url: jdbc:postgresql://rc1a-7osqmsdaf27d2ieh.mdb.yandexcloud.net:6432/ncp-test?ssl=true&sslmode=require
|
||||||
|
username: ${YC_DB_USER:test}
|
||||||
|
password: ${YC_DB_PASSWORD:testtest}
|
||||||
|
driver-class-name: org.postgresql.Driver # ← ДОБАВЬ
|
||||||
|
|
||||||
|
jpa:
|
||||||
|
hibernate:
|
||||||
|
ddl-auto: update
|
||||||
|
|
||||||
|
flyway:
|
||||||
|
enabled: false
|
||||||
|
|
||||||
|
file:
|
||||||
|
storage:
|
||||||
|
base-path: ${FILE_STORAGE_PATH:/data/uploads}
|
||||||
|
chunk-size: ${FILE_CHUNK_SIZE:1000000} # 1MB
|
||||||
|
max-file-size: ${MAX_FILE_SIZE:10737418240} # 10GB
|
||||||
|
max-retry-attempts: ${MAX_RETRY_ATTEMPTS:3}
|
||||||
|
chunk-timeout-ms: ${CHUNK_TIMEOUT_MS:300000} # 5 минут
|
||||||
|
temp-ttl-hours: ${TEMP_TTL_HOURS:72} # 3 дня
|
||||||
|
auth-token-life-hours: ${AUTH_TOKEN_LIFE:1} # 1 час
|
||||||
|
session-expiry-hours: ${SESSION_EXPIRY_HOURS:24}
|
||||||
@@ -1,7 +1,6 @@
|
|||||||
spring:
|
spring:
|
||||||
# config:
|
profiles:
|
||||||
# activate:
|
active: ${SPRING_PROFILES_ACTIVE:local}
|
||||||
# on-profile: ${SPRING_PROFILES_ACTIVE:dev}
|
|
||||||
|
|
||||||
mail:
|
mail:
|
||||||
host: smtp.gmail.com
|
host: smtp.gmail.com
|
||||||
@@ -15,24 +14,15 @@ spring:
|
|||||||
starttls:
|
starttls:
|
||||||
enable: true
|
enable: true
|
||||||
|
|
||||||
# mail:
|
|
||||||
# host: postfix
|
|
||||||
# port: 25
|
|
||||||
# username: noreply@nocopy.com
|
|
||||||
# password: nocopy!nocopy!
|
|
||||||
# properties:
|
|
||||||
# mail.smtp.auth: false
|
|
||||||
# mail.smtp.starttls.enable: false
|
|
||||||
# mail.debug: true
|
|
||||||
|
|
||||||
flyway:
|
flyway:
|
||||||
enabled: true
|
enabled: true
|
||||||
baseline-on-migrate: true
|
baseline-on-migrate: true
|
||||||
|
|
||||||
datasource:
|
datasource:
|
||||||
url: jdbc:postgresql://${POSTGRES_HOST}:${POSTGRES_PORT}/${POSTGRES_DB}
|
# Настройки по умолчанию для local разработки
|
||||||
username: ${POSTGRES_USER}
|
url: jdbc:postgresql://${POSTGRES_HOST:localhost}:${POSTGRES_PORT:54320}/${POSTGRES_DB:no_copy_}
|
||||||
password: ${POSTGRES_PASSWORD}
|
username: ${POSTGRES_USER:postgres}
|
||||||
|
password: ${POSTGRES_PASSWORD:postgres}
|
||||||
driver-class-name: org.postgresql.Driver
|
driver-class-name: org.postgresql.Driver
|
||||||
|
|
||||||
jpa:
|
jpa:
|
||||||
|
|||||||
Reference in New Issue
Block a user