diff --git a/src/main/java/com/mfsys/uco/repository/PinRepository.java b/src/main/java/com/mfsys/uco/repository/PinRepository.java index 0a27098..20dfeef 100644 --- a/src/main/java/com/mfsys/uco/repository/PinRepository.java +++ b/src/main/java/com/mfsys/uco/repository/PinRepository.java @@ -12,7 +12,7 @@ public interface PinRepository extends JpaRepository { @Query("SELECT p FROM DG_PN_PIN p WHERE p.userName = :username AND p.pinstatus = 'Unverified' AND p.pinExpirydate > CURRENT_TIMESTAMP AND p.pintype=:pinType ORDER BY p.pinserial DESC LIMIT 1") Optional findLatestActiveOtpByUserName(String username, String pinType); - @Query("SELECT p FROM DG_PN_PIN p WHERE p.pinserial = :id And p.pincode =:obpPincode AND p.pinstatus = 'Unverified' AND p.pinExpirydate > CURRENT_TIMESTAMP AND p.pintype=:pinType ORDER BY p.pinserial DESC LIMIT 1") - Optional findsss(String id, String pinType, String obpPincode); + @Query("SELECT p FROM DG_PN_PIN p WHERE p.pincode =:obpPincode AND p.pinstatus = 'Unverified' AND p.pinExpirydate > CURRENT_TIMESTAMP AND p.pintype=:pinType ORDER BY p.pinserial DESC LIMIT 1") + Optional findsss( String pinType, String obpPincode); } diff --git a/src/main/java/com/mfsys/uco/service/NotificationService.java b/src/main/java/com/mfsys/uco/service/NotificationService.java index 4f34f1b..6d47692 100644 --- a/src/main/java/com/mfsys/uco/service/NotificationService.java +++ b/src/main/java/com/mfsys/uco/service/NotificationService.java @@ -61,7 +61,7 @@ public class NotificationService { } public void verifyOtpViaOtpId(String id, String pinType, String obpPincode) { - Pin pin = pinRepository.findsss(id, pinType, obpPincode) + Pin pin = pinRepository.findsss(pinType, obpPincode) .orElseThrow(() -> new InvalidOTPException(id)); pin.setPinstatus("VERIFIED"); pinRepository.save(pin);