API to fetch beneficiary ID linked with HealthID

Author: KA40094929

src/main/java/com/wipro/fhir/controller/healthID/CreateHealthIDWithMobileOTP.java

@@ -139,5 +139,31 @@ public String getBenhealthID(
 		logger.info("NDHM_FHIR get beneficiary ABHA response:" + response.toString());
 		return response.toString();
 	}
+	
+	@CrossOrigin()
+	@Operation(summary = "Get Beneficiary Id for ABHA Id")
+	@PostMapping(value = { "/getBenIdForhealthID" })
+	public String getBenIdForhealthID(
+			@Param(value = "{\"healthIdNumber\":\"String\"}") @RequestBody String request) {
+		OutputResponse response = new OutputResponse();
+
+		logger.info("NDHM_FHIR Request obj to fetch beneficiary Ids for HealthID :" + request);
+		try {
+			JSONObject obj = new JSONObject(request);
+			if (request != null) {
+				String healthId = obj.getString("healthIdNumber");
+				String res = healthIDService.getMappedBenIdForHealthId(healthId);
+				response.setResponse(res);
+			} else {
+				logger.info("NDHM_FHIR Invalid Request Data.");
+				response.setError(5000, "NDHM_FHIR Invalid request");
+			}
+		} catch (Exception e) {
+			response.setError(5000, e.getMessage());
+			logger.error("NDHM_FHIR Error while getting beneficiary Ids for HealthID:" + e);
+		}
+		logger.info("NDHM_FHIR get beneficiary Ids for HealthID response:" + response.toString());
+		return response.toString();
+	}
 
 }

src/main/java/com/wipro/fhir/repo/healthID/BenHealthIDMappingRepo.java

@@ -45,6 +45,12 @@ public interface BenHealthIDMappingRepo extends CrudRepository<BenHealthIDMappin
 	@Query(" SELECT bvd from BenHealthIDMapping bvd WHERE bvd.beneficiaryRegID = :benRegID")
 	public ArrayList<BenHealthIDMapping> getHealthDetails(@Param("benRegID") Long benRegID);
 
+	@Query("SELECT bvd.beneficiaryRegID from BenHealthIDMapping bvd WHERE bvd.healthIdNumber = :healthIdNumber")
+	public String[] getBenIdForHealthId(@Param("healthIdNumber") String healthIdNumber);
+	
+	@Query(value = "SELECT BeneficiaryID FROM db_identity.m_beneficiaryregidmapping where BenRegId in (:benIds)", nativeQuery = true)
+	public String[] getBeneficiaryIds(@Param("benIds") String[] benIds);
+	
 	@Transactional
 	@Modifying
 	@Query(value = "UPDATE db_iemr.t_benvisitdetail SET HealthID= :healthID,HealthIdNumber= :healthIdNumber,CarecontextLinkDate=CURRENT_TIMESTAMP() WHERE VisitCode= :visitCode ", nativeQuery = true)

src/main/java/com/wipro/fhir/service/healthID/HealthIDService.java

@@ -27,4 +27,5 @@ public interface HealthIDService {
  String mapHealthIDToBeneficiary(String request) throws FHIRException;
  public String getBenHealthID(Long benRegID);
  public String addRecordToHealthIdTable(String request) throws FHIRException;
+public String getMappedBenIdForHealthId(String healthIdNumber);
 }

src/main/java/com/wipro/fhir/service/healthID/HealthIDServiceImpl.java

@@ -176,4 +176,16 @@ public String addRecordToHealthIdTable(String request) throws FHIRException {
 		}
 		return res;
 	}
+	
+	@Override
+	public String getMappedBenIdForHealthId(String healthIdNumber) {
+		String[] beneficiaryIdsList = benHealthIDMappingRepo.getBenIdForHealthId(healthIdNumber);
+		
+		if(beneficiaryIdsList.length > 0) {
+			String[] benIds = benHealthIDMappingRepo.getBeneficiaryIds(beneficiaryIdsList);
+			return String.join(",", benIds);
+		} 
+		return "No Beneficiary Found";
+	}
+	
 }