E-mail de notificação de pendências de acerto

public class DadosEmailGestorCustomizado extends DadosEmailGestor {

@Override

public List<ItemEmailPendencia> montaListaPendencias() {

String queryPendencias = "SELECT R066PEN.NUMEMP, R066PEN.TIPCOL, R066PEN.NUMCAD, R066PEN.DATAPU FROM R066PEN R066PEN WHERE R066PEN.SITPEN IN (3,4, 5) AND DATAPU BETWEEN ? AND ? ORDER BY NUMEMP, TIPCOL, NUMCAD";

DataAccessor dataAccessor = new DataAccessor(ContextSession.getSession());

// Executa o select para retornar os colaboradores que possuem pendência dos últimos 30 dias

IResultSet resultSet = dataAccessor.runQueryRS(queryPendencias, new LocalDate().minusDays(30), new LocalDate());

Map<Colaborador, Colaborador> cacheGestores = new HashMap<Colaborador, Colaborador>();

Map<Colaborador, ItemEmailPendencia> listaPendencias = new HashMap<Colaborador, ItemEmailPendencia>();

ItemEmailPendencia itemEmailGestor = null;

Map<Integer, IR044CAL> cacheCodigoCalculo = new HashMap<>();

Colaborador chefe = null;

while (resultSet.next()) {

Colaborador colaborador = new Colaborador(resultSet.getBigDecimal(0).intValue(), resultSet.getBigDecimal(1).intValue(), resultSet.getBigDecimal(2).intValue());

// Cria um cache de gestores por colaborador

if (!cacheGestores.containsKey(colaborador)) {

chefe = buscarChefe(colaborador);

cacheGestores.put(colaborador, chefe);

} else {

chefe = cacheGestores.get(colaborador);

}

IR044CAL codigoCalculo = null;

// Cria um cache de código de cálculo por empresa

if (cacheCodigoCalculo.get(colaborador.getNumEmp()) == null) {

codigoCalculo = buscarCodigoCalculo(colaborador.getNumEmp(), new LocalDate(2019, 3, 1));

cacheCodigoCalculo.put(colaborador.getNumEmp(), codigoCalculo);

} else {

codigoCalculo = cacheCodigoCalculo.get(colaborador.getNumEmp());

}

if(chefe != null) {

// Todo ItemEmailPendencia é um 'gestor' e dentro desse objeto deve ser preenchido os campos abaixo como

// Inicio e Fim do período, data limite de acertos as pendências dos liderados

itemEmailGestor = new ItemEmailPendencia(chefe.getNumEmp(), chefe.getTipCol(), chefe.getNumCad(), "nomeUsuarioChefe", "juan.wippel@senior.com.br", new ArrayList<PendenciaLiderado>());

if(!listaPendencias.containsKey(chefe)){

itemEmailGestor.setDataIniciPeriodoPendente(codigoCalculo.getIniApu());

itemEmailGestor.setDataFimPeriodoPendente(codigoCalculo.getFimApu());

itemEmailGestor.setDataLimite(codigoCalculo.getFimApu());

listaPendencias.put(chefe, itemEmailGestor);

} else {

itemEmailGestor = listaPendencias.get(chefe);

}

}

if (itemEmailGestor != null) {

//O objeto PendenciaLiderado é referente a pendência do liderado e deve ser adicionado ao ItemEmailPendencia(gestor)

PendenciaLiderado pendenciaLiderado = new PendenciaLiderado(colaborador.getNumEmp(), colaborador.getTipCol(), colaborador.getNumCad());

if(!itemEmailGestor.getPendencias().contains(pendenciaLiderado)) {

pendenciaLiderado.setNome(getEmailColaborador(colaborador));

itemEmailGestor.getPendencias().add(pendenciaLiderado);

itemEmailGestor.setQtdPendencias(1);

} else {

itemEmailGestor.setQtdPendencias(itemEmailGestor.getQtdPendencias() + 1);

}

}

}

return new ArrayList<ItemEmailPendencia>(listaPendencias.values());

}

/**

* Busca o chefe do colaborador passado como parâmetro

*

* @param liderado

* @return

*/

private Colaborador buscarChefe(Colaborador liderado) {

/**Implementar aqui a busca de chefe para o colaborador passado como parâmetro

* Pode-se utilizar cursores, selects, dependendo de como cada cliente define os chefes

* de seus colaboradores*/

return new Colaborador(3, 1, 5);

}

/**

* Busca o código de cálculo baseado nos parâmetros

*

* @param numEmp

* @param data

* @return

*/

private IR044CAL buscarCodigoCalculo(int numEmp, LocalDate data) {

/**Esse método é apenas uma sugestão, os parâmetros e sua implementação

* podem ser alterados para atender cada caso*/

ICursor<IR044CAL> crCodigoCalculo = CursorUtil.getCursor(IR044CAL.class);

MappedParamProvider params = new MappedParamProvider();

params.setParam("NumEmp", numEmp);

params.setParam("Data", data);

crCodigoCalculo.addFilter("NumEmp = :NumEmp and :Data between IniApu and FimApu", params);

crCodigoCalculo.open();

try {

if (crCodigoCalculo.first()) {

return crCodigoCalculo.read();

}

} finally {

crCodigoCalculo.close();

}

return null;

}

/**

* Busca o email do colaborador passado como parâmetro

*

* @param colaborador

* @return

*/

private String getEmailColaborador(Colaborador colaborador) {

MappedParamProvider params = new MappedParamProvider();

params.setParam("NumEmp", colaborador.getNumEmp());

params.setParam("TipCol", colaborador.getTipCol());

params.setParam("NumCad", colaborador.getNumCad());

ICursor<IColaboradorPonto> crColaborador = CursorUtil.getCursor(IColaboradorPonto.class);

crColaborador.addFilter("NumEmp = :NumEmp and TipCol = :TipCol and NumCad = :NumCad", params);

crColaborador.open();

try {

if (crColaborador.first()) {

return crColaborador.read().getNomFun();

}

} finally {

crColaborador.close();

}

return null;

}

}

public class DadosEmailLideradoCustomizado extends DadosEmailLiderado {

@Override

public List<ItemEmailPendencia> montaListaPendencias() {

String queryPendencias = "SELECT R066PEN.NUMEMP, R066PEN.TIPCOL, R066PEN.NUMCAD, R066PEN.DATAPU, R066PEN.DATEXP FROM R066PEN R066PEN WHERE R066PEN.SITPEN IN (3,4, 5) AND DATAPU BETWEEN ? AND ? ORDER BY NUMEMP, TIPCOL, NUMCAD";

DataAccessor dataAccessor = new DataAccessor(ContextSession.getSession());

// Executa o select para retornar os colaboradores que possuem pendência dos últimos 30 dias

IResultSet resultSet = dataAccessor.runQueryRS(queryPendencias, new LocalDate().minusDays(30), new LocalDate());

Map<Integer, IR044CAL> cacheCodigoCalculo = new HashMap<>();

IColaboradorPonto colaboradorPonto = null;

Map<Colaborador, ItemEmailPendencia> cacheLiderados = new HashMap<Colaborador, ItemEmailPendencia>();

while (resultSet.next()) {

Colaborador colaborador = new Colaborador(resultSet.getBigDecimal(0).intValue(), resultSet.getBigDecimal(1).intValue(), resultSet.getBigDecimal(2).intValue());

LocalDate datApu = resultSet.getDateTime(3).toLocalDate();

LocalDate datExp = resultSet.getDateTime(4).toLocalDate();

IR044CAL codigoCalculo = null;

// Cria um cache de código de cálculo por empresa

if (cacheCodigoCalculo.get(colaborador.getNumEmp()) == null) {

codigoCalculo = buscarCodigoCalculo(colaborador.getNumEmp(), new LocalDate(2019, 3, 1));

cacheCodigoCalculo.put(colaborador.getNumEmp(), codigoCalculo);

} else {

codigoCalculo = cacheCodigoCalculo.get(colaborador.getNumEmp());

}

ItemEmailPendencia itemEmailLiderado = cacheLiderados.get(colaborador);

if (itemEmailLiderado == null) {

MappedParamProvider params = new MappedParamProvider();

params.setParam("NumEmp", colaborador.getNumEmp());

params.setParam("TipCol", colaborador.getTipCol());

params.setParam("NumCad", colaborador.getNumCad());

ICursor<IColaboradorPonto> crColaborador = CursorUtil.getCursor(IColaboradorPonto.class);

crColaborador.addFilter("NumEmp=:NumEmp and TipCol=:TipCol and NumCad=:NumCad", params);

crColaborador.open();

try {

if (!crColaborador.first()) {

continue;

}

if (colaboradorPonto == null) {

colaboradorPonto = crColaborador.read();

} else {

crColaborador.read(colaboradorPonto);

}

} finally {

crColaborador.close();

}

// Cada ItemEmailPendencia é um colaborador

itemEmailLiderado = new ItemEmailPendencia(colaborador.getNumEmp(), colaborador.getTipCol(), colaborador.getNumCad(), colaboradorPonto.getNomFun(), colaboradorPonto.getEmaCom(), new ArrayList<PendenciaLiderado>());

itemEmailLiderado.setDataIniciPeriodoPendente(codigoCalculo.getIniApu());

itemEmailLiderado.setDataFimPeriodoPendente(codigoCalculo.getFimApu());

itemEmailLiderado.setDataLimite(codigoCalculo.getFimApu());

}

// PendenciaLiderado representa a pendência de um liderado e deve ser adicionado a lista de pendências do ItemEmailPendencia

PendenciaLiderado pendenciaLiderado = new PendenciaLiderado(colaborador.getNumEmp(), colaborador.getTipCol(), colaborador.getNumCad());

pendenciaLiderado.setDataPendencia(datApu);

pendenciaLiderado.setDataExpiracao(datExp);

itemEmailLiderado.getPendencias().add(pendenciaLiderado);

cacheLiderados.put(colaborador, itemEmailLiderado);

}

return new ArrayList<ItemEmailPendencia>(cacheLiderados.values());

}

/**

* Busca o código de cálculo baseado nos parâmetros

*

* @param numEmp

* @param data

* @return

*/

private IR044CAL buscarCodigoCalculo(int numEmp, LocalDate data) {

/**Esse método é apenas uma sugestão, os parâmetros e sua implementação

* podem ser alterados para atender cada caso*/

ICursor<IR044CAL> crCodigoCalculo = CursorUtil.getCursor(IR044CAL.class);

MappedParamProvider params = new MappedParamProvider();

params.setParam("NumEmp", numEmp);

params.setParam("Data", data);

crCodigoCalculo.addFilter("NumEmp = :NumEmp and :Data between IniApu and FimApu", params);

crCodigoCalculo.open();

try {

if (crCodigoCalculo.first()) {

return crCodigoCalculo.read();

}

} finally {

crCodigoCalculo.close();

}

return null;

}

}