MIFOSX-29: allow user to add or edit external id for client.
This commit is contained in:
@@ -118,7 +118,7 @@ public class Client extends AbstractAuditableCustom<AppUser, Long> {
|
|||||||
}
|
}
|
||||||
|
|
||||||
if (command.isExternalIdChanged()) {
|
if (command.isExternalIdChanged()) {
|
||||||
this.externalId = StringUtils.defaultIfEmpty(externalId.trim(), null);
|
this.externalId = StringUtils.defaultIfEmpty(command.getExternalId().trim(), null);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
+68
-38
@@ -11,16 +11,22 @@ import org.mifosng.platform.client.domain.NoteRepository;
|
|||||||
import org.mifosng.platform.exceptions.ClientNotFoundException;
|
import org.mifosng.platform.exceptions.ClientNotFoundException;
|
||||||
import org.mifosng.platform.exceptions.NoteNotFoundException;
|
import org.mifosng.platform.exceptions.NoteNotFoundException;
|
||||||
import org.mifosng.platform.exceptions.OfficeNotFoundException;
|
import org.mifosng.platform.exceptions.OfficeNotFoundException;
|
||||||
|
import org.mifosng.platform.exceptions.PlatformDataIntegrityException;
|
||||||
import org.mifosng.platform.organisation.domain.Office;
|
import org.mifosng.platform.organisation.domain.Office;
|
||||||
import org.mifosng.platform.organisation.domain.OfficeRepository;
|
import org.mifosng.platform.organisation.domain.OfficeRepository;
|
||||||
import org.mifosng.platform.security.PlatformSecurityContext;
|
import org.mifosng.platform.security.PlatformSecurityContext;
|
||||||
|
import org.slf4j.Logger;
|
||||||
|
import org.slf4j.LoggerFactory;
|
||||||
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.beans.factory.annotation.Autowired;
|
||||||
|
import org.springframework.dao.DataIntegrityViolationException;
|
||||||
import org.springframework.stereotype.Service;
|
import org.springframework.stereotype.Service;
|
||||||
import org.springframework.transaction.annotation.Transactional;
|
import org.springframework.transaction.annotation.Transactional;
|
||||||
|
|
||||||
@Service
|
@Service
|
||||||
public class ClientWritePlatformServiceJpaRepositoryImpl implements ClientWritePlatformService {
|
public class ClientWritePlatformServiceJpaRepositoryImpl implements ClientWritePlatformService {
|
||||||
|
|
||||||
|
private final static Logger logger = LoggerFactory.getLogger(ClientWritePlatformServiceJpaRepositoryImpl.class);
|
||||||
|
|
||||||
private final PlatformSecurityContext context;
|
private final PlatformSecurityContext context;
|
||||||
private final ClientRepository clientRepository;
|
private final ClientRepository clientRepository;
|
||||||
private final OfficeRepository officeRepository;
|
private final OfficeRepository officeRepository;
|
||||||
@@ -50,61 +56,85 @@ public class ClientWritePlatformServiceJpaRepositoryImpl implements ClientWriteP
|
|||||||
return new EntityIdentifier(client.getId());
|
return new EntityIdentifier(client.getId());
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/*
|
||||||
|
* Guaranteed to throw an exception no matter what the data integrity issue is.
|
||||||
|
*/
|
||||||
|
private void handleDataIntegrityIssues(final ClientCommand command, final DataIntegrityViolationException dve) {
|
||||||
|
|
||||||
|
Throwable realCause = dve.getMostSpecificCause();
|
||||||
|
if (realCause.getMessage().contains("external_id")) {
|
||||||
|
throw new PlatformDataIntegrityException("error.msg.client.duplicate.externalId", "Client with externalId `"+ command.getExternalId() +"` already exists", "externalId", command.getExternalId());
|
||||||
|
}
|
||||||
|
|
||||||
|
logger.error(dve.getMessage(), dve);
|
||||||
|
throw new PlatformDataIntegrityException("error.msg.client.unknown.data.integrity.issue", "Unknown data integrity issue with resource.");
|
||||||
|
}
|
||||||
|
|
||||||
@Transactional
|
@Transactional
|
||||||
@Override
|
@Override
|
||||||
public Long enrollClient(final ClientCommand command) {
|
public Long enrollClient(final ClientCommand command) {
|
||||||
|
|
||||||
context.authenticatedUser();
|
try{
|
||||||
|
context.authenticatedUser();
|
||||||
|
|
||||||
ClientCommandValidator validator = new ClientCommandValidator(command);
|
ClientCommandValidator validator = new ClientCommandValidator(command);
|
||||||
validator.validateForCreate();
|
validator.validateForCreate();
|
||||||
|
|
||||||
Office clientOffice = this.officeRepository.findOne(command.getOfficeId());
|
Office clientOffice = this.officeRepository.findOne(command.getOfficeId());
|
||||||
if (clientOffice == null) {
|
if (clientOffice == null) {
|
||||||
throw new OfficeNotFoundException(command.getOfficeId());
|
throw new OfficeNotFoundException(command.getOfficeId());
|
||||||
|
}
|
||||||
|
|
||||||
|
String firstname = command.getFirstname();
|
||||||
|
String lastname = command.getLastname();
|
||||||
|
if (StringUtils.isNotBlank(command.getClientOrBusinessName())) {
|
||||||
|
lastname = command.getClientOrBusinessName();
|
||||||
|
firstname = null;
|
||||||
|
}
|
||||||
|
|
||||||
|
Client newClient = Client.newClient(clientOffice, firstname, lastname, command.getJoiningDate(), command.getExternalId());
|
||||||
|
|
||||||
|
this.clientRepository.save(newClient);
|
||||||
|
|
||||||
|
return newClient.getId();
|
||||||
|
} catch (DataIntegrityViolationException dve) {
|
||||||
|
handleDataIntegrityIssues(command, dve);
|
||||||
|
return Long.valueOf(-1);
|
||||||
}
|
}
|
||||||
|
|
||||||
String firstname = command.getFirstname();
|
|
||||||
String lastname = command.getLastname();
|
|
||||||
if (StringUtils.isNotBlank(command.getClientOrBusinessName())) {
|
|
||||||
lastname = command.getClientOrBusinessName();
|
|
||||||
firstname = null;
|
|
||||||
}
|
|
||||||
|
|
||||||
Client newClient = Client.newClient(clientOffice, firstname, lastname, command.getJoiningDate(), command.getExternalId());
|
|
||||||
|
|
||||||
this.clientRepository.save(newClient);
|
|
||||||
|
|
||||||
return newClient.getId();
|
|
||||||
}
|
}
|
||||||
|
|
||||||
@Transactional
|
@Transactional
|
||||||
@Override
|
@Override
|
||||||
public EntityIdentifier updateClientDetails(final ClientCommand command) {
|
public EntityIdentifier updateClientDetails(final ClientCommand command) {
|
||||||
|
|
||||||
context.authenticatedUser();
|
try {
|
||||||
|
context.authenticatedUser();
|
||||||
|
|
||||||
ClientCommandValidator validator = new ClientCommandValidator(command);
|
ClientCommandValidator validator = new ClientCommandValidator(command);
|
||||||
validator.validateForUpdate();
|
validator.validateForUpdate();
|
||||||
|
|
||||||
Office clientOffice = null;
|
Office clientOffice = null;
|
||||||
Long officeId = command.getOfficeId();
|
Long officeId = command.getOfficeId();
|
||||||
if (command.isOfficeChanged() && officeId != null) {
|
if (command.isOfficeChanged() && officeId != null) {
|
||||||
clientOffice = this.officeRepository.findOne(officeId);
|
clientOffice = this.officeRepository.findOne(officeId);
|
||||||
if (clientOffice == null) {
|
if (clientOffice == null) {
|
||||||
throw new OfficeNotFoundException(command.getOfficeId());
|
throw new OfficeNotFoundException(command.getOfficeId());
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
Client clientForUpdate = this.clientRepository.findOne(command.getId());
|
||||||
|
if (clientForUpdate == null || clientForUpdate.isDeleted()) {
|
||||||
|
throw new ClientNotFoundException(command.getId());
|
||||||
|
}
|
||||||
|
clientForUpdate.update(clientOffice, command);
|
||||||
|
|
||||||
|
this.clientRepository.saveAndFlush(clientForUpdate);
|
||||||
|
|
||||||
|
return new EntityIdentifier(clientForUpdate.getId());
|
||||||
|
} catch (DataIntegrityViolationException dve) {
|
||||||
|
handleDataIntegrityIssues(command, dve);
|
||||||
|
return new EntityIdentifier(Long.valueOf(-1));
|
||||||
}
|
}
|
||||||
|
|
||||||
Client clientForUpdate = this.clientRepository.findOne(command.getId());
|
|
||||||
if (clientForUpdate == null || clientForUpdate.isDeleted()) {
|
|
||||||
throw new ClientNotFoundException(command.getId());
|
|
||||||
}
|
|
||||||
clientForUpdate.update(clientOffice, command);
|
|
||||||
|
|
||||||
this.clientRepository.save(clientForUpdate);
|
|
||||||
|
|
||||||
return new EntityIdentifier(clientForUpdate.getId());
|
|
||||||
}
|
}
|
||||||
|
|
||||||
@Transactional
|
@Transactional
|
||||||
|
|||||||
Reference in New Issue
Block a user