同步台账优化

airport-ledger/src/main/java/com/sundot/airport/ledger/service/impl/LedgerSyncServiceImpl.java

@@ -213,7 +213,6 @@ public class LedgerSyncServiceImpl implements ILedgerSyncService {
 
         for (LedgerSupervisionProblem row : list) {
             String src = "supervision_problem:" + row.getId();
-            if (existsBySrc(src)) { skip++; continue; }
             if (!hasName(row.getInspectedName())) { skip++; continue; }
             // 按问题层级选取L3指标和默认分值
             String level = row.getProblemLevel() != null ? row.getProblemLevel() : "";
@@ -260,7 +259,6 @@ public class LedgerSyncServiceImpl implements ILedgerSyncService {
 
         for (LedgerRealtimeInterception row : list) {
             String src = "realtime_interception:" + row.getId();
-            if (existsBySrc(src)) { skip++; continue; }
             if (!hasName(row.getInspectorName())) { skip++; continue; }
             // 取【问题层级】字段，站层级扣1分，部门层级扣0.8分，其它层级跳过
             String level = row.getProblemLevel() != null ? row.getProblemLevel() : "";
@@ -313,7 +311,6 @@ public class LedgerSyncServiceImpl implements ILedgerSyncService {
         
         for (LedgerSecurityTest row : list) {
             String src = "security_test:" + row.getId();
-            if (existsBySrc(src)) { skip++; continue; }
             if (!"未通过".equals(row.getTestResult())) { skip++; continue; }
             if (!hasName(row.getTestedName())) { skip++; continue; }
             // 取层级字段（scoreIndicator），而不是testType
@@ -360,7 +357,6 @@ public class LedgerSyncServiceImpl implements ILedgerSyncService {
         
         for (LedgerUnsafeEvent row : list) {
             String src = "unsafe_event:" + row.getId();
-            if (existsBySrc(src)) { skip++; continue; }
             if (!hasName(row.getResponsibleName())) { skip++; continue; }
             String cat = row.getEventType() != null ? row.getEventType() : "";
             long l3Id; BigDecimal defaultSv;
@@ -407,7 +403,6 @@ public class LedgerSyncServiceImpl implements ILedgerSyncService {
         
         for (LedgerSeizureStats row : list) {
             String src = "seizure_stats:" + row.getId();
-            if (existsBySrc(src)) { skip++; continue; }
             if (!hasName(row.getInspectorName())) { skip++; continue; }
             String cat = row.getItemCategory() != null ? row.getItemCategory() : "";
             long l3Id; BigDecimal sv;
@@ -455,7 +450,6 @@ public class LedgerSyncServiceImpl implements ILedgerSyncService {
         
         for (LedgerRewardApproval row : list) {
             String src = "reward_approval:" + row.getId();
-            if (existsBySrc(src)) { skip++; continue; }
             if (!hasName(row.getPersonName())) { skip++; continue; }
             String result = row.getDisposalResult() != null ? row.getDisposalResult() : "";
             long l3Id; BigDecimal sv;
@@ -499,7 +493,6 @@ public class LedgerSyncServiceImpl implements ILedgerSyncService {
         
         for (LedgerServicePatrol row : list) {
             String src = "service_patrol:" + row.getId();
-            if (existsBySrc(src)) { skip++; continue; }
             if (!hasName(row.getInspectedName())) { skip++; continue; }
             String level = row.getProblemLevel() != null ? row.getProblemLevel() : "";
             long l3Id; BigDecimal defaultSv;
@@ -545,7 +538,6 @@ public class LedgerSyncServiceImpl implements ILedgerSyncService {
         
         for (LedgerComplaint row : list) {
             String src = "complaint:" + row.getId();
-            if (existsBySrc(src)) { skip++; continue; }
             if (!hasName(row.getResponsibleName())) { skip++; continue; }
             BigDecimal sv = row.getDeductScore() != null ? row.getDeductScore().negate() : NEG_TWO;
             ScoreEvent e = buildEvent(dimId, lv2, null, row.getResponsibleName(),
@@ -585,7 +577,6 @@ public class LedgerSyncServiceImpl implements ILedgerSyncService {
         
         for (LedgerTerminalBonus row : list) {
             String src = "terminal_bonus:" + row.getId();
-            if (existsBySrc(src)) { skip++; continue; }
             if (!hasName(row.getPersonName())) { skip++; continue; }
             BigDecimal sv = lv3.getScoreValue() != null ? lv3.getScoreValue() : ZERO;
             ScoreEvent e = buildEvent(dimId, lv2, lv3, row.getPersonName(),
@@ -624,7 +615,6 @@ public class LedgerSyncServiceImpl implements ILedgerSyncService {
         
         for (LedgerExamScore row : list) {
             String src = "exam_score:" + row.getId();
-            if (existsBySrc(src)) { skip++; continue; }
             if (!hasName(row.getPersonName())) { skip++; continue; }
             if (row.getTheoryScore() == null) { skip++; continue; }
             double score = row.getTheoryScore().doubleValue();
@@ -807,12 +797,6 @@ public class LedgerSyncServiceImpl implements ILedgerSyncService {
         return indCache.computeIfAbsent(id, indicatorMapper::selectById);
     }
 
-    private boolean existsBySrc(String sourceLedger) {
-        return scoreEventService.count(
-                new LambdaQueryWrapper<ScoreEvent>()
-                        .eq(ScoreEvent::getSourceLedger, sourceLedger)) > 0;
-    }
-
     private boolean hasName(String name) {
         return StringUtils.hasText(name);
     }