This commit is contained in:
@@ -13,6 +13,8 @@ public enum NotificationType {
|
|||||||
PAYMENT_RESULT("notification-payment-result"),
|
PAYMENT_RESULT("notification-payment-result"),
|
||||||
REFERRAL_DEPOSIT("notification-referral-deposit"),
|
REFERRAL_DEPOSIT("notification-referral-deposit"),
|
||||||
REFERRAL_REGISTERED("notification-referral-registered"),
|
REFERRAL_REGISTERED("notification-referral-registered"),
|
||||||
|
USER_VERIFIED("notification-user-verified"),
|
||||||
|
USER_NOT_VERIFIED("notification-user-not-verified"),
|
||||||
REFERRAL_ACTIVATED("notification-referral-activated"),
|
REFERRAL_ACTIVATED("notification-referral-activated"),
|
||||||
COMPLAINT_STATUS_CHANGED("notification-complaint-status"),
|
COMPLAINT_STATUS_CHANGED("notification-complaint-status"),
|
||||||
CASE_STATUS_CHANGED("notification-case-status"),
|
CASE_STATUS_CHANGED("notification-case-status"),
|
||||||
|
|||||||
@@ -10,7 +10,10 @@ import ru.soune.nocopy.dto.MessageCode;
|
|||||||
import ru.soune.nocopy.dto.file.ActionResponse;
|
import ru.soune.nocopy.dto.file.ActionResponse;
|
||||||
import ru.soune.nocopy.dto.user.moderation.UserVerificationRequest;
|
import ru.soune.nocopy.dto.user.moderation.UserVerificationRequest;
|
||||||
import ru.soune.nocopy.dto.user.moderation.UserVerificationResponse;
|
import ru.soune.nocopy.dto.user.moderation.UserVerificationResponse;
|
||||||
|
import ru.soune.nocopy.entity.notification.NotificationType;
|
||||||
|
import ru.soune.nocopy.entity.user.ModerationStatus;
|
||||||
import ru.soune.nocopy.entity.user.moderation.UserVerification;
|
import ru.soune.nocopy.entity.user.moderation.UserVerification;
|
||||||
|
import ru.soune.nocopy.service.notification.NotificationService;
|
||||||
import ru.soune.nocopy.service.user.moderation.UserVerificationService;
|
import ru.soune.nocopy.service.user.moderation.UserVerificationService;
|
||||||
|
|
||||||
import java.util.Arrays;
|
import java.util.Arrays;
|
||||||
@@ -25,6 +28,8 @@ public class UserVerificationHandler implements RequestHandler {
|
|||||||
|
|
||||||
private final ObjectMapper objectMapper;
|
private final ObjectMapper objectMapper;
|
||||||
|
|
||||||
|
private final NotificationService notificationService;
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public BaseResponse handle(BaseRequest request) throws Exception {
|
public BaseResponse handle(BaseRequest request) throws Exception {
|
||||||
UserVerificationRequest userVerificationRequest = objectMapper.convertValue(request.getMessageBody(),
|
UserVerificationRequest userVerificationRequest = objectMapper.convertValue(request.getMessageBody(),
|
||||||
@@ -76,6 +81,11 @@ public class UserVerificationHandler implements RequestHandler {
|
|||||||
null);
|
null);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
NotificationType notificationType = userVerification.getModerationStatus() == ModerationStatus.VERIFIED?
|
||||||
|
NotificationType.USER_VERIFIED: NotificationType.USER_NOT_VERIFIED;
|
||||||
|
|
||||||
|
notificationService.addNotification(notificationType, userVerification.getUserId());
|
||||||
|
|
||||||
return BaseResponse.builder()
|
return BaseResponse.builder()
|
||||||
.msgId(request.getMsgId())
|
.msgId(request.getMsgId())
|
||||||
.messageBody(UserVerificationResponse.builder()
|
.messageBody(UserVerificationResponse.builder()
|
||||||
|
|||||||
Reference in New Issue
Block a user