Commit 3816c6e8 authored by Roberto Loayza's avatar Roberto Loayza

Update Models

parent 5ff47b23
...@@ -222,10 +222,12 @@ public class ScheduleService implements SchedulingConfigurer { ...@@ -222,10 +222,12 @@ public class ScheduleService implements SchedulingConfigurer {
futureMap.remove(key); futureMap.remove(key);
} }
if (!keys.isEmpty()) { if (!keys.isEmpty()) {
for (String Key: keys) { for (String keyTask: keys) {
ScheduledFuture future = futureMap.get(Key); if (!futureMap.get(keyTask).isCancelled()) {
future.cancel(true); ScheduledFuture future = futureMap.get(keyTask);
futureMap.remove(key); future.cancel(true);
futureMap.remove(keyTask);
}
} }
} }
} }
......
...@@ -58,7 +58,7 @@ public class DataSensibleJPAWriter implements ItemWriter<DynaBean>, StepExecutio ...@@ -58,7 +58,7 @@ public class DataSensibleJPAWriter implements ItemWriter<DynaBean>, StepExecutio
@Override @Override
@Transactional @Transactional
public void write(List<? extends DynaBean> list) throws Exception { public void write(List<? extends DynaBean> list) throws Exception {
Object numeros = JsonUtils.getFieldFromJson(agent.getChannelValue(), "$.telefonos_desplegados"); Object numeros = JsonUtils.getFieldFromJson(agent.getChannelValue(), "$.telefono_despliegue");
List<String> numerosAgentes = numbersAgent((List<Map>) numeros); List<String> numerosAgentes = numbersAgent((List<Map>) numeros);
for (DynaBean dynaBean : list) { for (DynaBean dynaBean : list) {
Long id = Long.parseLong(dynaBean.get("id").toString()); Long id = Long.parseLong(dynaBean.get("id").toString());
...@@ -75,7 +75,7 @@ public class DataSensibleJPAWriter implements ItemWriter<DynaBean>, StepExecutio ...@@ -75,7 +75,7 @@ public class DataSensibleJPAWriter implements ItemWriter<DynaBean>, StepExecutio
if (toAgent == null) { if (toAgent == null) {
continue; continue;
} }
if (toAgent.isEmpty()) { if (!toAgent.isEmpty()) {
agentNumber = toAgent.split(":")[1]; agentNumber = toAgent.split(":")[1];
} }
if (numerosAgentes.contains(agentNumber)) { if (numerosAgentes.contains(agentNumber)) {
...@@ -142,7 +142,7 @@ public class DataSensibleJPAWriter implements ItemWriter<DynaBean>, StepExecutio ...@@ -142,7 +142,7 @@ public class DataSensibleJPAWriter implements ItemWriter<DynaBean>, StepExecutio
private List<String> numbersAgent(List<Map> listNumber){ private List<String> numbersAgent(List<Map> listNumber){
List<String> result = new ArrayList<>(); List<String> result = new ArrayList<>();
for (Map map : listNumber){ for (Map map : listNumber){
String cod = (String) map.get("CodigoInternacional"); String cod = (String) map.get("codigoInternacional");
String number = (String) map.get("numero"); String number = (String) map.get("numero");
String agent = "+" + cod + number; String agent = "+" + cod + number;
result.add(agent); result.add(agent);
......
...@@ -164,7 +164,7 @@ public class UserMessageProcessed extends MessageProcessedSupport implements Mes ...@@ -164,7 +164,7 @@ public class UserMessageProcessed extends MessageProcessedSupport implements Mes
List<DeleteDataSensBean> deleteDataSensBeans = deleteDataSensJDBCRepository List<DeleteDataSensBean> deleteDataSensBeans = deleteDataSensJDBCRepository
.getListAgentChannel(AgentStatusEnum.DEPLOYED.getName(), AgentParameterEnum.ACCESS_TWILIO.getName()); .getListAgentChannel(AgentStatusEnum.DEPLOYED.getName(), AgentParameterEnum.ACCESS_TWILIO.getName());
for (DeleteDataSensBean deleteDataSensBean: deleteDataSensBeans) { for (DeleteDataSensBean deleteDataSensBean: deleteDataSensBeans) {
Object numeros = JsonUtils.getFieldFromJson(deleteDataSensBean.getChannelValue(), "$.telefonos_desplegados"); Object numeros = JsonUtils.getFieldFromJson(deleteDataSensBean.getChannelValue(), "$.telefono_despliegue");
List<String> numerosAgentes = numbersAgent((List<Map>) numeros); List<String> numerosAgentes = numbersAgent((List<Map>) numeros);
if (numerosAgentes.contains(number)) { if (numerosAgentes.contains(number)) {
agentId = deleteDataSensBean.getAgenId(); agentId = deleteDataSensBean.getAgenId();
...@@ -178,7 +178,7 @@ public class UserMessageProcessed extends MessageProcessedSupport implements Mes ...@@ -178,7 +178,7 @@ public class UserMessageProcessed extends MessageProcessedSupport implements Mes
private List<String> numbersAgent(List<Map> listNumber){ private List<String> numbersAgent(List<Map> listNumber){
List<String> result = new ArrayList<>(); List<String> result = new ArrayList<>();
for (Map map : listNumber){ for (Map map : listNumber){
String cod = (String) map.get("CodigoInternacional"); String cod = (String) map.get("codigoInternacional");
String number = (String) map.get("numero"); String number = (String) map.get("numero");
String agent = "+" + cod + number; String agent = "+" + cod + number;
result.add(agent); result.add(agent);
......
...@@ -8,11 +8,13 @@ import com.bytesw.bytebot.model.enums.AgentTypeEnum; ...@@ -8,11 +8,13 @@ import com.bytesw.bytebot.model.enums.AgentTypeEnum;
import com.bytesw.bytebot.model.enums.LanguageEnum; import com.bytesw.bytebot.model.enums.LanguageEnum;
import lombok.*; import lombok.*;
import org.hibernate.annotations.Type; import org.hibernate.annotations.Type;
import org.hibernate.envers.Audited;
import javax.persistence.*; import javax.persistence.*;
import java.io.Serializable; import java.io.Serializable;
import java.util.List; import java.util.List;
//@Audited
@Entity @Entity
@Getter @Setter @EqualsAndHashCode(of = "id") @Getter @Setter @EqualsAndHashCode(of = "id")
@NoArgsConstructor @NoArgsConstructor
......
...@@ -10,7 +10,7 @@ import javax.persistence.*; ...@@ -10,7 +10,7 @@ import javax.persistence.*;
import java.io.Serializable; import java.io.Serializable;
import java.util.List; import java.util.List;
//@Audited @Audited
@Entity @Entity
@Table(name = "AVB_CALENDAR") @Table(name = "AVB_CALENDAR")
@NamedQuery(name = "Calendar.findByPK", query = "Select u from Calendar u where u.id = ?1") @NamedQuery(name = "Calendar.findByPK", query = "Select u from Calendar u where u.id = ?1")
......
...@@ -13,7 +13,7 @@ import javax.persistence.*; ...@@ -13,7 +13,7 @@ import javax.persistence.*;
import java.io.Serializable; import java.io.Serializable;
import java.math.BigInteger; import java.math.BigInteger;
//@Audited @Audited
@Entity @Entity
@Inheritance( @Inheritance(
strategy = InheritanceType.SINGLE_TABLE strategy = InheritanceType.SINGLE_TABLE
......
...@@ -13,7 +13,6 @@ import java.math.BigInteger; ...@@ -13,7 +13,6 @@ import java.math.BigInteger;
import java.time.LocalDate; import java.time.LocalDate;
import java.time.OffsetDateTime; import java.time.OffsetDateTime;
//@Audited
@Entity @Entity
@Inheritance( @Inheritance(
strategy = InheritanceType.SINGLE_TABLE strategy = InheritanceType.SINGLE_TABLE
......
...@@ -4,6 +4,7 @@ import lombok.EqualsAndHashCode; ...@@ -4,6 +4,7 @@ import lombok.EqualsAndHashCode;
import lombok.Getter; import lombok.Getter;
import lombok.Setter; import lombok.Setter;
import lombok.ToString; import lombok.ToString;
import org.hibernate.envers.Audited;
import javax.persistence.*; import javax.persistence.*;
import java.util.List; import java.util.List;
...@@ -19,6 +20,7 @@ import java.util.List; ...@@ -19,6 +20,7 @@ import java.util.List;
* Confidencial y debe usarla de acuerdo con los términos de aceptación de * Confidencial y debe usarla de acuerdo con los términos de aceptación de
* licencia de uso que firmó con Byte. * licencia de uso que firmó con Byte.
*/ */
@Audited
@Entity @Entity
@Table(name = "AVB_CHANNEL") @Table(name = "AVB_CHANNEL")
@Getter @Setter @ToString @Getter @Setter @ToString
......
...@@ -5,6 +5,7 @@ import lombok.EqualsAndHashCode; ...@@ -5,6 +5,7 @@ import lombok.EqualsAndHashCode;
import lombok.Getter; import lombok.Getter;
import lombok.Setter; import lombok.Setter;
import lombok.ToString; import lombok.ToString;
import org.hibernate.envers.Audited;
import javax.persistence.*; import javax.persistence.*;
...@@ -19,6 +20,7 @@ import javax.persistence.*; ...@@ -19,6 +20,7 @@ import javax.persistence.*;
* Confidencial y debe usarla de acuerdo con los términos de aceptación de * Confidencial y debe usarla de acuerdo con los términos de aceptación de
* licencia de uso que firmó con Byte. * licencia de uso que firmó con Byte.
*/ */
@Audited
@Entity @Entity
@Table(name = "AVB_CHANNEL_PARAM") @Table(name = "AVB_CHANNEL_PARAM")
@Getter @Getter
......
package com.bytesw.bytebot.model; package com.bytesw.bytebot.model;
import lombok.*; import lombok.*;
import org.hibernate.envers.Audited;
import javax.persistence.*; import javax.persistence.*;
import java.util.List; import java.util.List;
@Audited
@Entity @Entity
@Getter @Getter
@Setter @Setter
......
...@@ -6,6 +6,7 @@ import lombok.EqualsAndHashCode; ...@@ -6,6 +6,7 @@ import lombok.EqualsAndHashCode;
import lombok.Getter; import lombok.Getter;
import lombok.Setter; import lombok.Setter;
import lombok.ToString; import lombok.ToString;
import org.hibernate.envers.Audited;
import javax.persistence.*; import javax.persistence.*;
import java.util.List; import java.util.List;
...@@ -21,6 +22,7 @@ import java.util.List; ...@@ -21,6 +22,7 @@ import java.util.List;
* Confidencial y debe usarla de acuerdo con los términos de aceptación de * Confidencial y debe usarla de acuerdo con los términos de aceptación de
* licencia de uso que firmó con Byte. * licencia de uso que firmó con Byte.
*/ */
//@Audited
@Entity @Entity
@Table(name = "AVB_DEPLOYMENT_CHANNEL") @Table(name = "AVB_DEPLOYMENT_CHANNEL")
@Getter @Getter
......
...@@ -4,6 +4,7 @@ import lombok.EqualsAndHashCode; ...@@ -4,6 +4,7 @@ import lombok.EqualsAndHashCode;
import lombok.Getter; import lombok.Getter;
import lombok.Setter; import lombok.Setter;
import lombok.ToString; import lombok.ToString;
import org.hibernate.envers.Audited;
import javax.persistence.*; import javax.persistence.*;
...@@ -18,6 +19,7 @@ import javax.persistence.*; ...@@ -18,6 +19,7 @@ import javax.persistence.*;
* Confidencial y debe usarla de acuerdo con los términos de aceptación de * Confidencial y debe usarla de acuerdo con los términos de aceptación de
* licencia de uso que firmó con Byte. * licencia de uso que firmó con Byte.
*/ */
//@Audited
@Entity @Entity
@Table(name = "AVB_DEPLOYMENT_CHANNEL_PARAM_VALUE") @Table(name = "AVB_DEPLOYMENT_CHANNEL_PARAM_VALUE")
@Getter @Getter
......
...@@ -8,6 +8,7 @@ import lombok.EqualsAndHashCode; ...@@ -8,6 +8,7 @@ import lombok.EqualsAndHashCode;
import lombok.Getter; import lombok.Getter;
import lombok.Setter; import lombok.Setter;
import lombok.ToString; import lombok.ToString;
import org.hibernate.envers.Audited;
import javax.persistence.*; import javax.persistence.*;
import java.time.LocalDateTime; import java.time.LocalDateTime;
...@@ -24,6 +25,7 @@ import java.time.OffsetDateTime; ...@@ -24,6 +25,7 @@ import java.time.OffsetDateTime;
* Confidencial y debe usarla de acuerdo con los términos de aceptación de * Confidencial y debe usarla de acuerdo con los términos de aceptación de
* licencia de uso que firmó con Byte. * licencia de uso que firmó con Byte.
*/ */
//@Audited
@Entity @Entity
@Table(name = "AVB_FREQUENT_QUESTION") @Table(name = "AVB_FREQUENT_QUESTION")
@Getter @Getter
......
...@@ -9,7 +9,7 @@ import org.hibernate.envers.Audited; ...@@ -9,7 +9,7 @@ import org.hibernate.envers.Audited;
import javax.persistence.*; import javax.persistence.*;
import java.io.Serializable; import java.io.Serializable;
//@Audited @Audited
@Entity @Entity
@Table(name = "avb_process_etl") @Table(name = "avb_process_etl")
@NamedQuery(name = "ProcessETL.findByPK", query = "Select u from ProcessETL u where u.id = ?1") @NamedQuery(name = "ProcessETL.findByPK", query = "Select u from ProcessETL u where u.id = ?1")
......
...@@ -14,7 +14,9 @@ import lombok.NoArgsConstructor; ...@@ -14,7 +14,9 @@ import lombok.NoArgsConstructor;
import lombok.Setter; import lombok.Setter;
import lombok.ToString; import lombok.ToString;
import org.hibernate.annotations.Type; import org.hibernate.annotations.Type;
import org.hibernate.envers.Audited;
//@Audited
@Entity @Entity
@Getter @Getter
@Setter @Setter
......
...@@ -12,7 +12,7 @@ import javax.persistence.Entity; ...@@ -12,7 +12,7 @@ import javax.persistence.Entity;
import javax.persistence.NamedQuery; import javax.persistence.NamedQuery;
import java.time.OffsetDateTime; import java.time.OffsetDateTime;
//@Audited @Audited
@Entity @Entity
@DiscriminatorValue(value= RangeCalendarException.DISCRIMINATOR_VALUE) @DiscriminatorValue(value= RangeCalendarException.DISCRIMINATOR_VALUE)
@NamedQuery(name = "RangeCalendarException.findByPK", query = "Select u from RangeCalendarException u where u.id = ?1") @NamedQuery(name = "RangeCalendarException.findByPK", query = "Select u from RangeCalendarException u where u.id = ?1")
......
...@@ -13,7 +13,7 @@ import javax.persistence.*; ...@@ -13,7 +13,7 @@ import javax.persistence.*;
import java.io.Serializable; import java.io.Serializable;
import java.math.BigInteger; import java.math.BigInteger;
//@Audited @Audited
@Entity @Entity
@Table(name = "AVB_SCHEDULER_TASK") @Table(name = "AVB_SCHEDULER_TASK")
@NamedQuery(name = "SchedulerTask.findByPK", query = "Select u from SchedulerTask u where u.id = ?1") @NamedQuery(name = "SchedulerTask.findByPK", query = "Select u from SchedulerTask u where u.id = ?1")
......
package com.bytesw.bytebot.model; package com.bytesw.bytebot.model;
import lombok.*; import lombok.*;
import org.hibernate.envers.Audited;
import javax.persistence.*; import javax.persistence.*;
...@@ -15,7 +16,7 @@ import javax.persistence.*; ...@@ -15,7 +16,7 @@ import javax.persistence.*;
* Confidencial y debe usarla de acuerdo con los términos de aceptación de * Confidencial y debe usarla de acuerdo con los términos de aceptación de
* licencia de uso que firmó con Byte. * licencia de uso que firmó con Byte.
*/ */
@Audited
@Entity @Entity
@Getter @Setter @Getter @Setter
@NoArgsConstructor @NoArgsConstructor
......
...@@ -12,7 +12,7 @@ import javax.persistence.Entity; ...@@ -12,7 +12,7 @@ import javax.persistence.Entity;
import javax.persistence.NamedQuery; import javax.persistence.NamedQuery;
import java.time.LocalDate; import java.time.LocalDate;
//@Audited @Audited
@Entity @Entity
@DiscriminatorValue(value= UniqueCalendarException.DISCRIMINATOR_VALUE) @DiscriminatorValue(value= UniqueCalendarException.DISCRIMINATOR_VALUE)
@NamedQuery(name = "UniqueCalendarException.findByPK", query = "Select u from UniqueCalendarException u where u.id = ?1") @NamedQuery(name = "UniqueCalendarException.findByPK", query = "Select u from UniqueCalendarException u where u.id = ?1")
......
...@@ -11,7 +11,7 @@ import javax.persistence.DiscriminatorValue; ...@@ -11,7 +11,7 @@ import javax.persistence.DiscriminatorValue;
import javax.persistence.Entity; import javax.persistence.Entity;
import javax.persistence.NamedQuery; import javax.persistence.NamedQuery;
//@Audited @Audited
@Entity @Entity
@DiscriminatorValue(value= UniqueWeeklyCalendarException.DISCRIMINATOR_VALUE) @DiscriminatorValue(value= UniqueWeeklyCalendarException.DISCRIMINATOR_VALUE)
@NamedQuery(name = "UniqueWeeklyCalendarException.findByPK", query = "Select u from UniqueWeeklyCalendarException u where u.id = ?1") @NamedQuery(name = "UniqueWeeklyCalendarException.findByPK", query = "Select u from UniqueWeeklyCalendarException u where u.id = ?1")
......
...@@ -14,7 +14,7 @@ import java.math.BigInteger; ...@@ -14,7 +14,7 @@ import java.math.BigInteger;
import java.time.OffsetDateTime; import java.time.OffsetDateTime;
import java.time.OffsetTime; import java.time.OffsetTime;
//@Audited @Audited
@Entity @Entity
@Table(name = "AVB_WEEK_SCHEDULER") @Table(name = "AVB_WEEK_SCHEDULER")
@NamedQuery(name = "WeekScheduler.findByPK", query = "Select u from WeekScheduler u where u.id = ?1") @NamedQuery(name = "WeekScheduler.findByPK", query = "Select u from WeekScheduler u where u.id = ?1")
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment