配分事项表

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

@@ -10,8 +10,10 @@ import com.sundot.airport.common.utils.DateUtils;
 import com.sundot.airport.ledger.domain.*;
 import com.sundot.airport.ledger.mapper.*;
 import com.sundot.airport.ledger.service.ILedgerSyncService;
+import com.sundot.airport.system.domain.BasePosition;
 import com.sundot.airport.system.mapper.SysDeptMapper;
 import com.sundot.airport.system.mapper.SysUserMapper;
+import com.sundot.airport.system.service.IBasePositionService;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
@@ -62,11 +64,13 @@ public class LedgerSyncServiceImpl implements ILedgerSyncService {
     @Autowired private ScoreIndicatorMapper indicatorMapper;
     @Autowired private SysDeptMapper sysDeptMapper;
     @Autowired private SysUserMapper sysUserMapper;
+    @Autowired private IBasePositionService basePositionService;
 
     // ── Dimension ID cache (loaded once) ─────────────────────
     private final Map<String, Long> dimCache = new HashMap<>();
     private final Map<String, Long> deptCache = new HashMap<>();
     private final Map<String, Long> userCache = new HashMap<>();
+    private final Map<Long, BasePosition> positionCache = new HashMap<>();
 
     // ── Constants: Indicator IDs（与 score.sql 中的显式 ID 对应）─
     // dim1 安全防控能力
@@ -127,6 +131,7 @@ public class LedgerSyncServiceImpl implements ILedgerSyncService {
             loadDimCache();
             loadDeptCache();
             loadUserCache();
+            loadPositionCache();
             StringBuilder sb = new StringBuilder();
             int totalIns = 0, totalSkip = 0;
             for (String type : Arrays.asList(
@@ -153,6 +158,7 @@ public class LedgerSyncServiceImpl implements ILedgerSyncService {
             loadDimCache();
             loadDeptCache();
             loadUserCache();
+            loadPositionCache();
             return doSync(ledgerType);
         } finally {
             // 同步完成后清除缓存
@@ -551,6 +557,19 @@ public class LedgerSyncServiceImpl implements ILedgerSyncService {
         sysUserMapper.selectUserList(new SysUser()).forEach(d -> userCache.put(d.getNickName(), d.getUserId()));
     }
 
+    /** 缓存所有区域-航站楼关系 */
+    private void loadPositionCache() {
+        if (!positionCache.isEmpty()) return;
+        List<BasePosition> basePositionList = basePositionService.selectBasePositionListTree(new BasePosition());
+        basePositionList.forEach(terminl -> {
+            if (terminl.getChildren() != null && !terminl.getChildren().isEmpty()) {
+                terminl.getChildren().forEach(regional -> {
+                    positionCache.put(((BasePosition) regional).getId(), terminl);
+                });
+            }
+        });
+    }
+
     /**
      * 清除所有缓存
      */
@@ -558,6 +577,7 @@ public class LedgerSyncServiceImpl implements ILedgerSyncService {
         dimCache.clear();
         deptCache.clear();
         userCache.clear();
+        positionCache.clear();
         indCache.clear();
         indicatorNameToIdCache.clear();
     }
@@ -705,6 +725,12 @@ public class LedgerSyncServiceImpl implements ILedgerSyncService {
         e.setChannelName(channelNo);
         e.setRegionalName(location);
         e.setRegionalId(areaId);
+        // 通过区域查找航站楼
+        BasePosition terminl = positionCache.get(e.getRegionalId());
+        if (terminl != null) {
+            e.setTerminlId(terminl.getId());
+            e.setTerminlName(terminl.getName());
+        }
         e.setPostId(positionId);
         e.setPostName(position);
         // 通过人员名称解析组织信息（ID和名称）