Notes

package com.hpe.ngit.service.mdm.repository;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.stereotype.Component;

import com.hpe.ngit.constants.PartyConstants;
import com.hpe.ngit.service.mdm.config.AbstractMdmRepository;
import com.hpe.ngit.service.mdm.model.ProtectedExclusionResponse;

// 542.2
@Component
public class ProtectedPartyRepository extends AbstractMdmRepository {

@Autowired
JdbcTemplate mdmJdbcTemplate;

public ProtectedExclusionResponse addProtectedParty(int partyId) {
ProtectedExclusionResponse protectedExclusionResponse = new ProtectedExclusionResponse();
// QUERY TO CHECK WHETHER PARTYID EXISTS IN C_PRTY TABLE
String cPrtyTableQuery = "SELECT COUNT(PRTY_ID) FROM [cmx_ors].[DBO].[C_PRTY] WITH(NOLOCK) WHERE PRTY_ID='"
+ partyId + "'";
int retrievedCount = mdmJdbcTemplate.queryForInt(cPrtyTableQuery);
if (retrievedCount > 0) {
// QUERY TO CHECK WHETHER PARTYID EXISTS IN EXCLUDE_PRTYID_LIST
String excludePrtyIdQuery = "SELECT COUNT(PRTY_ID) FROM [cmx_ors].[DBO].[EXCLUDE_PRTYID_LIST] WITH(NOLOCK) WHERE PRTY_ID='"
+ partyId + "'";
int excludedCount = mdmJdbcTemplate.queryForInt(excludePrtyIdQuery);
if (excludedCount > 0) {
protectedExclusionResponse.setStatus(PartyConstants.PARTY_EXISTS_IN_PROTECTED_LIST);
return protectedExclusionResponse;
} else {
// QUERY TO CHECK WHETHER PARTYID EXISTS IN EXCLUSION LIST
String exclusionPrtyIdQuery = "SELECT COUNT(PRTY_ID) FROM [cmx_ors].[DBO].[C_PRTY] WITH(NOLOCK) WHERE PRTY_ID='"
+ partyId + "' AND CONSOLIDATION_IND=9";
int exclusionCount = mdmJdbcTemplate.queryForInt(exclusionPrtyIdQuery);
if (exclusionCount > 0) {
protectedExclusionResponse.setStatus(PartyConstants.PARTY_EXISTS_IN_EXCLUSION_LIST);
return protectedExclusionResponse;
}
// FUZZY LOGIC TO BE ADDED
else {
String addQuery = "INSERT INTO [cmx_ors].[DBO].[EXCLUDE_PRTYID_LIST] (PRTY_ID, REASON) VALUES ('"
+ partyId + "' , 'Constant Prty ID')";
mdmJdbcTemplate.execute(addQuery);
protectedExclusionResponse.setStatus(PartyConstants.PARTY_ADDED_SUCCESSFULLY_TO_PROTECTED_LIST);
return protectedExclusionResponse;
}
}
} else {
protectedExclusionResponse.setStatus(PartyConstants.INVALID_PARTY_ID);
return protectedExclusionResponse;
}
}

public ProtectedExclusionResponse removeProtectedParty(int partyId) {
ProtectedExclusionResponse protectedExclusionResponse = new ProtectedExclusionResponse();
String excludePrtyIdQuery = "SELECT COUNT(PRTY_ID) FROM [cmx_ors].[DBO].[EXCLUDE_PRTYID_LIST] WITH(NOLOCK) WHERE PRTY_ID='"
+ partyId + "'";
int excludeCount = mdmJdbcTemplate.queryForInt(excludePrtyIdQuery);
if (excludeCount == 1) {
String deleteQuery = "DELETE FROM [cmx_ors].[DBO].[EXCLUDE_PRTYID_LIST] WHERE PRTY_ID='" + partyId + "'";
mdmJdbcTemplate.execute(deleteQuery);
protectedExclusionResponse.setStatus(PartyConstants.PARTY_REMOVED_FROM_PROTECTED_LIST);
return protectedExclusionResponse;
} else {
protectedExclusionResponse.setStatus(PartyConstants.PARTY_NOT_EXISTS_IN_PROTECTED_LIST);
return protectedExclusionResponse;
}
}
}