修改:lyric enc数据同步优化

This commit is contained in:
2026-03-05 14:32:54 +08:00
parent 609a5e5aa9
commit cfe09f4c86
3 changed files with 11 additions and 7 deletions

View File

@@ -0,0 +1,3 @@
-- 删除历史同步的enc信息
delete from simulation_task_extra where property_name='abnormal';
delete from simulation_task_ecn;

View File

@@ -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());
}

View File

@@ -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();
}