From 011a93585c2fbe2b84558ed703ed61ecf84f7060 Mon Sep 17 00:00:00 2001 From: gaoyutao Date: Wed, 25 Mar 2026 17:55:37 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BC=98=E5=8C=96=E7=9C=81=E5=B8=82=E8=BF=90?= =?UTF-8?q?=E8=90=A5=E5=95=86=E4=BF=A1=E6=81=AF=E5=A4=84=E7=90=86=E3=80=82?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/com/tongran/rocketmq/handler/MessageHandler.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/tongran-rocketmq/src/main/java/com/tongran/rocketmq/handler/MessageHandler.java b/tongran-rocketmq/src/main/java/com/tongran/rocketmq/handler/MessageHandler.java index c8ef3d5..abdd104 100644 --- a/tongran-rocketmq/src/main/java/com/tongran/rocketmq/handler/MessageHandler.java +++ b/tongran-rocketmq/src/main/java/com/tongran/rocketmq/handler/MessageHandler.java @@ -2228,7 +2228,7 @@ public class MessageHandler { boolean needUpdate = false; // 逐个字段比较是否需要更新 - if (networkInfo.getCity() != null && !StringUtils.equals(networkInfo.getCity(), oldInterfaceMsg.getCity())) { + if (StringUtils.isNotEmpty(networkInfo.getCity()) && !StringUtils.equals(networkInfo.getCity(), oldInterfaceMsg.getCity())) { updateData.setCity(networkInfo.getCity()); needUpdate = true; } @@ -2240,15 +2240,15 @@ public class MessageHandler { updateData.setIpv6Address(networkInfo.getIpv6()); needUpdate = true; } - if (networkInfo.getProvince() != null && !StringUtils.equals(networkInfo.getProvince(), oldInterfaceMsg.getProvince())) { + if (StringUtils.isNotEmpty(networkInfo.getProvince()) && !StringUtils.equals(networkInfo.getProvince(), oldInterfaceMsg.getProvince())) { updateData.setProvince(networkInfo.getProvince()); needUpdate = true; } - if (networkInfo.getPublicIp() != null && !StringUtils.equals(networkInfo.getPublicIp(), oldInterfaceMsg.getPublicIp())) { + if (StringUtils.isNotEmpty(networkInfo.getPublicIp()) && !StringUtils.equals(networkInfo.getPublicIp(), oldInterfaceMsg.getPublicIp())) { updateData.setPublicIp(networkInfo.getPublicIp()); needUpdate = true; } - if (networkInfo.getCarrier() != null && !StringUtils.equals(networkInfo.getCarrier(), oldInterfaceMsg.getIsp())) { + if (StringUtils.isNotEmpty(networkInfo.getCarrier()) && !StringUtils.equals(networkInfo.getCarrier(), oldInterfaceMsg.getIsp())) { updateData.setIsp(networkInfo.getCarrier()); needUpdate = true; }