diff --git a/account-service/src/main/java/com/drinkool/services/AccountService.java b/account-service/src/main/java/com/drinkool/services/AccountService.java index a6c3002..01a8c8a 100644 --- a/account-service/src/main/java/com/drinkool/services/AccountService.java +++ b/account-service/src/main/java/com/drinkool/services/AccountService.java @@ -1,7 +1,9 @@ package com.drinkool.services; +import com.drinkool.Role; import com.drinkool.Url; import com.drinkool.dtos.SmsOtp; +import com.drinkool.entities.ManagerEntity; import com.drinkool.models.UserModel; import jakarta.inject.Inject; import jakarta.ws.rs.*; @@ -22,11 +24,14 @@ public class AccountService { .entity("InvalidPhoneNumber") .build(); + if ( + ManagerEntity.find("phone", input.phone).firstResult() != null + ) return Response.accepted().entity(Role.Manager).build(); + String otp = otpService.generateAndSaveOtp(input.phone); - // Ở đây bạn sẽ gọi Kafka để gửi SMS thực tế System.out.println("OTP cho " + input.phone + " là: " + otp); - return Response.accepted().build(); + return Response.accepted().entity(Role.Customer).build(); } } diff --git a/account-service/src/main/java/com/drinkool/services/ManagerService.java b/account-service/src/main/java/com/drinkool/services/ManagerService.java index cffc147..ce2d9b6 100644 --- a/account-service/src/main/java/com/drinkool/services/ManagerService.java +++ b/account-service/src/main/java/com/drinkool/services/ManagerService.java @@ -62,6 +62,7 @@ public class ManagerService extends BaseService { return Response.accepted() .header(InternalValue.userId, customer.id.toString()) .header(InternalValue.role, Role.Manager) + .entity(customer) .build(); } }