diff --git a/jsowell-pile/src/main/java/com/jsowell/pile/mapper/PileConnectorInfoMapper.java b/jsowell-pile/src/main/java/com/jsowell/pile/mapper/PileConnectorInfoMapper.java
index 425f3d77d..0cbf9e8e4 100644
--- a/jsowell-pile/src/main/java/com/jsowell/pile/mapper/PileConnectorInfoMapper.java
+++ b/jsowell-pile/src/main/java/com/jsowell/pile/mapper/PileConnectorInfoMapper.java
@@ -128,4 +128,11 @@ public interface PileConnectorInfoMapper {
      * @return
      */
     PileConnectorInfoVO getConnectorInfoByParams(@Param("dto") QueryConnectorInfoDTO dto);
+
+    /**
+     * 通过站点idList查询枪口列表信息
+     * @param stationIds
+     * @return
+     */
+    List<ConnectorInfoVO> batchSelectConnectorList(@Param("stationIds") List<String> stationIds);
 }
diff --git a/jsowell-pile/src/main/java/com/jsowell/pile/service/PileConnectorInfoService.java b/jsowell-pile/src/main/java/com/jsowell/pile/service/PileConnectorInfoService.java
index 1d31945cf..a7ed68530 100644
--- a/jsowell-pile/src/main/java/com/jsowell/pile/service/PileConnectorInfoService.java
+++ b/jsowell-pile/src/main/java/com/jsowell/pile/service/PileConnectorInfoService.java
@@ -114,6 +114,13 @@ public interface PileConnectorInfoService {
 
     List<ConnectorInfoVO> getConnectorListForLianLian(Long stationId);
 
+    /**
+     * 根据站点idList批量查询枪口数据
+     * @param stationIds
+     * @return
+     */
+    List<ConnectorInfoVO> batchSelectConnectorList(List<String> stationIds);
+
 	List<ConnectorInfoVO> selectConnectorInfoList(String pileSn);
 
 	PageResponse selectStationConnectorList(QueryConnectorListDTO dto);
diff --git a/jsowell-pile/src/main/java/com/jsowell/pile/service/impl/PileConnectorInfoServiceImpl.java b/jsowell-pile/src/main/java/com/jsowell/pile/service/impl/PileConnectorInfoServiceImpl.java
index 22243f7a3..6ab085135 100644
--- a/jsowell-pile/src/main/java/com/jsowell/pile/service/impl/PileConnectorInfoServiceImpl.java
+++ b/jsowell-pile/src/main/java/com/jsowell/pile/service/impl/PileConnectorInfoServiceImpl.java
@@ -46,10 +46,7 @@ import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
 import org.springframework.stereotype.Service;
 
 import java.math.BigDecimal;
-import java.util.LinkedHashMap;
-import java.util.List;
-import java.util.Map;
-import java.util.Objects;
+import java.util.*;
 import java.util.concurrent.CompletableFuture;
 import java.util.concurrent.TimeUnit;
 import java.util.stream.Collectors;
@@ -484,10 +481,67 @@ public class PileConnectorInfoServiceImpl implements PileConnectorInfoService {
         return list;
     }
 
+    @Override
     public List<ConnectorInfoVO> getConnectorListForLianLian(Long stationId) {
         return getUniAppConnectorList(stationId);
     }
 
+    /**
+     * 批量查询枪口列表接口
+     * @param stationIds
+     * @return
+     */
+    @Override
+    public List<ConnectorInfoVO> batchSelectConnectorList(List<String> stationIds){
+        List<ConnectorInfoVO> resultList = new ArrayList<>();
+        Map<String, List<ConnectorInfoVO>> map = new LinkedHashMap<>();
+        String baseRedisKey = CacheConstants.GET_UNIAPP_CONNECTOR_LIST_BY_STATION_ID;
+        // 先查询缓存数据
+        for (String stationId : stationIds) {
+            String redisKey = baseRedisKey + stationId;
+            List<ConnectorInfoVO> list = redisCache.getCacheList(redisKey);
+            if (CollectionUtils.isNotEmpty(list)) {
+                map.put(stationId, list);
+                // 重新设置缓存
+                redisCache.deleteObject(redisKey);
+                redisCache.setCacheList(redisKey, list);
+                redisCache.expire(redisKey, CacheConstants.cache_expire_time_1h);
+            }
+        }
+        // 先将已经有数据的stationId进行收集
+        List<String> hasDataStationIds = new ArrayList<>(map.keySet());
+        Collection<List<ConnectorInfoVO>> values = map.values();
+        // 筛选出没有数据的stationIds
+        List<String> noDataStationIds = stationIds.stream()
+                .filter(x -> !hasDataStationIds.contains(x))
+                .collect(Collectors.toList());
+        if (CollectionUtils.isNotEmpty(noDataStationIds)) {
+            // 重新查询数据库
+            // 通过stationIds批量查询数据库
+            List<ConnectorInfoVO> newConnectorInfoList = pileConnectorInfoMapper.batchSelectConnectorList(noDataStationIds);
+
+            values.add(newConnectorInfoList);
+
+            // 设置缓存
+            // 先将list根据站点id分组
+            Map<String, List<ConnectorInfoVO>> collect = newConnectorInfoList.stream()
+                    .collect(Collectors.groupingBy(ConnectorInfoVO::getStationId));
+            // 循环map并设置缓存
+            for (Map.Entry<String, List<ConnectorInfoVO>> entry : collect.entrySet()) {
+                String stationId = entry.getKey();
+                List<ConnectorInfoVO> voList = entry.getValue();
+
+                String redisKey = baseRedisKey + stationId;
+                redisCache.setCacheObject(redisKey, voList, CacheConstants.cache_expire_time_1h);
+            }
+        }
+
+        // 最终将 values 中的所有 ConnectorInfoVO 元素收集到 resultList
+        values.forEach(resultList::addAll);
+
+        return resultList;
+    }
+
     @Override
     public List<ConnectorInfoVO> selectConnectorInfoList(String pileSn) {
         // log.info("查询充电枪口详情-selectConnectorInfoList, param:{}", pileSn);
diff --git a/jsowell-pile/src/main/resources/mapper/pile/PileConnectorInfoMapper.xml b/jsowell-pile/src/main/resources/mapper/pile/PileConnectorInfoMapper.xml
index c241a0771..4e5cf5e33 100644
--- a/jsowell-pile/src/main/resources/mapper/pile/PileConnectorInfoMapper.xml
+++ b/jsowell-pile/src/main/resources/mapper/pile/PileConnectorInfoMapper.xml
@@ -285,4 +285,24 @@
         AND
             t3.pile_connector_code = #{dto.pileConnectorCode,jdbcType=VARCHAR}
     </select>
+
+    <select id="batchSelectConnectorList" resultType="com.jsowell.pile.vo.base.ConnectorInfoVO">
+        SELECT
+            t1.pile_connector_code as pileConnectorCode,
+            t2.station_id as stationId,
+            t1.STATUS as connectorStatus,
+            t1.pile_sn as pileSn,
+            t2.model_id as modelId,
+            t3.speed_type as chargingType,
+            t3.rated_power as ratedPower
+        FROM
+            pile_connector_info t1
+                JOIN pile_basic_info t2 ON (t1.pile_sn = t2.sn AND t2.del_flag = '0')
+                JOIN pile_model_info t3 ON (t2.model_id = t3.id AND t3.del_flag = '0')
+        WHERE t1.del_flag = '0'
+          AND t2.station_id in
+            <foreach collection="stationIds" item="stationId" open="(" separator="," close=")">
+                #{stationId, jdbcType=VARCHAR}
+            </foreach>
+    </select>
 </mapper>
\ No newline at end of file
diff --git a/jsowell-thirdparty/src/main/java/com/jsowell/thirdparty/platform/service/impl/GanSuPlatformServiceImpl.java b/jsowell-thirdparty/src/main/java/com/jsowell/thirdparty/platform/service/impl/GanSuPlatformServiceImpl.java
index 3fac00429..82a38d115 100644
--- a/jsowell-thirdparty/src/main/java/com/jsowell/thirdparty/platform/service/impl/GanSuPlatformServiceImpl.java
+++ b/jsowell-thirdparty/src/main/java/com/jsowell/thirdparty/platform/service/impl/GanSuPlatformServiceImpl.java
@@ -15,7 +15,10 @@ import com.jsowell.pile.service.*;
 import com.jsowell.pile.thirdparty.CommonParamsDTO;
 import com.jsowell.pile.thirdparty.EquipmentInfo;
 import com.jsowell.pile.vo.ThirdPartySecretInfoVO;
+import com.jsowell.pile.vo.base.ConnectorInfoVO;
 import com.jsowell.pile.vo.base.ThirdPartyStationInfoVO;
+import com.jsowell.thirdparty.lianlian.domain.ConnectorStatusInfo;
+import com.jsowell.thirdparty.lianlian.domain.StationStatusInfo;
 import com.jsowell.thirdparty.lianlian.vo.AccessTokenVO;
 import com.jsowell.thirdparty.platform.domain.SupStationInfo;
 import com.jsowell.thirdparty.platform.factory.ThirdPartyPlatformFactory;
@@ -201,6 +204,30 @@ public class GanSuPlatformServiceImpl implements ThirdPartyPlatformService {
         return ThirdPartyPlatformUtils.generateResultMap(map, thirdPartySecretInfoVO);
     }
 
+
+    /**
+     * 拉取充电站中的充电枪的状态数据  query_station_status
+     * @param dto 查询站点信息dto
+     * @return
+     */
+    @Override
+    public Map<String, String> queryStationStatus(QueryStationInfoDTO dto) {
+        List<String> stationIds = dto.getStationIds();
+        List<StationStatusInfo> StationStatusInfos = new ArrayList<>();
+        List<Object> connectorStatusInfos = new ArrayList<>();
+        // 查询密钥信息
+        ThirdPartySecretInfoVO thirdPartySecretInfoVO = getGanSuSecretInfo();
+
+        ConnectorStatusInfo connectorStatusInfo;
+        // 根据站点idList查询
+        List<ConnectorInfoVO> list = pileConnectorInfoService.batchSelectConnectorList(stationIds);
+
+
+
+
+        return null;
+    }
+
     /**
      * 获取甘肃平台密钥
      * @return