diff --git a/ems-core/src/main/java/it/integry/ems/migration/model/Migration_20251114150912.java b/ems-core/src/main/java/it/integry/ems/migration/model/Migration_20251114150912.java
new file mode 100644
index 0000000000..1615692ad9
--- /dev/null
+++ b/ems-core/src/main/java/it/integry/ems/migration/model/Migration_20251114150912.java
@@ -0,0 +1,19 @@
+package it.integry.ems.migration.model;
+
+import it.integry.ems.migration._base.BaseMigration;
+import it.integry.ems.migration._base.MigrationModelInterface;
+
+public class Migration_20251114150912 extends BaseMigration implements MigrationModelInterface {
+
+    @Override
+    public void up() throws Exception {
+        if (isHistoryDB())
+            return;
+
+        executeStatement("ALTER TABLE jtb_comt ADD data_mod DATETIME");
+    }
+
+    @Override
+    public void down() throws Exception {
+    }
+}
\ No newline at end of file
diff --git a/ems-core/src/main/java/it/integry/ems/migration/model/Migration_20251114163222.java b/ems-core/src/main/java/it/integry/ems/migration/model/Migration_20251114163222.java
new file mode 100644
index 0000000000..fd6a5efcc8
--- /dev/null
+++ b/ems-core/src/main/java/it/integry/ems/migration/model/Migration_20251114163222.java
@@ -0,0 +1,21 @@
+package it.integry.ems.migration.model;
+
+import it.integry.ems.migration._base.BaseMigration;
+import it.integry.ems.migration._base.MigrationModelInterface;
+
+public class Migration_20251114163222 extends BaseMigration implements MigrationModelInterface {
+
+    @Override
+    public void up() throws Exception {
+        if (isHistoryDB())
+            return;
+
+        executeStatement("ALTER TABLE vtb_dest ADD data_mod DATETIME");
+        executeStatement("ALTER TABLE ptb_pros ADD data_mod DATETIME");
+        executeStatement("ALTER TABLE ptb_pros_rif ADD data_mod DATETIME");
+    }
+
+    @Override
+    public void down() throws Exception {
+    }
+}
\ No newline at end of file
diff --git a/ems-core/src/main/java/it/integry/ems_model/entity/JtbComt.java b/ems-core/src/main/java/it/integry/ems_model/entity/JtbComt.java
index 82efb2be9d..9661ad580d 100644
--- a/ems-core/src/main/java/it/integry/ems_model/entity/JtbComt.java
+++ b/ems-core/src/main/java/it/integry/ems_model/entity/JtbComt.java
@@ -6,6 +6,7 @@ import it.integry.ems_model.annotation.*;
 import it.integry.ems_model.base.EntityBase;
 import org.kie.api.definition.type.PropertyReactive;
 import java.math.BigDecimal;
+import java.time.LocalDateTime;
 import java.util.Date;
 import java.util.List;
 import java.util.ArrayList;
@@ -132,6 +133,9 @@ public class JtbComt extends EntityBase {
     @SqlField(value = "rif_comm", maxLength = 255)
     private String rifComm;
 
+    @SqlField(value = "data_mod", defaultObjectValue = CommonConstants.TIMESTAMP)
+    private LocalDateTime dataMod;
+
     @EntityChild
     private List<JrlDisOrd> jrlDisOrd = new ArrayList<>();
 
@@ -468,6 +472,15 @@ public class JtbComt extends EntityBase {
         this.rifComm = rifComm;
     }
 
+    public LocalDateTime getDataMod() {
+        return dataMod;
+    }
+
+    public JtbComt setDataMod(LocalDateTime dataMod) {
+        this.dataMod = dataMod;
+        return this;
+    }
+
     public List<JrlDisOrd> getJrlDisOrd() {
         return jrlDisOrd;
     }
diff --git a/ems-core/src/main/java/it/integry/ems_model/entity/PtbPros.java b/ems-core/src/main/java/it/integry/ems_model/entity/PtbPros.java
index 2fa4e8dace..af649768a8 100644
--- a/ems-core/src/main/java/it/integry/ems_model/entity/PtbPros.java
+++ b/ems-core/src/main/java/it/integry/ems_model/entity/PtbPros.java
@@ -6,6 +6,7 @@ import it.integry.ems_model.annotation.*;
 import it.integry.ems_model.base.EntityBase;
 import org.kie.api.definition.type.PropertyReactive;
 import java.math.BigDecimal;
+import java.time.LocalDateTime;
 import java.util.Date;
 import java.util.List;
 import java.util.ArrayList;
@@ -153,6 +154,9 @@ public class PtbPros extends EntityBase {
     @SqlField(value = "flag_stato_pros", nullable = false, defaultObjectValue = "1")
     private Boolean flagStatoPros;
 
+    @SqlField(value = "data_mod", defaultObjectValue = CommonConstants.TIMESTAMP)
+    private LocalDateTime dataMod;
+
     @EntityChild
     private List<PtbProsRif> ptbProsRif = new ArrayList<>();
 
@@ -558,6 +562,15 @@ public class PtbPros extends EntityBase {
         this.flagStatoPros = flagStatoPros;
     }
 
+    public LocalDateTime getDataMod() {
+        return dataMod;
+    }
+
+    public PtbPros setDataMod(LocalDateTime dataMod) {
+        this.dataMod = dataMod;
+        return this;
+    }
+
     public List<PtbDest> getPtbDest() {
         return ptbDest;
     }
diff --git a/ems-core/src/main/java/it/integry/ems_model/entity/PtbProsRif.java b/ems-core/src/main/java/it/integry/ems_model/entity/PtbProsRif.java
index 3c051dd2ac..22f7bdeeb8 100644
--- a/ems-core/src/main/java/it/integry/ems_model/entity/PtbProsRif.java
+++ b/ems-core/src/main/java/it/integry/ems_model/entity/PtbProsRif.java
@@ -1,6 +1,7 @@
 package it.integry.ems_model.entity;
 
 import com.fasterxml.jackson.annotation.JsonTypeName;
+import it.integry.common.var.CommonConstants;
 import it.integry.ems_model.annotation.PK;
 import it.integry.ems_model.annotation.SqlDetailId;
 import it.integry.ems_model.annotation.SqlField;
@@ -10,6 +11,8 @@ import org.kie.api.definition.type.PropertyReactive;
 import org.apache.logging.log4j.LogManager;
 import org.apache.logging.log4j.Logger;
 
+import java.time.LocalDateTime;
+
 @PropertyReactive
 @Table(PtbProsRif.ENTITY)
 @JsonTypeName(PtbProsRif.ENTITY)
@@ -48,6 +51,9 @@ public class PtbProsRif extends EntityBase {
     @SqlField(value = "telefono", maxLength = 40)
     private String telefono;
 
+    @SqlField(value = "data_mod", defaultObjectValue = CommonConstants.TIMESTAMP)
+    private LocalDateTime dataMod;
+
     public PtbProsRif() {
         super(logger);
     }
@@ -123,4 +129,13 @@ public class PtbProsRif extends EntityBase {
         this.telefono = telefono;
         return this;
     }
+
+    public LocalDateTime getDataMod() {
+        return dataMod;
+    }
+
+    public PtbProsRif setDataMod(LocalDateTime dataMod) {
+        this.dataMod = dataMod;
+        return this;
+    }
 }
diff --git a/ems-core/src/main/java/it/integry/ems_model/entity/VtbDest.java b/ems-core/src/main/java/it/integry/ems_model/entity/VtbDest.java
index f6fe17fb1c..1b5e9d98ad 100644
--- a/ems-core/src/main/java/it/integry/ems_model/entity/VtbDest.java
+++ b/ems-core/src/main/java/it/integry/ems_model/entity/VtbDest.java
@@ -1,6 +1,7 @@
 package it.integry.ems_model.entity;
 
 import com.fasterxml.jackson.annotation.JsonTypeName;
+import it.integry.common.var.CommonConstants;
 import it.integry.ems_model.annotation.EntityChild;
 import it.integry.ems_model.annotation.PK;
 import it.integry.ems_model.annotation.SqlField;
@@ -12,6 +13,7 @@ import org.apache.logging.log4j.Logger;
 import org.kie.api.definition.type.PropertyReactive;
 
 import java.math.BigDecimal;
+import java.time.LocalDateTime;
 import java.util.ArrayList;
 import java.util.Date;
 import java.util.List;
@@ -225,6 +227,9 @@ public class VtbDest extends EntityBase implements EquatableEntityInterface<VtbD
     @SqlField(value = "stampa_doc_cons", nullable = false, defaultObjectValue = "0")
     private Boolean stampaDocCons;
 
+    @SqlField(value = "data_mod", defaultObjectValue = CommonConstants.TIMESTAMP)
+    private LocalDateTime dataMod;
+
     private String precode;
 
     @EntityChild
@@ -828,6 +833,15 @@ public class VtbDest extends EntityBase implements EquatableEntityInterface<VtbD
         return this;
     }
 
+    public LocalDateTime getDataMod() {
+        return dataMod;
+    }
+
+    public VtbDest setDataMod(LocalDateTime dataMod) {
+        this.dataMod = dataMod;
+        return this;
+    }
+
     @Override
     protected void insertChilds() throws Exception {
         for (VtbDestIntercode vtbDestIntercode : getVtbDestIntercode()) {
diff --git a/ems-core/src/main/resources/rules/anag.drl b/ems-core/src/main/resources/rules/anag.drl
index e5c76b9c1e..bca07a15b2 100644
--- a/ems-core/src/main/resources/rules/anag.drl
+++ b/ems-core/src/main/resources/rules/anag.drl
@@ -174,4 +174,28 @@ when
 	$entity: GtbAnagNote(dataIns == null)
 then
 	modify ( $entity ) { setDataIns(UtilityLocalDate.getNow()) }
+end
+
+rule "completeDataModVtbDest"
+when
+	eval(completeRulesEnabled)
+	$entity : VtbDest(operation != OperationType.DELETE)
+then
+	modify ( $entity ) { setDataMod(LocalDateTime.now()) }
+end
+
+rule "completeDataModPtbPros"
+when
+	eval(completeRulesEnabled)
+	$entity : PtbPros(operation != OperationType.DELETE)
+then
+	modify ( $entity ) { setDataMod(LocalDateTime.now()) }
+end
+
+rule "completeDataModPtbProsRif"
+when
+	eval(completeRulesEnabled)
+	$entity : PtbProsRif(operation != OperationType.DELETE)
+then
+	modify ( $entity ) { setDataMod(LocalDateTime.now()) }
 end
\ No newline at end of file
diff --git a/ems-core/src/main/resources/rules/commesse.drl b/ems-core/src/main/resources/rules/commesse.drl
index 4d45fc3191..9e432685b5 100644
--- a/ems-core/src/main/resources/rules/commesse.drl
+++ b/ems-core/src/main/resources/rules/commesse.drl
@@ -65,3 +65,13 @@ then
 	String tipoAnag = CommesseRules.completeTipoAnag(conn, $comT.getCodAnag());
 	modify($comT) {setTipoAnag(tipoAnag)}
 end
+
+rule "completeDataMod"
+when
+	eval(completeRulesEnabled)
+	$entity : JtbComt(operation != OperationType.DELETE)
+then
+	modify ( $entity ) {
+	    setDataMod(LocalDateTime.now())
+	}
+end
\ No newline at end of file
diff --git a/ems-engine/src/main/java/it/integry/ems/order/crm/dto/CRMAnagRequestDTO.java b/ems-engine/src/main/java/it/integry/ems/order/crm/dto/CRMAnagRequestDTO.java
index 025bd89aa4..6d120037bf 100644
--- a/ems-engine/src/main/java/it/integry/ems/order/crm/dto/CRMAnagRequestDTO.java
+++ b/ems-engine/src/main/java/it/integry/ems/order/crm/dto/CRMAnagRequestDTO.java
@@ -1,10 +1,11 @@
 package it.integry.ems.order.crm.dto;
 
+import java.time.LocalDateTime;
 import java.util.Date;
 
 public class CRMAnagRequestDTO {
 
-    private Date filterDate;
+    private LocalDateTime filterDate;
 
     private String flagStato;
     private String partitaIva;
@@ -12,11 +13,11 @@ public class CRMAnagRequestDTO {
 
     private boolean returnPersRif;
 
-    public Date getFilterDate() {
+    public LocalDateTime getFilterDate() {
         return filterDate;
     }
 
-    public CRMAnagRequestDTO setFilterDate(Date filterDate) {
+    public CRMAnagRequestDTO setFilterDate(LocalDateTime filterDate) {
         this.filterDate = filterDate;
         return this;
     }
diff --git a/ems-engine/src/main/java/it/integry/ems/order/crm/service/CrmService.java b/ems-engine/src/main/java/it/integry/ems/order/crm/service/CrmService.java
index cdbbb0cfb2..209ae20243 100644
--- a/ems-engine/src/main/java/it/integry/ems/order/crm/service/CrmService.java
+++ b/ems-engine/src/main/java/it/integry/ems/order/crm/service/CrmService.java
@@ -530,7 +530,7 @@ public class CrmService {
         Connection conn = multiDBTransactionManager.getPrimaryConnection();
         CRMTransferProspectResponseDTO transferProspectResponse =
                 CRMUtility.prospectToClie(
-                        conn , request.getCodAnag(), request.getCodPpro()
+                        conn, request.getCodAnag(), request.getCodPpro()
                 );
 
         try {
@@ -545,7 +545,7 @@ public class CrmService {
             );
 
             CRMSyncResponseDTO crmSyncResponse = retrieveClienti(new CRMAnagRequestDTO().setCodAnag(codAnag));
-            if (!crmSyncResponse.getAnagClie().isEmpty()){
+            if (!crmSyncResponse.getAnagClie().isEmpty()) {
                 transferProspectResponse.setAnagClie(crmSyncResponse.getAnagClie().get(0));
             }
             transferProspectResponse.setVtbDest(crmSyncResponse.getVtbDest());
@@ -858,10 +858,12 @@ public class CrmService {
     }
 
     public List<JtbComt> retrieveCommesse(LocalDate dateFilter) throws Exception {
-        if (dateFilter != null) return null;
-
-        String sql = "SELECT * FROM jtb_comt";
+        if (dateFilter == null)
+            return UtilityDB.executeSimpleQueryDTO(
+                    multiDBTransactionManager.getPrimaryConnection(),
+                    "SELECT * FROM jtb_comt", JtbComt.class);
 
+        String sql = "SELECT * FROM jtb_comt WHERE data_mod >= " + UtilityDB.valueToString(dateFilter);
         return UtilityDB.executeSimpleQueryDTO(multiDBTransactionManager.getPrimaryConnection(), sql, JtbComt.class);
     }
 
@@ -870,7 +872,11 @@ public class CrmService {
 
         String sql = "SELECT * FROM ptb_pros WHERE cod_anag IS NULL";
         if (requestDTO.getFilterDate() != null)
-            sql = UtilityDB.addwhereCond(sql, "data_ins >= " + UtilityDB.valueToString(requestDTO.getFilterDate()), false);
+            sql = UtilityDB.addwhereCond(
+                    sql,
+                    "data_ins >= " + UtilityDB.valueToString(requestDTO.getFilterDate()) + " OR data_mod >= " + UtilityDB.valueToString(requestDTO.getFilterDate()),
+                    true
+            );
 
         if (requestDTO.getPartitaIva() != null)
             sql = UtilityDB.addwhereCond(sql, "part_iva = " + UtilityDB.valueToString(requestDTO.getPartitaIva()), false);
@@ -883,19 +889,13 @@ public class CrmService {
         );
 
         if (requestDTO.ReturnPersRif()) {
-            if (requestDTO.getFilterDate() == null) {
-                sql = "SELECT *\n" +
-                        "FROM ptb_pros_rif\n" +
-                        "WHERE EXISTS(SELECT * FROM ptb_pros WHERE ptb_pros.cod_anag IS NULL AND ptb_pros.cod_ppro = ptb_pros_rif.cod_ppro)";
-            } else {
-                sql = Query.format(
-                        "SELECT *\n" +
-                                "FROM ptb_pros_rif\n" +
-                                "WHERE EXISTS(SELECT * FROM ptb_pros WHERE ptb_pros.cod_anag IS NULL\n" +
-                                "                                      AND data_ins >= %s\n" +
-                                "                                      AND ptb_pros.cod_ppro = ptb_pros_rif.cod_ppro)",
-                        requestDTO.getFilterDate()
-                );
+            sql = "SELECT *\n" +
+                    "FROM ptb_pros_rif\n" +
+                    "WHERE EXISTS(SELECT * FROM ptb_pros WHERE ptb_pros.cod_anag IS NULL AND ptb_pros.cod_ppro = ptb_pros_rif.cod_ppro)";
+
+            if (requestDTO.getFilterDate() != null) {
+                sql = UtilityDB.addwhereCond(
+                        sql, "data_mod >= " + UtilityDB.valueToString(requestDTO.getFilterDate()), false);
             }
 
             taskSyncResponse.setPtbProsRif(
@@ -964,6 +964,11 @@ public class CrmService {
                     "FROM vtb_dest\n" +
                     "WHERE EXISTS(SELECT * FROM vtb_clie WHERE vtb_clie.cod_anag = vtb_dest.cod_anag)";
 
+            if (requestDTO.getFilterDate() != null) {
+                sql = UtilityDB.addwhereCond(
+                        sql, "data_mod >= " + UtilityDB.valueToString(requestDTO.getFilterDate()), false);
+            }
+
             if (requestDTO.getCodAnag() != null)
                 sql = UtilityDB.addwhereCond(sql, "cod_anag = " + UtilityDB.valueToString(requestDTO.getCodAnag()), false);
 
@@ -975,6 +980,11 @@ public class CrmService {
                     "FROM vtb_clie_pers_rif\n" +
                     "WHERE EXISTS(SELECT * FROM vtb_clie WHERE vtb_clie.cod_anag = vtb_clie_pers_rif.cod_anag)";
 
+            if (requestDTO.getFilterDate() != null) {
+                sql = UtilityDB.addwhereCond(
+                        sql, "data_ult_agg >= " + UtilityDB.valueToString(requestDTO.getFilterDate()), false);
+            }
+
             if (requestDTO.getCodAnag() != null)
                 sql = UtilityDB.addwhereCond(sql, "cod_anag = " + UtilityDB.valueToString(requestDTO.getCodAnag()), false);