This commit is contained in:
2024-03-07 16:35:34 +08:00
parent 5aa2fcc713
commit 50fc7cdf96
2 changed files with 7 additions and 0 deletions

View File

@@ -696,6 +696,12 @@ public class PileConnectorInfoServiceImpl implements PileConnectorInfoService {
int slowFree = 0; // 慢充空闲数
if (CollectionUtils.isNotEmpty(connectorList)) {
// 批量查询redis中的枪口状态
List<String> redisKeyList = connectorList.stream()
.map(x -> CacheConstants.PILE_CONNECTOR_STATUS_KEY + x.getPileConnectorCode())
.collect(Collectors.toList());
List<String> statusList = redisCache.multiGet(redisKeyList);
for (ConnectorInfoVO connectorVO : connectorList) {
String redisKey = CacheConstants.PILE_CONNECTOR_STATUS_KEY + connectorVO.getPileConnectorCode();
String status = redisCache.getCacheObject(redisKey);