diff --git a/xhpc-modules/xhpc-power-pile/src/main/java/com/xhpc/pp/server/RateModelTask.java b/xhpc-modules/xhpc-power-pile/src/main/java/com/xhpc/pp/server/RateModelTask.java index 47e82c32..0cb0e72c 100644 --- a/xhpc-modules/xhpc-power-pile/src/main/java/com/xhpc/pp/server/RateModelTask.java +++ b/xhpc-modules/xhpc-power-pile/src/main/java/com/xhpc/pp/server/RateModelTask.java @@ -31,7 +31,7 @@ public class RateModelTask { Set pks = stationDto.getPiles(); if (pks != null) for (String pk : pks) { Long rateModelIdPile = REDIS.getCacheMapValue(pk, "rateModelId"); - if (rateModelIdPile == null || !rateModelIdStation.equals(rateModelIdPile)) { + if (!rateModelIdStation.equals(rateModelIdPile)) { String gkPattern = ("gun:").concat(pk).concat("*"); Collection gks = REDIS.keys(gkPattern); boolean charging = false; @@ -47,8 +47,9 @@ public class RateModelTask { String rsmsg = RateModelRequestLogic.translate(pk.substring(5), rateModelIdStation, "0058"); try { handler.sendClientBinary(HexUtils.toBytes(rsmsg)); + log.info("pile[{}] rate model[{}] sent ⚪", pk, rateModelIdPile); } catch (IOException e) { - log.error("{} rate model not sent.", pk); + log.error("pile[{}] rate model[{}] not sent ×", pk, rateModelIdPile); } } }