From 6721936cef653ec5338ce34ec9a5f2bb87b556a8 Mon Sep 17 00:00:00 2001 From: bayuzhen Date: Tue, 19 Nov 2024 17:01:08 +0800 Subject: [PATCH] =?UTF-8?q?fix=20=E8=B0=83=E7=94=A8=E8=BF=90=E6=8E=A7?= =?UTF-8?q?=E6=8E=A5=E5=8F=A3=E7=A9=BA=E6=8C=87=E9=92=88=E9=97=AE=E9=A2=98?= =?UTF-8?q?&=E6=B7=BB=E5=8A=A0=E6=97=A5=E5=BF=97?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../sms/booter/scheduler/YunKongMessageSchedule.java | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/bocloud.sms.booter/src/main/java/com/bocloud/sms/booter/scheduler/YunKongMessageSchedule.java b/bocloud.sms.booter/src/main/java/com/bocloud/sms/booter/scheduler/YunKongMessageSchedule.java index 07ec310..26434d7 100644 --- a/bocloud.sms.booter/src/main/java/com/bocloud/sms/booter/scheduler/YunKongMessageSchedule.java +++ b/bocloud.sms.booter/src/main/java/com/bocloud/sms/booter/scheduler/YunKongMessageSchedule.java @@ -15,6 +15,7 @@ import org.springframework.beans.factory.annotation.Value; import org.springframework.scheduling.annotation.Scheduled; import org.springframework.stereotype.Component; import org.springframework.util.Assert; +import org.springframework.util.StringUtils; import java.util.*; @@ -59,7 +60,7 @@ public class YunKongMessageSchedule { String url = host + "/system/common/queryYKInterface"; HttpClient httpClient = new HttpClient(PostDataFormat.RAW); - log.info("curl -k -X POST -H 'Content-Type: application/json' -d '{}' '{}'", JSON.toJSONString(request), url); + log.info("【运控接口】curl -k -X POST -H 'Content-Type: application/json' -d '{}' '{}'", JSON.toJSONString(request), url); Result result = httpClient.post(new HashMap<>(), request, url); Assert.isTrue(result.isSuccess(), result.getMessage()); @@ -70,6 +71,10 @@ public class YunKongMessageSchedule { for (int i = 0; i < array.size(); i++) { JSONObject item = array.getJSONObject(i); String externalId = item.getString("record_id"); + if (StringUtils.isEmpty(externalId)) { + log.info("【运控接口】当前外部id为null：" + item.toJSONString()); + continue; + } Message message = oldMessages.stream() .filter(m -> externalId.equals(m.getExternalId())) .findFirst().orElse(new Message());