diff --git a/xhpc-modules/xhpc-power-pile/src/main/java/com/xhpc/pp/server/ChargingPileEventHandler.java b/xhpc-modules/xhpc-power-pile/src/main/java/com/xhpc/pp/server/ChargingPileEventHandler.java index 5a87105b..856dc270 100644 --- a/xhpc-modules/xhpc-power-pile/src/main/java/com/xhpc/pp/server/ChargingPileEventHandler.java +++ b/xhpc-modules/xhpc-power-pile/src/main/java/com/xhpc/pp/server/ChargingPileEventHandler.java @@ -32,10 +32,12 @@ public class ChargingPileEventHandler implements ClientEventHandler { public void lostConnection(ClientHandler handler) { String pileNo = ChargingPileServer.getPileNo(handler); - String pkey = "pile:".concat(pileNo); - Map cachePile = REDIS.getCacheMap(pkey); - cachePile.put("status", RegisterLogic.DISCONNECTED); - REDIS.setCacheMap(pkey, cachePile); + if (pileNo != null) { + String pkey = "pile:".concat(pileNo); + Map cachePile = REDIS.getCacheMap(pkey); + cachePile.put("status", RegisterLogic.DISCONNECTED); + REDIS.setCacheMap(pkey, cachePile); + } log.info("-> ({}) - [{}] <- {}", pileNo, handler.getName(), handler.getSocket().getRemoteSocketAddress().toString()); }