diff --git a/jsowell-admin/src/main/java/com/jsowell/api/uniapp/JumpController.java b/jsowell-admin/src/main/java/com/jsowell/api/uniapp/JumpController.java index 1726fdbff..edefe3c82 100644 --- a/jsowell-admin/src/main/java/com/jsowell/api/uniapp/JumpController.java +++ b/jsowell-admin/src/main/java/com/jsowell/api/uniapp/JumpController.java @@ -64,6 +64,7 @@ public class JumpController extends BaseController { return response; } + // 针对汇鑫大厦的用户,自动加入集团中 private void addMember2MemberGroup(String memberId, PileConnectorVO vo) { if (vo == null || StringUtils.isBlank(memberId)) { return; 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 43abcd19f..e762babe1 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 @@ -696,6 +696,12 @@ public class PileConnectorInfoServiceImpl implements PileConnectorInfoService { int slowFree = 0; // 慢充空闲数 if (CollectionUtils.isNotEmpty(connectorList)) { + // 批量查询redis中的枪口状态 + List redisKeyList = connectorList.stream() + .map(x -> CacheConstants.PILE_CONNECTOR_STATUS_KEY + x.getPileConnectorCode()) + .collect(Collectors.toList()); + List statusList = redisCache.multiGet(redisKeyList); + for (ConnectorInfoVO connectorVO : connectorList) { String redisKey = CacheConstants.PILE_CONNECTOR_STATUS_KEY + connectorVO.getPileConnectorCode(); String status = redisCache.getCacheObject(redisKey);