From 30acfe8ce91b06582bbe80011a8cdd5d911dad93 Mon Sep 17 00:00:00 2001 From: zz Date: Tue, 7 Dec 2021 23:45:09 +0800 Subject: [PATCH] logit --- .../src/main/java/com/xhpc/pp/server/RateModelTask.java | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) 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); } } }