diff --git a/1-sql/2026-03-06/yang.sql b/1-sql/2026-03-06/yang.sql
new file mode 100644
index 00000000..842e9543
--- /dev/null
+++ b/1-sql/2026-03-06/yang.sql
@@ -0,0 +1,3 @@
+-- 删除历史同步的enc信息
+delete from simulation_task_extra where property_name='abnormal';
+delete from simulation_task_ecn;
diff --git a/project/src/main/java/com/sdm/project/service/impl/LyricInternalNewServiceImpl.java b/project/src/main/java/com/sdm/project/service/impl/LyricInternalNewServiceImpl.java
index 859acbb8..97288982 100644
--- a/project/src/main/java/com/sdm/project/service/impl/LyricInternalNewServiceImpl.java
+++ b/project/src/main/java/com/sdm/project/service/impl/LyricInternalNewServiceImpl.java
@@ -131,7 +131,7 @@ public class LyricInternalNewServiceImpl  {
                 pageNum++;
                 // 9. batchSaveTaskEcns，记录EP异常的编码信息
                 try {
-                    int ecnsCount =  simulationTaskEcnService.batchRemoveSaveTaskEcns(newTaskEcns);
+                     simulationTaskEcnService.batchRemoveSaveTaskEcns(newTaskEcns);
                 } catch (Exception e) {
                     log.error("batchRemoveSaveTaskEcns error:{}", e.getMessage());
                 }
diff --git a/project/src/main/java/com/sdm/project/service/impl/SimulationTaskEcnServiceImpl.java b/project/src/main/java/com/sdm/project/service/impl/SimulationTaskEcnServiceImpl.java
index 0ef6088d..5c6b9aad 100644
--- a/project/src/main/java/com/sdm/project/service/impl/SimulationTaskEcnServiceImpl.java
+++ b/project/src/main/java/com/sdm/project/service/impl/SimulationTaskEcnServiceImpl.java
@@ -53,18 +53,19 @@ public class SimulationTaskEcnServiceImpl extends ServiceImpl<SimulationTaskEcnM
             );
         }
         // 4. 执行删除
-        boolean remove = this.remove(queryWrapper);
-        log.warn("batchSaveTaskEcns before delete: {}", remove);
-        if(!remove) {
-            log.error("batchSaveTaskEcns before delete failed");
-            throw new RuntimeException("batchSaveTaskEcns before delete failed");
+        try {
+            this.remove(queryWrapper);
+        } catch (Exception e) {
+            log.error("batchSaveTaskEcns before delete exception：{}", e.getMessage());
+            throw new RuntimeException("batchSaveTaskEcns before delete exception");
         }
+        // 5. 执行保存
         boolean b = this.saveBatch(newTaskEcns);
         if(!b) {
             log.error("batchSaveTaskEcns after save failed");
             throw new RuntimeException("batchSaveTaskEcns after save failed");
         }
-        log.info("batchSaveTaskEcns after save: {}", b);
+        log.info("batchSaveTaskEcns after save: {},counts:{}", b,newTaskEcns.size());
         return newTaskEcns.size();
     }