autumn/JChargePointProtocol
1
0
Fork 0
mirror of https://gitee.com/san-bing/JChargePointProtocol synced 2026-06-20 23:19:41 +08:00
Code Issues Packages Projects Releases Wiki Activity

不保存pileId维度的会话

Browse Source
This commit is contained in:
三丙
2024-10-16 15:21:06 +08:00
parent 5b7d42da9e
commit 6c3b5c46bf
2 changed files with 2 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
jcpp-app/src/main/java/sanbing/jcpp/app/service/cache/session/PileSessionCacheKey.java vendored
View File

@@ -7,35 +7,26 @@ package sanbing.jcpp.app.service.cache.session;
import lombok.Builder; import lombok.Builder;
import lombok.EqualsAndHashCode; import lombok.EqualsAndHashCode;
import lombok.Getter; import lombok.Getter;
import lombok.RequiredArgsConstructor;
import java.io.Serializable; import java.io.Serializable;
import java.util.Optional;
import java.util.UUID;
/** /**
* @author baigod * @author baigod
*/ */
@Getter @Getter
@EqualsAndHashCode @EqualsAndHashCode
@RequiredArgsConstructor
@Builder @Builder
public class PileSessionCacheKey implements Serializable { public class PileSessionCacheKey implements Serializable {
private final UUID pileId;
private final String pileCode; private final String pileCode;
public PileSessionCacheKey(UUID pileId) {
this(pileId, null);
}
public PileSessionCacheKey(String pileCode) { public PileSessionCacheKey(String pileCode) {
this(null, pileCode); this.pileCode = pileCode;
} }
@Override @Override
public String toString() { public String toString() {
return Optional.ofNullable(pileId).map(UUID::toString).orElse(pileCode); return pileCode;
} }
} }

1
jcpp-app/src/main/java/sanbing/jcpp/app/service/impl/DefaultPileProtocolService.java
View File

@@ -108,7 +108,6 @@ public class DefaultPileProtocolService implements PileProtocolService {
pileSession.setRemoteAddress(remoteAddress); pileSession.setRemoteAddress(remoteAddress);
pileSession.setNodeId(nodeId); pileSession.setNodeId(nodeId);
pileSession.setNodeWebapiIpPort(nodeWebapiIpPort); pileSession.setNodeWebapiIpPort(nodeWebapiIpPort);
pileSessionCache.put(new PileSessionCacheKey(pile.getId()), pileSession);
pileSessionCache.put(new PileSessionCacheKey(pile.getPileCode()), pileSession); pileSessionCache.put(new PileSessionCacheKey(pile.getPileCode()), pileSession);
} }