diff --git a/evcs-modules/evcs-core/src/main/java/com/xhpc/evcs/notification/NotificationEquipChargeStatusTask.java b/evcs-modules/evcs-core/src/main/java/com/xhpc/evcs/notification/NotificationEquipChargeStatusTask.java index 38c60d47..51a17331 100644 --- a/evcs-modules/evcs-core/src/main/java/com/xhpc/evcs/notification/NotificationEquipChargeStatusTask.java +++ b/evcs-modules/evcs-core/src/main/java/com/xhpc/evcs/notification/NotificationEquipChargeStatusTask.java @@ -51,7 +51,6 @@ public class NotificationEquipChargeStatusTask extends CoreDispatcher { List authSecretTokenOutList = authSecretTokenRepository.findBySecretTokenType(SECRET_TOKEN_TYPE_OUT); final Collection gunkeys = REDIS.keys("gun:*"); for (AuthSecretToken authSecretToken : authSecretTokenOutList) { - for (String gunkey : gunkeys) { if (!gunkey.endsWith(".seqdec") && !gunkey.endsWith(".seqhex") && !gunkey.endsWith(".hori")) { final Map cacheGun = REDIS.getCacheMap(gunkey); @@ -59,8 +58,10 @@ public class NotificationEquipChargeStatusTask extends CoreDispatcher { if (isInteger(status)) { final String orderkey = cacheGun.get("orderkey").toString(); EquipChargeStatus equipChargeStatus = new EquipChargeStatus(); - equipChargeStatus.setStartChargeSeq(REDIS.getCacheMapValue(orderkey.replace("order:", "pushOrder:"), - "internetSerialNumber")); + final String internetSerialNumber = REDIS.getCacheMapValue(orderkey.replace("order:", "pushOrder:"), + "internetSerialNumber"); + if (!internetSerialNumber.startsWith(authSecretToken.getOperatorId3irdpty())) continue; + equipChargeStatus.setStartChargeSeq(internetSerialNumber); equipChargeStatus.setStartChargeSeqStat(2); equipChargeStatus.setConnectorID(orderkey.substring(6, 22)); String current = REDIS.getCacheMapValue(gunkey, "current"); @@ -204,8 +205,7 @@ public class NotificationEquipChargeStatusTask extends CoreDispatcher { EquipChargeStatusRes equipChargeStatusRes = DTOJsonHelper.parseResponseData(responseBody, EquipChargeStatusRes.class, authSecretTokenOut); if (equipChargeStatusRes != null && equipChargeStatusRes.getSuccStat() != 0) { - throw new RuntimeException(String.format("push equipment order status [%s] failed: %s", - equipChargeStatus.getStartChargeSeq(), responseBody)); + logger.error("push equipment order status [%s] failed: %s", equipChargeStatus.getStartChargeSeq(), responseBody); } }