Corrige serviço listar unidades do processo

O serviço estava inconsistente e não considerava a tarefa conclusão automatica. Em alguns casos unidades onde o processo estava concluído eram retornadas.

Corrige serviço listar unidades do processo
O serviço estava inconsistente e não considerava a tarefa conclusão automatica. Em alguns casos unidades onde o processo estava concluído eram retornadas.
andre.guimaraes
1 parent 417b7ae2
Showing 2 changed files with 49 additions and 25 deletions Show diff stats
src/main/java/br/gov/ans/integracao/sei/dao/UnidadeDAO.java
src/main/java/br/gov/ans/integracao/sei/modelo/UnidadeTarefa.java
@@ -2,6 +2,7 @@ package br.gov.ans.integracao.sei.dao;
 import java.util.List;
 import java.util.function.Predicate;
+import java.util.stream.Collector;
 import java.util.stream.Collectors;
 import javax.persistence.EntityManager;
@@ -20,11 +21,12 @@ public class UnidadeDAO {
 	private static final int CONCLUSAO_PROCESSO = 28;
 	private static final int REABERTURA_PROCESSO = 29;
 	private static final int ENVIO_PROCESSO = 32;
+	private static final int CONCLUSAO_AUTOMATICA = 41;
 	private static final int RECEBIMENTO_PROCESSO = 48;
-	
+
 	public List<Unidade> listarUnidadesProcesso(String idProcedimento){
 		StringBuilder sql = new StringBuilder("SELECT u.id_unidade idUnidade, u.sigla, u.descricao, u.sin_protocolo sinProtocolo, ");
-		sql.append("u.sin_arquivamento sinArquivamento, u.sin_ouvidoria sinOuvidoria, t.id_tarefa tarefa ");
+		sql.append("u.sin_arquivamento sinArquivamento, u.sin_ouvidoria sinOuvidoria, t.id_tarefa tarefa, a.dth_abertura data ");
 		sql.append("FROM protocolo p ");
 		sql.append("JOIN atividade a ON p.id_protocolo = a.id_protocolo ");
 		sql.append("JOIN unidade u ON a.id_unidade = u.id_unidade ");
@@ -32,43 +34,50 @@ public class UnidadeDAO {
 		sql.append("WHERE p.id_protocolo = :protocolo ");
 		sql.append("and t.id_tarefa in (");
 		sql.append(ABERTURA_PROCESSO + ",");
-		sql.append(CONCLUSAO_PROCESSO + ",");
 		sql.append(REABERTURA_PROCESSO + ",");
+		sql.append(CONCLUSAO_PROCESSO + ",");
 		sql.append(ENVIO_PROCESSO + ",");
+		sql.append(CONCLUSAO_AUTOMATICA + ",");
 		sql.append(RECEBIMENTO_PROCESSO);
 		sql.append(") ");
 		sql.append("order by a.dth_abertura desc ");
 		Query query = em.createNativeQuery(sql.toString(), UnidadeTarefa.class);
-		
 		query.setParameter("protocolo", idProcedimento);
 		List<UnidadeTarefa> resultado = query.getResultList();
+
+		resultado = removeUnidadesProcessoConcluido(resultado);
-		List<Unidade> unidades = resultado.stream()
-			.filter(makeUntil(u -> u.getTarefa() == 28))
-			.distinct()
-			.filter(u -> u.getTarefa() != 28)
-			.collect(Collectors.toList());
+		resultado = removeRegistrosDeTarefasDeConclusao(resultado);
-		return unidades;
+		return convertParaListUnidadeRemovendoDuplicidades(resultado);
 	}
-	public static <T> Predicate<T> makeUntil(final Predicate<T> predicate) {
-	    return new Predicate<T>() {
-
-	        private boolean hasMatched;
+	private List<UnidadeTarefa> removeUnidadesProcessoConcluido(List<UnidadeTarefa> unidades){
+		unidades.removeIf(u -> unidades.stream()
+				.filter(c -> (c.getTarefa() == CONCLUSAO_PROCESSO || c.getTarefa() == CONCLUSAO_AUTOMATICA))
+				.anyMatch(r -> 
+					(
+						r.getIdUnidade() == u.getIdUnidade() && 
+						r.getData().after(u.getData())
+					)
+			));
+		
+		return unidades;
+	}
-	        @Override
-	        public boolean test(final T s) {
-	            if (hasMatched) {
-	                return false;
-	            }
-	            else {
-	                hasMatched = predicate.test(s);
-	                return true;
-	            }
-	        }
-	    };
+	private List<UnidadeTarefa> removeRegistrosDeTarefasDeConclusao(List<UnidadeTarefa> unidades){
+		return unidades.stream()
+					.filter(u -> u.getTarefa() != CONCLUSAO_PROCESSO)
+					.filter(u -> u.getTarefa() != CONCLUSAO_AUTOMATICA)
+				.collect(Collectors.toList());
+	}
+	
+	private List<Unidade> convertParaListUnidadeRemovendoDuplicidades(List<UnidadeTarefa> unidades){
+		return unidades.stream()
+				.map(u -> (Unidade) u)
+				.distinct()
+				.collect(Collectors.toList());
 	}
 }
 package br.gov.ans.integracao.sei.modelo;
+import java.util.Date;
+
 import javax.persistence.Entity;
 import org.codehaus.jackson.annotate.JsonIgnore;
@@ -11,6 +13,9 @@ public class UnidadeTarefa extends Unidade{
 	@JsonIgnore
 	private int tarefa;
+	
+	@JsonIgnore
+	private Date data;
 	@JsonIgnore
 	public int getTarefa() {
@@ -21,4 +26,14 @@ public class UnidadeTarefa extends Unidade{
 	public void setTarefa(int tarefa) {
 		this.tarefa = tarefa;
 	}
+
+	@JsonIgnore
+	public Date getData() {
+		return data;
+	}
+
+	@JsonIgnore
+	public void setData(Date data) {
+		this.data = data;
+	}
 }
 \ No newline at end of file
1	package br.gov.ans.integracao.sei.modelo;	1	package br.gov.ans.integracao.sei.modelo;
2		2
		3	+import java.util.Date;
		4	+
3	import javax.persistence.Entity;	5	import javax.persistence.Entity;
4		6
5	import org.codehaus.jackson.annotate.JsonIgnore;	7	import org.codehaus.jackson.annotate.JsonIgnore;
	@@ -11,6 +13,9 @@ public class UnidadeTarefa extends Unidade{		@@ -11,6 +13,9 @@ public class UnidadeTarefa extends Unidade{
11		13
12	@JsonIgnore	14	@JsonIgnore
13	private int tarefa;	15	private int tarefa;
		16	+
		17	+ @JsonIgnore
		18	+ private Date data;
14		19
15	@JsonIgnore	20	@JsonIgnore
16	public int getTarefa() {	21	public int getTarefa() {
	@@ -21,4 +26,14 @@ public class UnidadeTarefa extends Unidade{		@@ -21,4 +26,14 @@ public class UnidadeTarefa extends Unidade{
21	public void setTarefa(int tarefa) {	26	public void setTarefa(int tarefa) {
22	this.tarefa = tarefa;	27	this.tarefa = tarefa;
23	}	28	}
		29	+
		30	+ @JsonIgnore
		31	+ public Date getData() {
		32	+ return data;
		33	+ }
		34	+
		35	+ @JsonIgnore
		36	+ public void setData(Date data) {
		37	+ this.data = data;
		38	+ }
24	}	39	}
25	\ No newline at end of file	40	\ No newline at end of file