删除多余代码

service/src/main/java/com/kym/service/admin/impl/ConnectorInfoServiceImpl.java

@@ -14,7 +14,6 @@ import com.kym.entity.miniapp.ChargeOrder;
 import com.kym.mapper.admin.ConnectorInfoMapper;
 import com.kym.service.MyBaseServiceImpl;
 import com.kym.service.admin.ConnectorInfoService;
-import com.kym.service.admin.EquipmentRelationService;
 import com.kym.service.cache.KymCache;
 import com.kym.service.miniapp.ChargeOrderService;
 import org.springframework.beans.BeanUtils;
@@ -41,11 +40,8 @@ public class ConnectorInfoServiceImpl extends MyBaseServiceImpl<ConnectorInfoMap
 
     private final ChargeOrderService chargeOrderService;
 
-    private final EquipmentRelationService equipmentRelationService;
-
-    public ConnectorInfoServiceImpl(ChargeOrderService chargeOrderService, EquipmentRelationService equipmentRelationService) {
+    public ConnectorInfoServiceImpl(ChargeOrderService chargeOrderService) {
         this.chargeOrderService = chargeOrderService;
-        this.equipmentRelationService = equipmentRelationService;
     }
 
     @Override

service/src/main/java/com/kym/service/admin/impl/EquipmentRelationServiceImpl.java

@@ -1,17 +1,12 @@
 package com.kym.service.admin.impl;
 
 import com.baomidou.dynamic.datasource.annotation.DS;
-import com.baomidou.dynamic.datasource.toolkit.DynamicDataSourceContextHolder;
 import com.github.yulichang.base.MPJBaseServiceImpl;
 import com.kym.entity.admin.EquipmentRelation;
 import com.kym.mapper.admin.EquipmentRelationMapper;
 import com.kym.service.admin.EquipmentRelationService;
-import com.kym.service.cache.KymCache;
-import jakarta.annotation.PostConstruct;
 import org.springframework.stereotype.Service;
 
-import java.util.stream.Collectors;
-
 /**
  * <p>
  * 服务实现类
@@ -24,18 +19,6 @@ import java.util.stream.Collectors;
 @DS("db-admin")
 public class EquipmentRelationServiceImpl extends MPJBaseServiceImpl<EquipmentRelationMapper, EquipmentRelation> implements EquipmentRelationService {
 
-
-    @PostConstruct
-    private void init() {
-        // 初始化KymCache shortId:equipmentId
-        // 手动切换数据源
-        DynamicDataSourceContextHolder.push("db-admin");
-        KymCache.INSTANCE.putConnectorId2ShortId(list().stream().collect(Collectors.toMap(EquipmentRelation::getConnectorId, EquipmentRelation::getShortId)));
-        // 初始化KymCache connectorId:stationId
-        KymCache.INSTANCE.putConnectorId2StationId(list().stream().collect(Collectors.toMap(EquipmentRelation::getConnectorId, EquipmentRelation::getStationId)));
-        DynamicDataSourceContextHolder.poll();
-    }
-
     @Override
     public EquipmentRelation getByShortId(String shortId) {
         return lambdaQuery().eq(EquipmentRelation::getShortId, shortId).one();