Update Writter Process

src/main/java/com/bytesw/bytebot/etl/batch/writer/DataSensibleJPAWriter.java

@@ -61,13 +61,14 @@ public class DataSensibleJPAWriter implements ItemWriter<DynaBean>, StepExecutio
     @Transactional
     public void write(List<? extends DynaBean> list) throws Exception {
         for (DynaBean dynaBean : list) {
-            Long id = (Long) dynaBean.get("id");
+            Long id =  Long.parseLong(dynaBean.get("id").toString());
             String json = (String) dynaBean.get("data");
             String event = (String) JsonUtils.getFieldFromJson(json, "$.event");
             if (EventTypeEnum.USER.getName().equals(event)) {
                 String toAgent = (String) JsonUtils.getFieldFromJson(json, "$.metadata.To");
                 if (agent.getChannelValue().equals(toAgent)) {
                     String intent = (String) JsonUtils.getFieldFromJson(json, "$.parse_data.intent.name");
+                    //log.debug();
                     if (intentByAgent.indexOf(intent) >= 0) {
                         String SmSMessageSid = (String) JsonUtils.getFieldFromJson(json, "$.metadata.SmsMessageSid");
 

src/main/java/com/bytesw/bytebot/etl/dao/DeleteDataSensibleControlRepository.java

@@ -9,6 +9,6 @@ import java.util.Optional;
 
 public interface DeleteDataSensibleControlRepository extends CrudRepository<DeleteDataSensibleControl, Long> {
 
-    @Query("SELECT s from avb_delete_sens_msg_control s WHERE s.agentId = :agentId")
+    @Query("SELECT s from DeleteDataSensibleControl s WHERE s.agentId = :agentId")
     Optional<DeleteDataSensibleControl> findEventIdByAgentId(@Param("agentId") Long agentId);
 }

src/main/java/com/bytesw/bytebot/etl/dao/IntentRepository.java

@@ -11,7 +11,7 @@ import java.util.Optional;
 public interface IntentRepository extends CrudRepository<Intent, Long> {
     Optional<Intent> findByIdentifier(String identifier);
 
-    @Query("SELECT s from avb_intent s WHERE s.identifier = :intenIdent and  s.agenId = :agenId")
+    @Query("SELECT s from Intent s WHERE s.identifier = :intenIdent and  s.agenId = :agenId")
     Optional<IntentBean> findIntenNameById(@Param("intenIdent") String intenIdent, @Param("agenId") Long agenId);
 
 }